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

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.common.CoreDeviceService;
import com.ld.igds.io.notify.NotifyWebInvoker;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.protocol.fzzy.ServerUtils;
import com.ld.igds.protocol.fzzy.command.BaseRemoteImpl;
import com.ld.igds.protocol.fzzy.dto.ReMessage;
import com.ld.igds.protocol.fzzy.resp.Response5002;
import com.ld.igds.temp.dto.TempParam;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 温度
 *
 * @author andy.jia
 */
@Slf4j
@Component(AnalysisTemp.BEAN_ID)
public class AnalysisTemp extends BaseRemoteImpl {

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

    @Autowired
    private CoreDeviceService deviceService;
    @Autowired
    private NotifyWebInvoker notifyInvoker;

    public void analysis5001(ReMessage message, DeviceSer ser) {
        log.debug("-DO NOTHING-");
        //DO NOTHING
    }

    public void analysis5002(ReMessage reMessage, DeviceSer ser) {

        Response5002 resp = JSONObject.parseObject(reMessage.getContent(), Response5002.class);
        ServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(), resp.getDeviceId(), resp.getStatus());

        TempParam param = new TempParam();
        param.setId(ser.getId());
        param.setTargetTemp(resp.getTemp());
        param.setTargetStatus(resp.getStatus());
        param.setTargetModel(resp.getMode());
        deviceService.updateTempControlInfo(param);

        notifyInvoker.notifyAnalysisStatusSuccess(ser.getCompanyId(),ser.getId(), OrderRespEnum.MSG_SUCCESS, "设备状态查询成功并完成解析！");
    }
}