package cron

import (
	"fmt"
	"strings"

	"mini-chat/internal/repository/mysql/model"
)

func (s *server) AddTask(task *model.PatientMedicineTask) {
	defer func() {
		if err := recover(); err != nil {
			s.logger.Error(fmt.Sprintf("[定时任务] 任务编号: %s, 添加异常: %+v", task.Code, err))
		}
	}()

	spec := "0 " + strings.TrimSpace(task.Spec)
	name := fmt.Sprintf("cron_task_%s", task.Code)

	s.cron.AddFunc(spec, s.AddJob(task, "定时任务"), name)
}