Add void returns to clean queries

DEFRA · Oct 14, 2024 · a8f3a49 · a8f3a49
1 parent 9a6f0e4
commit a8f3a49
Showing 1 changed file with 57 additions and 0 deletions.
diff --git a/src/modules/return-versions/lib/clean-queries.js b/src/modules/return-versions/lib/clean-queries.js
@@ -23,6 +23,25 @@ const cleanPoints = `
  rl.return_requirement = rr.legacy_id::varchar
  LIMIT 1
  )
+ UNION ALL
+ SELECT
+ rr.return_requirement_id
+ FROM
+ water.return_requirements rr
+ WHERE
+ NOT EXISTS (
+ SELECT 1
+ FROM nald_return_requirements nrr
+ WHERE rr.external_id = nrr.nald_id
+ )
+ AND EXISTS (
+ SELECT 1
+ FROM "returns"."returns" rl
+ WHERE
+ rl.return_requirement = rr.legacy_id::varchar
+ AND rl.status = 'void'
+ LIMIT 1
+ )
  );
 `
 
@@ -49,6 +68,25 @@ const cleanPurposes = `
  rl.return_requirement = rr.legacy_id::varchar
  LIMIT 1
  )
+ UNION ALL
+ SELECT
+ rr.return_requirement_id
+ FROM
+ water.return_requirements rr
+ WHERE
+ NOT EXISTS (
+ SELECT 1
+ FROM nald_return_requirements nrr
+ WHERE rr.external_id = nrr.nald_id
+ )
+ AND EXISTS (
+ SELECT 1
+ FROM "returns"."returns" rl
+ WHERE
+ rl.return_requirement = rr.legacy_id::varchar
+ AND rl.status = 'void'
+ LIMIT 1
+ )
  );
 `
 
@@ -75,6 +113,25 @@ const cleanRequirements = `
  rl.return_requirement = rr.legacy_id::varchar
  LIMIT 1
  )
+ UNION ALL
+ SELECT
+ rr.return_requirement_id
+ FROM
+ water.return_requirements rr
+ WHERE
+ NOT EXISTS (
+ SELECT 1
+ FROM nald_return_requirements nrr
+ WHERE rr.external_id = nrr.nald_id
+ )
+ AND EXISTS (
+ SELECT 1
+ FROM "returns"."returns" rl
+ WHERE
+ rl.return_requirement = rr.legacy_id::varchar
+ AND rl.status = 'void'
+ LIMIT 1
+ )
  );
 `