lcfns/gatewayServer/gatewayProtocol.go

package gatewayServer

import (
	"bytes"
	"encoding/binary"
	"encoding/hex"
	"fmt"

	"strings"
)

type CmdCode uint16

/*设备->服务端：命令码0x4xxx开头；
  服务端->设备：命令码0x8xxx开头；
*/

const (
	CmdCodeServerC2S    CmdCode = 0x4000 //获取管理服务器请求
	CmdCodeServerS2C    CmdCode = 0x8000 //获取管理服务器应答
	CmdCodeRegisterC2S  CmdCode = 0x4001 //设备注册登录请求
	CmdCodeRegisterS2C  CmdCode = 0x8001 //设备注册登陆应答
	CmdCodeHeartbeatC2S CmdCode = 0x4002 //设备心跳请求
	CmdCodeHeartbeatS2C CmdCode = 0x8002 //设备心跳应答
	CmdCodeGetParamS2C  CmdCode = 0x8003 //获取设备配置参数请求
	CmdCodeGetParamC2S  CmdCode = 0x4003 //获取设备配置参数应答
	CmdCodeUpdateS2C    CmdCode = 0x8101 //开始设备升级请求
	CmdCodeUpdateC2S    CmdCode = 0x4101 //设备升级应答

	CmdCodeSetParameterS2C CmdCode = 0x8004 //配置设备参数请求
	CmdCodeSetParameterC2S CmdCode = 0x4004 //配置设备参数应答
	SubCodeWAN             CmdCode = 0x0001 //WAN口参数配置
	SubCodeLAN             CmdCode = 0x0002 //LAN口参数配置
	SubCodeWiFi            CmdCode = 0x0003 //WiFi参数配置
	SubCodeDetection       CmdCode = 0x0004 //在线探测参数配置
	SubCodePPTP            CmdCode = 0x1001 //PPTP参数配置
	SubCodeL2TP            CmdCode = 0x1002 //L2TP参数配置
	SubCodeSerialPort      CmdCode = 0x2001 //串口应用配置
	SubCodeFlowRate        CmdCode = 0x2002 //流量统计配置
	SubCodeInfo            CmdCode = 0x3001 //系统基本信息配置
	SubCodeTime            CmdCode = 0x3002 //时间设置
	SubCodeRecover         CmdCode = 0x3003 //恢复出厂设置
	SubCodeReboot          CmdCode = 0x3004 //重启
	SubCodePortTrans       CmdCode = 0x5001 //端口转发
)

type AppDataUnit struct {
	Start          []byte
	Length         uint16
	identification string
	CmdCode        CmdCode
	SubCode        CmdCode
	DevId          string
	Data           string
	CheckCode      []byte
}

func (adu AppDataUnit) String() string {
	return fmt.Sprintf(`
    报头标识:%s
	数据长度:%X
	包标识:%s
	命令码:%4X
	子命令码:%04X
	设备ID:%s
	DATA:%s
	CRC:%X
    `, adu.Start, adu.Length, adu.identification, adu.CmdCode, adu.SubCode, adu.DevId, adu.Data, adu.CheckCode)
}

func (adu AppDataUnit) Debug() {
	if !openDebug {
		return
	}
	if adu.Start == nil {
		fmt.Println(UnPack(Pack(adu)))
	} else {
		fmt.Println(adu)
	}
}

func UnPack(data []byte) AppDataUnit {
	//todo 校验数据
	var res = AppDataUnit{
		Start:          data[:2],
		Length:         Bin2UInt16(data[2:4], binary.BigEndian),
		identification: hex.EncodeToString(data[4:36]),
		CmdCode:        CmdCode(Bin2UInt16(data[36:38], binary.BigEndian)),
		SubCode:        CmdCode(Bin2UInt16(data[38:40], binary.BigEndian)),
		DevId:          strings.Trim(string(data[40:52]), string(byte(0))),
		CheckCode:      data[len(data)-2:],
	}
	if res.Length-54 > 0 {
		res.Data = string(data[52 : len(data)-2])
	} else {
		res.Data = ""
	}
	return res
}

