From 2cbecf439e907b5e44816a1edbba18015652cc5c Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 3 Nov 2022 20:08:56 +0800 Subject: [PATCH] test cron --- internal/cron_task/cron_task.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/cron_task/cron_task.go b/internal/cron_task/cron_task.go index 3fa39d14d..c0e4c0b86 100644 --- a/internal/cron_task/cron_task.go +++ b/internal/cron_task/cron_task.go @@ -30,9 +30,9 @@ func StartCronTask() { if err := DeleteMongoMsgAndResetRedisSeq(operationID, userID); err != nil { log.NewError(operationID, utils.GetSelfFuncName(), err.Error(), userID) } - if err := checkMaxSeqWithMongo(operationID, userID, constant.WriteDiffusion); err != nil { - log.NewError(operationID, utils.GetSelfFuncName(), userID, err) - } + //if err := checkMaxSeqWithMongo(operationID, userID, constant.WriteDiffusion); err != nil { + // log.NewError(operationID, utils.GetSelfFuncName(), userID, err) + //} } } else { log.NewError(operationID, utils.GetSelfFuncName(), err.Error()) @@ -52,9 +52,9 @@ func StartCronTask() { if err := ResetUserGroupMinSeq(operationID, groupID, userIDList); err != nil { log.NewError(operationID, utils.GetSelfFuncName(), err.Error(), groupID, userIDList) } - if err := checkMaxSeqWithMongo(operationID, groupID, constant.ReadDiffusion); err != nil { - log.NewError(operationID, utils.GetSelfFuncName(), groupID, err) - } + //if err := checkMaxSeqWithMongo(operationID, groupID, constant.ReadDiffusion); err != nil { + // log.NewError(operationID, utils.GetSelfFuncName(), groupID, err) + //} } } else { log.NewError(operationID, utils.GetSelfFuncName(), err.Error())