sis/realtime/generationXK-service/src/main/java/com/gyee/generation/service/EquipmentInfo5Service.java

package com.gyee.generation.service;//package com.gyee.generation.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.gyee.common.contant.ContantXk;
import com.gyee.common.model.PointData;
import com.gyee.generation.init.CacheContext;
import com.gyee.generation.model.auto.*;
import com.gyee.generation.service.auto.*;
import com.gyee.generation.util.DateUtils;
import com.gyee.generation.util.StringUtils;
import com.gyee.generation.util.realtimesource.IEdosUtil;
import com.gyee.generation.util.statisticcs.Initial;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
import java.util.stream.Collectors;

@Service
public class EquipmentInfo5Service {

//    private static final Logger logger = LoggerFactory.getLogger(EquipmentInfo5Service.class);
    @Resource
    private IEdosUtil edosUtil;

    @Resource
    private IProEconShutdownEvent2Service proEconShutdownEvent2Service;
    //状态转换率
    @Resource
    private IProEconEquipmentInfoDay5Service proEconEquipmentInfoDay5Service;

    @Resource
    private IProEconStateTranRatesSubService proEconStateTranRatesSubService;

    @Resource
    private IProEconStateTranRatesSub2Service proEconStateTranRatesSub2Service;

    @Resource
    private IProEconFaultLiminatedefectsService proEconFaultLiminatedefectsService;
    @Resource
    private IProEconShutdownEventService proEconShutdownEventService;

    /**
     * 复位及时率
     */
    public void resetRate(Date currentDate) {
        //调度时间是第二天，currentDate 是第一天
        Date endDate = DateUtils.addDays(currentDate, 1);


        List<ProEconShutdownEvent2> shutdownevents = proEconShutdownEvent2Service.list().stream().filter(i ->
                i.getWinpowerstationId().contains("FDC")
                        && (i.getStopTime().compareTo(currentDate) == 0 || i.getStopTime().after(currentDate))
                        && (i.getStopTime().compareTo(endDate) == 0 || i.getStopTime().before(endDate))
                        && !i.getStopTypeId().equals("wh")
        ).collect(Collectors.toList());


        Map<String, ProEconEquipmentInfoDay5> rates = new HashMap<>();

        for (ProBasicEquipment wt : CacheContext.wtls) {
            ProEconEquipmentInfoDay5 rate = new ProEconEquipmentInfoDay5();
            rate.setRecordDate(currentDate);
            rate.setWindpowerstationId(wt.getWindpowerstationId());
            rate.setProjectId(wt.getProjectId());
            rate.setLineId(wt.getLineId());
            rate.setWindturbineId(wt.getId());
            Initial.initial(rate);
            rates.put(wt.getId(), rate);
        }

        for (ProEconShutdownEvent2 item : shutdownevents) {
            if (rates.containsKey(item.getWindturbineId())) {
                if (item.getStopHours() <= 1) {
                    double temp = rates.get(item.getWindturbineId()).getTimerate20();
                    temp = temp + 1;
                    rates.get(item.getWindturbineId()).setTimerate20(temp);


                    if (item.getStopHours() <= 0.08) {
                        temp = rates.get(item.getWindturbineId()).getTimerate16();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate16(temp);

                        temp = rates.get(item.getWindturbineId()).getTimerate17();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate17(temp);

                        temp = rates.get(item.getWindturbineId()).getTimerate18();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate18(temp);

                        temp = rates.get(item.getWindturbineId()).getTimerate19();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate19(temp);
                        item.setResetRate("5");

                    } else if (item.getStopHours() <= 0.17) {
                        temp = rates.get(item.getWindturbineId()).getTimerate17();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate17(temp);

                        temp = rates.get(item.getWindturbineId()).getTimerate18();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate18(temp);

                        temp = rates.get(item.getWindturbineId()).getTimerate19();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate19(temp);
                        item.setResetRate("10");
                    } else if (item.getStopHours() <= 0.25) {
                        temp = rates.get(item.getWindturbineId()).getTimerate18();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate18(temp);

                        temp = rates.get(item.getWindturbineId()).getTimerate19();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate19(temp);
                        item.setResetRate("15");
                    } else if (item.getStopHours() <= 0.33) {
                        temp = rates.get(item.getWindturbineId()).getTimerate19();
                        temp = temp + 1;
                        rates.get(item.getWindturbineId()).setTimerate19(temp);
                        item.setResetRate("20");
                    } else if (item.getResetRate() == null) {
                        item.setResetRate("99");

                    } else {
                        item.setResetRate(null);
                    }
                }
            }

            for (ProEconEquipmentInfoDay5 day : rates.values()) {

                Optional<ProEconEquipmentInfoDay5> dayInfoo = proEconEquipmentInfoDay5Service.list().stream().filter(i -> i.getWindturbineId().equals(day.getWindturbineId())
                        && i.getRecordDate().compareTo(currentDate) == 0
                ).findFirst();

                ProEconEquipmentInfoDay5 dayInfo ;
                if (dayInfoo.isPresent()) {

                    dayInfo = dayInfoo.get();
                    buildresetRate(dayInfo, day);
                    QueryWrapper<ProEconEquipmentInfoDay5> wrapper = new QueryWrapper<>();
                    wrapper.eq("id", dayInfo.getId());
                    proEconEquipmentInfoDay5Service.remove(wrapper);


                }else
                {
                    dayInfo = new ProEconEquipmentInfoDay5();
                    buildresetRate(dayInfo, day);
                }




                proEconEquipmentInfoDay5Service.save(dayInfo);
            }


        }
    }

