diff --git a/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java b/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java
index bf25387c..452ecb50 100644
--- a/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java
+++ b/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java
@@ -631,6 +631,8 @@ public class GepafinConstant {
     public static final String APPLICATION_CONTRACT_ALREADY_EXIST="application.contract.already.exist";
     public static final String APPLICATION_NOT_APPROVED="application.not.approved";
     public static final String SUBJECT_AND_BODY_REQUIRED="subject.body.required";
+    public static final String MAIL_SENT_SUCCESSFULLY="mail.send.successfully";
+    public static final String EMAIL_LOG_FETCHED="email.log.fetched";
 
 }
 
diff --git a/src/main/java/net/gepafin/tendermanagement/dao/EmailLogDao.java b/src/main/java/net/gepafin/tendermanagement/dao/EmailLogDao.java
index d95978fd..747c9e83 100644
--- a/src/main/java/net/gepafin/tendermanagement/dao/EmailLogDao.java
+++ b/src/main/java/net/gepafin/tendermanagement/dao/EmailLogDao.java
@@ -3,10 +3,7 @@ package net.gepafin.tendermanagement.dao;
 import jakarta.servlet.http.HttpServletRequest;
 import net.gepafin.tendermanagement.constants.GepafinConstant;
 import net.gepafin.tendermanagement.entities.EmailLogEntity;
-import net.gepafin.tendermanagement.enums.EmailScenarioTypeEnum;
-import net.gepafin.tendermanagement.enums.EmailEntityTypeEnum;
-import net.gepafin.tendermanagement.enums.RecipientTypeEnum;
-import net.gepafin.tendermanagement.enums.VersionActionTypeEnum;
+import net.gepafin.tendermanagement.enums.*;
 import net.gepafin.tendermanagement.model.request.EmailLogRequest;
 import net.gepafin.tendermanagement.model.request.VersionHistoryRequest;
 import net.gepafin.tendermanagement.repositories.EmailLogRepository;
diff --git a/src/main/java/net/gepafin/tendermanagement/dao/PecMailDao.java b/src/main/java/net/gepafin/tendermanagement/dao/PecMailDao.java
new file mode 100644
index 00000000..f24c6be8
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/dao/PecMailDao.java
@@ -0,0 +1,142 @@
+package net.gepafin.tendermanagement.dao;
+
+import jakarta.servlet.http.HttpServletRequest;
+import liquibase.util.Validate;
+import lombok.extern.log4j.Log4j2;
+import net.gepafin.tendermanagement.config.Translator;
+import net.gepafin.tendermanagement.constants.GepafinConstant;
+import net.gepafin.tendermanagement.entities.*;
+import net.gepafin.tendermanagement.enums.EmailServiceTypeEnum;
+import net.gepafin.tendermanagement.enums.StatusTypeEnum;
+import net.gepafin.tendermanagement.model.response.EmailLogResponse;
+import net.gepafin.tendermanagement.model.response.PecEmailLogResponse;
+import net.gepafin.tendermanagement.model.response.PecMailResponse;
+import net.gepafin.tendermanagement.repositories.EmailLogRepository;
+import net.gepafin.tendermanagement.repositories.UserActionsRepository;
+import net.gepafin.tendermanagement.service.ApplicationService;
+import net.gepafin.tendermanagement.service.CallService;
+import net.gepafin.tendermanagement.util.Utils;
+import net.gepafin.tendermanagement.util.Validator;
+import net.gepafin.tendermanagement.web.rest.api.errors.CustomValidationException;
+import net.gepafin.tendermanagement.web.rest.api.errors.ResourceNotFoundException;
+import net.gepafin.tendermanagement.web.rest.api.errors.Status;
+import org.checkerframework.checker.units.qual.A;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Component
+@Log4j2
+public class PecMailDao {
+
+    @Autowired
+    private Validator validator;
+
+    @Autowired
+    private UserActionsRepository userActionsRepository;
+
+    @Autowired
+    private EmailLogRepository emailLogRepository;
+
+    @Autowired
+    private CallService callService;
+
+    @Autowired
+    private EmailNotificationDao emailNotificationDao;
+
+    @Autowired
+    private ApplicationService applicationService;
+
+
+    public PecMailResponse sendPecMail(HttpServletRequest request, List<Long> userActionIds) {
+
+        for (Long userActionId: userActionIds) {
+            List<EmailLogEntity> emailLogs = getEmailLogEntities(request, userActionId);
+            for (EmailLogEntity log : emailLogs) {
+                List<String> recipients = Utils.commaSeparatedStringToList(log.getRecipientEmails());
+                CallEntity call = callService.validateCall(log.getCallId());
+                emailNotificationDao.sendMail(
+                        call.getHub().getId(),
+                        log.getEmailSubject(),
+                        log.getEmailBody(),
+                        recipients,
+                        null
+                );
+
+            }
+        }
+        return null;
+    }
+
+    private List<EmailLogEntity> getEmailLogEntities(HttpServletRequest request, Long userActionId) {
+        UserActionEntity userActionEntity = userActionsRepository.findUserActionByIdAndIsDeletedFalse(userActionId);
+        if (userActionEntity == null) {
+            throw new ResourceNotFoundException(Status.NOT_FOUND, Translator.toLocale(GepafinConstant.USER_ACTION_ID_NOT_FOUND));
+        }
+        validator.validateHubId(request, userActionEntity.getHubId());
+
+        List<EmailLogEntity> emailLogs = emailLogRepository.findByUserActionIdAndEmailServiceTypeAndSendStatus(userActionId, EmailServiceTypeEnum.PEC_SERVICE.getValue(), StatusTypeEnum.PENDING.getValue());
+
+        if (emailLogs.isEmpty()) {
+            log.info("No emails found for given userActionId: {}", userActionId);
+            throw new CustomValidationException(Status.VALIDATION_ERROR, Translator.toLocale(GepafinConstant.NO_EMAIL_LOG_FOUND));
+        }
+        return emailLogs;
+    }
+
+    public List<PecEmailLogResponse> getEmailLogByUserActionId(HttpServletRequest request,Long userActionId){
+        List<EmailLogEntity> emailLogs = getEmailLogEntities(request, userActionId);
+        ApplicationEntity applicationEntity=applicationService.validateApplication(emailLogs.get(0).getApplicationId());
+        String callName=applicationEntity.getCall().getName();
+        List<PecEmailLogResponse> pecEmailLogResponses=new ArrayList<>();
+        for(EmailLogEntity emailLogEntity:emailLogs) {
+            PecEmailLogResponse pecEmailLogResponse = createPecEmailLogResponse(userActionId, emailLogEntity, callName);
+            pecEmailLogResponses.add(pecEmailLogResponse);
+        }
+        return pecEmailLogResponses;
+    }
+
+    private PecEmailLogResponse createPecEmailLogResponse(Long userActionId, EmailLogEntity emailLogEntity, String callName) {
+        PecEmailLogResponse pecEmailLogResponse = new PecEmailLogResponse();
+        pecEmailLogResponse.setId(emailLogEntity.getId());
+        pecEmailLogResponse.setUserActionId(userActionId);
+        pecEmailLogResponse.setUserId(emailLogEntity.getUserId());
+        pecEmailLogResponse.setApplicationId(emailLogEntity.getApplicationId());
+        pecEmailLogResponse.setCallName(callName);
+        EmailLogResponse emailLogResponse=new EmailLogResponse();
+        emailLogResponse.setRecipientId(emailLogEntity.getRecipientId());
+        emailLogResponse.setRecipientType(emailLogEntity.getRecipientType());
+        pecEmailLogResponse.setEmailLogs(emailLogResponse);
+        pecEmailLogResponse.setType(emailLogEntity.getEmailType());
+        pecEmailLogResponse.setSubject(emailLogEntity.getEmailSubject());
+        pecEmailLogResponse.setHtmlContent(emailLogEntity.getEmailBody());
+        pecEmailLogResponse.setCallId(emailLogEntity.getCallId());
+        return pecEmailLogResponse;
+    }
+    private PecMailResponse createPecMailResponse(Long userActionId, EmailLogEntity emailLogEntity, String callName) {
+        PecMailResponse pecMailResponse = new PecMailResponse();
+        pecMailResponse.setId(emailLogEntity.getId());
+        pecMailResponse.setUserActionId(userActionId);
+        pecMailResponse.setUserId(emailLogEntity.getUserId());
+        pecMailResponse.setApplicationId(emailLogEntity.getApplicationId());
+        pecMailResponse.setCallName(callName);
+        pecMailResponse.setType(emailLogEntity.getEmailType());
+        pecMailResponse.setSubject(emailLogEntity.getEmailSubject());
+        pecMailResponse.setHtmlContent(emailLogEntity.getEmailBody());
+        pecMailResponse.setCallId(emailLogEntity.getCallId());
+        return pecMailResponse;
+    }
+    public List<PecMailResponse> getAllEmailLogs(HttpServletRequest request) {
+        List<EmailLogEntity> emailLogs=emailLogRepository.findPendingPECEmailLogs();
+        List<PecMailResponse> pecMailResponses=new ArrayList<>();
+        for (EmailLogEntity emailLogEntity: emailLogs){
+            ApplicationEntity applicationEntity=applicationService.validateApplication(emailLogEntity.getApplicationId());
+            String callName=applicationEntity.getCall().getName();
+            PecMailResponse pecMailResponse=createPecMailResponse(emailLogEntity.getUserAction().getId(),emailLogEntity,callName);
+            pecMailResponses.add(pecMailResponse);
+        }
+    return pecMailResponses;
+    }
+}
diff --git a/src/main/java/net/gepafin/tendermanagement/enums/StatusTypeEnum.java b/src/main/java/net/gepafin/tendermanagement/enums/StatusTypeEnum.java
index dc7c11d5..738a6a17 100644
--- a/src/main/java/net/gepafin/tendermanagement/enums/StatusTypeEnum.java
+++ b/src/main/java/net/gepafin/tendermanagement/enums/StatusTypeEnum.java
@@ -3,7 +3,7 @@ package net.gepafin.tendermanagement.enums;
 import com.fasterxml.jackson.annotation.JsonValue;
 
 public enum StatusTypeEnum {
-
+    PENDING ("PENDING"),
     SUCCESS ("SUCCESS"),
     FAILED("FAILED");
 
diff --git a/src/main/java/net/gepafin/tendermanagement/enums/UserActionContextEnum.java b/src/main/java/net/gepafin/tendermanagement/enums/UserActionContextEnum.java
index 98aca8cf..9401834e 100644
--- a/src/main/java/net/gepafin/tendermanagement/enums/UserActionContextEnum.java
+++ b/src/main/java/net/gepafin/tendermanagement/enums/UserActionContextEnum.java
@@ -229,7 +229,10 @@ public enum UserActionContextEnum {
     UPDATE_APPLICATION_CONTRACT("UPDATE_APPLICATION_CONTRACT"),
     FETCH_APPLICATION_CONTRACT("FETCH_APPLICATION_CONTRACT"),
     FETCH_APPLICATION_CONTRACT_BY_APPLICATION_ID("FETCH_APPLICATION_CONTRACT_BY_APPLICATION_ID"),
-    FETCH_APPLICATION_CONTRACT_BY_BENEFICIARY_USER_ID("FETCH_APPLICATION_CONTRACT_BY_BENEFICIARY_USER_ID");
+    FETCH_APPLICATION_CONTRACT_BY_BENEFICIARY_USER_ID("FETCH_APPLICATION_CONTRACT_BY_BENEFICIARY_USER_ID"),
+    SEND_PEC_MAIL("SEND_PEC_MAIL"),
+    FETCH_EMAIL_LOG("FETCH_EMAIL_LOG"),
+    FETCH_ALL_EMAIL_LOG("FETCH_ALL_EMAIL_LOG");
 
 
     private final String value;
diff --git a/src/main/java/net/gepafin/tendermanagement/model/response/EmailLogResponse.java b/src/main/java/net/gepafin/tendermanagement/model/response/EmailLogResponse.java
new file mode 100644
index 00000000..c6b4ab77
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/model/response/EmailLogResponse.java
@@ -0,0 +1,12 @@
+package net.gepafin.tendermanagement.model.response;
+
+import lombok.Data;
+
+@Data
+public class EmailLogResponse {
+
+    private String recipientType;
+
+    private Long recipientId;
+
+}
diff --git a/src/main/java/net/gepafin/tendermanagement/model/response/PecEmailLogResponse.java b/src/main/java/net/gepafin/tendermanagement/model/response/PecEmailLogResponse.java
new file mode 100644
index 00000000..6b0ada2f
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/model/response/PecEmailLogResponse.java
@@ -0,0 +1,30 @@
+package net.gepafin.tendermanagement.model.response;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class PecEmailLogResponse {
+
+    private Long id;
+
+    private Long userActionId;
+
+    private Long userId;
+
+    private Long applicationId;
+
+    private String callName;
+
+    private EmailLogResponse emailLogs;
+
+    private String type;
+
+    private String subject;
+
+    private String htmlContent;
+
+    private Long callId;
+
+}
diff --git a/src/main/java/net/gepafin/tendermanagement/model/response/PecMailResponse.java b/src/main/java/net/gepafin/tendermanagement/model/response/PecMailResponse.java
new file mode 100644
index 00000000..b613772d
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/model/response/PecMailResponse.java
@@ -0,0 +1,28 @@
+package net.gepafin.tendermanagement.model.response;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class PecMailResponse {
+
+    private Long id;
+
+    private Long userActionId;
+
+    private Long userId;
+
+    private Long applicationId;
+
+    private String callName;
+
+    private String type;
+
+    private String subject;
+
+    private String htmlContent;
+
+    private Long callId;
+
+}
diff --git a/src/main/java/net/gepafin/tendermanagement/repositories/EmailLogRepository.java b/src/main/java/net/gepafin/tendermanagement/repositories/EmailLogRepository.java
index 9d9e26e5..0d6a2202 100644
--- a/src/main/java/net/gepafin/tendermanagement/repositories/EmailLogRepository.java
+++ b/src/main/java/net/gepafin/tendermanagement/repositories/EmailLogRepository.java
@@ -3,6 +3,7 @@ package net.gepafin.tendermanagement.repositories;
 import net.gepafin.tendermanagement.entities.EmailLogEntity;
 import net.gepafin.tendermanagement.entities.UserEntity;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
 
 import java.util.List;
 import java.util.Optional;
@@ -23,6 +24,10 @@ public interface EmailLogRepository extends JpaRepository<EmailLogEntity,Long> {
             String sendStatus
     );
 
+    @Query(value = """
+    SELECT DISTINCT ON (user_action_id) * FROM email_log WHERE send_status = 'PENDING' AND is_deleted = false AND email_service_type = 'PEC_SERVICE'  """, nativeQuery = true)
+    List<EmailLogEntity> findPendingPECEmailLogs();
+
 
 
 }
diff --git a/src/main/java/net/gepafin/tendermanagement/service/PecMailService.java b/src/main/java/net/gepafin/tendermanagement/service/PecMailService.java
new file mode 100644
index 00000000..2d7dbd30
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/service/PecMailService.java
@@ -0,0 +1,16 @@
+package net.gepafin.tendermanagement.service;
+
+import jakarta.servlet.http.HttpServletRequest;
+import net.gepafin.tendermanagement.model.response.PecEmailLogResponse;
+import net.gepafin.tendermanagement.model.response.PecMailResponse;
+
+import java.util.List;
+
+public interface PecMailService {
+
+    public PecMailResponse sendPecMail(HttpServletRequest request, List<Long> userActionIds);
+
+    public List<PecEmailLogResponse> getEmailLogByUserActionId(HttpServletRequest request, Long userActionId);
+
+    public List<PecMailResponse> getAllEmailLogs(HttpServletRequest request);
+}
diff --git a/src/main/java/net/gepafin/tendermanagement/service/impl/PecMailSerivceImpl.java b/src/main/java/net/gepafin/tendermanagement/service/impl/PecMailSerivceImpl.java
new file mode 100644
index 00000000..507923be
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/service/impl/PecMailSerivceImpl.java
@@ -0,0 +1,33 @@
+package net.gepafin.tendermanagement.service.impl;
+
+import jakarta.servlet.http.HttpServletRequest;
+import net.gepafin.tendermanagement.dao.PecMailDao;
+import net.gepafin.tendermanagement.model.response.PecEmailLogResponse;
+import net.gepafin.tendermanagement.model.response.PecMailResponse;
+import net.gepafin.tendermanagement.service.PecMailService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class PecMailSerivceImpl implements PecMailService {
+
+    @Autowired
+    private PecMailDao pecMailDao;
+
+    @Override
+    public PecMailResponse sendPecMail(HttpServletRequest request, List<Long> userActionIds) {
+        return pecMailDao.sendPecMail(request,userActionIds);
+    }
+
+    @Override
+    public List<PecEmailLogResponse> getEmailLogByUserActionId(HttpServletRequest request, Long userActionId) {
+        return pecMailDao.getEmailLogByUserActionId(request,userActionId);
+    }
+
+    @Override
+    public List<PecMailResponse> getAllEmailLogs(HttpServletRequest request) {
+        return pecMailDao.getAllEmailLogs(request);
+    }
+}
diff --git a/src/main/java/net/gepafin/tendermanagement/web/rest/api/PecMailApi.java b/src/main/java/net/gepafin/tendermanagement/web/rest/api/PecMailApi.java
new file mode 100644
index 00000000..34315491
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/web/rest/api/PecMailApi.java
@@ -0,0 +1,56 @@
+package net.gepafin.tendermanagement.web.rest.api;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.ExampleObject;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import jakarta.servlet.http.HttpServletRequest;
+import net.gepafin.tendermanagement.model.request.NotificationReq;
+import net.gepafin.tendermanagement.model.response.NotificationResponse;
+import net.gepafin.tendermanagement.model.response.PecEmailLogResponse;
+import net.gepafin.tendermanagement.model.response.PecMailResponse;
+import net.gepafin.tendermanagement.model.util.Response;
+import net.gepafin.tendermanagement.web.rest.api.errors.ErrorConstants;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+public interface PecMailApi {
+
+    @Operation(summary = "Api to send mail from pec.", responses = { @ApiResponse(responseCode = "200", description = "OK"),
+            @ApiResponse(responseCode = "404", description = "Not Found", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.NOTFOUND_ERROR_EXAMPLE))),
+            @ApiResponse(responseCode = "401", description = "Unauthorized", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.UNAUTHORIZED_ERROR_EXAMPLE))),
+            @ApiResponse(responseCode = "400", description = "Bad Request", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.BADREQUEST_ERROR_EXAMPLE))) })
+    @PostMapping(value = "/userAction", produces = "application/json")
+    ResponseEntity<Response<PecMailResponse>> sendPecMail(HttpServletRequest request,
+                                                          @Parameter(description = "The user action id", required = true) @RequestParam("userActionIds") List<Long> userActionIds);
+
+
+    @Operation(summary = "Api to get email log by user action id", responses = { @ApiResponse(responseCode = "200", description = "OK"),
+            @ApiResponse(responseCode = "404", description = "Not Found", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.NOTFOUND_ERROR_EXAMPLE))),
+            @ApiResponse(responseCode = "401", description = "Unauthorized", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.UNAUTHORIZED_ERROR_EXAMPLE))),
+            @ApiResponse(responseCode = "400", description = "Bad Request", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.BADREQUEST_ERROR_EXAMPLE))) })
+    @GetMapping(value = "/userAction/{userActionId}", produces = "application/json")
+    ResponseEntity<Response<List<PecEmailLogResponse>>> getEmailLogByUserActionId(HttpServletRequest request,
+                                                                                  @Parameter(description = "The user action id", required = true) @PathVariable("userActionId") Long userActionId);
+
+    @Operation(summary = "Api to get all email logs", responses = { @ApiResponse(responseCode = "200", description = "OK"),
+            @ApiResponse(responseCode = "404", description = "Not Found", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.NOTFOUND_ERROR_EXAMPLE))),
+            @ApiResponse(responseCode = "401", description = "Unauthorized", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.UNAUTHORIZED_ERROR_EXAMPLE))),
+            @ApiResponse(responseCode = "400", description = "Bad Request", content = @Content(mediaType = MediaType.APPLICATION_JSON_VALUE, examples = @ExampleObject(value =
+                    ErrorConstants.BADREQUEST_ERROR_EXAMPLE))) })
+    @GetMapping(value = "",produces = "application/json")
+    ResponseEntity<Response<List<PecMailResponse>>> getAllEmailLogs(HttpServletRequest request);
+
+}
diff --git a/src/main/java/net/gepafin/tendermanagement/web/rest/api/impl/PecMailController.java b/src/main/java/net/gepafin/tendermanagement/web/rest/api/impl/PecMailController.java
new file mode 100644
index 00000000..ca3c7c35
--- /dev/null
+++ b/src/main/java/net/gepafin/tendermanagement/web/rest/api/impl/PecMailController.java
@@ -0,0 +1,69 @@
+package net.gepafin.tendermanagement.web.rest.api.impl;
+
+import jakarta.servlet.http.HttpServletRequest;
+import net.gepafin.tendermanagement.config.Translator;
+import net.gepafin.tendermanagement.constants.GepafinConstant;
+import net.gepafin.tendermanagement.enums.UserActionContextEnum;
+import net.gepafin.tendermanagement.enums.UserActionLogsEnum;
+import net.gepafin.tendermanagement.model.request.UserActionRequest;
+import net.gepafin.tendermanagement.model.response.ApplicationAmendmentRequestResponse;
+import net.gepafin.tendermanagement.model.response.PecEmailLogResponse;
+import net.gepafin.tendermanagement.model.response.PecMailResponse;
+import net.gepafin.tendermanagement.model.util.Response;
+import net.gepafin.tendermanagement.service.PecMailService;
+import net.gepafin.tendermanagement.util.LoggingUtil;
+import net.gepafin.tendermanagement.web.rest.api.PecMailApi;
+import net.gepafin.tendermanagement.web.rest.api.errors.Status;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("${openapi.gepafin.base-path:/v1/pecMail}")
+public class PecMailController implements PecMailApi {
+
+    @Autowired
+    private LoggingUtil loggingUtil;
+
+    @Autowired
+    private PecMailService pecMailService;
+
+    @Override
+    public ResponseEntity<Response<PecMailResponse>> sendPecMail(HttpServletRequest request,List<Long> userActionIds) {
+        loggingUtil.logUserAction(UserActionRequest.builder().request(request).actionType(UserActionLogsEnum.EMAIL)
+                .actionContext(UserActionContextEnum.SEND_PEC_MAIL).build());
+
+//        PecMailResponse pecMailResponse=pecMailService.sendPecMail(request,userActionId);
+
+        return ResponseEntity.status(HttpStatus.OK)
+                .body(new Response<>(null, Status.SUCCESS, Translator.toLocale(GepafinConstant.MAIL_SENT_SUCCESSFULLY)));
+
+    }
+
+    @Override
+    public ResponseEntity<Response<List<PecEmailLogResponse>>> getEmailLogByUserActionId(HttpServletRequest request, Long userActionId) {
+        loggingUtil.logUserAction(UserActionRequest.builder().request(request).actionType(UserActionLogsEnum.EMAIL)
+                .actionContext(UserActionContextEnum.FETCH_EMAIL_LOG).build());
+
+        List<PecEmailLogResponse> pecEmailLogResponse=pecMailService.getEmailLogByUserActionId(request,userActionId);
+
+        return ResponseEntity.status(HttpStatus.OK)
+                .body(new Response<>(pecEmailLogResponse, Status.SUCCESS, Translator.toLocale(GepafinConstant.EMAIL_LOG_FETCHED)));
+
+    }
+
+    @Override
+    public ResponseEntity<Response<List<PecMailResponse>>> getAllEmailLogs(HttpServletRequest request) {
+        loggingUtil.logUserAction(UserActionRequest.builder().request(request).actionType(UserActionLogsEnum.EMAIL)
+                .actionContext(UserActionContextEnum.FETCH_ALL_EMAIL_LOG).build());
+
+        List<PecMailResponse> pecMailResponses=pecMailService.getAllEmailLogs(request);
+
+        return ResponseEntity.status(HttpStatus.OK)
+                .body(new Response<>(pecMailResponses, Status.SUCCESS, Translator.toLocale(GepafinConstant.EMAIL_LOG_FETCHED)));
+    }
+}
diff --git a/src/main/resources/db/changelog/db.changelog-1.0.0.xml b/src/main/resources/db/changelog/db.changelog-1.0.0.xml
index e96d0bf7..178e4ad4 100644
--- a/src/main/resources/db/changelog/db.changelog-1.0.0.xml
+++ b/src/main/resources/db/changelog/db.changelog-1.0.0.xml
@@ -3135,4 +3135,33 @@
     <changeSet id="04-11-2025_RK_151527" author="Rajesh Khore">
         <sqlFile dbms="postgresql" path="db/dump/insert_notification_template_for_contract_upload.sql"/>
     </changeSet>
