org.activiti.engine.RepositoryService.createDeploymentQuery()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(13.2k)|赞(0)|评价(0)|浏览(113)

本文整理了Java中org.activiti.engine.RepositoryService.createDeploymentQuery方法的一些代码示例,展示了RepositoryService.createDeploymentQuery的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RepositoryService.createDeploymentQuery方法的具体详情如下:
包路径:org.activiti.engine.RepositoryService
类名称:RepositoryService
方法名:createDeploymentQuery

RepositoryService.createDeploymentQuery介绍

[英]Query deployment.
[中]查询部署。

代码示例

代码示例来源:origin: Activiti/Activiti

@Override
public void afterTestClass(TestContext testContext) throws Exception {
 RepositoryService repositoryService = testContext.getApplicationContext().getBean(RepositoryService.class);
 for (Deployment deployment : repositoryService.createDeploymentQuery().list()) {
  repositoryService.deleteDeployment(deployment.getId(), true);
 }
}

代码示例来源:origin: Activiti/Activiti

List<Deployment> deploymentList = commandContext.getProcessEngineConfiguration().getRepositoryService().createDeploymentQuery().deploymentName(deployment.getName())
  .deploymentTenantId(deployment.getTenantId()).orderByDeploymentId().desc().list();

代码示例来源:origin: org.activiti/activiti-explorer

public DeploymentQuery getCountQuery(RepositoryService repositoryService) {
 return repositoryService.createDeploymentQuery();
}

代码示例来源:origin: org.activiti/activiti-rest

@ApiOperation(value = "Get a deployment", tags = {"Deployment"})
@ApiResponses(value = {
  @ApiResponse(code = 200, message = "Indicates the deployment was found and returned."),
  @ApiResponse(code = 404, message = "Indicates the requested deployment was not found.")
})
@RequestMapping(value = "/repository/deployments/{deploymentId}", method = RequestMethod.GET, produces = "application/json")
public DeploymentResponse getDeployment(@ApiParam(name = "deploymentId", value = "The id of the deployment to get.") @PathVariable String deploymentId, HttpServletRequest request) {
 Deployment deployment = repositoryService.createDeploymentQuery().deploymentId(deploymentId).singleResult();
 if (deployment == null) {
  throw new ActivitiObjectNotFoundException("Could not find a deployment with id '" + deploymentId + "'.", Deployment.class);
 }
 return restResponseFactory.createDeploymentResponse(deployment);
}

代码示例来源:origin: com.bbossgroups.pdp/pdp-workflow

/**
 * 根据部署ID查询部署的流程
 * 
 * @param deploymentId
 * @return
 */
public Deployment getDeploymentById(String deploymentId) {
  Deployment deployment = repositoryService.createDeploymentQuery()
      .deploymentId(deploymentId).singleResult();
  return deployment;
}

代码示例来源:origin: org.activiti/activiti-rest

@ApiOperation(value = "List resources in a deployment", tags = {"Deployment"}, notes="The dataUrl property in the resulting JSON for a single resource contains the actual URL to use for retrieving the binary resource.")
 @ApiResponses(value = {
   @ApiResponse(code = 200, message = "Indicates the deployment was found and the resource list has been returned."),
   @ApiResponse(code = 404, message = "Indicates the requested deployment was not found.")
 })
 @RequestMapping(value = "/repository/deployments/{deploymentId}/resources", method = RequestMethod.GET, produces = "application/json")
 public List<DeploymentResourceResponse> getDeploymentResources(@ApiParam(name = "deploymentId", value = "The id of the deployment to get the resources for.") @PathVariable String deploymentId, HttpServletRequest request) {
  // Check if deployment exists
  Deployment deployment = repositoryService.createDeploymentQuery().deploymentId(deploymentId).singleResult();
  if (deployment == null) {
   throw new ActivitiObjectNotFoundException("Could not find a deployment with id '" + deploymentId + "'.", Deployment.class);
  }

  List<String> resourceList = repositoryService.getDeploymentResourceNames(deploymentId);

  return restResponseFactory.createDeploymentResourceResponseList(deploymentId, resourceList, contentTypeResolver);
 }
}

代码示例来源:origin: org.activiti/activiti-explorer

public Item loadSingleResult(String id) {
 Deployment deployment = repositoryService.createDeploymentQuery().deploymentId(id).singleResult();
 if(deployment != null) {
  return deploymentFilter.createItem(deployment);
 }
 return null;
}

代码示例来源:origin: org.activiti/activiti-rest

