From 2b67ed2da39eba5824cfee7950e03be2c1a256ec Mon Sep 17 00:00:00 2001
From: heheng <475597332@qq.com>
Date: 星期一, 20 十月 2025 13:17:04 +0800
Subject: [PATCH] 新增数据上传准东
---
src/main/java/com/ruoyi/doublePrevention/scheduls/SearchRectifyDateSchedule.java | 310 +++++++++++++++++++++++++-------------------------
1 files changed, 155 insertions(+), 155 deletions(-)
diff --git a/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchRectifyDateSchedule.java b/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchRectifyDateSchedule.java
index 1b25894..4ada973 100644
--- a/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchRectifyDateSchedule.java
+++ b/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchRectifyDateSchedule.java
@@ -1,155 +1,155 @@
-package com.ruoyi.doublePrevention.scheduls;
-
-
-import com.ruoyi.doublePrevention.entity.CJReport.CJdto.Data;
-import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportCheckRecordFromTask;
-import com.ruoyi.doublePrevention.entity.PreventReportConfig;
-import com.ruoyi.doublePrevention.entity.PreventRiskDangerCheckLog;
-import com.ruoyi.doublePrevention.entity.PreventRiskJobAndMeasure;
-import com.ruoyi.doublePrevention.entity.PreventTaskType;
-import com.ruoyi.doublePrevention.enums.E;
-import com.ruoyi.doublePrevention.enums.SyncEnum;
-import com.ruoyi.doublePrevention.exception.AusinessException;
-import com.ruoyi.doublePrevention.service.baseService.*;
-import com.ruoyi.project.system.dept.service.IDeptService;
-import com.ruoyi.project.system.user.domain.User;
-import com.ruoyi.project.system.user.service.IUserService;
-import com.ruoyi.project.tr.HiddenDangerCheckJob.domain.HiddenDangerCheckJob;
-import com.ruoyi.project.tr.HiddenDangerCheckJob.service.IHiddenDangerCheckJobService;
-import com.ruoyi.project.tr.hiddenDangerCheck.domain.HiddenDangerCheck;
-import com.ruoyi.project.tr.hiddenDangerCheck.service.IHiddenDangerCheckService;
-import com.ruoyi.project.tr.hiddenDangerCheckPoint.domain.HiddenDangerCheckPoint;
-import com.ruoyi.project.tr.hiddenDangerCheckPoint.service.IHiddenDangerCheckPointService;
-import com.ruoyi.project.tr.riskList.service.IRiskListService;
-import org.apache.commons.lang3.ObjectUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.text.SimpleDateFormat;
-import java.util.*;
-
-@Component
-public class SearchRectifyDateSchedule {
-
- private final Logger logger = LoggerFactory.getLogger(this.getClass());
-
- public static SimpleDateFormat startFormat = new SimpleDateFormat("yyyy-MM-dd 06:30:00");
- public static SimpleDateFormat endFormat = new SimpleDateFormat("yyyy-MM-dd 23:59:59");
-
- public static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
- @Autowired
- private PreventReportConfigService preventReportConfigService;
-
- @Autowired
- private PreventCJReportRiskAnaUnitService CJRiskAnaUnitService;
- @Autowired
- private PreventCJReportRiskEventService CJEventService;
- @Autowired
- private PreventCJReportRiskControlMeasureService CJMeasureService;
- @Autowired
- private PreventCJReportCheckTaskFromWorkService CJTaskFromWorkService;
- @Autowired
- private PreventCJReportCheckRecordFromTaskService CJTaskRecordService;
- @Autowired
- private PreventCJReportDangerInfoService CJDangerInfoService;
- @Autowired
- private PreventCJReportPointService CJPointService;
-
-
- @Autowired
- private IDeptService trDeptService; //部门服务
- @Autowired
- private IUserService trUserService; //用户服务
-
- @Autowired
- private IRiskListService trRiskAnaUnitService; //风险设备、分析单元
- @Autowired
- private PreventRiskUnitUuidService preventRiskUnitUuidService; //风险设备、分析单元附属表
-
- @Autowired
- private PreventRiskEventService preventRiskEventService;
- @Autowired
- private PreventRiskControlMeasureService preventRiskControlMeasureService;
- @Autowired
- private PreventRiskControlTemplateService preventRiskControlTemplateService;
-
- @Autowired
- private IHiddenDangerCheckJobService trHiddenDangerCheckJobService;//排查任务job
- @Autowired
- private PreventRiskJobAndMeasureService preventRiskJobAndMeasureService;//排查任务附属表
-
- @Autowired
- private IHiddenDangerCheckService trHiddenDangerCheckService;//排查任务记录
- @Autowired
- private PreventRiskDangerCheckLogService preventRiskDangerCheckLogService;//排查任务记录附属表
-
- @Autowired
- private IHiddenDangerCheckPointService trHiddenDangerCheckPointService;//隐患信息上报、整改、验收
- @Autowired
- private PreventRiskDangerInfoService preventRiskDangerInfoService;//隐患信息附属表
-
- @Autowired
- private PreventRiskCheckUnitService preventRiskCheckUnitService;//管控措施，任务清单对应关系。基础排查点附属表
- @Autowired
- private PreventRiskDangerCheckAndMeasureService riskDangerCheckAndMeasureService;//管控措施，任务清单对应关系。基础排查点附属表
-
- @Autowired
- private PreventTaskTypeService taskTypeService;//管控措施，任务清单对应关系。基础排查点附属表
-
- @Autowired
- private PreventOverhaulLogService overhaulLogService;
- @Autowired
- private PreventCJReportOverhaulLogService reportOverhaulLogService;
-
-
- @Transactional
-// @Scheduled(cron = "0/10 * * * * ?") // 30秒
- @Scheduled(cron = "0 0 0/2 * * ? ")
- public void searchReportDate(){
-
- logger.info("【双重预防】纠正前置处理...");
- int step = 1;
- String companyCode = "652310082";
-
-
- /**
- *
- * */
- //读取安全风险管控措施数据上报主配置信息
- PreventReportConfig recordReportConfig = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG__CHECK_RECORD.getCode());
- //如果安全风险管控措施主配置开启上报
- if (recordReportConfig.getReportState().equals(SyncEnum.REPORT_ON.getCode())){
-
- List<PreventRiskDangerCheckLog> tasks = preventRiskDangerCheckLogService.listSearchRectifyReportTask();
-
- if (ObjectUtils.isNotEmpty(tasks)){
- for (PreventRiskDangerCheckLog task : tasks) {
-
- PreventRiskDangerCheckLog dangerCheckLog = new PreventRiskDangerCheckLog();
- Calendar calendar = Calendar.getInstance();
- calendar.set(Calendar.YEAR, 2040);
- calendar.set(Calendar.MONTH, 5); // 注意月份从0开始，即0对应1月
- calendar.set(Calendar.DATE, 20);
- dangerCheckLog.setReportTime(calendar.getTime());
- dangerCheckLog.setId(task.getId());
-
-// int i = preventRiskDangerCheckLogService.updateSearchRectifyReportTask(dangerCheckLog);
-// if (i < 1){
-// logger.info("纠正出错");
-// }
- }
- }else {
- logger.info("无需纠正");
- }
-
- }else {
- logger.info("排查任务记录数据上报已关闭");
- }
-
- }
-}
+package com.ruoyi.doublePrevention.scheduls;
+
+
+import com.ruoyi.doublePrevention.entity.CJReport.CJdto.Data;
+import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportCheckRecordFromTask;
+import com.ruoyi.doublePrevention.entity.PreventReportConfig;
+import com.ruoyi.doublePrevention.entity.PreventRiskDangerCheckLog;
+import com.ruoyi.doublePrevention.entity.PreventRiskJobAndMeasure;
+import com.ruoyi.doublePrevention.entity.PreventTaskType;
+import com.ruoyi.doublePrevention.enums.E;
+import com.ruoyi.doublePrevention.enums.SyncEnum;
+import com.ruoyi.doublePrevention.exception.AusinessException;
+import com.ruoyi.doublePrevention.service.baseService.*;
+import com.ruoyi.project.system.dept.service.IDeptService;
+import com.ruoyi.project.system.user.domain.User;
+import com.ruoyi.project.system.user.service.IUserService;
+import com.ruoyi.project.tr.HiddenDangerCheckJob.domain.HiddenDangerCheckJob;
+import com.ruoyi.project.tr.HiddenDangerCheckJob.service.IHiddenDangerCheckJobService;
+import com.ruoyi.project.tr.hiddenDangerCheck.domain.HiddenDangerCheck;
+import com.ruoyi.project.tr.hiddenDangerCheck.service.IHiddenDangerCheckService;
+import com.ruoyi.project.tr.hiddenDangerCheckPoint.domain.HiddenDangerCheckPoint;
+import com.ruoyi.project.tr.hiddenDangerCheckPoint.service.IHiddenDangerCheckPointService;
+import com.ruoyi.project.tr.riskList.service.IRiskListService;
+import org.apache.commons.lang3.ObjectUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+@Component
+public class SearchRectifyDateSchedule {
+
+ private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+ public static SimpleDateFormat startFormat = new SimpleDateFormat("yyyy-MM-dd 06:30:00");
+ public static SimpleDateFormat endFormat = new SimpleDateFormat("yyyy-MM-dd 23:59:59");
+
+ public static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+ @Autowired
+ private PreventReportConfigService preventReportConfigService;
+
+ @Autowired
+ private PreventCJReportRiskAnaUnitService CJRiskAnaUnitService;
+ @Autowired
+ private PreventCJReportRiskEventService CJEventService;
+ @Autowired
+ private PreventCJReportRiskControlMeasureService CJMeasureService;
+ @Autowired
+ private PreventCJReportCheckTaskFromWorkService CJTaskFromWorkService;
+ @Autowired
+ private PreventCJReportCheckRecordFromTaskService CJTaskRecordService;
+ @Autowired
+ private PreventCJReportDangerInfoService CJDangerInfoService;
+ @Autowired
+ private PreventCJReportPointService CJPointService;
+
+
+ @Autowired
+ private IDeptService trDeptService; //部门服务
+ @Autowired
+ private IUserService trUserService; //用户服务
+
+ @Autowired
+ private IRiskListService trRiskAnaUnitService; //风险设备、分析单元
+ @Autowired
+ private PreventRiskUnitUuidService preventRiskUnitUuidService; //风险设备、分析单元附属表
+
+ @Autowired
+ private PreventRiskEventService preventRiskEventService;
+ @Autowired
+ private PreventRiskControlMeasureService preventRiskControlMeasureService;
+ @Autowired
+ private PreventRiskControlTemplateService preventRiskControlTemplateService;
+
+ @Autowired
+ private IHiddenDangerCheckJobService trHiddenDangerCheckJobService;//排查任务job
+ @Autowired
+ private PreventRiskJobAndMeasureService preventRiskJobAndMeasureService;//排查任务附属表
+
+ @Autowired
+ private IHiddenDangerCheckService trHiddenDangerCheckService;//排查任务记录
+ @Autowired
+ private PreventRiskDangerCheckLogService preventRiskDangerCheckLogService;//排查任务记录附属表
+
+ @Autowired
+ private IHiddenDangerCheckPointService trHiddenDangerCheckPointService;//隐患信息上报、整改、验收
+ @Autowired
+ private PreventRiskDangerInfoService preventRiskDangerInfoService;//隐患信息附属表
+
+ @Autowired
+ private PreventRiskCheckUnitService preventRiskCheckUnitService;//管控措施，任务清单对应关系。基础排查点附属表
+ @Autowired
+ private PreventRiskDangerCheckAndMeasureService riskDangerCheckAndMeasureService;//管控措施，任务清单对应关系。基础排查点附属表
+
+ @Autowired
+ private PreventTaskTypeService taskTypeService;//管控措施，任务清单对应关系。基础排查点附属表
+
+ @Autowired
+ private PreventOverhaulLogService overhaulLogService;
+ @Autowired
+ private PreventCJReportOverhaulLogService reportOverhaulLogService;
+
+
+ @Transactional
+// @Scheduled(cron = "0/10 * * * * ?") // 30秒
+ @Scheduled(cron = "0 0 0/2 * * ? ")
+ public void searchReportDate(){
+
+ logger.info("【双重预防】纠正前置处理...");
+ int step = 1;
+ String companyCode = "652310082";
+
+
+ /**
+ *
+ * */
+ //读取安全风险管控措施数据上报主配置信息
+ PreventReportConfig recordReportConfig = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG__CHECK_RECORD.getCode());
+ //如果安全风险管控措施主配置开启上报
+ if (recordReportConfig.getReportState().equals(SyncEnum.REPORT_ON.getCode())){
+
+ List<PreventRiskDangerCheckLog> tasks = preventRiskDangerCheckLogService.listSearchRectifyReportTask();
+
+ if (ObjectUtils.isNotEmpty(tasks)){
+ for (PreventRiskDangerCheckLog task : tasks) {
+
+ PreventRiskDangerCheckLog dangerCheckLog = new PreventRiskDangerCheckLog();
+ Calendar calendar = Calendar.getInstance();
+ calendar.set(Calendar.YEAR, 2040);
+ calendar.set(Calendar.MONTH, 5); // 注意月份从0开始，即0对应1月
+ calendar.set(Calendar.DATE, 20);
+ dangerCheckLog.setReportTime(calendar.getTime());
+ dangerCheckLog.setId(task.getId());
+
+ int i = preventRiskDangerCheckLogService.updateSearchRectifyReportTask(dangerCheckLog);
+ if (i < 1){
+ logger.info("纠正出错");
+ }
+ }
+ }else {
+ logger.info("无需纠正");
+ }
+
+ }else {
+ logger.info("排查任务记录数据上报已关闭");
+ }
+
+ }
+}
--
Gitblit v1.9.2