Merge branch 'master' of http://35.207.205.18:3000/Arminta/watermanagement-backend

src/controllers/tanksController.js

@@ -252,6 +252,8 @@ exports.getTanklevels = async (req, reply) => {
 const intervals = {};
 let sum_oh_count = 0
 let bore_sump_count = 0
+let sump_sump_count = 0
+
 exports.motorAction = async (req, reply) => {
   try {
     //let start_time,stop_time
@@ -411,6 +413,7 @@ exports.motorAction = async (req, reply) => {
           connection.motor_status = "1";
           await sumpTank.save();
         }
+        sump_sump_count++;
 
        // console.log(receiver_capacity,"0",receiver_tank_info.tankName)
         await Tank.findOneAndUpdate({customerId, tankName: receiver_tank,tankLocation:receiver_type}, { $set: { motor_status: "1" } });
@@ -431,11 +434,10 @@ exports.motorAction = async (req, reply) => {
  
           clearInterval(intervals[interval_variable]); // Clear the interval for this tank
           delete intervals[interval_variable]; 
-         
-        
+          sump_sump_count--;
+           if (sump_sump_count===0){
             await Tank.findOneAndUpdate({customerId, tankName: receiver_tank,tankLocation:receiver_type}, { $set: { motor_status: "0" } });
-
-    
+                                     }
 
           console.log("end for" + receiver_tank);
         } else {
@@ -567,7 +569,11 @@ exports.motorAction = async (req, reply) => {
     delete intervals[interval_variable]; 
     if (supplier_tank_type === "sump" && receiver_type ==="sump"){
 
+      sump_sump_count--;
+           if (sump_sump_count===0){
             await Tank.findOneAndUpdate({customerId, tankName: receiver_tank,tankLocation:receiver_type}, { $set: { motor_status: "0" } });
+                                     }
+      
 
       
     }