NodeJs 遍历文件夹内容 上传到服务器.并输出上传记录文件

时间:2023-03-10 05:47:13
NodeJs 遍历文件夹内容 上传到服务器.并输出上传记录文件
 var path = require('path');
var glob = require('glob')
var fs = require('fs');
var Promise = require('bluebird');
var readdir = Promise.promisify(fs.readdir);
var rename = Promise.promisify(fs.rename);
var readFile = Promise.promisify(fs.readFile);
var writeFile = Promise.promisify(fs.writeFile);
var request = Promise.promisify(require('request'));
var projectinfo = require('./build/projectinfo');
const jsonname = "./uploadimg/uploadimg.txt"; function updateFile(filepath, dir) {
var _fileName = path.join(projectinfo.updatesrc, filepath.split('/').slice(2).join('/'));
let tmp_fileName = filepath.split('/').slice(2).join('/');
_fileName = _fileName.split('\\').join('/');
console.log(tmp_fileName); fs.readFile(jsonname, function(err, data) {
if (err) {
fs.createWriteStream(jsonname)
}
}); var formData = {
filename: _fileName,
file: fs.createReadStream(filepath)
};
var _options = {
method: 'POST',
uri: 'http://***.***.***/upload/***?',
qs: {
guid: '***',
rand: 1,
time: 1,
platform: 'server'
},
formData: formData
}
request(_options)
.then(function(res) {
var _body = JSON.parse(res.body);
if (!_body.errno) {
var resinfo = JSON.parse(res.body);
console.log(resinfo);
writeJson(tmp_fileName, resinfo.data.url);
}
})
.catch(function(err) {
console.log(err)
})
} glob.sync('./uploadimg/*.*').forEach(function(entry) {
basename = path.basename(entry)
if (/(png)$/.test(basename) || /(jpg)$/.test(basename)) {
//console.log("需要上传的文件:\n" + entry + "\n")
updateFile(entry)
}
}) function writeJson(_name, _val) {
var _str = _name + " : " + _val + "\n";
fs.appendFile(jsonname, _str, function(err) {
if (err) {
console.log("写入失败:" + obj);
}
}); }