Arminta
/
watermanagement-backend-prod
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'master' of http://35.207.205.18:3000/Arminta/watermanagement-backend

Browse Source
master^2
ashok 9 months ago
parent 65a91115d6 ad0cf229b9
commit ddcda7651d
1 changed files with 258 additions and 144 deletions
Show Stats Download Patch File Download Diff File

402
src/controllers/tanksController.js
Unescape View File

@ -2841,62 +2841,215 @@ async function calculateTotalPumpedWater(customerId, motorId, start_instance_id)
exports.motorAction = async (req, reply) => { exports.motorAction = async (req, reply) => {
try { try {
const { customerId } = req.params; const customerId = req.params.customerId;
const { action, motor_id: motorId, start_instance_id, phone, threshold_type, manual_threshold_time, manual_threshold_litres } = req.body; const action = req.body.action;
const motorId = req.body.motor_id;
if (!motorId) throw new Error("Motor ID is required."); const start_instance_id = req.body.start_instance_id;
// Define thresholds for water levels
const lowWaterThreshold = 5; // Low water level percentage threshold
//const highWaterThreshold = 90; // High water level percentage threshold
const highWaterThreshold = 70; // High water level percentage threshold
const veryHighWaterThreshold = 80; // Very High water level percentage threshold
const criticalHighWaterThreshold = 85;
// Ensure motor_id is provided
if (!motorId) {
throw new Error("Motor ID is required.");
}
// Get user FCM tokens
const users = await User.findOne({ customerId }); const users = await User.findOne({ customerId });
if (!users) return reply.status(404).send({ error: "User not found" }); console.log("users",users)
let loggedInUser = null;
let loggedInUser = users.phone === phone ? if (users) {
{ role: "Customer", name: users.username, phone: users.phone } : if (users.phone === req.body.phone) {
users.staff?.staff?.find(staff => staff.phone === phone) ? loggedInUser = { role: "Customer", name: users.username, phone: users.phone };
{ role: "Staff", name: users.staff.staff.find(staff => staff.phone === phone).name, phone } : null; } else if (users.staff && users.staff.staff) {
const staffMember = users.staff.staff.find(staff => staff.phone === req.body.phone);
if (staffMember) {
loggedInUser = { role: "Staff", name: staffMember.name, phone: staffMember.phone };
}
}
}
if (!loggedInUser) return reply.status(404).send({ error: "User not found" }); if (!loggedInUser) {
console.log("User not found. Cannot proceed with motorStart event.");
return reply.status(404).send({ error: "User not found" }); // ✅ FIX: Ensure a response is returned
}
const fcmToken = users.fcmIds ? users.fcmIds.filter(id => id) : []; const fcmToken = users.fcmIds ? users.fcmIds.filter(fcmIds => fcmIds) : [];
// const fcmToken = users.map(user => user.fcmIds).filter(fcmIds => fcmIds);
console.log(fcmToken)
const receiverTank = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() }); const receiverTank = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() });
if (!receiverTank) throw new Error("Receiver tank not found."); console.log(receiverTank)
const currentWaterLevel = parseInt(receiverTank.waterlevel, 10);
const waterLevelThresholds = { low: 30, veryLow: 20, criticallyLow: 10 };
const typeOfWater = receiverTank.typeOfWater; const typeOfWater = receiverTank.typeOfWater;
let motorStopStatus = action === "start" ? "2" : "1"; console.log(typeOfWater,"typeOfWater")
const blockName = req.body.from || "Unknown Block";
const tankName = req.body.to || "Unknown Tank"; // Determine the motor stop status based on the action
let motorStopStatus;
const blockName = req.body.from || "Unknown Block"; // Provide a fallback if `from` is missing
const tankName = req.body.to || "Unknown Tank"; // Provide a fallback if `to` is missing
const stopTime = req.body.stopTime const stopTime = req.body.stopTime
const motorOnType = "manual";
const manual_threshold_time = req.body.manual_threshold_time;
let hasNotifiedStart = false;
let hasNotifiedStop = false;
if (action === "start") { if (action === "start") {
motorStopStatus = "2";
if (motorIntervals[motorId]) { const startTime = req.body.startTime;
console.log(`🛑 Clearing old interval for motorId: ${motorId}`); await Tank.updateOne(
clearInterval(motorIntervals[motorId]); { customerId, "connections.inputConnections.motor_id": motorId },
delete motorIntervals[motorId]; { $set: { "connections.inputConnections.$.motor_stop_status": motorStopStatus } }
);
const thresholdTimeMs = req.body.manual_threshold_time * 60 * 1000; // Convert minutes to milliseconds
const stopCriteria =
motorOnType === "time"
? `${req.body.manual_threshold_time} minutes`
: `${req.body.manual_threshold_litres} litres`;
try {
eventEmitter.emit(
"motorStart",
customerId,
fcmToken,
tankName,
blockName,
startTime,
"Mobile APP",
manual_threshold_time,
typeOfWater,
motorId,
loggedInUser.phone,
);
reply.code(200).send({ message: "Motor started successfully." });
} catch (error) {
console.error("Error in handleMotorStart:", error);
reply.code(500).send({ error: "Internal Server Error" });
}
// Start checking water level every 30 minutes
if (!waterLevelCheckInterval) {
waterLevelCheckInterval = setInterval(async () => {
await checkWaterLevel(customerId, motorId, fcmToken, receiverTank);
}, 30 * 60 * 1000); // 30 minutes
}
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{ $set: { "connections.inputConnections.$.motor_stop_status": "2",
"connections.inputConnections.$.manual_threshold_time": manual_threshold_time,
"connections.inputConnections.$.threshold_type": "time",
"connections.inputConnections.$.motor_on_type": "manual" } }
);
reply.code(200).send({ message: "Motor started successfully." });
} else if (action === "stop") {
motorStopStatus = "1"; // If action is stop, set stop status to "1"
// Confirm deletion try {
if (!motorIntervals[motorId]) {
console.log(`✅ Old interval successfully deleted.`);
} else { const totalWaterPumped = await calculateTotalPumpedWater(customerId, motorId, start_instance_id);
console.error(`❌ Failed to delete old interval.`);
eventEmitter.emit("motorStop", customerId, fcmToken, tankName, blockName, stopTime, "Mobile APP", totalWaterPumped, typeOfWater, motorId,
loggedInUser.phone,);
reply.code(200).send({ message: "Motor stopped successfully." });
} catch (error) {
console.error("Error in handleMotorStop:", error);
reply.code(500).send({ error: "Internal Server Error" });
}
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{
$set: {
"connections.inputConnections.$.motor_stop_status": "1",
"connections.inputConnections.$.motor_on_type": motorOnType }
}
);
// Clear the interval when the motor is stopped
if (waterLevelCheckInterval) {
clearInterval(waterLevelCheckInterval);
waterLevelCheckInterval = null; // Reset the interval ID
}
} else {
throw new Error("Invalid action provided.");
}
// If action is stop, immediately update motor status and perform stop operations
if (action === "stop") {
console.log("enterted stop")
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{
$set: {
"connections.inputConnections.$.motor_stop_status": "1",
"connections.inputConnections.$.motor_on_type": "manual",
"connections.inputConnections.$.stopTime": req.body.stopTime,
"connections.inputConnections.$.threshold_type": null,
"connections.inputConnections.$.manual_threshold_time": null,
"connections.inputConnections.$.manual_threshold_percentage": null
}
} }
);
if (motorIntervals[motorId]) {
console.log(motorIntervals[motorId],"deleted")
clearInterval(motorIntervals[motorId]); // Clear the interval
delete motorIntervals[motorId]; // Remove the interval from the object
} }
const startTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm'); this.publishMotorStopStatus(motorId, motorStopStatus);
// Send immediate response to the client
reply.code(200).send({ message: "Motor stopped successfully." });
// Perform stop operations in the background
(async () => {
console.log(start_instance_id,"start_instance_id",customerId,"customerId",motorId,"motorId")
const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id: start_instance_id });
if (motorData) {
console.log("entered if in stop")
const receiverTank = await Tank.findOne({ customerId, tankName: motorData.receiverTank, tankLocation: motorData.receiver_type.toLowerCase() });
const receiverFinalWaterLevel = parseInt(receiverTank.waterlevel, 10);
const quantityDelivered = receiverFinalWaterLevel - parseInt(motorData.receiverInitialwaterlevel, 10);
const water_pumped_till_now = parseInt(receiverTank.total_water_added_from_midnight, 10);
const totalwaterpumped = quantityDelivered + water_pumped_till_now;
await Tank.findOneAndUpdate(
{ customerId, tankName: motorData.receiverTank, tankLocation: motorData.receiver_type.toLowerCase() },
{ $set: { total_water_added_from_midnight: totalwaterpumped } }
);
await MotorData.updateOne(
{ customerId, motor_id: motorId, start_instance_id: start_instance_id },
{
$set: {
stopTime: req.body.stopTime,
receiverfinalwaterlevel: receiverFinalWaterLevel.toString(),
quantity_delivered: quantityDelivered.toString()
}
}
);
}
})();
return; // Return early to avoid executing the start logic
} else {
await Tank.updateOne( await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId }, { customerId, "connections.inputConnections.motor_id": motorId },
{ $set: { { $set: { "connections.inputConnections.$.motor_stop_status": "2" } }
"connections.inputConnections.$.motor_stop_status": "2",
"connections.inputConnections.$.manual_threshold_time": manual_threshold_time,
"connections.inputConnections.$.threshold_type": threshold_type,
"connections.inputConnections.$.motor_on_type": "manual"
}}
); );
}
eventEmitter.emit("motorStart", customerId, fcmToken, tankName, blockName, startTime, "Mobile APP", manual_threshold_time, typeOfWater, motorId, loggedInUser.phone);
//this.publishMotorStopStatus(motorId, motorStopStatus); // Check threshold settings if action is start
reply.code(200).send({ message: "Motor started successfully." }); if (action === "start") {
if (req.body.threshold_type === "time") { if (req.body.threshold_type === "time") {
// Create a new MotorData entry // Create a new MotorData entry
const receiverTank = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() }); const receiverTank = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() });
@ -2912,7 +3065,7 @@ exports.motorAction = async (req, reply) => {
receiverInitialwaterlevel: parseInt(receiverTank.waterlevel, 10) receiverInitialwaterlevel: parseInt(receiverTank.waterlevel, 10)
}); });
await newMotorData.save(); await newMotorData.save();
console.log("entered time",motorId,motorStopStatus)
// Update the tank connections with start time and threshold time // Update the tank connections with start time and threshold time
for await (const tank of Tank.find({ "connections.inputConnections.motor_id": motorId })) { for await (const tank of Tank.find({ "connections.inputConnections.motor_id": motorId })) {
this.publishMotorStopStatus(motorId, motorStopStatus); this.publishMotorStopStatus(motorId, motorStopStatus);
@ -2933,88 +3086,55 @@ exports.motorAction = async (req, reply) => {
); );
} }
} }
const thresholdTime = new Date(new Date().getTime() + req.body.manual_threshold_time * 60000);
console.log("New Threshold Time:", thresholdTime); const thresholdTime = new Date(new Date().getTime() + req.body.manual_threshold_time * 60000);
console.log("Current Time:", new Date());
motorIntervals[motorId] = setInterval(async () => { motorIntervals[motorId] = setInterval(async () => {
const supplierTank = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() }); const supplierTank = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() });
const currentWaterLevel = parseInt(supplierTank.waterlevel, 10); const currentWaterLevel = parseInt(supplierTank.waterlevel, 10);
const currentWaterPercentage = (currentWaterLevel / parseInt(supplierTank.capacity.replace(/,/g, ''), 10)) * 100; const currentWaterPercentage = (currentWaterLevel / parseInt(supplierTank.capacity.replace(/,/g, ''), 10)) * 100;
// const notificationTracker = new Map(); const notificationTracker = new Map();
if (new Date() >= thresholdTime || currentWaterPercentage <= lowWaterThreshold) { if (new Date() >= thresholdTime || currentWaterPercentage <= lowWaterThreshold) {
console.log(new Date(),"new date") console.log(new Date(),"new date")
console.log(thresholdTime,"thresholdTime") console.log(thresholdTime,"thresholdTime")
//console.log("motor stopping because it entered this condition") console.log("motor stopping because it entered this condition")
// Emit the threshold time notification // Emit the threshold time notification
try { // eventEmitter.emit(
console.log("motor stopping because it entered this condition") // "sendThresholdTimeNotification",
// customerId,
const tank = await Tank.findOne( // fcmToken,
{ customerId, "connections.inputConnections.motor_id": motorId }, // manual_threshold_time,
{ "connections.inputConnections.$": 1 } // Fetch only relevant motor connection // motorId,
); // tankName,
// blockName
if (tank && tank.connections.inputConnections[0].motor_stop_status === "1") { // );
console.log("⚠️ Motor already stopped. Skipping notification.");
} else { const notificationKey = `${customerId}_${motorId}_threshold`;
console.log("🚀 Sending threshold time notification...");
eventEmitter.emit(
"sendThresholdTimeNotification",
customerId,
fcmToken,
manual_threshold_time,
motorId,
tankName,
blockName
);
}
// eventEmitter.emit(
// "sendThresholdTimeNotification",
// customerId,
// fcmToken,
// manual_threshold_time,
// motorId,
// tankName,
// blockName
// );
reply.code(200).send({ message: "Motor stopped successfully." });
} catch (error) {
console.error("Error in handleMotorStop:", error);
reply.code(500).send({ error: "Internal Server Error" });
}
//const notificationKey = `${customerId}_${motorId}_threshold`;
// Check if the notification has already been sent // Check if the notification has already been sent
// if (!notificationTracker.get(notificationKey)) { if (!notificationTracker.get(notificationKey)) {
// console.log("Sending threshold time notification..."); console.log("Sending threshold time notification...");
// eventEmitter.emit( eventEmitter.emit(
// "sendThresholdTimeNotification", "sendThresholdTimeNotification",
// customerId, customerId,
// fcmToken, fcmToken,
// manual_threshold_time, manual_threshold_time,
// motorId, motorId,
// tankName, tankName,
// blockName blockName
// ); );
// // Mark notification as sent // Mark notification as sent
// notificationTracker.set(notificationKey, true); notificationTracker.set(notificationKey, true);
// // Optionally, reset the flag after some time (e.g., 24 hours) // Optionally, reset the flag after some time (e.g., 24 hours)
// setTimeout(() => { setTimeout(() => {
// notificationTracker.delete(notificationKey); notificationTracker.delete(notificationKey);
// }, 24 * 60 * 60 * 1000); // Reset after 24 hours }, 24 * 60 * 60 * 1000); // Reset after 24 hours
// } else { } else {
// console.log("Notification already sent, skipping..."); console.log("Notification already sent, skipping...");
// } }
const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm'); const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm');
await Tank.updateOne( await Tank.updateOne(
@ -3030,20 +3150,28 @@ exports.motorAction = async (req, reply) => {
} }
} }
); );
// eventEmitter.emit('sendLowWaterNotification', fcmToken, receiverTank);
// console.log(motorIntervals[motorId],"deleted automatically") // Emit low water level notification
// clearInterval(motorIntervals[motorId]); // Clear interval
// delete motorIntervals[motorId];
// await checkWaterLevelsAndNotify(customerId, tankName, supplierTank.tankLocation, fcmToken);
// if (currentWaterPercentage >= highWaterThreshold && !notificationSentStatus.highWater) {
// eventEmitter.emit('sendHighWaterNotification', fcmToken, `Water level has reached high levels.`);
// notificationSentStatus.highWater = true; // Set flag to true to prevent duplicate notifications
// }
if (motorIntervals[motorId]) { // if (currentWaterPercentage >= veryHighWaterThreshold && !notificationSentStatus.veryHighWater) {
console.log(`🛑 Clearing interval for motorId: ${motorId}`); // eventEmitter.emit('sendVeryHighWaterNotification', fcmToken, `Water level has reached very high levels.`);
clearInterval(motorIntervals[motorId]); // notificationSentStatus.veryHighWater = true; // Set flag to true to prevent duplicate notifications
delete motorIntervals[motorId]; // }
// Confirm deletion // if (currentWaterPercentage >= criticalHighWaterThreshold && !notificationSentStatus.criticallyHighWater) {
if (!motorIntervals[motorId]) { // eventEmitter.emit('sendCriticalHighWaterNotification', fcmToken, `Water level has reached critically high levels.`);
console.log(`✅ Interval for motorId: ${motorId} successfully deleted.`); // notificationSentStatus.criticallyHighWater = true; // Set flag to true to prevent duplicate notifications
} else { // }
console.error(`❌ Failed to delete interval for motorId: ${motorId}`); clearInterval(motorIntervals[motorId]); // Stop the motor if condition met
} delete motorIntervals[motorId]; // Remove from interval object
}
this.publishMotorStopStatus(motorId, "1"); this.publishMotorStopStatus(motorId, "1");
console.log(start_instance_id,"start_instance_id",customerId,"customerId",motorId,"motorId") console.log(start_instance_id,"start_instance_id",customerId,"customerId",motorId,"motorId")
@ -3085,8 +3213,7 @@ exports.motorAction = async (req, reply) => {
}, 30000); // Check every minute }, 30000); // Check every minute
} }
} }else if (req.body.threshold_type === "litres") {
else if (req.body.threshold_type === "litres") {
console.log("entered litres") console.log("entered litres")
const receiver_tank_info7 = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() }); const receiver_tank_info7 = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() });
const supplier_tank_info7 = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() }); const supplier_tank_info7 = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() });
@ -3192,25 +3319,12 @@ exports.motorAction = async (req, reply) => {
} }
} }
} else if (action === "stop") {
await stopMotor(motorId, customerId, start_instance_id);
try {
const totalWaterPumped = await calculateTotalPumpedWater(customerId, motorId, start_instance_id);
eventEmitter.emit("motorStop", customerId, fcmToken, tankName, blockName, stopTime, "Mobile APP", totalWaterPumped, typeOfWater, motorId,
loggedInUser.phone,);
reply.code(200).send({ message: "Motor stopped successfully." });
} catch (error) {
console.error("Error in handleMotorStop:", error);
reply.code(500).send({ error: "Internal Server Error" });
}
this.publishMotorStopStatus(motorId, motorStopStatus);
reply.code(200).send({ message: "Motor stopped successfully." });
} }
// Respond with success message
reply.code(200).send({ message: `Motor ${action === "start" ? "started" : "stopped"} successfully.` });
} catch (err) { } catch (err) {
throw boom.boomify(err); throw boom.boomify(err);
} }
@ -3235,7 +3349,7 @@ async function stopMotor(motorId, customerId, start_instance_id) {
delete motorIntervals[motorId]; delete motorIntervals[motorId];
} }
// eventEmitter.emit("motorStop", customerId, [], "", "", currentTime, "Mobile APP", 0, "", motorId, ""); eventEmitter.emit("motorStop", customerId, [], "", "", currentTime, "Mobile APP", 0, "", motorId, "");
const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id }); const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id });
if (motorData) { if (motorData) {

Write Preview
Loading…
Cancel
Save