wecube-platform-master.zip

package com.webank.wecube.platform.core.service.workflow; import static com.webank.wecube.platform.core.utils.Constants.ASYNC_SERVICE_SYMBOL; import static com.webank.wecube.platform.core.utils.Constants.FIELD_REQUIRED; import static com.webank.wecube.platform.core.utils.Constants.MAPPING_TYPE_CONSTANT; import static com.webank.wecube.platform.core.utils.Constants.MAPPING_TYPE_CONTEXT; import static com.webank.wecube.platform.core.utils.Constants.MAPPING_TYPE_ENTITY; import static com.webank.wecube.platform.core.utils.Constants.MAPPING_TYPE_OBJECT; import static com.webank.wecube.platform.core.utils.Constants.MAPPING_TYPE_SYSTEM_VARIABLE; import java.io.IOException; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.UUID; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.fasterxml.jackson.core.JsonProcessingException; import com.webank.wecube.platform.core.commons.WecubeCoreException; import com.webank.wecube.platform.core.dto.plugin.ItsDangerConfirmResultDto; import com.webank.wecube.platform.core.entity.plugin.CoreObjectMeta; import com.webank.wecube.platform.core.entity.plugin.CoreObjectPropertyMeta; import com.webank.wecube.platform.core.entity.plugin.CoreObjectVar; import com.webank.wecube.platform.core.entity.plugin.PluginConfigInterfaceParameters; import com.webank.wecube.platform.core.entity.plugin.PluginConfigInterfaces; import com.webank.wecube.platform.core.entity.plugin.PluginConfigs; import com.webank.wecube.platform.core.entity.plugin.PluginInstances; import com.webank.wecube.platform.core.entity.plugin.PluginPackageAttributes; import com.webank.wecube.platform.core.entity.plugin.PluginPackages; import com.webank.wecube.platform.core.entity.plugin.SystemVariables; import com.webank.wecube.platform.core.entity.workflow.ExtraTaskEntity; import com.webank.wecube.platform.core.entity.workflow.ProcDefInfoEntity; import com.webank.wecube.platform.core.entity.workflow.ProcExecBindingEntity; import com.webank.wecube.platform.core.entity.workflow.ProcExecContextEntity; import com.webank.wecube.platform.core.entity.workflow.ProcInstInfoEntity; import com.webank.wecube.platform.core.entity.workflow.TaskNodeDefInfoEntity; import com.webank.wecube.platform.core.entity.workflow.TaskNodeExecParamEntity; import com.webank.wecube.platform.core.entity.workflow.TaskNodeExecRequestEntity; import com.webank.wecube.platform.core.entity.workflow.TaskNodeInstInfoEntity; import com.webank.wecube.platform.core.entity.workflow.TaskNodeParamEntity; import com.webank.wecube.platform.core.model.workflow.BoundTaskNodeExecParamWrapper; import com.webank.wecube.platform.core.model.workflow.ContextCalculationParam; import com.webank.wecube.platform.core.model.workflow.ContextCalculationParamCollection; import com.webank.wecube.platform.core.model.workflow.DmeOutputParamAttr; import com.webank.wecube.platform.core.model.workflow.InputParamAttr; import com.webank.wecube.platform.core.model.workflow.InputParamObject; import com.webank.wecube.platform.core.model.workflow.PluginInvocationCommand; import com.webank.wecube.platform.core.model.workflow.PluginInvocationResult; import com.webank.wecube.platform.core.model.workflow.ProcExecBindingKey; import com.webank.wecube.platform.core.model.workflow.ProcExecBindingKeyLink; import com.webank.wecube.platform.core.model.workflow.WorkflowInstCreationContext; import com.webank.wecube.platform.core.service.dme.EntityDataAttr; import com.webank.wecube.platform.core.service.dme.EntityDataRecord; import com.webank.wecube.platform.core.service.dme.EntityOperationRootCondition; import com.webank.wecube.platform.core.service.dme.EntityQueryExprNodeInfo; import com.webank.wecube.platform.core.service.dme.EntityRouteDescription; import com.webank.wecube.platform.core.service.dme.EntityTreeNodesOverview; import com.webank.wecube.platform.core.service.dme.StandardEntityDataNode; import com.webank.wecube.platform.core.service.dme.StandardEntityOperationResponseDto; import com.webank.wecube.platform.core.service.dme.StandardEntityOperationRestClient; import com.webank.wecube.platform.core.service.plugin.CoreObjectVarCalculationContext; import com.webank.wecube.platform.core.service.plugin.PluginPackageDataModelService; import com.webank.wecube.platform.core.service.plugin.PluginParamObject; import com.webank.wecube.platform.core.service.plugin.PluginParamObjectVarStorage; import com.webank.wecube.platform.core.service.workflow.PluginInvocationProcessor.PluginInterfaceInvocationContext; import com.webank.wecube.platform.core.service.workflow.PluginInvocationProcessor.PluginInterfaceInvocationResult; import com.webank.wecube.platform.core.service.workflow.PluginInvocationProcessor.PluginInvocationOperation; import com.webank.wecube.platform.core.support.plugin.dto.DynamicEntityAttrValueDto; import com.webank.wecube.platform.core.support.plugin.dto.DynamicEntityValueDto; import com.webank.wecube.platform.core.support.plugin.dto.TaskFormDataEntityDto; import com.webank.wecube.platform.core.support.plugin.dto.TaskFormItemMetaDto; import com.webank.wecube.platform.core.support.plugin.dto.TaskFormItemValueDto; import com.webank.wecube.platform.core.support.plugin.dto.TaskFormMetaDto; import com.webank.wecube.platform.core.support.plugin.dto.TaskFormValueDto; import com.webank.wecube.platform.core.utils.Constants; import com.webank.wecube.platform.core.utils.JsonUtils; import com.webank.wecube.platform.workflow.WorkflowConstants; import com.webank.wecube.platform.workflow.commons.LocalIdGenerator; /** * * @author gavin * */ @Service public class PluginInvocationService extends AbstractPluginInvocationService { @Autowired protected PluginParamObjectVarStorage pluginParamObjectVarStorageService; @Autowired protected PluginPackageDataModelService pluginPackageDataModelService; /** * * @param cmd */ public void invokePluginInterface(PluginInvocationCommand cmd) { if (log.isInfoEnabled()) { log.info("invoke plugin interface with:{}", cmd); } ProcInstInfoEntity procInstEntity = null; TaskNodeInstInfoEntity taskNodeInstEntity = null; try { procInstEntity = retrieveProcInstInfoEntity(cmd); taskNodeInstEntity = retrieveTaskNodeInstInfoEntity(procInstEntity.getId(), cmd.getNodeId()); doInvokePluginInterface(procInstEntity, taskNodeInstEntity, cmd); } catch (Exception e) { log.warn("errors while processing {} {}", cmd.getClass().getSimpleName(), cmd, e); pluginInvocationResultService.responsePluginInterfaceInvocation( new PluginInvocationResult().parsePluginInvocationCommand(cmd).withResultCode(RESULT_CODE_ERR)); updateTaskNodeInstInfoEntityFaulted(taskNodeInstEntity, e); } } /** * handle results of plugin interface invocation. * * @param pluginInvocationResult * @param ctx */ public void handlePluginInterfaceInvocationResult(PluginInterfaceInvocationResult pluginInvocationResult, PluginInterfaceInvocationContext ctx) { if (log.isDebugEnabled()) { log.debug("handle plugin interface invocation result"); } if (!pluginInvocationResult.isSuccess() || pluginInvocationResult.hasErrors()) { handleErrorInvocationResult(pluginInvocationResult, ctx); return; } PluginConfigInterfaces pci = ctx.getPluginConfigInterface(); if (ASYNC_SERVICE_SYMBOL.equalsIgnoreCase(pci.getIsAsyncProcessing())) { log.debug("such interface is asynchronous service : {} ", pci.getServiceName()); return; } List<Object> resultData = pluginInvocationResult.getResul