@ -216,24 +216,29 @@ exports.getTank = async (req, reply) => {
const transformedDocs = docs . map ( ( tank ) => {
const transformedDocs = docs . map ( ( tank ) => {
const inputConnections = tank . connections ? . inputConnections || [ ] ;
const inputConnections = tank . connections ? . inputConnections || [ ] ;
// Count switches
const switchCount = inputConnections . reduce ( ( count , connection ) => {
const switchCount = inputConnections . reduce ( ( count , connection ) => {
return count + ( connection . inputismotor === true ? 1 : 0 ) ;
return count + ( connection . inputismotor === true ? 1 : 0 ) ;
} , 0 ) ;
} , 0 ) ;
totalSwitchCount += switchCount ;
totalSwitchCount += switchCount ; // Accumulate the switch_count
// Count sensors
// Check if the tank has need_sensor set to "yes"
if ( tank . need _sensor ? . toLowerCase ( ) === "yes" ) {
if ( tank . need _sensor ? . toLowerCase ( ) === "yes" ) {
totalSensorCount ++ ;
totalSensorCount ++ ;
}
}
// Add the switch_count field inside connections
// Determine all_motor_status
const allMotorStatus = inputConnections . some ( connection => connection . motor _status === "2" ) ;
// Add switch_count and all_motor_status to the response
return {
return {
... tank . toObject ( ) , // Convert Mongoose document to plain object
... tank . toObject ( ) , // Convert Mongoose document to plain object
connections : {
connections : {
... tank . connections ,
... tank . connections ,
switch _count : switchCount ,
switch _count : switchCount ,
} ,
} ,
all _motor _status : allMotorStatus , // Add all_motor_status field
} ;
} ;
} ) ;
} ) ;
@ -241,8 +246,8 @@ exports.getTank = async (req, reply) => {
status _code : 200 ,
status _code : 200 ,
data : transformedDocs ,
data : transformedDocs ,
count : transformedDocs . length ,
count : transformedDocs . length ,
total _switch _count : totalSwitchCount , // Add the total switch count
total _switch _count : totalSwitchCount ,
total _sensor _count : totalSensorCount , // Add the total sensor count
total _sensor _count : totalSensorCount ,
} ) ;
} ) ;
} )
} )
. catch ( ( err ) => {
. catch ( ( err ) => {
@ -2198,20 +2203,20 @@ console.log(fcmToken)
// Schedule a task to send a notification when the threshold time is reached
// Schedule a task to send a notification when the threshold time is reached
motorIntervals [ motorId ] = setTimeout ( async ( ) => {
// motorIntervals[motorId] = setTimeout(async () => {
try {
// try {
//
//
//
//
//
) ;
// );
//
delete motorIntervals [ motorId ] ;
// delete motorIntervals[motorId];
} catch ( error ) {
// } catch (error) {
console . error ( "Error in threshold time handling:" , error ) ;
// console.error("Error in threshold time handling:", error);
}
// }
} , thresholdTimeMs ) ;
// }, thresholdTimeMs);
const stopCriteria =
const stopCriteria =
motorOnType === "time"
motorOnType === "time"
? ` ${ req . body . manual _threshold _time } minutes `
? ` ${ req . body . manual _threshold _time } minutes `
@ -2253,27 +2258,27 @@ console.log(fcmToken)
// Schedule threshold check
// Schedule threshold check
// const thresholdTimeMs = manual_threshold_time * 60 * 1000;
// const thresholdTimeMs = manual_threshold_time * 60 * 1000;
motorIntervals [ motorId ] = setTimeout ( async ( ) => {
// motorIntervals[motorId] = setTimeout(async () => {
try {
// try {
//
//
//
//
//
//
//
//
//
//
//
) ;
// );
delete motorIntervals [ motorId ] ;
// delete motorIntervals[motorId];
} catch ( error ) {
// } catch (error) {
console . error ( "Error during threshold handling:" , error ) ;
// console.error("Error during threshold handling:", error);
}
// }
} , thresholdTimeMs ) ;
// }, thresholdTimeMs);
reply . code ( 200 ) . send ( { message : "Motor started successfully." } ) ;
reply . code ( 200 ) . send ( { message : "Motor started successfully." } ) ;
// Schedule water level checks after motor start
// Schedule water level checks after motor start
@ -2299,22 +2304,8 @@ console.log(fcmToken)
// const stopMessage = `The motor supplying water to '${tankName}' in block '${blockName}' was stopped manually at ${stopTime}.`;
// const stopMessage = `The motor supplying water to '${tankName}' in block '${blockName}' was stopped manually at ${stopTime}.`;
// eventEmitter.emit("sendMotorStopNotification", fcmToken, stopMessage);
// 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 (
eventEmitter . emit (
"motorStop" ,
"motorStop" ,
fcmToken ,
fcmToken ,
@ -2326,23 +2317,23 @@ console.log(fcmToken)
motorOnType
motorOnType
) ;
) ;
await Tank . updateOne (
// await Tank.updateOne(
{ customerId , "connections.inputConnections.motor_id" : motorId } ,
// { customerId, "connections.inputConnections.motor_id": motorId },
{
// {
//
//
//
}
// }
}
// }
) ;
// );
// const stopMessage = `Motor supplying water to '${tankName}' in block '${blockName}' stopped manually at ${stopTime}.`;
// const stopMessage = `Motor supplying water to '${tankName}' in block '${blockName}' stopped manually at ${stopTime}.`;
// eventEmitter.emit('sendMotorStopNotification', fcmToken, stopMessage);
// eventEmitter.emit('sendMotorStopNotification', fcmToken, stopMessage);
if ( motorIntervals [ motorId ] ) {
// if (motorIntervals[motorId]) {
clearTimeout ( motorIntervals [ motorId ] ) ;
// clearTimeout(motorIntervals[motorId]);
//
}
// }
} else {
} else {
throw new Error ( "Invalid action provided." ) ;
throw new Error ( "Invalid action provided." ) ;
@ -2512,8 +2503,115 @@ console.log(fcmToken)
} , 30000 ) ; // Check every minute
} , 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
// Respond with success message
reply . code ( 200 ) . send ( { message : ` Motor ${ action === "start" ? "started" : "stopped" } successfully. ` } ) ;
reply . code ( 200 ) . send ( { message : ` Motor ${ action === "start" ? "started" : "stopped" } successfully. ` } ) ;
@ -5243,3 +5341,73 @@ async function removeDuplicates () {
// Run the remove duplicates function
// Run the remove duplicates function
// removeDuplicates();
// removeDuplicates();
console . log ( "this is for testing autopush,line located in tankscontroller" ) console . log ( "this is for testing autopush,line located in tankscontroller" )
const calculateDailyConsumptionAndNotify = async ( ) => {
try {
const today = moment ( ) . startOf ( "day" ) ;
const yesterday = moment ( today ) . subtract ( 1 , "days" ) ;
// Fetch all active users
const activeUsers = await User . find ( { } ) ;
for ( const user of activeUsers ) {
const { customerId , fcmIds } = user ;
// Fetch daily consumption for the customer
const consumptions = await TankConsumptionOriginalSchema . find ( {
customerId ,
time : {
$gte : yesterday . format ( "DD-MMM-YYYY - HH:mm" ) ,
$lt : today . format ( "DD-MMM-YYYY - HH:mm" ) ,
} ,
} ) ;
// Calculate total consumption
const totalConsumption = consumptions . reduce ( ( total , record ) => {
return total + parseInt ( record . consumption , 10 ) ;
} , 0 ) ;
// Prepare tank-wise consumption details
const tankDetails = consumptions . map ( ( record ) => ( {
tankName : record . tankName ,
consumption : record . consumption ,
} ) ) ;
// Send notification
const notificationTitle = "Daily Water Consumption Report" ;
const notificationBody = `
Total Consumption : $ { totalConsumption } liters
Tank Details : $ { tankDetails
. map ( ( tank ) => ` ${ tank . tankName } : ${ tank . consumption } liters ` )
. join ( ", " ) }
` ;
if ( fcmIds && fcmIds . length > 0 ) {
await sendNotification ( fcmIds , notificationTitle , notificationBody ) ;
}
}
console . log ( "Daily consumption notifications sent successfully." ) ;
} catch ( err ) {
console . error ( "Error sending daily consumption notifications:" , err ) ;
}
} ;
// cron.schedule("0 11:57 * * *", async () => {
// console.log("Starting daily consumption notification task...");
// await calculateDailyConsumptionAndNotify();
// });
cron . schedule (
"0 9 * * *" ,
async ( ) => {
console . log ( "Starting daily consumption notification task..." ) ;
await calculateDailyConsumptionAndNotify ( ) ;
} ,
{
timezone : "Asia/Kolkata" , // Specify the timezone
}
) ;
