diff --git a/src/controllers/tanksController.js b/src/controllers/tanksController.js index ec8bb0ca..fa621e6d 100644 --- a/src/controllers/tanksController.js +++ b/src/controllers/tanksController.js @@ -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}); + + try { + const customerId = req.params.customerId; + const tank = await Tank.find({customerId}); + - for (var i=0; i < tank.length; i++) { + 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) => { diff --git a/src/routes/tanksRoute.js b/src/routes/tanksRoute.js index 8fbdc87d..c5493165 100644 --- a/src/routes/tanksRoute.js +++ b/src/routes/tanksRoute.js @@ -143,7 +143,7 @@ module.exports = function (fastify, opts, next) { }); fastify.route({ - method: "GET", + method: "PUT", url: "/api/updateTanklevels/:customerId", schema: { tags: ["Tank"],