From 2f8eaa7c850445fde0cdca0e8ecddcb7e2a936a3 Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Tue, 05 Mar 2024 16:01:35 +0800
Subject: [PATCH] 洪水预报接口对接
---
skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ArimaPredictServiceImpl.java | 19 ++++++++++++++++---
1 files changed, 16 insertions(+), 3 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ArimaPredictServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ArimaPredictServiceImpl.java
index 7f4868b..d79431d 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ArimaPredictServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ArimaPredictServiceImpl.java
@@ -9,6 +9,7 @@
import cn.gistack.nky.service.IArimaPredictService;
import cn.gistack.nky.service.INkyService;
import cn.gistack.nky.service.IZtApiService;
+import cn.gistack.nky.vo.ArimaPredictVO;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
@@ -56,6 +57,11 @@
});
}else if (type.equals("2")){
//渗流
+ cdList.forEach(dataResChildrenPo -> {
+ ArimaPredictReqPo arimaPredictReqPo = new ArimaPredictReqPo(dataResChildrenPo, type);
+ //循环预测请求
+ nkyService.arimaPredict(arimaPredictReqPo);
+ });
}else if (type.equals("3") || type.equals("4") || type.equals("5")){
cdList.forEach(dataResChildrenPo -> {
//循环预测请求
@@ -74,8 +80,15 @@
}
@Override
- public List<ArimaPredict> getFutureData(String resCd,String type) {
- List<ArimaPredict> futureData = baseMapper.getFutureData(resCd, type);
+ public List<ArimaPredictVO> getFutureData(String resCd, String type) {
+ List<ArimaPredictVO> futureData = new ArrayList<>();
+ if (type.equals("3")){
+ //位移另一张表
+ futureData=baseMapper.getFutureDataWy(resCd,type);
+ }else{
+ futureData = baseMapper.getFutureData(resCd, type);
+ }
+
futureData.forEach(arimaPredict -> {
arimaPredict.setPredicts(JSON.parse(arimaPredict.getPredicts().toString()));
});
@@ -108,7 +121,7 @@
cdList = ztApiService.getSy();
}else if (type.equals("2")){
//获取渗流测点
- return null;
+ cdList = ztApiService.getSl();
}else if (type.equals("3") || type.equals("4") || type.equals("5")){
//获取位移测点
cdList = ztApiService.getWy();
--
Gitblit v1.9.3