fix: 更新pb

This commit is contained in:
cjy 2025-12-08 09:35:34 +08:00
parent 8072f9c002
commit 61018d1a3e
3 changed files with 4043 additions and 1606 deletions

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@ -47,7 +47,10 @@ type CastClient interface {
WorkInfo(ctx context.Context, in *WorkInfoReq, opts ...grpc_go.CallOption) (*WorkInfoResp, common.ErrorWithAttachment)
ArtistInfo(ctx context.Context, in *ArtistInfoReq, opts ...grpc_go.CallOption) (*ArtistInfoResp, common.ErrorWithAttachment)
ImportWorkBatch(ctx context.Context, in *ImportWorkBatchReq, opts ...grpc_go.CallOption) (*ImportWorkBatchResp, common.ErrorWithAttachment)
UpdateWorkPlatformInfo(ctx context.Context, in *UpdateWorkPlatformInfoReq, opts ...grpc_go.CallOption) (*UpdateWorkPlatformInfoResp, common.ErrorWithAttachment)
UpdateWorkPublishLog(ctx context.Context, in *UpdateWorkPublishLogReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment)
OAuthAccount(ctx context.Context, in *OAuthAccountReq, opts ...grpc_go.CallOption) (*OAuthAccountResp, common.ErrorWithAttachment)
OAuthAccountV2(ctx context.Context, in *OAuthAccountV2Req, opts ...grpc_go.CallOption) (*OAuthAccountV2Resp, common.ErrorWithAttachment)
OAuthCodeToToken(ctx context.Context, in *OAuthCodeToTokenReq, opts ...grpc_go.CallOption) (*OAuthCodeToTokenResp, common.ErrorWithAttachment)
RefreshToken(ctx context.Context, in *RefreshTokenReq, opts ...grpc_go.CallOption) (*RefreshTokenResp, common.ErrorWithAttachment)
PublishMediaInfo(ctx context.Context, in *PublishMediaInfoReq, opts ...grpc_go.CallOption) (*PublishMediaInfoResp, common.ErrorWithAttachment)
@ -67,6 +70,9 @@ type CastClient interface {
GetPrompt(ctx context.Context, in *GetPromptReq, opts ...grpc_go.CallOption) (*GetPromptResp, common.ErrorWithAttachment)
ListPrompts(ctx context.Context, in *ListPromptsReq, opts ...grpc_go.CallOption) (*ListPromptsResp, common.ErrorWithAttachment)
UpdatePromptBatch(ctx context.Context, in *UpdatePromptBatchReq, opts ...grpc_go.CallOption) (*UpdatePromptBatchResp, common.ErrorWithAttachment)
// 艺人相关接口
UpdateArtist(ctx context.Context, in *UpdateArtistReq, opts ...grpc_go.CallOption) (*UpdateArtistResp, common.ErrorWithAttachment)
GetArtist(ctx context.Context, in *GetArtistReq, opts ...grpc_go.CallOption) (*GetArtistResp, common.ErrorWithAttachment)
// 作品分析相关接口
CreateWorkAnalysis(ctx context.Context, in *CreateWorkAnalysisReq, opts ...grpc_go.CallOption) (*CreateWorkAnalysisResp, common.ErrorWithAttachment)
UpdateWorkAnalysis(ctx context.Context, in *UpdateWorkAnalysisReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment)
@ -104,7 +110,10 @@ type CastClientImpl struct {
WorkInfo func(ctx context.Context, in *WorkInfoReq) (*WorkInfoResp, error)
ArtistInfo func(ctx context.Context, in *ArtistInfoReq) (*ArtistInfoResp, error)
ImportWorkBatch func(ctx context.Context, in *ImportWorkBatchReq) (*ImportWorkBatchResp, error)
UpdateWorkPlatformInfo func(ctx context.Context, in *UpdateWorkPlatformInfoReq) (*UpdateWorkPlatformInfoResp, error)
UpdateWorkPublishLog func(ctx context.Context, in *UpdateWorkPublishLogReq) (*emptypb.Empty, error)
OAuthAccount func(ctx context.Context, in *OAuthAccountReq) (*OAuthAccountResp, error)
OAuthAccountV2 func(ctx context.Context, in *OAuthAccountV2Req) (*OAuthAccountV2Resp, error)
OAuthCodeToToken func(ctx context.Context, in *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error)
RefreshToken func(ctx context.Context, in *RefreshTokenReq) (*RefreshTokenResp, error)
PublishMediaInfo func(ctx context.Context, in *PublishMediaInfoReq) (*PublishMediaInfoResp, error)
@ -122,6 +131,8 @@ type CastClientImpl struct {
GetPrompt func(ctx context.Context, in *GetPromptReq) (*GetPromptResp, error)
ListPrompts func(ctx context.Context, in *ListPromptsReq) (*ListPromptsResp, error)
UpdatePromptBatch func(ctx context.Context, in *UpdatePromptBatchReq) (*UpdatePromptBatchResp, error)
UpdateArtist func(ctx context.Context, in *UpdateArtistReq) (*UpdateArtistResp, error)
GetArtist func(ctx context.Context, in *GetArtistReq) (*GetArtistResp, error)
CreateWorkAnalysis func(ctx context.Context, in *CreateWorkAnalysisReq) (*CreateWorkAnalysisResp, error)
UpdateWorkAnalysis func(ctx context.Context, in *UpdateWorkAnalysisReq) (*emptypb.Empty, error)
UpdateWorkAnalysisStatus func(ctx context.Context, in *UpdateWorkAnalysisStatusReq) (*emptypb.Empty, error)
@ -254,12 +265,30 @@ func (c *castClient) ImportWorkBatch(ctx context.Context, in *ImportWorkBatchReq
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ImportWorkBatch", in, out)
}
func (c *castClient) UpdateWorkPlatformInfo(ctx context.Context, in *UpdateWorkPlatformInfoReq, opts ...grpc_go.CallOption) (*UpdateWorkPlatformInfoResp, common.ErrorWithAttachment) {
out := new(UpdateWorkPlatformInfoResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateWorkPlatformInfo", in, out)
}
func (c *castClient) UpdateWorkPublishLog(ctx context.Context, in *UpdateWorkPublishLogReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) {
out := new(emptypb.Empty)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateWorkPublishLog", in, out)
}
func (c *castClient) OAuthAccount(ctx context.Context, in *OAuthAccountReq, opts ...grpc_go.CallOption) (*OAuthAccountResp, common.ErrorWithAttachment) {
out := new(OAuthAccountResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/OAuthAccount", in, out)
}
func (c *castClient) OAuthAccountV2(ctx context.Context, in *OAuthAccountV2Req, opts ...grpc_go.CallOption) (*OAuthAccountV2Resp, common.ErrorWithAttachment) {
out := new(OAuthAccountV2Resp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/OAuthAccountV2", in, out)
}
func (c *castClient) OAuthCodeToToken(ctx context.Context, in *OAuthCodeToTokenReq, opts ...grpc_go.CallOption) (*OAuthCodeToTokenResp, common.ErrorWithAttachment) {
out := new(OAuthCodeToTokenResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -362,6 +391,18 @@ func (c *castClient) UpdatePromptBatch(ctx context.Context, in *UpdatePromptBatc
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdatePromptBatch", in, out)
}
func (c *castClient) UpdateArtist(ctx context.Context, in *UpdateArtistReq, opts ...grpc_go.CallOption) (*UpdateArtistResp, common.ErrorWithAttachment) {
out := new(UpdateArtistResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateArtist", in, out)
}
func (c *castClient) GetArtist(ctx context.Context, in *GetArtistReq, opts ...grpc_go.CallOption) (*GetArtistResp, common.ErrorWithAttachment) {
out := new(GetArtistResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetArtist", in, out)
}
func (c *castClient) CreateWorkAnalysis(ctx context.Context, in *CreateWorkAnalysisReq, opts ...grpc_go.CallOption) (*CreateWorkAnalysisResp, common.ErrorWithAttachment) {
out := new(CreateWorkAnalysisResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -444,7 +485,10 @@ type CastServer interface {
WorkInfo(context.Context, *WorkInfoReq) (*WorkInfoResp, error)
ArtistInfo(context.Context, *ArtistInfoReq) (*ArtistInfoResp, error)
ImportWorkBatch(context.Context, *ImportWorkBatchReq) (*ImportWorkBatchResp, error)
UpdateWorkPlatformInfo(context.Context, *UpdateWorkPlatformInfoReq) (*UpdateWorkPlatformInfoResp, error)
UpdateWorkPublishLog(context.Context, *UpdateWorkPublishLogReq) (*emptypb.Empty, error)
OAuthAccount(context.Context, *OAuthAccountReq) (*OAuthAccountResp, error)
OAuthAccountV2(context.Context, *OAuthAccountV2Req) (*OAuthAccountV2Resp, error)
OAuthCodeToToken(context.Context, *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error)
RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenResp, error)
PublishMediaInfo(context.Context, *PublishMediaInfoReq) (*PublishMediaInfoResp, error)
@ -464,6 +508,9 @@ type CastServer interface {
GetPrompt(context.Context, *GetPromptReq) (*GetPromptResp, error)
ListPrompts(context.Context, *ListPromptsReq) (*ListPromptsResp, error)
UpdatePromptBatch(context.Context, *UpdatePromptBatchReq) (*UpdatePromptBatchResp, error)
// 艺人相关接口
UpdateArtist(context.Context, *UpdateArtistReq) (*UpdateArtistResp, error)
GetArtist(context.Context, *GetArtistReq) (*GetArtistResp, error)
// 作品分析相关接口
CreateWorkAnalysis(context.Context, *CreateWorkAnalysisReq) (*CreateWorkAnalysisResp, error)
UpdateWorkAnalysis(context.Context, *UpdateWorkAnalysisReq) (*emptypb.Empty, error)
@ -538,9 +585,18 @@ func (UnimplementedCastServer) ArtistInfo(context.Context, *ArtistInfoReq) (*Art
func (UnimplementedCastServer) ImportWorkBatch(context.Context, *ImportWorkBatchReq) (*ImportWorkBatchResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method ImportWorkBatch not implemented")
}
func (UnimplementedCastServer) UpdateWorkPlatformInfo(context.Context, *UpdateWorkPlatformInfoReq) (*UpdateWorkPlatformInfoResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateWorkPlatformInfo not implemented")
}
func (UnimplementedCastServer) UpdateWorkPublishLog(context.Context, *UpdateWorkPublishLogReq) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateWorkPublishLog not implemented")
}
func (UnimplementedCastServer) OAuthAccount(context.Context, *OAuthAccountReq) (*OAuthAccountResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method OAuthAccount not implemented")
}
func (UnimplementedCastServer) OAuthAccountV2(context.Context, *OAuthAccountV2Req) (*OAuthAccountV2Resp, error) {
return nil, status.Errorf(codes.Unimplemented, "method OAuthAccountV2 not implemented")
}
func (UnimplementedCastServer) OAuthCodeToToken(context.Context, *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method OAuthCodeToToken not implemented")
}
@ -592,6 +648,12 @@ func (UnimplementedCastServer) ListPrompts(context.Context, *ListPromptsReq) (*L
func (UnimplementedCastServer) UpdatePromptBatch(context.Context, *UpdatePromptBatchReq) (*UpdatePromptBatchResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdatePromptBatch not implemented")
}
func (UnimplementedCastServer) UpdateArtist(context.Context, *UpdateArtistReq) (*UpdateArtistResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateArtist not implemented")
}
func (UnimplementedCastServer) GetArtist(context.Context, *GetArtistReq) (*GetArtistResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetArtist not implemented")
}
func (UnimplementedCastServer) CreateWorkAnalysis(context.Context, *CreateWorkAnalysisReq) (*CreateWorkAnalysisResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateWorkAnalysis not implemented")
}
@ -1172,6 +1234,64 @@ func _Cast_ImportWorkBatch_Handler(srv interface{}, ctx context.Context, dec fun
return interceptor(ctx, in, info, handler)
}
func _Cast_UpdateWorkPlatformInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateWorkPlatformInfoReq)
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("UpdateWorkPlatformInfo", 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 _Cast_UpdateWorkPublishLog_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateWorkPublishLogReq)
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("UpdateWorkPublishLog", 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 _Cast_OAuthAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(OAuthAccountReq)
if err := dec(in); err != nil {
@ -1201,6 +1321,35 @@ func _Cast_OAuthAccount_Handler(srv interface{}, ctx context.Context, dec func(i
return interceptor(ctx, in, info, handler)
}
func _Cast_OAuthAccountV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(OAuthAccountV2Req)
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("OAuthAccountV2", 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 _Cast_OAuthCodeToToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(OAuthCodeToTokenReq)
if err := dec(in); err != nil {
@ -1694,6 +1843,64 @@ func _Cast_UpdatePromptBatch_Handler(srv interface{}, ctx context.Context, dec f
return interceptor(ctx, in, info, handler)
}
func _Cast_UpdateArtist_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateArtistReq)
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("UpdateArtist", 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 _Cast_GetArtist_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(GetArtistReq)
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("GetArtist", 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 _Cast_CreateWorkAnalysis_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateWorkAnalysisReq)
if err := dec(in); err != nil {
@ -2063,10 +2270,22 @@ var Cast_ServiceDesc = grpc_go.ServiceDesc{
MethodName: "ImportWorkBatch",
Handler: _Cast_ImportWorkBatch_Handler,
},
{
MethodName: "UpdateWorkPlatformInfo",
Handler: _Cast_UpdateWorkPlatformInfo_Handler,
},
{
MethodName: "UpdateWorkPublishLog",
Handler: _Cast_UpdateWorkPublishLog_Handler,
},
{
MethodName: "OAuthAccount",
Handler: _Cast_OAuthAccount_Handler,
},
{
MethodName: "OAuthAccountV2",
Handler: _Cast_OAuthAccountV2_Handler,
},
{
MethodName: "OAuthCodeToToken",
Handler: _Cast_OAuthCodeToToken_Handler,
@ -2135,6 +2354,14 @@ var Cast_ServiceDesc = grpc_go.ServiceDesc{
MethodName: "UpdatePromptBatch",
Handler: _Cast_UpdatePromptBatch_Handler,
},
{
MethodName: "UpdateArtist",
Handler: _Cast_UpdateArtist_Handler,
},
{
MethodName: "GetArtist",
Handler: _Cast_GetArtist_Handler,
},
{
MethodName: "CreateWorkAnalysis",
Handler: _Cast_CreateWorkAnalysis_Handler,