1.部分实现状态变量设置

chenluhua1980

2026-01-08 f6cd6b95c9aa2ad17b199c32553c0b5e06b60bea

1.部分实现状态变量设置

 SourceCode/Bond/Servo/Model.cpp

@@ -31,6 +31,18 @@
    m_hsmsPassive.setVariableValue("PJobSpace", (__int64)(m_master.isProcessJobsEmpty() ? 1 : 0));
}

void CModel::setControlState(ControlState newState)
{
    const auto prev = m_currentControlState;
    if (newState != m_currentControlState) {
        m_hsmsPassive.setVariableValue("PreviousControlState", (__int64)static_cast<uint8_t>(prev));
        m_currentControlState = newState;
    }

    // Always keep SV in sync (even if state didn't change or variables were just loaded).
    m_hsmsPassive.setVariableValue("CurrentControlState", (__int64)static_cast<uint8_t>(m_currentControlState));
}

IObservable* CModel::getObservable()
{
    if (m_pObservable == nullptr) {
@@ -117,16 +129,31 @@


    SECSListener listener;
    listener.onEQOffLine = [&](void* pFrom) -> void {
    listener.onEQOffLine = [this](void* pFrom) -> void {
        LOGI("远程请求OffLine");
        (void)pFrom;
        setControlState(ControlState::OfflineHost);
    };
    listener.onEQOnLine = [&](void* pFrom) -> void {
    listener.onEQOnLine = [this](void* pFrom) -> void {
        LOGI("远程请求OnLine");
        (void)pFrom;
        // Customer flow: S1F17 RequestOnline defaults to OnlineRemote.
        setControlState(ControlState::OnlineRemote);
    };
    listener.onCommand = [&](void* pFrom, const char* pszName, std::vector<CommandParameter>& params) -> void {
    listener.onCommand = [this](void* pFrom, const char* pszName, std::vector<CommandParameter>& params) -> void {
        LOGI("onCommand:%s", pszName);
        (void)pFrom;
        for (auto& item : params) {
            LOGI("param:%s,%s", item.szName, item.szValue);
        }

        if (pszName == nullptr) return;
        // S2F41 GoLocal / GoRemote (RCMD)
        if (_strcmpi(pszName, "GoLocal") == 0 || _strcmpi(pszName, "LOCAL") == 0 || _strcmpi(pszName, "GoLOCAL") == 0) {
            setControlState(ControlState::OnlineLocal);
        }
        else if (_strcmpi(pszName, "GoRemote") == 0 || _strcmpi(pszName, "REMOTE") == 0 || _strcmpi(pszName, "GoREMOTE") == 0) {
            setControlState(ControlState::OnlineRemote);
        }
    };
    listener.onEQConstantRequest = [&](void* pFrom, std::vector<EQConstant>& eqcs) -> void {
@@ -253,6 +280,7 @@
    CString strVarialbleFile;
    strVarialbleFile.Format(_T("%s\\VariableList.txt"), (LPTSTR)(LPCTSTR)m_strWorkDir);
    m_hsmsPassive.loadVarialbles((LPTSTR)(LPCTSTR)strVarialbleFile);
    setControlState(m_currentControlState);
    refreshDerivedSVs();
    m_hsmsPassive.init(this, "APP", 7000);
    strVarialbleFile.Format(_T("%s\\ReportList.txt"), (LPTSTR)(LPCTSTR)m_strWorkDir);

 SourceCode/Bond/Servo/Model.h

@@ -3,6 +3,16 @@
#include "HsmsPassive.h"
#include "CMaster.h"
#include "CGlassPool.h"
#include <cstdint>

enum class ControlState : uint8_t {
    OfflineEquipment = 0,
    OfflineAttempt = 1,
    Online = 2,
    OfflineHost = 3,
    OnlineLocal = 4,
    OnlineRemote = 5,
};

class CModel
{
@@ -23,6 +33,7 @@

private:
    void refreshDerivedSVs();
    void setControlState(ControlState newState);

public:
    int notify(int code);
@@ -49,5 +60,7 @@
    IObservableEmitter* m_pObservableEmitter;
    CString m_strWorkDir;
    CString m_strDataDir;
};

private:
    ControlState m_currentControlState{ ControlState::OfflineEquipment };
};