Files
ExperionCrawler/docs/측류추출식-통합유량설정공식-구현코딩-WO-6-완전코드.md
windpacer 7c26aa7361 feat: Phase II auto-write (WriteGuard, audit, auth) + WO-2~7 완료
Phase II:
- FfOperatorAction entity + ff_operator_action DDL/DbSet
- IFeedforwardWriteGuard + FeedforwardWriteGuard (SP bounds, grade C, transient, NaN)
- IFeedforwardAuditService + FeedforwardAuditService (raw ADO insert/query)
- FeedforwardSupervisor.AutoWriteAsync (per-stream OPC UA after Tick, rate-limited)
- FeedforwardConfigStore: advisory_only now read/writes DB, sp_node_id column
- FeedforwardController: auth (X-Kb-Token) on config/delete/write/audit;
  POST write/{id}/{key} manual SP write; GET audit; write results in MapColumn
- ff.js: token header, auto-write badge, per-stream write result, spNodeId, advisoryOnly
- ff.css: .ff-write-badge, .ff-write, .ff-write-err, .ff-wg-blocked
- Program.cs: register audit (Scoped) + write guard (Singleton)

WO-2~7 (build 0W/0E, test 22/22):
- PCT monitor, θ auto-tune, slow bias, front position indicator,
  total reflux recovery, config form expansion
2026-05-31 20:30:06 +09:00

26 KiB

WO-6 (전환류 Total Reflux 평형복귀 모드) — 완전코드 작업지시서 ★

대상 실행자: 본 LLM보다 능력이 낮은 LLM. 추론·탐색 금지. 찾기/바꾸기 앵커와 전체 코드 블록을 그대로 복붙. 선행 완료 전제(필수): §0 + WO-1 + WO-2 + WO-3 + WO-4 + WO-5 머지 완료. 특히 WO-4(VLossMa)·WO-5(FrontPositionState) 가 트리거 입력이므로 반드시 선행. ColumnMode, ColumnConfig의 recovery 필드들, AdvisoryResult.Mode/ModeReason(§0)은 이미 존재. 불변식(매우 중요): 본 WO도 제어 레지스터 쓰기 0건. 전환류는 "권장 SP 오버라이드 + 모드 표시 + 운전원 ARM"까지만. 실제 SP 쓰기(F·P·D·B 차단, R 전량환류)는 전부 PhaseIII(WriteGuard) 경유. 여기서 SP를 직접 쓰면 불변식 위반.

목적

컬럼 균형이 심각히 붕괴하면(다신호 트리거) 전환류 모드를 권장: FEED·P·D·B 권장SP=0(또는 RecoverySp), R=전량환류(SpMax), 평형 회복까지 dwell 후 램프 복귀. 근거 knowledge/PGMEA_측류추출운전방식_주의점.md §4.3("측류 먼저 중단→환류↑ 재안정화→재개").

상태기계 (AdvisoryResult.Mode)

Normal ──(severe 지속 ImbalanceTriggerSec + !transient + (AutoArm||운전원ARM))──▶ Recovering
Recovering ──(평형 회복 RecoverySettleSec 연속)──▶ Returning ──(ReturnRampSec 경과)──▶ Normal
(어느 상태든 운전원 cancel → Normal)

severe 다신호 트리거(OR, 가용 신호만): ① |VLossMa|/F > ImbalanceTriggerFrac(WO-4) ② WO-5 프론트 "상승/하강" 드리프트 ③ ΔP > DeltaPFloodLimit.

변경 파일 (총 8개)

  1. src/Core/Application/Feedforward/FeedforwardModels.csAdvisoryResult.FeedRecommendedSp, PvSnapshot.DeltaP
  2. src/Infrastructure/Control/FeedforwardEngine.csColumnState 모드 타이머 + ApplyRecovery + Tick 배선
  3. src/Infrastructure/Control/FeedforwardSupervisor.cs — ΔP 읽기 + ARM/Cancel API(ColumnState 접근)
  4. src/Web/Program.cs — Supervisor를 singleton+hosted로 (컨트롤러 주입용)
  5. src/Web/Controllers/FeedforwardController.csrecovery/{id}/arm·cancel + MapColumn에 feedRecommendedSp
  6. src/Web/wwwroot/js/ff.js — 모드 뱃지 + ARM/취소 버튼
  7. src/Web/wwwroot/css/ff.css — 모드 뱃지 스타일
  8. tests/ExperionCrawler.Tests/FeedforwardRecoveryTests.cs신규 테스트

