diff --git a/paperless-backend/src/agrarmonitor/agrarmonitor-polling.service.ts b/paperless-backend/src/agrarmonitor/agrarmonitor-polling.service.ts index 890f00f..1859bbb 100644 --- a/paperless-backend/src/agrarmonitor/agrarmonitor-polling.service.ts +++ b/paperless-backend/src/agrarmonitor/agrarmonitor-polling.service.ts @@ -105,9 +105,8 @@ export class AgrarmonitorPollingService implements OnModuleInit { )) { try { const lieferantennummer = (customer['lieferantennummer'] as string) ?? ''; - const searchName = `(${lieferantennummer})`; const displayName = this.buildCustomerName(customer, lieferantennummer); - const existing = await this.paperlessService.getCorrespondentByName(searchName); + const existing = await this.paperlessService.getCorrespondentByName(displayName); if (!existing) { await this.paperlessService.addCorrespondent({ name: displayName, @@ -153,6 +152,14 @@ export class AgrarmonitorPollingService implements OnModuleInit { try { amResults = await amClient.eingangsrechnungenLivesearch(interneBelegnummer); } catch (err: unknown) { + const status = (err as any)?.response?.status; + if (status === 401 || status === 403) { + this.agrarmonitorService.clearClient(); + const msg = `Session abgelaufen (${status}) — Polling abgebrochen, nächster Lauf meldet sich neu an`; + this.logger.warn(msg); + result.errors.push(msg); + break; + } const msg = `${interneBelegnummer}: Livesearch-Fehler`; this.logger.error(`${msg}: ${err instanceof Error ? err.message : err}`); result.errors.push(msg); diff --git a/paperless-backend/src/agrarmonitor/agrarmonitor.service.ts b/paperless-backend/src/agrarmonitor/agrarmonitor.service.ts index bff9a17..1fdb49c 100644 --- a/paperless-backend/src/agrarmonitor/agrarmonitor.service.ts +++ b/paperless-backend/src/agrarmonitor/agrarmonitor.service.ts @@ -56,6 +56,10 @@ export class AgrarmonitorService { return this.client; } + clearClient(): void { + this.client = null; + } + async getStatus(): Promise { try { const client = await this.getClient();