GHZMRNavigatorProXR/Assets/COSScripts/DownloadResManager.cs

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Text;
using UnityEngine;

public class DownloadResManager : MonoSingleton<DownloadResManager>
{
    /// <summary>
    ///  本地已下载素材列表
    /// </summary>
    private List<DownLoadMaterial> listCompletedMaterial;

    /// <summary>
    ///  未下载素材列表
    /// </summary>
    private List<DownLoadMaterial> listNotMaterial;

    /// <summary>
    ///  下载失败素材列表
    /// </summary>
    private List<DownLoadMaterial> listFaildMaterial;

    private Queue<DownLoadMaterial> qDownload;
    private int maxDownLoad = 1;
    private int nowDownLoad = 0;
    private string path;
    // Start is called before the first frame update
    void Start()
    {
        path = Application.persistentDataPath + "/Material/";
        listNotMaterial = new List<DownLoadMaterial>();
        listFaildMaterial = new List<DownLoadMaterial>();
        qDownload = new Queue<DownLoadMaterial>();
        //先判断是否存在，再创建
        if (!File.Exists(path))
        {
            Directory.CreateDirectory(path);
        }
        else
        {
            string msg = File.ReadAllText(path + "/CompletedMaterial.txt");
            listCompletedMaterial = JsonConvert.DeserializeObject<List<DownLoadMaterial>>(msg);
        }
        if (listCompletedMaterial == null)
            listCompletedMaterial = new List<DownLoadMaterial>();

        for (int i = 0; i < listCompletedMaterial.Count; i++)
        {
            if(!File.Exists(listCompletedMaterial[i].localLoadPath))
            {
                listCompletedMaterial.RemoveAt(i);
            }
        }
        StartCoroutine(DownLoad());
    }

    /// <summary>
    ///  批量素材下载
    /// </summary>
    /// <param name="listDLMaterial"> 所有素材列表 </param>
    public void DownLoad(List<DownLoadMaterial> listDLMaterial)
    {
        Debug.Log(listDLMaterial.Count);
        for (int i = 0; i < listDLMaterial.Count; i++)
        {
            Screen(listDLMaterial[i]);
        }
     //   COSDownLoad cos = new COSDownLoad();
     //   COSDownLoad.Instance.TransferBatchDownloadObjects(listNotMaterial, path);

    }

    /// <summary>
    ///  单个素材下载
    /// </summary>
    /// <param name="downloadMaterial"></param>
    public void DownLoad(DownLoadMaterial downloadMaterial)
    {
        //Debug.LogError("单个素材下载   " + downloadMaterial.downLoadPath);
        //List<DownLoadMaterial> list = new List<DownLoadMaterial>();
        //list.Add(downloadMaterial);
        // COSDownLoad.Instance.TransferBatchDownloadObjects(list, path);

        if (Screen(downloadMaterial) == false)
        {
            //List<DownLoadMaterial> list = new List<DownLoadMaterial>();
            //list.Add(downloadMaterial);
         //   COSDownLoad.Instance.TransferBatchDownloadObjects(list, path);
        }
        else
        {
            LocalLoadManager.Instance.LocalLoadMaterial(downloadMaterial);
        }
    }

    private IEnumerator DownLoad()
    {
      

        while(true)
        {
            yield return new WaitForFixedUpdate();
            if (qDownload.Count>0 && nowDownLoad<maxDownLoad)
            {
                nowDownLoad++;
                COSDownLoad.Instance.TransferDownloadObject(qDownload.Dequeue(), path);
            }
        }

    }

    /// <summary>
    /// 检测
    /// </summary>
    /// <param name="downloadMaterial"></param>
    /// <returns></returns>
    private bool Screen(DownLoadMaterial downloadMaterial)
    {
       bool  finish = false;
        for (int j = 0; j < listCompletedMaterial.Count; j++)
        {
            if (downloadMaterial.downLoadPath == listCompletedMaterial[j].downLoadPath)
            {
                if (downloadMaterial.updataTime == listCompletedMaterial[j].updataTime)
                    finish = true;
            }
        }

        if (!finish)
        {
            listNotMaterial.Add(downloadMaterial);
            qDownload.Enqueue(downloadMaterial);
        }
          

        return finish;
    }

    /// <summary>
    ///  下载成功
    /// </summary>
    /// <param name="localFilePath"></param>
    public void DownLoadCompleted(string localFilePath)
    {

        nowDownLoad--;
        for (int i = 0; i < listNotMaterial.Count; i++)
        {
            Debug.Log("Hjj   DownLoadCompleted :" + listNotMaterial[i].downLoadPath + "——" + localFilePath);
            if (Path.GetFileName( listNotMaterial[i].downLoadPath) == localFilePath)
            {
                listCompletedMaterial.Add(listNotMaterial[i]);              
                LocalLoadManager.Instance.LocalLoadMaterial(listNotMaterial[i]);
                listNotMaterial.RemoveAt(i);
                break;
            }
        }
    }

    /// <summary>
    ///  下载失败
    /// </summary>
    /// <param name="localFilePath"></param>
    public void DownLoadFaild(string localFilePath)
    {
        nowDownLoad--;
        for (int i = 0; i < listNotMaterial.Count; i++)
        {
            Debug.Log("Hjj   DownLoadFaild :" + listNotMaterial[i].downLoadPath + "——" + localFilePath);
            if (Path.GetFileName(listNotMaterial[i].downLoadPath) == localFilePath)
            {
                listFaildMaterial.Add(listNotMaterial[i]);
                MsgHandler.SendMsg(listNotMaterial[i].localLoadPath, null);
                listNotMaterial.RemoveAt(i);
                break;
            }
        }
    }

    private void OnDisable()
    {
        string msg = JsonConvert.SerializeObject(listCompletedMaterial);
        Debug.Log(msg);
        System.IO.Directory.CreateDirectory(path);
       // string NowTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss").Replace(" ", "_").Replace("/", "_").Replace(":", "_");
        Debug.Log(path);
        using (System.IO.StreamWriter writer = System.IO.File.CreateText(path + "/CompletedMaterial.txt"))
        {
            writer.Write(msg);
            //writer.
        }  
    }
}

public class MaterailDetail
{
    public int id { get; set; }
}

public class DownLoadMaterial
{
    public string downLoadPath { get; set; }
    public string localLoadPath { get; set; }
    public long updataTime { get; set; }

    public string type { get; set; }

    
}