STEP 1 — FeedforwardModels.cs

1.1 AdvisoryResult.FeedRecommendedSp 추가

찾기:

    public string?    FrontPositionState { get; init; }
    public string?    FrontTrimAdvice    { get; init; }
}

바꾸기:

    public string?    FrontPositionState { get; init; }
    public string?    FrontTrimAdvice    { get; init; }
    public double?    FeedRecommendedSp  { get; init; }   // WO-6 전환류 시 FEED 권장(0=차단), 그 외 null
}

1.2 PvSnapshot.DeltaP 추가

전제: WO-3에서 SteamOp가 추가됨.

찾기:

    public IReadOnlyList<TagSample>? Temps { get; init; }
    public TagSample? SteamOp { get; init; }   // WO-3: TICA.OP (스팀, 부분상관 2번째 입력)
}

바꾸기:

    public IReadOnlyList<TagSample>? Temps { get; init; }
    public TagSample? SteamOp { get; init; }   // WO-3: TICA.OP (스팀, 부분상관 2번째 입력)
    public TagSample? DeltaP  { get; init; }   // WO-6: 탑 차압(플러딩 트리거)
}

STEP 2 — FeedforwardEngine.cs

2.1 ColumnState에 모드/타이머/ARM 추가

전제: WO-5에서 FrontInd가 추가됨.

찾기:

    public FrontPositionIndicator? FrontInd { get; set; }   // WO-5
    public Dictionary<string, StreamState> Streams { get; } = new();

바꾸기:

    public FrontPositionIndicator? FrontInd { get; set; }   // WO-5
    // WO-6 전환류 상태기계
    public ColumnMode Mode { get; set; } = ColumnMode.Normal;
    public double ImbalanceTimerSec { get; set; }
    public double RecoverySettleTimerSec { get; set; }
    public double ReturnTimerSec { get; set; }
    public bool   OperatorArmed { get; set; }   // 컨트롤러가 set
    public bool   OperatorCancel { get; set; }  // 컨트롤러가 set(즉시 Normal)
    public Dictionary<string, StreamState> Streams { get; } = new();

2.2 Tick 배선 — return 직전, 프론트 다음

전제: WO-5 이후 return 영역.

찾기:

        var (frontState, frontTrim) = ApplyFront(cfg, st, ts, temps, transient);   // WO-5 프론트 위치
        return new AdvisoryResult(cfg.Id, cfg.Name, now, cfg.Enabled,
            transient, treason, ff, outs, vloss, yield, mbState)
            { Temps = temps, VLossMa = vLossMa, FrontPositionState = frontState, FrontTrimAdvice = frontTrim };

바꾸기:

        var (frontState, frontTrim) = ApplyFront(cfg, st, ts, temps, transient);   // WO-5 프론트 위치
        var (mode, modeReason, feedRecSp) = ApplyRecovery(
            cfg, pv, st, ts, ff, vLossMa, frontState, transient, ref outs);        // WO-6 전환류 복귀
        return new AdvisoryResult(cfg.Id, cfg.Name, now, cfg.Enabled,
            transient, treason, ff, outs, vloss, yield, mbState)
            { Temps = temps, VLossMa = vLossMa, FrontPositionState = frontState, FrontTrimAdvice = frontTrim,
              Mode = mode, ModeReason = modeReason, FeedRecommendedSp = feedRecSp };

2.3 ApplyRecovery 메서드 추가 (ApplyFront 바로 뒤)

전제: WO-5가 추가한 ApplyFrontreturn (state, trim); + } 로 끝난다.

찾기:

        var (state, trim, _) = st.FrontInd.Update(metric, ts, refTauSec: 1800.0, strongSignal: strong);
        return (state, trim);
    }

