From f838162ed0ee7f2832924c2399eddd461760135a Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 13 十月 2023 21:47:54 +0800
Subject: [PATCH] plc地址和工艺参数不再单独拉取，只serf主启动时拉取
---
main.go | 16 +++++++++++-----
1 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/main.go b/main.go
index 569c9e7..bae163b 100644
--- a/main.go
+++ b/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()
@@ -54,6 +49,11 @@
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
+ }
}
logx.Infof("apsClient start serve...")
@@ -73,8 +73,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)
--
Gitblit v1.8.0