UObject_SK.h

 
// --------------------------------------------------------------------------
/*
 DO NOT EDIT THIS FILE. IT IS AUTOGENERATED FILE.
 ALL YOUR CHANGES WILL BE LOST.
 
 НЕ РЕДАКТИРУЙТЕ ЭТОТ ФАЙЛ. ЭТОТ ФАЙЛ СОЗДАН АВТОМАТИЧЕСКИ.
 ВСЕ ВАШИ ИЗМЕНЕНИЯ БУДУТ ПОТЕРЯНЫ.
*/ 
// --------------------------------------------------------------------------
// generate timestamp: 2023-03-07+03:00
// -----------------------------------------------------------------------------
#ifndef UObject_SK_H_
#define UObject_SK_H_
// -----------------------------------------------------------------------------
#include <memory>
#include <string>
#include <unordered_map>
#include <sstream>
#include "UniSetObject.h"
#include "UniXML.h"
#include "Trigger.h"
#include "DebugStream.h"
#include "LogServer.h"
#include "LogAgregator.h"
#include "VMonitor.h"
// -----------------------------------------------------------------------------
class UObject_SK:
    public uniset::UniSetObject
{
    public:
        UObject_SK( uniset::ObjectId id, xmlNode* node=uniset::uniset_conf()->getNode("UObject"), const std::string& argprefix="", xmlNode* globalConfNode=nullptr );
        UObject_SK();
        virtual ~UObject_SK();
 
        
        long getValue( uniset::ObjectId sid );
        void setValue( uniset::ObjectId sid, long value );
        void askSensor( uniset::ObjectId sid, UniversalIO::UIOCommand, uniset::ObjectId node = uniset::uniset_conf()->getLocalNode() );
 
        virtual uniset::SimpleInfo* getInfo( const char* userparam ) override;
 
        inline std::shared_ptr<DebugStream> log() noexcept { return mylog; }
        inline std::shared_ptr<uniset::LogAgregator> logAgregator() noexcept { return loga; }
 
        void init_dlog( std::shared_ptr<DebugStream> d ) noexcept;
 
        // "синтаксический сахар"..для логов
        #ifndef myinfo 
            #define myinfo if( log()->debugging(Debug::INFO) ) log()->info() 
        #endif
        #ifndef mywarn
            #define mywarn if( log()->debugging(Debug::WARN) ) log()->warn()
        #endif
        #ifndef mycrit
            #define mycrit if( log()->debugging(Debug::CRIT) ) log()->crit()
        #endif
        #ifndef mylog1
            #define mylog1 if( log()->debugging(Debug::LEVEL1) ) log()->level1()
        #endif
        #ifndef mylog2
            #define mylog2 if( log()->debugging(Debug::LEVEL2) ) log()->level2()
        #endif
        #ifndef mylog3
            #define mylog3 if( log()->debugging(Debug::LEVEL3) ) log()->level3()
        #endif
        #ifndef mylog4
            #define mylog4 if( log()->debugging(Debug::LEVEL4) ) log()->level4()
        #endif
        #ifndef mylog5
            #define mylog5 if( log()->debugging(Debug::LEVEL5) ) log()->level5()
        #endif
        #ifndef mylog6
            #define mylog6 if( log()->debugging(Debug::LEVEL6) ) log()->level6()
        #endif
        #ifndef mylog7
            #define mylog7 if( log()->debugging(Debug::LEVEL7) ) log()->level7()
        #endif
        #ifndef mylog8
            #define mylog8 if( log()->debugging(Debug::LEVEL8) ) log()->level8()
        #endif
        #ifndef mylog9
            #define mylog9 if( log()->debugging(Debug::LEVEL9) ) log()->level9()
        #endif
        #ifndef mylogany
            #define mylogany log()->any()
        #endif
        #ifndef vmonit
            #define vmonit( var ) vmon.add( #var, var )
        #endif
    
        inline std::string dumpVars(){ return vmon.pretty_str(); }
        // ------------------------------------------------------------
        std::string help() const noexcept;
 
 
#ifndef DISABLE_REST_API
        // HTTP API
        virtual Poco::JSON::Object::Ptr httpGet( const Poco::URI::QueryParameters& p ) override;
        virtual Poco::JSON::Object::Ptr httpRequest( const std::string& req, const Poco::URI::QueryParameters& p ) override;
        virtual Poco::JSON::Object::Ptr httpHelp( const Poco::URI::QueryParameters& p ) override;
#endif
 
    protected:
 
        virtual void callback() noexcept override;
        virtual void processingMessage( const uniset::VoidMessage* msg ) override;
        virtual void sysCommand( const uniset::SystemMessage* sm ) override {}
        virtual void askSensors( UniversalIO::UIOCommand cmd ) {}
        virtual void sensorInfo( const uniset::SensorMessage* sm ) override {}
        virtual void timerInfo( const uniset::TimerMessage* tm ) override {}
        virtual bool activateObject() override;
        virtual bool deactivateObject() override;
        virtual std::string getMonitInfo() const { return ""; } 
        virtual std::string getTypeOfMessage( int t ) const { return uniset::strTypeOfMessage(t); } 
#ifndef DISABLE_REST_API
        virtual void httpGetUserData( Poco::JSON::Object::Ptr& jdata ){} 
        virtual Poco::JSON::Object::Ptr httpDumpIO();
        virtual Poco::JSON::Object::Ptr httpRequestLog( const Poco::URI::QueryParameters& p );
        virtual Poco::JSON::Object::Ptr request_params_set( const std::string& req, const Poco::URI::QueryParameters& p ) override;
        virtual Poco::JSON::Object::Ptr request_params_get( const std::string& req, const Poco::URI::QueryParameters& p ) override;
#endif
 
        void preAskSensors( UniversalIO::UIOCommand cmd );
        void preSysCommand( const uniset::SystemMessage* sm );
        
 
        bool waitSM( int wait_msec, uniset::ObjectId testID = uniset::DefaultObjectId );
        uniset::ObjectId getSMTestID() const;
 
 
        bool active;
 
        const std::string argprefix;
        uniset::ObjectId smTestID; 
        // управление датчиком "сердцебиения"
        uniset::PassiveTimer ptHeartBeat;               
        uniset::ObjectId idHeartBeat;       
        long maxHeartBeat;                      
        xmlNode* confnode;
        int getIntProp(const std::string& name) { return uniset::uniset_conf()->getIntProp(confnode, name); }
        inline const std::string getProp(const std::string& name) { return uniset::uniset_conf()->getProp(confnode, name); }
 
        uniset::timeout_t smReadyTimeout;   
        std::atomic_bool activated = { false };
        std::atomic_bool canceled = { false };
        uniset::timeout_t activateTimeout;  
        uniset::PassiveTimer ptStartUpTimeout;  
        int askPause; 
        IOController_i::SensorInfo si;
        
        std::shared_ptr<uniset::LogAgregator> loga;
        std::shared_ptr<DebugStream> mylog;
        std::shared_ptr<uniset::LogServer> logserv;
        std::string logserv_host = {""};
        int logserv_port = {0};
 
        uniset::VMonitor vmon;
 
        
 
    private:
 
        // ------------ private функции ---------------
 
        void preSensorInfo( const uniset::SensorMessage* sm );
        void preTimerInfo( const uniset::TimerMessage* tm );
        // --------------------------------------------
        
        class StatHashFn
        {
            public:
            size_t operator() (const uniset::ObjectId& key) const
            {
                return std::hash<long>()(key);
            }
        };
        
        std::unordered_map<const uniset::ObjectId,size_t, StatHashFn> smStat; 
        size_t processingMessageCatchCount = { 0 }; 
        std::unordered_map<long,size_t> msgTypeStat; 
        std::string ostate = { "" }; 
        bool end_private; // вспомогательное поле (для внутреннего использования при генерировании кода)
};
 
// -----------------------------------------------------------------------------
#endif // UObject_SK_H_