From 6994981f40f1573f54de1a1e402a7743073cf38e Mon Sep 17 00:00:00 2001
From: fyxc <fyxc@qq.com>
Date: 星期四, 22 五月 2025 14:26:30 +0800
Subject: [PATCH] server commit file

---
 src/main/java/com/zy/asrs/controller/MonitorController.java |  113 ++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 92 insertions(+), 21 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/MonitorController.java b/src/main/java/com/zy/asrs/controller/MonitorController.java
index 2d839dd..8f7ff4d 100644
--- a/src/main/java/com/zy/asrs/controller/MonitorController.java
+++ b/src/main/java/com/zy/asrs/controller/MonitorController.java
@@ -1,19 +1,29 @@
 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.*;
+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 +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);
+    }
 
     /**
      * 鑾峰彇褰撳墠鏃堕棿
@@ -53,7 +76,17 @@
      * 鑾峰彇鍏朵粬淇℃伅
      */
     @GetMapping("/other")
-    public R monitorOther(@RequestParam("crnId") Integer crnId) {
+    public R monitorOther(@RequestParam("crnId") Integer crnId, @RequestParam("ledId") Integer sta) {
+        Integer ledId = 0;
+        for (LedSlave led : slaveProperties.getLed()) {
+            for (Integer staNo : led.getInStaArr()) {
+                if (staNo.equals(sta)) {
+                    ledId = led.getId();
+                    break;
+                }
+            }
+        }
+
         Double xSpeed = 0.0D;
         Double ySpeed = 0.0D;
         Double zSpeed = 0.0D;
@@ -76,10 +109,10 @@
                             forkPos = 1;
                             break;
                         case 1:
-                            forkPos = 0;
+                            forkPos = 2;
                             break;
                         case 2:
-                            forkPos = 2;
+                            forkPos = 0;
                             break;
                         default:
                             forkPos = 1;
@@ -93,20 +126,22 @@
             }
         }
 
-//        int totalWrk = reportQueryMapper.getTotalWrkByCrnId(crnId);
-//        int totalLoc = reportQueryMapper.getTotalLocByCrnId();
+        // 鑾峰彇杈撻�佺嚎plc绾跨▼
+        LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, ledId);
+        String ledContent = Cools.isEmpty(ledThread) ? "" : ledThread.getWorkNos().toString();
+//        ledContent = "ask鐨勬ā鍧楄惃婊″ぇ绠椾簡钀ㄦ弧澶т簡\n 鏄獦澧冨埌鍩冨強鍡插鍡瞈n 钀ㄨ揪濮嗘墦寮�钀ㄦ弧澶у嚡鎾掗害褰撳姵钀ㄦ弧澶ц�佸笀";
 
         return R.ok(
-                Cools.add("xSpeed", xSpeed) // 琛岃蛋閫熷害
-                .add("ySpeed", ySpeed)  // 鍗囬檷閫熷害
-                .add("zSpeed", zSpeed)  // 鍙夌墮閫熷害
+                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("totalLoc", totalLoc)  // 鎬诲簱浣嶆暟
-//                .add("totalWrk", totalWrk)    // 鎬讳换鍔℃暟
-                .add("xDistance", xDistance)    // 绱璧拌璺濈km
-                .add("yDistance", yDistance)    // 绱鍗囬檷璺濈km
-                .add("xDuration", xDuration)    // 绱璧拌鏃堕暱h
-                .add("yDuration", yDuration)    // 绱鍗囬檷鏃堕暱h
+                .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) // 鏄剧ず鍐呭
         );
     }
 
@@ -181,6 +216,7 @@
     public R monitorLocRep(){
         List<Map<String, Object>> pie = new ArrayList<>();
 
+
         LocChartPie locUseRate = reportQueryMapper.getLocUseRate();
         if(locUseRate!=null) {
             Map<String, Object> map = new HashMap<>();
@@ -204,6 +240,7 @@
             pie.add(map3);
         }
 
+
         // 鎬诲簱浣嶆暟
         Integer total = (int) Arith.add(0, locUseRate.getFqty(), locUseRate.getOqty(), locUseRate.getUqty(), locUseRate.getXqty());
         // 浣跨敤涓�
@@ -214,16 +251,50 @@
 
         return R.ok(
                 Cools.add("pie", pie)
-                .add("stockCunt", locUseRate.getFqty())
-                .add("emptyCount", locUseRate.getOqty())
-                .add("noneCount", locUseRate.getXqty())
-                .add("total", total)
-                .add("used", used)
-                .add("usedPr", usedPr)
+                        .add("stockCunt", locUseRate.getFqty())
+                        .add("emptyCount", locUseRate.getOqty())
+                        .add("noneCount", locUseRate.getXqty())
+                        .add("total", total)
+                        .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.getInStaArr().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.getInStaArr().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