|
@@ -238,12 +238,11 @@ func main() {
|
|
|
// error 错误状态,此状态下不启动数采任务
|
|
|
|
|
|
// 启停master
|
|
|
- if localStatus == "running" && timeAllowedFlag && !limitReachedFlag {
|
|
|
- if !launchedFlag { // 目前未启动数采程序
|
|
|
- c_log.GlobalLogger.Info("数采程序启动 - 开始。")
|
|
|
- startMasterNode()
|
|
|
- }
|
|
|
- } else if localStatus == "idle" || !timeAllowedFlag || !limitReachedFlag {
|
|
|
+ if localStatus == "running" && timeAllowedFlag && !limitReachedFlag && !launchedFlag {
|
|
|
+ // 目前未启动数采程序
|
|
|
+ c_log.GlobalLogger.Info("数采程序启动 - 开始。")
|
|
|
+ startMasterNode()
|
|
|
+ } else if localStatus == "idle" || !timeAllowedFlag || limitReachedFlag {
|
|
|
if !renewedFlag && launchedFlag && len(entity.TimeWindowConsumerQueue) == 0 {
|
|
|
time.Sleep(time.Duration(waitStopLength) * time.Minute)
|
|
|
c_log.GlobalLogger.Info("数采程序关闭 - 开始。")
|