Skip to content

Commit

Permalink
refactor: require SeriesModel instead of dicomSeriesModel
Browse files Browse the repository at this point in the history
  • Loading branch information
Chinlinlee committed Nov 10, 2023
1 parent 2075c1d commit 33bdee2
Show file tree
Hide file tree
Showing 6 changed files with 13 additions and 13 deletions.
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
const _ = require("lodash");
const { PatientModel } = require("@dbModels/patient");
const { StudyModel } = require("@dbModels/dicomStudy");
const dicomSeriesModel = require("@models/mongodb/models/dicomSeries");
const { SeriesModel } = require("@dbModels/dicomSeries");
const dicomModel = require("@models/mongodb/models/dicom");
const { dictionary } = require("@models/DICOM/dicom-tags-dic");
const { mongoDateQuery, timeQuery } = require("@models/mongodb/service");
Expand Down Expand Up @@ -193,7 +193,7 @@ class QueryStudyDicomJsonFactory extends QueryDicomJsonFactory {
class QuerySeriesDicomJsonFactory extends QueryDicomJsonFactory {
constructor(queryOptions) {
super(queryOptions);
this.model = dicomSeriesModel;
this.model = SeriesModel;
}
}

Expand Down
4 changes: 2 additions & 2 deletions api/dicom-web/controller/WADO-RS/deletion/service/delete.js
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
const _ = require("lodash");
const { StudyModel } = require("@dbModels/dicomStudy");
const dicomSeriesModel = require("../../../../../../models/mongodb/models/dicomSeries");
const { SeriesModel } = require("@dbModels/dicomSeries");
const dicomModel = require("../../../../../../models/mongodb/models/dicom");
const fsP = require("fs/promises");
const { NotFoundInstanceError } = require("../../../../../../error/dicom-instance");
Expand Down Expand Up @@ -46,7 +46,7 @@ class DeleteService {
}

async deleteSeries() {
let aSeries = await dicomSeriesModel.findOne({
let aSeries = await SeriesModel.findOne({
...this.request.params
});

Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
const dicomModel = require("../../../../../models/mongodb/models/dicom");
const dicomSeriesModel = require("../../../../../models/mongodb/models/dicomSeries");
const errorResponse = require("../../../../../utils/errorResponse/errorResponseMessage");
const renderedService = require("../service/rendered.service");
const _ = require("lodash");
Expand Down
6 changes: 3 additions & 3 deletions dimse/seriesQueryTask.js
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ const _ = require("lodash");
const { createQueryTaskInjectProxy } = require("@java-wrapper/org/github/chinlinlee/dcm777/net/QueryTaskInject");
const { DimseQueryBuilder } = require("./queryBuilder");
const { JsStudyQueryTask } = require("./studyQueryTask");
const dicomSeriesModel = require("@models/mongodb/models/dicomSeries");
const { SeriesModel } = require("@dbModels/dicomSeries");
const { SeriesQueryTask } = require("@java-wrapper/org/github/chinlinlee/dcm777/net/SeriesQueryTask");
const { Attributes } = require("@dcm4che/data/Attributes");
const { createSeriesQueryTaskInjectProxy } = require("@java-wrapper/org/github/chinlinlee/dcm777/net/SeriesQueryTaskInject");
Expand Down Expand Up @@ -117,7 +117,7 @@ class JsSeriesQueryTask extends JsStudyQueryTask {
await this.as.getRemoteAET(), await this.as.getRemoteHostName(),
await this.as.getLocalAET(), await this.as.getLocalHostName()
);

let queryAttr = await Attributes.newInstanceAsync();
await queryAttr.addAll(this.keys);
await queryAttr.addSelected(this.studyAttr, [Tag.PatientID, Tag.StudyInstanceUID]);
Expand All @@ -134,7 +134,7 @@ class JsSeriesQueryTask extends JsStudyQueryTask {
let returnKeys = this.getReturnKeys(normalQuery);

logger.info(`do DIMSE Series query: ${JSON.stringify(mongoQuery.$match)}`);
this.seriesCursor = await dicomSeriesModel.getDimseResultCursor({
this.seriesCursor = await SeriesModel.getDimseResultCursor({
...mongoQuery.$match
}, returnKeys);
}
Expand Down
10 changes: 5 additions & 5 deletions models/mongodb/deleteSchedule.js
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ const moment = require("moment");
const { logger } = require("@root/utils/logs/log");
const { StudyModel } = require("@dbModels/dicomStudy");
const dicomModel = require("./models/dicom");
const dicomSeriesModel = require("./models/dicomSeries");
const { SeriesModel } = require("@dbModels/dicomSeries");

// Delete dicom with delete status >= 2
schedule.scheduleJob("*/5 * * * * *", async function () {
Expand Down Expand Up @@ -38,7 +38,7 @@ async function deleteExpireStudies() {
dicomModel.deleteMany({
studyUID
}),
dicomSeriesModel.deleteMany({
SeriesModel.deleteMany({
studyUID
}),
deletedStudy.delete()
Expand All @@ -50,7 +50,7 @@ async function deleteExpireStudies() {
}

async function deleteExpireSeries() {
let deletedSeries = await dicomSeriesModel.find({
let deletedSeries = await SeriesModel.find({
deleteStatus: {
$gte: 2
}
Expand All @@ -61,7 +61,7 @@ async function deleteExpireSeries() {
let now = moment();
let diff = now.diff(updateAtDate, "seconds");
if (diff >= 30) {
let {studyUID, seriesUID} = aDeletedSeries;
let { studyUID, seriesUID } = aDeletedSeries;

logger.info("delete expired series: " + seriesUID);
await Promise.all([
Expand All @@ -87,7 +87,7 @@ async function deleteExpireInstances() {
});

for (let deletedInstance of deletedInstances) {
let {instanceUID} = deletedInstance;
let { instanceUID } = deletedInstance;

let updateAtDate = moment(deletedInstance.updatedAt);
let now = moment();
Expand Down
1 change: 1 addition & 0 deletions models/mongodb/models/dicomSeries.js
Original file line number Diff line number Diff line change
Expand Up @@ -107,3 +107,4 @@ let dicomSeriesModel = mongoose.model(
);

module.exports = dicomSeriesModel;
module.exports.SeriesModel = dicomSeriesModel;

0 comments on commit 33bdee2

Please sign in to comment.