From 09de90a273d413c06306a921adc4fd25f205e2da Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期四, 21 八月 2025 11:10:37 +0800
Subject: [PATCH] 1

---
 src/main/java/com/zy/asrs/controller/TVController.java |   66 ++++++++++++++++++++++++++-------
 1 files changed, 52 insertions(+), 14 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/TVController.java b/src/main/java/com/zy/asrs/controller/TVController.java
index d797b27..5a4bb40 100644
--- a/src/main/java/com/zy/asrs/controller/TVController.java
+++ b/src/main/java/com/zy/asrs/controller/TVController.java
@@ -1,17 +1,13 @@
 package com.zy.asrs.controller;
 
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 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.dto.LocChartPie;
-import com.zy.asrs.entity.BasDevp;
-import com.zy.asrs.entity.BasShuttle;
+import com.zy.asrs.domain.dto.WorkChartAxis;
 import com.zy.asrs.entity.BasShuttleErr;
 import com.zy.asrs.entity.WrkMast;
 import com.zy.asrs.mapper.ReportQueryMapper;
@@ -19,19 +15,14 @@
 import com.zy.asrs.service.BasShuttleErrService;
 import com.zy.asrs.service.BasShuttleService;
 import com.zy.asrs.service.WrkMastService;
-import com.zy.common.model.MatDto;
-import com.zy.common.model.SearchLocParam;
 import com.zy.common.service.CommonService;
-import com.zy.common.utils.HttpHandler;
 import com.zy.common.utils.RedisUtil;
 import com.zy.core.cache.SlaveConnection;
 import com.zy.core.enums.SlaveType;
 import com.zy.core.model.LedSlave;
 import com.zy.core.model.ShuttleSlave;
-import com.zy.core.model.command.LedCommand;
 import com.zy.core.model.protocol.ShuttleProtocol;
 import com.zy.core.properties.SlaveProperties;
-import com.zy.core.thread.LedThread;
 import com.zy.core.thread.ShuttleThread;
 import com.zy.core.thread.impl.NormalLedThread;
 import lombok.extern.slf4j.Slf4j;
@@ -42,7 +33,6 @@
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.io.IOException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -69,6 +59,7 @@
     private SlaveProperties slaveProperties;
     @Autowired
     private BasShuttleErrService basShuttleErrService;
+
 
     @Autowired
     private RedisUtil redisUtil;
@@ -233,13 +224,13 @@
     public R monitorLed(@RequestParam("ledId") Integer ledId) {
         int dev_no1 = 1011;
         int dev_no2 = 1012;
-        int dev_no3 = 1015;
+        int dev_no3 = 0;
         if (ledId == 1) {
             dev_no1 = 1011;
             dev_no2 = 1012;
         } else if (ledId == 2) {
             dev_no1 = 1013;
-            dev_no2 = 1015;
+            dev_no2 = 1014;
             dev_no3 = 1015;
         } else if (ledId == 3) {
             dev_no1 = 1021;
@@ -318,8 +309,55 @@
     /**
      * 璁惧寮傚父閫氱煡
      */
+    @GetMapping("/sta/mode")
+    public R monitorStaMode(@RequestParam("ledId") Integer ledId) {
+        List<WrkMast> wrkMastList1 = null;
+        List<WrkMast> wrkMastList2 = null;
+        switch (ledId) {
+            case 1:
+                wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1014, 1022, 1025));
+                wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1013, 1021, 1024));
+                break;
+            case 2:
+                wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1012, 1022, 1025));
+                wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1011, 1021, 1024));
+                break;
+            case 3:
+                wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1012, 1014, 1025));
+                wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1011, 1013, 1024));
+                break;
+            case 4:
+                wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1012, 1014, 1022));
+                wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1011, 1013, 1021));
+                break;
+            default:
+                break;
+        }
+        if (!Cools.isEmpty(wrkMastList1)) {
+            String msg = "绔欑偣鍦ㄥ叆搴�;";
+            Set<Integer> set = new HashSet<>();
+            for (WrkMast wrkMast : wrkMastList1) {
+                set.add(wrkMast.getSourceStaNo());
+            }
+            return R.ok().add(set.toString() + msg);
+        }
+        if (!Cools.isEmpty(wrkMastList2)) {
+            String msg = "绔欑偣鍦ㄥ嚭搴�;";
+            Set<Integer> set = new HashSet<>();
+            for (WrkMast wrkMast : wrkMastList2) {
+                set.add(wrkMast.getSourceStaNo());
+            }
+            return R.ok().add(set.toString() + msg);
+        }
+        return R.ok();
+    }
+
+
+    /**
+     * 璁惧寮傚父閫氱煡
+     */
     @GetMapping("/device/error")
-    public R monitorDeviceError() {
+    public R monitorStaInfo() {
         ArrayList<HashMap<String, Object>> list = new ArrayList<>();
 
         for (ShuttleSlave shuttleSlave : slaveProperties.getShuttle()) {

--
Gitblit v1.9.1