jjxu/fonchain-artistinfo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更新

Browse Source
This commit is contained in:
徐俊杰 2023-02-15 10:03:22 +08:00
parent c6401d2093
commit b71036007e
4 changed files with 1467 additions and 549 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/internal/controller/artisrInfo.go
View File

@ -70,6 +70,12 @@ func (a *ArtistInfoProvider) ArtistSupplyList(ctx context.Context, req *artistin
// 绑定邀请人和受邀请人的账号,并加入到次数统计
func (a *ArtistInfoProvider) BindInviteInvitedAccount(ctx context.Context, in *artistinfo.BindInviteInvitedAccountRequest) (res *artistinfo.BindInviteInvitedAccountRespond, err error) {
if in.UserId == 0 || in.InvitedUserId == 0 {
return nil, err
}
// todo 变量in 参数检测: 邀请码没填的话需要从账号服务获取
// ..
// ..
var data model.Invite
// 只能绑定一个邀请人
if err = db.DB.Where("invited_id = ?", in.InvitedUserId).Find(&data).Error; err != nil {

1771
pb/artistinfo/artistinfo.pb.go
View File

File diff suppressed because it is too large Load Diff

102
pb/artistinfo/artistinfo.proto
View File

@ -3,20 +3,81 @@ package artistinfo;
option go_package = "./;artistinfo";
// protoc --proto_path=. --go_out=./pb/artistinfo --go-triple_out=./pb/artistinfo ./pb/artistinfo/artistinfo.proto
service ArtistInfo {
rpc UploadPic (UploadPicRequest) returns (UploadPicRespond) {}
rpc UploadIdCard (UploadIdCardRequest) returns (UploadIdCardRespond) {}
rpc RegisterUser (RegisterUserRequest) returns (RegisterUserRespond){}
rpc GetUser(GetUserRequest) returns (GetUserRespond){}
rpc GetUserById(GetUserByIdRequest) returns (GetUserByIdRespond){}
rpc CreateUser (CreateUserRequest) returns (CreateUserRespond){}
rpc CreateUserInfo (CreateUserInfoRequest) returns (CreateUserInfoRespond){}
rpc UpdateRealName (UpdateRealNameRequest) returns (UpdateRealNameRespond){}
rpc FinishVerify (FinishVerifyRequest) returns (FinishVerifyRespond){}
rpc CheckUserLock (CheckUserLockRequest) returns (CheckUserLockRespond) {}
rpc ArtistSupplyList (ArtistSupplyListRequest) returns (ArtistSupplyListRespond){}
rpc UserLock (UserLockRequest) returns(UserLockRespond){}
// rpc GetAccountDetailByInviteCode(GetInviteCodeDetailRequest) returns(GetInviteCodeDetailRespond){} //获取邀请码对应的账号信息
rpc BindInviteInvitedAccount(BindInviteInvitedAccountRequest)returns(BindInviteInvitedAccountRespond){}
rpc UploadPic (UploadPicRequest) returns (UploadPicRespond) {}
rpc UploadIdCard (UploadIdCardRequest) returns (UploadIdCardRespond) {}
rpc RegisterUser (RegisterUserRequest) returns (RegisterUserRespond){}
rpc GetUser(GetUserRequest) returns (GetUserRespond){}
rpc GetUserById(GetUserByIdRequest) returns (GetUserByIdRespond){}
rpc CreateUser (CreateUserRequest) returns (CreateUserRespond){}
rpc CreateUserInfo (CreateUserInfoRequest) returns (CreateUserInfoRespond){}
rpc UpdateRealName (UpdateRealNameRequest) returns (UpdateRealNameRespond){}
rpc FinishVerify (FinishVerifyRequest) returns (FinishVerifyRespond){}
rpc CheckUserLock (CheckUserLockRequest) returns (CheckUserLockRespond) {}
rpc ArtistSupplyList (ArtistSupplyListRequest) returns (ArtistSupplyListRespond){}
rpc UserLock (UserLockRequest) returns(UserLockRespond){}
rpc CheckInvitedCode(CheckInvitedCodeRequest)returns (GetUserRespond){}
rpc UnFinishList(UnFinishListRequest)returns (UnFinishListRespond){}
rpc GetUserMsg(GetUserMsgRequest) returns (GetUserMsgRespond){}
rpc BindInviteInvitedAccount(BindInviteInvitedAccountRequest)returns(BindInviteInvitedAccountRespond){}
}
message GetUserMsgRequest{
uint64 Id =1;
}
message GetUserMsgRespond{
uint64 ID =1[json_name = "id"];
uint64 MgmtUserId =2[json_name = "mgmtUserId"];
string MgmtArtistId =3[json_name = "mgmtArtistId"];
string Account =4[json_name = "account"];
string MnemonicWords =5[json_name = "mnemonicWords"];
string TelNum =6[json_name = "telNum"];
string Name =7[json_name = "name"];
string PenName =8[json_name = "penName"];
string StageName =9[json_name = "stageName"];
string JoinAssoTime =10[json_name = "joinAssoTime"];
string CertificateNum =11[json_name = "certificateNum"];
string CertificateImg =12[json_name = "certificateImg"];
string Key =13[json_name = "key"];
int32 RealNameID =14[json_name = "realNameID"];
string IDNum =15[json_name = "idNum"];
int32 Sex =16[json_name = "sex"];
int64 Ruler =17[json_name = "ruler"];
string OpenId =18[json_name = "openId"];
string CustomerId =19[json_name = "customerId"];
int32 Age =20[json_name = "age"];
string Introduct =21[json_name = "introduct"];
int64 CreateAt =22[json_name = "createAt"];
string ConAddress =23[json_name = "conAddress"];
string Photo =24[json_name = "photo"];
string Video =25[json_name = "video"];
int64 IsRealName =26[json_name = "isRealName"];
int64 IsFdd =27[json_name = "isFdd"];
int64 FddState =28[json_name = "fddState"];
string WxAccount =29[json_name = "wxAccount"];
bool IsLock =30[json_name = "isLock"];
string InvitedCode =31[json_name = "invitedCode"];
int32 IsRead =32[json_name = "isRead"];
int32 IsImport =33[json_name = "isImport"];
bool Enable =34[json_name = "enable"];
}
message CheckInvitedCodeRequest {
string InvitedCode =1;
}
message CheckInvitedCodeRespond {
}
message UnFinishListRequest {
uint64 Id = 1;
}
message UnFinishListRespond {
int64 ContractList =1;
int64 SupplyInfoList =2;
int64 AccountStateList =3;
}
message UploadPicRequest {
@ -56,7 +117,7 @@ message GetUserRequest {
}
message GetUserRespond {
uint64 Id =1;
uint64 Id =1 ;
uint64 MgmtUserId =2;
string MgmtArtistId = 3;
string TelNum = 4;
@ -244,20 +305,13 @@ message UserLockRespond {
}
//message GetInviteCodeDetailRequest{
//
//}
//message GetInviteCodeDetailRespond{
//
//}
message BindInviteInvitedAccountRequest{
int32 UserId =1; //邀请人账号id
int32 InvitedUserId =2; // 受邀请人账号id
int32 InviteCode = 3; //邀请人的邀请码
int32 InvitedCode = 4; //受邀请人的邀请码
}
message BindInviteInvitedAccountRespond{
// no params
// no params
}

137
pb/artistinfo/artistinfo_triple.pb.go
View File

@ -40,7 +40,9 @@ type ArtistInfoClient interface {
CheckUserLock(ctx context.Context, in *CheckUserLockRequest, opts ...grpc_go.CallOption) (*CheckUserLockRespond, common.ErrorWithAttachment)
ArtistSupplyList(ctx context.Context, in *ArtistSupplyListRequest, opts ...grpc_go.CallOption) (*ArtistSupplyListRespond, common.ErrorWithAttachment)
UserLock(ctx context.Context, in *UserLockRequest, opts ...grpc_go.CallOption) (*UserLockRespond, common.ErrorWithAttachment)
// rpc GetAccountDetailByInviteCode(GetInviteCodeDetailRequest) returns(GetInviteCodeDetailRespond){} //获取邀请码对应的账号信息
CheckInvitedCode(ctx context.Context, in *CheckInvitedCodeRequest, opts ...grpc_go.CallOption) (*GetUserRespond, common.ErrorWithAttachment)
UnFinishList(ctx context.Context, in *UnFinishListRequest, opts ...grpc_go.CallOption) (*UnFinishListRespond, common.ErrorWithAttachment)
GetUserMsg(ctx context.Context, in *GetUserMsgRequest, opts ...grpc_go.CallOption) (*GetUserMsgRespond, common.ErrorWithAttachment)
BindInviteInvitedAccount(ctx context.Context, in *BindInviteInvitedAccountRequest, opts ...grpc_go.CallOption) (*BindInviteInvitedAccountRespond, common.ErrorWithAttachment)
}
@ -61,6 +63,9 @@ type ArtistInfoClientImpl struct {
CheckUserLock func(ctx context.Context, in *CheckUserLockRequest) (*CheckUserLockRespond, error)
ArtistSupplyList func(ctx context.Context, in *ArtistSupplyListRequest) (*ArtistSupplyListRespond, error)
UserLock func(ctx context.Context, in *UserLockRequest) (*UserLockRespond, error)
CheckInvitedCode func(ctx context.Context, in *CheckInvitedCodeRequest) (*GetUserRespond, error)
UnFinishList func(ctx context.Context, in *UnFinishListRequest) (*UnFinishListRespond, error)
GetUserMsg func(ctx context.Context, in *GetUserMsgRequest) (*GetUserMsgRespond, error)
BindInviteInvitedAccount func(ctx context.Context, in *BindInviteInvitedAccountRequest) (*BindInviteInvitedAccountRespond, error)
}
@ -148,6 +153,24 @@ func (c *artistInfoClient) UserLock(ctx context.Context, in *UserLockRequest, op
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UserLock", in, out)
}
func (c *artistInfoClient) CheckInvitedCode(ctx context.Context, in *CheckInvitedCodeRequest, opts ...grpc_go.CallOption) (*GetUserRespond, common.ErrorWithAttachment) {
out := new(GetUserRespond)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CheckInvitedCode", in, out)
}
func (c *artistInfoClient) UnFinishList(ctx context.Context, in *UnFinishListRequest, opts ...grpc_go.CallOption) (*UnFinishListRespond, common.ErrorWithAttachment) {
out := new(UnFinishListRespond)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UnFinishList", in, out)
}
func (c *artistInfoClient) GetUserMsg(ctx context.Context, in *GetUserMsgRequest, opts ...grpc_go.CallOption) (*GetUserMsgRespond, common.ErrorWithAttachment) {
out := new(GetUserMsgRespond)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetUserMsg", in, out)
}
func (c *artistInfoClient) BindInviteInvitedAccount(ctx context.Context, in *BindInviteInvitedAccountRequest, opts ...grpc_go.CallOption) (*BindInviteInvitedAccountRespond, common.ErrorWithAttachment) {
out := new(BindInviteInvitedAccountRespond)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -170,7 +193,9 @@ type ArtistInfoServer interface {
CheckUserLock(context.Context, *CheckUserLockRequest) (*CheckUserLockRespond, error)
ArtistSupplyList(context.Context, *ArtistSupplyListRequest) (*ArtistSupplyListRespond, error)
UserLock(context.Context, *UserLockRequest) (*UserLockRespond, error)
// rpc GetAccountDetailByInviteCode(GetInviteCodeDetailRequest) returns(GetInviteCodeDetailRespond){} //获取邀请码对应的账号信息
CheckInvitedCode(context.Context, *CheckInvitedCodeRequest) (*GetUserRespond, error)
UnFinishList(context.Context, *UnFinishListRequest) (*UnFinishListRespond, error)
GetUserMsg(context.Context, *GetUserMsgRequest) (*GetUserMsgRespond, error)
BindInviteInvitedAccount(context.Context, *BindInviteInvitedAccountRequest) (*BindInviteInvitedAccountRespond, error)
mustEmbedUnimplementedArtistInfoServer()
}
@ -216,6 +241,15 @@ func (UnimplementedArtistInfoServer) ArtistSupplyList(context.Context, *ArtistSu
func (UnimplementedArtistInfoServer) UserLock(context.Context, *UserLockRequest) (*UserLockRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method UserLock not implemented")
}
func (UnimplementedArtistInfoServer) CheckInvitedCode(context.Context, *CheckInvitedCodeRequest) (*GetUserRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method CheckInvitedCode not implemented")
}
func (UnimplementedArtistInfoServer) UnFinishList(context.Context, *UnFinishListRequest) (*UnFinishListRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method UnFinishList not implemented")
}
func (UnimplementedArtistInfoServer) GetUserMsg(context.Context, *GetUserMsgRequest) (*GetUserMsgRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetUserMsg not implemented")
}
func (UnimplementedArtistInfoServer) BindInviteInvitedAccount(context.Context, *BindInviteInvitedAccountRequest) (*BindInviteInvitedAccountRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method BindInviteInvitedAccount not implemented")
}
@ -595,6 +629,93 @@ func _ArtistInfo_UserLock_Handler(srv interface{}, ctx context.Context, dec func
return interceptor(ctx, in, info, handler)
}
func _ArtistInfo_CheckInvitedCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(CheckInvitedCodeRequest)
if err := dec(in); err != nil {
return nil, err
}
base := srv.(dubbo3.Dubbo3GrpcService)
args := []interface{}{}
args = append(args, in)
md, _ := metadata.FromIncomingContext(ctx)
invAttachment := make(map[string]interface{}, len(md))
for k, v := range md {
invAttachment[k] = v
}
invo := invocation.NewRPCInvocation("CheckInvitedCode", args, invAttachment)
if interceptor == nil {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
info := &grpc_go.UnaryServerInfo{
Server: srv,
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
return interceptor(ctx, in, info, handler)
}
func _ArtistInfo_UnFinishList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(UnFinishListRequest)
if err := dec(in); err != nil {
return nil, err
}
base := srv.(dubbo3.Dubbo3GrpcService)
args := []interface{}{}
args = append(args, in)
md, _ := metadata.FromIncomingContext(ctx)
invAttachment := make(map[string]interface{}, len(md))
for k, v := range md {
invAttachment[k] = v
}
invo := invocation.NewRPCInvocation("UnFinishList", args, invAttachment)
if interceptor == nil {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
info := &grpc_go.UnaryServerInfo{
Server: srv,
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
return interceptor(ctx, in, info, handler)
}
func _ArtistInfo_GetUserMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(GetUserMsgRequest)
if err := dec(in); err != nil {
return nil, err
}
base := srv.(dubbo3.Dubbo3GrpcService)
args := []interface{}{}
args = append(args, in)
md, _ := metadata.FromIncomingContext(ctx)
invAttachment := make(map[string]interface{}, len(md))
for k, v := range md {
invAttachment[k] = v
}
invo := invocation.NewRPCInvocation("GetUserMsg", args, invAttachment)
if interceptor == nil {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
info := &grpc_go.UnaryServerInfo{
Server: srv,
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
return result, result.Error()
}
return interceptor(ctx, in, info, handler)
}
func _ArtistInfo_BindInviteInvitedAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(BindInviteInvitedAccountRequest)
if err := dec(in); err != nil {
@ -679,6 +800,18 @@ var ArtistInfo_ServiceDesc = grpc_go.ServiceDesc{
MethodName: "UserLock",
Handler: _ArtistInfo_UserLock_Handler,
},
{
MethodName: "CheckInvitedCode",
Handler: _ArtistInfo_CheckInvitedCode_Handler,
},
{
MethodName: "UnFinishList",
Handler: _ArtistInfo_UnFinishList_Handler,
},
{
MethodName: "GetUserMsg",
Handler: _ArtistInfo_GetUserMsg_Handler,
},
{
MethodName: "BindInviteInvitedAccount",
Handler: _ArtistInfo_BindInviteInvitedAccount_Handler,