#include "stdafx.h"
#include "Common.h"
#include "CEqProcessStep.h"
#include "Log.h"
#include "ToolUnits.h"
#include "CEquipment.h"


namespace SERVO {
	CEqProcessStep::CEqProcessStep() : CReadStep()
	{
		m_nProcessDev = 0;
		m_nTotalParameter = 0;
	}

	CEqProcessStep::~CEqProcessStep()
	{

	}

	void CEqProcessStep::getAttributeVector(CAttributeVector& attrubutes)
	{
		CReadStep::getAttributeVector(attrubutes);

		unsigned int weight = 31;
		attrubutes.addAttribute(new CAttribute("Glass ID",
			m_strGlassId.c_str(), "", weight++));
		attrubutes.addAttribute(new CAttribute("Start Time",
			m_strStartTime.c_str(), "", weight++));
		attrubutes.addAttribute(new CAttribute("End Time",
			m_strEndTime.c_str(), "", weight++));
		attrubutes.addAttribute(new CAttribute("Total Parameter",
			std::to_string(m_nTotalParameter).c_str(), "", weight++));
		attrubutes.addAttribute(new CAttribute("Total Group",
			std::to_string(m_nTotalGroup).c_str(), "", weight++));
		attrubutes.addAttribute(new CAttribute("Current Group",
			std::to_string(m_nCurrentGroup).c_str(), "", weight++));

		char szName[256];
		int index = 0;
		for (auto item : m_params) {
			sprintf_s(szName, 256, "Parameter %d", ++index);
			attrubutes.addAttribute(new CAttribute(szName,
				item.c_str(), "", weight++));
		}
	}

#define PROGRESS_BUF_SIZE		(1024 + 64)
	int CEqProcessStep::onReadData()
	{
		CReadStep::onReadData();

		// W1864 ~ W1A74, 529¸öword, 1058 bytes
		char szBuffer[PROGRESS_BUF_SIZE];
		int nRet = m_pCclink->ReadData2(m_station, DeviceType::W,
			m_nProcessDev, PROGRESS_BUF_SIZE, szBuffer);
		if (0 != nRet) {
			return -1;
		}

		// ½âÊÍÊý¾Ý
		// Glass ID(1864~186D)
		int index = 0;
		convertString(&szBuffer[index], (0x186d - 0x1864 + 1) * 2, m_strGlassId);
		index += (0x186d - 0x1864 + 1) * 2;

		// Process Start Time(186e~1875)
		convertString(&szBuffer[index], (0x1875 - 0x186e + 1) * 2, m_strStartTime);
		index += (0x1875 - 0x186e + 1) * 2;

		// Process End Time(1876~187d)
		convertString(&szBuffer[index], (0x187d - 0x1876 + 1) * 2, m_strEndTime);
		index += (0x187d - 0x1876 + 1) * 2;

		// parameter count
		m_nTotalParameter = (unsigned int)CToolUnits::toInt16(&szBuffer[index]);
		index += 2;

		// total group
		m_nTotalGroup = (unsigned int)CToolUnits::toInt16(&szBuffer[index]);
		index += 2;

		// current group
		m_nCurrentGroup = (unsigned int)CToolUnits::toInt16(&szBuffer[index]);
		index += 2;

		// param list(0x1881~0x1a74), ¹²1000 bytes, 20¸ö×Ö·ûΪһ¸ö²ÎÊý, 50×é
		// ×îºóÒ»group¿ÉÄܲ»Âú×ã50, ÒÔm_nTotalParameterΪÒÀ¾Ý
		int size = (m_nCurrentGroup == m_nTotalGroup) ? m_nTotalParameter % 50 : 50;
		for (int i = 0; i < size; i++) {
			std::string strParam;
			convertString(&szBuffer[index], 20, strParam);
			if (!strParam.empty()) {
				m_params.push_back(strParam);
			}
			index += 20;
		}

		if (m_nCurrentGroup == m_nTotalGroup) {
			ASSERT(m_pEquipment);
			m_pEquipment->onStepEvent(this, STEP_EVENT_PROCESS_DATA);
		}


		LOGI("<CEqProcessStep> Process Data<GlassId:%s>\n",
			m_strGlassId.c_str());

		return 0;
	}

	int CEqProcessStep::onComplete()
	{
		CReadStep::onComplete();
		LOGI("<CEqProcessStep> onComplete.");

		return 0;
	}

	int CEqProcessStep::onTimeout()
	{
		CReadStep::onTimeout();
		LOGE("<CEqProcessStep> onTimeout.");

		return 0;
	}

	void CEqProcessStep::setProcessDev(int nDev)
	{
		m_nProcessDev = nDev;
	}

	std::string& CEqProcessStep::getGlassId()
	{
		return m_strGlassId;
	}

	std::string& CEqProcessStep::getStartTime()
	{
		return m_strStartTime;
	}

	std::string& CEqProcessStep::getEndTime()
	{
		return m_strEndTime;
	}

	unsigned int CEqProcessStep::getTotalParameter()
	{
		return m_nTotalParameter;
	}

	const std::list<std::string> CEqProcessStep::getParameters()
	{
		return m_params;
	}

	void CEqProcessStep::getParameters(std::list<std::string>& list)
	{
		Lock();
		std::copy(m_params.begin(), m_params.end(), std::back_inserter(list));
		Unlock();
	}
}