Update final_sell_monitor.py

final_sell_monitor.py

@@ -21,6 +21,7 @@ import sys, ssl, os
 from datetime import datetime, timezone, timedelta
 import FinanceDataReader as fdr
 import confirm_sell_backtest as BT   # 핵심 로직/설정 그대로 (main()은 __main__ 가드라 실행 안 됨)
+import buy_engine as be              # 매수 엔진 (일봉 동산/위아래 국면 → '모아가는 구간' 판별)
 
 KST = timezone(timedelta(hours=9))
 
@@ -51,11 +52,115 @@ MAP_PATH = os.path.join(HERE, 'market_map.csv')
 # =====================================================
 # [여기만 바꾸면 됨] 보유종목 코드
 # =====================================================
+# =====================================================
+# 모아가는 구간 (매수 국면) — 이 구간의 전량매도 알람은 무시
+#   구간 = 동산성공(위아래 시작) ~ 2번째 아래 종료(240올)
+#   중간에 생명선이탈/사이클종료/더블동산 나오면 거기서 끝
+# =====================================================
+IGNORE_SELL_IN_ACCUM = True   # False 로 하면 기존처럼 항상 알람
+
+_accum_cache = {}
+
+def accum_ranges(tk):
+    """buy_engine 일봉 국면에서 '모아가는 구간' [(시작일, 끝일|None)]"""
+    if tk in _accum_cache:
+        return _accum_cache[tk]
+    out = []
+    try:
+        df = fdr.DataReader(tk, '2000-01-01')
+        if df is not None and len(df) > 300 and 'Close' in df.columns:
+            ev, buys, mts = be.run(df, '1day')
+            start = None
+            for d, tag, dt in ev:
+                ds = str(d)[:10]
+                if tag == '동산성공→위아래시작':
+                    start = ds
+                elif start and (('2번째 아래 종료' in tag) or ('240올' in tag)
+                                or ('생명선이탈' in tag) or ('사이클종료' in tag)
+                                or ('더블동산' in tag)):
+                    out.append((start, ds)); start = None
+            if start:
+                out.append((start, None))   # 진행 중
+    except Exception:
+        out = []
+    _accum_cache[tk] = out
+    return out
+
+
+def in_accum(ds, ranges):
+    return any(ds >= a and (b is None or ds < b) for a, b in ranges)
+
+
 WATCH = [
-    '277810',   # 레인보우로보틱스
-    '373220',   # LG에너지솔루션
+    # '277810',   # 레인보우로보틱스
+    # '373220',   # LG에너지솔루션
     # 코드 대신 종목명으로도 됨! 예: '레인보우로보틱스', 'LG에너지솔루션'
     # '060370',
+        '483650',  # 달바글로벌
+        '096770',  # SK이노베이션
+        '090430',  # 아모레퍼시픽
+        '326030',  # SK바이오팜
+        '035420',  # NAVER
+        '352820',  # 하이브
+        '003490',  # 대한항공
+        '025540',  # 한국단자
+        '373220',  # LG에너지솔루션
+        '443060',  # HD현대마린솔루션
+        '032350',  # 롯데관광개발
+        '005380',  # 현대차
+        '003670',  # 포스코퓨처엠
+        '011790',  # SKC
+        '005930',  # 삼성전자
+        '000660',  # SK하이닉스
+       '078520',  # 에이블씨엔씨
+        '206640',  # 바디텍메드
+        '302440',  # SK바이오사이언스
+        '328130',  # 루닛
+        '005250',  # 녹십자홀딩스
+        '234690',  # 녹십자웰빙
+        '083930',  # 아바코
+        '195940',  # HK이노엔
+        '122870',  # 와이지엔터테인먼트
+        '112610',  # 씨에스윈드
+        '257720',  # 실리콘투
+        '086710',  # 선진뷰티사이언스
+        '217730',  # 강스템바이오텍
+        '003570',  # SNT다이내믹스
+        '194370',  # 제이에스코퍼레이션
+        '131030',  # 옵투스제약
+        '204320',  # HL만도
+        '096530',  # 씨젠
+        '035900',  # JYP Ent.
+        '178920',  # PI첨단소재
+        '216080',  # 제테마
+        '099320',  # 쎄트렉아이
+        '088130',  # 동아엘텍
+        '420770',  # 기가비스
+        '222080',  # SFA반도체
+        '147830',  # 제룡산업
+        '281820',  # 케이씨텍
+        '017510',  # 세명전기
+        '112290',  # 와이씨켐
+        '089010',  # 켐트로닉스
+        '102120',  # 어보브반도체
+        '251370',  # 와이에이치티
+        '094360',  # 칩스앤미디어
+        '166090',  # 하나머티리얼즈
+        '277810',  # 레인보우로보틱스
+        '389020',  # 자람테크놀로지
+        '161580',  # 필옵틱스
+        '232140',  # 와이씨
+        '033100',  # 제룡전기
+        '031980',  # 피에스케이홀딩스
+        '403870',  # HPSP
+        '183300',  # 코미코
+        '445090',  # 에이직랜드
+        '347850',  # 디앤디파마텍
+        '030530',  # 원익홀딩스
+        '399720',  # 가온칩스
+        '042700',  # 한미반도체
+        '440110',  # 파두
+        '039030',  # 이오테크닉스        
 ]
 
 ALERT_DAYS = 5   # 최근 이 거래일 안에 매도신호가 났으면 [매도]로 알림
