From 36fe13023318917dc3fb59b8ce4182920bcaf14d Mon Sep 17 00:00:00 2001
From: choieigun <choieigun@ubisam.com>
Date: Tue, 10 Mar 2026 12:21:50 +0900
Subject: [PATCH] =?UTF-8?q?Can=EC=9D=B4=20=EC=97=86=EC=96=B4=EB=8F=84=20Ce?=
 =?UTF-8?q?llTracker=EC=97=90=EC=84=9C=20=EB=B0=9B=EC=95=84=EC=98=A8=20?=
 =?UTF-8?q?=EB=8D=B0=EC=9D=B4=ED=84=B0=EB=8A=94=20=EA=B3=84=EC=86=8D=20?=
 =?UTF-8?q?=EC=86=8C=EB=B9=84=ED=95=B4=EC=A4=98=EC=95=BC=ED=95=A8=20CellTr?=
 =?UTF-8?q?acker=EB=8A=94=20CanExist=EC=9D=98=20=EC=9C=A0=EB=AC=B4?=
 =?UTF-8?q?=EC=99=80=20=EC=83=81=EA=B4=80=EC=97=86=EC=9D=B4=20=EB=8D=B0?=
 =?UTF-8?q?=EC=9D=B4=ED=84=B0=EB=A5=BC=20=EC=A4=8C=20(=EC=95=9E=EB=8B=A8?=
 =?UTF-8?q?=EC=97=90=EC=84=9C=20=EC=B0=8D=EC=9D=80=20=EB=B0=94=EC=BD=94?=
 =?UTF-8?q?=EB=93=9C=20=EC=A0=95=EB=B3=B4=EC=97=90=20=EB=94=B0=EB=9D=BC=20?=
 =?UTF-8?q?=EB=8D=B0=EC=9D=B4=ED=84=B0=EB=A5=BC=20=EC=A0=84=EB=8B=AC?=
 =?UTF-8?q?=ED=95=B4=EC=A4=8C)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Sequences/ProcessObjects/ProcessManager.cs   | 16 +++++++++++++++-
 .../Sequences/SeqAutoRunCCWH52A.cs               | 15 ++++++++++++---
 2 files changed, 27 insertions(+), 4 deletions(-)

diff --git a/Machines/ILSOS_CCW_H52A/Sequences/ProcessObjects/ProcessManager.cs b/Machines/ILSOS_CCW_H52A/Sequences/ProcessObjects/ProcessManager.cs
index af33138..be0a631 100644
--- a/Machines/ILSOS_CCW_H52A/Sequences/ProcessObjects/ProcessManager.cs
+++ b/Machines/ILSOS_CCW_H52A/Sequences/ProcessObjects/ProcessManager.cs
@@ -75,7 +75,21 @@ namespace ILSOS_CCW_H52A.Sequences.ProcessObjects
             lotId = lotId.Replace("\0", "").Trim();
             cellId = cellId.Replace("\0", "").Trim();
             ReceivedCellInfoQueue.Enqueue((lotId, cellId));
-            _log.I($"Cell Tracker CallBack Received >> [LotId({lotId})] [CellId({cellId})]");
+            _log.I($"Cell Tracker CallBack Received >> [LotId({lotId})] [CellId({cellId})] [QueueCount({ReceivedCellInfoQueue.Count})]");
+        }
+
+        /// <summary>
+        /// 재시작 시 큐 잔류 데이터 전량 폐기.
+        /// CellTracker는 투입 기준으로 선읽음하므로, 정지 시점에 큐에 남은 데이터는
+        /// 이미 처리됐거나 이전 회차의 셀 정보일 수 있어 모두 버린다.
+        /// _pendingPrefetch1/2 는 이미 TryDequeue 이후 저장된 별도 슬롯이므로 영향 없음.
+        /// </summary>
+        public void DrainCellInfoQueue()
+        {
+            int count = 0;
+            while (ReceivedCellInfoQueue.TryDequeue(out _)) count++;
+            if (count > 0)
+                _log.W($"[QueueDrain] 재시작 시 잔류 데이터 {count}건 폐기");
         }
 
         public IEnumerable<bool> CheckRotaryState()
diff --git a/Machines/ILSOS_CCW_H52A/Sequences/SeqAutoRunCCWH52A.cs b/Machines/ILSOS_CCW_H52A/Sequences/SeqAutoRunCCWH52A.cs
index 2b75844..696ecc6 100644
--- a/Machines/ILSOS_CCW_H52A/Sequences/SeqAutoRunCCWH52A.cs
+++ b/Machines/ILSOS_CCW_H52A/Sequences/SeqAutoRunCCWH52A.cs
@@ -450,6 +450,7 @@ namespace ILSOS_CCW_H52A.Sequences
             if (_CellScheduler.HasPendingPrefetch)
                 Log.I("[PendingRestore] 미용접 셀 보존됨 >> 재시작 후 JigNo 매칭 시 복원 예정");
             _CellScheduler.Reset();
+            ProcessManager.Instance.DrainCellInfoQueue();
 
             // 정지 전 미저장 APD 잔존 데이터 클리어 — 재시작 시 중복 누적 방지
             Status.GetProcessingWeldingData().APD.Clear();
@@ -761,10 +762,18 @@ namespace ILSOS_CCW_H52A.Sequences
                     Log.W($"[PendingRestore] Jig{_WeldingJigNo} canExist=false, 복원 데이터 폐기 >> CellId({rCell})");
                 }
             }
-            else if (canExist && ProcessManager.Instance.ReceivedCellInfoQueue.TryDequeue(out var cell)) {
-                recvInfo.LotId = cell.LotId;
-                recvInfo.CellId = cell.CellId;
+            else if (ProcessManager.Instance.ReceivedCellInfoQueue.TryDequeue(out var cell)) {
+                if (canExist) {
+                    recvInfo.LotId = cell.LotId;
+                    recvInfo.CellId = cell.CellId;
+                } else {
+                    // 앞공정 NG 셀: CellTracker는 투입 시 이미 스캔했으므로 큐에서 소비 후 폐기.
+                    // 소비하지 않으면 다음 정상 셀이 이 NG 데이터를 가져가 정합성 붕괴.
+                    Log.W($"[NG Skip] Jig{_WeldingJigNo} canExist=false, 큐 데이터 폐기 >> CellId({cell.CellId})");
+                }
             } else {
+                if (canExist)
+                    Log.E($"[QueueEmpty] Jig{_WeldingJigNo} canExist=true 이지만 큐가 비어있음");
                 _CellTracker.getDummyData(out string lotId, out string cellId);
                 recvInfo.LotId = lotId;
                 recvInfo.CellId = cellId;