|
@ -0,0 +1,48 @@
|
|
|
|
package com.yihu.jw.care.job.visit;
|
|
|
|
|
|
|
|
import com.yihu.jw.care.job.consult.FinishConsultJob;
|
|
|
|
import com.yihu.jw.entity.care.doorCoach.BaseDoorCoachOrderDO;
|
|
|
|
import com.yihu.jw.entity.care.lifeCare.LifeCareOrderDO;
|
|
|
|
import com.yihu.jw.entity.care.visit.BaseVisitDO;
|
|
|
|
import com.yihu.jw.entity.order.BusinessOrderDO;
|
|
|
|
import com.yihu.jw.util.date.DateUtil;
|
|
|
|
import org.quartz.DisallowConcurrentExecution;
|
|
|
|
import org.quartz.Job;
|
|
|
|
import org.quartz.JobExecutionContext;
|
|
|
|
import org.quartz.JobExecutionException;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
import java.util.Date;
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 每5分钟执行一次 过期超时的日常走访
|
|
|
|
* Created by yeshijie on 2021/11/15.
|
|
|
|
*/
|
|
|
|
@DisallowConcurrentExecution//解决执行频率和间隔时间的问题。到了执行时间点前一任务还在执行中,不会执行下一次任务,直至该次任务完成
|
|
|
|
public class OverTimeVistJob implements Job {
|
|
|
|
private static Logger logger = LoggerFactory.getLogger(OverTimeVistJob.class);
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private JdbcTemplate jdbcTemplate;
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
|
|
|
Long nowTime = System.currentTimeMillis();
|
|
|
|
logger.info("OverTimeVistJob start 过期超时的日常走访JOb开始----截至支付时间:"+nowTime);
|
|
|
|
try {
|
|
|
|
String now = DateUtil.getStringDate();
|
|
|
|
String sql = "update base_visit set status ='2' WHERE `status` = 0 and visit_plan_date<='"+now+"'";
|
|
|
|
jdbcTemplate.execute(sql);
|
|
|
|
}catch (Exception e){
|
|
|
|
e.printStackTrace();
|
|
|
|
}
|
|
|
|
|
|
|
|
logger.info("OverTimeVistJob end 过期超时的日常走访JOb结束----");
|
|
|
|
}
|
|
|
|
}
|