diff --git a/app/task/init.go b/app/task/init.go index 95667ea..e60475e 100644 --- a/app/task/init.go +++ b/app/task/init.go @@ -41,8 +41,19 @@ func Run() { _ = logx.Info("auto tasks running...") } +// MapCrontabCfg 获取自动任务队列 +func MapCrontabCfg(eg *xorm.Engine) *[]model.SysCfg { + var c []model.SysCfg + // 数据库查询如果有下划线会认为是一个任意字符 + if err := eg.Where("`k` LIKE 'cron\\_%' AND val != ''").Cols("`key`,`val`").Find(&c); err != nil || len(c) == 0 { + logx.Warn(err) + return nil + } + return &c +} + func reload() { - taskCfgList = db.MapCrontabCfg(db.Db) + taskCfgList = MapCrontabCfg(db.Db) if len(*taskCfgList) > 0 { // 删除原有所有任务