From e4376621b9f87629004ffca35067e8dd75970a37 Mon Sep 17 00:00:00 2001
From: lsh <lsh>
Date: 星期五, 17 五月 2024 13:35:55 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/RgvController.java b/src/main/java/com/zy/asrs/controller/RgvController.java
index ecaf5ff..97112ee 100644
--- a/src/main/java/com/zy/asrs/controller/RgvController.java
+++ b/src/main/java/com/zy/asrs/controller/RgvController.java
@@ -294,6 +294,12 @@
         return rgvFetchSingleStepPut(param,3)?R.ok():R.error();
     }
 
+    @ManagerAuth(memo = "鍙栨斁")
+    @PostMapping("/operator/single/step/four/put")
+    public R rgvFetchSingleStepFourPut(RgvOperatorParam param){
+        return rgvFetchSingleStepPut(param,4)?R.ok():R.error();
+    }
+
     public boolean rgvFetchSingleStepPut(RgvOperatorParam param ,Integer type){
         wrkNo++;
         RgvCommand command = new RgvCommand();
@@ -309,6 +315,9 @@
                 break;
             case 3:
                 fetchPut = RgvTaskModeType.X_MOVE;
+                break;
+            case 4:
+                fetchPut = RgvTaskModeType.FETCH_PUT;
                 break;
             default:
                 return false;
@@ -326,7 +335,7 @@
 //        command.setDestinationStaNo2(param.getStaNo2());  // 鐩爣绔�
         command.setCommand((short) 0);
 
-        return rgvControl(command);
+        return rgvControlD(command);
     }
 
 
@@ -611,4 +620,34 @@
         return false;
     }
 
+    private boolean rgvControlD(RgvCommand command){
+        if (command.getRgvNo() == null) {
+            throw new CoolException("璇烽�夋嫨RGV");
+        }
+        for (RgvSlave rgv : slaveProperties.getRgv()) {
+            // 鑾峰彇RGV淇℃伅
+            if (command.getRgvNo().equals(rgv.getId())) {
+//                SiemensRgvThread rgvThread = (SiemensRgvThread) SlaveConnection.get(SlaveType.Rgv, rgv.getId());
+//                if (rgvThread == null) {
+//                    throw new CoolException("RGV涓嶅湪绾�");
+//                }
+//                RgvProtocol rgvProtocol = rgvThread.getRgvProtocol();
+//                if (rgvProtocol == null) {
+//                    throw new CoolException("RGV涓嶅湪绾�");
+//                }
+                try{
+                    if (MessageQueue.offer(SlaveType.Rgv, rgv.getId(), new Task(11, command))) {
+                        return true;
+                    } else {
+                        throw new CoolException("鍛戒护涓嬪彂澶辫触");
+                    }
+                }catch (Exception e){
+                    log.error("鍗曟浠诲姟涓嬪彂澶辫触锛屽紓甯革細"+e);
+                    throw new CoolException("鍛戒护涓嬪彂澶辫触");
+                }
+            }
+        }
+        return false;
+    }
+
 }
\ No newline at end of file

--
Gitblit v1.9.1