From 2dc89f4c8ec0ef95e90654e33f2447525d01cfa4 Mon Sep 17 00:00:00 2001 From: chfei Date: Thu, 27 Aug 2026 18:05:28 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=81=E6=B0=B4=E8=AE=A1=E7=AE=97=E5=A2=9E?= =?UTF-8?q?=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- KJD_WebService/BLL/WXXD/WXOemManage.cs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/KJD_WebService/BLL/WXXD/WXOemManage.cs b/KJD_WebService/BLL/WXXD/WXOemManage.cs index d5a9e7e..3a95bff 100644 --- a/KJD_WebService/BLL/WXXD/WXOemManage.cs +++ b/KJD_WebService/BLL/WXXD/WXOemManage.cs @@ -646,20 +646,22 @@ namespace KJD_Web.BLL.WXXD long total_fen = (long)Math.Round(total_amount * 100m); long rebate_fen = (long)Math.Round(rebate_amount * 100m); string now = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); - LogHelper.Info($"开始修改"); + LogHelper.Info($"开始修改金额"); // 3. 写oem金额 + 更新流水状态（同一事务） sql = "UPDATE wxxd.oem SET available_balance=available_balance+" + total_fen + ", total_rebate_amount=total_rebate_amount+" + rebate_fen + " WHERE oem_id='" + oem_id + "'"; var oemRst = mySql.ExecuteAffectedRows(sql); + LogHelper.Info($"开始修改金额{sql}"); if (!string.IsNullOrEmpty(mySql.Message) || oemRst <= 0) throw new Exception("结算流水到账户失败"); - + LogHelper.Info($"开始修改状态"); sql = "UPDATE wxxd.user_payment_record SET settlement=1,settlement_time='" + now + "' WHERE id IN (" + string.Join(",", settleIdLst) + ")"; var flowRst = mySql.ExecuteAffectedRows(sql); + LogHelper.Info($"开始修改状态{sql}"); + if (!string.IsNullOrEmpty(mySql.Message) || flowRst <= 0) throw new Exception("标记流水结算失败"); - return total_fen; }