From 227c4f1fc845080a70f230a2929fe76c204a9d9f Mon Sep 17 00:00:00 2001
From: vincent <1341870251@qq.com>
Date: 星期二, 18 八月 2020 15:08:50 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index ee847a6..781a542 100644
--- a/src/main/java/com/zy/asrs/controller/CrnController.java
+++ b/src/main/java/com/zy/asrs/controller/CrnController.java
@@ -327,6 +327,47 @@
         return R.ok("娓呴櫎鍛戒护鎴愬姛");
     }
 
+    @ManagerAuth(memo = "鎵嬪姩澶嶄綅")
+    @PostMapping("/operator/handleReset")
+    public R handleReset(CrnOperatorParam param) throws Exception {
+        if (param.getCrnNo() == null) {
+            throw new CoolException("璇烽�夋嫨鍫嗗灈鏈�");
+        }
+        // 鑾峰彇鍫嗗灈鏈虹紦瀛�
+        for (CrnSlave crn : slaveProperties.getCrn()) {
+            // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+            if (param.getCrnNo().equals(crn.getId())) {
+                CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());
+                if (crnThread == null) {
+                    throw new CoolException("鍫嗗灈鏈轰笉鍦ㄧ嚎");
+                }
+                CrnProtocol crnProtocol = crnThread.getCrnProtocol();
+                if (crnProtocol == null) {
+                    throw new CoolException("鍫嗗灈鏈轰笉鍦ㄧ嚎");
+                }
+                // 鍙湁鍑虹幇鎸囧畾寮傚父鎵嶈繘琛屽浣�
+                if (crnProtocol.getCrnError2().leftTakeNoneErr
+                        || crnProtocol.getCrnError2().rightTakeNoneErr
+                        || crnProtocol.getCrnError2().leftPutLoadErr
+                        || crnProtocol.getCrnError2().rightPutLoadErr) {
+                    CrnCommand command = new CrnCommand();
+                    command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
+                    command.setAckFinish((short) 1);  // 浠诲姟瀹屾垚纭浣�
+                    command.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
+                    // 寤舵椂鍙戦��
+                    Thread.sleep(3000L);
+                    if (MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(2, command))) {
+                        return R.ok();
+                    } else {
+                        throw new CoolException("鍛戒护涓嬪彂澶辫触");
+                    }
+                }
+            }
+        }
+
+        return R.error();
+    }
+
     private boolean crnControl(CrnCommand command){
         if (command.getCrnNo() == null) {
             throw new CoolException("璇烽�夋嫨鍫嗗灈鏈�");

--
Gitblit v1.9.1