From 12b3967ebefcfc31e8e2eeb4fea6c699f5bd04f4 Mon Sep 17 00:00:00 2001
From: liuhaonan <konodioda2333@vip.qq.com>
Date: 星期一, 25 四月 2022 17:33:43 +0800
Subject: [PATCH] bug修复

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java |   22 +++++++++++++++++++++-
 1 files changed, 21 insertions(+), 1 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
index c72e607..e317fe5 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
@@ -33,6 +33,7 @@
 import com.sandu.ximon.admin.vo.PoleBindVO;
 import com.sandu.ximon.dao.bo.*;
 import com.sandu.ximon.dao.domain.*;
+import com.sandu.ximon.dao.mapper.MonitorMapper;
 import com.sandu.ximon.dao.mapper.PoleMapper;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -57,6 +58,7 @@
     private final PoleBindingService poleBindingService;
     private final PoleGroupRelationService groupRelationService;
     private final ClientService clientService;
+    private final PoleMapper poleMapper;
 
     public boolean addPole(PoleParam param) {
         Pole pole = new Pole();
@@ -202,6 +204,16 @@
         }
         result.put("AirEquipmentOnlineCount", number);
         result.put("AirEquipmentTotalCount", airEquipments.size());
+        //澶ф皵(鍐滆��)
+        number = 0;
+        List<AirEquipmentNongGengBo> airEquipmentNongGengBos = SpringContextHolder.getBean(AirEquipmentNongGengService.class).listAirEquipmentByKeyword(null, null);
+        for (AirEquipmentNongGengBo airEquipmentNongGengBo : airEquipmentNongGengBos) {
+            if (RedisUtils.getBean().get(AtmoFunctionCode.AIR_HEARTBEAT_NONG_GENG.getCode() + airEquipmentNongGengBo.getMac()) != null) {
+                number++;
+            }
+        }
+        result.put("AirEquipmentNongGengOnlineCount", number);
+        result.put("AirEquipmentNongGengTotalCount", airEquipmentNongGengBos.size());
         //姘磋川
         number = 0;
         List<WaterQualityEquipmentBo> waterQualityEquipments
@@ -820,9 +832,12 @@
     public Pole getPoleByMac(Long poleId) {
         Pole one = getOne(Wrappers.lambdaQuery(Pole.class).eq(Pole::getId, poleId));
         ArrayList<String> macs = new ArrayList<>();
+
         macs.add(one.getDeviceCode());
         List<DeviceStatus> deviceStatuses = listStatusByDeviceCode(macs);
-        if (deviceStatuses.get(0).getStatus() == 0) {
+        if (one.getDeviceCode() == null || one.getDeviceType() == null || one.getDeviceType() == -1) {
+            one.setOnLineState("铏氭嫙鐏潌");
+        } else if (deviceStatuses.get(0).getStatus() == 0) {
             one.setOnLineState("绂荤嚎");
         } else if (deviceStatuses.get(0).getStatus() == 1) {
             one.setOnLineState("鍦ㄧ嚎");
@@ -846,4 +861,9 @@
 //        return energy;
 //    }
 
+
+    public boolean updateDeviceCode(Long poleId) {
+        return poleMapper.updateDeviceCode(poleId);
+    }
+
 }
\ No newline at end of file

--
Gitblit v1.9.3