forked from jpvelsamy/handyman
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #43 from zucisystems-dev/bugs/sor_grouping_001
Bugs/sor grouping 001
- Loading branch information
Showing
5 changed files
with
15 additions
and
125 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
130 changes: 7 additions & 123 deletions
130
src/main/java/in/handyman/raven/lib/EpisodeOfCoverageAction.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,161 +1,45 @@ | ||
| package in.handyman.raven.lib; | ||
|
|
||
| import in.handyman.raven.exception.HandymanException; | ||
| import in.handyman.raven.lambda.access.ResourceAccess; | ||
| import in.handyman.raven.lambda.action.ActionExecution; | ||
| import in.handyman.raven.lambda.action.IActionExecution; | ||
| import in.handyman.raven.lambda.doa.audit.ActionExecutionAudit; | ||
| import in.handyman.raven.lib.agadia.eocsplitting.EocIdCoverage; | ||
| import in.handyman.raven.lib.agadia.eocsplitting.OriginCoverage; | ||
| import in.handyman.raven.lib.agadia.eocsplitting.QrCodeCoverage; | ||
| import in.handyman.raven.lib.agadia.eocsplitting.SorItemCoverage; | ||
| import in.handyman.raven.lib.model.EpisodeOfCoverage; | ||
| import in.handyman.raven.util.ExceptionUtil; | ||
| import lombok.AllArgsConstructor; | ||
| import lombok.Builder; | ||
| import lombok.Data; | ||
| import lombok.NoArgsConstructor; | ||
| import org.jdbi.v3.core.Jdbi; | ||
| import java.lang.Exception; | ||
| import java.lang.Object; | ||
| import java.lang.Override; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.Marker; | ||
| import org.slf4j.MarkerFactory; | ||
|
|
||
| import java.sql.Timestamp; | ||
| import java.time.LocalDateTime; | ||
| import java.util.HashMap; | ||
| import java.util.List; | ||
| import java.util.Map; | ||
|
|
||
| /** | ||
| * Auto Generated By Raven | ||
| */ | ||
| @ActionExecution( | ||
| actionName = "EpisodeOfCoverage" | ||
| actionName = "EpisodeOfCoverage" | ||
| ) | ||
| public class EpisodeOfCoverageAction implements IActionExecution { | ||
| private final ActionExecutionAudit action; | ||
|
|
||
| private final Logger log; | ||
| public static Map<String, List<Integer>> qrObjectMap = new HashMap<>(); | ||
| public static Boolean hasMember = false; | ||
|
|
||
| private final EpisodeOfCoverage episodeOfCoverage; | ||
|
|
||
| private final Marker aMarker; | ||
|
|
||
| public EpisodeOfCoverageAction(final ActionExecutionAudit action, final Logger log, | ||
| final Object episodeOfCoverage) { | ||
| final Object episodeOfCoverage) { | ||
| this.episodeOfCoverage = (EpisodeOfCoverage) episodeOfCoverage; | ||
| this.action = action; | ||
| this.log = log; | ||
| this.aMarker = MarkerFactory.getMarker(" EpisodeOfCoverage:" + this.episodeOfCoverage.getName()); | ||
| this.aMarker = MarkerFactory.getMarker(" EpisodeOfCoverage:"+this.episodeOfCoverage.getName()); | ||
| } | ||
|
|
||
| @Override | ||
| public void execute() throws Exception { | ||
|
|
||
| try { | ||
| log.info(aMarker, "Episode of coverage Action for {} with group by eoc-id has started" , episodeOfCoverage.getName()); | ||
| final Jdbi jdbi = ResourceAccess.rdbmsJDBIConn(episodeOfCoverage.getResourceConn()); | ||
| if (Integer.parseInt(episodeOfCoverage.getEocIdCount()) > 0) { | ||
| log.info("patient instance check for Eoc id in aggregation"); | ||
| EocIdCoverage eocIdCoverage = new EocIdCoverage(log, episodeOfCoverage, aMarker, action); | ||
| Map<String, List<Integer>> sorIdPageNumbers = eocIdCoverage.SplitByEocId(jdbi, "patient_eoc"); | ||
| OutputQueryExecutor(jdbi, "EID", sorIdPageNumbers); | ||
| log.info("patient instance checked for Eoc id in aggregation and the output result is {}", sorIdPageNumbers); | ||
|
|
||
| } else if (Integer.parseInt(episodeOfCoverage.getEocIdCount()) <= 0) { | ||
| log.info("patient instance extract QR code from source of truth table"); | ||
| QrCodeCoverage qrCodeCoverage = new QrCodeCoverage(log, episodeOfCoverage, aMarker, action); | ||
| Map<String, List<Integer>> qrPagenumbers = qrCodeCoverage.splitByQrcode(jdbi, "qr_code"); | ||
| OutputQueryExecutor(jdbi, "QID", qrPagenumbers); | ||
|
|
||
| log.info("patient instance checked for Qrcode from source of truth and the output result is {}", qrPagenumbers); | ||
|
|
||
| if (qrPagenumbers.isEmpty()) { | ||
| log.info("patient instance check for member_id from aggregation"); | ||
| SorItemCoverage sorItemMemberIdCoverage = new SorItemCoverage(log, episodeOfCoverage, aMarker, action); | ||
| Map<String, List<Integer>> patientMemberPageNumbers = sorItemMemberIdCoverage.splitBySorItem(jdbi, "patient_member_id"); | ||
| OutputQueryExecutor(jdbi, "PID", patientMemberPageNumbers); | ||
| log.info("patient instance check for member_id from aggregation and the output result is {}", patientMemberPageNumbers); | ||
|
|
||
| if (patientMemberPageNumbers.isEmpty()) { | ||
| log.info("patient instance check for patient_name and patient_dob from aggregation"); | ||
| SorItemCoverage sorItemPatientNameCoverage = new SorItemCoverage(log, episodeOfCoverage, aMarker, action); | ||
| Map<String, List<Integer>> patientNamePageNumbers = sorItemPatientNameCoverage.splitBySorItem(jdbi, "patient_name"); | ||
| OutputQueryExecutor(jdbi, "PND", patientNamePageNumbers); | ||
| log.info("patient instance checked for patient_name and patient_dob from aggregation and the output result is {}", patientNamePageNumbers); | ||
|
|
||
| if(patientNamePageNumbers.isEmpty()){ | ||
| log.info("patient instance check for origin id from aggregation"); | ||
| OriginCoverage originCoverage = new OriginCoverage(log, episodeOfCoverage, aMarker, action); | ||
| Map<String, List<Integer>> originIdPageNumbers = originCoverage.aggregateByOrigin(jdbi, episodeOfCoverage.getOriginId()) ; | ||
| OutputQueryExecutor(jdbi, "NID", originIdPageNumbers); | ||
| log.info("patient instance checked for no id from aggregation and the output result is {}", originIdPageNumbers); | ||
| } | ||
| } | ||
|
|
||
| } | ||
| } | ||
|
|
||
| } catch (Exception e) { | ||
| log.error(aMarker, "Episode of coverage Action for {} with group by eoc-id has failed for {}" , episodeOfCoverage.getName(), ExceptionUtil.toString(e)); | ||
| throw new HandymanException("Error in sor grouping", e, action); | ||
| } | ||
|
|
||
| } | ||
|
|
||
| @Override | ||
| public boolean executeIf() throws Exception { | ||
| return episodeOfCoverage.getCondition(); | ||
| } | ||
|
|
||
|
|
||
| public void OutputQueryExecutor(Jdbi jdbi, String sorItem, Map<String, List<Integer>> stringListMap) { | ||
|
|
||
| stringListMap.forEach((s, integers) -> { | ||
| for (Integer integer : integers) { | ||
| CoverageEntity coverageEntity = CoverageEntity.builder() | ||
| .paperNo(integer) | ||
| .pahubId(s) | ||
| .originId(episodeOfCoverage.getOriginId()) | ||
| .groupId(Integer.valueOf(episodeOfCoverage.getGroupId())) | ||
| .createdOn(Timestamp.valueOf(LocalDateTime.now())) | ||
| .sourceOfPahub(sorItem) | ||
| .build(); | ||
| try { | ||
| jdbi.useTransaction(handle -> { | ||
| handle.createUpdate("INSERT INTO " + episodeOfCoverage.getOutputTable() + | ||
| "(pahub_id, origin_id, source_of_pahub,group_id,created_on, paper_no,status,stage,message)" + | ||
| "VALUES (:pahubId , :originId, :sourceOfPahub ,:groupId,:createdOn, :paperNo, 'COMPLETED', 'SOR_GROUPING', 'sor grouping completed')") | ||
| .bindBean(coverageEntity).execute(); | ||
| }); | ||
| log.info(aMarker, "Completed insert for the patient instance {}", coverageEntity); | ||
|
|
||
| } catch (Exception e) { | ||
| log.error(aMarker, "Failed in executed formatted query {} for this sor item {}", e, sorItem); | ||
| throw new HandymanException("Failed in executed formatted query {} for this sor item {}", e, action); | ||
| } | ||
| } | ||
| }); | ||
| } | ||
|
|
||
|
|
||
| @Data | ||
| @AllArgsConstructor | ||
| @NoArgsConstructor | ||
| @Builder | ||
| public static class CoverageEntity { | ||
| private String pahubId; | ||
|
|
||
| private String originId; | ||
| private Integer groupId; | ||
| private String fileId; | ||
| private Timestamp createdOn; | ||
| private String sourceOfPahub; | ||
|
|
||
| private Integer paperNo; | ||
| } | ||
|
|
||
|
|
||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters