183 lines
9.2 KiB
Java
183 lines
9.2 KiB
Java
package net.gepafin.tendermanagement.scheduler;
|
|
|
|
import jakarta.servlet.http.HttpServletRequest;
|
|
import net.gepafin.tendermanagement.dao.ApplicationAmendmentRequestDao;
|
|
import net.gepafin.tendermanagement.dao.NotificationDao;
|
|
import java.time.LocalDateTime;
|
|
import java.time.LocalTime;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
import java.util.stream.Collectors;
|
|
|
|
import net.gepafin.tendermanagement.entities.ApplicationEntity;
|
|
import net.gepafin.tendermanagement.entities.AssignedApplicationsEntity;
|
|
import net.gepafin.tendermanagement.repositories.ApplicationEvaluationRepository;
|
|
import net.gepafin.tendermanagement.repositories.ApplicationRepository;
|
|
import net.gepafin.tendermanagement.repositories.AssignedApplicationsRepository;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
import net.gepafin.tendermanagement.entities.ApplicationAmendmentRequestEntity;
|
|
import net.gepafin.tendermanagement.entities.ApplicationEvaluationEntity;
|
|
import net.gepafin.tendermanagement.enums.ApplicationAmendmentRequestEnum;
|
|
import net.gepafin.tendermanagement.enums.ApplicationEvaluationStatusTypeEnum;
|
|
import net.gepafin.tendermanagement.enums.ApplicationStatusTypeEnum;
|
|
import net.gepafin.tendermanagement.enums.AssignedApplicationEnum;
|
|
import net.gepafin.tendermanagement.enums.NotificationTypeEnum;
|
|
import net.gepafin.tendermanagement.enums.UserActionContextEnum;
|
|
import net.gepafin.tendermanagement.enums.UserActionLogsEnum;
|
|
import net.gepafin.tendermanagement.enums.VersionActionTypeEnum;
|
|
import net.gepafin.tendermanagement.model.request.UserActionRequest;
|
|
import net.gepafin.tendermanagement.model.request.VersionHistoryRequest;
|
|
import net.gepafin.tendermanagement.repositories.ApplicationAmendmentRequestRepository;
|
|
import net.gepafin.tendermanagement.util.DateTimeUtil;
|
|
import net.gepafin.tendermanagement.util.LoggingUtil;
|
|
import net.gepafin.tendermanagement.util.Utils;
|
|
|
|
@Component
|
|
public class ApplicationAmendmentScheduler {
|
|
|
|
@Autowired
|
|
private HttpServletRequest httpServletRequest;
|
|
|
|
@Autowired
|
|
private ApplicationAmendmentRequestRepository applicationAmendmentRepository;
|
|
|
|
|
|
@Autowired
|
|
private ApplicationAmendmentRequestDao applicationAmendmentRequestDao;
|
|
|
|
@Autowired
|
|
private LoggingUtil loggingUtil;
|
|
|
|
@Autowired
|
|
private NotificationDao notificationDao;
|
|
|
|
@Autowired
|
|
private AssignedApplicationsRepository assignedApplicationsRepository;
|
|
|
|
@Autowired
|
|
private ApplicationRepository applicationRepository;
|
|
|
|
@Autowired
|
|
private ApplicationEvaluationRepository applicationEvaluationRepository;
|
|
|
|
private static final Logger log = LoggerFactory.getLogger(ApplicationAmendmentScheduler.class);
|
|
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
|
public void processAmendmentExpirationScheduler() {
|
|
log.info("Starting the Application Amendment Expiration scheduler.");
|
|
try {
|
|
|
|
Utils.setHttpServletRequestForScheduler();
|
|
|
|
/** This code is responsible for creating user action logs for the "Application Amendment Expiration scheduler" operation. **/
|
|
loggingUtil.logUserActionWithoutToken(
|
|
UserActionRequest.builder().request(httpServletRequest).actionType(UserActionLogsEnum.SCHEDULER).actionContext(UserActionContextEnum.AMENDMENT_EXPIRATION_SCHEDULER).build());
|
|
|
|
List<ApplicationAmendmentRequestEntity> amendmentRequestList = applicationAmendmentRepository
|
|
.findAmendmentsDueForExpiration(
|
|
DateTimeUtil.DateServerToUTC(LocalDateTime.now()).with(LocalTime.MIN).plusSeconds(5));
|
|
processAmendmentsForExpiration(amendmentRequestList);
|
|
log.info("Application Amendment Expiration scheduler completed successfully.");
|
|
} catch (Exception e) {
|
|
log.error("An error occurred during the Application Amendment Expiration scheduler: {}", e.getMessage(), e);
|
|
}
|
|
Utils.clearHttpServletRequest();
|
|
}
|
|
|
|
private void processAmendmentsForExpiration(List<ApplicationAmendmentRequestEntity> amendmentRequests) {
|
|
|
|
log.info("Starting the process of expiring application amendments.");
|
|
amendmentRequests.forEach(request -> {
|
|
try {
|
|
ApplicationAmendmentRequestEntity oldAmendmentRequestEntity = Utils.getClonedEntityForData(request);
|
|
request.setStatus(ApplicationAmendmentRequestEnum.EXPIRED.getValue());
|
|
ApplicationEntity application=oldAmendmentRequestEntity.getApplicationEvaluationEntity().getAssignedApplicationsEntity().getApplication();
|
|
request = applicationAmendmentRepository.save(request);
|
|
Map<String ,String> placeHolders=notificationDao.sendNotificationToBeneficiary(application,NotificationTypeEnum.AMENDMENT_EXPIRED);
|
|
notificationDao.sendNotificationToInstructor(placeHolders,oldAmendmentRequestEntity.getApplicationEvaluationEntity(),NotificationTypeEnum.AMENDMENT_EXPIRED);
|
|
/** This code is responsible for adding a version history log for the "Update Application Amendment" operation. **/
|
|
loggingUtil.addVersionHistory(VersionHistoryRequest.builder().request(httpServletRequest).actionType(VersionActionTypeEnum.UPDATE).oldData(oldAmendmentRequestEntity).newData(request).build());
|
|
|
|
// emailNotificationDao.sendApplicationFailureNotificationEmail(request);
|
|
log.info("Updated status to EXPIRED for ApplicationAmendmentRequest with ID: {}", request.getId());
|
|
} catch (Exception e) {
|
|
log.error("Error expiring ApplicationAmendmentRequest with ID {}: {}", request.getId(), e.getMessage(),
|
|
e);
|
|
}
|
|
});
|
|
log.info("Completed the process of updating expiring application amendments.");
|
|
|
|
log.info("Starting the process of updating EndDate in ApplicationEvaluations.");
|
|
try {
|
|
Set<Long> applicationEvaluationIds = amendmentRequests.stream()
|
|
.map(request -> request.getApplicationEvaluationEntity().getId()).collect(Collectors.toSet());
|
|
|
|
Set<ApplicationEvaluationEntity> evaluationsWithoutActiveAmendmentList = applicationAmendmentRepository
|
|
.findEvaluationsWithoutActiveAmendmentsByIds(applicationEvaluationIds);
|
|
evaluationsWithoutActiveAmendmentList.forEach(evaluation -> {
|
|
try {
|
|
applicationAmendmentRequestDao.calculateEndDateAndSuspensionDaysOnExpirationOrClosing(evaluation);
|
|
|
|
updateEvaluationStatus(evaluation);
|
|
|
|
// Update AssignedApplicationsEntity status
|
|
updateAssignedApplicationStatus(evaluation.getAssignedApplicationsEntity());
|
|
|
|
// Update ApplicationEntity status
|
|
updateApplicationStatus(evaluation.getAssignedApplicationsEntity().getApplication());
|
|
|
|
|
|
log.info("Updated EndDate and suspension days for ApplicationEvaluation with ID: {}",
|
|
evaluation.getId());
|
|
} catch (Exception e) {
|
|
log.error("Error updating EndDate for ApplicationEvaluation with ID {}: {}", evaluation.getId(),
|
|
e.getMessage(), e);
|
|
}
|
|
});
|
|
|
|
log.info("Completed the process of updating EndDate in ApplicationEvaluations.");
|
|
} catch (Exception e) {
|
|
log.error("An error occurred while updating EndDate in ApplicationEvaluations: {}", e.getMessage(), e);
|
|
}
|
|
|
|
}
|
|
|
|
public void updateAssignedApplicationStatus(AssignedApplicationsEntity assignedApplicationsEntity){
|
|
AssignedApplicationsEntity oldAssignedApplicationEntity = Utils.getClonedEntityForData(assignedApplicationsEntity);
|
|
assignedApplicationsEntity.setStatus(AssignedApplicationEnum.OPEN.getValue());
|
|
assignedApplicationsRepository.save(assignedApplicationsEntity);
|
|
log.info("Updated status to OPEN for Assigned Application with ID: {}", assignedApplicationsEntity.getId());
|
|
|
|
/** This code is responsible for adding a version history log for the "Update Assigned Application status" operation. **/
|
|
loggingUtil.addVersionHistory(VersionHistoryRequest.builder().request(httpServletRequest).actionType(VersionActionTypeEnum.UPDATE).oldData(oldAssignedApplicationEntity).newData(assignedApplicationsEntity).build());
|
|
|
|
}
|
|
|
|
public void updateApplicationStatus(ApplicationEntity applicationEntity){
|
|
ApplicationEntity oldApplicationEntity = Utils.getClonedEntityForData(applicationEntity);
|
|
applicationEntity.setStatus(applicationEntity.getPreviousStatus());
|
|
applicationRepository.save(applicationEntity);
|
|
log.info("Updated status to EVALUATION for Application with ID: {}",applicationEntity.getId());
|
|
|
|
/** This code is responsible for adding a version history log for the "Update Application Status" operation. **/
|
|
loggingUtil.addVersionHistory(VersionHistoryRequest.builder().request(httpServletRequest).actionType(VersionActionTypeEnum.UPDATE).oldData(oldApplicationEntity).newData(applicationEntity).build());
|
|
|
|
}
|
|
public void updateEvaluationStatus(ApplicationEvaluationEntity applicationEvaluationEntity){
|
|
ApplicationEvaluationEntity oldApplicationEvaluationEntity = Utils.getClonedEntityForData(applicationEvaluationEntity);
|
|
applicationEvaluationEntity.setStatus(ApplicationEvaluationStatusTypeEnum.OPEN.getValue());
|
|
applicationEvaluationRepository.save(applicationEvaluationEntity);
|
|
log.info("Updated status to OPEN for ApplicationEvaluation with ID: {}", applicationEvaluationEntity.getId());
|
|
|
|
/** This code is responsible for adding a version history log for the "Update Application Status" operation. **/
|
|
loggingUtil.addVersionHistory(VersionHistoryRequest.builder().request(httpServletRequest).actionType(VersionActionTypeEnum.UPDATE).oldData(oldApplicationEvaluationEntity).newData(applicationEvaluationEntity).build());
|
|
|
|
}
|
|
}
|