|
@@ -28,8 +28,10 @@ import com.ruoyi.project.sems.his.service.ITApproveSpecModifyService;
|
|
|
import com.ruoyi.project.sems.service.ITSpecCheckService;
|
|
|
import com.ruoyi.project.system.domain.SysDept;
|
|
|
import com.ruoyi.project.system.domain.SysDictData;
|
|
|
+import com.ruoyi.project.system.domain.TAlarmtype;
|
|
|
import com.ruoyi.project.system.service.ISysDeptService;
|
|
|
import com.ruoyi.project.system.service.ISysDictTypeService;
|
|
|
+import com.ruoyi.project.system.service.ITAlarmtypeService;
|
|
|
import org.activiti.engine.RuntimeService;
|
|
|
import org.activiti.engine.impl.identity.Authentication;
|
|
|
import org.activiti.engine.runtime.ProcessInstance;
|
|
@@ -75,6 +77,10 @@ public class TSpecdevCcController extends BaseController {
|
|
|
private TApproveSpecModifyController approveSpecModifyController;
|
|
|
@Autowired
|
|
|
private TSpechiCcController tSpechiCcController;
|
|
|
+ //注入特种设备预警接口
|
|
|
+ @Autowired
|
|
|
+ private ITAlarmtypeService tAlarmtypeService;
|
|
|
+
|
|
|
/**
|
|
|
* 查询特种设备叉车台账列表
|
|
|
*/
|
|
@@ -143,14 +149,14 @@ public class TSpecdevCcController extends BaseController {
|
|
|
logger.info("流程实例id:" + pi.getProcessInstanceId());
|
|
|
tApproveSpecModify.setProcessId(pi.getProcessInstanceId());
|
|
|
new Thread(() -> {
|
|
|
- approveSpecModifyController.sendMail(tApproveSpecModify , tSpecdevCc.getWxjl());
|
|
|
- },"发送邮件").start();
|
|
|
+ approveSpecModifyController.sendMail(tApproveSpecModify, tSpecdevCc.getWxjl());
|
|
|
+ }, "发送邮件").start();
|
|
|
|
|
|
LoginUser loginUser = SpringUtils.getBean(TokenService.class).getLoginUser(ServletUtils.getRequest());
|
|
|
- String userName =loginUser != null? loginUser.getUsername(): "";
|
|
|
+ String userName = loginUser != null ? loginUser.getUsername() : "";
|
|
|
new Thread(() -> {
|
|
|
- tSpechiCcController.addOperLog(String.valueOf(tSpecdevCc.getId()),userName,new Date() , "新增申请" );
|
|
|
- },"特种设备操作日志").start();
|
|
|
+ tSpechiCcController.addOperLog(String.valueOf(tSpecdevCc.getId()), userName, new Date(), "新增申请");
|
|
|
+ }, "特种设备操作日志").start();
|
|
|
return AjaxResult.success();
|
|
|
}
|
|
|
|
|
@@ -176,10 +182,13 @@ public class TSpecdevCcController extends BaseController {
|
|
|
tSpecdevCcService.updateTSpecdevCc(tSpecdevCc);
|
|
|
|
|
|
LoginUser loginUser = SpringUtils.getBean(TokenService.class).getLoginUser(ServletUtils.getRequest());
|
|
|
- String userName =loginUser != null? loginUser.getUsername(): "";
|
|
|
+ String userName = loginUser != null ? loginUser.getUsername() : "";
|
|
|
new Thread(() -> {
|
|
|
- tSpechiCcController.addOperLog(String.valueOf(tSpecdevCc.getId()),userName,new Date() , "修改" );
|
|
|
- },"特种设备操作日志").start();
|
|
|
+ tSpechiCcController.addOperLog(String.valueOf(tSpecdevCc.getId()), userName, new Date(), "修改");
|
|
|
+ }, "特种设备操作日志").start();
|
|
|
+ new Thread(() -> {
|
|
|
+ this.checkWarnflag();
|
|
|
+ }, "特种设备warnflag更新").start();
|
|
|
return AjaxResult.success();
|
|
|
}
|
|
|
|
|
@@ -355,14 +364,14 @@ public class TSpecdevCcController extends BaseController {
|
|
|
logger.info("流程实例id:" + pi.getProcessInstanceId());
|
|
|
tApproveSpecModify.setProcessId(pi.getProcessInstanceId());
|
|
|
new Thread(() -> {
|
|
|
- approveSpecModifyController.sendMail(tApproveSpecModify , wxjl);
|
|
|
- },"发送邮件").start();
|
|
|
+ approveSpecModifyController.sendMail(tApproveSpecModify, wxjl);
|
|
|
+ }, "发送邮件").start();
|
|
|
|
|
|
LoginUser loginUser = SpringUtils.getBean(TokenService.class).getLoginUser(ServletUtils.getRequest());
|
|
|
- String userName =loginUser != null? loginUser.getUsername(): "";
|
|
|
+ String userName = loginUser != null ? loginUser.getUsername() : "";
|
|
|
new Thread(() -> {
|
|
|
- tSpechiCcController.addOperLog(ids.toArray(),userName,new Date() , "新增申请" );
|
|
|
- },"特种设备操作日志").start();
|
|
|
+ tSpechiCcController.addOperLog(ids.toArray(), userName, new Date(), "新增申请");
|
|
|
+ }, "特种设备操作日志").start();
|
|
|
|
|
|
logger.info("list:" + JSON.toJSONString(list));
|
|
|
logger.info("successNumber:" + String.valueOf(successNumber));
|
|
@@ -469,23 +478,30 @@ public class TSpecdevCcController extends BaseController {
|
|
|
}
|
|
|
}
|
|
|
for (TSpecdevCc t : oldList) {
|
|
|
- TSpecCheck tc = new TSpecCheck();
|
|
|
- tc.setDevType(6l);
|
|
|
- tc.setCheckUnit(t.getCheckUnit());
|
|
|
- tc.setDevId(t.getId());
|
|
|
- tc.setNextWarnDate(t.getNextWarnDate());
|
|
|
- tc.setReportNo(t.getReportNo());
|
|
|
- tc.setWarnDate(t.getWarnDate());
|
|
|
- tc.setCheckConclusion(t.getPerTestConclusion());
|
|
|
- tSpecCheckService.insertTSpecCheck(tc);
|
|
|
+ try {
|
|
|
+ TSpecCheck tc = new TSpecCheck();
|
|
|
+ tc.setDevType(6l);
|
|
|
+ tc.setCheckUnit(t.getCheckUnit());
|
|
|
+ tc.setDevId(t.getId());
|
|
|
+ tc.setNextWarnDate(t.getNextWarnDate());
|
|
|
+ tc.setReportNo(t.getReportNo());
|
|
|
+ tc.setWarnDate(t.getWarnDate());
|
|
|
+ tc.setCheckConclusion(t.getPerTestConclusion());
|
|
|
+ tSpecCheckService.insertTSpecCheck(tc);
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.info("e:" + e);
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
LoginUser loginUser = SpringUtils.getBean(TokenService.class).getLoginUser(ServletUtils.getRequest());
|
|
|
- String userName =loginUser != null? loginUser.getUsername(): "";
|
|
|
+ String userName = loginUser != null ? loginUser.getUsername() : "";
|
|
|
new Thread(() -> {
|
|
|
- tSpechiCcController.addOperLog(ids.toArray(),userName,new Date() , "批量更新" );
|
|
|
- },"特种设备操作日志").start();
|
|
|
-
|
|
|
+ tSpechiCcController.addOperLog(ids.toArray(), userName, new Date(), "批量更新");
|
|
|
+ }, "特种设备操作日志").start();
|
|
|
+ new Thread(() -> {
|
|
|
+ this.checkWarnflag();
|
|
|
+ }, "特种设备warnflag更新").start();
|
|
|
logger.info("list:" + JSON.toJSONString(list));
|
|
|
logger.info("successNumber:" + String.valueOf(successNumber));
|
|
|
logger.info("failNumber:" + String.valueOf(failNumber));
|
|
@@ -575,5 +591,65 @@ public class TSpecdevCcController extends BaseController {
|
|
|
return AjaxResult.success(filename);
|
|
|
}
|
|
|
|
|
|
+ public void checkWarnflag() {
|
|
|
+ //获取动态处理预警级别
|
|
|
+ TAlarmtype tAlarmtype = this.tAlarmtypeService.selectTAlarmtypeById(1080L);
|
|
|
+ if (tAlarmtype.getIsOpen() == 0) {
|
|
|
+ logger.info("特种设备预警标识定时任务未启用");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ Long firstlevel = tAlarmtype.getFirstlevel();//1级
|
|
|
+ Long secondlevel = tAlarmtype.getSecondlevel();//2级
|
|
|
+ Long thirdlevel = tAlarmtype.getThirdlevel();//3级
|
|
|
+ List<TSpecdevCc> list = this.tSpecdevCcService.list(new QueryWrapper<TSpecdevCc>()
|
|
|
+ .eq("del_flag", 0).eq("status", "1"));
|
|
|
+ List<TSpecdevCc> firstList = new ArrayList<>();
|
|
|
+ List<TSpecdevCc> secondList = new ArrayList<>();
|
|
|
+ List<TSpecdevCc> thirdList = new ArrayList<>();
|
|
|
+ for (TSpecdevCc tSpecdevCc : list) {
|
|
|
+ if (tSpecdevCc.getNextWarnDate() != null) {
|
|
|
+ long now = System.currentTimeMillis();
|
|
|
+ long diff = tSpecdevCc.getNextWarnDate().getTime() - now;
|
|
|
+ long nd = 1000 * 24 * 60 * 60;
|
|
|
+ long day = diff / nd;
|
|
|
+ // 半年内 预警标识为2级
|
|
|
+ if (day > 0 && day <= secondlevel) {
|
|
|
+ this.updateForCc(2L, tSpecdevCc);
|
|
|
+ //只在当天发送邮件
|
|
|
+ if (day == secondlevel) {
|
|
|
+ firstList.add(tSpecdevCc);
|
|
|
+ }
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ // 半年-一年 预警标识为1级
|
|
|
+ if (day > secondlevel && day <= thirdlevel) {
|
|
|
+ this.updateForCc(1L, tSpecdevCc);
|
|
|
+ //只在当天发送邮件
|
|
|
+ if (day == thirdlevel) {
|
|
|
+ secondList.add(tSpecdevCc);
|
|
|
+ }
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ // 超时 预警标识为3级
|
|
|
+ if (day <= firstlevel) {
|
|
|
+ this.updateForCc(3L, tSpecdevCc);
|
|
|
+ //只在当天发送邮件
|
|
|
+ if (day == firstlevel) {
|
|
|
+ thirdList.add(tSpecdevCc);
|
|
|
+ }
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (day > thirdlevel) {
|
|
|
+ this.updateForCc(0L, tSpecdevCc);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void updateForCc(Long flag, TSpecdevCc tSpecdevCc) {
|
|
|
+ tSpecdevCc.setWarnFlag(flag);
|
|
|
+ this.tSpecdevCcService.updateTSpecdevCc(tSpecdevCc);
|
|
|
+ }
|
|
|
|
|
|
}
|