+112
-101
@@ -6,3 +6,3 @@ /* | ||
| const fs = require('fs'); | ||
| const common = function() { | ||
| const common = function () { | ||
@@ -14,85 +14,87 @@ } | ||
| common.prototype.file = { | ||
| set: function(file, message, opation) { | ||
| fs.appendFile(file, message, (err) => { | ||
| if (err) { | ||
| throw err; | ||
| } | ||
| set: function (file, message, opation) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.appendFile(file, message, (err) => { | ||
| if (err) { | ||
| reject(err); | ||
| } | ||
| s | ||
| resolve(); | ||
| }); | ||
| }) | ||
| }, | ||
| reset: function (file, message) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.writeFile(file, message, (err) => { | ||
| if (err) { | ||
| reject(err); | ||
| } | ||
| resolve(); | ||
| }); | ||
| }); | ||
| }); | ||
| }, | ||
| reset: function(file, message, callback) { | ||
| fs.writeFile(file, message, (err) => { | ||
| if (err) { | ||
| throw err; | ||
| } | ||
| if (!!callback) { | ||
| callback(); | ||
| } | ||
| read: function (file, callback) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.readFile(file, 'utf8', (err, data) => { | ||
| if (err) { | ||
| reject(err); | ||
| } | ||
| resolve(data); | ||
| }); | ||
| }); | ||
| }, | ||
| read: function(file, callback) { | ||
| return new Promise((resolve,reject)=>{ | ||
| fs.readFile(file, 'utf8', (err, data) => { | ||
| if (err) { | ||
| reject(err); | ||
| } | ||
| resolve(data); | ||
| }); | ||
| readdir: function (path) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.readdir(path, (err, fd) => { | ||
| if (err) { | ||
| reject(err); | ||
| } | ||
| resolve(); | ||
| }); | ||
| }); | ||
| }, | ||
| readdir: function(path, callback) { | ||
| fs.readdir(path, (err, fd) => { | ||
| if (err) { | ||
| throw err; | ||
| } | ||
| if (callback) { | ||
| callback(fd); | ||
| } | ||
| readdirSync: function (path, callback) { | ||
| return new Promise((resolove, reject) => { | ||
| const file = fs.readdirSync(path); | ||
| }); | ||
| resolve(); | ||
| }, | ||
| readdirSync: function(path, callback) { | ||
| var file = fs.readdirSync(path); | ||
| if (callback) { | ||
| callback(file); | ||
| } | ||
| }, | ||
| // 获取指定目录下指定文件合集 | ||
| searchFileType: function(root, fileType, callback) { | ||
| searchFileType: function (root, fileType, callback) { | ||
| this.array = []; | ||
| this.getFile(root, fileType, callback); | ||
| this.getFile(root, fileType).then(array => callback(array)); | ||
| }, | ||
| // 获取指定目录下指定文件合集(内部调用方法) | ||
| getFile: function(root, fileType, callback) { | ||
| getFile: function (root, fileType) { | ||
| const _this = this; | ||
| return new Promise((resolve, reject) => { | ||
| _this.readdirSync(root, (file) => { | ||
| file.forEach((file) => { | ||
| if (file.indexOf('.' + fileType) > 0) { | ||
| _this.array.push(file); | ||
| } else if (file.indexOf('.') < 0) { | ||
| // 目录 | ||
| _this.getFile(root + '/' + file, fileType).then((file) => { | ||
| _this.array.concat(file); | ||
| }); | ||
| } | ||
| }); | ||
| _this.readdirSync(root, (file) => { | ||
| file.forEach((file) => { | ||
| if (file.indexOf('.' + fileType) > 0) { | ||
| _this.array.push(file); | ||
| } else if (file.indexOf('.') < 0) { | ||
| // 目录 | ||
| _this.getFile(root + '/' + file, fileType, (file) => { | ||
| _this.array.concat(file); | ||
| }); | ||
| } | ||
| }); | ||
| resolve(_this.array); | ||
| }); | ||
| callback(_this.array); | ||
| }, | ||
| open: function(file, callback) { | ||
| fs.open(file, 0666, (err, d) => { | ||
| if (err) { | ||
| throw err | ||
| } | ||
| open: function (file) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.open(file, 0666, (err, d) => { | ||
| if (err) { | ||
| throw err | ||
| } | ||
| resolve() | ||
| }); | ||
| }) | ||
| if (callback) { | ||
| callback(d); | ||
| } | ||
| }); | ||
| }, | ||
| create: function(file, message, callback) { | ||
| create: function (file, message, callback) { | ||
| const _this = this; | ||
@@ -110,3 +112,3 @@ const array = file.split('/'); | ||
| path: file, | ||
| callback: function(data) { | ||
| callback: function (data) { | ||
| if (data) { | ||
@@ -116,3 +118,3 @@ console.error(file + '对应目录文件已存在,创建失败'); | ||
| common.mkdirSync(root, () => { | ||
| _this.resest(file, message, callback); | ||
| _this.reset(file, message).then(callback()); | ||
| }); | ||
@@ -123,36 +125,38 @@ } | ||
| }, | ||
| mkdirSync: function(root, callback) { | ||
| fs.mkdir(root, 0777, (err) => { | ||
| if (err) { | ||
| console.error(root + ' =>对应目录已存在'); | ||
| } else { | ||
| console.tip(root + '=> 目录已创建完成'); | ||
| } | ||
| if (callback) { | ||
| callback(); | ||
| } | ||
| mkdirSync: function (root) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.mkdir(root, 0777, (err) => { | ||
| if (err) { | ||
| // console.error(root + ' =>对应目录已存在'); | ||
| reject(err); | ||
| } else { | ||
| // console.tip(root + '=> 目录已创建完成'); | ||
| } | ||
| resolve(); | ||
| }); | ||
| }); | ||
| }, | ||
| // 判断文件是否存在 | ||
| exists: function(obj) { | ||
| fs.exists(obj.path, (exists) => { | ||
| if (!exists) { | ||
| if (obj.error) { | ||
| obj.error(exists); | ||
| // todo 后续用stat替换 | ||
| exists: function (obj) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.exists(obj.path, (exists) => { | ||
| if (!exists) { | ||
| reject(exists); | ||
| } | ||
| } else { | ||
| if (obj.success) { | ||
| obj.success(exists); | ||
| } | ||
| } | ||
| if (obj.callback) { | ||
| obj.callback(exists); | ||
| } | ||
| resolve(exists); | ||
| }); | ||
| }); | ||
| }, | ||
| // 读取文件 | ||
| readFile: function(obj) { | ||
| fs.readFile(obj.path, obj.encode || 'utf8', (err, file) => { | ||
| obj.callback(err, file); | ||
| }); | ||
| readFile: function (obj) { | ||
| return new Promise((resolve, reject) => { | ||
| fs.readFile(obj.path, obj.encode || 'utf8', (err, file) => { | ||
| resolve(err,file); | ||
| // obj.callback(err, file); | ||
| }); | ||
| }) | ||
| }, | ||
@@ -164,3 +168,3 @@ | ||
| common.prototype.JSON = { | ||
| get: function() { | ||
| get: function () { | ||
| return JSON.parse(fs.readFileSync(file)); | ||
@@ -172,3 +176,3 @@ } | ||
| common.prototype.tools = { | ||
| formatDate: function(date) { | ||
| formatDate: function (date,type,format) { | ||
| const arr = ['00', '01', '02', '03', '04', '05', '06', '07', '08', '09']; | ||
@@ -181,5 +185,12 @@ const D = date.getDate(), | ||
| s = date.getSeconds(); | ||
| return `${Y}-${arr[M] || M}-${arr[D] || D} ${arr[h] || h}:${arr[m] || m}:${arr[s] || s}`; | ||
| cosnt _date=`${Y}-${arr[M] || M}-${arr[D] || D}`.split('-'),join(format), | ||
| _time=`${arr[h] || h}:${arr[m] || m}:${arr[s] || s}` | ||
| return { | ||
| date:_date, | ||
| time:_time, | ||
| fullDate:`${_date} ${_time}` | ||
| }; | ||
| }, | ||
| formatData: function(obj, type) { | ||
| formatData: function (obj, type) { | ||
| const _this = this, | ||
@@ -192,3 +203,3 @@ data = decodeURI(obj.toString()); | ||
| }, | ||
| dataToObj: function(url) { | ||
| dataToObj: function (url) { | ||
| var obj = {}; | ||
@@ -212,5 +223,5 @@ var keyvalue = []; | ||
| // 打印日志 | ||
| common.prototype.msg=msg; | ||
| common.prototype.msg = msg; | ||
| const cpwcom = new common(); | ||
| module.exports = cpwcom; | ||
| module.exports = cpwcom; |
+1
-1
| { | ||
| "name": "cpwcom", | ||
| "version": "1.0.8", | ||
| "version": "1.0.9", | ||
| "description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
26901
2.61%279
3.72%