16 Commits

Author SHA1 Message Date
root d702c63eb6 update 2017-05-26 11:06:15 +08:00
root 58057bcfa0 update ipmi page 2017-05-25 15:53:26 +08:00
root 432ff46ecd update 2017-05-25 13:37:16 +08:00
root c934490047 update 2017-05-22 20:19:37 +08:00
root 7a270f862f update 2017-05-22 17:48:17 +08:00
root 68e07e0dcd update ipmi page not fin 2017-05-22 17:47:16 +08:00
root 63520e50d5 fix event url 2017-05-05 18:01:52 +08:00
root 7826befe8e add del event, add download event, add download event video 2017-05-05 17:24:45 +08:00
root 0cd5667f63 fix viewimg 404 status 2017-05-05 10:45:44 +08:00
root bcc4b1ed7d update 2017-05-04 17:29:20 +08:00
root fbab4f44e8 add event history 2017-05-04 14:36:29 +08:00
root af1d96062a modify add ipcam api 2017-05-03 17:15:08 +08:00
root 5113518997 fix modal bug 2017-05-03 13:10:04 +08:00
root ef5e115b9d update model value 2017-05-03 12:00:17 +08:00
root 9ed476df9c add ipcam set page 2017-05-03 11:16:01 +08:00
root 27cd09220e update 2017-05-02 10:03:13 +08:00
25 changed files with 1822 additions and 101 deletions
-1
View File
@@ -1 +0,0 @@
wristband-v0.0.1
+62 -2
View File
@@ -8,6 +8,8 @@ const path = require('path');
const config = require('./config'); const config = require('./config');
const so = require('./includes/storeObject'); const so = require('./includes/storeObject');
const exec = require('child_process').exec; const exec = require('child_process').exec;
const fs = require('fs');
const archiver = require('archiver');
const app = express(); const app = express();
@@ -54,8 +56,66 @@ app.get(['/admin', '/admin/*'], (req, res) => {
res.sendFile(path.resolve(__dirname, 'views', 'admin.html')); res.sendFile(path.resolve(__dirname, 'views', 'admin.html'));
}); });
app.get('/camevent', (req, res) => {
let ip = req.headers['x-forwarded-for'] || req.connection.remoteAddress;
ip = ip.split(':').pop();
let cmd = `camcam ${ip} ${Math.floor(Date.now() / 1000)}`;
exec(cmd, (err, sout, serr) => {
res.send({ ip });
});
})
app.get(['/viewcamimg/:dir/:file', '/dlcamvideo/:dir/:file'], async(req, res) => {
let dir = req.params.dir;
let file = req.params.file;
if (!dir || !file) return res.sendStatus(404);
try {
let stat = await new Promise((resolve, reject) => {
fs.stat(path.resolve(config.cmdpath.ipcamsave, dir, file), (err, stats) => {
if (err) return reject(err);
return resolve(stats);
})
})
if (!stat.isFile()) return res.sendStatus(404);
} catch (e) {
return res.sendStatus(404);
}
res.sendfile(path.resolve(config.cmdpath.ipcamsave, dir, file))
})
app.get('/dlevent/:dir', async(req, res) => {
let dir = req.params.dir;
if (!dir) return res.sendStatus(404);
let list = [];
try {
let stat = await new Promise((resolve, reject) => {
fs.stat(path.resolve(config.cmdpath.ipcamsave, dir), (err, stats) => {
if (err) return reject(err);
return resolve(stats);
})
});
if (!stat.isDirectory()) return res.sendStatus(404);
list = await new Promise((resolve, reject) => {
fs.readdir(path.resolve(config.cmdpath.ipcamsave, dir), (err, fis) => {
if (err) return reject(err);
return resolve(fis);
})
})
} catch (e) {
return res.sendStatus(404);
}
res.writeHead(200, {
'Content-Type': 'application/zip',
'Content-disposition': 'attachment; filename=cam_event.zip'
});
let zip = archiver('zip', { store: true });
zip.pipe(res);
for (let i of list) {
zip.file(path.resolve(config.cmdpath.ipcamsave, dir, i), { name: i })
}
zip.finalize();
})
app.get('/servcmd', (req, res) => { app.get('/servcmd', (req, res) => {
res.send({ status: `exit time ${Date.now()}` }); res.send({ status: `exit time ${(new Date()).toString()}` });
setTimeout(() => { process.exit(1) }, 2000); setTimeout(() => { process.exit(1) }, 2000);
}); });
@@ -67,7 +127,7 @@ app.get('/fixmysql', (req, res) => {
restart: '' restart: ''
}; };
exec(cmd, (err, stdout, stderr) => { exec(cmd, (err, stdout, stderr) => {
let cmd = 'systemctl restart mysqld'; let cmd = 'systemctl start mysqld';
json.rm = stdout; json.rm = stdout;
exec(cmd, (err, sout, serr) => { exec(cmd, (err, sout, serr) => {
json.restart = sout; json.restart = sout;
+9 -6
View File
@@ -4,7 +4,8 @@
}, },
"uni_token": "webiounitoken", "uni_token": "webiounitoken",
"perpage": 10, "perpage": 10,
"leone_limie": 40, "leone_limit": 40,
"ipcam_limit": 4,
"db": { "db": {
"user": "root", "user": "root",
"pass": "16055536", "pass": "16055536",
@@ -20,7 +21,8 @@
"db8": "jciocln", "db8": "jciocln",
"db9": "jcbtwristband", "db9": "jcbtwristband",
"db10": "jcmblog", "db10": "jcmblog",
"db11": "jciocserver" "db11": "jciocserver",
"db12": "jcioccam"
}, },
"permission": { "permission": {
"dio": true, "dio": true,
@@ -29,11 +31,11 @@
"iogroup": true, "iogroup": true,
"iocmd": true, "iocmd": true,
"schedule": true, "schedule": true,
"modbus": false, "modbus": true,
"link": true, "link": true,
"ipcam": false, "ipcam": true,
"wristband": true, "wristband": true,
"server": false "server": true
}, },
"cmdpath": { "cmdpath": {
"manualip": "/home/www/cmd/manualip", "manualip": "/home/www/cmd/manualip",
@@ -45,6 +47,7 @@
"iocmd": "/home/www/cmd/cmdio", "iocmd": "/home/www/cmd/cmdio",
"leonert": "/home/www/tmp/rtles", "leonert": "/home/www/tmp/rtles",
"htsrt": "/home/www/tmp/rthts", "htsrt": "/home/www/tmp/rthts",
"version": "/factory/webioa_version" "version": "/factory/webioa_version",
"ipcamsave": "/home/www/cam"
} }
} }
+7
View File
@@ -66,6 +66,13 @@
"ERR0064": "MAC Addr 輸入錯誤", "ERR0064": "MAC Addr 輸入錯誤",
"ERR0065": "版本輸入錯誤", "ERR0065": "版本輸入錯誤",
"ERR0066": "SNMP Level輸入錯誤", "ERR0066": "SNMP Level輸入錯誤",
"ERR0067": "型號輸入錯誤",
"ERR0068": "事件數量輸入錯誤",
"ERR0069": "圖片數量輸入錯誤",
"ERR0070": "IPCam 裝置已達上限",
"ERR0071": "無此裝置資料",
"ERR0072": "目錄資訊取得失敗",
"ERR0073": "目錄輸入錯誤",
"ERR7000": "命令執行失敗", "ERR7000": "命令執行失敗",
+1
View File
@@ -12,6 +12,7 @@
"author": "", "author": "",
"license": "MIT", "license": "MIT",
"dependencies": { "dependencies": {
"archiver": "^1.3.0",
"body-parser": "^1.16.1", "body-parser": "^1.16.1",
"cookie-parser": "^1.4.3", "cookie-parser": "^1.4.3",
"cors": "^2.8.1", "cors": "^2.8.1",
+7 -6
View File
@@ -8,19 +8,19 @@ router
.get('/', (req, res) => { .get('/', (req, res) => {
res.send({ name: 'WebIO API System' }); res.send({ name: 'WebIO API System' });
}) })
.all('*', (req,res,n)=>{ .all('*', (req, res, n) => {
if('x-auth-token' in req.headers) { if ('x-auth-token' in req.headers) {
let token = req.headers['x-auth-token']; let token = req.headers['x-auth-token'];
if(so.chkKey(token)){ if (so.chkKey(token)) {
let obj = so.get(token); let obj = so.get(token);
if(obj != null) { if (obj != null) {
so.set(token, obj); so.set(token, obj);
} }
} }
} }
n(); n();
}) })
.get('/showallso', (req,res)=>{ .get('/showallso', (req, res) => {
res.send(so.show()); res.send(so.show());
}) })
.use('/system', require('./system.js')) .use('/system', require('./system.js'))
@@ -33,6 +33,7 @@ router
.use('/link', require('./link.js')) .use('/link', require('./link.js'))
.use('/modbus', require('./modbus.js')) .use('/modbus', require('./modbus.js'))
.use('/ipcam', require('./ipcam.js')) .use('/ipcam', require('./ipcam.js'))
.use('/server', require('./server.js'))
.use('/wristband', require('./wristband.js')); .use('/wristband', require('./wristband.js'));
// api error handler // api error handler
@@ -52,7 +53,7 @@ router.use((err, req, res, n) => {
status: 0 status: 0
}; };
if('sys_err' in res && process.env.NODE_ENV != 'production') json.sys_err = res.sys_err; if ('sys_err' in res && process.env.NODE_ENV != 'production') json.sys_err = res.sys_err;
res.send(json); res.send(json);
}) })
+267 -49
View File
@@ -8,27 +8,28 @@ const tool = require('../../includes/apiTool');
const exec = require('child_process').exec; const exec = require('child_process').exec;
const so = require('../../includes/storeObject'); const so = require('../../includes/storeObject');
const crypt = require('../../libs/crypto'); const crypt = require('../../libs/crypto');
const path = require('path');
router router
.get('/', (req, res, n) => { .get('/', (req, res, n) => {
res.send({ name: 'WebIO IPCam API' }); res.send({ name: 'WebIO IPCam API' });
}) })
.post('*', async(req,res,n) => { .post('*', async(req, res, n) => {
try{ try {
res.db = await mysql.getConn(); res.db = await mysql.getConn();
}catch(e){ } catch (e) {
console.log(`Get DB Connection ERROR ${e}`); console.log(`Get DB Connection ERROR ${e}`);
return n('ERR8100'); return n('ERR8100');
} }
n(); n();
}) })
.post('/getipcamlist', (req,res,n) => { .post('/getipcamlist', (req, res, n) => {
if(!config.permission.ipcam) return n('ERR9000'); 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, 'ipcam']; let param = [config.db.db1, 'jcioccamset'];
res.db.query(query, param, (err, row) => { res.db.query(query, param, (err, row) => {
if(err) return rt.err(res,err,n,'ERR8000'); if (err) return rt.err(res, err, n, 'ERR8000');
res.api_res = { res.api_res = {
record: tool.checkArray(row) record: tool.checkArray(row)
@@ -37,68 +38,285 @@ router
n(); n();
}); });
}) })
.post('/addipcam', (req,res,n) => { .post('/addipcam', (req, res, n) => {
if(!config.permission.ipcam) return n('ERR9000'); if (!config.permission.ipcam) return n('ERR9000');
if(!tool.checkPermission(req)) return n('ERR9000'); if (!tool.checkPermission(req)) return n('ERR9000');
let arr = req.body; let arr = req.body;
if(!arr.data) return n('ERR0000'); if (!arr.data) return n('ERR0000');
if(!arr.data.ip) return n('ERR0010'); if (!arr.data.ip) return n("ERR0010");
if(!arr.data.name) return n('ERR0026'); if (!arr.data.name) return n('ERR0026');
if (!arr.data.model) return n('ERR0067');
if (!arr.data.maxevents) return n('ERR0068');
if (!arr.data.maximg) return n('ERR0069');
if (!/^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}$/.test(arr.data.ip)) return n('ERR0025');
if(!/^\d{1,3}\.\d{1,3}.\d{1,3}.\d{1,3}$/.test(arr.data.ip)) return n('ERR0025'); 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;
let query = "select count(*) as c from ??.?? where `ip` = ?"; let active = arr.data.active == 1 ? 1 : 0;
let param = [config.db.db1, 'ipcam', arr.data.ip];
res.db.query(query, param, (err, row) => { !async function runSync() {
if(err || row.length == 0) return rt.err(res,err,n,'ERR8000'); // data flag 0 is insert, 1 is update
if(row[0]['c'] > 0) return n('ERR0027'); let flag = 0;
let idx = 1;
// query db data
try {
let query = "select `uid` from ??.?? order by `uid` desc limit 1";
let param = [config.db.db1, 'jcioccamset'];
let id = await tool.promiseQuery(res, query, param);
if (id.data.length > 0 && id.data[0].uid) idx = id.data[0].uid + 1;
if (idx > config.ipcam_limit) {
query = "select `uid` from ??.?? where `delete` = 1 limit 1";
flag = 1;
let id = await tool.promiseQuery(res, query, param);
if (id.data.length > 0 && id.data[0].uid) idx = id.data[0].uid;
else return n('ERR0070');
}
query = "select count(*) as c from ??.?? where `ip` = ?";
param = [config.db.db1, 'jcioccamset', arr.data.ip];
let count = await tool.promiseQuery(res, query, param);
if (count.data.length == 0) return n('ERR8000');
if (count.data[0].c >= 1) return n('ERR0027');
} catch (e) {
return rt.err(res, e, n, 'ERR8000');
}
if (flag == 1) {
try {
let query = "update ??.?? set \
`ip` = ?, \
`name` = ?, \
`model` = ?, \
`maxevents` = ?, \
`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, u, idx];
await tool.promiseQuery(res, query, param);
} catch (e) {
return rt.err(res, e, n, 'ERR8002');
}
} else {
try {
let query = "insert into ??.?? (`uid`, `ip`, `name`, `model`, `maxevents`, `maximg`, `active`, `cuser`, `muser`, `ctime`, `mtime` ) \
values (?, ?, ?, ?, ?, ?, ?, ?, ?, unix_timestamp(), unix_timestamp())";
let param = [config.db.db1, 'jcioccamset', idx, arr.data.ip, arr.data.name, arr.data.model, arr.data.maxevents, arr.data.maximg, active, u, u];
await tool.promiseQuery(res, query, param);
} catch (e) {
return rt.err(res, e, n, 'ERR8001');
}
}
let query = "insert into ??.?? (`name`, `ip`) values (?,?)";
let param = [config.db.db1, 'ipcam', arr.data.name, arr.data.ip];
res.db.query(query, param, (err, row) => {
if(err) return rt.err(res,err,n,'ERR8001');
res.api_res = { res.api_res = {
record: [] record: []
}; }
n(); return n();
}); }()
});
}) })
.post('/delipcam', (req,res,n) => { .post('/editipcam', (req, res, n) => {
if(!config.permission.ipcam) return n('ERR9000'); if (!config.permission.ipcam) return n('ERR9000');
if(!tool.checkPermission(req)) return n('ERR9000'); if (!tool.checkPermission(req)) return n('ERR9000');
let arr = req.body; let arr = req.body;
if(!arr.data) return n('ERR0000'); if (!arr.data) return n('ERR0000');
if(!arr.data.id) return n('ERR0028'); if (!arr.data.id) return n('ERR0028');
if (!arr.data.ip) return n("ERR0010");
if (!arr.data.name) return n('ERR0026');
if (!arr.data.model) return n('ERR0067');
if (!arr.data.maxevents) return n('ERR0068');
if (!arr.data.maximg) return n('ERR0069');
if (!/^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}$/.test(arr.data.ip)) return n('ERR0025');
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;
let active = arr.data.active == 1 ? 1 : 0;
let query = "select count(*) as c from ??.?? where `ip` = ? and `uid` != ?";
let param = [config.db.db1, 'jcioccamset', arr.data.ip, arr.data.id];
let query = "delete from ??.?? where `uid` = ?";
let param = [config.db.db1, 'ipcam', arr.data.id];
res.db.query(query, param, (err, row) => { res.db.query(query, param, (err, row) => {
if(err) return rt.err(res,err,n,'ERR8003'); if (err || row.length == 0) return rt.err(res, err, n, 'ERR8000');
if (row[0].c >= 1) return n('ERR0027');
let query = "update ??.?? set \
`ip` = ?, \
`name` = ?, \
`model` = ?, \
`maxevents` = ?, \
`maximg` = ?, \
`active` = ?, \
`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];
res.db.query(query, param, (err, row) => {
if (err) return rt.err(res, err, n, 'ERR8002');
res.api_res = { res.api_res = {
record: [] record: []
}; }
n(); n();
}) })
});
}) })
.post('/editipcam', (req,res,n) => { .post('/delipcam', (req, res, n) => {
if(!config.permission.ipcam) return n('ERR9000'); if (!config.permission.ipcam) return n('ERR9000');
if(!tool.checkPermission(req)) return n('ERR9000'); if (!tool.checkPermission(req)) return n('ERR9000');
let arr = req.body; let arr = req.body;
if(!arr.data) return n('ERR0000'); if (!arr.data) return n('ERR0000');
if(!arr.data.id) return n('ERR0028'); if (!arr.data.id) return n('ERR0028');
if(!arr.data.name) return n('ERR0026');
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 = "update ??.?? set \
`delete` = 1, \
`muser` = ?, \
`mtime` = unix_timestamp() \
where `uid` = ?";
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');
let query = "update ??.?? set `name` = ? where `uid` = ?";
let param = [config.db.db1, 'ipcam', arr.data.name, arr.data.id];
res.db.query(query, param, (err,row) => {
if(err) return rt.err(res,err,n,'ERR8002');
res.api_res = { res.api_res = {
record: [] record: []
} }
n(); n();
}) })
}) })
.post('/swipcamactive', (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');
let query = "update ??.?? set \
`active` = case when `active` = 1 then 0 else 1 end \
where \
`uid` = ?";
let param = [config.db.db1, 'jcioccamset', arr.data.id];
res.db.query(query, param, (err, row) => {
if (err) return rt.err(res, err, n, 'ERR8002');
res.api_res = {
record: []
}
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();
})
.post('/delevent', 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.dir) return n('ERR0073');
let rp = config.cmdpath.ipcamsave;
let dp = path.resolve(rp, arr.data.dir);
try {
let stat = await new Promise((resolve, reject) => {
fs.stat(dp, (err, stats) => {
if (err) return reject(err);
return resolve(stats);
});
});
if (dp.split(' ')[0] == '/') return n('ERR0073');
await new Promise((resolve, reject) => {
exec(`rm -rf ${dp}`, (err, sout, serr) => {
if (err) return reject(err);
return resolve(null);
})
})
} catch (e) {
return rt.err(res, e, n, 'ERR0072');
}
res.api_res = {
record: []
}
return n();
})
.all('*', rt.send); .all('*', rt.send);
module.exports = router; module.exports = router;
+314 -16
View File
@@ -22,11 +22,11 @@ router
} }
n(); n();
}) })
.post('/getserverlist', (req, res, n) => { .post('/getdevicelist', (req, res, n) => {
if (!config.permission.server) return n('ERR9000'); if (!config.permission.server) return n('ERR9000');
let query = "select * from ??.??"; let query = "select * from ??.??";
let param = [config.db.db11, 'jciocservert']; let param = [config.db.db11, 'dev'];
res.db.query(query, param, (err, row) => { res.db.query(query, param, (err, row) => {
if (err) return rt.err(res, err, n, 'ERR8000'); if (err) return rt.err(res, err, n, 'ERR8000');
@@ -36,28 +36,326 @@ router
n(); n();
}) })
}) })
.post('/addserver', (req, res, n) => { .post('/getdevice', async(req, res, n) => {
if (!config.permission.server) return n('ERR9000');
let arr = req.body;
if (!arr.data) return n('ERR0000');
if (!arr.data.id) return n('ERR0028');
let query = "select * from ??.?? where `devuid` = ?";
let param = [config.db.db11, 'dev', arr.data.id];
try {
let dev = await tool.promiseQuery(res, query, param);
if (dev.data.length == 0) return n('ERR8000');
let ipmi_param = [config.db.db11, 'ipmi', arr.data.id];
let ipmi = await tool.promiseQuery(res, query, ipmi_param);
let snmp_param = [config.db.db11, 'snmp', arr.data.id];
let snmp = await tool.promiseQuery(res, query, snmp_param);
res.api_res = {
record: tool.checkArray(dev.data),
rt: {
ipmi: tool.checkArray(ipmi.data),
snmp: tool.checkArray(snmp.data)
}
}
} catch (e) {
return rt.err(res, e, n, 'ERR8000');
}
n();
})
.post('/adddevice', async(req, res, n) => {
if (!config.permission.server) return n('ERR9000'); if (!config.permission.server) return n('ERR9000');
if (!tool.checkPermission(req)) return n('ERR9000'); if (!tool.checkPermission(req)) return n('ERR9000');
let arr = req.body; let arr = req.body;
if (!arr.data) return n('ERR0000'); if (!arr.data) return n('ERR0000');
if (!arr.data.name) return n('ERR0026'); if (!arr.data.name) return n('ERR0026');
if (arr.data.iip) {
if (!arr.data.iaccount) return n('ERR0016');
if (!arr.data.ipassword) return n('ERR0017');
if (!arr.data.imac) return n('ERR0064');
if (!arr.data.itype) return n('ERR0009');
}
if (arr.data.sip) {
if (!arr.data.smac) return n('ERR0064');
if (!arr.data.stype) return n('ERR0009');
if (!arr.data.sname) return n('ERR0026');
if (!arr.data.sver) return n('ERR0065');
if (arr.data.sver == 'v3' && !arr.data.v3level) return n('ERR0066');
if (arr.data.v3level) {
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;
try {
let query = "insert into ??.?? (`name`, `ctime`, `cuser`, `mtime`, `muser`) values \
(?, unix_timestamp(), ?, unix_timestamp(), ?)";
let param = [config.db.db11, 'dev', arr.data.name, u, u];
await tool.promiseQuery(res, query, param);
} catch (e) {
return rt.err(res, e, n, 'ERR8001');
} }
res.api_res = {
record: []
};
n();
})
.post('/editdevice', async(req, res, n) => {
if (!config.permission.server) 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');
if (!arr.data.name) return n('ERR0026');
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;
try {
let query = "update ??.?? set \
`name` = ?, \
`muser` = ?, \
`mtime` = unix_timestamp() \
where \
`devuid` = ?";
let param = [config.db.db11, 'dev', arr.data.name, u, arr.data.id];
await tool.promiseQuery(res, query, param);
} catch (e) {
return rt.err(res, e, n, 'ERR8002');
} }
res.api_res = {
record: []
};
n();
})
.post('/deldevice', async(req, res, n) => {
if (!config.permission.server) 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 = "delete from ??.?? where `devuid` = ?";
let param = [config.db.db11, 'dev', arr.data.id];
await tool.promiseQuery(res, query, param);
} catch (err) {
return rt.err(res, err, n, 'ERR8003');
}
res.api_res = {
record: []
}
return n();
})
.post('/addipmi', async(req, res, n) => {
if (!config.permission.server) return n('ERR9000');
if (!tool.checkPermission(req)) return n('ERR9000');
let arr = req.body;
if (!arr.data) return n('ERR0000');
if (!arr.data.devuid) return n('ERR0028');
if (!arr.data.account) return n('ERR0016');
if (!arr.data.password) return n('ERR0017');
if (!arr.data.ip) return n('ERR0010');
try {
let query = "select count(*) as c from ??.?? where `ip` = ?";
let param = [config.db.db11, 'ipmi', arr.data.ip];
let c = await tool.promiseQuery(res, query, param);
if (c.data.length > 0 && c.data.c > 0) return n('ERR0027');
} catch (err) {
return rt.err(res, err, n, 'ERR8000');
}
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;
try {
let query = "insert into ??.?? (`devuid`, `ip`, `account`, `password`, `cuser`, `ctime`, `muser`, `mtime`) values \
(?, ?, ?, ?, ?, unix_timestamp(), ?, unix_timestamp())";
let param = [config.db.db11, 'ipmi', arr.data.devuid, arr.data.ip, arr.data.account, arr.data.password, u, u];
await tool.promiseQuery(res, query, param);
} catch (err) {
return rt.err(res, err, n, 'ERR8001');
}
res.api_res = {
record: []
};
return n();
})
.post('/editipmi', async(req, res, n) => {
if (!config.permission.server) 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');
if (!arr.data.account) return n('ERR0016');
if (!arr.data.password) return n('ERR0017');
if (!arr.data.ip) return n('ERR0010');
try {
let query = "select count(*) as c from ??.?? where `ipmuid` != ? and `ip` = ?";
let param = [config.db.db11, 'ipmi', arr.data.id, arr.data.ip];
let c = await tool.promiseQuery(res, query, param);
if (c.data.length > 0 && c.data.c > 0) return n('ERR0027');
} catch (err) {
return rt.err(res, err, n, 'ERR8000');
}
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;
try {
let query = "update ??.?? set \
`account` = ?, \
`password` = ?, \
`ip` = ?, \
`muser` = ?, \
`mtime` = unix_timestamp() \
where \
`ipmuid` = ?";
let param = [config.db.db11, 'ipmi', arr.data.account, arr.data.password, arr.data.ip, u, arr.data.id];
await tool.promiseQuery(res, query, param);
} catch (err) {
return rt.err(res, err, n, 'ERR8002');
}
res.api_res = {
record: []
};
return n();
})
.post('/delipmi', async(req, res, n) => {
if (!config.permission.server) 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 = "delete from ??.?? where `ipmuid` = ?";
let param = [config.db.db11, 'ipmi', arr.data.id];
await tool.promiseQuery(res, query, param);
} catch (err) {
return rt.err(res, err, n, 'ERR8003');
}
res.api_res = {
record: []
};
return n();
})
.post('/getipmiinfo', async(req, res, n) => {
if (!config.permission.server) return n('ERR9000');
let arr = req.body;
if (!arr.data) return n('ERR0000');
if (!arr.data.id) return n('ERR0028');
res.api_res = {
record: [],
rt: {
log: [],
sensor: [],
bmcgroup: [],
bmcdata: []
}
};
try {
let query = "select * from ??.?? where `ipmuid` = ?";
let param = [config.db.db11, 'ipmi', arr.data.id];
let ipmi = await tool.promiseQuery(res, query, param);
if (ipmi.data.length == 0) return n('ERR8000');
delete ipmi.data[0].password;
res.api_res.record = tool.checkArray(ipmi.data);
query = "select * from ??.?? order by `guid`";
param = [config.db.db11, 'bmg'];
let bmg = await tool.promiseQuery(res, query, param);
res.api_res.rt.bmcgroup = tool.checkArray(bmg.data);
query = "select * from ??.?? where `ipmuid` = ?";
param = [config.db.db11, 'bmrt', arr.data.id];
let bmrt = await tool.promiseQuery(res, query, param);
res.api_res.rt.bmcdata = tool.checkArray(bmrt.data);
query = "select * from ??.?? where `ipmuid` = ?";
param = [config.db.db11, 'ipmilogrt', arr.data.id];
let log = await tool.promiseQuery(res, query, param);
res.api_res.rt.log = tool.checkArray(log.data);
query = "select * from ??.?? where `ipmuid` = ?";
param = [config.db.db11, 'ipmisenrt', arr.data.id];
let sensor = await tool.promiseQuery(res, query, param);
res.api_res.rt.sensor = tool.checkArray(sensor.data);
} catch (err) {
return rt.err(res, err, n, 'ERR8000');
}
return n();
})
.post('/getbmctl', async(req, res, n) => {
if (!config.permission.server) return n('ERR9000');
try {
let query = "select `uid`,`name` from ??.??";
let param = [config.db.db11, 'bmctl'];
let ctls = await tool.promiseQuery(res, query, param);
res.api_res = {
record: tool.checkArray(ctls.data)
}
} catch (err) {
return rt.err(res, err, n, 'ERR8000');
}
return n();
})
.post('/runbmctl', async(req, res, n) => {
if (!config.permission.server) return n('ERR9000');
if (!tool.checkPermission(req)) return n('ERR9000');
let arr = req.body;
if (!arr.data) return n('ERR0000');
if (!arr.data.ctlid || !arr.data.ipmuid) return n('ERR0028');
res.api_res = {
record: []
};
try {
let query = "select * from ??.?? where `uid` = ?";
let param = [config.db.db11, 'bmctl', arr.data.ctlid];
let ctl = await tool.promiseQuery(res, query, param);
if (ctl.data.length == 0) return n('ERR8000');
query = "select * from ??.?? where `ipmuid` = ?";
param = [config.db.db11, 'ipmi', arr.data.ipmuid];
let ipmi = await tool.promiseQuery(res, query, param);
if (ipmi.data.length == 0) return n('ERR8000');
let cmd = ctl.data[0].cmd;
cmd = cmd.trim();
if (!cmd) return n('ERR7000');
cmd = cmd.replace(/\@ipmuid/i, ipmi.data[0].ipmuid);
let result = await new Promise((resolve, reject) => {
exec(cmd, (err, stderr, stdout) => {
if (err) return reject(err);
return resolve(stdout || stderr);
});
})
result = result.split(/\n/).filter(e => e).join('');
if (result == 0) return n('ERR7000');
} catch (err) {
return rt.err(res, err, n, 'ERR8000');
}
return n();
}) })
.all('*', rt.send); .all('*', rt.send);
@@ -0,0 +1,82 @@
import React from 'react';
import { Modal, Grid, List, Menu, Icon, Message } from 'semantic-ui-react';
import {convertTime} from '../../../tools';
import ImgGrid from './EvtImgGrid';
const EventModal = ({ i18n, open, name, list, sel, closeEventModal, changeSelectEvent,refreshEvt, delEvent }) => {
return (
<Modal open={open} onClose={()=>{closeEventModal()}} size="fullscreen">
<Modal.Header content={`IPCam: ${name}`} />
<Modal.Content>
<Grid>
<Grid.Column width={4}>
<Menu vertical>
<Menu.Item>
<Menu.Header>
事件列表
<Icon name="refresh" style={{
cursor: "pointer",
float: 'right'
}} onClick={()=>{refreshEvt(-1)}}/>
</Menu.Header>
<Menu.Menu>
{
list.map((t,idx) =>{
let n = t.name;
let time = n.split('-')[1];
return (
<Menu.Item key={idx} active={sel == idx} >
<span onClick={()=>{changeSelectEvent(idx)}}
style={{cursor: "pointer"}}>{convertTime(time, true)}</span>
<Icon name="download" title="下載事件" style={{
cursor: "pointer",
float: 'right'
}} onClick={()=>{window.open(`/dlevent/${t.name}`, '_blank')}}/>
<Icon name="trash" title="刪除事件" style={{
cursor: "pointer",
float: 'right'
}} onClick={()=>{delEvent(t.name)}}/>
</Menu.Item>
)})
}
</Menu.Menu>
</Menu.Item>
</Menu>
</Grid.Column>
<Grid.Column width={12}>
{
sel != -1 && list[sel].files.video.length > 0 ? (
<Message>
<Message.Header>影片下載</Message.Header>
<p>
{
list[sel].files.video.map((t, idx) => {
return (
<div key={idx}>
<a href={`/dlcamvideo/${list[sel].name}/${t}`} target="_blank">{t}</a>
</div>
)
})
}
</p>
</Message>
) :null
}
{
sel != -1 ?
(
<ImgGrid i18n={i18n}
dname={list[sel].name}
list={list[sel].files.img} />
) : null
}
</Grid.Column>
</Grid>
</Modal.Content>
</Modal>
)
}
export default EventModal;
@@ -0,0 +1,21 @@
import React from 'react';
import {Grid, Image} from 'semantic-ui-react';
const EvtImgGrid = ({ i18n, dname, list }) => {
return (
<Grid columns={3}>
{
list.map((t,idx) => {
return (
<Grid.Column key={idx}>
<Image fluid src={`/viewcamimg/${dname}/${t}`} href={`/viewcamimg/${dname}/${t}`} target="_blank"/>
</Grid.Column>
)
})
}
</Grid>
)
}
export default EvtImgGrid;
@@ -0,0 +1,68 @@
import React from 'react';
import { Modal, Form, Grid, Button, Input, Checkbox } from 'semantic-ui-react';
const IPCamModal = ({ i18n, open, type, data, closeModal, submitModal }) => {
return (
<Modal open={open}>
<Modal.Header content={type == 1 ? '修改資料' : '新增資料'} />
<Modal.Content>
<Form onSubmit={(e,d) => {
e.preventDefault();
submitModal(type, d.formData);
}} serializer={e=>{
let json = {};
let name = e.querySelector('input[name="name"]');
if(name && 'value' in name) json.name = name.value;
let ip = e.querySelector('input[name="ip"]');
if(ip && 'value' in ip) json.ip = ip.value;
let model = e.querySelector('select[name="model"]');
if(model && 'value' in model) json.model = model.value;
let maxevents = e.querySelector('input[name="maxevents"]');
if(maxevents && 'value' in maxevents) json.maxevents = maxevents.value;
let maximg = e.querySelector('input[name="maximg"]');
if(maximg && 'value' in maximg) json.maximg = maximg.value;
let active = e.querySelector('input[type="checkbox"]');
if(active && 'checked' in active) json.active = active.checked;
if(type == 1) json.id = data.uid;
return json;
}}>
<Form.Field>
<Checkbox label="啟用裝置" defaultChecked={data.active == 1} name="active" />
</Form.Field>
<Form.Field>
<Input name="name" label="名稱" defaultValue={data.name} />
</Form.Field>
<Form.Field>
<Input name="ip" label="IP" defaultValue={data.ip} />
</Form.Field>
<Form.Field>
<select defaultValue={data.model} name="model">
<option value="">請選擇型號</option>
<option value="AXIS-M1124">AXIS-M1124</option>
<option value="GRANDSTREAM-GXV3610_HD">GRANDSTREAM-GXV3610_HD</option>
</select>
</Form.Field>
<Form.Field>
<Input name="maxevents" label="最大儲存事件數量(1-10)" defaultValue={data.maxevents} />
</Form.Field>
<Form.Field>
<Input name="maximg" label="最大儲存圖片數量(1-20)" defaultValue={data.maximg} />
</Form.Field>
<Grid columns={2}>
<Grid.Column>
<Button type="submit" fluid content="送出" />
</Grid.Column>
<Grid.Column>
<Button type="button" fluid content="取消" onClick={()=>{closeModal()}} />
</Grid.Column>
</Grid>
</Form>
</Modal.Content>
</Modal>
)
}
export default IPCamModal;
@@ -0,0 +1,23 @@
import React from 'react';
import {Table, Button} from 'semantic-ui-react';
const ListItem = ({ i18n, data, swActive, openModal, delIPCam, getEvents }) => {
return (
<Table.Row>
<Table.Cell>
<Button basic content="修改" type="button" onClick={()=>openModal(1, data)} />
<Button basic content="刪除" type="button" onClick={()=>delIPCam(data.uid)}/>
<Button basic content={data.active == 1 ? '停用' : '啟用'} type="button" onClick={()=>swActive(data.uid)} />
<Button basic content="事件紀錄" type="button" onClick={()=>getEvents(data.uid, data.name)} />
</Table.Cell>
<Table.Cell>{data.name}</Table.Cell>
<Table.Cell>{data.ip}</Table.Cell>
<Table.Cell>{data.model}</Table.Cell>
<Table.Cell>{data.model == 'AXIS-M1124' ? `/${data.model}-${data.uid}` : '/'}</Table.Cell>
<Table.Cell>{data.active == 1? '啟用' : '停用'}</Table.Cell>
</Table.Row>
)
}
export default ListItem;
+212 -4
View File
@@ -1,12 +1,220 @@
import React from 'react'; import React from 'react';
import {} from 'semantic-ui-react'; import { Container, Segment, Table, Button, Label, Message } from 'semantic-ui-react';
import {getRequest} from '../../../actions';
import ListItem from './ListItem';
import IPCamModal from './IPCamModal';
import EvtModal from './EventModal';
class IPCamPage extends React.Component{ const stateDefault = ()=>({
list: [],
modal: {
type: 0,
open: false,
data: {}
},
evt: {
open: false,
list: [],
name: '',
sel: -1,
id: -1
}
})
render(){ class IPCamPage extends React.Component {
state = {
...stateDefault()
}
componentDidMount(){
this.getList();
}
getList = () => {
let {toggleLoading, showDialog} = this.props;
toggleLoading(1);
fetch('/api/ipcam/getipcamlist', getRequest())
.then(response => response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
let list = json.data.record || [];
this.setState({
list
})
})
}
swActive = (id) => {
if(!id) return ;
let {toggleLoading, showDialog} = this.props;
toggleLoading(1);
fetch('/api/ipcam/swipcamactive', getRequest({id}))
.then(response=>response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
this.getList();
})
}
openModal = (type, data = {}) => {
this.setState({
modal: {
type,
data,
open: true
}
})
}
closeModal = () => {
this.setState({
modal: {
...stateDefault().modal
}
})
}
submitModal = (type, data = {}) => {
let {toggleLoading,showDialog} = this.props;
if(type == 1 && !data.id) return showDialog('資料讀取錯誤');
if(!data.maxevents || data.maxevents < 1 || data.maxevents > 10) return showDialog('事件數量請介於1-5間');
if(!data.maximg || data.maximg < 1 || data.maximg > 20) return showDialog('圖片數量請介於1-5間');
if(!data.name) return showDialog('請輸入名稱');
if(!data.ip) return showDialog('請輸入IP');
if(!data.model) return showDialog('請選擇型號');
toggleLoading(1);
let url = type == 1 ? '/api/ipcam/editipcam' : '/api/ipcam/addipcam';
fetch(url, getRequest(data))
.then(response=>response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
this.closeModal();
this.getList();
})
}
delIPCam = (id) => {
if(!id) return ;
let {callConfirm, toggleLoading, showDialog} = this.props;
callConfirm('確定要刪除此筆資料?', ()=>{
fetch('/api/ipcam/delipcam', getRequest({id}))
.then(response=>response.json())
.then(json => {
if(json.status != 1) return showDialog(json.message);
this.getList();
})
});
}
getEvents = (id, name = '') => {
if(!id) return ;
if(id==-1) id = this.state.evt.id;
let {callConfirm, toggleLoading, showDialog} = this.props;
toggleLoading(1);
fetch('/api/ipcam/getevents', getRequest({id}))
.then(response=>response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
this.setState({
evt: {
open: true,
list: json.data.record || [],
name: name != '' ? name : this.state.evt.name,
sel: -1,
id
}
})
})
}
closeEventModal = () => {
this.setState({
evt: {
...stateDefault().evt
}
})
}
changeSelectEvent = (idx) => {
if(!isFinite(idx) || idx < 0) return ;
this.setState({
evt:{
...this.state.evt,
sel: idx
}
})
}
delEvent = (dir) => {
if(!dir) return ;
let {callConfirm, toggleLoading, showDialog} = this.props;
callConfirm('確定刪除這筆事件?', ()=>{
toggleLoading(1);
fetch('/api/ipcam/delevent', getRequest({dir}))
.then(response=>response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
this.getEvents(-1);
})
})
}
render() {
let {i18n} = this.props;
return ( return (
null <Container>
<Segment className="clearfix">
<Message>
<Message.Header>攝影機事件通知位址</Message.Header>
<p>
{`${location.protocol}//${location.host}/camevent`}
</p>
</Message>
<Button basic content="新增" icon="plus" floated="right" type="button" style={{marginBottom: '15px'}} color="green" onClick={()=>{this.openModal(0)}} />
<Table>
<Table.Header>
<Table.Row>
<Table.HeaderCell>操作</Table.HeaderCell>
<Table.HeaderCell>名稱</Table.HeaderCell>
<Table.HeaderCell>IP</Table.HeaderCell>
<Table.HeaderCell>型號</Table.HeaderCell>
<Table.HeaderCell>FTP路徑</Table.HeaderCell>
<Table.HeaderCell>啟用狀態</Table.HeaderCell>
</Table.Row>
</Table.Header>
<Table.Body>
{
this.state.list.map((t,idx) => (
<ListItem key={idx}
i18n={i18n}
data={t}
swActive={this.swActive}
delIPCam={this.delIPCam}
openModal={this.openModal}
getEvents={this.getEvents} />
))
}
</Table.Body>
</Table>
</Segment>
<IPCamModal i18n={i18n}
open={this.state.modal.open}
data={this.state.modal.data}
type={this.state.modal.type}
closeModal={this.closeModal}
submitModal={this.submitModal} />
<EvtModal i18n={i18n}
open={this.state.evt.open}
list={this.state.evt.list}
sel={this.state.evt.sel}
name={this.state.evt.name}
refreshEvt={this.getEvents}
closeEventModal={this.closeEventModal}
changeSelectEvent={this.changeSelectEvent}
delEvent={this.delEvent} />
</Container>
) )
} }
} }
@@ -0,0 +1,40 @@
import React from 'react';
import { Menu, List, Icon } from 'semantic-ui-react';
class DevList extends React.Component {
render() {
let {list, sel,selectDevice, openModal, delData} = this.props;
return (
<Menu vertical>
<Menu.Item>
<Menu.Header className="clearfix">
裝置列表
<Icon name="plus"
style={{float: 'right',cursor:'pointer'}}
onClick={()=>openModal('device')} />
</Menu.Header>
<Menu.Menu>
{
list.map((t,idx)=>(
<Menu.Item key={idx} active={sel == t.devuid}>
<span style={{cursor:'pointer'}} onClick={()=>selectDevice(t.devuid)}>{t.name}</span>
<Icon name="trash"
style={{cursor:'pointer'}}
onClick={()=>delData('device', t.devuid)} />
<Icon name="edit"
style={{cursor:'pointer'}}
onClick={()=>openModal('device', 1, t)} />
</Menu.Item>
))
}
</Menu.Menu>
</Menu.Item>
</Menu>
)
}
}
export default DevList;
@@ -0,0 +1,27 @@
import React from 'react';
import {Table, Button} from 'semantic-ui-react';
const SetListItem = ({ i18n, data, openModal, delData, bmctl, runbmctl }) => {
return (
<Table.Row>
<Table.Cell>
<Button content="修改" basic onClick={()=>openModal('ipmi', 1, data)} />
<Button content="刪除" basic onClick={()=>delData('ipmi', data.ipmuid)} />
<Button content="ShowInfo" basic onClick={()=>openModal('ipmiinfo', 0, {id: data.ipmuid})} />
</Table.Cell>
<Table.Cell>
{
bmctl.map((t,idx) => (
<Button key={idx} content={t.name} type="button" onClick={()=>runbmctl(t.uid, data.ipmuid)} />
))
}
</Table.Cell>
<Table.Cell>{data.ip}</Table.Cell>
<Table.Cell>{data.account}</Table.Cell>
<Table.Cell>{data.mac}</Table.Cell>
</Table.Row>
)
}
export default SetListItem;
@@ -0,0 +1,47 @@
import React from 'react';
import {Container, Segment, Button, Table} from 'semantic-ui-react';
import SelListItem from './SetListItem';
const IPMIPage = ({i18n, list, openModal, delData, bmctl, runbmctl}) => {
return (
<Container>
<Segment className="clearfix">
<Button content="新增設定"
icon="plus"
floated="right"
basic
color="green"
style={{marginBottom: '15px'}}
onClick={()=>openModal('ipmi')} />
<Table>
<Table.Header>
<Table.Row>
<Table.HeaderCell>操作</Table.HeaderCell>
<Table.HeaderCell>設備操作</Table.HeaderCell>
<Table.HeaderCell>IP</Table.HeaderCell>
<Table.HeaderCell>帳號</Table.HeaderCell>
<Table.HeaderCell>MAC Address</Table.HeaderCell>
</Table.Row>
</Table.Header>
<Table.Body>
{
list.map((t,idx) => {
return (
<SelListItem key={idx}
i18n={i18n}
data={t}
openModal={openModal}
delData={delData}
bmctl={bmctl}
runbmctl={runbmctl} />
)
})
}
</Table.Body>
</Table>
</Segment>
</Container>
)
}
export default IPMIPage;
@@ -0,0 +1,40 @@
import React from 'react';
import {Modal, Form, Input, Button, Grid} from 'semantic-ui-react';
const DevModel = ({ i18n, open, type, data, closeModal, submitModal }) => {
return (
<Modal open={open}>
<Modal.Header content={type == 1 ? '修改裝置' : '新增裝置'} />
<Modal.Content>
<Form onSubmit={(e,d) => {
e.preventDefault();
submitModal('device', type, d.formData);
}} serializer={e=>{
let json = {};
let name = e.querySelector('input[name="name"]');
if(name && 'value' in name) json.name = name.value;
if(type == 1) json.id = data.devuid;
return json;
}}>
<Form.Field>
<Input label="裝置名稱" name="name" defaultValue={data.name} />
</Form.Field>
<Grid columns={2}>
<Grid.Column>
<Button type="submit" content="送出" basic fluid/>
</Grid.Column>
<Grid.Column>
<Button type="button" fluid content="取消" basic onClick={()=>closeModal('device')} />
</Grid.Column>
</Grid>
</Form>
</Modal.Content>
</Modal>
)
}
export default DevModel;
@@ -0,0 +1,150 @@
import React from 'react';
import {Modal, Segment, Menu, Label, Container, Header, List, Table} from 'semantic-ui-react';
import {convertTime} from '../../../../tools';
const stateDefault = () => ({
open: false,
tabIdx: 1
})
class IPMIInfoModal extends React.Component {
state = {...stateDefault()}
componentWillReceiveProps(nextProps){
if(nextProps.open != this.state.open){
if(nextProps.open == false){
this.setState({...stateDefault()})
}else{
this.setState({
open: true
})
}
}
}
changeIdx = (idx) => {
this.setState({
tabIdx: idx
})
}
getInfoView = () => {
switch(this.state.tabIdx){
case 1:
return <BMCContent group={this.props.bmcgroup} data={this.props.bmcdata} />
case 2:
return <SensorContent sensor={this.props.sensor} />
case 3:
return <LogContent log={this.props.log} />
default:
return null;
}
}
render() {
let {closeModal} = this.props;
return (
<Modal size="fullscreen" open={this.state.open} onClose={()=>closeModal('ipmiinfo')}>
<Modal.Header content="IPMI Info" />
<Modal.Content>
<Menu attached="top" tabular>
<Menu.Item name="BMC Info" active={this.state.tabIdx == 1} onClick={()=>this.changeIdx(1)} />
<Menu.Item name="Sensor" active={this.state.tabIdx == 2} onClick={()=>this.changeIdx(2)} />
<Menu.Item name="Log" active={this.state.tabIdx == 3} onClick={()=>this.changeIdx(3)} />
</Menu>
<Segment attached="bottom">
{this.getInfoView()}
</Segment>
</Modal.Content>
</Modal>
)
}
}
const BMCContent = ({group, data}) => {
return (
<Container fluid>
{
group.map((t,idx) => (
<Segment key={idx}>
<Header as="h3" color="blue">
{t.name}
<Header.Subheader>{t.value}</Header.Subheader>
</Header>
<List>
{
data.map((t2, idx) => {
if(t2.guid != t.guid) return null;
return (
<List.Item key={idx}>
<Label content={t2.name} basic />
{t2.value}
</List.Item>
)})
}
</List>
</Segment>
))
}
</Container>
)
}
const LogContent = ({log}) => {
return (
<Container fluid>
<Table>
<Table.Header>
<Table.Row>
<Table.HeaderCell>行號</Table.HeaderCell>
<Table.HeaderCell>時間</Table.HeaderCell>
<Table.HeaderCell>內容</Table.HeaderCell>
</Table.Row>
</Table.Header>
<Table.Body>
{
log.map((t,idx) => (
<Table.Row>
<Table.Cell>{t.line}</Table.Cell>
<Table.Cell>{convertTime(t.time, true)}</Table.Cell>
<Table.Cell>{t.content}</Table.Cell>
</Table.Row>
))
}
</Table.Body>
</Table>
</Container>
)
}
const SensorContent = ({sensor}) => {
return (
<Container fluid>
<Table>
<Table.Header>
<Table.Row>
<Table.HeaderCell>名稱</Table.HeaderCell>
<Table.HeaderCell>數值</Table.HeaderCell>
<Table.HeaderCell>單位</Table.HeaderCell>
<Table.HeaderCell>狀態</Table.HeaderCell>
</Table.Row>
</Table.Header>
<Table.Body>
{
sensor.map((t,idx) => (
<Table.Row>
<Table.Cell>{t.name}</Table.Cell>
<Table.Cell>{t.value}</Table.Cell>
<Table.Cell>{t.unit}</Table.Cell>
<Table.Cell>{t.status}</Table.Cell>
</Table.Row>
))
}
</Table.Body>
</Table>
</Container>
)
}
export default IPMIInfoModal;
@@ -0,0 +1,50 @@
import React from 'react';
import {Modal, Form, Grid, Input, Button } from 'semantic-ui-react';
const IPMIModal = ({ i18n, open, type, data, closeModal, submitModal }) => {
return (
<Modal open={open}>
<Modal.Header content={type == 1 ? '修改設定' : '新增設定'} />
<Modal.Content>
<Form onSubmit={(e,d) => {
e.preventDefault();
submitModal('ipmi', type, d.formData);
}} serializer={e=>{
let json ={};
let ip = e.querySelector('input[name="ip"]');
if(ip && 'value' in ip) json.ip = ip.value;
let account = e.querySelector('input[name="account"]');
if(account && 'value' in account) json.account = account.value;
let pass = e.querySelector('input[name="password"]');
if(pass && 'value' in pass) json.password = pass.value;
if(type == 1 ) json.id = data.ipmuid;
return json;
}}>
<Form.Field>
<Input label="IP" name="ip" defaultValue={data.ip} />
</Form.Field>
<Form.Field>
<Input label="帳號" name="account" defaultValue={data.account} />
</Form.Field>
<Form.Field>
<Input label="密碼" name="password" defaultValue={data.password} />
</Form.Field>
<Grid columns={2}>
<Grid.Column>
<Button type="submit" content="送出" basic fluid/>
</Grid.Column>
<Grid.Column>
<Button type="button" fluid content="取消" basic onClick={()=>closeModal('ipmi')} />
</Grid.Column>
</Grid>
</Form>
</Modal.Content>
</Modal>
)
}
export default IPMIModal;
@@ -0,0 +1,18 @@
import React from 'react';
import {Container, Segment} from 'semantic-ui-react';
class SNMPPage extends React.Component {
render() {
return (
<Container>
<Segment>
</Segment>
</Container>
)
}
}
export default SNMPPage;
+333
View File
@@ -0,0 +1,333 @@
import React from 'react';
import { Container, Segment, Menu, List, Grid } from 'semantic-ui-react';
import {getRequest} from '../../../actions';
import DevList from './DevList';
import IPMIPage from './IPMIPage';
import DevModal from './Modals/DevModal';
import IPMIModal from './Modals/IPMIModal';
import IPMIInfoModal from './Modals/IPMIInfoModal';
const stateDefault = ()=>({
list: [],
bmctl: [],
devSel: {
id: null,
type: null,
data: {
snmp: [],
ipmi: []
}
},
devModal: {
open: false,
type: 0,
data: {}
},
ipmiModal: {
open: false,
type: 0,
data: {}
},
ipmiInfo: {
open: false,
ipmi: [],
log: [],
sensor: [],
bmcdata: [],
bmcgroup: []
}
})
class ServerPage extends React.Component {
state = {...stateDefault()}
componentDidMount(){
this.getDevList();
this.getBMCtl();
}
getDevList = () => {
let {showDialog, toggleLoading} = this.props;
toggleLoading(1);
fetch('/api/server/getdevicelist', getRequest())
.then(response => response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
this.setState({
list: json.data.record || []
})
})
}
getBMCtl = () => {
fetch('/api/server/getbmctl', getRequest())
.then(response=>response.json())
.then(json => {
if(json.status == 1) {
this.setState({
bmctl: json.data.record || []
})
}
})
}
selectDevice = (id, refresh = false) => {
if(!id) return ;
let {showDialog, toggleLoading} = this.props;
toggleLoading(1);
fetch('/api/server/getdevice', getRequest({id}))
.then(response=>response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
let ipmi = json.data.rt.ipmi || [];
let snmp = json.data.rt.snmp || [];
let jdata = {
...stateDefault().devSel,
id,
data: {
ipmi,
snmp
}
};
if(refresh) jdata.type = this.state.devSel.type;
this.setState({
devSel: jdata
})
})
}
selectDataType = (type) => {
this.setState({
devSel: {
...this.state.devSel,
type: type
}
})
}
genSubPage = () => {
let {i18n, showDialog, toggleLoading, callConfirm} = this.props;
switch(this.state.devSel.type){
case 'ipmi':
return <IPMIPage i18n={i18n}
showDialog={showDialog}
toggleLoading={toggleLoading}
callConfirm={callConfirm}
list={this.state.devSel.data.ipmi}
openModal={this.openModal}
closeModal={this.closeModal}
delData={this.delData}
bmctl={this.state.bmctl}
runbmctl={this.runbmctl} />
default:
return null;
}
}
openModal = (mtype, type = 0, data = {}) => {
switch(mtype){
case 'device':
this.setState({
devModal: {
open: true,
type,
data
}
})
break;
case 'ipmi':
this.setState({
ipmiModal:{
open: true,
type,
data
}
});
break;
case 'ipmiinfo':
this.getIPMIData(data.id);
break;
default:
return null;
}
}
closeModal = (mtype, cb = null) => {
switch(mtype){
case 'device':
this.setState({devModal: {...stateDefault().devModal}});
break;
case 'ipmi':
this.setState({ipmiModal:{...stateDefault().ipmiModal}});
break;
case 'ipmiinfo':
this.setState({ipmiInfo: {...stateDefault().ipmiInfo}});
break;
}
if(cb && typeof cb == 'function') cb();
}
submitModal = (mtype, type = 0, data = {}) => {
if(!mtype) return ;
let {i18n, showDialog, toggleLoading, callConfirm} = this.props;
let url = '';
switch(mtype){
case 'device':
if(type == 1 && !data.id) return showDialog('資料讀取錯誤');
if(!data.name) return showDialog('請填寫設備名稱');
url = type == 1 ? '/api/server/editdevice' : '/api/server/adddevice';
fetch(url, getRequest(data))
.then(response => response.json())
.then(json => {
if(json.status != 1) return showDialog(json.message);
this.closeModal(mtype, ()=>{this.getDevList()});
});
break;
case 'ipmi':
if(type == 1 && !data.id) return showDialog('資料讀取錯誤');
if(!data.ip) return showDialog('請填寫IP');
if(!data.account) return showDialog('請填寫帳號');
if(!data.password) return showDialog('請填寫密碼');
data.devuid = this.state.devSel.id;
url = type == 1 ? '/api/server/editipmi' : '/api/server/addipmi';
fetch(url, getRequest(data))
.then(response=>response.json())
.then(json => {
if(json.status != 1) return showDialog(json.message);
this.closeModal(mtype, ()=>{ this.selectDevice(this.state.devSel.id, true); })
})
default :
return null;
}
}
delData = (mtype, id) => {
if(!mtype || !id) return ;
let {i18n, showDialog, toggleLoading, callConfirm} = this.props;
switch(mtype) {
case 'device':
callConfirm('確定刪除此裝置?', ()=>{
fetch('/api/server/deldevice', getRequest({id}))
.then(response=>response.json())
.then(json => {
if(json.status != 1) return showDialog(json.message);
this.getDevList();
})
});
break;
case 'ipmi':
callConfirm('確定刪除此筆設定?', ()=>{
fetch('/api/server/delipmi', getRequest({id}))
.then(response=>response.json())
.then(json => {
if(json.status != 1) return showDialog(json.message);
this.selectDevice(this.state.devSel.id, true);
});
});
break;
}
}
getIPMIData = (id) => {
if(!id) return ;
let {i18n, showDialog, toggleLoading, callConfirm} = this.props;
toggleLoading(1);
fetch('/api/server/getipmiinfo', getRequest({id}))
.then(response=>response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
let ipmi = json.data.record || [];
let sensor = json.data.rt.sensor || [];
let log = json.data.rt.log || [];
let bmcgroup = json.data.rt.bmcgroup || [];
let bmcdata = json.data.rt.bmcdata || [];
this.setState({
ipmiInfo: {
open: true,
log,
sensor,
ipmi,
bmcdata,
bmcgroup
}
})
})
}
runbmctl = (ctlid, ipmuid) => {
if(!ctlid || !ipmuid) return ;
let {i18n, showDialog, toggleLoading, callConfirm} = this.props;
toggleLoading(1);
fetch('/api/server/runbmctl', getRequest({ctlid, ipmuid}))
.then(response=>response.json())
.then(json => {
toggleLoading(0);
if(json.status != 1) return showDialog(json.message);
return showDialog('命令執行完成');
})
}
render() {
let {i18n, showDialog, toggleLoading, callConfirm} = this.props;
return (
<Container fluid>
<Grid>
<Grid.Column width={3}>
<DevList i18n={i18n}
toggleLoading={toggleLoading}
showDialog={showDialog}
callConfirm={callConfirm}
sel={this.state.devSel.id}
selectDevice={this.selectDevice}
list={this.state.list}
openModal={this.openModal}
delData={this.delData} />
</Grid.Column>
<Grid.Column width={13}>
{
this.state.devSel.id != null ?
(
<Container style={{marginBottom: '10px'}}>
<Menu fluid widths={2}>
<Menu.Item name="SNMP"
active={this.state.devSel.type == 'snmp'}
onClick={()=>this.selectDataType('snmp')}/>
<Menu.Item name="IPMI"
active={this.state.devSel.type == 'ipmi'}
onClick={()=>this.selectDataType('ipmi')}/>
</Menu>
</Container>
) : null
}
{this.genSubPage()}
</Grid.Column>
</Grid>
<DevModal i18n={i18n}
open={this.state.devModal.open}
type={this.state.devModal.type}
data={this.state.devModal.data}
closeModal={this.closeModal}
submitModal={this.submitModal} />
<IPMIModal i18n={i18n}
open={this.state.ipmiModal.open}
type={this.state.ipmiModal.type}
data={this.state.ipmiModal.data}
closeModal={this.closeModal}
submitModal={this.submitModal} />
<IPMIInfoModal i18n={i18n}
{...this.state.ipmiInfo}
closeModal={this.closeModal} />
</Container>
)
}
}
export default ServerPage;
+1
View File
@@ -22,6 +22,7 @@ const MainMenu = ({i18n, show, toggleMenu, children, permissions, showDashboard,
<MItem toLink="/admin/link" txt={i18n && 't' in i18n ? i18n.t('menu.item.link') : ''} permission={permissions.link} onClick={()=>toggleMenu()} /> <MItem toLink="/admin/link" txt={i18n && 't' in i18n ? i18n.t('menu.item.link') : ''} permission={permissions.link} onClick={()=>toggleMenu()} />
<MItem toLink="/admin/ipcam" txt={i18n && 't' in i18n ? i18n.t('menu.item.ipcam') : ''} permission={permissions.ipcam} onClick={()=>toggleMenu()} /> <MItem toLink="/admin/ipcam" txt={i18n && 't' in i18n ? i18n.t('menu.item.ipcam') : ''} permission={permissions.ipcam} onClick={()=>toggleMenu()} />
<MItem toLink="/admin/wristband" txt={i18n && 't' in i18n ? i18n.t('menu.item.wristband') : ''} permission={permissions.wristband} onClick={()=>toggleMenu()} /> <MItem toLink="/admin/wristband" txt={i18n && 't' in i18n ? i18n.t('menu.item.wristband') : ''} permission={permissions.wristband} onClick={()=>toggleMenu()} />
<MItem toLink="/admin/server" txt="伺服器(Server)" permission={permissions.server} onClick={()=>toggleMenu()} />
<MItem toLink="/admin" txt={i18n && 't' in i18n ? i18n.t('menu.item.logout') : ''} permission={true} onClick={()=>{ <MItem toLink="/admin" txt={i18n && 't' in i18n ? i18n.t('menu.item.logout') : ''} permission={true} onClick={()=>{
sessionStorage.clear(); sessionStorage.clear();
location.replace('/'); location.replace('/');
+5 -2
View File
@@ -1,5 +1,5 @@
import {connect} from 'react-redux'; import { connect } from 'react-redux';
import {add_dialog_msg, toggle_loading} from '../../actions'; import { add_dialog_msg, toggle_loading, add_confirm } from '../../actions';
import IPCamPage from '../../components/AdminPage/IPCam'; import IPCamPage from '../../components/AdminPage/IPCam';
const mapStateToProps = (state) => ({ const mapStateToProps = (state) => ({
@@ -12,6 +12,9 @@ const mapDispatchToProps = (dispatch, ownProps) => ({
}, },
toggleLoading: (flag = false) => { toggleLoading: (flag = false) => {
dispatch(toggle_loading(flag)); dispatch(toggle_loading(flag));
},
callConfirm: (msg, act = null) => {
dispatch(add_confirm(msg, act));
} }
}) })
+21
View File
@@ -0,0 +1,21 @@
import { connect } from 'react-redux';
import { add_dialog_msg, toggle_loading, add_confirm } from '../../actions';
import ServerPage from '../../components/AdminPage/Server';
const mapStateToProps = (state) => ({
i18n: state.i18n
});
const mapDispatchToProps = (dispatch, ownProps) => ({
showDialog: (msg) => {
dispatch(add_dialog_msg(msg));
},
toggleLoading: (flag = false) => {
dispatch(toggle_loading(flag));
},
callConfirm: (msg, act = null) => {
dispatch(add_confirm(msg, act));
}
})
export default connect(mapStateToProps, mapDispatchToProps)(ServerPage);
+2
View File
@@ -17,6 +17,7 @@ import ActionLinkAdd from './containers/AdminPage/ActionLinkAdd';
import IPCam from './containers/AdminPage/IPCam'; import IPCam from './containers/AdminPage/IPCam';
import Wristband from './containers/AdminPage/Wristband'; import Wristband from './containers/AdminPage/Wristband';
import ModbusPreview from './containers/AdminPage/ModbusPreview'; import ModbusPreview from './containers/AdminPage/ModbusPreview';
import ServerPage from './containers/AdminPage/Server';
const Routes = ( const Routes = (
<Route path="/admin" component={AdminPage}> <Route path="/admin" component={AdminPage}>
@@ -36,6 +37,7 @@ const Routes = (
<Route path="modbuslog" component={ModbusLog} /> <Route path="modbuslog" component={ModbusLog} />
<Route path="ipcam" component={IPCam} /> <Route path="ipcam" component={IPCam} />
<Route path="wristband" component={Wristband} /> <Route path="wristband" component={Wristband} />
<Route path="server" component={ServerPage} />
</Route> </Route>
); );