切换设备时不需要重启任务

zhangqian

2023-11-10 96536e0052cc29e9fb9fab729fe2f50f53bcc084

 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 一次性任务
@@ -160,6 +169,12 @@
   if err != nil {
      logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg)
   }
   msg = &common.MsgPullDataRequest{DataType: common.PullDataTypeProcessModelPlcAddress}
   caller = nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicPullDataRequest, conf.Conf.NsqConf.NodeId), constvar.NsqTopicPullDataResponse)
   err = caller.Send(msg)
   if err != nil {
      logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg)
   }
}

func QueryClusterStatus() {