Compare commits

...

5 Commits

Author SHA1 Message Date
b1bde71f34 Update task.go 2026-02-05 14:38:45 +08:00
f4c826936b 解绑取消授权记录 2026-02-04 19:02:42 +08:00
f59b434dc7 同步bundle的proto 2026-02-04 17:39:00 +08:00
39dc62b032 套餐续费和新购 2026-02-04 16:09:08 +08:00
5a814ab12f DM取消授权 2026-02-04 09:41:39 +08:00
9 changed files with 6365 additions and 4784 deletions

File diff suppressed because it is too large Load Diff

View File

@ -17,6 +17,9 @@ var _ = proto.Marshal
var _ = fmt.Errorf var _ = fmt.Errorf
var _ = math.Inf var _ = math.Inf
func (this *GetInEffectOrderRecordRequest) Validate() error {
return nil
}
func (this *QueryTheOrderSnapshotInformationReq) Validate() error { func (this *QueryTheOrderSnapshotInformationReq) Validate() error {
return nil return nil
} }
@ -812,3 +815,19 @@ func (this *MetricsVideoSubmitExportItem) Validate() error {
func (this *MetricsBalanceDetailExportReq) Validate() error { func (this *MetricsBalanceDetailExportReq) Validate() error {
return nil return nil
} }
func (this *WorkCastInfo) Validate() error {
return nil
}
func (this *ExportWorkCastInfoReq) Validate() error {
return nil
}
func (this *ExportWorkCastInfoResp) Validate() error {
for _, item := range this.Data {
if item != nil {
if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
return github_com_mwitkow_go_proto_validators.FieldError("Data", err)
}
}
}
return nil
}

View File