바꾸기:

        var (state, trim, _) = st.FrontInd.Update(metric, ts, refTauSec: 1800.0, strongSignal: strong);
        return (state, trim);
    }

    // ── WO-6: 전환류(Total Reflux) 평형복귀 상태기계 (advisory — 권장값 오버라이드만, 쓰기 없음) ──
    private static (ColumnMode mode, string? reason, double? feedRecSp) ApplyRecovery(
        ColumnConfig cfg, PvSnapshot pv, ColumnState st, double ts, double ff,
        double? vLossMa, string? frontState, bool transient, ref List<StreamAdvisory> outs)
    {
        // 기능 off → 항상 Normal(상태 리셋)
        if (!cfg.RecoveryEnabled)
        {
            st.Mode = ColumnMode.Normal; st.ImbalanceTimerSec = 0; st.OperatorArmed = false; st.OperatorCancel = false;
            return (ColumnMode.Normal, null, null);
        }
        // 운전원 수동 취소 → 즉시 Normal
        if (st.OperatorCancel)
        {
            st.OperatorCancel = false; st.OperatorArmed = false;
            st.Mode = ColumnMode.Normal; st.ImbalanceTimerSec = 0; st.RecoverySettleTimerSec = 0; st.ReturnTimerSec = 0;
            return (ColumnMode.Normal, "운전원 취소", null);
        }

        // 다신호 severe 판정 (가용 신호만 OR)
        double frac = (vLossMa.HasValue && ff > 1e-6) ? Math.Abs(vLossMa.Value) / ff : 0.0;
        bool sigVloss = vLossMa.HasValue && frac > cfg.ImbalanceTriggerFrac;
        bool sigFront = frontState is not null && (frontState.Contains("상승") || frontState.Contains("하강"));
        bool sigDp    = pv.DeltaP is { Good: true } dp && Num.IsFinite(dp.Value) && dp.Value > cfg.DeltaPFloodLimit;
        bool severe   = sigVloss || sigFront || sigDp;

        string SeverityText() =>
            (sigVloss ? $"물질수지({frac:P0}) " : "") + (sigFront ? "프론트드리프트 " : "") + (sigDp ? "ΔP플러딩" : "");

        switch (st.Mode)
        {
            case ColumnMode.Normal:
                if (!transient && severe) st.ImbalanceTimerSec += ts; else st.ImbalanceTimerSec = 0;
                bool armed = cfg.RecoveryAutoArm || st.OperatorArmed;
                if (st.ImbalanceTimerSec >= cfg.ImbalanceTriggerSec && armed)
                {
                    st.Mode = ColumnMode.Recovering; st.OperatorArmed = false;
                    st.RecoverySettleTimerSec = 0;
                    return (ColumnMode.Recovering, $"전환류 진입: {SeverityText()}", OverrideRecovering(cfg, ref outs));
                }
                // ARM 대기 표시(자동무장 아님 + 임계 지속)
                if (st.ImbalanceTimerSec >= cfg.ImbalanceTriggerSec)
                    return (ColumnMode.Normal, $"전환류 권장(ARM 대기): {SeverityText()}", null);
                return (ColumnMode.Normal, null, null);

            case ColumnMode.Recovering:
            {
                var feedRec = OverrideRecovering(cfg, ref outs);
                // 평형 회복: severe 해제 + frac < Frac*0.5 연속
                bool recovered = !severe && frac < cfg.ImbalanceTriggerFrac * 0.5;
                if (recovered) st.RecoverySettleTimerSec += ts; else st.RecoverySettleTimerSec = 0;
                if (st.RecoverySettleTimerSec >= cfg.RecoverySettleSec)
                {
                    st.Mode = ColumnMode.Returning; st.ReturnTimerSec = 0;
                    return (ColumnMode.Returning, "평형 회복 — 복귀 램프 시작", null);
                }
                return (ColumnMode.Recovering, $"전환류 평형대기 {st.RecoverySettleTimerSec:F0}/{cfg.RecoverySettleSec:F0}s", feedRec);
            }

            case ColumnMode.Returning:
                st.ReturnTimerSec += ts;
                if (st.ReturnTimerSec >= cfg.ReturnRampSec)
                {
                    st.Mode = ColumnMode.Normal;
                    return (ColumnMode.Normal, "복귀 완료", null);
                }
                // 램프 중엔 정상 권장값 그대로(RateLimiter가 자연 램프) + FEED는 정상 복원 표시(null)
                return (ColumnMode.Returning, $"복귀 램프 {st.ReturnTimerSec:F0}/{cfg.ReturnRampSec:F0}s", null);

            default:
                st.Mode = ColumnMode.Normal;
                return (ColumnMode.Normal, null, null);
        }
    }

    /// <summary>Recovering 권장값 오버라이드: reflux=SpMax(전량), draw(P/D/B)=RecoverySp(NaN→0). FEED 권장 반환.</summary>
    private static double? OverrideRecovering(ColumnConfig cfg, ref List<StreamAdvisory> outs)
    {
        outs = outs.Select(a =>
        {
            // reflux 스트림 식별: IsReflux 또는 RefluxFromProduct
            var sc = cfg.Streams.FirstOrDefault(x => x.Key == a.Key);
            bool isReflux = sc is not null && (sc.IsReflux || sc.RefluxFromProduct);
            double? ov;
            if (isReflux) ov = sc!.SpMax;                                  // 전량 환류
            else if (a.Role == StreamRole.Monitor) ov = a.RecommendedSp;  // 모니터는 그대로
            else ov = (sc is not null && !double.IsNaN(sc.RecoverySp)) ? sc.RecoverySp : 0.0;  // draw 차단
            return a with { RecommendedSp = ov, Valid = false, Note = "전환류 복귀 — 운전원 인가 필요" };
        }).ToList();
        return cfg.FeedRecoverySp;   // FEED 권장(기본 0=차단)
    }

