删除不再用的topic，增加初始化的时候，设备拉取

zhangqian

2023-10-20 bc7ee359dfe4e66a05c2cca9deb7a945534009f3

 crontask/cron_task.go

@@ -143,11 +143,12 @@
   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", err.Error())
      logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg)
   }
   caller = nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicGetPlcAddress, conf.Conf.NsqConf.NodeId), "")
   err = caller.Send(common.RequestPlcAddress{DeviceId: conf.Conf.System.DeviceId})
   msg = &common.MsgPullDataRequest{DataType: common.PullDataTypeDevice}
   caller = nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicPullDataRequest, conf.Conf.NsqConf.NodeId), constvar.NsqTopicPullDataResponse)
   err = caller.Send(msg)
   if err != nil {
      logx.Infof("get plc address err: %v", err.Error())
      logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg)
   }
}