From fc9b4e6257483256c0e7e7d50772b67a413d5a85 Mon Sep 17 00:00:00 2001 From: zzlgreat Date: Fri, 14 Nov 2025 15:20:58 +0800 Subject: [PATCH] update ui --- app.py | 60 ++++++++++++++++++++++++++++------------------------------ 1 file changed, 29 insertions(+), 31 deletions(-) diff --git a/app.py b/app.py index 0384f2c2..2f633395 100755 --- a/app.py +++ b/app.py @@ -8657,7 +8657,7 @@ def get_stock_info(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode).fetchone() + result = conn.execute(query, {'seccode': seccode}).fetchone() if not result: return jsonify({ @@ -8681,7 +8681,7 @@ def get_stock_info(seccode): """) with engine.connect() as conn: - forecast_result = conn.execute(forecast_query, seccode=seccode).fetchone() + forecast_result = conn.execute(forecast_query, {'seccode': seccode}).fetchone() data = { 'stock_code': result.SECCODE, @@ -8843,7 +8843,7 @@ def get_balance_sheet(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, limit=limit) + result = conn.execute(query, {'seccode': seccode, 'limit': limit}) data = [] for row in result: @@ -9034,7 +9034,7 @@ def get_income_statement(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, limit=limit) + result = conn.execute(query, {'seccode': seccode, 'limit': limit}) data = [] for row in result: @@ -9244,7 +9244,7 @@ def get_cashflow(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, limit=limit) + result = conn.execute(query, {'seccode': seccode, 'limit': limit}) data = [] for row in result: @@ -9480,7 +9480,7 @@ def get_financial_metrics(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, limit=limit) + result = conn.execute(query, {'seccode': seccode, 'limit': limit}) data = [] for row in result: @@ -9621,7 +9621,7 @@ def get_main_business(seccode): """) with engine.connect() as conn: - periods = conn.execute(period_query, seccode=seccode, limit=limit).fetchall() + periods = conn.execute(period_query, {'seccode': seccode, 'limit': limit}).fetchall() # 产品分类数据 product_data = [] @@ -9640,7 +9640,7 @@ def get_main_business(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, enddate=period[0]) + result = conn.execute(query, {'seccode': seccode, 'enddate': period[0]}) # Convert result to list to allow multiple iterations rows = list(result) @@ -9690,7 +9690,7 @@ def get_main_business(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, enddate=period[0]) + result = conn.execute(query, {'seccode': seccode, 'enddate': period[0]}) # Convert result to list to allow multiple iterations rows = list(result) @@ -9752,7 +9752,7 @@ def get_forecast(seccode): """) with engine.connect() as conn: - forecast_result = conn.execute(forecast_query, seccode=seccode) + forecast_result = conn.execute(forecast_query, {'seccode': seccode}) forecast_data = [] for row in forecast_result: @@ -9794,7 +9794,7 @@ def get_forecast(seccode): """) with engine.connect() as conn: - pretime_result = conn.execute(pretime_query, seccode=seccode) + pretime_result = conn.execute(pretime_query, {'seccode': seccode}) pretime_data = [] for row in pretime_result: @@ -9894,7 +9894,7 @@ def get_industry_rank(seccode): # 获取多个报告期的数据 with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, limit_total=limit * 4) + result = conn.execute(query, {'seccode': seccode, 'limit_total': limit * 4}) # 按报告期和行业级别组织数据 data_by_period = {} @@ -10015,7 +10015,7 @@ def get_period_comparison(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, periods=periods) + result = conn.execute(query, {'seccode': seccode, 'periods': periods}) data = [] for row in result: @@ -10140,7 +10140,7 @@ def get_trade_data(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, end_date=end_date, days=days) + result = conn.execute(query, {'seccode': seccode, 'end_date': end_date, 'days': days}) data = [] for row in result: @@ -10217,7 +10217,7 @@ def get_funding_data(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, days=days) + result = conn.execute(query, {'seccode': seccode, 'days': days}) data = [] for row in result: @@ -10276,7 +10276,7 @@ def get_bigdeal_data(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode, days=days) + result = conn.execute(query, {'seccode': seccode, 'days': days}) data = [] for row in result: @@ -10351,7 +10351,7 @@ def get_unusual_data(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode) + result = conn.execute(query, {'seccode': seccode}) data = [] for row in result: @@ -10430,7 +10430,7 @@ def get_pledge_data(seccode): """) with engine.connect() as conn: - result = conn.execute(query, seccode=seccode) + result = conn.execute(query, {'seccode': seccode}) data = [] for row in result: @@ -10488,11 +10488,11 @@ def get_market_summary(seccode): """) with engine.connect() as conn: - trade_result = conn.execute(trade_query, seccode=seccode).fetchone() + trade_result = conn.execute(trade_query, {'seccode': seccode}).fetchone() with engine.connect() as conn: - funding_result = conn.execute(funding_query, seccode=seccode).fetchone() + funding_result = conn.execute(funding_query, {'seccode': seccode}).fetchone() with engine.connect() as conn: - pledge_result = conn.execute(pledge_query, seccode=seccode).fetchone() + pledge_result = conn.execute(pledge_query, {'seccode': seccode}).fetchone() summary = { 'stock_code': seccode, @@ -11051,7 +11051,7 @@ def get_comprehensive_analysis(company_code): """) with engine.connect() as conn: - qualitative_result = conn.execute(qualitative_query, company_code=company_code).fetchone() + qualitative_result = conn.execute(qualitative_query, {'company_code': company_code}).fetchone() # 获取业务板块分析 segments_query = text(""" @@ -11069,7 +11069,7 @@ def get_comprehensive_analysis(company_code): """) with engine.connect() as conn: - segments_result = conn.execute(segments_query, company_code=company_code).fetchall() + segments_result = conn.execute(segments_query, {'company_code': company_code}).fetchall() # 获取竞争地位数据 - 最新一期 competitive_query = text(""" @@ -11095,7 +11095,7 @@ def get_comprehensive_analysis(company_code): """) with engine.connect() as conn: - competitive_result = conn.execute(competitive_query, company_code=company_code).fetchone() + competitive_result = conn.execute(competitive_query, {'company_code': company_code}).fetchone() # 获取业务结构数据 - 最新一期 business_structure_query = text(""" @@ -11123,7 +11123,7 @@ def get_comprehensive_analysis(company_code): """) with engine.connect() as conn: - business_structure_result = conn.execute(business_structure_query, company_code=company_code).fetchall() + business_structure_result = conn.execute(business_structure_query, {'company_code': company_code}).fetchall() # 构建返回数据 response_data = { @@ -11261,7 +11261,7 @@ def get_value_chain_analysis(company_code): """) with engine.connect() as conn: - nodes_result = conn.execute(nodes_query, company_code=company_code).fetchall() + nodes_result = conn.execute(nodes_query, {'company_code': company_code}).fetchall() # 获取产业链流向数据 flows_query = text(""" @@ -11282,7 +11282,7 @@ def get_value_chain_analysis(company_code): """) with engine.connect() as conn: - flows_result = conn.execute(flows_query, company_code=company_code).fetchall() + flows_result = conn.execute(flows_query, {'company_code': company_code}).fetchall() # 构建节点数据结构 nodes_by_level = {} @@ -11393,7 +11393,7 @@ def get_key_factors_timeline(company_code): """) with engine.connect() as conn: - categories_result = conn.execute(categories_query, company_code=company_code).fetchall() + categories_result = conn.execute(categories_query, {'company_code': company_code}).fetchall() # 获取关键因素详情 factors_query = text(""" @@ -11479,9 +11479,7 @@ def get_key_factors_timeline(company_code): """) with engine.connect() as conn: - timeline_result = conn.execute(timeline_query, - company_code=company_code, - limit=event_limit).fetchall() + timeline_result = conn.execute(timeline_query, {'company_code': company_code, 'limit': event_limit}).fetchall() # 构建关键因素数据结构 key_factors_data = {}