STEP 3 — FeedforwardSupervisor.cs

3.1 ΔP 읽기

찾기:

        if (cfg.SteamOpTag is not null) tags.Add(cfg.SteamOpTag.ToLowerInvariant());  // WO-3 스팀 OP(.op 그대로)

바꾸기:

        if (cfg.SteamOpTag is not null) tags.Add(cfg.SteamOpTag.ToLowerInvariant());  // WO-3 스팀 OP(.op 그대로)
        if (cfg.DeltaPTag is not null)  tags.Add(PvTag(cfg.DeltaPTag));               // WO-6 차압(.pv)

3.2 PvSnapshot에 DeltaP

전제: WO-3에서 return이 { Temps = temps, SteamOp = steam } 형태다.

찾기:

        var steam = cfg.SteamOpTag is not null ? SampleExact(cfg.SteamOpTag) : null;
        return new PvSnapshot(feed, press, levels, streams) { Temps = temps, SteamOp = steam };

바꾸기:

        var steam = cfg.SteamOpTag is not null ? SampleExact(cfg.SteamOpTag) : null;
        var deltaP = cfg.DeltaPTag is not null ? Sample(cfg.DeltaPTag) : null;
        return new PvSnapshot(feed, press, levels, streams) { Temps = temps, SteamOp = steam, DeltaP = deltaP };

3.3 ARM/Cancel 공개 메서드 (클래스 맨 끝, ExecuteAsync 등과 같은 레벨)

전제: _statesprivate readonly Dictionary<int, ColumnState> _states. GetState는 이미 있다.

찾기 (파일에서 GetState 메서드 전체):

    private ColumnState GetState(int id)
    {
        if (!_states.TryGetValue(id, out var s)) { s = new ColumnState(); _states[id] = s; }
        return s;
    }

바꾸기:

    private ColumnState GetState(int id)
    {
        if (!_states.TryGetValue(id, out var s)) { s = new ColumnState(); _states[id] = s; }
        return s;
    }

    // WO-6: 운전원 ARM/취소 (모드 판정용 플래그만 — 쓰기 아님). 다음 Tick에서 소비.
    public bool Arm(int columnId)    { lock (_states) { GetState(columnId).OperatorArmed = true; }  return true; }
    public bool Cancel(int columnId) { lock (_states) { GetState(columnId).OperatorCancel = true; } return true; }

