修改获取消息ID方法

gongshangguo

2022-03-03 d3d05d0eecdd76e86eeb3d28dcd765db042dce17

 server/clienter.go

@@ -28,7 +28,7 @@
   msg.SenderId = Srv.serverId
   msg.Receiver = aiot.RECEIVER_TO_MASTER
   msg.ReqType = aiot.REQ_TYPE_RESPONSE
   msg.MsgProto = cli.GetMsgProto(msg.MsgProto.MsgId)
   msg.MsgProto = client.GetMsgProto(msg.MsgProto.MsgId)
   _ = cli.WriteBody(msg)
   // 上报到服务端
   go Srv.serverCallBack.OnHeartBeat(cli, msg)
@@ -37,7 +37,7 @@

// 实现OnRegister
func (c *Clients) OnRegister(cli *client.Client, msg *aiot.Protocol) error {
   Srv.RegisterDevice(msg, cli)
   Srv.RegisterDevice(cli, msg)
   go Srv.serverCallBack.OnRegister(cli, msg)
   msgFeedBack := &aiot.Protocol{
      Receiver: aiot.RECEIVER_TO_MASTER,
@@ -45,7 +45,7 @@
      DeviceProto: msg.DeviceProto,
      MsgType: aiot.MSG_TYPE_REGISTER,
      ReqType: aiot.REQ_TYPE_RESPONSE,
      MsgProto: cli.GetMsgProto(msg.MsgProto.MsgId),
      MsgProto: client.GetMsgProto(msg.MsgProto.MsgId),
      Data: msg.Data,
   }
   _ = cli.WriteBody(msgFeedBack)