+
+    <changeSet id="07-11-2025_RK_143942" author="Rajesh Khore">
+        <insert tableName="role">
+            <column name="role_name" value="director"/>
+            <column name="role_type" value="ROLE_DIRECTOR"/>
+            <column name="description"
+                    value="They can evaluate email and send emails."/>
+            <column name="created_date" value="2025-11-07 00:00:00"/>
+            <column name="updated_date" value="2025-11-07 00:00:00"/>
+            <column name="permissions" value=""/>
+            <column name="region_id" valueComputed="1"/>
+        </insert>
+
+        <insert tableName="GEPAFIN_USER">
+            <column name="email" value="director@test.test"/>
+            <column name="password" value="$2a$10$doUyOcEm8WPuFfpFT5y18.1DvZzF7exbqgy9X0P27cUBK7YWbfzzS"/>
+            <column name="first_name" value="Test"/>
+            <column name="last_name" value="Director"/>
+            <column name="last_login" value="2025-11-07 00:00:00"/>
+            <column name="organization" value="DirectorOrg"/>
+            <column name="role_id" valueComputed="(SELECT id FROM role WHERE role_type = 'ROLE_DIRECTOR')"/>
+            <column name="status" value="ACTIVE"/>
+            <column name="last_login" value="2025-11-07 00:00:00"/>
+            <column name="address" value="789 Victory Road"/>
+            <column name="city" value="Naples"/>
+            <column name="country" value="Italy"/>
+            <column name="hub_id" value="1"/>
+        </insert>
+    </changeSet>
 </databaseChangeLog>
diff --git a/src/main/resources/message_en.properties b/src/main/resources/message_en.properties
index 48b7a1d6..a2aeca61 100644
--- a/src/main/resources/message_en.properties
+++ b/src/main/resources/message_en.properties
@@ -424,3 +424,4 @@ files.required.for.contract=Files are required for contract.
 application.contract.already.exist=Application contract already exist for this application.
 application.not.approved=Application is not approved.
 subject.body.required=Subject and body is required to create contract.
+mail.send.successfully=Mail sent succesfully.
diff --git a/src/main/resources/message_it.properties b/src/main/resources/message_it.properties
index 9a0f2724..8507f202 100644
--- a/src/main/resources/message_it.properties
+++ b/src/main/resources/message_it.properties
@@ -415,3 +415,4 @@ files.required.for.contract=I file sono necessari per il contratto.
 application.contract.already.exist=Il contratto di applicazione esiste già per questa applicazione.
 application.not.approved=La domanda non è stata approvata.
 subject.body.required=Per creare un contratto sono necessari oggetto e corpo.
+mail.send.successfully=Email inviata con successo.