From f7a6472f91709ae4e97fcf441d2be59a25797412 Mon Sep 17 00:00:00 2001 From: varun Date: Sat, 11 May 2024 02:54:05 -0400 Subject: [PATCH] change in iot --- src/controllers/tanksController.js | 457 ++++++++++++++++++----------- src/routes/tanksRoute.js | 2 +- 2 files changed, 279 insertions(+), 180 deletions(-) diff --git a/src/controllers/tanksController.js b/src/controllers/tanksController.js index 25965dd4..783719ee 100644 --- a/src/controllers/tanksController.js +++ b/src/controllers/tanksController.js @@ -1252,208 +1252,307 @@ exports.calculateCapacity = async (req, reply) => { -exports.IotDevice = async (req, reply) => { - try { - const { hardwareId, mode, tanks } = req.body; - - // create a new tank document with the current date and time - const currentDate = new Date(); - const date = currentDate.toISOString(); // save the date as an ISO string - const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' }); - - // Create an array of tank documents - const tankDocuments = tanks.map(tank => ({ - tankhardwareId: tank.tankhardwareId, - tankHeight: tank.tankHeight, - maxLevel: tank.maxLevel, - minLevel: tank.minLevel, - date: date, - time: time - })); - - // create a new IotData document with the provided data - const ottank = new IotData({ hardwareId, mode, tanks: tankDocuments, date, time }); - - // save the document to MongoDB - await ottank.save(); - - // Delete excess records (keep only the latest three records) - const recordsToKeep = 3; - const recordsToDelete = await IotData.find({ hardwareId }) - .sort({ date: -1, time: -1 }) - .skip(recordsToKeep); - - for (const record of recordsToDelete) { - await record.remove(); - } +exports.IotDevice = async (req, reply) => { + try { + const { hardwareId, mode, tanks } = req.body; + + // create a new tank document with the current date and time + const currentDate = new Date(); + const date = currentDate.toISOString(); // save the date as an ISO string + const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' }); + + // Create an array of tank documents + const tankDocuments = tanks.map(tank => ({ + tankhardwareId: tank.tankhardwareId, + tankHeight: tank.tankHeight, + maxLevel: tank.maxLevel, + minLevel: tank.minLevel, + date: date, + time: time + })); + + // create a new IotData document with the provided data + const ottank = new IotData({ hardwareId, mode, tanks: tankDocuments, date, time }); + + // save the document to MongoDB + await ottank.save(); + + // Delete excess records (keep only the latest three records) + const recordsToKeep = 3; + const recordsToDelete = await IotData.find({ hardwareId }) + .sort({ date: -1, time: -1 }) + .skip(recordsToKeep); + + for (const record of recordsToDelete) { + await record.remove(); + } + + // Update waterlevel in tanksSchema for each tank + for (const tank of tanks) { + const { tankhardwareId, tankHeight } = tank; + + // Find the corresponding tank in tanksSchema + const existingTank = await Tank.findOne({ hardwareId, tankhardwareId }); + + + if (existingTank) { + // Update the waterlevel using the tankHeight value + + const tank_height1 = (parseInt(existingTank.height.replace(/,/g, ''), 10)) * 30.48; + console.log(tank_height1, 25); + + // The value of tank_height1 is a number, not a string, so you cannot use replace on it. + // If you want to format it with commas, you can create a function to add commas to a number. + function numberWithCommas(x) { + return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); + } + + // Now you can use the function to format the tank_height1 value with commas. + const formatted_tank_height1 = numberWithCommas(tank_height1); + console.log(formatted_tank_height1, 25); + + const tank_height = parseInt(formatted_tank_height1.replace(/,/g, ''), 10); + console.log(tank_height); + // console.log(tank_height,1) + const water_level_height = tank_height - tankHeight + console.log(water_level_height,2) + + const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10) + console.log(waterCapacityPerCm,3) + const water_level = water_level_height * waterCapacityPerCm; + console.log(water_level, 4); + + // Function to add commas to a number + function numberWithCommas(x) { + return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); + } + + const formatted_water_level = numberWithCommas(water_level); + console.log(formatted_water_level, 4); + + existingTank.waterlevel = parseInt(formatted_water_level.replace(/,/g, ''), 10); + console.log(existingTank.waterlevel); + + + + // Save the updated tank document + await existingTank.save(); + } + } + + // Send the latest three documents + const latestOttanks = await IotData.find({ hardwareId }) + .sort({ date: -1, time: -1 }); + + reply.code(200).send({ latestOttanks }); + } catch (err) { + // send an error response + reply.code(500).send({ error: err.message }); + } + }; - // Update waterlevel in tanksSchema for each tank - for (const tank of tanks) { - const { tankhardwareId, tankHeight } = tank; +// exports.IotDevice2 = async (req, reply) => { +// try { +// const { hardwareId, mode, tanks } = req.body; - // Find the corresponding tank in tanksSchema - const existingTank = await Tank.findOne({ hardwareId, tankhardwareId }); +// // create a new tank document with the current date and time +// const currentDate = new Date(); +// const date = currentDate.toISOString(); // save the date as an ISO string +// const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' }); + +// // Create an array of tank documents +// const tankDocuments = tanks.map(tank => ({ +// tankhardwareId: tank.tankhardwareId, +// tankHeight: tank.tankHeight, +// maxLevel: tank.maxLevel, +// minLevel: tank.minLevel, +// date: date, +// time: time +// })); + +// // create a new IotData document with the provided data +// const ottank = new IotData({ hardwareId, mode, tanks: tankDocuments, date, time }); + +// // save the document to MongoDB +// await ottank.save(); + +// // Delete excess records (keep only the latest three records) +// const recordsToKeep = 3; +// const recordsToDelete = await IotData.find({ hardwareId }) +// .sort({ date: -1, time: -1 }) +// .skip(recordsToKeep); + +// for (const record of recordsToDelete) { +// await record.remove(); +// } + +// // Update waterlevel in tanksSchema for each tank +// for (const tank of tanks) { +// const { tankhardwareId, tankHeight } = tank; + +// // Find the corresponding tank in tanksSchema +// const existingTank = await Tank.findOne({ hardwareId, tankhardwareId }); - if (existingTank) { - // Update the waterlevel using the tankHeight value +// if (existingTank) { +// // Update the waterlevel using the tankHeight value - const tank_height1 = (parseInt(existingTank.height.replace(/,/g, ''), 10)) * 30.48; - console.log(tank_height1, 25); +// const tank_height1 = (parseInt(existingTank.height.replace(/,/g, ''), 10)) * 30.48; +// console.log(tank_height1, 25); - // The value of tank_height1 is a number, not a string, so you cannot use replace on it. - // If you want to format it with commas, you can create a function to add commas to a number. - function numberWithCommas(x) { - return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); - } +// // The value of tank_height1 is a number, not a string, so you cannot use replace on it. +// // If you want to format it with commas, you can create a function to add commas to a number. +// function numberWithCommas(x) { +// return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); +// } - // Now you can use the function to format the tank_height1 value with commas. - const formatted_tank_height1 = numberWithCommas(tank_height1); - console.log(formatted_tank_height1, 25); +// // Now you can use the function to format the tank_height1 value with commas. +// const formatted_tank_height1 = numberWithCommas(tank_height1); +// console.log(formatted_tank_height1, 25); - const tank_height = parseInt(formatted_tank_height1.replace(/,/g, ''), 10); - console.log(tank_height); - // console.log(tank_height,1) - const water_level_height = tank_height - tankHeight - console.log(water_level_height,2) +// const tank_height = parseInt(formatted_tank_height1.replace(/,/g, ''), 10); +// console.log(tank_height); +// // console.log(tank_height,1) +// const water_level_height = tank_height - tankHeight +// console.log(water_level_height,2) - const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10) - console.log(waterCapacityPerCm,3) - const water_level = water_level_height * waterCapacityPerCm; -console.log(water_level, 4); - -// Function to add commas to a number -function numberWithCommas(x) { - return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); -} +// const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10) +// console.log(waterCapacityPerCm,3) +// const water_level = water_level_height * waterCapacityPerCm; +// console.log(water_level, 4); + +// // Function to add commas to a number +// function numberWithCommas(x) { +// return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); +// } -const formatted_water_level = numberWithCommas(water_level); -console.log(formatted_water_level, 4); +// const formatted_water_level = numberWithCommas(water_level); +// console.log(formatted_water_level, 4); -existingTank.waterlevel = parseInt(formatted_water_level.replace(/,/g, ''), 10); -console.log(existingTank.waterlevel); +// existingTank.waterlevel = parseInt(formatted_water_level.replace(/,/g, ''), 10); +// console.log(existingTank.waterlevel); - // Save the updated tank document - await existingTank.save(); - for (const outputConnection of existingTank.connections.outputConnections) { - const linkedTank = await Tank.findOne({ customerId: customerId, tankName: outputConnection.outputConnections, tankLocation: outputConnection.output_type }); - if (linkedTank) { - // linkedTank.waterlevel = existingTank.waterlevel; - //await linkedTank.save(); +// // Save the updated tank document +// await existingTank.save(); +// for (const outputConnection of existingTank.connections.outputConnections) { +// const linkedTank = await Tank.findOne({ customerId: customerId, tankName: outputConnection.outputConnections, tankLocation: outputConnection.output_type }); +// if (linkedTank) { +// // linkedTank.waterlevel = existingTank.waterlevel; +// //await linkedTank.save(); - // Update water level of tanks linked through input connections of the linked tank - for (const inputConnection of linkedTank.connections.inputConnections) { - if (inputConnection.inputConnections === tank_name) { - inputConnection.water_level = water_level.toString(); - await linkedTank.save(); - } - } - } - } - } - } +// // Update water level of tanks linked through input connections of the linked tank +// for (const inputConnection of linkedTank.connections.inputConnections) { +// if (inputConnection.inputConnections === tank_name) { +// inputConnection.water_level = water_level.toString(); +// await linkedTank.save(); +// } +// } +// } +// } +// } +// } - // Send the latest three documents - const latestOttanks = await IotData.find({ hardwareId }) - .sort({ date: -1, time: -1 }); +// // Send the latest three documents +// const latestOttanks = await IotData.find({ hardwareId }) +// .sort({ date: -1, time: -1 }); - reply.code(200).send({ latestOttanks }); - } catch (err) { - // send an error response - reply.code(500).send({ error: err.message }); - } -}; +// reply.code(200).send({ latestOttanks }); +// } catch (err) { +// // send an error response +// reply.code(500).send({ error: err.message }); +// } +// }; -exports.IotDevice1 = async (req, reply) => { - try { - const { hardwareId, mode, tanks } = req.body; - - // create a new tank document with the current date and time - const currentDate = new Date(); - const date = currentDate.toISOString(); // save the date as an ISO string - const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' }); - - // Create an array of tank documents - const tankDocuments = tanks.map(tank => ({ - tankhardwareId: tank.tankhardwareId, - tankHeight: tank.tankHeight, - maxLevel: tank.maxLevel, - minLevel: tank.minLevel, - date: date, - time: time - })); - - // create a new IotData document with the provided data - const ottank = new IotData({ hardwareId, mode, tanks: tankDocuments, date, time }); - - // save the document to MongoDB - await ottank.save(); - - // Delete excess records (keep only the latest three records) - const recordsToKeep = 3; - const recordsToDelete = await IotData.find({ hardwareId }) - .sort({ date: -1, time: -1 }) - .skip(recordsToKeep); - - for (const record of recordsToDelete) { - await record.remove(); - } +// exports.IotDevice1 = async (req, reply) => { +// try { +// const { hardwareId, mode, tanks } = req.body; - // Update waterlevel in tanksSchema for each tank - for (const tank of tanks) { - const { tankhardwareId, tankHeight } = tank; - - if (tankHeight === null || tankHeight === undefined) { - continue; // Skip this iteration and move to the next tank - } - // Find the corresponding tank in tanksSchema - const existingTank = await Tank.findOne({ hardwareId, tankhardwareId }); +// // create a new tank document with the current date and time +// const currentDate = new Date(); +// const date = currentDate.toISOString(); // save the date as an ISO string +// const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' }); + +// // Create an array of tank documents +// const tankDocuments = tanks.map(tank => ({ +// tankhardwareId: tank.tankhardwareId, +// tankHeight: tank.tankHeight, +// maxLevel: tank.maxLevel, +// minLevel: tank.minLevel, +// date: date, +// time: time +// })); + +// // create a new IotData document with the provided data +// const ottank = new IotData({ hardwareId, mode, tanks: tankDocuments, date, time }); + +// // save the document to MongoDB +// await ottank.save(); + +// // Delete excess records (keep only the latest three records) +// const recordsToKeep = 3; +// const recordsToDelete = await IotData.find({ hardwareId }) +// .sort({ date: -1, time: -1 }) +// .skip(recordsToKeep); + +// for (const record of recordsToDelete) { +// await record.remove(); +// } + +// // Update waterlevel in tanksSchema for each tank +// for (const tank of tanks) { +// const { tankhardwareId, tankHeight } = tank; + +// if (tankHeight === null || tankHeight === undefined) { +// continue; // Skip this iteration and move to the next tank +// } +// // Find the corresponding tank in tanksSchema +// const existingTank = await Tank.findOne({ hardwareId, tankhardwareId }); - if (existingTank) { - // Update the waterlevel using the tankHeight value - const tank_height = parseInt(existingTank.height.replace(/,/g, ''), 10) * 30.48; - const water_level_height = tank_height - tankHeight; - const customerId = existingTank.customerId; - const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10); - let water_level = water_level_height * waterCapacityPerCm; - water_level = Math.round(water_level); // Round to nearest whole number - existingTank.waterlevel = water_level.toString(); // Convert to string as per schema definition - const tank_name = existingTank.tankName; - // Save the updated tank document - await existingTank.save(); - - // Update water level of tanks linked through output connections - for (const outputConnection of existingTank.connections.outputConnections) { - const linkedTank = await Tank.findOne({ customerId: customerId, tankName: outputConnection.outputConnections, tankLocation: outputConnection.output_type }); - if (linkedTank) { - // linkedTank.waterlevel = existingTank.waterlevel; - //await linkedTank.save(); - - // Update water level of tanks linked through input connections of the linked tank - for (const inputConnection of linkedTank.connections.inputConnections) { - if (inputConnection.inputConnections === tank_name) { - inputConnection.water_level = water_level.toString(); - await linkedTank.save(); - } - } - } - } - } - } +// if (existingTank) { +// // Update the waterlevel using the tankHeight value +// const tank_height = parseInt(existingTank.height.replace(/,/g, ''), 10) * 30.48; +// const water_level_height = tank_height - tankHeight; +// const customerId = existingTank.customerId; +// const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10); +// let water_level = water_level_height * waterCapacityPerCm; +// water_level = Math.round(water_level); // Round to nearest whole number +// existingTank.waterlevel = water_level.toString(); // Convert to string as per schema definition +// const tank_name = existingTank.tankName; +// // Save the updated tank document +// await existingTank.save(); + +// // Update water level of tanks linked through output connections +// for (const outputConnection of existingTank.connections.outputConnections) { +// const linkedTank = await Tank.findOne({ customerId: customerId, tankName: outputConnection.outputConnections, tankLocation: outputConnection.output_type }); +// if (linkedTank) { +// // linkedTank.waterlevel = existingTank.waterlevel; +// //await linkedTank.save(); + +// // Update water level of tanks linked through input connections of the linked tank +// for (const inputConnection of linkedTank.connections.inputConnections) { +// if (inputConnection.inputConnections === tank_name) { +// inputConnection.water_level = water_level.toString(); +// await linkedTank.save(); +// } +// } +// } +// } +// } +// } - // Send the latest three documents - const latestOttanks = await IotData.find({ hardwareId }) - .sort({ date: -1, time: -1 }); +// // Send the latest three documents +// const latestOttanks = await IotData.find({ hardwareId }) +// .sort({ date: -1, time: -1 }); - reply.code(200).send({ latestOttanks }); - } catch (err) { - // send an error response - reply.code(500).send({ error: err.message }); - } -}; +// reply.code(200).send({ latestOttanks }); +// } catch (err) { +// // send an error response +// reply.code(500).send({ error: err.message }); +// } +// }; diff --git a/src/routes/tanksRoute.js b/src/routes/tanksRoute.js index 259cb827..ef8c5190 100644 --- a/src/routes/tanksRoute.js +++ b/src/routes/tanksRoute.js @@ -191,7 +191,7 @@ module.exports = function (fastify, opts, next) { }, ], }, - preHandler: fastify.auth([fastify.authenticate]), + // preHandler: fastify.auth([fastify.authenticate]), handler: tanksController.getTank, });