106 lines
3.4 KiB
TypeScript
106 lines
3.4 KiB
TypeScript
import { spawn } from "node:child_process";
|
|
import { existsSync } from "node:fs";
|
|
import log from "electron-log";
|
|
import path from "node:path";
|
|
import FormData from "form-data";
|
|
import { readFile } from "fs/promises";
|
|
import axios from "axios";
|
|
import { PatientInfo, SeriesInfo, StudyInfo } from "./pacs.type";
|
|
|
|
export const OrthancServerRoot = "http://localhost:8042";
|
|
|
|
export const getPacsPath = (
|
|
platform: "macos" | "windows",
|
|
isDevelopment: boolean
|
|
): string => {
|
|
const orthancExecFile = {
|
|
macos: "orthanc-mac-24.8.1/Orthanc",
|
|
windows: "orthanc-win64-1.12.4/Orthanc.exe",
|
|
};
|
|
const basePath = isDevelopment
|
|
? path.join(process.env.VITE_PUBLIC, "../extraResources")
|
|
: path.join(process.resourcesPath, "lib");
|
|
return path.join(basePath, orthancExecFile[platform]);
|
|
};
|
|
|
|
export const runOrthancServer = (pacsPath: string) => {
|
|
if (existsSync(pacsPath)) {
|
|
const configPath = path.join(path.dirname(pacsPath), "config.json");
|
|
const child_process = spawn(pacsPath, [configPath]);
|
|
child_process.stdout.on("data", (data) => log.info(data.toString()));
|
|
child_process.stderr.on("data", (data) => log.error(data.toString()));
|
|
} else {
|
|
console.error("pacsPath is a not exist");
|
|
log.error("pacsPath is a not exist");
|
|
}
|
|
};
|
|
|
|
/**
|
|
* 上传文件到到pacs
|
|
* @param {string} filePath 文件地址
|
|
* @param {string} orthancUrl orthanc的服务地址
|
|
* @returns
|
|
*/
|
|
export const uploadDicomFile = async (
|
|
filePath: string,
|
|
orthancUrl: string = OrthancServerRoot
|
|
): Promise<boolean> => {
|
|
try {
|
|
const buffer = await readFile(filePath);
|
|
const fd = new FormData();
|
|
fd.append("files", buffer);
|
|
const url = `${orthancUrl}/instances`;
|
|
const headers = { "Content-Type": "multipart/form-data" };
|
|
const { status } = await axios.post(url, fd, { headers });
|
|
return status === 200;
|
|
} catch (error) {
|
|
log.error("Failed to upload DICOM file:", error);
|
|
console.error("Failed to upload DICOM file:", error);
|
|
return false;
|
|
}
|
|
};
|
|
|
|
export const selectStructuredDicom = async (
|
|
orthancUrl: string = OrthancServerRoot
|
|
) => {
|
|
try {
|
|
const response = await axios.get(`${orthancUrl}/patients`);
|
|
const patientIds: string[] = response.data;
|
|
const patients: PatientInfo[] = [];
|
|
|
|
for (const patientId of patientIds) {
|
|
const patientDetailsResponse = await axios.get<PatientInfo>(
|
|
`${orthancUrl}/patients/${patientId}`
|
|
);
|
|
const patientDetails = patientDetailsResponse.data;
|
|
|
|
const studyIds = patientDetails.Studies;
|
|
const studies: StudyInfo[] = [];
|
|
|
|
for (const studyId of studyIds) {
|
|
const studyDetailsResponse = await axios.get<StudyInfo>(
|
|
`${orthancUrl}/studies/${studyId}`
|
|
);
|
|
const studyDetails = studyDetailsResponse.data;
|
|
|
|
const seriesIds = studyDetails.Series;
|
|
const series: SeriesInfo[] = [];
|
|
|
|
for (const seriesId of seriesIds) {
|
|
const seriesDetailsResponse = await axios.get<SeriesInfo>(
|
|
`${orthancUrl}/series/${seriesId}`
|
|
);
|
|
const seriesDetails = seriesDetailsResponse.data;
|
|
series.push({ ...seriesDetails });
|
|
}
|
|
studies.push({ ...studyDetails, children: series });
|
|
}
|
|
patients.push({ ...patientDetails, children: studies });
|
|
}
|
|
return patients;
|
|
} catch (error) {
|
|
console.error("Error fetching detailed patient information:", error);
|
|
throw error; // or handle it accordingly
|
|
}
|
|
};
|