import sparkMD5 from 'spark-md5' // 安裝下spark-md5包

// 定義hash函數(shù)，接受一個(gè)名為chunks的數(shù)組作為參數(shù)
hash = (chunks) => {
  // 返回一個(gè)Promise，這樣調(diào)用者可以使用.then()或async/await來處理結(jié)果
  return new Promise((resolve) => {
    // 創(chuàng)建一個(gè)新的sparkMD5實(shí)例，用于計(jì)算MD5哈希值
    const spark = new sparkMD5();

    // 定義一個(gè)遞歸函數(shù)_read，用于逐個(gè)處理chunks數(shù)組中的blob
    function _read(i) {
      // 如果索引i大于等于chunks數(shù)組的長(zhǎng)度，說明所有blob都已經(jīng)處理完畢
      if (i >= chunks.length) {
        // 調(diào)用sparkMD5實(shí)例的end方法，并傳入resolve回調(diào)，以返回最終的哈希值
        resolve(spark.end());
        return; // 讀取完成，退出函數(shù)
      }

      // 獲取當(dāng)前索引i對(duì)應(yīng)的blob
      const blob = chunks[i];

      // 創(chuàng)建一個(gè)新的FileReader實(shí)例，用于讀取blob的內(nèi)容
      const reader = new FileReader();

      // 設(shè)置FileReader的onload事件處理函數(shù)，當(dāng)blob內(nèi)容讀取完成后調(diào)用
      reader.onload = e => {
        // 從事件對(duì)象e中獲取讀取到的字節(jié)數(shù)組
        const bytes = e.target.result;

        // 將字節(jié)數(shù)組添加到sparkMD5實(shí)例中，用于計(jì)算哈希值
        spark.append(bytes);

        // 遞歸調(diào)用_read函數(shù)，處理下一個(gè)blob
        _read(i + 1);
      };

      // 以ArrayBuffer格式異步讀取當(dāng)前blob的內(nèi)容
      reader.readAsArrayBuffer(blob); // 這里是讀取操作開始的地方
    }

    // 從索引0開始，調(diào)用_read函數(shù)，處理chunks數(shù)組中的第一個(gè)blob
    _read(0);
  });
};

const md5Str = await this.hash(chunksList);
/* 這里寫發(fā)送md5Str【接口1】 的方法，獲取已上傳片數(shù) */

chunkFile = (file, chunksize) => {  
    const chunks = Math.ceil(file.size / chunksize);  
    const chunksList = [];  
    let currentChunk = 0;  
    while (currentChunk < chunks) {  
        const start = currentChunk * chunksize;  
        const end = Math.min(file.size, start + chunksize);  
        const chunk = file.slice(start, end);  
        chunksList.push(chunk);  
        currentChunk++;  
    }  
    return chunksList;  
};

chunkPromise = data => { //每個(gè)分片的請(qǐng)求
	return new Promise((resolve, reject) => { 
		/* 這里寫上傳的 【接口2】，傳data過去*/
	}).catch(err => {
		message.error(err.msg);
		reject();
	})
}
	 const promiseList = []
	 const chunkList = chunkFile(file, size)
	 chunkList.map(item => {
	 const formData = new FormData();
	 formData.append('file', item)
	 // limit是線程池組件 后面會(huì)寫
	 promiseList.push(limit(() => this.chunkPromise(formData, chunks)))
})

const pLimit = require('p-limit');
const limit = pLimit(2);

const input = [
  limit(() => fetchSomething('foo')),
  limit(() => fetchSomething('bar')),
  limit(() => doSomethingElse()),
];

// Only two promises will run at once, the rest will be queued
Promise.all(input).then(results => {
  console.log(results);
});

	Promise.all(promiseList).then(res =>{
		// 這里寫接口3 問后端是否合并成功了
	}).catch(err => {
		message.error(err.msg);
	})

const md5Str = await this.hash(chunksList);
/* 這里寫發(fā)送md5Str【接口1】 的方法，獲取已上傳片數(shù) */
const promiseList = []
const chunkList = this.chunkFile(file, size)
chunkList.map(item => {
	const formData = new FormData();
	formData.append('file', item)
	promiseList.push(limit(() => this.chunkPromise(formData, chunks))) // 【接口2 在this.chunkPromise里】
}
Promise.all(promiseList).then(res =>{
		// 這里寫【接口3】 問后端是否合并成功了
	}).catch(err => {
		message.error(err.msg);
	})