package net.gepafin.tendermanagement.dao;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import net.gepafin.tendermanagement.constants.GepafinConstant;
import net.gepafin.tendermanagement.entities.*;
import net.gepafin.tendermanagement.enums.RecipientTypeEnum;
import net.gepafin.tendermanagement.model.request.EmailConfig;
import net.gepafin.tendermanagement.model.request.EmailLogRequest;
import net.gepafin.tendermanagement.model.response.AmendmentFormFieldResponse;
import net.gepafin.tendermanagement.model.response.EmailContentResponse;
import net.gepafin.tendermanagement.model.response.SystemEmailTemplateResponse;
import net.gepafin.tendermanagement.repositories.*;
import net.gepafin.tendermanagement.service.*;
import net.gepafin.tendermanagement.service.impl.EmailService;
import net.gepafin.tendermanagement.service.impl.EmailServiceFactory;
import net.gepafin.tendermanagement.util.DateTimeUtil;
import net.gepafin.tendermanagement.util.Utils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.*;

import static net.gepafin.tendermanagement.dao.ApplicationAmendmentRequestDao.filterByName;

@Component
public class EmailNotificationDao {

    private static final Logger log = LoggerFactory.getLogger(EmailNotificationDao.class);

    @Autowired
    private SystemEmailTemplatesService systemEmailTemplatesService;

    @Autowired
    private ApplicationService applicationService;

    @Autowired
    private UserService userService;

    @Autowired
    private HubService hubService;

    @Autowired
    EmailServiceFactory emailServiceFactory;

    @Autowired
    HubRepository hubRepository;

    @Autowired
    private EmailLogDao emailLogDao;

    @Autowired
    private EmailLogRepository emailLogRepository;

    @Autowired
    private CompanyService companyService;

    @Autowired
    private ApplicationFormRepository applicationFormRepository;

    @Autowired
    private ApplicationEvaluationRepository applicationEvaluationRepository;

    @Value("${rinaldo_email}")
    private String rinaldoEmail;

    private void sendEmail(ApplicationEntity applicationEntity, SystemEmailTemplatesEntity.SystemEmailTemplatesEntityTypeEnum templateType, Map<String, String> bodyPlaceholders,
            List<String> additionalRecipients, Long amendmentId) {

        HubEntity hubEntity = hubService.valdateHub(applicationEntity.getHubId());
//        String service = determineService(applicationEntity.getHubId());
//        String legalMail = service.equals("Gepafin S.p.a.") ? "bandi.gepafin@legalmail.it" : "bandi.sviluppumbria@legalmail.it";

        EmailContentResponse emailContent = prepareEmailContent(applicationEntity, templateType, hubEntity, bodyPlaceholders);
        UserEntity userEntity = userService.validateUser(applicationEntity.getUserId());
        sendEmails(applicationEntity, userEntity, additionalRecipients,amendmentId,emailContent.getSystemEmailTemplateResponse(),emailContent.getSubject(),emailContent.getBody());
    }

    public EmailContentResponse prepareEmailContent(
            ApplicationEntity applicationEntity,
            SystemEmailTemplatesEntity.SystemEmailTemplatesEntityTypeEnum templateType,
            HubEntity hubEntity,
            Map<String, String> bodyPlaceholders
    ) {
        SystemEmailTemplateResponse systemEmailTemplateResponse = systemEmailTemplatesService.retrieveTemplateByTypeAndCall(templateType, hubEntity, null);

        Map<String, String> subjectPlaceholders = new HashMap<>();
        CompanyEntity company = companyService.validateCompany(applicationEntity.getCompanyId());
        subjectPlaceholders.put("{{call_name}}", applicationEntity.getCall().getName());
        subjectPlaceholders.put("{{company_name}}", company.getCompanyName());
//        bodyPlaceholders.put("{{legal_mail}}", legalMail);
        String subject = Utils.replacePlaceholders(systemEmailTemplateResponse.getSubject(), subjectPlaceholders);
        String body = Utils.replacePlaceholders(systemEmailTemplateResponse.getHtmlContent(), bodyPlaceholders);

        return new EmailContentResponse(subject, body, systemEmailTemplateResponse);
    }

