// CCOS.Dev.GEN.Almax.cpp : 定义 DLL 应用程序的导出函数。 // #include "stdafx.h" #include #include #include using namespace std::placeholders; #include "Helper.JSON.hpp" #include "CCOS.Dev.Generator.ContainerExample.h" using namespace CCOS::Dev::Detail::Generator; namespace nsGEN = CCOS::Dev::Detail::Generator; //关闭无关警告 #pragma warning (disable:4244) // warning C4244: “初始化”: 从“double”转换到“float”，可能丢失数据 #pragma warning (disable:4305) // warning C4305: “参数”: 从“double”到“float”截断 #pragma warning (disable:4267) // warning C4267 : “初始化”: 从“size_t”转换到“int”，可能丢失数据 #pragma warning (disable:4805) // warning C4805: “!=”: 在操作中将类型“bool”与类型“int”混合不安全 //全局定义 static nsGEN::AlmaxDriver* pIODriver = nullptr; //指令头 #define Almax_CMD_GetGenVer "C0" //5.1.1.MESSAGE TYPE C0H #define Almax_CMD_SetLanguage "82" //5.1.2.MESSAGE TYPE 82H #define Almax_CMD_SetAPRAPF "38" //5.1.3.MESSAGE TYPE 38H #define Almax_CMD_SetAnatomic "39" //5.1.4.MESSAGE TYPE 39H 解剖 #define Almax_CMD_SetProject "3A" //5.1.5.MESSAGE TYPE 3AH #define Almax_CMD_SetFluPPS "3C" //5.1.6.MESSAGE TYPE 3CH #define Almax_CMD_SetRadPPS "3D" //5.1.7.MESSAGE TYPE 3DH #define Almax_CMD_SetRadDose "49" //5.1.8.MESSAGE TYPE 49H #define Almax_CMD_SetAcqData "4A" //5.1.9.MESSAGE TYPE 4AH 采集透视数据 #define Almax_CMD_SetABSKV "4B" //5.1.10. MESSAGE TYPE 4BH #define Almax_CMD_GetABSKV "4C" //5.1.11. MESSAGE TYPE 4CH #define Almax_CMD_SetABSGrey "4E" //5.1.12. MESSAGE TYPE 4EH #define Almax_CMD_GetStatus "50" //5.1.13. MESSAGE TYPE 50H #define Almax_CMD_GetRPData "51" //5.1.14. MESSAGE TYPE 51H #define Almax_CMD_GetFluDose "52" //5.1.15. MESSAGE TYPE 52H #define Almax_CMD_GetRadDose "53" //5.1.16. MESSAGE TYPE 53H #define Almax_CMD_SetFPDTemp "54" //5.1.17. MESSAGE TYPE 54H #define Almax_CMD_SetNewExam "55" //5.1.18. MESSAGE TYPE 55H #define Almax_CMD_SetlowDose "56" //5.1.19. MESSAGE TYPE 56H #define Almax_CMD_SetPatient "58" //5.1.21. MESSAGE TYPE 58H #define Almax_CMD_SetPhysique "59" //5.1.22. MESSAGE TYPE 59H #define Almax_CMD_ResKeyEvent "00" //6.1.1.MESSAGE TYPE 00H #define Almax_CMD_ResGenVer "81" //6.1.2.MESSAGE TYPE 81H (作为消息 83H 的替代方案) #define Almax_CMD_ResArchVer "83" //6.1.3.MESSAGE TYPE 83H (作为消息 81H 的替代方案) #define Almax_CMD_ResExam "3E" //6.1.4.MESSAGE TYPE 3EH #define Almax_CMD_ResPhysique "3F" //6.1.5.MESSAGE TYPE 3FH #define Almax_CMD_ResABSKV "4D" //6.1.6.MESSAGE TYPE 4DH #define Almax_CMD_ReslowDose "57" //6.1.7.MESSAGE TYPE 57H #define Almax_CMD_ResFluPost "72" //6.1.8.MESSAGE TYPE 72H #define Almax_CMD_ResFLUPost "73" //6.1.9.MESSAGE TYPE 73H #define Almax_CMD_ResRadPost "7B" //6.1.10. MESSAGE TYPE 7BH #define Almax_CMD_ResRADPost "74" //6.1.11. MESSAGE TYPE 74H #define Almax_CMD_ResRPData "91" //6.1.12. MESSAGE TYPE 91H #define Almax_CMD_ResStatus "76" //6.1.13. MESSAGE TYPE 76H #define Almax_CMD_ResSID "77" //6.1.14. Message Type 77H #define Almax_CMD_ResCollData "7E" //6.1.15. MESSAGE TYPE 7EH #define Almax_CMD_ResRotating "7F" //6.1.16. MESSAGE TYPE 7FH #define Almax_CMD_ResErrWarn "80" //6.1.17. MESSAGE TYPE 80H //设置相关常量 static const int msTimeOut_Lock = 500; //通讯接口锁定时间 #define Almax_Com_NormalLen 300 #define Almax_LoopDefHBTime 1000 #define Almax_LoopExpHBTime 500 #define Almax_STX 0x02 #define Almax_ETX 0x03 #define Almax_ACK 0x06 #define Almax_NAK 0x15 /* *串口/以太网通信帧格式: 解释: = 1 ASCII 0x02 帧头 = 1 ASCII指令头+不定长属性项、属性值 = 校验和 = 1 ASCII 0x03 帧尾 串口通信设置: . 19200 波特率 . No Parity . 8 Data Bits . 2 Stop Bit . 无握手过程 */ //设置对应通信接口库 #ifdef _WIN64 #ifdef _DEBUG static const auto COM_SCFDllName = "Ccos.Dev.SerialSCFX64D.dll"; #else static const auto COM_SCFDllName = "Ccos.Dev.SerialSCFX64.dll"; #endif #endif #ifdef _WIN64 #ifdef _DEBUG static const auto TCP_SCFDllName = "Ccos.Dev.TcpipSCFX64D.dll"; #else static const auto TCP_SCFDllName = "Ccos.Dev.TcpipSCFX64.dll"; #endif #endif Log4CPP::Logger* gLogger = nullptr; //指令操作关联结构 nsGEN::tFrameMapItem::tFrameMapItem() { m_fFun = NULL; } nsGEN::tFrameMapItem::tFrameMapItem(cbFun f) { m_fFun = f; } nsGEN::tFrameMapItem& nsGEN::tFrameMapItem::operator =(const tFrameMapItem& value) { m_fFun = value.m_fFun; return *this; } //响应操作对照表 static std::map arFrame; //生成命令校验和:cmdData 为 ; size:指令长度+1 BYTE CheckSum char ComputeCheckSum(const char* cmdData, int& size) { try { char AsciiSum = 0x00; if (size < 2) //1 BYTE CMD_ID + 1 BYTE Reserved { FDEBUG("ComputeCheckSum:failed[0x00]"); return AsciiSum; } for (int i = 0; i < size; i++) //每字节相加 { AsciiSum ^= cmdData[i]; } FDEBUG("ComputeCheckSum:[0x{$:x}]", AsciiSum); return (char)AsciiSum; } catch (...) { FDEBUG("ComputeCheckSum:Error[0x00]"); return 0x00; } } //查找响应操作对照表执行对应操作 static bool DecodeFrame(const char* strFrame, int length) { char data[Almax_Com_NormalLen] = { 0 }; strncpy_s(data, strFrame+1, 2); auto found = arFrame.find(data);//此处pr用来在arFrame中找到对于的包头 if (found == arFrame.end()) { return false; } //found->second.tChangeWaitState(0, data); int cmdHead = found->first.length(); memcpy(data, strFrame + cmdHead + 1, length - cmdHead - 1); found->second.m_fFun(data, length - cmdHead);//第二个参数 不重要 return true; } //取值集合 std::vector g_MAS_List = { 0.5,0.6,0.8,1,1.6,2,2.5,3.2,4,5,6.3,8,10,12.5,16,20,25,32,40,50,63,71,80,100,125,160,200,250,320,400,500,630 }; std::vector g_MS_List = { 5,6,8,10,12,16,20,25,32,40,50,63,80,100,125,160,200,250,320,400,500,630,800,1000,1250,1600,2000,2500,3200,4000,5000,6300,8000,10000 }; //----------------------------------------------------------------------------- // AlmaxDevice //----------------------------------------------------------------------------- atomic nsGEN::AlmaxDevice::m_bExtraFlag = false; atomic nsGEN::AlmaxDevice::m_iLoopTime = Almax_LoopDefHBTime; nsSerialGPM::CDeliverModule nsGEN::AlmaxDevice::m_tDelivermodule; static atomicHeartBeatFlag = false; nsGEN::AlmaxDevice::AlmaxDevice(std::shared_ptr center, nsSCF::SCF SCF, string configfile) : super(center, SCF) { assert(EventCenter); //其余属性初始化 ResDataObject temp; temp.loadFile(configfile.c_str()); m_GenConfig = temp["CONFIGURATION"]; m_pHardwareStatusThread = NULL; m_bExpEnable = false; m_iHeartBeats = 0; m_bConnectFlag = true; m_iLoopTime.store(Almax_LoopDefHBTime); //两种日志方式自行选择 string version; if(GetVersion(version, hMyModule)) FINFO("\n===============log begin : version:{$} ===================\n", version.c_str()); else FINFO("\n===============log begin : version:0.0.0.0 ===================\n"); //点片参数 m_DoseUnit.m_KV.reset(new KVMould(40.0, 40.0, 150.0, 1.0)); //接口协议范围:40-150 m_DoseUnit.m_MA.reset(new MAMould(10.0, 0, 1000, 0.1)); //接口协议范围:10-1000 m_DoseUnit.m_MS.reset(new MSMould(500.0, 0, 65535, 0.01));//接口协议范围:0-65535 m_DoseUnit.m_MAS.reset(new MASMould(0.5, 0, 1000.0, 0.01)); //接口协议范围:0.5-1000 m_DoseUnit.m_Techmode.reset(new TECHMODEMould(AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P, AttrKey::TECHMODE_NOAEC_3P, AttrKey::TECHMODE_AEC_MAS_MA, 1)); m_DoseUnit.m_WS.reset(new WORKSTATIONMould(1, 0, 5, 1)); m_DoseUnit.m_Focus.reset(new FOCUSMould(AttrKey::FOCUS_TYPE::FOCUS_LARGE, AttrKey::FOCUS_SMALL, AttrKey::FOCUS_LARGE, 1)); m_DoseUnit.m_AECField.reset(new AECFIELDMould(0, 0, 111, 1)); m_DoseUnit.m_AECFilm.reset(new AECFILMMould(0, 0, 2, 1)); m_DoseUnit.m_AECDensity.reset(new AECDENSITYMould(0, -4, 4, 1)); m_DoseUnit.m_HE.reset(new TUBEHEATMould(0, 0, 100, 1)); m_DoseUnit.m_GenSynState.reset(new GENSYNSTATEMould(AttrKey::GENERATOR_RAD_OFF, AttrKey::GENERATOR_SYNC_ERR, AttrKey::GENERATOR_SYNC_MAX, 1)); m_DoseUnit.m_GenState.reset(new GENSTATEMould(0, AttrKey::GENERATOR_STATUS_SHUTDOWN, AttrKey::GENERATOR_STATUS_NOWORK, 1)); m_DoseUnit.m_GenTotalExpNumber.reset(new TOTALEXPNUMMould(0, 0, 9999, 1)); m_DoseUnit.m_GenTotalAcqTimes.reset(new TOTALACQTIMESMould(0, 0, 9999, 1)); m_DoseUnit.m_GenTubeCoolWaitTimes.reset(new TUBECOOLTIMEMould(0, 0, 9999, 1)); m_DoseUnit.m_GenTubeOverLoadNumber.reset(new TUBEOVERLOADNUMMould(0, 0, 9999, 1)); m_DoseUnit.m_GenCurrentExpNumber.reset(new CUREXPNUMMould(0, 0, 9999, 1)); m_DoseUnit.m_ExpMode.reset(new EXPMODEMould(EXPMODE_TYPE::Single)); m_DoseUnit.m_FrameRate.reset(new FRAMERATEMould(0, 0, 16, 1)); m_DoseUnit.m_FLFMode.reset(new FLFMODEMould(FLFMODE_TYPE::FLF_DISB)); m_DoseUnit.m_BatteryChargeState.reset(new BATTERYCHARGSTATEMould(0, 0, 1, 1)); m_DoseUnit.m_TubeTargetMaterial.reset(new TUBETARGETMATERIALMould(TUBETARGETMATERIAL_TYPE::MO)); m_DoseUnit.m_TubeAngle.reset(new TUBEANGLEMould(0, -45, 45, 1)); //动态参数 std::unique_ptr m_FLKV; std::unique_ptr m_FLMA; std::unique_ptr m_FLMS; std::unique_ptr m_FLAccTime;//透视累计时间 std::unique_ptr m_FLIntTime;//脉冲周期时间 std::unique_ptr m_PPS;//帧率 std::unique_ptr m_FLMode;//透视模式: 0-非透视, 1-连续,2-脉冲,3-高剂量连续,4-高剂量脉冲 std::unique_ptr m_ABSStatus;//ABS状态: 0-ABS关闭, 1-ABS启用(KV only), 2 - ABS启用(KV/mA) std::unique_ptr m_MagSize;//fluoro mag 0 to 3 - sets Mag size, ASCII character for 255 - Mag selection disabled std::unique_ptr m_DoseLevel;//剂量模式，DOSE_LEVEL_LOW = 0, DOSE_LEVEL_NORMAL = 1, DOSE_LEVEL_HIGH = 2 ,后来由于需要分开cine的dose level和 透视的dose level 互不影响，所以约定 10以后的值 给cine 使用。 std::unique_ptr m_Curve;//ABS曲线 0 = OFF, 1-3 = curve enabled //cine std::unique_ptr m_CineFLKV;// std::unique_ptr m_CineFLMA;// std::unique_ptr m_CineFLMS;// //实际曝光参数值 m_DoseUnit.m_PostKV.reset(new POSTKVMould(0.0, 0.0, 50.0, 1.0)); m_DoseUnit.m_PostMA.reset(new POSTMAMould(0.0, 0.0, 200.0, 0.1)); m_DoseUnit.m_PostMS.reset(new POSTMSMould(0.0, 0.0, 12000.0, 0.01)); m_DoseUnit.m_PostMAS.reset(new POSTMASMould(0.0, 0.0, 600.0, 0.01)); //发生器告警及错误消息 m_MSGUnit.reset(new nsDetail::MSGUnit(center, nsGEN::GeneratorUnitType)); if (m_GenConfig.GetKeyCount("loopEnable") > 0) { m_bExtraFlag = (int)m_GenConfig["loopEnable"]; } if (m_GenConfig.GetKeyCount(ConfKey::CcosTubeInfo) > 0) { string tempValue = m_GenConfig[ConfKey::CcosTubeInfo]; m_DoseUnit.m_TubeInfo.reset(new TUBEINFOMould(tempValue)); FireNotify(AttrKey::TUBEINFO, m_DoseUnit.m_TubeInfo->JSGet()); } if (m_GenConfig.GetKeyCount(ConfKey::CcosFocusSmall) > 0) { float tempValue = (float)m_GenConfig[ConfKey::CcosFocusSmall]; m_DoseUnit.m_FocusSmall = tempValue; } if (m_GenConfig.GetKeyCount(ConfKey::CcosFocusLarge) > 0) { float tempValue = (float)m_GenConfig[ConfKey::CcosFocusLarge]; m_DoseUnit.m_FocusLarge = tempValue; } m_tDelivermodule.InitSendModle(this, &ProcessClientData, WriteLog); m_nCMDType_WaitTime = m_tDelivermodule.SetPriority(true, false, false, true, 100); m_nCMDType_HB = m_tDelivermodule.SetPriority(false, true, false, true, 100); m_nCMDType_WaitACK = m_tDelivermodule.SetPriority(true, false, 3, false, 0,true,1000); FINFO("m_nCMDType_WaitTime[{$}]m_nCMDType_HB[{$}] m_nCMDType_WaitACK[{$}]", m_nCMDType_WaitTime, m_nCMDType_HB, m_nCMDType_WaitACK); //配置响应操作对照表 供发生器回传的数据触发相应的操作 OnCallBack(); //将发生器可以对外提供的指令注册集进行补充 Register(); //重置发生器 Reset(); Sleep(500); //以下进行默认设置，需要注意默认值是否正确 RefreshData(); //刷新初始数值 //启动硬件状态轮询进程 StartHardwareStatusThread(); } nsGEN::AlmaxDevice::~AlmaxDevice() { m_bExtraFlag = false; FINFO("\n===============log end ===================\n"); if (m_pHardwareStatusThread != NULL) { TerminateThread(m_pHardwareStatusThread, 0); m_pHardwareStatusThread = NULL; } arFrame.clear(); } std::string nsGEN::AlmaxDevice::GetGUID() const { FINFO("===============GetGUID : {$} ===================\n", GeneratorUnitType); return GeneratorUnitType; } void nsGEN::AlmaxDevice::Register() { auto Disp = Dispatch.Lock().As(); superGen::Register(Disp); superGen::RegisterKV(Disp); superGen::RegisterMA(Disp); superGen::RegisterMS(Disp); superGen::RegisterMAS(Disp); superGen::RegisterAEC(Disp); superGen::RegisterFOCUS(Disp); superGen::RegisterTECHMODE(Disp); superGen::RegisterExpEnable(Disp); superGen::RegisterGeneratortoSyncStatus(Disp); Disp->Get.Push(m_MSGUnit->GetKey().c_str(), [this](std::string& out) { out = m_MSGUnit->JSGet(); return RET_STATUS::RET_SUCCEED; }); auto fun_Clear_DAP = [this](auto in, auto& out) { return Clear_DAP(); }; Disp->Action.Push("Clear_DAP", fun_Clear_DAP); auto fun_GetValue_DAP = [this](auto in, auto& out) { float value = 0; RET_STATUS ret = GetValue_DAP(value); out = ToJSON(value); return ret; }; Disp->Action.Push("GetValue_DAP", fun_GetValue_DAP); auto fun_StartMove = [this](auto in, auto& out) { return StartMove(); }; Disp->Action.Push("StartMove", fun_StartMove); auto fun_EndMove = [this](auto in, auto& out) { return EndMove(); }; Disp->Action.Push("EndMove", fun_EndMove); } RET_STATUS nsGEN::AlmaxDevice::IncKV() { if (!m_DoseUnit.m_KV->CanInc()) return RET_STATUS::RET_SUCCEED; float oldKV= m_DoseUnit.m_KV->Get(); oldKV++; oldKV *= 1000; char temp[50] = { 0 }; sprintf_s(temp, "10,%d,", (int)round(oldKV / 12.21)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::DecKV() { if (!m_DoseUnit.m_KV->CanDec()) return RET_STATUS::RET_SUCCEED; float oldKV = m_DoseUnit.m_KV->Get(); oldKV--; oldKV *= 1000; char temp[50] = { 0 }; sprintf_s(temp, "10,%d,", (int)round(oldKV / 12.21)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::SetKV(float value) { if (!m_DoseUnit.m_KV->Verify(value)) return RET_STATUS::RET_SUCCEED; char temp[50] = { 0 }; sprintf_s(temp, "10,%d,", (int)round(value * 1000 / 12.21)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::IncMA() { if (!m_DoseUnit.m_MA->CanInc()) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { FINFO("Techmode is 2Point, Cannot inc MA \n"); return RET_STATUS::RET_FAILED; } float oldMA = m_DoseUnit.m_MA->Get(); oldMA++; char temp[50] = { 0 }; sprintf_s(temp, "11,%d,", (int)round(oldMA / 0.04884)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::DecMA() { if (!m_DoseUnit.m_MA->CanDec()) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { FINFO("Techmode is 2Point, Cannot dec MA \n"); return RET_STATUS::RET_FAILED; } float oldMA = m_DoseUnit.m_MA->Get(); oldMA--; char temp[50] = { 0 }; sprintf_s(temp, "11,%d,", (int)round(oldMA / 0.04884)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::SetMA(float value) { if (!m_DoseUnit.m_MA->Verify(value)) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { FINFO("Techmode is 2Point, Cannot set MA \n"); return RET_STATUS::RET_FAILED; } char temp[50] = { 0 }; sprintf_s(temp, "11,%d,", (int)round(value / 0.04884)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::IncMS() { if (!m_DoseUnit.m_MS->CanInc()) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { FINFO("Techmode is 2Point, Cannot inc MS \n"); return RET_STATUS::RET_FAILED; } float oldMS = m_DoseUnit.m_MS->Get(); oldMS++; char temp[50] = { 0 }; sprintf_s(temp, "72,%d,", (int)(oldMS)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::DecMS() { if (!m_DoseUnit.m_MS->CanDec()) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { FINFO("Techmode is 2Point, Cannot dec MS \n"); return RET_STATUS::RET_FAILED; } float oldMS = m_DoseUnit.m_MS->Get(); oldMS--; char temp[50] = { 0 }; sprintf_s(temp, "72,%d,", (int)(oldMS)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::SetMS(float value) { if (!m_DoseUnit.m_MS->Verify(value)) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { FINFO("Techmode is 2Point, Cannot set MS \n"); return RET_STATUS::RET_FAILED; } char temp[50] = { 0 }; sprintf_s(temp, "72,%d,", (int)(value)); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::IncMAS() { if (!m_DoseUnit.m_MAS->CanInc()) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P) { FINFO("Techmode is 3Point, Cannot inc MAS \n"); return RET_STATUS::RET_FAILED; } float oldMAS = m_DoseUnit.m_MAS->Get(); if (m_DoseUnit.m_MAS->CanToNext(oldMAS, g_MAS_List)) { FDEBUG("IncMAS:inc MAS[{$}]->[{$}]", m_DoseUnit.m_MAS->Get(), oldMAS); char temp[50] = { 0 }; sprintf_s(temp, "74,%d,", (int)round(oldMAS / 0.1)); return HWSendWaittimeCMD(temp, strlen(temp)); } else { FERROR("IncMAS:Cannot inc MAS[{$}]", m_DoseUnit.m_MAS->Get()); return RET_STATUS::RET_FAILED; } return RET_STATUS::RET_FAILED; } RET_STATUS nsGEN::AlmaxDevice::DecMAS() { if (!m_DoseUnit.m_MAS->CanDec()) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P) { FINFO("Techmode is 3Point, Cannot dec MAS \n"); return RET_STATUS::RET_FAILED; } float oldMAS = m_DoseUnit.m_MAS->Get(); if (m_DoseUnit.m_MAS->CanToPrev(oldMAS, g_MAS_List)) { FDEBUG("DecMAS:dec MAS[{$}]->[{$}]", m_DoseUnit.m_MAS->Get(), oldMAS); char temp[50] = { 0 }; sprintf_s(temp, "74,%d,", (int)round(oldMAS / 0.1)); return HWSendWaittimeCMD(temp, strlen(temp)); } else { FERROR("DecMAS:Cannot dec MAS[{$}]", m_DoseUnit.m_MAS->Get()); return RET_STATUS::RET_FAILED; } return RET_STATUS::RET_FAILED; } RET_STATUS nsGEN::AlmaxDevice::SetMAS(float value) { if (!m_DoseUnit.m_MAS->Verify(value)) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P) { FINFO("Techmode is 3Point, Cannot set MAS \n"); return RET_STATUS::RET_FAILED; } float tempValue = value; if (m_DoseUnit.m_MAS->CanToUpdate(tempValue, g_MAS_List)) { FDEBUG("UpdateMAS:update MAS[{$}]->[{$}]->[{$}]", m_DoseUnit.m_MAS->Get(), value, tempValue); char temp[50] = { 0 }; sprintf_s(temp, "74,%d,", (int)round(tempValue / 0.1)); return HWSendWaittimeCMD(temp, strlen(temp)); } else { FERROR("UpdateMAS:Cannot set MAS[{$}]->[{$}]", value, tempValue); return RET_STATUS::RET_FAILED; } return RET_STATUS::RET_FAILED; } RET_STATUS nsGEN::AlmaxDevice::SetTechmode(int value) { if (!m_DoseUnit.m_Techmode->Verify(value)) return RET_STATUS::RET_SUCCEED; FINFO("SetTechmode:[{$}] \n", value); switch (value) { case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P: { HWSendWaitACKCMD("55,0,", 5, 3); HWSendWaitACKCMD("57,0,", 5, 3); } break; case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P: { HWSendWaitACKCMD("55,1,", 5, 3); HWSendWaitACKCMD("57,0,", 5, 3); } break; case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P: { HWSendWaitACKCMD("55,0,", 5, 3); HWSendWaitACKCMD("57,1,", 5, 3); } break; case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P: { HWSendWaitACKCMD("55,1,", 5, 3); HWSendWaitACKCMD("57,1,", 5, 3); } break; default: break; } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetEXAMMode(std::string value) //DMOC实际是通过此接口设置是否启用AEC { //上层给我设置exam mode（manual semiauto automatic）对应（NoAEC2Point AEC2Point AEC2Point） FINFO("Enter setexammode func value = {$}\n", value); if (value == EXAMMODE_TYPE::MANUAL) { //if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P) { SetTechmode(AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P); } } else if (value == EXAMMODE_TYPE::SEMIAUTO) { //if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { SetTechmode(AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P); } } else if (value == EXAMMODE_TYPE::AUTOMATIC) { //if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { SetTechmode(AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P); } } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetAPR(const _tAPRArgs& t) { FINFO("APR:KV={$},MA={$},MS={$},MAS={$},Focus={$},Techmode={$},WS={$},AECDensity={$},AECField={$},AECFilm={$}", t.fKV, t.fMA, t.fMS, t.fMAS, t.nFocus, t.nTechmode, t.nWS, t.nAECDensity, t.nAECField, t.nAECFilm); if (!m_DoseUnit.m_KV->Verify(t.fKV)) { FERROR("SetAPR:KV Out of bounds[{$}] \n", t.fKV); } else if (!m_DoseUnit.m_MA->Verify(t.fMA) && (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P)) { FERROR("SetAPR:MA Out of bounds[{$}] \n", t.fMA); } else if (!m_DoseUnit.m_MS->Verify(t.fMS) && (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P)) { FERROR("SetAPR:MS Out of bounds[{$}] \n", t.fMS); } else if (!m_DoseUnit.m_MAS->Verify(t.fMAS) && (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P)) { FERROR("SetAPR:MAS Out of bounds[{$}] \n", t.fMAS); //add by wxx for test float oldKV = m_DoseUnit.m_KV->Get(); float oldMAS = m_DoseUnit.m_MAS->Get(); float oldMA = m_DoseUnit.m_MA->Get(); float oldMS = m_DoseUnit.m_MS->Get(); int oldFocus = m_DoseUnit.m_Focus->Get(); FERROR("SetAPR:old KV[{$}],MAS[{$}],MA[{$}],Focus[{$}]", oldKV, oldMAS, oldMA, oldFocus); char temp[50] = { 0 }; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P) { char temp[50] = { 0 }; sprintf_s(temp, "50,%d,%d,%d,%d,", (int)(oldMS), (int)round(oldKV * 1000 / 12.21), (int)round(oldMA / 0.04884), (int)(oldFocus)); return HWSendWaittimeCMD(temp, strlen(temp)); } else if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { char temp[50] = { 0 }; sprintf_s(temp, "10,%d,", (int)round(oldKV * 1000 / 12.21)); HWSendWaittimeCMD(temp, strlen(temp)); float tempValue = oldMAS; if (m_DoseUnit.m_MAS->CanToUpdate(tempValue, g_MAS_List)) { FDEBUG("SetAPR:update MAS[{$}]->[{$}]->[{$}]", m_DoseUnit.m_MAS->Get(), oldFocus, tempValue); char temp[50] = { 0 }; sprintf_s(temp, "74,%d,", (int)round(tempValue / 0.1)); HWSendWaittimeCMD(temp, strlen(temp)); } } } else if (!m_DoseUnit.m_Focus->Verify(t.nFocus)) { FERROR("SetAPR:Focus Out of bounds[{$}] \n", t.nFocus); } else { if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P) { char temp[50] = { 0 }; sprintf_s(temp, "50,%d,%d,%d,%d,", (int)(t.fMS), (int)round(t.fKV * 1000 / 12.21), (int)round(t.fMA / 0.04884), (int)(t.nFocus)); return HWSendWaittimeCMD(temp, strlen(temp)); } else if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { char temp[50] = { 0 }; sprintf_s(temp, "10,%d,", (int)round(t.fKV * 1000 / 12.21)); HWSendWaittimeCMD(temp, strlen(temp)); float tempValue = t.fMAS; if (m_DoseUnit.m_MAS->CanToUpdate(tempValue, g_MAS_List)) { FDEBUG("SetAPR:update MAS[{$}]->[{$}]->[{$}]", m_DoseUnit.m_MAS->Get(), t.fMAS, tempValue); char temp[50] = { 0 }; sprintf_s(temp, "74,%d,", (int)round(tempValue / 0.1)); HWSendWaittimeCMD(temp, strlen(temp)); } } } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::RefreshData() { FDEBUG("RefreshData:processing begin \n"); //HWSendWaittimeCMD("51,",3); //HWSendWaittimeCMD("54,",3); HWSendWaittimeCMD("22,", 3); return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetFocus(int value) { if (!m_DoseUnit.m_Focus->Verify(value)) return RET_STATUS::RET_SUCCEED; char temp[50] = { 0 }; sprintf_s(temp, "73,%01d,", (int)value); return HWSendWaittimeCMD(temp,strlen(temp)); } RET_STATUS nsGEN::AlmaxDevice::Reset() { FDEBUG("clear all errors \n"); int level = 0; m_MSGUnit->DelErrorMessage("0", level, "clear all errors"); HWSendWaittimeCMD("31,",3);//仅重置错误状态 return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::QueryHE(int& value) //实际为主动上报 { //value = m_DoseUnit.m_HE->Get(); HWSendWaittimeCMD("77,",3); return RET_STATUS::RET_SUCCEED; } //Almax发生器不支持的通用操作 RET_STATUS nsGEN::AlmaxDevice::SetAECDensity(int value) //发生器无此设置 { if (!m_DoseUnit.m_AECDensity->Verify(value)) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P) { FINFO("Techmode is not AEC, Cannot set Density \n"); return RET_STATUS::RET_FAILED; } m_DoseUnit.m_AECDensity->Update(value); return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetAECField(int value) //发生器无此设置 { if (!m_DoseUnit.m_AECField->Verify(value)) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P) { FINFO("Techmode is not AEC, Cannot set Field \n"); return RET_STATUS::RET_FAILED; } m_DoseUnit.m_AECField->Update(value); return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetAECFilm(int value) //发生器无此设置 { if (!m_DoseUnit.m_AECFilm->Verify(value)) return RET_STATUS::RET_SUCCEED; if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P) { FINFO("Techmode is not AEC, Cannot set Film \n"); return RET_STATUS::RET_FAILED; } m_DoseUnit.m_AECFilm->Update(value); return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetWS(const string value) //发生器无此设置 { FINFO("Enter SetWS {$}", value); int tempws = 0; if (value == "Table") tempws = (int)m_GenConfig["WSTable"]; else if (value == "Wall") tempws = (int)m_GenConfig["WSWall"]; else if (value == "Direct") tempws = (int)m_GenConfig["WSConventional"]; else if (value == "Free") tempws = (int)m_GenConfig["WSFree"]; else if (value == "Tomo") tempws = (int)m_GenConfig["WSTomo"]; m_DoseUnit.m_WS->Update(tempws); return RET_STATUS::RET_SUCCEED; } int nsGEN::AlmaxDevice::GetGeneratorBatteryChargState() //实际为主动上报 { return m_DoseUnit.m_BatteryChargeState->Get(); } RET_STATUS nsGEN::AlmaxDevice::QueryPostKV(float& value) //实际为主动上报 { if (m_DoseUnit.m_PostKV->Get() > 0) { value = m_DoseUnit.m_PostKV->Get(); } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::QueryPostMA(float& value) //实际为主动上报 { if (m_DoseUnit.m_PostMA->Get() > 0) { value = m_DoseUnit.m_PostMA->Get(); } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::QueryPostMS(float& value) //实际为主动上报 { if (m_DoseUnit.m_PostMS->Get() > 0) { value = m_DoseUnit.m_PostMS->Get(); } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::QueryPostMAS(float& value) //实际为主动上报 { if (m_DoseUnit.m_PostMAS->Get() > 0) { value = m_DoseUnit.m_PostMAS->Get(); } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::Clear_DAP() //发生器无此设置 { return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::GetValue_DAP(float& value) //发生器无此设置 { //value = m_DAP->Get(); return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::StartMove() //发生器无此设置 { return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::EndMove() //发生器无此设置 { return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetGenSynState(int value) //发生器无此设置:AEC二阶段曝光使用 { FDEBUG("Enter SetGenSynState[{$}]->[{$}]", m_DoseUnit.m_GenSynState->Get(), value); if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_MAS_MA) { if (value == nsGEN::AttrKey::GENERATOR_RAD_XRAYON) { FDEBUG("SetGenSynState:get Gen Status_5:RAD_READY(PR2) -> X-Ray On(XR1)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_XRAYON)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } else if (value == nsGEN::AttrKey::GENERATOR_RAD_OFF) { float CurrtLastKV = m_DoseUnit.m_PostKV->Get(); FDEBUG("SetGenSynState:get CurrtLastKV [{$}]", CurrtLastKV); FireNotify(AttrKey::POSTKV, m_DoseUnit.m_PostKV->JSGet()); float CurrtLastMA = m_DoseUnit.m_PostMA->Get(); float CurrtLastMS = m_DoseUnit.m_PostMS->Get(); float CurrtLastMAS = CurrtLastMS * CurrtLastMA / 1000; FDEBUG("SetGenSynState:CurrtLastMS[{$}] and CurrtLastMA[{$}] compute CurrtLastMAS[{$}]", CurrtLastMS, CurrtLastMA, CurrtLastMAS); m_DoseUnit.m_PostMAS->Update(CurrtLastMAS); FireNotify(AttrKey::POSTMAS, m_DoseUnit.m_PostMAS->JSGet()); FDEBUG("SetGenSynState:get Gen Status_5:X-Ray On(XR1) -> RAD_OFF(PR0)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_OFF)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } } return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetGenState(int value) //发生器无此设置 { return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetExpMode(std::string value) //发生器无此设置 { FINFO("Enter SetExpMode...{$} \n",value); m_DoseUnit.m_ExpMode->Update(value); //add for dcm img hard FINFO("SetExpMode:add for dcm img hard"); FireNotify(m_DoseUnit.m_TubeTargetMaterial->GetKey(), m_DoseUnit.m_TubeTargetMaterial->JSGet()); FireNotify(m_DoseUnit.m_TubeAngle->GetKey(), m_DoseUnit.m_TubeAngle->JSGet()); return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetFLFMode(std::string value) //发生器无此动态设置 { return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetFrameRate(FLOAT frameRate) //发生器无此动态设置 { m_DoseUnit.m_FrameRate->Update(frameRate); return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetRPS(int rps) //发生器无此动态设置 { return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetExpEnable() //发生器无此设置 { //HWSendWaittimeCMD("31,",3); //清空错误 return RET_STATUS::RET_SUCCEED; } RET_STATUS nsGEN::AlmaxDevice::SetExpDisable() //发生器无此设置 { return RET_STATUS::RET_SUCCEED; } //Almax发生器特有功能 //----------------------------------------------------------------------------- // ProcessCmd //----------------------------------------------------------------------------- void nsGEN::AlmaxDevice::ProcessClientData(const char* pData, unsigned long nDataLength, void* lparam) { AlmaxDevice* pCurGen = (AlmaxDevice*)lparam; pCurGen->HWSend(pData, nDataLength); } void nsGEN::AlmaxDevice::WriteLog(const char* pData, nsSerialGPM::LOG_V2_LEVEL level) { switch (level) { case nsSerialGPM::LOG_V2_FATAL: case nsSerialGPM::LOG_V2_ERROR: FERROR(pData); break; case nsSerialGPM::LOG_V2_WARNING: FWARN(pData); break; case nsSerialGPM::LOG_V2_DEBUG: FDEBUG(pData); break; case nsSerialGPM::LOG_V2_INFO: FINFO(pData); break; default: break; } } RET_STATUS nsGEN::AlmaxDevice::HWSendWaittimeCMD(char* strCommand, int lengh, int headLengh) { return m_tDelivermodule.ProcessCommand(strCommand, lengh, m_nCMDType_WaitTime, headLengh); } RET_STATUS nsGEN::AlmaxDevice::HWSendHBCMD(char* strCommand, int lengh, int headLengh) { return m_tDelivermodule.ProcessCommand(strCommand, lengh, m_nCMDType_HB, headLengh); } RET_STATUS nsGEN::AlmaxDevice::HWSendWaitACKCMD(char* strCommand, int lengh, int headLengh) { return m_tDelivermodule.ProcessCommand(strCommand, lengh, m_nCMDType_WaitACK, headLengh); } RET_STATUS nsGEN::AlmaxDevice::HWSend(const char* strCommand,int lengh, bool reSend, int nTimeOut) { if (!m_bConnectFlag) { FERROR("==OUT==: not Connect,[{$:x2}] send failed \n", strCommand[0]); return RET_STATUS::RET_FAILED; } if (!m_SCF) return RET_STATUS::RET_FAILED; char checkSum = ComputeCheckSum(strCommand, lengh); if (checkSum == 0x00) { FERROR("HWSend: cmd[{$:x2}] Check Sum failed \n", strCommand[0]); return RET_STATUS::RET_FAILED; } string cmdText{ "" }; string tempTransmit; cmdText += Almax_STX; for (int i = 0; i < lengh; i++) { tempTransmit = std::format("{:02X}", strCommand[i]); cmdText += tempTransmit; } tempTransmit = std::format("{:02X}", checkSum); cmdText += tempTransmit; cmdText += Almax_ETX; if (cmdText.compare(0,2,Almax_CMD_GetStatus,0,2) != 0) { if (reSend) { FINFO("==OUT==: [{$}:{$}] reSend \n", cmdText.c_str(), cmdText.length()); } else { FINFO("==OUT==: [{$}:{$}] \n", cmdText.c_str(), cmdText.length()); } } int retLength; m_SCF.Lock(msTimeOut_Lock) .SendPacket(cmdText.c_str(), cmdText.length(), nTimeOut, retLength); //Sleep(nTimeOut); return RET_STATUS::RET_SUCCEED; } void nsGEN::AlmaxDevice::FireNotify(string key, int context) { char szInfo[64] = { 0 }; sprintf_s(szInfo, "%d", context); std::string str = szInfo; EventCenter->OnNotify(1, key, str); } void nsGEN::AlmaxDevice::FireNotify(std::string key, float context) { char szInfo[16] = { 0 }; sprintf_s(szInfo,15, "%.2f", context); std::string str = szInfo; FINFO("FireNotify(float):[{$}][{$}]", szInfo, str.c_str()); EventCenter->OnNotify(1, key, str); } void nsGEN::AlmaxDevice::FireNotify(std::string key, std::string context) { EventCenter->OnNotify(1, key, context); } void nsGEN::AlmaxDevice::FireErrorMessage(const bool Act, const int Code, const char* ResInfo) { string ErrorCode("Almax_ERR_"); ErrorCode += std::to_string(Code); int level = ContainerExample_REGULATION_LEVEL::REG_ERRO; if (Act) { FERROR("add {$}:{$}", ErrorCode.c_str(), ResInfo); m_MSGUnit->AddErrorMessage(ErrorCode.c_str(), level, ResInfo); } else { FERROR("del {$}:{$}", ErrorCode.c_str(), ResInfo); m_MSGUnit->DelErrorMessage(ErrorCode.c_str(), level, ResInfo); } } void nsGEN::AlmaxDevice::FireWarnMessage(const bool Act, const int Code, const char* ResInfo) { string ErrorCode("Almax_WAR_"); ErrorCode += std::to_string(Code); int level = ContainerExample_REGULATION_LEVEL::REG_WARN; if (Act) { FERROR("add {$}:{$}", ErrorCode.c_str(), ResInfo); m_MSGUnit->AddWarnMessage(ErrorCode.c_str(), level, ResInfo); } else { FERROR("del {$}:{$}", ErrorCode.c_str(), ResInfo); m_MSGUnit->DelWarnMessage(ErrorCode.c_str(), level, ResInfo); } } void nsGEN::AlmaxDevice::OnCallBack() { //无 操作 auto HWNotProcess = [](const char* value, int length) -> void { //printf("This commands didn't need to process!"); FINFO("This commands[{$}] didn't need to process", value); }; //校验和错误 auto HWERROR_1 = [this](char* value, int length) -> void { char* nextTokenPtr = NULL; char* tokenPtr = strtok_s(value, ",", &nextTokenPtr); if(tokenPtr != NULL) { FERROR("== HWERROR_1 == : error CheckSum:[{$}]", tokenPtr); } else { FERROR("== HWERROR_1 == : error CheckSum:no csum"); } }; //命令模式:用于正常操作 //主机请求固件传输模拟监视器读回当前值 //主机请求固件发送电源状态 auto HW22 = [this](char* value, int length) -> void { m_iHeartBeats = 0; int FaultFlag = false; int AECReady = false; char* nextTokenPtr = NULL; char* tokenPtr = strtok_s(value, ",", &nextTokenPtr); if (tokenPtr != NULL) //ARG1:XR1 / XR0状态 { int iARG = atoi(tokenPtr); #if Almax_22CMDCtrlGenSynState_Flag if (iARG) { if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_XRAYON) { FDEBUG("Request Status_1:already X-Ray On(XR1)"); } else if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_READY) { FDEBUG("Request Status_1:RAD_READY(PR2) -> X-Ray On(XR1)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_XRAYON)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } else { FWARN("Request Status_1:Wrong state change:{$} -try to> X-Ray On(XR1)", m_DoseUnit.m_GenSynState->Get()); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_XRAYON)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } } else { if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_XRAYON) { FDEBUG("Request Status_1:get post KV MA MS MAS"); //HWSendWaittimeCMD("54,3"); m_iCompPostMAS = 10; HWSendWaittimeCMD("60,",3); HWSendWaittimeCMD("61,",3); HWSendWaittimeCMD("65,",3); FDEBUG("Request Status_1:X-Ray On(XR1) -> Off(XR0)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_XRAYOFF)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } else if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_XRAYOFF) { FDEBUG("Request Status_1:X-Ray Off(XR0) -> Off(PR2)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_READY)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } else FDEBUG("Request Status_1:already X-Ray Off(XR0)"); } #else FDEBUG("Request Status_1:Unit High Voltage output Status[{$}]", iARG); #endif // Almax_22CMDCtrlGenSynState_Flag } else return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG2:安全开关状态 { int iARG = atoi(tokenPtr); if (iARG == 0) { FDEBUG("Request Status_2:Safety interlock is Open; not ok to make high voltage"); FaultFlag = true; } else { FDEBUG("Request Status_2:Safety interlock is closed; ok to make high voltage"); } } else return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG3:故障状况 { int iARG = atoi(tokenPtr); if (iARG == 1) { FDEBUG("Request Status_3:There are 1 or more active faults,not make high voltage"); FaultFlag = true; } else { FDEBUG("Request Status_3:no active faults"); } } else return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG4:PR1 / PR0状态 { int iARG = atoi(tokenPtr); #if Almax_22CMDCtrlGenSynState_Flag if (iARG == 1) { if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P || m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P) { FDEBUG("Request Status_4:AEC mod ignore ARG13"); AECReady = true; } //加快查询时间 if (m_iLoopTime != Almax_LoopExpHBTime) { FDEBUG("quicken loopTime[{$}]->[{$}]", m_iLoopTime.load(), Almax_LoopExpHBTime); m_iLoopTime = Almax_LoopExpHBTime; } if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_PREPARE || m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_READY || m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_XRAYON || m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_XRAYOFF) { FDEBUG("Request Status_4:GEN is already in Prep state(PR1)"); } else if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_OFF) { FDEBUG("Request Status_4:RAD_OFF(PR0) -> RAD_PREPARE(PR1)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_PREPARE)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } else { FWARN("Request Status_4:Wrong state change:{$} -> RAD_PREPARE(PR1)", m_DoseUnit.m_GenSynState->Get()); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_PREPARE)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } if (m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_EXP && m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_ERROR) { //更新发生器状态并上报，否则会影响工作流 FrameEnable -> FrameReady 的转变 FDEBUG("Request Status_4:GENSTATE {$} -> STATUS_EXP", m_DoseUnit.m_GenState->JSGet()); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_EXP); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } } else { AECReady = false; //回复查询时间 if (m_iLoopTime == Almax_LoopExpHBTime) { if ((int)m_GenConfig["loopTime"] >= 100) { m_iLoopTime = (int)m_GenConfig["loopTime"]; } else m_iLoopTime = Almax_LoopDefHBTime; FDEBUG("reduction loopTime[{$}]->[{$}]", Almax_LoopExpHBTime,m_iLoopTime.load()); } FDEBUG("Request Status_4:GEN is not in Prep state(PR0)"); if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_PREPARE) { if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_OFF)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } if (m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_STANDBY && m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_ERROR) { if (m_bExpEnable) { FDEBUG("Request Status_4:GENSTATE {$} -> STATUS_STANDBY", m_DoseUnit.m_GenState->JSGet()); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_STANDBY); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } else if(m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_SLEEP) { FDEBUG("Request Status_4:GENSTATE {$} -> STATUS_SLEEP", m_DoseUnit.m_GenState->JSGet()); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_SLEEP); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } } } #else FDEBUG("Request Status_4:Unit Prep state[{$}]", iARG); if (iARG == 1) { //加快查询时间 if (m_iLoopTime != Almax_LoopExpHBTime) { FDEBUG("quicken loopTime[{$}]->[{$}]", m_iLoopTime.load(), Almax_LoopExpHBTime); m_iLoopTime = Almax_LoopExpHBTime; } if (m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_EXP && m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_ERROR) { //更新发生器状态并上报，否则会影响工作流 FrameEnable -> FrameReady 的转变 FDEBUG("Request Status_4:GENSTATE {$} -> STATUS_EXP", m_DoseUnit.m_GenState->JSGet()); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_EXP); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } } else { //回复查询时间 if (m_iLoopTime == Almax_LoopExpHBTime) { if ((int)m_GenConfig["loopTime"] >= 100) { m_iLoopTime = (int)m_GenConfig["loopTime"]; } else m_iLoopTime = Almax_LoopDefHBTime; FDEBUG("reduction loopTime[{$}]->[{$}]", Almax_LoopExpHBTime, m_iLoopTime.load()); } FDEBUG("Request Status_4:GEN turn to Prep state(PR0)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_OFF)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); if (m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_STANDBY && m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_ERROR) { if (m_bExpEnable) { FDEBUG("Request Status_4:GENSTATE {$} -> STATUS_STANDBY", m_DoseUnit.m_GenState->JSGet()); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_STANDBY); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } else if (m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_SLEEP) { FDEBUG("Request Status_4:GENSTATE {$} -> STATUS_SLEEP", m_DoseUnit.m_GenState->JSGet()); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_SLEEP); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } } } #endif // Almax_22CMDCtrlGenSynState_Flag } else return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG5:Xray Condition { int iflag = atoi(tokenPtr); if(iflag) FDEBUG("Request Status_5:Unit is in Xray state (Ready to make X-Ray shot)"); else FDEBUG("Request Status_5:Unit is not in Xray state"); } else return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG6 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG7 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG8 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG9 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG10 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG11 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG12 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG13:准备状态(PR2) { int iARG = atoi(tokenPtr); #if Almax_22CMDCtrlGenSynState_Flag if (iARG == 1) { if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_READY || m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_XRAYON || m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_XRAYOFF) { FDEBUG("Request Status_13:GEN is already to make X-Rays(PR2)"); } else if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_PREPARE) { FDEBUG("Request Status_13:PREPARE or XRAYOFF(PR1 or XR0) -> RAD_READY(PR2)"); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_READY)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } else { FWARN("Request Status_13:Wrong state change:{$} -> RAD_READY(PR2)", m_DoseUnit.m_GenSynState->Get()); if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_READY)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } } else { if (AECReady) { FDEBUG("Request Status_13:GEN is in AEC_ready(temp PR0)"); } else { FDEBUG("Request Status_13:GEN is not finish ready(PR0)"); } if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_READY && !AECReady) { if (m_DoseUnit.m_GenSynState->Update(nsGEN::AttrKey::GENERATOR_RAD_PREPARE)) FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet()); } } #else FDEBUG("Request Status_13:Unit Ready Status[{$}]", iARG); #endif // Almax_22CMDCtrlGenSynState_Flag } else return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); //ARG14 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG15:校准模式 { int iARG = atoi(tokenPtr); if (iARG == 1) //该装置处于校准模式 { FDEBUG("Request Status_15:GEN is in calibration mode"); } else { FDEBUG("Request Status_15:GEN is not in calibration mode"); } } else return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG16 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG17 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG18 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG19 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG20 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG21 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG22 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",", &nextTokenPtr); //ARG23 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG24:负载持续率可限制 { int iARG = atoi(tokenPtr); if (iARG == 1) //此位表示设备如果过载保护也允许新的曝光周期开始 { FDEBUG("Request Status_24:Ok to enter Prep"); if (!m_bExpEnable) { m_bExpEnable = true; if (m_DoseUnit.m_GenState->Get() == nsGEN::AttrKey::GENERATOR_STATUS_SLEEP) { FireWarnMessage(false, 2, "Almax generator need some time to rest(about 20 Sec)"); if (FaultFlag) { FDEBUG("Request Status_24 STATUS_SLEEP -> STATUS_ERROR"); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_ERROR); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } else { FDEBUG("Request Status_24 STATUS_SLEEP -> STATUS_STANDBY"); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_STANDBY); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } } } } else { FDEBUG("Request Status_24:Not ready to enter prep"); if (m_bExpEnable) { FireWarnMessage(true, 2, "Almax generator need some time to rest(about 20 Sec)"); m_bExpEnable = false; if (m_DoseUnit.m_GenSynState->Get() < nsGEN::AttrKey::GENERATOR_RAD_PREPARE && !FaultFlag) { FDEBUG("Request Status_24:GENSTATE {$} -> STATUS_SLEEP", m_DoseUnit.m_GenState->JSGet()); m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_SLEEP); FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet()); } } } } else return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); //ARG25 if (tokenPtr == NULL) return; tokenPtr = strtok_s(NULL, ",",&nextTokenPtr); if (tokenPtr != NULL) //ARG26:HSS速度 { int iARG = atoi(tokenPtr); if (iARG == 1) //X射线管转子转速设定 { FDEBUG("Request Status_26:High Speed"); } else { FDEBUG("Request Status_26:Low Speed"); } } else return; }; arFrame.clear(); //命令模式:用于正常操作 arFrame["22"] = tFrameMapItem(HW22); arFrame["1"] = tFrameMapItem(HWERROR_1);//命令格式:校验和错误 } bool nsGEN::AlmaxDevice::ReConnect() { FINFO("Enter PSG_reConnect"); m_SCF.Disconnect(); if (!pIODriver) { FINFO("PSG_reConnect:Driver null"); } else if (pIODriver->ReConnection(m_SCF)) { FireErrorMessage(false, 1, "lost Connect"); m_bConnectFlag = true; FINFO("PSG_reConnect success"); return true; } else { FINFO("PSG_reConnect failed"); } return false; } bool nsGEN::AlmaxDevice::StartHardwareStatusThread() { FINFO("enter Start HardwareStatus Thread "); if (m_pHardwareStatusThread == NULL) { DWORD m_HardwareStatusID; m_pHardwareStatusThread = CreateThread(0, 0, HardwareStatusThread, this, 0, &m_HardwareStatusID); if (m_pHardwareStatusThread == NULL) { FERROR("Start HardwareStatus Thread Failed"); return false; } } return true; } DWORD nsGEN::AlmaxDevice::HardwareStatusThread(LPVOID pParam) { AlmaxDevice* pCurGen = (AlmaxDevice*)pParam; if (pCurGen == NULL) { return false; } HeartBeatFlag = true; FINFO("HardwareStatusThread start"); if ((int)pCurGen->m_GenConfig["loopTime"] >= 100) { pCurGen->m_iLoopTime = (int)pCurGen->m_GenConfig["loopTime"]; } FINFO("loopTime = {$}", pCurGen->m_iLoopTime.load()); int currtTime = pCurGen->m_iLoopTime; while (m_bExtraFlag) { if (!(pCurGen->m_bConnectFlag)) { FINFO("AlmaxGEN: not Connect,try to reconnect \n"); pCurGen->FireErrorMessage(true, 1, "lost Connect"); pCurGen->ReConnect(); Sleep(20000); continue; } FDEBUG("currtloopTime = {$}", pCurGen->m_iLoopTime.load()); currtTime = pCurGen->m_iLoopTime; Sleep(currtTime); //心跳包统计加1 pCurGen->m_iHeartBeats++; int tempHeartBeat = pCurGen->m_iHeartBeats; if (tempHeartBeat > 10) //无返回信息认为连接断开 { pCurGen->m_iHeartBeats = 0; FINFO("AlmaxGEN: lost Connect \n"); pCurGen->m_bConnectFlag = false; continue; } //发送心跳 if (currtTime == Almax_LoopExpHBTime) { pCurGen->HWSendHBCMD("22,", 3); } else { if(!(pCurGen->m_bExpEnable)) pCurGen->HWSendHBCMD("22,", 3); else pCurGen->HWSendHBCMD("99,", 3); } pCurGen->HWSendHBCMD("77,",3); //轮询发生器温度信息 } FINFO("HardwareStatusThread stop"); return true; } //----------------------------------------------------------------------------- // AlmaxDriver //----------------------------------------------------------------------------- nsGEN::AlmaxDriver::AlmaxDriver() { m_bDemoMode = false; m_bDemoConnected = false; m_pAttribute.reset(new ResDataObject()); m_pDescription.reset(new ResDataObject()); } nsGEN::AlmaxDriver::~AlmaxDriver() { Close(); gLogger = nullptr; } void nsGEN::AlmaxDriver::Prepare() { ResDataObject r_config; if (r_config.loadFile(m_ConfigFileName.c_str())) { if ((int)r_config["CONFIGURATION"]["logEnable"] == 1) { string strLogPath = GetProcessDirectory() + R"(\OEMDrivers\Generator\Conf\Log4CPP.Config.GEN.xml)"; //Log4CPP::ThreadContext::Map::Set("LogFileName", "GEN.ContainerExample"); Log4CPP::GlobalContext::Map::Set(ECOM::Utility::Hash("LogFileName"), "GEN.ContainerExample"); auto rc = Log4CPP::LogManager::LoadConfigFile(strLogPath.c_str()); gLogger = Log4CPP::LogManager::GetLogger("GEN.ContainerExample"); } m_bDemoMode = (atoi)(((string)r_config["CONFIGURATION"]["IsDemo"]).c_str()); ResDataObject Connection = r_config["CONFIGURATION"]["connections"][0]; if ((string)Connection["type"] == "COM") { m_SCFDllName = COM_SCFDllName; } else { m_SCFDllName = TCP_SCFDllName; } } super::Prepare(); } std::string nsGEN::AlmaxDriver::DriverProbe() { ResDataObject r_config, HardwareInfo; if (r_config.loadFile(m_ConfigFileName.c_str())) { HardwareInfo.add("MajorID", r_config["CONFIGURATION"]["MajorID"]); HardwareInfo.add("MinorID", r_config["CONFIGURATION"]["MinorID"]); HardwareInfo.add("VendorID", r_config["CONFIGURATION"]["VendorID"]); HardwareInfo.add("ProductID", r_config["CONFIGURATION"]["ProductID"]); HardwareInfo.add("SerialID", r_config["CONFIGURATION"]["SerialID"]); } else { HardwareInfo.add("MajorID", "Generator"); HardwareInfo.add("MinorID", "Dr"); HardwareInfo.add("VendorID", "Almax"); HardwareInfo.add("ProductID", "HF"); HardwareInfo.add("SerialID", "Drv"); } string ret = HardwareInfo.encode(); return ret; } bool nsGEN::AlmaxDriver::ReConnection(nsSCF::SCF& DevSCF) { super::Disconnect(); FINFO("ReConnection:SCF Disconnect"); ResDataObject r_config; if (!r_config.loadFile(m_ConfigFileName.c_str())) { FINFO("ReConnection:open configFile failed"); return SCF_ERR::SCF_OPEN_FAILED; } ResDataObject Connection = r_config["CONFIGURATION"]["connections"][0]; FINFO("ReConnection:{$} \n", Connection.encode()); auto erCode = m_SCF.Connect(Connection.encode(), &nsGEN::AlmaxDriver::callbackPackageProcess, SCF_PACKET_TRANSFER, 3000); if (erCode == SCF_ERR::SCF_SUCCEED) { Sleep(1000); auto rc = super::Connect(); if (!rc) { FINFO("ReConnection:super Connect failed"); } else { DevSCF = m_SCF; return true; } } else { FINFO("ReConnection failed"); } return false; } bool nsGEN::AlmaxDriver::Connect() { if (m_bDemoMode) { FINFO("connections:DEMO \n"); m_bDemoConnected = true; return true; //return SCF_ERR::SCF_SUCCEED; } ResDataObject r_config; if (!r_config.loadFile(m_ConfigFileName.c_str())) return false; //return SCF_ERR::SCF_OPEN_FAILED; ResDataObject Connection = r_config["CONFIGURATION"]["connections"][0]; //printf("connections:%s \n", Connection.encode()); FINFO("connections:{$} \n", Connection.encode()); auto erCode = m_SCF.Connect(Connection.encode(), &nsGEN::AlmaxDriver::callbackPackageProcess, SCF_PACKET_TRANSFER, 3000); if (erCode != SCF_ERR::SCF_SUCCEED) return false; //return erCode; auto rc = super::Connect(); if (!rc) return false; //return 0; //return (erCode == SCF_ERR::SCF_SUCCEED); return true; //return SCF_ERR::SCF_SUCCEED; } auto nsGEN::AlmaxDriver::CreateDevice(int index) -> std::unique_ptr { if (m_bDemoMode) { if (!m_bDemoConnected) { FERROR("CreateDevice:m_bDemoConnected is false \n"); return nullptr; } auto dev = std::unique_ptr (new IODevice(new DemoDevice(EventCenter))); return dev; } if (!m_SCF.isConnected()) { FERROR("CreateDevice:m_SCF is not Connected \n"); return nullptr; } auto dev = std::unique_ptr (new IODevice(new AlmaxDevice(EventCenter, m_SCF, m_ConfigFileName))); return dev; } void nsGEN::AlmaxDriver::FireNotify(int code, std::string key, std::string content) { EventCenter->OnNotify(code, key, content); } bool nsGEN::AlmaxDriver::isConnected() const { if (m_bDemoMode) return m_bDemoConnected; else { if (super::isConnected()) { return true; } else { if(HeartBeatFlag) //避过平台层的断连检测 return true; else return false; } } } std::string nsGEN::AlmaxDriver::GetResource() { ResDataObject r_config, temp; if (!temp.loadFile(m_ConfigFileName.c_str())) { return ""; } m_ConfigAll = temp; r_config = temp["CONFIGURATION"]; m_Configurations = r_config; ResDataObject DescriptionTemp; ResDataObject DescriptionSend; ResDataObject m_DescriptionSend; ResDataObject ListTemp; string strTemp = ""; //用于读取字符串配置信息 string strIndex = ""; //用于读取配置信息中的List项 int nTemp = -1; //用于读取整型配置信息 char sstream[10] = { 0 }; //用于转换值 string strValue = ""; //用于存储配置的值 string strType = ""; //用于存储配置的类型 int/float/string... /*** * 1. 通过循环，将所有配置项写到pDeviceConfig * 2. 记录配置项的内部key以及配置类型，类型对应了不同配置文件路径，用于读写真实值 ***/ try { //便利ConfigToolInfo 中 所有的AttributeInfo 属性段 int nConfigInfoCount = (int)m_Configurations["ConfigToolInfo"].GetKeyCount("AttributeInfo"); m_pAttribute->clear(); m_pDescription->clear(); for (int nInfoIndex = 0; nInfoIndex < nConfigInfoCount; nInfoIndex++) { DescriptionTemp.clear(); DescriptionSend.clear(); ListTemp.clear(); //AttributeType strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["Type"]; DescriptionTemp.add(ConfKey::CcosType, strTemp.c_str());//CcosGeneratorAttribute DescriptionSend.add(ConfKey::CcosType, strTemp.c_str());//CcosGeneratorAttribute strType = strTemp; //记录配置项的类型 //AttributeKey //1. 根据AttributeType，内部key和配置路径，拿到当前的真实值 strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["InnerKey"]; nTemp = (int)m_Configurations["ConfigToolInfo"][nInfoIndex]["PathID"]; GetDeviceConfigValue(r_config, strTemp.c_str(), nTemp, strValue); //得到strValue的值 //printf("********************************innerkey=%s --strValue = %s\n", strTemp.c_str(), strValue.c_str()); //2. 赋值 strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeKey"]; if ("int" == strType) { (*m_pAttribute).add(strTemp.c_str(), atoi(strValue.c_str())); } else if ("float" == strType) { (*m_pAttribute).add(strTemp.c_str(), atoi(strValue.c_str())); } else //其它先按string类型处理 { (*m_pAttribute).add(strTemp.c_str(), strValue.c_str()); } //printf("********************************outkey =%s --strValue = %s\n", strTemp.c_str(), strValue.c_str()); //AttributeAccess strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["Access"]; DescriptionTemp.add(ConfKey::CcosAccess, strTemp.c_str()); DescriptionSend.add(ConfKey::CcosAccess, strTemp.c_str()); /* //AttributeRangeMin strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["RangeMin"]; if (strTemp != "") //不需要的配置项为空 { DescriptionTemp.add(ConfKey::CcosRangeMin, strTemp.c_str()); } //AttributeRangeMax strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["RangeMax"]; if (strTemp != "") //不需要的配置项为空 { DescriptionTemp.add(ConfKey::CcosRangeMax, strTemp.c_str()); } */ //AttributeList nTemp = m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["ListNum"]; if (nTemp > 0) //ListNum不大于0时说明不需要list配置 { for (int nListIndex = 0; nListIndex < nTemp; nListIndex++) { strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["ListInfo"][nListIndex]; auto temKey = std::to_string(nListIndex); ListTemp.add(temKey.c_str(), strTemp.c_str()); } DescriptionTemp.add(ConfKey::CcosList, ListTemp); DescriptionSend.add(ConfKey::CcosList, ListTemp.encode()); } //AttributeRequired strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["Required"]; DescriptionTemp.add(ConfKey::CcosRequired, strTemp.c_str()); DescriptionSend.add(ConfKey::CcosRequired, strTemp.c_str()); //AttributeDefaultValue strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["DefaultValue"]; if (strTemp != "") //不需要的配置项为空 { DescriptionTemp.add(ConfKey::CcosDefaultValue, strTemp.c_str()); DescriptionSend.add(ConfKey::CcosDefaultValue, strTemp.c_str()); } strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeKey"]; (*m_pDescription).add(strTemp.c_str(), DescriptionTemp); m_DescriptionSend.add(strTemp.c_str(), DescriptionSend.encode()); } } catch (ResDataObjectExption& e) { FERROR("Get config error: {$}", e.what()); return ""; } ResDataObject resDeviceResource; resDeviceResource.add(ConfKey::CcosGeneratorAttribute, (*m_pAttribute)); resDeviceResource.add(ConfKey::CcosGeneratorDescription, (*m_pDescription)); ResDataObject DescriptionTempEx; DescriptionTempEx.add(ConfKey::CcosGeneratorConfig, resDeviceResource); m_DeviceConfig.clear(); m_DeviceConfig = DescriptionTempEx; FDEBUG("local ************* get resource over {$}", DescriptionTempEx.encode()); //printf("local ************* get resource over %s \n", DescriptionTempEx.encode()); resDeviceResource.clear(); resDeviceResource.add(ConfKey::CcosGeneratorAttribute, (*m_pAttribute)); resDeviceResource.add(ConfKey::CcosGeneratorDescription, m_DescriptionSend); DescriptionTempEx.clear(); DescriptionTempEx.add(ConfKey::CcosGeneratorConfig, resDeviceResource); m_DeviceConfigSend.clear(); m_DeviceConfigSend = DescriptionTempEx; string res = m_DeviceConfigSend.encode(); //printf("%s", res.c_str()); FDEBUG("get resource over {$}", DescriptionTempEx.encode()); //("************* get resource over %s \n", DescriptionTempEx.encode()); return res; } std::string nsGEN::AlmaxDriver::DeviceProbe() { ResDataObject r_config, HardwareInfo; if (r_config.loadFile(m_ConfigFileName.c_str())) { HardwareInfo.add("MajorID", r_config["CONFIGURATION"]["MajorID"]); HardwareInfo.add("MinorID", r_config["CONFIGURATION"]["MinorID"]); HardwareInfo.add("VendorID", r_config["CONFIGURATION"]["VendorID"]); HardwareInfo.add("ProductID", r_config["CONFIGURATION"]["ProductID"]); HardwareInfo.add("SerialID", r_config["CONFIGURATION"]["SerialID"]); } else { HardwareInfo.add("MajorID", "Generator"); HardwareInfo.add("MinorID", "Dr"); HardwareInfo.add("VendorID", "Almax"); HardwareInfo.add("ProductID", "HF"); HardwareInfo.add("SerialID", "Dev"); } string ret = HardwareInfo.encode(); return ret; } void nsGEN::AlmaxDriver::Disconnect() { super::Disconnect(); m_SCF.Disconnect(); m_bDemoConnected = false; Close(); gLogger = nullptr; } void nsGEN::AlmaxDriver::Dequeue(const char* Packet, DWORD Length) { DecodeFrame(Packet, Length); } PACKET_RET nsGEN::AlmaxDriver::callbackPackageProcess(const char* RecData, DWORD nLength, DWORD& PacketLength) { #if 0 if (nLength > 1) { FERROR("receive data_len[{$}]", nLength); for (int i = 0; i < nLength; i++) { if (i != nLength - 1) { FERROR("receive data[{$}][{$}]", i, RecData[i]); } else { FERROR("receive data[{$}][{$}]", i, RecData[i]); } } } #endif bool bHasHead = false; if (nLength < 1) { PacketLength = 0; FERROR("nLength too small, nLength=={$}", nLength); return PACKET_USELESS; } else if(nLength > Almax_Com_NormalLen) { PacketLength = nLength; FERROR("nLength too big, nLength=={$}", nLength); return PACKET_USELESS; } for (DWORD i = 0; i < nLength; i++) { //寻找包头 if (RecData[i]== Almax_STX) { if (i!=0) //包头之前的数据格式不对，全部扔掉 { PacketLength = i; char strtemp[Almax_Com_NormalLen] = { 0 }; memcpy(strtemp, RecData, PacketLength); FERROR("==IN unknown format data ==:[{$}],UselessDataLength={$},TotalLength={$} \n", strtemp, PacketLength, nLength); return PACKET_USELESS; } else { bHasHead = true; } } //寻找包尾 if (RecData[i] == Almax_ETX) { if(bHasHead) { if (i >= 4) //正常指令 { PacketLength = i + 1; //+1 because ETX char strtemp[Almax_Com_NormalLen] = { 0 }; memcpy(strtemp, RecData + 1, i - 1); //只有数据+CSUM，+1 排除 STX ，-1 排除 ETX。 if (!((strtemp[0] == '9' && strtemp[1] == '9') || (strtemp[0] == '7' && strtemp[1] == '7'))) { FINFO("==IN==:[{$}]", strtemp); AlmaxDevice::m_tDelivermodule.CheckReceive(strtemp,2); } return PACKET_ISPACKET; } else //空指令 { PacketLength = i + 1; char strtemp[Almax_Com_NormalLen] = { 0 }; memcpy(strtemp, RecData, PacketLength); //空数据，格式正确但无有效命令。 FERROR("==IN uselss data==:[{$}] \n", strtemp); return PACKET_USELESS; } } else //有包尾但无包头 { PacketLength = i + 1; char strtemp[Almax_Com_NormalLen] = { 0 }; memcpy(strtemp, RecData, PacketLength); FERROR("==IN no head data ==:[{$}],NoHeadDataLength={$},TotalLength={$} \n", strtemp, PacketLength, nLength); return PACKET_USELESS; } } } if (bHasHead) { PacketLength = 0; } return PACKET_NOPACKET; } bool nsGEN::AlmaxDriver::GetDeviceConfig(std::string& Cfg) { Cfg = m_DeviceConfigSend.encode(); printf("GetDeviceConfig over , %s", Cfg.c_str()); return true; } bool nsGEN::AlmaxDriver::SetDeviceConfig(std::string Cfg) { FINFO("--Func-- SetDeviceConfig {$}\n", Cfg.c_str()); printf("\n--Func-- SetDeviceConfig %s\n", Cfg.c_str()); ResDataObject DeviceConfig; DeviceConfig.decode(Cfg.c_str()); ResDataObject DescriptionTempEx; DescriptionTempEx = DeviceConfig["DeviceConfig"]["Attribute"]; FDEBUG("Attribute:{$}", DescriptionTempEx.encode()); bool bSaveFile = false; //true:重新保存配置文件 string strAccess = ""; for (int i = 0; i < DescriptionTempEx.size(); i++) { string strKey = DescriptionTempEx.GetKey(i); FINFO("{$}", strKey.c_str()); printf("%s\n", strKey.c_str()); try { if (m_pAttribute->GetFirstOf(strKey.c_str()) >= 0) { strAccess = (string)(*m_pDescription)[strKey.c_str()]["Access"]; if ("RW" == strAccess) { //修改对应配置，在其他单元的配置项要同时调用其修改函数修改真实值 //1. 修改内存中的值，用于给上层发消息 (*m_pAttribute)[strKey.c_str()] = DescriptionTempEx[i]; //2. 拿到Innerkey int nConfigInfoCount = (int)m_Configurations["ConfigToolInfo"].GetKeyCount("AttributeInfo"); FINFO("nConfigInfoCount {$}", nConfigInfoCount); string strTemp = ""; //存储AttributeKey for (int nInfoIndex = 0; nInfoIndex < nConfigInfoCount; nInfoIndex++) { strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeKey"]; if (strTemp == strKey) { strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["InnerKey"]; break; } } //3. 修改配置文件中的值 if (SetDeviceConfigValue(m_Configurations, strTemp.c_str(), 1, DescriptionTempEx[i])) { FDEBUG("SetDeviceConfigValue over"); bSaveFile = true; } } else { FINFO("{$} is not a RW configuration item", strKey.c_str()); } } else { FINFO("without this attribute {$}", strKey.c_str()); } } catch (ResDataObjectExption& e) { printf("\nSetDriverConfig crashed: %s\n", e.what()); FERROR("SetDriverConfig crashed: {$}", e.what()); return false; } } if (bSaveFile) { //3. 重新保存配置文件 SaveConfigFile(true); } return true; } bool nsGEN::AlmaxDriver::SaveConfigFile(bool bSendNotify) { m_ConfigAll["CONFIGURATION"] = m_Configurations; bool bRt = m_ConfigAll.SaveFile(m_ConfigFileName.c_str()); FINFO("SaveConfigFile over {$}", bRt); return true; } bool nsGEN::AlmaxDriver::GetDeviceConfigValue(ResDataObject config, const char* pInnerKey, int nPathID, string& strValue) { strValue = ""; string strTemp = pInnerKey; if (1 == nPathID) //从DriverConfig路径下每个DPC自己的配置文件读取 { int pos = 0; ResDataObject resTemp = config; while ((pos = strTemp.find_first_of(',')) != string::npos) { string Key = strTemp.substr(0, pos); string TempValue = resTemp[Key.c_str()].encode(); // printf("-TempValue=== %s", TempValue.c_str()); resTemp.clear(); resTemp.decode(TempValue.c_str()); strTemp = strTemp.substr(pos + 1, strTemp.length() - pos - 1); //printf("-************--%s", strTemp.c_str()); } if (strTemp != "") { strValue = (string)resTemp[strTemp.c_str()]; } else { strValue = (string)resTemp; } } //printf("------------%s", strValue.c_str()); return true; } bool nsGEN::AlmaxDriver::SetDeviceConfigValue(ResDataObject& config, const char* pInnerKey, int nPathID, const char* szValue) { string strTemp = pInnerKey; FDEBUG("Begin to change {$} item value to {$}", pInnerKey, szValue); printf("\nbbbbbbbbbbbbbbBegin to change {%s} item value to {%s}\n", pInnerKey, szValue); if (1 == nPathID) //从DriverConfig路径下每个DPC自己的配置文件读取 { try { int pos = 0; ResDataObject* resTemp = &config; while ((pos = strTemp.find_first_of(',')) != string::npos) { string Key = strTemp.substr(0, pos); resTemp = &(*resTemp)[Key.c_str()]; strTemp = strTemp.substr(pos + 1, strTemp.length() - pos - 1); } if (strTemp != "") { //if ((strTemp.compare("WSTable") == 0) || // (strTemp.compare("WSWall") == 0) || // (strTemp.compare("WSFree") == 0) || // (strTemp.compare("WSTomo") == 0) || // (strTemp.compare("WSConventional") == 0) // ) //{ // int sum = (*szValue) + 1; // (*resTemp)[strTemp.c_str()] = (char*)(&sum); //} //else // (*resTemp)[strTemp.c_str()] = szValue; (*resTemp)[strTemp.c_str()] = szValue; } else { *resTemp = szValue; } } catch (ResDataObjectExption& e) { FERROR("SetDriverConfigvalue crashed: {$}", e.what()); return false; } } return true; } //----------------------------------------------------------------------------- // GetIODriver & CreateIODriver //----------------------------------------------------------------------------- static nsGEN::AlmaxDriver gIODriver; extern "C" CCOS::Dev::IODriver * __cdecl GetIODriver() // 返回静态对象的引用, 调用者不能删除 ! { return &gIODriver; } extern "C" CCOS::Dev::IODriver * __cdecl CreateIODriver() // 返回新对象, 调用者必须自行删除此对象 ! { pIODriver = new nsGEN::AlmaxDriver(); return pIODriver; }