From 04b45b8c22594cc5535b164380738a80b0e8cbe2 Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期一, 26 五月 2025 15:27:57 +0800
Subject: [PATCH] 修改大屏录像可用率指标

---
 ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java |  257 +++++++++++++++++++++++++++++++++++----------------
 1 files changed, 176 insertions(+), 81 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java
index 3127208..e450615 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java
@@ -674,18 +674,20 @@
                 .map(CompletableFuture::join)
                 .flatMap(List::stream)
                 .collect(Collectors.toList());
-        log.error("鎵撳嵃鍏ㄩ噺鏁版嵁:{}",totalExps);
         ExcelExp excelExp = new ExcelExp("鍏ㄩ噺", totalExps, VideoDailyExp.class);
         mysheet.add(excelExp);
+
+        long face = totalExps.stream().filter(item -> item.getType().contains("1")).count();
+        long car = totalExps.stream().filter(item -> item.getType().contains("2")).count();
+        long video = totalExps.stream().filter(item -> item.getType().contains("3")).count();
+        log.error("浜鸿劯鏁�:{}",face);
+        log.error("car鏁�:{}",car);
+        log.error("video鏁�:{}",video);
         //娣诲姞鏂扮殑sheet 绂荤嚎鏁扮粺璁¤〃
         List<VideoTypeOffOnlineExp> videoTypeOffOnlineExps = new ArrayList<>();
-        //鎻掑叆excel鏃剁‘淇濇暟鎹嚭鐜板湪鏈�鍚�
-        List<VideoTypeOffOnlineExp> allVideoTypeOffOnlineExps = new ArrayList<>();
 
         //鍦ㄧ嚎鐜囩粺璁¤〃
         List<VideoOnlineRateExp> videoOnlineRateExps = new ArrayList<>();
