changes in connections

src/controllers/createConnectionController.js

@@ -548,35 +548,32 @@ exports.createConnections = async (req, body) => {
 
     const tank_connections = await tankInfo.save();
 
-    const connection_data_check = tank_connections.connections.inputConnections;
-    const sump_names = connection_data_check.map(d => d.inputConnections);
-    console.log(sump_names);
-
     const connection_data = usertobeInserted.outputConnections;
-    console.log(connection_data, "connection_data");
     for (const data of connection_data) {
       if (data['output_type'] === "overhead") {
         const tankName = data['outputConnections'];
 
-        if (sump_names.includes(tankname)) {
+        // Check if the current tank is already included in the inputConnections of any other tanks
-          console.log(`${tankname} exists in ${sump_names}`);
+        const tanksWithCurrentTankAsInput = await Tank.find({ 'connections.inputConnections.inputConnections': tankname });
-        } else {
+
-          const tankConnections = await Tank.findOneAndUpdate(
+        // If the current tank is not in the inputConnections of any other tank, add it
-            { customerId: customerId.toString(), tankName: tankName },
+        if (tanksWithCurrentTankAsInput.length === 0) {
+          // Loop through each tank to add the current tank as an inputConnection
+          for (const tank of tanksWithCurrentTankAsInput) {
+            await Tank.findOneAndUpdate(
+              { customerId: customerId.toString(), tankName: tank.tankName },
               {
                 $addToSet: {
                   'connections.inputConnections': {
-                  $each: [{ inputConnections: tankname, input_type: 'sump', inputismotor: data.outputismotor || false }],
+                    inputConnections: tankname,
-                },
+                    input_type: 'sump',
-                // 'connections.outputConnections': {
+                    inputismotor: data.outputismotor || false
-                //   $each: [{ outputConnections: tankname, output_type: 'overhead'}],
+                  }
-                // },
+                }
-              },
               },
               { new: true }
             );
-          console.log("tankConnections", tankConnections.connections.inputConnections);
+          }
-          console.log("tankConnections", tankConnections.connections.outputConnections);
         }
       }
     }
@@ -590,6 +587,7 @@ exports.createConnections = async (req, body) => {
 
 
 
+
 // exports.createConnections = async (req, body) => {
 //   try {
 //     const customerId = req.params.customerId;

src/controllers/tanksController.js

@@ -1252,106 +1252,7 @@ exports.calculateCapacity = async (req, reply) => {
 
 
 
-exports.IotDevice = async (req, reply) => { 
+// exports.IotDevice = 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(); 
-  } 
-  } 
-  
-  // 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.IotDevice2 = async (req, reply) => {
 //   try { 
 //   const { hardwareId, mode, tanks } = req.body; 
   
@@ -1436,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();
-//               }
-//             }
-//           }
-//         }
 //   } 
 //   } 
   
@@ -1465,6 +1351,120 @@ exports.IotDevice = async (req, reply) => {
 //   } 
 //   }; 
 
+exports.IotDevice = 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 {

src/routes/createConnectionsRoute.js

@@ -158,7 +158,7 @@ module.exports = function (fastify, opts, next) {
               },
           ],
       },
-      preHandler: fastify.auth([fastify.authenticate]),
+      //preHandler: fastify.auth([fastify.authenticate]),
       handler: createConnectionController.createConnections,
   });