package service

import (
	"context"
	"github.com/go-kratos/kratos/v2/log"
)

func (s *VoucherService) CronWarningBudget(ctx context.Context) error {

	c, ok := s.bc.Cron.CommandMap["warningBudget"]

	if !ok {
		log.Error("warningBudget定时任务未找到")
		return nil
	}

	if !c.IsOpen {
		log.Warn("warningBudget定时任务未开启")
		return nil
	}

	if len(c.Command) == 0 {
		log.Error("warningBudget定时任务 command is empty")
		return nil
	}

	return s.cron.AddFunc(c.Command, func() {

		s.VoucherBiz.CronWarningBudget(ctx)

	})

}