流水计算增加日志
This commit is contained in:
1 parent
c59096dfd1
commit
2dc89f4c8e
1 file changed
+5
-3
@@ -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;
|
||||
}
|
||||
|
||||
|
||||
Reference in new issue
Block a user