当前在线人

api/partner/partner.proto

@@ -452,6 +452,13 @@ service Partner {
       body:"*"
     };
   };
+  // 当前在线人
+  rpc OnlinePerson (google.protobuf.Empty) returns (OnlinePersonReply){
+    option (google.api.http) = {
+      post: "/api/manager/online/person",
+      body:"*"
+    };
+  };
 
   // ---rpc---
   // 1、获取用户详情
@@ -479,6 +486,15 @@ service Partner {
   rpc SendOverOneMinuteUnreadMessageMessage (SendOverOneMinuteUnreadMessageMessageRequest) returns (google.protobuf.Empty){};
 }
 
+message OnlinePersonReply{
+  int64 userManNum = 1; // 男用户在线数
+  int64 userWomanNum = 2; // 女用户在线数
+  int64 partnerManNum = 3; // 男接待员在线数
+  int64 partnerWomanNum = 4; // 女接待员在线数
+  int64 userOtherNum = 5; // 未填写性别的用户在线数
+  int64 partnerOtherNum = 6; // 未填写性别的接待员在线数
+}
+
 message SendOverOneMinuteUnreadMessageMessageRequest{
   string personID = 1;
   int64 unreadNum = 2;

api/partner/partner_grpc.pb.go

@@ -145,6 +145,8 @@ type PartnerClient interface {
 	ManagerLogin(ctx context.Context, in *common.ManagerLoginRequest, opts ...grpc.CallOption) (*common.LoginToken, error)
 	// 审核记录列表
 	FindExamineRecordList(ctx context.Context, in *FindExamineRecordListRequest, opts ...grpc.CallOption) (*FindExamineRecordListReply, error)
+	// 当前在线人
+	OnlinePerson(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonReply, error)
 	// ---rpc---
 	// 1、获取用户详情
 	GetPartnerDBMsg(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*common.PersonMsg, error)
@@ -727,6 +729,15 @@ func (c *partnerClient) FindExamineRecordList(ctx context.Context, in *FindExami
 	return out, nil
 }
 
+func (c *partnerClient) OnlinePerson(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonReply, error) {
+	out := new(OnlinePersonReply)
+	err := c.cc.Invoke(ctx, "/api.partner.Partner/OnlinePerson", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 func (c *partnerClient) GetPartnerDBMsg(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*common.PersonMsg, error) {
 	out := new(common.PersonMsg)
 	err := c.cc.Invoke(ctx, "/api.partner.Partner/GetPartnerDBMsg", in, out, opts...)
@@ -953,6 +964,8 @@ type PartnerServer interface {
 	ManagerLogin(context.Context, *common.ManagerLoginRequest) (*common.LoginToken, error)
 	// 审核记录列表
 	FindExamineRecordList(context.Context, *FindExamineRecordListRequest) (*FindExamineRecordListReply, error)
+	// 当前在线人
+	OnlinePerson(context.Context, *emptypb.Empty) (*OnlinePersonReply, error)
 	// ---rpc---
 	// 1、获取用户详情
 	GetPartnerDBMsg(context.Context, *common.PersonIDParam) (*common.PersonMsg, error)
@@ -1166,6 +1179,9 @@ func (UnimplementedPartnerServer) ManagerLogin(context.Context, *common.ManagerL
 func (UnimplementedPartnerServer) FindExamineRecordList(context.Context, *FindExamineRecordListRequest) (*FindExamineRecordListReply, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method FindExamineRecordList not implemented")
 }
+func (UnimplementedPartnerServer) OnlinePerson(context.Context, *emptypb.Empty) (*OnlinePersonReply, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method OnlinePerson not implemented")
+}
 func (UnimplementedPartnerServer) GetPartnerDBMsg(context.Context, *common.PersonIDParam) (*common.PersonMsg, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetPartnerDBMsg not implemented")
 }
@@ -2310,6 +2326,24 @@ func _Partner_FindExamineRecordList_Handler(srv interface{}, ctx context.Context
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Partner_OnlinePerson_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(emptypb.Empty)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(PartnerServer).OnlinePerson(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.partner.Partner/OnlinePerson",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(PartnerServer).OnlinePerson(ctx, req.(*emptypb.Empty))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 func _Partner_GetPartnerDBMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(common.PersonIDParam)
 	if err := dec(in); err != nil {
@@ -2759,6 +2793,10 @@ var Partner_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "FindExamineRecordList",
 			Handler:    _Partner_FindExamineRecordList_Handler,
 		},
+		{
+			MethodName: "OnlinePerson",
+			Handler:    _Partner_OnlinePerson_Handler,
+		},
 		{
 			MethodName: "GetPartnerDBMsg",
 			Handler:    _Partner_GetPartnerDBMsg_Handler,

api/partner/partner_http.pb.go

@@ -66,6 +66,7 @@ type PartnerHTTPServer interface {
 	GetPartnerMessage(context.Context, *emptypb.Empty) (*PartnerMessage, error)
 	GetPartnerRoomByPerson(context.Context, *common.PersonParam) (*chat.PartnerRoomInfo, error)
 	ManagerLogin(context.Context, *common.ManagerLoginRequest) (*common.LoginToken, error)
+	OnlinePerson(context.Context, *emptypb.Empty) (*OnlinePersonReply, error)
 	PartnerApplyWithdraw(context.Context, *PartnerApplyWithdrawRequest) (*emptypb.Empty, error)
 	PartnerCollect(context.Context, *PartnerCollectIDsRequest) (*emptypb.Empty, error)
 	PartnerDeleteChat(context.Context, *common.RoomIDRequest) (*emptypb.Empty, error)
@@ -156,6 +157,7 @@ func RegisterPartnerHTTPServer(s *http.Server, srv PartnerHTTPServer) {
 	r.POST("/api/partner/register/examine", _Partner_ExaminePartner0_HTTP_Handler(srv))
 	r.POST("/api/manager/login", _Partner_ManagerLogin0_HTTP_Handler(srv))
 	r.POST("/api/manager/register/examine/record/list", _Partner_FindExamineRecordList0_HTTP_Handler(srv))
+	r.POST("/api/manager/online/person", _Partner_OnlinePerson0_HTTP_Handler(srv))
 }
 
 func _Partner_GetPartnerInfo0_HTTP_Handler(srv PartnerHTTPServer) func(ctx http.Context) error {
@@ -1805,6 +1807,33 @@ func _Partner_FindExamineRecordList0_HTTP_Handler(srv PartnerHTTPServer) func(ct
 	}
 }
 
+func _Partner_OnlinePerson0_HTTP_Handler(srv PartnerHTTPServer) func(ctx http.Context) error {
+	return func(ctx http.Context) error {
+		var in emptypb.Empty
+		if err := ctx.Bind(&in); err != nil {
+			return err
+		}
+		if err := ctx.BindQuery(&in); err != nil {
+			return err
+		}
+		http.SetOperation(ctx, "/api.partner.Partner/OnlinePerson")
+		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
+			return srv.OnlinePerson(ctx, req.(*emptypb.Empty))
+		})
+		out, err := h(ctx, &in)
+		if err != nil {
+			return err
+		}
+		success := &reply.SuccessReply{
+			Code: 0,
+		}
+		if out != nil {
+			success.Data = out
+		}
+		return ctx.Result(200, success)
+	}
+}
+
 type PartnerHTTPClient interface {
 	CheckPhoneCode(ctx context.Context, req *common.CheckPhoneCodeRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
 	CreateScrip(ctx context.Context, req *CreateScripRequest, opts ...http.CallOption) (rsp *common.ScripID, err error)
@@ -1842,6 +1871,7 @@ type PartnerHTTPClient interface {
 	GetPartnerMessage(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *PartnerMessage, err error)
 	GetPartnerRoomByPerson(ctx context.Context, req *common.PersonParam, opts ...http.CallOption) (rsp *chat.PartnerRoomInfo, err error)
 	ManagerLogin(ctx context.Context, req *common.ManagerLoginRequest, opts ...http.CallOption) (rsp *common.LoginToken, err error)
+	OnlinePerson(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *OnlinePersonReply, err error)
 	PartnerApplyWithdraw(ctx context.Context, req *PartnerApplyWithdrawRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
 	PartnerCollect(ctx context.Context, req *PartnerCollectIDsRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
 	PartnerDeleteChat(ctx context.Context, req *common.RoomIDRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
@@ -2345,6 +2375,19 @@ func (c *PartnerHTTPClientImpl) ManagerLogin(ctx context.Context, in *common.Man
 	return &out, err
 }
 
+func (c *PartnerHTTPClientImpl) OnlinePerson(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*OnlinePersonReply, error) {
+	var out OnlinePersonReply
+	pattern := "/api/manager/online/person"
+	path := binding.EncodeURL(pattern, in, false)
+	opts = append(opts, http.Operation("/api.partner.Partner/OnlinePerson"))
+	opts = append(opts, http.PathTemplate(pattern))
+	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return &out, err
+}
+
 func (c *PartnerHTTPClientImpl) PartnerApplyWithdraw(ctx context.Context, in *PartnerApplyWithdrawRequest, opts ...http.CallOption) (*emptypb.Empty, error) {
 	var out emptypb.Empty
 	pattern := "/api/partner/withdraw"

js/api/partner/partner_http_pb.ts

@@ -1,6 +1,6 @@
 // @ts-ignore
 import request from '@/libs/request';
-import {PartnerInfo,PartnerBalance,CreateScripRequest,ReplyScripRequest,PartnerCollectIDsRequest,PartnerCollectRequest,PartnerMessage,LevelTable,PartnerGetAwardRequest,PartnerUpdateWorkingStatusRequest,PartnerApplyWithdrawRequest,PartnerWithdrawTemplateListReply,PartnerWithdrawRecordListReply,PartnerGetRoomBalanceAndTodayBalanceReply,FindExamineListReply,ExaminePartnerRequest,FindExamineRecordListRequest,FindExamineRecordListReply,PartnerDBBalance,AddPartnerBalanceRequest,GetRecommendPartnerDBRequest,SendOverOneMinuteUnreadMessageMessageRequest} from "./partner_pb";
+import {PartnerInfo,PartnerBalance,CreateScripRequest,ReplyScripRequest,PartnerCollectIDsRequest,PartnerCollectRequest,PartnerMessage,LevelTable,PartnerGetAwardRequest,PartnerUpdateWorkingStatusRequest,PartnerApplyWithdrawRequest,PartnerWithdrawTemplateListReply,PartnerWithdrawRecordListReply,PartnerGetRoomBalanceAndTodayBalanceReply,FindExamineListReply,ExaminePartnerRequest,FindExamineRecordListRequest,FindExamineRecordListReply,OnlinePersonReply,PartnerDBBalance,AddPartnerBalanceRequest,GetRecommendPartnerDBRequest,SendOverOneMinuteUnreadMessageMessageRequest} from "./partner_pb";
 import {SendPhoneCodeRequest,CheckPhoneCodeRequest,UpdateInformationRequest,CreateChatRoomParam,PersonParam,HomeInfo,LookedAndLikedNum,ListPageRequest,WxConfReq,WxConfResponse,SexReq,TagListReply,ListPage2Request,RecommendPersonListReply,FindChatRecordListRequest,ChatRecordListReply,FindChatRoomMsgRequest,ChatRoomMsg,IsLike,MemeRequest,MemeList,FindChatTopicRequest,ChatTopicList,RandomNum,CommonTextList,RandomNumAndSex,MemeTitleList,PartnerChatCardInfo,ReportChatRequest,FindOverSevenDayAvatarReply,UpdateLastScripIDRequest,ScripID,ScripIdRequest,ScripReply,FindScripRequest,ScripInfo,ChatRecordInfo,RoomIDRequest,ManagerLoginRequest,LoginToken,PersonIDParam,PersonMsg,PersonIDList,PersonDBReply,UpdateLastScripIDDBRequest,FindRecommendRequest,PartnerIDParam,AddFriendMessageInfo,PersonDB} from "../common/common_pb";
 import {RoomReply,PartnerFindRoomListReply,UnreadNumReply,PartnerRoomInfo,FindNotReplyNumReply} from "../chat/chat_pb";
 import {LookAndLikeListReply,LookMessageReply} from "../statistics/statistics_pb";
@@ -312,6 +312,11 @@ const PartnerService = {
 	const res = await request.post<{ data: FindExamineRecordListReply, code: string, message: string }>('/api/manager/register/examine/record/list', req);
     return res.data.data;
   },
+  /**  当前在线人 */
+  OnlinePerson: async (req?: undefined) => {
+	const res = await request.post<{ data: OnlinePersonReply, code: string, message: string }>('/api/manager/online/person', req);
+    return res.data.data;
+  },
 
 };
 

js/api/partner/partner_pb.ts

@@ -1,5 +1,19 @@
 import {Message} from "../common/common_pb";
 
+export interface OnlinePersonReply{
+    /**  男用户在线数 */
+    userManNum?:number;
+    /**  女用户在线数 */
+    userWomanNum?:number;
+    /**  男接待员在线数 */
+    partnerManNum?:number;
+    /**  女接待员在线数 */
+    partnerWomanNum?:number;
+    /**  未填写性别的用户在线数 */
+    userOtherNum?:number;
+    /**  未填写性别的接待员在线数 */
+    partnerOtherNum?:number;
+}
 export interface SendOverOneMinuteUnreadMessageMessageRequest{
     personID?:string;
     unreadNum?:number;