wrdep/wrdep-biz/src/main/java/com/jiayue/biz/service/impl/HomePageServiceImpl.java

package com.jiayue.biz.service.impl;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.db.Entity;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jiayue.biz.conf.RequestDataHelper;
import com.jiayue.biz.domain.*;
import com.jiayue.biz.dto.EquipmentDto;
import com.jiayue.biz.dto.ProjectEvolveDto;
import com.jiayue.biz.dto.ProjectInfoDto;
import com.jiayue.biz.dto.SelectLabForVal;
import com.jiayue.biz.eunms.WindDirectionEnum;
import com.jiayue.biz.mapper.ProphaseAnemometryDataMapper;
import com.jiayue.biz.mapper.ProphaseWeatherDataMapper;
import com.jiayue.biz.mapper.WindTowerDataParentTableMapper;
import com.jiayue.biz.service.*;
import com.jiayue.biz.util.CalculationUtil;
import com.jiayue.biz.util.DateTimeUtil;
import com.jiayue.common.core.redis.RedisCache;
import com.jiayue.common.utils.DateUtil;
import com.jiayue.common.utils.spring.SpringUtils;
import com.sun.corba.se.spi.ior.ObjectKey;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.sql.Timestamp;
import java.sql.Wrapper;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * 首页Service业务层处理
 *
 * @author L.ym
 * @date 2022-05-11
 */
@Service
@AllArgsConstructor
public class HomePageServiceImpl extends ServiceImpl<WindTowerDataParentTableMapper, WindTowerDataParentTable> implements HomePageService {
    private final WindTowerInfoService windTowerInfoService;
    private final EquipmentAttributeService equipmentAttributeService;
    private final WindTowerCalculationDataServiceImpl windTowerCalculationDataService;

    private final WindTowerDataParentTableService windTowerDataParentTableService;
    private final StatisticsSituationService iStatisticsSituationService;
    private final ProjectService projectService;
    private final ElectricStationService electricStationService;

    private final ProvincialEnergyStationsService provincialEnergyStationsService;

    private final ProjectInfoService projectInfoService;
    private final StationInfoService stationInfoService;

    private final ProjectProgressService proProjectInfoService;
    private final TotalityInfoService totalityInfoService;
    private final FanModelDataService fanModelDataService;

    private final ProphaseAnemometryDataService prophaseAnemometryDataService;

    private final ProphaseWeatherDataService prophaseWeatherDataService;

    private final OtherStationInfoService otherStationInfoService;

    private final WindDirectionStatisticsDataService windDirectionStatisticsDataService;


    private final BigDecimal threeParameterOne = new BigDecimal("1.146");
    private final BigDecimal threeParameterTow = new BigDecimal("77.42");
    private final BigDecimal threeParameterThree = new BigDecimal("1672");
    private final BigDecimal threeParameterFour = new BigDecimal("5251");

    private final Double e = 10.0;


    /**
     * 风速 风功率 柱状图
     *
     * @param equipmentId 设备编号
     * @return Map<String, Object>
     */
    public Map<String, Object> getWsAndWpdForHeight(String equipmentId, String month) {
        List<WindTowerInfo> windTowerInfoList = windTowerInfoService.getByEquipmentNo(equipmentId);
        String[] heights = windTowerInfoList.get(0).getHeights().split(",");
        //获取最后一条记录
        WindTowerCalculationData lastDataCalculation = windTowerCalculationDataService.getLastDataCalculation(equipmentId);
        Date yearDay = DateTimeUtil.getYearDay(lastDataCalculation.getTime().getTime());
        //获取去年月份开始时间
        Date beginTime = DateUtil.offsetMonth(DateUtil.beginOfMonth(yearDay), 1);
        Date endTime = lastDataCalculation.getTime();


        List<EquipmentAttribute> equipmentAttributeList = equipmentAttributeService.lambdaQuery().likeLeft(EquipmentAttribute::getFieldName, "wpdMonth").or().likeLeft(EquipmentAttribute::getFieldName, "awsMonth").list();
        List<WindTowerCalculationData> windTowerCalculationData = windTowerCalculationDataService.getByBetweenTimeAndEquipmentIdAndEbId(beginTime, endTime, equipmentId, equipmentAttributeList);

        HashMap<String, Object> dataMap = new HashMap<>();
        ArrayList<BigDecimal> wpdList = new ArrayList<>();
        ArrayList<BigDecimal> wsList = new ArrayList<>();
        ArrayList<String> heightList = new ArrayList<>();
        //循环层高
        for (String height : heights) {
            //获取风速风功率的统计id
            List<EquipmentAttribute> equipmentAttributeWpd = equipmentAttributeList.stream().filter(e -> e.getFieldName().equals(height + "wpdMonth")).collect(Collectors.toList());
            List<EquipmentAttribute> equipmentAttributeWs = equipmentAttributeList.stream().filter(e -> e.getFieldName().equals(height + "awsMonth")).collect(Collectors.toList());
            heightList.add(height + "m");

            //根据id和时间过滤
            BigDecimal wpd = this.getDataForTimeAndId(windTowerCalculationData, equipmentAttributeWpd.get(0).getId(), beginTime.getTime(), endTime.getTime());
            wpdList.add(wpd);
            //根据id和时间过滤
            BigDecimal ws = this.getDataForTimeAndId(windTowerCalculationData, equipmentAttributeWs.get(0).getId(), beginTime.getTime(), endTime.getTime());
            wsList.add(ws);


        }
        dataMap.put("ws", wsList);
        dataMap.put("wpd", wpdList);
        dataMap.put("height", heightList);

        return dataMap;
    }

    //计算统计数据时间段内平均值
    public BigDecimal getDataForTimeAndId(List<WindTowerCalculationData> windTowerCalculationData, String ebId, Long startTime, Long endTime) {
        List<BigDecimal> calculationData = windTowerCalculationData.stream().filter(w -> w.getEbId().equals(ebId) && w.getTime().getTime() >= startTime && w.getTime().getTime() <= endTime).map(WindTowerCalculationData::getValue).collect(Collectors.toList());


        return calculationData.size() > 0 ? CalculationUtil.getAvgWind(calculationData) : BigDecimal.ZERO;


    }


