From d86bc04d0b34f2b7d9ddbd30ee703b51d48876e8 Mon Sep 17 00:00:00 2001 From: username@email.com <yzy2002yzy@163.com> Date: 星期三, 05 二月 2025 09:51:15 +0800 Subject: [PATCH] 修改审核中员工排在前边 --- cylsg/EzInitQ/PayServiceMessageQ.cs | 22 +++++++++++++++------- 1 files changed, 15 insertions(+), 7 deletions(-) diff --git a/cylsg/EzInitQ/PayServiceMessageQ.cs b/cylsg/EzInitQ/PayServiceMessageQ.cs index a113317..d4e47d4 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}"); @@ -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) @@ -286,6 +287,8 @@ 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