From 4f2c857bbf2f2ba976b088827afdc8c8176423f6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Wed, 30 Dec 2020 18:10:51 +0800 Subject: [PATCH] aa --- business/jxstore/event/event.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) 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)