made changes in tanks controller

master
varun 2 years ago
parent a7a6fc7868
commit f835314efa

@ -160,10 +160,11 @@ exports.updateTanklevels = async (req, reply) => {
const tankId = tank._id;
const tank_name = tank.tankName
let capacity = parseInt(tank.capacity.replace(/,/g, ''), 10);
let waterLevel = parseInt(tank.waterlevel.replace(/,/g, ''), 10);
// let waterLevel = parseInt(tank.waterlevel.replace(/,/g, ''), 10);
const intervalId = setInterval(async function () {
const newWaterLevel = Math.floor(waterLevel - 200);
let waterLevel = parseInt(tank.waterlevel.replace(/,/g, ''), 10);
const newWaterLevel = Math.floor(waterLevel - 200);
if (newWaterLevel <= 0) {
clearInterval(intervals[tankId]);
@ -201,33 +202,22 @@ exports.getTanklevels = async (req, reply) => {
try {
const customerId = req.params.customerId;
const updated_data = await Tank.find({ customerId: customerId });
reply.send({ status_code: 200, data: updated_data});
let sumSumpDrinkingWater = 0;
let sumOverheadDrinkingWater = 0;
updated_data.forEach((tank) => {
if (tank.tankLocation === 'sump' && tank.typeOfWater === 'Drinking Water') {
sumSumpDrinkingWater += parseInt(tank.waterlevel);
} else if (tank.tankLocation === 'overhead' && tank.typeOfWater === 'Drinking Water') {
sumOverheadDrinkingWater += parseInt(tank.waterlevel);
}
});
reply.send({
status_code: 200,
data: updated_data,
totalDrinkingWaterInSump: sumSumpDrinkingWater,
totalDrinkingWaterInOverhead: sumOverheadDrinkingWater
});
return { message: 'success' };
}
return { message: 'success' };
} catch (err) {
catch (err) {
throw boom.boomify(err);
}
};
exports.motorAction = async (req, reply) => {
try {
//let start_time,stop_time

Loading…
Cancel
Save