From 85cdffb1cce286951fbfe8b084defb750e431658 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期四, 03 四月 2025 14:23:51 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/MonitorController.java |   85 +++++++++++++++++++++++++++++++++++++-----
 1 files changed, 75 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/MonitorController.java b/src/main/java/com/zy/asrs/controller/MonitorController.java
index 8977b4f..7a49863 100644
--- a/src/main/java/com/zy/asrs/controller/MonitorController.java
+++ b/src/main/java/com/zy/asrs/controller/MonitorController.java
@@ -1,17 +1,23 @@
 package com.zy.asrs.controller;
 
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Arith;
 import com.core.common.Cools;
 import com.core.common.R;
 import com.zy.asrs.domain.dto.AxisBean;
 import com.zy.asrs.domain.dto.WorkChartAxis;
 import com.zy.asrs.domain.vo.LocChartPie;
+import com.zy.asrs.entity.LocDetl;
 import com.zy.asrs.mapper.ReportQueryMapper;
+import com.zy.asrs.service.LocDetlService;
 import com.zy.common.service.CommonService;
 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.GetMapping;
@@ -33,6 +39,19 @@
 
     @Autowired
     private ReportQueryMapper reportQueryMapper;
+    @Autowired
+    private SlaveProperties slaveProperties;
+    @Autowired
+    private LocDetlService locDetlService;
+
+    @GetMapping(value = "/locDetl/pda/statisticalModel")
+    public R statisticalModel() {
+        //浠撳簱鏁版嵁
+        EntityWrapper<LocDetl> locDetlEntityWrapper = new EntityWrapper<>();
+        locDetlEntityWrapper.setSqlSelect("matnr,count(*)as matnrCount").groupBy("matnr");
+        List<Map<String, Object>> selectMap = locDetlService.selectMaps(locDetlEntityWrapper);
+        return R.ok(selectMap);
+    }
 
     /**
      * 鑾峰彇褰撳墠鏃堕棿
@@ -57,7 +76,17 @@
      * 鑾峰彇鍏朵粬淇℃伅
      */
     @GetMapping("/other")
-    public R monitorOther(@RequestParam("crnId") Integer crnId, @RequestParam("ledId") Integer ledId) {
+    public R monitorOther(@RequestParam("crnId") Integer crnId, @RequestParam("ledId") Integer sta) {
+        Integer ledId = 0;
+        for (LedSlave led : slaveProperties.getLed()) {
+            for (Integer staNo : led.getStaArr()) {
+                if (staNo.equals(sta)) {
+                    ledId = led.getId();
+                    break;
+                }
+            }
+        }
+
         Double xSpeed = 0.0D;
         Double ySpeed = 0.0D;
         Double zSpeed = 0.0D;
@@ -99,7 +128,7 @@
 
         // 鑾峰彇杈撻�佺嚎plc绾跨▼
         LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, ledId);
-        String ledContent = ledThread.getWorkNos().toString();
+        String ledContent = Cools.isEmpty(ledThread) ? "" : ledThread.getWorkNos().toString();
 //        ledContent = "ask鐨勬ā鍧楄惃婊″ぇ绠椾簡钀ㄦ弧澶т簡\n 鏄獦澧冨埌鍩冨強鍡插鍡瞈n 钀ㄨ揪濮嗘墦寮�钀ㄦ弧澶у嚡鎾掗害褰撳姵钀ㄦ弧澶ц�佸笀";
 
         return R.ok(
@@ -187,7 +216,12 @@
     public R monitorLocRep(){
         List<Map<String, Object>> pie = new ArrayList<>();
 
+
         LocChartPie locUseRate = reportQueryMapper.getLocUseRate();
+        // 鎬诲簱浣嶆暟
+        Integer total = (int) Arith.add(0, locUseRate.getFqty(), locUseRate.getOqty(), locUseRate.getUqty(), locUseRate.getXqty());
+        // 浣跨敤涓�
+        Integer used = locUseRate.getFqty() + locUseRate.getUqty();
         if(locUseRate!=null) {
             Map<String, Object> map = new HashMap<>();
             map.put("name", "鍦ㄥ簱");
@@ -196,7 +230,7 @@
 
             Map<String, Object> map1 = new HashMap<>();
             map1.put("name", "绌�");
-            map1.put("value", locUseRate.getOqty());
+            map1.put("value", 11200-used);
             pie.add(map1);
 
             Map<String, Object> map2 = new HashMap<>();
@@ -210,26 +244,57 @@
             pie.add(map3);
         }
 
-        // 鎬诲簱浣嶆暟
-        Integer total = (int) Arith.add(0, locUseRate.getFqty(), locUseRate.getOqty(), locUseRate.getUqty(), locUseRate.getXqty());
-        // 浣跨敤涓�
-        Integer used = locUseRate.getFqty() + locUseRate.getUqty();
+
         // 搴撲綅浣跨敤鐜�
-        double usedDivides = Arith.divides(3, used, total);
+        double usedDivides = Arith.divides(3, used, 11200);
         double usedPr = Arith.multiplys(1, usedDivides, 100);
 
         return R.ok(
                 Cools.add("pie", pie)
                 .add("stockCunt", locUseRate.getFqty())
-                .add("emptyCount", locUseRate.getOqty())
+                .add("emptyCount", 11200-used)
                 .add("noneCount", locUseRate.getXqty())
-                .add("total", total)
+                .add("total", 11200)
                 .add("used", used)
                 .add("usedPr", usedPr)
         );
     }
 
+    /**
+     * 鑾峰彇鍏朵粬淇℃伅
+     */
+    @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