Merge branch 'dev/v1.2.7_rjj' of moapp/MessageCenter into feature/v1.2.7

api/internal/handler/messagesetreadstatushandler.go

@@ -1,29 +0,0 @@
-package handler
-
-import (
-	"net/http"
-
-	"app.yhyue.com/moapp/MessageCenter/api/internal/logic"
-	"app.yhyue.com/moapp/MessageCenter/api/internal/svc"
-	"app.yhyue.com/moapp/MessageCenter/api/internal/types"
-
-	"github.com/zeromicro/go-zero/rest/httpx"
-)
-
-func MessageSetReadStatusHandler(ctx *svc.ServiceContext) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		var req types.MsgReadStatusReq
-		if err := httpx.Parse(r, &req); err != nil {
-			httpx.Error(w, err)
-			return
-		}
-
-		l := logic.NewMessageSetReadStatusLogic(r.Context(), ctx)
-		resp, err := l.MessageSetReadStatus(req)
-		if err != nil {
-			httpx.Error(w, err)
-		} else {
-			httpx.OkJson(w, resp)
-		}
-	}
-}

api/internal/handler/routes.go

@@ -72,6 +72,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
 				Path:    "/messageCenter/MessageList",
 				Handler: MessageListHandler(serverCtx),
 			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/messageCenter/unreadMessages",
+				Handler: UnreadMessagesHandler(serverCtx),
+			},
 		},
 	)
 }

api/internal/handler/messagedeletehandler.go → api/internal/handler/unreadmessageshandler.go

@@ -6,20 +6,19 @@ import (
 	"app.yhyue.com/moapp/MessageCenter/api/internal/logic"
 	"app.yhyue.com/moapp/MessageCenter/api/internal/svc"
 	"app.yhyue.com/moapp/MessageCenter/api/internal/types"
-
 	"github.com/zeromicro/go-zero/rest/httpx"
 )
 