    private void sendEmails(ApplicationEntity applicationEntity, UserEntity userEntity, List<String> additionalRecipients,Long amendmentId,SystemEmailTemplateResponse systemEmailTemplateResponse,String subject,String body) {

        Optional<ApplicationEvaluationEntity> applicationEvaluationEntity = applicationEvaluationRepository.findByApplicationIdAndIsDeletedFalse(applicationEntity.getId());
        CompanyEntity company = companyService.validateCompany(applicationEntity.getCompanyId());

        UserWithCompanyEntity userWithCompany=companyService.getUserWithCompany(userEntity.getId(),company.getId());
                String companyEmail = userWithCompany.getEmail();
                String contactEmail = userWithCompany.getContactEmail();

                if (companyEmail != null && !companyEmail.isEmpty()) {
                    EmailLogRequest emailLogRequest = emailLogDao.createEmailLogRequest(systemEmailTemplateResponse.getEmailScenario(), RecipientTypeEnum.COMPANY,company.getId() ,
                            companyEmail, userEntity.getId(), applicationEntity.getId(), amendmentId, applicationEntity.getCall().getId());
                    sendMail(applicationEntity.getHubId(), subject, body, List.of(companyEmail), emailLogRequest);
                }
                if (contactEmail != null && !contactEmail.isEmpty() && !contactEmail.equals(companyEmail)) {
                    EmailLogRequest emailLogRequest = emailLogDao.createEmailLogRequest(systemEmailTemplateResponse.getEmailScenario(), RecipientTypeEnum.COMPANY,company.getId(),
                            contactEmail, userEntity.getId(), applicationEntity.getId(), amendmentId, applicationEntity.getCall().getId());
                    sendMail(applicationEntity.getHubId(), subject, body, List.of(contactEmail), emailLogRequest);
                }

                if (userEntity.getBeneficiary().getEmail() != null) {
                    String beneficiaryEmail = userEntity.getBeneficiary().getEmail();
                    EmailLogRequest emailLogRequest = emailLogDao.createEmailLogRequest(systemEmailTemplateResponse.getEmailScenario(), RecipientTypeEnum.BENEFICIARY,userEntity.getBeneficiary().getId() ,
                            beneficiaryEmail, userEntity.getId(), applicationEntity.getId(), amendmentId, applicationEntity.getCall().getId());
                    sendMail(applicationEntity.getHubId(), subject, body, List.of(beneficiaryEmail), emailLogRequest);
                }
                if(userEntity.getHub().getEmail() != null){
                    String hubEmails = userEntity.getHub().getEmail();
                    String[] hubEmailArray = hubEmails.split(",");
                    for (String hubEmail : hubEmailArray) {
                        hubEmail = hubEmail.trim();
                        if (!hubEmail.isEmpty()) {
                            EmailLogRequest emailLogRequest = emailLogDao.createEmailLogRequest(systemEmailTemplateResponse.getEmailScenario(), RecipientTypeEnum.PROPERTIES,null,
                                    hubEmail, userEntity.getId(), applicationEntity.getId(), amendmentId, applicationEntity.getCall().getId());
                            sendMail(applicationEntity.getHubId(), subject, body, List.of(hubEmail), emailLogRequest);
                        }
                    }
                }
               if (rinaldoEmail != null) {
                   EmailLogRequest emailLogRequest = emailLogDao.createEmailLogRequest(systemEmailTemplateResponse.getEmailScenario(), RecipientTypeEnum.PROPERTIES,null ,
                           rinaldoEmail, userEntity.getId(), applicationEntity.getId(), amendmentId, applicationEntity.getCall().getId());
                   sendMail(applicationEntity.getHubId(), subject, body, List.of(rinaldoEmail), emailLogRequest);
               }
              if (applicationEvaluationEntity.isPresent()) {
                  Long preInstructorId = applicationEvaluationEntity.get().getUserId(); // Assuming UserEntity has an email field
                  UserEntity instructorUser = userService.validateUser(preInstructorId);
                  String preInstructorEmail = instructorUser.getEmail();
                  if (preInstructorEmail != null && !preInstructorEmail.isEmpty()) {
                      EmailLogRequest emailLogRequest = emailLogDao.createEmailLogRequest(systemEmailTemplateResponse.getEmailScenario(), RecipientTypeEnum.INSTRUCTOR, instructorUser.getId(),
                              preInstructorEmail, userEntity.getId(), applicationEntity.getId(), amendmentId, applicationEntity.getCall().getId());
                      sendMail(applicationEntity.getHubId(), subject, body, List.of(preInstructorEmail), emailLogRequest);
                  }
              }
    }
//
//    private String determineService(Long hubId) {
//
//        HubEntity hub = hubRepository.findById(hubId).orElseThrow(() -> new IllegalArgumentException("Invalid Hub ID: " + hubId));
//        return hub.getEmailServiceType().equalsIgnoreCase("MAILGUN_SERVICE") ? "Sviluppumbria" : "Gepafin S.p.a.";
//    }

