From 61cae17b15d6a7d256e25ce42f0a4ef4163fd088 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期四, 11 九月 2025 15:54:03 +0800
Subject: [PATCH] 1、删除未修改的大屏程序

---
 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java |   55 +++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 51 insertions(+), 4 deletions(-)

diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
index e964692..85d6675 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
@@ -20,6 +20,8 @@
 import com.mes.edgstoragecage.entity.EdgStorageCageDetails;
 import com.mes.edgstoragecage.service.EdgStorageCageDetailsService;
 import com.mes.edgstoragecage.service.EdgStorageCageService;
+import com.mes.engineering.entity.Engineering;
+import com.mes.engineering.mapper.EngineeringMapper;
 import com.mes.glassinfo.entity.GlassInfo;
 import com.mes.glassinfo.service.GlassInfoService;
 import com.mes.taskcache.entity.TaskCache;
@@ -64,6 +66,9 @@
     WebSocketServer webServerService;
     @Autowired
     DamageService damageService;
+    @Autowired
+    EngineeringMapper engineeringMapper;
+
 
     @Value("${mes.threshold}")
     private int threshold;
@@ -121,11 +126,11 @@
         }
 
 //        taskRequestTypeValue = "2";
-//        out08Glassstate = "1";
+//        out08Glassstate = "0";
 //        out10Glassstate = "1";
 //        currentSlot = "1";
 //        confirmationWrodValue = "0";
-//        glassIdeValue = "P25021704|75|12";
+//        glassIdeValue = "";
 
         log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佸垎鍒负锛欰09:{}銆丄10:{},褰撳墠鏍煎瓙鍙蜂负锛歿}",
                 taskRequestTypeValue, glassIdeValue, confirmationWrodValue, out08Glassstate, out10Glassstate, currentSlot);
@@ -147,6 +152,20 @@
         if (!result) {
             log.info("姝ょ幓鐠僫d宸茬粡杩涜繃");
             return;
+        }
+        if (StringUtils.isNotBlank(glassIdeValue)) {
+            GlassInfo glassInfo = glassInfoService.getOne(
+                    new LambdaQueryWrapper<GlassInfo>()
+                            .eq(GlassInfo::getGlassId, glassIdeValue)
+            );
+            Engineering engineering = engineeringMapper.selectOne(
+                    new LambdaQueryWrapper<Engineering>()
+                            .eq(Engineering::getEngineerId, glassInfo.getEngineerId())
+            );
+            if (engineering.getState() == 2) {
+                log.info("姝よ鍗曞凡绂佹鐢熶骇");
+                return;
+            }
         }
         if ("1".equals(taskRequestTypeValue) && result) {
             log.info("2銆佽繘鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛岃繘鐗囦换鍔�,鎵爜閲嶅ID楠岃瘉銆愭湁閲嶅=false,鏃犻噸澶�=true銆戯細{}", result);
@@ -400,8 +419,13 @@
                             .eq(GlassInfo::getGlassId, glassId)
             );
             if (glassInfos != null) {
-                if (Math.max(glassInfos.getWidth(), glassInfos.getHeight()) > Integer.parseInt(firstLength) && out08Glassstate == 1) {
-                    endcell = Const.A09_OUT_TARGET_POSITION;
+                if (Math.max(glassInfos.getWidth(), glassInfos.getHeight()) > Integer.parseInt(firstLength)) {
+                    if (out08Glassstate == 1) {
+                        endcell = Const.A09_OUT_TARGET_POSITION;
+                    } else {
+                        log.info("褰撳墠鐜荤拑鍙兘璧板ぇ绾匡紝浣嗗ぇ绾挎湭绌洪棽鐜荤拑淇℃伅锛歿}", glassInfos);
+                        return Boolean.FALSE;
+                    }
                 } else {
                     endcell = computerLineByState(out08Glassstate, out10Glassstate);
                 }
@@ -993,4 +1017,27 @@
             }
         }
     }
+
+//    @Scheduled(fixedDelay = 1000)
+//    public void largenScreen() {
+//        JSONObject jsonObject = new JSONObject();
+//
+//        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("largenScreen");
+//        if (sendwServer != null) {
+//            List<PieChartVO> pieChartVOS = edgStorageCageDetailsService.queryPieChart();
+//            jsonObject.append("pieChartVOS", pieChartVOS);
+//            for (WebSocketServer webserver : sendwServer) {
+//                if (webserver != null) {
+//                    webserver.sendMessage(jsonObject.toString());
+//                    List<String> messages = webserver.getMessages();
+//                    if (!messages.isEmpty()) {
+//                        // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
+//                        webserver.clearMessages();
+//                    }
+//                } else {
+//                    log.info("largenScreen is closed");
+//                }
+//            }
+//        }
+//    }
 }

--
Gitblit v1.8.0