Proyecto terminado

.gitattributes

@@ -33,3 +33,4 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
 *.zip filter=lfs diff=lfs merge=lfs -text
 *.zst filter=lfs diff=lfs merge=lfs -text
 *tfevents* filter=lfs diff=lfs merge=lfs -text
+database/anhelados.db filter=lfs diff=lfs merge=lfs -text

.gitignore

@@ -0,0 +1,2 @@
+__pycache__/
+__init__.py

Dockerfile

@@ -0,0 +1,15 @@
+# Usa una imagen base de Python
+FROM python:3.9
+# Establece el directorio de trabajo
+WORKDIR /code
+
+# Copia los archivos necesarios al contenedor
+COPY ./requirements.txt /code/requirements.txt
+RUN pip install --no-cache-dir -r /code/requirements.txt
+
+COPY . .
+
+RUN chmod -R 777 /code
+
+# Comando para ejecutar la aplicación
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]

app.py

@@ -0,0 +1,52 @@
+# uvicorn app:app --host localhost --port 7860 --reload
+from library.librerias import *
+from routers.routers import *
+
+
+app = FastAPI(
+    title="API de la heladería Anhelados",
+    description="Esta es la API de la microempresa Anhelados, la cual se dedica a la venta de helados y postres. Aquí se pueden realizar operaciones CRUD para los recursos de la empresa.",
+    version="2.8.7",
+    openapi_url="/anhelados-openapi.json",
+    docs_url="/anhelados-docs",
+    redoc_url="/anhelados-redoc",
+    contact={
+        "name": "Anhelados",
+        "url": "https://www.anhelados.com",
+        "email": "[email protected]",
+    },
+    license_info={"name": "MIT", "url": "https://opensource.org/licenses/MIT"},
+)
+
+# CORS
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+
+# saludo
+@app.get("/", summary="Saludo", description="Saludo de la API")
+def read_root():
+    return {"message": "Bienvenido a la API de la heladeria"}
+
+
+# Routers
+
+app.router.include_router(almacen.router)
+app.router.include_router(clientes.router)
+app.router.include_router(detalle_pedidos.router)
+app.router.include_router(detalle_ventas.router)
+app.router.include_router(empleados.router)
+app.router.include_router(gastos_imprevistos.router)
+app.router.include_router(gastos.router)
+app.router.include_router(insumos.router)
+app.router.include_router(maquinas.router)
+app.router.include_router(pedidos_proveedor.router)
+app.router.include_router(produccion.router)
+app.router.include_router(productos.router)
+app.router.include_router(registro_energetico.router)
+app.router.include_router(ventas.router)

database/anhelados.db

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:201772d7fc1f716aeb890fdb6e926c21ed8dba8f10fd90f95e0ab297c0f0ca46
+size 3162112

database/conexion.py

@@ -0,0 +1,49 @@
+from library.librerias import sqlite3, Queue, threading
+
+
+DB_PATH = "database/anhelados.db"
+
+
+class DatabaseConnection:
+    """
+    Clase para gestionar las conexiones a la base de datos con un pool.
+    """
+
+    _instance = None
+    _lock = threading.Lock()
+    _connection_pool = Queue(maxsize=5)
+
+    def __new__(cls):
+        """
+        Crea una nueva instancia de la clase si no existe.
+        """
+        with cls._lock:
+            if cls._instance is None:
+                cls._instance = super().__new__(cls)
+                cls._instance.conn = cls._instance._create_connection()
+        return cls._instance
+
+    def _create_connection(self):
+        """
+        Crea una conexión a la base de datos.
+        """
+        if not self._connection_pool.empty():
+            return self._connection_pool.get()
+        else:
+            connection = sqlite3.connect(DB_PATH)
+            connection.row_factory = sqlite3.Row
+            return connection
+
+    def get_connection(self):
+        """
+        Obtener el objeto de conexión de la base de datos.
+        """
+        return self._instance._create_connection()
+
+    def release_connection(self):
+        """
+        Liberar la conexión de nuevo al pool.
+        """
+        if self._instance is not None:
+            self._connection_pool.put(self._instance.conn)
+            self._instance.conn = None  # Marcar la instancia como sin conexión

