From 1fbed2679d7eb6f75954dbe1d0d48524d3ed6e36 Mon Sep 17 00:00:00 2001
From: marvzhang <tikazyq@163.com>
Date: Sat, 18 Jul 2020 21:35:54 +0800
Subject: [PATCH] updated node offline task update

---
 backend/services/node.go | 26 +++++++++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

diff --git a/backend/services/node.go b/backend/services/node.go
index 641b403c..e3ef237a 100644
--- a/backend/services/node.go
+++ b/backend/services/node.go
@@ -192,6 +192,26 @@ func UpdateNodeStatusPeriodically() {
 	}
 }
 
+// 每60秒更新异常节点信息
+func UpdateOfflineNodeTaskToAbnormalPeriodically() {
+	for {
+		nodes, err := model.GetNodeList(bson.M{"status": constants.StatusOffline})
+		if err != nil {
+			log.Errorf("get nodes error: " + err.Error())
+			debug.PrintStack()
+			continue
+		}
+		for _, n := range nodes {
+			if err := model.UpdateTaskToAbnormal(n.Id); err != nil {
+				log.Errorf("update task to abnormal error: " + err.Error())
+				debug.PrintStack()
+				continue
+			}
+		}
+		time.Sleep(60 * time.Second)
+	}
+}
+
 // 初始化节点服务
 func InitNodeService() error {
 	node, err := local_node.InitLocalNode()
@@ -216,9 +236,13 @@ func InitNodeService() error {
 		return err
 	}
 
-	// 如果为主节点，每10秒刷新所有节点信息
+	// 如果为主节点
 	if model.IsMaster() {
+		// 每10秒刷新所有节点信息
 		go UpdateNodeStatusPeriodically()
+
+		// 每60秒更新离线节点任务为异常
+		go UpdateOfflineNodeTaskToAbnormalPeriodically()
 	}
 
 	// 更新在当前节点执行中的任务状态为：abnormal