From 033972b87d35210ca5dc6769ba8a09f46e062e43 Mon Sep 17 00:00:00 2001
From: Guoqs <123@jsowell.com>
Date: Wed, 16 Apr 2025 15:55:14 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E6=9C=AA=E5=88=86=E5=B8=90=E8=AE=A2=E5=8D=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/jsowell/quartz/task/JsowellTask.java   | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
index a8cbd9752..dd00fa7ad 100644
--- a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
+++ b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
@@ -354,6 +354,9 @@ public class JsowellTask {
         // 查询未分帐订单
         PageUtils.startPage(1, 500);
         List<OrderUnsplitRecord> list = orderUnsplitRecordService.queryUnsplitOrders(startTime, endTime);
+
+        log.info("处理未分帐订单start, 当前时间:{}, 查询出[{}]条未分账订单, 下面进行处理", DateUtils.getDateTime(), list.size());
+        int count = 0;
         for (OrderUnsplitRecord orderUnsplitRecord : list) {
             String paymentId = orderUnsplitRecord.getPaymentId();
             String orderCode = orderUnsplitRecord.getOrderCode();
@@ -376,15 +379,17 @@ public class JsowellTask {
 
             // 如果确认交易成功，则更新订单状态为已分账
             if (paymentConfirmResponse.isSuccess()) {
-                log.info("processUnsplitOrders, 分账成功, paymentId:{}", paymentId);
+                count++;
                 orderUnsplitRecord.setStatus(paymentConfirmResponse.getStatus());
                 orderUnsplitRecordService.updateOrderUnsplitRecord(orderUnsplitRecord);
+                log.info("processUnsplitOrders, 分账成功, paymentId:{}", paymentId);
             } else {
                 // 如果失败，打印日志
                 log.info("processUnsplitOrders, 分账失败, paymentId:{}, 错误信息:{}", paymentId, paymentConfirmResponse.getError_msg());
-                return;
+                break;
             }
         }
+        log.info("处理未分帐订单end, 当前时间:[{}], 成功分账[{}]条订单", DateUtils.getDateTime(), count);
     }
 
 }