|
|
@ -1,11 +1,22 @@
|
|
|
|
package cn.estsh.i3plus.core.apiservice.schedulejob;
|
|
|
|
package cn.estsh.i3plus.core.apiservice.schedulejob;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysConfigService;
|
|
|
|
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
|
|
|
|
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskTimeService;
|
|
|
|
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.TimeTool;
|
|
|
|
|
|
|
|
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
|
|
|
|
|
|
|
|
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.base.schedule.BaseImppScheduleJob;
|
|
|
|
import cn.estsh.impp.framework.boot.init.ApplicationProperties;
|
|
|
|
import cn.estsh.impp.framework.boot.init.ApplicationProperties;
|
|
|
|
|
|
|
|
import com.netflix.discovery.converters.Auto;
|
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
|
import org.quartz.JobExecutionContext;
|
|
|
|
import org.quartz.JobExecutionContext;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import java.text.SimpleDateFormat;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* @Description : 定时任务
|
|
|
|
* @Description : 定时任务
|
|
|
@ -22,9 +33,29 @@ public class DemoJob extends BaseImppScheduleJob {
|
|
|
|
super(DemoJob.class,"定时任务demo");
|
|
|
|
super(DemoJob.class,"定时任务demo");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
|
|
|
private ISysTaskTimeService taskTimeService;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
|
|
|
private ISysMessageService sysMessageService;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
|
|
|
private ISysConfigService sysConfigService;
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public void executeImppJob(JobExecutionContext context, ApplicationProperties applicationProperties) {
|
|
|
|
public void executeImppJob(JobExecutionContext context, ApplicationProperties applicationProperties) {
|
|
|
|
System.out.println("定时任务被执行");
|
|
|
|
System.out.println("定时任务被执行");
|
|
|
|
LOGGER.info("projectName:{},port:{}",applicationProperties.getApplicationName(),applicationProperties.getServerPort());
|
|
|
|
LOGGER.info("projectName:{},port:{}",applicationProperties.getApplicationName(),applicationProperties.getServerPort());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
SysMessage sysMessage = new SysMessage();
|
|
|
|
|
|
|
|
sysMessage.setMessageTitle("定时邮件发送");
|
|
|
|
|
|
|
|
sysMessage.setMessageContent("定时邮件内容"+TimeTool.getNowTime(true));
|
|
|
|
|
|
|
|
sysMessage.setMessageType(ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue());
|
|
|
|
|
|
|
|
sysMessage.setMessageContentType(ImppEnumUtil.MESSAGE_TYPE_CONTENT.HTML.getValue());
|
|
|
|
|
|
|
|
sysMessage.setMessageReceiversId(PlatformConstWords.CONTACT_MAIL);
|
|
|
|
|
|
|
|
sysMessage.setMessageReceiversNameRdd(PlatformConstWords.CONTACT_MAIL);
|
|
|
|
|
|
|
|
sysMessageService.doSendSysMessage(sysMessage);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
taskTimeService.doSysTaskTimeLastDateByNameAndGroupName(TimeTool.getNowTime(true),
|
|
|
|
|
|
|
|
context.getJobDetail().getKey().getName(),
|
|
|
|
|
|
|
|
context.getJobDetail().getKey().getGroup());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|