CCOS.Dev.Generator.REMEDYST.cpp 71 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542
  1. // CCOS.Dev.GEN.REMEDYST.cpp : 定义 DLL 应用程序的导出函数。
  2. //
  3. #include <assert.h>
  4. #include <functional>
  5. #include <unordered_map>
  6. #include <fstream>
  7. #include <set>
  8. #include "LogicDevice.h"
  9. #include "CCOS.Dev.Generator.REMEDYST.h"
  10. #include "Helper.JSON.hpp"
  11. #include "LogLocalHelper.h"
  12. #include "Log4CPP.h"
  13. using namespace std::placeholders;
  14. using namespace CCOS::Dev::Detail::Generator;
  15. namespace nsGEN = CCOS::Dev::Detail::Generator;
  16. #pragma warning (disable:4244)
  17. #pragma warning (disable:4305)
  18. #pragma warning (disable:4267)
  19. static const int msTimeOut_Lock = 500;
  20. #ifdef _WIN64
  21. #ifdef _DEBUG
  22. static const auto COM_SCFDllName = "Ccos.Dev.SerialSCFX64D.dll";
  23. #else
  24. static const auto COM_SCFDllName = "Ccos.Dev.SerialSCFX64.dll";
  25. #endif
  26. #endif
  27. #ifdef _WIN64
  28. #ifdef _DEBUG
  29. static const auto TCP_SCFDllName = "Ccos.Dev.TcpipSCFX64D.dll";
  30. #else
  31. static const auto TCP_SCFDllName = "Ccos.Dev.TcpipSCFX64.dll";
  32. #endif
  33. #endif
  34. //-----------------------------------------------------------------------------
  35. // REMEDYSTDevice
  36. //-----------------------------------------------------------------------------
  37. 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 };
  38. 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 };
  39. 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 };
  40. std::unordered_map<int, std::string> errorMessages = {
  41. {3, "Generator CPU EEPROM Data Checksum Error"},
  42. {4, "Generator CPU Real Time Clock error"},
  43. {5, "Main Contactor error"},
  44. {6, "Rotor Fault"},
  45. {7, "Filament Fault"},
  46. {9, "Beam_Cathode Fault"},
  47. {10, "Beam_Anode Fault"},
  48. {11, "Beam_INVA Fault"},
  49. {12, "Beam_INVB Fault"},
  50. {13, "Beam_KV Fault"},
  51. {14, "Beam_IR Fault"},
  52. {15, "Beam KV too low."},
  53. {16, "Beam kv unbalance"},
  54. {17, "Inverter is too hot"},
  55. {18, "Preparation Time-out Error"},
  56. {19, "Handle release time timed out"},
  57. {20, "No KV during exposure"},
  58. {21, "mA during exposure too high"},
  59. {22, "mA during exposure too low"},
  60. {23, "Manually Terminated Exposure"},
  61. {24, "AEC Back-up Timer - Exposure Terminated"},
  62. {25, "AEC MAS Exceeded - Exposure Terminated"},
  63. {27, "Anode Heat Limit"},
  64. {28, "Thermal Switch Interlock Error"},
  65. {29, "Door Interlock Error"},
  66. {31, "Bucky 1 Not Contact Error"},
  67. {33, "Bucky 2 Not Contact Error"},
  68. {34, "Prep Input active during Initialization Phase"},
  69. {35, "X-ray Input active during Initialization Phase"},
  70. {36, "Communication Error Console"},
  71. {37, "+12VDC Error"},
  72. {38, "-12VDC Error"},
  73. {43, "High Voltage Error - KV detected in non x-ray state"},
  74. {44, "Invalid Communication Message"},
  75. {45, "Communication Message Not Supported"},
  76. {46, "Communication Message Not Allowed"},
  77. {48, "Current reception is not enabled"},
  78. {49, "AEC channel is not enable in current reception"},
  79. {51, "AEC Feedback Error (No Feedback Signal Detected)"},
  80. {52, "High Small Focus Filament Current Error in Standby"},
  81. {53, "High Large Focus Filament Current Error in Standby"},
  82. {54, "AEC Reference out of range"},
  83. {55, "No Fields Selected in AEC mode"},
  84. {56, "No Tube Programmed"},
  85. {57, "AEC Stop signal in wrong state"},
  86. {60, "High KV Error"},
  87. {61, "Low KV Error"},
  88. {71, "Boost filament current error"},
  89. {72, "Preheat filament current error"},
  90. {73, "Film screen is invalid"},
  91. {74, "DC BUS voltage is too higher or too low"},
  92. {75, "Tube count data corrupt"},
  93. {82, "INV1 Error"},
  94. {83, "INV2 Error"},
  95. {84, "INV3 Error"},
  96. {100, "Calibration Error - Maximum mA Exceeded"},
  97. {101, "Calibration Error - Calibration Data Table Exceeded"},
  98. {102, "Calibration Error - Maximum Filament Current Exceeded"},
  99. {103, "Calibration Error - Manually Terminated"},
  100. {104, "Calibration Error - No mA"},
  101. {105, "Calibration Error - Minimum mA not calibrated"},
  102. {106, "Generator Limit, Selected Parameter Not calibrated"},
  103. {107, "pre-charge relay fault"},
  104. {108, "large filament set parameter is more than max. filament current"},
  105. {109, "small filament set parameter is more than max. filament current."},
  106. {200, "Anode Warning Level Exceeded"},
  107. {202, "Generator KW Limit"},
  108. {203, "Generator KV Limit"},
  109. {204, "Generator MA Limit"},
  110. {205, "Generator MS Limit"},
  111. {206, "Generator MAS Limit"},
  112. {207, "Tube KW Limit"},
  113. {208, "Tube KV Limit"},
  114. {209, "Tube MA Limit"},
  115. {210, "Tube MAS Limit"},
  116. {212, "Generator AEC Density Limit"},
  117. {213, "Invalid Communication Parameter"},
  118. {214, "Housing Heat Warning2 "}
  119. };
  120. static const std::set<int> specialErrorValues = { 3, 4, 5, 6, 7, 9, 10, 11, 12, 13, 14, 15, 20, 28, 29, 34, 35, 37, 38 };
  121. int g_AECFIELD_List[] = { 1, 10, 100, 11, 101, 111 };
  122. std::vector <float> gf_MA_List = { 8, 10, 12.5, 16, 20, 25, 32, 40, 50, 64, 80, 100, 125, 160, 200, 250, 320, 400, 500, 640 };
  123. atomic<int> nsGEN::REMEDYSTDevice::m_iLoopTime = REMEDYST_LoopDefTime;
  124. string GetProcessDirectory()
  125. {
  126. string ret = "";
  127. char szFilename[MAX_PATH] = { 0 };
  128. DWORD res = GetModuleFileNameA(0, szFilename, MAX_PATH);
  129. if (res == 0)
  130. {
  131. return ret;
  132. }
  133. string fullpath = szFilename;
  134. string::size_type firstHit = fullpath.find_last_of('\\');
  135. if (firstHit == string::npos || firstHit == 0)
  136. {
  137. return ret;
  138. }
  139. ret = fullpath.substr(0, firstHit);//kick last \
  140. return ret;
  141. }
  142. nsGEN::REMEDYSTDevice::REMEDYSTDevice(std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF, string configfile) : super(center, SCF)
  143. {
  144. assert(EventCenter);
  145. FINFO("version:3.0.1.0");
  146. m_DoseUnit.m_KV.reset(new KVMould(0.0, 40.0, 120.0, 1.0));
  147. m_DoseUnit.m_MA.reset(new MAMould(0.0, 10.0, 1000.0, 0.1));
  148. m_DoseUnit.m_MS.reset(new MSMould(0.0, 1.0, 6300.0, 0.01));
  149. m_DoseUnit.m_MAS.reset(new MASMould(0.0, 0.1, 1000.0, 0.01));
  150. m_DoseUnit.m_Techmode.reset(new TECHMODEMould(0, 0, 2, 1));
  151. m_DoseUnit.m_WS.reset(new WORKSTATIONMould(1, 0, 5, 1));
  152. m_DoseUnit.m_Focus.reset(new FOCUSMould(1, 0, 1, 1));
  153. m_DoseUnit.m_AECField.reset(new AECFIELDMould(0, 0, 111, 1));
  154. m_DoseUnit.m_AECFilm.reset(new AECFILMMould(0, 0, 2, 1));
  155. m_DoseUnit.m_AECDensity.reset(new AECDENSITYMould(0, -4, 4, 1));
  156. m_DoseUnit.m_HE.reset(new TUBEHEATMould(0, 0, 100, 1));
  157. m_DoseUnit.m_PostKV.reset(new POSTKVMould(0.0, 40.0, 120.0, 1.0));
  158. m_DoseUnit.m_PostMA.reset(new POSTMAMould(0.0, 10.0, 1000.0, 0.1));
  159. m_DoseUnit.m_PostMS.reset(new POSTMSMould(0.0, 1.0, 10000.0, 0.01));
  160. m_DoseUnit.m_PostMAS.reset(new POSTMASMould(0.0, 0.5, 1000.0, 0.01));
  161. m_DoseUnit.m_GenSynState.reset(new GENSYNSTATEMould(0, AttrKey::GENERATOR_SYNC_ERR, AttrKey::GENERATOR_SYNC_MAX, 1));
  162. m_DoseUnit.m_GenState.reset(new GENSTATEMould(4, AttrKey::GENERATOR_STATUS_SHUTDOWN, AttrKey::GENERATOR_STATUS_MAX, 1));
  163. m_DoseUnit.m_GenTotalExpNumber.reset(new TOTALEXPNUMMould(0, 0, 9999, 1));
  164. m_DoseUnit.m_GenTotalAcqTimes.reset(new TOTALACQTIMESMould(0, 0, 9999, 1));
  165. m_DoseUnit.m_GenTubeCoolWaitTimes.reset(new TUBECOOLTIMEMould(0, 0, 9999, 1));
  166. m_DoseUnit.m_GenTubeOverLoadNumber.reset(new TUBEOVERLOADNUMMould(0, 0, 9999, 1));
  167. m_DoseUnit.m_GenCurrentExpNumber.reset(new CUREXPNUMMould(0, 0, 9999, 1));
  168. m_DoseUnit.m_ExpMode.reset(new EXPMODEMould(AttrKey::EXPMODE_TYPE::Single));
  169. m_DoseUnit.m_FrameRate.reset(new FRAMERATEMould(0, 0, 16, 1));
  170. m_MSGUnit.reset(new nsDetail::MSGUnit(center, nsGEN::GeneratorUnitType));
  171. m_DAP.reset(new DevDAP::DOSEMould(0.0, 0.0, 1000.0, 0.01));
  172. m_DoseUnit.m_FLMode.reset(new FLUModeMould(AttrKey::GENERATOR_FLUMode::GENERATOR_FLMODE_NOTFLU));
  173. m_DoseUnit.m_FLIntTime.reset(new FLUIntTimeMould(0.0, 0.0, 100.0, 0.1));
  174. m_DoseUnit.m_FLAccTime.reset(new FLAccTimeMould(0.0, 0.0, 999.0, 0.1));
  175. m_DoseUnit.m_FLKV.reset(new FLUKVMould(0, 40, 125, 1));
  176. m_DoseUnit.m_FLMS.reset(new FLUMSMould(10.0, 10.0, 999999.0, 0.01));
  177. m_DoseUnit.m_FLMA.reset(new FLUMAMould(0.5, 0.5, 99.0, 0.1));
  178. m_DoseUnit.m_ABSStatus.reset(new FLUABSStatusMould(0, 0, 2, 1));
  179. m_DoseUnit.m_PPS.reset(new PPSMould(0.5, 0.5, 30, 0.1));
  180. m_DoseUnit.m_DoseLevel.reset(new FLUDoseLevelMould(0, 0, 2, 1));
  181. m_DoseUnit.m_Curve.reset(new FLUCurveMould(0, 0, 3, 1));
  182. m_hGenPostEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
  183. m_pHardwareStatusThread = NULL;
  184. m_bIsConfigLoaded = false;
  185. m_strConfigPath = configfile;
  186. m_bMasR20 = 0;
  187. m_bUseEAcmd = 0;
  188. m_bResetActive = false;
  189. LoadConfig(configfile);
  190. OnCallBack();
  191. Register();
  192. HWSend("RE");
  193. HWSend("RS");
  194. StartHardwareStatusThread();
  195. }
  196. nsGEN::REMEDYSTDevice::~REMEDYSTDevice()
  197. {
  198. CloseHandle(m_hGenPostEvent);
  199. }
  200. std::string nsGEN::REMEDYSTDevice::GetGUID() const
  201. {
  202. FINFO("\n===============GetGUID : {$} ===================\n", GeneratorUnitType);
  203. return GeneratorUnitType;
  204. }
  205. void nsGEN::REMEDYSTDevice::Register()
  206. {
  207. auto Disp = &Dispatch;
  208. superGen::Register(Disp);
  209. superGen::RegisterRAD(Disp);
  210. superGen::RegisterAEC(Disp);
  211. superGen::RegisterExpEnable(Disp);
  212. superGen::RegisterGeneratortoSyncStatus(Disp);
  213. superGen::RegisterFluoro(Disp);
  214. Disp->Get.Push(m_MSGUnit->GetKey().c_str(), [this](std::string& out) { out = m_MSGUnit->JSGet(); return RET_STATUS::RET_SUCCEED; });
  215. auto fun_Clear_DAP = [this](auto a, auto&)
  216. {
  217. return Clear_DAP();
  218. };
  219. Disp->Action.Push("Clear_DAP", fun_Clear_DAP);
  220. auto fun_GetValue_DAP = [this](auto a, auto& b)
  221. {
  222. float value = 0;
  223. RET_STATUS ret = GetValue_DAP(value);
  224. b = ToJSON(value);
  225. return ret;
  226. };
  227. Disp->Action.Push("GetValue_DAP", fun_GetValue_DAP);
  228. auto fun_StartMove = [this](auto a,auto& b)
  229. {
  230. return StartMove();
  231. };
  232. Disp->Action.Push("StartMove", fun_StartMove);
  233. auto fun_EndMove = [this](auto a, auto& b)
  234. {
  235. return EndMove();
  236. };
  237. Disp->Action.Push("EndMove", fun_EndMove);
  238. }
  239. RET_STATUS nsGEN::REMEDYSTDevice::IncKV()
  240. {
  241. FINFO("KV value before calling IncKV: {$}\n", m_DoseUnit.m_KV->JSGet().c_str());
  242. if (!m_DoseUnit.m_KV->CanInc()) return RET_STATUS::RET_SUCCEED;
  243. return HWSend("KV+");
  244. }
  245. RET_STATUS nsGEN::REMEDYSTDevice::DecKV()
  246. {
  247. FINFO("KV value before calling DecKV: {$}\n", m_DoseUnit.m_KV->JSGet().c_str());
  248. if (!m_DoseUnit.m_KV->CanDec()) return RET_STATUS::RET_SUCCEED;
  249. return HWSend("KV-");
  250. }
  251. RET_STATUS nsGEN::REMEDYSTDevice::SetKV(float value)
  252. {
  253. FINFO("KV value before calling SetKV: {$}\n", m_DoseUnit.m_KV->JSGet().c_str());
  254. if (!m_DoseUnit.m_KV->Verify(value)) return RET_STATUS::RET_SUCCEED;
  255. char temp[50] = { 0 };
  256. sprintf_s(temp, "KV%03d", (int)value);
  257. return HWSend(temp);
  258. }
  259. RET_STATUS nsGEN::REMEDYSTDevice::IncMA()
  260. {
  261. FINFO("MA value before calling IncMA: {$}\n", m_DoseUnit.m_MA->JSGet().c_str());
  262. if (!m_DoseUnit.m_MA->CanInc()) return RET_STATUS::RET_SUCCEED;
  263. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
  264. {
  265. FINFO("\n Techmode is MAS, can't inc MA");
  266. return RET_STATUS::RET_FAILED;
  267. }
  268. return HWSend("MA+");
  269. }
  270. RET_STATUS nsGEN::REMEDYSTDevice::DecMA()
  271. {
  272. FINFO("MA value before calling DecMA: {$}\n", m_DoseUnit.m_MA->JSGet().c_str());
  273. if (!m_DoseUnit.m_MA->CanDec()) return RET_STATUS::RET_SUCCEED;
  274. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
  275. {
  276. FINFO("\n Techmode is MAS, can't dec MA");
  277. return RET_STATUS::RET_FAILED;
  278. }
  279. return HWSend("MA-");
  280. }
  281. RET_STATUS nsGEN::REMEDYSTDevice::SetMA(float value)
  282. {
  283. FINFO("MA value before calling SetMA: {$}\n", m_DoseUnit.m_MA->JSGet().c_str());
  284. if (!m_DoseUnit.m_MA->Verify(value)) return RET_STATUS::RET_SUCCEED;
  285. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
  286. {
  287. FINFO("\n Techmode is MAS, can't set MA");
  288. return RET_STATUS::RET_FAILED;
  289. }
  290. char temp[50] = { 0 };
  291. sprintf_s(temp, "MA%05d", (int)(value * 10));
  292. return HWSend(temp);
  293. }
  294. RET_STATUS nsGEN::REMEDYSTDevice::IncMS()
  295. {
  296. FINFO("MS value before calling IncMS: {$}\n", m_DoseUnit.m_MS->JSGet().c_str());
  297. if (!m_DoseUnit.m_MS->CanInc())
  298. {
  299. int Level = 1;
  300. m_MSGUnit->AddWarnMessage("REMEDYST_WARN", Level, "Generator MS Limit");
  301. return RET_STATUS::RET_SUCCEED;
  302. }
  303. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
  304. {
  305. FINFO("\n Techmode is MAS, can't inc MS");
  306. return RET_STATUS::RET_FAILED;
  307. }
  308. return HWSend("MS+");
  309. }
  310. RET_STATUS nsGEN::REMEDYSTDevice::DecMS()
  311. {
  312. FINFO("MS value before calling DecMS: {$}\n", m_DoseUnit.m_MS->JSGet().c_str());
  313. if (!m_DoseUnit.m_MS->CanDec()) return RET_STATUS::RET_SUCCEED;
  314. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
  315. {
  316. FINFO("\n Techmode is MAS, can't dec MS");
  317. return RET_STATUS::RET_FAILED;
  318. }
  319. return HWSend("MS-");
  320. }
  321. RET_STATUS nsGEN::REMEDYSTDevice::SetMS(float value)
  322. {
  323. FINFO("MS value before calling SetMS: {$}\n", m_DoseUnit.m_MS->JSGet().c_str());
  324. if (!m_DoseUnit.m_MA->Verify(value)) return RET_STATUS::RET_SUCCEED;
  325. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_MAS)
  326. {
  327. FINFO("\n Techmode is MAS, can't set MS");
  328. return RET_STATUS::RET_FAILED;
  329. }
  330. char temp[50] { 0 };
  331. sprintf_s(temp, "MS%05d", (int)(value * 10));
  332. return HWSend(temp);
  333. }
  334. RET_STATUS nsGEN::REMEDYSTDevice::IncMAS()
  335. {
  336. FINFO("MAS value before calling IncMAS: {$}\n", m_DoseUnit.m_MAS->JSGet().c_str());
  337. if (!m_DoseUnit.m_MAS->CanInc()) return RET_STATUS::RET_SUCCEED;
  338. if (!m_DoseUnit.m_MS->CanInc())
  339. {
  340. int Level = 1;
  341. m_MSGUnit->AddWarnMessage("REMEDYST_WARN", Level, "Generator MS Limit");
  342. return RET_STATUS::RET_SUCCEED;
  343. }
  344. if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_MAS)
  345. {
  346. FINFO("\n Techmode is not MAS, can't inc MAS");
  347. return RET_STATUS::RET_FAILED;
  348. }
  349. return HWSend("MX+");
  350. }
  351. RET_STATUS nsGEN::REMEDYSTDevice::DecMAS()
  352. {
  353. FINFO("MAS value before calling DecMAS: {$}\n", m_DoseUnit.m_MAS->JSGet().c_str());
  354. if (!m_DoseUnit.m_MAS->CanDec()) return RET_STATUS::RET_SUCCEED;
  355. if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_MAS)
  356. {
  357. FINFO("\n Techmode is not MAS, can't dec MAS");
  358. return RET_STATUS::RET_FAILED;
  359. }
  360. return HWSend("MX-");
  361. }
  362. RET_STATUS nsGEN::REMEDYSTDevice::SetMAS(float value)
  363. {
  364. FINFO("MAS value before calling SetMAS: {$}\n", m_DoseUnit.m_MAS->JSGet().c_str());
  365. if (!m_DoseUnit.m_MAS->Verify(value)) return RET_STATUS::RET_SUCCEED;
  366. if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_MAS)
  367. {
  368. FINFO("\n Techmode is not MAS, can't set MAS");
  369. return RET_STATUS::RET_FAILED;
  370. }
  371. char temp[50] = { 0 };
  372. if (m_bMasR20)
  373. {
  374. sprintf_s(temp, "MX%06d", (int)(value * 100));
  375. }
  376. else
  377. {
  378. sprintf_s(temp, "MX%05d", (int)(value * 10));
  379. }
  380. return HWSend(temp);
  381. }
  382. RET_STATUS nsGEN::REMEDYSTDevice::SetTechmode(int value)
  383. {
  384. FINFO("Techmode value before calling SetTechmode: {$}\n", m_DoseUnit.m_Techmode->JSGet().c_str());
  385. if (!m_DoseUnit.m_Techmode->Verify(value)) return RET_STATUS::RET_SUCCEED;
  386. char temp[50] = { 0 };
  387. sprintf_s(temp, "ET%01d", (int)value);
  388. return HWSend(temp);
  389. }
  390. RET_STATUS nsGEN::REMEDYSTDevice::SetFocus(int value)
  391. {
  392. FINFO("Focus value before calling SetFocus: {$}\n", m_DoseUnit.m_Focus->JSGet().c_str());
  393. if (!m_DoseUnit.m_Focus->Verify(value)) return RET_STATUS::RET_SUCCEED;
  394. char temp[50] = { 0 };
  395. sprintf_s(temp, "FO%01d", (int)value);
  396. return HWSend(temp);
  397. }
  398. RET_STATUS nsGEN::REMEDYSTDevice::SetAECDensity(int value)
  399. {
  400. if (!m_DoseUnit.m_AECDensity->Verify(value)) return RET_STATUS::RET_SUCCEED;
  401. if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_AEC)
  402. return RET_STATUS::RET_FAILED;
  403. char temp[50] = { 0 };
  404. if (value >= 0)
  405. {
  406. sprintf_s(temp, "FN+%01d", (int)value);
  407. }
  408. else
  409. {
  410. sprintf_s(temp, "FN-%01d", (int)value);
  411. }
  412. return HWSend(temp);
  413. }
  414. RET_STATUS nsGEN::REMEDYSTDevice::SetAECField(int value)
  415. {
  416. if (!m_DoseUnit.m_AECField->Verify(value)) return RET_STATUS::RET_SUCCEED;
  417. if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_AEC)
  418. return RET_STATUS::RET_FAILED;
  419. char temp[50] = { 0 };
  420. sprintf_s(temp, "FI%03d", (int)value);
  421. return HWSend(temp);
  422. }
  423. RET_STATUS nsGEN::REMEDYSTDevice::SetAECFilm(int value)
  424. {
  425. if (!m_DoseUnit.m_AECFilm->Verify(value)) return RET_STATUS::RET_SUCCEED;
  426. if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_AEC)
  427. return RET_STATUS::RET_FAILED;
  428. char temp[50] = { 0 };
  429. sprintf_s(temp, "FS%03d", (int)value);
  430. return HWSend(temp);
  431. }
  432. RET_STATUS nsGEN::REMEDYSTDevice::SetWS(const string value)
  433. {
  434. int tempws = 0;
  435. if (value == "Table") tempws = (int)m_GenConfig["WSTable"];
  436. else if (value == "Wall") tempws = (int)m_GenConfig["WSWall"];
  437. else if (value == "Direct") tempws = (int)m_GenConfig["WSConventional"];
  438. else if (value == "Free") tempws = (int)m_GenConfig["WSFree"];
  439. else if (value == "Tomo") tempws = (int)m_GenConfig["WSTomo"];
  440. char temp[50] = { 0 };
  441. sprintf_s(temp, "WS%01d", tempws);
  442. return HWSend(temp);
  443. }
  444. string nsGEN::REMEDYSTDevice::WSUI2Gen(int nUIWS)
  445. {
  446. string strWS = "";
  447. try
  448. {
  449. if (nUIWS == AttrKey::GENWS_TYPE::TABLE) //lying: cross mode
  450. {
  451. strWS = m_GenConfig["WSTable"].encode();
  452. }
  453. else if (nUIWS == AttrKey::GENWS_TYPE::WALL) //standing mode
  454. {
  455. strWS = m_GenConfig["WSWall"].encode();
  456. }
  457. else if (nUIWS == AttrKey::GENWS_TYPE::FREE_TABLE) //standing mode
  458. {
  459. strWS = m_GenConfig["WSFree"].encode();
  460. }
  461. else if (nUIWS == AttrKey::GENWS_TYPE::TOMO) //standing mode
  462. {
  463. strWS = m_GenConfig["WSTOMO"].encode();
  464. }
  465. else if (nUIWS == AttrKey::GENWS_TYPE::CONVENTIONAL) //standing mode
  466. {
  467. strWS = m_GenConfig["WSConventional"].encode();
  468. }
  469. }
  470. catch (ResDataObjectExption& exp)
  471. {
  472. FERROR("Get configuration failed, {$}\n", exp.what());
  473. }
  474. FINFO("Set WS: {$},Generator workstaion: {$}\n", nUIWS, strWS);
  475. if (strWS == "")
  476. {
  477. strWS = "Table";
  478. }
  479. return strWS;
  480. }
  481. RET_STATUS nsGEN::REMEDYSTDevice::SetAPR(const _tAPRArgs& t)
  482. {
  483. m_t = t;
  484. FINFO("*********************Enter SetAPR*********************");
  485. FINFO("t.ws={$},t.fKV={$},t.fMA={$},t.fMAS={$},t.nAECDensity={$},t.nAECField={$},t.nAECFilm={$},t.nFocus={$},t.nTechmode={$}", t.nWS,t.fKV, t.fMA, t.fMAS, t.nAECDensity, t.nAECField, t.nAECFilm, t.nFocus, t.nTechmode);
  486. //2
  487. SetKV(t.fKV);
  488. //3
  489. SetFocus(t.nFocus);
  490. //4
  491. if (t.nTechmode == AttrKey::TECHMODE_V2TYPE::ET_AEC)//aec
  492. {
  493. SetTechmode(t.nTechmode);
  494. SetAECField(t.nAECField);
  495. SetAECDensity(t.nAECDensity);
  496. SetMA(t.fMA);
  497. SetMS(t.fMS);
  498. }
  499. else if (t.nTechmode == AttrKey::TECHMODE_V2TYPE::ET_MAS)//2p
  500. {
  501. SetTechmode(t.nTechmode);
  502. const float EPSINON = 0.000001;
  503. SetMAS(t.fMAS);
  504. }
  505. else if (t.nTechmode == AttrKey::TECHMODE_V2TYPE::ET_TIME)//3p
  506. {
  507. SetTechmode(t.nTechmode);
  508. SetMA(t.fMA);
  509. SetMS(t.fMS);
  510. }
  511. HWSend("RR");
  512. FINFO("*********************Leave SetAPR*********************");
  513. return RET_STATUS::RET_SUCCEED;
  514. }
  515. RET_STATUS nsGEN::REMEDYSTDevice::QueryHE(int& value)
  516. {
  517. return HWSend("HE?");
  518. }
  519. RET_STATUS nsGEN::REMEDYSTDevice::QueryPostKV(float& value)
  520. {
  521. m_DoseUnit.m_PostKV->Update(m_DoseUnit.m_KV->Get());
  522. value = m_DoseUnit.m_PostKV->Get();
  523. return HWSend("AP?");
  524. return RET_STATUS::RET_SUCCEED;
  525. }
  526. RET_STATUS nsGEN::REMEDYSTDevice::QueryPostMA(float& value)
  527. {
  528. return HWSend("AP?");
  529. }
  530. RET_STATUS nsGEN::REMEDYSTDevice::QueryPostMS(float& value)
  531. {
  532. return HWSend("AT?");
  533. }
  534. RET_STATUS nsGEN::REMEDYSTDevice::QueryPostMAS(float& value)
  535. {
  536. value = m_DoseUnit.m_PostMAS->Get();
  537. return RET_STATUS::RET_SUCCEED;
  538. }
  539. RET_STATUS nsGEN::REMEDYSTDevice::Clear_DAP()
  540. {
  541. if (m_bDAPEnable)
  542. {
  543. return HWSend("DZ");
  544. }
  545. return RET_STATUS::RET_SUCCEED;
  546. }
  547. RET_STATUS nsGEN::REMEDYSTDevice::GetValue_DAP(float& value)
  548. {
  549. if (m_bDAPEnable)
  550. {
  551. HWSend("DA");
  552. Sleep(300); //wait 300ms to get real dap value.
  553. value = m_DAP->Get();
  554. }
  555. return RET_STATUS::RET_SUCCEED;
  556. }
  557. RET_STATUS nsGEN::REMEDYSTDevice::StartMove()
  558. {
  559. FINFO("Enter startMove");
  560. FINFO("end startmove");
  561. return RET_STATUS::RET_SUCCEED;
  562. }
  563. RET_STATUS nsGEN::REMEDYSTDevice::EndMove()
  564. {
  565. FINFO("Enter endmove");
  566. FINFO("end EndMove");
  567. return RET_STATUS::RET_SUCCEED;
  568. }
  569. RET_STATUS nsGEN::REMEDYSTDevice::SetGenSynState(int value)
  570. {
  571. FINFO("Enter SetGenSynState...{$} \n", value);
  572. //if (AttrKey::GENERATOR_RAD_XRAYON == value) //软同步,收到XR1时,子系统会变为XRAYON状态,并调用此处,然后我立刻回复XR1至发生器,然后才真正出线。
  573. //{
  574. // FINFO("SetGenSynState be call.this is soft syn mode.");
  575. // HWSend("XR1");
  576. // m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYON);
  577. // FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  578. //}
  579. return RET_STATUS::RET_SUCCEED;
  580. }
  581. RET_STATUS nsGEN::REMEDYSTDevice::SetGenState(int value)
  582. {
  583. return RET_STATUS::RET_SUCCEED;
  584. }
  585. RET_STATUS nsGEN::REMEDYSTDevice::SetExpMode(std::string value)
  586. {
  587. //note: when time the func be called?
  588. FINFO("Enter SetExpMode...{$}",value);
  589. m_DoseUnit.m_ExpMode->Update(value);
  590. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  591. //
  592. ////退出CBCT,设置exp mode时,强制退出cbct,因为放在endmove中,偶发执行不到的问题。
  593. //SetFLFMode("0");
  594. //HWSend("TIC0");
  595. //
  596. //if (m_DoseUnit.m_ExpMode->JSGet() == EXPMODE_TYPE::Single)
  597. //{
  598. // FINFO("Enter SetAPR Single kv={$} ma={$}",m_t.fKV,m_t.fMA);
  599. // SetWS(m_DoseUnit.m_WS->JSGet());
  600. //
  601. // if (abs(m_t.fKV) == 0) //如果上层传入参数为零,那么查询
  602. // {
  603. // HWSend("RKV?");
  604. // }
  605. // else
  606. // {
  607. // SetKV(m_t.fKV);
  608. // }
  609. // SetFocus(m_t.nFocus);
  610. // SetTechmode(m_t.nTechmode);
  611. // if (m_t.nTechmode == AttrKey::TECHMODE_V2TYPE::ET_MAS)//mas
  612. // {
  613. // SetMAS(m_t.fMAS);
  614. // }
  615. // else if (m_t.nTechmode == AttrKey::TECHMODE_V2TYPE::ET_AEC)//aec
  616. // {
  617. // SetAECField(m_t.nAECField);
  618. // SetAECFilm(m_t.nAECFilm);
  619. // SetAECDensity(m_t.nAECDensity);
  620. // SetMA(m_t.fMA);
  621. // SetMS(m_t.fMS);
  622. // }
  623. // else//time
  624. // {
  625. // if (abs(m_t.fMA) == 0)
  626. // {
  627. // HWSend("RMA?");
  628. // }
  629. // else
  630. // {
  631. // SetMA(m_t.fMA);
  632. // }
  633. // SetMS(m_t.fMS);
  634. // }
  635. //}
  636. //else if (m_DoseUnit.m_ExpMode->JSGet() == EXPMODE_TYPE::TOMO)
  637. //{
  638. // char temp[50] = { 0 };
  639. // sprintf_s(temp, "FLK%03d", (int)(m_DoseUnit.m_KV->Get()));
  640. // HWSend(temp);
  641. // sprintf_s(temp, "FLM%03d", (int)(10*(m_DoseUnit.m_MA->Get())));
  642. // HWSend(temp);
  643. // sprintf_s(temp, "FLS%03d", (int)(10*(m_DoseUnit.m_FrameRate->Get())));
  644. // FINFO("Enter SetAPR TOMO kv={$} ma={$}", m_DoseUnit.m_KV->Get(), m_DoseUnit.m_MA->Get());
  645. // HWSend(temp);
  646. //}
  647. //
  648. ////无论哪种模式,均设置FLF2= PF. 仅测试用,后续正式版本,得删除.
  649. //char temp[50] = { 0 };
  650. //sprintf_s(temp, "FLF%01d", (int)(2));
  651. //HWSend(temp);
  652. ////理论上来说,设置exp模式的时候,若点片,RPS主动设置为0.
  653. //if (EXPMODE_TYPE::Single == value)
  654. //{
  655. // FINFO("now is Single mode, send RPS0");
  656. // SetRPS(0);
  657. //}
  658. return RET_STATUS::RET_SUCCEED;
  659. }
  660. RET_STATUS nsGEN::REMEDYSTDevice::SetFLFMode(std::string value)
  661. {
  662. FINFO("Enter SetFLFMode...,FLFMode:{$} \n", value.c_str());
  663. if (value == "CF")
  664. {
  665. m_DoseUnit.m_FLMode->Update(1);
  666. HWSend("FLF1", 4);
  667. SetPPS(15);
  668. SetPluseWidth(15);
  669. }
  670. else if (value == "PF")
  671. {
  672. if (m_DoseUnit.m_FLKV->Get() > m_fPFLimitMaxKV)
  673. {
  674. HWSend("FLK040", 6);
  675. }
  676. if (m_DoseUnit.m_FLMA->Get() > m_fPFLimitMaxMA)
  677. {
  678. HWSend("FLM100", 6);
  679. }
  680. m_DoseUnit.m_FLMode->Update(2);
  681. HWSend("FLF2", 4);
  682. SetPPS(5);
  683. SetPluseWidth(5);
  684. }
  685. else if (value == "HLF")
  686. {
  687. if (m_DoseUnit.m_FLKV->Get() < m_fHLFLimitMinKV)
  688. {
  689. HWSend("FLK080", 6);
  690. }
  691. if (m_DoseUnit.m_FLMA->Get() < m_fHLFLimitMinMA)
  692. {
  693. HWSend("FLM4000", 7);
  694. }
  695. m_DoseUnit.m_FLMode->Update(2);
  696. HWSend("FLF2", 4);
  697. SetPPS(5);
  698. SetPluseWidth(5);
  699. }
  700. else
  701. {
  702. FINFO("other FluMode : {$}", value.c_str());
  703. }
  704. return RET_STATUS::RET_SUCCEED;
  705. }
  706. RET_STATUS nsGEN::REMEDYSTDevice::SetAPF(const _tAPFArgs& t)
  707. {
  708. FINFO("APF:FLKV={$},FLMA={$},PPS={$},WS={$},FLuType={$},ABSMode={$},DoseLever={$}", t.nFLKV, t.fFLMA, t.nPPS, t.nWS, t.nFluMode, t.nABSMode, t.nDoseLever);
  709. SetFluKV(t.nFLKV);
  710. SetFluMA(t.fFLMA);
  711. HWSend("RF");
  712. return RET_STATUS::RET_SUCCEED;
  713. }
  714. RET_STATUS nsGEN::REMEDYSTDevice::IncFluKV()
  715. {
  716. FINFO("FluKV value before calling IncFluKV: {$}\n", m_DoseUnit.m_FLKV->JSGet().c_str());
  717. if (!m_DoseUnit.m_FLKV->CanInc()) return RET_STATUS::RET_SUCCEED;
  718. return HWSend("FLK+", 4);
  719. }
  720. RET_STATUS nsGEN::REMEDYSTDevice::DecFluKV()
  721. {
  722. FINFO("FluKV value before calling DecFluKV: {$}\n", m_DoseUnit.m_FLKV->JSGet().c_str());
  723. if (!m_DoseUnit.m_FLKV->CanDec()) return RET_STATUS::RET_SUCCEED;
  724. return HWSend("FLK-", 4);
  725. }
  726. RET_STATUS nsGEN::REMEDYSTDevice::SetFluKV(float value)
  727. {
  728. FINFO("FluKV value before calling SetFluKV: {$}\n", m_DoseUnit.m_FLKV->JSGet().c_str());
  729. if (!m_DoseUnit.m_FLKV->Verify(value)) return RET_STATUS::RET_SUCCEED;
  730. char temp[50] = { 0 };
  731. sprintf_s(temp, "FLK%03d", (int)value);
  732. return HWSend(temp, strlen(temp));
  733. }
  734. RET_STATUS nsGEN::REMEDYSTDevice::IncFluMA()
  735. {
  736. FINFO("FluMA value before calling IncFluMA: {$}\n", m_DoseUnit.m_FLMA->JSGet().c_str());
  737. if (!m_DoseUnit.m_FLMA->CanInc()) return RET_STATUS::RET_SUCCEED;
  738. return HWSend("FLM+", 4);
  739. }
  740. RET_STATUS nsGEN::REMEDYSTDevice::DecFluMA()
  741. {
  742. FINFO("FluMA value before calling DecFluMA: {$}\n", m_DoseUnit.m_FLMA->JSGet().c_str());
  743. if (!m_DoseUnit.m_FLMA->CanDec()) return RET_STATUS::RET_SUCCEED;
  744. return HWSend("FLM-", 4);
  745. }
  746. RET_STATUS nsGEN::REMEDYSTDevice::SetFluMA(float value)
  747. {
  748. FINFO("FluMA value before calling SetFluMA: {$}\n", m_DoseUnit.m_FLMA->JSGet().c_str());
  749. if (!m_DoseUnit.m_FLMA->Verify(value)) return RET_STATUS::RET_SUCCEED;
  750. char temp[50] = { 0 };
  751. sprintf_s(temp, "FLM%03d", (int)(value * 10));
  752. return HWSend(temp, strlen(temp));
  753. }
  754. RET_STATUS nsGEN::REMEDYSTDevice::INCPPS()
  755. {
  756. if (!m_DoseUnit.m_PPS->CanInc()) return RET_STATUS::RET_SUCCEED;
  757. return HWSend("FLS+", 4);
  758. }
  759. RET_STATUS nsGEN::REMEDYSTDevice::DECPPS()
  760. {
  761. if (!m_DoseUnit.m_PPS->CanDec()) return RET_STATUS::RET_SUCCEED;
  762. return HWSend("FLS-", 4);
  763. }
  764. RET_STATUS nsGEN::REMEDYSTDevice::SetPPS(float value)
  765. {
  766. if (!m_DoseUnit.m_PPS->Verify(value)) return RET_STATUS::RET_SUCCEED;
  767. char temp[50] = { 0 };
  768. sprintf_s(temp, "FLS%03d", (int)(value * 10));
  769. return HWSend(temp, strlen(temp));
  770. }
  771. RET_STATUS nsGEN::REMEDYSTDevice::SetABSMode(int nMode)
  772. {
  773. if (!m_DoseUnit.m_ABSStatus->Verify(nMode)) return RET_STATUS::RET_SUCCEED;
  774. char temp[50] = { 0 };
  775. FINFO("SetABSMode[{$}] \n", nMode);
  776. sprintf_s(temp, "FLA%1d", (int)nMode);
  777. return HWSend(temp, strlen(temp));
  778. }
  779. RET_STATUS nsGEN::REMEDYSTDevice::SetABSCurve(int curveNum)
  780. {
  781. return RET_STATUS::RET_SUCCEED;
  782. }
  783. RET_STATUS nsGEN::REMEDYSTDevice::IncABSCurve()
  784. {
  785. return RET_STATUS::RET_SUCCEED;
  786. }
  787. RET_STATUS nsGEN::REMEDYSTDevice::DecABSCurve()
  788. {
  789. return RET_STATUS::RET_SUCCEED;
  790. }
  791. RET_STATUS nsGEN::REMEDYSTDevice::GetABSCurve()
  792. {
  793. return HWSend("FLA?", 4);
  794. }
  795. float nsGEN::REMEDYSTDevice::GetFluIntTimer()
  796. {
  797. return HWSend("FLI?", 4);
  798. }
  799. float nsGEN::REMEDYSTDevice::GetFluAccTimer()
  800. {
  801. return HWSend("FLT?", 4);
  802. }
  803. RET_STATUS nsGEN::REMEDYSTDevice::ResetFluTimer(int ntype)
  804. {
  805. char temp[50] = { 0 };
  806. sprintf_s(temp, "FLR%1d", (int)ntype);
  807. FINFO("ReSetFluAccTimer:[{$}] \n", ntype);
  808. return HWSend(temp, strlen(temp));
  809. }
  810. RET_STATUS nsGEN::REMEDYSTDevice::SetFluPre(int value)
  811. {
  812. return RET_STATUS::RET_SUCCEED;
  813. }
  814. RET_STATUS nsGEN::REMEDYSTDevice::SetFluEXP(int value)
  815. {
  816. return RET_STATUS::RET_SUCCEED;
  817. }
  818. RET_STATUS nsGEN::REMEDYSTDevice::SetFluMode(std::string value)
  819. {
  820. FINFO("Enter SetFLFMode...{$} \n", value.c_str());
  821. if (value == "CF")
  822. {
  823. m_DoseUnit.m_FLMode->Update(1);
  824. return HWSend("FLF1", 4);
  825. }
  826. else if (value == "PF")
  827. {
  828. m_DoseUnit.m_FLMode->Update(2);
  829. return HWSend("FLF2", 4);
  830. }
  831. else
  832. {
  833. FINFO("other FluMode : {$}", value.c_str());
  834. return RET_STATUS::RET_SUCCEED;
  835. }
  836. }
  837. RET_STATUS nsGEN::REMEDYSTDevice::SetFluDoseLever(int value)
  838. {
  839. return RET_STATUS::RET_SUCCEED;
  840. }
  841. void CCOS::Dev::Detail::Generator::REMEDYSTDevice::UpdateLimits(const std::string& key, float& currentValue, float defaultValue)
  842. {
  843. if (m_GenConfig.GetKeyCount(key.c_str()) > 0)
  844. {
  845. currentValue = static_cast<float>(m_GenConfig[key.c_str()]);
  846. }
  847. else
  848. {
  849. currentValue = defaultValue;
  850. }
  851. }
  852. void CCOS::Dev::Detail::Generator::REMEDYSTDevice::UpdateLimitsInt(const std::string& key, int& currentValue, int defaultValue)
  853. {
  854. if (m_GenConfig.GetKeyCount(key.c_str()) > 0)
  855. {
  856. currentValue = static_cast<int>(m_GenConfig[key.c_str()]);
  857. }
  858. else
  859. {
  860. currentValue = defaultValue;
  861. }
  862. }
  863. int CCOS::Dev::Detail::Generator::REMEDYSTDevice::GetGenState()
  864. {
  865. if (m_DoseUnit.m_GenState != NULL)
  866. {
  867. return m_DoseUnit.m_GenState->Get();
  868. }
  869. else
  870. {
  871. return 0;
  872. }
  873. }
  874. int CCOS::Dev::Detail::Generator::REMEDYSTDevice::LoadConfig(string configfile)
  875. {
  876. FINFO("=====================LoadConfig=========================");
  877. // 检查文件是否存在
  878. std::ifstream file(configfile);
  879. if (!file) {
  880. // 文件不存在,直接返回空的Connection对象
  881. FINFO("Config file does not exist: {$}", configfile.c_str());
  882. return -1;
  883. }
  884. if (m_bIsConfigLoaded)
  885. {
  886. FINFO("Configuration already loaded.");
  887. return 0;
  888. }
  889. ResDataObject temp;
  890. temp.loadFile(m_strConfigPath.c_str());
  891. m_GenConfig = temp["CONFIGURATION"];
  892. TransJsonText(m_GenConfig);
  893. if (m_GenConfig.GetKeyCount("R20Enable") > 0)
  894. {
  895. m_bMasR20 = (bool)m_GenConfig["R20Enable"];
  896. }
  897. if (m_GenConfig.GetKeyCount("USEEACMD") > 0)
  898. {
  899. m_bUseEAcmd = (bool)m_GenConfig["USEEACMD"];
  900. }
  901. m_bIsConfigLoaded = true;
  902. return 0;
  903. }
  904. RET_STATUS nsGEN::REMEDYSTDevice::SetEXAMMode(std::string value)
  905. {
  906. //EXAMMODE_TYPE::MANUAL
  907. return RET_STATUS::RET_SUCCEED;
  908. }
  909. void nsGEN::REMEDYSTDevice::HandleError(const char* value, const char* prefix, const std::string& type)
  910. {
  911. assert(value);
  912. int nValue = atoi(value);
  913. if (nValue != 0)
  914. {
  915. char ErrorCode[20];
  916. sprintf_s(ErrorCode, sizeof(ErrorCode), "%s%d", prefix, nValue);
  917. FINFO("error code: {$} \n", ErrorCode);
  918. int level = 1;
  919. auto it = errorMessages.find(nValue);
  920. if (it != errorMessages.end())
  921. {
  922. char temp[50] = { 0 };
  923. sprintf_s(temp, "%s%03d", type.c_str(), nValue);
  924. HWSend(temp);
  925. if (std::find(m_localWarnlist.begin(), m_localWarnlist.end(), ErrorCode) == m_localWarnlist.end())
  926. {
  927. if (specialErrorValues.find(nValue) != specialErrorValues.end())
  928. {
  929. m_MSGUnit->AddErrorMessage(ErrorCode, level, it->second.c_str());
  930. }
  931. else
  932. {
  933. m_MSGUnit->AddWarnMessage(ErrorCode, level, it->second.c_str());
  934. }
  935. m_localWarnlist.push_back(ErrorCode);
  936. }
  937. else
  938. {
  939. FINFO("ErrorCode {$} is already in the local warning list.\n", ErrorCode);
  940. }
  941. }
  942. else
  943. {
  944. // 处理未知错误码
  945. FINFO("Unknown error code: {$} \n", nValue);
  946. if (std::find(m_localWarnlist.begin(), m_localWarnlist.end(), ErrorCode) == m_localWarnlist.end())
  947. {
  948. m_localWarnlist.push_back(ErrorCode);
  949. m_MSGUnit->AddWarnMessage(ErrorCode, level, "Unknown error");
  950. }
  951. }
  952. }
  953. else
  954. {
  955. int level = 1;
  956. char EmptyCode[10] = { "" };
  957. m_MSGUnit->DelWarnMessage(EmptyCode, level, "");
  958. m_MSGUnit->DelErrorMessage(EmptyCode, level, "");
  959. }
  960. }
  961. RET_STATUS nsGEN::REMEDYSTDevice::ActiveSyncMode(_tSyncModeArgs value)
  962. {
  963. FINFO("value.strSyncMode: {$}, value.strSyncValue: {$}, value.strWS: {$} \n", value.strSyncMode, value.strSyncValue, value.strWS);
  964. int nSyncModeValue = atoi(value.strSyncValue.c_str());
  965. char temp[50] = { 0 };
  966. sprintf_s(temp, "WS%01d", nSyncModeValue);
  967. return HWSend(temp);
  968. }
  969. RET_STATUS nsGEN::REMEDYSTDevice::SetFrameRate(FLOAT frameRate)
  970. {
  971. m_DoseUnit.m_FrameRate->Update(frameRate); //this variable should be set when in oncallback.
  972. char temp[50]{ 0 };
  973. sprintf_s(temp, "FLS%03d", int(frameRate*10));
  974. return HWSend(temp);
  975. }
  976. RET_STATUS nsGEN::REMEDYSTDevice::SetRPS(int rps)
  977. {
  978. return RET_STATUS::RET_SUCCEED;
  979. //char temp[50]{ 0 };
  980. //sprintf_s(temp, "RPS%03d", rps * 10);
  981. //return HWSend(temp);
  982. }
  983. RET_STATUS nsGEN::REMEDYSTDevice::RefreshData()
  984. {
  985. HWSend("RR");
  986. HWSend("RS");
  987. return RET_STATUS::RET_SUCCEED;
  988. }
  989. RET_STATUS nsGEN::REMEDYSTDevice::SetExpEnable()
  990. {
  991. FINFO("SetExpEnable in ...\n");
  992. if (m_bUseEAcmd)
  993. {
  994. HWSend("EA111");
  995. }
  996. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  997. return RET_STATUS::RET_SUCCEED;
  998. //return HWSend("EXB1");
  999. }
  1000. RET_STATUS nsGEN::REMEDYSTDevice::SetExpDisable()
  1001. {
  1002. FINFO("SetExpDisable in...\n");
  1003. if (m_bUseEAcmd)
  1004. {
  1005. HWSend("EA000");
  1006. }
  1007. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  1008. FINFO("SetExpDisable... {$}\n", m_DoseUnit.m_GenState->JSGet().c_str());
  1009. return RET_STATUS::RET_SUCCEED;
  1010. }
  1011. RET_STATUS nsGEN::REMEDYSTDevice::Reset()
  1012. {
  1013. m_bResetActive = true;
  1014. FINFO("RESET in...\n");
  1015. int level = 0;
  1016. if (!m_localWarnlist.empty())
  1017. {
  1018. m_localWarnlist.clear();
  1019. FINFO("Local warning list has been cleared.\n");
  1020. m_MSGUnit->DelErrorMessage("0", level, "clear all errors");
  1021. m_MSGUnit->DelWarnMessage("0", level, "clear all Warning");
  1022. return HWSend("RE");
  1023. }
  1024. else
  1025. {
  1026. return RET_STATUS::RET_SUCCEED;
  1027. }
  1028. }
  1029. RET_STATUS nsGEN::REMEDYSTDevice::HWSend(char* strCommand, int nTimeOut)
  1030. {
  1031. if (!m_SCF) return RET_STATUS::RET_FAILED;
  1032. char strSendCommand[100] = { 0 };
  1033. int len = strlen(strCommand);
  1034. int tmpSum = 0;
  1035. for (int i = 0; i < len; i++)
  1036. {
  1037. tmpSum += (int)strCommand[i];
  1038. }
  1039. char checkSum = char(tmpSum + 3); //3 is ETX
  1040. memcpy(strSendCommand, strCommand, len);
  1041. strSendCommand[len + 0] = 0x03;
  1042. strSendCommand[len + 1] = checkSum;
  1043. FINFO("==OUT==: {$} \n", strSendCommand);
  1044. int retLength;
  1045. m_SCF.Lock(msTimeOut_Lock)
  1046. .SendPacket(strSendCommand, strlen(strSendCommand), nTimeOut, retLength);
  1047. Sleep(nTimeOut);
  1048. return RET_STATUS::RET_SUCCEED;
  1049. }
  1050. //-----------------------------------------------------------------------------
  1051. // ProcessCmd
  1052. //-----------------------------------------------------------------------------
  1053. void nsGEN::REMEDYSTDevice::FireNotify(std::string key, std::string content)
  1054. {
  1055. EventCenter->OnNotify(1, key, content);
  1056. }
  1057. struct tFrameMapping
  1058. {
  1059. static const int MaxLen = 5; // 前缀不能超超过 5 个字符 !
  1060. using cbFun = std::function <void(const char*, int)>;
  1061. char strHead[MaxLen];
  1062. int NbOfCharOfHead;
  1063. cbFun fun;
  1064. tFrameMapping(char* str, int len, cbFun f)
  1065. {
  1066. assert(len < MaxLen); //len最大只能是4
  1067. //strHead[0] = 0x02; //STX ----------->note : no package header
  1068. for (int i = 0; i < len; i++) //给strHead赋值
  1069. strHead[i] = str[i];
  1070. NbOfCharOfHead = len;
  1071. fun = f;
  1072. }
  1073. };
  1074. static std::list <tFrameMapping> arFrame;
  1075. static bool DecodeFrame(const char* strFrame, int length);
  1076. void nsGEN::REMEDYSTDevice::OnCallBack()
  1077. {
  1078. auto HWNotProcess = [](const char* value, int length) -> void
  1079. {
  1080. printf("\n This commands didn't need to process!\n");
  1081. FINFO("\n This commands didn't need to process!\n");
  1082. };
  1083. //==IN==:KV070 MA00320 MS00063 MX00036 sometimes : this long str appear. so must deal with it
  1084. auto HWKV = [this](const char* value, int length) -> void
  1085. {
  1086. assert(value);
  1087. FINFO("hwkv={$},len={$}",value, length);
  1088. if (length > 20) //if length more than 20, it must be a long string like :070 MA00320 MS00063 MX00036
  1089. {
  1090. //loop the long string to find kv ma ms mas
  1091. int tmpkv;
  1092. float tmpma, tmpms, tmpmx;
  1093. char tmpbuf[6]{ 0,0,0,0,0,0 };
  1094. //kv
  1095. tmpbuf[0] = value[0];
  1096. tmpbuf[1] = value[1];
  1097. tmpbuf[2] = value[2];
  1098. tmpkv = atoi(tmpbuf);
  1099. if (m_DoseUnit.m_KV->Update(tmpkv))
  1100. FireNotify(AttrKey::KV, m_DoseUnit.m_KV->JSGet());
  1101. //ma
  1102. tmpbuf[0] = value[6];
  1103. tmpbuf[1] = value[7];
  1104. tmpbuf[2] = value[8];
  1105. tmpbuf[3] = value[9];
  1106. tmpbuf[4] = value[10];
  1107. tmpma = atof(tmpbuf)/10.0;
  1108. /*if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_TIME)
  1109. {
  1110. FireNotify(AttrKey::MA, to_string(0));
  1111. }
  1112. else
  1113. {*/
  1114. m_DoseUnit.m_MA->Update(tmpma);
  1115. FireNotify(AttrKey::MA, m_DoseUnit.m_MA->JSGet());
  1116. /*}*/
  1117. //ms
  1118. tmpbuf[0] = value[14];
  1119. tmpbuf[1] = value[15];
  1120. tmpbuf[2] = value[16];
  1121. tmpbuf[3] = value[17];
  1122. tmpbuf[4] = value[18];
  1123. tmpms = atof(tmpbuf) / 10.0;
  1124. /*if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_TIME)
  1125. {
  1126. FireNotify(AttrKey::MS, to_string(0));
  1127. }
  1128. else
  1129. {*/
  1130. m_DoseUnit.m_MS->Update(tmpms);
  1131. FireNotify(AttrKey::MS, m_DoseUnit.m_MS->JSGet());
  1132. /*}*/
  1133. //mx
  1134. tmpbuf[0] = value[22];
  1135. tmpbuf[1] = value[23];
  1136. tmpbuf[2] = value[24];
  1137. tmpbuf[3] = value[25];
  1138. tmpbuf[4] = value[26];
  1139. tmpbuf[5] = value[27];
  1140. if (m_bMasR20)
  1141. {
  1142. tmpmx = atof(tmpbuf) / 100.0;
  1143. }
  1144. else
  1145. {
  1146. tmpmx = atof(tmpbuf) / 10.0;
  1147. }
  1148. /*
  1149. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_TIME)
  1150. {
  1151. FireNotify(AttrKey::MAS, to_string(0));
  1152. }
  1153. else
  1154. {*/
  1155. m_DoseUnit.m_MAS->Update(tmpmx);
  1156. FireNotify(AttrKey::MAS, m_DoseUnit.m_MAS->JSGet());
  1157. /*}*/
  1158. FINFO("tmpkv={$} tmpma={$}, tmpms={$}, tmpmx={$};", tmpkv, tmpma, tmpms, tmpmx);
  1159. }
  1160. else
  1161. {
  1162. int tmpkv = atoi(value);
  1163. if (m_DoseUnit.m_KV->Update(tmpkv))
  1164. FireNotify(AttrKey::KV, m_DoseUnit.m_KV->JSGet());
  1165. }
  1166. };
  1167. //==IN==:TU0 WS1 FO0 ET0 FI010 FS001 FN 0 HE000
  1168. auto HWTU = [this](const char* value, int length) -> void
  1169. {
  1170. assert(value);
  1171. FINFO("recv TU={$},len={$}", value,length);
  1172. char tmpbuf[3] = { 0,0,0 };
  1173. int tmpWS, tmpFO, tmpET, tmpField, tmpFilm, tmpDensity, tmpHE;
  1174. //ws
  1175. tmpbuf[0] = value[4];
  1176. tmpWS = atoi(tmpbuf);
  1177. m_DoseUnit.m_WS->Update(tmpWS);
  1178. {
  1179. FireNotify(m_DoseUnit.m_WS->GetKey(), m_DoseUnit.m_WS->JSGet());
  1180. }
  1181. //FO
  1182. tmpbuf[0] = value[8];
  1183. tmpFO = atoi(tmpbuf);
  1184. m_DoseUnit.m_Focus->Update(tmpFO);
  1185. {
  1186. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  1187. FINFO("Current focus:{$}, FO={$}", atoi(m_DoseUnit.m_Focus->JSGet().c_str()) ? "large focus" : "small focus", m_DoseUnit.m_Focus->JSGet().c_str());
  1188. }
  1189. //ET
  1190. tmpbuf[0] = value[12];
  1191. tmpET = atoi(tmpbuf);
  1192. m_DoseUnit.m_Techmode->Update(tmpET);
  1193. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  1194. switch (tmpET)
  1195. {
  1196. case 0:
  1197. FINFO("ET={$}", "mA/ms", m_DoseUnit.m_Techmode->JSGet().c_str());
  1198. break;
  1199. case 1:
  1200. FINFO("ET={$}", "mAs", m_DoseUnit.m_Techmode->JSGet().c_str());
  1201. break;
  1202. case 2:
  1203. FINFO("ET={$}", "AEC / mA", m_DoseUnit.m_Techmode->JSGet().c_str());
  1204. break;
  1205. case 3:
  1206. FINFO("ET={$}", "mAs / ms", m_DoseUnit.m_Techmode->JSGet().c_str());
  1207. break;
  1208. case 4:
  1209. FINFO("ET={$}", "AEC", m_DoseUnit.m_Techmode->JSGet().c_str());
  1210. break;
  1211. }
  1212. //FIELD
  1213. tmpbuf[0] = value[16];
  1214. tmpbuf[1] = value[17];
  1215. tmpbuf[2] = value[18];
  1216. tmpField = atoi(tmpbuf);
  1217. if (m_DoseUnit.m_AECField->Update(tmpField))
  1218. FireNotify(AttrKey::AECFIELD, m_DoseUnit.m_AECField->JSGet());
  1219. //Film
  1220. tmpbuf[0] = value[22];
  1221. tmpbuf[1] = value[23];
  1222. tmpbuf[2] = value[24];
  1223. tmpFilm = atoi(tmpbuf);
  1224. if (m_DoseUnit.m_AECFilm->Update(tmpFilm))
  1225. FireNotify(AttrKey::AECFILM, m_DoseUnit.m_AECFilm->JSGet());
  1226. //Density
  1227. tmpbuf[0] = value[29];
  1228. tmpbuf[1] = 0;
  1229. tmpbuf[2] = 0;
  1230. tmpDensity = atoi(tmpbuf);
  1231. if (m_DoseUnit.m_AECDensity->Update(tmpDensity))
  1232. FireNotify(AttrKey::AECDENSITY, m_DoseUnit.m_AECDensity->JSGet());
  1233. //HE
  1234. tmpbuf[0] = value[33];
  1235. tmpbuf[1] = value[34];
  1236. tmpbuf[2] = value[35];
  1237. tmpHE = atoi(tmpbuf);
  1238. if (m_DoseUnit.m_HE->Update(tmpHE))
  1239. FireNotify(m_DoseUnit.m_HE->GetKey(), m_DoseUnit.m_HE->JSGet());
  1240. FINFO("parse tmpWS={$}, tmpFO={$}, tmpET={$}, tmpField={$}, tmpFilm={$}, tmpDensity={$}, tmpHE={$}", tmpWS, tmpFO, tmpET, tmpField, tmpFilm, tmpDensity, tmpHE);
  1241. };
  1242. auto HWEC = [this](const char* value, int length) -> void
  1243. {
  1244. assert(value);
  1245. FINFO("recv EC{$}",value);
  1246. };
  1247. auto HWST = [this](const char* value, int length) -> void
  1248. {
  1249. assert(value);
  1250. int genStatus = atoi(value);
  1251. if (m_bResetActive)
  1252. {
  1253. m_bResetActive = false;
  1254. //clear all error list
  1255. int level = 1;
  1256. for (auto errorStr : m_localErrorlist)
  1257. {
  1258. m_MSGUnit->DelErrorMessage(errorStr.c_str(), level, "");
  1259. FINFO("clear error = {$}\n", errorStr);
  1260. }
  1261. m_localErrorlist.clear();
  1262. }
  1263. switch (genStatus)
  1264. {
  1265. case 0:
  1266. FDEBUG("Get Gen Status_1:GENSTATE {$}", m_DoseUnit.m_GenState->JSGet());
  1267. FINFO("Initialization Phase\n");
  1268. if (1 == m_bUseEAcmd)
  1269. {
  1270. static int nST001Count = 0;
  1271. if (0 == nST001Count)//只执行一次。
  1272. {
  1273. FINFO("recv st001,and feedback EA000,just once");
  1274. HWSend("EA000");
  1275. nST001Count = 1;
  1276. }
  1277. }
  1278. break;
  1279. case 1:
  1280. FDEBUG("Get Gen Status_2:GENSTATE {$} -> (Standby Phase)", m_DoseUnit.m_GenState->JSGet());
  1281. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_STANDBY))
  1282. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  1283. break;
  1284. case 2:
  1285. FINFO("Rad Preparation Phase\n");
  1286. break;
  1287. case 3:
  1288. FINFO("Rad Ready Phase\n");
  1289. break;
  1290. case 4:
  1291. FDEBUG("Get Gen Status_10:GENSTATE {$} -> (GENERATOR_STATUS_EXP)", m_DoseUnit.m_GenSynState->JSGet());
  1292. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_EXP))
  1293. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  1294. break;
  1295. case 7:
  1296. FDEBUG("Get Gen Status_7:GENSTATE {$} -> (Error Phase)", m_DoseUnit.m_GenState->JSGet());
  1297. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_ERROR))
  1298. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  1299. break;
  1300. default:
  1301. FDEBUG("Get Gen Status:[{$}] unknown", genStatus);
  1302. break;
  1303. }
  1304. };
  1305. auto HWMAS = [this](const char* value, int length)
  1306. {
  1307. assert(value);
  1308. float fmas = 0.0f;
  1309. if (m_bMasR20)
  1310. {
  1311. fmas = atof(value) / 100.0;
  1312. }
  1313. else
  1314. {
  1315. fmas = atof(value) / 10.0;
  1316. }
  1317. /*if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_V2TYPE::ET_TIME)
  1318. {
  1319. FireNotify(AttrKey::MAS, to_string(0));
  1320. }
  1321. else
  1322. {*/
  1323. m_DoseUnit.m_MAS->Update(fmas);
  1324. FireNotify(AttrKey::MAS, m_DoseUnit.m_MAS->JSGet());
  1325. /*}*/
  1326. };
  1327. auto HWMA = [this](const char* value, int length)
  1328. {
  1329. assert(value);
  1330. float fma = atof(value) / 10.0;
  1331. /*if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_TIME)
  1332. {
  1333. FireNotify(AttrKey::MA, to_string(0));
  1334. }
  1335. else
  1336. {*/
  1337. m_DoseUnit.m_MA->Update(fma);
  1338. FireNotify(AttrKey::MA, m_DoseUnit.m_MA->JSGet());
  1339. /*}*/
  1340. };
  1341. auto HWMS = [this](const char* value, int length)
  1342. {
  1343. assert(value);
  1344. float fms = atof(value) / 10.0;
  1345. /*if (m_DoseUnit.m_Techmode->Get() != AttrKey::TECHMODE_V2TYPE::ET_TIME)
  1346. {
  1347. FireNotify(AttrKey::MS, to_string(0));
  1348. }
  1349. else
  1350. {*/
  1351. m_DoseUnit.m_MS->Update(fms);
  1352. FireNotify(AttrKey::MS, m_DoseUnit.m_MS->JSGet());
  1353. /*}*/
  1354. };
  1355. auto HWFocus = [this](const char* value, int length)
  1356. {
  1357. assert(value);
  1358. int nfous = atoi(value);
  1359. m_DoseUnit.m_Focus->Update(nfous);
  1360. {
  1361. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  1362. FINFO("Current focus:{$}, FO={$}", atoi(m_DoseUnit.m_Focus->JSGet().c_str()) ? "large focus" : "small focus", m_DoseUnit.m_Focus->JSGet().c_str());
  1363. }
  1364. };
  1365. auto HWTechmode = [this](const char* value, int length)
  1366. {
  1367. assert(value);
  1368. int ntechmode = atoi(value);
  1369. m_DoseUnit.m_Techmode->Update(ntechmode);
  1370. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  1371. switch (ntechmode)
  1372. {
  1373. case 0:
  1374. FINFO("ET={$}", "mA/ms", m_DoseUnit.m_Techmode->JSGet().c_str());
  1375. break;
  1376. case 1:
  1377. FINFO("ET={$}", "mAs", m_DoseUnit.m_Techmode->JSGet().c_str());
  1378. break;
  1379. case 2:
  1380. FINFO("ET={$}", "AEC / mA", m_DoseUnit.m_Techmode->JSGet().c_str());
  1381. break;
  1382. case 3:
  1383. FINFO("ET={$}", "mAs / ms", m_DoseUnit.m_Techmode->JSGet().c_str());
  1384. break;
  1385. case 4:
  1386. FINFO("ET={$}", "AEC", m_DoseUnit.m_Techmode->JSGet().c_str());
  1387. break;
  1388. }
  1389. };
  1390. auto HWAECField = [this](const char* value, int length)
  1391. {
  1392. assert(value);
  1393. int nvalue = atoi(value);
  1394. if (m_DoseUnit.m_AECField->Update(nvalue))
  1395. FireNotify(AttrKey::AECFIELD, m_DoseUnit.m_AECField->JSGet());
  1396. };
  1397. auto HWAECFilm = [this](const char* value, int length)
  1398. {
  1399. assert(value);
  1400. int nvalue = atoi(value);
  1401. if (m_DoseUnit.m_AECFilm->Update(nvalue))
  1402. FireNotify(AttrKey::AECFILM, m_DoseUnit.m_AECFilm->JSGet());
  1403. };
  1404. auto HWAECDensity = [this](const char* value, int length)
  1405. {
  1406. assert(value);
  1407. int nvalue = atoi(value);
  1408. if (m_DoseUnit.m_AECDensity->Update(nvalue))
  1409. FireNotify(AttrKey::AECDENSITY, m_DoseUnit.m_AECDensity->JSGet());
  1410. };
  1411. auto HWWS = [this](const char* value, int length)
  1412. {
  1413. assert(value);
  1414. int nValue = atoi(value);
  1415. if (m_DoseUnit.m_WS->Update(nValue))
  1416. {
  1417. FireNotify(m_DoseUnit.m_WS->GetKey(), m_DoseUnit.m_WS->JSGet());
  1418. }
  1419. };
  1420. auto HWPR = [this](const char* value, int length)
  1421. {
  1422. assert(value);
  1423. int nValue = atoi(value);
  1424. if (nValue == 2)
  1425. {
  1426. FINFO("The high voltage generator enters the exposure preparation stage。");
  1427. HWSend("PR2");
  1428. }
  1429. else if (nValue == 1)
  1430. {
  1431. HWSend("PR1");
  1432. m_iLoopTime = REMEDYST_LoopExpTime;
  1433. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_PREPARE))
  1434. {
  1435. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1436. FINFO("Generator exposure process status:{$};", "GENERATOR_RAD_PREPARE");
  1437. }
  1438. }
  1439. else if (nValue == 0)
  1440. {
  1441. HWSend("PR0");
  1442. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_OFF));
  1443. {
  1444. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1445. FINFO("Generator exposure process status:{$};", "GENERATOR_RAD_OFF");
  1446. FINFO("HWPR m_DoseUnit.m_GenSynState->JSGet()={$}", m_DoseUnit.m_GenSynState->JSGet().c_str());
  1447. RefreshData();
  1448. }
  1449. if (m_iLoopTime == REMEDYST_LoopExpTime)
  1450. {
  1451. if ((int)m_GenConfig["loopTime"] >= 100)
  1452. {
  1453. m_iLoopTime = (int)m_GenConfig["loopTime"];
  1454. }
  1455. else
  1456. m_iLoopTime = REMEDYST_LoopDefTime;
  1457. FDEBUG("reduction loopTime[{$}]->[{$}]", REMEDYST_LoopExpTime, m_iLoopTime.load());
  1458. }
  1459. }
  1460. };
  1461. auto HWXR = [this](const char* value, int length)
  1462. {
  1463. assert(value);
  1464. int nValue = atoi(value);
  1465. if (nValue == 1)
  1466. {
  1467. HWSend("XR1");
  1468. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_READY))
  1469. {
  1470. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1471. FINFO("Generator exposure process status:{$};", "GENERATOR_RAD_READY");
  1472. }
  1473. }
  1474. else if (nValue == 2)
  1475. {
  1476. HWSend("XR2");
  1477. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_EXP))
  1478. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  1479. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYON))
  1480. {
  1481. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1482. FINFO("Generator exposure process status:{$};", "GENERATOR_RAD_XRAYON");
  1483. }
  1484. }
  1485. else if (nValue == 0)
  1486. {
  1487. HWSend("XR0");
  1488. if(m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYOFF));
  1489. {
  1490. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1491. FINFO("Generator exposure process status:{$};", "GENERATOR_RAD_XRAYOFF");
  1492. FINFO("HWXR m_DoseUnit.m_GenSynState->JSGet()={$}", m_DoseUnit.m_GenSynState->JSGet().c_str());
  1493. HWSend("AP?");
  1494. Sleep(30);
  1495. HWSend("AT?");
  1496. Sleep(30);
  1497. }
  1498. }
  1499. };
  1500. auto HWVPDOSE = [this](const char* value, int length)//mas
  1501. {
  1502. assert(value);
  1503. m_DoseUnit.m_PostKV->Update(atof(value));
  1504. FireNotify(AttrKey::POSTKV, m_DoseUnit.m_PostKV->JSGet());
  1505. FINFO("Actual exposure parameters KV:{$}", m_DoseUnit.m_PostKV->JSGet().c_str());
  1506. };
  1507. auto HWAPDOSE = [this](const char* value, int length)//mas
  1508. {
  1509. assert(value);
  1510. m_DoseUnit.m_PostMAS->Update(atof(value) / 10.0);
  1511. FireNotify(m_DoseUnit.m_PostMAS->GetKey(), m_DoseUnit.m_PostMAS->JSGet());
  1512. m_DoseUnit.m_PostKV->Update(m_DoseUnit.m_KV->Get());
  1513. FireNotify(AttrKey::POSTKV, m_DoseUnit.m_PostKV->JSGet());
  1514. FINFO("Actual exposure parametersMAS:{$}", m_DoseUnit.m_PostMAS->JSGet().c_str());
  1515. };
  1516. auto HWATDOSE = [this](const char* value, int length)
  1517. {
  1518. assert(value);
  1519. m_DoseUnit.m_PostMS->Update(atof(value) / 10.0);
  1520. FireNotify(m_DoseUnit.m_PostMS->GetKey(), m_DoseUnit.m_PostMS->JSGet());
  1521. m_DoseUnit.m_PostMA->Update(m_DoseUnit.m_PostMAS->Get() * 1000.0 / m_DoseUnit.m_PostMS->Get());
  1522. FireNotify(m_DoseUnit.m_PostMA->GetKey(), m_DoseUnit.m_PostMA->JSGet());
  1523. FINFO("Actual exposure parametersMS:{$}", m_DoseUnit.m_PostMS->JSGet().c_str());
  1524. };
  1525. auto HWDAPST = [this](const char* value, int length)
  1526. {
  1527. assert(value);
  1528. int dapStatus = atoi(value);
  1529. if (dapStatus == 1)
  1530. {
  1531. m_bDAPEnable = true;
  1532. m_bAKEnable = false;
  1533. }
  1534. else if (dapStatus == 2)
  1535. {
  1536. m_bDAPEnable = false;
  1537. m_bAKEnable = true;
  1538. }
  1539. else if (dapStatus == 3)
  1540. {
  1541. m_bDAPEnable = true;
  1542. m_bAKEnable = true;
  1543. }
  1544. else
  1545. {
  1546. m_bDAPEnable = false;
  1547. m_bAKEnable = false;
  1548. }
  1549. };
  1550. auto HWDT = [this](const char* value, int length)
  1551. {
  1552. assert(value);
  1553. int dapStatus = atoi(value);
  1554. if (dapStatus == 0)
  1555. {
  1556. m_bDAPEnable = false;
  1557. FINFO("DAP test failed");
  1558. }
  1559. else if (dapStatus == 1)
  1560. {
  1561. m_bDAPEnable = true;
  1562. FINFO("DAP test passed");
  1563. }
  1564. else if (dapStatus == 2)
  1565. {
  1566. m_bDAPEnable = true;
  1567. FINFO("DAP test in progress.");
  1568. }
  1569. };
  1570. auto HWDAP = [this](const char* value, int length)
  1571. {
  1572. assert(value);
  1573. //m_DoseUnit.->Update(atof(value));
  1574. //FireNotify(m_DoseUnit.m_PostMS->GetKey(), m_DoseUnit.m_PostMS->JSGet());
  1575. //SetEvent(m_hGenPostEvent);
  1576. m_DAP->Update(atof(value)); //should push to subsystem.......
  1577. };
  1578. // 公共处理函数
  1579. auto HWEL = [this](const char* value, int length)
  1580. {
  1581. HandleError(value, "REMEDY_EL_", "EL");
  1582. };
  1583. auto HWER = [this](const char* value, int length)
  1584. {
  1585. HandleError(value, "REMEDY_ER_", "ER");
  1586. };
  1587. auto HWWARN = [this](const char* value, int length)
  1588. {
  1589. HandleError(value, "REMEDY_WARN_", "EW");
  1590. };
  1591. auto HWEHE = [this](const char* value, int length)
  1592. {
  1593. assert(value);
  1594. int nhe = atoi(value);
  1595. FINFO("热容百分比{$}%", nhe);
  1596. if (m_DoseUnit.m_HE->Update(nhe))
  1597. FireNotify(m_DoseUnit.m_HE->GetKey(), m_DoseUnit.m_HE->JSGet());
  1598. };
  1599. //075 FLM100 FLI000 FLT006 FLF2 FLA0 FLS060 FLZ0 FLD0
  1600. auto HWFLK = [this](const char* value, int length)
  1601. {
  1602. assert(value);
  1603. if (length > 20) // Check if length is more than 20
  1604. {
  1605. FINFO("HWFLK={$}", value);
  1606. int tmpflk, tmpflf, tmpfla, tmpfld, tmpflo;
  1607. float tmpflm, tmpfli, tmpflt, tmpfls, tmpflw;
  1608. char tmpbuf[3]{ 0, 0, 0 };
  1609. //flk
  1610. tmpbuf[0] = value[0];
  1611. tmpbuf[1] = value[1];
  1612. tmpbuf[2] = value[2];
  1613. tmpflk = atoi(tmpbuf);
  1614. if (m_DoseUnit.m_FLKV->Update(tmpflk))
  1615. FireNotify(AttrKey::FLUKV, m_DoseUnit.m_FLKV->JSGet());
  1616. // flm
  1617. tmpbuf[0] = value[7];
  1618. tmpbuf[1] = value[8];
  1619. tmpbuf[2] = value[9];
  1620. tmpflm = atof(tmpbuf) / 10.0;
  1621. if (m_DoseUnit.m_FLMA->Update(tmpflm))
  1622. FireNotify(AttrKey::FLUMA, m_DoseUnit.m_FLMA->JSGet());
  1623. // fli
  1624. tmpbuf[0] = value[14];
  1625. tmpbuf[1] = value[15];
  1626. tmpbuf[2] = value[16];
  1627. tmpfli = atof(tmpbuf) / 10.0;
  1628. if (m_DoseUnit.m_FLIntTime->Update(tmpfli))
  1629. FireNotify(AttrKey::FLUIntTime, m_DoseUnit.m_FLIntTime->JSGet());
  1630. // flt
  1631. tmpbuf[0] = value[21];
  1632. tmpbuf[1] = value[22];
  1633. tmpbuf[2] = value[23];
  1634. tmpflt = atof(tmpbuf) / 10.0;
  1635. if (m_DoseUnit.m_FLAccTime->Update(tmpflt))
  1636. FireNotify(AttrKey::FLUAccTime, m_DoseUnit.m_FLAccTime->JSGet());
  1637. // flf
  1638. tmpbuf[0] = value[28];
  1639. tmpbuf[1] = 0;
  1640. tmpbuf[2] = 0;
  1641. tmpflf = atoi(tmpbuf);
  1642. if (m_DoseUnit.m_FLMode->Update(tmpflf))
  1643. FireNotify(AttrKey::FLUMode, m_DoseUnit.m_FLMode->JSGet());
  1644. // fla
  1645. tmpbuf[0] = value[33];
  1646. tmpfla = atoi(tmpbuf);
  1647. if (m_DoseUnit.m_ABSStatus->Update(tmpfla))
  1648. FireNotify(AttrKey::FLUABSStatus, m_DoseUnit.m_ABSStatus->JSGet());
  1649. // fls
  1650. tmpbuf[0] = value[38];
  1651. tmpbuf[1] = value[39];
  1652. tmpbuf[2] = value[40];
  1653. tmpfls = atof(tmpbuf) / 10.0;
  1654. if (m_DoseUnit.m_PPS->Update(tmpfls))
  1655. FireNotify(AttrKey::FLUPPS, m_DoseUnit.m_PPS->JSGet());
  1656. // fld
  1657. tmpbuf[0] = value[50];
  1658. tmpbuf[1] = 0;
  1659. tmpbuf[2] = 0;
  1660. tmpfld = atoi(tmpbuf);
  1661. if (m_DoseUnit.m_DoseLevel->Update(tmpfld))
  1662. FireNotify(AttrKey::FLUDoseLevel, m_DoseUnit.m_DoseLevel->JSGet());
  1663. FINFO("tmpflk={$}, tmpflf={$}, tmpfla={$}, tmpfld={$}, tmpflm={$}, tmpfli={$}, tmpflt={$}, tmpfls={$};", tmpflk, tmpflf, tmpfla, tmpfld, tmpflm, tmpfli, tmpflt, tmpfls);
  1664. }
  1665. else
  1666. {
  1667. if (m_DoseUnit.m_FLKV->Update(atof(value)))
  1668. FireNotify(AttrKey::FLUKV, m_DoseUnit.m_FLKV->JSGet());
  1669. }
  1670. };
  1671. auto HWFLM = [this](const char* value, int length)
  1672. {
  1673. assert(value);
  1674. float tmpflm = atof(value) / 10.0;
  1675. if (m_DoseUnit.m_FLMA->Update(tmpflm))
  1676. FireNotify(AttrKey::FLUMA, m_DoseUnit.m_FLMA->JSGet());
  1677. };
  1678. auto HWFLS = [this](const char* value, int length)
  1679. {
  1680. assert(value);
  1681. FINFO("HWFLS={$}", value);
  1682. float tmppps = atof(value) / 10.0;
  1683. if (m_DoseUnit.m_PPS->Update(tmppps))
  1684. FireNotify(AttrKey::FLUPPS, m_DoseUnit.m_PPS->JSGet());
  1685. };
  1686. auto HWFLX = [this](const char* value, int length)
  1687. {
  1688. assert(value);
  1689. int nValue = atoi(value);
  1690. if (nValue == 0)
  1691. {
  1692. HWSend("FLX0");
  1693. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_XRAYOFF))
  1694. {
  1695. FINFO("Generator exposure process status{$};", "GENERATOR_FLU_XRAYOFF");
  1696. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1697. }
  1698. }
  1699. else
  1700. {
  1701. HWSend("FLX1");
  1702. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_EXP))
  1703. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  1704. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_XRAYON))
  1705. {
  1706. FINFO("Generator exposure process status{$};", "GENERATOR_FLU_XRAYON");
  1707. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1708. }
  1709. }
  1710. };
  1711. auto HWFLP = [this](const char* value, int length)
  1712. {
  1713. assert(value);
  1714. int nValue = atoi(value);
  1715. if (nValue == 0)
  1716. {
  1717. if (m_iLoopTime == REMEDYST_LoopExpTime)
  1718. {
  1719. if ((int)m_GenConfig["loopTime"] >= 100)
  1720. {
  1721. m_iLoopTime = (int)m_GenConfig["loopTime"];
  1722. }
  1723. else
  1724. m_iLoopTime = REMEDYST_LoopDefTime;
  1725. FDEBUG("reduction loopTime[{$}]->[{$}]", REMEDYST_LoopExpTime, m_iLoopTime.load());
  1726. }
  1727. HWSend("FLP0");
  1728. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_OFF))
  1729. {
  1730. FINFO("脚闸抬起,发生器曝光流程状态{$};", "GENERATOR_FLU_OFF");
  1731. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1732. }
  1733. RefreshData();
  1734. }
  1735. else
  1736. {
  1737. m_iLoopTime = REMEDYST_LoopExpTime;
  1738. HWSend("FLP1");
  1739. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_READY))
  1740. {
  1741. FINFO("Generator exposure process status{$};", "GENERATOR_FLU_READY");
  1742. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1743. }
  1744. }
  1745. };
  1746. auto HWFLF = [this](const char* value, int length)
  1747. {
  1748. assert(value);
  1749. FINFO("HWFLF={$};", value);
  1750. int tmpflf = atoi(value);
  1751. if (m_DoseUnit.m_FLMode->Update(tmpflf))
  1752. FireNotify(AttrKey::FLUMode, m_DoseUnit.m_FLMode->JSGet());
  1753. };
  1754. auto HWFLA = [this](const char* value, int length)
  1755. {
  1756. assert(value);
  1757. int tmpfla = atoi(value);
  1758. if (m_DoseUnit.m_ABSStatus->Update(tmpfla))
  1759. FireNotify(AttrKey::FLUABSStatus, m_DoseUnit.m_ABSStatus->JSGet());
  1760. };
  1761. auto HWFLD = [this](const char* value, int length)
  1762. {
  1763. assert(value);
  1764. };
  1765. auto HWFLC = [this](const char* value, int length)
  1766. {
  1767. assert(value);
  1768. };
  1769. auto HWFLO = [this](const char* value, int length)
  1770. {
  1771. assert(value);
  1772. int nValue = atoi(value);
  1773. if (m_DoseUnit.m_Curve->Update(nValue))
  1774. FireNotify(AttrKey::FLUCurve, m_DoseUnit.m_Curve->JSGet());
  1775. };
  1776. auto HWFLW = [this](const char* value, int length)
  1777. {
  1778. assert(value);;
  1779. float tmpflms = atof(value) / 100.0;
  1780. if (m_DoseUnit.m_FLMS->Update(tmpflms))
  1781. FireNotify(AttrKey::FLUMS, m_DoseUnit.m_FLMS->JSGet());
  1782. };
  1783. auto HWFLI = [this](const char* value, int length)
  1784. {
  1785. assert(value);
  1786. float tmpfli = atof(value) / 10.0;
  1787. if (m_DoseUnit.m_FLIntTime->Update(tmpfli))
  1788. FireNotify(AttrKey::FLUIntTime, m_DoseUnit.m_FLIntTime->JSGet());
  1789. };
  1790. auto HWFLT = [this](const char* value, int length)
  1791. {
  1792. assert(value);
  1793. float tmpflt = atof(value) / 10.0;
  1794. if (m_DoseUnit.m_FLAccTime->Update(tmpflt))
  1795. FireNotify(AttrKey::FLUAccTime, m_DoseUnit.m_FLAccTime->JSGet());
  1796. };
  1797. // 有部分前缀是包含关系, 长的包含短的, 例如 KVS 包含了 KV.
  1798. // 因此长的在前面, 短的在后面
  1799. // !!! Device 是个短寿命对象, 而 arFrame 是静态变量 !!!
  1800. // !!! 因此, 在添加到 arFrame 之前, 务必先清零 !!!
  1801. arFrame.clear();
  1802. arFrame.push_back(tFrameMapping("KV", 2, HWKV));
  1803. arFrame.push_back(tFrameMapping("TU", 2, HWTU));
  1804. arFrame.push_back(tFrameMapping("MX", 2, HWMAS));
  1805. arFrame.push_back(tFrameMapping("MA", 2, HWMA));
  1806. arFrame.push_back(tFrameMapping("MS", 2, HWMS));
  1807. arFrame.push_back(tFrameMapping("ET", 2, HWTechmode));
  1808. arFrame.push_back(tFrameMapping("FO", 2, HWFocus));
  1809. arFrame.push_back(tFrameMapping("FI", 2, HWAECField));
  1810. arFrame.push_back(tFrameMapping("FS", 2, HWAECFilm));
  1811. arFrame.push_back(tFrameMapping("FN", 2, HWAECDensity));
  1812. arFrame.push_back(tFrameMapping("WS", 2, HWWS));
  1813. arFrame.push_back(tFrameMapping("PR", 2, HWPR));
  1814. arFrame.push_back(tFrameMapping("XR", 2, HWXR));
  1815. arFrame.push_back(tFrameMapping("VP", 2, HWVPDOSE));
  1816. arFrame.push_back(tFrameMapping("AP", 2, HWAPDOSE));
  1817. arFrame.push_back(tFrameMapping("AT", 2, HWATDOSE));
  1818. arFrame.push_back(tFrameMapping("EL", 2, HWEL));
  1819. arFrame.push_back(tFrameMapping("ER", 2, HWER));
  1820. arFrame.push_back(tFrameMapping("EW", 2, HWWARN));
  1821. arFrame.push_back(tFrameMapping("HE", 2, HWEHE));
  1822. arFrame.push_back(tFrameMapping("FLK", 3, HWFLK));
  1823. arFrame.push_back(tFrameMapping("FLM", 3, HWFLM));
  1824. arFrame.push_back(tFrameMapping("FLS", 3, HWFLS));
  1825. arFrame.push_back(tFrameMapping("FLF", 3, HWFLF));
  1826. arFrame.push_back(tFrameMapping("FLP", 3, HWFLP));
  1827. arFrame.push_back(tFrameMapping("FLX", 3, HWFLX));
  1828. arFrame.push_back(tFrameMapping("FLW", 3, HWFLW));
  1829. arFrame.push_back(tFrameMapping("FLI", 3, HWFLI));
  1830. arFrame.push_back(tFrameMapping("FLT", 3, HWFLT));
  1831. arFrame.push_back(tFrameMapping("FLA", 3, HWFLA));
  1832. arFrame.push_back(tFrameMapping("FLD", 3, HWFLD));
  1833. arFrame.push_back(tFrameMapping("FLC", 3, HWFLD));
  1834. arFrame.push_back(tFrameMapping("FLO", 3, HWFLO));
  1835. arFrame.push_back(tFrameMapping("ST", 2, HWST));
  1836. arFrame.push_back(tFrameMapping("EC", 2, HWEC));
  1837. arFrame.push_back(tFrameMapping("DS", 2, HWDAPST)); //dap status
  1838. arFrame.push_back(tFrameMapping("DA", 2, HWDAP)); //dap value
  1839. arFrame.push_back(tFrameMapping("DT", 2, HWDT)); //test dap
  1840. arFrame.push_back(tFrameMapping("P", 1, HWPR));
  1841. }
  1842. bool nsGEN::REMEDYSTDevice::StartHardwareStatusThread()
  1843. {
  1844. FINFO("enter Start HardwareStatus Thread ");
  1845. if (m_pHardwareStatusThread == NULL)
  1846. {
  1847. DWORD m_HardwareStatusID;
  1848. m_pHardwareStatusThread = CreateThread(0, 0, HardwareStatusThread, this, 0, &m_HardwareStatusID);
  1849. if (m_pHardwareStatusThread == NULL)
  1850. {
  1851. Fatal("Start HardwareStatus Thread Failed");
  1852. return false;
  1853. }
  1854. }
  1855. return true;
  1856. }
  1857. DWORD nsGEN::REMEDYSTDevice::HardwareStatusThread(LPVOID pParam)
  1858. {
  1859. REMEDYSTDevice* pCurGen = (REMEDYSTDevice*)pParam;
  1860. if (pCurGen == NULL)
  1861. {
  1862. return false;
  1863. }
  1864. int currtTime = pCurGen->m_iLoopTime;
  1865. int messageIndex = 0;
  1866. FINFO("HardwareStatusThread start");
  1867. while (true)
  1868. {
  1869. if (currtTime != pCurGen->m_iLoopTime)
  1870. {
  1871. currtTime = pCurGen->m_iLoopTime;
  1872. }
  1873. Sleep(currtTime);
  1874. //获取消息
  1875. // 发送不同的消息,根据messageIndex循环
  1876. switch (messageIndex)
  1877. {
  1878. case 0:
  1879. pCurGen->HWSend("HE?");
  1880. break;
  1881. case 1:
  1882. pCurGen->HWSend("ST");
  1883. break;
  1884. }
  1885. // 更新messageIndex,以便下一轮发送不同的消息
  1886. messageIndex = (messageIndex + 1) % 2;
  1887. }
  1888. FINFO("HardwareStatusThread stop");
  1889. return true;
  1890. }
  1891. //-----------------------------------------------------------------------------
  1892. // REMEDYSTDriver
  1893. //-----------------------------------------------------------------------------
  1894. nsGEN::REMEDYSTDriver::REMEDYSTDriver()
  1895. {
  1896. m_bDemoMode = false;
  1897. m_bDemoConnected = false;
  1898. }
  1899. nsGEN::REMEDYSTDriver::~REMEDYSTDriver()
  1900. {
  1901. }
  1902. auto nsGEN::REMEDYSTDriver::CreateDevice(int index) -> std::unique_ptr <IODevice>
  1903. {
  1904. FINFO("CreateDevice in\n");
  1905. m_pDevice = new REMEDYSTDevice(EventCenter, m_SCF, m_ConfigFileName);
  1906. auto dev = std::unique_ptr <IODevice>(new IODevice(m_pDevice));
  1907. FINFO("CreateDevice out\n");
  1908. return dev;
  1909. }
  1910. void nsGEN::REMEDYSTDriver::FireNotify(int code, std::string key, std::string content)
  1911. {
  1912. EventCenter->OnNotify(code, key, content);
  1913. }
  1914. Log4CPP::Logger* gLogger = nullptr;
  1915. void nsGEN::REMEDYSTDriver::Prepare()
  1916. {
  1917. string strLogPath = GetProcessDirectory() + R"(\OEMDrivers\Generator\Conf\Log4CPP.Config.GEN.xml)";
  1918. Log4CPP::GlobalContext::Map::Set(ECOM::Utility::Hash("LogFileName"), "GEN.REMEDYST");
  1919. auto rc = Log4CPP::LogManager::LoadConfigFile(strLogPath.c_str());
  1920. gLogger = Log4CPP::LogManager::GetLogger("GEN.REMEDYST");
  1921. FINFO("Enter Prepare.");
  1922. m_SCFDllName = GetConnectDLL(m_ConfigFileName);
  1923. super::Prepare();
  1924. }
  1925. bool DATA_ACTION nsGEN::REMEDYSTDriver::Connect()
  1926. {
  1927. super::Disconnect();
  1928. m_SCF.Disconnect();
  1929. FINFO("Enter {$},configlef={$}\n", __FUNCTION__, m_ConfigFileName.c_str());
  1930. ResDataObject Connection = GetConnectParam(m_ConfigFileName);
  1931. FINFO("connections:{$} \n", Connection.encode());
  1932. auto erCode = m_SCF.Connect(Connection.encode(), &nsGEN::REMEDYSTDriver::callbackPackageProcess, SCF_PACKET_TRANSFER, 3000);
  1933. if (erCode != SCF_ERR::SCF_SUCCEED)
  1934. return false;
  1935. auto rc = super::Connect();
  1936. if (!rc)
  1937. return false;
  1938. return true;
  1939. }
  1940. void nsGEN::REMEDYSTDriver::Disconnect()
  1941. {
  1942. super::Disconnect();
  1943. m_SCF.Disconnect();
  1944. m_bDemoConnected = false;
  1945. }
  1946. bool nsGEN::REMEDYSTDriver::isConnected() const
  1947. {
  1948. if (!super::isConnected())
  1949. {
  1950. FINFO("No valid connection!!!\n");
  1951. return false;
  1952. }
  1953. if (m_pDevice == nullptr)
  1954. {
  1955. FINFO("m_pDevice == nullptr\n");
  1956. return false;
  1957. }
  1958. if (m_pDevice->LoadConfig(m_ConfigFileName) == -1)
  1959. {
  1960. return false; //return 0;
  1961. }
  1962. int genState = m_pDevice->GetGenState();
  1963. FINFO("m_pDevice->GetGenState() == {$}\n", genState);
  1964. return genState > 0; // 只有返回值大于 0 时才返回 true
  1965. }
  1966. std::string nsGEN::REMEDYSTDriver::DriverProbe()
  1967. {
  1968. FINFO("DriverProbe in \n");
  1969. ResDataObject r_config, HardwareInfo;
  1970. if (r_config.loadFile(m_ConfigFileName.c_str()))
  1971. {
  1972. HardwareInfo.add("MajorID", r_config["CONFIGURATION"]["MajorID"]);
  1973. HardwareInfo.add("MinorID", r_config["CONFIGURATION"]["MinorID"]);
  1974. HardwareInfo.add("VendorID", r_config["CONFIGURATION"]["VendorID"]);
  1975. HardwareInfo.add("ProductID", r_config["CONFIGURATION"]["ProductID"]);
  1976. HardwareInfo.add("SerialID", r_config["CONFIGURATION"]["SerialID"]);
  1977. }
  1978. else
  1979. {
  1980. HardwareInfo.add("MajorID", "Generator");
  1981. HardwareInfo.add("MinorID", "Dr");
  1982. HardwareInfo.add("VendorID", "REMEDYST");
  1983. HardwareInfo.add("ProductID", "HF");
  1984. HardwareInfo.add("SerialID", "Drv");
  1985. }
  1986. string ret = HardwareInfo.encode();
  1987. FINFO("DriverProbe out \n");
  1988. return ret;
  1989. }
  1990. std::string nsGEN::REMEDYSTDriver::GetResource()
  1991. {
  1992. ResDataObject temp;
  1993. if (!temp.loadFile(m_ConfigFileName.c_str()))
  1994. return std::string();
  1995. auto r_config = temp["CONFIGURATION"];
  1996. for (auto& Item : m_ConfigInfo)
  1997. {
  1998. string key = Item.GetKey();
  1999. if (key == ConfKey::CcosGeneratorType)
  2000. {
  2001. Item.SetCurrentValue(((string)r_config["VendorID"]).c_str());
  2002. }
  2003. else if (key == ConfKey::CcosGeneratorModel)
  2004. {
  2005. Item.SetCurrentValue(((string)r_config["ProductID"]).c_str());
  2006. }
  2007. else if (key == ConfKey::CcosWSTable || key == ConfKey::CcosWSWall || key == ConfKey::CcosWSFree
  2008. || key == ConfKey::CcosWSTomo || key == ConfKey::CcosWSConventional)
  2009. {
  2010. Item.SetCurrentValue(((string)r_config[key.c_str()]).c_str());
  2011. }
  2012. else if (key == ConfKey::CcosSynTable || key == ConfKey::CcosSynWall || key == ConfKey::CcosSynFree
  2013. || key == ConfKey::CcosSynTomo || key == ConfKey::CcosSynConventional)
  2014. {
  2015. Item.SetCurrentValue(((string)r_config[key.c_str()]).c_str());
  2016. }
  2017. else if (key == ConfKey::CcosSCFType)
  2018. {
  2019. Item.SetCurrentValue(((string)r_config["connections"][0]["type"]).c_str());
  2020. }
  2021. else if (key == ConfKey::CcosSCFPort || key == ConfKey::CcosSCFBaudrate || key == ConfKey::CcosSCFBytesize
  2022. || key == ConfKey::CcosSCFParity || key == ConfKey::CcosSCFStopbits || key == ConfKey::CcosSCFIP)
  2023. {
  2024. if (r_config["connections"][0].GetFirstOf(key.c_str()) >= 0)
  2025. {
  2026. Item.SetCurrentValue(((string)r_config["connections"][0][key.c_str()]).c_str());
  2027. }
  2028. }
  2029. }
  2030. ResDataObject resAttr, resDescription;
  2031. for (auto Item : m_ConfigInfo)
  2032. {
  2033. resAttr.add(Item.GetKey(), Item.GetCurrentValue());
  2034. resDescription.add(Item.GetKey(), Item.GetDescription());
  2035. }
  2036. ResDataObject resDeviceResource;
  2037. resDeviceResource.add(ConfKey::CcosGeneratorAttribute, resAttr);
  2038. resDeviceResource.add(ConfKey::CcosGeneratorDescription, resDescription);
  2039. string res = resDeviceResource.encode();
  2040. //printf("resDeviceResource :%s \n", resDeviceResource.encode());
  2041. FINFO("resDeviceResource :{$} \n", resDeviceResource.encode());
  2042. ResDataObject DescriptionTempEx;
  2043. DescriptionTempEx.add(ConfKey::CcosGeneratorConfig, resDeviceResource);
  2044. m_DeviceConfig.clear();
  2045. m_DeviceConfig = DescriptionTempEx;
  2046. return res;
  2047. }
  2048. bool nsGEN::REMEDYSTDriver::GetDeviceConfig(std::string& Cfg)
  2049. {
  2050. //Cfg = m_DeviceConfigSend.encode();
  2051. Cfg = m_DeviceConfig.encode();
  2052. //printf("GetDeviceConfig over");
  2053. printf("GetDeviceConfig over , %s", Cfg.c_str());
  2054. return true;
  2055. }
  2056. bool nsGEN::REMEDYSTDriver::SetDeviceConfig(std::string Cfg)
  2057. {
  2058. FINFO("--Func-- SetDeviceConfig {$}\n", Cfg.c_str());
  2059. return true;
  2060. #if 0
  2061. ResDataObject DeviceConfig;
  2062. DeviceConfig.decode(Cfg.c_str());
  2063. ResDataObject DescriptionTempEx;
  2064. DescriptionTempEx = DeviceConfig["DeviceConfig"]["Attribute"];
  2065. FDEBUG("Attribute:{$}", DescriptionTempEx.encode());
  2066. bool bSaveFile = false; //true:重新保存配置文件
  2067. string strAccess = "";
  2068. for (int i = 0; i < DescriptionTempEx.size(); i++)
  2069. {
  2070. string strKey = DescriptionTempEx.GetKey(i);
  2071. FINFO("{$}", strKey.c_str());
  2072. try
  2073. {
  2074. if (m_pAttribute->GetFirstOf(strKey.c_str()) >= 0)
  2075. {
  2076. strAccess = (string)(*m_pDescription)[strKey.c_str()]["Access"];
  2077. if ("RW" == strAccess)
  2078. {
  2079. //修改对应配置,在其他单元的配置项要同时调用其修改函数修改真实值
  2080. //1. 修改内存中的值,用于给上层发消息
  2081. (*m_pAttribute)[strKey.c_str()] = DescriptionTempEx[i];
  2082. //2. 拿到Innerkey
  2083. int nConfigInfoCount = (int)m_Configurations["ConfigToolInfo"].GetKeyCount("AttributeInfo");
  2084. FINFO("nConfigInfoCount {$}", nConfigInfoCount);
  2085. string strTemp = ""; //存储AttributeKey
  2086. for (int nInfoIndex = 0; nInfoIndex < nConfigInfoCount; nInfoIndex++)
  2087. {
  2088. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeKey"];
  2089. if (strTemp == strKey)
  2090. {
  2091. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["InnerKey"];
  2092. break;
  2093. }
  2094. }
  2095. //3. 修改配置文件中的值
  2096. if (SetDeviceConfigValue(m_Configurations, strTemp.c_str(), 1, DescriptionTempEx[i]))
  2097. {
  2098. FDEBUG("SetDeviceConfigValue over");
  2099. bSaveFile = true;
  2100. }
  2101. }
  2102. else
  2103. {
  2104. FINFO("{$} is not a RW configuration item", strKey.c_str());
  2105. }
  2106. }
  2107. else
  2108. {
  2109. FINFO("without this attribute {$}", strKey.c_str());
  2110. }
  2111. }
  2112. catch (ResDataObjectExption& e)
  2113. {
  2114. FERROR("SetDriverConfig crashed: {$}", e.what());
  2115. return false;
  2116. }
  2117. }
  2118. if (bSaveFile)
  2119. {
  2120. //3. 重新保存配置文件
  2121. SaveConfigFile(true);
  2122. }
  2123. #endif // 0
  2124. return true;
  2125. }
  2126. bool nsGEN::REMEDYSTDriver::SaveConfigFile(bool bSendNotify)
  2127. {
  2128. m_ConfigAll["CONFIGURATION"] = m_Configurations;
  2129. bool bRt = m_ConfigAll.SaveFile(m_ConfigFileName.c_str());
  2130. FINFO("SaveConfigFile over {$}", bRt);
  2131. return true;
  2132. }
  2133. std::string nsGEN::REMEDYSTDriver::DeviceProbe()
  2134. {
  2135. FINFO("std::string nsGEN::PSGRFDriver::DeviceProbe() in\n");
  2136. ResDataObject r_config, HardwareInfo;
  2137. if (r_config.loadFile(m_ConfigFileName.c_str()))
  2138. {
  2139. HardwareInfo.add("MajorID", r_config["CONFIGURATION"]["MajorID"]);
  2140. HardwareInfo.add("MinorID", r_config["CONFIGURATION"]["MinorID"]);
  2141. HardwareInfo.add("VendorID", r_config["CONFIGURATION"]["VendorID"]);
  2142. HardwareInfo.add("ProductID", r_config["CONFIGURATION"]["ProductID"]);
  2143. HardwareInfo.add("SerialID", r_config["CONFIGURATION"]["SerialID"]);
  2144. }
  2145. else
  2146. {
  2147. HardwareInfo.add("MajorID", "Generator");
  2148. HardwareInfo.add("MinorID", "Dr");
  2149. HardwareInfo.add("VendorID", "REMEDYST");
  2150. HardwareInfo.add("ProductID", "HF");
  2151. HardwareInfo.add("SerialID", "1234");
  2152. }
  2153. string ret = HardwareInfo.encode();
  2154. FINFO("std::string nsGEN::PSGRFDriver::DeviceProbe() out\n");
  2155. return ret;
  2156. }
  2157. void nsGEN::REMEDYSTDriver::Dequeue(const char* Packet, DWORD Length)
  2158. {
  2159. DecodeFrame(Packet, Length);
  2160. }
  2161. /*
  2162. ==IN==:KV070 MA00320 MS00063 MX00036
  2163. ==IN==:TU0 WS1 FO0 ET0 FI010 FS001 FN 0 HE000
  2164. how to split the str like up.
  2165. //command+03+sum
  2166. */
  2167. PACKET_RET nsGEN::REMEDYSTDriver::callbackPackageProcess(const char* RecData, DWORD nLength, DWORD& PacketLength)
  2168. {
  2169. if (nLength < 1)
  2170. {
  2171. printf("nLength < 1, nLength==%d \n", nLength);
  2172. return PACKET_USELESS;
  2173. }
  2174. for (DWORD i = 0; i < nLength - 1; i++)
  2175. {
  2176. if (RecData[i] == 0x03)
  2177. {
  2178. PacketLength = i + 2; //应该+2.才会把最后的checmsum也包含进来。FO1+03+sum.
  2179. char strtemp[100] = { 0 };
  2180. memcpy(strtemp, RecData, i);
  2181. strtemp[i + 1] = 0;
  2182. FINFO("==IN==:{$}\n", strtemp);
  2183. return PACKET_ISPACKET;
  2184. }
  2185. }
  2186. return PACKET_NOPACKET;
  2187. }
  2188. //-----------------------------------------------------------------------------
  2189. // DecodeFrame
  2190. //-----------------------------------------------------------------------------
  2191. static bool DecodeFrame(const char* strFrame, int length)
  2192. {
  2193. auto pr = [strFrame, length](const tFrameMapping& Item)
  2194. {
  2195. for (int i = 0; i < Item.NbOfCharOfHead; i++)
  2196. {
  2197. if (strFrame[i] != Item.strHead[i])
  2198. {
  2199. return false;
  2200. }
  2201. }
  2202. return true;
  2203. };
  2204. auto found = std::find_if(arFrame.begin(), arFrame.end(), pr);
  2205. if (found == arFrame.end())
  2206. {
  2207. return false;
  2208. }
  2209. const auto& Item = *found;
  2210. auto pc = strFrame;
  2211. pc += Item.NbOfCharOfHead;
  2212. Item.fun(pc, length - Item.NbOfCharOfHead);
  2213. return true;
  2214. }
  2215. //-----------------------------------------------------------------------------
  2216. // GetIODriver & CreateIODriver
  2217. //-----------------------------------------------------------------------------
  2218. static nsGEN::REMEDYSTDriver gIODriver;
  2219. extern "C" CCOS::Dev::IODriver * __cdecl GetIODriver() // 返回静态对象的引用, 调用者不能删除 !
  2220. {
  2221. return &gIODriver;
  2222. }
  2223. extern "C" CCOS::Dev::IODriver * __cdecl CreateIODriver() // 返回新对象, 调用者必须自行删除此对象 !
  2224. {
  2225. return new nsGEN::REMEDYSTDriver();
  2226. }