package com.sandu.ximon.admin.manager.iot.rrpc.util;

import cn.hutool.core.codec.Base64;
import cn.hutool.core.util.HexUtil;
import cn.hutool.core.util.StrUtil;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;

/**
 * @author chenjiantian
 * @date 2021/12/3 17:36
 */
public class FrameUtils {

    /**
     * 把上报的内容 转化成帧实体类
     * @param value 上报内容 {{@link com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonReportMessage.Params}}
     * @return 帧实体类
     */
    public static CommonFrame transformMessageToFrame(String value) {
        String hex = decodeReportMessage(value);
        if (hex == null || hex.length() < 18) {
            return null;
        }
        //  将十六进制数转为大写
        hex = hex.toUpperCase();
        CommonFrame frame = new CommonFrame();
        // MQTT通信方式(1)
        frame.setConnectType(hex.substring(0, 2));
        //  功能码(1)
        frame.setFunctionCode(hex.substring(2, 4));
        //  命令类型(1)
        frame.setOrderType(hex.substring(4, 6));
        //  负荷长度(2)
        frame.setPayloadLength(hex.substring(6, 10));
        //  响应payload
        frame.setPayload(hex.substring(10, hex.length() - 8));
        //  校验码(4)
        frame.setCrc32(hex.substring(hex.length() - 8));
        //  判断校验是否通过
        String content = hex.substring(2, hex.length() - 8);
        frame.setValidate(CRC32Utils.validateFrame(content, frame.getCrc32()));

        return frame;
    }

    public static void main(String[] args) {
        System.out.println(HexUtil.hexToInt("FF"));
        System.out.println(transformMessageToFrame("/qWEACrwAQAi//8BAQEYAB4CAAAAAAAAAApcAAAAEAAVAAAAAwAQAagAAMPfU3KbHyny").toString());
    }

    /**
     * 将设备上报的内容解码
     *
     * @param value 设备上报的内容
     * @return 解码后的内容，16进制
     */
    public static String decodeReportMessage(String value) {
        if (StrUtil.isBlank(value)) {
            return null;
        }
        byte[] decode = Base64.decode(value.getBytes());
        return HexUtil.encodeHexStr(decode);
    }

    /**
     * 将准备发送的内容编码
     * @param value 待编码内容
     * @return 编码后的内容 字符串
     */
    public static String encodeReportMessage(String value) {
        if (StrUtil.isBlank(value)) {
            return null;
        }
        byte[] bytes = HexUtil.decodeHex(value);
        String encode = Base64.encode(bytes);
        return encode;
    }

}