diff --git a/drivers/189_share/driver.go b/drivers/189_share/driver.go index 4abf8ea1..1f5af5de 100644 --- a/drivers/189_share/driver.go +++ b/drivers/189_share/driver.go @@ -100,6 +100,7 @@ func (d *Cloud189Share) link(ctx context.Context, file model.Obj) (*model.Link, } fileObject, _ := file.(*FileObj) + log.Infof("[%v] 获取天翼云盘转存链接 %v %v", cloud189PC.ID, file.GetName(), file.GetID()) link, err = cloud189PC.Transfer(ctx, shareInfo.ShareId, fileObject.ID, fileObject.oldName) return link, err } diff --git a/drivers/189pc/driver.go b/drivers/189pc/driver.go index 6516819c..00c6b684 100644 --- a/drivers/189pc/driver.go +++ b/drivers/189pc/driver.go @@ -210,12 +210,14 @@ func (y *Cloud189PC) Link(ctx context.Context, file model.Obj, args model.LinkAr } exp := time.Hour - like := &model.Link{ + link := &model.Link{ Expiration: &exp, - URL: downloadUrl.URL, + URL: downloadUrl.URL + fmt.Sprintf("#storageId=%d", y.ID), Header: http.Header{ "User-Agent": []string{base.UserAgent}, }, + Concurrency: y.Concurrency, + PartSize: y.ChunkSize * utils.KB, } /* // 获取链接有效时常 @@ -228,7 +230,7 @@ func (y *Cloud189PC) Link(ctx context.Context, file model.Obj, args model.LinkAr } } */ - return like, nil + return link, nil } func (y *Cloud189PC) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) (model.Obj, error) { diff --git a/drivers/189pc/extension.go b/drivers/189pc/extension.go index cc33e538..49836e52 100644 --- a/drivers/189pc/extension.go +++ b/drivers/189pc/extension.go @@ -8,6 +8,7 @@ import ( "encoding/base64" "encoding/pem" "errors" + "fmt" "github.com/OpenListTeam/OpenList/v4/drivers/base" "github.com/OpenListTeam/OpenList/v4/internal/conf" "github.com/OpenListTeam/OpenList/v4/internal/model" @@ -120,10 +121,12 @@ func (y *Cloud189PC) GetShareLink(shareId int, file model.Obj) (*model.Link, err exp := time.Hour link := &model.Link{ Expiration: &exp, - URL: url, + URL: url + fmt.Sprintf("#storageId=%d", y.ID), Header: http.Header{ "User-Agent": []string{base.UserAgent}, }, + Concurrency: y.Concurrency, + PartSize: y.ChunkSize * utils.KB, } log.Debugf("使用直链播放:%v", url) return link, nil diff --git a/drivers/189pc/meta.go b/drivers/189pc/meta.go index 0713932a..cbfb6498 100644 --- a/drivers/189pc/meta.go +++ b/drivers/189pc/meta.go @@ -22,6 +22,9 @@ type Addition struct { AutoCheckin bool `json:"auto_checkin"` Cookie string `json:"cookie"` + + Concurrency int `json:"concurrency" type:"number" default:"1"` + ChunkSize int `json:"chunk_size" type:"number" default:"1024"` } var config = driver.Config{