#include "stdafx.h"
#include "CLoadPort.h"


namespace SERVO {
	CLoadPort::CLoadPort() : CEquipment()
	{

	}

	CLoadPort::~CLoadPort()
	{

	}

	const char* CLoadPort::getClassName()
	{
		static char* pszName = "CLoadPort";
		return pszName;
	}

	void CLoadPort::init()
	{
		CEquipment::init();
	}

	void CLoadPort::term()
	{
		CEquipment::term();
	}

	// ±ØÐëҪʵÏÖµÄÐ麯Êý£¬Ôڴ˳õʼ»¯PinÁбí
	void CLoadPort::initPins()
	{
		// ¼ÓÈëPin³õʼ»¯´úÂë
		LOGI("<CLoadPort>initPins");
		addPin(SERVO::PinType::INPUT, _T("In"));
		addPin(SERVO::PinType::OUTPUT, _T("Out1"));
		addPin(SERVO::PinType::OUTPUT, _T("Out2"));
	}

	void CLoadPort::onTimer(UINT nTimerid)
	{
		CEquipment::onTimer(nTimerid);
	}

	void CLoadPort::serialize(CArchive& ar)
	{
		CEquipment::serialize(ar);
	}

	void CLoadPort::getAttributeVector(CAttributeVector& attrubutes)
	{
		__super::getAttributeVector(attrubutes);
	}

	int CLoadPort::recvIntent(CPin* pPin, CIntent* pIntent)
	{
		return __super::recvIntent(pPin, pIntent);
	}

	int CLoadPort::outputGlass(int port)
	{
		// Èç¹ûÁбíÖÐûÓÐPanel,Ä£ÄâÉú³É10ÕÅ
		if (m_glassList.empty()) {
			static int ii = 0;
			char szBuffer[64];
			LOGI("<CLoadPort>Ä£ÄâÉú³É10ÕÅPANEL");
			for (int i = 0; i < 10; i++) {
				sprintf_s(szBuffer, "P20250320A1A%d", ++ii);
				CGlass* pGlass = new CGlass();
				pGlass->setID(szBuffer);
				addGlassToList(pGlass);
			}
		}

		return __super::outputGlass(port);
	}

	BOOL CLoadPort::glassWillArrive(CGlass* pGlass)
	{
		BOOL bRet = __super::glassWillArrive(pGlass);
		if (!bRet) {
			return FALSE;
		}

		return (m_glassList.size() < 8);
	}

	int CLoadPort::sendCassetteCtrlCmd(short cmd,
		short* jobExistence,
		int jobExistenceSize,
		short slotProcess,
		short jopCount,
		CJobDataB* pJobDataB)
	{
		int id = getID();
		if ( !(id == EQ_ID_LOADPORT1 || id == EQ_ID_LOADPORT2) ) {
			return -1;
		}


		SERVO::CEqCassetteCtrlCmdStep* pStep = (SERVO::CEqCassetteCtrlCmdStep*)getCassetteCtrlCmdStep();
		ASSERT(pStep);
		return pStep->sendCtrlCmd(cmd, jobExistence, jobExistenceSize, slotProcess, jopCount, pJobDataB);
	}

	CStep* CLoadPort::getCassetteCtrlCmdStep()
	{
		CStep* pStep = nullptr;
		Lock();
		for (auto item : m_mapStep) {
			if (item.second->getName().find(STEP_EQ_P1_CASSETTE_CTRL_CMD) == 0
				|| item.second->getName().find(STEP_EQ_P2_CASSETTE_CTRL_CMD) == 0
				|| item.second->getName().find(STEP_EQ_P3_CASSETTE_CTRL_CMD) == 0
				|| item.second->getName().find(STEP_EQ_P4_CASSETTE_CTRL_CMD) == 0) {
				pStep = item.second;
			}
		}
		Unlock();

		return pStep;
	}
}