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


import com.alibaba.fastjson.JSONObject;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.pressure.dto.PressureData;
import com.ld.igds.pressure.service.CorePressureService;
import com.ld.igds.protocol.fzzy.dto.ReMessage;
import com.ld.igds.protocol.fzzy.resp.Response3304;
import com.ld.igds.util.ContextUtil;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 氮气解析
 *
 * @author andy
 */
@Component(AnalysisN2.BEAN_ID)
@Slf4j
public class AnalysisN2 {

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


    @Autowired
    private CorePressureService pressureService;


    public void analysis3301(ReMessage message, DeviceSer ser) {
    }

    public void analysis3302(ReMessage message, DeviceSer ser) {
    }

    public void analysis3303(ReMessage message, DeviceSer ser) {
    }

    /**
     * 气压返回
     *
     * @param reMessage
     * @param ser
     */
    public void analysis3304(ReMessage reMessage, DeviceSer ser) {

        Response3304 response = JSONObject.parseObject(reMessage.getContent(), Response3304.class);

        PressureData pressureData = new PressureData();
        pressureData.setBatchId(ContextUtil.getDefaultBatchId());
        pressureData.setDepotId(response.getHouseId());
        pressureData.setCheckUser(null);
        pressureData.setCompanyId(ser.getCompanyId());
        pressureData.setPointNum(1);
        pressureData.setPoints(null);
        pressureData.setPressure(response.getPAvg());
        pressureData.setPressureMax(response.getPMax());
        pressureData.setPressureMin(response.getPMin());

        pressureService.savePressure(pressureData);

        log.info("控制柜----->>>平台：气压解析完成-控制柜={}", ser.getName());
    }
}