189 Concurrency

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
 }

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) {

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

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{