From 7e7195766eb018b4ba00b2d0663f6dcb11adefc8 Mon Sep 17 00:00:00 2001
From: 16639036659 <577530412@qq.com>
Date: 星期二, 27 九月 2022 09:01:38 +0800
Subject: [PATCH] 临时提交-目前改到隐患上报部分
---
src/main/java/com/ruoyi/project/tr/HiddenDangerCheckJob/util/AbstractQuartzJob.java | 52 ++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 44 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/ruoyi/project/tr/HiddenDangerCheckJob/util/AbstractQuartzJob.java b/src/main/java/com/ruoyi/project/tr/HiddenDangerCheckJob/util/AbstractQuartzJob.java
index 52de356..29c0527 100644
--- a/src/main/java/com/ruoyi/project/tr/HiddenDangerCheckJob/util/AbstractQuartzJob.java
+++ b/src/main/java/com/ruoyi/project/tr/HiddenDangerCheckJob/util/AbstractQuartzJob.java
@@ -10,12 +10,15 @@
import com.ruoyi.common.utils.bean.BeanUtils;
import com.ruoyi.common.utils.security.ShiroUtils;
import com.ruoyi.common.utils.spring.SpringUtils;
+import com.ruoyi.doublePrevention.entity.PreventRiskJobAndMeasure;
+import com.ruoyi.doublePrevention.service.RiskService;
import com.ruoyi.framework.web.service.JpushService;
import com.ruoyi.project.enumerate.TrRiskTypeEnum;
import com.ruoyi.project.monitor.job.domain.JobLog;
import com.ruoyi.project.monitor.job.service.IJobLogService;
import com.ruoyi.project.tr.HiddenDangerCheckJob.domain.HiddenDangerCheckJob;
import com.ruoyi.project.tr.baseCheckPoint.domain.BaseCheckPoint;
+import com.ruoyi.project.tr.baseCheckPoint.mapper.BaseCheckPointMapper;
import com.ruoyi.project.tr.baseCheckPoint.service.IBaseCheckPointService;
import com.ruoyi.project.tr.hiddenDangerCheck.domain.HiddenDangerCheck;
import com.ruoyi.project.tr.hiddenDangerCheck.service.IHiddenDangerCheckService;
@@ -25,11 +28,14 @@
import com.ruoyi.project.tr.riskCheckPoint.service.IRiskCheckPointService;
import com.ruoyi.project.tr.riskEvaluationPlan.domain.RiskEvaluationPlan;
import com.ruoyi.project.tr.riskEvaluationPlan.service.IRiskEvaluationPlanService;
+import com.ruoyi.project.tr.riskList.domain.RiskList;
+import com.ruoyi.project.tr.riskList.service.IRiskListService;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.context.support.SpringBeanAutowiringSupport;
import java.util.Date;
@@ -48,11 +54,17 @@
JpushService jpushService;
+ @Autowired
+ private RiskService riskService;
+ @Autowired
+ private IRiskListService iRiskListService;
+
/**
* 线程本地变量
*/
private static ThreadLocal<Date> threadLocal = new ThreadLocal<>();
+
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
@@ -62,9 +74,8 @@
before(context, job);
if (job != null) {
doExecute(context, job);
-
}
- createData(context, job);//生成数据
+ createData(context, job);//生成数据 // todo-2022 调用方法 定时隐患排查任务生成
after(context, job, null);
} catch (Exception e) {
log.error("任务执行异常 - ：", e);
@@ -114,8 +125,11 @@
-
+ /**
+ * todo-2022 定时隐患排查任务生成
+ * */
//生成定时隐患排查数据
+ @Transactional
protected void createData(JobExecutionContext context, HiddenDangerCheckJob job) {
Date startTime = threadLocal.get();
@@ -148,20 +162,35 @@
hdc.setCheckType(job.getCheckType());//设置排查方式
if ("1".equals(job.getCheckType())) {
hdc.setRiskId(job.getRiskId() != null ? Long.valueOf(job.getRiskId()) : -1);//风险单元ID
- hdc.setRiskName(job.getRiskName());//风险单元名称
+
+ // todo-2022 ,基础排除清单名称-》改用基础清单表中信息
+ RiskList infoByRiskId = iRiskListService.getInfoByRiskId(job.getRiskId());
+ hdc.setRiskName(infoByRiskId.getRiskListName());//风险单元名称
+
hdc.setDangerPlaceId(job.getRiskPlaceId());//风险单元地点ID
hdc.setDangerPlaceName(job.getRiskPlaceName());//风险单元地点名称
hdc.setDangerDeptId(job.getRiskDeptId());//隐患责任部门ID
hdc.setDangerDeptName(job.getRiskDeptName());//隐患责任部门名称
hdc.setRiskType(job.getRiskType());//风险单元类型
+// //1、校验是否有管控措施
+// PreventRiskJobAndMeasure jobAndMeasure = riskService.getJobAndMeasure(job.getJobId());
+// if (jobAndMeasure == null ){
+// throw new RuntimeException("空任务，不调度");
+// }
+
// HiddenDangerCheck（隐患排查）写入数据库当中
SpringUtils.getBean(IHiddenDangerCheckService.class).insertHiddenDangerCheck(hdc);
-
-
//HiddenDangerCheckPoint（隐患排查检查点）写入数据库当中
hdc.setCompanyId(job.getCompanyId());
insertHiddenDangerCheckPoint(hdc);
+
+ // todo-2022 插入 任务附属表 写到此处
+ hdc.getCheckId();
+ int result = riskService.insertDangerCheckLog(hdc.getCheckId(), hdc);
+ if (result < 1){
+ throw new RuntimeException("定时任务生产失败");
+ }
} else if ("2".equals(job.getCheckType())) {
String[] riskIdArray = job.getRiskId().split(",");
@@ -198,8 +227,11 @@
}
}
-
+ /**
+ * todo-2022 生成核查任务时，添加任务的核查点信息
+ * */
//生成检查点信息
+ @Transactional
public void insertHiddenDangerCheckPoint(HiddenDangerCheck job) {
if(!StringUtils.isEmpty(job.getRiskType())) {
//风险单元类型为基础清单
@@ -222,6 +254,11 @@
// hdcp.setDangerSources(TrHiddenDangerCheckConstants.DANGER_SOURCES_SCHEDULE_PRODUCE);//隐患来源(定时器任务生成)
// 写入数据库当中
SpringUtils.getBean(IHiddenDangerCheckPointService.class).insertHiddenDangerCheckPoint(hdcp);
+
+ hdcp.getId();
+
+ // todo-2022 现场核查清单对应的核查点信息
+ riskService.insertCheckAndMeasure(hdcp.getId(), hdcp);
}
});
@@ -232,7 +269,6 @@
RiskCheckPoint rcpQuery = new RiskCheckPoint();
rcpQuery.setPlanId(plan.getPlanId());
List<RiskCheckPoint> riskCheckPointList = SpringUtils.getBean(IRiskCheckPointService.class).selectRiskCheckPointList(rcpQuery);
-
riskCheckPointList.forEach(rcp -> {
if (rcp != null) {
--
Gitblit v1.9.2