zcloud_gbs
/
zcloud_gbs_fire_check_gwj
15
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

消息job

main
zhaokai 2026-03-05 15:24:27 +08:00
parent 5a03e3bf64
commit 127c8405dc
17 changed files with 656 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanDayJob.java Normal file
View File

@ -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<String> execute(String param) {
System.out.println("开始执行计划任务");
XxlJobHelper.log( "============每日超期消息提醒(消防点检)==========");
log.info( "============每日超期消息提醒(消防点检)==========开始");
Map<String, Object> 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;
}
}

44
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfMonthlyJob.java Normal file
View File

@ -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<String> execute(String param) {
XxlJobHelper.log( "============开始定时每半月超期未检查记录==========");
Map<String, Object> 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;
}
}

45
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanHalfYearlyJob.java Normal file
View File

@ -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<String> execute(String param) {
XxlJobHelper.log( "============开始定时增加每半年超期未检查记录==========");
Map<String, Object> 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;
}
}

44
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanMonthlyJob.java Normal file
View File

@ -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<String> execute(String param) {
XxlJobHelper.log( "============开始定时增加每月超期未检查记录==========");
Map<String, Object> 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;
}
}

44
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanQuarterlyJob.java Normal file
View File

@ -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<String> execute(String param) {
XxlJobHelper.log( "============开始定时每季度超期未检查记录==========");
Map<String, Object> 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;
}
}

42
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanTenDayJob.java Normal file
View File

@ -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<String> execute(String param) {
XxlJobHelper.log( "============开始定时增加每询超期未检查记录==========");
Map<String, Object> 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;
}
}

51
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanWeeklyJob.java Normal file
View File

@ -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<String> execute(String param) {
Map<String, Object> 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;
}
}

44
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireCheckRecordPlanYearlyJob.java Normal file
View File

@ -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<String> execute(String param) {
XxlJobHelper.log( "============开始定时每年超期未检查记录==========");
Map<String, Object> 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;
}
}

33
web-adapter/src/main/java/com/zcloud/fire/check/plan/FireDeviceOverTimeJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============消防设备到期提请(消防点检)==========开始");
XxlJobHelper.log( "============消防设备到期提请(消防点检)==========");
fireDeviceServiceI.deviceOverTimeMessage();
log.info( "============消防设备到期提请(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}

32
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckLisTenJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============待排查消息提醒(消防点检)==========开始");
XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始");
fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.TEN_DAYS.getCode());
log.info( "============待排查消息提醒(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}

32
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListDayJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============待排查消息提醒(消防点检)==========开始");
XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始");
fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.DAILY.getCode());
log.info( "============待排查消息提醒(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}

32
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfMonthlyJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============待排查消息提醒(消防点检)==========开始");
XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始");
fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.HALF_MONTH.getCode());
log.info( "============待排查消息提醒(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}

32
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListHalfYearlyJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============待排查消息提醒(消防点检)==========开始");
XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始");
fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.HALF_YEAR.getCode());
log.info( "============待排查消息提醒(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}

32
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListMonthlyJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============待排查消息提醒(消防点检)==========开始");
XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始");
fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.MONTHLY.getCode());
log.info( "============待排查消息提醒(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}

32
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListQuarterlyJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============待排查消息提醒(消防点检)==========开始");
XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始");
fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.QUARTERLY.getCode());
log.info( "============待排查消息提醒(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}

36
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListWeeklyJob.java Normal file
View File

@ -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<String> 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;
}
}

32
web-adapter/src/main/java/com/zcloud/fire/check/plan/WaitFireCheckListYearlyJob.java Normal file
View File

@ -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<String> execute(String param) {
log.info( "============待排查消息提醒(消防点检)==========开始");
XxlJobHelper.log( "============待排查消息提醒(消防点检)==========开始");
fireCheckListServiceI.waitFireCheckList(ListManagerCheckPeriodEnum.YEARLY.getCode());
log.info( "============待排查消息提醒(消防点检)==========结束");
return ReturnT.SUCCESS;
}
}