xiaoyu/topfans
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: rpc

Browse Source
This commit is contained in:
zerosaturation 2026-05-16 01:16:24 +08:00
parent 4d8554c40c
commit c48378d9fd
2 changed files with 131 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

127
backend/pkg/proto/asset/asset.triple.go
View File

@ -86,6 +86,11 @@ type AssetService interface {
CheckAssetLike(ctx context.Context, req *CheckAssetLikeRequest, opts ...client.CallOption) (*CheckAssetLikeResponse, error) CheckAssetLike(ctx context.Context, req *CheckAssetLikeRequest, opts ...client.CallOption) (*CheckAssetLikeResponse, error)
GetAssetLikes(ctx context.Context, req *GetAssetLikesRequest, opts ...client.CallOption) (*GetAssetLikesResponse, error) GetAssetLikes(ctx context.Context, req *GetAssetLikesRequest, opts ...client.CallOption) (*GetAssetLikesResponse, error)
ClearAssetLikeRecords(ctx context.Context, req *ClearAssetLikeRecordsRequest, opts ...client.CallOption) (*ClearAssetLikeRecordsResponse, error) ClearAssetLikeRecords(ctx context.Context, req *ClearAssetLikeRecordsRequest, opts ...client.CallOption) (*ClearAssetLikeRecordsResponse, error)
UploadMaterial(ctx context.Context, req *UploadMaterialRequest, opts ...client.CallOption) (*UploadMaterialResponse, error)
BindAssetMaterials(ctx context.Context, req *BindAssetMaterialsRequest, opts ...client.CallOption) (*BindAssetMaterialsResponse, error)
GetAssetMaterials(ctx context.Context, req *GetAssetMaterialsRequest, opts ...client.CallOption) (*GetAssetMaterialsResponse, error)
UpdateMaterialLayerOrder(ctx context.Context, req *UpdateMaterialLayerOrderRequest, opts ...client.CallOption) (*UpdateMaterialLayerOrderResponse, error)
UnbindAssetMaterial(ctx context.Context, req *UnbindAssetMaterialRequest, opts ...client.CallOption) (*UnbindAssetMaterialResponse, error)
} }
// NewAssetService constructs a client for the asset.AssetService service. // NewAssetService constructs a client for the asset.AssetService service.
@ -220,9 +225,49 @@ func (c *AssetServiceImpl) ClearAssetLikeRecords(ctx context.Context, req *Clear
return resp, nil return resp, nil
} }
func (c *AssetServiceImpl) UploadMaterial(ctx context.Context, req *UploadMaterialRequest, opts ...client.CallOption) (*UploadMaterialResponse, error) {
resp := new(UploadMaterialResponse)
if err := c.conn.CallUnary(ctx, []interface{}{req}, resp, "UploadMaterial", opts...); err != nil {
return nil, err
}
return resp, nil
}
func (c *AssetServiceImpl) BindAssetMaterials(ctx context.Context, req *BindAssetMaterialsRequest, opts ...client.CallOption) (*BindAssetMaterialsResponse, error) {
resp := new(BindAssetMaterialsResponse)
if err := c.conn.CallUnary(ctx, []interface{}{req}, resp, "BindAssetMaterials", opts...); err != nil {
return nil, err
}
return resp, nil
}
func (c *AssetServiceImpl) GetAssetMaterials(ctx context.Context, req *GetAssetMaterialsRequest, opts ...client.CallOption) (*GetAssetMaterialsResponse, error) {
resp := new(GetAssetMaterialsResponse)
if err := c.conn.CallUnary(ctx, []interface{}{req}, resp, "GetAssetMaterials", opts...); err != nil {
return nil, err
}
return resp, nil
}
func (c *AssetServiceImpl) UpdateMaterialLayerOrder(ctx context.Context, req *UpdateMaterialLayerOrderRequest, opts ...client.CallOption) (*UpdateMaterialLayerOrderResponse, error) {
resp := new(UpdateMaterialLayerOrderResponse)
if err := c.conn.CallUnary(ctx, []interface{}{req}, resp, "UpdateMaterialLayerOrder", opts...); err != nil {
return nil, err
}
return resp, nil
}
func (c *AssetServiceImpl) UnbindAssetMaterial(ctx context.Context, req *UnbindAssetMaterialRequest, opts ...client.CallOption) (*UnbindAssetMaterialResponse, error) {
resp := new(UnbindAssetMaterialResponse)
if err := c.conn.CallUnary(ctx, []interface{}{req}, resp, "UnbindAssetMaterial", opts...); err != nil {
return nil, err
}
return resp, nil
}
var AssetService_ClientInfo = client.ClientInfo{ var AssetService_ClientInfo = client.ClientInfo{
InterfaceName: "topfans.asset.AssetService", InterfaceName: "topfans.asset.AssetService",
MethodNames: []string{"InitMintOrder", "PreCreateMintOrder", "CreateMintOrder", "GetMyAssets", "GetAsset", "GetAssetStatus", "GetMintOrder", "CancelMintOrder", "GetAssetForRPC", "LikeAsset", "UnlikeAsset", "CheckAssetLike", "GetAssetLikes", "ClearAssetLikeRecords"}, MethodNames: []string{"InitMintOrder", "PreCreateMintOrder", "CreateMintOrder", "GetMyAssets", "GetAsset", "GetAssetStatus", "GetMintOrder", "CancelMintOrder", "GetAssetForRPC", "LikeAsset", "UnlikeAsset", "CheckAssetLike", "GetAssetLikes", "ClearAssetLikeRecords", "UploadMaterial", "BindAssetMaterials", "GetAssetMaterials", "UpdateMaterialLayerOrder", "UnbindAssetMaterial"},
ConnectionInjectFunc: func(dubboCliRaw interface{}, conn *client.Connection) { ConnectionInjectFunc: func(dubboCliRaw interface{}, conn *client.Connection) {
dubboCli := dubboCliRaw.(*AssetServiceImpl) dubboCli := dubboCliRaw.(*AssetServiceImpl)
dubboCli.conn = conn dubboCli.conn = conn
@ -245,6 +290,11 @@ type AssetServiceHandler interface {
CheckAssetLike(context.Context, *CheckAssetLikeRequest) (*CheckAssetLikeResponse, error) CheckAssetLike(context.Context, *CheckAssetLikeRequest) (*CheckAssetLikeResponse, error)
GetAssetLikes(context.Context, *GetAssetLikesRequest) (*GetAssetLikesResponse, error) GetAssetLikes(context.Context, *GetAssetLikesRequest) (*GetAssetLikesResponse, error)
ClearAssetLikeRecords(context.Context, *ClearAssetLikeRecordsRequest) (*ClearAssetLikeRecordsResponse, error) ClearAssetLikeRecords(context.Context, *ClearAssetLikeRecordsRequest) (*ClearAssetLikeRecordsResponse, error)
UploadMaterial(context.Context, *UploadMaterialRequest) (*UploadMaterialResponse, error)
BindAssetMaterials(context.Context, *BindAssetMaterialsRequest) (*BindAssetMaterialsResponse, error)
GetAssetMaterials(context.Context, *GetAssetMaterialsRequest) (*GetAssetMaterialsResponse, error)
UpdateMaterialLayerOrder(context.Context, *UpdateMaterialLayerOrderRequest) (*UpdateMaterialLayerOrderResponse, error)
UnbindAssetMaterial(context.Context, *UnbindAssetMaterialRequest) (*UnbindAssetMaterialResponse, error)
} }
func RegisterAssetServiceHandler(srv *server.Server, hdlr AssetServiceHandler, opts ...server.ServiceOption) error { func RegisterAssetServiceHandler(srv *server.Server, hdlr AssetServiceHandler, opts ...server.ServiceOption) error {
@ -469,5 +519,80 @@ var AssetService_ServiceInfo = server.ServiceInfo{
return triple_protocol.NewResponse(res), nil return triple_protocol.NewResponse(res), nil
}, },
}, },
{
Name: "UploadMaterial",
Type: constant.CallUnary,
ReqInitFunc: func() interface{} {
return new(UploadMaterialRequest)
},
MethodFunc: func(ctx context.Context, args []interface{}, handler interface{}) (interface{}, error) {
req := args[0].(*UploadMaterialRequest)
res, err := handler.(AssetServiceHandler).UploadMaterial(ctx, req)
if err != nil {
return nil, err
}
return triple_protocol.NewResponse(res), nil
},
},
{
Name: "BindAssetMaterials",
Type: constant.CallUnary,
ReqInitFunc: func() interface{} {
return new(BindAssetMaterialsRequest)
},
MethodFunc: func(ctx context.Context, args []interface{}, handler interface{}) (interface{}, error) {
req := args[0].(*BindAssetMaterialsRequest)
res, err := handler.(AssetServiceHandler).BindAssetMaterials(ctx, req)
if err != nil {
return nil, err
}
return triple_protocol.NewResponse(res), nil
},
},
{
Name: "GetAssetMaterials",
Type: constant.CallUnary,
ReqInitFunc: func() interface{} {
return new(GetAssetMaterialsRequest)
},
MethodFunc: func(ctx context.Context, args []interface{}, handler interface{}) (interface{}, error) {
req := args[0].(*GetAssetMaterialsRequest)
res, err := handler.(AssetServiceHandler).GetAssetMaterials(ctx, req)
if err != nil {
return nil, err
}
return triple_protocol.NewResponse(res), nil
},
},
{
Name: "UpdateMaterialLayerOrder",
Type: constant.CallUnary,
ReqInitFunc: func() interface{} {
return new(UpdateMaterialLayerOrderRequest)
},
MethodFunc: func(ctx context.Context, args []interface{}, handler interface{}) (interface{}, error) {
req := args[0].(*UpdateMaterialLayerOrderRequest)
res, err := handler.(AssetServiceHandler).UpdateMaterialLayerOrder(ctx, req)
if err != nil {
return nil, err
}
return triple_protocol.NewResponse(res), nil
},
},
{
Name: "UnbindAssetMaterial",
Type: constant.CallUnary,
ReqInitFunc: func() interface{} {
return new(UnbindAssetMaterialRequest)
},
MethodFunc: func(ctx context.Context, args []interface{}, handler interface{}) (interface{}, error) {
req := args[0].(*UnbindAssetMaterialRequest)
res, err := handler.(AssetServiceHandler).UnbindAssetMaterial(ctx, req)
if err != nil {
return nil, err
}
return triple_protocol.NewResponse(res), nil
},
},
}, },
} }

