mrDarker
2025-05-22 5cf5e464a5891c8eb62aafadfce0d204fdc79b02
SourceCode/Bond/Servo/Model.cpp
@@ -5,6 +5,7 @@
#include "ToolUnits.h"
#include "CEqAlarmStep.h"
#include "AlarmManager.h"
#include "CGlassPool.h"
CModel::CModel()
@@ -19,6 +20,12 @@
IObservable* CModel::getObservable()
{
   if (m_pObservable == nullptr) {
      m_pObservable = RX_AllocaObservable([&](IObservableEmitter* e) -> void {
         m_pObservableEmitter = e;         // 保存发射器
      });
   }
   return m_pObservable;
}
@@ -40,6 +47,9 @@
   CString strSoftRev = _T("1.0.2");
   // CGlassPool
   m_glassPool.initPool();
   // Log
   CString strLogDir;
@@ -53,11 +63,6 @@
   CLog::GetLog()->SetLogsDir(strLogDir);
   CLog::GetLog()->SetEquipmentId((LPTSTR)(LPCTSTR)strUnitId);
   LOGI("\r\n\r\n~~~ Prog Start! ~~~");
   m_pObservable = RX_AllocaObservable([&](IObservableEmitter* e) -> void {
      m_pObservableEmitter = e;         // 保存发射器
   });
   SECSListener listener;
@@ -152,6 +157,10 @@
   masterListener.onEqVcrEventReport = [&](void* pMaster, SERVO::CEquipment* pEquipment, SERVO::CVcrEventReport* pReport) {
      LOGE("<CModel>onEqVcrEventReport.");
   };
   masterListener.onEqDataChanged = [&](void* pMaster, SERVO::CEquipment* pEquipment, int code) {
      LOGE("<CModel>onEqDataChanged.");
      notifyPtr(RX_CODE_EQ_DATA_CHANGED, pEquipment);
   };
   m_master.setListener(masterListener);
@@ -177,6 +186,7 @@
   m_hsmsPassive.term();
   CLog::GetLog()->SetOnLogCallback(nullptr);
   m_master.term();
   m_glassPool.term();
   return 0;
}