From 6671a156075e3fafe63b7768f2e81df4634f04f8 Mon Sep 17 00:00:00 2001
From: wangfei <3597712270@qq.com>
Date: 星期四, 25 七月 2024 10:21:57 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes

---
 UI-Project/config.js                                                                                                                         |    8 ++--
 UI-Project/src/views/Returns/returns.vue                                                                                                     |    6 +-
 hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java                                              |    7 ++-
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java |    1 
 UI-Project/src/utils/constants.js                                                                                                            |    4 +-
 hangzhoumesParent/common/servicebase/src/main/java/com/mes/temperingglass/service/impl/TemperingGlassInfoServiceImpl.java                    |   25 ++++++++----
 UI-Project/src/utils/WebSocketService.js                                                                                                     |    3 -
 hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java                                    |   14 +++++-
 8 files changed, 43 insertions(+), 25 deletions(-)

diff --git a/UI-Project/config.js b/UI-Project/config.js
index b15a1a5..7df122b 100644
--- a/UI-Project/config.js
+++ b/UI-Project/config.js
@@ -1,7 +1,7 @@
 export default {
- serverUrl: "10.153.19.150:88/api",
-//  serverUrl: "192.168.1.199:88/api",
-  serverUrl2: "10.153.19.150:88"
-  // serverUrl2: "192.168.1.199:88"
+//  serverUrl: "10.153.19.150:88/api",
+ serverUrl: "192.168.1.199:88/api",
+  // serverUrl2: "10.153.19.150:88"
+  serverUrl2: "192.168.1.199:88"
   //serverUrl:"res.abeim.cn"
 }
\ No newline at end of file
diff --git a/UI-Project/src/utils/WebSocketService.js b/UI-Project/src/utils/WebSocketService.js
index 4ad03b7..f74df0a 100644
--- a/UI-Project/src/utils/WebSocketService.js
+++ b/UI-Project/src/utils/WebSocketService.js
@@ -1,7 +1,7 @@
 // WebSocketService.js
 
 let socket = null;
-let messages = '';
+let messages='' ;
 export const initializeWebSocket = (socketUrl, messageHandler) => {
     if (typeof WebSocket === "undefined") {
       console.log("Your browser does not support WebSocket");
@@ -18,7 +18,6 @@
       if (!msg.data) {
         return;
       }
-      
       const isLastChunk = msg.data.endsWith('<END>');
       //鏄惁涓烘渶鍚庝竴鍧楁秷鎭�
       messages += msg.data;
diff --git a/UI-Project/src/utils/constants.js b/UI-Project/src/utils/constants.js
index 67d36d2..9a2423c 100644
--- a/UI-Project/src/utils/constants.js
+++ b/UI-Project/src/utils/constants.js
@@ -1,3 +1,3 @@
-// export const WebSocketHost = "192.168.1.199";
-export const WebSocketHost = "10.153.19.150";
+export const WebSocketHost = "192.168.1.199";
+// export const WebSocketHost = "10.153.19.150";
 export const host = "88";
\ No newline at end of file
diff --git a/UI-Project/src/views/Returns/returns.vue b/UI-Project/src/views/Returns/returns.vue
index e7e0451..26b1c91 100644
--- a/UI-Project/src/views/Returns/returns.vue
+++ b/UI-Project/src/views/Returns/returns.vue
@@ -594,11 +594,11 @@
     console.error('WebSocket杩炴帴寮傚父鍏抽棴');  
   }  
 };  
