实现在服务中使用分组

internal/web/actions/default/clusters/cluster/groups/options.go

@@ -1,31 +0,0 @@
-package groups
-
-import (
-	"github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils"
-	"github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb"
-	"github.com/iwind/TeaGo/maps"
-)
-
-type OptionsAction struct {
-	actionutils.ParentAction
-}
-
-func (this *OptionsAction) RunPost(params struct {
-	ClusterId int64
-}) {
-	groupsResp, err := this.RPC().NodeGroupRPC().FindAllEnabledNodeGroupsWithClusterId(this.AdminContext(), &pb.FindAllEnabledNodeGroupsWithClusterIdRequest{ClusterId: params.ClusterId})
-	if err != nil {
-		this.ErrorPage(err)
-	}
-
-	groupMaps := []maps.Map{}
-	for _, group := range groupsResp.Groups {
-		groupMaps = append(groupMaps, maps.Map{
-			"id":   group.Id,
-			"name": group.Name,
-		})
-	}
-	this.Data["groups"] = groupMaps
-
-	this.Success()
-}

internal/web/actions/default/clusters/cluster/init.go

@@ -42,7 +42,6 @@ func init() {
 			GetPost("/groups/updatePopup", new(groups.UpdatePopupAction)).
 			Post("/groups/delete", new(groups.DeleteAction)).
 			Post("/groups/sort", new(groups.SortAction)).
-			Post("/groups/options", new(groups.OptionsAction)).
 			GetPost("/groups/selectPopup", new(groups.SelectPopupAction)).
 
 			EndAll()

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

@@ -16,7 +16,6 @@ func init() {
 			Get("", new(IndexAction)).
 			GetPost("/createPopup", new(CreatePopupAction)).
 			GetPost("/updatePopup", new(UpdatePopupAction)).
-			Post("/options", new(OptionsAction)).
 			GetPost("/selectPopup", new(SelectPopupAction)).
 			Post("/delete", new(DeleteAction)).
 			Post("/sort", new(SortAction)).

internal/web/actions/default/servers/components/groups/options.go

@@ -1,11 +0,0 @@
-package groups
-
-import "github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils"
-
-type OptionsAction struct {
-	actionutils.ParentAction
-}
-
-func (this *OptionsAction) RunPost(params struct{}) {
-	this.Success()
-}

internal/web/actions/default/servers/components/groups/selectPopup.go

@@ -1,6 +1,14 @@
 package groups
 
-import "github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils"
+import (
+	"github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils"
+	"github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb"
+	"github.com/iwind/TeaGo/actions"
+	"github.com/iwind/TeaGo/lists"
+	"github.com/iwind/TeaGo/maps"
+	"github.com/iwind/TeaGo/types"
+	"strings"
+)
 
 type SelectPopupAction struct {
 	actionutils.ParentAction
@@ -10,6 +18,61 @@ func (this *SelectPopupAction) Init() {
 	this.Nav("", "", "")
 }
 
-func (this *SelectPopupAction) RunGet(params struct{}) {
+func (this *SelectPopupAction) RunGet(params struct {
+	SelectedGroupIds string
+}) {
+	groupsResp, err := this.RPC().ServerGroupRPC().FindAllEnabledServerGroups(this.AdminContext(), &pb.FindAllEnabledServerGroupsRequest{})
+	if err != nil {
+		this.ErrorPage(err)
+	}
+
+	selectedGroupIds := []int64{}
+	if len(params.SelectedGroupIds) > 0 {
+		for _, v := range strings.Split(params.SelectedGroupIds, ",") {
+			selectedGroupIds = append(selectedGroupIds, types.Int64(v))
+		}
+	}
+
+	groupMaps := []maps.Map{}
+	for _, group := range groupsResp.Groups {
+		// 已经选过的就跳过
+		if lists.ContainsInt64(selectedGroupIds, group.Id) {
+			continue
+		}
+		groupMaps = append(groupMaps, maps.Map{
+			"id":   group.Id,
+			"name": group.Name,
+		})
+	}
+	this.Data["groups"] = groupMaps
+
 	this.Show()
 }
+
+func (this *SelectPopupAction) RunPost(params struct {
+	GroupId int64
+
+	Must *actions.Must
+}) {
+	if params.GroupId <= 0 {
+		this.Fail("请选择要使用的分组")
+	}
+
+	groupResp, err := this.RPC().ServerGroupRPC().FindEnabledServerGroup(this.AdminContext(), &pb.FindEnabledServerGroupRequest{GroupId: params.GroupId})
+	if err != nil {
+		this.ErrorPage(err)
+		return
+	}
+	group := groupResp.Group
+	if group == nil {
+		this.NotFound("serverGroup", params.GroupId)
+		return
+	}
+
+	this.Data["group"] = maps.Map{
+		"id":   group.Id,
+		"name": group.Name,
+	}
+
+	this.Success()
+}

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

@@ -47,6 +47,7 @@ func (this *CreateAction) RunPost(params struct {
 	Name        string
 	Description string
 	ClusterId   int64
+	GroupIds    []int64
 
 	ServerType  string
 	Addresses   string
@@ -259,6 +260,7 @@ func (this *CreateAction) RunPost(params struct {
 		ExcludeNodesJSON: excludeNodesJSON,
 		WebId:            webId,
 		ReverseProxyJSON: reverseProxyRefJSON,
+		GroupIds:         params.GroupIds,
 	}
 	if httpConfig != nil {
 		data, err := json.Marshal(httpConfig)

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

@@ -95,6 +95,17 @@ func (this *IndexAction) RunGet(params struct{}) {
 			}
 		}
 
+		// 分组
+		groupMaps := []maps.Map{}
+		if len(server.Groups) > 0 {
+			for _, group := range server.Groups {
+				groupMaps = append(groupMaps, maps.Map{
+					"id":   group.Id,
+					"name": group.Name,
+				})
+			}
+		}
+
 		serverMaps = append(serverMaps, maps.Map{
 			"id":   server.Id,
 			"isOn": server.IsOn,
@@ -105,6 +116,7 @@ func (this *IndexAction) RunGet(params struct{}) {
 			},
 			"ports":          portMaps,
 			"serverTypeName": serverconfigs.FindServerType(server.Type).GetString("name"),
+			"groups":         groupMaps,
 		})
 	}
 	this.Data["servers"] = serverMaps

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

@@ -57,6 +57,17 @@ func (this *IndexAction) RunGet(params struct {
 		clusterId = server.Cluster.Id
 	}
 
+	// 分组
+	groupMaps := []maps.Map{}
+	if len(server.Groups) > 0 {
+		for _, group := range server.Groups {
+			groupMaps = append(groupMaps, maps.Map{
+				"id":   group.Id,
+				"name": group.Name,
+			})
+		}
+	}
+
 	this.Data["server"] = maps.Map{
 		"id":          server.Id,
 		"clusterId":   clusterId,
@@ -64,6 +75,7 @@ func (this *IndexAction) RunGet(params struct {
 		"name":        server.Name,
 		"description": server.Description,
 		"isOn":        server.IsOn,
+		"groups":      groupMaps,
 	}
 
 	serverType := serverconfigs.FindServerType(server.Type)
@@ -84,6 +96,7 @@ func (this *IndexAction) RunPost(params struct {
 	Name        string
 	Description string
 	ClusterId   int64
+	GroupIds    []int64
 	IsOn        bool
 
 	Must *actions.Must
@@ -102,6 +115,7 @@ func (this *IndexAction) RunPost(params struct {
 		Description: params.Description,
 		ClusterId:   params.ClusterId,
 		IsOn:        params.IsOn,
+		GroupIds:    params.GroupIds,
 	})
 	if err != nil {
 		this.ErrorPage(err)

web/public/js/components/node/node-group-selector.js

@@ -1,20 +1,8 @@
 Vue.component("node-group-selector", {
 	props: ["v-cluster-id", "v-group"],
-	mounted: function () {
-		let that = this
-		Tea.action("/clusters/cluster/groups/options")
-			.post()
-			.params({
-				clusterId: this.vClusterId
-			})
-			.success(function (resp) {
-
-			})
-	},
 	data: function () {
 		return {
-			groups: [],
-			selectedGroup: this.vGroup,
+			selectedGroup: this.vGroup
 		}
 	},
 	methods: {

web/public/js/components/server/server-group-selector.js

@@ -0,0 +1,53 @@
+Vue.component("server-group-selector", {
+	props: ["v-groups"],
+	data: function () {
+		let groups = this.vGroups
+		if (groups == null) {
+			groups = []
+		}
+		return {
+			groups: groups
+		}
+	},
+	methods: {
+		selectGroup: function () {
+			let that = this
+			let groupIds = this.groups.map(function (v) {
+				return v.id.toString()
+			}).join(",")
+			teaweb.popup("/servers/components/groups/selectPopup?selectedGroupIds=" + groupIds, {
+				callback: function (resp) {
+					that.groups.push(resp.data.group)
+				}
+			})
+		},
+		addGroup: function () {
+			let that = this
+			teaweb.popup("/servers/components/groups/createPopup", {
+				callback: function (resp) {
+					that.groups.push(resp.data.group)
+				}
+			})
+		},
+		removeGroup: function (index) {
+			this.groups.$remove(index)
+		},
+		groupIds: function () {
+			return this.groups.map(function (v) {
+				return v.id
+			})
+		}
+	},
+	template: `<div>
+	<div v-if="groups.length > 0">
+		<div class="ui label tiny" v-if="groups.length > 0" v-for="(group, index) in groups">
+			<input type="hidden" name="groupIds" :value="group.id"/>
+			{{group.name}} &nbsp;<a href="" title="删除" @click.prevent="removeGroup(index)"><i class="icon remove"></i></a>
+		</div>
+		<div class="ui divider"></div>
+	</div>
+	<div>
+		<a href="" @click.prevent="selectGroup()">[选择分组]</a> &nbsp; <a href="" @click.prevent="addGroup()">[添加分组]</a>
+	</div>
+</div>`
+})

web/views/@default/servers/create.html

@@ -82,6 +82,13 @@
 			</td>
 		</tr>
 
+		<tr>
+			<td>选择分组</td>
+			<td>
+				<server-group-selector></server-group-selector>
+			</td>
+		</tr>
+
 		<tr>
 			<td colspan="2"><more-options-indicator></more-options-indicator></td>
 		</tr>

web/views/@default/servers/index.html

@@ -7,6 +7,7 @@
 	<thead>
 		<tr>
 			<th>服务名称</th>
+			<th>所属分组</th>
 			<th>服务类型</th>
 			<th>部署集群</th>
 			<th>端口</th>
@@ -16,6 +17,14 @@
 	</thead>
 	<tr v-for="server in servers">
 		<td>{{server.name}}</td>
+		<td>
+			<div v-if="server.groups.length > 0">
+				<div  v-for="group in server.groups">
+					<span class="ui label tiny" style="margin-bottom:0.5em">{{group.name}}</span>
+				</div>
+			</div>
+			<span class="disabled" v-else>-</span>
+		</td>
 		<td>{{server.serverTypeName}}</td>
 		<td>{{server.cluster.name}}</td>
 		<td>

web/views/@default/servers/server/settings/index.html

@@ -26,6 +26,12 @@
 					{{typeName}}
 				</td>
 			</tr>
+			<tr>
+				<td>选择分组</td>
+				<td>
+					<server-group-selector :v-groups="server.groups"></server-group-selector>
+				</td>
+			</tr>
 			<tr>
 				<td colspan="2"><more-options-indicator></more-options-indicator></td>
 			</tr>