定时删除两个表的过期日志

main.go

@@ -19,8 +19,7 @@ func main() {
 		web.BConfig.WebConfig.DirectoryIndex = true
 		web.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
 	}
-	services.DeleteLog()
-	//go services.Task()
+	go services.Task()
 	//services.TaskTest()
 	web.BConfig.RecoverFunc = Recover
 	web.Run()

models/data_manage/ppt_v2_save_log.go

@@ -0,0 +1,15 @@
+package data_manage
+
+import (
+	"fmt"
+	"github.com/beego/beego/v2/client/orm"
+)
+
+func DeletePPTLogByDate(date string) (err error) {
+	sql := `DELETE FROM ppt_v2_save_log WHERE creat_time<%s `
+	sql = fmt.Sprintf(sql, date)
+	o := orm.NewOrmUsingDB("rddp")
+	_, err = o.Raw(sql, date).Exec()
+
+	return
+}

models/data_manage/report_save_log.go

@@ -0,0 +1,15 @@
+package data_manage
+
+import (
+	"fmt"
+	"github.com/beego/beego/v2/client/orm"
+)
+
+func DeleteReportLogByDate(date string) (err error) {
+	sql := `DELETE FROM report_save_log WHERE creat_time<%s `
+	sql = fmt.Sprintf(sql, date)
+	o := orm.NewOrmUsingDB("rddp")
+	_, err = o.Raw(sql, date).Exec()
+
+	return
+}

services/save_log.go

@@ -0,0 +1,18 @@
+package services
+
+import (
+	"context"
+	"hongze/hongze_task/models/data_manage"
+	"hongze/hongze_task/utils"
+	"time"
+)
+
+func DeleteLog(cont context.Context) (err error) {
+	date := time.Now().AddDate(0,-1,0).Format(utils.FormatDateTime)
+	err = data_manage.DeletePPTLogByDate(date)
+	if err != nil {
+		return
+	}
+	err = data_manage.DeleteReportLogByDate(date)
+	return
+}

services/task.go

@@ -109,13 +109,12 @@ func Task() {
 	syncComeinMeeting := task.NewTask("SyncComeinMeeting", "0 1 */1 * * * ", SyncComeinMeeting)
 	task.AddTask("SyncComeinMeeting", syncComeinMeeting)
 
-	//同步user_record中的关注状态
-	syncSubStatus := task.NewTask("syncSubStatus", "0 0 2 * * *", SyncSubStatus)
-	task.AddTask("syncSubStatus", syncSubStatus)
+
+
 
 	//删除日志 report_save_log，ppt_v2_save_log，保留一个月的
-	//deleteLog := task.NewTask("syncSubStatus", "0 0 2 1 * *", DeleteLog)
-	//task.AddTask("deleteLog", deleteLog)
+	deleteLog := task.NewTask("syncSubStatus", "0 0 2 1 * *", DeleteLog)
+	task.AddTask("deleteLog", deleteLog)
 
 
 	task.StartTask()