package protocol import ( "encoding/hex" "github.com/gogf/gf/os/glog" "strconv" ) type Dlt_0x33343435 struct { //接收表号 DeviceAddress []byte //表号 DeviceID string //当前A相电压 VoltageA float64 } func (e *Dlt_0x33343435) MsgID() MsgID { return Msgdlt_0x33343435 } func (e *Dlt_0x33343435) Encode(ctx *PacketContext) ([]byte, error) { writer := NewWriter() // 接收符号 writer.Write([]byte{0x68}) writer.Write(ctx.GetReceiveAddress()) writer.Write([]byte{0x68, 0x11, 0x04, 0x33, 0x34, 0x34, 0x35}) //cs效验位 var one byte for _, v := range writer.Bytes() { one += v } writer.WriteByte(one) // 功能码 writer.WriteByte(0x16) return writer.Bytes(), nil } func (e *Dlt_0x33343435) Decode(ctx *PacketContext, dataByte []byte, data *Data) (err error) { bytea := dataByte[1:7] for i, j := 0, len(bytea)-1; i < j; i, j = i+1, j-1 { bytea[i], bytea[j] = bytea[j], bytea[i] } e.DeviceID = hex.EncodeToString(bytea) //正向总电能每个字节-33,1-4,分别为,小数位,个位,百位,万位 byteb := make([]byte, 2) for i := 0; i < 2; i++ { byteb[i] = dataByte[14+i] - 0x33 } e.VoltageA, err = stringToVoltage(hex.EncodeToString(byteb)) if err != nil { return err } glog.Debugf("数据读取成功:表号:%s,当前A相电压:%2f", e.DeviceID, e.VoltageA) data.DataType = IsVData return nil } func stringToVoltage(s string) (float64, error) { a0, _ := strconv.ParseFloat(s[0:2], 64) a1, _ := strconv.ParseFloat(s[2:4], 64) res := a0*0.1 + a1*10 return res, nil }