|
|
|
@ -3,9 +3,12 @@ package cn.estsh.i3plus.core.apiservice.schedulejob;
|
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
|
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.TimeTool;
|
|
|
|
|
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
|
|
|
|
|
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
|
|
|
|
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
|
|
|
|
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
|
|
|
|
|
import cn.estsh.impp.framework.base.schedule.BaseImppScheduleJob;
|
|
|
|
|
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
|
|
|
|
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
|
|
|
|
|
import cn.estsh.impp.framework.boot.init.ApplicationProperties;
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
|
@ -34,6 +37,14 @@ public class DemoJob extends BaseImppScheduleJob {
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void executeImppJob(JobExecutionContext context, ApplicationProperties applicationProperties) {
|
|
|
|
|
if(getJobParam() != null && "error".equals(getJobParam())){
|
|
|
|
|
throw ImppExceptionBuilder.newInstance()
|
|
|
|
|
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
|
|
|
|
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
|
|
|
|
|
.setErrorDetail("定时任务异常测试!")
|
|
|
|
|
.setErrorSolution("请检查异常通知邮件")
|
|
|
|
|
.build();
|
|
|
|
|
}
|
|
|
|
|
System.out.println("定时任务被执行");
|
|
|
|
|
LOGGER.info("projectName:{},port:{}",applicationProperties.getApplicationName(),applicationProperties.getServerPort());
|
|
|
|
|
|
|
|
|
|