Upload app.py

app.py

@@ -0,0 +1,960 @@
+# -*- coding: utf-8 -*-
+"""
+주식 디버거 (모바일 웹앱) - 5개 분석 통합
+
+  1) VCP 돌파 감지      (past_vcp_debug.py)   * 진단 날짜 선택 입력 가능
+  2) VCP 실패 부분매도  (vcp_sell_debug.py)
+  3) 볼린저 카운트      (bollinger_count_debug.py)  * 최근 1년 자동
+  4) 240선 추세사망 컷  (MA240_cut_debug.py)
+  5) 전량매도 (RS·이격) (sell_+10_debug.py)
+
+각 분석은 데스크탑 스크립트의 로직/출력을 그대로 보존(print 출력을 캡처).
+"""
+
+import io
+import sys
+import ssl
+import contextlib
+import warnings
+from datetime import datetime, timedelta
+
+import pandas as pd
+import numpy as np
+import FinanceDataReader as fdr
+import gradio as gr
+
+ssl._create_default_https_context = ssl._create_unverified_context
+warnings.filterwarnings('ignore')
+
+
+# ============================================================
+# 1) 볼린저 카운트  (날짜만 최근 1년 자동, 나머지 동일)
+# ============================================================
+def run_bollinger(ticker):
+    buf = io.StringIO()
+    try:
+        with contextlib.redirect_stdout(buf):
+            TICKER       = ticker
+            BB_WINDOW    = 20
+            BB_STD       = 2
+            MA_240       = 240
+            MA_60        = 60
+            BB_THRESHOLD = 1.030
+
+            today      = datetime.today()
+            DEBUG_TO   = today.strftime('%Y-%m-%d')
+            DEBUG_FROM = (today - timedelta(days=365)).strftime('%Y-%m-%d')
+            DATA_START = (today - timedelta(days=1100)).strftime('%Y-%m-%d')
+
+            print(f"({TICKER}) 데이터 로드 중...")
+            df = fdr.DataReader(TICKER, DATA_START, DEBUG_TO)
+            print(f"데이터: {len(df)}일치\n")
+
+            df['ma20']     = df['Close'].rolling(BB_WINDOW).mean()
+            df['std20']    = df['Close'].rolling(BB_WINDOW).std()
+            df['bb_upper'] = df['ma20'] + BB_STD * df['std20']
+            df['bb_lower'] = df['ma20'] - BB_STD * df['std20']
+            df['ma60']     = df['Close'].rolling(MA_60).mean()
+            df['ma240']    = df['Close'].rolling(MA_240).mean()
+
+            count        = 0
+            peak_close   = 0
+            was_below_60 = False
+            counts       = []
+            peak_list    = []
+            flags        = []
+
+            for i in range(len(df)):
+                c    = df['Close'].iloc[i]
+                o    = df['Open'].iloc[i]
+                u    = df['bb_upper'].iloc[i]
+                m60  = df['ma60'].iloc[i]
+                m240 = df['ma240'].iloc[i]
+
+                if pd.isna(m240) or pd.isna(u) or pd.isna(m60):
+                    counts.append(count)
+                    peak_list.append(peak_close)
+                    flags.append('데이터부족')
+                    continue
+
+                if c < m240:
+                    count        = 0
+                    peak_close   = 0
+                    was_below_60 = False
+                    flag = '240선이탈→리셋'
+
+                elif c < m60:
+                    was_below_60 = True
+                    flag = f'60선이탈→유지(count={count})'
+
+                else:
+                    open_above_240 = (o > m240)
+                    clearly_above  = (c > u * BB_THRESHOLD)
+
+                    if not open_above_240:
+                        flag = f'시초가({o:,.0f})<240선({m240:,.0f})→무효'
+                    elif clearly_above:
+                        if was_below_60:
+                            if o > peak_close:
+                                count       += 1
+                                peak_close   = c
+                                was_below_60 = False
+                                flag = f'+{count} (60선복귀,시초가>{peak_close:,.0f})'
+                            else:
+                                flag = f'BB돌파but시초가({o:,.0f})≤피크({peak_close:,.0f})→스킵'
+                        else:
+                            count      += 1
+                            peak_close  = max(peak_close, c)
+                            flag = f'+{count}'
+                    else:
+                        pct = (c / u - 1) * 100
+                        flag = f'종가미달(BB대비{pct:+.1f}%)'
+
+                counts.append(count)
+                peak_list.append(peak_close)
+                flags.append(flag)
+
+            df['bb_count']   = counts
+            df['peak_close'] = peak_list
+            df['flag']       = flags
+
+            mask     = (df.index >= DEBUG_FROM) & (df.index <= DEBUG_TO)
+            debug_df = df[mask].copy()
+
+            print("=" * 115)
+            print(f"날짜별 카운팅 ({DEBUG_FROM} ~ {DEBUG_TO})")
+            print("=" * 115)
+            print(f"{'날짜':<12} {'종가':>7} {'시가':>7} {'BB상단':>8} {'BB×1.03':>9} "
+                  f"{'60MA':>7} {'240MA':>7} {'피크':>8} {'카운트':>6}  판정")
+            print("-" * 115)
+
+            prev_count = 0
+            for date, row in debug_df.iterrows():
+                cnt  = int(row['bb_count'])
+                flag = row['flag']
+                is_notable = (cnt != prev_count or
+                              '리셋' in flag or '이탈' in flag or
+                              '복귀' in flag or '스킵' in flag or
+                              '무효' in flag)
+                if is_notable:
+                    mark = ' ◀' if cnt > prev_count else ''
+                    print(f"{str(date)[:10]:<12} "
+                          f"{row['Close']:>7,.0f} "
+                          f"{row['Open']:>7,.0f} "
+                          f"{row['bb_upper']:>8,.0f} "
+                          f"{row['bb_upper']*BB_THRESHOLD:>9,.0f} "
+                          f"{row['ma60']:>7,.0f} "
+                          f"{row['ma240']:>7,.0f} "
+                          f"{row['peak_close']:>8,.0f} "
+                          f"{cnt:>6}  {flag}{mark}")
+                prev_count = cnt
+
+            print("\n" + "=" * 60)
+            print("카운트 증가한 날들 요약")
+            print("=" * 60)
+            prev = 0
+            for date, row in debug_df.iterrows():
+                cnt = int(row['bb_count'])
+                if cnt > prev:
+                    print(f"  {str(date)[:10]}: {row['flag']}"
+                          f"  (종가:{row['Close']:,.0f}, 시가:{row['Open']:,.0f}, "
+                          f"BB×1.03:{row['bb_upper']*BB_THRESHOLD:,.0f}, "
+                          f"240MA:{row['ma240']:,.0f})")
+                prev = cnt
+
+            print(f"\n최대 카운트: {debug_df['bb_count'].max()}")
+    except SystemExit:
+        pass
+    except Exception as e:
+        buf.write(f"\n[오류] {type(e).__name__}: {e}\n"
+                  f"티커 번호(6자리)를 확인해주세요. 예: 005930")
+    return buf.getvalue()
+
+
+# ============================================================
+# 2) 240선 추세사망 컷  (MA240_cut_debug.py 로직 그대로)
+# ============================================================
+def run_ma240(ticker):
+    buf = io.StringIO()
+
+    BREAK_PCT      = 0.05
+    CONFIRM_DAYS   = 3
+    USE_SLOPE      = False
+    SLOPE_LOOKBACK = 20
+    ARM_PCT        = 0.25
+    DATA_BACK      = 800
+    SHOW_FROM      = None
+
+    def compute_240ma_cut(df, break_pct=BREAK_PCT, confirm_days=CONFIRM_DAYS,
+                          use_slope=USE_SLOPE, slope_lookback=SLOPE_LOOKBACK,
+                          arm_pct=ARM_PCT):
+        df = df.copy()
+        df['ma240'] = df['Close'].rolling(240).mean()
+        closes = df['Close'].values.astype(float)
+        ma240  = df['ma240'].values.astype(float)
+        dates  = df.index
+
+        rows = []
+        consec    = 0
+        is_sold   = False
+        armed     = False
+        sell_info = None
+
+        for i in range(len(df)):
+            c = closes[i]
+            m = ma240[i]
+
+            rec = {
+                'date': dates[i], 'close': c, 'ma240': m,
+                'cut_line': np.nan, 'gap_pct': np.nan, 'ma_dir': '-',
+                'consec': 0, 'below_cut': False, 'armed': armed,
+                'category': 'nodata', 'verdict': '데이터부족',
+                'sold_today': False, 'is_sold': is_sold,
+            }
+
+            if np.isnan(m):
+                rows.append(rec)
+                continue
+
+            cut_line = m * (1 - break_pct)
+            gap_pct  = (c / m - 1) * 100
+
+            j = i - slope_lookback
+            if j >= 0 and not np.isnan(ma240[j]):
+                ma_dir = 'down' if m < ma240[j] else 'up'
+            else:
+                ma_dir = 'na'
+
+            just_armed = False
+            if not armed and gap_pct >= arm_pct * 100:
+                armed = True
+                just_armed = True
+
+            below_cut = c < cut_line
+            rec.update({'cut_line': cut_line, 'gap_pct': gap_pct,
+                        'ma_dir': ma_dir, 'below_cut': below_cut, 'armed': armed})
+
+            if is_sold:
+                consec = 0
+                rec['category'] = 'sold'
+                if sell_info and sell_info['price'] > 0:
+                    chg = (c / sell_info['price'] - 1) * 100
+                    rec['verdict'] = f"(이미 전량매도) 매도가 대비 {chg:+.1f}%"
+                else:
+                    rec['verdict'] = "(이미 전량매도)"
+                rec['consec']  = 0
+                rec['is_sold'] = True
+                rows.append(rec)
+                continue
+
+            if not below_cut:
+                consec = 0
+                if c >= m:
+                    rec['category'] = 'safe_above'
+                    rec['verdict']  = "240선 위 - 보유"
+                    if just_armed:
+                        rec['verdict'] += f"  ★컷 무장(240선 +{arm_pct*100:.0f}% 돌파)"
+                else:
+                    rec['category'] = 'buffer'
+                    rec['verdict']  = (f"240선 아래지만 {gap_pct:+.1f}% "
+                                       f"(컷라인 위, 살짝만 깸) - 보유")
+            else:
+                consec += 1
+                if not armed:
+                    rec['category'] = 'below_unarmed'
+                    rec['verdict'] = (f"컷라인 {gap_pct:+.1f}% 아래지만 240선 "
+                                      f"+{arm_pct*100:.0f}% 돌파 이력 없음(동산 구간) "
+                                      f"-> 컷 대상 아님 - 보유")
+                else:
+                    slope_ok = (not use_slope) or (ma_dir == 'down')
+                    rec['category'] = 'below_cut'
+                    if consec < confirm_days:
+                        rec['verdict'] = (f"컷라인 {gap_pct:+.1f}% 아래 - "
+                                          f"{consec}/{confirm_days}일째 (확정 전) - 보유")
+                    elif not slope_ok:
+                        rec['verdict'] = (f"컷라인 아래 {consec}일째 BUT 240MA 아직 상승중 "
+                                          f"-> 기울기조건 미충족 - 보유")
+                    else:
+                        tail = ", 240MA 하락 전환" if use_slope else ""
+                        rec['verdict']  = (f">>> 전량 매도! "
+                                           f"(무장+240선 {break_pct*100:.0f}% 아래로 "
+                                           f"{confirm_days}일 확정{tail})")
+                        rec['category']   = 'sell'
+                        rec['sold_today'] = True
+                        is_sold = True
+                        sell_info = {'date': dates[i], 'price': c, 'ma240': m,
+                                     'gap_pct': gap_pct, 'index_i': i}
+
+            rec['consec']  = consec
+            rec['is_sold'] = is_sold
+            rows.append(rec)
+
+        return rows, sell_info
+
+    def analyze(ticker):
+        print("=" * 96)
+        print(f"240일선 추세사망 컷 디버그 : {ticker}")
+        print(f"규칙 : 종가 < 240MA×{1-BREAK_PCT:.2f} ({BREAK_PCT*100:.0f}% 아래) "
+              f"가 {CONFIRM_DAYS}일 연속 -> 전량 매도"
+              + (f" | 240MA 하락전환 필수(USE_SLOPE)" if USE_SLOPE else " | 240MA방향은 정보로만"))
+        print("=" * 96)
+
+        name, market = ticker, '-'
+        try:
+            kospi  = fdr.StockListing('KOSPI')
+            kosdaq = fdr.StockListing('KOSDAQ')
+            if ticker in kospi['Code'].values:
+                market = 'KOSPI'; name = kospi[kospi['Code'] == ticker]['Name'].values[0]
+            elif ticker in kosdaq['Code'].values:
+                market = 'KOSDAQ'; name = kosdaq[kosdaq['Code'] == ticker]['Name'].values[0]
+        except Exception:
+            pass
+
+        data_start = (datetime.today() - timedelta(days=DATA_BACK)).strftime('%Y-%m-%d')
+        analyze_to = datetime.today().strftime('%Y-%m-%d')
+        df = fdr.DataReader(ticker, data_start, analyze_to)
+        if df is None or len(df) == 0:
+            print("데이터 없음"); return
+        print(f"종목 : {name} ({ticker}) / {market} | 데이터 {len(df)}일\n")
+
+        rows, sell_info = compute_240ma_cut(df)
+
+        if np.isnan(rows[-1]['ma240']):
+            print("!! 240일치 데이터가 부족해서 240MA를 못 구함 -> 분석 불가 "
+                  "(상장 1년 미만 종목)")
+            return
+
+        valid_rows = [r for r in rows if r['category'] != 'nodata']
+        if not valid_rows:
+            print("240MA 유효 구간 없음"); return
+
+        if SHOW_FROM:
+            win = [r for r in valid_rows if str(r['date'])[:10] >= SHOW_FROM]
+            if not win:
+                print(f"!! SHOW_FROM({SHOW_FROM}) 이후 데이터 없음. 240MA 유효 범위: "
+                      f"{str(valid_rows[0]['date'])[:10]} ~ {str(valid_rows[-1]['date'])[:10]}")
+                return
+        else:
+            win = valid_rows
+
+        print(f"240MA 유효 시작: {str(valid_rows[0]['date'])[:10]} | "
+              f"표 표시: {str(win[0]['date'])[:10]} ~ {str(win[-1]['date'])[:10]}")
+
+        print("-" * 96)
+        print(f"{'날짜':<11}{'종가':>9}{'240MA':>9}{'컷라인':>9}"
+              f"{'vs240':>8}{'방향':>5}{'연속':>5}  판정")
+        print("-" * 96)
+
+        dir_map = {'up': 'UP', 'down': 'DN', 'na': '-', '-': '-'}
+        prev_cat = None
+        for k, r in enumerate(win):
+            cat       = r['category']
+            is_last   = (k == len(win) - 1)
+            notable   = (cat != prev_cat) or (cat in ('below_cut', 'sell')) or is_last
+            prev_cat  = cat
+            if not notable:
+                continue
+            consec_s = str(r['consec']) if r['category'] == 'below_cut' else ''
+            mark     = '  <<<<<' if r['sold_today'] else ''
+            print(f"{str(r['date'])[:10]:<11}"
+                  f"{r['close']:>9,.0f}"
+                  f"{r['ma240']:>9,.0f}"
+                  f"{r['cut_line']:>9,.0f}"
+                  f"{r['gap_pct']:>+7.1f}%"
+                  f"{dir_map.get(r['ma_dir'],'-'):>5}"
+                  f"{consec_s:>5}  {r['verdict']}{mark}")
+
+        print("\n" + "=" * 96)
+        print("요약")
+        print("=" * 96)
+        print(f"종목     : {name} ({ticker}) / {market}")
+        print(f"컷 규칙  : 무장(240선 +{ARM_PCT*100:.0f}% 이력) + 240MA×{1-BREAK_PCT:.2f} "
+              f"아래 {CONFIRM_DAYS}일 연속" + (" + 240MA 하락전환" if USE_SLOPE else ""))
+
+        valid_gaps = [r['gap_pct'] for r in valid_rows if not np.isnan(r['gap_pct'])]
+        max_gap    = max(valid_gaps) if valid_gaps else float('nan')
+        ever_armed = any(r['armed'] for r in valid_rows)
+        print(f"무장 상태: {'무장됨' if ever_armed else '무장 안 됨(동산 구간 -> 240선 컷 대상 아님)'}"
+              f" | 240선 대비 최고 {max_gap:+.1f}%")
+
+        if sell_info is not None:
+            si = sell_info
+            in_win = "" if si['date'] >= win[0]['date'] else "  (표 시작 이전 구간)"
+            print(f"매도 신호: >>> {str(si['date'])[:10]}{in_win} | "
+                  f"매도가 {si['price']:,.0f} | 그때 240MA {si['ma240']:,.0f} "
+                  f"({si['gap_pct']:+.1f}%)")
+
+            after = [r for r in rows[si['index_i'] + 1:] if not np.isnan(r['close'])]
+            if after:
+                ac     = np.array([r['close'] for r in after])
+                mn_i   = int(np.argmin(ac)); mx_i = int(np.argmax(ac))
+                mn, mx, lp = ac[mn_i], ac[mx_i], ac[-1]
+                mn_chg = (mn / si['price'] - 1) * 100
+                mx_chg = (mx / si['price'] - 1) * 100
+                lp_chg = (lp / si['price'] - 1) * 100
+                print(f"\n[매도 후 검증]  매도가 {si['price']:,.0f} 기준")
+                print(f"  이후 최고 : {mx:,.0f} ({str(after[mx_i]['date'])[:10]}) -> {mx_chg:+.1f}%")
+                print(f"  이후 최저 : {mn:,.0f} ({str(after[mn_i]['date'])[:10]}) -> {mn_chg:+.1f}%")
+                print(f"  현재가    : {lp:,.0f} -> {lp_chg:+.1f}%")
+                if mx_chg >= 10 and mx_i < mn_i:
+                    print(f"  => 매도 후 {mx_chg:+.0f}%까지 반등했다가 빠짐 "
+                          f"-> 휩쏘(저점 근처에서 너무 일찍 컷) 가능성 큼.")
+                elif mn_chg <= -5:
+                    print(f"  => 매도 후 더 빠짐 -> 컷이 손실을 막아준 케이스.")
+                elif lp_chg > 8:
+                    print(f"  => 매도 후 반등 유지 -> 휩쏘(너무 일찍 컷) 가능성.")
+                else:
+                    print(f"  => 매도 후 큰 변동 없음.")
+        else:
+            last = win[-1]
+            cat  = last['category']
+            print(f"매도 신호: 없음 (240선 컷 미발생, 계속 보유)")
+            if cat == 'safe_above':
+                tail = "240선 위, 보유"
+            elif cat == 'buffer':
+                tail = "240선 아래지만 컷라인 위(살짝 깸), 보유"
+            elif cat == 'below_cut':
+                tail = (f"컷라인 아래 {last['consec']}일째 "
+                        f"(확정 전, {CONFIRM_DAYS}일 되면 매도), 보유")
+            elif cat == 'below_unarmed':
+                tail = (f"컷라인 아래지만 동산 구간(무장 안 됨) -> 컷 대상 아님, 보유")
+            else:
+                tail = "보유"
+            print(f"현재 상태: 종가 {last['close']:,.0f} / 240MA {last['ma240']:,.0f} "
+                  f"({last['gap_pct']:+.1f}%) -> {tail}")
+
+    try:
+        with contextlib.redirect_stdout(buf):
+            analyze(ticker)
+    except SystemExit:
+        pass
+    except Exception as e:
+        buf.write(f"\n[오류] {type(e).__name__}: {e}\n"
+                  f"티커 번호(6자리)를 확인해주세요. 예: 005930")
+    return buf.getvalue()
+
+
+# ============================================================
+# 3) 전량매도 (RS·이격)  (sell_+10_debug.py 로직 그대로)
+# ============================================================
+def run_sell(ticker):
+    buf = io.StringIO()
+    try:
+        with contextlib.redirect_stdout(buf):
+            TICKER = ticker
+
+            DIV_THRESHOLD       = -0.10
+            RS_MA_PERIOD        = 20
+            INDEX_PEAK_LOOKBACK = 180
+            DATA_START = (datetime.today() - timedelta(days=600)).strftime('%Y-%m-%d')
+            ANALYZE_TO = datetime.today().strftime('%Y-%m-%d')
+
+            print("=" * 70)
+            print(f"분석 종목: {TICKER}")
+            print("=" * 70)
+            print("\n[1/3] 시장 판별 중...")
+            market = 'KOSDAQ'; name = TICKER
+            try:
+                kospi  = fdr.StockListing('KOSPI')
+                kosdaq = fdr.StockListing('KOSDAQ')
+                if TICKER in kospi['Code'].values:
+                    market = 'KOSPI'
+                    name = kospi[kospi['Code'] == TICKER]['Name'].values[0]
+                elif TICKER in kosdaq['Code'].values:
+                    market = 'KOSDAQ'
+                    name = kosdaq[kosdaq['Code'] == TICKER]['Name'].values[0]
+                print(f"    {name} ({TICKER}) / {market}")
+            except:
+                print(f"    판별 실패 -> {market} 가정")
+
+            print("\n[2/3] 데이터 로드 중...")
+            stock_df = fdr.DataReader(TICKER, DATA_START, ANALYZE_TO)
+            if stock_df is None or len(stock_df) == 0:
+                print("종목 데이터 없음"); sys.exit()
+
+            candidates = ['KQ11', '^KQ11'] if market == 'KOSDAQ' else ['KS11', '^KS11']
+            index_df = None
+            for c in candidates:
+                try:
+                    t = fdr.DataReader(c, DATA_START, ANALYZE_TO)
+                    if t is not None and len(t) > 0:
+                        index_df = t; print(f"    지수: {c}"); break
+                except:
+                    continue
+            if index_df is None:
+                print("지수 로드 실패"); sys.exit()
+
+            merged = pd.concat([
+                stock_df['Close'].rename('stock'),
+                index_df['Close'].rename('index')
+            ], axis=1).dropna()
+            print(f"    종목 {len(stock_df)}일 | 지수 {len(index_df)}일")
+
+            print("\n[3/3] 지수 고점 탐색 중...")
+            cutoff = (datetime.today() - timedelta(days=INDEX_PEAK_LOOKBACK)).strftime('%Y-%m-%d')
+            recent_idx       = merged[merged.index >= cutoff]['index']
+            index_peak_date  = recent_idx.idxmax()
+            index_peak_value = float(recent_idx.max())
+            stock_at_peak    = float(merged.loc[index_peak_date, 'stock']) if index_peak_date in merged.index else None
+
+            latest_date = merged.index[-1]
+            is_ath      = (index_peak_date == latest_date)
+
+            days_from_peak = (latest_date.to_pydatetime().replace(tzinfo=None) -
+                              index_peak_date.to_pydatetime().replace(tzinfo=None)).days
+
+            print(f"    지수 고점: {index_peak_value:,.2f} ({str(index_peak_date)[:10]})")
+            print(f"    정점날 종목: {stock_at_peak:,.0f}" if stock_at_peak else "    정점날 종목: 없음")
+            print(f"    오늘 지수: {float(merged['index'].iloc[-1]):,.2f} ({str(latest_date)[:10]})")
+            print(f"    ATH 여부: {'예 → RS Line 분석' if is_ath else f'아니오 (고점 {days_from_peak}일 경과) → 이격 분석'}")
+
+            FLAG_START = str(index_peak_date)[:10]
+
+            if not is_ath:
+                flag_data = merged[merged.index >= FLAG_START].copy()
+                if len(flag_data) == 0:
+                    print("데이터 없음"); sys.exit()
+
+                print("\n" + "=" * 70)
+                print("[이격 분석] 지수 고점 기준")
+                print(f"지수 정점: {FLAG_START} ({index_peak_value:,.2f})")
+                print("=" * 70)
+                print(f"\n{'날짜':<12} {'종목가':>8} {'지수':>8} {'지수수익':>9} {'종목수익':>9} {'이격':>8} {'flag':>5}  판정")
+                print("-" * 78)
+
+                div_flag = False; div_flag_value = None
+                sell_signal = False; sell_date = None; sell_reason = None
+
+                for date, row in flag_data.iterrows():
+                    s = float(row['stock']); idx = float(row['index'])
+                    if stock_at_peak is None:
+                        continue
+                    ir  = (idx / index_peak_value) - 1
+                    sr  = (s   / stock_at_peak)    - 1
+                    div = sr - ir
+                    verdict = ''
+                    if div <= DIV_THRESHOLD:
+                        if not div_flag:
+                            div_flag = True; div_flag_value = div
+                            verdict = '*** FLAG ON (오늘 매도X)'
+                        else:
+                            if div < div_flag_value:
+                                verdict = '!!! 전량매도!'
+                                if not sell_signal:
+                                    sell_signal = True; sell_date = str(date)[:10]
+                                    sell_reason = f'이격 {div*100:.1f}%'
+                                div_flag_value = div
+                            else:
+                                verdict = 'Watch'; div_flag_value = div
+                    else:
+                        if div_flag:
+                            div_flag = False; div_flag_value = None; verdict = 'FLAG OFF'
+
+                    print(f"{str(date)[:10]:<12} {s:>8,.0f} {idx:>8,.0f} "
+                          f"{ir*100:>+8.1f}% {sr*100:>+8.1f}% {div*100:>+7.1f}% "
+                          f"{'ON' if div_flag else '':>5}  {verdict}")
+
+                print()
+                if sell_signal:
+                    print(f">>> 전량 매도 신호: {sell_date} | {sell_reason}")
+                else:
+                    print(">>> 아직 전량 매도 신호 없음")
+
+                if stock_at_peak:
+                    last = flag_data.iloc[-1]
+                    dv_now = ((float(last['stock'])/stock_at_peak) - 1) - ((float(last['index'])/index_peak_value) - 1)
+                    print(f"\n현재 이격 ({str(flag_data.index[-1])[:10]}):")
+                    print(f"  지수 정점   : {index_peak_value:,.2f} ({FLAG_START})")
+                    print(f"  정점날 종목 : {stock_at_peak:,.0f}")
+                    print(f"  현재 종목   : {float(last['stock']):,.0f}")
+                    print(f"  이격        : {dv_now*100:+.1f}% (기준 {DIV_THRESHOLD*100:.0f}%)")
+                    print(f"  div_flag    : {'ON' if div_flag else 'off'}")
+
+                print("\n" + "=" * 70)
+                print("최종 요약")
+                print("=" * 70)
+                print(f"종목      : {name} ({TICKER}) / {market}")
+                print(f"지수 정점 : {FLAG_START} ({index_peak_value:,.2f}) | {days_from_peak}일 경과")
+                print(f"이격 신호 : {('>>> ' + sell_date) if sell_signal else 'None'}")
+                print()
+                if sell_signal:
+                    print(f"==> 매도 신호: {sell_date}")
+                else:
+                    print("==> 아직 매도 신호 없음. 계속 보유.")
+
+            else:
+                print("\n" + "=" * 70)
+                print(f"[RS Line 분석] MA{RS_MA_PERIOD} - 오늘이 지수 고점 (ATH)")
+                print("=" * 70)
+
+                rs_all = merged.copy()
+                rs_all['rs']    = rs_all['stock'] / rs_all['index']
+                rs_all['rs_ma'] = rs_all['rs'].rolling(RS_MA_PERIOD).mean()
+                rs_flag = rs_all[rs_all.index >= FLAG_START].dropna(subset=['rs_ma'])
+
+                rs_sell_signal = False; rs_sell_date = None
+
+                if len(rs_flag) == 0:
+                    print("RS MA 계산 불가 (데이터 부족)")
+                else:
+                    print(f"\n{'날짜':<12} {'종목가':>8} {'RS':>10} {'RS MA20':>10} {'vs MA':>8}  판정")
+                    print("-" * 58)
+                    for date, row in rs_flag.iterrows():
+                        rs = float(row['rs']); rma = float(row['rs_ma'])
+                        pct = (rs / rma - 1) * 100
+                        v = '>>> 데드크로스!' if rs < rma else 'Golden'
+                        if rs < rma and not rs_sell_signal:
+                            rs_sell_signal = True; rs_sell_date = str(date)[:10]
+                        print(f"{str(date)[:10]:<12} {float(row['stock']):>8,.0f} "
+                              f"{rs:>10.4f} {rma:>10.4f} {pct:>+7.1f}%  {v}")
+
+                print("\n" + "=" * 70)
+                print("최종 요약")
+                print("=" * 70)
+                print(f"종목      : {name} ({TICKER}) / {market}")
+                print(f"지수 정점 : {FLAG_START} ({index_peak_value:,.2f}) | ATH")
+                print(f"RS  신호  : {('>>> ' + rs_sell_date) if rs_sell_signal else 'None'}")
+                print()
+                if rs_sell_signal:
+                    print(f"==> RS Line 매도 신호: {rs_sell_date}")
+                else:
+                    print("==> RS Line 데드크로스 없음. 계속 보유.")
+    except SystemExit:
+        pass
+    except Exception as e:
+        buf.write(f"\n[오류] {type(e).__name__}: {e}\n"
+                  f"티커 번호(6자리)를 확인해주세요. 예: 005930")
+    return buf.getvalue()
+
+
+# ============================================================
+# 4) VCP 실패 부분매도  (vcp_sell_debug.py 로직 그대로)
+# ============================================================
+def run_vcp_sell(ticker):
+    buf = io.StringIO()
+
+    VCP_BUFFER  = 0.05
+    VCP_BUY_KRW = None
+    STOP_REF    = 'breakout_low'
+
+    CONTRACT_DAYS    = 2
+    VOL_DRYUP_SURGE  = 2.0
+    MIN_PRICE_GAIN   = 0.10
+    BASE_LOOKBACK    = 10
+
+    ANALYZE_DAYS = 365
+    WARMUP_DAYS  = 40
+    DATA_START   = (datetime.today() - timedelta(days=ANALYZE_DAYS + WARMUP_DAYS)).strftime('%Y-%m-%d')
+    ANALYZE_FROM = (datetime.today() - timedelta(days=ANALYZE_DAYS)).strftime('%Y-%m-%d')
+
+    def find_vcp_breakouts(df):
+        O = df['Open'].values.astype(float);  H = df['High'].values.astype(float)
+        L = df['Low'].values.astype(float);   C = df['Close'].values.astype(float)
+        V = df['Volume'].values.astype(float)
+        out = []
+        for t in range(BASE_LOOKBACK, len(df)):
+            quiet_max = V[t - CONTRACT_DAYS:t].max()
+            if quiet_max <= 0 or C[t - 1] <= 0:
+                continue
+            surge     = V[t] / quiet_max
+            base_high = H[t - BASE_LOOKBACK:t].max()
+            gain      = C[t] / C[t - 1] - 1
+            if (surge >= VOL_DRYUP_SURGE and C[t] > base_high
+                    and gain >= MIN_PRICE_GAIN and C[t] > O[t]):
+                out.append({
+                    'i': t, 'date': str(df.index[t])[:10],
+                    'close': C[t], 'open': O[t], 'low': L[t],
+                    'gain': round(gain * 100, 1), 'surge': round(surge, 2),
+                    'base_high': base_high, 'base_low': float(L[t - BASE_LOOKBACK:t].min()),
+                })
+        return [b for b in out if b['date'] >= ANALYZE_FROM]
+
+    def track_vcp_stop(closes, dates, breakout_i, ref_low, entry_price, buffer=VCP_BUFFER):
+        stop = ref_low * (1 - buffer)
+        daily, failed, fail = [], False, None
+        for k in range(breakout_i + 1, len(closes)):
+            ck = float(closes[k])
+            if ck < stop:
+                failed = True
+                fail = {'date': dates[k], 'price': ck, 'k': k,
+                        'loss_pct': (ck / entry_price - 1) * 100}
+                daily.append((dates[k], ck, 'fail')); break
+            elif ck < stop * 1.05:
+                daily.append((dates[k], ck, 'warn'))
+            else:
+                daily.append((dates[k], ck, 'hold'))
+        return stop, failed, fail, daily
+
+    def analyze(ticker):
+        ref_name = "돌파일 저점" if STOP_REF == 'breakout_low' else "베이스 저점"
+        print("=" * 80)
+        print(f"VCP 실패 부분매도 디버그 : {ticker}")
+        print(f"규칙 : 돌파 매수 후 종가 < {ref_name}×{1-VCP_BUFFER:.2f} ({VCP_BUFFER*100:.0f}% 버퍼) "
+              f"-> VCP 실패 -> VCP로 산 만큼만 부분 매도")
+        print(f"       (VCP 실패 ≠ 종목 악화. 나머지 포지션은 그대로 유지)")
+        print("=" * 80)
+
+        name, market = ticker, '-'
+        try:
+            kospi  = fdr.StockListing('KOSPI')
+            kosdaq = fdr.StockListing('KOSDAQ')
+            if ticker in kospi['Code'].values:
+                market = 'KOSPI'; name = kospi[kospi['Code'] == ticker]['Name'].values[0]
+            elif ticker in kosdaq['Code'].values:
+                market = 'KOSDAQ'; name = kosdaq[kosdaq['Code'] == ticker]['Name'].values[0]
+        except Exception:
+            pass
+
+        df = fdr.DataReader(ticker, DATA_START, datetime.today().strftime('%Y-%m-%d'))
+        if df is None or len(df) == 0:
+            print("데이터 없음"); return
+        print(f"종목 : {name} ({ticker}) / {market} | 데이터 {len(df)}일\n")
+
+        bos    = find_vcp_breakouts(df)
+        closes = df['Close'].values.astype(float)
+        dates  = [str(d)[:10] for d in df.index]
+        print(f"VCP 돌파(매수): {len(bos)}개\n")
+        if not bos:
+            print("VCP 돌파 없음 -> 추적 대상 없음"); return
+
+        results = []
+        for n, b in enumerate(bos, 1):
+            entry   = b['close']
+            ref_low = b['low'] if STOP_REF == 'breakout_low' else b['base_low']
+            stop, failed, fail, daily = track_vcp_stop(closes, dates, b['i'], ref_low, entry, VCP_BUFFER)
+
+            print("-" * 80)
+            print(f"VCP #{n}  돌파 {b['date']} @ {entry:,.0f}원 "
+                  f"(상승 +{b['gain']}%, 거래량 {b['surge']}배)")
+            print(f"  {ref_name}: {ref_low:,.0f} | 손절선 = {ref_low:,.0f}×{1-VCP_BUFFER:.2f} = {stop:,.0f}원 "
+                  f"(진입가 대비 {(stop/entry-1)*100:+.1f}%)")
+            print(f"  ---- 돌파 후 추적 ----")
+            prev = None
+            for j, (d, c, st) in enumerate(daily):
+                is_last = (j == len(daily) - 1)
+                if not ((st != prev) or st in ('warn', 'fail') or is_last):
+                    prev = st; continue
+                prev = st
+                if st == 'fail':
+                    msg = (f">>> VCP 실패! 종가 {c:,.0f} < 손절선 {stop:,.0f} "
+                           f"-> VCP분만 매도 (진입가 대비 {fail['loss_pct']:+.1f}%)  <<<<<")
+                elif st == 'warn':
+                    msg = f"경고 (종가 {c:,.0f}, 손절선 {stop:,.0f} 근접) - 보유"
+                else:
+                    msg = f"보유 (종가 {c:,.0f} > 손절선 {stop:,.0f})"
+                print(f"  {d:<11} {msg}")
+            if not failed:
+                cur = closes[-1]
+                print(f"  => VCP 유지 중 (현재 {cur:,.0f}, 진입가 대비 {(cur/entry-1)*100:+.1f}%)")
+            results.append({'n': n, 'entry': entry, 'failed': failed, 'fail': fail})
+            print()
+
+        fails = [r for r in results if r['failed']]
+        holds = [r for r in results if not r['failed']]
+        print("=" * 80)
+        print("요약")
+        print("=" * 80)
+        print(f"종목     : {name} ({ticker}) / {market}")
+        print(f"VCP 돌파 : {len(bos)}개 | 실패(부분매도): {len(fails)}개 | 유지: {len(holds)}개")
+        if fails:
+            avg = np.mean([r['fail']['loss_pct'] for r in fails])
+            print(f"실패분 손실: 평균 {avg:+.1f}% (VCP 트랜치 기준, 나머지 포지션은 유지)")
+            for r in fails:
+                line = f"  VCP #{r['n']}: 진입 {r['entry']:,.0f} -> {r['fail']['date']} 매도 ({r['fail']['loss_pct']:+.1f}%)"
+                if VCP_BUY_KRW:
+                    loss = VCP_BUY_KRW * r['fail']['loss_pct'] / 100
+                    line += f" | 매도금액 ~{VCP_BUY_KRW+loss:,.0f}원 (손익 {loss:+,.0f}원)"
+                print(line)
+
+    try:
+        with contextlib.redirect_stdout(buf):
+            analyze(ticker)
+    except SystemExit:
+        pass
+    except Exception as e:
+        buf.write(f"\n[오류] {type(e).__name__}: {e}\n"
+                  f"티커 번호(6자리)를 확인해주세요. 예: 005930")
+    return buf.getvalue()
+
+
+# ============================================================
+# 5) VCP 돌파 감지  (past_vcp_debug.py 로직 그대로 + 진단 날짜 선택)
+# ============================================================
+def run_vcp_detect(ticker, diagnose_date=None):
+    buf = io.StringIO()
+
+    CONTRACT_DAYS    = 2
+    VOL_DRYUP_SURGE  = 6.0
+    MIN_PRICE_GAIN   = 0.13
+    BASE_LOOKBACK    = 10
+
+    DIAGNOSE_DATE    = diagnose_date  # 비우면 진단 생략
+
+    ANALYZE_DAYS = 365
+    WARMUP_DAYS  = 40
+    DATA_START   = (datetime.today() - timedelta(days=ANALYZE_DAYS + WARMUP_DAYS)).strftime('%Y-%m-%d')
+    ANALYZE_FROM = (datetime.today() - timedelta(days=ANALYZE_DAYS)).strftime('%Y-%m-%d')
+    ANALYZE_TO   = datetime.today().strftime('%Y-%m-%d')
+
+    def find_vcp_breakouts(df):
+        O = df['Open'].values.astype(float);  H = df['High'].values.astype(float)
+        L = df['Low'].values.astype(float);   C = df['Close'].values.astype(float)
+        V = df['Volume'].values.astype(float)
+        out = []
+        for t in range(BASE_LOOKBACK, len(df)):
+            quiet_max = V[t - CONTRACT_DAYS:t].max()
+            if quiet_max <= 0 or C[t - 1] <= 0:
+                continue
+            surge     = V[t] / quiet_max
+            base_high = H[t - BASE_LOOKBACK:t].max()
+            gain      = C[t] / C[t - 1] - 1
+            if (surge >= VOL_DRYUP_SURGE and C[t] > base_high
+                    and gain >= MIN_PRICE_GAIN and C[t] > O[t]):
+                out.append({
+                    'i': t, 'date': str(df.index[t])[:10],
+                    'close': C[t], 'open': O[t], 'low': L[t],
+                    'gain': round(gain * 100, 1), 'surge': round(surge, 2),
+                    'base_high': base_high, 'base_low': float(L[t - BASE_LOOKBACK:t].min()),
+                })
+        return [b for b in out if b['date'] >= ANALYZE_FROM]
+
+    def run_diagnose(df, date_str):
+        O = df['Open'].values.astype(float);  H = df['High'].values.astype(float)
+        C = df['Close'].values.astype(float); V = df['Volume'].values.astype(float)
+        idx = [str(d)[:10] for d in df.index]
+        pos = next((k for k, d in enumerate(idx) if d >= date_str), len(df) - 1)
+        lo  = max(BASE_LOOKBACK, pos - 12); hi = min(len(df), pos + 4)
+        bh_label = f"{BASE_LOOKBACK}일고가"
+
+        print("\n" + "=" * 92)
+        print(f"[진단] {date_str} 주변 일별  (배수 = 그날 거래량 / 직전 {CONTRACT_DAYS}일 '최대' 거래량)")
+        print("=" * 92)
+        print(f"{'날짜':<11}{'종가':>8}{'시가':>8}{'거래량':>12}{'직전최대':>12}{'배수':>7}"
+              f"{'대비%':>7}{'양봉':>5}{bh_label:>9}{'고가돌파':>7}")
+        print("-" * 92)
+        for k in range(lo, hi):
+            qa  = V[k - CONTRACT_DAYS:k].max()
+            sg  = (V[k] / qa) if qa > 0 else 0
+            bh  = H[k - BASE_LOOKBACK:k].max()
+            gn  = (C[k] / C[k - 1] - 1) * 100 if C[k - 1] > 0 else 0
+            bull = 'O' if C[k] > O[k] else ''
+            pbk  = 'O' if C[k] > bh else ''
+            mark = '  <==' if idx[k] == date_str else ''
+            print(f"{idx[k]:<11}{C[k]:>8,.0f}{O[k]:>8,.0f}{V[k]:>12,.0f}{qa:>12,.0f}{sg:>6.1f}x"
+                  f"{gn:>+6.1f}%{bull:>5}{bh:>9,.0f}{pbk:>7}{mark}")
+
+        print("\n  [판정]")
+        target = idx[pos]
+        if target != date_str:
+            print(f"  (참고: {date_str}은 거래일 아님 -> 가장 가까운 {target} 기준)")
+        qa = V[pos - CONTRACT_DAYS:pos].max()
+        sg = (V[pos] / qa) if qa > 0 else 0
+        bh = H[pos - BASE_LOOKBACK:pos].max()
+        gn = (C[pos] / C[pos - 1] - 1) * 100 if C[pos - 1] > 0 else 0
+        c1 = sg >= VOL_DRYUP_SURGE; c2 = C[pos] > bh
+        c3 = gn >= MIN_PRICE_GAIN * 100; c4 = C[pos] > O[pos]
+        print(f"    거래량 배수 {sg:.1f}x >= {VOL_DRYUP_SURGE}?        {'O' if c1 else 'X'}")
+        print(f"    종가 {C[pos]:,.0f} > {BASE_LOOKBACK}일고가 {bh:,.0f}?   {'O' if c2 else 'X'}")
+        print(f"    상승률 {gn:+.1f}% >= {MIN_PRICE_GAIN*100:.0f}%?         {'O' if c3 else 'X'}")
+        print(f"    양봉 (종가 {C[pos]:,.0f} > 시가 {O[pos]:,.0f})?    {'O' if c4 else 'X'}")
+        if c1 and c2 and c3 and c4:
+            print(f"  => 4조건 통과 -> 잡혀야 함.")
+        else:
+            fails = [n for n, ok in [(f'거래량 배수 부족({sg:.1f}x)', c1), ('가격이 고가 못 넘음', c2),
+                                     (f'상승률 부족({gn:+.1f}%)', c3), ('음봉', c4)] if not ok]
+            print(f"  => 안 잡힘. 이유: {', '.join(fails)}")
+            if not c1:
+                print(f"     (VOL_DRYUP_SURGE를 {sg:.1f} 밑으로 낮추면 잡혀)")
+
+    try:
+        with contextlib.redirect_stdout(buf):
+            TICKER = ticker
+            print("=" * 70)
+            print(f"VCP 돌파 감지: {TICKER} | 기간: {ANALYZE_FROM} ~ {ANALYZE_TO}")
+            print(f"조건: 직전{CONTRACT_DAYS}일 대비 거래량 {VOL_DRYUP_SURGE}배+ & {BASE_LOOKBACK}일고가 돌파 "
+                  f"& 상승 +{MIN_PRICE_GAIN*100:.0f}%+ & 양봉")
+            print("=" * 70)
+
+            df = fdr.DataReader(TICKER, DATA_START, ANALYZE_TO)
+            if df is None or len(df) == 0:
+                print("데이터 없음"); sys.exit()
+            print(f"데이터: {len(df)}일 로드 완료\n")
+
+            bos = find_vcp_breakouts(df)
+            print(f"감지된 VCP 돌파: {len(bos)}개\n")
+
+            for n, b in enumerate(bos, 1):
+                print("=" * 70)
+                print(f"VCP #{n}  돌파 {b['date']} @ {b['close']:,.0f}원")
+                print(f"  상승률 +{b['gain']}% | 거래량 {b['surge']}배(직전{CONTRACT_DAYS}일의 최대 기준) | "
+                      f"{BASE_LOOKBACK}일고가({b['base_high']:,.0f}) 돌파 | 양봉")
+                print()
+
+            print("=" * 70)
+            print(f"요약: 총 {len(bos)}개 돌파")
+            for b in bos:
+                print(f"  {b['date']} | {b['close']:,.0f}원 | +{b['gain']}% | 거래량 {b['surge']}배")
+
+            if DIAGNOSE_DATE:
+                run_diagnose(df, DIAGNOSE_DATE)
+    except SystemExit:
+        pass
+    except Exception as e:
+        buf.write(f"\n[오류] {type(e).__name__}: {e}\n"
+                  f"티커 번호(6자리)를 확인해주세요. 예: 005930")
+    return buf.getvalue()
+
+
+# ============================================================
+# Gradio UI
+# ============================================================
+VCP_DETECT = "VCP 돌파 감지"
+VCP_SELL   = "VCP 실패 부분매도"
+BOLL       = "볼린저 카운트"
+MA240      = "240선 추세사망 컷"
+SELL       = "전량매도 (RS·이격)"
+
+CHOICES = [VCP_DETECT, VCP_SELL, BOLL, MA240, SELL]
+
+
+def analyze(choice, ticker, diag_date):
+    ticker = (ticker or "").strip()
+    if not ticker:
+        return "티커 번호(6자리)를 입력하세요.\n예: 005930(삼성전자), 009150(삼성전기)"
+    diag = (diag_date or "").strip() or None
+
+    if choice == VCP_DETECT:
+        return run_vcp_detect(ticker, diag)
+    if choice == VCP_SELL:
+        return run_vcp_sell(ticker)
+    if choice == BOLL:
+        return run_bollinger(ticker)
+    if choice == MA240:
+        return run_ma240(ticker)
+    if choice == SELL:
+        return run_sell(ticker)
+    return "분석 종류를 선택하세요."
+
+
+with gr.Blocks(title="주식 디버거", theme=gr.themes.Soft()) as demo:
+    gr.Markdown(
+        "## 📈 주식 디버거\n"
+        "분석 종류를 고르고 티커(6자리)를 입력한 뒤 **분석 실행**을 누르세요.\n"
+        "표가 넓으면 좌우로 스크롤하거나 가로화면으로 보세요."
+    )
+    with gr.Row():
+        choice = gr.Dropdown(choices=CHOICES, value=VCP_DETECT, label="분석 종류")
+        ticker = gr.Textbox(label="티커 (6자리)", placeholder="예: 005930")
+    diag_date = gr.Textbox(
+        label="VCP 진단 날짜 (선택 · 'VCP 돌파 감지'에서만 사용)",
+        placeholder="예: 2025-12-16  (비워두면 진단 생략)",
+    )
+    btn = gr.Button("분석 실행", variant="primary")
+    out = gr.Code(label="결과", lines=30)
+
+    btn.click(analyze, inputs=[choice, ticker, diag_date], outputs=out)
+    ticker.submit(analyze, inputs=[choice, ticker, diag_date], outputs=out)
+
+
+if __name__ == "__main__":
+    demo.launch()