jiazhizhong/polaris
1
0
Fork 0
mirror of https://github.com/simon-ding/polaris.git synced 2026-06-09 19:47:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: cron jobs

Browse Source
This commit is contained in:
Simon Ding
2024-09-04 13:18:14 +08:00
parent 3e5e20e933
commit e4c111ac2a
3 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/core/scheduler.go
View File

@@ -17,22 +17,23 @@ import (
) )
func (c *Client) addSysCron() { func (c *Client) addSysCron() {
c.registerCronJob("check_running_tasks","@every 1m", c.checkTasks) c.registerCronJob("check_running_tasks", "@every 1m", c.checkTasks)
c.registerCronJob("check_available_medias_to_download","0 0 * * * *", func() error{ c.registerCronJob("check_available_medias_to_download", "0 0 * * * *", func() error {
c.downloadAllTvSeries() c.downloadAllTvSeries()
c.downloadAllMovies() c.downloadAllMovies()
return nil return nil
}) })
c.registerCronJob("check_series_new_release", "0 0 */12 * * *", c.checkAllSeriesNewSeason) c.registerCronJob("check_series_new_release", "0 0 */12 * * *", c.checkAllSeriesNewSeason)
c.registerCronJob("update_import_lists","0 30 * * * *", c.periodicallyUpdateImportlist) c.registerCronJob("update_import_lists", "0 30 * * * *", c.periodicallyUpdateImportlist)
c.schedulers.Range(func(key string, value scheduler) bool { c.schedulers.Range(func(key string, value scheduler) bool {
log.Debugf("add cron job: %v", key)
c.mustAddCron(value.cron, func() { c.mustAddCron(value.cron, func() {
if err := value.f(); err != nil { if err := value.f(); err != nil {
log.Errorf("exexuting cron job %s error: %v", key, err) log.Errorf("exexuting cron job %s error: %v", key, err)
} }
}) })
return false return true
}) })
c.cron.Start() c.cron.Start()
} }
@@ -52,7 +53,7 @@ func (c *Client) TriggerCronJob(name string) error {
return job.f() return job.f()
} }
func (c *Client) checkTasks() error{ func (c *Client) checkTasks() error {
log.Debug("begin check tasks...") log.Debug("begin check tasks...")
for id, t := range c.tasks { for id, t := range c.tasks {
r := c.db.GetHistory(id) r := c.db.GetHistory(id)
@@ -375,7 +376,7 @@ func (c *Client) downloadMovieSingleEpisode(ep *ent.Episode, targetDir string) (
return r1.Name, nil return r1.Name, nil
} }
func (c *Client) checkAllSeriesNewSeason() error{ func (c *Client) checkAllSeriesNewSeason() error {
log.Infof("begin checking series all new season") log.Infof("begin checking series all new season")
allSeries := c.db.GetMediaWatchlist(media.MediaTypeTv) allSeries := c.db.GetMediaWatchlist(media.MediaTypeTv)
for _, series := range allSeries { for _, series := range allSeries {

2
ui/lib/settings/importlist.dart
View File

@@ -118,6 +118,6 @@ class _ImportlistState extends ConsumerState<Importlist> {
} }
return showSettingDialog( return showSettingDialog(
context, "导入列表", list.id != null, body, onSubmit, onDelete); context, "监控列表", list.id != null, body, onSubmit, onDelete);
} }
} }

2
ui/lib/settings/settings.dart
View File

@@ -28,7 +28,7 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
getExpansionTile("下载器", const DownloaderSettings()), getExpansionTile("下载器", const DownloaderSettings()),
getExpansionTile("存储", const StorageSettings()), getExpansionTile("存储", const StorageSettings()),
getExpansionTile("通知客户端", const NotifierSettings()), getExpansionTile("通知客户端", const NotifierSettings()),
getExpansionTile("导入列表", const Importlist()), getExpansionTile("监控列表", const Importlist()),
getExpansionTile("认证", const AuthSettings()) getExpansionTile("认证", const AuthSettings())
], ],
); );