From 41e652559093b1baf349aeead09797df0ef01509 Mon Sep 17 00:00:00 2001
From: GoEdgeLab <goedgecloud@gmail.com>
Date: Fri, 25 Nov 2022 15:48:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=81=A5=E5=BA=B7=E6=A3=80=E6=9F=A5=E6=97=B6?=
 =?UTF-8?q?=E5=8F=AA=E6=9C=89=E5=BC=80=E5=90=AF=E4=BA=86=E8=87=AA=E5=8A=A8?=
 =?UTF-8?q?=E4=B8=8B=E7=BA=BF=E6=89=8D=E5=8F=91=E9=80=81=E4=B8=8A=E7=BA=BF?=
 =?UTF-8?q?=E9=80=9A=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/tasks/health_check_executor.go | 37 +++++++++++++------------
 1 file changed, 20 insertions(+), 17 deletions(-)

diff --git a/internal/tasks/health_check_executor.go b/internal/tasks/health_check_executor.go
index f90ae103..90e36ff0 100644
--- a/internal/tasks/health_check_executor.go
+++ b/internal/tasks/health_check_executor.go
@@ -167,24 +167,27 @@ func (this *HealthCheckExecutor) runNode(healthCheckConfig *serverconfigs.Health
 		}
 
 		if isChanged {
-			// 发送消息
-			var message = ""
-			var messageType string
-			var messageLevel string
-			if result.IsOk {
-				message = "健康检查成功，节点\"" + result.Node.Name + "\"，IP\"" + result.NodeAddr + "\"已恢复上线"
-				messageType = models.MessageTypeHealthCheckNodeUp
-				messageLevel = models.MessageLevelSuccess
-			} else {
-				message = "健康检查失败，节点\"" + result.Node.Name + "\"，IP\"" + result.NodeAddr + "\"已自动下线"
-				messageType = models.MessageTypeHealthCheckNodeDown
-				messageLevel = models.MessageLevelError
-			}
+			// 在线状态发生变化
+			if healthCheckConfig.AutoDown {
+				// 发送消息
+				var message = ""
+				var messageType string
+				var messageLevel string
+				if result.IsOk {
+					message = "健康检查成功，节点\"" + result.Node.Name + "\"，IP\"" + result.NodeAddr + "\"已恢复上线"
+					messageType = models.MessageTypeHealthCheckNodeUp
+					messageLevel = models.MessageLevelSuccess
+				} else {
+					message = "健康检查失败，节点\"" + result.Node.Name + "\"，IP\"" + result.NodeAddr + "\"已自动下线"
+					messageType = models.MessageTypeHealthCheckNodeDown
+					messageLevel = models.MessageLevelError
+				}
 
-			err = models.NewMessageDAO().CreateNodeMessage(nil, nodeconfigs.NodeRoleNode, this.clusterId, int64(result.Node.Id), messageType, messageLevel, message, message, nil, false)
-			if err != nil {
-				this.logErr("HealthCheckExecutor", err.Error())
-				return
+				err = models.NewMessageDAO().CreateNodeMessage(nil, nodeconfigs.NodeRoleNode, this.clusterId, int64(result.Node.Id), messageType, messageLevel, message, message, nil, false)
+				if err != nil {
+					this.logErr("HealthCheckExecutor", err.Error())
+					return
+				}
 			}
 
 			// 触发阈值