健康检查没有开启上下线的时候也发送节点状态变更通知

internal/const/const.go

@@ -21,5 +21,5 @@ const (
 	NodeVersion = "0.5.8"
 
 	// SQLVersion SQL版本号
-	SQLVersion = "3"
+	SQLVersion = "4"
 )

internal/tasks/health_check_executor.go

@@ -198,9 +198,11 @@ func (this *HealthCheckExecutor) runNode(healthCheckConfig *serverconfigs.Health
 			}
 		}
 
-		// 我们只处理IP的上下线，不修改节点的状态
+		// 结束处理 ，因为我们只处理IP的上下线，不修改节点的状态
+		if healthCheckConfig.AutoDown {
 			return
 		}
+	}
 
 	// 修改节点状态
 	if healthCheckConfig.AutoDown {
@@ -216,6 +218,24 @@ func (this *HealthCheckExecutor) runNode(healthCheckConfig *serverconfigs.Health
 				message := "健康检查失败，节点\"" + result.Node.Name + "\"已自动下线"
 				err = models.NewMessageDAO().CreateNodeMessage(nil, nodeconfigs.NodeRoleNode, this.clusterId, int64(result.Node.Id), models.MessageTypeHealthCheckNodeDown, models.MessageLevelError, message, message, nil, false)
 			}
+			if err != nil {
+				this.logErr("HealthCheckExecutor", err.Error())
+				return
+			}
+		}
+	} else {
+		// 通知健康检查结果
+		var err error
+		if result.IsOk {
+			message := "节点\"" + result.Node.Name + "\"健康检查成功"
+			err = models.NewMessageDAO().CreateNodeMessage(nil, nodeconfigs.NodeRoleNode, this.clusterId, int64(result.Node.Id), models.MessageTypeHealthCheckNodeUp, models.MessageLevelSuccess, message, message, nil, false)
+		} else {
+			message := "节点\"" + result.Node.Name + "\"健康检查失败"
+			err = models.NewMessageDAO().CreateNodeMessage(nil, nodeconfigs.NodeRoleNode, this.clusterId, int64(result.Node.Id), models.MessageTypeHealthCheckNodeDown, models.MessageLevelError, message, message, nil, false)
+		}
+		if err != nil {
+			this.logErr("HealthCheckExecutor", err.Error())
+			return
 		}
 	}
 }