本文整理了Java中org.activiti.engine.RepositoryService.createDeploymentQuery
方法的一些代码示例,展示了RepositoryService.createDeploymentQuery
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RepositoryService.createDeploymentQuery
方法的具体详情如下:
包路径:org.activiti.engine.RepositoryService
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!