for null received from iot device

master
varun 1 year ago
parent 38d6d699a7
commit e961f3e1e4

@ -1154,17 +1154,13 @@ exports.IotDevice = async (req, reply) => {
} }
// Update waterlevel in tanksSchema for each tank // Update waterlevel in tanksSchema for each tank
for (const tank of tanks) { for (const tank of tanks) {
const { tankhardwareId, tankHeight } = tank; const { tankhardwareId, tankHeight } = tank;
// Skip if tankHeight is null or undefined
if (tankHeight === null || tankHeight === undefined) {
continue; // Skip this iteration and move to the next tank
}
// Find the corresponding tank in tanksSchema // Find the corresponding tank in tanksSchema
const existingTank = await Tank.findOne({ hardwareId, tankhardwareId }); const existingTank = await Tank.findOne({ hardwareId, tankhardwareId });
if (existingTank) { if (existingTank) {
// Update the waterlevel using the tankHeight value // Update the waterlevel using the tankHeight value
@ -1185,29 +1181,30 @@ for (const tank of tanks) {
console.log(tank_height); console.log(tank_height);
// console.log(tank_height,1) // console.log(tank_height,1)
const water_level_height = tank_height - tankHeight const water_level_height = tank_height - tankHeight
console.log(water_level_height, 2) console.log(water_level_height,2)
const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10) const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10)
console.log(waterCapacityPerCm, 3) console.log(waterCapacityPerCm,3)
const water_level = water_level_height * waterCapacityPerCm; const water_level = water_level_height * waterCapacityPerCm;
console.log(water_level, 4); console.log(water_level, 4);
// Function to add commas to a number // Function to add commas to a number
function numberWithCommas(x) { function numberWithCommas(x) {
return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); 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);
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 // Save the updated tank document
await existingTank.save(); await existingTank.save();
} }
} }
// Send the latest three documents // Send the latest three documents
const latestOttanks = await IotData.find({ hardwareId }) const latestOttanks = await IotData.find({ hardwareId })
@ -1220,7 +1217,6 @@ for (const tank of tanks) {
} }
}; };
// exports.getIotD = async(req, reply) => { // exports.getIotD = async(req, reply) => {
// try { // try {
// await IotData.find({hardwareId: req.query.hardwareId}) // await IotData.find({hardwareId: req.query.hardwareId})

Loading…
Cancel
Save