From 5d0f7a5aa4ee994782f3f3bcc66e23653a6ac40a Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期五, 19 七月 2024 10:07:46 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/RgvController.java |   44 +++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 43 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..8f744ed 100644
--- a/src/main/java/com/zy/asrs/controller/RgvController.java
+++ b/src/main/java/com/zy/asrs/controller/RgvController.java
@@ -218,6 +218,9 @@
                    case 17://鎭㈠鑱旀満浠诲姟
                        DB="6.0";
                        break;
+                   case 18://娓呮鑱旀満浠诲姟
+                       DB="6.1";
+                       break;
                    default:
                        return R.error("鎸夐挳涓嶅瓨鍦紵锛燂紵锛燂紒锛侊紒");
                }
@@ -294,6 +297,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 +318,9 @@
                 break;
             case 3:
                 fetchPut = RgvTaskModeType.X_MOVE;
+                break;
+            case 4:
+                fetchPut = RgvTaskModeType.FETCH_PUT;
                 break;
             default:
                 return false;
@@ -326,7 +338,7 @@
 //        command.setDestinationStaNo2(param.getStaNo2());  // 鐩爣绔�
         command.setCommand((short) 0);
 
-        return rgvControl(command);
+        return rgvControlD(command);
     }
 
 
@@ -611,4 +623,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