package org.jeecg.modules.eam.job;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import org.jeecg.common.api.dto.message.MessageDTO;
|
import org.jeecg.common.system.api.ISysBaseAPI;
|
import org.jeecg.modules.eam.entity.Equipment;
|
import org.jeecg.modules.eam.entity.EquipmentReportRepair;
|
import org.jeecg.modules.eam.service.IEamEquipmentService;
|
import org.jeecg.modules.eam.service.IEquipmentReportRepairService;
|
import org.jeecg.modules.eam.service.IPredictiveWorkPlanWarnService;
|
import org.jeecg.modules.system.entity.SysUser;
|
import org.jeecg.modules.system.service.ISysUserService;
|
import org.quartz.Job;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.ZoneId;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author 李能靓
|
*/
|
public class RepairOrderWarning implements Job {
|
@Resource
|
private IEquipmentReportRepairService equipmentReportRepairService;
|
|
@Resource
|
private IEamEquipmentService equipmentService;
|
|
@Resource
|
private ISysBaseAPI sysBaseAPI;
|
|
@Resource
|
private ISysUserService sysUserService;
|
|
|
@Override
|
public void execute(JobExecutionContext context) throws JobExecutionException {
|
LocalDateTime currentDateTime = LocalDateTime.now();
|
LocalDateTime dateBefore3Days = currentDateTime.minusDays(3);
|
LocalDateTime dateBefore1Days = currentDateTime.minusDays(1);
|
Date result3 = Date.from(dateBefore3Days.atZone(ZoneId.systemDefault()).toInstant());
|
Date result1= Date.from(dateBefore1Days.atZone(ZoneId.systemDefault()).toInstant());
|
List<EquipmentReportRepair> equipmentReportRepairs1 = equipmentReportRepairService.list(new QueryWrapper<EquipmentReportRepair>().lt("fault_time",result1).eq("status","1"));
|
List<EquipmentReportRepair> equipmentReportRepairs3 = equipmentReportRepairService.list(new QueryWrapper<EquipmentReportRepair>().lt("fault_time",result3).eq("status","1"));
|
for(EquipmentReportRepair equipmentReportRepair1:equipmentReportRepairs1){
|
Equipment equipment1 = equipmentService.getById(equipmentReportRepair1.getEquipmentId());
|
if(StringUtils.isNotBlank(equipment1.getSpecificEquipment())){
|
String teamId = equipment1.getTeamId();
|
if(StringUtils.isNotBlank(teamId)){
|
List<SysUser> sysUsers = sysUserService.list(new QueryWrapper<SysUser>()
|
.eq("team_id",teamId)
|
.eq("del_flag",0));
|
for(SysUser user:sysUsers){
|
String msg = "统一编号为【"+equipment1.getNum()+"】的设备已经超过一天未维修，请移步至故障报修查看";
|
MessageDTO messageDTO = new MessageDTO();
|
messageDTO.setTitle("故障报修提醒");
|
messageDTO.setContent(msg);
|
messageDTO.setCategory("故障报修提醒");
|
messageDTO.setFromUser("故障报修提醒小助手");
|
messageDTO.setToUser(user.getUsername());
|
sysBaseAPI.sendSysAnnouncement(messageDTO);
|
}
|
}
|
}
|
|
}
|
|
for(EquipmentReportRepair equipmentReportRepair3:equipmentReportRepairs3){
|
Equipment equipment3 = equipmentService.getById(equipmentReportRepair3.getEquipmentId());
|
if(StringUtils.isNotBlank(equipment3.getSpecificEquipment())){
|
String teamId = equipment3.getTeamId();
|
if(StringUtils.isNotBlank(teamId)){
|
List<SysUser> sysUsers = sysUserService.list(new QueryWrapper<SysUser>()
|
.eq("team_id",teamId)
|
.eq("del_flag",0));
|
for(SysUser user:sysUsers){
|
String msg = "统一编号为【"+equipment3.getNum()+"】的设备已经超过三天未维修，请移步至故障报修查看";
|
MessageDTO messageDTO = new MessageDTO();
|
messageDTO.setTitle("故障报修提醒");
|
messageDTO.setContent(msg);
|
messageDTO.setCategory("故障报修提醒");
|
messageDTO.setFromUser("故障报修提醒小助手");
|
messageDTO.setToUser(user.getUsername());
|
sysBaseAPI.sendSysAnnouncement(messageDTO);
|
}
|
}
|
}
|
}
|
}
|
}
|
