From b78a202c2933d345e1983de26948dbdae5d72382 Mon Sep 17 00:00:00 2001
From: chenluhua1980 <Chenluhua@qq.com>
Date: 星期四, 12 二月 2026 10:28:06 +0800
Subject: [PATCH] 1.加上限制条件,Port1必须配置Port2, Port3必须配Port4,且是同一ProcessJob

---
 SourceCode/Bond/Servo/CCjPage2.cpp |  355 ++++++++++++++++++++--------------
 SourceCode/Bond/Servo/CCjPage2.h   |    2 
 SourceCode/Bond/Servo/CMaster.cpp  |  222 ++++++++++++++++++++++
 3 files changed, 430 insertions(+), 149 deletions(-)

diff --git a/SourceCode/Bond/Servo/CCjPage2.cpp b/SourceCode/Bond/Servo/CCjPage2.cpp
index 29eea6a..7a79783 100644
--- a/SourceCode/Bond/Servo/CCjPage2.cpp
+++ b/SourceCode/Bond/Servo/CCjPage2.cpp
@@ -14,6 +14,64 @@
     IDC_BUTTON_PORT4_PROCESS_START };
 
 namespace {
+    constexpr int kPortCount = 4;
+    constexpr int kSlotCount = 8;
+
+    int NormalizeMaterial(int material)
+    {
+        return (material == CCarrierSlotGrid::MAT_G2)
+            ? CCarrierSlotGrid::MAT_G2
+            : CCarrierSlotGrid::MAT_G1;
+    }
+
+    void EnsureWarpDefaults(PJWarp& warp)
+    {
+        bool hasSelectedPort = false;
+        for (int p = 0; p < kPortCount; ++p) {
+            if (warp.selectedPorts[p]) {
+                hasSelectedPort = true;
+            }
+            for (int s = 0; s < kSlotCount; ++s) {
+                warp.materialSlots[p][s] = NormalizeMaterial(warp.materialSlots[p][s]);
+            }
+        }
+
+        for (int s = 0; s < kSlotCount; ++s) {
+            warp.material[s] = NormalizeMaterial(warp.material[s]);
+        }
+
+        // Migrate legacy single-port data into multi-port fields.
+        if (!hasSelectedPort && 0 <= warp.port && warp.port < kPortCount) {
+            warp.selectedPorts[warp.port] = TRUE;
+            for (int s = 0; s < kSlotCount; ++s) {
+                warp.checkSlots[warp.port][s] = warp.checkSlot[s];
+                warp.materialSlots[warp.port][s] = NormalizeMaterial(warp.material[s]);
+            }
+        }
+
+        int firstSelectedPort = -1;
+        for (int p = 0; p < kPortCount; ++p) {
+            if (warp.selectedPorts[p]) {
+                firstSelectedPort = p;
+                break;
+            }
+        }
+
+        warp.port = firstSelectedPort;
+        if (firstSelectedPort >= 0) {
+            for (int s = 0; s < kSlotCount; ++s) {
+                warp.checkSlot[s] = warp.checkSlots[firstSelectedPort][s];
+                warp.material[s] = NormalizeMaterial(warp.materialSlots[firstSelectedPort][s]);
+            }
+        }
+        else {
+            for (int s = 0; s < kSlotCount; ++s) {
+                warp.checkSlot[s] = FALSE;
+                warp.material[s] = CCarrierSlotGrid::MAT_G1;
+            }
+        }
+    }
+
     void BuildCassetteCtrlMaps(SERVO::CLoadPort* pPort, short (&jobExistence)[12], short& slotProcess)
     {
         slotProcess = 0;
@@ -185,9 +243,10 @@
 
 int CCjPage2::OnApply() 
 {
-    //SERVO::CProcessJob*
     if (m_pContext == nullptr) return -1;
+
     PJWarp* pPjWarp = (PJWarp*)m_pContext;
+    EnsureWarpDefaults(*pPjWarp);
     SERVO::CProcessJob* pProcessJob = (SERVO::CProcessJob*)pPjWarp->pj;
 
     // 鏇存柊鍚嶇О
@@ -208,7 +267,6 @@
         return -1;
     }
 
-
     pProcessJob->setId(std::string(szBuffer));
 
     // 鏇存柊閰嶆柟
@@ -223,27 +281,45 @@
 #else
         std::string recipe(strRecipe.GetString());
 #endif
-
         pProcessJob->setRecipe(SERVO::RecipeMethod::NoTuning, recipe);
     }
 
-
-    // 鏇存柊Port
-    int port = -1;
     static int ids[] = { IDC_RADIO1, IDC_RADIO2, IDC_RADIO3, IDC_RADIO4 };
-    for (int i = 0; i < 4; i++) {
-        int state = ((CButton*)GetDlgItem(ids[i]))->GetCheck();
-        if (state == BST_CHECKED) port = i;
-    }
-    pPjWarp->port = port;
 
-    if (pPjWarp->port != -1) {
-        for (int i = 0; i < 8; i++) {
-            pPjWarp->checkSlot[i] = m_grid.GetSlotChecked(pPjWarp->port, i);
-            pPjWarp->material[i] = m_grid.GetSlotMaterialType(pPjWarp->port, i);
+    int firstSelectedPort = -1;
+    for (int p = 0; p < kPortCount; ++p) {
+        BOOL selected = (((CButton*)GetDlgItem(ids[p]))->GetCheck() == BST_CHECKED) ? TRUE : FALSE;
+        pPjWarp->selectedPorts[p] = selected;
+        if (selected && firstSelectedPort < 0) {
+            firstSelectedPort = p;
+        }
+
+        for (int s = 0; s < kSlotCount; ++s) {
+            if (selected) {
+                pPjWarp->checkSlots[p][s] = m_grid.GetSlotChecked(p, s);
+                pPjWarp->materialSlots[p][s] = NormalizeMaterial(m_grid.GetSlotMaterialType(p, s));
+            }
+            else {
+                pPjWarp->checkSlots[p][s] = FALSE;
+                pPjWarp->materialSlots[p][s] = CCarrierSlotGrid::MAT_G1;
+            }
         }
     }
 
+    // Keep legacy single-port fields in sync for compatibility.
+    pPjWarp->port = firstSelectedPort;
+    if (firstSelectedPort >= 0) {
+        for (int s = 0; s < kSlotCount; ++s) {
+            pPjWarp->checkSlot[s] = pPjWarp->checkSlots[firstSelectedPort][s];
+            pPjWarp->material[s] = NormalizeMaterial(pPjWarp->materialSlots[firstSelectedPort][s]);
+        }
+    }
+    else {
+        for (int s = 0; s < kSlotCount; ++s) {
+            pPjWarp->checkSlot[s] = FALSE;
+            pPjWarp->material[s] = CCarrierSlotGrid::MAT_G1;
+        }
+    }
 
     ContentChanged(1);
     return 0;
@@ -255,6 +331,13 @@
 
     m_bContentChangedLock = TRUE;
 
+    PJWarp* pPjWarp = (PJWarp*)m_pContext;
+    EnsureWarpDefaults(*pPjWarp);
+
+    for (auto& item : m_pjWarps) {
+        EnsureWarpDefaults(item);
+    }
+
     CComboBox* pComboBox = (CComboBox*)GetDlgItem(IDC_COMBO_RECIPE);
     pComboBox->ResetContent();
     std::vector<std::string> vecRecipe = RecipeManager::getInstance().getAllPPID();
@@ -262,82 +345,47 @@
         pComboBox->AddString(CString(recipe.c_str()));
     }
 
-
-    // ComboBox
-    PJWarp* pPjWarp = (PJWarp*)m_pContext;
     SERVO::CProcessJob* pProcessJob = (SERVO::CProcessJob*)pPjWarp->pj;
     SetDlgItemText(IDC_EDIT_PJ_ID, pProcessJob->id().c_str());
     int idx = pComboBox->FindStringExact(-1, pProcessJob->recipeSpec().c_str());
     if (idx != CB_ERR) pComboBox->SetCurSel(idx);
 
-
-    // 4涓猚heckbox
-    static int ids[] = { IDC_RADIO1, IDC_RADIO2, IDC_RADIO3, IDC_RADIO4};
-    static char* pszUsed[] = { "Port1(宸插崰鐢�)", "Port2(宸插崰鐢�)", "Port3(宸插崰鐢�)", "Port4(宸插崰鐢�)" };
-    static char* pszUnUsed[] = { "Port1(鍙敤)", "Port2(鍙敤)", "Port3(鍙敤)", "Port4(鍙敤)" };
-
-    int portIndex = -1;
-    bool enable[] = {true, true, true, true};
-    bool checked[] = { false, false, false, false };
-    for (auto item : m_pjWarps) {
-        if (0 <= item.port && item.port <= 4 && item.pj != ((PJWarp*)m_pContext)->pj) {
-            enable[item.port] = false;
-        }
-    }
-    if (0 <= ((PJWarp*)m_pContext)->port && ((PJWarp*)m_pContext)->port <= 3) {
-        checked[((PJWarp*)m_pContext)->port] = true;
-        portIndex = ((PJWarp*)m_pContext)->port;
-        m_nSelRadioId = ids[((PJWarp*)m_pContext)->port];
-    }
-
-    for (int i = 0; i < 4; i++) {
-        CButton* pButton = (CButton*)GetDlgItem(ids[i]);
-        pButton->SetCheck(checked[i] ? BST_CHECKED : BST_UNCHECKED);
-        pButton->SetWindowText(enable[i] ? pszUnUsed[i] : pszUsed[i]);
-        pButton->EnableWindow(enable[i]);
-
-        m_grid.SetPortAllocated(i, !checked[i], _T(""));
-        GetDlgItem(btnID[i])->EnableWindow(checked[i]);
-    }
-
-
-    // 璇诲彇鍑虹湡瀹炴暟鎹�
+    // 璇诲彇鐪熷疄鏁版嵁
     auto& master = theApp.m_model.getMaster();
-    int EQID[] = {EQ_ID_LOADPORT1, EQ_ID_LOADPORT2, EQ_ID_LOADPORT3, EQ_ID_LOADPORT4};
-    for (int p = 0; p < 4; p++) {
+    int EQID[] = { EQ_ID_LOADPORT1, EQ_ID_LOADPORT2, EQ_ID_LOADPORT3, EQ_ID_LOADPORT4 };
+    for (int p = 0; p < kPortCount; p++) {
         SERVO::CLoadPort* pPort = (SERVO::CLoadPort*)master.getEquipment(EQID[p]);
-        m_grid.SetPortInfo(p, 
-            (std::string("Port ") + std::to_string(p+1)).c_str(),
-            pPort->getCassetteId().c_str()
-        );
-        for (int i = 0; i < SLOT_MAX; ++i) {
-            SERVO::CSlot* pSlot = pPort->getSlot(i);
-            if (!pSlot) {
-                continue;
-            }
+        m_grid.SetPortInfo(p,
+            (std::string("Port ") + std::to_string(p + 1)).c_str(),
+            pPort->getCassetteId().c_str());
 
-            // 璁剧疆 Panel ID 
+        for (int s = 0; s < SLOT_MAX; ++s) {
+            SERVO::CSlot* pSlot = pPort->getSlot(s);
+            if (!pSlot) continue;
+
             SERVO::CGlass* pGlass = dynamic_cast<SERVO::CGlass*>(pSlot->getContext());
-            SERVO::CJobDataS* pJobDataS = pGlass->getJobDataS();
+            SERVO::CJobDataS* pJobDataS = (pGlass != nullptr) ? pGlass->getJobDataS() : nullptr;
             if (pGlass != nullptr && pJobDataS != nullptr) {
-                m_grid.SetSlotGlass(p, i, TRUE, 
-                    pGlass->getID().c_str(), 
-                    m_pjWarps[p].material[i]);
+                const int mat = (s < kSlotCount)
+                    ? NormalizeMaterial(pPjWarp->materialSlots[p][s])
+                    : CCarrierSlotGrid::MAT_G1;
+                m_grid.SetSlotGlass(p, s, TRUE, pGlass->getID().c_str(), mat);
             }
             else {
-                m_grid.SetSlotGlass(p, i, FALSE, nullptr, CCarrierSlotGrid::MAT_G1);
+                m_grid.SetSlotGlass(p, s, FALSE, nullptr, CCarrierSlotGrid::MAT_G1);
             }
         }
     }
 
-
-    // 璁剧疆鍕鹃�夋暟鎹�
-    if (portIndex != -1) {
-        for (int i = 0; i < 8; i++) {
-            m_grid.SetSlotChecked(portIndex, i, ((PJWarp*)m_pContext)->checkSlot[i]);
+    static int ids[] = { IDC_RADIO1, IDC_RADIO2, IDC_RADIO3, IDC_RADIO4 };
+    for (int p = 0; p < kPortCount; ++p) {
+        ((CButton*)GetDlgItem(ids[p]))->SetCheck(pPjWarp->selectedPorts[p] ? BST_CHECKED : BST_UNCHECKED);
+        for (int s = 0; s < kSlotCount; ++s) {
+            m_grid.SetSlotChecked(p, s, pPjWarp->selectedPorts[p] ? pPjWarp->checkSlots[p][s] : FALSE);
         }
     }
 
+    RefreshPortLocksAndButtons();
     m_bContentChangedLock = FALSE;
 }
 
@@ -351,87 +399,108 @@
     ContentChanged(0);
 }
 
+void CCjPage2::RefreshPortLocksAndButtons()
+{
+    if (m_pContext == nullptr) return;
+
+    PJWarp* pCurrent = (PJWarp*)m_pContext;
+    EnsureWarpDefaults(*pCurrent);
+
+    bool usedByOthers[kPortCount] = { false, false, false, false };
+    for (auto& item : m_pjWarps) {
+        if (item.pj == pCurrent->pj) {
+            continue;
+        }
+        EnsureWarpDefaults(item);
+        for (int p = 0; p < kPortCount; ++p) {
+            if (item.selectedPorts[p]) {
+                usedByOthers[p] = true;
+            }
+        }
+    }
+
+    static int ids[] = { IDC_RADIO1, IDC_RADIO2, IDC_RADIO3, IDC_RADIO4 };
+    static const char* pszUsed[] = { "Port1(宸插崰鐢�)", "Port2(宸插崰鐢�)", "Port3(宸插崰鐢�)", "Port4(宸插崰鐢�)" };
+    static const char* pszUnUsed[] = { "Port1(鍙敤)", "Port2(鍙敤)", "Port3(鍙敤)", "Port4(鍙敤)" };
+
+    for (int p = 0; p < kPortCount; ++p) {
+        CButton* pButton = (CButton*)GetDlgItem(ids[p]);
+        BOOL checked = (pButton->GetCheck() == BST_CHECKED) ? TRUE : FALSE;
+        const bool enable = !usedByOthers[p] || checked;
+
+        pButton->EnableWindow(enable ? TRUE : FALSE);
+        pButton->SetWindowText((enable || checked) ? pszUnUsed[p] : pszUsed[p]);
+
+        if (!enable && !checked) {
+            pButton->SetCheck(BST_UNCHECKED);
+        }
+
+        checked = (pButton->GetCheck() == BST_CHECKED) ? TRUE : FALSE;
+        pCurrent->selectedPorts[p] = checked;
+        m_grid.SetPortAllocated(p, !checked, _T(""));
+        GetDlgItem(btnID[p])->EnableWindow(checked);
+    }
+    // Keep one material type across all selected ports.
+    int syncMat = CCarrierSlotGrid::MAT_G1;
+    bool hasSyncMat = false;
+    for (int p = 0; p < kPortCount && !hasSyncMat; ++p) {
+        if (!pCurrent->selectedPorts[p]) continue;
+        for (int s = 0; s < kSlotCount; ++s) {
+            if (m_grid.GetSlotChecked(p, s)) {
+                syncMat = m_grid.GetSlotMaterialType(p, s);
+                hasSyncMat = true;
+                break;
+            }
+        }
+    }
+    if (!hasSyncMat) {
+        for (int p = 0; p < kPortCount; ++p) {
+            if (!pCurrent->selectedPorts[p]) continue;
+            syncMat = m_grid.GetSlotMaterialType(p, 0);
+            hasSyncMat = true;
+            break;
+        }
+    }
+    SyncMaterialAcrossSelectedPorts(syncMat);
+
+    EnsureWarpDefaults(*pCurrent);
+}
+
+void CCjPage2::SyncMaterialAcrossSelectedPorts(int material)
+{
+    if (m_pContext == nullptr) return;
+
+    const int mat = NormalizeMaterial(material);
+    PJWarp* pCurrent = (PJWarp*)m_pContext;
+    for (int p = 0; p < kPortCount; ++p) {
+        if (!pCurrent->selectedPorts[p]) continue;
+        for (int s = 0; s < kSlotCount; ++s) {
+            m_grid.SetSlotMaterialType(p, s, mat, FALSE);
+        }
+    }
+}
+
 void CCjPage2::OnBnClickedRadio1()
 {
-    BOOL lock[] = {TRUE, TRUE, TRUE, TRUE};
-    if (IDC_RADIO1 == m_nSelRadioId) {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, 0);
-        m_nSelRadioId = 0;
-    }
-    else {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, IDC_RADIO1);
-        m_nSelRadioId = IDC_RADIO1;
-        lock[0] = FALSE;
-    }
-
-    for (int i = 0; i < 4; i++) {
-        m_grid.SetPortAllocated(i, lock[i], _T(""));
-        GetDlgItem(btnID[i])->EnableWindow(!lock[i]);
-    }
-
+    RefreshPortLocksAndButtons();
     ContentChanged(0);
 }
 
 void CCjPage2::OnBnClickedRadio2()
 {
-    BOOL lock[] = { TRUE, TRUE, TRUE, TRUE };
-    if (IDC_RADIO2 == m_nSelRadioId) {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, 0);
-        m_nSelRadioId = 0;
-    }
-    else {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, IDC_RADIO2);
-        m_nSelRadioId = IDC_RADIO2;
-        lock[1] = FALSE;
-    }
-
-    for (int i = 0; i < 4; i++) {
-        m_grid.SetPortAllocated(i, lock[i], _T(""));
-        GetDlgItem(btnID[i])->EnableWindow(!lock[i]);
-    }
-
+    RefreshPortLocksAndButtons();
     ContentChanged(0);
 }
 
 void CCjPage2::OnBnClickedRadio3()
 {
-    BOOL lock[] = { TRUE, TRUE, TRUE, TRUE };
-    if (IDC_RADIO3 == m_nSelRadioId) {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, 0);
-        m_nSelRadioId = 0;
-    }
-    else {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, IDC_RADIO3);
-        m_nSelRadioId = IDC_RADIO3;
-        lock[2] = FALSE;
-    }
-
-    for (int i = 0; i < 4; i++) {
-        m_grid.SetPortAllocated(i, lock[i], _T(""));
-        GetDlgItem(btnID[i])->EnableWindow(!lock[i]);
-    }
-
+    RefreshPortLocksAndButtons();
     ContentChanged(0);
 }
 
 void CCjPage2::OnBnClickedRadio4()
 {
-    BOOL lock[] = { TRUE, TRUE, TRUE, TRUE };
-    if (IDC_RADIO4 == m_nSelRadioId) {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, 0);
-        m_nSelRadioId = 0;
-    }
-    else {
-        CheckRadioButton(IDC_RADIO1, IDC_RADIO4, IDC_RADIO4);
-        m_nSelRadioId = IDC_RADIO4;
-        lock[3] = FALSE;
-    }
-
-    for (int i = 0; i < 4; i++) {
-        m_grid.SetPortAllocated(i, lock[i], _T(""));
-        GetDlgItem(btnID[i])->EnableWindow(!lock[i]);
-    }
-
+    RefreshPortLocksAndButtons();
     ContentChanged(0);
 }
 