-        //鎻掑叆excel鏃剁‘淇濇暟鎹嚭鐜板湪鏈�鍚�
-        List<VideoOnlineRateExp> allVideoOnlineRateExps = new ArrayList<>();
 
         for (Integer deptId : map.keySet()){
             List<VideoDailyExp>  list = map.get(deptId);
@@ -694,17 +696,17 @@
             //璁惧绫诲瀷 1浜鸿劯 2杞﹁締 3瑙嗛
             //浜鸿劯
             log.error("浼犲叆閮ㄩ棬闆嗗悎澶у皬:{} + 閮ㄩ棬id:{}" ,list.size(),deptId);
-            VideoTypeOffOnlineExp faceVideoTypeOffOnlineExp = this.getListOfflineCountInfo(list,"1",areaDeptEnum,false);
+            VideoTypeOffOnlineExp faceVideoTypeOffOnlineExp = this.getListOfflineCountInfo(list,"1",areaDeptEnum);
             //鍗″彛
-            VideoTypeOffOnlineExp carVideoTypeOffOnlineExp =this.getListOfflineCountInfo(list,"2",areaDeptEnum,false);
+            VideoTypeOffOnlineExp carVideoTypeOffOnlineExp =this.getListOfflineCountInfo(list,"2",areaDeptEnum);
             //瑙嗛
-            VideoTypeOffOnlineExp videoTypeOffOnlineExp = this.getListOfflineCountInfo(list,"3",areaDeptEnum,false);
+            VideoTypeOffOnlineExp videoTypeOffOnlineExp = this.getListOfflineCountInfo(list,"3",areaDeptEnum);
 
-            VideoOnlineRateExp faceVideoOnlineRateExp = this.getListOnLineCountInfo(list,"1",areaDeptEnum,false);
+            VideoOnlineRateExp faceVideoOnlineRateExp = this.getListOnLineCountInfo(list,"1",areaDeptEnum);
             //鍗″彛
-            VideoOnlineRateExp carVideoOnlineRateExp =this.getListOnLineCountInfo(list,"2",areaDeptEnum,false);
+            VideoOnlineRateExp carVideoOnlineRateExp =this.getListOnLineCountInfo(list,"2",areaDeptEnum);
             //瑙嗛
-            VideoOnlineRateExp VideoOnlineRateExp = this.getListOnLineCountInfo(list,"3",areaDeptEnum,false);
+            VideoOnlineRateExp VideoOnlineRateExp = this.getListOnLineCountInfo(list,"3",areaDeptEnum);
 
 
             //灏嗚鍖哄煙绫讳笁绉嶈澶囩被鍨嬬殑 淇℃伅 鏀惧叆 excel瀵硅薄鍐�
@@ -718,36 +720,48 @@
             videoOnlineRateExps.add(faceVideoOnlineRateExp);
             videoOnlineRateExps.add(carVideoOnlineRateExp);
             videoOnlineRateExps.add(VideoOnlineRateExp);
-
-
-            VideoTypeOffOnlineExp ALLfaceVideoTypeOffOnlineExp = this.getListOfflineCountInfo(list,"1",areaDeptEnum,true);
-            //鍗″彛
-            VideoTypeOffOnlineExp ALLcarVideoTypeOffOnlineExp =this.getListOfflineCountInfo(list,"2",areaDeptEnum,true);
-            //瑙嗛
-            VideoTypeOffOnlineExp ALLvideoTypeOffOnlineExp = this.getListOfflineCountInfo(list,"3",areaDeptEnum,true);
-
-            VideoOnlineRateExp ALLfaceVideoOnlineRateExp = this.getListOnLineCountInfo(list,"1",areaDeptEnum,true);
-            //鍗″彛
-            VideoOnlineRateExp ALLcarVideoOnlineRateExp =this.getListOnLineCountInfo(list,"2",areaDeptEnum,true);
-            //瑙嗛
-            VideoOnlineRateExp ALLVideoOnlineRateExp = this.getListOnLineCountInfo(list,"3",areaDeptEnum,true);
-
-            //娣诲姞鍚堣鏁版嵁
-            allVideoTypeOffOnlineExps.add(ALLfaceVideoTypeOffOnlineExp);
-            //鏀惧叆褰撳墠鍖哄煙鐨勮溅杈嗚澶囩浉鍏宠缁�
-            allVideoTypeOffOnlineExps.add(ALLcarVideoTypeOffOnlineExp);
-            //鏀惧叆褰撳墠鍖哄煙鐨勮棰戣澶囩浉鍏宠缁�
-            allVideoTypeOffOnlineExps.add(ALLvideoTypeOffOnlineExp);
-
-            allVideoOnlineRateExps.add(ALLfaceVideoOnlineRateExp);
-            allVideoOnlineRateExps.add(ALLcarVideoOnlineRateExp);
-            allVideoOnlineRateExps.add(ALLVideoOnlineRateExp);
-
         }
