Skip to content

Commit bb90af0

Browse files
fix: remove unused method (#386)
1 parent 0c389e3 commit bb90af0

File tree

3 files changed

+11
-33
lines changed

3 files changed

+11
-33
lines changed

src/main/java/it/gov/pagopa/idpay/transactions/service/RewardBatchServiceImpl.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -518,16 +518,6 @@ public Mono<RewardBatch> approvedTransactions(String rewardBatchId, Transactions
518518
acc.getTrxSuspended())
519519
);
520520
}
521-
@Scheduled (cron = "${app.transactions.reward-batch.to-evaluating.schedule}")
522-
void evaluatingRewardBatchStatusScheduler(){
523-
log.info("[EVALUATING_REWARD_BATCH][SCHEDULER] Start to evaluating all reward batches with status SENT");
524-
evaluatingRewardBatches(null)
525-
.onErrorResume(RewardBatchNotFound.class, x -> {
526-
log.error("[EVALUATING_REWARD_BATCH][SCHEDULER] " + ERROR_MESSAGE_NOT_FOUND_REWARD_BATCH_SENT, x);
527-
return Mono.just(0L);
528-
})
529-
.subscribe(numberUpdateBatch -> log.info("[EVALUATING_REWARD_BATCH][SCHEDULER] Completed evaluation. Updated {} reward batches to status EVALUATING", numberUpdateBatch));
530-
}
531521

532522
@Override
533523
public Mono<Long> evaluatingRewardBatches(List<String> rewardBatchesRequest) {

src/main/resources/application.yml

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -227,8 +227,4 @@ app:
227227
delete:
228228
paginationSize: ${DELETE_PAGINATION_SIZE:45}
229229
delayTime: ${DELETE_DELAY_TIME:1000}
230-
sampling: ${SAMPLING_HASH_SEED:15121984}
231-
transactions:
232-
reward-batch:
233-
to-evaluating:
234-
schedule: ${SCHEDULE_REWARD_BATCH_TO_EVALUATING:0 0 1 * * ?} # each day at 01:00AM
230+
sampling: ${SAMPLING_HASH_SEED:15121984}

src/test/java/it/gov/pagopa/idpay/transactions/service/RewardBatchServiceImplTest.java

Lines changed: 10 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
import it.gov.pagopa.common.web.exception.*;
77
import it.gov.pagopa.idpay.transactions.connector.rest.UserRestClient;
88
import it.gov.pagopa.idpay.transactions.dto.ChecksErrorDTO;
9-
import it.gov.pagopa.idpay.transactions.dto.ReasonDTO;
109
import it.gov.pagopa.idpay.transactions.dto.TransactionsRequest;
1110
import it.gov.pagopa.idpay.transactions.dto.mapper.ChecksErrorMapper;
1211
import it.gov.pagopa.idpay.transactions.enums.RewardBatchAssignee;
@@ -21,11 +20,6 @@
2120
import it.gov.pagopa.idpay.transactions.storage.ApprovedRewardBatchBlobService;
2221
import it.gov.pagopa.idpay.transactions.utils.AuditUtilities;
2322
import it.gov.pagopa.idpay.transactions.utils.ExceptionConstants;
24-
import java.lang.reflect.Method;
25-
import java.time.LocalDate;
26-
import java.time.LocalDateTime;
27-
import java.time.YearMonth;
28-
import java.util.*;
2923
import org.junit.jupiter.api.BeforeEach;
3024
import org.junit.jupiter.api.Test;
3125
import org.junit.jupiter.api.extension.ExtendWith;
@@ -45,9 +39,17 @@
4539
import reactor.core.publisher.Mono;
4640
import reactor.test.StepVerifier;
4741

42+
import java.lang.reflect.Method;
43+
import java.time.LocalDate;
44+
import java.time.LocalDateTime;
45+
import java.time.YearMonth;
46+
import java.util.Collections;
47+
import java.util.List;
48+
import java.util.Map;
49+
4850
import static it.gov.pagopa.idpay.transactions.enums.PosType.PHYSICAL;
49-
import static it.gov.pagopa.idpay.transactions.utils.ExceptionConstants.ExceptionCode.*;
50-
import static it.gov.pagopa.idpay.transactions.utils.ExceptionConstants.ExceptionMessage.*;
51+
import static it.gov.pagopa.idpay.transactions.utils.ExceptionConstants.ExceptionMessage.ERROR_MESSAGE_INVALID_CHECKS_ERROR;
52+
import static it.gov.pagopa.idpay.transactions.utils.ExceptionConstants.ExceptionMessage.MERCHANT_OR_OPERATOR_HEADER_MANDATORY;
5153
import static org.junit.jupiter.api.Assertions.*;
5254
import static org.mockito.ArgumentMatchers.*;
5355
import static org.mockito.Mockito.*;
@@ -725,16 +727,6 @@ void evaluatingRewardBatches_withList_handlesMissingIdsAsEmpty() {
725727
verify(rewardBatchRepository, never()).updateStatusAndApprovedAmountCents(any(), any(), anyLong());
726728
}
727729

728-
@Test
729-
void evaluatingRewardBatchStatusScheduler_handlesRewardBatchNotFoundError() {
730-
doReturn(Mono.error(new RewardBatchNotFound(REWARD_BATCH_NOT_FOUND, "x")))
731-
.when(serviceSpy).evaluatingRewardBatches(null);
732-
733-
serviceSpy.evaluatingRewardBatchStatusScheduler();
734-
735-
verify(serviceSpy).evaluatingRewardBatches(null);
736-
}
737-
738730

739731
@Test
740732
void downloadApprovedRewardBatchFile_invalidRequest_missingHeaders() {

0 commit comments

Comments
 (0)