From 4b05094288012d463141dd0c0699222e125ee233 Mon Sep 17 00:00:00 2001
From: wu <731351411@qq.com>
Date: 星期三, 24 七月 2024 19:18:43 +0800
Subject: [PATCH] 修改数据推送

---
 hangzhoumesParent/common/servicebase/src/main/java/com/mes/temperingglass/service/impl/TemperingGlassInfoServiceImpl.java |   13 ++++++++-----
 hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java                 |    9 +++++++--
 2 files changed, 15 insertions(+), 7 deletions(-)

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..0fddaea 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
@@ -55,11 +55,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/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java b/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java
index f7e63e5..b33022e 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
@@ -45,11 +45,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