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