问如何使用NodeJs实现Red hat流程自动化管理器(RHPAM)

EN

private void runjBPMApi() throws IOException {
    RestTemplate restTemplate = new RestTemplate();
    HttpHeaders headers = new HttpHeaders();
    headers.add("content-type", "application/json");
    headers.add("accept", "application/json");

    HttpHeaders headersMary = new HttpHeaders();
    headersMary.addAll(headers);
    headersMary.add("Authorization", "Basic " + new String(Base64.getEncoder().encode("mary:mary".getBytes())));

    HttpHeaders headersJack = new HttpHeaders();
    headersJack.addAll(headers);
    headersJack.add("Authorization", "Basic " + new String(Base64.getEncoder().encode("jack:jack".getBytes())));        

    HttpHeaders headersJohn = new HttpHeaders();
    headersJohn.addAll(headers);
    headersJohn.add("Authorization", "Basic " + new String(Base64.getEncoder().encode("john:john".getBytes())));        

    ObjectMapper mapper = new ObjectMapper(); 

    String startEval = "{\"employee\":\"jack\"}";
    HttpEntity<String> requestEval = new HttpEntity<>(startEval, headersMary); 
    ResponseEntity<String> evaluation = 
        restTemplate.exchange(serverRestUrl+"/containers/"+containerId+"/processes/Evaluation.Evaluation/instances",
            HttpMethod.POST, 
            requestEval, String.class );

    Long processId = Long.parseLong( evaluation.getBody() );
    log.info("Started Process Instance: " + processId.toString());

    String selfEval = "{\"selfeval\":\"did lots of work\"}";
    performUserTaskApi(restTemplate, headersJack, selfEval, false, mapper);
    String pmEval = "{\"pmeval\":\"Projects Done\"}";
    performUserTaskApi(restTemplate, headersJohn, pmEval, true, mapper);
    String hrEval = "{\"hreval\":\"No Incidents\"}";
    performUserTaskApi(restTemplate, headersMary, hrEval, true, mapper);

    HttpEntity<String> requestVariables = new HttpEntity<>(headersMary);
    ResponseEntity<String> variables = 
        restTemplate.exchange(serverRestUrl+"/containers/"+containerId+"/processes/instances/"+processId+"/variables/instances",
            HttpMethod.GET, 
            requestVariables, String.class );
    JsonNode variableTree = mapper.readTree(variables.getBody());
    Iterator<JsonNode> variablesItr = variableTree.findValue("variable-instance").elements();
    while ( variablesItr.hasNext() ) {
        log.info( variablesItr.next().toString() );
    }
}

private void performUserTaskApi(RestTemplate restTemplate, HttpHeaders userHeaders, String params, boolean claim, ObjectMapper mapper) throws IOException {
    HttpEntity<String> emptyEntity = new HttpEntity<>(userHeaders);
    HttpEntity<String> paramsEntity = new HttpEntity<>(params, userHeaders);
    ResponseEntity<String> potOwners = 
        restTemplate.exchange(serverRestUrl+"/queries/tasks/instances/pot-owners",
            HttpMethod.GET, emptyEntity, String.class );

    JsonNode evalTree = mapper.readTree(potOwners.getBody());
    Long taskId = evalTree.findValue("task-id").asLong();

    if ( claim ) {
        restTemplate.exchange(serverRestUrl+"/containers/"+containerId+"/tasks/"+taskId+"/states/claimed",
            HttpMethod.PUT, emptyEntity, String.class );
    }
    restTemplate.exchange(serverRestUrl+"/containers/"+containerId+"/tasks/"+taskId+"/states/started",
        HttpMethod.PUT, emptyEntity, String.class );

    restTemplate.exchange(serverRestUrl+"/containers/"+containerId+"/tasks/"+taskId+"/states/completed",
        HttpMethod.PUT, paramsEntity, String.class );

}