From 3ce5c6f76219d31fa01e62118461119be717d852 Mon Sep 17 00:00:00 2001
From: 15066119699 <bo.wu@finesys.com.cn>
Date: Tue, 11 Mar 2025 14:45:39 +0800
Subject: [PATCH] 1

---
 .../web/controller/app/AppTaskController.java | 21 ++++++++++++++-----
 .../com/ruoyi/quartz/task/TaskExecutor.java   | 12 ++++++++++-
 2 files changed, 27 insertions(+), 6 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/app/AppTaskController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/app/AppTaskController.java
index 7a241611..322a4b89 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/app/AppTaskController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/app/AppTaskController.java
@@ -168,7 +168,14 @@ public class AppTaskController extends BaseController
 
         return success(appLocation);
     }
-
+    private void updateAppTask(List<AppTask> appTasks){
+        for(AppTask appTask : appTasks){
+            AppTask appTask1 = new AppTask();
+            appTask1.setTaskId(appTask.getTaskId());
+            appTask1.setTaskStatus(appTask.getTaskStatus());
+            appTaskService.updateAppTask(appTask1);
+        }
+    }
     /**
      * 反馈任务状态
      */
@@ -208,7 +215,8 @@ public class AppTaskController extends BaseController
             if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
                 // 更新wms任务状态
                 thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(2));// 执行中
-                appTaskService.batchUpdateAppTask(thisWmsTaskList);
+               // appTaskService.batchUpdateAppTask(thisWmsTaskList);
+                updateAppTask(thisWmsTaskList);
             }
             return success("反馈任务执行中成功。");
         }
@@ -222,7 +230,8 @@ public class AppTaskController extends BaseController
             if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
                 // 更新wms任务状态
                 thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(5));// 任务完成
-                appTaskService.batchUpdateAppTask(thisWmsTaskList);
+               // appTaskService.batchUpdateAppTask(thisWmsTaskList);
+                updateAppTask(thisWmsTaskList);
             }
             return success("反馈任务完成成功。");
         }
@@ -236,7 +245,8 @@ public class AppTaskController extends BaseController
             if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
                 // 更新wms任务状态
                 thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(8));// wcs取消任务
-                appTaskService.batchUpdateAppTask(thisWmsTaskList);
+//                appTaskService.batchUpdateAppTask(thisWmsTaskList);
+                updateAppTask(thisWmsTaskList);
             }
             return success("反馈任务取消成功。");
         }
@@ -249,7 +259,8 @@ public class AppTaskController extends BaseController
             if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
                 // 更新wms任务状态
                 thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(9));// 任务异常
-                appTaskService.batchUpdateAppTask(thisWmsTaskList);
+//                appTaskService.batchUpdateAppTask(thisWmsTaskList);
+                updateAppTask(thisWmsTaskList);
             }
             return success("反馈任务异常成功。");
         }
diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/TaskExecutor.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/TaskExecutor.java
index 65ffb228..a1bdf45c 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/TaskExecutor.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/TaskExecutor.java
@@ -100,12 +100,22 @@ public class TaskExecutor {
         }
         if(!wcsTaskMap.isEmpty()) {
             // 更新wms任务
-            appTaskService.batchUpdateAppTask(executingWmsTaskList);
+            //appTaskService.batchUpdateAppTask(executingWmsTaskList);
+            updateAppTask(executingWmsTaskList);
             // 存储wcs任务
             appWcsTaskService.batchInsertAppWcsTask(new ArrayList<>(wcsTaskMap.values()));
         }
     }
 
+    private void updateAppTask(List<AppTask> appTasks){
+        for(AppTask appTask : appTasks){
+            AppTask appTask1 = new AppTask();
+            appTask1.setTaskId(appTask.getTaskId());
+            appTask1.setWcsTaskId(appTask.getWcsTaskId());
+            appTask1.setTaskStatus(appTask.getTaskStatus());
+            appTaskService.updateAppTask(appTask1);
+        }
+    }
     /**
      * 发送wcs任务
      * 任务状态为0