XiuXianProject/GameClient/Assets/Game/Launcher/Version/VersionController.cs

using GFGGame.Launcher;
using System;
using System.Collections;
using UnityEngine;
using YooAsset;

namespace GFGGame
{
    public class VersionController : SingletonMonoBase<VersionController>
    {
        public const string DefaultPackage = "GameLogic";
        string defaultHostServer = "http://127.0.0.1/CDN/Android/v1.0";
        string fallbackHostServer = "http://127.0.0.1/CDN/Android/v1.0";

        public ResourcePackage package;

        /// <summary>
        /// 包裹的版本信息
        /// </summary>
        public string PackageVersion { set; get; }


        public void Init()
        {
            // 初始化资源系统
            YooAssets.Initialize();
            StartCoroutine(InitVersion());
        }

        public IEnumerator InitVersion()
        {
            yield return InitDefaultPackage();
            if (string.IsNullOrEmpty(LauncherConfig.manifest_v))
            {
                var cor = StartCoroutine(GetStaticVersion(DefaultPackage));
                yield return cor;
            }
            else
            {
                VersionController.Instance.PackageVersion = LauncherConfig.manifest_v;
            }
            yield return UpdateManifest(DefaultPackage);
            CreateDownloader(DefaultPackage);
        
        }

        private IEnumerator InitDefaultPackage()
        {
            // 创建默认的资源包
            //string packageName = DefaultPackage;
            //var package = YooAssets.TryGetPackage(packageName);
            //Debug.Log($"是否找到包：{package}");
            //if (package == null)
            //{
            //    package = YooAssets.CreatePackage(packageName);
            //    YooAssets.SetDefaultPackage(package);
            //}

            package = YooAssets.CreatePackage(DefaultPackage);
            YooAssets.SetDefaultPackage(package);

            var playMode = GameLauncher.Instance.PlayMode;

#if UNITY_EDITOR 

#elif UNITY_WEBGL            
            playMode = EPlayMode.WebPlayMode;
#endif

            InitializationOperation initializationOperation = null;
            if (playMode == EPlayMode.EditorSimulateMode)
            {
                // 编辑器下的模拟模式
                //var createParameters = new EditorSimulateModeParameters();
                //createParameters.SimulateManifestFilePath = EditorSimulateModeHelper.SimulateBuild(packageName);
                //initializationOperation = package.InitializeAsync(createParameters);

                var buildResult = EditorSimulateModeHelper.SimulateBuild(DefaultPackage);
                var packageRoot = buildResult.PackageRootDirectory;
                var fileSystemParams = FileSystemParameters.CreateDefaultEditorFileSystemParameters(packageRoot);

                var createParameters = new EditorSimulateModeParameters();
                createParameters.EditorFileSystemParameters = fileSystemParams;

                initializationOperation = package.InitializeAsync(createParameters);
                yield return initializationOperation;

                if (initializationOperation.Status == EOperationStatus.Succeed)
                    Debug.Log("资源包初始化成功！");
                else
                    Debug.LogError($"资源包初始化失败：{initializationOperation.Error}");

            }
            else if (playMode == EPlayMode.HostPlayMode)
            {
                // 联机运行模式
                //string defaultHostServer = GetHostServerURL(DefaultPackage);
                //string fallbackHostServer = defaultHostServer;
                //var createParameters = new HostPlayModeParameters();
                //createParameters.DecryptionServices = new GameDecryptionServices();
                //createParameters.QueryServices = new GameQueryServices();
                //createParameters.RemoteServices = new RemoteServices(defaultHostServer, fallbackHostServer);
                //initializationOperation = package.InitializeAsync(createParameters);

                var fileSystemParams = FileSystemParameters.CreateDefaultBuildinFileSystemParameters();

                var createParameters = new OfflinePlayModeParameters();
                createParameters.BuildinFileSystemParameters = fileSystemParams;

                initializationOperation = package.InitializeAsync(createParameters);
                yield return initializationOperation;

                if (initializationOperation.Status == EOperationStatus.Succeed)
                    Debug.Log("资源包初始化成功！");
                else
                    Debug.LogError($"资源包初始化失败：{initializationOperation.Error}");
            }
            else if (playMode == EPlayMode.HostPlayMode)
            {
                IRemoteServices remoteServices = new RemoteServices(defaultHostServer, fallbackHostServer);
                var cacheFileSystemParams = FileSystemParameters.CreateDefaultCacheFileSystemParameters(remoteServices);
                var buildinFileSystemParams = FileSystemParameters.CreateDefaultBuildinFileSystemParameters();

                var createParameters = new HostPlayModeParameters();
                createParameters.BuildinFileSystemParameters = buildinFileSystemParams;
                createParameters.CacheFileSystemParameters = cacheFileSystemParams;

                initializationOperation = package.InitializeAsync(createParameters);
                yield return initializationOperation;

                if (initializationOperation.Status == EOperationStatus.Succeed)
                    Debug.Log("资源包初始化成功！");
                else
                    Debug.LogError($"资源包初始化失败：{initializationOperation.Error}");
            }
            else if (playMode == EPlayMode.WebPlayMode)
            {
                Debug.Log("进入EPlayMode.WebPlayMode");
                defaultHostServer = Application.streamingAssetsPath + "\\yoo\\GameLogic\\";
                fallbackHostServer = Application.streamingAssetsPath + "\\yoo\\GameLogic\\";
                IRemoteServices remoteServices = new RemoteServices(defaultHostServer, fallbackHostServer);
                //var webServerFileSystemParams = FileSystemParameters.CreateDefaultWebServerFileSystemParameters();
                var webRemoteFileSystemParams = FileSystemParameters.CreateDefaultWebRemoteFileSystemParameters(remoteServices); //支持跨域下载
                var createParameters = new WebPlayModeParameters();
                //createParameters.WebServerFileSystemParameters = webServerFileSystemParams;
                createParameters.WebRemoteFileSystemParameters = webRemoteFileSystemParams;
                initializationOperation = package.InitializeAsync(createParameters);

                yield return initializationOperation;
                if (initializationOperation.Status == EOperationStatus.Succeed)
                    Debug.Log("资源包初始化成功！");
                else
                    Debug.LogError($"资源包初始化失败：{initializationOperation.Error}");

            }

            yield return initializationOperation;
            if (initializationOperation.Status != EOperationStatus.Succeed)
            {
                Debug.LogWarning($"{initializationOperation.Error}");
            }
        }

