From 10dab7d3386ef06679c9d9a78c0dbf94e473aeeb Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期一, 22 四月 2024 14:56:45 +0800
Subject: [PATCH] #按钮

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

diff --git a/src/main/java/com/zy/asrs/controller/RgvController.java b/src/main/java/com/zy/asrs/controller/RgvController.java
index c46f545..b71f6c3 100644
--- a/src/main/java/com/zy/asrs/controller/RgvController.java
+++ b/src/main/java/com/zy/asrs/controller/RgvController.java
@@ -124,7 +124,7 @@
         }
 //        List<Map<String, Object>> res = new ArrayList<>();
         for (RgvSlave rgvSlave : slaveProperties.getRgv()) {
-            if (rgvSlave.getId() == rgvNo){
+            if (rgvSlave.getId().equals(rgvNo)){
                 rgvSlave.setDemo(true);
             }
         }
@@ -137,13 +137,85 @@
         }
 //        List<Map<String, Object>> res = new ArrayList<>();
         for (RgvSlave rgvSlave : slaveProperties.getRgv()) {
-            if (rgvSlave.getId() == rgvNo){
+            if (rgvSlave.getId().equals(rgvNo)){
                 rgvSlave.setDemo(false);
             }
         }
         return R.ok();
     }
 
+    @GetMapping("/demo/status/rgvStatus")
+    public R demoStatusTrue1(Integer rgvNo,Integer status){
+        if (Cools.isEmpty(rgvNo)){
+            return R.error("璇烽�夋嫨rgv");
+        }
+        if (Cools.isEmpty(status)){
+            return R.error("閫夋嫨鎸夐挳鏈夎");
+        }
+//        List<Map<String, Object>> res = new ArrayList<>();
+        for (RgvSlave rgvSlave : slaveProperties.getRgv()) {
+            // 鑾峰彇RGV淇℃伅
+            SiemensRgvThread rgvThread = (SiemensRgvThread) SlaveConnection.get(SlaveType.Rgv, rgvNo);
+            if (rgvThread == null) {
+                throw new CoolException("RGV涓嶅湪绾�");
+            }
+            RgvProtocol rgvProtocol = rgvThread.getRgvProtocol();
+            if (rgvProtocol == null) {
+                throw new CoolException("RGV涓嶅湪绾�");
+            }
+            String DB = "";
+            if (rgvSlave.getId().equals(rgvNo)){
+               switch (status){
+                   case 5://寮哄埗鍚姩
+                       DB="4.4";
+                       break;
+//                   case 6://澶嶄綅淇″彿
+//                       DB="4.5";
+//                       break;
+                   case 7://鎶ヨ娑堥煶
+                       DB="4.6";
+                       break;
+                   case 8://鍚姩
+                       DB="4.7";
+                       break;
+                   case 9://鍋滄
+                       DB="5.0";
+                       break;
+                   case 10://鎬ュ仠
+                       DB="5.1";
+                       break;
+                   case 11://澶嶄綅鎸夐挳
+                       DB="5.2";
+                       break;
+                   case 12://鎵嬪姩
+                       DB="5.3";
+                       break;
+                   case 13://鎵嬪姩瀹氫綅
+                       DB="5.4";
+                       break;
+                   case 14://鍗曟満
+                       DB="5.5";
+                       break;
+                   case 15://鑱旀満
+                       DB="5.6";
+                       break;
+                   case 16://璐у弶瀹氫綅鍥炰腑
+                       DB="5.7";
+                       break;
+                   default:
+                       return R.error("鎸夐挳涓嶅瓨鍦紵锛燂紵锛燂紒锛侊紒");
+               }
+               if (MessageQueue.offer(SlaveType.Rgv, rgvNo, new Task(10, DB))) {
+                   return R.ok();
+               } else {
+                   return R.error("鍛戒护涓嬪彂澶辫触");
+               }
+            }
+
+        }
+        return R.ok();
+    }
+
 
 
     @PostMapping("/demo/switch")

--
Gitblit v1.9.1