diff --git a/pom.xml b/pom.xml
index e59892b4..daa067ba 100644
--- a/pom.xml
+++ b/pom.xml
@@ -251,6 +251,13 @@
0.4.8
+
+ org.apache.commons
+ commons-csv
+ 1.10.0
+
+
+
@@ -282,8 +289,8 @@
liquibase-maven-plugin
src/main/resources/application.properties
-
-
-
+
+
+
diff --git a/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java b/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java
index c7bf075e..5c849a47 100644
--- a/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java
+++ b/src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java
@@ -101,6 +101,7 @@ public class GepafinConstant {
public static final String STATUS_SAME_ERROR = "status.same.error";
public static final String INVALID_STATUS_CHANGE_FROM_DRAFT = "invalid.status.change.from.draft";
public static final String INVALID_STATUS_CHANGE_FROM_PUBLISH = "invalid.status.change.from.publish";
+ public static final String INVALID_STATUS_CHANGE_FROM_PUBLISH_TO_DRAFT = "invalid.status.change.from.publish.to.draft";
public static final String STATUS_CANNOT_BE_CHANGED = "status.cannot.be.changed";
public static final String PUBLISHED_CALL_NOT_UPDATE = "published.call.not.update";
public static final String INVALID_USER = "invalid_user";
@@ -136,8 +137,9 @@ public class GepafinConstant {
public static final String UPDATING_FORM_VALUE_IMPACT_ON_FLOW = "updating.form.value.impact.on.flow";
public static final String APPLICATION_IS_INCOMPLETE_MSG = "application.is.incomplete";
public static final String AUTHORIZATION = "Authorization";
- public static final String CHECK_VATNUMBER_V2_NEW_URL = "https://imprese.openapi.it/advance";
- public static final String CHECK_VATNUMBER_V2_NEW_URL_IT_ADVANCE = "https://company.openapi.com/IT-advanced";
+ public static final String CHECK_VATNUMBER_URL_V1 = "https://imprese.openapi.it/advance";
+ public static final String CHECK_VATNUMBER_URL_V2 = "https://company.openapi.com/IT-advanced";
+ public static final String VAT_CHECK_API_VERSION = "VAT_CHECK_API_VERSION";
public static final String VALIDATION_FIELD_CUSTOM = "validation.field.custom";
public static final String VALIDATION_CODICE_FISCALE = "validation.codice.fiscale";
public static final String VALIDATION_CAP = "validation.cap";
@@ -504,6 +506,35 @@ public class GepafinConstant {
public static final String APPLICATION="application";
public static final String APPLICATION_ID="applicationId";
public static final String USER_WITH_COMPANY_ID="userWithCompanyId";
+ public static final String ASSIGNED_USER_ID="assignedUserId";
+ public static final String APPLICATION_USER_ID="applicationUserId";
+ public static final String INVALID_USER_ID="invalid.user";
+ public static final String COMPANY_NAME="companyName";
+ public static final String TABLE_COLUMNS="table_columns";
+ public static final String PREDEFINED="predefined";
+ public static final String EBABLE_CSV="enableCsv";
+ public static final String LABEL_CSV="labelCsv";
+ public static final String GET="get";
+ public static final String REPORT_COLUMNS="reportColumns";
+ public static final String FIELD_TYPE="fieldtype";
+ public static final String ENABLE_FORMULA="enableFormula";
+ public static final String STATE_FIELD_DATA="stateFieldData";
+ public static final String REPORT_ENABLE="reportEnable";
+ public static final String TABLE="table";
+ public static final String GET_FIELD_TYPE="getFieldType";
+ public static final String GET_APPLICATION_FORM_ID="getApplicationFormId";
+ public static final String GET_APPLICATION_ID="getApplicationId";
+ public static final String GET_ID="getId";
+ public static final String GET_CLASS="getClass";
+ public static final String GET_FORM_ID="getFormId";
+ public static final String GET_FIELD_ID="getFieldId";
+ public static final String GET_FIELD_LABEL="getFieldLabel";
+ public static final String GET_FIELD_VALUE="getFieldValue";
+ public static final String GET_REPORT_ENABLE="getReportEnable";
+ public static final String GET_REPORT_HEADER="getReportHeader";
+
+ public static final String APPOINTMENT_ID="appointmentId";
+ public static final String APPLICATION_STATUS="applicationStatus";
public static final String RINALDO_EMAIL = "rinaldo.bonazzo@bflows.net";
}
diff --git a/src/main/java/net/gepafin/tendermanagement/dao/ApplicationAmendmentRequestDao.java b/src/main/java/net/gepafin/tendermanagement/dao/ApplicationAmendmentRequestDao.java
index a766d1a5..daa4391b 100644
--- a/src/main/java/net/gepafin/tendermanagement/dao/ApplicationAmendmentRequestDao.java
+++ b/src/main/java/net/gepafin/tendermanagement/dao/ApplicationAmendmentRequestDao.java
@@ -134,6 +134,12 @@ public class ApplicationAmendmentRequestDao {
@Autowired
private ApplicationEvaluationFormRepository applicationEvaluationFormRepository;
+ @Autowired
+ private ApplicationAmendmentRequestViewRepository applicationAmendmentRequestViewRepository;
+
+ @Autowired
+ private ApplicationDao applicationDao;
+
public ApplicationAmendmentRequestResponse getApplicationDataForAmendment(Long applicationEvaluationId) {
log.info("Fetching the application data for the Amendment process {}", applicationEvaluationId);
ApplicationEvaluationEntity applicationEvaluationEntity = applicationEvaluationService.validateApplicationEvaluation(applicationEvaluationId);
@@ -1268,7 +1274,122 @@ public class ApplicationAmendmentRequestDao {
documentService.deleteFile(documentId);
}
- public PageableResponseBean> getApplicationAmendmentByPaginnation(Long userId, ApplicationAmendmentPaginationRequestBean applicationAmendmentPaginationRequestBean) {
+// public PageableResponseBean> getApplicationAmendmentByPaginnation(Long userId, ApplicationAmendmentPaginationRequestBean applicationAmendmentPaginationRequestBean) {
+// Integer pageNo = null;
+// Integer pageLimit = null;
+// if (applicationAmendmentPaginationRequestBean.getGlobalFilters() != null) {
+// pageNo = applicationAmendmentPaginationRequestBean.getGlobalFilters().getPage();
+// pageLimit = applicationAmendmentPaginationRequestBean.getGlobalFilters().getLimit();
+// }
+// if (pageLimit == null || pageLimit <= 0) {
+// pageLimit = GepafinConstant.DEFAULT_PAGE_LIMIT;
+// }
+// if (pageNo == null || pageNo <= 0) {
+// pageNo = GepafinConstant.DEFAULT_PAGE;
+// }
+// Specification spec = searchPagination(userId,applicationAmendmentPaginationRequestBean);
+// Page entityPage = applicationAmendmentRequestRepository.findAll(spec, PageRequest.of(pageNo - 1, pageLimit));
+//
+//
+// List applicationResponses = entityPage.getContent().stream()
+// .map(application -> {
+// ApplicationAmendmentRequestResponse response = convertEntityToResponse(application,false);
+// return response;
+// })
+// .collect(Collectors.toList());
+//
+//
+// PageableResponseBean> pageableResponseBean = new PageableResponseBean<>();
+// pageableResponseBean.setBody(applicationResponses);
+// pageableResponseBean.setCurrentPage(entityPage.getNumber() + 1); // Page numbers typically start from 0, so add 1 for user-friendly indexing
+// pageableResponseBean.setTotalPages(entityPage.getTotalPages());
+// pageableResponseBean.setTotalRecords(entityPage.getTotalElements());
+// pageableResponseBean.setPageSize(entityPage.getSize());
+//
+// return pageableResponseBean;
+// }
+//
+// public Specification searchPagination(Long userId,ApplicationAmendmentPaginationRequestBean applicationAmendmentPaginationRequestBean) {
+// return (root, query, criteriaBuilder) -> {
+//
+// List predicates = getPredicates(applicationAmendmentPaginationRequestBean, criteriaBuilder, root,userId);
+// SortBy sortBy = new SortBy(GepafinConstant.CREATED_DATE, true);
+//
+// if (applicationAmendmentPaginationRequestBean .getGlobalFilters() != null
+// && applicationAmendmentPaginationRequestBean.getGlobalFilters().getSortBy() != null &&
+// applicationAmendmentPaginationRequestBean.getGlobalFilters().getSortBy().getColumnName() != null && Boolean.FALSE.equals(
+// isEmpty(applicationAmendmentPaginationRequestBean.getGlobalFilters().getSortBy().getColumnName()))) {
+// sortBy.setColumnName(applicationAmendmentPaginationRequestBean.getGlobalFilters().getSortBy().getColumnName());
+// sortBy.setSortDesc(true);
+// if (applicationAmendmentPaginationRequestBean.getGlobalFilters().getSortBy().getSortDesc() != null) {
+// sortBy.setSortDesc(applicationAmendmentPaginationRequestBean.getGlobalFilters().getSortBy().getSortDesc());
+// }
+// }
+//
+// query.orderBy(criteriaBuilder.desc(root.get(sortBy.getColumnName())));
+// if (Boolean.FALSE.equals(sortBy.getSortDesc())) {
+// query.orderBy(criteriaBuilder.asc(root.get(sortBy.getColumnName())));
+// }
+// return query.where(criteriaBuilder.and(predicates.toArray(new Predicate[0]))).getRestriction();
+// };
+// }
+//
+//
+// private List getPredicates(ApplicationAmendmentPaginationRequestBean amendmentPaginationRequestBean,
+// CriteriaBuilder criteriaBuilder, Root root,Long userId) {
+//
+// Integer year = null;
+// String search = null;
+// if (amendmentPaginationRequestBean.getGlobalFilters() != null) {
+// year = amendmentPaginationRequestBean.getGlobalFilters().getYear();
+// search = amendmentPaginationRequestBean.getGlobalFilters().getSearch();
+// }
+// List predicates = new ArrayList<>();
+//
+// if (year != null && year > 0) {
+// int filterYear = amendmentPaginationRequestBean.getGlobalFilters().getYear();
+//
+//// Create LocalDateTime boundaries for the start and end of the year
+// LocalDateTime startOfYear = LocalDateTime.of(filterYear, 1, 1, 0, 0);
+// LocalDateTime endOfYear = LocalDateTime.of(filterYear, 12, 31, 23, 59, 59);
+//
+//// Add the range comparison to filter records within the year
+// predicates.add(criteriaBuilder.between(root.get(GepafinConstant.CREATED_DATE), startOfYear, endOfYear));
+//
+// }
+// // Search in `title` and `message` (if search term is provided)
+// if (search != null && !search.isEmpty()) {
+// Predicate notePredicate = criteriaBuilder.like(
+// criteriaBuilder.upper(root.get(GepafinConstant.NOTE)),
+// "%" + search.toUpperCase() + "%"
+// );
+// predicates.add(criteriaBuilder.or(notePredicate));
+// Predicate internalNotePredicate = criteriaBuilder.like(
+// criteriaBuilder.upper(root.get(GepafinConstant.INTERNAL_NOTE)),
+// "%" + search.toUpperCase() + "%"
+// );
+// predicates.add(criteriaBuilder.or(internalNotePredicate));
+// }
+//
+// // Filter by `status` (if status list is provided)
+// if (amendmentPaginationRequestBean.getStatus() != null && !amendmentPaginationRequestBean.getStatus().isEmpty()) {
+// List statusValues = amendmentPaginationRequestBean.getStatus().stream()
+// .map(ApplicationAmendmentRequestEnum::name) // Convert enum to string
+// .toList();
+// predicates.add(root.get(GepafinConstant.STATUS).in(statusValues));
+// }
+// if(Boolean.TRUE.equals(validator.checkIsBeneficiary()) || Boolean.TRUE.equals(validator.checkIsConfidi())) {
+// predicates.add(root.get("applicationEvaluationEntity").get("assignedApplicationsEntity").get("application").get("userId").in(userId));
+// }
+// else {
+// predicates.add(root.get("applicationEvaluationEntity").get("assignedApplicationsEntity").get("userId").in(userId));
+// }
+//
+// return predicates;
+//
+// }
+
+ public PageableResponseBean> getApplicationAmendmentByPaginationByView(Long userId, ApplicationAmendmentPaginationRequestBean applicationAmendmentPaginationRequestBean) {
Integer pageNo = null;
Integer pageLimit = null;
if (applicationAmendmentPaginationRequestBean.getGlobalFilters() != null) {
@@ -1281,20 +1402,20 @@ public class ApplicationAmendmentRequestDao {
if (pageNo == null || pageNo <= 0) {
pageNo = GepafinConstant.DEFAULT_PAGE;
}
- Specification spec = searchPagination(userId,applicationAmendmentPaginationRequestBean);
- Page entityPage = applicationAmendmentRequestRepository.findAll(spec, PageRequest.of(pageNo - 1, pageLimit));
+ Specification spec = searchPaginationByView(userId,applicationAmendmentPaginationRequestBean);
+ Page entityPage = applicationAmendmentRequestViewRepository.findAll(spec, PageRequest.of(pageNo - 1, pageLimit));
- List applicationResponses = entityPage.getContent().stream()
- .map(application -> {
- ApplicationAmendmentRequestResponse response = convertEntityToResponse(application,false);
+ List applicationAmendmentRequestViewResponses = entityPage.getContent().stream()
+ .map(amendmentRequestView -> {
+ ApplicationAmendmentRequestViewResponse response = convertAmendmentEntityToApplicationAmendmentRequestViewResponse(amendmentRequestView);
return response;
})
.collect(Collectors.toList());
- PageableResponseBean> pageableResponseBean = new PageableResponseBean<>();
- pageableResponseBean.setBody(applicationResponses);
+ PageableResponseBean> pageableResponseBean = new PageableResponseBean<>();
+ pageableResponseBean.setBody(applicationAmendmentRequestViewResponses);
pageableResponseBean.setCurrentPage(entityPage.getNumber() + 1); // Page numbers typically start from 0, so add 1 for user-friendly indexing
pageableResponseBean.setTotalPages(entityPage.getTotalPages());
pageableResponseBean.setTotalRecords(entityPage.getTotalElements());
@@ -1302,11 +1423,10 @@ public class ApplicationAmendmentRequestDao {
return pageableResponseBean;
}
-
- public Specification searchPagination(Long userId,ApplicationAmendmentPaginationRequestBean applicationAmendmentPaginationRequestBean) {
+ public Specification searchPaginationByView(Long userId,ApplicationAmendmentPaginationRequestBean applicationAmendmentPaginationRequestBean) {
return (root, query, criteriaBuilder) -> {
- List predicates = getPredicates(applicationAmendmentPaginationRequestBean, criteriaBuilder, root,userId);
+ List predicates = getPredicatesByView(applicationAmendmentPaginationRequestBean, criteriaBuilder, root,userId);
SortBy sortBy = new SortBy(GepafinConstant.CREATED_DATE, true);
if (applicationAmendmentPaginationRequestBean .getGlobalFilters() != null
@@ -1329,15 +1449,19 @@ public class ApplicationAmendmentRequestDao {
}
- private List getPredicates(ApplicationAmendmentPaginationRequestBean amendmentPaginationRequestBean,
- CriteriaBuilder criteriaBuilder, Root root,Long userId) {
+ private List getPredicatesByView(ApplicationAmendmentPaginationRequestBean amendmentPaginationRequestBean,
+ CriteriaBuilder criteriaBuilder, Root root,Long userId) {
Integer year = null;
String search = null;
+ Map filters = new HashMap<>();
if (amendmentPaginationRequestBean.getGlobalFilters() != null) {
year = amendmentPaginationRequestBean.getGlobalFilters().getYear();
search = amendmentPaginationRequestBean.getGlobalFilters().getSearch();
}
+ if (amendmentPaginationRequestBean.getFilters() != null) {
+ filters = amendmentPaginationRequestBean.getFilters();
+ }
List predicates = new ArrayList<>();
if (year != null && year > 0) {
@@ -1351,19 +1475,37 @@ public class ApplicationAmendmentRequestDao {
predicates.add(criteriaBuilder.between(root.get(GepafinConstant.CREATED_DATE), startOfYear, endOfYear));
}
- // Search in `title` and `message` (if search term is provided)
+
if (search != null && !search.isEmpty()) {
- Predicate notePredicate = criteriaBuilder.like(
- criteriaBuilder.upper(root.get(GepafinConstant.NOTE)),
+ List searchPredicates = new ArrayList<>();
+
+ searchPredicates.add(criteriaBuilder.like(
+ criteriaBuilder.upper(root.get(GepafinConstant.CALL_NAME)),
"%" + search.toUpperCase() + "%"
- );
- predicates.add(criteriaBuilder.or(notePredicate));
- Predicate internalNotePredicate = criteriaBuilder.like(
- criteriaBuilder.upper(root.get(GepafinConstant.INTERNAL_NOTE)),
+ ));
+
+ searchPredicates.add(criteriaBuilder.like(
+ criteriaBuilder.upper(root.get(GepafinConstant.COMPANY_NAME)),
"%" + search.toUpperCase() + "%"
- );
- predicates.add(criteriaBuilder.or(internalNotePredicate));
+ ));
+
+ // Uncomment these if needed
+ // searchPredicates.add(criteriaBuilder.like(
+ // criteriaBuilder.upper(root.get(GepafinConstant.NOTE)),
+ // "%" + search.toUpperCase() + "%"
+ // ));
+ //
+ // searchPredicates.add(criteriaBuilder.like(
+ // criteriaBuilder.upper(root.get(GepafinConstant.INTERNAL_NOTE)),
+ // "%" + search.toUpperCase() + "%"
+ // ));
+
+ Predicate finalPredicate = criteriaBuilder.or(searchPredicates.toArray(new Predicate[0]));
+
+ predicates.add(finalPredicate);
}
+ Utils.applyFiltersByPagination(root, criteriaBuilder, predicates, filters);
+
// Filter by `status` (if status list is provided)
if (amendmentPaginationRequestBean.getStatus() != null && !amendmentPaginationRequestBean.getStatus().isEmpty()) {
@@ -1372,14 +1514,33 @@ public class ApplicationAmendmentRequestDao {
.toList();
predicates.add(root.get(GepafinConstant.STATUS).in(statusValues));
}
- if(Boolean.TRUE.equals(validator.checkIsBeneficiary()) || Boolean.TRUE.equals(validator.checkIsConfidi())) {
- predicates.add(root.get("applicationEvaluationEntity").get("assignedApplicationsEntity").get("application").get("userId").in(userId));
- }
- else {
- predicates.add(root.get("applicationEvaluationEntity").get("assignedApplicationsEntity").get("userId").in(userId));
+ boolean isBeneficiaryOrConfidi = validator.checkIsBeneficiary() || validator.checkIsConfidi();
+ boolean isPreInstructor = validator.checkIsPreInstructor();
+ boolean isInstructorManagerWithPersonalRecords = validator.checkIsInstructorManager() &&
+ Boolean.TRUE.equals(amendmentPaginationRequestBean.getPersonalRecords());
+
+ if (isBeneficiaryOrConfidi) {
+ predicates.add(root.get(GepafinConstant.APPLICATION_USER_ID).in(userId));
+ } else if (isPreInstructor || isInstructorManagerWithPersonalRecords) {
+ predicates.add(root.get(GepafinConstant.ASSIGNED_USER_ID).in(userId));
}
return predicates;
}
+ public ApplicationAmendmentRequestViewResponse convertAmendmentEntityToApplicationAmendmentRequestViewResponse(ApplicationAmendmentRequestView applicationAmendmentRequestView){
+ ApplicationAmendmentRequestViewResponse applicationAmendmentRequestViewResponse=new ApplicationAmendmentRequestViewResponse();
+ applicationAmendmentRequestViewResponse.setId(applicationAmendmentRequestView.getId());
+ applicationAmendmentRequestViewResponse.setApplicationId(applicationAmendmentRequestView.getApplicationId());
+ applicationAmendmentRequestViewResponse.setProtocolNumber(applicationAmendmentRequestView.getProtocolNumber());
+ applicationAmendmentRequestViewResponse.setCallName(applicationAmendmentRequestView.getCallName());
+ applicationAmendmentRequestViewResponse.setCompanyName(applicationAmendmentRequestView.getCompanyName());
+ applicationAmendmentRequestViewResponse.setStartDate(applicationAmendmentRequestView.getStartDate());
+ applicationAmendmentRequestViewResponse.setExpirationDate(applicationAmendmentRequestView.getExpirationDate());
+ applicationAmendmentRequestViewResponse.setAssigendUserName(applicationAmendmentRequestView.getAssigendUserName());
+ applicationAmendmentRequestViewResponse.setStatus(applicationAmendmentRequestView.getStatus());
+ return applicationAmendmentRequestViewResponse;
+ }
+
+
}
diff --git a/src/main/java/net/gepafin/tendermanagement/dao/ApplicationDao.java b/src/main/java/net/gepafin/tendermanagement/dao/ApplicationDao.java
index e060120e..35f1cc32 100644
--- a/src/main/java/net/gepafin/tendermanagement/dao/ApplicationDao.java
+++ b/src/main/java/net/gepafin/tendermanagement/dao/ApplicationDao.java
@@ -21,15 +21,14 @@ import net.gepafin.tendermanagement.service.FormService;
import net.gepafin.tendermanagement.service.HubService;
import net.gepafin.tendermanagement.service.SystemEmailTemplatesService;
import net.gepafin.tendermanagement.service.UserService;
-import net.gepafin.tendermanagement.util.DateTimeUtil;
-import net.gepafin.tendermanagement.util.FieldValidator;
-import net.gepafin.tendermanagement.util.LoggingUtil;
-import net.gepafin.tendermanagement.util.Utils;
-import net.gepafin.tendermanagement.util.Validator;
+import net.gepafin.tendermanagement.util.*;
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.apache.commons.csv.CSVFormat;
+import org.apache.commons.csv.CSVPrinter;
+import org.apache.commons.lang3.StringUtils;
import org.h2.util.IOUtils;
import org.json.JSONObject;
import org.slf4j.Logger;
@@ -47,9 +46,14 @@ import jakarta.servlet.http.HttpServletRequest;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
+import java.io.OutputStreamWriter;
+import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.text.MessageFormat;
+import java.text.SimpleDateFormat;
+import java.time.LocalDate;
import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -185,6 +189,11 @@ public class ApplicationDao {
@Autowired
private ApplicationViewRepository applicationViewRepository;
+ @Autowired
+ private ApplicationFormViewRepository applicationFormViewRepository;
+
+ @Autowired
+ private FormRepository formRepository;
public ApplicationResponseBean createApplication(HttpServletRequest request, ApplicationRequestBean applicationRequestBean, Long formId, Long applicationId) {
FormEntity formEntity = formService.validateForm(formId);
@@ -1438,185 +1447,6 @@ public class ApplicationDao {
}
}
- public PageableResponseBean> getAllApplicationByPagination(UserEntity userEntity, Long callId, Long companyId, ApplicationPageableRequestBean applicationPageableRequestBean) {
- Integer pageNo = null;
- Integer pageLimit = null;
-
- UserWithCompanyEntity userWithCompany= userWithCompanyRepository.findByUserIdAndCompanyIdAndIsDeletedFalse(userEntity.getId(), companyId).orElse(null);
- Long userWithCompanyId = userWithCompany!=null?userWithCompany.getId():null;
- if (applicationPageableRequestBean.getGlobalFilters() != null) {
- pageNo = applicationPageableRequestBean.getGlobalFilters().getPage();
- pageLimit = applicationPageableRequestBean.getGlobalFilters().getLimit();
- }
- if (pageLimit == null || pageLimit <= 0) {
- pageLimit = GepafinConstant.DEFAULT_PAGE_LIMIT;
- }
- if (pageNo == null || pageNo <= 0) {
- pageNo = GepafinConstant.DEFAULT_PAGE;
- }
- Specification spec = search(callId,companyId, userWithCompanyId, applicationPageableRequestBean, userEntity);
- Page entityPage = applicationRepository.findAll(spec, PageRequest.of(pageNo - 1, pageLimit));
- // Prepare the response
-
-
- List applicationResponses = entityPage.getContent().stream()
- .map(application -> {
- ApplicationResponse response = getApplicationResponse(application);
- return response;
- })
- .collect(Collectors.toList());
-
-
- PageableResponseBean> pageableResponseBean = new PageableResponseBean<>();
- pageableResponseBean.setBody(applicationResponses);
- pageableResponseBean.setCurrentPage(entityPage.getNumber() + 1); // Page numbers typically start from 0, so add 1 for user-friendly indexing
- pageableResponseBean.setTotalPages(entityPage.getTotalPages());
- pageableResponseBean.setTotalRecords(entityPage.getTotalElements());
- pageableResponseBean.setPageSize(entityPage.getSize());
-
- return pageableResponseBean;
- }
-
- public Specification search(Long callId, Long companyId, Long userWithCompanyId, ApplicationPageableRequestBean applicationPageableRequestBean, UserEntity userEntity) {
- return (root, query, criteriaBuilder) -> {
-
- List predicates = getPredicates(applicationPageableRequestBean, criteriaBuilder, root, callId,companyId, userWithCompanyId, userEntity);
- SortBy sortBy = new SortBy(GepafinConstant.CREATED_DATE, true);
-
- if (applicationPageableRequestBean.getGlobalFilters() != null
- && applicationPageableRequestBean.getGlobalFilters().getSortBy() != null &&
- applicationPageableRequestBean.getGlobalFilters().getSortBy().getColumnName() != null && Boolean.FALSE.equals(
- isEmpty(applicationPageableRequestBean.getGlobalFilters().getSortBy().getColumnName()))) {
- sortBy.setColumnName(applicationPageableRequestBean.getGlobalFilters().getSortBy().getColumnName());
- sortBy.setSortDesc(true);
- if (applicationPageableRequestBean.getGlobalFilters().getSortBy().getSortDesc() != null) {
- sortBy.setSortDesc(applicationPageableRequestBean.getGlobalFilters().getSortBy().getSortDesc());
- }
- }
-
- query.orderBy(criteriaBuilder.desc(root.get(sortBy.getColumnName())));
- if (Boolean.FALSE.equals(sortBy.getSortDesc())) {
- query.orderBy(criteriaBuilder.asc(root.get(sortBy.getColumnName())));
- }
- return query.where(criteriaBuilder.and(predicates.toArray(new Predicate[0]))).getRestriction();
- };
- }
-
-
- private List getPredicates(ApplicationPageableRequestBean applicationPageableRequestBean,
- CriteriaBuilder criteriaBuilder, Root root, Long callId,Long companyId, Long userWithCompanyId, UserEntity userEntity) {
-
- Integer year = null;
- String search = null;
- Integer daysRange = null;
- Map filters = new HashMap<>();
- if (applicationPageableRequestBean.getGlobalFilters() != null) {
- year = applicationPageableRequestBean.getGlobalFilters().getYear();
- search = applicationPageableRequestBean.getGlobalFilters().getSearch();
- daysRange = applicationPageableRequestBean.getDaysRange();
- }
- if (applicationPageableRequestBean.getFilters() != null) {
- filters = applicationPageableRequestBean.getFilters();
- }
- List predicates = new ArrayList<>();
-
-// Boolean isBeneficiary = validator.checkIsBeneficiary();
- if (Boolean.TRUE.equals(validator.checkIsBeneficiary()) || Boolean.TRUE.equals(validator.checkIsConfidi())) {
- predicates.add(criteriaBuilder.equal(root.get(GepafinConstant.USER_ID), userEntity.getId()));
- }
- if (year != null && year > 0) {
- int filterYear = applicationPageableRequestBean.getGlobalFilters().getYear();
-
-// Create LocalDateTime boundaries for the start and end of the year
- LocalDateTime startOfYear = LocalDateTime.of(filterYear, 1, 1, 0, 0);
- LocalDateTime endOfYear = LocalDateTime.of(filterYear, 12, 31, 23, 59, 59);
-
-// Add the range comparison to filter records within the year
- predicates.add(criteriaBuilder.between(root.get(GepafinConstant.CREATED_DATE), startOfYear, endOfYear));
-
- }
- // Search in `title` and `message` (if search term is provided)
- if (search != null && !search.isEmpty()) {
- Predicate titlePredicate = criteriaBuilder.like(
- criteriaBuilder.upper(root.get(GepafinConstant.COMMENTS)),
- "%" + search.toUpperCase() + "%"
- );
-// Predicate protocolPredicate = criteriaBuilder.like(
-// criteriaBuilder.function(
-// "TO_CHAR",
-// String.class,
-// criteriaBuilder.function("CAST", String.class, root.get(GepafinConstant.PROTOCOL).get(GepafinConstant.PROTOCOL_NUMBER))
-// ),
-// "%" + search + "%"
-// );
-
- Predicate callNamePredicate =criteriaBuilder.like(
- criteriaBuilder.upper(root.get(GepafinConstant.CALL).get(GepafinConstant.NAME)), // Adjust field name
- "%" + search.toUpperCase() + "%"
- );
-
-// predicates.add(criteriaBuilder.or(protocolPredicate));
- predicates.add(criteriaBuilder.or(callNamePredicate));
- predicates.add(criteriaBuilder.or(titlePredicate));
- }
-
- // Filter by `status` (if status list is provided)
- if (applicationPageableRequestBean.getStatus() != null && !applicationPageableRequestBean.getStatus().isEmpty()) {
- List statusValues = applicationPageableRequestBean.getStatus().stream()
- .map(ApplicationStatusTypeEnum::name) // Convert enum to string
- .toList();
- predicates.add(root.get(GepafinConstant.STATUS).in(statusValues));
- }
-
- if (callId != null) {
- CallEntity call = callService.validateCall(callId);
- predicates.add(criteriaBuilder.equal(root.get(GepafinConstant.CALL).get(GepafinConstant.ID), callId));
- }
-
- // Optional companyId filter
- if (userWithCompanyId != null) {
- predicates.add(criteriaBuilder.equal(root.get(GepafinConstant.USER_WITH_COMPANY).get(GepafinConstant.ID), userWithCompanyId));
- }
- if (companyId != null) {
- predicates.add(criteriaBuilder.equal(root.get(GepafinConstant.COMPANY_ID), companyId));
- }
-
- if (daysRange != null && daysRange >= 0) {
- LocalDateTime today = LocalDateTime.now();
- LocalDateTime pastDate = today.minusDays(daysRange);
- predicates.add(criteriaBuilder.between(root.get(GepafinConstant.CREATED_DATE), pastDate, today));
- }
- applyFilters(root, criteriaBuilder, predicates, filters);
-
- predicates.add(criteriaBuilder.isFalse(root.get(GepafinConstant.IS_DELETED)));
-
- predicates.add(criteriaBuilder.equal(root.get(GepafinConstant.HUB_ID), userEntity.getHub().getId()));
-
-
- return predicates;
- }
- private void applyFilters(Root> root, CriteriaBuilder criteriaBuilder, List predicates, Map filters) {
- if (Boolean.FALSE.equals(filters.isEmpty())) {
- for (Map.Entry entry : filters.entrySet()) {
- String fieldName = entry.getKey();
- FilterCriteria filterCriteria = entry.getValue();
- Object value = filterCriteria.getValue();
- MatchModeEnum matchMode = filterCriteria.getMatchMode();
-
- if (value != null && matchMode != null) {
- Path> fieldPath = root.get(fieldName);
- if (fieldPath != null) {
- Utils.applyStringFilter(fieldPath, criteriaBuilder, predicates, value, matchMode);
- Utils.applyNumberFilter(fieldPath, criteriaBuilder, predicates, value, matchMode);
- Utils.applyDateFilter(fieldPath, criteriaBuilder, predicates, value, matchMode,root);
- }
- }
- }
- }
- }
-
-
-
// private Path> getFieldPath(Root> root, String fieldName) {
// try {
@@ -1889,27 +1719,29 @@ public class ApplicationDao {
}
// Search in `title` and `message` (if search term is provided)
if (search != null && !search.isEmpty()) {
+ String searchPattern = "%" + search.toUpperCase() + "%";
+
Predicate titlePredicate = criteriaBuilder.like(
criteriaBuilder.upper(root.get(GepafinConstant.COMMENTS)),
- "%" + search.toUpperCase() + "%"
- );
-// Predicate protocolPredicate = criteriaBuilder.like(
-// criteriaBuilder.function(
-// "TO_CHAR",
-// String.class,
-// criteriaBuilder.function("CAST", String.class, root.get(GepafinConstant.PROTOCOL).get(GepafinConstant.PROTOCOL_NUMBER))
-// ),
-// "%" + search + "%"
-// );
-
- Predicate callNamePredicate =criteriaBuilder.like(
- criteriaBuilder.upper(root.get(GepafinConstant.CALL_TITLE)), // Adjust field name
- "%" + search.toUpperCase() + "%"
+ searchPattern
);
-// predicates.add(criteriaBuilder.or(protocolPredicate));
- predicates.add(criteriaBuilder.or(callNamePredicate));
- predicates.add(criteriaBuilder.or(titlePredicate));
+ Predicate callTitlePredicate = criteriaBuilder.like(
+ criteriaBuilder.upper(root.get(GepafinConstant.CALL_TITLE)),
+ searchPattern
+ );
+ Predicate callNamePredicate = criteriaBuilder.like(
+ criteriaBuilder.upper(root.get(GepafinConstant.CALL_NAME)),
+ searchPattern
+ );
+ Predicate companyName = criteriaBuilder.like(
+ criteriaBuilder.upper(root.get(GepafinConstant.COMPANY_NAME)),
+ searchPattern
+ );
+
+ // Combine them using a single `or()`
+ Predicate finalPredicate = criteriaBuilder.or(titlePredicate, callTitlePredicate,callNamePredicate,companyName);
+ predicates.add(finalPredicate);
}
// Filter by `status` (if status list is provided)
@@ -1938,7 +1770,7 @@ public class ApplicationDao {
LocalDateTime pastDate = today.minusDays(daysRange);
predicates.add(criteriaBuilder.between(root.get(GepafinConstant.CREATED_DATE), pastDate, today));
}
- applyFilters(root, criteriaBuilder, predicates, filters);
+ Utils.applyFiltersByPagination(root, criteriaBuilder, predicates, filters);
predicates.add(criteriaBuilder.isFalse(root.get(GepafinConstant.IS_DELETED)));
@@ -1952,7 +1784,7 @@ public class ApplicationDao {
ApplicationResponse responseBean = new ApplicationResponse();
List flowEdgesList = flowEdgesRepository.findByCallId(applicationView.getCallId());
Long totalFormSteps = flowFormDao.calculateTotalSteps(flowEdgesList);
- Long completedSteps= Long.valueOf(flowFormDao.getCompletedStepsByView(applicationView.getId(), false));
+ Long completedSteps = Long.valueOf(flowFormDao.getCompletedStepsByView(applicationView.getId(), false));
Integer progress = calculateProgress(totalFormSteps, completedSteps);
responseBean.setId(applicationView.getId());
responseBean.setProgress(progress);
@@ -1966,23 +1798,326 @@ public class ApplicationDao {
responseBean.setEvaluationVersion(EvaluationVersionEnum.valueOf(applicationView.getEvaluationVersion()));
responseBean.setComments(applicationView.getComments());
responseBean.setCompanyId(applicationView.getCompanyId());
- Optional assignedApplicationsOptional =
- assignedApplicationsRepository.findByApplicationIdAndIsDeletedFalse(applicationView.getId());
- if(assignedApplicationsOptional.isPresent()){
- responseBean.setAssignedUserId(assignedApplicationsOptional.get().getUserId());
- UserEntity user = userService.validateUser(assignedApplicationsOptional.get().getUserId());
- String firstName = user.getFirstName() != null ? user.getFirstName() : "";
- String lastName = user.getLastName() != null ? user.getLastName() : "";
- String userName = String.join(" ", firstName, lastName).trim();
- responseBean.setAssignedUserName(userName);
- }
- CompanyEntity company=companyService.validateCompany(applicationView.getCompanyId());
- responseBean.setCompanyName(company.getCompanyName());
- responseBean.setProtocolNumber(applicationView.getProtocolNumber());
+ responseBean.setAssignedUserId(applicationView.getAssignedUserId());
+ responseBean.setAssignedUserName(applicationView.getAssignedUserName());
+ responseBean.setCompanyName(applicationView.getCompanyName());
+ responseBean.setProtocolNumber(applicationView.getProtocolNumber());
responseBean.setAmountAccepted(applicationView.getAmountAccepted());
responseBean.setAmountRequested(applicationView.getAmountRequested());
responseBean.setDateAccepted(applicationView.getDateAccepted());
responseBean.setDateRejected(applicationView.getDateRejected());
return responseBean;
}
+
+ public List getApplicationFormData(Long callId) {
+ List applicationFormViews=new ArrayList<>();
+
+ applicationFormViews= applicationFormViewRepository.findByCallId(callId);
+
+ return applicationFormViews;
+ }
+
+ private List getStaticGetterMethods() {
+ List excluded = Arrays.asList(
+ GepafinConstant.GET_FIELD_TYPE,GepafinConstant.GET_APPLICATION_FORM_ID,GepafinConstant.GET_ID,GepafinConstant.GET_CLASS,GepafinConstant.GET_FORM_ID,GepafinConstant.GET_FIELD_ID,GepafinConstant.GET_FIELD_LABEL,GepafinConstant.GET_FIELD_VALUE,GepafinConstant.GET_REPORT_HEADER,GepafinConstant.GET_REPORT_ENABLE
+ );
+
+ Method applicationIdMethod = null;
+
+ List methods = new ArrayList<>();
+
+ for (Method m : ApplicationFormView.class.getMethods()) {
+ if (m.getName().equals(GepafinConstant.GET_APPLICATION_ID)) {
+ applicationIdMethod = m;
+ } else if (m.getName().startsWith(GepafinConstant.GET) && m.getParameterCount() == 0 && !excluded.contains(m.getName())) {
+ methods.add(m);
+ }
+ }
+
+ methods.sort(Comparator.comparing(Method::getName)); // Sort remaining
+
+ if (applicationIdMethod != null) {
+ methods.add(0, applicationIdMethod); // Add it to the beginning
+ }
+
+ return methods;
+
+ }
+
+ private String methodToHeader(Method method) {
+ String name = method.getName().substring(3); // strip "get"
+ return Arrays.stream(name.split("(?=[A-Z])"))
+ .map(String::toLowerCase)
+ .map(word -> Character.toUpperCase(word.charAt(0)) + word.substring(1))
+ .collect(Collectors.joining(" "));
+ }
+
+ private String invokeGetter(ApplicationFormView view, Method method) {
+ try {
+ Object value = method.invoke(view);
+ if (value == null) return "";
+
+ String stringValue;
+
+ if (value instanceof LocalDate) {
+ stringValue = ((LocalDate) value).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+ } else if (value instanceof LocalDateTime) {
+ stringValue = ((LocalDateTime) value).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+ } else if (value instanceof Date) {
+ stringValue = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format((Date) value);
+ } else {
+ stringValue = value.toString();
+ }
+
+ // Wrap it in ="..." to make Excel treat it as a literal string
+ return "=\"" + stringValue.replace("\"", "\"\"") + "\"";
+
+ } catch (Exception e) {
+ return "";
+ }
+ }
+
+
+ public byte[] exportCsv(Long callId) {
+
+ List results = getApplicationFormData(callId);
+
+
+ Map appInfo = new HashMap<>();
+ Map> appFieldValues = new LinkedHashMap<>();
+ Set tableFieldIds = new HashSet<>();
+ Map fieldIdToLabel = new LinkedHashMap<>();
+
+ for (ApplicationFormView row : results) {
+ appInfo.putIfAbsent(row.getApplicationId(), row);
+ String label=row.getReportHeader();
+ if(Boolean.TRUE.equals(StringUtils.isEmpty(label))){
+ label=row.getFieldLabel();
+ }
+ fieldIdToLabel.putIfAbsent(row.getFieldId(), label);
+
+ if (GepafinConstant.TABLE.equalsIgnoreCase(row.getFieldType())) {
+ tableFieldIds.add(row.getFieldId());
+ continue;
+ }
+
+ String value = Optional.ofNullable(row.getFieldValue())
+ .map(v -> v.startsWith("\"") && v.endsWith("\"") ? v.substring(1, v.length() - 1) : v)
+ .orElse("");
+
+ appFieldValues
+ .computeIfAbsent(row.getApplicationId(), k -> new LinkedHashMap<>())
+ .merge(row.getFieldId(), value, (v1, v2) -> v1.equals(v2) ? v1 : String.join(", ", v1, v2));
+ }
+
+ Map> tableHeadersByFieldId = new LinkedHashMap<>();
+ Map> tableDataByApp = new HashMap<>();
+ prepareTableFieldData(results, tableFieldIds, tableHeadersByFieldId, tableDataByApp);
+
+ // Final header construction
+ List staticMethods = getStaticGetterMethods();
+ List staticHeaders = staticMethods.stream().map(this::methodToHeader).toList();
+
+ List dynamicHeaders = new ArrayList<>();
+ for (String fieldId : fieldIdToLabel.keySet()) {
+ if (tableHeadersByFieldId.containsKey(fieldId)) {
+ dynamicHeaders.addAll(tableHeadersByFieldId.get(fieldId));
+ } else {
+ dynamicHeaders.add(fieldIdToLabel.get(fieldId));
+ }
+ }
+
+ List allHeaders = new ArrayList<>(staticHeaders);
+ allHeaders.addAll(dynamicHeaders);
+
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+ try (CSVPrinter printer = new CSVPrinter(new OutputStreamWriter(out), CSVFormat.DEFAULT.withHeader(allHeaders.toArray(new String[0])))) {
+ for (Long appId : appFieldValues.keySet()) {
+ ApplicationFormView appRow = appInfo.get(appId);
+ Map flatFieldVals = appFieldValues.get(appId);
+ Map tableVals = tableDataByApp.getOrDefault(appId, Collections.emptyMap());
+
+ List row = new ArrayList<>();
+ for (Method method : staticMethods) {
+ row.add(invokeGetter(appRow, method));
+ }
+
+ for (String fieldId : fieldIdToLabel.keySet()) {
+ if (tableHeadersByFieldId.containsKey(fieldId)) {
+ for (String header : tableHeadersByFieldId.get(fieldId)) {
+ row.add(tableVals.getOrDefault(header, ""));
+ }
+ } else {
+ row.add(flatFieldVals.getOrDefault(fieldId, ""));
+ }
+ }
+
+ printer.printRecord(row);
+ }
+
+ } catch (IOException e) {
+ throw new RuntimeException("CSV generation failed", e);
+ }
+
+ return out.toByteArray();
+ }
+ private Map extractTableData(String fieldType,
+ ContentResponseBean content, String fieldValue) {
+
+ if (content == null) return Map.of();
+
+ Map result = new LinkedHashMap<>();
+
+ List