SagaController.java 文件源码

@ApiResponses({
    @ApiResponse(code = 200, response = String.class, message = "success"),
    @ApiResponse(code = 400, response = String.class, message = "illegal request content"),
})
@CrossOrigin
@RequestMapping(value = "requests", method = GET)
public ResponseEntity<SagaExecutionQueryResult> queryExecutions(
    @RequestParam(name = "pageIndex") String pageIndex,
    @RequestParam(name = "pageSize") String pageSize,
    @RequestParam(name = "startTime") String startTime,
    @RequestParam(name = "endTime") String endTime) {
  if (isRequestParamValid(pageIndex, pageSize, startTime, endTime)) {
    try {
      return ResponseEntity.ok(queryService.querySagaExecution(pageIndex, pageSize, startTime, endTime));
    } catch (ParseException ignored) {
      throw new InvocationException(BAD_REQUEST, "illegal request content");
    }
  } else {
    throw new InvocationException(BAD_REQUEST, "illegal request content");
  }
}