SS-FCSC/fcsc_ipi_backend
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added 1s delay time

Browse Source
This commit is contained in:
unknown 2025-12-10 12:37:19 +05:30
parent acddc25918
commit 8557ddb37a
1 changed files with 36 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

75
app/controllers/quarterlyWindowsConfiguration.controller.js
View File

@ -7,10 +7,22 @@ const EstablishmentUser = db.EstablishmentUser;
const { sendEmailService } = require("../services/email.service");
// Create new configuration
exports.createConfig = async (req, res) => {
try {
const {survey_name, quarter, year, start_date, end_date } = req.body;
const surveyNameExists = await QuarterlyWindowsConfiguration.findOne({
where: { survey_name, is_active: true }
});
if (surveyNameExists) {
return res.status(400).json({
status: "failed",
message: `Survey Name '${survey_name}' already exists.`
});
}
// find config
const exists = await QuarterlyWindowsConfiguration.findOne({where: { quarter, year }});
@ -40,54 +52,39 @@ exports.createConfig = async (req, res) => {
support_email: process.env.SUPPORT_EMAIL,
support_phone: process.env.SUPPORT_PHONE
};
const EstablishmentUserData = await EstablishmentUser.findAll({where: { is_active: 1 }});
const establishmentEmailPromises = EstablishmentUserData.map(async (userObj) => {
try {
await sendEmailService(
userObj.email,
"quarterly_survey_created_to_establishment",
placeholder
);
return { email: userObj.email, status: "sent" };
} catch (error) {
return { email: userObj.email, status: "failed", error: error.message };
}
});
// Wait for all emails to resolve
const emailResults = await Promise.all(establishmentEmailPromises);
// Create quarterly window configuration
const data = await QuarterlyWindowsConfiguration.create(req.body);
res.status(201).send({
status: "success",
message: "Quarterly window configuration created successfully",
data,
emailResults,
status: "success",
message: "Quarterly window configuration created successfully",
data,
});
// const establishmentEmailPromises = EstablishmentUserData.map((userObj) => {
// return sendEmailService(userObj.email,"quarterly_survey_created_to_establishment", placeholder);
// });
// await Promise.all([
// ...establishmentEmailPromises
// ]);
// const data = await QuarterlyWindowsConfiguration.create(req.body);
// res.status(201).send({
// status: "success",
// message: "Quarterly window configuration created successfully",
// data,
// });
sendEmailsToEstablishments(placeholder);
} catch (err) {
res.status(500).send({ status: "failed", message: err.message });
}
};
async function sendEmailsToEstablishments(placeholder) {
try {
const users = await EstablishmentUser.findAll({
where: { is_active: 1 }
});
for (const user of users) {
try {
await sendEmailService( user.email, "quarterly_survey_created_to_establishment", placeholder );
await new Promise(resolve => setTimeout(resolve, 1000));
} catch (emailErr) {
console.error("Email failed:", user.email, emailErr.message);
}
}
} catch (err) {
console.error("Email background job failed:", err.message);
}
}
// Get all configurations
exports.getAllConfigs = async (req, res) => {
try {