PhysicalDevice/Generator/SINO/DIOS.Dev.Generator.SINOmini/DIOS.Dev.Generator.SINOmini.h

#pragma once

#include <atomic>
#include "CCOS.Dev.Generator.Mould.hpp"
#include "IODeviceWithSCF.tlh"
#include "IODeviceWithSCF.tli"

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

#include "CCOS.Dev.IODevice.Detail.hpp"
#include "SINOminiCommandDef.h"
#include "OEM.Mechanical.h"
#include "OEM.Collimator.h"

#ifdef CCOSDEVGENSINOmini_EXPORTS
#define _CCOSDEVGENSINOmini_API __declspec(dllexport)
#else
#define _CCOSDEVGENSINOmini_API __declspec(dllimport)
#endif

enum SINOmini_REGULATION_LEVEL { //故障等级
	REG_ERRO,
	REG_WARN
};

namespace CCOS::Dev::Detail::Generator
{
	static const int TIMEOUTVALUE = 100;
	//using JSONString = std::string;
	//namespace DevDAP = CCOS::Dev::Detail::DAP;

//-----------------------------------------------------------------------------
//		SINOminiDevice
//-----------------------------------------------------------------------------
	//namespace nDev = CCOS::Dev;
	//namespace DevDAP = CCOS::Dev::Detail::DAP;

	class  _CCOSDEVGENSINOmini_API  SINOminiDevice : public IODeviceWithSCF <IODeviceDetail>,public GeneratorMould
	{
		using super = IODeviceWithSCF <IODeviceDetail>;
		using superGen = GeneratorMould;
		
	public:
		SINOminiDevice (std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF, string configfile);
		~SINOminiDevice ();

		virtual std::string GetGUID() const override;
		RET_STATUS SetAPRMaMmo(int nKV, float fMAS, int nFO, int nET, int nDensity, int nThickness = -1, int nPress = -1, int nFilter = -1, int nSensor = 255, int nGrid = 1);
		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 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 SetExpEnable() override;
		virtual RET_STATUS SetExpDisable()override;
		virtual RET_STATUS Reset()override;

		//为了将gen和其他设备关联，能相互调用接口
		RET_STATUS SetGrid(int nGridType);
		RET_STATUS SetFilter(int nFilterType);
		RET_STATUS SetAutoTracking(int nAutoTracking);
		RET_STATUS GetTomoResults(ResDataObject& resultAngle, ResDataObject& resultHeight);

		RET_STATUS SetMechDev(OemMechanical* dev);
		RET_STATUS SetCollimatorDev(OemCollimator* dev);
		RET_STATUS SetCollimatorSize(int xsize, int ysize);
		RET_STATUS SetCollimatorLight(WORD pParams);

		//发生器不支持的命令
		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 SetGenSynState(int value) override;
		virtual RET_STATUS SetGenState(int 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);
		RET_STATUS StartMove();
		RET_STATUS EndMove();
		RET_STATUS RefreshData();
		RET_STATUS SetRPS(int rps);//设置连续点片帧率

		//暂不对外提供的指令
		void ReConnect();
		//virtual RET_STATUS SetGeneratortoSyncStatus(std::string value);

	public:
		ResDataObject m_GenConfig;  //driver's config file.
		//线程变量互斥锁
		std::mutex mtxTime;
		static int m_iLoopTime;	        //循环间隔时间（毫秒）
		std::mutex mtxHeartBeats;
		int m_iHeartBeats;	        //心跳统计
		std::mutex mtxConnectFlag;
		bool m_bConnectFlag;	    //连接标记

	private:
		std::unique_ptr<OemMechanical> m_pMechDev;
		std::unique_ptr<OemCollimator> m_pCollDev;
		//std::unique_ptr<DevDAP::DOSEMould> m_DAP;
		std::unique_ptr<nsDetail::MSGUnit> m_MSGUnit;
		HANDLE m_pHardwareStatusThread;
		HANDLE m_pAECProcessThread; //解决AEC流程过快
		atomic<bool> m_AECFlag;
		bool m_bExpEnable;	           //曝光使能

	private:
		RET_STATUS  HWSend(SINOminiCommand &strCommand, int nTimeOut = TIMEOUTVALUE);
		void OnCallBack();
		void Register();
		bool StartHardwareStatusThread();				//定时查询状态信息
		static DWORD HardwareStatusThread(LPVOID pParam);
		static DWORD AECProcessThread(LPVOID pParam);
		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 = "");
		
	};

}


	//-----------------------------------------------------------------------------
	//		SINOminiDriver
	//-----------------------------------------------------------------------------

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

	public:
		SINOminiDriver ();
		virtual ~SINOminiDriver ();

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

		SINOminiDevice* m_pDriGenDev;// = nullptr;
		OemMechanical* m_pDriMechDev;// = nullptr;
		OemCollimator* m_pDriCollDev;// = nullptr;
		ResDataObject m_DeviceConfig;
		ResDataObject m_ConfigAll; //存储当前的配置，用于修改配置时写回文件
		ResDataObject m_Configurations; //存储当前配置中“CONFIGURATION”节点的内容
		bool m_bDemoConnected;	//	在 DEMO 模式下, 是否调用过 Connect

		ResDataObject m_DeviceConfigSend;
		string g_strAppPath;
		std::unique_ptr <ResDataObject> m_pAttribute;
		std::unique_ptr <ResDataObject>  m_pDescription;
	};

}