updating products
This commit is contained in:
@@ -32,11 +32,49 @@ exports.addProduct = async (req, res) => {
|
||||
}
|
||||
};
|
||||
|
||||
exports.removeProduct = async (req, res) => {
|
||||
const { userID, productID } = req.body;
|
||||
console.log(userID);
|
||||
|
||||
try {
|
||||
// First delete images
|
||||
await db.execute(`DELETE FROM Image_URL WHERE ProductID = ?`, [productID]);
|
||||
await db.execute(`DELETE FROM History WHERE ProductID = ?`, [productID]);
|
||||
await db.execute(`DELETE FROM Favorites WHERE ProductID = ?`, [productID]);
|
||||
await db.execute(`DELETE FROM Product_Category WHERE ProductID = ?`, [
|
||||
productID,
|
||||
]);
|
||||
await db.execute(`DELETE FROM Product_Category WHERE ProductID = ?`, [
|
||||
productID,
|
||||
]);
|
||||
await db.execute(`DELETE FROM Transaction WHERE ProductID = ?`, [
|
||||
productID,
|
||||
]);
|
||||
await db.execute(
|
||||
`DELETE FROM Recommendation WHERE RecommendedProductID = ?`,
|
||||
[productID],
|
||||
);
|
||||
|
||||
// Then delete the product
|
||||
await db.execute(`DELETE FROM Product WHERE UserID = ? AND ProductID = ?`, [
|
||||
userID,
|
||||
productID,
|
||||
]);
|
||||
|
||||
res.json({
|
||||
success: true,
|
||||
message: "Product removed successfully",
|
||||
});
|
||||
} catch (error) {
|
||||
console.error("Error removing product:", error);
|
||||
return res.json({ error: "Could not remove product" });
|
||||
}
|
||||
};
|
||||
|
||||
exports.addFavorite = async (req, res) => {
|
||||
const { userID, productID } = req.body;
|
||||
console.log(userID);
|
||||
try {
|
||||
// Use parameterized query to prevent SQL injection
|
||||
const [result] = await db.execute(
|
||||
`INSERT INTO Favorites (UserID, ProductID) VALUES (?, ?)`,
|
||||
[userID, productID],
|
||||
@@ -72,6 +110,60 @@ exports.removeFavorite = async (req, res) => {
|
||||
}
|
||||
};
|
||||
|
||||
exports.updateProduct = async (req, res) => {
|
||||
const { productId } = req.params;
|
||||
const { name, description, price, category, images } = req.body;
|
||||
|
||||
console.log(productId);
|
||||
|
||||
const connection = await db.getConnection();
|
||||
try {
|
||||
await connection.beginTransaction();
|
||||
|
||||
// Step 1: Check if the product exists
|
||||
const [checkProduct] = await connection.execute(
|
||||
"SELECT * FROM Product WHERE ProductID = ?",
|
||||
[productId],
|
||||
);
|
||||
if (checkProduct.length === 0) {
|
||||
await connection.rollback();
|
||||
return res.status(404).json({ error: "Product not found" });
|
||||
}
|
||||
|
||||
// Step 2: Update the product
|
||||
await connection.execute(
|
||||
`
|
||||
UPDATE Product
|
||||
SET Name = ?, Description = ?, Price = ?, CategoryID = ?
|
||||
WHERE ProductID = ?
|
||||
`,
|
||||
[name, description, price, category, productId],
|
||||
);
|
||||
|
||||
// Step 3: Delete existing images
|
||||
await connection.execute(`DELETE FROM Image_URL WHERE ProductID = ?`, [
|
||||
productId,
|
||||
]);
|
||||
|
||||
// Step 4: Insert new image URLs
|
||||
for (const imageUrl of images) {
|
||||
await connection.execute(
|
||||
`INSERT INTO Image_URL (ProductID, URL) VALUES (?, ?)`,
|
||||
[productId, imageUrl],
|
||||
);
|
||||
}
|
||||
|
||||
await connection.commit();
|
||||
res.json({ success: true, message: "Product updated successfully" });
|
||||
} catch (error) {
|
||||
await connection.rollback();
|
||||
console.error("Update product error:", error);
|
||||
res.status(500).json({ error: "Failed to update product" });
|
||||
} finally {
|
||||
connection.release();
|
||||
}
|
||||
};
|
||||
|
||||
exports.myProduct = async (req, res) => {
|
||||
const { userID } = req.body;
|
||||
|
||||
@@ -253,33 +345,3 @@ exports.getProductById = async (req, res) => {
|
||||
});
|
||||
}
|
||||
};
|
||||
|
||||
// db_con.query(
|
||||
// "SELECT ProductID FROM product WHERE ProductID = ?",
|
||||
// [productID],
|
||||
// (err, results) => {
|
||||
// if (err) {
|
||||
// console.error("Error checking product:", err);
|
||||
// return res.json({ error: "Database error" });
|
||||
// }
|
||||
|
||||
// if (results.length === 0) {
|
||||
// return res.json({ error: "Product does not exist" });
|
||||
// }
|
||||
// },
|
||||
// );
|
||||
|
||||
// db_con.query(
|
||||
// "INSERT INTO Favorites (UserID, ProductID) VALUES (?, ?)",
|
||||
// [userID, productID],
|
||||
// (err, result) => {
|
||||
// if (err) {
|
||||
// console.error("Error adding favorite product:", err);
|
||||
// return res.json({ error: "Could not add favorite product" });
|
||||
// }
|
||||
// res.json({
|
||||
// success: true,
|
||||
// message: "Product added to favorites successfully",
|
||||
// });
|
||||
// },
|
||||
// );
|
||||
|
||||
Reference in New Issue
Block a user