| | |
| | | #include "Model.h" |
| | | #include "Log.h" |
| | | #include "Common.h" |
| | | #include "ToolUnits.h" |
| | | #include "CEqAlarmStep.h" |
| | | #include "AlarmManager.h" |
| | | |
| | | |
| | | CModel::CModel() |
| | |
| | | m_hsmsPassive.setEquipmentModelType((LPTSTR)(LPCTSTR)strModeType); |
| | | m_hsmsPassive.setSoftRev((LPTSTR)(LPCTSTR)strSoftRev); |
| | | 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); |
| | | |
| | | // 处理警告信息 |
| | | if (isAlarmStep(pStep)) { |
| | | // 保存到数据库 |
| | | AlarmManager& alarmManager = AlarmManager::getInstance(); |
| | | std::string strAlarmText; |
| | | SERVO::CEquipment* pEquipment = pStep->getEquipment(); |
| | | SERVO::CEqAlarmStep* pEqAlarmStep = (SERVO::CEqAlarmStep*)pStep; |
| | | const AlarmInfo* pAlarmInfo = alarmManager.getAlarmInfoByID(pEqAlarmStep->getAlarmId()); |
| | | if (pAlarmInfo != nullptr) { |
| | | strAlarmText = pAlarmInfo->strAlarmText; |
| | | } |
| | | int state = pEqAlarmStep->getAlarmState(); |
| | | if (state == 1) { |
| | | AlarmData alarmData; |
| | | alarmData.nId = pEqAlarmStep->getAlarmId(); |
| | | alarmData.nSeverityLevel = pEqAlarmStep->getAlarmLevel(); |
| | | alarmData.nDeviceId = pEqAlarmStep->getEquipment()->getID(); |
| | | alarmData.nUnitId = pEqAlarmStep->getUnitId(); |
| | | alarmData.strDeviceName = alarmManager.getDeviceNameById(alarmData.nDeviceId); |
| | | alarmData.strUnitName = alarmManager.getUnitNameById(alarmData.nDeviceId, alarmData.nUnitId); |
| | | alarmData.strStartTime = CToolUnits::timeToString2(CToolUnits::getTimestamp()); |
| | | alarmData.strEndTime = ""; |
| | | |
| | | const AlarmInfo* alarmInfo = alarmManager.getAlarmInfoByID(alarmData.nId); |
| | | alarmData.strDescription = alarmInfo != nullptr ? alarmInfo->strAlarmText : ""; |
| | | |
| | | int nAlarmEventId = 0; |
| | | bool result = alarmManager.addAlarm(alarmData, nAlarmEventId); |
| | | if (result) { |
| | | LOGI("<CModel> Alarm added successfully!"); |
| | | } |
| | | else { |
| | | LOGE("<CModel> Failed to add alarm."); |
| | | } |
| | | } |
| | | else { |
| | | alarmManager.clearAlarmByAttributes(pEqAlarmStep->getAlarmId(), |
| | | pEqAlarmStep->getEquipment()->getID(), |
| | | pEqAlarmStep->getUnitId(), |
| | | CToolUnits::getCurrentTimeString()); |
| | | } |
| | | |
| | | m_hsmsPassive.requestAlarmReport(pEqAlarmStep->getAlarmState(), |
| | | pEquipment->getBaseAlarmId() + pEqAlarmStep->getAlarmId(), |
| | | strAlarmText.c_str()); |
| | | } |
| | | } |
| | | }; |
| | | |
| | | m_master.setListener(masterListener); |
| | | |
| | | |
| | | // 加载警告信息 |
| | | AlarmManager& alarmManager = AlarmManager::getInstance(); |
| | | char szBuffer[MAX_PATH]; |
| | | sprintf_s(szBuffer, MAX_PATH, "%s\\AlarmList.csv", (LPTSTR)(LPCTSTR)m_strWorkDir); |
| | | alarmManager.readAlarmFile(szBuffer); |
| | | |
| | | |
| | | |
| | | return 0; |
| | |
| | | |
| | | return 0; |
| | | } |
| | | |
| | | bool CModel::isAlarmStep(SERVO::CStep* pStep) |
| | | { |
| | | return CToolUnits::startsWith(pStep->getName(), STEP_ALARM_START); |
| | | } |