import org.activiti.engine.IdentityService; //导入依赖的package包/类
public String startProcess(String userId, String businessKey,
        String processDefinitionId, Map<String, Object> processParameters) {
    // 先设置登录用户
    IdentityService identityService = processEngine.getIdentityService();
    identityService.setAuthenticatedUserId(userId);

    ProcessInstance processInstance = processEngine.getRuntimeService()
            .startProcessInstanceById(processDefinitionId, businessKey,
                    processParameters);

    /*
     * // {流程标题:title}-{发起人:startUser}-{发起时间:startTime} String processDefinitionName =
     * processEngine.getRepositoryService() .createProcessDefinitionQuery()
     * .processDefinitionId(processDefinitionId).singleResult() .getName(); String processInstanceName =
     * processDefinitionName + "-" + userConnector.findById(userId).getDisplayName() + "-" + new
     * SimpleDateFormat("yyyy-MM-dd HH:mm").format(new Date());
     * processEngine.getRuntimeService().setProcessInstanceName( processInstance.getId(), processInstanceName);
     */
    return processInstance.getId();
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
@Override
public EngineServices getEngineServices() {
    if (this.engineServicesMock != null) {
        return this.engineServicesMock;
    }

    this.engineServicesMock = mock(EngineServices.class);
    when(engineServicesMock.getFormService()).thenReturn(mock(FormService.class));
    when(engineServicesMock.getHistoryService()).thenReturn(mock(HistoryService.class));
    when(engineServicesMock.getIdentityService()).thenReturn(mock(IdentityService.class));
    when(engineServicesMock.getManagementService()).thenReturn(mock(ManagementService.class));
    when(engineServicesMock.getRepositoryService()).thenReturn(mock(RepositoryService.class));
    when(engineServicesMock.getRuntimeService()).thenReturn(mock(RuntimeService.class));
    when(engineServicesMock.getTaskService()).thenReturn(mock(TaskService.class));

    return engineServicesMock;
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
@Override
public void execute(DelegateExecution execution) {

    IdentityService identityService = Context.getProcessEngineConfiguration().getIdentityService();

    String username = "Kermit";
    User user = identityService.newUser(username);
    user.setPassword("123");
    user.setFirstName("Manually");
    user.setLastName("created");
    identityService.saveUser(user);

    // Add admin group
    Group group = identityService.newGroup("admin");
    identityService.saveGroup(group);

    identityService.createMembership(username, "admin");
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
protected void initPicture(IdentityService identityService, boolean renderPicture, final String userName) {
  if(renderPicture) {
    Picture picture = identityService.getUserPicture(userName);
    if(picture != null) {
      Resource imageResource = new StreamResource(new InputStreamStreamSource(picture.getInputStream()), 
        userName + picture.getMimeType(), ExplorerApp.get());
      
      Embedded image = new Embedded(null, imageResource);
      image.addStyleName(ExplorerLayout.STYLE_CLICKABLE);
      image.setType(Embedded.TYPE_IMAGE);
      image.setHeight(30, Embedded.UNITS_PIXELS);
      image.setWidth(30, Embedded.UNITS_PIXELS);
      image.addListener(new MouseEvents.ClickListener() {
        private static final long serialVersionUID = 7341560240277898495L;
        public void click(com.vaadin.event.MouseEvents.ClickEvent event) {
          viewManager.showProfilePopup(userName);
        }
      });
      
      addComponent(image);
      setComponentAlignment(image, Alignment.MIDDLE_LEFT);
    } else {
     // TODO: what when no image is available?
    }
  }
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
public GroupSelectionPopupWindow(IdentityService identityService, String userId) {
  this.identityService = identityService;
  this.i18nManager = ExplorerApp.get().getI18nManager();
  this.userId = userId;
  
  setCaption(i18nManager.getMessage(Messages.USER_SELECT_GROUPS_POPUP, userId));
  setModal(true);
  center();
  setWidth(500, UNITS_PIXELS);
  setHeight(400, UNITS_PIXELS);
  addStyleName(Reindeer.WINDOW_LIGHT);
  ((VerticalLayout) getContent()).setSpacing(true);
  
  initGroupTable();
  initSelectButton();
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
public static void main(String[] args) {
  ProcessEngineImpl processEngine = (ProcessEngineImpl) ProcessEngines.getDefaultProcessEngine();
  IdentityService identityService = processEngine.getIdentityService();
  
  User user = identityService.newUser("johndoe");
  identityService.saveUser(user);
  
  String accountUsername = System.getProperty("user");
  String accountPassword = System.getProperty("pwd");
  Map<String, String> accountDetails = new HashMap<String, String>();
  accountDetails.put("toDoFolderName", "Cases");
  accountDetails.put("toDoInActivitiFolderName", "CasesInActiviti");
  accountDetails.put("imapHost", "imap.gmail.com");
  accountDetails.put("imapProtocol", "imaps");
  
  identityService.setUserAccount("tom", null, "mailscan", accountUsername, accountPassword, accountDetails);
  
  MailScanner mailScanner = processEngine
    .getProcessEngineConfiguration()
    .getMailScanner();
  
  mailScanner.start();
  
  mailScanner.addUser("tom", null);
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
@Put()
public StateResponse createUser(UserInfoWithPassword userInfo){
  if(authenticate() == false) return null;
  
  IdentityService identityService = ActivitiUtil.getIdentityService();
  if(userInfo == null || userInfo.getId() == null) {
    throw new ActivitiException("No user id supplied");
  }

  if (identityService.createUserQuery().userId(userInfo.getId()).count() == 0) {
     User user = identityService.newUser(userInfo.getId());
     user.setFirstName(userInfo.getFirstName());
     user.setLastName(userInfo.getLastName());
     user.setPassword(userInfo.getPassword());
     user.setEmail(userInfo.getEmail());
     identityService.saveUser(user);
  } else  {
    throw new ActivitiException("user id must be unique");
  }
  return new StateResponse().setSuccess(true);
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
@Override
public void execute(DelegateExecution execution) throws Exception {

  IdentityService identityService = execution.getEngineServices().getIdentityService();
  
  String username = "Kermit";
  User user = identityService.newUser(username);
  user.setPassword("123");
  user.setFirstName("Manually");
  user.setLastName("created");
  identityService.saveUser(user);
  
  // Add admin group
  Group group = identityService.newGroup("admin");
  identityService.saveGroup(group);

  identityService.createMembership(username, "admin");
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
public IdentityService getIdentityService() {
    if (processEngine == null) {
        return null;
    }

    return processEngine.getIdentityService();
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
/**
 * 完成任务.
 */
public void completeTask(String taskId, String userId,
        Map<String, Object> variables) {
    TaskService taskService = processEngine.getTaskService();
    Task task = taskService.createTaskQuery().taskId(taskId).singleResult();

    if (task == null) {
        throw new IllegalStateException("任务不存在");
    }

    // 先设置登录用户
    IdentityService identityService = processEngine.getIdentityService();
    identityService.setAuthenticatedUserId(userId);

    // 处理子任务
    if ("subtask".equals(task.getCategory())) {
        processEngine.getManagementService().executeCommand(
                new DeleteTaskWithCommentCmd(taskId, "完成"));

        int count = jdbcTemplate.queryForObject(
                "select count(*) from ACT_RU_TASK where PARENT_TASK_ID_=?",
                Integer.class, task.getParentTaskId());

        if (count > 1) {
            return;
        }

        taskId = task.getParentTaskId();
    }

    processEngine.getManagementService().executeCommand(
            new CompleteTaskWithCommentCmd(taskId, variables, "完成"));
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
static void persistUser(IdentityService identityService, String userId) {
    User user = identityService.createUserQuery().userId(userId).singleResult();
    if (user == null) {
        user = identityService.newUser(userId);
        identityService.saveUser(user);
    }
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
@RequestMapping(method=RequestMethod.POST)
public RedirectView submitForm(Model model, @ModelAttribute LoginForm signupForm, BindingResult bindingResult){
	model.addAttribute("signupForm", signupForm);
	RedirectView redirectView = new RedirectView();
	redirectView.setContextRelative(true);
	
	if(bindingResult.hasErrors()) {
		signupForm = new LoginForm();
		redirectView.setUrl("/ocs/signup");
		references(model);
		model.addAttribute("signupForm", signupForm);
	} else{
		loginService.addAccount(signupForm);
		IdentityService identityService = processEngine.getIdentityService();
	    User user = identityService.newUser(signupForm.getUsername());
	    user.setPassword(signupForm.getPassword());
	    identityService.saveUser(user);
	    
	    try{
	    	identityService.saveGroup(identityService.newGroup("payor"));
			identityService.saveGroup(identityService.newGroup("shipper"));
			identityService.saveGroup(identityService.newGroup("shopper"));
			identityService.saveGroup(identityService.newGroup("buyer"));
	    }catch(Exception e){
	    	System.out.println("Groups already exists....");
	    }
	   
	    identityService.createMembership(signupForm.getUsername(), "shopper");
	    identityService.createMembership(signupForm.getUsername(), "buyer");
	    identityService.createMembership(signupForm.getUsername(), "payor");
	    identityService.createMembership(signupForm.getUsername(), "shipper");
	      		
		redirectView.setUrl("/ocs/login");
		
	}
	return redirectView;
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
public List<String> getAuthorizationGroups() {
    // Similar behaviour as the TaskQuery.taskCandidateUser() which includes the groups the candidate user is part of
    if (authorizationUserId != null) {
        IdentityService identityService = Context.getProcessEngineConfiguration().getIdentityService();
        List<Group> groups = identityService.createGroupQuery().groupMember(authorizationUserId).list();
        List<String> groupIds = new ArrayList<>();
        for (Group group : groups) {
            groupIds.add(group.getId());
        }
        return groupIds;
    }
    return null;
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
protected List<String> getGroupsForCandidateUser(String candidateUser) {
    IdentityService identityService = Context.getProcessEngineConfiguration().getIdentityService();
    List<Group> groups = identityService.createGroupQuery().groupMember(candidateUser).list();
    List<String> groupIds = new ArrayList<>();
    for (Group group : groups) {
        groupIds.add(group.getId());
    }
    return groupIds;
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
@Override
public void notify(DelegateExecution execution) throws Exception {
    IdentityService identityService = execution.getEngineServices().getIdentityService();
    String applyUserId = (String) execution.getVariable("applyUserId");
    User user = identityService.createUserQuery().userId(applyUserId).singleResult();
    execution.setVariableLocal("to", user.getEmail());
    execution.setVariableLocal("name", user.getFirstName() + " " + user.getLastName());

    // 超时提醒时间设置，请假结束时间+1天
    Date endDate = (Date) execution.getVariable("endDate");
    Calendar ca = Calendar.getInstance();
    ca.setTime(endDate);
    ca.add(Calendar.DAY_OF_MONTH, 1);
    execution.setVariableLocal("reportBackTimeout", ca.getTime());
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
public UserProfileLink(IdentityService identityService, boolean renderPicture, final String userId) {
  this.identityService = identityService;
  this.viewManager = ExplorerApp.get().getViewManager();
  this.userCache = ExplorerApp.get().getUserCache();
  
  setSizeUndefined();
  setSpacing(true);
  addStyleName(ExplorerLayout.STYLE_PROFILE_LINK);
  
  initPicture(identityService, renderPicture, userId);
  initUserLink(userId);
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
public DeleteMembershipListener(IdentityService identityService, String userId,
        String groupId, MemberShipChangeListener memberShipChangeListener ) {
  this.identityService = identityService;
  this.userId = userId;
  this.groupId = groupId;
  this.membershipChangeListener = memberShipChangeListener;
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
private void initUserCache() {
  if (environment.equals(Environments.ALFRESCO)) {
    userCache = new DummyUserCache(); // User cache is not needed in Alfresco since we hook in Alfresco's ID mgmt
  } else {
    userCache = new TrieBasedUserCache();
    
    // indentityService is not injected in this factory bean because 
    // we don't want to expose it in Alfresco context.xml. So we inject it manually here.
    ((TrieBasedUserCache)userCache).setIdentityService(applicationContext.getBean(IdentityService.class));
  }
}
 

import org.activiti.engine.IdentityService; //导入依赖的package包/类
public static IdentityService getIdentityService() {
    IdentityService identityService = null;
    if (getBPMNEngineService().getProcessEngine() != null) {
        identityService = getBPMNEngineService().getProcessEngine().getIdentityService();
        if (identityService == null) {
            throw new BPMNOSGIServiceException("IdentityService couldn't be identified");
        }
    }
    return identityService;
}