From df07adb7a162c5841a90e20e6c8bcc01075ecbc7 Mon Sep 17 00:00:00 2001 From: smirnovaae Date: Thu, 9 May 2024 10:20:39 -0700 Subject: [PATCH 1/3] wip --- .../ab2d/coverage/repository/CoverageServiceRepository.java | 4 +++- .../gov/cms/ab2d/worker/processor/ContractProcessorImpl.java | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java b/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java index b4e56271a0..396247fe3d 100644 --- a/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java +++ b/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java @@ -308,7 +308,7 @@ public int countBeneficiariesByPeriods(List coveragePeriodIds, String c NamedParameterJdbcTemplate template = new NamedParameterJdbcTemplate(dataSource); //If OptOut is enabled, count beneficiaries who agreed to share their data String query = (propertiesService.isToggleOn("OptOutOn", false)) ? SELECT_DISTINCT_OPTOUT_COVERAGE_BY_PERIOD_COUNT : SELECT_DISTINCT_COVERAGE_BY_PERIOD_COUNT; - + log.error("SELECT_DISTINCT_OPTOUT_COVERAGE_BY_PERIOD_COUNT " + query); return template.queryForList(query, parameters, Integer.class) .stream().findFirst().orElseThrow(() -> new RuntimeException("no coverage information found for any " + "of the coverage periods provided")); @@ -602,10 +602,12 @@ private List queryCoverageMembership(CoveragePagingRequest p NamedParameterJdbcTemplate template = new NamedParameterJdbcTemplate(dataSource); if (pageCursor.isPresent()) { String queryWithCursor = (isOptOutOn) ? SELECT_OPTOUT_COVERAGE_WITH_CURSOR : SELECT_COVERAGE_WITH_CURSOR; + log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR " + queryWithCursor); enrollment = template.query(queryWithCursor, sqlParameterSource, CoverageServiceRepository::asMembership); } else { String queryWithoutCursor = (isOptOutOn) ? SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR : SELECT_COVERAGE_WITHOUT_CURSOR; + log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR " + queryWithoutCursor); enrollment = template.query(queryWithoutCursor, sqlParameterSource, CoverageServiceRepository::asMembership); } diff --git a/worker/src/main/java/gov/cms/ab2d/worker/processor/ContractProcessorImpl.java b/worker/src/main/java/gov/cms/ab2d/worker/processor/ContractProcessorImpl.java index cbadefc0d9..816334facb 100644 --- a/worker/src/main/java/gov/cms/ab2d/worker/processor/ContractProcessorImpl.java +++ b/worker/src/main/java/gov/cms/ab2d/worker/processor/ContractProcessorImpl.java @@ -137,6 +137,7 @@ public List process(Job job) { ContractDTO contract = contractWorkerClient.getContractByContractNumber(contractNumber); int numBenes = coverageDriver.numberOfBeneficiariesToProcess(job, contract); jobChannelService.sendUpdate(job.getJobUuid(), JobMeasure.PATIENTS_EXPECTED, numBenes); + log.error("jobChannelService.sendUpdate(job.getJobUuid(), JobMeasure.PATIENTS_EXPECTED, numBenes) " + numBenes); log.info("Contract [{}] has [{}] Patients", contractNumber, numBenes); // Create the aggregator @@ -238,7 +239,7 @@ private void loadEobRequests(ContractData contractData) throws InterruptedExcept current = coverageDriver.pageCoverage(current.getNextRequest().get()); loadRequestBatch(contractData, current, searchConfig.getNumberBenesPerBatch()); jobChannelService.sendUpdate(jobUuid, JobMeasure.PATIENT_REQUEST_QUEUED, current.size()); - + log.error("sendUpdate(jobUuid, JobMeasure.PATIENT_REQUEST_QUEUED, current.size() " + current.size()); processFinishedRequests(contractData); } if (contractData.getJob().hasJobBeenCancelled()) { From fc2656ff8d14a9cea75d38f46435ce89fb83bc04 Mon Sep 17 00:00:00 2001 From: Sadibhatla Date: Mon, 13 May 2024 12:15:42 -0700 Subject: [PATCH 2/3] extra logging --- .../ab2d/coverage/repository/CoverageServiceRepository.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java b/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java index 396247fe3d..97daef4c40 100644 --- a/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java +++ b/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java @@ -309,6 +309,7 @@ public int countBeneficiariesByPeriods(List coveragePeriodIds, String c //If OptOut is enabled, count beneficiaries who agreed to share their data String query = (propertiesService.isToggleOn("OptOutOn", false)) ? SELECT_DISTINCT_OPTOUT_COVERAGE_BY_PERIOD_COUNT : SELECT_DISTINCT_COVERAGE_BY_PERIOD_COUNT; log.error("SELECT_DISTINCT_OPTOUT_COVERAGE_BY_PERIOD_COUNT " + query); + log.error("DISTINCT_OPTOUT_COVERAGE_BY_PERIOD_COUNT " + parameters); return template.queryForList(query, parameters, Integer.class) .stream().findFirst().orElseThrow(() -> new RuntimeException("no coverage information found for any " + "of the coverage periods provided")); @@ -603,11 +604,15 @@ private List queryCoverageMembership(CoveragePagingRequest p if (pageCursor.isPresent()) { String queryWithCursor = (isOptOutOn) ? SELECT_OPTOUT_COVERAGE_WITH_CURSOR : SELECT_COVERAGE_WITH_CURSOR; log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR " + queryWithCursor); + log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR PARAM " + sqlParameterSource ); + log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR_VALUE " + pageCursor ); enrollment = template.query(queryWithCursor, sqlParameterSource, CoverageServiceRepository::asMembership); } else { String queryWithoutCursor = (isOptOutOn) ? SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR : SELECT_COVERAGE_WITHOUT_CURSOR; log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR " + queryWithoutCursor); + log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR PARAM " + sqlParameterSource ); + log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR_VALUE " + pageCursor ); enrollment = template.query(queryWithoutCursor, sqlParameterSource, CoverageServiceRepository::asMembership); } From 6f4fb4316d6c7660c5b0d80cf46e68bbbfaa6855 Mon Sep 17 00:00:00 2001 From: Sadibhatla Date: Mon, 13 May 2024 12:20:49 -0700 Subject: [PATCH 3/3] extra logging removed errors --- .../coverage/repository/CoverageServiceRepository.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java b/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java index 97daef4c40..6e4ce1da22 100644 --- a/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java +++ b/coverage/src/main/java/gov/cms/ab2d/coverage/repository/CoverageServiceRepository.java @@ -604,15 +604,15 @@ private List queryCoverageMembership(CoveragePagingRequest p if (pageCursor.isPresent()) { String queryWithCursor = (isOptOutOn) ? SELECT_OPTOUT_COVERAGE_WITH_CURSOR : SELECT_COVERAGE_WITH_CURSOR; log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR " + queryWithCursor); - log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR PARAM " + sqlParameterSource ); - log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR_VALUE " + pageCursor ); + log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR PARAM " + sqlParameterSource); + log.error("SELECT_OPTOUT_COVERAGE_WITH_CURSOR_VALUE " + pageCursor); enrollment = template.query(queryWithCursor, sqlParameterSource, CoverageServiceRepository::asMembership); } else { String queryWithoutCursor = (isOptOutOn) ? SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR : SELECT_COVERAGE_WITHOUT_CURSOR; log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR " + queryWithoutCursor); - log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR PARAM " + sqlParameterSource ); - log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR_VALUE " + pageCursor ); + log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR PARAM " + sqlParameterSource); + log.error("SELECT_OPTOUT_COVERAGE_WITHOUT_CURSOR_VALUE " + pageCursor); enrollment = template.query(queryWithoutCursor, sqlParameterSource, CoverageServiceRepository::asMembership); }