-func MessageDeleteHandler(ctx *svc.ServiceContext) http.HandlerFunc {
+func UnreadMessagesHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		var req types.MessageDeleteReq
+		var req types.UnreadMessageReq
 		if err := httpx.Parse(r, &req); err != nil {
 			httpx.Error(w, err)
 			return
 		}
 
-		l := logic.NewMessageDeleteLogic(r.Context(), ctx)
-		resp, err := l.MessageDelete(req)
+		l := logic.NewUnreadMessagesLogic(r.Context(), svcCtx)
+		resp, err := l.UnreadMessages(&req)
 		if err != nil {
 			httpx.Error(w, err)
 		} else {

api/internal/logic/markreadlogic.go

@@ -26,7 +26,7 @@ func NewMarkReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) MarkReadL
 func (l *MarkReadLogic) MarkRead(req types.MarkReadReq) (*types.MarkReadRes, error) {
 	result := &types.MarkReadRes{}
 	lsi := l.svcCtx.MessageCenter
-	resp, err := lsi.ChangeReadStatus(l.ctx, &messageclient.ChangeReadStatusRequest{
+	resp, err := lsi.ChangeReadStatus(l.ctx, &messageclient.ChangeReadStatusReq{
 		Appid:      req.AppId,
 		ReadStatus: 1,
 		Id:         req.MsgId,

api/internal/logic/messagesetreadstatuslogic.go

@@ -1,41 +0,0 @@
-package logic
-
-import (
-	"app.yhyue.com/moapp/MessageCenter/api/internal/svc"
-	"app.yhyue.com/moapp/MessageCenter/api/internal/types"
-	"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
-	"context"
-
-	"github.com/zeromicro/go-zero/core/logx"
-)
-
-type MessageSetReadStatusLogic struct {
-	logx.Logger
-	ctx    context.Context
-	svcCtx *svc.ServiceContext
-}
-
-func NewMessageSetReadStatusLogic(ctx context.Context, svcCtx *svc.ServiceContext) MessageSetReadStatusLogic {
-	return MessageSetReadStatusLogic{
-		Logger: logx.WithContext(ctx),
-		ctx:    ctx,
-		svcCtx: svcCtx,
-	}
-}
-
-func (l *MessageSetReadStatusLogic) MessageSetReadStatus(req types.MsgReadStatusReq) (*types.MsgReadStatusResp, error) {
-	result := &types.MsgReadStatusResp{}
-	lsi := l.svcCtx.MessageCenter
-	resp, err := lsi.UpdateMessageRead(l.ctx, &messageclient.UpdateMessageReadReq{
-		AppId:         req.AppId,
-		ReceiveUserid: req.UserId,
-		MsgType:       int64(req.MsgType),
-	})
-	if err != nil {
-		return nil, err
-	}
-	result.Code = resp.Code
-	result.Message = resp.Message
-	result.Status = resp.Status
-	return result, nil
-}

api/internal/logic/unreadmessageslogic.go

@@ -0,0 +1,60 @@
+package logic
+
+import (
+	"app.yhyue.com/moapp/MessageCenter/api/internal/svc"
+	"app.yhyue.com/moapp/MessageCenter/api/internal/types"
+	"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
+	"context"
+	"log"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type UnreadMessagesLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewUnreadMessagesLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UnreadMessagesLogic {
+	return &UnreadMessagesLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *UnreadMessagesLogic) UnreadMessages(req *types.UnreadMessageReq) (resp *types.UnreadMessageResp, err error) {
+	result := &types.UnreadMessageResp{}
+	lsi := l.svcCtx.MessageCenter
+	res, err := lsi.UserUnreadMsgList(l.ctx, &messageclient.UserUnreadMsgListReq{
+		UserId:   req.UserId,
+		Appid:    req.AppId,
+		PageSize: req.PageSize,
+		OffSet:   req.Offset,
+	})
+	if err != nil {
+		return nil, err
+	}
+	if res.List != nil && len(res.List) > 0 {
+		for _, v := range res.List {
+			result.Data = append(result.Data, map[string]interface{}{
+				"id":         v.Id,
+				"appid":      v.Appid,
+				"createtime": v.Createtime,
+				"title":      v.Title,
+				"msg_type":   v.MsgType,
+				"link":       v.Link,
+				"content":    v.Content,
+				"isRead":     v.IsRead,
+				"msgLogId":   v.MsgLogId,
+				"url":        v.Url,
+			})
+		}
+	}
+	log.Println(result.Data)
+	result.Code = res.Code
+	result.Message = res.Message
+	result.Total = res.Count
+	return result, nil
+}

api/internal/types/types.go

@@ -63,8 +63,8 @@ type MessageUnreadClassCountRes struct {
 }
 
 type MessageUnreadCountReq struct {
-	UserId string `form:"userId"`
-	AppId  string `form:"appId"`
+	UserId string `header:"mgoUserId"`
+	AppId  string `header:"appId"`
 }
 
 type MessageUnreadCountRes struct {
@@ -180,3 +180,17 @@ type MessageListResp struct {
 	Column  []map[string]interface{} `json:"column"`
 	Unread  int64                    `json:"unread"`
 }
+
+type UnreadMessageReq struct {
+	UserId   string `header:"mgoUserId"`
+	AppId    string `header:"appId"`
+	Offset   int64  `json:"offset"` //
+	PageSize int64  `json:"pageSize"`
+}
+
+type UnreadMessageResp struct {
+	Code    int64                    `json:"code"`
+	Message string                   `json:"message"`
+	Data    []map[string]interface{} `json:"data"`
+	Total   int64                    `json:"total"`
+}

api/message.api

@@ -64,8 +64,8 @@ type MessageUnreadClassCountRes {
 	Data    []map[string]interface{} `json:"data"`
 }
 type MessageUnreadCountReq {
-	UserId string `form:"userId"`
-	AppId  string `form:"appId"`
+	UserId string `header:"mgoUserId"`
+	AppId  string `header:"appId"`
 }
 type MessageUnreadCountRes {
 	Code    int64                  `json:"code"`
@@ -177,11 +177,23 @@ type MessageListResp {
 	Column  []map[string]interface{} `json:"column"`
 	Unread  int64                    `json:"unread"`
 }
+type UnreadMessageReq {
+	UserId   string `header:"mgoUserId"`
+	AppId    string `header:"appId"`
+	Offset   int64  `json:"offset"` //
+	PageSize int64  `json:"pageSize"`
+}
+type UnreadMessageResp {
+	Code    int64                    `json:"code"`
+	Message string                   `json:"message"`
+	Data    []map[string]interface{} `json:"data"`
+	Total   int64                    `json:"total"`
+}
 
 service message-api {
 	
 	//查询消息详情
-	@handler MessageDetailHandler // TODO: set handler name and delete this comment
+	@handler MessageDetailHandler
 	get /messageCenter/messageDetail (MessageDetailReq) returns (MessageDetailResp)
 	// 获取指定类型的最新一条未读消息
 	@handler MessageGetLastHandler
@@ -219,4 +231,7 @@ service message-api {
 	
 	@handler MessageList
 	post /messageCenter/MessageList (MessageListReq) returns (MessageListResp)
+	
+	@handler UnreadMessages
+	post /messageCenter/unreadMessages (UnreadMessageReq) returns (UnreadMessageResp)
 }

rpc/internal/common/sendMsg.go

@@ -273,6 +273,7 @@ func UserUnreadMsgList(this *message.UserUnreadMsgListReq) (int64, []*message.Me
 		"appid":          this.Appid,
 		"isRead":         0,
 	}
+	log.Println(cquery)
 	count = entity.Mysql.Count("message", cquery)
 	if count > 0 {
 		res := entity.Mysql.Find("message", cquery, "", "createtime desc", (int(this.OffSet)-1)*int(this.PageSize), int(this.PageSize))

rpc/internal/logic/changereadstatuslogic.go

@@ -26,7 +26,8 @@ func NewChangeReadStatusLogic(ctx context.Context, svcCtx *svc.ServiceContext) *
 }
 
 // 修改消息阅读状态
-func (l *ChangeReadStatusLogic) ChangeReadStatus(in *message.ChangeReadStatusReq) (*message.Response, error) {
+func (l *ChangeReadStatusLogic) ChangeReadStatus(in *messageclient.ChangeReadStatusReq) (*message.Response, error) {
+	// todo: add your logic here and delete this line
 	m := &service.MessageService{}
 	code, msg := m.ChangeReadStatus(in)
 	return &messageclient.Response{

rpc/internal/logic/userunreadmsglistlogic.go

@@ -4,6 +4,7 @@ import (
 	service "app.yhyue.com/moapp/MessageCenter/rpc/internal/common"
 	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
 	"context"
+	"log"
 
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/svc"
 	"github.com/zeromicro/go-zero/core/logx"
@@ -27,6 +28,7 @@ func NewUserUnreadMsgListLogic(ctx context.Context, svcCtx *svc.ServiceContext)
 func (l *UserUnreadMsgListLogic) UserUnreadMsgList(in *message.UserUnreadMsgListReq) (*message.UserUnreadMsgListRes, error) {
 	data := new(message.UserUnreadMsgListRes)
 	count, res := service.UserUnreadMsgList(in) //具体信息
+	log.Println(count, res)
 	if count > 0 && len(res) > 0 {
 		data.List = res
 		data.Count = count

rpc/internal/server/messageserver.go

@@ -4,16 +4,16 @@
 package server
 
 import (
+	message2 "app.yhyue.com/moapp/MessageCenter/rpc/type/message"
 	"context"
 
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/logic"
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/svc"
-	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
 )
 
 type MessageServer struct {
 	svcCtx *svc.ServiceContext
-	message.UnimplementedMessageServer
+	message2.UnimplementedMessageServer
 }
 
 func NewMessageServer(svcCtx *svc.ServiceContext) *MessageServer {
@@ -23,91 +23,91 @@ func NewMessageServer(svcCtx *svc.ServiceContext) *MessageServer {
 }
 
 // 批量保存消息
-func (s *MessageServer) MultipleSaveMsg(ctx context.Context, in *message.MultipleSaveMsgReq) (*message.MultipleSaveMsgResp, error) {
+func (s *MessageServer) MultipleSaveMsg(ctx context.Context, in *message2.MultipleSaveMsgReq) (*message2.MultipleSaveMsgResp, error) {
 	l := logic.NewMultipleSaveMsgLogic(ctx, s.svcCtx)
 	return l.MultipleSaveMsg(in)
 }
 
 //  修改消息阅读状态
-func (s *MessageServer) ChangeReadStatus(ctx context.Context, in *message.ChangeReadStatusReq) (*message.Response, error) {
+func (s *MessageServer) ChangeReadStatus(ctx context.Context, in *message2.ChangeReadStatusReq) (*message2.Response, error) {
 	l := logic.NewChangeReadStatusLogic(ctx, s.svcCtx)
 	return l.ChangeReadStatus(in)
 }
 
 // 指定用户发消息
-func (s *MessageServer) SendUserMsg(ctx context.Context, in *message.SendMsgRequest) (*message.Response, error) {
+func (s *MessageServer) SendUserMsg(ctx context.Context, in *message2.SendMsgRequest) (*message2.Response, error) {
 	l := logic.NewSendUserMsgLogic(ctx, s.svcCtx)
 	return l.SendUserMsg(in)
 }
 
 //   查询指定用户未读消息合计
-func (s *MessageServer) GetUnreadCount(ctx context.Context, in *message.GetUnreadCountRequest) (*message.GetUnreadCountResponse, error) {
+func (s *MessageServer) GetUnreadCount(ctx context.Context, in *message2.GetUnreadCountRequest) (*message2.GetUnreadCountResponse, error) {
 	l := logic.NewGetUnreadCountLogic(ctx, s.svcCtx)
 	return l.GetUnreadCount(in)
 }
 
 //   查询指定用户的历史消息记录
-func (s *MessageServer) FindUserMsg(ctx context.Context, in *message.FindUserMsgReq) (*message.FindUserMsgRes, error) {
+func (s *MessageServer) FindUserMsg(ctx context.Context, in *message2.FindUserMsgReq) (*message2.FindUserMsgRes, error) {
 	l := logic.NewFindUserMsgLogic(ctx, s.svcCtx)
 	return l.FindUserMsg(in)
 }
 
 //   查询指定用户指定分类的未读消息合计
-func (s *MessageServer) GetClassUnreadCount(ctx context.Context, in *message.GetClassUnreadCountReq) (*message.GetUnreadCountResponse, error) {
+func (s *MessageServer) GetClassUnreadCount(ctx context.Context, in *message2.GetClassUnreadCountReq) (*message2.GetUnreadCountResponse, error) {
 	l := logic.NewGetClassUnreadCountLogic(ctx, s.svcCtx)
 	return l.GetClassUnreadCount(in)
 }
 
 //   获取指定用户指定分类的最新一条消息
-func (s *MessageServer) GetLastMessage(ctx context.Context, in *message.GetLastMessageReq) (*message.GetLastMessageRes, error) {
+func (s *MessageServer) GetLastMessage(ctx context.Context, in *message2.GetLastMessageReq) (*message2.GetLastMessageRes, error) {
 	l := logic.NewGetLastMessageLogic(ctx, s.svcCtx)
 	return l.GetLastMessage(in)
 }
 
 // 查看详细详情
-func (s *MessageServer) FindMessageDetail(ctx context.Context, in *message.MessageDetailReq) (*message.MessageDetailResp, error) {
+func (s *MessageServer) FindMessageDetail(ctx context.Context, in *message2.MessageDetailReq) (*message2.MessageDetailResp, error) {
 	l := logic.NewFindMessageDetailLogic(ctx, s.svcCtx)
 	return l.FindMessageDetail(in)
 }
 
 //   获取指定用户的分类及未读消息数量
-func (s *MessageServer) GetUnreadClassCount(ctx context.Context, in *message.GetUnreadClassCountReq) (*message.GetUnreadClassCountRes, error) {
+func (s *MessageServer) GetUnreadClassCount(ctx context.Context, in *message2.GetUnreadClassCountReq) (*message2.GetUnreadClassCountRes, error) {
 	l := logic.NewGetUnreadClassCountLogic(ctx, s.svcCtx)
 	return l.GetUnreadClassCount(in)
 }
 
 //   获取指定用户收到消息的分类
-func (s *MessageServer) GetMsgType(ctx context.Context, in *message.GetMsgTypeReq) (*message.GetMsgTypeRes, error) {
+func (s *MessageServer) GetMsgType(ctx context.Context, in *message2.GetMsgTypeReq) (*message2.GetMsgTypeRes, error) {
 	l := logic.NewGetMsgTypeLogic(ctx, s.svcCtx)
 	return l.GetMsgType(in)
 }
 
 //   查询指定用户的浮标消息
-func (s *MessageServer) FindUserBuoyMsg(ctx context.Context, in *message.FindUserBuoyMsgReq) (*message.FindUserBuoyMsgRes, error) {
+func (s *MessageServer) FindUserBuoyMsg(ctx context.Context, in *message2.FindUserBuoyMsgReq) (*message2.FindUserBuoyMsgRes, error) {
 	l := logic.NewFindUserBuoyMsgLogic(ctx, s.svcCtx)
 	return l.FindUserBuoyMsg(in)
 }
 
 //    一键清空未读消息
-func (s *MessageServer) ClearUnreadMsg(ctx context.Context, in *message.ClearUnreadMsgReq) (*message.Response, error) {
+func (s *MessageServer) ClearUnreadMsg(ctx context.Context, in *message2.ClearUnreadMsgReq) (*message2.Response, error) {
 	l := logic.NewClearUnreadMsgLogic(ctx, s.svcCtx)
 	return l.ClearUnreadMsg(in)
 }
 
 //    new用户消息列表
-func (s *MessageServer) UserMsgList(ctx context.Context, in *message.UserMsgListReq) (*message.UserMsgListRes, error) {
+func (s *MessageServer) UserMsgList(ctx context.Context, in *message2.UserMsgListReq) (*message2.UserMsgListRes, error) {
 	l := logic.NewUserMsgListLogic(ctx, s.svcCtx)
 	return l.UserMsgList(in)
 }
 
 //   发送微信模版消息
-func (s *MessageServer) SendWxTmplMsg(ctx context.Context, in *message.WxTmplMsg) (*message.Response, error) {
+func (s *MessageServer) SendWxTmplMsg(ctx context.Context, in *message2.WxTmplMsg) (*message2.Response, error) {
 	l := logic.NewSendWxTmplMsgLogic(ctx, s.svcCtx)
 	return l.SendWxTmplMsg(in)
 }
 
 //    官网、移动端首页、工作桌面消息滚动
-func (s *MessageServer) UserUnreadMsgList(ctx context.Context, in *message.UserUnreadMsgListReq) (*message.UserUnreadMsgListRes, error) {
+func (s *MessageServer) UserUnreadMsgList(ctx context.Context, in *message2.UserUnreadMsgListReq) (*message2.UserUnreadMsgListRes, error) {
 	l := logic.NewUserUnreadMsgListLogic(ctx, s.svcCtx)
 	return l.UserUnreadMsgList(in)
 }

rpc/messageclient/message.go

@@ -4,48 +4,47 @@
 package messageclient
 
 import (
+	message2 "app.yhyue.com/moapp/MessageCenter/rpc/type/message"
 	"context"
 
-	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
-
 	"github.com/zeromicro/go-zero/zrpc"
 	"google.golang.org/grpc"
 )
 
 type (
-	AllSortData            = message.AllSortData
-	BuoyMessages           = message.BuoyMessages
-	ChangeReadStatusReq    = message.ChangeReadStatusReq
-	ClearUnreadMsgReq      = message.ClearUnreadMsgReq
-	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
-	User                   = message.User
-	UserMsgList            = message.UserMsgList
-	UserMsgListReq         = message.UserMsgListReq
-	UserMsgListRes         = message.UserMsgListRes
-	UserUnreadMsgListReq   = message.UserUnreadMsgListReq
-	UserUnreadMsgListRes   = message.UserUnreadMsgListRes
-	WxTmplMsg              = message.WxTmplMsg
-	WxTmplResponse         = message.WxTmplResponse
+	AllSortData            = message2.AllSortData
+	BuoyMessages           = message2.BuoyMessages
+	ChangeReadStatusReq    = message2.ChangeReadStatusReq
+	ClearUnreadMsgReq      = message2.ClearUnreadMsgReq
+	FindUserBuoyMsgReq     = message2.FindUserBuoyMsgReq
+	FindUserBuoyMsgRes     = message2.FindUserBuoyMsgRes
+	FindUserMsgReq         = message2.FindUserMsgReq
+	FindUserMsgRes         = message2.FindUserMsgRes
+	GetClassUnreadCountReq = message2.GetClassUnreadCountReq
+	GetLastMessageReq      = message2.GetLastMessageReq
+	GetLastMessageRes      = message2.GetLastMessageRes
+	GetMsgTypeReq          = message2.GetMsgTypeReq
+	GetMsgTypeRes          = message2.GetMsgTypeRes
+	GetUnreadClassCountReq = message2.GetUnreadClassCountReq
+	GetUnreadClassCountRes = message2.GetUnreadClassCountRes
+	GetUnreadCountRequest  = message2.GetUnreadCountRequest
+	GetUnreadCountResponse = message2.GetUnreadCountResponse
+	MessageDetailReq       = message2.MessageDetailReq
+	MessageDetailResp      = message2.MessageDetailResp
+	Messages               = message2.Messages
+	MultipleSaveMsgReq     = message2.MultipleSaveMsgReq
+	MultipleSaveMsgResp    = message2.MultipleSaveMsgResp
+	ResCount               = message2.ResCount
+	Response               = message2.Response
+	SendMsgRequest         = message2.SendMsgRequest
+	User                   = message2.User
+	UserMsgList            = message2.UserMsgList
+	UserMsgListReq         = message2.UserMsgListReq
+	UserMsgListRes         = message2.UserMsgListRes
+	UserUnreadMsgListReq   = message2.UserUnreadMsgListReq
+	UserUnreadMsgListRes   = message2.UserUnreadMsgListRes
+	WxTmplMsg              = message2.WxTmplMsg
+	WxTmplResponse         = message2.WxTmplResponse
 
 	Message interface {
 		// 批量保存消息
@@ -93,90 +92,90 @@ func NewMessage(cli zrpc.Client) Message {
 
 // 批量保存消息
 func (m *defaultMessage) MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error) {
-	client := message.NewMessageClient(m.cli.Conn())
+	client := message2.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())
+	client := message2.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())
+	client := message2.NewMessageClient(m.cli.Conn())
 	return client.SendUserMsg(ctx, in, opts...)
 }
 
 //   查询指定用户未读消息合计
 func (m *defaultMessage) GetUnreadCount(ctx context.Context, in *GetUnreadCountRequest, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) {
-	client := message.NewMessageClient(m.cli.Conn())
+	client := message2.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())
+	client := message2.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())
+	client := message2.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())
+	client := message2.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())
+	client := message2.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())
+	client := message2.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())
+	client := message2.NewMessageClient(m.cli.Conn())
 	return client.GetMsgType(ctx, in, opts...)
 }
 
 //   查询指定用户的浮标消息
 func (m *defaultMessage) FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error) {
-	client := message.NewMessageClient(m.cli.Conn())
+	client := message2.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())
+	client := message2.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())
+	client := message2.NewMessageClient(m.cli.Conn())
 	return client.UserMsgList(ctx, in, opts...)
 }
 
 //   发送微信模版消息
 func (m *defaultMessage) SendWxTmplMsg(ctx context.Context, in *WxTmplMsg, opts ...grpc.CallOption) (*Response, error) {
-	client := message.NewMessageClient(m.cli.Conn())
+	client := message2.NewMessageClient(m.cli.Conn())
 	return client.SendWxTmplMsg(ctx, in, opts...)
 }
 
 //    官网、移动端首页、工作桌面消息滚动
 func (m *defaultMessage) UserUnreadMsgList(ctx context.Context, in *UserUnreadMsgListReq, opts ...grpc.CallOption) (*UserUnreadMsgListRes, error) {
-	client := message.NewMessageClient(m.cli.Conn())
+	client := message2.NewMessageClient(m.cli.Conn())
 	return client.UserUnreadMsgList(ctx, in, opts...)
 }

rpc/type/message/message.pb.go

@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.28.1
+// 	protoc-gen-go v1.28.0
 // 	protoc        v3.19.4
 // source: message.proto
 
@@ -819,7 +819,7 @@ func (x *GetClassUnreadCountReq) GetAppid() string {
 	return ""
 }
 
-// 查看消息内容
+//查看消息内容
 type MessageDetailReq struct {
 	state         protoimpl.MessageState
 	sizeCache     protoimpl.SizeCache

rpc/type/message/message_grpc.pb.go

@@ -22,35 +22,35 @@ const _ = grpc.SupportPackageIsVersion7
 //
 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
 type MessageClient interface {
-	// 批量保存消息
+	//批量保存消息
 	MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error)
 	// 修改消息阅读状态
 	ChangeReadStatus(ctx context.Context, in *ChangeReadStatusReq, opts ...grpc.CallOption) (*Response, error)
-	// 指定用户发消息
+	//指定用户发消息
 	SendUserMsg(ctx context.Context, in *SendMsgRequest, 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)
-	// 查询指定用户的浮标消息
+	//  查询指定用户的浮标消息
 	FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error)
-	// 一键清空未读消息
+	//   一键清空未读消息
 	ClearUnreadMsg(ctx context.Context, in *ClearUnreadMsgReq, opts ...grpc.CallOption) (*Response, error)
-	// new用户消息列表
+	//   new用户消息列表
 	UserMsgList(ctx context.Context, in *UserMsgListReq, opts ...grpc.CallOption) (*UserMsgListRes, error)
-	// 发送微信模版消息
+	//  发送微信模版消息
 	SendWxTmplMsg(ctx context.Context, in *WxTmplMsg, opts ...grpc.CallOption) (*Response, error)
-	// 官网、移动端首页、工作桌面消息滚动
+	//   官网、移动端首页、工作桌面消息滚动
 	UserUnreadMsgList(ctx context.Context, in *UserUnreadMsgListReq, opts ...grpc.CallOption) (*UserUnreadMsgListRes, error)
 }
 
@@ -201,35 +201,35 @@ func (c *messageClient) UserUnreadMsgList(ctx context.Context, in *UserUnreadMsg
 // All implementations must embed UnimplementedMessageServer
 // for forward compatibility
 type MessageServer interface {
-	// 批量保存消息
+	//批量保存消息
 	MultipleSaveMsg(context.Context, *MultipleSaveMsgReq) (*MultipleSaveMsgResp, error)
 	// 修改消息阅读状态
 	ChangeReadStatus(context.Context, *ChangeReadStatusReq) (*Response, error)
-	// 指定用户发消息
+	//指定用户发消息
 	SendUserMsg(context.Context, *SendMsgRequest) (*Response, error)
-	// 查询指定用户未读消息合计
+	//  查询指定用户未读消息合计
 	GetUnreadCount(context.Context, *GetUnreadCountRequest) (*GetUnreadCountResponse, error)
-	// 查询指定用户的历史消息记录
+	//  查询指定用户的历史消息记录
 	FindUserMsg(context.Context, *FindUserMsgReq) (*FindUserMsgRes, error)
-	// 查询指定用户指定分类的未读消息合计
+	//  查询指定用户指定分类的未读消息合计
 	GetClassUnreadCount(context.Context, *GetClassUnreadCountReq) (*GetUnreadCountResponse, error)
-	// 获取指定用户指定分类的最新一条消息
+	//  获取指定用户指定分类的最新一条消息
 	GetLastMessage(context.Context, *GetLastMessageReq) (*GetLastMessageRes, error)
-	// 查看详细详情
+	//查看详细详情
 	FindMessageDetail(context.Context, *MessageDetailReq) (*MessageDetailResp, error)
-	// 获取指定用户的分类及未读消息数量
+	//  获取指定用户的分类及未读消息数量
 	GetUnreadClassCount(context.Context, *GetUnreadClassCountReq) (*GetUnreadClassCountRes, error)
-	// 获取指定用户收到消息的分类
+	//  获取指定用户收到消息的分类
 	GetMsgType(context.Context, *GetMsgTypeReq) (*GetMsgTypeRes, error)
-	// 查询指定用户的浮标消息
+	//  查询指定用户的浮标消息
 	FindUserBuoyMsg(context.Context, *FindUserBuoyMsgReq) (*FindUserBuoyMsgRes, error)
-	// 一键清空未读消息
+	//   一键清空未读消息
 	ClearUnreadMsg(context.Context, *ClearUnreadMsgReq) (*Response, error)
-	// new用户消息列表
+	//   new用户消息列表
 	UserMsgList(context.Context, *UserMsgListReq) (*UserMsgListRes, error)
-	// 发送微信模版消息
+	//  发送微信模版消息
 	SendWxTmplMsg(context.Context, *WxTmplMsg) (*Response, error)
-	// 官网、移动端首页、工作桌面消息滚动
+	//   官网、移动端首页、工作桌面消息滚动
 	UserUnreadMsgList(context.Context, *UserUnreadMsgListReq) (*UserUnreadMsgListRes, error)
 	mustEmbedUnimplementedMessageServer()
 }