DICOM 图像传输：使用 LeadTools 实现 C-Store SCP 服务 源码

#include "SCPClient.h" #include "DicomError.h" #include "LogEvent.h" #include <QDateTime> #include <QDir> SCPClient::SCPClient() :LDicomNet((L_TCHAR*)NULL, DICOM_SECURE_NONE) { } L_VOID SCPClient::OnReceiveAssociateRequest(LDicomAssociate *pPDU) { outputLog(m_strSCUIP + "：收到 SCU Associate 请求..."); //要先调用 GetCalled 后调用 GetCalling，否则出错 L_TCHAR szCalled[PDU_MAX_TITLE_SIZE]; pPDU->GetCalled(szCalled, PDU_MAX_TITLE_SIZE); L_TCHAR szCalling[PDU_MAX_TITLE_SIZE]; pPDU->GetCalling(szCalling, PDU_MAX_TITLE_SIZE); QString strClientAE = QString::fromWCharArray(szCalling); m_strSCUAETitle = strClientAE; //验证客户端版本 L_UINT16 nVer=pPDU->GetVersion(); if(nVer != 1) { outputLog(QString("%1：不支持的协议版本(%2)，拒绝该连接请求。").arg(m_strSCUIP).arg(nVer)); SendAssociateReject(PDU_REJECT_RESULT_PERMANENT, PDU_REJECT_SOURCE_PROVIDER1, PDU_REJECT_REASON_VERSION); return; } LDicomAssociate dicomAssociate(L_FALSE); dicomAssociate.Reset(L_FALSE); dicomAssociate.SetCalled(szCalled); dicomAssociate.SetCalling(szCalling); dicomAssociate.SetApplication(const_cast<L_TCHAR*>(UID_APPLICATION_CONTEXT_NAME)); dicomAssociate.SetVersion(1); L_TCHAR szUID[] = L"1.2.3.108.56497.33"; L_TCHAR szVersion[] = L"StoreSCP"; dicomAssociate.SetImplementClass(L_TRUE, szUID); dicomAssociate.SetImplementVersion(L_TRUE, szVersion); QStringList firstTransferList; firstTransferList.append(QString::fromWCharArray(UID_JPEG_LOSSLESS_NONHIER_14B)); firstTransferList.append(QString::fromWCharArray(UID_JPEG_LOSSLESS_NONHIER_14)); firstTransferList.append(QString::fromWCharArray(UID_JPEG_LOSSLESS_NONHIER_15)); firstTransferList.append(QString::fromWCharArray(UID_JPEG_LOSSLESS_HIER_PROCESS_28)); firstTransferList.append(QString::fromWCharArray(UID_JPEG_LOSSLESS_HIER_PROCESS_29)); firstTransferList.append(QString::fromWCharArray(UID_JPEG2000_LOSSLESS_ONLY)); firstTransferList.append(QString::fromWCharArray(UID_RLE_LOSSLESS)); firstTransferList.append(QString::fromWCharArray(UID_EXPLICIT_VR_LITTLE_ENDIAN)); firstTransferList.append(QString::fromWCharArray(UID_IMPLICIT_VR_LITTLE_ENDIAN)); firstTransferList.append(QString::fromWCharArray(UID_EXPLICIT_VR_BIG_ENDIAN)); QList<L_TCHAR*> szFirstTransferList; szFirstTransferList.append(const_cast<L_TCHAR*>(UID_JPEG_LOSSLESS_NONHIER_14B)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_JPEG_LOSSLESS_NONHIER_14)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_JPEG_LOSSLESS_NONHIER_15)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_JPEG_LOSSLESS_HIER_PROCESS_28)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_JPEG_LOSSLESS_HIER_PROCESS_29)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_JPEG2000_LOSSLESS_ONLY)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_RLE_LOSSLESS)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_EXPLICIT_VR_LITTLE_ENDIAN)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_IMPLICIT_VR_LITTLE_ENDIAN)); szFirstTransferList.append(const_cast<L_TCHAR*>(UID_EXPLICIT_VR_BIG_ENDIAN)); //在 Abstract 表中查找，如果存在(并能找到Transfer)，表示支持。优先支持无损压缩的传输语法。 QStringList acceptClassUIDs; L_TCHAR szAbstract[PDU_MAX_UID_SIZE]; L_INT nPresentationCount = pPDU->GetPresentationCount(); for (int ind = 0; ind < nPresentationCount; ind++) { L_UCHAR nID = pPDU->GetPresentation(ind); pPDU->GetAbstract(nID, szAbstract, PDU_MAX_UID_SIZE); QString strAbstract = QString::fromWCharArray(szAbstract); if (acceptClassUIDs.contains(strAbstract)) { dicomAssociate.AddPresentation(nID, PDU_ACCEPT_RESULT_ABSTRACT_SYNTAX, szAbstract); continue; } else { acceptClassUIDs.append(strAbstract); } dicomAssociate.AddPresentation(nID, PDU_ACCEPT_RESULT_SUCCESS, szAbstract); QStringList transferList; L_TCHAR szTransfer[PDU_MAX_UID_SIZE]; L_INT transferCount = pPDU->GetTransferCount(nID); for (int j = 0; j < transferCount; j++) { pPDU->GetTransfer(nID, j, szTransfer, PDU_MAX_UID_SIZE); QString strTransfer = QString::fromWCharArray(szTransfer); if (transferList.contains(strTransfer) == false) { transferList.append(strTransfer); } } bool bFound = false; for (int j = 0; j < firstTransferList.length(); j++) { if (transferList.contains(firstTransferList.at(j))) { dicomAssociate.AddTransfer(nID, szFirstTransferList[j]); bFound = true; break; } } if (false == bFound && transferList.length() > 0) { L_TCHAR pszTransfer[PDU_MAX_TITLE_SIZE]; transferList.at(0).toWCharArray(pszTransfer); pszTransfer[transferList.at(0).length()] = '\0'; dicomAssociate.AddTransfer(nID, pszTransfer); bFound = true; } if (bFound) { dicomAssociate.SetResult(nID, PDU_ACCEPT_RESULT_SUCCESS); } else { dicomAssociate.SetResult(nID, PDU_ACCEPT_RESULT_TRANSFER_SYNTAX); } } L_INT nRet = SendAssociateAccept(&dicomAssociate); if (nRet != DICOM_SUCCESS) { QString dcmError = DicomError::instance().text(nRet); QString strError = QString("%1：发送 associate accept 发生错误，原因：%2").arg(m_strSCUIP, dcmError); outputLog(strError); return; } outputLog(m_strSCUIP + "：SCU Associate 已接受。"); } L_VOID SCPClient::OnReceiveCStoreRequest(L_UCHAR nPresentationID, L_UINT16 nMessageID, L_TCHAR* pszClass, L_TCHAR* pszInstance, L_UINT16 nPriority, L_TCHAR* pszMoveAE, L_UINT16 nMoveMessageID, LDicomDS* pDS) { Q_UNUSED(nPriority) Q_UNUSED(pszMoveAE) Q_UNUSED(nMoveMessageID) if (nullptr == pDS) { outputLog(m_strSCUIP + "：C-STORE DataSet Is NULL，返回 COMMAND_STATUS_PROCESSING_FAILURE。"); SendCStoreResponse(nPresentationID, nMessageID, pszClass, pszInstance, COMMAND_STATUS_PROCESSING_FAILURE); return; } QString strInstanceUID = QString::fromWCharArray(pszInstance); QString strPatientID, strPatientName; getElementValue(pDS, TAG_PATIENT_ID, strPatientID); getElementValue(pDS, TAG_PATIENT_NAME, strPatientName); outputLog(QString("%1：收到 C-STORE 请求，PatientName：%2，InstanceUID：%3，ClassUID：%4").arg(m_strSCUIP, strPatientName, strInstanceUID, pszClass)); if (strPatientName.isEmpty() || "***" == strPatientName) { //此处对***做特殊处理，是因为测试图像的PatientName是*** strPatientName = "UnknownName"; } QString strStudyDate; QDateTime dtStudyTime; bool bSuccess = getDateTime(pDS, TAG_STUDY_DATE, TAG_STUDY_TIME, dtStudyTime); if (bSuccess) { strStudyDate = dtStudyTime.toString("yyyyMMdd"); } else { strStudyDate = QDateTime::currentDateTime().toString("yyyyMMdd"); } QString strModality; getElementValue(pDS, TAG_MODALITY, strModality); QString strSopInstanceUID = QString::fromWCharArray(pszInstance); QString strImagePath = QString("%1/%2").arg(m_strImageFolder, strPatientName); QDir qDir; if (qDir.exists(strImagePath) == false) { qDir.mkpath(strImagePath); } QString strImageFilename = QString("%1/%2_%3.dcm").arg(strImagePath, strModality, strSopInstanceUID); L_TCHAR pszImageFilename[_MAX_PATH]; strImageFilename.toWCharArray(pszImageFilename); pszImageFilename[strImageFilename.length()] = '\0';