From 9a39d329e674485f3dddfb43408530f1f17d1837 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E5=A5=8E=E5=85=B4?= <2220574228@qq.com>
Date: Tue, 21 Apr 2026 16:15:35 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97;?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../persistence/ScheduledTaskServiceImpl.java |  1 +
 .../repository/task/BillingScheduler.java     | 24 ++++++++++++-------
 .../BusinessDocumentApplicationService.java   |  1 +
 3 files changed, 17 insertions(+), 9 deletions(-)

diff --git a/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/persistence/ScheduledTaskServiceImpl.java b/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/persistence/ScheduledTaskServiceImpl.java
index 53fd369ed..4248b2f9b 100644
--- a/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/persistence/ScheduledTaskServiceImpl.java
+++ b/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/persistence/ScheduledTaskServiceImpl.java
@@ -73,6 +73,7 @@ public class ScheduledTaskServiceImpl extends ServiceImpl<ScheduledTaskMapper, S
             } else if ("散租".equals(leaseType)) {
                 ScatteredRentalSynchronization(busId);
             }
+            log.info("结束执行出账业务");
         } catch (Exception e) {
             log.error("出账业务异常", e);
         }
diff --git a/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/task/BillingScheduler.java b/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/task/BillingScheduler.java
index d9614afd6..e209545bc 100644
--- a/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/task/BillingScheduler.java
+++ b/mhd-modules/mhd-system/src/main/java/com/mhd/basic/domain/scheduledTask/repository/task/BillingScheduler.java
@@ -64,13 +64,18 @@ public class BillingScheduler {
     }
 
     private void executeTask(ScheduledTask task) {
-        String status = "";
+        String status = "SUCCESS";
         try {
             // 执行具体的出账逻辑
             scheduledTaskService.executeBilling(task.getBusId());
-
+            ScheduledTaskLog log = new ScheduledTaskLog();
+            log.setTaskId(task.getId());
+            log.setBusId(task.getBusId());
+            log.setTaskStatus(status);
+            log.setExecuteTime(new Date());
+            scheduledTaskLogMapper.insert(log);
             //scheduledTaskMapper.updateStatus(task.getId(), "SUCCESS");
-            status = "SUCCESS";
+            //status = "SUCCESS";
         } catch (Exception e) {
             // 重试机制
             scheduledTaskMapper.incrementRetryCount(task.getId());
@@ -78,14 +83,15 @@ public class BillingScheduler {
                 //scheduledTaskMapper.updateStatus(task.getId(), "PENDING");
             } else {
                 status = "FAILED";
+                ScheduledTaskLog log = new ScheduledTaskLog();
+                log.setTaskId(task.getId());
+                log.setBusId(task.getBusId());
+                log.setTaskStatus(status);
+                log.setExecuteTime(new Date());
+                scheduledTaskLogMapper.insert(log);
                 //scheduledTaskMapper.updateStatus(task.getId(), "FAILED");
             }
         }
-        ScheduledTaskLog log = new ScheduledTaskLog();
-        log.setTaskId(task.getId());
-        log.setBusId(task.getBusId());
-        log.setTaskStatus(status);
-        log.setExecuteTime(new Date());
-        scheduledTaskLogMapper.insert(log);
+
     }
 }
\ No newline at end of file
diff --git a/mhd_bms/src/main/java/com/mhd/bms/application/server/businessDocument/BusinessDocumentApplicationService.java b/mhd_bms/src/main/java/com/mhd/bms/application/server/businessDocument/BusinessDocumentApplicationService.java
index d722338b5..7b7014500 100644
--- a/mhd_bms/src/main/java/com/mhd/bms/application/server/businessDocument/BusinessDocumentApplicationService.java
+++ b/mhd_bms/src/main/java/com/mhd/bms/application/server/businessDocument/BusinessDocumentApplicationService.java
@@ -953,6 +953,7 @@ public class BusinessDocumentApplicationService {
     @Transactional(rollbackFor = Exception.class)
     public Boolean wholeRentSynchronization(BusinessDocumentDO businessDocumentDO) {
         log.info("定时任务进入BMS业务单据保存--开始");
+        log.error("定时任务进入BMS业务单据保存--开始");
         //根据结算主题id查询 结算对象编码
         Long settlementEntityId = businessDocumentDO.getSettlementEntityId();
         List<SettlementCustomers> settlementCustomersList = settlementCustomersService.list(new LambdaQueryWrapper<SettlementCustomers>()