#pragma once
#include "CCOS.Dev.Generator.Mould.hpp"

#include "DAP.BasicMoulds.hpp"
#include "CCOS.Dev.MSGMould.hpp"

#include "IODeviceWithSCF.tlh"
#include "IODeviceWithSCF.tli"

#include "HVUSBTOCAN.h"
#include "UIObject.h"

#ifdef CCOSDEVGENRYGEN_EXPORTS
#define _CCOSDEVGENRYGEN_API __declspec(dllexport)
#else
#define _CCOSDEVGENRYGEN_API __declspec(dllimport)
#endif

#define RYGEN_LoopDefTime 1500
#define RYGEN_LoopExpTime 300

namespace CCOS::Dev::Detail::Generator
{
	static const int TIMEOUTVALUE = 100;
//-----------------------------------------------------------------------------
//		RYGENDevice
//-----------------------------------------------------------------------------
	namespace nDev = CCOS::Dev;
	namespace DevDAP = CCOS::Dev::Detail::DAP;
	class  _CCOSDEVGENRYGEN_API  RYGENDevice : public IODeviceDetail ,public GeneratorMould,public CWnd, public CcosLock
	{
		DECLARE_DYNAMIC(RYGENDevice)
		using super = IODeviceDetail;
		using superGen = GeneratorMould;
		
	public:
		RYGENDevice(std::shared_ptr <IOEventCenter> center, UIObject* UIobj,string configfile);
		~RYGENDevice ();

		DECLARE_MESSAGE_MAP()
		afx_msg LRESULT RYAPIMSG(WPARAM wParam, LPARAM lParam);
		static LRESULT CALLBACK OnCallBack(void* obj, UINT, WPARAM, LPARAM);

		virtual std::string GetGUID() const override;
	public:
		static atomic<int>  m_iLoopTime;	          //循环间隔时间（毫秒）
	private:


		RET_STATUS  HWSend (char * strCommand, int nTimeOut = TIMEOUTVALUE);
		std::unique_ptr<DevDAP::DOSEMould> m_DAP;
		std::unique_ptr<nsDetail::MSGUnit> m_MSGUnit;
		bool StartHardwareStatusThread();
		static DWORD HardwareStatusThread(LPVOID pParam);
		HANDLE m_pHardwareStatusThread;

		bool InitGen();

		void HandlePRMsg(int nMessageValue);
		void HandleXRMsg(int nMessageValue);
		void HandleSTMsg(int nMessageValue);
		void HandleATMsg(int nMessageValue);
		void HandleSVMsg(int nMessageValue);
		void HandleTEMsg(int nMessageValue);
		void HandleERMsg(int nMessageValue);
		void HandleELMsg(int nMessageValue);
		void HandleCOKMsg(int nMessageValue);
		void HandleCLRMsg(int nMessageValue);
		void HandleHEMsg(int nMessageValue);
		void HandleFIMsg(int nMessageValue);
		void HandleFNMsg(int nMessageValue);
		void HandleFSMsg(int nMessageValue);
		void HandleFLPMsg(int nMessageValue); // For fluoro
		void HandleFLXMsg(int nMessageValue); // for fluoro
		void HandleFLKMsg(int nMessageValue); // for fluoro
		void HandleFLMMsg(int nMessageValue); // for fluoro
		void HandleFLFMsg(int nMessageValue); // for fluoro
		void HandleFLIMsg(int nMessageValue);
		void HandleFLRMsg(int nMessageValue);
		void HandleFLIWMsg(int nMessageValue);

		bool UpdateGenParamter();
		
	private:
		void Register();
	public:
		int m_nPreWS;
		int m_nPreFO;
		int m_nPreET;
		int m_nPreAECFieldSel;
		int m_nPreAECFilmSel;
		int m_nPreAECDensity;
		int m_nPreKV;
		float m_fPreMA;
		float m_fPreMS;
		float m_fPreMAS;
		std::string m_strFLFMode;
		float m_fpps;
		bool m_bError;
		UIObject* m_pUIOBJ;
	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;

		virtual float GetKV();
		virtual float GetMA();
		virtual float GetMS();
		virtual float GetMAS();
		virtual float GetFluKV();
		virtual float GetFluMA();
		virtual float GetFluMS();

		bool GetABSMode();
		bool GetAECDensityBuff(void);
		bool GetAECFieldBuff(void);

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

		RET_STATUS StartMove();
		RET_STATUS EndMove();

		virtual RET_STATUS ActiveSyncMode(_tSyncModeArgs value) override;
		int LoadConfig(string configfile);


		/********************透视命令****************************/

		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;


	protected:
		RET_STATUS RefreshData ();
		RET_STATUS SetRPS(int rps);//设置连续点片帧率
	private:
		void FireNotify (std::string key, std::string context);
		HANDLE m_hGenPostEvent;			//暂时不使用了.		
		_tAPRArgs m_t;					//保存服务传入的参数

		string m_strConfigPath;			//RYGEN generator confile.
		ResDataObject m_GenConfig;		//driver's config file.
		bool m_bIsConfigLoaded;

		bool m_bDAPEnable;
		bool m_bAKEnable;
		bool m_bResetActive;

		vector<string> m_localErrorlist;	//本地error list，用于清除error时，使用里面的string。
		vector<string> m_localWarnlist;		//本地warn  list，用于清除warn 时，使用里面的string。

		string WSUI2Gen(int nUIWS);			//根据nWS，得到string WS.
	};
}


	//-----------------------------------------------------------------------------
	//		RYGENDriver
	//-----------------------------------------------------------------------------

namespace CCOS::Dev::Detail::Generator
{
	class  _CCOSDEVGENRYGEN_API  RYGENDriver : public DriverMould
	{
		using super = DriverMould;

	public:
		RYGENDriver ();
		virtual ~RYGENDriver ();

	public:

		virtual void Prepare () override;

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

		void Dequeue (const char * Packet, DWORD Length);
		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;


		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);

	private:
		static PACKET_RET callbackPackageProcess (const char* RecData, DWORD nLength, DWORD& PacketLength);

		bool m_bDemoMode;
		bool m_bDemoConnected;	//	在 DEMO 模式下, 调用过 Connect 吗?
		bool m_bGenConnectReal;	//表示gen是否真正连接了。
		UIObject* m_pUIOBJ;

		ResDataObject m_DeviceConfig;
		ResDataObject m_DeviceConfigSend;
		string g_strAppPath;
		ResDataObject m_ConfigAll; //存储当前的配置，用于修改配置时写回文件
		ResDataObject m_Configurations; //存储当前配置中“CONFIGURATION”节点的内容


		//webconfig使用
		std::unique_ptr <ResDataObject> m_pAttribute;
		std::unique_ptr <ResDataObject>  m_pDescription;
		RYGENDevice* m_pDevice{ nullptr };

	};

}