@@ -462,22 +531,10 @@
 void CCjPage2::OnGridMatChanged(NMHDR* pNMHDR, LRESULT* pResult)
 {
     auto* nm = reinterpret_cast<CSG_MAT_CHANGE*>(pNMHDR);
-    const int port = nm->port;
-    const int slot = nm->slot;
     const int mat = nm->material; // 1/2
 
-    // 渚嬪锛氬嵆鍒诲埛鏂板彸渚ч瑙�/璁板綍鏃ュ織绛�
+    SyncMaterialAcrossSelectedPorts(mat);
     ContentChanged(0);
-
-    /*
-    if (m_pContext != nullptr) {
-        PJWarp* pjWarp = (PJWarp*)m_pContext;
-        for (int i = 0; i < 8; i++) {
-            pjWarp->checkSlot[i] = m_grid.GetSlotChecked(port, i);
-            pjWarp->material[i] = m_grid.GetSlotMaterialType(port, i);
-        }
-    }
-    */
 
     *pResult = 0;
 }
diff --git a/SourceCode/Bond/Servo/CCjPage2.h b/SourceCode/Bond/Servo/CCjPage2.h
index e9561cd..a49ee7a 100644
--- a/SourceCode/Bond/Servo/CCjPage2.h
+++ b/SourceCode/Bond/Servo/CCjPage2.h
@@ -25,6 +25,8 @@
 
 private:
 	void UpdatePjData();
