dissolve group api

Author: yuwnloyblog

admins/apis/group.go

@@ -8,6 +8,7 @@ import (
 	"github.com/juggleim/commons/errs"
 	"github.com/juggleim/commons/responses"
 	"github.com/juggleim/commons/tools"
+	"github.com/juggleim/jugglechat-server/admins/apis/models"
 	"github.com/juggleim/jugglechat-server/admins/services"
 )
 
@@ -44,3 +45,17 @@ func QryGroups(ctx *gin.Context) {
 	}
 	responses.AdminSuccessHttpResp(ctx, grps)
 }
+
+func DissolveGroup(ctx *gin.Context) {
+	var req models.GroupIds
+	if err := ctx.ShouldBindJSON(&req); err != nil || req.AppKey == "" {
+		responses.AdminErrorHttpResp(ctx, errs.AdminErrorCode_ParamError)
+		return
+	}
+	code := services.DissolveGroups(ctxs.ToCtx(ctx), &req)
+	if code != errs.AdminErrorCode_Success {
+		responses.AdminErrorHttpResp(ctx, code)
+		return
+	}
+	responses.AdminSuccessHttpResp(ctx, nil)
+}

admins/apis/models/group.go

@@ -14,3 +14,8 @@ type Groups struct {
 	Items  []*Group `json:"items"`
 	Offset string   `json:"offset,omitempty"`
 }
+
+type GroupIds struct {
+	AppKey   string   `json:"app_key"`
+	GroupIds []string `json:"group_ids`
+}

admins/routers/router.go

@@ -201,6 +201,7 @@ func Route(group *gin.RouterGroup) *gin.RouterGroup {
 
 	//groups
 	group.GET("/apps/groups/list", apis.QryGroups)
+	group.POST("/apps/groups/dissolve", apis.DissolveGroup)
 
 	//convers
 	group.GET("/apps/convers/list", apis.QryConversations)

admins/services/groupservice.go

@@ -4,6 +4,7 @@ import (
 	"context"
 
 	"github.com/juggleim/commons/errs"
+	"github.com/juggleim/commons/imsdk"
 	"github.com/juggleim/commons/tools"
 	apimodels "github.com/juggleim/jugglechat-server/admins/apis/models"
 	"github.com/juggleim/jugglechat-server/storages"
@@ -65,3 +66,18 @@ func QryGroupInfo(appkey, groupId string) *apimodels.Group {
 		GroupPortrait: grp.GroupPortrait,
 	}
 }
+
+func DissolveGroups(ctx context.Context, req *apimodels.GroupIds) errs.AdminErrorCode {
+	appkey := req.AppKey
+	sdk := imsdk.GetImSdk(appkey)
+	storage := storages.NewGroupStorage()
+	memberStorage := storages.NewGroupMemberStorage()
+	for _, groupId := range req.GroupIds {
+		storage.Delete(appkey, groupId)
+		memberStorage.DeleteByGroupId(appkey, groupId)
+		if sdk != nil {
+			sdk.DissolveGroup(groupId)
+		}
+	}
+	return errs.AdminErrorCode_Success
+}