o2o java_O2OA办公平台：流程控制 For Java

Demo_StartProcess.java

package net.o2oa.demos;

​

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.URL;

import java.net.URLConnection;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

​

import org.apache.commons.codec.binary.StringUtils;

import org.json.JSONArray;

import org.json.JSONObject;

​

import net.o2oa.demos.Demo_LoginToServer.LoginResult;

​

/*** 本例使用Java语言发送请求，向服务器进行认证后，启动一个新的流程，创建一个工单* @author O2OA**/

public class Demo_StartProcess {

static final String URL_LOGIN="/x_processplatform_assemble_surface/jaxrs/work/process/";

public static void main( String[] args ) {

String applicationServer = "127.0.0.1";

Integer applicationPort = 20020;

String userName = "张三";

String password = "o2";

String identity ="测试部门张三@9659e75d-b3f3-4eb3-bf26-52812d9228ec@I";

String processFlag = "bc4b0018-edee-4225-838e-1b2db5c24f25";

String processData = "{\"latest\":\"false\",\"title\":\"使用Java启动流程示例一\",\"identity\":\""+identity+"\",\"data\":\"{'name':'这是Name参数'}\"}";

try {

LoginResult result = Demo_LoginToServer.login(applicationServer, applicationPort, userName, password);

if( StringUtils.equals( "success", result.getType() )) {

//成功登录 到O2ServerSystem.out.println("成功登录到O2Server！xtoken=" + result.getToken() );

//启动指定的流程start( applicationServer, applicationPort, processFlag, processData, result.getToken() );

}else {

//登录失败System.out.println("登录失败！message:" + result.getMessage() );

}

} catch (Exception e) {

e.printStackTrace();

}

}

public static List start( String applicationServer, Integer applicationPort, String processFlag, String processData, String xtoken ) throws Exception {

​

//将xtoken添加到httpHeader里，调用服务一定要添加认证过的token Map headMap = getHeader( xtoken );

​

String path = "http://" + applicationServer + ":" + applicationPort + URL_LOGIN + processFlag ;

String responseData = sendPost( path, processData, headMap);

​

/*** {"type": "success","data": [{"taskCompletedList": [],"taskList": [{"id": "773c19e8-46b8-4fd5-b998-618e9a259958","job": "8baa58cb-914c-4c30-b32f-d9c23cf1cf7f","title": "测试----123321","startTime": "2019-10-19 15:41:48","startTimeMonth": "2019-10","work": "a3e0d9c6-aa73-4346-8ad9-d929903477d4","application": "a34ea9d9-cceb-45d4-8e55-d81b932ee438","applicationName": "测试应用","applicationAlias": "发文管理","process": "bc4b0018-edee-4225-838e-1b2db5c24f25","processName": "李义测试","processAlias": "","serial": "","person": "张三@0b31209b-cc14-46c6-afcb-d3823d0abfb7@P","identity": "张三@9659e75d-b3f3-4eb3-bf26-52812d9228ec@I","unit": "测试部门@b3a3a25b-6a10-45ed-8dc5-b354d7449c59@U","activity": "5596e264-7bd7-4d51-ad2d-1a0cf152695f","activityName": "拟稿","activityAlias": "","activityDescription": "","activityType": "manual","activityToken": "9d79104c-dfce-4407-8bd1-cb4981787267","creatorPerson": "张三@0b31209b-cc14-46c6-afcb-d3823d0abfb7@P","creatorIdentity": "张三@9659e75d-b3f3-4eb3-bf26-52812d9228ec@I","creatorUnit": "测试部门@b3a3a25b-6a10-45ed-8dc5-b354d7449c59@U","expired": false,"urged": false,"routeList": ["cadae125-ff16-41e1-89dd-0e04f43295f0"],"routeNameList": ["送核稿"],"routeOpinionList": [""],"routeDecisionOpinionList": [""],"routeName": "","opinion": "","modified": false,"viewed": false,"first": true,"createTime": "2019-10-19 15:41:48","updateTime": "2019-10-19 15:41:48"}],"currentTaskIndex": 0,"id": "322e82e0-b5d6-45a9-9cb3-e4c93ea71150","job": "8baa58cb-914c-4c30-b32f-d9c23cf1cf7f","work": "a3e0d9c6-aa73-4346-8ad9-d929903477d4","completed": false,"fromActivity": "5596e264-7bd7-4d51-ad2d-1a0cf152695f","fromActivityType": "manual","fromActivityName": "拟稿","fromActivityAlias": "","fromActivityToken": "9d79104c-dfce-4407-8bd1-cb4981787267","fromTime": "2019-10-19 15:41:48","application": "a34ea9d9-cceb-45d4-8e55-d81b932ee438","applicationName": "测试应用","process": "bc4b0018-edee-4225-838e-1b2db5c24f25","processName": "李义测试","connected": false,"splitting": false,"splitTokenList": [],"createTime": "2019-10-19 15:41:48","updateTime": "2019-10-19 15:41:48"}],"message": "","date": "2019-10-19 15:41:48","spent": 192,"size": 1,"count": 0,"position": 0}*/

JSONObject jsonObj = new JSONObject( responseData );

JSONArray dataArray = jsonObj.getJSONArray("data");

List workIds = new ArrayList<>();

if( dataArray != null && dataArray.length() > 0 ) {

for (int i = 0; i < dataArray.length(); i++) {

JSONObject data = (JSONObject) dataArray.get(i);

String workid = data.getString("work");

workIds.add( workid );

System.out.println("流程启动完成，生成workId=" + workid);

}

}

return workIds;

}

public static String sendPost( String url, String param, Map headers ) {

PrintWriter out = null;

BufferedReader in = null;

String result = "";

try {

URL realUrl = new URL(url);

URLConnection conn = realUrl.openConnection();

headers.entrySet().forEach( header->{

conn.setRequestProperty(header.getKey(),header.getValue());

});

​

conn.setDoOutput(true);

conn.setDoInput(true);

out = new PrintWriter(conn.getOutputStream());

out.print(param);

out.flush();

in = new BufferedReader(

new InputStreamReader(conn.getInputStream()));

String line;

while ((line = in.readLine()) != null) {

result += line;

}

} catch (Exception e) {

System.out.println(" POST" + e);

e.printStackTrace();

} finally {

try {

if (out != null) {

out.close();

}

if (in != null) {

in.close();

}

} catch (IOException ex) {

ex.printStackTrace();

}

}

return result;

}

public static Map getHeader( String xtoken ) {

Map headMap = new HashMap();

headMap.put("x-token", xtoken );

headMap.put("Cookie", "x-token=" + xtoken );

headMap.put("accept", "*/*");

headMap.put("connection", "Keep-Alive");

headMap.put("Content-Type", "application/json; charset=utf-8");

headMap.put("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");

return headMap;

}

}