동시성: _states는 평소 Tick 루프(단일 스레드) 소유지만 ARM/Cancel은 HTTP 스레드에서 set한다. bool 단일 대입이라 사실상 안전하나 명시적 lock으로 보호. Tick 측 읽기는 다음 주기에 자연 반영(즉시성 불필요).


STEP 4 — Program.cs : Supervisor를 singleton+hosted로

파일: src/Web/Program.cs

찾기:

builder.Services.AddHostedService<ExperionCrawler.Infrastructure.Control.FeedforwardSupervisor>();

바꾸기:

builder.Services.AddSingleton<ExperionCrawler.Infrastructure.Control.FeedforwardSupervisor>();
builder.Services.AddHostedService(sp => sp.GetRequiredService<ExperionCrawler.Infrastructure.Control.FeedforwardSupervisor>());

단일 인스턴스를 hosted(백그라운드)+injectable(컨트롤러)로 동시 노출. 인스턴스는 1개만 가동(틱 루프 1회).


STEP 5 — FeedforwardController.cs

5.1 Supervisor 주입

찾기:

    private readonly IFeedforwardAdvisoryStore _store;
    private readonly IFeedforwardConfigStore   _config;
    public FeedforwardController(
        IFeedforwardAdvisoryStore store,
        IFeedforwardConfigStore   config)
    { _store = store; _config = config; }

바꾸기:

    private readonly IFeedforwardAdvisoryStore _store;
    private readonly IFeedforwardConfigStore   _config;
    private readonly ExperionCrawler.Infrastructure.Control.FeedforwardSupervisor _supervisor;
    public FeedforwardController(
        IFeedforwardAdvisoryStore store,
        IFeedforwardConfigStore   config,
        ExperionCrawler.Infrastructure.Control.FeedforwardSupervisor supervisor)
    { _store = store; _config = config; _supervisor = supervisor; }

5.2 ARM/Cancel 엔드포인트 (DeleteConfig 메서드 다음)

찾기:

    [HttpDelete("config/{id:int}")]
    public async Task<IActionResult> DeleteConfig(int id, CancellationToken ct)
    {
        await _config.DeleteColumnAsync(id, ct);
        return Ok(new { success = true });
    }

바꾸기:

    [HttpDelete("config/{id:int}")]
    public async Task<IActionResult> DeleteConfig(int id, CancellationToken ct)
    {
        await _config.DeleteColumnAsync(id, ct);
        return Ok(new { success = true });
    }

    // ── WO-6 전환류 ARM/취소 (쓰기 아님 — 모드 판정 플래그) ──
    [HttpPost("recovery/{id:int}/arm")]
    public IActionResult ArmRecovery(int id) => Ok(new { success = _supervisor.Arm(id) });

    [HttpPost("recovery/{id:int}/cancel")]
    public IActionResult CancelRecovery(int id) => Ok(new { success = _supervisor.Cancel(id) });

5.3 MapColumn에 feedRecommendedSp 노출

찾기:

        mode             = r.Mode.ToString(),
        modeReason       = r.ModeReason,
        vLossMa          = r.VLossMa,

바꾸기:

        mode             = r.Mode.ToString(),
        modeReason       = r.ModeReason,
        feedRecommendedSp = r.FeedRecommendedSp,
        vLossMa          = r.VLossMa,

STEP 6 — ff.js : 모드 뱃지 + ARM/취소

파일: src/Web/wwwroot/js/ff.js

6.1 모드 뱃지/버튼 const (front const 다음, return 직전)

전제: WO-5가 const front = ... 를 추가했다.

