a{iΗdZddlmZmZmZmZddlmZddlmZddl Z ddl Z e j e Z ede dZd Zd Zed d g edZeddg edZedd g edZedd g edZeddg edZedd g edZeddg edZedd g edZedd g edZed dg ed!Zed"d#g ed$Zed%d&g ed'Zedd#g ed(Zed)d g ed*Zed+dg ed,Z ed-dg ed.Z!ed/d g ed0Z"ed1d g ed2Z#ed3d g ed4Z$dS)5a= ENIGMA Inventario - API Routes FIXED v2 ========================================= Endpoints REST con FIX per: 1. Isolamento filiali (sede_id filtering) 2. Gestione nomi sessioni (nome_sessione field) 3. Chiusura sessioni pulita (no note override) Author: HetGi & Claude Date: 2026-01-21 (ISOLAMENTO FILIALI FIX) ) Blueprintrequestjsonifyrender_templatewraps)datetimeN inventoryz/api/v1/inventory) url_prefixc<tfd}|S)zDecorator auth (mock per demo).c6dddddt_|i|S)Nzdemo@studium.itadmin)id tenant_idemailrole)ruser)argskwargsfs =/var/www/tmov.alphamb/tmov_inventario/app/routes/inventory.py decoratedzrequire_auth..decorateds6&    q$!&!!!r)rrs` r require_authrs4 1XX""""X" rcddlm}tjddtjddtjddtjd d d }tjd }|st d |||S)zFactory per InventoryService.r)create_inventory_serviceDB_HOST localhostDB_USER enigma_user DB_PASSWORD arcana2026DB_NAMEenigma)hostrpassworddatabaseCASSANOVA_API_KEYz'CASSANOVA_API_KEY non trovata nel .env!)app.services.inventory_servicerosgetenv ValueError)r db_configapi_keys r get_servicer0'sGGGGGG )[11 )]33Im\::Ii22 Ii+,,G DBCCC # #Iw 7 77rz /salespointsGET)methodsc6 t}tjd}ddl}|jd i|jj}||jj }| d||f| }| | tdd|iddfS#t$rH}td |td t#|d d fcYd}~Sd}~wwxYw)zARecupera tutti i Sales Points da inv_sedi con conteggio prodotti.rrNu SELECT s.id, s.nome as name, s.indirizzo as address, s.città as city, COUNT(DISTINCT p.codice_barcode) as product_count FROM inv_sedi s LEFT JOIN inv_cache_prodotti p ON p.id_tenant = %s AND JSON_SEARCH(p.dati_cassanova, 'one', s.id, NULL, '$.prices[*].idSalesPoint') IS NOT NULL WHERE s.id_tenant = %s GROUP BY s.id ORDER BY s.nome T salespointssuccessdatazErrore get salespoints: Fr6error)r0rrpymysqlconnect session_modelr.cursorcursors DictCursorexecutefetchallcloser Exceptionloggerr:str)servicerr=connr@r4es rget_salespointsrL>sL#A--L- wAA!6!@AAW_788   # % % %oo''   {       AAA 33344453q66::;;S@@@@@@@AsCC D=D DDz/products/syncPOSTc@ t}tjd}||}t d|ddfS#t $rH}t d|t dt|ddfcYd }~Sd }~wwxYw) z Sincronizza TUTTI i prodotti da Cassanova. Returns: { "success": true, "data": { "total": 1234, "cached": 1230, "errors": 4 } } rTr5r8z Errore sync: Fr9r;N) r0rrsync_all_productsrrFrGr:rH)rIrresultrKs r sync_productsrQls A--L- **955       AAA (Q(()))53q66::;;S@@@@@@@AsAA B=BBBz /cache/infoc ( t}tjd}ddl}|t jddt jddt jdd t jd d d |jj }| }| d|f| }| | td|dpd|dr|dnddddfS#t$rH}t d|tdt%|ddfcYd}~Sd}~wwxYw)z Ritorna info sulla cache locale.rrNrrr r!r"r#r$r%utf8mb4)r&rr'r(charset cursorclassz SELECT COUNT(*) as total, MAX(cache_timestamp) as last_sync FROM inv_cache_prodotti WHERE id_tenant = %s Ttotal last_sync) product_countrWr5r8zErrore get cache info: Fr9r;)r0rrr=r>r+r,rArBr@rCfetchonerEr isoformatrFrGr:rH)rIrr=rJr@rPrKs rget_cache_infor[s#A--L- 9k229m44Y}l;;Yy(332     \     ""  !'!5A@F{@S]VK0::<<U>UV`>a>a0c0cdd **4 +r@rArBappendrCrDrErrdrFrGr:rH) rIrrrr=r.rJr@sqlparamsrrKs rget_recent_sessionsrs'A--L- GL$$Wb1122 ((99 )3 w++++W_788   . & &C MM#m,, - - - 99 esF###??$$  $X       AAA .1..///53q66::;;S@@@@@@@AsE%E(( F:2=F5/F:5F:z/session/c t}tjd}|||}|||}t d||t |dddfS#t$rH}t d|t dt|dd fcYd }~Sd }~wwxYw) zDettaglio sessione con items.rT)rmrz items_countr5r8zErrore get detail: Fr9r;N) r0rrrtrrrdrFrGr:rH)rlrIrrurzrKs rget_session_detailrsA--L- 22:yII ))*i@@'"5zz       AAA .1..///53q66::;;S@@@@@@@AsA0A33 C==C:CCz/scanc  t}tj}tj}|rd|vrt ddddfS|d}|dd}|d}|s)||d | }|r|d nd }t|}| |d |d }|st ddddfS| |d |d |||||d} | r(| ||d} |r|| d<|rdnd} t d| | ddfSt ddddfS#t$rH} t d| t dt| ddfcYd } ~ Sd } ~ wwxYw)as Scansiona barcode e aggiunge a sessione. Body: { "barcode": "8001234567890", "quantita": 1 // opzionale } Returns: { "success": true, "data": { "item_id": 456, "found_in_api": true, "product": {...} } } r]FzCampo barcode richiestor9r_quantitar product_datar)r]rNrz2Nessuna sessione aperta. Avvia prima una sessione.ry)item_idr] found_in_apiproductzProdotto trovato e aggiuntoz Barcode registrato (non trovato)T)r6r7rrnzErrore aggiunta itemr;z Errore scan: )r0rrrorstriprbrcboolr}add_itemrFrGr:rH) rIrr7r]rrr`rrr response_datarrKs r scan_barcoders,BA--|!! y,, 2  y/''))88J**xx//  =--d;.?-QQH*2<8A;;LL)) --d;.?dLL  M  "" DM       I     "" ,M  8+7 i(7Ck33IkG%"    /  AAA (Q(()))53q66::;;S@@@@@@@As2AE+ B6E+AE+E++ F=5=F82F=8F=z/item/DELETEc t}tj}||d|d}|st ddddfS|||d}|rt ddd d fSt dd dd fS#t $rH}td |t dt|ddfcYd}~Sd}~wwxYw)zElimina item da sessione.rrFr{r9r_TzItem eliminatorr8Item non trovato o errorezErrore delete: r;N) r0rrr}r delete_itemrFrGr:rH)rrIrrr6rKs rrr+sYA--|--d;.?dLL  2  %%gwt}==  +   4  AAA *q**+++53q66::;;S@@@@@@@As*AB1BB C,$=C'!C,'C,z/item//quantityPUTcd t}tj}tj}|d}|t ddddfS||d|d}|st dd ddfS|||d|}|rt d d ||d d dfSt ddddfS#t$rH}t d|t dt|ddfcYd}~Sd}~wwxYw)uAggiorna quantità item.rNFzCampo quantita richiestor9r_rrr{TuQuantità aggiornata)rr)r6rr7r8rrzErrore update quantity: r;) r0rrrorbrr}update_item_quantityrFrGr:rH)rrIrr7 new_quantityrr6rKs rrrLs(A--|!!xx ++   3  --d;.?dLL  2  ..w |TT  1& ,  4  AAA 33344453q66::;;S@@@@@@@As0AC7C6C C D/'=D*$D/*D/cd t}tjd}ddl}|jditjj}|}|d||f|d||f| | | tdddd fS#t$rH}td |td t|d d fcYd}~Sd}~wwxYw)z*Elimina una sessione e tutti i suoi items.rrNzNDELETE FROM inv_risultati_inventario WHERE id_sessione = %s AND id_tenant = %szDDELETE FROM inv_sessioni_inventario WHERE id = %s AND id_tenant = %sTzSessione eliminatarr8zErrore delete session: Fr9r;r<)r0rrr=r>r?r.r@rCcommitrErrFrGr:rH)rlrIrr=rJr@rKs rdelete_session_endpointrzsKA--L-  wGG!/statsc  ddl}ddlm}tjddtjddtjdd tjd d d d }|jdi|}||jj}tj d}| d||f| d}| d||f| rdnd}| d||f| } | dpd} | dpd} | | td||t| t!| dddfS#t"$rH} t$d| tdt)| ddfcYd} ~ Sd} ~ wwxYw)z+Statistiche per un punto vendita specifico.rN)InventorySessionrrr r!r"r#r$r%rS)r&rr'r(rTrz SELECT COUNT(*) as total FROM inv_sessioni_inventario WHERE id_tenant = %s AND id_sede = %s rVz SELECT id FROM inv_sessioni_inventario WHERE id_tenant = %s AND id_sede = %s AND stato = 'aperta' LIMIT 1 ra. SELECT COALESCE(SUM(i.quantita_fisica), 0) as total_items, COALESCE(SUM( CAST(JSON_EXTRACT(p.dati_cassanova, '$.prices[0].value') AS DECIMAL(10,2)) * i.quantita_fisica ), 0) as total_value FROM inv_risultati_inventario i JOIN inv_sessioni_inventario s ON i.id_sessione = s.id LEFT JOIN inv_cache_prodotti p ON i.barcode = p.codice_barcode WHERE s.id_tenant = %s AND s.id_sede = %s AND s.stato = 'chiusa' total_items total_valueT)total_sessionsactive_sessionrrr5r8zErrore get salespoint stats: Fr9r;r<)r=app.models.inventoryrr+r,r>r@rArBrrrCrYrErr|floatrFrGr:rH) rr=rr.rJr@rrr items_datarrrKs rget_salespoint_statsrsX?A999999Ii55Ii77 ->> )X66   w++++W_788L-    '  ) ) )  **73   '  ) ) ) %oo//6Q    ' ) ) )__&&  /41  /41   "0"0";//$[11        AAA 8Q8899953q66::;;S@@@@@@@AsFF G-%=G("G-(G-z /session//reopenc t}tjd}ddl}|jdi|jj}||jj }| d||f| | d||f| }td|||t!dd|id d fS#t"$rH}td |t!d t'|d dfcYd}~Sd}~wwxYw)zRiapre una sessione chiusa.rrNz UPDATE inv_sessioni_inventario SET stato = 'aperta', timestamp_fine = NULL WHERE id = %s AND id_tenant = %s zh SELECT * FROM inv_sessioni_inventario WHERE id = %s AND id_tenant = %s zSession data: Trmr5r8zErrore reopen session: Fr9r;r<)r0rrr=r>r?r.r@rArBrCrrYrGinforErrFr:rH)rlrIrr=rJr@rurKs rreopen_sessionrs#A--L- wAA!6!@AAW_788  ) $  & & &   ) $ & & & ((  3\33444   -       AAA 2q2233353q66::;;S@@@@@@@AsD D E!=EE!E!z /sync-stocksc t}tj}tj}|d}|st ddddfS||d|}t d||d|d d d fS#t$rH}t d |t dt|dd fcYd}~Sd}~wwxYw)aH Sincronizza giacenze da Cassanova per un salespoint. Body: { "salespoint_id": 17117 } Returns: { "success": true, "data": { "synced_count": 150, "message": "150 giacenze sincronizzate" } } rFsalespoint_id richiestor9r_rTz! giacenze sincronizzate per sede ) synced_countrr5r8zErrore sync_stocks: r;N) r0rrrorbr sync_stocksrFrGr:rH)rIrr7rrarKs rrrs>(A--|!!11   2  ##D$5}EE %#UUmUU       AAA /A//00053q66::;;S@@@@@@@As$AB7B C$=CC$C$z/stock/c t}tj}tjdt }|st ddddfSddl}|jdi|j j }| |j j }|d |d ||f|}|||rt d |d d fSt d d|dd d fS#t"$rH}t$d|t dt)|ddfcYd}~Sd}~wwxYw)a Ottiene giacenza di un prodotto per un salespoint. Query params: salespoint_id: ID sede Returns: { "success": true, "data": { "quantita": 50, "id_prodotto": "..." } } r)rwFrr9r_rNz SELECT quantita, id_prodotto FROM inv_giacenze WHERE id_tenant = %s AND id_sede = %s AND id_prodotto = %s LIMIT 1 rTr5r8)r id_prodottozErrore get_stock: r;r<)r0rrrrbr|rr=r>r?r.r@rArBrCrYrErFrGr:rH) product_idrIrrr=rJr@rPrKs r get_stockr7s$$A--| ((s(CC  Xu7PQQRRTWW WwAA!6!@AAW_788 ; ;  = = =""     %&zBB  AAA -!--...53q66::;;S@@@@@@@As+ADB*DD E,$=E'!E,'E,z$/report/warehouse/sede/c . t}tjd}ddl}|jdi|jj}||jj }| d||f| }|s<| | tddddfS| d ||f|}g}d} d} d} d} |D]} | d | d |f|}t|}t!d |D}t!d |D}t!d|D}|| d | d| dr| dnd|||||dd| |z } | |z } | |z } | |z } | | td||| | | | t|ddddfS#t&$rH}t(d|tdt-|ddfcYd}~Sd}~wwxYw)a  Genera report magazzino AGGREGATO per una filiale. Aggrega TUTTE le sessioni chiuse della filiale. Returns: { "success": true, "data": { "sede": {...}, "sessions": [ { "session_id": 43, "nome_sessione": "TEST", "items": [...], "subtotal": {...} } ], "totals": {...} } } rrNzT SELECT id, nome FROM inv_sedi WHERE id = %s AND id_tenant = %s FzFiliale non trovatar9rz SELECT id, nome_sessione, timestamp_fine FROM inv_sessioni_inventario WHERE id_sede = %s AND id_tenant = %s AND stato = 'chiusa' ORDER BY timestamp_fine DESC aE SELECT r.id as item_id, r.nome_prodotto, r.barcode, r.quantita_fisica as contato, COALESCE(g.quantita, 0) as teorico, (r.quantita_fisica - COALESCE(g.quantita, 0)) as differenza, r.prezzo_pubblico, (r.quantita_fisica * COALESCE(r.prezzo_pubblico, 0)) as valore_contato, CASE WHEN (r.quantita_fisica - COALESCE(g.quantita, 0)) = 0 THEN 'ok' WHEN (r.quantita_fisica - COALESCE(g.quantita, 0)) > 0 THEN 'excess' ELSE 'deficit' END as status FROM inv_risultati_inventario r LEFT JOIN inv_giacenze g ON r.id_sede = g.id_sede AND r.codice_prodotto COLLATE utf8mb4_unicode_ci = g.id_prodotto COLLATE utf8mb4_unicode_ci WHERE r.id_sessione = %s AND r.id_tenant = %s ORDER BY r.nome_prodotto rc3DK|]}t|dpdVdS)valore_contatorN)r.0items r z/get_warehouse_report_by_sede..s5"X"X$5.>)?)D1#E#E"X"X"X"X"X"Xrc32K|]}|ddkdVdS)statusexcessrNr<rs rrz/get_warehouse_report_by_sede..s0PPDT(^x5O5Oa5O5O5O5OPPrc32K|]}|ddkdVdS)rdeficitrNr<rs rrz/get_warehouse_report_by_sede..s0RRTd8n 6Q6Qq6Q6Q6Q6QRRr nome_sessionetimestamp_fine)rranomalies_excessanomalies_deficit)rlrrrzsubtotalT)rrrrr)sedertotalsr5r8z%Errore get_warehouse_report_by_sede: r;r<)r0rrr=r>r?r.r@rArBrCrYrErrDrdsumrrZrFrGr:rH)rirIrr=rJr@r sessions_list sessions_datagrand_total_itemsgrand_total_valuegrand_total_excessgrand_total_deficitsessrzsess_total_itemssess_total_value sess_excess sess_deficitrKs rget_warehouse_report_by_sederss[0lA--L- wAA!6!@AAW_788  y ! # # #   T LLNNN JJLLLu7LMMNNPSS S  y !  # # #))  !2 02 0D NN.t*i(/ * * *2OO%%E #5zz ""X"XRW"X"X"XXX PPEPPPPPKRRURRRRRL  "4j!%o!6HLM]H^"h$'7"8"B"B"D"D"Ddh#3#3(3)5  " "    !1 1  !1 1  + -  < /    )#4#4(:)<&)-&8&8            AAA @Q@@AAA53q66::;;S@@@@@@@As%CIE;I J =J JJz"/report/warehouse/cf t}tjd}ddl}|jdi|jj}||jj }| d||f| }|s<| | tddddfS| d ||f|}| d ||f| }| | td |||d d dfS#t$rH} t d| tdt%| ddfcYd} ~ Sd} ~ wwxYw)a Genera report magazzino per una sessione. Query params (opzionali): - format: 'json' (default) o 'html' per redirect a template Returns (JSON): { "success": true, "data": { "session": { "id": 43, "nome_sessione": "TEST FIX", "id_sede": 640, "sede_nome": "BOUTIQUE MILANO", "user_nome": "Demo User", "timestamp_fine": "2026-01-21T21:50:00" }, "items": [ { "item_id": 44, "nome_prodotto": "All the pretty horses", "barcode": "9781035003754", "contato": 5, "teorico": 5, "differenza": 0, "valore_contato": 75.00, "status": "ok" }, { "item_id": 43, "nome_prodotto": "Leonardo frida and the others", "barcode": "9783791377186", "contato": 7, "teorico": 5, "differenza": 2, "valore_contato": 301.00, "status": "excess" } ], "totals": { "total_items": 3, "total_contato": 15, "total_teorico": 18, "total_differenza": -3, "total_value": 500.50, "anomalies_excess": 1, "anomalies_deficit": 1 } } } rrNa. SELECT s.*, se.nome as sede_nome, u.nome as user_nome, u.email as user_email FROM inv_sessioni_inventario s LEFT JOIN inv_sedi se ON s.id_sede = se.id LEFT JOIN tenant_users u ON s.id_user = u.id WHERE s.id = %s AND s.id_tenant = %s FzSessione non trovatar9ra SELECT r.id as item_id, r.nome_prodotto, r.barcode, r.codice_prodotto, r.quantita_fisica as contato, COALESCE(g.quantita, 0) as teorico, (r.quantita_fisica - COALESCE(g.quantita, 0)) as differenza, r.prezzo_pubblico, (r.quantita_fisica * COALESCE(r.prezzo_pubblico, 0)) as valore_contato, CASE WHEN (r.quantita_fisica - COALESCE(g.quantita, 0)) = 0 THEN 'ok' WHEN (r.quantita_fisica - COALESCE(g.quantita, 0)) > 0 THEN 'excess' ELSE 'deficit' END as status FROM inv_risultati_inventario r LEFT JOIN inv_giacenze g ON r.id_sede = g.id_sede AND r.codice_prodotto COLLATE utf8mb4_unicode_ci = g.id_prodotto COLLATE utf8mb4_unicode_ci WHERE r.id_sessione = %s AND r.id_tenant = %s ORDER BY CASE WHEN (r.quantita_fisica - COALESCE(g.quantita, 0)) != 0 THEN 0 ELSE 1 END, ABS(r.quantita_fisica - COALESCE(g.quantita, 0)) DESC, r.nome_prodotto ASC a SELECT COUNT(DISTINCT r.id) as total_items, SUM(r.quantita_fisica) as total_contato, SUM(COALESCE(g.quantita, 0)) as total_teorico, SUM(r.quantita_fisica - COALESCE(g.quantita, 0)) as total_differenza, SUM(r.quantita_fisica * COALESCE(r.prezzo_pubblico, 0)) as total_value, SUM(CASE WHEN (r.quantita_fisica - COALESCE(g.quantita, 0)) > 0 THEN 1 ELSE 0 END) as anomalies_excess, SUM(CASE WHEN (r.quantita_fisica - COALESCE(g.quantita, 0)) < 0 THEN 1 ELSE 0 END) as anomalies_deficit FROM inv_risultati_inventario r LEFT JOIN inv_giacenze g ON r.id_sede = g.id_sede AND r.codice_prodotto COLLATE utf8mb4_unicode_ci = g.id_prodotto COLLATE utf8mb4_unicode_ci WHERE r.id_sessione = %s AND r.id_tenant = %s T)rmrzrr5r8zErrore get_warehouse_report: r;r<)r0rrr=r>r?r.r@rArBrCrYrErrDrFrGr:rH) rlrIrr=rJr@rurzrrKs rget_warehouse_reportrsnbA--L- wAA!6!@AAW_788  ) $  & & &((   LLNNN JJLLL /   <) $= & & &@!!  ) $! & & &$""  '        AAA 8Q8899953q66::;;S@@@@@@@As%CEBE F0(=F+%F0+F0)%__doc__flaskrrrr functoolsrr loggingr+ getLogger__name__rG inventory_bprr0routerLrQr[rerrr}rrrrrrrrrrrrrr<rrrs  ?>>>>>>>>>>>  8 $ $yh;NOOO    888.NUG44 %A%A54%AX$vh77 AA87ABME733 %A%A43%AV&88 (A(A98(A^$vh77 3A3A873Al&88 *A*A98*AZ$vh77 -A-A87-A`&88 )A)A98)AX/%AA AABAA4GfX.. VAVA/.VAr)H:>> AA?>A>2UGDD *A*AED*AX/(DD AAEDA2;eWMM AAAANMAAF6II %A%AJI%AVNVH55 +A+A65+A\)E7;; 4A4A<;4At:UGLL BABAMLBAJ85'JJ WAWAKJWAWAWAr