DIOS.Dev.Generator.SimensRF80.cpp 164 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966
  1. // CCOS.Dev.Generator.EMD_EPS45_80.cpp : 定义 DLL 应用程序的导出函数。
  2. //
  3. #include "stdafx.h"
  4. #include <bitset>
  5. #include <assert.h>
  6. #include "Base64.h"
  7. using namespace std::placeholders;
  8. #include "Helper.JSON.hpp"
  9. #include "CCOS.Dev.Generator.SimensRF80.h"
  10. using namespace CCOS::Dev::Detail::Generator;
  11. namespace nsGEN = CCOS::Dev::Detail::Generator;
  12. #pragma warning (disable:4244) // warning C4244: “初始化”: 从“double”转换到“float”,可能丢失数据
  13. #pragma warning (disable:4305) // warning C4305: “参数”: 从“double”到“float”截断
  14. #pragma warning (disable:4267) // warning C4267 : “初始化”: 从“size_t”转换到“int”,可能丢失数据
  15. static const int msTimeOut_Lock = 500;
  16. #define RF80_WaitACKTimer 2000
  17. #define RF80_Flag_COMCtrl 1
  18. Log4CPP::Logger* mLog::gLogger = nullptr;
  19. //指令操作关联结构
  20. nsGEN::tFrameMapItem::tFrameMapItem()
  21. {
  22. m_fFun = NULL;
  23. }
  24. nsGEN::tFrameMapItem::tFrameMapItem(cbFun f)
  25. {
  26. m_fFun = f;
  27. }
  28. nsGEN::tFrameMapItem& nsGEN::tFrameMapItem::operator =(const tFrameMapItem& value)
  29. {
  30. m_fFun = value.m_fFun;
  31. return *this;
  32. }
  33. static map <string, tFrameMapItem> arFrame;
  34. //-----------------------------------------------------------------------------
  35. // 特殊方法
  36. //-----------------------------------------------------------------------------
  37. //以指定分隔符截断字符串
  38. void StrSubstrData(const char* strData, char delimiter, std::vector<string>& array, int endAct = 1)
  39. {
  40. string strtemp = strData;
  41. string strItem = strtemp;
  42. std::size_t oldPos = 0;
  43. std::size_t findPos = strtemp.find(delimiter);
  44. while (findPos != string::npos)
  45. {
  46. strItem = strtemp.substr(oldPos, findPos - oldPos);
  47. if(!strItem.empty())
  48. {
  49. array.push_back(strItem);
  50. }
  51. if (findPos != strtemp.length())
  52. {
  53. oldPos = findPos + 1;
  54. findPos = strtemp.find(delimiter, oldPos);
  55. if (findPos == string::npos)
  56. {
  57. strItem = strtemp.substr(oldPos, strtemp.length() - oldPos);
  58. break;
  59. }
  60. }
  61. else
  62. {
  63. break;
  64. }
  65. }
  66. switch (endAct)
  67. {
  68. case 0:
  69. {}break;
  70. case 1:
  71. {
  72. if (strItem.length() >= 3)
  73. {
  74. strItem.pop_back();
  75. strItem.pop_back();
  76. }
  77. }break;
  78. default:
  79. break;
  80. }
  81. array.push_back(strItem);
  82. }
  83. void InitSendRecvCMDMap()
  84. {
  85. //send
  86. {
  87. //正在将发电机组设置为安全状态.发电机组状态变为SERIAL_ERROR
  88. glo_Send_RF80Fun["ABT"] = stru_EDS_SMG{ "<ABT", "11111" };
  89. //此命令用于获取2点暗盒或DR曝光的参数:Max ms
  90. glo_Send_RF80Fun["DQ2"] = stru_EDS_SMG{ "<DQ2 %.1f", "11111" };
  91. //此命令用于获取3点盒式磁带或DR曝光的参数
  92. glo_Send_RF80Fun["DQ3"] = stru_EDS_SMG{ "<DQ3", "11111" };
  93. //此命令用于检查2点暗盒或DR曝光的参数:UT, Tube Load, Focus
  94. glo_Send_RF80Fun["CP2"] = stru_EDS_SMG{ "<CP2 %.1f %u %c", "00101" };
  95. //此命令用于检查3点盒式磁带或DR曝光的参数:UT, mAs, Focus
  96. glo_Send_RF80Fun["CP3"] = stru_EDS_SMG{ "<CP3 %.1f %.2f %c", "00101" };
  97. //此命令用于检查两点序列的参数:UT, FPS, Xray Time, Focus
  98. glo_Send_RF80Fun["CS2"] = stru_EDS_SMG{ "<CS2 %.1f %.1f %u %c", "00101" };
  99. //此命令用于检查3点序列的参数:UT, FPS, Xray Time, Focus
  100. glo_Send_RF80Fun["CS3"] = stru_EDS_SMG{ "<CS3 %.1f %.1f %u %c", "00101" };
  101. //此命令用于发送0点DR曝光(单个或系列)的参数:Curve, Switch, Focus, Dose, Dominant, Max.time, Fps, Scene Length
  102. glo_Send_RF80Fun["ED0"] = stru_EDS_SMG{ "<ED0 %u %x %c %u %u %u %.1f %u", "00100" };
  103. //此命令用于发送1点DR曝光的参数:WS, UT, Tube load, Current red, Switch, Focus, Dose, Density, Dominant, Max.time
  104. glo_Send_RF80Fun["ED1"] = stru_EDS_SMG{ "<ED1 %u %.1f %u %u %x %c %u %.1f %u %u", "00100" };
  105. //此命令用于发送2点DR曝光的参数(使用kV和mAs进行曝光,无AEC,发生器将计算mA,以获得尽可能短的时间):WS, UT, mAs, Tube Load, Switch, Focus
  106. glo_Send_RF80Fun["ED2"] = stru_EDS_SMG{ "<ED2 %u %.1f %.2f %u %x %c", "00100" };
  107. //此命令用于发送三点曝光的参数:WS, UT, mAs, IT, Switch, Focus
  108. glo_Send_RF80Fun["ED3"] = stru_EDS_SMG{ "<ED3 %u %.1f %.2f %.3f %x %c", "00100" };
  109. //此命令用于发送1点DR曝光系列的参数:WS, UT, Tube load, Current red, Switch, Focus, Dose, Density, Dominant, Max.time, Frame per second
  110. glo_Send_RF80Fun["ES1"] = stru_EDS_SMG{ "<ES1 %u %.1f %u %u %x %c %u %.1f %u %u %.1f", "00100" };
  111. //此命令用于发送2点DR曝光的参数(使用kV和mAs进行曝光,无AEC,发生器将计算mA,以获得尽可能短的时间):WS, UT, mAs, Tube Load, Switch, Focus, Frame per second
  112. glo_Send_RF80Fun["ES2"] = stru_EDS_SMG{ "<ES2 %u %.1f %.2f %u %x %c %.1f", "00100" };
  113. //此命令用于发送三点曝光的参数:WS, UT, mAs, IT, Switch, Focus, Frame per second
  114. glo_Send_RF80Fun["ES3"] = stru_EDS_SMG{ "<ES3 %u %.1f %.2f %.3f %x %c %.1f", "00100" };
  115. //这是发送三点曝光参数的备用命令:WS, UT, mAs, ms, Tube load, Switch, Focus
  116. glo_Send_RF80Fun["EA3"] = stru_EDS_SMG{ "<EA3 %u %.1f %.2f %.0f %u %x %c", "00100" };
  117. //此命令用于发送1点曝光(使用kV和AEC进行曝光)的参数:WS, UT, Tube load, Current red, Switch, Focus, Sensitivity, Dominant, Density
  118. glo_Send_RF80Fun["EP1"] = stru_EDS_SMG{ "<EP1 %u %.1f %u %u %x %c %c %u %.1f", "00100" };
  119. //此命令用于发送2点曝光的参数(使用kV和mAs进行曝光,无AEC,发生器将计算mA,以获得尽可能短的时间):WS, UT, mAs, Tube Load, Switch, Focus
  120. glo_Send_RF80Fun["EP2"] = stru_EDS_SMG{ "<EP2 %u %.1f %.2f %u %x %c", "00100" };
  121. //此命令用于发送三点曝光的参数:WS, UT, mAs, IT, Switch, Focus
  122. glo_Send_RF80Fun["EP3"] = stru_EDS_SMG{ "<EP3 %u %.1f %.2f %.1f %x %c", "00100" };
  123. //HOST命令发电机组从 SERIAL_ERROR 返回至 SERIAL_STANDBY
  124. glo_Send_RF80Fun["ERQ"] = stru_EDS_SMG{ "<ERQ", "00101" };
  125. //生命防护由主机初始化.生命防护不是强制性的:Time out Receive count
  126. glo_Send_RF80Fun["GRD"] = stru_EDS_SMG{ "<GRD %u %u", "11111" };
  127. //此命令请求发生器的状态
  128. glo_Send_RF80Fun["GST"] = stru_EDS_SMG{ "<GST", "11111" };
  129. //从现在起,Generator将使用指定的版本.如果版本未知,Generator将报告并使用实现的最新版本:Version
  130. glo_Send_RF80Fun["IFV"] = stru_EDS_SMG{ "<IFV %u", "11111" };
  131. //此命令请求卡套管载荷计算器的状态
  132. glo_Send_RF80Fun["GHU"] = stru_EDS_SMG{ "<GHU", "11111" };
  133. //该命令用于重置DAP和荧光数据kV、mA、蜂鸣器时间和总时间的实际和汇总数据,以及荧光ABC控制的实际曝光点值:[DAP] [future use]
  134. glo_Send_RF80Fun["RAD"] = stru_EDS_SMG{ "<RAD %u %u", "00100" };
  135. //发生器报告其准备执行曝光,即阻塞条件
  136. glo_Send_RF80Fun["RDY"] = stru_EDS_SMG{ "<RDY", "11111" };
  137. //发电机应设置为未就绪状态.仅适用于Polydoros RFX:Not Ready Condition
  138. glo_Send_RF80Fun["SNRDY"] = stru_EDS_SMG{ "<SNRDY %x", "11111" };
  139. //此命令用于设置房间灯光输出的开/关:D800/D880.X23
  140. glo_Send_RF80Fun["RLC"] = stru_EDS_SMG{ "<RLC %u", "01111" };
  141. //主机请求发送CAN电报:Address Length Data Data
  142. glo_Send_RF80Fun["CS"] = stru_EDS_SMG{ "<CS %x %d %x %x", "01111" };
  143. //主机请求在D801.X4或X5上发送串行电报:string
  144. glo_Send_RF80Fun["KKS"] = stru_EDS_SMG{ "<KKS %s", "01111" };
  145. //主机向发生器发送可能的剂量设定点值,以显示在SCU上.该命令必须在任何探测器曝光参数之前发送:Setpoint 1 Setpoint 2 .. Setpoint n
  146. glo_Send_RF80Fun["DOSP"] = stru_EDS_SMG{ "<DOSP %2.2f %2.2f %2.2f %2.2f", "01111" };
  147. //主机向发生器发送带有DR的1点暴露的剂量校正系数.发生器将ED1命令的设定值与该值相乘.该值应在0.7…1.3的范围内:WS 1 WS 2 WS 3
  148. glo_Send_RF80Fun["DOCF"] = stru_EDS_SMG{ "<DOCF %1.4f %1.4f %1.4f", "01111" };
  149. //主机向SCU发送探测器就绪状态
  150. glo_Send_RF80Fun["RDR"] = stru_EDS_SMG{ "<RDR", "00011" };
  151. //该命令用于通过类似D800/D880上S5的SW电报禁用X射线:on/off
  152. glo_Send_RF80Fun["SSWSS"] = stru_EDS_SMG{ "<SSWSS %u", "01111" };
  153. //此命令用于在平面探测器校准期间禁用X射线生成:on/off
  154. glo_Send_RF80Fun["DECEX"] = stru_EDS_SMG{ "<DECEX %u", "11111" };
  155. //该命令在准备过程中激活D800/D880 X142上的X射线开启指示:on/off
  156. glo_Send_RF80Fun["RIP"] = stru_EDS_SMG{ "<RIP %u", "11111" };
  157. //此命令用于启动曝光循环:Pre contact, Main contact, Mode
  158. glo_Send_RF80Fun["SXP"] = stru_EDS_SMG{ "<SXP %u %u %u", "00110" };
  159. //此命令用于停止和恢复DR系列曝光的调节剂量:Stop
  160. glo_Send_RF80Fun["DRS"] = stru_EDS_SMG{ "<DRS %u", "00010" };
  161. //此命令用于通知ABC控件实际荧光亮度值.此命令对于没有B信号的系统体系结构是必需的.电报和延迟之间的时间应该是恒定的,以实现稳定的亮度控制.超时待澄清:Brightness actual Brightness nominal
  162. glo_Send_RF80Fun["FBA"] = stru_EDS_SMG{ "<FBA %u %u", "00010" };
  163. //此命令用于发送连续荧光(使用荧光曲线的连续荧光)的参数:Curve type Stop Doserate Focus
  164. glo_Send_RF80Fun["FPC"] = stru_EDS_SMG{ "<FPC %u %u %u %c", "00110" };
  165. //此命令用于发送手动透视:UT, IT, Focus
  166. glo_Send_RF80Fun["FPM"] = stru_EDS_SMG{ "<FPM %.1f %.2f %c", "00110" };
  167. //该命令用于发送脉冲透视:Curve type, Stop, UT, IT, X-ray time, max.time, fps, Dose/pulse, Focus
  168. glo_Send_RF80Fun["FPP"] = stru_EDS_SMG{ "<FPP %u %u %.1f %.1f %.1f %u %.1f %u %c", "00110" };
  169. //此命令用于重置荧光蜂鸣器并将计时器设置为0
  170. glo_Send_RF80Fun["RFB"] = stru_EDS_SMG{ "<RFB", "00111" };
  171. //此命令用于启动和停止透视.只有当发电机组能够运行Fluoro时,才接受Fluoro:Start / Stop
  172. glo_Send_RF80Fun["SFL"] = stru_EDS_SMG{ "<SFL %u", "00110" };
  173. //此命令可用于测试串行端口:Count String
  174. glo_Send_RF80Fun["COMTEST"] = stru_EDS_SMG{ "<COMTEST %u %s", "11111" };
  175. }
  176. //recv
  177. {
  178. //DQ2 Format 1:UT Allowed min.mAs Allowed max.mAs-Generator Thermal lim.max.mAs-Large Thermal lim.max.mAs-Small Current lim.mAs-Large Current lim.mAs-Small
  179. glo_Recv_RF80Fun["AD2"] = stru_EDS_SMG{ ">AD2 %.1f %u %u %u %u %u %u", "11111" };
  180. //DQ2 Format 2:Maximal exposure time in sec
  181. glo_Recv_RF80Fun["AD2Timemax"] = stru_EDS_SMG{ ">AD2Timemax %u", "11111" };
  182. //DQ2 Format 3:Minimal exposure time in sec
  183. glo_Recv_RF80Fun["AD2Timemin"] = stru_EDS_SMG{ ">AD2Timemin %u", "11111" };
  184. //DQ2 Format 4:End:指令 DQ2 发送成功, 所有数据发送完毕
  185. glo_Recv_RF80Fun["AD2End"] = stru_EDS_SMG{ ">AD2End", "11111" };
  186. //DQ3 Format 1:index 1st Tube voltage UT index 2nd Tube voltage UT ..
  187. glo_Recv_RF80Fun["AD3kV"] = stru_EDS_SMG{ ">AD3kV %d %.2f %d %.2f %d", "11111" };
  188. //DQ3 Format 2:ms Allowed min mAs
  189. glo_Recv_RF80Fun["AD3ms"] = stru_EDS_SMG{ ">AD3ms %3.2f %d", "11111" };
  190. //DQ3 Format 3:1st Allowed max.mAs-Generator 1st Allowed max.mAs-Large 1st Allowed max.mAs-Small 2nd Allowed max.mAs-Generator …
  191. glo_Recv_RF80Fun["AD3mAs"] = stru_EDS_SMG{ ">AD3mAs %u %u %u %u %u", "11111" };
  192. //DQ3 Format 4:DP3电报的最后一行
  193. glo_Recv_RF80Fun["AD3End"] = stru_EDS_SMG{ ">AD3End", "11111" };
  194. //CP2:Allowed min.mAs Allowed max.mAs
  195. glo_Recv_RF80Fun["AC2"] = stru_EDS_SMG{ ">AC2 %.2f %.2f", "00101" };
  196. //CP3:mAs valid Allowed min.IT Allowed max.IT
  197. glo_Recv_RF80Fun["AC3"] = stru_EDS_SMG{ ">AC3 %u %.1f %.1f", "00101" };
  198. //CS2:Ut FPS Xray Time Focus mAs
  199. glo_Recv_RF80Fun["AS2"] = stru_EDS_SMG{ ">AS2 %.1f %.1f %u %c %.1f", "00101" };
  200. //CP3:Ut FPS Xray Time Focus mA
  201. glo_Recv_RF80Fun["AS3"] = stru_EDS_SMG{ ">AS3 %.1f %.1f %u %c %.1f", "00101" };
  202. //该命令由发电机组发出,用于发送DAP值:Sum Actual
  203. glo_Recv_RF80Fun["DAP"] = stru_EDS_SMG{ ">DAP %.2f %.2f", "00110" };
  204. //在曝光系列期间,发生器单元报告最后一个X射线脉冲的实际曝光数据:UT IT mAs ms End DAP Pulse
  205. glo_Recv_RF80Fun["EPA"] = stru_EDS_SMG{ ">EPA %.1f %.2f %.2f %.1f %x %.2f %u", "00110" };
  206. //发电机组检测到错误,并更改为状态 SERIAL_ERROR ,报告错误原因:Delimiter Num System ErrNum Para Prio Delimiter Num Reaction Prio Delimiter Extended
  207. glo_Recv_RF80Fun["ERR"] = stru_EDS_SMG{ ">ERR IT %04d %02x %02x %04x %1x F80 %d %04x %1x TXT %s %s %s", "01111" };
  208. //发生器报告曝光或荧光的准备状态已完成.状态从 SERIAL_STANDBY 更改为 SERIAL_EXPOSURE
  209. glo_Recv_RF80Fun["EXP"] = stru_EDS_SMG{ ">EXP", "00010" };
  210. //发生器报告用户按下关闭按钮,发生器将关闭.状态变为 SERIAL_SHUTDOWN
  211. glo_Recv_RF80Fun["SDN"] = stru_EDS_SMG{ ">SDN", "01111" };
  212. //生命防护由主机初始化.生命防护不是强制性的:Transmit count
  213. glo_Recv_RF80Fun["GRD"] = stru_EDS_SMG{ ">GRD %u", "11111" };
  214. //此命令请求发生器的状态:State Signals
  215. glo_Recv_RF80Fun["GST"] = stru_EDS_SMG{ ">GST %u %x", "11111" };
  216. //此命令用于告诉发生器单元Host将使用哪个版本的接口命令.如果未发送此命令,发生器将使用最新版本:Version
  217. glo_Recv_RF80Fun["IFV"] = stru_EDS_SMG{ ">IFV %u", "11111" };
  218. //发生器报告初始化状态已完成.状态从 SERIAL_START 更改为 SERIAL_INIT
  219. glo_Recv_RF80Fun["INI"] = stru_EDS_SMG{ ">INI", "01000" };
  220. //在曝光期间,已达到允许的最大mAs值.如果发电机的最大mAs不高于600mA,这可能是600mA,也可能是56kWs除以标称管电压的结果
  221. glo_Recv_RF80Fun["LIM"] = stru_EDS_SMG{ ">LIM", "00010" };
  222. //在曝光期间,已达到允许的最大曝光时间.从1点到3点的所有曝光类型都可能出现限制时间.在信号流中省略了硬件信号
  223. glo_Recv_RF80Fun["LIT"] = stru_EDS_SMG{ ">LIT", "00010" };
  224. //此命令取决于计算器的类型:%HU PT
  225. glo_Recv_RF80Fun["PHU"] = stru_EDS_SMG{ ">PHU %u %u", "00111" };
  226. //发生器报告其准备执行曝光,即阻塞条件:Ready Condition1 Ready Condition2
  227. glo_Recv_RF80Fun["RDY"] = stru_EDS_SMG{ ">RDY %x %x", "11111" };
  228. //发电机通知主机收到CAN电报:Address Length Data Data
  229. glo_Recv_RF80Fun["CR"] = stru_EDS_SMG{ ">CR %x %d %x %x", "01111" };
  230. //此命令用于通知主机曝光释放输入的变化(pre-contact or main-contact).如果满足所有要求,主机可以使用此命令使用“<SXP”触发曝光,或者发送KK-Tomo时间输入的更改:Pre contact Main contact KK
  231. glo_Recv_RF80Fun["RXP"] = stru_EDS_SMG{ ">RXP %u %u %u", "11111" };
  232. //发生器报告其处于备用状态并准备输入,状态从 SERIAL_INIT/SERIAL_EXPOSURE/SERIAL_ERROR 更改为 SERIAL_STANDBY
  233. glo_Recv_RF80Fun["SBY"] = stru_EDS_SMG{ ">SBY", "11111" };
  234. //发生器报告单个储罐温度高于或低于极限的变化
  235. glo_Recv_RF80Fun["TWS"] = stru_EDS_SMG{ ">TWS %x", "00100" };
  236. //发生器收到未知或错误的命令
  237. glo_Recv_RF80Fun["UNK"] = stru_EDS_SMG{ ">UNK", "11111" };
  238. //发生器收到一条校验和错误的消息
  239. glo_Recv_RF80Fun["CRC"] = stru_EDS_SMG{ ">CRC", "11111" };
  240. //此命令用于验证0点DR曝光的接收参数:请参阅ED0命令
  241. glo_Recv_RF80Fun["VD0"] = stru_EDS_SMG{ ">VD0 %u %x %c %u %u %u %.1f %u", "00100" };
  242. //此命令用于验证1点DR曝光的接收参数:请参阅ED1命令
  243. glo_Recv_RF80Fun["VD1"] = stru_EDS_SMG{ ">VD1 %u %.1f %u %u %x %c %u %.1f %u %u", "00100" };
  244. //此命令用于验证2点DR曝光的接收参数:请参阅ED2命令
  245. glo_Recv_RF80Fun["VD2"] = stru_EDS_SMG{ ">VD2 %u %.1f %.2f %u %x %c", "00100" };
  246. //此命令用于验证3点DR曝光的接收参数:请参阅ED3命令
  247. glo_Recv_RF80Fun["VD3"] = stru_EDS_SMG{ ">VD3 %u %.1f %.2f %.3f %x %c", "00100" };
  248. //此命令用于验证3点DR曝光的接收参数:请参阅EA3命令
  249. glo_Recv_RF80Fun["VA3"] = stru_EDS_SMG{ ">VA3 %u %.1f %.2f %.0f %u %x %c", "00100" };
  250. //此命令用于验证1点曝光的接收参数:请参阅EP1命令
  251. glo_Recv_RF80Fun["VP1"] = stru_EDS_SMG{ ">VP1 %u %.1f %u %u %x %c %c %u %.1f", "00100" };
  252. //此命令用于验证2点曝光的接收参数:请参阅EP2命令
  253. glo_Recv_RF80Fun["VP2"] = stru_EDS_SMG{ ">VP2 %u %.1f %.2f %u %x %c", "00100" };
  254. //此命令用于验证3点曝光的接收参数:请参阅EP3命令
  255. glo_Recv_RF80Fun["VP3"] = stru_EDS_SMG{ ">VP3 %u %.1f %.2f %.1f %x %c", "00100" };
  256. //此命令用于验证1点DR曝光的接收参数:请参阅ES1命令
  257. glo_Recv_RF80Fun["VS1"] = stru_EDS_SMG{ ">VS1 %u %.1f %u %u %x %c %u %.1f %u %u %.1f", "00100" };
  258. //此命令用于验证2点DR曝光的接收参数:请参阅ES2命令
  259. glo_Recv_RF80Fun["VS2"] = stru_EDS_SMG{ ">VS2 %u %.1f %.2f %u %x %c %.1f", "00100" };
  260. //此命令用于验证3点DR曝光的接收参数:请参阅ES3命令
  261. glo_Recv_RF80Fun["VS3"] = stru_EDS_SMG{ ">VS3 %u %.1f %.2f %.3f %x %c %.1f", "00100" };
  262. //该命令用于验证收到的剂量调节停止命令<DRS:Stop
  263. glo_Recv_RF80Fun["VRS"] = stru_EDS_SMG{ ">VRS %u", "00010" };
  264. //此命令用于指示荧光蜂鸣器已激活,因为指定的荧光计时器已过期
  265. glo_Recv_RF80Fun["FBS"] = stru_EDS_SMG{ ">FBS %u", "00010" };
  266. //该命令由发生器单元提供,用于指示实际的荧光参数:kV mA Time State Deviation
  267. glo_Recv_RF80Fun["FPA"] = stru_EDS_SMG{ ">FPA %.1f %.2f %.2f %u %d", "00110" };
  268. //该命令由发生器单元给出,用于指示实际的脉冲荧光参数:UT IT x-ray time Tube current time product Timer State Deviation
  269. glo_Recv_RF80Fun["PPA"] = stru_EDS_SMG{ ">PPA %.1f %.1f %.1f %.2f %.2f %u %d", "00110" };
  270. //使用此命令时,系统控制单元可以通知主机曝光释放输入(脚踏开关)的变化.如果满足所有要求,主机可以使用此命令使用“<SFL”触发曝光:Handswitch Footswitch
  271. glo_Recv_RF80Fun["RFL"] = stru_EDS_SMG{ ">RFL %u %u", "00110" };
  272. //此命令用于验证连续荧光的接收参数:参见FPC命令:Curve type Stop Doserate Focus
  273. glo_Recv_RF80Fun["VPC"] = stru_EDS_SMG{ ">VPC %u %u %u %c", "00110" };
  274. //此命令用于验证手动荧光检测的接收参数:参见FPM命令
  275. glo_Recv_RF80Fun["VPM"] = stru_EDS_SMG{ ">VPM %.1f %.2f %c", "00110" };
  276. //该命令用于验证脉冲荧光的接收参数:参见FPP命令
  277. glo_Recv_RF80Fun["VPP"] = stru_EDS_SMG{ ">VPP %u %u %.1f %.1f %.1f %u %.1f %u %c", "00110" };
  278. //此命令可用于测试串行端口:String
  279. glo_Recv_RF80Fun["COMTEST"] = stru_EDS_SMG{ ">COMTEST %s", "11111" };
  280. }
  281. }
  282. //-----------------------------------------------------------------------------
  283. // GenDevice
  284. //-----------------------------------------------------------------------------
  285. vector <float> g_MA_List = { 10, 12.5, 16, 20, 25, 32, 40, 50, 63, 80, 100, 125,160, 200, 250, 320, 400, 500, 630, 800, 1000 };
  286. vector <float> g_MAS_List = { 0.5, 0.63, 0.8, 1, 1.25, 1.6, 2, 2.5, 3.2, 4, 5, 6.3, 8, 10, 12.5, 16, 20, 25, 32, 40, 50, 63, 80, 100, 125, 160, 200, 250, 320, 400, 500, 630,800, 1000 };
  287. vector <float> g_MS_List = { 1,1.25,1.6,2,2.5,3.2,4, 5, 6.3, 8, 10, 12.5, 16, 20, 25, 32, 40,50, 63, 80, 100, 125, 160, 200, 250, 320, 400, 500, 630, 800, 1000,1250, 1600, 2000, 2500, 3200, 4000, 5000 };
  288. nsSerialGPM::CDeliverModule nsGEN::RF80Device::m_tDelivermodule;
  289. nsGEN::RF80Device::RF80Device(std::shared_ptr <IOEventCenter> center, nsSCF::SCF SCF,std::string configPath) : super(center, SCF)
  290. {
  291. assert(EventCenter);
  292. string version;
  293. if (GetVersion(version, hMyModule))
  294. mLog::Info("\n===============log begin : version:{$} ===================\n", version.c_str());
  295. else
  296. mLog::Info("\n===============log begin : version:0.0.0.0 ===================\n");
  297. m_DoseUnit.m_GenSynState.reset(new GENSYNSTATEMould(AttrKey::GENERATOR_RAD_OFF, AttrKey::GENERATOR_SYNC_ERR, AttrKey::GENERATOR_SYNC_MAX, 1));
  298. m_DoseUnit.m_GenState.reset(new GENSTATEMould(0, AttrKey::GENERATOR_STATUS_SHUTDOWN, AttrKey::GENERATOR_STATUS_MAX, 1));
  299. m_DoseUnit.m_WS.reset(new WORKSTATIONMould(1, 0, 5, 1));
  300. m_DoseUnit.m_Handswitch.reset(new GENHANDSWITCHMould(0, 0, 9999, 1));
  301. m_DoseUnit.m_GenTotalExpNumber.reset(new TOTALEXPNUMMould(0, 0, 9999, 1));
  302. m_DoseUnit.m_GenTotalAcqTimes.reset(new TOTALACQTIMESMould(0, 0, 9999, 1));
  303. m_DoseUnit.m_GenTubeCoolWaitTimes.reset(new TUBECOOLTIMEMould(0, 0, 9999, 1));
  304. m_DoseUnit.m_GenTubeOverLoadNumber.reset(new TUBEOVERLOADNUMMould(0, 0, 9999, 1));
  305. m_DoseUnit.m_GenCurrentExpNumber.reset(new CUREXPNUMMould(0, 0, 9999, 1));
  306. m_DoseUnit.m_KV.reset(new KVMould(0.0, 40.0, 150.0, 1.0));
  307. m_DoseUnit.m_MA.reset(new MAMould(0.0, 0.5, 800.0, 0.1));
  308. m_DoseUnit.m_MS.reset(new MSMould(0.0, 1.0, 10000.0, 0.01));
  309. m_DoseUnit.m_MAS.reset(new MASMould(0.0, 0.5, 800.0, 0.01));
  310. m_DoseUnit.m_Techmode.reset(new TECHMODEMould(AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P, AttrKey::TECHMODE_NOAEC_3P, AttrKey::TECHMODE_AEC_MAS_MA, 1));
  311. m_DoseUnit.m_Focus.reset(new FOCUSMould(AttrKey::FOCUS_TYPE::FOCUS_LARGE, AttrKey::FOCUS_SMALL, AttrKey::FOCUS_LARGE, 1));
  312. m_DoseUnit.m_AECField.reset(new AECFIELDMould(0, 0, 111, 1));
  313. m_DoseUnit.m_AECFilm.reset(new AECFILMMould(0, 0, 2, 1));
  314. m_DoseUnit.m_AECDensity.reset(new AECDENSITYMould(0, -4, 4, 1));
  315. m_DoseUnit.m_HE.reset(new TUBEHEATMould(0, 0, 100, 1));
  316. m_DoseUnit.m_PostKV.reset(new POSTKVMould(0.0, 40.0, 150.0, 1.0));
  317. m_DoseUnit.m_PostMA.reset(new POSTMAMould(0.0, 0.5, 800.0, 0.1));
  318. m_DoseUnit.m_PostMS.reset(new POSTMSMould(0.0, 1.0, 10000.0, 0.01));
  319. m_DoseUnit.m_PostMAS.reset(new POSTMASMould(0.0, 0.5, 800.0, 0.01));
  320. m_DoseUnit.m_ExpMode.reset(new EXPMODEMould(AttrKey::EXPMODE_TYPE::Single));
  321. m_DoseUnit.m_FrameRate.reset(new FRAMERATEMould(5, 0, 16, 1));
  322. m_DoseUnit.m_FLKV.reset(new FLUKVMould(0.0, 40.0, 150.0, 1));
  323. m_DoseUnit.m_FLMA.reset(new FLUMAMould(0.0, 0.5, 800.0, 0.1));
  324. m_DoseUnit.m_FLMS.reset(new FLUMSMould(0.0, 1.0, 10000.0, 0.01));
  325. m_DoseUnit.m_FLAccTime.reset(new FLAccTimeMould(0.0, 0.0, 300.0, 1));
  326. m_DoseUnit.m_FLIntTime.reset(new FLUIntTimeMould(0.0, 0.0, 1000.0, 1));
  327. m_DoseUnit.m_PPS.reset(new PPSMould(5.0, 0.0, 60.0, 1));
  328. m_DoseUnit.m_FLMode.reset(new FLUModeMould(AttrKey::GENERATOR_FLUMode::GENERATOR_FLMODE_NOTFLU));
  329. m_DoseUnit.m_ABSStatus.reset(new FLUABSStatusMould(AttrKey::GENERATOR_ABSStatus::GENERATOR_ABS_OFF));
  330. m_DoseUnit.m_MagSize.reset(new FLUMagMould(0, 0, 3, 1));
  331. m_DoseUnit.m_DoseLevel.reset(new FLUDoseLevelMould(AttrKey::GENERATOR_DoseLevel::GENERATOR_DOSE_LOW));
  332. m_DoseUnit.m_Curve.reset(new FLUCurveMould(0, 1, 3, 1));
  333. m_MSGUnit.reset(new nsDetail::MSGUnit(center, GeneratorUnitType));
  334. //串口处理层
  335. m_tDelivermodule.InitSendModle(this, &ProcessClientData, WriteLog);
  336. m_nCMDType_FirstSend = m_tDelivermodule.SetPriority(false, true);
  337. m_nCMDType_WaitTime = m_tDelivermodule.SetPriority(false, false, 0, true, 100);
  338. m_nCMDType_WaitSelf = m_tDelivermodule.SetPriority(false, false, 0, false, 0, true, 2000);
  339. mLog::Info("m_nCMDType_FirstSend[{$}] m_nCMDType_WaitTime[{$}] m_nCMDType_WaitSelf[{$}]",
  340. m_nCMDType_FirstSend,m_nCMDType_WaitTime, m_nCMDType_WaitSelf);
  341. {
  342. map<string, string> cmdHeadmap;
  343. cmdHeadmap["<IFV"] = ">IFV";
  344. cmdHeadmap["<GST"] = ">GST";
  345. cmdHeadmap["<ERQ"] = ">SBY";
  346. cmdHeadmap["<GHU"] = ">PHU";
  347. cmdHeadmap["<ED1"] = ">VD1";
  348. cmdHeadmap["<ES1"] = ">VS1";
  349. cmdHeadmap["<ED2"] = ">VD2";
  350. cmdHeadmap["<ES2"] = ">VS2";
  351. cmdHeadmap["<ED3"] = ">VD3";
  352. cmdHeadmap["<ES3"] = ">VS3";
  353. cmdHeadmap["<RFB"] = ">FBS";
  354. cmdHeadmap["<FPP"] = ">VPP";
  355. cmdHeadmap["<FPC"] = ">VPC";
  356. cmdHeadmap["<FPM"] = ">VPM";
  357. m_tDelivermodule.SetSpeSelfHead(cmdHeadmap);
  358. }
  359. //状态参数初始化
  360. m_GenStatus.changeState(GS_INIT);
  361. m_hRadLimitMASEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  362. m_hRadLimitMAEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  363. m_hExitEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  364. m_hLoopEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
  365. m_hArrayEvent[0] = m_hExitEvent;
  366. m_hArrayEvent[1] = m_hLoopEvent;
  367. //加载配制文件
  368. m_strConfigPath = configPath;
  369. ResDataObject temp;
  370. temp.loadFile(m_strConfigPath.c_str());
  371. m_GenConfig = temp["CONFIGURATION"];
  372. TransJsonText(m_GenConfig);
  373. //公布方法
  374. Register();
  375. InitSendRecvCMDMap();
  376. OnCallBack();
  377. //初始化参数
  378. GetConfData();
  379. GetState();
  380. //Reset();
  381. StartHardwareStatusThread();
  382. }
  383. nsGEN::RF80Device::~RF80Device ()
  384. {
  385. SetEvent(m_hExitEvent);
  386. Sleep(1000);
  387. #if Ccos_V3
  388. if (m_pGenClient)
  389. {
  390. if (!m_pGenClient->IsClosed())
  391. {
  392. m_pGenClient->Close();
  393. }
  394. delete m_pGenClient;
  395. m_pGenClient = NULL;
  396. }
  397. #endif
  398. }
  399. std::string nsGEN::RF80Device::GetGUID() const
  400. {
  401. mLog::Debug("\n===============GetGUID : {$} ===================\n", GeneratorUnitType);
  402. return GeneratorUnitType;
  403. }
  404. void nsGEN::RF80Device::Register()
  405. {
  406. auto Disp = &Dispatch;
  407. superGen::Register (Disp);
  408. superGen::RegisterRAD (Disp);
  409. superGen::RegisterAEC (Disp);
  410. superGen::RegisterExpEnable (Disp);
  411. superGen::RegisterGeneratortoSyncStatus(Disp);
  412. superGen::RegisterFluoro(Disp);
  413. Disp->Get.Push(m_MSGUnit->GetKey().c_str(), [this](std::string& out) { out = m_MSGUnit->JSGet(); return RET_STATUS::RET_SUCCEED; });
  414. auto fun_Clear_DAP = [this](auto a, auto&)
  415. {
  416. return Clear_DAP();
  417. };
  418. Disp->Action.Push("Clear_DAP", fun_Clear_DAP);
  419. auto fun_GetValue_DAP = [this](auto a, auto& b)
  420. {
  421. float value = 0;
  422. RET_STATUS ret = GetValue_DAP(value);
  423. b = ToJSON(value);
  424. return ret;
  425. };
  426. Disp->Action.Push("GetValue_DAP", fun_GetValue_DAP);
  427. }
  428. int nsGEN::RF80Device::GetConfData()
  429. {
  430. //是否由RXP发送SXP
  431. if (m_GenConfig.GetKeyCount("IsSendSXPByRxp") > 0)
  432. {
  433. string value = (string)m_GenConfig["IsSendSXPByRxp"];
  434. if (value.length() == 2 &&
  435. (value.at(0) == '1' || value.at(0) == '0') &&
  436. (value.at(1) == '1' || value.at(1) == '0'))
  437. {
  438. m_bIsSendSXPByRxpFlag = value;
  439. mLog::Debug("cfg IsSendSXPByRxp [{$}]", m_bIsSendSXPByRxpFlag.c_str());
  440. }
  441. else
  442. {
  443. mLog::Warn("cfg IsSendSXPByRxp not right");
  444. }
  445. }
  446. //是否由RXP发送SFL
  447. if (m_GenConfig.GetKeyCount("IsSendSFLByRxp") > 0)
  448. {
  449. string value = (string)m_GenConfig["IsSendSFLByRxp"];
  450. if (value.length() == 1 &&
  451. (value.at(0) == '1' || value.at(0) == '0'))
  452. {
  453. m_bIsSendSFLByRxpFlag = value;
  454. mLog::Debug("cfg IsSendSFLByRxp [{$}]", m_bIsSendSFLByRxpFlag.c_str());
  455. }
  456. else
  457. {
  458. mLog::Warn("cfg IsSendSFLByRxp not right");
  459. }
  460. }
  461. //是否发送RDR
  462. if (m_GenConfig.GetKeyCount("IsSendSCUFPDReady") > 0)
  463. {
  464. m_bIsSendSCUFPDReady = (int)m_GenConfig["IsSendSCUFPDReady"];
  465. mLog::Debug("cfg IsSendSCUFPDReady [{$}]", m_bIsSendSCUFPDReady);
  466. }
  467. //与FullUCB通信
  468. #if Ccos_V3
  469. if (m_GenConfig.GetKeyCount("IsSendToFullUCB") > 0)
  470. {
  471. m_SignalArray = (string)m_GenConfig["IsSendToFullUCB"];
  472. m_pGenClient = new LogicClient("DV3_FullUCB", "","NSQ", false);
  473. if (m_pGenClient->Open("ccosChannel", ALL_ACCESS))
  474. {
  475. mLog::Debug("Ccos_V3 Create DV3_FullUCB Client success");
  476. }
  477. }
  478. #endif
  479. //同步模式
  480. if (m_GenConfig.GetKeyCount("WSTable") > 0)
  481. {
  482. int WSNamber = (int)m_GenConfig["WSTable"];
  483. EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNTable"]);
  484. m_arrWSMap[cfgWorkStationKey("Table", AttrKey::TABLE)] = cfgWorkStationData("Table", WSNamber, WSSYN);
  485. mLog::Debug("cfg Table WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
  486. }
  487. if (m_GenConfig.GetKeyCount("WSWall") > 0)
  488. {
  489. int WSNamber = (int)m_GenConfig["WSWall"];
  490. EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNWall"]);
  491. m_arrWSMap[cfgWorkStationKey("Wall", AttrKey::WALL)] = cfgWorkStationData("Wall", WSNamber, WSSYN);
  492. mLog::Debug("cfg Wall WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
  493. }
  494. if (m_GenConfig.GetKeyCount("WSFree") > 0)
  495. {
  496. int WSNamber = (int)m_GenConfig["WSFree"];
  497. EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNFree"]);
  498. m_arrWSMap[cfgWorkStationKey("Free", AttrKey::MOBILE)] = cfgWorkStationData("Free", WSNamber, WSSYN);
  499. mLog::Debug("cfg Free WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
  500. }
  501. if (m_GenConfig.GetKeyCount("WSTomo") > 0)
  502. {
  503. int WSNamber = (int)m_GenConfig["WSTomo"];
  504. EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNTomo"]);
  505. m_arrWSMap[cfgWorkStationKey("Tomo", AttrKey::TOMO)] = cfgWorkStationData("Tomo", WSNamber, WSSYN);
  506. mLog::Debug("cfg Tomo WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
  507. }
  508. if (m_GenConfig.GetKeyCount("WSConventional") > 0)
  509. {
  510. int WSNamber = (int)m_GenConfig["WSConventional"];
  511. EnSYNMode WSSYN = (EnSYNMode)((int)m_GenConfig["SYNConventional"]);
  512. m_arrWSMap[cfgWorkStationKey("Direct", AttrKey::CONVENTIONAL)] = cfgWorkStationData("Direct", WSNamber, WSSYN);
  513. mLog::Debug("cfg Conventional WS[{$}],SYN[{$}]", WSNamber, (int)WSSYN);
  514. }
  515. //参数默认值
  516. if (m_GenConfig.GetKeyCount("TubeLoad") > 0)
  517. {
  518. m_nCfgTubeLoad = (int)m_GenConfig["TubeLoad"];
  519. mLog::Debug("cfg TubeLoad [{$}]", m_nCfgTubeLoad);
  520. }
  521. if (m_GenConfig.GetKeyCount("CurrentReduction") > 0)
  522. {
  523. m_nCfdCurrentRed = (int)m_GenConfig["CurrentReduction"];
  524. mLog::Debug("cfg CurrentReduction [{$}]", m_nCfdCurrentRed);
  525. }
  526. if (m_GenConfig.GetKeyCount("Switch") > 0)
  527. {
  528. m_nCfdSwitch = (int)m_GenConfig["Switch"];
  529. mLog::Debug("cfg Switch [{$}]", m_nCfdSwitch);
  530. }
  531. if (m_GenConfig.GetKeyCount("AECDose") > 0)
  532. {
  533. m_nCfdDose = (int)m_GenConfig["AECDose"];
  534. mLog::Debug("cfg AECDose [{$}]", m_nCfdDose);
  535. }
  536. if (m_GenConfig.GetKeyCount("AECDRMaxTime") > 0)
  537. {
  538. m_nCfdMaxTime = (int)m_GenConfig["AECDRMaxTime"];
  539. mLog::Debug("cfg AECDRMaxTime [{$}]", m_nCfdMaxTime);
  540. }
  541. if (m_GenConfig.GetKeyCount("DoseRate") > 0)
  542. {
  543. m_nCfdDoseRate = (int)m_GenConfig["DoseRate"];
  544. mLog::Debug("cfg DoseRate [{$}]", m_nCfdDoseRate);
  545. }
  546. if (m_GenConfig.GetKeyCount("PFMS") > 0)
  547. {
  548. m_nCfdPFMS = (int)m_GenConfig["PFMS"];
  549. mLog::Debug("cfg PFMS [{$}]", m_nCfdPFMS);
  550. }
  551. if (m_GenConfig.GetKeyCount("PFMSMax") > 0)
  552. {
  553. m_nCfdPFMSMax = (int)m_GenConfig["PFMSMax"];
  554. mLog::Debug("cfg PFMSMax [{$}]", m_nCfdPFMSMax);
  555. }
  556. //获取参数值合集
  557. m_ResParametersList = m_GenConfig["ParameterList"];
  558. //load FPS ans MAX KW map
  559. m_mapFPSMaxKW.clear();
  560. m_mapFPSMaxKW.insert(std::pair<float, int>(0.5, 8000));
  561. m_mapFPSMaxKW.insert(std::pair<float, int>(1.0, 8000));
  562. m_mapFPSMaxKW.insert(std::pair<float, int>(2.0, 8000));
  563. m_mapFPSMaxKW.insert(std::pair<float, int>(3.0, 8000));
  564. m_mapFPSMaxKW.insert(std::pair<float, int>(4.0, 4000));
  565. m_mapFPSMaxKW.insert(std::pair<float, int>(6.0, 4000));
  566. m_mapFPSMaxKW.insert(std::pair<float, int>(7.5, 4000));
  567. m_mapFPSMaxKW.insert(std::pair<float, int>(15, 2000));
  568. m_mapFPSMaxKW.insert(std::pair<float, int>(30, 2000));
  569. return 0;
  570. }
  571. RET_STATUS nsGEN::RF80Device::SetGenSynState(int value)
  572. {
  573. mLog::Debug("Enter SetGenSynState:[{$}]", value);
  574. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  575. if (value >= AttrKey::GENERATOR_RAD_OFF && value <= AttrKey::GENERATOR_RAD_XRAYOFF)
  576. {
  577. if (m_ExpReady[0] != '1')
  578. {
  579. mLog::Warn("SetGenSynState:not in RAD ready");
  580. return RET_STATUS::RET_SUCCEED;
  581. }
  582. }
  583. else if (value >= AttrKey::GENERATOR_FLU_OFF && value <= AttrKey::GENERATOR_FLU_XRAYOFF)
  584. {
  585. if (m_ExpReady[1] != '1')
  586. {
  587. mLog::Warn("SetGenSynState:not in Flu ready");
  588. return RET_STATUS::RET_SUCCEED;
  589. }
  590. }
  591. switch (value)
  592. {
  593. case AttrKey::GENERATOR_RAD_OFF:
  594. {
  595. sprintf_s(strSendCMD, glo_Send_RF80Fun["SXP"].strParamArry.c_str(),
  596. 0, 0, 0);
  597. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SXP"].struStatus);
  598. }break;
  599. case AttrKey::GENERATOR_RAD_PREPARE:
  600. {
  601. sprintf_s(strSendCMD, glo_Send_RF80Fun["SXP"].strParamArry.c_str(),
  602. m_nSYNMode, 0, m_RadMode);
  603. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SXP"].struStatus);
  604. if (m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::Single ||
  605. m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::TOMO)
  606. {
  607. DetectorReady();
  608. }
  609. }break;
  610. case AttrKey::GENERATOR_RAD_READY:
  611. {
  612. if (m_LastTechMode != RF80Tech_RAD)
  613. {
  614. m_bNeedSendToSynBox = true;
  615. m_LastTechMode = RF80Tech_RAD;
  616. HWSendWaitSelfCMD(m_LastParamArry[RF80Tech_RAD].strParamCMD, strlen(m_LastParamArry[RF80Tech_RAD].strParamCMD), glo_Send_RF80Fun[m_LastParamArry[RF80Tech_RAD].strCMDID].struStatus);
  617. }
  618. }break;
  619. case AttrKey::GENERATOR_RAD_XRAYON:
  620. {
  621. sprintf_s(strSendCMD, glo_Send_RF80Fun["SXP"].strParamArry.c_str(),
  622. m_nSYNMode, m_nSYNMode, m_RadMode);
  623. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SXP"].struStatus);
  624. }break;
  625. case AttrKey::GENERATOR_RAD_XRAYOFF:
  626. {
  627. sprintf_s(strSendCMD, glo_Send_RF80Fun["SXP"].strParamArry.c_str(),
  628. 0, 0, 0);
  629. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SXP"].struStatus);
  630. }break;
  631. case AttrKey::GENERATOR_FLU_OFF:
  632. {
  633. sprintf_s(strSendCMD, glo_Send_RF80Fun["SFL"].strParamArry.c_str(),
  634. 0);
  635. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SFL"].struStatus);
  636. }break;
  637. case AttrKey::GENERATOR_FLU_READY:
  638. {
  639. if (m_LastTechMode != RF80Tech_FLU)
  640. {
  641. m_bNeedSendToSynBox = true;
  642. m_LastTechMode = RF80Tech_FLU;
  643. HWSendWaitSelfCMD(m_LastParamArry[RF80Tech_FLU].strParamCMD, strlen(m_LastParamArry[RF80Tech_FLU].strParamCMD), glo_Send_RF80Fun[m_LastParamArry[RF80Tech_FLU].strCMDID].struStatus);
  644. }
  645. }break;
  646. case AttrKey::GENERATOR_FLU_XRAYON:
  647. {
  648. int fluMode = m_DoseUnit.m_FLMode->Get();
  649. mLog::Debug("SetGenSynState: current FluMode[{$}]", fluMode);
  650. switch (fluMode)
  651. {
  652. case AttrKey::GENERATOR_FLMODE_NOTFLU:
  653. break;
  654. case AttrKey::GENERATOR_FLMODE_CF:
  655. case AttrKey::GENERATOR_FLMODE_HCF:
  656. {
  657. sprintf_s(strSendCMD, glo_Send_RF80Fun["SFL"].strParamArry.c_str(),
  658. m_nSYNMode);
  659. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SFL"].struStatus);
  660. }break;
  661. case AttrKey::GENERATOR_FLMODE_PF:
  662. case AttrKey::GENERATOR_FLMODE_HPF:
  663. {
  664. sprintf_s(strSendCMD, glo_Send_RF80Fun["SFL"].strParamArry.c_str(),
  665. 1);
  666. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SFL"].struStatus);
  667. }break;
  668. break;
  669. case AttrKey::GENERATOR_FLMODE_MAX:
  670. break;
  671. default:
  672. break;
  673. }
  674. }break;
  675. case AttrKey::GENERATOR_FLU_XRAYOFF:
  676. {
  677. sprintf_s(strSendCMD, glo_Send_RF80Fun["SFL"].strParamArry.c_str(),
  678. 0);
  679. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SFL"].struStatus);
  680. }break;
  681. default:
  682. break;
  683. }
  684. return RET_STATUS::RET_SUCCEED;
  685. }
  686. RET_STATUS nsGEN::RF80Device::Reset()
  687. {
  688. mLog::Debug("Enter Reset");
  689. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  690. if (m_DoseUnit.m_FLMode->Get() != AttrKey::GENERATOR_FLMODE_NOTFLU)
  691. {
  692. sprintf(strSendCMD, glo_Send_RF80Fun["RAD"].strParamArry.c_str(), 1, 0);
  693. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["RAD"].struStatus);
  694. memset(strSendCMD, 0x00, GEN_CF80_SEND_LEN_max);
  695. }
  696. if (m_DoseUnit.m_GenState->Get() != nsGEN::AttrKey::GENERATOR_STATUS_ERROR)
  697. {
  698. GetState();
  699. }
  700. else
  701. {
  702. sprintf_s(strSendCMD, glo_Send_RF80Fun["ERQ"].strParamArry.c_str());
  703. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["ERQ"].struStatus);
  704. }
  705. Sleep(1000);
  706. mLog::Debug("End Reset");
  707. return RET_STATUS::RET_SUCCEED;
  708. }
  709. RET_STATUS nsGEN::RF80Device::SetExpMode(std::string value)
  710. {
  711. mLog::Debug("Enter SetExpMode:[{$}]", value.c_str());
  712. if (!value.empty())
  713. {
  714. if (m_DoseUnit.m_ExpMode->Update(value))
  715. {
  716. FireNotify(AttrKey::EXPMODE, m_DoseUnit.m_ExpMode->JSGet());
  717. }
  718. if (m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::TOMO)
  719. {
  720. if (0 == m_DoseUnit.m_KV->Get())
  721. {
  722. SetAPRLocal(m_APRParam.nWS, m_APRParam.nTechmode, m_APRParam.nFocus,
  723. m_APRParam.fKV, m_APRParam.fMA, m_APRParam.fMS, m_APRParam.fMAS,
  724. m_APRParam.nAECField, m_APRParam.nAECFilm, m_APRParam.nAECDensity);
  725. }
  726. else
  727. {
  728. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), m_DoseUnit.m_Focus->Get(),
  729. m_DoseUnit.m_KV->Get(), m_DoseUnit.m_MA->Get(), m_DoseUnit.m_MS->Get(), m_DoseUnit.m_MAS->Get(),
  730. m_DoseUnit.m_AECField->Get(), m_DoseUnit.m_AECFilm->Get(), m_DoseUnit.m_AECDensity->Get());
  731. }
  732. }
  733. else if (m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::Stitch)
  734. {
  735. int aprnum = m_DoseUnit.m_GenCurrentExpNumber->Get();
  736. if (!m_APRarray.empty() && aprnum < m_APRarray.size())
  737. {
  738. SetAPR(m_APRarray[aprnum]);
  739. m_DoseUnit.m_GenCurrentExpNumber->Update(++aprnum);
  740. mLog::Debug("SetAPRArray:[totalEXP:{$}, currentEXP:{$}]", m_APRarray.size(), m_DoseUnit.m_GenCurrentExpNumber->Get());
  741. }
  742. else
  743. {
  744. mLog::Warn("APRarray is empty");
  745. }
  746. }
  747. }
  748. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  749. return RET_STATUS::RET_SUCCEED;
  750. }
  751. RET_STATUS nsGEN::RF80Device::SetFrameRate(FLOAT frameRate)
  752. {
  753. mLog::Debug("Enter SetFrameRate[{$}]", frameRate);
  754. if (m_DoseUnit.m_FrameRate->Update(frameRate))
  755. {
  756. FireNotify(AttrKey::FRAMERATE, m_DoseUnit.m_FrameRate->Get());
  757. }
  758. return RET_STATUS::RET_SUCCEED;
  759. }
  760. RET_STATUS nsGEN::RF80Device::ActiveSyncMode(_tSyncModeArgs value)
  761. {
  762. mLog::Debug("Enter ActiveSyncMode:[SynMode:{$},SynValue:{$},WS:{$}],currentMode[{$}]",
  763. value.strSyncMode.c_str(), value.strSyncValue.c_str(), value.strWS.c_str(), m_DoseUnit.m_ExpMode->JSGet().c_str());
  764. int tempSynNUm = atoi(value.strSyncValue.c_str());
  765. if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_HWS)
  766. {
  767. m_nSYNMode = 1;
  768. }
  769. else if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_CMD)
  770. {
  771. m_nSYNMode = 2;
  772. }
  773. else if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_FRE)
  774. {
  775. m_bIsSendSXPByRxpFlag[1] = '1';
  776. m_nSYNMode = 2;
  777. }
  778. else if (value.strSyncMode == AttrKey::SYNC_TYPE::SYNC_DEMO)
  779. {
  780. m_nSYNMode = tempSynNUm;
  781. }
  782. mLog::Debug("ActiveSyncMode:not support [{$}:{$}] in [{$}]", value.strSyncMode.c_str(), value.strSyncValue.c_str(), m_DoseUnit.m_ExpMode->JSGet().c_str());
  783. return RET_STATUS::RET_SUCCEED;
  784. }
  785. RET_STATUS nsGEN::RF80Device::Clear_DAP()
  786. {
  787. return RET_STATUS::RET_SUCCEED;
  788. }
  789. RET_STATUS nsGEN::RF80Device::GetValue_DAP(float& value)
  790. {
  791. return RET_STATUS::RET_SUCCEED;
  792. }
  793. RET_STATUS nsGEN::RF80Device::QueryHE(int& value)
  794. {
  795. char strSendCMD[GEN_CF80_SEND_LEN_min] = { 0 };
  796. sprintf_s(strSendCMD, glo_Send_RF80Fun["GHU"].strParamArry.c_str());
  797. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["GHU"].struStatus);
  798. return RET_STATUS::RET_SUCCEED;
  799. }
  800. //点片
  801. RET_STATUS nsGEN::RF80Device::IncKV ()
  802. {
  803. mLog::Debug("Enter IncKV");
  804. if (!m_DoseUnit.m_KV->CanInc ()) return RET_STATUS::RET_SUCCEED;
  805. float value = m_DoseUnit.m_KV->Get();
  806. return SetKV(++value);
  807. }
  808. RET_STATUS nsGEN::RF80Device::DecKV ()
  809. {
  810. mLog::Debug("Enter DecKV");
  811. if (!m_DoseUnit.m_KV->CanDec()) return RET_STATUS::RET_SUCCEED;
  812. float value = m_DoseUnit.m_KV->Get();
  813. return SetKV(--value);
  814. }
  815. RET_STATUS nsGEN::RF80Device::SetKV (float value)
  816. {
  817. mLog::Debug("Enter SetKV:[{$}]", value);
  818. if (!m_DoseUnit.m_KV->Verify(value)) return RET_STATUS::RET_SUCCEED;
  819. m_RadLimitFlag = false;
  820. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), m_DoseUnit.m_Focus->Get(),
  821. value, m_DoseUnit.m_MA->Get(), m_DoseUnit.m_MS->Get(), m_DoseUnit.m_MAS->Get(),
  822. m_DoseUnit.m_AECField->Get(), m_DoseUnit.m_AECFilm->Get(), m_DoseUnit.m_AECDensity->Get());
  823. m_RadLimitFlag = true;
  824. return RET_STATUS::RET_SUCCEED;
  825. }
  826. RET_STATUS nsGEN::RF80Device::IncMA ()
  827. {
  828. mLog::Debug("Enter IncMA");
  829. if (!m_DoseUnit.m_MA->CanInc()) return RET_STATUS::RET_SUCCEED;
  830. float value = m_DoseUnit.m_MA->Get();
  831. {
  832. mLog::Debug("IncMA:small curr MA={$}", value);
  833. if (m_DoseUnit.m_MA->CanToNext(value, g_MA_List))
  834. {
  835. SetMA(value);
  836. }
  837. }
  838. return RET_STATUS::RET_SUCCEED;
  839. }
  840. RET_STATUS nsGEN::RF80Device::DecMA ()
  841. {
  842. mLog::Debug("Enter DecMA");
  843. if (!m_DoseUnit.m_MA->CanDec()) return RET_STATUS::RET_SUCCEED;
  844. float value = m_DoseUnit.m_MA->Get();
  845. {
  846. mLog::Debug("DecMA:small curr MA={$}", value);
  847. if (m_DoseUnit.m_MA->CanToPrev(value, g_MA_List))
  848. {
  849. SetMA(value);
  850. }
  851. }
  852. return RET_STATUS::RET_SUCCEED;
  853. }
  854. RET_STATUS nsGEN::RF80Device::SetMA (float value)
  855. {
  856. mLog::Debug("Enter SetMA:[{$}]", value);
  857. if (!m_DoseUnit.m_MA->Verify(value)) return RET_STATUS::RET_SUCCEED;
  858. float tempMAS = value * m_DoseUnit.m_MS->Get() / 1000.0f;
  859. Search3PointRange(m_DoseUnit.m_KV->Get(), tempMAS, m_DoseUnit.m_Focus->Get());
  860. if (WaitForSingleObject(m_hRadLimitMAEvent, 2000) == WAIT_OBJECT_0)
  861. {
  862. mLog::Debug("m_hRadLimitMAEvent = true");
  863. if (m_fCurMinMA < m_fCurMaxMA)
  864. {
  865. if (value < m_fCurMinMA)
  866. {
  867. mLog::Warn("set MA[{$}] too small[{$}]", value, m_fCurMinMA);
  868. value = m_fCurMinMA;
  869. }
  870. if (value > m_fCurMaxMA)
  871. {
  872. mLog::Warn("set MA[{$}] too big[{$}]", value, m_fCurMaxMA);
  873. value = m_fCurMaxMA;
  874. }
  875. }
  876. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), m_DoseUnit.m_Focus->Get(),
  877. m_DoseUnit.m_KV->Get(), value, m_DoseUnit.m_MS->Get(), tempMAS,
  878. m_DoseUnit.m_AECField->Get(), m_DoseUnit.m_AECFilm->Get(), m_DoseUnit.m_AECDensity->Get());
  879. }
  880. else
  881. {
  882. mLog::Warn("m_hRadLimitMAEvent timeout");
  883. }
  884. return RET_STATUS::RET_SUCCEED;
  885. }
  886. RET_STATUS nsGEN::RF80Device::IncMS ()
  887. {
  888. mLog::Debug("Enter IncMS");
  889. if (!m_DoseUnit.m_MS->CanInc()) return RET_STATUS::RET_SUCCEED;
  890. float value = m_DoseUnit.m_MS->Get();
  891. if (m_DoseUnit.m_MS->CanToNext(value, g_MS_List))
  892. {
  893. SetMS(value);
  894. }
  895. return RET_STATUS::RET_SUCCEED;
  896. }
  897. RET_STATUS nsGEN::RF80Device::DecMS ()
  898. {
  899. mLog::Debug("Enter DecMS");
  900. if (!m_DoseUnit.m_MS->CanDec()) return RET_STATUS::RET_SUCCEED;
  901. float value = m_DoseUnit.m_MS->Get();
  902. if (m_DoseUnit.m_MS->CanToPrev(value, g_MS_List))
  903. {
  904. SetMS(value);
  905. }
  906. return RET_STATUS::RET_SUCCEED;
  907. }
  908. RET_STATUS nsGEN::RF80Device::SetMS (float value)
  909. {
  910. mLog::Debug("Enter SetMS:[{$}]", value);
  911. if (!m_DoseUnit.m_MS->Verify(value)) return RET_STATUS::RET_SUCCEED;
  912. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), m_DoseUnit.m_Focus->Get(),
  913. m_DoseUnit.m_KV->Get(), m_DoseUnit.m_MA->Get(), value, m_DoseUnit.m_MAS->Get(),
  914. m_DoseUnit.m_AECField->Get(), m_DoseUnit.m_AECFilm->Get(), m_DoseUnit.m_AECDensity->Get());
  915. return RET_STATUS::RET_SUCCEED;
  916. }
  917. RET_STATUS nsGEN::RF80Device::IncMAS ()
  918. {
  919. mLog::Debug("Enter IncMAS");
  920. if (!m_DoseUnit.m_MAS->CanInc()) return RET_STATUS::RET_SUCCEED;
  921. float value = m_DoseUnit.m_MAS->Get();
  922. if (m_DoseUnit.m_MAS->CanToNext(value, g_MAS_List))
  923. {
  924. SetMAS(++value);
  925. }
  926. return RET_STATUS::RET_SUCCEED;
  927. }
  928. RET_STATUS nsGEN::RF80Device::DecMAS ()
  929. {
  930. mLog::Debug("Enter DecMAS");
  931. if (!m_DoseUnit.m_MAS->CanDec()) return RET_STATUS::RET_SUCCEED;
  932. float value = m_DoseUnit.m_MAS->Get();
  933. if (m_DoseUnit.m_MAS->CanToPrev(value, g_MAS_List))
  934. {
  935. SetMAS(--value);
  936. }
  937. return RET_STATUS::RET_SUCCEED;
  938. }
  939. RET_STATUS nsGEN::RF80Device::SetMAS (float value)
  940. {
  941. mLog::Debug("Enter SetMAS:[{$}]", value);
  942. if (!m_DoseUnit.m_MA->Verify(value)) return RET_STATUS::RET_SUCCEED;
  943. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), m_DoseUnit.m_Focus->Get(),
  944. m_DoseUnit.m_KV->Get(), m_DoseUnit.m_MA->Get(), m_DoseUnit.m_MS->Get(), value,
  945. m_DoseUnit.m_AECField->Get(), m_DoseUnit.m_AECFilm->Get(), m_DoseUnit.m_AECDensity->Get());
  946. return RET_STATUS::RET_SUCCEED;
  947. }
  948. RET_STATUS nsGEN::RF80Device::SetFocus(int value)
  949. {
  950. mLog::Debug("Enter SetFocus:[{$}]", value);
  951. if (!m_DoseUnit.m_Focus->Verify(value)) return RET_STATUS::RET_SUCCEED;
  952. if (m_DoseUnit.m_Focus->Get() != value)
  953. {
  954. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), value,
  955. m_DoseUnit.m_KV->Get(), m_DoseUnit.m_MA->Get(), m_DoseUnit.m_MS->Get(), m_DoseUnit.m_MAS->Get(),
  956. m_DoseUnit.m_AECField->Get(), m_DoseUnit.m_AECFilm->Get(), m_DoseUnit.m_AECDensity->Get());
  957. m_RadLimitFlag = true;
  958. }
  959. return RET_STATUS::RET_SUCCEED;
  960. }
  961. RET_STATUS nsGEN::RF80Device::SetWS(const string value)
  962. {
  963. mLog::Debug("Enter SetWS:[{$}]", value);
  964. int tempws = 1;
  965. string strWS = "";
  966. cfgWorkStationKey trWS = cfgWorkStationKey(value.c_str());
  967. if (m_arrWSMap.find(trWS) != m_arrWSMap.end())
  968. {
  969. m_strCurrentWSName = trWS;
  970. tempws = m_arrWSMap[m_strCurrentWSName].nWSNamber;
  971. strWS = m_arrWSMap[m_strCurrentWSName].strWSNAme;
  972. mLog::Debug("Set WS number [{$}][{$}]", strWS.c_str(), tempws);
  973. }
  974. else
  975. {
  976. mLog::Debug("Set WS number default 1");
  977. m_strCurrentWSName = cfgWorkStationKey(1);
  978. }
  979. m_DoseUnit.m_WS->Update(tempws);
  980. return RET_STATUS::RET_SUCCEED;
  981. }
  982. RET_STATUS nsGEN::RF80Device::SetTechmode (int value)
  983. {
  984. mLog::Debug("Enter SetTechmode:[{$}]", value);
  985. if (!m_DoseUnit.m_Techmode->Verify(value)) return RET_STATUS::RET_SUCCEED;
  986. if (m_DoseUnit.m_Techmode->Update(value))
  987. {
  988. float fKV = m_DoseUnit.m_KV->Get();
  989. float fMA = m_DoseUnit.m_MA->Get();
  990. float fMS = m_DoseUnit.m_MS->Get();
  991. float fMAS = m_DoseUnit.m_MAS->Get();
  992. int nAECDensity = m_DoseUnit.m_AECField->Get();
  993. int nAECFilm = m_DoseUnit.m_AECFilm->Get();
  994. int nAECField = m_DoseUnit.m_AECDensity->Get();
  995. //TechMode
  996. switch (value)
  997. {
  998. case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P:
  999. case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P:
  1000. {
  1001. if (m_APRParam.nAECDensity != 0)
  1002. {
  1003. nAECDensity = m_APRParam.nAECDensity;
  1004. m_APRParam.nAECDensity = 0;
  1005. }
  1006. if (m_APRParam.nAECFilm != 0)
  1007. {
  1008. nAECFilm = m_APRParam.nAECFilm;
  1009. m_APRParam.nAECFilm = 0;
  1010. }
  1011. if (m_APRParam.nAECField != 0)
  1012. {
  1013. nAECField = m_APRParam.nAECField;
  1014. m_APRParam.nAECField = 0;
  1015. }
  1016. }break;
  1017. case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P:
  1018. {
  1019. if (m_APRParam.fMAS != 0)
  1020. {
  1021. fMAS = m_APRParam.fMAS;
  1022. m_APRParam.fMAS = 0;
  1023. }
  1024. }break;
  1025. case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P:
  1026. {
  1027. if (m_APRParam.fMA != 0)
  1028. {
  1029. fMA = m_APRParam.fMA;
  1030. m_APRParam.fMA = 0;
  1031. }
  1032. if (m_APRParam.fMS != 0)
  1033. {
  1034. fMS = m_APRParam.fMS;
  1035. m_APRParam.fMS = 0;
  1036. }
  1037. }break;
  1038. }
  1039. SetAPRLocal(m_DoseUnit.m_WS->Get(), value, m_DoseUnit.m_Focus->Get(),
  1040. fKV, fMA, fMS, fMAS,
  1041. nAECDensity, nAECFilm, nAECField);
  1042. }
  1043. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  1044. return RET_STATUS::RET_SUCCEED;
  1045. }
  1046. RET_STATUS nsGEN::RF80Device::SetAECDensity (int value)
  1047. {
  1048. mLog::Debug("Enter SetAECDensity = {$}", value);
  1049. if (!m_DoseUnit.m_AECDensity->Verify (value)) return RET_STATUS::RET_SUCCEED;
  1050. if (m_DoseUnit.m_AECDensity->Get() != value)
  1051. {
  1052. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), m_DoseUnit.m_Focus->Get(),
  1053. m_DoseUnit.m_KV->Get(), m_DoseUnit.m_MA->Get(), m_DoseUnit.m_MS->Get(), m_DoseUnit.m_MAS->Get(),
  1054. m_DoseUnit.m_AECField->Get(), m_DoseUnit.m_AECFilm->Get(), value);
  1055. }
  1056. return RET_STATUS::RET_SUCCEED;
  1057. }
  1058. RET_STATUS nsGEN::RF80Device::SetAECField (int value)
  1059. {
  1060. mLog::Debug("Enter SetAECField = {$}", value);
  1061. if (!m_DoseUnit.m_AECField->Verify (value)) return RET_STATUS::RET_SUCCEED;
  1062. if (m_DoseUnit.m_AECDensity->Get() != value)
  1063. {
  1064. SetAPRLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_Techmode->Get(), m_DoseUnit.m_Focus->Get(),
  1065. m_DoseUnit.m_KV->Get(), m_DoseUnit.m_MA->Get(), m_DoseUnit.m_MS->Get(), m_DoseUnit.m_MAS->Get(),
  1066. value, m_DoseUnit.m_AECFilm->Get(), m_DoseUnit.m_AECDensity->Get());
  1067. }
  1068. return RET_STATUS::RET_SUCCEED;
  1069. }
  1070. RET_STATUS nsGEN::RF80Device::SetAECFilm (int value)
  1071. {
  1072. mLog::Debug("Enter SetAECFilm = {$}", value);
  1073. if (!m_DoseUnit.m_AECFilm->Verify (value)) return RET_STATUS::RET_SUCCEED;
  1074. if (m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P ||
  1075. m_DoseUnit.m_Techmode->Get() == AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P)
  1076. {
  1077. if (m_DoseUnit.m_AECFilm->Update(value))
  1078. {
  1079. FireNotify(AttrKey::AECFILM, value);
  1080. }
  1081. }
  1082. return RET_STATUS::RET_SUCCEED;
  1083. }
  1084. RET_STATUS nsGEN::RF80Device::SetAPR (const _tAPRArgs& t)
  1085. {
  1086. m_RadLimitFlag = true;
  1087. m_APRParam = t;
  1088. mLog::Debug("SetAPR:KV={$},MA={$},MS={$},MAS={$},Focus={$},Techmode={$},WS={$},AECDensity={$},AECField={$},AECFilm={$}",
  1089. t.fKV, t.fMA, t.fMS, t.fMAS, t.nFocus, t.nTechmode, t.nWS, t.nAECDensity, t.nAECField, t.nAECFilm);
  1090. SetAPRLocal(t.nWS, t.nTechmode, t.nFocus,
  1091. t.fKV, t.fMA, t.fMS, t.fMAS,
  1092. t.nAECField, t.nAECFilm, t.nAECDensity);
  1093. return RET_STATUS::RET_SUCCEED;
  1094. }
  1095. RET_STATUS nsGEN::RF80Device::SetAPRArray(vector<_tAPRArgs>& APRarray)
  1096. {
  1097. mLog::Debug("SetAPRArray:size[{$}]", APRarray.size());
  1098. m_DoseUnit.m_GenCurrentExpNumber->Update(0);
  1099. m_APRarray = APRarray;
  1100. return RET_STATUS::RET_SUCCEED;
  1101. }
  1102. bool nsGEN::RF80Device::SetAPRLocal(int nWS, int nET, int nFO, int nKV, float fMA, float fMS, float fMAS, int nAECFieldSel, int nAECFilmSel, int nAECDensity)
  1103. {
  1104. mLog::Debug("SetAPRLocal: RadLimitFlag[{$}],TechMode[{$}],Focus[{$}],KV[{$}],MA[{$}],MS[{$}],MAS[{$}],AECField[{$}],AECFilm[{$}],AECDensity[{$}],FrameRate[{$}]",
  1105. m_RadLimitFlag,nET, nFO, nKV, fMA, fMS, fMAS, nAECFieldSel, nAECFilmSel, nAECDensity, m_DoseUnit.m_FrameRate->Get());
  1106. //wxx_test
  1107. if(nET == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P)
  1108. nET = AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P;
  1109. if(nET == AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P)
  1110. nET = AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P;
  1111. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  1112. //工作位
  1113. int tempWS = 1;
  1114. if (m_arrWSMap.find(cfgWorkStationKey(nWS)) != m_arrWSMap.end())
  1115. {
  1116. m_strCurrentWSName = cfgWorkStationKey(nWS);
  1117. mLog::Debug("Set WS number {$}", m_arrWSMap[m_strCurrentWSName].nWSNamber);
  1118. tempWS = m_arrWSMap[m_strCurrentWSName].nWSNamber;
  1119. }
  1120. else
  1121. {
  1122. m_strCurrentWSName = cfgWorkStationKey(1);
  1123. mLog::Debug("Set WS number default 1");
  1124. }
  1125. //焦点
  1126. char tempFocus = 'S';
  1127. if (AttrKey::FOCUS_SMALL == nFO)
  1128. {
  1129. tempFocus = 'S';
  1130. }
  1131. else if (AttrKey::FOCUS_LARGE == nFO)
  1132. {
  1133. tempFocus = 'L';
  1134. }
  1135. //KV
  1136. float tempKV = nKV;
  1137. //TechMode
  1138. switch (nET)
  1139. {
  1140. case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P:
  1141. case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P:
  1142. {
  1143. int nfield = TurnAECFieldSel(true, nAECFieldSel);
  1144. if (m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::TOMO)
  1145. {
  1146. float tempPPS = m_DoseUnit.m_FrameRate->Get();
  1147. sprintf_s(strSendCMD, glo_Send_RF80Fun["ES1"].strParamArry.c_str(),
  1148. tempWS, tempKV, m_nCfgTubeLoad, m_nCfdCurrentRed, m_nCfdSwitch, tempFocus, m_nCfdDose, (float)nAECDensity, nfield, m_nCfdMaxTime, tempPPS);
  1149. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["ES1"].struStatus);
  1150. SetLastParambeforeEXP(RF80Tech_RAD,"ES1", strSendCMD);
  1151. }
  1152. else
  1153. {
  1154. sprintf_s(strSendCMD, glo_Send_RF80Fun["ED1"].strParamArry.c_str(),
  1155. tempWS, tempKV, m_nCfgTubeLoad, m_nCfdCurrentRed, m_nCfdSwitch, tempFocus, m_nCfdDose, (float)nAECDensity, nfield, m_nCfdMaxTime);
  1156. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["ED1"].struStatus);
  1157. SetLastParambeforeEXP(RF80Tech_RAD, "ED1", strSendCMD);
  1158. }
  1159. }break;
  1160. case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P:
  1161. {
  1162. float tempMA{ 0 };
  1163. float tempMAS = fMAS;
  1164. if (!CheckRadLimitValue(nET, nFO, tempKV, tempMAS, tempMA))
  1165. {
  1166. if (tempMAS < m_fCurMinMAS)
  1167. {
  1168. mLog::Warn("set MAS[{$}] too small[{$}]", tempMAS, m_fCurMinMAS);
  1169. tempMAS = m_fCurMinMAS;
  1170. }
  1171. if (tempMAS > m_fCurMaxMAS)
  1172. {
  1173. mLog::Warn("set MAS[{$}] too big[{$}]", tempMAS, m_fCurMaxMAS);
  1174. tempMAS = m_fCurMaxMAS;
  1175. }
  1176. }
  1177. if (m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::TOMO)
  1178. {
  1179. float tempPPS = m_DoseUnit.m_FrameRate->Get();
  1180. sprintf_s(strSendCMD, glo_Send_RF80Fun["ES2"].strParamArry.c_str(),
  1181. tempWS, tempKV, tempMAS, m_nCfgTubeLoad, m_nCfdSwitch, tempFocus, tempPPS);
  1182. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["ES2"].struStatus);
  1183. SetLastParambeforeEXP(RF80Tech_RAD,"ES2", strSendCMD);
  1184. }
  1185. else
  1186. {
  1187. sprintf_s(strSendCMD, glo_Send_RF80Fun["ED2"].strParamArry.c_str(),
  1188. tempWS, tempKV, tempMAS, m_nCfgTubeLoad, m_nCfdSwitch, tempFocus);
  1189. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["ED2"].struStatus);
  1190. SetLastParambeforeEXP(RF80Tech_RAD, "ED2", strSendCMD);
  1191. }
  1192. }break;
  1193. case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P:
  1194. {
  1195. float tempMA = fMA;
  1196. float tempMAS = fMA * fMS / 1000.0f;
  1197. if (!CheckRadLimitValue(nET, nFO, tempKV, tempMAS, tempMA))
  1198. {
  1199. if (tempMAS < m_fCurMinMAS)
  1200. {
  1201. mLog::Warn("set MAS[{$}] too small[{$}]", tempMAS, m_fCurMinMAS);
  1202. tempMAS = m_fCurMinMAS;
  1203. }
  1204. if (tempMAS > m_fCurMaxMAS)
  1205. {
  1206. mLog::Warn("set MAS[{$}] too big[{$}]", tempMAS, m_fCurMaxMAS);
  1207. tempMAS = m_fCurMaxMAS;
  1208. }
  1209. if (tempMA < m_fCurMinMA)
  1210. {
  1211. mLog::Warn("set MA[{$}] too small[{$}]", tempMA, m_fCurMinMA);
  1212. tempMA = m_fCurMinMA;
  1213. }
  1214. if (tempMA > m_fCurMaxMA)
  1215. {
  1216. mLog::Warn("set MA[{$}] too big[{$}]", tempMA, m_fCurMaxMA);
  1217. tempMA = m_fCurMaxMA;
  1218. }
  1219. }
  1220. if(m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::TOMO)
  1221. {
  1222. float tempPPS = m_DoseUnit.m_FrameRate->Get();
  1223. sprintf_s(strSendCMD, glo_Send_RF80Fun["ES3"].strParamArry.c_str(),
  1224. tempWS, tempKV, tempMAS, tempMA, m_nCfdSwitch, tempFocus, tempPPS);
  1225. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["ES3"].struStatus);
  1226. SetLastParambeforeEXP(RF80Tech_RAD,"ES3", strSendCMD);
  1227. }
  1228. else
  1229. {
  1230. sprintf_s(strSendCMD, glo_Send_RF80Fun["ED3"].strParamArry.c_str(),
  1231. tempWS, tempKV, tempMAS, tempMA, m_nCfdSwitch, tempFocus);
  1232. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["ED3"].struStatus);
  1233. SetLastParambeforeEXP(RF80Tech_RAD, "ED3", strSendCMD);
  1234. }
  1235. }break;
  1236. }
  1237. if (m_DoseUnit.m_Techmode->Update(nET))
  1238. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  1239. return true;
  1240. }
  1241. //未使用
  1242. RET_STATUS nsGEN::RF80Device::QueryPostKV(float& value)
  1243. {
  1244. return RET_STATUS::RET_SUCCEED;
  1245. }
  1246. RET_STATUS nsGEN::RF80Device::QueryPostMA(float& value)
  1247. {
  1248. return RET_STATUS::RET_SUCCEED;
  1249. }
  1250. RET_STATUS nsGEN::RF80Device::QueryPostMS(float& value)
  1251. {
  1252. return RET_STATUS::RET_SUCCEED;
  1253. }
  1254. RET_STATUS nsGEN::RF80Device::QueryPostMAS(float& value)
  1255. {
  1256. return RET_STATUS::RET_SUCCEED;
  1257. }
  1258. RET_STATUS nsGEN::RF80Device::SetGenState(int value)
  1259. {
  1260. return RET_STATUS::RET_SUCCEED;
  1261. }
  1262. RET_STATUS nsGEN::RF80Device::SetExpEnable()
  1263. {
  1264. return RET_STATUS::RET_SUCCEED;
  1265. }
  1266. RET_STATUS nsGEN::RF80Device::SetExpDisable()
  1267. {
  1268. return RET_STATUS::RET_SUCCEED;
  1269. }
  1270. RET_STATUS nsGEN::RF80Device::SetEXAMMode(std::string value)
  1271. {
  1272. return RET_STATUS::RET_SUCCEED;
  1273. }
  1274. //透视
  1275. RET_STATUS nsGEN::RF80Device::IncFluKV()
  1276. {
  1277. mLog::Debug("Enter IncFluKV");
  1278. if (!m_DoseUnit.m_FLKV->CanInc()) return RET_STATUS::RET_SUCCEED;
  1279. float value = m_DoseUnit.m_FLKV->Get();
  1280. return SetFluKV(++value);
  1281. }
  1282. RET_STATUS nsGEN::RF80Device::DecFluKV()
  1283. {
  1284. mLog::Debug("Enter DecFluKV");
  1285. if (!m_DoseUnit.m_FLKV->CanDec()) return RET_STATUS::RET_SUCCEED;
  1286. float value = m_DoseUnit.m_FLKV->Get();
  1287. return SetFluKV(--value);
  1288. }
  1289. RET_STATUS nsGEN::RF80Device::SetFluKV(float value)
  1290. {
  1291. mLog::Debug("Enter SetFluKV:[{$}]", value);
  1292. if (!m_DoseUnit.m_FLKV->Verify(value)) return RET_STATUS::RET_SUCCEED;
  1293. SetAPFLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_FLMode->Get(), m_DoseUnit.m_ABSStatus->Get(),
  1294. m_DoseUnit.m_DoseLevel->Get(), value, m_DoseUnit.m_FLMA->Get(), m_DoseUnit.m_PPS->Get());
  1295. return RET_STATUS::RET_SUCCEED;
  1296. }
  1297. RET_STATUS nsGEN::RF80Device::IncFluMA()
  1298. {
  1299. mLog::Debug("Enter IncFluKV");
  1300. if (!m_DoseUnit.m_FLMA->CanInc()) return RET_STATUS::RET_SUCCEED;
  1301. float value = m_DoseUnit.m_FLMA->Get();
  1302. SetFluKV(++value);
  1303. return RET_STATUS::RET_SUCCEED;
  1304. }
  1305. RET_STATUS nsGEN::RF80Device::DecFluMA()
  1306. {
  1307. mLog::Debug("Enter DecFluKV");
  1308. if (!m_DoseUnit.m_FLKV->CanDec()) return RET_STATUS::RET_SUCCEED;
  1309. float value = m_DoseUnit.m_FLKV->Get();
  1310. SetFluKV(--value);
  1311. if (!m_DoseUnit.m_FLMA->CanDec()) return RET_STATUS::RET_SUCCEED;
  1312. return RET_STATUS::RET_SUCCEED;
  1313. }
  1314. RET_STATUS nsGEN::RF80Device::SetFluMA(float value)
  1315. {
  1316. mLog::Debug("Enter SetFluMA:[{$}]", value);
  1317. if (!m_DoseUnit.m_FLMA->Verify(value)) return RET_STATUS::RET_SUCCEED;
  1318. SetAPFLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_FLMode->Get(), m_DoseUnit.m_ABSStatus->Get(),
  1319. m_DoseUnit.m_DoseLevel->Get(), m_DoseUnit.m_FLKV->Get(), value, m_DoseUnit.m_PPS->Get());
  1320. return RET_STATUS::RET_SUCCEED;
  1321. }
  1322. RET_STATUS nsGEN::RF80Device::IncFluMS()
  1323. {
  1324. return RET_STATUS::RET_SUCCEED;
  1325. }
  1326. RET_STATUS nsGEN::RF80Device::DecFluMS()
  1327. {
  1328. return RET_STATUS::RET_SUCCEED;
  1329. }
  1330. RET_STATUS nsGEN::RF80Device::SetFluMS(float value)
  1331. {
  1332. return RET_STATUS::RET_SUCCEED;
  1333. }
  1334. RET_STATUS nsGEN::RF80Device::SetPPS(float frameRate)
  1335. {
  1336. mLog::Debug("Enter SetPPS:[{$}]", frameRate);
  1337. if (!m_DoseUnit.m_PPS->Verify(frameRate)) return RET_STATUS::RET_SUCCEED;
  1338. SetAPFLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_FLMode->Get(), m_DoseUnit.m_ABSStatus->Get(),
  1339. m_DoseUnit.m_DoseLevel->Get(), m_DoseUnit.m_FLKV->Get(), m_DoseUnit.m_FLMA->Get(), frameRate);
  1340. return RET_STATUS::RET_SUCCEED;
  1341. }
  1342. RET_STATUS nsGEN::RF80Device::INCPPS()
  1343. {
  1344. mLog::Debug("Enter INCPPS");
  1345. if (!m_DoseUnit.m_PPS->CanInc()) return RET_STATUS::RET_SUCCEED;
  1346. float value = m_DoseUnit.m_PPS->Get();
  1347. SetPPS(++value);
  1348. return RET_STATUS::RET_SUCCEED;
  1349. }
  1350. RET_STATUS nsGEN::RF80Device::DECPPS()
  1351. {
  1352. mLog::Debug("Enter DECPPS");
  1353. if (!m_DoseUnit.m_PPS->CanDec()) return RET_STATUS::RET_SUCCEED;
  1354. float value = m_DoseUnit.m_PPS->Get();
  1355. SetPPS(--value);
  1356. return RET_STATUS::RET_SUCCEED;
  1357. }
  1358. RET_STATUS nsGEN::RF80Device::SetPluseWidth(float fplusewidth)
  1359. {
  1360. return RET_STATUS::RET_SUCCEED;
  1361. }
  1362. RET_STATUS nsGEN::RF80Device::SetABSMode(int nMode)
  1363. {
  1364. mLog::Debug("Enter SetABSMode:[{$}]", nMode);
  1365. if (!m_DoseUnit.m_ABSStatus->Verify(nMode)) return RET_STATUS::RET_SUCCEED;
  1366. SetAPFLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_FLMode->Get(), nMode,
  1367. m_DoseUnit.m_DoseLevel->Get(), m_DoseUnit.m_FLKV->Get(), m_DoseUnit.m_FLMA->Get(), m_DoseUnit.m_PPS->Get());
  1368. return RET_STATUS::RET_SUCCEED;
  1369. }
  1370. RET_STATUS nsGEN::RF80Device::SetABSCurve(int curveNum)
  1371. {
  1372. return RET_STATUS::RET_SUCCEED;
  1373. }
  1374. RET_STATUS nsGEN::RF80Device::IncABSCurve()
  1375. {
  1376. return RET_STATUS::RET_SUCCEED;
  1377. }
  1378. RET_STATUS nsGEN::RF80Device::DecABSCurve()
  1379. {
  1380. return RET_STATUS::RET_SUCCEED;
  1381. }
  1382. RET_STATUS nsGEN::RF80Device::SetABSValue(float fABSValue)
  1383. {
  1384. return RET_STATUS::RET_SUCCEED;
  1385. }
  1386. RET_STATUS nsGEN::RF80Device::SetABSTargetEXI(float fEXIValue)
  1387. {
  1388. return RET_STATUS::RET_SUCCEED;
  1389. }
  1390. float nsGEN::RF80Device::GetFluIntTimer()
  1391. {
  1392. return RET_STATUS::RET_SUCCEED;
  1393. }
  1394. float nsGEN::RF80Device::GetFluAccTimer()
  1395. {
  1396. return RET_STATUS::RET_SUCCEED;
  1397. }
  1398. RET_STATUS nsGEN::RF80Device::ResetFluTimer(int ntype)
  1399. {
  1400. mLog::Debug("ReSetFluAccTimer:[{$}]", ntype);
  1401. char strSendCMD[GEN_CF80_SEND_LEN_min] = { 0 };
  1402. sprintf_s(strSendCMD, glo_Send_RF80Fun["RFB"].strParamArry.c_str());
  1403. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["RFB"].struStatus);
  1404. return RET_STATUS::RET_SUCCEED;
  1405. }
  1406. RET_STATUS nsGEN::RF80Device::SetFluPre(int bPrepare)
  1407. {
  1408. return RET_STATUS::RET_SUCCEED;
  1409. }
  1410. RET_STATUS nsGEN::RF80Device::SetFluEXP(int bPrepare)
  1411. {
  1412. return RET_STATUS::RET_SUCCEED;
  1413. }
  1414. RET_STATUS nsGEN::RF80Device::SetFLFMode(std::string value)
  1415. {
  1416. mLog::Debug("Enter SetFLFMode:[{$}]", value.c_str());
  1417. float fKV = m_DoseUnit.m_FLKV->Get();
  1418. float fMA = m_DoseUnit.m_FLMA->Get();
  1419. int nABS = m_DoseUnit.m_ABSStatus->Get();
  1420. int nDose = m_DoseUnit.m_DoseLevel->Get();
  1421. float fPPS = m_DoseUnit.m_PPS->Get();
  1422. if (0.1 > fKV)
  1423. {
  1424. fKV = m_APFParam.nFLKV;
  1425. }
  1426. if (0.1 > fMA)
  1427. {
  1428. fMA = m_APFParam.fFLMA;
  1429. }
  1430. if (0.1 > fPPS)
  1431. {
  1432. fPPS = m_APFParam.nPPS;
  1433. }
  1434. if (value == "CF")
  1435. {
  1436. SetAPFLocal(m_DoseUnit.m_WS->Get(), AttrKey::GENERATOR_FLMODE_CF, nABS,
  1437. nDose, fKV, fMA, fPPS);
  1438. }
  1439. else if (value == "PF")
  1440. {
  1441. SetAPFLocal(m_DoseUnit.m_WS->Get(), AttrKey::GENERATOR_FLMODE_PF, nABS,
  1442. nDose, fKV, fMA, fPPS);
  1443. }
  1444. else
  1445. {
  1446. mLog::Info("other FluMode {$}", value.c_str());
  1447. return RET_STATUS::RET_SUCCEED;
  1448. }
  1449. return RET_STATUS::RET_SUCCEED;
  1450. }
  1451. RET_STATUS nsGEN::RF80Device::SetFluMAG(int nsize)
  1452. {
  1453. return RET_STATUS::RET_SUCCEED;
  1454. }
  1455. RET_STATUS nsGEN::RF80Device::DisableMAG()
  1456. {
  1457. return RET_STATUS::RET_SUCCEED;
  1458. }
  1459. RET_STATUS nsGEN::RF80Device::SetFluDoseLever(int nlever)
  1460. {
  1461. mLog::Debug("Enter SetFluDoseLever:[{$}]", nlever);
  1462. if (!m_DoseUnit.m_DoseLevel->Verify(nlever)) return RET_STATUS::RET_SUCCEED;
  1463. SetAPFLocal(m_DoseUnit.m_WS->Get(), m_DoseUnit.m_FLMode->Get(), m_DoseUnit.m_ABSStatus->Get(),
  1464. nlever, m_DoseUnit.m_FLKV->Get(), m_DoseUnit.m_FLMA->Get(), m_DoseUnit.m_PPS->Get());
  1465. }
  1466. RET_STATUS nsGEN::RF80Device::SetHalfDose(int nlever)
  1467. {
  1468. return RET_STATUS::RET_SUCCEED;
  1469. }
  1470. RET_STATUS nsGEN::RF80Device::TransferRadCurve(int ncurve)
  1471. {
  1472. return RET_STATUS::RET_SUCCEED;
  1473. }
  1474. RET_STATUS nsGEN::RF80Device::SetAPF(const _tAPFArgs& t)
  1475. {
  1476. mLog::Debug("SetAPF: nWS={$}, Flu mode={$}, ABS mode={$}, DoseLever={$}, nFlkv={$}, FlMA={$}",
  1477. t.nWS, t.nFluMode, t.nABSMode, t.nDoseLever, t.nFLKV, t.fFLMA, t.nPPS);
  1478. m_APFParam = t;
  1479. SetAPFLocal(t.nWS, t.nFluMode, t.nABSMode, t.nDoseLever, t.nFLKV, t.fFLMA, t.nPPS);
  1480. return RET_STATUS::RET_SUCCEED;
  1481. }
  1482. bool nsGEN::RF80Device::SetAPFLocal(int nWS, int nFluType, int nABSMode, int nDoseLevel, int nFKVP, float fFMA, float fPPS)
  1483. {
  1484. mLog::Debug("SetAPFLocal: nWS={$}, Flu mode={$}, ABS mode={$}, DoseLever={$}, FlKV={$}, FlMA={$}, PPS={$}",
  1485. nWS, nFluType, nABSMode, nDoseLevel, nFKVP, fFMA, fPPS);
  1486. switch (nFluType)
  1487. {
  1488. case AttrKey::GENERATOR_FLMODE_NOTFLU:
  1489. break;
  1490. case AttrKey::GENERATOR_FLMODE_CF:
  1491. {
  1492. if (nABSMode == AttrKey::GENERATOR_ABS_OFF)
  1493. {
  1494. SetManualFlourParameter(nFKVP, fFMA);
  1495. }
  1496. else
  1497. {
  1498. if (nDoseLevel == 0)
  1499. nDoseLevel = 1;
  1500. SetContinulFlourParameter(nDoseLevel, 0);
  1501. }
  1502. }break;
  1503. case AttrKey::GENERATOR_FLMODE_PF:
  1504. {
  1505. if (nABSMode == AttrKey::GENERATOR_ABS_OFF)
  1506. {
  1507. nDoseLevel = 0;
  1508. SetPlusFlouroParameter(nDoseLevel, 1, nFKVP, fFMA, fPPS);
  1509. }
  1510. else
  1511. {
  1512. if (nDoseLevel == 0)
  1513. {
  1514. nDoseLevel = 1;
  1515. }
  1516. SetPlusFlouroParameter(nDoseLevel, 0, nFKVP, fFMA, fPPS);
  1517. }
  1518. }break;
  1519. case AttrKey::GENERATOR_FLMODE_HCF:
  1520. break;
  1521. case AttrKey::GENERATOR_FLMODE_HPF:
  1522. break;
  1523. case AttrKey::GENERATOR_FLMODE_MAX:
  1524. break;
  1525. default:
  1526. break;
  1527. }
  1528. return true;
  1529. }
  1530. bool nsGEN::RF80Device::SetPlusFlouroParameter(int curve, int abs, float kv, float ma, float fps)
  1531. {
  1532. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  1533. sprintf_s(strSendCMD, glo_Send_RF80Fun["FPP"].strParamArry.c_str(),
  1534. curve, abs, kv, ma, (float)m_nCfdPFMS, m_nCfdPFMSMax, fps, m_nCfdDoseRate,'S');
  1535. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["FPP"].struStatus);
  1536. SetLastParambeforeEXP(RF80Tech_FLU,"FPP",strSendCMD);
  1537. return true;
  1538. }
  1539. bool nsGEN::RF80Device::SetContinulFlourParameter(int curve, int abs)
  1540. {
  1541. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  1542. sprintf_s(strSendCMD, glo_Send_RF80Fun["FPC"].strParamArry.c_str(),
  1543. curve, abs, m_nCfdDoseRate, 'S');
  1544. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["FPC"].struStatus);
  1545. SetLastParambeforeEXP(RF80Tech_FLU,"FPC", strSendCMD);
  1546. return true;
  1547. }
  1548. bool nsGEN::RF80Device::SetManualFlourParameter(int kv, float ma)
  1549. {
  1550. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  1551. sprintf_s(strSendCMD, glo_Send_RF80Fun["FPM"].strParamArry.c_str(),
  1552. (float)kv, ma, 'S');
  1553. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["FPM"].struStatus);
  1554. SetLastParambeforeEXP(RF80Tech_FLU, "FPM", strSendCMD);
  1555. return true;
  1556. }
  1557. //V3新方法
  1558. void nsGEN::RF80Device::SubscribeSelf(ccos_mqtt_connection* conn)
  1559. {
  1560. //订阅GEN所有Action
  1561. //SubscribeTopic(conn, "CCOS/DEVICE/Generator/Action/#"); Moduld层默认订阅了这个Action,如果这边也订阅的话就会执行两遍Action,可能会出问题
  1562. }
  1563. //消息上报
  1564. RET_STATUS nsGEN::RF80Device::ProcessMsg(char* strCMD, int nCMDLengh, stru_EDS_Status& state)
  1565. {
  1566. if (!state.compare(m_GenStatus))
  1567. {
  1568. mLog::Debug("==OUT failed==: [{$}][{$}], current[{$}]state not in[{$}] \n", strCMD, nCMDLengh, m_GenStatus.status, state.status);
  1569. return RET_STATUS::RET_SUCCEED;
  1570. }
  1571. if (FormatCMD(strCMD, nCMDLengh))
  1572. {
  1573. string strLog(strCMD);
  1574. strLog.at(strLog.length() - 1) = 0x03;
  1575. strLog.at(strLog.length() - 2) = 0x04;
  1576. mLog::Debug("==OUT==: [{$}],lengh[{$}] \n", strLog.c_str(), nCMDLengh);
  1577. int ret = 0;
  1578. int nTimeOut = 100;
  1579. m_SCF.Lock(msTimeOut_Lock)
  1580. .SendPacket(strCMD, nCMDLengh, nTimeOut, ret);
  1581. }
  1582. return RET_STATUS::RET_SUCCEED;
  1583. }
  1584. RET_STATUS nsGEN::RF80Device::HWSend(char* strCMD, int nCMDLengh)
  1585. {
  1586. if (FormatCMD(strCMD, nCMDLengh))
  1587. {
  1588. string strLog(strCMD);
  1589. strLog.at(strLog.length() - 1) = 0x03;
  1590. strLog.at(strLog.length() - 2) = 0x04;
  1591. mLog::Debug("==OUT==: [{$}],lengh[{$}] \n", strLog.c_str(), nCMDLengh);
  1592. int ret = 0;
  1593. int nTimeOut = 100;
  1594. m_SCF.Lock(msTimeOut_Lock)
  1595. .SendPacket(strCMD, nCMDLengh, nTimeOut, ret);
  1596. }
  1597. return RET_STATUS::RET_SUCCEED;
  1598. }
  1599. void nsGEN::RF80Device::FireNotify(string key, const int context)
  1600. {
  1601. char szInfo[64] = { 0 };
  1602. sprintf_s(szInfo, "%d", context);
  1603. std::string str = szInfo;
  1604. EventCenter->OnNotify(1, key, str);//(int)ATTRACTION_SET 2
  1605. }
  1606. void nsGEN::RF80Device::FireNotify(std::string key, const float context)
  1607. {
  1608. char szInfo[64] = { 0 };
  1609. sprintf_s(szInfo, "%.2f", context);
  1610. std::string str = szInfo;
  1611. EventCenter->OnNotify(1, key, str);//(int)ATTRACTION_SET 2
  1612. }
  1613. void nsGEN::RF80Device::FireNotify(std::string key, const std::string context)
  1614. {
  1615. EventCenter->OnNotify(1, key, context);
  1616. }
  1617. void nsGEN::RF80Device::FireErrorMessage(const bool Act, const int Code, const char* ResInfo)
  1618. {
  1619. string ErrorCode("RF80_ERR_");
  1620. int level = RF80_REGULATION_LEVEL::REG_ERRO;
  1621. if (Code != 0)
  1622. {
  1623. ErrorCode += std::to_string(Code);
  1624. }
  1625. else
  1626. {
  1627. ErrorCode = "";
  1628. }
  1629. if (Act)
  1630. {
  1631. mLog::Error("add [{$}:{$}]", ErrorCode.c_str(), ResInfo);
  1632. m_MSGUnit->AddErrorMessage(ErrorCode.c_str(), level, ResInfo);
  1633. }
  1634. else
  1635. {
  1636. mLog::Error("del [{$}:{$}]", ErrorCode.c_str(), ResInfo);
  1637. if (Code == 0)
  1638. m_MSGUnit->DelErrorMessage("0", level, ResInfo);
  1639. else
  1640. m_MSGUnit->DelErrorMessage(ErrorCode.c_str(), level, ResInfo);
  1641. }
  1642. }
  1643. void nsGEN::RF80Device::FireWarnMessage(const bool Act, const int Code, const char* ResInfo)
  1644. {
  1645. string ErrorCode("PSGMG_WAR_");
  1646. int level = RF80_REGULATION_LEVEL::REG_WARN;
  1647. if (Code != 0)
  1648. {
  1649. ErrorCode += std::to_string(Code);
  1650. }
  1651. else
  1652. {
  1653. ErrorCode = "";
  1654. }
  1655. if (Act)
  1656. {
  1657. mLog::Error("add {$}:{$}", ErrorCode.c_str(), ResInfo);
  1658. m_MSGUnit->AddWarnMessage(ErrorCode.c_str(), level, ResInfo);
  1659. }
  1660. else
  1661. {
  1662. mLog::Error("del {$}:{$}", ErrorCode.c_str(), ResInfo);
  1663. m_MSGUnit->DelWarnMessage(ErrorCode.c_str(), level, ResInfo);
  1664. }
  1665. }
  1666. //-----------------------------------------------------------------------------
  1667. // ProcessCmd
  1668. //-----------------------------------------------------------------------------
  1669. void nsGEN::RF80Device::ProcessClientData(const char* pData, unsigned long nDataLength, void* lparam)
  1670. {
  1671. RF80Device* pCurGen = (RF80Device*)lparam;
  1672. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  1673. memcpy(strSendCMD, pData, nDataLength);
  1674. pCurGen->HWSend(strSendCMD, nDataLength);
  1675. }
  1676. void nsGEN::RF80Device::WriteLog(const char* pData, nsSerialGPM::LOG_V2_LEVEL level)
  1677. {
  1678. switch (level)
  1679. {
  1680. case nsSerialGPM::LOG_V2_FATAL:
  1681. case nsSerialGPM::LOG_V2_ERROR:
  1682. mLog::Error(pData);
  1683. break;
  1684. case nsSerialGPM::LOG_V2_WARNING:
  1685. mLog::Warn(pData);
  1686. break;
  1687. case nsSerialGPM::LOG_V2_DEBUG:
  1688. mLog::Debug(pData);
  1689. break;
  1690. case nsSerialGPM::LOG_V2_INFO:
  1691. mLog::Info(pData);
  1692. break;
  1693. default:
  1694. break;
  1695. }
  1696. }
  1697. RET_STATUS nsGEN::RF80Device::HWSendFirst(char* strCommand, int lengh, stru_EDS_Status& state, int headLengh)
  1698. {
  1699. if (!state.compare(m_GenStatus))
  1700. {
  1701. mLog::Debug("==OUT failed==: [{$}][{$}], current[{$}]state not in[{$}] \n", strCommand, lengh, m_GenStatus.status, state.status);
  1702. return RET_STATUS::RET_SUCCEED;
  1703. }
  1704. return m_tDelivermodule.ProcessCommand(strCommand, lengh, m_nCMDType_FirstSend, headLengh);
  1705. }
  1706. RET_STATUS nsGEN::RF80Device::HWSendWaittimeCMD(char* strCommand, int lengh, stru_EDS_Status& state, int headLengh)
  1707. {
  1708. if (!state.compare(m_GenStatus))
  1709. {
  1710. mLog::Debug("==OUT failed==: [{$}][{$}], current[{$}]state not in[{$}] \n", strCommand, lengh, m_GenStatus.status, state.status);
  1711. return RET_STATUS::RET_SUCCEED;
  1712. }
  1713. return m_tDelivermodule.ProcessCommand(strCommand, lengh, m_nCMDType_WaitTime, headLengh);
  1714. }
  1715. RET_STATUS nsGEN::RF80Device::HWSendWaitSelfCMD(char* strCommand, int lengh, stru_EDS_Status& state, int headLengh)
  1716. {
  1717. if (!state.compare(m_GenStatus))
  1718. {
  1719. mLog::Debug("==OUT failed==: [{$}][{$}], current[{$}]state not in[{$}] \n", strCommand, lengh, m_GenStatus.status, state.status);
  1720. return RET_STATUS::RET_SUCCEED;
  1721. }
  1722. return m_tDelivermodule.ProcessCommand(strCommand, lengh, m_nCMDType_WaitSelf, headLengh);
  1723. }
  1724. //OnCallBack
  1725. bool nsGEN::RF80Device::OnCallBack()
  1726. {
  1727. //无 操作
  1728. auto HWNotProcess = [](const char* value, int length) -> void
  1729. {
  1730. mLog::Debug("This commands[{$}] didn't need to process", value);
  1731. };
  1732. //DQ2 Format 1:UT Allowed min.mAs Allowed max.mAs-Generator Thermal lim.max.mAs-Large Thermal lim.max.mAs-Small Current lim.mAs-Large Current lim.mAs-Small
  1733. auto HW_AD2 = [this](vector <string>& paramList) -> void
  1734. {
  1735. if (paramList.size() >= 8)
  1736. {
  1737. //%.1f %u %u %u %u %u %u
  1738. mLog::Debug("HW_AD2: UT[{$}], Allowed min.mAs[{$}], Allowed max.mAs-Generator[{$}], Thermal lim.max.mAs-Large[{$}], Thermal lim.max.mAs-Small[{$}], Current lim.mAs-Large[{$}], Current lim.mAs-Small[{$}]",
  1739. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  1740. paramList[6].c_str(), paramList[7].c_str());
  1741. m_fCurMinMAS = atof(paramList[1].c_str());
  1742. m_fCurMaxMAS = atof(paramList[2].c_str());
  1743. }
  1744. else
  1745. {
  1746. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1747. }
  1748. };
  1749. //DQ2 Format 2:Maximal exposure time in sec
  1750. auto HW_AD2Timemax = [this](vector <string>& paramList) -> void
  1751. {
  1752. if (paramList.size() >= 2)
  1753. {
  1754. //%u
  1755. mLog::Debug("HW_AD2Timemax: Maximal exposure time in sec[{$}]",
  1756. paramList[1].c_str());
  1757. m_fCurMinMS = atof(paramList[1].c_str());
  1758. }
  1759. else
  1760. {
  1761. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1762. }
  1763. };
  1764. //DQ2 Format 3:Minimal exposure time in sec
  1765. auto HW_AD2Timemin = [this](vector <string>& paramList) -> void
  1766. {
  1767. if (paramList.size() >= 2)
  1768. {
  1769. //%u
  1770. mLog::Debug("HW_AD2Timemin: Minimal exposure time in sec[{$}]",
  1771. paramList[1].c_str());
  1772. m_fCurMaxMS = atof(paramList[1].c_str());
  1773. }
  1774. else
  1775. {
  1776. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1777. }
  1778. };
  1779. //DQ2 Format 4:End:指令 DQ2 发送成功, 所有数据发送完毕
  1780. auto HW_AD2End = [this](vector <string>& paramList) -> void
  1781. {
  1782. mLog::Debug("HW_AD2End: AD2End");
  1783. };
  1784. //DQ3 Format 1:index 1st Tube voltage UT index 2nd Tube voltage UT ..
  1785. auto HW_AD3kV = [this](vector <string>& paramList) -> void
  1786. {
  1787. if (paramList.size() >= 5)
  1788. {
  1789. //%d %.2f %d %.2f %d
  1790. mLog::Debug("HW_AD3kV: index[{$}], 1st Tube voltage UT[{$}], index[{$}], 2nd Tube voltage UT[{$}]",
  1791. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str());
  1792. }
  1793. else
  1794. {
  1795. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1796. }
  1797. };
  1798. //DQ3 Format 2:ms Allowed min mAs
  1799. auto HW_AD3ms = [this](vector <string>& paramList) -> void
  1800. {
  1801. if (paramList.size() >= 3)
  1802. {
  1803. //%3.2f %d
  1804. mLog::Debug("HW_AD3ms: ms[{$}], Allowed min mAs[{$}]",
  1805. paramList[1].c_str(), paramList[2].c_str());
  1806. m_fCurMinMAS = atof(paramList[1].c_str());
  1807. }
  1808. else
  1809. {
  1810. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1811. }
  1812. };
  1813. //DQ3 Format 3:1st Allowed max.mAs-Generator 1st Allowed max.mAs-Large 1st Allowed max.mAs-Small 2nd Allowed max.mAs-Generator …
  1814. auto HW_AD3mAs = [this](vector <string>& paramList) -> void
  1815. {
  1816. if (paramList.size() >= 6)
  1817. {
  1818. //%u %u %u %u %u
  1819. mLog::Debug("HW_AD3mAs: 1st Allowed max.mAs-Generator[{$}], 1st Allowed max.mAs-Large[{$}], 1st Allowed max.mAs-Small[{$}], 2nd Allowed max.mAs-Generator[{$}]",
  1820. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str());
  1821. m_fCurMaxMAS = atof(paramList[1].c_str());
  1822. }
  1823. else
  1824. {
  1825. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1826. }
  1827. };
  1828. //DQ3 Format 4:DP3电报的最后一行
  1829. auto HW_AD3End = [this](vector <string>& paramList) -> void
  1830. {
  1831. mLog::Debug("HW_AD3End: AD3End");
  1832. };
  1833. //CP2:Allowed min.mAs Allowed max.mAs
  1834. auto HW_AC2 = [this](vector <string>& paramList) -> void
  1835. {
  1836. if (paramList.size() >= 3)
  1837. {
  1838. //%.2f %.2f
  1839. mLog::Debug("HW_AC2: Allowed min.mAs[{$}], Allowed max.mAs[{$}]",
  1840. paramList[1].c_str(), paramList[2].c_str());
  1841. m_fCurMinMAS = atof(paramList[1].c_str());
  1842. m_fCurMaxMAS = atof(paramList[2].c_str());
  1843. SetEvent(m_hRadLimitMASEvent);
  1844. }
  1845. else
  1846. {
  1847. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1848. }
  1849. };
  1850. //CP3:mAs valid Allowed min.IT Allowed max.IT
  1851. auto HW_AC3 = [this](vector <string>& paramList) -> void
  1852. {
  1853. if (paramList.size() >= 4)
  1854. {
  1855. //%u %.1f %.1f
  1856. mLog::Debug("HW_AC3: mAs valid[{$}], Allowed min.IT[{$}], Allowed max.IT[{$}]",
  1857. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str());
  1858. if ("0" == paramList[1].c_str())
  1859. {
  1860. mLog::Warn("HW_AC3: valid range should be checked in advance using <CP2");
  1861. }
  1862. else
  1863. {
  1864. mLog::Debug("HW_AC3: allowed tube currents are valid");
  1865. }
  1866. m_fCurMinMA = atof(paramList[2].c_str());
  1867. m_fCurMaxMA = atof(paramList[3].c_str());
  1868. SetEvent(m_hRadLimitMAEvent);
  1869. }
  1870. else
  1871. {
  1872. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1873. }
  1874. };
  1875. //CS2:Ut FPS Xray Time Focus mAs
  1876. auto HW_AS2 = [this](vector <string>& paramList) -> void
  1877. {
  1878. if (paramList.size() >= 6)
  1879. {
  1880. //%.1f %.1f %u %c %.1f
  1881. mLog::Debug("HW_AS2: Ut[{$}], FPS[{$}], Xray Time[{$}], Focus[{$}], mAs[{$}]",
  1882. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str());
  1883. m_fCurMaxMAS = atof(paramList[5].c_str());
  1884. }
  1885. else
  1886. {
  1887. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1888. }
  1889. };
  1890. //CP3:Ut FPS Xray Time Focus mA
  1891. auto HW_AS3 = [this](vector <string>& paramList) -> void
  1892. {
  1893. if (paramList.size() >= 6)
  1894. {
  1895. //%.1f %.1f %u %c %.1f mA
  1896. mLog::Debug("HW_AS3: Ut[{$}], FPS[{$}], Xray Time[{$}], Focus[{$}], mA[{$}]",
  1897. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str());
  1898. m_fCurMaxMA = atof(paramList[5].c_str());
  1899. }
  1900. else
  1901. {
  1902. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1903. }
  1904. };
  1905. //该命令由发电机组发出,用于发送DAP值:Sum Actual
  1906. auto HW_DAP = [this](vector <string>& paramList) -> void
  1907. {
  1908. if (paramList.size() >= 3)
  1909. {
  1910. //%.2f %.2f
  1911. mLog::Debug("HW_DAP: Sum[{$}], Actual[{$}]",
  1912. paramList[1].c_str(), paramList[2].c_str());
  1913. float DAPvalue = atof(paramList[2].c_str());
  1914. FireNotify("DAP", DAPvalue);
  1915. }
  1916. else
  1917. {
  1918. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1919. }
  1920. };
  1921. //在曝光系列期间,发生器单元报告最后一个X射线脉冲的实际曝光数据:UT IT mAs ms End DAP Pulse
  1922. auto HW_EPA = [this](vector <string>& paramList) -> void
  1923. {
  1924. if (paramList.size() >= 8)
  1925. {
  1926. //%.1f %.2f %.2f %.1f %x %.2f %u
  1927. mLog::Debug("HW_EPA: UT[{$}], IT[{$}], mAs[{$}], ms[{$}], End[{$}], DAP[{$}], Pulse[{$}]",
  1928. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  1929. paramList[6].c_str(), paramList[7].c_str());
  1930. if (m_DoseUnit.m_GenSynState->Get() == AttrKey::GENERATOR_RAD_READY)
  1931. {
  1932. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYON))
  1933. {
  1934. mLog::Debug("EXPSTATE: [{$}] -> XR1", m_DoseUnit.m_GenSynState->Get());
  1935. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1936. }
  1937. }
  1938. else if(m_DoseUnit.m_GenSynState->Get() != AttrKey::GENERATOR_RAD_XRAYON)
  1939. {
  1940. mLog::Warn("EXPSTATE: [{$}] not in ready", m_DoseUnit.m_GenSynState->Get());
  1941. }
  1942. m_DoseUnit.m_PostKV->Update(atof(paramList[1].c_str()));
  1943. FireNotify(m_DoseUnit.m_PostKV->GetKey(), m_DoseUnit.m_PostKV->Get());
  1944. m_DoseUnit.m_PostMA->Update(atof(paramList[2].c_str()));
  1945. FireNotify(m_DoseUnit.m_PostMA->GetKey(), m_DoseUnit.m_PostMA->Get());
  1946. m_DoseUnit.m_PostMS->Update(atof(paramList[4].c_str()));
  1947. FireNotify(m_DoseUnit.m_PostMS->GetKey(), m_DoseUnit.m_PostMS->Get());
  1948. m_DoseUnit.m_PostMAS->Update(atof(paramList[3].c_str()));
  1949. FireNotify(m_DoseUnit.m_PostMAS->GetKey(), m_DoseUnit.m_PostMAS->Get());
  1950. float DAPvalue = atof(paramList[6].c_str());
  1951. FireNotify("DAP", DAPvalue);
  1952. }
  1953. else
  1954. {
  1955. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1956. }
  1957. };
  1958. //发电机组检测到错误,并更改为状态 SERIAL_ERROR ,报告错误原因:Delimiter Num System ErrNum Para Prio Delimiter Num Reaction Prio Delimiter Extended
  1959. auto HW_ERR = [this](vector <string>& paramList) -> void
  1960. {
  1961. if (paramList.size() >= 15)
  1962. {
  1963. //IT %04d %02x %02x %04x %1x F80 %d %04x %1x TXT %s %s %s
  1964. mLog::Debug("HW_ERR: Delimiter[{$}], Num[{$}], System[{$}], ErrNum[{$}], Para[{$}], Prio[{$}], Delimiter[{$}], Num[{$}], Reaction[{$}], Prio[{$}], Delimiter[{$}], Extended[{$}]",
  1965. paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(), paramList[6].c_str(),
  1966. paramList[8].c_str(), paramList[9].c_str(), paramList[10].c_str(), paramList[12].c_str(), paramList[13].c_str(),
  1967. paramList[14].c_str());
  1968. mLog::Debug("GENSTATE: {$} -> SERIAL_ERROR", m_GenStatus.GetState());
  1969. m_GenStatus.changeState(GS_ERROR);
  1970. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_ERROR))
  1971. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  1972. int ErrorCode = atoi(paramList[2].c_str());
  1973. string info = "Generator has error,please reset it";
  1974. FireErrorMessage(true, ErrorCode, info.c_str());
  1975. }
  1976. else
  1977. {
  1978. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  1979. }
  1980. };
  1981. //发生器报告曝光或荧光的准备状态已完成.状态从 SERIAL_STANDBY 更改为 SERIAL_EXPOSURE
  1982. auto HW_EXP = [this](vector <string>& paramList) -> void
  1983. {//实际在">EXP"之后才是真正的Ready
  1984. if (paramList.size() >= 1)
  1985. {
  1986. m_XrayReady[1] = '1';
  1987. mLog::Debug("current XrayReady: [{$}]", m_XrayReady.c_str());
  1988. if (m_XrayReady == "11")
  1989. {
  1990. m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_READY);
  1991. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  1992. }
  1993. else
  1994. {
  1995. mLog::Warn("GENEXPSTATE: {$} not in EXP_Ready", m_DoseUnit.m_GenSynState->Get());
  1996. }
  1997. mLog::Debug("EXPSTATE: [{$}] -> PR2", m_DoseUnit.m_GenSynState->Get());
  1998. mLog::Debug("GENSTATE: {$} -> SERIAL_EXPOSURE", m_GenStatus.GetState());
  1999. m_GenStatus.changeState(GS_EXPOSURE);
  2000. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_EXP))
  2001. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  2002. }
  2003. else
  2004. {
  2005. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2006. }
  2007. };
  2008. //发生器报告用户按下关闭按钮,发生器将关闭.状态变为 SERIAL_SHUTDOWN
  2009. auto HW_SDN = [this](vector <string>& paramList) -> void
  2010. {
  2011. if (paramList.size() >= 1)
  2012. {
  2013. mLog::Debug("GENSTATE: {$} -> SERIAL_SHUTDOWN", m_GenStatus.GetState());
  2014. m_GenStatus.changeState(GS_SHUTDOWN);
  2015. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_SHUTDOWN))
  2016. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  2017. }
  2018. else
  2019. {
  2020. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2021. }
  2022. };
  2023. //生命防护由主机初始化.生命防护不是强制性的:Transmit count
  2024. auto HW_GRD = [this](vector <string>& paramList) -> void
  2025. {
  2026. if (paramList.size() >= 2)
  2027. {
  2028. //%u
  2029. mLog::Debug("HW_GRD: Transmit count[{$}]",
  2030. paramList[1].c_str());
  2031. }
  2032. else
  2033. {
  2034. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2035. }
  2036. };
  2037. //此命令请求发生器的状态:State Signals
  2038. auto HW_GST = [this](vector <string>& paramList) -> void
  2039. {
  2040. if (paramList.size() >= 3)
  2041. {
  2042. //%u %x
  2043. mLog::Debug("HW_GST: State[{$}], Signals[{$}]",
  2044. paramList[1].c_str(), paramList[2].c_str());
  2045. int state = atoi(paramList[1].c_str());
  2046. switch (state)
  2047. {
  2048. case 0: //undefined
  2049. {
  2050. }break;
  2051. case 1: //SERIAL_INIT
  2052. {
  2053. mLog::Debug("GENSTATE: {$} -> SERIAL_INIT", m_GenStatus.GetState());
  2054. m_GenStatus.changeState(GS_INIT);
  2055. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_INIT))
  2056. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  2057. }break;
  2058. case 2: //SERIAL_STANDBY
  2059. {
  2060. mLog::Debug("GENSTATE: {$} -> SERIAL_STANDBY", m_GenStatus.GetState());
  2061. if (m_DoseUnit.m_GenState->Get() == nsGEN::AttrKey::GENERATOR_STATUS_ERROR)
  2062. {
  2063. int ErrorCode = 0;
  2064. string info = "";
  2065. FireErrorMessage(false, ErrorCode, info.c_str());
  2066. }
  2067. m_GenStatus.changeState(GS_STANDBY);
  2068. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_STANDBY))
  2069. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  2070. }break;
  2071. case 3: //SERIAL_EXPOSURE
  2072. {
  2073. mLog::Debug("GENSTATE: {$} -> SERIAL_EXPOSURE", m_GenStatus.GetState());
  2074. m_GenStatus.changeState(GS_EXPOSURE);
  2075. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_EXP))
  2076. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  2077. }break;
  2078. case 4: //SERIAL_ERROR
  2079. {
  2080. mLog::Debug("GENSTATE: {$} -> SERIAL_ERROR", m_GenStatus.GetState());
  2081. m_GenStatus.changeState(GS_ERROR);
  2082. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_ERROR))
  2083. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  2084. }break;
  2085. default:
  2086. break;
  2087. }
  2088. }
  2089. else
  2090. {
  2091. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2092. }
  2093. };
  2094. //此命令用于告诉发生器单元Host将使用哪个版本的接口命令.如果未发送此命令,发生器将使用最新版本:Version
  2095. auto HW_IFV = [this](vector <string>& paramList) -> void
  2096. {
  2097. if (paramList.size() >= 2)
  2098. {
  2099. //%u
  2100. mLog::Debug("HW_IFV: Version[{$}]",
  2101. paramList[1].c_str());
  2102. m_nVersion = atoi(paramList[1].c_str());
  2103. }
  2104. else
  2105. {
  2106. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2107. }
  2108. };
  2109. //发生器报告初始化状态已完成.状态从 SERIAL_START 更改为 SERIAL_INIT
  2110. auto HW_INI = [this](vector <string>& paramList) -> void
  2111. {
  2112. if (paramList.size() >= 1)
  2113. {
  2114. mLog::Debug("GENSTATE: {$} -> SERIAL_INIT", m_GenStatus.GetState());
  2115. m_GenStatus.changeState(GS_INIT);
  2116. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_INIT))
  2117. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenSynState->JSGet());
  2118. }
  2119. else
  2120. {
  2121. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2122. }
  2123. };
  2124. //在曝光期间,已达到允许的最大mAs值.如果发电机的最大mAs不高于600mA,这可能是600mA,也可能是56kWs除以标称管电压的结果
  2125. auto HW_LIM = [this](vector <string>& paramList) -> void
  2126. {
  2127. if (paramList.size() >= 1)
  2128. {
  2129. mLog::Debug("HW_LIM: exposure was ended by mAs limit");
  2130. }
  2131. else
  2132. {
  2133. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2134. }
  2135. };
  2136. //在曝光期间,已达到允许的最大曝光时间.从1点到3点的所有曝光类型都可能出现限制时间.在信号流中省略了硬件信号
  2137. auto HW_LIT = [this](vector <string>& paramList) -> void
  2138. {
  2139. if (paramList.size() >= 2)
  2140. {
  2141. mLog::Debug("HW_LIT: exposure was ended by time limit");
  2142. }
  2143. else
  2144. {
  2145. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2146. }
  2147. };
  2148. //此命令取决于计算器的类型:%HU PT
  2149. auto HW_PHU = [this](vector <string>& paramList) -> void
  2150. {
  2151. if (paramList.size() >= 3)
  2152. {
  2153. //%u %u
  2154. mLog::Debug("HW_PHU: %HU[{$}], PT[{$}]",
  2155. paramList[1].c_str(), paramList[2].c_str());
  2156. if (m_DoseUnit.m_HE->Update(atoi(paramList[1].c_str())))
  2157. FireNotify(m_DoseUnit.m_HE->GetKey(), m_DoseUnit.m_HE->Get());
  2158. }
  2159. else
  2160. {
  2161. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2162. }
  2163. };
  2164. //发生器报告其准备执行曝光,即阻塞条件:Ready Condition1 Ready Condition2
  2165. auto HW_RDY = [this](vector <string>& paramList) -> void
  2166. {
  2167. if (paramList.size() >= 3)
  2168. {
  2169. //%x %x
  2170. std::bitset<16> binary1(std::stoi(paramList[1], 0, 16)); // 将16进制转为32位的二进制数
  2171. string Condition1 = binary1.to_string(); // 输出二进制字符串
  2172. std::bitset<16> binary2(std::stoi(paramList[2], 0, 16)); // 将16进制转为32位的二进制数
  2173. string Condition2 = binary2.to_string(); // 输出二进制字符串
  2174. mLog::Debug("HW_RDY: Ready Condition1[{$}]->[{$}], Ready Condition2[{$}]->[{$}]",
  2175. paramList[1].c_str(), Condition1.c_str(), paramList[2].c_str(), Condition2.c_str());
  2176. //条件1
  2177. string readyFlag = m_ExpReady;
  2178. if ("0000000000000000" == Condition1 || //0x0000
  2179. "0000000100000000" == Condition1 || //0x0100
  2180. "0000001000000000" == Condition1 || //0x0200
  2181. "0000100000000000" == Condition1) //0x0800
  2182. {
  2183. mLog::Debug("Ready Condition1[ready for exposure and fluoroscopy]");
  2184. readyFlag = "11";
  2185. }
  2186. else
  2187. {
  2188. if ('1' == Condition1.at(15)) //0x0001
  2189. {
  2190. mLog::Error("Ready Condition1[not ready because of heat unit or pause time]");
  2191. readyFlag = "00";
  2192. }
  2193. if ('1' == Condition1.at(14)) //0x0002
  2194. {
  2195. mLog::Error("Ready Condition1[not ready because door is open]");
  2196. readyFlag = "00";
  2197. }
  2198. if ('1' == Condition1.at(13)) //0x0004
  2199. {
  2200. mLog::Error("Ready Condition1[not ready because over temperature of the tube]");
  2201. readyFlag = "00";
  2202. }
  2203. if ('1' == Condition1.at(12)) //0x0008
  2204. {
  2205. mLog::Error("Ready Condition1[not ready because error state is active]");
  2206. readyFlag = "00";
  2207. }
  2208. if ('1' == Condition1.at(11)) //0x0010
  2209. {
  2210. mLog::Error("Ready Condition1[not ready because energy storage unit is not ready]");
  2211. readyFlag = "00";
  2212. }
  2213. if ('1' == Condition1.at(10)) //0x0020
  2214. {
  2215. mLog::Error("Ready Condition1[not ready for exposure because no valid exposure parameters are given]");
  2216. readyFlag.at(0) = '0';
  2217. }
  2218. else
  2219. {
  2220. readyFlag.at(0) = '1';
  2221. }
  2222. if ('1' == Condition1.at(9)) //0x0040
  2223. {
  2224. mLog::Error("Ready Condition1[not ready for fluoroscopy because no valid fluoroscopy parameters are given]");
  2225. readyFlag.at(1) = '0';
  2226. }
  2227. else
  2228. {
  2229. readyFlag.at(1) = '1';
  2230. }
  2231. if ('1' == Condition1.at(8)) //0x0080
  2232. {
  2233. mLog::Error("Ready Condition1[not ready because no exposure disable switch (room switch)]");
  2234. readyFlag = "00";
  2235. }
  2236. if ('1' == Condition1.at(7)) //0x0100
  2237. {
  2238. mLog::Error("Ready Condition1[state of S3 (service switch) on]");
  2239. }
  2240. else
  2241. {
  2242. mLog::Error("Ready Condition1[state of S3 (service switch) off]");
  2243. }
  2244. if ('1' == Condition1.at(6)) //0x0200
  2245. {
  2246. mLog::Error("Ready Condition1[state of S4 (mAs measure switch) on]");
  2247. }
  2248. else
  2249. {
  2250. mLog::Error("Ready Condition1[state of S4 (mAs measure switch) off]");
  2251. }
  2252. if ('1' == Condition1.at(5)) //0x0400
  2253. {
  2254. mLog::Error("Ready Condition1[state of S5 (X-ray disable switch) on]");
  2255. readyFlag = "00";
  2256. }
  2257. else
  2258. {
  2259. mLog::Error("Ready Condition1[state of S5 (X-ray disable switch) off]");
  2260. }
  2261. if ('1' == Condition1.at(4)) //0x0800
  2262. {
  2263. mLog::Error("Ready Condition1[state of S7 (just for internal use) on]");
  2264. }
  2265. else
  2266. {
  2267. mLog::Error("Ready Condition1[state of S7 (just for internal use) off]");
  2268. }
  2269. if ('1' == Condition1.at(3)) //0x1000
  2270. {
  2271. mLog::Error("Ready Condition1[reserved for internal use]");
  2272. }
  2273. if ('1' == Condition1.at(2)) //0x2000
  2274. {
  2275. mLog::Error("Ready Condition1[state of tube pressure switch (X143) on]");
  2276. }
  2277. else
  2278. {
  2279. mLog::Error("Ready Condition1[state of tube pressure switch (X143) off]");
  2280. }
  2281. if ('1' == Condition1.at(1)) //0x4000
  2282. {
  2283. mLog::Error("Ready Condition1[state of software safety switch X-ray disabled]");
  2284. readyFlag = "00";
  2285. }
  2286. else
  2287. {
  2288. mLog::Error("Ready Condition1[state of software safety switch X-ray enable]");
  2289. }
  2290. if ('1' == Condition1.at(0)) //0x8000
  2291. {
  2292. mLog::Error("Ready Condition1[state of calibration switch, input of X19.8]");
  2293. }
  2294. }
  2295. mLog::Debug("HW_RDY: current ExpReady[{$}]->[{$}]", m_ExpReady.c_str(), readyFlag.c_str());
  2296. if (readyFlag != m_ExpReady)
  2297. {
  2298. m_ExpReady = readyFlag;
  2299. SetEvent(m_hLoopEvent);
  2300. }
  2301. //条件2
  2302. if ("0000000000000000" == Condition2)
  2303. {
  2304. mLog::Debug("Ready Condition2[ready]");
  2305. }
  2306. else
  2307. {
  2308. if ('1' == Condition2.at(15))
  2309. {
  2310. mLog::Error("Ready Condition2[state of command <RIP]");
  2311. }
  2312. if ('1' == Condition2.at(14))
  2313. {
  2314. mLog::Error("Ready Condition2[state of command <DECEX]");
  2315. }
  2316. if ('1' == Condition2.at(13))
  2317. {
  2318. mLog::Error("Ready Condition2[state of communication with SCU]");
  2319. }
  2320. if ('1' == Condition2.at(12))
  2321. {
  2322. mLog::Error("Ready Condition2[not ready because of changed configuration, restart necessary]");
  2323. }
  2324. if ('1' == Condition2.at(11))
  2325. {
  2326. mLog::Error("Ready Condition2[not ready because generator time hasn’t been set by system]");
  2327. }
  2328. }
  2329. }
  2330. else
  2331. {
  2332. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2333. }
  2334. };
  2335. //发电机通知主机收到CAN电报:Address Length Data Data
  2336. auto HW_CR = [this](vector <string>& paramList) -> void
  2337. {
  2338. if (paramList.size() >= 5)
  2339. {
  2340. //%x %d %x %x
  2341. mLog::Debug("recv CAN data: Address[{$}], Length[{$}], Data[{$}], Data[{$}]",
  2342. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str());
  2343. }
  2344. else
  2345. {
  2346. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2347. }
  2348. };
  2349. //此命令用于通知主机曝光释放输入的变化(pre-contact or main-contact).如果满足所有要求,主机可以使用此命令使用“<SXP”触发曝光,或者发送KK-Tomo时间输入的更改:Pre contact Main contact KK
  2350. auto HW_RXP = [this](vector <string>& paramList) -> void
  2351. {
  2352. if (paramList.size() >= 4)
  2353. {
  2354. //%u %u %u
  2355. mLog::Debug("HW_RXP: Pre contact[{$}], Main contact[{$}], KK[{$}]",
  2356. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str());
  2357. int PreContact = atoi(paramList[1].c_str());
  2358. int MainContact = atoi(paramList[2].c_str());
  2359. switch (m_LastTechMode)
  2360. {
  2361. case CCOS::Dev::Detail::Generator::RF80Tech_RAD:
  2362. {
  2363. SetRadStatus(PreContact, MainContact);
  2364. }break;
  2365. case CCOS::Dev::Detail::Generator::RF80Tech_FLU:
  2366. {
  2367. SetFluStatus(PreContact, MainContact);
  2368. }break;
  2369. case CCOS::Dev::Detail::Generator::RF80Tech_FLU_MAX:
  2370. {}break;
  2371. default:
  2372. break;
  2373. }
  2374. }
  2375. else
  2376. {
  2377. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2378. }
  2379. };
  2380. //发生器报告其处于备用状态并准备输入,状态从 SERIAL_INIT/SERIAL_EXPOSURE/SERIAL_ERROR 更改为 SERIAL_STANDBY
  2381. auto HW_SBY = [this](vector <string>& paramList) -> void
  2382. {
  2383. mLog::Debug("GENSTATE: {$} -> SERIAL_STANDBY", m_GenStatus.GetState());
  2384. if (m_DoseUnit.m_GenState->Get() == nsGEN::AttrKey::GENERATOR_STATUS_ERROR)
  2385. {
  2386. int ErrorCode = 0;
  2387. string info = "";
  2388. FireErrorMessage(false, ErrorCode, info.c_str());
  2389. }
  2390. m_GenStatus.changeState(GS_STANDBY);
  2391. if (m_DoseUnit.m_GenState->Update(nsGEN::AttrKey::GENERATOR_STATUS_STANDBY))
  2392. FireNotify(AttrKey::GENSTATE, m_DoseUnit.m_GenState->JSGet());
  2393. //拼接参数自动下发
  2394. if (m_DoseUnit.m_ExpMode->JSGet() == AttrKey::EXPMODE_TYPE::Stitch)
  2395. {
  2396. int aprnum = m_DoseUnit.m_GenCurrentExpNumber->Get();
  2397. if (!m_APRarray.empty() && aprnum < m_APRarray.size())
  2398. {
  2399. SetAPR(m_APRarray[aprnum]);
  2400. m_DoseUnit.m_GenCurrentExpNumber->Update(++aprnum);
  2401. mLog::Debug("SetAPRArray:[totalEXP:{$}, currentEXP:{$}]", m_APRarray.size(), m_DoseUnit.m_GenCurrentExpNumber->Get());
  2402. }
  2403. else
  2404. {
  2405. mLog::Warn("APRarray is empty");
  2406. }
  2407. }
  2408. };
  2409. //发生器报告单个储罐温度高于或低于极限的变化
  2410. auto HW_TWS = [this](vector <string>& paramList) -> void
  2411. {
  2412. if (paramList.size() >= 2)
  2413. {
  2414. int state = atoi(paramList[1].c_str());
  2415. if(0 == state)
  2416. mLog::Debug("HW_TWS: single tank temperature below 60C");
  2417. else if(1 == state)
  2418. mLog::Debug("HW_TWS: single tank temperature above 60C");
  2419. else
  2420. mLog::Debug("HW_TWS: State[{$}]", paramList[1].c_str());
  2421. }
  2422. else
  2423. {
  2424. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2425. }
  2426. };
  2427. //发生器收到未知或错误的命令
  2428. auto HW_UNK = [this](vector <string>& paramList) -> void
  2429. {
  2430. if (paramList.size() >= 1)
  2431. {
  2432. mLog::Debug("HW_UNK: received an unknown or erroneous command");
  2433. }
  2434. else
  2435. {
  2436. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2437. }
  2438. };
  2439. //发生器收到一条校验和错误的消息
  2440. auto HW_CRC = [this](vector <string>& paramList) -> void
  2441. {
  2442. if (paramList.size() >= 1)
  2443. {
  2444. mLog::Debug("HW_CRC: received a message with wrong checksum");
  2445. }
  2446. else
  2447. {
  2448. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2449. }
  2450. };
  2451. //此命令用于验证0点DR曝光的接收参数:请参阅ED0命令
  2452. auto HW_VD0 = [this](vector <string>& paramList) -> void
  2453. {
  2454. if (paramList.size() >= 9)
  2455. {
  2456. //%u %x %c %u %u %u %.1f %u
  2457. mLog::Debug("HW_VD0: Curve[{$}], Switch[{$}], Focus[{$}], Dose[{$}], Dominant[{$}], Max.time[{$}], Fps[{$}], Scene Length[{$}]",
  2458. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2459. paramList[6].c_str(), paramList[7].c_str(), paramList[8].c_str());
  2460. //Focus
  2461. if ("S" == paramList[3])
  2462. {
  2463. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2464. {
  2465. mLog::Debug("HW_VD0: Focus update to [SMALL]");
  2466. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2467. }
  2468. }
  2469. else if ("L" == paramList[3])
  2470. {
  2471. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2472. {
  2473. mLog::Debug("HW_VD0: Focus update to [LARGE]");
  2474. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2475. }
  2476. }
  2477. //Dose
  2478. m_nCfdDose = atoi(paramList[4].c_str());
  2479. //AECField
  2480. int nField = TurnAECFieldSel(false, atoi(paramList[5].c_str()));
  2481. if (m_DoseUnit.m_AECField->Update(nField))
  2482. {
  2483. mLog::Debug("HW_VD0: AECField update to [{$}]", nField);
  2484. FireNotify(AttrKey::AECFIELD, m_DoseUnit.m_AECField->Get());
  2485. }
  2486. //Frames per second
  2487. float frameRate = atof(paramList[7].c_str());
  2488. if (m_DoseUnit.m_FrameRate->Update(frameRate))
  2489. {
  2490. mLog::Debug("HW_VD0: FrameRate update to [{$}]", frameRate);
  2491. FireNotify(AttrKey::FRAMERATE, m_DoseUnit.m_FrameRate->Get());
  2492. }
  2493. }
  2494. else
  2495. {
  2496. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2497. }
  2498. };
  2499. //此命令用于验证1点DR曝光的接收参数:请参阅ED1命令
  2500. auto HW_VD1 = [this](vector <string>& paramList) -> void
  2501. {
  2502. if (paramList.size() >= 11)
  2503. {
  2504. //%u %.1f %u %u %x %c %u %.1f %u %u
  2505. mLog::Debug("HW_VD1: WS[{$}], UT[{$}], Tube load[{$}], Current red[{$}], Switch[{$}], Focus[{$}], Dose[{$}], Density[{$}], Dominant[{$}], Max.time[{$}]",
  2506. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2507. paramList[6].c_str(), paramList[7].c_str(), paramList[8].c_str(), paramList[9].c_str(), paramList[10].c_str());
  2508. //TechMode
  2509. //if(m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_AEC_1P))
  2510. // {
  2511. //mLog::Debug("HW_VD1: Techmode update to [{$}] -> TECHMODE_AEC_1P", m_DoseUnit.m_Techmode->Get());
  2512. // FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2513. // }
  2514. //WS
  2515. int WS = atoi(paramList[1].c_str());
  2516. if (m_DoseUnit.m_WS->Update(WS))
  2517. {
  2518. mLog::Debug("HW_VD1: WS update to [{$}]", WS);
  2519. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2520. }
  2521. //KV
  2522. float KV = atof(paramList[2].c_str());
  2523. if (m_DoseUnit.m_KV->Update(KV))
  2524. {
  2525. mLog::Debug("HW_VD1: KV update to [{$}]", KV);
  2526. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  2527. }
  2528. //Focus
  2529. if ("S" == paramList[6])
  2530. {
  2531. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2532. {
  2533. mLog::Debug("HW_VD1: Focus update to [SMALL]");
  2534. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2535. }
  2536. }
  2537. else if ("L" == paramList[6])
  2538. {
  2539. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2540. {
  2541. mLog::Debug("HW_VD1: Focus update to [LARGE]");
  2542. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2543. }
  2544. }
  2545. //Dose
  2546. m_nCfdDose = atoi(paramList[7].c_str());
  2547. //AECDensity
  2548. int nDensity = atoi(paramList[8].c_str());
  2549. if (m_DoseUnit.m_AECDensity->Update(nDensity))
  2550. {
  2551. mLog::Debug("HW_VD1: AECDensity update to [{$}]", nDensity);
  2552. FireNotify(AttrKey::AECDENSITY, m_DoseUnit.m_AECDensity->Get());
  2553. }
  2554. //AECField
  2555. int nField = TurnAECFieldSel(false, atoi(paramList[9].c_str()));
  2556. if (m_DoseUnit.m_AECField->Update(nField))
  2557. {
  2558. mLog::Debug("HW_VD1: AECField update to [{$}]", nField);
  2559. FireNotify(AttrKey::AECFIELD, m_DoseUnit.m_AECField->Get());
  2560. }
  2561. SetSynBoxSwitchStatus(m_bNeedSendToSynBox);
  2562. }
  2563. else
  2564. {
  2565. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2566. }
  2567. };
  2568. //此命令用于验证2点DR曝光的接收参数:请参阅ED2命令
  2569. auto HW_VD2 = [this](vector <string>& paramList) -> void
  2570. {
  2571. if (paramList.size() >= 7)
  2572. {
  2573. //%u %.1f %.2f %u %x %c
  2574. mLog::Debug("HW_VD2: WS[{$}], UT[{$}], mAs[{$}], Tube Load[{$}], Switch[{$}], Focus[{$}]",
  2575. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2576. paramList[6].c_str());
  2577. //TechMode
  2578. if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_NOAEC_2P))
  2579. {
  2580. mLog::Debug("HW_VD2: Techmode update to [{$}] -> TECHMODE_NOAEC_2P", m_DoseUnit.m_Techmode->Get());
  2581. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2582. }
  2583. //WS
  2584. int WS = atoi(paramList[1].c_str());
  2585. if (m_DoseUnit.m_WS->Update(WS))
  2586. {
  2587. mLog::Debug("HW_VD2: WS update to [{$}]", WS);
  2588. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2589. }
  2590. //KV
  2591. float KV = atof(paramList[2].c_str());
  2592. if (m_DoseUnit.m_KV->Update(KV))
  2593. {
  2594. mLog::Debug("HW_VD2: KV update to [{$}]", KV);
  2595. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  2596. }
  2597. //MAS
  2598. float MAS = atof(paramList[3].c_str());
  2599. if (m_DoseUnit.m_MAS->Update(MAS))
  2600. {
  2601. mLog::Debug("HW_VD2: MAS update to [{$}]", MAS);
  2602. FireNotify(m_DoseUnit.m_MAS->GetKey(), m_DoseUnit.m_MAS->Get());
  2603. }
  2604. //Focus
  2605. if ("S" == paramList[6])
  2606. {
  2607. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2608. {
  2609. mLog::Debug("HW_VD2: Focus update to [SMALL]");
  2610. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2611. }
  2612. }
  2613. else if ("L" == paramList[6])
  2614. {
  2615. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2616. {
  2617. mLog::Debug("HW_VD2: Focus update to [LARGE]");
  2618. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2619. }
  2620. }
  2621. SetSynBoxSwitchStatus(m_bNeedSendToSynBox);
  2622. }
  2623. else
  2624. {
  2625. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2626. }
  2627. };
  2628. //此命令用于验证3点DR曝光的接收参数:请参阅ED3命令
  2629. auto HW_VD3 = [this](vector <string>& paramList) -> void
  2630. {
  2631. if (paramList.size() >= 7)
  2632. {
  2633. //%u %.1f %.2f %.3f %x %c
  2634. mLog::Debug("HW_VD3: WS[{$}], UT[{$}], mAs[{$}], IT[{$}], Switch[{$}], Focus[{$}]",
  2635. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2636. paramList[6].c_str());
  2637. //TechMode
  2638. if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_NOAEC_3P))
  2639. {
  2640. mLog::Debug("HW_VD3: Techmode update to [{$}] -> TECHMODE_NOAEC_3P", m_DoseUnit.m_Techmode->Get());
  2641. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2642. }
  2643. //WS
  2644. int WS = atoi(paramList[1].c_str());
  2645. if (m_DoseUnit.m_WS->Update(WS))
  2646. {
  2647. mLog::Debug("HW_VD3: WS update to [{$}]", WS);
  2648. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2649. }
  2650. //KV
  2651. float KV = atof(paramList[2].c_str());
  2652. if (m_DoseUnit.m_KV->Update(KV))
  2653. {
  2654. mLog::Debug("HW_VD3: KV update to [{$}]", KV);
  2655. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  2656. }
  2657. //MAS
  2658. float MAS = atof(paramList[3].c_str());
  2659. if(m_DoseUnit.m_MAS->Update(MAS))
  2660. {
  2661. mLog::Debug("HW_VD3: MAS update to [{$}]", MAS);
  2662. }
  2663. //MA
  2664. float MA = atof(paramList[4].c_str());
  2665. if (m_DoseUnit.m_MA->Update(MA))
  2666. {
  2667. mLog::Debug("HW_VD3: MA update to [{$}]", MA);
  2668. FireNotify(m_DoseUnit.m_MA->GetKey(), m_DoseUnit.m_MA->Get());
  2669. }
  2670. //MS
  2671. float MS = MAS * 1000.0f / MA;
  2672. if (m_DoseUnit.m_MS->Update(MS))
  2673. {
  2674. mLog::Debug("HW_VD3: MS update to [{$}]", MS);
  2675. FireNotify(m_DoseUnit.m_MS->GetKey(), m_DoseUnit.m_MS->Get());
  2676. }
  2677. //Focus
  2678. if ("S" == paramList[6])
  2679. {
  2680. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2681. {
  2682. mLog::Debug("HW_VD3: Focus update to [SMALL]");
  2683. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2684. }
  2685. }
  2686. else if ("L" == paramList[6])
  2687. {
  2688. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2689. {
  2690. mLog::Debug("HW_VD3: Focus update to [LARGE]");
  2691. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2692. }
  2693. }
  2694. SetSynBoxSwitchStatus(m_bNeedSendToSynBox);
  2695. }
  2696. else
  2697. {
  2698. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2699. }
  2700. };
  2701. //此命令用于验证3点DR曝光的接收参数:请参阅EA3命令
  2702. auto HW_VA3 = [this](vector <string>& paramList) -> void
  2703. {
  2704. if (paramList.size() >= 8)
  2705. {
  2706. //%u %.1f %.2f %.0f %u %x %c
  2707. mLog::Debug("HW_VA3: WS[{$}], UT[{$}], mAs[{$}], ms[{$}], Tube load[{$}], Switch[{$}], Focus[{$}]",
  2708. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2709. paramList[6].c_str(), paramList[7].c_str());
  2710. //TechMode
  2711. if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_NOAEC_3P))
  2712. {
  2713. mLog::Debug("HW_VA3: Techmode update to [{$}] -> TECHMODE_NOAEC_3P", m_DoseUnit.m_Techmode->Get());
  2714. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2715. }
  2716. //WS
  2717. int WS = atoi(paramList[1].c_str());
  2718. if (m_DoseUnit.m_WS->Update(WS))
  2719. {
  2720. mLog::Debug("HW_VA3: WS update to [{$}]", WS);
  2721. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2722. }
  2723. //KV
  2724. float KV = atof(paramList[2].c_str());
  2725. if (m_DoseUnit.m_KV->Update(KV))
  2726. {
  2727. mLog::Debug("HW_VA3: KV update to [{$}]", KV);
  2728. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  2729. }
  2730. //MAS
  2731. float MAS = atof(paramList[3].c_str());
  2732. if (m_DoseUnit.m_MAS->Update(MAS))
  2733. {
  2734. mLog::Debug("HW_VA3: MAS update to [{$}]", MAS);
  2735. }
  2736. //MS
  2737. float MS = atof(paramList[4].c_str());
  2738. if (m_DoseUnit.m_MS->Update(MS))
  2739. {
  2740. mLog::Debug("HW_VA3: MS update to [{$}]", MS);
  2741. FireNotify(m_DoseUnit.m_MS->GetKey(), m_DoseUnit.m_MS->Get());
  2742. }
  2743. //MA
  2744. float MA = MAS * 1000.0f / MS;
  2745. if (m_DoseUnit.m_MA->Update(MA))
  2746. {
  2747. mLog::Debug("HW_VA3: MA update to [{$}]", MA);
  2748. FireNotify(m_DoseUnit.m_MA->GetKey(), m_DoseUnit.m_MA->Get());
  2749. }
  2750. //Focus
  2751. if ("S" == paramList[7])
  2752. {
  2753. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2754. {
  2755. mLog::Debug("HW_VA3: Focus update to [SMALL]");
  2756. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2757. }
  2758. }
  2759. else if ("L" == paramList[7])
  2760. {
  2761. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2762. {
  2763. mLog::Debug("HW_VA3: Focus update to [LARGE]");
  2764. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2765. }
  2766. }
  2767. }
  2768. else
  2769. {
  2770. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2771. }
  2772. };
  2773. //此命令用于验证1点曝光的接收参数:请参阅EP1命令
  2774. auto HW_VP1 = [this](vector <string>& paramList) -> void
  2775. {
  2776. if (paramList.size() >= 10)
  2777. {
  2778. //%u %.1f %u %u %x %c %c %u %.1f
  2779. mLog::Debug("HW_VP1: WS[{$}], UT[{$}], Tube load[{$}], Current red[{$}], Switch[{$}], Focus[{$}], Sensitivity[{$}], Dominant[{$}], Density[{$}]",
  2780. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2781. paramList[6].c_str(), paramList[7].c_str(), paramList[8].c_str(), paramList[9].c_str());
  2782. //TechMode
  2783. //mLog::Debug("HW_VP1: Techmode update to [{$}] -> TECHMODE_AEC_1P", m_DoseUnit.m_Techmode->Get());
  2784. //if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_AEC_1P))
  2785. // FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2786. //WS
  2787. int WS = atoi(paramList[1].c_str());
  2788. if (m_DoseUnit.m_WS->Update(WS))
  2789. {
  2790. mLog::Debug("HW_VP1: WS update to [{$}]", WS);
  2791. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2792. }
  2793. //KV
  2794. float KV = atof(paramList[2].c_str());
  2795. if (m_DoseUnit.m_KV->Update(KV))
  2796. {
  2797. mLog::Debug("HW_VP1: KV update to [{$}]", KV);
  2798. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  2799. }
  2800. //Focus
  2801. if ("S" == paramList[6])
  2802. {
  2803. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2804. {
  2805. mLog::Debug("HW_VP1: Focus update to [SMALL]");
  2806. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2807. }
  2808. }
  2809. else if ("L" == paramList[6])
  2810. {
  2811. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2812. {
  2813. mLog::Debug("HW_VP1: Focus update to [LARGE]");
  2814. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2815. }
  2816. }
  2817. //AECFilm
  2818. int nFilm = TurnAECFilmSel(false, atoi(paramList[7].c_str()));
  2819. if (m_DoseUnit.m_AECFilm->Update(nFilm))
  2820. {
  2821. mLog::Debug("HW_VP1: AECFilm update to [{$}]", nFilm);
  2822. FireNotify(AttrKey::AECFILM, m_DoseUnit.m_AECFilm->Get());
  2823. }
  2824. //AECField
  2825. int nField = TurnAECFieldSel(false, atoi(paramList[8].c_str()));
  2826. if (m_DoseUnit.m_AECField->Update(nField))
  2827. {
  2828. mLog::Debug("HW_VP1: AECField update to [{$}]", nField);
  2829. FireNotify(AttrKey::AECFIELD, m_DoseUnit.m_AECField->Get());
  2830. }
  2831. //AECDensity
  2832. int nDensity = atoi(paramList[9].c_str());
  2833. if (m_DoseUnit.m_AECDensity->Update(nDensity))
  2834. {
  2835. mLog::Debug("HW_VP1: AECDensity update to [{$}]", nDensity);
  2836. FireNotify(AttrKey::AECDENSITY, m_DoseUnit.m_AECDensity->Get());
  2837. }
  2838. }
  2839. else
  2840. {
  2841. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2842. }
  2843. };
  2844. //此命令用于验证2点曝光的接收参数:请参阅EP2命令
  2845. auto HW_VP2 = [this](vector <string>& paramList) -> void
  2846. {
  2847. if (paramList.size() >= 7)
  2848. {
  2849. //%u %.1f %.2f %u %x %c
  2850. mLog::Debug("HW_VP2: WS[{$}], UT[{$}], mAs[{$}], Tube Load[{$}], Switch[{$}], Focus[{$}]",
  2851. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2852. paramList[6].c_str());
  2853. //TechMode
  2854. if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_NOAEC_2P))
  2855. {
  2856. mLog::Debug("HW_VP2: Techmode update to [{$}] -> TECHMODE_NOAEC_2P", m_DoseUnit.m_Techmode->Get());
  2857. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2858. }
  2859. //WS
  2860. int WS = atoi(paramList[1].c_str());
  2861. if (m_DoseUnit.m_WS->Update(WS))
  2862. {
  2863. mLog::Debug("HW_VP2: WS update to [{$}]", WS);
  2864. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2865. }
  2866. //KV
  2867. float KV = atof(paramList[2].c_str());
  2868. if (m_DoseUnit.m_KV->Update(KV))
  2869. {
  2870. mLog::Debug("HW_VP2: KV update to [{$}]", KV);
  2871. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->JSGet());
  2872. }
  2873. //MAS
  2874. float MAS = atof(paramList[3].c_str());
  2875. if (m_DoseUnit.m_MAS->Update(MAS))
  2876. {
  2877. mLog::Debug("HW_VP2: MAS update to [{$}]", MAS);
  2878. FireNotify(m_DoseUnit.m_MAS->GetKey(), m_DoseUnit.m_MAS->JSGet());
  2879. }
  2880. //Focus
  2881. if ("S" == paramList[6])
  2882. {
  2883. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2884. {
  2885. mLog::Debug("HW_VP2: Focus update to [SMALL]");
  2886. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2887. }
  2888. }
  2889. else if ("L" == paramList[6])
  2890. {
  2891. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2892. {
  2893. mLog::Debug("HW_VP2: Focus update to [LARGE]");
  2894. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2895. }
  2896. }
  2897. }
  2898. else
  2899. {
  2900. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2901. }
  2902. };
  2903. //此命令用于验证3点曝光的接收参数:请参阅EP3命令
  2904. auto HW_VP3 = [this](vector <string>& paramList) -> void
  2905. {
  2906. if (paramList.size() >= 7)
  2907. {
  2908. //%u %.1f %.2f %.1f %x %c
  2909. mLog::Debug("HW_VP3: WS[{$}], UT[{$}], mAs[{$}], IT[{$}], Switch[{$}], Focus[{$}]",
  2910. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2911. paramList[6].c_str());
  2912. //TechMode
  2913. if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_NOAEC_3P))
  2914. {
  2915. mLog::Debug("HW_VP3: Techmode update to [{$}] -> TECHMODE_NOAEC_3P", m_DoseUnit.m_Techmode->Get());
  2916. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2917. }
  2918. //WS
  2919. int WS = atoi(paramList[1].c_str());
  2920. if (m_DoseUnit.m_WS->Update(WS))
  2921. {
  2922. mLog::Debug("HW_VP3: WS update to [{$}]", WS);
  2923. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2924. }
  2925. //KV
  2926. float KV = atof(paramList[2].c_str());
  2927. if (m_DoseUnit.m_KV->Update(KV))
  2928. {
  2929. mLog::Debug("HW_VP3: KV update to [{$}]", KV);
  2930. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  2931. }
  2932. //MAS
  2933. float MAS = atof(paramList[3].c_str());
  2934. if (m_DoseUnit.m_MAS->Update(MAS))
  2935. {
  2936. mLog::Debug("HW_VP3: MAS update to [{$}]", MAS);
  2937. }
  2938. //MA
  2939. float MA = atof(paramList[4].c_str());
  2940. if (m_DoseUnit.m_MA->Update(MA))
  2941. {
  2942. mLog::Debug("HW_VP3: MA update to [{$}]", MA);
  2943. FireNotify(m_DoseUnit.m_MA->GetKey(), m_DoseUnit.m_MA->Get());
  2944. }
  2945. //MS
  2946. float MS = MAS * 1000.0f / MA;
  2947. if (m_DoseUnit.m_MS->Update(MS))
  2948. {
  2949. mLog::Debug("HW_VP3: MS update to [{$}]", MS);
  2950. FireNotify(m_DoseUnit.m_MS->GetKey(), m_DoseUnit.m_MS->Get());
  2951. }
  2952. //Focus
  2953. if ("S" == paramList[6])
  2954. {
  2955. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  2956. {
  2957. mLog::Debug("HW_VP3: Focus update to [SMALL]");
  2958. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2959. }
  2960. }
  2961. else if ("L" == paramList[6])
  2962. {
  2963. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  2964. {
  2965. mLog::Debug("HW_VP3: Focus update to [LARGE]");
  2966. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  2967. }
  2968. }
  2969. }
  2970. else
  2971. {
  2972. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  2973. }
  2974. };
  2975. //此命令用于验证1点DR曝光的接收参数:请参阅ES1命令
  2976. auto HW_VS1 = [this](vector <string>& paramList) -> void
  2977. {
  2978. if (paramList.size() >= 12)
  2979. {
  2980. //%u %.1f %u %u %x %c %u %.1f %u %u %.1f
  2981. mLog::Debug("HW_VS1: WS[{$}], UT[{$}], Tube load[{$}], Current red[{$}], Switch[{$}], Focus[{$}], Dose[{$}], Density[{$}], Dominant[{$}], Max.time[{$}], Frame per second[{$}]",
  2982. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  2983. paramList[6].c_str(), paramList[7].c_str(), paramList[8].c_str(), paramList[9].c_str(), paramList[10].c_str(),
  2984. paramList[11].c_str());
  2985. //TechMode
  2986. //mLog::Debug("HW_VS1: Techmode update to [{$}] -> TECHMODE_AEC_1P", m_DoseUnit.m_Techmode->Get());
  2987. //if(m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_AEC_1P))
  2988. // FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  2989. //WS
  2990. int WS = atoi(paramList[1].c_str());
  2991. mLog::Debug("HW_VS1: WS update to [{$}]", WS);
  2992. if (m_DoseUnit.m_WS->Update(WS))
  2993. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  2994. //KV
  2995. float KV = atof(paramList[2].c_str());
  2996. mLog::Debug("HW_VS1: KV update to [{$}]", KV);
  2997. if (m_DoseUnit.m_KV->Update(KV))
  2998. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  2999. //Focus
  3000. if ("S" == paramList[6])
  3001. {
  3002. mLog::Debug("HW_VS1: Focus update to [SMALL]");
  3003. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  3004. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3005. }
  3006. else if ("L" == paramList[6])
  3007. {
  3008. mLog::Debug("HW_VS1: Focus update to [LARGE]");
  3009. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  3010. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3011. }
  3012. //Dose
  3013. m_nCfdDose = atoi(paramList[7].c_str());
  3014. //AECDensity
  3015. int nDensity = atoi(paramList[8].c_str());
  3016. mLog::Debug("HW_VS1: AECDensity update to [{$}]", nDensity);
  3017. if (m_DoseUnit.m_AECDensity->Update(nDensity))
  3018. FireNotify(AttrKey::AECDENSITY, m_DoseUnit.m_AECDensity->Get());
  3019. //AECField
  3020. int nField = TurnAECFieldSel(false, atoi(paramList[9].c_str()));
  3021. mLog::Debug("HW_VS1: AECField update to [{$}]", nField);
  3022. if (m_DoseUnit.m_AECField->Update(nField))
  3023. FireNotify(AttrKey::AECFIELD, m_DoseUnit.m_AECField->Get());
  3024. //Frames per second
  3025. float frameRate = atof(paramList[11].c_str());
  3026. mLog::Debug("HW_VS1: FrameRate update to [{$}]", frameRate);
  3027. if (m_DoseUnit.m_FrameRate->Update(frameRate))
  3028. FireNotify(AttrKey::FRAMERATE, m_DoseUnit.m_FrameRate->Get());
  3029. SetSynBoxSwitchStatus(m_bNeedSendToSynBox);
  3030. }
  3031. else
  3032. {
  3033. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3034. }
  3035. };
  3036. //此命令用于验证2点DR曝光的接收参数:请参阅ES2命令
  3037. auto HW_VS2 = [this](vector <string>& paramList) -> void
  3038. {
  3039. if (paramList.size() >= 8)
  3040. {
  3041. //%u %.1f %.2f %u %x %c %.1f
  3042. mLog::Debug("HW_VS2: WS[{$}], UT[{$}], mAs[{$}], Tube Load[{$}], Switch[{$}], Focus[{$}], Frame per second[{$}]",
  3043. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  3044. paramList[6].c_str(), paramList[7].c_str());
  3045. //TechMode
  3046. mLog::Debug("HW_VS2: Techmode update to [{$}] -> TECHMODE_NOAEC_2P", m_DoseUnit.m_Techmode->Get());
  3047. if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_NOAEC_2P))
  3048. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  3049. //WS
  3050. int WS = atoi(paramList[1].c_str());
  3051. mLog::Debug("HW_VS2: WS update to [{$}]", WS);
  3052. if (m_DoseUnit.m_WS->Update(WS))
  3053. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  3054. //KV
  3055. float KV = atof(paramList[2].c_str());
  3056. mLog::Debug("HW_VS2: KV update to [{$}]", KV);
  3057. if (m_DoseUnit.m_KV->Update(KV))
  3058. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  3059. //MAS
  3060. float MAS = atof(paramList[3].c_str());
  3061. mLog::Debug("HW_VS2: MAS update to [{$}]", MAS);
  3062. if (m_DoseUnit.m_MAS->Update(MAS))
  3063. FireNotify(m_DoseUnit.m_MAS->GetKey(), m_DoseUnit.m_MAS->Get());
  3064. //Focus
  3065. if ("S" == paramList[6])
  3066. {
  3067. mLog::Debug("HW_VS2: Focus update to [SMALL]");
  3068. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  3069. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3070. }
  3071. else if ("L" == paramList[6])
  3072. {
  3073. mLog::Debug("HW_VS2: Focus update to [LARGE]");
  3074. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  3075. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3076. }
  3077. //Frames per second
  3078. float frameRate = atof(paramList[7].c_str());
  3079. mLog::Debug("HW_VS1: FrameRate update to [{$}]", frameRate);
  3080. if (m_DoseUnit.m_FrameRate->Update(frameRate))
  3081. FireNotify(AttrKey::FRAMERATE, m_DoseUnit.m_FrameRate->Get());
  3082. SetSynBoxSwitchStatus(m_bNeedSendToSynBox);
  3083. }
  3084. else
  3085. {
  3086. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3087. }
  3088. };
  3089. //此命令用于验证3点DR曝光的接收参数:请参阅ES3命令
  3090. auto HW_VS3 = [this](vector <string>& paramList) -> void
  3091. {
  3092. if (paramList.size() >= 8)
  3093. {
  3094. //%u %.1f %.2f %.3f %x %c %.1f
  3095. mLog::Debug("HW_VS3: WS[{$}], UT[{$}], mAs[{$}], IT[{$}], Switch[{$}], Focus[{$}], Frame per second[{$}]",
  3096. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  3097. paramList[6].c_str(), paramList[7].c_str());
  3098. //TechMode
  3099. if (m_DoseUnit.m_Techmode->Update(AttrKey::TECHMODE_NOAEC_3P))
  3100. {
  3101. mLog::Debug("HW_VS3: Techmode update to [{$}] -> TECHMODE_NOAEC_3P", m_DoseUnit.m_Techmode->Get());
  3102. FireNotify(AttrKey::TECHMODE, m_DoseUnit.m_Techmode->JSGet());
  3103. }
  3104. //WS
  3105. int WS = atoi(paramList[1].c_str());
  3106. if (m_DoseUnit.m_WS->Update(WS))
  3107. {
  3108. mLog::Debug("HW_VS3: WS update to [{$}]", WS);
  3109. FireNotify(AttrKey::WORKSTATION, m_DoseUnit.m_WS->JSGet());
  3110. }
  3111. //KV
  3112. float KV = atof(paramList[2].c_str());
  3113. if (m_DoseUnit.m_KV->Update(KV))
  3114. {
  3115. mLog::Debug("HW_VS3: KV update to [{$}]", KV);
  3116. FireNotify(m_DoseUnit.m_KV->GetKey(), m_DoseUnit.m_KV->Get());
  3117. }
  3118. //MAS
  3119. float MAS = atof(paramList[3].c_str());
  3120. if (m_DoseUnit.m_MAS->Update(MAS))
  3121. {
  3122. mLog::Debug("HW_VS3: MAS update to [{$}]", MAS);
  3123. }
  3124. //MA
  3125. float MA = atof(paramList[4].c_str());
  3126. if (m_DoseUnit.m_MA->Update(MA))
  3127. {
  3128. mLog::Debug("HW_VS3: MA update to [{$}]", MA);
  3129. FireNotify(m_DoseUnit.m_MA->GetKey(), m_DoseUnit.m_MA->Get());
  3130. }
  3131. //MS
  3132. float MS = MAS * 1000.0f / MA;
  3133. if (m_DoseUnit.m_MS->Update(MS))
  3134. {
  3135. mLog::Debug("HW_VS3: MS update to [{$}]", MS);
  3136. FireNotify(m_DoseUnit.m_MS->GetKey(), m_DoseUnit.m_MS->Get());
  3137. }
  3138. //Focus
  3139. if ("S" == paramList[6])
  3140. {
  3141. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  3142. {
  3143. mLog::Debug("HW_VS3: Focus update to [SMALL]");
  3144. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3145. }
  3146. }
  3147. else if ("L" == paramList[6])
  3148. {
  3149. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  3150. {
  3151. mLog::Debug("HW_VS3: Focus update to [LARGE]");
  3152. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3153. }
  3154. }
  3155. //Frames per second
  3156. float frameRate = atof(paramList[7].c_str());
  3157. if (m_DoseUnit.m_FrameRate->Update(frameRate))
  3158. {
  3159. mLog::Debug("HW_VS1: FrameRate update to [{$}]", frameRate);
  3160. FireNotify(AttrKey::FRAMERATE, m_DoseUnit.m_FrameRate->Get());
  3161. }
  3162. SetSynBoxSwitchStatus(m_bNeedSendToSynBox);
  3163. }
  3164. else
  3165. {
  3166. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3167. }
  3168. };
  3169. //该命令用于验证收到的剂量调节停止命令<DRS:Stop
  3170. auto HW_VRS = [this](vector <string>& paramList) -> void
  3171. {
  3172. if (paramList.size() >= 2)
  3173. {
  3174. //%u
  3175. int State = atoi(paramList[1].c_str());
  3176. switch (State)
  3177. {
  3178. case 0:
  3179. {
  3180. mLog::Debug("HW_VRS: Dose regulation on");
  3181. }break;
  3182. case 1:
  3183. {
  3184. mLog::Debug("HW_VRS: Dose regulation stop");
  3185. }break;
  3186. default:
  3187. {
  3188. mLog::Debug("HW_VRS: Stop[{$}]",
  3189. paramList[1].c_str());
  3190. }break;
  3191. }
  3192. }
  3193. else
  3194. {
  3195. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3196. }
  3197. };
  3198. //此命令用于指示荧光蜂鸣器已激活,因为指定的荧光计时器已过期
  3199. auto HW_FBS = [this](vector <string>& paramList) -> void
  3200. {
  3201. if (paramList.size() >= 2)
  3202. {
  3203. //%u
  3204. int State = atoi(paramList[1].c_str());
  3205. switch (State)
  3206. {
  3207. case 0:
  3208. {
  3209. mLog::Debug("HW_FBS: Fluoro Beeper is not activate");
  3210. }break;
  3211. case 1:
  3212. {
  3213. mLog::Debug("HW_FBS: Fluoro Beeper is active");
  3214. }break;
  3215. case 2:
  3216. {
  3217. mLog::Debug("HW_FBS: Xray blocked because of fluoro beeper timeout; Fluoro beeper is not active");
  3218. }break;
  3219. case 3:
  3220. {
  3221. mLog::Debug("HW_FBS: Xray blocked because of 60 minutes fluoro scene without interruption");
  3222. }break;
  3223. default:
  3224. {
  3225. mLog::Debug("HW_FBS: State[{$}]",
  3226. paramList[1].c_str());
  3227. }break;
  3228. }
  3229. }
  3230. else
  3231. {
  3232. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3233. }
  3234. };
  3235. //该命令由发生器单元提供,用于指示实际的荧光参数:kV mA Time State Deviation
  3236. auto HW_FPA = [this](vector <string>& paramList) -> void
  3237. {
  3238. if (paramList.size() >= 6)
  3239. {
  3240. //%.1f %.2f %.2f %u %d
  3241. mLog::Debug("HW_FPA: kV[{$}], mA[{$}], Time[{$}], State[{$}], Deviation[{$}]",
  3242. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str());
  3243. if (m_DoseUnit.m_GenSynState->Get() == AttrKey::GENERATOR_FLU_READY)
  3244. {
  3245. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_XRAYON))
  3246. {
  3247. mLog::Debug("EXPSTATE: [{$}] -> FLX1", m_DoseUnit.m_GenSynState->Get());
  3248. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  3249. }
  3250. }
  3251. else if (m_DoseUnit.m_GenSynState->Get() != AttrKey::GENERATOR_FLU_XRAYON)
  3252. {
  3253. mLog::Warn("EXPSTATE: [{$}] not in ready", m_DoseUnit.m_GenSynState->Get());
  3254. }
  3255. //KV
  3256. float KV = atof(paramList[1].c_str());
  3257. if (m_DoseUnit.m_PostKV->Update(KV))
  3258. {
  3259. mLog::Debug("HW_FPA: Post KV update to [{$}]", KV);
  3260. FireNotify(m_DoseUnit.m_PostKV->GetKey(), m_DoseUnit.m_PostKV->Get());
  3261. }
  3262. //MA
  3263. float MA = atof(paramList[2].c_str());
  3264. if (m_DoseUnit.m_PostMA->Update(MA))
  3265. {
  3266. mLog::Debug("HW_FPA: Post MA update to [{$}]", MA);
  3267. FireNotify(m_DoseUnit.m_PostMA->GetKey(), m_DoseUnit.m_PostMA->Get());
  3268. }
  3269. //time
  3270. float time = atof(paramList[3].c_str());
  3271. if (m_DoseUnit.m_FLAccTime->Update(time))
  3272. {
  3273. mLog::Debug("HW_FPA: time update to [{$}]", time);
  3274. FireNotify(m_DoseUnit.m_FLAccTime->GetKey(), m_DoseUnit.m_FLAccTime->Get());
  3275. }
  3276. //ABS mode
  3277. int abs = atoi(paramList[4].c_str());
  3278. switch (abs)
  3279. {
  3280. case 0:
  3281. {
  3282. mLog::Debug("HW_FPA: ABC control active");
  3283. }break;
  3284. case 1:
  3285. {
  3286. mLog::Debug("HW_FPA: ABC control active, but upper control limits reached");
  3287. }break;
  3288. case 2:
  3289. {
  3290. mLog::Debug("HW_FPA: ABC control active, but lower control limits reached");
  3291. }break;
  3292. case 3:
  3293. {
  3294. mLog::Debug("HW_FPA: ABC control stopped");
  3295. }break;
  3296. }
  3297. }
  3298. else
  3299. {
  3300. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3301. }
  3302. };
  3303. //该命令由发生器单元给出,用于指示实际的脉冲荧光参数:UT IT x-ray time Tube current time product Timer State Deviation
  3304. auto HW_PPA = [this](vector <string>& paramList) -> void
  3305. {
  3306. if (paramList.size() >= 8)
  3307. {
  3308. //%.1f %.1f %.1f %.2f %.2f %u %d
  3309. mLog::Debug("HW_PPA: UT[{$}], IT[{$}], x-ray time[{$}], Tube current time product[{$}], Timer[{$}], State[{$}], Deviation[{$}]",
  3310. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  3311. paramList[6].c_str(), paramList[7].c_str());
  3312. if (m_DoseUnit.m_GenSynState->Get() == AttrKey::GENERATOR_FLU_READY)
  3313. {
  3314. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_XRAYON))
  3315. {
  3316. mLog::Debug("EXPSTATE: [{$}] -> FLX1", m_DoseUnit.m_GenSynState->Get());
  3317. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  3318. }
  3319. }
  3320. else if (m_DoseUnit.m_GenSynState->Get() != AttrKey::GENERATOR_FLU_XRAYON)
  3321. {
  3322. mLog::Warn("EXPSTATE: [{$}] not in ready", m_DoseUnit.m_GenSynState->Get());
  3323. }
  3324. //KV
  3325. float KV = atof(paramList[1].c_str());
  3326. if (m_DoseUnit.m_PostKV->Update(KV))
  3327. {
  3328. mLog::Debug("HW_PPA: Post KV update to [{$}]", KV);
  3329. FireNotify(m_DoseUnit.m_PostKV->GetKey(), m_DoseUnit.m_PostKV->Get());
  3330. }
  3331. //MA
  3332. float MA = atof(paramList[2].c_str());
  3333. if (m_DoseUnit.m_PostMA->Update(MA))
  3334. {
  3335. mLog::Debug("HW_PPA: Post MA update to [{$}]", MA);
  3336. FireNotify(m_DoseUnit.m_PostMA->GetKey(), m_DoseUnit.m_PostMA->Get());
  3337. }
  3338. //MS
  3339. float MS = atof(paramList[3].c_str());
  3340. if (m_DoseUnit.m_FLMS->Update(MS))
  3341. {
  3342. mLog::Debug("HW_PPA: Post pulse length ms update to [{$}]", MS);
  3343. FireNotify(m_DoseUnit.m_FLMS->GetKey(), m_DoseUnit.m_FLMS->Get());
  3344. }
  3345. //time
  3346. float time = atof(paramList[5].c_str());
  3347. if (m_DoseUnit.m_FLAccTime->Update(time))
  3348. {
  3349. mLog::Debug("HW_PPA: time update to [{$}]", time);
  3350. FireNotify(m_DoseUnit.m_FLAccTime->GetKey(), m_DoseUnit.m_FLAccTime->Get());
  3351. }
  3352. //ABS mode
  3353. int abs = atoi(paramList[6].c_str());
  3354. switch (abs)
  3355. {
  3356. case 0:
  3357. {
  3358. mLog::Debug("HW_PPA: ABC control active");
  3359. }break;
  3360. case 1:
  3361. {
  3362. mLog::Debug("HW_PPA: ABC control active, but upper control limits reached");
  3363. }break;
  3364. case 2:
  3365. {
  3366. mLog::Debug("HW_PPA: ABC control active, but lower control limits reached");
  3367. }break;
  3368. case 3:
  3369. {
  3370. mLog::Debug("HW_PPA: ABC control stopped");
  3371. }break;
  3372. case 4:
  3373. {
  3374. mLog::Debug("HW_PPA: ABC control stopped, but upper control limits reached");
  3375. }break;
  3376. case 5:
  3377. {
  3378. mLog::Debug("HW_PPA: ABC control stopped, but lower control limits reached");
  3379. }break;
  3380. }
  3381. }
  3382. else
  3383. {
  3384. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3385. }
  3386. };
  3387. //使用此命令时,系统控制单元可以通知主机曝光释放输入(脚踏开关)的变化.如果满足所有要求,主机可以使用此命令使用“<SFL”触发曝光:Handswitch Footswitch
  3388. auto HW_RFL = [this](vector <string>& paramList) -> void
  3389. {
  3390. //%u %u
  3391. if (paramList.size() >= 3)
  3392. {
  3393. mLog::Debug("HW_RFL: Handswitch[{$}], Footswitch[{$}]",
  3394. paramList[1].c_str(), paramList[2].c_str());
  3395. }
  3396. else
  3397. {
  3398. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3399. }
  3400. };
  3401. //此命令用于验证连续荧光的接收参数:参见FPC命令:Curve type Stop Doserate Focus
  3402. auto HW_VPC = [this](vector <string>& paramList) -> void
  3403. {
  3404. if (paramList.size() >= 5)
  3405. {
  3406. //%u %u %u %c
  3407. mLog::Debug("HW_VPC: Curve type[{$}], Stop[{$}], Doserate[{$}], Focus[{$}]",
  3408. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str());
  3409. //FluMode
  3410. if (m_DoseUnit.m_FLMode->Update(AttrKey::GENERATOR_FLMODE_CF))
  3411. {
  3412. mLog::Debug("HW_VPC: FluMode update to [{$}] -> GENERATOR_FLMODE_CF", m_DoseUnit.m_FLMode->Get());
  3413. FireNotify(AttrKey::FLUMode, m_DoseUnit.m_FLMode->JSGet());
  3414. }
  3415. //DoseLevel
  3416. int DoseLevel = atoi(paramList[1].c_str());
  3417. if (m_DoseUnit.m_DoseLevel->Update(DoseLevel))
  3418. {
  3419. mLog::Debug("HW_VPC: DoseLevel update to [{$}]", DoseLevel);
  3420. FireNotify(AttrKey::FLUDoseLevel, m_DoseUnit.m_DoseLevel->Get());
  3421. }
  3422. //ABS
  3423. int abs = atoi(paramList[3].c_str());
  3424. switch (abs)
  3425. {
  3426. case 0:
  3427. {
  3428. if (m_DoseUnit.m_ABSStatus->Update(AttrKey::GENERATOR_ABS_ON_KV))
  3429. {
  3430. mLog::Debug("HW_VPC: abs update to [on]");
  3431. FireNotify(m_DoseUnit.m_ABSStatus->GetKey(), m_DoseUnit.m_ABSStatus->JSGet());
  3432. }
  3433. }break;
  3434. case 1:
  3435. {
  3436. if (m_DoseUnit.m_ABSStatus->Update(AttrKey::GENERATOR_ABS_OFF))
  3437. {
  3438. mLog::Debug("HW_VPC: abs update to [off]");
  3439. FireNotify(m_DoseUnit.m_ABSStatus->GetKey(), m_DoseUnit.m_ABSStatus->JSGet());
  3440. }
  3441. }break;
  3442. }
  3443. //Focus
  3444. if ("S" == paramList[4])
  3445. {
  3446. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  3447. {
  3448. mLog::Debug("HW_VPC: Focus update to [SMALL]");
  3449. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3450. }
  3451. }
  3452. else if ("L" == paramList[4])
  3453. {
  3454. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  3455. {
  3456. mLog::Debug("HW_VPC: Focus update to [LARGE]");
  3457. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3458. }
  3459. }
  3460. }
  3461. else
  3462. {
  3463. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3464. }
  3465. };
  3466. //此命令用于验证手动荧光检测的接收参数:参见FPM命令
  3467. auto HW_VPM = [this](vector <string>& paramList) -> void
  3468. {
  3469. if (paramList.size() >= 4)
  3470. {
  3471. //%.1f %.2f %c
  3472. mLog::Debug("HW_VPM: UT[{$}], IT[{$}], Focus[{$}]",
  3473. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str());
  3474. //FluMode
  3475. if (m_DoseUnit.m_FLMode->Update(AttrKey::GENERATOR_FLMODE_CF))
  3476. {
  3477. mLog::Debug("HW_VPM: FluMode update to [{$}] -> GENERATOR_FLMODE_CF", m_DoseUnit.m_FLMode->Get());
  3478. FireNotify(AttrKey::FLUMode, m_DoseUnit.m_FLMode->JSGet());
  3479. }
  3480. //KV
  3481. float KV = atof(paramList[1].c_str());
  3482. if (m_DoseUnit.m_FLKV->Update(KV))
  3483. {
  3484. mLog::Debug("HW_VPM: KV update to [{$}]", KV);
  3485. FireNotify(m_DoseUnit.m_FLKV->GetKey(), m_DoseUnit.m_FLKV->Get());
  3486. }
  3487. //MA
  3488. float MA = atof(paramList[2].c_str());
  3489. if (m_DoseUnit.m_FLMA->Update(MA))
  3490. {
  3491. mLog::Debug("HW_VPM: MA update to [{$}]", MA);
  3492. FireNotify(m_DoseUnit.m_FLMA->GetKey(), m_DoseUnit.m_FLMA->Get());
  3493. }
  3494. //Focus
  3495. if ("S" == paramList[3])
  3496. {
  3497. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  3498. {
  3499. mLog::Debug("HW_VPM: Focus update to [SMALL]");
  3500. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3501. }
  3502. }
  3503. else if ("L" == paramList[3])
  3504. {
  3505. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  3506. {
  3507. mLog::Debug("HW_VPM: Focus update to [LARGE]");
  3508. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3509. }
  3510. }
  3511. }
  3512. else
  3513. {
  3514. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3515. }
  3516. };
  3517. //该命令用于验证脉冲荧光的接收参数:参见FPP命令
  3518. auto HW_VPP = [this](vector <string>& paramList) -> void
  3519. {
  3520. if (paramList.size() >= 10)
  3521. {
  3522. //%u %u %.1f %.1f %.1f %u %.1f %u %c
  3523. mLog::Debug("HW_VPP: Curve type[{$}], Stop[{$}], UT[{$}], IT[{$}], X-ray time[{$}], max.time[{$}], fps[{$}], Dose/pulse[{$}], Focus[{$}]",
  3524. paramList[1].c_str(), paramList[2].c_str(), paramList[3].c_str(), paramList[4].c_str(), paramList[5].c_str(),
  3525. paramList[6].c_str(), paramList[7].c_str(), paramList[8].c_str(), paramList[9].c_str());
  3526. //FluMode
  3527. if (m_DoseUnit.m_FLMode->Update(AttrKey::GENERATOR_FLMODE_PF))
  3528. {
  3529. mLog::Debug("HW_VPP: FluMode update to [{$}] -> GENERATOR_FLMODE_PF", m_DoseUnit.m_FLMode->Get());
  3530. FireNotify(AttrKey::FLUMode, m_DoseUnit.m_FLMode->JSGet());
  3531. }
  3532. //DoseLevel
  3533. int DoseLevel = atoi(paramList[1].c_str());
  3534. if (m_DoseUnit.m_DoseLevel->Update(DoseLevel))
  3535. {
  3536. mLog::Debug("HW_VPP: DoseLevel update to [{$}]", DoseLevel);
  3537. FireNotify(AttrKey::FLUDoseLevel, m_DoseUnit.m_DoseLevel->Get());
  3538. }
  3539. //ABS
  3540. int abs = atoi(paramList[2].c_str());
  3541. switch (abs)
  3542. {
  3543. case 0:
  3544. {
  3545. if (m_DoseUnit.m_ABSStatus->Update(AttrKey::GENERATOR_ABS_ON_KV))
  3546. {
  3547. mLog::Debug("HW_VPP: abs update to [on]");
  3548. FireNotify(m_DoseUnit.m_ABSStatus->GetKey(), m_DoseUnit.m_ABSStatus->JSGet());
  3549. }
  3550. }break;
  3551. case 1:
  3552. {
  3553. if (m_DoseUnit.m_ABSStatus->Update(AttrKey::GENERATOR_ABS_OFF))
  3554. {
  3555. mLog::Debug("HW_VPP: abs update to [off]");
  3556. FireNotify(m_DoseUnit.m_ABSStatus->GetKey(), m_DoseUnit.m_ABSStatus->JSGet());
  3557. }
  3558. }break;
  3559. }
  3560. //KV
  3561. float KV = atof(paramList[3].c_str());
  3562. if (m_DoseUnit.m_FLKV->Update(KV))
  3563. {
  3564. mLog::Debug("HW_VPP: KV update to [{$}]", KV);
  3565. FireNotify(m_DoseUnit.m_FLKV->GetKey(), m_DoseUnit.m_FLKV->Get());
  3566. }
  3567. //MA
  3568. float MA = atof(paramList[4].c_str());
  3569. if (m_DoseUnit.m_FLMA->Update(MA))
  3570. {
  3571. mLog::Debug("HW_VPP: MA update to [{$}]", MA);
  3572. FireNotify(m_DoseUnit.m_FLMA->GetKey(), m_DoseUnit.m_FLMA->Get());
  3573. }
  3574. //MS
  3575. float MS = atof(paramList[5].c_str());
  3576. if (m_DoseUnit.m_FLMS->Update(MS))
  3577. {
  3578. mLog::Debug("HW_VPP: Post pulse length ms update to [{$}]", MS);
  3579. FireNotify(m_DoseUnit.m_FLMS->GetKey(), m_DoseUnit.m_FLMS->Get());
  3580. }
  3581. //PPS
  3582. float PPS = atof(paramList[7].c_str());
  3583. if (m_DoseUnit.m_PPS->Update(PPS))
  3584. {
  3585. mLog::Debug("HW_VPP: PPS update to [{$}]", PPS);
  3586. FireNotify(AttrKey::FLUPPS, m_DoseUnit.m_PPS->Get());
  3587. }
  3588. //Focus
  3589. if ("S" == paramList[9])
  3590. {
  3591. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_SMALL))
  3592. {
  3593. mLog::Debug("HW_VPP: Focus update to [SMALL]");
  3594. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3595. }
  3596. }
  3597. else if ("L" == paramList[9])
  3598. {
  3599. if (m_DoseUnit.m_Focus->Update(AttrKey::FOCUS_LARGE))
  3600. {
  3601. mLog::Debug("HW_VPP: Focus update to [LARGE]");
  3602. FireNotify(AttrKey::FOCUS, m_DoseUnit.m_Focus->JSGet());
  3603. }
  3604. }
  3605. }
  3606. else
  3607. {
  3608. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3609. }
  3610. };
  3611. //此命令可用于测试串行端口:String
  3612. auto HW_COMTEST = [this](vector <string>& paramList) -> void
  3613. {
  3614. if (paramList.size() >= 2)
  3615. {
  3616. //%s
  3617. mLog::Debug("HW_COMTEST: test serial port [{$}]",
  3618. paramList[1].c_str());
  3619. }
  3620. else
  3621. {
  3622. mLog::Warn("commands[{$}] item count[{$}] not right", paramList[0].c_str(), paramList.size());
  3623. }
  3624. };
  3625. arFrame.clear();
  3626. arFrame[">AD2"] = tFrameMapItem(HW_AD2);
  3627. arFrame[">AD2Timemax"] = tFrameMapItem(HW_AD2Timemax);
  3628. arFrame[">AD2Timemin"] = tFrameMapItem(HW_AD2Timemin);
  3629. arFrame[">AD2End"] = tFrameMapItem(HW_AD2End);
  3630. arFrame[">AD3kV"] = tFrameMapItem(HW_AD3kV);
  3631. arFrame[">AD3ms"] = tFrameMapItem(HW_AD3ms);
  3632. arFrame[">AD3mAs"] = tFrameMapItem(HW_AD3mAs);
  3633. arFrame[">AD3End"] = tFrameMapItem(HW_AD3End);
  3634. arFrame[">AC2"] = tFrameMapItem(HW_AC2);
  3635. arFrame[">AC3"] = tFrameMapItem(HW_AC3);
  3636. arFrame[">AS2"] = tFrameMapItem(HW_AS2);
  3637. arFrame[">AS3"] = tFrameMapItem(HW_AS3);
  3638. arFrame[">DAP"] = tFrameMapItem(HW_DAP);
  3639. arFrame[">EPA"] = tFrameMapItem(HW_EPA);
  3640. arFrame[">ERR"] = tFrameMapItem(HW_ERR);
  3641. arFrame[">EXP"] = tFrameMapItem(HW_EXP);
  3642. arFrame[">SDN"] = tFrameMapItem(HW_SDN);
  3643. arFrame[">GRD"] = tFrameMapItem(HW_GRD);
  3644. arFrame[">GST"] = tFrameMapItem(HW_GST);
  3645. arFrame[">IFV"] = tFrameMapItem(HW_IFV);
  3646. arFrame[">INI"] = tFrameMapItem(HW_INI);
  3647. arFrame[">LIM"] = tFrameMapItem(HW_LIM);
  3648. arFrame[">LIT"] = tFrameMapItem(HW_LIT);
  3649. arFrame[">PHU"] = tFrameMapItem(HW_PHU);
  3650. arFrame[">RDY"] = tFrameMapItem(HW_RDY);
  3651. arFrame[">CR"] = tFrameMapItem(HW_CR);
  3652. arFrame[">RXP"] = tFrameMapItem(HW_RXP);
  3653. arFrame[">SBY"] = tFrameMapItem(HW_SBY);
  3654. arFrame[">TWS"] = tFrameMapItem(HW_TWS);
  3655. arFrame[">UNK"] = tFrameMapItem(HW_UNK);
  3656. arFrame[">CRC"] = tFrameMapItem(HW_CRC);
  3657. arFrame[">VD0"] = tFrameMapItem(HW_VD0);
  3658. arFrame[">VD1"] = tFrameMapItem(HW_VD1);
  3659. arFrame[">VD2"] = tFrameMapItem(HW_VD2);
  3660. arFrame[">VD3"] = tFrameMapItem(HW_VD3);
  3661. arFrame[">VA3"] = tFrameMapItem(HW_VA3);
  3662. arFrame[">VP1"] = tFrameMapItem(HW_VP1);
  3663. arFrame[">VP2"] = tFrameMapItem(HW_VP2);
  3664. arFrame[">VP3"] = tFrameMapItem(HW_VP3);
  3665. arFrame[">VS1"] = tFrameMapItem(HW_VS1);
  3666. arFrame[">VS2"] = tFrameMapItem(HW_VS2);
  3667. arFrame[">VS3"] = tFrameMapItem(HW_VS3);
  3668. arFrame[">VRS"] = tFrameMapItem(HW_VRS);
  3669. arFrame[">FBS"] = tFrameMapItem(HW_FBS);
  3670. arFrame[">FPA"] = tFrameMapItem(HW_FPA);
  3671. arFrame[">PPA"] = tFrameMapItem(HW_PPA);
  3672. arFrame[">RFL"] = tFrameMapItem(HW_RFL);
  3673. arFrame[">VPC"] = tFrameMapItem(HW_VPC);
  3674. arFrame[">VPM"] = tFrameMapItem(HW_VPM);
  3675. arFrame[">VPP"] = tFrameMapItem(HW_VPP);
  3676. arFrame[">COMTEST"] = tFrameMapItem(HW_COMTEST);
  3677. return true;
  3678. }
  3679. //获取当前设备状态,固件版本
  3680. void nsGEN::RF80Device::GetState()
  3681. {
  3682. char strSendCMD[GEN_CF80_SEND_LEN_min] = { 0 };
  3683. sprintf_s(strSendCMD, glo_Send_RF80Fun["GST"].strParamArry.c_str());
  3684. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["GST"].struStatus);
  3685. memset(strSendCMD,0,GEN_CF80_SEND_LEN_min);
  3686. sprintf_s(strSendCMD, glo_Send_RF80Fun["RDY"].strParamArry.c_str());
  3687. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["RDY"].struStatus);
  3688. }
  3689. void nsGEN::RF80Device::SetVersion(int ver)
  3690. {
  3691. mLog::Debug("Enter SetVersion:[{$}]", ver);
  3692. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  3693. sprintf_s(strSendCMD, glo_Send_RF80Fun["IFV"].strParamArry.c_str(),
  3694. ver);
  3695. HWSendWaitSelfCMD(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["IFV"].struStatus);
  3696. }
  3697. //添加指令尾
  3698. //接口版本1: 每个命令都是一个字符串,必须以回车符'r\'和换行符'\n'终止。
  3699. //接口版本2; 每个命令都是一个字符串,并且只能以换行符'\n'(Unix样式)终止。最后一个字符是校验和。使用以下函数
  3700. bool nsGEN::RF80Device::FormatCMD(char* pCmd, int& nSize)
  3701. {
  3702. if (nSize > GEN_CF80_SEND_LEN_max)
  3703. {
  3704. mLog::Debug("FormatCMD: lengh[{$}] is too big \n", nSize);
  3705. return false;
  3706. }
  3707. if (m_nVersion = 1)
  3708. {
  3709. pCmd[nSize] = CR;
  3710. nSize++;
  3711. }
  3712. else if (m_nVersion = 2)
  3713. {
  3714. char checksum = 0;
  3715. for (int i = 0; i < nSize; i++)
  3716. checksum += pCmd[i];
  3717. if (checksum < 16)
  3718. checksum += 16;
  3719. pCmd[nSize] = checksum;
  3720. nSize++;
  3721. }
  3722. else
  3723. {
  3724. mLog::Debug("FormatCMD: unknow[{$}] version \n", m_nVersion);
  3725. return false;
  3726. }
  3727. pCmd[nSize] = LF;
  3728. nSize++;
  3729. return true;
  3730. }
  3731. //参数处理
  3732. void nsGEN::RF80Device::Search3PointRange(float kv, float mas, int focus)
  3733. {
  3734. char tempFocus = 'S';
  3735. if (AttrKey::FOCUS_SMALL == focus)
  3736. {
  3737. tempFocus = 'S';
  3738. }
  3739. else if (AttrKey::FOCUS_LARGE == focus)
  3740. {
  3741. tempFocus = 'L';
  3742. }
  3743. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  3744. sprintf_s(strSendCMD, glo_Send_RF80Fun["CP3"].strParamArry.c_str(),
  3745. kv, mas, tempFocus);
  3746. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["CP3"].struStatus);
  3747. }
  3748. void nsGEN::RF80Device::Search2PointRange(float kv, int focus)
  3749. {
  3750. char tempFocus = 'S';
  3751. if (AttrKey::FOCUS_SMALL == focus)
  3752. {
  3753. tempFocus = 'S';
  3754. }
  3755. else if (AttrKey::FOCUS_LARGE == focus)
  3756. {
  3757. tempFocus = 'L';
  3758. }
  3759. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  3760. sprintf_s(strSendCMD, glo_Send_RF80Fun["CP2"].strParamArry.c_str(),
  3761. kv, m_nCfgTubeLoad, tempFocus);
  3762. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["CP2"].struStatus);
  3763. }
  3764. bool nsGEN::RF80Device::CheckRadLimitValue(int techMode, int focus, float kv, float & mas, float& ma) //mode
  3765. {
  3766. if (m_RadLimitFlag)
  3767. {
  3768. m_RadLimitFlag = false;
  3769. mLog::Debug("CheckLimitValue:[{$}]", techMode);
  3770. switch (techMode)
  3771. {
  3772. case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_2P:
  3773. case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_2P:
  3774. {
  3775. Search2PointRange(kv, focus);
  3776. if (WaitForSingleObject(m_hRadLimitMASEvent, 2000) == WAIT_OBJECT_0)
  3777. {
  3778. mLog::Debug("m_hRadLimitMASEvent = true");
  3779. if (m_fCurMinMAS < m_fCurMaxMAS)
  3780. {
  3781. if (mas < m_fCurMinMAS)
  3782. {
  3783. mLog::Warn("set MAS[{$}] too small[{$}]", mas, m_fCurMinMAS);
  3784. mas = m_fCurMinMAS;
  3785. }
  3786. if (mas > m_fCurMaxMAS)
  3787. {
  3788. mLog::Warn("set MAS[{$}] too big[{$}]", mas, m_fCurMaxMAS);
  3789. mas = m_fCurMaxMAS;
  3790. }
  3791. }
  3792. return true;
  3793. }
  3794. else
  3795. {
  3796. mLog::Warn("m_hRadLimitMASEvent timeout");
  3797. return false;
  3798. }
  3799. }break;
  3800. case AttrKey::TECHMODE_TYPE::TECHMODE_NOAEC_3P:
  3801. case AttrKey::TECHMODE_TYPE::TECHMODE_AEC_3P:
  3802. {
  3803. Search2PointRange(kv, focus);
  3804. if (WaitForSingleObject(m_hRadLimitMASEvent, 2000) == WAIT_OBJECT_0)
  3805. {
  3806. mLog::Debug("m_hRadLimitMASEvent = true");
  3807. if (m_fCurMinMAS < m_fCurMaxMAS)
  3808. {
  3809. if (mas < m_fCurMinMAS)
  3810. {
  3811. mLog::Warn("set MAS[{$}] too small[{$}]", mas, m_fCurMinMAS);
  3812. mas = m_fCurMinMAS;
  3813. }
  3814. if (mas > m_fCurMaxMAS)
  3815. {
  3816. mLog::Warn("set MAS[{$}] too big[{$}]", mas, m_fCurMaxMAS);
  3817. mas = m_fCurMaxMAS;
  3818. }
  3819. }
  3820. Search3PointRange(kv, mas, focus);
  3821. if (WaitForSingleObject(m_hRadLimitMAEvent, 2000) == WAIT_OBJECT_0)
  3822. {
  3823. mLog::Debug("m_hRadLimitMAEvent = true");
  3824. if (m_fCurMinMA < m_fCurMaxMA)
  3825. {
  3826. if (ma < m_fCurMinMA)
  3827. {
  3828. mLog::Warn("set MA[{$}] too small[{$}]", ma, m_fCurMinMA);
  3829. ma = m_fCurMinMA;
  3830. }
  3831. if (ma > m_fCurMaxMA)
  3832. {
  3833. mLog::Warn("set MA[{$}] too big[{$}]", ma, m_fCurMaxMA);
  3834. ma = m_fCurMaxMA;
  3835. }
  3836. }
  3837. return true;
  3838. }
  3839. else
  3840. {
  3841. mLog::Warn("m_hRadLimitMAEvent timeout");
  3842. return false;
  3843. }
  3844. }
  3845. else
  3846. {
  3847. mLog::Warn("m_hRadLimitMASEvent timeout");
  3848. return false;
  3849. }
  3850. }break;
  3851. }
  3852. }
  3853. return false;
  3854. }
  3855. bool nsGEN::RF80Device::CheckFluFPSMaxKW(float kv, float ma)
  3856. {
  3857. for (auto p : m_mapFPSMaxKW)
  3858. {
  3859. float tempPPS = m_DoseUnit.m_PPS->Get();
  3860. if (abs(p.first - tempPPS) < 0.1)//find
  3861. {
  3862. if (kv * ma > p.second)
  3863. {
  3864. return false;//over max kw.do nothing.
  3865. }
  3866. else
  3867. {
  3868. return true;
  3869. }
  3870. }
  3871. }
  3872. return false;
  3873. }
  3874. int nsGEN::RF80Device::TurnAECFieldSel(bool isToGen, const int value)
  3875. {
  3876. int AECFieldSel = -1;
  3877. if (isToGen)
  3878. {
  3879. switch (value)
  3880. {
  3881. case 100:
  3882. AECFieldSel = 1;
  3883. break;
  3884. case 10:
  3885. AECFieldSel = 2;
  3886. break;
  3887. case 110:
  3888. AECFieldSel = 3;
  3889. break;
  3890. case 1:
  3891. AECFieldSel = 4;
  3892. break;
  3893. case 101:
  3894. AECFieldSel = 5;
  3895. break;
  3896. case 11:
  3897. AECFieldSel = 6;
  3898. break;
  3899. case 111:
  3900. AECFieldSel = 7;
  3901. break;
  3902. default:
  3903. AECFieldSel = 2;
  3904. break;
  3905. }
  3906. }
  3907. else
  3908. {
  3909. switch (value)
  3910. {
  3911. case 1:
  3912. AECFieldSel = 100;
  3913. break;
  3914. case 2:
  3915. AECFieldSel = 10;
  3916. break;
  3917. case 3:
  3918. AECFieldSel = 110;
  3919. break;
  3920. case 4:
  3921. AECFieldSel = 1;
  3922. break;
  3923. case 5:
  3924. AECFieldSel = 101;
  3925. break;
  3926. case 6:
  3927. AECFieldSel = 11;
  3928. break;
  3929. case 7:
  3930. AECFieldSel = 111;
  3931. break;
  3932. default:
  3933. AECFieldSel = 10;
  3934. break;
  3935. }
  3936. }
  3937. return AECFieldSel;
  3938. }
  3939. int nsGEN::RF80Device::TurnAECFilmSel(bool isToGen, int value)
  3940. {
  3941. int AECFilmSel = -1;
  3942. if (isToGen)
  3943. {
  3944. if (value == 1)
  3945. {
  3946. AECFilmSel = 'D'; //Low sensitivity
  3947. }
  3948. else if (value == 10)
  3949. {
  3950. AECFilmSel = 'U'; //medium sensitivity
  3951. }
  3952. else if (value == 100)
  3953. {
  3954. AECFilmSel = 'H'; //high sensitivity
  3955. }
  3956. else
  3957. {
  3958. AECFilmSel = 'D';
  3959. }
  3960. }
  3961. else
  3962. {
  3963. switch (value)
  3964. {
  3965. case 'H':
  3966. AECFilmSel = 100;
  3967. break;
  3968. case 'U':
  3969. AECFilmSel = 10;
  3970. break;
  3971. case 'D':
  3972. AECFilmSel = 1;
  3973. break;
  3974. default:
  3975. AECFilmSel = 10;
  3976. break;
  3977. }
  3978. }
  3979. return AECFilmSel;
  3980. }
  3981. void nsGEN::RF80Device::DetectorReady()
  3982. {
  3983. mLog::Debug("Enter DetectorReady[{$}]", m_bIsSendSCUFPDReady);
  3984. if (m_bIsSendSCUFPDReady)
  3985. {
  3986. char strSendCMD[GEN_CF80_SEND_LEN_min] = { 0 };
  3987. sprintf_s(strSendCMD, glo_Send_RF80Fun["RDR"].strParamArry.c_str());
  3988. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["RDR"].struStatus);
  3989. }
  3990. }
  3991. void nsGEN::RF80Device::SetLastParambeforeEXP(RF80_TechMode lastTech, string CMDid, const char* CMDdata)
  3992. {
  3993. mLog::Debug("Enter SetLastParambeforeEXP[{$}]", (int)lastTech);
  3994. switch (lastTech)
  3995. {
  3996. case RF80Tech_RAD:
  3997. {
  3998. m_LastTechMode = RF80Tech_RAD;
  3999. m_LastParamArry[RF80Tech_RAD].SetData(CMDid, CMDdata);
  4000. }break;
  4001. case RF80Tech_FLU:
  4002. {
  4003. m_LastTechMode = RF80Tech_FLU;
  4004. m_LastParamArry[RF80Tech_FLU].SetData(CMDid, CMDdata);
  4005. }break;
  4006. case RF80Tech_FLU_MAX:
  4007. break;
  4008. default:
  4009. break;
  4010. }
  4011. }
  4012. //设置曝光状态
  4013. void nsGEN::RF80Device::SetRadStatus(int PreContact, int MainContact)
  4014. {
  4015. mLog::Debug("Enter SetRadStatus[{$},{$}]", PreContact, MainContact);
  4016. if (m_ExpReady[0] != '1')
  4017. {
  4018. mLog::Warn("SetRadStatus:not in RAD ready");
  4019. return;
  4020. }
  4021. if (0 == PreContact && 0 == MainContact)
  4022. {
  4023. mLog::Debug("EXPSTATE: [{$}] -> PR0", m_DoseUnit.m_GenSynState->Get());
  4024. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_OFF))
  4025. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  4026. m_XrayReady = "00";
  4027. mLog::Debug("current XrayReady: [{$}]", m_XrayReady.c_str());
  4028. }
  4029. else if (0 != PreContact && 0 == MainContact)
  4030. {
  4031. m_XrayReady[0] = '1';
  4032. mLog::Debug("current XrayReady: [{$}]", m_XrayReady.c_str());
  4033. if (m_DoseUnit.m_GenSynState->Get() == AttrKey::GENERATOR_RAD_XRAYON)
  4034. {
  4035. mLog::Debug("EXPSTATE: [{$}] -> XR0", m_DoseUnit.m_GenSynState->Get());
  4036. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_XRAYOFF))
  4037. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  4038. }
  4039. else
  4040. {
  4041. mLog::Debug("EXPSTATE: [{$}] -> PR1", m_DoseUnit.m_GenSynState->Get());
  4042. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_RAD_PREPARE))
  4043. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  4044. }
  4045. }
  4046. else if (0 != PreContact && 0 != MainContact)
  4047. {
  4048. //只用于触发"<SXP 1/2 1/2 0/1"自动发送
  4049. }
  4050. mLog::Debug("currSYNmode:WS[{$}:{$}]", m_arrWSMap[m_strCurrentWSName].strWSNAme.c_str(), (int)m_nSYNMode);
  4051. if (PreContact)
  4052. {
  4053. PreContact = m_nSYNMode;
  4054. }
  4055. if (MainContact)
  4056. {
  4057. MainContact = m_nSYNMode;
  4058. }
  4059. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  4060. sprintf_s(strSendCMD, glo_Send_RF80Fun["SXP"].strParamArry.c_str(),
  4061. PreContact, MainContact, m_RadMode);
  4062. if (("00" == m_bIsSendSXPByRxpFlag) && (0 == PreContact && 0 == MainContact))
  4063. {
  4064. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SXP"].struStatus);
  4065. }
  4066. else if (("10" == m_bIsSendSXPByRxpFlag) && (0 == MainContact))
  4067. {
  4068. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SXP"].struStatus);
  4069. }
  4070. else if ("11" == m_bIsSendSXPByRxpFlag)
  4071. {
  4072. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SXP"].struStatus);
  4073. if (0 != PreContact && 0 != MainContact)
  4074. {
  4075. DetectorReady();
  4076. }
  4077. }
  4078. }
  4079. void nsGEN::RF80Device::SetFluStatus(int PreContact, int MainContact)
  4080. {
  4081. mLog::Debug("Enter SetFluStatus[{$},{$}]", PreContact, MainContact);
  4082. if (m_ExpReady[1] != '1')
  4083. {
  4084. mLog::Warn("SetFluStatus:not in Flu ready");
  4085. return;
  4086. }
  4087. if (0 == PreContact && 0 == MainContact)
  4088. {
  4089. mLog::Debug("EXPSTATE: [{$}] -> FLU0", m_DoseUnit.m_GenSynState->Get());
  4090. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_OFF))
  4091. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  4092. }
  4093. else if (0 != PreContact && 0 == MainContact)
  4094. {
  4095. if (m_DoseUnit.m_GenSynState->Get() == AttrKey::GENERATOR_FLU_XRAYON)
  4096. {
  4097. mLog::Debug("EXPSTATE: [{$}] -> FLX0", m_DoseUnit.m_GenSynState->Get());
  4098. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_XRAYOFF))
  4099. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  4100. }
  4101. else
  4102. {
  4103. mLog::Debug("EXPSTATE: [{$}] -> FLU1", m_DoseUnit.m_GenSynState->Get());
  4104. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_READY))
  4105. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  4106. }
  4107. }
  4108. else if (0 != PreContact && 0 != MainContact)
  4109. {
  4110. if (m_DoseUnit.m_GenSynState->Get() != AttrKey::GENERATOR_FLU_READY)
  4111. {
  4112. mLog::Debug("EXPSTATE: [{$}] -> FLU1", m_DoseUnit.m_GenSynState->Get());
  4113. if (m_DoseUnit.m_GenSynState->Update(AttrKey::GENERATOR_FLU_READY))
  4114. FireNotify(m_DoseUnit.m_GenSynState->GetKey(), m_DoseUnit.m_GenSynState->JSGet());
  4115. }
  4116. }
  4117. mLog::Debug("currSYNmode:WS[{$}:{$}]", m_arrWSMap[m_strCurrentWSName].strWSNAme.c_str(), (int)m_nSYNMode);
  4118. bool softSyn = false;
  4119. if (m_DoseUnit.m_FLMode->Get() == AttrKey::GENERATOR_FLMODE_CF ||
  4120. m_DoseUnit.m_FLMode->Get() == AttrKey::GENERATOR_FLMODE_HCF)
  4121. {
  4122. if (PreContact)
  4123. {
  4124. PreContact = m_nSYNMode;
  4125. }
  4126. if (MainContact)
  4127. {
  4128. MainContact = m_nSYNMode;
  4129. }
  4130. }
  4131. if((0 != PreContact && 0 != MainContact) || (0 == PreContact && 0 == MainContact))
  4132. {
  4133. char strSendCMD[GEN_CF80_SEND_LEN_max] = { 0 };
  4134. sprintf_s(strSendCMD, glo_Send_RF80Fun["SFL"].strParamArry.c_str(),
  4135. PreContact);
  4136. if (("0" == m_bIsSendSFLByRxpFlag) && (0 == PreContact))
  4137. {
  4138. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SFL"].struStatus);
  4139. }
  4140. else if ("1" == m_bIsSendSFLByRxpFlag)
  4141. {
  4142. HWSendFirst(strSendCMD, strlen(strSendCMD), glo_Send_RF80Fun["SFL"].struStatus);
  4143. }
  4144. }
  4145. }
  4146. void nsGEN::RF80Device::SetSynBoxSwitchStatus(bool flag)
  4147. {
  4148. mLog::Debug("Enter SetSynBoxSwitchStatus[{$}]", m_bNeedSendToSynBox);
  4149. if (m_bNeedSendToSynBox)
  4150. {
  4151. m_bNeedSendToSynBox = false;
  4152. #if Ccos_V3
  4153. if (m_pGenClient != NULL)
  4154. {
  4155. if (!m_pGenClient->IsClosed())
  4156. {
  4157. std::vector <string> paramList;
  4158. StrSubstrData(m_SignalArray.c_str(), (char)TAB, paramList,0);
  4159. ResDataObject Request, Response;
  4160. for (auto item : paramList)
  4161. {
  4162. mLog::Debug("DV3_FullUCB Client execute [SimulateSwitchSignal][{$}]", item.c_str());
  4163. Request.add("P0", item.c_str());
  4164. }
  4165. m_pGenClient->Action("SimulateSwitchSignal", Request, Response, 4993, "CCOS/DEVICE/SynBox");
  4166. }
  4167. else
  4168. {
  4169. mLog::Debug("DV3_FullUCB Client is Close");
  4170. }
  4171. }
  4172. else
  4173. {
  4174. mLog::Debug("DV3_FullUCB Client is NULL");
  4175. }
  4176. #endif
  4177. }
  4178. }
  4179. /*下面的线程函数,其实用来充当定时器功能。*/
  4180. bool nsGEN::RF80Device::StartHardwareStatusThread()
  4181. {
  4182. mLog::Debug("Enter StartHardwareStatusThread");
  4183. if (m_pHardwareStatusThread == NULL)
  4184. {
  4185. DWORD m_HardwareStatusID;
  4186. m_pHardwareStatusThread = CreateThread(0, 0, HardwareStatusThread, this, 0, &m_HardwareStatusID);
  4187. if (m_pHardwareStatusThread == NULL)
  4188. {
  4189. mLog::Error("Start HardwareStatus Thread Failed");
  4190. return false;
  4191. }
  4192. }
  4193. return true;
  4194. }
  4195. DWORD nsGEN::RF80Device::HardwareStatusThread(LPVOID pParam)
  4196. {
  4197. mLog::Debug("Enter HardwareStatusThread");
  4198. RF80Device* pCurGen = (RF80Device*)pParam;
  4199. if (pCurGen == NULL)
  4200. {
  4201. return 0;
  4202. }
  4203. if (pCurGen->m_GenConfig.GetFirstOf("loopTime") >= 0)
  4204. {
  4205. if ((int)pCurGen->m_GenConfig["loopTime"] >= 100)
  4206. {
  4207. pCurGen->m_iLoopTime = (int)pCurGen->m_GenConfig["loopTime"];
  4208. }
  4209. }
  4210. mLog::Debug("loopTime = {$}", pCurGen->m_iLoopTime);
  4211. int currtTime = pCurGen->m_iLoopTime;
  4212. if (0 == currtTime)
  4213. {
  4214. return 0;
  4215. }
  4216. int waitTime = INFINITE;
  4217. DWORD event = 0;
  4218. bool bExit = false;
  4219. while (!bExit)
  4220. {
  4221. event = WaitForMultipleObjects(2, pCurGen->m_hArrayEvent, FALSE, waitTime);
  4222. switch (event)
  4223. {
  4224. case WAIT_OBJECT_0:
  4225. {
  4226. mLog::Debug("HardwareStatusThread: exited");
  4227. bExit = TRUE;
  4228. return 0;
  4229. }break;
  4230. case (WAIT_TIMEOUT):
  4231. {
  4232. mLog::Warn("HardwareStatusThread: Get loop EVENT timeout");
  4233. }break;
  4234. case (WAIT_OBJECT_0 + 1):
  4235. {
  4236. //曝光允许
  4237. int expReady = false;
  4238. {
  4239. if (pCurGen->m_ExpReady == "11")
  4240. {
  4241. expReady = true;
  4242. }
  4243. else if (pCurGen->m_ExpReady == "10")
  4244. {
  4245. if (pCurGen->m_DoseUnit.m_FLMode->Get() == AttrKey::GENERATOR_FLMODE_NOTFLU)
  4246. {
  4247. expReady = true;
  4248. }
  4249. }
  4250. else if (pCurGen->m_ExpReady == "01")
  4251. {
  4252. if (pCurGen->m_DoseUnit.m_FLMode->Get() == AttrKey::GENERATOR_FLMODE_NOTFLU)
  4253. {
  4254. expReady = true;
  4255. }
  4256. }
  4257. }
  4258. //等待
  4259. Sleep(currtTime);
  4260. //发送状态查询
  4261. if (!expReady)
  4262. {
  4263. pCurGen->GetState();
  4264. }
  4265. //判断是否停止轮询
  4266. if (expReady)
  4267. {
  4268. ResetEvent(pCurGen->m_hLoopEvent);
  4269. }
  4270. }break;
  4271. default:
  4272. {
  4273. mLog::Debug("HardwareStatusThread: unknown event");
  4274. }break;
  4275. }
  4276. }
  4277. return 0;
  4278. }
  4279. //查找响应操作对照表执行对应操作
  4280. static bool DecodeFrame(const char* strFrame, int length)
  4281. {
  4282. std::vector <string> paramList;
  4283. StrSubstrData(strFrame, (char)TAB, paramList);
  4284. //if (!paramList.empty())
  4285. {
  4286. auto found = arFrame.find(paramList[0]);//此处pr用来在arFrame中找到对于的包头
  4287. if (found == arFrame.end())
  4288. {
  4289. return false;
  4290. }
  4291. found->second.m_fFun(paramList);
  4292. }
  4293. return true;
  4294. }
  4295. //-----------------------------------------------------------------------------
  4296. // GenDriver
  4297. //-----------------------------------------------------------------------------
  4298. nsGEN::RF80Driver::RF80Driver ()
  4299. {
  4300. m_pAttribute.reset(new ResDataObject());
  4301. m_pDescription.reset(new ResDataObject());
  4302. }
  4303. nsGEN::RF80Driver::~RF80Driver ()
  4304. {
  4305. }
  4306. auto nsGEN::RF80Driver::CreateDevice (int index) -> std::unique_ptr <IODevice>
  4307. {
  4308. if (!m_SCF.isConnected())
  4309. return nullptr;
  4310. auto dev = std::unique_ptr <IODevice>(new IODevice(new RF80Device(EventCenter, m_SCF,m_ConfigFileName)));
  4311. return dev;
  4312. }
  4313. void nsGEN::RF80Driver::FireNotify (int code, std::string key, std::string content)
  4314. {
  4315. EventCenter->OnNotify (code, key, content);
  4316. }
  4317. void nsGEN::RF80Driver::Prepare ()
  4318. {
  4319. string strLogPath = GetProcessDirectory();
  4320. string::size_type PlatformFlag = strLogPath.find("\\PlatformModule");
  4321. if (PlatformFlag != string::npos)
  4322. {
  4323. strLogPath.resize(PlatformFlag);
  4324. }
  4325. strLogPath += R"(\OEMDrivers\Generator\Conf\Log4CPP.Config.GEN.xml)";
  4326. Log4CPP::GlobalContext::Map::Set(ECOM::Utility::Hash("LogFileName"), "GEN.Simens");
  4327. auto rc = Log4CPP::LogManager::LoadConfigFile(strLogPath.c_str());
  4328. mLog::gLogger = Log4CPP::LogManager::GetLogger("GEN.Simens");
  4329. m_SCFDllName = GetConnectDLL(m_ConfigFileName);
  4330. super::Prepare ();
  4331. }
  4332. bool DATA_ACTION nsGEN::RF80Driver::Connect ()
  4333. {
  4334. ResDataObject Connection = GetConnectParam(m_ConfigFileName);
  4335. mLog::Info("connections:{$} \n", Connection.encode());
  4336. auto erCode = m_SCF.Connect(Connection.encode(), &nsGEN::RF80Driver::callbackPackageProcess, SCF_PACKET_TRANSFER, 3000);
  4337. if (erCode != SCF_ERR::SCF_SUCCEED)
  4338. return false;
  4339. auto rc = super::Connect();
  4340. if (!rc)
  4341. return false;
  4342. return true;
  4343. }
  4344. void nsGEN::RF80Driver::Disconnect()
  4345. {
  4346. super::Disconnect();
  4347. m_SCF.Disconnect();
  4348. }
  4349. bool nsGEN::RF80Driver::isConnected() const
  4350. {
  4351. return super::isConnected();
  4352. }
  4353. std::string nsGEN::RF80Driver::DriverProbe ()
  4354. {
  4355. ResDataObject r_config, HardwareInfo;
  4356. if (r_config.loadFile (m_ConfigFileName.c_str ()))
  4357. {
  4358. HardwareInfo.add ("MajorID", r_config ["CONFIGURATION"] ["MajorID"]);
  4359. HardwareInfo.add ("MinorID", r_config ["CONFIGURATION"] ["MinorID"]);
  4360. HardwareInfo.add ("VendorID", r_config ["CONFIGURATION"] ["VendorID"]);
  4361. HardwareInfo.add ("ProductID", r_config ["CONFIGURATION"] ["ProductID"]);
  4362. HardwareInfo.add ("SerialID", r_config ["CONFIGURATION"] ["SerialID"]);
  4363. }
  4364. else
  4365. {
  4366. HardwareInfo.add ("MajorID", "Generator");
  4367. HardwareInfo.add ("MinorID", "Dr");
  4368. HardwareInfo.add("VendorID", "ECOM");
  4369. HardwareInfo.add("ProductID", "Template");
  4370. HardwareInfo.add ("SerialID", "Drv");
  4371. }
  4372. string ret = HardwareInfo.encode ();
  4373. return ret;
  4374. }
  4375. bool nsGEN::RF80Driver::GetDeviceConfig(std::string& Cfg)
  4376. {
  4377. Cfg = m_DeviceConfigSend.encode();
  4378. return true;
  4379. }
  4380. bool nsGEN::RF80Driver::SetDeviceConfig(std::string Cfg)
  4381. {
  4382. mLog::Info("--Func-- SetDeviceConfig {$}\n", Cfg.c_str());
  4383. ResDataObject DeviceConfig;
  4384. DeviceConfig.decode(Cfg.c_str());
  4385. ResDataObject DescriptionTempEx;
  4386. DescriptionTempEx = DeviceConfig["DeviceConfig"]["Attribute"];
  4387. mLog::Debug("Attribute:{$}", DescriptionTempEx.encode());
  4388. bool bSaveFile = false; //true:重新保存配置文件
  4389. string strAccess = "";
  4390. for (int i = 0; i < DescriptionTempEx.size(); i++)
  4391. {
  4392. string strKey = DescriptionTempEx.GetKey(i);
  4393. mLog::Info("{$}", strKey.c_str());
  4394. try
  4395. {
  4396. if (m_pAttribute->GetFirstOf(strKey.c_str()) >= 0)
  4397. {
  4398. strAccess = (string)(*m_pDescription)[strKey.c_str()]["Access"];
  4399. if ("RW" == strAccess)
  4400. {
  4401. //修改对应配置,在其他单元的配置项要同时调用其修改函数修改真实值
  4402. //1. 修改内存中的值,用于给上层发消息
  4403. (*m_pAttribute)[strKey.c_str()] = DescriptionTempEx[i];
  4404. //2. 拿到Innerkey
  4405. int nConfigInfoCount = (int)m_Configurations["ConfigToolInfo"].GetKeyCount("AttributeInfo");
  4406. mLog::Info("nConfigInfoCount {$}", nConfigInfoCount);
  4407. string strTemp = ""; //存储AttributeKey
  4408. for (int nInfoIndex = 0; nInfoIndex < nConfigInfoCount; nInfoIndex++)
  4409. {
  4410. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeKey"];
  4411. if (strTemp == strKey)
  4412. {
  4413. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["InnerKey"];
  4414. break;
  4415. }
  4416. }
  4417. //3. 修改配置文件中的值
  4418. if (SetDeviceConfigValue(m_Configurations, strTemp.c_str(), 1, DescriptionTempEx[i]))
  4419. {
  4420. mLog::Debug("SetDeviceConfigValue over");
  4421. bSaveFile = true;
  4422. }
  4423. }
  4424. else
  4425. {
  4426. mLog::Info("{$} is not a RW configuration item", strKey.c_str());
  4427. }
  4428. }
  4429. else
  4430. {
  4431. mLog::Info("without this attribute {$}", strKey.c_str());
  4432. }
  4433. }
  4434. catch (ResDataObjectExption& e)
  4435. {
  4436. mLog::Error("SetDriverConfig crashed: {$}", e.what());
  4437. return false;
  4438. }
  4439. }
  4440. if (bSaveFile)
  4441. {
  4442. //3. 重新保存配置文件
  4443. SaveConfigFile(true);
  4444. }
  4445. return true;
  4446. }
  4447. bool nsGEN::RF80Driver::SaveConfigFile(bool bSendNotify)
  4448. {
  4449. m_ConfigAll["CONFIGURATION"] = m_Configurations;
  4450. bool bRt = m_ConfigAll.SaveFile(m_ConfigFileName.c_str());
  4451. mLog::Info("SaveConfigFile over {$}", bRt);
  4452. return true;
  4453. }
  4454. bool nsGEN::RF80Driver::GetDeviceConfigValue(ResDataObject config, const char* pInnerKey, int nPathID, string& strValue)
  4455. {
  4456. strValue = "";
  4457. string strTemp = pInnerKey;
  4458. if (1 == nPathID) //从DriverConfig路径下每个DPC自己的配置文件读取
  4459. {
  4460. size_t pos = 0;
  4461. ResDataObject resTemp = config;
  4462. while ((pos = strTemp.find_first_of(',')) != string::npos)
  4463. {
  4464. string Key = strTemp.substr(0, pos);
  4465. string TempValue = resTemp[Key.c_str()].encode();
  4466. resTemp.clear();
  4467. resTemp.decode(TempValue.c_str());
  4468. strTemp = strTemp.substr(pos + 1, strTemp.length() - pos - 1);
  4469. }
  4470. if (strTemp != "")
  4471. {
  4472. strValue = (string)resTemp[strTemp.c_str()];
  4473. }
  4474. else
  4475. {
  4476. strValue = (string)resTemp;
  4477. }
  4478. }
  4479. return true;
  4480. }
  4481. bool nsGEN::RF80Driver::SetDeviceConfigValue(ResDataObject& config, const char* pInnerKey, int nPathID, const char* szValue)
  4482. {
  4483. string strTemp = pInnerKey;
  4484. mLog::Debug("Begin to change {$} item value to {$}", pInnerKey, szValue);
  4485. if (1 == nPathID) //从DriverConfig路径下每个DPC自己的配置文件读取
  4486. {
  4487. try {
  4488. int pos = 0;
  4489. ResDataObject* resTemp = &config;
  4490. while ((pos = strTemp.find_first_of(',')) != string::npos)
  4491. {
  4492. string Key = strTemp.substr(0, pos);
  4493. resTemp = &(*resTemp)[Key.c_str()];
  4494. strTemp = strTemp.substr(pos + 1, strTemp.length() - pos - 1);
  4495. }
  4496. if (strTemp != "")
  4497. {
  4498. (*resTemp)[strTemp.c_str()] = szValue;
  4499. }
  4500. else
  4501. {
  4502. *resTemp = szValue;
  4503. }
  4504. }
  4505. catch (ResDataObjectExption& e)
  4506. {
  4507. mLog::Error("SetDriverConfigvalue crashed: {$}", e.what());
  4508. return false;
  4509. }
  4510. }
  4511. return true;
  4512. }
  4513. std::string nsGEN::RF80Driver::GetResource()
  4514. {
  4515. ResDataObject r_config, temp;
  4516. if (!temp.loadFile(m_ConfigFileName.c_str()))
  4517. {
  4518. return "";
  4519. }
  4520. m_ConfigAll = temp;
  4521. r_config = temp["CONFIGURATION"];
  4522. m_Configurations = r_config;
  4523. ResDataObject DescriptionTemp;
  4524. ResDataObject DescriptionSend;
  4525. ResDataObject m_DescriptionSend;
  4526. ResDataObject ListTemp;
  4527. string strTemp = ""; //用于读取字符串配置信息
  4528. string strIndex = ""; //用于读取配置信息中的List项
  4529. int nTemp = -1; //用于读取整型配置信息
  4530. char sstream[10] = { 0 }; //用于转换值
  4531. string strValue = ""; //用于存储配置的值
  4532. string strType = ""; //用于存储配置的类型 int/float/string...
  4533. /***
  4534. * 1. 通过循环,将所有配置项写到pDeviceConfig
  4535. * 2. 记录配置项的内部key以及配置类型,类型对应了不同配置文件路径,用于读写真实值
  4536. ***/
  4537. try
  4538. {
  4539. //便利ConfigToolInfo 中 所有的AttributeInfo 属性段
  4540. int nConfigInfoCount = (int)m_Configurations["ConfigToolInfo"].GetKeyCount("AttributeInfo");
  4541. m_pAttribute->clear();
  4542. m_pDescription->clear();
  4543. for (int nInfoIndex = 0; nInfoIndex < nConfigInfoCount; nInfoIndex++)
  4544. {
  4545. DescriptionTemp.clear();
  4546. DescriptionSend.clear();
  4547. ListTemp.clear();
  4548. //AttributeType
  4549. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["Type"];
  4550. DescriptionTemp.add(ConfKey::CcosGeneratorType, strTemp.c_str());//CcosGeneratorAttribute
  4551. DescriptionSend.add(ConfKey::CcosGeneratorType, strTemp.c_str());//CcosGeneratorAttribute
  4552. strType = strTemp; //记录配置项的类型
  4553. //AttributeKey
  4554. //1. 根据AttributeType,内部key和配置路径,拿到当前的真实值
  4555. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["InnerKey"];
  4556. nTemp = (int)m_Configurations["ConfigToolInfo"][nInfoIndex]["PathID"];
  4557. GetDeviceConfigValue(r_config, strTemp.c_str(), nTemp, strValue); //得到strValue的值
  4558. //2. 赋值
  4559. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeKey"];
  4560. if ("int" == strType)
  4561. {
  4562. (*m_pAttribute).add(strTemp.c_str(), atoi(strValue.c_str()));
  4563. }
  4564. else if ("float" == strType)
  4565. {
  4566. (*m_pAttribute).add(strTemp.c_str(), atoi(strValue.c_str()));
  4567. }
  4568. else //其它先按string类型处理
  4569. {
  4570. (*m_pAttribute).add(strTemp.c_str(), strValue.c_str());
  4571. }
  4572. //AttributeAccess
  4573. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["Access"];
  4574. DescriptionTemp.add(ConfKey::CcosAccess, strTemp.c_str());
  4575. DescriptionSend.add(ConfKey::CcosAccess, strTemp.c_str());
  4576. //AttributeList
  4577. nTemp = m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["ListNum"];
  4578. if (nTemp > 0) //ListNum不大于0时说明不需要list配置
  4579. {
  4580. for (int nListIndex = 0; nListIndex < nTemp; nListIndex++)
  4581. {
  4582. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["ListInfo"][nListIndex];
  4583. auto temKey = std::to_string(nListIndex);
  4584. ListTemp.add(temKey.c_str(), strTemp.c_str());
  4585. }
  4586. DescriptionTemp.add(ConfKey::CcosList, ListTemp);
  4587. DescriptionSend.add(ConfKey::CcosList, ListTemp.encode());
  4588. }
  4589. //AttributeRequired
  4590. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["Required"];
  4591. DescriptionTemp.add(ConfKey::CcosRequired, strTemp.c_str());
  4592. DescriptionSend.add(ConfKey::CcosRequired, strTemp.c_str());
  4593. //AttributeDefaultValue
  4594. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeDescripition"]["DefaultValue"];
  4595. if (strTemp != "") //不需要的配置项为空
  4596. {
  4597. DescriptionTemp.add(ConfKey::CcosDefaultValue, strTemp.c_str());
  4598. DescriptionSend.add(ConfKey::CcosDefaultValue, strTemp.c_str());
  4599. }
  4600. strTemp = (string)m_Configurations["ConfigToolInfo"][nInfoIndex]["AttributeKey"];
  4601. (*m_pDescription).add(strTemp.c_str(), DescriptionTemp);
  4602. m_DescriptionSend.add(strTemp.c_str(), DescriptionSend.encode());
  4603. }
  4604. }
  4605. catch (ResDataObjectExption& e)
  4606. {
  4607. mLog::Error("Get config error: {$}", e.what());
  4608. return "";
  4609. }
  4610. ResDataObject resDeviceResource;
  4611. resDeviceResource.add(ConfKey::CcosGeneratorAttribute, (*m_pAttribute));
  4612. resDeviceResource.add(ConfKey::CcosGeneratorDescription, (*m_pDescription));
  4613. ResDataObject DescriptionTempEx;
  4614. DescriptionTempEx.add(ConfKey::CcosGeneratorConfig, resDeviceResource);
  4615. m_DeviceConfig.clear();
  4616. m_DeviceConfig = DescriptionTempEx;
  4617. //mLog::Debug("local ************* get resource over {$}", DescriptionTempEx.encode());
  4618. resDeviceResource.clear();
  4619. resDeviceResource.add(ConfKey::CcosGeneratorAttribute, (*m_pAttribute));
  4620. resDeviceResource.add(ConfKey::CcosGeneratorDescription, m_DescriptionSend);
  4621. DescriptionTempEx.clear();
  4622. DescriptionTempEx.add(ConfKey::CcosGeneratorConfig, resDeviceResource);
  4623. m_DeviceConfigSend.clear();
  4624. m_DeviceConfigSend = DescriptionTempEx;
  4625. string res = m_DeviceConfigSend.encode();
  4626. //mLog::Debug("get resource over {$}", DescriptionTempEx.encode());
  4627. return res;
  4628. }
  4629. std::string nsGEN::RF80Driver::DeviceProbe ()
  4630. {
  4631. ResDataObject r_config, HardwareInfo;
  4632. if (r_config.loadFile (m_ConfigFileName.c_str ()))
  4633. {
  4634. HardwareInfo.add ("MajorID", r_config ["CONFIGURATION"] ["MajorID"]);
  4635. HardwareInfo.add ("MinorID", r_config ["CONFIGURATION"] ["MinorID"]);
  4636. HardwareInfo.add ("VendorID", r_config ["CONFIGURATION"] ["VendorID"]);
  4637. HardwareInfo.add ("ProductID", r_config ["CONFIGURATION"] ["ProductID"]);
  4638. HardwareInfo.add ("SerialID", r_config ["CONFIGURATION"] ["SerialID"]);
  4639. }
  4640. else
  4641. {
  4642. HardwareInfo.add ("MajorID", "Generator");
  4643. HardwareInfo.add ("MinorID", "Dr");
  4644. HardwareInfo.add ("VendorID", "ECOM");
  4645. HardwareInfo.add ("ProductID", "Template");
  4646. HardwareInfo.add ("SerialID", "1234");
  4647. }
  4648. string ret = HardwareInfo.encode ();
  4649. return ret;
  4650. }
  4651. void nsGEN::RF80Driver::Dequeue (const char * Packet, DWORD Length)
  4652. {
  4653. DecodeFrame (Packet, Length);
  4654. }
  4655. PACKET_RET nsGEN::RF80Driver::callbackPackageProcess (const char * RecData, DWORD nLength, DWORD& PacketLength)
  4656. {
  4657. //判断是否是整包
  4658. /*
  4659. 这个是回调函数,我收到的数据会需要这个回调函数帮我判断是否是整个的包;
  4660. 如果有整个的包,返回值为true,在PacketLength处返回给我整个包的长度,我再截取后放入缓存供上层使用;
  4661. 如果缓存中的数据没有整个的数据包,那么返回false
  4662. */
  4663. #if 0 //测试专用
  4664. if (nLength > 1)
  4665. {
  4666. mLog::Error("receive data_len[{$}]", nLength);
  4667. for (int i = 0; i < nLength; i++)
  4668. {
  4669. if (i != nLength - 1)
  4670. {
  4671. mLog::Error("receive data[{$}][{$}]", i, RecData[i]);
  4672. }
  4673. else
  4674. {
  4675. mLog::Error("receive data[{$}][{$}]", i, RecData[i]);
  4676. }
  4677. }
  4678. }
  4679. #endif
  4680. bool bHasHead = false;
  4681. if (nLength < 1)
  4682. {
  4683. PacketLength = 0;
  4684. mLog::Error("nLength too small, nLength=={$}", nLength);
  4685. return PACKET_USELESS;
  4686. }
  4687. else if (nLength > GEN_CF80_RECV_LEN)
  4688. {
  4689. PacketLength = nLength;
  4690. mLog::Error("nLength too big, nLength=={$}", nLength);
  4691. return PACKET_USELESS;
  4692. }
  4693. char strtemp[GEN_CF80_RECV_LEN] = { 0 };
  4694. for (DWORD i = 0; i < nLength; i++)
  4695. {
  4696. //寻找包头
  4697. if (RecData[i] == RECV_HEAD)
  4698. {
  4699. if (i != 0) //包头之前的数据格式不对,全部扔掉
  4700. {
  4701. PacketLength = i;
  4702. memcpy(strtemp, RecData, PacketLength);
  4703. mLog::Error("==IN unknown format data ==: [{$}],UselessDataLength={$};TotalLength={$} \n", strtemp, PacketLength, nLength);
  4704. return PACKET_USELESS;
  4705. }
  4706. else
  4707. {
  4708. bHasHead = true;
  4709. }
  4710. }
  4711. //寻找包尾
  4712. if (RecData[i] == LF)
  4713. {
  4714. if (bHasHead)
  4715. {
  4716. if (i >= 4) //正常指令
  4717. {
  4718. PacketLength = i + 1; //+1 because \n
  4719. memcpy(strtemp, RecData, i - 1); //只有>+数据,-1 排除 checkSum or \r
  4720. if (true)
  4721. {
  4722. mLog::Info("==IN==: [{$}]", strtemp);
  4723. }
  4724. RF80Device::m_tDelivermodule.CheckReceive(strtemp, 4);
  4725. return PACKET_ISPACKET;
  4726. }
  4727. else //空指令
  4728. {
  4729. PacketLength = i + 1;
  4730. memcpy(strtemp, RecData, PacketLength); //空数据,格式正确但无有效命令
  4731. mLog::Error("==IN uselss data==: [{$}] \n", strtemp);
  4732. return PACKET_USELESS;
  4733. }
  4734. }
  4735. else //有包尾但无包头
  4736. {
  4737. PacketLength = i + 1;
  4738. memcpy(strtemp, RecData, PacketLength);
  4739. mLog::Error("==IN no head data ==: [{$}],NoHeadDataLength={$};TotalLength={$} \n", strtemp, PacketLength, nLength);
  4740. return PACKET_USELESS;
  4741. }
  4742. }
  4743. }
  4744. if (bHasHead)
  4745. {
  4746. PacketLength = 0;
  4747. }
  4748. return PACKET_NOPACKET;
  4749. }
  4750. //-----------------------------------------------------------------------------
  4751. // GetIODriver & CreateIODriver
  4752. //-----------------------------------------------------------------------------
  4753. static nsGEN::RF80Driver gIODriver;
  4754. extern "C" CCOS::Dev::IODriver * __cdecl GetIODriver () // 返回静态对象的引用, 调用者不能删除 !
  4755. {
  4756. return &gIODriver;
  4757. }
  4758. extern "C" CCOS::Dev::IODriver * __cdecl CreateIODriver () // 返回新对象, 调用者必须自行删除此对象 !
  4759. {
  4760. return new nsGEN::RF80Driver ();
  4761. }