From 13e3287fd79b0f96b463923e4114670689430620 Mon Sep 17 00:00:00 2001 From: meusinfirmary Date: Wed, 16 Jul 2025 19:15:32 +0700 Subject: [PATCH] update --- app.js | 7 - controllers/ListenController.js | 83 ++---- controllers/ListenController_bak.js | 439 ++++++++++++++++++++++++++++ routes/routes.js | 74 +++-- 4 files changed, 494 insertions(+), 109 deletions(-) create mode 100644 controllers/ListenController_bak.js diff --git a/app.js b/app.js index 9aa8b3f..586c03a 100644 --- a/app.js +++ b/app.js @@ -134,13 +134,6 @@ async function commitMessage(now, logDevice) { }); } - // ✅ 3. Sekarang log sudah lengkap → tampilkan untuk debug - console.log("Sebelum Simpan >>>", { - pre_milleage: logDevice.pre_milleage, - vhc_milleage: logDevice.vhc_milleage, - sum_milleage: logDevice.sum_milleage, - }); - // 4. Simpan ke DB GpsTracksModels.bundleCreate2(logDevice, logDevice); } diff --git a/controllers/ListenController.js b/controllers/ListenController.js index e97d21c..a9f0678 100644 --- a/controllers/ListenController.js +++ b/controllers/ListenController.js @@ -11,22 +11,19 @@ const VhcModels = require("../models/VhcModels"); const ZoneModels = require("../models/ZoneModels"); const LibHelper = require("../library/LibHelper"); -// const LibQueueBlastOrder = require('../library/LibQueueBlastOrder'); Validator.useLang("en"); const devices = []; 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; @@ -44,10 +41,10 @@ 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)) { console.log("logDevice:", logDevice); - // get last ignition + const lastHeartbeatOrAlarm = await GpsTracksModels.get2LastHeartbeatOrAlarm(logDevice.device_id); if (lastHeartbeatOrAlarm.length > 0) { logDevice.ignition = lastHeartbeatOrAlarm[0].ignition; @@ -139,11 +136,17 @@ async function commitMessage(now, logDevice) { logDevice.sum_milleage = (lastTrack[0].sum_milleage + logDevice.pre_milleage).toFixed(8); if (vhc.length > 0) { logDevice.vhc_id = vhc[0] ? vhc[0].vid : 0; + // if (lastTrack[0].vhc_id == logDevice.vhc_id) { + // logDevice.vhc_milleage = (lastTrack[0].vhc_milleage + logDevice.pre_milleage).toFixed(8); + // } else { + // logDevice.vhc_milleage = (vhc[0] ? vhc[0].sum_milleage : 0 + logDevice.pre_milleage).toFixed(8); + // } if (lastTrack[0].vhc_id == logDevice.vhc_id) { logDevice.vhc_milleage = (lastTrack[0].vhc_milleage + logDevice.pre_milleage).toFixed(8); } else { - logDevice.vhc_milleage = (vhc[0] ? vhc[0].sum_milleage : 0 + logDevice.pre_milleage).toFixed(8); + logDevice.vhc_milleage = ((vhc[0] ? vhc[0].sum_milleage : 0) + logDevice.pre_milleage).toFixed(8); } + VhcModels.update(vhc[0] ? vhc[0].vid : 0, { sum_milleage: logDevice.vhc_milleage }); } } @@ -249,10 +252,8 @@ class ListenController { try { const c = { id: req.body._id }; let buffer_req = Buffer.from(req.body.data, "base64"); - console.log("buffer_req", buffer_req); const now = moment().unix(); const me = LibDevice.identifyProtocolFromBuffer(buffer_req); - // console.log('app ', buffer_req); const logDevice = { original_hex: me.ori_string, @@ -291,23 +292,16 @@ class ListenController { }; 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); if (act.action_type == "login") { logDevice.action = act.action_type; logDevice.device_id = act.device_id; - devices[c.id] = act.device_id; - // netConn[act.device_id] = c; - if (typeof act.buffer_resp != "undefined") { - // c.write(act.buffer_resp); - } } else if (act.action_type == "location") { logDevice.action = act.action_type; logDevice.device_id = act.device_id; - logDevice.latitude = act.gps_data.latitude || null; logDevice.longitude = act.gps_data.longitude || null; logDevice.speed = act.gps_data.speed; @@ -315,12 +309,10 @@ class ListenController { if (logDevice.latitude) { logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; } - logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; 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(); @@ -328,38 +320,21 @@ class ListenController { } 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_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_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; let stts_alarm = Number(act.stts_data.terminal_info.stts); - if (stts_alarm == 0) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; - } else if (stts_alarm == 1) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; - } else if (stts_alarm == 2) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; - } else if (stts_alarm == 3) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; - } else if (stts_alarm == 4) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; - } + logDevice.stts_alarm = stts_alarm === 1 ? GpsTracksModels.STTS_ALARM_SHOCK : stts_alarm === 2 ? GpsTracksModels.STTS_ALARM_POWER_CUT : stts_alarm === 3 ? GpsTracksModels.STTS_ALARM_LOW_BATTERY : stts_alarm === 4 ? GpsTracksModels.STTS_ALARM_SOS : GpsTracksModels.STTS_ALARM_NORMAL; logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; - - if (typeof act.buffer_resp != "undefined") { - // c.write(act.buffer_resp); - } } else if (act.action_type == "alarm") { logDevice.action = act.action_type; logDevice.device_id = act.device_id; - logDevice.latitude = act.gps_data.latitude || null; logDevice.longitude = act.gps_data.longitude || null; logDevice.speed = act.gps_data.speed; @@ -367,47 +342,27 @@ class ListenController { if (logDevice.latitude) { logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; } - logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; 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.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_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_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; let stts_alarm = Number(act.stts_data.terminal_info.stts); - if (stts_alarm == 0) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; - } else if (stts_alarm == 1) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; - } else if (stts_alarm == 2) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; - } else if (stts_alarm == 3) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; - } else if (stts_alarm == 4) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; - } + logDevice.stts_alarm = stts_alarm === 1 ? GpsTracksModels.STTS_ALARM_SHOCK : stts_alarm === 2 ? GpsTracksModels.STTS_ALARM_POWER_CUT : stts_alarm === 3 ? GpsTracksModels.STTS_ALARM_LOW_BATTERY : stts_alarm === 4 ? GpsTracksModels.STTS_ALARM_SOS : GpsTracksModels.STTS_ALARM_NORMAL; logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; - 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"); - - 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; } diff --git a/controllers/ListenController_bak.js b/controllers/ListenController_bak.js new file mode 100644 index 0000000..177eb5c --- /dev/null +++ b/controllers/ListenController_bak.js @@ -0,0 +1,439 @@ +const moment = require("moment"); +const Validator = require("validatorjs"); +const Helper = require("../library/LibHelper"); +const response = require("../config/response"); +const LibMail = require("../library/LibMail"); +const LibDevice = require("../library/LibDevice"); +const DanaModels = require("../models/DanaModels"); +const GpsTracksModels = require("../models/GpsTracksModels"); +const { nanoid } = require("nanoid"); +const VhcModels = require("../models/VhcModels"); +const ZoneModels = require("../models/ZoneModels"); +const LibHelper = require("../library/LibHelper"); + +// const LibQueueBlastOrder = require('../library/LibQueueBlastOrder'); +Validator.useLang("en"); + +const devices = []; + +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; + } else { + if (lastTrack.length > 0) { + const checkLastHeartbeat = await GpsTracksModels.getLastHeartbeatToDeterminIdling(logDevice.device_id, lastTrack[0].crt, now); + if (checkLastHeartbeat.length >= 3) { + logDevice.stts_engine = GpsTracksModels.STTS_EN_IDLING; + } else { + logDevice.stts_engine = lastTrack[0].stts_engine; + } + } + } + } else { + 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)) { + console.log("logDevice:", logDevice); + // get last ignition + const lastHeartbeatOrAlarm = await GpsTracksModels.get2LastHeartbeatOrAlarm(logDevice.device_id); + if (lastHeartbeatOrAlarm.length > 0) { + logDevice.ignition = lastHeartbeatOrAlarm[0].ignition; + logDevice.stts_gps = lastHeartbeatOrAlarm[0].stts_gps; + logDevice.stts_gsm = lastHeartbeatOrAlarm[0].stts_gsm; + logDevice.stts_oil_electricity = lastHeartbeatOrAlarm[0].stts_oil_electricity; + logDevice.stts_alarm = lastHeartbeatOrAlarm[0].stts_alarm; + logDevice.stts_charge = lastHeartbeatOrAlarm[0].stts_charge; + logDevice.stts_acc = lastHeartbeatOrAlarm[0].stts_acc; + logDevice.stts_volt = lastHeartbeatOrAlarm[0].stts_volt; + logDevice.stts_switch = lastHeartbeatOrAlarm[0].stts_switch; + } else { + logDevice.ignition = null; + logDevice.stts_gps = null; + logDevice.stts_gsm = null; + logDevice.stts_oil_electricity = null; + logDevice.stts_alarm = null; + logDevice.stts_charge = null; + logDevice.stts_acc = null; + logDevice.stts_volt = null; + logDevice.stts_switch = null; + } + // set engine stts moving,idling,stopped + if (logDevice.ignition == GpsTracksModels.STTS_IGNITION_HIGH) { + if (logDevice.speed) { + logDevice.stts_engine = GpsTracksModels.STTS_EN_MOVING; + } else { + if (lastTrack.length > 0) { + const checkLastHeartbeat = await GpsTracksModels.getLastHeartbeatToDeterminIdling(logDevice.device_id, lastTrack[0].crt, now); + if (checkLastHeartbeat.length >= 3) { + logDevice.stts_engine = GpsTracksModels.STTS_EN_IDLING; + } else { + logDevice.stts_engine = lastTrack[0].stts_engine; + } + } + } + // get stts_alarm, stts_charge, stts_acc, stts_volt, stts_switch + } else { + logDevice.stts_engine = GpsTracksModels.STTS_EN_STOPING; + } + logDevice.stts_oil_electricity = lastHeartbeatOrAlarm[0].stts_oil_electricity; + logDevice.stts_alarm = lastHeartbeatOrAlarm[0].stts_alarm; + logDevice.stts_charge = lastHeartbeatOrAlarm[0].stts_charge; + logDevice.stts_acc = lastHeartbeatOrAlarm[0].stts_acc; + logDevice.stts_volt = lastHeartbeatOrAlarm[0].stts_volt; + 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; + logDevice.longitude = lastTrack[0].longitude; + logDevice.speed = lastTrack[0].speed; + logDevice.orientation = lastTrack[0].orientation; + if (logDevice.latitude) { + logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; + } + + logDevice.length_gps = lastTrack[0].length_gps; + logDevice.pos_stlt_gps = lastTrack[0].pos_stlt_gps; + 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; + logDevice.crt_d_format = moment.unix(now).format("YYYY-MM-DD HH:mm:ss"); + } + } + + // 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 + return false; + } + logDevice.pre_milleage = distance_km; + logDevice.sum_milleage = (lastTrack[0].sum_milleage + logDevice.pre_milleage).toFixed(8); + if (vhc.length > 0) { + logDevice.vhc_id = vhc[0] ? vhc[0].vid : 0; + // if (lastTrack[0].vhc_id == logDevice.vhc_id) { + // logDevice.vhc_milleage = (lastTrack[0].vhc_milleage + logDevice.pre_milleage).toFixed(8); + // } else { + // logDevice.vhc_milleage = (vhc[0] ? vhc[0].sum_milleage : 0 + logDevice.pre_milleage).toFixed(8); + // } + if (lastTrack[0].vhc_id == logDevice.vhc_id) { + logDevice.vhc_milleage = (lastTrack[0].vhc_milleage + logDevice.pre_milleage).toFixed(8); + } else { + logDevice.vhc_milleage = ((vhc[0] ? vhc[0].sum_milleage : 0) + logDevice.pre_milleage).toFixed(8); + } + + VhcModels.update(vhc[0] ? vhc[0].vid : 0, { sum_milleage: logDevice.vhc_milleage }); + } + } + + // 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 = []; + for (let zone of inCircle) { + insideSpawnZone.push(zone); + } + for (let zone of inShape) { + insideSpawnZone.push(zone); + } + + /** + * get lastSpawn desc index 0, where leave_at = 0 + * kalo gaada create, dengan isi field enter_at aja, kalo ada didalam zona + * kalo ada update, dengan isi field leave_at aja, kalo udah diluar zona + */ + const lastSpawn = await GpsTracksModels.listSpawnZone({ + source: GpsTracksModels.SOURCE_GPS_TRACKER, + device_id: logDevice.device_id, + vhc_id: vhc[0] ? vhc[0].vid : 0, + leave_at_d: 0, + order_by: "ORDER BY id DESC", + limit: 1, + }); + + if (lastSpawn.length > 0) { + let is_leave_zone = 1; + for (const insideZone of insideSpawnZone) { + if (insideZone.zid === lastSpawn[0].zone_id) is_leave_zone = 0; + } + if (is_leave_zone === 1 && lastSpawn[0].device_id == logDevice.device_id) { + GpsTracksModels.updt2SpawnZone( + { + leave_lat: logDevice.latitude, + leave_lng: logDevice.longitude, + leave_at_d: logDevice.crt_d || now, + leave_at_d_format: moment.unix(logDevice.crt_d || now).format("YYYY-MM-DD HH:mm:ss"), + leave_at_s: now, + leave_at_s_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + updt: now, + updt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + }, + lastSpawn[0].id + ); + } + } else { + for (let zone of insideSpawnZone) { + let mailData = { + pic_name: zone.pic_name, + pic_mail: zone.pic_mail, + z_name: zone.name, + z_type_name: zone.type_name, + z_workflow_name: zone.workflow_type_name, + shiptocode: zone.shiptocode, + z_fulladdress: zone.fulladdress, + v_nopol: (vhc[0] ? vhc[0].nopol1 : 0 || "") + (vhc[0] ? vhc[0].nopol2 : 0 || "") + (vhc[0] ? vhc[0].nopol3 : 0 || ""), + 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({ + device_id: logDevice.device_id, + master_id: Number(currTrack.result.insertId), + enter_lat: logDevice.latitude, + enter_lng: logDevice.longitude, + enter_at_d: logDevice.crt_d || now, + enter_at_d_format: moment.unix(logDevice.crt_d || now).format("YYYY-MM-DD HH:mm:ss"), + enter_at_s: now, + enter_at_s_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + zone_id: zone.zid, + zone_name: zone.name, + vhc_id: vhc[0] ? vhc[0].vid : 0, + source: GpsTracksModels.SOURCE_GPS_TRACKER, + crt: now, + crt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + }); + if (logDevice.device_id === "0865784052395871") console.log("DISINI"); + } + } + } else { + // log tracking + GpsTracksModels.bundleCreate2(logDevice, logDevice); + } + } catch (e) { + console.error(e); + } +} + +class ListenController { + async gps(req, res) { + let apiRes = {}; + try { + const c = { id: req.body._id }; + let buffer_req = Buffer.from(req.body.data, "base64"); + console.log("buffer_req", buffer_req); + const now = moment().unix(); + const me = LibDevice.identifyProtocolFromBuffer(buffer_req); + // console.log('app ', buffer_req); + + const logDevice = { + original_hex: me.ori_string, + protocol: me.protocol_name == "unknown" ? null : me.protocol_name, + action: null, + device_id: null, + latitude: null, + longitude: null, + speed: null, + orientation: 0, + ignition: 0, + stts_engine: 0, + stts_gps: 0, + length_gps: 0, + pos_stlt_gps: 0, + pos_type_gps: 0, + is_pos_gps: 0, + stts_gsm: 0, + stts_oil_electricity: 0, + stts_alarm: 0, + stts_charge: 0, + stts_acc: 0, + stts_volt: 0, + stts_switch: 0, + stts_reverse_geo: 0, + pre_milleage: 0, + source: GpsTracksModels.SOURCE_GPS_TRACKER, + vhc_id: 0, + drv_id: 0, + crt: now, + crt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + crt_d: 0, + crt_d_format: null, + crt_s: now, + crt_s_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + }; + + 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); + + if (act.action_type == "login") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; + + devices[c.id] = act.device_id; + // netConn[act.device_id] = c; + if (typeof act.buffer_resp != "undefined") { + // c.write(act.buffer_resp); + } + } else if (act.action_type == "location") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; + + logDevice.latitude = act.gps_data.latitude || null; + logDevice.longitude = act.gps_data.longitude || null; + logDevice.speed = act.gps_data.speed; + logDevice.orientation = act.gps_data.orientation; + if (logDevice.latitude) { + logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; + } + + logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; + logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; + 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"); + } 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_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 + + let stts_alarm = Number(act.stts_data.terminal_info.stts); + if (stts_alarm == 0) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; + } else if (stts_alarm == 1) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; + } else if (stts_alarm == 2) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; + } else if (stts_alarm == 3) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; + } else if (stts_alarm == 4) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; + } + + logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; + logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; + logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; + logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; + + if (typeof act.buffer_resp != "undefined") { + // c.write(act.buffer_resp); + } + } else if (act.action_type == "alarm") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; + + logDevice.latitude = act.gps_data.latitude || null; + logDevice.longitude = act.gps_data.longitude || null; + logDevice.speed = act.gps_data.speed; + logDevice.orientation = act.gps_data.orientation; + if (logDevice.latitude) { + logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; + } + + logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; + logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; + 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.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_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 + + let stts_alarm = Number(act.stts_data.terminal_info.stts); + if (stts_alarm == 0) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; + } else if (stts_alarm == 1) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; + } else if (stts_alarm == 2) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; + } else if (stts_alarm == 3) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; + } else if (stts_alarm == 4) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; + } + + logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; + logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; + logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; + logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; + + 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"); + + if (typeof act.buffer_resp != "undefined") { + // c.write(act.buffer_resp); + } + } + // act.action_type == 'other' + else { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; + } + } + + await commitMessage(now, logDevice); + + apiRes = JSON.parse(JSON.stringify(response[200])); + apiRes.meta.message = "success"; + apiRes.data = logDevice; + return res.status(200).json(apiRes); + } catch (e) { + console.log("error", e); + apiRes = JSON.parse(JSON.stringify(response[500])); + apiRes.meta.message += Helper.setErrMsg(": " + e.message); + return res.status(500).json(apiRes); + } + } +} + +const object = new ListenController(); + +module.exports = object; diff --git a/routes/routes.js b/routes/routes.js index 2e6d827..32f3fb8 100755 --- a/routes/routes.js +++ b/routes/routes.js @@ -1,50 +1,48 @@ -const WorkerController = require('../controllers/WorkerController'); -const ZoneController = require('../controllers/ZoneController'); -const DummyController = require('../controllers/DummyController'); -const OrderController = require('../controllers/OrderController'); +const WorkerController = require("../controllers/WorkerController"); +const ZoneController = require("../controllers/ZoneController"); +const DummyController = require("../controllers/DummyController"); +const OrderController = require("../controllers/OrderController"); const ListenController = require("../controllers/ListenController"); -const ServiceDriverRoute = require('./ServiceDriverRoute'); +const ServiceDriverRoute = require("./ServiceDriverRoute"); const { PATH_URL } = process.env; exports.use = function (app) { + // app.all('/*', DummyController.logging); - // app.all('/*', DummyController.logging); + // queue + app.post(PATH_URL + "/workers/add", WorkerController.add); + app.get(PATH_URL + "/workers/getJobs", WorkerController.getJobs); + app.get(PATH_URL + "/workers/getRepeatableJobs", WorkerController.getRepeatableJobs); + app.post(PATH_URL + "/workers/resume", WorkerController.resume); + app.post(PATH_URL + "/workers/pause", WorkerController.pause); + app.post(PATH_URL + "/workers/drain", WorkerController.drain); + app.post(PATH_URL + "/workers/obliterate", WorkerController.obliterate); + // workers + app.post(PATH_URL + "/workers/start", WorkerController.start); + app.post(PATH_URL + "/workers/shutdown", WorkerController.shutdown); + // process workers via request + app.post(PATH_URL + "/workers/revgeo", WorkerController.revgeo); - // queue - app.post(PATH_URL + '/workers/add', WorkerController.add); - app.get(PATH_URL + '/workers/getJobs', WorkerController.getJobs); - app.get(PATH_URL + '/workers/getRepeatableJobs', WorkerController.getRepeatableJobs); - app.post(PATH_URL + '/workers/resume', WorkerController.resume); - app.post(PATH_URL + '/workers/pause', WorkerController.pause); - app.post(PATH_URL + '/workers/drain', WorkerController.drain); - app.post(PATH_URL + '/workers/obliterate', WorkerController.obliterate); - // workers - app.post(PATH_URL + '/workers/start', WorkerController.start); - app.post(PATH_URL + '/workers/shutdown', WorkerController.shutdown); - // process workers via request - app.post(PATH_URL + '/workers/revgeo', WorkerController.revgeo); + // zoning + app.get(PATH_URL + "/zone/nearest", ZoneController.nearest); + app.get(PATH_URL + "/zone/in_circle", ZoneController.inCircle); + app.get(PATH_URL + "/zone/in_shape", ZoneController.inShape); - // zoning - app.get(PATH_URL + '/zone/nearest', ZoneController.nearest); - app.get(PATH_URL + '/zone/in_circle', ZoneController.inCircle); - app.get(PATH_URL + '/zone/in_shape', ZoneController.inShape); + // order + app.post(PATH_URL + "/order/create", OrderController.createOrder); + app.post(PATH_URL + "/order/email_to_vendor", OrderController.emailToVendor); + app.post(PATH_URL + "/order/email_vendor_acc_order", OrderController.emailVdrAccOrder); + app.post(PATH_URL + "/order/delay_blast_order", OrderController.delayBlastOrder); + app.post(PATH_URL + "/order/finance_info_tf_pocket", OrderController.sendFinanceInfoTfPocket); + app.post(PATH_URL + "/order/finance_info_dana_amount", OrderController.sendFinanceInfoDanaAmount); - // order - app.post(PATH_URL + '/order/create', OrderController.createOrder); - app.post(PATH_URL + '/order/email_to_vendor', OrderController.emailToVendor); - app.post(PATH_URL + '/order/email_vendor_acc_order', OrderController.emailVdrAccOrder); - app.post(PATH_URL + '/order/delay_blast_order', OrderController.delayBlastOrder); - app.post(PATH_URL + '/order/finance_info_tf_pocket', OrderController.sendFinanceInfoTfPocket); - app.post(PATH_URL + '/order/finance_info_dana_amount', OrderController.sendFinanceInfoDanaAmount); - - // dummy - app.get(PATH_URL + '/dummy/distance', DummyController.distance); - app.post(PATH_URL + '/dummy/send_email', DummyController.sendEmail); - - // LISTEN - app.post(PATH_URL + "/listen/gps", ListenController.gps); - ServiceDriverRoute.routesConfig(app); + // dummy + app.get(PATH_URL + "/dummy/distance", DummyController.distance); + app.post(PATH_URL + "/dummy/send_email", DummyController.sendEmail); + // LISTEN + app.post(PATH_URL + "/listen/gps", ListenController.gps); + ServiceDriverRoute.routesConfig(app); };