PhysicalDevice/Generator/PSG/DIOS.Dev.Generator.PSG_HR/DIOS.Dev.Generator.PSG_HR.h

#pragma once

#include <atomic>
#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"

#ifdef CCOSDEVGENPSGHR_EXPORTS
#define _CCOSDEVGENPSGHR_API __declspec(dllexport)
#else
#define _CCOSDEVGENPSGHR_API __declspec(dllimport)
#endif

enum PSG_HR_REGULATION_LEVEL { //故障等级
	REG_ERRO,
	REG_WARN
};
enum PSG_HR_CHARGE_STATE { //电池状态
	POWER_LOW,
	POWER_NOR
};
#define PSGHR_Com_ReSendLen 32
namespace nsSerialGPM = CCOS::Dev::MODLE::SerialGPM;

namespace CCOS::Dev::Detail::Generator
{
	using cbFun = std::function <void(char*, int)>;
	//struct tFrameMapItem
	//{
	//	//static HANDLE m_hBeginReSendEvent;        //设置开始重发事件
	//	////static HANDLE m_hStopReSendEvent;         //设置停止重发事件
	//	//static mutex  m_mtxWaitACK;               //读写锁
	//	//static vector <string> m_dWaitACKVector;  //等待ACK的指令队列
	//	//
	//	cbFun m_fFun;                             //处理函数 
	//	//mutex m_mtxCMDRW;                         //读写锁
	//	//int   m_nReSendCount{ 0 };                //重试计数
	//	//char  m_strCMD[PSGHR_Com_ReSendLen]{ 0 }; //指令内容
	//	//int   m_nCMDLengh{ 0 };                   //指令长度
	//	//
	//	tFrameMapItem();
	//	tFrameMapItem(cbFun f);
	//	tFrameMapItem& operator =(const tFrameMapItem& value);
	//	//void tChangeWaitState(int status, const char* cmd, int lengh = 0);
	//};
	static const int TIMEOUTVALUE = 100;
	/*暂不使用
	using JSONString = std::string;
	namespace DevDAP = CCOS::Dev::Detail::DAP;
	*/
//-----------------------------------------------------------------------------
//		PSGHRDevice
//-----------------------------------------------------------------------------

	class  _CCOSDEVGENPSGHR_API  PSGHRDevice : public IODeviceWithSCF <IODeviceDetail>,public GeneratorMould
	{
		using super = IODeviceWithSCF <IODeviceDetail>;
		using superGen = GeneratorMould;
		
