From 4686d9d5bc63a5aeb35452ee9049a4720123b992 Mon Sep 17 00:00:00 2001
From: 移动系统liao <liaoxujun@qq.com>
Date: 星期一, 30 九月 2024 15:37:14 +0800
Subject: [PATCH] no message
---
cylsg/EzInitQ/PayServiceMessageQ.cs | 36 +++++++++++++++++++++++++++---------
1 files changed, 27 insertions(+), 9 deletions(-)
diff --git a/cylsg/EzInitQ/PayServiceMessageQ.cs b/cylsg/EzInitQ/PayServiceMessageQ.cs
index 1b98ba1..a9194b3 100644
--- a/cylsg/EzInitQ/PayServiceMessageQ.cs
+++ b/cylsg/EzInitQ/PayServiceMessageQ.cs
@@ -195,7 +195,7 @@
var WeChatTransferOrderwork = new BaseRepository<WeChatTransferOrder>();
- var TransferOrder = await WeChatTransferOrderwork.AsQueryable().Includes(x => x.TransferDetailList).Where(x=>x.Id==msg.toInt()).FirstAsync();
+ var TransferOrder = await WeChatTransferOrderwork.AsQueryable().Includes(x => x.TransferDetailList).Includes(x => x.user).Where(x=>x.Id==msg.toInt()).FirstAsync();
if(TransferOrder == null)
{
Log.Error($"WxTransfer寰俊鏀粯澶勭悊 澶辫触锛屽師鍥犳槸娌℃湁鎵惧埌TransferOrder 锛屼紶閫扞d涓簕msg}");
@@ -207,13 +207,19 @@
return;
}
-
+ var UserWork = new BaseRepository<UserWorker>();
+ var userWk = await UserWork.GetFirstAsync(x => x.UserId == TransferOrder.UserID);
+ if(userWk == null) {
+ Log.Error($"WxTransfer寰俊鏀粯澶勭悊 澶辫触锛岃鐢ㄦ埛涓嶆槸宸ヤ汉 锛屼紶閫掔殑TransferOrder Id涓簕msg}");
+
+ return;
+ }
// 鍙戣捣鏀粯
var requit = _mapper.Map<CreateTransferBatchRequest>(TransferOrder);
requit.AppId = App.Configuration["WechatAPP:AppId"];
requit.BatchName = "灏忛晣涓存椂宸ュ伐璧勮浆璐�";
- requit.BatchRemark = "宸濆嵃涓存椂宸ュ伐璧勶紝鎿嶈繃200鐨勫绗旀敮浠�";
-
+ requit.BatchRemark = $"{TransferOrder.user.ItCode}{userWk.name?.Substring(0, 2)}{userWk.IdCode}";
+
var ret = await _wecharPayServicecs.Transfer(requit);
if (ret.IsSuccessful())
{
@@ -247,13 +253,13 @@
_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).Where(x => x.Id == msg.toInt()).FirstAsync();
+ var TransferOrder = await WeChatTransferOrderwork.AsQueryable().Includes(x => x.TransferDetailList).Includes(x=>x.user).Where(x => x.Id == msg.toInt()).FirstAsync();
if (TransferOrder == null)
{
- Log.Error($" 鍐嶆璋冪敤WxTransfer寰俊鏀粯澶勭悊 澶辫触锛屽師鍥犳槸娌℃湁鎵惧埌TransferOrder 锛屼紶閫扞d涓簕msg}");
+ Log.Error($" 鍐嶆璋冪敤WxTransfer寰俊鏀粯澶勭悊 澶辫触锛屽師鍥犳槸娌℃湁鎵惧埌TransferOrder锛屼紶閫扞d涓簕msg}");
return;
}
@@ -262,12 +268,22 @@
return;
}
+ var UserWork = new BaseRepository<UserWorker>();
+ var userWk = await UserWork.GetFirstAsync(x => x.UserId == TransferOrder.UserID);
+ if (userWk == null)
+ {
+ Log.Error($"WxTransfer寰俊鏀粯澶勭悊 澶辫触锛岃鐢ㄦ埛涓嶆槸宸ヤ汉 锛屼紶閫掔殑TransferOrder Id涓簕msg}");
- // 鍙戣捣鏀粯
+ return;
+ }
+ // 鍙戣捣鏀粯
+
var requit = _mapper.Map<CreateTransferBatchRequest>(TransferOrder);
+
+ requit.BatchName = msg;
requit.AppId = App.Configuration["WechatAPP:AppId"];
requit.BatchName = "灏忛晣涓存椂宸ュ伐璧勮浆璐�";
- requit.BatchRemark = "宸濆嵃涓存椂宸ュ伐璧勶紝鎿嶈繃200鐨勫绗旀敮浠�";
+ requit.BatchRemark = $"{TransferOrder.user.ItCode}{userWk.name?.Substring(0,2)}{userWk.IdCode}";
var ret = await _wecharPayServicecs.Transfer(requit);
if (ret.IsSuccessful())
@@ -277,6 +293,8 @@
retdata.BatchStatus = ret.BatchStatus;
retdata.UpDataBy = "鍐嶆寰俊浠樻璇锋眰";
retdata.UpDataTime = DateTime.Now;
+ retdata.ErrorMsg = null;
+ retdata.ErrorCode = null;
await WeChatTransferOrderwork.UpdateAsync(retdata);
}
else
--
Gitblit v1.9.1