From 5cf5e464a5891c8eb62aafadfce0d204fdc79b02 Mon Sep 17 00:00:00 2001
From: mrDarker <mr.darker@163.com>
Date: 星期四, 22 五月 2025 13:50:02 +0800
Subject: [PATCH] 1. 添加机械臂快速测试界面
---
SourceCode/Bond/Servo/CEFEM.cpp | 475 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 474 insertions(+), 1 deletions(-)
diff --git a/SourceCode/Bond/Servo/CEFEM.cpp b/SourceCode/Bond/Servo/CEFEM.cpp
index 4520495..b59945d 100644
--- a/SourceCode/Bond/Servo/CEFEM.cpp
+++ b/SourceCode/Bond/Servo/CEFEM.cpp
@@ -1,5 +1,6 @@
#include "stdafx.h"
#include "CEFEM.h"
+#include "Log.h"
#define ADD_EQ_CASSETTE_TRANSFER_STATE_STEP(name,ws,index,psd) { \
@@ -19,6 +20,8 @@
m_pPort[1] = nullptr;
m_pPort[2] = nullptr;
m_pPort[3] = nullptr;
+ m_pAligner = nullptr;
+ m_pFliper = nullptr;
}
CEFEM::~CEFEM()
@@ -37,6 +40,295 @@
if (index < 4) {
m_pPort[index] = pPort;
}
+ }
+
+ void CEFEM::setAligner(CAligner* pAligner)
+ {
+ m_pAligner = pAligner;
+ }
+
+ void CEFEM::setFliper(CFliper* pFliper)
+ {
+ m_pFliper = pFliper;
+ }
+
+ void CEFEM::setArmTray(unsigned int index, CArmTray* pArmTray)
+ {
+ if (index < 2) {
+ m_pArmTray[index] = pArmTray;
+ }
+ }
+
+ int CEFEM::robotCmd(ROBOT_CMD_PARAM& robotCmdParam, ONWRITED onWritedBlock/* = nullptr*/)
+ {
+ SERVO::CEqWriteStep* pStep = (SERVO::CEqWriteStep*)getStepWithName(STEP_EFEM_ROBOT_CMD);
+ if (pStep == nullptr) {
+ return -1;
+ }
+
+ LOGI("<CEFEM-%s>准备发送RobotCmd<%d>", m_strName.c_str(), (int)robotCmdParam.rcmd);
+ if (onWritedBlock != nullptr) {
+ pStep->writeDataEx((const char*)&robotCmdParam, ROBOT_CMD_PARAM_SIZE, onWritedBlock);
+ }
+ else {
+ pStep->writeDataEx((const char*)&robotCmdParam, ROBOT_CMD_PARAM_SIZE, [&](int code) -> int {
+ if (code == WOK) {
+ LOGI("<CEFEM-%s>发送RobotCmd成功.", m_strName.c_str());
+ }
+ else {
+ LOGI("<CEFEM-%s>发送RobotCmd失败，code:%d", m_strName.c_str(), code);
+ }
+
+ return 0;
+ });
+ }
+
+ return 0;
+ }
+
+ int CEFEM::robotCmds(ROBOT_CMD_PARAM* robotCmdParam, unsigned int count, ONWRITED onWritedBlock/* = nullptr*/)
+ {
+ SERVO::CEqWriteStep* pStep = (SERVO::CEqWriteStep*)getStepWithName(STEP_EFEM_ROBOT_CMD);
+ if (pStep == nullptr) {
+ return -1;
+ }
+
+
+ // 平铺到内存中，如果ROBOT_CMD_PARAM不是4的整数倍，只能一个一个复制
+ std::string strLog = "准备发送RobotCmds<";
+ char szBuffer[ROBOT_CMD_PARAM_SIZE * 4];
+ for (int i = 0; i < min(4, count); i++) {
+ memcpy(&szBuffer[i * ROBOT_CMD_PARAM_SIZE], (robotCmdParam + i), ROBOT_CMD_PARAM_SIZE);
+ strLog += std::to_string((robotCmdParam + i)->rcmd);
+ strLog += ",";
+ LOGI("%d", (robotCmdParam + 1)->rcmd);
+ }
+ strLog += ">.";
+ LOGI("<CEFEM-%s>%s", m_strName.c_str(), strLog.c_str());
+
+
+ if (onWritedBlock != nullptr) {
+ pStep->writeDataEx(szBuffer, ROBOT_CMD_PARAM_SIZE * min(4, count), onWritedBlock);
+ }
+ else {
+ pStep->writeDataEx(szBuffer, ROBOT_CMD_PARAM_SIZE * min(4, count), [&](int code) -> int {
+ if (code == WOK) {
+ LOGI("<CEquipment-%s>发送RobotCmdS成功.", m_strName.c_str());
+ }
+ else {
+ LOGI("<CEquipment-%s>发送RobotCmds失败，code:%d", m_strName.c_str(), code);
+ }
+
+ return 0;
+ });
+ }
+
+ return 0;
+ }
+
+ int CEFEM::SendHome(int seq)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Robot_home);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendTransfer(int seq, int armNo, int fromPos, int toPos, int fromSlot, int toSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Transfer);
+ cmd.armNo = static_cast<short>(armNo);
+ cmd.getPosition = static_cast<short>(fromPos);
+ cmd.getSlotNo = static_cast<short>(fromSlot);
+ cmd.putPosition = static_cast<short>(toPos);
+ cmd.putSlotNo = static_cast<short>(toSlot);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendMoveToGet(int seq, int armNo, int pos, int slot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Move);
+ cmd.armNo = static_cast<short>(armNo);
+ cmd.getPosition = static_cast<short>(pos);
+ cmd.getSlotNo = static_cast<short>(slot);
+ cmd.subCmd = 1;
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendMoveToPut(int seq, int armNo, int pos, int slot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Move);
+ cmd.armNo = static_cast<short>(armNo);
+ cmd.putPosition = static_cast<short>(pos);
+ cmd.putSlotNo = static_cast<short>(slot);
+ cmd.subCmd = 2;
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendGet(int seq, int armNo, int pos, int slot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Get);
+ cmd.armNo = static_cast<short>(armNo);
+ cmd.getPosition = static_cast<short>(pos);
+ cmd.getSlotNo = static_cast<short>(slot);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendPut(int seq, int armNo, int pos, int slot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Put);
+ cmd.armNo = static_cast<short>(armNo);
+ cmd.putPosition = static_cast<short>(pos);
+ cmd.putSlotNo = static_cast<short>(slot);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendExchange(int seq, int armNo, int pos, int getSlot, int putSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::One_Action_Exchange);
+ cmd.armNo = static_cast<short>(armNo);
+ cmd.getPosition = static_cast<short>(pos);
+ cmd.putPosition = static_cast<short>(pos);
+ cmd.getSlotNo = static_cast<short>(getSlot);
+ cmd.putSlotNo = static_cast<short>(putSlot);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendCommandClear(int seq)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Command_Clear);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendBatchGet(int seq, int getPos, int getSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Batch_get);
+ cmd.armNo = ARM_ALL;
+ cmd.getPosition = static_cast<short>(getPos);
+ cmd.getSlotNo = static_cast<short>(getSlot);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendBatchPut(int seq, int putPos, int putSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmd = {};
+ cmd.sequenceNo = static_cast<short>(seq);
+ cmd.rcmd = static_cast<short>(SERVO::RCMD::Batch_put);
+ cmd.armNo = ARM_ALL;
+ cmd.putPosition = static_cast<short>(putPos);
+ cmd.putSlotNo = static_cast<short>(putSlot);
+ return robotCmd(cmd);
+ }
+
+ int CEFEM::SendMoveToGetAndHome(int seq, int armNo, int getPos, int getSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmds[2] = {};
+
+ // Move to Get
+ cmds[0].sequenceNo = static_cast<short>(seq);
+ cmds[0].rcmd = static_cast<short>(SERVO::RCMD::Move);
+ cmds[0].armNo = static_cast<short>(armNo);
+ cmds[0].getPosition = static_cast<short>(getPos);
+ cmds[0].getSlotNo = static_cast<short>(getSlot);
+ cmds[0].subCmd = 1;
+
+ // Home
+ cmds[1].sequenceNo = static_cast<short>(seq + 1);
+ cmds[1].rcmd = static_cast<short>(SERVO::RCMD::Robot_home);
+
+ return robotCmds(cmds, 2);
+ }
+
+ int CEFEM::SendMoveToPutAndHome(int seq, int armNo, int putPos, int putSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmds[2] = {};
+
+ // Move to Put
+ cmds[0].sequenceNo = static_cast<short>(seq);
+ cmds[0].rcmd = static_cast<short>(SERVO::RCMD::Move);
+ cmds[0].armNo = static_cast<short>(armNo);
+ cmds[0].putPosition = static_cast<short>(putPos);
+ cmds[0].putSlotNo = static_cast<short>(putSlot);
+ cmds[0].subCmd = 2;
+
+ // Home
+ cmds[1].sequenceNo = static_cast<short>(seq + 1);
+ cmds[1].rcmd = static_cast<short>(SERVO::RCMD::Robot_home);
+
+ return robotCmds(cmds, 2);
+ }
+
+ int CEFEM::SendTransferAndHome(int seq, int armNo, int fromPos, int toPos, int fromSlot, int toSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmds[2] = {};
+
+ // Transfer
+ cmds[0].sequenceNo = static_cast<short>(seq);
+ cmds[0].rcmd = static_cast<short>(SERVO::RCMD::Transfer);
+ cmds[0].armNo = static_cast<short>(armNo);
+ cmds[0].getPosition = static_cast<short>(fromPos);
+ cmds[0].getSlotNo = static_cast<short>(fromSlot);
+ cmds[0].putPosition = static_cast<short>(toPos);
+ cmds[0].putSlotNo = static_cast<short>(toSlot);
+
+ // Home
+ cmds[1].sequenceNo = static_cast<short>(seq + 1);
+ cmds[1].rcmd = static_cast<short>(SERVO::RCMD::Robot_home);
+
+ return robotCmds(cmds, 2);
+ }
+
+ int CEFEM::SendGetAndPut(int seq, int armNo, int getPos, int getSlot, int putPos, int putSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmds[2] = {};
+
+ cmds[0].sequenceNo = static_cast<short>(seq);
+ cmds[0].rcmd = static_cast<short>(SERVO::RCMD::Get);
+ cmds[0].armNo = static_cast<short>(armNo);
+ cmds[0].getPosition = static_cast<short>(getPos);
+ cmds[0].getSlotNo = static_cast<short>(getSlot);
+
+ cmds[1].sequenceNo = static_cast<short>(seq + 1);
+ cmds[1].rcmd = static_cast<short>(SERVO::RCMD::Put);
+ cmds[1].armNo = static_cast<short>(armNo);
+ cmds[1].putPosition = static_cast<short>(putPos);
+ cmds[1].putSlotNo = static_cast<short>(putSlot);
+
+ return robotCmds(cmds, 2);
+ }
+
+ int CEFEM::SendPutAndHome(int seq, int armNo, int putPos, int putSlot)
+ {
+ SERVO::ROBOT_CMD_PARAM cmds[2] = {};
+
+ // Put
+ cmds[0].sequenceNo = static_cast<short>(seq);
+ cmds[0].rcmd = static_cast<short>(SERVO::RCMD::Put);
+ cmds[0].armNo = static_cast<short>(armNo);
+ cmds[0].putPosition = static_cast<short>(putPos);
+ cmds[0].putSlotNo = static_cast<short>(putSlot);
+
+ // Home
+ cmds[1].sequenceNo = static_cast<short>(seq + 1);
+ cmds[1].rcmd = static_cast<short>(SERVO::RCMD::Robot_home);
+
+ return robotCmds(cmds, 2);
}
void CEFEM::init()
@@ -213,7 +505,6 @@
}
}
-
{
// 请求主配方列表的step
CEqWriteStep* pStep = new CEqWriteStep();
@@ -274,6 +565,100 @@
STEP_ID_PORT4_CASSETTIE_UNLOAD_READY, 0x60b0);
ADD_EQ_CASSETTE_TRANSFER_STATE_STEP(STEP_EQ_P4_CASSETTE_BLOCKED, 0x103,
STEP_ID_PORT4_CASSETTIE_BLOCKED, 0x60b0);
+
+ {
+ // Received Job Report Upstream#1~9
+ char szBuffer[256];
+ for (int i = 0; i < 9; i++) {
+ CEqReadStep* pStep = new CEqReadStep(0x4c90 + 320 * i, 320 * 2,
+ [&](void* pFrom, int code, const char* pszData, size_t size) -> int {
+ if (code == ROK && pszData != nullptr && size > 0) {
+ int port = (int)(__int64)((CEqReadStep*)pFrom)->getProp("Port");
+ if (port > 0) {
+ decodeFetchedOutJobReport((CStep*)pFrom, port, pszData, size);
+ }
+ }
+ return -1;
+ });
+ sprintf_s(szBuffer, "%s%d", STEP_EQ_RECEIVED_JOBn, i + 1);
+ pStep->setName(szBuffer);
+ pStep->setProp("Upstream", (void*)(__int64)(i + 1));
+ pStep->setWriteSignalDev(0x0 + i);
+ if (addStep(STEP_ID_FETCHED_OUT_JOB_REPORT1 + i, pStep) != 0) {
+ delete pStep;
+ }
+ }
+ }
+
+ {
+ // Fetched Out Job Report #1~15
+ char szBuffer[256];
+ for (int i = 0; i < 15; i++) {
+ CEqReadStep* pStep = new CEqReadStep(0x5c31 + 18 * i, 18 * 2,
+ [&](void* pFrom, int code, const char* pszData, size_t size) -> int {
+ if (code == ROK && pszData != nullptr && size > 0) {
+ int port = (int)(__int64)((CEqReadStep*)pFrom)->getProp("Port");
+ if (port > 0) {
+ decodeFetchedOutJobReport((CStep*)pFrom, port, pszData, size);
+ }
+ }
+ return -1;
+ });
+ sprintf_s(szBuffer, "%s%d", STEP_EQ_FETCHED_OUT_JOBn, i+1);
+ pStep->setName(szBuffer);
+ pStep->setProp("Port", (void*)(__int64)(i + 1));
+ pStep->setWriteSignalDev(0x023 + i);
+ if (addStep(STEP_ID_FETCHED_OUT_JOB_REPORT1 + i, pStep) != 0) {
+ delete pStep;
+ }
+ }
+ }
+
+ {
+ // Store Job Report #1~15
+ char szBuffer[256];
+ for (int i = 0; i < 15; i++) {
+ CEqReadStep* pStep = new CEqReadStep(0x5b23 + 18 * i, 18 * 2,
+ [&](void* pFrom, int code, const char* pszData, size_t size) -> int {
+ if (code == ROK && pszData != nullptr && size > 0) {
+ int port = (int)(__int64)((CEqReadStep*)pFrom)->getProp("Port");
+ if (port > 0) {
+ decodeStoredJobReport((CStep*)pFrom, port, pszData, size);
+ }
+ }
+ return -1;
+ });
+ sprintf_s(szBuffer, "%s%d", STEP_EQ_STORED_JOBn, i + 1);
+ pStep->setName(szBuffer);
+ pStep->setProp("Port", (void*)(__int64)(i + 1));
+ pStep->setWriteSignalDev(0x014 + i);
+ if (addStep(STEP_ID_STORE_JOB_REPORT1 + i, pStep) != 0) {
+ delete pStep;
+ }
+ }
+ }
+
+ {
+ // Dispatching Mode Change Command
+ CEqWriteStep* pStep = new CEqWriteStep();
+ pStep->setName(STEP_EQ_DISPATCHINT_MODE_CHANGE);
+ pStep->setWriteSignalDev(0x071);
+ pStep->setDataDev(0x5c6);
+ if (addStep(STEP_ID_DISPATCHING_MODE_CHANGE_REPLY, pStep) != 0) {
+ delete pStep;
+ }
+ }
+
+ {
+ // Robot CMD
+ CEqWriteStep* pStep = new CEqWriteStep();
+ pStep->setName(STEP_EFEM_ROBOT_CMD);
+ pStep->setWriteSignalDev(0x14D);
+ pStep->setDataDev(0x90a);
+ if (addStep(STEP_ID_ROBOT_CMD_REPLY, pStep) != 0) {
+ delete pStep;
+ }
+ }
}
int CEFEM::onStepEvent(CStep* pStep, int code)
@@ -335,4 +720,92 @@
}
}
}
+
+ int CEFEM::onReceivedJob(int port, CJobDataS* pJobDataS)
+ {
+ m_pPort[0]->onReceivedJob(port, pJobDataS);
+ m_pPort[1]->onReceivedJob(port, pJobDataS);
+ m_pPort[2]->onReceivedJob(port, pJobDataS);
+ m_pPort[3]->onReceivedJob(port, pJobDataS);
+ m_pArmTray[0]->onReceivedJob(port, pJobDataS);
+ m_pArmTray[1]->onReceivedJob(port, pJobDataS);
+ m_pAligner->onReceivedJob(port, pJobDataS);
+ m_pFliper->onReceivedJob(port, pJobDataS);
+
+ return 0;
+ }
+
+ int CEFEM::onSentOutJob(int port, CJobDataS* pJobDataS)
+ {
+ m_pPort[0]->onSentOutJob(port, pJobDataS);
+ m_pPort[1]->onSentOutJob(port, pJobDataS);
+ m_pPort[2]->onSentOutJob(port, pJobDataS);
+ m_pPort[3]->onSentOutJob(port, pJobDataS);
+ m_pArmTray[0]->onSentOutJob(port, pJobDataS);
+ m_pArmTray[1]->onSentOutJob(port, pJobDataS);
+ m_pAligner->onSentOutJob(port, pJobDataS);
+ m_pFliper->onSentOutJob(port, pJobDataS);
+
+ return 0;
+ }
+
+ int CEFEM::onFetchedOutJob(int port, CJobDataB* pJobDataB)
+ {
+ if (port == 1) {
+ return m_pPort[0]->onFetchedOutJob(port, pJobDataB);
+ }
+ if (port == 2) {
+ return m_pPort[1]->onFetchedOutJob(port, pJobDataB);
+ }
+ if (port == 3) {
+ return m_pPort[2]->onFetchedOutJob(port, pJobDataB);
+ }
+ if (port == 4) {
+ return m_pPort[3]->onFetchedOutJob(port, pJobDataB);
+ }
+ if (port == 5) {
+ return m_pArmTray[0]->onFetchedOutJob(port, pJobDataB);
+ }
+ if (port == 6) {
+ return m_pArmTray[1]->onFetchedOutJob(port, pJobDataB);
+ }
+ if (port == 7) {
+ return m_pAligner->onFetchedOutJob(port, pJobDataB);
+ }
+ if (port == 8) {
+ return m_pFliper->onFetchedOutJob(port, pJobDataB);
+ }
+
+ return -1;
+ }
+
+ int CEFEM::onStoredJob(int port, CJobDataB* pJobDataB)
+ {
+ if (port == 1) {
+ return m_pPort[0]->onStoredJob(port, pJobDataB);
+ }
+ if (port == 2) {
+ return m_pPort[1]->onStoredJob(port, pJobDataB);
+ }
+ if (port == 3) {
+ return m_pPort[2]->onStoredJob(port, pJobDataB);
+ }
+ if (port == 4) {
+ return m_pPort[3]->onStoredJob(port, pJobDataB);
+ }
+ if (port == 5) {
+ return m_pArmTray[0]->onStoredJob(port, pJobDataB);
+ }
+ if (port == 6) {
+ return m_pArmTray[1]->onStoredJob(port, pJobDataB);
+ }
+ if (port == 7) {
+ return m_pAligner->onStoredJob(port, pJobDataB);
+ }
+ if (port == 8) {
+ return m_pFliper->onStoredJob(port, pJobDataB);
+ }
+
+ return -1;
+ }
}
--
Gitblit v1.9.3