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