honeymoose
/
hapi-fhir
mirror of https://github.com/hapifhir/hapi-fhir.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Tidy code

This commit is contained in:
Tadgh 2021-02-22 22:51:20 -05:00
parent 66c2b456de
commit b5b8d27b39
1 changed files with 4 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
hapi-fhir-jpaserver-base/src/test/java/ca/uhn/fhir/jpa/bulk/BulkDataExportSvcImplR4Test.java
View File

@ -519,23 +519,14 @@ public class BulkDataExportSvcImplR4Test extends BaseJpaR4Test {
public void testGroupBatchJobWorks() throws Exception { public void testGroupBatchJobWorks() throws Exception {
createResources(); createResources();
// Create a bulk job // Create a bulk job
IBulkDataExportSvc.JobInfo jobDetails = myBulkDataExportSvc.submitJob(new GroupBulkDataExportOptions(null, Sets.newHashSet("Immunization"), null, null, myPatientGroupId, true)); IBulkDataExportSvc.JobInfo jobDetails = myBulkDataExportSvc.submitJob(new GroupBulkDataExportOptions(null, Sets.newHashSet("Immunization"), null, null, myPatientGroupId, true));
SearchParameterMap spm = new SearchParameterMap();
spm.setCount(100);
String tempGroupId = myPatientGroupId.toUnqualifiedVersionless().toString();
spm.add("_has", new HasOrListParam().add(new HasParam("Group", "member", "_id", "Group/21")));
spm.addRevInclude(new Include("Immunization:patient"));
spm.setLoadSynchronous(true);
IBundleProvider search = myPatientDao.search(spm);
//Add the UUID to the job //Add the UUID to the job
//TODO GGG START HERE
GroupBulkExportJobParametersBuilder paramBuilder = new GroupBulkExportJobParametersBuilder(); GroupBulkExportJobParametersBuilder paramBuilder = new GroupBulkExportJobParametersBuilder();
paramBuilder.setGroupId(myPatientGroupId.getValue()); paramBuilder.setGroupId(myPatientGroupId.getIdPart());
paramBuilder.setJobUUID(jobDetails.getJobId()); paramBuilder.setJobUUID(jobDetails.getJobId());
paramBuilder.setReadChunkSize(10L); paramBuilder.setReadChunkSize(10L);
@ -589,6 +580,7 @@ public class BulkDataExportSvcImplR4Test extends BaseJpaR4Test {
myObservationDao.update(obs); myObservationDao.update(obs);
Immunization immunization = new Immunization(); Immunization immunization = new Immunization();
immunization.setId("IMM" + i);
immunization.setPatient(new Reference(patId)); immunization.setPatient(new Reference(patId));
if (i % 2 == 0) { if (i % 2 == 0) {
CodeableConcept cc = new CodeableConcept(); CodeableConcept cc = new CodeableConcept();
@ -599,7 +591,7 @@ public class BulkDataExportSvcImplR4Test extends BaseJpaR4Test {
cc.addCoding().setSystem("vaccines").setCode("COVID-19"); cc.addCoding().setSystem("vaccines").setCode("COVID-19");
immunization.setVaccineCode(cc); immunization.setVaccineCode(cc);
} }
myImmunizationDao.create(immunization); myImmunizationDao.update(immunization);
} }
myPatientGroupId = myGroupDao.create(group).getId(); myPatientGroupId = myGroupDao.create(group).getId();