| | |
|---|
| | | c.Logger.Debug("registering...") |
|---|
| | | data := c.deviceRegister |
|---|
| | | msgData, _ := json.Marshal(data) |
|---|
| | | _, err := c.WriteMsg(c.deviceId, aiot.MSG_TYPE_REGISTER, aiot.REQ_TYPE_REQUEST, msgData, c.GetMsgProto("")) |
|---|
| | | _, err := c.WriteMsg(c.deviceId, aiot.MSG_TYPE_REGISTER, aiot.REQ_TYPE_REQUEST, msgData, GetMsgProto("")) |
|---|
| | | if err != nil { |
|---|
| | | c.Logger.Error("Fail to send device register", zap.Any("msg", msgData)) |
|---|
| | | } |
|---|
| | |
|---|
| | | t.Stop() |
|---|
| | | return |
|---|
| | | } |
|---|
| | | go c.WriteMsg(c.deviceId, aiot.MSG_TYPE_HEART_BEAT, aiot.REQ_TYPE_REQUEST, pingData, c.GetMsgProto("")) |
|---|
| | | go c.WriteMsg(c.deviceId, aiot.MSG_TYPE_HEART_BEAT, aiot.REQ_TYPE_REQUEST, pingData, GetMsgProto("")) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 拼装消息ID |
|---|
| | | func (c *Client) GetMsgProto(msgId string) *aiot.MsgIdProto { |
|---|
| | | func GetMsgProto(msgId string) *aiot.MsgIdProto { |
|---|
| | | // 新消息 |
|---|
| | | if msgId == "" { |
|---|
| | | return &aiot.MsgIdProto{ |
|---|
