|
|
|
@@ -3,7 +3,6 @@ package services |
|
|
|
import ( |
|
|
|
"context" |
|
|
|
"fmt" |
|
|
|
"time" |
|
|
|
|
|
|
|
"github.com/samber/lo" |
|
|
|
"gitlink.org.cn/cloudream/common/pkgs/ioswitch/exec" |
|
|
|
@@ -240,14 +239,14 @@ func (svc *UserSpaceService) DownloadPackage(packageID clitypes.PackageID, users |
|
|
|
dstPath := rootJPath.ConcatNew(objPath) |
|
|
|
ft.AddTo(ioswitch2.NewToBaseStore(*destStg, dstPath)) |
|
|
|
// 顺便保存到同存储服务的分片存储中 |
|
|
|
if destStg.UserSpace.ShardStore != nil { |
|
|
|
ft.AddTo(ioswitch2.NewToShardStore(*destStg, ioswitch2.RawStream(), "")) |
|
|
|
pinned = append(pinned, clitypes.PinnedObject{ |
|
|
|
ObjectID: details[dIndex].Object.ObjectID, |
|
|
|
UserSpaceID: destStg.UserSpace.UserSpaceID, |
|
|
|
CreateTime: time.Now(), |
|
|
|
}) |
|
|
|
} |
|
|
|
// if destStg.UserSpace.ShardStore != nil { |
|
|
|
// ft.AddTo(ioswitch2.NewToShardStore(*destStg, ioswitch2.RawStream(), "")) |
|
|
|
// pinned = append(pinned, clitypes.PinnedObject{ |
|
|
|
// ObjectID: details[dIndex].Object.ObjectID, |
|
|
|
// UserSpaceID: destStg.UserSpace.UserSpaceID, |
|
|
|
// CreateTime: time.Now(), |
|
|
|
// }) |
|
|
|
// } |
|
|
|
|
|
|
|
err = parser.Parse(ft, plans) |
|
|
|
if err != nil { |
|
|
|
|