zhangqian
2023-12-20 9e2fbcdc62bc4b45519715c8243446a11ee011cf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
package modbusx
 
import (
    "apsClient/model/common"
)
 
func ReadByRTU(c *common.RTUConfig, address uint16, quantity uint16) (data []byte, err error) {
    address--
    cli := getModbusRTUConnection(c)
    data, err = cli.ReadHoldingRegisters(address, quantity)
    dealRTUErr(err, c.SerialName)
    if err != nil {
        cli = getModbusRTUConnection(c)
        data, err = cli.ReadHoldingRegisters(address, quantity)
        dealRTUErr(err, c.SerialName)
    }
    return
}
 
func WriteByRTU(c *common.RTUConfig, address uint16, value int, endian string, length int) (err error) {
    address--
    var bytesVal []byte
    bytesVal = intToBytes(value, endian, length)
    cli := getModbusRTUConnection(c)
    _, err = cli.WriteMultipleRegisters(address, uint16(len(bytesVal)), bytesVal)
    dealRTUErr(err, c.SerialName)
    if err != nil {
        cli = getModbusRTUConnection(c)
        _, err = cli.WriteMultipleRegisters(address, uint16(len(bytesVal)), bytesVal)
        dealRTUErr(err, c.SerialName)
    }
    return err
}
 
func dealRTUErr(err error, serialName string) {
    if err != nil {
        unsetModbusRTUConnection(serialName) //失败则删除缓存的连接
    }
}