From d66490d4dfbc811bca51a98c08dbbc444e258a30 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期二, 27 九月 2022 10:52:49 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/MonitorController.java |   91 ++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 76 insertions(+), 15 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/MonitorController.java b/src/main/java/com/zy/asrs/controller/MonitorController.java
index f746714..a3b2ccc 100644
--- a/src/main/java/com/zy/asrs/controller/MonitorController.java
+++ b/src/main/java/com/zy/asrs/controller/MonitorController.java
@@ -11,9 +11,16 @@
 import com.zy.core.CrnThread;
 import com.zy.core.cache.SlaveConnection;
 import com.zy.core.enums.SlaveType;
+import com.zy.core.model.LedSlave;
+import com.zy.core.model.command.LedCommand;
 import com.zy.core.model.protocol.CrnProtocol;
+import com.zy.core.properties.SlaveProperties;
+import com.zy.core.thread.LedThread;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
 
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -29,6 +36,8 @@
 
     @Autowired
     private ReportQueryMapper reportQueryMapper;
+    @Autowired
+    private SlaveProperties slaveProperties;
 
     /**
      * 鑾峰彇褰撳墠鏃堕棿
@@ -53,9 +62,11 @@
      * 鑾峰彇鍏朵粬淇℃伅
      */
     @GetMapping("/other")
-    public R monitorOther(@RequestParam("crnId") Integer crnId) {
+    public R monitorOther(@RequestParam("crnId") Integer crnId, @RequestParam("ledId") Integer ledId) {
         Double xSpeed = 0.0D;
         Double ySpeed = 0.0D;
+        Double zSpeed = 0.0D;
+        Short forkPos = 1;
         Double xDistance = 0.0D;
         Double yDistance = 0.0D;
         Double xDuration = 0.0D;
@@ -68,6 +79,21 @@
                 if (crnProtocol != null) {
                     xSpeed = Double.valueOf(crnProtocol.getXSpeed());
                     ySpeed = Double.valueOf(crnProtocol.getYSpeed());
+                    zSpeed = Double.valueOf(crnProtocol.getZSpeed());
+                    switch (crnProtocol.getForkPos()) {
+                        case 0:
+                            forkPos = 1;
+                            break;
+                        case 1:
+                            forkPos = 2;
+                            break;
+                        case 2:
+                            forkPos = 0;
+                            break;
+                        default:
+                            forkPos = 1;
+                            break;
+                    }
                     xDistance = Double.valueOf(crnProtocol.getXDistance());
                     yDistance = Double.valueOf(crnProtocol.getYDistance());
                     xDuration = Double.valueOf(crnProtocol.getXDuration());
@@ -76,21 +102,22 @@
             }
         }
 
-        xSpeed = Double.valueOf(new Random().nextInt(10));
-        ySpeed = Double.valueOf(new Random().nextInt(10));
-
-//        int totalWrk = reportQueryMapper.getTotalWrkByCrnId(crnId);
-//        int totalLoc = reportQueryMapper.getTotalLocByCrnId();
+        // 鑾峰彇杈撻�佺嚎plc绾跨▼
+        LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, ledId);
+        String ledContent = ledThread.getWorkNos().toString();
+//        ledContent = "ask鐨勬ā鍧楄惃婊″ぇ绠椾簡钀ㄦ弧澶т簡\n 鏄獦澧冨埌鍩冨強鍡插鍡瞈n 钀ㄨ揪濮嗘墦寮�钀ㄦ弧澶у嚡鎾掗害褰撳姵钀ㄦ弧澶ц�佸笀";
 
         return R.ok(
-                Cools.add("xSpeed", xSpeed) // 琛岃蛋閫熷害
-                .add("ySpeed", ySpeed)  // 鍗囬檷閫熷害
-//                .add("totalLoc", totalLoc)  // 鎬诲簱浣嶆暟
-//                .add("totalWrk", totalWrk)    // 鎬讳换鍔℃暟
-                .add("xDistance", xDistance)    // 绱璧拌璺濈km
-                .add("yDistance", yDistance)    // 绱鍗囬檷璺濈km
-                .add("xDuration", xDuration)    // 绱璧拌鏃堕暱h
-                .add("yDuration", yDuration)    // 绱鍗囬檷鏃堕暱h
+                Cools.add("xSpeed", Arith.multiplys(1, Math.abs(xSpeed), 1)) // 琛岃蛋閫熷害
+                .add("ySpeed", Arith.multiplys(1, Math.abs(ySpeed), 1))  // 鍗囬檷閫熷害
+                .add("zSpeed", Arith.multiplys(1, Math.abs(zSpeed), 1))  // 鍙夌墮閫熷害
+                .add("forkPos", forkPos)  // 鍙夌墮閫熷害
+                .add("xDistance", Arith.multiplys(1, Math.abs(xDistance), 1))    // 绱璧拌璺濈km
+                .add("yDistance", Arith.multiplys(1, Math.abs(yDistance), 1))   // 绱鍗囬檷璺濈km
+                .add("xDuration", Arith.multiplys(1, Math.abs(xDuration), 1))    // 绱璧拌鏃堕暱h
+                .add("yDuration", Arith.multiplys(1, Math.abs(yDuration), 1))    // 绱鍗囬檷鏃堕暱h
+                .add("isShow", !Cools.isEmpty(ledContent)) // 鏄惁鏄剧ず鍐呭
+                .add("content", ledContent) // 鏄剧ず鍐呭
         );
     }
 
@@ -213,7 +240,41 @@
 
 
 
+    /**
+     * 鑾峰彇鍏朵粬淇℃伅
+     */
+    @GetMapping("/led")
+    public R monitorLed(@RequestParam("ledId") Integer ledId) {
+        String ledContent = "";
+        List<LedCommand> commandList = null;
+        for (LedSlave slave : slaveProperties.getLed()) {
+            if (slave.getStaArr().contains(ledId)) {
+                LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, slave.getId());
+                if (null != ledThread) {
+                    ledContent = ledThread.getStringBuffer().toString();
+                    commandList = ledThread.getCommandList();
+                }
+            }
+        }
+        return R.ok().add(commandList);
+    }
 
+    /**
+     * 寮傚父閫氱煡
+     */
+    @GetMapping("/led/error")
+    public R monitorLedError(@RequestParam("ledId") Integer ledId) {
+        String errorMsg = "";
+        for (LedSlave slave : slaveProperties.getLed()) {
+            if (slave.getStaArr().contains(ledId)) {
+                LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, slave.getId());
+                if (null != ledThread) {
+                    errorMsg = ledThread.getErrorMsg().toString();
+                }
+            }
+        }
+        return R.ok().add(errorMsg);
+    }
 
 
 

--
Gitblit v1.9.1