+
+        //璁$畻鑷础甯傚悎璁�
+        //鎻掑叆excel鏃剁‘淇濇暟鎹嚭鐜板湪鏈�鍚�
+        List<VideoTypeOffOnlineExp> allVideoTypeOffOnlineExps = new ArrayList<>();
+        //鎻掑叆excel鏃剁‘淇濇暟鎹嚭鐜板湪鏈�鍚�
+        List<VideoOnlineRateExp> allVideoOnlineRateExps =  new ArrayList<>();
+
+        //鎵�鏈夌绾挎暟鎹腑锛屽悇鍖鸿澶囦负浜鸿劯鐨勫璞�  鍚堣瑁呴厤瀵硅薄
+        VideoTypeOffOnlineExp allFaceVideosOffline = new VideoTypeOffOnlineExp();
+        setAllVideoTypeOffOnlineExpCount(videoTypeOffOnlineExps,allFaceVideosOffline,"浜鸿劯");
+
+        VideoTypeOffOnlineExp allCarVideosOffline = new VideoTypeOffOnlineExp();
+        setAllVideoTypeOffOnlineExpCount(videoTypeOffOnlineExps,allCarVideosOffline,"鍗″彛");
+
+        VideoTypeOffOnlineExp allVideosOffline = new VideoTypeOffOnlineExp();
+        setAllVideoTypeOffOnlineExpCount(videoTypeOffOnlineExps,allVideosOffline,"瑙嗛");
+
+        allVideoTypeOffOnlineExps.add(allFaceVideosOffline);
+        allVideoTypeOffOnlineExps.add(allCarVideosOffline);
+        allVideoTypeOffOnlineExps.add(allVideosOffline);
+
+        //鎵�鏈夊湪绾挎暟鎹� 鍚堣瑁呴厤瀵硅薄
+        VideoOnlineRateExp allFaceVideosOnline = new VideoOnlineRateExp();
+        setAllVideoTypeOnlineExpCount(face,videoOnlineRateExps,allFaceVideosOnline,"浜鸿劯");
+
+
+        VideoOnlineRateExp allCarVideosOnline = new VideoOnlineRateExp();
+        setAllVideoTypeOnlineExpCount(car,videoOnlineRateExps,allCarVideosOnline,"鍗″彛");
+
+        VideoOnlineRateExp allVideosOnline = new VideoOnlineRateExp();
+        setAllVideoTypeOnlineExpCount(video,videoOnlineRateExps,allVideosOnline,"瑙嗛");
+
+
+        allVideoOnlineRateExps.add(allFaceVideosOnline);
+        allVideoOnlineRateExps.add(allCarVideosOnline);
+        allVideoOnlineRateExps.add(allVideosOnline);
+
         videoTypeOffOnlineExps.addAll(allVideoTypeOffOnlineExps);
         videoOnlineRateExps.addAll(allVideoOnlineRateExps);
         log.error("鎵撳嵃璁$畻绂荤嚎鐨勪俊鎭�:{}" ,videoTypeOffOnlineExps );
-        log.error("鎵撳嵃璁″湪绾跨殑淇℃伅:{}" ,videoOnlineRateExps );
+        log.error("鎵撳嵃鍦ㄧ嚎鐨勪俊鎭�:{}" ,videoOnlineRateExps );
         //娣诲姞鍚堣鏁版嵁
 
         ExcelExp excelTypeOffLineExp = new ExcelExp("绂荤嚎鏁扮粺璁�", videoTypeOffOnlineExps, VideoTypeOffOnlineExp.class);
@@ -761,6 +775,103 @@
         util.exportExcelManySheet(response, mysheet);
         log.error("瀵煎嚭缁撴潫");
     }
