11from flask import Blueprint , render_template , request
22from flask_login import login_required
33from datetime import datetime
4- from scripts import database as db
5- from scripts import google_services as gcp
6- from scripts import data_fetcher as dfetch
4+ from scripts . database import insert_batch_universe , execute_query
5+ from scripts . google_services import get_universe_tickers_from_gsheet
6+ from scripts . data_fetcher import get_data_for_db_between_dates
77
88
99views_bp = Blueprint ("views" , __name__ )
@@ -24,16 +24,16 @@ def run_script():
2424 return redirect (url_for ("views.welcome" ))
2525
2626 # 1. Prendo i tickers da Google Sheets
27- tickers = gcp . get_universe_tickers_from_gsheet ()
27+ tickers = get_universe_tickers_from_gsheet ()
2828
2929 # 2. Trunco la tabella universe
30- database . execute_query ("TRUNCATE TABLE universe RESTART IDENTITY CASCADE" , fetch = False )
30+ execute_query ("TRUNCATE TABLE universe RESTART IDENTITY CASCADE" , fetch = False )
3131
3232 # 3. Scarico i dati da yfinance
33- rows = dfetch . get_data_for_db_between_dates (tickers , start_date , end_date )
33+ rows = get_data_for_db_between_dates (tickers , start_date , end_date )
3434
3535 # 4. Inserisco i dati nel DB
36- inserted = db . insert_batch_universe (rows , conflict_resolution = "DO NOTHING" )
36+ inserted = insert_batch_universe (rows , conflict_resolution = "DO NOTHING" )
3737
3838 flash (f"Script eseguito correttamente ✅ ({ inserted } righe inserite)" , "success" )
3939 except Exception as e :
@@ -70,7 +70,7 @@ def run_query():
7070 error = "⚠️ Nessuna query inviata"
7171 else :
7272 try :
73- fetched , column_names = db . execute_query (query )
73+ fetched , column_names = execute_query (query )
7474 if fetched :
7575 columns = column_names # qui metti i nomi reali
7676 results = fetched
0 commit comments