Spring boot基于ScheduledFuture如何實(shí)現(xiàn)定時(shí)任務(wù)

@Entity
@Table(name="monitor_warn_item")
public class MonitorWarnItem {
 @Id
 private String id;
 private String proName;//名稱(chēng)
 private String rule;
 private String send_content;
 private String recommend_value;// 建議值
 private String standard_value; // 標(biāo)準(zhǔn)值
 private Integer fre_num;
 private String frequency;
 private String status;
 private String warnType;
 private String warn_date_num;// 監(jiān)測(cè)頻次
 
//此處省略get、set…
}
 
@Entity
@Table(name="qt_interface_parameter")
public class QtInterfaceParameter {
 @Id
 private String id;
 @Column(name="inter_id")
 private String interId;
 private String name; //參數(shù)名稱(chēng)
 private String explain_info; //參數(shù)描述
 private String type;// 輸入輸出類(lèi)型
 private String paraType; // 參數(shù)類(lèi)型
 private Integer paraLen;
private Integer paraValue; // 參數(shù)值
private Integer order_num; // 排序字段
 
//此處省略get、set…
}

public interface TestService {
  ResultInfo initMonitor(String Id);<br>　　// 省略之前的...
}

@Service
public class TestServiceImpl implements TestService {
 @Autowired
 private MonitorWarnItemRepository monitorWarnItemRepository
 @Autowired
 private ThreadPoolTaskScheduler threadPoolTaskScheduler;
 @Bean
 public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
  return new ThreadPoolTaskScheduler();
 }
List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>(); // 新建任務(wù)信息集合
/**
 * 初始化監(jiān)測(cè)項(xiàng)
 *
 * @param Id
 * @return
 */
@Override
@Transactional
public ResultInfo initMonitor(String Id) {
  ResultInfo info = new ResultInfo();
  String msg = "";
  MonitorWarnItem item = monitorWarnItemRepository.findId(Id);
  msg =buildTask(item);
info.setResult(1);
info.setMsg("初始化成功，初始化返回信息：" + msg);
System.out.println(msg);// 日志打印
return info;
 
}
/**
 * 配置任務(wù)信息
 *
 * @param qt
 * @return
 */
private String buildTask(MonitorWarnItem qt) {
  String msg = "";
  if (IsFure(qt.getId())) {
    List<QtInterface> InterList = qtInterfaceRepository.QueryInterFaceByItemId(qt.getId());
    if (InterList.size() > 0) {
 
      Map<String, Object> map_future = new HashMap<>();
 
      ScheduledFuture<&#63;> future;// 監(jiān)測(cè)任務(wù)
      List<QtInterfaceParameter> para = qtInterfaceParameterRepository.QueryInfoByInterId(InterList.get(0).getId()); // 查找參數(shù)信息
      List<String> map = new ArrayList<>(para.size());
      if (para.size() > 0) { // 參數(shù)集合
        for (QtInterfaceParameter pa : para) {
          for (int item = 1; item <= para.size(); item++) {
            if (item == pa.getOrder_num()) { // 根據(jù)字段排序來(lái)設(shè)置參數(shù)值的順序
              map.add(pa.getPara_value()); // 設(shè)置值
              item++;
            }
          }
        }
      }
      QuartzTaskService service = new QuartzTaskService(InterList.get(0).getName(), map, jdbcTemplate, qt);
      if (!"".equals(qt.getWarn_date_num()) && qt.getWarn_date_num() != null) {
        future = threadPoolTaskScheduler.schedule(service, new CronTrigger(qt.getWarn_date_num()));// 初始化任務(wù)，第二個(gè)參數(shù)是Cron表達(dá)式
        if (future != null) {
          map_future.put("future", future);
          map_future.put("id", InterList.get(0).getItemId());
          map_future.put("status", "0");
           mapList.add(map_future);
        }
      } else {
        msg += " 監(jiān)測(cè)項(xiàng):" + qt.getProName() + " 監(jiān)測(cè)頻次字段為空，不能執(zhí)行計(jì)劃！";
      }
 
    } else {
      msg += " 監(jiān)測(cè)項(xiàng):" + qt.getProName() + " 沒(méi)有查找到接口配置信息";
 
    }
  } else {
    msg += " 監(jiān)測(cè)項(xiàng):" + qt.getProName() + " 已經(jīng)啟動(dòng)，請(qǐng)不要重復(fù)啟動(dòng)。";
  }
  return msg;
}
}

public class QuartzTaskService implements Runnable {
 
  private JdbcTemplate jdbcTemplate;
  private String proName;
  private List<String> maplist;
  private MonitorWarnItem item;
  public QuartzTaskService(String proName,List<String> maplist,JdbcTemplate jdbcTemplate ,MonitorWarnItem item){
    this.proName=proName;
    this.maplist=maplist;
    this.jdbcTemplate=jdbcTemplate;
    this.item=item;
  }
 
  protected void executeInternal() throws JobExecutionException {
    SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    StringBuffer bf=new StringBuffer();
    bf.append("call ");
    bf.append(proName);
    bf.append("(");
    int i=1;
    for(String map:maplist){
      if(i==maplist.size()){ // 最后一位
        bf.append("'"+map+"')");
      }else {
        bf.append("'" + map + "',");
      }
     i++;
    }
    jdbcTemplate.batchUpdate(bf.toString());
 
    System.out.println("執(zhí)行了過(guò)程：" +proName+"當(dāng)前參數(shù)順序："+bf.toString()+ " 當(dāng)前時(shí)間 "+ sdf.format(new Date()));
  }
  @Override
  public void run() {
    try {
      executeInternal(); // 調(diào)用執(zhí)行
    } catch (JobExecutionException e) {
      e.printStackTrace();
    }
  }

@Component
@Order(1)
public class StartTask implements CommandLineRunner {
  @Autowired
  private TestService testService;
 
  public String setTask(){
    Calendar cale = null;
    cale = Calendar.getInstance();
    int year = cale.get(Calendar.YEAR);
    MonitorWarnItem itemList=testService.QueryByStatus ("1");// 根據(jù)狀態(tài)查詢(xún)需要啟動(dòng)的監(jiān)測(cè)項(xiàng)
    if(itemList.size()>0){ // 存在需要啟動(dòng)的檢測(cè)項(xiàng)
For(MonitorWarnItem qt: itemList)
      testService.initMonitor(qt);// 啟動(dòng)任務(wù)列表和消息
    }
    return "";
  }
 
  @Override
  public void run(String... args) throws Exception {
    setTask ();
  }
}

public class ResultInfo<T> {
  private Integer result;
  private String msg;
  private T rows;
  private int total;
//省略其他處理
}