1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656 |
- // CCOS.Dev.GEN.DEMO.cpp : 定义 DLL 应用程序的导出函数。
- //
- /*
- settechmode:没有专门的指令来设置。所以只要field不为零,就认为是AEC模式。
- */
- #include "stdafx.h"
- #include <assert.h>
- #include "Base64.h"
- #include <functional>
- using namespace std::placeholders;
- //#include "ResDataObject.h"
- //#include "logger.temp.h"
- #include "CCOS.Dev.Generator.SDC.h"
- #include "Helper.JSON.hpp"
- 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”,可能丢失数据
- static const int msTimeOut_Lock = 500;
- #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
- #define SpecialCMDAR "AR"
- #define SpecialCMDHU "HU"
- #define SpecialCMDIT "IT"
- #define SpecialCMDST "ST"
- #define SpecialCMDRX "RX"
- #define SpecialCMDRX1 "RX1"
- #define SpecialCMDRX0 "RX0"
- #define SpecialCMDXR1 "XR1"
- #define SpecialCMDXR0 "XR0"
- #define SpecialCMDPC "PC"
- #define SpecialCMDDO "DO?"
- #define SpecialCMDDOR "DOR"
- #define SpecialCMDFOS "FOS"
- #define SpecialCMDRF "RF"
- #define SpecialCMDBT "BT"
- #define SpecialCMDSA "SA"
- #define SpecialCMDDS "DS"
- #define SpecialCMDSX "SX"
- #define SpecialCMDDE "DE"
- #define WaitForNothing 0
- #define WaitForSelf 1
- #define WaitForACK 10
- #define WaitForCP 100
- #define WaitForCPSELF 101
- #define WaitForACKCP 110
- #define WaitForALL 111
- std::vector <string> g_SpecialCMD_List = { "AR","XR1","RX","ST","HU","WS","SA","SX","DS","DE"};
- std::vector <string> g_WaitSELF_List = { "AR","SA","SX","DS","XR1","RX0","RX1","ST","HU"};
- std::vector <string> g_WaitAKCMD_List = { "SA","SX","WS","MM","PH","PC","FI","FN","EC9","AR","MD","PC","TM","URSSHST",
- "XR1","RX0","RX1","URSSHSS","URSSHIA","URSSHIR","URSSHCA","URSSHEI","URSLK","URSSD","URSPO","URSPN","URSPR","URSRV","URSCF","URSFK","URSST","URSFI","URSOF","URSCA","URSPP","URSTI","URSYD","URSLI","URSLD","URSCL"};
- std::vector <string> g_WaitCPCMD_List = { "SA","SX","KV","MA","MS","MX","WS","MM","PH","PC","FI","FN","EC9","AR","MD","PC","TM","URSSHST",
- "XR1","RX0","RX1","HU","ST","DS","FOS","RF","BT"};
- //-----------------------------------------------------------------------------
- // ProcessCmd
- //-----------------------------------------------------------------------------
- struct tFrameMapping
- {
- static const int MaxLen = 5; // 前缀不能超超过 5 个字符 !
- using cbFun = std::function <void(const char*, int)>;
- char strHead[MaxLen]{0};
- int NbOfCharOfHead{0};
- cbFun fun{NULL};
- tFrameMapping(char* str, int len, cbFun f)
- {
- assert(len < MaxLen);
- for (int i = 0; i < len; i++)
- strHead[i] = str[i];
- NbOfCharOfHead = len;
- fun = f;
- }
- };
- static std::list <tFrameMapping> arFrame;
- static bool DecodeFrame(const char* strFrame, int length);
- //暂无取固定值的使用要求
- std::vector <float> g_MA_List = { 8, 10, 12.5, 16, 20, 25, 32, 40, 50, 64, 80, 100, 125, 160, 200, 250, 320, 400, 500, 640 };
- std::vector <float> g_MAS_List = { 1, 1.25, 1.6, 2, 2.5, 3.2, 4, 5, 6.4, 8, 10, 12.5, 16, 20, 25, 32, 40, 50, 64, 80, 100, 125, 160, 200, 250, 320, 400, 500, 640, 800, 1000 };
- std::vector <float> g_MS_List = { 1, 2, 3, 4, 5, 6, 8, 10, 12, 16, 20, 25, 32, 40, 50, 64, 80, 100, 125, 160, 200, 250, 320, 400, 500, 640, 800, 1000, 1250, 1600, 2000, 2500, 3200, 4000, 5000, 6400, 8000, 10000 };
- int g_AECFIELD_List [] = { 1, 10, 100, 11, 101, 110, 111 };
- bool RapidChangeValue(float& value, std::vector <float>& list,bool isIncAct)
- {
- auto item = std::find(list.begin(), list.end(), value);
- if (isIncAct)
- {
- if (item == list.end())
- value += 5;
- else
- {
- int index = distance(list.begin(), item)+1;
- if (index + 3 >= list.size())
- value = *(list.end() - 1);
- else
- value = *(item + 3);
- }
- }
- else
- {
- if (item == list.end())
- value -= 5;
- else if (item == list.end() - 1)
- return false;
- else
- {
- int index = distance(list.begin(), item);
- if (index - 3 <= 0)
- value = *(list.begin());
- else
- value = *(item - 3);
- }
- }
- return true;
- }
- template<typename T>
- int FindPositon (T *pList, int nListSize, T& value)
- {
- if (pList == NULL || nListSize == 0) return -1;
- if (value <= pList [0])
- {
- value = pList [0];
- return 0;
- }
- if (value >= pList [nListSize - 1])
- {
- value = pList [nListSize - 1];
- return nListSize - 1;
- }
- for (int i = 0; i < nListSize - 1; i++)
- {
- if (value >= pList [i] && value <= pList [i + 1])
- {
- int npos = 0;
- if (abs (value - pList [i]) >= abs (value - pList [i + 1]))
- {
- value = pList [i + 1];
- npos = i + 1;
- }
- else
- {
- value = pList [i];
- npos = i;
- }
- return npos;
- }
- }
- return -1;
- }
- //-----------------------------------------------------------------------------
- // SDCDevice
- //-----------------------------------------------------------------------------
- nsGEN::SDCDevice::SDCDevice(std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF,std::string configPath) : super(center, SCF)
- {
- assert(EventCenter);
- //CreateLogger("SDCSHRF");
- //load config XML
- m_strConfigPath = configPath;
- ResDataObject temp;
- temp.loadFile(m_strConfigPath.c_str());
- m_GenConfig = temp["CONFIGURATION"];
- TransJsonText(m_GenConfig);
- string version;
- if (GetVersion(version, hMyModule))
- mLog::Debug("\n===============log begin : version:{$} ===================", version.c_str());
- else
- mLog::Debug("===============log begin : version:0.0.0.0 ===================\n");
- m_DoseUnit.m_KV.reset(new KVMould(0.0, 40.0, 150.0, 1.0));
- m_DoseUnit.m_MA.reset(new MAMould(500, 8.0, 1000.0, 0.1));
- m_DoseUnit.m_MS.reset(new MSMould(0.0, 1.0, 10000.0, 0.01));
- m_DoseUnit.m_MAS.reset(new MASMould(0.0, 0.5, 1000.0, 0.01));
- m_DoseUnit.m_Techmode.reset(new TECHMODEMould(0, 0, 2, 1));
- m_DoseUnit.m_WS.reset(new WORKSTATIONMould(1, 1, 8, 1));
- m_DoseUnit.m_Focus.reset(new FOCUSMould(1, 0, 1, 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_PostKV.reset(new POSTKVMould(0.0, 40.0, 150.0, 1.0));
- m_DoseUnit.m_PostMA.reset(new POSTMAMould(0.0, 8.0, 1000.0, 0.1));
- m_DoseUnit.m_PostMS.reset(new POSTMSMould(0.0, 1.0, 10000.0, 0.01));
- m_DoseUnit.m_PostMAS.reset(new POSTMASMould(0.0, 0.5, 1000.0, 0.01));
- m_DoseUnit.m_GenSynState.reset(new GENSYNSTATEMould(0, AttrKey::GENERATOR_SYNC_ERR, AttrKey::GENERATOR_RAD_XRAYOFF, 1));
- m_DoseUnit.m_GenState.reset(new GENSTATEMould(4, AttrKey::GENERATOR_STATUS_SHUTDOWN, AttrKey::GENERATOR_STATUS_MAX, 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_MSGUnit.reset(new nsDetail::MSGUnit(center, GeneratorUnitType));
- m_DAP.reset(new DevDAP::DOSEMould(0.0, 0.0, 1000.0, 0.01));
- m_hGenPostEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
- m_hSendingThreadToggleEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
- m_hGenCPEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
- m_hGenACKEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
- m_hGenSELFEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
- //m_nDeviceType = (int)(m_GenConfig["GenType"]);//默认设置为2. 带有coll的。
- InitializeCriticalSection(&m_iCriticalSection);
- m_bSendingCommandsThreadExit = false;
- m_TimeoutReset = 0;
- m_bExpoEnable = false;
- m_bExpoFlag = false;
- m_sendEnable = true;
- m_arrWSMap.clear();
- //add by wxx for demand574
- if (m_GenConfig.GetKeyCount(ConfKey::CcosTubeInfo) > 0)
- {
- string tempValue = m_GenConfig[ConfKey::CcosTubeInfo];
- m_DoseUnit.m_TubeInfo.reset(new TUBEINFOMould(tempValue));
- }
- 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;
- }
- //同步模式
- if (m_GenConfig.GetKeyCount("WSTable") > 0)
- {
- int WSNamber = (int)m_GenConfig["WSTable"];
- EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNTable"]);
- m_arrWSMap[cfgWorkStationKey("Table", AttrKey::TABLE)] = cfgWorkStationData("Table", WSNamber, WSSYN);
- mLog::Debug("cfg Table WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
- }
- if (m_GenConfig.GetKeyCount("WSWall") > 0)
- {
- int WSNamber = (int)m_GenConfig["WSWall"];
- EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNWall"]);
- m_arrWSMap[cfgWorkStationKey("Wall", AttrKey::WALL)] = cfgWorkStationData("Wall", WSNamber, WSSYN);
- mLog::Debug("cfg Wall WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
- }
- if (m_GenConfig.GetKeyCount("WSFree") > 0)
- {
- int WSNamber = (int)m_GenConfig["WSFree"];
- EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNFree"]);
- m_arrWSMap[cfgWorkStationKey("Free", AttrKey::MOBILE)] = cfgWorkStationData("Free", WSNamber, WSSYN);
- mLog::Debug("cfg Free WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
- }
- if (m_GenConfig.GetKeyCount("WSTomo") > 0)
- {
- int WSNamber = (int)m_GenConfig["WSTomo"];
- EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNTomo"]);
- m_arrWSMap[cfgWorkStationKey("Tomo", AttrKey::TOMO)] = cfgWorkStationData("Tomo", WSNamber, WSSYN);
- mLog::Debug("cfg Tomo WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
- }
- if (m_GenConfig.GetKeyCount("WSConventional") > 0)
- {
- int WSNamber = (int)m_GenConfig["WSConventional"];
- EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNConventional"]);
- m_arrWSMap[cfgWorkStationKey("Direct", AttrKey::CONVENTIONAL)] = cfgWorkStationData("Direct", WSNamber, WSSYN);
- mLog::Debug("cfg Conventional WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
- }
- OnCallBack();
- Register();
- StartSendingCommandsThread();
- RefreshData();
- }
- nsGEN::SDCDevice::~SDCDevice ()
- {
- CloseHandle(m_hGenPostEvent);
- StopSendingCommandsThread();
- DeleteCriticalSection(&m_iCriticalSection);
- }
- std::string nsGEN::SDCDevice::GetGUID() const
- {
- printf("\n===============GetGUID : %s ===================\n", GeneratorUnitType);
- return GeneratorUnitType;
- }
- void nsGEN::SDCDevice::Register()
- {
- auto Disp = &Dispatch;
- superGen::Register (Disp);
- superGen::RegisterRAD (Disp);
- superGen::RegisterAEC (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 a, auto&)
- {
- return Clear_DAP();
- };
- Disp->Action.Push ("Clear_DAP", fun_Clear_DAP);
- auto fun_GetValue_DAP = [this](auto a, auto& b)
- {
- float value = 0;
- RET_STATUS ret = GetValue_DAP(value);
- b = ToJSON(value);
- return ret;
- };
- Disp->Action.Push("GetValue_DAP", fun_GetValue_DAP);
- }
- RET_STATUS nsGEN::SDCDevice::IncKV ()
- {
- if (!m_DoseUnit.m_KV->CanInc ()) return RET_STATUS::RET_SUCCEED;
- ProcessCommand("KV+");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecKV ()
- {
- if (!m_DoseUnit.m_KV->CanDec ()) return RET_STATUS::RET_SUCCEED;
- ProcessCommand("KV-");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetKV (float value)
- {
- if (! m_DoseUnit.m_KV->Verify (value)) return RET_STATUS::RET_SUCCEED;
- char temp [50] = { 0 };
- sprintf_s (temp, "KV%03d", (int)value);
- ProcessCommand(temp);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::IncKVL()
- {
- float tempKV = m_DoseUnit.m_KV->Get();
- tempKV += 5;
- if (!m_DoseUnit.m_KV->Verify(tempKV)) return RET_STATUS::RET_SUCCEED;
- ProcessCommand("KV++");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecKVL()
- {
- float tempKV = m_DoseUnit.m_KV->Get();
- tempKV -= 5;
- if (!m_DoseUnit.m_KV->Verify(tempKV)) return RET_STATUS::RET_SUCCEED;
- ProcessCommand("KV--");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::IncMA ()
- {
- #if 0
- IncMAL();
- #else
- if (!m_DoseUnit.m_MA->CanInc ()) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is MAS, can't set MA");
- return RET_STATUS::RET_FAILED;
- }
- ProcessCommand("MA+");
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecMA ()
- {
- #if 0
- DecMAL();
- #else
- if (!m_DoseUnit.m_MA->CanDec ()) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is MAS, can't set MA");
- return RET_STATUS::RET_FAILED;
- }
- ProcessCommand("MA-");
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetMA (float value)
- {
- if (! m_DoseUnit.m_MA->Verify (value)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is MAS, can't set MA");
- return RET_STATUS::RET_FAILED;
- }
- char temp [50] = { 0 };
- sprintf_s (temp, "MA%05d", (int)(value*10));
- ProcessCommand(temp);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::IncMAL()
- {
- #if 1
- IncMA();
- #else
- float tempMA = m_DoseUnit.m_MA->Get();
- if (!RapidChangeValue(tempMA, g_MA_List, true))
- {
- return IncMA();
- }
- if (!m_DoseUnit.m_MA->Verify(tempMA)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf("\n Techmode is MAS, can't set MA");
- return RET_STATUS::RET_FAILED;
- }
- char temp[50] = { 0 };
- sprintf_s(temp, "MA%05d", (int)(tempMA * 10));
- ProcessCommand(temp);
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecMAL()
- {
- #if 1
- DecMA();
- #else
- float tempMA = m_DoseUnit.m_MA->Get();
- if (!RapidChangeValue(tempMA, g_MA_List, false))
- {
- return DecMA();
- }
- if (!m_DoseUnit.m_MA->Verify(tempMA)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf("\n Techmode is MAS, can't set MA");
- return RET_STATUS::RET_FAILED;
- }
- char temp[50] = { 0 };
- sprintf_s(temp, "MA%05d", (int)(tempMA * 10));
- ProcessCommand(temp);
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::IncMS ()
- {
- if (!m_DoseUnit.m_MS->CanInc ()) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is MAS, can't set MS");
- return RET_STATUS::RET_FAILED;
- }
- ProcessCommand("MS+");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecMS ()
- {
- if (!m_DoseUnit.m_MS->CanDec ()) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is MAS, can't set MS");
- return RET_STATUS::RET_FAILED;
- }
- ProcessCommand("MS-");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetMS (float value)
- {
- if (! m_DoseUnit.m_MS->Verify (value)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is MAS, can't set MS");
- return RET_STATUS::RET_FAILED;
- }
- char temp [50] = { 0 };
- sprintf_s (temp, "MS%05d", (int)(value));
- ProcessCommand(temp);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::IncMSL()
- {
- #if 1
- IncMS();
- #else
- float tempMS = m_DoseUnit.m_MS->Get();
- if (!RapidChangeValue(tempMS, g_MS_List, true))
- {
- return IncMS();
- }
- if (!m_DoseUnit.m_MS->Verify(tempMS)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf("\n Techmode is MAS, can't set MS");
- return RET_STATUS::RET_FAILED;
- }
- char temp[50] = { 0 };
- sprintf_s(temp, "MS%05d", (int)(tempMS));
- ProcessCommand(temp);
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecMSL()
- {
- #if 1
- DecMS();
- #else
- float tempMS = m_DoseUnit.m_MS->Get();
- if (!RapidChangeValue(tempMS, g_MS_List, false))
- {
- return DecMS();
- }
- if (!m_DoseUnit.m_MS->Verify(tempMS)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf("\n Techmode is MAS, can't set MS");
- return RET_STATUS::RET_FAILED;
- }
- char temp[50] = { 0 };
- sprintf_s(temp, "MS%05d", (int)(tempMS));
- ProcessCommand(temp);
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::IncMAS ()
- {
- if (!m_DoseUnit.m_MAS->CanInc ()) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () != AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is not MAS, can't set MAS");
- return RET_STATUS::RET_FAILED;
- }
- ProcessCommand("MX+");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecMAS ()
- {
- if (!m_DoseUnit.m_MAS->CanDec ()) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () != AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is not MAS, can't set MAS");
- return RET_STATUS::RET_FAILED;
- }
- ProcessCommand("MX-");
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetMAS (float value)
- {
- if (! m_DoseUnit.m_MAS->Verify (value)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () != AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf ("\n Techmode is not MAS, can't set MAS");
- return RET_STATUS::RET_FAILED;
- }
- char temp [50] = { 0 };
- sprintf_s (temp, "MX%06d", (int)(value * 1000));
- ProcessCommand(temp);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::IncMASL()
- {
- #if 1
- IncMAS();
- #else
- float tempMAS = m_DoseUnit.m_MAS->Get();
- if (!RapidChangeValue(tempMAS, g_MAS_List, true))
- {
- return IncMAS();
- }
- if (!m_DoseUnit.m_MAS->Verify(tempMAS)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf("\n Techmode is not MAS, can't set MAS");
- return RET_STATUS::RET_FAILED;
- }
- char temp[50] = { 0 };
- sprintf_s(temp, "MX%06d", (int)(tempMAS * 1000));
- ProcessCommand(temp);
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::DecMASL()
- {
- #if 1
- DecMAS();
- #else
- float tempMAS = m_DoseUnit.m_MAS->Get();
- if (!RapidChangeValue(tempMAS, g_MAS_List, false))
- {
- return DecMAS();
- }
- if (!m_DoseUnit.m_MAS->Verify(tempMAS)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- printf("\n Techmode is not MAS, can't set MAS");
- return RET_STATUS::RET_FAILED;
- }
- char temp[50] = { 0 };
- sprintf_s(temp, "MX%06d", (int)(tempMAS * 1000));
- ProcessCommand(temp);
- #endif
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetTechmode (int value)
- {
- if (!m_DoseUnit.m_Techmode->Verify (value)) return RET_STATUS::RET_SUCCEED;
- #if 0
- char temp [50] = { 0 };
- if (value == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- sprintf_s(temp, "TM%01d", 2);
- else
- sprintf_s(temp, "TM%01d", 3);
-
- ProcessCommand(temp);
- #else
- //实际发送长数据
- char strcmd[250] = { 0 };
- if (value == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- //SetMAS(m_sPreAPRvalue.fMAS);
- sprintf_s(strcmd, "SXWS%1dFO%1dFI%03dFS1FN%1dKV%03dMX%06d",m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Focus->Get(), m_sPreAPRvalue.nAECField, m_sPreAPRvalue.nAECDensity + 4, (int)m_sPreAPRvalue.fKV, (int)(m_sPreAPRvalue.fMAS * 1000));
- //sprintf_s(strcmd, "SA2P%1d%1d%03d%06d", m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Focus->Get(), (int)m_sPreAPRvalue.fKV, (int)(m_sPreAPRvalue.fMAS * 1000));
- }
- else
- {
- //SetMA(m_sPreAPRvalue.fMA);
- //SetMS(m_sPreAPRvalue.fMS);
- sprintf_s(strcmd, "SAWS%1dFO%1dET%1dFI%03dFS1FN%1dKV%03dMA%05dMS%05d",m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Focus->Get(), value, m_sPreAPRvalue.nAECField, m_sPreAPRvalue.nAECDensity + 4, (int)m_sPreAPRvalue.fKV, (int)(m_sPreAPRvalue.fMA * 10), (int)m_sPreAPRvalue.fMS);
- //sprintf_s(strcmd, "SA3P%1d%1d%03d%05d%05d", m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Focus->Get(), (int)m_sPreAPRvalue.fKV, (int)(m_sPreAPRvalue.fMA * 10), (int)m_sPreAPRvalue.fMS);
- }
- ProcessCommand(strcmd);
- #endif
- mLog::Debug("Enter SetTechmode = {$}", value);
- assert(value);
- bool rc = false;
- int ntechmode = value;
- if (ntechmode == AttrKey::TECHMODE_V2TYPE::ET_AEC)
- {
- rc = m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_V2TYPE::ET_AEC);
- if (m_DoseUnit.m_AECField == 0)
- {
- m_DoseUnit.m_AECField->Update(10);
- FireNotify(AttrKey::AECFIELD, m_DoseUnit.m_AECField->JSGet());
- }
- }
- else if (ntechmode == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- rc = m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_V2TYPE::ET_MAS);
- }
- else if (ntechmode == AttrKey::TECHMODE_V2TYPE::ET_TIME)
- {
- rc = m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_V2TYPE::ET_TIME);
- }
- if (rc)
- {
- FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
- }
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetFocus (int value)
- {
- if (!m_DoseUnit.m_Focus->Verify (value)) return RET_STATUS::RET_SUCCEED;
- char temp [50] = { 0 };
- sprintf_s (temp, "FOS%01d", (int)value+1);
- ProcessCommand(temp);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetAECDensity (int value)
- {
- mLog::Debug("Enter SetAECDensity = {$}", value);
- if (!m_DoseUnit.m_AECDensity->Verify (value)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () != AttrKey::TECHMODE_V2TYPE::ET_AEC)
- return RET_STATUS::RET_FAILED;
- mLog::Debug("2 Enter SetAECDensity = {$}", value);
- if (m_DoseUnit.m_AECDensity->Get() != value)
- {
- char temp[50] = { 0 };
- int realData = ((int)value + 4);
- sprintf_s(temp, "FN%01d", realData);
- ProcessCommand(temp);
- mLog::Debug("3 Enter SetAECDensity = {$}", value);
- }
- mLog::Debug("4 Enter SetAECDensity = {$}", value);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetAECField (int value)
- {
- mLog::Debug("Enter SetAECField = {$}", value);
- if (!m_DoseUnit.m_AECField->Verify (value)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- return RET_STATUS::RET_FAILED;
- char temp [50] = { 0 };
- int leftValue = value / 100;
- int midValue = (value % 100) / 10;
- int rightValue = value % 10;
- sprintf_s (temp, "FI0%01d", leftValue);
- ProcessCommand(temp);
- sprintf_s(temp, "FI1%01d", midValue);
- ProcessCommand(temp);
- sprintf_s(temp, "FI2%01d", rightValue);
- ProcessCommand(temp);
- mLog::Debug("Leave SetAECField = {$}", value);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetAECFilm (int value)
- {
- if (!m_DoseUnit.m_AECFilm->Verify (value)) return RET_STATUS::RET_SUCCEED;
- if (m_DoseUnit.m_Techmode->Get () == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- return RET_STATUS::RET_FAILED;
- char temp [50] = { 0 };
- sprintf_s (temp, "FS%01d", (int)value);
- ProcessCommand(temp);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetWS (const string value)
- {
- mLog::Debug("Enter SetWS {$}", value);
- int tempws = 1;
- string strWS = "";
- cfgWorkStationKey trWS = cfgWorkStationKey(value.c_str());
- if (m_arrWSMap.find(trWS) != m_arrWSMap.end())
- {
- m_strCurrentWSName = trWS;
- tempws = m_arrWSMap[m_strCurrentWSName].nWSNamber;
- strWS = m_arrWSMap[m_strCurrentWSName].strWSNAme;
- mLog::Debug("Set WS number [{$}][{$}]", strWS.c_str(), tempws);
- }
- else
- {
- mLog::Debug("Set WS number default 1");
- m_strCurrentWSName = cfgWorkStationKey(1);
- }
- char temp[50] = { 0 };
- sprintf_s(temp, "WS%01d", tempws);
- ProcessCommand(temp);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetAPR (const _tAPRArgs& t)
- {
- char strcmd[256];
- mLog::Debug("Enter SETAPR t.nWS={$},t.fKV={$},t.fMA={$},t.fMAS={$},t.fMS={$},t.nAECDensity={$},t.nAECField={$},t.nAECFilm={$},t.nFocus={$},t.nTechmode={$} \n",
- t.nWS, t.fKV, t.fMA, t.fMAS, t.fMS, t.nAECDensity, t.nAECField, t.nAECFilm, t.nFocus, t.nTechmode);
- mLog::Debug("[SynMode:{$},SynValue:{$},WS:{$}],currentMode[{$}]",
- m_SyncMode.strSyncMode.c_str(), m_SyncMode.strSyncValue.c_str(), m_SyncMode.strWS.c_str(), m_DoseUnit.m_ExpMode->JSGet().c_str());
- int tempws = atoi(m_SyncMode.strSyncValue.c_str());
- //if (m_arrWSMap.find(cfgWorkStationKey(t.nWS)) != m_arrWSMap.end())
- //{
- // m_strCurrentWSName = cfgWorkStationKey(t.nWS);
- // tempws = m_arrWSMap[m_strCurrentWSName].nWSNamber;
- // mLog::Debug("Set WS number {$}", tempws);
- //}
- //else
- //{
- // mLog::Debug("Set WS number default 1");
- // m_strCurrentWSName = cfgWorkStationKey(t.nWS);
- // tempws = t.nWS;
- //}
- //add by wxx for bug6097 20230919
- mLog::Debug("save APR value");
- m_sPreAPRvalue = t;
- if (m_DoseUnit.m_Techmode->Verify(t.nTechmode))
- m_DoseUnit.m_Techmode->Update(t.nTechmode);
- FireNotify(m_DoseUnit.m_Techmode->GetKey(), m_DoseUnit.m_Techmode->JSGet());
- if (t.nTechmode == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- {
- sprintf_s(strcmd, "SXWS%1dFO%1dFI%03dFS1FN%1dKV%03dMX%06d", tempws, t.nFocus, t.nAECField, t.nAECDensity + 4, (int)t.fKV, (int)(t.fMAS * 1000));
- }
- else
- {
- //sprintf_s(strcmd, "SAWS%1dFO%1dE0FI%03dFS1FN%1dKV%03dMA%05dMS%05d", m_DoseUnit.m_WS->Get(), t.nFocus, t.nAECField, t.nAECDensity + 4, (int)t.fKV, (int)(t.fMA * 10), (int)t.fMS);
- sprintf_s(strcmd, "SAWS%1dFO%1dET%1dFI%03dFS1FN%1dKV%03dMA%05dMS%05d", tempws, t.nFocus, 0, t.nAECField, t.nAECDensity + 4, (int)t.fKV, (int)(t.fMA * 10), (int)t.fMS);
- }
- ProcessCommand(strcmd);
- mLog::Debug("Leave SETAPR = {$}", strcmd);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::QueryHE(int& value)
- {
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::QueryPostKV(float& value)
- {
- if (WAIT_OBJECT_0 == WaitForSingleObject(m_hGenPostEvent, 100))
- {
- value = m_DoseUnit.m_PostKV->Get();
- return RET_STATUS::RET_SUCCEED;
- }
- else
- {
- value = 0.0;
- return RET_STATUS::RET_SUCCEED;
- }
-
-
- }
- RET_STATUS nsGEN::SDCDevice::QueryPostMA(float& value)
- {
- if (WAIT_OBJECT_0 == WaitForSingleObject(m_hGenPostEvent, 100))
- {
- value = m_DoseUnit.m_PostMA->Get();
- return RET_STATUS::RET_SUCCEED;
- }
- else
- {
- value = 0.0;
- return RET_STATUS::RET_SUCCEED;
- }
- }
- RET_STATUS nsGEN::SDCDevice::QueryPostMS(float& value)
- {
- if (WAIT_OBJECT_0 == WaitForSingleObject(m_hGenPostEvent, 100))
- {
- value = m_DoseUnit.m_PostMS->Get();
- return RET_STATUS::RET_SUCCEED;
- }
- else
- {
- value = 0.0;
- return RET_STATUS::RET_SUCCEED;
- }
- }
- RET_STATUS nsGEN::SDCDevice::QueryPostMAS(float& value)
- {
- if (WAIT_OBJECT_0 == WaitForSingleObject(m_hGenPostEvent, 100))
- {
- value = m_DoseUnit.m_PostMAS->Get();
- return RET_STATUS::RET_SUCCEED;
- }
- else
- {
- value = 0.0;
- return RET_STATUS::RET_SUCCEED;
- }
- }
- RET_STATUS nsGEN::SDCDevice::Clear_DAP()
- {
- ProcessCommand("DOR", WaitForNothing);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::GetValue_DAP(float& value)
- {
- if (WAIT_OBJECT_0 == WaitForSingleObject(m_hGenPostEvent, 100))
- {
- value = m_DAP->Get();
- return RET_STATUS::RET_SUCCEED;
- }
- else
- {
- value = 0.0;
- return RET_STATUS::RET_SUCCEED;
- }
- }
- RET_STATUS nsGEN::SDCDevice::ActiveSyncMode(_tSyncModeArgs value)
- {
- mLog::Debug("Enter ActiveSyncMode:[SynMode:{$},SynValue:{$},WS:{$}],currentMode[{$}]",
- value.strSyncMode.c_str(), value.strSyncValue.c_str(), value.strWS.c_str(), m_DoseUnit.m_ExpMode->JSGet().c_str());
- m_SyncMode = value;
- int tempSynNUm = atoi(value.strSyncValue.c_str());
- if (tempSynNUm == m_DoseUnit.m_WS->Get())
- {
- char temp[50] = { 0 };
- sprintf_s(temp, "WS%01d", tempSynNUm);
- if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_HWS)
- {
- ProcessCommand(temp);
- }
- else if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_CMD)
- {
- ProcessCommand(temp);
- }
- else if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_FRE)
- {
- ProcessCommand(temp);
- }
- else if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_DEMO)
- {
- }
- mLog::Debug("ActiveSyncMode:not support [{$}:{$}] in [{$}]", value.strSyncMode.c_str(), value.strSyncValue.c_str(), m_DoseUnit.m_ExpMode->JSGet().c_str());
- }
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetGenSynState(int value)
- {
- mLog::Debug("SetGenSynState:[{$}]", value);
- if (value == 3 && m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_READY)
- {
- if (m_SyncMode.strSyncMode == AttrKey::SYNC_TYPE::SYNC_CMD)
- {
-
- //if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYON))
- // FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
- mLog::Debug("SetGenSynState: in softSYN,turn to RAD_XRAYON and send XR1");
- ProcessCommand(SpecialCMDXR1, -1, true);
- }
- else
- {
- mLog::Debug("SetGenSynState:SyncMode[{$}] not CMD", m_SyncMode.strSyncMode.c_str());
- }
- }
- else
- {
- mLog::Debug("SetGenSynState: generator is not in ready status, can't send XR1 command");
- }
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetGenState(int value)
- {
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::RefreshData ()
- {
- if(m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_INIT))
- m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_INIT);
- mLog::Debug("RefreshData:gen state is GENERATOR_STATUS_INIT");
- ProcessCommand(SpecialCMDAR);
- ProcessCommand(SpecialCMDRF);
- ProcessCommand(SpecialCMDST);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetExpEnable()
- {
- ProcessCommand(SpecialCMDRX1);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetExpDisable()
- {
- ProcessCommand(SpecialCMDRX0);
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::Reset()
- {
- ProcessCommand(SpecialCMDAR);
- if (m_bExpoEnable.load() == false)
- {
- ProcessCommand(SpecialCMDRX1);
- }
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetExpMode(std::string value)
- {
- FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetFLFMode(std::string value)
- {
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetEXAMMode(std::string value)
- {
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::SetFrameRate(FLOAT frameRate)
- {
- return RET_STATUS::RET_SUCCEED;
- }
- RET_STATUS nsGEN::SDCDevice::HWSend (char* strCommand, int iWaitType , int nTimeOut)
- {
- int nWhileNumber = 0;
- if (!m_SCF)
- {
- mLog::Error("HWSend: m_SCF is null");
- return RET_STATUS::RET_FAILED;
- }
- else if (!m_sendEnable &&
- !(strncmp(strCommand, SpecialCMDAR,2) == 0 || strncmp(strCommand, SpecialCMDST, 2) == 0))//如果发生器处于错误状态,并且发送的不是AR或者ST命令,通通不发
- {
- mLog::Debug("HWSend: Don`t Send Command: [{$}]", strCommand);
- StopWait();
- return RET_STATUS::RET_FAILED;
- }
-
- ResetEvent(m_hGenCPEvent);
- ResetEvent(m_hGenACKEvent);
- ResetEvent(m_hGenSELFEvent);
-
- if(!m_bExpoFlag ||
- (m_bExpoFlag && (strncmp(strCommand, SpecialCMDXR1, 3) == 0 ||
- strncmp(strCommand, SpecialCMDXR0, 3) == 0 ||
- strncmp(strCommand, SpecialCMDPC, 2) == 0)))
- {
- char strSendCommand[100] = { 0 };
- int len = strlen(strCommand);
- if (len < 100)
- {
- ::memcpy(strSendCommand, strCommand, len);
- }
- strSendCommand[len] = 0x0d;
- strSendCommand[len + 1] = 0x0a;
- strSendCommand[len + 2] = 0x03;
- //strSendCommand [len + 3] = 0x00;
- mLog::Debug("==OUT==:[{$}]", strSendCommand);
- int ret = 0;
- m_SCF.Lock(msTimeOut_Lock)
- .SendPacket(strSendCommand, strlen(strSendCommand), nTimeOut, ret);
- //Sleep(nTimeOut);
- }
- else
- {
- StopWait();
- }
- return RET_STATUS::RET_SUCCEED;
- }
- void nsGEN::SDCDevice::WaitforSELF(const char* cmd, int lengh)
- {
- if (m_strCurrentCommand.strCommand.compare(0, lengh, cmd, 0, lengh) != 0)
- {
- return;
- }
- if (m_strCurrentCommand.nCommmandType % 10 > 0)
- {
- m_strCurrentCommand.nCommmandType -= 1;
- }
- mLog::Debug("WaitforSELF:get cmd[{$}]type[{$}] self", m_strCurrentCommand.strCommand.c_str(), m_strCurrentCommand.nCommmandType.load());
- SetEvent(m_hGenSELFEvent);
- }
- void nsGEN::SDCDevice::WaitforACK()
- {
- if (m_strCurrentCommand.nCommmandType % 100 >= 10)
- {
- m_strCurrentCommand.nCommmandType -= 10;
- }
- mLog::Debug("WaitforACK:get cmd[{$}]type[{$}] ACK", m_strCurrentCommand.strCommand.c_str(), m_strCurrentCommand.nCommmandType.load());
- SetEvent(m_hGenACKEvent);
- }
- void nsGEN::SDCDevice::WaitforCP()
- {
- if (m_strCurrentCommand.nCommmandType >= 100)
- {
- m_strCurrentCommand.nCommmandType -= 100;
- }
- mLog::Debug("WaitforCP:get cmd[{$}]type[{$}] cp", m_strCurrentCommand.strCommand.c_str(), m_strCurrentCommand.nCommmandType.load());
- SetEvent(m_hGenCPEvent);
- }
- void nsGEN::SDCDevice::StopWait()
- {
- if (!m_strCurrentCommand.strCommand.empty())
- {
- mLog::Debug("StopWait:cmd[{$}]type[{$}] not wait", m_strCurrentCommand.strCommand.c_str(), m_strCurrentCommand.nCommmandType.load());
- m_strCurrentCommand.nCommmandType = 0;
- }
- }
- void nsGEN::SDCDevice::FireNotify (std::string key, std::string content)
- {
- EventCenter->OnNotify (1, key, content);
- }
- bool nsGEN::SDCDevice::ProcessCommand(std::string strCommand, int nType, bool isFirstSend)
- {
- tagCommandStruct TempSDCCommand;
- TempSDCCommand.strCommand = strCommand;
- if (nType == -1)
- {
- TempSDCCommand.nCommmandType = 0;
- if (std::find_if(g_WaitSELF_List.begin(), g_WaitSELF_List.end(), [strCommand](const string& Item)
- {
- if (strCommand.compare(0, Item.length(), Item, 0, Item.length()) == 0)
- {
- return true;
- }
- return false;
- }) != g_WaitSELF_List.end())
- {
- TempSDCCommand.nCommmandType += 1;
- }
- if (std::find_if(g_WaitAKCMD_List.begin(), g_WaitAKCMD_List.end(), [strCommand](const string& Item)
- {
- if (strCommand.compare(0, Item.length(), Item, 0, Item.length()) == 0)
- {
- return true;
- }
- return false;
- }) != g_WaitAKCMD_List.end())
- {
- TempSDCCommand.nCommmandType += 10;
- }
- if (std::find_if(g_WaitCPCMD_List.begin(), g_WaitCPCMD_List.end(), [strCommand](const string& Item)
- {
- if (strCommand.compare(0, Item.length(), Item, 0, Item.length()) == 0)
- {
- return true;
- }
- return false;
- }) != g_WaitCPCMD_List.end())
- {
- TempSDCCommand.nCommmandType += 100;
- }
- }
- else
- TempSDCCommand.nCommmandType = nType;
- bool firstOldCMD = true;
- EnterCriticalSection(&m_iCriticalSection);
- //当发送ST,HU,SA,SX,DS,RX命令前,清空待发送命令vector中的其他同类型命令,提高发送效率,减少发送错误
- auto found = std::find_if(g_SpecialCMD_List.begin(), g_SpecialCMD_List.end(), [strCommand](const string& Item)
- {
- if (strCommand.compare(0, Item.length(), Item, 0, Item.length()) == 0)
- {
- return true;
- }
- return false;
- });
- if (found != g_SpecialCMD_List.end())
- {
- if ((strCommand.compare(SpecialCMDAR) == 0) || (strCommand.compare(SpecialCMDXR1) == 0))
- {
- //if (m_DoseUnit.m_GenState->Get() == nsGEN::AttrKey::GENERATOR_STATUS_STANDBY)
- //{
- m_SdcCommondvector.clear();
- mLog::Debug("ProcessCommand:clear the whole vector when get[{$}] ", strCommand.c_str());
- //}
- //else
- //{
- // mLog::Warn("ProcessCommand:isn`t GENERATOR_STATUS_STANDBY not clear");
- //}
- }
- else
- {
- //if (m_DoseUnit.m_GenState->Get() == nsGEN::AttrKey::GENERATOR_STATUS_STANDBY)
- //{
- for (int i = 0; i < m_SdcCommondvector.size(); i++)
- {
- if (m_SdcCommondvector[i].strCommand.compare(0, strCommand.length(),strCommand, 0, strCommand.length()) == 0)
- {
- if(firstOldCMD)
- {
- firstOldCMD = false;
- m_SdcCommondvector[i] = TempSDCCommand;
- mLog::Debug("ProcessCommand:replace first same command[{$}] in vector ", strCommand.c_str());
- }
- else
- {
- m_SdcCommondvector.erase(m_SdcCommondvector.begin() + i);
- i--;
- mLog::Debug("ProcessCommand:Clear other same command[{$}] in vector ", strCommand.c_str());
- }
- }
- }
- //}
- //else
- //{
- // mLog::Warn("ProcessCommand:isn`t GENERATOR_STATUS_STANDBY not replace");
- //}
- }
- }
- if(firstOldCMD)
- {
-
- if(TempSDCCommand.strCommand.compare(SpecialCMDRX1) == 0)
- {
- TempSDCCommand.nWaitTime = 10000;
- }
- if (isFirstSend)
- {
- mLog::Debug("ProcessCommand:add cmd[{$}][{$}] in vector begin",
- TempSDCCommand.strCommand.c_str(), TempSDCCommand.nCommmandType.load());
- m_SdcCommondvector.push_front(TempSDCCommand);
- }
- else
- {
- mLog::Debug("ProcessCommand:add cmd[{$}][{$}] in vector end",
- TempSDCCommand.strCommand.c_str(), TempSDCCommand.nCommmandType.load());
- m_SdcCommondvector.push_back(TempSDCCommand);
- }
- }
- LeaveCriticalSection(&m_iCriticalSection);
- return true;
- }
- bool nsGEN::SDCDevice::ReProcessCommand(std::string strCommand, int nType)
- {
- tagCommandStruct TempSDCCommand;
- TempSDCCommand.strCommand = strCommand;
- if (nType == -1)
- {
- TempSDCCommand.nCommmandType = 0;
- if (std::find_if(g_WaitSELF_List.begin(), g_WaitSELF_List.end(), [strCommand](const string& Item)
- {
- if (strCommand.compare(0, Item.length(), Item, 0, Item.length()) == 0)
- {
- return true;
- }
- return false;
- }) != g_WaitSELF_List.end())
- {
- TempSDCCommand.nCommmandType += 1;
- }
- if (std::find_if(g_WaitAKCMD_List.begin(), g_WaitAKCMD_List.end(), [strCommand](const string& Item)
- {
- if (strCommand.compare(0, Item.length(), Item, 0, Item.length()) == 0)
- {
- return true;
- }
- return false;
- }) != g_WaitAKCMD_List.end())
- {
- TempSDCCommand.nCommmandType += 10;
- }
- if (std::find_if(g_WaitCPCMD_List.begin(), g_WaitCPCMD_List.end(), [strCommand](const string& Item)
- {
- if (strCommand.compare(0, Item.length(), Item, 0, Item.length()) == 0)
- {
- return true;
- }
- return false;
- }) != g_WaitCPCMD_List.end())
- {
- TempSDCCommand.nCommmandType += 100;
- }
- }
- else
- TempSDCCommand.nCommmandType = nType;
- EnterCriticalSection(&m_iCriticalSection);
- m_SdcCommondvector.push_front(TempSDCCommand);
- LeaveCriticalSection(&m_iCriticalSection);
- return true;
- }
- DWORD SDCDevice::SedecalSendingCommandsThread(LPVOID pParam)
- {
- mLog::Debug("Enter SedecalSendingCommandsThread");
- SDCDevice* pCurrentGen = (SDCDevice*)pParam;
- if (pCurrentGen == NULL)
- {
- mLog::Error("SendingCommandsThread is null");
- return 0;
- }
- //indicating start thread success;
- SetEvent(pCurrentGen->m_hSendingThreadToggleEvent);
- //perform sending sedecal commands
- while (!pCurrentGen->m_bSendingCommandsThreadExit)
- {
- //query the command from the vector
- if (pCurrentGen->m_SdcCommondvector.size() > 0)
- {
- EnterCriticalSection(&(pCurrentGen->m_iCriticalSection));
- pCurrentGen->m_strCurrentCommand = pCurrentGen->m_SdcCommondvector[0];
- pCurrentGen->m_SdcCommondvector.pop_front();//erase the first command
- mLog::Debug("SendingCommandsThread:get cmd[{$}]type[{$}] from vector",
- pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType.load());
- LeaveCriticalSection(&(pCurrentGen->m_iCriticalSection));
- if (pCurrentGen->m_strCurrentCommand.strCommand != "" && pCurrentGen->m_strCurrentCommand.nCommmandType.load() >= 0)// with commnad
- {
- //if (pCurrentGen->m_strCurrentCommand.strCommand.compare(0, 2, SpecialCMDHU) == 0 || pCurrentGen->m_strCurrentCommand.strCommand.compare(0, 2, SpecialCMDIT) == 0) //not wait command
- //{
- // pCurrentGen->m_strCurrentCommand.nCommmandType = 0;
- // pCurrentGen->HWSend((char*)pCurrentGen->m_strCurrentCommand.strCommand.c_str(), 0);
- //}else
- if (pCurrentGen->m_strCurrentCommand.strCommand.compare(0, 2, SpecialCMDSA) == 0 ||
- pCurrentGen->m_strCurrentCommand.strCommand.compare(0, 2, SpecialCMDSX) == 0)//APR command, dual energy command
- {
- pCurrentGen->HWSend((char*)pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType, 3000);
- }
- else if (pCurrentGen->m_strCurrentCommand.strCommand.compare(0,3, SpecialCMDFOS) == 0) //FO command
- {
- pCurrentGen->HWSend((char*)pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType, 1000);
- }
- else
- {
- pCurrentGen->HWSend((char*)pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType);
- }
- //等待
- if (pCurrentGen->m_strCurrentCommand.nCommmandType > 0)
- {
- int waitType = pCurrentGen->m_strCurrentCommand.nCommmandType.load();
- int arrayNum = 0;
- bool cmdOver = false;
- HANDLE hEventArray[3];
- if (waitType % 10 > 0)
- {
- hEventArray[arrayNum] = pCurrentGen->m_hGenSELFEvent;
- arrayNum++;
- }
- if (waitType % 100 >= 10)
- {
- hEventArray[arrayNum] = pCurrentGen->m_hGenACKEvent;
- arrayNum++;
- }
- if (waitType >= 100)
- {
- hEventArray[arrayNum] = pCurrentGen->m_hGenCPEvent;
- arrayNum++;
- }
- mLog::Debug("SendingCommandsThread:wait cmd[{$}]type[{$}][{$}]waitTime[{$}]",
- pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType.load(), arrayNum, pCurrentGen->m_strCurrentCommand.nWaitTime);
- int waitTime = pCurrentGen->m_strCurrentCommand.nWaitTime;
- DWORD dwResult = WaitForMultipleObjects(arrayNum, hEventArray, TRUE, waitTime);
- switch (dwResult)
- {
- case WAIT_OBJECT_0:
- mLog::Debug("SendingCommandsThread:cmd[{$}]type[{$}] is over",
- pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType.load());
- cmdOver = true;
- pCurrentGen->m_TimeoutReset = 0;
- break;
- case WAIT_TIMEOUT:
- mLog::Debug("SendingCommandsThread:cmd[{$}]type[{$}] is timeout",
- pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType.load());
- if (pCurrentGen->m_strCurrentCommand.nCommmandType.load() == 0)
- {
- cmdOver = true;
- pCurrentGen->m_TimeoutReset = 0;
- }
- break;
- case WAIT_FAILED:
- mLog::Debug("SendingCommandsThread:cmd[{$}]type[{$}] is failed",
- pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType.load());
- break;
- }
- if (!cmdOver)
- {
- if (pCurrentGen->m_TimeoutReset <= 3)
- {
- pCurrentGen->m_TimeoutReset++;
- pCurrentGen->ReProcessCommand(pCurrentGen->m_strCurrentCommand.strCommand);
- }
- else
- {
- pCurrentGen->m_TimeoutReset = 0;
- mLog::Warn("SendingCommandsThread:cmd[{$}]type[{$}] Exceeded attempts",
- pCurrentGen->m_strCurrentCommand.strCommand.c_str(), pCurrentGen->m_strCurrentCommand.nCommmandType.load());
- }
- }
- else
- {
- Sleep(30);//no commnad to send, so sleep 10 ms
- }
- }
- }
- else
- {
- Sleep(30);//no commnad to send, so sleep 10 ms
- }
- }
- else
- {
- Sleep(10);//no commnad to send, so sleep 10 ms
- }
- // send command
- if (!(pCurrentGen->m_bExpoFlag)) //add by wxx for bug6038 20230919
- {
- DWORD tmNowTime = GetTickCount();
- if (tmNowTime > 15000)
- {
- long runTime = tmNowTime - pCurrentGen->m_tmSysTime;
- if (runTime > 15000)
- {
- pCurrentGen->m_tmSysTime = tmNowTime;
- //pCurrentGen->ProcessCommand(SpecialCMDHU, WaitForCPSELF);
- //pCurrentGen->ProcessCommand(SpecialCMDIT, WaitForNothing);
- }
- }
- else
- {
- pCurrentGen->m_tmSysTime = GetTickCount();
- }
- }
- }
- mLog::Debug("End SendingCommandsThread!!");
- //indicating the end of thread;
- SetEvent(pCurrentGen->m_hSendingThreadToggleEvent);
- return 0;
- }
- //start timer to do offset calibration periodically;
- bool SDCDevice::StartSendingCommandsThread()
- {
- //create thread;
- DWORD m_HardwareStatusID;
- m_SendingCommandsThread = CreateThread(0, 0, SedecalSendingCommandsThread, this, 0, &m_HardwareStatusID);
- mLog::Debug("Enter StartSendingCommandsThread beion");
- if (NULL == m_SendingCommandsThread)
- {
- mLog::Debug("StartSendingCommandsThread failed \n");
- return false;
- }
- //wait till thread create successful;
- if (WaitForSingleObject(m_hSendingThreadToggleEvent, 5000) == WAIT_OBJECT_0)
- {
- mLog::Debug("detected the start of sending commands thread!");
- ResetEvent(m_hSendingThreadToggleEvent);
- }
- mLog::Debug("StartSendingCommandsThread end \n");
- m_nSendingCommandsThreadId = m_HardwareStatusID;
- return true;
- }
- bool SDCDevice::SetAcquireSatus()
- {
- ProcessCommand("RFW");
- return true;
- }
- //stop sending commands thread periodically;
- void SDCDevice::StopSendingCommandsThread()
- {
- mLog::Debug("sending commands thread exiting...");
- if (NULL != m_SendingCommandsThread)
- {
- m_bSendingCommandsThreadExit = true;
- if (::WaitForSingleObject(m_hSendingThreadToggleEvent, 5000) == WAIT_OBJECT_0)
- {
- mLog::Debug("detected the exit of sending commands thread!");
- ResetEvent(m_hSendingThreadToggleEvent);
- }
- else
- {
- DWORD exitCode = 0;
- //Retrieves the termination status of the specified thread;
- if (!GetExitCodeThread(m_SendingCommandsThread, &exitCode))
- {
- DWORD nError = ::GetLastError();
- mLog::Debug("GetExitCodeThread() error, error No is [{$}]", nError);
- }
- TerminateThread(m_SendingCommandsThread, exitCode);
- }
- m_SendingCommandsThread = NULL;
- }
- }
- // 收到硬件的通知, 有包到达
- // 按照设计, 仅当数据有变化时, 才发通知到上层, 因此里面有大量的 if (..) FireNotify (..)
- void nsGEN::SDCDevice::OnCallBack ()
- {
- auto HWNotProcess = [] (const char * value, int length) -> void
- {
- printf ("\n This commands didn't need to process!\n");
- };
- auto HWKV = [this] (const char * value, int length) -> void
- {
- assert (value);
- mLog::Debug("Recv KV={$}", value);
- if (m_DoseUnit.m_KV->Verify(atof(value)))
- {
- m_DoseUnit.m_KV->Update(atof(value));
- FireNotify(AttrKey::KV, value);
- m_sPreAPRvalue.fKV = atof(value);
- }
- };
- auto HWMAS = [this] (const char * value, int length)
- {
- assert (value);
- mLog::Debug("Recv MAS={$}", value);
- if (m_DoseUnit.m_MAS->Verify(atof(value)))
- {
- m_DoseUnit.m_MAS->Update(atof(value));
- FireNotify(AttrKey::MAS, value);
- if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
- m_sPreAPRvalue.fMAS = atof(value);
- }
- };
- auto HWMA = [this] (const char * value, int length)
- {
- assert (value);
- mLog::Debug("Recv MA={$}", value);
- if (m_DoseUnit.m_MA->Verify(atof(value)))
- {
- m_DoseUnit.m_MA->Update(atof(value));
- FireNotify(AttrKey::MA, value);
- if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_MAS)
- m_sPreAPRvalue.fMA = atof(value);
- }
- };
- auto HWMS = [this] (const char * value, int length)
- {
- assert (value);
- mLog::Debug("Recv MS={$}", value);
- if (m_DoseUnit.m_MS->Verify(atof(value)))
- {
- m_DoseUnit.m_MS->Update(atof(value));
- FireNotify(AttrKey::MS, value);
- if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_MAS)
- m_sPreAPRvalue.fMS = atof(value);
- }
- };
- auto HWFocus = [this] (const char * value, int length)
- {
- assert (value);
- mLog::Debug("Recv FO={$}", value);
- string strval = value;
- if (strval.find("11") != string::npos || strval.find("20") != string::npos)
- {
- m_DoseUnit.m_Focus->Update(0);
- }
- else if (strval.find("10") != string::npos || strval.find("21") != string::npos)
- {
- m_DoseUnit.m_Focus->Update(1);
- }
-
- FireNotify (AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
- if (m_DoseUnit.m_Focus->Get() == AttrKey::FOCUS_SMALL) //add by wxx for demand574
- FireNotify(AttrKey::FOCUSSIZE, std::to_string(m_DoseUnit.m_FocusSmall));
- else
- FireNotify(AttrKey::FOCUSSIZE, std::to_string(m_DoseUnit.m_FocusLarge));
- };
- auto HWTechmode = [this] (const char * value, int length)
- {
- assert(value);
- //实际发送长数据
- //bool rc = false;
- //int ntechmode = atoi (value);
- //if (ntechmode == 2)
- //{
- // rc = m_DoseUnit.m_Techmode->Update(GENPARAM::ET_MAS);
- //}
- //else
- //{
- // if (m_DoseUnit.m_AECField->Get () == 0)
- // rc = m_DoseUnit.m_Techmode->Update(GENPARAM::ET_TIME);
- // else
- // rc = m_DoseUnit.m_Techmode->Update(GENPARAM::ET_AEC);
- //}
- //if (rc)
- // FireNotify (AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
- // printf ("\r\n%s : %f\n", m_DoseUnit.m_Techmode->Key.c_str (), m_DoseUnit.m_Techmode->m_Val);
- };
- auto HWAECField = [this] (const char * value, int length)
- {
- int nvalue = atoi (value);
- auto nToValue = m_DoseUnit.m_AECField->Get ();
- switch (nvalue / 10)
- {
- case 0:
- if (nvalue % 10 == 0)
- nToValue = nToValue & 110;
- else
- nToValue = nToValue | 001;
- break;
- case 1:
- if (nvalue % 10 == 0)
- nToValue = nToValue & 101;
- else
- nToValue = nToValue | 010;
- break;
- case 2:
- if (nvalue % 10 == 0)
- nToValue = nToValue & 11;
- else
- nToValue = nToValue | 100;
- break;
- default:
- break;
- }
- if (m_DoseUnit.m_AECField->Update (nToValue))
- {
- FireNotify(AttrKey::AECFIELD, value);
- if(m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_AEC)
- m_sPreAPRvalue.nAECField = nToValue;
- }
- };
- auto HWAECFilm = [this] (const char * value, int length)
- {
- assert (value);
- if (m_DoseUnit.m_AECFilm->Update(atoi (value)))
- {
- FireNotify(AttrKey::AECFILM, value);
- if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_AEC)
- m_sPreAPRvalue.nAECField = atoi(value);
- }
- };
- auto HWAECDensity = [this] (const char * value, int length)
- {
- assert (value);
- if (atoi(value) % 10 != 0)
- {
- if (m_DoseUnit.m_AECDensity->Update(atoi(value) / 10 - 4))
- {
- FireNotify(AttrKey::AECDENSITY, m_DoseUnit.m_AECDensity->JSGet());
- if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_AEC)
- m_sPreAPRvalue.nAECField = atoi(value) / 10 - 4;
- }
- }
- };
- auto HWWS = [this](const char* value, int length)
- {
- assert(value);
- int nValue = atoi(value);
- if (m_DoseUnit.m_WS->Update(nValue))
- {
- FireNotify(m_DoseUnit.m_WS->GetKey(), m_DoseUnit.m_WS->JSGet());
- }
-
- };
- auto HWPR = [this](const char* value, int length)
- {
- assert(value);
- int nValue = atoi(value);
- if (nValue == 1)
- {
- m_bExpoFlag = true;
- ResetEvent(m_hGenPostEvent);
- 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)
- {
- mLog::Debug("HWPR:GEN is already in Prep state(PR1)");
- }
- else if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_OFF)
- {
- mLog::Debug("HWPR: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
- {
- mLog::Warn("HWPR: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());
- }
- m_nSoftSynPR1Flag = true;
- }
- else if (nValue == 2)
- {
- 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)
- {
- mLog::Debug("HWPR:GEN is already to make X-Rays(PR2)");
- }
- else if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_PREPARE)
- {
- mLog::Debug("HWPR: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
- {
- mLog::Warn("HWPR: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
- {
- m_bExpoFlag = false;
- mLog::Debug("HWPR:GEN exit 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());
- m_nSoftSynPR1Flag = false;
- }
- };
- auto HWXR = [this](const char* value, int length)
- {
- assert(value);
- int nValue = atoi(value);
- if (nValue == 1)
- {
- WaitforSELF("XR",2);
- if(m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYON)) //add by wxx for bug6079 20230915
- FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
- }
- else
- {
- m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYOFF);
- ProcessCommand(SpecialCMDPC); //add by wxx
- //ProcessCommand("PD?",WaitForACK); //add by wxx:Not working
- //ProcessCommand("PDN?",WaitForACK); //add by wxx:Not working
-
- FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
- }
- };
- auto HWXS = [this](const char* value, int length)
- {
- assert(value);
- int nValue = atoi(value);
- if (nValue == 1)
- {
- if (m_nSoftSynPR1Flag)
- {
- if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_READY))
- FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
- }
- else
- {
- //mLog::Warn("HWXS:not recv PR1,need to wait PR1 to RAD_READY");
- 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)
- {
- mLog::Debug("HWPR:GEN is already to make X-Rays(PR2)");
- }
- else if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_PREPARE)
- {
- mLog::Debug("HWPR: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
- {
- mLog::Warn("HWPR: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(m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYOFF))
- // FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
- //ProcessCommand(SpecialCMDPC); //add by wxx
- //ProcessCommand("PD?",WaitForACK); //add by wxx:Not working
- //ProcessCommand("PDN?",WaitForACK); //add by wxx:Not working
- //FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
- }
- };
- auto HWRX = [this](const char* value, int length) -> void
- {
- assert(value);
- int nValue = atoi(value);
- if (nValue == 1)
- {
- mLog::Debug("HWRX:[{$}],exp enable", nValue);
- m_bExpoEnable = true;
- }
- else
- {
- mLog::Debug("HWRX:[{$}],exp disable", nValue);
- m_bExpoEnable = false;
- }
- WaitforSELF(SpecialCMDRX,2);
- };
- auto HWDOSE = [this](const char* value, int length) //PC:<mA> <mAs> <ms> <dose>
- {
- assert(value);
- string strval = value;
- if (length >= 13)
- {
- //解析Post值 aaaa bbbb ccccc aaaa postma, ccccc postms
- m_DoseUnit.m_PostKV->Update(m_DoseUnit.m_KV->Get());
- FireNotify(m_DoseUnit.m_PostKV->GetKey(), m_DoseUnit.m_PostKV->JSGet());
- m_DoseUnit.m_PostMA->Update(atof(strval.substr(0,4).c_str()));
- FireNotify(m_DoseUnit.m_PostMA->GetKey(), m_DoseUnit.m_PostMA->JSGet());
- m_DoseUnit.m_PostMS->Update(atof(strval.substr(8, 5).c_str()));
- FireNotify(m_DoseUnit.m_PostMS->GetKey(), m_DoseUnit.m_PostMS->JSGet());
- m_DoseUnit.m_PostMAS->Update(m_DoseUnit.m_PostMA->Get()* m_DoseUnit.m_PostMS->Get() / 1000.0);
- FireNotify(m_DoseUnit.m_PostMAS->GetKey(), m_DoseUnit.m_PostMAS->JSGet());
- SetEvent(m_hGenPostEvent);
- }
- if (length == 19)
- {
- //解析DAP值 后六位ddd eff ddd*10^eff mGycm2, mGycm2/100=dGycm2
- }
- };
- auto HWPD = [this](const char* value, int length)//add by wxx:PD:<mA> <mAs> <ms>
- {
- assert(value);
- string strval = value;
- if (length >= 13)
- {
- //解析Post值 aaaa bbbb ccccc aaaa postma, ccccc postms
- m_DoseUnit.m_PostKV->Update(m_DoseUnit.m_KV->Get());
- FireNotify(m_DoseUnit.m_PostKV->GetKey(), m_DoseUnit.m_PostKV->JSGet());
- m_DoseUnit.m_PostMA->Update(atof(strval.substr(0, 4).c_str()));
- FireNotify(m_DoseUnit.m_PostMA->GetKey(), m_DoseUnit.m_PostMA->JSGet());
- m_DoseUnit.m_PostMS->Update(atof(strval.substr(8, 5).c_str()));
- FireNotify(m_DoseUnit.m_PostMS->GetKey(), m_DoseUnit.m_PostMS->JSGet());
- m_DoseUnit.m_PostMAS->Update(m_DoseUnit.m_PostMA->Get() * m_DoseUnit.m_PostMS->Get() / 1000.0);
- FireNotify(m_DoseUnit.m_PostMAS->GetKey(), m_DoseUnit.m_PostMAS->JSGet());
- SetEvent(m_hGenPostEvent);
- }
- };
- auto HWERROR = [this](const char* value, int length)
- {
- assert(value);
- int nValue = atoi(value);
- if (nValue != 0)
- {
- if (99 == nValue)
- {
- char WarnCode[100]{ "" };
- sprintf_s(WarnCode, "SDC_WARN_%d", nValue);
- int level = 1;
- m_MSGUnit->AddWarnMessage(WarnCode, level, "");
- mLog::Debug("HWERROR: recv ER099,try to ReSet");
- ProcessCommand(SpecialCMDAR);
- ProcessCommand(SpecialCMDRF);
- ProcessCommand(SpecialCMDST);
- ProcessCommand(SpecialCMDRX1);
- }
- else
- {
- char ErrorCode[100]{ "" };
- sprintf_s(ErrorCode, "SDC_ERR_%d", nValue);
- int level = 1;
- m_MSGUnit->AddErrorMessage(ErrorCode, level, "");
- m_sendEnable = false;//error 阶段,禁止发送指令
- mLog::Debug("HWERROR: [{$}] -> STATUS_ERROR", m_DoseUnit.m_GenState->Get());
- if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_ERROR))
- FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
- }
- }
- else
- {
- if (99 == nValue)
- {
- int level = 1;
- char ErrorCode[100]{ "" };
- m_MSGUnit->DelWarnMessage(ErrorCode, level, "");
- }
- else
- {
- int level = 1;
- char ErrorCode[100]{ "" };
- m_MSGUnit->DelErrorMessage(ErrorCode, level, "");
- m_sendEnable = true;
- mLog::Debug("HWERROR: [{$}] -> STATUS_STANDBY", m_DoseUnit.m_GenState->Get());
- if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_STANDBY))
- FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
- }
- }
- };
- auto HWAR = [this](const char* value, int length)
- {
- WaitforSELF(SpecialCMDAR, 2);
- assert(value);
- int nValue = atoi(value);
- if (nValue != 0)
- {
- Reset();
- }
- };
- auto HWHE = [this](const char* value, int length) -> void
- {
- WaitforSELF(SpecialCMDHU, 2);
- assert(value);
- mLog::Debug("Recv HE={$}", value);
- if (m_DoseUnit.m_HE->Update(atoi(value)))
- FireNotify(AttrKey::TUBEHEAT, value);
- };
- auto HWIT = [this](const char* value, int length) -> void
- {
- assert(value);
- mLog::Debug("Recv IT={$}", value);
- if (m_DoseUnit.m_KV->Update(atoi(value)))
- FireNotify(AttrKey::DENHEAT, value);
- };
- auto HWSA = [this](const char* value, int length) -> void
- {
- WaitforSELF(SpecialCMDSA,2);
- };
- auto HWSX = [this](const char* value, int length) -> void
- {
- WaitforSELF(SpecialCMDSX, 2);
- };
- auto HWDS = [this](const char* value, int length) -> void
- {
- WaitforSELF(SpecialCMDDS, 2);
- };
- auto HWST = [this](const char* value, int length) -> void
- {
- mLog::Debug("HWST:[{$}]", value);
- WaitforSELF(SpecialCMDST, 2);
- assert(value);
- switch (atoi(value))
- {
- case 1: //1. - Initialization phase
- {
- mLog::Debug("HWST:Initialization Phase");
- if (m_DoseUnit.m_GenState->Get() < nsGEN::AttrKey::GENERATOR_STATUS_INIT)
- {
- mLog::Debug("HWST:GENSTATE {$} -> STATUS_INIT", m_DoseUnit.m_GenState->JSGet());
- m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_INIT);
- FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
- }
- }
- break;
- case 2: //2. - Standby
- {
- mLog::Debug("HWST:Standby");
- if (m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_STANDBY)
- {
- mLog::Debug("HWST: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());
- }
- }
- break;
- case 3: //3. - Preparation
- {
- mLog::Debug("HWST:Preparation");
- if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_OFF)
- {
- mLog::Debug("get Gen Status_3: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());
- }
- }
- break;
- case 4: //4. - Exposure
- {
- mLog::Debug("HWST:Exposure");
- //更新发生器状态并上报,否则会影响工作流 FrameEnable -> FrameReady 的转变
- mLog::Debug("HWST: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());
- if (m_DoseUnit.m_GenSynState->Get() == nsGEN::AttrKey::GENERATOR_RAD_PREPARE)
- {
- mLog::Debug("get Gen Status_4:PREPARE(PR1) -> 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());
- }
- }
- break;
- case 5: //5.- Fluoro
- {
- mLog::Debug("HWST:Fluoro");
- }
- break;
- case 6: //6. - Filament Current Calibration
- {
- mLog::Debug("HWST:Filament Current Calibration");
- }
- break;
- case 7: //7. - Unrecoverable Error
- {
- mLog::Debug("HWST:Unrecoverable Error");
- mLog::Debug("get Gen Status_7:GENSTATE {$} -> STATUS_ERROR", m_DoseUnit.m_GenState->JSGet());
- if(m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_ERROR))
- FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
- }
- break;
- case 8: //8. - Configuration
- {
- mLog::Debug("HWST:Configuration");
- }
- break;
- case 9: //9. - AutoCalibration
- {
- mLog::Debug("HWST:AutoCalibration");
- }
- break;
- case 10: //10. - Parameters Calibration
- {
- mLog::Debug("HWST:Parameters Calibration");
- }
- break;
- case 11: //11. - Recoverable Error
- {
- mLog::Debug("HWST:Recoverable Error");
- mLog::Debug("get Gen Status_11:GENSTATE {$} -> STATUS_ERROR", m_DoseUnit.m_GenState->JSGet());
- if(m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_ERROR))
- FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
- }
- break;
- default:
- mLog::Debug("get Gen Status:[{$}] unknown", atoi(value));
- break;
- }
- };
- auto HWAK = [this](const char* value, int length) -> void
- {
- WaitforACK();
- };
- auto HWZCP = [this](const char* value, int length) -> void
- {
- WaitforCP();
- };
- auto HWCP = [this](const char* value, int length) -> void
- {
- WaitforCP();
- };
- // 有部分前缀是包含关系, 长的包含短的, 例如 KVS 包含了 KV.
- // 因此长的在前面, 短的在后面
- // !!! Device 是个短寿命对象, 而 arFrame 是静态变量 !!!
- // !!! 因此, 在添加到 arFrame 之前, 务必先清零 !!!
- arFrame.clear ();
- arFrame.push_back (tFrameMapping ("AK", 2, HWAK));
- arFrame.push_back (tFrameMapping ("ZCP", 3, HWZCP));
- arFrame.push_back (tFrameMapping ("CP", 2, HWCP));
- arFrame.push_back (tFrameMapping ("KV+", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("KV-", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("MA+", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("MA-", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("MS+", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("MS-", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("MX+", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("MX-", 3, HWNotProcess));
- arFrame.push_back (tFrameMapping ("KVS", 3, HWKV));
- arFrame.push_back (tFrameMapping ("MXS", 3, HWMAS));
- arFrame.push_back (tFrameMapping ("MAS", 3, HWMA));
- arFrame.push_back (tFrameMapping ("MSS", 3, HWMS));
- arFrame.push_back (tFrameMapping ("KV", 2, HWKV));
- arFrame.push_back (tFrameMapping ("MX", 2, HWMAS));
- arFrame.push_back (tFrameMapping ("MA", 2, HWMA));
- arFrame.push_back (tFrameMapping ("MS", 2, HWMS));
- arFrame.push_back (tFrameMapping ("TM", 2, HWTechmode));
- arFrame.push_back (tFrameMapping ("FO", 2, HWFocus));
- arFrame.push_back (tFrameMapping ("FI", 2, HWAECField));
- arFrame.push_back (tFrameMapping ("FS", 2, HWAECFilm));
- arFrame.push_back (tFrameMapping ("FN", 2, HWAECDensity));
- arFrame.push_back (tFrameMapping ("WS", 2, HWWS));
- arFrame.push_back (tFrameMapping ("PR", 2, HWPR));
- arFrame.push_back (tFrameMapping ("XR", 2, HWXR));
- arFrame.push_back (tFrameMapping ("XS", 2, HWXS));
- arFrame.push_back (tFrameMapping ("RX", 2, HWRX));
- arFrame.push_back (tFrameMapping ("PC", 2, HWDOSE));
- arFrame.push_back (tFrameMapping ("PD", 2, HWPD));
- arFrame.push_back (tFrameMapping ("ER", 2, HWERROR));
- arFrame.push_back (tFrameMapping ("AR", 2, HWAR));
- arFrame.push_back (tFrameMapping ("HE", 2, HWHE));
- arFrame.push_back (tFrameMapping ("IT", 2, HWIT));
- arFrame.push_back (tFrameMapping ("SA", 2, HWSA));
- arFrame.push_back (tFrameMapping ("SX", 2, HWSX));
- arFrame.push_back (tFrameMapping ("DS", 2, HWDS));
- arFrame.push_back (tFrameMapping ("ST", 2, HWST));
- }
- //-----------------------------------------------------------------------------
- // SDCDriver
- //-----------------------------------------------------------------------------
- nsGEN::SDCDriver::SDCDriver ()
- {
- m_pAttribute.reset(new ResDataObject());
- m_pDescription.reset(new ResDataObject());
- }
- nsGEN::SDCDriver::~SDCDriver ()
- {
- }
- auto nsGEN::SDCDriver::CreateDevice (int index) -> std::unique_ptr <IODevice>
- {
- if (!m_SCF.isConnected())
- return nullptr;
- auto dev = std::unique_ptr <IODevice>(new IODevice(new SDCDevice(EventCenter, m_SCF,m_ConfigFileName)));
- return dev;
- }
- void nsGEN::SDCDriver::FireNotify (int code, std::string key, std::string content)
- {
- EventCenter->OnNotify (code, key, content);
- }
- Log4CPP::Logger* mLog::gLogger = nullptr;
- void nsGEN::SDCDriver::Prepare ()
- {
- string strLogPath = GetProcessDirectory() + R"(\OEMDrivers\Generator\Conf\Log4CPP.Config.GEN.xml)";
- Log4CPP::GlobalContext::Map::Set(ECOM::Utility::Hash("LogFileName"), "GEN.SDC");
- auto rc = Log4CPP::LogManager::LoadConfigFile(strLogPath.c_str());
- mLog::gLogger = Log4CPP::LogManager::GetLogger("GEN.SDC");
- m_SCFDllName = GetConnectDLL(m_ConfigFileName);
- super::Prepare ();
- }
- bool nsGEN::SDCDriver::Connect ()
- {
- ResDataObject Connection = GetConnectParam(m_ConfigFileName);
- mLog::Info("connections:{$} \n", Connection.encode());
- auto erCode = m_SCF.Connect(Connection.encode(), &nsGEN::SDCDriver::callbackPackageProcess, SCF_PACKET_TRANSFER, 3000);
- if (erCode != SCF_ERR::SCF_SUCCEED)
- return false; // erCode;
- auto rc = super::Connect();
- if (!rc)
- return false;
- //return (erCode == SCF_ERR::SCF_SUCCEED);
- return true; // SCF_ERR::SCF_SUCCEED;
- }
- void nsGEN::SDCDriver::Disconnect()
- {
- super::Disconnect();
- m_SCF.Disconnect();
- }
- bool nsGEN::SDCDriver::isConnected() const
- {
- return super::isConnected();
- }
- std::string nsGEN::SDCDriver::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", "SDC");
- HardwareInfo.add ("ProductID", "HF");
- HardwareInfo.add ("SerialID", "Drv");
- }
- string ret = HardwareInfo.encode ();
- return ret;
- }
- bool nsGEN::SDCDriver::GetDeviceConfig(std::string& Cfg)
- {
- Cfg = m_DeviceConfigSend.encode();
- printf("GetDeviceConfig over , %s",Cfg.c_str());
- return true;
- }
- bool nsGEN::SDCDriver::SetDeviceConfig(std::string Cfg)
- {
- mLog::Debug("--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"];
- mLog::Debug("Attribute:{$}", DescriptionTempEx.encode());
- bool bSaveFile = false; //true:重新保存配置文件
- string strAccess = "";
- for (int i = 0; i < DescriptionTempEx.size(); i++)
- {
- string strKey = DescriptionTempEx.GetKey(i);
- mLog::Debug("{$}", 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");
- mLog::Debug("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]))
- {
- mLog::Debug("SetDeviceConfigValue over");
- bSaveFile = true;
- }
- }
- else
- {
- mLog::Debug("{$} is not a RW configuration item", strKey.c_str());
- }
- }
- else
- {
- mLog::Debug("without this attribute {$}", strKey.c_str());
- }
- }
- catch (ResDataObjectExption& e)
- {
- printf("\nSetDriverConfig crashed: %s\n", e.what());
- mLog::Error("SetDriverConfig crashed: {$}", e.what());
- return false;
- }
- }
- if (bSaveFile)
- {
- //3. 重新保存配置文件
- SaveConfigFile(true);
- }
- return true;
- }
- bool nsGEN::SDCDriver::SaveConfigFile(bool bSendNotify)
- {
- m_ConfigAll["CONFIGURATION"] = m_Configurations;
- bool bRt = m_ConfigAll.SaveFile(m_ConfigFileName.c_str());
- mLog::Debug("SaveConfigFile over {$}", bRt);
- return true;
- }
- bool nsGEN::SDCDriver::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::SDCDriver::SetDeviceConfigValue(ResDataObject& config, const char* pInnerKey, int nPathID, const char* szValue)
- {
- string strTemp = pInnerKey;
- mLog::Debug("Begin to change {$} item value to {$}", pInnerKey, szValue);
- printf("bBegin to change {%s} item value to {%s}", 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)
- {
- mLog::Error("SetDriverConfigvalue crashed: {$}", e.what());
- return false;
- }
- }
- return true;
- }
- std::string nsGEN::SDCDriver::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)
- {
- mLog::Error("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;
- //mLog::Debug("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());
- //mLog::Debug("get resource over {$}", DescriptionTempEx.encode());
- printf("************* get resource over %s \n", DescriptionTempEx.encode());
- return res;
- }
- std::string nsGEN::SDCDriver::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", "SDC");
- HardwareInfo.add ("ProductID", "HF");
- HardwareInfo.add ("SerialID", "1234");
- }
- string ret = HardwareInfo.encode ();
- return ret;
- }
- void nsGEN::SDCDriver::Dequeue (const char * Packet, DWORD Length)
- {
- mLog::Debug("Dequeue:Get MSG");
- DecodeFrame (Packet, Length);
- }
- PACKET_RET nsGEN::SDCDriver::callbackPackageProcess (const char * RecData, DWORD nLength, DWORD& PacketLength)
- {
- //判断是否是整包
- /*
- 这个是回调函数,我收到的数据会需要这个回调函数帮我判断是否是整个的包;
- 如果有整个的包,返回值为true,在PacketLength处返回给我整个包的长度,我再截取后放入缓存供上层使用;
- 如果缓存中的数据没有整个的数据包,那么返回false
- */
- if (nLength < 1)
- {
- printf ("nLength < 1, nLength==%d \n", nLength);
- return PACKET_USELESS;
- }
- for (DWORD i = 0; i < nLength - 1; i++)
- {
- if (RecData [i] == 0x0d && RecData [i + 1] == 0x0a)
- {
- PacketLength = i + 2;
- char strtemp [100] = { 0 };
- ::memcpy(strtemp, RecData, i);
- strtemp [PacketLength + 1] = 0;
- //printf ("==IN ==:%s\n", strtemp);
- mLog::Debug("==IN==:[{$}]", strtemp);
- //printf("==IN(Hex) ==:");
- //for (int j = 0; j < i; j++)
- //{
- // printf("%02X ", RecData[j]);
- //}
- //printf("\n");
- return PACKET_ISPACKET;
- }
- else if (RecData [i] == 0x03)
- {
- printf ("(Hex)0x03 ,len=%d \n", i);
- PacketLength = i + 1;
- return PACKET_USELESS;
- }
- }
- return PACKET_NOPACKET;
- }
- //-----------------------------------------------------------------------------
- // DecodeFrame
- //-----------------------------------------------------------------------------
- static bool DecodeFrame (const char* strFrame, int length)
- {
- auto pr = [ strFrame, length ] (const tFrameMapping& Item)
- {
- for (int i = 0; i < Item.NbOfCharOfHead; i++)
- {
- if (strFrame [i] != Item.strHead [i])
- {
- return false;
- }
- }
- return true;
- };
- auto found = std::find_if (arFrame.begin (), arFrame.end (), pr);
- if (found == arFrame.end ())
- {
- return false;
- }
- const auto& Item = *found;
- auto pc = strFrame;
- pc += Item.NbOfCharOfHead;
- Item.fun (pc, length - Item.NbOfCharOfHead);
- return true;
- }
- //-----------------------------------------------------------------------------
- // GetIODriver & CreateIODriver
- //-----------------------------------------------------------------------------
- static nsGEN::SDCDriver gIODriver;
- extern "C" CCOS::Dev::IODriver * __cdecl GetIODriver () // 返回静态对象的引用, 调用者不能删除 !
- {
- return &gIODriver;
- }
- extern "C" CCOS::Dev::IODriver * __cdecl CreateIODriver () // 返回新对象, 调用者必须自行删除此对象 !
- {
- return new nsGEN::SDCDriver ();
- }
|