        private IEnumerator GetStaticVersion(string packageName)
        {
            //var package = YooAssets.GetPackage(packageName);
            Debug.Log(package.PackageName);
            //var operation = package.UpdatePackageVersionAsync();
            var operation = package.RequestPackageVersionAsync();
            yield return operation;

            if (operation.Status == EOperationStatus.Succeed)
            {
                VersionController.Instance.PackageVersion = operation.PackageVersion;
                Debug.Log($"远端最新版本为: {operation.PackageVersion}");
            }
            else
            {
                Debug.LogWarning(operation.Error);
            }
        }

        private IEnumerator UpdateManifest(string packageName)
        {
            bool savePackageVersion = true;
            //var package = YooAssets.GetPackage(packageName);
            var operation =
                package.UpdatePackageManifestAsync(VersionController.Instance.PackageVersion);
            //package.UpdatePackageManifestAsync(VersionController.Instance.PackageVersion, savePackageVersion);
            yield return operation;
            if (operation.Status != EOperationStatus.Succeed)
            {
                Debug.LogWarning(operation.Error);
                Alert.Show("更新版本信息失败，请检测网络链接后重试。")
                    .SetLeftButton(true, "重试", (data) => { StartCoroutine(UpdateManifest(packageName)); });
            }
        }

        private void CreateDownloader(string packageName)
        {

            LauncherController.OnVersionCompleted();
            return;

            int downloadingMaxNum = 10;
            int failedTryAgain = 3;
           // ResourcePackage package = YooAssets.GetPackage(packageName);
            //ResourceDownloaderOperation downloaderOperation = package.CreateResourceDownloader(new string[] { "preload", "dynamic" }, downloadingMaxNum, failedTryAgain);
            ResourceDownloaderOperation downloaderOperation =
                package.CreateResourceDownloader(new string[] { "preload" }, downloadingMaxNum, failedTryAgain);
            if (downloaderOperation.TotalDownloadCount == 0)
            {
                LauncherController.OnVersionCompleted();
            }
            else
            {
                //A total of 10 files were found that need to be downloaded
                Debug.Log($"Found total {downloaderOperation.TotalDownloadCount} files that need download ！");
                // 发现新更新文件后，挂起流程系统
                // 注意：开发者需要在下载前检测磁盘空间不足
                //int totalDownloadCount = downloaderOperation.TotalDownloadCount;
                long totalDownloadBytes = downloaderOperation.TotalDownloadBytes;
                float sizeMB = totalDownloadBytes / 1048576f;
                sizeMB = Mathf.Clamp(sizeMB, 0.1f, float.MaxValue);
                if (sizeMB > LauncherConfig.promptSizeMB)
                {
                    string totalSizeMB = sizeMB.ToString("f1");
                    if (string.IsNullOrEmpty(LauncherConfig.updateResPrompt))
                    {
                        LauncherConfig.updateResPrompt = "游戏有新的内容，需要更新{0}MB大小的资源";
                    }

                    string message = string.Format(LauncherConfig.updateResPrompt, totalSizeMB);
                    Alert.Show(message)
                        .SetLeftButton(true, "更新",
                            (data) => { StartCoroutine(BeginDownload(downloaderOperation, packageName)); });
                }
                else
                {
                    StartCoroutine(BeginDownload(downloaderOperation, packageName));
                }
            }
        }

