package com.ld.igds.es.service;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.ld.igds.constant.BizType;
import com.ld.igds.data.ChartLine;
import com.ld.igds.data.ChartSeries;
import com.ld.igds.grain.dto.GrainData;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.websocket.WebSocketPacket;
import com.ld.igds.websocket.WebSocketServer;

import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.ld.igds.constant.RedisConst;
import com.ld.igds.es.dto.EsData;
import com.ld.igds.es.dto.EsParam;
import com.ld.igds.es.dto.EsSummary;
import com.ld.igds.es.mapper.EsServiceMapper;
import com.ld.igds.util.DateUtil;
import com.ld.igds.util.RedisUtil;

@Slf4j
@Component(CoreEsService.BEAN_ID)
public class CoreEsServiceImpl implements CoreEsService {

//    @Autowired
//    private WebSocketServer socketServer;
    @Autowired
    private EsServiceMapper esServiceMapper;
    @Autowired
    private RedisUtil redisUtil;

    @Override
    public List<EsSummary> getSummaryGroupByDepot(EsParam param) {

        if (null == param.getCheckDate()) {
            return null;
        }
        // 说明按照日期来的
        if ("day".equals(param.getTimeType())) {
            param.setStart(DateUtil.getCurZero(param.getCheckDate()));
            param.setEnd(DateUtil.getNextZero(param.getCheckDate()));
        }
        if ("month".equals(param.getTimeType())) {
            param.setStart(DateUtil.getMonthFirst(param.getCheckDate()));
            param.setEnd(DateUtil.getNextMonthFirst(param.getCheckDate()));
        }

        return esServiceMapper.getSummaryGroupByDepot(param);
    }

    @Override
    public EsSummary getSummaryByParam(EsParam param) {

        if (null == param.getStart())
            new EsSummary();
        if (null == param.getEnd())
            new EsSummary();
        EsSummary result = esServiceMapper.getSummaryByParam(param);
        if (null == result)
            result = new EsSummary();
        return result;
    }

    @Override
    public List<EsSummary> listSumGroupByDay(EsParam param) {

        if (null == param.getStart()) {
            param.setStart(DateUtil.getNewByDay(null, -30));
        }

        return esServiceMapper.listSumGroupByDay(param);
    }

    @Override
    public List<EsData> listDetailChartData(EsParam param) {

        if (null == param.getStart()) {
            param.setStart(DateUtil.getNewByDay(null, -30));
        }

        if (null != param.getEnd()) {
            param.setEnd(DateUtil.getNextZero(param.getEnd()));
        }
        return esServiceMapper.listDetailChartData(param);
    }

    @Override
    public EsData getCacheEsData(String companyId, String depotId) {
        Map<String, EsData> dataMap = getCacheEsDataMap(companyId);
        if (null == dataMap || dataMap.isEmpty()) {
            return null;
        }
        EsData result = null;
        for (String key : dataMap.keySet()) {
            if(key.startsWith(depotId)){
                if(null == result){
                    result = dataMap.get(key);
                }else {
                    result.setEp(result.getEp() + dataMap.get(key).getEp());
                    result.setEq(result.getEq() + dataMap.get(key).getEq());
                    result.setEs(result.getEs() + dataMap.get(key).getEs());
                }
            }
        }
        return result;
    }

    @Override
    public EsData getCacheEsDepotData(String companyId, String depotId, String deviceId) {
        Map<String, EsData> dataMap = getCacheEsDataMap(companyId);
        if (null == dataMap || dataMap.isEmpty()) {
            return null;
        }
        return dataMap.get(depotId + "-" + deviceId);
    }

    @Override
    public void updateCacheEsData(EsData esData) {
        Map<String, EsData> dataMap = getCacheEsDataMap(esData.getCompanyId());
        if (null == dataMap) {
            dataMap = new HashMap<String, EsData>();
        } else {
            dataMap.put(esData.getDepotId() + "-" + esData.getDeviceId(), esData);
        }
        String deptId = ContextUtil.subDeptId(null);
        String key = RedisConst.buildKey(esData.getCompanyId(),
                RedisConst.KEY_ES_DATA_MAP, deptId);
        redisUtil.set(key, dataMap);
    }

    @SuppressWarnings("unchecked")
    @Override
    public Map<String, EsData> getCacheEsDataMap(String companyId) {
        String deptId = ContextUtil.subDeptId(null);
        String key = RedisConst.buildKey(companyId, RedisConst.KEY_ES_DATA_MAP, deptId);
        Map<String, EsData> result = (Map<String, EsData>) redisUtil.get(key);
        if (null == result) {
            log.info("系统中没有获取到能耗数据缓存信息！！");
        }
        return result;
    }

    @Override
    public void saveAndUpdateInc(EsData data) {

        // 获取上次的缓存信息，如果缓存中的数据跟当前数据时间差小于12个小时，则计算增量，否则增量为0,增量不可为负数。
        EsData oldData = getCacheEsDepotData(data.getCompanyId(), data.getDepotId(), data.getDeviceId());
        if (null != oldData && oldData.getEs() > 0) {
            long time = data.getUpdateTime().getTime() - oldData.getUpdateTime().getTime();
            if (time <= 12 * 60 * 60 * 1001) {
                data.setEpInc(data.getEp() - oldData.getEp());
                data.setEpInc(data.getEpInc() > 0 ? data.getEpInc() : 0.0);

                data.setEqInc(data.getEq() - oldData.getEq());
                data.setEqInc(data.getEqInc() > 0 ? data.getEqInc() : 0.0);

                data.setEsInc(data.getEs() - oldData.getEs());
                data.setEsInc(data.getEsInc() > 0 ? data.getEsInc() : 0.0);
            }
        }

        if (null == data.getUpdateTime()) {
            data.setUpdateTime(new Date());
        }

        if (StringUtils.isEmpty(data.getId())) {
            data.setId(data.getCompanyId() + "-" + data.getDepotId() + "-" + data.getDeviceId() + "-"
                    + ContextUtil.getCurTimeMillis());
        }

        // 更新缓存
        this.updateCacheEsData(data);

        // 持久化数据库
        esServiceMapper.insertData(data);
    }

    @SuppressWarnings("static-access")
    @Override
    public ChartLine queryScreenEsChart(EsParam esParam, boolean toWeb) {

        if (StringUtils.isEmpty(esParam.getCompanyId())) {
            esParam.setCompanyId(ContextUtil.getDefaultCompanyId());
        }
        if (StringUtils.isEmpty(esParam.getDeptId())) {
            esParam.setDeptId(ContextUtil.subDeptId(null));
        }
        List<EsSummary> list = this.listSumGroupByDay(esParam);

        if (null == list || list.isEmpty())
            return null;

        // 从新排序
        list.sort((a, b) -> a.getGroupTag().compareTo(b.getGroupTag()));

        // 调整对象,groupTag = yyyy-MM-dd
        ChartLine line = new ChartLine();
        ChartSeries series = new ChartSeries();
        for (EsSummary sum : list) {
            line.getXaxisData().add(sum.getGroupTag().substring(5));
            series.getData().add(String.valueOf(sum.getEpSum()));
        }
        line.getSeries().add(series);

        if (toWeb) {
            // 大屏的数据存放缓存，并推送页面
            WebSocketPacket packet = new WebSocketPacket();
            packet.setCompanyId(ContextUtil.getDefaultCompanyId());
            packet.setBizType(BizType.SCREEN.getCode());
            packet.setDeptId(esParam.getDeptId());
            packet.setBizId(BizType.ES.getCode());
            packet.setData(line);
            WebSocketServer.sendByPocket(packet);
        }
        return line;
    }

}