Merge branch 'jtdev' of https://hbsl-code.gistack.cn/hbwri/manager into jtdev

zhongrj

2023-08-07 50bc6ee76ffcebc0b539e0fb5698a3911e5f6c02

 skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ArimaPredictServiceImpl.java

@@ -3,6 +3,8 @@
import cn.gistack.nky.entity.ArimaPredict;
import cn.gistack.nky.mapper.ArimaPredictMapper;
import cn.gistack.nky.requestpojo.ArimaPredictReqPo;
import cn.gistack.nky.requestpojo.HstPredictReqPo;
import cn.gistack.nky.requestpojo.PredictWatersPo;
import cn.gistack.nky.requestpojo.QueryReqPo;
import cn.gistack.nky.resultpojo.DataResChildrenPo;
import cn.gistack.nky.service.IArimaPredictService;
@@ -42,11 +44,31 @@
   @Override
   public void predictData(String type) {
      List<DataResChildrenPo> cdList = getCdList(type);
      cdList.forEach(dataResChildrenPo -> {
         ArimaPredictReqPo arimaPredictReqPo = new ArimaPredictReqPo(dataResChildrenPo, type);
         //循环预测请求
         nkyService.arimaPredict(arimaPredictReqPo);
      });

      if (type.equals("1")){
         //渗压
            cdList.forEach(dataResChildrenPo -> {
               ArimaPredictReqPo arimaPredictReqPo = new ArimaPredictReqPo(dataResChildrenPo, type);
               //循环预测请求
               nkyService.arimaPredict(arimaPredictReqPo);
            });
      }else if (type.equals("2")){
         //渗流
      }else if (type.equals("3") || type.equals("4") || type.equals("5")){
         cdList.forEach(dataResChildrenPo -> {
            //循环预测请求
            ArimaPredictReqPo arimaPredictReqPoX = new ArimaPredictReqPo(dataResChildrenPo, "3");
            nkyService.arimaPredict(arimaPredictReqPoX);

            ArimaPredictReqPo arimaPredictReqPoY = new ArimaPredictReqPo(dataResChildrenPo, "4");
            nkyService.arimaPredict(arimaPredictReqPoY);

            ArimaPredictReqPo arimaPredictReqPoZ = new ArimaPredictReqPo(dataResChildrenPo, "5");
            nkyService.arimaPredict(arimaPredictReqPoZ);
         });
      }


   }

   @Override