feature(1.2.7): 新增 cron_server - 后台任务

- 优化代码；
xinliangnote · Sep 5, 2021 · f47f57e · f47f57e
1 parent f17f6a7
commit f47f57e
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 2 deletions.
diff --git a/internal/cron/cron_server/server.go b/internal/cron/cron_server/server.go
@@ -50,11 +50,21 @@ type server struct {
 
 type Server interface {
 	i()
+
+	// Start 启动 cron 服务
 	Start()
+
+	// Stop 停止 cron 服务
 	Stop()
+
+	// AddTask 增加定时任务
 	AddTask(task *cron_task_repo.CronTask)
-	AddJob(task *cron_task_repo.CronTask) cron.FuncJob
+
+	// RemoveTask 删除定时任务
 	RemoveTask(taskId int)
+
+	// AddJob 增加定时任务执行的工作内容
+	AddJob(task *cron_task_repo.CronTask) cron.FuncJob
 }
 
 func New(logger *zap.Logger, db db.Repo, cache cache.Repo) (Server, error) {

diff --git a/internal/cron/cron_server/service_add_job.go b/internal/cron/cron_server/service_add_job.go
@@ -13,7 +13,10 @@ func (s *server) AddJob(task *cron_task_repo.CronTask) cron.FuncJob {
 		s.taskCount.Add()
 		defer s.taskCount.Done()
 
-		msg := fmt.Sprintf("开始执行任务：(%d)%s [%s]", task.Id, task.Name, task.Spec)
+		// 将 task 信息写入到 Kafka Topic 中，任务执行器订阅 Topic 如果为符合条件的任务并进行执行，反之不执行
+		// 为了便于演示，不写入到 Kafka 中，仅记录日志
+
+		msg := fmt.Sprintf("执行任务：(%d)%s [%s]", task.Id, task.Name, task.Spec)
 		s.logger.Info(msg)
 	}
 }