使用NodeJS实现文件上传、转码、预览功能(零前端)
async function uploadFile(ctx: RouterContext) {
const files: Files = ctx.request.files;
if (!(files && files.image)) {
ctx.body = HoResponseUtils.error<any>({
error_no: 100301
});
return;
}
if (files.image && files.image['length']) {
ctx.body = HoResponseUtils.error<any>({
error_no: 100302
});
return;
}
ca_logger.info(upload_conf);
try {
// 另存为本地临时文件
const tmpPath = await _saveFile(files);
// 解压
const originPath = upload_conf.outputPath + '/origin';
const imgPathListStr = await _decompression(tmpPath, originPath);
// 转码
const thumbPath = upload_conf.outputPath + '/thumb';
await _thumbImgList(imgPathListStr, thumbPath);
} catch (error) {
ctx.body = HoResponseUtils.error<any>({
error_no: 100302,
error_message: error
});
return;
}
ctx.body = HoResponseUtils.normal<any>({
data: '上传成功'
});
return;
}
// 重命名为image，并另存为本地临时文件下
function _saveFile(files): Promise<string> {
const file = files.image as File;
const suffix = file.name.split('.').pop();
const tmpPath = `${upload_conf.tempPath}/images.${suffix}`;
return new Promise((resolve, reject) => {
try {
caUtils.mkdir(tmpPath);
const data = fs.readFileSync(file.path);
fs.writeFileSync(tmpPath, data)
resolve(tmpPath);
} catch (err) {
reject('文件读取失败，请上传正确的压缩文件夹！')
}
});
}
/**
* @param tempPath
* @param outputPath
* 读取 tempPath 路径下的压缩文件 解压之后，解压后的文件放至 outputPath
* 解压之后临时文件可删可不删，每次上传都会重命名为image，第二次上传，会覆盖掉第一次上传的压缩文件
*/
function _decompression(tempPath: string, outputPath: string): Promise<string> {
const outputArr = [];
const myStream = extractFull(tempPath, outputPath, {
$bin: pathTo7zip,
$progress: true
});
return new Promise((res, rej) => {
myStream.on('data', function (data) {
outputArr.push(upload_conf.host + '/upload/origin/' + data.file)
});
myStream.on('end', function () {
ca_logger.info('Complete!');
if (outputArr.length) {
res(outputArr.join(','));
} else {
rej('文件夹为空，请上传正确的压缩文件夹！');
}
});
myStream.on('error', (err) => {
ca_logger.error('Error:', err)
rej('文件解压失败，请上传正确的压缩文件夹！');
});
});
}