#include "stdafx.h"
|
#include "EQStateMonitor.h"
|
#include "Common.h"
|
#include "CBonder.h"
|
#include "Log.h"
|
|
#define EQSTATE_MAX 200
|
|
CEQStateMonitor::CEQStateMonitor()
|
{
|
m_nBeginAddr = 0;
|
m_bStatusReport = FALSE;
|
m_lastState = EQSTATE::Idle;
|
m_nLastDoorState = 0;
|
}
|
|
|
CEQStateMonitor::~CEQStateMonitor()
|
{
|
|
}
|
|
std::string& CEQStateMonitor::getClassName()
|
{
|
static std::string strClassName = "CEQStateMonitor";
|
return strClassName;
|
}
|
|
void CEQStateMonitor::onRecvBroadcast(void* pSender, CIntent* pIntent)
|
{
|
|
}
|
|
void CEQStateMonitor::onData(int id, const void* pData, int size)
|
{
|
const char* pszData = (const char*)pData;
|
if (m_nIndex + 1 == id) {
|
int addr = m_nBeginAddr * 2;
|
int state = (pszData[addr] & 0xff) | (pszData[addr + 1] & 0xff) << 8;
|
if ((int)m_lastState != state && (state >= 1 && state <= 6)) {
|
LOGI("<CEQStateMonitor-%d>state:%d", m_nIndex, state);
|
ReportStatus(state);
|
}
|
|
int doorState = (pszData[addr + 2] & 0xff) | (pszData[addr + 3] & 0xff) << 8;
|
if (m_nLastDoorState != doorState) {
|
LOGI("<CEQStateMonitor-%d>door state:%d", m_nIndex, doorState);
|
ReportDoorState((int)m_lastState, doorState);
|
}
|
|
}
|
}
|
|
void CEQStateMonitor::enableStatusReport(BOOL bEnable)
|
{
|
m_bStatusReport = bEnable;
|
}
|
|
void CEQStateMonitor::init()
|
{
|
CComponent::init();
|
}
|
|
void CEQStateMonitor::term()
|
{
|
for (auto item : m_eqStates) {
|
item->release();
|
}
|
}
|
|
void CEQStateMonitor::setBeginAddr(int nAddr)
|
{
|
m_nBeginAddr = nAddr;
|
}
|
|
void CEQStateMonitor::OnTimer(UINT nTimerid)
|
{
|
|
}
|
|
void CEQStateMonitor::ReportStatus(int eqst)
|
{
|
BEQ::IUnit* pUnit = m_pBonder->getUnit(m_nIndex);
|
ASSERT(pUnit);
|
pUnit->setState((BEQ::EQ_STATE)(eqst-1));
|
LOGI("<CEQStateMonitor-%d> ¸üÐÂÉ豸״̬(%d).", m_nIndex, eqst);
|
|
CEQState* pState = new CEQState(m_nIndex, (EQSTATE)eqst);
|
AddEQState(pState);
|
SendBroadcast(&CIntent(BC_CODE_EQSTATE_EVENT, "", pState));
|
m_lastState = (EQSTATE)eqst;
|
}
|
|
void CEQStateMonitor::ReportDoorState(int eqst, int doorst)
|
{
|
BEQ::IUnit* pUnit = m_pBonder->getUnit(m_nIndex);
|
ASSERT(pUnit);
|
pUnit->setDoorState(doorst);
|
LOGI("<CEQStateMonitor-%d>¸üа²È«ÃÅ״̬(%d).", m_nIndex, doorst);
|
|
CEQState* pState = new CEQState(m_nIndex, (EQSTATE)eqst);
|
pState->setDoorState(doorst);
|
AddEQState(pState);
|
SendBroadcast(&CIntent(BC_CODE_EQSTATE_EVENT, "", pState));
|
m_nLastDoorState = doorst;
|
}
|
|
void CEQStateMonitor::Serialize(CArchive& ar)
|
{
|
if (ar.IsStoring())
|
{
|
Lock();
|
int count = (int)m_eqStates.size();
|
ar << count;
|
for (auto item : m_eqStates) {
|
item->Serialize(ar);
|
}
|
Unlock();
|
}
|
else
|
{
|
Lock();
|
int count;
|
ar >> count;
|
for (int i = 0; i < count; i++) {
|
CEQState* pState = new CEQState();
|
pState->addRef();
|
pState->Serialize(ar);
|
AddEQState(pState);
|
pState->release();
|
|
}
|
Unlock();
|
}
|
}
|
|
void CEQStateMonitor::AddEQState(CEQState* pEQState)
|
{
|
Lock();
|
pEQState->addRef();
|
m_eqStates.push_back(pEQState);
|
if (m_eqStates.size() > EQSTATE_MAX) {
|
CEQState* pTemp = m_eqStates.front();
|
pTemp->release();
|
m_eqStates.pop_front();
|
}
|
Unlock();
|
}
|
|
void CEQStateMonitor::getEQStateList(std::list<CEQState*>& list)
|
{
|
Lock();
|
list = m_eqStates;
|
Unlock();
|
}
|