@ApiOperation(value = "Get a deployment resource", tags = {"Deployment"}, notes="Replace ** by ResourceId")
 @ApiResponses(value = {
   @ApiResponse(code = 200, message = "Indicates both deployment and resource have been found and the resource has been returned."),
   @ApiResponse(code = 404, message = "Indicates the requested deployment was not found or there is no resource with the given id present in the deployment. The status-description contains additional information.")
 })

 @RequestMapping(value = "/repository/deployments/{deploymentId}/resources/**", method = RequestMethod.GET, produces = "application/json")
 public DeploymentResourceResponse getDeploymentResource(@ApiParam(name = "deploymentId", value = "The id of the deployment the requested resource is part of.") @PathVariable("deploymentId") String deploymentId, HttpServletRequest request) {

  Deployment deployment = repositoryService.createDeploymentQuery().deploymentId(deploymentId).singleResult();
  if (deployment == null) {
   throw new ActivitiObjectNotFoundException("Could not find a deployment with id '" + deploymentId + "'.");
  }

  String pathInfo = request.getPathInfo();
  String resourceName = pathInfo.replace("/repository/deployments/" + deploymentId + "/resources/", "");

  List<String> resourceList = repositoryService.getDeploymentResourceNames(deploymentId);

  if (resourceList.contains(resourceName)) {
   // Build resource representation
   DeploymentResourceResponse response = restResponseFactory.createDeploymentResourceResponse(deploymentId, resourceName, contentTypeResolver.resolveContentType(resourceName));
   return response;

  } else {
   // Resource not found in deployment
   throw new ActivitiObjectNotFoundException("Could not find a resource with id '" + resourceName + "' in deployment '" + deploymentId + "'.");
  }
 }
}

代码示例来源:origin: GZWgssmart/zywork

@Override
public void remove(String processName) {
  List<Deployment> deploymentList = repositoryService.createDeploymentQuery().processDefinitionKey(processName).list();
  for (Deployment deployment : deploymentList) {
    repositoryService.deleteDeployment(deployment.getId(), true);
  }
}

代码示例来源:origin: org.activiti/activiti-explorer

public DeploymentQuery getQuery(RepositoryService repositoryService) {
 return repositoryService.createDeploymentQuery()
 .orderByDeploymentName().asc()
 .orderByDeploymentId().asc();
}

代码示例来源:origin: com.camunda.fox.platform/fox-platform-service

protected Deployment performEngineDeployment(ProcessArchive processArchive) {
 String deploymentId = activitiDeployer.processArchiveDeployed(processArchive);   
 if(deploymentId == null) {
  return null;
 } else {
  return activitiProcessEngine.getRepositoryService()
      .createDeploymentQuery()
      .deploymentId(deploymentId)
      .singleResult();
 }
}

代码示例来源:origin: org.apache.provisionr/activiti-karaf-commands

private void printDeployments(PrintWriter out, RepositoryService repo) {
  List<Deployment> depList = repo.createDeploymentQuery().orderByDeploymenTime().asc().list();
  out.println();
  out.println("Activiti Deployments");
  out.println("--------------------");
  if (depList.isEmpty()) {
    out.println("No Activiti Deployments Found.");
    return;
  }
  TextTable txtTable = new TextTable(3);
  txtTable.addHeaders("ID", "Name", "Deployment Time");
  for (Deployment dep : depList) {
    txtTable.addRow(dep.getId(), dep.getName(), formatDate(dep.getDeploymentTime()));
  }
  txtTable.print(out);
}

代码示例来源:origin: axemblr/axemblr-provisionr

private void printDeployments(PrintWriter out, RepositoryService repo) {
  List<Deployment> depList = repo.createDeploymentQuery().orderByDeploymenTime().asc().list();
  out.println();
  out.println("Activiti Deployments");
  out.println("--------------------");
  if (depList.isEmpty()) {
    out.println("No Activiti Deployments Found.");
    return;
  }
  TextTable txtTable = new TextTable(3);
  txtTable.addHeaders("ID", "Name", "Deployment Time");
  for (Deployment dep : depList) {
    txtTable.addRow(dep.getId(), dep.getName(), formatDate(dep.getDeploymentTime()));
  }
  txtTable.print(out);
}

代码示例来源:origin: Evolveum/midpoint

private void autoDeployResource(Resource resource) throws IOException, XPathExpressionException {
  RepositoryService repositoryService = processEngine.getRepositoryService();
  URL url = resource.getURL();
  String name = url.toString();
  long resourceLastModified = resource.lastModified();
  LOGGER.debug("Checking resource " + name + " (last modified = " + new Date(resourceLastModified) + ")");
  boolean tooOld = false;
  List<Deployment> existingList = repositoryService.createDeploymentQuery().deploymentName(name).orderByDeploymenTime().desc().listPage(1, 1);
  Deployment existing = existingList != null && !existingList.isEmpty() ? existingList.get(0) : null;
  if (existing != null) {
    if (resourceLastModified >= existing.getDeploymentTime().getTime()) {
      tooOld = true;
    }
    LOGGER.debug("Found deployment " + existing.getName() + ", last modified " + existing.getDeploymentTime() +
        (tooOld ? " (too old)" : " (current)"));
  } else {
    LOGGER.debug("Deployment with name " + name + " was not found.");
  }
  if (existing == null || tooOld) {
    repositoryService.createDeployment().name(name).addInputStream(name, resource.getInputStream()).deploy();
    LOGGER.info("Successfully deployed Activiti resource " + name); // + " as deployment with id = " + deployment.getId() + ", name = " + deployment.getName());
  }
}

