Feat generate sms inserasaf (#3892)

Author: pYassine

packages/backend/src/_migrations/1756117243339-manual-migration.ts

@@ -0,0 +1,86 @@
+import { MessageSms } from "@domifa/common";
+import { MigrationInterface, QueryRunner } from "typeorm";
+import { messageSmsRepository } from "../database";
+import { appLogger } from "../util";
+import { domifaConfig } from "../config";
+
+export class ManualMigration1756117243339 implements MigrationInterface {
+  name = "CreateSmsForUserUsager1756117243339";
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    if (domifaConfig().envId === "prod") {
+      appLogger.warn(
+        "Début de la migration : Création des SMS pour les comptes usagers"
+      );
+
+      // Récupération de tous les user_usager avec les informations nécessaires via jointure
+      const userUsagers = await queryRunner.query(`
+      SELECT
+        uu.id,
+        uu."usagerUUID",
+        uu."structureId",
+        uu.login,
+        u.ref as "usagerRef",
+        u.telephone,
+        u."dateNaissance"
+      FROM user_usager uu
+      INNER JOIN usager u ON uu."usagerUUID" = u.uuid
+      WHERE  u.telephone IS NOT NULL
+        AND (u.options ->> 'portailUsagerEnabled')::boolean = true
+        AND u."structureId" = 2165
+        AND (u.telephone->>'numero') IS NOT NULL
+        AND (u.telephone->>'numero') != ''
+    `);
+
+      appLogger.warn(`Nombre d'utilisateurs trouvés : ${userUsagers.length}`);
+
+      const smsToSave: MessageSms[] = [];
+      const scheduledDate = new Date();
+
+      for (const userUsager of userUsagers) {
+        const { login, telephone, usagerRef, structureId } = userUsager;
+
+        const phoneNumber = telephone?.numero || "";
+
+        if (!phoneNumber) {
+          appLogger.warn(
+            `Numéro de téléphone manquant pour l'usager ${userUsager.usagerUUID}`
+          );
+          continue;
+        }
+
+        // Contenu du SMS
+        const smsContent = `Nouveau portail Inserasaf pour consulter votre courrier !
+Connexion: https://urlr.me/JCdwYs
+ID: ${login}
+MDP: votre date de naissance
+DomiFa`;
+
+        smsToSave.push({
+          usagerRef: usagerRef,
+          structureId: structureId,
+          content: smsContent,
+          senderName: "DomiFa",
+          status: "TO_SEND",
+          smsId: "idMonDomiFa",
+          phoneNumber: phoneNumber,
+          scheduledDate,
+          errorCount: 0,
+        });
+      }
+
+      if (smsToSave?.length > 0) {
+        await messageSmsRepository.save(smsToSave);
+        appLogger.warn(`Migration terminée : ${smsToSave.length} SMS créés`);
+      } else {
+        appLogger.warn("Aucun SMS à créer");
+      }
+    }
+  }
+
+  public async down(): Promise<void> {
+    appLogger.warn(
+      "Début du rollback : Suppression des SMS de création de compte"
+    );
+  }
+}

packages/backend/src/modules/sms/services/message-sms-sender.service.ts

