ssos框架，记录平时使用的一些工具类，集成权限、数据权限、动态表单、自定义字段.zip

/* 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 com.ssos.flowable.modeler.service; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ArrayNode; import com.fasterxml.jackson.databind.node.ObjectNode; import com.ssos.flowable.modeler.model.*; import com.ssos.flowable.modeler.model.decisiontable.DecisionTableDefinitionRepresentation; import com.ssos.flowable.modeler.repository.ModelHistoryRepository; import com.ssos.flowable.modeler.repository.ModelRelationRepository; import com.ssos.flowable.modeler.repository.ModelRepository; import com.ssos.flowable.modeler.repository.ModelSort; import com.ssos.flowable.modeler.serviceapi.ModelService; import com.ssos.flowable.modeler.util.XmlUtil; import org.apache.commons.lang3.StringUtils; import org.apache.ibatis.javassist.NotFoundException; import org.flowable.bpmn.converter.BpmnXMLConverter; import org.flowable.bpmn.model.BpmnModel; import org.flowable.bpmn.model.ExtensionElement; import org.flowable.bpmn.model.Process; import org.flowable.bpmn.model.UserTask; import org.flowable.cmmn.converter.CmmnXmlConverter; import org.flowable.cmmn.editor.json.converter.CmmnJsonConverter; import org.flowable.cmmn.editor.json.converter.util.CmmnModelJsonConverterUtil; import org.flowable.cmmn.model.CmmnModel; import org.flowable.editor.language.json.converter.BpmnJsonConverter; import org.flowable.editor.language.json.converter.util.CollectionUtils; import org.flowable.editor.language.json.converter.util.JsonConverterUtil; import org.flowable.form.model.SimpleFormModel; import org.flowable.idm.api.User; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.xml.stream.XMLInputFactory; import javax.xml.stream.XMLStreamReader; import java.io.InputStream; import java.io.InputStreamReader; import java.util.*; @Service @Transactional public class ModelServiceImpl implements ModelService { private static final Logger LOGGER = LoggerFactory.getLogger(ModelServiceImpl.class); public static final String NAMESPACE = "http://flowable.org/modeler"; protected static final String PROCESS_NOT_FOUND_MESSAGE_KEY = "PROCESS.ERROR.NOT-FOUND"; @Autowired protected ModelImageService modelImageService; @Autowired protected ModelRepository modelRepository; @Autowired protected ModelHistoryRepository modelHistoryRepository; @Autowired protected ModelRelationRepository modelRelationRepository; @Autowired protected ObjectMapper objectMapper; protected BpmnJsonConverter bpmnJsonConverter = new BpmnJsonConverter(); protected BpmnXMLConverter bpmnXMLConverter = new BpmnXMLConverter(); protected CmmnJsonConverter cmmnJsonConverter = new CmmnJsonConverter(); protected CmmnXmlConverter cmmnXMLConverter = new CmmnXmlConverter(); @Override public Model getModel(String modelId) { Model model = modelRepository.get(modelId); if (model == null) { System.out.println("null"); } return model; } public ModelRepresentation getModelRepresentation(String modelId) { Model model = getModel(modelId); return new ModelRepresentation(model); } @Override public List<AbstractModel> getModelsByModelType(Integer modelType) { return new ArrayList<AbstractModel>(modelRepository.findByModelType(modelType, ModelSort.NAME_ASC)); } @Override public ModelHistory getModelHistory(String modelId, String modelHistoryId) { // Check if the user has read-rights on the process-model in order to fetch history Model model = getModel(modelId); ModelHistory modelHistory = modelHistoryRepository.get(modelHistoryId); // Check if history corresponds to the current model and is not deleted if (modelHistory == null || modelHistory.getRemovalDate() != null || !modelHistory.getModelId().equals(model.getId())) { try { throw new NotFoundException("Process model history not found: " + modelHistoryId); } catch (NotFoundException e) { } } return modelHistory; } @Override public byte[] getBpmnXML(AbstractModel model) { BpmnModel bpmnModel = getBpmnModel(model); return getBpmnXML(bpmnModel); } @Override public byte[] getBpmnXML(BpmnModel bpmnModel) { for (Process process : bpmnModel.getProcesses()) { if (StringUtils.isNotEmpty(process.getId())) { char firstCharacter = process.getId().charAt(0); // no digit is allowed as first character if (Character.isDigit(firstCharacter)) { process.setId("a" + process.getId()); } } } byte[] xmlBytes = bpmnXMLConverter.convertToXML(bpmnModel); return xmlBytes; } @Override public byte[] getCmmnXML(AbstractModel model) { CmmnModel cmmnModel = getCmmnModel(model); return getCmmnXML(cmmnModel); } @Override public byte[] getCmmnXML(CmmnModel cmmnModel) { byte[] xmlBytes = cmmnXMLConverter.convertToXML(cmmnModel); return xmlBytes; } public ModelKeyRepresentation validateModelKey(Model model, Integer modelType, String key) { ModelKeyRepresentation modelKeyResponse = new ModelKeyRepresentation(); modelKeyResponse.setKey(key); List<Model> models = modelRepository.findByKeyAndType(key, modelType); for (Model modelInfo : models) { if (model == null || !modelInfo.getId().equals(model.getId())) { modelKeyResponse.setKeyAlreadyExists(true); modelKeyResponse.setId(modelInfo.getId()); modelKeyResponse.setName(modelInfo.getName()); break; } } return modelKeyResponse; } @Override public String createModelJson(ModelRepresentation model) { String json = null; if (Integer.valueOf(AbstractModel.MODEL_TYPE_FORM).equals(model.getModelType())) { try { json = objectMapper.writeValueAsString(new SimpleFormModel()); } catch (Exception e) { LOGGER.error("Error creating form model", e); throw new RuntimeException("Error creating form"); } } else if (Integer.valueOf(AbstractModel.MODEL_TYPE_DECISION_TABLE).equals(model.getModelType())) { try { DecisionTableDefinitionRepresentation decisionTableDefinition = new DecisionTableDefinitionRepresentation(); String decisionTableDefinitionKey = model.getName().replaceAll(" ", ""); decisionTableDefinition.setKey(decisionTableDefinitionKey); json = objectMapper.writeValueAsString(decisionTableDefinition); } catch (Exception e) { LOGGER.error("Error creating decision table model", e); throw new RuntimeException("Error creating decision table"); } } else if (Integer.valueOf(AbstractModel.MODEL_TYPE_APP).equals(model.getModelType())) { try { json = objectMapper.writeValueAsString(new AppDefinition());