128 lines
3.5 KiB
JavaScript
128 lines
3.5 KiB
JavaScript
const db = require("../models");
|
|
const Product = db.Product;
|
|
const fs = require("fs");
|
|
const csv = require("csv-parser");
|
|
const path = require("path");
|
|
const UnitMaster = db.UnitMaster;
|
|
|
|
exports.createProduct = async (req, res) => {
|
|
try {
|
|
|
|
const data = await Product.create(req.body);
|
|
|
|
res.status(201).send({'status':"success",'message':"created successfully",'data': data });
|
|
|
|
} catch (error) {
|
|
res.status(500).send({'status':"failed",'message':err.message });
|
|
}
|
|
};
|
|
|
|
exports.getAllProducts = async (req, res) => {
|
|
try {
|
|
|
|
const data = await Product.findAll({
|
|
include: [
|
|
{
|
|
model: UnitMaster,
|
|
as: "unit",
|
|
attributes: ["uom"],
|
|
},
|
|
],
|
|
});
|
|
|
|
res.status(200).send({'status':"success",'message':"Fetched successfully",'data': data });
|
|
|
|
} catch (error) {
|
|
res.status(500).send({'status':"failed",'message':err.message });
|
|
}
|
|
};
|
|
|
|
exports.getProductById = async (req, res) => {
|
|
try {
|
|
|
|
const data = await Product.findByPk(req.params.id);
|
|
|
|
if (!data) res.status(404).send({'status':"failed",'message':"Record Not found",'data': "" });
|
|
|
|
res.status(200).send({'status':"success",'message':"Fetched successfully",'data': data });
|
|
|
|
} catch (error) {
|
|
res.status(500).send({'status':"failed",'message':err.message });
|
|
}
|
|
};
|
|
|
|
exports.updateProduct = async (req, res) => {
|
|
try {
|
|
|
|
const [updated] = await Product.update(req.body, { where: { id: req.params.id } });
|
|
|
|
if (!updated) res.status(404).send({'status':"failed",'message':"Record Not found",'data': "" });
|
|
|
|
res.status(200).send({'status':"success",'message':"Updated successfully",'data': "" });
|
|
|
|
} catch (error) {
|
|
res.status(500).send({'status':"failed",'message':err.message });
|
|
}
|
|
};
|
|
|
|
exports.deleteProduct = async (req, res) => {
|
|
try {
|
|
|
|
const deleted = await Product.destroy({ where: { id: req.params.id } });
|
|
|
|
if (!deleted) res.status(404).send({'status':"failed",'message':"Record Not found",'data': "" });
|
|
|
|
res.status(200).send({'status':"success",'message':"Deleted successfully",'data': "" });
|
|
|
|
} catch (error) {
|
|
res.status(500).send({'status':"failed",'message':err.message });
|
|
}
|
|
};
|
|
|
|
exports.uploadProductsFromCSV = async (req, res) => {
|
|
try {
|
|
if (!req.file) {
|
|
return res.status(400).send({ status: "failed", message: "No file uploaded" });
|
|
}
|
|
|
|
const results = [];
|
|
const filePath = req.file.path;
|
|
|
|
// Read CSV and store rows
|
|
fs.createReadStream(filePath)
|
|
.pipe(csv())
|
|
.on("data", (row) => {
|
|
results.push(row);
|
|
})
|
|
.on("end", async () => {
|
|
try {
|
|
// Insert all rows into Product table
|
|
const inserted = await Product.bulkCreate(results, { validate: true });
|
|
fs.unlinkSync(filePath); // delete file after processing
|
|
|
|
res.status(201).send({
|
|
status: "success",
|
|
message: `${inserted.length} products inserted successfully`,
|
|
data: inserted,
|
|
});
|
|
} catch (dbErr) {
|
|
res.status(500).send({
|
|
status: "failed",
|
|
message: dbErr.message,
|
|
});
|
|
}
|
|
});
|
|
} catch (error) {
|
|
res.status(500).send({ status: "failed", message: error.message });
|
|
}
|
|
};
|
|
|
|
exports.downloadProductSample = async (req, res) => {
|
|
try {
|
|
const filePath = path.join(__dirname, "../writable/uploads/sample_files/products_upload_sample.csv");
|
|
return res.download(filePath, "products_upload_sample.csv");
|
|
} catch (err) {
|
|
return res.status(500).send({ status: "failed", message: err.message });
|
|
}
|
|
};
|