package plc
|
|
import (
|
"encoding/hex"
|
"errors"
|
"fmt"
|
"io"
|
"strings"
|
"time"
|
|
"github.com/jacobsa/go-serial/serial"
|
)
|
|
/*
|
定义串口客户端
|
*/
|
|
type SerialClient struct {
|
readWriter io.ReadWriteCloser
|
OutBuffer chan string
|
PortName string
|
baudRate uint
|
}
|
|
func NewSerialClient(portName string, baudRate uint) (*SerialClient, error) {
|
c := &SerialClient{
|
readWriter: nil,
|
OutBuffer: make(chan string, 1024),
|
PortName: portName,
|
baudRate: baudRate,
|
}
|
r, err := c.open(portName, baudRate)
|
if err != nil {
|
return nil, err
|
}
|
|
c.readWriter = r
|
return c, nil
|
}
|
|
func (c *SerialClient) Start() {
|
for {
|
buf := make([]byte, 1024)
|
n, err := c.readWriter.Read(buf)
|
if err != nil {
|
if err != io.EOF {
|
//尝试重新打开
|
r, err := c.open(c.PortName, c.baudRate)
|
if err != nil {
|
time.Sleep(2 * time.Second)
|
continue
|
}
|
c.readWriter = r
|
}
|
continue
|
}
|
|
buf = buf[:n]
|
res := hex.EncodeToString(buf)
|
if strings.TrimSpace(res) == "" {
|
continue
|
}
|
fmt.Printf("Rx: %s\n", res)
|
c.OutBuffer <- res
|
}
|
}
|
|
func (c *SerialClient) open(portName string, baudRate uint) (io.ReadWriteCloser, error) {
|
options := serial.OpenOptions{
|
PortName: portName,
|
BaudRate: baudRate,
|
DataBits: 7,
|
StopBits: 1,
|
MinimumReadSize: 4,
|
ParityMode: serial.PARITY_EVEN,
|
}
|
|
r, err := serial.Open(options)
|
if err != nil {
|
return nil, err
|
}
|
|
c.readWriter = r
|
|
return r, err
|
}
|
|
func (c *SerialClient) Close() {
|
if c.readWriter != nil {
|
c.readWriter.Close()
|
}
|
}
|
|
func (c *SerialClient) SendMsg(data string) (int, error) {
|
if c.readWriter == nil {
|
return 0, errors.New("serial port is closed")
|
}
|
|
bytes, err := hex.DecodeString(data)
|
if err != nil {
|
return 0, err
|
}
|
|
return c.readWriter.Write(bytes)
|
}
|
|
func (c *SerialClient) ReadHoldRegister(addr string) (int, error) {
|
if c.readWriter == nil {
|
return 0, errors.New("serial port is closed")
|
}
|
|
// 三菱fn系列串口协议
|
// 02 表示开始 + 30 表示读数据 + 4位地址位 + 02 数据长度 + 03 停止 + 偶校验
|
|
// 先组装数据
|
// 读取的地址
|
dataBytes := append([]byte{0x30}, []byte(addr)...)
|
|
// 读取的长度
|
dataBytes = append(dataBytes, []byte("02")...)
|
|
// 停止
|
dataBytes = append(dataBytes, []byte{0x03}...)
|
|
// 计算校验码, 30 + 地址编码 + 数据长度 + 03 , 十六进制结果取后两位.
|
var sum uint8
|
for _, d := range dataBytes {
|
sum += d
|
}
|
|
sumStr := fmt.Sprintf("%x", sum)
|
|
fmt.Printf("sumStr: %s\n", sumStr)
|
|
var checkCode string
|
if len(sumStr) < 2 {
|
checkCode = "0" + sumStr
|
} else {
|
checkCode = sumStr[len(sumStr)-2:]
|
}
|
|
var bytes = []byte{0x02}
|
// 添加数据
|
bytes = append(bytes, dataBytes...)
|
// 添加校验
|
bytes = append(bytes, []byte(checkCode)...)
|
|
fmt.Printf("Tx: %X \n", bytes)
|
|
// 写
|
if n, err := c.readWriter.Write(bytes); err != nil {
|
return n, err
|
} else {
|
fmt.Printf("Tx:len:%d\n", n)
|
}
|
|
// 读
|
buf := make([]byte, 1024)
|
n, err := c.readWriter.Read(buf)
|
if err != nil {
|
return n, err
|
}
|
|
buf = buf[:n]
|
|
fmt.Printf("Rx: %X\nRx len:%d", buf, n)
|
fmt.Printf("value: %d\n", buf[2:6])
|
|
return n, nil
|
}
|
|
func (c *SerialClient) WriteHoldRegister(addr string) (int, error) {
|
if c.readWriter == nil {
|
return 0, errors.New("serial port is closed")
|
}
|
|
// 三菱fn系列串口协议
|
// 02 表示开始 + 31 表示写数据 + 4位地址位 + 02 数据长度 + 03 停止 + 偶校验
|
|
// 先组装数据
|
// 读取的地址
|
dataBytes := append([]byte{0x31}, []byte(addr)...)
|
|
// 读取的长度
|
dataBytes = append(dataBytes, []byte("02")...)
|
|
// 停止
|
dataBytes = append(dataBytes, []byte{0x03}...)
|
|
// 计算校验码, 30 + 地址编码 + 数据长度 + 03 , 十六进制结果取后两位.
|
var sum uint8
|
for _, d := range dataBytes {
|
sum += d
|
}
|
|
sumStr := fmt.Sprintf("%x", sum)
|
|
fmt.Printf("sumStr: %s\n", sumStr)
|
|
var checkCode string
|
if len(sumStr) < 2 {
|
checkCode = "0" + sumStr
|
} else {
|
checkCode = sumStr[len(sumStr)-2:]
|
}
|
|
var bytes = []byte{0x02}
|
// 添加数据
|
bytes = append(bytes, dataBytes...)
|
// 添加校验
|
bytes = append(bytes, []byte(checkCode)...)
|
|
fmt.Printf("Tx: %X \n", bytes)
|
|
// 写
|
if n, err := c.readWriter.Write(bytes); err != nil {
|
return n, err
|
} else {
|
fmt.Printf("Tx:len:%d\n", n)
|
}
|
|
// 读
|
buf := make([]byte, 1024)
|
n, err := c.readWriter.Read(buf)
|
if err != nil {
|
return n, err
|
}
|
|
buf = buf[:n]
|
|
fmt.Printf("Rx: %X\nRx len:%d", buf, n)
|
fmt.Printf("value: %d\n", buf[2:6])
|
|
return n, nil
|
}
|
