| | |
| | | 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("排查任务记录数据上报已关闭"); |
| | | } |
| | | |
| | | } |
| | | } |