From c6cb57f307b0c62a05cac78cfd828c313f10e611 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期二, 15 四月 2025 10:58:25 +0800
Subject: [PATCH] 1、卧式理片笼新增任务逻辑 2、入参时间加入时区

---
 hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/PlcTemperingGlassTask.java |   22 +++++++++++++++++-----
 1 files changed, 17 insertions(+), 5 deletions(-)

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 dd786f3..cf02b08 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
@@ -7,6 +7,7 @@
 import com.mes.damage.entity.Damage;
 import com.mes.damage.service.DamageService;
 import com.mes.engineering.entity.Engineering;
+import com.mes.largenscreen.entity.PieChartVO;
 import com.mes.temperingglass.service.TemperingGlassInfoService;
 import com.mes.temperingglass.entity.TemperingGlassInfo;
 import com.mes.tools.WebSocketServer;
@@ -113,13 +114,24 @@
         );
         jsonObject.append("temperingTaskType", putGlass);
         //澶у睆閽㈠寲淇℃伅
-        Integer temperingGlass = temperingAgoService.count(
-                new LambdaUpdateWrapper<TemperingGlassInfo>()
+        List<TemperingGlassInfo> temperingGlassInfoList = temperingAgoService.list(
+                new LambdaQueryWrapper<TemperingGlassInfo>()
+                        .select(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 閫夋嫨瑕佸幓閲嶇殑瀛楁
                         .eq(TemperingGlassInfo::getState, Const.TEMPERING_START)
-                        .groupBy(TemperingGlassInfo::getEngineerId,
-                                TemperingGlassInfo::getTemperingLayoutId)
+                        .groupBy(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 鎸� engineerId 鍜� temperingLayoutId 鍒嗙粍
         );
-        jsonObject.append("temperingGlass", temperingGlass);
+        jsonObject.append("temperingGlassInfoList", temperingGlassInfoList.size());
+        //澶у睆閽㈠寲淇℃伅
+        List<TemperingGlassInfo> temperingGlassInfoInList = temperingAgoService.list(
+                new LambdaQueryWrapper<TemperingGlassInfo>()
+                        .select(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 閫夋嫨瑕佸幓閲嶇殑瀛楁
+                        .eq(TemperingGlassInfo::getState, Const.TEMPERING_DROP)
+                        .groupBy(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 鎸� engineerId 鍜� temperingLayoutId 鍒嗙粍
+        );
+        jsonObject.append("temperingGlassInfoInList", temperingGlassInfoInList.size());
+        //閽㈠寲楗煎浘鏁版嵁
+        List<PieChartVO> pieChartVOS = temperingAgoService.queryPieChart();
+        jsonObject.append("pieChartVOS", pieChartVOS);
         ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("largenScreen");
         if (sendwServer != null) {
             for (WebSocketServer webserver : sendwServer) {

--
Gitblit v1.8.0