1.使用CEqReadStep替换CEqJobEventStep, 实现ReceivedJob 2.实现SentOutJob

LAPTOP-SNT8I5JK\Boounion

2025-05-12 9fbd7479ce17f76f72cc0e5a675336261ec76472

 SourceCode/Bond/Servo/Model.cpp

@@ -19,6 +19,12 @@

IObservable* CModel::getObservable()
{
   if (m_pObservable == nullptr) {
      m_pObservable = RX_AllocaObservable([&](IObservableEmitter* e) -> void {
         m_pObservableEmitter = e;         // 保存发射器
      });
   }

   return m_pObservable;
}

@@ -53,11 +59,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 +153,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);