import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public void createTask(CommandContext commandContext, DbSqlSession dbSqlSession, MailTransformer mailTransformer) throws MessagingException {
  // distill the task description from the mail body content (without the html tags)
  String taskDescription = mailTransformer.getHtml();
  taskDescription = taskDescription.replaceAll("\\<.*?\\>", "");
  taskDescription = taskDescription.replaceAll("\\s", " ");
  taskDescription = taskDescription.trim();
  if (taskDescription.length()>120) {
    taskDescription = taskDescription.substring(0, 117)+"...";
  }

  // create and insert the task
  TaskEntity task = new TaskEntity();
  task.setAssignee(userId);
  task.setName(mailTransformer.getMessage().getSubject());
  task.setDescription(taskDescription);
  dbSqlSession.insert(task);
  String taskId = task.getId();
  
  // add identity links for all the recipients
  for (String recipientEmailAddress: mailTransformer.getRecipients()) {
    User recipient = new UserQueryImpl(commandContext)
      .userEmail(recipientEmailAddress)
      .singleResult();
    if (recipient!=null) {
      task.addUserIdentityLink(recipient.getId(), "Recipient");
    }
  }
  
  // attach the mail and other attachments to the task
  List<AttachmentEntity> attachments = mailTransformer.getAttachments();
  for (AttachmentEntity attachment: attachments) {
    // insert the bytes as content
    ByteArrayEntity content = attachment.getContent();
    dbSqlSession.insert(content);
    // insert the attachment
    attachment.setContentId(content.getId());
    attachment.setTaskId(taskId);
    dbSqlSession.insert(attachment);
  }
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@Override
public List<org.activiti.engine.identity.User> findUserByQueryCriteria(UserQueryImpl query, Page page) {
    throw new RuntimeException("not implement method..");
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@Override
public long findUserCountByQueryCriteria(UserQueryImpl query) {
    throw new RuntimeException("not implement method.");
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public List<User> findUserByQueryCriteria(UserQueryImpl query, Page page) {
//		return getDbSqlSession().selectList("selectUserByQueryCriteria", query, page);
		throw new RuntimeException("not implement method.");
	}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public long findUserCountByQueryCriteria(UserQueryImpl query) {
//		return (Long) getDbSqlSession().selectOne("selectUserCountByQueryCriteria", query);
		throw new RuntimeException("not implement method.");
	}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<User> findUserByQueryCriteria(UserQueryImpl query, Page page) {
	return getDbSqlSession().selectList("selectUserByQueryCriteria", query, page);
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public long findUserCountByQueryCriteria(UserQueryImpl query) {
	return (Long) getDbSqlSession().selectOne("selectUserCountByQueryCriteria", query);
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public UserQuery createNewUserQuery() {
	return new UserQueryImpl(Context.getProcessEngineConfiguration().getCommandExecutor());
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public UserQuery createNewUserQuery() {
  return new UserQueryImpl(Context.getProcessEngineConfiguration().getCommandExecutorTxRequired());
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public UserQueryImpl createUserQuery() {
  return new UserQueryImpl();
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@Override
public long findUserCountByQueryCriteria(UserQueryImpl userQuery) {
    return findUserByQueryCriteria(userQuery, null).size();
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@Override
public UserQuery createNewUserQuery() {
    return new UserQueryImpl(((ProcessEngineConfigurationImpl)BPMNServerHolder.getInstance().getEngine().getProcessEngineConfiguration()).getCommandExecutor());
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@Override
public List<User> findUserByQueryCriteria(UserQueryImpl query, Page page) {
	return convertToHashedUser(super.findUserByQueryCriteria(query, page));
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
public List<User> findUserByQueryCriteria(final UserQueryImpl query, final Page page) {
    throw new UnsupportedOperationException();
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
public long findUserCountByQueryCriteria(final UserQueryImpl query) {
    throw new UnsupportedOperationException();
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<User> findUserByQueryCriteria(UserQueryImpl query, Page page) {
  return getDbSqlSession().selectList("selectUserByQueryCriteria", query, page);
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public long findUserCountByQueryCriteria(UserQueryImpl query) {
  return (Long) getDbSqlSession().selectOne("selectUserCountByQueryCriteria", query);
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
public UserQuery createNewUserQuery() {
  return new UserQueryImpl(Context.getProcessEngineConfiguration().getCommandExecutor());
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
@Override  
public long findUserCountByQueryCriteria(UserQueryImpl query) {  
    return findUserByQueryCriteria(query, null).size();  
}
 

import org.activiti.engine.impl.UserQueryImpl; //导入依赖的package包/类
List<User> findUserByQueryCriteria(UserQueryImpl query, Page page);