package com.gk.hotwork.Scheduls.warning;
|
|
import com.gk.hotwork.Domain.*;
|
import com.gk.hotwork.Domain.Enum.TaskType;
|
import com.gk.hotwork.Domain.Vo.TaskVo;
|
import com.gk.hotwork.Domain.Vo.TaskWorkerVo;
|
import com.gk.hotwork.Scheduls.uploadUser.uploadUserTask;
|
import com.gk.hotwork.Service.TaskGasService;
|
import com.gk.hotwork.Service.TaskService;
|
import com.gk.hotwork.Service.WarningService;
|
import org.apache.log4j.LogManager;
|
import org.apache.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author : jingjy
|
* @date : 2021/9/9 10:38
|
*/
|
//@Configuration
|
//@EnableScheduling
|
//@ConditionalOnProperty(prefix = "scheduling", name = "enabled", havingValue = "true")
|
public class Warning {
|
@Autowired
|
private TaskGasService taskGasService;
|
@Autowired
|
private WarningService warningService;
|
@Autowired
|
private TaskService taskService;
|
|
@Scheduled(cron = "0/30 * * * * ?") //每隔30秒执行一次
|
public void setWarning(){
|
Date now = new Date();
|
Date startTime = new Date(now.getTime() - 2*60*1000);
|
List<TaskVo> taskVos = taskService.getDoingTask();
|
if (taskVos == null || taskVos.size() < 1){
|
return;
|
}
|
for (TaskVo taskVo : taskVos){
|
List<TaskWorkerVo>taskWorkers = taskVo.getTaskWorkers();
|
for (TaskWorkerVo taskWorkerVo : taskWorkers){
|
//检查设备是否齐全
|
boolean result = hasNecessaryEquipment(taskWorkerVo);
|
//判断当前动火人是否有设备，没有则不进行下面判断
|
if (!result){
|
continue;
|
}
|
//报警
|
List<TaskGasInfo>taskGasInfos = taskGasService.getWarnList(taskVo.getCode(),taskWorkerVo.getWorker(),startTime,now);
|
dealWarn(taskGasInfos,taskWorkerVo,"报警",now);
|
|
//预警
|
List<TaskGasInfo>taskGasInfoList = taskGasService.getEarlyWarnList(taskVo.getCode(),taskWorkerVo.getWorker(),startTime,now);
|
dealWarn(taskGasInfoList,taskWorkerVo,"预警",now);
|
|
//故障
|
boolean isEquipmentError = taskGasService.isEquipmentError(taskVo.getCode(),taskWorkerVo.getWorker(),startTime,now);
|
if (isEquipmentError){
|
WarningInfo warningInfo = new WarningInfo();
|
String content = "在任务 "+taskWorkerVo.getTaskcode()+" 中，动火人："+taskWorkerVo.getWorker()+"气体探测器故障";
|
warningInfo.setCreatedat(now);
|
warningInfo.setTaskcode(taskWorkerVo.getTaskcode());
|
warningInfo.setTasktype(TaskType.getTaskType(taskWorkerVo.getTasktype()));
|
warningInfo.setContent(content);
|
warningInfo.setType(WarningInfo.FAULT);
|
warningInfo.setWorker(taskWorkerVo.getWorker());
|
warningService.save(warningInfo);
|
}else {
|
String type = "故障";
|
List<WarningInfo>warningInfos = warningService.getBeforeWarn(taskWorkerVo.getTaskcode(),taskWorkerVo.getWorker(),type,now);
|
if (warningInfos != null && warningInfos.size() > 0){
|
for (WarningInfo warningInfo : warningInfos){
|
warningInfo.setIsdeal((byte)1);
|
}
|
warningService.updateBatchById(warningInfos);
|
}
|
}
|
}
|
|
}
|
|
}
|
|
private void dealWarn(List<TaskGasInfo> taskGasInfos, TaskWorkerVo taskWorkerVo, String type, Date now) {
|
if (taskGasInfos != null && taskGasInfos.size() > 0){
|
for (TaskGasInfo taskGasInfo : taskGasInfos){
|
String content = "在任务 "+taskWorkerVo.getTaskcode()+" 中，动火人："+taskWorkerVo.getWorker()+"气体探测器数据异常，"
|
+taskGasInfo.getGastype()+"："+taskGasInfo.getGasvalue()+taskGasInfo.getGasunit();
|
WarningInfo warningInfo = new WarningInfo();
|
warningInfo.setCreatedat(taskGasInfo.getUpdatetime());
|
warningInfo.setTaskcode(taskGasInfo.getTaskcode());
|
warningInfo.setWorker(taskWorkerVo.getWorker());
|
warningInfo.setTasktype(TaskType.getTaskType(taskWorkerVo.getTasktype()));
|
if (taskGasInfo.getIswarn() == 1){
|
warningInfo.setContent(content);
|
warningInfo.setType(WarningInfo.WARNING);
|
WarningInfo warningInfoExist = warningService.getByContent(taskWorkerVo.getTaskcode(),taskWorkerVo.getWorker(),content);
|
if (warningInfoExist == null){
|
warningService.save(warningInfo);
|
}
|
}
|
if (taskGasInfo.getIsyujing() == 1){
|
warningInfo.setContent(content);
|
warningInfo.setType(WarningInfo.EARLY_WARNING);
|
WarningInfo warningInfoExist = warningService.getByContent(taskWorkerVo.getTaskcode(),taskWorkerVo.getWorker(),content);
|
if (warningInfoExist == null){
|
warningService.save(warningInfo);
|
}
|
}
|
}
|
}else {
|
List<WarningInfo>warningInfos = warningService.getBeforeWarn(taskWorkerVo.getTaskcode(),taskWorkerVo.getWorker(),type,now);
|
if (warningInfos != null && warningInfos.size() > 0){
|
for (WarningInfo warningInfo : warningInfos){
|
warningInfo.setIsdeal((byte)1);
|
}
|
warningService.updateBatchById(warningInfos);
|
}
|
}
|
}
|
|
private boolean hasNecessaryEquipment(TaskWorkerVo taskWorkerVo) {
|
List<EquipmentInfo> equipmentInfos = taskWorkerVo.getEquipments();
|
if (equipmentInfos == null || equipmentInfos.size() < 1){
|
return false;
|
}
|
boolean hasGasDetector = false;
|
boolean hasHelmet = false;
|
String content;
|
for (EquipmentInfo equipmentInfo : equipmentInfos){
|
if (equipmentInfo.getName().equals("气体探测器")){
|
hasGasDetector = true;
|
}
|
if (equipmentInfo.getName().equals("头盔")){
|
hasHelmet = true;
|
}
|
}
|
|
WarningInfo warningInfo = new WarningInfo();
|
warningInfo.setCreatedat(new Date());
|
warningInfo.setTaskcode(taskWorkerVo.getTaskcode());
|
warningInfo.setTasktype(TaskType.getTaskType(taskWorkerVo.getTasktype()));
|
warningInfo.setType(WarningInfo.WARNING);
|
warningInfo.setWorker(taskWorkerVo.getWorker());
|
if (!hasGasDetector){
|
content = "在任务 "+taskWorkerVo.getTaskcode()+" 中，动火人："+taskWorkerVo.getWorker()+"缺少气体探测器";
|
warningInfo.setContent(content);
|
WarningInfo warningInfoExist = warningService.getByContent(taskWorkerVo.getTaskcode(), taskWorkerVo.getWorker(), content);
|
if (warningInfoExist == null){
|
warningService.save(warningInfo);
|
}
|
}
|
if (!hasHelmet){
|
content = "在任务 "+taskWorkerVo.getTaskcode()+" 中，动火人："+taskWorkerVo.getWorker()+"缺少头盔";
|
warningInfo.setContent(content);
|
WarningInfo warningInfoExist = warningService.getByContent(taskWorkerVo.getTaskcode(),taskWorkerVo.getWorker(),content);
|
if (warningInfoExist == null){
|
warningService.save(warningInfo);
|
}
|
}
|
|
return true;
|
}
|
|
|
|
}
|
