package org.jeecg.modules.quartz.job;
|
|
import org.jeecg.modules.andon.entity.AndonButtonConfig;
|
import org.jeecg.modules.andon.entity.AndonOrder;
|
import org.jeecg.modules.andon.entity.AndonResponseConfig;
|
import org.jeecg.modules.andon.service.IAndonButtonConfigService;
|
import org.jeecg.modules.andon.service.IAndonOrderService;
|
import org.jeecg.modules.andon.service.IAndonResponseConfigService;
|
import org.quartz.Job;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
|
import java.time.LocalDateTime;
|
import java.time.ZoneId;
|
import java.util.Date;
|
import java.util.List;
|
//org.jeecg.modules.quartz.job.AndonJob
|
public class AndonJob implements Job {
|
private static final String ANDON_STATUS_DXY = "1";
|
private static final String ANDON_STATUS_DCL = "2";
|
private static final String ANDON_STATUS_YWC = "3";
|
@Autowired
|
@Lazy
|
private IAndonOrderService andonOrderService;
|
@Autowired
|
@Lazy
|
private IAndonButtonConfigService andonButtonConfigService;
|
@Autowired
|
@Lazy
|
private IAndonResponseConfigService andonResponseConfigService;
|
|
@Override
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
LocalDateTime currentTime = LocalDateTime.now();
|
List<AndonOrder> andonOrdersExceptYWC = andonOrderService.getAndonOrdersExceptYWC();
|
for (AndonOrder andonOrder : andonOrdersExceptYWC) {
|
AndonResponseConfig andonResponseConfig = andonResponseConfigService.getAndonResponseConfigByFactoryIdAndButtonId(andonOrder.getFactoryId(), andonOrder.getButtonId());
|
AndonButtonConfig andonButtonConfig = andonButtonConfigService.getAndonButtonById(andonOrder.getButtonId());
|
System.out.println("andonOrder----"+andonOrder.getId()+"----andonResponseConfig----"+andonResponseConfig.getId()+"-----"+"andonButtonConfig----"+andonButtonConfig.getId());
|
levelUpgradeOne(andonOrder, andonResponseConfig, andonButtonConfig, currentTime);
|
levelUpgradeTwo(andonOrder, andonResponseConfig, andonButtonConfig, currentTime);
|
levelProcessOne(andonOrder, andonResponseConfig, andonButtonConfig, currentTime);
|
levelProcessTwo(andonOrder, andonResponseConfig, andonButtonConfig, currentTime);
|
}
|
}
|
|
/**
|
* 判断二级响应升级
|
* 如果安灯工单响应时间超过一级响应时长还为空，则说明未响应
|
*/
|
public void levelUpgradeOne(AndonOrder andonOrder, AndonResponseConfig andonResponseConfig, AndonButtonConfig andonButtonConfig, LocalDateTime currentTime) {
|
if (andonOrder.getAndonLevel().equals("1") && andonOrder.getOrderStatus().equals(ANDON_STATUS_DXY)) {
|
//安灯时间
|
Date operateTime = andonOrder.getOperateTime();
|
//响应时长 （分钟）
|
Integer upgradeResponseDuration = andonButtonConfig.getUpgradeResponseDuration();
|
LocalDateTime timeoutTime = operateTime.toInstant()
|
.atZone(ZoneId.systemDefault())
|
.toLocalDateTime()
|
.plusMinutes(upgradeResponseDuration);
|
if (currentTime.isAfter(timeoutTime)) {
|
//响应时间超过一级响应时长，升级一次,并提醒（模拟发送飞书消息）
|
andonOrder.setAndonLevel("2");
|
andonOrderService.saveOrUpdate(andonOrder);
|
//TODO 发送飞书消息（这块为模拟需要有接口才能开发）
|
System.out.println("初始响应人"+andonResponseConfig.getFirsterResponder()+"未响应！"+"安灯工单：" + andonOrder.getId() + "已升级二级响应,并发消息给二级响应人"+andonResponseConfig.getSecondResponder());
|
}
|
}
|
}
|
|
/**
|
* 判断三级响应升级
|
* 安灯工单响应时间超过二级响应时长还为空，则说明未响应
|
*/
|
public void levelUpgradeTwo(AndonOrder andonOrder, AndonResponseConfig andonResponseConfig, AndonButtonConfig andonButtonConfig, LocalDateTime currentTime) {
|
if (andonOrder.getAndonLevel().equals("2") && andonOrder.getOrderStatus().equals(ANDON_STATUS_DXY)) {
|
Date operateTime = andonOrder.getOperateTime();
|
Integer upgradeResponseDuration = andonButtonConfig.getSecondUpgradeResponseDuration();
|
LocalDateTime timeoutTime = operateTime.toInstant()
|
.atZone(ZoneId.systemDefault())
|
.toLocalDateTime()
|
.plusMinutes(upgradeResponseDuration);
|
if (currentTime.isAfter(timeoutTime)) {
|
//响应时间超过一级响应时长，升级一次,并提醒（模拟发送飞书消息）
|
andonOrder.setAndonLevel("3");
|
andonOrderService.saveOrUpdate(andonOrder);
|
//TODO 发送飞书消息（这块为模拟需要有接口才能开发）
|
System.out.println("二级响应人"+andonResponseConfig.getSecondResponder()+"未响应！"+"安灯工单：" + andonOrder.getId() + "已升级三级响应,并发消息给三级响应人"+andonResponseConfig.getThirdResponder());
|
}
|
}
|
}
|
/**
|
* 判断二级处理升级
|
* 安灯工单响应时间超过二级处理时长还为空，则说明未响应
|
*/
|
public void levelProcessOne(AndonOrder andonOrder, AndonResponseConfig andonResponseConfig, AndonButtonConfig andonButtonConfig, LocalDateTime currentTime){
|
if (andonOrder.getAndonLevel().equals("1") && andonOrder.getOrderStatus().equals(ANDON_STATUS_DCL)) {
|
Date responseTime = andonOrder.getResponseTime();
|
Integer upgradeProcessDuration = andonButtonConfig.getUpgradeProcessDuration();
|
LocalDateTime timeoutTime = responseTime.toInstant()
|
.atZone(ZoneId.systemDefault())
|
.toLocalDateTime()
|
.plusMinutes(upgradeProcessDuration);
|
if (currentTime.isAfter(timeoutTime)) {
|
//处理时间超过一级处理时长，升级一次,并提醒（模拟发送飞书消息）
|
andonOrder.setAndonLevel("2");
|
andonOrderService.saveOrUpdate(andonOrder);
|
//TODO 发送飞书消息（这块为模拟需要有接口才能开发）
|
System.out.println("一级处理人"+andonResponseConfig.getFirsterResponder()+"未处理！"+"安灯工单：" + andonOrder.getId() + "已升级二级处理,并发消息给二级处理人"+andonResponseConfig.getSecondResponder());
|
}
|
}
|
}
|
/**
|
* 判断三级处理升级
|
* 安灯工单响应时间超过二级处理时长还为空，则说明未响应
|
*/
|
public void levelProcessTwo(AndonOrder andonOrder, AndonResponseConfig andonResponseConfig, AndonButtonConfig andonButtonConfig, LocalDateTime currentTime){
|
if (andonOrder.getAndonLevel().equals("2") && andonOrder.getOrderStatus().equals(ANDON_STATUS_DCL)) {
|
Date responseTime = andonOrder.getResponseTime();
|
Integer secondUpgradeProcessDuration = andonButtonConfig.getSecondUpgradeProcessDuration();
|
LocalDateTime timeoutTime = responseTime.toInstant()
|
.atZone(ZoneId.systemDefault())
|
.toLocalDateTime()
|
.plusMinutes(secondUpgradeProcessDuration);
|
if (currentTime.isAfter(timeoutTime)) {
|
//处理时间超过一级处理时长，升级一次,并提醒（模拟发送飞书消息）
|
andonOrder.setAndonLevel("3");
|
andonOrderService.saveOrUpdate(andonOrder);
|
//TODO 发送飞书消息（这块为模拟需要有接口才能开发）
|
System.out.println("二级处理人"+andonResponseConfig.getSecondResponder()+"未处理！"+"安灯工单：" + andonOrder.getId() + "已升级三级处理,并发消息给三级处理人"+andonResponseConfig.getThirdResponder());
|
}
|
}
|
}
|
|
}
|
