1

记录余量使用类型
删除omitempty
2025-10-21 15:49:17 +08:00 · 2025-10-21 14:59:36 +08:00 · 2025-10-20 17:11:13 +08:00 · 2025-10-20 17:01:29 +08:00 · 2025-10-20 17:01:08 +08:00 · 2025-10-20 14:34:09 +08:00
12 changed files with 7910 additions and 2095 deletions
--- a/api/bundle/bundle.pb.go
+++ b/api/bundle/bundle.pb.go
--- a/api/bundle/bundle.validator.pb.go
+++ b/api/bundle/bundle.validator.pb.go
@ -95,6 +95,13 @@ func (this *BundleProfile) Validate() error {
 			}
 		}
 	}
+	for _, item := range this.SelectValueAdditionalService {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("SelectValueAdditionalService", err)
+			}
+		}
+	}
 	for _, item := range this.BundleProfileLang {
 		if item != nil {
 			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
@ -105,6 +112,16 @@ func (this *BundleProfile) Validate() error {
 	return nil
 }
 func (this *BundleProfileLang) Validate() error {
+	for _, item := range this.ServiceLangInfo {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("ServiceLangInfo", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *ServiceLangInfo) Validate() error {
 	return nil
 }
 func (this *SaveResponse) Validate() error {
@ -113,6 +130,9 @@ func (this *SaveResponse) Validate() error {
 func (this *SelectValueAddService) Validate() error {
 	return nil
 }
+func (this *SelectValueAdditionalService) Validate() error {
+	return nil
+}
 func (this *DelBundleRequest) Validate() error {
 	return nil
 }
@ -350,6 +370,22 @@ func (this *GetBundleBalanceReq) Validate() error {
 func (this *BundleBalanceItem) Validate() error {
 	return nil
 }
+func (this *BundleBalanceExportItem) Validate() error {
+	return nil
+}
+func (this *BundleBalanceExportReq) Validate() error {
+	return nil
+}
+func (this *BundleBalanceExportResp) 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
+}
 func (this *GetBundleBalanceListResp) Validate() error {
 	for _, item := range this.Data {
 		if item != nil {
@ -466,3 +502,90 @@ func (this *UnfinishedInfo) Validate() error {
 func (this *SoftDeleteUnfinishedInfoRequest) Validate() error {
 	return nil
 }
+func (this *BundleActivateReq) Validate() error {
+	return nil
+}
+func (this *BundleActivateResp) Validate() error {
+	return nil
+}
+func (this *TaskQueryRequest) Validate() error {
+	return nil
+}
+func (this *TaskQueryResponse) Validate() error {
+	for _, item := range this.Tasks {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Tasks", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *TaskManagementInfo) Validate() error {
+	return nil
+}
+func (this *TaskAssignRequest) Validate() error {
+	return nil
+}
+func (this *UpdatePendingCountRequest) Validate() error {
+	return nil
+}
+func (this *RecentAssignRecordsRequest) Validate() error {
+	return nil
+}
+func (this *RecentAssignRecordsResponse) Validate() error {
+	return nil
+}
+func (this *EmployeeTaskQueryRequest) Validate() error {
+	return nil
+}
+func (this *EmployeeTaskQueryResponse) Validate() error {
+	for _, item := range this.Records {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Records", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *TaskAssignRecordInfo) Validate() error {
+	return nil
+}
+func (this *CompleteTaskManuallyRequest) Validate() error {
+	return nil
+}
+func (this *UpdateTaskProgressRequest) Validate() error {
+	return nil
+}
+func (this *TaskAssignRecordsQueryRequest) Validate() error {
+	return nil
+}
+func (this *TaskAssignRecordsQueryResponse) Validate() error {
+	for _, item := range this.Records {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Records", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *ArtistBundleBalanceRequest) Validate() error {
+	return nil
+}
+func (this *ArtistBundleBalanceResponse) Validate() error {
+	return nil
+}
+func (this *SetBundleBalanceLayoutReq) Validate() error {
+	return nil
+}
+func (this *SetBundleBalanceLayoutResp) Validate() error {
+	return nil
+}
+func (this *GetBundleBalanceLayoutReq) Validate() error {
+	return nil
+}
+func (this *GetBundleBalanceLayoutResp) Validate() error {
+	return nil
+}
--- a/api/bundle/bundle_triple.pb.go
+++ b/api/bundle/bundle_triple.pb.go
@ -69,6 +69,10 @@ type BundleClient interface {
 	GetBundleBalanceByUserId(ctx context.Context, in *GetBundleBalanceByUserIdReq, opts ...grpc_go.CallOption) (*GetBundleBalanceByUserIdResp, common.ErrorWithAttachment)
 	CreateBundleBalance(ctx context.Context, in *CreateBundleBalanceReq, opts ...grpc_go.CallOption) (*CreateBundleBalanceResp, common.ErrorWithAttachment)
 	AddBundleBalance(ctx context.Context, in *AddBundleBalanceReq, opts ...grpc_go.CallOption) (*AddBundleBalanceResp, common.ErrorWithAttachment)
+	BundleActivate(ctx context.Context, in *BundleActivateReq, opts ...grpc_go.CallOption) (*BundleActivateResp, common.ErrorWithAttachment)
+	BundleBalanceExport(ctx context.Context, in *BundleBalanceExportReq, opts ...grpc_go.CallOption) (*BundleBalanceExportResp, common.ErrorWithAttachment)
+	GetBundleBalanceLayout(ctx context.Context, in *GetBundleBalanceLayoutReq, opts ...grpc_go.CallOption) (*GetBundleBalanceLayoutResp, common.ErrorWithAttachment)
+	SetBundleBalanceLayout(ctx context.Context, in *SetBundleBalanceLayoutReq, opts ...grpc_go.CallOption) (*SetBundleBalanceLayoutResp, common.ErrorWithAttachment)
 	// 使用记录
 	GetUsedRecordList(ctx context.Context, in *GetUsedRecordListReq, opts ...grpc_go.CallOption) (*GetUsedRecordListResp, common.ErrorWithAttachment)
 	GetImageWorkDetail(ctx context.Context, in *GetImageWorkDetailReq, opts ...grpc_go.CallOption) (*GetImageWorkDetailResp, common.ErrorWithAttachment)
@ -83,6 +87,16 @@ type BundleClient interface {
 	// 查出没处理的数据
 	ListUnfinishedInfos(ctx context.Context, in *AutoCreateUserAndOrderRequest, opts ...grpc_go.CallOption) (*UnfinishedInfos, common.ErrorWithAttachment)
 	SoftDeleteUnfinishedInfo(ctx context.Context, in *SoftDeleteUnfinishedInfoRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+	// 任务台
+	GetPendingTaskList(ctx context.Context, in *TaskQueryRequest, opts ...grpc_go.CallOption) (*TaskQueryResponse, common.ErrorWithAttachment)
+	AssignTask(ctx context.Context, in *TaskAssignRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+	UpdatePendingCount(ctx context.Context, in *UpdatePendingCountRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+	GetRecentAssignRecords(ctx context.Context, in *RecentAssignRecordsRequest, opts ...grpc_go.CallOption) (*RecentAssignRecordsResponse, common.ErrorWithAttachment)
+	GetEmployeeAssignedTasks(ctx context.Context, in *EmployeeTaskQueryRequest, opts ...grpc_go.CallOption) (*EmployeeTaskQueryResponse, common.ErrorWithAttachment)
+	CompleteTaskManually(ctx context.Context, in *CompleteTaskManuallyRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+	UpdateTaskProgress(ctx context.Context, in *UpdateTaskProgressRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+	GetTaskAssignRecordsList(ctx context.Context, in *TaskAssignRecordsQueryRequest, opts ...grpc_go.CallOption) (*TaskAssignRecordsQueryResponse, common.ErrorWithAttachment)
+	GetArtistBundleBalance(ctx context.Context, in *ArtistBundleBalanceRequest, opts ...grpc_go.CallOption) (*ArtistBundleBalanceResponse, common.ErrorWithAttachment)
 }

 type bundleClient struct {
@ -128,6 +142,10 @@ type BundleClientImpl struct {
 	GetBundleBalanceByUserId                 func(ctx context.Context, in *GetBundleBalanceByUserIdReq) (*GetBundleBalanceByUserIdResp, error)
 	CreateBundleBalance                      func(ctx context.Context, in *CreateBundleBalanceReq) (*CreateBundleBalanceResp, error)
 	AddBundleBalance                         func(ctx context.Context, in *AddBundleBalanceReq) (*AddBundleBalanceResp, error)
+	BundleActivate                           func(ctx context.Context, in *BundleActivateReq) (*BundleActivateResp, error)
+	BundleBalanceExport                      func(ctx context.Context, in *BundleBalanceExportReq) (*BundleBalanceExportResp, error)
+	GetBundleBalanceLayout                   func(ctx context.Context, in *GetBundleBalanceLayoutReq) (*GetBundleBalanceLayoutResp, error)
+	SetBundleBalanceLayout                   func(ctx context.Context, in *SetBundleBalanceLayoutReq) (*SetBundleBalanceLayoutResp, error)
 	GetUsedRecordList                        func(ctx context.Context, in *GetUsedRecordListReq) (*GetUsedRecordListResp, error)
 	GetImageWorkDetail                       func(ctx context.Context, in *GetImageWorkDetailReq) (*GetImageWorkDetailResp, error)
 	GetVedioWorkDetail                       func(ctx context.Context, in *GetVedioWorkDetailReq) (*GetVedioeWorkDetailResp, error)
@ -139,6 +157,15 @@ type BundleClientImpl struct {
 	UpdateReconciliationStatusBySerialNumber func(ctx context.Context, in *UpdateStatusAndPayTimeBySerialNumber) (*CommonResponse, error)
 	ListUnfinishedInfos                      func(ctx context.Context, in *AutoCreateUserAndOrderRequest) (*UnfinishedInfos, error)
 	SoftDeleteUnfinishedInfo                 func(ctx context.Context, in *SoftDeleteUnfinishedInfoRequest) (*CommonResponse, error)
+	GetPendingTaskList                       func(ctx context.Context, in *TaskQueryRequest) (*TaskQueryResponse, error)
+	AssignTask                               func(ctx context.Context, in *TaskAssignRequest) (*CommonResponse, error)
+	UpdatePendingCount                       func(ctx context.Context, in *UpdatePendingCountRequest) (*CommonResponse, error)
+	GetRecentAssignRecords                   func(ctx context.Context, in *RecentAssignRecordsRequest) (*RecentAssignRecordsResponse, error)
+	GetEmployeeAssignedTasks                 func(ctx context.Context, in *EmployeeTaskQueryRequest) (*EmployeeTaskQueryResponse, error)
+	CompleteTaskManually                     func(ctx context.Context, in *CompleteTaskManuallyRequest) (*CommonResponse, error)
+	UpdateTaskProgress                       func(ctx context.Context, in *UpdateTaskProgressRequest) (*CommonResponse, error)
+	GetTaskAssignRecordsList                 func(ctx context.Context, in *TaskAssignRecordsQueryRequest) (*TaskAssignRecordsQueryResponse, error)
+	GetArtistBundleBalance                   func(ctx context.Context, in *ArtistBundleBalanceRequest) (*ArtistBundleBalanceResponse, error)
 }

 func (c *BundleClientImpl) GetDubboStub(cc *triple.TripleConn) BundleClient {
@ -381,6 +408,30 @@ func (c *bundleClient) AddBundleBalance(ctx context.Context, in *AddBundleBalanc
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/AddBundleBalance", in, out)
 }

+func (c *bundleClient) BundleActivate(ctx context.Context, in *BundleActivateReq, opts ...grpc_go.CallOption) (*BundleActivateResp, common.ErrorWithAttachment) {
+	out := new(BundleActivateResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/BundleActivate", in, out)
+}
+
+func (c *bundleClient) BundleBalanceExport(ctx context.Context, in *BundleBalanceExportReq, opts ...grpc_go.CallOption) (*BundleBalanceExportResp, common.ErrorWithAttachment) {
+	out := new(BundleBalanceExportResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/BundleBalanceExport", in, out)
+}
+
+func (c *bundleClient) GetBundleBalanceLayout(ctx context.Context, in *GetBundleBalanceLayoutReq, opts ...grpc_go.CallOption) (*GetBundleBalanceLayoutResp, common.ErrorWithAttachment) {
+	out := new(GetBundleBalanceLayoutResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetBundleBalanceLayout", in, out)
+}
+
+func (c *bundleClient) SetBundleBalanceLayout(ctx context.Context, in *SetBundleBalanceLayoutReq, opts ...grpc_go.CallOption) (*SetBundleBalanceLayoutResp, common.ErrorWithAttachment) {
+	out := new(SetBundleBalanceLayoutResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/SetBundleBalanceLayout", in, out)
+}
+
 func (c *bundleClient) GetUsedRecordList(ctx context.Context, in *GetUsedRecordListReq, opts ...grpc_go.CallOption) (*GetUsedRecordListResp, common.ErrorWithAttachment) {
 	out := new(GetUsedRecordListResp)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -447,6 +498,60 @@ func (c *bundleClient) SoftDeleteUnfinishedInfo(ctx context.Context, in *SoftDel
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/SoftDeleteUnfinishedInfo", in, out)
 }

+func (c *bundleClient) GetPendingTaskList(ctx context.Context, in *TaskQueryRequest, opts ...grpc_go.CallOption) (*TaskQueryResponse, common.ErrorWithAttachment) {
+	out := new(TaskQueryResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetPendingTaskList", in, out)
+}
+
+func (c *bundleClient) AssignTask(ctx context.Context, in *TaskAssignRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/AssignTask", in, out)
+}
+
+func (c *bundleClient) UpdatePendingCount(ctx context.Context, in *UpdatePendingCountRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdatePendingCount", in, out)
+}
+
+func (c *bundleClient) GetRecentAssignRecords(ctx context.Context, in *RecentAssignRecordsRequest, opts ...grpc_go.CallOption) (*RecentAssignRecordsResponse, common.ErrorWithAttachment) {
+	out := new(RecentAssignRecordsResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetRecentAssignRecords", in, out)
+}
+
+func (c *bundleClient) GetEmployeeAssignedTasks(ctx context.Context, in *EmployeeTaskQueryRequest, opts ...grpc_go.CallOption) (*EmployeeTaskQueryResponse, common.ErrorWithAttachment) {
+	out := new(EmployeeTaskQueryResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetEmployeeAssignedTasks", in, out)
+}
+
+func (c *bundleClient) CompleteTaskManually(ctx context.Context, in *CompleteTaskManuallyRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CompleteTaskManually", in, out)
+}
+
+func (c *bundleClient) UpdateTaskProgress(ctx context.Context, in *UpdateTaskProgressRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateTaskProgress", in, out)
+}
+
+func (c *bundleClient) GetTaskAssignRecordsList(ctx context.Context, in *TaskAssignRecordsQueryRequest, opts ...grpc_go.CallOption) (*TaskAssignRecordsQueryResponse, common.ErrorWithAttachment) {
+	out := new(TaskAssignRecordsQueryResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetTaskAssignRecordsList", in, out)
+}
+
+func (c *bundleClient) GetArtistBundleBalance(ctx context.Context, in *ArtistBundleBalanceRequest, opts ...grpc_go.CallOption) (*ArtistBundleBalanceResponse, common.ErrorWithAttachment) {
+	out := new(ArtistBundleBalanceResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetArtistBundleBalance", in, out)
+}
+
 // BundleServer is the server API for Bundle service.
 // All implementations must embed UnimplementedBundleServer
 // for forward compatibility
@ -492,6 +597,10 @@ type BundleServer interface {
 	GetBundleBalanceByUserId(context.Context, *GetBundleBalanceByUserIdReq) (*GetBundleBalanceByUserIdResp, error)
 	CreateBundleBalance(context.Context, *CreateBundleBalanceReq) (*CreateBundleBalanceResp, error)
 	AddBundleBalance(context.Context, *AddBundleBalanceReq) (*AddBundleBalanceResp, error)
+	BundleActivate(context.Context, *BundleActivateReq) (*BundleActivateResp, error)
+	BundleBalanceExport(context.Context, *BundleBalanceExportReq) (*BundleBalanceExportResp, error)
+	GetBundleBalanceLayout(context.Context, *GetBundleBalanceLayoutReq) (*GetBundleBalanceLayoutResp, error)
+	SetBundleBalanceLayout(context.Context, *SetBundleBalanceLayoutReq) (*SetBundleBalanceLayoutResp, error)
 	// 使用记录
 	GetUsedRecordList(context.Context, *GetUsedRecordListReq) (*GetUsedRecordListResp, error)
 	GetImageWorkDetail(context.Context, *GetImageWorkDetailReq) (*GetImageWorkDetailResp, error)
@ -506,6 +615,16 @@ type BundleServer interface {
 	// 查出没处理的数据
 	ListUnfinishedInfos(context.Context, *AutoCreateUserAndOrderRequest) (*UnfinishedInfos, error)
 	SoftDeleteUnfinishedInfo(context.Context, *SoftDeleteUnfinishedInfoRequest) (*CommonResponse, error)
+	// 任务台
+	GetPendingTaskList(context.Context, *TaskQueryRequest) (*TaskQueryResponse, error)
+	AssignTask(context.Context, *TaskAssignRequest) (*CommonResponse, error)
+	UpdatePendingCount(context.Context, *UpdatePendingCountRequest) (*CommonResponse, error)
+	GetRecentAssignRecords(context.Context, *RecentAssignRecordsRequest) (*RecentAssignRecordsResponse, error)
+	GetEmployeeAssignedTasks(context.Context, *EmployeeTaskQueryRequest) (*EmployeeTaskQueryResponse, error)
+	CompleteTaskManually(context.Context, *CompleteTaskManuallyRequest) (*CommonResponse, error)
+	UpdateTaskProgress(context.Context, *UpdateTaskProgressRequest) (*CommonResponse, error)
+	GetTaskAssignRecordsList(context.Context, *TaskAssignRecordsQueryRequest) (*TaskAssignRecordsQueryResponse, error)
+	GetArtistBundleBalance(context.Context, *ArtistBundleBalanceRequest) (*ArtistBundleBalanceResponse, error)
 	mustEmbedUnimplementedBundleServer()
 }

@ -628,6 +747,18 @@ func (UnimplementedBundleServer) CreateBundleBalance(context.Context, *CreateBun
 func (UnimplementedBundleServer) AddBundleBalance(context.Context, *AddBundleBalanceReq) (*AddBundleBalanceResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method AddBundleBalance not implemented")
 }
+func (UnimplementedBundleServer) BundleActivate(context.Context, *BundleActivateReq) (*BundleActivateResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method BundleActivate not implemented")
+}
+func (UnimplementedBundleServer) BundleBalanceExport(context.Context, *BundleBalanceExportReq) (*BundleBalanceExportResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method BundleBalanceExport not implemented")
+}
+func (UnimplementedBundleServer) GetBundleBalanceLayout(context.Context, *GetBundleBalanceLayoutReq) (*GetBundleBalanceLayoutResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetBundleBalanceLayout not implemented")
+}
+func (UnimplementedBundleServer) SetBundleBalanceLayout(context.Context, *SetBundleBalanceLayoutReq) (*SetBundleBalanceLayoutResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method SetBundleBalanceLayout not implemented")
+}
 func (UnimplementedBundleServer) GetUsedRecordList(context.Context, *GetUsedRecordListReq) (*GetUsedRecordListResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetUsedRecordList not implemented")
 }
@ -661,6 +792,33 @@ func (UnimplementedBundleServer) ListUnfinishedInfos(context.Context, *AutoCreat
 func (UnimplementedBundleServer) SoftDeleteUnfinishedInfo(context.Context, *SoftDeleteUnfinishedInfoRequest) (*CommonResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method SoftDeleteUnfinishedInfo not implemented")
 }
+func (UnimplementedBundleServer) GetPendingTaskList(context.Context, *TaskQueryRequest) (*TaskQueryResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetPendingTaskList not implemented")
+}
+func (UnimplementedBundleServer) AssignTask(context.Context, *TaskAssignRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method AssignTask not implemented")
+}
+func (UnimplementedBundleServer) UpdatePendingCount(context.Context, *UpdatePendingCountRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UpdatePendingCount not implemented")
+}
+func (UnimplementedBundleServer) GetRecentAssignRecords(context.Context, *RecentAssignRecordsRequest) (*RecentAssignRecordsResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetRecentAssignRecords not implemented")
+}
+func (UnimplementedBundleServer) GetEmployeeAssignedTasks(context.Context, *EmployeeTaskQueryRequest) (*EmployeeTaskQueryResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetEmployeeAssignedTasks not implemented")
+}
+func (UnimplementedBundleServer) CompleteTaskManually(context.Context, *CompleteTaskManuallyRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method CompleteTaskManually not implemented")
+}
+func (UnimplementedBundleServer) UpdateTaskProgress(context.Context, *UpdateTaskProgressRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UpdateTaskProgress not implemented")
+}
+func (UnimplementedBundleServer) GetTaskAssignRecordsList(context.Context, *TaskAssignRecordsQueryRequest) (*TaskAssignRecordsQueryResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetTaskAssignRecordsList not implemented")
+}
+func (UnimplementedBundleServer) GetArtistBundleBalance(context.Context, *ArtistBundleBalanceRequest) (*ArtistBundleBalanceResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetArtistBundleBalance not implemented")
+}
 func (s *UnimplementedBundleServer) XXX_SetProxyImpl(impl protocol.Invoker) {
 	s.proxyImpl = impl
 }
@ -1791,6 +1949,122 @@ func _Bundle_AddBundleBalance_Handler(srv interface{}, ctx context.Context, dec
 	return interceptor(ctx, in, info, handler)
 }

+func _Bundle_BundleActivate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(BundleActivateReq)
+	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("BundleActivate", 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_BundleBalanceExport_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(BundleBalanceExportReq)
+	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("BundleBalanceExport", 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_GetBundleBalanceLayout_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetBundleBalanceLayoutReq)
+	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("GetBundleBalanceLayout", 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_SetBundleBalanceLayout_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(SetBundleBalanceLayoutReq)
+	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("SetBundleBalanceLayout", 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_GetUsedRecordList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
 	in := new(GetUsedRecordListReq)
 	if err := dec(in); err != nil {
@ -2110,6 +2384,267 @@ func _Bundle_SoftDeleteUnfinishedInfo_Handler(srv interface{}, ctx context.Conte
 	return interceptor(ctx, in, info, handler)
 }

+func _Bundle_GetPendingTaskList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(TaskQueryRequest)
+	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("GetPendingTaskList", 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_AssignTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(TaskAssignRequest)
+	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("AssignTask", 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_UpdatePendingCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UpdatePendingCountRequest)
+	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("UpdatePendingCount", 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_GetRecentAssignRecords_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(RecentAssignRecordsRequest)
+	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("GetRecentAssignRecords", 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_GetEmployeeAssignedTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(EmployeeTaskQueryRequest)
+	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("GetEmployeeAssignedTasks", 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_CompleteTaskManually_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CompleteTaskManuallyRequest)
+	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("CompleteTaskManually", 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_UpdateTaskProgress_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UpdateTaskProgressRequest)
+	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("UpdateTaskProgress", 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_GetTaskAssignRecordsList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(TaskAssignRecordsQueryRequest)
+	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("GetTaskAssignRecordsList", 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_GetArtistBundleBalance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(ArtistBundleBalanceRequest)
+	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("GetArtistBundleBalance", 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.
 // It's only intended for direct use with grpc_go.RegisterService,
 // and not to be introspected or modified (even as a copy)
@ -2269,6 +2804,22 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "AddBundleBalance",
 			Handler:    _Bundle_AddBundleBalance_Handler,
 		},
+		{
+			MethodName: "BundleActivate",
+			Handler:    _Bundle_BundleActivate_Handler,
+		},
+		{
+			MethodName: "BundleBalanceExport",
+			Handler:    _Bundle_BundleBalanceExport_Handler,
+		},
+		{
+			MethodName: "GetBundleBalanceLayout",
+			Handler:    _Bundle_GetBundleBalanceLayout_Handler,
+		},
+		{
+			MethodName: "SetBundleBalanceLayout",
+			Handler:    _Bundle_SetBundleBalanceLayout_Handler,
+		},
 		{
 			MethodName: "GetUsedRecordList",
 			Handler:    _Bundle_GetUsedRecordList_Handler,
@ -2313,6 +2864,42 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "SoftDeleteUnfinishedInfo",
 			Handler:    _Bundle_SoftDeleteUnfinishedInfo_Handler,
 		},
+		{
+			MethodName: "GetPendingTaskList",
+			Handler:    _Bundle_GetPendingTaskList_Handler,
+		},
+		{
+			MethodName: "AssignTask",
+			Handler:    _Bundle_AssignTask_Handler,
+		},
+		{
+			MethodName: "UpdatePendingCount",
+			Handler:    _Bundle_UpdatePendingCount_Handler,
+		},
+		{
+			MethodName: "GetRecentAssignRecords",
+			Handler:    _Bundle_GetRecentAssignRecords_Handler,
+		},
+		{
+			MethodName: "GetEmployeeAssignedTasks",
+			Handler:    _Bundle_GetEmployeeAssignedTasks_Handler,
+		},
+		{
+			MethodName: "CompleteTaskManually",
+			Handler:    _Bundle_CompleteTaskManually_Handler,
+		},
+		{
+			MethodName: "UpdateTaskProgress",
+			Handler:    _Bundle_UpdateTaskProgress_Handler,
+		},
+		{
+			MethodName: "GetTaskAssignRecordsList",
+			Handler:    _Bundle_GetTaskAssignRecordsList_Handler,
+		},
+		{
+			MethodName: "GetArtistBundleBalance",
+			Handler:    _Bundle_GetArtistBundleBalance_Handler,
+		},
 	},
 	Streams:  []grpc_go.StreamDesc{},
 	Metadata: "pb/bundle.proto",
--- a/api/cast/cast.pb.go
+++ b/api/cast/cast.pb.go
@ -1379,6 +1379,7 @@ type WorkListReq struct {
 	Page                  int32                  `protobuf:"varint,12,opt,name=page,proto3" json:"page"`
 	PageSize              int32                  `protobuf:"varint,13,opt,name=pageSize,proto3" json:"pageSize"`
 	MediaAccountUuids     []string               `protobuf:"bytes,14,rep,name=mediaAccountUuids,proto3" json:"mediaAccountUuids"`
+	CostType              int32                  `protobuf:"varint,15,opt,name=costType,proto3" json:"costType"`
 	unknownFields         protoimpl.UnknownFields
 	sizeCache             protoimpl.SizeCache
 }
@ -1511,6 +1512,13 @@ func (x *WorkListReq) GetMediaAccountUuids() []string {
 	return nil
 }

+func (x *WorkListReq) GetCostType() int32 {
+	if x != nil {
+		return x.CostType
+	}
+	return 0
+}
+
 type WorkListResp struct {
 	state         protoimpl.MessageState `protogen:"open.v1"`
 	Data          []*WorkListResp_Info   `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
@ -1896,6 +1904,7 @@ type UpdateStatusReq struct {
 	ConfirmStatus uint32                 `protobuf:"varint,5,opt,name=confirmStatus,proto3" json:"confirmStatus"`
 	ApprovalReply string                 `protobuf:"bytes,6,opt,name=approvalReply,proto3" json:"approvalReply"`
 	AutoPublish   AutoPublishENUM        `protobuf:"varint,7,opt,name=autoPublish,proto3,enum=Cast.AutoPublishENUM" json:"autoPublish"`
+	CostType      uint32                 `protobuf:"varint,8,opt,name=costType,proto3" json:"costType"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@ -1979,6 +1988,13 @@ func (x *UpdateStatusReq) GetAutoPublish() AutoPublishENUM {
 	return AutoPublishENUM_AutoPublish_UNKONW
 }

+func (x *UpdateStatusReq) GetCostType() uint32 {
+	if x != nil {
+		return x.CostType
+	}
+	return 0
+}
+
 type MediaAccountsReq struct {
 	state         protoimpl.MessageState `protogen:"open.v1"`
 	ArtistUuid    string                 `protobuf:"bytes,1,opt,name=artistUuid,proto3" json:"artistUuid"`
@ -2179,6 +2195,94 @@ func (x *MediaWorksResp) GetData() []*MediaWorksResp_Info {
 	return nil
 }

+type PublishReq struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	WorkUuids     []string               `protobuf:"bytes,1,rep,name=workUuids,proto3" json:"workUuids"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *PublishReq) Reset() {
+	*x = PublishReq{}
+	mi := &file_pb_fiee_cast_proto_msgTypes[23]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *PublishReq) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*PublishReq) ProtoMessage() {}
+
+func (x *PublishReq) ProtoReflect() protoreflect.Message {
+	mi := &file_pb_fiee_cast_proto_msgTypes[23]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use PublishReq.ProtoReflect.Descriptor instead.
+func (*PublishReq) Descriptor() ([]byte, []int) {
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{23}
+}
+
+func (x *PublishReq) GetWorkUuids() []string {
+	if x != nil {
+		return x.WorkUuids
+	}
+	return nil
+}
+
+type PublishResp struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Data          []*PublishResp_Info    `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *PublishResp) Reset() {
+	*x = PublishResp{}
+	mi := &file_pb_fiee_cast_proto_msgTypes[24]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *PublishResp) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*PublishResp) ProtoMessage() {}
+
+func (x *PublishResp) ProtoReflect() protoreflect.Message {
+	mi := &file_pb_fiee_cast_proto_msgTypes[24]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use PublishResp.ProtoReflect.Descriptor instead.
+func (*PublishResp) Descriptor() ([]byte, []int) {
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{24}
+}
+
+func (x *PublishResp) GetData() []*PublishResp_Info {
+	if x != nil {
+		return x.Data
+	}
+	return nil
+}
+
 type RePublishReq struct {
 	state             protoimpl.MessageState `protogen:"open.v1"`
 	WorkUuid          string                 `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"`
@ -2190,7 +2294,7 @@ type RePublishReq struct {

 func (x *RePublishReq) Reset() {
 	*x = RePublishReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[23]
+	mi := &file_pb_fiee_cast_proto_msgTypes[25]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2202,7 +2306,7 @@ func (x *RePublishReq) String() string {
 func (*RePublishReq) ProtoMessage() {}

 func (x *RePublishReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[23]
+	mi := &file_pb_fiee_cast_proto_msgTypes[25]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2215,7 +2319,7 @@ func (x *RePublishReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use RePublishReq.ProtoReflect.Descriptor instead.
 func (*RePublishReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{23}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{25}
 }

 func (x *RePublishReq) GetWorkUuid() string {
@ -2249,7 +2353,7 @@ type RePublishResp struct {

 func (x *RePublishResp) Reset() {
 	*x = RePublishResp{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[24]
+	mi := &file_pb_fiee_cast_proto_msgTypes[26]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2261,7 +2365,7 @@ func (x *RePublishResp) String() string {
 func (*RePublishResp) ProtoMessage() {}

 func (x *RePublishResp) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[24]
+	mi := &file_pb_fiee_cast_proto_msgTypes[26]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2274,7 +2378,7 @@ func (x *RePublishResp) ProtoReflect() protoreflect.Message {

 // Deprecated: Use RePublishResp.ProtoReflect.Descriptor instead.
 func (*RePublishResp) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{24}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{26}
 }

 func (x *RePublishResp) GetArtistUuid() string {
@ -2300,7 +2404,7 @@ type DelWorkReq struct {

 func (x *DelWorkReq) Reset() {
 	*x = DelWorkReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[25]
+	mi := &file_pb_fiee_cast_proto_msgTypes[27]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2312,7 +2416,7 @@ func (x *DelWorkReq) String() string {
 func (*DelWorkReq) ProtoMessage() {}

 func (x *DelWorkReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[25]
+	mi := &file_pb_fiee_cast_proto_msgTypes[27]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2325,7 +2429,7 @@ func (x *DelWorkReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use DelWorkReq.ProtoReflect.Descriptor instead.
 func (*DelWorkReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{25}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{27}
 }

 func (x *DelWorkReq) GetWorkUuid() string {
@ -2344,7 +2448,7 @@ type WorkInfoReq struct {

 func (x *WorkInfoReq) Reset() {
 	*x = WorkInfoReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[26]
+	mi := &file_pb_fiee_cast_proto_msgTypes[28]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2356,7 +2460,7 @@ func (x *WorkInfoReq) String() string {
 func (*WorkInfoReq) ProtoMessage() {}

 func (x *WorkInfoReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[26]
+	mi := &file_pb_fiee_cast_proto_msgTypes[28]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2369,7 +2473,7 @@ func (x *WorkInfoReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use WorkInfoReq.ProtoReflect.Descriptor instead.
 func (*WorkInfoReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{26}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{28}
 }

 func (x *WorkInfoReq) GetWorkUuid() string {
@ -2393,7 +2497,7 @@ type WorkInfoResp struct {

 func (x *WorkInfoResp) Reset() {
 	*x = WorkInfoResp{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[27]
+	mi := &file_pb_fiee_cast_proto_msgTypes[29]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2405,7 +2509,7 @@ func (x *WorkInfoResp) String() string {
 func (*WorkInfoResp) ProtoMessage() {}

 func (x *WorkInfoResp) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[27]
+	mi := &file_pb_fiee_cast_proto_msgTypes[29]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2418,7 +2522,7 @@ func (x *WorkInfoResp) ProtoReflect() protoreflect.Message {

 // Deprecated: Use WorkInfoResp.ProtoReflect.Descriptor instead.
 func (*WorkInfoResp) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{27}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{29}
 }

 func (x *WorkInfoResp) GetWorkStatus() uint32 {
@ -2472,7 +2576,7 @@ type OAuthAccountReq struct {

 func (x *OAuthAccountReq) Reset() {
 	*x = OAuthAccountReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[28]
+	mi := &file_pb_fiee_cast_proto_msgTypes[30]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2484,7 +2588,7 @@ func (x *OAuthAccountReq) String() string {
 func (*OAuthAccountReq) ProtoMessage() {}

 func (x *OAuthAccountReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[28]
+	mi := &file_pb_fiee_cast_proto_msgTypes[30]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2497,7 +2601,7 @@ func (x *OAuthAccountReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use OAuthAccountReq.ProtoReflect.Descriptor instead.
 func (*OAuthAccountReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{28}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{30}
 }

 func (x *OAuthAccountReq) GetMediaAccountUuid() string {
@ -2516,7 +2620,7 @@ type OAuthAccountResp struct {

 func (x *OAuthAccountResp) Reset() {
 	*x = OAuthAccountResp{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[29]
+	mi := &file_pb_fiee_cast_proto_msgTypes[31]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2528,7 +2632,7 @@ func (x *OAuthAccountResp) String() string {
 func (*OAuthAccountResp) ProtoMessage() {}

 func (x *OAuthAccountResp) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[29]
+	mi := &file_pb_fiee_cast_proto_msgTypes[31]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2541,7 +2645,7 @@ func (x *OAuthAccountResp) ProtoReflect() protoreflect.Message {

 // Deprecated: Use OAuthAccountResp.ProtoReflect.Descriptor instead.
 func (*OAuthAccountResp) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{29}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{31}
 }

 func (x *OAuthAccountResp) GetUrl() string {
@ -2562,7 +2666,7 @@ type OAuthYoutubeTokenReq struct {

 func (x *OAuthYoutubeTokenReq) Reset() {
 	*x = OAuthYoutubeTokenReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[30]
+	mi := &file_pb_fiee_cast_proto_msgTypes[32]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2574,7 +2678,7 @@ func (x *OAuthYoutubeTokenReq) String() string {
 func (*OAuthYoutubeTokenReq) ProtoMessage() {}

 func (x *OAuthYoutubeTokenReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[30]
+	mi := &file_pb_fiee_cast_proto_msgTypes[32]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2587,7 +2691,7 @@ func (x *OAuthYoutubeTokenReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use OAuthYoutubeTokenReq.ProtoReflect.Descriptor instead.
 func (*OAuthYoutubeTokenReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{30}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{32}
 }

 func (x *OAuthYoutubeTokenReq) GetMediaAccountUuid() string {
@ -2615,7 +2719,7 @@ type OAuthYoutubeTokenResp struct {

 func (x *OAuthYoutubeTokenResp) Reset() {
 	*x = OAuthYoutubeTokenResp{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[31]
+	mi := &file_pb_fiee_cast_proto_msgTypes[33]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2627,7 +2731,7 @@ func (x *OAuthYoutubeTokenResp) String() string {
 func (*OAuthYoutubeTokenResp) ProtoMessage() {}

 func (x *OAuthYoutubeTokenResp) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[31]
+	mi := &file_pb_fiee_cast_proto_msgTypes[33]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2640,7 +2744,7 @@ func (x *OAuthYoutubeTokenResp) ProtoReflect() protoreflect.Message {

 // Deprecated: Use OAuthYoutubeTokenResp.ProtoReflect.Descriptor instead.
 func (*OAuthYoutubeTokenResp) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{31}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{33}
 }

 func (x *OAuthYoutubeTokenResp) GetAccessToken() string {
@ -2675,7 +2779,7 @@ type OAuthCodeToTokenReq struct {

 func (x *OAuthCodeToTokenReq) Reset() {
 	*x = OAuthCodeToTokenReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[32]
+	mi := &file_pb_fiee_cast_proto_msgTypes[34]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2687,7 +2791,7 @@ func (x *OAuthCodeToTokenReq) String() string {
 func (*OAuthCodeToTokenReq) ProtoMessage() {}

 func (x *OAuthCodeToTokenReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[32]
+	mi := &file_pb_fiee_cast_proto_msgTypes[34]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2700,7 +2804,7 @@ func (x *OAuthCodeToTokenReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use OAuthCodeToTokenReq.ProtoReflect.Descriptor instead.
 func (*OAuthCodeToTokenReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{32}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{34}
 }

 func (x *OAuthCodeToTokenReq) GetCode() string {
@ -2732,7 +2836,7 @@ type OAuthCodeToTokenResp struct {

 func (x *OAuthCodeToTokenResp) Reset() {
 	*x = OAuthCodeToTokenResp{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[33]
+	mi := &file_pb_fiee_cast_proto_msgTypes[35]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2744,7 +2848,7 @@ func (x *OAuthCodeToTokenResp) String() string {
 func (*OAuthCodeToTokenResp) ProtoMessage() {}

 func (x *OAuthCodeToTokenResp) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[33]
+	mi := &file_pb_fiee_cast_proto_msgTypes[35]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2757,7 +2861,7 @@ func (x *OAuthCodeToTokenResp) ProtoReflect() protoreflect.Message {

 // Deprecated: Use OAuthCodeToTokenResp.ProtoReflect.Descriptor instead.
 func (*OAuthCodeToTokenResp) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{33}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{35}
 }

 type RefreshTokenReq struct {
@ -2771,7 +2875,7 @@ type RefreshTokenReq struct {

 func (x *RefreshTokenReq) Reset() {
 	*x = RefreshTokenReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[34]
+	mi := &file_pb_fiee_cast_proto_msgTypes[36]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2783,7 +2887,7 @@ func (x *RefreshTokenReq) String() string {
 func (*RefreshTokenReq) ProtoMessage() {}

 func (x *RefreshTokenReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[34]
+	mi := &file_pb_fiee_cast_proto_msgTypes[36]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2796,7 +2900,7 @@ func (x *RefreshTokenReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use RefreshTokenReq.ProtoReflect.Descriptor instead.
 func (*RefreshTokenReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{34}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{36}
 }

 func (x *RefreshTokenReq) GetRefreshToken() string {
@ -2830,7 +2934,7 @@ type RefreshTokenResp struct {

 func (x *RefreshTokenResp) Reset() {
 	*x = RefreshTokenResp{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[35]
+	mi := &file_pb_fiee_cast_proto_msgTypes[37]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2842,7 +2946,7 @@ func (x *RefreshTokenResp) String() string {
 func (*RefreshTokenResp) ProtoMessage() {}

 func (x *RefreshTokenResp) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[35]
+	mi := &file_pb_fiee_cast_proto_msgTypes[37]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2855,7 +2959,7 @@ func (x *RefreshTokenResp) ProtoReflect() protoreflect.Message {

 // Deprecated: Use RefreshTokenResp.ProtoReflect.Descriptor instead.
 func (*RefreshTokenResp) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{35}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{37}
 }

 func (x *RefreshTokenResp) GetAccessToken() string {
@ -2883,7 +2987,7 @@ type PublishMediaInfoReq struct {

 func (x *PublishMediaInfoReq) Reset() {
 	*x = PublishMediaInfoReq{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[36]
+	mi := &file_pb_fiee_cast_proto_msgTypes[38]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2895,7 +2999,7 @@ func (x *PublishMediaInfoReq) String() string {
 func (*PublishMediaInfoReq) ProtoMessage() {}

 func (x *PublishMediaInfoReq) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[36]
+	mi := &file_pb_fiee_cast_proto_msgTypes[38]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2908,7 +3012,7 @@ func (x *PublishMediaInfoReq) ProtoReflect() protoreflect.Message {

 // Deprecated: Use PublishMediaInfoReq.ProtoReflect.Descriptor instead.
 func (*PublishMediaInfoReq) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{36}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{38}
 }

 func (x *PublishMediaInfoReq) GetWorkUuid() string {
@ -2944,7 +3048,7 @@ type PublishMediaInfoResp struct {

 func (x *PublishMediaInfoResp) Reset() {
 	*x = PublishMediaInfoResp{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[37]
+	mi := &file_pb_fiee_cast_proto_msgTypes[39]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -2956,7 +3060,7 @@ func (x *PublishMediaInfoResp) String() string {
 func (*PublishMediaInfoResp) ProtoMessage() {}

 func (x *PublishMediaInfoResp) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[37]
+	mi := &file_pb_fiee_cast_proto_msgTypes[39]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -2969,7 +3073,7 @@ func (x *PublishMediaInfoResp) ProtoReflect() protoreflect.Message {

 // Deprecated: Use PublishMediaInfoResp.ProtoReflect.Descriptor instead.
 func (*PublishMediaInfoResp) Descriptor() ([]byte, []int) {
-	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{37}
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{39}
 }

 func (x *PublishMediaInfoResp) GetWorkUuid() string {
@ -3023,7 +3127,7 @@ type WorkListResp_Info struct {

 func (x *WorkListResp_Info) Reset() {
 	*x = WorkListResp_Info{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[38]
+	mi := &file_pb_fiee_cast_proto_msgTypes[40]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -3035,7 +3139,7 @@ func (x *WorkListResp_Info) String() string {
 func (*WorkListResp_Info) ProtoMessage() {}

 func (x *WorkListResp_Info) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[38]
+	mi := &file_pb_fiee_cast_proto_msgTypes[40]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -3170,7 +3274,7 @@ type MediaAccountsResp_Info struct {

 func (x *MediaAccountsResp_Info) Reset() {
 	*x = MediaAccountsResp_Info{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[40]
+	mi := &file_pb_fiee_cast_proto_msgTypes[42]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -3182,7 +3286,7 @@ func (x *MediaAccountsResp_Info) String() string {
 func (*MediaAccountsResp_Info) ProtoMessage() {}

 func (x *MediaAccountsResp_Info) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[40]
+	mi := &file_pb_fiee_cast_proto_msgTypes[42]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -3258,7 +3362,7 @@ type MediaWorksResp_Info struct {

 func (x *MediaWorksResp_Info) Reset() {
 	*x = MediaWorksResp_Info{}
-	mi := &file_pb_fiee_cast_proto_msgTypes[41]
+	mi := &file_pb_fiee_cast_proto_msgTypes[43]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@ -3270,7 +3374,7 @@ func (x *MediaWorksResp_Info) String() string {
 func (*MediaWorksResp_Info) ProtoMessage() {}

 func (x *MediaWorksResp_Info) ProtoReflect() protoreflect.Message {
-	mi := &file_pb_fiee_cast_proto_msgTypes[41]
+	mi := &file_pb_fiee_cast_proto_msgTypes[43]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@ -3356,6 +3460,58 @@ func (x *MediaWorksResp_Info) GetCoverUrl() string {
 	return ""
 }

+type PublishResp_Info struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	ArtistUuid    string                 `protobuf:"bytes,1,opt,name=artistUuid,proto3" json:"artistUuid"`
+	WorkCategory  int32                  `protobuf:"varint,2,opt,name=workCategory,proto3" json:"workCategory"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *PublishResp_Info) Reset() {
+	*x = PublishResp_Info{}
+	mi := &file_pb_fiee_cast_proto_msgTypes[44]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *PublishResp_Info) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*PublishResp_Info) ProtoMessage() {}
+
+func (x *PublishResp_Info) ProtoReflect() protoreflect.Message {
+	mi := &file_pb_fiee_cast_proto_msgTypes[44]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use PublishResp_Info.ProtoReflect.Descriptor instead.
+func (*PublishResp_Info) Descriptor() ([]byte, []int) {
+	return file_pb_fiee_cast_proto_rawDescGZIP(), []int{24, 0}
+}
+
+func (x *PublishResp_Info) GetArtistUuid() string {
+	if x != nil {
+		return x.ArtistUuid
+	}
+	return ""
+}
+
+func (x *PublishResp_Info) GetWorkCategory() int32 {
+	if x != nil {
+		return x.WorkCategory
+	}
+	return 0
+}
+
 var File_pb_fiee_cast_proto protoreflect.FileDescriptor

 const file_pb_fiee_cast_proto_rawDesc = "" +
@ -3494,7 +3650,7 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\x10coverTimestampMs\x18\x12 \x01(\x04R\x10coverTimestampMs\x127\n" +
 	"\vautoPublish\x18\x13 \x01(\x0e2\x15.Cast.AutoPublishENUMR\vautoPublish\"1\n" +
 	"\x13UpdateWorkVideoResp\x12\x1a\n" +
-	"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\"\x8f\x04\n" +
+	"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\"\xab\x04\n" +
 	"\vWorkListReq\x12\x1c\n" +
 	"\tartistVal\x18\x01 \x01(\tR\tartistVal\x12\x1e\n" +
 	"\n" +
@ -3514,7 +3670,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\x0emanagerUserVal\x18\v \x01(\tR\x0emanagerUserVal\x12\x12\n" +
 	"\x04page\x18\f \x01(\x05R\x04page\x12\x1a\n" +
 	"\bpageSize\x18\r \x01(\x05R\bpageSize\x12,\n" +
-	"\x11mediaAccountUuids\x18\x0e \x03(\tR\x11mediaAccountUuids\"\xe8\x04\n" +
+	"\x11mediaAccountUuids\x18\x0e \x03(\tR\x11mediaAccountUuids\x12\x1a\n" +
+	"\bcostType\x18\x0f \x01(\x05R\bcostType\"\xe8\x04\n" +
 	"\fWorkListResp\x12+\n" +
 	"\x04data\x18\x01 \x03(\v2\x17.Cast.WorkListResp.InfoR\x04data\x12\x14\n" +
 	"\x05count\x18\x02 \x01(\x03R\x05count\x1a\x94\x04\n" +
@ -3586,7 +3743,7 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\x10coverTimestampMs\x18\x12 \x01(\x04R\x10coverTimestampMs\x1aT\n" +
 	"\x11MediaAccDataEntry\x12\x10\n" +
 	"\x03key\x18\x01 \x01(\tR\x03key\x12)\n" +
-	"\x05value\x18\x02 \x01(\v2\x13.Cast.MediaUserInfoR\x05value:\x028\x01\"\xae\x02\n" +
+	"\x05value\x18\x02 \x01(\v2\x13.Cast.MediaUserInfoR\x05value:\x028\x01\"\xca\x02\n" +
 	"\x0fUpdateStatusReq\x124\n" +
 	"\n" +
 	"workAction\x18\x01 \x01(\x0e2\x14.Cast.WorkActionENUMR\n" +
@ -3598,7 +3755,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\rconfirmRemark\x18\x04 \x01(\tR\rconfirmRemark\x12$\n" +
 	"\rconfirmStatus\x18\x05 \x01(\rR\rconfirmStatus\x12$\n" +
 	"\rapprovalReply\x18\x06 \x01(\tR\rapprovalReply\x127\n" +
-	"\vautoPublish\x18\a \x01(\x0e2\x15.Cast.AutoPublishENUMR\vautoPublish\"2\n" +
+	"\vautoPublish\x18\a \x01(\x0e2\x15.Cast.AutoPublishENUMR\vautoPublish\x12\x1a\n" +
+	"\bcostType\x18\b \x01(\rR\bcostType\"2\n" +
 	"\x10MediaAccountsReq\x12\x1e\n" +
 	"\n" +
 	"artistUuid\x18\x01 \x01(\tR\n" +
@ -3638,7 +3796,17 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\x06images\x18\b \x03(\tR\x06images\x12\x1a\n" +
 	"\bvideoUrl\x18\t \x01(\tR\bvideoUrl\x12\x1a\n" +
 	"\bcoverUrl\x18\n" +
-	" \x01(\tR\bcoverUrl\"\x86\x01\n" +
+	" \x01(\tR\bcoverUrl\"*\n" +
+	"\n" +
+	"PublishReq\x12\x1c\n" +
+	"\tworkUuids\x18\x01 \x03(\tR\tworkUuids\"\x85\x01\n" +
+	"\vPublishResp\x12*\n" +
+	"\x04data\x18\x01 \x03(\v2\x16.Cast.PublishResp.InfoR\x04data\x1aJ\n" +
+	"\x04Info\x12\x1e\n" +
+	"\n" +
+	"artistUuid\x18\x01 \x01(\tR\n" +
+	"artistUuid\x12\"\n" +
+	"\fworkCategory\x18\x02 \x01(\x05R\fworkCategory\"\x86\x01\n" +
 	"\fRePublishReq\x12\x1a\n" +
 	"\bworkUuid\x18\x01 \x01(\tR\bworkUuid\x12,\n" +
 	"\x11mediaAccountUuids\x18\x02 \x03(\tR\x11mediaAccountUuids\x12,\n" +
@ -3731,7 +3899,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\x0fAutoPublishENUM\x12\x16\n" +
 	"\x12AutoPublish_UNKONW\x10\x00\x12\x14\n" +
 	"\x10AutoPublish_TRUE\x10\x01\x12\x15\n" +
-	"\x11AutoPublish_FALSE\x10\x022\xde\t\n" +
+	"\x11AutoPublish_FALSE\x10\x022\x90\n" +
+	"\n" +
 	"\x04Cast\x12B\n" +
 	"\rMediaUserList\x12\x16.Cast.MediaUserListReq\x1a\x17.Cast.MediaUserListResp\"\x00\x12Q\n" +
 	"\x12UpdateMediaAccount\x12\x1b.Cast.UpdateMediaAccountReq\x1a\x1c.Cast.UpdateMediaAccountResp\"\x00\x12B\n" +
@ -3745,7 +3914,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" +
 	"\fUpdateStatus\x12\x15.Cast.UpdateStatusReq\x1a\x16.google.protobuf.Empty\"\x00\x12B\n" +
 	"\rMediaAccounts\x12\x16.Cast.MediaAccountsReq\x1a\x17.Cast.MediaAccountsResp\"\x00\x129\n" +
 	"\n" +
-	"MediaWorks\x12\x13.Cast.MediaWorksReq\x1a\x14.Cast.MediaWorksResp\"\x00\x126\n" +
+	"MediaWorks\x12\x13.Cast.MediaWorksReq\x1a\x14.Cast.MediaWorksResp\"\x00\x120\n" +
+	"\aPublish\x12\x10.Cast.PublishReq\x1a\x11.Cast.PublishResp\"\x00\x126\n" +
 	"\tRePublish\x12\x12.Cast.RePublishReq\x1a\x13.Cast.RePublishResp\"\x00\x125\n" +
 	"\aDelWork\x12\x10.Cast.DelWorkReq\x1a\x16.google.protobuf.Empty\"\x00\x123\n" +
 	"\bWorkInfo\x12\x11.Cast.WorkInfoReq\x1a\x12.Cast.WorkInfoResp\"\x00\x12?\n" +
@ -3768,7 +3938,7 @@ func file_pb_fiee_cast_proto_rawDescGZIP() []byte {
 }

 var file_pb_fiee_cast_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
-var file_pb_fiee_cast_proto_msgTypes = make([]protoimpl.MessageInfo, 42)
+var file_pb_fiee_cast_proto_msgTypes = make([]protoimpl.MessageInfo, 45)
 var file_pb_fiee_cast_proto_goTypes = []any{
 	(PlatformIDENUM)(0),            // 0: Cast.PlatformIDENUM
 	(AuthStatusENUM)(0),            // 1: Cast.AuthStatusENUM
@ -3797,26 +3967,29 @@ var file_pb_fiee_cast_proto_goTypes = []any{
 	(*MediaAccountsResp)(nil),      // 24: Cast.MediaAccountsResp
 	(*MediaWorksReq)(nil),          // 25: Cast.MediaWorksReq
 	(*MediaWorksResp)(nil),         // 26: Cast.MediaWorksResp
-	(*RePublishReq)(nil),           // 27: Cast.RePublishReq
-	(*RePublishResp)(nil),          // 28: Cast.RePublishResp
-	(*DelWorkReq)(nil),             // 29: Cast.DelWorkReq
-	(*WorkInfoReq)(nil),            // 30: Cast.WorkInfoReq
-	(*WorkInfoResp)(nil),           // 31: Cast.WorkInfoResp
-	(*OAuthAccountReq)(nil),        // 32: Cast.OAuthAccountReq
-	(*OAuthAccountResp)(nil),       // 33: Cast.OAuthAccountResp
-	(*OAuthYoutubeTokenReq)(nil),   // 34: Cast.OAuthYoutubeTokenReq
-	(*OAuthYoutubeTokenResp)(nil),  // 35: Cast.OAuthYoutubeTokenResp
-	(*OAuthCodeToTokenReq)(nil),    // 36: Cast.OAuthCodeToTokenReq
-	(*OAuthCodeToTokenResp)(nil),   // 37: Cast.OAuthCodeToTokenResp
-	(*RefreshTokenReq)(nil),        // 38: Cast.RefreshTokenReq
-	(*RefreshTokenResp)(nil),       // 39: Cast.RefreshTokenResp
-	(*PublishMediaInfoReq)(nil),    // 40: Cast.PublishMediaInfoReq
-	(*PublishMediaInfoResp)(nil),   // 41: Cast.PublishMediaInfoResp
-	(*WorkListResp_Info)(nil),      // 42: Cast.WorkListResp.Info
-	nil,                            // 43: Cast.WorkDetailResp.MediaAccDataEntry
-	(*MediaAccountsResp_Info)(nil), // 44: Cast.MediaAccountsResp.Info
-	(*MediaWorksResp_Info)(nil),    // 45: Cast.MediaWorksResp.Info
-	(*emptypb.Empty)(nil),          // 46: google.protobuf.Empty
+	(*PublishReq)(nil),             // 27: Cast.PublishReq
+	(*PublishResp)(nil),            // 28: Cast.PublishResp
+	(*RePublishReq)(nil),           // 29: Cast.RePublishReq
+	(*RePublishResp)(nil),          // 30: Cast.RePublishResp
+	(*DelWorkReq)(nil),             // 31: Cast.DelWorkReq
+	(*WorkInfoReq)(nil),            // 32: Cast.WorkInfoReq
+	(*WorkInfoResp)(nil),           // 33: Cast.WorkInfoResp
+	(*OAuthAccountReq)(nil),        // 34: Cast.OAuthAccountReq
+	(*OAuthAccountResp)(nil),       // 35: Cast.OAuthAccountResp
+	(*OAuthYoutubeTokenReq)(nil),   // 36: Cast.OAuthYoutubeTokenReq
+	(*OAuthYoutubeTokenResp)(nil),  // 37: Cast.OAuthYoutubeTokenResp
+	(*OAuthCodeToTokenReq)(nil),    // 38: Cast.OAuthCodeToTokenReq
+	(*OAuthCodeToTokenResp)(nil),   // 39: Cast.OAuthCodeToTokenResp
+	(*RefreshTokenReq)(nil),        // 40: Cast.RefreshTokenReq
+	(*RefreshTokenResp)(nil),       // 41: Cast.RefreshTokenResp
+	(*PublishMediaInfoReq)(nil),    // 42: Cast.PublishMediaInfoReq
+	(*PublishMediaInfoResp)(nil),   // 43: Cast.PublishMediaInfoResp
+	(*WorkListResp_Info)(nil),      // 44: Cast.WorkListResp.Info
+	nil,                            // 45: Cast.WorkDetailResp.MediaAccDataEntry
+	(*MediaAccountsResp_Info)(nil), // 46: Cast.MediaAccountsResp.Info
+	(*MediaWorksResp_Info)(nil),    // 47: Cast.MediaWorksResp.Info
+	(*PublishResp_Info)(nil),       // 48: Cast.PublishResp.Info
+	(*emptypb.Empty)(nil),          // 49: google.protobuf.Empty
 }
 var file_pb_fiee_cast_proto_depIdxs = []int32{
 	0,  // 0: Cast.MediaUserListReq.platformID:type_name -> Cast.PlatformIDENUM
@ -3834,62 +4007,65 @@ var file_pb_fiee_cast_proto_depIdxs = []int32{
 	14, // 12: Cast.UpdateWorkVideoReq.publishConfig2:type_name -> Cast.PublishConfig
 	14, // 13: Cast.UpdateWorkVideoReq.publishConfig3:type_name -> Cast.PublishConfig
 	3,  // 14: Cast.UpdateWorkVideoReq.autoPublish:type_name -> Cast.AutoPublishENUM
-	42, // 15: Cast.WorkListResp.data:type_name -> Cast.WorkListResp.Info
+	44, // 15: Cast.WorkListResp.data:type_name -> Cast.WorkListResp.Info
 	14, // 16: Cast.WorkDetailResp.publishConfig1:type_name -> Cast.PublishConfig
 	14, // 17: Cast.WorkDetailResp.publishConfig2:type_name -> Cast.PublishConfig
 	14, // 18: Cast.WorkDetailResp.publishConfig3:type_name -> Cast.PublishConfig
 	20, // 19: Cast.WorkDetailResp.WorkLogData:type_name -> Cast.WorkLogInfo
-	43, // 20: Cast.WorkDetailResp.mediaAccData:type_name -> Cast.WorkDetailResp.MediaAccDataEntry
+	45, // 20: Cast.WorkDetailResp.mediaAccData:type_name -> Cast.WorkDetailResp.MediaAccDataEntry
 	2,  // 21: Cast.UpdateStatusReq.workAction:type_name -> Cast.WorkActionENUM
 	3,  // 22: Cast.UpdateStatusReq.autoPublish:type_name -> Cast.AutoPublishENUM
-	44, // 23: Cast.MediaAccountsResp.data:type_name -> Cast.MediaAccountsResp.Info
-	45, // 24: Cast.MediaWorksResp.data:type_name -> Cast.MediaWorksResp.Info
-	0,  // 25: Cast.OAuthCodeToTokenReq.platformID:type_name -> Cast.PlatformIDENUM
-	0,  // 26: Cast.RefreshTokenReq.platformID:type_name -> Cast.PlatformIDENUM
-	5,  // 27: Cast.WorkDetailResp.MediaAccDataEntry.value:type_name -> Cast.MediaUserInfo
-	4,  // 28: Cast.Cast.MediaUserList:input_type -> Cast.MediaUserListReq
-	7,  // 29: Cast.Cast.UpdateMediaAccount:input_type -> Cast.UpdateMediaAccountReq
-	9,  // 30: Cast.Cast.UnbindManager:input_type -> Cast.UnbindManagerReq
-	11, // 31: Cast.Cast.BindManager:input_type -> Cast.BindManagerReq
-	12, // 32: Cast.Cast.UpdateWorkImage:input_type -> Cast.UpdateWorkImageReq
-	15, // 33: Cast.Cast.UpdateWorkVideo:input_type -> Cast.UpdateWorkVideoReq
-	17, // 34: Cast.Cast.WorkList:input_type -> Cast.WorkListReq
-	19, // 35: Cast.Cast.WorkDetail:input_type -> Cast.WorkDetailReq
-	22, // 36: Cast.Cast.UpdateStatus:input_type -> Cast.UpdateStatusReq
-	23, // 37: Cast.Cast.MediaAccounts:input_type -> Cast.MediaAccountsReq
-	25, // 38: Cast.Cast.MediaWorks:input_type -> Cast.MediaWorksReq
-	27, // 39: Cast.Cast.RePublish:input_type -> Cast.RePublishReq
-	29, // 40: Cast.Cast.DelWork:input_type -> Cast.DelWorkReq
-	30, // 41: Cast.Cast.WorkInfo:input_type -> Cast.WorkInfoReq
-	32, // 42: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq
-	36, // 43: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq
-	38, // 44: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq
-	40, // 45: Cast.Cast.PublishMediaInfo:input_type -> Cast.PublishMediaInfoReq
-	46, // 46: Cast.Cast.Test:input_type -> google.protobuf.Empty
-	6,  // 47: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp
-	8,  // 48: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp
-	10, // 49: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp
-	46, // 50: Cast.Cast.BindManager:output_type -> google.protobuf.Empty
-	13, // 51: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp
-	16, // 52: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp
-	18, // 53: Cast.Cast.WorkList:output_type -> Cast.WorkListResp
-	21, // 54: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp
-	46, // 55: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty
-	24, // 56: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp
-	26, // 57: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp
-	28, // 58: Cast.Cast.RePublish:output_type -> Cast.RePublishResp
-	46, // 59: Cast.Cast.DelWork:output_type -> google.protobuf.Empty
-	31, // 60: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp
-	33, // 61: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp
-	37, // 62: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp
-	39, // 63: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp
-	41, // 64: Cast.Cast.PublishMediaInfo:output_type -> Cast.PublishMediaInfoResp
-	46, // 65: Cast.Cast.Test:output_type -> google.protobuf.Empty
-	47, // [47:66] is the sub-list for method output_type
-	28, // [28:47] is the sub-list for method input_type
-	28, // [28:28] is the sub-list for extension type_name
-	28, // [28:28] is the sub-list for extension extendee
-	0,  // [0:28] is the sub-list for field type_name
+	46, // 23: Cast.MediaAccountsResp.data:type_name -> Cast.MediaAccountsResp.Info
+	47, // 24: Cast.MediaWorksResp.data:type_name -> Cast.MediaWorksResp.Info
+	48, // 25: Cast.PublishResp.data:type_name -> Cast.PublishResp.Info
+	0,  // 26: Cast.OAuthCodeToTokenReq.platformID:type_name -> Cast.PlatformIDENUM
+	0,  // 27: Cast.RefreshTokenReq.platformID:type_name -> Cast.PlatformIDENUM
+	5,  // 28: Cast.WorkDetailResp.MediaAccDataEntry.value:type_name -> Cast.MediaUserInfo
+	4,  // 29: Cast.Cast.MediaUserList:input_type -> Cast.MediaUserListReq
+	7,  // 30: Cast.Cast.UpdateMediaAccount:input_type -> Cast.UpdateMediaAccountReq
+	9,  // 31: Cast.Cast.UnbindManager:input_type -> Cast.UnbindManagerReq
+	11, // 32: Cast.Cast.BindManager:input_type -> Cast.BindManagerReq
+	12, // 33: Cast.Cast.UpdateWorkImage:input_type -> Cast.UpdateWorkImageReq
+	15, // 34: Cast.Cast.UpdateWorkVideo:input_type -> Cast.UpdateWorkVideoReq
+	17, // 35: Cast.Cast.WorkList:input_type -> Cast.WorkListReq
+	19, // 36: Cast.Cast.WorkDetail:input_type -> Cast.WorkDetailReq
+	22, // 37: Cast.Cast.UpdateStatus:input_type -> Cast.UpdateStatusReq
+	23, // 38: Cast.Cast.MediaAccounts:input_type -> Cast.MediaAccountsReq
+	25, // 39: Cast.Cast.MediaWorks:input_type -> Cast.MediaWorksReq
+	27, // 40: Cast.Cast.Publish:input_type -> Cast.PublishReq
+	29, // 41: Cast.Cast.RePublish:input_type -> Cast.RePublishReq
+	31, // 42: Cast.Cast.DelWork:input_type -> Cast.DelWorkReq
+	32, // 43: Cast.Cast.WorkInfo:input_type -> Cast.WorkInfoReq
+	34, // 44: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq
+	38, // 45: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq
+	40, // 46: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq
+	42, // 47: Cast.Cast.PublishMediaInfo:input_type -> Cast.PublishMediaInfoReq
+	49, // 48: Cast.Cast.Test:input_type -> google.protobuf.Empty
+	6,  // 49: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp
+	8,  // 50: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp
+	10, // 51: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp
+	49, // 52: Cast.Cast.BindManager:output_type -> google.protobuf.Empty
+	13, // 53: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp
+	16, // 54: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp
+	18, // 55: Cast.Cast.WorkList:output_type -> Cast.WorkListResp
+	21, // 56: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp
+	49, // 57: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty
+	24, // 58: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp
+	26, // 59: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp
+	28, // 60: Cast.Cast.Publish:output_type -> Cast.PublishResp
+	30, // 61: Cast.Cast.RePublish:output_type -> Cast.RePublishResp
+	49, // 62: Cast.Cast.DelWork:output_type -> google.protobuf.Empty
+	33, // 63: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp
+	35, // 64: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp
+	39, // 65: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp
+	41, // 66: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp
+	43, // 67: Cast.Cast.PublishMediaInfo:output_type -> Cast.PublishMediaInfoResp
+	49, // 68: Cast.Cast.Test:output_type -> google.protobuf.Empty
+	49, // [49:69] is the sub-list for method output_type
+	29, // [29:49] is the sub-list for method input_type
+	29, // [29:29] is the sub-list for extension type_name
+	29, // [29:29] is the sub-list for extension extendee
+	0,  // [0:29] is the sub-list for field type_name
 }

 func init() { file_pb_fiee_cast_proto_init() }
@ -3903,7 +4079,7 @@ func file_pb_fiee_cast_proto_init() {
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: unsafe.Slice(unsafe.StringData(file_pb_fiee_cast_proto_rawDesc), len(file_pb_fiee_cast_proto_rawDesc)),
 			NumEnums:      4,
-			NumMessages:   42,
+			NumMessages:   45,
 			NumExtensions: 0,
 			NumServices:   1,
 		},
--- a/api/cast/cast.pb.validate.go
+++ b/api/cast/cast.pb.validate.go
@ -1770,6 +1770,8 @@ func (m *WorkListReq) validate(all bool) error {

 	// no validation rules for PageSize

+	// no validation rules for CostType
+
 	if len(errors) > 0 {
 		return WorkListReqMultiError(errors)
 	}
@ -2520,6 +2522,8 @@ func (m *UpdateStatusReq) validate(all bool) error {

 	// no validation rules for AutoPublish

+	// no validation rules for CostType
+
 	if len(errors) > 0 {
 		return UpdateStatusReqMultiError(errors)
 	}
@ -3078,6 +3082,238 @@ var _ interface {
 	ErrorName() string
 } = MediaWorksRespValidationError{}

+// Validate checks the field values on PublishReq with the rules defined in the
+// proto definition for this message. If any rules are violated, the first
+// error encountered is returned, or nil if there are no violations.
+func (m *PublishReq) Validate() error {
+	return m.validate(false)
+}
+
+// ValidateAll checks the field values on PublishReq with the rules defined in
+// the proto definition for this message. If any rules are violated, the
+// result is a list of violation errors wrapped in PublishReqMultiError, or
+// nil if none found.
+func (m *PublishReq) ValidateAll() error {
+	return m.validate(true)
+}
+
+func (m *PublishReq) validate(all bool) error {
+	if m == nil {
+		return nil
+	}
+
+	var errors []error
+
+	if len(errors) > 0 {
+		return PublishReqMultiError(errors)
+	}
+
+	return nil
+}
+
+// PublishReqMultiError is an error wrapping multiple validation errors
+// returned by PublishReq.ValidateAll() if the designated constraints aren't met.
+type PublishReqMultiError []error
+
+// Error returns a concatenation of all the error messages it wraps.
+func (m PublishReqMultiError) Error() string {
+	msgs := make([]string, 0, len(m))
+	for _, err := range m {
+		msgs = append(msgs, err.Error())
+	}
+	return strings.Join(msgs, "; ")
+}
+
+// AllErrors returns a list of validation violation errors.
+func (m PublishReqMultiError) AllErrors() []error { return m }
+
+// PublishReqValidationError is the validation error returned by
+// PublishReq.Validate if the designated constraints aren't met.
+type PublishReqValidationError struct {
+	field  string
+	reason string
+	cause  error
+	key    bool
+}
+
+// Field function returns field value.
+func (e PublishReqValidationError) Field() string { return e.field }
+
+// Reason function returns reason value.
+func (e PublishReqValidationError) Reason() string { return e.reason }
+
+// Cause function returns cause value.
+func (e PublishReqValidationError) Cause() error { return e.cause }
+
+// Key function returns key value.
+func (e PublishReqValidationError) Key() bool { return e.key }
+
+// ErrorName returns error name.
+func (e PublishReqValidationError) ErrorName() string { return "PublishReqValidationError" }
+
+// Error satisfies the builtin error interface
+func (e PublishReqValidationError) Error() string {
+	cause := ""
+	if e.cause != nil {
+		cause = fmt.Sprintf(" | caused by: %v", e.cause)
+	}
+
+	key := ""
+	if e.key {
+		key = "key for "
+	}
+
+	return fmt.Sprintf(
+		"invalid %sPublishReq.%s: %s%s",
+		key,
+		e.field,
+		e.reason,
+		cause)
+}
+
+var _ error = PublishReqValidationError{}
+
+var _ interface {
+	Field() string
+	Reason() string
+	Key() bool
+	Cause() error
+	ErrorName() string
+} = PublishReqValidationError{}
+
+// Validate checks the field values on PublishResp with the rules defined in
+// the proto definition for this message. If any rules are violated, the first
+// error encountered is returned, or nil if there are no violations.
+func (m *PublishResp) Validate() error {
+	return m.validate(false)
+}
+
+// ValidateAll checks the field values on PublishResp with the rules defined in
+// the proto definition for this message. If any rules are violated, the
+// result is a list of violation errors wrapped in PublishRespMultiError, or
+// nil if none found.
+func (m *PublishResp) ValidateAll() error {
+	return m.validate(true)
+}
+
+func (m *PublishResp) validate(all bool) error {
+	if m == nil {
+		return nil
+	}
+
+	var errors []error
+
+	for idx, item := range m.GetData() {
+		_, _ = idx, item
+
+		if all {
+			switch v := interface{}(item).(type) {
+			case interface{ ValidateAll() error }:
+				if err := v.ValidateAll(); err != nil {
+					errors = append(errors, PublishRespValidationError{
+						field:  fmt.Sprintf("Data[%v]", idx),
+						reason: "embedded message failed validation",
+						cause:  err,
+					})
+				}
+			case interface{ Validate() error }:
+				if err := v.Validate(); err != nil {
+					errors = append(errors, PublishRespValidationError{
+						field:  fmt.Sprintf("Data[%v]", idx),
+						reason: "embedded message failed validation",
+						cause:  err,
+					})
+				}
+			}
+		} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
+			if err := v.Validate(); err != nil {
+				return PublishRespValidationError{
+					field:  fmt.Sprintf("Data[%v]", idx),
+					reason: "embedded message failed validation",
+					cause:  err,
+				}
+			}
+		}
+
+	}
+
+	if len(errors) > 0 {
+		return PublishRespMultiError(errors)
+	}
+
+	return nil
+}
+
+// PublishRespMultiError is an error wrapping multiple validation errors
+// returned by PublishResp.ValidateAll() if the designated constraints aren't met.
+type PublishRespMultiError []error
+
+// Error returns a concatenation of all the error messages it wraps.
+func (m PublishRespMultiError) Error() string {
+	msgs := make([]string, 0, len(m))
+	for _, err := range m {
+		msgs = append(msgs, err.Error())
+	}
+	return strings.Join(msgs, "; ")
+}
+
+// AllErrors returns a list of validation violation errors.
+func (m PublishRespMultiError) AllErrors() []error { return m }
+
+// PublishRespValidationError is the validation error returned by
+// PublishResp.Validate if the designated constraints aren't met.
+type PublishRespValidationError struct {
+	field  string
+	reason string
+	cause  error
+	key    bool
+}
+
+// Field function returns field value.
+func (e PublishRespValidationError) Field() string { return e.field }
+
+// Reason function returns reason value.
+func (e PublishRespValidationError) Reason() string { return e.reason }
+
+// Cause function returns cause value.
+func (e PublishRespValidationError) Cause() error { return e.cause }
+
+// Key function returns key value.
+func (e PublishRespValidationError) Key() bool { return e.key }
+
+// ErrorName returns error name.
+func (e PublishRespValidationError) ErrorName() string { return "PublishRespValidationError" }
+
+// Error satisfies the builtin error interface
+func (e PublishRespValidationError) Error() string {
+	cause := ""
+	if e.cause != nil {
+		cause = fmt.Sprintf(" | caused by: %v", e.cause)
+	}
+
+	key := ""
+	if e.key {
+		key = "key for "
+	}
+
+	return fmt.Sprintf(
+		"invalid %sPublishResp.%s: %s%s",
+		key,
+		e.field,
+		e.reason,
+		cause)
+}
+
+var _ error = PublishRespValidationError{}
+
+var _ interface {
+	Field() string
+	Reason() string
+	Key() bool
+	Cause() error
+	ErrorName() string
+} = PublishRespValidationError{}
+
 // Validate checks the field values on RePublishReq with the rules defined in
 // the proto definition for this message. If any rules are violated, the first
 // error encountered is returned, or nil if there are no violations.
@ -5007,3 +5243,107 @@ var _ interface {
 	Cause() error
 	ErrorName() string
 } = MediaWorksResp_InfoValidationError{}
+
+// Validate checks the field values on PublishResp_Info with the rules defined
+// in the proto definition for this message. If any rules are violated, the
+// first error encountered is returned, or nil if there are no violations.
+func (m *PublishResp_Info) Validate() error {
+	return m.validate(false)
+}
+
+// ValidateAll checks the field values on PublishResp_Info with the rules
+// defined in the proto definition for this message. If any rules are
+// violated, the result is a list of violation errors wrapped in
+// PublishResp_InfoMultiError, or nil if none found.
+func (m *PublishResp_Info) ValidateAll() error {
+	return m.validate(true)
+}
+
+func (m *PublishResp_Info) validate(all bool) error {
+	if m == nil {
+		return nil
+	}
+
+	var errors []error
+
+	// no validation rules for ArtistUuid
+
+	// no validation rules for WorkCategory
+
+	if len(errors) > 0 {
+		return PublishResp_InfoMultiError(errors)
+	}
+
+	return nil
+}
+
+// PublishResp_InfoMultiError is an error wrapping multiple validation errors
+// returned by PublishResp_Info.ValidateAll() if the designated constraints
+// aren't met.
+type PublishResp_InfoMultiError []error
+
+// Error returns a concatenation of all the error messages it wraps.
+func (m PublishResp_InfoMultiError) Error() string {
+	msgs := make([]string, 0, len(m))
+	for _, err := range m {
+		msgs = append(msgs, err.Error())
+	}
+	return strings.Join(msgs, "; ")
+}
+
+// AllErrors returns a list of validation violation errors.
+func (m PublishResp_InfoMultiError) AllErrors() []error { return m }
+
+// PublishResp_InfoValidationError is the validation error returned by
+// PublishResp_Info.Validate if the designated constraints aren't met.
+type PublishResp_InfoValidationError struct {
+	field  string
+	reason string
+	cause  error
+	key    bool
+}
+
+// Field function returns field value.
+func (e PublishResp_InfoValidationError) Field() string { return e.field }
+
+// Reason function returns reason value.
+func (e PublishResp_InfoValidationError) Reason() string { return e.reason }
+
+// Cause function returns cause value.
+func (e PublishResp_InfoValidationError) Cause() error { return e.cause }
+
+// Key function returns key value.
+func (e PublishResp_InfoValidationError) Key() bool { return e.key }
+
+// ErrorName returns error name.
+func (e PublishResp_InfoValidationError) ErrorName() string { return "PublishResp_InfoValidationError" }
+
+// Error satisfies the builtin error interface
+func (e PublishResp_InfoValidationError) Error() string {
+	cause := ""
+	if e.cause != nil {
+		cause = fmt.Sprintf(" | caused by: %v", e.cause)
+	}
+
+	key := ""
+	if e.key {
+		key = "key for "
+	}
+
+	return fmt.Sprintf(
+		"invalid %sPublishResp_Info.%s: %s%s",
+		key,
+		e.field,
+		e.reason,
+		cause)
+}
+
+var _ error = PublishResp_InfoValidationError{}
+
+var _ interface {
+	Field() string
+	Reason() string
+	Key() bool
+	Cause() error
+	ErrorName() string
+} = PublishResp_InfoValidationError{}
--- a/api/cast/cast_triple.pb.go
+++ b/api/cast/cast_triple.pb.go
@ -40,6 +40,7 @@ type CastClient interface {
 	UpdateStatus(ctx context.Context, in *UpdateStatusReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment)
 	MediaAccounts(ctx context.Context, in *MediaAccountsReq, opts ...grpc_go.CallOption) (*MediaAccountsResp, common.ErrorWithAttachment)
 	MediaWorks(ctx context.Context, in *MediaWorksReq, opts ...grpc_go.CallOption) (*MediaWorksResp, common.ErrorWithAttachment)
+	Publish(ctx context.Context, in *PublishReq, opts ...grpc_go.CallOption) (*PublishResp, common.ErrorWithAttachment)
 	RePublish(ctx context.Context, in *RePublishReq, opts ...grpc_go.CallOption) (*RePublishResp, common.ErrorWithAttachment)
 	DelWork(ctx context.Context, in *DelWorkReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment)
 	WorkInfo(ctx context.Context, in *WorkInfoReq, opts ...grpc_go.CallOption) (*WorkInfoResp, common.ErrorWithAttachment)
@ -66,6 +67,7 @@ type CastClientImpl struct {
 	UpdateStatus       func(ctx context.Context, in *UpdateStatusReq) (*emptypb.Empty, error)
 	MediaAccounts      func(ctx context.Context, in *MediaAccountsReq) (*MediaAccountsResp, error)
 	MediaWorks         func(ctx context.Context, in *MediaWorksReq) (*MediaWorksResp, error)
+	Publish            func(ctx context.Context, in *PublishReq) (*PublishResp, error)
 	RePublish          func(ctx context.Context, in *RePublishReq) (*RePublishResp, error)
 	DelWork            func(ctx context.Context, in *DelWorkReq) (*emptypb.Empty, error)
 	WorkInfo           func(ctx context.Context, in *WorkInfoReq) (*WorkInfoResp, error)
@ -154,6 +156,12 @@ func (c *castClient) MediaWorks(ctx context.Context, in *MediaWorksReq, opts ...
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/MediaWorks", in, out)
 }

+func (c *castClient) Publish(ctx context.Context, in *PublishReq, opts ...grpc_go.CallOption) (*PublishResp, common.ErrorWithAttachment) {
+	out := new(PublishResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/Publish", in, out)
+}
+
 func (c *castClient) RePublish(ctx context.Context, in *RePublishReq, opts ...grpc_go.CallOption) (*RePublishResp, common.ErrorWithAttachment) {
 	out := new(RePublishResp)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -217,6 +225,7 @@ type CastServer interface {
 	UpdateStatus(context.Context, *UpdateStatusReq) (*emptypb.Empty, error)
 	MediaAccounts(context.Context, *MediaAccountsReq) (*MediaAccountsResp, error)
 	MediaWorks(context.Context, *MediaWorksReq) (*MediaWorksResp, error)
+	Publish(context.Context, *PublishReq) (*PublishResp, error)
 	RePublish(context.Context, *RePublishReq) (*RePublishResp, error)
 	DelWork(context.Context, *DelWorkReq) (*emptypb.Empty, error)
 	WorkInfo(context.Context, *WorkInfoReq) (*WorkInfoResp, error)
@ -266,6 +275,9 @@ func (UnimplementedCastServer) MediaAccounts(context.Context, *MediaAccountsReq)
 func (UnimplementedCastServer) MediaWorks(context.Context, *MediaWorksReq) (*MediaWorksResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method MediaWorks not implemented")
 }
+func (UnimplementedCastServer) Publish(context.Context, *PublishReq) (*PublishResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method Publish not implemented")
+}
 func (UnimplementedCastServer) RePublish(context.Context, *RePublishReq) (*RePublishResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method RePublish not implemented")
 }
@ -637,6 +649,35 @@ func _Cast_MediaWorks_Handler(srv interface{}, ctx context.Context, dec func(int
 	return interceptor(ctx, in, info, handler)
 }

+func _Cast_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(PublishReq)
+	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("Publish", 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_RePublish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
 	in := new(RePublishReq)
 	if err := dec(in); err != nil {
@ -920,6 +961,10 @@ var Cast_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "MediaWorks",
 			Handler:    _Cast_MediaWorks_Handler,
 		},
+		{
+			MethodName: "Publish",
+			Handler:    _Cast_Publish_Handler,
+		},
 		{
 			MethodName: "RePublish",
 			Handler:    _Cast_RePublish_Handler,
--- a/go.mod
+++ b/go.mod
@ -112,6 +112,7 @@ require (
 	github.com/mholt/archiver v3.1.1+incompatible
 	github.com/natefinch/lumberjack v2.0.0+incompatible
 	github.com/rwcarlsen/goexif v0.0.0-20190401172101-9e8deecbddbd
+	github.com/samber/lo v1.52.0
 	github.com/signintech/gopdf v0.29.2
 	github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e
 	github.com/spf13/viper v1.7.1
--- a/go.sum
+++ b/go.sum
@ -779,6 +779,8 @@ github.com/rwcarlsen/goexif v0.0.0-20190401172101-9e8deecbddbd/go.mod h1:hPqNNc0
 github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
 github.com/ryanuber/columnize v2.1.0+incompatible/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
 github.com/ryanuber/go-glob v1.0.0/go.mod h1:807d1WSdnB0XRJzKNil9Om6lcp/3a0v4qIHxIXzX/Yc=
+github.com/samber/lo v1.52.0 h1:Rvi+3BFHES3A8meP33VPAxiBZX/Aws5RxrschYGjomw=
+github.com/samber/lo v1.52.0/go.mod h1:4+MXEGsJzbKGaUEQFKBq2xtfuznW9oz/WrgyzMzRoM0=
 github.com/samuel/go-zookeeper v0.0.0-20190923202752-2cc03de413da/go.mod h1:gi+0XIa01GRL2eRQVjQkKGqKF3SF9vZR/HnPullcV2E=
 github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b h1:gQZ0qzfKHQIybLANtM3mBXNUtOfsCFXeTsnBqCsx1KM=
 github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0=
--- a/pkg/model/bundle/bundle.go
+++ b/pkg/model/bundle/bundle.go
@ -3,5 +3,30 @@ package bundle
 type UserWorkConfirmReq struct {
 	WorkUuid      string `json:"workUuid"`
 	ConfirmRemark string `json:"confirmRemark"`
-	ConfirmStatus int `json:"confirmStatus"` // 1确认 2 驳回
+	ConfirmStatus int    `json:"confirmStatus"` // 1确认 2 驳回
+}
+
+type GetBundleBalanceListResp struct {
+
+	Total int64                `protobuf:"varint,1,opt,name=total,proto3" json:"total"`
+	Data  []*BundleBalanceItem `protobuf:"bytes,2,rep,name=data,proto3" json:"data"`
+}
+
+type BundleBalanceItem struct {
+	UserId                        int32  `protobuf:"varint,1,opt,name=userId,proto3" json:"userId"`
+	UserName                      string `protobuf:"bytes,2,opt,name=userName,proto3" json:"userName"`
+	UserPhoneNumber               string `protobuf:"bytes,3,opt,name=userPhoneNumber,proto3" json:"userPhoneNumber"`
+	Status                        int32  `protobuf:"varint,4,opt,name=status,proto3" json:"status"`
+	BundleName                    string `protobuf:"bytes,5,opt,name=bundleName,proto3" json:"bundleName"`
+	ExpiredTime                   int64  `protobuf:"varint,6,opt,name=expiredTime,proto3" json:"expiredTime"`
+	AccountNumber                 int32  `protobuf:"varint,7,opt,name=accountNumber,proto3" json:"accountNumber"`
+	AccountConsumptionNumber      int32  `protobuf:"varint,8,opt,name=accountConsumptionNumber,proto3" json:"accountConsumptionNumber"`
+	VideoNumber                   int32  `protobuf:"varint,9,opt,name=videoNumber,proto3" json:"videoNumber"`
+	VideoConsumptionNumber        int32  `protobuf:"varint,10,opt,name=videoConsumptionNumber,proto3" json:"videoConsumptionNumber"`
+	ImageNumber                   int32  `protobuf:"varint,11,opt,name=imageNumber,proto3" json:"imageNumber"`
+	ImageConsumptionNumber        int32  `protobuf:"varint,12,opt,name=imageConsumptionNumber,proto3" json:"imageConsumptionNumber"`
+	DataAnalysisNumber            int32  `protobuf:"varint,13,opt,name=dataAnalysisNumber,proto3" json:"dataAnalysisNumber"`
+	DataAnalysisConsumptionNumber int32  `protobuf:"varint,14,opt,name=dataAnalysisConsumptionNumber,proto3" json:"dataAnalysisConsumptionNumber"`
+	ExpansionPacksNumber          int32  `protobuf:"varint,15,opt,name=expansionPacksNumber,proto3" json:"expansionPacksNumber"`
+	Bought                        int32  `protobuf:"varint,16,opt,name=bought,proto3" json:"bought"`
 }
--- a/pkg/router/bundle.go
+++ b/pkg/router/bundle.go
@ -32,7 +32,12 @@ func BundleRouter(r *gin.RouterGroup) {
 			bundleBalance := bundleClientRoute.Group("balance")
 			{
 				bundleBalance.POST("list", bundle.GetBundleBalance)
+				bundleBalance.POST("account/list", bundle.GetAccountBundleBalance)
 				bundleBalance.POST("used-record", bundle.GetUsedRecordList)
+				bundleBalance.POST("activate", bundle.BundleActivate)
+				bundleBalance.POST("export", bundle.BundleExport)
+				bundleBalance.POST("layout-update", bundle.SetBalanceLayout)
+				bundleBalance.POST("layout", bundle.GetBalanceLayout)
 			}
 		}
 		bundleClientRouteV2 := bundleRoute.Group("system/v2")
--- a/pkg/router/router.go
+++ b/pkg/router/router.go
@ -197,7 +197,7 @@ func NewRouter() *gin.Engine {
 		importRoute.POST("data/confirm", imports.WorkConfirm)
 	}
 	//静态文件
-	r.StaticFS("/api/static", http.Dir("./runtime"))
+	r.StaticFS("/api/fiee/static", http.Dir("./runtime"))
 	r.NoRoute(func(c *gin.Context) {
 		c.JSON(http.StatusNotFound, gin.H{
 			"status": 1,
--- a/pkg/service/bundle/bundleBalance.go
+++ b/pkg/service/bundle/bundleBalance.go
@ -2,16 +2,24 @@ package bundle

 import (
 	"context"
+	"encoding/json"
 	"errors"
+	"fmt"
 	"fonchain-fiee/api/bundle"
 	"fonchain-fiee/api/cast"
 	"fonchain-fiee/pkg/service"
+	"fonchain-fiee/pkg/utils"
+	"io"
 	"strconv"
+	"strings"
+	"time"

 	bundleModel "fonchain-fiee/pkg/model/bundle"
 	"fonchain-fiee/pkg/model/login"

 	"github.com/gin-gonic/gin"
+	"github.com/samber/lo"
+	"github.com/xuri/excelize/v2"
 )

 func BundleExtend(c *gin.Context) {
@ -217,7 +225,7 @@ func WorkConfirm(c *gin.Context) { // 确认作品并扣除余量
 		service.Error(c, errors.New("不支持的类型"))
 		return
 	}
-	_, err = service.BundleProvider.AddBundleBalance(c, &addBalanceReq)
+	resp, err := service.BundleProvider.AddBundleBalance(c, &addBalanceReq)
 	if err != nil {
 		service.Error(c, err)
 		return
@ -226,6 +234,7 @@ func WorkConfirm(c *gin.Context) { // 确认作品并扣除余量
 		WorkAction:    cast.WorkActionENUM_CONFIRM,
 		WorkUuid:      req.WorkUuid,
 		ConfirmRemark: req.ConfirmRemark,
+		CostType:      resp.UsedType,
 		ConfirmStatus: 1,
 	})
 	if err != nil {
@ -248,3 +257,227 @@ func CastLogConfirm(ctx *gin.Context) {
 	}
 	service.Success(ctx, res)
 }
+
+func BundleActivate(ctx *gin.Context) {
+	var req bundle.BundleActivateReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	res, err := service.BundleProvider.BundleActivate(context.Background(), &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, res)
+}
+
+func BundleExport(ctx *gin.Context) {
+	var req bundle.BundleBalanceExportReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+
+	userInfo := login.GetUserInfoFromC(ctx)
+	exportFileName := fmt.Sprintf("%d月份余量信息.xlsx", time.Now().Month())
+	filePath := fmt.Sprintf("./runtime/%d/%s", userInfo.ID, exportFileName)
+	utils.CheckDirPath("./runtime/"+fmt.Sprint(userInfo.ID), true)
+	res, err := service.BundleProvider.BundleBalanceExport(context.Background(), &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	if err := writeToExcel(filePath, res.Data); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	var scheme string
+	if ctx.GetHeader("X-Forwarded-Proto") == "https" {
+		scheme = "https"
+	} else {
+		scheme = "http"
+	}
+
+	var exportUrl string = fmt.Sprintf("%s://%s/api/fiee/static/%s", scheme, ctx.Request.Host, strings.Replace(filePath, "./runtime/", "", 1))
+	service.Success(ctx, gin.H{
+		"url": exportUrl,
+	})
+}
+
+func SetBalanceLayout(ctx *gin.Context) {
+	b, _ := io.ReadAll(ctx.Request.Body)
+	userInfo := login.GetUserInfoFromC(ctx)
+	var req = bundle.SetBundleBalanceLayoutReq{
+		Data:   string(b),
+		UserId: uint32(userInfo.ID),
+	}
+	res, err := service.BundleProvider.SetBundleBalanceLayout(context.Background(), &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, res)
+}
+func GetBalanceLayout(ctx *gin.Context) {
+	userInfo := login.GetUserInfoFromC(ctx)
+	var req = bundle.GetBundleBalanceLayoutReq{
+		UserId: uint32(userInfo.ID),
+	}
+	res, err := service.BundleProvider.GetBundleBalanceLayout(context.Background(), &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	var j any
+	json.Unmarshal([]byte(res.Data), &j)
+	service.Success(ctx, j)
+}
+
+func writeToExcel(filename string, items []*bundle.BundleBalanceExportItem) error {
+	f := excelize.NewFile()
+	sheet := "Sheet1"
+
+	// 手动表头（顺序与写入字段顺序必须一致）
+	headers := []string{
+		"所属月份", "用户编号", "名字", "手机号", "支付时间",
+		"套餐金额", "增值服务金额", "支付金额", "币种", "手续费", "套餐视频单价", "增值视频单价",
+		"套餐账号总数", "增值账号总数", "套餐账号使用数", "增值账号使用数",
+		"当前可用套餐视频数", "当前可用增值视频数", "当前已用套餐视频数", "当前已用增值视频数", "当前作废套餐视频数", "当前作废增值视频数", "当月新增套餐视频数", "当月新增增值视频数", "当月作废套餐视频数", "当月作废增值视频数",
+		"当前可用套餐图文数", "当前可用增值图文数", "当前已用套餐图文数", "当前已用增值图文数", "当前作废套餐图文数", "当前作废增值图文数", "当月新增套餐图文数", "当月新增增值图文数", "当月作废套餐图文数", "当月作废增值图文数",
+		"当前可用套餐数据分析数", "当前可用增值数据分析数", "当前已用套餐数据分析数", "当前已用增值数据分析数", "当前作废套餐数据分析数", "当前作废增值数据分析数", "当月新增套餐数据分析数", "当月新增增值数据分析数", "当月作废套餐数据分析数", "当月作废增值数据分析数",
+		"当月手动扩展账号新增数", "当月手动扩展视频新增数", "当月手动扩展图文新增数", "当月手动扩展数据分析新增数", "当月新增手动扩展时长（天）", "当月手动扩展账号使用数", "当月手动扩展视频使用数", "当月手动扩展图文使用数", "当月手动扩展数据分析使用数",
+	}
+
+	// 写表头
+	for i, h := range headers {
+		col, _ := excelize.ColumnNumberToName(i + 1)
+		cell := col + "1"
+		if err := f.SetCellValue(sheet, cell, h); err != nil {
+			return err
+		}
+	}
+
+	// 从第2行开始写数据
+	for r, it := range items {
+		row := r + 2
+		// 逐列写入（注意顺序必须和 headers 一致）
+		write := func(colIdx int, v interface{}) error {
+			col, _ := excelize.ColumnNumberToName(colIdx)
+			cell := fmt.Sprintf("%s%d", col, row)
+			return f.SetCellValue(sheet, cell, v)
+		}
+
+		// 基本信息
+		_ = write(1, it.Month)
+		_ = write(2, it.CustomerNum)
+		_ = write(3, it.UserName)
+		_ = write(4, it.UserPhoneNumber)
+		_ = write(5, it.PayTime)
+		_ = write(6, float64(it.BundleAmount))
+		_ = write(7, float64(it.IncreaseAmount))
+		_ = write(8, float64(it.TotalPayAmount))
+		_ = write(9, it.Currency)
+		_ = write(10, it.Fee)
+		_ = write(11, float64(it.BundleVideoUnitPrice))
+		_ = write(12, float64(it.IncreaseVideoUnitPrice))
+
+		// 账号类
+		_ = write(13, int(it.BundleAccountNumber))
+		_ = write(14, int(it.IncreaseAccountNumber))
+		_ = write(15, int(it.BundleAccountConsumptionNumber))
+		_ = write(16, int(it.IncreaseAccountConsumptionNumber))
+
+		// 视频类
+		_ = write(17, int(it.BundleVideoNumber))
+		_ = write(18, int(it.IncreaseVideoNumber))
+		_ = write(19, int(it.BundleVideoConsumptionNumber))
+		_ = write(20, int(it.IncreaseVideoConsumptionNumber))
+		_ = write(21, int(it.InvalidBundleVideoNumber))
+		_ = write(22, int(it.InvalidIncreaseVideoNumber))
+		_ = write(23, int(it.MonthlyNewBundleVideoNumber))
+		_ = write(24, int(it.MonthlyNewIncreaseVideoNumber))
+		_ = write(25, int(it.MonthlyInvalidBundleVideoNumber))
+		_ = write(26, int(it.MonthlyInvalidIncreaseVideoNumber))
+
+		// 图文类
+		_ = write(27, int(it.BundleImageNumber))
+		_ = write(28, int(it.IncreaseImageNumber))
+		_ = write(29, int(it.BundleImageConsumptionNumber))
+		_ = write(30, int(it.IncreaseImageConsumptionNumber))
+		_ = write(31, int(it.InvalidBundleImageNumber))
+		_ = write(32, int(it.InvalidIncreaseImageNumber))
+		_ = write(33, int(it.MonthlyNewBundleImageNumber))
+		_ = write(34, int(it.MonthlyNewIncreaseImageNumber))
+		_ = write(35, int(it.MonthlyInvalidBundleImageNumber))
+		_ = write(36, int(it.MonthlyInvalidIncreaseImageNumber))
+
+		// 数据分析类
+		_ = write(37, int(it.BundleDataAnalysisNumber))
+		_ = write(38, int(it.IncreaseDataAnalysisNumber))
+		_ = write(39, int(it.BundleDataAnalysisConsumptionNumber))
+		_ = write(40, int(it.IncreaseDataAnalysisConsumptionNumber))
+		_ = write(41, int(it.InvalidBundleDataAnalysisNumber))
+		_ = write(42, int(it.InvalidIncreaseDataAnalysisNumber))
+		_ = write(43, int(it.MonthlyNewBundleDataAnalysisNumber))
+		_ = write(44, int(it.MonthlyNewIncreaseDataAnalysisNumber))
+		_ = write(45, int(it.MonthlyInvalidBundleDataAnalysisNumber))
+		_ = write(46, int(it.MonthlyInvalidIncreaseDataAnalysisNumber))
+
+		// 手动扩展类
+		_ = write(47, int(it.MonthlyNewManualAccountNumber))
+		_ = write(48, int(it.MonthlyNewManualVideoNumber))
+		_ = write(49, int(it.MonthlyNewManualImageNumber))
+		_ = write(50, int(it.MonthlyNewManualDataAnalysisNumber))
+		_ = write(51, int(it.MonthlyNewDurationNumber))
+		_ = write(52, int(it.MonthlyManualAccountConsumptionNumber))
+		_ = write(53, int(it.MonthlyManualVideoConsumptionNumber))
+		_ = write(54, int(it.MonthlyManualImageConsumptionNumber))
+		_ = write(55, int(it.MonthlyManualDataAnalysisConsumptionNumber))
+	}
+
+	// 可选：设置列宽，使表格更美观
+	_ = f.SetColWidth(sheet, "A", "AZ", 15)
+
+	// 保存文件
+	if err := f.SaveAs(filename); err != nil {
+		return err
+	}
+	return nil
+}
+
+func GetAccountBundleBalance(c *gin.Context) {
+	var req bundle.GetBundleBalanceListReq
+	if err := c.ShouldBindJSON(&req); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.BundleProvider.GetBundleBalanceList(context.Background(), &req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	result := bundleModel.GetBundleBalanceListResp{
+		Total: res.Total,
+	}
+	result.Data = lo.Map(res.Data, func(item *bundle.BundleBalanceItem, index int) *bundleModel.BundleBalanceItem {
+		return &bundleModel.BundleBalanceItem{
+			UserId:                        item.UserId,
+			UserName:                      item.UserName,
+			UserPhoneNumber:               item.UserPhoneNumber,
+			Status:                        item.Status,
+			BundleName:                    item.BundleName,
+			ExpiredTime:                   item.ExpiredTime,
+			AccountNumber:                 item.BundleAccountNumber + item.IncreaseAccountNumber + item.ManualAccountNumber,
+			AccountConsumptionNumber:      item.BundleAccountConsumptionNumber + item.IncreaseAccountConsumptionNumber + item.ManualAccountConsumptionNumber,
+			VideoNumber:                   item.BundleVideoNumber + item.IncreaseVideoNumber + item.ManualVideoNumber,
+			VideoConsumptionNumber:        item.BundleVideoConsumptionNumber + item.IncreaseVideoConsumptionNumber + item.ManualVideoConsumptionNumber,
+			ImageNumber:                   item.BundleImageNumber + item.IncreaseImageNumber + item.ManualImageNumber,
+			ImageConsumptionNumber:        item.BundleImageConsumptionNumber + item.IncreaseImageConsumptionNumber + item.ManualImageNumber,
+			DataAnalysisNumber:            item.BundleDataAnalysisNumber + item.IncreaseDataAnalysisNumber + item.ManualDataAnalysisNumber,
+			DataAnalysisConsumptionNumber: item.BundleDataAnalysisConsumptionNumber + item.IncreaseDataAnalysisConsumptionNumber + item.ManualDataAnalysisNumber,
+			Bought:                        item.Bought,
+		}
+	})
+	service.Success(c, result)
+}
Author	SHA1	Message	Date
lzh	88fd3e80b3	1	2025-10-21 15:49:17 +08:00
lzh	746fc21f99	记录余量使用类型	2025-10-21 14:59:36 +08:00
lzh	97fd36711a	删除omitempty	2025-10-20 17:11:13 +08:00
lzh	9c693a694e	1	2025-10-20 17:01:29 +08:00
lzh	2d23c9d654	添加艺人账号余量查询	2025-10-20 17:01:08 +08:00
lzh	88d1a021cb	修改导出链接拼接	2025-10-20 14:34:09 +08:00
lzh	ad089ca1aa	修改字段类型	2025-10-17 16:00:42 +08:00
lzh	03058ac4e4	1	2025-10-17 15:41:00 +08:00
lzh	bce901e2a4	1	2025-10-17 15:32:57 +08:00
lzh	e56cddb325	1	2025-10-17 15:32:55 +08:00
lzh	3711c5402a	1	2025-10-17 15:16:48 +08:00
lzh	fecc9faff0	1	2025-10-17 15:01:10 +08:00
lzh	ec49f60138	导出接口修订	2025-10-17 14:50:34 +08:00
lzh	226b170dce	1	2025-10-17 10:33:42 +08:00
lzh	127da23d69	布局接口	2025-10-17 10:23:28 +08:00
lzh	84f4637f09	1	2025-10-16 16:59:33 +08:00
lzh	8116303f05	excel导出	2025-10-16 16:37:06 +08:00
lzh	a989dae45a	添加激活接口	2025-10-16 09:18:17 +08:00
lzh	0d880d2999	proto更新	2025-10-15 15:58:26 +08:00