package com.ld.igds.timer;
|
|
|
import com.ld.igds.io.request.BaseRequest;
|
import com.ld.igds.io.request.DeviceAutoControlRequest;
|
import com.ld.igds.io.request.DeviceControlRequest;
|
import com.ld.igds.models.N2IntelTask;
|
import com.ld.igds.n2.service.CoreN2Service;
|
import com.ld.igds.pressure.PressureManager;
|
import com.ld.igds.util.DateUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
|
/**
|
* @Desc: 气调定时任务，主要包括气调任务执行判断和相关
|
* @author: Andy
|
* @update-time: 2022/12/27
|
*/
|
@Slf4j
|
@Component(N2Scheduled.BEAN_ID)
|
public class N2Scheduled {
|
|
public static final String BEAN_ID = "basic.n2Scheduled";
|
|
@Resource
|
private CoreN2Service coreN2Service;
|
@Resource
|
private PressureManager pressureManager;
|
|
|
/**
|
* 氮气气调任务判断，早上8--18点之间每间隔1分组执行一次任务查询并执行，
|
* 通过缓存中的任务列表进行执行，如果缓存中没有任务需要执行，则直接跳过
|
*/
|
@Scheduled(cron = "0 * 8-17 * * ?")
|
public void n2TaskExe() {
|
|
Date cur = new Date();
|
|
log.debug("--------定时任务系统气调任务执行--------");
|
|
//TODO 暂停当前系统执行模式，公司自己控制柜执行，直接返回结果和状态，当前定时任务根据气调任务调用压力即可
|
|
List<N2IntelTask> list = coreN2Service.listIntelTaskByCache(null);
|
|
|
//获取实时压力信息
|
this.exePressure(list, cur);
|
}
|
|
/**
|
* 根据系统中是否纯在需要执行的任务进行压力检测，如果没有气调任务则不用执行压力检测
|
* <p>
|
* 如果系统没有任务，每天固定时间点执行异常压力检测 暂定每天早上8点1分钟
|
*
|
* @param list
|
*/
|
private void exePressure(List<N2IntelTask> list, Date curDate) {
|
|
if (null == list) {
|
|
int hour = DateUtil.getHour(curDate);
|
int minute = DateUtil.getMinute(curDate);
|
|
if (hour == 8 && minute == 1) {
|
pressureManager.checkAll();
|
}
|
return;
|
}
|
|
//去重复，同一分机只执行一次
|
Map<String, String> tempMap = new HashMap<>();
|
|
DeviceAutoControlRequest autoControlRequest;
|
DeviceControlRequest controlRequest;
|
BaseRequest baseRequest;
|
for (N2IntelTask task : list) {
|
autoControlRequest = task.getAutoControlRequest();
|
if (null != autoControlRequest) {
|
|
if (null != tempMap.get(autoControlRequest.getSerId())) {
|
continue;
|
}
|
|
baseRequest = new BaseRequest();
|
baseRequest.setDeptId(task.getDeptId());
|
baseRequest.setCompanyId(task.getCompanyId());
|
baseRequest.setSerName(autoControlRequest.getSerName());
|
baseRequest.setSerId(autoControlRequest.getSerId());
|
baseRequest.setIp(autoControlRequest.getIp());
|
baseRequest.setPort(autoControlRequest.getPort());
|
baseRequest.setBizType(autoControlRequest.getBizType());
|
baseRequest.setDepotId(task.getDepotId());
|
baseRequest.setDepotName(autoControlRequest.getDepotName());
|
baseRequest.setProtocol(autoControlRequest.getProtocol());
|
|
pressureManager.checkByRequest(baseRequest);
|
|
tempMap.put(baseRequest.getSerId(), "SUCCESS");
|
continue;
|
}
|
|
controlRequest = task.getDeviceControlRequest();
|
if (null != controlRequest) {
|
|
if (null != tempMap.get(controlRequest.getSerId())) {
|
continue;
|
}
|
|
baseRequest = new BaseRequest();
|
baseRequest.setDeptId(task.getDeptId());
|
baseRequest.setCompanyId(task.getCompanyId());
|
baseRequest.setSerName(controlRequest.getSerName());
|
baseRequest.setSerId(controlRequest.getSerId());
|
baseRequest.setIp(controlRequest.getIp());
|
baseRequest.setPort(controlRequest.getPort());
|
baseRequest.setBizType(controlRequest.getBizType());
|
baseRequest.setDepotId(task.getDepotId());
|
baseRequest.setDepotName(controlRequest.getDepotName());
|
baseRequest.setProtocol(controlRequest.getProtocol());
|
|
pressureManager.checkByRequest(baseRequest);
|
tempMap.put(baseRequest.getSerId(), "SUCCESS");
|
|
continue;
|
}
|
}
|
}
|
}
|
