新增列表多选操作功能

2019-08-19 18:19:39 +08:00
parent 8817318a53
commit 601e1a67a1
26 changed files with 750 additions and 192 deletions
@@ -2,18 +2,30 @@ import download from '../../utils/download'
 import fs from 'fs'
 import path from 'path'
 import music from '../../utils/music'
+import { getMusicType } from '../../utils/music/utils'

 // state
 const state = {
  list: [],
+  waitingList: [],
+  downloadStatus: {
+    RUN: 'run',
+    WAITING: 'waiting',
+    PAUSE: 'pause',
+    ERROR: 'error',
+    COMPLETED: 'completed',
+  },
 }

+
 const dls = {}
+const tryNum = {}

 // getters
 const getters = {
  list: state => state.list || [],
  dls: () => dls || {},
+  downloadStatus: state => state.downloadStatus,
 }

 const checkPath = path => {
@@ -40,19 +52,37 @@ const getExt = type => {

 const checkList = (list, musicInfo, type) => list.some(s => s.musicInfo.songmid === musicInfo.songmid && s.type === type)

+const getStartTask = (list, downloadStatus, maxDownloadNum) => {
+  let downloadCount = 0
+  const waitList = list.filter(item => item.status == downloadStatus.WAITING ? true : (item.status === downloadStatus.RUN && ++downloadCount && false))
+  console.log(downloadCount, waitList)
+  return downloadCount < maxDownloadNum && waitList.length > 0 && waitList.shift()
+}
+
+const addTask = (list, type, store) => {
+  window.requestAnimationFrame(() => {
+    let item = list.shift()
+    store.dispatch('download/createDownload', {
+      musicInfo: item,
+      type: getMusicType(item, type),
+    })
+    if (list.length) addTask(list, type, store)
+  })
+}
+
 const refreshUrl = downloadInfo => {
  return music[downloadInfo.musicInfo.source].getMusicUrl(downloadInfo.musicInfo, downloadInfo.type).promise
 }

 // actions
 const actions = {
-  createDownload({ state, rootState }, { musicInfo, type }) {
+  createDownload({ state, rootState, commit }, { musicInfo, type }) {
    if (checkList(state.list, musicInfo, type)) return
    let ext = getExt(type)
    const downloadInfo = {
      isComplate: false,
-      isDownloading: false,
-      statusText: '任务初始化中',
+      status: state.downloadStatus.WAITING,
+      statusText: '待下载',
      url: null,
      fileName: `${rootState.setting.download.fileName
        .replace('歌名', musicInfo.name)
@@ -68,19 +98,33 @@ const actions = {
      key: `${musicInfo.songmid}${ext}`,
    }
    downloadInfo.filePath = path.join(rootState.setting.download.savePath, downloadInfo.fileName)
+    commit('addTask', downloadInfo)
    if (dls[downloadInfo.key]) {
      dls[downloadInfo.key].stop().finally(() => {
-        this.dispatch('download/addTask', downloadInfo)
+        delete dls[downloadInfo.key]
+        this.dispatch('download/startTask', downloadInfo)
      })
    } else {
      // console.log(downloadInfo)
-      this.dispatch('download/addTask', downloadInfo)
+      this.dispatch('download/startTask', downloadInfo)
    }
  },
-  addTask({ commit, rootState }, downloadInfo) {
-    commit('addTask', downloadInfo)
+  createDownloadMultiple({ state, rootState }, { list, type }) {
+    addTask([...list], type, this)
+  },
+  startTask({ commit, state, rootState }, downloadInfo) {
+    // 检查是否可以开始任务
+    if (downloadInfo && downloadInfo != state.downloadStatus.WAITING) commit('setStatus', { downloadInfo, status: state.downloadStatus.WAITING })
+    let result = getStartTask(state.list, state.downloadStatus, rootState.setting.download.maxDownloadNum)
+    if (!result) return downloadInfo && commit('setStatus', { downloadInfo, status: state.downloadStatus.WAITING })
+    if (!downloadInfo) downloadInfo = result
+
+    // 开始任务
+    commit('setStatusText', { downloadInfo, text: '任务初始化中' })
+    commit('onDownload', downloadInfo)
    let msg = checkPath(rootState.setting.download.savePath)
    if (msg) return commit('setStatusText', '检查下载目录出错: ' + msg)
+    const _this = this
    const options = {
      url: downloadInfo.url,
      path: rootState.setting.download.savePath,
@@ -89,37 +133,46 @@ const actions = {
      override: true,
      onEnd() {
        commit('onEnd', downloadInfo)
+        _this.dispatch('download/startTask')
        console.log('on complate')
      },
      onError(err) {
-        console.log(err)
-        if (err.message.includes('Response status was')) {
-          const code = err.message.replace(/Response status was (\d+)$/, '$1')
-          switch (code) {
-            case '401':
-            case '403':
-            case '410':
-              commit('setStatusText', { downloadInfo, text: '链接失效，正在刷新链接' })
-              refreshUrl(downloadInfo).then(result => {
-                commit('updateUrl', { downloadInfo, url: result.url })
-                commit('setStatusText', { downloadInfo, text: '链接刷新成功' })
-                dls[downloadInfo.key].url = dls[downloadInfo.key].requestURL = result.url
-                dls[downloadInfo.key].__initProtocol(result.url)
-                dls[downloadInfo.key].resume()
-              }).catch(err => {
-                console.log(err)
-              })
-              return
-
-            default:
-              break
-          }
-        }
+        console.log(err.message)
        commit('onError', downloadInfo)
+        // console.log(tryNum[downloadInfo.key])
+        if (++tryNum[downloadInfo.key] > 5) return
+        let code
+        if (err.message.includes('Response status was')) {
+          code = err.message.replace(/Response status was (\d+)$/, '$1')
+        } if (err.code === 'ETIMEDOUT') {
+          code = 'ETIMEDOUT'
+        } else {
+          console.log('Download failed, Attempting Retry')
+          dls[downloadInfo.key].resume()
+          commit('setStatusText', { downloadInfo, text: '正在重试' })
+          return
+        }
+        switch (code) {
+          case '401':
+          case '403':
+          case '410':
+          case 'ETIMEDOUT':
+            commit('setStatusText', { downloadInfo, text: '链接失效，正在刷新链接' })
+            refreshUrl(downloadInfo).then(result => {
+              commit('updateUrl', { downloadInfo, url: result.url })
+              commit('setStatusText', { downloadInfo, text: '链接刷新成功' })
+              dls[downloadInfo.key].url = dls[downloadInfo.key].requestURL = result.url
+              dls[downloadInfo.key].__initProtocol(result.url)
+              dls[downloadInfo.key].resume()
+            }).catch(err => {
+              console.log(err)
+              _this.dispatch('download/startTask')
+            })
+        }
      },
-      onStateChanged(state) {
-        console.log(state)
-      },
+      // onStateChanged(state) {
+      //   console.log(state)
+      // },
      onDownload() {
        commit('onDownload', downloadInfo)
        console.log('on download')
@@ -130,6 +183,7 @@ const actions = {
      },
      onPause() {
        commit('pauseTask', downloadInfo)
+        _this.dispatch('download/startTask')
      },
      onResume() {
        commit('resumeTask', downloadInfo)
@@ -138,80 +192,52 @@ const actions = {
    let p = options.url ? Promise.resolve() : refreshUrl(downloadInfo).then(result => {
      commit('updateUrl', { downloadInfo, url: result.url })
      options.url = result.url
+    }).catch(err => {
+      commit('onError', downloadInfo)
+      commit('setStatusText', { downloadInfo, text: err.message })
+      return Promise.reject(err)
    })
    p.then(() => {
+      tryNum[downloadInfo.key] = 0
      dls[downloadInfo.key] = download(options)
    })
+  },
+  startTaskMultiple({ state, rootState }, list) {
+
  },
  removeTask({ commit, state }, index) {
    let info = state.list[index]
-    if (state.list[index].isDownloading) {
-      dls[info.key].stop().finally(() => {
-        delete dls[info.key]
-      })
+    if (state.list[index].status == state.downloadStatus.RUN) {
+      if (dls[info.key]) {
+        dls[info.key].stop().finally(() => {
+          delete dls[info.key]
+        })
+      }
    }
    commit('removeTask', index)
    if (dls[info.key]) delete dls[info.key]
+    this.dispatch('download/startTask')
  },
-  resumeTask({ commit, rootState }, downloadInfo) {
-    let msg = checkPath(rootState.setting.download.savePath)
-    if (msg) return commit('setStatusText', '检查下载目录出错: ' + msg)
-    const options = {
-      url: downloadInfo.url,
-      path: rootState.setting.download.savePath,
-      fileName: downloadInfo.fileName,
-      method: 'get',
-      override: true,
-      onEnd() {
-        commit('onEnd', downloadInfo)
-        console.log('on complate')
-      },
-      onError(err) {
-        commit('onError', downloadInfo)
-        commit('setStatusText', { downloadInfo, text: '链接失效，正在刷新链接' })
-        refreshUrl(downloadInfo).then(result => {
-          commit('updateUrl', { downloadInfo, url: result.url })
-          commit('setStatusText', { downloadInfo, text: '链接刷新成功' })
-          dls[downloadInfo.key].url = dls[downloadInfo.key].requestURL = result.url
-          dls[downloadInfo.key].__initProtocol(result.url)
-          dls[downloadInfo.key].resume()
-        }).catch(err => {
-          console.log(err)
-        })
-        console.log(err)
-      },
-      onStateChanged(state) {
-        console.log(state)
-      },
-      onDownload() {
-        commit('onDownload', downloadInfo)
-        console.log('on download')
-      },
-      onProgress(status) {
-        commit('onProgress', { downloadInfo, status })
-        console.log(status)
-      },
-      onPause() {
-        commit('pauseTask', downloadInfo)
-      },
-      onResume() {
-        commit('resumeTask', downloadInfo)
-      },
-    }
-
-    let p = options.url ? Promise.resolve() : refreshUrl(downloadInfo).then(result => {
-      commit('updateUrl', { downloadInfo, url: result.url })
-      options.url = result.url
-    })
-
-    if (fs.existsSync(downloadInfo.filePath)) {
-      options.resumeInfo = {
-        totalFileSize: downloadInfo.progress.total,
+  removeTaskMultiple({ commit, rootState, state }, list) {
+    list.forEach(item => {
+      let index = state.list.indexOf(item)
+      if (index < 0) return
+      // this.dispatch('download/removeTask', index)
+      if (state.list[index].status == state.downloadStatus.RUN) {
+        if (dls[item.key]) {
+          dls[item.key].stop().finally(() => {
+            delete dls[item.key]
+          })
+        }
      }
-    }
-    p.then(() => {
-      dls[downloadInfo.key] = download(options)
+      commit('removeTask', index)
+      if (dls[item.key]) delete dls[item.key]
    })
+    let result = getStartTask(state.list, state.downloadStatus, rootState.setting.download.maxDownloadNum)
+    while (result) {
+      this.dispatch('download/startTask', result)
+      result = getStartTask(state.list, state.downloadStatus, rootState.setting.download.maxDownloadNum)
+    }
  },
 }

@@ -224,29 +250,57 @@ const mutations = {
    state.list.splice(index, 1)
  },
  pauseTask(state, downloadInfo) {
-    downloadInfo.isDownloading = false
+    downloadInfo.status = state.downloadStatus.PAUSE
+    downloadInfo.statusText = '暂停下载'
  },
  resumeTask(state, downloadInfo) {
-    downloadInfo.statusText = '恢复下载'
+    downloadInfo.statusText = '开始下载'
  },
-  setStatusText(state, { downloadInfo, index, text }) {
+  setStatusText(state, { downloadInfo, index, text }) { // 设置状态文本
    if (downloadInfo) {
      downloadInfo.statusText = text
    } else {
      state.list[index].statusText = text
    }
  },
+  setStatus(state, { downloadInfo, index, status }) { // 设置状态及状态文本
+    let text
+    switch (status) {
+      case state.downloadStatus.RUN:
+        text = '正在下载'
+        break
+      case state.downloadStatus.WAITING:
+        text = '等待下载'
+        break
+      case state.downloadStatus.PAUSE:
+        text = '暂停下载'
+        break
+      case state.downloadStatus.ERROR:
+        text = '任务出错'
+        break
+      case state.downloadStatus.COMPLETED:
+        text = '下载完成'
+        break
+    }
+    if (downloadInfo) {
+      downloadInfo.statusText = text
+      downloadInfo.status = status
+    } else {
+      state.list[index].statusText = text
+      state.list[index].status = status
+    }
+  },
  onEnd(state, downloadInfo) {
    downloadInfo.isComplate = true
-    downloadInfo.isDownloading = false
+    downloadInfo.status = state.downloadStatus.COMPLETED
    downloadInfo.statusText = '下载完成'
  },
  onError(state, downloadInfo) {
-    downloadInfo.isDownloading = false
+    downloadInfo.status = state.downloadStatus.ERROR
    downloadInfo.statusText = '任务出错'
  },
  onDownload(state, downloadInfo) {
-    downloadInfo.isDownloading = true
+    downloadInfo.status = state.downloadStatus.RUN
    downloadInfo.statusText = '正在下载'
  },
  onProgress(state, { downloadInfo, status }) {
@@ -30,9 +30,22 @@ const mutations = {
    if (state.defaultList.list.some(s => s.songmid === musicInfo.songmid)) return
    state.defaultList.list.push(musicInfo)
  },
+  defaultListAddMultiple(state, list) {
+    list.forEach(musicInfo => {
+      if (state.defaultList.list.some(s => s.songmid === musicInfo.songmid)) return
+      state.defaultList.list.push(musicInfo)
+    })
+  },
  defaultListRemove(state, index) {
    state.defaultList.list.splice(index, 1)
  },
+  defaultListRemoveMultiple(state, list) {
+    list.forEach(musicInfo => {
+      let index = state.defaultList.list.indexOf(musicInfo)
+      if (index < 0) return
+      state.defaultList.list.splice(index, 1)
+    })
+  },
  defaultListClear(state) {
    state.defaultList.list.length = 0
  },