Merge branch 'dev-lzh-1009'

新增使用类型字段
Merge branch 'feature-costType-daiyb'
2025-10-10 10:35:31 +08:00 · 2025-10-10 10:29:46 +08:00 · 2025-10-10 09:18:42 +08:00 · 2025-10-10 09:11:30 +08:00 · 2025-10-10 08:54:15 +08:00 · 2025-10-09 17:11:33 +08:00
26 changed files with 5136 additions and 6115 deletions
--- a/README.md
+++ b/README.md
@ -0,0 +1,13 @@
+## 测试服后台
+    http://172.16.100.99:9028/
+    13580848136
+
+https://erp.fiee.com/older_list
+13580848136
+Aa.123456
+
+测试h5
+## https://saas-test.szjixun.cn
+
+正式h5
+https://saas.fiee.com
--- 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
@ -7,8 +7,8 @@ import (
 	fmt "fmt"
 	math "math"
 	proto "github.com/golang/protobuf/proto"
-	_ "github.com/mwitkow/go-proto-validators"
 	_ "google.golang.org/protobuf/types/descriptorpb"
+	_ "github.com/mwitkow/go-proto-validators"
 	github_com_mwitkow_go_proto_validators "github.com/mwitkow/go-proto-validators"
 )

@ -95,13 +95,6 @@ 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 {
@ -112,16 +105,6 @@ 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 {
@ -130,9 +113,6 @@ 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
 }
@ -486,78 +466,3 @@ func (this *UnfinishedInfo) Validate() error {
 func (this *SoftDeleteUnfinishedInfoRequest) 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 *BundleActivateReq) Validate() error {
-	return nil
-}
-func (this *BundleActivateResp) Validate() error {
-	return nil
-}
--- a/api/bundle/bundle_triple.pb.go
+++ b/api/bundle/bundle_triple.pb.go
@ -69,7 +69,6 @@ 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)
 	// 使用记录
 	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)
@ -84,16 +83,6 @@ 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 {
@ -139,7 +128,6 @@ 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)
 	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)
@ -151,15 +139,6 @@ 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 {
@ -402,12 +381,6 @@ 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) GetUsedRecordList(ctx context.Context, in *GetUsedRecordListReq, opts ...grpc_go.CallOption) (*GetUsedRecordListResp, common.ErrorWithAttachment) {
 	out := new(GetUsedRecordListResp)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@ -474,60 +447,6 @@ 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
@ -573,7 +492,6 @@ 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)
 	// 使用记录
 	GetUsedRecordList(context.Context, *GetUsedRecordListReq) (*GetUsedRecordListResp, error)
 	GetImageWorkDetail(context.Context, *GetImageWorkDetailReq) (*GetImageWorkDetailResp, error)
@ -588,16 +506,6 @@ 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()
 }

@ -720,9 +628,6 @@ 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) GetUsedRecordList(context.Context, *GetUsedRecordListReq) (*GetUsedRecordListResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetUsedRecordList not implemented")
 }
@ -756,33 +661,6 @@ 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
 }
@ -1913,35 +1791,6 @@ 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_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 {
@ -2261,267 +2110,6 @@ 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)
@ -2681,10 +2269,6 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "AddBundleBalance",
 			Handler:    _Bundle_AddBundleBalance_Handler,
 		},
