From b3280ee290938d7010105a4b7136fbf6966ecf0c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Mon, 6 Dec 2021 10:15:32 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BC=A9=E7=9F=AD=E7=9B=91=E6=8E=A7=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=B8=85=E7=90=86=E6=97=B6=E9=97=B4=E4=B8=BA2?= =?UTF-8?q?=E5=A4=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/db/models/node_value_dao.go | 6 +++--- internal/tasks/monitor_item_value_task.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/db/models/node_value_dao.go b/internal/db/models/node_value_dao.go index c84b62fa..2c9ec20c 100644 --- a/internal/db/models/node_value_dao.go +++ b/internal/db/models/node_value_dao.go @@ -55,10 +55,10 @@ func (this *NodeValueDAO) CreateValue(tx *dbs.Tx, clusterId int64, role nodeconf }) } -// DeleteExpiredValues 清除数据 -func (this *NodeValueDAO) DeleteExpiredValues(tx *dbs.Tx) error { +// Clean 清除数据 +func (this *NodeValueDAO) Clean(tx *dbs.Tx) error { // 删除N天之前的所有数据 - expiredDays := 7 + expiredDays := 2 day := timeutil.Format("Ymd", time.Now().AddDate(0, 0, -expiredDays)) _, err := this.Query(tx). Where("day<:day"). diff --git a/internal/tasks/monitor_item_value_task.go b/internal/tasks/monitor_item_value_task.go index 62fbcbb1..74d1c0fd 100644 --- a/internal/tasks/monitor_item_value_task.go +++ b/internal/tasks/monitor_item_value_task.go @@ -39,5 +39,5 @@ func (this *MonitorItemValueTask) Start() { } func (this *MonitorItemValueTask) Loop() error { - return models.SharedNodeValueDAO.DeleteExpiredValues(nil) + return models.SharedNodeValueDAO.Clean(nil) }