diff --git a/src/controllers/installationController.js b/src/controllers/installationController.js index e1674213..5a2ade4f 100644 --- a/src/controllers/installationController.js +++ b/src/controllers/installationController.js @@ -1298,103 +1298,195 @@ exports.getMasterSlaveSummary = async (req, reply) => { // }; +// exports.getIotDataByCustomer = async (req, reply) => { +// try { +// const { customerId } = req.params; + +// if (!customerId) { +// return reply.code(400).send({ error: "customerId is required" }); +// } + +// // Fetch all sensors for the customer +// const sensors = await Insensors.find({ customerId }); + +// if (!sensors || sensors.length === 0) { +// return reply.code(404).send({ message: "No sensors found for this customer." }); +// } + +// // Extract unique hardwareIds that are connected to sensors +// const hardwareIds = [ +// ...new Set( +// sensors.map(sensor => sensor.connected_to?.trim()).filter(Boolean) +// ) +// ]; + +// if (hardwareIds.length === 0) { +// return reply.send({ status_code: 200, message: "No connected hardwareIds found", data: [] }); +// } + +// // Fetch the latest IoT data and enrich it with sensor details +// const latestDataPromises = hardwareIds.map(async hardwareId => { +// // Fetch the latest IoT data for this hardwareId +// const latestRecord = await IotData.findOne({ hardwareId }) +// .sort({ date: -1 }) // Sorting to get the latest record based on the date +// .lean(); + +// // If no IoT data is found for this hardwareId, return a placeholder +// if (!latestRecord) { +// return { +// hardwareId, +// message: "No IoT data found", +// tanks: [] +// }; +// } + +// // Find sensors related to this hardwareId +// const relatedSensors = sensors.filter(sensor => sensor.connected_to?.trim() === hardwareId); + +// // Check if this hardwareId is "disconnected" in Insensors (based on your logic, e.g., isConnected=false) +// const isDisconnected = relatedSensors.some(sensor => sensor.isConnected === false); // You can adjust this check based on your schema. + +// // Default message for GSM connection status +// let message = isDisconnected ? "GSM is disconnected" : "GSM is not connected"; + +// // If any tank data has height > 0, assume GSM is connected, overriding the disconnected state +// if (latestRecord?.tanks?.some(tank => parseFloat(tank.tankHeight || 0) > 0)) { +// message = "GSM is connected"; +// } + +// // Enrich each tank with the IoT data +// const tanksStatus = relatedSensors.map(sensor => { +// const tankhardwareId = sensor.hardwareId?.trim(); +// const matchedTank = latestRecord?.tanks?.find( +// tank => tank.tankhardwareId === tankhardwareId +// ); + +// // Check if LoRa is connected based on the tankHeight +// const loraMessage = +// matchedTank && parseFloat(matchedTank.tankHeight || 0) > 0 +// ? "LORA is connected" +// : "LORA is not connected"; + +// return { +// tankhardwareId, +// tankName: sensor.tankName ?? null, +// tankLocation: sensor.tankLocation ?? null, +// masterName: sensor.masterName ?? null, +// location: sensor.location ?? null, +// loraMessage, +// latestTankData: matchedTank || null +// }; +// }); + +// return { +// hardwareId, +// message, +// masterName: relatedSensors[0]?.masterName ?? null, +// location: relatedSensors[0]?.location ?? null, +// tanks: tanksStatus +// }; +// }); + +// // Wait for all promises to resolve to gather all the enriched data +// const iotDataGrouped = await Promise.all(latestDataPromises); + +// // Return the final response +// return reply.send({ +// status_code: 200, +// message: "Success", +// data: iotDataGrouped +// }); + +// } catch (err) { +// console.error("Error fetching IoT data by customerId:", err); +// return reply.code(500).send({ error: "Internal Server Error" }); +// } +// }; + + exports.getIotDataByCustomer = async (req, reply) => { try { const { customerId } = req.params; if (!customerId) { - return reply.code(400).send({ error: "customerId is required" }); + return reply.status(400).send({ error: "customerId is required" }); } - // Fetch all sensors of the customer + console.log("Fetching data for customerId:", customerId); + + // Step 1: Fetch all sensors for the customer const sensors = await Insensors.find({ customerId }); if (!sensors || sensors.length === 0) { - return reply.code(404).send({ message: "No sensors found for this customer." }); + return reply.send({ status_code: 404, message: "No sensors found for this customer", data: [] }); } - // Extract unique hardwareIds - const hardwareIds = [ - ...new Set( - sensors.map(sensor => sensor.connected_to?.trim()).filter(Boolean) - ) - ]; - - if (hardwareIds.length === 0) { - return reply.send({ status_code: 200, message: "No connected hardwareIds found", data: [] }); - } + // Step 2: Fetch latest IoT data for each sensor's hardwareId + const enrichedSensors = await Promise.all(sensors.map(async (sensor) => { + const { connected_to: hardwareId, masterName, location } = sensor; - // Fetch latest IoT data and enrich it - const latestDataPromises = hardwareIds.map(async hardwareId => { - // Fetch the latest IoT data for the hardwareId - const latestRecord = await IotData.findOne({ hardwareId }) - .sort({ date: -1 }) + // Fetch the latest IoT data for this hardwareId + const iotData = await IotData.findOne({ hardwareId }) + .sort({ date: -1 }) // Sort to get the latest data .lean(); - // If there's no IoT data for the hardwareId, skip processing - if (!latestRecord) { + if (!iotData) { return { hardwareId, message: "No IoT data found", + masterName, + location, tanks: [] }; } - // Find sensors related to this hardwareId - const relatedSensors = sensors.filter(sensor => sensor.connected_to?.trim() === hardwareId); - - // Default message indicating GSM connection status - let message = "GSM is not connected"; - - // If any tank data indicates a height greater than 0, assume GSM is connected - if (latestRecord?.tanks?.some(tank => parseFloat(tank.tankHeight || 0) > 0)) { - message = "GSM is connected"; - } + // Step 3: Get GSM status based on the latest IoT data + const latestRecord = iotData; + const indiaTime = moment.tz(latestRecord.date, "Asia/Kolkata"); + const connected_gsm_date = indiaTime.format("YYYY-MM-DD"); + const connected_gsm_time = indiaTime.format("HH:mm:ss"); - // Prepare individual tank connection statuses - const tanksStatus = relatedSensors.map(sensor => { - const tankhardwareId = sensor.hardwareId?.trim(); - const matchedTank = latestRecord?.tanks?.find( - tank => tank.tankhardwareId === tankhardwareId - ); + const now = moment.tz("Asia/Kolkata"); + const diffInMinutes = now.diff(indiaTime, "minutes"); + const isGSMConnected = diffInMinutes <= 1; + const gsmStatus = isGSMConnected ? "GSM Connected" : "GSM Not Connected"; - const loraMessage = - matchedTank && parseFloat(matchedTank.tankHeight || 0) > 0 - ? "LORA is connected" - : "LORA is not connected"; + // Step 4: Annotate each tank with LoRa connection status + const tanksWithConnectionStatus = latestRecord.tanks.map(tank => { + const tankMoment = moment.tz(tank.date, "Asia/Kolkata"); + const tankDiff = now.diff(tankMoment, "minutes"); + const loraStatus = tankDiff <= 1 ? "LORA is connected" : "LORA is not connected"; return { - tankhardwareId, + tankhardwareId: tank.tankhardwareId, tankName: sensor.tankName ?? null, tankLocation: sensor.tankLocation ?? null, masterName: sensor.masterName ?? null, location: sensor.location ?? null, - loraMessage, - latestTankData: matchedTank || null + loraMessage: loraStatus, + latestTankData: tank }; }); + // Step 5: Return enriched sensor data in the desired format return { hardwareId, - message, - masterName: relatedSensors[0]?.masterName ?? null, - location: relatedSensors[0]?.location ?? null, - tanks: tanksStatus.slice(1) // Skip the first tank as needed + message: gsmStatus, + masterName, + location, + tanks: tanksWithConnectionStatus }; - }); - - // Wait for all promises to resolve - const iotDataGrouped = await Promise.all(latestDataPromises); + })); - // Return the enriched IoT data + // Step 6: Return the enriched data for the customer return reply.send({ status_code: 200, message: "Success", - data: iotDataGrouped + data: enrichedSensors }); } catch (err) { - console.error("Error fetching IoT data by customerId:", err); - return reply.code(500).send({ error: "Internal Server Error" }); + console.error("Error in getAllDataForCustomer:", err); + return reply.status(500).send({ error: "Internal Server Error" }); } };