|
|
@ -932,7 +932,13 @@ exports.motorAction = async (req, reply) => {
|
|
|
|
const thresholdTime = moment().add(req.body.manual_threshold_time, 'minutes').toDate();
|
|
|
|
const thresholdTime = moment().add(req.body.manual_threshold_time, 'minutes').toDate();
|
|
|
|
const intervalId = setInterval(async () => {
|
|
|
|
const intervalId = setInterval(async () => {
|
|
|
|
// Check if threshold time has been reached
|
|
|
|
// Check if threshold time has been reached
|
|
|
|
if (new Date() >= thresholdTime) {
|
|
|
|
const splr_tank_info3 = await Tank.findOne({ customerId, tankName: req.body.from, tankLocation: req.body.from_type.toLowerCase() });
|
|
|
|
|
|
|
|
const splr_tank_info3_waterlevel = parseInt(supplier_tank_info.waterlevel, 10);
|
|
|
|
|
|
|
|
const splr_tank_info3_capacity = parseInt(supplier_tank_info.capacity, 10);
|
|
|
|
|
|
|
|
const splr_tank_info3_percentage = (splr_tank_info3_waterlevel / splr_tank_info3_capacity) * 100;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (new Date() >= thresholdTime || splr_tank_info3_percentage<=20) {
|
|
|
|
// Stop the motor pump
|
|
|
|
// Stop the motor pump
|
|
|
|
await Tank.updateOne(
|
|
|
|
await Tank.updateOne(
|
|
|
|
{ customerId, "connections.inputConnections.motor_id": motorId },
|
|
|
|
{ customerId, "connections.inputConnections.motor_id": motorId },
|
|
|
|