From 2665d0b12062dd08bc7a8bf6819f85aeafd6cd83 Mon Sep 17 00:00:00 2001
From: Guoqs <123@jsowell.com>
Date: Fri, 14 Nov 2025 16:13:31 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E6=89=93=E5=8D=B0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../resources/mapper/pile/AdapayUnsplitRecordMapper.xml    | 1 +
 .../src/main/java/com/jsowell/quartz/task/JsowellTask.java | 7 +++++--
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml b/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml
index 767f9fae2..bb03de5fa 100644
--- a/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml
+++ b/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml
@@ -704,5 +704,6 @@
     where pay_time >= #{startTime} and pay_time &lt;= #{endTime}
     and due_refund_amount is null
     and settle_amount is null
+    and order_code like 'C%'
     </select>
 </mapper>
\ No newline at end of file
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 99803d2d4..0e8a5d1cd 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
@@ -410,17 +410,19 @@ public class JsowellTask {
     public void processUnSettledOrder() {
         // processUnSettledOrderOld(); // 旧方法
         for (int i = 0; i < 35; i++) {
-            processUnSettledOrderNew(); // 新方法
+            int batchNum = i + 1;
+            processUnSettledOrderNew(batchNum); // 新方法
         }
     }
 
-    private void processUnSettledOrderNew() {
+    private void processUnSettledOrderNew(int batchNum) {
         String startTime = "2025-01-01 00:00:00";
         String endTime = "2025-12-31 23:59:59";
 
         // 查询未分帐订单
         PageUtils.startPage(1, 1000);
         List<AdapayUnsplitRecord> list = adapayUnsplitRecordService.queryUnsplitOrders(startTime, endTime);
+        log.info("第{}批次，共查询到{}条数据", batchNum, list.size());
         if (CollectionUtils.isEmpty(list)) {
             return;
         }
@@ -451,6 +453,7 @@ public class JsowellTask {
             updateList.add(adapayUnsplitRecord);
         }
         adapayUnsplitRecordService.updateBatchSelective(updateList);
+        log.info("第{}批次，共更新{}条数据", batchNum, updateList.size());
     }
 
     // private void processUnSettledOrderOld() {