+ 5)i<jRt^RIHtHtHtHtHt^RIt^RI H t H t ^RI H t ^RI Ht!RR4tR#)zS OMS Data Service Service for extracting time series data from OMS database tables )ListDictAnyOptionalTupleN)datetime timedelta)DatabaseService) get_loggerca]tRt^ toRtRtRV3RlRlltV3RlRltV3RlR ltV3R lR lt RV3R lR llt V3RlRlt RV3RlRllt Rt VtR#)OMSDataServicez9Service for extracting time series data from OMS databasec*\4Vn\R4VnRRRRRRRRRR R .R //R RRRRRR RRR R .R //RRRRRRRRRR RR.R //RRRRRRRRRR RR.R //RRRRRRRRRR R.R //RRRRRRR RRR R!R".R //R#RR$RRRR%RRR R&.R ///VnR'#)(oms_data_serviceorderstable date_column order_date value_column order_total value_funcSUMextra_conditionszdeleted_at IS NULLfilters order_countidCOUNTrevenuetransaction_sales bill_datez status = 1zdeleted_by IS NULL collections collection credited_dateamountz status = 17zcredited_date IS NOT NULL credit_notestransaction_cnzstatus IN (12, 13, 14) stock_outward product_stock created_at change_stockzstock_type = 2zentity_type = 2purchase_orderspurchase_orderquantityz status != 9N)r db_servicer logger table_configsselfs&JD:\Projects\python\client-ideal-oms_pyapi\app\services\oms_data_service.py__init__OMSDataService.__init__sa)+ !34 2 | e"%9$:2  |g"%9$:2  ,{ e"\3G$H2  e"]4O$P2  ){ e"%=$>2  |e"%57H$I2  )| e"]O2  i\ Nc<V^8dQhRS[RS[S[,RS[S[,RS[S[S[S[3,,RS[S[,RS[S[S[S[3,,/#) table_key start_dateend_dater aggregationreturn)strrrrr)format __classdict__s"r1 __annotate__OMSDataService.__annotate__sm///SM/3- / $sCx.) / c] / d38n /r4c  WP9d3\RV R\VPP44 24hVPV,P 4p/VP R/4CT;'g/CVR&VP WbW54pVPPRV RV 24VPPV4pV'g"VPPRV R24.#VPPR\V4 R V R 24V# \d1p TPPR T R\T 4 24hR p ? ii;i) a[ Extract time series data from an OMS table. Args: table_key: Key in table_configs (e.g. 'revenue', 'collections') start_date: Inclusive lower bound on the date column (YYYY-MM-DD) end_date: Inclusive upper bound on the date column (YYYY-MM-DD) filters: Additional col=value conditions merged at request time. Pass {"company_id": } for per-company scoping. Omit or pass {} for all-companies (collective) data. aggregation: 'daily' | 'weekly' | 'monthly' Returns: List of {"ds": , "y": } dicts ready for Prophet. Unknown table configuration: 'z'. Available: rzExecuting query for '': zNo data found for 'z' with the given filtersz Retrieved z records for ''z'Error extracting time series data for 'N)r. ValueErrorlistkeyscopyget _build_queryr-infor,execute_mysql_querywarninglen Exceptionerrorr<) r0r7r8r9rr:configqueryresultses &&&&&& r1get_time_series_data#OMSDataService.get_time_series_datasa.  2 22 #A)M//3D4F4F4K4K4M/N.O"QRR '' 2779F P6::i#< PB PF9 %%f(PE KK  4YKs5'J Koo99%@G ##&9)D\$]^ KK  z#g,~i[PQR SN  KK   G {RUVYZ[V\U]^ _  s%A>D,A=D,?,D,, E'7+E""E'c n<V^8dQhRS[S[S[3,RS[S[,RS[S[,RS[RS[/#)r6rQr8r9r:r;)rr<rr)r=r>s"r1r?r@sTGGS#XGSMG3- G  G Gr4c  VR,pVR,pVR,pVPRR4pVR8XdRV RV R V R 2p R V R 2p MDVR 8XdRV RV RV R V R 2 p RV R2p M'VR8XdRV RV R V R 2p RV RV R 2p M V RV R2p Rp RV RV 2p .p VPR.4Fp V PV 4K V'dV PV RV R24V'dV PV R V R24VPR!/4P4Fwr\V\4'd2R"P R#V44pV PV R$V R 24KL\V\ 4'dV PV R%V R24K{V PV R&V 24K V 'd V R'R(P V 4,, p V 'd V R)V 2, p V R*, p V #)+u< Build a parameterised aggregation query for Prophet input. Aggregation levels: daily → DATE(date_col) GROUP BY DATE(date_col) weekly → Monday of ISO week GROUP BY YEARWEEK(date_col) monthly → first day of month GROUP BY YEAR, MONTH rrrrrdailyzDATE(z ) AS ds, (z) AS yzGROUP BY DATE()weeklyzDATE(DATE_SUB(z, INTERVAL WEEKDAY(z) DAY)) AS ds, zGROUP BY YEARWEEK(z, 1)monthlyz DATE_FORMAT(z, '%Y-%m-01') AS ds, zGROUP BY YEAR(z ), MONTH( AS ds, z AS ySELECT z FROM r >= 'rD <= 'rz, c3p"TF,p\V\4'dRV R2M \V4xK. R#5i)rDN) isinstancer<).0vs& r1 .OMSDataService._build_query..s0 [UZPQZ3-?-?1QCqSV!KUZs46z IN (z = 'z =  WHERE  AND  z ORDER BY ds)rIappenditemsrdrFjoinr<)r0rQr8r9r:rdate_col value_colr select_clause group_clauserRwhere_conditionscondkeyvaluevalss&&&&& r1rJOMSDataService._build_querysSG_M*N+ ZZ e4 ' !#H:Yzl!I;fUM,XJa8L H $  *=hZ,a {&2 0z>L I %xj(=,a {&2 ,H:YxjJL'j 5AML-ug6JJ126D  # #D )7   # #xjj\$C D   # #xjhZq$A B!**Y399;JC%&&yy [UZ [[ ''3%uTF!(<=E3'' ''3%tE7!(<= ''3%s5'(:;<  Y.>!?? ?E  q' 'E  r4c0<V^8dQhRS[S[,/#)r6r;)rr<)r=r>s"r1r?r@s//d3i/r4c H\VPP44#)z)Return the list of configured table keys.)rFr.rGr/s&r1get_available_tables#OMSDataService.get_available_tablessD&&++-..r4cL<V^8dQhRS[RS[S[S[S[3,,/#r6r7r;)r<rrr)r=r>s"r1r?r@s(c3h0Hr4c hWP9d"VPV,P4#R#)z2Return a copy of the config for a given table key.N)r.rH)r0r7s&&r1get_table_infoOMSDataService.get_table_infos+ ** *%%i0557 7r4c<V^8dQhRS[RS[RS[RS[RS[RS[S[S[,,RS[S[,RS[S[S[S[3,,/#) r6rurrrrrgroup_byr)r<rrrr)r=r>s"r1r?r@s Q Q  Q Q Q  Q  Q#49- Q3- Q$sCx.) Qr4c  RTRTRTRTRT;'g.RT;'g//VPV&VPPRV RV 24R #) a Register a custom table configuration at runtime. Args: key: Lookup key used in API calls table: Physical table name date_column: Column used as the time axis value_column: Column to aggregate value_func: 'SUM' or 'COUNT' extra_conditions: List of raw SQL predicates always added to WHERE group_by: Unused legacy parameter (kept for compatibility) filters: Default col=value filters rrrrrrz!Registered table configuration: 'u' → N)r.r-rK) r0rurrrrrrrs &&&&&&&&&r1add_table_configOMSDataService.add_table_configse2 U ; L *  0 6 6B w}}" # 3 s"r1r?r@)s$88s8uT3Y7G8r4c pWP9d.\VPP44pRRV RV 23#VPV,pVPP RVR, 24pV'gRRVR, R23#R # \ dpRR\ T4 23uR p?#R p?ii;i) z Validate that a table key exists and its underlying table is reachable. Returns: (True, "") on success, (False, reason) on failure. FzTable configuration 'z' not found. Available: zSELECT COUNT(*) AS cnt FROM rzTable 'z&' does not exist or returned no resultzValidation error: N)Tr_)r.rFrGr,rLrOr<)r0r7 availablerQresultrTs&& r1validate_table_config$OMSDataService.validate_table_config)s 8 2 22 !3!3!8!8!:; !6ykB--6K 9::'' 2F__88.vg.?@Fw'88^___O 8.s1vh77 7 8s.s"r1r?r@CsR1111SM 1 3- 1 d38n  1r4c  WP9d\RV R24hVPV,p\VPR.44pV'dVP VR, RV R24V'dVP VR, RV R24RVR, RVR , R VR , 2pV'd VR R P V4,, pVRVR, RV 2, pVP PV4pT;'g.# \d1p TPPRT R\T 4 24hRp ? ii;i)u Return a raw (non-aggregated) preview of the most recent rows for a table key. extra_conditions from the config are applied so the preview reflects the same filtered dataset that would be used for training. Args: table_key: Configured table key limit: Number of rows to return (1–100) start_date: Optional lower bound on the date column end_date: Optional upper bound on the date column Returns: List of {"ds": , "y": } dicts (raw, not aggregated). rBrDrrrarbr`r^rz AS y FROM rrirjz ORDER BY z DESC LIMIT z Error getting data preview for 'rCN) r.rErFrIrlrnr,rLrOr-rPr<) r0r7rr8r9rQrsrRrSrTs &&&&& r1get_data_previewOMSDataService.get_data_previewCsa*  2 22 #A)A!NOO'' 2F#FJJ/A2$FG  ''6-+@*AzlRS(TU ''6-+@*AxjPQ(RS&/09O8PQw(*   W\\2B%CCC z&"7!8 UGL LEoo99%@G==b   KK   @ 3sSTvhW X  s,A:D=ADADD E*+EE)r,r-r.)NNNrY)rNNN) NN)__name__ __module__ __qualname____firstlineno____doc__r2rUrJr{rrrr__static_attributes____classdictcell__)r>s@r1r r saCq f//bGGR// Q QD884111r4r )rtypingrrrrrpandaspdrrapp.services.database_servicer app.utils.helpersr r r4r1rs* 43(9(ggr4