diff --git a/internal/domain/repo/repos.go b/internal/domain/repo/repos.go index a3250ba..0350d95 100644 --- a/internal/domain/repo/repos.go +++ b/internal/domain/repo/repos.go @@ -3,17 +3,17 @@ package repo import ( "ai_scheduler/internal/config" "ai_scheduler/internal/data/impl" - "ai_scheduler/internal/pkg/oss" + "ai_scheduler/internal/pkg/utils_oss" ) // Repos 聚合所有 Repository type Repos struct { Session SessionRepo - OssClient *oss.Client + OssClient *utils_oss.Client } func NewRepos(sessionImpl *impl.SessionImpl, cfg *config.Config) *Repos { - ossClient, _ := oss.NewClient(cfg.Oss) + ossClient, _ := utils_oss.NewClient(cfg) return &Repos{ Session: NewSessionAdapter(sessionImpl), OssClient: ossClient, diff --git a/internal/domain/workflow/recharge/statistics_ours_product.go b/internal/domain/workflow/recharge/statistics_ours_product.go index 91d5092..d8bd64a 100644 --- a/internal/domain/workflow/recharge/statistics_ours_product.go +++ b/internal/domain/workflow/recharge/statistics_ours_product.go @@ -7,7 +7,7 @@ import ( "ai_scheduler/internal/domain/tools/recharge/statistics_ours_product" "ai_scheduler/internal/domain/workflow/runtime" "ai_scheduler/internal/entitys" - "ai_scheduler/internal/pkg/oss" + "ai_scheduler/internal/pkg/utils_oss" "context" "errors" "fmt" @@ -28,7 +28,7 @@ func init() { type statisticsOursProduct struct { cfg *config.Config toolManager *toolManager.Manager - ossClient *oss.Client + ossClient *utils_oss.Client } type StatisticsOursProductWorkflowInput struct {