fix

zhangqian

2023-12-01 8324f872ef3a4d0c978a9b1d062800c6a1701c12

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
package modbusx
 
import (
    "apsClient/model/common"
)
 
func ReadByRTU(c *common.RTUConfig, address uint16, quantity uint16) (data []byte, err error) {
    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) (err error) {
    var bytesVal []byte
    bytesVal = intToBytes(value)
    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) //失败则删除缓存的连接
    }
}