✨ Formulaire de modification d'une candidature

packages/applications/document-builder/src/candidature/attestation/buildCertificate.ts

@@ -109,9 +109,12 @@ const mapToCertificateData = ({
       potentielId,
 
       nomProjet: candidature.nomProjet,
-      adresseProjet: [candidature.localité.adresse1, candidature.localité.adresse2]
+      adresseProjet: [
+        ...candidature.localité.adresse1.split('\n'),
+        ...(candidature.localité.adresse2?.split('\n') ?? []),
+      ]
         .filter(Boolean)
-        .join('\n'),
+        .join(', '),
       codePostalProjet: candidature.localité.codePostal,
       communeProjet: candidature.localité.commune,
 

packages/applications/legacy/src/config/eventHandlers/project.eventHandlers.ts

@@ -4,6 +4,7 @@ import { LegacyModificationImported } from '../../modules/modificationRequest';
 import {
   handleLegacyModificationImported,
   handleProjectRawDataImported,
+  handleProjectRawDataCorrected,
   makeOnDélaiAccordé,
   makeOnDélaiAccordéCorrigé,
   ProjectRawDataImported,
@@ -13,12 +14,14 @@ import {
   makeOnDateMiseEnServiceTransmise,
   makeOnDemandeComplèteRaccordementTransmise,
   DemandeComplèteRaccordementTransmise,
+  ProjectRawDataCorrected,
 } from '../../modules/project';
 import { subscribeToRedis } from '../eventBus.config';
 import { eventStore } from '../eventStore.config';
 import { findProjectByIdentifiers, récupérerDétailDossiersRaccordements } from '../queries.config';
 import { getProjectAppelOffre } from '../queryProjectAO.config';
 import { projectRepo } from '../repos.config';
+import { getUserById } from '../queries.config';
 
 eventStore.subscribe(
   ProjectRawDataImported.type,
@@ -29,6 +32,14 @@ eventStore.subscribe(
   }),
 );
 
+eventStore.subscribe(
+  ProjectRawDataCorrected.type,
+  handleProjectRawDataCorrected({
+    projectRepo,
+    getUserById,
+  }),
+);
+
 eventStore.subscribe(
   LegacyModificationImported.type,
   handleLegacyModificationImported({

packages/applications/legacy/src/infra/sequelize/queries/project/getLegacyProjetByIdentifiantProjet.ts

@@ -1,12 +1,13 @@
 import { IdentifiantProjet } from '@potentiel-domain/common';
 import { Project } from '../../projectionsNext';
+import { PlainType } from '@potentiel-domain/core';
 
 export const getLegacyProjetByIdentifiantProjet = async ({
   appelOffre,
   période,
   famille,
   numéroCRE,
-}: Pick<IdentifiantProjet.ValueType, 'appelOffre' | 'famille' | 'numéroCRE' | 'période'>) => {
+}: PlainType<IdentifiantProjet.ValueType>) => {
   try {
     const projet = await Project.findOne({
       where: {

packages/applications/legacy/src/modules/project/eventHandlers/handleProjectRawDataCorrected.ts

@@ -0,0 +1,27 @@
+import { err } from 'neverthrow';
+import { TransactionalRepository, UniqueEntityID } from '../../../core/domain';
+import { ProjectRawDataCorrected } from '../events';
+import { Project } from '../Project';
+import { GetUserById } from '../../../config';
+
+// This exists only to access Project repo from within the ssr=>legacy saga.
+export const handleProjectRawDataCorrected =
+  (deps: { projectRepo: TransactionalRepository<Project>; getUserById: GetUserById }) =>
+  async (event: ProjectRawDataCorrected) => {
+    const { projectRepo, getUserById } = deps;
+
+    const { correctedBy, correctedData, projectId } = event.payload;
+    return projectRepo.transaction(
+      new UniqueEntityID(projectId || undefined),
+      (project) =>
+        getUserById(correctedBy).map((user) => {
+          if (user) {
+            return project.correctData(user, correctedData);
+          }
+          return err('no user found');
+        }),
+      {
+        acceptNew: true,
+      },
+    );
+  };

packages/applications/legacy/src/modules/project/eventHandlers/index.ts

@@ -1,5 +1,6 @@
 export * from './handleLegacyModificationImported';
 export * from './handleProjectRawDataImported';
+export * from './handleProjectRawDataCorrected';
 export * from './onDélaiAccordé';
 export * from './onCahierDesChargesChoisi';
 export * from './onDélaiAccordéCorrigé';

packages/applications/legacy/src/modules/project/events/ProjectRawDataCorrected.ts

@@ -0,0 +1,41 @@
+import { BaseDomainEvent, DomainEvent } from '../../../core/domain';
+
+import { Actionnariat } from '../types';
+
+export interface ProjectRawDataCorrectedPayload {
+  projectId: string;
+  correctedBy: string;
+  correctedData: {
+    nomProjet: string;
+    territoireProjet: string;
+    puissance: number;
+    prixReference: number;
+    evaluationCarbone: number;
+    note: number;
+    nomCandidat: string;
+    nomRepresentantLegal: string;
+    email: string;
+    adresseProjet: string;
+    codePostalProjet: string;
+    communeProjet: string;
+    engagementFournitureDePuissanceAlaPointe: boolean;
+    isFinancementParticipatif: boolean;
+    isInvestissementParticipatif: boolean;
+    motifsElimination: string;
+    actionnariat?: Actionnariat;
+  };
+}
+
+// This exists only to access Project repo from within the ssr=>legacy saga.
+export class ProjectRawDataCorrected
+  extends BaseDomainEvent<ProjectRawDataCorrectedPayload>
+  implements DomainEvent
+{
+  public static type: 'ProjectRawDataCorrected' = 'ProjectRawDataCorrected';
+  public type = ProjectRawDataCorrected.type;
+  currentVersion = 1;
+
+  aggregateIdFromPayload(payload: ProjectRawDataCorrectedPayload) {
+    return payload.projectId;
+  }
+}

packages/applications/legacy/src/modules/project/events/index.ts

@@ -17,6 +17,7 @@ export * from './ProjectCompletionDueDateSet';
 export * from './ProjectDCRDueDateCancelled';
 export * from './ProjectDCRDueDateSet';
 export * from './ProjectDataCorrected';
+export * from './ProjectRawDataCorrected';
 export * from './ProjectFournisseursUpdated';
 export * from './ProjectImported';
 export * from './ProjectNotificationDateSet';

packages/applications/legacy/src/sagas/candidature.saga.ts

@@ -2,7 +2,12 @@ import { Message, MessageHandler, mediator } from 'mediateur';
 import { Event } from '@potentiel-infrastructure/pg-event-sourcing';
 import { Candidature } from '@potentiel-domain/candidature';
 import { eventStore } from '../config/eventStore.config';
-import { DésignationCatégorie, ProjectRawDataImported } from '../modules/project';
+import {
+  DésignationCatégorie,
+  ProjectClasseGranted,
+  ProjectRawDataCorrected,
+  ProjectRawDataImported,
+} from '../modules/project';
 import { v4 } from 'uuid';
 import { AppelOffre } from '@potentiel-domain/appel-offre';
 import { Option } from '@potentiel-libraries/monads';
@@ -11,6 +16,9 @@ import getDepartementRegionFromCodePostal, {
 } from '../helpers/getDepartementRegionFromCodePostal';
 import { ConsulterDocumentProjetQuery, DocumentProjet } from '@potentiel-domain/document';
 import { DateTime, IdentifiantProjet } from '@potentiel-domain/common';
+import { getLegacyProjetByIdentifiantProjet } from '../infra/sequelize/queries/project';
+import { getUserByEmail } from '../infra/sequelize/queries/users/getUserByEmail';
+import { ok } from 'neverthrow';
 
 export type SubscriptionEvent = (
   | Candidature.CandidatureImportéeEvent
@@ -39,14 +47,54 @@ export const register = () => {
     switch (event.type) {
       case 'CandidatureImportée-V1':
       case 'CandidatureCorrigée-V1':
-        await eventStore.publish(
-          new ProjectRawDataImported({
-            payload: {
-              importId: v4(),
-              data: { ...mapToLegacyEventPayload(identifiantProjet, payload, appelOffre), details },
-            },
-          }),
-        );
+        const projet = await getLegacyProjetByIdentifiantProjet(identifiantProjet);
+        // Si le projet n'est pas notifié, on l'importe ou le réimporte
+        if (!projet?.notifiedOn) {
+          await eventStore.publish(
+            new ProjectRawDataImported({
+              payload: {
+                importId: v4(),
+                data: {
+                  ...mapToLegacyEventPayload(identifiantProjet, payload, appelOffre),
+                  details,
+                },
+              },
+            }),
+          );
+        } else if (event.type === 'CandidatureCorrigée-V1') {
+          const userId = await new Promise<string>((r) =>
+            getUserByEmail(event.payload.corrigéPar).map((user) => {
+              r(user?.id ?? '');
+              return ok(user);
+            }),
+          );
+          if (projet.classe === 'Eliminé' && event.payload.statut === 'classé') {
+            await eventStore.publish(
+              new ProjectClasseGranted({
+                payload: {
+                  projectId: projet.id,
+                  grantedBy: userId,
+                },
+              }),
+            );
+          } else {
+            // si le projet est notifié, on corrige les données
+            eventStore.publish(
+              new ProjectRawDataCorrected({
+                payload: {
+                  correctedBy: userId,
+                  projectId: projet.id,
+                  correctedData: mapToCorrectedData(event.payload),
+                },
+              }),
+            );
+          }
+          // TODO
+          // if(newTechnologie !== oldTEchnologie){
+          //   publish ProjectCompletionDueDateSet
+          // }
+        }
+
         return;
     }
   };
@@ -75,41 +123,48 @@ const mapToLegacyEventPayload = (
     familleId: identifiantProjet.famille,
     numeroCRE: identifiantProjet.numéroCRE,
     classe: payload.statut === 'classé' ? 'Classé' : 'Eliminé',
-    nomProjet: payload.nomProjet,
-    nomCandidat: payload.nomCandidat,
-    nomRepresentantLegal: payload.nomReprésentantLégal,
-    email: payload.emailContact,
-    motifsElimination: payload.motifÉlimination ?? '',
     garantiesFinancièresDateEchéance: payload.dateÉchéanceGf,
+    garantiesFinancièresType: getTypeGarantiesFinancieresLabel(payload.typeGarantiesFinancières),
     technologie: payload.technologie,
     historiqueAbandon: payload.historiqueAbandon,
-    puissance: payload.puissanceProductionAnnuelle,
-    garantiesFinancièresType: getTypeGarantiesFinancieresLabel(payload.typeGarantiesFinancières),
-    engagementFournitureDePuissanceAlaPointe: payload.puissanceALaPointe,
     actionnaire: payload.sociétéMère,
-    prixReference: payload.prixReference,
-    note: payload.noteTotale,
-    evaluationCarbone: payload.evaluationCarboneSimplifiée,
     désignationCatégorie: getDésignationCatégorie({
       puissance: payload.puissanceProductionAnnuelle,
       note: payload.noteTotale,
       periodeDetails: période,
     }),
-
-    actionnariat:
-      payload.actionnariat === 'financement-collectif' ||
-      payload.actionnariat === 'gouvernance-partagée'
-        ? payload.actionnariat
-        : undefined,
-    isFinancementParticipatif: payload.actionnariat === 'financement-participatif',
-    isInvestissementParticipatif: payload.actionnariat === 'investissement-participatif',
-
     notifiedOn: 0,
-    territoireProjet: payload.territoireProjet,
+    ...mapToCorrectedData(payload),
     ...getLocalitéInfo(payload.localité),
   };
 };
 
+const mapToCorrectedData = (
+  payload: SubscriptionEvent['payload'],
+): ProjectRawDataCorrected['payload']['correctedData'] => ({
+  nomProjet: payload.nomProjet,
+  nomCandidat: payload.nomCandidat,
+  nomRepresentantLegal: payload.nomReprésentantLégal,
+  email: payload.emailContact,
+  motifsElimination: payload.motifÉlimination ?? '',
+  puissance: payload.puissanceProductionAnnuelle,
+  engagementFournitureDePuissanceAlaPointe: payload.puissanceALaPointe,
+  prixReference: payload.prixReference,
+  note: payload.noteTotale,
+  evaluationCarbone: payload.evaluationCarboneSimplifiée,
+  actionnariat:
+    payload.actionnariat === 'financement-collectif'
+      ? 'financement-collectif'
+      : payload.actionnariat === 'gouvernance-partagée'
+        ? 'gouvernance-partagee'
+        : undefined,
+  isFinancementParticipatif: payload.actionnariat === 'financement-participatif',
+  isInvestissementParticipatif: payload.actionnariat === 'investissement-participatif',
+
+  territoireProjet: payload.territoireProjet,
+  ...getLocalitéInfo(payload.localité),
+});
+
 const getLocalitéInfo = ({
   codePostal,
   adresse1,

packages/applications/legacy/src/views/components/UI/organisms/UserNavigation.tsx

@@ -103,9 +103,6 @@ const MenuAdmin = (currentPage?: string) => (
       >
         Notifier des candidats
       </DropdownMenu.DropdownItem>
-      <DropdownMenu.DropdownItem href={Routes.Candidature.corriger}>
-        Corriger des candidats
-      </DropdownMenu.DropdownItem>
       <DropdownMenu.DropdownItem href={Routes.Candidature.lister()}>
         Tous les candidats
       </DropdownMenu.DropdownItem>

packages/applications/routes/src/candidature/candidature.routes.ts

@@ -1,7 +1,7 @@
 import { encodeParameter } from '../encodeParameter';
 
 export const importer = '/candidatures/importer';
-export const corriger = '/candidatures/corriger';
+export const corrigerEnMasse = '/candidatures/corriger';
 
 type ListerFilters = {
   appelOffre?: string;
@@ -31,9 +31,15 @@ export const lister = (filters?: ListerFilters) => {
   return `/candidatures${searchParams.toString() ? `?${searchParams.toString()}` : ''}`;
 };
 
-export const prévisualiserAttestation = (identifiantProjet: string) =>
-  `/candidatures/${encodeParameter(identifiantProjet)}/previsualiser-attestation`;
+const _avecIdentifiant =
+  (path = '') =>
+  (identifiantProjet: string) =>
+    `/candidatures/${encodeParameter(identifiantProjet)}${path}`;
+
+export const détails = _avecIdentifiant();
+export const corriger = _avecIdentifiant('/corriger');
+
+export const prévisualiserAttestation = _avecIdentifiant('/previsualiser-attestation');
 // TODO: à supprimer pour utiliser directement Routes.Document.télécharger dans le front
 // une fois qu'on aura migré la page Projet
-export const téléchargerAttestation = (identifiantProjet: string) =>
-  `/candidatures/${encodeParameter(identifiantProjet)}/telecharger-attestation`;
+export const téléchargerAttestation = _avecIdentifiant('/telecharger-attestation');