|
楼主 |
发表于 2019-6-24 13:42:56
|
显示全部楼层
- @Slf4j
- public class TenancyInfoJob implements Job {
- @Autowired
- private IAmTenancyInfoService iAmTenancyInfoService;
- /**
- * 若参数变量名修改 QuartzJobController中也需对应修改
- */
- private String parameter;
- public void setParameter(String parameter) {
- this.parameter = parameter;
- }
- @Override
- public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
- // 使得job对象可以通过注解实现依赖注入
- SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
- //查询是否有数据到期
- List<AmTenancyInfo> amTenancyInfos = new ArrayList<AmTenancyInfo>();
- System.out.println("执行定时任务==========TenancyInfoJob=========");
- amTenancyInfos = iAmTenancyInfoService.hasDueData(this.parameter);
- if(amTenancyInfos.size()>0){
- //有需要提醒推送的数据,保存
- amTenancyInfos.forEach(amTenant -> {
- log.info(amTenant.toString());
- //将信息保存到sys_qutz_msg记录表中
- });
- }else{
- //没有需要推送的消息
- }
- log.info(String.format("welcome %s! Jeecg-Boot 带参数定时任务 TenancyInfoJob ! 时间:" + DateUtils.now(), this.parameter));
- }
- }
复制代码 这是我按照jeecg框架里写的一个job,但是通过接口添加quartz任务后,只有添加后执行了一次job,之后就不执行了,请问是还需要修改或者添加什么吗? |
|