添加命令行参数

zhangzengfei

2023-07-25 208b87f5ca5ae803bd7b539ad27414fa5891c056

添加命令行参数

 README.md

@@ -8,4 +8,23 @@
go build
```
####备忘
SubscriptionRequestBuilder 不支持modbus
SubscriptionRequestBuilder 不支持modbus

####广升测试
汇川 H5U
<br>
默认IP 192.168.1.88
<br>
生产计数: D1230, 生产总量: D1234

三菱 FX-5U
<br>
默认IP 192.168.3.250,  第二台已修改为 192.168.3.251
<br>
生产计数: D831, 生产总量: D832

ETH-FX-2P模块
<br>
IP地址默认为 192.168.1.188, 已修改为192.168.1.150
<br>
生产计数: 42382, 生产总量: 42384(E0FF) 和 42385(05F5)

 go.mod

@@ -2,4 +2,7 @@

go 1.14

require github.com/apache/plc4x/plc4go v0.0.0-20230714120555-05ec3da87ebe
require (
    github.com/apache/plc4x/plc4go v0.0.0-20230714120555-05ec3da87ebe
    github.com/rs/zerolog v1.29.1 // indirect
)

 main.go

@@ -1,15 +1,48 @@
package main

import (
    "encoding/binary"
    "flag"
    "fmt"

    plc4go "github.com/apache/plc4x/plc4go/pkg/api"
    "github.com/apache/plc4x/plc4go/pkg/api/drivers"
    apiModel "github.com/apache/plc4x/plc4go/pkg/api/model"
    "github.com/apache/plc4x/plc4go/pkg/api/transports"
    //"github.com/apache/plc4x/plc4go/spi/options"
    "github.com/rs/zerolog"
)

var (
    ipAddr  string
    address int
    length  int
    format  string
)

func init() {
    flag.StringVar(&ipAddr, "ip", "", "设备ip")
    flag.StringVar(&format, "format", "hex", "格式化: hex, 十六进制, dec 十进制, str, 字符串")
    flag.IntVar(&address, "addr", 100, "起始地址")
    flag.IntVar(&length, "len", 1, "长度")
}

func main() {
    flag.Parse()

    if ipAddr == "" {
        flag.PrintDefaults()
        return
    }

    // 强制读一个地址
    if length == 0 {
        length = 1
    }

    // 控制日志打印级别
    zerolog.SetGlobalLevel(zerolog.FatalLevel)

    // 创建驱动管理器
    driverManager := plc4go.NewPlcDriverManager()

@@ -27,7 +60,8 @@
    drivers.RegisterModbusTcpDriver(driverManager)

    // 通过TCP连接PLC设备
    connectionRequestChanel := driverManager.GetConnection("modbus-tcp://192.168.1.88")
    connectionString := fmt.Sprintf("modbus-tcp://%s", ipAddr)
    connectionRequestChanel := driverManager.GetConnection(connectionString)

    // 等待连接响应
    connectionResult := <-connectionRequestChanel
@@ -43,48 +77,63 @@
    defer connection.Close()

    // 测试是否可以正常通信
    pingResult := <-connection.Ping()
    if err := pingResult.GetErr(); err != nil {
        fmt.Printf("Couldn't ping device: %s\n", err.Error())
    //pingResult := <-connection.Ping()
    //if err := pingResult.GetErr(); err != nil {
    //    fmt.Printf("Couldn't ping device: %s\n", err.Error())
    //}
    //
    //// 验证是否可读
    //if !connection.GetMetadata().CanRead() {
    //    fmt.Printf("This connection doesn't support read operations\n")
    //    return
    //}

    // 将长度按60切割, 太长了modbus不返回
    for i, len := 0, 60; i < length; i = i + 60 {
        if i+len > length {
            len = length - i
        }

        tagAddress := fmt.Sprintf("holding-register:%d:DINT[%d]", address+i, len)

        // 读模式
        readRequest, err := connection.ReadRequestBuilder().AddTagAddress("tag0", tagAddress).Build()
        if err != nil {
            fmt.Printf("Error preparing read-request:%s\n", err.Error())
            return
        }

        // 执行
        readResult := <-readRequest.Execute()
        if err := readResult.GetErr(); err != nil {
            fmt.Printf("Error execting read-request:%s\n", err.Error())
            return
        }

        // 判断响应码是否正确
        if readResult.GetResponse().GetResponseCode("tag0") != apiModel.PlcResponseCode_OK {
            fmt.Printf("error an non-ok return code: %s", readResult.GetResponse().GetResponseCode("tag0").GetName())
            return
        }

        // 测试获取变量名称
        //names := readResult.GetResponse().GetTagNames()
        //fmt.Printf("Got tag names %+v", names)

        value := readResult.GetResponse().GetValue("tag0")

        //// 按字符串打印变量
        //fmt.Printf("val data: %s\n", value.GetRaw())
        for idx, val := range value.GetList() {
            raw := val.GetRaw()
            if format == "hex" {
                fmt.Printf("%d:%X\t", address+i+idx, raw)
            }
            if format == "dec" {
                fmt.Printf("%d:%d\t", address+i+idx, binary.BigEndian.Uint16(raw))
            }
        }
    }

    // 验证是否可读
    if !connection.GetMetadata().CanRead() {
        fmt.Printf("This connection doesn't support read operations\n")
        return
    }

    // 读模式
    readRequest, err := connection.ReadRequestBuilder().AddTagAddress("count", "holding-register:1230:DINT[20]").Build()
    if err != nil {
        fmt.Printf("Error preparing read-request:%s\n", err.Error())
        return
    }

    // 执行
    readResult := <-readRequest.Execute()
    if err := readResult.GetErr(); err != nil {
        fmt.Printf("Error execting read-request:%s\n", err.Error())
        return
    }

    // 判断响应码是否正确
    if readResult.GetResponse().GetResponseCode("count") != apiModel.PlcResponseCode_OK {
        fmt.Printf("error an non-ok return code: %s", readResult.GetResponse().GetResponseCode("count").GetName())
        return
    }

    // 测试获取变量名称
    //names := readResult.GetResponse().GetTagNames()
    //fmt.Printf("Got tag names %+v", names)

    value := readResult.GetResponse().GetValue("count")
    fmt.Printf("Got result length %d\n", value.GetLength())

    // 按字符串打印变量
    fmt.Printf("val data: %s\n", value.GetRaw())
    for _, val := range value.GetList() {
        fmt.Printf("%d ", val.GetUint16())
    }
    fmt.Printf("\n")

}