func Pack(adu AppDataUnit) []byte {
	//devId不够12位补ascii空值
	for i := 0; i < 12-len(adu.DevId); i++ {
		adu.DevId = adu.DevId + string(byte(0))
	}
	//fmt.Println("len:", len(adu.DevId), " DevId ", adu.DevId)
	var buf []byte
	writer := bytes.NewBuffer(buf)
	writer.Write([]byte("@@"))                                                                                           //起始
	writer.Write(Uint16ToBin(uint16(54+len(adu.Data)), binary.BigEndian))                                                //长度
	writer.Write([]byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0}) //包标识
	writer.Write(Uint16ToBin(uint16(adu.CmdCode), binary.BigEndian))                                                     //命令码
	writer.Write(Uint16ToBin(uint16(adu.SubCode), binary.BigEndian))                                                     //子命令码
	writer.Write([]byte(adu.DevId))                                                                                      //设备ID
	writer.Write([]byte(adu.Data))                                                                                       //数据内容
	writer.Write(CRC16(writer.Bytes(), len(writer.Bytes())))                                                             //校验
	//fmt.Printf("% 02X", writer.Bytes())
	return writer.Bytes()
}

func CRC16(data []byte, dataLen int) []byte {
	var uchCRCHi byte = 0xFF
	var uchCRCLo byte = 0xFF
	var uIndex uint16

	for i := 0; i < int(dataLen); i++ {
		uIndex = uint16(uchCRCLo) ^ uint16(data[i])
		uchCRCLo = uchCRCHi ^ auchCRCHi[uIndex]
		uchCRCHi = auchCRCLo[uIndex]
	}
	crc := (uint16(uchCRCHi) << 8) | uint16(uchCRCLo)
	return Uint16ToBin(crc, binary.BigEndian)
}

var auchCRCHi = []byte{
	0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
	0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
	0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01,
	0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
	0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81,
	0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
	0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01,
	0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
	0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
	0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
	0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01,
	0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
	0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
	0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
	0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01,
	0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
	0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
	0x40,
}

var auchCRCLo = []byte{
	0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06, 0x07, 0xC7, 0x05, 0xC5, 0xC4,
	0x04, 0xCC, 0x0C, 0x0D, 0xCD, 0x0F, 0xCF, 0xCE, 0x0E, 0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09,
	0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A, 0x1E, 0xDE, 0xDF, 0x1F, 0xDD,
	0x1D, 0x1C, 0xDC, 0x14, 0xD4, 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
	0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3, 0xF2, 0x32, 0x36, 0xF6, 0xF7,
	0x37, 0xF5, 0x35, 0x34, 0xF4, 0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A,
	0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38, 0x28, 0xE8, 0xE9, 0x29, 0xEB, 0x2B, 0x2A, 0xEA, 0xEE,
	0x2E, 0x2F, 0xEF, 0x2D, 0xED, 0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
	0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60, 0x61, 0xA1, 0x63, 0xA3, 0xA2,
	0x62, 0x66, 0xA6, 0xA7, 0x67, 0xA5, 0x65, 0x64, 0xA4, 0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F,
	0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68, 0x78, 0xB8, 0xB9, 0x79, 0xBB,
	0x7B, 0x7A, 0xBA, 0xBE, 0x7E, 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
	0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71, 0x70, 0xB0, 0x50, 0x90, 0x91,
	0x51, 0x93, 0x53, 0x52, 0x92, 0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C,
	0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E, 0x5A, 0x9A, 0x9B, 0x5B, 0x99, 0x59, 0x58, 0x98, 0x88,
	0x48, 0x49, 0x89, 0x4B, 0x8B, 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
	0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42, 0x43, 0x83, 0x41, 0x81, 0x80,
	0x40,
}