guoshilong
2024-04-28 90cc59400715f3ece6384eddf01cefd8eff449ea
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/NkyXxlJob.java
@@ -2,12 +2,19 @@
import cn.gistack.job.executor.thread.MyThread;
import cn.gistack.nky.fegin.INkyClient;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import lombok.AllArgsConstructor;
import org.springblade.core.tool.utils.DateUtil;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
/**
 * 南科院预测数据定时器
@@ -212,4 +219,28 @@
      return ReturnT.SUCCESS;
   }
   @XxlJob("initAlgorithmHandler")
   public ReturnT<String> initAlgorithmHandler(String param) {
      XxlJobLogger.log("定时器执行时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(DateUtil.now()));
      JSONObject jsonParam = JSON.parseObject(param);
      List<String> resList = new ArrayList<>();
      if (jsonParam != null){
         String resGuids = jsonParam.getString("resGuids");
         resList = Arrays.asList(resGuids.split(","));
      }
      nkyClient.initAlgorithm(resList);
      XxlJobLogger.log("定时器执行结束时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(DateUtil.now()));
      return ReturnT.SUCCESS;
   }
}