From 16c20286873c2d4b9d7cab112f95566bbe45e831 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 12 Jul 2023 13:29:40 +0800 Subject: [PATCH] kickuserlog --- pkg/common/db/controller/msg.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/common/db/controller/msg.go b/pkg/common/db/controller/msg.go index 279381b8c..f23e7580c 100644 --- a/pkg/common/db/controller/msg.go +++ b/pkg/common/db/controller/msg.go @@ -604,6 +604,7 @@ func (db *commonMsgDatabase) UserMsgsDestruct(ctx context.Context, userID string // 获取报错，或者获取不到了，物理删除并且返回seq delMongoMsgsPhysical(delStruct.delDocIDList), 结束递归 break } + index++ //&& msgDocModel.Msg[0].Msg.SendTime > lastMsgDestructTime.UnixMilli() if len(msgDocModel.Msg) > 0 { for _, msg := range msgDocModel.Msg { @@ -619,6 +620,7 @@ func (db *commonMsgDatabase) UserMsgsDestruct(ctx context.Context, userID string } } } + log.ZDebug(ctx, "UserMsgsDestruct", "conversationID", conversationID, "userID", userID, "seqs", seqs) if len(seqs) > 0 { latestSeq := seqs[len(seqs)-1]