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
Varun 7 months ago
parent d721b4d37c 6b98420c96
commit 65c941386f
1 changed files with 34 additions and 34 deletions
Show Stats Download Patch File Download Diff File

64
src/controllers/tanksController.js
Unescape View File

@ -1572,18 +1572,18 @@ eventEmitter.on('sendCriticalHighWaterNotification', async (fcmTokens, tankInfo,
// }); // });
eventEmitter.on('sendThresholdTimeNotification', async (customerId, fcmTokens, thresholdTime, hw_Id, tankName, blockName) => { // eventEmitter.on('sendThresholdTimeNotification', async (customerId, fcmTokens, thresholdTime, hw_Id, tankName, blockName) => {
try { // try {
const message = // const message =
`🛢️ Tank Name: '${tankName}'\n` + // `🛢️ Tank Name: '${tankName}'\n` +
`🏢 Block Name: '${blockName}'\n` + // `🏢 Block Name: '${blockName}'\n` +
`Motor Stopped as it completed ${thresholdTime} minutes.`; // `Motor Stopped as it completed ${thresholdTime} minutes.`;
await sendNotification(hw_Id, customerId, fcmTokens, 'Motor Alert', message); // await sendNotification(hw_Id, customerId, fcmTokens, 'Motor Alert', message);
console.log("Threshold time notification sent successfully."); // console.log("Threshold time notification sent successfully.");
} catch (error) { // } catch (error) {
console.error("Error sending threshold time notification:", error); // console.error("Error sending threshold time notification:", error);
} // }
}); // });
// eventEmitter.on( // eventEmitter.on(
// 'sendMotorStartNotification', // 'sendMotorStartNotification',
@ -3105,29 +3105,29 @@ exports.motorAction = async (req, reply) => {
const notificationKey = `${customerId}_${motorId}_threshold`; 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(

Write Preview
Loading…
Cancel
Save