Tria/edr-platform
1
0
Fork 0
mirror of https://github.com/Tria-plc/edr-platform.git synced 2026-08-28 06:40:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
natib21
2026-07-17 11:03:23 +00:00
parent 3376f106b7
commit 57f49a9333
2 changed files with 87 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
apps/edr-freight-api/src/scripts/seed-edr-wagons.ts
View File

@@ -2,6 +2,7 @@ import { AppDataSource } from '../data-source';
import { SeedEdrWagonFleetErNumbering2260000000000 } from '../migrations/2260000000000-SeedEdrWagonFleetErNumbering';
import { AddWagonTrainNumbers2270000000000 } from '../migrations/2270000000000-AddWagonTrainNumbers';
import { SeedWagonRunNumbers2280000000000 } from '../migrations/2280000000000-SeedWagonRunNumbers';
import { SeedWagonYardDoraleh2290000000000 } from '../migrations/2290000000000-SeedWagonYardDoraleh';
async function seedEdRWagons() {
await AppDataSource.initialize();
@@ -12,12 +13,14 @@ async function seedEdRWagons() {
await queryRunner.connect();
await queryRunner.startTransaction();
// Fleet first (recreates every wagon with NULL runs), then the columns are
// ensured to exist, then the run roster is applied on top. Same order the
// migrations run in, so the script and a fresh migrate agree.
// Fleet first (recreates every wagon with NULL yard + NULL runs), then the
// columns are ensured to exist, then the run roster and the yard are applied
// on top. Same order the migrations run in, so the script and a fresh
// migrate agree.
await new SeedEdrWagonFleetErNumbering2260000000000().up(queryRunner);
await new AddWagonTrainNumbers2270000000000().up(queryRunner);
await new SeedWagonRunNumbers2280000000000().up(queryRunner);
await new SeedWagonYardDoraleh2290000000000().up(queryRunner);
const summary = await queryRunner.query(`
SELECT
@@ -27,7 +30,7 @@ async function seedEdRWagons() {
MIN(w.wagon_number) AS first_wagon,
MAX(w.wagon_number) AS last_wagon,
COUNT(*) FILTER (WHERE w.status = 'AVAILABLE')::int AS available,
COUNT(*) FILTER (WHERE w.current_yard_id IS NULL)::int AS unassigned_yard,
COUNT(*) FILTER (WHERE w.current_yard_id IS NULL)::int AS no_yard,
COUNT(*) FILTER (WHERE w.export_train_number IS NOT NULL)::int AS on_a_run
FROM freight.wagons w
JOIN freight.wagon_types wt ON wt.id = w.wagon_type_id
@@ -43,6 +46,16 @@ async function seedEdRWagons() {
FROM freight.wagons;
`);
const yards = await queryRunner.query(`
SELECT
COALESCE(y.label, '(no yard)') AS yard,
COUNT(*)::int AS wagons
FROM freight.wagons w
LEFT JOIN freight.yards y ON y.id = w.current_yard_id
GROUP BY y.label
ORDER BY 2 DESC;
`);
const runs = await queryRunner.query(`
SELECT
export_train_number AS export_run,
@@ -60,6 +73,8 @@ async function seedEdRWagons() {
console.table(summary);
console.log('Run roster (export/import pairs):');
console.table(runs);
console.log('Fleet by yard:');
console.table(yards);
console.log(
`Seeded EDR wagon fleet — ${totals.total} wagons total (expected 1100), ` +
`${totals.on_a_run} on a run (expected 533).`,