| | |
| | | }); |
| | | }else if (type.equals("2")){ |
| | | //渗流 |
| | | collect.forEach(dataResChildrenPo -> { |
| | | //所有水库请求预报数据 |
| | | if (!resCd.equals(dataResChildrenPo.getRes_cd())) { |
| | | //请求预报水位 |
| | | List<List<String>> future = hsybService.getFuture(dataResChildrenPo.getRes_cd()); |
| | | resCd = dataResChildrenPo.getRes_cd(); |
| | | if (future != null && future.size() > 0) { |
| | | List<PredictWatersPo> po = new ArrayList<>(); |
| | | future.forEach(item -> { |
| | | PredictWatersPo predictWatersPo = new PredictWatersPo(); |
| | | //设置时间 |
| | | predictWatersPo.setTime(item.get(0)); |
| | | //设置预测水位 |
| | | predictWatersPo.setValue(Double.parseDouble(item.get(2))); |
| | | po.add(predictWatersPo); |
| | | }); |
| | | HstPredictReqPo arimaPredictReqPo = new HstPredictReqPo(dataResChildrenPo, type,po); |
| | | //循环预测请求 |
| | | nkyService.hstPredict(arimaPredictReqPo); |
| | | } |
| | | } |
| | | }); |
| | | |
| | | |
| | | |
| | | }else if (type.equals("3") || type.equals("4") || type.equals("5")){ |
| | | collect.forEach(dataResChildrenPo -> { |
| | | //所有水库请求预报数据 |
| | |
| | | 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(); |