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; }