#pragma once #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" #include "LogicClient.h" #ifdef CCOSDEVGENDelta_EXPORTS #define _CCOSDEVGENDelta_API __declspec(dllexport) #else #define _CCOSDEVGENDelta_API __declspec(dllimport) #endif enum DELTA_ABNORMAL_LEVEL { //故障等级 REG_ERRO, REG_WARN }; enum TransToType { tochar = 0, toint, tohex }; struct AECINFORM { int Chamber; int Field; int Density; int FilmScreenSpeed; }; namespace nsSerialGPM = CCOS::Dev::MODLE::SerialGPM; static const int TIMEOUTVALUE = 100; static int m_nCountTimes = 0; // 定义常量数组长度 // 静态缓冲区用于存储不完整指令 static char buffer[1024]; static int bufferLength = 0; // 记录可能的指令片段状态 static std::queue partialCommandQueue; // 记录当前处理位置 static int currentIndex = 0; //----------------------------------------------------------------------------- // DeltaDevice //----------------------------------------------------------------------------- namespace CCOS::Dev::Detail::Generator { namespace nDev = CCOS::Dev; namespace DevDAP = CCOS::Dev::Detail::DAP; class _CCOSDEVGENDelta_API DeltaDevice : public IODeviceWithSCF ,public GeneratorMould { using super = IODeviceWithSCF ; using superGen = GeneratorMould; public: DeltaDevice(std::shared_ptr center, nsSCF::SCF SCF,string configfile); ~DeltaDevice (); bool DecodeFrame(const char* strPackage, int nLength); void ProcessCommand(const char* strPackage, int Index, int End); 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 SetFocus(int value) 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 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 SetGenSynState(int value) override; virtual RET_STATUS SetGenState(int value) override; virtual RET_STATUS SetExpEnable() override; virtual RET_STATUS SetExpDisable()override; virtual RET_STATUS Reset()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 SetEXAMMode(std::string value) override; virtual RET_STATUS ActiveSyncMode(_tSyncModeArgs value) override; static DeltaDevice* g_GenDevice; //串口处理层 static nsSerialGPM::CDeliverModule m_tDelivermodule; int m_nCMDType_ACK{ 0 }; int m_nCMDType_WaitTime{ 0 }; int m_nCMDType_WaitACK{ 0 }; int m_nCMDType_WaitSELF{ 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 HWSendACKCMD(string strCommand, int headLengh = 1); //RET_STATUS HWSendWaittimeCMD(string strCommand, int headLengh = 1); RET_STATUS HWSendWaitACKCMD(string strCommand, int headLengh = 1); bool LoadConfig(string configfile); int GetGenState(); private: void Register(); RET_STATUS RefreshData(); RET_STATUS HWSend(const char * strCommand, int lengh, int nTimeOut = TIMEOUTVALUE); 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 = ""); //上报告警消息 bool GetConfData(); _tSyncModeArgs m_cfgCurrentWSSYN; //当前选中的工作位和对应的同步模式 _tAPRArgs m_tAPRdata; //保存服务传入的参数 ResDataObject m_GenConfig; //driver's config file std::unique_ptr m_DAP; //DAP值 std::unique_ptr m_MSGUnit; //错误消息处理对象 string m_ErrorCode; //错误码，防止重复发送 bool m_ExpPreFlagStatus{ false }; //发生器返回的是否允许prepare bool m_XRayOnFlagStatus{ false }; //发生器返回的X-RAY ON bool m_SysLimitFlagStatus{ false }; //发生器返回的SYSTEM LIMITS bool m_InterlockFlagStatus{ false }; //发生器返回的INTERLOCK bool m_TubeFlagStatus{ false }; //发生器返回的TUBE bool m_KVHoldFlagStatus{ false }; //发生器返回的KV HOLD bool m_ServiceFlagStatus{ false }; //发生器返回的SERVICE bool m_FluLevelFlagStatus{ false }; //发生器返回的FLUORO LEVEL bool m_ExamProFlagStatus{ false }; //发生器返回的EXAM PROCESS COMPLETED bool m_ExamSwitchFlagStatus{ false }; //发生器返回的EXPOSURE SWITCH PRESSED bool m_XRDisableFlagStatus{ false }; //发生器返回的XR DISABLE bool m_ABSFlagStatus{ false }; //发生器返回的FLUORO LOCK bool m_AECFlagStatus{ false }; //发生器返回的RAD LOCK //lsy bool ChangeGenParam(int kv, float fma, float fms, float fmas); bool SetRADKV_MA_MS(int kv, float ma, float ms); bool SetRADKV_MAS(int kv, float mas); bool SetAECKV_MA_MS(int kv, float ma, float ms); int FormatCommand(char* buf, int len); //int GetFacValue(vector Index, int& value); int GetFacFloatValue(vector Index, float& value); string m_strCommand; string uint8ArrayToHexStr(const UINT8* array, size_t length); string m_strKV; vector m_vecKV; string m_strMAS; vector m_vecMAS; string m_strMA; vector m_vecMA; string m_strMS; vector m_vecMS; int m_nTubeMaSFMaxValue{ 160 }; int m_nTubeMaBFMinValue{ 180 }; bool m_nTableUsePanelAEC{ false }; bool m_nWallUsePanelAEC{ false }; bool m_nFreeUsePanelAEC{ false }; bool m_nTableUsePanelDDR{ false }; bool m_nWallUsePanelDDR{ false }; bool m_nFreeUsePanelDDR{ false }; bool m_bSendXwindowToDector{ false }; bool SetAECInformation(int chamber, int field, int density, int film); bool SetRadMode(int radmode, int desmode); bool SetDAECEnable(int enable);//打开关闭DAEC功能 int m_nChamberIndex{ 1 }; int WSGen2UI(int InputWS); int m_nAecFiled{2}; int m_nAecDensity{0}; int m_nAecFilm{ 0 }; bool SetDualEnergyCommand(const _tAPRArgs& t); bool m_bIsDualExp{ false }; int m_nExposureNumber{ 0 }; bool SetAPRForDual(int nWS, int nFO, int nET, int nAECFieldSel, int nAECFilmSel, float fAECDensity, float fKV, float fMA, float fMS, float fMAS); bool GetLastExpParamenters(void); std::unordered_map m_ErrorMessages; std::unordered_map m_WarnMessages; void RetrieveFirewareVersion(); string AnalysisCommand(int number, const char* chdigital, int type); LogicClient* m_pDetectorClient; int m_nDEFrameRate{ 1 }; int m_nCurErrLevel{ 2 }; bool m_bXronMsg{ false }; std::string GetFileVersion(std::string strFilePathName); std::string GetDynamicLibraryPath(); void SetNoDrMode(); void SetSyncOutMode(); void SeleckDetectorNumber(int detectorID); //轮询处理 static atomic m_iLoopTime; //循环间隔时间（毫秒） HANDLE m_hArrayEvent[4]; HANDLE m_hExitEvent{ NULL }; HANDLE m_hHUstatus{ NULL }; HANDLE m_hGENstatus{ NULL }; HANDLE m_hLoopEvent{ NULL }; bool StartHardwareStatusThread(); static DWORD HardwareStatusThread(LPVOID pParam); HANDLE m_pHardwareStatusThread{ NULL }; void RetrieveHU(); void CheckGeneratorStatus(); bool m_nProcessXrayon{ false }; void RetrieveMaxRating(); int m_nMaxKW{ 0 }; //AEC相关 void UpdataAECInformation(AECINFORM aec);//通过发生器返回的参数更新AEC数据 AECINFORM m_AECinformation; void RetrieveGeneratroDerating(); string m_strConfigPath{ "" }; //断线重连 bool m_bReconnect{ false }; bool m_bSetAPR{ false }; vector> parse_packets(const vector& data); bool m_bLoadConfigFile{ false }; }; } //----------------------------------------------------------------------------- // DeltaDriver //----------------------------------------------------------------------------- namespace CCOS::Dev::Detail::Generator { class _CCOSDEVGENDelta_API DeltaDriver : public IODriverWithSCF { using super = IODriverWithSCF ; public: DeltaDriver (); virtual ~DeltaDriver (); public: //virtual bool DriverEntry (std::string CfgFileName); //设置配制文件路径,对外接口最先调用 virtual void Prepare() override; //在 DriverEntry 之后执行;选择与物理设备通信方式（串口、TCP） virtual std::string DriverProbe() override; //在 Prepare 之后执行;读取配置文件模块参数，供上层创建驱动work路径 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”节点的内容 bool m_bDemoConnected; // 在 DEMO 模式下, 是否调用过 Connect //webconfig使用 ResDataObject m_DeviceConfigSend; string g_strAppPath; std::unique_ptr m_pAttribute; std::unique_ptr m_pDescription; DeltaDevice* m_pDevice{ nullptr }; }; }