From 4c87e40a3ca38b3fc2dab600cb033946e80bcbbd Mon Sep 17 00:00:00 2001
From: 小飞侠 <8277136+liaoxujun@user.noreply.gitee.com>
Date: 星期二, 07 四月 2026 13:05:18 +0800
Subject: [PATCH] no message
---
cylsg/EzInitQ/PayServiceMessageQ.cs | 26 +++++++++++++++++---------
1 files changed, 17 insertions(+), 9 deletions(-)
diff --git a/cylsg/EzInitQ/PayServiceMessageQ.cs b/cylsg/EzInitQ/PayServiceMessageQ.cs
index a113317..b04b8f2 100644
--- a/cylsg/EzInitQ/PayServiceMessageQ.cs
+++ b/cylsg/EzInitQ/PayServiceMessageQ.cs
@@ -175,7 +175,9 @@
retdata.BatchStatus= ret.BatchStatus;
retdata.UpDataBy = "寰俊浠樻璇锋眰涔嬪悗";
retdata.UpDataTime= DateTime.Now;
- await WeChatTransferOrderwork.UpdateAsync(retdata);
+ retdata.ErrorMsg = ret.ErrorMessage;
+ retdata.ErrorCode = ret.ErrorCode;
+ await WeChatTransferOrderwork.UpdateAsync(retdata);
}
else
throw Oops.Oh($"寰俊璇锋眰浠樻澶辫触+++++++++++++{ret.ToString()}+++++++++++msg{msg}");
@@ -217,7 +219,7 @@
// 鍙戣捣鏀粯
var requit = _mapper.Map<CreateTransferBatchRequest>(TransferOrder);
requit.AppId = App.Configuration["WechatAPP:AppId"];
- requit.BatchName = "灏忛晣涓存椂宸ュ伐璧勮浆璐�";
+ requit.BatchName = "宸濆嵃涓存椂宸ュ伐璧勮浆璐�";
requit.BatchRemark = $"{TransferOrder.user.ItCode}{userWk.name?.Substring(0, 2)}{userWk.IdCode}";
var ret = await _wecharPayServicecs.Transfer(requit);
@@ -228,6 +230,9 @@
retdata.BatchStatus = ret.BatchStatus;
retdata.UpDataBy = "寰俊浠樻璇锋眰涔嬪悗";
retdata.UpDataTime = DateTime.Now;
+ retdata.ErrorMsg = ret.ErrorMessage;
+ retdata.ErrorCode = ret.ErrorCode;
+
await WeChatTransferOrderwork.UpdateAsync(retdata);
}
else
@@ -253,7 +258,7 @@
_ezCoreNetRedisService = App.GetService<IEzCoreNetRedisService>();
_wecharPayServicecs = App.GetService<IWecharPayServicecs>();
_mapper = App.GetService<IMapper>();
-
+
var WeChatTransferOrderwork = new BaseRepository<WeChatTransferOrder>();
var TransferOrder = await WeChatTransferOrderwork.AsQueryable().Includes(x => x.TransferDetailList).Includes(x=>x.user).Where(x => x.Id == msg.toInt()).FirstAsync();
@@ -263,11 +268,7 @@
return;
}
- if (!string.IsNullOrEmpty(TransferOrder.BatchStatus))
- {
-
- return;
- }
+
var UserWork = new BaseRepository<UserWorker>();
var userWk = await UserWork.GetFirstAsync(x => x.UserId == TransferOrder.UserID);
if (userWk == null)
@@ -282,10 +283,12 @@
requit.BatchName = msg;
requit.AppId = App.Configuration["WechatAPP:AppId"];
- requit.BatchName = "灏忛晣涓存椂宸ュ伐璧勮浆璐�";
+ requit.BatchName = "宸濆嵃涓存椂宸ュ伐璧勮浆璐�";
requit.BatchRemark = $"{TransferOrder.user.ItCode}{userWk.name?.Substring(0,2)}{userWk.IdCode}";
var ret = await _wecharPayServicecs.Transfer(requit);
+
+
if (ret.IsSuccessful())
{
var retdata = await WeChatTransferOrderwork.GetByIdAsync(TransferOrder.Id);
@@ -293,6 +296,8 @@
retdata.BatchStatus = ret.BatchStatus;
retdata.UpDataBy = "鍐嶆寰俊浠樻璇锋眰";
retdata.UpDataTime = DateTime.Now;
+ retdata.ErrorMsg = ret.ErrorMessage;
+ retdata.ErrorCode = ret.ErrorCode;
await WeChatTransferOrderwork.UpdateAsync(retdata);
}
else
@@ -305,6 +310,9 @@
retdata.UpDataTime = DateTime.Now;
await WeChatTransferOrderwork.UpdateAsync(retdata);
Log.Error($"WxTransfer寰俊鏀粯澶勭悊 澶辫触锛屼紶閫扞d涓簕msg} 閿欒鍘熷洜:{retdata.ErrorMsg}");
+
+
+
return;
}
--
Gitblit v1.9.1