// 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 (
	AllSortData            = message.AllSortData
	BitmapSaveMsgReq       = message.BitmapSaveMsgReq
	BuoyMessages           = message.BuoyMessages
	ChangeReadStatusReq    = message.ChangeReadStatusReq
	ClearUnreadMsgReq      = message.ClearUnreadMsgReq
	CustomWxTpl            = message.CustomWxTpl
	FindUserBuoyMsgReq     = message.FindUserBuoyMsgReq
	FindUserBuoyMsgRes     = message.FindUserBuoyMsgRes
	FindUserMsgReq         = message.FindUserMsgReq
	FindUserMsgRes         = message.FindUserMsgRes
	GetClassUnreadCountReq = message.GetClassUnreadCountReq
	GetLastMessageReq      = message.GetLastMessageReq
	GetLastMessageRes      = message.GetLastMessageRes
	GetUnreadClassCountReq = message.GetUnreadClassCountReq
	GetUnreadClassCountRes = message.GetUnreadClassCountRes
	MaterialDetail         = message.MaterialDetail
	MaterialDetailReq      = message.MaterialDetailReq
	MaterialDetailResp     = message.MaterialDetailResp
	MessageDetailReq       = message.MessageDetailReq
	MessageDetailResp      = message.MessageDetailResp
	Messages               = message.Messages
	MsgOpenLogReq          = message.MsgOpenLogReq
	MsgTypes               = message.MsgTypes
	MultipleSaveMsgReq     = message.MultipleSaveMsgReq
	MultipleSaveMsgResp    = message.MultipleSaveMsgResp
	NewUserInsertMsgReq    = message.NewUserInsertMsgReq
	ResCount               = message.ResCount
	Response               = message.Response
	SendMsgResponse        = message.SendMsgResponse
	TmplItem               = message.TmplItem
	UpdateMsgSummaryReq    = message.UpdateMsgSummaryReq
	User                   = message.User
	UserMsgList            = message.UserMsgList
	UserMsgListReq         = message.UserMsgListReq
	UserMsgListRes         = message.UserMsgListRes
	WorkingDesktopReq      = message.WorkingDesktopReq
	WorkingDesktopResp     = message.WorkingDesktopResp
	WxTmplMsgRequest       = message.WxTmplMsgRequest
	WxTmplResponse         = message.WxTmplResponse

	Message interface {
		// 工作桌面列表
		WorkingDesktopList(ctx context.Context, in *WorkingDesktopReq, opts ...grpc.CallOption) (*WorkingDesktopResp, error)
		// 发送消息更新一次消息汇总表
		UpdateMsgSummary(ctx context.Context, in *UpdateMsgSummaryReq, opts ...grpc.CallOption) (*Response, error)
		// 新用户发送消息
		NewUserMsg(ctx context.Context, in *NewUserInsertMsgReq, opts ...grpc.CallOption) (*Response, error)
		// bitmap保存消息
		BitmapSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error)
		// 批量保存消息
		MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error)
		//  修改消息阅读状态
		ChangeReadStatus(ctx context.Context, in *ChangeReadStatusReq, opts ...grpc.CallOption) (*Response, error)
		//   查询指定用户的历史消息记录
		FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error)
		// 查看详细详情
		FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error)
		//   消息的分类
		FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error)
		//    一键清空未读消息
		ClearUnreadMsg(ctx context.Context, in *ClearUnreadMsgReq, opts ...grpc.CallOption) (*Response, error)
		//    new用户消息列表
		UserMsgList(ctx context.Context, in *UserMsgListReq, opts ...grpc.CallOption) (*UserMsgListRes, error)
		//   发送剑鱼微信模版消息
		SendWxTmplMsg(ctx context.Context, in *WxTmplMsgRequest, opts ...grpc.CallOption) (*SendMsgResponse, error)
		//    官网、移动端首页、工作桌面消息滚动
		MsgOpenLog(ctx context.Context, in *MsgOpenLogReq, opts ...grpc.CallOption) (*Response, error)
		//  物料详情
		MlDetails(ctx context.Context, in *MaterialDetailReq, opts ...grpc.CallOption) (*MaterialDetailResp, error)
		//   发送剑鱼微信模版消息
		AppLetterPush(ctx context.Context, in *WxTmplMsgRequest, opts ...grpc.CallOption) (*SendMsgResponse, error)
	}

	defaultMessage struct {
		cli zrpc.Client
	}
)

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

// 工作桌面列表
func (m *defaultMessage) WorkingDesktopList(ctx context.Context, in *WorkingDesktopReq, opts ...grpc.CallOption) (*WorkingDesktopResp, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.WorkingDesktopList(ctx, in, opts...)
}

// 发送消息更新一次消息汇总表
func (m *defaultMessage) UpdateMsgSummary(ctx context.Context, in *UpdateMsgSummaryReq, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.UpdateMsgSummary(ctx, in, opts...)
}

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

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

// 批量保存消息
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 *ChangeReadStatusReq, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.ChangeReadStatus(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) 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) FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.FindUserBuoyMsg(ctx, in, opts...)
}

// 一键清空未读消息
func (m *defaultMessage) ClearUnreadMsg(ctx context.Context, in *ClearUnreadMsgReq, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.ClearUnreadMsg(ctx, in, opts...)
}

// new用户消息列表
func (m *defaultMessage) UserMsgList(ctx context.Context, in *UserMsgListReq, opts ...grpc.CallOption) (*UserMsgListRes, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.UserMsgList(ctx, in, opts...)
}

// 发送剑鱼微信模版消息
func (m *defaultMessage) SendWxTmplMsg(ctx context.Context, in *WxTmplMsgRequest, opts ...grpc.CallOption) (*SendMsgResponse, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.SendWxTmplMsg(ctx, in, opts...)
}

// 官网、移动端首页、工作桌面消息滚动
func (m *defaultMessage) MsgOpenLog(ctx context.Context, in *MsgOpenLogReq, opts ...grpc.CallOption) (*Response, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.MsgOpenLog(ctx, in, opts...)
}

// 物料详情
func (m *defaultMessage) MlDetails(ctx context.Context, in *MaterialDetailReq, opts ...grpc.CallOption) (*MaterialDetailResp, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.MlDetails(ctx, in, opts...)
}

// 发送剑鱼微信模版消息
func (m *defaultMessage) AppLetterPush(ctx context.Context, in *WxTmplMsgRequest, opts ...grpc.CallOption) (*SendMsgResponse, error) {
	client := message.NewMessageClient(m.cli.Conn())
	return client.AppLetterPush(ctx, in, opts...)
}