From 2aa49f080e61e48e1c398bf455fe6f367dec1b14 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 28 Dec 2022 19:19:26 +0800 Subject: [PATCH] cron --- internal/cron_task/clear_msg.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/cron_task/clear_msg.go b/internal/cron_task/clear_msg.go index 5ae3b16c6..08ef74cef 100644 --- a/internal/cron_task/clear_msg.go +++ b/internal/cron_task/clear_msg.go @@ -119,6 +119,9 @@ func deleteMongoMsg(operationID string, ID string, index int64, delStruct *delMs } else { var hasMarkDelFlag bool for index, msg := range msgs.Msg { + if msg.SendTime == 0 { + continue + } msgPb := &server_api_params.MsgData{} err = proto.Unmarshal(msg.Msg, msgPb) if err != nil {