// 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
	ChatGroupPersonList  = messagecenter.ChatGroupPersonList
	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
	GroupNotice          = messagecenter.GroupNotice
	GroupNoticeAddReq    = messagecenter.GroupNoticeAddReq
	GroupNoticeGetResp   = messagecenter.GroupNoticeGetResp
	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) (*GroupNoticeGetResp, 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) (*GroupNoticeGetResp, error) {
	client := messagecenter.NewMessageCenterClient(m.cli.Conn())
	return client.GroupNoticeGet(ctx, in, opts...)
}