10
backend/services/assetService/provider/material_provider.go
View File

@ -42,7 +42,7 @@ func (p *AssetProvider) UploadMaterial(ctx context.Context, req *pb.UploadMateri
if err != nil { if err != nil {
logger.Logger.Error("UploadMaterial failed", zap.Error(err)) logger.Logger.Error("UploadMaterial failed", zap.Error(err))
return &pb.UploadMaterialResponse{ return &pb.UploadMaterialResponse{
Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL, Message: err.Error()}, Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL_ERROR, Message: err.Error()},
}, err }, err
} }
@ -88,7 +88,7 @@ func (p *AssetProvider) BindAssetMaterials(ctx context.Context, req *pb.BindAsse
if _, err := p.materialService.BindMaterials(req.AssetId, items); err != nil { if _, err := p.materialService.BindMaterials(req.AssetId, items); err != nil {
logger.Logger.Error("BindAssetMaterials failed", zap.Error(err)) logger.Logger.Error("BindAssetMaterials failed", zap.Error(err))
return &pb.BindAssetMaterialsResponse{ return &pb.BindAssetMaterialsResponse{
Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL, Message: err.Error()}, Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL_ERROR, Message: err.Error()},
}, err }, err
} }
@ -108,7 +108,7 @@ func (p *AssetProvider) GetAssetMaterials(ctx context.Context, req *pb.GetAssetM
relations, err := p.materialService.GetAssetMaterials(req.AssetId) relations, err := p.materialService.GetAssetMaterials(req.AssetId)
if err != nil { if err != nil {
return &pb.GetAssetMaterialsResponse{ return &pb.GetAssetMaterialsResponse{
Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL, Message: err.Error()}, Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL_ERROR, Message: err.Error()},
}, err }, err
} }
@ -163,7 +163,7 @@ func (p *AssetProvider) UpdateMaterialLayerOrder(ctx context.Context, req *pb.Up
if err := p.materialService.UpdateLayerOrder(req.AssetId, orders); err != nil { if err := p.materialService.UpdateLayerOrder(req.AssetId, orders); err != nil {
return &pb.UpdateMaterialLayerOrderResponse{ return &pb.UpdateMaterialLayerOrderResponse{
Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL, Message: err.Error()}, Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL_ERROR, Message: err.Error()},
}, err }, err
} }
@ -182,7 +182,7 @@ func (p *AssetProvider) UnbindAssetMaterial(ctx context.Context, req *pb.UnbindA
if err := p.materialService.UnbindMaterial(req.RelationId); err != nil { if err := p.materialService.UnbindMaterial(req.RelationId); err != nil {
return &pb.UnbindAssetMaterialResponse{ return &pb.UnbindAssetMaterialResponse{
Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL, Message: err.Error()}, Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_INTERNAL_ERROR, Message: err.Error()},
}, err }, err
} }