From 3ceabb21c1fd2b7fbdbc5c77c23f26152ec7f9aa Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期五, 09 五月 2025 18:57:25 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/RgvController.java |   24 ++++++++++++++++++++++++
 1 files changed, 24 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/RgvController.java b/src/main/java/com/zy/asrs/controller/RgvController.java
index 9ea4f5c..e85e4de 100644
--- a/src/main/java/com/zy/asrs/controller/RgvController.java
+++ b/src/main/java/com/zy/asrs/controller/RgvController.java
@@ -51,6 +51,30 @@
         return R.ok().add(res);
     }
 
+    @PostMapping("/task/cache/all")
+    @ManagerAuth(memo = "鍏ㄩ儴淇℃伅")
+    public R allTaskCache(@RequestParam(defaultValue = "0")  Integer rgvNo){
+        List<Map<String, Object>> res = new ArrayList<>();
+        try{
+            RgvThread rgvThread = (RgvThread) SlaveConnection.get(SlaveType.Rgv, rgvNo);
+            TaskProtocolCache taskProtocolCache = rgvThread.getTaskProtocolCache();
+            ConcurrentHashMap<String, TaskProtocol> allTaskProtocol = taskProtocolCache.getAllTaskProtocol();
+            for (TaskProtocol taskProtocol : allTaskProtocol.values()){
+                Map<String, Object> map2 = new HashMap<>();
+                map2.put("rgvNo", rgvNo);
+                map2.put("taskNo", taskProtocol.getTaskNo());
+                map2.put("targetPosition", taskProtocol.getTargetPosition());
+                map2.put("isRunning", taskProtocol.getIsRunning());
+                map2.put("taskStatus", taskProtocol.getTaskStatus());
+                map2.put("direction", taskProtocol.isDirection());
+                res.add(map2);
+            }
+        } catch (Exception e){
+//            return R.error("寮傚父"+e.getMessage());
+        }
+        return R.ok().add(res);
+    }
+
     @PostMapping("/run/walk")//Take  Put  Walk
     @ManagerAuth(memo = "灏忚溅琛岃蛋")
     public R rgvRunWalk(@RequestParam(defaultValue = "0")  Integer rgvNo,

--
Gitblit v1.9.1