hst预测定时器启用多线程请求

guoshilong

2024-03-12 b7c3fc85eba070a5c6625bc680ae9993d5553fae

 skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/NkyXxlJob.java

@@ -1,15 +1,13 @@
package cn.gistack.job.executor.jobhandler;

import cn.gistack.job.executor.thread.MyThread;
import cn.gistack.nky.fegin.INkyClient;
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.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * 南科院预测数据定时器
@@ -21,19 +19,20 @@
   private static final String SY = "1";
   private static final String SL = "2";
   private static final String X = "3";
   private static final String Y= "4";
   private static final String Y = "4";
   private static final String Z = "5";

   private final INkyClient nkyClient;

   /**
    * 南科院Arima请求预测
    *
    * @param param
    * @return
    * @throws Exception
    */
   @XxlJob("predictNkyDataJobHandler")
   public ReturnT<String> predictNkyDataJobHandler(String param){
   public ReturnT<String> predictNkyDataJobHandler(String param) {
      XxlJobLogger.log("开始ArimaPredict预测...");
      arimaPredict();
      XxlJobLogger.log("ArimaPredict预测结束...");
@@ -44,12 +43,13 @@

   /**
    * 南科院Hst请求预测
    *
    * @param param
    * @return
    * @throws Exception
    */
   @XxlJob("predictNkyHstDataJobHandler")
   public ReturnT<String> predictNkyHstDataJobHandler(String param){
   public ReturnT<String> predictNkyHstDataJobHandler(String param) {

      XxlJobLogger.log("开始Hst预测...");
      hstPredict();
@@ -60,12 +60,13 @@

   /**
    * 南科院Hst请求预测结果
    *
    * @param param
    * @return
    * @throws Exception
    */
   @XxlJob("queryNkyHstDataJobHandler")
   public ReturnT<String> queryNkyHstDataJobHandler(String param){
   public ReturnT<String> queryNkyHstDataJobHandler(String param) {
      XxlJobLogger.log("开始Hst预测结果请求");
      hstQuery();
      XxlJobLogger.log("Hst预测结果请求结束");
@@ -75,49 +76,52 @@

   /**
    * 南科院Arima请求预测结果(渗压)
    *
    * @param param
    * @return
    * @throws Exception
    */
   @XxlJob("queryNkyDataJobHandler")
   public ReturnT<String> queryNkyDataJobHandler(String param){
      XxlJobLogger.log("开始预测时间："+DateUtil.now().toString());
   public ReturnT<String> queryNkyDataJobHandler(String param) {
      XxlJobLogger.log("开始预测时间：" + DateUtil.now().toString());
      nkyClient.arimaQueryData(SY);
      XxlJobLogger.log("预测结束时间：" +DateUtil.now().toString());
      XxlJobLogger.log("预测结束时间：" + DateUtil.now().toString());
      return ReturnT.SUCCESS;
   }

   /**
    * 南科院Arima请求预测结果(渗流)
    *
    * @param param
    * @return
    * @throws Exception
    */
   @XxlJob("queryNkyDataSlJobHandler")
   public ReturnT<String> queryNkyDataSlJobHandler(String param){
      XxlJobLogger.log("开始预测时间："+DateUtil.now().toString());
   public ReturnT<String> queryNkyDataSlJobHandler(String param) {
      XxlJobLogger.log("开始预测时间：" + DateUtil.now().toString());
      nkyClient.arimaQueryData(SL);
      XxlJobLogger.log("预测结束时间：" +DateUtil.now().toString());
      XxlJobLogger.log("预测结束时间：" + DateUtil.now().toString());
      return ReturnT.SUCCESS;
   }

   /**
    * 南科院Arima请求预测结果(位移)
    *
    * @param param
    * @return
    * @throws Exception
    */
   @XxlJob("queryNkyDataWyJobHandler")
   public ReturnT<String> queryNkyDataWyJobHandler(String param){
      XxlJobLogger.log("开始预测时间："+DateUtil.now().toString());
   public ReturnT<String> queryNkyDataWyJobHandler(String param) {
      XxlJobLogger.log("开始预测时间：" + DateUtil.now().toString());
      nkyClient.arimaQueryData(X);
      nkyClient.arimaQueryData(Y);
      nkyClient.arimaQueryData(Z);
      XxlJobLogger.log("预测结束时间：" +DateUtil.now().toString());
      XxlJobLogger.log("预测结束时间：" + DateUtil.now().toString());
      return ReturnT.SUCCESS;
   }

   public void arimaPredict(){
   public void arimaPredict() {
      XxlJobLogger.log("渗压预测开始");
      nkyClient.arimaPredictData(SY);
      XxlJobLogger.log("渗流预测开始");
@@ -127,7 +131,7 @@

   }

   public void arimaQuery(){
   public void arimaQuery() {
      nkyClient.arimaQueryData(SY);
      nkyClient.arimaQueryData(SL);
      nkyClient.arimaQueryData(X);
@@ -138,33 +142,50 @@
   /**
    * hst预测
    */
   public void hstPredict(){
      XxlJobLogger.log("渗压预测开始");
      nkyClient.hstPredictData(SY);
      XxlJobLogger.log("渗流预测开始");
      nkyClient.hstPredictData(SL);
      XxlJobLogger.log("位移预测开始");
      nkyClient.hstPredictData(X);
   public void hstPredict() {

      try {
         MyThread sl = new MyThread(nkyClient,SL);
         MyThread wy = new MyThread(nkyClient,X);
         MyThread sy = new MyThread(nkyClient,SY);

         sl.start();
         wy.start();
         sy.start();
      } catch (Exception e) {
         e.printStackTrace();
      }

//      XxlJobLogger.log("渗流预测开始");
//      nkyClient.hstPredictData(SL);
//      XxlJobLogger.log("位移预测开始");
//      nkyClient.hstPredictData(X);
//      XxlJobLogger.log("渗压预测开始");
//      nkyClient.hstPredictData(SY);


   }

   public void hstQuery(){
      nkyClient.hstQueryData(SY);
   public void hstQuery() {
      nkyClient.hstQueryData(SL);
      nkyClient.hstQueryData(X);
      nkyClient.hstQueryData(Y);
      nkyClient.hstQueryData(Z);
      nkyClient.hstQueryData(SY);
   }

   /**
    * 南科院按库请求数据接口
    *
    * @param param
    * @return
    */
   @XxlJob("batchDataJobHandler")
   public ReturnT<String> batchDataJobHandler(String param){
   public ReturnT<String> batchDataJobHandler(String param) {
      XxlJobLogger.log("按库请求开始");

      nkyClient.batchData(SY);
      nkyClient.batchData(SL);
      nkyClient.batchData(X);
      nkyClient.batchData(Y);
      nkyClient.batchData(Z);
@@ -176,11 +197,12 @@

   /**
    * 南科院按库请求数据接口
    *
    * @param param
    * @return
    */
   @XxlJob("alarmGetJobHandler")
   public ReturnT<String> alarmGetJobHandler(String param){
   public ReturnT<String> alarmGetJobHandler(String param) {
      XxlJobLogger.log("判定异常开始");

      nkyClient.alarmGetData(SY);