AlanRex commited on
Commit
14cd3f1
·
verified ·
1 Parent(s): 594bf67

Upload app.py

Browse files
Files changed (1) hide show
  1. app.py +901 -0
app.py ADDED
@@ -0,0 +1,901 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ # HUGING_FACE_V3.1.2.py (整合 Bert_predict 版本)
2
+
3
+ # 系統套件
4
+ import os
5
+ from datetime import datetime, timedelta
6
+ import google.generativeai as genai
7
+ import pandas as pd
8
+ import numpy as np
9
+ import yfinance as yf
10
+ from dash import Dash, dcc, html, callback
11
+ import dash
12
+ import plotly.express as px
13
+ import plotly.graph_objects as go
14
+ from plotly.subplots import make_subplots
15
+ import re
16
+ from bs4 import BeautifulSoup
17
+ import requests
18
+ import time # 引用 time 模組以處理時間戳
19
+
20
+ # ========================= 引用外部模組 START =========================
21
+ # 引用您組員的預測器程式
22
+ from Bert_predict import BertPredictor
23
+
24
+ # 引用新的模型預測器
25
+ from model_predictor import advanced_lstm_predict
26
+ # ========================== 引用外部模組 END ==========================
27
+
28
+ # ========================= 全域設定 START =========================
29
+ # 【【【模型切換開關】】】
30
+ # False: 使用簡易統計模型 (預設)
31
+ # True: 使用 model_predictor.py 中的進階 LSTM 模型 (未來啟用)
32
+ USE_ADVANCED_MODEL = False
33
+
34
+
35
+ # ========================= CACHE 設定 START =========================
36
+ # 分析結果的快取字典
37
+ ANALYSIS_CACHE = {}
38
+ # 快取有效時間(秒),例如:4 小時 = 4 * 60 * 60 = 14400 秒
39
+ CACHE_DURATION_SECONDS = 8 * 60 * 60
40
+ # ========================== CACHE 設定 END ==========================
41
+ # ========================== 全域設定 END ==========================
42
+
43
+ # 台股代號對應表 (移除台指期,因為它現在是獨立區塊)
44
+ TAIWAN_STOCKS = {
45
+ '元大台灣50': '0050.TW',
46
+ '台積電': '2330.TW',
47
+ '聯發科': '2454.TW',
48
+ '鴻海': '2317.TW',
49
+ '台達電': '2308.TW',
50
+ '廣達': '2382.TW',
51
+ '富邦金': '2881.TW',
52
+ '中信金': '2891.TW',
53
+ '國泰金': '2882.TW',
54
+ '聯電': '2303.TW',
55
+ '中華電': '2412.TW',
56
+ '玉山金': '2884.TW',
57
+ '兆豐金': '2886.TW',
58
+ '日月光投控': '3711.TW',
59
+ '華碩': '2357.TW',
60
+ '統一': '1216.TW',
61
+ '元大金': '2885.TW',
62
+ '智邦': '2345.TW',
63
+ '緯創': '3231.TW',
64
+ '聯詠': '3034.TW',
65
+ '第一金': '2892.TW',
66
+ '瑞昱': '2379.TW',
67
+ '緯穎': '6669.TWO',
68
+ '永豐金': '2890.TW',
69
+ '合庫金': '5880.TW',
70
+ '華南金': '2880.TW',
71
+ '台光電': '2383.TW',
72
+ '世芯-KY': '3661.TWO',
73
+ '奇鋐': '3017.TW',
74
+ '凱基金': '2883.TW',
75
+ '大立光': '3008.TW',
76
+ '長榮': '2603.TW',
77
+ '光寶科': '2301.TW',
78
+ '中鋼': '2002.TW',
79
+ '中租-KY': '5871.TW',
80
+ '國巨': '2327.TW',
81
+ '台新金': '2887.TW',
82
+ '上海商銀': '5876.TW',
83
+ '台泥': '1101.TW',
84
+ '台灣大': '3045.TW',
85
+ '和碩': '4938.TW',
86
+ '遠傳': '4904.TW',
87
+ '和泰車': '2207.TW',
88
+ '研華': '2395.TW',
89
+ '台塑': '1301.TW',
90
+ '統一超': '2912.TW',
91
+ '藥華藥': '6446.TWO',
92
+ '南亞': '1303.TW',
93
+ '陽明': '2609.TW',
94
+ '萬海': '2615.TW',
95
+ '台塑化': '6505.TW',
96
+ '慧洋-KY': '2637.TW',
97
+ '上銀': '2049.TW',
98
+ '台泥': '1101.TW',
99
+ '南亞科': '2408.TW',
100
+ '旺宏': '2337.TW',
101
+ '譜瑞-KY': '4966.TWO',
102
+ '貿聯-KY': '3665.TW',
103
+ '騰雲': '6870.TWO',
104
+ '穩懋': '3105.TWO'
105
+ }
106
+
107
+ # 產業分類
108
+ INDUSTRY_MAPPING = {
109
+ '0050.TW': 'ETF',
110
+ '2330.TW': '半導體',
111
+ '2454.TW': '半導體',
112
+ '2317.TW': '電子組件',
113
+ '2308.TW': '電子',
114
+ '2382.TW': '電子',
115
+ '2881.TW': '金融',
116
+ '2891.TW': '金融',
117
+ '2882.TW': '金融',
118
+ '2303.TW': '半導體',
119
+ '2412.TW': '電信',
120
+ '2884.TW': '金融',
121
+ '2886.TW': '金融',
122
+ '3711.TW': '半導體',
123
+ '2357.TW': '電子',
124
+ '1216.TW': '食品',
125
+ '2885.TW': '金融',
126
+ '2345.TW': '網通設備',
127
+ '3231.TW': '電子',
128
+ '3034.TW': '半導體',
129
+ '2892.TW': '金融',
130
+ '2379.TW': '半導體',
131
+ '6669.TWO': '電子',
132
+ '2890.TW': '金融',
133
+ '5880.TW': '金融',
134
+ '2880.TW': '金融',
135
+ '2383.TW': '電子',
136
+ '3661.TWO': '半導體',
137
+ '3017.TW': '電子',
138
+ '2883.TW': '金融',
139
+ '3008.TW': '光學',
140
+ '2603.TW': '航運',
141
+ '2301.TW': '電子',
142
+ '2002.TW': '鋼鐵',
143
+ '5871.TW': '金融',
144
+ '2327.TW': '電子被動元件',
145
+ '2887.TW': '金融',
146
+ '5876.TW': '金融',
147
+ '1101.TW': '營建',
148
+ '3045.TW': '電信',
149
+ '4938.TW': '電子',
150
+ '4904.TW': '電信',
151
+ '2207.TW': '汽車',
152
+ '2395.TW': '電腦周邊',
153
+ '1301.TW': '塑膠',
154
+ '2912.TW': '百貨',
155
+ '6446.TWO': '生技',
156
+ '1303.TW': '塑膠',
157
+ '2609.TW': '航運',
158
+ '2615.TW': '航運',
159
+ '6505.TW': '塑膠',
160
+ '2637.TW': '散裝航運',
161
+ '2049.TW': '工具機',
162
+ '1101.TW': '營建',
163
+ '2408.TW': 'DRAM',
164
+ '2337.TW': 'NFLSH',
165
+ '4966.TWO': '高速傳輸',
166
+ '3665.TW': '連接器',
167
+ '6870.TWO': '軟體整合',
168
+ '3105.TWO': 'PA功率'
169
+ }
170
+
171
+ def get_stock_data(symbol, period='1y'):
172
+ """獲取股票資料"""
173
+ try:
174
+ stock = yf.Ticker(symbol)
175
+ data = stock.history(period=period)
176
+ if data.empty and symbol == 'TXF=F':
177
+ stock = yf.Ticker('0050.TW')
178
+ data = stock.history(period=period)
179
+ if data.empty:
180
+ stock = yf.Ticker('^TWII')
181
+ data = stock.history(period=period)
182
+ return data
183
+ except:
184
+ return pd.DataFrame()
185
+
186
+ def simple_statistical_predict(data, predict_days=5):
187
+ """【備用模型】簡化的統計預測模型。"""
188
+ if len(data) < 60: return None
189
+ prices = data['Close'].values
190
+ ma_short = np.mean(prices[-5:])
191
+ ma_medium = np.mean(prices[-20:])
192
+ ma_long = np.mean(prices[-60:])
193
+ recent_trend = np.polyfit(range(20), prices[-20:], 1)[0]
194
+ volatility = np.std(prices[-20:]) / np.mean(prices[-20:])
195
+ base_change = recent_trend * predict_days
196
+ trend_factor = 1.0 + (0.02 if ma_short > ma_medium > ma_long else -0.02 if ma_short < ma_medium < ma_long else 0)
197
+ noise_factor = np.random.normal(1, volatility * 0.1)
198
+ predicted_price = prices[-1] * trend_factor + base_change + (prices[-1] * noise_factor * 0.01)
199
+ change_pct = ((predicted_price - prices[-1]) / prices[-1]) * 100
200
+ return {'predicted_price': predicted_price, 'change_pct': change_pct, 'confidence': max(0.6, 1 - volatility * 2)}
201
+
202
+ def get_prediction(data, predict_days=5):
203
+ """
204
+ 【【模型預測控制器】】
205
+ 根據 USE_ADVANCED_MODEL 的設定,呼叫對應的預測模型。
206
+ """
207
+ if USE_ADVANCED_MODEL:
208
+ print(f"模式: 進階LSTM模型 | 預測天期: {predict_days}天")
209
+ prediction = advanced_lstm_predict(predict_days)
210
+ # 如果進階模型預測失敗,則自動降級使用簡易模型
211
+ if prediction is not None:
212
+ return prediction
213
+ else:
214
+ print("進階模型預測失敗,自動降級為簡易統計模型。")
215
+
216
+ # 預設或降級時執行簡易模型
217
+ print(f"模式: 簡易統計模型 | 預測天期: {predict_days}天")
218
+ return simple_statistical_predict(data, predict_days)
219
+
220
+ def calculate_technical_indicators(df):
221
+ """計算技術指標"""
222
+ if df.empty: return df
223
+ df['MA5'] = df['Close'].rolling(window=5).mean()
224
+ df['MA20'] = df['Close'].rolling(window=20).mean()
225
+ delta = df['Close'].diff()
226
+ gain = (delta.where(delta > 0, 0)).rolling(window=14).mean()
227
+ loss = (-delta.where(delta < 0, 0)).rolling(window=14).mean()
228
+ rs = gain / loss
229
+ df['RSI'] = 100 - (100 / (1 + rs))
230
+ exp1 = df['Close'].ewm(span=12).mean()
231
+ exp2 = df['Close'].ewm(span=26).mean()
232
+ df['MACD'] = exp1 - exp2
233
+ df['MACD_Signal'] = df['MACD'].ewm(span=9).mean()
234
+ df['MACD_Histogram'] = df['MACD'] - df['MACD_Signal']
235
+ df['BB_Middle'] = df['Close'].rolling(window=20).mean()
236
+ bb_std = df['Close'].rolling(window=20).std()
237
+ df['BB_Upper'] = df['BB_Middle'] + (bb_std * 2)
238
+ df['BB_Lower'] = df['BB_Middle'] - (bb_std * 2)
239
+ low_min = df['Low'].rolling(window=9).min()
240
+ high_max = df['High'].rolling(window=9).max()
241
+ rsv = (df['Close'] - low_min) / (high_max - low_min) * 100
242
+ df['K'] = rsv.ewm(com=2).mean()
243
+ df['D'] = df['K'].ewm(com=2).mean()
244
+ low_min_14 = df['Low'].rolling(window=14).min()
245
+ high_max_14 = df['High'].rolling(window=14).max()
246
+ df['Williams_R'] = -100 * (high_max_14 - df['Close']) / (high_max_14 - low_min_14)
247
+ df['up_move'] = df['High'] - df['High'].shift(1)
248
+ df['down_move'] = df['Low'].shift(1) - df['Low']
249
+ df['+DM'] = np.where((df['up_move'] > df['down_move']) & (df['up_move'] > 0), df['up_move'], 0)
250
+ df['-DM'] = np.where((df['down_move'] > df['up_move']) & (df['down_move'] > 0), df['down_move'], 0)
251
+ df['TR'] = np.max([df['High'] - df['Low'], abs(df['High'] - df['Close'].shift(1)), abs(df['Low'] - df['Close'].shift(1))], axis=0)
252
+ df['+DI'] = (df['+DM'].ewm(com=13, adjust=False).mean() / df['TR'].ewm(com=13, adjust=False).mean()) * 100
253
+ df['-DI'] = (df['-DM'].ewm(com=13, adjust=False).mean() / df['TR'].ewm(com=13, adjust=False).mean()) * 100
254
+ df['DX'] = abs(df['+DI'] - df['-DI']) / (df['+DI'] + df['-DI']) * 100
255
+ df['ADX'] = df['DX'].ewm(com=13, adjust=False).mean()
256
+ return df
257
+
258
+ def calculate_volume_profile(df, num_bins=50):
259
+ if df.empty or 'High' not in df.columns or 'Low' not in df.columns or 'Volume' not in df.columns: return None, None, None
260
+ all_prices = np.concatenate([df['High'].values, df['Low'].values])
261
+ min_price, max_price = all_prices.min(), all_prices.max()
262
+ price_for_volume = (df['High'] + df['Low'] + df['Close']) / 3
263
+ df_vol_profile = df.copy()
264
+ df_vol_profile['Price_Indicator'] = price_for_volume
265
+ hist, bin_edges = np.histogram(df_vol_profile['Price_Indicator'], bins=num_bins, range=(min_price, max_price), weights=df_vol_profile['Volume'])
266
+ price_centers = (bin_edges[:-1] + bin_edges[1:]) / 2
267
+ return bin_edges, hist, price_centers
268
+
269
+ def get_business_climate_data():
270
+ try:
271
+ if not os.path.exists('business_climate.csv'): return pd.DataFrame()
272
+ df = pd.read_csv('business_climate.csv')
273
+ if 'Date' not in df.columns: df.columns = ['Date', 'Index'] if len(df.columns) == 2 else df.columns
274
+ if 'Date' in df.columns:
275
+ try: df['Date'] = pd.to_datetime(df['Date'] + '-01', format='%Y-%m-%d', errors='coerce')
276
+ except: df['Date'] = pd.to_datetime(df['Date'], errors='coerce')
277
+ df = df.dropna(subset=['Date'])
278
+ return df
279
+ except Exception as e:
280
+ print(f"無法獲取景氣燈號資料: {str(e)}")
281
+ return pd.DataFrame()
282
+
283
+ def get_pmi_data():
284
+ try:
285
+ if not os.path.exists('taiwan_pmi.csv'): return pd.DataFrame()
286
+ df = pd.read_csv('taiwan_pmi.csv')
287
+ if 'DATE' in df.columns: df = df.rename(columns={'DATE': 'Date', 'INDEX': 'Index'})
288
+ elif len(df.columns) == 2: df.columns = ['Date', 'Index']
289
+ if 'Date' in df.columns:
290
+ try: df['Date'] = pd.to_datetime(df['Date'] + '-01', format='%Y-%m-%d', errors='coerce')
291
+ except: df['Date'] = pd.to_datetime(df['Date'], errors='coerce')
292
+ df = df.dropna(subset=['Date'])
293
+ return df
294
+ except Exception as e:
295
+ print(f"無法獲取 PMI 資料: {str(e)}")
296
+ return pd.DataFrame()
297
+
298
+ def generate_gemini_analysis(stock_name, stock_symbol, period, data):
299
+ """
300
+ 使用 Gemini API 生成基本面和市場展望分析。
301
+ """
302
+ api_key = os.getenv("GEMINI_API_KEY")
303
+ if not api_key:
304
+ return "無法讀取 GEMINI API 金鑰", "請在系統環境變數中設定您的金鑰"
305
+
306
+ try:
307
+ genai.configure(api_key=api_key)
308
+ model = genai.GenerativeModel('gemini-1.5-flash')
309
+
310
+ price_change = ((data['Close'].iloc[-1] - data['Close'].iloc[0]) / data['Close'].iloc[0]) * 100
311
+ rsi_current = data['RSI'].iloc[-1]
312
+ macd_current = data['MACD'].iloc[-1]
313
+ macd_signal_current = data['MACD_Signal'].iloc[-1]
314
+ industry = INDUSTRY_MAPPING.get(stock_symbol, '綜合')
315
+
316
+ prompt = f"""
317
+ 請扮演一位專業、資深的台灣股市金融分析師。
318
+ 我將提供一檔台股的即時技術指標數據,請你基於這些數據,結合你對這家公司、其所在產業以及當前市場趨勢的理解,為我生成一段專業的「基本面分析」和一段「市場展望與投資建議」。
319
+
320
+ **股票資訊:**
321
+ - **公司名稱:** {stock_name} ({stock_symbol})
322
+ - **分析期間:** 最近 {period}
323
+ - **所屬產業:** {industry}
324
+ - **期間價格變動:** {price_change:+.2f}%
325
+ - **目前 RSI 指標:** {rsi_current:.2f}
326
+ - **目前 MACD 指標:** MACD線為 {macd_current:.3f}, 信號線為 {macd_signal_current:.3f}
327
+
328
+ **你的任務:**
329
+ 1. **基本面分析 (約 150 字):**
330
+ - 評論這家公司的產業地位、近期營運亮點或挑戰。
331
+ - 提及任何可能影響其基本面的關鍵因素 (例如:財報、法說會、政策、供應鏈變化等)。
332
+ - 請用專業、客觀的語氣撰寫。
333
+
334
+ 2. **市場展望與投資建議 (約 150 字):**
335
+ - 基於上述所有資訊,提供對該股票的短期和中期市場展望。
336
+ - 提出具體的投資建議,例如:適合何種類型的投資人、潛在的風險點。
337
+ - 請直接提供分析內容,不要包含任何問候語。
338
+
339
+ **輸出格式:**
340
+ 請嚴格按照以下格式回傳,使用"$$"作為兩個段落之間的分隔符:
341
+ [基本面分析內容]$$[市場展望與投資建議內容]
342
+ """
343
+
344
+ response = model.generate_content(prompt)
345
+ parts = response.text.split('$$')
346
+ if len(parts) == 2:
347
+ fundamental_analysis = parts[0].strip()
348
+ market_outlook = parts[1].strip()
349
+ return dcc.Markdown(fundamental_analysis), dcc.Markdown(market_outlook)
350
+ else:
351
+ # Fallback for unexpected response format
352
+ return dcc.Markdown("無法解析 Gemini 回應,請稍後再試。"), dcc.Markdown(response.text)
353
+
354
+ except Exception as e:
355
+ error_message = f"呼叫 Gemini API 時發生錯誤: {str(e)}"
356
+ print(error_message)
357
+ return dcc.Markdown(error_message), dcc.Markdown("請檢查後台日誌或 API 金鑰設定")
358
+
359
+ # 建立 Dash 應用程式
360
+ app = dash.Dash(__name__, suppress_callback_exceptions=True)
361
+
362
+ try:
363
+ print("正在初始化新聞情緒分析模型...")
364
+ predictor = BertPredictor(max_news_per_keyword=5)
365
+ print("新聞情緒分析模型初始化成功。")
366
+ except Exception as e:
367
+ print(f"錯誤:新聞情緒分析模型初始化失敗 - {e}")
368
+ predictor = None
369
+
370
+ # 應用程式佈局
371
+ app.layout = html.Div([
372
+ html.H1("台股分析儀表板", style={'text-align': 'center', 'margin-bottom': '30px'}),
373
+ html.Div([
374
+ html.H2("🤖 AI深度學習預測 - 台指期指數", style={'text-align': 'center','color': '#FFCC22','margin-bottom': '25px'}),
375
+ html.Div([
376
+ html.Div([
377
+ html.Label("預測期間:", style={'font-weight': 'bold', 'color': '#FFCC22'}),
378
+ dcc.Dropdown(id='taiex-prediction-period',
379
+ options=[
380
+ {'label': '1日後預測', 'value': 1},{'label': '5日後預測', 'value': 5},
381
+ {'label': '10日後預測', 'value': 10},{'label': '20日後預測', 'value': 20},
382
+ {'label': '60日後預測', 'value': 60}], value=5,
383
+ style={'margin-bottom': '10px', 'color': '#272727'})
384
+ ], style={'width': '30%', 'display': 'inline-block'}),
385
+ html.Div(id='taiex-prediction-results', style={'width': '65%', 'display': 'inline-block', 'margin-left': '5%'})
386
+ ]),
387
+ html.Div([dcc.Graph(id='taiex-prediction-chart')], style={'margin-top': '20px'})
388
+ ], style={'background': 'linear-gradient(135deg, #667eea 0%, #764ba2 100%)','padding': '25px','border-radius': '15px','box-shadow': '0 8px 25px rgba(0,0,0,0.15)','color': 'white','margin-bottom': '40px'}),
389
+
390
+ html.Div([
391
+ html.H3("📰 市場情緒與新聞分析", style={'color': '#E74C3C', 'margin-bottom': '20px'}),
392
+ html.Div([
393
+ html.Div([
394
+ html.H4("市場情緒指標", style={'color': '#8E44AD'}),
395
+ html.Div(id='sentiment-gauge')
396
+ ], style={'width': '48%', 'display': 'inline-block'}),
397
+ html.Div([
398
+ html.H4("關鍵新聞摘要", style={'color': '#27AE60'}),
399
+ html.Div(id='news-summary', style={'background': '#f8f9fa','padding': '15px','border-radius': '8px','max-height': '200px','overflow-y': 'auto'})
400
+ ], style={'width': '48%', 'display': 'inline-block', 'margin-left': '4%'})
401
+ ])
402
+ ], style={'margin-top': '30px','padding': '20px','background': 'white','border-radius': '10px','box-shadow': '0 2px 10px rgba(0,0,0,0.1)'}),
403
+
404
+ html.Div([
405
+ html.H3("景氣燈號與 PMI 分析"),
406
+ html.Div([
407
+ html.Div([dcc.Graph(id='business-climate-chart')], style={'width': '48%', 'display': 'inline-block'}),
408
+ html.Div([dcc.Graph(id='pmi-chart')], style={'width': '48%', 'display': 'inline-block', 'margin-left': '2%'})
409
+ ])
410
+ ], style={'margin-top': '30px'}),
411
+
412
+ html.Div([
413
+ html.Div([
414
+ html.Label("選擇股票:"),
415
+ dcc.Dropdown(id='stock-dropdown', options=[{'label': name, 'value': symbol} for name, symbol in TAIWAN_STOCKS.items()], value='2330.TW', style={'margin-bottom': '10px'})
416
+ ], style={'width': '30%', 'display': 'inline-block', 'vertical-align': 'top'}),
417
+ html.Div([
418
+ html.Label("時間範圍:"),
419
+ dcc.Dropdown(id='period-dropdown',
420
+ options=[{'label': '1個月', 'value': '1mo'},{'label': '3個月', 'value': '3mo'},{'label': '6個月', 'value': '6mo'},{'label': '1年', 'value': '1y'},{'label': '2年', 'value': '2y'}],
421
+ value='1mo', style={'margin-bottom': '10px'})
422
+ ], style={'width': '30%', 'display': 'inline-block', 'margin-left': '5%', 'vertical-align': 'top'}),
423
+ html.Div([
424
+ html.Label("圖表類型:"),
425
+ dcc.Dropdown(id='chart-type', options=[{'label': '線圖', 'value': 'line'},{'label': '蠟燭圖', 'value': 'candlestick'}], value='candlestick', style={'margin-bottom': '10px'})
426
+ ], style={'width': '30%', 'display': 'inline-block', 'margin-left': '5%', 'vertical-align': 'top'})
427
+ ], style={'margin-bottom': '30px'}),
428
+
429
+ html.Div(id='stock-info-cards', style={'margin-bottom': '30px'}),
430
+ html.Div([html.Div([dcc.Graph(id='price-chart')], style={'width': '100%', 'display': 'inline-block', 'vertical-align': 'top'})]),
431
+ html.Div([
432
+ html.H3("📊 進階技術指標分析", style={'margin-bottom': '20px'}),
433
+ html.Div([
434
+ html.Label("選擇技術指標:", style={'font-weight': 'bold', 'margin-right': '10px'}),
435
+ dcc.Dropdown(id='technical-indicator-selector',
436
+ options=[{'label': 'RSI 相對強弱指標', 'value': 'RSI'},{'label': 'MACD 指數平滑異同移動平均線', 'value': 'MACD'},{'label': '布林通道 Bollinger Bands', 'value': 'BB'},
437
+ {'label': 'KD 隨機指標', 'value': 'KD'},{'label': '威廉指標 %R', 'value': 'WR'},{'label': 'DMI 動向指標', 'value': 'DMI'}],
438
+ value='RSI', style={'width': '100%'})
439
+ ], style={'margin-bottom': '20px'}),
440
+ html.Div([dcc.Graph(id='advanced-technical-chart')])
441
+ ], style={'margin-top': '20px','padding': '20px','background': 'white','border-radius': '10px','box-shadow': '0 2px 10px rgba(0,0,0,0.1)'}),
442
+ html.Div([dcc.Graph(id='volume-chart')], style={'margin-top': '20px'}),
443
+ html.Div([html.H3("產業表現分析"), dcc.Graph(id='industry-analysis')], style={'margin-top': '30px'}),
444
+ html.Div([
445
+ html.H3("📊 分析師觀點與市場解讀", style={'color': '#2E86AB', 'margin-bottom': '20px'}),
446
+ html.Div([
447
+ html.Div([
448
+ html.H4("🔍 技術面分析", style={'color': '#A23B72', 'margin-bottom': '15px'}),
449
+ html.Div(id='technical-analysis-text', style={'background': '#f8f9fa','padding': '15px','border-radius': '8px','border-left': '4px solid #A23B72','min-height': '150px','font-size': '14px','line-height': '1.6'})
450
+ ], style={'width': '48%', 'display': 'inline-block', 'vertical-align': 'top'}),
451
+ html.Div([
452
+ html.H4("📈 基本面分析 (AI 生成)", style={'color': '#F18F01', 'margin-bottom': '15px'}),
453
+ html.Div(id='fundamental-analysis-text', style={'background': '#f8f9fa','padding': '15px','border-radius': '8px','border-left': '4px solid #F18F01','min-height': '150px','font-size': '14px','line-height': '1.6'})
454
+ ], style={'width': '48%', 'display': 'inline-block', 'margin-left': '4%', 'vertical-align': 'top'})
455
+ ]),
456
+ html.Div([
457
+ html.H4("🎯 市場展望與投資建議 (AI 生成)", style={'color': '#C73E1D', 'margin-bottom': '15px', 'margin-top': '25px'}),
458
+ html.Div(id='market-outlook-text', style={'background': 'linear-gradient(135deg, #667eea 0%, #764ba2 100%)','color': 'white','padding': '20px','border-radius': '10px','min-height': '100px','font-size': '15px','line-height': '1.7','box-shadow': '0 4px 15px rgba(0,0,0,0.1)'})
459
+ ])
460
+ ], style={'margin-top': '30px','padding': '25px','background': 'white','border-radius': '12px','box-shadow': '0 4px 20px rgba(0,0,0,0.08)','border': '1px solid #e9ecef'}),
461
+ html.Div([
462
+ html.H3("📊 多檔股票比較分析", style={'margin-bottom': '20px'}),
463
+ html.Div([
464
+ html.Div([
465
+ html.Label("選擇比較股票(最多5檔):", style={'font-weight': 'bold'}),
466
+ dcc.Dropdown(id='comparison-stocks', options=[{'label': name, 'value': symbol} for name, symbol in TAIWAN_STOCKS.items()], value=['0050.TW', '2330.TW', '2454.TW'], multi=True, style={'margin-bottom': '5px'}),
467
+ html.Small('(元大台灣50 (0050.TW) 為固定比較基準,不可移除)', style={'display': 'block', 'font-style': 'italic', 'color': 'gray'})
468
+ ], style={'width': '60%', 'display': 'inline-block'}),
469
+ html.Div([
470
+ html.Label("比較期間:", style={'font-weight': 'bold'}),
471
+ dcc.Dropdown(id='comparison-period', options=[{'label': '1個月', 'value': '1mo'},{'label': '3個月', 'value': '3mo'},{'label': '6個月', 'value': '6mo'},{'label': '1年', 'value': '1y'}], value='3mo')
472
+ ], style={'width': '35%', 'display': 'inline-block', 'margin-left': '5%', 'vertical-align': 'top'})
473
+ ]),
474
+ html.Div([
475
+ html.Div([dcc.Graph(id='comparison-chart')], style={'width': '65%', 'display': 'inline-block'}),
476
+ html.Div([html.H4("比較結果", style={'color': '#2E86AB'}), html.Div(id='comparison-table')], style={'width': '33%', 'display': 'inline-block', 'margin-left': '2%', 'vertical-align': 'top'})
477
+ ])
478
+ ], style={'margin-top': '30px','padding': '20px','background': 'white','border-radius': '10px','box-shadow': '0 2px 10px rgba(0,0,0,0.1)'}),
479
+ ])
480
+
481
+ @app.callback(
482
+ [dash.dependencies.Output('taiex-prediction-results', 'children'),
483
+ dash.dependencies.Output('taiex-prediction-chart', 'figure')],
484
+ [dash.dependencies.Input('taiex-prediction-period', 'value')]
485
+ )
486
+ def update_taiex_prediction(predict_days):
487
+ data = get_stock_data('^TWII', '2y')
488
+ if data.empty: return html.Div("無法獲取台指期資料"), {}
489
+
490
+ # === 修改點:統一呼叫 get_prediction 控制器 ===
491
+ final_prediction = get_prediction(data, predict_days)
492
+
493
+ if final_prediction is None: return html.Div("資料不足,無法進行預測"), {}
494
+ current_price, last_date = data['Close'].iloc[-1], data.index[-1]
495
+ predicted_price, change_pct, confidence = final_prediction['predicted_price'], final_prediction['change_pct'], final_prediction['confidence']
496
+
497
+ prediction_paths = {1: [1], 5: [1, 5], 10: [1, 5, 10], 20: [1, 10, 20], 60: [1, 10, 20, 60]}
498
+ intervals_to_predict = prediction_paths.get(predict_days, [predict_days])
499
+ prediction_dates, prediction_prices = [last_date], [current_price]
500
+
501
+ for days in intervals_to_predict:
502
+ # === 修改點:迴圈內也使用統一的預測控制器 ===
503
+ interim_prediction = get_prediction(data, days)
504
+ if interim_prediction:
505
+ prediction_dates.append(last_date + timedelta(days=days))
506
+ prediction_prices.append(interim_prediction['predicted_price'])
507
+
508
+ # (後續繪圖邏輯不變)
509
+ color, arrow = ('red', '📈') if change_pct >= 0 else ('green', '📉')
510
+ result_card = html.Div([
511
+ html.H4(f"{predict_days}日後預測結果", style={'margin': '0 0 15px 0', 'color': 'white'}),
512
+ html.Div([html.Span(f"{arrow} ", style={'font-size': '24px'}), html.Span(f"{change_pct:+.2f}%", style={'font-size': '28px','font-weight': 'bold','color': color})], style={'margin': '10px 0'}),
513
+ html.P(f"目前價格: {current_price:.2f}", style={'margin': '5px 0'}), html.P(f"預測價格: {predicted_price:.2f}", style={'margin': '5px 0'}),
514
+ html.P(f"信心度: {confidence:.1%}", style={'margin': '5px 0', 'font-size': '14px'})
515
+ ], style={'background': 'rgba(255,255,255,0.1)','padding': '20px','border-radius': '10px','border': '1px solid rgba(255,255,255,0.2)'})
516
+ fig = go.Figure()
517
+ recent_data = data.tail(30)
518
+ fig.add_trace(go.Scatter(x=recent_data.index, y=recent_data['Close'], mode='lines', name='歷史價格', line=dict(color='#FFA726', width=2)))
519
+ fig.add_trace(go.Scatter(x=prediction_dates, y=prediction_prices, mode='lines+markers', name=f'{predict_days}日預測路徑', line=dict(color=color, width=3, dash='dash'), marker=dict(size=8)))
520
+ fig.update_layout(title=f'台指期 {predict_days}日預測走勢', xaxis_title='日期', yaxis_title='指數點位', height=350, plot_bgcolor='rgba(0,0,0,0)', paper_bgcolor='rgba(0,0,0,0)', font=dict(color='white'))
521
+ return result_card, fig
522
+
523
+ @app.callback(
524
+ dash.dependencies.Output('stock-info-cards', 'children'),
525
+ [dash.dependencies.Input('stock-dropdown', 'value')]
526
+ )
527
+ def update_stock_info(selected_stock):
528
+ data = get_stock_data(selected_stock, '5d')
529
+ if data.empty: return html.Div("無法獲取股票資料")
530
+ current_price = data['Close'].iloc[-1]
531
+ prev_price = data['Close'].iloc[-2] if len(data) > 1 else current_price
532
+ change = current_price - prev_price
533
+ change_pct = (change / prev_price) * 100
534
+ stock_name = [name for name, symbol in TAIWAN_STOCKS.items() if symbol == selected_stock][0]
535
+ color, arrow = ('red', '▲') if change >= 0 else ('green', '▼')
536
+ return html.Div([
537
+ html.Div([
538
+ html.H3(f"{stock_name} ({selected_stock})", style={'margin': '0'}),
539
+ html.H2(f"${current_price:.2f}", style={'margin': '5px 0', 'color': color}),
540
+ html.P(f"{arrow} {change:+.2f} ({change_pct:+.2f}%)", style={'margin': '0', 'color': color, 'font-weight': 'bold'})
541
+ ], style={'background': 'white','padding': '20px','border-radius': '10px','box-shadow': '0 2px 10px rgba(0,0,0,0.1)','display': 'inline-block','margin-right': '20px'}),
542
+ html.Div([
543
+ html.H4("今日統計", style={'margin': '0 0 10px 0'}),
544
+ html.P(f"最高: ${data['High'].iloc[-1]:.2f}", style={'margin': '5px 0'}),
545
+ html.P(f"最低: ${data['Low'].iloc[-1]:.2f}", style={'margin': '5px 0'}),
546
+ html.P(f"成交量: {data['Volume'].iloc[-1]:,.0f}", style={'margin': '5px 0'})
547
+ ], style={'background': 'white','padding': '20px','border-radius': '10px','box-shadow': '0 2px 10px rgba(0,0,0,0.1)','display': 'inline-block'})
548
+ ])
549
+
550
+ @app.callback(
551
+ dash.dependencies.Output('price-chart', 'figure'),
552
+ [dash.dependencies.Input('stock-dropdown', 'value'),
553
+ dash.dependencies.Input('period-dropdown', 'value'),
554
+ dash.dependencies.Input('chart-type', 'value')]
555
+ )
556
+ def update_price_chart(selected_stock, period, chart_type):
557
+ data = get_stock_data(selected_stock, period)
558
+ if data.empty: return {}
559
+ data = calculate_technical_indicators(data)
560
+ stock_name = [name for name, symbol in TAIWAN_STOCKS.items() if symbol == selected_stock][0]
561
+ fig = make_subplots(rows=1, cols=2, shared_yaxes=True, column_widths=[0.8, 0.2], horizontal_spacing=0.01)
562
+ if chart_type == 'candlestick':
563
+ fig.add_trace(go.Candlestick(x=data.index, open=data['Open'], high=data['High'], low=data['Low'], close=data['Close'], name=stock_name, increasing_line_color='red', decreasing_line_color='green'), row=1, col=1)
564
+ else:
565
+ fig.add_trace(px.line(data, y='Close').data[0], row=1, col=1)
566
+ fig.add_trace(go.Scatter(x=data.index, y=data['MA5'], mode='lines', name='MA5', line=dict(color='orange')), row=1, col=1)
567
+ fig.add_trace(go.Scatter(x=data.index, y=data['MA20'], mode='lines', name='MA20', line=dict(color='blue')), row=1, col=1)
568
+ bin_edges, volume_per_bin, price_centers = calculate_volume_profile(data, num_bins=50)
569
+ if volume_per_bin is not None:
570
+ fig.add_trace(go.Bar(orientation='h', y=price_centers, x=volume_per_bin, name='Volume Profile', text=[f'{vol/1000:.0f}k' for vol in volume_per_bin], textposition='auto', marker=dict(color='rgba(173, 216, 230, 0.6)', line=dict(color='rgba(30, 144, 255, 0.8)', width=1))), row=1, col=2)
571
+ fig.update_layout(title_text=f'{stock_name} 股價走勢與成交量分佈', height=500, showlegend=True, xaxis1=dict(title='日期', type='date', rangeslider_visible=False), yaxis1=dict(title='價格 (TWD)'), xaxis2=dict(title='成交量', showticklabels=True), yaxis2=dict(showticklabels=False), bargap=0.05)
572
+ return fig
573
+
574
+ @app.callback(
575
+ dash.dependencies.Output('advanced-technical-chart', 'figure'),
576
+ [dash.dependencies.Input('technical-indicator-selector', 'value'),
577
+ dash.dependencies.Input('stock-dropdown', 'value'),
578
+ dash.dependencies.Input('period-dropdown', 'value')]
579
+ )
580
+ def update_advanced_technical_chart(indicator, selected_stock, period):
581
+ data = get_stock_data(selected_stock, period)
582
+ if data.empty: return {}
583
+ data = calculate_technical_indicators(data)
584
+ stock_name = [name for name, symbol in TAIWAN_STOCKS.items() if symbol == selected_stock][0]
585
+ fig = go.Figure()
586
+ if indicator == 'RSI':
587
+ fig = go.Figure()
588
+ fig.add_trace(go.Scatter(x=data.index, y=data['RSI'], mode='lines', name='RSI', line=dict(color='purple', width=2)))
589
+ fig.add_hline(y=70, line_dash="dash", line_color="green", annotation_text="超買線(70)")
590
+ fig.add_hline(y=30, line_dash="dash", line_color="red", annotation_text="超賣線(30)")
591
+ fig.add_hline(y=50, line_dash="dot", line_color="gray", annotation_text="中線(50)")
592
+ fig.update_layout(title=f'{stock_name} - RSI 相對強弱指標', xaxis_title='日期', yaxis_title='RSI', height=450, yaxis=dict(range=[0, 100]))
593
+ elif indicator == 'MACD':
594
+ fig = make_subplots(rows=2, cols=1, shared_xaxes=True, vertical_spacing=0.1, row_heights=[0.7, 0.3], subplot_titles=('價格走勢', 'MACD 指標'))
595
+ fig.add_trace(go.Scatter(x=data.index, y=data['Close'], mode='lines', name='收盤價', line=dict(color='black', width=1.5)), row=1, col=1)
596
+ fig.add_trace(go.Scatter(x=data.index, y=data['MACD'], mode='lines', name='MACD (快線)', line=dict(color='blue', width=2)), row=2, col=1)
597
+ fig.add_trace(go.Scatter(x=data.index, y=data['MACD_Signal'], mode='lines', name='Signal (慢線)', line=dict(color='red', width=2)), row=2, col=1)
598
+ colors = ['red' if x >= 0 else 'green' for x in data['MACD_Histogram']]
599
+ fig.add_trace(go.Bar(x=data.index, y=data['MACD_Histogram'], name='MACD柱狀圖', marker_color=colors), row=2, col=1)
600
+ fig.update_layout(title_text=f'{stock_name} - MACD 指數平滑異同移動平均線', height=550)
601
+ elif indicator == 'BB':
602
+ fig = go.Figure()
603
+ fig.add_trace(go.Scatter(x=data.index, y=data['Close'], mode='lines', name='收盤價', line=dict(color='black', width=2)))
604
+ fig.add_trace(go.Scatter(x=data.index, y=data['BB_Upper'], mode='lines', name='上軌', line=dict(color='red', width=1, dash='dash')))
605
+ fig.add_trace(go.Scatter(x=data.index, y=data['BB_Middle'], mode='lines', name='中軌(MA20)', line=dict(color='blue', width=1)))
606
+ fig.add_trace(go.Scatter(x=data.index, y=data['BB_Lower'], mode='lines', name='下軌', line=dict(color='green', width=1, dash='dash')))
607
+ fig.update_layout(title=f'{stock_name} - 布林通道 (20日, 2σ)', xaxis_title='日期', yaxis_title='價格 (TWD)', height=450)
608
+ elif indicator == 'KD':
609
+ fig = make_subplots(rows=2, cols=1, shared_xaxes=True, vertical_spacing=0.1, row_heights=[0.6, 0.4], subplot_titles=('價格走勢', 'KD指標'))
610
+ fig.add_trace(go.Scatter(x=data.index, y=data['Close'], mode='lines', name='收盤價', line=dict(color='black', width=1)), row=1, col=1)
611
+ fig.add_trace(go.Scatter(x=data.index, y=data['K'], mode='lines', name='K線', line=dict(color='blue', width=2)), row=2, col=1)
612
+ fig.add_trace(go.Scatter(x=data.index, y=data['D'], mode='lines', name='D線', line=dict(color='red', width=2)), row=2, col=1)
613
+ fig.add_hline(y=80, line_dash="dash", line_color="green", annotation_text="超買線(80)", row=2, col=1)
614
+ fig.add_hline(y=20, line_dash="dash", line_color="red", annotation_text="超賣線(20)", row=2, col=1)
615
+ fig.update_layout(title=f'{stock_name} - KD 隨機指標 (9,3,3)', height=500, yaxis2_range=[0, 100])
616
+ elif indicator == 'WR':
617
+ fig = make_subplots(rows=2, cols=1, shared_xaxes=True, vertical_spacing=0.1, row_heights=[0.6, 0.4], subplot_titles=('價格走勢', '威廉指標 %R'))
618
+ fig.add_trace(go.Scatter(x=data.index, y=data['Close'], mode='lines', name='收盤價', line=dict(color='black', width=1)), row=1, col=1)
619
+ fig.add_trace(go.Scatter(x=data.index, y=data['Williams_R'], mode='lines', name='威廉%R', line=dict(color='purple', width=2)), row=2, col=1)
620
+ fig.add_hline(y=-20, line_dash="dash", line_color="green", annotation_text="超買線(-20)", row=2, col=1)
621
+ fig.add_hline(y=-80, line_dash="dash", line_color="red", annotation_text="超賣線(-80)", row=2, col=1)
622
+ fig.update_layout(title=f'{stock_name} - 威廉指標 %R (14日)', height=500, yaxis2_range=[-100, 0])
623
+ elif indicator == 'DMI':
624
+ fig = make_subplots(rows=2, cols=1, shared_xaxes=True, vertical_spacing=0.1, row_heights=[0.6, 0.4], subplot_titles=('價格走勢', 'DMI 指標'))
625
+ data_filtered = data.iloc[14:]
626
+ fig.add_trace(go.Scatter(x=data_filtered.index, y=data_filtered['Close'], mode='lines', name='收盤價', line=dict(color='black', width=1)), row=1, col=1)
627
+ fig.add_trace(go.Scatter(x=data_filtered.index, y=data_filtered['+DI'], mode='lines', name='+DI', line=dict(color='red', width=2)), row=2, col=1)
628
+ fig.add_trace(go.Scatter(x=data_filtered.index, y=data_filtered['-DI'], mode='lines', name='-DI', line=dict(color='green', width=2)), row=2, col=1)
629
+ fig.add_trace(go.Scatter(x=data_filtered.index, y=data_filtered['ADX'], mode='lines', name='ADX', line=dict(color='blue', width=2, dash='dot')), row=2, col=1)
630
+ fig.update_layout(title=f'{stock_name} - DMI 動向指標 (14日)', height=500, showlegend=True, yaxis2_range=[0, 100])
631
+ return fig
632
+
633
+ @app.callback(
634
+ dash.dependencies.Output('volume-chart', 'figure'),
635
+ [dash.dependencies.Input('stock-dropdown', 'value'),
636
+ dash.dependencies.Input('period-dropdown', 'value')]
637
+ )
638
+ def update_volume_chart(selected_stock, period):
639
+ data = get_stock_data(selected_stock, period)
640
+ if data.empty: return {}
641
+ stock_name = [name for name, symbol in TAIWAN_STOCKS.items() if symbol == selected_stock][0]
642
+ colors = ['red' if data['Close'].iloc[i] > data['Open'].iloc[i] else 'green' for i in range(len(data))]
643
+ fig = go.Figure(go.Bar(x=data.index, y=data['Volume'], marker_color=colors, name='成交量'))
644
+ fig.update_layout(title=f'{stock_name} 成交量', xaxis_title='日期', yaxis_title='成交量', height=300)
645
+ return fig
646
+
647
+ @app.callback(
648
+ dash.dependencies.Output('industry-analysis', 'figure'),
649
+ [dash.dependencies.Input('stock-dropdown', 'value')]
650
+ )
651
+ def update_industry_analysis(selected_stock):
652
+ performance_data = []
653
+ for name, symbol in TAIWAN_STOCKS.items():
654
+ data = get_stock_data(symbol, '1mo')
655
+ if not data.empty and len(data) > 1:
656
+ return_pct = ((data['Close'].iloc[-1] - data['Close'].iloc[0]) / data['Close'].iloc[0]) * 100
657
+ performance_data.append({
658
+ '股票': name,
659
+ '代碼': symbol,
660
+ '月報酬率(%)': return_pct,
661
+ '絕對波動': abs(return_pct)
662
+ })
663
+ if not performance_data:
664
+ fig = go.Figure().add_annotation(text="無法計算產業資料", showarrow=False)
665
+ fig.update_layout(title="近一月市場波動最大標的", height=400)
666
+ return fig
667
+ df_performance = pd.DataFrame(performance_data)
668
+ df_top_movers = df_performance.sort_values(by='絕對波動', ascending=False).head(10)
669
+ fig = px.pie(
670
+ df_top_movers,
671
+ values='絕對波動',
672
+ names='股票',
673
+ title='近一月市場波動最大 Top 10 標的',
674
+ hover_data={'月報酬率(%)': ':.2f'}
675
+ )
676
+ fig.update_traces(
677
+ textposition='inside',
678
+ textinfo='percent+label',
679
+ hovertemplate="<b>%{label}</b><br>月報酬率: %{customdata[0]:.2f}%<extra></extra>"
680
+ )
681
+ fig.update_layout(height=400, showlegend=False)
682
+ return fig
683
+
684
+ @app.callback(
685
+ dash.dependencies.Output('business-climate-chart', 'figure'),
686
+ [dash.dependencies.Input('stock-dropdown', 'value')]
687
+ )
688
+ def update_business_climate_chart(selected_stock):
689
+ df = get_business_climate_data()
690
+ if df.empty:
691
+ fig = go.Figure().add_annotation(text="無法載入景氣燈號資料", showarrow=False)
692
+ fig.update_layout(title="台灣景氣燈號", height=300)
693
+ return fig
694
+ def get_light_color(score):
695
+ if score >= 32: return 'red'
696
+ elif score >= 24: return 'orange'
697
+ elif score >= 17: return 'yellow'
698
+ elif score >= 10: return 'lightgreen'
699
+ else: return 'blue'
700
+ colors = [get_light_color(score) for score in df['Index']]
701
+ fig = go.Figure()
702
+ fig.add_trace(go.Scatter(x=df['Date'], y=df['Index'], mode='lines+markers', name='景氣燈號', line=dict(color='darkblue', width=2), marker=dict(size=8, color=colors, line=dict(width=2, color='darkblue'))))
703
+ fig.add_hline(y=32, line_dash="dash", line_color="red", annotation_text="紅燈(32)")
704
+ fig.add_hline(y=17, line_dash="dash", line_color="yellow", annotation_text="黃燈(17)")
705
+ fig.update_layout(title="台灣景氣燈號走勢", xaxis_title='日期', yaxis_title='燈號分數', height=300, yaxis=dict(range=[0, 40]))
706
+ return fig
707
+
708
+ # ========================= MODIFIED SECTION START (CACHE INTEGRATED) =========================
709
+ @app.callback(
710
+ [dash.dependencies.Output('technical-analysis-text', 'children'),
711
+ dash.dependencies.Output('fundamental-analysis-text', 'children'),
712
+ dash.dependencies.Output('market-outlook-text', 'children')],
713
+ [dash.dependencies.Input('stock-dropdown', 'value'),
714
+ dash.dependencies.Input('period-dropdown', 'value')]
715
+ )
716
+ def update_analysis_text(selected_stock, period):
717
+ # 建立快取的唯一鍵值
718
+ cache_key = f"{selected_stock}-{period}"
719
+ current_time = time.time()
720
+
721
+ # 1. 檢查快取
722
+ if cache_key in ANALYSIS_CACHE:
723
+ cached_data = ANALYSIS_CACHE[cache_key]
724
+ if current_time - cached_data['timestamp'] < CACHE_DURATION_SECONDS:
725
+ print(f"從快取載入分析: {cache_key}")
726
+ # 直接回傳快取的內容
727
+ return cached_data['technical'], cached_data['fundamental'], cached_data['outlook']
728
+
729
+ print(f"重新生成分析: {cache_key}")
730
+ # --- 如果快取沒有,才繼續執行以下程式 ---
731
+
732
+ data = get_stock_data(selected_stock, period)
733
+ stock_name = [name for name, symbol in TAIWAN_STOCKS.items() if symbol == selected_stock][0]
734
+ if data.empty or len(data) < 20:
735
+ return "資料不足,無法分析", "資料不足,無法分析", "資料不足,無法分析"
736
+
737
+ data = calculate_technical_indicators(data)
738
+
739
+ # 2. 技術面分析
740
+ price_change = ((data['Close'].iloc[-1] - data['Close'].iloc[0]) / data['Close'].iloc[0]) * 100
741
+ rsi_current = data['RSI'].iloc[-1] if not pd.isna(data['RSI'].iloc[-1]) else 50
742
+ macd_current = data['MACD'].iloc[-1] if not pd.isna(data['MACD'].iloc[-1]) else 0
743
+ macd_signal_current = data['MACD_Signal'].iloc[-1] if not pd.isna(data['MACD_Signal'].iloc[-1]) else 0
744
+
745
+ technical_text = html.Div([
746
+ html.P([html.Strong("價格趨勢:"), f"在最近 {period} 期間內,{stock_name} 股價呈現", html.Span(f"{'上漲' if price_change > 5 else '下跌' if price_change < -5 else '盤整'}", style={'color': 'red' if price_change > 5 else 'green' if price_change < -5 else 'orange', 'font-weight': 'bold'}), f"走勢,累計變動 {price_change:+.1f}%。"]),
747
+ html.P([html.Strong("RSI 指標:"), f"目前的 RSI 值為 {rsi_current:.1f},", html.Span("處於超買區(>70)" if rsi_current > 70 else "處於超賣區(<30)" if rsi_current < 30 else "在正常範圍內", style={'color': 'green' if rsi_current > 70 else 'red' if rsi_current < 30 else 'blue', 'font-weight': 'bold'}), "。"]),
748
+ html.P([html.Strong("MACD 指標:"), f"MACD 快線 ({macd_current:.3f}) 目前", html.Span("高於" if macd_current > macd_signal_current else "低於", style={'color': 'red' if macd_current > macd_signal_current else 'green', 'font-weight': 'bold'}), f" Signal 慢線 ({macd_signal_current:.3f}),", f"顯示市場動能偏向{'多頭' if macd_current > macd_signal_current else '空頭'}。"]),
749
+ ])
750
+
751
+ # 3. 基本面與展望分析 (呼叫 Gemini)
752
+ fundamental_text, market_outlook_text = generate_gemini_analysis(stock_name, selected_stock, period, data)
753
+
754
+ # 4. 將新產生的結果存入快取
755
+ ANALYSIS_CACHE[cache_key] = {
756
+ 'technical': technical_text,
757
+ 'fundamental': fundamental_text,
758
+ 'outlook': market_outlook_text,
759
+ 'timestamp': current_time
760
+ }
761
+
762
+ return technical_text, fundamental_text, market_outlook_text
763
+ # ========================== MODIFIED SECTION END ==========================
764
+
765
+ @app.callback(
766
+ dash.dependencies.Output('pmi-chart', 'figure'),
767
+ [dash.dependencies.Input('stock-dropdown', 'value')]
768
+ )
769
+ def update_pmi_chart(selected_stock):
770
+ df = get_pmi_data()
771
+ if df.empty:
772
+ fig = go.Figure().add_annotation(text="無法載入PMI資料", showarrow=False)
773
+ fig.update_layout(title="台灣PMI指數", height=300)
774
+ return fig
775
+ colors = ['red' if value >= 50 else 'green' for value in df['Index']]
776
+ fig = go.Figure()
777
+ fig.add_trace(go.Scatter(x=df['Date'], y=df['Index'], mode='lines+markers', name='PMI指數', line=dict(color='darkblue', width=2), marker=dict(size=8, color=colors, line=dict(width=2, color='darkblue'))))
778
+ fig.add_hline(y=50, line_dash="dash", line_color="black", annotation_text="榮枯線(50)")
779
+ fig.update_layout(title="台灣PMI指數走勢", xaxis_title='日期', yaxis_title='PMI指數', height=300, yaxis=dict(range=[35, 60]))
780
+ return fig
781
+
782
+ def summarize_news_with_gemini(news_list: list) -> str:
783
+ """
784
+ 使用 Gemini API 將英文新聞標題列表摘要成一段繁體中文。
785
+ """
786
+ api_key = os.getenv("GEMINI_API_KEY")
787
+ if not api_key:
788
+ return "錯誤:找不到 GEMINI_API_KEY。請在 Hugging Face Secrets 中設定。"
789
+
790
+ try:
791
+ genai.configure(api_key=api_key)
792
+ model = genai.GenerativeModel('gemini-1.5-flash')
793
+
794
+ formatted_news = "\n".join([f"- {news}" for news in news_list])
795
+
796
+ prompt = f"""
797
+ 請扮演一位專業的金融市場分析師。
798
+ 以下是幾則最新的英文財經新聞標題,請將它們整合成一段簡潔、流暢、約 200 字的繁體中文市場動態摘要,與利多哪些產業,利空哪些產業。
799
+ 提供3段重點,
800
+ 請專注於可能影響市場情緒和股價的關鍵資訊,並直接提供摘要內容,不要包含任何額外的問候語或說明。
801
+
802
+ 英文新聞標題如下:
803
+ {formatted_news}
804
+ """
805
+
806
+ response = model.generate_content(prompt)
807
+ return response.text
808
+
809
+ except Exception as e:
810
+ print(f"呼叫 Gemini API 時發生錯誤: {e}")
811
+ return f"無法生成新聞摘要,請稍後再試。錯誤訊息:{e}"
812
+
813
+ @app.callback(
814
+ [dash.dependencies.Output('comparison-chart', 'figure'),
815
+ dash.dependencies.Output('comparison-table', 'children')],
816
+ [dash.dependencies.Input('comparison-stocks', 'value'),
817
+ dash.dependencies.Input('comparison-period', 'value')]
818
+ )
819
+ def update_comparison_analysis(selected_stocks, period):
820
+ fixed_stock = '0050.TW'
821
+ if not selected_stocks: selected_stocks = [fixed_stock]
822
+ elif fixed_stock not in selected_stocks: selected_stocks.insert(0, fixed_stock)
823
+ selected_stocks = selected_stocks[:5]
824
+ fig = go.Figure()
825
+ comparison_data = []
826
+ for stock in selected_stocks:
827
+ data = get_stock_data(stock, period)
828
+ if not data.empty:
829
+ stock_name = next((name for name, symbol in TAIWAN_STOCKS.items() if symbol == stock), stock)
830
+ normalized_prices = (data['Close'] / data['Close'].iloc[0]) * 100
831
+ fig.add_trace(go.Scatter(x=data.index, y=normalized_prices, mode='lines', name=stock_name, line=dict(width=2)))
832
+ total_return = ((data['Close'].iloc[-1] / data['Close'].iloc[0]) - 1) * 100
833
+ volatility = data['Close'].pct_change().std() * np.sqrt(252) * 100
834
+ comparison_data.append({'name': stock_name, 'return': total_return, 'volatility': volatility, 'current_price': data['Close'].iloc[-1]})
835
+ fig.update_layout(title=f'股票績效比較 - {period}', xaxis_title='日期', yaxis_title='相對績效 (基期=100)', height=400, hovermode='x unified')
836
+ if comparison_data:
837
+ table_rows = []
838
+ for item in sorted(comparison_data, key=lambda x: x['return'], reverse=True):
839
+ color = 'red' if item['return'] > 0 else 'green'
840
+ table_rows.append(html.Tr([html.Td(item['name'], style={'font-weight': 'bold'}), html.Td(f"{item['return']:+.1f}%", style={'color': color, 'font-weight': 'bold'}), html.Td(f"{item['volatility']:.1f}%"), html.Td(f"${item['current_price']:.2f}")]))
841
+ table = html.Table([html.Thead(html.Tr([html.Th("股票"), html.Th("報酬率"), html.Th("波動率"), html.Th("現價")])), html.Tbody(table_rows)], style={'width': '100%'})
842
+ return fig, table
843
+ return fig, html.Div("無可比較資料")
844
+
845
+ @app.callback(
846
+ [dash.dependencies.Output('sentiment-gauge', 'children'),
847
+ dash.dependencies.Output('news-summary', 'children')],
848
+ [dash.dependencies.Input('stock-dropdown', 'value')]
849
+ )
850
+ def update_sentiment_analysis(selected_stock):
851
+ if predictor is None:
852
+ error_fig = go.Figure().add_annotation(text="情緒指標模型載入失敗", showarrow=False)
853
+ error_fig.update_layout(height=200)
854
+ return dcc.Graph(figure=error_fig), html.P("新聞分析模型載入失敗,請檢查後台日誌。")
855
+
856
+ sentiment_score_raw = predictor.get_news_index()
857
+
858
+ if sentiment_score_raw is not None:
859
+ sentiment_score_normalized = (sentiment_score_raw + 1) * 50
860
+ sentiment_score_normalized = max(0, min(100, sentiment_score_normalized))
861
+ if sentiment_score_normalized >= 65:
862
+ bar_color, level_text = "#5cb85c", "樂觀"
863
+ elif sentiment_score_normalized >= 35:
864
+ bar_color, level_text = "#f0ad4e", "中性"
865
+ else:
866
+ bar_color, level_text = "#d9534f", "悲觀"
867
+ gauge_fig = go.Figure(go.Indicator(
868
+ mode = "gauge+number", value = sentiment_score_normalized,
869
+ domain = {'x': [0, 1], 'y': [0, 1]},
870
+ title = {'text': f"昨日市場情緒: {level_text}", 'font': {'size': 18}},
871
+ gauge = {'axis': {'range': [0, 100]}, 'bar': {'color': bar_color},
872
+ 'steps': [{'range': [0, 35], 'color': "rgba(217, 83, 79, 0.2)"},
873
+ {'range': [35, 65], 'color': "rgba(240, 173, 78, 0.2)"},
874
+ {'range': [65, 100], 'color': "rgba(92, 184, 92, 0.2)"}]}
875
+ ))
876
+ gauge_fig.update_layout(height=200, margin=dict(l=30, r=30, t=50, b=20))
877
+ gauge_content = dcc.Graph(figure=gauge_fig)
878
+ else:
879
+ error_fig = go.Figure().add_annotation(text="今日尚無情緒分數", showarrow=False)
880
+ error_fig.update_layout(height=200)
881
+ gauge_content = dcc.Graph(figure=error_fig)
882
+
883
+ top_news_list = predictor.get_news()
884
+ news_content = None
885
+
886
+ if top_news_list and isinstance(top_news_list, list):
887
+ summary_text = summarize_news_with_gemini(top_news_list)
888
+ news_content = dcc.Markdown(summary_text, style={
889
+ 'margin': '8px 0', 'padding-left': '5px',
890
+ 'font-size': '15px', 'line-height': '1.7'
891
+ })
892
+ elif top_news_list == []:
893
+ news_content = html.P("昨日無重大相關新聞。", style={'text-align': 'center', 'padding-top': '50px'})
894
+ else:
895
+ news_content = html.P("讀取新聞時發生錯誤。", style={'text-align': 'center', 'padding-top': '50px'})
896
+
897
+ return gauge_content, news_content
898
+
899
+ # 主程式執行
900
+ if __name__ == '__main__':
901
+ app.run(host="0.0.0.0", port=7860, debug=False)