update
This commit is contained in:
meusinfirmary
112
app.js
112
app.js
@ -1,7 +1,7 @@
|
||||
require("dotenv").config({ path: ".env" });
|
||||
require("events").EventEmitter.prototype._maxListeners = 30;
|
||||
const morgan = require("morgan");
|
||||
// start for gps-tracking
|
||||
|
||||
const net = require("net");
|
||||
const dgram = require("dgram");
|
||||
const crc = require("crc");
|
||||
@ -13,36 +13,23 @@ const VhcModels = require("./models/VhcModels");
|
||||
const LibMail = require("./library/LibMail");
|
||||
const LibHelper = require("./library/LibHelper");
|
||||
const nanoid = require("nanoid").nanoid;
|
||||
// end for gps-tracking
|
||||
|
||||
// start for normal http request
|
||||
const express = require("express");
|
||||
// const LibBullAdapter = require('./library/LibBullAdapter');
|
||||
const routes = require("./routes/routes");
|
||||
// const routes = require('./routes/routes_without_scheduler');
|
||||
const app = express();
|
||||
// end for normal http request
|
||||
|
||||
// start for logging
|
||||
const LibWinston = require("./library/LibWinston");
|
||||
|
||||
const logName = "libUdp";
|
||||
const Logger = LibWinston.initialize(logName);
|
||||
// end for logging
|
||||
|
||||
// start commit / log message from gps
|
||||
async function commitMessage(now, logDevice) {
|
||||
try {
|
||||
// don't log
|
||||
if (!logDevice.original_hex) {
|
||||
return false;
|
||||
}
|
||||
// in the future don't log to db if device_id not found in vhc
|
||||
|
||||
const vhc = await VhcModels.getVhcByDeviceId(logDevice.device_id);
|
||||
const lastTrack = await GpsTracksModels.get2LastLocByDeviceId(logDevice.device_id);
|
||||
|
||||
if (["heartbeat", "alarm"].includes(logDevice.action)) {
|
||||
// set engine stts moving,idling,stopped
|
||||
if (logDevice.ignition == GpsTracksModels.STTS_IGNITION_HIGH) {
|
||||
if (logDevice.speed) {
|
||||
logDevice.stts_engine = GpsTracksModels.STTS_EN_MOVING;
|
||||
@ -60,9 +47,8 @@ async function commitMessage(now, logDevice) {
|
||||
logDevice.stts_engine = GpsTracksModels.STTS_EN_STOPING;
|
||||
}
|
||||
}
|
||||
// get last ignition, stts_engine, stts_alarm, stts_charge, stts_acc, stts_volt, stts_switch
|
||||
|
||||
if (["location"].includes(logDevice.action)) {
|
||||
// get last ignition
|
||||
const lastHeartbeatOrAlarm = await GpsTracksModels.get2LastHeartbeatOrAlarm(logDevice.device_id);
|
||||
if (lastHeartbeatOrAlarm.length > 0) {
|
||||
logDevice.ignition = lastHeartbeatOrAlarm[0].ignition;
|
||||
@ -73,7 +59,7 @@ async function commitMessage(now, logDevice) {
|
||||
logDevice.stts_gps = lastHeartbeatOrAlarm[0].stts_gps;
|
||||
logDevice.stts_gsm = lastHeartbeatOrAlarm[0].stts_gsm;
|
||||
}
|
||||
// set engine stts moving,idling,stopped
|
||||
|
||||
if (logDevice.ignition == GpsTracksModels.STTS_IGNITION_HIGH) {
|
||||
if (logDevice.speed) {
|
||||
logDevice.stts_engine = GpsTracksModels.STTS_EN_MOVING;
|
||||
@ -87,7 +73,6 @@ async function commitMessage(now, logDevice) {
|
||||
}
|
||||
}
|
||||
}
|
||||
// get stts_alarm, stts_charge, stts_acc, stts_volt, stts_switch
|
||||
} else {
|
||||
logDevice.stts_engine = GpsTracksModels.STTS_EN_STOPING;
|
||||
}
|
||||
@ -99,7 +84,6 @@ async function commitMessage(now, logDevice) {
|
||||
logDevice.stts_switch = lastHeartbeatOrAlarm[0].stts_switch;
|
||||
}
|
||||
|
||||
// sekarang heartbeat diinject data lokasi juga dari lokasi terakhir
|
||||
if (["heartbeat"].includes(logDevice.action)) {
|
||||
if (lastTrack.length > 0) {
|
||||
logDevice.latitude = lastTrack[0].latitude;
|
||||
@ -115,12 +99,6 @@ async function commitMessage(now, logDevice) {
|
||||
logDevice.pos_type_gps = lastTrack[0].pos_type_gps;
|
||||
logDevice.is_pos_gps = lastTrack[0].is_pos_gps;
|
||||
|
||||
// jika gapengen dimunculin di last movement
|
||||
// logDevice.crt = lastTrack[0].crt;
|
||||
// logDevice.crt_format = lastTrack[0].crt_format;
|
||||
// logDevice.crt_d = lastTrack[0].crt_d;
|
||||
// logDevice.crt_d_format = lastTrack[0].crt_d_format;
|
||||
// jika pengen di munculin di last movement
|
||||
logDevice.crt = now;
|
||||
logDevice.crt_format = moment.unix(now).format("YYYY-MM-DD HH:mm:ss");
|
||||
logDevice.crt_d = now;
|
||||
@ -128,14 +106,12 @@ async function commitMessage(now, logDevice) {
|
||||
}
|
||||
}
|
||||
|
||||
// count milleage
|
||||
if (logDevice.latitude != null && logDevice.longitude != null && lastTrack.length > 0) {
|
||||
const distance = LibHelper.haversineGreatCircleDistance(lastTrack[0].latitude, lastTrack[0].longitude, logDevice.latitude, logDevice.longitude, LibHelper.EARTH_RADIUS_KM);
|
||||
const distance_km = LibHelper.kmToKm(distance, 100000000);
|
||||
// console.log(`GPS TRACKER UP LOCATION => device_id:${logDevice.device_id} vhc_id:${(vhc[0]) ? vhc[0].vid : 0}, distance_km:${distance_km}`);
|
||||
// validasi jika lebih dari 3km, ga disimpan
|
||||
|
||||
if (distance_km >= 3) {
|
||||
GpsTracksModels.bundleCreate2(logDevice, logDevice); // jika tidak disimpan malah jadi bug, jadi akan update lokasi terus dengan kalkulasi jarak sebelumnya jadi makan lama makin lebar, mending disimpen terus milleagenya jadi 0 aja
|
||||
GpsTracksModels.bundleCreate2(logDevice, logDevice);
|
||||
return false;
|
||||
}
|
||||
logDevice.pre_milleage = distance_km;
|
||||
@ -151,12 +127,9 @@ async function commitMessage(now, logDevice) {
|
||||
}
|
||||
}
|
||||
|
||||
// truck zoning spawn
|
||||
if (logDevice.latitude != null && logDevice.longitude != null) {
|
||||
// && vhc.length > 0
|
||||
// log tracking
|
||||
const currTrack = await GpsTracksModels.bundleCreate2(logDevice, logDevice);
|
||||
// console.log('GT06 HAS LOCATION AND CHECK ZONE');
|
||||
|
||||
const inCircle = await ZoneModels.getInCircle(logDevice.latitude, logDevice.longitude);
|
||||
const inShape = await ZoneModels.getInShape(logDevice.latitude, logDevice.longitude);
|
||||
const insideSpawnZone = [];
|
||||
@ -215,7 +188,6 @@ async function commitMessage(now, logDevice) {
|
||||
da_name: vhc[0] ? vhc[0].da_name : 0 || "",
|
||||
da_phone: "+" + (vhc[0] ? vhc[0].da_phone_code : 0 || "") + (vhc[0] ? vhc[0].da_phone : 0 || ""),
|
||||
};
|
||||
// LibMail.sendVhcSpawnZoneMail(`${(vhc[0]) ? vhc[0].nopol1 : 0 || ''}${(vhc[0]) ? vhc[0].nopol2 : 0 || ''}${(vhc[0]) ? vhc[0].nopol3 : 0 || ''} entering zone ${mailData.z_name}`, mailData.pic_mail, mailData);
|
||||
|
||||
if (logDevice.device_id === "0865784052395871") console.log(1234567890);
|
||||
GpsTracksModels.create2SpawnZone({
|
||||
@ -238,16 +210,13 @@ async function commitMessage(now, logDevice) {
|
||||
}
|
||||
}
|
||||
} else {
|
||||
// log tracking
|
||||
GpsTracksModels.bundleCreate2(logDevice, logDevice);
|
||||
}
|
||||
} catch (e) {
|
||||
console.error(e);
|
||||
}
|
||||
}
|
||||
// end commit / log message from gps
|
||||
|
||||
// start for gps-tracking TCP ONLY
|
||||
const devices = [];
|
||||
const netConn = require("./config/netConn");
|
||||
/**
|
||||
@ -259,9 +228,6 @@ net.createServer(
|
||||
allowHalfOpen: true,
|
||||
},
|
||||
function (c) {
|
||||
// c mean connection
|
||||
|
||||
// save connections
|
||||
c.id = nanoid();
|
||||
|
||||
c.pipe(c);
|
||||
@ -269,7 +235,6 @@ net.createServer(
|
||||
c.on("data", async (buffer_req) => {
|
||||
const now = moment().unix();
|
||||
const me = LibDevice.identifyProtocolFromBuffer(buffer_req);
|
||||
// console.log('app ', buffer_req);
|
||||
|
||||
const logDevice = {
|
||||
original_hex: me.ori_string,
|
||||
@ -308,7 +273,6 @@ net.createServer(
|
||||
};
|
||||
|
||||
if (me.protocol_name == "gt06") {
|
||||
// const act = LibDevice.gt06Action(me, device.device_id || null);
|
||||
let dvc_id = devices[c.id];
|
||||
const act = LibDevice.gt06Action(me, dvc_id || null);
|
||||
|
||||
@ -338,19 +302,35 @@ net.createServer(
|
||||
logDevice.pos_type_gps = Number(act.gps_data.realtime_dif_gps) === 0 ? GpsTracksModels.STTS_POS_TYPE_GPS_RLTM : GpsTracksModels.STTS_POS_TYPE_GPS_DIFF;
|
||||
logDevice.is_pos_gps = Number(act.gps_data.positioning_gps) ? GpsTracksModels.STTS_IS_POS_GPS_HAS : GpsTracksModels.STTS_IS_POS_GPS_NOT;
|
||||
|
||||
logDevice.crt = moment(act.gps_data.date).unix();
|
||||
logDevice.crt_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss");
|
||||
logDevice.crt_d = moment(act.gps_data.date).unix();
|
||||
logDevice.crt_d_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss");
|
||||
// logDevice.crt = moment(act.gps_data.date).unix();
|
||||
// logDevice.crt_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss");
|
||||
// logDevice.crt_d = moment(act.gps_data.date).unix();
|
||||
// logDevice.crt_d_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss");
|
||||
|
||||
let deviceTime = moment(act.gps_data.date).unix();
|
||||
let now = moment().unix();
|
||||
let diff = Math.abs(deviceTime - now);
|
||||
|
||||
// Jika beda waktu terlalu besar (> 300 detik atau 5 menit), pakai waktu server
|
||||
if (diff > 300) {
|
||||
console.warn(`[WAKTU TIDAK VALID] Device ${logDevice.device_id} mengirim waktu tidak sinkron, pakai waktu server.`);
|
||||
deviceTime = now;
|
||||
}
|
||||
|
||||
logDevice.crt = deviceTime;
|
||||
logDevice.crt_format = moment.unix(deviceTime).format("YYYY-MM-DD HH:mm:ss");
|
||||
logDevice.crt_d = deviceTime;
|
||||
logDevice.crt_d_format = moment.unix(deviceTime).format("YYYY-MM-DD HH:mm:ss");
|
||||
logDevice.crt_device_raw = moment(act.gps_data.date).unix(); // waktu asli dari device (sebelum validasi)
|
||||
} else if (act.action_type == "heartbeat") {
|
||||
logDevice.action = act.action_type;
|
||||
logDevice.device_id = act.device_id;
|
||||
|
||||
logDevice.ignition = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_IGNITION_HIGH : GpsTracksModels.STTS_IGNITION_LOW;
|
||||
logDevice.stts_gps = act.stts_data.terminal_info.gps_tracking ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF; // 1=>on, 2=>off
|
||||
logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1; // 1=>no signal, n>1=>get signal
|
||||
logDevice.stts_gps = act.stts_data.terminal_info.gps_tracking ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF;
|
||||
logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1;
|
||||
|
||||
logDevice.stts_oil_electricity = Number(act.stts_data.terminal_info.oil_electricity) === 0 ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF; // 1=>on, 2=>off
|
||||
logDevice.stts_oil_electricity = Number(act.stts_data.terminal_info.oil_electricity) === 0 ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF;
|
||||
|
||||
let stts_alarm = Number(act.stts_data.terminal_info.stts);
|
||||
if (stts_alarm == 0) {
|
||||
@ -391,10 +371,10 @@ net.createServer(
|
||||
logDevice.is_pos_gps = Number(act.gps_data.positioning_gps) ? GpsTracksModels.STTS_IS_POS_GPS_HAS : GpsTracksModels.STTS_IS_POS_GPS_NOT;
|
||||
|
||||
logDevice.ignition = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_IGNITION_HIGH : GpsTracksModels.STTS_IGNITION_LOW;
|
||||
logDevice.stts_gps = act.stts_data.terminal_info.gps_tracking ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF; // 1=>on, 2=>off
|
||||
logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1; // 1=>no signal, n>1=>get signal
|
||||
logDevice.stts_gps = act.stts_data.terminal_info.gps_tracking ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF;
|
||||
logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1;
|
||||
|
||||
logDevice.stts_oil_electricity = Number(act.stts_data.terminal_info.oil_electricity) === 0 ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF; // 1=>on, 2=>off
|
||||
logDevice.stts_oil_electricity = Number(act.stts_data.terminal_info.oil_electricity) === 0 ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF;
|
||||
|
||||
let stts_alarm = Number(act.stts_data.terminal_info.stts);
|
||||
if (stts_alarm == 0) {
|
||||
@ -422,9 +402,7 @@ net.createServer(
|
||||
if (typeof act.buffer_resp != "undefined") {
|
||||
c.write(act.buffer_resp);
|
||||
}
|
||||
}
|
||||
// act.action_type == 'other'
|
||||
else {
|
||||
} else {
|
||||
logDevice.action = act.action_type;
|
||||
logDevice.device_id = act.device_id;
|
||||
}
|
||||
@ -435,7 +413,6 @@ net.createServer(
|
||||
c.on("end", () => {});
|
||||
c.on("close", () => {});
|
||||
|
||||
// unused
|
||||
c.on("drain", (a) => {
|
||||
console.log("client drain", a);
|
||||
});
|
||||
@ -452,41 +429,27 @@ net.createServer(
|
||||
console.log("client timeout", a);
|
||||
});
|
||||
|
||||
// not work for gps tracker
|
||||
// https://stackoverflow.com/questions/17245881/how-do-i-debug-error-econnreset-in-node-js
|
||||
// c.write("<?xml version=\"1.0\"?>\n");
|
||||
// c.write("<!DOCTYPE cross-domain-policy SYSTEM \"http://www.macromedia.com/xml/dtds/cross-domain-policy.dtd\">\n");
|
||||
// c.write("<cross-domain-policy>\n");
|
||||
// c.write("<allow-access-from domain=\"*\" to-ports=\"*\"/>\n");
|
||||
// c.write("</cross-domain-policy>\n");
|
||||
// c.end();
|
||||
|
||||
c.pipe(c);
|
||||
}
|
||||
).listen(process.env.PORT, () => {
|
||||
console.log("Server gps tracker running at port " + process.env.PORT);
|
||||
});
|
||||
// end for gps-tracking TCP ONLY
|
||||
|
||||
// start for normal http request
|
||||
app.use(morgan("combined"));
|
||||
app.use(express.json({ limit: "10mb" })); // parsing application/json
|
||||
app.use(express.urlencoded({ extended: true, limit: "10mb" })); // parsing application/x-www-form-urlencoded
|
||||
app.use(express.json({ limit: "10mb" }));
|
||||
app.use(express.urlencoded({ extended: true, limit: "10mb" }));
|
||||
app.use(async function (req, res, next) {
|
||||
// set control allowed headers
|
||||
res.header("Access-Control-Allow-Origin", "*");
|
||||
res.header("Access-Control-Allow-Methods", "OPTIONS,GET,HEAD,PUT,PATCH,POST,DELETE");
|
||||
res.header("Access-Control-Allow-Headers", "Accept, Authorization, Content-Type, X-Requested-With, Range, x-api-key, x-forwarded-for");
|
||||
next();
|
||||
});
|
||||
// app.use(process.env.PATH_URL + '/bull/monitor', LibBullAdapter.getRouter());
|
||||
|
||||
routes.use(app);
|
||||
app.listen(process.env.PORT_EXPRESS, () => {
|
||||
console.log("Express server running at port " + process.env.PORT_EXPRESS);
|
||||
});
|
||||
// end for normal http request
|
||||
|
||||
// start for gps-tracking UDP ONLY
|
||||
const udp = dgram.createSocket("udp4");
|
||||
|
||||
const devices1 = [];
|
||||
@ -567,4 +530,3 @@ udp.on("listening", () => {
|
||||
});
|
||||
|
||||
udp.bind(process.env.PORT_UDP);
|
||||
// end for gps-tracking UDP ONLY
|
||||
|
||||
Reference in New Issue
Block a user