本例使用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 = "o2oa@2022"; 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() )) { //成功登录 到O2Server System.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<String> start( String applicationServer, Integer applicationPort, String processFlag, String processData, String xtoken ) throws Exception { //将xtoken添加到httpHeader里,调用服务一定要添加认证过的token Map<String, String> headMap = getHeader( xtoken ); String path = "http://" + applicationServer + ":" + applicationPort + URL_LOGIN + processFlag ; String responseData = sendPost( path, processData, headMap); JSONObject jsonObj = new JSONObject( responseData ); JSONArray dataArray = jsonObj.getJSONArray("data"); List<String> 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<String,String> 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<String, String> getHeader( String xtoken ) { Map<String, String> headMap = new HashMap<String, String>(); 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; } }
返回Json格式:
{ "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 }
pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>net.o2oa.demos</groupId> <artifactId>test_o2oa_java_demo</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>test_start_process_demo</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties> <dependencies> <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient --> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> <version>4.5.10</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpcore-nio --> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpcore-nio</artifactId> <version>4.4.12</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpcore --> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpcore</artifactId> <version>4.4.12</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpmime --> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpmime</artifactId> <version>4.5.10</version> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.9</version> </dependency> <dependency> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> <version>2.8.5</version> </dependency> <!-- https://mvnrepository.com/artifact/org.json/json --> <dependency> <groupId>org.json</groupId> <artifactId>json</artifactId> <version>20190722</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> </dependencies> </project>
若有收获,就点个赞吧