PhysicalDevice/Generator/Delta/DIOS.Dev.Generator.Delta_50KCXAF/DIOS.Dev.Generator.Delta_50KCXAF.h

#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_MOBILE_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;

//-----------------------------------------------------------------------------
//		DeltaMobileDevice
//-----------------------------------------------------------------------------

namespace CCOS::Dev::Detail::Generator
{

	namespace nDev = CCOS::Dev;
	namespace DevDAP = CCOS::Dev::Detail::DAP;
	class  _CCOSDEVGENDelta_API  DeltaMobileDevice : public IODeviceWithSCF <IODeviceDetail>,public GeneratorMould
	{
		using super = IODeviceWithSCF <IODeviceDetail>;
		using superGen = GeneratorMould;
		
	public:
		DeltaMobileDevice(std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF,string configfile);
		~DeltaMobileDevice ();
		bool DecodeFrame(const char* strPackage, int nLength);
		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;  //0x01--AEC mode 0x02--Ms mode 0x03--mAs mode
		virtual RET_STATUS SetFocus(int value) override;	//0x01--large:0x02--small:0x03--auto
		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;


		virtual RET_STATUS ResetFluTimer(int ntype) override;
		virtual RET_STATUS SetPPS(float frameRate) override;
		static DeltaMobileDevice* 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 HWSendWaitACKCMD(string strCommand, int headLengh = 1);

		//轮询处理
		static atomic<int>  m_iLoopTime;	          //循环间隔时间（毫秒）
		HANDLE m_hArrayEvent[4];
		HANDLE m_hExitEvent{ NULL };
		HANDLE m_hHUstatus{ NULL };
		HANDLE m_hGENstatus{ NULL };
		HANDLE m_hLoopEvent{ NULL };
		void StartHardwareStatusThread();
		static DWORD HardwareStatusThread(LPVOID pParam);
		HANDLE                                     m_pHardwareStatusThread{ NULL };
		bool										m_nProcessXrayon{ false };
	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 = ""); //上报告警消息
		void GetConfData();

