messageCenter/rpc/messagecenter/messagecenter/messagecenter.go

// Code generated by goctl. DO NOT EDIT!
// Source: messagecenter.proto

package messagecenter

import (
	"context"

	"github.com/zeromicro/go-zero/zrpc"
	"google.golang.org/grpc"
)

type (
	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)
		// 用户撤回消息
		WithdrawMessage(ctx context.Context, in *ReadWithdrawReq, opts ...grpc.CallOption) (*CurrencyResp, error)
		//  用户评价回复
		AppraiseMessage(ctx context.Context, in *AppraiseReq, opts ...grpc.CallOption) (*CurrencyResp, error)
		//  客服列表查询
		ConversationList(ctx context.Context, in *ConversationReq, opts ...grpc.CallOption) (*UserResp, error)
		//  群聊
		GroupChat(ctx context.Context, in *MessageSaveReq, 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := 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 := NewMessageCenterClient(m.cli.Conn())
	return client.GroupNoticeGet(ctx, in, opts...)
}

// 用户撤回消息
func (m *defaultMessageCenter) WithdrawMessage(ctx context.Context, in *ReadWithdrawReq, opts ...grpc.CallOption) (*CurrencyResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.WithdrawMessage(ctx, in, opts...)
}

//  用户评价回复
func (m *defaultMessageCenter) AppraiseMessage(ctx context.Context, in *AppraiseReq, opts ...grpc.CallOption) (*CurrencyResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.AppraiseMessage(ctx, in, opts...)
}

//  客服列表查询
func (m *defaultMessageCenter) ConversationList(ctx context.Context, in *ConversationReq, opts ...grpc.CallOption) (*UserResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.ConversationList(ctx, in, opts...)
}

//  群聊
func (m *defaultMessageCenter) GroupChat(ctx context.Context, in *MessageSaveReq, opts ...grpc.CallOption) (*CommonReq, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.GroupChat(ctx, in, opts...)
}