| | |
|---|
| | | "apsClient/pkg/convertx" |
|---|
| | | "apsClient/pkg/ecode" |
|---|
| | | "apsClient/pkg/logx" |
|---|
| | | "apsClient/pkg/safe" |
|---|
| | | "apsClient/service" |
|---|
| | | "apsClient/service/plc_address" |
|---|
| | | "errors" |
|---|
| | |
|---|
| | | Value: v, |
|---|
| | | }) |
|---|
| | | } |
|---|
| | | |
|---|
| | | safe.Go(func() { |
|---|
| | | caller := nsq.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*3) |
|---|
| | | if err != nil { |
|---|
| | | logx.Infof("get plc address err: %v", err.Error()) |
|---|
| | | } |
|---|
| | | }) |
|---|
| | | |
|---|
| | | resp := response.ProcessParamsResponse{ |
|---|
| | | Number: processModel.Number, |
|---|
| | | Params: processParamsArr, |
|---|
