From 3b0516a2959e25576e4f3fda697a3b025d06c8c9 Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期二, 24 六月 2025 14:09:07 +0800
Subject: [PATCH] 每日录像可用指标添加日志,修改大屏为查看当前月平均

---
 ycl-server/src/main/java/com/ycl/calculate/FaceDeviceSampleCalculation.java |   44 ++++++++++++++------------------------------
 1 files changed, 14 insertions(+), 30 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/calculate/FaceDeviceSampleCalculation.java b/ycl-server/src/main/java/com/ycl/calculate/FaceDeviceSampleCalculation.java
index d598f12..62007de 100644
--- a/ycl-server/src/main/java/com/ycl/calculate/FaceDeviceSampleCalculation.java
+++ b/ycl-server/src/main/java/com/ycl/calculate/FaceDeviceSampleCalculation.java
@@ -29,47 +29,28 @@
  */
 @Component
 @Slf4j
-public class FaceDeviceSampleCalculation extends IndexCalculationServe implements CalculationStrategy<FaceDeviceSamplingResult> {
+public class FaceDeviceSampleCalculation extends IndexCalculationServe<FaceDeviceSamplingResult, FaceDeviceSampleCalculation.AreaStats> implements CalculationStrategy<FaceDeviceSamplingResult> {
     @Autowired
     private CheckIndexFaceMapper checkIndexFaceMapper;
-    @Autowired
-    private TMonitorMapper monitorMapper;
     @Autowired
     private ICheckIndexFaceService checkIndexFaceService;
 
     //鍖哄煙杞﹁締鎶芥鎸囨爣
-    private static class AreaStats {
+    protected static class AreaStats {
         int totalSites = 0;
         //鍥剧墖鍚堟牸鐨勭偣浣嶆暟
         int picQualifySites = 0;
         //鍥剧墖鍙敤鐨勭偣浣嶆暟
         int picUsabilitySites = 0;
+        //鍥剧墖鎬荤偣浣嶆暟
+        int picSites = 0;
     }
 
     @Override
     public void calculate(List<FaceDeviceSamplingResult> list) {
-        if (CollectionUtils.isEmpty(list)) {
-            log.info("鏁版嵁涓虹┖");
-            return;
-        }
-        //杩斿洖浠ュ浗鏍囩爜涓簁ey鐨勮澶噈ap
-        Map<String, TMonitorVO> monitorMap = monitorMapper.selectListByIds(list.stream().map(FaceDeviceSamplingResult::getExternalIndexCode).collect(Collectors.toList()))
-                .stream().collect(Collectors.toMap(TMonitorVO::getSerialNumber, Function.identity()));
-        //鑾峰彇鐪佸巺鍥芥爣鐮侀泦鍚�
-        List<String> provinceIds = getProvince();
-        Map<String, AreaStats> areaStatsMap = new HashMap<>();
-        for (FaceDeviceSamplingResult result : list) {
-            TMonitorVO monitor = monitorMap.get(result.getExternalIndexCode());
-            if (monitor == null) continue;
-            String deptId = monitor.getDeptId().toString();
-            updateAreaStats(areaStatsMap, deptId, result);
-
-            // 澶勭悊鐪佸巺鏁版嵁
-            if (!CollectionUtils.isEmpty(provinceIds) && provinceIds.contains(monitor.getSerialNumber())) {
-                String provinceKey = ApiConstants.Province + deptId;
-                updateAreaStats(areaStatsMap, provinceKey, result);
-            }
-        }
+        //鑾峰彇鍒嗗尯鍩熺殑鎸囨爣鏁伴噺
+        Map<String, FaceDeviceSampleCalculation.AreaStats> areaStatsMap = getAreaStatsMap(list,Boolean.FALSE);
+        if (areaStatsMap == null) return;
 
         // 鏌ヨ鏄惁index琛ㄥ凡缁忓瓨鍦ㄤ粖鏃ユ暟鎹�
         List<CheckIndexFace> checkIndexFaceList = checkIndexFaceMapper.selectToday(DateUtils.getDate());
@@ -89,7 +70,8 @@
     /**
      * 绱鎶撴媿鏁版嵁鍑嗙‘璁惧鏁板拰璁惧鎬绘暟
      */
-    private void updateAreaStats(Map<String, AreaStats> areaStatsMap, String key, FaceDeviceSamplingResult result) {
+    @Override
+    public void updateAreaStats(Map<String, AreaStats> areaStatsMap, String key, FaceDeviceSamplingResult result) {
         //杩斿洖瀵硅薄鐨勫紩鐢紝濡傛灉涓嶅瓨鍦ㄤ細鏀惧叆鏂扮殑key,value
         AreaStats stats = areaStatsMap.computeIfAbsent(key, k -> new AreaStats());
         FaceDeviceSamplingResult.BigUsefulness bigUseful = result.getBigUseful();
@@ -101,8 +83,10 @@
                 stats.picQualifySites++;
             }
         }
-        //澶у浘鍙敤鐜囧ぇ浜�90%瑙嗕负鍚堟牸
-        if (bigUseful != null) {
+        //鍙绠楁娊妫�鐨�
+        if(bigUseful.getSampleCount() !=0){
+            stats.picSites++;
+            //澶у浘鍙敤鐜囧ぇ浜�90%瑙嗕负鍚堟牸,
             if (bigUseful.getBigUsefulPercent() >= 0.9) {
                 stats.picUsabilitySites++;
             }
@@ -125,7 +109,7 @@
         checkIndexFace.setFacePictureQualification(dataQualify);
         //璋冪敤澶у浘鍙敤鎬ц绠楁柟娉�
         Map<String, Object> usabilityParam = new HashMap<>();
-        usabilityParam.put("totalSites", stats.totalSites);
+        usabilityParam.put("totalSites", stats.picSites);
         usabilityParam.put("picUsabilitySites", stats.picUsabilitySites);
         BigDecimal picUsability = picUsability(usabilityParam);
         checkIndexFace.setFacePictureAvailability(picUsability);

--
Gitblit v1.8.0