        private IEnumerator BeginDownload(ResourceDownloaderOperation downloaderOperation, string packageName)
        {
            // 注册下载回调
            downloaderOperation.DownloadErrorCallback = (data) => {
                Debug.LogError($"" +
                                      $"加载{data.FileName}失败 {data.ErrorInfo}");
            };
            downloaderOperation.DownloadUpdateCallback = (data) =>
            {
                //string currentSizeMB = (currentDownloadSizeBytes / 1048576f).ToString("f1");
                //string totalSizeMB = (totalDownloadSizeBytes / 1048576f).ToString("f1");
                //var progress = (float)currentDownloadSizeBytes / totalDownloadSizeBytes;
                //LauncherView.Instance.SetDesc($"正在下载资源，{currentDownloadCount}/{totalDownloadCount}",
                //    $"{currentSizeMB}MB/{totalSizeMB}MB", true);
                //LauncherView.Instance.SetProgress((int)(progress * 100));

                string currentSizeMB = (data.CurrentDownloadBytes / 1048576f).ToString("f1");
                string totalSizeMB = (data.TotalDownloadBytes / 1048576f).ToString("f1");
                var progress = (float)data.CurrentDownloadBytes / data.TotalDownloadBytes;
                LauncherView.Instance.SetDesc($"正在下载资源，{data.CurrentDownloadCount}/{data.TotalDownloadCount}",
                    $"{currentSizeMB}MB/{totalSizeMB}MB", true);
                LauncherView.Instance.SetProgress((int)(progress * 100));
            };
                
            downloaderOperation.BeginDownload();
            yield return downloaderOperation;

            // 检测下载结果
            if (downloaderOperation.Status != EOperationStatus.Succeed)
            {
                Alert.Show("下载失败！请检查网络状态后重试。")
                    .SetLeftButton(true, "重试",
                        (data) => { StartCoroutine(BeginDownload(downloaderOperation, packageName)); });
                yield break;
            }

            LauncherController.OnVersionCompleted();
        }

        /// <summary>
        /// 获取资源服务器地址
        /// </summary>
        private string GetHostServerURL(string packageName)
        {
            //LauncherConfig.CDN_ROOT = "http://10.108.64.127";

            string platform = "PC";
#if UNITY_EDITOR
            if (UnityEditor.EditorUserBuildSettings.activeBuildTarget == UnityEditor.BuildTarget.Android)
                platform = "Android";
            else if (UnityEditor.EditorUserBuildSettings.activeBuildTarget == UnityEditor.BuildTarget.iOS)
                platform = "IOS";
            else if (UnityEditor.EditorUserBuildSettings.activeBuildTarget == UnityEditor.BuildTarget.WebGL)
                platform = "WebGL";
#else
		if (Application.platform == RuntimePlatform.Android)
                platform = "Android";
		else if (Application.platform == RuntimePlatform.IPhonePlayer)
                platform = "IOS";
		else if (Application.platform == RuntimePlatform.WebGLPlayer)
                platform = "WebGL";
#endif
            return $"{LauncherConfig.CDN_ROOT}/{platform}/{packageName}/HostPlay";
        }

        /// <summary>
        /// 远端资源地址查询服务类
        /// </summary>
        private class RemoteServices : IRemoteServices
        {
            private readonly string _defaultHostServer;
            private readonly string _fallbackHostServer;

            public RemoteServices(string defaultHostServer, string fallbackHostServer)
            {
                _defaultHostServer = defaultHostServer;
                _fallbackHostServer = fallbackHostServer;
            }

            string IRemoteServices.GetRemoteMainURL(string fileName)
            {
                return $"{_defaultHostServer}/{fileName}";
            }

            string IRemoteServices.GetRemoteFallbackURL(string fileName)
            {
                return $"{_fallbackHostServer}/{fileName}";
            }
        }
    }
}