add event history

route/api/ipcam.js

@@ -8,6 +8,7 @@ const tool = require('../../includes/apiTool');
 const exec = require('child_process').exec;
 const so = require('../../includes/storeObject');
 const crypt = require('../../libs/crypto');
+const path = require('path');
 
 router
     .get('/', (req, res, n) => {
@@ -25,7 +26,7 @@ router
     .post('/getipcamlist', (req, res, n) => {
         if (!config.permission.ipcam) return n('ERR9000');
 
-        let query = "select * from ??.??";
+        let query = "select * from ??.?? where `delete` = 0 order by `ctime`";
         let param = [config.db.db1, 'jcioccamset'];
         res.db.query(query, param, (err, row) => {
             if (err) return rt.err(res, err, n, 'ERR8000');
@@ -92,11 +93,13 @@ router
                         `maximg` = ?, \
                         `active` = ?, \
                         `delete` = 0, \
+                        `cuser` = ?, \
+                        `ctime` = unix_timestamp(), \
                         `muser` = ?, \
                         `mtime` = unix_timestamp() \
                         where \
                         `uid` = ?";
-                    let param = [config.db.db1, 'jcioccamset', arr.data.ip, arr.data.name, arr.data.model, arr.data.maxevents, arr.data.maximg, active, u, arr.data.id];
+                    let param = [config.db.db1, 'jcioccamset', arr.data.ip, arr.data.name, arr.data.model, arr.data.maxevents, arr.data.maximg, active, u, u, idx];
                     await tool.promiseQuery(res, query, param);
                 } catch (e) {
                     return rt.err(res, e, n, 'ERR8002');
@@ -175,10 +178,17 @@ router
         if (!arr.data) return n('ERR0000');
         if (!arr.data.id) return n('ERR0028');
 
+        let u = '';
+        let obj = so.get(req.headers['x-auth-token'] || '');
+        if (obj != null && 'user' in obj && 'account' in obj.user) u = obj.user.account;
+
         res.db.query(`use ${config.db.db1}`);
-        let query = "delete from ??.?? \
+        let query = "update ??.?? set \
+            `delete` = 1, \
+            `muser` = ?, \
+            `mtime` = unix_timestamp() \
             where `uid` = ?";
-        let param = [config.db.db1, 'jcioccamset', arr.data.id];
+        let param = [config.db.db1, 'jcioccamset', u, arr.data.id];
 
         res.db.query(query, param, (err, row) => {
             if (err) return rt.err(res, err, n, 'ERR8003');
@@ -211,6 +221,70 @@ router
             n();
         })
     })
+    .post('/getevents', async(req, res, n) => {
+        if (!config.permission.ipcam) return n('ERR9000');
+        if (!tool.checkPermission(req)) return n('ERR9000');
+        let arr = req.body;
+        if (!arr.data) return n('ERR0000');
+        if (!arr.data.id) return n('ERR0028');
+
+        try {
+            let query = "select * from ??.?? where `uid` = ? and `delete` = 0";
+            let param = [config.db.db1, 'jcioccamset', arr.data.id];
+            let cam = await tool.promiseQuery(res, query, param);
+            if (cam.length == 0) return n('ERR0071');
+        } catch (e) {
+            return rt.err(res, e, n, 'ERR8000');
+        }
+        let rp = config.cmdpath.ipcamsave;
+        let dirs = [];
+
+        try {
+            let dirls = await new Promise((resolve, reject) => {
+                fs.readdir(rp, (err, list) => {
+                    if (err) return reject(err);
+                    return resolve(list);
+                })
+            })
+            for (let i of dirls) {
+                let tmp = i.split('-');
+                if (tmp.length != 2) continue;
+                if (tmp[0] == arr.data.id) dirs.push({
+                    name: i,
+                    files: {
+                        img: [],
+                        video: []
+                    }
+                });
+            }
+
+            for (let i in dirs) {
+                let p = path.resolve(rp, dirs[i].name);
+                let idx = i;
+                let files = await new Promise((resolve, reject) => {
+                    fs.readdir(p, (err, list) => {
+                        if (err) return reject(err);
+                        return resolve(list);
+                    })
+                })
+                for (let j of files) {
+                    if (/^img/.test(j)) {
+                        dirs[idx].files.img.push(j);
+                    } else if (/^vid/.test(j)) {
+                        dirs[idx].files.video.push(j);
+                    }
+                }
+            }
+
+        } catch (e) {
+            return rt.err(res, e, n, 'ERR0072');
+        }
+
+        res.api_res = {
+            record: tool.checkArray(dirs)
+        }
+        return n();
+    })
     .all('*', rt.send);
 
 module.exports = router;