| | |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.List; |
| | | import java.util.concurrent.ExecutorService; |
| | | import java.util.concurrent.Executors; |
| | | |
| | | /** |
| | | * 南科院预测数据定时器 |
| | |
| | | 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; |
| | | } |
| | | |
| | | |
| | | |
| | | } |