Quito log para produccion

app.py

@@ -1,5 +1,6 @@
 from flask import Flask, render_template, jsonify, Response
 from conexion import get_connection
+from conexion import init_pool
 from dotenv import load_dotenv
 import os
 
@@ -8,11 +9,16 @@ load_dotenv()
 ip = os.getenv("IPSERVER")
 puerto = os.getenv("PORT")
 modo = os.getenv("MODE", "1")
+no_estado1 = os.getenv("NESTADO1","0")
+no_estado2 = os.getenv("NESTADO2","0")
 monitor1 = os.getenv("MONITOR_ID_1")
 monitor2 = os.getenv("MONITOR_ID_2")
 es_quirofano_1 = os.getenv("IS_QUIRO_1")
 es_quirofano_2 = os.getenv("IS_QUIRO_2")
 tema = os.getenv("THEME", "csm")
+extender = os.getenv("EXTEND")
+interval_refresh = os.getenv("TIME_REFRESH", 10000)
+query = ""
 tema_styles = {
     "csm": {
         "bg1":"#114b94",
@@ -25,31 +31,28 @@ tema_styles = {
 }
 
 app = Flask(__name__)
+init_pool()
 
-def obtener_turnos(mon_id, es_quiro):
-    conn = get_connection()
-    if not conn:
-        return []
+def obtener_turnos(mon_id, qry):
+    conn = None
     try:
+        conn = get_connection()
         cursor = conn.cursor()
-        if es_quiro == "1":
-            cursor.execute("SELECT QUIROFANOS.CODIGO_INTERNO AS CONSULTA, 1 AS ESTADO_CONSULTA, NVL (TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL (TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM (SELECT DISTINCT(CSMK_TURNO.CODIGO_PERSONAL), FP.CODIGO_INTERNO FROM CSMK_TURNO, NOVAHIS.FPERSONA FP WHERE ESTANCIA_ID = 639 AND FECHA = TRUNC(SYSDATE) AND CSMK_TURNO.CODIGO_PERSONAL = FP.CODIGO_PERSONAL) QUIROFANOS LEFT JOIN (SELECT t.* FROM (SELECT CT.CODIGO_PERSONAL, CTM.*, ROW_NUMBER () OVER (PARTITION BY CT.CODIGO_PERSONAL ORDER BY CTM.TURNO_MON_ID DESC) AS RN FROM CSMK_TURNO_MON CTM, CSMK_TURNO CT WHERE     CTM.FECHA = TRUNC (SYSDATE) AND CTM.ESTADO_ID IN (1, 2) AND CTM.MONITOR_ID = :monitor AND CTM.TURNO_ID = CT.TURNO_ID) t WHERE t.RN = 1) TURNOS ON QUIROFANOS.CODIGO_PERSONAL = TURNOS.CODIGO_PERSONAL ORDER BY QUIROFANOS.CODIGO_INTERNO ASC",{'monitor':mon_id})
-        else:
-            cursor.execute("SELECT CONS_ESTADO.CODIGO_IMPRESION AS CONSULTA, CONS_ESTADO.ESTADO_ID AS ESTADO_CONSULTA, NVL(CONS_TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL(CONS_TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM ( SELECT ROW_NUMBER () OVER ( PARTITION BY ESTADO.ESTANCIA_ID ORDER BY ESTADO.CONSULTA_ESTADO_ID DESC ) AS RN, ESTADO.ESTADO_ID, ESTANCIA.* FROM CSMK_CONSULTA_ESTADO ESTADO JOIN CSMK_ESTANCIA ESTANCIA ON ESTADO.ESTANCIA_ID = ESTANCIA.ESTANCIA_ID WHERE ESTADO.FECHA = TRUNC (SYSDATE) AND ESTANCIA.MONITOR_ID = :monitor ) CONS_ESTADO LEFT JOIN ( SELECT t.* FROM ( SELECT TM.*, ROW_NUMBER() OVER ( PARTITION BY TM.ESTANCIA_ID ORDER BY TM.TURNO_MON_ID DESC ) AS RN FROM CSMK_TURNO_MON TM WHERE TM.FECHA = TRUNC (SYSDATE) AND TM.ESTADO_ID IN (1,2) AND TM.MONITOR_ID = :monitor ) t WHERE t.RN = 1 ) CONS_TURNOS ON CONS_ESTADO.ESTANCIA_ID = CONS_TURNOS.ESTANCIA_ID AND CONS_ESTADO.MONITOR_ID = CONS_TURNOS.MONITOR_ID WHERE CONS_ESTADO.RN = 1 ORDER BY CONSULTA ASC",{'monitor':mon_id})
-        
+        cursor.execute(qry,{'monitor':mon_id})
         datos = cursor.fetchall()
         cursor.close()
-        conn.close()
         return datos
     except Exception as e:
         print(f"Error al conectar: {e}")
         return None
+    finally:
+        if conn:
+            conn.close()    
 
 def obtener_pie(mon_id1, mon_id2):
-    conn = get_connection()
-    if not conn:
-        return []
+    conn = None
     try:
+        conn = get_connection()
         cursor = conn.cursor()
         if modo == "2":
             cursor.execute("SELECT MENSAJE FROM CSMK_MONITOR_PIE WHERE MONITOR_ID IN (:monitor, :monitor2) AND INACTIVO = 0 ORDER BY MONITOR_ID, MONITOR_PIE_ID ASC",{'monitor':mon_id1, 'monitor2':mon_id2})
@@ -59,25 +62,56 @@ def obtener_pie(mon_id1, mon_id2):
         mensajes = [fila[0] for fila in cursor.fetchall()]
         mensaje_final = "       ".join(mensajes)
         cursor.close()
-        conn.close()
+        print("Obteniendo el pie bien...")
         return mensaje_final
     except Exception as e:
         print(f"Error al conectar: {e}")
         return None
+    finally:
+        if conn:
+            conn.close()
         
 @app.route('/')
 def index():
     tema_colores = tema_styles.get(tema, tema_styles["csm"])
-    return render_template("index.html", mode=modo, theme=tema, theme_colors=tema_colores, quiro1=es_quirofano_1, quiro2=es_quirofano_2)
+    return render_template("index.html", mode=modo, theme=tema, theme_colors=tema_colores, quiro1=es_quirofano_1, quiro2=es_quirofano_2, refresh_interval = interval_refresh)
 
 @app.route('/api/datos1')
 def api_datos1():
-    filas = obtener_turnos(monitor1, es_quirofano_1)
+
+    if no_estado1 == "1":
+        cons_estado = "SELECT * FROM (SELECT D.*, ROW_NUMBER () OVER (PARTITION BY ESTANCIA_ID ORDER BY RN) AS ORDEN FROM (SELECT ROW_NUMBER () OVER (PARTITION BY ESTADO.ESTANCIA_ID ORDER BY ESTADO.CONSULTA_ESTADO_ID DESC) AS RN, ESTADO.ESTADO_ID, ESTANCIA.* FROM    CSMK_CONSULTA_ESTADO ESTADO JOIN CSMK_ESTANCIA ESTANCIA ON ESTADO.ESTANCIA_ID = ESTANCIA.ESTANCIA_ID WHERE ESTADO.FECHA = TRUNC (SYSDATE) AND ESTANCIA.MONITOR_ID = :monitor UNION ALL SELECT 1 AS RN, 1 AS ESTADO_ID, ESTANCIA.* FROM CSMK_ESTANCIA ESTANCIA WHERE ESTANCIA.MONITOR_ID = :monitor) D) WHERE ORDEN = 1"
+    else:
+        cons_estado = "SELECT ROW_NUMBER () OVER (PARTITION BY ESTADO.ESTANCIA_ID ORDER BY ESTADO.CONSULTA_ESTADO_ID DESC) AS RN, ESTADO.ESTADO_ID, ESTANCIA.* FROM    CSMK_CONSULTA_ESTADO ESTADO JOIN CSMK_ESTANCIA ESTANCIA ON ESTADO.ESTANCIA_ID = ESTANCIA.ESTANCIA_ID WHERE ESTADO.FECHA = TRUNC (SYSDATE) AND ESTANCIA.MONITOR_ID = :monitor"
+    
+    if modo == "2" and extender =="1":
+        query = "WITH BASE AS (SELECT CONS_ESTADO.CODIGO_IMPRESION AS CONSULTA, CONS_ESTADO.ESTADO_ID AS ESTADO_CONSULTA, NVL (CONS_TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL (CONS_TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM ({cons_estado}) CONS_ESTADO LEFT JOIN (SELECT t.* FROM (SELECT TM.*, ROW_NUMBER () OVER (PARTITION BY TM.ESTANCIA_ID ORDER BY TM.TURNO_MON_ID DESC) AS RN FROM CSMK_TURNO_MON TM WHERE     TM.FECHA = TRUNC (SYSDATE) AND TM.ESTADO_ID IN (1, 2) AND TM.MONITOR_ID = :monitor) t WHERE t.RN = 1) CONS_TURNOS ON CONS_ESTADO.ESTANCIA_ID = CONS_TURNOS.ESTANCIA_ID AND CONS_ESTADO.MONITOR_ID = CONS_TURNOS.MONITOR_ID WHERE CONS_ESTADO.RN = 1), numerada AS (SELECT b.*, ROW_NUMBER () OVER (ORDER BY b.CONSULTA ASC) AS rn_global, COUNT (*) OVER () AS total FROM base b) SELECT CONSULTA, ESTADO_CONSULTA, TURNO, ESTADO_TURNO FROM numerada WHERE rn_global <= total / 2 ORDER BY rn_global".format(cons_estado=cons_estado)
+    else:
+        if es_quirofano_1 == "1":
+            query = "SELECT QUIROFANOS.CODIGO_INTERNO AS CONSULTA, 1 AS ESTADO_CONSULTA, NVL (TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL (TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM (SELECT DISTINCT(CSMK_TURNO.CODIGO_PERSONAL), FP.CODIGO_INTERNO FROM CSMK_TURNO, NOVAHIS.FPERSONA FP WHERE ESTANCIA_ID = 639 AND FECHA = TRUNC(SYSDATE) AND CSMK_TURNO.CODIGO_PERSONAL = FP.CODIGO_PERSONAL) QUIROFANOS LEFT JOIN (SELECT t.* FROM (SELECT CT.CODIGO_PERSONAL, CTM.*, ROW_NUMBER () OVER (PARTITION BY CT.CODIGO_PERSONAL ORDER BY CTM.TURNO_MON_ID DESC) AS RN FROM CSMK_TURNO_MON CTM, CSMK_TURNO CT WHERE     CTM.FECHA = TRUNC (SYSDATE) AND CTM.ESTADO_ID IN (1, 2) AND CTM.MONITOR_ID = :monitor AND CTM.TURNO_ID = CT.TURNO_ID) t WHERE t.RN = 1) TURNOS ON QUIROFANOS.CODIGO_PERSONAL = TURNOS.CODIGO_PERSONAL ORDER BY QUIROFANOS.CODIGO_INTERNO ASC"
+        else:
+            query ="SELECT CONS_ESTADO.CODIGO_IMPRESION AS CONSULTA, CONS_ESTADO.ESTADO_ID AS ESTADO_CONSULTA, NVL(CONS_TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL(CONS_TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM ({cons_estado}) CONS_ESTADO LEFT JOIN ( SELECT t.* FROM ( SELECT TM.*, ROW_NUMBER() OVER ( PARTITION BY TM.ESTANCIA_ID ORDER BY TM.TURNO_MON_ID DESC ) AS RN FROM CSMK_TURNO_MON TM WHERE TM.FECHA = TRUNC (SYSDATE) AND TM.ESTADO_ID IN (1,2) AND TM.MONITOR_ID = :monitor ) t WHERE t.RN = 1 ) CONS_TURNOS ON CONS_ESTADO.ESTANCIA_ID = CONS_TURNOS.ESTANCIA_ID AND CONS_ESTADO.MONITOR_ID = CONS_TURNOS.MONITOR_ID WHERE CONS_ESTADO.RN = 1 ORDER BY CONSULTA ASC".format(cons_estado=cons_estado)
+    filas = obtener_turnos(monitor1, query)
     return jsonify(filas)
 
 @app.route('/api/datos2')
 def api_datos2():
-    filas = obtener_turnos(monitor2, es_quirofano_2)
+    global monitor2
+
+    if no_estado2 == "1":
+        cons_estado = "SELECT * FROM (SELECT D.*, ROW_NUMBER () OVER (PARTITION BY ESTANCIA_ID ORDER BY RN) AS ORDEN FROM (SELECT ROW_NUMBER () OVER (PARTITION BY ESTADO.ESTANCIA_ID ORDER BY ESTADO.CONSULTA_ESTADO_ID DESC) AS RN, ESTADO.ESTADO_ID, ESTANCIA.* FROM    CSMK_CONSULTA_ESTADO ESTADO JOIN CSMK_ESTANCIA ESTANCIA ON ESTADO.ESTANCIA_ID = ESTANCIA.ESTANCIA_ID WHERE ESTADO.FECHA = TRUNC (SYSDATE) AND ESTANCIA.MONITOR_ID = :monitor UNION ALL SELECT 1 AS RN, 1 AS ESTADO_ID, ESTANCIA.* FROM CSMK_ESTANCIA ESTANCIA WHERE ESTANCIA.MONITOR_ID = :monitor) D) WHERE ORDEN = 1"
+    else:
+        cons_estado = "SELECT ROW_NUMBER () OVER (PARTITION BY ESTADO.ESTANCIA_ID ORDER BY ESTADO.CONSULTA_ESTADO_ID DESC) AS RN, ESTADO.ESTADO_ID, ESTANCIA.* FROM    CSMK_CONSULTA_ESTADO ESTADO JOIN CSMK_ESTANCIA ESTANCIA ON ESTADO.ESTANCIA_ID = ESTANCIA.ESTANCIA_ID WHERE ESTADO.FECHA = TRUNC (SYSDATE) AND ESTANCIA.MONITOR_ID = :monitor"
+    
+    if modo == "2" and extender =="1":
+        monitor2 = monitor1
+        query = "WITH BASE AS (SELECT CONS_ESTADO.CODIGO_IMPRESION AS CONSULTA, CONS_ESTADO.ESTADO_ID AS ESTADO_CONSULTA, NVL (CONS_TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL (CONS_TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM ({cons_estado}) CONS_ESTADO LEFT JOIN (SELECT t.* FROM (SELECT TM.*, ROW_NUMBER () OVER (PARTITION BY TM.ESTANCIA_ID ORDER BY TM.TURNO_MON_ID DESC) AS RN FROM CSMK_TURNO_MON TM WHERE     TM.FECHA = TRUNC (SYSDATE) AND TM.ESTADO_ID IN (1, 2) AND TM.MONITOR_ID = :monitor) t WHERE t.RN = 1) CONS_TURNOS ON CONS_ESTADO.ESTANCIA_ID = CONS_TURNOS.ESTANCIA_ID AND CONS_ESTADO.MONITOR_ID = CONS_TURNOS.MONITOR_ID WHERE CONS_ESTADO.RN = 1), numerada AS (SELECT b.*, ROW_NUMBER () OVER (ORDER BY b.CONSULTA ASC) AS rn_global, COUNT (*) OVER () AS total FROM base b) SELECT CONSULTA, ESTADO_CONSULTA, TURNO, ESTADO_TURNO FROM numerada WHERE rn_global > total / 2 ORDER BY rn_global".format(cons_estado=cons_estado)
+    else:
+        if es_quirofano_2 == "1":
+            query = "SELECT QUIROFANOS.CODIGO_INTERNO AS CONSULTA, 1 AS ESTADO_CONSULTA, NVL (TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL (TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM (SELECT DISTINCT(CSMK_TURNO.CODIGO_PERSONAL), FP.CODIGO_INTERNO FROM CSMK_TURNO, NOVAHIS.FPERSONA FP WHERE ESTANCIA_ID = 639 AND FECHA = TRUNC(SYSDATE) AND CSMK_TURNO.CODIGO_PERSONAL = FP.CODIGO_PERSONAL) QUIROFANOS LEFT JOIN (SELECT t.* FROM (SELECT CT.CODIGO_PERSONAL, CTM.*, ROW_NUMBER () OVER (PARTITION BY CT.CODIGO_PERSONAL ORDER BY CTM.TURNO_MON_ID DESC) AS RN FROM CSMK_TURNO_MON CTM, CSMK_TURNO CT WHERE     CTM.FECHA = TRUNC (SYSDATE) AND CTM.ESTADO_ID IN (1, 2) AND CTM.MONITOR_ID = :monitor AND CTM.TURNO_ID = CT.TURNO_ID) t WHERE t.RN = 1) TURNOS ON QUIROFANOS.CODIGO_PERSONAL = TURNOS.CODIGO_PERSONAL ORDER BY QUIROFANOS.CODIGO_INTERNO ASC"
+        else:
+            query ="SELECT CONS_ESTADO.CODIGO_IMPRESION AS CONSULTA, CONS_ESTADO.ESTADO_ID AS ESTADO_CONSULTA, NVL(CONS_TURNOS.CODIGO_TURNO, NULL) AS TURNO, NVL(CONS_TURNOS.ESTADO_ID, 2) AS ESTADO_TURNO FROM ({cons_estado}) CONS_ESTADO LEFT JOIN ( SELECT t.* FROM ( SELECT TM.*, ROW_NUMBER() OVER ( PARTITION BY TM.ESTANCIA_ID ORDER BY TM.TURNO_MON_ID DESC ) AS RN FROM CSMK_TURNO_MON TM WHERE TM.FECHA = TRUNC (SYSDATE) AND TM.ESTADO_ID IN (1,2) AND TM.MONITOR_ID = :monitor ) t WHERE t.RN = 1 ) CONS_TURNOS ON CONS_ESTADO.ESTANCIA_ID = CONS_TURNOS.ESTANCIA_ID AND CONS_ESTADO.MONITOR_ID = CONS_TURNOS.MONITOR_ID WHERE CONS_ESTADO.RN = 1 ORDER BY CONSULTA ASC".format(cons_estado=cons_estado)
+    filas = obtener_turnos(monitor2, query)
     return jsonify(filas)
 
 @app.route('/api/footer')

conexion.py

@@ -1,13 +1,20 @@
 import os  
 from dotenv import load_dotenv  
-#import cx_Oracle
 import oracledb  
 
 load_dotenv()  
 
+# Inicializar el cliente Oracle (Solo una vez al iniciar la app)
 oracledb.init_oracle_client(lib_dir=os.getenv("ORA_DIRECTORY"))  
 
-def get_connection():
+# Variable global para almacenar el pool
+db_pool = None
+
+def init_pool():
+    """
+    Esta función debe llamarse una sola vez al arrancar el servidor (ej. en el main)
+    """
+    global db_pool
     try:
         user = os.getenv("DB_USER")  
         password = os.getenv("DB_PASSWORD")  
@@ -15,13 +22,29 @@ def get_connection():
         port = os.getenv("DB_PORT", "1521")  
         sid = os.getenv("DB_SID")  
         
-        #dsn = cx_Oracle.makedsn(host, port, sid=sid)
         dsn = oracledb.makedsn(host, port, sid=sid)  
         
-        #connection = cx_Oracle.connect(user=user, password=password, dsn=dsn)
-        connection = oracledb.connect(user=user, password=password, dsn=dsn)
-
-        return connection
+        # Creamos el pool
+        db_pool = oracledb.create_pool(
+            user=user, 
+            password=password, 
+            dsn=dsn, 
+            min=2,   # Conexiones mínimas siempre abiertas
+            max=10,  # Máximo de conexiones simultáneas permitidas
+            increment=1
+        )
+        print("Pool de conexiones creado exitosamente")
     except oracledb.DatabaseError as e:
-        print(f"Error al conectar a la base de datos: {e}")
+        print(f"Error al crear el pool: {e}")
+        raise
+
+def get_connection():
+    """
+    Obtiene una conexión del pool. 
+    IMPORTANTE: El que llama a esta función DEBE devolver la conexión al pool.
+    """
+    try:
+        return db_pool.acquire()
+    except oracledb.DatabaseError as e:
+        print(f"Error al adquirir conexión del pool: {e}")
         raise

example.env

@@ -10,5 +10,9 @@ MODE="1"
 THEME="csm"
 MONITOR_ID_1=0
 MONITOR_ID_2=0
+EXTEND=0
+NESTADO1=0
+NESTADO2=1
 IS_QUIRO_1=0
 IS_QUIRO_2=0 
+TIME_REFRESH=10000

static/js/scripts.js

@@ -34,6 +34,7 @@ function cargarTabla(endpoint, tablaId, esQuiro) {
 
                 const td2 = document.createElement("td");
                 const estadoConsulta = fila[1];
+                const turno = fila[2];
                 const estadoTurno = fila[3];
 
                 if (estadoConsulta == 0) {
@@ -100,12 +101,15 @@ function cargarTabla(endpoint, tablaId, esQuiro) {
                     td2.className = `border bg-[#a9a9a9] align-middle ${sizeClass}`;
                 }
 
-                if (estadoAnterior[id] === 2 && estadoTurno === 1) {
+                if (
+                    (estadoAnterior[id]?.estado !== 1 && estadoTurno === 1) || 
+                    (estadoAnterior[id]?.turno !== turno && estadoTurno === 1) 
+                ) {
                     sonido.currentTime = 0;
                     sonido.play().catch(err => console.warn("No se pudo reproducir el sonido: ", err));
                 }
 
-                estadoAnterior[id] = estadoTurno;
+                estadoAnterior[id] = {estado: estadoTurno, turno: turno};
                 tr.appendChild(td2);
                 tbody.appendChild(tr);
             });
@@ -139,5 +143,5 @@ function actualizarTablas() {
 
 //cargarFooter();
 actualizarTablas();
-setInterval(actualizarTablas, 20000);
+setInterval(actualizarTablas, window.refreshInterval);
 //setInterval(cargarFooter, 45000);

templates/index.html

@@ -8,6 +8,7 @@
     <script>
         const quiro1 = "{{ quiro1 }}"; 
         const quiro2 = "{{ quiro2 }}";
+        
     </script>
     <script src="{{ url_for('static', filename='js/utils.js') }}"></script>
     <script src="{{ url_for('static', filename='js/scripts.js') }}" defer></script>
@@ -62,8 +63,8 @@
             </div>
         {% else %}
             <div class="md:w-1/2 w-full flex items-center bg-black">
-                <!--<video src="{{ url_for('static', filename='media/'+ theme +'.mp4') }}" class="w-full shadow-md" autoplay muted loop
-                    preload="none"></video>-->
+                <video src="{{ url_for('static', filename='media/'+ theme +'.mp4') }}" class="w-full shadow-md" autoplay muted loop
+                    preload="none"></video>
             </div>
             <div class="md:w-1/2 w-full overflow-hidden">
                 <table class="min-w-full text-center text-white text-4xl table-fixed border-collapse h-full">
@@ -95,4 +96,5 @@
 </html>
 <script> 
     window.themeColors = JSON.parse(document.getElementById('theme-data').textContent.trim());
+    window.refreshInterval = {{ refresh_interval | safe }};
 </script>