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

package com.jiayue.biz.service.impl;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.lang.TypeReference;
import cn.hutool.db.Entity;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
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.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.CommonUtil;
import com.jiayue.biz.util.DateTimeUtil;
import com.jiayue.biz.util.FileUtil;
import com.jiayue.common.utils.DateUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.sql.Timestamp;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 测风塔父表数据Service业务层处理
 *
 * @author whc
 * @date 2022-08-04
 */
@Slf4j
@Service
public class WindTowerDataParentTableServiceImpl extends ServiceImpl<WindTowerDataParentTableMapper, WindTowerDataParentTable> implements WindTowerDataParentTableService {

    @Autowired
    WindTowerDataChildTableService windTowerDataChildTableService;
    @Autowired
    EquipmentAttributeServiceImpl equipmentAttributeService;
    @Autowired
    WindTowerInfoServiceImpl windTowerInfoService;
    @Autowired
    AnalysisLogServiceImpl analysisLogService;
    @Autowired
    DisplayConfigServiceImpl displayConfigService;

    @Autowired
    ProphaseAnemometryDataOrgService prophaseAnemometryDataOrgService;

    @Autowired
    ProphaseWeatherDataOrgService prophaseWeatherDataOrgService;
    @Autowired
    ProphaseAnemometryDataService prophaseAnemometryDataService;

    @Autowired
    ProphaseWeatherDataService prophaseWeatherDataService;


