style(database): Fixed the issue with long function declarations

https://g.codrs.ru/Hackaton/Backend/pulls/2#issuecomment-23
https://g.codrs.ru/Hackaton/Backend/pulls/2#issuecomment-31

.env.tmp

@@ -0,0 +1,2 @@
+KEY=  # Key for JWT token
+POSTGRES_URL=postgresql://

api/auth.py

@@ -0,0 +1,28 @@
+from flask import Blueprint, request, jsonify
+from model.user import User
+
+auth = Blueprint("auth", __name__)
+
+
+@auth.route('/login', methods = ['POST'])
+def login():
+    if request.is_json:
+        req = request.json
+
+        email = req.get('email')
+        password = req.get('password')
+
+        if not email or not password:
+            return "Request must have email and password", 400
+
+        if len(email.strip()) < 4 or '@' not in email or '.' not in email:
+            return "Email is incorrect", 400
+
+        if len(password.strip()) < 8:
+            return "Password is too short", 400
+
+        user = User(email, password)
+        return jsonify(user.toJson())
+
+    else:
+        return "Request is not a json", 400

api/loginapi.py

@@ -1,12 +0,0 @@
-from flask import Blueprint, request
-from model.user import user
-
-loginBP =  Blueprint("loginapi", __name__)
-
-@loginBP.route('/api/login', methods = ['POST'])
-def login():
-    email = request.form['email']
-    password = request.form['password']
-    #if(isvalid(email, password)):
-    us = user.initialize(email, password)
-    return us.toJSON()

app.py

@@ -1,6 +1,11 @@
+from sys import exit
 from flask import Flask
-from api.loginapi import loginBP
+from api.auth import auth
+from utils.loadDotEnv import initializeENV
+
+if not initializeENV():
+    exit(-1)
 
 app = Flask(__name__)
 
-app.register_blueprint(loginBP)
+app.register_blueprint(auth, url_prefix='/api/auth')

db/connection.py

@@ -0,0 +1,61 @@
+import psycopg2
+import os
+import logging
+from contextlib import contextmanager
+from typing import Generator
+
+from utils.loadDotEnv import initializeENV
+
+initializeENV()
+
+logger = logging.getLogger(__name__)
+
+def PSQLConnect():
+    conn = psycopg2.connect(os.getenv('POSTDRESS_CONNECTION'))
+    return conn
+
+def PSQLCursor(conn):
+    cur =  conn.cursor()
+    return cur
+
+
+@contextmanager
+def get_connection() -> Generator[psycopg2.extensions.connection, None, None]:
+    conn = None
+    try:
+        conn = PSQLConnect()
+        logger.info("Подключение к БД установлено")
+        yield conn
+    except psycopg2.OperationalError as e:
+        logger.error(f"Ошибка подключения к БД: {e}")
+        raise
+    except psycopg2.Error as e:
+        logger.error(f"Ошибка PostgreSQL: {e}")
+        raise
+    except Exception as e:
+        logger.error(f"Неожиданная ошибка при работе с БД: {e}")
+        raise
+    finally:
+        if conn:
+            try:
+                conn.close()
+                logger.info("Соединение с БД закрыто")
+            except Exception as e:
+                logger.warning(f"Ошибка при закрытии соединения: {e}")
+
+def test_connection() -> bool:
+    try:
+        with get_connection() as conn:
+            cur = PSQLCursor(conn)
+            try:
+                cur.execute("SELECT version();")
+                version = cur.fetchone()
+                logger.info(f"Версия PostgreSQL: {version[0]}")
+                return True
+            finally:
+                cur.close()
+                logger.debug("Курсор закрыт")
+    except Exception as e:
+        logger.error(f"Тест подключения к БД провален: {e}")
+        return False
+print(test_connection())

db/repositories/__init__.py

@@ -0,0 +1,7 @@
+from .user_repository import UserRepository
+from .robot_repository import RobotRepository
+from .product_repository import ProductRepository
+from .inventory_repository import InventoryRepository
+from .ai_prediction_repository import AIPredictionsRepository
+
+__all__ = ['UserRepository', 'RobotRepository', 'ProductRepository', 'InventoryRepository', 'AIPredictionsRepository']

