/**
 #                                                    __----~~~~~~~~~~~------___
 #                                   .  .   ~~//====......          __--~ ~~
 #                   -.            \_|//     |||\\  ~~~~~~::::... /~
 #                ___-==_       _-~o~  \/    |||  \\            _/~~-
 #        __---~~~.==~||\=_    -_--~/_-~|-   |\\   \\        _/~
 #    _-~~     .=~    |  \\-_    '-~7  /-   /  ||    \      /
 #  .~       .~       |   \\ -_    /  /-   /   ||      \   /
 # /  ____  /         |     \\ ~-_/  /|- _/   .||       \ /
 # |~~    ~~|--~~~~--_ \     ~==-/   | \~--===~~        .\
 #          '         ~-|      /|    |-~\~~       __--~~
 #                      |-~~-_/ |    |   ~\_   _-~            /\
 #                           /  \     \__   \/~                \__
 #                       _--~ _/ | .-~~____--~-/                  ~~==.
 #                      ((->/~   '.|||' -_|    ~~-/ ,              . _||
 #                                 -_     ~\      ~~---l__i__i__i--~~_/
 #                                 _-~-__   ~)  \--______________--~~
 #                               //.-~~~-~_--~- |-------~~~~~~~~
 #                                      //.-~~~--\
 #                  神兽保佑
 #                  永无BUG！
 */
package com.fengdu.gas.service;

import com.fengdu.gas.common.*;
import com.fengdu.gas.common.enums.*;
import com.fengdu.gas.common.model.Tuple;
import com.fengdu.gas.common.util.*;
import com.fengdu.gas.repository.impl.*;
import com.fengdu.gas.repository.mapper.DataUploadRecordHourMapper;
import com.fengdu.gas.repository.po.*;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import org.apache.commons.lang3.BooleanUtils;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
import java.util.stream.Collectors;

import com.fengdu.gas.entity.request.datauploadrecord.ReqCreateDataUploadRecord;
import com.fengdu.gas.entity.request.datauploadrecord.ReqModifyDataUploadRecord;
import com.fengdu.gas.entity.search.SearchDataUploadRecord;
import com.fengdu.gas.repository.vo.DataUploadRecordVO;
import com.fengdu.gas.service.convert.DataUploadRecordConvert;

/**
 * 数据上报记录
 * @author zr
 */
@Service
public class DataUploadRecordService extends BaseService {
    @Autowired
    private DataUploadRecordMapperImpl mapper;
    @Autowired
    private WaterFacilityMapperImpl waterFacilityMapper;
    @Autowired
    private WaterMonitoryPointMapperImpl waterMonitoryPointMapper;
    @Autowired
    private DataUploadRecordHourMapperImpl dataUploadRecordHourMapper;
    @Autowired
    private DataUploadRecordDayMapperImpl dataUploadRecordDayMapper;
    @Autowired
    private DataUploadRecordMonthMapperImpl dataUploadRecordMonthMapper;
    @Autowired
    private WaterFacilityParameterMapperImpl waterFacilityParameterMapper;
    private static final Logger DEBUG_LOGGER = LoggerUtil.get(ELogger.DEBUG);
    private static final Logger ERROR_LOGGER = LoggerUtil.get(ELogger.SYS_ERROR);
    public ExecutedResult<Long> create(ReqCreateDataUploadRecord request) {
        // 转换po
        DataUploadRecordPO item = DataUploadRecordConvert.INSTANCE.toCreate(request);
        // 设置状态
        //item.setStatus(EState.NORMAL.getValue());
        // 设置记录创建时间
        item.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
        // 是否删除(逻辑删除)初始值
        item.setIsDelete(EYesOrNo.NO.getValue());

        int rowCount = mapper.insert(item);
        if (rowCount != 1) {
            return ExecutedResult.failed("创建[数据上报记录]失败。");
        }
        return ExecutedResult.success(item.getId());
    }

