From 160a425c85f128ed47f92aa15c7eb6f76d68610a Mon Sep 17 00:00:00 2001
From: gongshangguo <gongshangguo@admin.com>
Date: 星期一, 28 二月 2022 17:26:10 +0800
Subject: [PATCH] 回复register
---
server/clienter.go | 28 +++++++++++++++++++---------
1 files changed, 19 insertions(+), 9 deletions(-)
diff --git a/server/clienter.go b/server/clienter.go
index f18377e..710f769 100644
--- a/server/clienter.go
+++ b/server/clienter.go
@@ -39,6 +39,16 @@
func (c *Clients) OnRegister(cli *client.Client, msg *aiot.Protocol) error {
Srv.RegisterDevice(msg, cli)
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: cli.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