feat(migration-structures-milo): rattacher animations collectives aux…

… structures
SocialGouv · Dec 10, 2023 · adf51f6 · adf51f6
1 parent 4feb877
commit adf51f6
Show file tree

Hide file tree

Showing 11 changed files with 291 additions and 225 deletions.
diff --git a/scripts/data-migrations/purger-sessions-milo.js b/scripts/data-migrations/purger-sessions-milo.js
diff --git a/scripts/data-migrations/structures-milo-ac.js b/scripts/data-migrations/structures-milo-ac.js
@@ -0,0 +1,33 @@
+require('dotenv').config()
+const { Sequelize } = require('sequelize')
+const sequelize = new Sequelize(process.env.DATABASE_URL, {
+  dialect: 'postgres'
+})
+
+sequelize.transaction(async transaction => {
+  const ACsRAW = await sequelize.query(
+    `SELECT * FROM rendez_vous WHERE rendez_vous.type = 'ATELIER' OR rendez_vous.type = 'INFORMATION_COLLECTIVE'`
+  )
+  const ACs = ACsRAW[0]
+  for (const AC of ACs) {
+    const idStructureRaw = await sequelize.query(
+      `SELECT conseiller.id_structure_milo AS id_structure_milo FROM conseiller WHERE conseiller.id = '${AC.createur.id}'`,
+      { transaction }
+    )
+    const idStructure = idStructureRaw[0][0].id_structure_milo
+
+    if (idStructure)
+      await sequelize.query(
+        `UPDATE rendez_vous SET id_structure_milo = '${idStructure}' WHERE rendez_vous.id = '${AC.id}'`
+      )
+  }
+  await sequelize.query(
+    `UPDATE rendez_vous SET date_suppression = NOW() WHERE (rendez_vous.type = 'ATELIER' OR rendez_vous.type = 'INFORMATION_COLLECTIVE') AND rendez_vous.id_structure_milo IS NULL`
+  )
+
+  await sequelize.query(`DELETE FROM rendez_vous_jeune_association WHERE id IN (SELECT rendez_vous_jeune_association.id FROM rendez_vous_jeune_association, jeune, rendez_vous 
+    WHERE rendez_vous.id_structure_milo IS NOT null
+    AND rendez_vous.id = rendez_vous_jeune_association.id_rendez_vous
+    AND rendez_vous_jeune_association.id_jeune = jeune.id 
+    AND jeune.id_structure_milo != rendez_vous.id_structure_milo)`)
+})
diff --git a/src/app.module.ts b/src/app.module.ts
diff --git a/src/domain/rendez-vous/rendez-vous.ts b/src/domain/rendez-vous/rendez-vous.ts
@@ -123,6 +123,7 @@ export interface RendezVous {
   icsSequence?: number
   createur: Createur
   idAgence?: string
+  idStructureMilo?: string
   dateCloture?: DateTime
   informationsPartenaire?: RendezVous.InformationsPartenaire
   nombreMaxParticipants?: number

diff --git a/src/infrastructure/jdd/rendez-vous.jdd.ts b/src/infrastructure/jdd/rendez-vous.jdd.ts
@@ -29,6 +29,7 @@ export function unRendezVousJDD(
     icsSequence: null,
     dateCloture: null,
     idAgence: null,
+    idStructureMilo: null,
     createur: { id: '1', nom: 'Tavernier', prenom: 'Nils' },
     typePartenaire: null,
     idPartenaire: null,

diff --git a/src/infrastructure/repositories/mappers/rendez-vous.mappers.ts b/src/infrastructure/repositories/mappers/rendez-vous.mappers.ts
@@ -32,6 +32,7 @@ export function toRendezVousDto(rendezVous: RendezVous): AsSql<RendezVousDto> {
     icsSequence: rendezVous.icsSequence ?? null,
     createur: rendezVous.createur,
     idAgence: rendezVous.idAgence ?? null,
+    idStructureMilo: rendezVous.idStructureMilo ?? null,
     typePartenaire: rendezVous.informationsPartenaire?.type ?? null,
     idPartenaire: rendezVous.informationsPartenaire?.id ?? null,
     nombreMaxParticipants: rendezVous.nombreMaxParticipants ?? null
@@ -59,6 +60,7 @@ export function toRendezVous(rendezVousSql: RendezVousSqlModel): RendezVous {
     createur: rendezVousSql.createur,
     dateCloture: DateService.fromJSDateToDateTime(rendezVousSql.dateCloture),
     idAgence: rendezVousSql.idAgence ?? undefined,
+    idStructureMilo: rendezVousSql.idStructureMilo ?? undefined,
     informationsPartenaire: buildInformationsPartenaire(rendezVousSql),
     nombreMaxParticipants: rendezVousSql.nombreMaxParticipants ?? undefined
   }

diff --git a/src/infrastructure/sequelize/migrations/20231206080808-ajout-structure-milo-rdv.js b/src/infrastructure/sequelize/migrations/20231206080808-ajout-structure-milo-rdv.js
@@ -0,0 +1,29 @@
+'use strict'
+
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+    await queryInterface.sequelize.transaction(async transaction => {
+      await queryInterface.addColumn(
+        'rendez_vous',
+        'id_structure_milo',
+        {
+          type: Sequelize.STRING,
+          references: {
+            model: 'structure_milo',
+            key: 'id'
+          },
+          allowNull: true
+        },
+        { transaction }
+      )
+    })
+  },
+
+  down: async queryInterface => {
+    await queryInterface.sequelize.transaction(async transaction => {
+      await queryInterface.removeColumn('rendez_vous', 'id_structure_milo', {
+        transaction
+      })
+    })
+  }
+}
diff --git a/src/infrastructure/sequelize/models/rendez-vous.sql-model.ts b/src/infrastructure/sequelize/models/rendez-vous.sql-model.ts
@@ -16,6 +16,7 @@ import { AgenceSqlModel } from './agence.sql-model'
 import { JeuneSqlModel } from './jeune.sql-model'
 import { RendezVousJeuneAssociationSqlModel } from './rendez-vous-jeune-association.sql-model'
 import { LogModificationRendezVousSqlModel } from './log-modification-rendez-vous-sql.model'
+import { StructureMiloSqlModel } from './structure-milo.sql-model'
 
 export class RendezVousDto extends Model {
   @PrimaryKey
@@ -84,6 +85,13 @@ export class RendezVousDto extends Model {
   })
   idAgence: string | null
 
+  @ForeignKey(() => StructureMiloSqlModel)
+  @Column({
+    field: 'id_structure_milo',
+    type: DataType.STRING
+  })
+  idStructureMilo: string | null
+
   @Column({
     field: 'type_partenaire',
     type: DataType.STRING

diff --git a/test/fixtures/rendez-vous.fixture.ts b/test/fixtures/rendez-vous.fixture.ts
@@ -29,6 +29,7 @@ export const unRendezVous = (args: Partial<RendezVous> = {}): RendezVous => {
     icsSequence: undefined,
     dateCloture: undefined,
     idAgence: undefined,
+    idStructureMilo: undefined,
     precision: 'Ceci est une précision',
     createur: {
       id: '1',

diff --git a/test/fixtures/sql-models/rendez-vous.sql-model.ts b/test/fixtures/sql-models/rendez-vous.sql-model.ts
@@ -29,6 +29,7 @@ export function unRendezVousDto(
     icsSequence: null,
     dateCloture: null,
     idAgence: null,
+    idStructureMilo: null,
     createur: { id: '1', nom: 'Tavernier', prenom: 'Nils' },
     source: RendezVous.Source.PASS_EMPLOI,
     typePartenaire: null,

diff --git a/test/infrastructure/repositories/rendez-vous/animation-collective-sql.repository.db.test.ts b/test/infrastructure/repositories/rendez-vous/animation-collective-sql.repository.db.test.ts
@@ -174,6 +174,7 @@ describe('AnimationsCollectivesSqlRepository', () => {
         createur: uneACAVenir.createur,
         dateCloture: DateService.fromJSDateToDateTime(uneACAVenir.dateCloture),
         idAgence: uneACAVenir.idAgence!,
+        idStructureMilo: undefined,
         source: RendezVous.Source.PASS_EMPLOI,
         informationsPartenaire: undefined,
         nombreMaxParticipants: undefined
@@ -279,6 +280,7 @@ describe('AnimationsCollectivesSqlRepository', () => {
         createur: uneACAVenir.createur,
         dateCloture: DateService.fromJSDateToDateTime(uneACAVenir.dateCloture),
         idAgence: uneACAVenir.idAgence!,
+        idStructureMilo: undefined,
         source: RendezVous.Source.PASS_EMPLOI,
         informationsPartenaire: undefined,
         nombreMaxParticipants: undefined
@@ -337,6 +339,7 @@ describe('AnimationsCollectivesSqlRepository', () => {
           const animationCollectiveAvecUnJeuneDePlus: RendezVous.AnimationCollective =
             {
               ...uneAnimationCollectiveTest,
+              idStructureMilo: undefined,
               informationsPartenaire: undefined,
               jeunes: uneAnimationCollectiveTest.jeunes.concat(nouveauJeune)
             }
@@ -353,11 +356,12 @@ describe('AnimationsCollectivesSqlRepository', () => {
       })
 
       describe('quand on enlève un jeune du rendez-vous', () => {
-        it('met à jour les informations du animationCollective en supprimant une association quand on supprime un jeune', async () => {
+        it("met à jour les informations de l'animation collective en supprimant une association quand on supprime un jeune", async () => {
           // Given
           const rendezVousAvecUnJeuneDeMoins: RendezVous.AnimationCollective = {
             ...uneAnimationCollectiveTest,
             informationsPartenaire: undefined,
+            idStructureMilo: undefined,
             jeunes: uneAnimationCollectiveTest.jeunes.filter(
               jeune => jeune.id !== unAutreJeune.id
             )
@@ -375,7 +379,7 @@ describe('AnimationsCollectivesSqlRepository', () => {
       })
 
       describe('quand on ne change pas le nombre de jeunes', () => {
-        it('met à jour les informations du animationCollective en ne rajoutant pas une association supplémentaire et en mettant à jour les informations de presence des jeunes', async () => {
+        it("met à jour les informations de l'animation collective en ne rajoutant pas une association supplémentaire et en mettant à jour les informations de presence des jeunes", async () => {
           // Given
           const uneAnimationCollectiveModifiee: RendezVous.AnimationCollective =
             {
@@ -405,6 +409,7 @@ describe('AnimationsCollectivesSqlRepository', () => {
           expect(actual).to.deep.equal({
             ...uneAnimationCollectiveModifiee,
             informationsPartenaire: undefined,
+            idStructureMilo: undefined,
             jeunes: [jeune, unAutreJeune]
           })
         })