From d39f61122b47cd21c16921e6c33eec5db4145ddc Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Tue, 26 Oct 2021 19:52:43 +0800 Subject: [PATCH] test msg --- src/msg_transfer/logic/history_msg_handler.go | 20 ++++++++----------- 1 file changed, 8 insertions(+), 12 deletions(-) diff --git a/src/msg_transfer/logic/history_msg_handler.go b/src/msg_transfer/logic/history_msg_handler.go index d3d992a64..ce17b9cb1 100644 --- a/src/msg_transfer/logic/history_msg_handler.go +++ b/src/msg_transfer/logic/history_msg_handler.go @@ -63,20 +63,16 @@ func (mc *HistoryConsumerHandler) handleChatWs2Mongo(msg []byte, msgKey string) log.Info("", "", "msg_transfer chat type = SingleChatType", isHistory, isPersist) if isHistory { if msgKey == pbSaveData.RecvID { - go func() { - err := saveUserChat(pbData.RecvID, &pbSaveData) - if err != nil { - log.ErrorByKv("data insert to mongo err", pbSaveData.OperationID, "data", pbSaveData.String(), "err", err.Error()) - } - }() + //err := saveUserChat(pbData.RecvID, &pbSaveData) + //if err != nil { + // log.ErrorByKv("data insert to mongo err", pbSaveData.OperationID, "data", pbSaveData.String(), "err", err.Error()) + //} } else if msgKey == pbSaveData.SendID { - go func() { - err := saveUserChat(pbData.SendID, &pbSaveData) - if err != nil { - log.ErrorByKv("data insert to mongo err", pbSaveData.OperationID, "data", pbSaveData.String(), "err", err.Error()) - } - }() + //err := saveUserChat(pbData.SendID, &pbSaveData) + //if err != nil { + // log.ErrorByKv("data insert to mongo err", pbSaveData.OperationID, "data", pbSaveData.String(), "err", err.Error()) + //} }