提交

rpc/internal/server/messageserver.go

@@ -68,3 +68,9 @@ func (s *MessageServer) GetLastMessage(ctx context.Context, in *message.GetLastM
 	l := logic.NewGetLastMessageLogic(ctx, s.svcCtx)
 	return l.GetLastMessage(in)
 }
+
+//   获取指定用户的未读消息分类及数量 及分类的最新消息
+func (s *MessageServer) GetUnreadClassCount(ctx context.Context, in *message.GetUnreadClassCountReq) (*message.GetUnreadClassCountRes, error) {
+	l := logic.NewGetUnreadClassCountLogic(ctx, s.svcCtx)
+	return l.GetUnreadClassCount(in)
+}

rpc/messageclient/message.go

@@ -14,19 +14,22 @@ import (
 )
 
 type (
-	FindUserMsgRes               = message.FindUserMsgRes
-	GetClassUnreadCountReq       = message.GetClassUnreadCountReq
-	ChangeReadStatusRequest      = message.ChangeReadStatusRequest
 	DeleteSingleMessageRequest   = message.DeleteSingleMessageRequest
 	DeleteMultipleMessageRequest = message.DeleteMultipleMessageRequest
-	GetUnreadCountRequest        = message.GetUnreadCountRequest
+	GetLastMessageReq            = message.GetLastMessageReq
+	GetUnreadClassCountRes       = message.GetUnreadClassCountRes
+	ChangeReadStatusRequest      = message.ChangeReadStatusRequest
 	Response                     = message.Response
+	FindUserMsgRes               = message.FindUserMsgRes
+	ResCount                     = message.ResCount
 	FindUserMsgReq               = message.FindUserMsgReq
-	GetLastMessageReq            = message.GetLastMessageReq
+	GetClassUnreadCountReq       = message.GetClassUnreadCountReq
+	GetUnreadClassCountReq       = message.GetUnreadClassCountReq
+	GetLastMessageRes            = message.GetLastMessageRes
 	SendMsgRequest               = message.SendMsgRequest
+	GetUnreadCountRequest        = message.GetUnreadCountRequest
 	GetUnreadCountResponse       = message.GetUnreadCountResponse
 	Messages                     = message.Messages
-	GetLastMessageRes            = message.GetLastMessageRes
 
 	Message interface {
 		//  修改消息阅读状态
@@ -45,6 +48,8 @@ type (
 		GetClassUnreadCount(ctx context.Context, in *GetClassUnreadCountReq) (*GetUnreadCountResponse, error)
 		//   获取指定用户指定分类的最新一条未读消息
 		GetLastMessage(ctx context.Context, in *GetLastMessageReq) (*GetLastMessageRes, error)
+		//   获取指定用户的未读消息分类及数量 及分类的最新消息
+		GetUnreadClassCount(ctx context.Context, in *GetUnreadClassCountReq) (*GetUnreadClassCountRes, error)
 	}
 
 	defaultMessage struct {
@@ -105,3 +110,9 @@ func (m *defaultMessage) GetLastMessage(ctx context.Context, in *GetLastMessageR
 	client := message.NewMessageClient(m.cli.Conn())
 	return client.GetLastMessage(ctx, in)
 }
+
+//   获取指定用户的未读消息分类及数量 及分类的最新消息
+func (m *defaultMessage) GetUnreadClassCount(ctx context.Context, in *GetUnreadClassCountReq) (*GetUnreadClassCountRes, error) {
+	client := message.NewMessageClient(m.cli.Conn())
+	return client.GetUnreadClassCount(ctx, in)
+}