package com.fzzy.protocol.zldz.analysis;

import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiCommonDevice;
import com.fzzy.api.utils.BytesUtil;
import com.fzzy.gateway.entity.GatewayDevice;
import com.fzzy.gateway.service.GatewayDeviceService;
import com.fzzy.protocol.zldz.data.ReMessage;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * @author vince
 */
@Slf4j
@Component(AnalysisConf.BEAN_ID)
public class AnalysisConf {

    public static final String BEAN_ID = "zldz.analysisConf";

    @Resource
    private GatewayDeviceService gatewayDeviceService;

    /**
     * 解析分机配置信息
     *
     * @param message
     * @param device
     */
    public void analysis8816(ReMessage message, GatewayDevice device, ApiCommonDevice commonDevice) {

        log.debug("分机---->>>平台：消息类型=8816-----{}", device.getDeviceName());

        String content = message.getBody().getContent();

        // 读写标志
        int start = 0, len = 1;
        String temp = content.substring(start * 2, start * 2 + len * 2);
        int readTag = BytesUtil.hexToInt(temp);

        // 设备ID，全局唯一
        start = 1;
        len = 2;
        temp = content.substring(start * 2, start * 2 + len * 2);

        // 网络ID
        start = 3;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);

        // 信道
        start = 4;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);

        // 速率
        start = 5;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);

        //层 -行 -列
        String cable = "";
        // 层数
        start = 6;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);
        cable += BytesUtil.hexToInt(temp);

        // 行数
        start = 7;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);
        cable += "-" + BytesUtil.hexToInt(temp);

        // 列数
        start = 8;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);
        cable += "-" + BytesUtil.hexToInt(temp);


        // 电缆制式
        start = 9;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);
        device.setCableFormat("0" + BytesUtil.hexToInt(temp));

        // 电缆类型
        start = 10;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);
        device.setCableType("0" + BytesUtil.hexToInt(temp));

        // 供电模式
        start = 11;
        len = 1;
        temp = content.substring(start * 2, start * 2 + len * 2);
        //ser.setPowerModel("0" + BytesUtil.hexToInt(temp));


        // 组织编码
        start = 12;
        temp = content.substring(start * 2);
        if (readTag != 1) {// 表示写的成功返回
            device.setOrgId(BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) + "");
        }

        device.setIp(message.getIp());
        device.setPort(message.getPort());

        // 开始列默认=1
        if (null == device.getCableStart()) {
            device.setCableStart("1");
        }

        log.info("分机---->>>平台：分机配置解析完成---{}，更新到服服务器",
                device.getDeviceName());

        //更新设备信息
        gatewayDeviceService.updateData(device);

        //更新连接设备信息
        commonDevice.setSn(device.getDeviceSn());
        commonDevice.setCable(cable);
        commonDevice.setOrgId(device.getOrgId());
        Constant.updateCache(commonDevice);
    }

    /**
     * 电缆初始化成功
     *
     * @param reMessage
     * @param ser
     */
    public void analysis8822(ReMessage reMessage, GatewayDevice ser) {
        log.info("--------电缆初始化成功------------{}", ser.getDeviceName());
    }

    /**
     * 电缆修改返回，
     *
     * @param reMessage
     * @param ser
     */
    public void analysis8826(ReMessage reMessage, GatewayDevice ser) {
        log.info("--------修改电缆信息返回------------{}", ser.getDeviceName());
    }

    /**
     * 通道电缆获取返回，分机返回收到命令信息，实际返回值在8829中说明
     *
     * @param reMessage
     * @param ser
     */
    public void analysis8825(ReMessage reMessage, GatewayDevice ser) {
        log.info("--------通道电缆获取返回------------{}", ser.getDeviceName());
    }

    /**
     * 终端发送通道电缆数据给后台，分机主动推送
     *
     * @param reMessage
     * @param ser
     */
    @SuppressWarnings("unchecked")
    public void analysis1129(ReMessage reMessage, GatewayDevice ser) {
        log.info("--------终端发送通道电缆数据给后台------------{}", ser.getDeviceName());
    }

    /**
     * 电缆汇总应答
     *
     * @param reMessage
     * @param ser
     */
    public void analysis8823(ReMessage reMessage, GatewayDevice ser) {
        // 开始解析
        String content = reMessage.getBody().getContent();

        //DO NOTHING
    }
}