| | |
| | | import com.ruoyi.project.system.service.ISysNoticeService; |
| | | import com.ruoyi.project.system.domain.SysNotice; |
| | | |
| | | import com.ruoyi.project.system.service.impl.UnipushService; |
| | | import java.util.Collections; |
| | | import java.io.Serializable; |
| | | import java.time.DayOfWeek; |
| | | import java.time.LocalDateTime; |
| | |
| | | |
| | | @Autowired |
| | | private ISysNoticeService sysNoticeService; |
| | | |
| | | @Autowired |
| | | private UnipushService unipushService; |
| | | |
| | | @Override |
| | | public void execute(JobExecutionContext context) throws JobExecutionException { |
| | |
| | | // 给执行人发送系统通知 |
| | | if (timingTask.getExecutorId() != null) { |
| | | SysNotice notice = new SysNotice(); |
| | | notice.setNoticeTitle("新保养任务提醒"); |
| | | notice.setNoticeTitle("新保养计划提醒"); |
| | | notice.setNoticeType("1"); // 1 通知 |
| | | notice.setNoticeContent("您有一个新的设备保养任务需要执行,设备名称:" + timingTask.getTaskName()); |
| | | String dateStr = java.time.LocalDate.now().toString(); |
| | | notice.setNoticeContent("你有一个新的设备保养计划 ," + dateStr + " " + timingTask.getTaskName()); |
| | | notice.setStatus("0"); // 正常 |
| | | notice.setConsigneeId(timingTask.getExecutorId()); |
| | | notice.setSenderId(0L); // 0代表系统发送 |
| | | notice.setTenantId(timingTask.getTenantId()); |
| | | sysNoticeService.insertNotice(notice); |
| | | |
| | | try { |
| | | unipushService.sendClientMessage(Collections.singletonList(notice)); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | // 3. 更新定时任务的执行时间 |
| | |
| | | inspectionTask.setStatus(0); |
| | | inspectionTask.setDeviceModel(timingTask.getDeviceModel()); |
| | | inspectionTask.setMachineryCategory(timingTask.getMachineryCategory()); |
| | | inspectionTask.setCreateUser(Integer.parseInt(timingTask.getRegistrantId().toString())); |
| | | if (timingTask.getRegistrantId() != null) { |
| | | inspectionTask.setCreateUser(Integer.parseInt(timingTask.getRegistrantId().toString())); |
| | | inspectionTask.setUpdateUser(Integer.parseInt(timingTask.getRegistrantId().toString())); |
| | | } |
| | | inspectionTask.setUpdateTime(LocalDateTime.now()); |
| | | inspectionTask.setCreateTime(LocalDateTime.now()); |
| | | inspectionTask.setUpdateUser(Integer.parseInt(timingTask.getRegistrantId().toString())); |
| | | return inspectionTask; |
| | | } |
| | | |