+    //绂荤嚎璁惧鏁版嵁锛屽悎璁″璞★紝淇℃伅瑁呴厤
+    public void setAllVideoTypeOffOnlineExpCount(List<VideoTypeOffOnlineExp> videoTypeOffOnlineExps,
+                                                                  VideoTypeOffOnlineExp videoTypeOffOnlineExp,
+                                                                  String type) throws NoSuchFieldException, IllegalAccessException {
+        List<VideoTypeOffOnlineExp> filterExps = videoTypeOffOnlineExps.stream().filter(exp -> type.equals(exp.getType())).collect(Collectors.toList());
+        long allCount = 0;
+        for (VideoTypeOffOnlineExp obj :filterExps){
+            //obj 瀵硅薄浠h〃浜嗚鍖� 绛涢�変簡鐨勬寚瀹歵ype鐨勮澶囩殑瀵硅薄
+            //璁$畻鎬荤殑璁惧绂荤嚎鎬绘暟
+            long count  = Long.parseLong(obj.getOfflineCount());
+            allCount += count;
+            //璁$畻姣忔棩
+            for (int i =1 ;i <= 31; i++){
+                String fieldName = "day" + i;
+                Field dayField = obj.getClass().getDeclaredField(fieldName);
+                dayField.setAccessible(true);
+                Object value = dayField.get(obj); //鑾峰彇瀛楁鍊�
+                if (value != null) {
+                    long newFieldValue = Long.parseLong(value.toString());
+                    //鑾峰彇闇�瑕佸~鍏呯殑瀛楁
+                    Field videoTypeOffOnlineExpField = videoTypeOffOnlineExp.getClass().getDeclaredField(fieldName);
+                    videoTypeOffOnlineExpField.setAccessible(true);
+                    //鍏堣幏鍙栦竴娆�
+                    Object oldValue = videoTypeOffOnlineExpField.get(videoTypeOffOnlineExp);
+
+                    //涓簄ull 绗竴娆$洿鎺ヨ璧嬪��
+                    if (oldValue == null){
+                        videoTypeOffOnlineExpField.set(videoTypeOffOnlineExp,newFieldValue + "");
+                    }else {
+                        //瀛樺湪鏃у�� 鐩稿姞瑕嗙洊
+                        videoTypeOffOnlineExpField.set(videoTypeOffOnlineExp, (Long.parseLong(oldValue.toString()) + newFieldValue) + "");
+                    }
+                }
+
+
+
+            }
+
+        }
+        videoTypeOffOnlineExp.setOfflineCount(String.valueOf(allCount));
+        videoTypeOffOnlineExp.setArea("鑷础甯�");
+        videoTypeOffOnlineExp.setType(type + "鍚堣");
+    }
+    //鍦ㄧ嚎璁惧鏁版嵁锛屽悎璁″璞★紝淇℃伅瑁呴厤
+    public void setAllVideoTypeOnlineExpCount(
+            long allVideoCount,List<VideoOnlineRateExp> videoOnlineRateExps,
+                                              VideoOnlineRateExp videoOnlineRateExp,
+                                              String type) throws NoSuchFieldException, IllegalAccessException{
+        List<VideoOnlineRateExp> filterExps = videoOnlineRateExps.stream().filter(item -> type.equals(item.getType())).collect(Collectors.toList());
+
+        for (VideoOnlineRateExp obj :filterExps){
+            for (int i = 1;i <= 31; i++){
+                String countFileName = "count" +i;
+                Field countField = obj.getClass().getDeclaredField(countFileName);
+                countField.setAccessible(true);
+                long newFieldValue = countField.getLong(obj);
+                Field videoOnlineRateExpField = obj.getClass().getDeclaredField(countFileName);
+                videoOnlineRateExpField.setAccessible(true);
+                Object oldValue = videoOnlineRateExpField.get(videoOnlineRateExp);
+                if (oldValue == null){
+                    videoOnlineRateExpField.setLong(videoOnlineRateExp,newFieldValue);
+                }else {
+                    //瀛樺湪鏃у�� 鐩稿姞瑕嗙洊
+                    videoOnlineRateExpField.setLong(videoOnlineRateExp, Long.parseLong(oldValue.toString()) + newFieldValue);
+                }
+            }
+        }
+        //璁$畻瀹屾瘡鏃ュ湪绾胯澶囨暟
+        //寰幆涓�涓湀
+        for (int i = 1;i <= 31 ;i++){
+            //鍦ㄧ嚎鐜囪绠�
+            String countFileName = "count" +i;
+            Field countField = videoOnlineRateExp.getClass().getDeclaredField(countFileName);
+            countField.setAccessible(true);
+            long newFieldValue = countField.getLong(videoOnlineRateExp);
+            String fieldName = "day" + i;
+            //姣忔棩鍦ㄧ嚎鐜�
+            double rate = (double) newFieldValue / allVideoCount;
+            //鍙嶅皠娣诲姞鍒板璞″睘鎬т腑
+            Field field = videoOnlineRateExp.getClass().getDeclaredField(fieldName);
+            //璁剧疆姣忔棩鍦ㄧ嚎璁惧璁惧鏁�
+            field.setAccessible(true);
+            String rateStr = String.format("%.2f", rate * 100) +"%";
+            if (!"0.00%".equals(rateStr)){
+                field.set(videoOnlineRateExp, rateStr);
+            }
+
+        }
+
+
+        videoOnlineRateExp.setArea("鑷础甯�");
+        videoOnlineRateExp.setType(type + "鍚堣");
+    }
+
+
+
+
 
     /**
      * 璁$畻绂荤嚎璁惧excel瀵硅薄淇℃伅
@@ -771,8 +882,8 @@
      */
     public VideoTypeOffOnlineExp getListOfflineCountInfo(List<VideoDailyExp> videoDailyExps,
                                                          String type,
-                                                         AreaDeptEnum areaDeptEnum,
-                                                         boolean isTotal){
+                                                         AreaDeptEnum areaDeptEnum
+                                                        ){
         VideoTypeOffOnlineExp videoTypeOffOnlineExp = new VideoTypeOffOnlineExp();
 
         List<VideoDailyExp> list = videoDailyExps.stream()
@@ -781,45 +892,36 @@
         //绂荤嚎鏁伴噺
         try {
             //璁剧疆绂荤嚎鏁伴噺 浠ュ強姣忔棩绂荤嚎鏁伴噺
-            setVideoTypeOffOnlineExpCountAndDays(list,videoTypeOffOnlineExp,isTotal);
+            setVideoTypeOffOnlineExpCountAndDays(list,videoTypeOffOnlineExp);
         } catch (Exception e) {
             log.error(e.getMessage());
         }
         //璁惧绫诲瀷
-        if(isTotal){
-            if ("1".equals(type)){
-                videoTypeOffOnlineExp.setType("浜鸿劯鍚堣");
-            }else if ("2".equals(type)){
-                videoTypeOffOnlineExp.setType("鍗″彛鍚堣");
-            }else if ("3".equals(type)){
-                videoTypeOffOnlineExp.setType("瑙嗛鍚堣");
-            }
-        }else {
-            if ("1".equals(type)){
-                videoTypeOffOnlineExp.setType("浜鸿劯");
-            }else if ("2".equals(type)){
-                videoTypeOffOnlineExp.setType("鍗″彛");
-            }else if ("3".equals(type)){
-                videoTypeOffOnlineExp.setType("瑙嗛");
-            }
+        if ("1".equals(type)){
+            videoTypeOffOnlineExp.setType("浜鸿劯");
+        }else if ("2".equals(type)){
+            videoTypeOffOnlineExp.setType("鍗″彛");
         }
+        else if ("3".equals(type)){
+            videoTypeOffOnlineExp.setType("瑙嗛");
+        }
+
         //淇敼鍖哄煙
         videoTypeOffOnlineExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName());
         return videoTypeOffOnlineExp;
     }
 
