wfz 3 gadi atpakaļ
vecāks
revīzija
45c54a58f7

Failā izmaiņas netiks attēlotas, jo tās ir par lielu
+ 454 - 261
api/account/account.pb.go


+ 18 - 0
api/account/account.proto

@@ -86,12 +86,30 @@ service Account {
   };
   // 通过accountID获取Identify信息
   rpc GetIdentifyByAccountID (GetIdentifyByAccountIDRequest) returns (GetIdentifyByAccountIDReply){};
+  // 通过accountID获取Identify信息
+  rpc GetIdentifyByAccountIDAndIsSubscribe (GetIdentifyByAccountIDRequest) returns (GetIdentifyByAccountIDReply){};
+  // 通过accountID获取Identify信息
+  rpc FindIdentifyByAccountIDAndIsSubscribe (FindIdentifyByAccountIDAndIsSubscribeRequest) returns (FindIdentifyByAccountIDAndIsSubscribeReply){};
   // 用户关注
   rpc UserSubscribe (OpenIDAndAppIDRequest) returns (google.protobuf.Empty){};
   // 用户取关
   rpc UserUnsubscribe (OpenIDAndAppIDRequest) returns (google.protobuf.Empty){};
 }
 
+message FindIdentifyByAccountIDAndIsSubscribeRequest{
+  repeated int64 accountIds = 1;
+}
+
+message FindIdentifyByAccountIDAndIsSubscribeReply{
+  repeated FindIdentifyByAccountIDInfo list = 1;
+}
+
+message FindIdentifyByAccountIDInfo{
+  string openId = 1;
+  string appid = 2;
+  int64 accountId  = 3;
+}
+
 message GetGetGzhConfigReply{
   string appId  = 1;// 公众号Id
   string name  = 2;// 公众号名称

+ 76 - 0
api/account/account_grpc.pb.go

@@ -53,6 +53,10 @@ type AccountClient interface {
 	GetUserLoginConfig(ctx context.Context, in *common.GetLoginConfigRequest, opts ...grpc.CallOption) (*common.GetLoginConfigReply, error)
 	// 通过accountID获取Identify信息
 	GetIdentifyByAccountID(ctx context.Context, in *GetIdentifyByAccountIDRequest, opts ...grpc.CallOption) (*GetIdentifyByAccountIDReply, error)
+	// 通过accountID获取Identify信息
+	GetIdentifyByAccountIDAndIsSubscribe(ctx context.Context, in *GetIdentifyByAccountIDRequest, opts ...grpc.CallOption) (*GetIdentifyByAccountIDReply, error)
+	// 通过accountID获取Identify信息
+	FindIdentifyByAccountIDAndIsSubscribe(ctx context.Context, in *FindIdentifyByAccountIDAndIsSubscribeRequest, opts ...grpc.CallOption) (*FindIdentifyByAccountIDAndIsSubscribeReply, error)
 	// 用户关注
 	UserSubscribe(ctx context.Context, in *OpenIDAndAppIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
 	// 用户取关
@@ -238,6 +242,24 @@ func (c *accountClient) GetIdentifyByAccountID(ctx context.Context, in *GetIdent
 	return out, nil
 }
 
+func (c *accountClient) GetIdentifyByAccountIDAndIsSubscribe(ctx context.Context, in *GetIdentifyByAccountIDRequest, opts ...grpc.CallOption) (*GetIdentifyByAccountIDReply, error) {
+	out := new(GetIdentifyByAccountIDReply)
+	err := c.cc.Invoke(ctx, "/api.account.Account/GetIdentifyByAccountIDAndIsSubscribe", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *accountClient) FindIdentifyByAccountIDAndIsSubscribe(ctx context.Context, in *FindIdentifyByAccountIDAndIsSubscribeRequest, opts ...grpc.CallOption) (*FindIdentifyByAccountIDAndIsSubscribeReply, error) {
+	out := new(FindIdentifyByAccountIDAndIsSubscribeReply)
+	err := c.cc.Invoke(ctx, "/api.account.Account/FindIdentifyByAccountIDAndIsSubscribe", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 func (c *accountClient) UserSubscribe(ctx context.Context, in *OpenIDAndAppIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
 	out := new(emptypb.Empty)
 	err := c.cc.Invoke(ctx, "/api.account.Account/UserSubscribe", in, out, opts...)
@@ -293,6 +315,10 @@ type AccountServer interface {
 	GetUserLoginConfig(context.Context, *common.GetLoginConfigRequest) (*common.GetLoginConfigReply, error)
 	// 通过accountID获取Identify信息
 	GetIdentifyByAccountID(context.Context, *GetIdentifyByAccountIDRequest) (*GetIdentifyByAccountIDReply, error)
+	// 通过accountID获取Identify信息
+	GetIdentifyByAccountIDAndIsSubscribe(context.Context, *GetIdentifyByAccountIDRequest) (*GetIdentifyByAccountIDReply, error)
+	// 通过accountID获取Identify信息
+	FindIdentifyByAccountIDAndIsSubscribe(context.Context, *FindIdentifyByAccountIDAndIsSubscribeRequest) (*FindIdentifyByAccountIDAndIsSubscribeReply, error)
 	// 用户关注
 	UserSubscribe(context.Context, *OpenIDAndAppIDRequest) (*emptypb.Empty, error)
 	// 用户取关
@@ -361,6 +387,12 @@ func (UnimplementedAccountServer) GetUserLoginConfig(context.Context, *common.Ge
 func (UnimplementedAccountServer) GetIdentifyByAccountID(context.Context, *GetIdentifyByAccountIDRequest) (*GetIdentifyByAccountIDReply, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetIdentifyByAccountID not implemented")
 }
+func (UnimplementedAccountServer) GetIdentifyByAccountIDAndIsSubscribe(context.Context, *GetIdentifyByAccountIDRequest) (*GetIdentifyByAccountIDReply, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetIdentifyByAccountIDAndIsSubscribe not implemented")
+}
+func (UnimplementedAccountServer) FindIdentifyByAccountIDAndIsSubscribe(context.Context, *FindIdentifyByAccountIDAndIsSubscribeRequest) (*FindIdentifyByAccountIDAndIsSubscribeReply, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method FindIdentifyByAccountIDAndIsSubscribe not implemented")
+}
 func (UnimplementedAccountServer) UserSubscribe(context.Context, *OpenIDAndAppIDRequest) (*emptypb.Empty, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method UserSubscribe not implemented")
 }
@@ -722,6 +754,42 @@ func _Account_GetIdentifyByAccountID_Handler(srv interface{}, ctx context.Contex
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Account_GetIdentifyByAccountIDAndIsSubscribe_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetIdentifyByAccountIDRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(AccountServer).GetIdentifyByAccountIDAndIsSubscribe(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.account.Account/GetIdentifyByAccountIDAndIsSubscribe",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(AccountServer).GetIdentifyByAccountIDAndIsSubscribe(ctx, req.(*GetIdentifyByAccountIDRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Account_FindIdentifyByAccountIDAndIsSubscribe_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(FindIdentifyByAccountIDAndIsSubscribeRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(AccountServer).FindIdentifyByAccountIDAndIsSubscribe(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.account.Account/FindIdentifyByAccountIDAndIsSubscribe",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(AccountServer).FindIdentifyByAccountIDAndIsSubscribe(ctx, req.(*FindIdentifyByAccountIDAndIsSubscribeRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 func _Account_UserSubscribe_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(OpenIDAndAppIDRequest)
 	if err := dec(in); err != nil {
@@ -841,6 +909,14 @@ var Account_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "GetIdentifyByAccountID",
 			Handler:    _Account_GetIdentifyByAccountID_Handler,
 		},
+		{
+			MethodName: "GetIdentifyByAccountIDAndIsSubscribe",
+			Handler:    _Account_GetIdentifyByAccountIDAndIsSubscribe_Handler,
+		},
+		{
+			MethodName: "FindIdentifyByAccountIDAndIsSubscribe",
+			Handler:    _Account_FindIdentifyByAccountIDAndIsSubscribe_Handler,
+		},
 		{
 			MethodName: "UserSubscribe",
 			Handler:    _Account_UserSubscribe_Handler,

+ 1 - 1
js/api/account/account_http_pb.ts

@@ -1,6 +1,6 @@
 // @ts-ignore
 import request from '@/libs/request';
-import {DebugLoginRequest,TokenReply,AuthorizationRequest,RandomNicknameReply,RandomAvatarReply,GetGetGzhConfigReply,RandomAvatarListReply,OpenIDAndAppIDRequest,IdentityInfo,MediaID,MaterialLink,CheckTextRequest,CheckTextReply,GetIdentifyByAccountIDRequest,GetIdentifyByAccountIDReply} from "./account_pb";
+import {DebugLoginRequest,TokenReply,AuthorizationRequest,RandomNicknameReply,RandomAvatarReply,GetGetGzhConfigReply,RandomAvatarListReply,OpenIDAndAppIDRequest,IdentityInfo,MediaID,MaterialLink,CheckTextRequest,CheckTextReply,GetIdentifyByAccountIDRequest,GetIdentifyByAccountIDReply,FindIdentifyByAccountIDAndIsSubscribeRequest,FindIdentifyByAccountIDAndIsSubscribeReply} from "./account_pb";
 import {SexReq,TagListReply,Ids,RandomIntroduceReply,MemeRequest,MemeList,FindChatTopicRequest,ChatTopicList,RandomNum,CommonTextList,RandomNumAndSex,GetLoginConfigRequest,GetLoginConfigReply} from "../common/common_pb";
 
 const AccountService = {

+ 11 - 0
js/api/account/account_pb.ts

@@ -1,3 +1,14 @@
+export interface FindIdentifyByAccountIDAndIsSubscribeRequest{
+    accountIds?:Array<number>;
+}
+export interface FindIdentifyByAccountIDAndIsSubscribeReply{
+    list?:Array<FindIdentifyByAccountIDInfo>;
+}
+export interface FindIdentifyByAccountIDInfo{
+    openId?:string;
+    appid?:string;
+    accountId?:number;
+}
 export interface GetGetGzhConfigReply{
     /**  公众号Id */
     appId?:string;

Daži faili netika attēloti, jo izmaiņu fails ir pārāk liels