diff --git a/src/controllers/tanksController.js b/src/controllers/tanksController.js
index e9fd7f8f..2daefeea 100644
--- a/src/controllers/tanksController.js
+++ b/src/controllers/tanksController.js
@@ -5986,86 +5986,113 @@ async function processIotData(hw_Id, data) {
   try {
     const { Motor_status, tanks } = data.objects;
     console.log(`📡 Processing data for hw_Id: ${hw_Id}`);
-
     const currentDate = new Date();
-    const date = currentDate.toISOString();
-    const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' });
-
-    const tankDocuments = tanks.map(tank => ({
-      tankhardwareId: tank.Id,
-      tankHeight: tank.level,
-      date,
-      time
-    }));
-
-    const iotTankData = new IotData({
-      hardwareId: hw_Id,
-      Motor_status,
-      tanks: tankDocuments,
-      date,
-      time
-    });
-    await iotTankData.save();
-
-    const recordsToKeep = 3;
-    const recordsToDelete = await IotData.find({ hardwareId: hw_Id })
-      .sort({ date: -1, time: -1 })
-      .skip(recordsToKeep);
+      const date = currentDate.toISOString(); // ISO string for date
+      const time = currentDate.toLocaleTimeString('en-IN', { hour12: false, timeZone: 'Asia/Kolkata' }); // Time in 'HH:MM:SS'
 
-    for (const record of recordsToDelete) {
-      await record.remove();
-    }
+      // Create array of tank documents with current date and time
+      const tankDocuments = tanks.map(tank => ({
+        tankhardwareId: tank.Id, // Updated to match the new format
+        tankHeight: tank.level,   // Updated to match the new format
+        date,
+        time
+      }));
 
-    for (const tank of tanks) {
-      const { Id: tankhardwareId, level: tankHeight } = tank;
-      const existingTank = await Tank.findOne({ hardwareId: hw_Id, tankhardwareId });
-      if (!existingTank) continue;
-
-      const customerId = existingTank.customerId;
-      const tank_name = existingTank.tankName;
+      
 
-      const tankHeightInCm = (parseInt(existingTank.height.replace(/,/g, ''), 10)) * 30.48;
-      const tank_height = parseInt(tankHeightInCm.toFixed(0), 10);
-      const waterLevelHeight = tank_height - tankHeight;
-      const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10);
+      // Save IoT data for the received tanks
+      const iotTankData = new IotData({
+        hardwareId: hw_Id,       // Updated variable name
+        Motor_status,
+        tanks: tankDocuments,
+        date,
+        time
+      });
+      await iotTankData.save();
 
-      const waterLevel = parseInt(waterLevelHeight * waterCapacityPerCm, 10);
+      // Delete excess records (keep only the latest three records)
+      const recordsToKeep = 3;
+      const recordsToDelete = await IotData.find({ hardwareId: hw_Id }) // Updated variable name
+        .sort({ date: -1, time: -1 })
+        .skip(recordsToKeep);
 
-      if (tankHeight > 0 && waterLevel >= 0) {
-        existingTank.waterlevel = waterLevel;
-        await existingTank.save();
+      for (const record of recordsToDelete) {
+        await record.remove();
       }
-    }
 
-    const status = Motor_status;
-    const motorTank = await Tank.findOne({ "connections.inputConnections.motor_id": hw_Id });
+      // Process each tank to update water level and connections
+      for (const tank of tanks) {
+        const { Id: tankhardwareId, level: tankHeight } = tank; // Updated to match the new format
+        // Find the corresponding tank in the Tank schema using hardwareId and tankhardwareId
+        const existingTank = await Tank.findOne({ hardwareId: hw_Id, tankhardwareId }); // Updated variable name
+        if (!existingTank) continue;
+
+        const customerId = existingTank.customerId;
+        const tank_name = existingTank.tankName;
+
+        // Calculate water level using tank height and capacity
+        const tankHeightInCm = (parseInt(existingTank.height.replace(/,/g, ''), 10)) * 30.48; // Convert height to cm
+        const tank_height = parseInt(tankHeightInCm.toFixed(0), 10);
+        const waterLevelHeight = tank_height - tankHeight;
+        const waterCapacityPerCm = parseInt(existingTank.waterCapacityPerCm.replace(/,/g, ''), 10);
+
+        const waterLevel = parseInt(waterLevelHeight * waterCapacityPerCm, 10); // Calculated water level
+
+        // Update water level in the existing tank
+        console.log(tankHeight,"this is located in tank controllers at iot-data mqtt sub ")
+        if (tankHeight>0 && waterLevel >= 0) {
+          existingTank.waterlevel = waterLevel;
+          await existingTank.save();
+
+          // Update linked tanks (input/output connections)
+          for (const outputConnection of existingTank.connections.outputConnections) {
+            const linkedTank = await Tank.findOne({ customerId, tankName: outputConnection.outputConnections, tankLocation: outputConnection.output_type });
+            if (linkedTank) {
+              for (const inputConnection of linkedTank.connections.inputConnections) {
+                if (inputConnection.inputConnections === tank_name) {
+                  inputConnection.water_level = waterLevel; // Update water level for linked tank
+                  await linkedTank.save(); // Save updated linked tank
+                }
+              }
+            }
+          }
+        }
+      }
 
-    if (!motorTank) {
-      console.log('Motor not found for the specified motor_id');
-      return;
-    }
+      // Update motor status
+      const status = Motor_status;
+      const motorTank = await Tank.findOne({ "connections.inputConnections.motor_id": hw_Id }); // Updated variable name
 
-    const inputConnection = motorTank.connections.inputConnections.find(conn => conn.motor_id === hw_Id);
-    if (inputConnection) {
-      inputConnection.motor_status = status;
-      if (inputConnection.motor_stop_status === "1" && status === 2 && inputConnection.motor_on_type !== "forced_manual") {
-        const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm');
-        inputConnection.motor_stop_status = "2";
-        inputConnection.motor_on_type = "forced_manual";
-        inputConnection.startTime = currentTime;
+      if (!motorTank) {
+        console.log('Motor not found for the specified motor_id');
+        return;
       }
 
-      if (inputConnection.motor_stop_status === "2" && status === 1) {
-        const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm');
-        inputConnection.motor_stop_status = "1";
-        inputConnection.stopTime = currentTime; 
+      // Find the inputConnection for the motor and update motor status
+      const inputConnection = motorTank.connections.inputConnections.find(conn => conn.motor_id === hw_Id); // Updated variable name
+      if (inputConnection) {
+        inputConnection.motor_status = status; // Update motor status
+        if (inputConnection.motor_stop_status === "1" && status === 2 && inputConnection.motor_on_type !== "forced_manual") {
+          const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm'); 
+          inputConnection.motor_stop_status = "2";
+          inputConnection.motor_on_type = "forced_manual";
+          inputConnection.startTime = currentTime;
+        }
+        
+        if (inputConnection.motor_stop_status === "2" && status === 1) {
+          const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm'); 
+          inputConnection.motor_stop_status = "1";
+          inputConnection.motor_on_type = "manual";
+          inputConnection.stopTime = currentTime;
+        }
+        
+        await motorTank.save(); // Save the updated tank
       }
 
-      await motorTank.save();
-    }
+      console.log('Data processed successfully for hardwareId:', hw_Id); // Updated variable name
 
-    console.log('✅ Data processed successfully for hardwareId:', hw_Id);
-  } catch (err) {
+
+    } catch (err) {
     console.error('❌ Error processing IoT data:', err.message);
   }
 }