liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
苏尹岚
2020-12-30 18:10:51 +08:00
parent 786ac3f365
commit 4f2c857bbf
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/event/event.go
View File

@@ -704,9 +704,6 @@ func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageReco
//循环map客户端 //循环map客户端
for _, client := range wsClient.Clients[groupID] { for _, client := range wsClient.Clients[groupID] {
globals.SugarLogger.Debugf("msg %v", utils.Format4Output(imMessageRecord, false)) globals.SugarLogger.Debugf("msg %v", utils.Format4Output(imMessageRecord, false))
if imMessageRecord.CreatedAt == utils.ZeroTimeValue {
imMessageRecord.CreatedAt = time.Now()
}
err = client.WriteJSON(imMessageRecord) err = client.WriteJSON(imMessageRecord)
if err != nil { if err != nil {
globals.SugarLogger.Debugf("client.WriteJSON error: %v", err) globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)
@@ -715,11 +712,10 @@ func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageReco
} }
} }
} else { } else {
wsClient.s.RLock()
client := wsClient.Clients[groupID][userID] client := wsClient.Clients[groupID][userID]
wsClient.s.RUnlock()
globals.SugarLogger.Debugf("msg %v", utils.Format4Output(imMessageRecord, false)) globals.SugarLogger.Debugf("msg %v", utils.Format4Output(imMessageRecord, false))
if imMessageRecord.CreatedAt == utils.ZeroTimeValue {
imMessageRecord.CreatedAt = time.Now()
}
err = client.WriteJSON(imMessageRecord) err = client.WriteJSON(imMessageRecord)
if err != nil { if err != nil {
globals.SugarLogger.Debugf("client.WriteJSON error: %v", err) globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)