    /**
     * 组装数据
     *
     * @param allData     数据
     * @param equipmentId 设备编号
     * @param type        文件类型
     * @param operation   操作类型(DataRecalculation数据重算)
     */
    public void packageData(List<Map<String, Object>> allData, String equipmentId, String type, String operation) {

        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
        if (type.equals("rld") || type.equals("dat")) {
            simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        }
        if (type.equals("sld")) {
            simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmm");
        }
        if (type.equals("eol")) {
            simpleDateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm");
        }
        String eqNo = equipmentId;
        List<WindTowerInfo> windTowerInfoList = windTowerInfoService.list();
        List<WindTowerInfo> windTowerInfo = windTowerInfoList.stream().filter(w -> w.getEquipmentNo().equals(eqNo)).collect(Collectors.toList());
        String windTowerInfoHeights = windTowerInfo.get(0).getHeights();
        String windTowerInfoWdHeights = windTowerInfo.get(0).getWdHeights();
        String[] wdHeight = windTowerInfoWdHeights.split(",");
        String[] heights = windTowerInfoHeights.split(",");
        HashSet<String> heightAll = new HashSet<>();
        heightAll.addAll(Arrays.asList(wdHeight));
        heightAll.addAll(Arrays.asList(heights));
        //层高
//        ArrayList<ProphaseAnemometryData> prophaseAnemometryDataArrayList = new ArrayList<>();
//        ArrayList<ProphaseWeatherData> prophaseAnemometryPublicDataArrayList = new ArrayList<>();
        try {
            //所有数据
            for (Map<String, Object> m : allData) {
                if (!operation.equals("DataRecalculation")) {
                    this.packageOrgData(m, heightAll, simpleDateFormat, eqNo, "org");
                }
                //异常数据赋值为-99
                if (m.get("abnormalType") != null) {
                    if (m.get("abnormalType").toString().contains(",")) {
                        String[] abnormalTypes = m.get("abnormalType").toString().split(",");
                        for (String abnormalType : abnormalTypes) {
                            m.put(abnormalType, -99f);
                        }
                    } else {
                        m.put(m.get("abnormalType").toString(), -99f);
                    }
                }
                this.packageOrgData(m, heightAll, simpleDateFormat, eqNo, "noOrg");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    public void packageOrgData(Map<String, Object> m, HashSet<String> heightAll, SimpleDateFormat simpleDateFormat, String equipmentId, String org) {
        for (String height : heightAll) {
            ProphaseAnemometryData one = new ProphaseAnemometryData();
            //组装子表数据
            one.setWsAve(m.get("wsAve_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wsAve_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWsMin(m.get("wsMin_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wsMin_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWsMax(m.get("wsMax_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wsMax_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWsSta(m.get("wsSta_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wsSta_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWsInst(m.get("wsInst_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wsInst_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWdAve(m.get("wdAve_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wdAve_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWdMax(m.get("wdMax_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wdMax_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWdMin(m.get("wdMin_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wdMin_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWdSta(m.get("wdSta_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wdSta_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setWdInst(m.get("wdInst_" + height) == null ? null : CalculationUtil.getBigDecimal(m.get("wdInst_" + height)).setScale(2, RoundingMode.HALF_UP).floatValue());
            one.setLayerHeight(height);
            one.setEquipmentId(equipmentId);
            if (m.get("time") != null) {
                try {
                    try {
                        one.setTs(new Timestamp(simpleDateFormat.parse(m.get("time").toString()).getTime()));
                    } catch (ParseException e) {
                        one.setTs(new Timestamp(new Date(Long.parseLong(m.get("time").toString())).getTime()));
                    }

                } catch (Exception e) {
                    log.error("时间转换异常:" + e);
                }
            }
            if (org.equals("org")) {
                prophaseAnemometryDataOrgService.insertOneWithNew(one);
            } else {
                prophaseAnemometryDataService.insertOneWithNew(one);
            }
        }

        ProphaseWeatherData prophaseAnemometryPublicData = new ProphaseWeatherData();
        prophaseAnemometryPublicData.setEquipmentId(equipmentId);
        if (m.get("paMax") != null)
            //kpa转hpa
            if (BigDecimal.valueOf(Double.parseDouble(m.get("paMax").toString())).compareTo(new BigDecimal(200)) < 0)
                prophaseAnemometryPublicData.setPaMax(CalculationUtil.getBigDecimal(m.get("paMax").toString()).multiply(new BigDecimal(10)).setScale(2, RoundingMode.HALF_UP).floatValue());
            else
                prophaseAnemometryPublicData.setPaMax(CalculationUtil.getBigDecimal(m.get("paMax").toString()).floatValue());
        if (m.get("paMin") != null)
            //kpa转hpa
            if (BigDecimal.valueOf(Double.parseDouble(m.get("paMin").toString())).compareTo(new BigDecimal(200)) < 0)
                prophaseAnemometryPublicData.setPaMin(CalculationUtil.getBigDecimal(m.get("paMin").toString()).multiply(new BigDecimal(10)).setScale(2, RoundingMode.HALF_UP).floatValue());
            else
                prophaseAnemometryPublicData.setPaMin(CalculationUtil.getBigDecimal(m.get("paMin").toString()).floatValue());
        if (m.get("paAve") != null)
            //kpa转hpa
            if (BigDecimal.valueOf(Double.parseDouble(m.get("paAve").toString())).compareTo(new BigDecimal(200)) < 0)
                prophaseAnemometryPublicData.setPaAve(CalculationUtil.getBigDecimal(m.get("paAve").toString()).multiply(new BigDecimal(10)).setScale(2, RoundingMode.HALF_UP).floatValue());
            else
                prophaseAnemometryPublicData.setPaAve(CalculationUtil.getBigDecimal(m.get("paAve").toString()).floatValue());
        prophaseAnemometryPublicData.setPaSta(m.get("paSta") == null ? null : CalculationUtil.getBigDecimal(m.get("paSta")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setTMax(m.get("tMax") == null ? null : CalculationUtil.getBigDecimal(m.get("tMax")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setTMin(m.get("tMin") == null ? null : CalculationUtil.getBigDecimal(m.get("tMin")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setTAve(m.get("tAve") == null ? null : CalculationUtil.getBigDecimal(m.get("tAve")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setTSta(m.get("tSta") == null ? null : CalculationUtil.getBigDecimal(m.get("tSta")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setRhMax(m.get("rhMax") == null ? null : CalculationUtil.getBigDecimal(m.get("rhMax")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setRhMin(m.get("rhMin") == null ? null : CalculationUtil.getBigDecimal(m.get("rhMin")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setRhAve(m.get("rhAve") == null ? null : CalculationUtil.getBigDecimal(m.get("rhAve")).setScale(2, RoundingMode.HALF_UP).floatValue());
        prophaseAnemometryPublicData.setRhSta(m.get("rhSta") == null ? null : CalculationUtil.getBigDecimal(m.get("rhSta")).setScale(2, RoundingMode.HALF_UP).floatValue());
        //计算空气密度  1.293*(273/(273+温度摄氏度))*气压百帕/1013
        if (prophaseAnemometryPublicData.getTAve() != null && prophaseAnemometryPublicData.getPaAve() != null &&
                prophaseAnemometryPublicData.getTAve() != -99 && prophaseAnemometryPublicData.getPaAve() > 0) {
            BigDecimal airDensity = BigDecimal.valueOf(1.293).multiply(new BigDecimal(273).divide(new BigDecimal(273).add(BigDecimal.valueOf(prophaseAnemometryPublicData.getTAve())), 2, RoundingMode.HALF_UP)).multiply(BigDecimal.valueOf(prophaseAnemometryPublicData.getPaAve())).divide(new BigDecimal(1013), 2, RoundingMode.HALF_UP);
            prophaseAnemometryPublicData.setAirDensity(airDensity.floatValue());
        } else {
            //随机数 上限1.28 下限1.15
            Random random = new Random();
            int randNumber = random.nextInt(128 - 115 + 1) + 115;
            BigDecimal air = BigDecimal.valueOf(randNumber).divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP);
            prophaseAnemometryPublicData.setAirDensity(air.floatValue());
        }
        if (m.get("time") != null) {
            try {
                try {
                    prophaseAnemometryPublicData.setTs(new Timestamp(simpleDateFormat.parse(m.get("time").toString()).getTime()));
                } catch (ParseException e) {
                    prophaseAnemometryPublicData.setTs(new Timestamp(new Date(Long.parseLong(m.get("time").toString())).getTime()));
                }

            } catch (Exception e) {
                log.error("时间转换异常:" + e);
            }
        }

        if (org.equals("org")) {
            prophaseWeatherDataOrgService.insertOne(prophaseAnemometryPublicData);
        } else {
            prophaseWeatherDataService.insertOne(prophaseAnemometryPublicData);
        }
    }

    /**
     * 组装数据
     *
     * @param allData     数据
     * @param equipmentId 设备编号
     * @param eTime       时间
     * @param type        文件类型
     * @param operation   操作类型(DataRecalculation数据重算)
     */
    public void packageData1(List<Map<String, Object>> allData, String equipmentId, String eTime, String type, String operation) {

        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
        if (type.equals("rld")) {
            simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        }
        if (type.equals("sld")) {
            simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmm");
        }
        String eqNo = equipmentId;
        List<EquipmentAttribute> equipmentAttributeList = equipmentAttributeService.list();
        List<EquipmentAttribute> heightList = equipmentAttributeList.stream().filter(e -> "height".equals(e.getAttributeFunction())).collect(Collectors.toList());
        List<WindTowerInfo> windTowerInfoList = windTowerInfoService.getAllWindTower();
        List<WindTowerInfo> windTowerInfo = windTowerInfoList.stream().filter(w -> w.getEquipmentNo().equals(eqNo)).collect(Collectors.toList());
        String windTowerInfoHeights = windTowerInfo.get(0).getHeights();
        String windTowerInfoWdHeights = windTowerInfo.get(0).getWdHeights();
        String[] wdHeight = windTowerInfoWdHeights.split(",");
        String[] heights = windTowerInfoHeights.split(",");
        HashSet<String> heightAll = new HashSet<>();
        heightAll.addAll(Arrays.asList(wdHeight));
        heightAll.addAll(Arrays.asList(heights));
        //层高
        List<WindTowerDataParentTable> windTowerDataParentTableList = new ArrayList<>();
        List<WindTowerDataChildTable> windTowerDataChildTableList = new ArrayList<>();

        try {
            //所有数据
            if (operation.equals("DataRecalculation")) {
                for (Map<String, Object> m : allData) {
                    WindTowerDataParentTable windTowerDataParentTable = new WindTowerDataParentTable();
                    UUID uuid = UUID.randomUUID();
                    for (String height : heightAll) {
                        //层高对应的属性
                        List<EquipmentAttribute> eqHeight = heightList.stream().filter(h -> height.equals(h.getFieldName())).collect(Collectors.toList());
                        //组装子表数据
                        WindTowerDataChildTable windTowerDataChildTable = new WindTowerDataChildTable();
                        windTowerDataChildTable.setParentId(uuid.toString());
                        windTowerDataChildTable.setLayerHeight(eqHeight.get(0).getId());
                        windTowerDataChildTable.setWsAve(CalculationUtil.getBigDecimal(m.get("ws_ave" + height) == null ? null : m.get("ws_ave" + height).toString()));
                        windTowerDataChildTable.setWsMin(CalculationUtil.getBigDecimal(m.get("ws_min" + height) == null ? null : m.get("ws_min" + height).toString()));
                        windTowerDataChildTable.setWsMax(CalculationUtil.getBigDecimal(m.get("ws_max" + height) == null ? null : m.get("ws_max" + height).toString()));
                        windTowerDataChildTable.setWsSta(CalculationUtil.getBigDecimal(m.get("ws_sta" + height) == null ? null : m.get("ws_sta" + height).toString()));
                        windTowerDataChildTable.setWdAve(CalculationUtil.getBigDecimal(m.get("wd_ave" + height) == null ? null : m.get("wd_ave" + height).toString()));
                        windTowerDataChildTable.setWdMax(CalculationUtil.getBigDecimal(m.get("wd_max" + height) == null ? null : m.get("wd_max" + height).toString()));
                        windTowerDataChildTable.setWdMin(CalculationUtil.getBigDecimal(m.get("wd_min" + height) == null ? null : m.get("wd_min" + height).toString()));
                        windTowerDataChildTable.setWdSta(CalculationUtil.getBigDecimal(m.get("wd_sta" + height) == null ? null : m.get("wd_sta" + height).toString()));
                        windTowerDataChildTableList.add(windTowerDataChildTable);
                    }
                    //组装父表数据
                    windTowerDataParentTable.setEquipmentId(equipmentId);
                    windTowerDataParentTable.setId(uuid.toString());
                    if (m.get("time") != null)
                        try {
                            try {
                                windTowerDataParentTable.setTime(simpleDateFormat.parse(m.get("time").toString()));
                            } catch (ParseException e) {

                                windTowerDataParentTable.setTime(new Date(Long.parseLong(m.get("time").toString())));
                            }

                        } catch (Exception e) {
                            log.error("时间转换异常:" + e);
                        }

                    if (m.get("paMax") != null)
                        //kpa转hpa
                        if (BigDecimal.valueOf(Double.parseDouble(m.get("pa_max").toString())).compareTo(new BigDecimal(200)) < 0)
                            windTowerDataParentTable.setPaMax(CalculationUtil.getBigDecimal(m.get("pa_max").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
                        else
                            windTowerDataParentTable.setPaMax(CalculationUtil.getBigDecimal(m.get("pa_max").toString()));
                    if (m.get("pa_min") != null)
                        //kpa转hpa
                        if (BigDecimal.valueOf(Double.parseDouble(m.get("pa_min").toString())).compareTo(new BigDecimal(200)) < 0)
                            windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(m.get("pa_min").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
                        else
                            windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(m.get("pa_min").toString()));
                    if (m.get("pa_ave") != null)
                        //kpa转hpa
                        if (BigDecimal.valueOf(Double.parseDouble(m.get("pa_ave").toString())).compareTo(new BigDecimal(200)) < 0)
                            windTowerDataParentTable.setPaAve(CalculationUtil.getBigDecimal(m.get("pa_ave").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
                        else
                            windTowerDataParentTable.setPaAve(CalculationUtil.getBigDecimal(m.get("pa_ave").toString()));
                    windTowerDataParentTable.setPaSta(CalculationUtil.getBigDecimal(m.get("pa_sta") == null ? null : m.get("pa_sta").toString()));
                    windTowerDataParentTable.setTMax(CalculationUtil.getBigDecimal(m.get("t_max") == null ? null : m.get("t_max").toString()));
                    windTowerDataParentTable.setTMin(CalculationUtil.getBigDecimal(m.get("t_min") == null ? null : m.get("t_min").toString()));
                    windTowerDataParentTable.setTAve(CalculationUtil.getBigDecimal(m.get("t_ave") == null ? null : m.get("t_ave").toString()));
                    windTowerDataParentTable.setTSta(CalculationUtil.getBigDecimal(m.get("t_sta") == null ? null : m.get("t_sta").toString()));
                    windTowerDataParentTable.setRhMax(CalculationUtil.getBigDecimal(m.get("rh_max") == null ? null : m.get("rh_max").toString()));
                    windTowerDataParentTable.setRhMin(CalculationUtil.getBigDecimal(m.get("rh_min") == null ? null : m.get("rh_min").toString()));
                    windTowerDataParentTable.setRhAve(CalculationUtil.getBigDecimal(m.get("rh_ave") == null ? null : m.get("rh_ave").toString()));
                    windTowerDataParentTable.setRhSta(CalculationUtil.getBigDecimal(m.get("rh_sta") == null ? null : m.get("rh_sta").toString()));
                    windTowerDataParentTable.setAbnormalData(m.get("abnormalData") == null ? null : m.get("abnormalData").toString());
                    windTowerDataParentTable.setAbnormalType(m.get("abnormalType") == null ? null : m.get("abnormalType").toString());
                    windTowerDataParentTableList.add(windTowerDataParentTable);
                }
            } else {
                for (Map<String, Object> m : allData) {
                    WindTowerDataParentTable windTowerDataParentTable = new WindTowerDataParentTable();
                    UUID uuid = UUID.randomUUID();
                    for (String height : heightAll) {
                        //层高对应的属性
                        List<EquipmentAttribute> eqHeight = heightList.stream().filter(h -> height.equals(h.getFieldName())).collect(Collectors.toList());
                        //组装子表数据
                        WindTowerDataChildTable windTowerDataChildTable = new WindTowerDataChildTable();
                        windTowerDataChildTable.setParentId(uuid.toString());
                        windTowerDataChildTable.setLayerHeight(eqHeight.get(0).getId());
                        windTowerDataChildTable.setWsAve(CalculationUtil.getBigDecimal(m.get("wsAve_" + height) == null ? null : m.get("wsAve_" + height).toString()));
                        windTowerDataChildTable.setWsMin(CalculationUtil.getBigDecimal(m.get("wsMin_" + height) == null ? null : m.get("wsMin_" + height).toString()));
                        windTowerDataChildTable.setWsMax(CalculationUtil.getBigDecimal(m.get("wsMax_" + height) == null ? null : m.get("wsMax_" + height).toString()));
                        windTowerDataChildTable.setWsSta(CalculationUtil.getBigDecimal(m.get("wsSta_" + height) == null ? null : m.get("wsSta_" + height).toString()));
                        windTowerDataChildTable.setWdAve(CalculationUtil.getBigDecimal(m.get("wdAve_" + height) == null ? null : m.get("wdAve_" + height).toString()));
                        windTowerDataChildTable.setWdMax(CalculationUtil.getBigDecimal(m.get("wdMax_" + height) == null ? null : m.get("wdMax_" + height).toString()));
                        windTowerDataChildTable.setWdMin(CalculationUtil.getBigDecimal(m.get("wdMin_" + height) == null ? null : m.get("wdMin_" + height).toString()));
                        windTowerDataChildTable.setWdSta(CalculationUtil.getBigDecimal(m.get("wdSta_" + height) == null ? null : m.get("wdSta_" + height).toString()));
                        windTowerDataChildTableList.add(windTowerDataChildTable);
                    }
                    //组装父表数据
                    windTowerDataParentTable.setEquipmentId(equipmentId);
                    windTowerDataParentTable.setId(uuid.toString());
                    if (m.get("time") != null)
                        try {
                            try {
                                windTowerDataParentTable.setTime(simpleDateFormat.parse(m.get("time").toString()));
                            } catch (ParseException e) {

                                windTowerDataParentTable.setTime(new Date(Long.parseLong(m.get("time").toString())));
                            }

                        } catch (Exception e) {
                            log.error("时间转换异常:" + e);
                        }

                    if (m.get("paMax") != null)
                        //kpa转hpa
                        if (BigDecimal.valueOf(Double.parseDouble(m.get("paMax").toString())).compareTo(new BigDecimal(200)) < 0)
                            windTowerDataParentTable.setPaMax(CalculationUtil.getBigDecimal(m.get("paMax").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
                        else
                            windTowerDataParentTable.setPaMax(CalculationUtil.getBigDecimal(m.get("paMax").toString()));
                    if (m.get("paMin") != null)
                        //kpa转hpa
                        if (BigDecimal.valueOf(Double.parseDouble(m.get("paMin").toString())).compareTo(new BigDecimal(200)) < 0)
                            windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(m.get("paMin").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
                        else
                            windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(m.get("paMin").toString()));
                    if (m.get("paAve") != null)
                        //kpa转hpa
                        if (BigDecimal.valueOf(Double.parseDouble(m.get("paAve").toString())).compareTo(new BigDecimal(200)) < 0)
                            windTowerDataParentTable.setPaAve(CalculationUtil.getBigDecimal(m.get("paAve").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
                        else
                            windTowerDataParentTable.setPaAve(CalculationUtil.getBigDecimal(m.get("paAve").toString()));
                    windTowerDataParentTable.setPaSta(CalculationUtil.getBigDecimal(m.get("paSta") == null ? null : m.get("paSta").toString()));
                    windTowerDataParentTable.setTMax(CalculationUtil.getBigDecimal(m.get("tMax") == null ? null : m.get("tMax").toString()));
                    windTowerDataParentTable.setTMin(CalculationUtil.getBigDecimal(m.get("tMin") == null ? null : m.get("tMin").toString()));
                    windTowerDataParentTable.setTAve(CalculationUtil.getBigDecimal(m.get("tAve") == null ? null : m.get("tAve").toString()));
                    windTowerDataParentTable.setTSta(CalculationUtil.getBigDecimal(m.get("tSta") == null ? null : m.get("tSta").toString()));
                    windTowerDataParentTable.setRhMax(CalculationUtil.getBigDecimal(m.get("rhMax") == null ? null : m.get("rhMax").toString()));
                    windTowerDataParentTable.setRhMin(CalculationUtil.getBigDecimal(m.get("rhMin") == null ? null : m.get("rhMin").toString()));
                    windTowerDataParentTable.setRhAve(CalculationUtil.getBigDecimal(m.get("rhAve") == null ? null : m.get("rhAve").toString()));
                    windTowerDataParentTable.setRhSta(CalculationUtil.getBigDecimal(m.get("rhSta") == null ? null : m.get("rhSta").toString()));
                    windTowerDataParentTable.setAbnormalData(m.get("abnormalData") == null ? null : m.get("abnormalData").toString());
                    windTowerDataParentTable.setAbnormalType(m.get("abnormalType") == null ? null : m.get("abnormalType").toString());
                    windTowerDataParentTableList.add(windTowerDataParentTable);
                }
            }

        } catch (Exception e) {
            log.error("组装数据异常");
        }
        this.dataSave(windTowerDataParentTableList, windTowerDataChildTableList, equipmentId, eTime, type);
    }

    /**
     * 数据计算入库
     *
     * @param windTowerDataParentTableList 父表数据
     * @param windTowerDataChildTableList  子表数据
     * @param
     */
    private void dataSave(List<WindTowerDataParentTable> windTowerDataParentTableList, List<WindTowerDataChildTable> windTowerDataChildTableList, String equipmentId, String eTime, String type) {
        //获取设备编号 006177_2022-03-28_00.00_000060.rld 006177为设备编号
        //应该是文件的时间而不是系统时间
        Date date = new Date();
        if (type.equals("rld")) {
            SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
            try {
                date = simpleDateFormat.parse(eTime);
            } catch (ParseException e) {
                log.error("RLD转换文件名日期异常");
            }
        } else if (type.equals("sld")) {
            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmm");
            try {
                date = sdf.parse(eTime);
            } catch (ParseException e) {
                log.error("RWD转换文件名异常");
            }
        } else {
            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
            try {
                date = sdf.parse(eTime);
            } catch (ParseException e) {
                log.error("声雷达日期转换异常常");
            }
        }

        try {
            List<WindTowerDataParentTable> parentTableList = new ArrayList<>();
            List<WindTowerDataParentTable> parentTableCollect = windTowerDataParentTableList.stream().sorted(Comparator.comparing(WindTowerDataParentTable::getTime)).collect(Collectors.toList());
            List<Map<String, Object>> windTowerDataParentTables = selectDataByBetweenTimeAndEquipmetId(parentTableCollect.get(0).getTime(), parentTableCollect.get(parentTableCollect.size() - 1).getTime(), equipmentId);
            List<String> parentIdList = new ArrayList<>();
            if (!windTowerDataParentTables.isEmpty()) {
                for (Map<String, Object> map : windTowerDataParentTables) {
                    if (!map.get("id").toString().isEmpty()) {
                        parentIdList.add(map.get("id").toString());
                    }
                }
                windTowerDataChildTableService.deleteBetweenTimeAndEquipmentIdAndChild(parentIdList, equipmentId);
                deleteBetweenTimeAndEquipmentIdAndParent(DateTimeUtil.getDayStartTime(date.getTime()), DateTimeUtil.getDayLastTime(date.getTime()), equipmentId);
            }
            for (WindTowerDataParentTable w : parentTableCollect) {
                //计算空气密度  1.293*(273/(273+温度摄氏度))*气压百帕/1013
                if (w.getTAve() != null && w.getPaAve() != null) {
                    BigDecimal airDensity = BigDecimal.valueOf(1.293).multiply(new BigDecimal(273).divide(new BigDecimal(273).add(w.getTAve()), 2, RoundingMode.HALF_UP)).multiply(w.getPaAve()).divide(new BigDecimal(1013), 2, RoundingMode.HALF_UP);
                    w.setAirDensity(airDensity);
                }
                w.setEquipmentId(equipmentId);
                parentTableList.add(w);
            }
            saveBatchByEquipmentId(parentTableList, windTowerDataChildTableList, equipmentId);
            AnalysisLog analysisLog = new AnalysisLog();
            analysisLog.setStatus("1");
            analysisLog.setTime(date);
            analysisLog.setEquipmentId(equipmentId);
            analysisLogService.save(analysisLog);
        } catch (Exception e) {
            log.error("数据入库失败" + e);
            AnalysisLog analysisLog = new AnalysisLog();
            analysisLog.setStatus("2");
            analysisLog.setTime(date);
            analysisLog.setEquipmentId(equipmentId);
            analysisLogService.save(analysisLog);
        }
    }

    /**
     * 存多条数据
     *
     * @param windTowerDataParentTableList
     * @param windTowerDataChildTableList
     * @param equipmentId
     */
    public void saveBatchById(List<WindTowerDataParentTable> windTowerDataParentTableList, List<WindTowerDataChildTable> windTowerDataChildTableList, String equipmentId) {
        Map<String, Object> map = new HashMap<>();
        map.put("equipment_id", equipmentId);
        RequestDataHelper.setRequestData(map);
        windTowerDataChildTableService.saveBatchByEquipmentId(windTowerDataChildTableList, equipmentId);
        this.saveBatch(windTowerDataParentTableList);
    }


    //通道数据保存
    public void saveDataForTunnel(HashMap<String, BigDecimal> dataMap, HashSet<Integer> heightSet, String equipmentNo, String time) {
        WindTowerDataParentTable windTowerDataParentTable = new WindTowerDataParentTable();
        List<WindTowerInfo> windTowerInfos = windTowerInfoService.getByEquipmentNo(equipmentNo).stream().filter(w -> w.getType().equals("2")).collect(Collectors.toList());
        String id = String.valueOf(UUID.randomUUID());
        List<EquipmentAttribute> equipmentAttributes = equipmentAttributeService.lambdaQuery().eq(EquipmentAttribute::getAttributeFunction, "height").list();
        List<WindTowerDataChildTable> windTowerDataChildTableList = new ArrayList<>();
        for (Integer height : heightSet) {
            List<EquipmentAttribute> eqHeight = equipmentAttributes.stream().filter(e -> e.getFieldName().equals(height.toString())).collect(Collectors.toList());
            WindTowerDataChildTable windTowerDataChildTable = new WindTowerDataChildTable();
            windTowerDataChildTable.setParentId(id);
            windTowerDataChildTable.setLayerHeight(eqHeight.get(0).getId());
            windTowerDataChildTable.setWsAve(CalculationUtil.getBigDecimal(dataMap.get("wsAve" + height) == null ? null : dataMap.get("wsAve" + height).toString()));
            windTowerDataChildTable.setWsMin(CalculationUtil.getBigDecimal(dataMap.get("wsMin" + height) == null ? null : dataMap.get("wsMin" + height).toString()));
            windTowerDataChildTable.setWsMax(CalculationUtil.getBigDecimal(dataMap.get("wsMax" + height) == null ? null : dataMap.get("wsMax" + height).toString()));
            windTowerDataChildTable.setWsSta(CalculationUtil.getBigDecimal(dataMap.get("wsSta" + height) == null ? null : dataMap.get("wsSta" + height).toString()));
            windTowerDataChildTable.setWsInst(CalculationUtil.getBigDecimal(dataMap.get("wsInst" + height) == null ? null : dataMap.get("wsInst" + height).toString()));
            windTowerDataChildTable.setWsGust(CalculationUtil.getBigDecimal(dataMap.get("wsGust" + height) == null ? null : dataMap.get("wsGust" + height).toString()));
            windTowerDataChildTable.setWsGreat(CalculationUtil.getBigDecimal(dataMap.get("wsGreat" + height) == null ? null : dataMap.get("wsGreat" + height).toString()));
            windTowerDataChildTable.setWdAve(CalculationUtil.getBigDecimal(dataMap.get("wdAve" + height) == null ? null : dataMap.get("wdAve" + height).toString()));
            windTowerDataChildTable.setWdMax(CalculationUtil.getBigDecimal(dataMap.get("wdMax" + height) == null ? null : dataMap.get("wdMax" + height).toString()));
            windTowerDataChildTable.setWdMin(CalculationUtil.getBigDecimal(dataMap.get("wdMin" + height) == null ? null : dataMap.get("wdMin" + height).toString()));
            windTowerDataChildTable.setWdSta(CalculationUtil.getBigDecimal(dataMap.get("wdSta" + height) == null ? null : dataMap.get("wdSta" + height).toString()));
            windTowerDataChildTable.setWdInst(CalculationUtil.getBigDecimal(dataMap.get("wdInst" + height) == null ? null : dataMap.get("wdInst" + height).toString()));
            windTowerDataChildTable.setWdOnWs(CalculationUtil.getBigDecimal(dataMap.get("wdOnWs" + height) == null ? null : dataMap.get("wdOnWs" + height).toString()));
            windTowerDataChildTable.setWdNow(CalculationUtil.getBigDecimal(dataMap.get("wdNow" + height) == null ? null : dataMap.get("wdNow" + height).toString()));
            windTowerDataChildTableList.add(windTowerDataChildTable);
        }

        windTowerDataParentTable.setEquipmentId(windTowerInfos.get(0).getEquipmentNo());
        windTowerDataParentTable.setId(id);
        //设置时间
        windTowerDataParentTable.setTime(DateUtil.parseDate(time));
        if (dataMap.get("paMax") != null)
            //kpa转hpa
            if (BigDecimal.valueOf(Double.parseDouble(dataMap.get("paMax").toString())).compareTo(new BigDecimal(200)) < 0)
                windTowerDataParentTable.setPaMax(CalculationUtil.getBigDecimal(dataMap.get("paMax").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
            else
                windTowerDataParentTable.setPaMax(CalculationUtil.getBigDecimal(dataMap.get("paMax").toString()));
        if (dataMap.get("paMin") != null)
            //kpa转hpa
            if (BigDecimal.valueOf(Double.parseDouble(dataMap.get("paMin").toString())).compareTo(new BigDecimal(200)) < 0)
                windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(dataMap.get("paMin").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
            else
                windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(dataMap.get("paMin").toString()));
        if (dataMap.get("paInst") != null)
            //kpa转hpa
            if (BigDecimal.valueOf(Double.parseDouble(dataMap.get("paInst").toString())).compareTo(new BigDecimal(200)) < 0)
                windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(dataMap.get("paInst").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
            else
                windTowerDataParentTable.setPaMin(CalculationUtil.getBigDecimal(dataMap.get("paInst").toString()));
        if (dataMap.get("paAve") != null)
            //kpa转hpa
            if (BigDecimal.valueOf(Double.parseDouble(dataMap.get("paAve").toString())).compareTo(new BigDecimal(200)) < 0)
                windTowerDataParentTable.setPaAve(CalculationUtil.getBigDecimal(dataMap.get("paAve").toString()).multiply(new BigDecimal(10)).setScale(4, RoundingMode.HALF_UP));
            else
                windTowerDataParentTable.setPaAve(CalculationUtil.getBigDecimal(dataMap.get("paAve").toString()));
        windTowerDataParentTable.setPaSta(CalculationUtil.getBigDecimal(dataMap.get("paSta") == null ? null : dataMap.get("paSta").toString()));
        windTowerDataParentTable.setPaNow(CalculationUtil.getBigDecimal(dataMap.get("paNow") == null ? null : dataMap.get("paNow").toString()));

        windTowerDataParentTable.setTMax(CalculationUtil.getBigDecimal(dataMap.get("tMax") == null ? null : dataMap.get("tMax").toString()));
        windTowerDataParentTable.setTMin(CalculationUtil.getBigDecimal(dataMap.get("tMin") == null ? null : dataMap.get("tMin").toString()));
        windTowerDataParentTable.setTAve(CalculationUtil.getBigDecimal(dataMap.get("tAve") == null ? null : dataMap.get("tAve").toString()));
        windTowerDataParentTable.setTSta(CalculationUtil.getBigDecimal(dataMap.get("tSta") == null ? null : dataMap.get("tSta").toString()));
        windTowerDataParentTable.setTInst(CalculationUtil.getBigDecimal(dataMap.get("tInst") == null ? null : dataMap.get("tInst").toString()));
        windTowerDataParentTable.setTNow(CalculationUtil.getBigDecimal(dataMap.get("tNow") == null ? null : dataMap.get("tNow").toString()));

        windTowerDataParentTable.setRhMax(CalculationUtil.getBigDecimal(dataMap.get("rhMax") == null ? null : dataMap.get("rhMax").toString()));
        windTowerDataParentTable.setRhMin(CalculationUtil.getBigDecimal(dataMap.get("rhMin") == null ? null : dataMap.get("rhMin").toString()));
        windTowerDataParentTable.setRhAve(CalculationUtil.getBigDecimal(dataMap.get("rhAve") == null ? null : dataMap.get("rhAve").toString()));
        windTowerDataParentTable.setRhSta(CalculationUtil.getBigDecimal(dataMap.get("rhSta") == null ? null : dataMap.get("rhSta").toString()));
        windTowerDataParentTable.setRhInst(CalculationUtil.getBigDecimal(dataMap.get("rhInst") == null ? null : dataMap.get("rhInst").toString()));
        windTowerDataParentTable.setRhNow(CalculationUtil.getBigDecimal(dataMap.get("rhNow") == null ? null : dataMap.get("rhNow").toString()));

        windTowerDataParentTable.setVMax(CalculationUtil.getBigDecimal(dataMap.get("vMax") == null ? null : dataMap.get("vMax").toString()));
        windTowerDataParentTable.setVMin(CalculationUtil.getBigDecimal(dataMap.get("vMin") == null ? null : dataMap.get("vMin").toString()));
        windTowerDataParentTable.setVAve(CalculationUtil.getBigDecimal(dataMap.get("vAve") == null ? null : dataMap.get("vAve").toString()));
        windTowerDataParentTable.setVSta(CalculationUtil.getBigDecimal(dataMap.get("vSta") == null ? null : dataMap.get("vSta").toString()));
        windTowerDataParentTable.setVInst(CalculationUtil.getBigDecimal(dataMap.get("vInst") == null ? null : dataMap.get("vInst").toString()));
        windTowerDataParentTable.setVNow(CalculationUtil.getBigDecimal(dataMap.get("vNow") == null ? null : dataMap.get("vNow").toString()));

        //计算空气密度
        if (dataMap.get("TAve") != null && dataMap.get("paAve") != null) {
            BigDecimal airDensity = BigDecimal.valueOf(1.293).multiply(new BigDecimal(273).divide(new BigDecimal(273).add(dataMap.get("TAve")), 2, RoundingMode.HALF_UP)).multiply(dataMap.get("paAve")).divide(new BigDecimal(1013), 2, RoundingMode.HALF_UP);
            windTowerDataParentTable.setAirDensity(airDensity);
        }
        ArrayList<WindTowerDataParentTable> windTowerDataParentTableList = new ArrayList<>();
        windTowerDataParentTableList.add(windTowerDataParentTable);
        // TODO 目前没有异常数据校验
//        windTowerDataParentTable.setAbnormalData(dataMap.get("abnormalData") == null ? null : dataMap.get("abnormalData").toString());
//        windTowerDataParentTable.setAbnormalType(dataMap.get("abnormalType") == null ? null : dataMap.get("abnormalType").toString());
//        windTowerDataParentTableList.add(windTowerDataParentTable);


        this.saveBatchById(windTowerDataParentTableList, windTowerDataChildTableList, "station_" + equipmentNo);
    }


    /**
     * 根据时间范围和设备id查询数据
     *
     * @param startTime   开始时间
     * @param endTime     结束时间
     * @param equipmentId 设备id
     * @return List<Map < String, Object>>
     */
    public List<Map<String, Object>> selectDataByBetweenTimeAndEquipmetId(Date startTime, Date endTime, String equipmentId) {
        return selectByBetweenTimeAndEquipmetId(startTime, endTime, equipmentId);
    }

    /**
     * 根据条件查询数据并分页
     *
     * @param startTime   开始时间
     * @param endTime     结束时间
     * @param equipmentId 设备id
     * @return
     */
    public Map<String, Object> selectDataPageByBetweenTimeAndEquipmetId(Date startTime, Date endTime, String equipmentId, Integer pageNo, Integer pageSize) {
        List<Map<String, Object>> maps = selectByBetweenTimeAndEquipmetId(startTime, endTime, equipmentId);
        Map<String, Object> map = new HashMap<>();
        map.put("count", maps.size());
        map.put("list", maps.stream().skip((pageNo - 1) * pageSize).limit(pageSize).collect(Collectors.toList()));
        return map;
    }

    //原实时数据查询
    public List<Map<String, Object>> selectByBetweenTimeAndEquipmetIdOld(Date startTime, Date endTime, String equipmentId) {
        List<Entity> windTowerDataParentTables = baseMapper.selectDataByBetweenTimeAndEquipmetId(equipmentId, startTime, endTime);
        //entity转JOSN数组
        JSONArray array = new JSONArray(windTowerDataParentTables);
        //JSON数据转List<Map<String, Object>>
        List<Map<String, Object>> maps = JSON.parseObject(array.toString(), new TypeReference<List<Map<String, Object>>>() {
        });
        //最终转换后的map
        List<Map<String, Object>> newMaps = new ArrayList<>();
        // 数据库查出来的结果父一行 子多行  一父多子转换成一父一子
        for (int i = 0; i < maps.size(); i++) {
            Map<String, Object> newMap = new HashMap<>();
            int finalI = i;
            maps.get(i).forEach((key, value) -> {
                if (!newMaps.isEmpty()) {
                    //有数据的情况下 如果parent_id相等 则代表应合并成一条
                    if (newMaps.get(newMaps.size() - 1).get("parent_id").equals(maps.get(finalI).get("parent_id"))) {
                        //只有风速风向有层高
                        if (key.contains("ws_") || key.contains("wd_")) {
                            newMaps.get(newMaps.size() - 1).put(key + maps.get(finalI).get("field_name"), value);
                        }
                    } else {
                        if (key.contains("ws_") || key.contains("wd_")) {
                            newMap.put(key + maps.get(finalI).get("field_name"), value);
                        } else {
                            newMap.put(key, value);
                        }
                    }
                } else {
                    if (key.contains("ws_") || key.contains("wd_")) {
                        newMap.put(key + maps.get(finalI).get("field_name"), value);
                    } else {
                        newMap.put(key, value);
                    }
                }
            });
            //在合并数据的时候是直接往list里put  newMap就是空的 如果直接add的话会报错空指针
            if (!newMap.isEmpty()) {
                newMaps.add(newMap);
            }
        }
        return newMaps;
    }


    /**
     * 实时数据查询
     *
     * @param timeBegin   开始时间
     * @param timeEnd     结束时间
     * @param equipmentId 设备编号
     * @return List<Map < String, Object>> 实时数据
     */
    private List<Map<String, Object>> selectByBetweenTimeAndEquipmetId(Date timeBegin, Date timeEnd, String equipmentId) {
        Timestamp startTime = new Timestamp(timeBegin.getTime());
        Timestamp endTime = new Timestamp(timeEnd.getTime());
        HashSet<String> heightSet = new HashSet<>();
        LambdaQueryWrapper<ProphaseAnemometryData> lambdaQueryWrapper = Wrappers.lambdaQuery();
        lambdaQueryWrapper.eq(ProphaseAnemometryData::getEquipmentId, equipmentId);
        lambdaQueryWrapper.between(ProphaseAnemometryData::getTs, startTime, endTime);
        //获取测风塔数据
        List<WindTowerInfo> list = windTowerInfoService.getByEquipmentNo(equipmentId);
        List<Map<String, Object>> mapList = new ArrayList<>();
        List<ProphaseAnemometryData> prophaseAnemometryPublicData = prophaseAnemometryDataService.list(lambdaQueryWrapper);
        List<ProphaseWeatherData> prophaseAnemometryPublicDataList = prophaseWeatherDataService.selectPublicData(equipmentId, startTime, endTime);

        String heights = list.get(0).getHeights();
        String wdHeights = list.get(0).getWdHeights();
        //将层高加入list
        heightSet.addAll(Arrays.asList(heights.split(",")));
        heightSet.addAll(Arrays.asList(wdHeights.split(",")));
        //组装数据
        for (ProphaseWeatherData anemometryPublicData : prophaseAnemometryPublicDataList) {
            HashMap<String, Object> dataMap = new HashMap<>();
            List<ProphaseAnemometryData> prophaseAnemometryData = prophaseAnemometryPublicData.stream().filter(p -> p.getTs().getTime() == anemometryPublicData.getTs().getTime()).collect(Collectors.toList());
            dataMap.put("time", anemometryPublicData.getTs().getTime());
            dataMap.put("t_ave", anemometryPublicData.getTAve());
            dataMap.put("t_max", anemometryPublicData.getTMax());
            dataMap.put("t_min", anemometryPublicData.getTMin());
            dataMap.put("t_sta", anemometryPublicData.getTSta());
            dataMap.put("t_inst", anemometryPublicData.getTInst());


            dataMap.put("rh_ave", anemometryPublicData.getRhAve());
            dataMap.put("rh_max", anemometryPublicData.getRhMax());
            dataMap.put("rh_min", anemometryPublicData.getRhMin());
            dataMap.put("rh_sta", anemometryPublicData.getRhSta());
            dataMap.put("rh_inst", anemometryPublicData.getRhInst());

            dataMap.put("pa_ave", anemometryPublicData.getPaAve());
            dataMap.put("pa_max", anemometryPublicData.getPaMax());
            dataMap.put("pa_min", anemometryPublicData.getPaMin());
            dataMap.put("pa_sta", anemometryPublicData.getPaSta());
            dataMap.put("pa_inst", anemometryPublicData.getPaInst());

            dataMap.put("air_density", anemometryPublicData.getAirDensity());

            if (prophaseAnemometryData.size() > 0) {
                for (ProphaseAnemometryData prophaseAnemometryDatum : prophaseAnemometryData) {
                    dataMap.put("ws_ave" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWsAve());
                    dataMap.put("ws_max" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWsMax());
                    dataMap.put("ws_min" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWsMin());
                    dataMap.put("ws_sta" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWsSta());
                    dataMap.put("ws_inst" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWsInst());
                    dataMap.put("wd_ave" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWdAve());
                    dataMap.put("wd_max" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWdMax());
                    dataMap.put("wd_min" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWdMin());
                    dataMap.put("wd_sta" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWdSta());
                    dataMap.put("wd_inst" + prophaseAnemometryDatum.getLayerHeight(), prophaseAnemometryDatum.getWdInst());

                }
            }
            //过滤value为空的数据
            Map<String, Object> collect = dataMap.entrySet().stream().filter(h -> h.getValue() != null).collect(Collectors.toMap(Map.Entry::getKey, h -> h.getValue()));
            mapList.add(collect);
        }
        return mapList;
    }


    /**
     * 导出测风塔数据
     *
     * @param startTime
     * @param endTime
     * @param equipmentId
     */
    public void export(HttpServletResponse response, Long startTime, Long endTime, String equipmentId) {
        try {
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            BufferedOutputStream bos = null;
            StringBuilder templateContent = new StringBuilder();
            List<Map<String, Object>> mapList = selectDataByBetweenTimeAndEquipmetId(new Date(startTime), new Date(endTime), equipmentId);
            //根据设备编号查找此场站显示的列
            List<DisplayConfig> displayConfigs = displayConfigService.findByDisplaySign(equipmentId);
            //把显示列分割数组
            String[] strings;
            if (displayConfigs.size() > 0) {
                strings = displayConfigs.get(0).getShowCode().split(",");
            } else {
                //获取层高根据层高拼
                //String s = "equipment_id,time,t_inst,t_max,t_min,t_ave,t_sta,rh_inst,rh_max,rh_min,rh_ave,rh_sta,pa_inst,pa_max,pa_min,pa_ave,ws_inst150,ws_max150,ws_min150,ws_ave150,ws_sta150,wd_inst150,wd_max150,wd_min150,wd_ave150,wd_sta150,ws_inst150A,ws_max150A,ws_min150A,ws_ave150A,ws_sta150A,wd_inst150A,wd_max150A,wd_min150A,wd_ave150A,wd_sta150A,ws_inst140,ws_max140,ws_min140,ws_ave140,ws_sta140,wd_inst140,wd_max140,wd_min140,wd_ave140,wd_sta140,ws_inst140A,ws_max140A,ws_min140A,ws_ave140A,ws_sta140A,wd_inst140A,wd_max140A,wd_min140A,wd_ave140A,wd_sta140A,ws_inst120,ws_max120,ws_min120,ws_ave120,ws_sta120,wd_inst120,wd_max120,wd_min120,wd_ave120,wd_sta120,ws_inst80,ws_max80,ws_min80,ws_ave80,ws_sta80,wd_inst80,wd_max80,wd_min80,wd_ave80,wd_sta80,ws_inst90,ws_max90,ws_min90,ws_ave90,ws_sta90,wd_inst90,wd_max90,wd_min90,wd_ave90,wd_sta90,ws_inst100,ws_max100,ws_min100,ws_ave100,ws_sta100,wd_inst100,wd_max100,wd_min100,wd_ave100,wd_sta100,ws_inst110,ws_max110,ws_min110,ws_ave110,ws_sta110,wd_inst110,wd_max110,wd_min110,wd_ave110,wd_sta110,ws_inst120,ws_max120,ws_min120,ws_ave120,ws_sta120,wd_inst120,wd_max120,wd_min120,wd_ave120,wd_sta120,wd_inst140,wd_max140,wd_min140,wd_ave140,wd_sta140,ws_inst140,ws_max140,ws_min140,ws_ave140,ws_sta140,wd_inst150,wd_max150,wd_min150,wd_ave150,wd_sta150,ws_inst150,ws_max150,ws_min150,ws_ave150,ws_sta150,airDensity";
                StringBuffer stringBuffer = new StringBuffer();
                stringBuffer.append("equipment_id")
                        .append(",").append("time")
                        .append(",").append("t_inst")
                        .append(",").append("t_max")
                        .append(",").append("t_min")
                        .append(",").append("t_ave")
                        .append(",").append("t_sta")
                        .append(",").append("rh_inst")
                        .append(",").append("rh_max")
                        .append(",").append("rh_min")
                        .append(",").append("rh_ave")
                        .append(",").append("rh_sta")
                        .append(",").append("pa_inst")
                        .append(",").append("pa_max")
                        .append(",").append("pa_min")
                        .append(",").append("pa_ave")
                        .append(",").append("pa_sta");
                //所有层高
                String[] height = {"200", "200A", "190", "190A", "180", "180A", "170", "170A", "160", "160A", "150", "150A", "140", "140A", "120", "120A", "110", "110A", "100", "100A", "90", "90A", "80", "80A", "70", "70A", "50", "50A", "30", "30A", "10", "10A"};
                Map<String, Object> map = new HashMap<>();
                if (!mapList.isEmpty()) {
                    map = mapList.get(0);
                }
                //把拼装后的属性和共有的属性拼装
                StringBuffer key = getKey(height);
                stringBuffer.append(key);
                String[] strs = stringBuffer.toString().split(",");
                StringBuffer strBuffer = new StringBuffer();
                for (String s : strs) {
                    if (map.get(s) != null) {
                        strBuffer.append(s).append(",");
                    }
                }
                strBuffer.append("air_density");
                strings = strBuffer.toString().split(",");
            }
            //表头
            String header = "";
            //内容
            StringBuilder content = new StringBuilder();
            for (String s : strings) {
                //获取动态的表头
                header += getName(s) + ",";
            }
            header += "\r\n";

            templateContent.append(header);
            //拼接内容
            if (!mapList.isEmpty()) {
                for (Map<String, Object> map : mapList) {
                    for (String string : strings) {
                        if (string.equals("time")) {
                            content.append(sdf.format(map.get(string))).append(",");
                        } else {
                            content.append(map.get(string)).append(",");
                        }
                    }
                    content.append("\r\n");
                }
            }
            templateContent.append(content);
            sdf = new SimpleDateFormat("yyyy-MM-dd");
            response.setContentType("application/x-msdownload;charset=UTF-8");// 文件下载必须配置为application/x-msdownload
            response.setHeader("Content-disposition", "attachment; filename=" + URLEncoder.encode(sdf.format(startTime) + "至" + sdf.format(endTime) + "测风塔文件" + ".csv", "UTF-8"));// 中文文件名必须使用URLEncoder.encode进行转码
            byte[] templateContentBytes = new byte[0];
            templateContentBytes = templateContent.toString().getBytes(StandardCharsets.UTF_8);
            bos = new BufferedOutputStream(response.getOutputStream());// 向response中写入文件流
            bos.write(new byte[]{(byte) 0xEF, (byte) 0xBB, (byte) 0xBF});// 指定csv文件用UTF-8字符集打开
            bos.write(templateContentBytes);
            response.flushBuffer();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 导出测风塔数据文件
     *
     * @param equipmentId
     */
    public void exportAll(HttpServletRequest request, HttpServletResponse response, String equipmentId, Long startTime, Long endTime) {
        try {
            File dataFile = new File(FileUtil.getSystemFilePath() + File.separator + equipmentId);
            File[] files = dataFile.listFiles();
            String zipPath = FileUtil.getSystemFilePath() + File.separator + equipmentId + File.separator + equipmentId + "数据文件.zip";

            List<File> files1 = Arrays.stream(files).map(file -> {
                String name = file.getName();
                if (name.contains(".rld")) {
                    String[] rldNameTime = name.split("_");
                    long time = DateUtil.parse(rldNameTime[1], "yyyy-MM-dd").getTime();
                    if (time >= startTime && time <= endTime) {
                        return file;
                    }
                } else if (name.contains(".RWD")) {
                    String rwdNameTime = name.substring(equipmentId.length(), equipmentId.length() + 8);
                    long time = DateUtil.parse(rwdNameTime, "yyyyMMdd").getTime();
                    if (time >= startTime && time <= endTime) {
                        return file;
                    }
                } else if (name.contains(".elog") || name.contains(".csv")) {
                    String[] elogNameTime = name.split("_");
                    long time = DateUtil.parse(elogNameTime[1], "yyyyMMdd").getTime();
                    if (time >= startTime && time <= endTime) {
                        return file;
                    }
                } else if (name.contains("dat")) {
                    String subTime = name.substring(equipmentId.length(), equipmentId.length() + 8);
                    long time = DateUtil.parse(subTime, "yyyyMMdd").getTime();
                    if (time >= startTime && time <= endTime) {
                        return file;
                    }
                }
                return null;
            }).filter(file -> file != null && file.getName().contains(equipmentId)).collect(Collectors.toList());
            String[] strDir = new String[files1.size()];
            for (int i = 0; i < files1.size(); i++) {
                strDir[i] = files1.get(i).toString();
            }
            FileOutputStream fos2 = new FileOutputStream(new File(zipPath));
            //压缩
            CommonUtil.toZip(strDir, fos2, true);
            downLoadFile(request, response, zipPath);
            File deleteFile = new File(zipPath);
            //下载完删除本地压缩包
            deleteFile.delete();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 文件下载
     *
     * @param request  HttpServletRequest
     * @param response HttpServletResponse
     * @param zipPath  路径
     */
    public void downLoadFile(HttpServletRequest request,
                             HttpServletResponse response,
                             String zipPath) {
        response.setContentType("text/html;charset=utf-8");
        try {
            request.setCharacterEncoding("UTF-8");
        } catch (UnsupportedEncodingException e1) {
            log.error("系统错误：" + e1.getMessage(), e1);
        }

        InputStream ins = null;
        BufferedInputStream bins = null;
        try {
            File df = new File(zipPath);
            ins = new FileInputStream(df);
            bins = new BufferedInputStream(ins);
            OutputStream outs = response.getOutputStream();
            BufferedOutputStream bouts = new BufferedOutputStream(outs);
            response.setHeader("Content-disposition", "attachment;filename=" + java.net.URLEncoder.encode(df.getName(), "UTF-8"));
            response.setContentType("application/x-msdownload; charset=utf-8");
            int bytesRead = 0;
            byte[] buffer = new byte[8192];
            while ((bytesRead = bins.read(buffer, 0, 8192)) != -1) {
                bouts.write(buffer, 0, bytesRead);
            }
            bouts.flush();
            bouts.close();
        } catch (Exception e) {
            log.error("系统错误：" + e.getMessage(), e);
        } finally {
            if (bins != null) {
                try {
                    bins.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (ins != null) {
                try {
                    ins.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 根据传入的层高 返回拼装的属性
     *
     * @param height 层高
     * @return
     */
    private StringBuffer getKey(String[] height) {
        StringBuffer strings = new StringBuffer();
        for (String s : height) {
            strings.append(",").append("ws_inst").append(s).append(",").append("ws_max").append(s).append(",").append("ws_min").append(s).append(",").append("ws_ave").append(s).append(",").append("ws_sta").append(s).append(",").append("wd_inst").append(s).append(",").append("wd_max").append(s).append(",").append("wd_min").append(s).append(",").append("wd_ave").append(s).append(",").append("wd_sta").append(s);
        }
        return strings;
    }

    /**
     * 根据属性名返回表头
     *
     * @param name 属性名
     * @return
     */
    private String getName(String name) {
        if (name.equals("equipment_id")) {
            return "设备编号";
        } else if (name.equals("time")) {
            return "时间";
        } else if (name.equals("t_inst")) {
            return "温度瞬时值";
        } else if (name.equals("t_max")) {
            return "温度最大值";
        } else if (name.equals("t_min")) {
            return "温度最小值";
        } else if (name.equals("t_ave")) {
            return "温度平均值";
        } else if (name.equals("t_sta")) {
            return "温度标差值";
        } else if (name.equals("rh_inst")) {
            return "湿度瞬时值";
        } else if (name.equals("rh_max")) {
            return "湿度最大值";
        } else if (name.equals("rh_min")) {
            return "湿度最小值";
        } else if (name.equals("rh_ave")) {
            return "湿度平均值";
        } else if (name.equals("rh_sta")) {
            return "湿度标差值";
        } else if (name.equals("pa_inst")) {
            return "气压瞬时值";
        } else if (name.equals("pa_max")) {
            return "气压最大值";
        } else if (name.equals("pa_min")) {
            return "气压最小值";
        } else if (name.equals("pa_ave")) {
            return "气压平均值";
        } else if (name.equals("pa_sta")) {
            return "气压标差值";
        } else if (name.contains("ws_inst")) {
            return name.substring(7) + "米风速瞬时值";
        } else if (name.contains("ws_max")) {
            return name.substring(6) + "米风速最大值";
        } else if (name.contains("ws_min")) {
            return name.substring(6) + "米风速最小值";
        } else if (name.contains("ws_ave")) {
            return name.substring(6) + "米风速平均值";
        } else if (name.contains("ws_sta")) {
            return name.substring(6) + "米风速标差值";
        } else if (name.contains("wd_inst")) {
            return name.substring(7) + "米风向瞬时值";
        } else if (name.contains("wd_max")) {
            return name.substring(6) + "米风向最大值";
        } else if (name.contains("wd_min")) {
            return name.substring(6) + "米风向最小值";
        } else if (name.contains("wd_ave")) {
            return name.substring(6) + "米风向平均值";
        } else if (name.contains("wd_sta")) {
            return name.substring(6) + "米风向标差值";
        } else if (name.equals("air_density")) {
            return "空气密度";
        } else {
            return "";
        }
    }

    /**
     * 存一条数据
     *
     * @param windTowerDataParentTable
     * @param windTowerDataChildTable
     * @param equipmentId
     */
    public void saveByEquipmentId(WindTowerDataParentTable windTowerDataParentTable, WindTowerDataChildTable windTowerDataChildTable, String equipmentId) {
        Map<String, Object> map = new HashMap<>();
        map.put("equipment_id", equipmentId);
        RequestDataHelper.setRequestData(map);
        windTowerDataChildTableService.saveByEquipmentId(windTowerDataChildTable, equipmentId);
        this.save(windTowerDataParentTable);
    }


    /**
     * 存多条数据
     *
     * @param windTowerDataParentTableList
     * @param windTowerDataChildTableList
     * @param equipmentId
     */
    public void saveBatchByEquipmentId(List<WindTowerDataParentTable> windTowerDataParentTableList, List<WindTowerDataChildTable> windTowerDataChildTableList, String equipmentId) {
        Map<String, Object> map = new HashMap<>();
        map.put("equipment_id", equipmentId);
        RequestDataHelper.setRequestData(map);
        windTowerDataChildTableService.saveBatchByEquipmentId(windTowerDataChildTableList, equipmentId);
        this.saveBatch(windTowerDataParentTableList);
    }

    /**
     * 删除数据
     *
     * @param equipmentId 设备编号
     * @param startTime   开始时间
     * @param endTime     结束时间
     */
    public void deleteDataByBetweenTimeAndEquipmetId(Date startTime, Date endTime, String equipmentId) {
        baseMapper.deleteDataByBetweenTimeAndEquipmetId(equipmentId, startTime, endTime);
    }

    /**
     * 删除父表数据
     *
     * @param startTime   开始时间
     * @param endTime     结束时间
     * @param equipmentId 设备编号
     */

    public void deleteBetweenTimeAndEquipmentIdAndParent(Date startTime, Date endTime, String equipmentId) {
        baseMapper.deleteBetweenTimeAndEquipmentIdAndParent(equipmentId, startTime, endTime);
    }


    /**
     * 数据完整性
     *
     * @param equipmentId 设备编号
     * @return List<Map < String, Object>>
     */
    public List<Map<String, Object>> countDataIntegrity(String equipmentId, String startTime, String endTime) {
        return baseMapper.countDataIntegrity(equipmentId, startTime, endTime);
    }

    /**
     * 根据设备编号获取该设备的第一条数据
     *
     * @param equipmentId 设备编号
     * @return WindTowerDataParentTable
     */
    public WindTowerDataParentTable getFirstData(String equipmentId) {
        return baseMapper.getFirstData(equipmentId);
    }

    /**
     * 根据设备编号获取该设备的最后一条数据
     *
     * @param equipmentId 设备编号
     * @return WindTowerDataParentTable
     */
    public WindTowerDataParentTable getLastData(String equipmentId) {
        return baseMapper.getLastData(equipmentId);
    }

    /**
     * 根据设备编号获取最新一天的数据
     *
     * @param equipmentId 设备编号
     * @return List<Map < String, Object>>
     */
    public List<Map<String, Object>> getStartTimeAndEndTimeForData(String equipmentId) {
        WindTowerDataParentTable towerDataParentTableServiceLastData = getLastData(equipmentId);
        Date endTime = towerDataParentTableServiceLastData.getTime();
        DateTime dateTime = DateUtil.beginOfDay(endTime);
        return selectDataByBetweenTimeAndEquipmetId(new Date(dateTime.getTime()), endTime, equipmentId);

    }

}