Merge pull request #274 from Tria-plc/Release_order

Release order
This commit is contained in:
yaschalew10
2026-06-25 11:42:23 +03:00
committed by GitHub
46 changed files with 3767 additions and 854 deletions

View File

@@ -17,6 +17,7 @@
"type-check": "tsc --noEmit",
"seed:demo-scheduling": "ts-node -r tsconfig-paths/register src/scripts/seed-demo-scheduling.ts",
"seed:freight-demo": "ts-node -r tsconfig-paths/register src/scripts/seed-freight-demo.ts",
"seed:export-djibouti-interchange-demo": "ts-node -r tsconfig-paths/register src/scripts/seed-export-djibouti-interchange-demo.ts",
"seed:file-upload-settings": "ts-node -r tsconfig-paths/register src/scripts/seed-file-upload-settings.ts",
"seed:fleet-wagons": "bash ../../../docs/new/seeds/seed-fleet-wagons.sh"
},

View File

@@ -66,6 +66,7 @@ import { VehiclesModule } from './modules/vehicles/vehicles.module';
import { DriversModule } from './modules/drivers/drivers.module';
import { FirstMileModule } from './modules/first-mile/first-mile.module';
import { LastMileModule } from './modules/last-mile/last-mile.module';
import { InterchangeDocumentsModule } from './modules/interchange-documents/interchange-documents.module';
@Module({
imports: [
@@ -128,6 +129,7 @@ import { LastMileModule } from './modules/last-mile/last-mile.module';
DriversModule,
FirstMileModule,
LastMileModule,
InterchangeDocumentsModule,
],
providers: [
EdrOrgSeeder,

View File

@@ -0,0 +1,109 @@
import { MigrationInterface, QueryRunner, Table } from 'typeorm';
export class CreateInterchangeDocuments1821000000000 implements MigrationInterface {
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.createTable(
new Table({
schema: 'freight',
name: 'interchange_documents',
columns: [
{ name: 'id', type: 'uuid', isPrimary: true, default: 'uuid_generate_v4()' },
{ name: 'document_no', type: 'varchar', length: '40', isUnique: true },
{ name: 'direction', type: 'varchar', length: '10' },
{ name: 'schedule_id', type: 'uuid', isNullable: true },
{ name: 'train_no', type: 'varchar', length: '40', isNullable: true },
{ name: 'route_id', type: 'uuid', isNullable: true },
{ name: 'origin_facility_id', type: 'uuid', isNullable: true },
{ name: 'destination_facility_id', type: 'uuid', isNullable: true },
{ name: 'handover_location', type: 'varchar', length: '255' },
{ name: 'handover_from', type: 'varchar', length: '255' },
{ name: 'handover_to', type: 'varchar', length: '255' },
{ name: 'operator_name', type: 'varchar', length: '255', isNullable: true },
{ name: 'port_operator_name', type: 'varchar', length: '255', isNullable: true },
{ name: 'shipping_line_name', type: 'varchar', length: '255', isNullable: true },
{ name: 'customs_reference', type: 'varchar', length: '120', isNullable: true },
{ name: 'manifest_reference', type: 'varchar', length: '120', isNullable: true },
{ name: 'status', type: 'varchar', length: '20', default: "'DRAFT'" },
{ name: 'generated_at', type: 'timestamptz', isNullable: true },
{ name: 'acknowledged_at', type: 'timestamptz', isNullable: true },
{ name: 'generated_by', type: 'varchar', length: '120', isNullable: true },
{ name: 'acknowledged_by', type: 'varchar', length: '120', isNullable: true },
{ name: 'remarks', type: 'text', isNullable: true },
{ name: 'created_at', type: 'timestamptz', default: 'now()' },
{ name: 'updated_at', type: 'timestamptz', default: 'now()' },
{ name: 'deleted_at', type: 'timestamptz', isNullable: true },
],
indices: [
{ name: 'idx_interchange_documents_direction', columnNames: ['direction'] },
{ name: 'idx_interchange_documents_status', columnNames: ['status'] },
{ name: 'idx_interchange_documents_schedule', columnNames: ['schedule_id'] },
],
}),
true,
);
await queryRunner.createTable(
new Table({
schema: 'freight',
name: 'interchange_document_items',
columns: [
{ name: 'id', type: 'uuid', isPrimary: true, default: 'uuid_generate_v4()' },
{ name: 'interchange_document_id', type: 'uuid' },
{ name: 'booking_id', type: 'uuid', isNullable: true },
{ name: 'booking_reference', type: 'varchar', length: '64', isNullable: true },
{ name: 'item_type', type: 'varchar', length: '20' },
{ name: 'booking_container_id', type: 'uuid', isNullable: true },
{ name: 'booking_cargo_id', type: 'uuid', isNullable: true },
{ name: 'container_number', type: 'varchar', length: '64', isNullable: true },
{ name: 'seal_number', type: 'varchar', length: '100', isNullable: true },
{ name: 'cargo_id', type: 'uuid', isNullable: true },
{ name: 'cargo_type', type: 'varchar', length: '255', isNullable: true },
{ name: 'cargo_description', type: 'text', isNullable: true },
{ name: 'weight', type: 'numeric', precision: 14, scale: 3, isNullable: true },
{ name: 'quantity', type: 'numeric', precision: 12, scale: 3, isNullable: true },
{ name: 'package_count', type: 'int', isNullable: true },
{ name: 'wagon_number', type: 'varchar', length: '80', isNullable: true },
{ name: 'condition_status', type: 'varchar', length: '20', default: "'GOOD'" },
{ name: 'damage_description', type: 'text', isNullable: true },
{ name: 'remarks', type: 'text', isNullable: true },
{ name: 'created_at', type: 'timestamptz', default: 'now()' },
{ name: 'updated_at', type: 'timestamptz', default: 'now()' },
{ name: 'deleted_at', type: 'timestamptz', isNullable: true },
],
foreignKeys: [
{
columnNames: ['interchange_document_id'],
referencedSchema: 'freight',
referencedTableName: 'interchange_documents',
referencedColumnNames: ['id'],
onDelete: 'CASCADE',
},
{
columnNames: ['booking_id'],
referencedSchema: 'freight',
referencedTableName: 'bookings',
referencedColumnNames: ['id'],
onDelete: 'SET NULL',
},
],
indices: [
{ name: 'idx_interchange_items_document', columnNames: ['interchange_document_id'] },
{ name: 'idx_interchange_items_booking', columnNames: ['booking_id'] },
],
}),
true,
);
await queryRunner.query(`
CREATE UNIQUE INDEX IF NOT EXISTS uq_interchange_active_schedule_direction
ON freight.interchange_documents(schedule_id, direction)
WHERE schedule_id IS NOT NULL AND status <> 'CANCELLED' AND deleted_at IS NULL;
`);
}
public async down(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query('DROP INDEX IF EXISTS freight.uq_interchange_active_schedule_direction;');
await queryRunner.dropTable('freight.interchange_document_items', true);
await queryRunner.dropTable('freight.interchange_documents', true);
}
}

View File

@@ -0,0 +1,3 @@
import { GenerateFromScheduleDto } from './generate-from-schedule.dto';
export class CreateInterchangeDocumentDto extends GenerateFromScheduleDto {}

View File

@@ -0,0 +1,57 @@
import { IsIn, IsOptional, IsString, IsUUID, MaxLength } from 'class-validator';
import { INTERCHANGE_DIRECTIONS, InterchangeDirection } from '../entities/interchange-document.entity';
export class GenerateFromScheduleDto {
@IsUUID()
scheduleId!: string;
@IsIn(INTERCHANGE_DIRECTIONS)
direction!: InterchangeDirection;
@IsString()
@MaxLength(255)
handoverLocation!: string;
@IsString()
@MaxLength(255)
handoverFrom!: string;
@IsString()
@MaxLength(255)
handoverTo!: string;
@IsOptional()
@IsString()
@MaxLength(255)
operatorName?: string;
@IsOptional()
@IsString()
@MaxLength(255)
portOperatorName?: string;
@IsOptional()
@IsString()
@MaxLength(255)
shippingLineName?: string;
@IsOptional()
@IsString()
@MaxLength(120)
customsReference?: string;
@IsOptional()
@IsString()
@MaxLength(120)
manifestReference?: string;
@IsOptional()
@IsString()
@MaxLength(120)
generatedBy?: string;
@IsOptional()
@IsString()
remarks?: string;
}

View File

@@ -0,0 +1,38 @@
import { IsIn, IsOptional, IsString, IsUUID } from 'class-validator';
import {
INTERCHANGE_DIRECTIONS,
INTERCHANGE_DOCUMENT_STATUSES,
InterchangeDirection,
InterchangeDocumentStatus,
} from '../entities/interchange-document.entity';
export class InterchangeDocumentQueryDto {
@IsOptional()
@IsIn(INTERCHANGE_DIRECTIONS)
direction?: InterchangeDirection;
@IsOptional()
@IsIn(INTERCHANGE_DOCUMENT_STATUSES)
status?: InterchangeDocumentStatus;
@IsOptional()
@IsUUID()
scheduleId?: string;
@IsOptional()
@IsString()
documentNo?: string;
@IsOptional()
@IsString()
dateFrom?: string;
@IsOptional()
@IsString()
dateTo?: string;
@IsOptional()
@IsString()
search?: string;
}

View File

@@ -0,0 +1,16 @@
import { IsOptional, IsString, MaxLength } from 'class-validator';
export class AcknowledgeInterchangeDocumentDto {
@IsString()
@MaxLength(120)
acknowledgedBy!: string;
@IsOptional()
@IsString()
remarks?: string;
}
export class DisputeInterchangeDocumentDto {
@IsString()
remarks!: string;
}

View File

@@ -0,0 +1,85 @@
import { BaseEntity } from '@edr/api-common';
import { Column, Entity, Index, JoinColumn, ManyToOne } from 'typeorm';
import { Booking } from '../../bookings/entities/booking.entity';
import { InterchangeDocument } from './interchange-document.entity';
export const INTERCHANGE_ITEM_TYPES = ['CONTAINER', 'CARGO'] as const;
export type InterchangeItemType = (typeof INTERCHANGE_ITEM_TYPES)[number];
export const INTERCHANGE_CONDITION_STATUSES = [
'GOOD',
'DAMAGED',
'SHORTAGE',
'EXCESS',
'HOLD',
'UNKNOWN',
] as const;
export type InterchangeConditionStatus = (typeof INTERCHANGE_CONDITION_STATUSES)[number];
@Entity({ schema: 'freight', name: 'interchange_document_items' })
@Index(['interchangeDocumentId'])
@Index(['bookingId'])
export class InterchangeDocumentItem extends BaseEntity {
@Column({ name: 'interchange_document_id', type: 'uuid' })
interchangeDocumentId!: string;
@ManyToOne(() => InterchangeDocument, (document) => document.items, { onDelete: 'CASCADE' })
@JoinColumn({ name: 'interchange_document_id' })
document?: InterchangeDocument;
@Column({ name: 'booking_id', type: 'uuid', nullable: true })
bookingId?: string | null;
@ManyToOne(() => Booking, { nullable: true, onDelete: 'SET NULL' })
@JoinColumn({ name: 'booking_id' })
booking?: Booking | null;
@Column({ name: 'booking_reference', type: 'varchar', length: 64, nullable: true })
bookingReference?: string | null;
@Column({ name: 'item_type', type: 'varchar', length: 20 })
itemType!: InterchangeItemType;
@Column({ name: 'booking_container_id', type: 'uuid', nullable: true })
bookingContainerId?: string | null;
@Column({ name: 'booking_cargo_id', type: 'uuid', nullable: true })
bookingCargoId?: string | null;
@Column({ name: 'container_number', type: 'varchar', length: 64, nullable: true })
containerNumber?: string | null;
@Column({ name: 'seal_number', type: 'varchar', length: 100, nullable: true })
sealNumber?: string | null;
@Column({ name: 'cargo_id', type: 'uuid', nullable: true })
cargoId?: string | null;
@Column({ name: 'cargo_type', type: 'varchar', length: 255, nullable: true })
cargoType?: string | null;
@Column({ name: 'cargo_description', type: 'text', nullable: true })
cargoDescription?: string | null;
@Column({ name: 'weight', type: 'numeric', precision: 14, scale: 3, nullable: true })
weight?: number | null;
@Column({ name: 'quantity', type: 'numeric', precision: 12, scale: 3, nullable: true })
quantity?: number | null;
@Column({ name: 'package_count', type: 'int', nullable: true })
packageCount?: number | null;
@Column({ name: 'wagon_number', type: 'varchar', length: 80, nullable: true })
wagonNumber?: string | null;
@Column({ name: 'condition_status', type: 'varchar', length: 20, default: 'GOOD' })
conditionStatus!: InterchangeConditionStatus;
@Column({ name: 'damage_description', type: 'text', nullable: true })
damageDescription?: string | null;
@Column({ name: 'remarks', type: 'text', nullable: true })
remarks?: string | null;
}

View File

@@ -0,0 +1,89 @@
import { BaseEntity } from '@edr/api-common';
import { Column, Entity, Index, OneToMany } from 'typeorm';
import { InterchangeDocumentItem } from './interchange-document-item.entity';
export const INTERCHANGE_DIRECTIONS = ['IMPORT', 'EXPORT'] as const;
export type InterchangeDirection = (typeof INTERCHANGE_DIRECTIONS)[number];
export const INTERCHANGE_DOCUMENT_STATUSES = [
'DRAFT',
'GENERATED',
'ACKNOWLEDGED',
'DISPUTED',
'CANCELLED',
] as const;
export type InterchangeDocumentStatus = (typeof INTERCHANGE_DOCUMENT_STATUSES)[number];
@Entity({ schema: 'freight', name: 'interchange_documents' })
@Index(['documentNo'], { unique: true })
@Index(['direction'])
@Index(['status'])
@Index(['scheduleId'])
export class InterchangeDocument extends BaseEntity {
@Column({ name: 'document_no', type: 'varchar', length: 40, unique: true })
documentNo!: string;
@Column({ name: 'direction', type: 'varchar', length: 10 })
direction!: InterchangeDirection;
@Column({ name: 'schedule_id', type: 'uuid', nullable: true })
scheduleId?: string | null;
@Column({ name: 'train_no', type: 'varchar', length: 40, nullable: true })
trainNo?: string | null;
@Column({ name: 'route_id', type: 'uuid', nullable: true })
routeId?: string | null;
@Column({ name: 'origin_facility_id', type: 'uuid', nullable: true })
originFacilityId?: string | null;
@Column({ name: 'destination_facility_id', type: 'uuid', nullable: true })
destinationFacilityId?: string | null;
@Column({ name: 'handover_location', type: 'varchar', length: 255 })
handoverLocation!: string;
@Column({ name: 'handover_from', type: 'varchar', length: 255 })
handoverFrom!: string;
@Column({ name: 'handover_to', type: 'varchar', length: 255 })
handoverTo!: string;
@Column({ name: 'operator_name', type: 'varchar', length: 255, nullable: true })
operatorName?: string | null;
@Column({ name: 'port_operator_name', type: 'varchar', length: 255, nullable: true })
portOperatorName?: string | null;
@Column({ name: 'shipping_line_name', type: 'varchar', length: 255, nullable: true })
shippingLineName?: string | null;
@Column({ name: 'customs_reference', type: 'varchar', length: 120, nullable: true })
customsReference?: string | null;
@Column({ name: 'manifest_reference', type: 'varchar', length: 120, nullable: true })
manifestReference?: string | null;
@Column({ name: 'status', type: 'varchar', length: 20, default: 'DRAFT' })
status!: InterchangeDocumentStatus;
@Column({ name: 'generated_at', type: 'timestamptz', nullable: true })
generatedAt?: Date | null;
@Column({ name: 'acknowledged_at', type: 'timestamptz', nullable: true })
acknowledgedAt?: Date | null;
@Column({ name: 'generated_by', type: 'varchar', length: 120, nullable: true })
generatedBy?: string | null;
@Column({ name: 'acknowledged_by', type: 'varchar', length: 120, nullable: true })
acknowledgedBy?: string | null;
@Column({ name: 'remarks', type: 'text', nullable: true })
remarks?: string | null;
@OneToMany(() => InterchangeDocumentItem, (item) => item.document)
items?: InterchangeDocumentItem[];
}

View File

@@ -0,0 +1,56 @@
import { Body, Controller, Get, Param, ParseUUIDPipe, Patch, Post, Query } from '@nestjs/common';
import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
import { GenerateFromScheduleDto } from './dto/generate-from-schedule.dto';
import { InterchangeDocumentQueryDto } from './dto/interchange-document-query.dto';
import {
AcknowledgeInterchangeDocumentDto,
DisputeInterchangeDocumentDto,
} from './dto/update-interchange-document-status.dto';
import { InterchangeDocumentsService } from './interchange-documents.service';
@ApiTags('interchange-documents')
@ApiBearerAuth()
@Controller('interchange-documents')
export class InterchangeDocumentsController {
constructor(private readonly service: InterchangeDocumentsService) {}
@Get()
@ApiOperation({ summary: 'List interchange documents' })
findAll(@Query() query: InterchangeDocumentQueryDto) {
return this.service.findAll(query);
}
@Get(':id')
@ApiOperation({ summary: 'Get interchange document detail' })
findOne(@Param('id', ParseUUIDPipe) id: string) {
return this.service.findOne(id);
}
@Post('generate-from-schedule')
@ApiOperation({ summary: 'Generate interchange document from a train schedule handover' })
generateFromSchedule(@Body() dto: GenerateFromScheduleDto) {
return this.service.generateFromSchedule(dto);
}
@Patch(':id/acknowledge')
@ApiOperation({ summary: 'Acknowledge an interchange document' })
acknowledge(
@Param('id', ParseUUIDPipe) id: string,
@Body() dto: AcknowledgeInterchangeDocumentDto,
) {
return this.service.acknowledge(id, dto);
}
@Patch(':id/dispute')
@ApiOperation({ summary: 'Dispute an interchange document' })
dispute(@Param('id', ParseUUIDPipe) id: string, @Body() dto: DisputeInterchangeDocumentDto) {
return this.service.dispute(id, dto);
}
@Patch(':id/cancel')
@ApiOperation({ summary: 'Cancel a draft/generated interchange document' })
cancel(@Param('id', ParseUUIDPipe) id: string) {
return this.service.cancel(id);
}
}

View File

@@ -0,0 +1,16 @@
import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';
import { InterchangeDocumentItem } from './entities/interchange-document-item.entity';
import { InterchangeDocument } from './entities/interchange-document.entity';
import { InterchangeDocumentsController } from './interchange-documents.controller';
import { InterchangeDocumentsRepository } from './interchange-documents.repository';
import { InterchangeDocumentsService } from './interchange-documents.service';
@Module({
imports: [TypeOrmModule.forFeature([InterchangeDocument, InterchangeDocumentItem])],
controllers: [InterchangeDocumentsController],
providers: [InterchangeDocumentsRepository, InterchangeDocumentsService],
exports: [InterchangeDocumentsService],
})
export class InterchangeDocumentsModule {}

View File

@@ -0,0 +1,13 @@
import { BaseRepository } from '@edr/api-common';
import { Injectable } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { InterchangeDocument } from './entities/interchange-document.entity';
@Injectable()
export class InterchangeDocumentsRepository extends BaseRepository<InterchangeDocument> {
constructor(@InjectRepository(InterchangeDocument) repository: Repository<InterchangeDocument>) {
super(repository);
}
}

View File

@@ -0,0 +1,392 @@
import { BadRequestException, Injectable, NotFoundException } from '@nestjs/common';
import { DataSource, FindOptionsWhere, ILike, Not } from 'typeorm';
import { deriveTradeDirection } from '../../common/derive-trade-direction.util';
import { GenerateFromScheduleDto } from './dto/generate-from-schedule.dto';
import { InterchangeDocumentQueryDto } from './dto/interchange-document-query.dto';
import {
AcknowledgeInterchangeDocumentDto,
DisputeInterchangeDocumentDto,
} from './dto/update-interchange-document-status.dto';
import { InterchangeDocumentItem } from './entities/interchange-document-item.entity';
import {
InterchangeDirection,
InterchangeDocument,
InterchangeDocumentStatus,
} from './entities/interchange-document.entity';
interface ScheduleSnapshot {
id: string;
status: string;
trainNo: string | null;
routeId: string | null;
originFacilityId: string | null;
destinationFacilityId: string | null;
originCountry: string | null;
destinationCountry: string | null;
}
interface InterchangeItemSnapshot {
bookingId: string;
bookingReference: string | null;
itemType: 'CONTAINER' | 'CARGO';
bookingContainerId: string | null;
bookingCargoId: string | null;
containerNumber: string | null;
sealNumber: string | null;
cargoId: string | null;
cargoType: string | null;
cargoDescription: string | null;
weight: string | number | null;
quantity: string | number | null;
packageCount: string | number | null;
wagonNumber: string | null;
hasDamage: boolean | null;
damageDescription: string | null;
hasWeightLoss: boolean | null;
hasMissingItems: boolean | null;
missingItemsDescription: string | null;
}
@Injectable()
export class InterchangeDocumentsService {
constructor(private readonly dataSource: DataSource) {}
async findAll(query: InterchangeDocumentQueryDto): Promise<InterchangeDocument[]> {
const where: FindOptionsWhere<InterchangeDocument>[] = [];
const base: FindOptionsWhere<InterchangeDocument> = {
...(query.direction ? { direction: query.direction } : {}),
...(query.status ? { status: query.status } : {}),
...(query.scheduleId ? { scheduleId: query.scheduleId } : {}),
...(query.documentNo ? { documentNo: ILike(`%${query.documentNo}%`) } : {}),
};
const search = query.search?.trim();
if (search) {
where.push(
{ ...base, documentNo: ILike(`%${search}%`) },
{ ...base, trainNo: ILike(`%${search}%`) },
{ ...base, handoverLocation: ILike(`%${search}%`) },
{ ...base, handoverFrom: ILike(`%${search}%`) },
{ ...base, handoverTo: ILike(`%${search}%`) },
);
}
const qb = this.dataSource
.getRepository(InterchangeDocument)
.createQueryBuilder('doc')
.leftJoinAndSelect('doc.items', 'items')
.where(where.length ? where : base)
.orderBy('doc.createdAt', 'DESC')
.addOrderBy('items.createdAt', 'ASC');
if (query.dateFrom) qb.andWhere('doc.created_at >= :dateFrom', { dateFrom: query.dateFrom });
if (query.dateTo) qb.andWhere('doc.created_at <= :dateTo', { dateTo: query.dateTo });
return qb.getMany();
}
async findOne(id: string): Promise<InterchangeDocument> {
const document = await this.dataSource.getRepository(InterchangeDocument).findOne({
where: { id },
relations: { items: true },
order: { items: { createdAt: 'ASC' } },
});
if (!document) throw new NotFoundException(`Interchange document ${id} not found`);
return document;
}
async generateFromSchedule(dto: GenerateFromScheduleDto): Promise<InterchangeDocument> {
const existing = await this.dataSource.getRepository(InterchangeDocument).findOne({
where: {
scheduleId: dto.scheduleId,
direction: dto.direction,
status: Not('CANCELLED') as unknown as InterchangeDocumentStatus,
},
relations: { items: true },
});
if (existing) return existing;
const schedule = await this.getScheduleSnapshot(dto.scheduleId);
const routeDirection = deriveTradeDirection(
{ country: schedule.originCountry },
{ country: schedule.destinationCountry },
);
if (routeDirection !== dto.direction) {
throw new BadRequestException(`Train schedule route is ${routeDirection}, not ${dto.direction}`);
}
const itemSnapshots = await this.getScheduleItems(dto.scheduleId);
if (itemSnapshots.length === 0) {
throw new BadRequestException('No booking/container/cargo items found for this schedule');
}
return this.dataSource.transaction(async (manager) => {
const now = new Date();
const document = manager.getRepository(InterchangeDocument).create({
documentNo: await this.nextDocumentNo(dto.direction),
direction: dto.direction,
scheduleId: schedule.id,
trainNo: schedule.trainNo,
routeId: schedule.routeId,
originFacilityId: schedule.originFacilityId,
destinationFacilityId: schedule.destinationFacilityId,
handoverLocation: dto.handoverLocation.trim(),
handoverFrom: dto.handoverFrom.trim(),
handoverTo: dto.handoverTo.trim(),
operatorName: dto.operatorName?.trim() || null,
portOperatorName: dto.portOperatorName?.trim() || null,
shippingLineName: dto.shippingLineName?.trim() || null,
customsReference: dto.customsReference?.trim() || null,
manifestReference: dto.manifestReference?.trim() || null,
status: 'GENERATED',
generatedAt: now,
generatedBy: dto.generatedBy?.trim() || null,
remarks: dto.remarks?.trim() || null,
});
const saved = await manager.getRepository(InterchangeDocument).save(document);
const items = itemSnapshots.map((item) =>
manager.getRepository(InterchangeDocumentItem).create({
interchangeDocumentId: saved.id,
bookingId: item.bookingId,
bookingReference: item.bookingReference,
itemType: item.itemType,
bookingContainerId: item.bookingContainerId,
bookingCargoId: item.bookingCargoId,
containerNumber: item.containerNumber,
sealNumber: item.sealNumber,
cargoId: item.cargoId,
cargoType: item.cargoType,
cargoDescription: item.cargoDescription,
weight: item.weight === null ? null : Number(item.weight) || null,
quantity: item.quantity === null ? null : Number(item.quantity) || null,
packageCount: item.packageCount === null ? null : Number(item.packageCount) || null,
wagonNumber: item.wagonNumber,
conditionStatus: this.conditionFromInspection(item),
damageDescription:
item.damageDescription ?? item.missingItemsDescription ?? null,
remarks: null,
}),
);
await manager.getRepository(InterchangeDocumentItem).save(items);
return manager.getRepository(InterchangeDocument).findOneOrFail({
where: { id: saved.id },
relations: { items: true },
order: { items: { createdAt: 'ASC' } },
});
});
}
async acknowledge(
id: string,
dto: AcknowledgeInterchangeDocumentDto,
): Promise<InterchangeDocument> {
const document = await this.findOne(id);
if (document.status === 'CANCELLED') {
throw new BadRequestException('Cancelled interchange document cannot be acknowledged');
}
await this.dataSource.getRepository(InterchangeDocument).update(id, {
status: 'ACKNOWLEDGED',
acknowledgedAt: new Date(),
acknowledgedBy: dto.acknowledgedBy,
remarks: dto.remarks ?? document.remarks ?? null,
});
return this.findOne(id);
}
async dispute(id: string, dto: DisputeInterchangeDocumentDto): Promise<InterchangeDocument> {
await this.findOne(id);
await this.dataSource.getRepository(InterchangeDocument).update(id, {
status: 'DISPUTED',
remarks: dto.remarks,
});
return this.findOne(id);
}
async cancel(id: string): Promise<InterchangeDocument> {
const document = await this.findOne(id);
if (!['DRAFT', 'GENERATED'].includes(document.status)) {
throw new BadRequestException(`Interchange document ${document.status} cannot be cancelled`);
}
await this.dataSource.getRepository(InterchangeDocument).update(id, { status: 'CANCELLED' });
return this.findOne(id);
}
private async getScheduleSnapshot(scheduleId: string): Promise<ScheduleSnapshot> {
const [schedule] = await this.dataSource.query(
`SELECT ts.id,
ts.status,
ts.train_number AS "trainNo",
ts.route_id AS "routeId",
ts.origin_station_id AS "originFacilityId",
ts.destination_station_id AS "destinationFacilityId",
oy.country AS "originCountry",
dy.country AS "destinationCountry"
FROM freight.train_schedules ts
LEFT JOIN freight.yards oy ON oy.id = ts.origin_station_id
LEFT JOIN freight.yards dy ON dy.id = ts.destination_station_id
WHERE ts.id = $1 AND ts.deleted_at IS NULL
LIMIT 1`,
[scheduleId],
);
if (!schedule) throw new NotFoundException(`Train schedule ${scheduleId} not found`);
return schedule;
}
private async getScheduleItems(scheduleId: string): Promise<InterchangeItemSnapshot[]> {
return this.dataSource.query(
`WITH assigned AS (
SELECT b.id AS booking_id,
b.reference,
COALESCE(cgt.cargo_type_name, b.cargo_free_text) AS booking_cargo_type,
b.cargo_free_text,
b.cargo_total_weight_vgm,
(
SELECT string_agg(DISTINCT w.wagon_number, ', ' ORDER BY w.wagon_number)
FROM freight.wagon_booking_allocations wba
JOIN freight.train_set_wagons tsw ON tsw.id = wba.train_set_wagon_id
LEFT JOIN freight.wagons w ON w.id = tsw.physical_wagon_id
WHERE wba.booking_id = b.id
) AS wagon_number,
bool_or(COALESCE(wir.has_damage, false)) AS has_damage,
bool_or(COALESCE(wir.has_weight_loss, false)) AS has_weight_loss,
bool_or(COALESCE(wir.has_missing_items, false)) AS has_missing_items,
string_agg(DISTINCT NULLIF(wir.damage_description, ''), '; ') AS damage_description,
string_agg(DISTINCT NULLIF(wir.missing_items_description, ''), '; ') AS missing_items_description
FROM freight.train_schedule_bookings tsb
JOIN freight.bookings b ON b.id = tsb.booking_id AND b.deleted_at IS NULL
LEFT JOIN freight.cargo_types cgt ON cgt.id = b.cargo_type_id
LEFT JOIN freight.warehouse_inventory inv ON inv.booking_id = b.id AND inv.deleted_at IS NULL
LEFT JOIN freight.warehouse_inspection_reports wir ON wir.inventory_id = inv.id AND wir.deleted_at IS NULL
WHERE tsb.train_schedule_id = $1 AND tsb.deleted_at IS NULL
GROUP BY b.id, b.reference, cgt.cargo_type_name, b.cargo_free_text, b.cargo_total_weight_vgm
)
SELECT a.booking_id AS "bookingId",
a.reference AS "bookingReference",
'CONTAINER' AS "itemType",
COALESCE(c.booking_container_id, bc.id) AS "bookingContainerId",
NULL AS "bookingCargoId",
COALESCE(c.container_number, bc.container_number) AS "containerNumber",
c.seal_number AS "sealNumber",
NULL AS "cargoId",
a.booking_cargo_type AS "cargoType",
a.cargo_free_text AS "cargoDescription",
COALESCE(bc.total_vgm_tons, c.max_gross_weight, a.cargo_total_weight_vgm) AS "weight",
COALESCE(bc.quantity, 1) AS "quantity",
COALESCE(bc.quantity, 1) AS "packageCount",
a.wagon_number AS "wagonNumber",
a.has_damage AS "hasDamage",
a.damage_description AS "damageDescription",
a.has_weight_loss AS "hasWeightLoss",
a.has_missing_items AS "hasMissingItems",
a.missing_items_description AS "missingItemsDescription"
FROM assigned a
JOIN freight.containers c ON c.booking_id = a.booking_id AND c.deleted_at IS NULL
LEFT JOIN freight.booking_container bc ON bc.id = c.booking_container_id AND bc.deleted_at IS NULL
UNION ALL
SELECT a.booking_id AS "bookingId",
a.reference AS "bookingReference",
'CONTAINER' AS "itemType",
bc.id AS "bookingContainerId",
NULL AS "bookingCargoId",
bc.container_number AS "containerNumber",
NULL AS "sealNumber",
NULL AS "cargoId",
a.booking_cargo_type AS "cargoType",
a.cargo_free_text AS "cargoDescription",
COALESCE(bc.total_vgm_tons, a.cargo_total_weight_vgm) AS "weight",
bc.quantity AS "quantity",
bc.quantity AS "packageCount",
a.wagon_number AS "wagonNumber",
a.has_damage AS "hasDamage",
a.damage_description AS "damageDescription",
a.has_weight_loss AS "hasWeightLoss",
a.has_missing_items AS "hasMissingItems",
a.missing_items_description AS "missingItemsDescription"
FROM assigned a
JOIN freight.booking_container bc ON bc.booking_id = a.booking_id AND bc.deleted_at IS NULL
WHERE NOT EXISTS (
SELECT 1 FROM freight.containers c
WHERE c.booking_container_id = bc.id AND c.deleted_at IS NULL
)
UNION ALL
SELECT a.booking_id AS "bookingId",
a.reference AS "bookingReference",
'CARGO' AS "itemType",
NULL AS "bookingContainerId",
cg.id AS "bookingCargoId",
NULL AS "containerNumber",
NULL AS "sealNumber",
cg.id AS "cargoId",
COALESCE(cgt.cargo_type_name, a.booking_cargo_type) AS "cargoType",
COALESCE(cg.description, a.cargo_free_text) AS "cargoDescription",
COALESCE(cg.weight, a.cargo_total_weight_vgm) AS "weight",
cg.quantity AS "quantity",
cg.quantity AS "packageCount",
a.wagon_number AS "wagonNumber",
a.has_damage AS "hasDamage",
a.damage_description AS "damageDescription",
a.has_weight_loss AS "hasWeightLoss",
a.has_missing_items AS "hasMissingItems",
a.missing_items_description AS "missingItemsDescription"
FROM assigned a
JOIN freight.cargoes cg ON cg.booking_id = a.booking_id AND cg.deleted_at IS NULL
LEFT JOIN freight.cargo_types cgt ON cgt.id = cg.cargo_type_id
UNION ALL
SELECT a.booking_id AS "bookingId",
a.reference AS "bookingReference",
CASE WHEN a.booking_cargo_type ILIKE '%container%' THEN 'CONTAINER' ELSE 'CARGO' END AS "itemType",
NULL AS "bookingContainerId",
NULL AS "bookingCargoId",
NULL AS "containerNumber",
NULL AS "sealNumber",
NULL AS "cargoId",
a.booking_cargo_type AS "cargoType",
a.cargo_free_text AS "cargoDescription",
a.cargo_total_weight_vgm AS "weight",
1 AS "quantity",
1 AS "packageCount",
a.wagon_number AS "wagonNumber",
a.has_damage AS "hasDamage",
a.damage_description AS "damageDescription",
a.has_weight_loss AS "hasWeightLoss",
a.has_missing_items AS "hasMissingItems",
a.missing_items_description AS "missingItemsDescription"
FROM assigned a
WHERE NOT EXISTS (SELECT 1 FROM freight.containers c WHERE c.booking_id = a.booking_id AND c.deleted_at IS NULL)
AND NOT EXISTS (SELECT 1 FROM freight.booking_container bc WHERE bc.booking_id = a.booking_id AND bc.deleted_at IS NULL)
AND NOT EXISTS (SELECT 1 FROM freight.cargoes cg WHERE cg.booking_id = a.booking_id AND cg.deleted_at IS NULL)
ORDER BY "bookingReference" ASC NULLS LAST, "itemType" ASC, "containerNumber" ASC NULLS LAST`,
[scheduleId],
);
}
private conditionFromInspection(item: InterchangeItemSnapshot) {
if (item.hasDamage) return 'DAMAGED';
if (item.hasWeightLoss || item.hasMissingItems) return 'SHORTAGE';
return 'GOOD';
}
private async nextDocumentNo(direction: InterchangeDirection): Promise<string> {
const prefix = `ICD-${direction === 'EXPORT' ? 'EXP' : 'IMP'}-${this.yyyymmdd(new Date())}`;
const [row] = await this.dataSource.query(
`SELECT document_no AS "documentNo"
FROM freight.interchange_documents
WHERE document_no LIKE $1
ORDER BY document_no DESC
LIMIT 1`,
[`${prefix}-%`],
);
const last = row?.documentNo ? Number(String(row.documentNo).split('-').pop()) || 0 : 0;
return `${prefix}-${String(last + 1).padStart(4, '0')}`;
}
private yyyymmdd(date: Date): string {
const yyyy = date.getUTCFullYear();
const mm = String(date.getUTCMonth() + 1).padStart(2, '0');
const dd = String(date.getUTCDate()).padStart(2, '0');
return `${yyyy}${mm}${dd}`;
}
}

View File

@@ -52,6 +52,41 @@ export class LastMileService {
);
}
if ((booking.tradeDirection ?? '').toUpperCase() !== 'IMPORT') {
throw new BadRequestException(`Booking ${bookingReference} is not an import booking`);
}
if (!booking.lastMileDeliveryAddress?.trim()) {
throw new BadRequestException(`Booking ${bookingReference} has no last-mile delivery address`);
}
const [eligibleInventory] = await this.dataSource.query(
`SELECT inv.id
FROM freight.warehouse_inventory inv
WHERE inv.booking_id = $1
AND inv.deleted_at IS NULL
AND inv.status = 'READY_FOR_PICKUP'
AND inv.inspection_status = 'PASSED'
LIMIT 1`,
[booking.id],
);
if (!eligibleInventory) {
throw new BadRequestException(
`Booking ${bookingReference} is not eligible for last mile. Import inventory must pass inspection and be READY_FOR_PICKUP.`,
);
}
const [existing] = await this.dataSource.query(
`SELECT id
FROM freight.last_mile
WHERE booking_id = $1 AND deleted_at IS NULL
LIMIT 1`,
[booking.id],
);
if (existing) {
return this.findById(existing.id);
}
return this.create({
bookingId: booking.id,
advancedPayment: 0,

View File

@@ -1,8 +1,8 @@
import { Module, forwardRef } from "@nestjs/common";
import { TypeOrmModule } from "@nestjs/typeorm";
import { DynamicModule, Module, forwardRef } from "@nestjs/common";
import { HttpModule } from "@nestjs/axios";
import { ConfigModule, ConfigService } from "@nestjs/config";
import { RabbitMQModule } from "@golevelup/nestjs-rabbitmq";
import { TypeOrmModule } from "@nestjs/typeorm";
import {
PAYMENT_EVENTS_DLX,
PAYMENT_EVENTS_EXCHANGE,
@@ -10,33 +10,31 @@ import {
PaymentService as PaymentServiceEnum,
paymentServiceBindingPattern,
} from "@edr/types";
import { PaymentService } from "./payment.service";
import { PaymentClientService } from "./payment-client.service";
import { PaymentController } from "./payment.controller";
import { PaymentRepository } from "./payment.repository";
import { PaymentEventsConsumer } from "./payment-events.consumer";
import { InternalPaymentController } from "./internal-payment.controller";
import { ServiceAuthGuard } from "../../common/guards/service-auth.guard";
import { TrainSchedulingModule } from "../train-scheduling/train-scheduling.module";
import { DropdownSettingsModule } from "../dropdown-settings/dropdown-settings.module";
import { FirstMileModule } from "../first-mile/first-mile.module";
import { PaymentWebhookEventEntity } from "./entities/payment-webhook-event.entity";
import { TrainSchedulingModule } from "../train-scheduling/train-scheduling.module";
import { PaymentRefundEntity } from "./entities/payment-refund.entity";
import { PaymentWebhookEventEntity } from "./entities/payment-webhook-event.entity";
import { PaymentEntity } from "./entities/payment.entity";
import { InternalPaymentController } from "./internal-payment.controller";
import { PaymentClientService } from "./payment-client.service";
import { PaymentController } from "./payment.controller";
import { PaymentEventsConsumer } from "./payment-events.consumer";
import { PaymentRepository } from "./payment.repository";
import { PaymentService } from "./payment.service";
const FREIGHT_QUEUE = PAYMENT_QUEUES[PaymentServiceEnum.FREIGHT];
@Module({
imports: [
HttpModule.register({ timeout: 10_000 }),
ConfigModule,
DropdownSettingsModule,
forwardRef(() => FirstMileModule),
forwardRef(() => TrainSchedulingModule),
TypeOrmModule.forFeature([PaymentWebhookEventEntity, PaymentRefundEntity]),
function rabbitMQImport(): DynamicModule[] {
if (!process.env.PAYMENT_RABBITMQ_URL) return [];
return [
RabbitMQModule.forRootAsync({
inject: [ConfigService],
useFactory: (config: ConfigService) => ({
uri: config.get<string>("rabbitmq.url") as string,
uri: config.get<string>("rabbitmq.url") ?? process.env.PAYMENT_RABBITMQ_URL ?? "",
exchanges: [
{ name: PAYMENT_EVENTS_EXCHANGE, type: "topic", options: { durable: true } },
{ name: PAYMENT_EVENTS_DLX, type: "topic", options: { durable: true } },
@@ -53,6 +51,22 @@ const FREIGHT_QUEUE = PAYMENT_QUEUES[PaymentServiceEnum.FREIGHT];
connectionInitOptions: { wait: false },
}),
}),
];
}
@Module({
imports: [
HttpModule.register({ timeout: 10_000 }),
ConfigModule,
DropdownSettingsModule,
forwardRef(() => FirstMileModule),
forwardRef(() => TrainSchedulingModule),
TypeOrmModule.forFeature([
PaymentEntity,
PaymentWebhookEventEntity,
PaymentRefundEntity,
]),
...rabbitMQImport(),
],
providers: [
PaymentRepository,
@@ -64,4 +78,4 @@ const FREIGHT_QUEUE = PAYMENT_QUEUES[PaymentServiceEnum.FREIGHT];
controllers: [PaymentController, InternalPaymentController],
exports: [PaymentService],
})
export class PaymentModule { }
export class PaymentModule {}

View File

@@ -62,13 +62,4 @@ export class Vehicle extends BaseEntity {
@Column({ name: 'assigned_driver_name', nullable: true })
assignedDriverName?: string;
@Column({ name: 'code', nullable: true })
code?: string;
@Column({ name: 'power_plate_no', nullable: true })
powerPlateNo?: string;
@Column({ name: 'trailer_plate_no', nullable: true })
trailerPlateNo?: string;
}

View File

@@ -1,5 +1,5 @@
import { ApiPropertyOptional } from '@nestjs/swagger';
import { IsBoolean, IsNumber, IsOptional, IsString, Min } from 'class-validator';
import { IsBoolean, IsIn, IsNumber, IsOptional, IsString, Min } from 'class-validator';
export class GenerateInvoiceDto {
@ApiPropertyOptional({ description: 'Create even when the calculated amount is zero.' })
@@ -11,6 +11,11 @@ export class GenerateInvoiceDto {
@IsOptional()
@IsString()
performedBy?: string;
@ApiPropertyOptional({ enum: ['ETB', 'USD'], description: 'Currency to bill the generated invoice in.' })
@IsOptional()
@IsIn(['ETB', 'USD'])
billingCurrency?: 'ETB' | 'USD';
}
export class PayInvoiceBodyDto {

View File

@@ -15,6 +15,7 @@ import { WarehouseZone } from './warehouse-zone.entity';
// IMPORT: READY_FOR_PICKUP → DELIVERED (release order + proof of delivery)
export const WAREHOUSE_INVENTORY_STATUSES = [
'UNLOADED',
'UNLOADED_AT_DJIBOUTI_PORT',
'RECEIVED',
'STORED',
'RESERVED',
@@ -31,12 +32,13 @@ export const WAREHOUSE_INVENTORY_TRANSITIONS: Record<WarehouseInventoryStatus, W
// UNLOADED = train-arrival landing state (Batch 8). Not yet stored/inspected.
// Mirrors RECEIVED so the import flow can store or go straight to pickup after inspection.
UNLOADED: ['STORED', 'READY_FOR_PICKUP'],
UNLOADED_AT_DJIBOUTI_PORT: [],
RECEIVED: ['STORED', 'READY_FOR_PICKUP'],
STORED: ['RESERVED'],
RESERVED: ['READY_FOR_LOADING'],
READY_FOR_LOADING: ['LOADED'],
LOADED: ['DISPATCHED'],
DISPATCHED: [],
DISPATCHED: ['UNLOADED_AT_DJIBOUTI_PORT'],
// Batch 10: an inspected import item can leave by customer pickup (DELIVERED) or be dispatched
// out by EDR (DISPATCHED) — kept separate — or be put into storage (STORED) if no one collects
// it / customs or inspection hold / operator chooses to store.

View File

@@ -37,6 +37,36 @@ export interface ImportTrainItemRow {
lastMileRequested: boolean;
pickupOption: string;
}
export interface ExportDjiboutiQueueFilter {
scheduleId?: string;
destination?: string;
status?: string;
dateFrom?: string;
dateTo?: string;
}
export interface ExportTrainRow extends ImportTrainRow {
departureTime: string | null;
}
export interface ExportTrainItemRow {
bookingId: string;
bookingReference: string | null;
customerId: string | null;
customerName: string | null;
itemType: 'CONTAINER' | 'CARGO';
itemId: string | null;
inventoryId: string | null;
containerNumber: string | null;
cargoType: string | null;
weight: number | null;
origin: string | null;
destination: string | null;
trainSchedule: string | null;
arrivalTime: string | null;
currentStatus: string | null;
}
export interface WagonView {
id: string;
wagonNumber: string;
@@ -67,6 +97,13 @@ export interface BookingScheduleView {
export class SchedulingReadFacade {
constructor(private readonly dataSource: DataSource) {}
private isDjiboutiPortDestination(value: string | null | undefined): boolean {
const normalized = (value ?? '').toUpperCase();
return ['DJIBOUTI', 'DORALEH', 'DMP', 'DCT', 'NAGAD'].some((token) =>
normalized.includes(token),
);
}
/** Look up a single physical wagon. Returns null if it does not exist. */
async findWagon(wagonId: string): Promise<WagonView | null> {
const rows = await this.dataSource.query(
@@ -220,4 +257,187 @@ export class SchedulingReadFacade {
);
return rows;
}
/**
* ARRIVED export train schedules at Djibouti-side destinations, with assigned item counts.
* Read-only: this only selects from scheduling/booking/inventory tables.
*/
async exportDjiboutiArrivalQueue(
filter: ExportDjiboutiQueueFilter = {},
): Promise<ExportTrainRow[]> {
const params: unknown[] = [];
const where = [
'ts.deleted_at IS NULL',
"ts.status = ANY($1)",
`EXISTS (
SELECT 1
FROM freight.train_schedule_bookings tsb_exists
JOIN freight.bookings b_exists ON b_exists.id = tsb_exists.booking_id AND b_exists.deleted_at IS NULL
LEFT JOIN freight.warehouse_inventory inv_exists ON inv_exists.booking_id = b_exists.id AND inv_exists.deleted_at IS NULL
WHERE tsb_exists.train_schedule_id = ts.id
AND tsb_exists.deleted_at IS NULL
AND (inv_exists.status = ANY($2) OR b_exists.status = ANY($2))
)`,
];
params.push(
filter.status ? [filter.status] : ['ARRIVED', 'ARRIVED_AT_DJIBOUTI'],
['DISPATCHED', 'IN_TRANSIT', 'ARRIVED_AT_DJIBOUTI', 'ARRIVED_AT_PORT', 'ARRIVED_AT_DESTINATION'],
);
if (filter.scheduleId) {
params.push(filter.scheduleId);
where.push(`ts.id = $${params.length}`);
}
if (filter.destination) {
params.push(`%${filter.destination}%`);
where.push(`(dy.code ILIKE $${params.length} OR dy.name ILIKE $${params.length})`);
}
if (filter.dateFrom) {
params.push(filter.dateFrom);
where.push(`COALESCE(ts.actual_arrival_at, ts.scheduled_arrival_date) >= $${params.length}`);
}
if (filter.dateTo) {
params.push(filter.dateTo);
where.push(`COALESCE(ts.actual_arrival_at, ts.scheduled_arrival_date) <= $${params.length}`);
}
const rows: Array<
ExportTrainRow & {
originCountry: string | null;
destinationCountry: string | null;
destinationName: string | null;
}
> = await this.dataSource.query(
`SELECT ts.id AS "scheduleId",
ts.train_number AS "trainNumber",
oy.code AS "origin",
dy.code AS "destination",
dy.name AS "destinationName",
oy.country AS "originCountry",
dy.country AS "destinationCountry",
ts.scheduled_departure_date AS "departureTime",
COALESCE(ts.actual_arrival_at, ts.scheduled_arrival_date) AS "arrivalTime",
ts.status,
(SELECT count(*) FROM freight.train_schedule_bookings tsb
WHERE tsb.train_schedule_id = ts.id AND tsb.deleted_at IS NULL) AS "totalBookings",
(SELECT count(*) FROM freight.containers c
JOIN freight.train_schedule_bookings tsbc ON tsbc.booking_id = c.booking_id AND tsbc.deleted_at IS NULL
WHERE tsbc.train_schedule_id = ts.id AND c.deleted_at IS NULL) AS "totalContainers",
(SELECT count(*) FROM freight.cargoes cg
JOIN freight.train_schedule_bookings tsbg ON tsbg.booking_id = cg.booking_id AND tsbg.deleted_at IS NULL
WHERE tsbg.train_schedule_id = ts.id AND cg.deleted_at IS NULL) AS "totalCargoes"
FROM freight.train_schedules ts
LEFT JOIN freight.yards oy ON oy.id = ts.origin_station_id
LEFT JOIN freight.yards dy ON dy.id = ts.destination_station_id
WHERE ${where.join(' AND ')}
ORDER BY COALESCE(ts.actual_arrival_at, ts.scheduled_arrival_date) DESC NULLS LAST`,
params,
);
return rows
.filter((r) => {
const direction = deriveTradeDirection(
{ country: r.originCountry },
{ country: r.destinationCountry },
);
return (
direction === 'EXPORT' &&
this.isDjiboutiPortDestination(`${r.destination ?? ''} ${r.destinationName ?? ''}`)
);
})
.map(({ originCountry: _oc, destinationCountry: _dc, destinationName: _dn, ...rest }) => ({
...rest,
totalBookings: Number(rest.totalBookings) || 0,
totalContainers: Number(rest.totalContainers) || 0,
totalCargoes: Number(rest.totalCargoes) || 0,
route: rest.origin || rest.destination ? `${rest.origin ?? '?'} -> ${rest.destination ?? '?'}` : null,
}));
}
/** Assigned export booking items for an arrived Djibouti-side export train. Read-only. */
async exportDjiboutiTrainDetail(scheduleId: string): Promise<ExportTrainItemRow[]> {
const rows: ExportTrainItemRow[] = await this.dataSource.query(
`WITH assigned AS (
SELECT b.id AS booking_id,
b.reference,
b.company_id,
company.name AS customer_name,
COALESCE(cgt.cargo_type_name, b.cargo_free_text) AS cargo_type,
b.cargo_total_weight_vgm AS booking_weight,
oy.code AS origin,
dy.code AS destination,
ts.train_number,
COALESCE(ts.actual_arrival_at, ts.scheduled_arrival_date) AS arrival_time,
inv.id AS inventory_id,
COALESCE(inv.status, b.status) AS current_status
FROM freight.train_schedule_bookings tsb
JOIN freight.train_schedules ts ON ts.id = tsb.train_schedule_id
JOIN freight.bookings b ON b.id = tsb.booking_id AND b.deleted_at IS NULL
LEFT JOIN freight.companies company ON company.id = b.company_id
LEFT JOIN freight.cargo_types cgt ON cgt.id = b.cargo_type_id
LEFT JOIN freight.yards oy ON oy.id = b.origin_yard_id
LEFT JOIN freight.yards dy ON dy.id = b.destination_yard_id
LEFT JOIN freight.warehouse_inventory inv ON inv.booking_id = b.id AND inv.deleted_at IS NULL
WHERE tsb.train_schedule_id = $1 AND tsb.deleted_at IS NULL
)
SELECT a.booking_id AS "bookingId",
a.reference AS "bookingReference",
a.company_id AS "customerId",
a.customer_name AS "customerName",
'CONTAINER' AS "itemType",
c.id AS "itemId",
a.inventory_id AS "inventoryId",
c.container_number AS "containerNumber",
a.cargo_type AS "cargoType",
a.booking_weight AS "weight",
a.origin,
a.destination,
a.train_number AS "trainSchedule",
a.arrival_time AS "arrivalTime",
a.current_status AS "currentStatus"
FROM assigned a
JOIN freight.containers c ON c.booking_id = a.booking_id AND c.deleted_at IS NULL
UNION ALL
SELECT a.booking_id AS "bookingId",
a.reference AS "bookingReference",
a.company_id AS "customerId",
a.customer_name AS "customerName",
'CARGO' AS "itemType",
cg.id AS "itemId",
a.inventory_id AS "inventoryId",
NULL AS "containerNumber",
COALESCE(cgt.cargo_type_name, a.cargo_type) AS "cargoType",
COALESCE(cg.weight, a.booking_weight) AS "weight",
a.origin,
a.destination,
a.train_number AS "trainSchedule",
a.arrival_time AS "arrivalTime",
a.current_status AS "currentStatus"
FROM assigned a
JOIN freight.cargoes cg ON cg.booking_id = a.booking_id AND cg.deleted_at IS NULL
LEFT JOIN freight.cargo_types cgt ON cgt.id = cg.cargo_type_id
UNION ALL
SELECT a.booking_id AS "bookingId",
a.reference AS "bookingReference",
a.company_id AS "customerId",
a.customer_name AS "customerName",
CASE WHEN a.cargo_type ILIKE '%container%' THEN 'CONTAINER' ELSE 'CARGO' END AS "itemType",
a.inventory_id AS "itemId",
a.inventory_id AS "inventoryId",
NULL AS "containerNumber",
a.cargo_type AS "cargoType",
a.booking_weight AS "weight",
a.origin,
a.destination,
a.train_number AS "trainSchedule",
a.arrival_time AS "arrivalTime",
a.current_status AS "currentStatus"
FROM assigned a
WHERE NOT EXISTS (SELECT 1 FROM freight.containers c WHERE c.booking_id = a.booking_id AND c.deleted_at IS NULL)
AND NOT EXISTS (SELECT 1 FROM freight.cargoes cg WHERE cg.booking_id = a.booking_id AND cg.deleted_at IS NULL)
ORDER BY "bookingReference" ASC NULLS LAST, "itemType" ASC`,
[scheduleId],
);
return rows;
}
}

View File

@@ -1,4 +1,5 @@
import { Injectable, NotFoundException } from '@nestjs/common';
import { ExchangeService } from '@edr/api-common';
import { DataSource } from 'typeorm';
import { CreateFeeRuleDto, UpdateFeeRuleDto } from './dto/fee-rule.dto';
@@ -28,6 +29,8 @@ export interface FeePreview {
freeDays: number;
ratePerDay: number;
currency: string;
ruleCurrency: string | null;
billingCurrency: string;
startDate: string | null;
endDate: string;
endIsOpen: boolean; // true when still accruing (no release/gate-clear yet)
@@ -45,6 +48,7 @@ export class WarehouseFeeService {
constructor(
private readonly dataSource: DataSource,
private readonly feeRuleRepository: WarehouseFeeRuleRepository,
private readonly exchangeService: ExchangeService,
) {}
// ── Rule CRUD ──────────────────────────────────────────────────────────────
@@ -137,12 +141,32 @@ export class WarehouseFeeService {
return best;
}
private compute(ruleType: FeeRuleType, rule: WarehouseFeeRule | null, item: ItemAttributes, now: Date): FeePreview {
private normalizeCurrency(currency?: string | null): 'ETB' | 'USD' {
return currency === 'ETB' ? 'ETB' : 'USD';
}
private async convertAmount(amount: number, fromCurrency: string, toCurrency: string): Promise<number> {
const from = this.normalizeCurrency(fromCurrency);
const to = this.normalizeCurrency(toCurrency);
if (from === to) return Math.round(amount * 100) / 100;
const rate = await this.exchangeService.getRate(from, to);
return Math.round(amount * rate * 100) / 100;
}
private async compute(
ruleType: FeeRuleType,
rule: WarehouseFeeRule | null,
item: ItemAttributes,
now: Date,
billingCurrency: string,
): Promise<FeePreview> {
const start = item.arrivedAt ? new Date(item.arrivedAt) : null;
const endDate = item.gateClearedAt ?? item.releaseDate ?? now;
const endIsOpen = !item.gateClearedAt && !item.releaseDate;
const freeDays = rule?.freeDays ?? 0;
const ratePerDay = Number(rule?.ratePerDay ?? 0);
const ruleCurrency = rule ? this.normalizeCurrency(rule.currency) : null;
const targetCurrency = this.normalizeCurrency(billingCurrency);
const isContainer = (item.freightType ?? '').toUpperCase() === 'CONTAINER';
const inventoryQuantity = Math.max(1, Math.round(Number(item.inventoryQuantity) || 1));
const containerCount = isContainer
@@ -154,15 +178,21 @@ export class WarehouseFeeService {
: 0;
const chargeableDays = Math.max(0, elapsedDays - freeDays);
const billableUnits = chargeableDays * containerCount;
const amount = Math.round(billableUnits * ratePerDay * 100) / 100;
const sourceAmount = Math.round(billableUnits * ratePerDay * 100) / 100;
const amount = ruleCurrency ? await this.convertAmount(sourceAmount, ruleCurrency, targetCurrency) : 0;
const convertedRatePerDay = ruleCurrency
? await this.convertAmount(ratePerDay, ruleCurrency, targetCurrency)
: 0;
return {
ruleType,
ruleId: rule?.id ?? null,
ruleName: rule?.name ?? null,
freeDays,
ratePerDay,
currency: rule?.currency ?? 'USD',
ratePerDay: convertedRatePerDay,
currency: targetCurrency,
ruleCurrency,
billingCurrency: targetCurrency,
startDate: start ? start.toISOString() : null,
endDate: new Date(endDate).toISOString(),
endIsOpen,
@@ -175,14 +205,22 @@ export class WarehouseFeeService {
}
/** Preview demurrage + storage fees for an inventory item using the most specific active rules. */
async previewForInventory(inventoryId: string): Promise<FeePreview[]> {
async previewForInventory(inventoryId: string, billingCurrency = 'USD'): Promise<FeePreview[]> {
const item = await this.loadItem(inventoryId);
const rules = await this.feeRuleRepository.findAll({ where: { isActive: true } });
const now = new Date();
const byType: FeeRuleType[] = ['DEMURRAGE_FEE', 'STORAGE_FEE'];
return byType.map((type) =>
this.compute(type, this.bestRule(rules.filter((r) => r.ruleType === type), item), item, now),
return Promise.all(
byType.map((type) =>
this.compute(
type,
this.bestRule(rules.filter((r) => r.ruleType === type), item),
item,
now,
billingCurrency,
),
),
);
}
}

View File

@@ -2,6 +2,7 @@ import { Injectable, NotFoundException } from '@nestjs/common';
import { DataSource } from 'typeorm';
import { FilesService } from '../files/files.service';
import { LastMileService } from '../last-mile/last-mile.service';
import { CreateInspectionReportDto } from './dto/create-inspection-report.dto';
import { UpdateInspectionReportDto } from './dto/update-inspection-report.dto';
import { WarehouseInspectionReport } from './entities/warehouse-inspection-report.entity';
@@ -16,6 +17,7 @@ export class WarehouseInspectionService {
private readonly dataSource: DataSource,
private readonly inspectionRepository: WarehouseInspectionRepository,
private readonly filesService: FilesService,
private readonly lastMileService: LastMileService,
) {}
/** Create or update the inspection report for an inventory item and sync its inspectionStatus. */
@@ -70,9 +72,37 @@ export class WarehouseInspectionService {
inspectedAt,
});
if (dto.inspectionStatus === 'PASSED') {
await this.markImportPickupReadyAndAcceptLastMile(inventoryId);
}
return report;
}
private async markImportPickupReadyAndAcceptLastMile(inventoryId: string): Promise<void> {
const [row] = await this.dataSource.query(
`SELECT inv.booking_id AS "bookingId",
b.reference AS "bookingReference",
b.trade_direction AS "tradeDirection",
b.last_mile_delivery_address AS "lastMileDeliveryAddress"
FROM freight.warehouse_inventory inv
LEFT JOIN freight.bookings b ON b.id = inv.booking_id
WHERE inv.id = $1 AND inv.deleted_at IS NULL
LIMIT 1`,
[inventoryId],
);
if ((row?.tradeDirection ?? '').toUpperCase() !== 'IMPORT') return;
await this.dataSource.getRepository(WarehouseInventory).update(inventoryId, {
status: 'READY_FOR_PICKUP',
readyForPickupAt: new Date(),
});
if (row.bookingReference && row.lastMileDeliveryAddress) {
await this.lastMileService.acceptBooking(row.bookingReference);
}
}
async findByInventory(inventoryId: string): Promise<WarehouseInspectionReport[]> {
return this.inspectionRepository.findAll({
where: { inventoryId },
@@ -113,6 +143,9 @@ export class WarehouseInspectionService {
await this.dataSource
.getRepository(WarehouseInventory)
.update(report.inventoryId, { inspectionStatus: dto.inspectionStatus });
if (dto.inspectionStatus === 'PASSED') {
await this.markImportPickupReadyAndAcceptLastMile(report.inventoryId);
}
}
return this.findById(id);

View File

@@ -143,6 +143,36 @@ export class WarehouseInventoryController {
return this.inventoryService.importUnloadedQueue();
}
@Get('export/djibouti-arrival-queue')
@ApiOperation({ summary: 'Arrived EXPORT train schedules at Djibouti-side ports, ready for unloading' })
exportDjiboutiArrivalQueue(
@Query('scheduleId') scheduleId?: string,
@Query('destination') destination?: string,
@Query('status') status?: string,
@Query('dateFrom') dateFrom?: string,
@Query('dateTo') dateTo?: string,
) {
return this.scheduling.exportDjiboutiArrivalQueue({
scheduleId,
destination,
status,
dateFrom,
dateTo,
});
}
@Get('export/djibouti-trains/:scheduleId/items')
@ApiOperation({ summary: 'Assigned export bookings/items for an arrived Djibouti-side train' })
exportDjiboutiTrainDetail(@Param('scheduleId', ParseUUIDPipe) scheduleId: string) {
return this.scheduling.exportDjiboutiTrainDetail(scheduleId);
}
@Post('export/auto-unload-at-djibouti')
@ApiOperation({ summary: 'Unload all eligible export items assigned to an arrived Djibouti-side train' })
autoUnloadExportAtDjibouti(@Body() dto: { scheduleId: string; performedBy?: string }) {
return this.inventoryService.autoUnloadExportAtDjibouti(dto.scheduleId, dto.performedBy);
}
@Get('import/pickup-ready-queue')
@ApiOperation({ summary: 'IMPORT inventory that is PICKUP_READY (READY_FOR_PICKUP) awaiting pickup/dispatch' })
importPickupReadyQueue() {

View File

@@ -3,6 +3,9 @@ import { Between, DataSource, EntityManager, FindManyOptions, ILike, LessThanOrE
import { deriveTradeDirection } from '../../common/derive-trade-direction.util';
import { Cargo } from '../cargoes/entities/cargoes.entity';
import { InterchangeDocumentsService } from '../interchange-documents/interchange-documents.service';
import type { InterchangeDocument } from '../interchange-documents/entities/interchange-document.entity';
import { LastMileService } from '../last-mile/last-mile.service';
import { ContractPdfService } from '../../contracts/contract-pdf.service';
import { BulkInspectDto } from './dto/bulk-inspect.dto';
import { BulkReceiveDto } from './dto/bulk-receive.dto';
@@ -235,6 +238,23 @@ export interface AutoUnloadArrivedResult {
results: { bookingId: string; inventoryId?: string; status: string; reason?: string }[];
}
export interface AutoUnloadExportDjiboutiResult {
unloadedCount: number;
skippedCount: number;
failedCount: number;
interchangeDocument?: Pick<InterchangeDocument, 'id' | 'documentNo' | 'status'>;
results: Array<{
bookingId: string;
itemType: 'CONTAINER' | 'CARGO';
itemId?: string | null;
inventoryId?: string;
containerNumber?: string | null;
status: string;
message?: string;
reason?: string;
}>;
}
export interface ImportUnloadedRow {
id: string;
bookingId: string | null;
@@ -264,6 +284,8 @@ export class WarehouseInventoryService {
private readonly invoices: WarehouseInvoiceService,
private readonly inspectionService: WarehouseInspectionService,
private readonly pdfService: ContractPdfService,
private readonly interchangeDocuments: InterchangeDocumentsService,
private readonly lastMileService: LastMileService,
) {}
/**
@@ -869,6 +891,20 @@ export class WarehouseInventoryService {
/** Booking statuses that must never be unloaded into warehouse inventory. */
private readonly IMPORT_UNLOAD_BLOCKED_STATUSES = ['DRAFT', 'REJECTED', 'CANCELLED', 'COMPLETED'];
private readonly EXPORT_DJIBOUTI_UNLOAD_ELIGIBLE_STATUSES = [
'DISPATCHED',
'IN_TRANSIT',
'ARRIVED_AT_DJIBOUTI',
'ARRIVED_AT_PORT',
'ARRIVED_AT_DESTINATION',
];
private isDjiboutiPortDestination(value: string | null | undefined): boolean {
const normalized = (value ?? '').toUpperCase();
return ['DJIBOUTI', 'DORALEH', 'DMP', 'DCT', 'NAGAD'].some((token) =>
normalized.includes(token),
);
}
/**
* Batch 8 — unload all eligible assigned bookings of an ARRIVED import train into UNLOADED state.
@@ -1010,6 +1046,243 @@ export class WarehouseInventoryService {
return result;
}
/**
* Unload eligible EXPORT inventory from an arrived Djibouti-side train.
* This only advances warehouse inventory items assigned to the train and does not write to
* train schedules, wagon assignment, rescheduling, or booking payment state.
*/
async autoUnloadExportAtDjibouti(
scheduleId: string,
performedBy?: string,
): Promise<AutoUnloadExportDjiboutiResult> {
const result: AutoUnloadExportDjiboutiResult = {
unloadedCount: 0,
skippedCount: 0,
failedCount: 0,
results: [],
};
const [schedule] = await this.dataSource.query(
`SELECT ts.id,
ts.status,
oy.country AS "originCountry",
dy.country AS "destinationCountry",
dy.code AS "destinationCode",
dy.name AS "destinationName"
FROM freight.train_schedules ts
LEFT JOIN freight.yards oy ON oy.id = ts.origin_station_id
LEFT JOIN freight.yards dy ON dy.id = ts.destination_station_id
WHERE ts.id = $1 AND ts.deleted_at IS NULL
LIMIT 1`,
[scheduleId],
);
if (!schedule) {
throw new NotFoundException(`Train schedule ${scheduleId} not found`);
}
const direction = deriveTradeDirection(
{ country: schedule.originCountry },
{ country: schedule.destinationCountry },
);
if (direction !== 'EXPORT') {
throw new BadRequestException(`Train schedule route is ${direction}, not EXPORT`);
}
if (!this.isDjiboutiPortDestination(`${schedule.destinationCode ?? ''} ${schedule.destinationName ?? ''}`)) {
throw new BadRequestException('Train schedule destination is not Djibouti / Doraleh / DMP / DCT / Nagad');
}
if (!['ARRIVED', 'ARRIVED_AT_DJIBOUTI'].includes(schedule.status)) {
throw new BadRequestException(`Train schedule is ${schedule.status}, not ARRIVED`);
}
const items: Array<{
bookingId: string;
inventoryId: string | null;
inventoryStatus: string | null;
bookingStatus: string | null;
warehouseId: string | null;
yardId: string | null;
zoneId: string | null;
itemType: 'CONTAINER' | 'CARGO';
itemId: string | null;
containerNumber: string | null;
}> = await this.dataSource.query(
`WITH assigned AS (
SELECT b.id AS booking_id,
b.status AS booking_status,
inv.id AS inventory_id,
inv.status AS inventory_status,
inv.warehouse_id,
inv.yard_id,
inv.zone_id
FROM freight.train_schedule_bookings tsb
JOIN freight.bookings b ON b.id = tsb.booking_id AND b.deleted_at IS NULL
LEFT JOIN freight.warehouse_inventory inv ON inv.booking_id = b.id AND inv.deleted_at IS NULL
WHERE tsb.train_schedule_id = $1 AND tsb.deleted_at IS NULL
)
SELECT a.booking_id AS "bookingId",
a.inventory_id AS "inventoryId",
a.inventory_status AS "inventoryStatus",
a.booking_status AS "bookingStatus",
a.warehouse_id AS "warehouseId",
a.yard_id AS "yardId",
a.zone_id AS "zoneId",
'CONTAINER' AS "itemType",
c.id AS "itemId",
c.container_number AS "containerNumber"
FROM assigned a
JOIN freight.containers c ON c.booking_id = a.booking_id AND c.deleted_at IS NULL
UNION ALL
SELECT a.booking_id AS "bookingId",
a.inventory_id AS "inventoryId",
a.inventory_status AS "inventoryStatus",
a.booking_status AS "bookingStatus",
a.warehouse_id AS "warehouseId",
a.yard_id AS "yardId",
a.zone_id AS "zoneId",
'CARGO' AS "itemType",
cg.id AS "itemId",
NULL AS "containerNumber"
FROM assigned a
JOIN freight.cargoes cg ON cg.booking_id = a.booking_id AND cg.deleted_at IS NULL
UNION ALL
SELECT a.booking_id AS "bookingId",
a.inventory_id AS "inventoryId",
a.inventory_status AS "inventoryStatus",
a.booking_status AS "bookingStatus",
a.warehouse_id AS "warehouseId",
a.yard_id AS "yardId",
a.zone_id AS "zoneId",
'CARGO' AS "itemType",
a.inventory_id AS "itemId",
NULL AS "containerNumber"
FROM assigned a
WHERE NOT EXISTS (SELECT 1 FROM freight.containers c WHERE c.booking_id = a.booking_id AND c.deleted_at IS NULL)
AND NOT EXISTS (SELECT 1 FROM freight.cargoes cg WHERE cg.booking_id = a.booking_id AND cg.deleted_at IS NULL)`,
[scheduleId],
);
const seenInventory = new Set<string>();
const now = new Date();
await this.dataSource.transaction(async (manager) => {
for (const item of items) {
const skip = (reason: string) => {
result.skippedCount += 1;
result.results.push({
bookingId: item.bookingId,
itemType: item.itemType,
itemId: item.itemId,
inventoryId: item.inventoryId ?? undefined,
containerNumber: item.containerNumber,
status: 'SKIPPED',
reason,
});
};
const fail = (reason: string) => {
result.failedCount += 1;
result.results.push({
bookingId: item.bookingId,
itemType: item.itemType,
itemId: item.itemId,
inventoryId: item.inventoryId ?? undefined,
containerNumber: item.containerNumber,
status: 'FAILED',
reason,
});
};
if (!item.inventoryId || !item.warehouseId || !item.yardId || !item.zoneId) {
skip('No warehouse inventory found for assigned export item');
continue;
}
if (seenInventory.has(item.inventoryId)) {
result.results.push({
bookingId: item.bookingId,
itemType: item.itemType,
itemId: item.itemId,
inventoryId: item.inventoryId,
containerNumber: item.containerNumber,
status: 'UNLOADED_AT_DJIBOUTI_PORT',
message: 'Unloaded at Djibouti Port',
});
continue;
}
const currentStatus = item.inventoryStatus ?? item.bookingStatus;
if (!currentStatus || !this.EXPORT_DJIBOUTI_UNLOAD_ELIGIBLE_STATUSES.includes(currentStatus)) {
skip(`Status ${currentStatus ?? 'UNKNOWN'} is not eligible for Djibouti export unloading`);
continue;
}
try {
await manager.getRepository(WarehouseInventory).update(item.inventoryId, {
status: 'UNLOADED_AT_DJIBOUTI_PORT',
unloadedAt: now,
arrivedAt: now,
notes: 'Unloaded at Djibouti Port',
});
await manager.getRepository(WarehouseInventoryMovement).save(
manager.getRepository(WarehouseInventoryMovement).create({
inventoryId: item.inventoryId,
fromWarehouseId: item.warehouseId,
fromYardId: item.yardId,
fromZoneId: item.zoneId,
toWarehouseId: item.warehouseId,
toYardId: item.yardId,
toZoneId: item.zoneId,
remarks: 'EXPORT_UNLOADED_AT_DJIBOUTI_PORT',
movedBy: performedBy ?? null,
movedAt: now,
}),
);
await this.activityLog.record(
{
activityType: 'INVENTORY_UNLOADED',
inventoryId: item.inventoryId,
warehouseId: item.warehouseId,
description: 'EXPORT_UNLOADED_AT_DJIBOUTI_PORT',
performedBy,
},
manager,
);
seenInventory.add(item.inventoryId);
result.unloadedCount += 1;
result.results.push({
bookingId: item.bookingId,
itemType: item.itemType,
itemId: item.itemId,
inventoryId: item.inventoryId,
containerNumber: item.containerNumber,
status: 'UNLOADED_AT_DJIBOUTI_PORT',
message: 'Unloaded at Djibouti Port',
});
} catch (error) {
fail(error instanceof Error ? error.message : String(error));
}
}
});
if (result.unloadedCount > 0) {
const document = await this.interchangeDocuments.generateFromSchedule({
scheduleId,
direction: 'EXPORT',
handoverLocation: schedule.destinationName ?? 'Djibouti Port',
handoverFrom: 'EDR',
handoverTo: 'Djibouti Port Operator',
portOperatorName: 'Doraleh Multipurpose Port',
generatedBy: performedBy,
remarks: 'Generated after export unloading at Djibouti Port',
});
result.interchangeDocument = {
id: document.id,
documentNo: document.documentNo,
status: document.status,
};
}
return result;
}
/**
* Bulk-mark received items inspection PASSED (reusing the inspection service to create a minimal
* report + sync inspectionStatus/inspectedAt). EXPORT items advance straight to READY_FOR_LOADING.
@@ -1078,6 +1351,7 @@ export class WarehouseInventoryService {
manager,
);
});
await this.acceptLastMileIfRequested(item.bookingId);
result.results.push({ inventoryId, status: 'READY_FOR_PICKUP' });
} else {
result.results.push({ inventoryId, status: 'INSPECTED' });
@@ -1090,6 +1364,20 @@ export class WarehouseInventoryService {
// ── Receive ──────────────────────────────────────────────────────────────
private async acceptLastMileIfRequested(bookingId?: string | null): Promise<void> {
if (!bookingId) return;
const [booking] = await this.dataSource.query(
`SELECT reference,
last_mile_delivery_address AS "lastMileDeliveryAddress"
FROM freight.bookings
WHERE id = $1 AND deleted_at IS NULL
LIMIT 1`,
[bookingId],
);
if (!booking?.reference || !booking.lastMileDeliveryAddress) return;
await this.lastMileService.acceptBooking(booking.reference);
}
async receive(dto: ReceiveWarehouseInventoryDto): Promise<WarehouseInventory> {
const weight = Number(dto.weight) || 0;
const volume = Number(dto.volume) || 0;

View File

@@ -14,6 +14,7 @@ import { WarehouseFeeService } from './warehouse-fee.service';
interface GenerateOptions {
confirmZero?: boolean;
performedBy?: string;
billingCurrency?: 'ETB' | 'USD';
}
export interface PayInvoiceDto {
@@ -58,7 +59,8 @@ export class WarehouseInvoiceService {
);
}
const previews = await this.feeService.previewForInventory(inventoryId);
const billingCurrency = opts.billingCurrency === 'ETB' ? 'ETB' : 'USD';
const previews = await this.feeService.previewForInventory(inventoryId, billingCurrency);
const isContainer = (item.freightType ?? '').toUpperCase() === 'CONTAINER';
const items = previews
@@ -98,7 +100,7 @@ export class WarehouseInvoiceService {
const invoiceType: WarehouseInvoiceType =
hasDemurrage && hasStorage ? 'MIXED_WAREHOUSE_FEES' : hasStorage ? 'STORAGE_FEE' : 'DEMURRAGE';
const currency = items[0]?.currency ?? 'USD';
const currency = billingCurrency;
const now = new Date();
const periodEnd = previews[0] ? new Date(previews[0].endDate) : now;

View File

@@ -1,4 +1,4 @@
import { Body, Controller, Delete, Get, HttpCode, Param, ParseUUIDPipe, Patch, Post } from '@nestjs/common';
import { Body, Controller, Delete, Get, HttpCode, Param, ParseUUIDPipe, Patch, Post, Query } from '@nestjs/common';
import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
import {
@@ -79,7 +79,10 @@ export class WarehouseRulesController {
@Get('warehouse-inventory/:id/fee-preview')
@ApiOperation({ summary: 'Preview demurrage + storage fees for an inventory item' })
feePreview(@Param('id', ParseUUIDPipe) id: string) {
return this.feeService.previewForInventory(id);
feePreview(
@Param('id', ParseUUIDPipe) id: string,
@Query('billingCurrency') billingCurrency?: string,
) {
return this.feeService.previewForInventory(id, billingCurrency);
}
}

View File

@@ -1,8 +1,12 @@
import { Module } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';
import { ExchangeModule, ExchangeOptions } from '@edr/api-common';
import { TypeOrmModule } from '@nestjs/typeorm';
import { ContractPdfService } from '../../contracts/contract-pdf.service';
import { FilesModule } from '../files/files.module';
import { InterchangeDocumentsModule } from '../interchange-documents/interchange-documents.module';
import { LastMileModule } from '../last-mile/last-mile.module';
import { WarehouseActivityLog } from './entities/warehouse-activity-log.entity';
import { WarehouseAllocationRule } from './entities/warehouse-allocation-rule.entity';
import { WarehouseFeeInvoice } from './entities/warehouse-fee-invoice.entity';
@@ -65,6 +69,13 @@ import { WarehousesService } from './warehouses.service';
WarehouseFeeInvoiceItem,
]),
FilesModule,
InterchangeDocumentsModule,
LastMileModule,
ExchangeModule.forRootAsync({
inject: [ConfigService],
useFactory: (config: ConfigService): ExchangeOptions =>
config.get<ExchangeOptions>('app.cbeExchange') ?? {},
}),
],
controllers: [
WarehousesController,

View File

@@ -0,0 +1,186 @@
import 'reflect-metadata';
import { config } from 'dotenv';
import { resolve } from 'path';
config({ path: resolve(__dirname, '../../.env') });
import { NestFactory } from '@nestjs/core';
import { DataSource } from 'typeorm';
import { AppModule } from '../app.module';
import { Booking } from '../modules/bookings/entities/booking.entity';
import { Locomotive } from '../modules/locomotives/entities/locomotive.entity';
import { CargoType } from '../modules/rule-engine/entities/cargo-type.entity';
import { ServiceType } from '../modules/rule-engine/entities/service-type.entity';
import { Yard } from '../modules/rule-engine/entities/yard.entity';
import { TrainSchedule } from '../modules/train-schedules/entities/train-schedule.entity';
import { TrainScheduleBooking } from '../modules/train-schedules/entities/train-schedule-booking.entity';
import { TrainSet } from '../modules/train-sets/entities/train-set.entity';
import { WarehouseInventory } from '../modules/warehouses/entities/warehouse-inventory.entity';
import { WarehouseYard } from '../modules/warehouses/entities/warehouse-yard.entity';
import { WarehouseZone } from '../modules/warehouses/entities/warehouse-zone.entity';
import { Warehouse } from '../modules/warehouses/entities/warehouse.entity';
const TRAIN_NUMBER = 'ICD-DEMO-EXP-DJ-01';
const BOOKING_REFS = ['ICD-DEMO-EXP-001', 'ICD-DEMO-EXP-002', 'ICD-DEMO-EXP-003'];
async function main() {
const app = await NestFactory.createApplicationContext(AppModule, {
logger: ['error', 'warn', 'log'],
});
try {
const dataSource = app.get(DataSource);
const yardRepo = dataSource.getRepository(Yard);
const serviceTypeRepo = dataSource.getRepository(ServiceType);
const cargoTypeRepo = dataSource.getRepository(CargoType);
const warehouseRepo = dataSource.getRepository(Warehouse);
const warehouseYardRepo = dataSource.getRepository(WarehouseYard);
const warehouseZoneRepo = dataSource.getRepository(WarehouseZone);
const bookingRepo = dataSource.getRepository(Booking);
const inventoryRepo = dataSource.getRepository(WarehouseInventory);
const locomotiveRepo = dataSource.getRepository(Locomotive);
const trainSetRepo = dataSource.getRepository(TrainSet);
const scheduleRepo = dataSource.getRepository(TrainSchedule);
const scheduleBookingRepo = dataSource.getRepository(TrainScheduleBooking);
const existingSchedule = await scheduleRepo.findOne({ where: { trainNumber: TRAIN_NUMBER } });
if (existingSchedule) {
console.log(`Export Djibouti interchange demo already seeded: ${TRAIN_NUMBER}`);
console.log(`Schedule ID: ${existingSchedule.id}`);
return;
}
const originYard =
(await yardRepo.findOne({ where: { code: 'MOJO' } })) ??
(await yardRepo.findOne({ where: { country: 'Ethiopia' } }));
const destinationYard =
(await yardRepo.findOne({ where: { code: 'DJIB_PORT' } })) ??
(await yardRepo.findOne({ where: { code: 'DJIBOUTI' } })) ??
(await yardRepo.findOne({ where: { country: 'Djibouti' } }));
const serviceType =
(await serviceTypeRepo.findOne({ where: { code: 'RAIL_CONTAINER' } })) ??
(await serviceTypeRepo.findOne({ where: { isActive: true } }));
const cargoType = await cargoTypeRepo.findOne({ where: { isActive: true } });
const warehouse = await warehouseRepo.findOne({ where: { code: 'INDODE_OPEN' } });
const warehouseYard = warehouse
? await warehouseYardRepo.findOne({ where: { warehouseId: warehouse.id } })
: null;
const warehouseZone = warehouseYard
? await warehouseZoneRepo.findOne({ where: { yardId: warehouseYard.id } })
: null;
const missing = [
!originYard ? 'Ethiopian origin yard' : '',
!destinationYard ? 'Djibouti destination yard' : '',
!serviceType ? 'service type' : '',
!warehouse ? 'INDODE_OPEN warehouse' : '',
!warehouseYard ? 'warehouse yard' : '',
!warehouseZone ? 'warehouse zone' : '',
].filter(Boolean);
if (missing.length) {
throw new Error(`Cannot seed export Djibouti interchange demo, missing: ${missing.join(', ')}`);
}
const now = Date.now();
const departure = new Date(now - 6 * 60 * 60 * 1000);
const arrival = new Date(now - 60 * 60 * 1000);
const locomotive =
(await locomotiveRepo.findOne({ where: { code: 'ICD-DEMO-LOCO' } })) ??
(await locomotiveRepo.save(
locomotiveRepo.create({
code: 'ICD-DEMO-LOCO',
name: 'Interchange Demo Locomotive',
maxPullWeightTons: 4000,
}),
));
const trainSet = await trainSetRepo.save(
trainSetRepo.create({
locomotiveId: locomotive.id,
totalWeightTons: 700,
totalLengthMeters: 360,
wagonCount: 12,
status: 'COMPLETED',
}),
);
const schedule = await scheduleRepo.save(
scheduleRepo.create({
trainSetId: trainSet.id,
originStationId: originYard!.id,
destinationStationId: destinationYard!.id,
scheduledDepartureDate: departure,
scheduledArrivalDate: arrival,
actualArrivalAt: arrival,
status: 'ARRIVED' as TrainSchedule['status'],
trainNumber: TRAIN_NUMBER,
}),
);
for (const [index, reference] of BOOKING_REFS.entries()) {
const weight = 5200 + index * 800;
const booking = await bookingRepo.save(
bookingRepo.create({
reference,
originYardId: originYard!.id,
destinationYardId: destinationYard!.id,
serviceTypeId: serviceType!.id,
status: 'IN_TRANSIT',
paymentStatus: 'PAID',
scheduledDate: new Date(),
contractType: 'SPOT',
equipmentReturn: 'TERMINAL',
paymentCurrency: 'ETB',
totalAmount: 0,
isGovernment: false,
tradeDirection: 'EXPORT',
freightType: index % 2 === 0 ? 'CONTAINER' : 'BULK',
cargoTypeId: cargoType?.id ?? null,
cargoFreeText: cargoType ? null : `Export Djibouti interchange demo cargo ${index + 1}`,
cargoTotalWeightVgm: weight,
}),
);
await inventoryRepo.save(
inventoryRepo.create({
warehouseId: warehouse!.id,
yardId: warehouseYard!.id,
zoneId: warehouseZone!.id,
bookingId: booking.id,
quantity: 1,
weight,
status: 'DISPATCHED',
inspectionStatus: 'PASSED',
arrivedAt: new Date(now - 4 * 60 * 60 * 1000),
inspectedAt: new Date(now - 3 * 60 * 60 * 1000),
readyForLoadingAt: new Date(now - 2 * 60 * 60 * 1000),
loadedAt: new Date(now - 90 * 60 * 1000),
dispatchedAt: new Date(now - 70 * 60 * 1000),
notes: '[ICD-DEMO] Eligible for Djibouti export unload and interchange generation',
}),
);
await scheduleBookingRepo.save(
scheduleBookingRepo.create({
trainScheduleId: schedule.id,
bookingId: booking.id,
}),
);
}
console.log('Export Djibouti interchange demo seeded.');
console.log(`Train number: ${TRAIN_NUMBER}`);
console.log(`Schedule ID: ${schedule.id}`);
console.log('Open Djibouti Unloading, click "Auto Unload Export Items", then check Interchange Documents.');
} finally {
await app.close();
}
}
main().catch((error) => {
console.error('Export Djibouti interchange demo seed failed:', error);
process.exit(1);
});

File diff suppressed because it is too large Load Diff

View File

@@ -4,6 +4,7 @@ import {
ClipboardCheck,
PackageCheck,
PackagePlus,
PackageOpen,
Send,
Truck,
Warehouse,
@@ -17,12 +18,16 @@ import { formatDate, humanizeEnum } from './options';
const activityIcon: Record<ActivityType, React.ReactNode> = {
INVENTORY_RECEIVED: <PackagePlus size={14} />,
INVENTORY_UNLOADED: <PackageOpen size={14} />,
INVENTORY_STORED: <Warehouse size={14} />,
INVENTORY_MOVED: <ArrowRightLeft size={14} />,
INVENTORY_RESERVED: <ClipboardCheck size={14} />,
READY_FOR_LOADING: <PackageCheck size={14} />,
INVENTORY_LOADED: <Truck size={14} />,
INVENTORY_DISPATCHED: <Send size={14} />,
READY_FOR_PICKUP: <PackageCheck size={14} />,
INVENTORY_RELEASED: <Send size={14} />,
INVENTORY_DELIVERED: <PackageCheck size={14} />,
};
export function ActivityTimeline({ inventoryId }: { inventoryId: string }) {

View File

@@ -1,4 +1,5 @@
import { Badge, Button, Card, Divider, Group, Loader, Modal, Stack, Text } from '@mantine/core';
import { useState } from 'react';
import { Badge, Button, Card, Divider, Group, Loader, Modal, SegmentedControl, Stack, Text } from '@mantine/core';
import { CalendarClock, Coins, DoorOpen, FileText } from 'lucide-react';
import { useMutation, useQuery } from '@tanstack/react-query';
@@ -91,10 +92,11 @@ function Row({ label, value }: { label: string; value: string }) {
/** Batch 5 fee preview + Batch 6 invoice generation / gate clearance for an inventory item. */
export function FeePreviewModal({ opened, onClose, inventoryId }: FeePreviewModalProps) {
const { toast } = useToast();
const [billingCurrency, setBillingCurrency] = useState<'ETB' | 'USD'>('USD');
const enabledId = opened ? inventoryId ?? undefined : undefined;
const { data, isLoading } = useQuery(
api.warehouses.feePreview.queryOptions({
input: { inventoryId: enabledId ?? '' },
input: { inventoryId: enabledId ?? '', billingCurrency },
enabled: Boolean(enabledId),
}),
);
@@ -108,21 +110,22 @@ export function FeePreviewModal({ opened, onClose, inventoryId }: FeePreviewModa
const gateClear = useMutation(api.warehouses.gateClearance.mutationOptions());
const activeInvoice = (invoices ?? []).find((i) => i.status !== 'CANCELLED');
const totalPreviewAmount = (data ?? []).reduce((sum, fee) => sum + Number(fee.amount || 0), 0);
const handleGenerate = async (confirmZero = false) => {
const handleGenerate = async () => {
if (!inventoryId) return;
if (totalPreviewAmount <= 0) {
toast({
title: 'No fee to invoice',
description: 'The item is still within the configured free days, or no active fee rule matched it.',
});
return;
}
try {
const inv = await generate.mutateAsync({ inventoryId, confirmZero });
const inv = await generate.mutateAsync({ inventoryId, billingCurrency });
toast({ title: 'Invoice generated', description: `${inv.invoiceNumber} - ${money(inv.totalAmount, inv.currency)}` });
} catch (error) {
const msg = extractErrorMessage(error);
if (/no payable warehouse fee/i.test(msg)) {
if (window.confirm('No payable warehouse fee found. Create a zero-amount invoice anyway?')) {
handleGenerate(true);
}
return;
}
toast({ variant: 'destructive', title: 'Generate failed', description: msg });
toast({ variant: 'destructive', title: 'Generate failed', description: extractErrorMessage(error) });
}
};
@@ -172,6 +175,22 @@ export function FeePreviewModal({ opened, onClose, inventoryId }: FeePreviewModa
<Divider label="Invoice & Release" labelPosition="left" />
<Group justify="space-between" align="center">
<Text size="sm" fw={600}>
Billing currency
</Text>
<SegmentedControl
size="xs"
value={billingCurrency}
onChange={(value) => setBillingCurrency(value as 'ETB' | 'USD')}
data={[
{ value: 'USD', label: 'USD' },
{ value: 'ETB', label: 'Birr' },
]}
disabled={Boolean(activeInvoice)}
/>
</Group>
{activeInvoice ? (
<Group justify="space-between">
<Group gap="xs">
@@ -191,7 +210,7 @@ export function FeePreviewModal({ opened, onClose, inventoryId }: FeePreviewModa
color="orange"
leftSection={<FileText size={16} />}
loading={generate.isPending}
onClick={() => handleGenerate(false)}
onClick={handleGenerate}
>
Generate Fee Invoice
</Button>

View File

@@ -0,0 +1,128 @@
import {
Badge,
Group,
Loader,
SimpleGrid,
Stack,
Table,
Text,
} from '@mantine/core';
import type { ReactNode } from 'react';
import { useInterchangeDocument } from '@/hooks/useInterchangeDocuments';
import type { InterchangeDocumentStatus } from '@/types/interchangeDocument';
import { formatDate, formatNumber } from './options';
const statusColor: Record<InterchangeDocumentStatus, string> = {
DRAFT: 'gray',
GENERATED: 'blue',
ACKNOWLEDGED: 'green',
DISPUTED: 'red',
CANCELLED: 'gray',
};
function DetailField({ label, value }: { label: string; value: ReactNode }) {
return (
<Stack gap={2}>
<Text size="xs" c="dimmed">
{label}
</Text>
<Text size="sm" fw={600}>
{value || '-'}
</Text>
</Stack>
);
}
export function InterchangeDocumentDetailPanel({ id }: { id: string }) {
const { data: document, isLoading } = useInterchangeDocument(id);
if (isLoading) {
return (
<Group justify="center" py="xl">
<Loader />
</Group>
);
}
if (!document) return null;
const items = document.items ?? [];
return (
<Stack gap="lg">
<SimpleGrid cols={{ base: 1, sm: 2, lg: 4 }}>
<DetailField label="Document No" value={document.documentNo} />
<DetailField label="Direction" value={document.direction} />
<DetailField label="Schedule" value={document.scheduleId?.slice(0, 8)} />
<DetailField label="Train No" value={document.trainNo} />
<DetailField label="Handover Location" value={document.handoverLocation} />
<DetailField label="Handover From" value={document.handoverFrom} />
<DetailField label="Handover To" value={document.handoverTo} />
<DetailField
label="Status"
value={
<Badge variant="light" color={statusColor[document.status]}>
{document.status}
</Badge>
}
/>
<DetailField label="Generated At" value={formatDate(document.generatedAt)} />
<DetailField label="Acknowledged At" value={formatDate(document.acknowledgedAt)} />
<DetailField label="Customs Ref" value={document.customsReference} />
<DetailField label="Manifest Ref" value={document.manifestReference} />
</SimpleGrid>
<Table.ScrollContainer minWidth={980}>
<Table striped highlightOnHover verticalSpacing="sm">
<Table.Thead>
<Table.Tr>
<Table.Th>Booking Reference</Table.Th>
<Table.Th>Item Type</Table.Th>
<Table.Th>Container Number</Table.Th>
<Table.Th>Seal Number</Table.Th>
<Table.Th>Cargo Type</Table.Th>
<Table.Th>Weight</Table.Th>
<Table.Th>Quantity</Table.Th>
<Table.Th>Wagon Number</Table.Th>
<Table.Th>Condition</Table.Th>
<Table.Th>Damage Description</Table.Th>
<Table.Th>Remarks</Table.Th>
</Table.Tr>
</Table.Thead>
<Table.Tbody>
{items.map((item) => (
<Table.Tr key={item.id}>
<Table.Td>{item.bookingReference ?? item.bookingId?.slice(0, 8) ?? '-'}</Table.Td>
<Table.Td>{item.itemType}</Table.Td>
<Table.Td>{item.containerNumber ?? '-'}</Table.Td>
<Table.Td>{item.sealNumber ?? '-'}</Table.Td>
<Table.Td>{item.cargoType ?? item.cargoDescription ?? '-'}</Table.Td>
<Table.Td>{formatNumber(item.weight)}</Table.Td>
<Table.Td>{formatNumber(item.quantity)}</Table.Td>
<Table.Td>{item.wagonNumber ?? '-'}</Table.Td>
<Table.Td>
<Badge
variant="light"
color={
item.conditionStatus === 'GOOD'
? 'green'
: item.conditionStatus === 'UNKNOWN'
? 'gray'
: 'orange'
}
size="sm"
>
{item.conditionStatus}
</Badge>
</Table.Td>
<Table.Td>{item.damageDescription ?? '-'}</Table.Td>
<Table.Td>{item.remarks ?? '-'}</Table.Td>
</Table.Tr>
))}
</Table.Tbody>
</Table>
</Table.ScrollContainer>
</Stack>
);
}

View File

@@ -6,6 +6,7 @@ import { useMutation } from '@tanstack/react-query';
import { api } from '@/services/api';
import { useToast } from '@/hooks/use-toast';
import { lastMileService } from '@/services/last-mile.service';
import { warehouseService } from '@/services/warehouse.service';
import type { InventoryAction, WarehouseInventoryItem } from '@/types/warehouse';
import { DeliverInventoryModal } from './DeliverInventoryModal';
@@ -50,6 +51,9 @@ export function InventoryWorkbench({ items, isLoading, onLastMile }: InventoryWo
api.warehouses.markReadyForPickup.mutationOptions(),
);
const dispatchMutation = useMutation(api.warehouses.dispatch.mutationOptions());
const lastMileMutation = useMutation({
mutationFn: (bookingReference: string) => lastMileService.accept(bookingReference).then((r) => r.data),
});
const inspectMutation = useMutation(
api.warehouses.bulkMarkInspected.mutationOptions(),
);
@@ -116,6 +120,34 @@ export function InventoryWorkbench({ items, isLoading, onLastMile }: InventoryWo
}
};
const acceptLastMile = async (item: WarehouseInventoryItem) => {
const reference = item.booking?.reference;
if (!reference) {
toast({
variant: 'destructive',
title: 'Last mile failed',
description: 'Booking reference is missing for this inventory item.',
});
return;
}
setBusyId(item.id);
try {
const record = await lastMileMutation.mutateAsync(reference);
toast({
title: 'Last mile accepted',
description: `${reference} moved to last-mile queue (${record.status.replace(/_/g, ' ')}).`,
});
} catch (error) {
toast({
variant: 'destructive',
title: 'Last mile failed',
description: extractErrorMessage(error),
});
} finally {
setBusyId(null);
}
};
const storeInventory = async (item: WarehouseInventoryItem) => {
setBusyId(item.id);
try {
@@ -195,7 +227,7 @@ export function InventoryWorkbench({ items, isLoading, onLastMile }: InventoryWo
onInspect={setInspectItem}
onFeePreview={setFeeItem}
onReleaseDocument={downloadReleaseDocument}
onLastMile={onLastMile}
onLastMile={onLastMile ? acceptLastMile : undefined}
selectedIds={selected}
onToggleSelect={toggleSelect}
onToggleSelectAll={toggleSelectAll}

View File

@@ -212,11 +212,7 @@ export function WarehouseInventoryTable({
)}
{onReleaseDocument && item.releaseDate && (
<Tooltip label="View release exit paper" withArrow>
<ActionIcon
variant="subtle"
color="orange"
onClick={() => onReleaseDocument(item)}
>
<ActionIcon variant="subtle" color="orange" onClick={() => onReleaseDocument(item)}>
<FileText size={16} />
</ActionIcon>
</Tooltip>

View File

@@ -54,6 +54,7 @@ export function WarehouseStatusBadge({ status }: { status: WarehouseStatus }) {
const inventoryStatusColor: Record<InventoryStatus, string> = {
UNLOADED: "indigo",
UNLOADED_AT_DJIBOUTI_PORT: "edr-green",
RECEIVED: "yellow",
STORED: "blue",
RESERVED: "grape",

View File

@@ -331,6 +331,10 @@ export const URL_CONSTANTS = {
IMPORT_AUTO_UNLOAD_ARRIVED: '/warehouse-inventory/import/auto-unload-arrived-bookings',
IMPORT_UNLOADED_QUEUE: '/warehouse-inventory/import/unloaded-queue',
IMPORT_PICKUP_READY_QUEUE: '/warehouse-inventory/import/pickup-ready-queue',
EXPORT_DJIBOUTI_ARRIVAL_QUEUE: '/warehouse-inventory/export/djibouti-arrival-queue',
EXPORT_DJIBOUTI_TRAIN_ITEMS: (scheduleId: string) =>
`/warehouse-inventory/export/djibouti-trains/${scheduleId}/items`,
EXPORT_AUTO_UNLOAD_AT_DJIBOUTI: '/warehouse-inventory/export/auto-unload-at-djibouti',
},
WAREHOUSE_LOADINGS: {
@@ -362,6 +366,15 @@ export const URL_CONSTANTS = {
GATE_CLEARANCE: (inventoryId: string) => `/warehouse-inventory/${inventoryId}/gate-clearance`,
},
INTERCHANGE_DOCUMENTS: {
BASE: '/interchange-documents',
BY_ID: (id: string) => `/interchange-documents/${id}`,
GENERATE_FROM_SCHEDULE: '/interchange-documents/generate-from-schedule',
ACKNOWLEDGE: (id: string) => `/interchange-documents/${id}/acknowledge`,
DISPUTE: (id: string) => `/interchange-documents/${id}/dispute`,
CANCEL: (id: string) => `/interchange-documents/${id}/cancel`,
},
VEHICLES: {
BASE: '/vehicles',
BY_ID: (id: string) => `/vehicles/${id}`,

View File

@@ -0,0 +1,76 @@
import { useMutation, useQuery, useQueryClient } from '@tanstack/react-query';
import { interchangeDocumentsService } from '@/services/interchange-documents.service';
import type {
GenerateInterchangeDocumentPayload,
InterchangeDocumentFilter,
} from '@/types/interchangeDocument';
export const interchangeDocumentKeys = {
all: ['interchange-documents'] as const,
list: (filter?: InterchangeDocumentFilter) =>
['interchange-documents', 'list', filter ?? {}] as const,
detail: (id?: string) => ['interchange-documents', 'detail', id ?? ''] as const,
};
export function useInterchangeDocuments(filter?: InterchangeDocumentFilter, enabled = true) {
return useQuery({
queryKey: interchangeDocumentKeys.list(filter),
queryFn: () => interchangeDocumentsService.list(filter).then((r) => r.data),
enabled,
});
}
export function useInterchangeDocument(id?: string) {
return useQuery({
queryKey: interchangeDocumentKeys.detail(id),
queryFn: () => interchangeDocumentsService.getById(id as string).then((r) => r.data),
enabled: Boolean(id),
});
}
function useInterchangeInvalidation() {
const qc = useQueryClient();
return () => {
qc.invalidateQueries({ queryKey: interchangeDocumentKeys.all });
qc.invalidateQueries({ queryKey: ['warehouse-inventory', 'export-djibouti-arrival-queue'] });
};
}
export function useGenerateInterchangeDocument() {
const onSuccess = useInterchangeInvalidation();
return useMutation({
mutationFn: (payload: GenerateInterchangeDocumentPayload) =>
interchangeDocumentsService.generateFromSchedule(payload),
onSuccess,
});
}
export function useAcknowledgeInterchangeDocument() {
const onSuccess = useInterchangeInvalidation();
return useMutation({
mutationFn: (args: { id: string; acknowledgedBy: string; remarks?: string }) =>
interchangeDocumentsService.acknowledge(args.id, {
acknowledgedBy: args.acknowledgedBy,
remarks: args.remarks,
}),
onSuccess,
});
}
export function useDisputeInterchangeDocument() {
const onSuccess = useInterchangeInvalidation();
return useMutation({
mutationFn: (args: { id: string; remarks: string }) =>
interchangeDocumentsService.dispute(args.id, { remarks: args.remarks }),
onSuccess,
});
}
export function useCancelInterchangeDocument() {
const onSuccess = useInterchangeInvalidation();
return useMutation({
mutationFn: (id: string) => interchangeDocumentsService.cancel(id),
onSuccess,
});
}

View File

@@ -282,6 +282,38 @@ export function useImportTrainItems(scheduleId?: string) {
export const useAutoUnloadArrivedBookings = () =>
useInventoryMutation((scheduleId: string) => warehouseService.autoUnloadArrivedBookings(scheduleId));
/** Arrived EXPORT trains at Djibouti-side ports. Read-only. */
export function useExportDjiboutiArrivalQueue(enabled = true) {
return useQuery({
queryKey: ['warehouse-inventory', 'export-djibouti-arrival-queue'],
queryFn: () => warehouseService.exportDjiboutiArrivalQueue().then((r) => r.data),
enabled,
});
}
/** Assigned export bookings/items for a Djibouti-side arrived export train. Read-only. */
export function useExportDjiboutiTrainItems(scheduleId?: string) {
return useQuery({
queryKey: ['warehouse-inventory', 'export-djibouti-train-items', scheduleId],
queryFn: () => warehouseService.exportDjiboutiTrainItems(scheduleId as string).then((r) => r.data),
enabled: Boolean(scheduleId),
});
}
/** Unload eligible export items assigned to an arrived Djibouti-side train. */
export const useAutoUnloadExportAtDjibouti = () => {
const qc = useQueryClient();
return useMutation({
mutationFn: (scheduleId: string) => warehouseService.autoUnloadExportAtDjibouti(scheduleId),
onSuccess: () => {
qc.invalidateQueries({ queryKey: ['warehouse-inventory'] });
qc.invalidateQueries({ queryKey: ['warehouse-loadings'] });
qc.invalidateQueries({ queryKey: warehouseKeys.all });
qc.invalidateQueries({ queryKey: ['interchange-documents'] });
},
});
};
/** IMPORT inventory in the Unloaded Queue (UNLOADED / destination inspection). Read-only. */
export function useImportUnloadedQueue(enabled = true) {
return useQuery({
@@ -468,10 +500,10 @@ export const useUpdateFeeRule = () =>
export const useDeleteFeeRule = () =>
useRuleMutation((id: string) => warehouseService.deleteFeeRule(id), ['warehouse-fee-rules']);
export function useFeePreview(inventoryId?: string) {
export function useFeePreview(inventoryId?: string, billingCurrency: 'ETB' | 'USD' = 'USD') {
return useQuery({
queryKey: ['warehouse-inventory', inventoryId, 'fee-preview'],
queryFn: () => warehouseService.feePreview(inventoryId as string).then((r) => r.data),
queryKey: ['warehouse-inventory', inventoryId, 'fee-preview', billingCurrency],
queryFn: () => warehouseService.feePreview(inventoryId as string, billingCurrency).then((r) => r.data),
enabled: Boolean(inventoryId),
});
}
@@ -512,8 +544,15 @@ function useInvoiceInvalidation() {
export function useGenerateInvoice() {
const onSuccess = useInvoiceInvalidation();
return useMutation({
mutationFn: ({ inventoryId, confirmZero }: { inventoryId: string; confirmZero?: boolean }) =>
warehouseService.generateInvoice(inventoryId, confirmZero).then((r) => r.data),
mutationFn: ({
inventoryId,
confirmZero,
billingCurrency,
}: {
inventoryId: string;
confirmZero?: boolean;
billingCurrency?: 'ETB' | 'USD';
}) => warehouseService.generateInvoice(inventoryId, confirmZero, billingCurrency).then((r) => r.data),
onSuccess,
});
}

View File

@@ -12,7 +12,6 @@ import {
} from '@mantine/core';
import { ChevronDown, ChevronRight, PackageOpen, Truck } from 'lucide-react';
import { PageHeader } from '@/components/page';
import Breadcrumbs from '@/components/ui/Breadcrumbs';
import {
VisualEmptyState,
@@ -79,17 +78,13 @@ function ImportTrainDetailRows({ scheduleId }: { scheduleId: string }) {
{item.bookingReference ?? item.bookingId.slice(0, 8)}
</Text>
</Table.Td>
<Table.Td>{item.customerName ?? '-'}</Table.Td>
<Table.Td>{item.containerNumber ?? '-'}</Table.Td>
<Table.Td>{item.cargoType ?? '-'}</Table.Td>
<Table.Td>{item.customerName ?? ''}</Table.Td>
<Table.Td>{item.containerNumber ?? ''}</Table.Td>
<Table.Td>{item.cargoType ?? ''}</Table.Td>
<Table.Td>{formatNumber(item.weight)}</Table.Td>
<Table.Td>{formatDate(item.arrivalTime)}</Table.Td>
<Table.Td>
<Badge
variant="light"
color={item.currentStatus === 'UNLOADED' ? 'green' : 'orange'}
size="sm"
>
<Badge variant="light" color={item.currentStatus === 'UNLOADED' ? 'green' : 'orange'} size="sm">
{item.currentStatus ?? 'PENDING'}
</Badge>
</Table.Td>
@@ -112,9 +107,7 @@ export default function ArrivalQueuePage() {
const unloadTrain = async (train: ImportTrain) => {
setBusyScheduleId(train.scheduleId);
try {
const res = (await autoUnload.mutateAsync(train.scheduleId)) as {
data: AutoUnloadArrivedResult;
};
const res = (await autoUnload.mutateAsync(train.scheduleId)) as { data: AutoUnloadArrivedResult };
const result = res.data;
const details = [
result.skippedCount ? `${result.skippedCount} skipped` : '',
@@ -143,11 +136,6 @@ export default function ArrivalQueuePage() {
<Breadcrumbs items={[{ label: 'Arrival queue' }]} />
<Stack gap="lg" mt="sm">
<PageHeader
title="Arrival / Unloading Queue"
subtitle="Arrived import trains ready to unload assigned bookings into warehouse inventory."
/>
<WarehouseHero
variant="container"
secondaryVariant="warehouse"
@@ -199,16 +187,16 @@ export default function ArrivalQueuePage() {
<Table.Td>
<Stack gap={0}>
<Text size="sm" fw={700}>
{train.trainNumber ?? '-'}
{train.trainNumber ?? ''}
</Text>
<Text size="xs" c="dimmed">
{train.scheduleId.slice(0, 8)}
</Text>
</Stack>
</Table.Td>
<Table.Td>{train.route ?? '-'}</Table.Td>
<Table.Td>{train.origin ?? '-'}</Table.Td>
<Table.Td>{train.destination ?? '-'}</Table.Td>
<Table.Td>{train.route ?? ''}</Table.Td>
<Table.Td>{train.origin ?? ''}</Table.Td>
<Table.Td>{train.destination ?? ''}</Table.Td>
<Table.Td>
<Text size="xs">{formatDate(train.arrivalTime)}</Text>
</Table.Td>
@@ -225,9 +213,7 @@ export default function ArrivalQueuePage() {
<Button
size="compact-xs"
variant="light"
leftSection={
isOpen ? <ChevronDown size={14} /> : <ChevronRight size={14} />
}
leftSection={isOpen ? <ChevronDown size={14} /> : <ChevronRight size={14} />}
onClick={() => setOpenScheduleId(isOpen ? null : train.scheduleId)}
>
Open
@@ -235,13 +221,7 @@ export default function ArrivalQueuePage() {
<Button
size="compact-xs"
color="orange"
leftSection={
busyScheduleId === train.scheduleId ? (
<PackageOpen size={14} />
) : (
<Truck size={14} />
)
}
leftSection={busyScheduleId === train.scheduleId ? <PackageOpen size={14} /> : <Truck size={14} />}
loading={busyScheduleId === train.scheduleId}
onClick={() => unloadTrain(train)}
>

View File

@@ -0,0 +1,420 @@
import { Fragment, useState } from 'react';
import {
Badge,
Button,
Card,
Container,
Group,
Loader,
Modal,
Stack,
Table,
Tabs,
Text,
} from '@mantine/core';
import { useNavigate } from 'react-router-dom';
import { ChevronDown, ChevronRight, Eye, FileText, History, PackageOpen, Truck } from 'lucide-react';
import { PageHeader } from '@/components/page';
import Breadcrumbs from '@/components/ui/Breadcrumbs';
import {
ActivityTimeline,
InventoryMovementHistoryTable,
VisualEmptyState,
WarehouseHero,
formatDate,
formatNumber,
} from '@/components/warehouses';
import {
useAutoUnloadExportAtDjibouti,
useExportDjiboutiArrivalQueue,
useExportDjiboutiTrainItems,
} from '@/hooks/useWarehouses';
import {
useGenerateInterchangeDocument,
useInterchangeDocuments,
} from '@/hooks/useInterchangeDocuments';
import { useToast } from '@/hooks/use-toast';
import type {
AutoUnloadExportDjiboutiResult,
ExportTrain,
ExportTrainItem,
} from '@/types/warehouse';
const getErrorMessage = (error: unknown) => {
if (error && typeof error === 'object' && 'response' in error) {
const response = (error as { response?: { data?: { message?: unknown } } }).response;
const message = response?.data?.message;
if (Array.isArray(message)) return message.join(', ');
if (typeof message === 'string') return message;
}
return error instanceof Error ? error.message : undefined;
};
const statusColor = (status?: string | null) => {
if (status === 'UNLOADED_AT_DJIBOUTI_PORT') return 'green';
if (status === 'ARRIVED_AT_DJIBOUTI' || status === 'ARRIVED') return 'blue';
if (status === 'FAILED') return 'red';
if (status === 'SKIPPED') return 'orange';
return 'gray';
};
const statusLabel = (status?: string | null) =>
status === 'UNLOADED_AT_DJIBOUTI_PORT'
? 'Unloaded at Djibouti Port'
: (status ?? 'PENDING').replace(/_/g, ' ');
function ExportTrainDetailRows({
scheduleId,
onOpenHistory,
}: {
scheduleId: string;
onOpenHistory: (inventoryId: string) => void;
}) {
const navigate = useNavigate();
const { data: items = [], isLoading } = useExportDjiboutiTrainItems(scheduleId);
if (isLoading) {
return (
<Group justify="center" py="md">
<Loader size="sm" />
</Group>
);
}
if (items.length === 0) {
return (
<Text c="dimmed" ta="center" py="md" size="sm">
No assigned export bookings found for this train.
</Text>
);
}
return (
<Table.ScrollContainer minWidth={1320}>
<Table highlightOnHover verticalSpacing="xs">
<Table.Thead>
<Table.Tr>
<Table.Th>Booking ID</Table.Th>
<Table.Th>Booking Reference</Table.Th>
<Table.Th>Customer ID</Table.Th>
<Table.Th>Customer Name</Table.Th>
<Table.Th>Item Type</Table.Th>
<Table.Th>Container Number</Table.Th>
<Table.Th>Cargo Type</Table.Th>
<Table.Th>Weight</Table.Th>
<Table.Th>Origin</Table.Th>
<Table.Th>Destination</Table.Th>
<Table.Th>Train Schedule</Table.Th>
<Table.Th>Arrival Time at Djibouti</Table.Th>
<Table.Th>Current Status</Table.Th>
<Table.Th ta="right">Actions</Table.Th>
</Table.Tr>
</Table.Thead>
<Table.Tbody>
{items.map((item: ExportTrainItem) => (
<Table.Tr key={`${item.bookingId}-${item.itemType}-${item.itemId ?? item.inventoryId ?? 'item'}`}>
<Table.Td>{item.bookingId.slice(0, 8)}</Table.Td>
<Table.Td>
<Text size="sm" fw={600}>
{item.bookingReference ?? '-'}
</Text>
</Table.Td>
<Table.Td>{item.customerId?.slice(0, 8) ?? '-'}</Table.Td>
<Table.Td>{item.customerName ?? '-'}</Table.Td>
<Table.Td>{item.itemType}</Table.Td>
<Table.Td>{item.containerNumber ?? '-'}</Table.Td>
<Table.Td>{item.cargoType ?? '-'}</Table.Td>
<Table.Td>{formatNumber(item.weight)}</Table.Td>
<Table.Td>{item.origin ?? '-'}</Table.Td>
<Table.Td>{item.destination ?? '-'}</Table.Td>
<Table.Td>{item.trainSchedule ?? '-'}</Table.Td>
<Table.Td>{formatDate(item.arrivalTime)}</Table.Td>
<Table.Td>
<Badge variant="light" color={statusColor(item.currentStatus)} size="sm">
{statusLabel(item.currentStatus)}
</Badge>
</Table.Td>
<Table.Td>
<Group gap="xs" justify="flex-end" wrap="nowrap">
<Button
size="compact-xs"
variant="light"
leftSection={<Eye size={14} />}
onClick={() => navigate(`/dashboard/booking-requests/${item.bookingId}`)}
>
View
</Button>
<Button
size="compact-xs"
variant="light"
color="gray"
leftSection={<History size={14} />}
disabled={!item.inventoryId}
onClick={() => item.inventoryId && onOpenHistory(item.inventoryId)}
>
Movement
</Button>
</Group>
</Table.Td>
</Table.Tr>
))}
</Table.Tbody>
</Table>
</Table.ScrollContainer>
);
}
export default function ExportDjiboutiUnloadingQueuePage() {
const navigate = useNavigate();
const { toast } = useToast();
const { data: trains = [], isLoading } = useExportDjiboutiArrivalQueue();
const { data: interchangeDocuments = [] } = useInterchangeDocuments({ direction: 'EXPORT' });
const autoUnload = useAutoUnloadExportAtDjibouti();
const generateInterchange = useGenerateInterchangeDocument();
const [openScheduleId, setOpenScheduleId] = useState<string | null>(null);
const [busyScheduleId, setBusyScheduleId] = useState<string | null>(null);
const [historyInventoryId, setHistoryInventoryId] = useState<string | null>(null);
const interchangeBySchedule = new Map(
interchangeDocuments
.filter((doc) => doc.scheduleId && doc.status !== 'CANCELLED')
.map((doc) => [doc.scheduleId as string, doc]),
);
const unloadTrain = async (train: ExportTrain) => {
setBusyScheduleId(train.scheduleId);
try {
const res = (await autoUnload.mutateAsync(train.scheduleId)) as {
data: AutoUnloadExportDjiboutiResult;
};
const result = res.data;
const details = [
result.skippedCount ? `${result.skippedCount} skipped` : '',
result.failedCount ? `${result.failedCount} failed` : '',
result.interchangeDocument
? `Interchange document ${result.interchangeDocument.documentNo} generated`
: '',
]
.filter(Boolean)
.join(', ');
toast({
title: `${result.unloadedCount} export item(s) unloaded`,
description: details || `${train.trainNumber ?? 'Train'} unloaded at Djibouti Port.`,
});
} catch (error) {
toast({
variant: 'destructive',
title: 'Auto unload failed',
description: getErrorMessage(error),
});
} finally {
setBusyScheduleId(null);
}
};
const generateInterchangeDocument = async (train: ExportTrain) => {
setBusyScheduleId(train.scheduleId);
try {
const res = await generateInterchange.mutateAsync({
scheduleId: train.scheduleId,
direction: 'EXPORT',
handoverLocation: train.destination ?? 'Djibouti Port',
handoverFrom: 'EDR',
handoverTo: 'Djibouti Port Operator',
portOperatorName: 'Doraleh Multipurpose Port',
remarks: 'Generated after export unloading at Djibouti Port',
});
toast({
title: 'Interchange document generated',
description: res.data.documentNo,
});
navigate('/dashboard/interchange-documents');
} catch (error) {
toast({
variant: 'destructive',
title: 'Interchange document generation failed',
description: getErrorMessage(error),
});
} finally {
setBusyScheduleId(null);
}
};
return (
<Container size="xxl" py="lg">
<Breadcrumbs items={[{ label: 'Djibouti Arrival / Unloading Queue' }]} />
<Stack gap="lg" mt="sm">
<PageHeader
title="Djibouti Arrival / Unloading Queue"
subtitle="Arrived export trains at Djibouti-side destinations ready for unloading."
/>
<WarehouseHero
variant="train"
secondaryVariant="container"
title="Export Unloading at Djibouti Port"
subtitle="Review arrived export trains and unload eligible assigned export items."
/>
<Card withBorder radius="md" padding="lg">
<Group justify="space-between" mb="md">
<Text fw={600}>{trains.length} arrived export train(s)</Text>
<Text size="sm" c="dimmed">
Open a train to review assigned export items, then auto unload it.
</Text>
</Group>
{isLoading ? (
<Group justify="center" py="xl">
<Loader />
</Group>
) : trains.length === 0 ? (
<VisualEmptyState
variant="train"
title="No arrived export trains"
description="Export trains appear here after arriving at Djibouti, Doraleh, DMP, DCT, or Nagad."
/>
) : (
<Table.ScrollContainer minWidth={1180}>
<Table verticalSpacing="sm" highlightOnHover striped>
<Table.Thead>
<Table.Tr>
<Table.Th>Train Schedule ID</Table.Th>
<Table.Th>Train Number</Table.Th>
<Table.Th>Route</Table.Th>
<Table.Th>Origin</Table.Th>
<Table.Th>Destination</Table.Th>
<Table.Th>Departure Time</Table.Th>
<Table.Th>Arrival Time</Table.Th>
<Table.Th ta="center">Total Bookings</Table.Th>
<Table.Th ta="center">Total Containers</Table.Th>
<Table.Th ta="center">Total Cargoes</Table.Th>
<Table.Th>Current Status</Table.Th>
<Table.Th ta="right">Actions</Table.Th>
</Table.Tr>
</Table.Thead>
<Table.Tbody>
{trains.map((train: ExportTrain) => {
const isOpen = openScheduleId === train.scheduleId;
const interchangeDocument = interchangeBySchedule.get(train.scheduleId);
return (
<Fragment key={train.scheduleId}>
<Table.Tr>
<Table.Td>{train.scheduleId.slice(0, 8)}</Table.Td>
<Table.Td>
<Text size="sm" fw={700}>
{train.trainNumber ?? '-'}
</Text>
</Table.Td>
<Table.Td>{train.route ?? '-'}</Table.Td>
<Table.Td>{train.origin ?? '-'}</Table.Td>
<Table.Td>{train.destination ?? '-'}</Table.Td>
<Table.Td>{formatDate(train.departureTime)}</Table.Td>
<Table.Td>{formatDate(train.arrivalTime)}</Table.Td>
<Table.Td ta="center">{train.totalBookings}</Table.Td>
<Table.Td ta="center">{train.totalContainers}</Table.Td>
<Table.Td ta="center">{train.totalCargoes}</Table.Td>
<Table.Td>
<Badge variant="light" color={statusColor(train.status)} size="sm">
{statusLabel(train.status)}
</Badge>
</Table.Td>
<Table.Td>
<Group gap="xs" justify="flex-end" wrap="nowrap">
<Button
size="compact-xs"
variant="light"
leftSection={
isOpen ? <ChevronDown size={14} /> : <ChevronRight size={14} />
}
onClick={() => setOpenScheduleId(isOpen ? null : train.scheduleId)}
>
Open
</Button>
<Button
size="compact-xs"
color="green"
leftSection={
busyScheduleId === train.scheduleId ? (
<PackageOpen size={14} />
) : (
<Truck size={14} />
)
}
loading={busyScheduleId === train.scheduleId}
onClick={() => unloadTrain(train)}
>
Auto Unload Export Items
</Button>
{interchangeDocument ? (
<Button
size="compact-xs"
variant="light"
color="blue"
leftSection={<Eye size={14} />}
onClick={() => navigate('/dashboard/interchange-documents')}
>
View Document
</Button>
) : (
<Button
size="compact-xs"
variant="light"
color="green"
leftSection={<FileText size={14} />}
loading={busyScheduleId === train.scheduleId && generateInterchange.isPending}
onClick={() => generateInterchangeDocument(train)}
>
Generate Interchange Document
</Button>
)}
</Group>
</Table.Td>
</Table.Tr>
{isOpen && (
<Table.Tr>
<Table.Td colSpan={12} bg="var(--mantine-color-gray-0)">
<ExportTrainDetailRows
scheduleId={train.scheduleId}
onOpenHistory={setHistoryInventoryId}
/>
</Table.Td>
</Table.Tr>
)}
</Fragment>
);
})}
</Table.Tbody>
</Table>
</Table.ScrollContainer>
)}
</Card>
</Stack>
<Modal
opened={Boolean(historyInventoryId)}
onClose={() => setHistoryInventoryId(null)}
title="Movement history"
size="xl"
>
{historyInventoryId ? (
<Tabs defaultValue="activity">
<Tabs.List>
<Tabs.Tab value="activity">Activity</Tabs.Tab>
<Tabs.Tab value="movements">Movements</Tabs.Tab>
</Tabs.List>
<Tabs.Panel value="activity" pt="md">
<ActivityTimeline inventoryId={historyInventoryId} />
</Tabs.Panel>
<Tabs.Panel value="movements" pt="md">
<InventoryMovementHistoryTable inventoryId={historyInventoryId} />
</Tabs.Panel>
</Tabs>
) : null}
</Modal>
</Container>
);
}

View File

@@ -0,0 +1,315 @@
import { useMemo, useState } from 'react';
import {
Badge,
Button,
Card,
Group,
Loader,
Modal,
SimpleGrid,
Stack,
Table,
Text,
TextInput,
} from '@mantine/core';
import { CheckCircle2, Eye, FileText, Search, XCircle } from 'lucide-react';
import type { ReactNode } from 'react';
import { PageContainer, PageHeader } from '@/components/page';
import { VisualEmptyState, formatDate, formatNumber } from '@/components/warehouses';
import {
useAcknowledgeInterchangeDocument,
useCancelInterchangeDocument,
useDisputeInterchangeDocument,
useInterchangeDocument,
useInterchangeDocuments,
} from '@/hooks/useInterchangeDocuments';
import { useToast } from '@/hooks/use-toast';
import type { InterchangeDocument, InterchangeDocumentStatus } from '@/types/interchangeDocument';
const statusColor: Record<InterchangeDocumentStatus, string> = {
DRAFT: 'gray',
GENERATED: 'blue',
ACKNOWLEDGED: 'green',
DISPUTED: 'red',
CANCELLED: 'gray',
};
const getErrorMessage = (error: unknown) => {
if (error && typeof error === 'object' && 'response' in error) {
const response = (error as { response?: { data?: { message?: unknown } } }).response;
const message = response?.data?.message;
if (Array.isArray(message)) return message.join(', ');
if (typeof message === 'string') return message;
}
return error instanceof Error ? error.message : undefined;
};
function DetailField({ label, value }: { label: string; value: ReactNode }) {
return (
<Stack gap={2}>
<Text size="xs" c="dimmed">
{label}
</Text>
<Text size="sm" fw={600}>
{value || '-'}
</Text>
</Stack>
);
}
function InterchangeDocumentDetail({ id }: { id: string }) {
const { data: document, isLoading } = useInterchangeDocument(id);
if (isLoading) {
return (
<Group justify="center" py="xl">
<Loader />
</Group>
);
}
if (!document) return null;
const items = document.items ?? [];
return (
<Stack gap="lg">
<SimpleGrid cols={{ base: 1, sm: 2, lg: 4 }}>
<DetailField label="Document No" value={document.documentNo} />
<DetailField label="Direction" value={document.direction} />
<DetailField label="Schedule" value={document.scheduleId?.slice(0, 8)} />
<DetailField label="Train No" value={document.trainNo} />
<DetailField label="Handover Location" value={document.handoverLocation} />
<DetailField label="Handover From" value={document.handoverFrom} />
<DetailField label="Handover To" value={document.handoverTo} />
<DetailField
label="Status"
value={
<Badge variant="light" color={statusColor[document.status]}>
{document.status}
</Badge>
}
/>
<DetailField label="Generated At" value={formatDate(document.generatedAt)} />
<DetailField label="Acknowledged At" value={formatDate(document.acknowledgedAt)} />
<DetailField label="Customs Ref" value={document.customsReference} />
<DetailField label="Manifest Ref" value={document.manifestReference} />
</SimpleGrid>
<Table.ScrollContainer minWidth={980}>
<Table striped highlightOnHover verticalSpacing="sm">
<Table.Thead>
<Table.Tr>
<Table.Th>Booking Reference</Table.Th>
<Table.Th>Item Type</Table.Th>
<Table.Th>Container Number</Table.Th>
<Table.Th>Seal Number</Table.Th>
<Table.Th>Cargo Type</Table.Th>
<Table.Th>Weight</Table.Th>
<Table.Th>Quantity</Table.Th>
<Table.Th>Wagon Number</Table.Th>
<Table.Th>Condition</Table.Th>
<Table.Th>Damage Description</Table.Th>
<Table.Th>Remarks</Table.Th>
</Table.Tr>
</Table.Thead>
<Table.Tbody>
{items.map((item) => (
<Table.Tr key={item.id}>
<Table.Td>{item.bookingReference ?? item.bookingId?.slice(0, 8) ?? '-'}</Table.Td>
<Table.Td>{item.itemType}</Table.Td>
<Table.Td>{item.containerNumber ?? '-'}</Table.Td>
<Table.Td>{item.sealNumber ?? '-'}</Table.Td>
<Table.Td>{item.cargoType ?? item.cargoDescription ?? '-'}</Table.Td>
<Table.Td>{formatNumber(item.weight)}</Table.Td>
<Table.Td>{formatNumber(item.quantity)}</Table.Td>
<Table.Td>{item.wagonNumber ?? '-'}</Table.Td>
<Table.Td>
<Badge
variant="light"
color={item.conditionStatus === 'GOOD' ? 'green' : item.conditionStatus === 'UNKNOWN' ? 'gray' : 'orange'}
size="sm"
>
{item.conditionStatus}
</Badge>
</Table.Td>
<Table.Td>{item.damageDescription ?? '-'}</Table.Td>
<Table.Td>{item.remarks ?? '-'}</Table.Td>
</Table.Tr>
))}
</Table.Tbody>
</Table>
</Table.ScrollContainer>
</Stack>
);
}
export default function InterchangeDocumentsPage() {
const { toast } = useToast();
const [search, setSearch] = useState('');
const [viewId, setViewId] = useState<string | null>(null);
const filter = useMemo(() => ({ search: search.trim() || undefined }), [search]);
const { data: documents = [], isLoading } = useInterchangeDocuments(filter);
const acknowledge = useAcknowledgeInterchangeDocument();
const dispute = useDisputeInterchangeDocument();
const cancel = useCancelInterchangeDocument();
const run = async (fn: () => Promise<unknown>, title: string) => {
try {
await fn();
toast({ title });
} catch (error) {
toast({ variant: 'destructive', title: 'Action failed', description: getErrorMessage(error) });
}
};
const acknowledgeDocument = (document: InterchangeDocument) => {
const acknowledgedBy = window.prompt('Acknowledged by');
if (!acknowledgedBy) return;
run(
() => acknowledge.mutateAsync({ id: document.id, acknowledgedBy }),
'Interchange document acknowledged',
);
};
const disputeDocument = (document: InterchangeDocument) => {
const remarks = window.prompt('Dispute reason');
if (!remarks) return;
run(() => dispute.mutateAsync({ id: document.id, remarks }), 'Interchange document disputed');
};
return (
<PageContainer>
<PageHeader
title="Interchange Documents"
subtitle="Official freight handover documents with booking, container and cargo line items."
/>
<Card withBorder radius="md" padding="lg">
<Group justify="space-between" mb="md">
<Text fw={600}>{documents.length} document(s)</Text>
<TextInput
w={{ base: '100%', sm: 320 }}
leftSection={<Search size={16} />}
placeholder="Search documents"
value={search}
onChange={(event) => setSearch(event.currentTarget.value)}
/>
</Group>
{isLoading ? (
<Group justify="center" py="xl">
<Loader />
</Group>
) : documents.length === 0 ? (
<VisualEmptyState
variant="container"
title="No interchange documents"
description="Generated freight handover documents appear here."
/>
) : (
<Table.ScrollContainer minWidth={1060}>
<Table striped highlightOnHover verticalSpacing="sm">
<Table.Thead>
<Table.Tr>
<Table.Th>Document No</Table.Th>
<Table.Th>Direction</Table.Th>
<Table.Th>Train No / Schedule</Table.Th>
<Table.Th>Route</Table.Th>
<Table.Th>Handover Location</Table.Th>
<Table.Th>Handover From</Table.Th>
<Table.Th>Handover To</Table.Th>
<Table.Th>Status</Table.Th>
<Table.Th>Generated At</Table.Th>
<Table.Th ta="right">Actions</Table.Th>
</Table.Tr>
</Table.Thead>
<Table.Tbody>
{documents.map((document) => (
<Table.Tr key={document.id}>
<Table.Td>
<Text fw={700} size="sm">
{document.documentNo}
</Text>
</Table.Td>
<Table.Td>{document.direction}</Table.Td>
<Table.Td>
<Stack gap={0}>
<Text size="sm">{document.trainNo ?? '-'}</Text>
<Text size="xs" c="dimmed">
{document.scheduleId?.slice(0, 8) ?? '-'}
</Text>
</Stack>
</Table.Td>
<Table.Td>{document.routeId?.slice(0, 8) ?? '-'}</Table.Td>
<Table.Td>{document.handoverLocation}</Table.Td>
<Table.Td>{document.handoverFrom}</Table.Td>
<Table.Td>{document.handoverTo}</Table.Td>
<Table.Td>
<Badge variant="light" color={statusColor[document.status]}>
{document.status}
</Badge>
</Table.Td>
<Table.Td>{formatDate(document.generatedAt)}</Table.Td>
<Table.Td>
<Group gap="xs" justify="flex-end" wrap="nowrap">
<Button
size="compact-xs"
variant="light"
leftSection={<Eye size={14} />}
onClick={() => setViewId(document.id)}
>
View
</Button>
{document.status !== 'ACKNOWLEDGED' && document.status !== 'CANCELLED' ? (
<Button
size="compact-xs"
color="green"
variant="light"
leftSection={<CheckCircle2 size={14} />}
onClick={() => acknowledgeDocument(document)}
>
Acknowledge
</Button>
) : null}
{document.status !== 'CANCELLED' ? (
<Button
size="compact-xs"
color="orange"
variant="light"
leftSection={<FileText size={14} />}
onClick={() => disputeDocument(document)}
>
Dispute
</Button>
) : null}
{document.status === 'DRAFT' || document.status === 'GENERATED' ? (
<Button
size="compact-xs"
color="red"
variant="light"
leftSection={<XCircle size={14} />}
onClick={() =>
run(() => cancel.mutateAsync(document.id), 'Interchange document cancelled')
}
>
Cancel
</Button>
) : null}
</Group>
</Table.Td>
</Table.Tr>
))}
</Table.Tbody>
</Table>
</Table.ScrollContainer>
)}
</Card>
<Modal opened={Boolean(viewId)} onClose={() => setViewId(null)} title="Interchange Document" size="90%">
{viewId ? <InterchangeDocumentDetail id={viewId} /> : null}
</Modal>
</PageContainer>
);
}

View File

@@ -749,12 +749,12 @@ export const api = {
() => ["warehouse-fee-rules"],
),
feePreview: endpoint<{ inventoryId: string }, FeePreview[]>(
feePreview: endpoint<{ inventoryId: string; billingCurrency?: 'ETB' | 'USD' }, FeePreview[]>(
"warehouse-inventory",
"fee-preview",
({ inventoryId }) =>
warehouseService.feePreview(inventoryId).then((r) => r.data),
({ inventoryId }) => ["warehouse-inventory", inventoryId, "fee-preview"],
({ inventoryId, billingCurrency }) =>
warehouseService.feePreview(inventoryId, billingCurrency).then((r) => r.data),
({ inventoryId, billingCurrency }) => ["warehouse-inventory", inventoryId, "fee-preview", billingCurrency ?? 'USD'],
),
invoices: endpoint<{ filter?: WarehouseInvoiceFilter }, WarehouseFeeInvoice[]>(
@@ -1045,14 +1045,14 @@ export const api = {
// ── Invoices ───────────────────────────────────────────────────────────
generateInvoice: endpoint<
{ inventoryId: string; confirmZero?: boolean },
{ inventoryId: string; confirmZero?: boolean; billingCurrency?: 'ETB' | 'USD' },
WarehouseFeeInvoice
>(
"warehouse-fee-invoices",
"generate",
({ inventoryId, confirmZero }) =>
({ inventoryId, confirmZero, billingCurrency }) =>
warehouseService
.generateInvoice(inventoryId, confirmZero)
.generateInvoice(inventoryId, confirmZero, billingCurrency)
.then((r) => r.data),
undefined,
() => [["warehouse-fee-invoices"], ["warehouse-inventory"]],
@@ -1980,4 +1980,4 @@ export const api = {
({ range }) => overviewService.getDashboard(range),
),
},
};
};

View File

@@ -0,0 +1,33 @@
import { api as apiClient } from '../auth/http';
import { URL_CONSTANTS } from '@/constants/URLS';
import type {
GenerateInterchangeDocumentPayload,
InterchangeDocument,
InterchangeDocumentFilter,
} from '@/types/interchangeDocument';
const cleanParams = (params: object) =>
Object.fromEntries(
Object.entries(params).filter(([, value]) => value !== undefined && value !== '' && value !== null),
);
export const interchangeDocumentsService = {
list: (filter?: InterchangeDocumentFilter) =>
apiClient.get<InterchangeDocument[]>(URL_CONSTANTS.INTERCHANGE_DOCUMENTS.BASE, {
params: cleanParams(filter ?? {}),
}),
getById: (id: string) =>
apiClient.get<InterchangeDocument>(URL_CONSTANTS.INTERCHANGE_DOCUMENTS.BY_ID(id)),
generateFromSchedule: (payload: GenerateInterchangeDocumentPayload) =>
apiClient.post<InterchangeDocument>(
URL_CONSTANTS.INTERCHANGE_DOCUMENTS.GENERATE_FROM_SCHEDULE,
payload,
),
acknowledge: (id: string, payload: { acknowledgedBy: string; remarks?: string }) =>
apiClient.patch<InterchangeDocument>(URL_CONSTANTS.INTERCHANGE_DOCUMENTS.ACKNOWLEDGE(id), payload),
dispute: (id: string, payload: { remarks: string }) =>
apiClient.patch<InterchangeDocument>(URL_CONSTANTS.INTERCHANGE_DOCUMENTS.DISPUTE(id), payload),
cancel: (id: string) =>
apiClient.patch<InterchangeDocument>(URL_CONSTANTS.INTERCHANGE_DOCUMENTS.CANCEL(id), {}),
};

View File

@@ -63,5 +63,5 @@ export const lastMileService = {
update: (id: string, data: { status?: LastMileApiStatus; vehicleId?: string | null }) =>
api.patch<LastMileRecord>(LM.BY_ID(id), data),
accept: (bookingReference: string) =>
api.post<LastMileRecord>(LM.ACCEPT(bookingReference)),
api.post<LastMileRecord>(LM.ACCEPT(encodeURIComponent(bookingReference))),
};

View File

@@ -37,6 +37,9 @@ import type {
BulkInspectResult,
ReadyToLoadRow,
BulkDispatchResult,
AutoUnloadExportDjiboutiResult,
ExportTrain,
ExportTrainItem,
ImportTrain,
ImportTrainItem,
ImportUnloadedItem,
@@ -167,6 +170,17 @@ export const warehouseService = {
apiClient.get<ImportUnloadedItem[]>(URL_CONSTANTS.WAREHOUSE_INVENTORY.IMPORT_UNLOADED_QUEUE),
importPickupReadyQueue: () =>
apiClient.get<ImportUnloadedItem[]>(URL_CONSTANTS.WAREHOUSE_INVENTORY.IMPORT_PICKUP_READY_QUEUE),
exportDjiboutiArrivalQueue: () =>
apiClient.get<ExportTrain[]>(URL_CONSTANTS.WAREHOUSE_INVENTORY.EXPORT_DJIBOUTI_ARRIVAL_QUEUE),
exportDjiboutiTrainItems: (scheduleId: string) =>
apiClient.get<ExportTrainItem[]>(
URL_CONSTANTS.WAREHOUSE_INVENTORY.EXPORT_DJIBOUTI_TRAIN_ITEMS(scheduleId),
),
autoUnloadExportAtDjibouti: (scheduleId: string) =>
apiClient.post<AutoUnloadExportDjiboutiResult>(
URL_CONSTANTS.WAREHOUSE_INVENTORY.EXPORT_AUTO_UNLOAD_AT_DJIBOUTI,
{ scheduleId },
),
move: (id: string, payload: MoveInventoryPayload) =>
apiClient.post<WarehouseInventoryItem>(URL_CONSTANTS.WAREHOUSE_INVENTORY.MOVE(id), payload),
movements: (id: string) =>
@@ -237,8 +251,10 @@ export const warehouseService = {
updateFeeRule: (id: string, payload: Partial<SaveFeeRulePayload>) =>
apiClient.patch<FeeRule>(URL_CONSTANTS.WAREHOUSE_RULES.FEES_BY_ID(id), payload),
deleteFeeRule: (id: string) => apiClient.delete(URL_CONSTANTS.WAREHOUSE_RULES.FEES_BY_ID(id)),
feePreview: (inventoryId: string) =>
apiClient.get<FeePreview[]>(URL_CONSTANTS.WAREHOUSE_RULES.FEE_PREVIEW(inventoryId)),
feePreview: (inventoryId: string, billingCurrency?: 'ETB' | 'USD') =>
apiClient.get<FeePreview[]>(URL_CONSTANTS.WAREHOUSE_RULES.FEE_PREVIEW(inventoryId), {
params: cleanParams({ billingCurrency }),
}),
// ── Batch 6: Warehouse fee invoices ────────────────────────────────────────
listInvoices: (filter?: WarehouseInvoiceFilter) =>
@@ -251,8 +267,11 @@ export const warehouseService = {
apiClient.get<WarehouseFeeInvoice[]>(URL_CONSTANTS.WAREHOUSE_INVOICES.FOR_INVENTORY(inventoryId)),
invoicesForBooking: (bookingId: string) =>
apiClient.get<WarehouseFeeInvoice[]>(URL_CONSTANTS.WAREHOUSE_INVOICES.FOR_BOOKING(bookingId)),
generateInvoice: (inventoryId: string, confirmZero = false) =>
apiClient.post<WarehouseFeeInvoice>(URL_CONSTANTS.WAREHOUSE_INVOICES.GENERATE(inventoryId), { confirmZero }),
generateInvoice: (inventoryId: string, confirmZero = false, billingCurrency?: 'ETB' | 'USD') =>
apiClient.post<WarehouseFeeInvoice>(URL_CONSTANTS.WAREHOUSE_INVOICES.GENERATE(inventoryId), {
confirmZero,
billingCurrency,
}),
cancelInvoice: (id: string) =>
apiClient.patch<WarehouseFeeInvoice>(URL_CONSTANTS.WAREHOUSE_INVOICES.CANCEL(id)),
payInvoice: (id: string, payload: PayInvoicePayload) =>

View File

@@ -0,0 +1,90 @@
export type InterchangeDirection = 'IMPORT' | 'EXPORT';
export type InterchangeDocumentStatus =
| 'DRAFT'
| 'GENERATED'
| 'ACKNOWLEDGED'
| 'DISPUTED'
| 'CANCELLED';
export type InterchangeItemType = 'CONTAINER' | 'CARGO';
export type InterchangeConditionStatus =
| 'GOOD'
| 'DAMAGED'
| 'SHORTAGE'
| 'EXCESS'
| 'HOLD'
| 'UNKNOWN';
export interface InterchangeDocumentItem {
id: string;
interchangeDocumentId: string;
bookingId: string | null;
bookingReference: string | null;
itemType: InterchangeItemType;
bookingContainerId: string | null;
bookingCargoId: string | null;
containerNumber: string | null;
sealNumber: string | null;
cargoId: string | null;
cargoType: string | null;
cargoDescription: string | null;
weight: number | null;
quantity: number | null;
packageCount: number | null;
wagonNumber: string | null;
conditionStatus: InterchangeConditionStatus;
damageDescription: string | null;
remarks: string | null;
}
export interface InterchangeDocument {
id: string;
documentNo: string;
direction: InterchangeDirection;
scheduleId: string | null;
trainNo: string | null;
routeId: string | null;
originFacilityId: string | null;
destinationFacilityId: string | null;
handoverLocation: string;
handoverFrom: string;
handoverTo: string;
operatorName: string | null;
portOperatorName: string | null;
shippingLineName: string | null;
customsReference: string | null;
manifestReference: string | null;
status: InterchangeDocumentStatus;
generatedAt: string | null;
acknowledgedAt: string | null;
generatedBy: string | null;
acknowledgedBy: string | null;
remarks: string | null;
createdAt: string;
updatedAt: string;
items?: InterchangeDocumentItem[];
}
export interface InterchangeDocumentFilter {
direction?: InterchangeDirection;
status?: InterchangeDocumentStatus;
scheduleId?: string;
documentNo?: string;
dateFrom?: string;
dateTo?: string;
search?: string;
}
export interface GenerateInterchangeDocumentPayload {
scheduleId: string;
direction: InterchangeDirection;
handoverLocation: string;
handoverFrom: string;
handoverTo: string;
operatorName?: string;
portOperatorName?: string;
shippingLineName?: string;
customsReference?: string;
manifestReference?: string;
generatedBy?: string;
remarks?: string;
}

View File

@@ -24,6 +24,7 @@ export type WarehouseZoneType = (typeof WAREHOUSE_ZONE_TYPES)[number];
export const INVENTORY_STATUSES = [
'UNLOADED',
'UNLOADED_AT_DJIBOUTI_PORT',
'RECEIVED',
'STORED',
'RESERVED',
@@ -56,6 +57,7 @@ export type InventoryAction =
*/
export const INVENTORY_NEXT_ACTION: Record<InventoryStatus, InventoryAction | null> = {
UNLOADED: 'store',
UNLOADED_AT_DJIBOUTI_PORT: null,
RECEIVED: 'store',
STORED: 'reserve',
RESERVED: 'ready-for-loading',
@@ -236,12 +238,16 @@ export interface InventoryMovement {
export const ACTIVITY_TYPES = [
'INVENTORY_RECEIVED',
'INVENTORY_UNLOADED',
'INVENTORY_STORED',
'INVENTORY_MOVED',
'INVENTORY_RESERVED',
'READY_FOR_LOADING',
'INVENTORY_LOADED',
'INVENTORY_DISPATCHED',
'READY_FOR_PICKUP',
'INVENTORY_RELEASED',
'INVENTORY_DELIVERED',
] as const;
export type ActivityType = (typeof ACTIVITY_TYPES)[number];
@@ -419,6 +425,7 @@ export interface ImportTrain {
route: string | null;
origin: string | null;
destination: string | null;
departureTime?: string | null;
arrivalTime: string | null;
totalBookings: number;
totalContainers: number;
@@ -433,6 +440,49 @@ export interface AutoUnloadArrivedResult {
results: { bookingId: string; inventoryId?: string; status: string; reason?: string }[];
}
export type ExportTrain = ImportTrain & {
departureTime: string | null;
};
export interface ExportTrainItem {
bookingId: string;
bookingReference: string | null;
customerId: string | null;
customerName: string | null;
itemType: 'CONTAINER' | 'CARGO';
itemId: string | null;
inventoryId: string | null;
containerNumber: string | null;
cargoType: string | null;
weight: number | null;
origin: string | null;
destination: string | null;
trainSchedule: string | null;
arrivalTime: string | null;
currentStatus: string | null;
}
export interface AutoUnloadExportDjiboutiResult {
unloadedCount: number;
skippedCount: number;
failedCount: number;
interchangeDocument?: {
id: string;
documentNo: string;
status: string;
};
results: Array<{
bookingId: string;
itemType: 'CONTAINER' | 'CARGO';
itemId?: string | null;
inventoryId?: string;
containerNumber?: string | null;
status: string;
message?: string;
reason?: string;
}>;
}
export interface ImportUnloadedItem {
id: string;
bookingId: string | null;
@@ -615,6 +665,8 @@ export interface FeePreview {
freeDays: number;
ratePerDay: number;
currency: string;
ruleCurrency?: string | null;
billingCurrency?: string;
startDate: string | null;
endDate: string;
endIsOpen: boolean;