协议文件提交

Makefile

@@ -2,7 +2,7 @@ SHELL=cmd
 .PHONY: all
 all:  fmt tidy lint
 genRpc:
-	cd rpc/messagecenter && goctl rpc protoc messageCenter.proto --go_out=./ --go-grpc_out=./ --zrpc_out=.
+	cd rpc/messagecenter && goctl rpc protoc messagecenter.proto --go_out=./ --go-grpc_out=./ --zrpc_out=.
 	@echo "===========> genRpc finish"
 
 genApi:

api/messagecenter/internal/handler/chatgroupaddhandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func chatGroupAddHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.ChatGroupAddReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewChatGroupAddLogic(r.Context(), svcCtx)
+		resp, err := l.ChatGroupAdd(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/chatgroupjoinhandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func chatGroupJoinHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.ChatGroupJoinReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewChatGroupJoinLogic(r.Context(), svcCtx)
+		resp, err := l.ChatGroupJoin(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/chatgrouplisthandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func chatGroupListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.ChatGroupListReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewChatGroupListLogic(r.Context(), svcCtx)
+		resp, err := l.ChatGroupList(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/chatgrouppersonhandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func chatGroupPersonHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.ChatGroupPersonReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewChatGroupPersonLogic(r.Context(), svcCtx)
+		resp, err := l.ChatGroupPerson(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/groupnameupdatehandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func groupNameUpdateHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.GroupNameUpdateReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewGroupNameUpdateLogic(r.Context(), svcCtx)
+		resp, err := l.GroupNameUpdate(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/groupnoticeaddhandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func groupNoticeAddHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.GroupNoticeAddReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewGroupNoticeAddLogic(r.Context(), svcCtx)
+		resp, err := l.GroupNoticeAdd(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/groupnoticegethandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func groupNoticeGetHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.ChatGroupPersonReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewGroupNoticeGetLogic(r.Context(), svcCtx)
+		resp, err := l.GroupNoticeGet(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/groupnoticeupdatehandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/logic"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func groupNoticeUpdateHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.GroupNameUpdateReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewGroupNoticeUpdateLogic(r.Context(), svcCtx)
+		resp, err := l.GroupNoticeUpdate(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/routes.go

@@ -52,6 +52,46 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
 				Path:    "/message/updateReadById",
 				Handler: updateReadByIdHandler(serverCtx),
 			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/chatGroupList",
+				Handler: chatGroupListHandler(serverCtx),
+			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/chatGroupAdd",
+				Handler: chatGroupAddHandler(serverCtx),
+			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/chatGroupPerson",
+				Handler: chatGroupPersonHandler(serverCtx),
+			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/chatGroupJoin",
+				Handler: chatGroupJoinHandler(serverCtx),
+			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/groupNameUpdate",
+				Handler: groupNameUpdateHandler(serverCtx),
+			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/groupNoticeAdd",
+				Handler: groupNoticeAddHandler(serverCtx),
+			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/groupNoticeUpdate",
+				Handler: groupNoticeUpdateHandler(serverCtx),
+			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/message/groupNoticeGet",
+				Handler: groupNoticeGetHandler(serverCtx),
+			},
 		},
 	)
 }

api/messagecenter/internal/logic/chatgroupaddlogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupAddLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewChatGroupAddLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupAddLogic {
+	return &ChatGroupAddLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *ChatGroupAddLogic) ChatGroupAdd(req *types.ChatGroupAddReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/logic/chatgroupjoinlogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupJoinLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewChatGroupJoinLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupJoinLogic {
+	return &ChatGroupJoinLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *ChatGroupJoinLogic) ChatGroupJoin(req *types.ChatGroupJoinReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/logic/chatgrouplistlogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupListLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewChatGroupListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupListLogic {
+	return &ChatGroupListLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *ChatGroupListLogic) ChatGroupList(req *types.ChatGroupListReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/logic/chatgrouppersonlogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupPersonLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewChatGroupPersonLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupPersonLogic {
+	return &ChatGroupPersonLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *ChatGroupPersonLogic) ChatGroupPerson(req *types.ChatGroupPersonReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/logic/groupnameupdatelogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNameUpdateLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGroupNameUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNameUpdateLogic {
+	return &GroupNameUpdateLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *GroupNameUpdateLogic) GroupNameUpdate(req *types.GroupNameUpdateReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/logic/groupnoticeaddlogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNoticeAddLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGroupNoticeAddLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNoticeAddLogic {
+	return &GroupNoticeAddLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *GroupNoticeAddLogic) GroupNoticeAdd(req *types.GroupNoticeAddReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/logic/groupnoticegetlogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNoticeGetLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGroupNoticeGetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNoticeGetLogic {
+	return &GroupNoticeGetLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *GroupNoticeGetLogic) GroupNoticeGet(req *types.ChatGroupPersonReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/logic/groupnoticeupdatelogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNoticeUpdateLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGroupNoticeUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNoticeUpdateLogic {
+	return &GroupNoticeUpdateLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *GroupNoticeUpdateLogic) GroupNoticeUpdate(req *types.GroupNameUpdateReq) (resp *types.CommonRes, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/types/types.go

@@ -82,3 +82,42 @@ type ReadStateReq struct {
 	EntUserId int64  `header:"entUserId,optional"`
 	NewUserId int64  `header:"newUserId"`
 }
+
+type ChatGroupListReq struct {
+	EntId      int64  `header:"entId,optional"`
+	UserName   string `json:"userName"`
+	GroupName  string `json:"groupName"`
+	PositionId string `header:"positionId,optional"`
+}
+
+type ChatGroupAddReq struct {
+	EntId      int64    `header:"entId,optional"`
+	PositionId int64    `header:"positionId,optional"`
+	UserIdArr  []string `json:"userIdArr"`
+}
+
+type ChatGroupPersonReq struct {
+	ChatGroupId string `json:"chatGroupId"`
+	EntId       int64  `header:"entId,optional"`
+}
+
+type ChatGroupJoinReq struct {
+	ChatGroupId string `json:"chatGroupId"`
+	PositionId  string `json:"positionId"`
+}
+
+type GroupNameUpdateReq struct {
+	ChatGroupId string `json:"chatGroupId"`
+	PositionId  string `header:"positionId,optional"`
+	GroupName   string `json:"groupName"`
+}
+
+type GroupNoticeAddReq struct {
+	ChatGroupId string `json:"chatGroupId"`
+	Content     string `json:"content"`
+}
+
+type GroupNoticeUpdateReq struct {
+	Content       string `json:"content"`
+	GroupNoticeId string `json:"groupNoticeId"`
+}

api/messagecenter/messagecenter.api

@@ -1,3 +1,4 @@
+syntax = "v1"
 type CountReq {
 	UserType  int64 `json:"userType"`
 	NewUserId int64 `header:"newUserId,optional"`
@@ -72,6 +73,38 @@ type ReadStateReq {
 	EntUserId int64  `header:"entUserId,optional"`
 	NewUserId int64  `header:"newUserId"`
 }
+type ChatGroupListReq {
+	EntId      int64  `header:"entId,optional"`
+	UserName   string `json:"userName"`
+	GroupName  string `json:"groupName"`
+	PositionId string `header:"positionId,optional"`
+}
+type ChatGroupAddReq {
+	EntId      int64    `header:"entId,optional"`
+	PositionId int64    `header:"positionId,optional"`
+	UserIdArr  []string `json:"userIdArr"`
+}
+type ChatGroupPersonReq {
+	ChatGroupId string `json:"chatGroupId"`
+	EntId       int64  `header:"entId,optional"`
+}
+type ChatGroupJoinReq {
+	ChatGroupId string `json:"chatGroupId"`
+	PositionId  string `json:"positionId"`
+}
+type GroupNameUpdateReq {
+	ChatGroupId string `json:"chatGroupId"`
+	PositionId  string `header:"positionId,optional"`
+	GroupName   string `json:"groupName"`
+}
+type GroupNoticeAddReq {
+	ChatGroupId string `json:"chatGroupId"`
+	Content     string `json:"content"`
+}
+type GroupNoticeUpdateReq {
+	Content       string `json:"content"`
+	GroupNoticeId string `json:"groupNoticeId"`
+}
 service messagecenter-api {
 	@handler messageCount
 	post /message/messageCount (CountReq) returns (CommonRes);
@@ -89,4 +122,20 @@ service messagecenter-api {
 	post /message/obtainShunt (ShuntReq) returns (CommonRes);
 	@handler updateReadById
 	post /message/updateReadById (ReadStateReq) returns (CommonRes);
+	@handler chatGroupList
+	post /message/chatGroupList (ChatGroupListReq) returns (CommonRes);
+	@handler chatGroupAdd
+	post /message/chatGroupAdd (ChatGroupAddReq) returns (CommonRes);
+	@handler chatGroupPerson
+	post /message/chatGroupPerson (ChatGroupPersonReq) returns (CommonRes);
+	@handler chatGroupJoin
+	post /message/chatGroupJoin (ChatGroupJoinReq) returns (CommonRes);
+	@handler groupNameUpdate
+	post /message/groupNameUpdate (GroupNameUpdateReq) returns (CommonRes);
+	@handler groupNoticeAdd
+	post /message/groupNoticeAdd (GroupNoticeAddReq) returns (CommonRes);
+	@handler groupNoticeUpdate
+	post /message/groupNoticeUpdate (GroupNoticeUpdateReq) returns (CommonRes);
+	@handler groupNoticeGet
+	post /message/groupNoticeGet (ChatGroupPersonReq) returns (CommonRes);
 }

rpc/messagecenter/internal/logic/chatgroupaddlogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupAddLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewChatGroupAddLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupAddLogic {
+	return &ChatGroupAddLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 群组新增
+func (l *ChatGroupAddLogic) ChatGroupAdd(in *messagecenter.ChatGroupAddReq) (*messagecenter.CommonReq, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.CommonReq{}, nil
+}

rpc/messagecenter/internal/logic/chatgroupjoinlogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupJoinLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewChatGroupJoinLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupJoinLogic {
+	return &ChatGroupJoinLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 加入群组
+func (l *ChatGroupJoinLogic) ChatGroupJoin(in *messagecenter.ChatGroupJoinReq) (*messagecenter.CommonReq, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.CommonReq{}, nil
+}

rpc/messagecenter/internal/logic/chatgrouplistlogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupListLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewChatGroupListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupListLogic {
+	return &ChatGroupListLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 群组列表查询
+func (l *ChatGroupListLogic) ChatGroupList(in *messagecenter.ChatGroupListReq) (*messagecenter.ChatGroupListResp, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.ChatGroupListResp{}, nil
+}

rpc/messagecenter/internal/logic/chatgrouppersonlogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type ChatGroupPersonLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewChatGroupPersonLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ChatGroupPersonLogic {
+	return &ChatGroupPersonLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 群组成员查询
+func (l *ChatGroupPersonLogic) ChatGroupPerson(in *messagecenter.ChatGroupPersonReq) (*messagecenter.ChatGroupPersonResp, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.ChatGroupPersonResp{}, nil
+}

rpc/messagecenter/internal/logic/groupnameupdatelogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNameUpdateLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGroupNameUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNameUpdateLogic {
+	return &GroupNameUpdateLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 群组名称修改
+func (l *GroupNameUpdateLogic) GroupNameUpdate(in *messagecenter.GroupNameUpdateReq) (*messagecenter.CommonReq, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.CommonReq{}, nil
+}

rpc/messagecenter/internal/logic/groupnoticeaddlogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNoticeAddLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGroupNoticeAddLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNoticeAddLogic {
+	return &GroupNoticeAddLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 群任务新增
+func (l *GroupNoticeAddLogic) GroupNoticeAdd(in *messagecenter.GroupNoticeAddReq) (*messagecenter.CommonReq, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.CommonReq{}, nil
+}

rpc/messagecenter/internal/logic/groupnoticegetlogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNoticeGetLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGroupNoticeGetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNoticeGetLogic {
+	return &GroupNoticeGetLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 群任务编辑
+func (l *GroupNoticeGetLogic) GroupNoticeGet(in *messagecenter.ChatGroupPersonReq) (*messagecenter.CommonReq, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.CommonReq{}, nil
+}

rpc/messagecenter/internal/logic/groupnoticeupdatelogic.go

@@ -0,0 +1,31 @@
+package logic
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc"
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GroupNoticeUpdateLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGroupNoticeUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupNoticeUpdateLogic {
+	return &GroupNoticeUpdateLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// 群任务编辑
+func (l *GroupNoticeUpdateLogic) GroupNoticeUpdate(in *messagecenter.GroupNoticeUpdateReq) (*messagecenter.CommonReq, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.CommonReq{}, nil
+}

rpc/messagecenter/internal/server/messagecenterserver.go

@@ -1,5 +1,5 @@
-// Code generated by goctl. DO NOT EDIT!
-// Source: messageCenter.proto
+// Code generated by goctl. DO NOT EDIT.
+// Source: messagecenter.proto
 
 package server
 
@@ -22,37 +22,37 @@ func NewMessageCenterServer(svcCtx *svc.ServiceContext) *MessageCenterServer {
 	}
 }
 
-//  查询数量
+// 查询数量
 func (s *MessageCenterServer) Count(ctx context.Context, in *messagecenter.CountReq) (*messagecenter.CountResp, error) {
 	l := logic.NewCountLogic(ctx, s.svcCtx)
 	return l.Count(in)
 }
 
-//  用户列表查询
+// 用户列表查询
 func (s *MessageCenterServer) UserList(ctx context.Context, in *messagecenter.UserReq) (*messagecenter.UserResp, error) {
 	l := logic.NewUserListLogic(ctx, s.svcCtx)
 	return l.UserList(in)
 }
 
-//  聊天内容查询
+// 聊天内容查询
 func (s *MessageCenterServer) FindMessage(ctx context.Context, in *messagecenter.MessageReq) (*messagecenter.MessageResp, error) {
 	l := logic.NewFindMessageLogic(ctx, s.svcCtx)
 	return l.FindMessage(in)
 }
 
-//  聊天保存
+// 聊天保存
 func (s *MessageCenterServer) SaveMessage(ctx context.Context, in *messagecenter.MessageEntity) (*messagecenter.SaveMessageResp, error) {
 	l := logic.NewSaveMessageLogic(ctx, s.svcCtx)
 	return l.SaveMessage(in)
 }
 
-//  会话创建
+// 会话创建
 func (s *MessageCenterServer) CreateChatSession(ctx context.Context, in *messagecenter.ChatSessionReq) (*messagecenter.ChatSessionResp, error) {
 	l := logic.NewCreateChatSessionLogic(ctx, s.svcCtx)
 	return l.CreateChatSession(in)
 }
 
-//  会话关闭
+// 会话关闭
 func (s *MessageCenterServer) CloseChatSession(ctx context.Context, in *messagecenter.CloseSessionReq) (*messagecenter.ChatSessionResp, error) {
 	l := logic.NewCloseChatSessionLogic(ctx, s.svcCtx)
 	return l.CloseChatSession(in)
@@ -69,3 +69,51 @@ func (s *MessageCenterServer) UpdateReadById(ctx context.Context, in *messagecen
 	l := logic.NewUpdateReadByIdLogic(ctx, s.svcCtx)
 	return l.UpdateReadById(in)
 }
+
+// 群组列表查询
+func (s *MessageCenterServer) ChatGroupList(ctx context.Context, in *messagecenter.ChatGroupListReq) (*messagecenter.ChatGroupListResp, error) {
+	l := logic.NewChatGroupListLogic(ctx, s.svcCtx)
+	return l.ChatGroupList(in)
+}
+
+// 群组新增
+func (s *MessageCenterServer) ChatGroupAdd(ctx context.Context, in *messagecenter.ChatGroupAddReq) (*messagecenter.CommonReq, error) {
+	l := logic.NewChatGroupAddLogic(ctx, s.svcCtx)
+	return l.ChatGroupAdd(in)
+}
+
+// 群组成员查询
+func (s *MessageCenterServer) ChatGroupPerson(ctx context.Context, in *messagecenter.ChatGroupPersonReq) (*messagecenter.ChatGroupPersonResp, error) {
+	l := logic.NewChatGroupPersonLogic(ctx, s.svcCtx)
+	return l.ChatGroupPerson(in)
+}
+
+// 加入群组
+func (s *MessageCenterServer) ChatGroupJoin(ctx context.Context, in *messagecenter.ChatGroupJoinReq) (*messagecenter.CommonReq, error) {
+	l := logic.NewChatGroupJoinLogic(ctx, s.svcCtx)
+	return l.ChatGroupJoin(in)
+}
+
+// 群组名称修改
+func (s *MessageCenterServer) GroupNameUpdate(ctx context.Context, in *messagecenter.GroupNameUpdateReq) (*messagecenter.CommonReq, error) {
+	l := logic.NewGroupNameUpdateLogic(ctx, s.svcCtx)
+	return l.GroupNameUpdate(in)
+}
+
+// 群任务新增
+func (s *MessageCenterServer) GroupNoticeAdd(ctx context.Context, in *messagecenter.GroupNoticeAddReq) (*messagecenter.CommonReq, error) {
+	l := logic.NewGroupNoticeAddLogic(ctx, s.svcCtx)
+	return l.GroupNoticeAdd(in)
+}
+
+// 群任务编辑
+func (s *MessageCenterServer) GroupNoticeUpdate(ctx context.Context, in *messagecenter.GroupNoticeUpdateReq) (*messagecenter.CommonReq, error) {
+	l := logic.NewGroupNoticeUpdateLogic(ctx, s.svcCtx)
+	return l.GroupNoticeUpdate(in)
+}
+
+// 群任务编辑
+func (s *MessageCenterServer) GroupNoticeGet(ctx context.Context, in *messagecenter.ChatGroupPersonReq) (*messagecenter.CommonReq, error) {
+	l := logic.NewGroupNoticeGetLogic(ctx, s.svcCtx)
+	return l.GroupNoticeGet(in)
+}

rpc/messagecenter/messagecenter.proto

@@ -1,16 +1,16 @@
 syntax = "proto3";
 
 package messagecenter;
-option go_package="./messagecenter";
+option go_package = "./messagecenter";
 
 message CountReq {
-  int64     userType=2;      //用户类型:2用户1客服
+  int64     userType = 2;      //用户类型:2用户1客服
   int64     newUserId = 1;      // 用户id
   int64     entUserId = 3;      // 客服id
 }
 message CountResp {
   int64 count = 1;
-  MessageEntity lastMessage= 4;
+  MessageEntity lastMessage = 4;
   int64 error_code = 2; //响应代码
   string error_msg = 3; //响应消息
 }
@@ -19,47 +19,47 @@ message UserReq {
   string    startTime = 2;
   string    endTime = 3;
   int64     newUserId = 4;  //用户标识
-  int64     userType=5;  //用户类型:2用户1客服
+  int64     userType = 5;  //用户类型:2用户1客服
   int64     entUserId = 6;  //企业标识
 }
 message UserResp {
-   repeated UserEntity data=1;
-   int64 error_code = 2; //响应代码
-   string error_msg = 3; //响应消息
+  repeated UserEntity data = 1;
+  int64 error_code = 2; //响应代码
+  string error_msg = 3; //响应消息
 }
 message UserEntity {
   string userId = 1;
-  string name= 2;
+  string name = 2;
   string title = 3;
-  int64 type= 4;
+  int64 type = 4;
   string link = 5;
-  string content= 6;
+  string content = 6;
   int64 userType = 7;
-  int64 create_time= 8;
-  int64 number= 9;
-  string headimg=11;
+  int64 create_time = 8;
+  int64 number = 9;
+  string headimg = 11;
 }
 message MessageReq {
   int64         msgType = 1;     // 消息类型 ；1：站内信消息 2：点对点消息 3：群消息 4：机器人消息 5：客服消息
-  int64         userType=6;      //用户类型:2用户1客服
+  int64         userType = 6;      //用户类型:2用户1客服
   int64         LastId = 2;
   int64         pageSize = 3;
   int64         sendId = 4;
   int64         newUserId = 5;
-  int64         entUserId=7;
-  int64         entId=8;
-  int64         customerEntId=9;
-  string        sort=10;
+  int64         entUserId = 7;
+  int64         entId = 8;
+  int64         customerEntId = 9;
+  string        sort = 10;
 }
 message MessageResp {
   int64         count = 1;
-  repeated      MessageEntity data= 2;
+  repeated      MessageEntity data = 2;
   int64         error_code = 4; //响应代码
   string        error_msg = 3; //响应消息
 }
 message SaveMessageResp {
   int64         count = 1;
-  MessageEntity data= 2;
+  MessageEntity data = 2;
   int64         error_code = 4; //响应代码
   string        error_msg = 3; //响应消息
 }
@@ -70,70 +70,141 @@ message MessageEntity {
   int64         type = 4;
   string        link = 5;
   int64         create_time = 6;
-  string        appid=7;
-  int64         itemType=8;
-  int64         sendId=9;
-  int64         entUserId=10;
-  int64         newUserId=16;
-  int64         own_type =11;//拥有者类型；1：用户 2：会话
-  int64         fool=12;
-  string        robotName=13;
-  string        robotImg=14;
-  string        setName=15;
-  int64         receiveId=17;
-  string        ownImg=18;
-  string        messageId=19;
+  string        appid = 7;
+  int64         itemType = 8;
+  int64         sendId = 9;
+  int64         entUserId = 10;
+  int64         newUserId = 16;
+  int64         own_type = 11;//拥有者类型；1：用户 2：会话
+  int64         fool = 12;
+  string        robotName = 13;
+  string        robotImg = 14;
+  string        setName = 15;
+  int64         receiveId = 17;
+  string        ownImg = 18;
+  string        messageId = 19;
 }
 
 message ChatSessionReq {
   int64         entId = 1;
-  int64         customerServiceId= 2;
+  int64         customerServiceId = 2;
   int64         userId = 3;
   string        appId = 4;
-  string        customerserviceName=5;
+  string        customerserviceName = 5;
 }
 message CloseSessionReq {
   int64         sessionId = 1;
 }
 message ChatSessionResp {
-   int64 error_code = 2; //响应代码
-   string error_msg = 1; //响应消息
-   string  sessionId=3;
+  int64 error_code = 2; //响应代码
+  string error_msg = 1; //响应消息
+  string  sessionId = 3;
 }
 message SaveAutoReplyReq {
   int64         entId = 1;
-  int64         entUserId= 2;
+  int64         entUserId = 2;
   int64         userId = 3;
   int64         userType = 4;
   string        content = 5;
   string        appId = 6;
-  string        nowFormat=7;
+  string        nowFormat = 7;
 }
 message ReadStateReq {
   int64         messageId = 1;
-  int64         entUserId=2;
-  int64         newUserId=3;
+  int64         entUserId = 2;
+  int64         newUserId = 3;
 }
 
 message CurrencyResp {
-   int64 error_code = 2; //响应代码
-   string error_msg = 1; //响应消息
+  int64 error_code = 2; //响应代码
+  string error_msg = 1; //响应消息
+}
+message ChatGroupListReq{
+  int64 entId = 1;
+  int64 userName = 2;
+  int64 groupName = 3;
+  int64 positionId = 4;
+}
+message ChatGroupListResp {
+  repeated      ChatGroupList data = 1;
+  int64         error_code = 2; //响应代码
+  string        error_msg = 3; //响应消息
+}
+message ChatGroupList {
+  string  GroupName = 1;
+  int64   PersonCount = 2;
+  string  ChatGroupId = 3;
+}
+message ChatGroupAddReq {
+  int64  entId = 1;
+  int64   positionId = 2;
+  repeated string userIdArr = 3;
+}
+message CommonReq {
+  bool          status = 1;
+  int64         error_code = 2; //响应代码
+  string        error_msg = 3; //响应消息
+}
+message ChatGroupPersonReq{
+  int64 ChatGroupId = 1;
+}
+message ChatGroupPersonResp{
+  repeated      ChatGroupPerson data = 1;
+  int64         error_code = 2; //响应代码
+  string        error_msg = 3; //响应消息
+}
+message ChatGroupPerson{
+  string   personName = 1;
+  bool     isSystem = 2;
+}
+message ChatGroupJoinReq{
+  int64 chatGroupId = 1;
+  int64 positionId = 2;
+}
+message GroupNameUpdateReq{
+  int64  chatGroupId = 1;
+  int64  positionId = 2;
+  string groupName = 3;
+}
+message GroupNoticeAddReq{
+  int64 chatGroupId = 1;
+  string content = 2;
+}
+message GroupNoticeUpdateReq{
+  int64 groupNoticeId = 1;
+  string content = 2;
 }
 service messageCenter {
   // 查询数量
-  rpc Count(CountReq) returns (CountResp);
+  rpc Count(CountReq) returns(CountResp);
   // 用户列表查询
   rpc UserList(UserReq) returns(UserResp);
   // 聊天内容查询
   rpc FindMessage(MessageReq) returns(MessageResp);
-   // 聊天保存
+  // 聊天保存
   rpc SaveMessage(MessageEntity) returns(SaveMessageResp);
   // 会话创建
   rpc CreateChatSession(ChatSessionReq) returns(ChatSessionResp);
   // 会话关闭
   rpc CloseChatSession(CloseSessionReq) returns(ChatSessionResp);
-   //创建会话并且保存信息
+  //创建会话并且保存信息
   rpc SaveAutoReplyMsg(SaveAutoReplyReq)returns(MessageResp);
-   //根据消息修改已读状态
+  //根据消息修改已读状态
   rpc UpdateReadById(ReadStateReq)returns(CurrencyResp);
+  //群组列表查询
+  rpc ChatGroupList(ChatGroupListReq)returns(ChatGroupListResp);
+  //群组新增
+  rpc ChatGroupAdd(ChatGroupAddReq)returns(CommonReq);
+  //群组成员查询
+  rpc ChatGroupPerson(ChatGroupPersonReq)returns(ChatGroupPersonResp);
+  //加入群组
+  rpc ChatGroupJoin(ChatGroupJoinReq)returns(CommonReq);
+  //群组名称修改
+  rpc GroupNameUpdate(GroupNameUpdateReq)returns(CommonReq);
+  //群任务新增
+  rpc GroupNoticeAdd(GroupNoticeAddReq)returns(CommonReq);
+  //群任务编辑
+  rpc GroupNoticeUpdate(GroupNoticeUpdateReq)returns(CommonReq);
+  //群任务编辑
+  rpc GroupNoticeGet(ChatGroupPersonReq)returns(CommonReq);
 }

rpc/messagecenter/messagecenter/messagecenter_grpc.pb.go

@@ -2,7 +2,7 @@
 // versions:
 // - protoc-gen-go-grpc v1.2.0
 // - protoc             v3.15.1
-// source: messageCenter.proto
+// source: messagecenter.proto
 
 package messagecenter
 
@@ -38,6 +38,22 @@ type MessageCenterClient interface {
 	SaveAutoReplyMsg(ctx context.Context, in *SaveAutoReplyReq, opts ...grpc.CallOption) (*MessageResp, error)
 	//根据消息修改已读状态
 	UpdateReadById(ctx context.Context, in *ReadStateReq, opts ...grpc.CallOption) (*CurrencyResp, error)
+	//群组列表查询
+	ChatGroupList(ctx context.Context, in *ChatGroupListReq, opts ...grpc.CallOption) (*ChatGroupListResp, error)
+	//群组新增
+	ChatGroupAdd(ctx context.Context, in *ChatGroupAddReq, opts ...grpc.CallOption) (*CommonReq, error)
+	//群组成员查询
+	ChatGroupPerson(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*ChatGroupPersonResp, error)
+	//加入群组
+	ChatGroupJoin(ctx context.Context, in *ChatGroupJoinReq, opts ...grpc.CallOption) (*CommonReq, error)
+	//群组名称修改
+	GroupNameUpdate(ctx context.Context, in *GroupNameUpdateReq, opts ...grpc.CallOption) (*CommonReq, error)
+	//群任务新增
+	GroupNoticeAdd(ctx context.Context, in *GroupNoticeAddReq, opts ...grpc.CallOption) (*CommonReq, error)
+	//群任务编辑
+	GroupNoticeUpdate(ctx context.Context, in *GroupNoticeUpdateReq, opts ...grpc.CallOption) (*CommonReq, error)
+	//群任务编辑
+	GroupNoticeGet(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*CommonReq, error)
 }
 
 type messageCenterClient struct {
@@ -120,6 +136,78 @@ func (c *messageCenterClient) UpdateReadById(ctx context.Context, in *ReadStateR
 	return out, nil
 }
 
+func (c *messageCenterClient) ChatGroupList(ctx context.Context, in *ChatGroupListReq, opts ...grpc.CallOption) (*ChatGroupListResp, error) {
+	out := new(ChatGroupListResp)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/ChatGroupList", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *messageCenterClient) ChatGroupAdd(ctx context.Context, in *ChatGroupAddReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	out := new(CommonReq)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/ChatGroupAdd", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *messageCenterClient) ChatGroupPerson(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*ChatGroupPersonResp, error) {
+	out := new(ChatGroupPersonResp)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/ChatGroupPerson", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *messageCenterClient) ChatGroupJoin(ctx context.Context, in *ChatGroupJoinReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	out := new(CommonReq)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/ChatGroupJoin", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *messageCenterClient) GroupNameUpdate(ctx context.Context, in *GroupNameUpdateReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	out := new(CommonReq)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/GroupNameUpdate", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *messageCenterClient) GroupNoticeAdd(ctx context.Context, in *GroupNoticeAddReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	out := new(CommonReq)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/GroupNoticeAdd", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *messageCenterClient) GroupNoticeUpdate(ctx context.Context, in *GroupNoticeUpdateReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	out := new(CommonReq)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/GroupNoticeUpdate", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *messageCenterClient) GroupNoticeGet(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	out := new(CommonReq)
+	err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/GroupNoticeGet", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 // MessageCenterServer is the server API for MessageCenter service.
 // All implementations must embed UnimplementedMessageCenterServer
 // for forward compatibility
@@ -140,6 +228,22 @@ type MessageCenterServer interface {
 	SaveAutoReplyMsg(context.Context, *SaveAutoReplyReq) (*MessageResp, error)
 	//根据消息修改已读状态
 	UpdateReadById(context.Context, *ReadStateReq) (*CurrencyResp, error)
+	//群组列表查询
+	ChatGroupList(context.Context, *ChatGroupListReq) (*ChatGroupListResp, error)
+	//群组新增
+	ChatGroupAdd(context.Context, *ChatGroupAddReq) (*CommonReq, error)
+	//群组成员查询
+	ChatGroupPerson(context.Context, *ChatGroupPersonReq) (*ChatGroupPersonResp, error)
+	//加入群组
+	ChatGroupJoin(context.Context, *ChatGroupJoinReq) (*CommonReq, error)
+	//群组名称修改
+	GroupNameUpdate(context.Context, *GroupNameUpdateReq) (*CommonReq, error)
+	//群任务新增
+	GroupNoticeAdd(context.Context, *GroupNoticeAddReq) (*CommonReq, error)
+	//群任务编辑
+	GroupNoticeUpdate(context.Context, *GroupNoticeUpdateReq) (*CommonReq, error)
+	//群任务编辑
+	GroupNoticeGet(context.Context, *ChatGroupPersonReq) (*CommonReq, error)
 	mustEmbedUnimplementedMessageCenterServer()
 }
 
@@ -171,6 +275,30 @@ func (UnimplementedMessageCenterServer) SaveAutoReplyMsg(context.Context, *SaveA
 func (UnimplementedMessageCenterServer) UpdateReadById(context.Context, *ReadStateReq) (*CurrencyResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method UpdateReadById not implemented")
 }
+func (UnimplementedMessageCenterServer) ChatGroupList(context.Context, *ChatGroupListReq) (*ChatGroupListResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method ChatGroupList not implemented")
+}
+func (UnimplementedMessageCenterServer) ChatGroupAdd(context.Context, *ChatGroupAddReq) (*CommonReq, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method ChatGroupAdd not implemented")
+}
+func (UnimplementedMessageCenterServer) ChatGroupPerson(context.Context, *ChatGroupPersonReq) (*ChatGroupPersonResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method ChatGroupPerson not implemented")
+}
+func (UnimplementedMessageCenterServer) ChatGroupJoin(context.Context, *ChatGroupJoinReq) (*CommonReq, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method ChatGroupJoin not implemented")
+}
+func (UnimplementedMessageCenterServer) GroupNameUpdate(context.Context, *GroupNameUpdateReq) (*CommonReq, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GroupNameUpdate not implemented")
+}
+func (UnimplementedMessageCenterServer) GroupNoticeAdd(context.Context, *GroupNoticeAddReq) (*CommonReq, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GroupNoticeAdd not implemented")
+}
+func (UnimplementedMessageCenterServer) GroupNoticeUpdate(context.Context, *GroupNoticeUpdateReq) (*CommonReq, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GroupNoticeUpdate not implemented")
+}
+func (UnimplementedMessageCenterServer) GroupNoticeGet(context.Context, *ChatGroupPersonReq) (*CommonReq, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GroupNoticeGet not implemented")
+}
 func (UnimplementedMessageCenterServer) mustEmbedUnimplementedMessageCenterServer() {}
 
 // UnsafeMessageCenterServer may be embedded to opt out of forward compatibility for this service.
@@ -328,6 +456,150 @@ func _MessageCenter_UpdateReadById_Handler(srv interface{}, ctx context.Context,
 	return interceptor(ctx, in, info, handler)
 }
 
+func _MessageCenter_ChatGroupList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(ChatGroupListReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).ChatGroupList(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/ChatGroupList",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).ChatGroupList(ctx, req.(*ChatGroupListReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _MessageCenter_ChatGroupAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(ChatGroupAddReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).ChatGroupAdd(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/ChatGroupAdd",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).ChatGroupAdd(ctx, req.(*ChatGroupAddReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _MessageCenter_ChatGroupPerson_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(ChatGroupPersonReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).ChatGroupPerson(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/ChatGroupPerson",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).ChatGroupPerson(ctx, req.(*ChatGroupPersonReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _MessageCenter_ChatGroupJoin_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(ChatGroupJoinReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).ChatGroupJoin(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/ChatGroupJoin",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).ChatGroupJoin(ctx, req.(*ChatGroupJoinReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _MessageCenter_GroupNameUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GroupNameUpdateReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).GroupNameUpdate(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/GroupNameUpdate",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).GroupNameUpdate(ctx, req.(*GroupNameUpdateReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _MessageCenter_GroupNoticeAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GroupNoticeAddReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).GroupNoticeAdd(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/GroupNoticeAdd",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).GroupNoticeAdd(ctx, req.(*GroupNoticeAddReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _MessageCenter_GroupNoticeUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GroupNoticeUpdateReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).GroupNoticeUpdate(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/GroupNoticeUpdate",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).GroupNoticeUpdate(ctx, req.(*GroupNoticeUpdateReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _MessageCenter_GroupNoticeGet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(ChatGroupPersonReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessageCenterServer).GroupNoticeGet(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.messageCenter/GroupNoticeGet",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessageCenterServer).GroupNoticeGet(ctx, req.(*ChatGroupPersonReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 // MessageCenter_ServiceDesc is the grpc.ServiceDesc for MessageCenter service.
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
@@ -367,7 +639,39 @@ var MessageCenter_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "UpdateReadById",
 			Handler:    _MessageCenter_UpdateReadById_Handler,
 		},
+		{
+			MethodName: "ChatGroupList",
+			Handler:    _MessageCenter_ChatGroupList_Handler,
+		},
+		{
+			MethodName: "ChatGroupAdd",
+			Handler:    _MessageCenter_ChatGroupAdd_Handler,
+		},
+		{
+			MethodName: "ChatGroupPerson",
+			Handler:    _MessageCenter_ChatGroupPerson_Handler,
+		},
+		{
+			MethodName: "ChatGroupJoin",
+			Handler:    _MessageCenter_ChatGroupJoin_Handler,
+		},
+		{
+			MethodName: "GroupNameUpdate",
+			Handler:    _MessageCenter_GroupNameUpdate_Handler,
+		},
+		{
+			MethodName: "GroupNoticeAdd",
+			Handler:    _MessageCenter_GroupNoticeAdd_Handler,
+		},
+		{
+			MethodName: "GroupNoticeUpdate",
+			Handler:    _MessageCenter_GroupNoticeUpdate_Handler,
+		},
+		{
+			MethodName: "GroupNoticeGet",
+			Handler:    _MessageCenter_GroupNoticeGet_Handler,
+		},
 	},
 	Streams:  []grpc.StreamDesc{},
-	Metadata: "messageCenter.proto",
+	Metadata: "messagecenter.proto",
 }

rpc/messagecenter/messagecenterclient/messagecenter.go

@@ -0,0 +1,184 @@
+// Code generated by goctl. DO NOT EDIT.
+// Source: messagecenter.proto
+
+package messagecenterclient
+
+import (
+	"context"
+
+	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/zrpc"
+	"google.golang.org/grpc"
+)
+
+type (
+	ChatGroupAddReq      = messagecenter.ChatGroupAddReq
+	ChatGroupJoinReq     = messagecenter.ChatGroupJoinReq
+	ChatGroupList        = messagecenter.ChatGroupList
+	ChatGroupListReq     = messagecenter.ChatGroupListReq
+	ChatGroupListResp    = messagecenter.ChatGroupListResp
+	ChatGroupPerson      = messagecenter.ChatGroupPerson
+	ChatGroupPersonReq   = messagecenter.ChatGroupPersonReq
+	ChatGroupPersonResp  = messagecenter.ChatGroupPersonResp
+	ChatSessionReq       = messagecenter.ChatSessionReq
+	ChatSessionResp      = messagecenter.ChatSessionResp
+	CloseSessionReq      = messagecenter.CloseSessionReq
+	CommonReq            = messagecenter.CommonReq
+	CountReq             = messagecenter.CountReq
+	CountResp            = messagecenter.CountResp
+	CurrencyResp         = messagecenter.CurrencyResp
+	GroupNameUpdateReq   = messagecenter.GroupNameUpdateReq
+	GroupNoticeAddReq    = messagecenter.GroupNoticeAddReq
+	GroupNoticeUpdateReq = messagecenter.GroupNoticeUpdateReq
+	MessageEntity        = messagecenter.MessageEntity
+	MessageReq           = messagecenter.MessageReq
+	MessageResp          = messagecenter.MessageResp
+	ReadStateReq         = messagecenter.ReadStateReq
+	SaveAutoReplyReq     = messagecenter.SaveAutoReplyReq
+	SaveMessageResp      = messagecenter.SaveMessageResp
+	UserEntity           = messagecenter.UserEntity
+	UserReq              = messagecenter.UserReq
+	UserResp             = messagecenter.UserResp
+
+	MessageCenter interface {
+		// 查询数量
+		Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error)
+		// 用户列表查询
+		UserList(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResp, error)
+		// 聊天内容查询
+		FindMessage(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*MessageResp, error)
+		// 聊天保存
+		SaveMessage(ctx context.Context, in *MessageEntity, opts ...grpc.CallOption) (*SaveMessageResp, error)
+		// 会话创建
+		CreateChatSession(ctx context.Context, in *ChatSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error)
+		// 会话关闭
+		CloseChatSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error)
+		// 创建会话并且保存信息
+		SaveAutoReplyMsg(ctx context.Context, in *SaveAutoReplyReq, opts ...grpc.CallOption) (*MessageResp, error)
+		// 根据消息修改已读状态
+		UpdateReadById(ctx context.Context, in *ReadStateReq, opts ...grpc.CallOption) (*CurrencyResp, error)
+		// 群组列表查询
+		ChatGroupList(ctx context.Context, in *ChatGroupListReq, opts ...grpc.CallOption) (*ChatGroupListResp, error)
+		// 群组新增
+		ChatGroupAdd(ctx context.Context, in *ChatGroupAddReq, opts ...grpc.CallOption) (*CommonReq, error)
+		// 群组成员查询
+		ChatGroupPerson(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*ChatGroupPersonResp, error)
+		// 加入群组
+		ChatGroupJoin(ctx context.Context, in *ChatGroupJoinReq, opts ...grpc.CallOption) (*CommonReq, error)
+		// 群组名称修改
+		GroupNameUpdate(ctx context.Context, in *GroupNameUpdateReq, opts ...grpc.CallOption) (*CommonReq, error)
+		// 群任务新增
+		GroupNoticeAdd(ctx context.Context, in *GroupNoticeAddReq, opts ...grpc.CallOption) (*CommonReq, error)
+		// 群任务编辑
+		GroupNoticeUpdate(ctx context.Context, in *GroupNoticeUpdateReq, opts ...grpc.CallOption) (*CommonReq, error)
+		// 群任务编辑
+		GroupNoticeGet(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*CommonReq, error)
+	}
+
+	defaultMessageCenter struct {
+		cli zrpc.Client
+	}
+)
+
+func NewMessageCenter(cli zrpc.Client) MessageCenter {
+	return &defaultMessageCenter{
+		cli: cli,
+	}
+}
+
+// 查询数量
+func (m *defaultMessageCenter) Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.Count(ctx, in, opts...)
+}
+
+// 用户列表查询
+func (m *defaultMessageCenter) UserList(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.UserList(ctx, in, opts...)
+}
+
+// 聊天内容查询
+func (m *defaultMessageCenter) FindMessage(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*MessageResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.FindMessage(ctx, in, opts...)
+}
+
+// 聊天保存
+func (m *defaultMessageCenter) SaveMessage(ctx context.Context, in *MessageEntity, opts ...grpc.CallOption) (*SaveMessageResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.SaveMessage(ctx, in, opts...)
+}
+
+// 会话创建
+func (m *defaultMessageCenter) CreateChatSession(ctx context.Context, in *ChatSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.CreateChatSession(ctx, in, opts...)
+}
+
+// 会话关闭
+func (m *defaultMessageCenter) CloseChatSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.CloseChatSession(ctx, in, opts...)
+}
+
+// 创建会话并且保存信息
+func (m *defaultMessageCenter) SaveAutoReplyMsg(ctx context.Context, in *SaveAutoReplyReq, opts ...grpc.CallOption) (*MessageResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.SaveAutoReplyMsg(ctx, in, opts...)
+}
+
+// 根据消息修改已读状态
+func (m *defaultMessageCenter) UpdateReadById(ctx context.Context, in *ReadStateReq, opts ...grpc.CallOption) (*CurrencyResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.UpdateReadById(ctx, in, opts...)
+}
+
+// 群组列表查询
+func (m *defaultMessageCenter) ChatGroupList(ctx context.Context, in *ChatGroupListReq, opts ...grpc.CallOption) (*ChatGroupListResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.ChatGroupList(ctx, in, opts...)
+}
+
+// 群组新增
+func (m *defaultMessageCenter) ChatGroupAdd(ctx context.Context, in *ChatGroupAddReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.ChatGroupAdd(ctx, in, opts...)
+}
+
+// 群组成员查询
+func (m *defaultMessageCenter) ChatGroupPerson(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*ChatGroupPersonResp, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.ChatGroupPerson(ctx, in, opts...)
+}
+
+// 加入群组
+func (m *defaultMessageCenter) ChatGroupJoin(ctx context.Context, in *ChatGroupJoinReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.ChatGroupJoin(ctx, in, opts...)
+}
+
+// 群组名称修改
+func (m *defaultMessageCenter) GroupNameUpdate(ctx context.Context, in *GroupNameUpdateReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.GroupNameUpdate(ctx, in, opts...)
+}
+
+// 群任务新增
+func (m *defaultMessageCenter) GroupNoticeAdd(ctx context.Context, in *GroupNoticeAddReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.GroupNoticeAdd(ctx, in, opts...)
+}
+
+// 群任务编辑
+func (m *defaultMessageCenter) GroupNoticeUpdate(ctx context.Context, in *GroupNoticeUpdateReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.GroupNoticeUpdate(ctx, in, opts...)
+}
+
+// 群任务编辑
+func (m *defaultMessageCenter) GroupNoticeGet(ctx context.Context, in *ChatGroupPersonReq, opts ...grpc.CallOption) (*CommonReq, error) {
+	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
+	return client.GroupNoticeGet(ctx, in, opts...)
+}