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

package messageclient

import (
	"context"

	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"

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

type (
	BuoyMessages                 = message.BuoyMessages
	ChangeReadStatusRequest      = message.ChangeReadStatusRequest
	DeleteMultipleMessageRequest = message.DeleteMultipleMessageRequest
	DeleteSingleMessageRequest   = message.DeleteSingleMessageRequest
	FindUserBuoyMsgReq           = message.FindUserBuoyMsgReq
	FindUserBuoyMsgRes           = message.FindUserBuoyMsgRes
	FindUserMsgReq               = message.FindUserMsgReq
	FindUserMsgRes               = message.FindUserMsgRes
	GetClassUnreadCountReq       = message.GetClassUnreadCountReq
	GetLastMessageReq            = message.GetLastMessageReq
	GetLastMessageRes            = message.GetLastMessageRes
	GetMsgTypeReq                = message.GetMsgTypeReq
	GetMsgTypeRes                = message.GetMsgTypeRes
	GetUnreadClassCountReq       = message.GetUnreadClassCountReq
	GetUnreadClassCountRes       = message.GetUnreadClassCountRes
	GetUnreadCountRequest        = message.GetUnreadCountRequest
	GetUnreadCountResponse       = message.GetUnreadCountResponse
	MessageDetailReq             = message.MessageDetailReq
	MessageDetailResp            = message.MessageDetailResp
	Messages                     = message.Messages
	MultipleSaveMsgReq           = message.MultipleSaveMsgReq
	MultipleSaveMsgResp          = message.MultipleSaveMsgResp
	ResCount                     = message.ResCount
	Response                     = message.Response
	SendMsgRequest               = message.SendMsgRequest
	UpdateMessageReadReq         = message.UpdateMessageReadReq
	UpdateMessageReadResp        = message.UpdateMessageReadResp
	User                         = message.User

	Message interface {
		// 批量保存消息
		MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error)
		//  修改消息阅读状态
		ChangeReadStatus(ctx context.Context, in *ChangeReadStatusRequest, opts ...grpc.CallOption) (*Response, error)
		// 指定用户发消息
		SendUserMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*Response, error)
		//  删除单一消息
		DeleteSingleMessage(ctx context.Context, in *DeleteSingleMessageRequest, opts ...grpc.CallOption) (*Response, error)
		//  删除多条消息
		DeleteMultipleMessage(ctx context.Context, in *DeleteMultipleMessageRequest, opts ...grpc.CallOption) (*Response, error)
		//   查询指定用户未读消息合计
		GetUnreadCount(ctx context.Context, in *GetUnreadCountRequest, opts ...grpc.CallOption) (*GetUnreadCountResponse, error)
		//   查询指定用户的历史消息记录
		FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error)
		//   查询指定用户指定分类的未读消息合计
		GetClassUnreadCount(ctx context.Context, in *GetClassUnreadCountReq, opts ...grpc.CallOption) (*GetUnreadCountResponse, error)
		//   获取指定用户指定分类的最新一条消息
		GetLastMessage(ctx context.Context, in *GetLastMessageReq, opts ...grpc.CallOption) (*GetLastMessageRes, error)
		// 查看详细详情
		FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error)
		//   获取指定用户的分类及未读消息数量
		GetUnreadClassCount(ctx context.Context, in *GetUnreadClassCountReq, opts ...grpc.CallOption) (*GetUnreadClassCountRes, error)
		//   获取指定用户收到消息的分类
		GetMsgType(ctx context.Context, in *GetMsgTypeReq, opts ...grpc.CallOption) (*GetMsgTypeRes, error)
		// 修改用户指定分类下的消息已读未读
		UpdateMessageRead(ctx context.Context, in *UpdateMessageReadReq, opts ...grpc.CallOption) (*UpdateMessageReadResp, error)
		//   查询指定用户的浮标消息
		FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error)
	}

	defaultMessage struct {
		cli zrpc.Client
	}
)

func NewMessage(cli zrpc.Client) Message {
	return &defaultMessage{
		cli: cli,
	}
}

// 批量保存消息
func (m *defaultMessage) MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.MultipleSaveMsg(ctx, in, opts...)
}

//  修改消息阅读状态
func (m *defaultMessage) ChangeReadStatus(ctx context.Context, in *ChangeReadStatusRequest, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.ChangeReadStatus(ctx, in, opts...)
}

// 指定用户发消息
func (m *defaultMessage) SendUserMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.SendUserMsg(ctx, in, opts...)
}

//  删除单一消息
func (m *defaultMessage) DeleteSingleMessage(ctx context.Context, in *DeleteSingleMessageRequest, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.DeleteSingleMessage(ctx, in, opts...)
}

//  删除多条消息
func (m *defaultMessage) DeleteMultipleMessage(ctx context.Context, in *DeleteMultipleMessageRequest, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.DeleteMultipleMessage(ctx, in, opts...)
}

//   查询指定用户未读消息合计
func (m *defaultMessage) GetUnreadCount(ctx context.Context, in *GetUnreadCountRequest, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.GetUnreadCount(ctx, in, opts...)
}

//   查询指定用户的历史消息记录
func (m *defaultMessage) FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.FindUserMsg(ctx, in, opts...)
}

//   查询指定用户指定分类的未读消息合计
func (m *defaultMessage) GetClassUnreadCount(ctx context.Context, in *GetClassUnreadCountReq, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.GetClassUnreadCount(ctx, in, opts...)
}

//   获取指定用户指定分类的最新一条消息
func (m *defaultMessage) GetLastMessage(ctx context.Context, in *GetLastMessageReq, opts ...grpc.CallOption) (*GetLastMessageRes, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.GetLastMessage(ctx, in, opts...)
}

// 查看详细详情
func (m *defaultMessage) FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.FindMessageDetail(ctx, in, opts...)
}

//   获取指定用户的分类及未读消息数量
func (m *defaultMessage) GetUnreadClassCount(ctx context.Context, in *GetUnreadClassCountReq, opts ...grpc.CallOption) (*GetUnreadClassCountRes, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.GetUnreadClassCount(ctx, in, opts...)
}

//   获取指定用户收到消息的分类
func (m *defaultMessage) GetMsgType(ctx context.Context, in *GetMsgTypeReq, opts ...grpc.CallOption) (*GetMsgTypeRes, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.GetMsgType(ctx, in, opts...)
}

// 修改用户指定分类下的消息已读未读
func (m *defaultMessage) UpdateMessageRead(ctx context.Context, in *UpdateMessageReadReq, opts ...grpc.CallOption) (*UpdateMessageReadResp, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.UpdateMessageRead(ctx, in, opts...)
}

//   查询指定用户的浮标消息
func (m *defaultMessage) FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.FindUserBuoyMsg(ctx, in, opts...)
}