srm同步用户改成同步本公司全部用户

zhangqian

2023-11-27 b4aff74b597ad5604694903cd6b36f355bdfd2a2

 proto/user/user_grpc.pb.go

@@ -1,4 +1,8 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc             v3.19.0
// source: user.proto

package user

@@ -14,11 +18,19 @@
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

const (
   UserService_SyncUser_FullMethodName      = "/user.UserService/SyncUser"
   UserService_UserMenuCheck_FullMethodName = "/user.UserService/UserMenuCheck"
   UserService_SyncAllUser_FullMethodName   = "/user.UserService/SyncAllUser"
)

// UserServiceClient is the client API for UserService service.
//
// 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 UserServiceClient interface {
   SyncUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error)
   UserMenuCheck(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
   SyncAllUser(ctx context.Context, in *AllUserRequest, opts ...grpc.CallOption) (*AllUserResponse, error)
}

type userServiceClient struct {
@@ -31,7 +43,25 @@

func (c *userServiceClient) SyncUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error) {
   out := new(UserResponse)
   err := c.cc.Invoke(ctx, "/user.UserService/SyncUser", in, out, opts...)
   err := c.cc.Invoke(ctx, UserService_SyncUser_FullMethodName, in, out, opts...)
   if err != nil {
      return nil, err
   }
   return out, nil
}

func (c *userServiceClient) UserMenuCheck(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error) {
   out := new(CheckResponse)
   err := c.cc.Invoke(ctx, UserService_UserMenuCheck_FullMethodName, in, out, opts...)
   if err != nil {
      return nil, err
   }
   return out, nil
}

func (c *userServiceClient) SyncAllUser(ctx context.Context, in *AllUserRequest, opts ...grpc.CallOption) (*AllUserResponse, error) {
   out := new(AllUserResponse)
   err := c.cc.Invoke(ctx, UserService_SyncAllUser_FullMethodName, in, out, opts...)
   if err != nil {
      return nil, err
   }
@@ -43,6 +73,8 @@
// for forward compatibility
type UserServiceServer interface {
   SyncUser(context.Context, *UserRequest) (*UserResponse, error)
   UserMenuCheck(context.Context, *CheckRequest) (*CheckResponse, error)
   SyncAllUser(context.Context, *AllUserRequest) (*AllUserResponse, error)
   mustEmbedUnimplementedUserServiceServer()
}

@@ -52,6 +84,12 @@

func (UnimplementedUserServiceServer) SyncUser(context.Context, *UserRequest) (*UserResponse, error) {
   return nil, status.Errorf(codes.Unimplemented, "method SyncUser not implemented")
}
func (UnimplementedUserServiceServer) UserMenuCheck(context.Context, *CheckRequest) (*CheckResponse, error) {
   return nil, status.Errorf(codes.Unimplemented, "method UserMenuCheck not implemented")
}
func (UnimplementedUserServiceServer) SyncAllUser(context.Context, *AllUserRequest) (*AllUserResponse, error) {
   return nil, status.Errorf(codes.Unimplemented, "method SyncAllUser not implemented")
}
func (UnimplementedUserServiceServer) mustEmbedUnimplementedUserServiceServer() {}

@@ -76,10 +114,46 @@
   }
   info := &grpc.UnaryServerInfo{
      Server:     srv,
      FullMethod: "/user.UserService/SyncUser",
      FullMethod: UserService_SyncUser_FullMethodName,
   }
   handler := func(ctx context.Context, req interface{}) (interface{}, error) {
      return srv.(UserServiceServer).SyncUser(ctx, req.(*UserRequest))
   }
   return interceptor(ctx, in, info, handler)
}

func _UserService_UserMenuCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   in := new(CheckRequest)
   if err := dec(in); err != nil {
      return nil, err
   }
   if interceptor == nil {
      return srv.(UserServiceServer).UserMenuCheck(ctx, in)
   }
   info := &grpc.UnaryServerInfo{
      Server:     srv,
      FullMethod: UserService_UserMenuCheck_FullMethodName,
   }
   handler := func(ctx context.Context, req interface{}) (interface{}, error) {
      return srv.(UserServiceServer).UserMenuCheck(ctx, req.(*CheckRequest))
   }
   return interceptor(ctx, in, info, handler)
}

func _UserService_SyncAllUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   in := new(AllUserRequest)
   if err := dec(in); err != nil {
      return nil, err
   }
   if interceptor == nil {
      return srv.(UserServiceServer).SyncAllUser(ctx, in)
   }
   info := &grpc.UnaryServerInfo{
      Server:     srv,
      FullMethod: UserService_SyncAllUser_FullMethodName,
   }
   handler := func(ctx context.Context, req interface{}) (interface{}, error) {
      return srv.(UserServiceServer).SyncAllUser(ctx, req.(*AllUserRequest))
   }
   return interceptor(ctx, in, info, handler)
}
@@ -95,6 +169,14 @@
         MethodName: "SyncUser",
         Handler:    _UserService_SyncUser_Handler,
      },
      {
         MethodName: "UserMenuCheck",
         Handler:    _UserService_UserMenuCheck_Handler,
      },
      {
         MethodName: "SyncAllUser",
         Handler:    _UserService_SyncAllUser_Handler,
      },
   },
   Streams:  []grpc.StreamDesc{},
   Metadata: "user.proto",