4nk/lecoffre-back
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed

Browse Source
This commit is contained in:
Vins 2023-10-03 09:48:15 +02:00
parent 7c2bb75244
commit 659067a280
2 changed files with 18 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/common/emails/EmailBuilder.ts
View File

@ -1,7 +1,7 @@
import DocumentsService from "@Services/super-admin/DocumentsService/DocumentsService"; import DocumentsService from "@Services/super-admin/DocumentsService/DocumentsService";
import { Documents } from "@prisma/client"; import { Documents } from "@prisma/client";
import { Document } from "le-coffre-resources/dist/SuperAdmin"; import User, { Document } from "le-coffre-resources/dist/SuperAdmin";
import { Service } from "typedi"; import { Service } from "typedi";
import { ETemplates } from "./Templates/EmailTemplates"; import { ETemplates } from "./Templates/EmailTemplates";
import MailchimpService from "@Services/common/MailchimpService/MailchimpService"; import MailchimpService from "@Services/common/MailchimpService/MailchimpService";
@ -48,14 +48,14 @@ export default class EmailBuilder {
}); });
} }
public async sendRecapEmails(usersToEmail: [{email: string, civility: string, last_name: string}]){ public async sendRecapEmails(usersToEmail: User[]){
usersToEmail.forEach(user => { usersToEmail.forEach(user => {
const to = user.email; const to = user.contact!.email;
const civility = this.getCivility(user.civility); const civility = this.getCivility(user.contact!.civility);
const templateVariables = { const templateVariables = {
civility: civility, civility: civility,
last_name: user.last_name, last_name: user.contact!.last_name,
link: this.variables.APP_HOST link: this.variables.APP_HOST
}; };

28
src/services/common/MailchimpService/MailchimpService.ts
View File

@ -1,17 +1,22 @@
import EmailRepository from "@Repositories/EmailRepository"; import EmailRepository from "@Repositories/EmailRepository";
import BaseService from "@Services/BaseService"; import BaseService from "@Services/BaseService";
import { Emails, PrismaClient } from "@prisma/client"; import { Emails } from "@prisma/client";
import { Service } from "typedi"; import { Service } from "typedi";
import MailchimpClient from "@mailchimp/mailchimp_transactional"; import MailchimpClient from "@mailchimp/mailchimp_transactional";
import { BackendVariables } from "@Common/config/variables/Variables"; import { BackendVariables } from "@Common/config/variables/Variables";
import UsersService from "@Services/super-admin/UsersService/UsersService";
import EmailBuilder from "@Common/emails/EmailBuilder"; import EmailBuilder from "@Common/emails/EmailBuilder";
// import DocumentsService from "@Services/super-admin/DocumentsService/DocumentsService";
@Service() @Service()
export default class MailchimpService extends BaseService { export default class MailchimpService extends BaseService {
private static readonly from = "vincent.alamelle@smart-chain.fr"; private static readonly from = "vincent.alamelle@smart-chain.fr";
constructor(private emailRepository: EmailRepository, protected variables: BackendVariables, private emailBuilder: EmailBuilder) { constructor(
private emailRepository: EmailRepository,
protected variables: BackendVariables,
private usersService: UsersService,
private emailBuilder: EmailBuilder,
) {
super(); super();
} }
@ -52,7 +57,7 @@ export default class MailchimpService extends BaseService {
* @description : Function called by cron to send emails * @description : Function called by cron to send emails
* @throws {Error} If email cannot be sent * @throws {Error} If email cannot be sent
*/ */
public async sendEmails() { public async sendEmails() {
const emailsToSend = await this.get({ where: { sentAt: null } }); const emailsToSend = await this.get({ where: { sentAt: null } });
const currentDate = new Date(); const currentDate = new Date();
let nextTrySendDate = null; let nextTrySendDate = null;
@ -85,8 +90,8 @@ export default class MailchimpService extends BaseService {
} }
} }
private async sendEmail(email: Emails) { private async sendEmail(email: Emails) {
const apiKey = this.variables.MAILCHIMP_API_KEY; const apiKey = this.variables.MAILCHIMP_API_KEY;
const mailchimpApiClient = MailchimpClient(apiKey!); const mailchimpApiClient = MailchimpClient(apiKey!);
await mailchimpApiClient.messages.sendTemplate({ await mailchimpApiClient.messages.sendTemplate({
@ -117,15 +122,8 @@ export default class MailchimpService extends BaseService {
} }
public async sendRecapEmails() { public async sendRecapEmails() {
const prisma = new PrismaClient(); const usersToEmail = await this.usersService.get({ where: { office_folders: { some:{ documents: { some: { document_status: "DEPOSITED" } } }} }, distinct: ["uid"], include: { contact: true } });
const usersToEmail: [{email: string, civility: string, last_name: string}] = await prisma.$queryRaw
`SELECT DISTINCT c.email, c.civility, c.last_name
FROM Contacts c
JOIN Users u ON c.uid = u.contact_uid
JOIN office_folders of ON u.office_uid = of.office_uid
JOIN Documents d ON of.uid = d.folder_uid
WHERE d.document_status = 'DEPOSITED';`
await this.emailBuilder.sendRecapEmails(usersToEmail); await this.emailBuilder.sendRecapEmails(usersToEmail);
} }
} }