From a3ff160ff0e25bf0802aa5f14d651776b6652cdc Mon Sep 17 00:00:00 2001
From: baoshiwei <baoshiwei@shlanbao.cn>
Date: 星期一, 04 八月 2025 16:03:17 +0800
Subject: [PATCH] feat(dry): 更新干燥设备接口和实时数据处理

---
 jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java |   19 ++++++++++++++++---
 1 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
index abf5f3d..56d34b9 100755
--- a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
@@ -216,8 +216,12 @@
             orderVo.setOrderStatus(realTimeDataVo.getWorkorder_status());
             orderVo.setEqp_status(realTimeDataVo.getEqp_status());
 //        orderVo.setEqp_state(realTimeDataVo.getEqp_state());
-            orderVo.setWarning(realTimeDataVo.getEqp_warning());
-            orderVo.setFault(realTimeDataVo.getEqp_fault());
+            if(realTimeDataParentVo.getFault()!=null && StringUtils.isNotEmpty(realTimeDataParentVo.getFault().getWarning())){
+                orderVo.setWarning(realTimeDataParentVo.getFault().getWarning());
+            }
+            if(realTimeDataParentVo.getFault()!=null && StringUtils.isNotEmpty(realTimeDataParentVo.getFault().getError())){
+                orderVo.setFault(realTimeDataParentVo.getFault().getError());
+            }
             orderVo.setLevel(realTimeDataVo.getLevel());
             DryOrderTrendVo trendVo = new DryOrderTrendVo(realTimeDataVo);
             // 2.2 淇濆瓨宸ュ崟鍚按鐜囧彉鍖� 鎴� 閲嶉噺鍙樺寲
@@ -225,6 +229,15 @@
             saveOrderTrendVo(trendVo, orderVo);
             orderVo.setTrendVo(trendVo);
             orderVo.getBellowsTemp().put(realTimeDataVo.getTime3(), realTimeDataVo.getTemp2());
+
+            if (realTimeDataParentVo.getFault() != null) {
+                if (realTimeDataParentVo.getFault().getError() != null) {
+                    orderVo.setFault(realTimeDataParentVo.getFault().getError());
+                }
+                if (realTimeDataParentVo.getFault().getWarning() != null) {
+                    orderVo.setWarning(realTimeDataParentVo.getFault().getWarning());
+                }
+            }
 
             // 2.3 鏇存柊鍒皉edis缂撳瓨
             redisUtil.hset(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(),
@@ -548,7 +561,7 @@
                     // 鑾峰彇宸ュ崟
                     DryOrderVo order = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + item.getCode());
                     list.add(item.getName().substring(0, item.getName().indexOf('#') + 1));
-                    if (order != null) {
+                    if (order != null &&  order.getDetailList()!=null && !order.getDetailList().isEmpty()) {
                         // 璁$畻骞茬嚗鏁堢巼锛岀敤浜庡姣�
                         DryOrderTrendVo dryOrderTrendVo = order.getDetailList().get(order.getDetailList().size() - 1);
                         double v = order.getOriginWeight() - dryOrderTrendVo.getWeight();

--
Gitblit v1.9.3