+	void RefreshPortLocksAndButtons();
+	void SyncMaterialAcrossSelectedPorts(int material);
 
 private:
 	CCarrierSlotGrid m_grid;
diff --git a/SourceCode/Bond/Servo/CMaster.cpp b/SourceCode/Bond/Servo/CMaster.cpp
index 25433ac..c7703e4 100644
--- a/SourceCode/Bond/Servo/CMaster.cpp
+++ b/SourceCode/Bond/Servo/CMaster.cpp
@@ -707,6 +707,91 @@
 					continue;
 				}
 
+				// 鐢熶骇妯″紡鍥哄畾鏄犲皠锛歅ort1/3 -> G1锛孭ort2/4 -> G2銆�
+				auto isProductionPortTypeMatch = [&](int portIndex, MaterialsType type) -> bool {
+					if (m_schedulingMode != SchedulingMode::Production) return true;
+					const bool isG1Port = (portIndex == 0 || portIndex == 2);
+					if (type == MaterialsType::G1) return isG1Port;
+					if (type == MaterialsType::G2) return !isG1Port;
+					return true;
+				};
+
+				// 鐢熶骇妯″紡锛氭牴鎹嚎涓婃湭閰嶅鐜荤拑鍙嶆帹涓嬩竴鐗囧簲鏉ヨ嚜鍝釜绔彛锛圥ort1<->2, Port3<->4锛夈��
+				auto getPreferredPortForType = [&](MaterialsType targetType) -> int {
+					if (m_schedulingMode != SchedulingMode::Production) return -1;
+
+					auto preferG1ByG2 = [&](CGlass* pG2) -> int {
+						if (pG2 == nullptr || pG2->getType() != MaterialsType::G2 || pG2->getBuddy() != nullptr) return -1;
+						int originPort = -1, originSlot = -1;
+						pG2->getOrginPort(originPort, originSlot);
+						if (originPort == 1) return 0; // Port2 -> Port1
+						if (originPort == 3) return 2; // Port4 -> Port3
+						return -1;
+					};
+					auto preferG2ByG1 = [&](CGlass* pG1) -> int {
+						if (pG1 == nullptr || pG1->getType() != MaterialsType::G1 || pG1->getBuddy() != nullptr) return -1;
+						int originPort = -1, originSlot = -1;
+						pG1->getOrginPort(originPort, originSlot);
+						if (originPort == 0) return 1; // Port1 -> Port2
+						if (originPort == 2) return 3; // Port3 -> Port4
+						return -1;
+					};
+
+					if (targetType == MaterialsType::G1) {
+						int p = preferG1ByG2(pBonder1->getGlassFromSlot(1)); if (p >= 0) return p;
+						p = preferG1ByG2(pBonder2->getGlassFromSlot(1)); if (p >= 0) return p;
+						p = preferG1ByG2(pFliper->getGlassFromSlot(1));   if (p >= 0) return p;
+						p = preferG1ByG2(pAligner->getGlassFromSlot(1));  if (p >= 0) return p;
+					}
+					else if (targetType == MaterialsType::G2) {
+						int p = preferG2ByG1(pBonder1->getGlassFromSlot(2)); if (p >= 0) return p;
+						p = preferG2ByG1(pBonder2->getGlassFromSlot(2)); if (p >= 0) return p;
+						p = preferG2ByG1(pVacuumBake->getGlassFromSlot(1)); if (p >= 0) return p;
+						p = preferG2ByG1(pVacuumBake->getGlassFromSlot(2)); if (p >= 0) return p;
+						p = preferG2ByG1(pAligner->getGlassFromSlot(1)); if (p >= 0) return p;
+					}
+
+					return -1;
+				};
+
+				// Job 妯″紡涓嬭姹� Bonder 鍐呯殑 G1/G2 鏉ヨ嚜鍚屼竴涓� ProcessJob銆�
+				auto validateBonderPairProcessJob = [&](CEquipment* pBonder, const char* bonderName) -> bool {
+					if (m_pActiveRobotTask == nullptr) return false;
+					CGlass* pIncomingG1 = (CGlass*)m_pActiveRobotTask->getContext();
+					CGlass* pExistingG2 = pBonder->getGlassFromSlot(0);
+					if (pIncomingG1 == nullptr || pExistingG2 == nullptr) return true;
+
+					CProcessJob* pjG1 = pIncomingG1->getProcessJob();
+					CProcessJob* pjG2 = pExistingG2->getProcessJob();
+					if (m_bJobMode && (pjG1 == nullptr || pjG2 == nullptr || pjG1 != pjG2)) {
+						std::string pj1 = (pjG1 == nullptr) ? "NULL" : pjG1->id();
+						std::string pj2 = (pjG2 == nullptr) ? "NULL" : pjG2->id();
+						LOGW("<Master>%s閰嶅鎷︽埅锛欸1/G2鏉ヨ嚜涓嶅悓ProcessJob(G1=%s,G2=%s)銆�",
+							bonderName, pj1.c_str(), pj2.c_str());
+						delete m_pActiveRobotTask;
+						m_pActiveRobotTask = nullptr;
+						return false;
+					}
+
+					// 鐢熶骇妯″紡鍥哄畾绔彛瀵癸細Port1<->Port2锛孭ort3<->Port4銆�
+					if (m_schedulingMode == SchedulingMode::Production) {
+						int g1Port = 0, g1Slot = 0, g2Port = 0, g2Slot = 0;
+						pIncomingG1->getOrginPort(g1Port, g1Slot);
+						pExistingG2->getOrginPort(g2Port, g2Slot);
+						const bool pairOk =
+							(g1Port == 0 && g2Port == 1) ||
+							(g1Port == 2 && g2Port == 3);
+						if (!pairOk) {
+							LOGW("<Master>%s閰嶅鎷︽埅锛氱鍙e涓嶅尮閰�(瑕佹眰1<->2鎴�3<->4, 瀹為檯G1Port=%d,G2Port=%d)銆�",
+								bonderName, g1Port + 1, g2Port + 1);
+							delete m_pActiveRobotTask;
+							m_pActiveRobotTask = nullptr;
+							return false;
+						}
+					}
+					return true;
+				};
+
 
 				// Bonder1銆丅onder2銆丗liper銆乂acuumBake銆丄ligner锛岀粺璁2鍜孏1鐨勬暟閲�, 閰嶅缁勬暟, 澶氬嚭鐨勭被鍨�
 				int nG2Count = 0, nG1Count = 0, nGlassGroup, nExtraType;
