PhysicalDevice/Generator/CPI/CCOS.Dev.Generator.CPI/CCOS.Dev.Generator.CPI.h

#pragma once

#include <thread>
#include <mutex>
#include <condition_variable>
#include <atomic>
#include <memory>
#include <functional>
#include <chrono>

#include "CCOS.Dev.Generator.Mould.hpp"
#include "DAP.BasicMoulds.hpp"
#include "CCOS.Dev.MSGMould.hpp"
#include "CCOS.Dev.IODevice.Detail.hpp"
#include "SCFWrapper.h"
#include "LinuxEvent.h"
#include "OEM.Collimator.h"
#include "OEM.Dap.h"
#include "OEM.Mechanical.h"

#define _CCOSDEVGENCPI_API __attribute__((visibility("default")))

// Linux 兼容的数据类型定义
using DWORD = unsigned long;
using LPVOID = void*;
using BOOL = int;
using HANDLE = void*;
#define TRUE 1
#define FALSE 0

// 睡眠函数(以毫秒为单位)
inline void Sleep(unsigned int milliseconds) {
	std::this_thread::sleep_for(std::chrono::milliseconds(milliseconds));
}

namespace CCOS::Dev::Detail::Generator
{
	static const int TIMEOUTVALUE = 100;
//-----------------------------------------------------------------------------
//		CPIDevice
//-----------------------------------------------------------------------------
	namespace nDev = CCOS::Dev;
	namespace DevDAP = CCOS::Dev::Detail::DAP;
	class  _CCOSDEVGENCPI_API  CPIDevice : public IODeviceDetail,public GeneratorMould
	{
		using super = IODeviceDetail;
		using superGen = GeneratorMould;

	public:
		//CPIDevice (std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF);
		CPIDevice(std::shared_ptr <IOEventCenter> center, std::shared_ptr<SCFWrapper> SCF,string configfile);
		~CPIDevice ();

		virtual std::string GetGUID() const override;
	private:
		RET_STATUS  HWSend (const char * strCommand, int nTimeOut = TIMEOUTVALUE);
		void OnCallBack ();
		std::shared_ptr<SCFWrapper> m_SCF;
		std::unique_ptr<DevDAP::DOSEMould> m_DAP;
		std::unique_ptr<nsDetail::MSGUnit> m_MSGUnit;
		bool StartHardwareStatusThread();
		static void HardwareStatusThread(CPIDevice* pParam);
		std::thread m_pHardwareStatusThread;

	private:
		void Register();

	public:
		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;
		//SetGeneratortoSyncStatus
		//virtual RET_STATUS SetGeneratortoSyncStatus(std::string value) override;

		RET_STATUS Clear_DAP();
		RET_STATUS GetValue_DAP(float& value);

		RET_STATUS StartMove();
		RET_STATUS EndMove();

		RET_STATUS SetCollimatorSize(int height,int width);
		RET_STATUS SetFilter(int filterType);
		RET_STATUS QueryDAP();

		//为了将gen和其他设备对象联系起来相互调用接口
		RET_STATUS SetCollimatorDev(OemCollimator* dev);
		RET_STATUS SetMechDev(OemMechanical* dev);
		RET_STATUS SetDapDev(OemDap* dev);

	protected:
		RET_STATUS RefreshData ();
		RET_STATUS SetRPS(int rps);//连续曝光片帧率
	private:
		void FireNotify (std::string key, std::string context);
		std::shared_ptr<LinuxEvent> m_hGenPostEvent;			//暂时不使用了.
		_tAPRArgs m_t;					//放射曝光的参数

		string m_strConfigPath;			//CPI generator confile.
		ResDataObject m_GenConfig;		//driver's config file.

		/*
		GenType == "CPI Series SIS0040B") || (strGenType == "CPI SIS0040B")) 时为1.
		GenType == "CPI with positioner I/F"时，set为2
		其它都是0.  一般情况为 GenType == ，CPI，
		*/
		int m_nDeviceType;
		bool m_bWithCollimator;	//有无coll，用于控制coll size 和 filter
		bool m_bExpEnable;	//

		enum MyEnum
		{
			EXPOSURE_SOFTWARE_HARDWARE,						//0
			EXPOSURE_NOSYNBOX_DIRCETCONNECT_DETECTOR_GEN,	//1
			EXPOSURE_SOFTWARE_NOSYNBOX						//2
		};

		//ysj++
		int m_nAECMode;//0 fix 1 mas 2 ms

		bool m_bSaveMSMA;//很难理解，但实质是表示 是否在setapr期间
		float m_PrefMS;
		float m_fPreMA;
		int m_nFO;
		float m_fMsLimit;
		int m_nPreET;
		bool m_bInExpState;	//用来表示是否在曝光状态，因为在exp状态时，有些指令必须防止发送
		int m_nCtlMode;

		std::unique_ptr<OemCollimator> m_pCollDev;
		//std::unique_ptr<OemMechanical> m_pMechDev;
		std::unique_ptr<OemDap> m_pDapDev;

		bool m_bCheckATUStatus;//
		bool m_bDAPEnable;

		std::atomic<bool> m_bExtraFlag{true};  // 硬件状态查询线程使能标记

	};
}


	//-----------------------------------------------------------------------------
	//		CPIDriver
	//-----------------------------------------------------------------------------

namespace CCOS::Dev::Detail::Generator
{
	class  _CCOSDEVGENCPI_API  CPIDriver : public DriverMould
	{
		using super = DriverMould;

	public:
		CPIDriver ();
		virtual ~CPIDriver ();

	public:

		virtual void Prepare () override;

		virtual bool DATA_ACTION  Connect () override;
		virtual void Disconnect() override;
		virtual bool isConnected() const override;

		virtual void Dequeue (const char * Packet, DWORD Length);
		virtual void FireNotify (int code, std::string key, std::string content);

		virtual auto CreateDevice (int index)->std::unique_ptr <IODevice> override;

		virtual std::string DriverProbe () override;
		virtual std::string GetResource () override;
		virtual std::string DeviceProbe () override;

		virtual bool GetDeviceConfig(std::string& Cfg) override;
		virtual bool SetDeviceConfig(std::string Cfg) override;

		std::shared_ptr<SCFWrapper> m_scfWrapper;
	private:
		static PACKET_RET callbackPackageProcess (const char* RecData, uint32_t nLength, uint32_t& PacketLength);

		bool m_bDemoConnected;	//	在 DEMO 模式下, 调用过 Connect 吗?

		CPIDevice* m_pDriGenDev;
		OemCollimator* m_pDriCollDev;
		OemDap* m_pDriDapDev;

		ResDataObject m_DeviceConfig;
		ResDataObject m_DeviceConfigSend;
		string g_strAppPath;
		ResDataObject m_ConfigAll; //存储当前配置，如果修改配置时写入文件
		ResDataObject m_Configurations; //存储当前配置中，CONFIGURATION节点内容
		std::unique_ptr <ResDataObject> m_pAttribute;
		std::unique_ptr <ResDataObject>  m_pDescription;

		bool SaveConfigFile(bool bSendNotify);
		bool GetDeviceConfigValue(ResDataObject config, const char* pInnerKey, int nPathID, string& strValue);
		bool SetDeviceConfigValue(ResDataObject& config, const char* pInnerKey, int nPathID, const char* szValue);

		//webconfig使用
		std::string  m_SCFDllName;

	};

}