giaBdZddlZddlZddlmZddlmZmZmZmZddl Z e j e Z GddZ GddZGd d ZdS) a  ENIGMA Inventario - Database Models ==================================== Models per gestione inventario con database MySQL. Usa le tabelle esistenti: - inv_sessioni_inventario - inv_risultati_inventario - inv_cache_prodotti Author: HetGi & Claude Date: 2026-01-14 N)datetime)OptionalDictListAnyc eZdZdZdefdZdZddededed eefd Z deded eefd Z d eded eefd Z dd edede d e fdZddeded eefdZdS)InventorySessionz'Model per gestione sessioni inventario. db_configc||_dSzs Inizializza model. Args: db_config: {host, user, password, database} Nr selfr s ?/var/www/tmov.alphamb/tmov_inventario/models_inventory_fixed.py__init__zInventorySession.__init__#ctj|jd|jd|jd|jddtjjSzCrea connessione database.hostuserpassworddatabaseutf8mb4)rrrrcharset cursorclasspymysqlconnectr cursors DictCursorrs r_get_connectionz InventorySession._get_connection$N''^J/^J/2     r tenant_iduser_idsede_idreturnc|}|} |d||f|}|rVtd|d|d|d||Sd}|||||f||j}t d|d||||S#t$rd} | t d| Yd } ~ ||d Sd } ~ wwxYw#||wxYw) z Crea nuova sessione inventario. Args: tenant_id: ID tenant user_id: ID utente sede_id: ID sede (default 1) Returns: ID sessione creata, None se errore z SELECT id FROM inv_sessioni_inventario WHERE id_tenant = %s AND id_user = %s AND stato = 'aperta' LIMIT 1 uSessione già aperta per user z: idz INSERT INTO inv_sessioni_inventario ( id_tenant, id_user, id_sede, timestamp_inizio, stato ) VALUES ( %s, %s, %s, NOW(), 'aperta' ) zSessione creata: z per user zErrore creazione sessione: N) r#cursorexecutefetchoneloggerwarningclosecommit lastrowidinfo Exceptionrollbackerror) rr&r'r(connr,existingsql session_ides rcreate_sessionzInventorySession.create_session/s##%%"  NNW%  ' ' ' ((H &[[[8TX>[[\\\~, LLNNN JJLLLL)C NN3GW = > > > KKMMM)J KKKJKK'KK L L L LLNNN JJLLLL     MMOOO LL:q:: ; ; ;444 LLNNN JJLLLLL   LLNNN JJLLLLs1AD..AD.. F81F)FFF*G cZ|}|} d}||||f|||S#||wxYw)z Ottiene sessione aperta corrente. Args: tenant_id: ID tenant user_id: ID utente Returns: Dati sessione o None ay SELECT id, id_tenant, id_user, id_sede, timestamp_inizio, stato, note, total_items, total_scans FROM inv_sessioni_inventario WHERE id_tenant = %s AND id_user = %s AND stato = 'aperta' ORDER BY timestamp_inizio DESC LIMIT 1 r#r,r-r.r1)rr&r'r8r,r:s rget_active_sessionz#InventorySession.get_active_sessionbs##%%  C NN3G 4 5 5 5??$$ LLNNN JJLLLL LLNNN JJLLLL -B*B*r;cZ|}|} d}||||f|||S#||wxYw)z Ottiene dettagli sessione. Args: session_id: ID sessione tenant_id: ID tenant Returns: Dati sessione o None a SELECT s.*, u.email as user_email, u.nome as user_name, COUNT(r.id) as items_count FROM inv_sessioni_inventario s LEFT JOIN tenant_users u ON s.id_user = u.id LEFT JOIN inv_risultati_inventario r ON s.id = r.id_sessione WHERE s.id = %s AND s.id_tenant = %s GROUP BY s.id r?rr;r&r8r,r:s r get_sessionzInventorySession.get_sessions##%%  C NN3Y 7 8 8 8??$$ LLNNN JJLLLL LLNNN JJLLLLrANnotec$|}|} |d|f|}|r|dnd}|r|dnd}d} || |||||f||j} t d|d|d| dk||S#t$rd} | t d | Yd } ~ ||d Sd } ~ wwxYw#||wxYw) z Chiude una sessione inventario. Args: session_id: ID sessione tenant_id: ID tenant note: Note opzionali Returns: True se successo, False altrimenti z SELECT COUNT(DISTINCT id) as total_items, COUNT(id) as total_scans FROM inv_risultati_inventario WHERE id_sessione = %s total_itemsr total_scansaN UPDATE inv_sessioni_inventario SET stato = 'chiusa', timestamp_fine = NOW(), total_items = %s, total_scans = %s, note = COALESCE(%s, note) WHERE id = %s AND id_tenant = %s AND stato = 'aperta' z Sessione z chiusa (z items)zErrore chiusura sessione: NF) r#r,r-r.r2rowcountr/r4r1r5r6r7) rr;r&rEr8r,countsrGrHr:affectedr<s r close_sessionzInventorySession.close_sessions##%%#  NN    __&&F39@&//qK39@&//qKC NN3k4Y W X X X KKMMMH KKMJMMMMM N N Na< LLNNN JJLLLL     MMOOO LL9a99 : : :555 LLNNN JJLLLLL   LLNNN JJLLLLs*B!C44 E">1E/E%E""E%%*F limitcZ|}|} d}||||f|||S#||wxYw)z Ottiene sessioni recenti. Args: tenant_id: ID tenant limit: Numero massimo risultati Returns: Lista sessioni a  SELECT s.*, u.email as user_email, u.nome as user_name, COUNT(r.id) as items_count FROM inv_sessioni_inventario s LEFT JOIN tenant_users u ON s.id_user = u.id LEFT JOIN inv_risultati_inventario r ON s.id = r.id_sessione WHERE s.id_tenant = %s GROUP BY s.id ORDER BY s.timestamp_inizio DESC LIMIT %s r#r,r-fetchallr1)rr&rNr8r,r:s rget_recent_sessionsz$InventorySession.get_recent_sessionss##%%  C NN3E 2 3 3 3??$$ LLNNN JJLLLL LLNNN JJLLLLrA)r%)N)rM)__name__ __module__ __qualname____doc__rrr#intrr=r@rDstrboolrLrrRrrr r sE11#$####    111c1C1PXY\P]1111fC#(4.>cchtnB222232RV2222h!!S!!d4j!!!!!!rr ceZdZdZdefdZdZ dded ed ed e ed e d ede efdZ ded ede efdZ dedede fdZdS) InventoryItemz#Model per gestione item inventario.r c||_dSr r rs rrzInventoryItem.__init__rrctj|jd|jd|jd|jddtjjSrrr"s rr#zInventoryItem._get_connectionr$rNFr%r;r&barcode product_data found_in_apiquantitar)c|}|} d} d} d} d} |r|d} |dp|d} t|dtr)|didnd} |d} |d||f|} | r| d|z}|d || df|t d | dd || d| | Sd }|rtj |nd}| }|||||| |||| | || f ||j }t d |d||| | S#t$rd}|td|Yd}~| | dSd}~wwxYw#| | wxYw)u Aggiunge item alla sessione inventario. Args: session_id: ID sessione tenant_id: ID tenant barcode: Codice a barre product_data: Dati prodotto da API (opzionale) found_in_api: Se trovato in Cassanova quantita: Quantità (default 1) Returns: ID item creato, None se errore Nr+ descriptionnamecategorypricez SELECT id, quantita_fisica FROM inv_risultati_inventario WHERE id_sessione = %s AND barcode = %s LIMIT 1 quantita_fisicaz UPDATE inv_risultati_inventario SET quantita_fisica = %s WHERE id = %s zItem aggiornato: u, nuova quantità: a INSERT INTO inv_risultati_inventario ( id_tenant, id_sessione, barcode, codice_prodotto, product_data, found_in_api, manual_entry, scanned_at, nome_prodotto, categoria, quantita_fisica, prezzo_pubblico ) VALUES ( %s, %s, %s, %s, %s, %s, %s, NOW(), %s, %s, %s, %s ) z Item creato: z per sessione zErrore add_item: )r#r,get isinstancedictr-r.r2r/r4r1jsondumpsr3r5r6r7)rr;r&r_r`rarbr8r,codice_prodotto nome_prodotto categoriaprezzo_pubblicor9 new_quantityr: product_json manual_entryitem_idr<s radd_itemzInventoryItem.add_items"##%%C "O MI"O <"."2"24"8"8 , 0 0 ? ? [B,,,,\!C!#!(4.!!!!!!rr|)rVrrlrtypingrrrrlogging getLoggerrSr/r r\r|rZrrrs   ,,,,,,,,,,,,  8 $ $________Dkkkkkkkk\ffffffffffr