package com.fzzy.protocol.fzzy.analysis;

import com.alibaba.fastjson.JSONObject;
import com.fzzy.api.data.ApiCommonDevice;
import com.fzzy.gateway.data.BaseReqData;
import com.fzzy.protocol.fzzy.builder.SimpleCommandBuilder;
import com.fzzy.protocol.fzzy.cmd.BaseRemoteImpl;
import com.fzzy.protocol.fzzy.data.ReMessage;
import com.fzzy.protocol.fzzy.data.SendMessage;
import com.fzzy.protocol.fzzy.resp.Response2102;
import com.fzzy.protocol.fzzy.server.ServerUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * 粮情解析
 *
 * @author Andy
 */
@Slf4j
@Component(AnalysisGrain.BEAN_ID)
public class AnalysisGrain extends BaseRemoteImpl {

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


    public static int ERROR_CHECK_TAG = -1000;//粮温，气体，虫害，故障值

    public static int ERROR_CHECK_TAG2 = -2000;//传感器故障或者不在线


    public void analysis2101(ReMessage reMessage, ApiCommonDevice ser) {
        //DO NOTHING
    }

    /**
     * 粮情返回信息解析
     *
     * @param reMessage
     * @param ser
     */
    public void analysis2102(ReMessage reMessage, ApiCommonDevice ser) {

        try {

            //返回控制柜信息
            returnMsg(ser);

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

            String depotId = response.getHouseId();

            //获取请求信息
            BaseReqData reqData = ServerUtils.getSyncReq(depotId);


            //粮情解析
            log.info("控制柜--->平台粮情信息--{}", response);


        } catch (Exception e) {

            log.error("控制柜--->平台粮情信息异常-{}", e);

        }
    }

    private void returnMsg(ApiCommonDevice ser) {
        //先回复控制柜
        SimpleCommandBuilder commandBuilder = SimpleCommandBuilder.getInstance();
        SendMessage message = commandBuilder.buildMessage(ser, ServerUtils.FUNCTION_2102);
        send(message);
    }
}