PhysicalDevice/Generator/SDC/DIOS.Dev.Generator.SDC/DIOS.Dev.Generator.SDC.h

#pragma once


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

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

#include "DAP.BasicMoulds.hpp"
#include "CCOS.Dev.MSGMould.hpp"
#include <deque>
//#include <afxmt.h>

#ifdef CCOSDEVGENSDC_EXPORTS
#define _CCOSDEVGENSDC_API __declspec(dllexport)
#else
#define _CCOSDEVGENSDC_API __declspec(dllimport)
#endif


namespace CCOS::Dev::Detail::Generator
{
	static const int TIMEOUTVALUE = 350;
	//using JSONString = std::string;
	//namespace DevDAP = CCOS::Dev::Detail::DAP;
	
	struct tagCommandStruct //SDC指令结构体
	{
		std::string strCommand;
		//hundred digit: wait for cp command
		//ten     digit: wait for ack command
		//one     digit: wait for self command
		atomic<int> nCommmandType;
		int nWaitTime;

		tagCommandStruct()
		{
			strCommand.clear();
			nCommmandType = 0;
			nWaitTime = 3000;
		}
		tagCommandStruct(const tagCommandStruct& value)
		{
			strCommand = value.strCommand;
			nCommmandType.store(value.nCommmandType);
			nWaitTime = value.nWaitTime;
		}
		tagCommandStruct& operator =(const tagCommandStruct& value)
		{
			strCommand = value.strCommand;
			nCommmandType.store(value.nCommmandType);
			nWaitTime = value.nWaitTime;
			return *this;
		}
	};

//-----------------------------------------------------------------------------
//		SDCDevice
//-----------------------------------------------------------------------------
	namespace nDev = CCOS::Dev;
	namespace DevDAP = CCOS::Dev::Detail::DAP;
	class  _CCOSDEVGENSDC_API  SDCDevice : public IODeviceWithSCF <IODeviceDetail>,public GeneratorMould
	{
		using super = IODeviceWithSCF <IODeviceDetail>;
		using superGen = GeneratorMould;
		
	public:
		SDCDevice(std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF, std::string configPath);
		~SDCDevice();

		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 IncKVL() override;//add by wxx for task226
		virtual RET_STATUS DecKVL() override;

		virtual RET_STATUS IncMA() override;
		virtual RET_STATUS DecMA() override;
		virtual RET_STATUS SetMA(float value) override;
		virtual RET_STATUS IncMAL() override;//add by wxx for task226
		virtual RET_STATUS DecMAL() override;

		virtual RET_STATUS IncMS() override;
		virtual RET_STATUS DecMS() override;
		virtual RET_STATUS SetMS(float value) override;
		virtual RET_STATUS IncMSL() override;//add by wxx for task226
		virtual RET_STATUS DecMSL() override;

		virtual RET_STATUS IncMAS() override;
		virtual RET_STATUS DecMAS() override;
		virtual RET_STATUS SetMAS(float value) override;
		virtual RET_STATUS IncMASL() override;//add by wxx for task226
		virtual RET_STATUS DecMASL() override;

		virtual RET_STATUS SetFocus(int value) override;
		virtual RET_STATUS SetTechmode(int value) override;
		virtual RET_STATUS SetWS(const std::string value) override;
		virtual RET_STATUS SetAPR(const _tAPRArgs& t) 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 SetAECDensity(int value) override;
		virtual RET_STATUS SetAECField(int value) override;
		virtual RET_STATUS SetAECFilm(int value) 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 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;
		RET_STATUS Clear_DAP();
		RET_STATUS GetValue_DAP(float& value);

		virtual RET_STATUS ActiveSyncMode(_tSyncModeArgs value) override;

		//add by wxx for bug6097 20230919
		_tAPRArgs    m_sPreAPRvalue{ 0 };      //转换techmode前的参数
		DWORD        m_tmSysTime{ 0 };         //系统时间
		atomic<bool> m_bExpoEnable;	           //曝光使能标记
		atomic<bool> m_bExpoFlag;	           //曝光流程标记
		map<cfgWorkStationKey, cfgWorkStationData> m_arrWSMap; //工作位标记码查找表
	protected:
		RET_STATUS RefreshData ();
		bool SetAcquireSatus();
		void WaitforSELF(const char* cmd, int lengh);
		void WaitforACK();
		void WaitforCP();
		void StopWait();
	private:
		void OnCallBack();
		void Register();
		void FireNotify(std::string key, std::string context);
		bool ProcessCommand(std::string strCommand, int nType = -1, bool isFirstSend = false);
		bool ReProcessCommand(std::string strCommand, int nType = -1);
		RET_STATUS HWSend(char* strCommand, int iWaitType = 0, int nTimeOut = TIMEOUTVALUE);

		bool StartSendingCommandsThread();                        //发送指令队列轮询线程
		static DWORD SedecalSendingCommandsThread(LPVOID pParam); //发送指令队列轮询处理
		void StopSendingCommandsThread();                         //发送指令队列轮询结束

		string m_strConfigPath;			             //CPI generator confile.
		ResDataObject m_GenConfig;		             //driver's config file.
		CRITICAL_SECTION  m_iCriticalSection;        //队列锁
		deque <tagCommandStruct> m_SdcCommondvector; //等待发送的指令队列
		tagCommandStruct m_strCurrentCommand;        //当前正在发送的指令
		std::unique_ptr<DevDAP::DOSEMould> m_DAP;    //DAP值
		std::unique_ptr<nsDetail::MSGUnit> m_MSGUnit;//错误消息处理对象
		HANDLE m_hGenPostEvent;                      //上报POST参数
		HANDLE m_hSendingThreadToggleEvent;          //发送指令线程事件
		HANDLE m_hGenSELFEvent;                      //等待指令自己事件
		HANDLE m_hGenACKEvent;                       //等待AK事件
		HANDLE m_hGenCPEvent;                        //等待CP事件
		int m_TimeoutReset;                          //超时重发计数
		HANDLE m_SendingCommandsThread;              //发送线程句柄
		int m_nSendingCommandsThreadId;              //发送线程ID
		atomic<bool> m_bSendingCommandsThreadExit;   //退出发送线程                 
		bool m_sendEnable;                           //指令发送使能
		cfgWorkStationKey m_strCurrentWSName;        //当前工作位名称
		bool m_nSoftSynPR1Flag{ false };             //记录PR1状态，用于软同步
		_tSyncModeArgs m_SyncMode;
	};
}


	//-----------------------------------------------------------------------------
	//		SDCDriver
	//-----------------------------------------------------------------------------

namespace CCOS::Dev::Detail::Generator
{
	class  _CCOSDEVGENSDC_API  SDCDriver : public IODriverWithSCF <DriverMould>
	{
		using super = IODriverWithSCF <DriverMould>;
		//ResDataObject m_GenConfig;
	public:
		SDCDriver ();
		virtual ~SDCDriver ();

	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) override;
		virtual void FireNotify (int code, std::string key, std::string content) override;

		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;

	private:
		static PACKET_RET callbackPackageProcess (const char* RecData, DWORD nLength, DWORD& PacketLength);
		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);

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

}