diff --git a/rule/block_star_chain_settlement.go b/rule/block_star_chain_settlement.go index 2028823..999a2b3 100644 --- a/rule/block_star_chain_settlement.go +++ b/rule/block_star_chain_settlement.go @@ -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 }