diff --git a/consume/egg_cannal_user_virtual_ coin_flow_aggregation_consume.go b/consume/egg_cannal_user_virtual_ coin_flow_aggregation_consume.go index 12b225e..1f43c06 100644 --- a/consume/egg_cannal_user_virtual_ coin_flow_aggregation_consume.go +++ b/consume/egg_cannal_user_virtual_ coin_flow_aggregation_consume.go @@ -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{}{