OTSBrukerImpl.cpp 77 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693
  1. #pragma once
  2. #include "stdafx.h"
  3. #include "OTSBrukerImpl.h"
  4. #include "3Parties\dibapi.h"
  5. #include "BrukerSPXFileMgr.h"
  6. #include "ControllerHelper.h"
  7. #include <COTSUtilityDllFunExport.h>
  8. namespace OTSController {
  9. unsigned int DEFAULT_MAX_WAIT_TIME_COLLECT_COUNTS = 5000;
  10. const CString DllXMLFileName = "./Config/ProData/HardwareConfig.xml";
  11. // constructor
  12. COTSBrukerImpl::COTSBrukerImpl()
  13. : m_bInit(false)
  14. , m_psServerName()
  15. , m_bSEMInst(false)
  16. , m_bScannerInst(false)
  17. , m_bXRAyControllerInst(false)
  18. , m_psRTSpectrumBuffer()
  19. , m_nClientID(0)
  20. , m_bSEMExternal(false)
  21. , m_nSPU(FIRST_DETECTOR_ID)
  22. , m_bConnected(false)
  23. , m_pSpectrumHead(NULL)
  24. , m_bDoQuantification(false)
  25. , m_bShowQuantificationSpectrum(false)
  26. {
  27. LogTrace(__FILE__,__LINE__,_T("Bruker Implement Controller created"));
  28. }
  29. // destructor
  30. COTSBrukerImpl::~COTSBrukerImpl()
  31. {
  32. // close client if necessary
  33. if (m_bConnected)
  34. {
  35. CloseClient();
  36. }
  37. m_psServerName.reset();
  38. m_psRTSpectrumBuffer.reset();
  39. LogTrace(__FILE__, __LINE__, _T("Bruker Implement Controller released."));
  40. }
  41. // COTSBrukerImpl methods
  42. // public
  43. // initialization
  44. BOOL COTSBrukerImpl::Init(CONTROL_TYPE a_nControlType, BOOL a_b32Bite /*=TRUE*/)
  45. {
  46. //m_bInit is the dll loading flag,so there's no need to free it manually , it'll be release when the the whole process is complete.(gsp)
  47. if (!m_bInit)
  48. {
  49. // calculate Bruker client dll name
  50. CString strBruckerDllName = "";
  51. this->GetLoadDllName(strBruckerDllName);
  52. // load Bruker client dll name succeed
  53. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::Init: bruker client dll name: %s"), strBruckerDllName);
  54. m_bInit = BrukerDll::LoadEspritAPI((/*_T("OTSCPPDll\\") +*/ strBruckerDllName).GetBuffer());
  55. // load Bruker client dll OK?
  56. if (!m_bInit)
  57. {
  58. // failed to load bruker client dll
  59. AfxMessageBox(_T("cann't load Bruker dll! name:" + strBruckerDllName));
  60. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::Init: failed to load Bruker Client Dll , Dll Name: %s"), strBruckerDllName);
  61. //exit(0);
  62. return false;
  63. }
  64. }
  65. // initialized?
  66. if (!m_bConnected)
  67. {
  68. if (QueryBrukerServers() && OpenClient())
  69. {
  70. LogTrace(__FILE__, __LINE__, "open bruker client success!");
  71. if (!m_psRTSpectrumBuffer)
  72. {
  73. m_psRTSpectrumBuffer.reset(new char[(int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE]);
  74. }
  75. memset(m_psRTSpectrumBuffer.get(), 0, (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE);
  76. // ok, return true
  77. m_bConnected = true;
  78. }
  79. else
  80. {
  81. m_bConnected = false;
  82. }
  83. }
  84. // control type?
  85. switch (a_nControlType)
  86. {
  87. // SEM
  88. case CONTROL_TYPE::BRUKER_SEM:
  89. {
  90. m_bSEMInst = TRUE;
  91. }
  92. break;
  93. // scanner
  94. case CONTROL_TYPE::BRUKER_SCAN:
  95. {
  96. m_bScannerInst = TRUE;
  97. }
  98. break;
  99. // x-ray control
  100. case CONTROL_TYPE::BRUKER_XRAY:
  101. {
  102. // check detector states and set m_nSPU
  103. if (!SetSPU())
  104. {
  105. return FALSE;
  106. }
  107. m_bXRAyControllerInst = TRUE;
  108. }
  109. break;
  110. default:
  111. {
  112. // invalid control type, something wrong
  113. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::Init: invalid control type."));
  114. return FALSE;
  115. }
  116. break;
  117. }
  118. return m_bConnected;
  119. }
  120. BOOL COTSBrukerImpl::DisConnect()
  121. {
  122. if (m_bConnected)
  123. {
  124. CloseClient();
  125. m_bConnected = false;
  126. }
  127. return true;
  128. }
  129. // check connection
  130. BOOL COTSBrukerImpl::CheckConnection(BOOL& a_bConnected)
  131. {
  132. if (BrukerDll::CheckConnection(m_nClientID)== 0)
  133. {
  134. // connected
  135. a_bConnected = TRUE;
  136. // ok, return true
  137. return TRUE;
  138. }
  139. else
  140. {
  141. a_bConnected = FALSE;
  142. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CheckConnection: no hardware connected."));
  143. return FALSE;
  144. }
  145. }
  146. void COTSBrukerImpl::SetExpectCount(int expectCount)
  147. {
  148. m_expectCount = expectCount;
  149. }
  150. int COTSBrukerImpl::GetExpectCount()
  151. {
  152. return m_expectCount;
  153. }
  154. // SEM functions
  155. // SEM Data (mag, KV and working distance)
  156. BOOL COTSBrukerImpl::GetSEMData(double& a_dMagnification, double& a_dHighVoltage, double& a_dWorkingDistance)
  157. {
  158. // get SEM data (mag, KV and working distance)
  159. double dMagnification, dHighVoltage, dWorkingDistance;
  160. if (BrukerDll::GetSEMData(m_nClientID, dMagnification, dHighVoltage, dWorkingDistance) != 0)
  161. {
  162. // failed to call get SEM data method (mag, KV and working distance)
  163. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetSEMData: failed to call GetSEMBCData client id is %d"), m_nClientID);
  164. return FALSE;
  165. }
  166. a_dMagnification = dMagnification;
  167. a_dHighVoltage = dHighVoltage;
  168. a_dWorkingDistance = dWorkingDistance;
  169. // ok, return TRUE
  170. return TRUE;
  171. }
  172. BOOL COTSBrukerImpl::SetSEMData(double a_dMagnification, double a_dHighVoltage, double a_dWorkingDistance)
  173. {
  174. if (BrukerDll::SetSEMData(m_nClientID, a_dMagnification, a_dHighVoltage, a_dWorkingDistance) != 0)
  175. {
  176. // failed to call set SEM data method (mag, KV and working distance)
  177. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSEMData: failed to call GetSEMBCData client id = %d"), m_nClientID);
  178. return FALSE;
  179. }
  180. // ok, return TRUE
  181. return TRUE;
  182. }
  183. // SEM BC Data (brightness and contrast)
  184. BOOL COTSBrukerImpl::GetSEMBCData(double& a_dBrightness, double& a_dContrast)
  185. {
  186. double dBrightness = 0, dContrast = 0;
  187. if (BrukerDll::GetSEMBCData(m_nClientID, dBrightness, dContrast) != 0)
  188. {
  189. // failed to call get SEM data method
  190. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetBrightness: failed to call GetSEMBCData client id is %d"), m_nClientID);
  191. return FALSE;
  192. }
  193. a_dBrightness = dBrightness;
  194. a_dContrast = dContrast;
  195. // ok, return TRUE
  196. return TRUE;
  197. }
  198. BOOL COTSBrukerImpl::SetSEMBCData(double a_dBrightness, double a_dContrast)
  199. {
  200. // set SEM data
  201. if (BrukerDll::SetSEMBCData(m_nClientID, a_dBrightness, a_dContrast) != 0)
  202. {
  203. // failed to call set SEM data method
  204. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetBrightness: failed to call SetSEMBCData client id is %d"), m_nClientID);
  205. return FALSE;
  206. }
  207. // ok, return TRUE
  208. return TRUE;
  209. }
  210. // get Probe Current
  211. BOOL COTSBrukerImpl::GetProbeCurrent(double& a_dKV)
  212. {
  213. // get Probe Current
  214. if (BrukerDll::GetSEMProbeCurrent(m_nClientID, a_dKV) != 0)
  215. {
  216. // failed to call GetSEMSpotSize method
  217. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::GetProbeCurrent: failed to call GetSEMProbeCurrent method, client id = %d", m_nClientID);
  218. return FALSE;
  219. }
  220. // ok, return TRUE
  221. return TRUE;
  222. }
  223. BOOL COTSBrukerImpl::SetProbeCurrent(double a_dKV)
  224. {
  225. // set Probe Current
  226. if (BrukerDll::SetSEMProbeCurrent(m_nClientID, a_dKV) != 0)
  227. {
  228. // failed to call GetSEMSpotSize method
  229. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::SetProbeCurrent: failed to call SetSEMProbeCurrent method, client id = %d", m_nClientID);
  230. return FALSE;
  231. }
  232. // ok, return TRUE
  233. return TRUE;
  234. }
  235. // spot size
  236. BOOL COTSBrukerImpl::GetSEMSpotSize(double& a_dSpotSize)
  237. {
  238. // get spot size
  239. if (BrukerDll::GetSEMSpotSize(m_nClientID, a_dSpotSize)!=0)
  240. {
  241. // failed to call GetSEMSpotSize method
  242. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::GetSpotSize: failed to call GetSEMSpotSize method, client id = %d", m_nClientID);
  243. return FALSE;
  244. }
  245. // ok, return TRUE
  246. return TRUE;
  247. }
  248. BOOL COTSBrukerImpl::SetSEMSpotSize(double a_dSpotSize)
  249. {
  250. // set spot size
  251. if (BrukerDll::SetSEMSpotSize(m_nClientID, a_dSpotSize)!=0)
  252. {
  253. // failed to call SetSEMSpotSize method
  254. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::SetSEMSpotSize: failed to call SetSEMSpotSize method, client id = %d", m_nClientID);
  255. return FALSE;
  256. }
  257. // ok, return TRUE
  258. return TRUE;
  259. }
  260. // stage data
  261. BOOL COTSBrukerImpl::GetSEMStageData(
  262. double& a_dPositionX,
  263. double& a_dPositionY,
  264. double& a_dPositionZ,
  265. double& a_dTilt,
  266. double& a_dRotation)
  267. {
  268. // get stage data
  269. double dPositionX, dPositionY, dPositionZ, dTilt, dRotation;
  270. if (BrukerDll::GetSEMStageData(m_nClientID, dPositionX, dPositionY, dPositionZ, dTilt, dRotation)!=0)
  271. {
  272. // failed to call GetSEMStageData method
  273. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::GetSEMStageData: failed to call GetSEMStageData method, client id = %d", m_nClientID);
  274. return FALSE;
  275. }
  276. a_dPositionX = dPositionX;
  277. a_dPositionY = dPositionY;
  278. a_dPositionZ = dPositionZ;
  279. a_dTilt = dTilt;
  280. a_dRotation = dRotation;
  281. // ok return TRUE
  282. return true;
  283. }
  284. BOOL COTSBrukerImpl::SetSEMStageData(
  285. double a_dPositionX,
  286. double a_dPositionY,
  287. double a_dPositionZ,
  288. double a_dTilt,
  289. double a_dRotation)
  290. {
  291. // set stage data
  292. if (BrukerDll::SetSEMStageData(m_nClientID, a_dPositionX, a_dPositionY, a_dPositionZ, a_dTilt, a_dRotation) != 0)
  293. {
  294. // failed to call SetSEMStageData method
  295. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::GetSEMStageData: failed to call SetSEMStageData method, client id = %d", m_nClientID);
  296. return FALSE;
  297. }
  298. // ok, return TRUE
  299. return TRUE;
  300. }
  301. // external on/off
  302. BOOL COTSBrukerImpl::SetSEMExternalOn(void)
  303. {
  304. // set external on
  305. if (BrukerDll::SetSEMExternalOn(m_nClientID) == 0)
  306. {
  307. m_bSEMExternal = true;
  308. LogWarn(__FILE__, __LINE__, _T("SetExternal On"));
  309. }
  310. else
  311. {
  312. // failed to call SetSEMExternalOn method
  313. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::SetSEMExternalOn: failed to call SetSEMExternalOn method, client id = %d", m_nClientID);
  314. return FALSE;
  315. }
  316. // ok, return TRUE
  317. return TRUE;
  318. }
  319. // set SEM external off
  320. // return true if success
  321. BOOL COTSBrukerImpl::SetSEMExternalOff(void)
  322. {
  323. // set external off
  324. if (BrukerDll::SetSEMExternalOff(m_nClientID)==0)
  325. {
  326. m_bSEMExternal = false;
  327. LogWarn(__FILE__, __LINE__, _T("SetExternal Off"));
  328. }
  329. else
  330. {
  331. // failed to call SetSEMExternalOn method
  332. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::SetSEMExternalOff: failed to call SetSEMExternalOff method, client id = %d", m_nClientID);
  333. return FALSE;
  334. }
  335. // ok, return TRUE
  336. return TRUE;
  337. }
  338. // get scan Mode
  339. BOOL COTSBrukerImpl::GetExternalScanMode(long& a_nScanMode)
  340. {
  341. a_nScanMode = (m_bSEMExternal) ? BRUKER_SCAN_MODE_EXTERNAL_ON : BRUKER_SCAN_MODE_EXTERNAL_OFF;
  342. return TRUE;
  343. }
  344. // set SEM off
  345. BOOL COTSBrukerImpl::SwitchSEMOff(BOOL a_bHTValue, BOOL a_bBeamCurrent, BOOL a_bBeamBlank)
  346. {
  347. // turn high tension off
  348. if (!a_bHTValue)
  349. {
  350. if (BrukerDll::SwitchSEMOff(m_nClientID, true, false, false)!=0)
  351. {
  352. // failed to call sSwitchSEMOff method
  353. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::SetHTOnOff: failed to call sSwitchSEMOff (HV) method, client id = %d", m_nClientID );
  354. return FALSE;
  355. }
  356. }
  357. else if(a_bBeamCurrent)
  358. {
  359. if (BrukerDll::SwitchSEMOff(m_nClientID, false, true, false)!=0)
  360. {
  361. // failed to call sSwitchSEMOff method
  362. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::SetHTOnOff: failed to call sSwitchSEMOff (Beam Current) method, client id = %d", m_nClientID );
  363. return FALSE;
  364. }
  365. }
  366. else if(a_bBeamBlank)
  367. {
  368. if (BrukerDll::SwitchSEMOff(m_nClientID, false, false, true)!=0)
  369. {
  370. // failed to call sSwitchSEMOff method
  371. LogErrorTrace(__FILE__, __LINE__, "COTSBrukerImpl::SetHTOnOff: failed to call sSwitchSEMOff (Beam Blank) method, client id = %d", m_nClientID );
  372. return FALSE;
  373. }
  374. }
  375. // ok, return TRUE
  376. return TRUE;
  377. }
  378. // image configuration
  379. BOOL COTSBrukerImpl::ImageGetConfiguration(
  380. DWORD& a_nWidth,
  381. DWORD& a_nHeight,
  382. DWORD& a_nAverage,
  383. BYTE& a_bCh1,
  384. BYTE& a_bCh2)
  385. {
  386. // get image configuration
  387. uint32_t nWidth;
  388. uint32_t nHeight;
  389. uint32_t nAverage;
  390. bool bCh1;
  391. bool bCh2;
  392. if (BrukerDll::ImageGetConfiguration(m_nClientID, nWidth, nHeight,nAverage, bCh1, bCh2)!=0)
  393. {
  394. // failed to call ImageGetConfiguration method
  395. LogErrorTrace(__FILE__, __LINE__, "ImageGetConfiguration::ImageGetConfiguration: failed to call ImageGetConfiguration method, client id = %d", m_nClientID);
  396. return FALSE;
  397. }
  398. a_nWidth = nWidth;
  399. a_nHeight = nHeight;
  400. a_nAverage = nAverage;
  401. a_bCh1 = bCh1;
  402. a_bCh2 = bCh2;
  403. // ok, return TRUE
  404. return TRUE;
  405. }
  406. BOOL COTSBrukerImpl::ImageSetConfiguration(
  407. DWORD a_nWidth,
  408. DWORD a_nHeight,
  409. DWORD a_nAverage,
  410. BYTE a_bCh1,
  411. BYTE a_bCh2)
  412. {
  413. // set image configuration
  414. if (BrukerDll::ImageSetConfiguration(m_nClientID, a_nWidth, a_nHeight, a_nAverage, a_bCh1, a_bCh2) != 0)
  415. {
  416. // failed to call ImageSetConfiguration method
  417. LogErrorTrace(__FILE__, __LINE__, "ImageGetConfiguration::ImageSetConfiguration: failed to call ImageSetConfiguration method, client id = %d", m_nClientID);
  418. return FALSE;
  419. }
  420. // ok, return TRUE
  421. return TRUE;
  422. }
  423. // Acquire Image
  424. CBSEImgPtr COTSBrukerImpl::AcquireImage()
  425. {
  426. try
  427. {
  428. // set external on
  429. if (!SetSEMExternalOn())
  430. {
  431. // failed to call SetSEMExternalOn method
  432. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::AcquireImage: failed to call SetSEMExternalOn method."));
  433. return CBSEImgPtr();
  434. }
  435. // Get the image config so we can allocate enough memory
  436. DWORD nWidth = 0;
  437. DWORD nHeight = 0;
  438. DWORD nAverage;
  439. BYTE bCh1;
  440. BYTE bCh2;
  441. if (!ImageGetConfiguration(nWidth, nHeight, nAverage, bCh1, bCh2))
  442. {
  443. // failed to call ImageGetConfiguration method
  444. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::AcquireImage: failed to call ImageGetConfiguration method."));
  445. return CBSEImgPtr();
  446. }
  447. // SEM info
  448. BrukerDll::TRTImageInfoEx imgInfo;
  449. BrukerDll::PRTImageInfoEx oImageInfo=&imgInfo;
  450. // the buffer returned is a bitmap stream, i.e. it contains the header information as well
  451. int32_t nImageSize = nWidth * nHeight + 20000;
  452. std::vector<BYTE> vecImage(nImageSize, 0);
  453. BYTE showProgress = false;
  454. if (BrukerDll::ImageAquireImage(m_nClientID, 1, showProgress, &vecImage[0], nImageSize, oImageInfo) != 0)
  455. {
  456. // failed to call ImageAquireImage method
  457. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::AcquireImage: failed to call ImageAquireImage, client id is %d"), m_nClientID);
  458. return CBSEImgPtr();
  459. }
  460. LPBITMAPFILEHEADER pHeader = (LPBITMAPFILEHEADER)&vecImage[0];
  461. LPBITMAPINFOHEADER pInfoHeader = (LPBITMAPINFOHEADER)(pHeader + 1);
  462. LPBYTE lpb = FindDIBBits(pInfoHeader);
  463. CRect r = CRect(0, 0, nWidth, nHeight);
  464. // Bruker acquires an upside-down image. Flip the image here.
  465. CBSEImgPtr poBseImage(new CBSEImg(r));
  466. poBseImage->InitImageData(nWidth, nHeight);
  467. BYTE* pImageData = poBseImage->GetImageDataPointer();
  468. // turn bInverseImage to FALSE if don't need to do flip
  469. BOOL bInverseImage = TRUE;
  470. if (bInverseImage)
  471. {
  472. // copy image upside down
  473. for (DWORD i = 0; i < nHeight; ++i)
  474. {
  475. LPBYTE pTarget = pImageData + i * nWidth;
  476. LPBYTE pSource = lpb + (nHeight - 1 - i) * nWidth;
  477. memcpy(pTarget, pSource, nWidth);
  478. }
  479. }
  480. else
  481. {
  482. long nActImageSize = nWidth * nHeight;
  483. memcpy(pImageData, lpb, nActImageSize);
  484. }
  485. // return BSE image
  486. return poBseImage;
  487. }
  488. catch (const std::exception&)
  489. {
  490. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::AcquireImage exception"));
  491. }
  492. finally{
  493. // turn SEM to external off
  494. if (!SetSEMExternalOff())
  495. {
  496. // failed to call SetSEMExternalOn method
  497. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::AcquireImage: failed to call SetSEMExternalOff method."));
  498. }
  499. }
  500. // error, return nullptr
  501. return nullptr;
  502. }
  503. // set image point (move beam to position)
  504. // CPoint& a_oPoint offside the image top left point (pixel)
  505. BOOL COTSBrukerImpl::ImageSetPoint(const CPoint& a_oPoint)
  506. {
  507. // image set point
  508. if (BrukerDll::ImageSetPoint(m_nClientID, (DWORD)a_oPoint.x, (DWORD)a_oPoint.y) != 0)
  509. {
  510. // failed to call ImageSetPoint method
  511. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ImageSetPoint: failed to call ImageSetPoint, client id is %d"), m_nClientID);
  512. return FALSE;
  513. }
  514. // ok, return TRUE
  515. return TRUE;
  516. }
  517. // x-ray functions
  518. /// get live time
  519. float COTSBrukerImpl::GetLiveTime()
  520. {
  521. // safety check
  522. ASSERT(m_pSpectrumHead);
  523. if (!m_pSpectrumHead)
  524. {
  525. // error, invalid m_pBrukerDllHandle
  526. LogErrorTrace(__FILE__, __LINE__, _T("GetLiveRealTime::ImageSetPoint: invalid m_pSpectrumHead."));
  527. return 0.0;
  528. }
  529. // NOTE: m_pSpectrumHead will set when spectra are collected and needs to be set to NULL
  530. // after live time is collected
  531. float fRet = (float)m_pSpectrumHead->LifeTime / (float)1000.0; // ms to second
  532. m_pSpectrumHead = NULL;
  533. return fRet;
  534. }
  535. BOOL COTSBrukerImpl::GetLiveRealTime(float& a_dLiveTime, float& a_dRealTime)
  536. {
  537. // safety check
  538. ASSERT(m_pSpectrumHead);
  539. if (!m_pSpectrumHead)
  540. {
  541. // error, invalid m_pSpectrumHead.
  542. LogErrorTrace(__FILE__, __LINE__, _T("GetLiveRealTime::ImageSetPoint: invalid m_pSpectrumHead."));
  543. return FALSE;
  544. }
  545. // NOTE: m_pSpectrumHead will set when spectra are collected and needs to be set to NULL
  546. // after live time is collected
  547. a_dLiveTime = (float)m_pSpectrumHead->LifeTime / (float)1000.0; // ms to second
  548. a_dRealTime = (float)m_pSpectrumHead->RealTime / (float)1000.0; // ms to second
  549. m_pSpectrumHead = NULL;
  550. // ok, return TRUE
  551. return TRUE;
  552. }
  553. // collect spectrum data
  554. // this method needs to be called after beam has been set to right position by ImageSetPoint method
  555. BOOL COTSBrukerImpl::CollectSpectrum( DWORD a_nMilliseconds, long* a_pXRayData, DWORD a_nBufferSize)
  556. {
  557. // input check
  558. ASSERT(a_pXRayData);
  559. if (!(a_pXRayData))
  560. {
  561. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectSpectrum: invalid a_pXRayData."));
  562. return FALSE;
  563. }
  564. // set buffer to 0
  565. memset(a_pXRayData, 0, sizeof(long) * a_nBufferSize);
  566. // start x ray measurement
  567. if (!SpectrumRealTimeMeasurement(a_nMilliseconds))
  568. {
  569. // failed to call SpectrumRealTimeMeasurement method
  570. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectSpectrum: failed to call SpectrumRealTimeMeasurement method."));
  571. return FALSE;
  572. }
  573. if (m_bDoQuantification)
  574. {
  575. // quantify the spectrum
  576. LogInfoTrace(__FILE__,__LINE__,_T("QuantifySpectrum"));
  577. char* pcMethod = "Default";//"Default";// "Automatic";
  578. char* pcParams = "ResultType=quantification";
  579. char cResult[(int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE];
  580. memset(cResult, 0, (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE);
  581. if (!QuantifySpectrum(pcMethod, pcParams, cResult, (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE))
  582. {
  583. LogErrorTrace(__FILE__,__LINE__,_T("failed to call QuantifySpectrum method"));
  584. return FALSE;
  585. }
  586. LogTrace(__FILE__,__LINE__,_T("Result: %s"), CControllerHelper::CharToString(cResult));
  587. // convert the result char to string
  588. CString strResult = CControllerHelper::CharToString(cResult);
  589. LogTrace(__FILE__, __LINE__, _T("Result: %s"), strResult);
  590. }
  591. // read spectrum
  592. if (!ReadSpectrum())
  593. {
  594. // failed to call ReadSpectrum method
  595. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectSpectrum: failed to call ReadSpectrum method."));
  596. return FALSE;
  597. }
  598. // copy spectrum
  599. if (!CopySpectrum(a_pXRayData, a_nBufferSize))
  600. {
  601. // failed to call CopySpectrum
  602. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectSpectrum: failed to call CopySpectrum method."));
  603. return FALSE;
  604. }
  605. // ok. return TRUE
  606. return TRUE;
  607. }
  608. BOOL COTSBrukerImpl::QuantifySpectrumOut(DWORD a_nMilliseconds, long* a_pXRayData, DWORD a_nBufferSize, CElementChemistriesList& a_listElementChemistries)
  609. {
  610. // input check
  611. ASSERT(a_pXRayData);
  612. if (!(a_pXRayData))
  613. {
  614. LogErrorTrace(__FILE__, __LINE__, _T("QuantifySpectrum::CollectSpectrum: invalid a_pXRayData."));
  615. return FALSE;
  616. }
  617. // set buffer to 0
  618. memset(a_pXRayData, 0, sizeof(long) * a_nBufferSize);
  619. // start x ray measurement
  620. if (!SpectrumRealTimeMeasurement(a_nMilliseconds))
  621. {
  622. // failed to call SpectrumRealTimeMeasurement method
  623. LogErrorTrace(__FILE__, __LINE__, _T("QuantifySpectrum::CollectSpectrum: failed to call SpectrumRealTimeMeasurement method."));
  624. return FALSE;
  625. }
  626. // quantify the spectrum
  627. LogInfoTrace(__FILE__, __LINE__, _T("QuantifySpectrum"));
  628. char* pcMethod = "Default";// "Automatic";
  629. char* pcParams = "ResultType=quantification";
  630. char cResult[(int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE];
  631. memset(cResult, 0, (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE);
  632. if (!QuantifySpectrum(pcMethod, pcParams, cResult, (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE))
  633. {
  634. LogErrorTrace(__FILE__, __LINE__, _T("failed to call QuantifySpectrum method"));
  635. return FALSE;
  636. }
  637. LogTrace(__FILE__, __LINE__, _T("Result: %s"), CControllerHelper::CharToString(cResult));
  638. // convert the result char to string
  639. CString strResult = CControllerHelper::CharToString(cResult);
  640. LogTrace(__FILE__, __LINE__, _T("Result: %s"), strResult);
  641. // separate the result string to element chemistry string
  642. std::vector<CString> listStrElementChemistries = CControllerHelper::SplitString(strResult, _T("\n"));
  643. for (auto strElementChemistry : listStrElementChemistries)
  644. {
  645. CElementChemistryPtr oElementChemistryData;
  646. if (GetElementChemistryData(*oElementChemistryData.get(), strElementChemistry))
  647. {
  648. a_listElementChemistries.push_back(oElementChemistryData);
  649. }
  650. }
  651. // read spectrum
  652. if (!ReadSpectrum())
  653. {
  654. // failed to call ReadSpectrum method
  655. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectSpectrum: failed to call ReadSpectrum method."));
  656. return FALSE;
  657. }
  658. // copy spectrum
  659. if (!CopySpectrum(a_pXRayData, a_nBufferSize))
  660. {
  661. // failed to call CopySpectrum
  662. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectSpectrum: failed to call CopySpectrum method."));
  663. return FALSE;
  664. }
  665. // ok. return TRUE
  666. return TRUE;
  667. }
  668. // quantify the spectrum in buffer
  669. BOOL COTSBrukerImpl::QuantifySpectrum(char* a_pcMethod, char* a_pcParams, char* a_pcResultBuffer, long a_nBufferSize)
  670. {
  671. // input check
  672. ASSERT(a_pcMethod);
  673. if (!a_pcParams)
  674. {
  675. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifySpectrum: invalid a_pcMethod."));
  676. return FALSE;
  677. }
  678. ASSERT(a_pcParams);
  679. if (!a_pcParams)
  680. {
  681. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifySpectrum: invalid a_pcParams."));
  682. return FALSE;
  683. }
  684. ASSERT(a_pcResultBuffer);
  685. if (!a_pcResultBuffer)
  686. {
  687. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifySpectrum: invalid a_pcResultBuffer."));
  688. return FALSE;
  689. }
  690. // quantify the spectrum in buffer
  691. if (BrukerDll::QuantifySpectrum(m_nClientID, 1, a_pcMethod, a_pcParams, a_pcResultBuffer, a_nBufferSize) != 0)
  692. {
  693. // failed to call QuantifySpectrum method
  694. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifySpectrum:Call QuantifySpectrum failed: client id is %d."), m_nClientID);
  695. return false;
  696. }
  697. // ok. return TRUE
  698. return TRUE;
  699. }
  700. BOOL COTSBrukerImpl::CollectXRayPoints(CPosXrayList& a_listXrayPois, DWORD a_nACTimeMS)
  701. {
  702. // do nothing if points list is empty
  703. if (a_listXrayPois.empty())
  704. {
  705. // points list is empty
  706. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPoints: poits list is empty."));
  707. return TRUE;
  708. }
  709. // turn SEM to external
  710. if (!SetSEMExternalOn())
  711. {
  712. // failed to call SetSEMExternalOn method
  713. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPoints: failed to call SetSEMExternalOn method."));
  714. return FALSE;
  715. }
  716. // create array of BrukerSegment
  717. long nCollectCount = (long)a_listXrayPois.size();
  718. boost::scoped_array<BrukerDll::TSegment> segmentArray(new BrukerDll::TSegment[nCollectCount]);
  719. for (int i = 0; i < nCollectCount; ++i)
  720. {
  721. CPoint poi = a_listXrayPois[i]->GetPosition();
  722. segmentArray[i].Y = poi.y;
  723. segmentArray[i].XStart = poi.x;
  724. segmentArray[i].XCount = 1;
  725. }
  726. // ask bruker to collect a set of x ray data
  727. if (!StartPointListMeasurement(nCollectCount, segmentArray.get(), a_nACTimeMS))
  728. {
  729. // failed to call StartPointListMeasurement method
  730. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPoints: failed to call StartPointListMeasurement method."));
  731. return FALSE;
  732. }
  733. // get the specs for a_listXrayPois
  734. if (!ReadXRayPoints(a_listXrayPois, a_nACTimeMS))
  735. {
  736. // failed to call ReadXRayPoints method
  737. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPoints: failed to call ReadXRayPoints method."));
  738. return FALSE;
  739. }
  740. //delete segmentArray;
  741. // ok return TRUE
  742. return TRUE;
  743. }
  744. // collect x ray points (area scan)
  745. BOOL COTSBrukerImpl::CollectXRayPointsByFeatures(std::vector<CPosXray*>& a_vXPoints, std::vector<BrukerFeature>& a_vFeatures, DWORD a_nACTimeMS)
  746. {
  747. // do nothing if points list is empty
  748. if (a_vXPoints.empty())
  749. {
  750. // points list is empty
  751. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures: poits list is empty."));
  752. return TRUE;
  753. }
  754. // lists size check
  755. if (a_vXPoints.size() != a_vFeatures.size())
  756. {
  757. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures:Feature size(%d) doesn't match xray point size(%d)"), a_vFeatures.size(), a_vXPoints.size());
  758. return FALSE;
  759. }
  760. // set SEM to external
  761. if (!SetSEMExternalOn())
  762. {
  763. // failed to call SetSEMExternalOn method
  764. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures: failed to call SetSEMExternalOn method."));
  765. return FALSE;
  766. }
  767. // create array of BrukerSegment
  768. long nCollectCount = (long)a_vXPoints.size();
  769. long nTotalPixelCount = 0;
  770. boost::scoped_array<SHORT*> pixelTimes(new SHORT*[nCollectCount]);
  771. boost::scoped_array<BrukerDll::TFeatureData> features(new BrukerDll::TFeatureData[nCollectCount]);
  772. std::vector<BrukerDll::TSegment> extraSegments;
  773. for (size_t i = 0; i < a_vXPoints.size(); i++)
  774. {
  775. features[i].SegmentCount = (long)a_vFeatures[i].SegmentCount;
  776. if (features[i].SegmentCount > 0)
  777. {
  778. int segCount = features[i].SegmentCount;
  779. auto ofeature = a_vFeatures[i];
  780. features.get()->Segments = new BrukerDll::TSegment[segCount];
  781. for (int j = 0; j < segCount; j++)
  782. {
  783. features.get()->Segments[j].XStart = ofeature.pSegment[j].XStart;
  784. features.get()->Segments[j].XCount = ofeature.pSegment[j].XCount;
  785. features.get()->Segments[j].Y = ofeature.pSegment[j].Y;
  786. }
  787. //features[i].Segments = &a_vFeatures[i].pSegment;
  788. // calculate pixel time
  789. int nPixelCount = 0;
  790. for (int j = 0; j < features[i].SegmentCount; j++)
  791. {
  792. nPixelCount += features[i].Segments[j].XCount;
  793. }
  794. *pixelTimes[i] = (SHORT)(a_nACTimeMS * 1000 / nPixelCount);
  795. nTotalPixelCount += nPixelCount;
  796. }
  797. else
  798. {
  799. // will generate according to the x-ray position
  800. // this shouldn't happen
  801. extraSegments.push_back(BrukerDll::TSegment());
  802. extraSegments[extraSegments.size() - 1].XStart = a_vXPoints[i]->GetPosition().x;
  803. extraSegments[extraSegments.size() - 1].Y = a_vXPoints[i]->GetPosition().y;
  804. features[i].SegmentCount = 1;
  805. features[i].Segments = &extraSegments[extraSegments.size() - 1];
  806. *pixelTimes[i] = (SHORT)(a_nACTimeMS * 1000);
  807. }
  808. }
  809. // ask bruker to collect a set of x-ray data
  810. if (!StartFeatureListMeasurement(nCollectCount, features.get(), pixelTimes.get()))
  811. {
  812. // failed to call StartFeatureListMeasurement method
  813. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures: failed to call StartFeatureListMeasurement method."));
  814. return FALSE;
  815. }
  816. // get the specs for a_vXPoints
  817. if (!ReadXRayPointsByFeature(a_vXPoints, a_nACTimeMS))
  818. {
  819. // failed to call ReadXRayPointsByFeature method
  820. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures: failed to call ReadXRayPointsByFeature method."));
  821. return FALSE;
  822. }
  823. return TRUE;
  824. }
  825. BOOL COTSBrukerImpl::ReadXRayPoints(CPosXrayList& a_listXrayPois, const DWORD a_nACTimeMS)
  826. {
  827. // point list is empty?
  828. if (a_listXrayPois.empty())
  829. {
  830. // doing nothing if point list is empty
  831. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPoints: point list (a_listXrayPois) is empty"));
  832. return TRUE;
  833. }
  834. long nCollectCount = (long)a_listXrayPois.size();
  835. // get the specs for a_vXPoints
  836. static DWORD nChannelData[(int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS];
  837. for (int i = 0; i < nCollectCount; ++i)
  838. {
  839. // cleanup data storage
  840. memset(nChannelData, 0, sizeof(DWORD) * (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS);
  841. if (m_bDoQuantification)
  842. {
  843. // quantify the spectrum
  844. char* pcMethod = "Default";//"Default";// "Automatic";
  845. char* pcParams = "ResultType=quantification";
  846. char cResult[10000];
  847. memset(cResult, 0, 10000);
  848. if (BrukerDll::QuantifyPointListSpectrum(m_nClientID, i, pcMethod, pcParams, cResult, 10000, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE) != 0)
  849. {
  850. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPoints failed to call QuantifyPointListSpectrum method, error code %d"), -1);
  851. }
  852. CElementChemistriesList vElement = CElement::ExtractElementChemistrys(CControllerHelper::CharToString(cResult));
  853. }
  854. // get spectrum data of a point
  855. bool success = GetPointListSpectrum(i, (long*)nChannelData);
  856. if (!success)
  857. {
  858. // error
  859. CPoint poi = a_listXrayPois[i]->GetPosition();
  860. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPoints:Call GetPointListSpectrum failed : index = %d(x : %d, y : %d)"),
  861. i,
  862. poi.x,
  863. poi.y);
  864. return FALSE;
  865. }
  866. // set spectrum data for the x-ray point
  867. a_listXrayPois[i]->SetXrayData(nChannelData);
  868. }
  869. // We have seen rare instances where StartPointListMeasurement returns some unexpected empty
  870. // spectra. (We can expect spectra to be empty if we measure in a hole due to charging in the
  871. // BSE image, but on some occasions we see some empty spectra within areas of a measurement
  872. // that otherwise look ok. We have no explanation for this and can't replicate it.)
  873. // In these scenarios we want to fall back to a single point measurement to see if it will
  874. // collect something valid.
  875. // Only if we haven't had an actual bruker error
  876. for (int i = 0; i < nCollectCount; ++i)
  877. {
  878. // check spectrum
  879. DWORD nTatolXrayCount = a_listXrayPois[i]->GetTotalCount();
  880. if (nTatolXrayCount < 20)
  881. {
  882. // captured an empty spectrum
  883. CPoint poi = a_listXrayPois[i]->GetPosition();
  884. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPoints:Collected low count spectrum(%d counts), index = %d(x:%d, y : %d) This could be caused by charging."),
  885. nTatolXrayCount, i, poi.x, poi.y);
  886. // try to redo x-ray collection at the position
  887. memset(nChannelData, 0, sizeof(DWORD) * (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS);
  888. if (!CollectOneXRayPoint(poi, a_nACTimeMS, (long*)nChannelData, (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS))
  889. {
  890. // error
  891. //LogError(_T("Call CollectOneXRayPoint failed: index = %d(x:%d, y:%d)"),
  892. // i, poi.x, poi.y);
  893. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPoints: Call CollectOneXRayPoint failed: index = %d(x:%d, y:%d)"),
  894. i, poi.x, poi.y);
  895. return FALSE;
  896. }
  897. // set spectrum with new spectrum
  898. a_listXrayPois[i]->SetXrayData(nChannelData);
  899. nTatolXrayCount = a_listXrayPois[i]->GetTotalCount();
  900. if (nTatolXrayCount < 20)
  901. {
  902. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPoints:Single point spectrum still low count (%d counts), index = %d(x:%d, y:%d.) This could be caused by charging."),
  903. nTatolXrayCount, i, poi.x, poi.y);
  904. }
  905. else
  906. {
  907. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPoints:Single point spectrum collected successfully (%d counts), index = %d(x:%d, y:%d.)"),
  908. nTatolXrayCount, i, poi.x, poi.y);
  909. }
  910. }
  911. }
  912. // ok, return true
  913. return TRUE;
  914. }
  915. BOOL COTSBrukerImpl::ReadXRayPointsByFeature(std::vector<CPosXray*>& a_vXPoints, const DWORD /*a_nACTimeMS*/)
  916. {
  917. // point list is empty?
  918. if (a_vXPoints.empty())
  919. {
  920. // doing nothing if point list is empty
  921. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPointsByFeature: point list is empty"));
  922. // ok, return true
  923. return TRUE;
  924. }
  925. long nCollectCount = (long)a_vXPoints.size();
  926. // get the specs for a_vXPoints
  927. static DWORD nChannelData[(int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS];
  928. for (int i = 0; i < nCollectCount; ++i)
  929. {
  930. // cleanup data storage
  931. memset(nChannelData, 0, sizeof(DWORD) * (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS);
  932. // get spectrum data of a point
  933. bool success = GetFeatureListSpectrum(i, (long*)nChannelData);
  934. if (!success)
  935. {
  936. // error
  937. CPoint poi = a_vXPoints[i]->GetPosition();
  938. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPointsByFeature:Call GetFeatureListSpectrum failed: index = %d(x:%d, y:%d)"),
  939. i,
  940. poi.x,
  941. poi.y);
  942. return FALSE;
  943. }
  944. // set spectrum data for the x-ray point
  945. a_vXPoints[i]->SetXrayData(nChannelData);
  946. }
  947. //ok, return true
  948. return TRUE;
  949. }
  950. BOOL COTSBrukerImpl::ReadXRayPointsByFeature(CPosXrayList& a_vXPoints, const DWORD a_nACTimeMS)
  951. {
  952. // point list is empty?
  953. if (a_vXPoints.empty())
  954. {
  955. // point list is empty
  956. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPointsByFeature: point list is empty"));
  957. // ok, return true
  958. return TRUE;
  959. }
  960. long nCollectCount = (long)a_vXPoints.size();
  961. // get the specs for a_vXPoints
  962. static DWORD nChannelData[(int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS];
  963. for (int i = 0; i < nCollectCount; ++i)
  964. {
  965. // cleanup data storage
  966. memset(nChannelData, 0, sizeof(DWORD) * (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS);
  967. // get spectrum data of a point
  968. bool success = GetFeatureListSpectrum(i, (long*)nChannelData);
  969. if (!success)
  970. {
  971. // error
  972. CPoint poi = a_vXPoints[i]->GetPosition();
  973. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPointsByFeature:Call GetFeatureListSpectrum failed: index = %d(x:%d, y:%d)"),
  974. i,
  975. poi.x,
  976. poi.y);
  977. return FALSE;
  978. }
  979. // set spectrum data for the x-ray point
  980. a_vXPoints[i]->SetXrayData(nChannelData);
  981. }
  982. // ok, return true
  983. return TRUE;
  984. }
  985. // protected
  986. // query servers
  987. BOOL COTSBrukerImpl::QueryBrukerServers(void)
  988. {
  989. // query servers
  990. long nBufferSize = (long)BRUKER_PARAM::BUF_LENGTH;
  991. m_psServerName.reset(new char[(int)BRUKER_PARAM::BUF_LENGTH]);
  992. memset(m_psServerName.get(), 0, nBufferSize);
  993. int ret = BrukerDll::QueryServers(m_psServerName.get(), nBufferSize);
  994. if ( ret!= 0)
  995. {
  996. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QueryServers: failed to call QueryServers method."));
  997. return FALSE;
  998. }
  999. // ok, return TRUE
  1000. return TRUE;
  1001. }
  1002. // Open Client
  1003. // return true if success
  1004. BOOL COTSBrukerImpl::OpenClient(void)
  1005. {
  1006. // first attempt to open client
  1007. BOOL bStartNew = FALSE;
  1008. BOOL bGUI = FALSE;
  1009. BOOL bRet = OpenClient(m_psServerName.get(), "edx", "edx", static_cast<BYTE>(bStartNew), static_cast<BYTE>(bGUI), m_nClientID);
  1010. if (!bRet)
  1011. {
  1012. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::OpenClient: call OpenClient failed at the first attempt."));
  1013. }
  1014. // double check the connection if client id is zero
  1015. BOOL bConnected = FALSE;
  1016. if (m_nClientID == 0)
  1017. {
  1018. // check if connection is OK
  1019. if (!CheckConnection(bConnected))
  1020. {
  1021. // failed to check connection
  1022. m_bConnected = false;
  1023. return FALSE;
  1024. }
  1025. // try to open client again if there is no connection
  1026. if (!bConnected)
  1027. {
  1028. // second attempt to open client
  1029. bRet = OpenClient(m_psServerName.get(), "edx", "edx", static_cast<BYTE>(bStartNew), static_cast<BYTE>(bGUI), m_nClientID);
  1030. if (!bRet)
  1031. {
  1032. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::OpenClient: call OpenClient failed at the second attempt."));
  1033. m_bConnected = false;
  1034. }
  1035. }
  1036. }
  1037. if (bRet)
  1038. {
  1039. m_bConnected = true;
  1040. }
  1041. // return method return flag
  1042. return bRet;
  1043. }
  1044. BOOL COTSBrukerImpl::OpenClient(char* a_sServerName, char* a_sUserName, char* a_sPassword, BYTE a_nStartNew, BYTE a_bGUI, uint32_t& a_nClientID)
  1045. {
  1046. // open client
  1047. int32_t bRet = BrukerDll::OpenClient(a_sServerName, a_sUserName, a_sPassword, a_nStartNew, a_bGUI, a_nClientID);
  1048. if (bRet!=0)
  1049. {
  1050. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::OpenClient: failed to open client dll."));
  1051. return false;
  1052. }
  1053. return true;
  1054. }
  1055. // check detector states and set m_nSPU // Bruker四个有一个盒子,盒子共接4个探头
  1056. BOOL COTSBrukerImpl::SetSPU(void)
  1057. {
  1058. long nCombineValue = 0;
  1059. BOOL bCombine = FALSE;
  1060. // check if the first detector is OK
  1061. BOOL bFirst = FALSE;
  1062. uint32_t nMaxEnergy1;
  1063. if (!CheckDetectorState(FIRST_DETECTOR_ID, bFirst, nMaxEnergy1))
  1064. {
  1065. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: failed to call CheckDetectorState method (first)."));
  1066. return FALSE;
  1067. }
  1068. if (bFirst)
  1069. {
  1070. nCombineValue = m_nSPU = FIRST_DETECTOR_COM;
  1071. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: find first."));
  1072. }
  1073. // check if the second detector is OK
  1074. BOOL bSecond = FALSE;
  1075. uint32_t nMaxEnergy2;
  1076. if (!CheckDetectorState(SECOND_DETECTOR_ID, bSecond, nMaxEnergy2))
  1077. {
  1078. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: failed to call CheckDetectorState method (second)."));
  1079. return FALSE;
  1080. }
  1081. if (bSecond)
  1082. {
  1083. m_nSPU = SECOND_DETECTOR_ID;
  1084. if (nCombineValue != 0)
  1085. {
  1086. bCombine = TRUE;
  1087. m_nSPU = FIRST_DETECTOR_ID;
  1088. }
  1089. nCombineValue += SECOND_DETECTOR_COM;
  1090. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: find second."));
  1091. }
  1092. // the third detector is OK
  1093. BOOL bThird = FALSE;
  1094. uint32_t nMaxEnergy3;
  1095. if (!CheckDetectorState(THIRD_DETECTOR_ID, bThird, nMaxEnergy3))
  1096. {
  1097. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: failed to call CheckDetectorState method (third)."));
  1098. return FALSE;
  1099. }
  1100. if (bThird)
  1101. {
  1102. m_nSPU = THIRD_DETECTOR_ID;
  1103. if (nCombineValue != 0)
  1104. {
  1105. bCombine = TRUE;
  1106. m_nSPU = FIRST_DETECTOR_ID;
  1107. }
  1108. nCombineValue += THIRD_DETECTOR_COM;
  1109. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: find third."));
  1110. }
  1111. // the fourth detector is OK
  1112. BOOL bFourth = FALSE;
  1113. uint32_t nMaxEnergy4;
  1114. if (!CheckDetectorState(FOURTH_DETECTOR_ID, bFourth, nMaxEnergy4))
  1115. {
  1116. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: failed to call CheckDetectorState method (fourth)."));
  1117. return FALSE;
  1118. }
  1119. if (bFourth)
  1120. {
  1121. m_nSPU = FOURTH_DETECTOR_ID;
  1122. if (nCombineValue != 0)
  1123. {
  1124. bCombine = TRUE;
  1125. m_nSPU = FIRST_DETECTOR_ID;
  1126. }
  1127. nCombineValue += FOURTH_DETECTOR_COM;
  1128. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: find fourth."));
  1129. }
  1130. // combine the two detectors if more than one active detectors.
  1131. BOOL bRet = FALSE;
  1132. if (bCombine)
  1133. {
  1134. bRet = BrukerDll::CombineSpectrometer(m_nClientID, nCombineValue)==0;
  1135. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: find combined."));
  1136. }
  1137. else
  1138. {
  1139. bRet = (nCombineValue != 0);
  1140. if (!bRet)
  1141. {
  1142. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: no detactor."));
  1143. }
  1144. }
  1145. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetSPU: result is %d."), bRet);
  1146. // method return flag
  1147. return bRet;
  1148. }
  1149. // check detector State
  1150. BOOL COTSBrukerImpl::CheckDetectorState(long a_nDetectorId, BOOL& a_bState, uint32_t& a_nMaxEnergy)
  1151. {
  1152. // get spectrum configuration
  1153. uint32_t nPulseThroughput;
  1154. a_bState = BrukerDll::GetSpectrometerConfiguration(m_nClientID, a_nDetectorId, a_nMaxEnergy, nPulseThroughput);
  1155. // ok, return TRUE
  1156. return TRUE;
  1157. }
  1158. // Close Client
  1159. // return true if success
  1160. BOOL COTSBrukerImpl::CloseClient(void)
  1161. {
  1162. LogTrace(__FILE__, __LINE__, _T("Close Bruker client...")+ CString(std::to_string(m_nClientID).c_str()));
  1163. if (BrukerDll::CloseClient(m_nClientID) != 0)
  1164. {
  1165. LogErrorTrace(__FILE__, __LINE__, " COTSBrukerImpl::CloseClient failed ");
  1166. return FALSE;
  1167. }
  1168. return TRUE;
  1169. }
  1170. /// collect a x ray point
  1171. /// input: CPoint a_oPoi,
  1172. // DWORD a_nLifeTimeMilliSeconds,
  1173. // long* a_pXRayData,
  1174. // DWORD a_nBufferSize,
  1175. // CollectOneXRayPoint
  1176. /// return true if success
  1177. BOOL COTSBrukerImpl::CollectOneXRayPoint(
  1178. const CPoint& a_oPoi,
  1179. DWORD a_nLifeTimeMilliSeconds,
  1180. long* a_pXRayData,
  1181. DWORD a_nBufferSize,
  1182. bool a_bSetHeadStruc)
  1183. {
  1184. // move beam to the point
  1185. if (!ImageSetPoint(a_oPoi))
  1186. {
  1187. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectOneXRayPoint:Call ImageSetPoint failed: at position [%d, %d]"), a_oPoi.x, a_oPoi.y);
  1188. return FALSE;
  1189. }
  1190. // collect a x-ray
  1191. if (!CollectSpectrum(a_nLifeTimeMilliSeconds, a_pXRayData, a_nBufferSize))
  1192. {
  1193. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectOneXRayPoint:Call CollectSpectrum failed : at position[%d, %d]"), a_oPoi.x, a_oPoi.y);
  1194. return FALSE;
  1195. }
  1196. // ok, return true
  1197. return TRUE;
  1198. }
  1199. BOOL COTSBrukerImpl::StartSpectrumMeasurement()
  1200. {
  1201. DWORD nRealTime = 0;
  1202. // Success?
  1203. if (BrukerDll::StartSpectrumMeasurement(m_nClientID, m_nSPU, nRealTime) != 0)
  1204. {
  1205. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::::StartSpectrumMeasurement:Call StartSpectrumMeasurement failed: client id is %d"), m_nClientID);
  1206. return FALSE;
  1207. }
  1208. // ok, return true
  1209. return TRUE;
  1210. }
  1211. // call IsSpectrumMeterRunning
  1212. // return true if success
  1213. BOOL COTSBrukerImpl::IsSpectrumMeterRunning(BOOL& a_bRunning)
  1214. {
  1215. double nState;
  1216. double nPulseRate;
  1217. bool bRunning;
  1218. if (BrukerDll::GetSpectrumMeasureState(m_nClientID, 1, bRunning, nState, nPulseRate) != 0)
  1219. {
  1220. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::IsSpectrumMeterRunning:Call GetSpectrumMeasureState failed: client id is %d"), m_nClientID);
  1221. return FALSE;
  1222. }
  1223. a_bRunning = (BOOL)bRunning;
  1224. // ok, return true
  1225. return TRUE;
  1226. }
  1227. // call StopSpectrumMeter
  1228. // return true if success
  1229. BOOL COTSBrukerImpl::StopSpectrumMeasure(void)
  1230. {
  1231. if (BrukerDll::StopSpectrumMeasurement(m_nClientID, 1) != 0)
  1232. {
  1233. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StopSpectrumMeter:Call StopSpectrumMeasurement failed: client id is %d"), m_nClientID);
  1234. return FALSE;
  1235. }
  1236. // ok, return true
  1237. return TRUE;
  1238. }
  1239. BOOL COTSBrukerImpl::ReadSpectrum(long* a_pXRayData, DWORD a_nBufferSize)
  1240. {
  1241. // read spectrum
  1242. if (!ReadSpectrum())
  1243. {
  1244. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::Read Spectrum failed."));
  1245. return FALSE;
  1246. }
  1247. // copy spectrum
  1248. if (!CopySpectrum(a_pXRayData, a_nBufferSize))
  1249. {
  1250. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadSpectrum:Copy Spectrum failed."));
  1251. return FALSE;
  1252. }
  1253. // ok, return true
  1254. return TRUE;
  1255. }
  1256. // get quantification method name strings (automatic only)
  1257. BOOL COTSBrukerImpl::GetQuantificationMethods(std::vector<CString>& a_vMethods)
  1258. {
  1259. // automatic methods only
  1260. bool AUTOMATIC_ONLY = true;
  1261. // char buffer size
  1262. const long CHAR_BUFFER_SIZE = 4096 * 100;
  1263. // char buffer
  1264. char cBuffer[CHAR_BUFFER_SIZE];
  1265. int32_t nBufferSize = CHAR_BUFFER_SIZE;
  1266. // get quantification method name strings
  1267. if (BrukerDll::GetQuantificationMethods(m_nClientID, AUTOMATIC_ONLY, cBuffer, nBufferSize) != 0)
  1268. {
  1269. LogErrorTrace(__FILE__, __LINE__, _T("Call GetQuantificationMethods failed: client id is %d"), m_nClientID);
  1270. return FALSE;
  1271. }
  1272. // get the quantification method name strings
  1273. CString strMethodsNames = CControllerHelper::CharToString(cBuffer);
  1274. LogTrace(__FILE__, __LINE__, _T("Result: %s"), strMethodsNames);
  1275. // clear the method strings list
  1276. a_vMethods.clear();
  1277. // separate the method strings
  1278. a_vMethods = CControllerHelper::SplitString(strMethodsNames, _T("\n"));
  1279. // ok, return true
  1280. return TRUE;
  1281. }
  1282. BOOL COTSBrukerImpl::QuantifyXrayPoint(CPosXray* a_pXRayPoint, CString a_strMethodName)
  1283. {
  1284. ASSERT(a_pXRayPoint);
  1285. if (!a_pXRayPoint)
  1286. {
  1287. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifyXrayPoint:x-ray point is empty, return"));
  1288. return FALSE;
  1289. }
  1290. // method name validation
  1291. a_strMethodName.Trim();
  1292. ASSERT(!a_strMethodName.IsEmpty());
  1293. if (a_strMethodName.IsEmpty())
  1294. {
  1295. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifyXrayPoint:method name is empty, return"));
  1296. return FALSE;
  1297. }
  1298. CString sFilePathName = GetQuantificationSpectrumPathName();
  1299. // export
  1300. CBrukerSPXFileMgr spxFileHelpers;
  1301. if (!spxFileHelpers.ExportXrayPoint(sFilePathName, _T("Quantification"), a_pXRayPoint))
  1302. {
  1303. LogErrorTrace(__FILE__,__LINE__,_T("Save quantification file(%s) failed."), sFilePathName);
  1304. return FALSE;
  1305. }
  1306. CElementChemistriesList vElementChemistry;
  1307. if (!QuantifySpectrumFile(sFilePathName, a_strMethodName, vElementChemistry))
  1308. {
  1309. LogErrorTrace(__FILE__,__LINE__,_T("Quantify spectrum by method %s from file(%s) failed."), a_strMethodName, sFilePathName);
  1310. return FALSE;
  1311. }
  1312. a_pXRayPoint->SetElementQuantifyData(vElementChemistry);
  1313. // ok, return true
  1314. return true;
  1315. }
  1316. BOOL COTSBrukerImpl::QuantifyPosXrayPointsOnLine(std::vector<CPosXrayPtr>& a_vXRayParts)
  1317. {
  1318. if (!SetXRayPoints(a_vXRayParts))
  1319. {
  1320. // failed to call ReadXRayPoints method
  1321. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPoints: failed to call ReadXRayPoints method."));
  1322. return FALSE;
  1323. }
  1324. // ok, return true
  1325. return true;
  1326. }
  1327. BOOL COTSBrukerImpl::QuantifyPosXrayPointOnLine(CPosXrayPtr a_vXRayPart)
  1328. {
  1329. char* pcMethod = "Default";//"Default";//"Automatic";
  1330. char* pcParams = "ResultType=quantification";
  1331. char cResult[10000];
  1332. memset(cResult, 0, 10000);
  1333. if (BrukerDll::QuantifyPointListSpectrum(m_nClientID, a_vXRayPart->GetIndex(), pcMethod, pcParams, cResult, 10000, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE) != 0)
  1334. {
  1335. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifyPosXrayPointOnLine failed to call QuantifyPointListSpectrum method at index %d, error code %d"), a_vXRayPart->GetIndex(), -1);
  1336. return false;
  1337. }
  1338. CElementChemistriesList listElement = CElement::ExtractElementChemistrys(CControllerHelper::CharToString(cResult));
  1339. a_vXRayPart->SetElementQuantifyData(listElement);
  1340. return true;
  1341. }
  1342. BOOL COTSBrukerImpl::QuantifySpectrumFile(LPCTSTR a_sFilePathName, CString a_strMethodName, CElementChemistriesList& a_vElementChemistry)
  1343. {
  1344. ASSERT(a_sFilePathName);
  1345. if (!a_sFilePathName)
  1346. {
  1347. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::QuantifySpectrumFile:file path name is not correct, return"));
  1348. return FALSE;
  1349. }
  1350. char sPathName[MAX_PATH];
  1351. CControllerHelper::WCharToChar((const wchar_t *)a_sFilePathName, sPathName);
  1352. if (!LoadSpectrum(sPathName))
  1353. {
  1354. LogErrorTrace(__FILE__,__LINE__,_T("LoadSpectrum from file(%s) failed"), a_sFilePathName);
  1355. return FALSE;
  1356. }
  1357. LogTrace(__FILE__,__LINE__,_T("Loaded spectrum to Bruker from file %s"), a_sFilePathName);
  1358. if (m_bShowQuantificationSpectrum)
  1359. {
  1360. ShowSpectrum(0, "Quantification");
  1361. }
  1362. char cMethod[(int)BRUKER_PARAM::BUF_LENGTH];
  1363. CControllerHelper::WCharToChar((const wchar_t *)&a_strMethodName, cMethod);
  1364. char* pcParams = "ResultType=quantification";
  1365. char cResult[(int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE];
  1366. memset(cResult, 0, (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE);
  1367. LogTrace(__FILE__,__LINE__,_T("To QuantifySpectrum"));
  1368. if (BrukerDll::QuantifySpectrum(m_nClientID, 0, cMethod, pcParams, cResult, (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE) != 0)
  1369. {
  1370. LogErrorTrace(__FILE__,__LINE__,_T("Call QuantifySpectrum failed: client id is %d."), m_nClientID);
  1371. return FALSE;
  1372. }
  1373. // convert the result char to string
  1374. CString strResult = CControllerHelper::CharToString(cResult);
  1375. LogTrace(__FILE__,__LINE__,_T("Result: %s"), strResult);
  1376. // separate the result string to element chemistry string
  1377. std::vector<CString> vElementChemistryStrings = CControllerHelper::SplitString(strResult, _T("\n"));
  1378. for (auto& strElementChemistry : vElementChemistryStrings)
  1379. {
  1380. CElementChemistryPtr oElementChemistryData;
  1381. if (GetElementChemistryData(*oElementChemistryData.get(), strElementChemistry))
  1382. {
  1383. a_vElementChemistry.push_back(oElementChemistryData);
  1384. }
  1385. }
  1386. // ok, return true
  1387. return TRUE;
  1388. }
  1389. RTSpectrumHeaderRec* COTSBrukerImpl::GetSectrumHeader()
  1390. {
  1391. // safety check
  1392. ASSERT(m_psRTSpectrumBuffer);
  1393. if (!m_psRTSpectrumBuffer)
  1394. {
  1395. // error, invalid m_psRTSpectrumBuffer
  1396. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetSectrumHeader: invalid m_psRTSpectrumBuffer"));
  1397. // return nullptr
  1398. return nullptr;
  1399. }
  1400. return (RTSpectrumHeaderRec*)m_psRTSpectrumBuffer.get();
  1401. }
  1402. // call GetSpectrum
  1403. // return true if success
  1404. BOOL COTSBrukerImpl::GetSpectrum(long a_nBufferIndex, BrukerDll::PRTSpectrumHeaderRec a_poSpcHR, long a_nBufferSize)
  1405. {
  1406. if (BrukerDll::GetSpectrum(m_nClientID, a_nBufferIndex, a_poSpcHR, a_nBufferSize) != 0)
  1407. {
  1408. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetSpectrum:Call GetSpectrum failed: client id is %d, error code is %d."), m_nClientID);
  1409. return FALSE;
  1410. }
  1411. // ok, return true
  1412. return TRUE;
  1413. }
  1414. BOOL COTSBrukerImpl::LoadSpectrum(char* a_sFilePathName)
  1415. {
  1416. // safety check
  1417. ASSERT(a_sFilePathName);
  1418. if (!a_sFilePathName)
  1419. {
  1420. // invalid a_sFilePathName
  1421. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::LoadSpectrum: invalid a_sFilePathName"));
  1422. return FALSE;
  1423. }
  1424. if (BrukerDll::LoadSpectrum(m_nClientID, a_sFilePathName) != 0)
  1425. {
  1426. // error, failed to call LoadSpectrum method
  1427. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::LoadSpectrum: failed to call LoadSpectrum method. client id is %d."), m_nClientID);
  1428. return FALSE;
  1429. }
  1430. // ok, return true
  1431. return TRUE;
  1432. }
  1433. // call ReadSpectrum
  1434. // return true if success
  1435. BOOL COTSBrukerImpl::ReadSpectrum(void)
  1436. {
  1437. if (BrukerDll::ReadSpectrum(m_nClientID, 1) != 0)
  1438. {
  1439. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadSpectrum:Call ReadSpectrum failed: client id is %d"), m_nClientID);
  1440. return FALSE;
  1441. }
  1442. // ok, return true
  1443. return TRUE;
  1444. }
  1445. // put spectrum into Bruker system
  1446. BOOL COTSBrukerImpl::PutSpectrum(char* a_pBuffer, long a_nBufferSize)
  1447. {
  1448. if (BrukerDll::PutSpectrum(m_nClientID, a_pBuffer, a_nBufferSize) != 0)
  1449. {
  1450. // error, fail to call PutSpectrum method
  1451. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::PutSpectrum: failed to call PutSpectrum."), m_nClientID);
  1452. return FALSE;
  1453. }
  1454. // ok, return true
  1455. return TRUE;
  1456. }
  1457. BOOL COTSBrukerImpl::CreateSpectrum(char* m_pParamBuffer, BrukerDll::PRTSpectrumHeaderRec a_poSpcHR, char* m_pResultBuffer, int32_t& a_nBufferSize)
  1458. {
  1459. // safety check
  1460. ASSERT(m_pParamBuffer);
  1461. if (!m_pParamBuffer)
  1462. {
  1463. // error, invalid m_pParamBuffer
  1464. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CreateSpectrum: invalid m_pParamBuffer"));
  1465. return FALSE;
  1466. }
  1467. ASSERT(a_poSpcHR);
  1468. if (!a_poSpcHR)
  1469. {
  1470. // invalid a_poSpcHR
  1471. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CreateSpectrum: invalid a_poSpcHR"));
  1472. return FALSE;
  1473. }
  1474. ASSERT(m_pResultBuffer);
  1475. if (!m_pResultBuffer)
  1476. {
  1477. // error, invalid m_pResultBuffer
  1478. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CreateSpectrum: invalid m_pResultBuffer"));
  1479. return FALSE;
  1480. }
  1481. if (BrukerDll::CreateSpectrum(m_pParamBuffer, a_poSpcHR, m_pResultBuffer, a_nBufferSize) != 0)
  1482. {
  1483. // error, failed to call CreateSpectrum method
  1484. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CreateSpectrum: failed to call CreateSpectrum method. client id is %d."), m_nClientID);
  1485. return FALSE;
  1486. }
  1487. // ok, return true
  1488. return TRUE;
  1489. }
  1490. BOOL COTSBrukerImpl::ShowSpectrum(long a_nBufferIndex, char* a_pSpectumName)
  1491. {
  1492. ASSERT(a_pSpectumName);
  1493. if (!a_pSpectumName)
  1494. {
  1495. // error, invalid a_pSpectumName
  1496. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ShowSpectrum: invalid a_pSpectumName"));
  1497. return FALSE;
  1498. }
  1499. if (BrukerDll::ShowSpectrum(m_nClientID, a_nBufferIndex, a_pSpectumName) != 0)
  1500. {
  1501. // error, failed to call ShowSpectrum method
  1502. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ShowSpectrum: failed to call ShowSpectrum method. client id is %d."), m_nClientID);
  1503. return FALSE;
  1504. }
  1505. // ok, return true
  1506. return TRUE;
  1507. }
  1508. BOOL COTSBrukerImpl::GetSpectrometerParams(long a_nBufferIndex, char* a_pBuffer, int32_t& a_nBufferSize)
  1509. {
  1510. if (BrukerDll::GetSpectrometerParams(m_nClientID, a_nBufferIndex, a_pBuffer, a_nBufferSize) != 0)
  1511. {
  1512. // error, failed to call GetSpectrometerParams method
  1513. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetSpectrometerParams: failed to call GetSpectrometerParams method. client id is %d."), m_nClientID);
  1514. return FALSE;
  1515. }
  1516. // ok, return true
  1517. return TRUE;
  1518. }
  1519. BOOL COTSBrukerImpl::GetElementChemistryData(CElementChemistry& a_oElementChemistryData, CString a_strElementChemistry)
  1520. {
  1521. // split element chemistry string
  1522. std::vector<CString> vString = CControllerHelper::SplitString(a_strElementChemistry, _T(","));
  1523. // the strings list should has at least three strings
  1524. long MIN_STRINGs_COUNT = 3;
  1525. if (MIN_STRINGs_COUNT > (long)vString.size())
  1526. {
  1527. return FALSE;
  1528. }
  1529. // name
  1530. CString strName = vString[0];
  1531. strName.Trim();
  1532. if (strName.IsEmpty())
  1533. {
  1534. return FALSE;
  1535. }
  1536. auto nPos = strName.Find(_T("="));
  1537. CString strTempName;
  1538. if (nPos > 0)
  1539. {
  1540. strTempName = strName.Right(strName.GetLength() - nPos - 1);
  1541. }
  1542. else
  1543. {
  1544. LogErrorTrace(__FILE__,__LINE__,_T("Wrong element name string(%s)"), strName);
  1545. strTempName = strName.Right(1);
  1546. }
  1547. a_oElementChemistryData.SetName(strTempName);
  1548. // percentage
  1549. CString strPercentage = vString[2];
  1550. strPercentage.Trim();
  1551. if (strPercentage.IsEmpty())
  1552. {
  1553. return FALSE;
  1554. }
  1555. double dPercentage;
  1556. if (!CControllerHelper::StringToDouble(strPercentage, dPercentage))
  1557. {
  1558. return FALSE;
  1559. }
  1560. a_oElementChemistryData.SetPercentage(dPercentage);
  1561. // OK return true
  1562. return TRUE;
  1563. }
  1564. // call CopySpectrum
  1565. // return true if success
  1566. BOOL COTSBrukerImpl::CopySpectrum(long* a_pXRayData, DWORD a_nBufferSize)
  1567. {
  1568. // start x ray measurement
  1569. if (!GetSpectrum(1, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE))
  1570. {
  1571. // error, failed to call GetSpectrum method
  1572. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl:: failed to call GetSpectrum method."));
  1573. return FALSE;
  1574. }
  1575. // convert spectrum
  1576. if (!ConvertSpectrum((RTSpectrumHeaderRec*)m_psRTSpectrumBuffer.get(), a_pXRayData, a_nBufferSize))
  1577. {
  1578. // error failed to call ConvertSpectrum method
  1579. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::Call ConvertSpectrum failed."));
  1580. return FALSE;
  1581. }
  1582. // set head struck
  1583. // always get a spectrum header for exporting quantify header
  1584. m_pSpectrumHead = (RTSpectrumHeaderRec*)m_psRTSpectrumBuffer.get();
  1585. // ok, return true
  1586. return TRUE;
  1587. }
  1588. // start spectrum life time measurement
  1589. BOOL COTSBrukerImpl::StartSpectrumLifeTimeMeasurement(DWORD a_nLifeTime)
  1590. {
  1591. if (BrukerDll::StartSpectrumLifeTimeMeasurement(m_nClientID, m_nSPU, a_nLifeTime) != 0)
  1592. {
  1593. // error, failed to call StartSpectrumLifeTimeMeasurement method
  1594. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StartSpectrumLifeTimeMeasurement: failed to call StartSpectrumLifeTimeMeasurement method. client id is %d"), m_nClientID);
  1595. return FALSE;
  1596. }
  1597. // ok, return true
  1598. return TRUE;
  1599. }
  1600. // call StartSpectrumLifeTimeMeasurement
  1601. // return true if success
  1602. BOOL COTSBrukerImpl::SpectrumLifeTimeMeasurement(DWORD a_nLifeTime)
  1603. {
  1604. if (!StartSpectrumLifeTimeMeasurement(a_nLifeTime))
  1605. {
  1606. // error failed to call StartSpectrumLifeTimeMeasurement method
  1607. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumLifeTimeMeasurement: failed to call StartSpectrumLifeTimeMeasurement method."));
  1608. return FALSE;
  1609. }
  1610. // check to see if the system has finished the action
  1611. #pragma warning(suppress: 28159)
  1612. DWORD nStart = GetTickCount();
  1613. DWORD nEnd = nStart;
  1614. BOOL bRunning = TRUE;
  1615. do
  1616. {
  1617. #pragma warning(suppress: 28159)
  1618. nEnd = GetTickCount();
  1619. if (!IsSpectrumMeterRunning(bRunning))
  1620. {
  1621. // error, failed to call IsSpectrumMeterRunning method
  1622. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumLifeTimeMeasurement: failed to call IsSpectrumMeterRunning method."));
  1623. return FALSE;
  1624. }
  1625. } while (nEnd >= nStart && nEnd <= (nStart + a_nLifeTime + 1) && bRunning);
  1626. // force to stop if system still busy
  1627. if (bRunning && !StopSpectrumMeasure())
  1628. {
  1629. // error, failed to call stop StopSpectrumMeter method
  1630. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumLifeTimeMeasurement: failed to call StopSpectrumMeter method."));
  1631. return FALSE;
  1632. }
  1633. // ok, return true
  1634. return TRUE;
  1635. }
  1636. // Start Spectrum Real Time Measurement
  1637. BOOL COTSBrukerImpl::StartSpectrumRealTimeMeasurement(DWORD a_nRealTime)
  1638. {
  1639. if (BrukerDll::StartSpectrumMeasurement(m_nClientID, m_nSPU, a_nRealTime) != 0)
  1640. {
  1641. // error, failed to call StartSpectrumMeasurement method
  1642. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StartSpectrumRealTimeMeasurement: failed to call StartSpectrumMeasurement method. client id is %d."), m_nClientID);
  1643. return FALSE;
  1644. }
  1645. // ok, return true
  1646. return TRUE;
  1647. }
  1648. // call StartSpectrumRealTimeMeasurement
  1649. // return true if success
  1650. BOOL COTSBrukerImpl::SpectrumRealTimeMeasurement(DWORD a_nRealTime)
  1651. {
  1652. if (!StartSpectrumRealTimeMeasurement(a_nRealTime))
  1653. {
  1654. // error, failed to call StartSpectrumRealTimeMeasurement method
  1655. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumRealTimeMeasurement: failed to call StartSpectrumRealTimeMeasurement method."));
  1656. return FALSE;
  1657. }
  1658. // check to see if the system has finished the action
  1659. #pragma warning(suppress: 28159)
  1660. DWORD nStart = GetTickCount();
  1661. DWORD nEnd = nStart;
  1662. BOOL bRunning = TRUE;
  1663. do
  1664. {
  1665. #pragma warning(suppress: 28159)
  1666. nEnd = GetTickCount();
  1667. if (!IsSpectrumMeterRunning(bRunning))
  1668. {
  1669. // error, failed to call IsSpectrumMeterRunning method
  1670. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumRealTimeMeasurement: failed to call IsSpectrumMeterRunning method."));
  1671. return FALSE;
  1672. }
  1673. } while (nEnd >= nStart && nEnd <= (nStart + a_nRealTime + 1) && bRunning);
  1674. // force to stop if system still busy
  1675. if (bRunning && !StopSpectrumMeasure())
  1676. {
  1677. // error failed to call StopSpectrumMeter method
  1678. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumRealTimeMeasurementCall: failed to call StopSpectrumMeter method."));
  1679. return FALSE;
  1680. }
  1681. // ok, return true
  1682. return TRUE;
  1683. }
  1684. BOOL COTSBrukerImpl::SpectrumCountsMeasurement(DWORD a_nTotalCounts, int a_nTimeLimit /*= -1*/)
  1685. {
  1686. if (a_nTimeLimit <= 0)
  1687. {
  1688. a_nTimeLimit = DEFAULT_MAX_WAIT_TIME_COLLECT_COUNTS;
  1689. }
  1690. if (!StartSpectrumMeasurement())
  1691. {
  1692. // error, failed to call StartSpectrumMeasurement method
  1693. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: failed to call StartSpectrumMeasurement method."));
  1694. return FALSE;
  1695. }
  1696. // check to see if the system has finished the action
  1697. #pragma warning(suppress: 28159)
  1698. DWORD nStartTime = GetTickCount();
  1699. DWORD nEndTime = nStartTime;
  1700. BOOL bRunning = TRUE;
  1701. do
  1702. {
  1703. if (!IsSpectrumMeterRunning(bRunning))
  1704. {
  1705. // error, failed to call IsSpectrumMeterRunning method
  1706. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: failed to call IsSpectrumMeterRunning method."));
  1707. return FALSE;
  1708. }
  1709. if (!bRunning)
  1710. {
  1711. // get out if bruker stopped
  1712. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: Bruker stopped."));
  1713. break;
  1714. }
  1715. // read spectrum
  1716. if (!ReadSpectrum())
  1717. {
  1718. // error, failed to call ReadSpectrum method
  1719. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: failed to call ReadSpectrum method."));
  1720. return FALSE;
  1721. }
  1722. // get a x ray
  1723. if (!GetSpectrum(1, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE))
  1724. {
  1725. // error, failed to call GetSpectrum method
  1726. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: failed to call GetSpectrum(1) method."));
  1727. return FALSE;
  1728. }
  1729. // quick to check total counts
  1730. // pcharTemp point to start of whole spectrum
  1731. char* pcharTemp = (char*)m_psRTSpectrumBuffer.get();
  1732. // jump over spectrum head, pcharTemp points to the data block
  1733. pcharTemp += sizeof(RTSpectrumHeaderRec);
  1734. // pLongChannels point to the data block
  1735. long* pLongChannels = (long*)pcharTemp;
  1736. RTSpectrumHeaderRec* pSpectrumHead = (RTSpectrumHeaderRec*)m_psRTSpectrumBuffer.get();
  1737. int nTotalChannel = pSpectrumHead->ChannelCount;
  1738. DWORD nTotalPoints = 0;
  1739. for (int i = 0; i < nTotalChannel; ++i)
  1740. {
  1741. nTotalPoints += pLongChannels[i];
  1742. }
  1743. #pragma warning(suppress: 28159)
  1744. nEndTime = GetTickCount();
  1745. if (nTotalPoints >= a_nTotalCounts)
  1746. {
  1747. // get out, get enough points
  1748. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: Stop collection: Got enough points"));
  1749. break;
  1750. }
  1751. // stop collection if it take too long
  1752. if (nEndTime > (nStartTime + a_nTimeLimit + 1))
  1753. {
  1754. // get out, took too long
  1755. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: Stop collection, took too long."));
  1756. break;
  1757. }
  1758. } while (bRunning);
  1759. // force to stop if system still busy
  1760. if (bRunning && !StopSpectrumMeasure())
  1761. {
  1762. // error, failed to call StopSpectrumMeter method
  1763. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SpectrumCountsMeasurement: failed to call StopSpectrumMeter method."));
  1764. return FALSE;
  1765. }
  1766. // ok, return true
  1767. return TRUE;
  1768. }
  1769. BOOL COTSBrukerImpl::ConvertSpectrum(RTSpectrumHeaderRec* a_poSpcHR, long* a_pXRayData, DWORD a_nBufferSize)
  1770. {
  1771. // safety check
  1772. ASSERT(a_poSpcHR);
  1773. if (!a_poSpcHR)
  1774. {
  1775. // error, invalid a_poSpcHR
  1776. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ConvertSpectrum: invalid a_poSpcHR."));
  1777. return FALSE;
  1778. }
  1779. if (!(a_nBufferSize > 0))
  1780. {
  1781. // error, invalid buffer size
  1782. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ConvertSpectrum: invalid buffer size."));
  1783. return FALSE;
  1784. }
  1785. a_poSpcHR->ChannelCount = 4096;
  1786. ASSERT(a_pXRayData);
  1787. if (!a_pXRayData)
  1788. {
  1789. // error, invalid a_pXRayData
  1790. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ConvertSpectrum: invalid a_pXRayData."));
  1791. return FALSE;
  1792. }
  1793. // calculate zero peak channel
  1794. long nZeroPeakChannel = 0;
  1795. const double MIN_CALIBRATION_LIN = 0.000001;
  1796. if (fabs(a_poSpcHR->CalibrationLin) > MIN_CALIBRATION_LIN)
  1797. {
  1798. nZeroPeakChannel = (long)fabs(a_poSpcHR->CalibrationAbs / a_poSpcHR->CalibrationLin);
  1799. }
  1800. // check if there are valid data channels
  1801. if (a_poSpcHR->ChannelCount / 2 <= nZeroPeakChannel)
  1802. {
  1803. // error, no channel data;
  1804. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ConvertSpectrum: no channel data (nZeroPeakChannel: %i)."), nZeroPeakChannel);
  1805. return FALSE;
  1806. }
  1807. // pcharTemp point to start of whole spectrum
  1808. char* pcharTemp = (char*)a_poSpcHR;
  1809. // jump over spectrum head, pcharTemp points to the data block
  1810. pcharTemp += sizeof(RTSpectrumHeaderRec);
  1811. // pLongChannels point to the data block
  1812. long* pLongChannels = (long*)pcharTemp;
  1813. // calculate zero peak ending channel
  1814. long nZeroPeakEndingChannel = nZeroPeakChannel;
  1815. // check if there are valid data channels
  1816. if (a_poSpcHR->ChannelCount <= nZeroPeakEndingChannel)
  1817. {
  1818. // no channel data
  1819. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ConvertSpectrum: no channel data nZeroPeakEndingChannel: %i)."), nZeroPeakEndingChannel);
  1820. return FALSE;
  1821. }
  1822. // find the end of the zero peak channel
  1823. long nPrevCount = pLongChannels[nZeroPeakEndingChannel];
  1824. for (long i = 0;
  1825. i < nZeroPeakChannel && // zero peak ending channel will be less than nZeroPeakChannel * 2
  1826. nPrevCount > 0;
  1827. ++i)
  1828. {
  1829. ++nZeroPeakEndingChannel;
  1830. long nCurrentCount = pLongChannels[nZeroPeakEndingChannel];
  1831. long nNextCount = pLongChannels[nZeroPeakEndingChannel + 1];
  1832. long nNextNextCountNext = pLongChannels[nZeroPeakEndingChannel + 2];
  1833. // if current count == 0 && nNextCount == 0 && nNextNextCountNext == 0
  1834. // or current > previous count && nNextCount > nCurrentCount && nNextNextCountNext > nNextCount, then this is
  1835. if ((nCurrentCount == 0 && nNextCount == 0 && nNextNextCountNext == 0) ||
  1836. (nCurrentCount > nPrevCount && nNextCount > nCurrentCount && nNextNextCountNext > nNextCount))
  1837. {
  1838. // find the zero peak ending channel, get out
  1839. break;
  1840. }
  1841. // the current count will be the
  1842. nPrevCount = nCurrentCount;
  1843. }
  1844. // calculate valid data channel number
  1845. long nDataChannelNO = a_poSpcHR->ChannelCount - nZeroPeakChannel;
  1846. // clean zero peak data
  1847. if (a_poSpcHR->ChannelCount > (nZeroPeakEndingChannel + 1))
  1848. {
  1849. memset(pLongChannels, 0, (nZeroPeakEndingChannel + 1) * sizeof(long));
  1850. }
  1851. // jump over zero peak channels
  1852. pLongChannels += nZeroPeakChannel;
  1853. // clean data buffer
  1854. memset(a_pXRayData, 0, a_nBufferSize * sizeof(long));
  1855. // copy data from bruker data buffer to data buffer [blend]
  1856. double dStep1 = 1.0 / (double)nDataChannelNO; // step size of bruker bin
  1857. double dStep2 = 1.0 / (double)a_nBufferSize; // step size of bin
  1858. // blend bruker data
  1859. for (long i = 0; i < nDataChannelNO; ++i)
  1860. {
  1861. // get the bruker bin data
  1862. long nValue = (pLongChannels[i] > 0) ? pLongChannels[i] : 0;
  1863. // calculate the bruker bin position
  1864. double dBinPos = (double)i * dStep1;
  1865. // calculate bin number on the left side of the position
  1866. long nLeftBin = (long)(dBinPos / dStep2);
  1867. // calculate % into left bin
  1868. double dLeft_Percent = double(nLeftBin + 1) - dBinPos / dStep2; // ((nLeftBin + 1)*dStep2 - dBinPos)/dStep2
  1869. // calculate data into the left bin
  1870. long nValueToLeftBin = (long)((double)nValue * dLeft_Percent + 0.5);
  1871. // put data into bins
  1872. a_pXRayData[nLeftBin] += nValueToLeftBin;
  1873. if ((nLeftBin + 1) < (long)a_nBufferSize)
  1874. {
  1875. a_pXRayData[nLeftBin + 1] += (nValue - nValueToLeftBin);
  1876. }
  1877. }
  1878. // ok, return true
  1879. return TRUE;
  1880. }
  1881. // call GetPointListSpectrum
  1882. // return true if success
  1883. BOOL COTSBrukerImpl::GetPointListSpectrum(long a_nIndex, long* a_pnSpec)
  1884. {
  1885. ASSERT(a_pnSpec);
  1886. if (!a_pnSpec)
  1887. {
  1888. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetPointListSpectrum: invalid a_pnSpec."));
  1889. return FALSE;
  1890. }
  1891. // Success?
  1892. if (BrukerDll::GetPointListSpectrum(m_nClientID, a_nIndex, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (long)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE) == 0)
  1893. {
  1894. if (!ConvertSpectrum((RTSpectrumHeaderRec*)m_psRTSpectrumBuffer.get(), a_pnSpec, (DWORD)BRUKER_PARAM::RT_SPECTRUM_CHANNELS))
  1895. {
  1896. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetPointListSpectrum:Call ConvertSpectrum failed."));
  1897. return FALSE;
  1898. }
  1899. }
  1900. else
  1901. {
  1902. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetPointListSpectrum:Call GetPointListSpectrum failed: error code is %d."), -1);
  1903. return FALSE;
  1904. }
  1905. return TRUE;
  1906. }
  1907. // call GetFeatureListSpectrum
  1908. // return true if success
  1909. BOOL COTSBrukerImpl::GetFeatureListSpectrum(long a_nIndex, long* a_pnSpec)
  1910. {
  1911. if (!a_pnSpec)
  1912. {
  1913. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetFeatureListSpectrum:a_pnSpec failed, return"));
  1914. return FALSE;
  1915. }
  1916. // Success?
  1917. if ((BrukerDll::GetFeatureListSpectrum(m_nClientID, a_nIndex, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE)) != 0)
  1918. {
  1919. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetFeatureListSpectrum:failed, return"));
  1920. return FALSE;
  1921. }
  1922. // return method return flag
  1923. if (!ConvertSpectrum((RTSpectrumHeaderRec*)m_psRTSpectrumBuffer.get(), a_pnSpec, (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS))
  1924. {
  1925. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetFeatureListSpectrum: convert spectrum failed, return"));
  1926. return FALSE;
  1927. }
  1928. return TRUE;
  1929. }
  1930. // call StartPointListMeasurement
  1931. // return true if success
  1932. BOOL COTSBrukerImpl::StartPointListMeasurement(
  1933. DWORD a_nSegmentCount,
  1934. BrukerDll::PSegmentList a_poSegment,
  1935. DWORD m_nMilliseconds)
  1936. {
  1937. ASSERT(a_poSegment);
  1938. if (!a_poSegment)
  1939. {
  1940. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StartPointListMeasurement:a_poSegment failed, return"));
  1941. return FALSE;
  1942. }
  1943. if (BrukerDll::StartPointListMeasurement(m_nClientID, m_nSPU, a_nSegmentCount, a_poSegment, m_nMilliseconds) != 0)
  1944. {
  1945. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StartPointListMeasurement:Call StartPointListMeasurement failed: client id is %d(%d, %d, %d)"), m_nClientID, m_nSPU, a_nSegmentCount, m_nMilliseconds);
  1946. return FALSE;
  1947. }
  1948. return TRUE;
  1949. }
  1950. // call StartFeatureListMeasurement
  1951. // return true if success
  1952. BOOL COTSBrukerImpl::StartFeatureListMeasurement(
  1953. DWORD a_nFeatureCount,
  1954. BrukerDll::PFeatureDataList a_poFeature,
  1955. SHORT** a_pwdPixelTimes)
  1956. {
  1957. ASSERT(a_poFeature);
  1958. if (!a_poFeature)
  1959. {
  1960. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StartFeatureListMeasurement:a_poFeature failed, return"));
  1961. return FALSE;
  1962. }
  1963. if (!a_pwdPixelTimes)
  1964. {
  1965. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StartFeatureListMeasurement:a_pwdPixelTimes failed, return"));
  1966. return FALSE;
  1967. }
  1968. if (BrukerDll::StartFeatureListMeasurement(m_nClientID, m_nSPU, a_nFeatureCount, a_poFeature, a_pwdPixelTimes) != 0)
  1969. {
  1970. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::StartFeatureListMeasurement:Call StartFeatureListMeasurement failed: client id is %d"), m_nClientID);
  1971. return FALSE;
  1972. }
  1973. return TRUE;
  1974. }
  1975. //
  1976. CString COTSBrukerImpl::GetQuantificationSpectrumPathName()
  1977. {
  1978. CString sFilePathName = _T("\\QuantificationSpectrum.spx");
  1979. return sFilePathName;
  1980. }
  1981. BOOL COTSBrukerImpl::GetXRayByPoints(CPosXrayList& a_listXrayPois, DWORD a_nACTimeMS)
  1982. {
  1983. try
  1984. {
  1985. // do nothing if points list is empty
  1986. if (a_listXrayPois.empty())
  1987. {
  1988. // points list is empty
  1989. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetXRayByPoints: poits list is empty."));
  1990. return TRUE;
  1991. }
  1992. // create array of BrukerSegment
  1993. long nCollectCount = (long)a_listXrayPois.size();
  1994. boost::scoped_array<BrukerDll::TSegment> segmentArray(new BrukerDll::TSegment[nCollectCount]);
  1995. for (int i = 0; i < nCollectCount; ++i)
  1996. {
  1997. CPoint poi = a_listXrayPois[i]->GetPosition();
  1998. segmentArray[i].Y = poi.y;
  1999. segmentArray[i].XStart = poi.x;
  2000. segmentArray[i].XCount = 1;
  2001. }
  2002. // ask Bruker to collect a set of x ray data
  2003. if (!StartPointListMeasurement(nCollectCount, segmentArray.get(), a_nACTimeMS))
  2004. {
  2005. // failed to call StartPointListMeasurement method
  2006. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPoints: failed to call StartPointListMeasurement method."));
  2007. return FALSE;
  2008. }
  2009. // get the specs for a_vXPoints
  2010. static DWORD nChannelData[(int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS];
  2011. for (int i = 0; i < nCollectCount; ++i)
  2012. {
  2013. // cleanup data storage
  2014. memset(nChannelData, 0, sizeof(DWORD) * (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS);
  2015. // get spectrum data of a point
  2016. bool success = GetPointListSpectrum(i, (long*)nChannelData);
  2017. if (!success)
  2018. {
  2019. // error
  2020. CPoint poi = a_listXrayPois[i]->GetPosition();
  2021. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetXRayPoints:Call GetPointListSpectrum failed : index = %d(x : %d, y : %d)"),
  2022. i,
  2023. poi.x,
  2024. poi.y);
  2025. return FALSE;
  2026. }
  2027. // set spectrum data for the x-ray point
  2028. a_listXrayPois[i]->SetXrayData(nChannelData);
  2029. }
  2030. return TRUE;
  2031. }
  2032. catch (const std::exception&)
  2033. {
  2034. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::GetXRayByPoints: exception."));
  2035. }
  2036. // error, return false
  2037. return FALSE;
  2038. }
  2039. BOOL COTSBrukerImpl::SetXRayPoints(CPosXrayList& a_listXrayPois/*, const DWORD a_nACTimeMS*/)
  2040. {
  2041. // Fail a_vXPoints is empty
  2042. if (a_listXrayPois.empty())
  2043. {
  2044. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetXRayPoints Empty point list given in argument a_oPointList"));
  2045. return TRUE;
  2046. }
  2047. long nCollectCount = (long)a_listXrayPois.size();
  2048. // get the specs for a_vXPoints
  2049. static DWORD nChannelData[(int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS];
  2050. for (int i = 0; i < nCollectCount; ++i)
  2051. {
  2052. // cleanup data storage
  2053. memset(nChannelData, 0, sizeof(DWORD) * (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS);
  2054. // quantify the spectrum
  2055. char* pcMethod = "Default";//"Default";//"Automatic";
  2056. char* pcParams = "ResultType=quantification";
  2057. char cResult[10000];
  2058. memset(cResult, 0, 10000);
  2059. if (BrukerDll::QuantifyPointListSpectrum(m_nClientID, i, pcMethod, pcParams, cResult, 10000, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE) != 0)
  2060. {
  2061. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetXRayPoints failed to call QuantifyPointListSpectrum method at index %d, error code %d"), i, -1);
  2062. }
  2063. CElementChemistriesList listElement = CElement::ExtractElementChemistrys(CControllerHelper::CharToString(cResult));
  2064. a_listXrayPois[i]->SetElementQuantifyData(listElement);
  2065. // get spectrum data of a point
  2066. //bool success = GetPointListSpectrum(i, (long*)nChannelData);
  2067. //if (!success)
  2068. //{
  2069. // // error
  2070. // CPoint poi = a_listXrayPois[i]->GetPosition();
  2071. // LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetXRayPoints:Call GetPointListSpectrum failed : index = %d(x : %d, y : %d)"),
  2072. // i,
  2073. // poi.x,
  2074. // poi.y);
  2075. // return FALSE;
  2076. //}
  2077. //// set spectrum data for the x-ray point
  2078. //a_listXrayPois[i]->SetXrayData(nChannelData);
  2079. }
  2080. return TRUE;
  2081. }
  2082. BOOL COTSBrukerImpl::GetXRayByFeatures(CPosXrayList& a_vXPoints, std::vector<BrukerFeature> a_vFeatures, SHORT a_nACTimeMS)
  2083. {
  2084. // do nothing if points list is empty
  2085. if (a_vXPoints.empty())
  2086. {
  2087. // points list is empty
  2088. LogTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures: poits list is empty."));
  2089. return TRUE;
  2090. }
  2091. // lists size check
  2092. if (a_vXPoints.size() != a_vFeatures.size())
  2093. {
  2094. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures:Feature size(%d) doesn't match xray point size(%d)"), a_vFeatures.size(), a_vXPoints.size());
  2095. return FALSE;
  2096. }
  2097. // create array of BrukerSegment
  2098. long nCollectCount = (long)a_vXPoints.size();
  2099. long nTotalPixelCount = 0;
  2100. boost::scoped_array<SHORT*> pixelTimes(new SHORT*[nCollectCount]);
  2101. boost::scoped_array<BrukerDll::TFeatureData> features(new BrukerDll::TFeatureData[nCollectCount]);
  2102. std::vector<BrukerDll::TSegment> extraSegments;
  2103. for (size_t i = 0; i < nCollectCount; i++)
  2104. {
  2105. BrukerFeature ofeature = a_vFeatures[i];
  2106. features[i].SegmentCount = ofeature.SegmentCount;
  2107. if (ofeature.SegmentCount > 0)
  2108. {
  2109. int segCount = features[i].SegmentCount;
  2110. auto ofeature = a_vFeatures[i];
  2111. features.get()->Segments = new BrukerDll::TSegment[segCount];
  2112. for (int j = 0; j < segCount; j++)
  2113. {
  2114. features.get()->Segments[j].XStart = ofeature.pSegment[j].XStart;
  2115. features.get()->Segments[j].XCount = ofeature.pSegment[j].XCount;
  2116. features.get()->Segments[j].Y = ofeature.pSegment[j].Y;
  2117. }
  2118. // calculate pixel time
  2119. int nPixelCount = 0;
  2120. for (int j = 0; j < ofeature.SegmentCount; j++)
  2121. {
  2122. nPixelCount += ofeature.pSegment[j].XCount;
  2123. }
  2124. *pixelTimes[i] = (SHORT)(ceil((double)a_nACTimeMS * 1000.0 / (double)nPixelCount));
  2125. nTotalPixelCount += nPixelCount;
  2126. }
  2127. else
  2128. {
  2129. // will generate according to the x-ray position
  2130. // this shouldn't happen
  2131. BrukerDll::PFeatureDataList features = new BrukerDll::TFeatureData[nCollectCount];
  2132. extraSegments.push_back(BrukerDll::TSegment());
  2133. extraSegments[extraSegments.size() - 1].XStart = a_vXPoints[i]->GetPosition().x;
  2134. extraSegments[extraSegments.size() - 1].Y = a_vXPoints[i]->GetPosition().y;
  2135. features[i].SegmentCount = 1;
  2136. features[i].Segments = &extraSegments[extraSegments.size() - 1];
  2137. *pixelTimes[i] = (SHORT)(a_nACTimeMS * 1000);
  2138. }
  2139. }
  2140. // ask bruker to collect a set of x-ray data
  2141. if (!StartFeatureListMeasurement(nCollectCount, features.get(), pixelTimes.get()))
  2142. {
  2143. // failed to call StartFeatureListMeasurement method
  2144. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures: failed to call StartFeatureListMeasurement method."));
  2145. return FALSE;
  2146. }
  2147. // get the specs for a_vXPoints
  2148. if (!SetXRayPointsByFeature(a_vXPoints, a_nACTimeMS))
  2149. {
  2150. // failed to call ReadXRayPointsByFeature method
  2151. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::CollectXRayPointsByFeatures: failed to call ReadXRayPointsByFeature method."));
  2152. return FALSE;
  2153. }
  2154. return TRUE;
  2155. }
  2156. BOOL COTSBrukerImpl::SetXRayPointsByFeature(CPosXrayList& a_vXPoints, const DWORD a_nACTimeMS)
  2157. {
  2158. // Fail a_vXPoints is empty
  2159. if (a_vXPoints.empty())
  2160. {
  2161. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPointsByFeature:Empty point list given in argument a_oPointList"));
  2162. return TRUE;
  2163. }
  2164. long nCollectCount = (long)a_vXPoints.size();
  2165. // get the specs for a_vXPoints
  2166. static DWORD nChannelData[(int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS];
  2167. for (int i = 0; i < nCollectCount; ++i)
  2168. {
  2169. // cleanup data storage
  2170. memset(nChannelData, 0, sizeof(DWORD) * (int)BRUKER_PARAM::RT_SPECTRUM_CHANNELS);
  2171. if (m_bDoQuantification)
  2172. {
  2173. // quantify the spectrum
  2174. char* pcMethod = "Default";//"Default";// "Automatic";
  2175. char* pcParams = "ResultType=quantification";
  2176. char cResult[10000];
  2177. memset(cResult, 0, 10000);
  2178. if (BrukerDll::QuantifyFeatureListSpectrum(m_nClientID, i, pcMethod, pcParams, cResult, 10000, (BrukerDll::PRTSpectrumHeaderRec)m_psRTSpectrumBuffer.get(), (int)BRUKER_PARAM::RT_SPECTRUM_BUFFER_SIZE) != 0)
  2179. {
  2180. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::SetXRayPoints failed to call QuantifyPointListSpectrum method, error code %d"), -1);
  2181. //return FALSE;
  2182. }
  2183. CElementChemistriesList listElement = CElement::ExtractElementChemistrys(CControllerHelper::CharToString(cResult));
  2184. a_vXPoints[i]->SetElementQuantifyData(listElement);
  2185. }
  2186. // get spectrum data of a point
  2187. bool success = GetFeatureListSpectrum(i, (long*)nChannelData);
  2188. if (!success)
  2189. {
  2190. // error
  2191. CPoint poi = a_vXPoints[i]->GetPosition();
  2192. LogErrorTrace(__FILE__, __LINE__, _T("COTSBrukerImpl::ReadXRayPointsByFeature:Call GetFeatureListSpectrum failed: index = %d(x:%d, y:%d)"),
  2193. i,
  2194. poi.x,
  2195. poi.y);
  2196. return FALSE;
  2197. }
  2198. // set spectrum data for the x-ray point
  2199. a_vXPoints[i]->SetXrayData(nChannelData);
  2200. }
  2201. return TRUE;
  2202. }
  2203. BOOL COTSBrukerImpl::GetLoadDllName(CString& csDllName)
  2204. {
  2205. tinyxml2::XMLDocument doc;
  2206. doc.LoadFile(DllXMLFileName);//载入xml文件
  2207. xmls::Slo subClass;
  2208. xmls::xString szS;
  2209. subClass.Register("Version", &szS);
  2210. subClass.Register("BrukerDllVersion", &subClass);
  2211. tinyxml2::XMLElement *rootNode;
  2212. rootNode = doc.FirstChildElement(RootClassName);
  2213. subClass.Serialize(false, &doc, rootNode);
  2214. csDllName = szS.value().c_str();
  2215. return true;
  2216. }
  2217. }