From bd8b398d7bb4b5691a0c52e2641f710eca90bf25 Mon Sep 17 00:00:00 2001
From: zrj <646384940@qq.com>
Date: Tue, 30 Jul 2024 15:48:22 +0800
Subject: [PATCH] 新增南科院预警接口，新增南科院实时测点输入及回调，新增定时任务实时测点输入
---
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/NkyXxlJob.java | 24 ++++++++++++++++++++++++
1 files changed, 24 insertions(+), 0 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 9ae441a..01c8498 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
@@ -15,6 +15,8 @@
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
/**
* 南科院预测数据定时器
@@ -241,6 +243,28 @@
return ReturnT.SUCCESS;
}
+ /**
+ * 南科院 实时测点测值输入
+ * @param param
+ * @return
+ */
+ @XxlJob("pointValueInletHandler")
+ public ReturnT<String> pointValueInletHandler(String param) {
+ XxlJobLogger.log("实时测点测值输入开始");
+ // 创建外呼任务
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ nkyClient.pointValueInlet(SY);
+ nkyClient.pointValueInlet(SL);
+ nkyClient.pointValueInlet(X);
+ nkyClient.pointValueInlet(Y);
+ nkyClient.pointValueInlet(Z);
+ });
+ XxlJobLogger.log("实时测点测值输入结束");
+ return ReturnT.SUCCESS;
+ }
+
}
--
Gitblit v1.9.3