찾기:

  const front = c.frontPositionState
    ? `<div class="ff-front${c.frontTrimAdvice?' ff-front-warn':''}">프론트: ${esc(c.frontPositionState)}${c.frontTrimAdvice?` → <b>${esc(c.frontTrimAdvice)}</b>`:''}</div>`
    : '';
  return `

바꾸기:

  const front = c.frontPositionState
    ? `<div class="ff-front${c.frontTrimAdvice?' ff-front-warn':''}">프론트: ${esc(c.frontPositionState)}${c.frontTrimAdvice?` → <b>${esc(c.frontTrimAdvice)}</b>`:''}</div>`
    : '';
  const armWait = (c.mode === 'Normal' && c.modeReason && c.modeReason.indexOf('ARM 대기') >= 0);
  const modeBadge =
      c.mode === 'Recovering' ? '<span class="ff-mode ff-mode-rec">전환류 복귀중 ●</span>'
    : c.mode === 'Returning'  ? '<span class="ff-mode ff-mode-ret">복귀 램프 ●</span>'
    : armWait                 ? '<span class="ff-mode ff-mode-arm">전환류 권장 ⚠</span>'
    : '';
  const recoveryCtl =
      armWait                                   ? `<button class="btn sm danger" onclick="ffArm(${c.columnId})">전환류 ARM</button>`
    : (c.mode==='Recovering'||c.mode==='Returning') ? `<button class="btn sm" onclick="ffCancelRecovery(${c.columnId})">취소(정상복귀)</button>`
    : '';
  const modeLine = (modeBadge || c.modeReason)
    ? `<div class="ff-modeline">${modeBadge} <small>${esc(c.modeReason||'')}</small> ${recoveryCtl}</div>` : '';
  return `

6.2 카드 헤더에 ${modeLine} 삽입

찾기:

      <span class="ff-time">${fmtTs(c.computedAt)}</span></div>
    ${banner}

바꾸기:

      <span class="ff-time">${fmtTs(c.computedAt)}</span></div>
    ${modeLine}
    ${banner}

6.3 ARM/Cancel 호출 함수 (ffCard 함수 바로 위 또는 파일 끝에 추가)

찾기:

