From 809f2703ce14d4c76eee5a998aeca064a340780a Mon Sep 17 00:00:00 2001
From: zenglf <18502938215@163.com>
Date: 星期三, 25 十月 2023 18:41:15 +0800
Subject: [PATCH] 维修工单管理
---
lxzn-module-eam/src/main/java/org/jeecg/modules/eam/job/RepairOrderWarning.java | 96 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 96 insertions(+), 0 deletions(-)
diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/job/RepairOrderWarning.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/job/RepairOrderWarning.java
new file mode 100644
index 0000000..c4ddca3
--- /dev/null
+++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/job/RepairOrderWarning.java
@@ -0,0 +1,96 @@
+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);
+ }
+ }
+ }
+ }
+ }
+}
--
Gitblit v1.9.3