    /**
     * 首页查询风速对比
     *
     * @param equipmentId 设备编号
     * @return
     */
    public Map<String, Object> homePageCharts(String equipmentId, String month) {

        HashMap<String, Object> everyMap = new HashMap();

        List<WindTowerInfo> windTowerInfoList = windTowerInfoService.getByEquipmentNo(equipmentId);
        String[] heights = windTowerInfoList.get(0).getHeights().split(",");
        //获取最后一条记录
        WindTowerCalculationData lastDataCalculation = windTowerCalculationDataService.getLastDataCalculation(equipmentId);
        Date yearDay = DateTimeUtil.getYearDay(lastDataCalculation.getTime().getTime());
        //获取去年月份开始时间
        Date beginTime = DateUtil.offsetMonth(DateUtil.beginOfMonth(yearDay), 1);
        Map<String, Long> startAndEnd = prophaseWeatherDataService.getDataTimeStartAndEnd(equipmentId);

        if(beginTime.getTime() < startAndEnd.get("startTime")){
            beginTime = new Date(startAndEnd.get("startTime"));
        }
        Date endTime = lastDataCalculation.getTime();

        List<EquipmentAttribute> equipmentAttributeList = equipmentAttributeService.lambdaQuery().likeLeft(EquipmentAttribute::getFieldName, "awsDay").list();
        List<WindTowerCalculationData> windTowerCalculationData = windTowerCalculationDataService.getByBetweenTimeAndEquipmentIdAndEbId(beginTime, endTime, equipmentId, equipmentAttributeList);
        //数据list 风速 层高
        ArrayList<Object> everyData = new ArrayList<>();
        //时间list
        ArrayList<String> timeList = new ArrayList();
        boolean type = true;
        for (String height : heights) {
            List<EquipmentAttribute> equipmentAttributes = equipmentAttributeList.stream().filter(e -> e.getFieldName().equals(height + "awsDay")).collect(Collectors.toList());

            ArrayList<Object> hList = new ArrayList();
            HashMap<String, Object> hMap = new HashMap();

            for (long i = beginTime.getTime(); i <= endTime.getTime(); i = i + 86400000) {
                long finalI = i;
                List<WindTowerCalculationData> calculationData = windTowerCalculationData.stream().filter(w -> w.getEbId().equals(equipmentAttributes.get(0).getId()) && w.getTime().getTime() == finalI).collect(Collectors.toList());
                if (type) {
                    timeList.add(DateUtil.format(new Date(i), "yyyy-MM-dd"));
                }
                hList.add(calculationData.size() > 0 ? calculationData.get(0).getValue() : BigDecimal.ZERO);

            }

            hMap.put("height", height);
            hMap.put("value", hList);
            everyData.add(hMap);
            type = false;
        }
        everyMap.put("chart", everyData);
        everyMap.put("time", timeList);

//        List<ProphaseAnemometryData> mapList = new ArrayList<>();
//        if (!month.equals("")) {
//            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
//            try {
//                Date startDate = sdf.parse(month);
//                Date endDate = DateTimeUtil.endOfMonth(startDate);
//                mapList = prophaseAnemometryDataService.selectWsAve(equipmentId, new Timestamp(startDate.getTime()), new Timestamp(endDate.getTime()));
//            } catch (ParseException e) {
//                e.printStackTrace();
//            }
//        } else {
//            // 最新一天数据
//            List<Entity> lastData = prophaseWeatherDataService.getLastData(equipmentId);
//            Timestamp timeEnd = (Timestamp) lastData.get(0).get("last (ts)");
//            DateTime startTime = DateUtil.beginOfDay(new Date(timeEnd.getTime()));
//            mapList = prophaseAnemometryDataService.selectWsAve(equipmentId, new Timestamp(startTime.getTime()), timeEnd);
//
//        }
////        HashMap<String, Object> everyMap = new HashMap();
//        //获取风速层高
//        List<WindTowerInfo> windTowerInfos = windTowerInfoService.getByEquipmentNo(equipmentId);
//        String height = windTowerInfos.get(0).getHeights();
//        String[] heightAll = height.split(",");
//
//        // 时间list
////        ArrayList<String> timeList = new ArrayList();
////        ArrayList<Object> everyData = new ArrayList<>();
//
//        for (String h : heightAll) {
//            timeList = new ArrayList();
//            ArrayList<Object> hList = new ArrayList();
//            HashMap<String, Object> hMap = new HashMap();
//            //根据层高过滤时间和风速
//            TreeMap<Long, Float> heightForTimeAndWs = new TreeMap<>(mapList.stream().filter(p -> p.getLayerHeight().equals(h))
//                    .collect(Collectors.toMap(prophaseAnemometryData -> prophaseAnemometryData != null ? prophaseAnemometryData.getTs().getTime() : null, prophaseAnemometryData1 -> prophaseAnemometryData1 != null ? prophaseAnemometryData1.getWsAve() : null)));
//            for (Map.Entry<Long, Float> entry : heightForTimeAndWs.entrySet()) {
//                String time = DateUtil.format(new Date(entry.getKey()), "yyyy-MM-dd HH:mm:ss");
//                timeList.add(time);
//                hList.add(entry.getValue());
//            }
//            hMap.put("height", h);
//            hMap.put("value", hList);
//            everyData.add(hMap);
//        }


        return everyMap;
    }


