|
|
@@ -70,7 +70,7 @@ func handleEggCanalUserVirtualCoinFlowAggregationConsume(msg []byte) error { |
|
|
|
return err |
|
|
|
} |
|
|
|
aggregationDb := implement.NewUserVirtualCoinFlowAggregationDb(db.Db) |
|
|
|
now := time.Now().AddDate(0, 0, 1) |
|
|
|
now := time.Now() |
|
|
|
|
|
|
|
if canalMsg.Data[0].CoinId == utils2.IntToStr(basicSetting.PersonEggEnergyCoinId) { |
|
|
|
userVirtualCoinFlowAggregation, err1 := aggregationDb.UserVirtualCoinFlowAggregationGetOneByParams(map[string]interface{}{ |
|
|
|