{{i^dZddlZddlZddlmZddlmZmZmZmZddl 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 ddededed eefd Z d eded eefdZ dd edede d e fdZddeded eefdZd edede d e fdZd S)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/app/models/inventory.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     rB 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) a Crea nuova sessione inventario. Args: tenant_id: ID tenant user_id: ID utente sede_id: ID sede (default 17117 - Sales Point principale) 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 u$Sessione 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 &agaaQYZ^Q_aabbb~, 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 Nc|}|} d}||g}||dz }|||dz }||||||S#||wxYw)a/ Ottiene sessione aperta corrente per una sede specifica. Args: tenant_id: ID tenant user_id: ID utente sede_id: ID sede (opzionale - se None, ritorna prima sessione trovata) Returns: Dati sessione o None a SELECT s.id, s.id_tenant, s.id_user, s.id_sede, s.timestamp_inizio, s.stato, s.note, s.nome_sessione, COUNT(DISTINCT r.id) as total_items, SUM(r.quantita_fisica) as total_scans FROM inv_sessioni_inventario s LEFT JOIN inv_risultati_inventario r ON s.id = r.id_sessione WHERE s.id_tenant = %s AND s.id_user = %s AND s.stato = 'aperta' Nz AND s.id_sede = %szt GROUP BY s.id ORDER BY s.timestamp_inizio DESC LIMIT 1 )r#r,appendr-r.r1)rr&r'r(r8r,r:paramss rget_active_sessionz#InventorySession.get_active_sessioncs##%%  C )F",, g&&&  C NN3 ' ' '??$$ LLNNN JJLLLL LLNNN JJLLLLs AB##*C 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#r,r-r.r1)rr;r&r8r,r:s r get_sessionzInventorySession.get_sessions##%%  C NN3Y 7 8 8 8??$$ LLNNN JJLLLL LLNNN JJLLLL -B*B*notec"|}|} |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_scansa UPDATE inv_sessioni_inventario SET stato = 'chiusa', timestamp_fine = NOW(), total_items = %s, total_scans = %s 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 NN3k:y Q R R R KKMMMH KKMJMMMMM N N Na< LLNNN JJLLLL     MMOOO LL9a99 : : :555 LLNNN JJLLLLL   LLNNN JJLLLLs*B C33 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 JJLLLLrDnamec|}|} d}|||||f||j}t d|d||dk||S#t$rd}| t d|Yd}~||dSd}~wwxYw#||wxYw)z Aggiorna nome sessione. Args: session_id: ID sessione tenant_id: ID tenant name: Nome sessione Returns: True se successo, False altrimenti z UPDATE inv_sessioni_inventario SET nome_sessione = %s WHERE id = %s AND id_tenant = %s zNome sessione z aggiornato: rzErrore update nome sessione: NF r#r,r-r2rIr/r4r1r5r6r7) rr;r&rSr8r,r:rKr<s rupdate_session_namez$InventorySession.update_session_names9##%% C NN3z9 = > > > KKMMMH KKHHH$HH I I Ia< LLNNN JJLLLL     MMOOO LL<<< = = =555 LLNNN JJLLLLL   LLNNN JJLLLL*AB.. D81D)DDD*E )r%N)rM)__name__ __module__ __qualname____doc__rrr#intrr=rArCstrboolrLrrRrVrrr r s11#$####    111c1C1T\]`Ta1111h**C*#**W_`dWe****ZcchtnB111131RV1111f!!S!!d4j!!!!F"c"c""QU""""""rr ceZdZdZdefdZdZ dded ed ed e ed e d edede efdZ dded edede efdZ dedede fdZdededede fdZdS) InventoryItemz#Model per gestione item inventario.r c||_dSr r rs rrzInventoryItem.__init__/rrctj|jd|jd|jd|jddtjjSrrr"s rr#zInventoryItem._get_connection8r$rNFr;r&barcode product_data found_in_apiquantitaid_seder)c$|}|} d} d} d} d} |r|d} |dp|d} t|dtr)|didnd} |dg}|r/t |dkr|dd} nd} | 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+ descriptionrScategorypricesrvaluez 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, id_sede, 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, %s, NOW(), %s, %s, %s, %s ) z Item creato: z per sessione zErrore add_item: )r#r,get isinstancedictlenr-r.r2r/r4r1jsondumpsr3r5r6r7)rr;r&rfrgrhrirjr8r,codice_prodotto nome_prodotto categoriaprezzo_pubblicornr9 new_quantityr: product_json manual_entryitem_idr<s radd_itemzInventoryItem.add_itemCs="##%%I "O MI"O +"."2"24"8"8 , 0 0 ? ? [1K/K%K""K%%*Lc|}|} |rd}|||||fnd}||||f|||S#||wxYw)z0Ottiene items di una sessione filtrati per sede.z SELECT * FROM inv_risultati_inventario WHERE id_sessione = %s AND id_tenant = %s AND id_sede = %s ORDER BY scanned_at DESC z SELECT * FROM inv_risultati_inventario WHERE id_sessione = %s AND id_tenant = %s ORDER BY scanned_at DESC rP)rr;r&rjr8r,r:s rget_session_itemszInventoryItem.get_session_itemss##%%  = sZG$DEEEE sZ$;<<<??$$ LLNNN JJLLLL LLNNN JJLLLLs A B*Cr~c|}|} d}||||f||j}t d|d|dk||S#t$rd}| t d|Yd}~||dSd}~wwxYw#||wxYw)z Elimina un item dalla sessione. Args: item_id: ID item session_id: ID sessione Returns: True se successo, False altrimenti zu DELETE FROM inv_risultati_inventario WHERE id = %s AND id_sessione = %s Item z eliminatorzErrore delete_item: NFrU)rr~r;r8r,r:rKr<s r delete_itemzInventoryItem.delete_items2##%% C NN3* 5 6 6 6 KKMMMH KK3333 4 4 4a< LLNNN JJLLLL     MMOOO LL333 4 4 4555 LLNNN JJLLLLL   LLNNN JJLLLLs*AB++ D51D&DDD*Er{c|}|} d}|||||f||j}t d|d||dk||S#t$rd}| t d|Yd}~||dSd}~wwxYw#||wxYw)u  Modifica la quantità di un item esistente. Args: item_id: ID item session_id: ID sessione new_quantity: Nuova quantità Returns: True se successo, False altrimenti z UPDATE inv_risultati_inventario SET quantita_fisica = %s WHERE id = %s AND id_sessione = %s ru aggiornato a quantità rzErrore update_item_quantity: NFrU) rr~r;r{r8r,r:rKr<s rupdate_item_quantityz"InventoryItem.update_item_quantitys9##%% C NN3w C D D D KKMMMH KKQQQ<QQ R R Ra< LLNNN JJLLLL     MMOOO LL<<< = = =555 LLNNN JJLLLLL   LLNNN JJLLLLrW)NFreNrX)rYrZr[r\rrr#r]r^rr_rrrrrr`rrrbrb,sR--#$####    LQ37]]3]3]]'~]DH]]-0]2E0E#1E&E##E&&*Fc|}|} d}||||f|}|rJ|drBt j|d||S ||dS#t$rP}t d|Yd}~||dSd}~wwxYw#||wxYw)z Recupera prodotto dalla cache. Args: tenant_id: ID tenant barcode: Codice a barre Returns: Dati prodotto o None se non in cache o scaduto z SELECT dati_cassanova, cache_timestamp, ttl FROM inv_cache_prodotti WHERE id_tenant = %s AND codice_barcode = %s AND TIMESTAMPDIFF(SECOND, cache_timestamp, NOW()) < ttl dati_cassanovaNzErrore get_cached_product: ) r#r,r-r.ruloadsr1r5r/r7)rr&rfr8r,r:resultr<s rget_cached_productzProductCache.get_cached_productsH##%% C NN3G 4 5 5 5__&&F <&!12 <z&)9":;; LLNNN JJLLLL LLNNN JJLLLLL     LL:q:: ; ; ;444 LLNNN JJLLLLL   LLNNN JJLLLLs*AC D)D$6D,$D))D,,*EqueryrNc|}|} t|dkr*g||Sd}d|d}||||||f|}g} |D]s} | dri t j| d} | | ;#t j $r&t d| dYowxYwtt dt| d|| ||S#t$rQ} t d | gcYd } ~ ||Sd } ~ wwxYw#||wxYw) a Cerca prodotti nella cache locale per nome. Args: tenant_id: ID tenant query: Testo da cercare (minimo 3 caratteri) limit: Numero massimo risultati Returns: Lista prodotti trovati a SELECT codice_barcode, dati_cassanova FROM inv_cache_prodotti WHERE id_tenant = %s AND TIMESTAMPDIFF(SECOND, cache_timestamp, NOW()) < ttl AND ( LOWER(dati_cassanova) LIKE LOWER(%s) OR LOWER(codice_barcode) LIKE LOWER(%s) ) LIMIT %s %rzJSON invalido per barcode codice_barcodezTrovati z prodotti per query: zErrore search_products_local: N)r#r,rtr1r-rQrurr?JSONDecodeErrorr/r7r4r5) rr&rrNr8r,r:search_patternresultsproductsrowproductr<s rsearch_products_localz"ProductCache.search_products_locals##%%* 5zzA~~J LLNNN JJLLLLE C*\\\N NN3NNE R S S Soo''GH [ ['([["&*S1A-B"C"C 0000/[[[ %Y#FVBW%Y%YZZZZZ[ [ KKN3x==NNuNN O O O LLNNN JJLLLL     LL=!== > > >IIIII LLNNN JJLLLL   LLNNN JJLLLLsZE,'AE,,/CE,2DE,D2E,, G6GGG GG *G4rX)r)r)rYrZr[r\rrr#r]r^r_rlistrrrrrr`rrrrs"00#$####    5911s1S1#'1.11=A1111f//$/C/#////b!C!#!(4.!!!!F99s939s9TXY]T^999999rr)r\rrurtypingrrrrlogging getLoggerrYr/r rbrr`rrrs   ,,,,,,,,,,,,  8 $ $QQQQQQQQhUUUUUUUUpWWWWWWWWWWr