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
|
//}
|
