| | |
|---|
| | | safe.Go(func() { |
|---|
| | | caller := NewCaller(fmt.Sprintf(constvar.NsqTopicGetPlcAddress, conf.Conf.NsqConf.NodeId), fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId)) |
|---|
| | | var addressResult common.ResponsePlcAddress |
|---|
| | | err := caller.Call(common.RequestPlcAddress{DeviceId: conf.Conf.System.DeviceId}, &addressResult, time.Second*2) |
|---|
| | | err := caller.Call(common.RequestPlcAddress{DeviceId: conf.Conf.System.DeviceId}, &addressResult, time.Second*3) |
|---|
| | | if err != nil { |
|---|
| | | logx.Infof("get plc address err: %v", err.Error()) |
|---|
| | | } |
|---|