db/repositories/ai_prediction_repository.py

@@ -0,0 +1,120 @@
+from typing import List, Optional
+from datetime import datetime, date
+import logging
+from db.connection import get_connection
+from model.ai_prediction import AIPrediction
+
+logger = logging.getLogger(__name__)
+
+class AIPredictionsRepository:
+    def get_all(self) -> List[AIPrediction]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM ai_predictions ORDER BY prediction_date DESC, product_id")
+                    predictions = [
+                        AIPrediction(
+                            id=row[0],
+                            product_id=row[1],
+                            prediction_date=row[2],
+                            days_until_stockout=row[3],
+                            recommended_order=row[4],
+                            confidence_score=row[5],
+                            created_at=row[6]
+                        ) for row in cur.fetchall()
+                    ]
+                    logger.info(f"Получено {len(predictions)} прогнозов")
+                    return predictions
+        except Exception as e:
+            logger.error(f"Ошибка получения прогнозов: {e}")
+            return []
+
+    def get_by_id(self, prediction_id: int) -> Optional[AIPrediction]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM ai_predictions WHERE id = %s", (prediction_id,))
+                    row = cur.fetchone()
+                    if row:
+                        logger.info(f"Прогноз {prediction_id} найден")
+                        return AIPrediction(*row)
+                    logger.warning(f"Прогноз {prediction_id} не найден")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка получения прогноза {prediction_id}: {e}")
+            return None
+
+    def get_by_product(self, product_id: str, limit: int = 10) -> List[AIPrediction]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM ai_predictions 
+                        WHERE product_id = %s 
+                        ORDER BY prediction_date DESC 
+                        LIMIT %s
+                    """, (product_id, limit))
+                    predictions = [AIPrediction(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(predictions)} прогнозов для товара {product_id}")
+                    return predictions
+        except Exception as e:
+            logger.error(f"Ошибка получения прогноза по товару {product_id}: {e}")
+            return []
+
+    def get_latest_predictions(self) -> List[AIPrediction]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT DISTINCT ON (product_id) *
+                        FROM ai_predictions 
+                        ORDER BY product_id, prediction_date DESC
+                    """)
+                    predictions = [AIPrediction(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(predictions)} последних прогнозов по товарам")
+                    return predictions
+        except Exception as e:
+            logger.error(f"Ошибка получения последних прогнозов по товарам: {e}")
+            return []
+
+    def create_prediction(
+        self,
+        product_id: str,
+        prediction_date: date,
+        days_until_stockout: int,
+        recommended_order: int,
+        confidence_score: float
+    ) -> Optional[int]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        INSERT INTO ai_predictions 
+                        (product_id, prediction_date, days_until_stockout, recommended_order, confidence_score)
+                        VALUES (%s, %s, %s, %s, %s)
+                        RETURNING id
+                    """, (product_id, prediction_date, days_until_stockout, recommended_order, confidence_score))
+
+                    prediction_id = cur.fetchone()[0]
+                    conn.commit()
+                    logger.info(f"Создан новый прогноз ID: {prediction_id} для товара {product_id}")
+                    return prediction_id
+        except Exception as e:
+            logger.error(f"Ошибка создания прогноза: {e}")
+            return None
+
+    def delete_old_predictions(self, older_than_days: int = 90) -> int:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        DELETE FROM ai_predictions 
+                        WHERE prediction_date < CURRENT_DATE - INTERVAL '%s days'
+                    """, (older_than_days,))
+                    deleted_count = cur.rowcount
+                    conn.commit()
+                    logger.info(f"Удалено {deleted_count} старых прогнозов старше {older_than_days} дней")
+                    return deleted_count
+        except Exception as e:
+            logger.error(f"Ошибка удаления старых прогнозов: {e}")
+            return 0

db/repositories/inventory_repository.py