    public ExecutedResult<String> modify(ReqModifyDataUploadRecord request) {
        // 验证记录是否存在
        ExecutedResult<DataUploadRecordPO> checkExists = this.check4Id(request.getId());
        if (checkExists.isFailed()) {
            return ExecutedResult.failed(checkExists.getMsg());
        }
        // 转换po
        DataUploadRecordPO item = DataUploadRecordConvert.INSTANCE.toModify(request);

        int rowCount = mapper.updateById(item);
        if (rowCount != 1) {
            return ExecutedResult.failed("编辑[数据上报记录]失败。");
        }
        return ExecutedResult.success();
    }

    public ExecutedResult<DataUploadRecordVO> get(Long id) {
        DataUploadRecordVO result = new DataUploadRecordVO();

        DataUploadRecordPO find = mapper.get(id);
        if (null != find) {
            // 转换vo
            result = DataUploadRecordConvert.INSTANCE.toVo(find);
        }
        return ExecutedResult.success(result);
    }

    //    public ExecutedResult<String> stop(Long id) {
//        // 验证记录是否存在
//        ExecutedResult<DataUploadRecordPO> checkExists = this.check4Id(id);
//        if (checkExists.isFailed()) {
//            return ExecutedResult.failed(checkExists.getMsg());
//        }
//        DataUploadRecordPO item = new DataUploadRecordPO();
//        item.setId(id);
//        item.setStatus(EState.DISABLED.getValue());
//
//        int rowCount = mapper.updateById(item);
//        if (rowCount != 1) {
//           return ExecutedResult.failed("停用[数据上报记录]失败。");
//       }
//       return ExecutedResult.success();
//   }
//
//    public ExecutedResult<String> enable(Long id) {
//        // 验证记录是否存在
//        ExecutedResult<DataUploadRecordPO> checkExists = this.check4Id(id);
//        if (checkExists.isFailed()) {
//            return ExecutedResult.failed(checkExists.getMsg());
//        }
//        DataUploadRecordPO item = new DataUploadRecordPO();
//        item.setId(id);
//        item.setStatus(EState.NORMAL.getValue());
//
//        int rowCount = mapper.updateById(item);
//        if (rowCount != 1) {
//            return ExecutedResult.failed("启用[数据上报记录]失败。");
//        }
//        return ExecutedResult.success();
//    }
//
//    public ExecutedResult<String> setSort(ReqSetSort request) {
//        // 验证记录是否存在
//        ExecutedResult<DataUploadRecordPO> checkExists = this.check4Id(request.getId());
//        if (checkExists.isFailed()) {
//            return ExecutedResult.failed(checkExists.getMsg());
//        }
//        DataUploadRecordPO item = new DataUploadRecordPO();
//        item.setId(request.getId());
//        item.setSort(request.getSort());
//
//        int rowCount = mapper.updateById(item);
//        if (rowCount != 1) {
//            return ExecutedResult.failed("设置[数据上报记录]排序值失败。");
//        }
//        return ExecutedResult.success();
//    }
//
//    public ExecutedResult<String> listSetSort(ReqListSetSort request) {
//        // id列表
//        List<Long> listId = request.getList().stream().map(ReqSetSort::getId).collect(Collectors.toList());
//        // 验证记录是否存在
//        ExecutedResult<List<DataUploadRecordPO>> checkExists = this.check4Id(listId);
//        if (checkExists.isFailed()) {
//            return ExecutedResult.failed(checkExists.getMsg());
//        }
//
//        List<DataUploadRecordPO> listUpdate = request.getList().stream()
//                .map(c -> {
//                    DataUploadRecordPO item = new DataUploadRecordPO();
//                    item.setId(c.getId());
//                    item.setSort(c.getSort());
//                    return item;
//                })
//                .collect(Collectors.toList());
//        Boolean result = mapper.modifyList(listUpdate);
//        if (result) {
//            return ExecutedResult.success();
//        }
//        return ExecutedResult.failed("[数据上报记录]设置排序值失败");
//    }
//
//    public ExecutedResult<String> remove(Long id) {
//        Boolean result = mapper.deleteLogic(id);
//        if (BooleanUtils.isFalse(result)) {
//            return ExecutedResult.failed("删除[数据上报记录]失败。");
//        }
//        return ExecutedResult.success();
//    }
//
//    public ExecutedResult<String> removeList(List<Long> ids) {
//        Boolean result = mapper.deleteLogic(ids);
//        if (BooleanUtils.isFalse(result)) {
//            return ExecutedResult.failed("删除[数据上报记录]失败。");
//        }
//        return ExecutedResult.success();
//    }
    /**
     * mqtt收到消息
     * @param topic 主题
     * @param msg 消息内容
     */
    public void mqttReceived(String topic, String msg) {
        if (StringUtil.isNullOrEmpty(topic)) {
            ERROR_LOGGER.error("主题不能为空");
            return;
        }
        if (StringUtil.isNullOrEmpty(msg)) {
            ERROR_LOGGER.error("消息不能为空");
            return;
        }
        if (msg.startsWith("{\"platform")) {
            return;
        }
        //报文解析
        //添加参数报警记录
        List<WaterFacilityPO> facilityPOList = waterFacilityMapper.getList();
        FacilityAlarmRecordPO recordPO=new FacilityAlarmRecordPO();

    }
    public ExecutedResult<String> dataUpload(Long startTime, Long endTime, Integer type) {
        List<WaterFacilityPO> facilityPOList = waterFacilityMapper.getList();
        //获取所有设备参数
        List<WaterFacilityParameterPO> parameterPOList = waterFacilityParameterMapper.getList();

        switch (type) {
            case 1:
                //按小时统计插入数据
                List<DataUploadRecordPO> recordPOList = mapper.getByTime(startTime, endTime);
                if(ListUtil.isNotNullOrEmpty(recordPOList)){
                    for (WaterFacilityParameterPO parameterPO : parameterPOList) {
                        WaterFacilityPO waterFacilityPO = facilityPOList.stream().filter(item -> item.getId().equals(parameterPO.getFacilityId())).findFirst().orElse(null);
                        //根据设备参数筛选数据集合
                        List<DataUploadRecordPO> dataList = recordPOList.stream().filter(item -> item.getFacilityId().equals(parameterPO.getFacilityId()) && item.getColumnsCode().equals(parameterPO.getColumnsCode())).collect(Collectors.toList());
                        //获取最大值
                        BigDecimal maxValue = dataList.stream().map(DataUploadRecordPO::getColumnValue).max(BigDecimal::compareTo).get();
                        //获取最小值
                        BigDecimal minValue = dataList.stream().map(DataUploadRecordPO::getColumnValue).min(BigDecimal::compareTo).get();
                        //获取平均值
                        double average = dataList.stream().map(DataUploadRecordPO::getColumnValue).mapToDouble(BigDecimal::doubleValue).average().orElse(Double.NaN);
                        BigDecimal averageValue = new BigDecimal(average).setScale(2, RoundingMode.DOWN);
                        DataUploadRecordHourPO recordHourPO = new DataUploadRecordHourPO();
                        recordHourPO.setPointId(waterFacilityPO.getPointId());
                        recordHourPO.setPointName(waterFacilityPO.getPointName());
                        recordHourPO.setFacilityId(waterFacilityPO.getId());
                        recordHourPO.setFacilityName(waterFacilityPO.getFacilityName());
                        recordHourPO.setColumnsCode(parameterPO.getColumnsCode());
                        recordHourPO.setMinValue(maxValue);
                        recordHourPO.setMaxValue(minValue);
                        recordHourPO.setAvgValue(averageValue);
                        recordHourPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
                        recordHourPO.setUploadDate(LocalDateTimeUtil.toFormatString(endTime));
                        recordHourPO.setUploadTime(endTime);
                        dataUploadRecordHourMapper.insert(recordHourPO);
                    }
                }

                break;
            case 2://按天统计插入数据
                List<DataUploadRecordHourPO> hourPOList = dataUploadRecordHourMapper.getByTime(startTime, endTime);
                if(ListUtil.isNotNullOrEmpty(hourPOList)){
                    for (WaterFacilityParameterPO parameterPO : parameterPOList) {
                        WaterFacilityPO waterFacilityPO = facilityPOList.stream().filter(item -> item.getId().equals(parameterPO.getFacilityId())).findFirst().orElse(null);
                        List<DataUploadRecordHourPO> dataList = hourPOList.stream().filter(item -> item.getFacilityId().equals(parameterPO.getFacilityId()) && item.getColumnsCode().equals(parameterPO.getColumnsCode())).collect(Collectors.toList());
                        //获取最大值
                        BigDecimal maxValue = dataList.stream().map(DataUploadRecordHourPO::getMaxValue).max(BigDecimal::compareTo).get();
                        //获取最小值
                        BigDecimal minValue = dataList.stream().map(DataUploadRecordHourPO::getMinValue).min(BigDecimal::compareTo).get();
                        //获取平均值
                        double average = dataList.stream().map(DataUploadRecordHourPO::getAvgValue).mapToDouble(BigDecimal::doubleValue).average().orElse(Double.NaN);
                        BigDecimal averageValue = new BigDecimal(average).setScale(2, RoundingMode.DOWN);
                        DataUploadRecordDayPO recordDayPO = new DataUploadRecordDayPO();
                        recordDayPO.setPointId(waterFacilityPO.getPointId());
                        recordDayPO.setPointName(waterFacilityPO.getPointName());
                        recordDayPO.setFacilityId(waterFacilityPO.getId());
                        recordDayPO.setFacilityName(waterFacilityPO.getFacilityName());
                        recordDayPO.setMinValue(maxValue);
                        recordDayPO.setMaxValue(minValue);
                        recordDayPO.setAvgValue(averageValue);
                        recordDayPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
                        recordDayPO.setUploadDate(LocalDateTimeUtil.toDateString(endTime));
                        recordDayPO.setUploadTime(endTime);
                        dataUploadRecordDayMapper.insert(recordDayPO);
                    }
                }
                break;
            case 3://按月统计插入数据
                List<DataUploadRecordDayPO> dayPOList = dataUploadRecordDayMapper.getByTime(startTime, endTime);
                if(ListUtil.isNotNullOrEmpty(dayPOList)){
                    for (WaterFacilityParameterPO parameterPO : parameterPOList) {
                        WaterFacilityPO waterFacilityPO = facilityPOList.stream().filter(item -> item.getId().equals(parameterPO.getFacilityId())).findFirst().orElse(null);
                        List<DataUploadRecordDayPO> dataList = dayPOList.stream().filter(item -> item.getFacilityId().equals(parameterPO.getFacilityId()) && item.getColumnsCode().equals(parameterPO.getColumnsCode())).collect(Collectors.toList());
                        //获取最大值
                        BigDecimal maxValue = dataList.stream().map(DataUploadRecordDayPO::getMaxValue).max(BigDecimal::compareTo).get();
                        //获取最小值
                        BigDecimal minValue = dataList.stream().map(DataUploadRecordDayPO::getMinValue).min(BigDecimal::compareTo).get();
                        //获取平均值
                        double average = dataList.stream().map(DataUploadRecordDayPO::getAvgValue).mapToDouble(BigDecimal::doubleValue).average().orElse(Double.NaN);
                        BigDecimal averageValue = new BigDecimal(average).setScale(2, RoundingMode.DOWN);
                        DataUploadRecordMonthPO recordMonthPO = new DataUploadRecordMonthPO();
                        recordMonthPO.setPointId(waterFacilityPO.getPointId());
                        recordMonthPO.setPointName(waterFacilityPO.getPointName());
                        recordMonthPO.setFacilityId(waterFacilityPO.getId());
                        recordMonthPO.setFacilityName(waterFacilityPO.getFacilityName());
                        recordMonthPO.setMinValue(maxValue);
                        recordMonthPO.setMaxValue(minValue);
                        recordMonthPO.setAvgValue(averageValue);
                        recordMonthPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
                        recordMonthPO.setUploadDate(LocalDateTimeUtil.toDateString(endTime));
                        recordMonthPO.setUploadTime(endTime);
                        dataUploadRecordMonthMapper.insert(recordMonthPO);
                        break;
                    }
                }



        }
        return ExecutedResult.success();
    }

