定时同步任务状态

zhangqian

2023-10-17 56307a744dc94f9b1eed3f7513a4be16a130e984

 main.go

@@ -25,11 +25,6 @@
      return
   }

   if err := crontask.InitTask(); err != nil {
      logx.Errorf("crontab task Init err:%v", err)
      return
   }

   //加载plc写入地址
   plc_address.LoadAddressFromFile()

@@ -41,6 +36,7 @@
      "process_model",
      "production_progress",
      "work_order",
      "task_status_sync",
   }

   agent := serf.InitAgent("apsClient", syncTables, sqlitex.GetDB())
@@ -52,6 +48,11 @@
   if agent.ClusterStatus != "slave" {
      if err := nsq.Init(); err != nil {
         logx.Errorf("nsq Init err:%v", err)
         return
      }
      crontask.Once()
      if err := crontask.StartTask(); err != nil {
         logx.Errorf("crontab task Init err:%v", err)
         return
      }
   }
@@ -73,8 +74,14 @@
         logx.Errorf("nsq Init err:%v", err)
         return
      }
      crontask.Once()
      if err := crontask.StartTask(); err != nil {
         logx.Errorf("crontab task Init err:%v", err)
         return
      }
   case serf.EventJoinCluster, serf.EventMaster2Slave:
      nsq.Stop()
      crontask.StopTask()
   }

   logx.Infof("serf cluster event: %v", stat)