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 <= #{endTime} and due_refund_amount is null and settle_amount is null + and order_code like 'C%' \ 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 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() {