imageBrowser.py 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963
  1. import os
  2. import unittest
  3. from __main__ import vtk, qt, ctk, slicer
  4. from slicer.ScriptedLoadableModule import *
  5. import json
  6. import datetime
  7. import sys
  8. import nixModule
  9. import pathlib
  10. import chardet
  11. import re
  12. #should be dealt with in nixModule
  13. import nixWrapper
  14. #
  15. # labkeySlicerPythonExtension
  16. #
  17. class imageBrowser(ScriptedLoadableModule):
  18. """Uses ScriptedLoadableModule base class, available at:
  19. https://github.com/Slicer/Slicer/blob/master/Base/Python/slicer/ScriptedLoadableModule.py
  20. """
  21. def __init__(self, parent):
  22. ScriptedLoadableModule.__init__(self, parent)
  23. self.parent.title = "image Browser"
  24. # TODO make this more human readable by adding spaces
  25. self.parent.categories = ["LabKey"]
  26. self.parent.dependencies = []
  27. self.parent.contributors = ["Andrej Studen (UL/FMF)"]
  28. # replace with "Firstname Lastname (Organization)"
  29. self.parent.helpText = """
  30. Interface to irAEMM files in LabKey
  31. """
  32. self.parent.acknowledgementText = """
  33. Developed within the medical physics research programme
  34. of the Slovenian research agency.
  35. """ # replace with organization, grant and thanks.
  36. #
  37. # labkeySlicerPythonExtensionWidget
  38. #
  39. class imageBrowserWidget(ScriptedLoadableModuleWidget):
  40. """Uses ScriptedLoadableModuleWidget base class, available at:
  41. https://github.com/Slicer/Slicer/blob/master/Base/Python/slicer/ScriptedLoadableModule.py
  42. """
  43. def setup(self):
  44. print("Setting up imageBrowserWidget")
  45. ScriptedLoadableModuleWidget.setup(self)
  46. # Instantiate and connect widgets ...
  47. self.logic=imageBrowserLogic(self)
  48. self.addInfoSection()
  49. self.addSetupSection()
  50. self.addPatientsSelector()
  51. self.addSegmentEditor()
  52. self.addWindowManipulator()
  53. def addInfoSection(self):
  54. #a python overview of json settings
  55. infoCollapsibleButton = ctk.ctkCollapsibleButton()
  56. infoCollapsibleButton.text = "Info"
  57. self.layout.addWidget(infoCollapsibleButton)
  58. infoLayout = qt.QFormLayout(infoCollapsibleButton)
  59. self.participantField=qt.QLabel("PatientId")
  60. infoLayout.addRow("Participant field:",self.participantField)
  61. self.ctField=qt.QLabel("ctResampled")
  62. infoLayout.addRow("Data field (CT):",self.ctField)
  63. self.petField=qt.QLabel("petResampled")
  64. infoLayout.addRow("Data field (PET):",self.petField)
  65. self.userField=qt.QLabel("Loading")
  66. infoLayout.addRow("User",self.userField)
  67. self.idField=qt.QLabel("Loading")
  68. infoLayout.addRow("ID",self.idField)
  69. #Add logic at some point
  70. #self.logic=imageBrowserLogic(self)
  71. def addPatientsSelector(self):
  72. #
  73. # Patients Area
  74. #
  75. patientsCollapsibleButton = ctk.ctkCollapsibleButton()
  76. patientsCollapsibleButton.text = "Patients"
  77. #don't add it yet
  78. self.layout.addWidget(patientsCollapsibleButton)
  79. patientsFormLayout = qt.QFormLayout(patientsCollapsibleButton)
  80. self.patientList=qt.QComboBox()
  81. self.patientList.currentIndexChanged.connect(self.onPatientListChanged)
  82. self.patientList.setEditable(True)
  83. self.patientList.setInsertPolicy(qt.QComboBox.NoInsert)
  84. patientsFormLayout.addRow("Patient:",self.patientList)
  85. self.visitList=qt.QComboBox()
  86. self.visitList.currentIndexChanged.connect(self.onVisitListChanged)
  87. patientsFormLayout.addRow("Visit:",self.visitList)
  88. self.ctCode=qt.QLabel("ctCode")
  89. patientsFormLayout.addRow("CT:",self.ctCode)
  90. self.petCode=qt.QLabel("petCode")
  91. patientsFormLayout.addRow("PET:",self.petCode)
  92. self.patientLoad=qt.QPushButton("Load")
  93. self.patientLoad.clicked.connect(self.onPatientLoadButtonClicked)
  94. patientsFormLayout.addRow("Load patient",self.patientLoad)
  95. self.patientSave=qt.QPushButton("Save")
  96. self.patientSave.clicked.connect(self.onPatientSaveButtonClicked)
  97. patientsFormLayout.addRow("Save segmentation",self.patientSave)
  98. #empty label as a spacer
  99. qX=qt.QLabel("")
  100. patientsFormLayout.addRow("",qX)
  101. self.patientClear=qt.QPushButton("Clear")
  102. self.patientClear.clicked.connect(self.onPatientClearButtonClicked)
  103. patientsFormLayout.addRow("Clear patient",self.patientClear)
  104. self.keepCached=qt.QCheckBox("keep Cached")
  105. self.keepCached.setChecked(1)
  106. patientsFormLayout.addRow("Keep cached",self.keepCached)
  107. self.forceReload=qt.QCheckBox("Force reload")
  108. self.forceReload.setChecked(0)
  109. patientsFormLayout.addRow("Force reload",self.forceReload)
  110. def addSetupSection(self):
  111. setupCollapsibleButton = ctk.ctkCollapsibleButton()
  112. setupCollapsibleButton.text = "Setup"
  113. self.layout.addWidget(setupCollapsibleButton)
  114. #Form layout (maybe one can think of more intuitive layouts)
  115. setupFormLayout = qt.QFormLayout(setupCollapsibleButton)
  116. self.serverList=qt.QComboBox()
  117. self.serverList.addItem('<Select>')
  118. self.serverList.addItem("astuden")
  119. self.serverList.addItem("adoma")
  120. self.serverList.addItem("kzevnik")
  121. self.serverList.currentIndexChanged.connect(self.onServerListChanged)
  122. setupFormLayout.addRow("Select user:",self.serverList)
  123. self.setupList=qt.QComboBox()
  124. self.setupList.addItem('<Select>')
  125. self.setupList.addItem("limfomiPET_iBrowser.json")
  126. self.setupList.addItem("limfomiPET_iBrowser_selected.json")
  127. self.setupList.addItem("iraemm_iBrowserProspective.json")
  128. self.setupList.addItem("iraemm_iBrowserRetrospective.json")
  129. self.setupList.addItem("ORLPET_iBrowser.json")
  130. self.setupList.addItem("FET_iBrowser.json")
  131. self.setupList.currentIndexChanged.connect(self.onSetupListChanged)
  132. setupFormLayout.addRow("Setup:",self.setupList)
  133. def addReviewSection(self):
  134. #
  135. # Review Area
  136. #
  137. reviewCollapsibleButton = ctk.ctkCollapsibleButton()
  138. reviewCollapsibleButton.text = "Review"
  139. self.layout.addWidget(reviewCollapsibleButton)
  140. self.reviewBoxLayout = qt.QVBoxLayout(reviewCollapsibleButton)
  141. self.reviewFormLayout = qt.QFormLayout()
  142. self.reviewSegment=qt.QComboBox()
  143. self.reviewSegment.currentIndexChanged.connect(\
  144. self.onReviewSegmentChanged)
  145. self.reviewFormLayout.addRow("Selected region:",self.reviewSegment)
  146. self.reviewResult=qt.QComboBox()
  147. sLabel="What do you think about the segmentation:"
  148. self.reviewFormLayout.addRow(sLabel,self.reviewResult)
  149. reviewOptions=['Select','Excellent','Minor deficiencies',\
  150. 'Major deficiencies','Unusable']
  151. for opt in reviewOptions:
  152. self.reviewResult.addItem(opt)
  153. self.aeResult=qt.QComboBox()
  154. aeLabel="Is organ suffering from adverse effect?"
  155. self.reviewFormLayout.addRow(aeLabel,self.aeResult)
  156. aeOptions=['Select','Yes','No']
  157. for opt in aeOptions:
  158. self.aeResult.addItem(opt)
  159. #self.aeResult.setCurrentIndex(0)
  160. self.updateReview=qt.QPushButton("Save")
  161. saLabel="Save segmentation and AE decision for current segment"
  162. self.reviewFormLayout.addRow(saLabel,self.updateReview)
  163. self.updateReview.clicked.connect(self.onUpdateReviewButtonClicked)
  164. self.reviewBoxLayout.addLayout(self.reviewFormLayout)
  165. submitFrame=qt.QGroupBox("Submit data")
  166. self.submitFormLayout=qt.QFormLayout()
  167. self.reviewComment=qt.QTextEdit("this is a test")
  168. self.submitFormLayout.addRow("Comments (optional)",self.reviewComment)
  169. self.submitReviewButton=qt.QPushButton("Submit")
  170. self.submitFormLayout.addRow("Submit to database",\
  171. self.submitReviewButton)
  172. self.submitReviewButton.clicked.connect(\
  173. self.onSubmitReviewButtonClicked)
  174. submitFrame.setLayout(self.submitFormLayout)
  175. submitFrame.setFlat(1)
  176. #submitFrame.setFrameShape(qt.QFrame.StyledPanel)
  177. #submitFrame.setFrameShadow(qt.QFrame.Sunken)
  178. submitFrame.setStyleSheet("background-color:rgba(220,215,180,45)")
  179. self.reviewBoxLayout.addWidget(submitFrame)
  180. def addSegmentEditor(self):
  181. editorCollapsibleButton = ctk.ctkCollapsibleButton()
  182. editorCollapsibleButton.text = "Segment Editor"
  183. self.layout.addWidget(editorCollapsibleButton)
  184. hLayout=qt.QVBoxLayout(editorCollapsibleButton)
  185. self.segmentEditorWidget=slicer.qMRMLSegmentEditorWidget()
  186. hLayout.addWidget(self.segmentEditorWidget)
  187. self.segmentEditorWidget.setMRMLScene(slicer.mrmlScene)
  188. segEditorNode=slicer.vtkMRMLSegmentEditorNode()
  189. slicer.mrmlScene.AddNode(segEditorNode)
  190. self.segmentEditorWidget.setMRMLSegmentEditorNode(segEditorNode)
  191. def addWindowManipulator(self):
  192. windowManipulatorCollapsibleButton=ctk.ctkCollapsibleButton()
  193. windowManipulatorCollapsibleButton.text="CT Window Manipulator"
  194. self.layout.addWidget(windowManipulatorCollapsibleButton)
  195. hLayout=qt.QHBoxLayout(windowManipulatorCollapsibleButton)
  196. ctWins={'CT:bone':self.onCtBoneButtonClicked,
  197. 'CT:air':self.onCtAirButtonClicked,
  198. 'CT:abdomen':self.onCtAbdomenButtonClicked,
  199. 'CT:brain':self.onCtBrainButtonClicked,
  200. 'CT:lung':self.onCtLungButtonClicked}
  201. for ctWin in ctWins:
  202. ctButton=qt.QPushButton(ctWin)
  203. ctButton.clicked.connect(ctWins[ctWin])
  204. hLayout.addWidget(ctButton)
  205. def onSetupListChanged(self,i):
  206. status=self.logic.setConfig(self.setupList.currentText)
  207. try:
  208. if status['error']=='FILE NOT FOUND':
  209. print('File {} not found.'.format(self.setupList.currentText))
  210. return
  211. except KeyError:
  212. pass
  213. #sort ids
  214. ids=status['ids']
  215. ids.sort()
  216. self.updatePatientList(ids)
  217. self.onPatientListChanged(0)
  218. def onServerListChanged(self,i):
  219. status=self.logic.setServer(self.serverList.currentText)
  220. try:
  221. if status['error']=='KEY ERROR':
  222. self.serverList.setStyleSheet('background-color: violet')
  223. if status['error']=='ID ERROR':
  224. self.serverList.setStyleSheet('background-color: red')
  225. return
  226. except KeyError:
  227. pass
  228. self.idField.setText(status['id'])
  229. self.userField.setText(status['displayName'])
  230. self.serverList.setStyleSheet('background-color: green')
  231. def onPatientListChanged(self,i):
  232. self.visitList.clear()
  233. self.petCode.setText("")
  234. self.ctCode.setText("")
  235. #add potential filters from setup to dbFilter
  236. ds=self.logic.getDataset(dbFilter={'participant':self.patientList.currentText})
  237. visitVar=self.logic.getVarName(var='visitField')
  238. dt=datetime.datetime
  239. #label is a combination of sequence number and date of imaging
  240. try:
  241. seq={row['SequenceNum']:
  242. {'label':row[visitVar],
  243. 'date': parseDate(row['studyDate'])}
  244. for row in ds['rows']}
  245. except TypeError:
  246. #if studyDate is empty, this will return no possible visits
  247. return
  248. #apply lookup to visitVar if available
  249. try:
  250. seq={x:
  251. {'label':ds['lookups'][visitVar][seq[x]['label']],
  252. 'date':seq[x]['date']}
  253. for x in seq}
  254. except KeyError:
  255. pass
  256. #format label
  257. seq={x:'{} ({})'.format(seq[x]['label'],dt.strftime(seq[x]['date'],'%d-%b-%Y'))
  258. for x in seq}
  259. for s in seq:
  260. #onVisitListChanged is called for every addItem
  261. self.visitList.addItem(seq[s],s)
  262. #self.onVisitListChanged(0)
  263. def onVisitListChanged(self,i):
  264. #ignore calls on empty list
  265. if self.visitList.count==0:
  266. return
  267. #get sequence num
  268. s=self.visitList.itemData(i)
  269. print("Visit: SequenceNum:{}, label{}".format(s,self.visitList.currentText))
  270. dbFilter={'participant':self.patientList.currentText,
  271. 'seqNum':s}
  272. ds=self.logic.getDataset(dbFilter=dbFilter)
  273. if not len(ds['rows'])==1:
  274. print("Found incorrect number {} of matches for [{}]/[{}]".\
  275. format(len(ds['rows']),\
  276. self.patientList.currentText,s))
  277. row=ds['rows'][0]
  278. #copy row properties for data access
  279. self.currentRow=row
  280. self.petCode.setText(row[self.petField.text])
  281. self.ctCode.setText(row[self.ctField.text])
  282. #self.segmentationCode.setText(row[self.segmentationField.text])
  283. def updatePatientList(self,ids):
  284. self.patientList.clear()
  285. for id in ids:
  286. self.patientList.addItem(id)
  287. def onPatientLoadButtonClicked(self):
  288. print("Load")
  289. #delegate loading to logic
  290. self.logic.loadImages(self.currentRow,self.keepCached.isChecked(),
  291. self.forceReload.isChecked())
  292. self.logic.loadSegmentation(self.currentRow)
  293. self.setSegmentEditor()
  294. #self.logic.loadReview(self.currentRow)
  295. #self.logic.loadAE(self.currentRow)
  296. #self.onReviewSegmentChanged()
  297. def setSegmentEditor(self):
  298. #use current row to set segment in segment editor
  299. self.segmentEditorWidget.setSegmentationNode(
  300. self.logic.volumeNode['Segmentation'])
  301. self.segmentEditorWidget.setMasterVolumeNode(
  302. self.logic.volumeNode['PET'])
  303. def onReviewSegmentChanged(self):
  304. pass
  305. def onPatientClearButtonClicked(self):
  306. msgBox=qt.QMessageBox()
  307. msgBox.setText('Are you sure you want to clear pateient?')
  308. msgBox.setStandardButtons(qt.QMessageBox.Ok |qt.QMessageBox.Cancel)
  309. returnValue=msgBox.exec()
  310. if returnValue==qt.QMessageBox.Cancel:
  311. print('Canceling')
  312. return
  313. print('Clearing')
  314. self.logic.clearVolumesAndSegmentations()
  315. self.clearSaveButton()
  316. def clearSaveButton(self):
  317. self.patientSave.setStyleSheet('background-color:gray')
  318. def onPatientSaveButtonClicked(self):
  319. status=self.logic.saveSegmentation()
  320. if status:
  321. self.patientSave.setStyleSheet('background-color:green')
  322. qt.QTimer.singleShot(5000,self.clearSaveButton)
  323. else:
  324. self.patientSave.setStyleSheet('background-color:red')
  325. def onCtBoneButtonClicked(self):
  326. self.logic.setWindow('CT:bone')
  327. def onCtAirButtonClicked(self):
  328. self.logic.setWindow('CT:air')
  329. def onCtAbdomenButtonClicked(self):
  330. self.logic.setWindow('CT:abdomen')
  331. def onCtBrainButtonClicked(self):
  332. self.logic.setWindow('CT:brain')
  333. def onCtLungButtonClicked(self):
  334. self.logic.setWindow('CT:lung')
  335. def cleanup(self):
  336. pass
  337. #
  338. # imageBrowserLogic
  339. #
  340. class imageBrowserLogic(ScriptedLoadableModuleLogic):
  341. """This class should implement all the actual
  342. computation done by your module. The interface
  343. should be such that other python code can import
  344. this class and make use of the functionality without
  345. requiring an instance of the Widget.
  346. Uses ScriptedLoadableModuleLogic base class, available at:
  347. https://github.com/Slicer/Slicer/blob/master/Base/Python/slicer/ScriptedLoadableModule.py
  348. """
  349. def __init__(self,parent=None):
  350. ScriptedLoadableModuleLogic.__init__(self, parent)
  351. print('imageBrowserLogic loading')
  352. if not parent==None:
  353. #use layout and data from parent widget
  354. self.parent=parent
  355. fhome=os.path.expanduser('~')
  356. fsetup=os.path.join(fhome,'.labkey','setup.json')
  357. try:
  358. with open(fsetup) as f:
  359. self.setup=json.load(f)
  360. except FileNotFoundError:
  361. self.setup={}
  362. try:
  363. pt=self.setup['paths']
  364. except KeyError:
  365. self.setup['paths']={}
  366. lName='labkeyInterface'
  367. nixWrapper.loadLibrary(lName)
  368. import labkeyInterface
  369. import labkeyDatabaseBrowser
  370. import labkeyFileBrowser
  371. self.network=labkeyInterface.labkeyInterface()
  372. self.dbBrowser=labkeyDatabaseBrowser
  373. self.fBrowser=labkeyFileBrowser
  374. self.tempDir=os.path.join(os.path.expanduser('~'),'temp')
  375. if not os.path.isdir(self.tempDir):
  376. os.mkdir(self.tempDir)
  377. self.lookups={}
  378. print('imageBrowserLogic setup complete')
  379. def setServer(self,serverName):
  380. #additional way of setting the labkey network interface
  381. #if no parent was provided in logic initialization (stand-alone mode)
  382. status={}
  383. fileName="NONE"
  384. if serverName=="astuden":
  385. fileName="astuden.json"
  386. if serverName=="adoma":
  387. fileName="adoma.json"
  388. if serverName=="kzevnik":
  389. fileName="kzevnik.json"
  390. if fileName=="NONE":
  391. print("No path was associated with server {}".format(serverName))
  392. status['error']='KEY ERROR'
  393. return status
  394. fconfig=os.path.join(os.path.expanduser('~'),'.labkey',fileName)
  395. self.network.init(fconfig)
  396. self.remoteId=self.network.getUserId()
  397. if self.remoteId==None:
  398. status['error']='ID ERROR'
  399. return status
  400. status['displayName']=self.remoteId['displayName']
  401. status['id']=self.remoteId['id']
  402. #reset db and fb (they are thin classes anyhow)
  403. self.db=self.dbBrowser.labkeyDB(self.network)
  404. self.fb=self.fBrowser.labkeyFileBrowser(self.network)
  405. return status
  406. def setConfig(self,configName):
  407. #read the config file and adjust the browser window
  408. status={}
  409. fileName=os.path.join(os.path.expanduser('~'),'.labkey',configName)
  410. if not os.path.isfile(fileName):
  411. status['error']='FILE NOT FOUND'
  412. return status
  413. with open(fileName,'r') as f:
  414. self.isetup=json.load(f)
  415. #update ctField and petField in widget
  416. self.parent.ctField.setText(self.isetup.get('ctField','ctResampled'))
  417. self.parent.petField.setText(self.isetup.get('petField','petResampled'))
  418. #include filters...
  419. ds=self.getDataset()
  420. try:
  421. filterValue=self.isetup['filterEntries']
  422. except KeyError:
  423. #this is default
  424. ids=[row[self.isetup['participantField']] for row in ds['rows']]
  425. status['ids']=list(set(ids))
  426. return status
  427. #look for entries where segmentation was already done
  428. dsSet=self.getDataset('SegmentationsMaster')
  429. segMap={'{}:{}'.format(r['ParticipantId'],r['visitCode']):r['comments']
  430. for r in dsSet['rows']}
  431. ids=[]
  432. for r in ds['rows']:
  433. code='{}:{}'.format(r['ParticipantId'],r['visitCode'])
  434. try:
  435. comment=segMap[code]
  436. except KeyError:
  437. ids.append(r['ParticipantId'])
  438. continue
  439. if comment==filterValue:
  440. ids.append(r['ParticipantId'])
  441. status['ids']=list(set(ids))
  442. return status
  443. def getVarName(self,name="Imaging",var="visitField"):
  444. dset=self.isetup['datasets'][name]
  445. defaults={"visitField":"imagingVisitId"}
  446. try:
  447. return dset[var]
  448. except KeyError:
  449. return defaults[var]
  450. def getDataset(self,name="Imaging",dbFilter={}):
  451. dset=self.isetup['datasets'][name]
  452. project=dset['project']
  453. schema=dset['schema']
  454. query=dset['query']
  455. #add default filters
  456. qFilter=[]
  457. try:
  458. for qf in dset['filter']:
  459. v=dset['filter'][qf]
  460. qFilter.append({'variable':qf,'value':v,'oper':'eq'})
  461. except KeyError:
  462. pass
  463. for f in dbFilter:
  464. if f=='participant':
  465. qFilter.append({'variable':self.isetup['participantField'],
  466. 'value':dbFilter[f],'oper':'eq'})
  467. continue
  468. if f=='seqNum':
  469. qFilter.append({'variable':'SequenceNum',
  470. 'value':'{}'.format(dbFilter[f]),
  471. 'oper':'eq'})
  472. continue
  473. qFilter.append({'variable':f,'value':dbFilter[f],'oper':'eq'})
  474. try:
  475. ds=self.db.selectRows(project,schema,query, \
  476. qFilter,dset['view'])
  477. except KeyError:
  478. ds=self.db.selectRows(project,schema,query,qFilter)
  479. #get lookups as well
  480. lookups={}
  481. for f in ds['metaData']['fields']:
  482. try:
  483. lookup=f['lookup']
  484. except KeyError:
  485. continue
  486. var=f['name']
  487. lookupCode='{}:{}'.format(lookup['schema'],lookup['queryName'])
  488. try:
  489. lookups[var]=self.lookups[lookupCode]
  490. except KeyError:
  491. self.lookups[lookupCode]=self.loadLookup(project,lookup)
  492. lookups[var]=self.lookups[lookupCode]
  493. return {'rows':ds['rows'],'lookups':lookups}
  494. def loadLookup(self,project,lookup):
  495. qData={}
  496. key=lookup['keyColumn']
  497. value=lookup['displayColumn']
  498. fSet=self.db.selectRows(project,lookup['schema'],lookup['queryName'],[])
  499. for q in fSet['rows']:
  500. qData[q[key]]=q[value]
  501. return qData
  502. def loadImage(self,iData):
  503. #unpack iData
  504. idx=iData['idx']
  505. path=iData['path']
  506. keepCached=iData['keepCached']
  507. try:
  508. forceReload=iData['forceReload']
  509. except KeyError:
  510. forceReload=False
  511. dset=self.isetup['datasets'][iData['dataset']]
  512. localPath=os.path.join(self.tempDir,path[-1])
  513. if not os.path.isfile(localPath) or forceReload:
  514. #download from server
  515. remotePath=self.fb.formatPathURL(dset['project'],'/'.join(path))
  516. if not self.fb.entryExists(remotePath):
  517. print("Failed to get {}".format(remotePath))
  518. return
  519. #overwrites existing file from remote
  520. self.fb.readFileToFile(remotePath,localPath)
  521. properties={}
  522. filetype='VolumeFile'
  523. #make sure segmentation gets loaded as a labelmap
  524. if idx=="Segmentation":
  525. filetype='SegmentationFile'
  526. #properties["labelmap"]=1
  527. self.volumeNode[idx]=slicer.util.loadNodeFromFile(localPath,
  528. filetype=filetype,properties=properties)
  529. if not keepCached:
  530. pass
  531. #os.remove(localPath)
  532. def loadImages(self,row,keepCached, forceReload=False):
  533. #fields={'ctResampled':True,'petResampled':False}
  534. fields={"CT":self.parent.ctField.text,\
  535. "PET":self.parent.petField.text}
  536. path=[self.isetup['imageDir'],row['patientCode'],row['visitCode']]
  537. relativePaths={x:path+[row[y]] for (x,y) in fields.items()}
  538. self.volumeNode={}
  539. for f in relativePaths:
  540. iData={'idx':f,'path':relativePaths[f],
  541. 'keepCached':keepCached,'dataset':'Imaging',
  542. 'forceReload':forceReload}
  543. self.loadImage(iData)
  544. #mimic abdominalCT standardized window setting
  545. self.volumeNode['CT'].GetScalarVolumeDisplayNode().\
  546. SetAutoWindowLevel(False)
  547. self.volumeNode['CT'].GetScalarVolumeDisplayNode().\
  548. SetWindowLevel(1400, -500)
  549. #set colormap for PET to PET-Heat (this is a verbatim setting from
  550. #the Volumes->Display->Lookup Table colormap identifier)
  551. self.volumeNode['PET'].GetScalarVolumeDisplayNode().\
  552. SetAndObserveColorNodeID(\
  553. slicer.util.getNode('Inferno').GetID())
  554. slicer.util.setSliceViewerLayers(background=self.volumeNode['CT'],\
  555. foreground=self.volumeNode['PET'],foregroundOpacity=0.5,fit=True)
  556. def loadSegmentation(self,row, loadFile=1):
  557. dbFilter={'User':'{}'.format(self.remoteId['id']),
  558. 'participant':row[self.isetup['participantField']],
  559. 'visitCode':row['visitCode']}
  560. ds=self.getDataset(name='SegmentationsMaster',
  561. dbFilter=dbFilter)
  562. if len(ds['rows'])>1:
  563. print('Multiple segmentations found!')
  564. return
  565. if len(ds['rows'])==1:
  566. #update self.segmentationEntry
  567. self.segmentationEntry=ds['rows'][0]
  568. self.segmentationEntry['origin']='database'
  569. if loadFile:
  570. self.loadSegmentationFromEntry()
  571. return
  572. #create new segmentation
  573. self.createSegmentation(row)
  574. def getSegmentationPath(self):
  575. path=[self.isetup['imageDir'],
  576. self.segmentationEntry['patientCode'],
  577. self.segmentationEntry['visitCode']]
  578. path.append('Segmentations')
  579. return path
  580. def loadSegmentationFromEntry(self):
  581. #compile path
  582. entry=self.segmentationEntry
  583. path=self.getSegmentationPath()
  584. path.append(entry['latestFile'])
  585. iData={'idx':'Segmentation','path':path,
  586. 'keepCached':1,'dataset':'SegmentationsMaster'}
  587. self.loadImage(iData)
  588. #look for missing segments
  589. segNode=self.volumeNode['Segmentation']
  590. seg=segNode.GetSegmentation()
  591. segNames=[seg.GetNthSegmentID(i) for i in range(seg.GetNumberOfSegments())]
  592. print('Segments')
  593. segmentList=self.getSegmentList()
  594. for s in segmentList:
  595. if s not in segNames:
  596. seg.AddEmptySegment(s,s)
  597. print(s)
  598. self.updateSegmentColors(seg)
  599. print('Done')
  600. def saveSegmentation(self):
  601. #get the latest key by adding an entry to SegmentationList
  602. copyFields=[self.isetup['participantField'],'patientCode','visitCode','User']
  603. outRow={x:self.segmentationEntry[x] for x in copyFields}
  604. sList=self.isetup['datasets']['SegmentationsList']
  605. respJSON=self.db.modifyRows('insert',sList['project'],
  606. sList['schema'],sList['query'],[outRow])
  607. print('Updating {}: {}/{}'.format(sList['project'],sList['schema'],sList['query']))
  608. try:
  609. outRow=respJSON['rows'][0]
  610. except KeyError:
  611. print(respJSON)
  612. raise KeyError
  613. #print(outRow)
  614. #construct file name with known key
  615. uName=re.sub(' ','_',self.remoteId['displayName'])
  616. fName='Segmentation_{}-{}_{}_{}.nrrd'.format(
  617. self.segmentationEntry['patientCode'],
  618. self.segmentationEntry['visitCode'],
  619. uName,outRow['Key'])
  620. path=self.getSegmentationPath()
  621. path.append(fName)
  622. status=self.saveNode(self.volumeNode['Segmentation'],'SegmentationsMaster',path)
  623. #update SegmentationList with know file name
  624. outRow['Segmentation']=fName
  625. self.db.modifyRows('update',sList['project'],
  626. sList['schema'],sList['query'],[outRow])
  627. #update SegmentationsMaster
  628. self.segmentationEntry['latestFile']=fName
  629. self.segmentationEntry['version']=outRow['Key']
  630. des=self.isetup['datasets']['SegmentationsMaster']
  631. op='insert'
  632. if self.segmentationEntry['origin']=='database':
  633. op='update'
  634. print('Saving: mode={}'.format(op))
  635. resp=self.db.modifyRows(op,des['project'],
  636. des['schema'],des['query'],[self.segmentationEntry])
  637. print(resp)
  638. #since we loaded a version, origin should be set to database
  639. self.loadSegmentation(self.segmentationEntry,0)
  640. return status
  641. #self.segmentationEntry['origin']='database'
  642. def saveNode(self,node,dataset,path):
  643. fName=path[-1]
  644. localPath=os.path.join(self.tempDir,fName)
  645. slicer.util.saveNode(node,localPath)
  646. dset=self.isetup['datasets'][dataset]
  647. #exclude file name when building directory structure
  648. remotePath=self.fb.buildPathURL(dset['project'],path[:-1])
  649. remotePath+='/'+fName
  650. self.fb.writeFileToFile(localPath,remotePath)
  651. return self.fb.entryExists(remotePath)
  652. #add entry to segmentation list
  653. def createSegmentation(self,entry):
  654. #create segmentation entry for database update
  655. #note that origin is not set to database
  656. copyFields=[self.isetup['participantField'],'patientCode','visitCode','SequenceNum']
  657. #copyFields=['ParticipantId','patientCode','visitCode','SequenceNum']
  658. self.segmentationEntry={x:entry[x] for x in copyFields}
  659. self.segmentationEntry['User']=self.remoteId['id']
  660. self.segmentationEntry['origin']='created'
  661. self.segmentationEntry['version']=-1111
  662. #create a segmentation node
  663. uName=re.sub(' ','_',self.remoteId['displayName'])
  664. segNode=slicer.vtkMRMLSegmentationNode()
  665. self.volumeNode['Segmentation']=segNode
  666. segNode.SetName('Segmentation_{}_{}_{}'.
  667. format(entry['patientCode'],entry['visitCode'],uName))
  668. slicer.mrmlScene.AddNode(segNode)
  669. segNode.CreateDefaultDisplayNodes()
  670. segNode.SetReferenceImageGeometryParameterFromVolumeNode(self.volumeNode['PET'])
  671. segmentList=self.getSegmentList()
  672. for s in segmentList:
  673. segNode.GetSegmentation().AddEmptySegment(s,s)
  674. self.updateSegmentColors(segNode.GetSegmentation())
  675. def getSegmentList(self):
  676. return self.isetup.get('segmentList', \
  677. ["Liver","Blood","Marrow","Disease","Deauville","Metastases","Lesion"])
  678. def updateSegmentColors(self,seg):
  679. colorMap={'Liver':(1,1,0),'Blood':(1,0,0),'Marrow':(1,0,1),
  680. 'Disease':(0,0.5,1),'Deauville':(0,1,1),'Metastases':(0.5,1,0),
  681. 'Lesion':(0,0.67,0.33),
  682. 'Lesion1':(0,0.25,0.1),
  683. 'Lesion2':(0,0.43,0.2),
  684. 'Lesion3':(0.12,0.55,0.3),
  685. 'Lesion4':(0.24,0.67,0.4),
  686. 'Lesion5':(0.45,0.75,0.46),
  687. 'Background':(0.5,0.3,0.2)
  688. }
  689. #map colors to segments
  690. for segIdx in range(seg.GetNumberOfSegments()):
  691. segmentId = seg.GetNthSegmentID(segIdx)
  692. segment = seg.GetSegment(segmentId)
  693. color=colorMap[segmentId]
  694. segment.SetColor(color[0],color[1],color[2]) # red
  695. def clearVolumesAndSegmentations(self):
  696. nodes=slicer.util.getNodesByClass("vtkMRMLVolumeNode")
  697. nodes.extend(slicer.util.getNodesByClass("vtkMRMLSegmentationNode"))
  698. res=[slicer.mrmlScene.RemoveNode(f) for f in nodes]
  699. #self.segmentationNode=None
  700. #self.reviewResult={}
  701. #self.aeList={}
  702. def setWindow(self,windowName):
  703. #default
  704. w=1400
  705. l=-500
  706. if windowName=='CT:bone':
  707. w=1000
  708. l=400
  709. if windowName=='CT:air':
  710. w=1000
  711. l=-426
  712. if windowName=='CT:abdomen':
  713. w=350
  714. l=40
  715. if windowName=='CT:brain':
  716. w=100
  717. l=50
  718. if windowName=='CT:lung':
  719. w=1400
  720. l=-500
  721. self.volumeNode['CT'].GetScalarVolumeDisplayNode().\
  722. SetWindowLevel(w,l)
  723. print('setWindow: {} {}/{}'.format(windowName,w,l))
  724. class imageBrowserTest(ScriptedLoadableModuleTest):
  725. """
  726. This is the test case for your scripted module.
  727. Uses ScriptedLoadableModuleTest base class, available at:
  728. https://github.com/Slicer/Slicer/blob/master/Base/Python/slicer/ScriptedLoadableModule.py
  729. """
  730. def setup(self):
  731. """ Do whatever is needed to reset the state - typically a scene clear will be enough.
  732. """
  733. slicer.mrmlScene.Clear(0)
  734. def runTest(self):
  735. """Run as few or as many tests as needed here.
  736. """
  737. self.setUp()
  738. self.test_irAEMMBrowser()
  739. def test_irAEMMBrowser(self):
  740. """ Ideally you should have several levels of tests. At the lowest level
  741. tests sould exercise the functionality of the logic with different inputs
  742. (both valid and invalid). At higher levels your tests should emulate the
  743. way the user would interact with your code and confirm that it still works
  744. the way you intended.
  745. One of the most important features of the tests is that it should alert other
  746. developers when their changes will have an impact on the behavior of your
  747. module. For example, if a developer removes a feature that you depend on,
  748. your test should break so they know that the feature is needed.
  749. """
  750. self.delayDisplay("Starting the test")
  751. #
  752. # first, get some data
  753. #
  754. #utility funcitons
  755. def parseDate(x):
  756. dt=datetime.datetime
  757. formats=['%Y/%m/%d %H:%M:%S','%Y-%m-%d %H:%M:%S.%f']
  758. #print(f'Converting {x}')
  759. for fmt in formats:
  760. try:
  761. v=dt.strptime(x,fmt)
  762. #print(f'\tReturning {v}')
  763. return v
  764. except ValueError:
  765. pass
  766. #print(f'\tReturning None')
  767. return None