@@ -0,0 +1,162 @@
+# db/repositories/inventory_repository.py
+from typing import List, Optional, Tuple
+from datetime import datetime
+import logging
+from db.connection import get_connection
+from model.inventory import InventoryRecord
+
+logger = logging.getLogger(__name__)
+
+class InventoryRepository:
+    def get_all(self) -> List[InventoryRecord]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM inventory_history ORDER BY scanned_at DESC")
+                    records = [
+                        InventoryRecord(
+                            id=row[0],
+                            robot_id=row[1],
+                            product_id=row[2],
+                            quantity=row[3],
+                            zone=row[4],
+                            row_number=row[5],
+                            shelf_number=row[6],
+                            status=row[7],
+                            scanned_at=row[8],
+                            created_at=row[9]
+                        ) for row in cur.fetchall()
+                    ]
+                    logger.info(f"Получено {len(records)} записей инвентаризации")
+                    return records
+        except Exception as e:
+            logger.error(f"Ошибка получения истории инвентаризации: {e}")
+            return []
+
+    def get_by_id(self, record_id: int) -> Optional[InventoryRecord]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM inventory_history WHERE id = %s", (record_id,))
+                    row = cur.fetchone()
+                    if row:
+                        logger.info(f"Запись инвентаризации {record_id} найдена")
+                        return InventoryRecord(*row)
+                    logger.warning(f"Запись инвентаризации {record_id} не найдена")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка получения записи инвентаризации {record_id}: {e}")
+            return None
+
+    def create_record(
+        self,
+        robot_id: str,
+        product_id: str,
+        quantity: int,
+        zone: str,
+        row_number: int,
+        shelf_number: int,
+        status: str,
+        scanned_at: datetime
+    ) -> Optional[int]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        INSERT INTO inventory_history 
+                        (robot_id, product_id, quantity, zone, row_number, shelf_number, status, scanned_at)
+                        VALUES (%s, %s, %s, %s, %s, %s, %s, %s)
+                        RETURNING id
+                    """, (robot_id, product_id, quantity, zone, row_number, shelf_number, status, scanned_at))
+
+                    record_id = cur.fetchone()[0]
+                    conn.commit()
+                    logger.info(f"Создана новая запись инвентаризации ID: {record_id}")
+                    return record_id
+        except Exception as e:
+            logger.error(f"Ошибка создания записи инвентаризации: {e}")
+            return None
+
+    def get_latest_inventory(self) -> List[InventoryRecord]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT DISTINCT ON (product_id) *
+                        FROM inventory_history 
+                        ORDER BY product_id, scanned_at DESC
+                    """)
+                    records = [InventoryRecord(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(records)} последних записей инвентаризации по товарам")
+                    return records
+        except Exception as e:
+            logger.error(f"Ошибка получения последней записи инвентаризации по каждому товару: {e}")
+            return []
+
+    def get_records_by_product(self, product_id: str, limit: int = 100) -> List[InventoryRecord]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM inventory_history 
+                        WHERE product_id = %s 
+                        ORDER BY scanned_at DESC 
+                        LIMIT %s
+                    """, (product_id, limit))
+                    records = [InventoryRecord(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(records)} записей инвентаризации для товара {product_id}")
+                    return records
+        except Exception as e:
+            logger.error(f"Ошибка получения записи инвентаризации по продукту {product_id}: {e}")
+            return []
+
+    def get_records_by_robot(self, robot_id: str, limit: int = 100) -> List[InventoryRecord]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM inventory_history 
+                        WHERE robot_id = %s 
+                        ORDER BY scanned_at DESC 
+                        LIMIT %s
+                    """, (robot_id, limit))
+                    records = [InventoryRecord(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(records)} записей инвентаризации для робота {robot_id}")
+                    return records
+        except Exception as e:
+            logger.error(f"Ошибка получения записи инвентаризации по роботу {robot_id}: {e}")
+            return []
+
+    def get_records_by_zone(self, zone: str, limit: int = 100) -> List[InventoryRecord]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM inventory_history 
+                        WHERE zone = %s 
+                        ORDER BY scanned_at DESC 
+                        LIMIT %s
+                    """, (zone, limit))
+                    records = [InventoryRecord(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(records)} записей инвентаризации для зоны {zone}")
+                    return records
+        except Exception as e:
+            logger.error(f"Ошибка получения записи инвентаризации по зоне {zone}: {e}")
+            return []
+
+    def get_critical_items(self, hours: int = 24) -> List[InventoryRecord]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM inventory_history 
+                        WHERE status IN ('LOW_STOCK', 'CRITICAL') 
+                        AND scanned_at >= NOW() - INTERVAL '%s hours'
+                        ORDER BY scanned_at DESC
+                    """, (hours,))
+                    records = [InventoryRecord(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(records)} критических товаров за последние {hours} часов")
+                    return records
+        except Exception as e:
+            logger.error(f"Ошибка получения товаров с критическим статусом: {e}")
+            return []

db/repositories/product_repository.py

@@ -0,0 +1,168 @@
+from typing import List, Optional
+import logging
+from db.connection import get_connection
+from model.product import Product
+
+logger = logging.getLogger(__name__)
+
+class ProductRepository:
+    def get_all(self) -> List[Product]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM products ORDER BY id")
+                    products = [
+                        Product(
+                            id=row[0],
+                            name=row[1],
+                            category=row[2],
+                            min_stock=row[3],
+                            optimal_stock=row[4]
+                        ) for row in cur.fetchall()
+                    ]
+                    logger.info(f"Получено {len(products)} товаров")
+                    return products
+        except Exception as e:
+            logger.error(f"Ошибка получения продуктов: {e}")
+            return []
+
+    def get_by_id(self, product_id: str) -> Optional[Product]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM products WHERE id = %s", (product_id,))
+                    row = cur.fetchone()
+                    if row:
+                        logger.info(f"Товар {product_id} найден")
+                        return Product(*row)
+                    logger.warning(f"Товар {product_id} не найден")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка получения товара {product_id}: {e}")
+            return None
+
+    def get_by_category(self, category: str) -> List[Product]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM products WHERE category = %s ORDER BY name", (category,))
+                    products = [Product(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(products)} товаров категории {category}")
+                    return products
+        except Exception as e:
+            logger.error(f"Ошибка получения товаров по категории {category}: {e}")
+            return []
+
+    def create_product(self, product_id: str, name: str, category: str,
+                       min_stock: int = 10, optimal_stock: int = 100) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        INSERT INTO products (id, name, category, min_stock, optimal_stock)
+                        VALUES (%s, %s, %s, %s, %s)
+                    """, (product_id, name, category, min_stock, optimal_stock))
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Создан новый товар {product_id}: {name}")
+                    else:
+                        logger.warning(f"Не удалось создать товар {product_id}")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка создания товара {product_id}: {e}")
+            return False
+
+    def update_product(self, product_id: str, name: str = None, category: str = None,
+                       min_stock: int = None, optimal_stock: int = None) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    updates = []
+                    params = []
+
+                    if name is not None:
+                        updates.append("name = %s")
+                        params.append(name)
+
+                    if category is not None:
+                        updates.append("category = %s")
+                        params.append(category)
+
+                    if min_stock is not None:
+                        updates.append("min_stock = %s")
+                        params.append(min_stock)
+
+                    if optimal_stock is not None:
+                        updates.append("optimal_stock = %s")
+                        params.append(optimal_stock)
+
+                    if not updates:
+                        logger.warning(f"Нет данных для обновления товара {product_id}")
+                        return False
+
+                    params.append(product_id)
+                    query = f"UPDATE products SET {', '.join(updates)} WHERE id = %s"
+
+                    cur.execute(query, params)
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Товар {product_id} успешно обновлен")
+                    else:
+                        logger.warning(f"Товар {product_id} не найден для обновления")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка обновления товара {product_id}: {e}")
+            return False
+
+    def delete_product(self, product_id: str) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("DELETE FROM products WHERE id = %s", (product_id,))
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Товар {product_id} удален")
+                    else:
+                        logger.warning(f"Товар {product_id} не найден для удаления")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка удаления товара {product_id}: {e}")
+            return False
+
+    def search_products(self, search_term: str) -> List[Product]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM products 
+                        WHERE name ILIKE %s OR id ILIKE %s
+                        ORDER BY name
+                    """, (f'%{search_term}%', f'%{search_term}%'))
+                    products = [Product(*row) for row in cur.fetchall()]
+                    logger.info(f"Найдено {len(products)} товаров по запросу '{search_term}'")
+                    return products
+        except Exception as e:
+            logger.error(f"Ошибка поиска товаров по названию '{search_term}': {e}")
+            return []
+
+    def get_low_stock_products(self) -> List[Product]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT DISTINCT p.* 
+                        FROM products p
+                        JOIN inventory_history ih ON p.id = ih.product_id
+                        WHERE ih.status IN ('LOW_STOCK', 'CRITICAL')
+                        AND ih.scanned_at >= NOW() - INTERVAL '1 day'
+                        ORDER BY p.name
+                    """)
+                    products = [Product(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(products)} товаров с низким запасом")
+                    return products
+        except Exception as e:
+            logger.error(f"Ошибка получения товаров с низким запасом: {e}")
+            return []

db/repositories/robot_repository.py

@@ -0,0 +1,174 @@
+from typing import List, Optional
+import logging
+from db.connection import get_connection
+from model.robot import Robot
+
+logger = logging.getLogger(__name__)
+
+class RobotRepository:
+    def get_all(self) -> List[Robot]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM robots ORDER BY id")
+                    robots = [
+                        Robot(
+                            id=row[0],
+                            status=row[1],
+                            battery_level=row[2],
+                            last_update=row[3],
+                            current_zone=row[4],
+                            current_row=row[5],
+                            current_shelf=row[6]
+                        ) for row in cur.fetchall()
+                    ]
+                    logger.info(f"Получено {len(robots)} роботов")
+                    return robots
+        except Exception as e:
+            logger.error(f"Ошибка получения всех роботов: {e}")
+            return []
+
+    def get_by_id(self, robot_id: str) -> Optional[Robot]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM robots WHERE id = %s", (robot_id,))
+                    row = cur.fetchone()
+                    if row:
+                        logger.info(f"Робот {robot_id} найден")
+                        return Robot(*row)
+                    logger.warning(f"Робот {robot_id} не найден")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка получения робота {robot_id}: {e}")
+            return None
+
+    def update_robot(
+        self,
+        robot_id: str,
+        status: str = None,
+        battery_level: int = None,
+        current_zone: str = None,
+        current_row: int = None,
+        current_shelf: int = None
+    ) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    updates = ["last_update = CURRENT_TIMESTAMP"]
+                    params = []
+
+                    if status is not None:
+                        updates.append("status = %s")
+                        params.append(status)
+
+                    if battery_level is not None:
+                        updates.append("battery_level = %s")
+                        params.append(battery_level)
+
+                    if current_zone is not None:
+                        updates.append("current_zone = %s")
+                        params.append(current_zone)
+
+                    if current_row is not None:
+                        updates.append("current_row = %s")
+                        params.append(current_row)
+
+                    if current_shelf is not None:
+                        updates.append("current_shelf = %s")
+                        params.append(current_shelf)
+
+                    params.append(robot_id)
+                    query = f"UPDATE robots SET {', '.join(updates)} WHERE id = %s"
+
+                    cur.execute(query, params)
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Робот {robot_id} успешно обновлен")
+                    else:
+                        logger.warning(f"Робот {robot_id} не найден для обновления")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка обновления робота {robot_id}: {e}")
+            return False
+
+    def get_robots_by_status(self, status: str) -> List[Robot]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM robots WHERE status = %s ORDER BY id", (status,))
+                    robots = [Robot(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(robots)} роботов со статусом {status}")
+                    return robots
+        except Exception as e:
+            logger.error(f"Ошибка получения роботов по статусу {status}: {e}")
+            return []
+
+    def get_low_battery_robots(self, threshold: int = 20) -> List[Robot]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM robots 
+                        WHERE battery_level < %s AND status = 'active'
+                        ORDER BY battery_level ASC
+                    """, (threshold,))
+                    robots = [Robot(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(robots)} роботов с низким зарядом (<{threshold}%)")
+                    return robots
+        except Exception as e:
+            logger.error(f"Ошибка получения роботов с низким зарядом: {e}")
+            return []
+
+    def get_robots_in_zone(self, zone: str) -> List[Robot]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM robots WHERE current_zone = %s ORDER BY id", (zone,))
+                    robots = [Robot(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(robots)} роботов в зоне {zone}")
+                    return robots
+        except Exception as e:
+            logger.error(f"Ошибка получения роботов в зоне {zone}: {e}")
+            return []
+
+    def create_robot(
+        self,
+        robot_id: str,
+        status: str = 'active',
+        battery_level: int = 100
+    ) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        INSERT INTO robots (id, status, battery_level, last_update)
+                        VALUES (%s, %s, %s, CURRENT_TIMESTAMP)
+                    """, (robot_id, status, battery_level))
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Создан новый робот {robot_id}")
+                    else:
+                        logger.warning(f"Не удалось создать робота {robot_id}")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка создания робота {robot_id}: {e}")
+            return False
+
+    def delete_robot(self, robot_id: str) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("DELETE FROM robots WHERE id = %s", (robot_id,))
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Робот {robot_id} удален")
+                    else:
+                        logger.warning(f"Робот {robot_id} не найден для удаления")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка удаления робота {robot_id}: {e}")
+            return False

db/repositories/user_repository.py

@@ -0,0 +1,219 @@
+from typing import List, Optional
+import logging
+from model.user import User
+from db.connection import get_connection
+
+logger = logging.getLogger(__name__)
+
+class UserRepository:
+    def get_all(self) -> List[User]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM users ORDER BY id")
+                    users = [
+                        User(
+                            id=row[0],
+                            email=row[1],
+                            password_hash=row[2],
+                            name=row[3],
+                            role=row[4],
+                            created_at=row[5]
+                        ) for row in cur.fetchall()
+                    ]
+                    logger.info(f"Получено {len(users)} пользователей")
+                    return users
+        except Exception as e:
+            logger.error(f"Ошибка получения пользователей: {e}")
+            return []
+
+    def get_by_id(self, user_id: int) -> Optional[User]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM users WHERE id = %s", (user_id,))
+                    row = cur.fetchone()
+                    if row:
+                        logger.info(f"Пользователь {user_id} найден")
+                        return User(*row)
+                    logger.warning(f"Пользователь {user_id} не найден")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка получения пользователя {user_id}: {e}")
+            return None
+
+    def get_by_email(self, email: str) -> Optional[User]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM users WHERE email = %s", (email,))
+                    row = cur.fetchone()
+                    if row:
+                        logger.info(f"Пользователь с email {email} найден")
+                        return User(*row)
+                    logger.warning(f"Пользователь с email {email} не найден")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка получения пользователя по email {email}: {e}")
+            return None
+
+    def create_user(
+        self,
+        email: str,
+        password_hash: str,
+        name: str,
+        role: str
+    ) -> Optional[User]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        INSERT INTO users (email, password_hash, name, role)
+                        VALUES (%s, %s, %s, %s)
+                        RETURNING id, email, password_hash, name, role, created_at
+                    """, (email, password_hash, name, role))
+
+                    row = cur.fetchone()
+                    conn.commit()
+
+                    if row:
+                        logger.info(f"Создан новый пользователь {email} с ID {row[0]}")
+                        return User(*row)
+                    logger.warning(f"Не удалось создать пользователя {email}")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка создания пользователя {email}: {e}")
+            return None
+
+    def update_user(self, user_id: int, name: str = None, role: str = None) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    updates = []
+                    params = []
+
+                    if name is not None:
+                        updates.append("name = %s")
+                        params.append(name)
+
+                    if role is not None:
+                        updates.append("role = %s")
+                        params.append(role)
+
+                    if not updates:
+                        logger.warning(f"Нет данных для обновления пользователя {user_id}")
+                        return False
+
+                    params.append(user_id)
+                    query = f"UPDATE users SET {', '.join(updates)} WHERE id = %s"
+
+                    cur.execute(query, params)
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Пользователь {user_id} успешно обновлен")
+                    else:
+                        logger.warning(f"Пользователь {user_id} не найден для обновления")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка обновления пользователя {user_id}: {e}")
+            return False
+
+    def delete_user(self, user_id: int) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("DELETE FROM users WHERE id = %s", (user_id,))
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Пользователь {user_id} удален")
+                    else:
+                        logger.warning(f"Пользователь {user_id} не найден для удаления")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка удаления пользователя {user_id}: {e}")
+            return False
+
+    def get_users_by_role(self, role: str) -> List[User]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT * FROM users WHERE role = %s ORDER BY name", (role,))
+                    users = [User(*row) for row in cur.fetchall()]
+                    logger.info(f"Получено {len(users)} пользователей с ролью {role}")
+                    return users
+        except Exception as e:
+            logger.error(f"Ошибка получения пользователей по роли {role}: {e}")
+            return []
+
+    def change_password(self, user_id: int, new_password_hash: str) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        UPDATE users 
+                        SET password_hash = %s 
+                        WHERE id = %s
+                    """, (new_password_hash, user_id))
+                    conn.commit()
+                    success = cur.rowcount > 0
+                    if success:
+                        logger.info(f"Пароль пользователя {user_id} изменен")
+                    else:
+                        logger.warning(f"Пользователь {user_id} не найден для смены пароля")
+                    return success
+        except Exception as e:
+            logger.error(f"Ошибка смены пароля пользователя {user_id}: {e}")
+            return False
+
+    def authenticate_user(self, email: str, password_hash: str) -> Optional[User]:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT * FROM users 
+                        WHERE email = %s AND password_hash = %s
+                    """, (email, password_hash))
+                    row = cur.fetchone()
+                    if row:
+                        logger.info(f"Успешная аутентификация пользователя {email}")
+                        return User(*row)
+                    logger.warning(f"Неудачная аутентификация пользователя {email}")
+                    return None
+        except Exception as e:
+            logger.error(f"Ошибка аутентификации пользователя {email}: {e}")
+            return None
+
+    def is_valid_authenticate(self, email: str, password_hash: str) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("""
+                        SELECT 1 FROM users 
+                        WHERE email = %s AND password_hash = %s
+                    """, (email, password_hash))
+                    is_valid = cur.fetchone() is not None
+                    if is_valid:
+                        logger.info(f"Валидные учетные данные для пользователя {email}")
+                    else:
+                        logger.warning(f"Невалидные учетные данные для пользователя {email}")
+                    return is_valid
+        except Exception as e:
+            logger.error(f"Ошибка проверки учетных данных пользователя {email}: {e}")
+            return False
+
+    def user_exists(self, email: str) -> bool:
+        try:
+            with get_connection() as conn:
+                with conn.cursor() as cur:
+                    cur.execute("SELECT 1 FROM users WHERE email = %s", (email,))
+                    exists = cur.fetchone() is not None
+                    if exists:
+                        logger.info(f"Пользователь с email {email} существует")
+                    else:
+                        logger.info(f"Пользователь с email {email} не существует")
+                    return exists
+        except Exception as e:
+            logger.error(f"Ошибка проверки существования пользователя {email}: {e}")
+            return False