    public ExecutedResult<List<DataUploadRecordVO>> getList(List<Long> listId) {
        List<DataUploadRecordVO> result = new ArrayList<>();

        List<DataUploadRecordPO> list = mapper.getList(listId);
        if (ListUtil.isNotNullOrEmpty(list)) {
            // 转换vo
            result = DataUploadRecordConvert.INSTANCE.toVo(list);
        }
        return ExecutedResult.success(result);
    }

    public ExecutedResult<PagerResult<DataUploadRecordVO>> search(SearchDataUploadRecord search) {
        // 处理创建时间范围-查询参数
        Tuple<String, String> createTimeRange = ParameterUtil.getTimeRange(search.getCreateTimeRange());
        if (StringUtil.isNotNullOrEmpty(createTimeRange.getItem1())) {
            search.setCreateTimeStart(LocalDateTimeUtil.getTimeStamp(createTimeRange.getItem1()).getTime());
        }
        if (StringUtil.isNotNullOrEmpty(createTimeRange.getItem2())) {
            search.setCreateTimeEnd(LocalDateTimeUtil.getTimeStamp(createTimeRange.getItem2()).getTime());
        }

        PagerResult<DataUploadRecordPO> pageList = mapper.search(search);
        List<DataUploadRecordVO> listVo = new ArrayList<>();
        List<DataUploadRecordPO> list = pageList.getList();
        if (ListUtil.isNotNullOrEmpty(list)) {
            pageList.setLastId(list.get(list.size() - 1).getId());
            // 转换vo
            listVo = DataUploadRecordConvert.INSTANCE.toVo(list);
        }
        PagerResult<DataUploadRecordVO> result = new PagerResult<>(pageList.getLimit(), pageList.getPage(), pageList.getTotal(), listVo);
        result.setLastId(pageList.getLastId());
        return ExecutedResult.success(result);
    }

    protected ExecutedResult<DataUploadRecordPO> check4Id(Long id) {
        DataUploadRecordPO exists = mapper.get(id);
        if (Objects.isNull(exists)) {
            return ExecutedResult.failed("[数据上报记录]不存在：" + id);
        }
        return ExecutedResult.success(exists);
    }

    protected ExecutedResult<List<DataUploadRecordPO>> check4Id(List<Long> listId) {
        // 从数据库查找数据上报记录
        List<DataUploadRecordPO> list = mapper.getList(listId);
        if (ListUtil.isNullOrEmpty(list)) {
            return ExecutedResult.failed("[数据上报记录]不存在." + listId);
        }
        // 数据库找到的id列表
        List<Long> listIdFind = list.stream().map(DataUploadRecordPO::getId).collect(Collectors.toList());
        // 数量不一致
        if (listId.size() != listIdFind.size()) {
            // 筛选数据库不存在的数据上报记录
            List<Long> listIdNotFound = listId.stream().filter(c -> !listIdFind.contains(c)).collect(Collectors.toList());
            if (ListUtil.isNullOrEmpty(list)) {
                return ExecutedResult.failed("[数据上报记录]不存在." + listIdNotFound);
            }
        }
        return ExecutedResult.success(list);
    }
}