移动系统liao
2024-10-14 18a4451e5b7bf8f7f6a260796acb24adb3b2ccda
cylsg/EzJob/WeChatJob.cs
@@ -33,7 +33,10 @@
            }
            var WeChatTransferOrderRs = new BaseRepository<WeChatTransferOrder>();
            var OderList = await WeChatTransferOrderRs.AsQueryable().Includes(x=>x.TransferDetailList).Where(x => (x.BatchId != null && x.BatchId != "")&&(x.BatchStatus==null|| x.BatchStatus == "ACCEPTED" || x.BatchStatus == "PROCESSING")).ToListAsync();
            var OderList = await WeChatTransferOrderRs.AsQueryable().Includes(x=>x.TransferDetailList).Where(x => (x.BatchId != null && x.BatchId != "")&&(
            (x.BatchStatus==null&&x.ErrorCode!= "INVALID_REQUEST") //代表支付时立即报错,不予查询
            || x.BatchStatus == "ACCEPTED" || x.BatchStatus == "PROCESSING")
            && x.IsSetOK==false).ToListAsync();
            foreach( var o in OderList )
            {
@@ -53,13 +56,15 @@
                        {
                            //已经全部完成
                            o.BatchStatus= ret.TransferBatch.BatchStatus;
                            o.UpDataBy = "ExecuteAsync";
                            o.UpDataBy = "查询任务WeChatJob";
                            o.UpDataTime=DateTime.Now;
                            o.CloseReason = ret.TransferBatch.CloseReason;
                            o.FailAmount= ret.TransferBatch.FailAmount;
                            o.FailNum = ret.TransferBatch.FailNumber;
                            o.SuccessNum = ret.TransferBatch.SuccessNumber;
                            o.SuccessAmount= ret.TransferBatch.SuccessAmount;
                            o.ErrorCode = ret.ErrorCode;
                            o.ErrorMsg = ret.ErrorCode;
                            foreach (var item in o.TransferDetailList)
                            {
                                var del =ret.TransferDetailList.Where(x=>x.OutDetailNumber==item.OutDetailNumber).FirstOrDefault();
@@ -102,13 +107,15 @@
                            if(ret.TransferBatch.BatchStatus== "PROCESSING")
                        {
                            o.BatchStatus = ret.TransferBatch.BatchStatus;
                            o.UpDataBy = "ExecuteAsync";
                            o.UpDataBy = "查询任务WeChatJob";
                            o.UpDataTime = DateTime.Now;
                            o.CloseReason = ret.TransferBatch.CloseReason;
                            o.FailAmount = ret.TransferBatch.FailAmount;
                            o.FailNum = ret.TransferBatch.FailNumber;
                            o.SuccessNum = ret.TransferBatch.SuccessNumber;
                            o.SuccessAmount = ret.TransferBatch.SuccessAmount;
                            o.ErrorMsg = null;
                            o.ErrorCode = null;
                        }
                    }
                    else
@@ -116,7 +123,7 @@
                        //处理失败
                        o.ErrorCode = ret.ErrorCode;
                        o.ErrorMsg = ret.ErrorMessage;
                        o.UpDataBy = "ExecuteAsync";
                        o.UpDataBy = "查询任务WeChatJob";
                        o.UpDataTime = DateTime.Now;