!+i `dZddlZddlmZddlmZej eZGddZ y)zF Data Processor Service Orchestrates daily data synchronization jobs. N)Session) SyncEnginec6eZdZdZdefdZdZdZd defdZ y) DataProcessorServicezt Service that orchestrates daily sync operations. Used by scheduler/jobs.py for the run_daily_sync job. dbc0||_t|_y)N)rr sync_engine)selfrs I/var/www/hypershopcomercio.com.br/hyper-ai/app/services/data_processor.py__init__zDataProcessorService.__init__s%<ctjd tjd|jjtjd|jj tjd|jj tjd|jj tjd|jjtjdy #t$r}tjd|d }~wwxYw) a Runs the complete daily sync pipeline: 1. Sync Ads (listings, prices, status) 2. Sync Visits (CRITICAL - fetches visit data from ML API) 3. Sync Orders (recent orders) 4. Sync Stock (Tiny ERP stock levels) 5. Recalculate Margins z(========== DAILY SYNC STARTED ==========z[1/5] Syncing Ads...z[2/5] Syncing Visits...z[3/5] Syncing Orders...z[4/5] Syncing Stock...z[5/5] Recalculating Margins...z*========== DAILY SYNC COMPLETED ==========zDaily sync failed: N) loggerinfor sync_ads sync_visits sync_orderssync_tiny_stock sync_margins Exceptionerror)r es r sync_daily_dataz$DataProcessorService.sync_daily_datas  >?  KK. /    % % ' KK1 2    ( ( * KK1 2    ( ( * KK0 1    , , . KK8 9    ) ) + KKD E  LL.qc2 3  sDD D?!D::D?ctjd|jjtjdy)zQ Syncs only visits data. Useful for manual trigger or debugging. zSyncing visits only...zVisits sync completed.N)rrr r)r s r sync_visits_onlyz%DataProcessorService.sync_visits_only<s0  ,- $$& ,-r lookback_hoursctjd|d|jj|tjdy)z? Syncs only orders with configurable lookback. zSyncing orders (lookback=zh)...)rzOrders sync completed.N)rrr sync_orders_incremental)r rs r sync_orders_onlyz%DataProcessorService.sync_orders_onlyDs?  //?uEF 000O ,-r N)0) __name__ __module__ __qualname____doc__rr rrintrr r rr s* (7($L..s.r r) r$loggingsqlalchemy.ormrapp.services.sync_enginer getLoggerr!rrr&r r r+s1"/   8 $>.>.r