diff --git a/internal/cron/cron_server/server.go b/internal/cron/cron_server/server.go index 5cce0f5..06eaaee 100644 --- 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 index 414e953..9d4c649 100644 --- 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) } }