content: package com.qihoo.finance.chronus.modules.job;
  
  import com.qihoo.finance.chronus.sdk.domain.JobData;
  import com.qihoo.finance.chronus.sdk.domain.TaskItemDefineDomain;
  import com.qihoo.finance.chronus.sdk.service.ChronusSdkSimpleJob;
  import org.apache.commons.lang3.StringUtils;
  import org.apache.logging.log4j.LogManager;
  import org.apache.logging.log4j.Logger;
  import org.springframework.stereotype.Service;
  
  import java.time.LocalDateTime;
  import java.util.List;
  
  /**
   * Created by xiongpu on 2019/11/15.
   */
  @Service("executeBean")
  public class ExecuteBean implements ChronusSdkSimpleJob {
      private static final Logger logger = LogManager.getLogger(ExecuteBean.class);
  
      @Override
      public boolean execute(JobData jobData) throws Exception {
          System.out.println(jobData.getTaskParameter());
          if (StringUtils.isNotBlank(jobData.getTaskParameter())) {
              Thread.sleep(Long.valueOf(jobData.getTaskParameter().trim()));
          }
          logger.info("结束处理 item:{}，当前时间:{}", jobData.getTaskParameter(), LocalDateTime.now());
          return true;
      }
  }
  