集群master启动时拉取全部设备的工艺参数plc地址

zhangqian

2023-11-03 7ce8847c6b9e74b9c420f024df7a3bb9fe576657

集群master启动时拉取全部设备的工艺参数plc地址

 crontask/cron_task.go

@@ -160,6 +160,12 @@
    if err != nil {
        logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg)
    }
    msg = &common.MsgPullDataRequest{DataType: common.PullDataTypeProcessModelPlcAddress}
    caller = nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicPullDataRequest, conf.Conf.NsqConf.NodeId), constvar.NsqTopicPullDataResponse)
    err = caller.Send(msg)
    if err != nil {
        logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg)
    }
}

func QueryClusterStatus() {