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 a7d04053bc 4f51941292
commit 6de780de3a
1 changed files with 15 additions and 222 deletions
Show Stats Download Patch File Download Diff File

231
src/controllers/tanksController.js
Unescape View File

@ -1674,39 +1674,6 @@ eventEmitter.on('sendCriticalHighWaterNotification', async (fcmTokens, tankInfo,
const message = `Attention: Water level in '${tankInfo.tankName}' located at '${tankInfo.tankLocation}' is critically high at ${tankInfo.waterLevel}% (${tankInfo.volumeInLitres} L). Water may overflow. Please stop the motor. Motor running from ${startTime} to ${stopTime}.`;
await sendNotification(fcmTokens, 'Critical High Water Level', message, 'Stop Motor');
});
eventEmitter.on('sendThresholdTimeNotification', async (fcmTokens, message) => {
try {
await sendNotification(fcmTokens, 'Threshold Time Reached', message, 'Motor Alert');
console.log("Threshold time notification sent successfully.");
} catch (error) {
console.error("Error sending threshold time notification:", error);
}
});
eventEmitter.on('sendMotorStartNotification', async (fcmTokens, message) => {
try {
await sendNotification(fcmTokens, "Motor Started", message);
console.log("Manual method time notification sent successfully.");
} catch (error) {
console.error("Error sending thresmanual method time notification:", error);
}
});
eventEmitter.on('sendMotorStopNotification', async (fcmTokens, message) => {
try {
await sendNotification(fcmTokens, "Motor Stopped", message);
console.log("Manual method time notification sent successfully.");
} catch (error) {
console.error("Error sending thresmanual method time notification:", error);
}
});
// Emit high water level event with motorId
// eventEmitter.on('highWaterLevel', async (fcmTokens, timestamp, motorId, waterLevel) => {
// await sendNotification(fcmTokens, 'High Water Level', `Motor ID: ${motorId}, water level reached above 90% at ${timestamp}. Current Water Level: ${waterLevel} Ltrs`);
@ -2185,51 +2152,7 @@ console.log(fcmToken)
if (action === "start") {
motorStopStatus = "2";
const startMessage = `The motor supplying water to '${tankName}' in block '${blockName}' has started manually at ${new Date().toISOString()}.`;
eventEmitter.emit("sendMotorStartNotification", fcmToken, startMessage);
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{ $set: { "connections.inputConnections.$.motor_stop_status": motorStopStatus } }
);
const thresholdTimeMs = req.body.manual_threshold_time * 60 * 1000; // Convert minutes to milliseconds
//const startTime = new Date(); // Record the start time
const startTime = req.body.startTime;
// Schedule a task to send a notification when the threshold time is reached
motorIntervals[motorId] = setTimeout(async () => {
try {
// Fetch the latest tank and motor data
const receiverTank = await Tank.findOne({
customerId,
tankName: req.body.to,
tankLocation: req.body.to_type.toLowerCase(),
});
// Send a notification for threshold time reached
const message = `Threshold time of ${req.body.manual_threshold_time} minutes has been reached for the motor supplying '${receiverTank.tankName}' located at '${receiverTank.tankLocation}'. Please review the motor operation.`;
eventEmitter.emit('sendThresholdTimeNotification', fcmToken, message);
// Optionally update the tank or motor state in the database
await Tank.updateOne(
{ customerId, tankName: receiverTank.tankName },
{ $set: { notificationSentThresholdTime: true } }
);
// Optionally stop the motor if needed
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{ $set: { "connections.inputConnections.$.motor_stop_status": "1" } }
);
clearTimeout(motorIntervals[motorId]);
delete motorIntervals[motorId];
} catch (error) {
console.error("Error handling threshold time notification:", error);
}
}, thresholdTimeMs)
const stopCriteria =
motorOnType === "time"
? `${req.body.manual_threshold_time} minutes`
@ -2274,26 +2197,6 @@ console.log(fcmToken)
}, 30000); // Check every 30 seconds
} else if (action === "stop") {
motorStopStatus = "1"; // If action is stop, set stop status to "1"
// Emit stop notification
const stopMessage = `The motor supplying water to '${tankName}' in block '${blockName}' was stopped manually at ${stopTime}.`;
eventEmitter.emit("sendMotorStopNotification", fcmToken, stopMessage);
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{
$set: {
"connections.inputConnections.$.motor_stop_status": motorStopStatus,
"connections.inputConnections.$.motor_on_type": "manual",
"connections.inputConnections.$.stopTime": stopTime
}
}
);
// Clear intervals if any
if (motorIntervals[motorId]) {
clearInterval(motorIntervals[motorId]);
delete motorIntervals[motorId];
}
eventEmitter.emit(
"motorStop",
fcmToken,
@ -2336,14 +2239,13 @@ console.log(fcmToken)
// Perform stop operations in the background
(async () => {
await delay(300000);
const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id: start_instance_id });
if (motorData) {
const supplierTank = await Tank.findOne({ customerId, tankName: motorData.supplierTank, tankLocation: motorData.supplier_type.toLowerCase() });
const supplierFinalWaterLevel = parseInt(supplierTank.waterlevel, 10);
const receiverTank = await Tank.findOne({ customerId, tankName: motorData.receiverTank, tankLocation: motorData.receiver_type.toLowerCase() });
const receiverFinalWaterLevel = parseInt(receiverTank.waterlevel, 10);
const quantityDelivered = parseInt(motorData.supplierInitialwaterlevel, 10)-supplierFinalWaterLevel;
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;
@ -2358,7 +2260,6 @@ console.log(fcmToken)
$set: {
stopTime: req.body.stopTime,
receiverfinalwaterlevel: receiverFinalWaterLevel.toString(),
supplierfinalwaterlevel:supplierFinalWaterLevel.toString(),
quantity_delivered: quantityDelivered.toString()
}
}
@ -2379,7 +2280,6 @@ console.log(fcmToken)
if (req.body.threshold_type === "time") {
// Create a new MotorData entry
const receiverTank = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() });
const supplierTank = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() });
const newMotorData = new MotorData({
customerId,
motor_id: motorId,
@ -2389,7 +2289,6 @@ console.log(fcmToken)
supplier_type: req.body.from_type,
receiver_type: req.body.to_type,
startTime: req.body.startTime,
supplierInitialwaterlevel: parseInt(supplierTank.waterlevel, 10),
receiverInitialwaterlevel: parseInt(receiverTank.waterlevel, 10)
});
await newMotorData.save();
@ -2442,16 +2341,15 @@ console.log(fcmToken)
delete motorIntervals[motorId];
this.publishMotorStopStatus(motorId, "1");
await delay(300000);
const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id: start_instance_id });
if (motorData) {
const supplierTank = await Tank.findOne({ customerId, tankName: motorData.supplierTank, tankLocation: motorData.supplier_type.toLowerCase() });
const supplierFinalWaterLevel = parseInt(supplierTank.waterlevel, 10);
const quantityDelivered = parseInt(motorData.supplierInitialwaterlevel, 10)-supplierFinalWaterLevel;
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 } }
@ -2462,7 +2360,6 @@ console.log(fcmToken)
{
$set: {
stopTime: req.body.stopTime,
supplierfinalwaterlevel: supplierFinalWaterLevel.toString(),
receiverfinalwaterlevel: receiverFinalWaterLevel.toString(),
quantity_delivered: quantityDelivered.toString()
}
@ -2478,114 +2375,8 @@ console.log(fcmToken)
}, 30000); // Check every minute
}
}else if (req.body.threshold_type === "litres") {
console.log("entered litres")
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 newMotorData = new MotorData({
customerId: customerId,
motor_id: motorId,
start_instance_id: start_instance_id,
supplierTank: req.body.from,
receiverTank: req.body.to,
supplier_type: req.body.from_type,
receiver_type: req.body.to_type,
startTime: req.body.startTime,
receiverInitialwaterlevel:parseInt(receiver_tank_info7.waterlevel, 10),
supplierInitialwaterlevel:parseInt(supplier_tank_info7.waterlevel, 10)
});
await newMotorData.save();
// If threshold type is percentage, calculate percentage threshold
const receiver_tank_info = await Tank.findOne({ customerId, tankName: req.body.to, tankLocation: req.body.to_type.toLowerCase() });
const supplier_tank_info = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() });
if (!receiver_tank_info) {
throw new Error("Receiver tank not found.");
}
if (!supplier_tank_info) {
throw new Error("Supplierr tank not found.");
}
const supplier_capacity = parseInt(supplier_tank_info.capacity, 10);
const supplier_waterLevel = parseInt(supplier_tank_info.waterlevel, 10);
const capacity = parseInt(receiver_tank_info.capacity, 10);
const waterLevel = parseInt(receiver_tank_info.waterlevel, 10);
const desired_percentage = parseInt(req.body.manual_threshold_litres.replace(/,/g, ''), 10);
console.log(desired_percentage)
const threshold_water_level = waterLevel+desired_percentage;
const supplier_threshold = supplier_waterLevel-desired_percentage
console.log(supplier_threshold,"supplier_threshold")
for await (const tank of Tank.find({ "connections.inputConnections.motor_id": motorId })) {
this.publishMotorStopStatus(motorId, motorStopStatus);
for await (const tank of Tank.find({ "connections.inputConnections.motor_id": motorId })) {
const index = tank.connections.inputConnections.findIndex(connection => connection.motor_id === motorId);
if (index !== -1) {
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{ $set: { [`connections.inputConnections.${index}.manual_threshold_percentage`]: supplier_threshold.toString(), [`connections.inputConnections.${index}.startTime`]: req.body.startTime } }
);
}
}
// Update water level threshold
// Start monitoring water level based on threshold percentage
motorIntervals[motorId] = setInterval(async () => {
// Check if water level has reached the threshold percentage
const supplier_tank_info1 = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() });
const current_water_level = parseInt(supplier_tank_info1.waterlevel, 10);
if (current_water_level <= supplier_threshold) {
// Stop the motor pump
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{
$set: {
"connections.inputConnections.$.motor_stop_status": "1",
"connections.inputConnections.$.threshold_type": null,
"connections.inputConnections.$.manual_threshold_time": null,
"connections.inputConnections.$.manual_threshold_percentage": null
}
}
);
clearInterval(motorIntervals[motorId]); // Clear interval
delete motorIntervals[motorId];
this.publishMotorStopStatus(motorId, "1");
await delay(300000);
const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id: start_instance_id });
if (motorData) {
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 stopTime = formatDate(new Date());
await MotorData.updateOne(
{ customerId, motor_id: motorId, start_instance_id: start_instance_id },
{
$set: {
stopTime:stopTime,
receiverfinalwaterlevel: receiverFinalWaterLevel.toString(),
quantity_delivered: quantityDelivered.toString()
}
}
);
}
}
}, 20000);
}
}
}
// Respond with success message
reply.code(200).send({ message: `Motor ${action === "start" ? "started" : "stopped"} successfully.` });
@ -2595,6 +2386,7 @@ console.log(fcmToken)
};
// exports.motorAction = async (req, reply) => {
// try {
// const customerId = req.params.customerId;
@ -5038,12 +4830,14 @@ client.on('message', async (topic, message) => {
const inputConnection = motorTank.connections.inputConnections.find(conn => conn.motor_id === hw_Id); // Updated variable name
if (inputConnection) {
inputConnection.motor_status = status; // Update motor status
if (inputConnection.motor_stop_status === "1" && status === "2" && inputConnection.motor_on_type !== "forced_manual") {
if (inputConnection.motor_stop_status === "1" && status === 2 && inputConnection.motor_on_type !== "forced_manual") {
const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm');
inputConnection.motor_stop_status = "2";
inputConnection.motor_on_type = "forced_manual";
inputConnection.startTime = currentTime;
}
if (inputConnection.motor_stop_status === "2" && status === "1") {
if (inputConnection.motor_stop_status === "2" && status === 1) {
inputConnection.motor_stop_status = "1";
}
@ -5189,7 +4983,6 @@ exports.consumptionofparticulartank = async (request, reply) => {
};
// // Set start and end dates
// const startDate = new Date("2024-08-20T00:00:00Z");
// const endDate = new Date("2024-11-04T00:00:00Z");
@ -5260,6 +5053,7 @@ exports.consumptionofparticulartank = async (request, reply) => {
// // Run the data generation function
// generateData();
async function removeDuplicates () {
try {
// Step 1: Find duplicates, considering time and ignoring case for typeofwater
@ -5309,7 +5103,6 @@ async function removeDuplicates() {
}
}
// Run the remove duplicates function
// removeDuplicates();
console.log("this is for testing autopush,line located in tankscontroller")
Write Preview
Loading…
Cancel
Save