|
@@ -41,13 +41,13 @@ func CollectContributionExchangeData(eg *xorm.Engine, masterId string, ch *rabbi |
|
|
nowHoneys := zhios_order_relate_utils.IntToStr(base.ContributionExchangeLowerLimit) //当前贡献值总量 |
|
|
nowHoneys := zhios_order_relate_utils.IntToStr(base.ContributionExchangeLowerLimit) //当前贡献值总量 |
|
|
|
|
|
|
|
|
//2、统计当前`可以兑换`的用户数量 |
|
|
//2、统计当前`可以兑换`的用户数量 |
|
|
var sql2 = fmt.Sprintf("SELECT COUNT(*)AS total FROM `user_virtual_amount` WHERE coin_id = %d and amount >= %d", base.CoinIdForContribution, base.ContributionExchangeLowerLimit) |
|
|
|
|
|
|
|
|
var sql2 = fmt.Sprintf("SELECT COUNT(*)AS total FROM `user_virtual_amount` WHERE coin_id = %d and amount > 0", base.CoinIdForContribution) |
|
|
results2, _ := db.QueryNativeString(eg, sql2) |
|
|
results2, _ := db.QueryNativeString(eg, sql2) |
|
|
nowUsers := results2[0]["total"] //当前用户总量 |
|
|
nowUsers := results2[0]["total"] //当前用户总量 |
|
|
|
|
|
|
|
|
//3、计算数据 |
|
|
//3、计算数据 |
|
|
honeyContributionExchangeRecords := new(models.HoneyContributionExchangeRecords) |
|
|
honeyContributionExchangeRecords := new(models.HoneyContributionExchangeRecords) |
|
|
has, err := eg.Where("state =?", 0).Desc("id").Get(&honeyContributionExchangeRecords) |
|
|
|
|
|
|
|
|
has, err := eg.Where("state =?", 0).Desc("id").Get(honeyContributionExchangeRecords) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|