@@ -164,7 +269,9 @@ def _skip_reason(stock, low, ma240, s):
     if getattr(BT, 'SKIP_IF_NO_240', False) and cat == 'UNKNOWN':
         return '240일선이 아직 없는 종목(상장 얼마 안 됨)이라 신호를 믿을 수 없어서'
     if getattr(BT, 'SKIP_IF_BELOW_240', False) and cat == 'ALREADY_DOWN':
-        return '신호 당일 주가가 이미 240일선을 건드린 상태 → 이미 늦은 신호라서'
+        tol = getattr(BT, 'BELOW_240_TOL', 0.05)
+        dpct = f'{days*100:.1f}%' if days is not None else ''
+        return f'신호 당일 종가가 240일선 -{tol*100:.0f}% 넘게 한참 아래(-{dpct}) → 이미 늦은 신호라서 (240 근처였으면 울렸음)'
     med = getattr(BT, 'MAX_EARLY_DAYS', None)
     if med is not None and cat == 'EARLY' and days is not None and days > med:
         return f'신호 뒤 {days}거래일이나 지나서야 240일선이 깨짐 → 너무 성급한 신호라서'
@@ -214,6 +321,15 @@ def check_one(tk, market):
         stock, index, r['dates'], r['start_pos'], return_state=True)
     # 백테스터와 동일한 필터로 '진짜 매도'만
     sells = _real_sells(stock, low, ma240, raw_sells)
+    # ★ 모아가는 구간(매수 국면)의 매도신호는 무시
+    accum_now = False; n_muted = 0
+    if IGNORE_SELL_IN_ACCUM:
+        rngs = accum_ranges(tk)
+        if rngs:
+            before = len(sells)
+            sells = [s for s in sells if not in_accum(s['date'], rngs)]
+            n_muted = before - len(sells)
+            accum_now = in_accum(r['dates'][len(stock) - 1], rngs)
     last_i = len(stock) - 1
     recent = [s for s in sells if s['i'] >= last_i - ALERT_DAYS]
 
@@ -241,11 +357,15 @@ def check_one(tk, market):
         'trigger': trigger,
         'skipped': skipped,
         'state': state,
+        'accum_now': accum_now, 'n_muted': n_muted,
     }
 
 
 def status_line(res):
     """현재 단계를 짧게: 관망 / flagON 대기 / 1차 / 2차flagON 대기 + 이격."""
+    if res.get('accum_now'):
+        mut = f" · 무시된 매도신호 {res['n_muted']}건" if res.get('n_muted') else ""
+        return f"★모아가는 구간 (동산 위아래 매수 국면) — 매도알람 무시 중{mut}"
     st = res.get('state')
     if not st:
         return '관망 (신호 대기)'