本文整理汇总了Java中org.activiti.engine.impl.Page类的典型用法代码示例。如果您正苦于以下问题：Java Page类的具体用法？Java Page怎么用？Java Page使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Page类属于org.activiti.engine.impl包，在下文中一共展示了Page类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getHistoricActivityInstanceEntity
import org.activiti.engine.impl.Page; //导入依赖的package包/类
/**
* 查询历史节点.
*/
public HistoricActivityInstanceEntity getHistoricActivityInstanceEntity(
String historyTaskId) {
logger.info("historyTaskId : {}", historyTaskId);
JdbcTemplate jdbcTemplate = ApplicationContextHelper
.getBean(JdbcTemplate.class);
String historicActivityInstanceId = jdbcTemplate.queryForObject(
"SELECT ID_ FROM ACT_HI_ACTINST WHERE TASK_ID_=?",
String.class, historyTaskId);
logger.info("historicActivityInstanceId : {}",
historicActivityInstanceId);
HistoricActivityInstanceQueryImpl historicActivityInstanceQueryImpl = new HistoricActivityInstanceQueryImpl();
historicActivityInstanceQueryImpl
.activityInstanceId(historicActivityInstanceId);
HistoricActivityInstanceEntity historicActivityInstanceEntity = (HistoricActivityInstanceEntity) Context
.getCommandContext()
.getHistoricActivityInstanceEntityManager()
.findHistoricActivityInstancesByQueryCriteria(
historicActivityInstanceQueryImpl, new Page(0, 1))
.get(0);
return historicActivityInstanceEntity;
}
开发者ID:zhaojunfei，项目名称:lemon，代码行数:29，代码来源:RollbackTaskCmd.java
示例2: getHistoricActivityInstanceEntity
import org.activiti.engine.impl.Page; //导入依赖的package包/类
public HistoricActivityInstanceEntity getHistoricActivityInstanceEntity(
String historyTaskId) {
logger.info("historyTaskId : {}", historyTaskId);
JdbcTemplate jdbcTemplate = ApplicationContextHelper
.getBean(JdbcTemplate.class);
String historicActivityInstanceId = jdbcTemplate.queryForObject(
"select id_ from ACT_HI_ACTINST where task_id_=?",
String.class, historyTaskId);
logger.info("historicActivityInstanceId : {}",
historicActivityInstanceId);
HistoricActivityInstanceQueryImpl historicActivityInstanceQueryImpl = new HistoricActivityInstanceQueryImpl();
historicActivityInstanceQueryImpl
.activityInstanceId(historicActivityInstanceId);
HistoricActivityInstanceEntity historicActivityInstanceEntity = (HistoricActivityInstanceEntity) Context
.getCommandContext()
.getHistoricActivityInstanceEntityManager()
.findHistoricActivityInstancesByQueryCriteria(
historicActivityInstanceQueryImpl, new Page(0, 1))
.get(0);
return historicActivityInstanceEntity;
}
开发者ID:zhaojunfei，项目名称:lemon，代码行数:26，代码来源:WithdrawTaskCmd.java
示例3: findTargetHistoricActivity
import org.activiti.engine.impl.Page; //导入依赖的package包/类
/**
* 找到想要回退对应的节点历史.
*/
public HistoricActivityInstanceEntity findTargetHistoricActivity(
CommandContext commandContext, TaskEntity taskEntity,
ActivityImpl activityImpl) {
HistoricActivityInstanceQueryImpl historicActivityInstanceQueryImpl = new HistoricActivityInstanceQueryImpl();
historicActivityInstanceQueryImpl.activityId(activityImpl.getId());
historicActivityInstanceQueryImpl.processInstanceId(taskEntity
.getProcessInstanceId());
historicActivityInstanceQueryImpl
.orderByHistoricActivityInstanceEndTime().desc();
HistoricActivityInstanceEntity historicActivityInstanceEntity = (HistoricActivityInstanceEntity) commandContext
.getHistoricActivityInstanceEntityManager()
.findHistoricActivityInstancesByQueryCriteria(
historicActivityInstanceQueryImpl, new Page(0, 1))
.get(0);
return historicActivityInstanceEntity;
}
开发者ID:zhaojunfei，项目名称:lemon，代码行数:22，代码来源:RollbackTaskCmd.java
示例4: fetchHistoricActivityInstances
import org.activiti.engine.impl.Page; //导入依赖的package包/类
public void fetchHistoricActivityInstances() {
HistoricActivityInstanceQueryImpl historicActivityInstanceQueryImpl = new HistoricActivityInstanceQueryImpl();
// historicActivityInstanceQueryImpl.processInstanceId(processInstanceId)
// .orderByHistoricActivityInstanceStartTime().asc();
// TODO: 如果用了uuid会造成这样排序出问题
// 但是如果用startTime，可能出现因为处理速度太快，时间一样，导致次序颠倒的问题
historicActivityInstanceQueryImpl.processInstanceId(processInstanceId)
.orderByHistoricActivityInstanceId().asc();
Page page = new Page(0, 100);
historicActivityInstances = Context
.getCommandContext()
.getHistoricActivityInstanceEntityManager()
.findHistoricActivityInstancesByQueryCriteria(
historicActivityInstanceQueryImpl, page);
}
开发者ID:zhaojunfei，项目名称:lemon，代码行数:17，代码来源:ActivitiHistoryGraphBuilder.java
示例5: findProcessDefinitionsByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<ProcessDefinition> findProcessDefinitionsByQueryCriteria(ProcessDefinitionQueryImpl processDefinitionQuery, Page page) {
// List<ProcessDefinition> processDefinitions =
return getDbSqlSession().selectList("selectProcessDefinitionsByQueryCriteria", processDefinitionQuery, page);
// skipped this after discussion within the team
// // retrieve process definitions from cache (https://activiti.atlassian.net/browse/ACT-1020) to have all available information
// ArrayList<ProcessDefinition> result = new ArrayList<ProcessDefinition>();
// for (ProcessDefinition processDefinitionEntity : processDefinitions) {
// ProcessDefinitionEntity fullProcessDefinition = Context
// .getProcessEngineConfiguration()
// .getDeploymentCache().resolveProcessDefinition((ProcessDefinitionEntity)processDefinitionEntity);
// result.add(fullProcessDefinition);
// }
// return result;
}
开发者ID:flowable，项目名称:flowable-engine，代码行数:17，代码来源:ProcessDefinitionEntityManager.java
示例6: findNewLatestProcessDefinitionAfterRemovalOf
import org.activiti.engine.impl.Page; //导入依赖的package包/类
protected ProcessDefinition findNewLatestProcessDefinitionAfterRemovalOf(ProcessDefinition processDefinitionToBeRemoved) {
// The latest process definition is not necessarily the one with 'version -1' (some versions could have been deleted)
// Hence, the following logic
ProcessDefinitionQueryImpl query = new ProcessDefinitionQueryImpl();
query.processDefinitionKey(processDefinitionToBeRemoved.getKey());
if (processDefinitionToBeRemoved.getTenantId() != null
&& !ProcessEngineConfiguration.NO_TENANT_ID.equals(processDefinitionToBeRemoved.getTenantId())) {
query.processDefinitionTenantId(processDefinitionToBeRemoved.getTenantId());
} else {
query.processDefinitionWithoutTenantId();
}
query.processDefinitionVersionLowerThan(processDefinitionToBeRemoved.getVersion());
query.orderByProcessDefinitionVersion().desc();
List<ProcessDefinition> processDefinitions = getProcessDefinitionManager().findProcessDefinitionsByQueryCriteria(query, new Page(0, 1));
if (processDefinitions != null && processDefinitions.size() > 0) {
return processDefinitions.get(0);
}
return null;
}
开发者ID:flowable，项目名称:flowable-engine，代码行数:25，代码来源:DeploymentEntityManager.java
示例7: findProcessDefinitionsByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<ProcessDefinition> findProcessDefinitionsByQueryCriteria(ProcessDefinitionQueryImpl processDefinitionQuery, Page page) {
// List<ProcessDefinition> processDefinitions =
return getDbSqlSession().selectList("selectProcessDefinitionsByQueryCriteria", processDefinitionQuery, page);
//skipped this after discussion within the team
// // retrieve process definitions from cache (http://jira.codehaus.org/browse/ACT-1020) to have all available information
// ArrayList<ProcessDefinition> result = new ArrayList<ProcessDefinition>();
// for (ProcessDefinition processDefinitionEntity : processDefinitions) {
// ProcessDefinitionEntity fullProcessDefinition = Context
// .getProcessEngineConfiguration()
// .getDeploymentCache().resolveProcessDefinition((ProcessDefinitionEntity)processDefinitionEntity);
// result.add(fullProcessDefinition);
// }
// return result;
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:17，代码来源:ProcessDefinitionEntityManager.java
示例8: selectList
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
public List selectList(String statement, Object parameter, Page page) {
if (page != null) {
return selectList(statement, parameter, page.getFirstResult(), page.getMaxResults());
} else {
return selectList(statement, parameter, 0, Integer.MAX_VALUE);
}
}
开发者ID:flowable，项目名称:flowable-engine，代码行数:9，代码来源:DbSqlSession.java
示例9: findHistoricProcessInstancesByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<HistoricProcessInstance> findHistoricProcessInstancesByQueryCriteria(HistoricProcessInstanceQueryImpl historicProcessInstanceQuery, Page page) {
if (historyLevel>ProcessEngineConfigurationImpl.HISTORYLEVEL_NONE) {
return getDbSqlSession().selectList("selectHistoricProcessInstancesByQueryCriteria", historicProcessInstanceQuery, page);
}
return Collections.EMPTY_LIST;
}
开发者ID:logicalhacking，项目名称:SecureBPMN，代码行数:8，代码来源:HistoricProcessInstanceManager.java
示例10: findLatestDeploymentByName
import org.activiti.engine.impl.Page; //导入依赖的package包/类
public DeploymentEntity findLatestDeploymentByName(String deploymentName) {
List<?> list = getDbSqlSession().selectList("selectDeploymentsByName", deploymentName, new Page(0, 1));
if (list!=null && !list.isEmpty()) {
return (DeploymentEntity) list.get(0);
}
return null;
}
开发者ID:logicalhacking，项目名称:SecureBPMN，代码行数:8，代码来源:DeploymentManager.java
示例11: findHistoricTaskInstancesByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<HistoricTaskInstance> findHistoricTaskInstancesByQueryCriteria(HistoricTaskInstanceQueryImpl historicTaskInstanceQuery, Page page) {
if (historyLevel>ProcessEngineConfigurationImpl.HISTORYLEVEL_NONE) {
return getDbSqlSession().selectList("selectHistoricTaskInstancesByQueryCriteria", historicTaskInstanceQuery, page);
}
return Collections.EMPTY_LIST;
}
开发者ID:logicalhacking，项目名称:SecureBPMN，代码行数:8，代码来源:HistoricTaskInstanceManager.java
示例12: selectList
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List selectList(String statement, Object parameter, Page page) {
statement = dbSqlSessionFactory.mapStatement(statement);
List loadedObjects;
if (page!=null) {
loadedObjects = sqlSession.selectList(statement, parameter, new RowBounds(page.getFirstResult(), page.getMaxResults()));
} else {
loadedObjects = sqlSession.selectList(statement, parameter);
}
return filterLoadedObjects(loadedObjects);
}
开发者ID:logicalhacking，项目名称:SecureBPMN，代码行数:12，代码来源:DbSqlSession.java
示例13: execute
import org.activiti.engine.impl.Page; //导入依赖的package包/类
public AcquiredJobs execute(CommandContext commandContext) {
String lockOwner = jobExecutor.getLockOwner();
int lockTimeInMillis = jobExecutor.getLockTimeInMillis();
int maxJobsPerAcquisition = jobExecutor.getMaxJobsPerAcquisition();
AcquiredJobs acquiredJobs = new AcquiredJobs();
List<JobEntity> jobs = commandContext
.getJobManager()
.findNextJobsToExecute(new Page(0, maxJobsPerAcquisition));
for (JobEntity job: jobs) {
List<String> jobIds = new ArrayList<String>();
if (job != null) {
job.setLockOwner(lockOwner);
GregorianCalendar gregorianCalendar = new GregorianCalendar();
gregorianCalendar.setTime(ClockUtil.getCurrentTime());
gregorianCalendar.add(Calendar.MILLISECOND, lockTimeInMillis);
job.setLockExpirationTime(gregorianCalendar.getTime());
jobIds.add(job.getId());
if (job.isExclusive()) {
// TODO acquire other exclusive jobs for the same process instance.
}
}
acquiredJobs.addJobIds(jobIds);
}
return acquiredJobs;
}
开发者ID:logicalhacking，项目名称:SecureBPMN，代码行数:32，代码来源:AcquireJobsCmd.java
示例14: pageUserList
import org.activiti.engine.impl.Page; //导入依赖的package包/类
private List<User> pageUserList(Page page, String[] users, int tenantId)
throws RegistryException, org.wso2.carbon.user.core.UserStoreException {
List<User> userList = new ArrayList<>();
int resultLength = users.length;
int max;
if (page != null) {
if (page.getFirstResult() > resultLength) {
//no more result left, sending empty list
return new ArrayList<>();
}
if (page.getMaxResults() > resultLength) {
max = resultLength;
} else {
max = page.getMaxResults();
}
for (int i = page.getFirstResult(); i < max; i++) {
userList.add(new UserEntity(users[i]));
}
} else {
for (int i = 0; i < resultLength; i++) {
userList.add(new UserEntity(users[i]));
}
}
return userList;
}
开发者ID:wso2，项目名称:carbon-business-process，代码行数:28，代码来源:BPSUserIdentityManager.java
示例15: findHistoricProcessInstancesByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<HistoricProcessInstance> findHistoricProcessInstancesByQueryCriteria(HistoricProcessInstanceQueryImpl historicProcessInstanceQuery, Page page) {
if (getHistoryManager().isHistoryEnabled()) {
return getDbSqlSession().selectList("selectHistoricProcessInstancesByQueryCriteria", historicProcessInstanceQuery, page);
}
return Collections.EMPTY_LIST;
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:8，代码来源:HistoricProcessInstanceEntityManager.java
示例16: findHistoricProcessInstancesAndVariablesByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<HistoricProcessInstance> findHistoricProcessInstancesAndVariablesByQueryCriteria(HistoricProcessInstanceQueryImpl historicProcessInstanceQuery, Page page) {
if (getHistoryManager().isHistoryEnabled()) {
return getDbSqlSession().selectList("selectHistoricProcessInstancesWithVariablesByQueryCriteria", historicProcessInstanceQuery, page);
}
return Collections.EMPTY_LIST;
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:8，代码来源:HistoricProcessInstanceEntityManager.java
示例17: findHistoricTaskInstancesByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<HistoricTaskInstance> findHistoricTaskInstancesByQueryCriteria(HistoricTaskInstanceQueryImpl historicTaskInstanceQuery, Page page) {
if (getHistoryManager().isHistoryEnabled()) {
return getDbSqlSession().selectList("selectHistoricTaskInstancesByQueryCriteria", historicTaskInstanceQuery, page);
}
return Collections.EMPTY_LIST;
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:8，代码来源:HistoricTaskInstanceEntityManager.java
示例18: findHistoricTaskInstancesAndVariablesByQueryCriteria
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<HistoricTaskInstance> findHistoricTaskInstancesAndVariablesByQueryCriteria(HistoricTaskInstanceQueryImpl historicTaskInstanceQuery, Page page) {
if (getHistoryManager().isHistoryEnabled()) {
return getDbSqlSession().selectList("selectHistoricTaskInstancesWithVariablesByQueryCriteria", historicTaskInstanceQuery, page);
}
return Collections.EMPTY_LIST;
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:8，代码来源:HistoricTaskInstanceEntityManager.java
示例19: selectList
import org.activiti.engine.impl.Page; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
public List selectList(String statement, Object parameter, Page page) {
if (page!=null) {
return selectList(statement, parameter, page.getFirstResult(), page.getMaxResults());
} else {
return selectList(statement, parameter, 0, Integer.MAX_VALUE);
}
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:9，代码来源:DbSqlSession.java
示例20: execute
import org.activiti.engine.impl.Page; //导入依赖的package包/类
public AcquiredJobs execute(CommandContext commandContext) {
String lockOwner = jobExecutor.getLockOwner();
int lockTimeInMillis = jobExecutor.getLockTimeInMillis();
int maxNonExclusiveJobsPerAcquisition = jobExecutor.getMaxJobsPerAcquisition();
AcquiredJobs acquiredJobs = new AcquiredJobs();
List<JobEntity> jobs = commandContext
.getJobEntityManager()
.findNextJobsToExecute(new Page(0, maxNonExclusiveJobsPerAcquisition));
for (JobEntity job: jobs) {
List<String> jobIds = new ArrayList<String>();
if (job != null && !acquiredJobs.contains(job.getId())) {
if (job.isExclusive() && job.getProcessInstanceId() != null) {
// acquire all exclusive jobs in the same process instance
// (includes the current job)
List<JobEntity> exclusiveJobs = commandContext.getJobEntityManager()
.findExclusiveJobsToExecute(job.getProcessInstanceId());
for (JobEntity exclusiveJob : exclusiveJobs) {
if(exclusiveJob != null) {
lockJob(exclusiveJob, lockOwner, lockTimeInMillis);
jobIds.add(exclusiveJob.getId());
}
}
} else {
lockJob(job, lockOwner, lockTimeInMillis);
jobIds.add(job.getId());
}
}
acquiredJobs.addJobIdBatch(jobIds);
}
return acquiredJobs;
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:38，代码来源:AcquireJobsCmd.java
注：本文中的org.activiti.engine.impl.Page类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论