| | |
| | | listener.onEQOnLine = [&](void* pFrom) -> void { |
| | | LOGI("远程请求OnLine"); |
| | | }; |
| | | listener.onCommand = [&](void* pFrom, const char* pszName, std::vector<CommandParameter>& params) -> void { |
| | | LOGI("onCommand:%s", pszName); |
| | | for (auto& item : params) { |
| | | LOGI("param:%s,%s", item.szName, item.szValue); |
| | | } |
| | | }; |
| | | listener.onEQConstantRequest = [&](void* pFrom, std::vector<EQConstant>& eqcs) -> void { |
| | | // 在此填充常量值,目前仅是加1后返回 |
| | | for (auto& item : eqcs) { |
| | |
| | | m_hsmsPassive.init(this, "APP", 7000); |
| | | |
| | | |
| | | SERVO::MasterListener masterListener; |
| | | masterListener.onEqAlive = [&](void* pMaster, SERVO::CEquipment* pEquipment, BOOL bAlive) -> void { |
| | | LOGI("<CModel>Equipment onAlive:%s(%s).\n", pEquipment->getName().c_str(), |
| | | bAlive ? _T("ON") : _T("OFF")); |
| | | notifyPtr(RX_CODE_EQ_ALIVE, pEquipment); |
| | | |
| | | }; |
| | | masterListener.onEqCimStateChanged = [&](void* pMaster, SERVO::CEquipment* pEquipment, BOOL bOn) -> void { |
| | | LOGI("<CModel>Equipment Cim State:%s(%s).\n", pEquipment->getName().c_str(), |
| | | bOn ? _T("ON") : _T("OFF")); |
| | | notifyPtr(RX_CODE_EQ_ALIVE, pEquipment); |
| | | |
| | | }; |
| | | masterListener.onEqStepEvent = [&](SERVO::CStep* pStep, int code, void* pData) -> void { |
| | | if (code == STEP_EVENT_READDATA) { |
| | | LOGI("<CModel>onEqStepEvent,数据变化:%s(%s, 0x%x).\n", pStep->getEquipment()->getName().c_str(), |
| | | pStep->getName().c_str(), pData); |
| | | notifyPtr(RX_CODE_STEP_EVENT_READDATA, pStep); |
| | | |
| | | } |
| | | }; |
| | | |
| | | m_master.setListener(masterListener); |
| | | |
| | | return 0; |
| | | } |
| | | |
| | |
| | | { |
| | | m_hsmsPassive.term(); |
| | | CLog::GetLog()->SetOnLogCallback(nullptr); |
| | | m_master.term(); |
| | | |
| | | return 0; |
| | | } |
| | | |