back to stage

app.py

@@ -179,46 +179,56 @@ def _band(lo, hi):
     return f"≤{hi*100:.0f}%" if lo <= -1 else f"({lo*100:.0f},{hi*100:.0f}]%"
 
 
+def _real_sells(stock, low, ma240, sells):
+    """백테스터 main()과 동일한 4종 필터로 '진짜 매도'만 (240터치/240없음/너무일찍/추세유지 SKIP)."""
+    out = []
+    for s in sells:
+        i = s["i"]; price = s["price"]
+        cat, days = BT.classify_240(stock, low, ma240, i, price)
+        if getattr(BT, "SKIP_IF_NO_240", False) and cat == "UNKNOWN":
+            continue
+        if getattr(BT, "SKIP_IF_BELOW_240", False) and cat == "ALREADY_DOWN":
+            continue
+        med = getattr(BT, "MAX_EARLY_DAYS", None)
+        if med is not None and cat == "EARLY" and days is not None and days > med:
+            continue
+        if getattr(BT, "SKIP_IF_STILL_UP", False) and cat == "STILL_UP":
+            continue
+        out.append(s)
+    return out
+
+
 def check_one(code):
     code = code.zfill(6)
     market = market_of(code)
     r = BT.load_one(code, market)
     if r is None:
         return {"code": code, "market": market, "ok": False, "msg": "데이터 없음"}
-    stock = r["stock"]; index = r["index"]
-    # 백테스터의 ENGINE 설정 그대로 (RS_A4 / STAGE)
-    _engine = BT.find_rs_a4_sells if getattr(BT, "ENGINE", "STAGE") == "RS_A4" else BT.find_confirmed_sells
-    sells, jumps, steps = _engine(
-        stock, index, r["dates"], r["start_pos"],
-        ma60=r.get("ma60"), ma240=r.get("ma240"),
-        low=r.get("low"), bbl=r.get("bbl"),
-        ma240_est=r.get("ma240_est"), ma120=r.get("ma120"))
+    stock = r["stock"]; index = r["index"]; low = r["low"]; ma240 = r["ma240"]
+    sells, jumps, state = BT.find_confirmed_sells(
+        stock, index, r["dates"], r["start_pos"], return_state=True)
+    sells = _real_sells(stock, low, ma240, sells)   # 4종 필터
     last_i = len(stock) - 1
     recent = [s for s in sells if s["i"] >= last_i - ALERT_DAYS]
-
-    # 현재 단계 status: steps 마지막의 '[현재] ...' (없으면 관망)
-    cur = None
-    for stp in steps:
-        if stp["name"].startswith("[현재]"):
-            cur = stp
     return {
         "code": code, "market": market, "ok": True,
         "price_now": float(stock[last_i]),
-        "last_date": r["dates"][last_i],     # 상태 기준일
+        "last_date": r["dates"][last_i],
         "recent": recent,
         "last_sell": sells[-1] if sells else None,
-        "cur": cur,
+        "state": state,
     }
 
 
 def _status_line(res):
-    """현재 단계를 짧게: 관망 / flagON 대기 / 1차 / 2차flagON 대기 + 이격."""
-    cur = res["cur"]
-    if cur is None:
+    st = res.get("state")
+    if not st:
         return "관망 (신호 대기)"
-    name = cur["name"].replace("[현재] ", "")
-    note = cur.get("note", "")
-    return f"{name} · 이격 {cur['div']*100:.1f}%" + (f" · {note}" if note else "")
+    nm = {"없음": "관망", "flagON": "flag ON (대기)", "1차": "1차 (진행중)",
+          "2차flagON": "2차 flag ON (전량매도 임박!)", "2차매도": "전량매도 발동"}.get(
+              st["stage_name"], st["stage_name"])
+    tail = " · 매도후 대기" if st.get("sold") else ""
+    return f"{nm} · 이격 {st['div']*100:.1f}%{tail}"
 
 
 def run_monitor(text):
@@ -227,18 +237,10 @@ def run_monitor(text):
     if not raw:
         return "종목코드 또는 종목명을 입력해줘 (예: 277810  레인보우로보틱스)"
 
-    if getattr(BT, "ENGINE", "STAGE") == "RS_A4":
-        rc = {"A4": "A-4평평", "MA60": "종가<60선", "MA120": "종가<120선",
-              "NONE": "RS단독"}.get(BT.RS_CONFIRM, BT.RS_CONFIRM)
-        head = (f"**전량매도 최후보루** (RS_A4) · 최근 {ALERT_DAYS}거래일 기준\n\n"
-                f"기준: RS선 약화(무장) → {rc} 확인 즉시매도"
-                f"{' + ' + BT.CONFIRM_NEEDS_FLAT if BT.RS_CONFIRM in ('MA60','MA120') else ''}\n\n---\n")
-    else:
-        head = (f"**전량매도 최후보루** (STAGE) · 최근 {ALERT_DAYS}거래일 기준\n\n"
-                f"기준: 돌파후{BT.RUN_MIN_DAYS}일 AND A-4평평 "
-                f"60{_band(BT.FLAT_MIN_60, BT.FLAT_MAX_60)} {BT.FLAT_COMBINE} "
-                f"120{_band(BT.FLAT_MIN_120, BT.FLAT_MAX_120)} {BT.FLAT_COMBINE} "
-                f"240{_band(BT.FLAT_MIN_240, BT.FLAT_MAX_240)}\n\n---\n")
+    head = (f"**전량매도 최후보루** · 최근 {ALERT_DAYS}거래일 기준\n\n"
+            f"기준: 이격 {BT.DIV_THRESHOLD*100:.0f}% 단계누적({BT.MIN_DEEPEN*100:.1f}%p+) "
+            f"+ 하루급변 {BT.DAILY_JUMP*100:.0f}%p 점프. "
+            f"필터: 240터치·240없음·헛매도 제외\n\n---\n")
     out = [head]
     alerts = []
     asof = None