	public:
		PSGHRDevice (std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF, string configfile);
		~PSGHRDevice ();
		//发生器支持的通用命令
		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;
		virtual RET_STATUS SetEXAMMode(std::string 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;
		virtual RET_STATUS ActiveSyncMode(_tSyncModeArgs value) override;
		RET_STATUS RefreshData();
		RET_STATUS SetRPS(int rps);//设置连续点片帧率,暂不使用

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

		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;
		virtual RET_STATUS SetPluseWidth(float fplusewidth) 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 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 SetFLLever(FLOAT value);
		bool EnableBucky(int nbucky);
		bool ECHO(void);
		bool SetABSModeNative(int nMode);
		RET_STATUS Clear_DAP();
		RET_STATUS GetValue_DAP(float& value);
		RET_STATUS StartMove();
		RET_STATUS EndMove();

		//V3新方法
		virtual void SubscribeSelf(ccos_mqtt_connection* conn) override;
		RET_STATUS SetVibrationGrid(int value);
		RET_STATUS GetVibrationGridMS(int &value);

		void SetSmartAEC(int value); //智能AEC
		bool ReConnect(); //重连
		int  GridMSMargin(); //返回震动栅MS的余量
		bool CalculateAppropriateMA(float& inoutMAS, float& inoutMA, float& inoutMS); //计算震动栅模式下恰当的MA
		void ReSendFailedAction(string &cmdNum); //重发失败后返回消息

		int GetGenState();
		int LoadConfig(string configfile);

	public:
		ResDataObject m_GenConfig;  //driver's config file.
		//线程变量互斥锁
		//atomic<int> m_iReSendCMD;	                  //初始命令重发次数
		static atomic<int>  m_iLoopTime;	          //循环间隔时间（毫秒）
		atomic<int>         m_iCompPostMAS;	          //计算PostMAS条件统计
		atomic<int>         m_iHeartBeats;	          //心跳统计
		atomic<bool>        m_bConnectFlag;	          //连接标记
		bool                m_bAECCtlSignal;	      //在曝光设置更新期间,AEC控制信号必须处于低状态
		atomic<bool>        m_iVibrationGridState;	  //震动栅模式(0,1)
		int                 m_iGridMSRadMargin;       //震动栅ms手动曝光误差(500-2000ms)
		int                 m_iGridMSAECMargin;       //震动栅ms自动曝光误差(500-2000ms)
		static atomic<bool> m_bExtraFlag;	          //使用标记
 
	    bool m_bGenBusy;
		bool m_bReturnFlag;

		float m_fPreMA;
		float m_fPreMS;
		float m_fPreMAS;

		int m_nPreET;

		int m_nAECMode;//0 fix 1 mas 2 ms

		bool m_bSaveMSMA;//根据用途来看，其实是表示 是否处于setapr期间
		float m_PrefMS;
		float m_fMsLimit;
		bool m_bInExpState;	//用来表示是否处于曝光状态，因为处于exp状态时，仅有几组指令可以发。
		int m_nCtlMode;

		bool m_bCheckATUStatus;//
		bool m_bDAPEnable;

		bool m_bUseCECmd;
		bool m_bIsConfigLoaded;

		//串口处理层
		static nsSerialGPM::CDeliverModule m_tDelivermodule;
		int m_nCMDType_WaitTime{ 0 };
		int m_nCMDType_HB{ 0 };
		int m_nCMDType_WaitACK{ 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 HWSendWaittimeCMD(char* strCommand, int lengh, int headLengh = 3);
		RET_STATUS HWSendHBCMD(char* strCommand, int lengh, int headLengh = 3);
		RET_STATUS HWSendWaitACKCMD(char* strCommand, int lengh, int headLengh = 3);

	private:
		//std::unique_ptr<DevDAP::DOSEMould> m_DAP;   //暂不使用
		std::unique_ptr<nsDetail::MSGUnit> m_MSGUnit; //处理消息上报对象指针
		HANDLE m_pHardwareStatusThread;               //轮询线程句柄
		HANDLE m_pHardwareRsSendThread;               //重发线程句柄
		HANDLE m_hGenPostEvent;			
		atomic<bool> m_bExpEnable;	                  //曝光使能
		atomic<bool> m_bInvalidKVMASSetupFlag;        //写入到设备的曝光设置无效
		atomic<bool> m_bFaultList[18];	              //记录 主机请求固件报告故障命令 返回的故障记录
		int          m_iMaxPower;	                  //最大功率:kV*mA
		int          MaxHeatContent;                  //最阳极热容积:kV*mAs
		bool         m_bMAS_MA_AEC;
		enum MyEnum
		{
			EXPOSURE_SOFTWARE_HARDWARE,						//0
			EXPOSURE_NOSYNBOX_DIRCETCONNECT_DETECTOR_GEN,	//1
			EXPOSURE_SOFTWARE_NOSYNBOX						//2
		};

	private:
		RET_STATUS  HWSend(const char* strCommand, int lengh, bool reSend = false, int nTimeOut = TIMEOUTVALUE); //指令发送接口
		void OnCallBack(); //处理指令回调函数
		void Register(); //注册对外提供的属性、方法
		bool StartHardwareStatusThread();				//启动轮询线程
		static DWORD HardwareStatusThread(LPVOID pParam); //定时查询状态信息
		static DWORD HardwareReSendThread(LPVOID pParam); //指令重发
		void FireNotify(std::string key, int context);//向上层上报消息
		void FireNotify(std::string key, float context);
		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 = ""); //上报告警消息
		
	};

}


	//-----------------------------------------------------------------------------
	//		PSGHRDriver
	//-----------------------------------------------------------------------------

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

	public:
		PSGHRDriver ();
		virtual ~PSGHRDriver ();

	public:
		//virtual bool DriverEntry (std::string CfgFileName); //设置配制文件路径,对外接口最先调用
		virtual void Prepare () override; //在 DriverEntry 之后执行;选择与物理设备通信方式（串口、TCP）
		virtual std::string DriverProbe() override; //在 Prepare 之后执行;读取配置文件模块参数，供上层创建驱动work路径

		bool ReConnection(nsSCF::SCF& DevSCF);
		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”节点的内容

		//webconfig使用
		ResDataObject m_DeviceConfigSend;
		string g_strAppPath;
		std::unique_ptr <ResDataObject> m_pAttribute;
		std::unique_ptr <ResDataObject>  m_pDescription;
		PSGHRDevice* m_pDevice{ nullptr };
	};

}