Update app.py

app.py

@@ -1521,39 +1521,60 @@ COL_STAGE_OVERALL = "#C32C2C"  # 빨
 COL_STAGE_PREF    = "#D24D3E"  # 주
 COL_STAGE_REC     = "#DE937A"  # 노
 COL_STAGE_INTENT  = "#D49442"  # 베(골드톤)
-COL_STAGE_BUY     = "#2B8E81"  # 초fig.update_xaxes
+COL_STAGE_BUY     = "#2B8E81"  # 초록   ← 오타 수정
 COL_STAGE_NONPREF = "#9CA3AF"  # 미선호(회색)
 
 
 def matrix_funnel_figure(row, df_tm, seg, mod, loy, **kwargs):
-    # --- 0) 로컬 확률 정규화 + 클리핑 유틸 ---
+    """
+    누적 퍼널:
+    - 퍼센트 문자열(예: '45.5%')/공백 섞여도 robust parsing
+    - 값이 비어도(drop/success 둘 다 NaN) 최소 2단계 이상 강제로 그려줌
+    - 기본 높이 420 (FUNNEL_H가 있으면 그 값 따름)
+    """
+    # --- Robust percent parser -------------------------------------------------
     def _p(x):
-        x = _safe_num(x)
-        if not np.isfinite(x):
+        if x is None:
+            return np.nan
+        if isinstance(x, str):
+            s = x.strip()
+            if not s:
+                return np.nan
+            if s.endswith("%"):
+                try:
+                    return float(s[:-1].strip()) / 100.0
+                except Exception:
+                    return np.nan
+            try:
+                return float(s)
+            except Exception:
+                return np.nan
+        try:
+            x = float(x)
+        except Exception:
             return np.nan
-        # 1.5보다 크면 '퍼센트(예: 23=23%)'로 보고 100으로 나눔
+        # 1.5 초과면 퍼센트로 간주(23 => 0.23)
         return x / 100.0 if x > 1.5 else x
 
-    def _clip01(x):
-        return np.nan if not np.isfinite(x) else float(min(1.0, max(0.0, x)))
+    def _clip01(v):
+        return np.nan if not np.isfinite(v) else float(min(1.0, max(0.0, v)))
 
-    # 1) 드롭/최종율 확보 (확률 정규화 + [0,1] 클리핑)
+    # --- 1) 드롭/최종율 확보 ---------------------------------------------------
     d1_raw, d2_raw, d3_raw, full_raw = drops_from_anywhere(row, df_tm, seg, mod, loy)
     d1, d2, d3 = map(_clip01, map(_p, (d1_raw, d2_raw, d3_raw)))
-    full_conv  = _p(full_raw)  # 최종율은 음수/1초과가 들어올 수 있어도 아래에서 단계 보정으로 처리
+    full_conv  = _p(full_raw)
 
-    # 2) 개별 스테이지 성공률 (확률 정규화)
+    # --- 2) 단계별 성공률 ------------------------------------------------------
     pref_sr   = _p(row.get("pref_success_rate"))
     rec_sr    = _p(row.get("rec_success_rate"))
     intent_sr = _p(row.get("intent_success_rate"))
     buy_sr    = _p(row.get("buy_success_rate"))
 
-    # 3) 누적율 계산 (드롭 우선, 결측 시 폴백)
+    # --- 3) 누적율 계산(드롭우선, 결측 폴백) -----------------------------------
     overall = 1.0
-    pref   = pref_sr
-
-    rec = pref * (1 - d1) if np.isfinite(pref) and np.isfinite(d1) else rec_sr
-    intent = rec * (1 - d2) if np.isfinite(rec) and np.isfinite(d2) else intent_sr
+    pref    = pref_sr
+    rec     = pref * (1 - d1) if np.isfinite(pref)   and np.isfinite(d1) else rec_sr
+    intent  = rec  * (1 - d2) if np.isfinite(rec)    and np.isfinite(d2) else intent_sr
 
     if np.isfinite(intent) and np.isfinite(d3):
         buy = intent * (1 - d3)
@@ -1564,19 +1585,14 @@ def matrix_funnel_figure(row, df_tm, seg, mod, loy, **kwargs):
     else:
         buy = intent
 
