Update main.py

main.py

@@ -59,42 +59,44 @@ def crea_database_azienda(database, azienda):
 async def receive_post(request: Request, azione: str, versione :str, database: str, azienda: str):
     data = await request.json()
     print(json.dumps(data, indent=3))
-    conn = get_db_connection()
-    cursor = conn.cursor()
-    crea_database_azienda(database, azienda)
-    insert_query = f"INSERT INTO [{database}].dbo.{azienda}transazioni (datreg, azione, id_transazione, JsonCompleto) VALUES (?, ?, ?, ?)"
-    cursor.execute(insert_query, (datetime.now(), azione, data.get('transazione_id'), json.dumps(data)))
-    conn.commit()
-    cursor.close()
-    conn.close()
+    #conn = get_db_connection()
+    #cursor = conn.cursor()
+    #crea_database_azienda(database, azienda)
+    #insert_query = f"INSERT INTO [{database}].dbo.{azienda}transazioni (datreg, azione, id_transazione, JsonCompleto) VALUES (?, ?, ?, ?)"
+    #cursor.execute(insert_query, (datetime.now(), azione, data.get('transazione_id'), json.dumps(data)))
+    #conn.commit()
+    #cursor.close()
+    #conn.close()
     return JSONResponse(content={"message": "Received", "data": data})  
 
 # ------------------------------------------------| GET |-----------------------------------------------------
 # Result/Status transazione (Questo endpoint viene chiamato da AdHoc per leggere il risultato della transazione) /dati-registri/v1.0/id_transazione/STATUS/Azienda
 @app.get("/{azione}/{versione}/{database}/{azienda}/{id_transazione}/{tipo}")
 async def get_status(azione: str, versione: str, id_transazione: str, tipo: str, database: str, azienda: str):
-    conn = get_db_connection()
-    cursor = conn.cursor()
-    select_query = f"SELECT TOP 1 JsonCompleto FROM [{database}].dbo.{azienda}transazioni WHERE azione = ? AND id_transazione = ? order by id desc"
-    cursor.execute(select_query, (azione, id_transazione))
-    row = cursor.fetchone()
-    cursor.close()
-    conn.close()
+    print('{"message": "OK"}')
+    return '{"message": "OK"}'
+    #conn = get_db_connection()
+    #cursor = conn.cursor()
+    #select_query = f"SELECT TOP 1 JsonCompleto FROM [{database}].dbo.{azienda}transazioni WHERE azione = ? AND id_transazione = ? order by id desc"
+    #cursor.execute(select_query, (azione, id_transazione))
+    #row = cursor.fetchone()
+    #cursor.close()
+    #conn.close()
     # STATUS: Restituisce 303 se esiste la riga della transazione (cioè se per il rentri è terminata)
-    if tipo == "status": 
-        if not row:
-            raise HTTPException(status_code=200, detail="Transazione non terminata")
-        else:
-            raise HTTPException(status_code=303, detail="Transazione terminata")
+    #if tipo == "status": 
+    #    if not row:
+    #        raise HTTPException(status_code=200, detail="Transazione non terminata")
+    #    else:
+    #        raise HTTPException(status_code=303, detail="Transazione terminata")
     # RESULT: Restituisce 303 se esiste la riga della transazione (cioè se per il rentri è terminata)
-    elif tipo == "result": 
-        if not row:
-            raise HTTPException(status_code=404, detail="Transazione non terminata")
-        else: 
-            result = json.loads(row.JsonCompleto)
-            return JSONResponse(content=result)
-    else:
-        raise HTTPException(status_code=404, detail="Endpoint non trovato")
+    #elif tipo == "result": 
+    #    if not row:
+    #        raise HTTPException(status_code=404, detail="Transazione non terminata")
+    #    else: 
+    #        result = json.loads(row.JsonCompleto)
+    #        return JSONResponse(content=result)
+    #else:
+    #    raise HTTPException(status_code=404, detail="Endpoint non trovato")
 
 @app.get("/")
 def read_general():