#pragma once #include #include "IODeviceWithSCF.tlh" #include "IODeviceWithSCF.tli" #include "CCOS.Dev.IODevice.Detail.hpp" #include "CCOS.Dev.MSGMould.hpp" #include "CCOS.Dev.Generator.Mould.hpp" //#include "DAP.BasicMoulds.hpp" #include "DeliverModule.h" #ifdef CCOSDEVGENPSGHR_EXPORTS #define _CCOSDEVGENPSGHR_API __declspec(dllexport) #else #define _CCOSDEVGENPSGHR_API __declspec(dllimport) #endif enum PSG_HR_REGULATION_LEVEL { //故障等级 REG_ERRO, REG_WARN }; enum PSG_HR_CHARGE_STATE { //电池状态 POWER_LOW, POWER_NOR }; #define PSGHR_Com_ReSendLen 32 namespace nsSerialGPM = CCOS::Dev::MODLE::SerialGPM; namespace CCOS::Dev::Detail::Generator { using cbFun = std::function ; //struct tFrameMapItem //{ // //static HANDLE m_hBeginReSendEvent; //设置开始重发事件 // ////static HANDLE m_hStopReSendEvent; //设置停止重发事件 // //static mutex m_mtxWaitACK; //读写锁 // //static vector m_dWaitACKVector; //等待ACK的指令队列 // // // cbFun m_fFun; //处理函数 // //mutex m_mtxCMDRW; //读写锁 // //int m_nReSendCount{ 0 }; //重试计数 // //char m_strCMD[PSGHR_Com_ReSendLen]{ 0 }; //指令内容 // //int m_nCMDLengh{ 0 }; //指令长度 // // // tFrameMapItem(); // tFrameMapItem(cbFun f); // tFrameMapItem& operator =(const tFrameMapItem& value); // //void tChangeWaitState(int status, const char* cmd, int lengh = 0); //}; static const int TIMEOUTVALUE = 100; /*暂不使用 using JSONString = std::string; namespace DevDAP = CCOS::Dev::Detail::DAP; */ //----------------------------------------------------------------------------- // PSGHRDevice //----------------------------------------------------------------------------- class _CCOSDEVGENPSGHR_API PSGHRDevice : public IODeviceWithSCF ,public GeneratorMould { using super = IODeviceWithSCF ; using superGen = GeneratorMould; public: PSGHRDevice (std::shared_ptr center, nsSCF::SCF SCF, string configfile); ~PSGHRDevice (); //发生器支持的通用命令 virtual std::string GetGUID() const override; virtual RET_STATUS IncKV() override; virtual RET_STATUS DecKV() override; virtual RET_STATUS SetKV(float value) override; virtual RET_STATUS IncMA() override; virtual RET_STATUS DecMA() override; virtual RET_STATUS SetMA(float value) override; virtual RET_STATUS IncMS() override; virtual RET_STATUS DecMS() override; virtual RET_STATUS SetMS(float value) override; virtual RET_STATUS IncMAS() override; virtual RET_STATUS DecMAS() override; virtual RET_STATUS SetMAS(float value) override; virtual RET_STATUS SetTechmode(int value) override; virtual RET_STATUS SetEXAMMode(std::string value) override; virtual RET_STATUS SetFocus(int value) override; virtual RET_STATUS SetAPR(const _tAPRArgs& t) override; virtual RET_STATUS QueryHE(int& value) override; virtual RET_STATUS QueryPostKV(float& value) override; virtual RET_STATUS QueryPostMA(float& value) override; virtual RET_STATUS QueryPostMS(float& value) override; virtual RET_STATUS QueryPostMAS(float& value) override; virtual RET_STATUS SetExpEnable() override; virtual RET_STATUS SetExpDisable()override; virtual RET_STATUS Reset()override; virtual RET_STATUS ActiveSyncMode(_tSyncModeArgs value) override; RET_STATUS RefreshData(); RET_STATUS SetRPS(int rps);//设置连续点片帧率,暂不使用 /********************透视命令****************************/ virtual RET_STATUS SetAPF(const _tAPFArgs& t) override; virtual RET_STATUS IncFluKV() override; virtual RET_STATUS DecFluKV() override; virtual RET_STATUS SetFluKV(float value) override; virtual RET_STATUS IncFluMA() override; virtual RET_STATUS DecFluMA() override; virtual RET_STATUS SetFluMA(float value) override; virtual RET_STATUS INCPPS() override; virtual RET_STATUS DECPPS() override; virtual RET_STATUS SetPPS(float value) override; virtual RET_STATUS SetABSMode(int nMode) override; virtual RET_STATUS SetABSCurve(int curveNum) override; virtual RET_STATUS IncABSCurve() override; virtual RET_STATUS DecABSCurve() override; virtual RET_STATUS GetABSCurve(); virtual float GetFluIntTimer() override; virtual float GetFluAccTimer() override; virtual RET_STATUS ResetFluTimer(int ntype) override; virtual RET_STATUS SetFluPre(int value) override; virtual RET_STATUS SetFluEXP(int value) override; virtual RET_STATUS SetFluMode(std::string value); virtual RET_STATUS SetFluDoseLever(int value) override; virtual RET_STATUS SetPluseWidth(float fplusewidth) override; virtual RET_STATUS SetAECDensity(int value) override; virtual RET_STATUS SetAECField(int value) override; virtual RET_STATUS SetAECFilm(int value) override; virtual RET_STATUS SetWS(const std::string value) override; virtual RET_STATUS SetGenSynState(int value) override; virtual RET_STATUS SetGenState(int value) override; virtual RET_STATUS SetExpMode(std::string value) override; virtual RET_STATUS SetFrameRate(FLOAT frameRate) override; virtual RET_STATUS SetFLFMode(std::string value) override; virtual RET_STATUS SetFLLever(FLOAT value); bool EnableBucky(int nbucky); bool ECHO(void); bool SetABSModeNative(int nMode); RET_STATUS Clear_DAP(); RET_STATUS GetValue_DAP(float& value); RET_STATUS StartMove(); RET_STATUS EndMove(); //V3新方法 virtual void SubscribeSelf(ccos_mqtt_connection* conn) override; RET_STATUS SetVibrationGrid(int value); RET_STATUS GetVibrationGridMS(int &value); void SetSmartAEC(int value); //智能AEC bool ReConnect(); //重连 int GridMSMargin(); //返回震动栅MS的余量 bool CalculateAppropriateMA(float& inoutMAS, float& inoutMA, float& inoutMS); //计算震动栅模式下恰当的MA void ReSendFailedAction(string &cmdNum); //重发失败后返回消息 int GetGenState(); int LoadConfig(string configfile); public: ResDataObject m_GenConfig; //driver's config file. //线程变量互斥锁 //atomic m_iReSendCMD; //初始命令重发次数 static atomic m_iLoopTime; //循环间隔时间（毫秒） atomic m_iCompPostMAS; //计算PostMAS条件统计 atomic m_iHeartBeats; //心跳统计 atomic m_bConnectFlag; //连接标记 bool m_bAECCtlSignal; //在曝光设置更新期间,AEC控制信号必须处于低状态 atomic m_iVibrationGridState; //震动栅模式(0,1) int m_iGridMSRadMargin; //震动栅ms手动曝光误差(500-2000ms) int m_iGridMSAECMargin; //震动栅ms自动曝光误差(500-2000ms) static atomic m_bExtraFlag; //使用标记 bool m_bGenBusy; bool m_bReturnFlag; float m_fPreMA; float m_fPreMS; float m_fPreMAS; int m_nPreET; int m_nAECMode;//0 fix 1 mas 2 ms bool m_bSaveMSMA;//根据用途来看，其实是表示 是否处于setapr期间 float m_PrefMS; float m_fMsLimit; bool m_bInExpState; //用来表示是否处于曝光状态，因为处于exp状态时，仅有几组指令可以发。 int m_nCtlMode; bool m_bCheckATUStatus;// bool m_bDAPEnable; bool m_bUseCECmd; bool m_bIsConfigLoaded; //串口处理层 static nsSerialGPM::CDeliverModule m_tDelivermodule; int m_nCMDType_WaitTime{ 0 }; int m_nCMDType_HB{ 0 }; int m_nCMDType_WaitACK{ 0 }; static void __stdcall ProcessClientData(const char* pData, unsigned long DataLength, void* lparam); static void __stdcall WriteLog(const char* pData, nsSerialGPM::LOG_V2_LEVEL level); RET_STATUS HWSendWaittimeCMD(char* strCommand, int lengh, int headLengh = 3); RET_STATUS HWSendHBCMD(char* strCommand, int lengh, int headLengh = 3); RET_STATUS HWSendWaitACKCMD(char* strCommand, int lengh, int headLengh = 3); private: //std::unique_ptr m_DAP; //暂不使用 std::unique_ptr m_MSGUnit; //处理消息上报对象指针 HANDLE m_pHardwareStatusThread; //轮询线程句柄 HANDLE m_pHardwareRsSendThread; //重发线程句柄 HANDLE m_hGenPostEvent; atomic m_bExpEnable; //曝光使能 atomic m_bInvalidKVMASSetupFlag; //写入到设备的曝光设置无效 atomic m_bFaultList[18]; //记录 主机请求固件报告故障命令 返回的故障记录 int m_iMaxPower; //最大功率:kV*mA int MaxHeatContent; //最阳极热容积:kV*mAs bool m_bMAS_MA_AEC; enum MyEnum { EXPOSURE_SOFTWARE_HARDWARE, //0 EXPOSURE_NOSYNBOX_DIRCETCONNECT_DETECTOR_GEN, //1 EXPOSURE_SOFTWARE_NOSYNBOX //2 }; private: RET_STATUS HWSend(const char* strCommand, int lengh, bool reSend = false, int nTimeOut = TIMEOUTVALUE); //指令发送接口 void OnCallBack(); //处理指令回调函数 void Register(); //注册对外提供的属性、方法 bool StartHardwareStatusThread(); //启动轮询线程 static DWORD HardwareStatusThread(LPVOID pParam); //定时查询状态信息 static DWORD HardwareReSendThread(LPVOID pParam); //指令重发 void FireNotify(std::string key, int context);//向上层上报消息 void FireNotify(std::string key, float context); void FireNotify(std::string key, std::string context); void FireErrorMessage(const bool Act, const int Code, const char* ResInfo = ""); //上报错误消息 void FireWarnMessage(const bool Act, const int Code, const char* ResInfo = ""); //上报告警消息 }; } //----------------------------------------------------------------------------- // PSGHRDriver //----------------------------------------------------------------------------- namespace CCOS::Dev::Detail::Generator { class _CCOSDEVGENPSGHR_API PSGHRDriver : public IODriverWithSCF { using super = IODriverWithSCF ; public: PSGHRDriver (); virtual ~PSGHRDriver (); public: //virtual bool DriverEntry (std::string CfgFileName); //设置配制文件路径,对外接口最先调用 virtual void Prepare () override; //在 DriverEntry 之后执行;选择与物理设备通信方式（串口、TCP） virtual std::string DriverProbe() override; //在 Prepare 之后执行;读取配置文件模块参数，供上层创建驱动work路径 bool ReConnection(nsSCF::SCF& DevSCF); virtual bool DATA_ACTION Connect () override; //在 DriverProbe 之后执行;根据通信方式与物理设备进行连接 virtual auto CreateDevice(int index)->std::unique_ptr override; //在 Connect 之后执行;创建逻辑设备，供上层创建驱动树节点 virtual bool isConnected() const override; //检查驱动与物理设备连接状态 virtual std::string GetResource() override; //获取配置文件的值 virtual std::string DeviceProbe() override; //读取配置文件模块参数，供上层创建设备work路径 virtual void Disconnect() override; //断开驱动与物理设备连接状态 virtual void Dequeue (const char * Packet, DWORD Length) override; //在super::Connect中轮询,调用 DecodeFrame:查找指令操作对照表,通过对应操作更新数据并调用FireNotify上报更新 virtual void FireNotify (int code, std::string key, std::string content) override; //向监听者上报事件 static PACKET_RET callbackPackageProcess(const char* RecData, DWORD nLength, DWORD& PacketLength); //判断从设备读到的数据有没有可用的数据包，有则最终调度到 Dequeue private: bool SaveConfigFile(bool bSendNotify); virtual bool GetDeviceConfig(std::string& Cfg) override; virtual bool SetDeviceConfig(std::string Cfg) override; bool GetDeviceConfigValue(ResDataObject config, const char* pInnerKey, int nPathID, string& strValue); bool SetDeviceConfigValue(ResDataObject& config, const char* pInnerKey, int nPathID, const char* szValue); ResDataObject m_DeviceConfig; ResDataObject m_ConfigAll; //存储当前的配置，用于修改配置时写回文件 ResDataObject m_Configurations; //存储当前配置中“CONFIGURATION”节点的内容 //webconfig使用 ResDataObject m_DeviceConfigSend; string g_strAppPath; std::unique_ptr m_pAttribute; std::unique_ptr m_pDescription; PSGHRDevice* m_pDevice{ nullptr }; }; }