-    # 3-1) 단계 단조감소 보장 + 0~1 클리핑 (여기서 1.6 같은 값 차단)
-    seq = [overall,
-           _clip01(pref),
-           _clip01(rec),
-           _clip01(intent),
-           _clip01(buy)]
+    # 단조감소 보장 + [0,1] 클리핑
+    seq = [overall, _clip01(pref), _clip01(rec), _clip01(intent), _clip01(buy)]
     for i in range(1, len(seq)):
-        if np.isfinite(seq[i]) and np.isfinite(seq[i-1]):
-            if seq[i] > seq[i-1]:
-                seq[i] = seq[i-1]
+        if np.isfinite(seq[i]) and np.isfinite(seq[i-1]) and seq[i] > seq[i-1]:
+            seq[i] = seq[i-1]
     overall, pref, rec, intent, buy = seq
 
-    # 4) 라벨/값 구성 (이하는 기존 그대로)
+    # --- 4) 라벨/값 구성(비어도 항상 그리기) -----------------------------------
     labels, values = ["전체"], [overall]
     if np.isfinite(pref):   labels.append("선호");     values.append(pref)
     if np.isfinite(rec):    labels.append("추천");     values.append(rec)
@@ -1584,7 +1600,16 @@ def matrix_funnel_figure(row, df_tm, seg, mod, loy, **kwargs):
     if np.isfinite(buy):    labels.append("구매");     values.append(buy)
 
     if len(labels) <= 1:
-        return _empty_fig("No Funnel data")
+        # 드롭률 기반으로 최소 2단계라도 구성
+        v = [1.0]
+        if np.isfinite(d1): v.append(v[-1]*(1-d1))
+        if np.isfinite(d2): v.append(v[-1]*(1-d2))
+        if np.isfinite(d3): v.append(v[-1]*(1-d3))
+        if len(v) == 1:
+            est = _clip01(buy_sr if np.isfinite(buy_sr) else full_conv)
+            v.append(0.0 if not np.isfinite(est) else est)
+        names = ["전체","선호","추천","구매의향","구매"][:len(v)]
+        labels, values = names, v
 
     txtpos = ["inside" if v >= 0.07 else "outside" for v in values]
 
@@ -1610,14 +1635,16 @@ def matrix_funnel_figure(row, df_tm, seg, mod, loy, **kwargs):
         connector=dict(line=dict(color="rgba(0,0,0,0.25)", width=0.6)),
     ))
 
+    # — 높이 확장 & 여백 다이어트
     fig.update_layout(
         title="Funnel (누적율)",
-        height=360,
-        margin=dict(l=10, r=10, t=30, b=10),
+        height=FUNNEL_H if 'FUNNEL_H' in globals() else 420,
+        margin=dict(l=6, r=6, t=26, b=14),
         paper_bgcolor="#ffffff",
         plot_bgcolor="#ffffff",
     )
     fig.update_xaxes(dtick=_auto_dtick(1.0), tickformat=".0%")
+
     return apply_dense_grid(fig, x_prob=True)
 
 def survival_curve_figure(row, df_tm, seg, mod, loy):
@@ -2917,15 +2944,15 @@ def update_all(seg, mod, loy, drag_val, stage_label, tab_right,
             empty, empty, empty, empty, empty, empty, empty, empty
         )
 
-# === [HF ADD] 서버 기동부 ===
+# ===================== 실행 =====================
 if __name__ == "__main__":
-    HOST = "0.0.0.0"
-    import os
-    PORT = int(os.getenv("PORT", "7860"))
-    try:
-        app  # Dash 인스턴스가 전역에 있어야 함 (예: app = Dash(__name__))
-    except NameError as e:
-        raise SystemExit("❌ 'app' 객체가 필요합니다. (app = Dash(__name__))") from e
-    app.run_server(host=HOST, port=PORT, debug=False)
-
+    base_port = int(os.getenv("PORT", "8059"))
+    for i in range(5):
+        try:
+            app.run_server(host="0.0.0.0", port=base_port + i, debug=False, use_reloader=False)
+            break
+        except (OSError, SystemExit) as e:
+            if "Address already in use" in str(e) or getattr(e, "code", None) == 1:
+                continue
+            raise