import org.activiti.engine.history.HistoricProcessInstanceQuery; //導入方法依賴的package包/類

protected DataResponse getQueryResponse(HistoricProcessInstanceQueryRequest queryRequest, Map

allRequestParams) {

HistoryService historyService = BPMNOSGIService.getHistoryService();

HistoricProcessInstanceQuery query = historyService.createHistoricProcessInstanceQuery();

// Populate query based on request

if (queryRequest.getProcessInstanceId() != null) {

query.processInstanceId(queryRequest.getProcessInstanceId());

}

if (queryRequest.getProcessInstanceIds() != null && !queryRequest.getProcessInstanceIds().isEmpty()) {

query.processInstanceIds(new HashSet(queryRequest.getProcessInstanceIds()));

}

if (queryRequest.getProcessDefinitionKey() != null) {

query.processDefinitionKey(queryRequest.getProcessDefinitionKey());

}

if (queryRequest.getProcessDefinitionId() != null) {

query.processDefinitionId(queryRequest.getProcessDefinitionId());

}

if (queryRequest.getProcessBusinessKey() != null) {

query.processInstanceBusinessKey(queryRequest.getProcessBusinessKey());

}

if (queryRequest.getInvolvedUser() != null) {

query.involvedUser(queryRequest.getInvolvedUser());

}

if (queryRequest.getSuperProcessInstanceId() != null) {

query.superProcessInstanceId(queryRequest.getSuperProcessInstanceId());

}

if (queryRequest.getExcludeSubprocesses() != null) {

query.excludeSubprocesses(queryRequest.getExcludeSubprocesses());

}

if (queryRequest.getFinishedAfter() != null) {

query.finishedAfter(queryRequest.getFinishedAfter());

}

if (queryRequest.getFinishedBefore() != null) {

query.finishedBefore(queryRequest.getFinishedBefore());

}

if (queryRequest.getStartedAfter() != null) {

query.startedAfter(queryRequest.getStartedAfter());

}

if (queryRequest.getStartedBefore() != null) {

query.startedBefore(queryRequest.getStartedBefore());

}

if (queryRequest.getStartedBy() != null) {

query.startedBy(queryRequest.getStartedBy());

}

if (queryRequest.getFinished() != null) {

if (queryRequest.getFinished()) {

query.finished();

} else {

query.unfinished();

}

}

if (queryRequest.getIncludeProcessVariables() != null) {

if (queryRequest.getIncludeProcessVariables()) {

query.includeProcessVariables();

}

}

if (queryRequest.getVariables() != null) {

addVariables(query, queryRequest.getVariables());

}

if (queryRequest.getTenantId() != null) {

query.processInstanceTenantId(queryRequest.getTenantId());

}

if (queryRequest.getTenantIdLike() != null) {

query.processInstanceTenantIdLike(queryRequest.getTenantIdLike());

}

if (Boolean.TRUE.equals(queryRequest.getWithoutTenantId())) {

query.processInstanceWithoutTenantId();

}

RestResponseFactory restResponseFactory = new RestResponseFactory();

DataResponse dataResponse = new HistoricProcessInstancePaginateList(restResponseFactory, uriInfo).paginateList(

allRequestParams, queryRequest, query, "processInstanceId", allowedSortProperties);

return dataResponse;

}