| | |
| | | } |
| | | |
| | | grpcServerConf struct { |
| | | ApsAddr string //aps服务grpc地址 |
| | | CrmAddr string //crm服务grpc地址 |
| | | SrmAddr string //srm服务grpc地址 |
| | | AdminAddr string //admin服务grpc地址 |
| | | ApsAddr string //aps服务grpc地址 |
| | | CrmAddr string //crm服务grpc地址 |
| | | SrmAddr string //srm服务grpc地址 |
| | | } |
| | | |
| | | fileTemplateConf struct { |
| | |
| | | nodeId := os.Getenv("NODE_ID") // 主账户用户名 |
| | | host := os.Getenv("HOST") // 本机IP地址 |
| | | GrpcPort := os.Getenv("WMS_GRPC") // 只对外提供grpc服务,本服务不用 |
| | | adminAddr := os.Getenv("ADMIN_GRPC") |
| | | apsAddr := os.Getenv("APS_GRPC") |
| | | crmAddr := os.Getenv("CRM_GRPC") |
| | | srmAddr := os.Getenv("SRM_GRPC") |
| | |
| | | if len(host) > 0 { |
| | | WebConf.Host = host |
| | | } |
| | | if len(adminAddr) > 0 { |
| | | GrpcServerConf.AdminAddr = adminAddr |
| | | } |
| | | if len(apsAddr) > 0 { |
| | | GrpcServerConf.ApsAddr = apsAddr |
| | | } |
| | |
| | | ) |
| | | |
| | | var ( |
| | | ApsConn *grpc.ClientConn |
| | | CrmConn *grpc.ClientConn |
| | | SrmConn *grpc.ClientConn |
| | | AdminConn *grpc.ClientConn |
| | | ApsConn *grpc.ClientConn |
| | | CrmConn *grpc.ClientConn |
| | | SrmConn *grpc.ClientConn |
| | | ) |
| | | |
| | | func InitClient() { |
| | | var err error |
| | | AdminConn, err = grpc.Dial(conf.GrpcServerConf.AdminAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) |
| | | if err != nil { |
| | | logx.Errorf("grpc dial product service error: %v", err.Error()) |
| | | return |
| | | } |
| | | ApsConn, err = grpc.Dial(conf.GrpcServerConf.ApsAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) |
| | | if err != nil { |
| | | logx.Errorf("grpc dial product service error: %v", err.Error()) |
| | |
| | | } |
| | | |
| | | func CloseClient() { |
| | | if AdminConn != nil { |
| | | AdminConn.Close() |
| | | } |
| | | if ApsConn != nil { |
| | | ApsConn.Close() |
| | | } |
New file |
| | |
| | | syntax = "proto3"; |
| | | |
| | | package user; |
| | | |
| | | option go_package = "./user"; |
| | | |
| | | service UserService { |
| | | rpc SyncUser(UserRequest) returns (UserResponse); |
| | | rpc UserMenuCheck(CheckRequest) returns (CheckResponse); |
| | | rpc SyncAllUser(AllUserRequest) returns (AllUserResponse); |
| | | rpc GetUserList(GetUserRequest) returns (GetUserResponse); |
| | | } |
| | | |
| | | message User { |
| | | string uuid = 1; |
| | | string username = 2; |
| | | int32 usertype = 3; |
| | | string nickname = 4; |
| | | repeated string sub_user_ids = 5; |
| | | bool sub_user_queried = 6; |
| | | } |
| | | |
| | | message UserRequest { |
| | | repeated User users = 1; |
| | | } |
| | | |
| | | message UserResponse { |
| | | int32 code = 1; |
| | | string message = 2; |
| | | repeated User List = 3; |
| | | int64 total = 4; |
| | | } |
| | | |
| | | message CheckRequest { |
| | | string apiPath = 1; //接口路径 |
| | | int32 SystemType = 2; //系统名称 |
| | | } |
| | | |
| | | message CheckResponse { |
| | | int32 code = 1; |
| | | string message = 2; |
| | | bool result = 3; |
| | | } |
| | | |
| | | message AllUserRequest { |
| | | int32 SystemType = 1; //系统名称 |
| | | } |
| | | |
| | | message UserSimple { |
| | | string uuid = 1; |
| | | string username = 2; |
| | | int32 usertype = 3; |
| | | string nickname = 4; |
| | | } |
| | | |
| | | message AllUserResponse { |
| | | int32 code = 1; |
| | | string message = 2; |
| | | repeated UserSimple List = 3; |
| | | int64 total = 4; |
| | | } |
| | | |
| | | message GetUserRequest { |
| | | string id = 1; |
| | | string userName = 2; |
| | | int32 userType = 3; |
| | | string nickName = 4; |
| | | string parentId = 5; |
| | | string pos = 6; |
| | | } |
| | | |
| | | message GetUserResponse { |
| | | int32 code = 1; |
| | | string message = 2; |
| | | repeated GetUserRequest List = 3; |
| | | int64 total = 4; |
| | | } |
New file |
| | |
| | | package user |
| | | |
| | | import ( |
| | | "context" |
| | | "wms/pkg/logx" |
| | | "wms/proto/init_client" |
| | | ) |
| | | |
| | | func GetUserList() ([]*GetUserRequest, error) { |
| | | cli := NewUserServiceClient(init_client.AdminConn) |
| | | list, err := cli.GetUserList(context.Background(), &GetUserRequest{}) |
| | | if err != nil { |
| | | logx.Error("grpc调用失败, GetPersonnelList err : " + err.Error()) |
| | | return nil, err |
| | | } |
| | | return list.List, nil |
| | | } |
New file |
| | |
| | | // Code generated by protoc-gen-go. DO NOT EDIT. |
| | | // versions: |
| | | // protoc-gen-go v1.34.2 |
| | | // protoc v3.20.3 |
| | | // source: user.proto |
| | | |
| | | package user |
| | | |
| | | import ( |
| | | protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| | | protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| | | reflect "reflect" |
| | | sync "sync" |
| | | ) |
| | | |
| | | const ( |
| | | // Verify that this generated code is sufficiently up-to-date. |
| | | _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) |
| | | // Verify that runtime/protoimpl is sufficiently up-to-date. |
| | | _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) |
| | | ) |
| | | |
| | | type User struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` |
| | | Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` |
| | | Usertype int32 `protobuf:"varint,3,opt,name=usertype,proto3" json:"usertype,omitempty"` |
| | | Nickname string `protobuf:"bytes,4,opt,name=nickname,proto3" json:"nickname,omitempty"` |
| | | SubUserIds []string `protobuf:"bytes,5,rep,name=sub_user_ids,json=subUserIds,proto3" json:"sub_user_ids,omitempty"` |
| | | SubUserQueried bool `protobuf:"varint,6,opt,name=sub_user_queried,json=subUserQueried,proto3" json:"sub_user_queried,omitempty"` |
| | | } |
| | | |
| | | func (x *User) Reset() { |
| | | *x = User{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[0] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *User) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*User) ProtoMessage() {} |
| | | |
| | | func (x *User) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[0] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use User.ProtoReflect.Descriptor instead. |
| | | func (*User) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{0} |
| | | } |
| | | |
| | | func (x *User) GetUuid() string { |
| | | if x != nil { |
| | | return x.Uuid |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *User) GetUsername() string { |
| | | if x != nil { |
| | | return x.Username |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *User) GetUsertype() int32 { |
| | | if x != nil { |
| | | return x.Usertype |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | func (x *User) GetNickname() string { |
| | | if x != nil { |
| | | return x.Nickname |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *User) GetSubUserIds() []string { |
| | | if x != nil { |
| | | return x.SubUserIds |
| | | } |
| | | return nil |
| | | } |
| | | |
| | | func (x *User) GetSubUserQueried() bool { |
| | | if x != nil { |
| | | return x.SubUserQueried |
| | | } |
| | | return false |
| | | } |
| | | |
| | | type UserRequest struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"` |
| | | } |
| | | |
| | | func (x *UserRequest) Reset() { |
| | | *x = UserRequest{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[1] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *UserRequest) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*UserRequest) ProtoMessage() {} |
| | | |
| | | func (x *UserRequest) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[1] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use UserRequest.ProtoReflect.Descriptor instead. |
| | | func (*UserRequest) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{1} |
| | | } |
| | | |
| | | func (x *UserRequest) GetUsers() []*User { |
| | | if x != nil { |
| | | return x.Users |
| | | } |
| | | return nil |
| | | } |
| | | |
| | | type UserResponse struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` |
| | | Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` |
| | | List []*User `protobuf:"bytes,3,rep,name=List,proto3" json:"List,omitempty"` |
| | | Total int64 `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"` |
| | | } |
| | | |
| | | func (x *UserResponse) Reset() { |
| | | *x = UserResponse{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[2] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *UserResponse) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*UserResponse) ProtoMessage() {} |
| | | |
| | | func (x *UserResponse) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[2] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use UserResponse.ProtoReflect.Descriptor instead. |
| | | func (*UserResponse) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{2} |
| | | } |
| | | |
| | | func (x *UserResponse) GetCode() int32 { |
| | | if x != nil { |
| | | return x.Code |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | func (x *UserResponse) GetMessage() string { |
| | | if x != nil { |
| | | return x.Message |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *UserResponse) GetList() []*User { |
| | | if x != nil { |
| | | return x.List |
| | | } |
| | | return nil |
| | | } |
| | | |
| | | func (x *UserResponse) GetTotal() int64 { |
| | | if x != nil { |
| | | return x.Total |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | type CheckRequest struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | ApiPath string `protobuf:"bytes,1,opt,name=apiPath,proto3" json:"apiPath,omitempty"` //接口路径 |
| | | SystemType int32 `protobuf:"varint,2,opt,name=SystemType,proto3" json:"SystemType,omitempty"` //系统名称 |
| | | } |
| | | |
| | | func (x *CheckRequest) Reset() { |
| | | *x = CheckRequest{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[3] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *CheckRequest) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*CheckRequest) ProtoMessage() {} |
| | | |
| | | func (x *CheckRequest) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[3] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead. |
| | | func (*CheckRequest) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{3} |
| | | } |
| | | |
| | | func (x *CheckRequest) GetApiPath() string { |
| | | if x != nil { |
| | | return x.ApiPath |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *CheckRequest) GetSystemType() int32 { |
| | | if x != nil { |
| | | return x.SystemType |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | type CheckResponse struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` |
| | | Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` |
| | | Result bool `protobuf:"varint,3,opt,name=result,proto3" json:"result,omitempty"` |
| | | } |
| | | |
| | | func (x *CheckResponse) Reset() { |
| | | *x = CheckResponse{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[4] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *CheckResponse) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*CheckResponse) ProtoMessage() {} |
| | | |
| | | func (x *CheckResponse) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[4] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead. |
| | | func (*CheckResponse) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{4} |
| | | } |
| | | |
| | | func (x *CheckResponse) GetCode() int32 { |
| | | if x != nil { |
| | | return x.Code |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | func (x *CheckResponse) GetMessage() string { |
| | | if x != nil { |
| | | return x.Message |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *CheckResponse) GetResult() bool { |
| | | if x != nil { |
| | | return x.Result |
| | | } |
| | | return false |
| | | } |
| | | |
| | | type AllUserRequest struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | SystemType int32 `protobuf:"varint,1,opt,name=SystemType,proto3" json:"SystemType,omitempty"` //系统名称 |
| | | } |
| | | |
| | | func (x *AllUserRequest) Reset() { |
| | | *x = AllUserRequest{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[5] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *AllUserRequest) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*AllUserRequest) ProtoMessage() {} |
| | | |
| | | func (x *AllUserRequest) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[5] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use AllUserRequest.ProtoReflect.Descriptor instead. |
| | | func (*AllUserRequest) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{5} |
| | | } |
| | | |
| | | func (x *AllUserRequest) GetSystemType() int32 { |
| | | if x != nil { |
| | | return x.SystemType |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | type UserSimple struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` |
| | | Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` |
| | | Usertype int32 `protobuf:"varint,3,opt,name=usertype,proto3" json:"usertype,omitempty"` |
| | | Nickname string `protobuf:"bytes,4,opt,name=nickname,proto3" json:"nickname,omitempty"` |
| | | } |
| | | |
| | | func (x *UserSimple) Reset() { |
| | | *x = UserSimple{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[6] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *UserSimple) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*UserSimple) ProtoMessage() {} |
| | | |
| | | func (x *UserSimple) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[6] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use UserSimple.ProtoReflect.Descriptor instead. |
| | | func (*UserSimple) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{6} |
| | | } |
| | | |
| | | func (x *UserSimple) GetUuid() string { |
| | | if x != nil { |
| | | return x.Uuid |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *UserSimple) GetUsername() string { |
| | | if x != nil { |
| | | return x.Username |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *UserSimple) GetUsertype() int32 { |
| | | if x != nil { |
| | | return x.Usertype |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | func (x *UserSimple) GetNickname() string { |
| | | if x != nil { |
| | | return x.Nickname |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | type AllUserResponse struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` |
| | | Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` |
| | | List []*UserSimple `protobuf:"bytes,3,rep,name=List,proto3" json:"List,omitempty"` |
| | | Total int64 `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"` |
| | | } |
| | | |
| | | func (x *AllUserResponse) Reset() { |
| | | *x = AllUserResponse{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[7] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *AllUserResponse) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*AllUserResponse) ProtoMessage() {} |
| | | |
| | | func (x *AllUserResponse) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[7] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use AllUserResponse.ProtoReflect.Descriptor instead. |
| | | func (*AllUserResponse) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{7} |
| | | } |
| | | |
| | | func (x *AllUserResponse) GetCode() int32 { |
| | | if x != nil { |
| | | return x.Code |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | func (x *AllUserResponse) GetMessage() string { |
| | | if x != nil { |
| | | return x.Message |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *AllUserResponse) GetList() []*UserSimple { |
| | | if x != nil { |
| | | return x.List |
| | | } |
| | | return nil |
| | | } |
| | | |
| | | func (x *AllUserResponse) GetTotal() int64 { |
| | | if x != nil { |
| | | return x.Total |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | type GetUserRequest struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` |
| | | UserName string `protobuf:"bytes,2,opt,name=userName,proto3" json:"userName,omitempty"` |
| | | UserType int32 `protobuf:"varint,3,opt,name=userType,proto3" json:"userType,omitempty"` |
| | | NickName string `protobuf:"bytes,4,opt,name=nickName,proto3" json:"nickName,omitempty"` |
| | | ParentId string `protobuf:"bytes,5,opt,name=parentId,proto3" json:"parentId,omitempty"` |
| | | Pos string `protobuf:"bytes,6,opt,name=pos,proto3" json:"pos,omitempty"` |
| | | } |
| | | |
| | | func (x *GetUserRequest) Reset() { |
| | | *x = GetUserRequest{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[8] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *GetUserRequest) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*GetUserRequest) ProtoMessage() {} |
| | | |
| | | func (x *GetUserRequest) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[8] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use GetUserRequest.ProtoReflect.Descriptor instead. |
| | | func (*GetUserRequest) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{8} |
| | | } |
| | | |
| | | func (x *GetUserRequest) GetId() string { |
| | | if x != nil { |
| | | return x.Id |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *GetUserRequest) GetUserName() string { |
| | | if x != nil { |
| | | return x.UserName |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *GetUserRequest) GetUserType() int32 { |
| | | if x != nil { |
| | | return x.UserType |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | func (x *GetUserRequest) GetNickName() string { |
| | | if x != nil { |
| | | return x.NickName |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *GetUserRequest) GetParentId() string { |
| | | if x != nil { |
| | | return x.ParentId |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *GetUserRequest) GetPos() string { |
| | | if x != nil { |
| | | return x.Pos |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | type GetUserResponse struct { |
| | | state protoimpl.MessageState |
| | | sizeCache protoimpl.SizeCache |
| | | unknownFields protoimpl.UnknownFields |
| | | |
| | | Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` |
| | | Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` |
| | | List []*GetUserRequest `protobuf:"bytes,3,rep,name=List,proto3" json:"List,omitempty"` |
| | | Total int64 `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"` |
| | | } |
| | | |
| | | func (x *GetUserResponse) Reset() { |
| | | *x = GetUserResponse{} |
| | | if protoimpl.UnsafeEnabled { |
| | | mi := &file_user_proto_msgTypes[9] |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | } |
| | | |
| | | func (x *GetUserResponse) String() string { |
| | | return protoimpl.X.MessageStringOf(x) |
| | | } |
| | | |
| | | func (*GetUserResponse) ProtoMessage() {} |
| | | |
| | | func (x *GetUserResponse) ProtoReflect() protoreflect.Message { |
| | | mi := &file_user_proto_msgTypes[9] |
| | | if protoimpl.UnsafeEnabled && x != nil { |
| | | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| | | if ms.LoadMessageInfo() == nil { |
| | | ms.StoreMessageInfo(mi) |
| | | } |
| | | return ms |
| | | } |
| | | return mi.MessageOf(x) |
| | | } |
| | | |
| | | // Deprecated: Use GetUserResponse.ProtoReflect.Descriptor instead. |
| | | func (*GetUserResponse) Descriptor() ([]byte, []int) { |
| | | return file_user_proto_rawDescGZIP(), []int{9} |
| | | } |
| | | |
| | | func (x *GetUserResponse) GetCode() int32 { |
| | | if x != nil { |
| | | return x.Code |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | func (x *GetUserResponse) GetMessage() string { |
| | | if x != nil { |
| | | return x.Message |
| | | } |
| | | return "" |
| | | } |
| | | |
| | | func (x *GetUserResponse) GetList() []*GetUserRequest { |
| | | if x != nil { |
| | | return x.List |
| | | } |
| | | return nil |
| | | } |
| | | |
| | | func (x *GetUserResponse) GetTotal() int64 { |
| | | if x != nil { |
| | | return x.Total |
| | | } |
| | | return 0 |
| | | } |
| | | |
| | | var File_user_proto protoreflect.FileDescriptor |
| | | |
| | | var file_user_proto_rawDesc = []byte{ |
| | | 0x0a, 0x0a, 0x75, 0x73, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x04, 0x75, 0x73, |
| | | 0x65, 0x72, 0x22, 0xba, 0x01, 0x0a, 0x04, 0x55, 0x73, 0x65, 0x72, 0x12, 0x12, 0x0a, 0x04, 0x75, |
| | | 0x75, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, |
| | | 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, |
| | | 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x75, |
| | | 0x73, 0x65, 0x72, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x75, |
| | | 0x73, 0x65, 0x72, 0x74, 0x79, 0x70, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x6e, 0x69, 0x63, 0x6b, 0x6e, |
| | | 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6e, 0x69, 0x63, 0x6b, 0x6e, |
| | | 0x61, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0c, 0x73, 0x75, 0x62, 0x5f, 0x75, 0x73, 0x65, 0x72, 0x5f, |
| | | 0x69, 0x64, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x75, 0x62, 0x55, 0x73, |
| | | 0x65, 0x72, 0x49, 0x64, 0x73, 0x12, 0x28, 0x0a, 0x10, 0x73, 0x75, 0x62, 0x5f, 0x75, 0x73, 0x65, |
| | | 0x72, 0x5f, 0x71, 0x75, 0x65, 0x72, 0x69, 0x65, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, |
| | | 0x0e, 0x73, 0x75, 0x62, 0x55, 0x73, 0x65, 0x72, 0x51, 0x75, 0x65, 0x72, 0x69, 0x65, 0x64, 0x22, |
| | | 0x2f, 0x0a, 0x0b, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x20, |
| | | 0x0a, 0x05, 0x75, 0x73, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0a, 0x2e, |
| | | 0x75, 0x73, 0x65, 0x72, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x52, 0x05, 0x75, 0x73, 0x65, 0x72, 0x73, |
| | | 0x22, 0x72, 0x0a, 0x0c, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, |
| | | 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, |
| | | 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, |
| | | 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x1e, |
| | | 0x0a, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0a, 0x2e, 0x75, |
| | | 0x73, 0x65, 0x72, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x52, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x14, |
| | | 0x0a, 0x05, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x74, |
| | | 0x6f, 0x74, 0x61, 0x6c, 0x22, 0x48, 0x0a, 0x0c, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x71, |
| | | 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x70, 0x69, 0x50, 0x61, 0x74, 0x68, 0x18, |
| | | 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x70, 0x69, 0x50, 0x61, 0x74, 0x68, 0x12, 0x1e, |
| | | 0x0a, 0x0a, 0x53, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, |
| | | 0x28, 0x05, 0x52, 0x0a, 0x53, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, 0x65, 0x22, 0x55, |
| | | 0x0a, 0x0d, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, |
| | | 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x63, |
| | | 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, |
| | | 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x16, 0x0a, |
| | | 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x72, |
| | | 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x30, 0x0a, 0x0e, 0x41, 0x6c, 0x6c, 0x55, 0x73, 0x65, 0x72, |
| | | 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1e, 0x0a, 0x0a, 0x53, 0x79, 0x73, 0x74, 0x65, |
| | | 0x6d, 0x54, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x53, 0x79, 0x73, |
| | | 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, 0x65, 0x22, 0x74, 0x0a, 0x0a, 0x55, 0x73, 0x65, 0x72, 0x53, |
| | | 0x69, 0x6d, 0x70, 0x6c, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x01, 0x20, |
| | | 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, |
| | | 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, |
| | | 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x74, 0x79, 0x70, |
| | | 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x74, 0x79, 0x70, |
| | | 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x6e, 0x69, 0x63, 0x6b, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, |
| | | 0x01, 0x28, 0x09, 0x52, 0x08, 0x6e, 0x69, 0x63, 0x6b, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x7b, 0x0a, |
| | | 0x0f, 0x41, 0x6c, 0x6c, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, |
| | | 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, |
| | | 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, |
| | | 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x24, |
| | | 0x0a, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x10, 0x2e, 0x75, |
| | | 0x73, 0x65, 0x72, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x53, 0x69, 0x6d, 0x70, 0x6c, 0x65, 0x52, 0x04, |
| | | 0x4c, 0x69, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x04, 0x20, |
| | | 0x01, 0x28, 0x03, 0x52, 0x05, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x22, 0xa2, 0x01, 0x0a, 0x0e, 0x47, |
| | | 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, |
| | | 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x1a, 0x0a, |
| | | 0x08, 0x75, 0x73, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, |
| | | 0x08, 0x75, 0x73, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, |
| | | 0x72, 0x54, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x75, 0x73, 0x65, |
| | | 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x6e, 0x69, 0x63, 0x6b, 0x4e, 0x61, 0x6d, |
| | | 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6e, 0x69, 0x63, 0x6b, 0x4e, 0x61, 0x6d, |
| | | 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x05, 0x20, |
| | | 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x10, 0x0a, |
| | | 0x03, 0x70, 0x6f, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x70, 0x6f, 0x73, 0x22, |
| | | 0x7f, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, |
| | | 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, |
| | | 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, |
| | | 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, |
| | | 0x12, 0x28, 0x0a, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14, |
| | | 0x2e, 0x75, 0x73, 0x65, 0x72, 0x2e, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, |
| | | 0x75, 0x65, 0x73, 0x74, 0x52, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, |
| | | 0x74, 0x61, 0x6c, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x74, 0x6f, 0x74, 0x61, 0x6c, |
| | | 0x32, 0xf2, 0x01, 0x0a, 0x0b, 0x55, 0x73, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, |
| | | 0x12, 0x31, 0x0a, 0x08, 0x53, 0x79, 0x6e, 0x63, 0x55, 0x73, 0x65, 0x72, 0x12, 0x11, 0x2e, 0x75, |
| | | 0x73, 0x65, 0x72, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, |
| | | 0x12, 0x2e, 0x75, 0x73, 0x65, 0x72, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, |
| | | 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x0d, 0x55, 0x73, 0x65, 0x72, 0x4d, 0x65, 0x6e, 0x75, 0x43, |
| | | 0x68, 0x65, 0x63, 0x6b, 0x12, 0x12, 0x2e, 0x75, 0x73, 0x65, 0x72, 0x2e, 0x43, 0x68, 0x65, 0x63, |
| | | 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x13, 0x2e, 0x75, 0x73, 0x65, 0x72, 0x2e, |
| | | 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3a, 0x0a, |
| | | 0x0b, 0x53, 0x79, 0x6e, 0x63, 0x41, 0x6c, 0x6c, 0x55, 0x73, 0x65, 0x72, 0x12, 0x14, 0x2e, 0x75, |
| | | 0x73, 0x65, 0x72, 0x2e, 0x41, 0x6c, 0x6c, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, |
| | | 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x75, 0x73, 0x65, 0x72, 0x2e, 0x41, 0x6c, 0x6c, 0x55, 0x73, 0x65, |
| | | 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3a, 0x0a, 0x0b, 0x47, 0x65, 0x74, |
| | | 0x55, 0x73, 0x65, 0x72, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x14, 0x2e, 0x75, 0x73, 0x65, 0x72, 0x2e, |
| | | 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, |
| | | 0x2e, 0x75, 0x73, 0x65, 0x72, 0x2e, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x73, |
| | | 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x08, 0x5a, 0x06, 0x2e, 0x2f, 0x75, 0x73, 0x65, 0x72, 0x62, |
| | | 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, |
| | | } |
| | | |
| | | var ( |
| | | file_user_proto_rawDescOnce sync.Once |
| | | file_user_proto_rawDescData = file_user_proto_rawDesc |
| | | ) |
| | | |
| | | func file_user_proto_rawDescGZIP() []byte { |
| | | file_user_proto_rawDescOnce.Do(func() { |
| | | file_user_proto_rawDescData = protoimpl.X.CompressGZIP(file_user_proto_rawDescData) |
| | | }) |
| | | return file_user_proto_rawDescData |
| | | } |
| | | |
| | | var file_user_proto_msgTypes = make([]protoimpl.MessageInfo, 10) |
| | | var file_user_proto_goTypes = []any{ |
| | | (*User)(nil), // 0: user.User |
| | | (*UserRequest)(nil), // 1: user.UserRequest |
| | | (*UserResponse)(nil), // 2: user.UserResponse |
| | | (*CheckRequest)(nil), // 3: user.CheckRequest |
| | | (*CheckResponse)(nil), // 4: user.CheckResponse |
| | | (*AllUserRequest)(nil), // 5: user.AllUserRequest |
| | | (*UserSimple)(nil), // 6: user.UserSimple |
| | | (*AllUserResponse)(nil), // 7: user.AllUserResponse |
| | | (*GetUserRequest)(nil), // 8: user.GetUserRequest |
| | | (*GetUserResponse)(nil), // 9: user.GetUserResponse |
| | | } |
| | | var file_user_proto_depIdxs = []int32{ |
| | | 0, // 0: user.UserRequest.users:type_name -> user.User |
| | | 0, // 1: user.UserResponse.List:type_name -> user.User |
| | | 6, // 2: user.AllUserResponse.List:type_name -> user.UserSimple |
| | | 8, // 3: user.GetUserResponse.List:type_name -> user.GetUserRequest |
| | | 1, // 4: user.UserService.SyncUser:input_type -> user.UserRequest |
| | | 3, // 5: user.UserService.UserMenuCheck:input_type -> user.CheckRequest |
| | | 5, // 6: user.UserService.SyncAllUser:input_type -> user.AllUserRequest |
| | | 8, // 7: user.UserService.GetUserList:input_type -> user.GetUserRequest |
| | | 2, // 8: user.UserService.SyncUser:output_type -> user.UserResponse |
| | | 4, // 9: user.UserService.UserMenuCheck:output_type -> user.CheckResponse |
| | | 7, // 10: user.UserService.SyncAllUser:output_type -> user.AllUserResponse |
| | | 9, // 11: user.UserService.GetUserList:output_type -> user.GetUserResponse |
| | | 8, // [8:12] is the sub-list for method output_type |
| | | 4, // [4:8] is the sub-list for method input_type |
| | | 4, // [4:4] is the sub-list for extension type_name |
| | | 4, // [4:4] is the sub-list for extension extendee |
| | | 0, // [0:4] is the sub-list for field type_name |
| | | } |
| | | |
| | | func init() { file_user_proto_init() } |
| | | func file_user_proto_init() { |
| | | if File_user_proto != nil { |
| | | return |
| | | } |
| | | if !protoimpl.UnsafeEnabled { |
| | | file_user_proto_msgTypes[0].Exporter = func(v any, i int) any { |
| | | switch v := v.(*User); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[1].Exporter = func(v any, i int) any { |
| | | switch v := v.(*UserRequest); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[2].Exporter = func(v any, i int) any { |
| | | switch v := v.(*UserResponse); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[3].Exporter = func(v any, i int) any { |
| | | switch v := v.(*CheckRequest); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[4].Exporter = func(v any, i int) any { |
| | | switch v := v.(*CheckResponse); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[5].Exporter = func(v any, i int) any { |
| | | switch v := v.(*AllUserRequest); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[6].Exporter = func(v any, i int) any { |
| | | switch v := v.(*UserSimple); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[7].Exporter = func(v any, i int) any { |
| | | switch v := v.(*AllUserResponse); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[8].Exporter = func(v any, i int) any { |
| | | switch v := v.(*GetUserRequest); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | file_user_proto_msgTypes[9].Exporter = func(v any, i int) any { |
| | | switch v := v.(*GetUserResponse); i { |
| | | case 0: |
| | | return &v.state |
| | | case 1: |
| | | return &v.sizeCache |
| | | case 2: |
| | | return &v.unknownFields |
| | | default: |
| | | return nil |
| | | } |
| | | } |
| | | } |
| | | type x struct{} |
| | | out := protoimpl.TypeBuilder{ |
| | | File: protoimpl.DescBuilder{ |
| | | GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| | | RawDescriptor: file_user_proto_rawDesc, |
| | | NumEnums: 0, |
| | | NumMessages: 10, |
| | | NumExtensions: 0, |
| | | NumServices: 1, |
| | | }, |
| | | GoTypes: file_user_proto_goTypes, |
| | | DependencyIndexes: file_user_proto_depIdxs, |
| | | MessageInfos: file_user_proto_msgTypes, |
| | | }.Build() |
| | | File_user_proto = out.File |
| | | file_user_proto_rawDesc = nil |
| | | file_user_proto_goTypes = nil |
| | | file_user_proto_depIdxs = nil |
| | | } |
New file |
| | |
| | | // Code generated by protoc-gen-go-grpc. DO NOT EDIT. |
| | | // versions: |
| | | // - protoc-gen-go-grpc v1.3.0 |
| | | // - protoc v3.20.3 |
| | | // source: user.proto |
| | | |
| | | package user |
| | | |
| | | import ( |
| | | context "context" |
| | | grpc "google.golang.org/grpc" |
| | | codes "google.golang.org/grpc/codes" |
| | | status "google.golang.org/grpc/status" |
| | | ) |
| | | |
| | | // This is a compile-time assertion to ensure that this generated file |
| | | // is compatible with the grpc package it is being compiled against. |
| | | // 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" |
| | | UserService_GetUserList_FullMethodName = "/user.UserService/GetUserList" |
| | | ) |
| | | |
| | | // 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) |
| | | GetUserList(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*GetUserResponse, error) |
| | | } |
| | | |
| | | type userServiceClient struct { |
| | | cc grpc.ClientConnInterface |
| | | } |
| | | |
| | | func NewUserServiceClient(cc grpc.ClientConnInterface) UserServiceClient { |
| | | return &userServiceClient{cc} |
| | | } |
| | | |
| | | func (c *userServiceClient) SyncUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error) { |
| | | out := new(UserResponse) |
| | | 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 |
| | | } |
| | | return out, nil |
| | | } |
| | | |
| | | func (c *userServiceClient) GetUserList(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*GetUserResponse, error) { |
| | | out := new(GetUserResponse) |
| | | err := c.cc.Invoke(ctx, UserService_GetUserList_FullMethodName, in, out, opts...) |
| | | if err != nil { |
| | | return nil, err |
| | | } |
| | | return out, nil |
| | | } |
| | | |
| | | // UserServiceServer is the server API for UserService service. |
| | | // All implementations must embed UnimplementedUserServiceServer |
| | | // for forward compatibility |
| | | type UserServiceServer interface { |
| | | SyncUser(context.Context, *UserRequest) (*UserResponse, error) |
| | | UserMenuCheck(context.Context, *CheckRequest) (*CheckResponse, error) |
| | | SyncAllUser(context.Context, *AllUserRequest) (*AllUserResponse, error) |
| | | GetUserList(context.Context, *GetUserRequest) (*GetUserResponse, error) |
| | | mustEmbedUnimplementedUserServiceServer() |
| | | } |
| | | |
| | | // UnimplementedUserServiceServer must be embedded to have forward compatible implementations. |
| | | type UnimplementedUserServiceServer struct { |
| | | } |
| | | |
| | | 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) GetUserList(context.Context, *GetUserRequest) (*GetUserResponse, error) { |
| | | return nil, status.Errorf(codes.Unimplemented, "method GetUserList not implemented") |
| | | } |
| | | func (UnimplementedUserServiceServer) mustEmbedUnimplementedUserServiceServer() {} |
| | | |
| | | // UnsafeUserServiceServer may be embedded to opt out of forward compatibility for this service. |
| | | // Use of this interface is not recommended, as added methods to UserServiceServer will |
| | | // result in compilation errors. |
| | | type UnsafeUserServiceServer interface { |
| | | mustEmbedUnimplementedUserServiceServer() |
| | | } |
| | | |
| | | func RegisterUserServiceServer(s grpc.ServiceRegistrar, srv UserServiceServer) { |
| | | s.RegisterService(&UserService_ServiceDesc, srv) |
| | | } |
| | | |
| | | func _UserService_SyncUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| | | in := new(UserRequest) |
| | | if err := dec(in); err != nil { |
| | | return nil, err |
| | | } |
| | | if interceptor == nil { |
| | | return srv.(UserServiceServer).SyncUser(ctx, in) |
| | | } |
| | | info := &grpc.UnaryServerInfo{ |
| | | Server: srv, |
| | | 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) |
| | | } |
| | | |
| | | func _UserService_GetUserList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| | | in := new(GetUserRequest) |
| | | if err := dec(in); err != nil { |
| | | return nil, err |
| | | } |
| | | if interceptor == nil { |
| | | return srv.(UserServiceServer).GetUserList(ctx, in) |
| | | } |
| | | info := &grpc.UnaryServerInfo{ |
| | | Server: srv, |
| | | FullMethod: UserService_GetUserList_FullMethodName, |
| | | } |
| | | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| | | return srv.(UserServiceServer).GetUserList(ctx, req.(*GetUserRequest)) |
| | | } |
| | | return interceptor(ctx, in, info, handler) |
| | | } |
| | | |
| | | // UserService_ServiceDesc is the grpc.ServiceDesc for UserService service. |
| | | // It's only intended for direct use with grpc.RegisterService, |
| | | // and not to be introspected or modified (even as a copy) |
| | | var UserService_ServiceDesc = grpc.ServiceDesc{ |
| | | ServiceName: "user.UserService", |
| | | HandlerType: (*UserServiceServer)(nil), |
| | | Methods: []grpc.MethodDesc{ |
| | | { |
| | | MethodName: "SyncUser", |
| | | Handler: _UserService_SyncUser_Handler, |
| | | }, |
| | | { |
| | | MethodName: "UserMenuCheck", |
| | | Handler: _UserService_UserMenuCheck_Handler, |
| | | }, |
| | | { |
| | | MethodName: "SyncAllUser", |
| | | Handler: _UserService_SyncAllUser_Handler, |
| | | }, |
| | | { |
| | | MethodName: "GetUserList", |
| | | Handler: _UserService_GetUserList_Handler, |
| | | }, |
| | | }, |
| | | Streams: []grpc.StreamDesc{}, |
| | | Metadata: "user.proto", |
| | | } |