feat: muistutuksen kasittely (HASSU-775) (#324)

* initial commit

* wip

* kuittauksen lahetys, email validointi

* testit

backend/src/apiHandler.ts

@@ -6,6 +6,7 @@ import {
   HaeVelhoProjektiAineistoLinkkiQueryVariables,
   LaskePaattymisPaivaQueryVariables,
   LataaProjektiQueryVariables,
+  LisaaMuistutusMutationVariables,
   LisaaPalauteMutationVariables,
   ListaaKayttajatQueryVariables,
   ListaaLisaAineistoQueryVariables,
@@ -46,6 +47,7 @@ import { ClientError } from "./error/ClientError";
 import { SystemError } from "./error/SystemError";
 import { tilaHandler } from "./handler/tila/tilaHandler";
 import { lisaAineistoHandler } from "./handler/lisaAineistoHandler";
+import { muistutusHandler } from "./muistutus/muistutusHandler";
 
 export type AppSyncEventArguments =
   | unknown
@@ -104,7 +106,7 @@ async function executeOperation(event: AppSyncResolverEvent<AppSyncEventArgument
     case apiConfig.listKirjaamoOsoitteet.name:
       return listKirjaamoOsoitteet();
     case apiConfig.lisaaMuistutus.name:
-      return "Kiitos muistutuksesta!"; //TODO: muistutuksen tallennus
+      return muistutusHandler.kasitteleMuistutus(event.arguments as LisaaMuistutusMutationVariables);
     case apiConfig.listaaLisaAineisto.name:
       return lisaAineistoHandler.listaaLisaAineisto(event.arguments as ListaaLisaAineistoQueryVariables);
     default:

backend/src/database/model/nahtavillaoloVaihe.ts

@@ -41,3 +41,16 @@ export type NahtavillaoloPDF = {
   nahtavillaoloIlmoitusPDFPath: string;
   nahtavillaoloIlmoitusKiinteistonOmistajallePDFPath: string;
 };
+
+export type Muistutus = {
+  id: string;
+  vastaanotettu: string;
+  etunimi?: string | null;
+  sukunimi?: string | null;
+  katuosoite?: string | null;
+  postinumeroJaPostitoimipaikka?: string | null;
+  sahkoposti?: string | null;
+  puhelinnumero?: string | null;
+  muistutus?: string | null;
+  liite?: string | null;
+};

backend/src/email/emailTemplates.ts

@@ -1,9 +1,10 @@
 import get from "lodash/get";
-import { Kayttaja } from "../../../common/graphql/apiModel";
+import { Kayttaja, Viranomainen } from "../../../common/graphql/apiModel";
 import { config } from "../config";
 import { DBProjekti } from "../database/model/projekti";
 import { EmailOptions } from "./email";
 import { linkSuunnitteluVaihe } from "../../../common/links";
+import { Muistutus } from "../database/model";
 
 function template(strs: TemplateStringsArray, ...exprs: string[]) {
   return function (obj: unknown) {
@@ -50,6 +51,30 @@ Voit tarkastella aloituskuulutusta osoitteessa https://${"domain"}/yllapito/proj
 
 Saat tämän viestin, koska sinut on merkitty aloituskuulutuksen projektipäälliköksi. Tämä on automaattinen sähköposti, johon ei voi vastata.`;
 const hyvaksyttyPDFVastaanottajat = template`${"velho.vastuuhenkilonEmail"}`;
+const muistutusTeksti = template`
+Muistutus vastaanotettu
+${"vastaanotettu"}
+
+Nimi
+${"etunimi"} ${"sukunimi"}
+
+Postiosoite
+${"katuosoite"} ${"postinumeroJaPostitoimipaikka"}
+
+Sähköposti
+${"sahkoposti"}
+
+Puhelinnumero
+${"puhelinnumero"}
+
+Suunnitelman asiatunnus
+${"asiatunnus"}
+
+Muistutus
+${"muistutus"}
+`;
+const muistutusOtsikko = template`Muistutus - ${"id"}`;
+const muistuttajanOtsikko = template`Vahvistus muistutuksen jättämisestä Valtion liikenneväylien suunnittelu -järjestelmän kautta`;
 
 export function createPerustamisEmail(projekti: DBProjekti): EmailOptions {
   return {
@@ -90,3 +115,27 @@ export function createNewFeedbackAvailableEmail(oid: string, recipient: string):
     to: recipient,
   };
 }
+
+export function createMuistutusKirjaamolleEmail(projekti: DBProjekti, muistutus: Muistutus, sahkoposti: string): EmailOptions {
+  const asiatunnus =
+    projekti.velho.suunnittelustaVastaavaViranomainen === Viranomainen.VAYLAVIRASTO
+      ? projekti.velho.asiatunnusELY
+      : projekti.velho.asiatunnusVayla;
+  return {
+    subject: muistutusOtsikko(muistutus),
+    text: muistutusTeksti({asiatunnus, ...muistutus }),
+    to: sahkoposti,
+  };
+}
+
+export function createKuittausMuistuttajalleEmail(projekti: DBProjekti, muistutus: Muistutus): EmailOptions {
+  const asiatunnus =
+    projekti.velho.suunnittelustaVastaavaViranomainen === Viranomainen.VAYLAVIRASTO
+      ? projekti.velho.asiatunnusELY
+      : projekti.velho.asiatunnusVayla;
+  return {
+    subject: muistuttajanOtsikko(muistutus),
+    text: muistutusTeksti({asiatunnus, ...muistutus }),
+    to: muistutus.sahkoposti,
+  };
+}

backend/src/handler/emailHandler.ts

@@ -18,7 +18,7 @@ import { localDateTimeString } from "../util/dateUtil";
 import { GetObjectOutput } from "aws-sdk/clients/s3";
 import { getS3 } from "../aws/client";
 
-async function getFileAttachment(oid: string, key: string): Promise<Mail.Attachment> {
+export async function getFileAttachment(oid: string, key: string): Promise<Mail.Attachment> {
   log.info("haetaan s3:sta liitetiedosto", key);
 
   try {
@@ -33,7 +33,7 @@ async function getFileAttachment(oid: string, key: string): Promise<Mail.Attachm
       return {
         filename: getFilename(key),
         contentDisposition: "attachment",
-        contentType: "application/pdf",
+        contentType: output.ContentType || "application/pdf",
         content: output.Body,
       };
     } else {

backend/src/muistutus/muistutusAdapter.ts

@@ -0,0 +1,9 @@
+import { MuistutusInput } from "../../../common/graphql/apiModel";
+import { Muistutus } from "../database/model";
+import { localDateTimeString } from "../util/dateUtil";
+import { uuid } from "../util/uuid";
+
+export function adaptMuistutusInput(muistutus: MuistutusInput): Muistutus {
+  const aikaleima = localDateTimeString();
+  return { ...muistutus, vastaanotettu: aikaleima, id: uuid.v4() };
+}

backend/src/muistutus/muistutusEmailService.ts

@@ -0,0 +1,48 @@
+import { DBProjekti, Muistutus } from "../database/model";
+import { emailClient } from "../email/email";
+import { createMuistutusKirjaamolleEmail, createKuittausMuistuttajalleEmail } from "../email/emailTemplates";
+import { getFileAttachment } from "../handler/emailHandler";
+import { kirjaamoOsoitteetService } from "../kirjaamoOsoitteet/kirjaamoOsoitteetService";
+import { log } from "../logger";
+
+class MuistutusEmailService {
+  async sendEmailToMuistuttaja(projekti: DBProjekti, muistutus: Muistutus) {
+    log.info("Lähetetään kuittaus muistutuksen tekijälle");
+    const emailOptions = createKuittausMuistuttajalleEmail(projekti, muistutus);
+    await emailClient.sendEmail(emailOptions);
+    log.info("Kuittaus muistuttajalle lähetetty: " + emailOptions.to);
+  }
+
+  async sendEmailToKirjaamo(projekti: DBProjekti, muistutus: Muistutus) {
+    const vastaavaViranomainen = projekti.velho.suunnittelustaVastaavaViranomainen;
+    const kirjaamot = await kirjaamoOsoitteetService.listKirjaamoOsoitteet();
+    // Hassussa on kahden tyyppista Viranomais -enumia, jotka eivat ole kuitenkaan taysin yhtenaisia kattavuudeltaan
+    // mutta string arvoiltaan ovat samoja, silloin kun viranomainen molemmista loytyy
+    const sahkoposti = kirjaamot.find(({ nimi }) => nimi.toString() === vastaavaViranomainen.toString())?.sahkoposti;
+    log.info("Muistutuksen vastaanottaja: ", sahkoposti);
+    if (!sahkoposti) {
+      log.error("Vastaavan viranomaisen kirjaamon sähköpostiosoitetta ei löytynyt", vastaavaViranomainen);
+      throw new Error("Muistutusta ei voitu lähettää kirjaamoon, syy: kirjaamon osoitetta ei löytynyt");
+    }
+
+    const emailOptions = createMuistutusKirjaamolleEmail(projekti, muistutus, sahkoposti);
+
+    if (muistutus.liite) {
+      log.info("haetaan muistutuksen liite: ", muistutus.liite);
+      const liite = await getFileAttachment(projekti.oid, muistutus.liite);
+      emailOptions.attachments = [liite];
+      emailOptions.text.toString().concat(`
+      
+      Muistutukseen on lisätty liite`);
+    } else {
+      emailOptions.text.toString().concat(`
+      
+      Muistutukseen ei ole lisätty liitettä`);
+    }
+
+    await emailClient.sendEmail(emailOptions);
+    log.info("Muistutuksen sisältävä sähköposti lähetetty: " + emailOptions.to);
+  }
+}
+
+export const muistutusEmailService = new MuistutusEmailService();

backend/src/muistutus/muistutusHandler.ts

@@ -0,0 +1,53 @@
+import { LisaaMuistutusMutationVariables, Status } from "../../../common/graphql/apiModel";
+import { NotFoundError } from "../error/NotFoundError";
+import { projektiDatabase } from "../database/projektiDatabase";
+import { fileService } from "../files/fileService";
+import { projektiAdapterJulkinen } from "../handler/projektiAdapterJulkinen";
+import { muistutusEmailService } from "./muistutusEmailService";
+import { adaptMuistutusInput } from "./muistutusAdapter";
+import { isValidEmail } from "../util/emailUtil";
+import { log } from "../logger";
+
+class MuistutusHandler {
+  async kasitteleMuistutus({ oid, muistutus: muistutusInput }: LisaaMuistutusMutationVariables) {
+    const projektiFromDB = await projektiDatabase.loadProjektiByOid(oid);
+    if (!projektiFromDB) {
+      log.error("Projektia ei löydy");
+      throw new NotFoundError("Projektia ei löydy");
+    }
+    const julkinenProjekti = projektiAdapterJulkinen.adaptProjekti(projektiFromDB);
+    if (!julkinenProjekti) {
+      log.error("Projektia ei löydy tai se ei ole vielä julkinen");
+      throw new NotFoundError("Projektia ei löydy tai se ei ole vielä julkinen");
+    }
+
+    if (julkinenProjekti.status !== Status.NAHTAVILLAOLO) {
+      log.error("Projekti ei ole nähtävilläolovaiheessa, joten muistutuksia ei voi antaa", julkinenProjekti.status);
+      throw new NotFoundError("Projekti ei ole nähtävilläolovaiheessa, joten muistutuksia ei voi antaa");
+    }
+
+    const muistutus = adaptMuistutusInput(muistutusInput);
+    if (muistutus.liite) {
+      muistutus.liite = await fileService.persistFileToProjekti({
+        uploadedFileSource: muistutus.liite,
+        oid,
+        targetFilePathInProjekti: "muistutukset/" + muistutus.id,
+      });
+    }
+
+    await muistutusEmailService.sendEmailToKirjaamo(projektiFromDB, muistutus);
+
+    if (muistutus.sahkoposti && isValidEmail(muistutus.sahkoposti)) {
+      await muistutusEmailService.sendEmailToMuistuttaja(projektiFromDB, muistutus);
+    } else {
+      log.error("Muistuttajalle ei voitu lähettää kuittausviestiä: ", muistutus.sahkoposti);
+    }
+
+    //TODO: kasvata ja tallenna lähetettyjen muistutusten määrää projektilla ->
+    // ehkä aikaleimoina, niin lisää jäljitettävyyttä?
+
+    return "OK";
+  }
+}
+
+export const muistutusHandler = new MuistutusHandler();

backend/src/util/emailUtil.ts

@@ -0,0 +1,8 @@
+// eslint-disable-next-line no-useless-escape
+const emailRegex = /^[\w-\.]+@([\w-]+\.)+[\w-]{2,4}$/g;
+export function isValidEmail(email: string): boolean {
+  if (emailRegex.test(email)) {
+    return true;
+  }
+  return false;
+}