@ -51,6 +51,7 @@ type BundleClient interface {
OrderListByOrderNo(ctx context.Context, in *OrderInfoByOrderNoRequest, opts ...grpc_go.CallOption) (*OrderInfoByOrderNoResp, common.ErrorWithAttachment) OrderListByOrderNo(ctx context.Context, in *OrderInfoByOrderNoRequest, opts ...grpc_go.CallOption) (*OrderInfoByOrderNoResp, common.ErrorWithAttachment)
OnlyAddValueListByOrderNo(ctx context.Context, in *OnlyAddValueListByOrderNoRequest, opts ...grpc_go.CallOption) (*OnlyAddValueListByOrderNoResp, common.ErrorWithAttachment) OnlyAddValueListByOrderNo(ctx context.Context, in *OnlyAddValueListByOrderNoRequest, opts ...grpc_go.CallOption) (*OnlyAddValueListByOrderNoResp, common.ErrorWithAttachment)
ReSignTheContract(ctx context.Context, in *ReSignTheContractRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) ReSignTheContract(ctx context.Context, in *ReSignTheContractRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
GetInEffectOrderRecord(ctx context.Context, in *GetInEffectOrderRecordRequest, opts ...grpc_go.CallOption) (*OrderRecord, common.ErrorWithAttachment)
// 增值套餐 // 增值套餐
CreateValueAddBundle(ctx context.Context, in *CreateValueAddBundleRequest, opts ...grpc_go.CallOption) (*CreateValueAddBundleResponse, common.ErrorWithAttachment) CreateValueAddBundle(ctx context.Context, in *CreateValueAddBundleRequest, opts ...grpc_go.CallOption) (*CreateValueAddBundleResponse, common.ErrorWithAttachment)
ValueAddBundleList(ctx context.Context, in *ValueAddBundleListRequest, opts ...grpc_go.CallOption) (*ValueAddBundleListResponse, common.ErrorWithAttachment) ValueAddBundleList(ctx context.Context, in *ValueAddBundleListRequest, opts ...grpc_go.CallOption) (*ValueAddBundleListResponse, common.ErrorWithAttachment)
@ -119,6 +120,8 @@ type BundleClient interface {
MetricsArtistAccountExport(ctx context.Context, in *MetricsArtistAccountExportReq, opts ...grpc_go.CallOption) (*MetricsArtistAccountExportResp, common.ErrorWithAttachment) MetricsArtistAccountExport(ctx context.Context, in *MetricsArtistAccountExportReq, opts ...grpc_go.CallOption) (*MetricsArtistAccountExportResp, common.ErrorWithAttachment)
MetricsVideoSubmitExport(ctx context.Context, in *MetricsVideoSubmitExportReq, opts ...grpc_go.CallOption) (*MetricsVideoSubmitExportResp, common.ErrorWithAttachment) MetricsVideoSubmitExport(ctx context.Context, in *MetricsVideoSubmitExportReq, opts ...grpc_go.CallOption) (*MetricsVideoSubmitExportResp, common.ErrorWithAttachment)
QueryTheOrderSnapshotInformation(ctx context.Context, in *QueryTheOrderSnapshotInformationReq, opts ...grpc_go.CallOption) (*QueryTheOrderSnapshotInformationResp, common.ErrorWithAttachment) QueryTheOrderSnapshotInformation(ctx context.Context, in *QueryTheOrderSnapshotInformationReq, opts ...grpc_go.CallOption) (*QueryTheOrderSnapshotInformationResp, common.ErrorWithAttachment)
// 临时接口
ExportWorkCastInfo(ctx context.Context, in *ExportWorkCastInfoReq, opts ...grpc_go.CallOption) (*ExportWorkCastInfoResp, common.ErrorWithAttachment)
} }
type bundleClient struct { type bundleClient struct {
@ -149,6 +152,7 @@ type BundleClientImpl struct {
OrderListByOrderNo func(ctx context.Context, in *OrderInfoByOrderNoRequest) (*OrderInfoByOrderNoResp, error) OrderListByOrderNo func(ctx context.Context, in *OrderInfoByOrderNoRequest) (*OrderInfoByOrderNoResp, error)
OnlyAddValueListByOrderNo func(ctx context.Context, in *OnlyAddValueListByOrderNoRequest) (*OnlyAddValueListByOrderNoResp, error) OnlyAddValueListByOrderNo func(ctx context.Context, in *OnlyAddValueListByOrderNoRequest) (*OnlyAddValueListByOrderNoResp, error)
ReSignTheContract func(ctx context.Context, in *ReSignTheContractRequest) (*CommonResponse, error) ReSignTheContract func(ctx context.Context, in *ReSignTheContractRequest) (*CommonResponse, error)
GetInEffectOrderRecord func(ctx context.Context, in *GetInEffectOrderRecordRequest) (*OrderRecord, error)
CreateValueAddBundle func(ctx context.Context, in *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error) CreateValueAddBundle func(ctx context.Context, in *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error)
ValueAddBundleList func(ctx context.Context, in *ValueAddBundleListRequest) (*ValueAddBundleListResponse, error) ValueAddBundleList func(ctx context.Context, in *ValueAddBundleListRequest) (*ValueAddBundleListResponse, error)
ValueAddBundleDetail func(ctx context.Context, in *ValueAddBundleDetailRequest) (*ValueAddBundleDetailResponse, error) ValueAddBundleDetail func(ctx context.Context, in *ValueAddBundleDetailRequest) (*ValueAddBundleDetailResponse, error)
@ -209,6 +213,7 @@ type BundleClientImpl struct {
MetricsArtistAccountExport func(ctx context.Context, in *MetricsArtistAccountExportReq) (*MetricsArtistAccountExportResp, error) MetricsArtistAccountExport func(ctx context.Context, in *MetricsArtistAccountExportReq) (*MetricsArtistAccountExportResp, error)
MetricsVideoSubmitExport func(ctx context.Context, in *MetricsVideoSubmitExportReq) (*MetricsVideoSubmitExportResp, error) MetricsVideoSubmitExport func(ctx context.Context, in *MetricsVideoSubmitExportReq) (*MetricsVideoSubmitExportResp, error)
QueryTheOrderSnapshotInformation func(ctx context.Context, in *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error) QueryTheOrderSnapshotInformation func(ctx context.Context, in *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error)
ExportWorkCastInfo func(ctx context.Context, in *ExportWorkCastInfoReq) (*ExportWorkCastInfoResp, error)
} }
func (c *BundleClientImpl) GetDubboStub(cc *triple.TripleConn) BundleClient { func (c *BundleClientImpl) GetDubboStub(cc *triple.TripleConn) BundleClient {
@ -361,6 +366,12 @@ func (c *bundleClient) ReSignTheContract(ctx context.Context, in *ReSignTheContr
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ReSignTheContract", in, out) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ReSignTheContract", in, out)
} }
func (c *bundleClient) GetInEffectOrderRecord(ctx context.Context, in *GetInEffectOrderRecordRequest, opts ...grpc_go.CallOption) (*OrderRecord, common.ErrorWithAttachment) {
out := new(OrderRecord)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetInEffectOrderRecord", in, out)
}
func (c *bundleClient) CreateValueAddBundle(ctx context.Context, in *CreateValueAddBundleRequest, opts ...grpc_go.CallOption) (*CreateValueAddBundleResponse, common.ErrorWithAttachment) { func (c *bundleClient) CreateValueAddBundle(ctx context.Context, in *CreateValueAddBundleRequest, opts ...grpc_go.CallOption) (*CreateValueAddBundleResponse, common.ErrorWithAttachment) {
out := new(CreateValueAddBundleResponse) out := new(CreateValueAddBundleResponse)
interfaceKey := ctx.Value(constant.InterfaceKey).(string) interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -721,6 +732,12 @@ func (c *bundleClient) QueryTheOrderSnapshotInformation(ctx context.Context, in
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/QueryTheOrderSnapshotInformation", in, out) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/QueryTheOrderSnapshotInformation", in, out)
} }
func (c *bundleClient) ExportWorkCastInfo(ctx context.Context, in *ExportWorkCastInfoReq, opts ...grpc_go.CallOption) (*ExportWorkCastInfoResp, common.ErrorWithAttachment) {
out := new(ExportWorkCastInfoResp)
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ExportWorkCastInfo", in, out)
}
// BundleServer is the server API for Bundle service. // BundleServer is the server API for Bundle service.
// All implementations must embed UnimplementedBundleServer // All implementations must embed UnimplementedBundleServer
// for forward compatibility // for forward compatibility
@ -748,6 +765,7 @@ type BundleServer interface {
OrderListByOrderNo(context.Context, *OrderInfoByOrderNoRequest) (*OrderInfoByOrderNoResp, error) OrderListByOrderNo(context.Context, *OrderInfoByOrderNoRequest) (*OrderInfoByOrderNoResp, error)
OnlyAddValueListByOrderNo(context.Context, *OnlyAddValueListByOrderNoRequest) (*OnlyAddValueListByOrderNoResp, error) OnlyAddValueListByOrderNo(context.Context, *OnlyAddValueListByOrderNoRequest) (*OnlyAddValueListByOrderNoResp, error)
ReSignTheContract(context.Context, *ReSignTheContractRequest) (*CommonResponse, error) ReSignTheContract(context.Context, *ReSignTheContractRequest) (*CommonResponse, error)
GetInEffectOrderRecord(context.Context, *GetInEffectOrderRecordRequest) (*OrderRecord, error)
// 增值套餐 // 增值套餐
CreateValueAddBundle(context.Context, *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error) CreateValueAddBundle(context.Context, *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error)
ValueAddBundleList(context.Context, *ValueAddBundleListRequest) (*ValueAddBundleListResponse, error) ValueAddBundleList(context.Context, *ValueAddBundleListRequest) (*ValueAddBundleListResponse, error)
@ -816,6 +834,8 @@ type BundleServer interface {
MetricsArtistAccountExport(context.Context, *MetricsArtistAccountExportReq) (*MetricsArtistAccountExportResp, error) MetricsArtistAccountExport(context.Context, *MetricsArtistAccountExportReq) (*MetricsArtistAccountExportResp, error)
MetricsVideoSubmitExport(context.Context, *MetricsVideoSubmitExportReq) (*MetricsVideoSubmitExportResp, error) MetricsVideoSubmitExport(context.Context, *MetricsVideoSubmitExportReq) (*MetricsVideoSubmitExportResp, error)
QueryTheOrderSnapshotInformation(context.Context, *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error) QueryTheOrderSnapshotInformation(context.Context, *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error)
// 临时接口
ExportWorkCastInfo(context.Context, *ExportWorkCastInfoReq) (*ExportWorkCastInfoResp, error)
mustEmbedUnimplementedBundleServer() mustEmbedUnimplementedBundleServer()
} }
@ -893,6 +913,9 @@ func (UnimplementedBundleServer) OnlyAddValueListByOrderNo(context.Context, *Onl
func (UnimplementedBundleServer) ReSignTheContract(context.Context, *ReSignTheContractRequest) (*CommonResponse, error) { func (UnimplementedBundleServer) ReSignTheContract(context.Context, *ReSignTheContractRequest) (*CommonResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReSignTheContract not implemented") return nil, status.Errorf(codes.Unimplemented, "method ReSignTheContract not implemented")
} }
func (UnimplementedBundleServer) GetInEffectOrderRecord(context.Context, *GetInEffectOrderRecordRequest) (*OrderRecord, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetInEffectOrderRecord not implemented")
}
func (UnimplementedBundleServer) CreateValueAddBundle(context.Context, *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error) { func (UnimplementedBundleServer) CreateValueAddBundle(context.Context, *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateValueAddBundle not implemented") return nil, status.Errorf(codes.Unimplemented, "method CreateValueAddBundle not implemented")
} }
@ -1073,6 +1096,9 @@ func (UnimplementedBundleServer) MetricsVideoSubmitExport(context.Context, *Metr
func (UnimplementedBundleServer) QueryTheOrderSnapshotInformation(context.Context, *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error) { func (UnimplementedBundleServer) QueryTheOrderSnapshotInformation(context.Context, *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method QueryTheOrderSnapshotInformation not implemented") return nil, status.Errorf(codes.Unimplemented, "method QueryTheOrderSnapshotInformation not implemented")
} }
func (UnimplementedBundleServer) ExportWorkCastInfo(context.Context, *ExportWorkCastInfoReq) (*ExportWorkCastInfoResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method ExportWorkCastInfo not implemented")
}
func (s *UnimplementedBundleServer) XXX_SetProxyImpl(impl protocol.Invoker) { func (s *UnimplementedBundleServer) XXX_SetProxyImpl(impl protocol.Invoker) {
s.proxyImpl = impl s.proxyImpl = impl
} }
@ -1768,6 +1794,35 @@ func _Bundle_ReSignTheContract_Handler(srv interface{}, ctx context.Context, dec
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _Bundle_GetInEffectOrderRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(GetInEffectOrderRecordRequest)
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("GetInEffectOrderRecord", 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 _Bundle_CreateValueAddBundle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { func _Bundle_CreateValueAddBundle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateValueAddBundleRequest) in := new(CreateValueAddBundleRequest)
if err := dec(in); err != nil { if err := dec(in); err != nil {
@ -3508,6 +3563,35 @@ func _Bundle_QueryTheOrderSnapshotInformation_Handler(srv interface{}, ctx conte
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _Bundle_ExportWorkCastInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
in := new(ExportWorkCastInfoReq)
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("ExportWorkCastInfo", 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)
}
// Bundle_ServiceDesc is the grpc_go.ServiceDesc for Bundle service. // Bundle_ServiceDesc is the grpc_go.ServiceDesc for Bundle service.
// It's only intended for direct use with grpc_go.RegisterService, // It's only intended for direct use with grpc_go.RegisterService,
// and not to be introspected or modified (even as a copy) // and not to be introspected or modified (even as a copy)
@ -3607,6 +3691,10 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
MethodName: "ReSignTheContract", MethodName: "ReSignTheContract",
Handler: _Bundle_ReSignTheContract_Handler, Handler: _Bundle_ReSignTheContract_Handler,
}, },
{
MethodName: "GetInEffectOrderRecord",
Handler: _Bundle_GetInEffectOrderRecord_Handler,
},
{ {
MethodName: "CreateValueAddBundle", MethodName: "CreateValueAddBundle",
Handler: _Bundle_CreateValueAddBundle_Handler, Handler: _Bundle_CreateValueAddBundle_Handler,
@ -3847,6 +3935,10 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
MethodName: "QueryTheOrderSnapshotInformation", MethodName: "QueryTheOrderSnapshotInformation",
Handler: _Bundle_QueryTheOrderSnapshotInformation_Handler, Handler: _Bundle_QueryTheOrderSnapshotInformation_Handler,
}, },
{
MethodName: "ExportWorkCastInfo",
Handler: _Bundle_ExportWorkCastInfo_Handler,
},
}, },
Streams: []grpc_go.StreamDesc{}, Streams: []grpc_go.StreamDesc{},
Metadata: "pb/bundle.proto", Metadata: "pb/bundle.proto",

View File

@ -16622,6 +16622,7 @@ type UpdateMediaAccInfoReq struct {
Expired uint32 `protobuf:"varint,3,opt,name=expired,proto3" json:"expired"` // 过期状态 1-未过期 2-已过期(可选) Expired uint32 `protobuf:"varint,3,opt,name=expired,proto3" json:"expired"` // 过期状态 1-未过期 2-已过期(可选)
ExpiredSource ExpiredMediaSourceENUM `protobuf:"varint,4,opt,name=expiredSource,proto3,enum=Cast.ExpiredMediaSourceENUM" json:"expiredSource"` // 过期来源 1 后台管理员更新 2 艺人端更新 3 订单检查 4 充值 ExpiredSource ExpiredMediaSourceENUM `protobuf:"varint,4,opt,name=expiredSource,proto3,enum=Cast.ExpiredMediaSourceENUM" json:"expiredSource"` // 过期来源 1 后台管理员更新 2 艺人端更新 3 订单检查 4 充值
Remark string `protobuf:"bytes,5,opt,name=remark,proto3" json:"remark"` // 备注信息(可选) Remark string `protobuf:"bytes,5,opt,name=remark,proto3" json:"remark"` // 备注信息(可选)
AuthStatus AuthStatusENUM `protobuf:"varint,6,opt,name=authStatus,proto3,enum=Cast.AuthStatusENUM" json:"authStatus"` // 授权状态 1-已授权 2-未授权(可选)
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
} }
@ -16691,6 +16692,13 @@ func (x *UpdateMediaAccInfoReq) GetRemark() string {
return "" return ""
} }
func (x *UpdateMediaAccInfoReq) GetAuthStatus() AuthStatusENUM {
if x != nil {
return x.AuthStatus
}
return AuthStatusENUM_UNKNOWNAuth
}
type WorkListResp_Info struct { type WorkListResp_Info struct {
state protoimpl.MessageState `protogen:"open.v1"` state protoimpl.MessageState `protogen:"open.v1"`
WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"` WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"`
@ -19495,13 +19503,16 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
"\x06remark\x18\x02 \x01(\tR\x06remark\"I\n" + "\x06remark\x18\x02 \x01(\tR\x06remark\"I\n" +
"\x13UnbindMediaAuthResp\x12\x18\n" + "\x13UnbindMediaAuthResp\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" + "\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\"\xe3\x01\n" + "\amessage\x18\x02 \x01(\tR\amessage\"\x99\x02\n" +
"\x15UpdateMediaAccInfoReq\x12*\n" + "\x15UpdateMediaAccInfoReq\x12*\n" +
"\x10mediaAccountUuid\x18\x01 \x01(\tR\x10mediaAccountUuid\x12(\n" + "\x10mediaAccountUuid\x18\x01 \x01(\tR\x10mediaAccountUuid\x12(\n" +
"\x0fexceptionStatus\x18\x02 \x01(\rR\x0fexceptionStatus\x12\x18\n" + "\x0fexceptionStatus\x18\x02 \x01(\rR\x0fexceptionStatus\x12\x18\n" +
"\aexpired\x18\x03 \x01(\rR\aexpired\x12B\n" + "\aexpired\x18\x03 \x01(\rR\aexpired\x12B\n" +
"\rexpiredSource\x18\x04 \x01(\x0e2\x1c.Cast.ExpiredMediaSourceENUMR\rexpiredSource\x12\x16\n" + "\rexpiredSource\x18\x04 \x01(\x0e2\x1c.Cast.ExpiredMediaSourceENUMR\rexpiredSource\x12\x16\n" +
"\x06remark\x18\x05 \x01(\tR\x06remark*T\n" + "\x06remark\x18\x05 \x01(\tR\x06remark\x124\n" +
"\n" +
"authStatus\x18\x06 \x01(\x0e2\x14.Cast.AuthStatusENUMR\n" +
"authStatus*T\n" +
"\x0ePlatformIDENUM\x12\v\n" + "\x0ePlatformIDENUM\x12\v\n" +
"\aUNKNOWN\x10\x00\x12\n" + "\aUNKNOWN\x10\x00\x12\n" +
"\n" + "\n" +
@ -20012,198 +20023,199 @@ var file_pb_fiee_cast_proto_depIdxs = []int32{
179, // 122: Cast.ImportCompetitiveReportBatchResp.reports:type_name -> Cast.CreateCompetitiveReportReq 179, // 122: Cast.ImportCompetitiveReportBatchResp.reports:type_name -> Cast.CreateCompetitiveReportReq
197, // 123: Cast.CountCompetitiveReportByWorkUuidsResp.data:type_name -> Cast.WorkUuidCount 197, // 123: Cast.CountCompetitiveReportByWorkUuidsResp.data:type_name -> Cast.WorkUuidCount
2, // 124: Cast.UpdateMediaAccInfoReq.expiredSource:type_name -> Cast.ExpiredMediaSourceENUM 2, // 124: Cast.UpdateMediaAccInfoReq.expiredSource:type_name -> Cast.ExpiredMediaSourceENUM
209, // 125: Cast.WorkListResp.Info.PublishMediaIDs:type_name -> Cast.WorkListResp.Info.PublishMediaIDsEntry 1, // 125: Cast.UpdateMediaAccInfoReq.authStatus:type_name -> Cast.AuthStatusENUM
11, // 126: Cast.WorkDetailResp.MediaAccDataEntry.value:type_name -> Cast.MediaUserInfo 209, // 126: Cast.WorkListResp.Info.PublishMediaIDs:type_name -> Cast.WorkListResp.Info.PublishMediaIDsEntry
216, // 127: Cast.RefreshWorkListResp.Info.PlatformInfoData:type_name -> Cast.RefreshWorkListResp.Info.PlatformInfo 11, // 127: Cast.WorkDetailResp.MediaAccDataEntry.value:type_name -> Cast.MediaUserInfo
0, // 128: Cast.RefreshWorkListResp.Info.PlatformInfo.platformID:type_name -> Cast.PlatformIDENUM 216, // 128: Cast.RefreshWorkListResp.Info.PlatformInfoData:type_name -> Cast.RefreshWorkListResp.Info.PlatformInfo
0, // 129: Cast.UpdateOAuthReq.Info.platformID:type_name -> Cast.PlatformIDENUM 0, // 129: Cast.RefreshWorkListResp.Info.PlatformInfo.platformID:type_name -> Cast.PlatformIDENUM
10, // 130: Cast.Cast.MediaUserList:input_type -> Cast.MediaUserListReq 0, // 130: Cast.UpdateOAuthReq.Info.platformID:type_name -> Cast.PlatformIDENUM
13, // 131: Cast.Cast.UpdateMediaAccount:input_type -> Cast.UpdateMediaAccountReq 10, // 131: Cast.Cast.MediaUserList:input_type -> Cast.MediaUserListReq
15, // 132: Cast.Cast.UnbindManager:input_type -> Cast.UnbindManagerReq 13, // 132: Cast.Cast.UpdateMediaAccount:input_type -> Cast.UpdateMediaAccountReq
17, // 133: Cast.Cast.BindManager:input_type -> Cast.BindManagerReq 15, // 133: Cast.Cast.UnbindManager:input_type -> Cast.UnbindManagerReq
18, // 134: Cast.Cast.UpdateWorkImage:input_type -> Cast.UpdateWorkImageReq 17, // 134: Cast.Cast.BindManager:input_type -> Cast.BindManagerReq
21, // 135: Cast.Cast.UpdateWorkVideo:input_type -> Cast.UpdateWorkVideoReq 18, // 135: Cast.Cast.UpdateWorkImage:input_type -> Cast.UpdateWorkImageReq
23, // 136: Cast.Cast.MediaInfo:input_type -> Cast.MediaInfoReq 21, // 136: Cast.Cast.UpdateWorkVideo:input_type -> Cast.UpdateWorkVideoReq
25, // 137: Cast.Cast.MediaInfoByPlatform:input_type -> Cast.MediaInfoByPlatformReq 23, // 137: Cast.Cast.MediaInfo:input_type -> Cast.MediaInfoReq
27, // 138: Cast.Cast.WorkList:input_type -> Cast.WorkListReq 25, // 138: Cast.Cast.MediaInfoByPlatform:input_type -> Cast.MediaInfoByPlatformReq
44, // 139: Cast.Cast.WorkListPublished:input_type -> Cast.WorkListPublishedReq 27, // 139: Cast.Cast.WorkList:input_type -> Cast.WorkListReq
29, // 140: Cast.Cast.WorkDetail:input_type -> Cast.WorkDetailReq 44, // 140: Cast.Cast.WorkListPublished:input_type -> Cast.WorkListPublishedReq
32, // 141: Cast.Cast.UpdateStatus:input_type -> Cast.UpdateStatusReq 29, // 141: Cast.Cast.WorkDetail:input_type -> Cast.WorkDetailReq
33, // 142: Cast.Cast.MediaAccounts:input_type -> Cast.MediaAccountsReq 32, // 142: Cast.Cast.UpdateStatus:input_type -> Cast.UpdateStatusReq
35, // 143: Cast.Cast.MediaWorks:input_type -> Cast.MediaWorksReq 33, // 143: Cast.Cast.MediaAccounts:input_type -> Cast.MediaAccountsReq
37, // 144: Cast.Cast.Publish:input_type -> Cast.PublishReq 35, // 144: Cast.Cast.MediaWorks:input_type -> Cast.MediaWorksReq
39, // 145: Cast.Cast.RePublish:input_type -> Cast.RePublishReq 37, // 145: Cast.Cast.Publish:input_type -> Cast.PublishReq
41, // 146: Cast.Cast.DelWork:input_type -> Cast.DelWorkReq 39, // 146: Cast.Cast.RePublish:input_type -> Cast.RePublishReq
42, // 147: Cast.Cast.WorkInfo:input_type -> Cast.WorkInfoReq 41, // 147: Cast.Cast.DelWork:input_type -> Cast.DelWorkReq
46, // 148: Cast.Cast.ArtistInfo:input_type -> Cast.ArtistInfoReq 42, // 148: Cast.Cast.WorkInfo:input_type -> Cast.WorkInfoReq
48, // 149: Cast.Cast.ImportWorkBatch:input_type -> Cast.ImportWorkBatchReq 46, // 149: Cast.Cast.ArtistInfo:input_type -> Cast.ArtistInfoReq
51, // 150: Cast.Cast.UpdateWorkPlatformInfo:input_type -> Cast.UpdateWorkPlatformInfoReq 48, // 150: Cast.Cast.ImportWorkBatch:input_type -> Cast.ImportWorkBatchReq
53, // 151: Cast.Cast.UpdateWorkPublishLog:input_type -> Cast.UpdateWorkPublishLogReq 51, // 151: Cast.Cast.UpdateWorkPlatformInfo:input_type -> Cast.UpdateWorkPlatformInfoReq
54, // 152: Cast.Cast.RefreshWorkList:input_type -> Cast.RefreshWorkListReq 53, // 152: Cast.Cast.UpdateWorkPublishLog:input_type -> Cast.UpdateWorkPublishLogReq
199, // 153: Cast.Cast.WorkResource:input_type -> Cast.WorkResourceReq 54, // 153: Cast.Cast.RefreshWorkList:input_type -> Cast.RefreshWorkListReq
201, // 154: Cast.Cast.UpdateWorkResource:input_type -> Cast.UpdateWorkResourceReq 199, // 154: Cast.Cast.WorkResource:input_type -> Cast.WorkResourceReq
203, // 155: Cast.Cast.UpdateMediaAccStatus:input_type -> Cast.UpdateMediaAccStatusReq 201, // 155: Cast.Cast.UpdateWorkResource:input_type -> Cast.UpdateWorkResourceReq
56, // 156: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq 203, // 156: Cast.Cast.UpdateMediaAccStatus:input_type -> Cast.UpdateMediaAccStatusReq
205, // 157: Cast.Cast.UnbindMediaAuth:input_type -> Cast.UnbindMediaAuthReq 56, // 157: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq
207, // 158: Cast.Cast.UpdateMediaAccInfo:input_type -> Cast.UpdateMediaAccInfoReq 205, // 158: Cast.Cast.UnbindMediaAuth:input_type -> Cast.UnbindMediaAuthReq
58, // 159: Cast.Cast.OAuthAccountV2:input_type -> Cast.OAuthAccountV2Req 207, // 159: Cast.Cast.UpdateMediaAccInfo:input_type -> Cast.UpdateMediaAccInfoReq
62, // 160: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq 58, // 160: Cast.Cast.OAuthAccountV2:input_type -> Cast.OAuthAccountV2Req
64, // 161: Cast.Cast.UpdateOAuth:input_type -> Cast.UpdateOAuthReq 62, // 161: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq
65, // 162: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq 64, // 162: Cast.Cast.UpdateOAuth:input_type -> Cast.UpdateOAuthReq
67, // 163: Cast.Cast.PublishMediaInfo:input_type -> Cast.PublishMediaInfoReq 65, // 163: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq
69, // 164: Cast.Cast.Tools:input_type -> Cast.ToolsReq 67, // 164: Cast.Cast.PublishMediaInfo:input_type -> Cast.PublishMediaInfoReq
70, // 165: Cast.Cast.UpdateVideoScript:input_type -> Cast.UpdateVideoScriptReq 69, // 165: Cast.Cast.Tools:input_type -> Cast.ToolsReq
72, // 166: Cast.Cast.GetVideoScript:input_type -> Cast.GetVideoScriptReq 70, // 166: Cast.Cast.UpdateVideoScript:input_type -> Cast.UpdateVideoScriptReq
74, // 167: Cast.Cast.ListVideoScripts:input_type -> Cast.ListVideoScriptsReq 72, // 167: Cast.Cast.GetVideoScript:input_type -> Cast.GetVideoScriptReq
77, // 168: Cast.Cast.DeleteVideoScript:input_type -> Cast.DeleteVideoScriptReq 74, // 168: Cast.Cast.ListVideoScripts:input_type -> Cast.ListVideoScriptsReq
78, // 169: Cast.Cast.UpdateVideoScriptBatch:input_type -> Cast.UpdateVideoScriptBatchReq 77, // 169: Cast.Cast.DeleteVideoScript:input_type -> Cast.DeleteVideoScriptReq
80, // 170: Cast.Cast.UpdateScriptStatus:input_type -> Cast.UpdateScriptStatusReq 78, // 170: Cast.Cast.UpdateVideoScriptBatch:input_type -> Cast.UpdateVideoScriptBatchReq
82, // 171: Cast.Cast.GetLayout:input_type -> Cast.GetLayoutReq 80, // 171: Cast.Cast.UpdateScriptStatus:input_type -> Cast.UpdateScriptStatusReq
81, // 172: Cast.Cast.SetLayout:input_type -> Cast.SetLayoutReq 82, // 172: Cast.Cast.GetLayout:input_type -> Cast.GetLayoutReq
84, // 173: Cast.Cast.UpdatePrompt:input_type -> Cast.UpdatePromptReq 81, // 173: Cast.Cast.SetLayout:input_type -> Cast.SetLayoutReq
85, // 174: Cast.Cast.DeletePrompt:input_type -> Cast.DeletePromptReq 84, // 174: Cast.Cast.UpdatePrompt:input_type -> Cast.UpdatePromptReq
86, // 175: Cast.Cast.GetPrompt:input_type -> Cast.GetPromptReq 85, // 175: Cast.Cast.DeletePrompt:input_type -> Cast.DeletePromptReq
88, // 176: Cast.Cast.ListPrompts:input_type -> Cast.ListPromptsReq 86, // 176: Cast.Cast.GetPrompt:input_type -> Cast.GetPromptReq
91, // 177: Cast.Cast.UpdatePromptBatch:input_type -> Cast.UpdatePromptBatchReq 88, // 177: Cast.Cast.ListPrompts:input_type -> Cast.ListPromptsReq
94, // 178: Cast.Cast.UpdateArtist:input_type -> Cast.UpdateArtistReq 91, // 178: Cast.Cast.UpdatePromptBatch:input_type -> Cast.UpdatePromptBatchReq
96, // 179: Cast.Cast.GetArtist:input_type -> Cast.GetArtistReq 94, // 179: Cast.Cast.UpdateArtist:input_type -> Cast.UpdateArtistReq
98, // 180: Cast.Cast.CreateWorkAnalysis:input_type -> Cast.CreateWorkAnalysisReq 96, // 180: Cast.Cast.GetArtist:input_type -> Cast.GetArtistReq
100, // 181: Cast.Cast.UpdateWorkAnalysis:input_type -> Cast.UpdateWorkAnalysisReq 98, // 181: Cast.Cast.CreateWorkAnalysis:input_type -> Cast.CreateWorkAnalysisReq
101, // 182: Cast.Cast.UpdateWorkAnalysisStatus:input_type -> Cast.UpdateWorkAnalysisStatusReq 100, // 182: Cast.Cast.UpdateWorkAnalysis:input_type -> Cast.UpdateWorkAnalysisReq
112, // 183: Cast.Cast.GetWorkAnalysis:input_type -> Cast.GetWorkAnalysisDetailReq 101, // 183: Cast.Cast.UpdateWorkAnalysisStatus:input_type -> Cast.UpdateWorkAnalysisStatusReq
113, // 184: Cast.Cast.GetLatestWorkAnalysis:input_type -> Cast.GetLatestWorkAnalysisReq 112, // 184: Cast.Cast.GetWorkAnalysis:input_type -> Cast.GetWorkAnalysisDetailReq
116, // 185: Cast.Cast.ListWorkAnalysis:input_type -> Cast.ListWorkAnalysisReq 113, // 185: Cast.Cast.GetLatestWorkAnalysis:input_type -> Cast.GetLatestWorkAnalysisReq
119, // 186: Cast.Cast.DeleteWorkAnalysis:input_type -> Cast.DeleteWorkAnalysisReq 116, // 186: Cast.Cast.ListWorkAnalysis:input_type -> Cast.ListWorkAnalysisReq
138, // 187: Cast.Cast.UpdateWorkAnalysisApprovalID:input_type -> Cast.UpdateWorkAnalysisApprovalIDReq 119, // 187: Cast.Cast.DeleteWorkAnalysis:input_type -> Cast.DeleteWorkAnalysisReq
120, // 188: Cast.Cast.ArtistDataList:input_type -> Cast.ArtistDataListReq 138, // 188: Cast.Cast.UpdateWorkAnalysisApprovalID:input_type -> Cast.UpdateWorkAnalysisApprovalIDReq
123, // 189: Cast.Cast.MediaDataList:input_type -> Cast.MediaDataListReq 120, // 189: Cast.Cast.ArtistDataList:input_type -> Cast.ArtistDataListReq
126, // 190: Cast.Cast.DataOverview:input_type -> Cast.DataOverviewReq 123, // 190: Cast.Cast.MediaDataList:input_type -> Cast.MediaDataListReq
128, // 191: Cast.Cast.ArtistMetricsSeries:input_type -> Cast.ArtistMetricsSeriesReq 126, // 191: Cast.Cast.DataOverview:input_type -> Cast.DataOverviewReq
130, // 192: Cast.Cast.ArtistMetricsDailyWindow:input_type -> Cast.ArtistMetricsDailyWindowReq 128, // 192: Cast.Cast.ArtistMetricsSeries:input_type -> Cast.ArtistMetricsSeriesReq
135, // 193: Cast.Cast.TobeConfirmedList:input_type -> Cast.TobeConfirmedListReq 130, // 193: Cast.Cast.ArtistMetricsDailyWindow:input_type -> Cast.ArtistMetricsDailyWindowReq
140, // 194: Cast.Cast.UpsertMediaMetricsDailyBatch:input_type -> Cast.UpsertMediaMetricsDailyBatchReq 135, // 194: Cast.Cast.TobeConfirmedList:input_type -> Cast.TobeConfirmedListReq
143, // 195: Cast.Cast.UpsertWorkMetricsDailyBatch:input_type -> Cast.UpsertWorkMetricsDailyBatchReq 140, // 195: Cast.Cast.UpsertMediaMetricsDailyBatch:input_type -> Cast.UpsertMediaMetricsDailyBatchReq
153, // 196: Cast.Cast.ListMediaMetricsDaily:input_type -> Cast.ListMediaMetricsDailyReq 143, // 196: Cast.Cast.UpsertWorkMetricsDailyBatch:input_type -> Cast.UpsertWorkMetricsDailyBatchReq
156, // 197: Cast.Cast.ListWorkMetricsDaily:input_type -> Cast.ListWorkMetricsDailyReq 153, // 197: Cast.Cast.ListMediaMetricsDaily:input_type -> Cast.ListMediaMetricsDailyReq
167, // 198: Cast.Cast.CalculateMediaMetricsByWorks:input_type -> Cast.CalculateMediaMetricsByWorksReq 156, // 198: Cast.Cast.ListWorkMetricsDaily:input_type -> Cast.ListWorkMetricsDailyReq
145, // 199: Cast.Cast.GetArtistAyrShareInfo:input_type -> Cast.GetArtistAyrShareInfoReq 167, // 199: Cast.Cast.CalculateMediaMetricsByWorks:input_type -> Cast.CalculateMediaMetricsByWorksReq
148, // 200: Cast.Cast.GetArtistAyrShareInfoByPlatformIDs:input_type -> Cast.GetArtistAyrShareInfoByPlatformIDsReq 145, // 200: Cast.Cast.GetArtistAyrShareInfo:input_type -> Cast.GetArtistAyrShareInfoReq
150, // 201: Cast.Cast.ListWorkPlatformInfo:input_type -> Cast.ListWorkPlatformInfoReq 148, // 201: Cast.Cast.GetArtistAyrShareInfoByPlatformIDs:input_type -> Cast.GetArtistAyrShareInfoByPlatformIDsReq
159, // 202: Cast.Cast.UpsertTaskList:input_type -> Cast.UpsertTaskListReq 150, // 202: Cast.Cast.ListWorkPlatformInfo:input_type -> Cast.ListWorkPlatformInfoReq
161, // 203: Cast.Cast.GetTaskList:input_type -> Cast.GetTaskListReq 159, // 203: Cast.Cast.UpsertTaskList:input_type -> Cast.UpsertTaskListReq
164, // 204: Cast.Cast.ListTaskList:input_type -> Cast.ListTaskListReq 161, // 204: Cast.Cast.GetTaskList:input_type -> Cast.GetTaskListReq
166, // 205: Cast.Cast.DeleteTaskList:input_type -> Cast.DeleteTaskListReq 164, // 205: Cast.Cast.ListTaskList:input_type -> Cast.ListTaskListReq
169, // 206: Cast.Cast.UpdateCastTag:input_type -> Cast.UpdateCastTagReq 166, // 206: Cast.Cast.DeleteTaskList:input_type -> Cast.DeleteTaskListReq
171, // 207: Cast.Cast.ListCastTags:input_type -> Cast.ListCastTagsReq 169, // 207: Cast.Cast.UpdateCastTag:input_type -> Cast.UpdateCastTagReq
174, // 208: Cast.Cast.UpdateCastTagBatch:input_type -> Cast.UpdateCastTagBatchReq 171, // 208: Cast.Cast.ListCastTags:input_type -> Cast.ListCastTagsReq
176, // 209: Cast.Cast.BatchUpdateCastTags:input_type -> Cast.BatchUpdateCastTagsReq 174, // 209: Cast.Cast.UpdateCastTagBatch:input_type -> Cast.UpdateCastTagBatchReq
177, // 210: Cast.Cast.UpdateCastTagStatus:input_type -> Cast.UpdateCastTagStatusReq 176, // 210: Cast.Cast.BatchUpdateCastTags:input_type -> Cast.BatchUpdateCastTagsReq
218, // 211: Cast.Cast.RecalculateCastTagQuoteCount:input_type -> google.protobuf.Empty 177, // 211: Cast.Cast.UpdateCastTagStatus:input_type -> Cast.UpdateCastTagStatusReq
179, // 212: Cast.Cast.CreateCompetitiveReport:input_type -> Cast.CreateCompetitiveReportReq 218, // 212: Cast.Cast.RecalculateCastTagQuoteCount:input_type -> google.protobuf.Empty
194, // 213: Cast.Cast.ImportCompetitiveReportBatch:input_type -> Cast.ImportCompetitiveReportBatchReq 179, // 213: Cast.Cast.CreateCompetitiveReport:input_type -> Cast.CreateCompetitiveReportReq
182, // 214: Cast.Cast.UpdateCompetitiveReportStatus:input_type -> Cast.UpdateCompetitiveReportStatusReq 194, // 214: Cast.Cast.ImportCompetitiveReportBatch:input_type -> Cast.ImportCompetitiveReportBatchReq
186, // 215: Cast.Cast.GetCompetitiveReport:input_type -> Cast.GetCompetitiveReportDetailReq 182, // 215: Cast.Cast.UpdateCompetitiveReportStatus:input_type -> Cast.UpdateCompetitiveReportStatusReq
187, // 216: Cast.Cast.GetCompetitiveReportForApp:input_type -> Cast.GetCompetitiveReportForAppReq 186, // 216: Cast.Cast.GetCompetitiveReport:input_type -> Cast.GetCompetitiveReportDetailReq
190, // 217: Cast.Cast.ListCompetitiveReport:input_type -> Cast.ListCompetitiveReportReq 187, // 217: Cast.Cast.GetCompetitiveReportForApp:input_type -> Cast.GetCompetitiveReportForAppReq
193, // 218: Cast.Cast.DeleteCompetitiveReport:input_type -> Cast.DeleteCompetitiveReportReq 190, // 218: Cast.Cast.ListCompetitiveReport:input_type -> Cast.ListCompetitiveReportReq
183, // 219: Cast.Cast.UpdateCompetitiveReportApprovalID:input_type -> Cast.UpdateCompetitiveReportApprovalIDReq 193, // 219: Cast.Cast.DeleteCompetitiveReport:input_type -> Cast.DeleteCompetitiveReportReq
196, // 220: Cast.Cast.CountCompetitiveReportByWorkUuids:input_type -> Cast.CountCompetitiveReportByWorkUuidsReq 183, // 220: Cast.Cast.UpdateCompetitiveReportApprovalID:input_type -> Cast.UpdateCompetitiveReportApprovalIDReq
12, // 221: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp 196, // 221: Cast.Cast.CountCompetitiveReportByWorkUuids:input_type -> Cast.CountCompetitiveReportByWorkUuidsReq
14, // 222: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp 12, // 222: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp
16, // 223: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp 14, // 223: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp
218, // 224: Cast.Cast.BindManager:output_type -> google.protobuf.Empty 16, // 224: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp
19, // 225: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp 218, // 225: Cast.Cast.BindManager:output_type -> google.protobuf.Empty
22, // 226: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp 19, // 226: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp
24, // 227: Cast.Cast.MediaInfo:output_type -> Cast.MediaInfoResp 22, // 227: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp
26, // 228: Cast.Cast.MediaInfoByPlatform:output_type -> Cast.MediaInfoByPlatformResp 24, // 228: Cast.Cast.MediaInfo:output_type -> Cast.MediaInfoResp
28, // 229: Cast.Cast.WorkList:output_type -> Cast.WorkListResp 26, // 229: Cast.Cast.MediaInfoByPlatform:output_type -> Cast.MediaInfoByPlatformResp
45, // 230: Cast.Cast.WorkListPublished:output_type -> Cast.WorkListPublishedResp 28, // 230: Cast.Cast.WorkList:output_type -> Cast.WorkListResp
31, // 231: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp 45, // 231: Cast.Cast.WorkListPublished:output_type -> Cast.WorkListPublishedResp
218, // 232: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty 31, // 232: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp
34, // 233: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp 218, // 233: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty
36, // 234: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp 34, // 234: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp
38, // 235: Cast.Cast.Publish:output_type -> Cast.PublishResp 36, // 235: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp
40, // 236: Cast.Cast.RePublish:output_type -> Cast.RePublishResp 38, // 236: Cast.Cast.Publish:output_type -> Cast.PublishResp
218, // 237: Cast.Cast.DelWork:output_type -> google.protobuf.Empty 40, // 237: Cast.Cast.RePublish:output_type -> Cast.RePublishResp
43, // 238: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp 218, // 238: Cast.Cast.DelWork:output_type -> google.protobuf.Empty
47, // 239: Cast.Cast.ArtistInfo:output_type -> Cast.ArtistInfoResp 43, // 239: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp
49, // 240: Cast.Cast.ImportWorkBatch:output_type -> Cast.ImportWorkBatchResp 47, // 240: Cast.Cast.ArtistInfo:output_type -> Cast.ArtistInfoResp
52, // 241: Cast.Cast.UpdateWorkPlatformInfo:output_type -> Cast.UpdateWorkPlatformInfoResp 49, // 241: Cast.Cast.ImportWorkBatch:output_type -> Cast.ImportWorkBatchResp
218, // 242: Cast.Cast.UpdateWorkPublishLog:output_type -> google.protobuf.Empty 52, // 242: Cast.Cast.UpdateWorkPlatformInfo:output_type -> Cast.UpdateWorkPlatformInfoResp
55, // 243: Cast.Cast.RefreshWorkList:output_type -> Cast.RefreshWorkListResp 218, // 243: Cast.Cast.UpdateWorkPublishLog:output_type -> google.protobuf.Empty
200, // 244: Cast.Cast.WorkResource:output_type -> Cast.WorkResourceResp 55, // 244: Cast.Cast.RefreshWorkList:output_type -> Cast.RefreshWorkListResp
202, // 245: Cast.Cast.UpdateWorkResource:output_type -> Cast.UpdateWorkResourceResp 200, // 245: Cast.Cast.WorkResource:output_type -> Cast.WorkResourceResp
204, // 246: Cast.Cast.UpdateMediaAccStatus:output_type -> Cast.UpdateMediaAccStatusResp 202, // 246: Cast.Cast.UpdateWorkResource:output_type -> Cast.UpdateWorkResourceResp
57, // 247: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp 204, // 247: Cast.Cast.UpdateMediaAccStatus:output_type -> Cast.UpdateMediaAccStatusResp
206, // 248: Cast.Cast.UnbindMediaAuth:output_type -> Cast.UnbindMediaAuthResp 57, // 248: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp
218, // 249: Cast.Cast.UpdateMediaAccInfo:output_type -> google.protobuf.Empty 206, // 249: Cast.Cast.UnbindMediaAuth:output_type -> Cast.UnbindMediaAuthResp
59, // 250: Cast.Cast.OAuthAccountV2:output_type -> Cast.OAuthAccountV2Resp 218, // 250: Cast.Cast.UpdateMediaAccInfo:output_type -> google.protobuf.Empty
63, // 251: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp 59, // 251: Cast.Cast.OAuthAccountV2:output_type -> Cast.OAuthAccountV2Resp
218, // 252: Cast.Cast.UpdateOAuth:output_type -> google.protobuf.Empty 63, // 252: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp
66, // 253: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp 218, // 253: Cast.Cast.UpdateOAuth:output_type -> google.protobuf.Empty
68, // 254: Cast.Cast.PublishMediaInfo:output_type -> Cast.PublishMediaInfoResp 66, // 254: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp
218, // 255: Cast.Cast.Tools:output_type -> google.protobuf.Empty 68, // 255: Cast.Cast.PublishMediaInfo:output_type -> Cast.PublishMediaInfoResp
71, // 256: Cast.Cast.UpdateVideoScript:output_type -> Cast.UpdateVideoScriptResp 218, // 256: Cast.Cast.Tools:output_type -> google.protobuf.Empty
73, // 257: Cast.Cast.GetVideoScript:output_type -> Cast.GetVideoScriptResp 71, // 257: Cast.Cast.UpdateVideoScript:output_type -> Cast.UpdateVideoScriptResp
76, // 258: Cast.Cast.ListVideoScripts:output_type -> Cast.ListVideoScriptsResp 73, // 258: Cast.Cast.GetVideoScript:output_type -> Cast.GetVideoScriptResp
218, // 259: Cast.Cast.DeleteVideoScript:output_type -> google.protobuf.Empty 76, // 259: Cast.Cast.ListVideoScripts:output_type -> Cast.ListVideoScriptsResp
79, // 260: Cast.Cast.UpdateVideoScriptBatch:output_type -> Cast.UpdateVideoScriptBatchResp 218, // 260: Cast.Cast.DeleteVideoScript:output_type -> google.protobuf.Empty
218, // 261: Cast.Cast.UpdateScriptStatus:output_type -> google.protobuf.Empty 79, // 261: Cast.Cast.UpdateVideoScriptBatch:output_type -> Cast.UpdateVideoScriptBatchResp
83, // 262: Cast.Cast.GetLayout:output_type -> Cast.GetLayoutResp 218, // 262: Cast.Cast.UpdateScriptStatus:output_type -> google.protobuf.Empty
218, // 263: Cast.Cast.SetLayout:output_type -> google.protobuf.Empty 83, // 263: Cast.Cast.GetLayout:output_type -> Cast.GetLayoutResp
218, // 264: Cast.Cast.UpdatePrompt:output_type -> google.protobuf.Empty 218, // 264: Cast.Cast.SetLayout:output_type -> google.protobuf.Empty
218, // 265: Cast.Cast.DeletePrompt:output_type -> google.protobuf.Empty 218, // 265: Cast.Cast.UpdatePrompt:output_type -> google.protobuf.Empty
87, // 266: Cast.Cast.GetPrompt:output_type -> Cast.GetPromptResp 218, // 266: Cast.Cast.DeletePrompt:output_type -> google.protobuf.Empty
90, // 267: Cast.Cast.ListPrompts:output_type -> Cast.ListPromptsResp 87, // 267: Cast.Cast.GetPrompt:output_type -> Cast.GetPromptResp
92, // 268: Cast.Cast.UpdatePromptBatch:output_type -> Cast.UpdatePromptBatchResp 90, // 268: Cast.Cast.ListPrompts:output_type -> Cast.ListPromptsResp
95, // 269: Cast.Cast.UpdateArtist:output_type -> Cast.UpdateArtistResp 92, // 269: Cast.Cast.UpdatePromptBatch:output_type -> Cast.UpdatePromptBatchResp
97, // 270: Cast.Cast.GetArtist:output_type -> Cast.GetArtistResp 95, // 270: Cast.Cast.UpdateArtist:output_type -> Cast.UpdateArtistResp
99, // 271: Cast.Cast.CreateWorkAnalysis:output_type -> Cast.CreateWorkAnalysisResp 97, // 271: Cast.Cast.GetArtist:output_type -> Cast.GetArtistResp
218, // 272: Cast.Cast.UpdateWorkAnalysis:output_type -> google.protobuf.Empty 99, // 272: Cast.Cast.CreateWorkAnalysis:output_type -> Cast.CreateWorkAnalysisResp
218, // 273: Cast.Cast.UpdateWorkAnalysisStatus:output_type -> google.protobuf.Empty 218, // 273: Cast.Cast.UpdateWorkAnalysis:output_type -> google.protobuf.Empty
115, // 274: Cast.Cast.GetWorkAnalysis:output_type -> Cast.GetWorkAnalysisDetailResp 218, // 274: Cast.Cast.UpdateWorkAnalysisStatus:output_type -> google.protobuf.Empty
114, // 275: Cast.Cast.GetLatestWorkAnalysis:output_type -> Cast.GetWorkAnalysisResp 115, // 275: Cast.Cast.GetWorkAnalysis:output_type -> Cast.GetWorkAnalysisDetailResp
118, // 276: Cast.Cast.ListWorkAnalysis:output_type -> Cast.ListWorkAnalysisResp 114, // 276: Cast.Cast.GetLatestWorkAnalysis:output_type -> Cast.GetWorkAnalysisResp
218, // 277: Cast.Cast.DeleteWorkAnalysis:output_type -> google.protobuf.Empty 118, // 277: Cast.Cast.ListWorkAnalysis:output_type -> Cast.ListWorkAnalysisResp
218, // 278: Cast.Cast.UpdateWorkAnalysisApprovalID:output_type -> google.protobuf.Empty 218, // 278: Cast.Cast.DeleteWorkAnalysis:output_type -> google.protobuf.Empty
122, // 279: Cast.Cast.ArtistDataList:output_type -> Cast.ArtistDataListResp 218, // 279: Cast.Cast.UpdateWorkAnalysisApprovalID:output_type -> google.protobuf.Empty
125, // 280: Cast.Cast.MediaDataList:output_type -> Cast.MediaDataListResp 122, // 280: Cast.Cast.ArtistDataList:output_type -> Cast.ArtistDataListResp
127, // 281: Cast.Cast.DataOverview:output_type -> Cast.DataOverviewResp 125, // 281: Cast.Cast.MediaDataList:output_type -> Cast.MediaDataListResp
129, // 282: Cast.Cast.ArtistMetricsSeries:output_type -> Cast.ArtistMetricsSeriesResp 127, // 282: Cast.Cast.DataOverview:output_type -> Cast.DataOverviewResp
134, // 283: Cast.Cast.ArtistMetricsDailyWindow:output_type -> Cast.ArtistMetricsDailyWindowResp 129, // 283: Cast.Cast.ArtistMetricsSeries:output_type -> Cast.ArtistMetricsSeriesResp
137, // 284: Cast.Cast.TobeConfirmedList:output_type -> Cast.TobeConfirmedListResp 134, // 284: Cast.Cast.ArtistMetricsDailyWindow:output_type -> Cast.ArtistMetricsDailyWindowResp
141, // 285: Cast.Cast.UpsertMediaMetricsDailyBatch:output_type -> Cast.UpsertMediaMetricsDailyBatchResp 137, // 285: Cast.Cast.TobeConfirmedList:output_type -> Cast.TobeConfirmedListResp
144, // 286: Cast.Cast.UpsertWorkMetricsDailyBatch:output_type -> Cast.UpsertWorkMetricsDailyBatchResp 141, // 286: Cast.Cast.UpsertMediaMetricsDailyBatch:output_type -> Cast.UpsertMediaMetricsDailyBatchResp
155, // 287: Cast.Cast.ListMediaMetricsDaily:output_type -> Cast.ListMediaMetricsDailyResp 144, // 287: Cast.Cast.UpsertWorkMetricsDailyBatch:output_type -> Cast.UpsertWorkMetricsDailyBatchResp
158, // 288: Cast.Cast.ListWorkMetricsDaily:output_type -> Cast.ListWorkMetricsDailyResp 155, // 288: Cast.Cast.ListMediaMetricsDaily:output_type -> Cast.ListMediaMetricsDailyResp
168, // 289: Cast.Cast.CalculateMediaMetricsByWorks:output_type -> Cast.CalculateMediaMetricsByWorksResp 158, // 289: Cast.Cast.ListWorkMetricsDaily:output_type -> Cast.ListWorkMetricsDailyResp
147, // 290: Cast.Cast.GetArtistAyrShareInfo:output_type -> Cast.GetArtistAyrShareInfoResp 168, // 290: Cast.Cast.CalculateMediaMetricsByWorks:output_type -> Cast.CalculateMediaMetricsByWorksResp
149, // 291: Cast.Cast.GetArtistAyrShareInfoByPlatformIDs:output_type -> Cast.GetArtistAyrShareInfoByPlatformIDsResp 147, // 291: Cast.Cast.GetArtistAyrShareInfo:output_type -> Cast.GetArtistAyrShareInfoResp
152, // 292: Cast.Cast.ListWorkPlatformInfo:output_type -> Cast.ListWorkPlatformInfoResp 149, // 292: Cast.Cast.GetArtistAyrShareInfoByPlatformIDs:output_type -> Cast.GetArtistAyrShareInfoByPlatformIDsResp
160, // 293: Cast.Cast.UpsertTaskList:output_type -> Cast.UpsertTaskListResp 152, // 293: Cast.Cast.ListWorkPlatformInfo:output_type -> Cast.ListWorkPlatformInfoResp
163, // 294: Cast.Cast.GetTaskList:output_type -> Cast.GetTaskListResp 160, // 294: Cast.Cast.UpsertTaskList:output_type -> Cast.UpsertTaskListResp
165, // 295: Cast.Cast.ListTaskList:output_type -> Cast.ListTaskListResp 163, // 295: Cast.Cast.GetTaskList:output_type -> Cast.GetTaskListResp
218, // 296: Cast.Cast.DeleteTaskList:output_type -> google.protobuf.Empty 165, // 296: Cast.Cast.ListTaskList:output_type -> Cast.ListTaskListResp
170, // 297: Cast.Cast.UpdateCastTag:output_type -> Cast.UpdateCastTagResp 218, // 297: Cast.Cast.DeleteTaskList:output_type -> google.protobuf.Empty
173, // 298: Cast.Cast.ListCastTags:output_type -> Cast.ListCastTagsResp 170, // 298: Cast.Cast.UpdateCastTag:output_type -> Cast.UpdateCastTagResp
175, // 299: Cast.Cast.UpdateCastTagBatch:output_type -> Cast.UpdateCastTagBatchResp 173, // 299: Cast.Cast.ListCastTags:output_type -> Cast.ListCastTagsResp
218, // 300: Cast.Cast.BatchUpdateCastTags:output_type -> google.protobuf.Empty 175, // 300: Cast.Cast.UpdateCastTagBatch:output_type -> Cast.UpdateCastTagBatchResp
218, // 301: Cast.Cast.UpdateCastTagStatus:output_type -> google.protobuf.Empty 218, // 301: Cast.Cast.BatchUpdateCastTags:output_type -> google.protobuf.Empty
178, // 302: Cast.Cast.RecalculateCastTagQuoteCount:output_type -> Cast.RecalculateCastTagQuoteCountResp 218, // 302: Cast.Cast.UpdateCastTagStatus:output_type -> google.protobuf.Empty
180, // 303: Cast.Cast.CreateCompetitiveReport:output_type -> Cast.CreateCompetitiveReportResp 178, // 303: Cast.Cast.RecalculateCastTagQuoteCount:output_type -> Cast.RecalculateCastTagQuoteCountResp
195, // 304: Cast.Cast.ImportCompetitiveReportBatch:output_type -> Cast.ImportCompetitiveReportBatchResp 180, // 304: Cast.Cast.CreateCompetitiveReport:output_type -> Cast.CreateCompetitiveReportResp
218, // 305: Cast.Cast.UpdateCompetitiveReportStatus:output_type -> google.protobuf.Empty 195, // 305: Cast.Cast.ImportCompetitiveReportBatch:output_type -> Cast.ImportCompetitiveReportBatchResp
189, // 306: Cast.Cast.GetCompetitiveReport:output_type -> Cast.GetCompetitiveReportDetailResp 218, // 306: Cast.Cast.UpdateCompetitiveReportStatus:output_type -> google.protobuf.Empty
188, // 307: Cast.Cast.GetCompetitiveReportForApp:output_type -> Cast.GetCompetitiveReportForAppResp 189, // 307: Cast.Cast.GetCompetitiveReport:output_type -> Cast.GetCompetitiveReportDetailResp
192, // 308: Cast.Cast.ListCompetitiveReport:output_type -> Cast.ListCompetitiveReportResp 188, // 308: Cast.Cast.GetCompetitiveReportForApp:output_type -> Cast.GetCompetitiveReportForAppResp
218, // 309: Cast.Cast.DeleteCompetitiveReport:output_type -> google.protobuf.Empty 192, // 309: Cast.Cast.ListCompetitiveReport:output_type -> Cast.ListCompetitiveReportResp
218, // 310: Cast.Cast.UpdateCompetitiveReportApprovalID:output_type -> google.protobuf.Empty 218, // 310: Cast.Cast.DeleteCompetitiveReport:output_type -> google.protobuf.Empty
198, // 311: Cast.Cast.CountCompetitiveReportByWorkUuids:output_type -> Cast.CountCompetitiveReportByWorkUuidsResp 218, // 311: Cast.Cast.UpdateCompetitiveReportApprovalID:output_type -> google.protobuf.Empty
221, // [221:312] is the sub-list for method output_type 198, // 312: Cast.Cast.CountCompetitiveReportByWorkUuids:output_type -> Cast.CountCompetitiveReportByWorkUuidsResp
130, // [130:221] is the sub-list for method input_type 222, // [222:313] is the sub-list for method output_type
130, // [130:130] is the sub-list for extension type_name 131, // [131:222] is the sub-list for method input_type
130, // [130:130] is the sub-list for extension extendee 131, // [131:131] is the sub-list for extension type_name
0, // [0:130] is the sub-list for field type_name 131, // [131:131] is the sub-list for extension extendee
0, // [0:131] is the sub-list for field type_name
} }
func init() { file_pb_fiee_cast_proto_init() } func init() { file_pb_fiee_cast_proto_init() }

View File

@ -25129,6 +25129,8 @@ func (m *UpdateMediaAccInfoReq) validate(all bool) error {
// no validation rules for Remark // no validation rules for Remark
// no validation rules for AuthStatus
if len(errors) > 0 { if len(errors) > 0 {
return UpdateMediaAccInfoReqMultiError(errors) return UpdateMediaAccInfoReqMultiError(errors)
} }

View File

@ -30,7 +30,7 @@ func InitTasks() error {
err := cm.AddTask("refreshWorkApprovalStatus", "0 */5 * * * *", RefreshWorkApprovalStatusTask) err := cm.AddTask("refreshWorkApprovalStatus", "0 */5 * * * *", RefreshWorkApprovalStatusTask)
err = cm.AddTask("artistAutoConfirm", "0 */1 * * * *", ArtistAutoConfirmTask) err = cm.AddTask("artistAutoConfirm", "0 */1 * * * *", ArtistAutoConfirmTask)
err = cm.AddTask("refreshPublishStatus", "0 */5 * * * *", PublishTask) err = cm.AddTask("refreshPublishStatus", "0 */5 * * * *", PublishTask)
err = cm.AddTask("scheduledPublish", "0 */30 * * * *", ScheduledPublishTask) err = cm.AddTask("scheduledPublish", "0 */1 * * * *", ScheduledPublishTask)
err = cm.AddTask("artistAutoConfirmAnalysis", "0 */1 * * * *", ArtistAutoConfirmAnalysisTask) err = cm.AddTask("artistAutoConfirmAnalysis", "0 */1 * * * *", ArtistAutoConfirmAnalysisTask)
err = cm.AddTask("refreshWorkAnalysisApprovalStatus", "0 */1 * * * *", RefreshWorkAnalysisApprovalStatusTask) err = cm.AddTask("refreshWorkAnalysisApprovalStatus", "0 */1 * * * *", RefreshWorkAnalysisApprovalStatusTask)

View File

@ -31,5 +31,5 @@ var NamePlatformIDKv = map[string]uint32{
} }
type UnbindAccountReq struct { type UnbindAccountReq struct {
MediaAccountUuids []string `json:"media_account_uuids"` MediaAccountUuids []string `json:"mediaAccountUuids"`
} }

View File

@ -14,6 +14,7 @@ import (
modelCast "fonchain-fiee/pkg/model/cast" modelCast "fonchain-fiee/pkg/model/cast"
"fonchain-fiee/pkg/model/login" "fonchain-fiee/pkg/model/login"
"fonchain-fiee/pkg/service" "fonchain-fiee/pkg/service"
"fonchain-fiee/pkg/service/upload"
"fonchain-fiee/pkg/utils" "fonchain-fiee/pkg/utils"
"net/http" "net/http"
"net/url" "net/url"
@ -780,12 +781,38 @@ func updateMediaAccount(platformName string, platformId cast.PlatformIDENUM, sub
func UnbindAuth(ctx *gin.Context) { func UnbindAuth(ctx *gin.Context) {
var req modelCast.UnbindAccountReq var req modelCast.UnbindAccountReq
var UpsertTaskListResp *cast.UpsertTaskListResp
var err error var err error
if err = ctx.ShouldBind(&req); err != nil { if err = ctx.ShouldBind(&req); err != nil {
service.Error(ctx, err) service.Error(ctx, err)
return return
} }
if len(req.MediaAccountUuids) == 0 {
service.Error(ctx, errors.New("参数错误"))
return
}
loginInfo := login.GetUserInfoFromC(ctx)
extraBytes, _ := json.Marshal(req.MediaAccountUuids)
UpsertTaskListResp, err = service.CastProvider.UpsertTaskList(context.Background(), &cast.UpsertTaskListReq{
Action: "unbindAuth",
Url: "",
Status: 1,
OperatorID: fmt.Sprint(loginInfo.ID),
OperatorName: loginInfo.Name,
ExtraData: string(extraBytes),
})
if err != nil {
service.Error(ctx, err)
return
}
err = UnbindAyr(req.MediaAccountUuids) err = UnbindAyr(req.MediaAccountUuids)
go func() {
err = RefreshTaskUnBindAuth(UpsertTaskListResp.Uuid)
if err != nil {
zap.L().Error("RefreshTaskUnBindAuth err", zap.Error(err))
return
}
}()
if err != nil { if err != nil {
service.Error(ctx, err) service.Error(ctx, err)
return return
@ -807,6 +834,17 @@ func UnbindAyr(MediaAccountUuids []string) error {
if mediaResp == nil || len(mediaResp.Data) == 0 { if mediaResp == nil || len(mediaResp.Data) == 0 {
return errors.New("未找到该账号") return errors.New("未找到该账号")
} }
// DM直接更新数据库
if cast.PlatformIDENUM(mediaResp.Data[0].PlatformID) == cast.PlatformIDENUM_DM {
_, err = service.CastProvider.UpdateMediaAccInfo(context.Background(), &cast.UpdateMediaAccInfoReq{
MediaAccountUuid: mediaResp.Data[0].MediaAccountUuid,
AuthStatus: cast.AuthStatusENUM_AuthNo,
})
if err != nil {
return err
}
continue
}
asArtistResp, _err := service.CastProvider.GetArtist(context.Background(), &cast.GetArtistReq{ asArtistResp, _err := service.CastProvider.GetArtist(context.Background(), &cast.GetArtistReq{
ArtistUuid: fmt.Sprint(mediaResp.Data[0].ArtistUuid), ArtistUuid: fmt.Sprint(mediaResp.Data[0].ArtistUuid),
}) })
@ -825,3 +863,116 @@ func UnbindAyr(MediaAccountUuids []string) error {
} }
return nil return nil
} }
// RefreshTaskUnBindAuth 刷新解绑授权任务状态
func RefreshTaskUnBindAuth(taskUuid string) error {
listResp, err := service.CastProvider.GetTaskList(context.Background(), &cast.GetTaskListReq{Uuid: taskUuid})
if err != nil {
zap.L().Error("GetTaskList err", zap.Error(err))
return err
}
if listResp == nil || listResp.Data.Status != 1 {
return nil
}
var mediaAccountUuids []string
err = json.Unmarshal([]byte(listResp.Data.ExtraData), &mediaAccountUuids)
if err != nil {
zap.L().Error("Unmarshal err", zap.Error(err))
return err
}
// 创建Excel文件
excelFile := excelize.NewFile()
sheetName := "Sheet1"
// 设置表头
headers := []string{"艺人名字", "账号名字", "平台名字", "授权状态", "备注"}
for i, header := range headers {
cell := fmt.Sprintf("%c1", 'A'+i)
excelFile.SetCellValue(sheetName, cell, header)
}
// 收集账号信息并写入Excel
rowIndex := 2
for _, mediaAccountUuid := range mediaAccountUuids {
mediaResp, err := service.CastProvider.MediaUserList(context.Background(), &cast.MediaUserListReq{
MediaUserID: mediaAccountUuid,
Page: 1,
PageSize: 1,
})
if err != nil {
zap.L().Error("MediaUserList err", zap.Error(err))
continue
}
if mediaResp == nil || len(mediaResp.Data) == 0 {
continue
}
mediaData := mediaResp.Data[0]
// 获取平台名字
platformName := modelCast.PlatformNameKv[mediaData.PlatformID]
if platformName == "" {
platformName = "未知平台"
}
// 获取授权状态
authStatusText := ""
switch mediaData.AuthStatus {
case cast.AuthStatusENUM_AuthOk:
authStatusText = "已授权"
case cast.AuthStatusENUM_AuthNo:
authStatusText = "未授权"
default:
authStatusText = "未知"
}
// 写入Excel
excelFile.SetCellValue(sheetName, fmt.Sprintf("A%d", rowIndex), mediaData.ArtistName) // 艺人名字
excelFile.SetCellValue(sheetName, fmt.Sprintf("B%d", rowIndex), mediaData.PlatformUserName) // 账号名字
excelFile.SetCellValue(sheetName, fmt.Sprintf("C%d", rowIndex), platformName) // 平台名字
excelFile.SetCellValue(sheetName, fmt.Sprintf("D%d", rowIndex), authStatusText) // 授权状态
excelFile.SetCellValue(sheetName, fmt.Sprintf("E%d", rowIndex), "") // 备注
rowIndex++
}
// 创建临时目录
tempDir := "./runtime/unbind_auth"
_, err = utils.CheckDirPath(tempDir, true)
if err != nil {
zap.L().Error("CheckDirPath err", zap.Error(err))
return err
}
// 保存Excel到本地
fileName := fmt.Sprintf("unbind_auth_%d.xlsx", time.Now().UnixMicro())
localPath := filepath.Join(tempDir, fileName)
if err = excelFile.SaveAs(localPath); err != nil {
zap.L().Error("SaveAs err", zap.Error(err))
return err
}
// Linux系统下需要显式设置文件权限
if err = os.Chmod(localPath, 0666); err != nil {
zap.L().Warn("设置文件权限失败", zap.Error(err))
}
// 上传到OSS
exportUrl, err := upload.PutBos(localPath, "excel", true)
if err != nil {
zap.L().Error("uploadExcelToOSS err", zap.Error(err))
return err
}
// 更新任务状态为完成
_, err = service.CastProvider.UpsertTaskList(context.Background(), &cast.UpsertTaskListReq{
Uuid: taskUuid,
Status: 3, // 3-处理完成
Url: exportUrl,
})
if err != nil {
zap.L().Error("UpsertTaskList err", zap.Error(err))
return err
}
return nil
}

View File

@ -505,7 +505,7 @@ func CheckUserBundleBalance(userID int32, balanceType modelCast.BalanceTypeEnum)
err = errors.New("套餐已过期") err = errors.New("套餐已过期")
return return
} }
fmt.Println("CheckUserBundleBalance resp", resp) //FIXME 判断用户是新购还是续费,新购就提示验收失败,套餐已过期,续费就继续扣减
switch balanceType { switch balanceType {
case modelCast.BalanceTypeAccountValue: case modelCast.BalanceTypeAccountValue:
if resp.AccountConsumptionNumber >= resp.AccountNumber { if resp.AccountConsumptionNumber >= resp.AccountNumber {
@ -690,7 +690,6 @@ func PostAS(ctx context.Context, workUuid string, publishSource cast.PublishSour
var mediaUrls []string var mediaUrls []string
var isVideo bool var isVideo bool
var urlResp *UploadMediaResponse var urlResp *UploadMediaResponse
fmt.Println(urlResp)
if workDetail.WorkCategory == 1 { if workDetail.WorkCategory == 1 {
isVideo = false isVideo = false
// 先用服务器上的文件,不上传到第三方 // 先用服务器上的文件,不上传到第三方
@ -2026,7 +2025,6 @@ func checkAndReuploadImage(imageUrl string, mediaType string) (string, error) {
if err != nil { if err != nil {
return "", errors.New("图片解码失败") return "", errors.New("图片解码失败")
} }
fmt.Println("原始图片格式:", format)
newFilePath := "./runtime/work/" + uuid.New().String() + ".jpg" newFilePath := "./runtime/work/" + uuid.New().String() + ".jpg"
// 如果不是 jpg则转换 // 如果不是 jpg则转换
if format != "jpeg" { if format != "jpeg" {
@ -2040,7 +2038,6 @@ func checkAndReuploadImage(imageUrl string, mediaType string) (string, error) {
if err != nil { if err != nil {
return "", errors.New("打开文件失败") return "", errors.New("打开文件失败")
} }
fmt.Println("已转换为 JPG: output.jpg")
} else { } else {
fmt.Println("本身就是 JPG无需转换") fmt.Println("本身就是 JPG无需转换")
} }