H;i˱ddlmZmZmZmZmZddlmZddlm Z m Z ddl m Z m Z mZmZddlZddlmZmZddlmZddlmZdd lmZd d lmZmZ dd lmZ dd l m!Z!ddl"m#Z#dZ$dZ% ddl+m,Z,dZ- ddl.m/Z/dZ0 ddl1m2Z2dZ3ejNe(Z4eZ5e5jmddede e7e ffdZ8e5jsdeejteddded d d!d"#eefd$e;d%e;d&efd'Ze5jsd,eej~eddd-ed d d!d.#eefd$e;d%e;d&efd/Z@e5jsd0eejeddd1ed d d!d2#eefd$e;d%e;d&efd3ZBe5jsd4eejeddd5ed d d!d6#eefd$e;d%e;d&efd7ZDe5jsd8eejeddd9ed d d!d:#eefd$e;d%e;d&efd;ZFe5jsdedd?@eddA@eefdBe;dCe;dDe7dEe;d&ef dFZHe5jmdGdHZIe5jmdIeddJ@fdKe7fdLZJe5jmdMeddN@fdKe7fdOZKe5jsdPejed d d=ed d d>eddQ@eefdBe;dRe;dDe7d&efdSZMe5jsdTed d d=ed d d!d>#eddQ@eddA@eddU@eddV@eefdBe;dRe;dDe7dEe;dWe;dXe;d&efdYZNe5jsdZejed[d d=ed[d d d>#edd\@eefdBe;dRe;dDe7d&efd]ZPe5jsd^ejd_g`ed[da@eddb@eddc@eddd@edde@eefdEe;dWe;dXe;dfe7dge7d&ef dhZRe5jmdieddJ@fdKe7fdjZSe5jsdkejd_g`ed d d=edld d>eddm@eddA@eddU@eddV@eddn@eefdBe;dRe;dDe7dEe;dWe;dXe;doeUd&efdpZVe5jsdqed d d=ed d d>eddA@eddU@eddV@eddr@eefdBe;dRe;dEe;dWe;dXe;dse7d&efdtZWe5jmdueddv@fdwe7fdxZXe5jmdyejed[dz@fdEe;fd{ZZe5jmd|ejeefd}ejd&efd~Z]e5jsdejd_g`ed[d@edd@edd@edd@eefdEe;dWe;dXe;dDe7d&ef dZ_e5jsdejd_g`ed[d@edd@edd@eefdEe;dWe;dDe7d&efdZae5jsdejd_g`ed[da@edd@edd@eddd@edde@eefdEe;dWe;dXe;dfe7dge7d&ef dZce5jsdejd_g`ed[da@eddb@edd@edld d d#eefdEe;dWee;dee;d%e;d&ef dZee5jsdejd_g`ed[da@eddb@edd@edld d d#eefdEe;dWee;dee;d%e;d&ef dZge5jsdejd_g`ed[da@eddb@edd@edld d d#eefdEe;dWee;dee;d%e;d&ef dZie5jsdejd_g`ed d d=edld d>eddA@eddU@eddV@edd@eefdBe;dRe;dEe;dWe;dXe;dse7d&efdZky#e$r dd lmZYwxYw#e$r9Z&ejNe(Z)e)jUde&dZ!dZ#dZ$dZ%YdZ&[&dZ&[&wwxYw#e$r5Z&ejNe(Z)e)jUde&dZ,dZ-YdZ&[& dZ&[&wwxYw#e$r5Z&ejNe(Z)e)jUde&dZ/dZ0YdZ&[& Csl2# \\^#XXlI6  01I1I1K0LMN l:,/0 2 2xx 0"599$FH KK-hZ8 9 2 2xx r266tUCH KK*8*5 6 NN1*> ? B:,aP#<<>335$   )$8   7Ax@A23q6(;   s9FEED)EFE F :FF  Fz /sales-orders)response_modelzNumber of sales orders to skip)ge descriptiondiz Number of sales orders to return)r@lerAskiplimitdbc tj|||}|S#t$r3}tj dt |t ddd}~wwxYw)z Get sales orders with paginationrDrEzError fetching sales orders: zError fetching sales ordersr.N)rget_sales_ordersr8r3r9r:r)rDrErF sales_ordersr<s r=rJrJsZS!222DN  S 4SVH=>4QRRS A.AAz/sales-order-linesz#Number of sales order lines to skipz%Number of sales order lines to returnc tj|||}|S#t$r3}tj dt |t ddd}~wwxYw)z%Get sales order lines with paginationrHz"Error fetching sales order lines: rIz Error fetching sales order linesr.N)rget_sales_order_linesr8r3r9r:r)rDrErFsales_order_linesr<s r=rNrN\X&<Date in YYYY-MM-DD format to get daily sales for specific date)rAzFilter by company IDpage pagelimitr company_idc tj|||||}|d|d|d|ddS#t$r3}tj dt |t dd d }~wwxYw) zGet daily sales records with pagination. If date is provided, returns sales for that specific date. If company_id is provided, filters by company.)rr_r]perpager,r]ratotalr,r]rarbzError fetching daily sales: rIzError fetching daily salesr.N)rget_daily_salesr8r3r9r:r)r]r^rr_rFresultr<s r=rdrds R++BTjW[eno6N6Ni(G_   R 3CF8<=4PQQRs,/ A+.A&&A+z/celery/compute-daily-salescts tdd tj}|jdddS#t $r3}t jdt|tdd d }~wwxYw) z1Trigger daily sales computation using Celery taskzOCelery not available. Daily sales computation service is currently unavailable.r.startedz$Daily sales computation task started)task_idr)r*z-Error starting daily sales computation task: rIz+Error starting daily sales computation taskN) daily_sales_celery_availablerrdelayr$r8r3r9r:)taskr<s r=trigger_compute_daily_salesrms (d  c"((*ww=  c DSVHMN4abbcs#9 A5.A00A5z/celery/compute-service-levelzDTarget date in YYYY-MM-DD format. If not provided, uses today's date target_datecxts tdd |rddlm} |j|dt j |}|rd |nd }|jd d ||d S#t$rtddwxYw#t$r3}tjdt|tddd}~wwxYw)z3Trigger service level computation using Celery taskrgzQCelery not available. Service level computation service is currently unavailable.r.rr%Y-%m-%dr-#Invalid date format. Use YYYY-MM-DD for for todayrhz&Service level computation task startedrir)r*rnz/Error starting service level computation task: rIz-Error starting service level computation taskN) service_level_celery_availablerrstrptime ValueErrorrrkr$r8r3r9r:rnrrldate_msgr<s r=trigger_compute_service_levelr{s *f  e  ) c!!!+z: +00=,7U;-(\ww?zJ&    c#Trigger daily inventory snapshot computation using Celery taskrgzVCelery not available. Inventory snapshot computation service is currently unavailable.r.rrprqr-rrrsz for yesterdayrhz+Inventory snapshot computation task startedruz4Error starting inventory snapshot computation task: rIz2Error starting inventory snapshot computation taskN) snapshot_celery_availablerrrwrxrrkr$r8r3r9r:rys r="trigger_compute_inventory_snapshotr6s %k  j  ) c!!!+z: *// <,7U;-(=MwwDXJO&    c#?4RSSTrz"/analytics/service-level-vs-demandzSmart Inventory - Frontend)r?tagszCompany ID (required)z Filter by location ID (optional)zFilter by product ID (optional)zCStart month in YYYY-MM format (optional, defaults to 11 months ago)zAEnd month in YYYY-MM format (optional, defaults to current month) month_frommonth_toc  tj||||||}d|ddS#t$rO}tj dt |t jdddd t |i cYd }~Sd }~wt$rO}tj d t |t jdd dd t |i cYd }~Sd }~wwxYw)a Get month-wise service level vs demand analytics. Returns aggregated monthly data: - demand_qty: Total demand quantity for the month (integer) - fulfilled_qty: Total fulfilled quantity for the month (integer) - lost_sales_qty: Total lost sales quantity for the month (integer) - service_level: fulfilled_qty / demand_qty (0.0 - 1.0, or 1.0 if no demand) Date Range: - month_from: Start month (YYYY-MM). Defaults to 11 months ago if not provided - month_to: End month (YYYY-MM). Defaults to current month if not provided - If neither provided, returns last 12 months of data Filters: - company_id: Required - filters data for specific company - location_id: Optional - if provided, only data for that location is included - product_id: Optional - if provided, only data for that product is included - If both location_id and product_id are omitted, aggregates across all locations and products )rFr_rrrrTz8Service level vs demand analytics retrieved successfullyr'r,r*z8Validation error for service level vs demand analytics: FValidation errorVALIDATION_ERRORr9r'r* error_codedetailsNz2Error fetching service level vs demand analytics: z&Error fetching service level analyticsDATABASE_ERROR) r%get_analytics_service_level_vs_demandrxr3r9r:r ErrorResponser8)r_rrrrrF result_datar<s r=get_service_level_vs_demandrs:  FF!#!!  Q    OPSTUPVxXY$$&)c!f%     I#a&RS$$<'c!f%    s. # CAA60C6 CAC C Cz/celery/compute-slow-moversc ddlm} |rddlm} |j |d|j|}|rd |nd }|jd d ||dS#t$rtddwxYw#t $rtdd wxYw#t$r3}tjdt|tddd}~wwxYw)z0Trigger slow mover computation using Celery taskr)compute_slow_movers_90drgzCelery task not available.r.rprqr-rrrsrtrhz#Slow mover computation task startedruz,Error starting slow mover computation task: rIz*Error starting slow mover computation taskN) *src.smart_inventory.tasks.slow_movers_taskr ImportErrorrrrwrxrkr$r8r3r9r:)rnrrrlrzr<s r=trigger_compute_slow_moversrs  Vb  ) c!!!+z: ',,[9,7U;-(\ww>Cz /slow-movers zDDate in YYYY-MM-DD format. If not provided, defaults to today's datezFilter by is_slow_mover flag is_slow_moverc  tj||||||||}d|ddS#t$rt$rO} tj dt | tjdddd t | i cYd } ~ Sd } ~ wt$rO} tj d t | tjdd dd t | i cYd } ~ Sd } ~ wwxYw)zmGet slow mover snapshots with pagination and filters. If date is not provided, returns data for today's date.)r]rarr_rrrTz"Slow movers retrieved successfullyrz%Invalid data format for slow movers: FInvalid data format INVALID_DATAr9rNzError fetching slow movers: zError fetching slow moversr) rget_slow_moversrrxr3r9r:rrr8) r]rarr_rrrrFrer<s r=rrs$ ++ !#!'  ;      A:.A55A:z/predictpayloadc |j|jz jdz}t|j|j |j |} tj ||j|j |j |d}tj#d|dtj&|j|j |j |j)Dcgc]9\}}tj*|dj-t/|d;c}}S#t$r>tjd|jtdd|jdt$rO}tjdt|tjd d d d t|i cYd}~Sd}~wwxYw#t$$rO}tjdt|tjd ddd t|i cYd}~Sd}~wt$rO}tjdt|tjd ddd t|i cYd}~Sd}~wwxYwcc}}w)z Generate and store demand forecast predictions. Automatically deletes existing forecasts for the same date range to avoid duplicates. r)r_rr horizon_dayszModel not found for company_id=r-zNo model found for company_id=z. Train it first.r.zError generating forecast: FzError generating forecastFORECAST_GENERATION_ERRORr9rNv1)rFr_rrdf_predictions model_versionzSuccessfully saved z forecast recordsz#Validation error saving forecasts: zInvalid forecast datarz$Error saving forecasts to database: z"Error saving forecasts to databaserr forecast_qty)rr)r_rr forecasts)end_date start_datedaysrr_rrFileNotFoundErrorr3r9rr8r:rrrsave_demand_forecastr4rxForecastResponseiterrowsForecastResponseItemrfloat)rrFrdf_predsr< saved_count_rows r=forecast_and_storers_ ((7+=+==CCaG #))++))%  ,  55))++))#    )+6GHI&  # #%%''%% #++-  3  ( ([%%'"3~#67   [   6w7I7I6JKL3G4F4F3GGXY     23q6(;<$$/2c!f%    *   :3q6(CD$$+)c!f%     ;CF8DE$$8'c!f%     sYAD2AG+>J2AGAG G G JAH%J% J1AI;5J;Jz/analytics/overviewz Company IDzLocation ID (optional)zProduct ID (optional)zhDate in YYYY-MM-DD format to get slow movers for specific date if no date is provided, uses today's datec H |s%ddlm}|jjd}t j |||||}d|ddS#t $rO}tjdt|tjd d d d t|i cYd}~Sd}~wwxYw)Nr)rrq)rr_rrTz)Analytics overview retrieved successfullyrz#Error fetching analytics overview: Fz!Error fetching analytics overviewrr9r) rrtodaystrftimerget_analytics_overviewr8r3r9r:rr)r_rrrrF date_classrer<s r=rrs  3##%..z:D22 !#!  B    :3q6(CD$$7'c!f%    sAA B!ABB!B!z/analytics/kpi-summaryzGDate in YYYY-MM-DD format (optional, defaults to latest available data)c  tj||||}d|ddS#t$rO}tj dt |t jdddd t |i cYd }~Sd }~wt$rO}tj d t |t jdd dd t |i cYd }~Sd }~wwxYw)a Get KPI summary for frontend dashboard cards. Returns aggregated metrics: - avg_service_level: Average service level (0.0 - 1.0) - stockouts_count: Number of products currently out of stock - overstock_count: Number of overstocked products - understock_count: Number of understocked products - slow_mover_count: Number of slow-moving products - total_products_tracked: Total number of products being tracked - avg_days_on_hand: Average days of inventory on hand (stock turns indicator) )rFr_rrTz"KPI summary retrieved successfullyrz"Validation error for KPI summary: Frrr9rNzError fetching KPI summary: zError fetching KPI summaryr) rget_kpi_summaryrxr3r9r:rrr8)r_rrrFrer<s r=rrs& ++!#  ;    9#a&BC$$&)c!f%     3CF8<=$$0'c!f%    s.! CAA4.C4 CAC C Cz/analytics/stock-vs-demandzJFilter by location ID (optional, aggregates all locations if not provided)zHFilter by product ID (optional, aggregates all products if not provided)c  tj||||||}d|ddS#t$rt$rO}tj dt |tjdddd t |i cYd }~Sd }~wt$rO}tj d t |tjdd dd t |i cYd }~Sd }~wwxYw)aLGet month-wise stock vs demand analysis. Returns aggregated monthly data: - avg_daily_demand: Average daily demand across all dates in the month (integer) - available_stock: Average available stock across all dates in the month (integer) Date Range: - month_from: Start month (YYYY-MM). Defaults to 11 months ago if not provided - month_to: End month (YYYY-MM). Defaults to current month if not provided - If neither provided, returns last 12 months of data Filters: - company_id: Required - filters data for specific company - location_id: Optional - if provided, only data for that location is included - product_id: Optional - if provided, only data for that product is included - If both location_id and product_id are omitted, aggregates across all locations and products )r_rrrrTz/Stock vs demand analysis retrieved successfullyrz2Invalid data format for stock vs demand analysis: Frrr9rNz)Error fetching stock vs demand analysis: z'Error fetching stock vs demand analysisr) rget_analytics_stock_vs_demandrrxr3r9r:rrr8)r_rrrrrFrer<s r=rrGs4" 99 !#!!  H     I#a&RS$$)%c!f%     @QIJ$$='c!f%    s. #CAA?9C? C ACCCz/analytics/fastest-movingz Filter by category ID (optional)z2Number of products to return (default 10, max 100) category_idc tj|||||}|S#t$r}tdt |d}~wt $r?}t jdt |tddt |d}~wwxYw)z@Get fastest moving products by ads_30d (highest sales velocity).rFr_rrrEr-r.Nz(Error fetching fastest moving products: rI)rget_fastest_moving_productsrxrr:r8r3r9r_rrrErFrever<s r=rrs 77!##   =CG<<   ?AxHI=c!fXF    B= B :BBz/analytics/most-stagnantc tj|||||}|S#t$r}tdt |d}~wt $r?}t jdt |tddt |d}~wwxYw)z]Get most stagnant products by ads_90d (lowest sales velocity) with excess stock calculations.rr-r.Nz'Error fetching most stagnant products: rI)rget_most_stagnant_productsrxrr:r8r3r9rs r=#get_most_stagnant_products_endpointrs 66!##   =CG<<   >s1vhGH NN< =" FA    ?AxHI$$&)c!f%      9#a&BC {9#7#7#9":;<$$6'c!f%    s1?A D ABD D!A.DDD)lfastapirrrrrsqlalchemy.ormr sqlalchemyr r typingr r r rloggingrr)src.smart_inventory.apps.inventory.modelsr*src.smart_inventory.core.demand_forecasterr,src.smart_inventory.core.prediction_pipelinerrrr src.utils.dbrrutils.db*src.smart_inventory.tasks.daily_sales_taskr,src.smart_inventory.tasks.service_level_taskrrjrvr< getLogger__name__ logger_tempr71src.smart_inventory.tasks.inventory_snapshot_taskrr~1src.smart_inventory.tasks.inventory_planning_taskrr.src.smart_inventory.tasks.demand_forecast_taskrrr3routerpostr:r>r2 SalesOrderOutintrJSalesOrderLineOutrNInventoryBatchOutrRInventoryMovementOutrUPurchaseOrderOutrXPurchaseOrderLineOutr[PaginatedDailySalesResponserdrmr{r"PaginatedInventorySnapshotResponserrPaginatedServiceLevelResponserServiceLevelVsDemandResponserrSlowMoverResponseboolrrrTrainDemandForecastResponserrForecastRequestrAnalyticsOverviewResponserKPISummaryResponserStockVsDemandResponserFastestMovingResponserMostStagnantResponserMostUrgentResponserInventoryResponserr=rsEE"!,,#DNH! # +NX#' %)"&\ $0e*.'3Z-1*   8 $  !; g; $sCx.; "; ~OD1F1F,GHaA+KLsqT7YZ&/ S  S  S  SI S g6O6O1PQaA+PQsqT7^_&/ X  X  X  XR X g6O6O1PQaA+PQsqT7^_&/ X  X  X  XR X "48T8T3UVaA+RSsqT7`a&/ Z  Z  Z  ZW Z tG4L4L/MNaA+NOsqT7\]&/ V  V  V  VO V #D9U9U4VWaA+STsqT7ab&/ [  [  [  [X [ $W5X5XYaA=9312LMd(hiD.DE&/ R RR R R  RZR* *+c,c. ,-T/uv!e!e.!eH 12T/yz!j!j3!jH "73]3]^aA=90JKd(fg&/ Z Z Z Z  Z_Z( 34aA=9t9STd(fgD.DET/FGD.DE&/c c c c c  c  c c5cB $W5Z5Z[ca];s8RSd(jk&/ T T T T  T\T* 0AeAenJmKLC-DET/QRD.OPD.st$,op&/ ; ; ; ;  ;  ;  ; L; ~ *+T/uv#b#b,#bLN7+D+DLhKijaA=9/IJd(noD.DET/FGD.DE2PQ&// / /  /  /  /  / /  / k/ dKaA=90JKD.DET/FGD.DE*xy&/Y Y YY Y  Y  Y YY8 12t1yz!j!j3!jH ,W=`=`aC-PQddbd4Z(@(@A&/K  $ $KKBK\ !'2S2S\x[yzC\:T/GHD.EFd)ST&/ " " " "   "  " {" J $W5O5OWsVtuC\:T/GHd(qr&/ / / /  /   / v/ d (9V9V^z]{|C-DET/{|D.xyD.st$,op&/ ; ; ; ;  ;  ;  ; }; | '8U8U]y\z{C-DE!&t9[!\!&t9[!\raC5ij&/   # #      | 8 &w7S7S[wZxyC-DE!&t9[!\!&t9[!\raC5ij&/   # #      z : $W5O5OWsVtuC-DE!&t9[!\!&t9[!\raC5ij&/   # #      v `Bw88@\?]^aA=9/IJD.DET/FGD.DE*xy&/6 6 6 6  6  6  6  6 _6 I   +#'##H-K9!=>"&#( %*" +&#'##H-KDQCHI!% % &0#'##H-KDQCHI*.'*/' 03#'##H-KJ1#NO"&-2* 3src0d(e1f:f=0 c?>c?e.d;;ee=*e88e=f:*f55f:=g7*g22g7