From 6c5d7fa4635b06d30840c39f96bd381b65cb56e7 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期二, 03 九月 2024 19:43:59 +0800
Subject: [PATCH] 数据中心优化

---
 ycl-server/src/main/java/com/ycl/task/VideoTask.java |   38 +++++++++++++++++++++++++++++++-------
 1 files changed, 31 insertions(+), 7 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/task/VideoTask.java b/ycl-server/src/main/java/com/ycl/task/VideoTask.java
index b8f8a53..3a277bd 100644
--- a/ycl-server/src/main/java/com/ycl/task/VideoTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/VideoTask.java
@@ -9,10 +9,7 @@
 import com.ycl.platform.domain.result.UY.*;
 import com.ycl.platform.domain.vo.PlatformOnlineVO;
 import com.ycl.platform.domain.vo.TMonitorVO;
-import com.ycl.platform.mapper.CheckIndexVideoMapper;
-import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper;
-import com.ycl.platform.mapper.PlatformOnlineMapper;
-import com.ycl.platform.mapper.TMonitorMapper;
+import com.ycl.platform.mapper.*;
 import com.ycl.platform.service.IImageResourceSecurityService;
 import com.ycl.utils.DateUtils;
 import com.ycl.utils.DictUtils;
@@ -27,6 +24,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -50,9 +48,12 @@
     private final IImageResourceSecurityService imageResourceSecurityService;
     private final CheckIndexVideoMapper checkIndexVideoMapper;
     private final ImageResourceSecurityDetailMapper imageResourceSecurityDetailMapper;
+    private final ImageResourceSecurityMapper imageResourceSecurityMapper;
+
     private static final BigDecimal NUM = new BigDecimal("0.15");
 
     public void siteOnlineTask() {
+        log.info("寮�濮嬭绠楃偣浣嶅湪绾跨巼");
         Date yesterday = DateUtils.addDays(new Date(), -1);
         //璁$畻鐐逛綅鍦ㄧ嚎鐜囧拰閲嶇偣鐐逛綅鍦ㄧ嚎鐜囧拰鎸囨尌鍥惧儚鍦ㄧ嚎鐜�
         Query query = new Query();
@@ -62,9 +63,11 @@
         List<VideoOnlineResult> results = mongoTemplate.find(query, VideoOnlineResult.class);
         CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_SiteOnline);
         calculator.calculate(results);
+        log.info("缁撴潫璁$畻鐐逛綅鍦ㄧ嚎鐜�");
     }
 
     public void videoUsabilityTask() {
+        log.info("寮�濮嬭绠楀綍鍍忓彲鐢ㄧ巼鍜岄噸鐐瑰綍鍍忓彲鐢ㄧ巼");
         Date yesterday = DateUtils.addDays(new Date(), -1);
         //璁$畻褰曞儚鍙敤鐜囧拰閲嶇偣褰曞儚鍙敤鐜�
         Query query = new Query();
@@ -74,15 +77,20 @@
         List<RecordMetaDSumResult> results = mongoTemplate.find(query, RecordMetaDSumResult.class);
         CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_Usability);
         calculator.calculate(results);
+        log.info("缁撴潫璁$畻褰曞儚鍙敤鐜囧拰閲嶇偣褰曞儚鍙敤鐜�");
     }
 
     public void oneMonitorFileTask() {
+        log.info("寮�濮嬭绠椾竴鏈轰竴妗f敞鍐岀巼銆佹。妗堣�冩牳姣�");
         //璁$畻涓�鏈轰竴妗f敞鍐岀巼銆佹。妗堣�冩牳姣�
         List<TMonitorVO> tMonitorVOS = monitorMapper.selectMonitorVOList();
         CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_MonitorRegis_ArchiveRate);
         calculator.calculate(tMonitorVOS);
+        log.info("缁撴潫璁$畻涓�鏈轰竴妗f敞鍐岀巼銆佹。妗堣�冩牳姣�");
     }