function ffCard(c) {

바꾸기:

function ffArm(id) {
  if (!confirm(`컬럼 ${id} 전환류 모드를 ARM(가동) 하시겠습니까?\n드로우 중단·전량 환류가 권장됩니다(실제 쓰기는 별도 인가).`)) return;
  ffApi('POST', `/api/ff/recovery/${id}/arm`).then(()=>ffLoadDash()).catch(()=>{});
}
function ffCancelRecovery(id) {
  ffApi('POST', `/api/ff/recovery/${id}/cancel`).then(()=>ffLoadDash()).catch(()=>{});
}
function ffCard(c) {

STEP 7 — ff.css

파일: src/Web/wwwroot/css/ff.css — 맨 끝에 추가:

/* WO-6 전환류 모드 */
.ff-modeline{margin:4px 0;display:flex;align-items:center;gap:8px;flex-wrap:wrap}
.ff-mode{font-size:12px;font-weight:600;padding:2px 8px;border-radius:10px}
.ff-mode-rec{background:#5a3000;color:#ffb74d}
.ff-mode-ret{background:#003a4d;color:#7fd1ff}
.ff-mode-arm{background:#5a0000;color:#ff8a80;animation:ffblink 1s step-start infinite}
@keyframes ffblink{50%{opacity:.4}}

STEP 8 — 신규 테스트 FeedforwardRecoveryTests.cs

신규 파일: tests/ExperionCrawler.Tests/FeedforwardRecoveryTests.cs

using System;
using System.Collections.Generic;
using System.Linq;
using ExperionCrawler.Core.Application.Feedforward;
using ExperionCrawler.Infrastructure.Control;
using Xunit;

namespace ExperionCrawler.Tests;

public class FeedforwardRecoveryTests
{
    // VLossMa 트리거가 빨리 잡히도록 작은 창/짧은 타이머
    private static ColumnConfig Cfg(bool autoArm) => new()
    {
        Id = 1, Name = "C-REC", Enabled = true, FeedTag = "f", ProductKey = "P",
        ScanSec = 2, BiasMaWindowSec = 4,
        RecoveryEnabled = true, RecoveryAutoArm = autoArm,
        ImbalanceTriggerFrac = 0.10, ImbalanceTriggerSec = 4,   // 2틱
        RecoverySettleSec = 4, ReturnRampSec = 4, FeedRecoverySp = 0,
        Streams = new[]
        {
            new StreamConfig { Key="P", FlowTag="p", Role=StreamRole.Commanded,   Grade=Confidence.A, TargetCoeff=0.95, SpMax=950 },
            new StreamConfig { Key="R", FlowTag="r", Role=StreamRole.Commanded,   Grade=Confidence.A, TargetCoeff=0.80, SpMax=1100, RefluxFromProduct=true },
            new StreamConfig { Key="D", FlowTag="d", Role=StreamRole.LevelDriven, Grade=Confidence.B, TargetCoeff=0.02, SpMax=60 },
            new StreamConfig { Key="B", FlowTag="b", Role=StreamRole.LevelDriven, Grade=Confidence.B, TargetCoeff=0.03, SpMax=80 },
        }
    };

    // 큰 V_loss(불균형): FEED 100인데 D+P+B 합이 작음 → vloss 큼
    private static PvSnapshot Imbalanced() => new(
        new TagSample("f", 100, true, DateTime.UtcNow), null, Array.Empty<TagSample>(),
        new Dictionary<string, TagSample> {
            ["P"]=new("p",30,true,DateTime.UtcNow), ["R"]=new("r",50,true,DateTime.UtcNow),
            ["D"]=new("d",2,true,DateTime.UtcNow),  ["B"]=new("b",3,true,DateTime.UtcNow) }); // vloss=100-35=65

    private static PvSnapshot Balanced() => new(
        new TagSample("f", 100, true, DateTime.UtcNow), null, Array.Empty<TagSample>(),
        new Dictionary<string, TagSample> {
            ["P"]=new("p",95,true,DateTime.UtcNow), ["R"]=new("r",760,true,DateTime.UtcNow),
            ["D"]=new("d",2,true,DateTime.UtcNow),  ["B"]=new("b",3,true,DateTime.UtcNow) }); // vloss=0

    [Fact]
    public void AutoArm_enters_recovering_on_sustained_imbalance()
    {
        var engine = new FeedforwardEngine(); var st = new ColumnState();
        AdvisoryResult res = engine.Tick(Cfg(autoArm:true), Imbalanced(), st, DateTime.UtcNow);
        for (int i = 0; i < 6; i++) res = engine.Tick(Cfg(autoArm:true), Imbalanced(), st, DateTime.UtcNow);
        Assert.Equal(ColumnMode.Recovering, res.Mode);
        // 권장값 오버라이드: R(reflux)=SpMax, P/D/B=0, FEED=0
        Assert.Equal(0.0, res.FeedRecommendedSp);
        var r = res.Streams.First(s => s.Key == "R");
        var p = res.Streams.First(s => s.Key == "P");
        Assert.Equal(1100.0, r.RecommendedSp);
        Assert.Equal(0.0, p.RecommendedSp);
        Assert.False(p.Valid);
    }

    [Fact]
    public void ManualArm_required_when_autoArm_false()
    {
        var engine = new FeedforwardEngine(); var st = new ColumnState();
        for (int i = 0; i < 6; i++) engine.Tick(Cfg(autoArm:false), Imbalanced(), st, DateTime.UtcNow);
        Assert.Equal(ColumnMode.Normal, st.Mode);   // ARM 없으면 진입 안 함
        st.OperatorArmed = true;                      // 운전원 ARM
        var res = engine.Tick(Cfg(autoArm:false), Imbalanced(), st, DateTime.UtcNow);
        Assert.Equal(ColumnMode.Recovering, res.Mode);
    }

    [Fact]
    public void Recovers_then_returns_to_normal()
    {
        var engine = new FeedforwardEngine(); var st = new ColumnState();
        for (int i = 0; i < 6; i++) engine.Tick(Cfg(autoArm:true), Imbalanced(), st, DateTime.UtcNow);
        Assert.Equal(ColumnMode.Recovering, st.Mode);
        // 균형 회복 입력 지속 → Returning → Normal
        AdvisoryResult res = null!;
        for (int i = 0; i < 10; i++) res = engine.Tick(Cfg(autoArm:true), Balanced(), st, DateTime.UtcNow);
        Assert.Equal(ColumnMode.Normal, res.Mode);
    }

    [Fact]
    public void Cancel_returns_to_normal_immediately()
    {
        var engine = new FeedforwardEngine(); var st = new ColumnState();
        for (int i = 0; i < 6; i++) engine.Tick(Cfg(autoArm:true), Imbalanced(), st, DateTime.UtcNow);
        Assert.Equal(ColumnMode.Recovering, st.Mode);
        st.OperatorCancel = true;
        var res = engine.Tick(Cfg(autoArm:true), Imbalanced(), st, DateTime.UtcNow);
        Assert.Equal(ColumnMode.Normal, res.Mode);
    }
}

STEP 9 — 검증

dotnet build src/Web/ExperionCrawler.csproj 2>&1 | grep -E "Build succeeded|Warning|Error"
dotnet test tests/ExperionCrawler.Tests/ExperionCrawler.Tests.csproj 2>&1 | grep -E "Passed!|Failed!"
node -c src/Web/wwwroot/js/ff.js && echo "JS OK"
# 쓰기 불변식 — 전환류도 advisory: FF 경로 쓰기 0건
grep -rnE "ExperionOpcWriteClient|Write.*Async|WriteTagAsync" src/Infrastructure/Control src/Web/Controllers/FeedforwardController.cs || echo "WRITE 0건 OK"
# Supervisor 단일 인스턴스 — AddHostedService<FeedforwardSupervisor>() 직접등록 없어야
grep -n "AddHostedService<.*FeedforwardSupervisor>" src/Web/Program.cs || echo "단일 인스턴스 OK"

기대: 빌드 0/0 · 테스트 22/22(WO-5까지 18 + 신규 4) · JS OK · 쓰기 0건 · 단일 인스턴스 OK.

런타임(선택)

  • recovery_enabled=TRUE, recovery_auto_arm=FALSE, imbalance_trigger_frac=0.1, imbalance_trigger_sec=600 설정.
  • 불균형 지속 → 카드에 "전환류 권장 ⚠ [전환류 ARM]" → 클릭 → "전환류 복귀중 ●", R=SpMax·P/D/B=0·FEED=0 권장 → 회복 후 "복귀 램프" → Normal.

감독자 Sign-off

항목 상태 서명
다신호 트리거(VLossMa 프론트 ΔP) 지속+!transient
AutoArm=false면 운전원 ARM 없이 진입 안 함 windpacer 2026-05-31
Recovering 오버라이드(R=SpMax, draw=0, FEED=0, Valid=false) windpacer 2026-05-31
회복→Returning→Normal 전이 windpacer 2026-05-31
운전원 cancel 즉시 Normal windpacer 2026-05-31
쓰기 0건(전환류도 advisory — 실제 쓰기는 PhaseIII) windpacer 2026-05-31
Supervisor 단일 인스턴스(틱 1회) windpacer 2026-05-31
빌드 0/0 · 테스트 22/22 windpacer 2026-05-31

주의(약한 LLM 함정) ★

  1. 실제 SP 쓰기 절대 금지 — Recovering은 StreamAdvisory.RecommendedSp 숫자만 바꾼다(권장 표시). ExperionOpcWriteClient 호출 0건. 실제 차단/환류는 PhaseIII.
  2. 트리거는 VLossMa(장기 MA) — 순간 vloss 쓰지 말 것(오발동). WO-4 선행 필수.
  3. Supervisor DI — STEP 4를 빼먹으면 컨트롤러 주입 실패(런타임 DI 예외). AddHostedService<T>() 직접등록은 제거.
  4. ARM/Cancel은 다음 Tick에 반영 — 즉시 모드 변경 아님(폴링으로 곧 보임). 정상.
  5. positional record 인자추가 금지 — FeedRecommendedSp/DeltaP는 init 프로퍼티.
  6. 테스트 타이머는 작게(ImbalanceTriggerSec=4=2틱) — 실 기본값(600s)으로 테스트하면 안 끝남.