imrecord userid
This commit is contained in:
@@ -161,11 +161,11 @@ func handleMessages() {
|
|||||||
for groupID, mmsg := range msg {
|
for groupID, mmsg := range msg {
|
||||||
for _, client := range clients[groupID] {
|
for _, client := range clients[groupID] {
|
||||||
//把通道中的消息发送给客户端
|
//把通道中的消息发送给客户端
|
||||||
globals.SugarLogger.Debugf("msg %v", utils.Format4Output(mmsg, false))
|
|
||||||
user, err := dao.GetUser(dao.GetDB(), mmsg.UserID)
|
user, err := dao.GetUser(dao.GetDB(), mmsg.UserID)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
mmsg.UserInfo = user
|
mmsg.UserInfo = user
|
||||||
}
|
}
|
||||||
|
globals.SugarLogger.Debugf("msg %v", utils.Format4Output(mmsg, false))
|
||||||
err = client.WriteJSON(mmsg)
|
err = client.WriteJSON(mmsg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)
|
globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)
|
||||||
|
|||||||
Reference in New Issue
Block a user