Personal-Twin/hapi-fhir-jpaserver-starter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added exposure of job controller API (#678)

Browse Source
This commit is contained in:
Jens Kristian Villadsen
2024-04-23 14:10:02 +02:00
committed by GitHub
parent 4e2faee32b
commit 31e64f6bab
1 changed files with 42 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
src/main/java/ca/uhn/fhir/jpa/starter/web/JobController.java Normal file
View File

@@ -0,0 +1,42 @@
package ca.uhn.fhir.jpa.starter.web;
import ca.uhn.fhir.batch2.api.IJobCoordinator;
import ca.uhn.fhir.batch2.api.JobOperationResultJson;
import ca.uhn.fhir.batch2.model.JobInstance;
import ca.uhn.fhir.batch2.model.StatusEnum;
import ca.uhn.fhir.batch2.models.JobInstanceFetchRequest;
import jakarta.validation.constraints.Min;
import org.springframework.data.domain.Sort;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping("control")
public class JobController {
private final IJobCoordinator theJobCoordinator;
public JobController(IJobCoordinator theJobCoordinator) {
this.theJobCoordinator = theJobCoordinator;
}
@RequestMapping(value = JobController.JOBS, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
public List<JobInstance> getAllJobs(@RequestParam(name = "pageStart") @Min(0) int pageStart, @RequestParam(name = "batchSize") int batchSize, @RequestParam(name = "jobStatus", required = false) StatusEnum jobStatus) {
JobInstanceFetchRequest jobInstanceFetchRequest = new JobInstanceFetchRequest();
jobInstanceFetchRequest.setPageStart(pageStart);
jobInstanceFetchRequest.setBatchSize(batchSize);
jobInstanceFetchRequest.setJobStatus(jobStatus != null ? jobStatus.toString() : "");
jobInstanceFetchRequest.setSort(Sort.by(Sort.Direction.DESC, JobController.MY_CREATE_TIME));
return theJobCoordinator.fetchAllJobInstances(jobInstanceFetchRequest).getContent();
}
@RequestMapping(value = JobController.JOBS, method = RequestMethod.DELETE, produces = MediaType.APPLICATION_JSON_VALUE)
public JobOperationResultJson cancelInstance(@RequestParam(name = "instanceId") String instanceId) {
return theJobCoordinator.cancelInstance(instanceId);
}
public static final String JOBS = "jobs";
public static final String MY_CREATE_TIME = "myCreateTime";
}