package com.ld.igds.protocol.fzzy.analysis;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.ld.igds.es.dto.EsData;
import com.ld.igds.es.service.CoreEsService;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.protocol.fzzy.dto.ReMessage;
import com.ld.igds.protocol.fzzy.resp.Response4001;

import lombok.extern.slf4j.Slf4j;

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

import java.util.Date;
import java.util.List;

/**
 * 解析能耗
 *
 * @author andy
 */
@Slf4j
@Component(AnalysisEs.BEAN_ID)
public class AnalysisEs {

    public static final String BEAN_ID = "fzzy.analysisEnergy";

    @Autowired
    private CoreEsService esService;

    /**
     * 能耗解析 2022-12-17弃用，改用新的解析方式
     * <p>
     * "ep":"4340.100","eq":"4802.100","houseId":"3P07","ia":"0.300","ib":"0.300","ic":"0.000","seqId":0,"ua":"229.4","ub":"229.2","uc":"229.0"
     *
     * @param reMessage
     * @param ser
     */
//    public void analysis4001(ReMessage reMessage, DeviceSer ser) {
//
//        Response4001 response = JSONObject.parseObject(reMessage.getContent(), Response4001.class);
//
//        //有功电能判断是否返回有效数据
//        if (null == response.getEp()) {
//            log.error("---能耗数据返回数据不完整，停止解析----{}", reMessage.toString());
//            return;
//        }
//
//        EsData esData = new EsData();
//        esData.setCompanyId(ser.getCompanyId());
//        esData.setDepotId(response.getHouseId());
//        esData.setUpdateTime(new Date());
//        esData.setUa(response.getUa());
//        esData.setUb(response.getUb());
//        esData.setUc(response.getUc());
//
//        esData.setIa(response.getIa());
//        esData.setIb(response.getIb());
//        esData.setIc(response.getIc());
//        esData.setF(response.getF() == null ? 0.0 : response.getF());
//
//        esData.setEp(response.getEp());
//        esData.setEq(response.getEq());
//        if (null != response.getEs()) {
//            esData.setEs(response.getEs());
//        } else {
//            esData.setEs(0.0);
//        }
//
//        esData.setEsFan(response.getEsFan() == null ? 0.0 : response.getEsFan());
//        esData.setEsAir(response.getEsAir() == null ? 0.0 : response.getEsAir());
//        esData.setEsLamp(response.getEsLamp() == null ? 0.0 : response.getEsLamp());
//
//        log.info("控制柜----->>>平台：能耗数据解析完成-仓库={}", esData.getDepotId());
//
//        esService.saveAndUpdateInc(esData);
//    }

    /**
     * 2022-12-17启用，报文内容为列表集合
     * "content": [{"houseId": "0135","deviceId": "6001","deviceName": "1号仓主控柜电表","ua": "220","ub": "220","uc": "220","ia": "0.1","ib": "0.1","ic": "0.1","pa": "50","pb": "50","pc": "50","pfa": "0.4","pfb": "0.4","pfc": "0.4","f": "50","ep": "123","eq": "123","es": "456","esFan": "0","esAir": "0", "esLamp": "0"}]
     * @param reMessage
     * @param ser
     */
    public void analysis4001(ReMessage reMessage, DeviceSer ser) {

        List<Response4001> result = JSON.parseArray(reMessage.getContent(), Response4001.class);

        //有功电能判断是否返回有效数据
        if (null == result || result.isEmpty()) {
            log.error("---能耗返回数据为空，停止解析----{}", reMessage.toString());
            return;
        }

        EsData esData;
        for (Response4001 response : result) {
            if (null == response.getEp()) {
                log.error("---能耗数据返回数据不完整，停止解析----{}", reMessage.toString());
                return;
            }
            esData = new EsData();
            esData.setCompanyId(ser.getCompanyId());
            esData.setDepotId(response.getHouseId());
            esData.setDeviceId(StringUtils.isEmpty(response.getDeviceId())?"0":response.getDeviceId());
            esData.setDeviceName(response.getDeviceName());
            esData.setUpdateTime(new Date());
            esData.setUa(response.getUa());
            esData.setUb(response.getUb());
            esData.setUc(response.getUc());

            esData.setIa(response.getIa());
            esData.setIb(response.getIb());
            esData.setIc(response.getIc());
            esData.setF(response.getF() == null ? 0.0 : response.getF());

            esData.setEp(response.getEp());
            esData.setEq(response.getEq());
            if (null != response.getEs()) {
                esData.setEs(response.getEs());
            } else {
                esData.setEs(0.0);
            }

            esData.setEsFan(response.getEsFan() == null ? 0.0 : response.getEsFan());
            esData.setEsAir(response.getEsAir() == null ? 0.0 : response.getEsAir());
            esData.setEsLamp(response.getEsLamp() == null ? 0.0 : response.getEsLamp());

            log.info("控制柜----->>>平台：能耗数据解析完成-仓库={}", esData.getDepotId());

            esService.saveAndUpdateInc(esData);
        }
    }

}