From 17abc106caecb59250c7f5fefae24b707e1a2ecf 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, 24 Mar 2026 10:42:39 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E6=8E=A8=E9=80=81=E8=B4=A6?=
 =?UTF-8?q?=E5=8D=95=E6=B7=BB=E5=8A=A0=E6=89=A7=E8=A1=8C=E6=97=A5=E5=BF=97?=
 =?UTF-8?q?;?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../repository/task/BillingScheduler.java     | 21 ++++++++-----------
 1 file changed, 9 insertions(+), 12 deletions(-)

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 a7de656dd..d9614afd6 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
@@ -50,18 +50,15 @@ public class BillingScheduler {
                     continue;
                 } else {
                     // 乐观锁更新状态，防止重复执行
-                    int updated = scheduledTaskMapper.updateStatusIfPending(
-                            task.getId(), "PENDING", "PROCESSING");
+                    //int updated = scheduledTaskMapper.updateStatusIfPending(task.getId(), "PENDING", "PROCESSING");
 
-                    if (updated > 0) {
-                        // 异步执行具体业务
-                        CompletableFuture.runAsync(() -> {
-                            executeTask(task);
-                        });
-                    }
+                    // 异步执行具体业务
+                    CompletableFuture.runAsync(() -> {
+                        executeTask(task);
+                    });
                 }
             } catch (Exception e) {
-                scheduledTaskMapper.updateStatus(task.getId(), "FAILED");
+                //scheduledTaskMapper.updateStatus(task.getId(), "FAILED");
             }
         }
     }
@@ -72,16 +69,16 @@ public class BillingScheduler {
             // 执行具体的出账逻辑
             scheduledTaskService.executeBilling(task.getBusId());
 
-            scheduledTaskMapper.updateStatus(task.getId(), "SUCCESS");
+            //scheduledTaskMapper.updateStatus(task.getId(), "SUCCESS");
             status = "SUCCESS";
         } catch (Exception e) {
             // 重试机制
             scheduledTaskMapper.incrementRetryCount(task.getId());
             if (task.getRetryCount() < 3) {
-                scheduledTaskMapper.updateStatus(task.getId(), "PENDING");
+                //scheduledTaskMapper.updateStatus(task.getId(), "PENDING");
             } else {
                 status = "FAILED";
-                scheduledTaskMapper.updateStatus(task.getId(), "FAILED");
+                //scheduledTaskMapper.updateStatus(task.getId(), "FAILED");
             }
         }
         ScheduledTaskLog log = new ScheduledTaskLog();