| | |
|---|
| | | |
|---|
| | | 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 |
|---|
| | |
|---|
| | | 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 { |
|---|
| | |
|---|
| | | 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 一次性任务 |
|---|