-		{
-			MethodName: "BundleActivate",
-			Handler:    _Bundle_BundleActivate_Handler,
-		},
 		{
 			MethodName: "GetUsedRecordList",
 			Handler:    _Bundle_GetUsedRecordList_Handler,
@ -2729,42 +2313,6 @@ 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
--- a/api/cast/cast.pb.validate.go
+++ b/api/cast/cast.pb.validate.go
--- a/api/cast/cast_triple.pb.go
+++ b/api/cast/cast_triple.pb.go
@ -43,8 +43,11 @@ type CastClient interface {
 	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)
-	OAuthYoutubeUrl(ctx context.Context, in *OAuthYoutubeUrlReq, opts ...grpc_go.CallOption) (*OAuthYoutubeUrlResp, common.ErrorWithAttachment)
-	OAuthYoutubeToken(ctx context.Context, in *OAuthYoutubeTokenReq, opts ...grpc_go.CallOption) (*OAuthYoutubeTokenResp, common.ErrorWithAttachment)
+	OAuthAccount(ctx context.Context, in *OAuthAccountReq, opts ...grpc_go.CallOption) (*OAuthAccountResp, common.ErrorWithAttachment)
+	OAuthCodeToToken(ctx context.Context, in *OAuthCodeToTokenReq, opts ...grpc_go.CallOption) (*OAuthCodeToTokenResp, common.ErrorWithAttachment)
+	RefreshToken(ctx context.Context, in *RefreshTokenReq, opts ...grpc_go.CallOption) (*RefreshTokenResp, common.ErrorWithAttachment)
+	PublishMediaInfo(ctx context.Context, in *PublishMediaInfoReq, opts ...grpc_go.CallOption) (*PublishMediaInfoResp, common.ErrorWithAttachment)
+	Test(ctx context.Context, in *emptypb.Empty, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment)
 }

 type castClient struct {
@ -66,8 +69,11 @@ type CastClientImpl struct {
 	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)
-	OAuthYoutubeUrl    func(ctx context.Context, in *OAuthYoutubeUrlReq) (*OAuthYoutubeUrlResp, error)
-	OAuthYoutubeToken  func(ctx context.Context, in *OAuthYoutubeTokenReq) (*OAuthYoutubeTokenResp, error)
+	OAuthAccount       func(ctx context.Context, in *OAuthAccountReq) (*OAuthAccountResp, error)
+	OAuthCodeToToken   func(ctx context.Context, in *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error)
+	RefreshToken       func(ctx context.Context, in *RefreshTokenReq) (*RefreshTokenResp, error)
+	PublishMediaInfo   func(ctx context.Context, in *PublishMediaInfoReq) (*PublishMediaInfoResp, error)
+	Test               func(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
 }

 func (c *CastClientImpl) GetDubboStub(cc *triple.TripleConn) CastClient {
@ -166,16 +172,34 @@ func (c *castClient) WorkInfo(ctx context.Context, in *WorkInfoReq, opts ...grpc
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/WorkInfo", in, out)
 }

-func (c *castClient) OAuthYoutubeUrl(ctx context.Context, in *OAuthYoutubeUrlReq, opts ...grpc_go.CallOption) (*OAuthYoutubeUrlResp, common.ErrorWithAttachment) {
-	out := new(OAuthYoutubeUrlResp)
+func (c *castClient) OAuthAccount(ctx context.Context, in *OAuthAccountReq, opts ...grpc_go.CallOption) (*OAuthAccountResp, common.ErrorWithAttachment) {
+	out := new(OAuthAccountResp)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
-	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/OAuthYoutubeUrl", in, out)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/OAuthAccount", in, out)
 }

-func (c *castClient) OAuthYoutubeToken(ctx context.Context, in *OAuthYoutubeTokenReq, opts ...grpc_go.CallOption) (*OAuthYoutubeTokenResp, common.ErrorWithAttachment) {
-	out := new(OAuthYoutubeTokenResp)
+func (c *castClient) OAuthCodeToToken(ctx context.Context, in *OAuthCodeToTokenReq, opts ...grpc_go.CallOption) (*OAuthCodeToTokenResp, common.ErrorWithAttachment) {
+	out := new(OAuthCodeToTokenResp)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
-	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/OAuthYoutubeToken", in, out)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/OAuthCodeToToken", in, out)
+}
+
+func (c *castClient) RefreshToken(ctx context.Context, in *RefreshTokenReq, opts ...grpc_go.CallOption) (*RefreshTokenResp, common.ErrorWithAttachment) {
+	out := new(RefreshTokenResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/RefreshToken", in, out)
+}
+
+func (c *castClient) PublishMediaInfo(ctx context.Context, in *PublishMediaInfoReq, opts ...grpc_go.CallOption) (*PublishMediaInfoResp, common.ErrorWithAttachment) {
+	out := new(PublishMediaInfoResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/PublishMediaInfo", in, out)
+}
+
+func (c *castClient) Test(ctx context.Context, in *emptypb.Empty, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) {
+	out := new(emptypb.Empty)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/Test", in, out)
 }

 // CastServer is the server API for Cast service.
@ -196,8 +220,11 @@ type CastServer interface {
 	RePublish(context.Context, *RePublishReq) (*RePublishResp, error)
 	DelWork(context.Context, *DelWorkReq) (*emptypb.Empty, error)
 	WorkInfo(context.Context, *WorkInfoReq) (*WorkInfoResp, error)
-	OAuthYoutubeUrl(context.Context, *OAuthYoutubeUrlReq) (*OAuthYoutubeUrlResp, error)
-	OAuthYoutubeToken(context.Context, *OAuthYoutubeTokenReq) (*OAuthYoutubeTokenResp, error)
+	OAuthAccount(context.Context, *OAuthAccountReq) (*OAuthAccountResp, error)
+	OAuthCodeToToken(context.Context, *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error)
+	RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenResp, error)
+	PublishMediaInfo(context.Context, *PublishMediaInfoReq) (*PublishMediaInfoResp, error)
+	Test(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
 	mustEmbedUnimplementedCastServer()
 }

@ -248,11 +275,20 @@ func (UnimplementedCastServer) DelWork(context.Context, *DelWorkReq) (*emptypb.E
 func (UnimplementedCastServer) WorkInfo(context.Context, *WorkInfoReq) (*WorkInfoResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method WorkInfo not implemented")
 }
-func (UnimplementedCastServer) OAuthYoutubeUrl(context.Context, *OAuthYoutubeUrlReq) (*OAuthYoutubeUrlResp, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method OAuthYoutubeUrl not implemented")
+func (UnimplementedCastServer) OAuthAccount(context.Context, *OAuthAccountReq) (*OAuthAccountResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method OAuthAccount not implemented")
 }
-func (UnimplementedCastServer) OAuthYoutubeToken(context.Context, *OAuthYoutubeTokenReq) (*OAuthYoutubeTokenResp, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method OAuthYoutubeToken not implemented")
+func (UnimplementedCastServer) OAuthCodeToToken(context.Context, *OAuthCodeToTokenReq) (*OAuthCodeToTokenResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method OAuthCodeToToken not implemented")
+}
+func (UnimplementedCastServer) RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method RefreshToken not implemented")
+}
+func (UnimplementedCastServer) PublishMediaInfo(context.Context, *PublishMediaInfoReq) (*PublishMediaInfoResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method PublishMediaInfo not implemented")
+}
+func (UnimplementedCastServer) Test(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method Test not implemented")
 }
 func (s *UnimplementedCastServer) XXX_SetProxyImpl(impl protocol.Invoker) {
 	s.proxyImpl = impl
@ -688,8 +724,8 @@ func _Cast_WorkInfo_Handler(srv interface{}, ctx context.Context, dec func(inter
 	return interceptor(ctx, in, info, handler)
 }

-func _Cast_OAuthYoutubeUrl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
-	in := new(OAuthYoutubeUrlReq)
+func _Cast_OAuthAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(OAuthAccountReq)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
@ -701,7 +737,7 @@ func _Cast_OAuthYoutubeUrl_Handler(srv interface{}, ctx context.Context, dec fun
 	for k, v := range md {
 		invAttachment[k] = v
 	}
-	invo := invocation.NewRPCInvocation("OAuthYoutubeUrl", args, invAttachment)
+	invo := invocation.NewRPCInvocation("OAuthAccount", args, invAttachment)
 	if interceptor == nil {
 		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
 		return result, result.Error()
@ -717,8 +753,8 @@ func _Cast_OAuthYoutubeUrl_Handler(srv interface{}, ctx context.Context, dec fun
 	return interceptor(ctx, in, info, handler)
 }

-func _Cast_OAuthYoutubeToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
-	in := new(OAuthYoutubeTokenReq)
+func _Cast_OAuthCodeToToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(OAuthCodeToTokenReq)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
@ -730,7 +766,94 @@ func _Cast_OAuthYoutubeToken_Handler(srv interface{}, ctx context.Context, dec f
 	for k, v := range md {
 		invAttachment[k] = v
 	}
-	invo := invocation.NewRPCInvocation("OAuthYoutubeToken", args, invAttachment)
+	invo := invocation.NewRPCInvocation("OAuthCodeToToken", 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_RefreshToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(RefreshTokenReq)
+	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("RefreshToken", 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_PublishMediaInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(PublishMediaInfoReq)
+	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("PublishMediaInfo", 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_Test_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(emptypb.Empty)
+	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("Test", args, invAttachment)
 	if interceptor == nil {
 		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
 		return result, result.Error()
@ -810,12 +933,24 @@ var Cast_ServiceDesc = grpc_go.ServiceDesc{
 			Handler:    _Cast_WorkInfo_Handler,
 		},
 		{
-			MethodName: "OAuthYoutubeUrl",
-			Handler:    _Cast_OAuthYoutubeUrl_Handler,
+			MethodName: "OAuthAccount",
+			Handler:    _Cast_OAuthAccount_Handler,
 		},
 		{
-			MethodName: "OAuthYoutubeToken",
-			Handler:    _Cast_OAuthYoutubeToken_Handler,
+			MethodName: "OAuthCodeToToken",
+			Handler:    _Cast_OAuthCodeToToken_Handler,
+		},
+		{
+			MethodName: "RefreshToken",
+			Handler:    _Cast_RefreshToken_Handler,
+		},
+		{
+			MethodName: "PublishMediaInfo",
+			Handler:    _Cast_PublishMediaInfo_Handler,
+		},
+		{
+			MethodName: "Test",
+			Handler:    _Cast_Test_Handler,
 		},
 	},
 	Streams:  []grpc_go.StreamDesc{},
--- a/cmd/app.go
+++ b/cmd/app.go
@ -21,6 +21,7 @@ import (
 	"fmt"
 	"fonchain-fiee/cmd/config"
 	"fonchain-fiee/pkg/cache"
+	"fonchain-fiee/pkg/common"
 	"fonchain-fiee/pkg/logger"
 	"fonchain-fiee/pkg/router"
 )
@ -55,6 +56,7 @@ func bootstrap() (err error) {
 	}

 	cache.LoadRedis(redisConfig)
+	common.Init()
 	//
 	//gpt.InitSet(configEnv.Ai.Host, configEnv.Ai.TelNum, configEnv.Ai.Password)
 	return nil
--- a/cmd/config/config.go
+++ b/cmd/config/config.go
@ -4,10 +4,11 @@ import (
 	"errors"
 	"fmt"
 	"fonchain-fiee/pkg/common"
-	"github.com/BurntSushi/toml"
-	"gopkg.in/ini.v1"
 	"os"
 	"strconv"
+
+	"github.com/BurntSushi/toml"
+	"gopkg.in/ini.v1"
 )

 var (
@ -117,6 +118,7 @@ type System struct {
 	Domain          string
 	ErpHost         string
 	FieeHost        string
+	AuthRedirectUrl string
 }
 type Oss struct {
 	AccessKeyId     string
--- a/data/policy.html
+++ b/data/policy.html
@ -0,0 +1,15 @@
+
+      <!DOCTYPE html>
+      <html>
+      <head>
+        <meta charset="UTF-8">
+        <title>隐私政策</title>
+        <style>
+          body { font-family: Arial, sans-serif; line-height: 1.6; }
+        </style>
+      </head>
+      <body>
+        <p>H5系统隐私政策</p><p>生效日期：2025年9月2日</p><p>1. 信息收集与使用</p><p>收集的个人信息类型</p><p>基础信息：手机号、微信昵称、头像、设备信息（IMEI、操作系统版本）。</p><p>支付信息：订单号、支付金额、交易时间（通过加密方式传输，不存储银行卡信息）。</p><p>自媒体平台授权信息，例如：</p><p>抖音：API接口权限（仅限内容同步）。</p><p>内容生成数据：用户输入的关键词、风格偏好、历史生成内容。</p><p>收集目的</p><p>账号验证与支付：手机号用于身份核验，支付信息用于完成交易。</p><p>内容发布：通过授权信息调用第三方平台API，执行用户指令。</p><p>2. 信息共享与转让</p><p>第三方平台接口：仅在用户授权范围内调用API，不共享用户平台账号密码。</p><p>支付合作方：与微信支付、支付宝等服务商共享订单信息以完成交易。</p><p>法律要求：如配合司法机关调查或响应政府要求，可能披露必要信息。</p><p>3. 用户权利</p><p>访问与控制：</p><p>可随时在“个人中心”查看历史生成内容、订单记录及授权状态。</p><p>删除与撤回：</p><p>可申请删除个人账户及生成内容（不包含已同步至第三方平台的内容）。</p><p>4. 数据安全</p><p>技术措施：采用HTTPS加密传输、数据库脱敏存储，定期进行安全漏洞检测。</p><p>第三方SDK：仅接入必要SDK（如微信登录、地图服务等），并签署数据保密协议。</p><p>5. 隐私政策更新</p><p>如涉及重大变更（如新增数据收集项），将通过短信/邮件通知并要求重新授权。</p><p>6. 联系我们</p><p>如有疑问，请通过以下方式联系：</p><p>客服邮箱：develop@fiee.com</p>
+      </body>
+      </html>
+    
--- a/data/service.html
+++ b/data/service.html
@ -0,0 +1,15 @@
+
+      <!DOCTYPE html>
+      <html>
+      <head>
+        <meta charset="UTF-8">
+        <title>服务条款</title>
+        <style>
+          body { font-family: Arial, sans-serif; line-height: 1.6; }
+        </style>
+      </head>
+      <body>
+        <p>服务条款</p><p>生效日期：2025年9月2日</p><p>1. 接受条款</p><p>通过注册或使用本系统（以下简称“服务”），您确认已阅读、理解并同意以下条款。若您不同意本条款，请立即停止使用本服务。</p><p>2. 服务内容</p><p>本系统提供自媒体内容生成与发布服务，用户可购买套餐后生成图文、短视频等原创内容，并通过系统接口同步至指定自媒体平台（如微信公众号、抖音、小红书等）。</p><p>服务包含AI辅助创作、内容优化建议、一键发布功能，具体内容以实际功能模块为准。</p><p>3. 用户权利与义务</p><p>账号与支付</p><p>注册需提供手机号或微信授权，购买套餐需通过系统支持的支付方式（如微信支付、支付宝）。</p><p>您需确保支付账户信息真实有效，因虚假信息导致的损失由您自行承担。</p><p>内容生成与发布</p><p>生成内容为原创作品，最终发布权归用户所有。</p><p>用户需对生成内容进行人工审核，确认无误后方可发布。因内容违规导致的平台处罚或法律纠纷，责任由用户承担。</p><p>系统不对用户未审核内容的合规性负责，但有权对明显违法内容（如涉黄、涉政）进行过滤拦截。</p><p>第三方平台接口</p><p>用户需授权系统调用其自媒体平台API（如tiktok开发者接口），授权范围限于内容发布及数据同步。</p><p>授权信息仅用于执行用户指令，系统不存储用户平台账号密码等敏感信息。</p><p>4. 套餐与退款</p><p>套餐有效期自购买成功日起计算，逾期未使用的套餐不支持退款。</p><p>如因系统故障或服务瑕疵导致无法正常使用，可联系客服协商退款。</p><p>5. 知识产权</p><p>由系统生成的内容（如文案、图片）默认无版权归属限制，但用户需遵守以下规则：</p><p>不得将内容用于商业用途（如转售、批量分发）；</p><p>不得篡改系统生成内容的署名或标识；</p><p>若内容包含第三方素材（如音乐、图片），用户需自行确保使用合法性。</p><p>6. 责任限制</p><p>系统不对以下情形承担责任：</p><p>用户未审核内容导致的平台封禁、投诉或法律风险；</p><p>第三方平台接口变更或服务中断；</p><p>因不可抗力（如网络故障）导致的发布延迟。</p><p>7. 其他</p><p>本条款解释权归服务提供方所有，更新后将在系统内公示，用户继续使用即视为同意。</p>
+      </body>
+      </html>
+    
--- a/docs/dev/conf.ini
+++ b/docs/dev/conf.ini
@ -6,6 +6,8 @@ Host = "https://common.szjixun.cn"
 RedirectUri = "/api/redirect/url"
 ErpHost = "http://114.218.158.24:9020"
 FieeHost = "http://114.218.158.24:9020"
+AuthRedirectUrl = "http://172.16.100.99:9028/media_account"
+
 [bos]
 Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe"
 Sk = "d2ecaa9d75114d3b9f42b99014198306"
--- a/docs/prod/conf.ini
+++ b/docs/prod/conf.ini
@ -6,6 +6,7 @@ Host = "https://common.szjixun.cn"
 RedirectUri = "/api/redirect/url"
 ErpHost = "https://erpapi.fontree.cn"
 FieeHost = "https://erpapi.fiee.com"
+AuthRedirectUrl = "https://erp.fiee.com/media_account"
 [bos]
 Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe"
 Sk = "d2ecaa9d75114d3b9f42b99014198306"
--- a/docs/test/conf.ini
+++ b/docs/test/conf.ini
@ -6,6 +6,8 @@ Host = "https://common.szjixun.cn"
 RedirectUri = "/api/redirect/url"
 ErpHost = "http://114.218.158.24:9020"
 FieeHost = "http://114.218.158.24:9020"
+FieeApiHost = "https://saas-test.szjixun.cn"
+AuthRedirectUrl = "http://172.16.100.99:9028/media_account"
 [bos]
 Ak = "ALTAKxrqOQHnAN525Tb2GX4Bhe"
 Sk = "d2ecaa9d75114d3b9f42b99014198306"
--- a/pkg/common/file.go
+++ b/pkg/common/file.go
@ -0,0 +1,11 @@
+package common
+
+import "fonchain-fiee/pkg/utils"
+
+func Init() {
+	_ = utils.CreateDirPath("./runtime")
+	utils.CopyFile("./data/policy.html", "./runtime")
+	utils.CopyFile("./data/service.html", "./runtime")
+	utils.CopyFile("../data/policy.html", "./runtime")
+	utils.CopyFile("../data/service.html", "./runtime")
+}
--- a/pkg/router/media.go
+++ b/pkg/router/media.go
@ -4,11 +4,12 @@ import (
 	"fonchain-fiee/pkg/middleware"
 	"fonchain-fiee/pkg/service"
 	serviceCast "fonchain-fiee/pkg/service/cast"
+
 	"github.com/gin-gonic/gin"
 )

 func MediaRouter(r *gin.RouterGroup) {
-	//noAuth := r.Group("")
+	noAuth := r.Group("")
 	auth := r.Group("")
 	auth.Use(middleware.CheckWebLogin(service.AccountProvider))
 	media := auth.Group("media")
@ -17,12 +18,14 @@ func MediaRouter(r *gin.RouterGroup) {
 		media.POST("unbind-manager", serviceCast.UnbindManager)
 		media.POST("bind-manager", serviceCast.BindManager)
 		media.POST("update-account", serviceCast.UpdateMediaAccount)
-		media.POST("oauth-url", serviceCast.OAuthUrl)
+		media.POST("oauth-account", serviceCast.OAuthAccount)
+		media.POST("refresh-token", serviceCast.RefreshToken)
 	}
 	mediaNoLogin := r.Group("media")
 	{
 		mediaNoLogin.GET("oauth2callback", serviceCast.OAuth2Callback)
-		mediaNoLogin.GET("test", serviceCast.Test)
+		mediaNoLogin.Any("test", serviceCast.Test)
+		//mediaNoLogin.GET("dmoauth2callback", serviceCast.DMOAuth2Callback)
 	}

 	work := auth.Group("work")
@ -35,5 +38,11 @@ func MediaRouter(r *gin.RouterGroup) {
 		work.POST("republish", serviceCast.RePublish)
 		work.POST("delete", serviceCast.DelWork)
 		work.POST("remind", serviceCast.Remind)
+		work.POST("publish-info", serviceCast.PublishInfo)
+	}
+
+	social := noAuth.Group("social")
+	{
+		social.GET("tiktok-redirect", serviceCast.TikTokRedirect)
 	}
 }
--- a/pkg/router/router.go
+++ b/pkg/router/router.go
@ -192,6 +192,8 @@ func NewRouter() *gin.Engine {
 		importRoute.Use(middleware.CheckWebLogin(service.AccountProvider))
 		importRoute.POST("data/bind", imports.ImportBind)
 		importRoute.POST("data/publish", imports.ImportPublish)
+		importRoute.POST("data/publish2", imports.ImportPublishV2)
+		importRoute.POST("data/publish3", imports.ImportPublishV3)
 		importRoute.POST("data/confirm", imports.WorkConfirm)
 	}
 	//静态文件
--- a/pkg/service/bundle/reconciliation.go
+++ b/pkg/service/bundle/reconciliation.go
@ -24,6 +24,33 @@ func GetReconciliationList(c *gin.Context) {
 		service.Error(c, err)
 		return
 	}
+	res := &bundle.GetReconciliationListResp{}
+	// Step 1: 如果有姓名/电话筛选，先查用户列表
+	if req.UserName != "" {
+		userListResp, err := service.AccountFieeProvider.UserList(context.Background(), &accountFiee.UserListRequest{
+			BlurNameTel: req.UserName,
+			Domain:      "app",
+		})
+		if err != nil {
+			service.Error(c, err)
+			return
+		}
+
+		if len(userListResp.UserList) == 0 {
+			// 没查到用户，直接返回空结果
+			res.Page = req.Page
+			res.PageSize = req.PageSize
+			res.Total = 0
+			service.Success(c, res)
+			return
+		}
+
+		// 提取用户ID列表
+		for _, u := range userListResp.UserList {
+			req.UserIDS = append(req.UserIDS, u.Id)
+		}
+	}
+	req.UserName = ""
 	detail, detailErr := service.BundleProvider.GetReconciliationList(context.Background(), &req)
 	if detailErr != nil {
 		service.Error(c, detailErr)
@ -63,6 +90,31 @@ func GetReconciliationListDownload(c *gin.Context) {
 		service.Error(c, err)
 		return
 	}
+	res := &bundle.GetReconciliationListResp{}
+	if req.UserName != "" {
+		userListResp, err := service.AccountFieeProvider.UserList(context.Background(), &accountFiee.UserListRequest{
+			BlurNameTel: req.UserName,
+			Domain:      "app",
+		})
+		if err != nil {
+			service.Error(c, err)
+			return
+		}
+
+		if len(userListResp.UserList) == 0 {
+			// 没查到用户，直接返回空结果
+			res.Page = req.Page
+			res.PageSize = req.PageSize
+			res.Total = 0
+			service.Success(c, res)
+			return
+		}
+
+		// 提取用户ID列表
+		for _, u := range userListResp.UserList {
+			req.UserIDS = append(req.UserIDS, u.Id)
+		}
+	}
 	detail, detailErr := service.BundleProvider.GetReconciliationList(context.Background(), &req)
 	if detailErr != nil {
 		service.Error(c, detailErr)
@ -92,7 +144,7 @@ func GetReconciliationListDownload(c *gin.Context) {
 		}
 	}
 	titleList := []string{
-		"关联套餐订单号", "关联增值服务订单号", "对账单创建时间", "用户编号", "艺人", "艺人手机号", "套餐", "支付金额", "手续费", "币种", "支付渠道", "支付时间", "支付状态", "流水号",
+		"关联套餐订单号", "关联增值服务订单号", "用户编号", "艺人", "艺人手机号", "套餐", "支付金额", "手续费", "币种", "支付渠道", "支付时间", "支付状态", "流水号",
 	}
 	var dataList []interface{}

@ -106,7 +158,7 @@ func GetReconciliationListDownload(c *gin.Context) {
 		data := []any{
 			i.BundleOrderOn,
 			i.BundleAddOrderOn,
-			i.CreationTime,
+			//i.CreationTime,
 			i.SubNum,
 			i.UserName,
 			i.UserTel,
@ -306,7 +358,7 @@ func AutoCreateUserAndOrder(c *gin.Context) {
 		)
 		// 当前 未将 签名 写入合同中 todo 金额和有效时间待修改
 		contract := "https://e-cdn.fontree.cn/fonchain-main/prod/file/saas/contract/template-25032801.pdf"
-		expirationDay = t.AddDate(10, 0, 0).Format("2006-01-02")
+		expirationDay = t.AddDate(1, 0, 0).Format("2006-01-02")
 		signContract, signContractErr := logic.SignContractV2(userReq.UserNum, contract, TotalPrice, expirationDay)
 		if signContractErr != nil {
 			service.Error(c, signContractErr)
--- a/pkg/service/cast/media.go
+++ b/pkg/service/cast/media.go
@ -3,6 +3,7 @@ package cast
 import (
 	"context"
 	"errors"
+	"fmt"
 	"fonchain-fiee/api/accountFiee"
 	"fonchain-fiee/api/bundle"
 	"fonchain-fiee/api/cast"
@ -10,9 +11,13 @@ import (
 	"fonchain-fiee/pkg/e"
 	modelCast "fonchain-fiee/pkg/model/cast"
 	"fonchain-fiee/pkg/service"
+	"net/http"
+	"net/url"
+	"strconv"
+
 	"github.com/gin-gonic/gin"
 	"go.uber.org/zap"
-	"strconv"
+	"google.golang.org/protobuf/types/known/emptypb"
 )

 func MediaUserList(ctx *gin.Context) {
@ -160,9 +165,10 @@ func UpdateMediaAccount(ctx *gin.Context) {
 	return
 }

-func OAuthUrl(ctx *gin.Context) {
-	var req *cast.OAuthYoutubeUrlReq
-	var resp *cast.OAuthYoutubeUrlResp
+// 账号授权
+func OAuthAccount(ctx *gin.Context) {
+	var req *cast.OAuthAccountReq
+	var resp *cast.OAuthAccountResp
 	var err error
 	if err = ctx.ShouldBind(&req); err != nil {
 		service.Error(ctx, err)
@ -172,7 +178,7 @@ func OAuthUrl(ctx *gin.Context) {
 		service.Error(ctx, err)
 		return
 	}
-	if resp, err = service.CastProvider.OAuthYoutubeUrl(ctx, req); err != nil {
+	if resp, err = service.CastProvider.OAuthAccount(ctx, req); err != nil {
 		service.Error(ctx, err)
 		return
 	}
@ -181,15 +187,63 @@ func OAuthUrl(ctx *gin.Context) {
 }

 func OAuth2Callback(ctx *gin.Context) {
+	var (
+		platformIds string
+		userID      string
+	)
 	code := ctx.Query("code")
 	state := ctx.Query("state")
-	//scope := ctx.Query("scope")
-	resp, err := service.CastProvider.OAuthYoutubeToken(ctx, &cast.OAuthYoutubeTokenReq{
-		MediaAccountUuid: state,
+	stateMM, _ := url.ParseQuery(state)
+	if len(stateMM["platform_id"]) > 0 {
+		platformIds = stateMM["platform_id"][0]
+	}
+	if len(stateMM["user_id"]) > 0 {
+		userID = stateMM["user_id"][0]
+	}
+	platformID, _ := strconv.ParseInt(platformIds, 10, 64)
+	req := &cast.OAuthCodeToTokenReq{
 		Code:   code,
-		//scope:             scope,
-	})
+		UserID: userID,
+	}
+	switch platformID {
+	case int64(cast.PlatformIDENUM_DM):
+		req.PlatformID = cast.PlatformIDENUM_DM
+	case int64(cast.PlatformIDENUM_TIKTOK):
+		req.PlatformID = cast.PlatformIDENUM_TIKTOK
+	default:
+		service.Error(ctx, errors.New(e.GetMsg(e.InvalidParams)))
+		return
+	}
+	zap.L().Info("OAuth2Callback", zap.Any("req", req), zap.Any("code", code), zap.Any("state", state))
+	_, err := service.CastProvider.OAuthCodeToToken(ctx, req)
 	if err != nil {
+		zap.L().Info("OAuth2Callback error", zap.Error(err))
+
+		ctx.Redirect(http.StatusFound, fmt.Sprintf("%s?%s", config.AppConfig.System.AuthRedirectUrl, "status=1"))
+		return
+	}
+	// TODO 跳转到前端页面
+	ctx.Redirect(http.StatusFound, fmt.Sprintf("%s?%s", config.AppConfig.System.AuthRedirectUrl, "status=0"))
+	//service.Success(ctx, map[string]interface{}{
+	//	"req":  req,
+	//	"resp": resp,
+	//})
+
+	return
+}
+func RefreshToken(ctx *gin.Context) {
+	var req *cast.RefreshTokenReq
+	var resp *cast.RefreshTokenResp
+	var err error
+	if err = ctx.ShouldBind(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	if err = req.Validate(); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	if resp, err = service.CastProvider.RefreshToken(ctx, req); err != nil {
 		service.Error(ctx, err)
 		return
 	}
@ -198,6 +252,6 @@ func OAuth2Callback(ctx *gin.Context) {
 }

 func Test(ctx *gin.Context) {
-	service.Success(ctx, nil)
+	service.CastProvider.Test(ctx, &emptypb.Empty{})
 	return
 }
--- a/pkg/service/cast/oauth.go
+++ b/pkg/service/cast/oauth.go
@ -1 +0,0 @@
-package cast
--- a/pkg/service/cast/social.go
+++ b/pkg/service/cast/social.go
@ -0,0 +1,38 @@
+package cast
+
+import (
+	"fmt"
+	"fonchain-fiee/pkg/service"
+	"net/url"
+
+	"github.com/gin-gonic/gin"
+)
+
+func TikTokRedirect(ctx *gin.Context) {
+	var state, decodeParams, code string
+	var err error
+	var values url.Values
+	fmt.Println(code)
+	state = ctx.Query("state")
+	decodeParams, err = url.QueryUnescape(state)
+	values, err = url.ParseQuery(decodeParams)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	switch values.Get("source") {
+	case "authcode":
+		code = ctx.Query("code")
+		/*resp, _err := service.CastProvider.OAuthTikTokToken(ctx, &cast.OAuthTikTokTokenReq{
+			Code:   code,
+			UserID: values.Get("userid"),
+		})
+		if _err != nil {
+			service.Error(ctx, _err)
+			return
+		}
+		service.Success(ctx, resp)*/
+	}
+
+	return
+}
--- a/pkg/service/cast/work.go
+++ b/pkg/service/cast/work.go
@ -11,7 +11,9 @@ import (
 	"fonchain-fiee/pkg/e"
 	modelCast "fonchain-fiee/pkg/model/cast"
 	"fonchain-fiee/pkg/service"
+	"fonchain-fiee/pkg/utils/stime"
 	"strconv"
+	"time"

 	"github.com/gin-gonic/gin"
 	"go.uber.org/zap"
@ -31,6 +33,7 @@ func UpdateWorkImage(ctx *gin.Context) {
 			ID:     artistId,
 			Domain: "app",
 		})
+		zap.L().Info("UpdateWorkImage infoResp", zap.Any("infoResp", infoResp))
 		if err != nil {
 			service.Error(ctx, err)
 			return
@ -53,6 +56,7 @@ func UpdateWorkImage(ctx *gin.Context) {
 	newCtx := NewCtxWithUserInfo(ctx)
 	req.Source = 1
 	resp, err := service.CastProvider.UpdateWorkImage(newCtx, req)
+	zap.L().Info("UpdateWorkImage resp", zap.Any("resp", resp))
 	if err != nil {
 		service.Error(ctx, err)
 		return
@ -75,6 +79,7 @@ func UpdateWorkVideo(ctx *gin.Context) {
 			ID:     artistId,
 			Domain: "app",
 		})
+		zap.L().Info("UpdateWorkVideo", zap.Any("infoResp", infoResp))
 		if err != nil {
 			service.Error(ctx, err)
 			return
@ -97,6 +102,7 @@ func UpdateWorkVideo(ctx *gin.Context) {
 	newCtx := NewCtxWithUserInfo(ctx)
 	req.Source = 1
 	resp, err := service.CastProvider.UpdateWorkVideo(newCtx, req)
+	zap.L().Info("UpdateWorkVideo", zap.Any("resp", resp))
 	if err != nil {
 		service.Error(ctx, err)
 		return
@ -146,6 +152,14 @@ func WorkList(ctx *gin.Context) {
 				approvalID, _ := strconv.ParseUint(v.ApprovalID, 10, 64)
 				workUuidApprovalIDMap[int(approvalID)] = v.WorkUuid
 			}
+			statusUpdateDate, _ := stime.DatetimeToTimes(v.StatusUpdateTime, "2006-01-02 15:04:05")
+			if v.WorkStatus == 6 && (time.Now().Unix()-int64(statusUpdateDate) < 300) {
+				go func() {
+					_, _ = service.CastProvider.PublishMediaInfo(context.Background(), &cast.PublishMediaInfoReq{
+						WorkUuid: v.WorkUuid,
+					})
+				}()
+			}
 		}
 		if len(workUuidApprovalIDMap) > 0 {
 			_ = RefreshWorkApprovalStatus(ctx, workUuidApprovalIDMap)
@ -176,8 +190,10 @@ func WorkDetail(ctx *gin.Context) {
 }

 func CheckUserBundleBalance(userID int32, balanceType modelCast.BalanceTypeEnum) (err error) {
+	zap.L().Info("CheckUserBundleBalance", zap.Any("userID", userID))
 	resp, err := service.BundleProvider.GetBundleBalanceByUserId(context.Background(), &bundle.GetBundleBalanceByUserIdReq{UserId: userID})
 	if err != nil {
+		zap.L().Error("CheckUserBundleBalance", zap.Any("err", err))
 		return
 	}
 	zap.L().Info("CheckUserBundleBalance", zap.Any("resp", resp))
@ -206,6 +222,7 @@ func RePublish(ctx *gin.Context) {
 	var (
 		req  *cast.RePublishReq
 		resp *cast.RePublishResp
+		//workInfoResp *cast.WorkInfoResp
 	)
 	var err error
 	if err = ctx.ShouldBind(&req); err != nil {
@ -213,28 +230,39 @@ func RePublish(ctx *gin.Context) {
 		return
 	}
 	newCtx := NewCtxWithUserInfo(ctx)
-	resp, err = service.CastProvider.RePublish(newCtx, req)
+	/*	workInfoResp, err = service.CastProvider.WorkInfo(context.Background(), &cast.WorkInfoReq{
+			WorkUuid: req.WorkUuid,
+		})
 		if err != nil {
 			service.Error(ctx, err)
 			return
 		}
-	artistID, _ := strconv.ParseUint(resp.ArtistUuid, 10, 64)
+		fmt.Println(workInfoResp)*/
+	/*artistID, _ := strconv.ParseInt(workInfoResp.ArtistUuid, 10, 64)
+	if err = CheckUserBundleBalance(int32(artistID), modelCast.BalanceTypeVideoValue); err != nil {
+		service.Error(ctx, err)
+		return
+	}
 	balanceReq := &bundle.AddBundleBalanceReq{
 		UserId: int32(artistID),
 	}
-	if resp.WorkCategory == 1 {
+	if workInfoResp.WorkCategory == 1 {
 		balanceReq.ImageConsumptionNumber = 1
 	}
-	if resp.WorkCategory == 2 {
+	if workInfoResp.WorkCategory == 2 {
 		balanceReq.VideoConsumptionNumber = 1
 	}
 	_, err = service.BundleProvider.AddBundleBalance(context.Background(), balanceReq)
 	if err != nil {
 		service.Error(ctx, err)
-		//FIXME 进行回滚
+		return
+	}*/
+	resp, err = service.CastProvider.RePublish(newCtx, req)
+	if err != nil {
+		service.Error(ctx, err)
 		return
 	}
-	service.Success(ctx, nil)
+	service.Success(ctx, resp)
 	return
 }

@ -364,3 +392,20 @@ func Remind(ctx *gin.Context) {
 	service.Success(ctx, nil)
 	return
 }
+
+func PublishInfo(ctx *gin.Context) {
+	var req *cast.PublishMediaInfoReq
+	var resp *cast.PublishMediaInfoResp
+	var err error
+	if err = ctx.ShouldBind(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	resp, err = service.CastProvider.PublishMediaInfo(context.Background(), req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+	return
+}
--- a/pkg/service/import/confirm.go
+++ b/pkg/service/import/confirm.go
@ -1,15 +1,14 @@
 package imports

 import (
-	"context"
 	"fmt"
-	account "fonchain-fiee/api/accountFiee"
 	"fonchain-fiee/api/bundle"
 	apiCast "fonchain-fiee/api/cast"
 	"fonchain-fiee/pkg/service"
 	"log"
 	"os"
 	"path/filepath"
+	"strconv"
 	"strings"

 	"github.com/gin-gonic/gin"
@ -40,22 +39,15 @@ func WorkConfirm(c *gin.Context) { // 确认作品并扣除余量
 	//遍历更新状态
 	var failedRecords []FailedRecord
 	for _, v := range artists {
-		res, err := service.AccountFieeProvider.UserList(context.Background(), &account.UserListRequest{
-			Name:   v.ArtistName,
-			SubNum: v.SubNum,
-		})
+		artistId, err := strconv.ParseUint(v.ArtistId, 10, 32)
 		if err != nil {
 			failedRecords = append(failedRecords, FailedRecord{
 				Name: v.ArtistName,
-				Msg:  fmt.Sprintf("获取用户信息失败: %s", err.Error()),
+				Msg:  fmt.Sprintf("解析用户ID失败: %s", err.Error()),
 			})
-			log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
+			log.Printf(fmt.Sprintf("解析用户ID失败: %s", err.Error()))
 			continue
 		}
-		var artistId uint64
-		if res != nil && len(res.UserList) > 0 {
-			artistId = res.UserList[0].Id
-		}
 		_, err = service.BundleProvider.AddBundleBalance(c, &bundle.AddBundleBalanceReq{
 			UserId:                 int32(artistId),
 			VideoConsumptionNumber: 1,
@ -73,6 +65,7 @@ func WorkConfirm(c *gin.Context) { // 确认作品并扣除余量
 			WorkUuid:      v.WorkUuid,
 			ConfirmRemark: "",
 			ConfirmStatus: 1,
+			AutoPublish:   apiCast.AutoPublishENUM_AutoPublish_FALSE,
 		})
 		if err != nil {
 			failedRecords = append(failedRecords, FailedRecord{
@ -104,9 +97,9 @@ func readCastWorkList(excelPath string) ([]ArtistVideoDetail, error) {
 			continue
 		}
 		tmp := ArtistVideoDetail{
+			ArtistId:   strings.TrimSpace(row[0]),
 			ArtistName: strings.TrimSpace(row[1]),
-			WorkUuid:   strings.TrimSpace(row[3]),
-			SubNum:     strings.TrimSpace(row[7]),
+			WorkUuid:   strings.TrimSpace(row[2]),
 		}
 		artistVideos = append(artistVideos, tmp)
 	}
--- a/pkg/service/import/publish.go
+++ b/pkg/service/import/publish.go
@ -42,16 +42,18 @@ func ImportPublish(c *gin.Context) {
 	os.MkdirAll(tempDir, 0755)
 	excelPath := filepath.Join(tempDir, "artists.xlsx")
 	zipPath := filepath.Join(tempDir, "archive.zip")
-
+	fmt.Println("before save excel...")
+	now := time.Now()
 	if err = c.SaveUploadedFile(excelFile, excelPath); err != nil {
 		c.JSON(500, gin.H{"error": "保存 Excel 失败"})
 		return
 	}
+	fmt.Println("save excel success", time.Since(now))
 	if err = c.SaveUploadedFile(zipFile, zipPath); err != nil {
 		c.JSON(500, gin.H{"error": "保存 ZIP 文件失败"})
 		return
 	}
-	fmt.Println("解压前...")
+	fmt.Println("save zip success", time.Since(now))
 	// 3. 解压 ZIP
 	unzipPath := filepath.Join(tempDir, "unzipped")
 	if _, err = os.Stat(unzipPath); err == nil {
@ -67,13 +69,11 @@ func ImportPublish(c *gin.Context) {
 		c.JSON(500, gin.H{"error": "解压 ZIP 失败: " + err.Error()})
 		return
 	}
-	fmt.Println("解压11111111")
 	entries, err := os.ReadDir(unzipPath)
 	if err != nil || len(entries) == 0 {
 		c.JSON(500, gin.H{"error": "读取解压目录失败或目录为空"})
 		return
 	}
-	fmt.Println("jieya后...")
 	if len(entries) == 1 && entries[0].IsDir() {
 		// 说明解压后多了一层目录，把它设为新的 unzipPath
 		unzipPath = filepath.Join(unzipPath, entries[0].Name())
@ -89,10 +89,9 @@ func ImportPublish(c *gin.Context) {
 	// 5.发布视频
 	var failedRecords []FailedRecord
 	var artistResp []ArtistVideoDetail
-	fmt.Println("artists: ", artists)
+	fmt.Println("artists num: ", len(artists))
 	for _, artist := range artists {
 		var infoResp *accountFiee.UserInfoResponse
-		var err error
 		list, err := service.AccountFieeProvider.UserList(context.Background(), &accountFiee.UserListRequest{
 			Name:   artist.Name,
 			SubNum: artist.SubNum,
@ -105,6 +104,14 @@ func ImportPublish(c *gin.Context) {
 			log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
 			continue
 		}
+		if len(list.UserList) == 0 {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("未找到用户信息: %s", artist.Name),
+			})
+			log.Printf(fmt.Sprintf("未找到用户信息: %s", artist.Name))
+			continue
+		}
 		if list != nil && len(list.UserList) > 0 {
 			infoResp, err = service.AccountFieeProvider.Info(context.Background(), &accountFiee.InfoRequest{
 				ID:     list.UserList[0].Id,
@ -130,7 +137,226 @@ func ImportPublish(c *gin.Context) {
 		}
 		//自媒体账号
 		accountList, err := service.CastProvider.MediaUserList(c, &apiCast.MediaUserListReq{
-			//ArtistUuid: strconv.FormatUint(list.UserList[0].Id, 10),
+			ArtistUuid: strconv.FormatUint(list.UserList[0].Id, 10),
+			ArtistVal:  artist.Name,
+			Page:       1,
+			PageSize:   10,
+		})
+		if err != nil {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data)),
+			})
+			log.Printf(fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data)))
+			continue
+		}
+		if accountList == nil || len(accountList.Data) == 0 {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  "自媒体账号数量为0",
+			})
+			log.Printf(fmt.Sprintf("自媒体账号,账号数量:%d", len(accountList.Data)))
+			continue
+		}
+		mediaAccountUuids := []string{}
+		mediaAccountNames := []string{}
+		platformIDs := []apiCast.PlatformIDENUM{}
+		for _, info := range accountList.Data {
+			if info.PlatformID == 2 && ((artist.Id == "31" && info.ArtistName == "荣小松") ||
+				(artist.Id == "72" && info.ArtistName == "韩风霞")) {
+				continue // 跳过
+			}
+			mediaAccountUuids = append(mediaAccountUuids, info.MediaAccountUuid)
+			mediaAccountNames = append(mediaAccountNames, info.PlatformUserName)
+			platformIDs = append(platformIDs, apiCast.PlatformIDENUM(info.PlatformID))
+		}
+		newCtx := cast.NewCtxWithUserInfo(c)
+		resp, err := service.CastProvider.UpdateWorkVideo(newCtx, &apiCast.UpdateWorkVideoReq{
+			Title:             artist.Title,
+			Content:           artist.Title,
+			VideoUrl:          artist.Video,
+			CoverUrl:          artist.Img,
+			AutoPublish:       apiCast.AutoPublishENUM_AutoPublish_FALSE,
+			MediaAccountUuids: mediaAccountUuids,
+			MediaAccountNames: mediaAccountNames,
+			PlatformIDs:       platformIDs,
+			PublishConfig1: &apiCast.PublishConfig{
+				CanComment:    1,
+				CanJoin:       1,
+				CanQuote:      1,
+				ForbidComment: 2,
+				IsAI:          1,
+				PublicType:    1,
+			},
+			PublishConfig2: &apiCast.PublishConfig{
+				CanComment:    1,
+				CanJoin:       1,
+				CanQuote:      1,
+				ForbidComment: 2,
+				IsAI:          1,
+				PublicType:    1,
+			},
+			PublishConfig3: &apiCast.PublishConfig{
+				CanComment:    1,
+				CanJoin:       1,
+				CanQuote:      1,
+				ForbidComment: 1,
+				IsAI:          1,
+				PublicType:    1,
+			},
+			Action:              "submit",
+			ArtistUuid:          strconv.FormatUint(list.UserList[0].Id, 10),
+			ArtistName:          infoResp.Name,
+			ArtistPhone:         infoResp.TelNum,
+			ArtistPhoneAreaCode: infoResp.TelAreaCode,
+			Source:              2,
+		})
+		if err != nil {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error()),
+			})
+			log.Printf(fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error()))
+			continue
+		}
+		artistResp = append(artistResp, ArtistVideoDetail{
+			Id:         artist.Id,
+			ArtistName: artist.Name,
+			SubNum:     artist.SubNum,
+			Title:      artist.Title,
+			WorkUuid:   resp.WorkUuid,
+			Youtube:    artist.Youtube,
+			Instagram:  artist.Instagram,
+			TikTok:     artist.TikTok,
+		})
+	}
+	// excelUrl, err := exportPublishRecordsToExcel(artistResp)
+	// if err != nil {
+	// 	service.Error(c, err)
+	// 	return
+	// }
+
+	// 6. 返回结果
+	service.Success(c, map[string]interface{}{
+		//"excelUrl":      excelUrl,
+		"failedRecords": failedRecords,
+	})
+}
+func ImportPublishV2(c *gin.Context) {
+	// 1. 上传画家短视频详情文件
+	excelFile, err := c.FormFile("excel")
+	if err != nil {
+		c.JSON(400, gin.H{"error": "缺少 Excel 文件 excel"})
+		return
+	}
+	zipFile, err := c.FormFile("zip")
+	if err != nil {
+		c.JSON(400, gin.H{"error": "缺少 ZIP 文件"})
+		return
+	}
+
+	// 2. 保存临时文件
+	tempDir := "tmp"
+	os.MkdirAll(tempDir, 0755)
+	excelPath := filepath.Join(tempDir, "artists.xlsx")
+	zipPath := filepath.Join(tempDir, "archive.zip")
+	fmt.Println("before save excel...")
+	now := time.Now()
+	if err = c.SaveUploadedFile(excelFile, excelPath); err != nil {
+		c.JSON(500, gin.H{"error": "保存 Excel 失败"})
+		return
+	}
+	fmt.Println("save excel success", time.Since(now))
+	if err = c.SaveUploadedFile(zipFile, zipPath); err != nil {
+		c.JSON(500, gin.H{"error": "保存 ZIP 文件失败"})
+		return
+	}
+	fmt.Println("save zip success", time.Since(now))
+	// 3. 解压 ZIP
+	unzipPath := filepath.Join(tempDir, "unzipped")
+	if _, err = os.Stat(unzipPath); err == nil {
+		// 路径已存在，删除
+		if removeErr := os.RemoveAll(unzipPath); removeErr != nil {
+			c.JSON(500, gin.H{"error": "清理已存在解压目录失败: " + removeErr.Error()})
+			return
+		}
+	}
+	fmt.Println("开始解压...")
+	os.MkdirAll(unzipPath, 0755)
+	if err = archiver.Unarchive(zipPath, unzipPath); err != nil {
+		c.JSON(500, gin.H{"error": "解压 ZIP 失败: " + err.Error()})
+		return
+	}
+	entries, err := os.ReadDir(unzipPath)
+	if err != nil || len(entries) == 0 {
+		c.JSON(500, gin.H{"error": "读取解压目录失败或目录为空"})
+		return
+	}
+	fmt.Println("jieya后...")
+	if len(entries) == 1 && entries[0].IsDir() {
+		// 说明解压后多了一层目录，把它设为新的 unzipPath
+		unzipPath = filepath.Join(unzipPath, entries[0].Name())
+	}
+	fmt.Println("开始读取excel...")
+	defer os.RemoveAll(tempDir)
+	// 4. 读取 Excel 画家名单, 匹配视频和图片
+	artists, err := readArtistVideoInfo(excelPath, unzipPath)
+	if err != nil {
+		c.JSON(500, gin.H{"error": "读取 Excel 失败"})
+		return
+	}
+	// 5.发布视频
+	var failedRecords []FailedRecord
+	var artistResp []ArtistVideoDetail
+	fmt.Println("artists num: ", len(artists))
+	for _, artist := range artists {
+		var infoResp *accountFiee.UserInfoResponse
+		list, err := service.AccountFieeProvider.UserList(context.Background(), &accountFiee.UserListRequest{
+			Name:   artist.Name,
+			SubNum: artist.SubNum,
+		})
+		if err != nil {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("获取用户信息失败: %s", err.Error()),
+			})
+			log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
+			continue
+		}
+		if len(list.UserList) == 0 {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("未找到用户信息: %s", artist.Name),
+			})
+			log.Printf(fmt.Sprintf("未找到用户信息: %s", artist.Name))
+			continue
+		}
+		if list != nil && len(list.UserList) > 0 {
+			infoResp, err = service.AccountFieeProvider.Info(context.Background(), &accountFiee.InfoRequest{
+				ID:     list.UserList[0].Id,
+				Domain: "app",
+			})
+			if err != nil {
+				failedRecords = append(failedRecords, FailedRecord{
+					Name: artist.Name,
+					Msg:  fmt.Sprintf("获取用户信息失败: %s", err.Error()),
+				})
+				log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
+				continue
+			}
+		}
+
+		if err = cast.CheckUserBundleBalance(int32(list.UserList[0].Id), modelCast.BalanceTypeVideoValue); err != nil {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("检查用户视频可消耗数量: %s", err.Error()),
+			})
+			log.Printf(fmt.Sprintf("检查用户视频可消耗数量: %s", err.Error()))
+			continue
+		}
+		//自媒体账号
+		accountList, err := service.CastProvider.MediaUserList(c, &apiCast.MediaUserListReq{
+			ArtistUuid: strconv.FormatUint(list.UserList[0].Id, 10),
 			ArtistVal:  artist.Name,
 			Page:       1,
 			PageSize:   10,
@ -222,19 +448,18 @@ func ImportPublish(c *gin.Context) {
 			TikTok:     artist.TikTok,
 		})
 	}
-	excelUrl, err := exportPublishRecordsToExcel(artistResp)
-	if err != nil {
-		service.Error(c, err)
-		return
-	}
+	// excelUrl, err := exportPublishRecordsToExcel(artistResp)
+	// if err != nil {
+	// 	service.Error(c, err)
+	// 	return
+	// }

 	// 6. 返回结果
 	service.Success(c, map[string]interface{}{
-		"excelUrl":      excelUrl,
+		//"excelUrl":      excelUrl,
 		"failedRecords": failedRecords,
 	})
 }
-
 func readArtistVideoInfo(excelPath, unzipPath string) ([]ArtistMedia, error) {
 	log.Println(unzipPath)
 	f, err := excelize.OpenFile(excelPath)
@ -298,12 +523,19 @@ func matchArtistMedia(artists []ArtistMedia, unzipPath string) ([]ArtistMedia, e
 	var err error
 	var res []ArtistMedia
 	for _, artist := range artists {
-		oldImgPath := fmt.Sprintf("%s/%s/%s.jpg", unzipPath, artist.Name, artist.Id)
+		var oldVideoPath, oldImgPath string
+		for _, ext := range []string{".jpg", ".png", ".jpeg"} {
+			p := fmt.Sprintf("%s/%s/%s%s", unzipPath, artist.Name, artist.Id, ext)
+			if _, err = os.Stat(p); err == nil {
+				oldImgPath = p
+				break
+			}
+		}
 		// 检查源文件是否存在
 		if _, err = os.Stat(oldImgPath); os.IsNotExist(err) {
+			fmt.Println("图片不存在: ", artist.Id, artist.Name, oldImgPath)
 			continue
 		}
-		var oldVideoPath string
 		for _, ext := range []string{".mp4", ".mov"} {
 			p := fmt.Sprintf("%s/%s/%s%s", unzipPath, artist.Name, artist.Id, ext)
 			if _, err = os.Stat(p); err == nil {
@ -312,6 +544,7 @@ func matchArtistMedia(artists []ArtistMedia, unzipPath string) ([]ArtistMedia, e
 			}
 		}
 		if oldVideoPath == "" {
+			fmt.Println("视频不存在: ", artist.Id, artist.Name, oldVideoPath)
 			continue
 		}
 		baseDir := filepath.Join(unzipPath, artist.Name)
@ -369,6 +602,7 @@ func matchArtistMedia(artists []ArtistMedia, unzipPath string) ([]ArtistMedia, e
 	}
 	return res, nil
 }
+
 func UploadToAnotherService(ctx context.Context, fileData []byte, path string) error {
 	const chunkSize = 4*1024*1024 - 100
 	_, err := service.FilesProvider.TusCreate(ctx, &files.TusCreateReq{
@ -402,71 +636,348 @@ func UploadToAnotherService(ctx context.Context, fileData []byte, path string) e
 	}
 	return nil
 }
-func exportPublishRecordsToExcel(artistInfos []ArtistVideoDetail) (string, error) {
-	fileDir := "./runtime/import/"
-	filename := "画家视频详情记录0922.xlsx"
-	filePath := filepath.Join(fileDir, filename)

-	_ = os.MkdirAll(fileDir, os.ModePerm)
+// func exportPublishRecordsToExcel(artistInfos []ArtistVideoDetail) (string, error) {
+// 	fileDir := "./runtime/import/"
+// 	filename := "画家视频详情记录0922.xlsx"
+// 	filePath := filepath.Join(fileDir, filename)

-	var f *excelize.File
-	sheet := "Sheet1"
+// 	_ = os.MkdirAll(fileDir, os.ModePerm)

-	// 判断文件是否存在
-	if _, err := os.Stat(filePath); os.IsNotExist(err) {
-		// 文件不存在，新建文件和Sheet
-		f = excelize.NewFile()
-		f.SetSheetName(f.GetSheetName(0), sheet)
+// 	var f *excelize.File
+// 	sheet := "Sheet1"

-		// 写表头
-		headers := []string{"序号", "画家名", "标题", "uuid", "youtube", "instagram", "tiktok", "用户编号"}
-		for col, h := range headers {
-			_ = f.SetCellValue(sheet, string('A'+col)+"1", h)
-		}
-	} else {
-		// 文件存在，打开
-		var err error
-		f, err = excelize.OpenFile(filePath)
+// 	// 判断文件是否存在
+// 	if _, err := os.Stat(filePath); os.IsNotExist(err) {
+// 		// 文件不存在，新建文件和Sheet
+// 		f = excelize.NewFile()
+// 		f.SetSheetName(f.GetSheetName(0), sheet)
+
+// 		// 写表头
+// 		headers := []string{"序号", "画家名", "标题", "uuid", "youtube", "instagram", "tiktok", "用户编号"}
+// 		for col, h := range headers {
+// 			_ = f.SetCellValue(sheet, string('A'+col)+"1", h)
+// 		}
+// 	} else {
+// 		// 文件存在，打开
+// 		var err error
+// 		f, err = excelize.OpenFile(filePath)
+// 		if err != nil {
+// 			return "", err
+// 		}
+// 	}
+
+// 	// 找到最后一行，追加数据
+// 	rows, err := f.GetRows(sheet)
+// 	if err != nil {
+// 		return "", err
+// 	}
+
+// 	// 计算下一行，从表头之后开始
+// 	startRow := len(rows) + 1
+// 	if startRow == 1 {
+// 		startRow = 2 // 文件新建或没有数据，从第2行开始
+// 	}
+
+// 	// 写数据
+// 	for i, artistInfo := range artistInfos {
+// 		row := startRow + i
+// 		_ = f.SetCellValue(sheet, "A"+strconv.Itoa(row), row-1) // 序号连续
+// 		_ = f.SetCellValue(sheet, "B"+strconv.Itoa(row), artistInfo.ArtistName)
+// 		_ = f.SetCellValue(sheet, "C"+strconv.Itoa(row), artistInfo.Title)
+// 		_ = f.SetCellValue(sheet, "D"+strconv.Itoa(row), artistInfo.WorkUuid)
+// 		_ = f.SetCellValue(sheet, "E"+strconv.Itoa(row), artistInfo.Youtube)
+// 		_ = f.SetCellValue(sheet, "F"+strconv.Itoa(row), artistInfo.Instagram)
+// 		_ = f.SetCellValue(sheet, "G"+strconv.Itoa(row), artistInfo.TikTok)
+// 		_ = f.SetCellValue(sheet, "H"+strconv.Itoa(row), artistInfo.SubNum)
+// 	}
+
+// 	// 保存文件
+// 	if err = f.SaveAs(filePath); err != nil {
+// 		fmt.Println("saveAs err: ", err)
+// 		return "", err
+// 	}
+
+// 	// 上传
+// 	excelUrl, err := upload.PutBos(filePath, "excel", false)
+// 	if err != nil {
+// 		return "", err
+// 	}
+// 	return excelUrl, nil
+// }
+
+func ImportPublishV3(c *gin.Context) {
+	// 1. 上传画家短视频详情文件
+	excelFile, err := c.FormFile("excel")
 	if err != nil {
-			return "", err
-		}
+		c.JSON(400, gin.H{"error": "缺少 Excel 文件 excel"})
+		return
 	}
+	// 2. 保存临时文件
+	tempDir := "tmp"
+	os.MkdirAll(tempDir, 0755)
+	excelPath := filepath.Join(tempDir, "artists.xlsx")

-	// 找到最后一行，追加数据
-	rows, err := f.GetRows(sheet)
+	if err = c.SaveUploadedFile(excelFile, excelPath); err != nil {
+		c.JSON(500, gin.H{"error": "保存 Excel 失败"})
+		return
+	}
+	fmt.Println("save excel...")
+	defer os.RemoveAll(tempDir)
+
+	// 3. 读取 Excel 画家名单, 匹配视频和图片
+	artists, err := readArtistVideoInfoV2(c, excelPath)
 	if err != nil {
-		return "", err
+		c.JSON(500, gin.H{"error": "读取 Excel 失败"})
+		return
 	}
-
-	// 计算下一行，从表头之后开始
-	startRow := len(rows) + 1
-	if startRow == 1 {
-		startRow = 2 // 文件新建或没有数据，从第2行开始
-	}
-
-	// 写数据
-	for i, artistInfo := range artistInfos {
-		row := startRow + i
-		_ = f.SetCellValue(sheet, "A"+strconv.Itoa(row), row-1) // 序号连续
-		_ = f.SetCellValue(sheet, "B"+strconv.Itoa(row), artistInfo.ArtistName)
-		_ = f.SetCellValue(sheet, "C"+strconv.Itoa(row), artistInfo.Title)
-		_ = f.SetCellValue(sheet, "D"+strconv.Itoa(row), artistInfo.WorkUuid)
-		_ = f.SetCellValue(sheet, "E"+strconv.Itoa(row), artistInfo.Youtube)
-		_ = f.SetCellValue(sheet, "F"+strconv.Itoa(row), artistInfo.Instagram)
-		_ = f.SetCellValue(sheet, "G"+strconv.Itoa(row), artistInfo.TikTok)
-		_ = f.SetCellValue(sheet, "H"+strconv.Itoa(row), artistInfo.SubNum)
-	}
-
-	// 保存文件
-	if err = f.SaveAs(filePath); err != nil {
-		fmt.Println("saveAs err: ", err)
-		return "", err
-	}
-
-	// 上传
-	excelUrl, err := upload.PutBos(filePath, "excel", false)
+	// 4.发布视频
+	var failedRecords []FailedRecord
+	//var artistResp []ArtistVideoDetail
+	for _, artist := range artists {
+		var infoResp *accountFiee.UserInfoResponse
+		list, err := service.AccountFieeProvider.UserList(context.Background(), &accountFiee.UserListRequest{
+			Name:   artist.Name,
+			SubNum: artist.SubNum,
+		})
 		if err != nil {
-		return "", err
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("获取用户信息失败: %s", err.Error()),
+			})
+			log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
+			continue
 		}
-	return excelUrl, nil
+		if len(list.UserList) == 0 {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("未找到用户信息: %s", artist.Name),
+			})
+			log.Printf(fmt.Sprintf("未找到用户信息: %s", artist.Name))
+			continue
+		}
+		if list != nil && len(list.UserList) > 0 {
+			infoResp, err = service.AccountFieeProvider.Info(context.Background(), &accountFiee.InfoRequest{
+				ID:     list.UserList[0].Id,
+				Domain: "app",
+			})
+			if err != nil {
+				failedRecords = append(failedRecords, FailedRecord{
+					Name: artist.Name,
+					Msg:  fmt.Sprintf("获取用户信息失败: %s", err.Error()),
+				})
+				log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
+				continue
+			}
+		}
+
+		if err = cast.CheckUserBundleBalance(int32(list.UserList[0].Id), modelCast.BalanceTypeVideoValue); err != nil {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("检查用户视频可消耗数量: %s", err.Error()),
+			})
+			log.Printf(fmt.Sprintf("检查用户视频可消耗数量: %s", err.Error()))
+			continue
+		}
+		//自媒体账号
+		accountList, err := service.CastProvider.MediaUserList(c, &apiCast.MediaUserListReq{
+			ArtistUuid: strconv.FormatUint(list.UserList[0].Id, 10),
+			ArtistVal:  artist.Name,
+			Page:       1,
+			PageSize:   10,
+		})
+		if err != nil {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data)),
+			})
+			log.Printf(fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data)))
+			continue
+		}
+		if accountList == nil || len(accountList.Data) == 0 {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  "自媒体账号数量为0",
+			})
+			log.Printf(fmt.Sprintf("自媒体账号,账号数量:%d", len(accountList.Data)))
+			continue
+		}
+		mediaAccountUuids := []string{}
+		mediaAccountNames := []string{}
+		platformIDs := []apiCast.PlatformIDENUM{}
+		for _, info := range accountList.Data {
+			mediaAccountUuids = append(mediaAccountUuids, info.MediaAccountUuid)
+			mediaAccountNames = append(mediaAccountNames, info.PlatformUserName)
+			platformIDs = append(platformIDs, apiCast.PlatformIDENUM(info.PlatformID))
+		}
+		newCtx := cast.NewCtxWithUserInfo(c)
+		_, err = service.CastProvider.UpdateWorkVideo(newCtx, &apiCast.UpdateWorkVideoReq{
+			Title:             artist.Title,
+			Content:           artist.Title,
+			VideoUrl:          artist.Video,
+			CoverUrl:          artist.Img,
+			MediaAccountUuids: mediaAccountUuids,
+			MediaAccountNames: mediaAccountNames,
+			PlatformIDs:       platformIDs,
+			PublishConfig1: &apiCast.PublishConfig{
+				CanComment:    1,
+				CanJoin:       1,
+				CanQuote:      1,
+				ForbidComment: 2,
+				IsAI:          1,
+				PublicType:    1,
+			},
+			PublishConfig2: &apiCast.PublishConfig{
+				CanComment:    1,
+				CanJoin:       1,
+				CanQuote:      1,
+				ForbidComment: 2,
+				IsAI:          1,
+				PublicType:    1,
+			},
+			PublishConfig3: &apiCast.PublishConfig{
+				CanComment:    1,
+				CanJoin:       1,
+				CanQuote:      1,
+				ForbidComment: 1,
+				IsAI:          1,
+				PublicType:    1,
+			},
+			Action:              "submit",
+			ArtistUuid:          strconv.FormatUint(list.UserList[0].Id, 10),
+			ArtistName:          infoResp.Name,
+			ArtistPhone:         infoResp.TelNum,
+			ArtistPhoneAreaCode: infoResp.TelAreaCode,
+			Source:              2,
+		})
+		if err != nil {
+			failedRecords = append(failedRecords, FailedRecord{
+				Name: artist.Name,
+				Msg:  fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error()),
+			})
+			log.Printf(fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error()))
+			continue
+		}
+		// artistResp = append(artistResp, ArtistVideoDetail{
+		// 	Id:         artist.Id,
+		// 	ArtistName: artist.Name,
+		// 	SubNum:     artist.SubNum,
+		// 	Title:      artist.Title,
+		// 	WorkUuid:   resp.WorkUuid,
+		// 	Youtube:    artist.Youtube,
+		// 	Instagram:  artist.Instagram,
+		// 	TikTok:     artist.TikTok,
+		// })
+	}
+	// excelUrl, err := exportPublishRecordsToExcel(artistResp)
+	// if err != nil {
+	// 	service.Error(c, err)
+	// 	return
+	// }
+
+	// 6. 返回结果
+	service.Success(c, map[string]interface{}{
+		//"excelUrl":      excelUrl,
+		"failedRecords": failedRecords,
+	})
+}
+func readArtistVideoInfoV2(ctx *gin.Context, excelPath string) ([]ArtistMedia, error) {
+	f, err := excelize.OpenFile(excelPath)
+	if err != nil {
+		return nil, err
+	}
+	defer f.Close()
+	sheetName := f.GetSheetName(0)
+	rows, err := f.GetRows(sheetName)
+	if err != nil {
+		return nil, err
+	}
+	log.Println("start read excel")
+	var artists []ArtistMedia
+	for i, row := range rows {
+		if i == 0 || i == 1 || len(row) < 2 {
+			continue
+		}
+		id, _ := f.GetCellValue(sheetName, fmt.Sprintf("A%d", i+1))
+		if id != "" {
+			id = strings.TrimSpace(id)
+		}
+		artistName, _ := f.GetCellValue(sheetName, fmt.Sprintf("B%d", i+1))
+		if artistName != "" {
+			artistName = strings.TrimSpace(artistName)
+		}
+		title, _ := f.GetCellValue(sheetName, fmt.Sprintf("C%d", i+1))
+		if title != "" {
+			title = strings.TrimSpace(title)
+		}
+		subNum, _ := f.GetCellValue(sheetName, fmt.Sprintf("G%d", i+1))
+		if subNum != "" {
+			subNum = strings.TrimSpace(subNum)
+		}
+		artists = append(artists, ArtistMedia{
+			Id:     id,
+			Name:   artistName,
+			Title:  title,
+			SubNum: subNum,
+		})
+	}
+	artists, err = matchArtistMediaV3(ctx, artists)
+	return artists, nil
+}
+
+func matchArtistMediaV3(ctx *gin.Context, artists []ArtistMedia) ([]ArtistMedia, error) {
+	var medias = make(map[string][]*files.Items)
+	var res []ArtistMedia
+	for _, artist := range artists {
+		mediaPath := "fiee2/" + artist.Name
+		imgPath := fmt.Sprintf("%s/%s/%s.jpg", mediaPath, artist.Name, artist.Title)
+		videoPath := fmt.Sprintf("%s/%s/%s.mp4", mediaPath, artist.Name, artist.Title)
+		//判断文件是否存在
+		if _, ok := medias[artist.Name]; !ok {
+			sortBy := ctx.DefaultQuery("sortBy", "name")
+			sortAsc, _ := strconv.ParseBool(ctx.DefaultQuery("sortAsc", "true"))
+			resp, err := service.FilesProvider.List(ctx, &files.FileListReq{
+				Path:          mediaPath,
+				UserSpacePath: "",
+				Sorting: &files.Sorting{
+					By:  sortBy,
+					Asc: sortAsc,
+				},
+			})
+			if err != nil {
+				return nil, err
+			}
+			medias[artist.Name] = resp.Items
+		}
+		isExist := false
+		for _, media := range medias[artist.Name] {
+			if media.Name == artist.Title+".jpg" || media.Name == artist.Title+".mp4" || media.Name == artist.Title+".mov" {
+				isExist = true
+				break
+			}
+		}
+		if !isExist {
+			continue
+		}
+		var httpType string
+		if config.AppConfig.System.AppMode == "dev" {
+			url := "114.218.158.24:9020"
+			httpType = fmt.Sprintf("%s%s", model.HttpType, url)
+		} else {
+			url := "saas.fiee.com"
+			httpType = fmt.Sprintf("%s%s", model.HttpsType, url)
+		}
+		baseUrl := fmt.Sprintf("%s/api/fiee/resource/raw/", httpType)
+		videoUrl := baseUrl + filepath.Base(videoPath)
+		imgUrl := baseUrl + filepath.Base(imgPath)
+		tmp := artist
+		tmp.Id = artist.Id
+		tmp.Name = artist.Name
+		tmp.Title = artist.Title
+		tmp.Img = imgUrl
+		tmp.Video = videoUrl
+		tmp.SubNum = artist.SubNum
+		res = append(res, tmp)
+	}
+	return res, nil
 }
--- a/pkg/utils/stime/common.go
+++ b/pkg/utils/stime/common.go
@ -7,6 +7,9 @@
 package stime

 import (
+	"errors"
+	"fonchain-fiee/pkg/e"
+	"go.uber.org/zap"
 	"time"
 )

@ -88,3 +91,19 @@ var WeekStrMap = map[string]string{
 	"Saturday":  "六",
 	"Sunday":    "日",
 }
+
+func DatetimeToTimes(datetime string, dateFormat string) (times int32, err error) {
+	if datetime == "" {
+		times = 0
+		return
+	}
+	loc, _ := time.LoadLocation("Asia/Shanghai")
+	t, err := time.ParseInLocation(dateFormat, datetime, loc)
+	if err != nil {
+		zap.L().Error("DatetimeToTimes err:"+datetime+":", zap.Error(err))
+		err = errors.New(e.GetCodeMsg(e.InvalidParams))
+		return
+	}
+	times = int32(t.Unix())
+	return
+}
--- a/pkg/utils/untils.go
+++ b/pkg/utils/untils.go
@ -7,14 +7,16 @@ import (
 	"errors"
 	"fmt"
 	"fonchain-fiee/pkg/e"
-	"github.com/gin-gonic/gin"
-	"github.com/tealeg/xlsx"
 	"io"
 	"io/ioutil"
 	"net/http"
 	"net/url"
 	"os"
+	"path/filepath"
 	"time"
+
+	"github.com/gin-gonic/gin"
+	"github.com/tealeg/xlsx"
 )

 const (
@ -128,3 +130,36 @@ func ResponseXls(c *gin.Context, content io.ReadSeeker, fileTag string) {
 	//c.Writer.Header().Add("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
 	http.ServeContent(c.Writer, c.Request, fileName, time.Now(), content)
 }
+
+func CreateDirPath(path string) (err error) {
+	if _, err = os.Stat(path); os.IsNotExist(err) {
+		if err = os.MkdirAll(path, os.ModePerm); err != nil {
+			return
+		}
+	}
+	return
+}
+
+func CopyFile(src, dstDir string) (string, error) {
+	in, err := os.Open(src)
+	if err != nil {
+		return "", err
+	}
+	defer in.Close()
+	if err := os.MkdirAll(dstDir, 0755); err != nil {
+		return "", err
+	}
+	dst := filepath.Join(dstDir, filepath.Base(src))
+	out, err := os.Create(dst)
+	if err != nil {
+		return "", err
+	}
+	defer out.Close()
+	if _, err = io.Copy(out, in); err != nil {
+		return "", err
+	}
+	if err = out.Sync(); err != nil {
+		return "", err
+	}
+	return dst, nil
+}
Author	SHA1	Message	Date
lzh	4098d590bf	Merge branch 'dev-lzh-1009'	2025-10-10 10:35:31 +08:00
lzh	db58773aea	新增使用类型字段	2025-10-10 10:29:46 +08:00
daiyb	b2a96ad465	Merge branch 'feature-costType-daiyb'	2025-10-10 09:18:42 +08:00
daiyb	6702083fd6	修改字段	2025-10-10 09:11:30 +08:00
daiyb	5da9d19112	Merge branch 'main' of http://gitea.tools.fontree.cn:3000/fiee/fonchain-fiee	2025-10-10 08:54:15 +08:00
lzh	87d46af603	更新proto文件	2025-10-09 17:11:33 +08:00
daiyb	15072f9e49	导出	2025-10-09 14:45:16 +08:00
sxy	c72d45c020	修改图片传入类型判断	2025-09-28 20:46:27 +08:00
sxy	f3c5cbff2a	导入修改-1	2025-09-28 19:17:19 +08:00
daiyb	ebe59394cf	Merge branch 'feature-tiktok-daiyb'	2025-09-28 19:14:10 +08:00
daiyb	5746dab3e0	添加更新视频的过滤字段	2025-09-28 19:13:58 +08:00
daiyb	6c4aeb8193	Merge branch 'feature-tiktok-daiyb'	2025-09-28 17:55:32 +08:00
daiyb	7200099204	更新字段	2025-09-28 17:55:17 +08:00
daiyb	c70c5913d4	Update README.md	2025-09-28 15:09:42 +08:00
JNG	414735bc54	Merge branch 'jng-0924'	2025-09-28 15:09:08 +08:00
JNG	3f5e4e3bc8	Update reconciliation.go	2025-09-28 15:08:45 +08:00
JNG	af4c370b84	Merge branch 'jng-0924'	2025-09-28 14:42:13 +08:00
JNG	9f7e2d1667	Update reconciliation.go	2025-09-28 14:41:24 +08:00
lzh	557739aeff	更新proto	2025-09-28 14:17:50 +08:00
sxy	91e1dfa196	导入修改	2025-09-28 10:53:18 +08:00
daiyb	2825ca826e	合并正式	2025-09-28 10:40:08 +08:00
daiyb	90d088101c	重新发布不扣除	2025-09-26 15:19:31 +08:00
daiyb	24cc34462e	分类	2025-09-26 12:28:27 +08:00
daiyb	9b7fbe73fd	Update media.go	2025-09-26 10:54:01 +08:00
daiyb	1c6172a848	更新proto	2025-09-26 09:25:09 +08:00
daiyb	af7fa93b4d	修改同步	2025-09-25 16:41:08 +08:00
daiyb	48dea8eaac	是否授权	2025-09-25 15:56:33 +08:00
sxy	761b9b656b	Merge branch 'feat-sxy-import919'	2025-09-25 13:47:13 +08:00
sxy	e2d87cb5e0	导入修改	2025-09-25 13:46:27 +08:00
daiyb	6a6bd459e6	Update conf.ini	2025-09-25 11:12:59 +08:00
daiyb	47473df3be	Update work.go	2025-09-24 17:16:10 +08:00
daiyb	fd908ec72b	Update work.go	2025-09-24 16:49:48 +08:00
JNG	6e6f159b23	Update reconciliation.go	2025-09-24 16:07:23 +08:00
daiyb	97f79df433	Update media.go	2025-09-24 11:58:22 +08:00
daiyb	e037f91507	Update media.go	2025-09-24 11:56:42 +08:00
daiyb	b35278771e	跳转	2025-09-24 11:47:16 +08:00
zhoujunyao	38e7e1aac6	fix: 自动刷订单的，过期时间10年变1年	2025-09-23 16:20:21 +08:00
daiyb	4dba6c7669	视频封面	2025-09-22 16:41:40 +08:00
daiyb	8271683614	添加信息查询	2025-09-22 16:29:38 +08:00
daiyb	39ca08605e	视频发布	2025-09-22 11:12:19 +08:00
daiyb	b4dd5d0778	完成视频发布	2025-09-22 10:02:44 +08:00
daiyb	6d34d7d4f2	复制隐私文件	2025-09-03 11:48:40 +08:00