diff --git a/internal/storage/game_sql.go b/internal/storage/game_sql.go index 5933102..228b4c0 100644 --- a/internal/storage/game_sql.go +++ b/internal/storage/game_sql.go @@ -90,7 +90,7 @@ INNER JOIN ` + quoteIdent(r.cfg.MySQL.Schema) + `.user_base_info u ON u.id = t.u WHERE ` + walletGameEventWhere() + ` AND (u.is_del = 0 OR u.is_del IS NULL) AND u.origin_sys = t.sys_origin -GROUP BY country_code, country_name, game_provider, game_id +GROUP BY t.sys_origin, country_code, country_name, game_provider, game_id ON DUPLICATE KEY UPDATE country_name = VALUES(country_name), game_name = VALUES(game_name), @@ -128,7 +128,7 @@ WHERE t.create_time >= ? AND t.create_time < ? AND t.sys_origin = ? AND (u.is_del = 0 OR u.is_del IS NULL) AND u.origin_sys = t.sys_origin -GROUP BY country_code, country_name +GROUP BY t.sys_origin, country_code, country_name ON DUPLICATE KEY UPDATE country_name = VALUES(country_name), game_name = VALUES(game_name),