dependencies.txt

@@ -1,4 +1,5 @@
 flask==3.1.2
 python-dotenv
-psycopg-binary
+psycopg2-binary
 pyjwt
+loguru

model/__init__.py

@@ -0,0 +1,7 @@
+from .robot import Robot
+from .product import Product
+from .inventory import InventoryRecord
+from .user import User
+from .ai_prediction import AIPrediction
+
+__all__ = ['Robot', 'Product', 'InventoryRecord', 'User', 'AIPrediction']

model/ai_prediction.py

@@ -0,0 +1,12 @@
+from dataclasses import dataclass
+from datetime import datetime, date
+
+@dataclass
+class AIPrediction:
+    id: int
+    product_id: str
+    prediction_date: date
+    days_until_stockout: int
+    recommended_order: int
+    confidence_score: float
+    created_at: datetime

model/inventory.py

@@ -0,0 +1,14 @@
+from dataclasses import dataclass
+from datetime import datetime
+@dataclass
+class InventoryRecord:
+    id: int
+    robot_id: str
+    product_id: str
+    quantity: int
+    zone: str
+    row_number: int
+    shelf_number: int
+    status: str
+    scanned_at: datetime
+    created_at: datetime

model/product.py

@@ -0,0 +1,9 @@
+from dataclasses import dataclass
+
+@dataclass
+class Product:
+    id: str
+    name: str
+    category: str
+    min_stock: int
+    optimal_stock: int

