线路设置
${Object.values(this.HOSTS).map(({hosts, title, id}) => {
hosts ??= []
let html = `${title}线路: `
return hosts.length ? html : ''}).join('')}
`,
callback: dialog => this.initInputs(dialog),
onClose: () => this.resources = this.resources.map(item => this.DETAIL.rules[item.rule_index].parseItem(item.data))
})
}
$('#_clearDownloads')[0].onclick = () => this.clearDownloads()
$('#_reDownloads')[0].onclick = () => this.reDownloads()
},
initAction(){
const onEvent = ev => {
let {srcElement} = ev
let {action} = srcElement.dataset
switch(action){
case 'addDownload':
let par = getParent(srcElement, el => el?.dataset?.id)
if(par){
this.downloadItem(this.findItem(par.dataset.id), true)
}
return
case 'exportUrls':
return this.addDownload({
url: URL.createObjectURL(new Blob([flattenArray(this.resources.map(({urls}) => Array.isArray(urls) ? urls.map(({url}) => url) : urls)).join("\r\n")])),
name: '导出链接.txt'
})
case 'exportData':
// todo csv
if(!this.resources.length) return alert('没有任何数据')
return this.addDownload({
url: URL.createObjectURL(new Blob([JSON.stringify(this.resources)])),
name: '导出数据.txt'
})
case 'importData':
return openFileDialog({
accept: '.txt',
callback: files => {
let reader = new FileReader()
reader.readAsText(files[0])
reader.onload = e => {
try {
json = JSON.parse(reader.result)
let cnt = json.length
if(cnt){
if(confirm(`发现${cnt}条数据!是否重置下载状态？`)) json = json.map(item => Object.assign(item, {status: WAITTING}))
this.setList(json) & this.writeLog('成功导入数据')
}
} catch (err) {
alert(err.toString())
}
}
}
})
default:
return
}
ev.stopPropagation(true) & ev.preventDefault()
}
document.body.addEventListener('click', onEvent)
},
initInputs(dialog){
const self = this
for(let select of dialog.querySelectorAll('select')) select.onchange = function(){
self.saveOptions({[`${this.dataset.for}_host`]: this.value})
}
for(let input of dialog.querySelectorAll('input')) input.onchange = function(){
let value, key = this.dataset.for
switch(this.type){
case 'checkbox':
case 'switch':
value = this.checked
break
default:
value = this.value
}
self.saveOptions({[key]: value})
if(key == 'useAria2c') self.enableAria2c(value)
}
},
clearDownloads(){
this.eachItems(DOWNLOADED, ({tr, item, index}) => {
this.resources.splice(index, 1)
tr && tr.remove()
})
},
reDownloads(){
this.cancelDownloads()
let cnt = this.eachItems([DOWNLOADING, ERROR], ({tr, item}) => {
if(tr){
let td = tr.querySelectorAll('td')
td[4].style.backgroundColor = 'unset'
td[4].innerHTML = createHTML('等待中...')
}
item.status = WAITTING
}).length
cnt ? this.writeLog(`重新下载${cnt}个视频`) & this.switchRunning(true) : alert('没有需要重新下载的任务')
},
cancelDownloads(){
Object.keys(this.downloads).forEach(id => this.removeDownload(id))
this.writeLog(`成功取消所有下载`)
},
eachItems(status_id, callback){
let ret = []
status_id = toArr(status_id)
for(let i=this.resources.length-1;i>=0;i--){
let item = this.resources[i]
ret.push(item)
let {status, id} = item
if(status_id.includes(status)){
let tr = this.findElement(id)
callback({tr, item, index: i})
}
}
return ret
},
checkFinishTimer: -1,
switchRunning(running){ // 切换运行状态
this.running = running ??= !this.running
$('#_switchRunning')[0].innerHTML = createHTML(running ? '暂停' : '运行')
if(running){
let threads = parseInt($('#_threads')[0].value)
let cnt = threads - this.getItems(DOWNLOADING).length
if(cnt){
this.writeLog('开始线程下载:'+cnt)
this.saveOptions({threads})
for(let i=0;i