28 files changed, 1416 insertions, 0 deletions
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/WorkflowApp.java b/wfenginemgrservice/src/main/java/org/onap/workflow/WorkflowApp.java
new file mode 100644
index 0000000..23f6ac6
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/WorkflowApp.java
@@ -0,0 +1,42 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow;
+
+import org.glassfish.jersey.media.multipart.MultiPartFeature;
+import org.onap.workflow.common.Config;
+
+import io.dropwizard.Application;
+import io.dropwizard.setup.Environment;
+
+public class WorkflowApp extends Application<WorkflowAppConfig> {
+
+	public static void main(String[] args) throws Exception {
+		new WorkflowApp().run(args);
+	}
+
+	public String getName() {
+		return " Workflow APP ";
+	}
+
+	@Override
+	public void run(WorkflowAppConfig configuration, Environment environment) throws Exception {
+		// TODO Auto-generated method stub
+	    environment.jersey().register(MultiPartFeature.class);
+	    
+	    Config.setWorkflowAppConfig(configuration);
+	}
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/WorkflowAppConfig.java b/wfenginemgrservice/src/main/java/org/onap/workflow/WorkflowAppConfig.java
new file mode 100644
index 0000000..71985cc
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/WorkflowAppConfig.java
@@ -0,0 +1,43 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow;
+
+import javax.validation.Valid;
+
+import org.hibernate.validator.constraints.NotEmpty;
+import org.onap.workflow.entity.MsbClientConfig;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import io.dropwizard.Configuration;
+
+public class WorkflowAppConfig extends Configuration {
+
+  @NotEmpty
+  private String defaultName = "WORKFLOW-ACTIVITI-EXT";
+  @NotEmpty
+  @JsonProperty
+  private String apidescription = "ZTE workflow-activiti-ext rest API";
+  
+  @JsonProperty
+  @Valid
+  private MsbClientConfig msbClientConfig;
+
+  public MsbClientConfig getMsbClientConfig() {
+    return msbClientConfig;
+  }
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/activitiext/common/ToolUtil.java b/wfenginemgrservice/src/main/java/org/onap/workflow/activitiext/common/ToolUtil.java
new file mode 100644
index 0000000..fe573e2
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/activitiext/common/ToolUtil.java
@@ -0,0 +1,52 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.activitiext.common;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+
+
+public class ToolUtil {
+  private static final Logger logger = LoggerFactory.getLogger(ToolUtil.class);
+  public static boolean isEmptyString(String val) {
+    return ((val == null || "".equals(val)) ? true : false);
+  }
+
+  public static boolean isTrimedEmptyString(String val) {
+    return ((val == null || "".equals(val.trim())) ? true : false);
+  }
+
+  public static boolean isTrimedEmptyArray(String[] val) {
+    return ((val == null || val.length == 0) ? true : false);
+  }
+  
+  /**
+   * @param ins
+   */
+  public static void closeInputStream(InputStream ins) {
+    if (ins != null) {
+      try {
+        ins.close();
+      } catch (IOException e) {
+        logger.info("Close InputStream failed.", e);
+      }
+    }
+  }
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/activitiext/common/package-info.java b/wfenginemgrservice/src/main/java/org/onap/workflow/activitiext/common/package-info.java
new file mode 100644
index 0000000..d64450f
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/activitiext/common/package-info.java
@@ -0,0 +1,16 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.activitiext.common;
+\ No newline at end of file
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/Config.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/Config.java
new file mode 100644
index 0000000..49dc227
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/Config.java
@@ -0,0 +1,31 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.common;
+
+import org.onap.workflow.WorkflowAppConfig;
+
+public class Config {
+    private static WorkflowAppConfig workflowAppConfig;
+
+    public static WorkflowAppConfig getWorkflowAppConfig() {
+        return workflowAppConfig;
+    }
+
+    public static void setWorkflowAppConfig(WorkflowAppConfig config) {
+    	workflowAppConfig = config;
+    }
+}
+\ No newline at end of file
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java
new file mode 100644
index 0000000..00f10d8
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java
@@ -0,0 +1,33 @@
+/**
+ * Copyright 2017 [ZTE] and others.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.common;
+
+public enum EnumModuleUrl {
+  ACTIVITI {
+    @Override
+    public String getApiRootDomain() {
+      return "/activiti-rest/service";
+    }
+  };
+
+  public abstract String getApiRootDomain();
+
+  public static String getBaseUrl(EnumModuleUrl enumUrl) {
+    String msbHost = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
+    return "http://" + msbHost + ":" + "80" + enumUrl.getApiRootDomain();
+  }
+
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumStatus.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumStatus.java
new file mode 100644
index 0000000..e2d1c5c
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumStatus.java
@@ -0,0 +1,21 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.common;
+
+public enum EnumStatus {
+  SUCCESS, FAIL
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestClient.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestClient.java
new file mode 100644
index 0000000..f037757
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestClient.java
@@ -0,0 +1,310 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.common;
+
+import java.io.IOException;
+
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpHost;
+import org.apache.http.HttpRequest;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.ResponseHandler;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpDelete;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpPut;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.BasicResponseHandler;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
+import org.onap.workflow.tools.Constants;
+import org.onap.workflow.tools.HttpDeleteWithBody;
+import org.onap.workflow.tools.RequestParameters;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.google.gson.Gson;
+
+public class RestClient {
+  private static final String HTTP = "http";
+  private static final Logger logger = LoggerFactory.getLogger(RestClient.class);
+
+  enum HttpMethod {
+    GET, POST, PUT, DELETE
+  }
+
+  /**
+   * 
+   * @param method
+   * @param ip
+   * @param port
+   * @param url
+   * @param body
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static RestResponse executeHttp(HttpMethod method, String ip, Integer port, String url,
+      HttpEntity body) throws ClientProtocolException, IOException {
+    logger.info("deployfile method send");
+    CloseableHttpClient httpclient = HttpClients.createDefault();
+    HttpResponse httpResponse = null;
+    RestResponse result = new RestResponse();
+    try {
+      if (ip == null) {
+        ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
+      }
+      if (port == null) {
+        port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
+      }
+      HttpHost target = new HttpHost(ip, port, HTTP);
+      HttpRequest request = getRequest(method, url, body);
+      logger.info("deployfile method send ip"+ip);
+      request.addHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());
+
+      httpResponse = httpclient.execute(target, request);
+      HttpEntity entity = httpResponse.getEntity();
+      logger.info("deployfile method send");
+      if (entity != null) {
+        result.setStatusCode(httpResponse.getStatusLine().getStatusCode());
+        logger.info("reply status code deploy"+httpResponse.getStatusLine().getStatusCode());
+        result.setResult(EntityUtils.toString(entity));
+      }
+    } catch (IOException e) {
+      logger.warn("Close httpclient failed.", e);
+    } finally {
+      if (httpclient != null) {
+        try {
+          httpclient.close();
+        } catch (IOException e) {
+          logger.warn("Close httpclient failed.", e);
+        }
+      }
+    }
+    return result;
+  }
+
+  private static HttpRequest getRequest(HttpMethod method, String url, HttpEntity body) {
+    HttpRequest request = null;
+    switch (method) {
+      case GET:
+        request = new HttpGet(url);
+        break;
+      case POST:
+        request = new HttpPost(url);
+        ((HttpPost) request).setEntity(body);
+        break;
+      case PUT:
+        request = new HttpPut(url);
+        ((HttpPut) request).setEntity(body);
+        break;
+      case DELETE:
+        request = new HttpDelete(url);
+        break;
+      default:
+        break;
+    }
+    return request;
+  }
+
+  /**
+   * 
+   * @param ip
+   * @param port
+   * @param url
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static String get(String ip, int port, String url)
+      throws ClientProtocolException, IOException {
+    return executeHttp(HttpMethod.GET, ip, port, url, null).getResult();
+  }
+
+  /**
+   * 
+   * @param ip
+   * @param port
+   * @param url
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static RestResponse delete(String ip, int port, String url)
+      throws ClientProtocolException, IOException {
+    return executeHttp(HttpMethod.GET, ip, port, url, null);
+  }
+
+  /**
+   * 
+   * @param ip
+   * @param port
+   * @param url
+   * @param requestBody
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static RestResponse post(String ip, int port, String url, HttpEntity requestBody)
+      throws ClientProtocolException, IOException {
+    return executeHttp(HttpMethod.POST, ip, port, url, requestBody);
+  }
+
+
+
+  /**
+   * 
+   * @param method
+   * @param ip
+   * @param port
+   * @param url
+   * @param body
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static RestResponse executeHttpDeleteDeploy(HttpMethod method, String ip, Integer port,
+      String url) throws ClientProtocolException, IOException {
+    if (ip == null) {
+      ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
+    }
+    port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
+    RestResponse result = new RestResponse();
+    CloseableHttpClient httpClient = HttpClients.createDefault();
+    try {
+      httpClient = HttpClients.createDefault();
+      // "http://localhost:8080/activiti-rest/service/repository/deployments/167501"
+      String deleteUrl = Constants.HTTP_HEADER + ip + Constants.COLON + port + url;
+      HttpDeleteWithBody httpDeteTest = new HttpDeleteWithBody(deleteUrl);
+      Gson gson = new Gson();
+      RequestParameters reqPa = new RequestParameters();
+      reqPa.setCasCade(true);
+      String jsonStr = gson.toJson(reqPa, RequestParameters.class);
+      StringEntity requestEntity = new StringEntity(jsonStr, "UTF-8");
+      requestEntity.setContentEncoding("UTF-8");
+      httpDeteTest.setHeader("Content-type", "application/json");
+      httpDeteTest.setHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());
+      httpDeteTest.setEntity(new StringEntity(jsonStr));
+      // returnValue = httpClient.execute(httpDeteTest, responseHandler); // 调接口获取返回值时，必须用此方法
+      CloseableHttpResponse httpResonse = httpClient.execute(httpDeteTest);
+      int statusCode = httpResonse.getStatusLine().getStatusCode();
+      result.setStatusCode(statusCode);
+   //   result.setResult(EntityUtils.toString(httpResonse.getEntity()));
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+
+    finally {
+      try {
+        httpClient.close();
+      } catch (IOException e) {
+        // TODO Auto-generated catch block
+        e.printStackTrace();
+      }
+    }
+
+    return result;
+  }
+
+  /**
+   * 
+   * @param method
+   * @param ip
+   * @param port
+   * @param url
+   * @param body
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static RestResponse executeHttpStartIntance(HttpMethod method, String ip, Integer port,
+      String url, ActivitiStartProcessRequest object) throws ClientProtocolException, IOException {
+    String returnValue = "";
+    RestResponse result = new RestResponse();
+    CloseableHttpClient httpClient = HttpClients.createDefault();
+    ResponseHandler<String> responseHandler = new BasicResponseHandler();
+    try {
+      httpClient = HttpClients.createDefault();
+      if (ip == null) {
+        ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
+      }
+      port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
+
+      HttpPost httpPost = new HttpPost(Constants.HTTP_HEADER + ip + ":" + port + url);
+      Gson gson = new Gson();
+      String jsonStr = gson.toJson(object, ActivitiStartProcessRequest.class);
+      StringEntity requestEntity = new StringEntity(jsonStr, "utf-8");
+      requestEntity.setContentEncoding("UTF-8");
+      httpPost.setHeader("Content-type", "application/json");
+      httpPost.setHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());
+      httpPost.setEntity(requestEntity);
+      returnValue = httpClient.execute(httpPost, responseHandler); // 调接口获取返回值时，必须用此方法
+      CloseableHttpResponse httpResonse = httpClient.execute(httpPost);
+      int statusCode = httpResonse.getStatusLine().getStatusCode();
+      returnValue = EntityUtils.toString(httpResonse.getEntity(),"UTF-8");
+      result.setStatusCode(statusCode);
+      result.setResult(returnValue);
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+
+    finally {
+      try {
+        httpClient.close();
+      } catch (IOException e) {
+        // TODO Auto-generated catch block
+        e.printStackTrace();
+      }
+    }
+
+    return result;
+  }
+
+  /**
+   * 
+   * @param ip
+   * @param port
+   * @param url
+   * @param requestBody
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static RestResponse post(String ip, Integer port, String url,
+      ActivitiStartProcessRequest requestBody) throws ClientProtocolException, IOException {
+    return executeHttpStartIntance(HttpMethod.POST, ip, port, url, requestBody);
+  }
+
+  /**
+   * 
+   * @param ip
+   * @param port
+   * @param url
+   * @param requestBody
+   * @return
+   * @throws ClientProtocolException
+   * @throws IOException
+   */
+  public static RestResponse post(String ip, Integer port, String url)
+      throws ClientProtocolException, IOException {
+    return executeHttpDeleteDeploy(HttpMethod.DELETE, ip, port, url);
+  }
+
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestClientUtils.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestClientUtils.java
new file mode 100644
index 0000000..d90077c
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestClientUtils.java
@@ -0,0 +1,42 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.common;
+
+import java.io.InputStream;
+
+import org.apache.http.HttpEntity;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.mime.MultipartEntityBuilder;
+
+/**
+ * 
+ * @author 10090474
+ * 
+ */
+public class RestClientUtils {
+  /**
+   * 
+   * @param ins
+   * @param fileName
+   * @return
+   */
+  public static HttpEntity buildMultipartRequest(InputStream ins, String fileName) {
+    MultipartEntityBuilder builder = MultipartEntityBuilder.create();
+    builder.seContentType(ContentType.MULTIPART_FORM_DATA);
+    builder.addBinaryBody("file", ins, ContentType.APPLICATION_OCTET_STREAM, fileName);
+    return builder.build();
+  }
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java
new file mode 100644
index 0000000..21467bf
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java
@@ -0,0 +1,37 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.common;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class RestResponse {
+  private int statusCode;
+  private String result;
+
+  @Override
+  public String toString() {
+    return "RestResponse [statusCode=" + statusCode + ", result=" + result + "]";
+  }
+
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/ToolUtil.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/ToolUtil.java
new file mode 100644
index 0000000..c148eb3
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/ToolUtil.java
@@ -0,0 +1,67 @@
+/**
+ * Copyright (C) 2017 ZTE, Inc. and others. All rights reserved. (ZTE)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *         http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.common;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.Charset;
+
+import org.apache.commons.codec.binary.Base64;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+
+
+public class ToolUtil {
+  private static final Logger logger = LoggerFactory.getLogger(ToolUtil.class);
+  
+  /**
+   * 构造Basic Auth认证头信息
+   * 
+   * @return
+   */
+  public static String getHeader() {
+    String auth = "kermit" + ":" +"kermit";
+    byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(Charset.forName("US-ASCII")));
+    String authHeader = "Basic " + new String(encodedAuth);
+    return authHeader;
+  }
+  
+  public static boolean isEmptyString(String val) {
+    return ((val == null || "".equals(val)) ? true : false);
+  }
+
+  public static boolean isTrimedEmptyString(String val) {
+    return ((val == null || "".equals(val.trim())) ? true : false);
+  }
+
+  public static boolean isTrimedEmptyArray(String[] val) {
+    return ((val == null || val.length == 0) ? true : false);
+  }
+  
+  /**
+   * @param ins
+   */
+  public static void closeInputStream(InputStream ins) {
+    if (ins != null) {
+      try {
+        ins.close();
+      } catch (IOException e) {
+        logger.info("Close InputStream failed.", e);
+      }
+    }
+  }
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/package-info.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/package-info.java
new file mode 100644
index 0000000..e47fcb8
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/package-info.java
@@ -0,0 +1,16 @@
+/**
+ * Copyright 2017 [ZTE] and others.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.common;
+\ No newline at end of file
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java
new file mode 100644
index 0000000..6a1920e
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java
@@ -0,0 +1,31 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class DeployBpmnFileResponse {
+  private int status;
+  private String message;
+  private String deployedId;
+  private String processId;
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java
new file mode 100644
index 0000000..e73c4f2
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java
@@ -0,0 +1,26 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.entity;
+
+import lombok.Data;
+
+@Data
+public class MsbClientConfig {
+
+	private String msbSvrIp;
+	private Integer msbSvrPort;
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java
new file mode 100644
index 0000000..cddaa09
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java
@@ -0,0 +1,33 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.entity;
+
+import java.util.Map;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class StartProcessRequest {
+  private String processDefinitionKey;
+  private Map<String, String> params;
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java
new file mode 100644
index 0000000..5ad3d12
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java
@@ -0,0 +1,25 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.externalservice.entity.activitientitiy;
+
+import lombok.Data;
+
+@Data
+public class ActivitiDeployResponse {
+  private String id;
+  private String deploymentTime;
+  private String url;
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java
new file mode 100644
index 0000000..ae7edf1
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java
@@ -0,0 +1,25 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.externalservice.entity.activitientitiy;
+
+import lombok.Data;
+
+@Data
+public class ActivitiStartProcessRequest {
+  private String processDefinitionKey;
+  private ActivitiStartProcessRequestParam[] variables;
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java
new file mode 100644
index 0000000..35dc487
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java
@@ -0,0 +1,27 @@
+/**
+ * Copyright 2017 [ZTE] and others.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.externalservice.entity.activitientitiy;
+
+import lombok.Data;
+
+/**
+ *
+ */
+@Data
+public class ActivitiStartProcessRequestParam {
+  private String name;
+  private String value;
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/package-info.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/package-info.java
new file mode 100644
index 0000000..102c36f
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/package-info.java
@@ -0,0 +1,19 @@
+/**
+ * Copyright 2017 [ZTE] and others.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ *
+ */
+package org.onap.workflow.externalservice.entity.activitientitiy;
+\ No newline at end of file
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumer.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumer.java
new file mode 100644
index 0000000..017cf35
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumer.java
@@ -0,0 +1,142 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.workflow.externalservice.service.activitiservice;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+import javax.ws.rs.core.Response;
+
+import org.apache.http.client.ClientProtocolException;
+import org.glassfish.jersey.client.ClientConfig;
+import org.onap.workflow.common.Config;
+import org.onap.workflow.common.EnumModuleUrl;
+import org.onap.workflow.common.RestClient;
+import org.onap.workflow.common.RestClientUtils;
+import org.onap.workflow.common.RestResponse;
+import org.onap.workflow.common.ToolUtil;
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiDeployResponse;
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
+import org.onap.workflow.tools.Constants;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.eclipsesource.jaxrs.consumer.ConsumerFactory;
+import com.google.gson.Gson;
+
+/**
+ * 
+ * @author 10090474
+ * 
+ */
+public class ActivitiServiceConsumer {
+  private static final Logger logger = LoggerFactory.getLogger(ActivitiServiceConsumer.class);
+  private static final String DEPLOY_BPMNFILE_URL =
+      EnumModuleUrl.ACTIVITI.getApiRootDomain() + "/repository/deployments";
+
+  private static IActivitiRestService activitiServiceProxy = null;
+
+  private static IActivitiRestService getActivitiService() {
+    if (activitiServiceProxy == null) {
+      ClientConfig config = new ClientConfig();
+      activitiServiceProxy = ConsumerFactory.createConsumer(
+          EnumModuleUrl.getBaseUrl(EnumModuleUrl.ACTIVITI), config, IActivitiRestService.class);
+
+    }
+    return activitiServiceProxy;
+  }
+
+  public static RestResponse undeploybpmnfile(String deploymentId) {
+    /*
+     * IActivitiRestService activitiProxy = getActivitiService();
+     * activitiProxy.undeployBpmnFile(deploymentId);
+     */
+    RestResponse res = deleteDeployProcess(deploymentId);
+    // activitiProxy.startProcess(request);
+
+    return res;
+  }
+
+  public static RestResponse startBpmnProcess(ActivitiStartProcessRequest request) {
+    // IActivitiRestService activitiProxy = getActivitiService();
+    // startProcess( request);
+    // activitiProxy.startProcess(request);
+    return startProcess(request);
+  }
+
+  public static RestResponse deleteDeployProcess(String deploymentId) {
+    // TODO Auto-generated method stub
+    RestResponse res = null;
+    try {
+      res = RestClient.post(null, null, Constants.DEPLOY_BPMNFILE_URL + "/" + deploymentId);
+    } catch (ClientProtocolException e) {
+      // TODO Auto-generated catch block
+      e.printStackTrace();
+    } catch (IOException e) {
+      // TODO Auto-generated catch block
+      e.printStackTrace();
+    }
+
+    return res;
+  }
+
+  public static RestResponse startProcess(ActivitiStartProcessRequest request) {
+    // TODO Auto-generated method stub
+    RestResponse res = null;
+    try {
+      res = RestClient.post(null, null, Constants.ACITIVI_START_INSTANCE_URL, request);
+    } catch (ClientProtocolException e) {
+      // TODO Auto-generated catch block
+      e.printStackTrace();
+    } catch (IOException e) {
+      // TODO Auto-generated catch block
+      e.printStackTrace();
+    }
+
+    // if (Response.Status.OK.getStatusCode() == res.getStatusCode()
+    // || Response.Status.CREATED.getStatusCode() == res.getStatusCode()) {
+    // Response response = new Gson().fromJson(res.getResult(), Response.class);
+    // return response;
+    // }
+    return res;
+  }
+
+  public static ActivitiDeployResponse deploybpmnfile(InputStream ins, String filename)
+      throws ClientProtocolException, IOException {
+    try {
+      return deployPackage2Activiti(ins, filename);
+    } finally {
+      ToolUtil.closeInputStream(ins);
+    }
+  }
+
+  private static ActivitiDeployResponse deployPackage2Activiti(InputStream ins, String filename)
+      throws ClientProtocolException, IOException {
+    String ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
+    int port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
+    RestResponse res = RestClient.post(ip, port, DEPLOY_BPMNFILE_URL,
+        RestClientUtils.buildMultipartRequest(ins, filename));
+    logger.info("deployfile to activiti return. {}", res);
+
+    if (Response.Status.OK.getStatusCode() == res.getStatusCode()
+        || Response.Status.CREATED.getStatusCode() == res.getStatusCode()) {
+      ActivitiDeployResponse response =
+          new Gson().fromJson(res.getResult(), ActivitiDeployResponse.class);
+      return response;
+    }
+    return null;
+  }
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/IActivitiRestService.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/IActivitiRestService.java
new file mode 100644
index 0000000..b2a8366
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/IActivitiRestService.java
@@ -0,0 +1,44 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.externalservice.service.activitiservice;
+
+import javax.ws.rs.Consumes;
+import javax.ws.rs.DELETE;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
+
+@Path("/")
+public interface IActivitiRestService {
+  @Path("/repository/deployments/{deploymentId}")
+  @DELETE
+  @Consumes(MediaType.APPLICATION_JSON)
+  @Produces(MediaType.APPLICATION_JSON)
+  Response undeployBpmnFile(@PathParam("deploymentId") String deploymentId);
+  
+
+  @Path("/runtime/process-instances")
+  @POST
+  @Consumes(MediaType.APPLICATION_JSON)
+  @Produces(MediaType.APPLICATION_JSON)
+  Response startProcess(ActivitiStartProcessRequest request);
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/package-info.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/package-info.java
new file mode 100644
index 0000000..a32e966
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/service/activitiservice/package-info.java
@@ -0,0 +1,17 @@
+/**
+ * Copyright 2017 [ZTE] and others.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.externalservice.service.activitiservice;
+\ No newline at end of file
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/resources/WorkflowResource.java b/wfenginemgrservice/src/main/java/org/onap/workflow/resources/WorkflowResource.java
new file mode 100644
index 0000000..5450d75
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/resources/WorkflowResource.java
@@ -0,0 +1,101 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.resources;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import io.swagger.annotations.ApiResponse;
+import io.swagger.annotations.ApiResponses;
+
+import java.io.InputStream;
+
+import javax.ws.rs.Consumes;
+import javax.ws.rs.DELETE;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+
+import org.eclipse.jetty.http.HttpStatus;
+import org.glassfish.jersey.media.multipart.FormDataContentDisposition;
+import org.glassfish.jersey.media.multipart.FormDataParam;
+import org.jvnet.hk2.annotations.Service;
+import org.onap.workflow.common.RestResponse;
+import org.onap.workflow.entity.DeployBpmnFileResponse;
+import org.onap.workflow.entity.StartProcessRequest;
+import org.onap.workflow.wrapper.WorkflowInstanceWrapper;
+
+@Path("/")
+@Api(tags = {"Workflow Resource"})
+@Produces(MediaType.APPLICATION_JSON)
+@Service
+public class WorkflowResource {
+  @POST
+  @Path("/package")
+  @Consumes({"multipart/form-data"})
+  @Produces({"application/json"})
+  @ApiOperation(value = "deploy bpmn file")
+  @ApiResponses(value = {
+      @ApiResponse(code = HttpStatus.NOT_FOUND_404, message = "microservice not found",
+          response = DeployBpmnFileResponse.class),
+      @ApiResponse(code = HttpStatus.UNSUPPORTED_MEDIA_TYPE_415,
+          message = "Unprocessable MicroServiceInfo Entity ", response = String.class),
+      @ApiResponse(code = HttpStatus.INTERNAL_SERVER_ERROR_500, message = "error")})
+  public Response deployBpmnFile(
+      @ApiParam(value = "file inputstream",
+          required = true) @FormDataParam("file") InputStream fileInputStream,
+      @ApiParam(value = "file detail",
+          required = false) @FormDataParam("file") FormDataContentDisposition fileDetail) {
+    return WorkflowInstanceWrapper.getInstance().deployBpmnFile(fileDetail.getFileName(),
+        fileInputStream, null);
+  }
+
+  @Path("/package/{deployId}")
+  @DELETE
+  @Consumes(MediaType.APPLICATION_JSON)
+  @Produces(MediaType.APPLICATION_JSON)
+  @ApiOperation(value = "undeploy bpmn file")
+  @ApiResponses(value = {
+      @ApiResponse(code = HttpStatus.NOT_FOUND_404, message = "microservice not found",
+          response = DeployBpmnFileResponse.class),
+      @ApiResponse(code = HttpStatus.UNSUPPORTED_MEDIA_TYPE_415,
+          message = "Unprocessable MicroServiceInfo Entity ", response = String.class),
+      @ApiResponse(code = HttpStatus.INTERNAL_SERVER_ERROR_500, message = "error")})
+  public RestResponse undeployBpmnFile(
+      @ApiParam("deployId") @PathParam("deployId") String deployId) {
+    return WorkflowInstanceWrapper.getInstance().undeployBpmnFile(deployId);
+  }
+
+  @Path("process/instance")
+  @POST
+  @Consumes(MediaType.APPLICATION_JSON)
+  @Produces(MediaType.APPLICATION_JSON)
+  @ApiOperation(value = "package process")
+  @ApiResponses(value = {
+      @ApiResponse(code = HttpStatus.NOT_FOUND_404, message = "microservice not found",
+          response = DeployBpmnFileResponse.class),
+      @ApiResponse(code = HttpStatus.UNSUPPORTED_MEDIA_TYPE_415,
+          message = "Unprocessable MicroServiceInfo Entity ", response = String.class),
+      @ApiResponse(code = HttpStatus.INTERNAL_SERVER_ERROR_500, message = "error")})
+  public Response startProcess(
+      @ApiParam(value = "request", required = false) StartProcessRequest request) {
+    return WorkflowInstanceWrapper.getInstance().startProcess(request);
+  }
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/tools/Constants.java b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/Constants.java
new file mode 100644
index 0000000..15aac35
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/Constants.java
@@ -0,0 +1,29 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.tools;
+
+import org.onap.workflow.common.EnumModuleUrl;
+
+public class Constants {
+ public final static String AUTHORIZATION ="Authorization";
+ public final static String HTTP_HEADER ="http://";
+ public final static String HTTP ="HTTP";
+ public final static String COLON =":";
+ public static final String ACITIVI_START_INSTANCE_URL =
+     EnumModuleUrl.ACTIVITI.getApiRootDomain() + "/runtime/process-instances";
+ public static final String DEPLOY_BPMNFILE_URL = EnumModuleUrl.ACTIVITI.getApiRootDomain() + "/repository/deployments";
+}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/tools/HttpDeleteWithBody.java b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/HttpDeleteWithBody.java
new file mode 100644
index 0000000..8fcc7a0
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/HttpDeleteWithBody.java
@@ -0,0 +1,37 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.tools;
+
+import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
+import java.net.URI;
+import org.apache.http.annotation.NotThreadSafe;
+
+@NotThreadSafe
+public class HttpDeleteWithBody extends HttpEntityEnclosingRequestBase {
+    public static final String METHOD_NAME = "DELETE";
+    public String getMethod() { return METHOD_NAME; }
+
+    public HttpDeleteWithBody(final String uri) {
+        super();
+        setURI(URI.create(uri));
+    }
+    public HttpDeleteWithBody(final URI uri) {
+        super();
+        setURI(uri);
+    }
+    public HttpDeleteWithBody() { super(); }
+}
+\ No newline at end of file
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java
new file mode 100644
index 0000000..b8e76d8
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java
@@ -0,0 +1,35 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.tools;
+
+import lombok.Data;
+
+/**
+ * @author 10175158
+ *
+ */
+@Data
+public class RequestParameters {
+
+  protected boolean casCade;
+  @Override
+  public String toString() {
+    return "casCade [casCade=" + casCade + "]";
+  }
+}
+
+
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/tools/package-info.java b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/package-info.java
new file mode 100644
index 0000000..afd5cfc
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/package-info.java
@@ -0,0 +1,17 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.tools;
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/wrapper/WorkflowInstanceWrapper.java b/wfenginemgrservice/src/main/java/org/onap/workflow/wrapper/WorkflowInstanceWrapper.java
new file mode 100644
index 0000000..5bc734d
--- /dev/null
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/wrapper/WorkflowInstanceWrapper.java
@@ -0,0 +1,98 @@
+/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.workflow.wrapper;
+
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.ws.rs.core.Response;
+
+import org.glassfish.jersey.media.multipart.FormDataContentDisposition;
+import org.onap.workflow.common.EnumStatus;
+import org.onap.workflow.common.RestResponse;
+import org.onap.workflow.entity.DeployBpmnFileResponse;
+import org.onap.workflow.entity.StartProcessRequest;
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiDeployResponse;
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequestParam;
+import org.onap.workflow.externalservice.service.activitiservice.ActivitiServiceConsumer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class WorkflowInstanceWrapper {
+  private static final Logger logger = LoggerFactory.getLogger(WorkflowInstanceWrapper.class);
+
+  private static WorkflowInstanceWrapper wrapper = new WorkflowInstanceWrapper();
+
+  public static WorkflowInstanceWrapper getInstance() {
+    return wrapper;
+  }
+
+  public Response deployBpmnFile(String filename, InputStream fileInputStream,
+      FormDataContentDisposition fileDetail) {
+    try {
+      ActivitiDeployResponse deployresult =
+          ActivitiServiceConsumer.deploybpmnfile(fileInputStream, filename);
+      if (deployresult != null) {
+        DeployBpmnFileResponse result = new DeployBpmnFileResponse();
+        result.setStatus(EnumStatus.SUCCESS.ordinal());
+        result.setMessage(EnumStatus.SUCCESS.toString());
+        result.setDeployedId(deployresult.getId());
+        result.setProcessId(filename);
+        return Response.ok(result).build();
+      }
+    } catch (Exception e) {
+      logger.error("deployBpmnFile fail.", e);
+    }
+    return Response.serverError().build();
+  }
+
+  public RestResponse undeployBpmnFile(String deployId) {
+    return ActivitiServiceConsumer.undeploybpmnfile(deployId);
+  }
+
+  public Response startProcess(StartProcessRequest request) {
+    try {
+      ActivitiStartProcessRequest bpmnrequest = new ActivitiStartProcessRequest();
+      bpmnrequest.setProcessDefinitionKey(request.getProcessDefinitionKey());
+      if (request.getParams() != null) {
+        List<ActivitiStartProcessRequestParam> paramlist = convertProcessRequest(request);
+        bpmnrequest.setVariables(paramlist.toArray(new ActivitiStartProcessRequestParam[0]));
+      }
+      RestResponse result = ActivitiServiceConsumer.startBpmnProcess(bpmnrequest);
+      return Response.ok(result.getResult()).build();
+    } catch (Exception e) {
+      logger.error("startProcess fail.", e);
+    }
+    return Response.serverError().build();
+  }
+
+  private List<ActivitiStartProcessRequestParam> convertProcessRequest(
+      StartProcessRequest request) {
+    List<ActivitiStartProcessRequestParam> paramlist =
+        new ArrayList<ActivitiStartProcessRequestParam>();
+    while (request.getParams().keySet().iterator().hasNext()) {
+      String key = request.getParams().keySet().iterator().next();
+      ActivitiStartProcessRequestParam param = new ActivitiStartProcessRequestParam();
+      param.setName(key);
+      param.setValue(request.getParams().get(key));
+      paramlist.add(param);
+    }
+    return paramlist;
+  }
+}