-  
 // 鐩戝惉WebSocket鐨勬秷鎭簨浠�  
 ws.onmessage = (event) => {  
   try {  
-    const data = JSON.parse(event.data); // 瑙f瀽娑堟伅涓篔SON  
+    
+    const data = JSON.parse(event.data.replace('<END>', '')); // 瑙f瀽娑堟伅涓篔SON  
   
     if (data && Array.isArray(data.InkageStatus) && data.InkageStatus.length > 0) {  
 if(data.InkageStatus!=null){
@@ -610,7 +610,7 @@
 }
     } else {  
       // 澶勭悊閿欒鎯呭喌鎴栨棤鏁堟暟鎹�  
-      console.error('鎺ユ敹鍒扮殑鏁版嵁鏃犳晥', data);  
+      // console.error('鎺ユ敹鍒扮殑鏁版嵁鏃犳晥', data);  
     }  
   } catch (error) {  
     // console.error('瑙f瀽WebSocket娑堟伅鏃跺彂鐢熼敊璇�', error);  
diff --git a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/temperingglass/service/impl/TemperingGlassInfoServiceImpl.java b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/temperingglass/service/impl/TemperingGlassInfoServiceImpl.java
index a7da6ff..d06778e 100644
--- a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/temperingglass/service/impl/TemperingGlassInfoServiceImpl.java
+++ b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/temperingglass/service/impl/TemperingGlassInfoServiceImpl.java
@@ -32,10 +32,14 @@
         QueryWrapper<TemperingGlassInfo> wrapper = new QueryWrapper<>();
         wrapper.select("Top 1 *").eq("state",1);
         TemperingGlassInfo glass=temperingMapper.selectOne(wrapper);
-        QueryWrapper<TemperingGlassInfo> glassinfo = new QueryWrapper<>();
-        glassinfo.eq("engineer_id",glass.getEngineerId())
-                .eq("tempering_layout_id", glass.getTemperingLayoutId());
-        return temperingMapper.selectList(glassinfo);
+        if(glass!=null) {
+            QueryWrapper<TemperingGlassInfo> glassinfo = new QueryWrapper<>();
+            glassinfo.eq("engineer_id", glass.getEngineerId())
+                    .eq("tempering_layout_id", glass.getTemperingLayoutId());
+            return temperingMapper.selectList(glassinfo);
+        }else {
+            return null;
+        }
     }
 
     @Override
@@ -55,11 +59,14 @@
         wrap.select("Top 1 *").eq("state",3);
         TemperingGlassInfo glass=temperingMapper.selectOne(wrap);
         //鏍规嵁宸ョ▼鍙峰拰鐗堝浘鑾峰彇鏁版嵁
-        QueryWrapper<TemperingGlassInfo> wapper = new QueryWrapper<>();
-        wapper.eq("engineer_id",glass.getEngineerId())
-                .eq("tempering_layout_id", glass.getTemperingLayoutId())
-                .orderByAsc("tempering_layout_id","tempering_feed_sequence");
-        return temperingMapper.selectList(wapper);
+        if(glass != null) {
+            QueryWrapper<TemperingGlassInfo> wapper = new QueryWrapper<>();
+            wapper.eq("engineer_id", glass.getEngineerId())
+                    .eq("tempering_layout_id", glass.getTemperingLayoutId())
+                    .orderByAsc("tempering_layout_id", "tempering_feed_sequence");
+            return temperingMapper.selectList(wapper);
+        }
+            return  null;
     }
 
     @Override
diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java
index 01b49c4..8de5698 100644
--- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java
+++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java
@@ -388,6 +388,7 @@
     public List<Map<String, Object>> selectTemperingGlass(){
         QueryWrapper<BigStorageCageDetails> wrapper = new QueryWrapper<>();
         wrapper.select("engineer_id,tempering_layout_id,count(*) as count")
+                .in("state",Const.GLASS_STATE_IN,Const.GLASS_STATE_ARTIFICIAL)
                 .groupBy("engineer_id,tempering_layout_id");
         List<Map<String, Object>> TemperingGlass = baseMapper.selectMaps(wrapper);
         return TemperingGlass;
diff --git a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
index 8c66de2..9c1a54e 100644
--- a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
+++ b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
@@ -120,7 +120,10 @@
         JSONObject jsonObject = new JSONObject();
         //姝e湪杩涜鐨勪换鍔�
         List<UpPattenUsage> upPattenUsages = upPattenUsageService.prioritylist();
-        jsonObject.append("prioritylist", upPattenUsages);
+        if(upPattenUsages!=null){
+            jsonObject.append("prioritylist", upPattenUsages);
+        }
+
         //宸ヤ綅淇℃伅
         List<UpWorkstation> upWorkstations = upWorkstationService.list();
         jsonObject.append("list", upWorkstations);
@@ -145,7 +148,7 @@
         JSONObject jsonObject = new JSONObject();
         //姝e湪杩涜鐨勪换鍔�
         String inkageStatus =plcParameterObject.getPlcParameter("MesToPlc").getValue();
-        //String inkageStatus ="1";
+//        String inkageStatus ="1";
         jsonObject.append("InkageStatus", inkageStatus);
         ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass");
         if (sendwServer != null) {
diff --git a/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java b/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java
index f7e63e5..e0a91f0 100644
--- a/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java
+++ b/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java
@@ -30,7 +30,10 @@
         JSONObject jsonObject = new JSONObject();
         //姝e湪绛夊緟杩涚墖鐨勭幓鐠�
         List<TemperingGlassInfo> waitingGlass = temperingAgoService.selectWaitingGlass();
-        jsonObject.append("waitingGlass", waitingGlass);
+        if(waitingGlass!=null){
+            jsonObject.append("waitingGlass", waitingGlass);
+        }
+
         //鑾峰彇鏁村湪鐐変腑鐨勪袱涓増鍥緄d
         List<TemperingGlassInfo> layoutId = temperingAgoService.selectLayoutId();
         //杩涚倝涓殑鐜荤拑
@@ -45,11 +48,16 @@
         }
         //鍑虹倝鍚庣殑鐜荤拑
         List<TemperingGlassInfo> outGlass = temperingAgoService.selectOutGlass();
-        jsonObject.append("outGlass", outGlass);
+        if(outGlass!=null){
+            jsonObject.append("outGlass", outGlass);
+        }
+
         //杩囨棆杞彴閽㈠寲鍚庣殑鐜荤拑
         List<TemperingGlassInfo> overGlass = temperingAgoService.selectOverGlass();
+        if (outGlass != null) {
+            jsonObject.append("overGlass", overGlass);
+        }
 
-        jsonObject.append("overGlass", overGlass);
 
         ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("temperingGlass");
         if (sendwServer != null) {

--
Gitblit v1.8.0