@@ -10,19 +10,13 @@ import {
 import { domifaConfig } from "../../../config";
 import { messageSmsRepository } from "../../../database";
 import { phoneUtil, appLogger } from "../../../util";
+import { SmsToSend } from "../types";
 
 @Injectable()
 export class MessageSmsSenderService {
   constructor(private readonly httpService: HttpService) {}
 
-  public async sendSms(message: {
-    content: string;
-    phoneNumber: string;
-    senderName: string;
-    structureId: number;
-    uuid: string;
-    errorCount: number;
-  }): Promise<void> {
+  public async sendSms(message: SmsToSend): Promise<void> {
     const parsedValue = phoneUtil.parse(message.phoneNumber);
 
     if (!phoneUtil.isValidNumber(parsedValue)) {

packages/backend/src/modules/sms/services/senders/cron-sms-id-mon-domifa.service.ts

@@ -0,0 +1,67 @@
+import { appLogger } from "../../../../util";
+import { messageSmsRepository } from "../../../../database";
+
+import { Cron, CronExpression } from "@nestjs/schedule";
+import { Injectable } from "@nestjs/common";
+import { domifaConfig } from "../../../../config";
+import { isCronEnabled } from "../../../../config/services/isCronEnabled.service";
+import { MessageSmsSenderService } from "../message-sms-sender.service";
+import { SmsToSend } from "../../types";
+@Injectable()
+export class CronSmsInteractionSenderService {
+  constructor(
+    private readonly messageSmsSenderService: MessageSmsSenderService
+  ) {}
+
+  @Cron(CronExpression.EVERY_10_MINUTES, {
+    timeZone: "Europe/Paris",
+    disabled: !isCronEnabled() || !domifaConfig().sms.enabled,
+  })
+  protected async processSMSBatch() {
+    appLogger.info("[SMS BATCH] Début d'envoi d'un batch de 500 SMS");
+
+    try {
+      const now = new Date();
+      const currentHour = now.getHours();
+
+      if (currentHour >= 20) {
+        appLogger.info(
+          `[SMS BATCH] Hors plage horaire (${currentHour}h) - Arrêt de l'envoi`
+        );
+        return;
+      }
+
+      const smsToSend = (await messageSmsRepository.find({
+        where: {
+          status: "TO_SEND",
+          smsId: "idMonDomiFa",
+        },
+        order: {
+          createdAt: "ASC",
+        },
+        take: 500,
+      })) as SmsToSend[];
+
+      if (smsToSend.length === 0) {
+        appLogger.info(
+          "[SMS BATCH] Aucun SMS d'identifiants Mon DomiFa à envoyer"
+        );
+        return;
+      }
+
+      appLogger.info(
+        `[SMS BATCH] ${smsToSend.length} SMS d'identifiants Mon DomiFa trouvés pour envoi`
+      );
+
+      for (const message of smsToSend) {
+        await this.messageSmsSenderService.sendSms(message);
+      }
+
+      appLogger.info(
+        `[SMS BATCH] Batch terminé - ${smsToSend.length} SMS traités`
+      );
+    } catch (error) {
+      appLogger.error("[SMS BATCH] Erreur lors de l'envoi du batch:", error);
+    }
+  }
+}

packages/backend/src/modules/sms/types/SmsToSend.interface.ts

@@ -0,0 +1,9 @@
+import { MessageSms } from "@domifa/common";
+
+export interface SmsToSend
+  extends Pick<
+    MessageSms,
+    "content" | "phoneNumber" | "senderName" | "structureId" | "errorCount"
+  > {
+  uuid: string;
+}

packages/backend/src/modules/sms/types/index.ts

@@ -0,0 +1,2 @@
+// @index('./*', f => `export * from '${f.path}'`)
+export * from "./SmsToSend.interface";

packages/common/src/message-sms/types/MessageSmsId.type.ts

@@ -1,4 +1,7 @@
 import { type InteractionType } from "../../interactions";
 import { type MessageSmsReminders } from "./MessageSmsReminders.type";
 
-export type MessageSmsId = InteractionType | MessageSmsReminders;
+export type MessageSmsId =
+  | InteractionType
+  | MessageSmsReminders
+  | "idMonDomiFa";

packages/frontend/src/app/modules/shared/services/auth.service.ts

@@ -18,7 +18,6 @@ import { Store } from "@ngrx/store";
 })
 export class AuthService {
   public currentUserSubject: BehaviorSubject<UserStructure | null>;
-
   private readonly endPoint = environment.apiUrl + "structures/auth";
 
   constructor(

packages/frontend/src/app/modules/usager-profil/constants/SMS_LABELS.const.ts

@@ -13,5 +13,6 @@ export const SMS_LABELS: {
   visite: "Passage enregistré",
   echeanceDeuxMois: "Sms rappel de renouvellement",
   dernierPassageTroisMois: "Avertissement dernier passage plus de 3 mois",
+  idMonDomiFa: "Envoi des identifiants Mon DomiFa",
   decision: "Nouvelle décision",
 };