From 6451d61e4438c93d78b5fb187afd7bc538f2af44 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期三, 08 一月 2025 17:42:40 +0800 Subject: [PATCH] OSD导出 --- ycl-server/src/main/java/com/ycl/task/VideoTask.java | 17 ++++++++++++----- 1 files changed, 12 insertions(+), 5 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 3a277bd..dc3b8b8 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,8 @@ import com.ycl.platform.domain.entity.CheckIndexVideo; import com.ycl.platform.domain.entity.ImageResourceSecurity; import com.ycl.platform.domain.entity.ImageResourceSecurityDetail; +import com.ycl.platform.domain.form.VideoExportForm; +import com.ycl.platform.domain.result.SYS.TMonitorResult; import com.ycl.platform.domain.result.UY.*; import com.ycl.platform.domain.vo.PlatformOnlineVO; import com.ycl.platform.domain.vo.TMonitorVO; @@ -13,7 +15,9 @@ import com.ycl.platform.service.IImageResourceSecurityService; import com.ycl.utils.DateUtils; import com.ycl.utils.DictUtils; +import constant.ApiConstants; import constant.CalculationStrategyConstants; +import constant.CheckConstants; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -59,7 +63,6 @@ Query query = new Query(); query.addCriteria(Criteria .where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday))); - List<VideoOnlineResult> results = mongoTemplate.find(query, VideoOnlineResult.class); CalculationStrategy calculator = IndexCalculationFactory.getCalculator(CalculationStrategyConstants.Video_SiteOnline); calculator.calculate(results); @@ -83,9 +86,13 @@ public void oneMonitorFileTask() { log.info("寮�濮嬭绠椾竴鏈轰竴妗f敞鍐岀巼銆佹。妗堣�冩牳姣�"); //璁$畻涓�鏈轰竴妗f敞鍐岀巼銆佹。妗堣�冩牳姣� - List<TMonitorVO> tMonitorVOS = monitorMapper.selectMonitorVOList(); + 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_MonitorRegis_ArchiveRate); - calculator.calculate(tMonitorVOS); + calculator.calculate(results); log.info("缁撴潫璁$畻涓�鏈轰竴妗f敞鍐岀巼銆佹。妗堣�冩牳姣�"); } @@ -127,7 +134,7 @@ /** * 瑙嗛鍥惧儚璧勬簮瀹夊叏锛岄渶瑕佹帓鍦ㄥ钩鍙板湪绾跨巼鍚庨潰銆� */ - @Transactional + @Transactional(rollbackFor = Exception.class) public void videoSecurity() { ArrayList<ImageResourceSecurity> imageResourceSecurities = new ArrayList<>(); List<CheckIndexVideo> list = checkIndexVideoMapper.selectAndDeptName(); @@ -161,7 +168,7 @@ imageResourceSecurities.add(imageResourceSecurity); //鑾峰彇鏈�杩戜竴娆℃暟鎹墜鍔ㄦ墦鍒� ImageResourceSecurity latest = imageResourceSecurityMapper.getLatest(checkIndexVideo.getDeptId(),new Date()); - imageResourceSecurity.setBoundaryIntegrity(latest.getBoundaryIntegrity()); + imageResourceSecurity.setBoundaryIntegrity(latest ==null?BigDecimal.ONE:latest.getBoundaryIntegrity()); // 鏇存柊鎸囨爣鏁版嵁 checkIndexVideo.setImageResourceSecurity( imageResourceSecurity.getPlatformOnline() -- Gitblit v1.8.0