| | |
|---|
| | | "github.com/spf13/cast" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | func PlcWrite(plcConfig *model.DevicePlc, fieldType constvar.PlcStartAddressType, position int, value interface{}) (err error) { |
|---|
| | | func PlcWrite(plcConfig *model.DevicePlc, fieldType constvar.PlcStartAddressType, channel int32, value interface{}) (err error) { |
|---|
| | | var ( |
|---|
| | | startAddress int |
|---|
| | | ipAddr string |
|---|
| | |
|---|
| | | plcConfig.CurrentTryTimes++ |
|---|
| | | |
|---|
| | | for _, pc := range plcConfig.Details { |
|---|
| | | if pc.FieldName == fieldType && pc.Position == position { |
|---|
| | | if pc.FieldName == fieldType && pc.Channel == channel { |
|---|
| | | startAddress = pc.StartAddress |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("plc write failed, address: %v, value: %v, err: %v", startAddress, value, err.Error()) |
|---|
| | | plcConfig.CurrentErr = err |
|---|
| | | return PlcWrite(plcConfig, fieldType, position, value) |
|---|
| | | return PlcWrite(plcConfig, fieldType, channel, value) |
|---|
| | | } |
|---|
| | | logx.Infof("plc write ok, address: %v, value: %v", startAddress, value) |
|---|
| | | } else if plcConfig.Method == constvar.PlcMethodSerial { |
|---|
