From d3d05d0eecdd76e86eeb3d28dcd765db042dce17 Mon Sep 17 00:00:00 2001
From: gongshangguo <gongshangguo@admin.com>
Date: 星期四, 03 三月 2022 10:46:05 +0800
Subject: [PATCH] 修改获取消息ID方法
---
server/clienter.go | 32 +++++++++++++++++++++-----------
1 files changed, 21 insertions(+), 11 deletions(-)
diff --git a/server/clienter.go b/server/clienter.go
index f18377e..018ce34 100644
--- a/server/clienter.go
+++ b/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,8 +37,18 @@
// 瀹炵幇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,
+ SenderId: Srv.serverId,
+ DeviceProto: msg.DeviceProto,
+ MsgType: aiot.MSG_TYPE_REGISTER,
+ ReqType: aiot.REQ_TYPE_RESPONSE,
+ MsgProto: client.GetMsgProto(msg.MsgProto.MsgId),
+ Data: msg.Data,
+ }
+ _ = cli.WriteBody(msgFeedBack)
return nil
}
@@ -54,15 +64,6 @@
return nil
}
-// 瀹炵幇OnClose
-func (c *Clients) OnClose(cli *client.Client) {
- if Srv.IsMasterOnline(cli.GetDeviceId()) {
- Srv.RemoveCluster(cli.GetDeviceId())
- }
- go Srv.serverCallBack.OnClose(cli)
- return
-}
-
// 瀹炵幇OnDataReport
func (c *Clients) OnDataReport(cli *client.Client, msg *aiot.Protocol) error {
go Srv.serverCallBack.OnDataReport(cli, msg)
@@ -74,3 +75,12 @@
go Srv.serverCallBack.OnDeviceControl(cli, msg)
return nil
}
+
+// 瀹炵幇OnClose
+func (c *Clients) OnClose(cli *client.Client) {
+ if Srv.IsMasterOnline(cli.GetDeviceId()) {
+ Srv.RemoveCluster(cli.GetDeviceId())
+ }
+ go Srv.serverCallBack.OnClose(cli)
+ return
+}
--
Gitblit v1.8.0