    /*首页地图   测风塔信息*/
    public List<Map<String, Object>> homePageMap() {
        List<Map<String, Object>> list = new ArrayList<>();
        try {
            SimpleDateFormat sdfTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
            Date startDay = DateTimeUtil.getDayStartTime(new Date().getTime() - 1000 * 60 * 60 * 24);
            Date endDay = DateTimeUtil.getDayLastTime(new Date().getTime() - 1000 * 60 * 60 * 24);
            /*测风塔设备*/
            List<WindTowerInfo> windTowerInfoList = windTowerInfoService.getAllWindTower();
            List<StatisticsSituation> statisticsSituationList = iStatisticsSituationService.list();
            /*系统昨日的时间戳*/
            long date = DateTimeUtil.getDayStartTime(new Date().getTime()).getTime() - 86400000;
            for (WindTowerInfo windTowerInfo : windTowerInfoList) {
                Map<String, Object> map = new HashMap();
                // 状态
                Boolean status = true;

                /*判断此塔是否停机状态 若运行状态 计算是否10天内没接入数据*/
                if (windTowerInfo.getStatus() == null || windTowerInfo.getStatus().equals("1")) {
                    /*根据设备编号获取该塔的最后一条数据*/
                    WindTowerDataParentTable lastData = windTowerDataParentTableService.getLastData(windTowerInfo.getEquipmentNo());
                    /*获取该塔接入的时间*/
                    long startTime = DateTimeUtil.getDayStartTime(lastData.getTime().getTime()).getTime();
                    /*测风塔最新接入时间 - 今日系统时间 = 差值 差值代表此塔几天没有接入数据，若差值>=10 将此塔状态设置为异常*/
                    long differenceDays = date - startTime;
                    if ((differenceDays / 86400000) >= 10) {
                        status = false;
                    } else {
                        status = true;
                    }
                }
                // 缺失的数据条数
                BigDecimal defectCount = new BigDecimal(144);
                /*昨日数据条数*/
                List<Map<String, Object>> maps = windTowerDataParentTableService.countDataIntegrity(windTowerInfo.getEquipmentNo(), sdfTime.format(startDay), sdfTime.format(endDay));
                List<StatisticsSituation> statisticsSituations = statisticsSituationList.stream().filter(w -> w.getEquipmentId().equals(windTowerInfo.getEquipmentNo())).collect(Collectors.toList());
                String info = "";
                if (!statisticsSituations.isEmpty()) {
                    StatisticsSituation statisticsSituation = statisticsSituations.get(0);
                    String[] split = statisticsSituation.getStartTimeAndEndTime().split(",");
                    info = info + "数据起止时间:" + sdf.format(new Date(Long.parseLong(split[0]))) + " - " + sdf.format(new Date(Long.parseLong(split[1])));
//                    if (statisticsSituation.getWsAve140() != null)
//                        info = info + "；140米风速：" + statisticsSituation.getWsAve140().setScale(2, RoundingMode.HALF_UP);
//                    if (statisticsSituation.getWsAve120() != null)
//                        info = info + "；120米风速：" + statisticsSituation.getWsAve120().setScale(2, RoundingMode.HALF_UP);
//                    if (statisticsSituation.getWsAve100() != null)
//                        info = info + "；100米风速：" + statisticsSituation.getWsAve100().setScale(2, RoundingMode.HALF_UP);
//                    if (statisticsSituation.getWsAve80() != null)
//                        info = info + "；80米风速：" + statisticsSituation.getWsAve80().setScale(2, RoundingMode.HALF_UP);
//                    if (statisticsSituation.getWsAve70() != null)
//                        info = info + "；70米风速：" + statisticsSituation.getWsAve70().setScale(2, RoundingMode.HALF_UP);
//                    if (statisticsSituation.getWsAve50() != null)
//                        info = info + "；50米风速：" + statisticsSituation.getWsAve50().setScale(2, RoundingMode.HALF_UP);
//                    if (statisticsSituation.getWsAve30() != null)
//                        info = info + "；30米风速：" + statisticsSituation.getWsAve30().setScale(2, RoundingMode.HALF_UP);
//                    if (statisticsSituation.getWsAve10() != null)
//                        info = info + "；10米风速：" + statisticsSituation.getWsAve10().setScale(2, RoundingMode.HALF_UP);
                }
                if (!maps.isEmpty()) {
                    defectCount = new BigDecimal(maps.get(0).get("num").toString()).subtract(new BigDecimal(144));
                }
                map.put("name", windTowerInfo.getName());
                map.put("equipmentNo", windTowerInfo.getEquipmentNo());
                map.put("lon", windTowerInfo.getLongitude());
                map.put("lat", windTowerInfo.getLatitude());
                map.put("defectCount", defectCount);
                map.put("status", status);
                map.put("info", info);
                list.add(map);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }/*首页地图   测风塔信息*/

    public List<Map<String, Object>> homePageAllWindMap() {
        List<Map<String, Object>> list = new ArrayList<>();
        try {
            /*项目信息*/
            List<Project> projectList = projectService.list();
            /*场站信息*/
            List<ElectricStation> electricStationList = electricStationService.list();
            /*测风塔设备*/
//            List<WindTowerInfo> windTowerInfoList = windTowerInfoService.list();
            List<WindTowerInfo> windTowerInfoList = windTowerInfoService.getAllWindTower();
            /*项目塔信息*/
            List<Map<String, Object>> projectTowerList = projectTowerMap(projectList, windTowerInfoList);
            list.addAll(projectTowerList);
            /*场站塔信息*/
            List<Map<String, Object>> electricStationTowerList = electricStationTowerMap(electricStationList, windTowerInfoList);
            list.addAll(electricStationTowerList);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }

    /*首页地图项目塔*/
    public List<Map<String, Object>> projectTowerMap(List<Project> projectList, List<WindTowerInfo> windTowerInfoList) {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        List<Map<String, Object>> list = new ArrayList<>();
        /*统计概述*/
        List<StatisticsSituation> statisticsSituationList = iStatisticsSituationService.list();
        /*系统昨日的时间戳*/
        long date = DateTimeUtil.getDayStartTime(new Date().getTime()).getTime() - 86400000;
        /*项目塔*/
        for (Project project : projectList) {
            /*项目关联的塔*/
            String[] strings = project.getRelationEquipment().split(",");
            if (strings.length > 0) {
                for (String equipmentNo : strings) {
                    Map<String, Object> map = new HashMap();
                    map.put("type", "emailWind");
                    map.put("projectId", project.getId());
                    List<WindTowerInfo> windTowerInfos = windTowerInfoList.stream().filter(w -> w.getEquipmentNo().equals(equipmentNo)).collect(Collectors.toList());
                    WindTowerInfo windTowerInfo = windTowerInfos.get(0);
                    // 状态
                    Boolean status = true;
                    /*判断此塔是否停机状态 若运行状态 计算是否10天内没接入数据*/
                    if (windTowerInfo.getStatus() == null || windTowerInfo.getStatus().equals("1")) {
                        /*根据设备编号获取该塔的最后一条数据*/
                        WindTowerDataParentTable lastData = windTowerDataParentTableService.getLastData(windTowerInfo.getEquipmentNo());
                        /*获取该塔接入的时间*/
                        long startTime = DateTimeUtil.getDayStartTime(lastData.getTime().getTime()).getTime();
                        /*测风塔最新接入时间 - 今日系统时间 = 差值 差值代表此塔几天没有接入数据，若差值>=10 将此塔状态设置为异常*/
                        long differenceDays = date - startTime;
                        if ((differenceDays / 86400000) >= 10) {
                            status = false;
                        } else {
                            status = true;
                        }
                    }
                    /*获取数据的起止时间*/
                    List<StatisticsSituation> statisticsSituations = statisticsSituationList.stream().filter(w -> w.getEquipmentId().equals(windTowerInfo.getEquipmentNo())).collect(Collectors.toList());
                    String info = "";
                    if (!statisticsSituations.isEmpty()) {
                        StatisticsSituation statisticsSituation = statisticsSituations.get(0);
                        String[] split = statisticsSituation.getStartTimeAndEndTime().split(",");
                        info = info + "数据起止时间:" + sdf.format(new Date(Long.parseLong(split[0]))) + " - " + sdf.format(new Date(Long.parseLong(split[1])));
                    }
                    map.put("name", windTowerInfo.getName());
                    map.put("equipmentNo", windTowerInfo.getEquipmentNo());
                    map.put("lon", windTowerInfo.getLongitude());
                    map.put("lat", windTowerInfo.getLatitude());
                    map.put("status", status);
                    map.put("info", info);
                    list.add(map);
                }
            }

        }
        return list;
    }

    /*首页地图实时塔*/
    public List<Map<String, Object>> electricStationTowerMap(List<ElectricStation> electricStationList, List<WindTowerInfo> windTowerInfoList) {
        List<Map<String, Object>> list = new ArrayList<>();
        /*实时塔*/
        for (ElectricStation electricStation : electricStationList) {
            /*风场站关联的塔*/
            String[] strings = electricStation.getRelationEquipment().split(",");
            if (strings.length > 0) {
                for (String equipmentNo : strings) {
                    Map<String, Object> map = new HashMap();
                    map.put("type", "realWind");
                    map.put("electricStationId", electricStation.getId());
                    List<WindTowerInfo> windTowerInfos = windTowerInfoList.stream().filter(w -> w.getEquipmentNo().equals(equipmentNo)).collect(Collectors.toList());
                    if (!windTowerInfos.isEmpty()) {
                        WindTowerInfo windTowerInfo = windTowerInfos.get(0);
                        // 状态
                        Boolean status = windTowerInfo.getStatus() == null || windTowerInfo.getStatus().equals("1") ? true : false;
                        map.put("name", windTowerInfo.getName());
                        map.put("equipmentNo", windTowerInfo.getEquipmentNo());
                        map.put("lon", windTowerInfo.getLongitude());
                        map.put("lat", windTowerInfo.getLatitude());
                        map.put("status", status);
                        list.add(map);
                    }

                }
            }

        }
        return list;
    }

    /**
     * 首页查询最新一天的风向玫瑰图
     *
     * @param equipmentId 设备编号
     * @param height      层高
     * @return List<Map < String, Object>>
     */
    @Override
    public HashMap<String, Object> homePageRose(String equipmentId, String height, String month) {
        List<ProphaseAnemometryData> anemometryData = new ArrayList<>();
        if (!month.equals("")) {
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
            try {
                Date startDate = sdf.parse(month);
                Date endDate = DateTimeUtil.endOfMonth(startDate);
                anemometryData = prophaseAnemometryDataService.selectWdAveAndWdAveAndWsStaForHeight(equipmentId, new Timestamp(startDate.getTime()), new Timestamp(endDate.getTime()), height);
            } catch (ParseException e) {
                e.printStackTrace();
            }
        } else {
            // 最新一天数据
            List<Entity> lastData = prophaseWeatherDataService.getLastData(equipmentId);
            Timestamp timeEnd = (Timestamp) lastData.get(0).get("last (ts)");
            DateTime startTime = DateUtil.beginOfDay(DateTimeUtil.getYearDay(timeEnd.getTime()));
            anemometryData = prophaseAnemometryDataService.selectWdAveAndWdAveAndWsStaForHeight(equipmentId, new Timestamp(startTime.getTime()), timeEnd, height);
        }

        HashMap<String, Integer> hashMap = new HashMap<>();

        Map<String, BigDecimal> map = new HashMap<>();
        Map<String, BigDecimal> windPowerMap = new HashMap<>();
        for (WindDirectionEnum value : WindDirectionEnum.values()) {
            //根据设备属性风向获取数据
            List<ProphaseAnemometryData> heightAndWindDirectionEnum = CalculationUtil.getForHeightAndWindDirectionEnum(anemometryData, value);
            BigDecimal wsAve = BigDecimal.ZERO;
            if (heightAndWindDirectionEnum.size() > 0) {
                wsAve = BigDecimal.valueOf(heightAndWindDirectionEnum.stream().map(h -> {
                    return BigDecimal.valueOf(h.getWsAve());
                }).collect(Collectors.averagingDouble(BigDecimal::doubleValue)));
            }

            hashMap.put(value.name(), heightAndWindDirectionEnum.size());

            if (anemometryData.size() > 0) {
                //风向频率
                BigDecimal wdF = BigDecimal.valueOf(heightAndWindDirectionEnum.size()).divide(BigDecimal.valueOf(anemometryData.size()), 2, RoundingMode.HALF_UP);
                map.put(value.name(), BigDecimal.valueOf(100).multiply(wdF));
                // 风能：风向频率 * 平均风速的立方
                windPowerMap.put(value.name(), wsAve.multiply(wsAve).multiply(wsAve).multiply(wdF).setScale(2, RoundingMode.HALF_UP));
            } else {
                map.put(value.name(), BigDecimal.ZERO);
                windPowerMap.put(value.name(), BigDecimal.ZERO);
            }
        }
        ArrayList<Map.Entry<String, BigDecimal>> entries = new ArrayList<>(map.entrySet());
        entries.sort((o1, o2) -> {
            return o2.getValue().compareTo(o1.getValue());
        });
        List<Map.Entry<String, BigDecimal>> entries1 = entries.subList(0, 3);
        HashMap<String, Object> everyMap = new HashMap<>();
        everyMap.put("echars", map);
        everyMap.put("windPowerEchars", windPowerMap);
        everyMap.put("proportion", entries1);
        return everyMap;

    }


    /**
     * 首页空气密度、温度、压强平均值 湍流 风切变 满发小时数 日发电量 经纬度 数据起止时间
     *
     * @param equipmentId 场站编号
     * @return Map<String, BigDecimal>
     */
    public Map<String, Object> getAirAndPaAndT(String equipmentId, String month) {
        List<WindTowerInfo> windTowerInfoList = windTowerInfoService.getByEquipmentNo(equipmentId);
        String[] wdHeight = windTowerInfoList.get(0).getWdHeights().split(",");

        ArrayList<String> arrayList = new ArrayList(Arrays.asList(windTowerInfoList.get(0).getHeights().split(",")));
        //层高排序
        List<Integer> heightList = arrayList.stream().map(s -> Integer.parseInt(CalculationUtil.getNumberFromString(s))).sorted().collect(Collectors.toList());
        Integer maxHeight = heightList.get(heightList.size() - 1);
        //获取最后一条记录
        WindTowerCalculationData lastDataCalculation = windTowerCalculationDataService.getLastDataCalculation(equipmentId);

        Date yearDay = DateTimeUtil.getYearDay(lastDataCalculation.getTime().getTime());
        //获取去年月份开始时间
        Date beginTime = DateUtil.offsetMonth(DateUtil.beginOfMonth(yearDay), 1);
        Date endTime = lastDataCalculation.getTime();

        List<EquipmentAttribute> equipmentAttributeList = equipmentAttributeService.lambdaQuery().eq(EquipmentAttribute::getFieldName, "airDensityMonth").or().eq(EquipmentAttribute::getFieldName, "tAVE").or().
                eq(EquipmentAttribute::getFieldName, "paAVE").or().eq(EquipmentAttribute::getFieldName, maxHeight + "turbulenceMonth").or().
                eq(EquipmentAttribute::getFieldName, "windShearMonth").or().eq(EquipmentAttribute::getFieldName, "batteryDay")
                .or().eq(EquipmentAttribute::getFieldName, wdHeight[0] + "monthWdRose").list();

        List<WindTowerCalculationData> windTowerCalculationDataList = windTowerCalculationDataService.getByBetweenTimeAndEquipmentIdAndEbId(beginTime, endTime, equipmentId, equipmentAttributeList);

        HashMap<String, Object> dataMap = new HashMap<>();
        //温度
        dataMap.put("t", this.getDataForCalculationByEb(equipmentAttributeList, windTowerCalculationDataList, "tAVE"));
        //空气密度
        dataMap.put("air", this.getDataForCalculationByEb(equipmentAttributeList, windTowerCalculationDataList, "airDensityMonth"));
        //压强
        dataMap.put("pa", this.getDataForCalculationByEb(equipmentAttributeList, windTowerCalculationDataList, "paAVE"));
        //湍流
        dataMap.put("turbulence", this.getDataForCalculationByEb(equipmentAttributeList, windTowerCalculationDataList, maxHeight + "turbulenceMonth"));
        //风切变
        dataMap.put("windShear", this.getDataForCalculationByEb(equipmentAttributeList, windTowerCalculationDataList, "windShearMonth"));
        //层高
        dataMap.put("height", maxHeight);
        List<EquipmentAttribute> batteryDay1 = equipmentAttributeList.stream().filter(e -> e.getFieldName().equals("batteryDay")).collect(Collectors.toList());
        List<WindTowerCalculationData> calculationDataList = windTowerCalculationDataList.stream().filter(w -> w.getEbId().equals(batteryDay1.get(0).getId())).collect(Collectors.toList());
        BigDecimal batteryDay = calculationDataList.stream().map(WindTowerCalculationData::getValue).reduce(BigDecimal.ZERO, BigDecimal::add);
        BigDecimal hourMax = batteryDay.divide(BigDecimal.valueOf(6.25), 2, RoundingMode.HALF_UP);
        //发电量
        dataMap.put("battery", batteryDay);
        //满发小时数
        dataMap.put("hour", hourMax);

        List<EquipmentAttribute> equipmentAttributes = equipmentAttributeList.stream().filter(e -> e.getFieldName().equals(wdHeight[0] + "monthWdRose")).collect(Collectors.toList());
        List<WindDirectionStatisticsData> windDirectionStatisticsDataList = windDirectionStatisticsDataService.lambdaQuery().eq(WindDirectionStatisticsData::getEbId, equipmentAttributes.get(0).getId()).between(WindDirectionStatisticsData::getTime, beginTime, endTime)
                .eq(WindDirectionStatisticsData::getEquipmentId, equipmentId).list();

        Map<String, List<WindDirectionStatisticsData>> collect = windDirectionStatisticsDataList.stream().collect(Collectors.groupingBy(w -> w.getDirection()));
        HashMap<String, BigDecimal> hashMap = new HashMap<>();
        for (Map.Entry<String, List<WindDirectionStatisticsData>> k : collect.entrySet()) {
            BigDecimal reduce = k.getValue().stream().map(WindDirectionStatisticsData::getValue).reduce(BigDecimal.ZERO, BigDecimal::add);
            hashMap.put(k.getKey(), reduce);
        }
        Map.Entry<String, BigDecimal> stringBigDecimalEntry = hashMap.entrySet().stream().max(Comparator.comparing(Map.Entry::getValue)).get();
        //主风向
        dataMap.put("wdSum", stringBigDecimalEntry.getKey());
        //起止时间
        Map<String, Long> dataTimeStartAndEnd = prophaseWeatherDataService.getDataTimeStartAndEnd(equipmentId);
        String startTime = DateUtil.format(new Date(dataTimeStartAndEnd.get("startTime")), "yyyy-MM-dd");
        String endTimeStr = DateUtil.format(endTime, "yyyy-MM-dd");
        dataMap.put("dataTime", startTime + "-" + endTimeStr);
        dataMap.put("longitude", windTowerInfoList.get(0).getLongitude());
        dataMap.put("latitude", windTowerInfoList.get(0).getLatitude());

        return dataMap;
    }

    public BigDecimal getDataForCalculationByEb(List<EquipmentAttribute> equipmentAttributeList, List<WindTowerCalculationData> windTowerCalculationDataList, String fieldName) {
        List<String> ebId = equipmentAttributeList.stream().filter(e -> e.getFieldName().equals(fieldName)).map(EquipmentAttribute::getId).collect(Collectors.toList());

        List<BigDecimal> dataList = windTowerCalculationDataList.stream().filter(w -> w.getEbId().equals(ebId.get(0))).map(WindTowerCalculationData::getValue).collect(Collectors.toList());

        return dataList.size() > 0 ? CalculationUtil.getAvgWind(dataList) : BigDecimal.ZERO;


    }


    //首页全省资源概述
    public HashMap<String, String> getResourcesOverview() {
        ProvincialEnergyStations provincialEnergyStations = provincialEnergyStationsService.getProvincialEnergyStations();
        HashMap<String, String> hashMap = new HashMap<>();
        hashMap.put("resourcesOverview", provincialEnergyStations.getResourcesOverview());
        return hashMap;
    }

    //获取华电以及全省资源概况
    public ProvincialEnergyStations getProvincialEnergyStations() {
        return provincialEnergyStationsService.getProvincialEnergyStations();
    }

    //获取项目类别以及项目概况
    public HashMap<String, Object> getProjectSort() {
        HashMap<String, Object> dataMap = new HashMap<>();
        List<TotalityInfo> totalityInfos = totalityInfoService.selectTotalityInfoList();
        List<ProjectInfo> projectInfoList = projectInfoService.getProjectInfoList();
        //根据类别分组
        Map<String, List<ProjectInfo>> four = projectInfoList.stream()
                .filter(p -> !p.getProjectBasicInfo().getProjectSort().equals("four"))
                .collect(Collectors.groupingBy((ProjectInfo pro) -> {
                    return pro.getProjectBasicInfo().getProjectSort();
                }));
        //循环数据 存放Id和项目名称
        for (Map.Entry<String, List<ProjectInfo>> entry : four.entrySet()) {
            ArrayList<ProjectInfoDto> projectInfoDtoList = new ArrayList<>();
            for (ProjectInfo projectInfo : entry.getValue()) {
                ProjectInfoDto projectInfoDto = new ProjectInfoDto();
                projectInfoDto.setId(projectInfo.getId());
                projectInfoDto.setProjectSort(projectInfo.getProjectBasicInfo().getProjectName());
                projectInfoDtoList.add(projectInfoDto);
            }
            dataMap.put(entry.getKey(), projectInfoDtoList);
        }
        //项目基本信息
        dataMap.put("pInfo", totalityInfos.get(0).getPInfo());

        return dataMap;
    }

    //查询项目概况
    public HashMap<String, Object> projectMapInfo(String projectId) {
        HashMap<String, Object> dataMap = new HashMap<>();
        //获取项目信息
        List<ProjectInfo> projectInfoList = projectInfoService.getProjectInfoList();
        //根据项目ID过滤指定数据
        List<ProjectInfo> collect = projectInfoList.stream().filter(p -> p.getId().equals(projectId)).collect(Collectors.toList());
        //获取对应项目概述
        if (!collect.isEmpty()) {
            for (ProjectInfo projectInfo : collect) {
                dataMap.put("projectOverview", projectInfo.getProjectBasicInfo().getProjectOverview());
                dataMap.put("resourcesOverview", projectInfo.getProjectBasicInfo().getResourcesOverview());
//                if (projectInfo.getEquipment() != null && projectInfo.getEquipment().size() > 0) {
//                    dataMap.put("longitude", projectInfo.getEquipment().get(0).getLongitude());
//                    dataMap.put("latitude", projectInfo.getEquipment().get(0).getLatitude());
//                }
                if (StrUtil.isNotBlank(projectInfo.getProjectBasicInfo().getPosition())) {
                    String[] split = projectInfo.getProjectBasicInfo().getPosition().split(",");
                    dataMap.put("longitude", split[0]);
                    dataMap.put("latitude", split[1]);
                }
            }
        }
        return dataMap;
    }

    //地图点位坐标 （风机、测风塔、拐点）
    public HashMap<String, Object> getPointMap() {
        HashMap<String, Object> dataMap = new HashMap<>();
        //获取项目信息
        List<ProjectInfo> projectInfoList = projectInfoService.getProjectInfoList();
        //获取场站数据
        List<StationInfo> stationInfoList = stationInfoService.selectStationInfo();
        //循环所有项目于信息
        //测风塔List
        HashSet<Map<String, Object>> towerList = new HashSet<>();
        //拐点坐标List
        ArrayList<Map<String, List<List<Coordinates>>>> coordinateList = new ArrayList<>();
        //风机List
        List<HashMap<String, Object>> fanList = new ArrayList<>();
        // 环境监测仪
        List<Map<String, Object>> weatherList = new ArrayList<>();
        List<Map<String, Object>> inverterList = new ArrayList<>();
        HashSet<String> eqNoList = new HashSet<>();
        for (StationInfo stationInfo : stationInfoList) {
            if (stationInfo.getEquipment() != null && stationInfo.getEquipment().size() > 0) {
                //循环测风塔信息
                ArrayList<Map<String, Object>> arrayList = new ArrayList<>();
                for (Equipment equipment : stationInfo.getEquipment()) {
                    eqNoList.add(equipment.getEquipmentNo());
                    HashMap<String, Object> map = new HashMap<>();
                    map.put("type", "station");
                    map.put("longitude", equipment.getLongitude());
                    map.put("latitude", equipment.getLatitude());
                    map.put("towerName", equipment.getName());
                    map.put("towerNo", equipment.getEquipmentNo());
                    map.put("projectId", stationInfo.getId());
                    arrayList.add(map);
                }
                towerList.addAll(arrayList);
            }
            if (stationInfo.getFanTowerList() != null && stationInfo.getFanTowerList().size() > 0) {
                Map<String, List<FanTower>> collect = stationInfo.getFanTowerList().stream().collect(Collectors.groupingBy(FanTower::getFanModel));
                for (Map.Entry<String, List<FanTower>> entry : collect.entrySet()) {
                    HashMap<String, Object> map = new HashMap<>();
                    List<FanTower> collect1 = stationInfo.getFanTowerList().stream().filter(w -> w.getFanModel().equals(entry.getKey())).collect(Collectors.toList());
                    map.put("type", "station");
                    map.put("name", stationInfo.getStationBasicInfo().getStationName());
                    map.put("data", collect1);
                    fanList.add(map);
                }
            }
            if (stationInfo.getWeatherStationInfos() != null && stationInfo.getWeatherStationInfos().size() > 0) {
                ArrayList<Map<String, Object>> arrayList = new ArrayList<>();
                for (WeatherStationInfo weatherStationInfo : stationInfo.getWeatherStationInfos()) {
                    HashMap<String, Object> map = new HashMap<>();
                    map.put("type", "station");
                    map.put("longitude", weatherStationInfo.getLongitude());
                    map.put("latitude", weatherStationInfo.getLatitude());
                    map.put("name", weatherStationInfo.getName());
                    map.put("id", weatherStationInfo.getId());
                    map.put("stationId", stationInfo.getId());
                    arrayList.add(map);
                }
                weatherList.addAll(arrayList);
            }
            if (stationInfo.getInverterInfos() != null && stationInfo.getInverterInfos().size() > 0) {
                ArrayList<Map<String, Object>> arrayList = new ArrayList<>();
                HashMap<String, Object> map = new HashMap<>();
                map.put("type", "station");
                map.put("name", stationInfo.getStationBasicInfo().getStationName());
                map.put("data", stationInfo.getInverterInfos());
                arrayList.add(map);
                inverterList.addAll(arrayList);
            }
        }
        for (ProjectInfo projectInfo : projectInfoList) {
            Map<String, List<List<Coordinates>>> cmap = new HashMap<>();
            cmap.put(projectInfo.getProjectBasicInfo().getProjectNameEasy(), projectInfo.getCoordinates());
            //拐点坐标
            coordinateList.add(cmap);

            if (projectInfo.getEquipment() != null && projectInfo.getEquipment().size() > 0) {
                //循环测风塔信息
                for (Equipment equipment : projectInfo.getEquipment()) {
                    HashMap<String, Object> map = new HashMap<>();
                    eqNoList.add(equipment.getEquipmentNo());
                    map.put("type", "project");
                    map.put("longitude", equipment.getLongitude());
                    map.put("latitude", equipment.getLatitude());
                    map.put("towerName", equipment.getName());
                    map.put("towerNo", equipment.getEquipmentNo());
                    map.put("projectId", projectInfo.getId());
                    towerList.add(map);
                }
            }
            if (projectInfo.getFanTowerList() != null && projectInfo.getFanTowerList().size() > 0) {
                HashMap<String, Object> map = new HashMap<>();
                map.put("type", "project");
                map.put("name", projectInfo.getProjectBasicInfo().getProjectName());
                map.put("data", projectInfo.getFanTowerList());
                fanList.add(map);
            }
        }


        dataMap.put("coordinatesList", coordinateList);


        List<Map<String, Object>> listMap = new ArrayList<>();
        //利用塔编号过滤分组项目以及场站的id
        for (String s : eqNoList) {
            ArrayList<Object> arrayList = new ArrayList<>();
            List<Map<String, Object>> towerNo = towerList.stream().filter(key -> key.get("towerNo").equals(s)).collect(Collectors.toList());
            //有多条只添加一个其他都是一样的只需要替换id 多余的需要删除
            for (Map<String, Object> map : towerNo) {
                HashMap<Object, Object> hashMap1 = new HashMap<>();
                hashMap1.put("type", map.get("type"));
                if (map.containsKey("projectId")) {
                    hashMap1.put("id", map.get("projectId"));
                    arrayList.add(hashMap1);
                }
            }
            //替换id值
            towerNo.get(0).put("projectId", arrayList);
            listMap.add(towerNo.get(0));
        }

        dataMap.put("towerList", listMap);
        dataMap.put("fan", fanList);
        dataMap.put("weather", weatherList);
        dataMap.put("inverter", inverterList);
        return dataMap;
    }


    /**
     * 项目测风塔下拉框(mongo)
     *
     * @return List<SelectLabForVal>
     */
//    public List<SelectLabForVal> projectSelect() {
//        List<ProjectInfo> projectInfoList = projectInfoService.getProjectInfoList();
//        ArrayList<SelectLabForVal> selectList = new ArrayList<>();
//        if (projectInfoList.size() > 0) {
//            //循环数据 放入项目id和项目名称
//            for (ProjectInfo projectInfo : projectInfoList) {
//                SelectLabForVal selectLabForVal = new SelectLabForVal();
//                selectLabForVal.setLabel(projectInfo.getProjectBasicInfo().getProjectNameEasy());
//                selectLabForVal.setValue(projectInfo.getId());
//                if (projectInfo.getEquipment().size() > 0) {
//                    ArrayList<EquipmentDto> equipmentDtoList = new ArrayList<>();
//                    //循环数据 放入测风塔id和测风塔名称
//                    for (Equipment equipment : projectInfo.getEquipment()) {
//                        EquipmentDto equipmentDto = new EquipmentDto();
//                        equipmentDto.setLabel(equipment.getName());
//                        equipmentDto.setValue(equipment.getEquipmentNo());
//                        equipmentDto.setWdHeight(equipment.getWdHeights());
//                        equipmentDto.setType(equipment.getType());
//                        equipmentDtoList.add(equipmentDto);
//                    }
//                    selectLabForVal.setEquipmentDto(equipmentDtoList);
//                }
//                selectList.add(selectLabForVal);
//            }
//
//        }
//
//        return selectList;
//    }


    /**
     * 项目测风塔下拉框
     *
     * @return List<SelectLabForVal>
     */
    public List<SelectLabForVal> projectSelect() {

        List<Project> projectList = projectService.list();
        List<WindTowerInfo> windTowerInfoList = windTowerInfoService.getAllWindTower();

        ArrayList<SelectLabForVal> selectList = new ArrayList<>();
        for (Project project : projectList) {
            SelectLabForVal selectLabForVal = new SelectLabForVal();
            selectLabForVal.setLabel(project.getProjectNameEasy());
            selectLabForVal.setValue(project.getId());
            ArrayList<EquipmentDto> equipmentDtoList = new ArrayList<>();
            EquipmentDto equipmentDto = new EquipmentDto();
            if(project.getRelationEquipment().contains(",")){
                String[] equipments = project.getRelationEquipment().split(",");
                for (String equipment : equipments) {
                    equipmentDto = new EquipmentDto();
                    List<WindTowerInfo> windTowerInfos = windTowerInfoList.stream().filter(w -> w.getEquipmentNo().equals(equipment)).collect(Collectors.toList());
                    equipmentDto.setLabel(windTowerInfos.get(0).getName());
                    equipmentDto.setValue(equipment);
                    equipmentDto.setWdHeight(windTowerInfos.get(0).getWdHeights());
                    equipmentDto.setType(windTowerInfos.get(0).getType());
                    equipmentDtoList.add(equipmentDto);
                }
            }else{
                List<WindTowerInfo> windTowerInfos = windTowerInfoList.stream().filter(w -> w.getEquipmentNo().equals(project.getRelationEquipment())).collect(Collectors.toList());
                equipmentDto.setLabel(windTowerInfos.get(0).getName());
                equipmentDto.setValue(project.getRelationEquipment());
                equipmentDto.setWdHeight(windTowerInfos.get(0).getWdHeights());
                equipmentDto.setType(windTowerInfos.get(0).getType());
                equipmentDtoList.add(equipmentDto);
            }
            selectLabForVal.setEquipmentDto(equipmentDtoList);
            selectLabForVal.setWeatherStationInfo(new ArrayList<>());
            selectList.add(selectLabForVal);
        }

        return selectList;
    }

    //查询场站信息以及场站列表
    public HashMap<String, Object> getStationTotalityInfo() {
        //总体信息
        List<TotalityInfo> totalityInfos = totalityInfoService.selectTotalityInfoList();
        //场站信息
        List<StationInfo> stationInfos = stationInfoService.selectStationInfo();
        HashMap<String, Object> stationMap = new HashMap<>();
        if (totalityInfos.size() > 0) {
            stationMap.put("fInfo", totalityInfos.get(0).getFInfo());
            stationMap.put("gInfo", totalityInfos.get(0).getGInfo());
            if (stationInfos.size() > 0) {
                ArrayList<Object> arrayList = new ArrayList<>();
                for (StationInfo stationInfo : stationInfos) {
                    HashMap<String, Object> hashMap = new HashMap<>();
                    hashMap.put("id", stationInfo.getId());
                    hashMap.put("stationName", stationInfo.getStationBasicInfo().getStationName());
                    //经度
                    hashMap.put("longitude", stationInfo.getStationBasicInfo().getLongitude());
                    //纬度
                    hashMap.put("latitude", stationInfo.getStationBasicInfo().getLatitude());
                    hashMap.put("type", stationInfo.getStationBasicInfo().getStationType());
                    arrayList.add(hashMap);
                }
                stationMap.put("station", arrayList);
            }
        }
        return stationMap;
    }

    /**
     * 查询所有的场站坐标
     */
    public HashMap<String, Object> getStationSeat() {
        HashMap<String, Object> dataMap = new HashMap<>();
        List<OtherStationInfo> otherStationInfoList = otherStationInfoService.selectOtherStationInfo();
        List<StationInfo> stationInfos = stationInfoService.selectStationInfo();
        ArrayList<HashMap<String, Object>> stationList = new ArrayList<>();
        for (StationInfo stationInfo : stationInfos) {
            HashMap<String, Object> hashMap = new HashMap<>();
            hashMap.put("id", stationInfo.getId());
            hashMap.put("stationName", stationInfo.getStationBasicInfo().getStationName());
            //经度
            hashMap.put("longitude", stationInfo.getStationBasicInfo().getLongitude());
            //纬度
            hashMap.put("latitude", stationInfo.getStationBasicInfo().getLatitude());
            hashMap.put("type", stationInfo.getStationBasicInfo().getStationType());
            stationList.add(hashMap);
        }
        ArrayList<HashMap<String, Object>> otherStationList = new ArrayList<>();
        for (OtherStationInfo otherStationInfo : otherStationInfoList) {
            if (otherStationInfo.getStationType().equals("风")) {//目前只要风
                HashMap<String, Object> hashMap = new HashMap<>();
                hashMap.put("id", otherStationInfo.getId());
                hashMap.put("stationName", otherStationInfo.getStationName());
                //经度
                hashMap.put("longitude", otherStationInfo.getLongitude());
                //纬度
                hashMap.put("latitude", otherStationInfo.getLatitude());
                hashMap.put("type", otherStationInfo.getStationType());
                otherStationList.add(hashMap);
            }
        }
        dataMap.put("HDStation", stationList);
        dataMap.put("otherStation", otherStationList);

        return dataMap;
    }

    /**
     * 查询所有的项目坐标
     */
    public ArrayList<Object> getProjectSeat() {
        ArrayList<Object> arrayList = new ArrayList<>();
        //获取项目信息
        List<ProjectInfo> projectInfoList = projectInfoService.getProjectInfoList();
        for (ProjectInfo projectInfo : projectInfoList) {
            HashMap<String, Object> map = new HashMap<>();
            if (StrUtil.isNotBlank(projectInfo.getProjectBasicInfo().getPosition())) {
                map.put("id", projectInfo.getId());
                map.put("projectNameEasy", projectInfo.getProjectBasicInfo().getProjectNameEasy());
                map.put("projectName", projectInfo.getProjectBasicInfo().getProjectName());
                String[] split = projectInfo.getProjectBasicInfo().getPosition().split(",");
                map.put("longitude", split[0]);
                map.put("latitude", split[1]);
                map.put("type", projectInfo.getProjectBasicInfo().getProjectType());
            }
//            if (projectInfo.getEquipment() != null && projectInfo.getEquipment().size() > 0) {
//
//            }
            arrayList.add(map);
        }
        return arrayList;
    }

    /**
     * 查询场站详细信息（风机、机型等）
     */
    public HashMap<String, Object> getStationInfo(String stationId) {
        //场站信息
        List<StationInfo> stationInfos = stationInfoService.selectStationInfo();
        List<StationInfo> stationInfoList = stationInfos.stream().filter(s -> s.getId().equals(stationId)).collect(Collectors.toList());
        List<FanModelData> fanModelDataList = fanModelDataService.getFanModelDataList();
        //过滤
        List<FanModelData> collect = fanModelDataList.stream().filter(f -> f.getStationId().equals(stationId)).collect(Collectors.toList());

        HashMap<String, Object> dataMap = new HashMap<>();
        if (stationInfoList.size() > 0) {
            ArrayList<HashMap<String, Object>> arrayList = new ArrayList<>();
            if (stationInfoList.get(0).getStationBasicInfo().getStationType().equals("风")) {
                //根据风机类型分组
                Map<String, List<FanTower>> modelMap = stationInfoList.get(0).getFanTowerList().stream()
                        .collect(Collectors.groupingBy(FanTower::getFanModel));
                //遍历map指定key
                for (Map.Entry<String, List<FanTower>> entry : modelMap.entrySet()) {
                    dataPag(collect, entry.getKey(), entry.getValue().size(), arrayList);
                }
            } else {
                //根据逆变器类型分组
                Map<String, List<InverterInfo>> modelMap = stationInfoList.get(0).getInverterInfos().stream()
                        .collect(Collectors.groupingBy(InverterInfo::getModelNumber));

                //遍历map指定key
                for (Map.Entry<String, List<InverterInfo>> entry : modelMap.entrySet()) {
                    dataPag(collect, entry.getKey(), entry.getValue().size(), arrayList);

                }
            }
            //过滤塔信息
            StationInfo stationInfo = stationInfoList.get(0);
            dataMap.put("longitude", stationInfo.getStationBasicInfo().getLongitude());
            dataMap.put("latitude", stationInfo.getStationBasicInfo().getLatitude());

            dataMap.put("modelT", arrayList);
        }
        return dataMap;
    }

    //组装数据
    public void dataPag(List<FanModelData> collect, String key, int size, ArrayList<HashMap<String, Object>> arrayList) {
        for (FanModelData fanModelData : collect) {
            if (fanModelData.getModelName().equals(key)) {
                HashMap<String, Object> map = new HashMap<>();
                //风机名称
                map.put("modelType", key);
                //风机数量
                map.put("modelTotal", size);
                //平均风速
                map.put("wsAve", fanModelData.getWsAve());
                //主风向
                map.put("wdSum", fanModelData.getWdSum());
                //发电量
                map.put("generatingCapacity", fanModelData.getGeneratingCapacity());
                //等效小时数
                map.put("realTimeTotal", size == 0 ? 0 : fanModelData.getRealTimeTotal());
                arrayList.add(map);

            }
        }
    }

    /**
     * 风场站测风塔下拉框
     *
     * @return List<SelectLabForVal>
     */
    public List<SelectLabForVal> stationSelect() {
        List<StationInfo> stationInfos = stationInfoService.selectStationInfo();
        List<StationInfo> stationInfoList = stationInfos.stream().filter(w -> w.getStationBasicInfo().getStationType().equals("风")).collect(Collectors.toList());
        ArrayList<SelectLabForVal> selectList = new ArrayList<>();
        if (stationInfoList.size() > 0) {
            //循环数据 放入项目id和项目名称
            for (StationInfo stationInfo : stationInfoList) {
                SelectLabForVal selectLabForVal = new SelectLabForVal();
                selectLabForVal.setLabel(stationInfo.getStationBasicInfo().getStationName());
                selectLabForVal.setValue(stationInfo.getId());
                if (stationInfo.getEquipment().size() > 0) {
                    ArrayList<EquipmentDto> equipmentDtoList = new ArrayList<>();
                    //循环数据 放入测风塔id和测风塔名称
                    for (Equipment equipment : stationInfo.getEquipment()) {
                        EquipmentDto equipmentDto = new EquipmentDto();
                        equipmentDto.setLabel(equipment.getName());
                        equipmentDto.setValue(equipment.getEquipmentNo());
                        equipmentDto.setWdHeight(equipment.getWdHeights());
                        equipmentDto.setType(equipment.getType());
                        equipmentDtoList.add(equipmentDto);
                    }
                    selectLabForVal.setEquipmentDto(equipmentDtoList);
                }
                selectList.add(selectLabForVal);
            }

        }

        return selectList;
    }
    /**
     * 光场站测风塔下拉框
     *
     * @return List<SelectLabForVal>
     */
    public List<SelectLabForVal> gStationSelect() {
        List<StationInfo> stationInfos = stationInfoService.selectStationInfo();
        List<StationInfo> stationInfoList = stationInfos.stream().filter(w -> w.getStationBasicInfo().getStationType().equals("光")).collect(Collectors.toList());
        ArrayList<SelectLabForVal> selectList = new ArrayList<>();
        if (stationInfoList.size() > 0) {
            //循环数据 放入项目id和项目名称
            for (StationInfo stationInfo : stationInfoList) {
                SelectLabForVal selectLabForVal = new SelectLabForVal();
                selectLabForVal.setLabel(stationInfo.getStationBasicInfo().getStationName());
                selectLabForVal.setValue(stationInfo.getId());
                if (stationInfo.getWeatherStationInfos() !=null && stationInfo.getWeatherStationInfos().size() > 0) {
                    ArrayList<WeatherStationInfo> weatherStationList = new ArrayList<>();
                    //循环数据 放入测风塔id和测风塔名称
                    for (WeatherStationInfo weatherStationInfo : stationInfo.getWeatherStationInfos()) {
                        weatherStationList.add(weatherStationInfo);
                    }
                    selectLabForVal.setWeatherStationInfo(weatherStationList);
                }
                selectList.add(selectLabForVal);
            }
        }
        return selectList;
    }

    //项目进展
    public List<ProjectEvolveDto> getProjectEvolve(String projectId) {
        //查询项目进展信息
        List<ProjectProgress> projectProgresses = proProjectInfoService.selectProProjectInfo();
        //根据项目id筛选数据
        List<ProjectProgress> progressList = projectProgresses.stream().filter(p -> p.getProjectId().equals(projectId)).collect(Collectors.toList());
        ArrayList<ProjectEvolveDto> projectEvolveList = new ArrayList<>();
        if (progressList.size() > 0) {
            //循环项目进展信息 一般只有一条
            for (ProjectProgress progress : progressList) {
                if (progress.getProjectMenusOneList().size() > 0) {
                    //循环一级菜单
                    for (ProjectMenusOne menusOne : progress.getProjectMenusOneList()) {
                        ProjectEvolveDto projectEvolveDtoOne = new ProjectEvolveDto();
                        //一级菜单
                        projectEvolveDtoOne.setIndex(menusOne.getIndex());
                        projectEvolveDtoOne.setTaskContent(menusOne.getWorkContent());
                        projectEvolveDtoOne.setPlanTime(menusOne.getPlanTime());
                        if (menusOne.getProjectMenusTows().size() > 0 && menusOne.getProjectMenusTows().get(0).getIndex().equals("")) {
                            if (menusOne.getProjectMenusTows().get(0).getProjectMenusThreeList().size() > 0) {
                                //设置三级详细工作内容
                                projectEvolveDtoOne.setDetailedTaskContent(menusOne.getProjectMenusTows().get(0).getProjectMenusThreeList().get(0).getWorkContent());
                                //设置三级实际完成时间
                                projectEvolveDtoOne.setRealTime(menusOne.getProjectMenusTows().get(0).getProjectMenusThreeList().get(0).getRealTime());
                                //设置备注
                                projectEvolveDtoOne.setStatus(menusOne.getProjectMenusTows().get(0).getProjectMenusThreeList().get(0).getRemark());
                                projectEvolveList.add(projectEvolveDtoOne);
                            }
                        } else {
                            projectEvolveList.add(projectEvolveDtoOne);
                            if (menusOne.getProjectMenusTows() != null && menusOne.getProjectMenusTows().size() > 0) {
                                //循环二级菜单
                                for (ProjectMenusTow menusTow : menusOne.getProjectMenusTows()) {
                                    if (menusTow.getProjectMenusThreeList() != null && menusTow.getProjectMenusThreeList().size() > 0) {
                                        //循环三级菜单
                                        for (ProjectMenusThree menusThree : menusTow.getProjectMenusThreeList()) {
                                            ProjectEvolveDto projectEvolveDto = new ProjectEvolveDto();
                                            //放入二级序号
                                            projectEvolveDto.setIndex(menusTow.getIndex());
                                            //放入二级计划时间
                                            projectEvolveDto.setPlanTime(menusTow.getPlanTime());
                                            //放入二级工作内容
                                            projectEvolveDto.setTaskContent(menusTow.getWorkContent());
                                            //详细工作信息 三级工作内容
                                            projectEvolveDto.setDetailedTaskContent(menusThree.getWorkContent());
                                            //实际完成时间 三级时间
                                            projectEvolveDto.setRealTime(menusThree.getRealTime());
                                            //放入状态 三级备注
                                            projectEvolveDto.setStatus(menusThree.getRemark());
                                            projectEvolveList.add(projectEvolveDto);
                                        }
                                    } else {
                                        ProjectEvolveDto projectEvolveDto = new ProjectEvolveDto();
                                        projectEvolveDto.setIndex(menusTow.getIndex());
                                        projectEvolveDto.setTaskContent(menusTow.getWorkContent());
                                        projectEvolveDto.setPlanTime(menusTow.getPlanTime());
                                        projectEvolveList.add(projectEvolveDto);
                                    }
                                }
                            }
                        }

                    }
                }

            }
        }
        return projectEvolveList;

    }


}