This commit is contained in:
Tadgh 2020-07-13 12:00:19 -07:00
parent c3b89b4ad5
commit 677bc5577b
4 changed files with 5 additions and 7 deletions

View File

@ -78,13 +78,11 @@ public class BulkExportJobConfig {
return new CreateBulkExportEntityTasklet();
}
@Bean
public JobParametersValidator bulkJobParameterValidator() {
return new BulkExportJobParameterValidator();
}
@Bean
public Step bulkExportGenerateResourceFilesStep() {
return myStepBuilderFactory.get("bulkExportGenerateResourceFilesStep")
@ -95,8 +93,6 @@ public class BulkExportJobConfig {
.build();
}
@Bean
@JobScope
public BulkExportJobCloser bulkExportJobCloser() {

View File

@ -60,6 +60,7 @@ public class EmpiStorageInterceptor implements IEmpiStorageInterceptor {
@Autowired
private PersonHelper myPersonHelper;
@Hook(Pointcut.STORAGE_PRESTORAGE_RESOURCE_CREATED)
public void blockManualPersonManipulationOnCreate(IBaseResource theBaseResource, RequestDetails theRequestDetails, ServletRequestDetails theServletRequestDetails) {

View File

@ -28,9 +28,6 @@ public class EmpiBatchSvcImpl implements IEmpiBatchService {
@Autowired
private DaoRegistry myDaoRegistry;
@Autowired
private EmpiMatchLinkSvc myEmpiMatchLinkSvc;
@Autowired
private IChannelNamer myChannelNamer;
@ -38,6 +35,7 @@ public class EmpiBatchSvcImpl implements IEmpiBatchService {
@Autowired
private FhirContext myFhirContext;
@Autowired
private IChannelFactory myChannelFactory;
@ -55,6 +53,7 @@ public class EmpiBatchSvcImpl implements IEmpiBatchService {
IBundleProvider search = patientDao.search(new SearchParameterMap().setLoadSynchronous(true));
List<IBaseResource> resources = search.getResources(0, search.size());
for (IBaseResource resource : resources) {
ResourceModifiedJsonMessage rmjm = new ResourceModifiedJsonMessage();
ResourceModifiedMessage resourceModifiedMessage = new ResourceModifiedMessage(myFhirContext, resource, ResourceModifiedMessage.OperationTypeEnum.MANUALLY_TRIGGERED);
@ -62,6 +61,7 @@ public class EmpiBatchSvcImpl implements IEmpiBatchService {
rmjm.setPayload(resourceModifiedMessage);
myEmpiChannelProducer.send(rmjm);
}
}
private EmpiTargetType getTargetTypeOrThrowException(String theResourceType) {

View File

@ -166,6 +166,7 @@ public class EmpiProviderR4 extends BaseEmpiProvider {
return (Parameters) myEmpiLinkUpdaterSvc.notDuplicatePerson(person, target, createEmpiContext(theRequestDetails));
}
//TODO accept a search string, parse it to make search parameters, and then submit those as the search.
@Operation(name = ProviderConstants.EMPI_BATCH_RUN, idempotent = true)
public void batchRunEmpi(@OperationParam(name= ProviderConstants.EMPI_BATCH_RUN_TARGET_TYPE, max=1) StringType theTargetType, ServletRequestDetails theRequestDetails) {
if (theTargetType == null) {