From e7143a517817ab744c9bf2701c1b478b310909c3 Mon Sep 17 00:00:00 2001 From: zhx Date: Mon, 25 May 2026 11:24:08 +0800 Subject: [PATCH] fix: tolerate missing recharge coin quantity --- internal/storage/recharge_reconcile.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/storage/recharge_reconcile.go b/internal/storage/recharge_reconcile.go index 999f44e..e124a56 100644 --- a/internal/storage/recharge_reconcile.go +++ b/internal/storage/recharge_reconcile.go @@ -161,7 +161,7 @@ func (r *MySQLRepository) StartRechargeReconciler(ctx context.Context, logger *s func (r *MySQLRepository) listOfficialRechargeRows(ctx context.Context, since time.Time, limit int) ([]officialRechargeRow, error) { rows, err := r.db.QueryContext(ctx, ` -SELECT CAST(o.id AS CHAR), o.user_id, o.sys_origin, o.pay_platform, o.unit_price, o.coin_quantity, o.create_time, +SELECT CAST(o.id AS CHAR), o.user_id, o.sys_origin, o.pay_platform, o.unit_price, 0 AS coin_quantity, o.create_time, u.id, u.origin_sys, IFNULL(NULLIF(u.country_code, ''), ?), IFNULL(NULLIF(u.country_name, ''), IFNULL(NULLIF(u.country_code, ''), ?)), IFNULL(u.is_del, 0), u.create_time, u.update_time