Tria/edr-platform
1
0
Fork 0
mirror of https://github.com/Tria-plc/edr-platform.git synced 2026-08-26 18:42:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1043 from Tria-plc/edrmiles

Browse Source 
generate and send notifcation for Carriage Acceptance sheet
This commit is contained in:
Hagernesh Tadesse
2026-07-31 14:45:49 +03:00
committed by GitHub
parent 7a30fd6aee 2759960d7e
commit 58c0d87caf
1 changed files with 35 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
apps/edr-freight-api/src/modules/warehouses/warehouse-inventory.service.ts
View File

@@ -1682,6 +1682,7 @@ export class WarehouseInventoryService {
for (const pending of pendingNotifications) {
void this.notifyOwnerInventoryReceived(pending.owner);
void this.notifyTruckAssignmentNeeded(pending.booking, pending.bookingId);
if (dto.direction === 'EXPORT') void this.notifyCarriageAcceptanceReady(pending.bookingId);
}
return result;
@@ -2809,6 +2810,10 @@ export class WarehouseInventoryService {
return saved.id;
});
if (dto.bookingId && bookingDirection === 'EXPORT') {
void this.notifyCarriageAcceptanceReady(dto.bookingId);
}
return this.findById(id);
}
@@ -5978,6 +5983,36 @@ export class WarehouseInventoryService {
return booking ?? {};
}
/**
* Tell the customer their export carriage acceptance sheet is ready to
* download from the portal. Export acceptance happens at the warehouse gate
* (see BookingsService.carriageAcceptanceSheet) — the sheet is generatable
* as soon as the cargo is received, no wagon allocation required, so this
* fires right after receive, not at marshalling.
*/
private async notifyCarriageAcceptanceReady(bookingId: string): Promise<void> {
try {
const [b]: Array<{ companyId: string | null; reference: string }> = await this.dataSource.query(
`SELECT company_id AS "companyId", reference FROM freight.bookings WHERE id = $1 AND deleted_at IS NULL`,
[bookingId],
);
if (!b?.companyId) return;
const body = `Your carriage acceptance sheet for booking ${b.reference} is ready to download from the portal.`;
await this.inbox.notify({
recipients: { companyId: b.companyId },
audience: NotificationAudience.PORTAL,
type: NotificationType.DOCUMENT_ACTION,
title: 'Carriage acceptance sheet ready',
body,
link: `/bookings/${bookingId}`,
data: { bookingId, reference: b.reference },
});
await sendCompanyChannels(this.dataSource, this.notifications, b.companyId, body);
} catch (err) {
this.logger.warn(`Carriage acceptance ready notify failed for ${bookingId}: ${(err as Error).message}`);
}
}
private async notifyOwnerInventoryReceived(params: {
phone?: string | null;
ownerName?: string | null;