webio-node/route/api/modbus.js

const express = require('express');
const router = express.Router();
const rt = require('../ResTool');
const config = require('../../config.json');
const mysql = require('../../libs/mysql_pool');
const tool = require('../../includes/apiTool');
const exec = require('child_process').exec;
const so = require('../../includes/storeObject');

router
    .get('/', (req, res) => {
        res.send({ name: 'WebIO Modbus API' });
    })
    .post('*', async(req, res, n) => {
        try {
            res.db = await mysql.getConn();
        } catch (e) {
            console.log(`Get DB Connection ERROR ${e}`);
            return n('ERR8100');
        }
        n();
    })
    .post('/getmodbuslist', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');

        let query = "select * from ??.?? order by `uid` desc";
        let param = [config.db.db5, 'device'];

        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');

            res.api_res = {
                record: tool.checkArray(row)
            };

            return n();
        })
    })
    .post('/getmodbus', (req, res, n) => {
        if (!config.permission.modbus) 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 = "select * from ??.?? where `uid` = ?";
        let param = [config.db.db5, 'device', arr.data.id];

        res.db.query(query, param, (err, row) => {
            if (err || row.length == 0) return rt.err(res, err, n, 'ERR8000');

            res.api_res = {
                record: tool.checkArray(row),
                rt: {
                    iolist: [],
                    aioset: []
                }
            };

            let pros = [];

            let iq = "select * from ??.?? where `devuid` = ?";
            let ip = [config.db.db5, 'iolist', row[0].uid];
            pros.push(tool.promiseQuery(res, iq, ip, 'iolist'));

            let aq = "select a.* from ??.?? a\
				left join ??.?? i\
				on \
				a.`iouid`= i.`uid` \
				where \
				i.`devuid` = ?";
            let ap = [config.db.db5, 'aioset', config.db.db5, 'iolist', row[0].uid];
            pros.push(tool.promiseQuery(res, aq, ap, 'aioset'));

            Promise.all(pros)
                .then(r => {
                    for (let i in r) {
                        if (r[i].key == 'iolist') res.api_res.rt.iolist = r[i].data;
                        if (r[i].key == 'aioset') res.api_res.rt.aioset = r[i].data;
                    }
                    return n();
                })
                .catch(err => rt.err(res, err, n, 'ERR8000'));
        });
    })
    .post('/getporttype', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');

        let query = "select * from ??.?? order by `uid` ";
        let param = [config.db.db5, 'porttype'];

        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');
            res.api_res = {
                record: tool.checkArray(row)
            };
            return n();
        });
    })
    .post('/addmodbus', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');
        if (!tool.checkPermission(req)) return n('ERR9000');
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.name) return n('ERR0026');
        if (!('node' in arr.data)) return n('ERR0038');

        let type = arr.data.type && isFinite(arr.data.type) ? arr.data.type : 0;

        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 = "insert into ??.?? (`name`, `node`, `type`, `adduser`, `moduser`, `ctime`, `mtime`) values (?,?,?,?,?, unix_timestamp(), unix_timestamp())";
        let param = [config.db.db5, 'device', arr.data.name, arr.data.node, type, u, u];

        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8001');

            res.api_res = {
                record: []
            };

            return n();
        });
    })
    .post('/editmodbus', (req, res, n) => {
        if (!config.permission.modbus) 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');
        if (!('node' in arr.data) || !('original_node' in arr.data)) return n('ERR0038');

        let type = arr.data.type && isFinite(arr.data.type) ? arr.data.type : 0;

        let query = "select count(*) as num from ??.?? where `node` = ? and `uid` != ?";
        let param = [config.db.db5, 'device', arr.data.node, arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err || row.length == 0) return rt.err(res, err, n, 'ERR8000');
            if (row[0].num > 0) return n('ERR0047');

            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 = "update ??.?? set \
				`name` = ?, \
				`node` = ?, \
                `type` = ?, \
				`moduser` = ?, \
				`mtime` = unix_timestamp() \
				where \
				`uid` = ?";
            let param = [config.db.db5, 'device', arr.data.name, arr.data.node, type, u, arr.data.id];
            res.db.query(query, param, (err, row) => {
                if (err) return rt.err(res, err, n, 'ERR8002');

                let q = "delete from ??.?? where `node` in (?)";
                let p = [config.db.db6, 'jcmbrt', [arr.data.node, arr.data.original_node]];
                res.db.query(q, p, (err, row) => {

                    res.api_res = {
                        record: []
                    };
                    return n();
                });
            })
        })
    })
    .post('/delmodbus', (req, res, n) => {
        if (!config.permission.modbus) 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');

        res.db.query(`use ${config.db.db5}`);

        let query = "delete d,i,s,rt from ??.?? d \
			left join ??.?? i \
			on d.`uid` = i.`devuid` \
			left join ??.?? s \
			on i.`uid` = s.`iouid` \
			left join ??.?? rt \
			on d.`node` = rt.`node` \
			where \
			d.`uid` = ?";
        let param = [config.db.db5, 'device', config.db.db5, 'iolist', config.db.db5, 'aioset', config.db.db6, 'jcmbrt', arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8003');
            res.api_res = {
                record: []
            };
            return n();
        });
    })
    .post('/getiostatus', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.id) return n('ERR0028');
        if (!arr.data.type) return n('ERR0009');

        let query = "select rt.*, a.`name` as name from ??.?? rt \
			left join ??.?? d \
			on d.`node` = rt.`node` \
			left join ??.?? i \
			on i.`devuid` = d.`uid` and i.`type` = ? \
            left join ??.?? a \
            on a.`iouid` = i.`uid` \
            and a.`portnum` = rt.`port`\
			where \
			d.`uid` = ? \
			and rt.`type` = ? \
			and i.`uid` is not null \
            and ( a.`name` is not null or rt.`type` in (1,2)) \
            order by rt.`port` asc";
        let param = [config.db.db6, 'jcmbrt', config.db.db5, 'device', config.db.db5, 'iolist', arr.data.type, config.db.db5, 'aioset', arr.data.id, arr.data.type];

        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');

            res.api_res = {
                record: tool.checkArray(row)
            };
            return n();
        });
    })
    .post('/getalliostatus', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');

        let pros = [];

        let query = "select rt.*, a.`name` as name \
            from ??.?? rt \
			left join ??.?? d \
			on d.`node` = rt.`node` \
			left join ??.?? i \
			on i.`devuid` = d.`uid` \
            and i.`type` = rt.`type` \
            left join ??.?? a \
            on a.`iouid` = i.`uid` \
            and a.`portnum` = rt.`port`\
			where \
			i.`uid` is not null \
            and ( a.`name` is not null or rt.`type` in (1,2)) \
            order by rt.`type` asc, rt.`port` asc";
        let param = [config.db.db6, 'jcmbrt', config.db.db5, 'device', config.db.db5, 'iolist', config.db.db5, 'aioset'];

        pros.push(tool.promiseQuery(res, query, param, 'record'));

        let rtq = "select * from ??.?? ";
        let rtp = [config.db.db5, 'device'];

        pros.push(tool.promiseQuery(res, rtq, rtp, 'rt'));

        res.api_res = {
            record: [],
            rt: {
                device: []
            }
        }

        Promise.all(pros)
            .then(d => {
                for (let i in d) {
                    if (d[i].key == 'record') {
                        res.api_res.record = tool.checkArray(d[i].data);
                    }
                    if (d[i].key == 'rt') {
                        res.api_res.rt.device = tool.checkArray(d[i].data);
                    }
                }
                n();
            })
            .catch(err => rt.err(res, err, n, 'ERR8000'));
    })
    .post('/getiolist', (req, res, n) => {
        if (!config.permission.modbus) 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 `uid` = ? ";
        let param = [config.db.db5, 'iolist', arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');

            res.api_res = {
                record: tool.checkArray(row)
            };

            return n();
        });
    })
    .post('/addiolist', (req, res, n) => {
        if (!config.permission.modbus) 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.type) return n('ERR0009');
        if (!arr.data.addr) return n('ERR0048');
        if (!arr.data.num) return n('ERR0049');

        let dlen = arr.data.datalen || 2;

        let query = "select count(*) as c from ??.?? \
			where \
			`devuid` = ? \
			and `type` = ? \
			and `addr` = ?";
        let param = [config.db.db5, 'iolist', arr.data.id, arr.data.type, arr.data.addr];
        res.db.query(query, param, (err, row) => {
            if (err || row.length == 0) return rt.err(res, err, n, 'ERR8000');

            if (row[0].c > 0) return n('ERR0054');

            let query = "insert into ??.?? (`devuid`,`type`,`addr`,`num`,`datalen`,`ctime`,`mtime`) values (?, ?, ?, ?, ?, unix_timestamp(), unix_timestamp())";
            let param = [config.db.db5, 'iolist', arr.data.id, arr.data.type, arr.data.addr, arr.data.num, dlen];
            res.db.query(query, param, (err, row) => {
                if (err) return rt.err(res, err, n, 'ERR8001');

                res.api_res = {
                    record: []
                };
                return n();
            });
        });
    })
    .post('/editiolist', (req, res, n) => {
        if (!config.permission.modbus) 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.addr) return n('ERR0048');
        if (!arr.data.num) return n('ERR0049');

        let dlen = arr.data.datalen || 2;

        let query = "select count(*) as c from ??.?? i \
			left join ??.?? i2 \
			on i2.`type` = i.`type` \
			and i2.`addr` = ? \
			and i2.`devuid` = i.`devuid` \
			and i2.`uid` != ? \
			where \
			i.`uid` = ? \
			and i2.`uid` is not null ";
        let param = [config.db.db5, 'iolist', config.db.db5, 'iolist', arr.data.addr, arr.data.id, arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err || row.length == 0) return rt.err(res, err, n, 'ERR8000');
            if (row[0].c > 0) return n('ERR0054');

            let q = "update ??.?? set \
				`addr` = ?, \
				`num` = ?, \
                `datalen` = ?, \
				`mtime` = unix_timestamp() \
				where \
				`uid` = ?";
            let p = [config.db.db5, 'iolist', arr.data.addr, arr.data.num, dlen, arr.data.id];
            res.db.query(q, p, (err, row) => {
                if (err) return rt.err(res, err, n, 'ERR8002');

                res.api_res = {
                    record: []
                };
                return n();
            });
        });
    })
    .post('/deliolist', (req, res, n) => {
        if (!config.permission.modbus) 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');

        res.db.query(`use ${config.db.db5}`);

        let query = "delete i, a from ??.?? i \
			left join ??.?? a \
			on a.`iouid` = i.`uid` \
			where \
			i.`uid` = ?";
        let param = [config.db.db5, 'iolist', config.db.db5, 'aioset', arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8003');

            res.api_res = {
                record: []
            };
            return n();
        });
    })
    .post('/getaiosetlist', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.id) return n('ERR0028');

        let query = "select a.* from ??.?? a \
			left join ??.?? i \
			on a.`iouid` = i.`uid` \
			where \
			i.`uid` = ?";
        let param = [config.db.db5, 'aioset', config.db.db5, 'iolist', arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');

            res.api_res = {
                record: tool.checkArray(row)
            };
            return n();
        });
    })
    .post('/getaioset', (req, res, n) => {
        if (!config.permission.modbus) 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 `uid` = ?";
        let param = [config.db.db5, 'aioset', arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');

            res.api_res = {
                record: tool.checkArray(row)
            };
            return n();
        });
    })
    .post('/delaioset', (req, res, n) => {
        if (!config.permission.modbus) 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 = "delete from ??.?? where `uid` = ?";
        let param = [config.db.db5, 'aioset', arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8003');
            res.api_res = {
                record: []
            };
            return n();
        });
    })
    .post('/addaioset', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');
        if (!tool.checkPermission(req)) return n('ERR9000');
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.iouid) return n('ERR0028');
        if (!arr.data.name) return n('ERR0026');
        if (!('portnum' in arr.data)) return n('ERR0048');
        if (!('type' in arr.data)) return n('ERR0009');
        if (!('range_min' in arr.data)) return n('ERR0050');
        if (!('range_max' in arr.data)) return n('ERR0051');
        if (!('scale_min' in arr.data)) return n('ERR0052');
        if (!('scale_max' in arr.data)) return n('ERR0053');

        let query = "select count(*) as count from ??.?? where `iouid` = ? and `portnum` = ?";
        let param = [config.db.db5, 'aioset', arr.data.iouid, arr.data.portnum];
        res.db.query(query, param, (err, row) => {
            if (err || row.length == 0) return rt.err(res, err, n, 'ERR8000');

            if (row[0].count > 0) return n('ERR0054');

            let q = "insert into ??.?? (`iouid`, `name`, `portnum`, `type`, `range_min`, `range_max`, `scale_min`, `scale_max`, `ctime`, `mtime`) values \
				(?, ?, ?, ?, ?, ?, ?, ?, unix_timestamp(), unix_timestamp())";
            let p = [config.db.db5, 'aioset', arr.data.iouid, arr.data.name, arr.data.portnum, arr.data.type, arr.data.range_min, arr.data.range_max, arr.data.scale_min, arr.data.scale_max];
            res.db.query(q, p, (err, row) => {
                if (err) return rt.err(res, err, n, 'ERR8001');

                res.api_res = {
                    record: []
                };

                return n();
            });
        });
    })
    .post('/editaioset', (req, res, n) => {
        if (!config.permission.modbus) 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.iouid) return n('ERR0028');
        if (!arr.data.name) return n('ERR0026');
        if (!('portnum' in arr.data)) return n('ERR0048');
        if (!('type' in arr.data)) return n('ERR0009');
        if (!('range_min' in arr.data)) return n('ERR0050');
        if (!('range_max' in arr.data)) return n('ERR0051');
        if (!('scale_min' in arr.data)) return n('ERR0052');
        if (!('scale_max' in arr.data)) return n('ERR0053');

        let query = "select count(*) as count from ??.?? \
            where \
            `iouid` = ? \
            and `portnum` = ? \
            and `uid` != ?";
        let param = [config.db.db5, 'aioset', arr.data.iouid, arr.data.portnum, arr.data.id];
        res.db.query(query, param, (err, row) => {
            if (err || row.length == 0) return rt.err(res, err, n, 'ERR8000');
            if (row[0].length > 0) return n('ERR0054');

            let query = "update ??.?? set \
                `name` = ?, \
                `portnum` = ?, \
                `type` = ?, \
                `range_min` = ?, \
                `range_max` = ?, \
                `scale_min` = ?, \
                `scale_max` = ?, \
                `mtime` = unix_timestamp() \
                where `uid` = ?";
            let param = [config.db.db5, 'aioset', arr.data.name, arr.data.portnum, arr.data.type, arr.data.range_min, arr.data.range_max, arr.data.scale_min, arr.data.scale_max, arr.data.id];
            res.db.query(query, param, (err, row) => {
                if (err) return rt.err(res, err, n, 'ERR8002');

                res.api_res = {
                    record: []
                };
                return n();
            });
        });
    })
    .post('/modbuscmd', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');
        if (!tool.checkPermission(req)) return n('ERR9000');
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.ip) return n('ERR0010');
        if (!('node' in arr.data) || arr.data.node.length == 0) return n('ERR0038');
        if (!('func' in arr.data) || arr.data.func.length == 0) return n('ERR0055');
        if (!('addr' in arr.data) || arr.data.addr.length == 0) return n('ERR0048');
        if (!('value' in arr.data) || arr.data.value.length == 0) return n('ERR0049');

        let cmd = `mbtcpm ${arr.data.ip} ${arr.data.node} ${arr.data.func} ${arr.data.addr} ${arr.data.value}`;
        res.api_res = {
            record: []
        };
        exec(cmd, (err, stdout, stderr) => {
            let msg = err ? err.toString() : `${stdout}${stderr}`;
            res.api_res.record.push({ msg });

            n();
        })
    })
    .post('/getmodbuslog', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.ids || !Array.isArray(arr.data.ids)) return n('ERR0028');
        if (!arr.data.stime || !arr.data.etime) return n('ERR0015');

        let query = "select log.`node`, log.`type`, log.`port`, log.`value2` as value, log.`tst`, dev.`name` as devname, aio.`name` as aioname \
            from ??.?? log \
            left join ??.?? dev \
            on dev.`node` = log.`node`\
            left join ??.?? io \
            on io.`devuid` = dev.`uid` \
            and io.`type` = log.`type` \
            left join ??.?? aio \
            on aio.`iouid` = io.`uid` \
            and aio.`portnum` = log.`port` \
            where \
            dev.`uid` in (?) \
            and ( log.`tst` >= ? \
            and log.`tst` <= ? ) \
            and io.`uid` is not null \
            and ( aio.`name` is not null or log.`type` in (1,2)) \
            order by log.`uid` desc, log.`tst` desc \
            limit 0, 100";
        let param = [config.db.db10, 'jcmbrt', config.db.db5, 'device', config.db.db5, 'iolist', config.db.db5, 'aioset', arr.data.ids, arr.data.stime, arr.data.etime];

        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');
            res.api_res = {
                record: tool.checkArray(row)
            }
            n();
        })
    })
    .post('/getmodbustype', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000');
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.id) return n('ERR0028');

        let query = "select io.`type` \
            from ??.?? io \
            left join ??.?? dev \
            on dev.`uid` = io.`devuid` \
            where \
            dev.`uid` = ? \
            group by io.`type` \
            order by io.`type` ";
        let param = [config.db.db5, 'iolist', config.db.db5, 'device', arr.data.id];

        res.db.query(query, param, (err, row) => {
            if (err) return rt.err(res, err, n, 'ERR8000');

            res.api_res = {
                record: tool.checkArray(row)
            }

            n();
        })
    })
    .post('/getmodbusport', (req, res, n) => {
        if (!config.permission.modbus) return n('ERR9000')
        let arr = req.body;
        if (!arr.data) return n('ERR0000');
        if (!arr.data.id) return n('ERR0028');
        if (!arr.data.type) return n('ERR0009');

        let type = arr.data.type;
        if (type == 5) type = 1;
        if (type == 6) type = 3;

        if (type == 3 || type == 4) {
            let query = "select a.`name`, a.`portnum` \
                from ??.?? a \
                left join ??.?? io \
                on io.`uid` = a.`iouid` \
                left join ??.?? dev \
                on dev.`uid` = io.`devuid` \
                where \
                io.`type` = ? \
                and dev.`uid` = ? ";
            let param = [config.db.db5, 'aioset', config.db.db5, 'iolist', config.db.db5, 'device', type, arr.data.id];

            res.db.query(query, param, (err, row) => {
                if (err) return rt.err(res, err, n, 'ERR8000');

                res.api_res = {
                    record: tool.checkArray(row)
                }

                n();
            });
            return;
        }

        if (type == 1 || type == 2) {
            let query = "select * \
                from ??.?? io \
                left join ??.?? dev \
                on dev.`uid` = io.`devuid` \
                where \
                dev.`uid` = ? \
                and io.`type` = ?";
            let param = [config.db.db5, 'iolist', config.db.db5, 'device', arr.data.id, type];

            res.db.query(query, param, (err, row) => {
                if (err) return rt.err(res, err, n, 'ERR8000');
                let arr = [];
                let num = 0;
                for (let i in row) {
                    num += parseInt(row[i].num);
                }
                for (let i = 0; i < num; i++) {
                    arr.push({ portnum: (i + 1), name: '' })
                }

                res.api_res = {
                    record: arr
                }
                n();
            })
            return;
        }

        return n('ERR0009');
    })
    .all('*', rt.send);

module.exports = router;