PhysicalDevice/Generator/ECOM/CCOS.Dev.Generator.Demo/CCOS.Dev.Generator.Demo.hpp

#pragma once
#include <string>
#include "CCOS.Dev.IODevice.Detail.hpp"
#include "CCOS.Dev.Generator.Mould.hpp"
#include "CcosThread.h"
//#include "IODeviceWithSCF.tlh"
#include "DAP.BasicMoulds.hpp"
#include "CCOS.Dev.MSGMould.hpp"
#include <deque>
#include <atomic>
#include "OEM.Collimator.h"
#include "OEM.Mechanical.h"


#define _CCOSDEVGENERATORDEMO_API

namespace CCOS::Dev::Detail::Generator
{
	enum Demo_REGULATION_LEVEL { //故障等级
		REG_ERRO,
		REG_WARN
	};

	//-----------------------------------------------------------------------------
	//		GENDeviceMould
	//-----------------------------------------------------------------------------
	namespace nDev = CCOS::Dev;
	class  _CCOSDEVGENERATORDEMO_API  DemoDevice : public IODeviceDetail, public GeneratorMould
	{
		using super = IODeviceDetail;
		using superGen = GeneratorMould;

	public:
		DemoDevice(std::shared_ptr <IOEventCenter> center, string configfile = "");
		~DemoDevice();

	private:
		void OnRegister();

	public:
		//设备方法
		virtual std::string GetGUID() const 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 SetExpEnable() override;
		virtual RET_STATUS SetExpDisable()override;
		virtual RET_STATUS PrepareAcquisition()override;
		virtual RET_STATUS Reset()override;
		virtual RET_STATUS SetExpMode(std::string value) override;
		virtual RET_STATUS QueryHE(int& value) override;
		virtual RET_STATUS SetEXAMMode(std::string value) override;
		virtual RET_STATUS ActiveSyncMode(_tSyncModeArgs value) override;
		RET_STATUS StartMove();
		RET_STATUS EndMove();
		RET_STATUS DirectlyNotify(string& value);
		RET_STATUS DirectlyCMD(string& value);
		//点片
		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 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 IncMASL() override;//add by wxx for task226
		virtual RET_STATUS DecMASL() override;
		void ComputeMAS(); //fix bug5297 by wxx

		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 SetAPRArray(vector<_tAPRArgs>& APRarray) override;

