1 changed files with 4 additions and 3 deletions
Unified View
Diff Options
+ 4
- 3
rule/honey_dividend/contribution.go
View File
| @@ -64,7 +64,7 @@ func CollectContributionExchangeData(eg *xorm.Engine, masterId string, ch *rabbi | |||||
| var totalValues decimal.Decimal | var totalValues decimal.Decimal | ||||
| for { | for { | ||||
| var list []model.UserVirtualAmount | var list []model.UserVirtualAmount | ||||
| err = eg.Where("coin_id = ? and amount >= ?", base.CoinId, base.DestroyHoneyValues).Limit(pageSize, (page-1)*pageSize).Asc("id").Find(&list) | |||||
| err = eg.Where("coin_id = ? and amount > 0", base.CoinId).Limit(pageSize, (page-1)*pageSize).Asc("id").Find(&list) | |||||
| if err != nil { | if err != nil { | ||||
| fmt.Println("err:::::1111", err) | fmt.Println("err:::::1111", err) | ||||
| return | return | ||||
| @@ -88,12 +88,13 @@ func CollectContributionExchangeData(eg *xorm.Engine, masterId string, ch *rabbi | |||||
| }, md2.HoneyDividendRoutKeyForUserContributionExchange) | }, md2.HoneyDividendRoutKeyForUserContributionExchange) | ||||
| totalValues = totalValues.Add(tmpValue) | totalValues = totalValues.Add(tmpValue) | ||||
| } | } | ||||
| page++ | |||||
| time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000))) | time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000))) | ||||
| } | } | ||||
| //6、修改分红记录数据 | //6、修改分红记录数据 | ||||
| honeyContributionExchangeRecords.TotalContributionValues = totalValues.String() | |||||
| honeyContributionExchangeRecords.TotalExchangeHoneyValues = nowHoneys | |||||
| honeyContributionExchangeRecords.TotalContributionValues = nowHoneys | |||||
| honeyContributionExchangeRecords.TotalExchangeHoneyValues = totalValues.String() | |||||
| honeyContributionExchangeRecords.UserNums = zhios_order_relate_utils.StrToInt(nowUsers) | honeyContributionExchangeRecords.UserNums = zhios_order_relate_utils.StrToInt(nowUsers) | ||||
| honeyContributionExchangeRecords.State = 1 | honeyContributionExchangeRecords.State = 1 | ||||