From 3842b76e482975e6f1e94f6e1d688bdd834e320f Mon Sep 17 00:00:00 2001 From: liaohechuan Date: Tue, 27 May 2025 17:02:57 +0800 Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=EF=BC=88JOB=EF=BC=89=E6=96=B0?= =?UTF-8?q?=E5=A2=9E=E6=AF=8F=E6=97=A5=E5=AE=9A=E6=97=B6=E7=94=9F=E6=88=90?= =?UTF-8?q?=E5=B7=A1=E6=A3=80=E4=BB=BB=E5=8A=A1=E5=8D=95=E5=92=8C=E6=AF=8F?= =?UTF-8?q?=E6=97=A5=E5=AE=9A=E6=97=B6=E7=94=9F=E6=88=90=E4=BF=9D=E5=85=BB?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=8D=95=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../foreverwin/mom/pms/job/EquipmentJob.java | 61 +++++++++++++++++++ 1 file changed, 61 insertions(+) create mode 100644 mom-pms-core/src/main/java/com/foreverwin/mom/pms/job/EquipmentJob.java diff --git a/mom-pms-core/src/main/java/com/foreverwin/mom/pms/job/EquipmentJob.java b/mom-pms-core/src/main/java/com/foreverwin/mom/pms/job/EquipmentJob.java new file mode 100644 index 0000000..a4f4e03 --- /dev/null +++ b/mom-pms-core/src/main/java/com/foreverwin/mom/pms/job/EquipmentJob.java @@ -0,0 +1,61 @@ +package com.foreverwin.mom.pms.job; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.foreverwin.mom.pms.entity.PmsMaintenancePlanMaster; +import com.foreverwin.mom.pms.entity.PmsPatrolSheetExt; +import com.foreverwin.mom.pms.service.PmsMaintenancePlanMasterService; +import com.foreverwin.mom.pms.service.PmsPatrolSheetExtService; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.AllArgsConstructor; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.List; + +/** + * JOB + */ +@Component +@AllArgsConstructor +public class EquipmentJob { + + private PmsPatrolSheetExtService pmsPatrolSheetExtService; + + private PmsMaintenancePlanMasterService pmsMaintenancePlanMasterService; + + /** + * 每日定时生成巡检任务单 + */ + @XxlJob("inspectionOrderJobHandler") + public void generateInspectionOrder() { + XxlJobHelper.log ( "每日定时生成巡检任务单JOB开始" ); + try { + List list = pmsPatrolSheetExtService.list ( new LambdaQueryWrapper() + .eq ( PmsPatrolSheetExt::getStateName, "on" ) + .le ( PmsPatrolSheetExt::getPlayTime, LocalDateTime.now () ) + .ge ( PmsPatrolSheetExt::getEndTime, LocalDateTime.now () ) ); + XxlJobHelper.log ( "待生成工单计划数:" + list.size () ); + list.forEach ( pmsPatrolSheetExtService::planGeneration ); + } catch (Exception e) { + XxlJobHelper.handleFail ( "每日定时生成巡检任务单JOB失败:" + e ); + } + XxlJobHelper.log ( "每日定时生成巡检任务单JOB结束" ); + } + + /** + * 每日定时生成保养任务单 + */ + @XxlJob("maintenanceOrderJobHandler") + public void generateMaintenanceOrder() { + XxlJobHelper.log ( "每日定时生成保养任务单JOB开始" ); + try { + List planList = pmsMaintenancePlanMasterService.getPlanList (); + XxlJobHelper.log ( "待生成工单计划数:" + planList.size () ); + planList.forEach ( pmsMaintenancePlanMasterService::execute ); + } catch (Exception e) { + XxlJobHelper.handleFail ( "每日定时生成保养任务单JOB失败:" + e ); + } + XxlJobHelper.log ( "每日定时生成保养任务单JOB结束" ); + } +}