diff --git a/server/src/queries/integrity.repository.sql b/server/src/queries/integrity.repository.sql index c6ca108d74..b9ff92b091 100644 --- a/server/src/queries/integrity.repository.sql +++ b/server/src/queries/integrity.repository.sql @@ -129,10 +129,10 @@ from and "integrity_report"."type" = $1 where "asset"."deletedAt" is null - and "createdAt" >= $2 - and "createdAt" <= $3 + and "integrity_report"."createdAt" >= $2 + and "integrity_report"."createdAt" <= $3 order by - "createdAt" asc + "integrity_report"."createdAt" asc -- IntegrityRepository.streamIntegrityReports select diff --git a/server/src/repositories/integrity.repository.ts b/server/src/repositories/integrity.repository.ts index c77a0a6375..84ba4bdf48 100644 --- a/server/src/repositories/integrity.repository.ts +++ b/server/src/repositories/integrity.repository.ts @@ -177,9 +177,9 @@ export class IntegrityRepository { 'asset.id as assetId', 'integrity_report.id as reportId', ]) - .$if(startMarker !== undefined, (qb) => qb.where('createdAt', '>=', startMarker!)) - .$if(endMarker !== undefined, (qb) => qb.where('createdAt', '<=', endMarker!)) - .orderBy('createdAt', 'asc') + .$if(startMarker !== undefined, (qb) => qb.where('integrity_report.createdAt', '>=', startMarker!)) + .$if(endMarker !== undefined, (qb) => qb.where('integrity_report.createdAt', '<=', endMarker!)) + .orderBy('integrity_report.createdAt', 'asc') .stream(); }