From b7c3fc85eba070a5c6625bc680ae9993d5553fae Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Tue, 12 Mar 2024 16:25:56 +0800
Subject: [PATCH] hst预测定时器启用多线程请求
---
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/NkyXxlJob.java | 80 +++++++++++++++++++++++++--------------
1 files changed, 51 insertions(+), 29 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/NkyXxlJob.java b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/NkyXxlJob.java
index 8e88183..8a96fb2 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/NkyXxlJob.java
+++ b/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);
--
Gitblit v1.9.3