Done ticket GEPAFINBE-210

src/main/java/net/gepafin/tendermanagement/dao/EmailDao.java

@@ -0,0 +1,91 @@
+package net.gepafin.tendermanagement.dao;
+
+
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.extern.log4j.Log4j2;
+import net.gepafin.tendermanagement.constants.GepafinConstant;
+import net.gepafin.tendermanagement.entities.CallEntity;
+import net.gepafin.tendermanagement.entities.EmailLogEntity;
+import net.gepafin.tendermanagement.enums.EmailScenarioTypeEnum;
+import net.gepafin.tendermanagement.enums.EmailServiceTypeEnum;
+import net.gepafin.tendermanagement.enums.RecipientTypeEnum;
+import net.gepafin.tendermanagement.enums.StatusTypeEnum;
+import net.gepafin.tendermanagement.model.request.EmailLogRequest;
+import net.gepafin.tendermanagement.model.response.EmailResendResponseBean;
+import net.gepafin.tendermanagement.model.response.EmailSendResponse;
+import net.gepafin.tendermanagement.repositories.EmailLogRepository;
+import net.gepafin.tendermanagement.service.CallService;
+import net.gepafin.tendermanagement.util.Utils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Set;
+
+@Component
+@Log4j2
+public class EmailDao {
+
+    @Autowired
+    EmailLogRepository emailLogRepository;
+
+    @Autowired
+    EmailNotificationDao emailNotificationDao;
+    
+    @Autowired
+    private CallService callService;
+
+    public EmailResendResponseBean resendEmail(HttpServletRequest request , Long userActionId){
+        List<EmailLogEntity> emailLogs  = emailLogRepository.findByUserActionIdAndEmailServiceType(userActionId,EmailServiceTypeEnum.PEC_SERVICE.getValue());
+        if (emailLogs.isEmpty()) {
+           log.info("No emails found for given userActionId.");
+        }
+        EmailResendResponseBean emailResendResponseBean = new EmailResendResponseBean();
+        for (EmailLogEntity log : emailLogs){
+            EmailLogRequest emailLogRequest = new EmailLogRequest();
+            emailLogRequest.setEmailType(EmailScenarioTypeEnum.valueOf(log.getEmailType()));
+            emailLogRequest.setRecipientType(RecipientTypeEnum.valueOf(log.getRecipientType()));
+            emailLogRequest.setRecipientId(log.getRecipientId());
+            emailLogRequest.setUserId(log.getUserId());
+            emailLogRequest.setApplicatioId(log.getApplicationId());
+            emailLogRequest.setCallId(log.getCallId());
+            emailLogRequest.setAmendmentId(log.getAmendmentId());
+
+            List<String> recipients = Utils.commaSeparatedStringToList(log.getRecipientEmails());
+            CallEntity call = callService.validateCall(log.getCallId());
+            emailNotificationDao.sendMail(
+                    call.getHub().getId(),
+                    log.getEmailSubject(),
+                    log.getEmailBody(),
+                    recipients,
+                    emailLogRequest
+            );
+        }
+        EmailSendResponse emailSendResponse = buildEmailSendResponseFromRequest(request);
+        emailResendResponseBean.setEmailSendResponse(emailSendResponse);
+        return emailResendResponseBean;
+    }
+
+    public EmailSendResponse buildEmailSendResponseFromRequest(HttpServletRequest request) {
+        Long userActionId = (Long) request.getAttribute(GepafinConstant.USER_ACTION_ID);
+        boolean isEmailSendSuccess = isEmailSentSuccessfully(userActionId);
+        EmailSendResponse emailSendResponse = new EmailSendResponse();
+        emailSendResponse.setIsEmailSend(isEmailSendSuccess);
+        emailSendResponse.setUserActionId(userActionId);
+        return emailSendResponse;
+    }
+
+    public boolean isEmailSentSuccessfully(Long userActionId) {
+        List<EmailLogEntity> emailLogs = emailLogRepository.findByUserActionId(userActionId);
+
+        for (EmailLogEntity log : emailLogs) {
+            if (EmailServiceTypeEnum.PEC_SERVICE.getValue().equals(log.getEmailServiceType()) &&
+                    StatusTypeEnum.SUCCESS.getValue().equals(log.getSendStatus())) {
+                return true;
+            }
+        }
+        return false;
+    }
+
+}