Package pl.net.bluesoft.rnd.processtool.model

Examples of pl.net.bluesoft.rnd.processtool.model.UserData


      ProcessStateWidget configuration, I18NSource i18nSource,
      ProcessToolBpmSession bpmSession, Application application,
      Set<String> permissions, boolean isOwner) {

//    get user from context
    UserData user = bpmSession.getUser(ProcessToolContext.Util
        .getThreadProcessToolContext());
    try {
     
//    load associated liferay user
      liferayUser = UserServiceUtil.getUserByEmailAddress(
          user.getCompanyId(), user.getEmail());

    } catch (SystemException e) {
      e.printStackTrace();
    } catch (PortalException e) {
      e.printStackTrace();
View Full Code Here


                ProcessToolContext.Util.setThreadProcessToolContext(processToolContext);
                try {
                    boolean skipJbpm = false;
                    InputStream is = bpmStream;
                    ProcessToolBpmSession session = processToolContext.getProcessToolSessionFactory().createSession(
                            new UserData("admin", "admin@aperteworkflow.org", "Admin"), Arrays.asList("ADMIN"));
                    if (cfg.getPermissions() != null) {
                        for (ProcessDefinitionPermission p : cfg.getPermissions()) {
                            if (!Strings.hasText(p.getPrivilegeName())) {
                                p.setPrivilegeName(PRIVILEGE_INCLUDE);
                            }
View Full Code Here

           return null;
       }

       @Override
       public BpmTask getPastOrActualTask(final ProcessInstanceLog log, ProcessToolContext ctx) {
           final UserData user = log.getUser();
           final ProcessInstance pi = log.getOwnProcessInstance();
           final Calendar minDate = log.getEntryDate();
           final Set<String> taskNames = new HashSet<String>();
           if (log.getState() != null && Strings.hasText(log.getState().getName())) {
               taskNames.add(log.getState().getName());
           }

           Command<List<HistoryActivityInstance>> cmd = new Command<List<HistoryActivityInstance>>() {
               @Override
               public List<HistoryActivityInstance> execute(Environment environment) throws Exception {
                   AbstractQuery q = new AbstractQuery() {
                       @Override
                       protected void applyPage(Query query) {
                           query.setFirstResult(0);
                           query.setMaxResults(1);
                       }

                       @Override
                       protected void applyParameters(Query query) {
                           query.setString("userIds", user.getLogin());
                           query.setString("internalIds", log.getExecutionId());
                           query.setDate("minDate", minDate.getTime());
                           if (!taskNames.isEmpty()) {
                               query.setParameterList("taskName", taskNames);
                           }
                       }

                       @Override
                       public String hql() {
                           StringBuilder hql = new StringBuilder()
                                   .append("select act ")
                                   .append("from ")
                                   .append(HistoryTaskInstanceImpl.class.getName()).append(" as act, ")
                                   .append(HistoryProcessInstanceImpl.class.getName()).append(" as proc, ")
                                   .append(HistoryTaskImpl.class.getName()).append(" as task  ")
                                   .append(" where act.historyProcessInstance = proc ")
                                   .append(" and act.historyTask = task ")
                                   .append(" and act.endTime is not null ");
                           if (!taskNames.isEmpty()) {
                               hql.append(" and act.activityName in (:taskName) ");
                           }
                           hql.append(" and task.assignee = :userIds ")
                                   .append(" and task.endTime > :minDate ")
                                   .append(" and act.executionId = :internalIds ")
                                   .append(" order by act.endTime asc ");
                           return hql.toString();
                       }
                   };
                   return (List<HistoryActivityInstance>) q.execute(environment);
               }
           };

           List<HistoryActivityInstance> pastTasks = getProcessEngine(ctx).execute(cmd);
           if (!pastTasks.isEmpty()) {
               return collectHistoryActivity(pastTasks.get(0), pi, user, ctx);
           }
           else {
               List<BpmTask> actualTasks = findProcessTasks(pi, user.getLogin(), taskNames, ctx);
               if (!actualTasks.isEmpty()) {
                   return actualTasks.get(0);
               }
           }
           return null;
View Full Code Here

       }

       @Override
     public List<BpmTask> findRecentTasks(Calendar minDate, Integer offset, Integer limit, ProcessToolContext ctx) {
       List<BpmTask> recentTasks = new ArrayList<BpmTask>();
       UserData user = getUser(ctx);
       ResultsPageWrapper<ProcessInstance> recentInstances = ctx.getProcessInstanceDAO().getRecentProcesses(user, minDate, offset, limit);
       Collection<ProcessInstance> instances = recentInstances.getResults();
       for (ProcessInstance pi : instances) {
         List<BpmTask> tasks = findProcessTasks(pi, user.getLogin(), ctx);
         if (tasks.isEmpty()) {
           BpmTask task = getMostRecentProcessHistoryTask(pi, user, minDate, ctx);
           if (task != null) {
             recentTasks.add(task);
           }
View Full Code Here

     }

     @Override
     public Integer getRecentTasksCount(Calendar minDate, ProcessToolContext ctx) {
       int count = 0;
       UserData user = getUser(ctx);
       Collection<ProcessInstance> instances = ctx.getProcessInstanceDAO().getUserProcessesAfterDate(user, minDate);
       for (ProcessInstance pi : instances) {
         List<BpmTask> tasks = findProcessTasks(pi, user.getLogin(), ctx);
         if (tasks.isEmpty() && getMostRecentProcessHistoryTask(pi, user, minDate, ctx) != null) {
           count += 1;
         }
         else {
           count += tasks.size();
View Full Code Here

    private MutableBpmTask collectTask(Task task, ProcessInstance pi, ProcessToolContext ctx) {
       MutableBpmTask t = new MutableBpmTask();
       t.setProcessInstance(pi);
       t.setAssignee(task.getAssignee());
       UserData ud = ctx.getUserDataDAO().loadUserByLogin(task.getAssignee());
       if (ud == null) {
         ud = new UserData();
         ud.setLogin(task.getAssignee());
       }
       t.setOwner(ud);
       t.setTaskName(task.getActivityName());
       t.setInternalTaskId(task.getId());
       t.setExecutionId(task.getExecutionId());
View Full Code Here

     public void assignTaskToUser(ProcessToolContext ctx, String taskId, String userLogin) {
      long start = System.currentTimeMillis();
       ProcessEngine processEngine = getProcessEngine(ctx);
       processEngine.getTaskService().assignTask(taskId, userLogin);
       BpmTask taskData = getTaskData(taskId, ctx);
       UserData newUser = new UserData()
       newUser.setLogin(userLogin);
       UserData loadOrCreateUser = loadOrCreateUser(ctx,newUser);
       broadcastEvent(ctx, new BpmEvent(BpmEvent.Type.ASSIGN_TASK, taskData, loadOrCreateUser));
       broadcastEvent(ctx, new BpmEvent(BpmEvent.Type.ASSIGN_TASK, taskData, user));
    ctx.getUserProcessQueueManager().onTaskAssigne(taskData);
      long duration = System.currentTimeMillis() - start;
    log.severe("assignTaskToUser: " +  duration);
View Full Code Here

                ProcessToolContext.Util.setThreadProcessToolContext(processToolContext);
                try {
                    boolean skipBpm = false;
                    InputStream is = bpmStream;
                    ProcessToolBpmSession session = processToolContext.getProcessToolSessionFactory().createSession(
                            new UserData("admin", "admin@aperteworkflow.org", "Admin"), Arrays.asList("ADMIN"));
                    byte[] oldDefinition = session.getProcessLatestDefinition(cfg.getBpmDefinitionKey(), cfg.getProcessName());
                    if (oldDefinition != null) {
                        byte[] newDefinition = IOUtils.slurp(is);
                        is = new ByteArrayInputStream(newDefinition);
                        if (Arrays.equals(newDefinition, oldDefinition)) {
View Full Code Here

        return getNextValue((String) null, sequenceName);
    }

    @Override
    public UserData getAutoUser() {
        return new UserData(Formats.nvl(getSetting(AUTO_USER_LOGIN), "system"), Formats.nvl(getSetting(AUTO_USER_NAME), "System"),
                Formats.nvl(getSetting(AUTO_USER_EMAIL), "awf@bluesoft.net.pl"));
    }
View Full Code Here

   
    /* Check if the current process has active task. It should has at least one */
    if(activeTasks.isEmpty())
      return false;
   
    UserData user = bpmSession.getUser(getCurrentContext());
    String userLogin = user.getLogin();
   
    for(BpmTask task: activeTasks)
    {
      if(task.getAssignee() != null && task.getAssignee().equals(userLogin))
      {
View Full Code Here

TOP

Related Classes of pl.net.bluesoft.rnd.processtool.model.UserData

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.