library/librerias.py

@@ -0,0 +1,21 @@
+# librerias propias del lenguaje
+from datetime import datetime
+from datetime import date
+import os
+
+# librerias para la API
+from pydantic import BaseModel
+from fastapi import FastAPI, HTTPException
+from fastapi.middleware.cors import CORSMiddleware
+from fastapi.responses import FileResponse
+from fastapi import APIRouter, Depends, status
+import uvicorn
+
+# importar librerias para la conexion a la base de datos
+from queue import Queue
+import sqlite3
+import threading
+
+
+# clase para la conexion a la base de datos
+from database.conexion import DatabaseConnection

models/almacen.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class Almacen(BaseModel):
+    ID_Almacen: int
+    ID_Insumo: Optional[int]
+    Cantidad_Actual: Optional[int]
+    Cantidad_Minima: Optional[int]

models/clientes.py

@@ -0,0 +1,21 @@
+from pydantic import BaseModel
+
+"""
+CREATE TABLE clientes (
+  ID_Proveedor INTEGER PRIMARY KEY AUTOINCREMENT,
+  Nombre TEXT,
+  Contacto TEXT,
+  Direccion TEXT
+);
+"""
+
+
+class Clientes(BaseModel):
+    ID_Proveedor: int
+    Nombre: str
+    Contacto: str
+    Direccion: str
+
+
+class SearchClientes(BaseModel):
+    nombre: str = ""

models/detalle_pedidos.py

@@ -0,0 +1,8 @@
+from pydantic import BaseModel
+
+
+class DetallePedidos(BaseModel):
+    ID_Pedido: int
+    ID_Insumo: int
+    Cantidad: int
+    Costo_Unitario: float

models/detalle_ventas.py

@@ -0,0 +1,8 @@
+from pydantic import BaseModel
+
+
+class DetalleVentas(BaseModel):
+    ID_Venta: int
+    ID_Producto: int
+    Cantidad: int
+    Precio_Unitario: float

models/empleados.py

@@ -0,0 +1,10 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class Empleados(BaseModel):
+    ID_Empleado: int
+    Nombre: str
+    Apellido: str
+    Sueldo: float
+    Fecha_Inicio: Optional[str]

models/gastos.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class Gastos(BaseModel):
+    ID_Gasto: int
+    Tipo: str
+    Monto: float
+    Fecha: Optional[str]

models/gastos_imprevistos.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class GastosImprevistos(BaseModel):
+    ID_Gasto_Imprevisto: int
+    Descripcion: str
+    Monto: float
+    Fecha: Optional[str]

models/insumos.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+
+
+class Insumos(BaseModel):
+    ID_Insumo: int
+    Descripcion: str
+    Tipo: str
+    Costo: float
+    Cantidad: int

models/maquinas.py

@@ -0,0 +1,8 @@
+from pydantic import BaseModel
+
+
+class Maquinas(BaseModel):
+    ID_Maquina: int
+    Tipo: str
+    Capacidad: int
+    Consumo_Energetico: float

models/pedidos_proveedor.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class PedidosProveedor(BaseModel):
+    ID_Pedido: int
+    ID_Proveedor: int
+    Fecha: Optional[str]
+    Total: float

models/produccion.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class Produccion(BaseModel):
+    ID_Produccion: int
+    ID_Maquina: int
+    Fecha: Optional[str]
+    Cantidad_Producida: int

models/productos.py

@@ -0,0 +1,7 @@
+from pydantic import BaseModel
+
+
+class Productos(BaseModel):
+    ID_Producto: int
+    Nombre: str
+    Precio: float

models/registro_energetico.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class RegistroEnergetico(BaseModel):
+    ID_Registro: int
+    ID_Maquina: int
+    Fecha: Optional[str]
+    Consumo: float

models/ventas.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+class Ventas(BaseModel):
+    ID_Venta: int
+    Fecha: Optional[str]
+    ID_Empleado: int
+    Total: float

requirements.txt

@@ -0,0 +1,2 @@
+fastapi
+uvicorn