From c8ca3c42906b89c5de910ad3ff9f164e6b846a4c Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期五, 09 八月 2024 15:41:21 +0800
Subject: [PATCH] 一机一档合格率
---
ycl-server/src/main/java/com/ycl/task/VideoTask.java | 45 +++++++++++++++++++--------------------------
1 files changed, 19 insertions(+), 26 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 827d57a..fe804d8 100644
--- a/ycl-server/src/main/java/com/ycl/task/VideoTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/VideoTask.java
@@ -6,6 +6,7 @@
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.MonitorQualifyResult;
import com.ycl.platform.domain.result.UY.QueryVqdResult;
import com.ycl.platform.domain.vo.PlatformOnlineVO;
import com.ycl.platform.mapper.CheckIndexVideoMapper;
@@ -41,14 +42,11 @@
private MongoTemplate mongoTemplate;
@Autowired
private PlatformOnlineMapper platformOnlineMapper;
- @Autowired
- private CheckIndexVideoMapper videoMapper;
- @Autowired
- private SysDeptMapper deptMapper;
+
public void siteOnlineTask() {
Date yesterday = DateUtils.addDays(new Date(), -1);
- //璁＄畻鐐逛綅鍦ㄧ嚎鐜囧拰閲嶇偣鐐逛綅鍦ㄧ嚎鐜�
+ //TODO锛氳绠楃偣浣嶅湪绾跨巼鍜岄噸鐐圭偣浣嶅湪绾跨巼
Query query = new Query();
query.addCriteria(Criteria
.where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday)));
@@ -71,31 +69,26 @@
}
public void oneMonitorFileTask() {
- //璁＄畻涓�鏈轰竴妗ｆ敞鍐岀巼銆佷竴鏈轰竴妗ｅ悎鏍肩巼銆佹。妗堣�冩牳姣�
+ //璁＄畻涓�鏈轰竴妗ｆ敞鍐岀巼銆佹。妗堣�冩牳姣�
+
}
+ public void oneMonitorQualifyTask(){
+ //璁＄畻涓�鏈轰竴妗ｅ悎鏍肩巼
+ Date yesterday = DateUtils.addDays(new Date(), -1);
+ Query query = new Query();
+ query.addCriteria(Criteria
+ .where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday)));
+ List<MonitorQualifyResult> results = mongoTemplate.find(query, MonitorQualifyResult.class);
+ CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_MonitorQualify);
+ calculator.calculate(results);
+ }
public void platformOnlineTask() {
//璁＄畻骞冲彴鍦ㄧ嚎鐜�
- //鎷垮埌浠婃棩绂荤嚎鏃堕暱鏁版嵁
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) -> {
-//
-// });
-
-
+ CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_PlatformOnline);
+ calculator.calculate(list);
}
+
+
}
--
Gitblit v1.8.0