model/robot.py

@@ -0,0 +1,13 @@
+from dataclasses import dataclass
+from datetime import datetime
+from typing import Optional
+
+@dataclass
+class Robot:
+    id: str
+    status: str
+    battery_level: int
+    last_update: datetime
+    current_zone: Optional[str] = None
+    current_row: Optional[int] = None
+    current_shelf: Optional[int] = None

model/user.py

@@ -1,22 +1,23 @@
 from dataclasses import dataclass
-import json
+from datetime import datetime
 from utils.token import generateKey
 
+
 @dataclass
-class user:
+class User:
     id: int
+    email: str
+    password_hash: str
     name: str
     role: str
-    token: str
+    created_at: datetime
 
-    @classmethod
-    def initialize(cls, email:str, passwd:str):
+    def __init__(self, email: str, passwd: str):
         #us = getUsModel() #возвращает словарь
-        id = 1#us['id']
-        name = 'Bob'#us['name']
-        role = 'Backend'#us['role']
-        token = generateKey(email, passwd)
-        return cls(id=id, name=name, role=role, token=token)
+        self.id = 1#us['id']
+        self.name = 'Bob'#us['name']
+        self.role = 'Backend'#us['role']
+        self.token = generateKey(email, passwd)
 
-    def toJSON(self):
-        return json.dumps({"token": f'{self.token}', "user": {"id": self.id, "role": f'{self.role}', "name": f'{self.name}'}})
+    def toJson(self):
+        return {"user": {"id": self.id, "name": self.name, "role": self.role}, "token": self.token}

