made changes in tanks controller

master
varun 3 years ago
parent 2b871d1114
commit af6892f8b1

@ -141,40 +141,52 @@ exports.getTank = async (req, reply) => {
// }
//};
exports.updateTanklevels = async (req, reply) => {
try {
const customerId = req.params.customerId;
const tank = await Tank.find({customerId});
for (var i=0; i < tank.length; i++) {
try {
const customerId = req.params.customerId;
const tank = await Tank.find({customerId});
for (var i=0; i < tank.length; i++) {
const tankname = tank[i].tankName
const capacity = (tank[i].capacity).replace(/,/g, "")
console.log(capacity)
//console.log(capacity)
let Number = capacity-100 //Math.floor(Math.random() * capacity)
//console.log(Number)
setInterval(async function () {
// const randomNumber = Math.floor(Math.random() * capacity)
//const randomNumber = Math.floor(Math.random() * (5500 - 1000) + 1000);E
// console.log(randomNumber)
//const randomNumber = Math.floor(Math.random() * (5500 - 1000) + 1000);
//console.log(tankname)
const randomNumber = Math.floor(Number/1.5)
const data = await Tank.findOneAndUpdate({ customerId: customerId, tankName: tankname }, { $set: { waterlevel: randomNumber } });
const tank_info =await Tank.findOneAndUpdate({customerId:customerId,tankName:tankname},{$set:{waterlevel:randomNumber}})
console.log(tank_info)
Number = randomNumber
// return Number
//return Number
}, 2000);
}
return { message: 'Water level will be updated every 2 seconds' };
}
catch (err) {
throw boom.boomify(err);
return { message: 'Water level will be updated every 2 seconds' };
}
};
catch (err) {
throw boom.boomify(err);
}
};
exports.getTanklevels = async (req, reply) => {

@ -143,7 +143,7 @@ module.exports = function (fastify, opts, next) {
});
fastify.route({
method: "GET",
method: "PUT",
url: "/api/updateTanklevels/:customerId",
schema: {
tags: ["Tank"],

Loading…
Cancel
Save