using System; using System.IO; using System.Collections.Generic; using UnityEngine; namespace YooAsset { /// /// 内置文件系统 /// internal class DefaultBuildinFileSystem : IFileSystem { private class UnpackRemoteServices : IRemoteServices { private readonly string _buildinPackageRoot; protected readonly Dictionary _mapping = new Dictionary(10000); public UnpackRemoteServices(string buildinPackRoot) { _buildinPackageRoot = buildinPackRoot; } string IRemoteServices.GetRemoteMainURL(string fileName) { return GetFileLoadURL(fileName); } string IRemoteServices.GetRemoteFallbackURL(string fileName) { return GetFileLoadURL(fileName); } private string GetFileLoadURL(string fileName) { if (_mapping.TryGetValue(fileName, out string url) == false) { string filePath = PathUtility.Combine(_buildinPackageRoot, fileName); url = DownloadSystemHelper.ConvertToWWWPath(filePath); _mapping.Add(fileName, url); } return url; } } public class FileWrapper { public string FileName { private set; get; } public FileWrapper(string fileName) { FileName = fileName; } } protected readonly Dictionary _wrappers = new Dictionary(10000); protected readonly Dictionary _loadedStream = new Dictionary(10000); protected readonly Dictionary _buildinFilePaths = new Dictionary(10000); protected IFileSystem _unpackFileSystem; protected string _packageRoot; /// /// 包裹名称 /// public string PackageName { private set; get; } /// /// 文件根目录 /// public string FileRoot { get { return _packageRoot; } } /// /// 文件数量 /// public int FileCount { get { return _wrappers.Count; } } #region 自定义参数 /// /// 自定义参数:初始化的时候缓存文件校验级别 /// public EFileVerifyLevel FileVerifyLevel { private set; get; } = EFileVerifyLevel.Middle; /// /// 自定义参数:数据文件追加文件格式 /// public bool AppendFileExtension { private set; get; } = false; /// /// 自定义参数:原生文件构建管线 /// public bool RawFileBuildPipeline { private set; get; } = false; #endregion public DefaultBuildinFileSystem() { } public virtual FSInitializeFileSystemOperation InitializeFileSystemAsync() { #if UNITY_EDITOR var operation = new DBFSInitializeInEditorPlayModeOperation(this); OperationSystem.StartOperation(PackageName, operation); return operation; #else var operation = new DBFSInitializeOperation(this); OperationSystem.StartOperation(PackageName, operation); return operation; #endif } public virtual FSLoadPackageManifestOperation LoadPackageManifestAsync(string packageVersion, int timeout) { var operation = new DBFSLoadPackageManifestOperation(this); OperationSystem.StartOperation(PackageName, operation); return operation; } public virtual FSRequestPackageVersionOperation RequestPackageVersionAsync(bool appendTimeTicks, int timeout) { var operation = new DBFSRequestPackageVersionOperation(this); OperationSystem.StartOperation(PackageName, operation); return operation; } public virtual FSClearAllBundleFilesOperation ClearAllBundleFilesAsync() { return _unpackFileSystem.ClearAllBundleFilesAsync(); } public virtual FSClearUnusedBundleFilesOperation ClearUnusedBundleFilesAsync(PackageManifest manifest) { return _unpackFileSystem.ClearUnusedBundleFilesAsync(manifest); } public virtual FSDownloadFileOperation DownloadFileAsync(PackageBundle bundle, DownloadParam param) { param.ImportFilePath = GetBuildinFileLoadPath(bundle); return _unpackFileSystem.DownloadFileAsync(bundle, param); } public virtual FSLoadBundleOperation LoadBundleFile(PackageBundle bundle) { if (NeedUnpack(bundle)) { return _unpackFileSystem.LoadBundleFile(bundle); } if (RawFileBuildPipeline) { var operation = new DBFSLoadRawBundleOperation(this, bundle); OperationSystem.StartOperation(PackageName, operation); return operation; } else { var operation = new DBFSLoadAssetBundleOperation(this, bundle); OperationSystem.StartOperation(PackageName, operation); return operation; } } public virtual void UnloadBundleFile(PackageBundle bundle, object result) { AssetBundle assetBundle = result as AssetBundle; if (assetBundle == null) return; if (_unpackFileSystem.Exists(bundle)) { _unpackFileSystem.UnloadBundleFile(bundle, assetBundle); } else { if (assetBundle != null) assetBundle.Unload(true); if (_loadedStream.TryGetValue(bundle.BundleGUID, out Stream managedStream)) { managedStream.Close(); managedStream.Dispose(); _loadedStream.Remove(bundle.BundleGUID); } } } public virtual void SetParameter(string name, object value) { if (name == "FILE_VERIFY_LEVEL") { FileVerifyLevel = (EFileVerifyLevel)value; } else if (name == "APPEND_FILE_EXTENSION") { AppendFileExtension = (bool)value; } else if (name == "RAW_FILE_BUILD_PIPELINE") { RawFileBuildPipeline = (bool)value; } else { YooLogger.Warning($"Invalid parameter : {name}"); } } public virtual void OnCreate(string packageName, string rootDirectory) { PackageName = packageName; if (string.IsNullOrEmpty(rootDirectory)) rootDirectory = GetDefaultRoot(); _packageRoot = PathUtility.Combine(rootDirectory, packageName); // 创建解压文件系统 var remoteServices = new UnpackRemoteServices(_packageRoot); _unpackFileSystem = new DefaultUnpackFileSystem(); _unpackFileSystem.SetParameter("REMOTE_SERVICES", remoteServices); _unpackFileSystem.SetParameter("FILE_VERIFY_LEVEL", FileVerifyLevel); _unpackFileSystem.SetParameter("APPEND_FILE_EXTENSION", AppendFileExtension); _unpackFileSystem.SetParameter("RAW_FILE_BUILD_PIPELINE", RawFileBuildPipeline); _unpackFileSystem.OnCreate(packageName, null); } public virtual void OnUpdate() { } public virtual bool Belong(PackageBundle bundle) { return _wrappers.ContainsKey(bundle.BundleGUID); } public virtual bool Exists(PackageBundle bundle) { return _wrappers.ContainsKey(bundle.BundleGUID); } public virtual bool NeedDownload(PackageBundle bundle) { return false; } public virtual bool NeedUnpack(PackageBundle bundle) { if (Belong(bundle) == false) return false; #if UNITY_ANDROID return RawFileBuildPipeline || bundle.Encrypted; #else return false; #endif } public virtual bool NeedImport(PackageBundle bundle) { return false; } #region 内部方法 protected string GetDefaultRoot() { return PathUtility.Combine(Application.streamingAssetsPath, YooAssetSettingsData.Setting.DefaultYooFolderName); } public string GetBuildinFileLoadPath(PackageBundle bundle) { if (_buildinFilePaths.TryGetValue(bundle.BundleGUID, out string filePath) == false) { filePath = PathUtility.Combine(_packageRoot, bundle.FileName); _buildinFilePaths.Add(bundle.BundleGUID, filePath); } return filePath; } public string GetBuildinCatalogFileLoadPath() { string fileName = Path.GetFileNameWithoutExtension(DefaultBuildinFileSystemDefine.BuildinCatalogFileName); return PathUtility.Combine(YooAssetSettingsData.Setting.DefaultYooFolderName, PackageName, fileName); } public string GetBuildinPackageVersionFilePath() { string fileName = YooAssetSettingsData.GetPackageVersionFileName(PackageName); return PathUtility.Combine(FileRoot, fileName); } public string GetBuildinPackageHashFilePath(string packageVersion) { string fileName = YooAssetSettingsData.GetPackageHashFileName(PackageName, packageVersion); return PathUtility.Combine(FileRoot, fileName); } public string GetBuildinPackageManifestFilePath(string packageVersion) { string fileName = YooAssetSettingsData.GetManifestBinaryFileName(PackageName, packageVersion); return PathUtility.Combine(FileRoot, fileName); } /// /// 记录文件信息 /// public bool RecordFile(string bundleGUID, FileWrapper wrapper) { if (_wrappers.ContainsKey(bundleGUID)) { YooLogger.Error($"{nameof(DefaultBuildinFileSystem)} has element : {bundleGUID}"); return false; } _wrappers.Add(bundleGUID, wrapper); return true; } /// /// 初始化解压文件系统 /// public FSInitializeFileSystemOperation InitializeUpackFileSystem() { return _unpackFileSystem.InitializeFileSystemAsync(); } #endregion } }