From c4f5c1a1b5ef7d83481d54658f8f6449cd0d6bd5 Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期六, 01 三月 2025 15:59:03 +0800
Subject: [PATCH] 通用的设备数量和状态统计方法调整

---
 src/main/java/com/whyc/service/Fbs9100StateService.java |   16 +++++++++++++---
 1 files changed, 13 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/whyc/service/Fbs9100StateService.java b/src/main/java/com/whyc/service/Fbs9100StateService.java
index 13249e7..70d323d 100644
--- a/src/main/java/com/whyc/service/Fbs9100StateService.java
+++ b/src/main/java/com/whyc/service/Fbs9100StateService.java
@@ -224,6 +224,11 @@
      * 杩欎釜鏄寜鐓ц澶噄p鏉ョ粺璁$殑.
      * 閫氳鏁呴殰>鏍稿鏀剧數>鍏呯數>鍐呴樆>娴厖,
      * 濡傛灉涓�鎷栦簩鐨勮澶�,鏈変袱涓笉鍚岀姸鎬�,瀹炵幇鐘舵�佷紭鍏堢骇瑕嗙洊
+     *
+     * 璁惧鐨勬暟閲忕粺璁″拰璁惧鐘舵�佺殑缁熻,閫昏緫鏄笉鍚岀殑,鏁版嵁搴撶瓫閫夌殑鏃跺�欐潯浠堕�昏緫蹇呭畾鏄笉鍚岀殑: TODO
+     *  閫氬父鎯呭喌涓�,璁惧鏁伴噺缁熻,瑕佹帓闄ゆ帀涓�涓澶囦袱涓猧d鐨勪竴鎷栦簩鎯呭喌;
+     *  鑰岃澶囩姸鎬佺粺璁�,鍙渶瑕佸尯鍒嗕竴涓澶囩殑瀛楁,涓�涓澶囨湁澶氭潯璁板綍涔熸槸姝e父鍚堢悊鐨�,閫氳繃鐘舵�佷紭鍏堢骇瑕嗙洊鏉ュ畾涔夋暣涓澶囩殑鐘舵��
+     *
      * @param userId
      * @param type 1-澶師鎺掗櫎钃勭數姹犺澶囦竴鎷栦簩鐨勭浜岀粍鐘舵�佺粺璁�
      * @param type 2-缁熻鎵�鏈夎澶噄p鐨勭姸鎬�
@@ -241,13 +246,17 @@
             resultMap.put("閫氳鏁呴殰鏁伴噺", 0);
 
             List<Fbs9100State> fbs9100StateList = mapper.getListWithoutZJDYBTSE2(userId,type);
-            //Map<String, List<Fbs9100State>> deviceMap = fbs9100StateList.stream().collect(Collectors.groupingBy(Fbs9100State::getDevIp));
-            Map<String, List<Fbs9100State>> deviceMap = fbs9100StateList.stream().collect(Collectors.groupingBy(state ->
-                    String.format("%s_%s",state.getDevIp(), state.getDevId())));
+            //涓婇潰鐨勫垎缁勫瓧娈� 鍙鑳藉尯鍒� 涓嶅悓鐨勮澶囧氨琛屼簡. 鍥犱负濡傛灉鏄竴鎷栦簩鐨勬儏鍐�,涔熷彲閫氳繃鍚庨潰鐨勭姸鎬佷紭鍏堢骇鏉ヨ鐩�,璁惧涓嶄細閲嶅
+            //澶緵鍙互閫氳繃ip鏉ョ‘瀹氭槸鍝彴璁惧
+            Map<String, List<Fbs9100State>> deviceMap = fbs9100StateList.stream().collect(Collectors.groupingBy(Fbs9100State::getDevIp));
+            //Map<String, List<Fbs9100State>> deviceMap = fbs9100StateList.stream().collect(Collectors.groupingBy(state ->
+            //        String.format("%s_%s",state.getDevIp(), state.getDevId())));
             Set<String> deviceSet = deviceMap.keySet();
             Calendar instance = Calendar.getInstance();
             instance.add(Calendar.MINUTE, -1);
             Date time = instance.getTime();
+            //杩欎釜閬嶅巻閲岄潰,鏄寜鐓roupingBy(瀛楁)鏉ヨ繘琛屽垎缁勭殑,鍙互瀛樺湪涓�涓澶囧涓褰�,鍗冲嚭鐜颁竴鎷栦簩鐨勬儏鍐�. 杩欎釜鏃跺�欐寜鐓т紭鍏堢骇杩涜瑕嗙洊鏉ュ畾涔夋暣涓澶囩殑鐘舵��
+            //涓婇潰鐨勫垎缁勫瓧娈� 鍙鑳藉尯鍒� 涓嶅悓鐨勮澶囧氨琛屼簡. 鍥犱负濡傛灉鏄竴鎷栦簩鐨勬儏鍐�,涔熷彲閫氳繃鐘舵�佷紭鍏堢骇鏉ヨ鐩�
             for (String deviceIp : deviceSet) {
                 List<Fbs9100State> fbs9100States = deviceMap.get(deviceIp);
                 List<Integer> workStateList = fbs9100States.stream().map(Fbs9100State::getDevWorkstate).collect(Collectors.toList());
@@ -326,6 +335,7 @@
             List<Fbs9100State> fbs9100StateList = mapper.getListWithoutZJDYBTSE2JY(type);
 
             //Map<String, List<Fbs9100State>> deviceMap = fbs9100StateList.stream().collect(Collectors.groupingBy(Fbs9100State::getDevIp));
+            //JY鐨勮澶�,ip閮戒竴鏍�,鎵�浠ュ尯鍒嗕笉鍚岀殑璁惧,闇�瑕侀�氳繃ip+id
             Map<String, List<Fbs9100State>> deviceMap = fbs9100StateList.stream().collect(Collectors.groupingBy(state ->String.format("%s_%s",state.getDevIp(), state.getDevId())));
             Set<String> deviceSet = deviceMap.keySet();
             Calendar instance = Calendar.getInstance();

--
Gitblit v1.9.1