package com.whyc.schedule;
|
|
import com.whyc.constant.AlarmConstant;
|
import com.whyc.constant.SuperConstant;
|
import com.whyc.constant.WorkflowEnum;
|
import com.whyc.constant.YamlProperties;
|
import com.whyc.pojo.WorkflowAlarm;
|
import com.whyc.pojo.WorkflowMain;
|
import com.whyc.service.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.EnableAsync;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.scheduling.annotation.Schedules;
|
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import sun.awt.image.ImageWatched;
|
|
import javax.jws.Oneway;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Properties;
|
|
/**
|
* 定时任务统一这里开启
|
*/
|
|
@Component
|
@EnableScheduling //开启定时任务
|
@EnableAsync //开启多线程
|
public class CustomTask {
|
|
@Autowired
|
private AlarmDataService service;
|
|
@Autowired
|
private BattalarmDataService battAlarmService;
|
|
@Autowired
|
private DeviceAlarmDataService deviceAlarmService;
|
|
@Autowired
|
private WorkflowMainService mainService;
|
|
@Autowired
|
private WorkflowAlarmService workflowAlarmService;
|
|
/**根据电池告警和设备告警,生成告警工单和工作流主表记录*/
|
@Scheduled(cron = SuperConstant.SCHEDULE_PER_MINUTE)
|
@Transactional
|
public void generateWorkflowAlarmAndMain() {
|
if (YamlProperties.alarmTaskSwitch.toUpperCase().equals("ON")) {
|
//从电池/设备告警表获取记录,系统派单到站点所在包机组的角色为管理员的用户(uRole=0)
|
List<WorkflowAlarm> battAlarmList = battAlarmService.getAlarmList();
|
List<WorkflowAlarm> deviceAlarmList = deviceAlarmService.getAlarmList();
|
battAlarmList.addAll(deviceAlarmList);
|
List<WorkflowAlarm> alarmList = battAlarmList;
|
alarmList.stream().forEach(alarm -> alarm.setAlarmName(AlarmConstant.getAllAlarmName(Integer.parseInt(alarm.getAlarmName()))));
|
//将记录生成到工作流主表和告警工单表中
|
if (alarmList.size() != 0) {
|
workflowAlarmService.add(alarmList);
|
//example:WF-1-20211101-00001
|
String ymd = new SimpleDateFormat("yyyyMMdd").format(new Date());
|
final String[] nextSequence = {mainService.getNextSequence()};
|
List<WorkflowMain> workflowMainList = new LinkedList<>();
|
alarmList.stream().forEach(workflowAlarm -> {
|
WorkflowMain temp = new WorkflowMain();
|
temp.setOrderId("WF-1-" + ymd + "-" + nextSequence[0]);
|
nextSequence[0] = String.format("%05d", Integer.parseInt(nextSequence[0]) + 1);
|
temp.setCreateTime(new Date());
|
temp.setCreateUserId(workflowAlarm.getUserId());
|
if (workflowAlarm.getDeviceId() == null) {
|
temp.setTitle("站点:" + workflowAlarm.getStationName() + "的" + workflowAlarm.getBattGroupName() + " 发生告警:" + workflowAlarm.getAlarmName());
|
temp.setTaskDesc("[" + workflowAlarm.getStationName() + "]的" + workflowAlarm.getBattGroupName() + "在" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(workflowAlarm.getAlarmTime()) + "发生" + workflowAlarm.getAlarmName());
|
} else {
|
temp.setTitle("站点:" + workflowAlarm.getStationName() + " 发生告警:" + workflowAlarm.getAlarmName());
|
temp.setTaskDesc("[" + workflowAlarm.getStationName() + "]在" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(workflowAlarm.getAlarmTime()) + "发生" + workflowAlarm.getAlarmName());
|
}
|
temp.setAlarmOrderId(workflowAlarm.getId());
|
temp.setStatus(WorkflowEnum.MAIN_STATUS_AUTO.getValue());
|
temp.setAuto(1);
|
workflowMainList.add(temp);
|
});
|
mainService.add(workflowMainList);
|
//增加子节点,系统自动派单给某个用户
|
|
//将原始数据状态设置为已生成工单,即work_flag=1
|
if (battAlarmList.size() != 0) {
|
battAlarmService.updateWorkFlag(battAlarmList);
|
}
|
if (deviceAlarmList.size() != 0) {
|
deviceAlarmService.updateWorkFlag(deviceAlarmList);
|
}
|
}
|
}
|
}
|
|
}
|
