Batman67 commited on
Commit
91d196a
·
verified ·
1 Parent(s): 8b6f26c

Upload pointblank.py

Browse files
Files changed (1) hide show
  1. pointblank.py +265 -0
pointblank.py ADDED
@@ -0,0 +1,265 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import warnings
2
+ warnings.filterwarnings("ignore")
3
+
4
+ import yfinance as yf
5
+ import pandas as pd
6
+ import numpy as np
7
+ import plotly.graph_objects as go
8
+ from plotly.subplots import make_subplots
9
+ from datetime import timedelta, datetime
10
+ import feedparser
11
+ import urllib.parse
12
+ import html
13
+ import re
14
+ import time
15
+ import gradio as gr
16
+
17
+ # --------------------------
18
+ # ML libraries
19
+ # --------------------------
20
+ HAS_PROPHET = False
21
+ HAS_ARIMA = False
22
+ HAS_SKLEARN = False
23
+ HAS_TF = False
24
+
25
+ try:
26
+ from prophet import Prophet
27
+ HAS_PROPHET = True
28
+ except: Prophet = None
29
+
30
+ try:
31
+ from statsmodels.tsa.arima.model import ARIMA
32
+ HAS_ARIMA = True
33
+ except: ARIMA = None
34
+
35
+ try:
36
+ from sklearn.ensemble import RandomForestRegressor
37
+ from sklearn.preprocessing import MinMaxScaler
38
+ HAS_SKLEARN = True
39
+ except: RandomForestRegressor = None; MinMaxScaler=None
40
+
41
+ try:
42
+ import tensorflow as tf
43
+ from tensorflow import keras
44
+ from tensorflow.keras import layers
45
+ HAS_TF = True
46
+ except: tf=None; keras=None; layers=None
47
+
48
+ # --------------------------
49
+ # Data Utilities
50
+ # --------------------------
51
+
52
+ def fetch_yahoo_data(ticker: str, period="6mo", interval="1d") -> pd.DataFrame:
53
+ try:
54
+ t = yf.Ticker(ticker)
55
+ df = t.history(period=period, interval=interval)
56
+ if df is None or df.empty:
57
+ return pd.DataFrame()
58
+ df = df.reset_index()
59
+ df['Date'] = pd.to_datetime(df['Date']).dt.tz_localize(None)
60
+ for col in ['Open','High','Low','Close','Volume']:
61
+ if col in df.columns:
62
+ df[col] = pd.to_numeric(df[col], errors='coerce')
63
+ df = df.dropna(subset=['Date','Close']).reset_index(drop=True)
64
+ return df
65
+ except:
66
+ return pd.DataFrame()
67
+
68
+ def compute_indicators(df: pd.DataFrame) -> pd.DataFrame:
69
+ df = df.copy().reset_index(drop=True)
70
+ df['MA20'] = df['Close'].rolling(20).mean()
71
+ df['MA50'] = df['Close'].rolling(50).mean()
72
+ df['EMA12'] = df['Close'].ewm(span=12, adjust=False).mean()
73
+ df['EMA26'] = df['Close'].ewm(span=26, adjust=False).mean()
74
+ df['MACD'] = df['EMA12'] - df['EMA26']
75
+ df['Signal'] = df['MACD'].ewm(span=9, adjust=False).mean()
76
+ df['BB_MID'] = df['Close'].rolling(20).mean()
77
+ df['BB_STD'] = df['Close'].rolling(20).std(ddof=0).fillna(0)
78
+ df['BB_UP'] = df['BB_MID'] + 2*df['BB_STD']
79
+ df['BB_LOW'] = df['BB_MID'] - 2*df['BB_STD']
80
+ delta = df['Close'].diff()
81
+ up = delta.clip(lower=0)
82
+ down = -delta.clip(upper=0)
83
+ roll_up = up.rolling(14).mean()
84
+ roll_down = down.rolling(14).mean()
85
+ rs = roll_up / (roll_down + 1e-8)
86
+ df['RSI'] = 100 - (100 / (1 + rs))
87
+ df['RSI'] = df['RSI'].clip(0,100).fillna(50)
88
+ return df
89
+
90
+ # --------------------------
91
+ # Plotting
92
+ # --------------------------
93
+
94
+ def plot_advanced(df: pd.DataFrame, show_indicators: bool=True) -> go.Figure:
95
+ fig = make_subplots(rows=3, cols=1, shared_xaxes=True, row_heights=[0.6,0.18,0.22], vertical_spacing=0.03)
96
+ fig.add_trace(go.Candlestick(x=df['Date'], open=df['Open'], high=df['High'], low=df['Low'], close=df['Close'], name='Price'), row=1, col=1)
97
+ if show_indicators:
98
+ fig.add_trace(go.Scatter(x=df['Date'], y=df['MA20'], name='MA20', line=dict(width=1.4)), row=1, col=1)
99
+ fig.add_trace(go.Scatter(x=df['Date'], y=df['MA50'], name='MA50', line=dict(width=1.4, dash='dash')), row=1, col=1)
100
+ fig.add_trace(go.Scatter(x=df['Date'], y=df['BB_UP'], name='BB_UP', line=dict(width=1, dash='dot')), row=1, col=1)
101
+ fig.add_trace(go.Scatter(x=df['Date'], y=df['BB_LOW'], name='BB_LOW', line=dict(width=1, dash='dot')), row=1, col=1)
102
+ fig.add_trace(go.Bar(x=df['Date'], y=df['Volume'], name='Volume', marker_color='gray', opacity=0.3), row=2, col=1)
103
+ fig.add_trace(go.Scatter(x=df['Date'], y=df['RSI'], name='RSI', line=dict(width=1.2)), row=3, col=1)
104
+ fig.add_hline(y=70, line_dash='dot', row=3, col=1)
105
+ fig.add_hline(y=30, line_dash='dot', row=3, col=1)
106
+ fig.update_layout(template='plotly_dark', height=600, paper_bgcolor='#000000', plot_bgcolor='#000000')
107
+ return fig
108
+
109
+ # --------------------------
110
+ # Forecasting
111
+ # --------------------------
112
+
113
+ def forecast_all(df: pd.DataFrame, periods: int = 30):
114
+ forecasts = {}
115
+ # Prophet
116
+ if HAS_PROPHET:
117
+ try:
118
+ prophet_df = df[['Date','Close']].rename(columns={'Date':'ds','Close':'y'}).copy()
119
+ m = Prophet(daily_seasonality=True, yearly_seasonality=True, weekly_seasonality=True)
120
+ m.fit(prophet_df)
121
+ future = m.make_future_dataframe(periods=periods, freq='D')
122
+ fc = m.predict(future)[['ds','yhat']].rename(columns={'ds':'Date'})
123
+ forecasts['Prophet'] = fc
124
+ except: pass
125
+ # ARIMA
126
+ if HAS_ARIMA:
127
+ try:
128
+ series = df.set_index('Date')['Close'].sort_index()
129
+ series.index = pd.to_datetime(series.index)
130
+ series = series.asfreq('D').ffill()
131
+ model = ARIMA(series, order=(5,1,0)).fit()
132
+ fc = model.forecast(steps=periods)
133
+ dates = pd.date_range(start=series.index[-1]+timedelta(days=1), periods=periods)
134
+ forecasts['ARIMA'] = pd.DataFrame({'Date':dates,'yhat':fc.values})
135
+ except: pass
136
+ # Random Forest
137
+ if HAS_SKLEARN:
138
+ try:
139
+ data = df[['Close']].copy()
140
+ n_lags = 5
141
+ for lag in range(1,n_lags+1): data[f'lag_{lag}'] = data['Close'].shift(lag)
142
+ data = data.dropna()
143
+ X = data[[f'lag_{i}' for i in range(1,n_lags+1)]].values
144
+ y = data['Close'].values
145
+ model = RandomForestRegressor(n_estimators=200, random_state=42)
146
+ model.fit(X,y)
147
+ last_window = X[-1].tolist()
148
+ preds=[]
149
+ for _ in range(periods): p=float(model.predict([last_window])); preds.append(p); last_window=[p]+last_window[:-1]
150
+ dates=pd.date_range(start=df['Date'].iloc[-1]+timedelta(days=1), periods=periods)
151
+ forecasts['RandomForest'] = pd.DataFrame({'Date':dates,'yhat':preds})
152
+ except: pass
153
+ # LSTM
154
+ if HAS_TF and HAS_SKLEARN:
155
+ try:
156
+ values=df['Close'].values.astype('float32')
157
+ n_lags=20
158
+ scaler=MinMaxScaler()
159
+ scaled=scaler.fit_transform(values.reshape(-1,1)).flatten()
160
+ X=[];y=[]
161
+ for i in range(n_lags,len(scaled)): X.append(scaled[i-n_lags:i]); y.append(scaled[i])
162
+ X=np.array(X).reshape(-1,n_lags,1);y=np.array(y)
163
+ tf.keras.backend.clear_session()
164
+ model=keras.Sequential([layers.Input(shape=(n_lags,1)),layers.LSTM(64),layers.Dense(32,activation='relu'),layers.Dense(1)])
165
+ model.compile(optimizer='adam',loss='mse');model.fit(X,y,epochs=10,batch_size=16,verbose=0)
166
+ last_window=list(scaled[-n_lags:]);preds_scaled=[]
167
+ for _ in range(periods): x=np.array(last_window).reshape(1,n_lags,1);p=float(model.predict(x,verbose=0)[0,0]);preds_scaled.append(p);last_window=last_window[1:]+[p]
168
+ preds = scaler.inverse_transform(np.array(preds_scaled).reshape(-1,1)).flatten().tolist()
169
+ dates=pd.date_range(start=df['Date'].iloc[-1]+timedelta(days=1), periods=periods)
170
+ forecasts['LSTM']=pd.DataFrame({'Date':dates,'yhat':preds})
171
+ except: pass
172
+ return forecasts
173
+
174
+ # --------------------------
175
+ # News
176
+ # --------------------------
177
+
178
+ def get_company_name(ticker:str) -> str:
179
+ try: return yf.Ticker(ticker).info.get('shortName','')
180
+ except: return ''
181
+
182
+ def _format_time(entry) -> str:
183
+ try:
184
+ if entry.get('published_parsed'):
185
+ ts = time.mktime(entry.published_parsed)
186
+ return datetime.fromtimestamp(ts).strftime("%a, %d %b %Y %H:%M:%S")
187
+ if entry.get('published'): return str(entry.get('published'))
188
+ except: pass
189
+ return 'Unknown'
190
+
191
+ def _extract_image(entry) -> str|None:
192
+ mc=entry.get('media_content') or entry.get('mediaContents')
193
+ if mc and isinstance(mc,(list,tuple)) and mc: return mc[0].get('url')
194
+ mt=entry.get('media_thumbnail')
195
+ if mt and isinstance(mt,(list,tuple)) and mt: return mt[0].get('url')
196
+ summary = entry.get('summary','') or entry.get('description','')
197
+ m=re.search(r'<img[^>]+src=["\']([^"\']+)["\']',summary or '',re.I)
198
+ return m.group(1) if m else None
199
+
200
+ def _resolve_link(entry, feed) -> str:
201
+ for l in entry.get('links',[]):
202
+ href=l.get('href') or ''
203
+ if href and 'news.google.com' not in href: return href
204
+ return entry.get('link','')
205
+
206
+ def fetch_google_news(query:str,max_items:int=5):
207
+ if not query: return []
208
+ encoded = urllib.parse.quote_plus(query)
209
+ rss_url=f'https://news.google.com/rss/search?q={encoded}'
210
+ feed=feedparser.parse(rss_url)
211
+ items=[];seen=set()
212
+ for entry in feed.entries:
213
+ try:
214
+ title=html.unescape(entry.get('title','')).strip() or '(no title)'
215
+ published=_format_time(entry)
216
+ src = feed.feed.get('title','')
217
+ image=_extract_image(entry)
218
+ link=_resolve_link(entry, feed)
219
+ if not link or link in seen: continue
220
+ seen.add(link)
221
+ items.append({'title':title,'link':link,'source':src,'published':published,'image':image})
222
+ if len(items)>=max_items: break
223
+ except: continue
224
+ return items
225
+
226
+ # --------------------------
227
+ # Gradio function
228
+ # --------------------------
229
+
230
+ def analyze_stock(ticker, period, interval, show_indicators):
231
+ df = fetch_yahoo_data(ticker, period, interval)
232
+ if df.empty: return None, None, None, None
233
+ df = compute_indicators(df)
234
+ fig = plot_advanced(df, show_indicators)
235
+ forecasts = forecast_all(df)
236
+ news_articles = fetch_google_news(ticker)
237
+ return fig, forecasts, df.tail(20), news_articles
238
+
239
+ # --------------------------
240
+ # Gradio Interface
241
+ # --------------------------
242
+
243
+ tickers_list = ["AAPL","MSFT","GOOG","AMZN","TSLA","META","NVDA","JPM","V","JNJ","WMT",
244
+ "RELIANCE.NS","TCS.NS","INFY.NS","HDFCBANK.NS","ICICIBANK.NS","SBIN.NS",
245
+ "BTC-USD","ETH-USD"]
246
+
247
+ iface = gr.Interface(
248
+ fn=analyze_stock,
249
+ inputs=[
250
+ gr.Dropdown(tickers_list, label="Ticker"),
251
+ gr.Dropdown(["1mo","3mo","6mo","1y","2y","5y","10y","max"], value="6mo", label="History Period"),
252
+ gr.Dropdown(["1d","1wk","1mo"], value="1d", label="Interval"),
253
+ gr.Checkbox(value=True, label="Show Indicators")
254
+ ],
255
+ outputs=[
256
+ gr.Plot(label="Price & Indicators"),
257
+ gr.JSON(label="Forecasts"),
258
+ gr.Dataframe(label="Recent Historical Data"),
259
+ gr.JSON(label="News Articles")
260
+ ],
261
+ title="POINT.BLANK — Stock Analysis & News",
262
+ description="Complete Stock Analysis & News Platform with technical indicators, AI forecasts, and latest news."
263
+ )
264
+
265
+ iface.launch()