-    private void setVideoTypeOffOnlineExpCountAndDays(List<VideoDailyExp> videoDailyExps,VideoTypeOffOnlineExp videoTypeOffOnlineExp,boolean isTotal)throws NoSuchFieldException, IllegalAccessException {
+    private void setVideoTypeOffOnlineExpCountAndDays(List<VideoDailyExp> videoDailyExps,VideoTypeOffOnlineExp videoTypeOffOnlineExp)throws NoSuchFieldException, IllegalAccessException {
         //寰幆涓�涓湀
         //绂荤嚎鎬绘暟
         long AllOffLineCount = 0;
-        log.error("浼犲叆闆嗗悎澶у皬:{}", videoDailyExps.size());
         for (VideoDailyExp videoDailyExp : videoDailyExps) {
             if (videoDailyExp.isAllOfflineByMonth()) {
                 AllOffLineCount++;
             }
         }
         //鏄悎璁℃暟鎹笉闇�瑕佷笅鏂规暟鎹�
-//        if (!isTotal) {
+
             for (int i = 1; i <= 31; i++) {
                 //姣忔棩绂荤嚎鏁�
                 long count = 0;
@@ -857,8 +959,8 @@
      */
     public VideoOnlineRateExp getListOnLineCountInfo(List<VideoDailyExp> videoDailyExps,
                                                          String type,
-                                                         AreaDeptEnum areaDeptEnum,
-                                                         boolean isTotal){
+                                                         AreaDeptEnum areaDeptEnum
+                                                         ){
         VideoOnlineRateExp videoOnlineRateExp = new VideoOnlineRateExp();
 
         List<VideoDailyExp> list = videoDailyExps.stream()
@@ -866,28 +968,17 @@
         log.error("绛涢�夊畬璁惧绫诲瀷 锛歿} 鍚庨泦鍚堢殑澶у皬锛歿}",type,list.size());
         //绂荤嚎鏁伴噺
         try {
-            //璁剧疆绂荤嚎鏁伴噺 浠ュ強姣忔棩绂荤嚎鏁伴噺
-            setVideoOnlineRateExpCountAndDays(list,videoOnlineRateExp,isTotal);
+            setVideoOnlineRateExpCountAndDays(list,videoOnlineRateExp);
         } catch (Exception e) {
             log.error(e.getMessage());
         }
         //璁惧绫诲瀷
-        if(isTotal) {
-            if ("1".equals(type)) {
-                videoOnlineRateExp.setType("浜鸿劯鍚堣");
-            } else if ("2".equals(type)) {
-                videoOnlineRateExp.setType("鍗″彛鍚堣");
-            } else if ("3".equals(type)) {
-                videoOnlineRateExp.setType("瑙嗛鍚堣");
-            }
-        }else {
-            if ("1".equals(type)) {
-                videoOnlineRateExp.setType("浜鸿劯");
-            } else if ("2".equals(type)) {
-                videoOnlineRateExp.setType("鍗″彛");
-            } else if ("3".equals(type)) {
-                videoOnlineRateExp.setType("瑙嗛");
-            }
+        if ("1".equals(type)) {
+             videoOnlineRateExp.setType("浜鸿劯");
+        } else if ("2".equals(type)) {
+            videoOnlineRateExp.setType("鍗″彛");
+        } else if ("3".equals(type)) {
+            videoOnlineRateExp.setType("瑙嗛");
         }
         //淇敼鍖哄煙
         videoOnlineRateExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName());
@@ -895,13 +986,13 @@
     }
 
 
-    private void setVideoOnlineRateExpCountAndDays(List<VideoDailyExp> videoDailyExps,VideoOnlineRateExp videoOnlineRateExp,boolean isTotal)throws NoSuchFieldException, IllegalAccessException {
-
+    private void setVideoOnlineRateExpCountAndDays(List<VideoDailyExp> videoDailyExps,VideoOnlineRateExp videoOnlineRateExp)throws NoSuchFieldException, IllegalAccessException {
         //寰幆涓�涓湀
         for (int i = 1;i <= 31 ;i++){
             //鍦ㄧ嚎鐜囪绠�
             long count = 0;
             String fieldName = "day" + i;
+            String countName = "count" + i;
             for(VideoDailyExp videoDailyExp: videoDailyExps){
                 // 鏋勯�犲瓧娈靛悕
                 Field field = videoDailyExp.getClass().getDeclaredField(fieldName);
@@ -917,6 +1008,10 @@
             double rate = (double) count / videoDailyExps.size();
             //鍙嶅皠娣诲姞鍒板璞″睘鎬т腑
             Field field = videoOnlineRateExp.getClass().getDeclaredField(fieldName);
+            Field countField = videoOnlineRateExp.getClass().getDeclaredField(countName);
+            countField.setAccessible(true);
+            //璁剧疆姣忔棩鍦ㄧ嚎璁惧璁惧鏁�
+            countField.setLong(videoOnlineRateExp, count);
             field.setAccessible(true);
             String rateStr = String.format("%.2f", rate * 100) +"%";
             if (!"0.00%".equals(rateStr)){

--
Gitblit v1.8.0