change in motoraction

src/controllers/tanksController.js

@@ -883,7 +883,7 @@ exports.motorAction = async (req, reply) => {
     if (action === "stop") {
       await Tank.updateOne(
         { customerId, "connections.inputConnections.motor_id": motorId },
-        { $set: { "connections.inputConnections.$.motor_stop_status": "1",real_motor_status:"4" } }
+        { $set: { "connections.inputConnections.$.motor_stop_status": "1" } }
       );
     } else {
       // Update the motor stop status to "2" for start action
@@ -899,7 +899,7 @@ exports.motorAction = async (req, reply) => {
         // If threshold type is time, update threshold time
         await Tank.updateOne(
           { customerId, "connections.inputConnections.motor_id": motorId },
-          { $set: { "connections.inputConnections.$.manual_threshold_time": req.body.manual_threshold_time,startTime:req.body.startTime ,real_motor_status:"3"} }
+          { $set: { "connections.inputConnections.$.manual_threshold_time": req.body.manual_threshold_time,startTime:req.body.startTime } }
         );
 
         // Start monitoring water level based on threshold time
@@ -910,7 +910,7 @@ exports.motorAction = async (req, reply) => {
             // Stop the motor pump
             await Tank.updateOne(
               { customerId, "connections.inputConnections.motor_id": motorId },
-              { $set: { "connections.inputConnections.$.motor_stop_status": "1",manual_threshold_time:null,real_motor_status:"4" } }
+              { $set: { "connections.inputConnections.$.motor_stop_status": "1",manual_threshold_time:null } }
             );
             clearInterval(intervalId); // Stop monitoring water level
           }
@@ -929,7 +929,7 @@ exports.motorAction = async (req, reply) => {
         // Update water level threshold
         await Tank.updateOne(
           { customerId, "connections.inputConnections.motor_id": motorId },
-          { $set: { "connections.inputConnections.$.manual_threshold_percentage": threshold_water_level.toString(),real_motor_status:"3" } }
+          { $set: { "connections.inputConnections.$.manual_threshold_percentage": threshold_water_level.toString() } }
         );
 
         // Start monitoring water level based on threshold percentage
@@ -940,7 +940,7 @@ exports.motorAction = async (req, reply) => {
             // Stop the motor pump
             await Tank.updateOne(
               { customerId, "connections.inputConnections.motor_id": motorId },
-              { $set: { "connections.inputConnections.$.motor_stop_status": "1",manual_threshold_percentage:null,real_motor_status:"4" } }
+              { $set: { "connections.inputConnections.$.motor_stop_status": "1",manual_threshold_percentage:null} }
             );
             clearInterval(intervalId); // Stop monitoring water level
           }
@@ -1252,7 +1252,6 @@ exports.calculateCapacity = async (req, reply) => {
 // };
 
 
-
 exports.IotDevice = async (req, reply) => {
   try {
     const { hardwareId, mode, tanks } = req.body;
@@ -1291,7 +1290,7 @@ exports.IotDevice = async (req, reply) => {
     // Update waterlevel in tanksSchema for each tank
     for (const tank of tanks) {
       const { tankhardwareId, tankHeight } = tank;
-  
+      console.log(tankhardwareId)
       // Find the corresponding tank in tanksSchema
       const existingTank = await Tank.findOne({ hardwareId, tankhardwareId });
       
@@ -1338,21 +1337,6 @@ exports.IotDevice = async (req, reply) => {
 
         // Save the updated tank document
         await existingTank.save();
-for (const outputConnection of existingTank.connections.outputConnections) {
-  const linkedTank = await Tank.findOne({ customerId: customerId, tankName: outputConnection.outputConnections, tankLocation: outputConnection.output_type });
-  if (linkedTank) {
-   // linkedTank.waterlevel = existingTank.waterlevel;
-    //await linkedTank.save();
-
-    // Update water level of tanks linked through input connections of the linked tank
-    for (const inputConnection of linkedTank.connections.inputConnections) {
-      if (inputConnection.inputConnections === tank_name) {
-        inputConnection.water_level = water_level.toString();
-        await linkedTank.save();
-      }
-    }
-  }
-} 
       }
     }
 
@@ -1367,6 +1351,126 @@ for (const outputConnection of existingTank.connections.outputConnections) {
   }
 };
 
+
+
+
+
+
+
+// exports.IotDevice3 = async (req, reply) => { 
+//   try { 
+//   const { hardwareId, mode, tanks } = req.body; 
+  
+//   // create a new tank document with the current date and time 
+//   const currentDate = new Date(); 
+//   const date = currentDate.toISOString(); // save the date as an ISO string 
+//   const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' }); 
+  
+//   // Create an array of tank documents 
+//   const tankDocuments = tanks.map(tank => ({ 
+//   tankhardwareId: tank.tankhardwareId, 
+//   tankHeight: tank.tankHeight, 
+//   maxLevel: tank.maxLevel, 
+//   minLevel: tank.minLevel, 
+//   date: date, 
+//   time: time 
+//   })); 
+  
+//   // create a new IotData document with the provided data 
+//   const ottank = new IotData({ hardwareId, mode, tanks: tankDocuments, date, time }); 
+  
+//   // save the document to MongoDB 
+//   await ottank.save(); 
+  
+//   // Delete excess records (keep only the latest three records) 
+//   const recordsToKeep = 3; 
+//   const recordsToDelete = await IotData.find({ hardwareId }) 
+//   .sort({ date: -1, time: -1 }) 
+//   .skip(recordsToKeep); 
+  
+//   for (const record of recordsToDelete) { 
+//   await record.remove(); 
+//   } 
+  
+//   // Update waterlevel in tanksSchema for each tank 
+//   for (const tank of tanks) { 
+//   const { tankhardwareId, tankHeight } = tank; 
+  
+//   // Find the corresponding tank in tanksSchema 
+//   const existingTank = await Tank.findOne({ hardwareId, tankhardwareId }); 
+  
+  
+//   if (existingTank) { 
+//   // Update the waterlevel using the tankHeight value 
+  
+//   const tank_height1 = (parseInt(existingTank.height.replace(/,/g, ''), 10)) * 30.48; 
+//   console.log(tank_height1, 25); 
+  
+//   // The value of tank_height1 is a number, not a string, so you cannot use replace on it. 
+//   // If you want to format it with commas, you can create a function to add commas to a number. 
+//   function numberWithCommas(x) { 
+//   return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); 
+//   } 
+  
+//   // Now you can use the function to format the tank_height1 value with commas. 
+//   const formatted_tank_height1 = numberWithCommas(tank_height1); 
+//   console.log(formatted_tank_height1, 25); 
+  
+//   const tank_height = parseInt(formatted_tank_height1.replace(/,/g, ''), 10); 
+//   console.log(tank_height); 
+//   // console.log(tank_height,1) 
+//   const water_level_height = tank_height - tankHeight 
+//   console.log(water_level_height,2) 
+  
+//   const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10) 
+//   console.log(waterCapacityPerCm,3) 
+//   const water_level = water_level_height * waterCapacityPerCm; 
+//   console.log(water_level, 4); 
+  
+//   // Function to add commas to a number 
+//   function numberWithCommas(x) { 
+//   return x.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ","); 
+//   } 
+  
+//   const formatted_water_level = numberWithCommas(water_level); 
+//   console.log(formatted_water_level, 4); 
+  
+//   existingTank.waterlevel = parseInt(formatted_water_level.replace(/,/g, ''), 10); 
+//   console.log(existingTank.waterlevel); 
+  
+  
+  
+//   // Save the updated tank document 
+//   await existingTank.save();
+// for (const outputConnection of existingTank.connections.outputConnections) {
+//   const linkedTank = await Tank.findOne({ customerId: customerId, tankName: outputConnection.outputConnections, tankLocation: outputConnection.output_type });
+//   if (linkedTank) {
+//    // linkedTank.waterlevel = existingTank.waterlevel;
+//     //await linkedTank.save();
+
+//     // Update water level of tanks linked through input connections of the linked tank
+//     for (const inputConnection of linkedTank.connections.inputConnections) {
+//       if (inputConnection.inputConnections === tank_name) {
+//         inputConnection.water_level = water_level.toString();
+//         await linkedTank.save();
+//       }
+//     }
+//   }
+// } 
+//   } 
+//   } 
+  
+//   // Send the latest three documents 
+//   const latestOttanks = await IotData.find({ hardwareId }) 
+//   .sort({ date: -1, time: -1 }); 
+  
+//   reply.code(200).send({ latestOttanks }); 
+//   } catch (err) { 
+//   // send an error response 
+//   reply.code(500).send({ error: err.message }); 
+//   } 
+//   }; 
+
 // exports.IotDevice1 = async (req, reply) => {
 //   try {
 //     const { hardwareId, mode, tanks } = req.body;
@@ -1940,11 +2044,7 @@ exports.writeMotorStatus = async (req, reply) => {
     
     // Update the motor_status of the inputConnection
     inputConnection.motor_status = status;
-    if (status === "1" && inputConnection.real_motor_status === "4") {
+     
-             inputConnection.real_motor_status = 1;
-           } else if (status === "2" && inputConnection.real_motor_status === "3") {
-             inputConnection.real_motor_status = 2;
-         }
 
     // Save the updated tank
     await tank.save();
@@ -1981,12 +2081,7 @@ exports.writeMotorStatus = async (req, reply) => {
 //     inputConnection.motor_status = status;
 
 //     // Update real_motor_status based on the conditions
-//     if (status === "1" && inputConnection.real_motor_status === "4") {
+//    
-//       inputConnection.real_motor_status = 1;
-//     } else if (status === "2" && inputConnection.real_motor_status === "3") {
-//       inputConnection.real_motor_status = 2;
-//     }
-
 //     // Save the updated tank
 //     await tank.save();