From 127c8405dcbbb47abaa54f0caeb94f2387c9454a Mon Sep 17 00:00:00 2001 From: zhaokai Date: Thu, 5 Mar 2026 15:24:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AFjob?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../check/plan/FireCheckRecordPlanDayJob.java | 49 ++++++++++++++++++ .../FireCheckRecordPlanHalfMonthlyJob.java | 44 ++++++++++++++++ .../FireCheckRecordPlanHalfYearlyJob.java | 45 ++++++++++++++++ .../plan/FireCheckRecordPlanMonthlyJob.java | 44 ++++++++++++++++ .../plan/FireCheckRecordPlanQuarterlyJob.java | 44 ++++++++++++++++ .../plan/FireCheckRecordPlanTenDayJob.java | 42 +++++++++++++++ .../plan/FireCheckRecordPlanWeeklyJob.java | 51 +++++++++++++++++++ .../plan/FireCheckRecordPlanYearlyJob.java | 44 ++++++++++++++++ .../check/plan/FireDeviceOverTimeJob.java | 33 ++++++++++++ .../check/plan/WaitFireCheckLisTenJob.java | 32 ++++++++++++ .../check/plan/WaitFireCheckListDayJob.java | 32 ++++++++++++ .../plan/WaitFireCheckListHalfMonthlyJob.java | 32 ++++++++++++ .../plan/WaitFireCheckListHalfYearlyJob.java | 32 ++++++++++++ .../plan/WaitFireCheckListMonthlyJob.java | 32 ++++++++++++ .../plan/WaitFireCheckListQuarterlyJob.java | 32 ++++++++++++ .../plan/WaitFireCheckListWeeklyJob.java | 36 +++++++++++++ .../plan/WaitFireCheckListYearlyJob.java | 32 ++++++++++++ 17 files changed, 656 insertions(+) create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanDayJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfMonthlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfYearlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanMonthlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanQuarterlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanTenDayJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanWeeklyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanYearlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/FireDeviceOverTimeJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckLisTenJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListDayJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfMonthlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfYearlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListMonthlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListQuarterlyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListWeeklyJob.java create mode 100644 web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListYearlyJob.java diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanDayJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanDayJob.java new file mode 100644 index 0000000..712195c --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanDayJob.java @@ -0,0 +1,49 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.api.FireCheckRecordServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import com.zcloud.fire.check.domain.model.FireCheckRecordE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanDayJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 10 0 * * ?", jobDesc = "每半年超期未检查记录",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.FireCheckRecordPlanDayJob") + public ReturnT execute(String param) { + + System.out.println("开始执行计划任务"); + XxlJobHelper.log( "============每日超期消息提醒(消防点检)=========="); + log.info( "============每日超期消息提醒(消防点检)==========开始"); + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getDayStartTime()); + params.put("endDate", checkRecordInterval.getDayEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.DAILY.getCode()); + fireCheckListServiceI.overTimeRecord(params); + log.info( "============每日超期消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfMonthlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfMonthlyJob.java new file mode 100644 index 0000000..7832095 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfMonthlyJob.java @@ -0,0 +1,44 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanHalfMonthlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 0 0 1,16 * ? ", jobDesc = "每半月超期未检查记录",triggerStatus = 1) +// @XxlJob(" com.zcloud.fire.check.plan.FireCheckRecordPlanHalfMonthlyJob") + public ReturnT execute(String param) { + XxlJobHelper.log( "============开始定时每半月超期未检查记录=========="); + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getHalfMonthStartTime()); + params.put("endDate", checkRecordInterval.getHalfMonthEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.HALF_MONTH.getCode()); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============结束定时每半月超期未检查记录=========="); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfYearlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfYearlyJob.java new file mode 100644 index 0000000..f1bb37f --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfYearlyJob.java @@ -0,0 +1,45 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanHalfYearlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 5 0 1 1,7 ?", jobDesc = "每半年超期未检查记录",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.CheckRecordPlanHalfYearlyJob") + public ReturnT execute(String param) { + XxlJobHelper.log( "============开始定时增加每半年超期未检查记录=========="); + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getHalfYearStartTime()); + params.put("endDate", checkRecordInterval.getHalfYearEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.HALF_YEAR.getCode()); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============结束定时增加每半年超期未检查记录=========="); + + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanMonthlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanMonthlyJob.java new file mode 100644 index 0000000..0c9d5a1 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanMonthlyJob.java @@ -0,0 +1,44 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanMonthlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 5 0 1 * ?", jobDesc = "每月超期未检查记录",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.CheckRecordPlanMonthlyJob") + public ReturnT execute(String param) { + XxlJobHelper.log( "============开始定时增加每月超期未检查记录=========="); + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getMonthlyStartTime()); + params.put("endDate", checkRecordInterval.getMonthlyEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.MONTHLY.getCode()); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============结束定时增加每月超期未检查记录=========="); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanQuarterlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanQuarterlyJob.java new file mode 100644 index 0000000..f8c3c56 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanQuarterlyJob.java @@ -0,0 +1,44 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanQuarterlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 5 0 1 1,4,7,10 ?", jobDesc = "每季度超期未检查记录",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.CheckRecordPlanQuarterlyJob") + public ReturnT execute(String param) { + XxlJobHelper.log( "============开始定时每季度超期未检查记录=========="); + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getQuarterlyStartTime()); + params.put("endDate", checkRecordInterval.getQuarterlyEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.QUARTERLY.getCode()); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============结束定时每季度超期未检查记录=========="); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanTenDayJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanTenDayJob.java new file mode 100644 index 0000000..2f68b06 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanTenDayJob.java @@ -0,0 +1,42 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanTenDayJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 5 0 1,11,21 * ?", jobDesc = "每询超期未检查记录",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.CheckRecordPlanTenDayJob") + public ReturnT execute(String param) { + XxlJobHelper.log( "============开始定时增加每询超期未检查记录=========="); + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getTenDaysStartTime()); + params.put("endDate", checkRecordInterval.getTenDaysEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.TEN_DAYS.getCode()); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============定时增加每询超期未检查记录完成=========="); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanWeeklyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanWeeklyJob.java new file mode 100644 index 0000000..d068dc1 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanWeeklyJob.java @@ -0,0 +1,51 @@ +package com.zcloud.fire.check.plan; + +import cn.hutool.json.JSONUtil; +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanWeeklyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 5 0 ? * MON", jobDesc = "每周超期未检查记录",triggerStatus = 1) +// @XxlJob("com.zcloud.zcGbsServicer.plan.CheckRecordPlanWeeklyJob") + public ReturnT execute(String param) { + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getWeeklyStartTime()); + params.put("endDate", checkRecordInterval.getWeeklyEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.WEEKLY.getCode()); + XxlJobHelper.log( "============开始定时增加每周超期未检查记录===,请求:"+ JSONUtil.toJsonStr( params)); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============结束定时增加每周超期未检查记录=========="); + + params.put("checkType", ListManagerCheckPeriodEnum.WEEKLY_N_TIMES.getCode()); + XxlJobHelper.log( "============开始定时增加每周N次超期未检查记录===,请求:"+ JSONUtil.toJsonStr( params)); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============结束定时增加每周N次超期未检查记录=========="); + + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanYearlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanYearlyJob.java new file mode 100644 index 0000000..95278e3 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanYearlyJob.java @@ -0,0 +1,44 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import com.zcloud.fire.check.domain.model.DateTimeE; +import com.zcloud.fire.check.domain.model.FireCheckListE; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireCheckRecordPlanYearlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 5 0 1 1 ?", jobDesc = "每年超期未检查记录",triggerStatus = 1) +// @XxlJob("com.zcloud.zcGbsServicer.plan.CheckRecordPlanYearlyJob") + public ReturnT execute(String param) { + XxlJobHelper.log( "============开始定时每年超期未检查记录=========="); + Map params =new HashMap<>(); + FireCheckListE fireCheckListE = new FireCheckListE(); + DateTimeE checkRecordInterval = fireCheckListE.getCheckRecordInterval(LocalDateTime.now().minusDays(1)); + params.put("startDate", checkRecordInterval.getMonthlyStartTime()); + params.put("endDate", checkRecordInterval.getYearlyEndTime()); + params.put("checkType", ListManagerCheckPeriodEnum.YEARLY.getCode()); + fireCheckListServiceI.overTimeRecord(params); + XxlJobHelper.log( "============结束定时每年超期未检查记录=========="); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireDeviceOverTimeJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireDeviceOverTimeJob.java new file mode 100644 index 0000000..0a93e0c --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/FireDeviceOverTimeJob.java @@ -0,0 +1,33 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireDeviceServiceI; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class FireDeviceOverTimeJob implements Job { + + @Autowired + private FireDeviceServiceI fireDeviceServiceI; + + @Override +// @JobRegister(cron = "0 30 0 * * ?", jobDesc = "消防设备到期提请",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.FireDeviceOverTimeJob") + public ReturnT execute(String param) { + + log.info( "============消防设备到期提请(消防点检)==========开始"); + XxlJobHelper.log( "============消防设备到期提请(消防点检)=========="); + + fireDeviceServiceI.deviceOverTimeMessage(); + + log.info( "============消防设备到期提请(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckLisTenJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckLisTenJob.java new file mode 100644 index 0000000..09205e0 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckLisTenJob.java @@ -0,0 +1,32 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckLisTenJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override + // @JobRegister(cron = "0 5 0 1,11,21 * ?", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckLisTenJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.TEN_DAYS.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListDayJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListDayJob.java new file mode 100644 index 0000000..e454719 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListDayJob.java @@ -0,0 +1,32 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckListDayJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 30 0 * * ?", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckListDayJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.DAILY.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfMonthlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfMonthlyJob.java new file mode 100644 index 0000000..6934d58 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfMonthlyJob.java @@ -0,0 +1,32 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckListHalfMonthlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override + // @JobRegister(cron = "0 0 0 1,16 * ? ", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckListHalfMonthlyJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.HALF_MONTH.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfYearlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfYearlyJob.java new file mode 100644 index 0000000..cbf333c --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfYearlyJob.java @@ -0,0 +1,32 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckListHalfYearlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override + // @JobRegister(cron = "0 5 0 1 1,7 ?", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckListHalfYearlyJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.HALF_YEAR.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListMonthlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListMonthlyJob.java new file mode 100644 index 0000000..16e6ac0 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListMonthlyJob.java @@ -0,0 +1,32 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckListMonthlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override + // @JobRegister(cron = "0 5 0 1 * ?", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckListMonthlyJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.MONTHLY.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListQuarterlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListQuarterlyJob.java new file mode 100644 index 0000000..846b4f2 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListQuarterlyJob.java @@ -0,0 +1,32 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckListQuarterlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override + // @JobRegister(cron = "0 5 0 1 1,4,7,10 ?", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckListQuarterlyJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.QUARTERLY.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListWeeklyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListWeeklyJob.java new file mode 100644 index 0000000..88a1ab6 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListWeeklyJob.java @@ -0,0 +1,36 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.jjb.saas.framework.job.annotation.JobRegister; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckListWeeklyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override +// @JobRegister(cron = "0 5 0 ? * MON", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckListYearlyJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.WEEKLY.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.WEEKLY_N_TIMES.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +} diff --git a/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListYearlyJob.java b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListYearlyJob.java new file mode 100644 index 0000000..94e38df --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListYearlyJob.java @@ -0,0 +1,32 @@ +package com.zcloud.fire.check.plan; + +import com.jjb.saas.framework.job.Job; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.zcloud.fire.check.api.FireCheckListServiceI; +import com.zcloud.fire.check.domain.enums.ListManagerCheckPeriodEnum; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@RequiredArgsConstructor +@Component +@Slf4j +public class WaitFireCheckListYearlyJob implements Job { + + @Autowired + private FireCheckListServiceI fireCheckListServiceI; + + @Override + // @JobRegister(cron = "0 5 0 1 1 ?", jobDesc = "待排查消息提醒",triggerStatus = 1) +// @XxlJob("com.zcloud.fire.check.plan.WaitFireCheckListYearlyJob") + public ReturnT execute(String param) { + + log.info( "============待排查消息提醒(消防点检)==========开始"); + XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始"); + fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.YEARLY.getCode()); + log.info( "============待排查消息提醒(消防点检)==========结束"); + return ReturnT.SUCCESS; + } +}