|
|
@@ -217,7 +217,7 @@ func statisticsAndDistributeCoinForStatic(session *xorm.Session, userIds []int, |
|
|
|
sumStaticValue := decimal.NewFromFloat(sumStatic) |
|
|
|
|
|
|
|
//2、查询出所有拥有静态贡献值的用户 |
|
|
|
err = session.Table("user_virtual_amount").In("uid", userIds).Where("coin_id =?", chain.Coin2).And("amount > 0").Find(&userVirtualAmounts) |
|
|
|
err = session.Table("user_virtual_amount").NotIn("uid", userIds).Where("coin_id =?", chain.Coin2).And("amount > 0").Find(&userVirtualAmounts) |
|
|
|
if err != nil { |
|
|
|
return err, unassignedTotalCoinValue |
|
|
|
} |
|
|
@@ -296,7 +296,7 @@ func statisticsAndDistributeCoinForDynamic(session *xorm.Session, userIds []int, |
|
|
|
sumStaticValue := decimal.NewFromFloat(sumStatic) |
|
|
|
|
|
|
|
//2、查询出所有拥有静态贡献值的用户 |
|
|
|
err = session.Table("user_virtual_amount").In("uid", userIds).Where("coin_id =?", chain.Coin2).And("amount > 0").Find(&userVirtualAmounts) |
|
|
|
err = session.Table("user_virtual_amount").NotIn("uid", userIds).Where("coin_id =?", chain.Coin2).And("amount > 0").Find(&userVirtualAmounts) |
|
|
|
if err != nil { |
|
|
|
return err, unassignedTotalCoinValue |
|
|
|
} |
|
|
|