From 595df5dac0a782bfdadab766b4dd62d326b0a383 Mon Sep 17 00:00:00 2001
From: 小飞侠 <8277136+liaoxujun@user.noreply.gitee.com>
Date: 星期二, 21 十月 2025 14:53:04 +0800
Subject: [PATCH] 增加川印设备维修回写
---
cylsg/EzJob/WeChatJob.cs | 85 ++++++++++++++++++++++++++++++------------
1 files changed, 61 insertions(+), 24 deletions(-)
diff --git a/cylsg/EzJob/WeChatJob.cs b/cylsg/EzJob/WeChatJob.cs
index 60c5e9a..3f45ef9 100644
--- a/cylsg/EzJob/WeChatJob.cs
+++ b/cylsg/EzJob/WeChatJob.cs
@@ -5,6 +5,7 @@
using Furion.FriendlyException;
using Furion.Schedule;
using Microsoft.AspNetCore.Http.HttpResults;
+using SKIT.FlurlHttpClient.Wechat.TenpayV3.Models;
using System;
using System.Collections.Generic;
using System.Linq;
@@ -32,57 +33,67 @@
}
var WeChatTransferOrderRs = new BaseRepository<WeChatTransferOrder>();
- var OderList = await WeChatTransferOrderRs.AsQueryable().Includes(x=>x.TransferDetailList).Where(x => (x.BatchId != null && x.BatchId != "") || 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 )
{
- var ret = await payServices.TransferBatches(new SKIT.FlurlHttpClient.Wechat.TenpayV3.Models.GetTransferBatchByBatchIdRequest
+ var ret = await payServices.TransferBatches(new GetTransferBatchByOutBatchNumberRequest
{
- BatchId = o.BatchId
+ OutBatchNumber = o.OutBatchNumber
+
+
- });
+ }); ;
if(ret != null)
{
if(ret.IsSuccessful())
- {
-
+ {
if (ret.TransferBatch.BatchStatus == "FINISHED")
{
//宸茬粡鍏ㄩ儴瀹屾垚
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();
- item.DetailStatus = del?.DetailStatus;
- switch (item.DetailStatus)
+ if (del != null)
+
{
- case "FAIL":
- //澶辫触锛岃幏鍙栧け璐ュ師鍥�
- var retde = await payServices.TransferBatchesDetails(new SKIT.FlurlHttpClient.Wechat.TenpayV3.Models.GetTransferBatchDetailByDetailIdRequest
- {
- BatchId = o.BatchId,
- DetailId = del.DetailId,
+ item.DetailStatus = del?.DetailStatus;
+ switch (item.DetailStatus)
+ {
+ case "FAIL":
+ //澶辫触锛岃幏鍙栧け璐ュ師鍥�
+ var retde = await payServices.TransferBatchesDetails(new SKIT.FlurlHttpClient.Wechat.TenpayV3.Models.GetTransferBatchDetailByDetailIdRequest
+ {
+ BatchId = o.BatchId,
+ DetailId = del.DetailId,
- });
+ });
- item.FailReason = retde?.FailReason;
- break;
- case "SUCCESS":
- item.DetailStatus = "SUCCESS";
+ item.FailReason = retde?.FailReason;
+ break;
+ case "SUCCESS":
+ item.DetailStatus = "SUCCESS";
- break;
+ break;
- default:
- item.DetailStatus = del?.DetailStatus;
- break;
+ default:
+ item.DetailStatus = del?.DetailStatus;
+ break;
+ }
}
@@ -92,7 +103,33 @@
}
+ else
+ if(ret.TransferBatch.BatchStatus== "PROCESSING")
+ {
+ o.BatchStatus = ret.TransferBatch.BatchStatus;
+ 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
+ {
+ //澶勭悊澶辫触
+ o.ErrorCode = ret.ErrorCode;
+ o.ErrorMsg = ret.ErrorMessage;
+ o.UpDataBy = "鏌ヨ浠诲姟WeChatJob";
+ o.UpDataTime = DateTime.Now;
+
+
+ }
+
+ await WeChatTransferOrderRs.UpdateRangeAsync(OderList);
}
}
}
--
Gitblit v1.9.1