获取工艺参数时异步刷新plc地址

zhangqian

2023-09-14 05f41513a5e51fb66691f6d8ba2a8adef2a415a5

获取工艺参数时异步刷新plc地址

 api/v1/task.go

@@ -12,6 +12,7 @@
    "apsClient/pkg/convertx"
    "apsClient/pkg/ecode"
    "apsClient/pkg/logx"
    "apsClient/pkg/safe"
    "apsClient/service"
    "apsClient/service/plc_address"
    "errors"
@@ -116,6 +117,16 @@
            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,