fetch issues revert

src/controllers/installationController.js

@@ -5053,13 +5053,119 @@ exports.moveIssueToCategory = async (req, reply) => {
 // };
 
 
+//final
+// exports.particularCategory = async (req, reply) => {
+//   try {
+//     const { customerId, supportId, category } = req.params;
+
+//     if (!customerId || !supportId || !category) {
+//       return reply.code(400).send({ error: "customerId, supportId, and category are required" });
+//     }
+
+//     const support = await Support.findOne({ supportId }).lean();
+//     if (!support) {
+//       return reply.code(404).send({ message: "Support record not found" });
+//     }
+
+//     // Filter categorizedIssues by category and customerId
+//     const issues = (support.categorizedIssues || []).filter(
+//       issue => issue.category === category
+//     );
+
+//     if (issues.length === 0) {
+//       return reply.code(404).send({ message: `No issues found for category: ${category}` });
+//     }
+
+//     const hardwareIds = issues.map(issue => issue.hardwareId).filter(Boolean);
+
+//     // Only fetch sensors that belong to the customerId
+//     const insensors = await Insensors.find({
+//       customerId,
+//       hardwareId: { $in: hardwareIds },
+//       connected_status: "disconnected"
+//     }).lean();
+
+//     if (!insensors.length) {
+//       return reply.code(404).send({ message: "No disconnected devices found for this category." });
+//     }
+
+//     const orderMap = {};
+//     const orders = await Order.find({ customerId }).lean();
+//     orders.forEach(order => {
+//       order.master_connections.forEach(conn => {
+//         orderMap[conn.hardwareId] = {
+//           masterName: conn.master_name || null,
+//           location: conn.location || null
+//         };
+//       });
+//     });
+
+//     const disconnectedIssues = [];
+
+//     for (const master of insensors.filter(i => i.type === "master")) {
+//       const slaves = await Insensors.find({
+//         customerId,
+//         connected_to: master.hardwareId,
+//         connected_status: "disconnected"
+//       }).lean();
+
+//       const slaveDetails = slaves.map(slave => {
+//         const slaveIssue = issues.find(i => i.hardwareId === slave.hardwareId);
+//         return {
+//           hardwareId: slave.hardwareId,
+//           tankName: slave.tankName || "",
+//           location: slave.tankLocation || "",
+//           connected_status: slave.connected_status,
+//           lora_last_disconnect_time: slave.lora_last_disconnect_time || null,
+//           team_member_support_lora_last_check_time: slave.team_member_support_lora_last_check_time,
+//           connected_to: slave.connected_to || "",
+//           masterName: orderMap[master.hardwareId]?.masterName || "",
+//           type: "slave",
+//           typeOfWater: slave.typeOfWater || "",
+//           support_lora_last_check_time: null,
+//           category,
+//           assignedTo: slaveIssue?.assignedTo || null
+//         };
+//       });
+
+//       const masterIssue = issues.find(i => i.hardwareId === master.hardwareId);
+
+//       disconnectedIssues.push({
+//         hardwareId: master.hardwareId,
+//         masterName: orderMap[master.hardwareId]?.masterName || "",
+//         location: orderMap[master.hardwareId]?.location || "",
+//         type: "master",
+//         connected_status: master.connected_status,
+//         gsm_last_disconnect_time: master.gsm_last_disconnect_time || null,
+//         team_member_support_gsm_last_check_time: master.team_member_support_gsm_last_check_time,
+//         support_gsm_last_check_time: null,
+//         connected_slave_count: slaveDetails.length,
+//         connected_slaves: slaveDetails,
+//         category,
+//         assignedTo: masterIssue?.assignedTo || null
+//       });
+//     }
+
+//     return reply.send({
+//       status_code: 200,
+//       supportId,
+//       customerId,
+//       totalMasters: disconnectedIssues.length,
+//       disconnectedIssues
+//     });
+
+//   } catch (err) {
+//     console.error("Error in particularCategory:", err);
+//     return reply.code(500).send({ error: "Internal server error" });
+//   }
+// };
 
 exports.particularCategory = async (req, reply) => {
   try {
-    const { customerId, supportId, category } = req.params;
+    const { supportId, category } = req.params;
 
-    if (!customerId || !supportId || !category) {
+    if (!supportId || !category) {
-      return reply.code(400).send({ error: "customerId, supportId, and category are required" });
+      return reply.code(400).send({ error: "supportId and category are required" });
     }
 
     const support = await Support.findOne({ supportId }).lean();
@@ -5067,20 +5173,13 @@ exports.particularCategory = async (req, reply) => {
       return reply.code(404).send({ message: "Support record not found" });
     }
 
-    // Filter categorizedIssues by category and customerId
+    const issues = (support.categorizedIssues || []).filter(issue => issue.category === category);
-    const issues = (support.categorizedIssues || []).filter(
-      issue => issue.category === category
-    );
-
     if (issues.length === 0) {
       return reply.code(404).send({ message: `No issues found for category: ${category}` });
     }
 
     const hardwareIds = issues.map(issue => issue.hardwareId).filter(Boolean);
-
-    // Only fetch sensors that belong to the customerId
     const insensors = await Insensors.find({
-      customerId,
       hardwareId: { $in: hardwareIds },
       connected_status: "disconnected"
     }).lean();
@@ -5090,21 +5189,23 @@ exports.particularCategory = async (req, reply) => {
     }
 
     const orderMap = {};
-    const orders = await Order.find({ customerId }).lean();
+    const customerId = insensors[0]?.customerId;
-    orders.forEach(order => {
+    if (customerId) {
-      order.master_connections.forEach(conn => {
+      const orders = await Order.find({ customerId }).lean();
-        orderMap[conn.hardwareId] = {
+      orders.forEach(order => {
-          masterName: conn.master_name || null,
+        order.master_connections.forEach(conn => {
-          location: conn.location || null
+          orderMap[conn.hardwareId] = {
-        };
+            masterName: conn.master_name || null,
+            location: conn.location || null
+          };
+        });
       });
-    });
+    }
 
     const disconnectedIssues = [];
 
     for (const master of insensors.filter(i => i.type === "master")) {
       const slaves = await Insensors.find({
-        customerId,
         connected_to: master.hardwareId,
         connected_status: "disconnected"
       }).lean();
@@ -5117,14 +5218,13 @@ exports.particularCategory = async (req, reply) => {
           location: slave.tankLocation || "",
           connected_status: slave.connected_status,
           lora_last_disconnect_time: slave.lora_last_disconnect_time || null,
-          team_member_support_lora_last_check_time: slave.team_member_support_lora_last_check_time,
           connected_to: slave.connected_to || "",
           masterName: orderMap[master.hardwareId]?.masterName || "",
           type: "slave",
           typeOfWater: slave.typeOfWater || "",
           support_lora_last_check_time: null,
           category,
-          assignedTo: slaveIssue?.assignedTo || null
+          assignedTo: slaveIssue?.assignedTo || null // <-- Include assigned details here
         };
       });
 
@@ -5137,19 +5237,17 @@ exports.particularCategory = async (req, reply) => {
         type: "master",
         connected_status: master.connected_status,
         gsm_last_disconnect_time: master.gsm_last_disconnect_time || null,
-        team_member_support_gsm_last_check_time: master.team_member_support_gsm_last_check_time,
         support_gsm_last_check_time: null,
         connected_slave_count: slaveDetails.length,
         connected_slaves: slaveDetails,
         category,
-        assignedTo: masterIssue?.assignedTo || null
+        assignedTo: masterIssue?.assignedTo || null // <-- Include assigned details here
       });
     }
 
     return reply.send({
       status_code: 200,
       supportId,
-      customerId,
       totalMasters: disconnectedIssues.length,
       disconnectedIssues
     });
@@ -5159,8 +5257,6 @@ exports.particularCategory = async (req, reply) => {
     return reply.code(500).send({ error: "Internal server error" });
   }
 };
-
-
 exports.assignCategorizeIssue = async (request, reply) => {
   const { supportId } = request.params;
   const { support_teamMemberId, startDate, endDate, category, masterHardwareId } = request.body;

src/routes/installationRoute.js

@@ -745,7 +745,7 @@ module.exports = function (fastify, opts, next) {
         handler: installationController.moveIssueToCategory
       });
       
-      fastify.get('/api/support/categorizedIssues/:supportId/:category/:customerId', {
+      fastify.get('/api/support/categorizedIssues/:supportId/:category', {
         schema: {
           description: 'Get all issues in a particular category for a support record',
           tags: ['Support'],
@@ -755,7 +755,7 @@ module.exports = function (fastify, opts, next) {
             required: ['supportId', 'category'],
             properties: {
               supportId: { type: 'string' },
-              customerId: { type: 'string' },
+              //customerId: { type: 'string' },
               category: {
                 type: 'string',
                 enum: ['Power Outage', 'Level1', 'Pending', 'Onsite Issues']  // your allowed categories