koiZddlmZmZmZmZmZmZmZddlm Z ddl m Z ddl m Z ddlmZmZddlZddlZ ddlmZej.eZeZej7d ed ed ed eefd ed e d dede fdZej=ddged dedddeddddeddeddeefd ededed ed!ede f d"Z ej=d#dgeefd$ede fd%Z!y#e$r ddlmZYwxYw)&) APIRouterDependsForm UploadFileFileQuery HTTPException) FileResponse)Session)Literal) controllerschemasN)get_dbz /upload-csv. company_id upload_type)productpurchase_orderpurchase_receive sales_order sales_returnpurchase_returnstock_transferfiledbcRKtj||||d{}|S7w)a Upload CSV file and queue for async background processing. The CSV file is saved to disk and a Celery task is created to process it. Processing happens asynchronously - the response is returned immediately. CSV types are processed in dependency order: - product: No dependencies, processed first - purchase_order: Depends on product - purchase_receive: Depends on product, purchase_order - sales_order: Depends on product, purchase_order, purchase_receive - sales_return: Depends on product, purchase_order, purchase_receive, sales_order - purchase_return: Depends on product, purchase_order, purchase_receive - stock_transfer: Depends on all other types Returns: - task_id: Celery task ID for tracking - task_name: Unique task name - status: "pending" (processing) or "hold" (waiting for dependencies) - file_path: Path to saved CSV file - message: Status message N)rprocess_csv_file)rrrrresults J/var/www/html/hubwallet-dev/src/smart_inventory/apps/data_import/router.py upload_csvr s,:..r4[Q QF MRs '%'z/csv-upload-logszSmart Inventory - Frontend)tagszCompany ID (required)) descriptionz Page number)ger" dzNumber of items per page)r#ler"zzFilter by CSV type (product, purchase_order, purchase_receive, sales_order, sales_return, purchase_return, stock_transfer)zDFilter by processing status (succeeded, failed, partially_succeeded)pageperpagecsv_typeprocessing_statusc P tj||||||}tj|d|d|d|d|d|dS#t$rR}t j d t|tjd g||d d t|cYd }~Sd }~wwxYw) z Get CSV upload logs with pagination and optional filtering. Returns logs ordered by upload_date descending (latest first). All dates are returned in UTC timezone. )rrr'r(r)r*successdatar'r(totalmessage)r,r-r'r(r.r/z Error fetching CSV upload logs: FrN)rget_csv_upload_logsrCSVUploadLogResponse Exceptionloggererrorstr)rr'r(r)r*rres rr0r05s //!/  ++9%9%/9%       7Ax@A++6s1vh?     sAA B%AB B% B%z/download-csv/{log_id}log_idc" ddlm}|j|j|j|k(j }|s t dd|j}tjj|s t ddtjj|}t||ddd |i S#t $rt$r?}tjd t!|t d d t!|d}~wwxYw)z Download a CSV file by log ID. Security: Validates that the log entry exists and the file is available. Args: log_id: CSV upload log ID Returns: FileResponse with the CSV file for download r) CSVUploadLogizCSV upload log not found) status_codedetailzFile not found on serverztext/csvzContent-Dispositionzattachment; filename=)pathfilename media_typeheaderszError downloading CSV file: izError downloading file: N)+src.smart_inventory.apps.data_import.modelsr9queryfilteridfirstr file_pathosr<existsbasenamer r2r3r4r5)r7rr9 log_entryrEr=r6s rdownload_csv_filerJbs + LHH\*11 OOv % %' 1  '' ww~~i(1  77##I.!*.CH:,NO       3CF8<=-c!fX6   sB:B==D:D  D)"fastapirrrrrrr fastapi.responsesr sqlalchemy.ormr typingr rrloggingrF src.utils.dbr ImportErrorutils.db getLogger__name__r3routerpostintr getr5r0rJrr\sTTT*"!  #   8 $ ]3iQUVYQZCy&/ MN   @ &B%CDC-DEaA=9c7QR$-ij"45{|&/ ) ) ) )  )  )  ) E) X $,H+IJ&/: : : K: q  sD D*)D*