+ ZjFHaRt!0tRt^RIt^RIt^RIt^RIt^RIHtHtH t H t H t H t ^RI H t Ht^RIt^RIt^RIHt^RIt^RIt^RIt^RIHt^RIHt^RIHtRRR R R R R R /t]^k!RR4t R#)zT Prophet Service Module Handles Facebook Prophet time series forecasting operations N)DictListOptionalAnyTupleUnion)datetime timedelta)Prophet) get_logger) MySQLModelMMEQQEYYEAca]tRt^toRt/t]P!4tRt ]P!4t Rt V3RlRlt V3RlRlt V3RlR ltV3R lR ltV3R lR ltV3RlRltRtV3RlRltV3RlRltR(V3RlRlltR)V3RlRlltR*V3RlRlltR+V3RlRlltV3RlRltV3R lR!ltV3R"lR#ltV3R$lR%ltV3R&ltR'tVtR#),ProphetServicez2ProphetService._model_file_path..Os%YPX1yy{{a:o!3FPXs-/z.joblib)joinr9pathr2)rrEsafe_ids&& r_model_file_pathProphetService._model_file_pathNs<''YPXYYww||D//1gYg3FGGr!c,<V^8dQhRS[RS[RS[/#)r$rEpayloadr%r'r)r(r)s"rr*r+Rs"cDSr!cXVPV4p\P!W#^R7V#))compress)rSjoblibdump)rrErV file_paths&&& r _save_to_diskProphetService._save_to_diskRs&))(3  G3r!c,<V^8dQhRS[RS[RS[/#)r$rEr]r%rW)r(r)s"rr*r+Ws"&&&&&r!c\PPV4'g\RV RV R24h\P !V4#)zModel file for 'z' not found at '')r9rQisfileFileNotFoundErrorr[load)rrEr]s&&&r_load_from_diskProphetService._load_from_diskWsCww~~i((#&6xj@PQZP[[\$]^ ^{{9%%r!c rRpVPPWqV\P!V4WEV34R#)a INSERT INTO ml_prophet_models (model_id, file_path, config, data_points, train_start, train_end) VALUES (%s, %s, %s, %s, %s, %s) ON DUPLICATE KEY UPDATE file_path=VALUES(file_path), config=VALUES(config), data_points=VALUES(data_points), train_start=VALUES(train_start), train_end=VALUES(train_end), updated_at=CURRENT_TIMESTAMP N)rr@jsondumps)rrEr]r1 data_points train_start train_endsqls&&&&&&& r_upsert_metadataProphetService._upsert_metadata\s2  sy$**V:Lkhq$rsr!c6<V^8dQhRS[RS[S[,/#rD)r'rr)r(r)s"rr*r+gs    r!cVPPRV34pV'gR#V^,p\VPR4\4'd!\ P !VR,4VR&V#)z;SELECT * FROM ml_prophet_models WHERE model_id = %s LIMIT 1Nr1)rr@ isinstancegetr'riloads)rrErowsrows&& r_fetch_metadataProphetService._fetch_metadatags_xx%% IH; 1g cggh' - - JJs8}5CM r!c&<V^8dQhRS[RS[/#rDrW)r(r)s"rr*r+rsstr!c \\P;_uu_4V\P9d"\PV,uuRRR4#RRR4VPV4pVf\ RV R24hVP WR,4p\P;_uu_4T\PT&RRR4T# +'giL;i \ d.TPPRT34\RT R24hi;i +'giT#;i)u8Three-layer fetch: process cache → DB metadata + disk.NzModel 'z ' not foundr]1DELETE FROM ml_prophet_models WHERE model_id = %sz<' file is missing. Orphaned record removed. Please re-train.) r _cache_lock_cacherx ValueErrorrfrdrr@ RuntimeError)rrEmetarVs&& r_resolve_modelProphetService._resolve_modelrs ' ' '>000%,,X6( '0( ##H- <wxj <= = **8+5FGG ' ' '.5N ! !( +(+( '!  HH " "#VYaXc d(#_`  ( 's#,C >C.D C 8D D+ cV<V^8dQhRS[S[,RS[RS[RS[P/#)r$data date_column value_columnr%)rrr'pd DataFrame)r(r)s"rr*r+s5 ? ?tDz ? ?Z] ?hjhtht ?r!c $\P!V4pW$P9d0\P!WB,4WB&VP V4pW4P9d!\P !WC,RR7WC&VP 4pVPPR\V4 R24V# \dDpTPPR\T4 24\R\T4 24hRp?ii;i)z Prepare data for Prophet model Args: data: List of dictionaries with date and value columns date_column: Name of the date column value_column: Name of the value column Returns: Pandas DataFrame formatted for Prophet coerce)errorszPrepared DataFrame with z rows for ProphetzError preparing DataFrame: zInvalid data format: N)rrcolumns to_datetime sort_values to_numericdropnarinfolen Exceptionerrorr'r)rrrrdfes&&&& r_prepare_dataframe!ProphetService._prepare_dataframes ?d#Bjj("$.."A^^K0zz)#%==1A(#S B KK  7By@QR SI ? KK   ;CF8D E4SVH=> > ?sB>C D >D  DNc x<V^8dQhRS[S[,RS[S[,RS[S[,RS[S[S[3,/#)r$rrEr1r%)rrrr'r)r(r)s"rr*r+sMLL4jL3-L L c3h Lr!c VPV4p\V4^8d \R4hRRRRRRRRR R R R R R RRRR/ pV'dVPV4\ R'/VBpVP V4V'g(R\ P!4PR4 2pVR,P4PR4pVR,P4PR4pRVRVRVR\ P!4R\V4RVRV/p \P;_uu_4VPW)4p VPW*V\V4Wx4V \PV&RRR4VP P#RV R\V4 R24R VR!R"R\V4RVR#R$VR,P4P%4R%VR,P4P%4//# +'giL;i \&d.p TP P)R&\+T 4 24hRp ? ii;i)(z Train a Prophet model Args: data: Time series data model_id: Optional model identifier for storage config: Prophet configuration parameters Returns: Training results with model info z?Insufficient data for training (minimum 2 data points required)seasonality_modeadditiveyearly_seasonalityTweekly_seasonalitydaily_seasonalityFchangepoint_prior_scaleg?seasonality_prior_scaleg$@holidays_prior_scalechangepoint_rangeg?interval_widthprophet_z %Y%m%d_%H%M%Sds%Y-%m-%dmodelr1 training_data created_atrkrlrmNzTrained Prophet model z with z data pointsrEstatustrainedtraining_date_rangestartendzError training Prophet model: r6)rrrupdater fitrnowstrftimeminmaxrr}r^ror~rr isoformatrrr') rrrEr1rprophet_configrrlrmrVr]rs &&&& r train_modelProphetService.train_models#"; ((.B2w{ !bcc#J$d$d#U)4)4&#S $ N%%f--n-E IIbM%hlln&=&=o&N%OPT(,,.11*=KT(,,.11*=I./2hllnmSW{KG  +++ ..xA %%h>3r7T_k29%%h/, KK  5hZvc"gYl[ \H)s2w.%RX\\^5572d8<<>335(  ,+$  KK   >s1vhG H  s9AH C,H6AH 8BH H H I((IIc N<V^8dQhRS[RS[RS[RS[RS[S[S[3,/#)r$rEperiodsfreqinclude_historyr%)r'intboolrr)r(r)s"rr*r+sLBBBB B  B c3h Br!c VPV4pVR,p\PW34pVPW#R7pVP V4pV'g\ VR,4M^p .p \ V \ V44Fp V PRVR,PV ,PR4R\R\\VR,PV ,4^44R\R\\VR,PV ,4^44R \R\\VR ,PV ,4^44/4K R VR VR VR V R\P!4P4/p V'deVR,p RV R,P PR4P#4RV R,P^4P#4/V R&VP$P'RV RV R24V # \(d.pTP$P+R\-T4 24hRp?ii;i)a( Generate forecast using trained model Args: model_id: ID of the trained model periods: Number of periods to forecast freq: Frequency of forecast ('D' for daily, 'H' for hourly, etc.) include_history: Whether to include historical data in response Returns: Forecast results rrrrrryhatg yhat_lower yhat_upperrEforecast_periods frequencyforecast generated_atyhistorical_datazGenerated forecast for model z: z periodszError generating forecast: N)r _FREQ_ALIASESrtmake_future_dataframepredictrrangeappendilocrrroundfloatrrrdttolistrrrrr')rrErrr model_inforfuturer start_idx forecast_rowsiresultrrs&&&&& rgenerate_forecast ProphetService.generate_forecasts#&/ ,,X6Jw'E!$$T0D000LF}}V,H APJ78UVIM9c(m4$$(4."5"5a"8"A"A*"M#c5x7G7L7LQ7O1PRS+T"U #c5x 7M7R7RST7U1VXY+Z"[ #c5x 7M7R7RST7U1VXY+Z"[ &5H"GTM  8 8 : F *? ; --0099*ELLNs+11!4;;=-() KK  <V^8dQhRS[RS[RS[RS[RS[RS[/#)r$rErrwidthheightr%)r'r)r(r)s"rr*r+HsG1111 1  1  1 1r!c VPV4pVR,p\PW34pVPW#R7pVP V4p VP W^d, V^d, 3R7p \ P!4p V PV R^dRR7V P^4\P!V P44PR4p V P4\P!V 4VP P#RV 24R V 2# \$d.p TP P'R \)T 4 24hR p ? ii;i) a Generate forecast plot as base64 encoded image Args: model_id: ID of the trained model periods: Number of periods to forecast freq: Frequency of forecast width: Plot width in pixels height: Plot height in pixels Returns: Base64 encoded PNG image rr)figsizepngtight)r(dpi bbox_incheszutf-8zGenerated plot for model zdata:image/png;base64,zError generating plot: N)rrrtrrplotioBytesIOsavefigseekbase64 b64encodegetvaluedecodeclosepltrrrrr')rrErrrrrrrrfigbuffer image_base64rs&&&&&& r generate_plotProphetService.generate_plotHs/* ,,X6Jw'E!$$T0D000LF}}V,H**Xc 6#:/F*GCZZ\F KKu#7K K KKN!++FOO,=>EEgNL LLN IIcN KK  8 C D+L>: :  KK   7Ax@ A  sD*D-- E%8(E  E%cL<V^8dQhRS[RS[S[S[S[3,,/#rD)r'rrr)r(r)s"rr*r+{s(  s xS#X/G r!c 4\P;_uu_4V\P9do\PV,pRVR,RVR,RVR,P4RVP R4RVP R4/uuRRR4#RRR4VP V4pVfR#RVR,RVR,R\ VR,4R\ VR,4R\ VR,4/# +'giLq;i)z Get information about a trained model Args: model_id: ID of the model Returns: Model information or None if not found rkr1rrlrmN)rr}r~rrtrxr')rrErMrs&& rget_model_infoProphetService.get_model_info{s ' ' '>000"))(3!1]#3Xq{ !L/";";"=!155#7aeeKFX( '0(##H- < 4 .$x. #d<01 3tM23[#d;FWBX  ( 's A9D D cF<V^8dQhRS[S[S[S[3,,/#r#)rrr'r)r(r)s"rr*r+s!T$sCx.1r!c VPPR4p.pVFp\VR,\4'd VR,M\P !VR,4pVP RVR,RVR,RVR\VR,4R\VR,4R\VR,4/4K V#)z? List all trained models Returns: List of model summaries zxSELECT model_id, data_points, config, train_start, train_end, created_at FROM ml_prophet_models ORDER BY created_at DESCr1rErkrlrmr)rr@rsdictrirurr')rrvrrwr1s& r list_modelsProphetService.list_modelssxx%% > C&0X&E&ES]4::VYZbVcKdF MMC O]C #8#88H( <  ' ' '  ! ! % %h 5(  I77>>${"344IId;/0 RU]T_`!( ' ( ' I ##&CA3$GHH Is5D,!D+D, D, D  D) , E7EEcL<V^8dQhRS[S[,RS[S[S[3,/#)r$rr%)rrrrr')r(r)s"rr*r+s(!!d!dCi8H!r!c \V\4'd\V4^8dR #RR0p\V4Fwr4\V\4'g RRV R23u#VP VP 44'g RRV R23u#\P!VR,4\TR,4K R # RRT 23uu#;i RRT 23uu#;i) z Validate input data format for Prophet Args: data: Input data to validate Returns: Tuple of (is_valid, error_message) Frrz Data point z must be a dictionaryz must contain 'ds' and 'y' keysz"Invalid date format in data point z$Invalid numeric value in data point )Fz/Data must be a list with at least 2 data points)TrG) rslistr enumeraterissubsetkeysrrr)rr required_keysritems&& rvalidate_data_format#ProphetService.validate_data_formats$%%TQK Ks  GAdD)) A3.CDDD ))$))+66 A3.MNNN GtDz*  Id3i '& G B1#FFF  I DQCHHHs C+C C C c<<V^8dQh/S[S[S[3,;R&#)r$r~)rr'r)r(r)s"rr*r+s cNr!)rr)rr)NN)DT)rri iX) __name__ __module__ __qualname____firstlineno____doc__r~ threadingLockr}r>r?rr2rrrSr^rfrorxrrrrrrrrr__annotate_func____static_attributes____classdictcell__)r)s@rrrsFF.."KN.."K!77::112HH && t  < ? ?LLL\BBH11f  6*:!!Y r!rcbV^8dQh/^\9d\\\3,;R&#)r$r)__conditional_annotations__rr')r(s"rr*r*s'0MLtCH~L1r!)"r!rr9riloggingrtypingrrrrrrrr pandasrnumpynpprophetr rrr[matplotlib.pyplotpyplotrapp.utils.helpersr app.models.mysql_modelr rrr*)r!s@rr,sd  ::( (-"%dCsD#t L LMMr!