utils/PostgressConnect.py

@@ -1,10 +0,0 @@
-import psycopg
-import os
-
-def PSQLConnect():
-    conn = psycopg.connect(os.getenv('POSTDRESS_CONNECTION'))
-    return conn
-
-def PSQLCursor(conn):
-    cur =  conn.cursor()
-    return cur

utils/loadDotEnv.py

@@ -1,12 +1,14 @@
 import os
 from dotenv import load_dotenv
+from loguru import logger as log
 
-def initializeENV():
-    dotenv_path = '../.env'
-    if os.path.exists(dotenv_path):
-        load_dotenv(dotenv_path)
-        print('.env is loaded')
-        return 1
+DOTENV_PATH = '.env'
+
+def initializeENV() -> bool:
+    if os.path.exists(DOTENV_PATH):
+        load_dotenv(DOTENV_PATH)
+        log.info('.env is loaded')
+        return True
     else:
-        print('.env isn`t loaded')
-        return 0
+        log.error('.env isn`t loaded')
+        return False

utils/token.py

@@ -1,7 +1,8 @@
 import jwt
 import os
+from time import time
 
 def generateKey(email, passwd):
     key = os.getenv('KEY')
-    encoded = jwt.encode({f"{email}": f"{passwd}"}, key, algorithm="HS256")
+    encoded = jwt.encode({email: passwd, 'iat': time()}, key, algorithm="HS256")
     return encoded