decode.go

package main

import (
	"bytes"
	"encoding/binary"
	"errors"
	"fmt"
	"net"
	"strconv"
	"strings"
	"time"
)

type NRL21packet struct {
	timeStamp  time.Time
	UDPAddrStr string
	UDPAddr    *net.UDPAddr //报文来源UDP地址和端口
	Version    string       //协议标识 “NRL2” 每个报文都以 NRL2 4个字节开头
	Length     uint16       //上层数据长度
	CPUID      string       //设备唯一标识 长度7字节
	Password   string       //密码
	Type       byte         //上层数据类型 一个字节 0:保留， 1：G.711语音，2：心跳  3：设备配置 4：保留，5. 文本消息，6，设备控制设备， 7，设备要求加入组等指令
	Status     byte         //设备状态位
	Count      uint16       //报文计数器2节
	CallSign   string       //所有者呼号 6字节
	SSID       byte         //所有者呼号 1字节
	DevMode    byte         //设备型号
	DATA       []byte       //上层数据内容
}

func (n *NRL21packet) decodeNRL21(d []byte) (err error) {

	if len(d) < 48 {
		return errors.New("packet too short ")
	}
	n.Version = string(d[0:4])

	if n.Version != "NRL2" {
		return errors.New("not NRL packet ")
	}

	n.Length = binary.BigEndian.Uint16(d[4:6])

	n.CPUID = fmt.Sprintf("%02X", d[6:10])
	n.Password = fmt.Sprintf("%02X", d[10:13])
	n.Type = d[20]
	n.Status = d[21]
	n.Count = binary.BigEndian.Uint16(d[21:23])
	n.CallSign = string(bytes.TrimRight(d[24:30], string([]byte{13, 0})))
	n.SSID = d[30]
	n.DevMode = d[31]
	n.DATA = d[48:]

	return nil

}

func (n *NRL21packet) String() string {
	return fmt.Sprintf("ver:%v len:%v CPUID:%v CallSign:%v-%v type:%v len:%v  Count:%v  %02X ", n.Version, n.Length, n.CPUID, n.CallSign, n.SSID, n.Type, len(n.DATA), n.Count, n.DATA)
}

type G711Voice struct {
	Number uint32
	DATA   []byte
}

func calculateCpuId(callSign string) []byte {
	// 将字符串生成 32 位哈希值
	var hash uint32 = 0
	for _, char := range callSign {
		hash = (hash*31 + uint32(char))
	}

	cpuIdBytes := make([]byte, 4)
	binary.BigEndian.PutUint32(cpuIdBytes[:4], hash)

	return cpuIdBytes

	// 将哈希值转换为 7 字节的十六进制字符串

}

func NRL21replace200dev(callsign string, ssid, packetType, DevMode uint8, cpuid, data []byte) (packet []byte) {

	packet = make([]byte, len(data))

	copy(packet, data)

	// 写入 CPUID

	copy(packet[6:11], cpuid)

	// 写入 CallSign
	copy(packet[24:30], callsign)

	// 写入 SSID
	packet[30] = ssid

	// 写入 DevMode
	packet[31] = DevMode

	return packet

}

func encodeNRL21(callsign string, ssid, packetType, DevMode uint8, cpuid, data []byte) (packet []byte) {

	//编码报名

	const fixedBufferSize = 48

	// 计算总大小
	totalSize := fixedBufferSize + len(data)

	// 创建字节切片
	packet = make([]byte, totalSize)

	// 写入固定头部
	copy(packet[0:4], []byte("NRL2"))

	// 写入长度
	binary.BigEndian.PutUint16(packet[4:6], uint16(totalSize))

	// 写入 CPUID

	copy(packet[6:11], cpuid)

	// 写入 Type  2
	packet[20] = packetType

	// 写入 Status
	packet[21] = 1

	// 写入 Count
	// binary.BigEndian.PutUint16(data[18:20], n.Count)

	// 写入 CallSign
	copy(packet[24:30], callsign)

	// 写入 SSID
	packet[30] = ssid

	// 写入 DevMode
	packet[31] = DevMode

	// 写入 DATA
	if len(data) > 0 {
		copy(packet[48:], data)
	}

	return packet

}

func getCallsignSSID(callsign string, ssid byte) string {

	var builder strings.Builder

	// 拼接字符串
	builder.WriteString(callsign)
	builder.WriteString("-")
	builder.WriteString(strconv.Itoa(int(ssid)))
	return builder.String()
}

// type COMData struct {
// 	Number int32
// 	DATA   []byte
// }

// type controlData struct {
// 	DeviceID    string
// 	SubDeviceID string
// 	Value       int
// }