    public void buildresetRate(ProEconEquipmentInfoDay5 dayInfo, ProEconEquipmentInfoDay5 day) {

        dayInfo.setRecordDate(day.getRecordDate());
        dayInfo.setWindpowerstationId(day.getWindpowerstationId());
        dayInfo.setProjectId(day.getProjectId());
        dayInfo.setLineId(day.getLineId());
        dayInfo.setWindturbineId(day.getWindturbineId());
        dayInfo.setTimerate16(day.getTimerate16());
        dayInfo.setTimerate17(day.getTimerate17());
        dayInfo.setTimerate18(day.getTimerate18());
        dayInfo.setTimerate19(day.getTimerate19());
        dayInfo.setTimerate20(day.getTimerate20());

    }

    /**
     * 状态转换及时率
     */
    Double interval = 0.33; //20分钟
    Map<Double, Double> stateDescription1 = new HashMap<>();
    Map<Double, Double> stateDescription2 = new HashMap<>();

    Double interval1 = 0.0;
    Double interval2 = 0.0;
    Double interval3 = 0.0;

    public void stateRate(Date currentDate) throws Exception {



        if (stateDescription1.size() == 0) {
            stateDescription1.put(3.0, 6.0);
            stateDescription1.put(3.5, 0.0);
            stateDescription1.put(4.0, 0.0);
        }
        if (stateDescription2.size() == 0) {
            stateDescription2.put(3.0, 6.0);
            stateDescription2.put(3.5, 2.0);
            stateDescription2.put(4.0, 2.0);
        }

        //调度时间是第二天，currentDate 是第一天

        Date beginDate = DateUtils.truncate(currentDate);
        Date endDate = DateUtils.addDays(currentDate, 1);


        Map<String, ProEconEquipmentInfoDay5> rates = new HashMap<>();
        Map<String, List<ProEconStateTranRatesSub>> ratesubs1 = new HashMap<>();
        Map<String, List<ProEconStateTranRatesSub2>> ratesubs2 = new HashMap<>();

        for (ProBasicEquipment wt : CacheContext.wtls) {
            ProEconEquipmentInfoDay5 rate = new ProEconEquipmentInfoDay5();
            rate.setRecordDate(currentDate);
            rate.setWindpowerstationId(wt.getWindpowerstationId());
            rate.setProjectId(wt.getProjectId());
            rate.setLineId(wt.getLineId());
            rate.setWindturbineId(wt.getId());

            Initial.initial(rate);

            rates.put(wt.getId(), rate);
            List<PointData> speedDataList = null;
            List<PointData> statusDataList = null;
            if (CacheContext.wtpAimap.containsKey(wt.getId())) {
                Map<String, ProBasicEquipmentPoint> wtpmap = CacheContext.wtpAimap.get(wt.getId());
                if (wtpmap.containsKey(ContantXk.CJ_SSFS)) {
                    ProBasicEquipmentPoint point = wtpmap.get(ContantXk.CJ_SSFS);
                    speedDataList = edosUtil.getHistoryDatasSnap(point.getNemCode(), beginDate.getTime() / 1000, endDate.getTime() / 1000);
                }
                if (wtpmap.containsKey(ContantXk.MXZT)) {
                    ProBasicEquipmentPoint point = wtpmap.get(ContantXk.MXZT);
                    statusDataList = edosUtil.getHistoryDatasSnap(point.getNemCode(), beginDate.getTime() / 1000, endDate.getTime() / 1000);
                }

            }


            //List<PointData> powerDataList = getHistoryDatasSnap(powerpointDictionary[id].ID, beginDate, endDate);

            List<ProEconStateTranRatesSub> subs = new ArrayList<>();
            ProEconStateTranRatesSub sub = new ProEconStateTranRatesSub();

            if (speedDataList != null && statusDataList != null && statusDataList.size() == speedDataList.size()) {


                for (int i = 0; i < speedDataList.size(); i++) {
                    if (speedDataList.get(i).getPointValueInDouble() <= 3.0) {
                        sub = buildStateRate(currentDate, wt.getId(), speedDataList, statusDataList, subs, sub, i, 3.0);

                    } else if (speedDataList.get(i).getPointValueInDouble() > 3 && speedDataList.get(i).getPointValueInDouble() <= 4) {
                        sub = buildStateRate(currentDate, wt.getId(), speedDataList, statusDataList, subs, sub, i, 3.5);
                    } else {
                        sub = buildStateRate(currentDate, wt.getId(), speedDataList, statusDataList, subs, sub, i, 4.0);
                    }
                }

                if (com.gyee.generation.util.StringUtils.empty(sub.getStatusEnd())) {
                    long time = speedDataList.get(speedDataList.size() - 1).getPointTime();
                    sub.setStatusEnd(new Date(time));
                    sub.setStatusHours(DateUtils.hoursDiff1(sub.getStatusBegin(), sub.getStatusEnd()));

                } else if (com.gyee.generation.util.StringUtils.notEmp(sub.getStatusBegin2()) && com.gyee.generation.util.StringUtils.empty(sub.getStatusEnd2())) {
                    long time = speedDataList.get(speedDataList.size() - 1).getPointTime();
                    sub.setStatusEnd2(new Date(time));
                    sub.setStatusHours2(DateUtils.hoursDiff1(sub.getStatusBegin2(), sub.getStatusEnd2()));

                }

                long time = speedDataList.get(speedDataList.size() - 1).getPointTime();
                sub.setEndTime(new Date(time));
                sub.setDurationHours(DateUtils.hoursDiff1(sub.getStartTime(), sub.getEndTime()));

                subs.add(sub);

                ratesubs1.put(wt.getId(), subs);


                //========================================================================================================================================
                //========================================================================================================================================

                List<ProEconStateTranRatesSub2> subs2 = new ArrayList<>();
                ProEconStateTranRatesSub2 sub2 = new ProEconStateTranRatesSub2();



                List<Date> intervaltimebegin = new ArrayList<>();
                List<Date> intervaltimeend = new ArrayList<>();



                for (int i = 0; i < subs.size(); i++) {

                    interval1 = 0.0;
                    interval2 = 0.0;
                    interval3 = 0.0;

                    if (sub2.getSpeed() == null) {
                        buildStatetransitionratesSub2(subs, sub2, i);
                    } else//非第一次
                    {
                        if (subs.get(i).getDurationHours() > interval)  //当前时间间隔满足条件
                        {
                            /* 加处理代码 */
                            double tempspeed;
                            if (interval1 >= interval2 && interval1 >= interval3) {
                                tempspeed = 3.0;
                            } else if (interval2 >= interval1 && interval2 >= interval3) {
                                tempspeed = 3.5;
                            } else {
                                tempspeed = 4.0;
                            }

                            if (Objects.equals(subs.get(i).getSpeed(), tempspeed)) {
                                sub2.setEndTime(subs.get(i).getEndTime());
                                sub2.setDurationHours(sub2.getDurationHours() + subs.get(i).getDurationHours());

                                /* 加处理代码 */
                            } else {

                                setStateTranRatesSub2(sub2, intervaltimebegin, intervaltimeend);
                                interval1 = 0.0;
                                interval2 = 0.0;
                                interval3 = 0.0;
                                intervaltimebegin = new ArrayList<>();
                                intervaltimeend = new ArrayList<>();
                                //newMethod(subs,  interval1,  interval2,  interval3, i,  lastspeed, intervaltimebegin, intervaltimeend);
                                subs2.add(sub2);
                                sub2 = new ProEconStateTranRatesSub2();
                                buildStatetransitionratesSub2(subs, sub2, i);


                            }
                        } else //当前时间间隔不满足条件
                        {

                            if (subs.get(i).getSpeed() == 3.0) {
                                interval1 = interval1 + subs.get(i).getDurationHours();

                            } else if (subs.get(i).getSpeed() == 3.5) {
                                interval2 = interval2 + subs.get(i).getDurationHours();
                            } else {
                                interval3 = interval3 + subs.get(i).getDurationHours();
                            }
                            if (interval1 > 0 && interval2 > 0 && interval3 > 0) {

                                if (subs.get(i).getSpeed() == 3.0) {
                                    interval1 = interval1 - subs.get(i).getDurationHours();
                                } else if (subs.get(i).getSpeed() == 3.5) {
                                    interval2 = interval2 - subs.get(i).getDurationHours();

                                } else {
                                    interval3 = interval3 - subs.get(i).getDurationHours();

                                }


                                setStateTranRatesSub2(sub2,  intervaltimebegin, intervaltimeend);
                                interval1 = 0.0;
                                interval2 = 0.0;
                                interval3 = 0.0;

                                intervaltimebegin = new ArrayList<>();
                                intervaltimeend = new ArrayList<>();


                                //newMethod(subs,  interval1,  interval2,  interval3, i,  lastspeed, intervaltimebegin, intervaltimeend);
                                subs2.add(sub2);
                                sub2 = new ProEconStateTranRatesSub2();
                                buildStatetransitionratesSub2(subs, sub2, i);
                            } else {
                                if (subs.get(i).getSpeed() == 3.0) {
                                    interval1 = interval1 - subs.get(i).getDurationHours();
                                } else if (subs.get(i).getSpeed() == 3.5) {
                                    interval2 = interval2 - subs.get(i).getDurationHours();
                                } else {
                                    interval3 = interval3 - subs.get(i).getDurationHours();
                                }
                                sub2.setEndTime(subs.get(i).getEndTime());
                                sub2.setDurationHours(sub2.getDurationHours() + subs.get(i).getDurationHours());

                            }

                        }
                    }
                    //-----------------------------------------------------------------------------------------------------------------
                    newMethod(subs,  i,  intervaltimebegin, intervaltimeend);
                    //------------------------------------------------------------------------------------------------------------------
                }


                if (interval1 >= interval2 && interval1 >= interval3) {
                    sub2.setSpeed(3.0);

                    if (intervaltimebegin.get(4) != null) {

                        sub2.setStatusCode2(4);
                        sub2.setStatusBegin2(intervaltimebegin.get(4));
                        sub2.setStatusEnd2(intervaltimeend.get(4));
                        sub2.setStatusHours2(DateUtils.hoursDiff2(sub2.getStatusEnd2(), sub2.getStatusBegin2()));

                    }


                } else if (interval2 >= interval1 && interval2 >= interval3) {
                    sub2.setSpeed(3.5);
                    newMethod(sub2, intervaltimebegin, intervaltimeend);
                } else {
                    sub2.setSpeed(4.0);

                    newMethod(sub2, intervaltimebegin, intervaltimeend);
                }
                subs2.add(sub2);
                ratesubs2.put(wt.getId(), subs2);
//============================================================================================================================================================================
//============================================================================================================================================================================

                for (ProEconStateTranRatesSub2 proEconStateTranRatesSub2 : subs2) {


                    if (proEconStateTranRatesSub2.getSpeed() == 3) {
                        if (proEconStateTranRatesSub2.getDurationHours() > 0.5) {
                            if (proEconStateTranRatesSub2.getStatusCode() == 0 || proEconStateTranRatesSub2.getStatusCode() == 1) {
                                //if (subs2.get(i).getStatusCode() == 4 && subs2.get(i).getStatusCode() == 2)
                                //{
                                if (proEconStateTranRatesSub2.getStatusHours() < 0.25)//5分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.25);
                                    double temp = rate.getTimerate1();
                                    temp = temp + 1;
                                    rate.setTimerate1(temp);

                                    temp = rate.getTimerate2();
                                    temp = temp + 1;
                                    rate.setTimerate2(temp);

                                    temp = rate.getTimerate3();
                                    temp = temp + 1;
                                    rate.setTimerate3(temp);

                                    temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);

                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.33)//10分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.33);
                                    double temp = rate.getTimerate2();
                                    temp = temp + 1;
                                    rate.setTimerate2(temp);

                                    temp = rate.getTimerate3();
                                    temp = temp + 1;
                                    rate.setTimerate3(temp);

                                    temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.42)//15分钟
                                {

                                    proEconStateTranRatesSub2.setResetRate(0.42);
                                    double temp = rate.getTimerate3();
                                    temp = temp + 1;
                                    rate.setTimerate3(temp);

                                    temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.5)//20分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.5);
                                    double temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);
                                }

                                //}
                                double temp = rate.getTimerate13();
                                temp = temp + 1;
                                rate.setTimerate13(temp);

                            }


                            if (proEconStateTranRatesSub2.getStatusCode() == 4) {

                                if (proEconStateTranRatesSub2.getStatusHours() < 0.25)//5分钟
                                {

                                    proEconStateTranRatesSub2.setResetRate(0.25);
                                    double temp = rate.getTimerate5();
                                    temp = temp + 1;
                                    rate.setTimerate5(temp);

                                    temp = rate.getTimerate6();
                                    temp = temp + 1;
                                    rate.setTimerate6(temp);

                                    temp = rate.getTimerate7();
                                    temp = temp + 1;
                                    rate.setTimerate7(temp);

                                    temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.33)//10分钟
                                {

                                    proEconStateTranRatesSub2.setResetRate(0.33);
                                    double temp = rate.getTimerate6();
                                    temp = temp + 1;
                                    rate.setTimerate6(temp);

                                    temp = rate.getTimerate7();
                                    temp = temp + 1;
                                    rate.setTimerate7(temp);

                                    temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.42)//15分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.42);
                                    double temp = rate.getTimerate7();
                                    temp = temp + 1;
                                    rate.setTimerate7(temp);

                                    temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);

                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.5)//20分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.5);
                                    double temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);
                                }

                                //}
                                double temp = rate.getTimerate14();
                                temp = temp + 1;
                                rate.setTimerate14(temp);

                            }


                        }
                    } else if (proEconStateTranRatesSub2.getSpeed() == 3.5) {
                        if (proEconStateTranRatesSub2.getDurationHours() > 0.5) {


                            if (proEconStateTranRatesSub2.getStatusCode() == 0 || proEconStateTranRatesSub2.getStatusCode() == 1) {
                                //if (subs2.get(i).getStatusCode() == 4 && subs2.get(i).getStatusCode() == 2)
                                //{
                                if (proEconStateTranRatesSub2.getStatusHours() < 0.25)//5分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.25);
                                    double temp = rate.getTimerate1();
                                    temp = temp + 1;
                                    rate.setTimerate1(temp);

                                    temp = rate.getTimerate2();
                                    temp = temp + 1;
                                    rate.setTimerate2(temp);

                                    temp = rate.getTimerate3();
                                    temp = temp + 1;
                                    rate.setTimerate3(temp);

                                    temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.33)//10分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.3);
                                    double temp = rate.getTimerate2();
                                    temp = temp + 1;
                                    rate.setTimerate2(temp);

                                    temp = rate.getTimerate3();
                                    temp = temp + 1;
                                    rate.setTimerate3(temp);

                                    temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.42)//15分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.42);
                                    double temp = rate.getTimerate3();
                                    temp = temp + 1;
                                    rate.setTimerate3(temp);

                                    temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.5)//20分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.5);
                                    double temp = rate.getTimerate4();
                                    temp = temp + 1;
                                    rate.setTimerate4(temp);
                                }

                                //}
                                double temp = rate.getTimerate13();
                                temp = temp + 1;
                                rate.setTimerate13(temp);
                            }

                            if (proEconStateTranRatesSub2.getStatusCode() == 4) {
                                //if (subs2.get(i).getStatusCode() == 0 || subs2.get(i).getStatusCode() == 1)
                                //{
                                if (proEconStateTranRatesSub2.getStatusHours() < 0.25)//5分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.25);
                                    double temp = rate.getTimerate5();
                                    temp = temp + 1;
                                    rate.setTimerate5(temp);

                                    temp = rate.getTimerate6();
                                    temp = temp + 1;
                                    rate.setTimerate6(temp);

                                    temp = rate.getTimerate7();
                                    temp = temp + 1;
                                    rate.setTimerate7(temp);

                                    temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.33)//10分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.33);
                                    double temp = rate.getTimerate6();
                                    temp = temp + 1;
                                    rate.setTimerate6(temp);

                                    temp = rate.getTimerate7();
                                    temp = temp + 1;
                                    rate.setTimerate7(temp);

                                    temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.42)//15分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.42);
                                    double temp = rate.getTimerate7();
                                    temp = temp + 1;
                                    rate.setTimerate7(temp);

                                    temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);
                                } else if (proEconStateTranRatesSub2.getStatusHours() < 0.5)//20分钟
                                {
                                    proEconStateTranRatesSub2.setResetRate(0.5);
                                    double temp = rate.getTimerate8();
                                    temp = temp + 1;
                                    rate.setTimerate8(temp);
                                }

                                //}
                                double temp = rate.getTimerate14();
                                temp = temp + 1;
                                rate.setTimerate14(temp);
                            }
                        }
                    } else if (proEconStateTranRatesSub2.getSpeed() == 4) {
                        if (proEconStateTranRatesSub2.getDurationHours() > 0.5) {
                            if (proEconStateTranRatesSub2.getStatusCode() == 0) {
                                if (proEconStateTranRatesSub2.getStatusCode() == 1) {
                                    if (proEconStateTranRatesSub2.getStatusHours() < 0.25)//5分钟
                                    {
                                        proEconStateTranRatesSub2.setResetRate(0.25);
                                        double temp = rate.getTimerate9();
                                        temp = temp + 1;
                                        rate.setTimerate9(temp);

                                        temp = rate.getTimerate10();
                                        temp = temp + 1;
                                        rate.setTimerate10(temp);

                                        temp = rate.getTimerate11();
                                        temp = temp + 1;
                                        rate.setTimerate11(temp);

                                        temp = rate.getTimerate12();
                                        temp = temp + 1;
                                        rate.setTimerate12(temp);
                                    } else if (proEconStateTranRatesSub2.getStatusHours() < 0.33)//10分钟
                                    {
                                        proEconStateTranRatesSub2.setResetRate(0.33);
                                        double temp = rate.getTimerate10();
                                        temp = temp + 1;
                                        rate.setTimerate10(temp);

                                        temp = rate.getTimerate11();
                                        temp = temp + 1;
                                        rate.setTimerate11(temp);

                                        temp = rate.getTimerate12();
                                        temp = temp + 1;
                                        rate.setTimerate12(temp);
                                    } else if (proEconStateTranRatesSub2.getStatusHours() < 0.42)//15分钟
                                    {
                                        proEconStateTranRatesSub2.setResetRate(0.42);
                                        double temp = rate.getTimerate11();
                                        temp = temp + 1;
                                        rate.setTimerate11(temp);

                                        temp = rate.getTimerate12();
                                        temp = temp + 1;
                                        rate.setTimerate12(temp);
                                    } else if (proEconStateTranRatesSub2.getStatusHours() < 0.5)//20分钟
                                    {
                                        proEconStateTranRatesSub2.setResetRate(0.5);
                                        double temp = rate.getTimerate12();
                                        temp = temp + 1;
                                        rate.setTimerate12(temp);
                                    }

                                    double temp = rate.getTimerate15();
                                    temp = temp + 1;
                                    rate.setTimerate15(temp);
                                }

                            }
                        }
                    }
                    //}


                }
            }
        }


        List<Integer> items1 = proEconStateTranRatesSubService.list().stream().filter(i -> i.getRecordDate().compareTo(currentDate) == 0).map(ProEconStateTranRatesSub::getId).collect(Collectors.toList());
        List<Integer> items2 = proEconStateTranRatesSub2Service.list().stream().filter(i -> i.getRecordDate().compareTo(currentDate) == 0).map(ProEconStateTranRatesSub2::getId).collect(Collectors.toList());


        if (!items1.isEmpty()) {
            proEconStateTranRatesSubService.removeByIds(items1);
        }
        if (!items2.isEmpty()) {
            proEconStateTranRatesSub2Service.removeByIds(items2);
        }

        for (String key : rates.keySet()) {
            ProEconEquipmentInfoDay5 rate = rates.get(key);
            if (ratesubs1.containsKey(key) && ratesubs2.containsKey(key)) {
                for (ProEconStateTranRatesSub item : ratesubs1.get(key)) {
                    proEconStateTranRatesSubService.save(item);
                }
                for (ProEconStateTranRatesSub2 item : ratesubs2.get(key)) {
                    proEconStateTranRatesSub2Service.save(item);
                }


                Optional<ProEconEquipmentInfoDay5> dayInfoo = proEconEquipmentInfoDay5Service.list().stream()
                        .filter(i -> i.getWindturbineId().equals(key)
                                && i.getRecordDate().compareTo(currentDate) == 0
                        ).findFirst();

                ProEconEquipmentInfoDay5 dayInfo;
                if (dayInfoo.isPresent()) {

                    dayInfo = dayInfoo.get();
                    buildresetRateByState(dayInfo, rate);
                    QueryWrapper<ProEconEquipmentInfoDay5> wrapper = new QueryWrapper<>();
                    wrapper.eq("id", dayInfo.getId());
                    proEconEquipmentInfoDay5Service.remove(wrapper);
                }else
                {
                    dayInfo = new ProEconEquipmentInfoDay5();
                    buildresetRateByState(dayInfo, rate);
                }

                proEconEquipmentInfoDay5Service.save(dayInfo);
            }
        }

    }

    private  void setStateTranRatesSub2(ProEconStateTranRatesSub2 sub2, List<Date> intervaltimebegin, List<Date> intervaltimeend) {

        if (interval1 >= interval2 && interval1 >= interval3) {

            sub2.setSpeed(3.0);

            if (intervaltimebegin.get(4) != null) {

                sub2.setStatusCode2(4);
                sub2.setStatusBegin2(intervaltimebegin.get(4));
                sub2.setStatusEnd2(intervaltimeend.get(4));
                sub2.setStatusHours2(DateUtils.hoursDiff2(sub2.getStatusEnd2(), sub2.getStatusBegin2()));

            }

        } else if (interval2 >= interval1 && interval2 >= interval3) {
            sub2.setSpeed(3.5);
            newMethod(sub2, intervaltimebegin, intervaltimeend);
        } else {
            sub2.setSpeed(4.0);

            newMethod(sub2, intervaltimebegin, intervaltimeend);
        }
    }

    private static void newMethod(ProEconStateTranRatesSub2 sub2, List<Date> intervaltimebegin, List<Date> intervaltimeend) {
        if (intervaltimebegin.get(0) != null) {
            if (intervaltimebegin.get(1) != null) {
                if (intervaltimebegin.get(0).before(intervaltimebegin.get(1))) {
                    sub2.setStatusCode(0);
                    sub2.setStatusBegin2(intervaltimebegin.get(0));
                    sub2.setStatusEnd2(intervaltimeend.get(0));
                } else {
                    sub2.setStatusCode(1);
                    sub2.setStatusBegin2(intervaltimebegin.get(1));
                    sub2.setStatusEnd2(intervaltimeend.get(1));
                }

            } else {
                sub2.setStatusCode(0);
                sub2.setStatusBegin2(intervaltimebegin.get(0));
                sub2.setStatusEnd2(intervaltimeend.get(0));
            }
            sub2.setStatusHours2(DateUtils.hoursDiff2(sub2.getStatusEnd2(), sub2.getStatusBegin2()));

        } else if (intervaltimebegin.get(1) != null) {
            sub2.setStatusCode(1);
            sub2.setStatusBegin2(intervaltimebegin.get(1));
            sub2.setStatusEnd2(intervaltimeend.get(1));
            sub2.setStatusHours2(DateUtils.hoursDiff2(sub2.getStatusEnd2(), sub2.getStatusBegin2()));
        }
    }

    private  void newMethod(List<ProEconStateTranRatesSub> subs, Integer i, List<Date> intervaltimebegin, List<Date> intervaltimeend) {
        if (subs.get(i).getSpeed() == 3.0) {
            interval1 += subs.get(i).getDurationHours();


        } else if (subs.get(i).getSpeed() == 3.5) {
            interval2 += subs.get(i).getDurationHours();

        } else {
            interval3 += subs.get(i).getDurationHours();

        }


        if (subs.get(i).getStatusCode() != null && subs.get(i).getStatusCode() < 5) {
            Integer key = subs.get(i).getStatusCode();
            if (intervaltimebegin.get(key) == null) {

                intervaltimebegin.set(key, subs.get(i).getStatusBegin2());
                intervaltimeend.set(key, subs.get(i).getStatusEnd2());

            }
        }
        if (subs.get(i).getStatusCode() != null && subs.get(i).getStatusCode() < 5) {
            Integer key = subs.get(i).getStatusCode();
            if (intervaltimebegin.get(key) == null) {
                intervaltimebegin.set(key, subs.get(i).getStatusBegin());
                intervaltimeend.set(key, subs.get(i).getStatusEnd());
            }
        }
    }

    public void buildresetRateByState(ProEconEquipmentInfoDay5 dayInfo, ProEconEquipmentInfoDay5 day) {
        dayInfo.setRecordDate(day.getRecordDate());
        dayInfo.setWindpowerstationId(day.getWindpowerstationId());
        dayInfo.setProjectId(day.getProjectId());
        dayInfo.setWindturbineId(day.getWindturbineId());
        dayInfo.setLineId(day.getLineId());
        dayInfo.setTimerate1(day.getTimerate1());
        dayInfo.setTimerate2(day.getTimerate2());
        dayInfo.setTimerate3(day.getTimerate3());
        dayInfo.setTimerate4(day.getTimerate4());
        dayInfo.setTimerate5(day.getTimerate5());
        dayInfo.setTimerate6(day.getTimerate6());
        dayInfo.setTimerate7(day.getTimerate7());
        dayInfo.setTimerate8(day.getTimerate8());
        dayInfo.setTimerate9(day.getTimerate9());
        dayInfo.setTimerate10(day.getTimerate10());
        dayInfo.setTimerate11(day.getTimerate11());
        dayInfo.setTimerate12(day.getTimerate12());
        dayInfo.setTimerate13(day.getTimerate13());
        dayInfo.setTimerate14(day.getTimerate14());
        dayInfo.setTimerate15(day.getTimerate15());
    }


    private static void buildStatetransitionratesSub2(List<ProEconStateTranRatesSub> subs, ProEconStateTranRatesSub2 sub2, Integer i) {
        sub2.setWindpwoerId(subs.get(i).getWindpwoerId());
        sub2.setProjectId(subs.get(i).getProjectId());
        sub2.setLineId(subs.get(i).getLineId());
        sub2.setWindturbineId(subs.get(i).getWindturbineId());
        sub2.setRecordDate(subs.get(i).getRecordDate());
        sub2.setStartTime(subs.get(i).getStartTime());
        sub2.setEndTime(subs.get(i).getEndTime());
        sub2.setDurationHours(subs.get(i).getDurationHours());
        sub2.setSpeed(subs.get(i).getSpeed());
        sub2.setMaxSpeed(subs.get(i).getMaxSpeed());
        sub2.setMinSpeed(subs.get(i).getMinSpeed());

        sub2.setStatusCode(subs.get(i).getStatusCode());
        sub2.setStatusHours(subs.get(i).getStatusHours());
        sub2.setStatusBegin(subs.get(i).getStatusBegin());
        sub2.setStatusEnd(subs.get(i).getStatusEnd());

        sub2.setStatusCode2(subs.get(i).getStatusCode2());
        sub2.setStatusHours2(subs.get(i).getStatusHours2());
        sub2.setStatusBegin2(subs.get(i).getStatusBegin2());
        sub2.setStatusEnd2(subs.get(i).getStatusEnd2());

    }

    private ProEconStateTranRatesSub buildStateRate(Date currentDate, String id, List<PointData> speedDataList, List<PointData> statusDataList, List<ProEconStateTranRatesSub> subs, ProEconStateTranRatesSub sub, Integer i, Double speed) {
        if (sub.getStartTime() == null) {
            //初始化
            buildSTATETRANSITIONRATESSUB(currentDate, id, speedDataList, statusDataList, sub, i, speed);
        } else {
            if (sub.getEndTime() == null) {
                //判定是几米风速 3 、 3.5 、 4
                if (Objects.equals(sub.getSpeed(), speed)) {
                    //stateDescription.Add(3, 4);
                    //stateDescription.Add(3.5m, 0);
                    //stateDescription.Add(4, 0);
                    if (sub.getStatusCode() != statusDataList.get(i).getPointValueInDouble() && sub.getStatusCode() == null &&
                            (statusDataList.get(i).getPointValueInDouble() == stateDescription1.get(speed) ||
                                    statusDataList.get(i).getPointValueInDouble() == stateDescription2.get(speed))) {
                        sub.setStatusCode(Integer.valueOf(String.valueOf(statusDataList.get(i).getPointValueInDouble())));

                        sub.setStatusBegin2(new Date(speedDataList.get(i).getPointTime()));
                        sub.setStatusEnd(new Date(speedDataList.get(i).getPointTime()));
                        sub.setStatusHours(DateUtils.hoursDiff1(sub.getStatusEnd(), sub.getStatusBegin()));

                    } else if (sub.getStatusCode() != null && sub.getStatusCode() != statusDataList.get(i).getPointValueInDouble()) {
                        sub.setStatusEnd2(new Date(speedDataList.get(i).getPointTime()));
                        sub.setStatusHours2(DateUtils.hoursDiff1(sub.getStatusEnd2(), sub.getStatusBegin2()));
                    }

                } else {
                    if (sub.getStatusEnd() == null) {
                        sub.setStatusEnd(new Date(speedDataList.get(i).getPointTime()));
                        sub.setStatusHours(DateUtils.hoursDiff1(sub.getStatusEnd(), sub.getStatusBegin()));
                    } else if (sub.getStatusBegin2() != null && sub.getStatusEnd2() == null) {
                        sub.setStatusEnd2(new Date(speedDataList.get(i).getPointTime()));
                        sub.setStatusHours2(DateUtils.hoursDiff1(sub.getStatusEnd2(), sub.getStatusBegin2()));
                    }
                    sub.setEndTime(new Date(speedDataList.get(i).getPointTime()));
                    sub.setDurationHours(DateUtils.hoursDiff1(sub.getEndTime(), sub.getStartTime()));


                    ProEconStateTranRatesSub finalSub = sub;
                    DoubleSummaryStatistics summaryStatistics = speedDataList.stream().filter(x -> new Date(x.getPointTime()).after(finalSub.getStartTime())
                            && new Date(x.getPointTime()).before(finalSub.getEndTime())
                    ).mapToDouble(PointData::getPointValueInDouble).summaryStatistics();

                    //最大最小风速
                    double max = summaryStatistics.getMax();
                    double min = summaryStatistics.getMin();

                    sub.setMaxSpeed(max);
                    sub.setMinSpeed(min);

                    subs.add(sub);

                    sub = new ProEconStateTranRatesSub();
                    buildSTATETRANSITIONRATESSUB(currentDate, id, speedDataList, statusDataList, sub, i, speed);
                }
            }
        }
        return sub;
    }


    private void buildSTATETRANSITIONRATESSUB(Date currentDate, String id, List<PointData> speedDataList, List<PointData> statusDataList, ProEconStateTranRatesSub sub, Integer i, Double speed) {
        sub.setStartTime(new Date(speedDataList.get(i).getPointTime()));
        sub.setWindpwoerId(CacheContext.wtmap.get(id).getWindpowerstationId());
        sub.setProjectId(CacheContext.wtmap.get(id).getProjectId());
        sub.setLineId(CacheContext.wtmap.get(id).getLineId());
        sub.setWindturbineId(id);
        sub.setRecordDate(currentDate);
        Double temp = statusDataList.get(i).getPointValueInDouble();
        sub.setStatusCode(Integer.valueOf(String.valueOf(temp)));
        sub.setStatusBegin(new Date(speedDataList.get(i).getPointTime()));
        sub.setSpeed(speed);
    }



    //故障消缺及时率

    public void failRate(Date cuttentDate) {

        Map<Date, Map<String, ProEconFaultLiminatedefects>> dtDictionary = new HashMap<>();
        Calendar c = Calendar.getInstance();
        c.setTime(cuttentDate);
        //Date now = Date.Now.Date.AddMonths(-1); //上月
        Date now = DateUtils.truncate(c.getTime()); //本月

        c.setTime(now);
        c.set(Calendar.DAY_OF_MONTH, 1);
        Date begin = c.getTime();

        c.add(Calendar.MONTH, 1);
        c.add(Calendar.DAY_OF_MONTH, -1);
        Date end = c.getTime();


        List<Integer> deleteitems = proEconFaultLiminatedefectsService.list().stream().filter(i ->
                (i.getDateTime().compareTo(begin) == 0 || i.getDateTime().after(begin))
                        && (i.getDateTime().compareTo(end) == 0 || i.getDateTime().before(end))
        ).map(ProEconFaultLiminatedefects::getId).collect(Collectors.toList());

        if (!deleteitems.isEmpty()) {
            proEconFaultLiminatedefectsService.removeByIds(deleteitems);
        }

        List<ProEconShutdownEvent> st2 = proEconShutdownEventService.list().stream()
                .filter(i ->
                        (i.getStopTime().compareTo(begin) == 0 || i.getStopTime().after(begin))
                                && (i.getStopTime().compareTo(end) == 0 || i.getStopTime().before(end))
                ).collect(Collectors.toList());

        for (ProEconShutdownEvent item : st2) {
            Date dt = item.getStopTime();
            Map<String, ProEconFaultLiminatedefects> fdDictionary;
            if (dtDictionary.containsKey(dt)) {
                fdDictionary = dtDictionary.get(dt);
            } else {
                fdDictionary = new HashMap<>();
                dtDictionary.put(dt, fdDictionary);
            }
            ProEconFaultLiminatedefects fs;
            if (fdDictionary.containsKey(item.getWindturbineId())) {
                fs = fdDictionary.get(item.getWindturbineId());
                double temp = fs.getFaultCount();
                temp = temp + 1;
                fs.setFaultCount(temp);

            } else {
                fs = new ProEconFaultLiminatedefects();
                fs.setWindturbineId(item.getWindturbineId());

                if (CacheContext.wtmap.containsKey(item.getWindturbineId())) {
                    ProBasicEquipment wt = CacheContext.wtmap.get(item.getWindturbineId());
                    fs.setWindpowerstationId(wt.getWindpowerstationId());
                    fs.setProjectId(wt.getProjectId());
                    fs.setLineId(wt.getLineId());
                }
                fs.setDateTime(dt);
                double temp = fs.getFaultCount();
                temp = temp + 1;
                fs.setFaultCount(temp);
                fs.setClassifyId("-1");

                if (!StringUtils.notEmp(fs.getRightCount())) {
                    fs.setRightCount(0.0);
                }

                fdDictionary.put(item.getWindturbineId(), fs);
            }
            if (item.getStopHours() < 24) {

                double temp = fs.getRightCount();
                temp = temp + 1;
                fs.setRightCount(temp);

            }
            if (fs.getFaultCount() != 0) {
                double temp = BigDecimal.valueOf(fs.getRightCount()).divide(BigDecimal.valueOf(fs.getFaultCount()), 2, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue();

                fs.setRate(temp);

            }
        }
        for (Map<String, ProEconFaultLiminatedefects> items : dtDictionary.values()) {
            for (ProEconFaultLiminatedefects item : items.values()) {

                proEconFaultLiminatedefectsService.save(item);
            }
        }


    }

}