Merge branch 'master' of https://github.com/cheminova2024/cheminova-api

app.js

@@ -47,6 +47,7 @@ app.use(express.static(publicPath));
 app.use(
   fileUpload({
     useTempFiles: true,
+    tempFileDir: join(publicPath, 'temp'), 
   })
 );
 

package.json

@@ -39,6 +39,7 @@
     "secure-random-password": "^0.2.3",
     "stripe": "^14.16.0",
     "uuid": "^9.0.1",
-    "validator": "^13.7.0"
+    "validator": "^13.7.0",
+    "xlsx": "^0.18.5"
   }
 }

resources/Products/ProductController.js

@@ -2,11 +2,234 @@ import { Product } from "./ProductModel.js";
 import cloudinary from "../../Utils/cloudinary.js";
 import { v4 as uuidv4 } from "uuid";
 import { CategoryModel } from "../Category/CategoryModel.js";
+import { Tax } from "../Tax/tax_model.js";
+import XLSX from "xlsx";
+import fs from "fs";
+import path from "path";
+import mongoose from "mongoose";
+
+// Function to handle product upload
+export const uploadProducts = async (req, res) => {
+  try {
+    if (!req.files || !req.files.file) {
+      return res.status(400).json({ message: "No file uploaded" });
+    }
+
+    const file = req.files.file;
+    const filePath = path.join("public", "uploads", file.name);
+
+    // Ensure 'uploads' directory exists
+    if (!fs.existsSync(path.dirname(filePath))) {
+      fs.mkdirSync(path.dirname(filePath), { recursive: true });
+    }
+
+    // Move the file from temp to the uploads directory
+    await file.mv(filePath);
+
+    // Process the file
+    const fileBuffer = fs.readFileSync(filePath);
+    const workbook = XLSX.read(fileBuffer, { type: "buffer" });
+    const sheetName = workbook.SheetNames[0];
+    const worksheet = workbook.Sheets[sheetName];
+    const data = XLSX.utils.sheet_to_json(worksheet, { header: 1 });
+
+    if (data.length <= 1) {
+      return res.status(400).json({ message: "Empty spreadsheet or no data found" });
+    }
+
+    const headers = data[0];
+
+    // Map headers from the Excel file to your schema
+    const headerMapping = {
+      "Product Name": "name",
+      "category Name": "category",
+      price: "price",
+      "GST Name": "GST",
+      description: "description",
+      special_instructions: "special_instructions",
+    };
+
+    const requiredHeaders = Object.keys(headerMapping);
+
+    if (!requiredHeaders.every((header) => headers.includes(header))) {
+      return res.status(400).json({ message: "Missing required columns in spreadsheet" });
+    }
+
+    const errors = [];
+    const productsProcessed = [];
+
+    for (let i = 1; i < data.length; i++) {
+      const row = data[i];
+      const item = {};
+
+      headers.forEach((header, index) => {
+        if (headerMapping[header]) {
+          item[headerMapping[header]] = row[index] !== undefined ? row[index] : "";
+        }
+      });
+
+      // Initialize error tracking for each item
+      const missingFields = new Set();
+      const notFoundErrors = new Set();
+
+      let { name, category, price, GST, description, special_instructions } = item;
+
+      // Trim leading and trailing spaces from product name and GST
+      name = name ? name.trim() : "";
+      GST = GST ? GST.toString().trim() : "";
+
+      // Validate required fields
+      if (!name) missingFields.add("name");
+      if (!category) missingFields.add("category");
+      if (price === undefined || price === "") missingFields.add("price");
+      if (!GST) missingFields.add("GST");
+
+      // Validate category
+      if (category) {
+        const categoryDoc = await CategoryModel.findOne({
+          categoryName: { $regex: new RegExp(`^${category.trim()}$`, "i") },
+        }).exec();
+        if (categoryDoc) {
+          item.category = categoryDoc._id;
+        } else {
+          notFoundErrors.add("category");
+        }
+      } else {
+        missingFields.add("category");
+      }
+
+      // Validate GST
+      if (GST) {
+        const gstDoc = await Tax.findOne({
+          name: { $regex: new RegExp(`^${GST}$`, "i") },
+        }).exec();
+        if (gstDoc) {
+          item.GST = gstDoc._id;
+        } else {
+          notFoundErrors.add("GST");
+        }
+      } else {
+        missingFields.add("GST");
+      }
+
+      // Combine all errors into a single message
+      let errorMessage = "";
+      if (missingFields.size > 0) {
+        errorMessage += `Missing fields: ${Array.from(missingFields).join(", ")}. `;
+      }
+      if (notFoundErrors.size > 0) {
+        errorMessage += `Not found: ${Array.from(notFoundErrors).join(", ")}.`;
+      }
+
+      // If there are errors, push them to the errors array
+      if (errorMessage.trim()) {
+        errors.push({
+          productName: name || "N/A",
+          category: category || "N/A",
+          GST: GST || "N/A",
+          message: errorMessage.trim(),
+        });
+        continue;
+      }
+
+      // Ensure fields are set to empty strings if not provided
+      description = description !== undefined ? description : "";
+      special_instructions = special_instructions !== undefined ? special_instructions : "";
+
+      // Check for existing product
+      let existingProduct = await Product.findOne({
+        name: new RegExp(`^${name}$`, "i"),
+      }).exec();
+
+      if (existingProduct) {
+        // Validate that the existing product can be updated
+        const updateErrors = [];
+        if (missingFields.size > 0) {
+          updateErrors.push(`Missing fields: ${Array.from(missingFields).join(", ")}`);
+        }
+        if (notFoundErrors.size > 0) {
+          updateErrors.push(`Not found: ${Array.from(notFoundErrors).join(", ")}`);
+        }
+
+        if (updateErrors.length > 0) {
+          errors.push({
+            productName: name,
+            message: updateErrors.join(". "),
+          });
+          continue;
+        }
+
+        // Update existing product
+        try {
+          await Product.updateOne(
+            { _id: existingProduct._id },
+            {
+              $set: {
+                category: item.category || existingProduct.category,
+                price: price !== undefined && price !== "" ? price : existingProduct.price,
+                GST: item.GST || existingProduct.GST,
+                description: description, // Ensure description is included
+                special_instructions: special_instructions, // Ensure special_instructions is included
+                product_Status: item.product_Status || existingProduct.product_Status || "Active",
+              },
+            }
+          );
+          productsProcessed.push({ ...existingProduct._doc, ...item }); // Track updated product
+        } catch (error) {
+          errors.push({
+            productName: name,
+            message: "Failed to update product",
+          });
+        }
+        continue;
+      }
+
+      // Create new product
+      if (item.category && item.GST) {
+        const productData = {
+          name,
+          category: item.category,
+          price,
+          GST: item.GST,
+          description: description, // Ensure description is included
+          special_instructions: special_instructions, // Ensure special_instructions is included
+          product_Status: item.product_Status || "Active",
+          addedBy: req.user._id,
+        };
+        try {
+          const newProduct = await Product.create(productData);
+          productsProcessed.push(newProduct); // Track new product
+        } catch (error) {
+          errors.push({
+            productName: name,
+            message: "Failed to create product",
+          });
+        }
+      }
+    }
+
+    fs.unlinkSync(filePath); // Clean up uploaded file
+
+    res.status(201).json({
+      message:
+        errors.length > 0
+          ? "Products processed with errors!"
+          : "Products processed successfully!",
+      productsProcessed: productsProcessed.length, // Total processed products
+      errors,
+    });
+  } catch (error) {
+    console.error("Error:", error);
+    res.status(500).json({ message: error.message || "Something went wrong!" });
+  }
+};
+
+
 export const createProduct = async (req, res) => {
   try {
     let findProduct = "";
     let product = { _id: "" };
-
+    // console.log("req.body", req.body);
     if (req.body?.product_id) {
       findProduct = await Product.findById(req.body.product_id);
     }
@@ -71,11 +294,15 @@ export const updateProduct = async (req, res) => {
 
     // Process new images
     for (const file of filesArray) {
-      if (file && file.tempFilePath) { // Check if file has tempFilePath
+      if (file && file.tempFilePath) {
+        // Check if file has tempFilePath
         try {
-          const result = await cloudinary.v2.uploader.upload(file.tempFilePath, {
+          const result = await cloudinary.v2.uploader.upload(
-            folder: "chemiNova/product",
+            file.tempFilePath,
-          });
+            {
+              folder: "chemiNova/product",
+            }
+          );
           newImagesLinks.push({
             public_id: result.public_id,
             url: result.secure_url,
@@ -83,7 +310,10 @@ export const updateProduct = async (req, res) => {
           // console.log("Uploaded image:", result.secure_url);
         } catch (uploadError) {
           console.error("Error uploading image:", uploadError);
-          return res.status(500).json({ message: "Failed to upload image", error: uploadError.message });
+          return res.status(500).json({
+            message: "Failed to upload image",
+            error: uploadError.message,
+          });
         }
       }
     }
@@ -109,7 +339,9 @@ export const updateProduct = async (req, res) => {
     product.image = allImages;
     await product.save();
 
-    res.status(200).json({ message: "Product updated successfully!", images: allImages });
+    res
+      .status(200)
+      .json({ message: "Product updated successfully!", images: allImages });
   } catch (error) {
     console.error(error); // Log error for debugging
     res.status(500).json({ message: "Server error!", error: error.message });
@@ -120,55 +352,49 @@ export const updateProduct = async (req, res) => {
 //get All Product
 export const getAllProductAdmin = async (req, res) => {
   try {
-    const PAGE_SIZE = parseInt(req.query?.show || "10");
+    const PAGE_SIZE = parseInt(req.query.show) || 10;
-    const page = parseInt(req.query?.page - 1 || "0");
+    const page = parseInt(req.query.page) || 1;
+    const skip = (page - 1) * PAGE_SIZE;
 
-    // Create filter object based on query parameters
     let filter = {};
 
-    if (req.query?.name) {
+    if (req.query.name) {
       filter.name = {
-        $regex: new RegExp(req.query.name, "i"), // Case-insensitive search
+        $regex: new RegExp(req.query.name, "i"),
       };
     }
-    if (req.query?.category) {
+    if (req.query.category) {
-      filter.category = mongoose.Types.ObjectId(req.query.category); // Ensure category is an ObjectId
+      filter.category = mongoose.Types.ObjectId(req.query.category);
-    }
-    if (req.query?.FeatureProduct) {
-      filter.featured_Product = req.query.FeatureProduct === "true"; // Convert string to boolean
     }
 
-    // Count total products matching the filter
     const total = await Product.countDocuments(filter);
 
-    // Fetch products with pagination and sorting
     const products = await Product.find(filter)
       .populate({
         path: "category addedBy GST",
         select: "categoryName name tax",
       })
       .limit(PAGE_SIZE)
-      .skip(PAGE_SIZE * page)
+      .skip(skip)
-      .sort({
+      .sort({ createdAt: -1 })
-        featured_Product: -1,
-        createdAt: -1,
-      })
       .exec();
 
     return res.status(200).json({
       success: true,
       total_data: total,
       total_pages: Math.ceil(total / PAGE_SIZE),
-      products, // Changed from `product` to `products` to match the response variable
+      products,
     });
   } catch (error) {
+    console.error(error); // Add logging for better debugging
     res.status(500).json({
       success: false,
-      msg: error.message ? error.message : "Something went wrong!",
+      msg: error.message || "Something went wrong!",
     });
   }
 };
 
+
 //get All Product User(website)
 export const getAllProductUser = async (req, res) => {
   try {
@@ -181,8 +407,6 @@ export const getAllProductUser = async (req, res) => {
         $options: "i",
       };
     if (req.query?.category) obj.category = req.query.category;
-    if (req.query?.FeatureProduct)
-      obj.featured_Product = req.query.FeatureProduct;
     obj.product_Status = "Active";
     const total = await Product.countDocuments(obj);
     const product = await Product.find(obj)
@@ -194,7 +418,6 @@ export const getAllProductUser = async (req, res) => {
       .skip(PAGE_SIZE * page)
       // .sort("name")
       .sort({
-        featured_Product: -1,
         createdAt: -1,
       })
       .exec();
@@ -248,49 +471,6 @@ export const ChangeProductStatus = async (req, res) => {
     });
   }
 };
-//Change Product status
-export const ChangeFeatueProductStatus = async (req, res) => {
-  try {
-    const data = await Product.findById(req.params.id);
-    if (data) {
-      if (data?.featured_Product === false) {
-        const totalFeatueProduct = await Product.countDocuments({
-          featured_Product: true,
-        });
-        if (totalFeatueProduct > 2) {
-          return res.status(400).json({
-            success: false,
-            msg: "Maximum 3 Featue Product can be..",
-          });
-        }
-        let product = await Product.findByIdAndUpdate(
-          req.params.id,
-          { featured_Product: true },
-          { new: true } // Return the updated document
-        );
-        return res.status(200).json({
-          success: true,
-          msg: "Changed status as Featue Product",
-        });
-      } else {
-        let product = await Product.findByIdAndUpdate(
-          req.params.id,
-          { featured_Product: false },
-          { new: true } // Return the updated document
-        );
-        return res.status(200).json({
-          success: true,
-          msg: "Changed status as not Featue Product",
-        });
-      }
-    }
-  } catch (error) {
-    res.status(500).json({
-      success: false,
-      msg: error.message ? error.message : "Something went wrong!",
-    });
-  }
-};
 //get One Product
 export const getOneProduct = async (req, res) => {
   try {
@@ -534,7 +714,6 @@ export const getAllProductsDevicesFirst = async (req, res) => {
 //   }
 // };
 
-
 export const deleteImageFromCloudinary = async (req, res) => {
   const { public_id } = req.params;
 

resources/Products/ProductModel.js

@@ -26,16 +26,12 @@ const productSchema = new Schema(
     description: {
       type: String,
       maxLength: [400, "description cannot exceed 100 characters"],
-      required: [true, "Please Enter product Description"],
+      // required: [true, "Please Enter product Description"],
     },
 
     special_instructions: {
       type: String,
     },
-    featured_Product: {
-      type: Boolean,
-      default: false, // Initially, products are not featured
-    },
     image: [
       {
         public_id: {

resources/Products/ProductRoute.js

@@ -10,10 +10,21 @@ import {
   getAllProductUser,
   getAllProductsDevicesFirst,
   ChangeProductStatus,
-  ChangeFeatueProductStatus,
+  uploadProducts,
 } from "./ProductController.js";
-const router = express.Router();
+
 import { isAuthenticatedUser, authorizeRoles } from "../../middlewares/auth.js";
+
+const router = express.Router();
+
+router
+  .route('/products/upload').post( 
+    isAuthenticatedUser, 
+  authorizeRoles('admin'), 
+  uploadProducts
+);
+
+
 router
   .route("/product/create/")
   .post(isAuthenticatedUser, authorizeRoles("admin"), createProduct);
@@ -23,9 +34,6 @@ router
 
 //change Product status
 router.route("/product/admin/status/:id").patch(ChangeProductStatus);
-router
-  .route("/product/admin/feature_product/status/:id")
-  .patch(ChangeFeatueProductStatus);
 
 //get all product user
 router.route("/product/getAll/user/").get(getAllProductUser);