From e4f06d34c3fc6bcfeb2f3c72dcebcd5d7e877f9c Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sat, 3 Dec 2022 21:51:55 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BC=A9=E7=9F=AD=E8=AE=BF=E9=97=AE=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E8=87=AA=E5=8A=A8=E6=B8=85=E7=90=86=E6=97=B6=E9=97=B4?= =?UTF-8?q?=EF=BC=88=E4=BB=8E=E6=AF=8F12=E4=B8=AA=E5=B0=8F=E6=97=B6?= =?UTF-8?q?=E6=94=B9=E6=88=90=E6=AF=8F6=E4=B8=AA=E5=B0=8F=E6=97=B6?= =?UTF-8?q?=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/tasks/server_access_log_cleaner.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/tasks/server_access_log_cleaner.go b/internal/tasks/server_access_log_cleaner.go index 387e1ebc..81b53647 100644 --- a/internal/tasks/server_access_log_cleaner.go +++ b/internal/tasks/server_access_log_cleaner.go @@ -16,7 +16,7 @@ import ( func init() { dbs.OnReadyDone(func() { goman.New(func() { - NewServerAccessLogCleaner(12 * time.Hour).Start() + NewServerAccessLogCleaner(6 * time.Hour).Start() }) }) } @@ -52,7 +52,7 @@ func (this *ServerAccessLogCleaner) Loop() error { if len(configJSON) == 0 { return nil } - config := &systemconfigs.DatabaseConfig{} + var config = &systemconfigs.DatabaseConfig{} err = json.Unmarshal(configJSON, config) if err != nil { return err @@ -60,8 +60,8 @@ func (this *ServerAccessLogCleaner) Loop() error { if config.ServerAccessLog.Clean.Days <= 0 { return nil } - days := config.ServerAccessLog.Clean.Days - endDay := timeutil.Format("Ymd", time.Now().AddDate(0, 0, -days+1)) + var days = config.ServerAccessLog.Clean.Days + var endDay = timeutil.Format("Ymd", time.Now().AddDate(0, 0, -days+1)) // 当前连接的数据库 db, err := dbs.Default() @@ -113,7 +113,7 @@ func (this *ServerAccessLogCleaner) cleanDB(db *dbs.DB, endDay string) error { if len(columnNames) != 1 { return errors.New("invalid column names: " + strings.Join(columnNames, ", ")) } - columnName := columnNames[0] + var columnName = columnNames[0] var reg = regexp.MustCompile(`^(?i)(edgeHTTPAccessLogs|edgeNSAccessLogs)_(\d{8})(_\d{4})?$`) for _, one := range ones { var tableName = one.GetString(columnName)