From b0e63cbf098a4ee0fde734236bc9358f7fa3ed0e Mon Sep 17 00:00:00 2001 From: xiangpei <xiangpei@timesnew.cn> Date: 星期五, 09 八月 2024 09:35:33 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ycl-server/src/main/java/com/ycl/task/VideoTask.java | 48 +++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 41 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 81c523c..827d57a 100644 --- a/ycl-server/src/main/java/com/ycl/task/VideoTask.java +++ b/ycl-server/src/main/java/com/ycl/task/VideoTask.java @@ -3,28 +3,37 @@ 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.vo.PlatformOnlineVO; +import com.ycl.platform.mapper.CheckIndexVideoMapper; import com.ycl.platform.mapper.PlatformOnlineMapper; 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; /** * 瑙嗛璁$畻鑰冩牳鎸囨爣浠诲姟 * 鍑屾櫒鎵ц璁$畻鏄ㄥぉ鏁版嵁 - * */ + */ @Slf4j @Component("videoTask") public class VideoTask { @@ -32,8 +41,12 @@ private MongoTemplate mongoTemplate; @Autowired private PlatformOnlineMapper platformOnlineMapper; + @Autowired + private CheckIndexVideoMapper videoMapper; + @Autowired + private SysDeptMapper deptMapper; - public void siteOnlineTask(){ + public void siteOnlineTask() { Date yesterday = DateUtils.addDays(new Date(), -1); //璁$畻鐐逛綅鍦ㄧ嚎鐜囧拰閲嶇偣鐐逛綅鍦ㄧ嚎鐜� Query query = new Query(); @@ -44,7 +57,8 @@ CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_SiteOnline); calculator.calculate(results); } - public void videoUsabilityTask(){ + + public void videoUsabilityTask() { Date yesterday = DateUtils.addDays(new Date(), -1); //璁$畻褰曞儚鍙敤鐜囧拰閲嶇偣褰曞儚鍙敤鐜� Query query = new Query(); @@ -55,13 +69,33 @@ CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_Usability); calculator.calculate(results); } - public void oneMonitorFileTask(){ + + public void oneMonitorFileTask() { //璁$畻涓�鏈轰竴妗f敞鍐岀巼銆佷竴鏈轰竴妗e悎鏍肩巼銆佹。妗堣�冩牳姣� } - public void platformOnlineTask(){ + + public void platformOnlineTask() { //璁$畻骞冲彴鍦ㄧ嚎鐜� //鎷垮埌浠婃棩绂荤嚎鏃堕暱鏁版嵁 - Integer time = platformOnlineMapper.sumOffTime(DateUtils.getMouthStart(new Date()),DateUtils.getMouthEnd(new Date())); - + List<PlatformOnlineVO> list = platformOnlineMapper.sumYesterday(DateUtils.getMouthStart(new Date()), DateUtils.getMouthEnd(new Date())); + +// int num = (time / 60) % 30; +// double score = Math.max(1 - num * 0.1, 0); +// List<CheckIndexVideo> checkIndexVideos = videoMapper.selectToday(DateUtils.getDate()); +// List<Long> deptIds = deptMapper.selectByParentId(207L); +// Map<String, CheckIndexVideo> map = new HashMap<>(); +// for (Long deptId : deptIds) { +// CheckIndexVideo video = new CheckIndexVideo(); +// video.setExamineTag(CheckConstants.Examine_Tag_County); +// map.put(deptId + "", video); +// CheckIndexVideo provinceVideo = new CheckIndexVideo(); +// provinceVideo.setExamineTag(CheckConstants.Examine_Tag_Province); +// map.put("Province_" + deptId, new CheckIndexVideo()); +// } +// map.forEach((deptId, video) -> { +// +// }); + + } } -- Gitblit v1.8.0