串口支持大数读写

zhangqian

2023-11-03 7335d19846ad4f5b0a61541a992d61763c5cf35b

 pkg/plccom/mitsubishi/protocol.go

@@ -44,6 +44,28 @@
   return proto
}

// MakeReadProtocolBits 三菱读协议, addr 是要读取的寄存器地址
func (p *ProtocolMitsubishi) MakeReadProtocolBits(bits int, addr string) []byte {
   // 02 表示开始 + 30 表示读数据 + 4位地址位 + 02 数据长度 + 03 停止 + 偶校验

   pro := []byte{0x30}
   pro = append(pro, []byte(addr)...)
   if bits == 16 {
      pro = append(pro, []byte("02")...)
   } else if bits == 32 {
      pro = append(pro, []byte("04")...)
   }
   pro = append(pro, []byte{0x03}...)

   crc := crc(pro)

   proto := []byte{0x02}
   proto = append(proto, pro...)
   proto = append(proto, []byte(crc)...)

   return proto
}

// MakeWriteProtocol 创建写入数据的协议
func (p *ProtocolMitsubishi) MakeWriteProtocol(addr string, value int) []byte {
   valueStr := fmt.Sprintf("000%X", value)
@@ -66,6 +88,46 @@
   return proto
}

func (p *ProtocolMitsubishi) MakeWriteProtocolBits(bits int, addr string, ival int) []byte {

   // 02 表示开始 + 31 表示写数据 + 4位地址位 + 02 数据长度 + 03 停止 + 偶校验
   proto := []byte{0x31}
   proto = append(proto, []byte(addr)...)
   if bits == 16 {
      proto = append(proto, []byte("02")...)

      vstr := fmt.Sprintf("000%X", ival)
      val := vstr[len(vstr)-2:]
      val += vstr[len(vstr)-4 : len(vstr)-2]
      proto = append(proto, val...)
   } else if bits == 32 {
      proto = append(proto, []byte("04")...)

      vstr := fmt.Sprintf("0000000%X", ival)
      // 低16位
      low := vstr[len(vstr)-4:]
      // 高16位
      high := vstr[len(vstr)-8 : len(vstr)-4]
      // 先存储低16位
      val := low[2:]
      val += low[0:2]
      proto = append(proto, val...)
      val = high[2:]
      val += high[0:2]
      proto = append(proto, val...)
   }

   proto = append(proto, []byte{0x03}...)

   crc := crc(proto)

   pro := []byte{0x02}
   pro = append(pro, proto...)
   pro = append(pro, []byte(crc)...)

   return pro
}

// ParseReadValue 解析从设备读取的值
func (p *ProtocolMitsubishi) ParseReadValue(data []byte) int {
   if len(data) < 6 {
@@ -82,6 +144,41 @@
   return int(bint)
}

func (p *ProtocolMitsubishi) ParseReadValueBits(data []byte) int {
   if len(data) < 6 {
      return -1
   }

   // 0x2 [xxxxxxxx] 0x3 crc1 crc2
   // 取出数据

   fmt.Printf("ParseReadValueBits %X\n", data)

   var num int64
   vhex := data[1 : len(data)-3]
   for i := len(vhex); i > 0; i -= 4 {
      tmp := vhex[i-4 : i]
      v := tmp[2:]
      v = append(v, tmp[0:2]...)
      var bint int64

      bint, _ = strconv.ParseInt(string(v), 16, 32)
      if num == 0 {
         num = 0x10000 * bint
      } else {
         num += bint
      }
   }

   // v := vhex[2:]
   // v = append(v, vhex[0:2]...)
   // vstr := string(v)
   // var bint int64
   // bint, _ = strconv.ParseInt(vstr, 16, 32)

   return int(num)
}

// ParseWriteValue 解析写入设备的结果
func (p *ProtocolMitsubishi) ParseWriteValue(data []byte) (v int, ok bool) {
   if len(data) == 0 {