GHZMRNavigatorProXR/Assets/COSScripts/LocalLoadManager.cs

using LitJson;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using UnityEngine;
using UnityEngine.Networking;

public class LocalLoadManager : MonoSingleton<LocalLoadManager>
{
    /// <summary>
    /// 已下载资源
    /// </summary>
  private  Dictionary<string, byte[]> dicLoaclData = new Dictionary<string, byte[]>();

    public void test()
    {
        Debug.Log("Hjj   test");
    }

    public void LocalLoadMaterial(DownLoadMaterial downloadMaterial)
    {

        //Debug.Log("Hjj   LocalLoadMaterial :" + downloadMaterial.localLoadPath + "    " + downloadMaterial.type);
        if (dicLoaclData.ContainsKey(downloadMaterial.downLoadPath))
        {
         //   Debug.Log("Hjj   LocalLoadMaterial 1 :" + downloadMaterial.localLoadPath + "    ");
            MsgHandler.SendMsg(downloadMaterial.downLoadPath, new Msg(downloadMaterial.downLoadPath, dicLoaclData[downloadMaterial.downLoadPath]));
        }
        else
        {
          //  Debug.Log("Hjj   LocalLoadMaterial 2 :" + downloadMaterial.localLoadPath + "    ");
           // StartCoroutine(DownloadFile(downloadMaterial));
            StartCoroutine(DownloadFileIO(downloadMaterial));
        }
    }

    private System.Collections.IEnumerator DownloadFile(DownLoadMaterial downloadMaterial)
    {
        bool isDownLoad;

        Debug.Log("Hjj   DownloadFile :" + downloadMaterial.localLoadPath + "    " + downloadMaterial.type);
        using (UnityWebRequest webRequest = new UnityWebRequest(downloadMaterial.localLoadPath, UnityWebRequest.kHttpVerbGET))
        {
            webRequest.downloadHandler = (DownloadHandler)new DownloadHandlerBuffer();

            webRequest.SetRequestHeader("authorization", UserInfo.Instance.Token);
            webRequest.SetRequestHeader("Content-Type", "application/json");

            Debug.Log("Hjj   DownloadFile start:" + downloadMaterial.localLoadPath + "    ");
            yield return webRequest.SendWebRequest();

            Debug.Log("Hjj   DownloadFile end:" + downloadMaterial.localLoadPath + "    ");
            while (!webRequest.isDone)
            {
                // 此处可以显示下载进度条等UI操作
                //progress = webRequest.downloadProgress;
                //onProgress?.Invoke(progress);
                // Debug.Log("Download Progress: " + progress);
                yield return new WaitForFixedUpdate();
            }

            if (webRequest.isHttpError || webRequest.isNetworkError)
            {
                Debug.LogError("Hjj   DownloadFile end:" + downloadMaterial.localLoadPath + "Download Failed: " + webRequest.error);
                // 下载失败 
                //downLoadState = webRequest.error;
                isDownLoad = false;
                MsgHandler.SendMsg(downloadMaterial.downLoadPath, new Msg(downloadMaterial.downLoadPath, null));
            }
            else
            {
                Debug.Log("Hjj   DownloadFile isDone:"+webRequest.isDone + "    " + webRequest.downloadHandler.data.Length);
                // Debug.LogError("Download Failed: " + webRequest.error);

                dicLoaclData.Add(downloadMaterial.downLoadPath, webRequest.downloadHandler.data);
                isDownLoad = true;
                MsgHandler.SendMsg(downloadMaterial.downLoadPath, new Msg(downloadMaterial.downLoadPath, webRequest.downloadHandler.data));
            }
           
        }

    }


    /// <summary>
    /// 读取本地数据
    /// </summary>
    private void ReadLocaData(DownLoadMaterial downloadMaterial)
    {
       
    }

    IEnumerator DownloadFileIO(DownLoadMaterial downloadMaterial)
    {

        if (!File.Exists(downloadMaterial.localLoadPath))
        {
            Debug.Log("DGJ  ====》 文件不存在 " + downloadMaterial.localLoadPath);
            MsgHandler.SendMsg(downloadMaterial.downLoadPath, new Msg(downloadMaterial.downLoadPath, null));
        }
        else
        {
            using (FileStream fs = new FileStream(downloadMaterial.localLoadPath, FileMode.Open))
            {
                long fileSize = new FileInfo(downloadMaterial.localLoadPath).Length;

                byte[] buffer = new byte[fileSize]; // 设置一个读取缓冲区

                int bytesRead;
                while ((bytesRead = fs.Read(buffer, 0, buffer.Length)) > 0)
                {
                    // 在这里处理读取到的数据
                    // Console.WriteLine("Read " + bytesRead + " bytes.");
                }

                yield return bytesRead == 0;
                dicLoaclData.Add(downloadMaterial.downLoadPath, buffer);
                // isDownLoad = true;
                MsgHandler.SendMsg(downloadMaterial.downLoadPath, new Msg(downloadMaterial.downLoadPath, buffer));

            }
        }
          
    }

}