预测更新

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;
    }
}

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

@@ -121,7 +121,11 @@

        List<HstPredict> list = baseMapper.getFutureData(resCd,type);
        list.forEach(hstPredict -> {
            hstPredict.setPredictList(JSON.parse(hstPredict.getPredictList().toString()));
            if (hstPredict.getPredictList() != null){
                hstPredict.setPredictList(JSON.parse(hstPredict.getPredictList().toString()));
            }else {
                hstPredict.setPredictList("[]");
            }
            hstPredict.setPreWaterList(JSON.parse(hstPredict.getPreWaterList().toString()));
        });

@@ -139,8 +143,9 @@

        if (list.size()>0){
            //删除该数据，添加最新数据
            baseMapper.deleteById(list.get(0));
            return super.save(entity);
//            baseMapper.deleteById(list.get(0));
//            return super.save(entity);
                return false;
        }else {
            return super.save(entity);
        }