From 9da24a8dfa3766cec565b092fc105f7f006de070 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期三, 21 八月 2024 11:52:25 +0800 Subject: [PATCH] 合同考核点位在线率记录 --- ycl-server/src/main/java/com/ycl/task/VideoTask.java | 68 +++++++++++++++++++++++++++------ 1 files changed, 55 insertions(+), 13 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 1fbec55..522d096 100644 --- a/ycl-server/src/main/java/com/ycl/task/VideoTask.java +++ b/ycl-server/src/main/java/com/ycl/task/VideoTask.java @@ -3,23 +3,34 @@ import com.ycl.calculate.CalculationStrategy; import com.ycl.factory.IndexCalculationFactory; +import com.ycl.platform.domain.entity.CheckIndexVideo; import com.ycl.platform.domain.param.UY.RecordMetaDSumParam; import com.ycl.platform.domain.result.HK.SnapshotDataMonitorResult; -import com.ycl.platform.domain.result.UY.QueryVqdResult; +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.PlatformOnlineMapper; +import com.ycl.platform.mapper.TMonitorMapper; import com.ycl.platform.service.PlatformOnlineService; +import com.ycl.system.mapper.SysDeptMapper; import com.ycl.utils.DateUtils; import constant.ApiConstants; import constant.CalculationStrategyConstants; +import constant.CheckConstants; +import enumeration.general.AreaDeptEnum; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.stereotype.Component; +import org.springframework.util.CollectionUtils; import java.util.Date; +import java.util.HashMap; import java.util.List; +import java.util.Map; /** * 瑙嗛璁$畻鑰冩牳鎸囨爣浠诲姟 @@ -32,41 +43,72 @@ private MongoTemplate mongoTemplate; @Autowired private PlatformOnlineMapper platformOnlineMapper; + @Autowired + private TMonitorMapper monitorMapper; public void siteOnlineTask() { Date yesterday = DateUtils.addDays(new Date(), -1); - //璁$畻鐐逛綅鍦ㄧ嚎鐜囧拰閲嶇偣鐐逛綅鍦ㄧ嚎鐜� + //TODO:鏃堕棿鍐欐浜� + Date date = DateUtils.getDay(2024,7,13); + //璁$畻鐐逛綅鍦ㄧ嚎鐜囧拰閲嶇偣鐐逛綅鍦ㄧ嚎鐜囧拰鎸囨尌鍥惧儚鍦ㄧ嚎鐜� Query query = new Query(); query.addCriteria(Criteria - .where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday))); + .where("mongoCreateTime").gte(DateUtils.getDayStart(date)).lt(DateUtils.getDayEnd(date))); - List<QueryVqdResult> results = mongoTemplate.find(query, QueryVqdResult.class); + List<VideoOnlineResult> results = mongoTemplate.find(query, VideoOnlineResult.class); CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_SiteOnline); calculator.calculate(results); } public void videoUsabilityTask() { Date yesterday = DateUtils.addDays(new Date(), -1); + //TODO:鏃堕棿鍐欐浜� + Date date = DateUtils.getDay(2024,7,13); //璁$畻褰曞儚鍙敤鐜囧拰閲嶇偣褰曞儚鍙敤鐜� Query query = new Query(); query.addCriteria(Criteria - .where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday))); + .where("mongoCreateTime").gte(DateUtils.getDayStart(date)).lt(DateUtils.getDayEnd(date))); - List<RecordMetaDSumParam> results = mongoTemplate.find(query, RecordMetaDSumParam.class); + List<RecordMetaDSumResult> results = mongoTemplate.find(query, RecordMetaDSumResult.class); CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_Usability); calculator.calculate(results); } public void oneMonitorFileTask() { - //璁$畻涓�鏈轰竴妗f敞鍐岀巼銆佷竴鏈轰竴妗e悎鏍肩巼銆佹。妗堣�冩牳姣� + //璁$畻涓�鏈轰竴妗f敞鍐岀巼銆佹。妗堣�冩牳姣� + List<TMonitorVO> tMonitorVOS = monitorMapper.selectMonitorVOList(); + CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_MonitorRegis_ArchiveRate); + calculator.calculate(tMonitorVOS); } - + public void oneMonitorQualifyTask(){ + //璁$畻涓�鏈轰竴妗e悎鏍肩巼 +// Date yesterday = DateUtils.addDays(new Date(), -1); + //TODO:鏃堕棿鍐欐浜� + Date date = DateUtils.getDay(2024,7,13); + Query query = new Query(); + query.addCriteria(Criteria + .where("mongoCreateTime").gte(DateUtils.getDayStart(date)).lt(DateUtils.getDayEnd(date))); + List<MonitorQualifyResult> results = mongoTemplate.find(query, MonitorQualifyResult.class); + CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_MonitorQualify); + calculator.calculate(results); + } public void platformOnlineTask() { //璁$畻骞冲彴鍦ㄧ嚎鐜� - //鎷垮埌浠婃棩绂荤嚎鏃堕暱鏁版嵁 - Integer time = platformOnlineMapper.sumOffTime(DateUtils.getMouthStart(new Date()), DateUtils.getMouthEnd(new Date())); - int num = (time / 60) % 30; - double score = Math.max(1 - num * 0.1,0); - + List<PlatformOnlineVO> list = platformOnlineMapper.yesterdayData(DateUtils.getMouthStart(new Date()), DateUtils.getMouthEnd(new Date())); + CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_PlatformOnline); + calculator.calculate(list); } + public void osdTask() { + //璁$畻Osd鏍囨敞銆佹椂闂村噯纭巼 + Date yesterday = DateUtils.addDays(new Date(), -1); + //TODO:鏃堕棿鍐欐浜� + Date date = DateUtils.getDay(2024,7,13); + Query query = new Query(); + query.addCriteria(Criteria + .where("mongoCreateTime").gte(DateUtils.getDayStart(date)).lt(DateUtils.getDayEnd(date))); + List<PyOsdResult> results = mongoTemplate.find(query, PyOsdResult.class); + CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_OsdTime); + calculator.calculate(results); + } + } -- Gitblit v1.8.0