清理掉定时任务config配置，修改为代码内书写 (flipped-aurora#1578)

Author: 奇淼（piexlmax

server/config.yaml

@@ -224,18 +224,6 @@ hua-wei-obs:
 excel:
  dir: ./resource/excel/
 
-# timer task db clear table
-Timer:
- start: true
- spec: "@daily" # 定时任务详细配置参考 https://pkg.go.dev/github.com/robfig/cron/v3
- detail:
- - tableName: sys_operation_records
- compareField: created_at
- interval: 2160h
- - tableName: jwt_blacklists
- compareField: created_at
- interval: 168h
-
 # 跨域配置
 # 需要配合 server/initialize/router.go -> `Router.Use(middleware.CorsByRules())` 使用
 cors:

server/config/config.go

@@ -26,7 +26,6 @@ type Server struct {
 AwsS3 AwsS3 `mapstructure:"aws-s3" json:"aws-s3" yaml:"aws-s3"`
 
 Excel Excel `mapstructure:"excel" json:"excel" yaml:"excel"`
-Timer Timer `mapstructure:"timer" json:"timer" yaml:"timer"`
 
 // 跨域配置
 Cors CORS `mapstructure:"cors" json:"cors" yaml:"cors"`

server/config/timer.go

@@ -2,32 +2,36 @@ package initialize
 
 import (
 "fmt"
+"github.com/flipped-aurora/gin-vue-admin/server/task"
 
 "github.com/robfig/cron/v3"
 
-"github.com/flipped-aurora/gin-vue-admin/server/config"
 "github.com/flipped-aurora/gin-vue-admin/server/global"
-"github.com/flipped-aurora/gin-vue-admin/server/utils"
 )
 
 func Timer() {
-if global.GVA_CONFIG.Timer.Start {
-for i := range global.GVA_CONFIG.Timer.Detail {
-go func(detail config.Detail) {
-var option []cron.Option
-if global.GVA_CONFIG.Timer.WithSeconds {
-option = append(option, cron.WithSeconds())
-}
-_, err := global.GVA_Timer.AddTaskByFunc("ClearDB", global.GVA_CONFIG.Timer.Spec, func() {
-err := utils.ClearTable(global.GVA_DB, detail.TableName, detail.CompareField, detail.Interval)
-if err != nil {
-fmt.Println("timer error:", err)
-}
-}, option...)
-if err != nil {
-fmt.Println("add timer error:", err)
-}
-}(global.GVA_CONFIG.Timer.Detail[i])
+go func() {
+var option []cron.Option
+option = append(option, cron.WithSeconds())
+// 清理DB定时任务
+_, err := global.GVA_Timer.AddTaskByFunc("ClearDB", "@daily", func() {
+err := task.ClearTable(global.GVA_DB) // 定时任务方法定在task文件包中
+if err != nil {
+fmt.Println("timer error:", err)
+}
+}, option...)
+if err != nil {
+fmt.Println("add timer error:", err)
 }
-}
+
+// 其他定时任务定在这里 参考上方使用方法
+
+//_, err := global.GVA_Timer.AddTaskByFunc("定时任务标识", "corn表达式", func() {
+//	具体执行内容...
+// ......
+//}, option...)
+//if err != nil {
+//	fmt.Println("add timer error:", err)
+//}
+}()
 }

server/initialize/timer.go

@@ -0,0 +1,7 @@
+package common
+
+type ClearDB struct {
+TableName string
+CompareField string
+Interval string
+}

server/model/common/clearDB.go

@@ -0,0 +1,51 @@
+package task
+
+import (
+"errors"
+"fmt"
+"github.com/flipped-aurora/gin-vue-admin/server/model/common"
+"time"
+
+"gorm.io/gorm"
+)
+
+//@author: [songzhibin97](https://github.com/songzhibin97)
+//@function: ClearTable
+//@description: 清理数据库表数据
+//@param: db(数据库对象) *gorm.DB, tableName(表名) string, compareField(比较字段) string, interval(间隔) string
+//@return: error
+
+func ClearTable(db *gorm.DB) error {
+var ClearTableDetail []common.ClearDB
+
+ClearTableDetail = append(ClearTableDetail, common.ClearDB{
+TableName: "sys_operation_records",
+CompareField: "created_at",
+Interval: "2160h",
+})
+
+ClearTableDetail = append(ClearTableDetail, common.ClearDB{
+TableName: "jwt_blacklists",
+CompareField: "created_at",
+Interval: "168h",
+})
+
+if db == nil {
+return errors.New("db Cannot be empty")
+}
+
+for _, detail := range ClearTableDetail {
+duration, err := time.ParseDuration(detail.Interval)
+if err != nil {
+return err
+}
+if duration < 0 {
+return errors.New("parse duration < 0")
+}
+err = db.Debug().Exec(fmt.Sprintf("DELETE FROM %s WHERE %s < ?", detail.TableName, detail.CompareField), time.Now().Add(-duration)).Error
+if err != nil {
+return err
+}
+}
+return nil
+}