Replace Queuing of Retrieve Tasks using UWL

Обзор

Эта страница кратко описывает альтернативу существующей реализации: - Retrieve studies specified in CSV from external archive - Mark studies for retrieve specified in CSV from external archive - Retrieve matching studies from external archive - Mark matching studies for retrieve from external archive

Эти сервисы в настоящее время обрабатываются подсистемой Java Message Service API (JMS) сервера Wildfly, которую в рамках будущего развития архива планируется полностью заменить на Unified Worklist.

Конфигурация

Настройте Remote Application Entity для внешнего архива.
В архиве преднастроено UPS Processing Rule для извлечения DICOM-экземпляров.
Создайте UPS Template Workitem со следующими изменениями в JSON полезных данных запроса.
Чтобы записи UPS, созданные UPS template workitem, обрабатывались преднастроенным правилом UPS processing, установите значение Scheduled Workitem Code Sequence (0040,4018) так, чтобы оно совпадало со значением правила UPS processing.
Чтобы изменить назначение по умолчанию (STORESCP), настройте Remote Application Entity и использайте это значение в Destination AE последовательности DICOM Storage Sequence из Output Destination Sequence.

Варианты использования

Поскольку создание записей UPS с использованием функции UPS template пока не реализовано в UI:
Create UPS records for external studies specified in CSV file
Create UPS records for external matching studies это можно протестировать непосредственно через RESTful-сервис с помощью curl.
Запустите storescp, который выступает в качестве назначения.
См. UPS Template Workitem для создания / поиска UPS Template Workitems.

Создание записей UPS для внешних исследований с использованием CSV-файла

Создайте / получите CSV-файл, содержащий Study Instance UID и (желательно также) Patient ID с issuer в формате HL7CX, связанные с этими исследованиями в локальном архиве. Обратите внимание, что если в CSV-файле нет Patient ID, то записи UPS для разных исследований будут созданы для одного фиктивного пациента. Укажите номера полей, содержащих study instance UID и Patient ID с issuer в формате HL7CX.
Выберите SOP Instance UID (0008,0018) желаемого UPS Template Workitem из ответа search UPS template workitem и использайте это значение как upsTemplateUID в следующем сервисе.

curl -v -H "Content-type: text/csv" -X POST 'http[s]://<archive-host>:<port>/dcm4chee-arc/aets/<LocalArchiveAET>/studies/csv:1/workitems/<upsTemplateUID>?csvPatientID=2' --data-binary @testRetrieveCSV.csv Опционально в приведённом выше запросе можно передать следующие фильтры, значения которых будут установлены в создаваемых UPS workitems - upsLabel: Procedure Step Label (можно использовать аналогично существующему Batch ID в задачах retrieve) - upsScheduledTime: Scheduled Procedure Step Start DateTime

Создание записей UPS для внешних соответствующих исследований

Протестируйте Create UPS records for external matching studies - Выберите желаемые атрибуты UPS Template Workitem из ответа и создайте JSON-файл с этим набором данных. Этот JSON-файл будет отправлен как полезные данные запроса в вызываемом сервисе. curl -v -H "Content-type:application/dicom+json" -X POST 'http[s]://<archive-host>:<port>/dcm4chee-arc/aets/<LocalArchiveAET>/dimse/<ExternalArchiveAET>/studies/workitems' --data @upsTemplateWorkitemAttrs.json Опционально в приведённом выше запросе можно передать следующие фильтры, значения которых будут установлены в создаваемых UPS workitems - upsLabel: Procedure Step Label (можно использовать аналогично существующему Batch ID в задачах retrieve) - upsScheduledTime: Scheduled Procedure Step Start DateTime

Проверка

Проверьте, что записи UPS были созданы, выполнив их поиск в Navigation -> UWL и указав требуемые фильтры.
По достижении Scheduled Procedure Step Start DateTime созданные записи UPS обрабатываются, и объекты принимаются на стороне назначения.
Проверьте список SOP-экземпляров, подлежащих извлечению через C-MOVE, в Input Information Sequence.
Performed Procedure Step Description содержит описание, указывающее количество экземпляров, переданных от AET локального архива к настроенному AET назначения.

Запросы/ответы C-MOVE и C-STORE можно также проверить в журнале сервера Wildfly:

09:50:38,724 INFO  [org.dcm4che3.net.Connection] (EE-ManagedExecutorService-default-Thread-548) Initiate connection from /0.0.0.0:0 to localhost:11115
09:50:38,725 INFO  [org.dcm4che3.net.Connection] (EE-ManagedExecutorService-default-Thread-548) Established connection Socket[addr=localhost/127.0.0.1,port=11115,localport=43311]
09:50:38,725 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-548) DCM4CHEE->STORESCP(77) << A-ASSOCIATE-RQ
09:50:38,726 INFO  [org.dcm4che3.net.Association] (EE-ManagedScheduledExecutorService-default-Thread-1) DCM4CHEE<-DCM4CHEE(73): close Socket[addr=localhost/127.0.0.1,port=54387,localport=11112]
09:50:38,727 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-544) DCM4CHEE->STORESCP(77) >> A-ASSOCIATE-AC
09:50:38,729 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedScheduledExecutorService-default-Thread-13) DCM4CHEE<-DCM4CHEE(76) << 1:C-MOVE-RSP[pcid=1, remaining=2, completed=0, failed=0, warning=0, status=ff00H
  cuid=1.2.840.10008.5.1.4.1.2.2.2 - Study Root Query/Retrieve Information Model - MOVE
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,731 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedExecutorService-default-Thread-547) DCM4CHEE->DCM4CHEE(75) >> 1:C-MOVE-RSP[pcid=1, remaining=2, completed=0, failed=0, warning=0, status=ff00H
  cuid=1.2.840.10008.5.1.4.1.2.2.2 - Study Root Query/Retrieve Information Model - MOVE
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,731 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedExecutorService-default-Thread-545) DCM4CHEE->STORESCP(77) << 1:C-STORE-RQ[pcid=1, prior=0
  orig=DCM4CHEE >> 1:C-MOVE-RQ
  cuid=1.2.840.10008.5.1.4.1.1.20 - Nuclear Medicine Image Storage
  iuid=1.2.840.113619.2.216.2.1.2642006132233562.11300 - ?
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,733 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedExecutorService-default-Thread-545) DCM4CHEE->STORESCP(77) << 2:C-STORE-RQ[pcid=1, prior=0
  orig=DCM4CHEE >> 1:C-MOVE-RQ
  cuid=1.2.840.10008.5.1.4.1.1.20 - Nuclear Medicine Image Storage
  iuid=1.2.840.113619.2.216.2.1.2642006131450734.9771 - ?
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,734 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedExecutorService-default-Thread-544) DCM4CHEE->STORESCP(77) >> 1:C-STORE-RSP[pcid=1, status=0H
  cuid=1.2.840.10008.5.1.4.1.1.20 - Nuclear Medicine Image Storage
  iuid=1.2.840.113619.2.216.2.1.2642006132233562.11300 - ?
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,739 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedExecutorService-default-Thread-544) DCM4CHEE->STORESCP(77) >> 2:C-STORE-RSP[pcid=1, status=0H
  cuid=1.2.840.10008.5.1.4.1.1.20 - Nuclear Medicine Image Storage
  iuid=1.2.840.113619.2.216.2.1.2642006131450734.9771 - ?
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,746 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-545) DCM4CHEE->STORESCP(77) << A-RELEASE-RQ
09:50:38,746 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedExecutorService-default-Thread-545) DCM4CHEE<-DCM4CHEE(76) << 1:C-MOVE-RSP[pcid=1, completed=2, failed=0, warning=0, status=0H
  cuid=1.2.840.10008.5.1.4.1.2.2.2 - Study Root Query/Retrieve Information Model - MOVE
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,747 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-544) DCM4CHEE->STORESCP(77) >> A-RELEASE-RP
09:50:38,747 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-544) DCM4CHEE->STORESCP(77): close Socket[addr=localhost/127.0.0.1,port=11115,localport=43311]
09:50:38,747 INFO  [org.dcm4che3.net.Dimse] (EE-ManagedExecutorService-default-Thread-547) DCM4CHEE->DCM4CHEE(75) >> 1:C-MOVE-RSP[pcid=1, completed=2, failed=0, warning=0, status=0H
  cuid=1.2.840.10008.5.1.4.1.2.2.2 - Study Root Query/Retrieve Information Model - MOVE
  tsuid=1.2.840.10008.1.2 - Implicit VR Little Endian]
09:50:38,747 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-546) DCM4CHEE->DCM4CHEE(75) << A-RELEASE-RQ
09:50:38,748 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-548) DCM4CHEE<-DCM4CHEE(76) >> A-RELEASE-RQ
09:50:38,748 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-548) DCM4CHEE<-DCM4CHEE(76) << A-RELEASE-RP
09:50:38,748 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-547) DCM4CHEE->DCM4CHEE(75) >> A-RELEASE-RP
09:50:38,748 INFO  [org.dcm4che3.net.Association] (EE-ManagedExecutorService-default-Thread-547) DCM4CHEE->DCM4CHEE(75): close Socket[addr=localhost/127.0.0.1,port=11112,localport=44299]
09:50:38,755 INFO  [org.dcm4chee.arc.ups.impl.UPSServiceEJB] (EE-ManagedExecutorService-default-Thread-546) DCM4CHEE: Update UPS[pk=301097, uid=2.25.200433259660085130731558299675522667642, state=COMPLETED]
09:50:38,798 INFO  [org.dcm4che3.net.Association] (EE-ManagedScheduledExecutorService-default-Thread-10) DCM4CHEE<-DCM4CHEE(76): close Socket[addr=localhost/127.0.0.1,port=44299,localport=11112]