fix delete

This commit is contained in:
wangchuxiao 2022-08-10 15:19:24 +08:00
parent 5a058d9b97
commit b1d0ca76c9

View File

@ -17,6 +17,7 @@ const cronTaskOperationID = "cronTaskOperationID-"
func StartCronTask() {
log.NewInfo(utils.OperationIDGenerator(), "start cron task")
c := cron.New()
fmt.Println("config", config.Config.Mongo.ChatRecordsClearTime)
_, err := c.AddFunc(config.Config.Mongo.ChatRecordsClearTime, func() {
operationID := getCronTaskOperationID()
userIDList, err := im_mysql_model.SelectAllUserID()