预测更新

guoshilong

2023-08-16 ab3c03a41b870e7939a3f9c35b469564157dc9c3

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

@@ -1,5 +1,6 @@
package cn.gistack.nky.service.impl;

import cn.gistack.common.utils.CommonUtil;
import cn.gistack.nky.entity.ArimaPredict;
import cn.gistack.nky.mapper.ArimaPredictMapper;
import cn.gistack.nky.requestpojo.ArimaPredictReqPo;
@@ -12,11 +13,14 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.tool.utils.ObjectUtil;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

@Service
@AllArgsConstructor
@@ -111,6 +115,28 @@
      }else {
         return null;
      }
      return cdList;
      List<DataResChildrenPo> filterList = filterTimeList(cdList, 24);
      return filterList;
   }

   /**
    * 筛选时间内的集合
    * @param sourceList
    * @param timeGap
    * @return
    */
   public List<DataResChildrenPo> filterTimeList(List<DataResChildrenPo> sourceList,Integer timeGap){
      //当前时间的时间戳
      Long todayTimeStamp = DateUtil.now().getTime();

      //过去时间的时间戳
      Long beforeTimeStamp = todayTimeStamp - 1000*60*60*timeGap;

      //过去时间的日期
      Date beforeDate = new Date(beforeTimeStamp);

      List<DataResChildrenPo> collect = sourceList.stream().filter(item -> CommonUtil.strToDate(item.getTm()).after(beforeDate)).collect(Collectors.toList());

      return collect;
   }
}