代码示例来源:origin: org.activiti/activiti-rest

Deployment deployment = repositoryService.createDeploymentQuery().deploymentId(deploymentId).singleResult();
if (deployment == null) {
 throw new ActivitiObjectNotFoundException("Could not find a deployment with id '" + deploymentId + "'.", Deployment.class);

代码示例来源:origin: FINRAOS/herd

/**
 * Deletes all deployments in the database and any associated tables.
 */
protected void deleteActivitiDeployments()
{
  for (Deployment deployment : activitiRepositoryService.createDeploymentQuery().list())
  {
    activitiRepositoryService.deleteDeployment(deployment.getId(), true);
  }
}

代码示例来源:origin: org.activiti/activiti-explorer

public DeploymentDetailPanel(String deploymentId, DeploymentPage parent) {
 this.repositoryService = ProcessEngines.getDefaultProcessEngine().getRepositoryService();
 this.i18nManager = ExplorerApp.get().getI18nManager();
 this.viewManager = ExplorerApp.get().getViewManager();
 
 this.deployment = repositoryService.createDeploymentQuery().deploymentId(deploymentId).singleResult();
 this.parent = parent;
 
 init();
}

代码示例来源:origin: com.bbossgroups.pdp/pdp-workflow

private List<ProcessDef> convert(List<ProcessDefinition> defs) {
  List<ProcessDef> datas = new ArrayList<ProcessDef>(defs.size());
  for (int i = 0; defs != null && i < defs.size(); i++) {
    ProcessDef def = new ProcessDef();
    ProcessDefinition def_ = defs.get(i);
    def.setCATEGORY_(def_.getCategory());
    def.setDEPLOYMENT_ID_(def_.getDeploymentId());
    def.setDGRM_RESOURCE_NAME_(def_.getDiagramResourceName());
    def.setHAS_START_FORM_KEY_(def_.hasStartFormKey() ? 1 : 0);
    def.setID_(def_.getId());
    def.setKEY_(def_.getKey());
    def.setNAME_(def_.getName());
    def.setRESOURCE_NAME_(def_.getResourceName());
    // def.setREV_(def_.)
    def.setSUSPENSION_STATE_(def_.isSuspended() ? 1 : 0);
    def.setVERSION_(def_.getVersion());
    Deployment deployment = repositoryService.createDeploymentQuery()
        .deploymentId(def_.getDeploymentId()).singleResult();
    def.setDEPLOYMENT_NAME_(deployment.getName());
    def.setDEPLOYMENT_TIME_(deployment.getDeploymentTime());
    datas.add(def);
  }
  return datas;
}

代码示例来源:origin: org.activiti/activiti-explorer

public AbstractProcessDefinitionDetailPanel(String processDefinitionId, AbstractPage parentPage) {
 this.repositoryService = ProcessEngines.getDefaultProcessEngine().getRepositoryService();
 this.managementService = ProcessEngines.getDefaultProcessEngine().getManagementService();
 this.formService = ProcessEngines.getDefaultProcessEngine().getFormService();
 this.i18nManager = ExplorerApp.get().getI18nManager();
 
 this.parentPage = parentPage;
 this.processDefinition = repositoryService.getProcessDefinition(processDefinitionId);
 if(processDefinition != null) {
  deployment = repositoryService.createDeploymentQuery().deploymentId(processDefinition.getDeploymentId()).singleResult();
 }
 
 initUi();
}

代码示例来源:origin: jbarrez/Activiti-KickStart

public List<KickstartWorkflowInfo> convertToWorkflowInfoList(List<ProcessDefinition> processDefinitions, boolean includeCounts) {
  List<KickstartWorkflowInfo> infoList = new ArrayList<KickstartWorkflowInfo>();
  for (ProcessDefinition processDefinition : processDefinitions) {
    KickstartWorkflowInfo workflowInfo = new KickstartWorkflowInfo();
    workflowInfo.setId(processDefinition.getId());
    workflowInfo.setKey(processDefinition.getKey());
    workflowInfo.setName(processDefinition.getName());
    workflowInfo.setVersion(processDefinition.getVersion());
    workflowInfo.setDeploymentId(processDefinition.getDeploymentId());
    Date deploymentTime = repositoryService.createDeploymentQuery()
        .deploymentId(processDefinition.getDeploymentId())
        .singleResult().getDeploymentTime();
    workflowInfo.setCreateTime(deploymentTime);
    if (includeCounts) {
     workflowInfo.setNrOfRuntimeInstances(historyService
         .createHistoricProcessInstanceQuery()
         .processDefinitionId(processDefinition.getId())
         .unfinished().count());
     workflowInfo.setNrOfHistoricInstances(historyService
         .createHistoricProcessInstanceQuery()
         .processDefinitionId(processDefinition.getId()).finished()
         .count());
    }
    infoList.add(workflowInfo);
  }
  return infoList;
}

相关文章

微信公众号

最新文章

更多