// 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)
		// 用户撤回消息
		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)
		//  1v1会话职位
		OneUserPosition(ctx context.Context, in *OneUserPositionReq, opts ...grpc.CallOption) (*OneUserPositionResp, error)
		//  1v1首次创建会话汇总表信息
		OneUserConversation(ctx context.Context, in *OneUserConversationReq, opts ...grpc.CallOption) (*CurrencyResp, error)
		//  根据客服id/职位id/群id 获取名称
		GetSenderName(ctx context.Context, in *GetSenderNameReq, opts ...grpc.CallOption) (*GetSenderNameResp, 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) 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...)
}

//  1v1会话职位
func (m *defaultMessageCenter) OneUserPosition(ctx context.Context, in *OneUserPositionReq, opts ...grpc.CallOption) (*OneUserPositionResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.OneUserPosition(ctx, in, opts...)
}

//  1v1首次创建会话汇总表信息
func (m *defaultMessageCenter) OneUserConversation(ctx context.Context, in *OneUserConversationReq, opts ...grpc.CallOption) (*CurrencyResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.OneUserConversation(ctx, in, opts...)
}

//  根据客服id/职位id/群id 获取名称
func (m *defaultMessageCenter) GetSenderName(ctx context.Context, in *GetSenderNameReq, opts ...grpc.CallOption) (*GetSenderNameResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.GetSenderName(ctx, in, opts...)
}