1

rule/consume_integral_settlement.go

@@ -142,7 +142,7 @@ func DailySettlementBlockConsumeIntegral(engine *xorm.Engine, mid string, isTask
 	}
 	userStatusList := userStatus(session, uids, 0, subsidyBase)
 	storeStatusList := userStatus(session, storeUids, 1, subsidyBase)
-	sql := `select uid, MAX(stop_date) as max_stop_date from subsidy_with_user_flow where uid in(%s) and kind in(1,2) order by create_at desc  limit 1`
+	sql := `select uid, MAX(stop_date) as max_stop_date from subsidy_with_user_flow where uid in(%s) and kind in(1,2)  group by uid`
 	sql = fmt.Sprintf(sql, strings.Join(uids, ","))
 	one, _ := db.QueryNativeStringSess(session, sql)
 	for _, v := range uids {
@@ -156,7 +156,7 @@ func DailySettlementBlockConsumeIntegral(engine *xorm.Engine, mid string, isTask
 			}
 		}
 	}
-	storesql := `select uid, MAX(stop_date) as max_stop_date from subsidy_with_user_flow where uid in(%s) and kind=3 order by create_at desc  limit 1`
+	storesql := `select uid, MAX(stop_date) as max_stop_date from subsidy_with_user_flow where uid in(%s) and kind=3 group by uid`
 	storesql = fmt.Sprintf(storesql, strings.Join(uids, ","))
 	storeone, _ := db.QueryNativeStringSess(session, storesql)
 	for _, v := range storeUids {