From 22d0d80bfe1de935b418af33380b407128b753df Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 4 Nov 2022 17:56:21 +0800 Subject: [PATCH] test cron --- internal/cron_task/clear_msg.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/internal/cron_task/clear_msg.go b/internal/cron_task/clear_msg.go index 045ef818a..ba5d8e7dd 100644 --- a/internal/cron_task/clear_msg.go +++ b/internal/cron_task/clear_msg.go @@ -84,7 +84,6 @@ func (d *delMsgRecursionStruct) getSetMinSeq() uint32 { // set minSeq 21 // recursion func deleteMongoMsg(operationID string, ID string, index int64, delStruct *delMsgRecursionStruct) (uint32, error) { - // delMsgIDList [[uid:0, minSeq], [uid:1, minSeq]] // find from oldest list msgs, err := db.DB.GetUserMsgListByIndex(ID, index) if err != nil || msgs.UID == "" { @@ -106,10 +105,10 @@ func deleteMongoMsg(operationID string, ID string, index int64, delStruct *delMs if len(msgs.Msg) > db.GetSingleGocMsgNum() { log.NewWarn(operationID, utils.GetSelfFuncName(), "msgs too large", len(msgs.Msg), msgs.UID) } - log.NewDebug(operationID, utils.GetSelfFuncName(), "get msgs: ", msgs.UID) for i, msg := range msgs.Msg { // 找到列表中不需要删除的消息了, 表示为递归到最后一个块 if utils.GetCurrentTimestampByMill() < msg.SendTime+(int64(config.Config.Mongo.DBRetainChatRecords)*24*60*60*1000) { + log.NewDebug(operationID, ID, "find uid", msgs.UID) // 删除块失败 递归结束 返回0 if err := delMongoMsgsPhysical(delStruct.delUidList); err != nil { return 0, err