kicap/tanah_longsor_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

try again

Browse Source
This commit is contained in:
kicap1992
2022-08-12 06:41:04 +08:00
parent fda3ea5aff
commit 58856f6687
2 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
index.js
View File

@ -67,6 +67,7 @@ io.on('connection', (socket) => {
console.log('socket connected', userId); console.log('socket connected', userId);
socket.on('reload_calibation', (_) => { socket.on('reload_calibation', (_) => {
console.log("sini reload calibation")
socket.broadcast.emit('reload_calibation', { socket.broadcast.emit('reload_calibation', {
message: 'reload_calibation' message: 'reload_calibation'
}); });

14
routes/from_esp32_routes.js
View File

@ -4,6 +4,7 @@ require('dotenv/config');
const { deviceModel, newDeviceModel, notificationModel } = require('../models/device_model'); const { deviceModel, newDeviceModel, notificationModel } = require('../models/device_model');
const io_sock = require("socket.io-client"); const io_sock = require("socket.io-client");
const socket = io_sock(`https://tanah-longosor-be.herokuapp.com/`); const socket = io_sock(`https://tanah-longosor-be.herokuapp.com/`);
// const socket = io_sock(`http://192.168.43.125:3004/`);
function send_notif(message, id, status, lat, lng) { function send_notif(message, id, status, lat, lng) {
@ -69,9 +70,9 @@ async function update_device_data(device_id, lat, lng, status) {
} }
cek_data_notif = await notificationModel.findOne({ device_id: device_id }); cek_data_notif = await notificationModel.findOne({ device_id: device_id });
console.log("disini ada kah1") // console.log("disini ada kah1")
if (!cek_data_notif) { if (!cek_data_notif) {
console.log("disini ada kah2") // console.log("disini ada kah2")
// insert data notification // insert data notification
if (statusnya != "Normal") { if (statusnya != "Normal") {
send_notif(message, device_id.id, statusnya, device_id.lat, device_id.lng); send_notif(message, device_id.id, statusnya, device_id.lat, device_id.lng);
@ -83,7 +84,7 @@ async function update_device_data(device_id, lat, lng, status) {
}) })
await new_notif.save(); await new_notif.save();
} else { } else {
console.log("disini ada kah3") // console.log("disini ada kah3")
if (cek_data_notif.status != statusnya) { if (cek_data_notif.status != statusnya) {
// update data notification // update data notification
await notificationModel.updateOne({ id: device_id.id }, { status: statusnya }); await notificationModel.updateOne({ id: device_id.id }, { status: statusnya });
@ -146,19 +147,20 @@ router.post('/', async (req, res) => {
} else { } else {
// console.log("di sini dia"); // console.log("di sini dia");
if (cek_device_db.status === 'calibration') { if (cek_device_db.status === 'calibration') {
// console.log("sini calibrate") console.log("sini calibrate")
const lat = latitude; const lat = latitude;
const lng = longitude; const lng = longitude;
if (lat != '' && lng != '') { if (lat != '' && lng != '') {
// update device data // update device data
await deviceModel.findOneAndUpdate({ _id: id }, { $set: { lat: latitude, lng: longitude } }); await deviceModel.findOneAndUpdate({ _id: id }, { $set: { lat: lat, lng: lng } });
await update_device_data(cek_device_db, lat, lng, soilMoistureValue); await update_device_data(cek_device_db, lat, lng, soilMoistureValue);
socket.emit('reload_calibation'); socket.emit('reload_calibation');
console.log("sini calibrate aman")
return res.status(200).send({ status: 'calibration right', message: "Success" }); return res.status(200).send({ status: 'calibration right', message: "Success" });
} else { } else {
console.log("sini calibrate tidak aman")
// if (check_device_db.lat != '' && check_device_db.lng != '') { // if (check_device_db.lat != '' && check_device_db.lng != '') {
return res.status(200).send({ status: 'calibration wrong', message: "Success" }); return res.status(200).send({ status: 'calibration wrong', message: "Success" });