Merge pull request #100 from Kitzanos/get-only-preferred-call-filter

Added an optional parameter onlyPreferredCall

src/main/java/net/gepafin/tendermanagement/constants/GepafinConstant.java

@@ -292,5 +292,7 @@ public class GepafinConstant {
     public static final String ENCRYPT_KEY = "U2VjdXJlRW5jcnlwdEtleQ==";
     public static final String APPLICATION_DOCUMENTS_NOT_FOUND_MSG = "application.documents.not.found";
     public static final String DUPLICATE_BENEFICIARY_CALL = "beneficiary.call.duplicate";
+    public static final String COMPANY_ID_REQUIRED_FOR_PREFERRED_CALL = "company.id.required.for.preferred.call";
+
 }
 

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

@@ -656,13 +656,29 @@ public class CallDao {
 		return createCallResponseBean;
 	}
 
-	public List<CallDetailsResponseBean> getAllCalls(HttpServletRequest request,UserEntity user, Long companyId) {
+	public List<CallDetailsResponseBean> getAllCalls(HttpServletRequest request,UserEntity user, Long companyId,Boolean onlyPreferredCall) {
 		String type = user.getRoleEntity().getRoleType();
 		List<String> callStatusList = CallStatusEnum.getStatusValues();
 		if (Boolean.FALSE.equals(ROLE_SUPER_ADMIN.getValue().equals(type))) {
 			callStatusList = List.of(CallStatusEnum.PUBLISH.getValue());
 		}
-		List<CallEntity> calls = callRepository.findByStatusInAndHubId(callStatusList, user.getHub().getId());
+		List<CallEntity> calls;
+		if (Boolean.TRUE.equals(onlyPreferredCall) && companyId == null) {
+			throw new CustomValidationException(Status.VALIDATION_ERROR,
+					Translator.toLocale(GepafinConstant.COMPANY_ID_REQUIRED_FOR_PREFERRED_CALL));
+		}
+
+		if (Boolean.TRUE.equals(onlyPreferredCall)) {
+			validator.validateUserWithCompany(request, companyId);
+			List<BeneficiaryPreferredCallEntity> preferredCalls = beneficiaryPreferredCallRepository
+					.findByUserIdAndCompanyIdAndIsDeletedFalse(user.getId(), companyId);
+			List<Long> preferredCallIds = preferredCalls.stream()
+					.map(BeneficiaryPreferredCallEntity::getCallId)
+					.collect(Collectors.toList());
+			calls = callRepository.findByIdInAndStatusIn(preferredCallIds, callStatusList);
+		} else {
+			calls = callRepository.findByStatusInAndHubId(callStatusList, user.getHub().getId());
+		}
 		List<Long> callIds = calls.stream().map(CallEntity::getId).collect(Collectors.toList());
 		Map<String, BeneficiaryPreferredCallEntity> preferredCallsMap =
 				getBeneficiaryPreferredCallsForUser(request,user, callIds, companyId);

src/main/java/net/gepafin/tendermanagement/repositories/CallRepository.java

@@ -45,4 +45,6 @@ public interface CallRepository extends JpaRepository<CallEntity, Long> {
 
 	@Query("SELECT COALESCE(SUM(c.amount), 0) FROM CallEntity c WHERE c.status = 'PUBLISH' And c.hub.id = :hubId")
 	BigDecimal findTotalAmountOfPublishedCallsAndHubId(@Param("hubId") Long hubId);
+	@Query("SELECT c FROM CallEntity c WHERE c.id IN :ids AND c.status IN :status")
+	List<CallEntity> findByIdInAndStatusIn(@Param("ids") List<Long> ids, @Param("status") List<String> status);
 }

src/main/java/net/gepafin/tendermanagement/service/CallService.java

@@ -21,7 +21,7 @@ public interface CallService {
 
 	CallResponse getCallById (HttpServletRequest request, Long callId,Long companyId);
 	
-	List<CallDetailsResponseBean> getAllCalls(HttpServletRequest request,Long companyId);
+	List<CallDetailsResponseBean> getAllCalls(HttpServletRequest request,Long companyId,Boolean onlyPreferredCall);
 
 	CallResponse validateCallData(HttpServletRequest request, Long callId);
     

src/main/java/net/gepafin/tendermanagement/service/impl/CallServiceImpl.java

@@ -62,9 +62,9 @@ public class CallServiceImpl implements CallService {
     
     @Override
     @Transactional(readOnly = true)
-    public List<CallDetailsResponseBean> getAllCalls(HttpServletRequest request,Long companyId) {
+    public List<CallDetailsResponseBean> getAllCalls(HttpServletRequest request,Long companyId,Boolean onlyPreferredCall) {
     	UserEntity user = validator.validateUser(request);
-        return callDao.getAllCalls(request,user,companyId);
+        return callDao.getAllCalls(request,user,companyId,onlyPreferredCall);
 
     }
     

src/main/java/net/gepafin/tendermanagement/web/rest/api/CallApi.java

@@ -100,8 +100,8 @@ public interface CallApi {
                             @ExampleObject(value = ErrorConstants.BADREQUEST_ERROR_EXAMPLE) })) })
     @GetMapping(value = "",
             produces = { "application/json" })
-    ResponseEntity<Response<List<CallDetailsResponseBean>>> getAllCalls(HttpServletRequest request,@RequestParam(value = "companyId", required = false) Long companyId);
+    ResponseEntity<Response<List<CallDetailsResponseBean>>> getAllCalls(HttpServletRequest request,@RequestParam(value = "companyId", required = false) Long companyId , @RequestParam(value = "onlyPreferredCall", required = false, defaultValue = "false") Boolean onlyPreferredCall);
-    
+
     
     @Operation(summary = "Api to validate call",
             responses = {

src/main/java/net/gepafin/tendermanagement/web/rest/api/impl/CallApiController.java

@@ -67,8 +67,8 @@ public class CallApiController implements CallApi {
 
     @Override
     @Transactional(readOnly = true)
-    public ResponseEntity<Response<List<CallDetailsResponseBean>>> getAllCalls(HttpServletRequest request,Long companyId) {
+    public ResponseEntity<Response<List<CallDetailsResponseBean>>> getAllCalls(HttpServletRequest request,Long companyId,Boolean onlyPreferredCall) {
-        List<CallDetailsResponseBean> calls = callService.getAllCalls(request,companyId);
+        List<CallDetailsResponseBean> calls = callService.getAllCalls(request,companyId,onlyPreferredCall);
 
         return ResponseEntity.status(HttpStatus.OK)
                 .body(new Response<>(calls, Status.SUCCESS, Translator.toLocale(GepafinConstant.CALL_FETCH_SUCCESS_MSG)));

src/main/resources/message_en.properties

@@ -308,3 +308,4 @@ invalid.amendment.for.comment = Invalid Amendment Request for the Given Comment.
 DD_MM_YYYY_HH_MM = dd_MM_yyyy HH:mm
 application.documents.not.found=No documents found for the application.
 beneficiary.call.duplicate = A preferred call with this call ID and company ID already exists for this user.
+company.id.required.for.preferred.call=Company ID is required when requesting only preferred calls.

src/main/resources/message_it.properties

@@ -303,3 +303,4 @@ beneficiary.email.not.found.msg=L'indirizzo email per il beneficiario non <20> st
 reminder.email.sent.success.msg=Email di promemoria inviata con successo!
 application.documents.not.found=Nessun documento trovato per la domanda.
 beneficiary.call.duplicate = Una chiamata preferita con questo ID di chiamata e ID azienda esiste gi<67> per questo utente.
+company.id.required.for.preferred.call=ID azienda obbligatorio quando si richiedono solo chiamate preferite.