    public void sendMailToNotifyBeneficiaryRegardingNewAmendment(ApplicationAmendmentRequestEntity applicationAmendmentRequestEntity) {

        ApplicationEntity applicationEntity = applicationService.validateApplication(applicationAmendmentRequestEntity.getApplicationId());
        Map<String, String> bodyPlaceholders = prepareEmailPlaceholders(applicationEntity, applicationAmendmentRequestEntity);
        sendEmail(applicationEntity, SystemEmailTemplatesEntity.SystemEmailTemplatesEntityTypeEnum.DOCUMENTATION_INTEGRATION_REQUEST, bodyPlaceholders, null,
                applicationAmendmentRequestEntity.getId());
    }
    public Map<String, String> prepareEmailPlaceholders(ApplicationEntity applicationEntity, ApplicationAmendmentRequestEntity applicationAmendmentRequestEntity){
        Map<String, String> bodyPlaceholders = new HashMap<>();
        bodyPlaceholders.put("{{call_name}}", applicationEntity.getCall().getName());
        bodyPlaceholders.put("{{protocol_number}}", applicationEntity.getProtocol().getProtocolNumber().toString());
        bodyPlaceholders.put("{{protocol_date}}", DateTimeUtil.formatLocalDateTime(applicationEntity.getProtocol().getCreatedDate(), GepafinConstant.DD_MM_YYYY));
        bodyPlaceholders.put("{{protocol_time}}", DateTimeUtil.parseLocalTimeToString(applicationEntity.getProtocol().getTime(), GepafinConstant.HH_MM_SS));
        bodyPlaceholders.put("{{response_days}}", applicationAmendmentRequestEntity.getResponseDays().toString());

        try {
            // Retrieve forms and initialize required collections
            List<ApplicationFormEntity> forms = applicationFormRepository.findByApplicationId(applicationEntity.getId());
            List<AmendmentFormFieldResponse> allFormFields = new ArrayList<>();
            StringBuilder bulletPoints = new StringBuilder();

            // Extract data from forms
            for (ApplicationFormEntity form : forms) {
                String content = form.getForm().getContent();
                List<Map<String, Object>> result = filterByName(content, "fileupload");
                allFormFields.addAll(getIdAndLabelFromResult(result));
            }

            // Process allFormFields and generate bullet points
            for (AmendmentFormFieldResponse field : allFormFields) {
                // Build bullet points
//                bulletPoints.append(field.getLabel());
                bulletPoints.append("<li>").append(field.getLabel()).append("</li>");

            }
            // Add the generated bullet points to placeholders
            bodyPlaceholders.put("{{form_dataInput}}", bulletPoints.toString());
        } catch (Exception e) {
            log.error("Failed to process form fields: ", e);
        }


        bodyPlaceholders.put("{{note}}", applicationAmendmentRequestEntity.getNote());
        return bodyPlaceholders;
    }

    public List<AmendmentFormFieldResponse> getIdAndLabelFromResult(List<Map<String, Object>> result) {
        List<AmendmentFormFieldResponse> formFieldResponses = new ArrayList<>();

        for (Map<String, Object> item : result) {
            AmendmentFormFieldResponse formFieldResponse = new AmendmentFormFieldResponse();
            formFieldResponse.setFieldId((String) item.get("id"));

            // Extract "label" value from the "settings" array
            List<Map<String, Object>> settings = (List<Map<String, Object>>) item.get("settings");
            String label = settings.stream()
                    .filter(setting -> "label".equals(setting.get("name")))
                    .map(setting -> (String) setting.get("value"))
                    .findFirst()
                    .orElse(""); // Default to empty string if not found

            if (label == null || label.trim().isEmpty()) {
                continue;
            }

            formFieldResponse.setLabel(label); // Set the label as fieldValue
            formFieldResponses.add(formFieldResponse);
        }

        return formFieldResponses;
    }

