serverRouter.js

const express = require('express');
const router = express.Router()
const axios = require('axios')
const user = require('./blurlyric/user');
const match = require('@unblockneteasemusic/server');
const fs = require("fs")
const path = require("path")
const fetch = require( 'node-fetch');

router.get('/createUser',(req,res)=>{

    user.createUser((data)=>{
        jsonTool('200',data,req,res)
        return
    })
    
})

router.get('/unblockmusic',async (req,res)=>{
    //,['kugou','migu','kuwo']
    // res.json({})
    match(req.query.id,['kugou','kuwo','migu']).then(text =>{
        // console.log(text);
        res.json(text)
    })
})

router.get('/getUser',(req,res)=>{
    if (!req.query.id) {
        jsonTool('200',{
            "msg": '请填入ID',
        },req,res)
        return 
    }
      
    user.getUser(req.query.id,(data)=>{
        jsonTool(200,data,req,res)
    })
})

router.get('/writeUser',(req,res)=>{
    console.log(req.query)
    if (!req.query.id||!req.query.res) {
        jsonTool('405',null,req,res)
        return
    }
    let dataSize = strSize(req.query.res.toString())
    if(strSize(dataSize,'utf8')>8000000){
        jsonTool('405',{msg: '文件过大 (>8mb)'},req,res)
        return
    }
    user.upsetConfig(req.query,(data)=>{
        jsonTool('200',data,req,res)
    })
})

function jsonTool(code,data,req,res) {
    res.json({
        "code": code || 200,
        "date": new Date(),
        "data": '' ||data,
        "ip": '' ||req.ip
    })
}
function strSize(str, charset) {
    let total = 0;
    charset = charset?.toLowerCase() || '';
    for (i = 0; i < str.length; i++) {
        let charCode = str.charCodeAt(i);
        if (charset === 'utf-16' || charset === 'utf16') {
            total += charCode <= 0xffff ? 2 : 4;
        } else {
            if (charCode <= 0x007f) {
                total += 1;
            } else if (charCode <= 0x07ff) {
                total += 2;
            } else if (charCode <= 0xffff) {
                total += 3;
            } else {
                total += 4;
            }
        }
    }
    return total;
}

async function getFileByUrl(url,fileName){
    console.log('['+(downloadTrack.now+1) + '/'+downloadTrack.list.length+']请求下载 ' + fileName)
    await fetch(url,   {
        method: 'GET',
        headers: { 'Content-Type': 'application/octet-stream' },
}).then(res=>res.buffer()).then(_=>{
    fs.writeFile(path.join(__dirname,'./blurlyric/download/'+fileName +'.mp3'),_,'binary',function (err) {
        downloadTrack.freeThread++
        downloadTrack.try()

        if (err) console.log('['+(downloadTrack.now+1) + '/'+downloadTrack.list.length+']下载失败 ' + fileName);
        else console.log('['+(downloadTrack.now+1) + '/'+downloadTrack.list.length+']完成下载 ' + fileName)
})}).catch((error)=>{
    downloadTrack.freeThread++
    downloadTrack.try()

})


}

var downloadTrack={
    list: [],
    now: 0,
    maxThread: 8,
    freeThread: 8,
    async try(){
        if(this.list.length>this.now){
            getFileByUrl(this.list[this.now].url,this.list[this.now].fileName)
            this.freeThread--
            this.now++
        }
        if(this.freeThread != 0&&this.list.length - this.now>1){
            this.try()
        }
    }
}


router.get('/downloadUrl',(req,res)=>{
    console.log(req.query)
    if (!req.query.url||!req.query.fileName) {
        jsonTool('405',null,req,res)
        return
    }
    console.log({
        url: req.query.url,
        fileName: req.query.fileName
    });
    downloadTrack.list.push({
        url: req.query.url,
        fileName: req.query.fileName
    })
    downloadTrack.try()
})
module.exports = router