@@ -837,11 +922,17 @@
 				// VacuumBake(G1) -> Bonder
 				if (!rmd.armState[0] && pBonder1->slotHasGlass(0) && !pBonder1->slotHasGlass(1)) {
 					m_pActiveRobotTask = createTransferTask(pVacuumBake, pBonder1, MaterialsType::G1, MaterialsType::G0);
+					if (m_pActiveRobotTask != nullptr && !validateBonderPairProcessJob(pBonder1, "Bonder1")) {
+						// 鍚� PJ 鏍¢獙澶辫触锛屾湰杞笉涓嬪彂鎼��
+					}
 					CHECK_RUN_ACTIVE_ROBOT_TASK(m_pActiveRobotTask);
 				}
 
 				if (!rmd.armState[0] && pBonder2->slotHasGlass(0) && !pBonder2->slotHasGlass(1)) {
 					m_pActiveRobotTask = createTransferTask(pVacuumBake, pBonder2, MaterialsType::G1, MaterialsType::G0);
+					if (m_pActiveRobotTask != nullptr && !validateBonderPairProcessJob(pBonder2, "Bonder2")) {
+						// 鍚� PJ 鏍¢獙澶辫触锛屾湰杞笉涓嬪彂鎼��
+					}
 					CHECK_RUN_ACTIVE_ROBOT_TASK(m_pActiveRobotTask);
 				}
 
