Compare commits
4 Commits
18999515b2
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| 5d066c96c9 | |||
| 91f18a6a9a | |||
| 74e7dc8fd5 | |||
| 1f542c65ab |
11
README.md
11
README.md
@@ -1,6 +1,15 @@
|
|||||||
# DELIVER_MAN
|
# DELIVER_MAN
|
||||||
|
|
||||||
## Docker
|
## Core Functionality
|
||||||
|
|
||||||
|
- View product inventory with current stock levels.
|
||||||
|
- Create orders with customer name and order date.
|
||||||
|
- Edit order details (customer name, date) and delete orders.
|
||||||
|
- Add items to orders, update item quantities or products, and remove items.
|
||||||
|
- Move items between orders.
|
||||||
|
- Prevent overselling by validating stock on add/update.
|
||||||
|
|
||||||
|
## Run via Docker
|
||||||
|
|
||||||
Run client + server + database:
|
Run client + server + database:
|
||||||
|
|
||||||
|
|||||||
@@ -415,9 +415,7 @@ async function refreshData() {
|
|||||||
|
|
||||||
currentDateEl.textContent = currentDate;
|
currentDateEl.textContent = currentDate;
|
||||||
orderDateInput.min = currentDate;
|
orderDateInput.min = currentDate;
|
||||||
if (!orderDateInput.value) {
|
orderDateInput.value = currentDate
|
||||||
orderDateInput.value = currentDate;
|
|
||||||
}
|
|
||||||
|
|
||||||
renderInventory();
|
renderInventory();
|
||||||
renderOrders();
|
renderOrders();
|
||||||
@@ -444,9 +442,7 @@ function initializeApp() {
|
|||||||
currentDate = initialDate;
|
currentDate = initialDate;
|
||||||
currentDateEl.textContent = initialDate;
|
currentDateEl.textContent = initialDate;
|
||||||
orderDateInput.min = initialDate;
|
orderDateInput.min = initialDate;
|
||||||
if (!orderDateInput.value) {
|
|
||||||
orderDateInput.value = initialDate;
|
orderDateInput.value = initialDate;
|
||||||
}
|
|
||||||
|
|
||||||
orderForm.addEventListener('submit', async (event) => {
|
orderForm.addEventListener('submit', async (event) => {
|
||||||
event.preventDefault();
|
event.preventDefault();
|
||||||
|
|||||||
@@ -135,14 +135,14 @@ export default class DBAdapter {
|
|||||||
if (!id || !customer_name || !orderDate){
|
if (!id || !customer_name || !orderDate){
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Empty in customer name or order date")
|
error: new Error("Пустое имя клиента или дата заказа")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
const currentDate = await getCurrentDate();
|
const currentDate = await getCurrentDate();
|
||||||
if (orderDate < currentDate){
|
if (orderDate < currentDate){
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Invalid order date")
|
error: new Error("Недопустимая дата заказа")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
@@ -152,7 +152,7 @@ export default class DBAdapter {
|
|||||||
} catch(err){
|
} catch(err){
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_INTERNAL_ERROR,
|
type: DB_INTERNAL_ERROR,
|
||||||
error: new Error("Server error")
|
error: new Error("Ошибка сервера")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -192,8 +192,8 @@ export default class DBAdapter {
|
|||||||
if (!id || !customer_name || !orderDate) {
|
if (!id || !customer_name || !orderDate) {
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Order ID, name or date is required!"),
|
error: new Error("Нужен ID заказа, имя и дата"),
|
||||||
message: "Order ID, name or date is required!" // Добавляем message напрямую
|
message: "Нужен ID заказа, имя и дата" // Добавляем message напрямую
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -201,8 +201,8 @@ export default class DBAdapter {
|
|||||||
if (orderDate < currentDate) {
|
if (orderDate < currentDate) {
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Order date cannot be less than current date"),
|
error: new Error("Дата заказа не может быть раньше текущей"),
|
||||||
message: "Order date cannot be less than current date"
|
message: "Дата заказа не может быть раньше текущей"
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -212,8 +212,8 @@ export default class DBAdapter {
|
|||||||
if (!order || order.length === 0) { // Исправлено: проверяем length
|
if (!order || order.length === 0) { // Исправлено: проверяем length
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Order not found"),
|
error: new Error("Заказ не найден"),
|
||||||
message: "Order not found"
|
message: "Заказ не найден"
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -228,8 +228,8 @@ export default class DBAdapter {
|
|||||||
console.error('Database error in changeOrderInfo:', err);
|
console.error('Database error in changeOrderInfo:', err);
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_INTERNAL_ERROR,
|
type: DB_INTERNAL_ERROR,
|
||||||
error: new Error("Server error"),
|
error: new Error("Ошибка сервера"),
|
||||||
message: err.message || "Database operation failed",
|
message: err.message || "Ошибка операции с базой данных",
|
||||||
details: err.message
|
details: err.message
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@@ -279,7 +279,7 @@ export default class DBAdapter {
|
|||||||
|
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_INTERNAL_ERROR,
|
type: DB_INTERNAL_ERROR,
|
||||||
error: new Error("Failed to delete order"),
|
error: new Error("Не удалось удалить заказ"),
|
||||||
details: err.message
|
details: err.message
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@@ -303,7 +303,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Order not found")
|
error: new Error("Заказ не найден")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -319,7 +319,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Product not found")
|
error: new Error("Товар не найден")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -328,7 +328,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Insufficient product quantity")
|
error: new Error("Недостаточно товара на складе")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -361,16 +361,16 @@ export default class DBAdapter {
|
|||||||
console.error('Transaction error:', err);
|
console.error('Transaction error:', err);
|
||||||
|
|
||||||
let errorType = DB_INTERNAL_ERROR;
|
let errorType = DB_INTERNAL_ERROR;
|
||||||
let userMessage = "Database operation failed";
|
let userMessage = "Ошибка операции с базой данных";
|
||||||
let retryable = false;
|
let retryable = false;
|
||||||
|
|
||||||
if (err.code === 'ER_LOCK_WAIT_TIMEOUT' || err.errno === 1205) {
|
if (err.code === 'ER_LOCK_WAIT_TIMEOUT' || err.errno === 1205) {
|
||||||
errorType = 'DB_CONFLICT';
|
errorType = 'DB_CONFLICT';
|
||||||
userMessage = "System is busy. Please try again in a moment.";
|
userMessage = "Система занята. Попробуйте позже.";
|
||||||
retryable = true;
|
retryable = true;
|
||||||
} else if (err.code === 'ER_DUP_ENTRY') {
|
} else if (err.code === 'ER_DUP_ENTRY') {
|
||||||
errorType = DB_USER_ERROR;
|
errorType = DB_USER_ERROR;
|
||||||
userMessage = "Item already exists in the order";
|
userMessage = "Позиция уже есть в заказе";
|
||||||
}
|
}
|
||||||
|
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
@@ -391,7 +391,7 @@ export default class DBAdapter {
|
|||||||
if (!itemId || !Number.isFinite(quantity) || quantity <= 0) {
|
if (!itemId || !Number.isFinite(quantity) || quantity <= 0) {
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Invalid item or quantity")
|
error: new Error("Неверная позиция или количество")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -409,7 +409,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Order item not found")
|
error: new Error("Позиция заказа не найдена")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -426,7 +426,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Product not found")
|
error: new Error("Товар не найден")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
if (newProductRow.quantity < quantity) {
|
if (newProductRow.quantity < quantity) {
|
||||||
@@ -434,7 +434,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Insufficient product quantity")
|
error: new Error("Недостаточно товара на складе")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -472,7 +472,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Insufficient product quantity")
|
error: new Error("Недостаточно товара на складе")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -509,7 +509,7 @@ export default class DBAdapter {
|
|||||||
|
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_INTERNAL_ERROR,
|
type: DB_INTERNAL_ERROR,
|
||||||
error: new Error("Failed to update order item"),
|
error: new Error("Не удалось обновить позицию заказа"),
|
||||||
details: err.message
|
details: err.message
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@@ -533,7 +533,7 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Order item not found")
|
error: new Error("Позиция заказа не найдена")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -564,7 +564,7 @@ export default class DBAdapter {
|
|||||||
|
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_INTERNAL_ERROR,
|
type: DB_INTERNAL_ERROR,
|
||||||
error: new Error("Failed to delete order item"),
|
error: new Error("Не удалось удалить позицию заказа"),
|
||||||
details: err.message,
|
details: err.message,
|
||||||
itemId: itemId
|
itemId: itemId
|
||||||
});
|
});
|
||||||
@@ -589,12 +589,12 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Target order not found")
|
error: new Error("Целевой заказ не найден")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
const item = await connection.query(
|
const item = await connection.query(
|
||||||
'SELECT id, order_id FROM order_items WHERE id = ? FOR UPDATE',
|
'SELECT id, order_id, product_id, quantity FROM order_items WHERE id = ? FOR UPDATE',
|
||||||
[itemId]
|
[itemId]
|
||||||
);
|
);
|
||||||
|
|
||||||
@@ -604,14 +604,38 @@ export default class DBAdapter {
|
|||||||
connection.release();
|
connection.release();
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_USER_ERROR,
|
type: DB_USER_ERROR,
|
||||||
error: new Error("Order item not found")
|
error: new Error("Позиция заказа не найдена")
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (itemRow.order_id === targetOrderId) {
|
||||||
|
await connection.rollback();
|
||||||
|
connection.release();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const targetItem = await connection.query(
|
||||||
|
'SELECT id, quantity FROM order_items WHERE order_id = ? AND product_id = ? FOR UPDATE',
|
||||||
|
[targetOrderId, itemRow.product_id]
|
||||||
|
);
|
||||||
|
|
||||||
|
const targetItemRow = targetItem?.[0];
|
||||||
|
|
||||||
|
if (targetItemRow) {
|
||||||
|
await connection.query(
|
||||||
|
'UPDATE order_items SET quantity = ? WHERE id = ?',
|
||||||
|
[targetItemRow.quantity + itemRow.quantity, targetItemRow.id]
|
||||||
|
);
|
||||||
|
await connection.query(
|
||||||
|
'DELETE FROM order_items WHERE id = ?',
|
||||||
|
[itemId]
|
||||||
|
);
|
||||||
|
} else {
|
||||||
await connection.query(
|
await connection.query(
|
||||||
'UPDATE order_items SET order_id = ? WHERE id = ?',
|
'UPDATE order_items SET order_id = ? WHERE id = ?',
|
||||||
[targetOrderId, itemId]
|
[targetOrderId, itemId]
|
||||||
);
|
);
|
||||||
|
}
|
||||||
|
|
||||||
await connection.commit();
|
await connection.commit();
|
||||||
connection.release();
|
connection.release();
|
||||||
@@ -628,7 +652,7 @@ export default class DBAdapter {
|
|||||||
|
|
||||||
return Promise.reject({
|
return Promise.reject({
|
||||||
type: DB_INTERNAL_ERROR,
|
type: DB_INTERNAL_ERROR,
|
||||||
error: new Error("Failed to move order item"),
|
error: new Error("Не удалось перенести позицию заказа"),
|
||||||
details: err.message
|
details: err.message
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import express from "express";
|
import express from "express";
|
||||||
import dotenv from "dotenv"
|
import dotenv from "dotenv"
|
||||||
import { randomUUID } from "crypto";
|
import { randomUUID } from "crypto";
|
||||||
import DBAdapter, { getCurrentDate, setCurrentDate } from "./db/database.js";
|
import DBAdapter, { getCurrentDate, setCurrentDate } from "./db/database.js";
|
||||||
@@ -24,7 +24,7 @@ app.use(express.json());
|
|||||||
app.use((req, res, next) => {
|
app.use((req, res, next) => {
|
||||||
res.setHeader('Access-Control-Allow-Origin', '*');
|
res.setHeader('Access-Control-Allow-Origin', '*');
|
||||||
res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
|
res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
|
||||||
res.setHeader('Access-Control-Allow-Methods', 'GET,POST,PUT,DELETE');
|
res.setHeader('Access-Control-Allow-Methods', 'GET,POST,PUT,DELETE,OPTIONS');
|
||||||
if (req.method === 'OPTIONS') {
|
if (req.method === 'OPTIONS') {
|
||||||
res.sendStatus(204);
|
res.sendStatus(204);
|
||||||
return;
|
return;
|
||||||
@@ -175,7 +175,7 @@ app.post('/api/orders', async (req, res) => {
|
|||||||
res.status(500).json({
|
res.status(500).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 500,
|
statusCode: 500,
|
||||||
message: "Unknown error",
|
message: "Неизвестная ошибка",
|
||||||
error: err.message
|
error: err.message
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@@ -190,7 +190,7 @@ app.put('/api/orders/:id', async (req, res) => {
|
|||||||
return res.status(400).json({
|
return res.status(400).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 400,
|
statusCode: 400,
|
||||||
error: "Customer name and order date are required"
|
error: "Имя клиента и дата заказа обязательны"
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -212,7 +212,7 @@ app.put('/api/orders/:id', async (req, res) => {
|
|||||||
|
|
||||||
const errorMessage = err.message ||
|
const errorMessage = err.message ||
|
||||||
err.error?.message ||
|
err.error?.message ||
|
||||||
"Unknown error occurred";
|
"Произошла неизвестная ошибка";
|
||||||
|
|
||||||
switch(err.type) {
|
switch(err.type) {
|
||||||
case DB_INTERNAL_ERROR:
|
case DB_INTERNAL_ERROR:
|
||||||
@@ -220,7 +220,7 @@ app.put('/api/orders/:id', async (req, res) => {
|
|||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 500,
|
statusCode: 500,
|
||||||
error: errorMessage,
|
error: errorMessage,
|
||||||
details: err.details || "Internal server error"
|
details: err.details || "Внутренняя ошибка сервера"
|
||||||
});
|
});
|
||||||
|
|
||||||
case DB_USER_ERROR:
|
case DB_USER_ERROR:
|
||||||
@@ -265,7 +265,7 @@ app.post('/api/orders/:orderId/items', async (req, res) => {
|
|||||||
return res.status(400).json({
|
return res.status(400).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 400,
|
statusCode: 400,
|
||||||
error: "Invalid productId or quantity"
|
error: "Некорректный товар или количество"
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -290,21 +290,21 @@ app.post('/api/orders/:orderId/items', async (req, res) => {
|
|||||||
return res.status(400).json({
|
return res.status(400).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 400,
|
statusCode: 400,
|
||||||
error: err.error?.message || "Invalid request",
|
error: err.error?.message || "Некорректный запрос",
|
||||||
details: err.details
|
details: err.details
|
||||||
});
|
});
|
||||||
} else if (err.type === DB_INTERNAL_ERROR) {
|
} else if (err.type === DB_INTERNAL_ERROR) {
|
||||||
return res.status(500).json({
|
return res.status(500).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 500,
|
statusCode: 500,
|
||||||
error: "Internal server error",
|
error: "Внутренняя ошибка сервера",
|
||||||
details: err.error?.message
|
details: err.error?.message
|
||||||
});
|
});
|
||||||
} else {
|
} else {
|
||||||
return res.status(500).json({
|
return res.status(500).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 500,
|
statusCode: 500,
|
||||||
error: "Internal server error"
|
error: "Внутренняя ошибка сервера"
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -347,14 +347,14 @@ app.delete('/api/orders/:orderId/items/:itemId', async (req, res) => {
|
|||||||
return res.status(500).json({
|
return res.status(500).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 500,
|
statusCode: 500,
|
||||||
error: "Server error",
|
error: "Ошибка сервера",
|
||||||
details: err.error.message
|
details: err.error.message
|
||||||
});
|
});
|
||||||
} else {
|
} else {
|
||||||
return res.status(500).json({
|
return res.status(500).json({
|
||||||
timeStamp: new Date().toISOString(),
|
timeStamp: new Date().toISOString(),
|
||||||
statusCode: 500,
|
statusCode: 500,
|
||||||
error: "Internal server error",
|
error: "Внутренняя ошибка сервера",
|
||||||
details: err.message
|
details: err.message
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@@ -387,7 +387,7 @@ app.post('/api/order-items/:itemId/move', async (req, res) => {
|
|||||||
|
|
||||||
|
|
||||||
app.use((req, res) => {
|
app.use((req, res) => {
|
||||||
res.status(404).json({ error: 'Invalid route' });
|
res.status(404).json({ error: 'Неверный маршрут' });
|
||||||
});
|
});
|
||||||
|
|
||||||
const server = app.listen(appPort, async() => {
|
const server = app.listen(appPort, async() => {
|
||||||
|
|||||||
Reference in New Issue
Block a user