chaulh/aiparking_api
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

update full business

Browse Source
This commit is contained in:
dongpd 2020-02-03 14:28:56 +07:00
parent 365a929ef7
commit 6cd7d22a2b
3 changed files with 93 additions and 73 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

158
api/controllers/ApiController.js
View File

@ -1,81 +1,105 @@
'use strict'; 'use strict';
const util = require('util');
var mysql = require('mysql'); var mysql = require('mysql');
const random = require('random'); var fs = require('fs');
var fs = require("fs"); const config = {
var check;
var con = mysql.createConnection({
host: "localhost", host: "localhost",
user: "root", user: "root",
password: "", password: "",
database: "intops" database: "intops"
}); };
function makeDb(config) {
const connection = mysql.createConnection(config);
// console.log(sql_levenshtein_cmd); return {
con.connect(function (err) { query(sql, args) {
if (err) throw err; return util.promisify(connection.query)
console.log("Connected!!!") .call(connection, sql, args);
}); },
close() {
return util.promisify(connection.end).call(connection);
}
};
}
exports.SaveLogs = async function (req, res) { exports.SaveLogs = async function (req, res) {
var sql_cmd = "SELECT * FROM vehicle WHERE plate=\"" + req.body.plate + "\"";
var sql_query_cmd = "select * from vehicle where levenshtein('" + req.body.plate + "',`plate`) BETWEEN 0 AND 2";
console.log("req: ", req.body.plate); console.log("req: ", req.body.plate);
con.connect(function (err) {
// if (err)
// throw err;
if (check != req.body.plate) {
con.query(sql_query_cmd, function (err, result, fields) {
console.log("levenshtein");
console.log(result);
var result_vehicle_id;
var sql_insert_logs_cmd, sql_insert_logs_unknow_cmd;
//if levenshtein not found plate var today = new Date();
if (result == "") { var currentDate = today.getDate();
console.log("Nothing to show"); var currentMonth = today.getMonth() + 1;
//timestamp in seconds var currentYear = today.getFullYear();
var today = new Date(); var rootDir = "/mnt/c/xampp/htdocs/AIParking_Intops_Server/web/data/uploads/";
var currentTimeInInt = Math.round(today.getTime() / 1000);
sql_insert_logs_unknow_cmd = "INSERT INTO logs_unknow(`id`,`plate`,`plate_image_in`,`frame_image_in`,`time_in`,`plate_image_out`,`frame_image_out`,`time_out`,`seal_no`,`note`,`factory`) VALUES (" + random.int(1, 1000) + ",'" + req.body.plate + "','1','1'," + currentTimeInInt + ",'1','1',11,'1','1','1')";
con.query(sql_insert_logs_unknow_cmd, function (err, result, fields) {
if (err)
throw err;
});
console.log("Log unknown done");
}
//if levenshtein found plate if (!fs.existsSync(rootDir + currentYear))
else { fs.mkdirSync(rootDir + currentYear);
console.log("Log to logs table"); if (!fs.existsSync(rootDir + currentYear + "/" + currentMonth))
//get vehicle id in vehicle table fs.mkdirSync(rootDir + currentYear + "/" + currentMonth);
con.query("SELECT id FROM vehicle where `plate`='" + result[0].plate + "'", function (err, result_vehicle_id) { if (!fs.existsSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate))
if (err) fs.mkdirSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate);
throw err; if (!fs.existsSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type))
console.log("result_vehicle_id"); fs.mkdirSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type);
console.log(result_vehicle_id[0].id); if (!fs.existsSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type + "/plate"))
var today = new Date(); fs.mkdirSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type + "/plate");
var currentTimeInInt = Math.round(today.getTime() / 1000); if (!fs.existsSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type + "/frame"))
sql_insert_logs_cmd = "INSERT INTO logs(`id`,`vehicle_id`,`plate_image_in`,`frame_image_in`,`time_in`,`plate_image_out`,`frame_image_out`,`time_out`,`seal_no`,`note`,`factory`) VALUES (" + random.int(1, 1000) + "," + result_vehicle_id[0].id + ",'1','1'," + currentTimeInInt + ",'1','1',11,'1','1','1')"; fs.mkdirSync(rootDir + currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type + "/frame");
con.query(sql_insert_logs_cmd, function (err, result, fields) { var currentTimestamp = Math.round(today.getTime() / 1000);
if (err) var fileName = req.body.plate + "_" + currentTimestamp + ".png";
throw err; var plateSaved = currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type + "/plate/" + fileName;
console.log("Log done"); var frameSaved = currentYear + "/" + currentMonth + "/" + currentDate + "/" + req.body.type + "/frame/" + fileName;
});
}); await fs.writeFileSync(rootDir + plateSaved, req.body.plate_image, 'base64');
} await fs.writeFileSync(rootDir + frameSaved, req.body.frame_image, 'base64');
});
const base64Image = req.body.plate_image; const db = makeDb(config);
const imageBuffer = new Buffer(base64Image, "base64"); var vehicleInfo = {"status": false};
fs.writeFileSync("image.jpg", imageBuffer); var query_plate_raw = await db.query("SELECT * FROM vehicle WHERE plate='" + req.body.plate + "'");
console.log("wrote image"); if (query_plate_raw.length > 0) {
check = req.body.plate; vehicleInfo = {"status": true, "data": query_plate_raw[0]};
if (req.body.type == "in") {
await db.query("INSERT INTO logs(`vehicle_id`,`plate_image_in`,`frame_image_in`,`time_in`) VALUES ('" + query_plate_raw[0].id + "','" + plateSaved + "','" + frameSaved + "'," + currentTimestamp + ")");
} }
else { if (req.body.type == "out") {
console.log("conflic plate"); var checkIn = await db.query("SELECT * FROM logs WHERE vehicle_id=" + query_plate_raw[0].id + " AND time_out=0 ORDER BY time_in DESC LIMIT 0,1");
if (checkIn.length > 0) {
await db.query("UPDATE logs SET `plate_image_out`='" + plateSaved + "',`frame_image_out`='" + frameSaved + "',`time_out`=" + currentTimestamp + " WHERE id=" + checkIn[0].id);
} else {
await db.query("INSERT INTO logs(`vehicle_id`,`plate_image_out`,`frame_image_out`,`time_out`) VALUES ('" + query_plate_raw[0].id + "','" + plateSaved + "','" + frameSaved + "'," + currentTimestamp + ")");
}
} }
}); } else {
var query_plate_levenshtein = await db.query("SELECT * FROM `vehicle` WHERE levenshtein('" + req.body.plate + "', `plate`) BETWEEN 0 AND 2 LIMIT 0,1");
res.send({ "status": "Done!" }); if (query_plate_levenshtein.length > 0) {
}; vehicleInfo = {"status": true, "data": query_plate_levenshtein[0]};
if (req.body.type == "in") {
await db.query("INSERT INTO logs(`vehicle_id`,`plate_image_in`,`frame_image_in`,`time_in`) VALUES ('" + query_plate_levenshtein[0].id + "','" + plateSaved + "','" + frameSaved + "'," + currentTimestamp + ")");
}
if (req.body.type == "out") {
var checkIn = await db.query("SELECT * FROM logs WHERE vehicle_id=" + query_plate_levenshtein[0].id + " AND time_out=0 ORDER BY time_in DESC LIMIT 0,1");
if (checkIn.length > 0) {
await db.query("UPDATE logs SET `plate_image_out`='" + plateSaved + "',`frame_image_out`='" + frameSaved + "',`time_out`=" + currentTimestamp + " WHERE id=" + checkIn[0].id);
} else {
await db.query("INSERT INTO logs(`vehicle_id`,`plate_image_out`,`frame_image_out`,`time_out`) VALUES ('" + query_plate_levenshtein[0].id + "','" + plateSaved + "','" + frameSaved + "'," + currentTimestamp + ")");
}
}
} else {
if (req.body.type == "in") {
await db.query("INSERT INTO logs_unknow(`plate`,`plate_image_in`,`frame_image_in`,`time_in`) VALUES ('" + req.body.plate + "','" + plateSaved + "','" + frameSaved + "'," + currentTimestamp + ")");
}
if (req.body.type == "out") {
var checkIn_raw = await db.query("SELECT * FROM logs_unknow WHERE plate=" + req.body.plate + " AND time_out=0 ORDER BY time_in DESC LIMIT 0,1");
if (checkIn_raw.length > 0) {
await db.query("UPDATE logs_unknow SET `plate_image_out`='" + plateSaved + "',`frame_image_out`='" + frameSaved + "',`time_out`=" + currentTimestamp + " WHERE id=" + checkIn_raw[0].id);
} else {
var checkIn_levenshtein = await db.query("SELECT * FROM `logs_unknow` WHERE levenshtein('" + req.body.plate + "', `plate`) BETWEEN 0 AND 2 AND time_out=0 ORDER BY time_in DESC LIMIT 0,1");
if (checkIn_levenshtein.length > 0) {
await db.query("UPDATE logs_unknow SET `plate_image_out`='" + plateSaved + "',`frame_image_out`='" + frameSaved + "',`time_out`=" + currentTimestamp + " WHERE id=" + checkIn_levenshtein[0].id);
} else {
await db.query("INSERT INTO logs_unknow(`plate`,`plate_image_out`,`frame_image_out`,`time_out`) VALUES ('" + req.body.plate + "','" + plateSaved + "','" + frameSaved + "'," + currentTimestamp + ")");
}
}
}
}
}
res.send(vehicleInfo);
};

2
api/routes/ApiRoutes.js
View File

@ -3,5 +3,5 @@
module.exports = function (app) { module.exports = function (app) {
var Api = require('../controllers/ApiController'); var Api = require('../controllers/ApiController');
app.route('/logs').post(Api.SaveLogs); app.route('/logs').post(Api.SaveLogs);
}; };

6
package.json
View File

@ -8,11 +8,7 @@
}, },
"dependencies": { "dependencies": {
"cookie-parser": "^1.4.3", "cookie-parser": "^1.4.3",
"cors": "^2.8.5", "express": "^4.13.3",
"express": "^4.17.1",
"jsonwebtoken": "^8.5.1",
"mysql": "^2.18.1",
"random": "^2.1.1",
"socket.io": "^2.1.1" "socket.io": "^2.1.1"
}, },
"engines": { "engines": {