		virtual RET_STATUS SetAECDensity(int value) override;
		virtual RET_STATUS IncAECDensity() override;
		virtual RET_STATUS DecAECDensity() override;
		virtual RET_STATUS SetAECField(int value) override;
		virtual RET_STATUS SetAECFilm(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 SetFrameRate(float frameRate) override;

		//透视
		virtual RET_STATUS IncFluKV() override; //透视KV调节
		virtual RET_STATUS DecFluKV() override;
		virtual RET_STATUS SetFluKV(float value) override;
		virtual RET_STATUS IncFluMA() override; //透视MA调节
		virtual RET_STATUS DecFluMA() override;
		virtual RET_STATUS SetFluMA(float value) override;
		virtual RET_STATUS IncFluMS() override; //透视MS调节
		virtual RET_STATUS DecFluMS() override;
		virtual RET_STATUS SetFluMS(float value) override;
		virtual RET_STATUS SetPPS(float frameRate) override; //脉冲透视帧率调节
		virtual RET_STATUS INCPPS() override;
		virtual RET_STATUS DECPPS() override;
		virtual RET_STATUS SetPluseWidth(float fplusewidth) override; //设置脉宽
		virtual RET_STATUS SetABSMode(int nMode) override; //设置自动亮度调节（ABS）模式
		virtual RET_STATUS SetABSCurve(int curveNum) override; //ABS曲线调节
		virtual RET_STATUS IncABSCurve() override;
		virtual RET_STATUS DecABSCurve() override;
		virtual RET_STATUS SetABSValue(float fABSValue) override;
		virtual RET_STATUS SetABSTargetEXI(float fEXIValue) override;
		virtual RET_STATUS SetAPF(const _tAPFArgs& t) override; //一次性设置透视参数
		virtual float GetFluIntTimer() override; //获取透视周期时间
		virtual float GetFluAccTimer() override; //获取透视曝光累计时间
		virtual RET_STATUS ResetFluTimer(int ntype) override; //清空透视曝光累计时间
		virtual RET_STATUS SetFluPre(int bPrepare) override; //设置透视预备阶段使能
		virtual RET_STATUS SetFluEXP(int bPrepare) override; //设置透视曝光阶段使能
		virtual RET_STATUS SetFLFMode(std::string value) override; //设置透视模式
		virtual RET_STATUS SetFluMAG(int nsize) override; //设置MG:0 to 3 - sets Mag size, ASCII character for 255 - Mag selection disabled
		virtual RET_STATUS DisableMAG() override;
		virtual RET_STATUS SetFluDoseLever(int nlever) override; //设置透视剂量等级( 0,1,2 )
		virtual RET_STATUS SetHalfDose(int nlever) override; //设置透视半价剂量
		virtual RET_STATUS TransferRadCurve(int ncurve) override; //点片KV跟随透视,0-3 Set curve 0:disable

		//为了将gen和其他设备关联，能相互调用接口
		static std::unique_ptr<OemCollimator> m_pCollDev; //遮光器逻辑实体指针
		static std::unique_ptr<OemMechanical> m_pMechDev; //机架逻辑实体指针

		RET_STATUS SetCollimatorDev(OemCollimator* dev);
		RET_STATUS SetMechDev(OemMechanical* dev);
		RET_STATUS SetCollimatorSize(int xsize, int ysize);
		RET_STATUS SetCollimatorLight(unsigned short pParams);
		RET_STATUS SetAutoTracking(int nAutoTracking);
		RET_STATUS SetFilter(int nFilterType);
		RET_STATUS SetGrid(int nGridType);
		RET_STATUS GetTomoResults(ResDataObject& resultAngle, ResDataObject& resultHeight);
		ResDataObject m_GenConfig;  //发生器配置
		atomic<int> m_iAutoExpFlag; //自动曝光流程
		int m_iStateChangeInterval; //状态切换间隔
		int m_iAutoExpActWaitTime;  //曝光动作等待时间
		bool m_bIsDemo;             //是否是Demo环境（即参数是否可调）
		ResDataObject m_resultAngle; //?
	protected:
		int GetConfData();
		std::vector <float> m_MA_List; //MA取值集合
		std::vector <float> m_MS_List; //MS取值集合
		std::vector <float> m_MAS_List; //MAS取值集合
		vector<_tAPRArgs>   m_APRarray; //APR数组,用于拼接
	private:
		std::mutex m_MSGLock; //消息上报锁
		void FireErrorMessage(const bool Act, const int Code, const char* ResInfo = ""); //上报错误消息
		void FireWarnMessage(const bool Act, const int Code, const char* ResInfo = ""); //上报告警消息
		void FireNotify(std::string key, int context);
		void FireNotify(std::string key, float context);
		void FireNotify(std::string key, std::string context);
		bool StartHardwareStatusThread();
		static void* HardwareStatusThread(void* pParam);
		pthread_t  m_pHardwareStatusThread;
		std::unique_ptr<nsDetail::MSGUnit> m_MSGUnit;          //处理消息上报对象指针
		cfgWorkStationKey m_strCurrentWSName;                  //当前工作位名称
		map<cfgWorkStationKey, cfgWorkStationData> m_arrWSMap; //工作位标记码查找表
#ifdef DEMO_SELF
#endif
	};
}

//-----------------------------------------------------------------------------
//		DEMODriver
//-----------------------------------------------------------------------------

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

	public:

		virtual void Prepare() override;

		virtual bool  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;

		virtual bool GetDeviceConfig(std::string& Cfg) override;
		virtual bool SetDeviceConfig(std::string Cfg) override;
	private:
		static int callbackPackageProcess(const char* RecData, DWORD nLength, DWORD& PacketLength);

		bool m_bDemoMode;
		bool m_bDemoConnected;	//	在 DEMO 模式下, 调用过 Connect 吗?
		DemoDevice* m_pDriGenDev;// = nullptr;
		OemCollimator* m_pDriCollDev;// = nullptr;
		OemMechanical* m_pDriMechDev;// = nullptr;
		bool m_bDemoInitDataFlag;	//是否存在初始化数据
		ResDataObject m_InitDataFile;

		//为了webconfig
		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;

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




	};

}