From 217d807ed38a439c37f06c6c20b72d82b916c71b Mon Sep 17 00:00:00 2001
From: simonzhangsz <simonzhangsz@outlook.com>
Date: Sat, 21 Oct 2023 16:32:24 +0800
Subject: [PATCH] fix: delete expired ne backup file

---
 src/modules/crontask/crontask.go                             | 5 +++--
 .../tasks.go => delExpiredNeBackup/delExpiredNeBackup.go}    | 4 ++--
 2 files changed, 5 insertions(+), 4 deletions(-)
 rename src/modules/crontask/{tasks/tasks.go => delExpiredNeBackup/delExpiredNeBackup.go} (96%)

diff --git a/src/modules/crontask/crontask.go b/src/modules/crontask/crontask.go
index 50de7700..5d544d25 100644
--- a/src/modules/crontask/crontask.go
+++ b/src/modules/crontask/crontask.go
@@ -3,7 +3,7 @@ package crontask
 import (
 	"ems.agt/src/framework/cron"
 	"ems.agt/src/framework/logger"
-	"ems.agt/src/modules/crontask/tasks"
+	"ems.agt/src/modules/crontask/delExpiredNeBackup"
 
 	"github.com/gin-gonic/gin"
 )
@@ -19,5 +19,6 @@ func Setup(router *gin.Engine) {
 
 // InitCronQueue 初始定时任务队列
 func InitCronQueue() {
-	cron.CreateQueue("tasks", tasks.NewProcessor)
+	// delete expired NE backup file
+	cron.CreateQueue("delExpiredNeBackup", delExpiredNeBackup.NewProcessor)
 }
diff --git a/src/modules/crontask/tasks/tasks.go b/src/modules/crontask/delExpiredNeBackup/delExpiredNeBackup.go
similarity index 96%
rename from src/modules/crontask/tasks/tasks.go
rename to src/modules/crontask/delExpiredNeBackup/delExpiredNeBackup.go
index 21f3b716..b7893533 100644
--- a/src/modules/crontask/tasks/tasks.go
+++ b/src/modules/crontask/delExpiredNeBackup/delExpiredNeBackup.go
@@ -1,4 +1,4 @@
-package tasks
+package delExpiredNeBackup
 
 import (
 	"ems.agt/lib/dborm"
@@ -57,7 +57,7 @@ func (s *BarProcessor) Execute(data any) (any, error) {
 
 	// 返回结果，用于记录执行结果
 	return map[string]any{
-		"err":      err.Error(),
+		"msg":      "sucesse",
 		"affected": affected,
 	}, nil
 }