package com.hdl.sdk.link.core.utils;

import com.hdl.sdk.link.common.utils.LogUtils;
import com.hdl.sdk.link.core.bean.BusProRequest;

import java.util.HashMap;
import java.util.Map;

/**
 * buspro协议工具类
 * Created by hxb on 2024/3/25.
 */
public class BusProUtils {

    //HDLMIRACLE的值
    static final byte[] matchHdlBytes = new byte[]{'H','D','L','M','I','R','A','C','L','E'};

    /**
     * 操作码对应匹配回复数据的索引，主要为了实现数据发送后能正常回调，Byte[]是附加数据的偏移量
     */
    private static final HashMap<String, Byte[]> matchIndex = new HashMap();

    static final String TAG = "BusProUtils";

    /**
     * 本设备子网号，默认值99
     */
    private static byte sourceSubnetId = 99;
    /**
     * 本设备设备号，默认值99
     */
    private static byte sourceDeviceId = 99;
    /**
     * 本设备设备类型，默认0xFEFE
     */
    private static byte[] deviceType = new byte[]{(byte) 0xFE, (byte) 0xFE};

    /**
     * 获取本地设备Id
     *
     * @return
     */
    public static byte getSourceSubnetId() {
        return sourceSubnetId;
    }

    /**
     * 设置本地设备Id
     */
    public static void setSourceSubnetId(byte sourceSubnetId) {
        BusProUtils.sourceSubnetId = sourceSubnetId;
    }

    /**
     * 获取本地设备Id
     */
    public static byte getSourceDeviceId() {
        return sourceDeviceId;
    }

    /**
     * 设置本地设备Id
     */
    public static void setSourceDeviceId(byte sourceDeviceId) {
        BusProUtils.sourceDeviceId = sourceDeviceId;
    }

    /**
     * 获取设备类型
     */
    public static byte[] getDeviceType() {
        return deviceType;
    }

    /**
     * 设置设备类型
     *
     * @param deviceType
     */
    public static void setDeviceType(byte[] deviceType) {
        BusProUtils.deviceType = deviceType;
    }

    /**
     * 是否buspro数据格式
     *
     * @param bytes bus协议每条数据
     * @return true表示是bus协议数据，false表示不是
     */
    public static boolean isBusProBytes(byte[] bytes) {
        //类似接收到以下数据 C0 A8 01 66 48 44 4C 4D 49 52 41 43 4C 45 AA AA 0B FD FE FF FE 00 0E FF FF A0 0D
        if (bytes == null || bytes.length < 27) {//最小的buspro数据包大小为27个byte
            return false;
        }

        for (int i = 0; i < matchHdlBytes.length; i++) {
            //HDLMIRACLE是从接收数据的索引4开始，前面4位是IP地址
            if (matchHdlBytes[i] != bytes[4 + i]) {
                return false;
            }
        }
        return true;
    }

    /**
     * 通过请求对象获取发送数据
     *
     * @param busProRequest bus协议的封装数据
     * @return 最终发出去的bus数据
     */
    public static byte[] getBusBytes(BusProRequest busProRequest) {
        if (busProRequest == null) {
            return null;
        }
        byte[] extraBytes = busProRequest.getExtraBytes();
        if (extraBytes == null) {
            LogUtils.i(TAG, "附加数据为null");
        }
        // 要计算CRC的数据和CRC两个字节
        byte[] crcBytes = new byte[9 + extraBytes.length + 2];

        // 发送出去的数据
        byte[] sendBytes = new byte[16 + crcBytes.length];

//        String[] ip = Net.CurrentNet.getPsdnIp().split("\\.");
//        // IP地址
//        sendBytes[0] = (byte) Global.GetStringToInteger(ip[0]);
//        sendBytes[1] = (byte) Global.GetStringToInteger(ip[1]);
//        sendBytes[2] = (byte) Global.GetStringToInteger(ip[2]);
//        sendBytes[3] = (byte) Global.GetStringToInteger(ip[3]);

        // HDLMIRACLE
        sendBytes[4] = (byte) 'H';
        sendBytes[5] = (byte) 'D';
        sendBytes[6] = (byte) 'L';
        sendBytes[7] = (byte) 'M';
        sendBytes[8] = (byte) 'I';
        sendBytes[9] = (byte) 'R';
        sendBytes[10] = (byte) 'A';
        sendBytes[11] = (byte) 'C';
        sendBytes[12] = (byte) 'L';
        sendBytes[13] = (byte) 'E';
        // 引导码
        sendBytes[14] = (byte) 0xAA;
        sendBytes[15] = (byte) 0xAA;

        // 16 数据包长度 11-78
        crcBytes[0] = (byte) crcBytes.length;
        // 17 源子网地址 0-254
        crcBytes[1] = sourceSubnetId;
        // 18 源设备地址 0-254
        crcBytes[2] = sourceDeviceId;
        byte[] deviceType = getDeviceType();
        if (deviceType == null || deviceType.length < 2) {
            LogUtils.i(TAG, "设备类型为null或者长度小于2");
        }
        // 19 源设备类型高位
        crcBytes[3] = deviceType[0];
        // 20 源设备类型低位
        crcBytes[4] = deviceType[1];

        byte[] command = busProRequest.getCommand();
        if (command == null || command.length < 2) {
            LogUtils.i(TAG, "操作码为null或者长度小于2");
        }
        // 21 操作码高位
        crcBytes[5] = busProRequest.getCommand()[0];
        // 22 操作码低位
        crcBytes[6] = busProRequest.getCommand()[1];
        // 23 目标子网地址 0-254
        crcBytes[7] = busProRequest.getDesSubnetId();
        // 24 目标设备地址 0-254
        crcBytes[8] = busProRequest.getDesDeviceId();
        // 25~n附加数据
        System.arraycopy(extraBytes, 0, crcBytes, 9, extraBytes.length);
        // CRC校验
        CRCUtil.ConCRC(crcBytes, crcBytes.length - 2);

        // 复制CRC数据到发送数据里面
        System.arraycopy(crcBytes, 0, sendBytes, 16, crcBytes.length);

        return sendBytes;
    }

    /**
     * 根据操作码动态获取匹配数据
     * @param subnetId 子网号
     * @param deviceId 设备号
     * @param command  操作码
     * @param extraBytes 发送或者接收到的附加数据
     * @return
     */
    public static String getMatchString(byte subnetId, byte deviceId, byte[] command, byte[] extraBytes) {
        String commandString=ByteUtils.encodeHexString(command);
        String result = String.format("BusPro_%s%s%s", ByteUtils.encodeHexString(subnetId), ByteUtils.encodeHexString(deviceId), commandString);
        Byte[] value = matchIndex.get(commandString);
        if (value != null) {
            //value[i]是附加数据偏移量，从0开始
            for (int i = 0; i < value.length; i++) {
                result += String.format("%s", ByteUtils.encodeHexString(extraBytes[value[i]]));
            }
        }
        return result;
    }

    public static void setMatchIndex(String key,Byte []value)
    {
        matchIndex.put(key,value);
    }

}