From 0aea8bd18daaaf91e622fdcfdd81dbb2e1b4860c Mon Sep 17 00:00:00 2001
From: swb <jpy123456>
Date: Mon, 21 Oct 2024 09:01:18 +0800
Subject: [PATCH] fix:立行立改责任主体修改提交

---
 screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java |   22 ++++++++++++++++++++--
 1 files changed, 20 insertions(+), 2 deletions(-)

diff --git a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
index 201dcdd..a129ae8 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
@@ -20,6 +20,7 @@
 import com.moral.api.service.HistoryHourlyService;
 import com.moral.api.service.SensorService;
 import com.moral.api.service.UnitConversionService;
+import com.moral.api.utils.StringUtils;
 import com.moral.api.vo.OnlineRateVo;
 import com.moral.constant.Constants;
 import com.moral.constant.RedisConstants;
@@ -55,6 +56,8 @@
 
     @Autowired
     SensorService sensorService;
+    @Autowired
+    private DeviceService deviceService;
 
     @Autowired
     UnitConversionService unitConversionService;
@@ -106,9 +109,18 @@
         );
 
         //������mac
-        List<String> macs = (List<String>) params.remove("macs");
+        List<String> macList = (List<String>) params.remove("macs");
         List<Map<String, Object>> elementLists = new ArrayList<>();
-
+        List<String> idList = macList.stream().filter(it->it.contains(",avg")).collect(Collectors.toList());
+        List<String> idListExcluding = macList.stream().filter(it->!it.contains(",avg")).collect(Collectors.toList());
+        List<String> macs = new ArrayList<>();
+        for(String s : idList){
+            String mm = s.substring(0, s.indexOf(",avg"));
+            List<String> macResultList = deviceService.getMacMonitorPointId(Integer.parseInt(mm));
+            macs.addAll(macResultList);
+        }
+        macs.addAll(idListExcluding);
+        macs = macs.stream().distinct().collect(Collectors.toList());
         for (String mac : macs) {
             //���redis���������������������������
             Device device = (Device) redisTemplate.opsForHash().get(RedisConstants.DEVICE_INFO, mac);
@@ -1243,4 +1255,10 @@
         }
         return OrfList;
     }
+    private boolean subStr(String mac){
+        if(StringUtils.isNotEmpty(mac)&&mac.contains(",avg")){
+            return true;
+        }
+        return false;
+    }
 }

--
Gitblit v1.8.0