From c48378d9fd7bf4c91369f88f252b7e4333453c8f Mon Sep 17 00:00:00 2001 From: zerosaturation Date: Sat, 16 May 2026 01:16:24 +0800 Subject: [PATCH] fix: rpc --- backend/pkg/proto/asset/asset.triple.go | 127 +++++++++++++++++- .../provider/material_provider.go | 10 +- 2 files changed, 131 insertions(+), 6 deletions(-) diff --git a/backend/pkg/proto/asset/asset.triple.go b/backend/pkg/proto/asset/asset.triple.go index 0770254..a2f18fd 100644 --- a/backend/pkg/proto/asset/asset.triple.go +++ b/backend/pkg/proto/asset/asset.triple.go @@ -86,6 +86,11 @@ type AssetService interface { CheckAssetLike(ctx context.Context, req *CheckAssetLikeRequest, opts ...client.CallOption) (*CheckAssetLikeResponse, error) GetAssetLikes(ctx context.Context, req *GetAssetLikesRequest, opts ...client.CallOption) (*GetAssetLikesResponse, 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. @@ -220,9 +225,49 @@ func (c *AssetServiceImpl) ClearAssetLikeRecords(ctx context.Context, req *Clear 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{ 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) { dubboCli := dubboCliRaw.(*AssetServiceImpl) dubboCli.conn = conn @@ -245,6 +290,11 @@ type AssetServiceHandler interface { CheckAssetLike(context.Context, *CheckAssetLikeRequest) (*CheckAssetLikeResponse, error) GetAssetLikes(context.Context, *GetAssetLikesRequest) (*GetAssetLikesResponse, 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 { @@ -469,5 +519,80 @@ var AssetService_ServiceInfo = server.ServiceInfo{ 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 + }, + }, }, } diff --git a/backend/services/assetService/provider/material_provider.go b/backend/services/assetService/provider/material_provider.go index ec3327e..aebc116 100644 --- a/backend/services/assetService/provider/material_provider.go +++ b/backend/services/assetService/provider/material_provider.go @@ -42,7 +42,7 @@ func (p *AssetProvider) UploadMaterial(ctx context.Context, req *pb.UploadMateri if err != nil { logger.Logger.Error("UploadMaterial failed", zap.Error(err)) 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 } @@ -88,7 +88,7 @@ func (p *AssetProvider) BindAssetMaterials(ctx context.Context, req *pb.BindAsse if _, err := p.materialService.BindMaterials(req.AssetId, items); err != nil { logger.Logger.Error("BindAssetMaterials failed", zap.Error(err)) 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 } @@ -108,7 +108,7 @@ func (p *AssetProvider) GetAssetMaterials(ctx context.Context, req *pb.GetAssetM relations, err := p.materialService.GetAssetMaterials(req.AssetId) if err != nil { 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 } @@ -163,7 +163,7 @@ func (p *AssetProvider) UpdateMaterialLayerOrder(ctx context.Context, req *pb.Up if err := p.materialService.UpdateLayerOrder(req.AssetId, orders); err != nil { 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 } @@ -182,7 +182,7 @@ func (p *AssetProvider) UnbindAssetMaterial(ctx context.Context, req *pb.UnbindA if err := p.materialService.UnbindMaterial(req.RelationId); err != nil { 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 }