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..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 @@ -308,7 +308,8 @@ 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); + 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")); @@ -602,10 +603,16 @@ 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); + 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); } 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()) {