-    public void oneMonitorQualifyTask(){
+
+    public void oneMonitorQualifyTask() {
+        log.info("寮�濮嬭绠椾竴鏈轰竴妗e悎鏍肩巼");
         //璁$畻涓�鏈轰竴妗e悎鏍肩巼
         Date yesterday = DateUtils.addDays(new Date(), -1);
         Query query = new Query();
@@ -91,14 +99,20 @@
         List<MonitorQualifyResult> results = mongoTemplate.find(query, MonitorQualifyResult.class);
         CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_MonitorQualify);
         calculator.calculate(results);
+        log.info("缁撴潫璁$畻涓�鏈轰竴妗e悎鏍肩巼");
     }
+
     public void platformOnlineTask() {
+        log.info("寮�濮嬭绠楀钩鍙板湪绾跨巼");
         //璁$畻骞冲彴鍦ㄧ嚎鐜�
         List<PlatformOnlineVO> list = platformOnlineMapper.yesterdayData(DateUtils.getMouthStart(new Date()), DateUtils.getMouthEnd(new Date()));
         CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_PlatformOnline);
         calculator.calculate(list);
+        log.info("缁撴潫璁$畻骞冲彴鍦ㄧ嚎鐜�");
     }
+
     public void osdTask() {
+        log.info("寮�濮嬭绠桹sd鏍囨敞銆佹椂闂村噯纭巼");
         //璁$畻Osd鏍囨敞銆佹椂闂村噯纭巼
         Date yesterday = DateUtils.addDays(new Date(), -1);
         Query query = new Query();
@@ -107,6 +121,7 @@
         List<OsdCheckResult> results = mongoTemplate.find(query, OsdCheckResult.class);
         CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_OsdTime);
         calculator.calculate(results);
+        log.info("缁撴潫璁$畻Osd鏍囨敞銆佹椂闂村噯纭巼");
     }
 
     /**
@@ -138,14 +153,23 @@
                     count++;
                 }
             }
-            imageResourceSecurity.setWeakPassword(BigDecimal.valueOf(score));
+            imageResourceSecurity.setWeakPassword(BigDecimal.valueOf(score).divide(new BigDecimal(100), 4, RoundingMode.HALF_UP));
             // 鑾峰彇瀛楀吀鍊�-鎬绘暟
             int onlineAssetsTotal = Integer.parseInt(DictUtils.getDictValue("online_assets_total", checkIndexVideo.getDeptName()));
             imageResourceSecurity.setRiskProperty(BigDecimal.valueOf(count / onlineAssetsTotal));
             imageResourceSecurity.setCreateTime(DateUtils.getNowDate());
             imageResourceSecurities.add(imageResourceSecurity);
+            //鑾峰彇鏈�杩戜竴娆℃暟鎹墜鍔ㄦ墦鍒�
+            ImageResourceSecurity latest = imageResourceSecurityMapper.getLatest(checkIndexVideo.getDeptId(),new Date());
+            imageResourceSecurity.setBoundaryIntegrity(latest.getBoundaryIntegrity());
             // 鏇存柊鎸囨爣鏁版嵁
-            checkIndexVideo.setImageResourceSecurity(imageResourceSecurity.getPlatformOnline().add(imageResourceSecurity.getPropertyAccuracy().add(imageResourceSecurity.getWeakPassword().add(imageResourceSecurity.getRiskProperty()))).multiply(NUM));
+            checkIndexVideo.setImageResourceSecurity(
+                    imageResourceSecurity.getPlatformOnline()
+                            .add(imageResourceSecurity.getPropertyAccuracy()
+                                    .add(imageResourceSecurity.getWeakPassword()
+                                            .add(imageResourceSecurity.getRiskProperty()))).multiply(NUM)
+                            .add(imageResourceSecurity.getBoundaryIntegrity()).multiply(new BigDecimal("0.45"))
+            );
             checkIndexVideoMapper.updateById(checkIndexVideo);
         }
         imageResourceSecurityService.saveBatch(imageResourceSecurities);

--
Gitblit v1.8.0