移动系统liao
2024-10-14 18a4451e5b7bf8f7f6a260796acb24adb3b2ccda
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,8 +296,8 @@
                retdata.BatchStatus = ret.BatchStatus;
                retdata.UpDataBy = "再次微信付款请求";
                retdata.UpDataTime = DateTime.Now;
                retdata.ErrorMsg = null;
                retdata.ErrorCode = null;
                retdata.ErrorMsg = ret.ErrorMessage;
                retdata.ErrorCode = ret.ErrorCode;
                await WeChatTransferOrderwork.UpdateAsync(retdata);
            }
            else
@@ -307,6 +310,9 @@
                retdata.UpDataTime = DateTime.Now;
                await WeChatTransferOrderwork.UpdateAsync(retdata);
                Log.Error($"WxTransfer微信支付处理 失败,传递Id为{msg} 错误原因:{retdata.ErrorMsg}");
                return;
            }