		_tSyncModeArgs								m_cfgCurrentWSSYN;  //当前选中的工作位和对应的同步模式
		_tAPRArgs									m_tAPRdata;		   //保存服务传入的参数
		ResDataObject								m_GenConfig;		   //driver's config file
		std::unique_ptr<DevDAP::DOSEMould>			m_DAP;              //DAP值
		std::unique_ptr<nsDetail::MSGUnit>			m_MSGUnit;          //错误消息处理对象
		string										m_ErrorCode;        //错误码，防止重复发送
		//lsy
		bool										ChangeGenParam(int kv, float fma, float fms, float fmas);
		int											FormatCommand(char* buf, int len);
		int											GetFacFloatValue(vector<float> Index, float& value);
		string										m_strCommand;
		string										uint8ArrayToHexStr(const UINT8* array, size_t length);
		string										m_strKV;
		vector<int>									m_vecKV;
		string										m_strMAS;
		vector<float>								m_vecMAS;
		string										m_strMA;
		vector<float>								m_vecMA;
		string										m_strMS;
		vector<float>								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										SetDAECEnable(int enable);//打开关闭DAEC功能
		int											m_nChamberIndex{ 1 };
		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);
		std::unordered_map<std::string, std::string>	m_ErrorMessages;
		std::unordered_map<std::string, std::string>	m_WarnMessages;
		LogicClient*								m_pDetectorClient;
		int											m_nDEFrameRate{ 1 };
		//0x01--Low Level Reset Function  用于复位3开头的错误
		//0x02--Clear setup				  清除所有曝光参数
		//0x03--High Level Reset Function 用于复位4开头的错误
		int											m_nCurErrLevel{ 0 };
		bool										m_bXronMsg{ false };
		void										SeleckDetectorNumber(int detectorID);
		void										SetNoDrMode();
		void										SetSyncOutMode();
		void										GetHE();
		//common
		string										AnalysisCommand(int number, const char* chdigital, int type);

		//LSY
		void										RetrieveFirewareVersion();
		void										RetrieveModelName();
		void										RetrieveSerialNumber();

		void										RetrieveMaxRating();
		int											m_nMaxKW{ 0 };
		int											m_nMaxMA{ 0 };
		int											m_nMaxMAS{ 0 };
		int											m_nMaxKV{ 0 };

		void										RetrieveGeneratroDerating();
		void										RetrieveAECDAPFirmwareVersion();
		void										RetrieveTubePartNumber();
		void										RetrieveTubeMaxPower();
		void										RetrieveTubeFilamentCurrent();
		void										RetrieveTubeHULimit();
		void										RetrieveTubeDeratingInformation();
		void										RetrieveRunningMode();//AEC 1  MS 2 MAS 3
		void										RetrieveDataAndTime();
		void										RetrieveErrorCode();
		void										RetrieveErrorParameters();//待补充
		void										RetrieveExposureResult();//获取曝光后的参数
		void										RetrieveRadioMode();//获取当前点片模式 单帧序列 单能双能
		void										RetrieveFluMode();//获取当前透视模式
		void										RetrieveAECInformation();//获取AEC信息
		//AEC相关
		void										UpdataAECInformation(AECINFORM aec);//通过发生器返回的参数更新AEC数据
		AECINFORM									m_AECinformation;
		
		//void										RetrieveHU();
		void										CheckGeneratorStatus();
		//曝光前的最后有效参数
		void										ReportRadExposurePostParam();
		void										ReportFluExposurePostParam();
		//
		void										RetrieveFocalSpot();
		void										RetrieveTubeID();
		//
		//void										RetrieveFluStopTime();
		void										SetRadMode(int radmode, int desmode);
		//void										SetRunMode(int radmode, int desmode);
		bool										SetRADKV_MA_MS(int kv, float ma, float ms);//设置rad模式的三点模式的KV MA MS
		bool										SetRADKV_MAS(int kv, float mas);
		//
		string										m_strFKV;
		vector<int>									m_vecFKV;
		string										m_strFMA;
		vector<float>								m_vecFMA;
		string										m_strFMAS;
		vector<float>								m_vecFMAS;
		void										SetFLUKV_MA_MAS(int fkv, float fma, float fmas);//设置flu模式下的曝光参数
		void										SetTubeDeratingPower();
		//
		void										RetrieveBucky();
		void										SelectBucky(int bucky);
		//
		void										SetGeneratorOperateStatus(int status);//不知道是啥
		void										SelectTubeID(int TubeID);//不知道是啥
		//void										TubeCalibrationCommand();
		//void										TubeCalibrationDataReport();
		//void										RestoreFactorySettings();
		//void										TubeSeasoning();
		//void										SetFluStopTime();
		//
		void										RetrieveDAPValue();//5801
		//void										RetrieveDAPRate();//5802
		//void										ClearDAPValue();//58A1
		//void										SetAECCalibrationStartAndStop();//F06A
		//void										SetAECCalibrationDefaultPara();//F06A
		//void										SetORRetrieveCurrentAECCurve();
		// 
		// 
		// 
		//void										RetrieveBatteryManuInformation();
		void										RetrieveBatteryRunningInformation();
		void										SetAECInformation(int chamber, int field, int density, int film);
		void										SetAECKV_MA_MS(int kv, float ma, float ms);
		//ABS相关
		virtual										RET_STATUS SetABSMode(int nMode) override; //设置自动亮度调节（ABS）模式
		virtual										RET_STATUS SetABSCurve(int curveNum) override; //ABS曲线调节
		//设置线长短
		void										SetCableLngth(int lenght);
		//Set or retrieve mask function			61A8
		//Set or retrieve mask function			61A9
		//获取版本号
		std::string									GetFileVersion(std::string strFilePathName);
		std::string									GetDynamicLibraryPath();
		string										m_strConfigPath{ "" };
	};
}

//-----------------------------------------------------------------------------
//		DeltaDriver
//-----------------------------------------------------------------------------

namespace CCOS::Dev::Detail::Generator
{
	class  _CCOSDEVGENDelta_API  DeltaDriver : public IODriverWithSCF <DriverMould>
	{
		using super = IODriverWithSCF <DriverMould>;

	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 <IODevice> 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 <ResDataObject> m_pAttribute;
		std::unique_ptr <ResDataObject>  m_pDescription;
	};

}