在服务列表中显示需要修复的错误

internal/web/actions/default/servers/fixLog.go

@@ -0,0 +1,24 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package servers
+
+import (
+	"github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils"
+	"github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb"
+)
+
+type FixLogAction struct {
+	actionutils.ParentAction
+}
+
+func (this *FixLogAction) RunPost(params struct {
+	LogId int64
+}) {
+	_, err := this.RPC().NodeLogRPC().FixNodeLog(this.AdminContext(), &pb.FixNodeLogRequest{NodeLogId: params.LogId})
+	if err != nil {
+		this.ErrorPage(err)
+		return
+	}
+
+	this.Success()
+}

internal/web/actions/default/servers/index.go

@@ -4,9 +4,11 @@ import (
 	"encoding/json"
 	"github.com/TeaOSLab/EdgeAdmin/internal/configloaders"
 	"github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils"
+	"github.com/TeaOSLab/EdgeCommon/pkg/configutils"
 	"github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb"
 	"github.com/TeaOSLab/EdgeCommon/pkg/serverconfigs"
 	"github.com/iwind/TeaGo/maps"
+	timeutil "github.com/iwind/TeaGo/utils/time"
 )
 
 type IndexAction struct {
@@ -250,5 +252,48 @@ func (this *IndexAction) RunGet(params struct {
 	// 是否有用户管理权限
 	this.Data["canVisitUser"] = configloaders.AllowModule(this.AdminId(), configloaders.AdminModuleCodeUser)
 
+	// 显示服务相关的日志
+	errorLogsResp, err := this.RPC().NodeLogRPC().ListNodeLogs(this.AdminContext(), &pb.ListNodeLogsRequest{
+		NodeId:     0,
+		Role:       "node",
+		Offset:     0,
+		Size:       10,
+		Level:      "error",
+		FixedState: int32(configutils.BoolStateNo),
+		AllServers: true,
+	})
+	if err != nil {
+		this.ErrorPage(err)
+		return
+	}
+	errorLogMaps := []maps.Map{}
+	for _, errorLog := range errorLogsResp.NodeLogs {
+		serverResp, err := this.RPC().ServerRPC().FindEnabledUserServerBasic(this.AdminContext(), &pb.FindEnabledUserServerBasicRequest{ServerId: errorLog.ServerId})
+		if err != nil {
+			this.ErrorPage(err)
+			return
+		}
+		server := serverResp.Server
+		if server == nil {
+			// 设置为已修复
+			_, err = this.RPC().NodeLogRPC().FixNodeLog(this.AdminContext(), &pb.FixNodeLogRequest{NodeLogId: errorLog.Id})
+			if err != nil {
+				this.ErrorPage(err)
+				return
+			}
+
+			continue
+		}
+
+		errorLogMaps = append(errorLogMaps, maps.Map{
+			"id":          errorLog.Id,
+			"description": errorLog.Description,
+			"createdTime": timeutil.FormatTime("Y-m-d H:i:s", errorLog.CreatedAt),
+			"serverId":    errorLog.ServerId,
+			"serverName":  server.Name,
+		})
+	}
+	this.Data["errorLogs"] = errorLogMaps
+
 	this.Show()
 }

internal/web/actions/default/servers/init.go

@@ -15,6 +15,7 @@ func init() {
 			Get("", new(IndexAction)).
 			GetPost("/create", new(CreateAction)).
 			GetPost("/update", new(UpdateAction)).
+			Post("/fixLog", new(FixLogAction)).
 
 			GetPost("/addPortPopup", new(AddPortPopupAction)).
 			GetPost("/addServerNamePopup", new(AddServerNamePopupAction)).