From 96536e0052cc29e9fb9fab729fe2f50f53bcc084 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 10 十一月 2023 17:56:53 +0800 Subject: [PATCH] 切换设备时不需要重启任务 --- crontask/cron_task.go | 13 +++++++++++-- 1 files changed, 11 insertions(+), 2 deletions(-) diff --git a/crontask/cron_task.go b/crontask/cron_task.go index aca64dd..c38ef9d 100644 --- a/crontask/cron_task.go +++ b/crontask/cron_task.go @@ -19,6 +19,9 @@ var s *gocron.Scheduler +func init() { + s = gocron.NewScheduler(time.UTC) +} func StartTask(isMaster bool) error { finishNumberTimeInterval := conf.Conf.PLC.FinishNumberTimeInterval totalNumberTimeInterval := conf.Conf.PLC.TotalNumberTimeInterval @@ -28,7 +31,6 @@ if totalNumberTimeInterval == 0 { totalNumberTimeInterval = 60 } - s = gocron.NewScheduler(time.UTC) _, err := s.Every(finishNumberTimeInterval).Seconds().Do(func() { plcConfig, code := service.NewDevicePlcService().GetDevicePlc() if code != ecode.OK { @@ -139,8 +141,15 @@ func RestartTask(isMaster bool) error { if s != nil { s.Stop() + s.Clear() } - return StartTask(isMaster) + err := StartTask(isMaster) + if err != nil { + logx.Errorf("restart task failed:%v", err) + return err + } + logx.Infof("restart task ok, isMaster:", isMaster) + return nil } // Once 涓�娆℃�т换鍔� -- Gitblit v1.8.0