OTSBrukerImpl.cpp 77 KB

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