修改连接判断
This commit is contained in:
@@ -115,12 +115,17 @@ func (*Websocks) MessageHandle(conn *websocket.Conn, deviceLoginInfo models.Devi
|
|||||||
if data.Recipient != 0 {
|
if data.Recipient != 0 {
|
||||||
// 将数据推送给对应设备
|
// 将数据推送给对应设备
|
||||||
userConn := Clients[RecipientDevice.UserId][RecipientDevice.ID]
|
userConn := Clients[RecipientDevice.UserId][RecipientDevice.ID]
|
||||||
|
if userConn != nil {
|
||||||
userConn.WriteJSON(&Message{
|
userConn.WriteJSON(&Message{
|
||||||
Type: "message",
|
Type: "message",
|
||||||
Data: data.Data,
|
Data: data.Data,
|
||||||
Sender: deviceLoginInfo.ID,
|
Sender: deviceLoginInfo.ID,
|
||||||
Recipient: data.Recipient,
|
Recipient: data.Recipient,
|
||||||
})
|
})
|
||||||
|
} else {
|
||||||
|
log.Println("未获取到设备ID:", RecipientDevice.ID)
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Reference in New Issue
Block a user