From d391a4d023cddab325be63bb412a56112b439af5 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 2 Nov 2022 11:40:55 +0800 Subject: [PATCH] test cron --- internal/cron_task/clear_msg.go | 2 +- internal/cron_task/cron_task.go | 4 ++-- pkg/common/db/mongoModel.go | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/cron_task/clear_msg.go b/internal/cron_task/clear_msg.go index 32243ac1b..229937304 100644 --- a/internal/cron_task/clear_msg.go +++ b/internal/cron_task/clear_msg.go @@ -79,7 +79,7 @@ func deleteMongoMsg(operationID string, ID string, index int64, delMsgIDList *[] if err != nil || msgs.UID == "" { if err != nil { if err == db.ErrMsgListNotExist { - log.NewDebug(operationID, utils.GetSelfFuncName(), ID, index, err.Error()) + log.NewDebug(operationID, utils.GetSelfFuncName(), "ID:", ID, "index:", index, err.Error()) } else { log.NewError(operationID, utils.GetSelfFuncName(), "GetUserMsgListByIndex failed", err.Error(), index, ID) } diff --git a/internal/cron_task/cron_task.go b/internal/cron_task/cron_task.go index 62543e4e4..3fa39d14d 100644 --- a/internal/cron_task/cron_task.go +++ b/internal/cron_task/cron_task.go @@ -16,9 +16,9 @@ const cronTaskOperationID = "cronTaskOperationID-" func StartCronTask() { log.NewPrivateLog("cron") - log.NewInfo(utils.OperationIDGenerator(), "start cron task") + log.NewInfo(utils.OperationIDGenerator(), "start cron task", "cron config", config.Config.Mongo.ChatRecordsClearTime) c := cron.New() - fmt.Println("config", config.Config.Mongo.ChatRecordsClearTime) + fmt.Println("cron config", config.Config.Mongo.ChatRecordsClearTime) _, err := c.AddFunc(config.Config.Mongo.ChatRecordsClearTime, func() { // user msg clear operationID := getCronTaskOperationID() diff --git a/pkg/common/db/mongoModel.go b/pkg/common/db/mongoModel.go index 0b4bd2617..f41a76d49 100644 --- a/pkg/common/db/mongoModel.go +++ b/pkg/common/db/mongoModel.go @@ -12,7 +12,6 @@ import ( "fmt" "github.com/go-redis/redis/v8" "github.com/gogo/protobuf/sortkeys" - "go.mongodb.org/mongo-driver/bson/primitive" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options" "math/rand" @@ -268,7 +267,8 @@ func (d *DataBases) GetUserMsgListByIndex(ID string, index int64) (*UserChat, er regex := fmt.Sprintf("/^%s/", ID) findOpts := options.Find().SetLimit(1).SetSkip(index).SetSort(bson.M{"uid": 1}) var msgs []UserChat - cursor, err := c.Find(ctx, bson.M{"uid": primitive.Regex{Pattern: regex}}, findOpts) + //primitive.Regex{Pattern: regex} + cursor, err := c.Find(ctx, bson.M{"uid": bson.M{"$regex": regex}}, findOpts) if err != nil { return nil, utils.Wrap(err, "") }