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()) + //} }