diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/processon/demo1.bpmn b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/processon/demo1.bpmn
deleted file mode 100644
index f860f8979..000000000
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/processon/demo1.bpmn
+++ /dev/null
@@ -1,69 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/processon/yishi.bpmn b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/processon/yishi.bpmn
deleted file mode 100644
index 152a2efff..000000000
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/processon/yishi.bpmn
+++ /dev/null
@@ -1,50 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/ActivitiApplication.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/ActivitiApplication.java
old mode 100644
new mode 100755
index c8bcbea4c..3ff8e300a
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/ActivitiApplication.java
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/ActivitiApplication.java
@@ -1,8 +1,8 @@
/**
* Copyright (c) 2018 人人开源 All rights reserved.
- *
+ *
* https://www.renren.io
- *
+ *
* 版权所有,侵权必究!
*/
@@ -20,8 +20,8 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
* @since 1.1.0
*/
@SpringBootApplication(exclude = {
- org.activiti.spring.boot.SecurityAutoConfiguration.class,
- org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class
+ org.activiti.spring.boot.SecurityAutoConfiguration.class,
+ org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class
})
@EnableDiscoveryClient
@EnableFeignClients
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/config/ModuleConfigImpl.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/config/ModuleConfigImpl.java
old mode 100644
new mode 100755
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/config/ProcessEngineConfig.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/config/ProcessEngineConfig.java
old mode 100644
new mode 100755
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/config/SwaggerConfig.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/config/SwaggerConfig.java
old mode 100644
new mode 100755
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActIdController.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActIdController.java
deleted file mode 100644
index 2b036e118..000000000
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActIdController.java
+++ /dev/null
@@ -1,66 +0,0 @@
-package com.elink.esua.epdc.controller;
-
-import com.elink.esua.epdc.commons.tools.annotation.LogOperation;
-import com.elink.esua.epdc.commons.tools.constant.Constant;
-import com.elink.esua.epdc.commons.tools.page.PageData;
-import com.elink.esua.epdc.commons.tools.utils.Result;
-import com.elink.esua.epdc.dto.form.ActGroupFormDto;
-import com.elink.esua.epdc.dto.form.ActUserFormDto;
-import com.elink.esua.epdc.exception.ModuleErrorCode;
-import com.elink.esua.epdc.service.ActIdService;
-import com.elink.esua.epdc.service.ActProcessService;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiImplicitParam;
-import io.swagger.annotations.ApiImplicitParams;
-import io.swagger.annotations.ApiOperation;
-import org.apache.commons.io.IOUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-import springfox.documentation.annotations.ApiIgnore;
-
-import javax.servlet.http.HttpServletResponse;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.Map;
-
-/**
- * 用户和用户组控制类
- *
- * @author rongchao
- * @Date 19-9-6
- */
-@RestController
-@RequestMapping("actId")
-public class ActIdController {
-
- @Autowired
- private ActIdService actIdService;
-
- /**
- * 添加流程用户
- *
- * @param actUserFormDto
- * @return com.elink.esua.epdc.commons.tools.utils.Result
- * @author rongchao
- * @since 2019-09-06
- */
- @PostMapping("addUser")
- public Result addUser(ActUserFormDto actUserFormDto) {
- return actIdService.saveUser(actUserFormDto);
- }
-
- /**
- * 添加用户组
- *
- * @param actGroupFormDto
- * @return com.elink.esua.epdc.commons.tools.utils.Result
- * @author rongchao
- * @since 2019-09-06
- */
- @PostMapping("addGroup")
- public Result addGroup(ActGroupFormDto actGroupFormDto) {
- return actIdService.saveGroup(actGroupFormDto);
- }
-
-}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActModelController.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActModelController.java
new file mode 100755
index 000000000..918fa9e83
--- /dev/null
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActModelController.java
@@ -0,0 +1,92 @@
+/**
+ * Copyright (c) 2018 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有,侵权必究!
+ */
+
+package com.elink.esua.epdc.controller;
+
+import com.elink.esua.epdc.commons.tools.annotation.LogOperation;
+import com.elink.esua.epdc.commons.tools.constant.Constant;
+import com.elink.esua.epdc.commons.tools.page.PageData;
+import com.elink.esua.epdc.commons.tools.utils.Result;
+import com.elink.esua.epdc.commons.tools.validator.ValidatorUtils;
+import com.elink.esua.epdc.dto.ModelDTO;
+import com.elink.esua.epdc.service.ActModelService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.activiti.engine.repository.Model;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import springfox.documentation.annotations.ApiIgnore;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.Map;
+
+/**
+ * 模型管理
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+@RestController
+@RequestMapping("model")
+@Api(tags="模型管理")
+public class ActModelController {
+ @Autowired
+ private ActModelService actModelService;
+
+ @GetMapping("page")
+ @ApiOperation("分页")
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = Constant.PAGE, value = "当前页码,从1开始", paramType = "query", required = true, dataType="int") ,
+ @ApiImplicitParam(name = Constant.LIMIT, value = "每页显示记录数", paramType = "query",required = true, dataType="int") ,
+ @ApiImplicitParam(name = "key", value = "key", paramType = "query", dataType="String"),
+ @ApiImplicitParam(name = "name", value = "name", paramType = "query", dataType="String")
+ })
+ public Result> page(@ApiIgnore @RequestParam Map params){
+ PageData page = actModelService.page(params);
+
+ return new Result>().ok(page);
+ }
+
+ @PostMapping
+ @ApiOperation("新增模型")
+ @LogOperation("新增模型")
+ public Result save(@RequestBody ModelDTO dto) throws Exception{
+ //效验数据
+ ValidatorUtils.validateEntity(dto);
+
+ actModelService.save(dto.getName(), dto.getKey(), dto.getDescription());
+
+ return new Result();
+ }
+
+ @PostMapping("deploy/{id}")
+ @ApiOperation("部署")
+ @LogOperation("部署")
+ public Result deploy(@PathVariable("id") String id) {
+ actModelService.deploy(id);
+ return new Result();
+ }
+
+ @GetMapping("export/{id}")
+ @ApiOperation("导出")
+ @LogOperation("导出")
+ public void export(@PathVariable("id") String id, @ApiIgnore HttpServletResponse response) {
+ actModelService.export(id, response);
+ }
+
+ @DeleteMapping
+ @ApiOperation("删除")
+ @LogOperation("删除")
+ public Result delete(@RequestBody String[] ids) {
+ for(String id : ids) {
+ actModelService.delete(id);
+ }
+ return new Result();
+ }
+}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActProcessController.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActProcessController.java
old mode 100644
new mode 100755
index 03028bc13..d336e4456
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActProcessController.java
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActProcessController.java
@@ -88,15 +88,15 @@ public class ActProcessController {
return new Result();
}
-// @PostMapping("convertToModel/{id}")
-// @ApiOperation("将部署的流程转换为模型")
-// @LogOperation("将部署的流程转换为模型")
-// @ApiImplicitParam(name = "id", value = "流程ID", paramType = "query", dataType="String")
-// public Result convertToModel(@PathVariable("id") String id) throws Exception {
-// actProcessService.convertToModel(id);
-//
-// return new Result();
-// }
+ @PostMapping("convertToModel/{id}")
+ @ApiOperation("将部署的流程转换为模型")
+ @LogOperation("将部署的流程转换为模型")
+ @ApiImplicitParam(name = "id", value = "流程ID", paramType = "query", dataType="String")
+ public Result convertToModel(@PathVariable("id") String id) throws Exception {
+ actProcessService.convertToModel(id);
+
+ return new Result();
+ }
@DeleteMapping
@ApiOperation("删除流程")
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActRunningController.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/controller/ActRunningController.java
old mode 100644
new mode 100755
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/dto/form/ActGroupFormDto.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/dto/form/ActGroupFormDto.java
deleted file mode 100644
index 292093c57..000000000
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/dto/form/ActGroupFormDto.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package com.elink.esua.epdc.dto.form;
-
-import lombok.Data;
-
-/**
- * 流程用户组表单DTO
- *
- * @author rongchao
- * @Date 19-9-6
- */
-@Data
-public class ActGroupFormDto {
-
- /**
- * 用户组ID
- */
- private long groupId;
-
- /**
- * 用户组名
- */
- private String groupName;
-}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/dto/form/ActUserFormDto.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/dto/form/ActUserFormDto.java
deleted file mode 100644
index 099f7d267..000000000
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/dto/form/ActUserFormDto.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package com.elink.esua.epdc.dto.form;
-
-import lombok.Data;
-
-/**
- * 流程用户表单DTO
- *
- * @author rongchao
- * @Date 19-9-6
- */
-@Data
-public class ActUserFormDto {
-
- /**
- * 用户ID
- */
- private long userId;
-
- /**
- * 用户名
- */
- private String userName;
-}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/main/StencilsetRestResource.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/main/StencilsetRestResource.java
new file mode 100755
index 000000000..191edb780
--- /dev/null
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/main/StencilsetRestResource.java
@@ -0,0 +1,38 @@
+/**
+ * Copyright (c) 2018 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有,侵权必究!
+ */
+
+package com.elink.esua.epdc.editor.main;
+
+import org.activiti.engine.ActivitiException;
+import org.apache.commons.io.IOUtils;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.io.InputStream;
+
+/**
+ * Stencilset
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+@RestController
+@RequestMapping("service")
+public class StencilsetRestResource {
+
+ @RequestMapping(value="/editor/stencilset", method = RequestMethod.GET, produces = "application/json;charset=utf-8")
+ public @ResponseBody String getStencilset() {
+ InputStream stencilsetStream = this.getClass().getClassLoader().getResourceAsStream("stencilset.json");
+ try {
+ return IOUtils.toString(stencilsetStream, "utf-8");
+ } catch (Exception e) {
+ throw new ActivitiException("Error while loading stencil set", e);
+ }
+ }
+}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/model/ModelEditorJsonRestResource.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/model/ModelEditorJsonRestResource.java
new file mode 100755
index 000000000..67e0cbb56
--- /dev/null
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/model/ModelEditorJsonRestResource.java
@@ -0,0 +1,69 @@
+/**
+ * Copyright (c) 2018 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有,侵权必究!
+ */
+
+package com.elink.esua.epdc.editor.model;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.activiti.editor.constants.ModelDataJsonConstants;
+import org.activiti.engine.ActivitiException;
+import org.activiti.engine.RepositoryService;
+import org.activiti.engine.repository.Model;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * Model Editor
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+@RestController
+@RequestMapping("service")
+public class ModelEditorJsonRestResource implements ModelDataJsonConstants {
+
+ protected static final Logger LOGGER = LoggerFactory.getLogger(ModelEditorJsonRestResource.class);
+
+ @Autowired
+ private RepositoryService repositoryService;
+
+ @Autowired
+ private ObjectMapper objectMapper;
+
+ @RequestMapping(value = "/model/{modelId}/json", method = RequestMethod.GET, produces = "application/json")
+ public ObjectNode getEditorJson(@PathVariable String modelId) {
+ ObjectNode modelNode = null;
+
+ Model model = repositoryService.getModel(modelId);
+
+ if (model != null) {
+ try {
+ if (StringUtils.isNotEmpty(model.getMetaInfo())) {
+ modelNode = (ObjectNode) objectMapper.readTree(model.getMetaInfo());
+ } else {
+ modelNode = objectMapper.createObjectNode();
+ modelNode.put(MODEL_NAME, model.getName());
+ }
+ modelNode.put(MODEL_ID, model.getId());
+ ObjectNode editorJsonNode = (ObjectNode) objectMapper.readTree(
+ new String(repositoryService.getModelEditorSource(model.getId()), "utf-8"));
+ modelNode.set("model", editorJsonNode);
+
+ } catch (Exception e) {
+ LOGGER.error("Error creating model JSON", e);
+ throw new ActivitiException("Error creating model JSON", e);
+ }
+ }
+ return modelNode;
+ }
+}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/model/ModelSaveRestResource.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/model/ModelSaveRestResource.java
new file mode 100755
index 000000000..cac6f0136
--- /dev/null
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/editor/model/ModelSaveRestResource.java
@@ -0,0 +1,90 @@
+/**
+ * Copyright (c) 2018 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有,侵权必究!
+ */
+
+package com.elink.esua.epdc.editor.model;
+
+import com.elink.esua.epdc.commons.tools.xss.XssHttpServletRequestWrapper;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.activiti.editor.constants.ModelDataJsonConstants;
+import org.activiti.engine.ActivitiException;
+import org.activiti.engine.RepositoryService;
+import org.activiti.engine.repository.Model;
+import org.apache.batik.transcoder.TranscoderInput;
+import org.apache.batik.transcoder.TranscoderOutput;
+import org.apache.batik.transcoder.image.PNGTranscoder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.InputStream;
+
+/**
+ * Model Rest
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+@RestController
+@RequestMapping("service")
+public class ModelSaveRestResource implements ModelDataJsonConstants {
+ protected static final Logger LOGGER = LoggerFactory.getLogger(ModelSaveRestResource.class);
+
+ @Autowired
+ private RepositoryService repositoryService;
+ @Autowired
+ private ObjectMapper objectMapper;
+
+ @RequestMapping(value = "/model/{modelId}/save", method = RequestMethod.PUT)
+ @ResponseStatus(value = HttpStatus.OK)
+ public void saveModel(@PathVariable String modelId, HttpServletRequest request) {
+ try {
+ HttpServletRequest orgRequest = XssHttpServletRequestWrapper.getOrgRequest(request);
+ String name = orgRequest.getParameter("name");
+ String description = orgRequest.getParameter("description");
+ String jsonXml = orgRequest.getParameter("json_xml");
+ String svgXml = orgRequest.getParameter("svg_xml");
+
+ Model model = repositoryService.getModel(modelId);
+
+ ObjectNode modelJson = (ObjectNode) objectMapper.readTree(model.getMetaInfo());
+
+ modelJson.put(MODEL_NAME, name);
+ modelJson.put(MODEL_DESCRIPTION, description);
+ model.setMetaInfo(modelJson.toString());
+ model.setName(name);
+
+ repositoryService.saveModel(model);
+
+ repositoryService.addModelEditorSource(model.getId(), jsonXml.getBytes("utf-8"));
+
+ InputStream svgStream = new ByteArrayInputStream(svgXml.getBytes("utf-8"));
+ TranscoderInput input = new TranscoderInput(svgStream);
+
+ PNGTranscoder transcoder = new PNGTranscoder();
+ // Setup output
+ ByteArrayOutputStream outStream = new ByteArrayOutputStream();
+ TranscoderOutput output = new TranscoderOutput(outStream);
+
+ // Do the transformation
+ transcoder.transcode(input, output);
+ final byte[] result = outStream.toByteArray();
+ repositoryService.addModelEditorSourceExtra(model.getId(), result);
+ outStream.close();
+
+ } catch (Exception e) {
+ LOGGER.error("Error saving model", e);
+ throw new ActivitiException("Error saving model", e);
+ }
+ }
+
+}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/exception/ModuleErrorCode.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/exception/ModuleErrorCode.java
old mode 100644
new mode 100755
index 007ab2b18..97988f469
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/exception/ModuleErrorCode.java
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/exception/ModuleErrorCode.java
@@ -8,6 +8,7 @@
package com.elink.esua.epdc.exception;
+
import com.elink.esua.epdc.commons.tools.exception.ErrorCode;
/**
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActIdService.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActIdService.java
deleted file mode 100644
index a6dc85598..000000000
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActIdService.java
+++ /dev/null
@@ -1,45 +0,0 @@
-package com.elink.esua.epdc.service;
-
-import com.elink.esua.epdc.commons.tools.utils.Result;
-import com.elink.esua.epdc.dto.form.ActGroupFormDto;
-import com.elink.esua.epdc.dto.form.ActUserFormDto;
-
-/**
- * 流程用户服务接口类
- *
- * @author rongchao
- * @Date 19-9-6
- */
-public interface ActIdService {
-
- /**
- * 添加用户
- *
- * @param actUserFormDto 用户名
- * @return boolean
- * @author rongchao
- * @since 2019-09-06
- */
- Result saveUser(ActUserFormDto actUserFormDto);
-
- /**
- * 添加用户组
- *
- * @param actGroupFormDto 用户组名
- * @return boolean
- * @author rongchao
- * @since 2019-09-06
- */
- Result saveGroup(ActGroupFormDto actGroupFormDto);
-
- /**
- * 修改用户组名
- *
- * @param newGroupName
- * @return boolean
- * @author rongchao
- * @since 2019-09-06
- */
- Result modifyGroupName(String newGroupName);
-
-}
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActModelService.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActModelService.java
old mode 100644
new mode 100755
index 580774e44..2e3bd7483
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActModelService.java
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActModelService.java
@@ -1,23 +1,37 @@
/**
* Copyright (c) 2018 人人开源 All rights reserved.
- *
+ *
* https://www.renren.io
- *
+ *
* 版权所有,侵权必究!
*/
package com.elink.esua.epdc.service;
import com.elink.esua.epdc.commons.tools.constant.Constant;
+import com.elink.esua.epdc.commons.tools.exception.RenException;
import com.elink.esua.epdc.commons.tools.page.PageData;
+import com.elink.esua.epdc.exception.ModuleErrorCode;
+import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.activiti.bpmn.converter.BpmnXMLConverter;
+import org.activiti.bpmn.model.BpmnModel;
+import org.activiti.editor.constants.ModelDataJsonConstants;
+import org.activiti.editor.language.json.converter.BpmnJsonConverter;
import org.activiti.engine.RepositoryService;
+import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.Model;
import org.activiti.engine.repository.ModelQuery;
+import org.activiti.engine.repository.ProcessDefinition;
+import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import javax.servlet.http.HttpServletResponse;
+import java.io.ByteArrayInputStream;
+import java.io.UnsupportedEncodingException;
import java.util.List;
import java.util.Map;
@@ -34,104 +48,104 @@ public class ActModelService {
private ObjectMapper objectMapper;
public PageData page(Map params) {
- String key = (String)params.get("key");
- String name = (String)params.get("name");
+ String key = (String) params.get("key");
+ String name = (String) params.get("name");
//分页参数
Integer curPage = 1;
Integer limit = 10;
- if(params.get(Constant.PAGE) != null){
- curPage = Integer.parseInt((String)params.get(Constant.PAGE));
+ if (params.get(Constant.PAGE) != null) {
+ curPage = Integer.parseInt((String) params.get(Constant.PAGE));
}
- if(params.get(Constant.LIMIT) != null){
- limit = Integer.parseInt((String)params.get(Constant.LIMIT));
+ if (params.get(Constant.LIMIT) != null) {
+ limit = Integer.parseInt((String) params.get(Constant.LIMIT));
}
ModelQuery modelQuery = repositoryService.createModelQuery().latestVersion().orderByLastUpdateTime().desc();
- if(StringUtils.isNotEmpty(key)){
+ if (StringUtils.isNotEmpty(key)) {
modelQuery.modelKey(key);
}
- if(StringUtils.isNotEmpty(name)){
+ if (StringUtils.isNotEmpty(name)) {
modelQuery.modelName(name);
}
List list = modelQuery.listPage((curPage - 1) * limit, limit);
- return new PageData<>(list, (int)modelQuery.count());
+ return new PageData<>(list, (int) modelQuery.count());
+ }
+
+ public void save(String name, String key, String description) throws UnsupportedEncodingException {
+ //新建一个空模型
+ Model model = repositoryService.newModel();
+
+ //metaInfo信息
+ ObjectNode metaInfo = objectMapper.createObjectNode();
+ metaInfo.put(ModelDataJsonConstants.MODEL_NAME, name);
+ metaInfo.put(ModelDataJsonConstants.MODEL_DESCRIPTION, description);
+ metaInfo.put(ModelDataJsonConstants.MODEL_REVISION, model.getVersion());
+
+ model.setKey(key);
+ model.setName(name);
+ model.setMetaInfo(metaInfo.toString());
+
+ repositoryService.saveModel(model);
+
+ ObjectNode editorNode = objectMapper.createObjectNode();
+ editorNode.put("id", "canvas");
+ editorNode.put("resourceId", "canvas");
+ ObjectNode stencilset = objectMapper.createObjectNode();
+ stencilset.put("namespace", "http://b3mn.org/stencilset/bpmn2.0#");
+ editorNode.set("stencilset", stencilset);
+ repositoryService.addModelEditorSource(model.getId(), editorNode.toString().getBytes("utf-8"));
}
-// public void save(String name, String key, String description) throws UnsupportedEncodingException {
-// //新建一个空模型
-// Model model = repositoryService.newModel();
-//
-// //metaInfo信息
-// ObjectNode metaInfo = objectMapper.createObjectNode();
-// metaInfo.put(ModelDataJsonConstants.MODEL_NAME, name);
-// metaInfo.put(ModelDataJsonConstants.MODEL_DESCRIPTION, description);
-// metaInfo.put(ModelDataJsonConstants.MODEL_REVISION, model.getVersion());
-//
-// model.setKey(key);
-// model.setName(name);
-// model.setMetaInfo(metaInfo.toString());
-//
-// repositoryService.saveModel(model);
-//
-// ObjectNode editorNode = objectMapper.createObjectNode();
-// editorNode.put("id", "canvas");
-// editorNode.put("resourceId", "canvas");
-// ObjectNode stencilset = objectMapper.createObjectNode();
-// stencilset.put("namespace", "http://b3mn.org/stencilset/bpmn2.0#");
-// editorNode.set("stencilset", stencilset);
-// repositoryService.addModelEditorSource(model.getId(), editorNode.toString().getBytes("utf-8"));
-// }
-//
-// public void deploy(String id) {
-// try {
-// Model model = repositoryService.getModel(id);
-// BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
-// JsonNode editorNode = new ObjectMapper().readTree(repositoryService.getModelEditorSource(model.getId()));
-// BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editorNode);
-// BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
-// byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);
-//
-// String processName = model.getName();
-// if (!StringUtils.endsWith(processName, ".bpmn20.xml")){
-// processName += ".bpmn20.xml";
-// }
-//
-// ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
-// Deployment deployment = repositoryService.createDeployment().name(model.getName()).addInputStream(processName, in).deploy();
-//
-// List list = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).list();
-// if (list.size() == 0){
-// throw new RenException(ModuleErrorCode.ACT_DEPLOY_ERROR);
-// }
-// } catch (Exception e) {
-// throw new RenException(ModuleErrorCode.ACT_MODEL_IMG_ERROR, e);
-// }
-// }
-//
-// /**
-// * 导出模型
-// */
-// public void export(String id, HttpServletResponse response) {
-// try {
-// Model model = repositoryService.getModel(id);
-// BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
-// JsonNode editorNode = new ObjectMapper().readTree(repositoryService.getModelEditorSource(model.getId()));
-// BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editorNode);
-// BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
-// byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);
-//
-// ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
-// IOUtils.copy(in, response.getOutputStream());
-// String filename = bpmnModel.getMainProcess().getId() + ".bpmn20.xml";
-// response.setHeader("Content-Disposition", "attachment; filename=" + filename);
-// response.flushBuffer();
-// } catch (Exception e) {
-// throw new RenException(ModuleErrorCode.ACT_MODEL_EXPORT_ERROR, id);
-// }
-// }
+ public void deploy(String id) {
+ try {
+ Model model = repositoryService.getModel(id);
+ BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
+ JsonNode editorNode = new ObjectMapper().readTree(repositoryService.getModelEditorSource(model.getId()));
+ BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editorNode);
+ BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
+ byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);
+
+ String processName = model.getName();
+ if (!StringUtils.endsWith(processName, ".bpmn20.xml")) {
+ processName += ".bpmn20.xml";
+ }
+
+ ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
+ Deployment deployment = repositoryService.createDeployment().name(model.getName()).addInputStream(processName, in).deploy();
+
+ List list = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).list();
+ if (list.size() == 0) {
+ throw new RenException(ModuleErrorCode.ACT_DEPLOY_ERROR);
+ }
+ } catch (Exception e) {
+ throw new RenException(ModuleErrorCode.ACT_MODEL_IMG_ERROR, e);
+ }
+ }
+
+ /**
+ * 导出模型
+ */
+ public void export(String id, HttpServletResponse response) {
+ try {
+ Model model = repositoryService.getModel(id);
+ BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
+ JsonNode editorNode = new ObjectMapper().readTree(repositoryService.getModelEditorSource(model.getId()));
+ BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editorNode);
+ BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
+ byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);
+
+ ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
+ IOUtils.copy(in, response.getOutputStream());
+ String filename = bpmnModel.getMainProcess().getId() + ".bpmn20.xml";
+ response.setHeader("Content-Disposition", "attachment; filename=" + filename);
+ response.flushBuffer();
+ } catch (Exception e) {
+ throw new RenException(ModuleErrorCode.ACT_MODEL_EXPORT_ERROR, id);
+ }
+ }
/**
* 删除模型
diff --git a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActProcessService.java b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActProcessService.java
old mode 100644
new mode 100755
index 00dd945b2..0976c1a44
--- a/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActProcessService.java
+++ b/esua-epdc/epdc-module/epdc-activiti/epdc-activiti-server/src/main/java/com/elink/esua/epdc/service/ActProcessService.java
@@ -1,8 +1,8 @@
/**
* Copyright (c) 2018 人人开源 All rights reserved.
- *
+ *
* https://www.renren.io
- *
+ *
* 版权所有,侵权必究!
*/
@@ -12,8 +12,15 @@ import com.elink.esua.epdc.commons.tools.constant.Constant;
import com.elink.esua.epdc.commons.tools.exception.RenException;
import com.elink.esua.epdc.commons.tools.page.PageData;
import com.elink.esua.epdc.exception.ModuleErrorCode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.activiti.bpmn.converter.BpmnXMLConverter;
+import org.activiti.bpmn.model.BpmnModel;
+import org.activiti.editor.constants.ModelDataJsonConstants;
+import org.activiti.editor.language.json.converter.BpmnJsonConverter;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;
+import org.activiti.engine.repository.Model;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.repository.ProcessDefinitionQuery;
import org.apache.commons.io.FilenameUtils;
@@ -22,8 +29,13 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
import java.io.IOException;
import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -42,31 +54,28 @@ public class ActProcessService {
/**
* 流程列表
- *
- * @param params
- * @return
*/
public PageData