OTSBrukerImpl.cpp 75 KB

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