diff --git a/internal/web/actions/default/clusters/init.go b/internal/web/actions/default/clusters/init.go index 048fed4c..041a638b 100644 --- a/internal/web/actions/default/clusters/init.go +++ b/internal/web/actions/default/clusters/init.go @@ -21,8 +21,8 @@ func init() { EndHelpers(). Helper(helpers.NewUserMustAuth(configloaders.AdminModuleCodeCommon)). Post("/options", new(OptionsAction)). + Post("/nodeOptions", new(NodeOptionsAction)). GetPost("/selectPopup", new(SelectPopupAction)). - EndAll() }) } diff --git a/internal/web/actions/default/clusters/logs/index.go b/internal/web/actions/default/clusters/logs/index.go index 670aeb88..febe6d9f 100644 --- a/internal/web/actions/default/clusters/logs/index.go +++ b/internal/web/actions/default/clusters/logs/index.go @@ -22,12 +22,14 @@ func (this *IndexAction) Init() { } func (this *IndexAction) RunGet(params struct { - DayFrom string - DayTo string - Keyword string - Level string - Type string - Tag string + DayFrom string + DayTo string + Keyword string + Level string + Type string + Tag string + ClusterId int64 + NodeId int64 }) { this.Data["dayFrom"] = params.DayFrom this.Data["dayTo"] = params.DayTo @@ -35,6 +37,8 @@ func (this *IndexAction) RunGet(params struct { this.Data["level"] = params.Level this.Data["type"] = params.Type this.Data["tag"] = params.Tag + this.Data["clusterId"] = params.ClusterId + this.Data["nodeId"] = params.NodeId // 常见标签 this.Data["tags"] = nodelogutils.FindNodeCommonTags() @@ -52,14 +56,15 @@ func (this *IndexAction) RunGet(params struct { // 日志数量 countResp, err := this.RPC().NodeLogRPC().CountNodeLogs(this.AdminContext(), &pb.CountNodeLogsRequest{ - NodeId: 0, - Role: nodeconfigs.NodeRoleNode, - DayFrom: params.DayFrom, - DayTo: params.DayTo, - Keyword: params.Keyword, - Level: params.Level, - IsUnread: params.Type == "unread", - Tag: params.Tag, + NodeClusterId: params.ClusterId, + NodeId: params.NodeId, + Role: nodeconfigs.NodeRoleNode, + DayFrom: params.DayFrom, + DayTo: params.DayTo, + Keyword: params.Keyword, + Level: params.Level, + IsUnread: params.Type == "unread", + Tag: params.Tag, }) if err != nil { this.ErrorPage(err) @@ -70,16 +75,17 @@ func (this *IndexAction) RunGet(params struct { this.Data["page"] = page.AsHTML() logsResp, err := this.RPC().NodeLogRPC().ListNodeLogs(this.AdminContext(), &pb.ListNodeLogsRequest{ - NodeId: 0, - Role: nodeconfigs.NodeRoleNode, - DayFrom: params.DayFrom, - DayTo: params.DayTo, - Keyword: params.Keyword, - Level: params.Level, - IsUnread: params.Type == "unread", - Tag: params.Tag, - Offset: page.Offset, - Size: page.Size, + NodeClusterId: params.ClusterId, + NodeId: params.NodeId, + Role: nodeconfigs.NodeRoleNode, + DayFrom: params.DayFrom, + DayTo: params.DayTo, + Keyword: params.Keyword, + Level: params.Level, + IsUnread: params.Type == "unread", + Tag: params.Tag, + Offset: page.Offset, + Size: page.Size, }) if err != nil { this.ErrorPage(err) diff --git a/internal/web/actions/default/servers/logs/nodeOptions.go b/internal/web/actions/default/clusters/nodeOptions.go similarity index 97% rename from internal/web/actions/default/servers/logs/nodeOptions.go rename to internal/web/actions/default/clusters/nodeOptions.go index 84f33caf..be08bc16 100644 --- a/internal/web/actions/default/servers/logs/nodeOptions.go +++ b/internal/web/actions/default/clusters/nodeOptions.go @@ -1,6 +1,6 @@ // Copyright 2022 Liuxiangchao iwind.liu@gmail.com. All rights reserved. -package logs +package clusters import ( "github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils" diff --git a/internal/web/actions/default/servers/logs/index.go b/internal/web/actions/default/servers/logs/index.go index b08b8ed9..754ff62e 100644 --- a/internal/web/actions/default/servers/logs/index.go +++ b/internal/web/actions/default/servers/logs/index.go @@ -7,7 +7,6 @@ import ( "github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils" "github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb" "github.com/iwind/TeaGo/lists" - "github.com/iwind/TeaGo/maps" timeutil "github.com/iwind/TeaGo/utils/time" "regexp" "strings" @@ -153,20 +152,5 @@ func (this *IndexAction) RunGet(params struct { } this.Data["regions"] = regionMap - // 集群列表 - var clusterMaps = []maps.Map{} - clusterResp, err := this.RPC().NodeClusterRPC().FindAllEnabledNodeClusters(this.AdminContext(), &pb.FindAllEnabledNodeClustersRequest{}) - if err != nil { - this.ErrorPage(err) - return - } - for _, cluster := range clusterResp.NodeClusters { - clusterMaps = append(clusterMaps, maps.Map{ - "id": cluster.Id, - "name": cluster.Name, - }) - } - this.Data["clusters"] = clusterMaps - this.Show() } diff --git a/internal/web/actions/default/servers/logs/init.go b/internal/web/actions/default/servers/logs/init.go index 0760cfaa..e504e224 100644 --- a/internal/web/actions/default/servers/logs/init.go +++ b/internal/web/actions/default/servers/logs/init.go @@ -17,7 +17,6 @@ func init() { Prefix("/servers/logs"). Get("", new(IndexAction)). GetPost("/settings", new(SettingsAction)). - Post("/nodeOptions", new(NodeOptionsAction)). EndAll() }) } diff --git a/web/public/js/components/cluster/node-cluster-combo-box.js b/web/public/js/components/cluster/node-cluster-combo-box.js new file mode 100644 index 00000000..d9d2957f --- /dev/null +++ b/web/public/js/components/cluster/node-cluster-combo-box.js @@ -0,0 +1,26 @@ +Vue.component("node-cluster-combo-box", { + props: ["v-cluster-id"], + data: function () { + let that = this + Tea.action("/clusters/options") + .post() + .success(function (resp) { + that.clusters = resp.data.clusters + }) + return { + clusters: [] + } + }, + methods: { + change: function (item) { + if (item == null) { + this.$emit("change", 0) + } else { + this.$emit("change", item.value) + } + } + }, + template: `