package com.ld.igds.protocol.bhzn.verb.analysis;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.common.CoreDeviceService;
import com.ld.igds.constant.BizType;
import com.ld.igds.es.dto.EsData;
import com.ld.igds.es.service.CoreEsService;
import com.ld.igds.gas.CoreGasService;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.notify.NotifyWebInvoker;
import com.ld.igds.models.DepotConf;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.models.Gas;
import com.ld.igds.models.GasInfo;
import com.ld.igds.protocol.bhzn.verb.command.BaseRemoteImpl;
import com.ld.igds.protocol.bhzn.verb.dto.IoMessage;
import com.ld.igds.protocol.bhzn.verb.dto.Res208;
import com.ld.igds.protocol.bhzn.verb.dto.Res209;
import com.ld.igds.util.ContextUtil;
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.text.DecimalFormat;
import java.text.NumberFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 能耗解析
 */
@Slf4j
@Component(AnalysisES.BEAN_ID)
public class AnalysisES extends BaseRemoteImpl {

    public static final String BEAN_ID = "bhzn.analysisEs";

    @Autowired
    private CoreDeviceService deviceService;
    @Autowired
    private NotifyWebInvoker notifyInvoker;
    @Autowired
    private CoreCommonService commonService;
    @Autowired
    private CoreEsService esService;

    /**
     * 设备状态
     *
     * @param reMessage
     * @param ser
     */
    public void analysis(IoMessage reMessage, DeviceSer ser) {

        log.info("能耗开始解析");
        Res208 res208 = JSONObject.parseObject(reMessage.getContentStr(), Res208.class);
        if(2==res208.getState()){

        }else{
            log.info("气体没有采集完成，取消解析！");
            return;
        }
        DepotConf depotConf = commonService.getCacheDepotConfBySerId(ser.getCompanyId(),ser.getId() );

        EsData esData = new EsData();
        esData.setCompanyId(ser.getCompanyId());
        esData.setDepotId(depotConf.getDepotId());
        esData.setDeviceId("0");
        esData.setDeviceName("");
        esData.setUpdateTime(new Date());
        esData.setUa(Double.valueOf(res208.getVA()));
        esData.setUb(Double.valueOf(res208.getVB()));
        esData.setUc(Double.valueOf(res208.getVC()));

        esData.setIa(Double.valueOf(res208.getIA()));
        esData.setIb(Double.valueOf(res208.getIB()));
        esData.setIc(Double.valueOf(res208.getIC()));
        esData.setF(Double.valueOf(res208.getZPL()));

        esData.setEp(0.0);
        esData.setEq(0.0);
        esData.setEs(0.0);
        esData.setEsFan(0.0);
        esData.setEsAir(0.0);
        esData.setEsLamp(0.0);
        esData.setEs(res208.getZNH());
        log.info("控制柜----->>>平台：能耗数据解析完成-仓库={}", esData.getDepotId());

        esService.saveAndUpdateInc(esData);
    }

}