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