@@ -880,14 +971,34 @@
 				else {
 					primaryType = MaterialsType::G1;
 				}
+				const int preferredPortForPrimary = getPreferredPortForType(primaryType);
+				{
+					static int s_prevPrimaryType = -1;
+					static int s_prevPreferredPort = -2;
+					const int curPrimaryType = (int)primaryType;
+					if (s_prevPrimaryType != curPrimaryType || s_prevPreferredPort != preferredPortForPrimary) {
+						LOGI("<Master>LoadPort->Aligner瑙勫垯(RUNNING): primaryType=%d, preferredPort=%d",
+							curPrimaryType, preferredPortForPrimary >= 0 ? (preferredPortForPrimary + 1) : 0);
+						s_prevPrimaryType = curPrimaryType;
+						s_prevPreferredPort = preferredPortForPrimary;
+					}
+				}
 
 				for (int s = 0; s < 4; s++) {
 					PortType pt = pLoadPorts[s]->getPortType();
 					if (!rmd.armState[0] && pLoadPorts[s]->isEnable()
 						&& (pt == PortType::Loading || pt == PortType::Both)
 						&& pLoadPorts[s]->getPortStatus() == PORT_INUSE) {
+						if (!isProductionPortTypeMatch(s, primaryType)) {
+							continue;
+						}
+						if (preferredPortForPrimary >= 0 && s != preferredPortForPrimary) {
+							continue;
+						}
 						m_pActiveRobotTask = createTransferTask(pLoadPorts[s], pAligner, primaryType, secondaryType, 1, m_bJobMode);
 						if (m_pActiveRobotTask != nullptr) {
+							LOGI("<Master>LoadPort->Aligner鍛戒腑(RUNNING): port=%d, primaryType=%d, preferredPort=%d",
+								s + 1, (int)primaryType, preferredPortForPrimary >= 0 ? (preferredPortForPrimary + 1) : 0);
 							CGlass* pGlass = (CGlass*)m_pActiveRobotTask->getContext();
 							if (pGlass->getBuddy() != nullptr) {
 								delete m_pActiveRobotTask;
@@ -969,6 +1080,91 @@
 					unlock(); // 绛夊綋鍓嶄换鍔″畬鎴愭垨涓鍚庣户缁�
 					continue;
 				}
+
+				// 鐢熶骇妯″紡鍥哄畾鏄犲皠锛歅ort1/3 -> G1锛孭ort2/4 -> G2銆�
+				auto isProductionPortTypeMatch = [&](int portIndex, MaterialsType type) -> bool {
+					if (m_schedulingMode != SchedulingMode::Production) return true;
+					const bool isG1Port = (portIndex == 0 || portIndex == 2);
+					if (type == MaterialsType::G1) return isG1Port;
+					if (type == MaterialsType::G2) return !isG1Port;
+					return true;
+				};
+
+				// 鐢熶骇妯″紡锛氭牴鎹嚎涓婃湭閰嶅鐜荤拑鍙嶆帹涓嬩竴鐗囧簲鏉ヨ嚜鍝釜绔彛锛圥ort1<->2, Port3<->4锛夈��
+				auto getPreferredPortForType = [&](MaterialsType targetType) -> int {
+					if (m_schedulingMode != SchedulingMode::Production) return -1;
+
+					auto preferG1ByG2 = [&](CGlass* pG2) -> int {
+						if (pG2 == nullptr || pG2->getType() != MaterialsType::G2 || pG2->getBuddy() != nullptr) return -1;
+						int originPort = -1, originSlot = -1;
+						pG2->getOrginPort(originPort, originSlot);
+						if (originPort == 1) return 0; // Port2 -> Port1
+						if (originPort == 3) return 2; // Port4 -> Port3
+						return -1;
+					};
+					auto preferG2ByG1 = [&](CGlass* pG1) -> int {
+						if (pG1 == nullptr || pG1->getType() != MaterialsType::G1 || pG1->getBuddy() != nullptr) return -1;
+						int originPort = -1, originSlot = -1;
+						pG1->getOrginPort(originPort, originSlot);
+						if (originPort == 0) return 1; // Port1 -> Port2
+						if (originPort == 2) return 3; // Port3 -> Port4
+						return -1;
+					};
+
+					if (targetType == MaterialsType::G1) {
+						int p = preferG1ByG2(pBonder1->getGlassFromSlot(1)); if (p >= 0) return p;
+						p = preferG1ByG2(pBonder2->getGlassFromSlot(1)); if (p >= 0) return p;
+						p = preferG1ByG2(pFliper->getGlassFromSlot(1));   if (p >= 0) return p;
+						p = preferG1ByG2(pAligner->getGlassFromSlot(1));  if (p >= 0) return p;
+					}
+					else if (targetType == MaterialsType::G2) {
+						int p = preferG2ByG1(pBonder1->getGlassFromSlot(2)); if (p >= 0) return p;
+						p = preferG2ByG1(pBonder2->getGlassFromSlot(2)); if (p >= 0) return p;
+						p = preferG2ByG1(pVacuumBake->getGlassFromSlot(1)); if (p >= 0) return p;
+						p = preferG2ByG1(pVacuumBake->getGlassFromSlot(2)); if (p >= 0) return p;
+						p = preferG2ByG1(pAligner->getGlassFromSlot(1)); if (p >= 0) return p;
+					}
+
+					return -1;
+				};
+
+				// Job 妯″紡涓嬭姹� Bonder 鍐呯殑 G1/G2 鏉ヨ嚜鍚屼竴涓� ProcessJob銆�
+				auto validateBonderPairProcessJob = [&](CEquipment* pBonder, const char* bonderName) -> bool {
+					if (m_pActiveRobotTask == nullptr) return false;
+					CGlass* pIncomingG1 = (CGlass*)m_pActiveRobotTask->getContext();
+					CGlass* pExistingG2 = pBonder->getGlassFromSlot(0);
+					if (pIncomingG1 == nullptr || pExistingG2 == nullptr) return true;
+
+					CProcessJob* pjG1 = pIncomingG1->getProcessJob();
+					CProcessJob* pjG2 = pExistingG2->getProcessJob();
+					if (m_bJobMode && (pjG1 == nullptr || pjG2 == nullptr || pjG1 != pjG2)) {
+						std::string pj1 = (pjG1 == nullptr) ? "NULL" : pjG1->id();
+						std::string pj2 = (pjG2 == nullptr) ? "NULL" : pjG2->id();
+						LOGW("<Master>%s閰嶅鎷︽埅锛欸1/G2鏉ヨ嚜涓嶅悓ProcessJob(G1=%s,G2=%s)銆�",
+							bonderName, pj1.c_str(), pj2.c_str());
+						delete m_pActiveRobotTask;
+						m_pActiveRobotTask = nullptr;
+						return false;
+					}
+
+					// 鐢熶骇妯″紡鍥哄畾绔彛瀵癸細Port1<->Port2锛孭ort3<->Port4銆�
+					if (m_schedulingMode == SchedulingMode::Production) {
+						int g1Port = 0, g1Slot = 0, g2Port = 0, g2Slot = 0;
+						pIncomingG1->getOrginPort(g1Port, g1Slot);
+						pExistingG2->getOrginPort(g2Port, g2Slot);
+						const bool pairOk =
+							(g1Port == 0 && g2Port == 1) ||
+							(g1Port == 2 && g2Port == 3);
+						if (!pairOk) {
+							LOGW("<Master>%s閰嶅鎷︽埅锛氱鍙e涓嶅尮閰�(瑕佹眰1<->2鎴�3<->4, 瀹為檯G1Port=%d,G2Port=%d)銆�",
+								bonderName, g1Port + 1, g2Port + 1);
+							delete m_pActiveRobotTask;
+							m_pActiveRobotTask = nullptr;
+							return false;
+						}
+					}
+					return true;
+				};
 
 				// 5.5) 鏆傚仠鐘舵�佹鏌ワ細鑻� CJ 鎴栧湪鍒� PJ 澶勪簬 Paused锛屾殏缂撹皟搴︽柊鐨勬惉閫�
 				bool pausedByEvent = false;
@@ -1098,10 +1294,16 @@
 				// 13) VacuumBake(G1) -> Bonder锛堟Ы绾у垽瀹氾細slot0(G2) 宸叉湁涓� slot1(G1) 涓虹┖锛�
 				if (!rmd.armState[0] && pBonder1->slotHasGlass(0) && !pBonder1->slotHasGlass(1)) {
 					m_pActiveRobotTask = createTransferTask(pVacuumBake, pBonder1, MaterialsType::G1, MaterialsType::G0);
+					if (m_pActiveRobotTask != nullptr && !validateBonderPairProcessJob(pBonder1, "Bonder1")) {
+						// 鍚� PJ 鏍¢獙澶辫触锛屾湰杞笉涓嬪彂鎼��
+					}
 					CHECK_RUN_ACTIVE_ROBOT_TASK(m_pActiveRobotTask);
 				}
 				if (!rmd.armState[0] && pBonder2->slotHasGlass(0) && !pBonder2->slotHasGlass(1)) {
 					m_pActiveRobotTask = createTransferTask(pVacuumBake, pBonder2, MaterialsType::G1, MaterialsType::G0);
+					if (m_pActiveRobotTask != nullptr && !validateBonderPairProcessJob(pBonder2, "Bonder2")) {
+						// 鍚� PJ 鏍¢獙澶辫触锛屾湰杞笉涓嬪彂鎼��
+					}
 					CHECK_RUN_ACTIVE_ROBOT_TASK(m_pActiveRobotTask);
 				}
 
@@ -1123,15 +1325,35 @@
 
 				// 16) LoadPort -> Aligner锛堝彈缁勬暟闂ㄩ檺鎺у埗锛涚粺涓� buddy/鐘舵�佹椂搴忥級
 				if (blockLoadFromLP) { unlock(); continue; }
+				const int preferredPortForPrimary = getPreferredPortForType(primaryType);
+				{
+					static int s_prevPrimaryType = -1;
+					static int s_prevPreferredPort = -2;
+					const int curPrimaryType = (int)primaryType;
+					if (s_prevPrimaryType != curPrimaryType || s_prevPreferredPort != preferredPortForPrimary) {
+						LOGI("<Master>LoadPort->Aligner瑙勫垯(RUNNING_BATCH): primaryType=%d, preferredPort=%d",
+							curPrimaryType, preferredPortForPrimary >= 0 ? (preferredPortForPrimary + 1) : 0);
+						s_prevPrimaryType = curPrimaryType;
+						s_prevPreferredPort = preferredPortForPrimary;
+					}
+				}
 
 				for (int s = 0; s < 4; s++) {
 					PortType pt = pLoadPorts[s]->getPortType();
 					if (!rmd.armState[0] && pLoadPorts[s]->isEnable()
 						&& (pt == PortType::Loading || pt == PortType::Both)
 						&& pLoadPorts[s]->getPortStatus() == PORT_INUSE) {
+						if (!isProductionPortTypeMatch(s, primaryType)) {
+							continue;
+						}
+						if (preferredPortForPrimary >= 0 && s != preferredPortForPrimary) {
+							continue;
+						}
 
 						m_pActiveRobotTask = createTransferTask(pLoadPorts[s], pAligner, primaryType, secondaryType, 1, m_bJobMode);
 						if (m_pActiveRobotTask != nullptr) {
+							LOGI("<Master>LoadPort->Aligner鍛戒腑(RUNNING_BATCH): port=%d, primaryType=%d, preferredPort=%d",
+								s + 1, (int)primaryType, preferredPortForPrimary >= 0 ? (preferredPortForPrimary + 1) : 0);
 							auto* pGlass = static_cast<CGlass*>(m_pActiveRobotTask->getContext());
 							if (pGlass->getBuddy() != nullptr) {
 								delete m_pActiveRobotTask; m_pActiveRobotTask = nullptr;

--
Gitblit v1.9.3