    public void sendApplicationFailureNotificationEmail(ApplicationAmendmentRequestEntity amendmentRequest) {

        ApplicationEntity applicationEntity = applicationService.validateApplication(amendmentRequest.getApplicationId());
        UserEntity user = userService.validateUser(applicationEntity.getUserId());
        Map<String, String> bodyPlaceholders = new HashMap<>();
        bodyPlaceholders.put("{{call_name}}", applicationEntity.getCall().getName());
        LocalDateTime lastReminderDateTime=amendmentRequest.getCreatedDate();
            List<EmailLogEntity> emailLogEntity = emailLogRepository.findByUserIdAndAmendmentIdAndIsDeletedFalse(user.getId(),amendmentRequest.getId());
            if(emailLogEntity!=null && (!emailLogEntity.isEmpty())){
                EmailLogEntity emailLogEntity1=emailLogEntity.get(0);
                lastReminderDateTime=emailLogEntity1.getSendDateTime();
        }
        bodyPlaceholders.put("{{date_time_emailSend}}", DateTimeUtil.formatLocalDateTime(lastReminderDateTime, GepafinConstant.DD_MM_YYYY));

        sendEmail(applicationEntity, SystemEmailTemplatesEntity.SystemEmailTemplatesEntityTypeEnum.INADMISSIBILITY_NOTIFICATION_DUE_TO_FAILURE, bodyPlaceholders, null,amendmentRequest.getId());
    }

    public void sendAdmissibilityNotificationEmailForApprovedApplication(ApplicationEntity applicationEntity) {
        Map<String, String> bodyPlaceholders = new HashMap<>();
        bodyPlaceholders.put("{{call_name}}", applicationEntity.getCall().getName());
        bodyPlaceholders.put("{{protocol_number}}", applicationEntity.getProtocol().getProtocolNumber().toString());
        bodyPlaceholders.put("{{protocol_date}}", DateTimeUtil.formatCreatedDate(applicationEntity.getProtocol().getCreatedDate()));
        bodyPlaceholders.put("{{protocol_time}}", DateTimeUtil.parseLocalTimeToString(applicationEntity.getProtocol().getTime(), GepafinConstant.HH_MM_SS));

        sendEmail(applicationEntity, SystemEmailTemplatesEntity.SystemEmailTemplatesEntityTypeEnum.ADMISSIBILITY_NOTIFICATION, bodyPlaceholders, null,null);
    }

    public void sendInadmissibilityEmailForRejectedApplication(ApplicationEntity applicationEntity,ApplicationEvaluationEntity applicationEvaluationEntity) {
        Map<String, String> bodyPlaceholders = new HashMap<>();
        bodyPlaceholders.put("{{call_name}}", applicationEntity.getCall().getName());
        bodyPlaceholders.put("{{protocol_number}}", applicationEntity.getProtocol().getProtocolNumber().toString());
        bodyPlaceholders.put("{{protocol_date}}", DateTimeUtil.formatCreatedDate(applicationEntity.getProtocol().getCreatedDate()));
        bodyPlaceholders.put("{{protocol_time}}", DateTimeUtil.parseLocalTimeToString(applicationEntity.getProtocol().getTime(), GepafinConstant.HH_MM_SS));
        bodyPlaceholders.put("{{form_text}}", applicationEvaluationEntity.getNote());

        sendEmail(applicationEntity, SystemEmailTemplatesEntity.SystemEmailTemplatesEntityTypeEnum.INADMISSIBILITY_TEMPLATE, bodyPlaceholders, null,null);
    }

    public void sendMail(Long hubId, String subject, String body, List<String> recipientEmails, EmailLogRequest emailLogRequest) {

        EmailConfig emailConfig = retrieveEmailConfig(hubId);
        EmailService emailService = emailServiceFactory.getEmailService(emailConfig.getEmailServiceType());
        emailService.sendEmail(subject, body, recipientEmails, emailConfig,emailLogRequest);
//        emailService.sendEmail(subject, body, recipientEmails, emailConfig);
    }

    public EmailConfig retrieveEmailConfig(Long hubId) {

        HubEntity hubEntity = hubRepository.findById(hubId).orElseThrow(() -> new IllegalArgumentException("Invalid Hub ID: " + hubId));
        String emailServiceType = hubEntity.getEmailServiceType();
        String encryptedConfigJson = hubEntity.getEmailServiceConfig();
        String decryptedConfigJson = Utils.decryptCredential(encryptedConfigJson);
        EmailConfig emailConfig = parseEmailConfig(decryptedConfigJson);
        emailConfig.setEmailServiceType(emailServiceType);
        return emailConfig;
    }

    private EmailConfig parseEmailConfig(String configJson) {

        ObjectMapper objectMapper = new ObjectMapper();
        try {
            return objectMapper.readValue(configJson, EmailConfig.class);
        } catch (JsonProcessingException e) {
            throw new IllegalArgumentException("Failed to parse email configuration JSON", e);
        }
    }
}