import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
private void setUserProperties(String username, IQ reply, JSONObject requestJSON)
{
    Element childElement = reply.setChildElement("response", "http://igniterealtime.org/protocol/ofmeet");

    try {
        UserManager userManager = XMPPServer.getInstance().getUserManager();
        User user = userManager.getUser(username);

        if (requestJSON != null)
        {
            Iterator<?> keys = requestJSON.keys();

            while( keys.hasNext() )
            {
                String key = (String)keys.next();
                String value = requestJSON.getString(key);

                user.getProperties().put(key, value);
            }
        }

    } catch (Exception e) {
        reply.setError(new PacketError(PacketError.Condition.not_allowed, PacketError.Type.modify, "User " + username + " " + requestJSON.toString() + " " + e));
        return;
    }
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
private User createUser(String userName, String password, String displayName)
                          throws UserAlreadyExistsException {
  if (userName.length() >= 64) {
    throw new IllegalArgumentException("user name too long");
  }

  boolean usePlainPassword = JiveGlobals.getBooleanProperty("user.usePlainPassword");
  if (usePlainPassword && password.length() >= 32) {
    throw new IllegalArgumentException("password too long");
  }

  XMPPServer server = XMPPServer.getInstance();
  User user = server.getUserManager().createUser(userName, password,
      displayName, null);
  return user;
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
IQ handleListUsers(IQ packet, JID from, String appId, String payload)
    throws UnauthorizedException {
  ListOfUserId userIds = GsonData.getGson().fromJson(payload, ListOfUserId.class);
  HashMap<String, UserInfo> map = new HashMap<String, UserInfo>(userIds.size());
  UserManager userManager = XMPPServer.getInstance().getUserManager();
  for (UserId userId : userIds) {
    String uid = userId.getUserId().toLowerCase();
    String userName = JIDUtil.makeNode(uid, appId);
    try {
      User user = userManager.getUser(userName);
      map.put(uid, new UserInfo()
        .setUserId(uid)
        .setDisplayName(user.getName())
        .setEmail(user.getEmail()));
    } catch (UserNotFoundException e) {
      // Ignored.
    }
  }
  IQ response = IQUtils.createResultIQ(packet, GsonData.getGson().toJson(map));
  return response;
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
IQ handleGetUser(IQ packet, JID from, String appId, String payload) 
    throws UnauthorizedException {
  String userName;
  UserId userId = UserId.fromJson(payload);
  if (userId == null || userId.getUserId() == null)
    userName = from.getNode();
  else
    userName = JIDUtil.makeNode(userId.getUserId().toLowerCase(), appId);
  
  try {
    UserManager userManager = XMPPServer.getInstance().getUserManager();
    User user = userManager.getUser(userName);
    UserInfo accountInfo = new UserInfo()
      .setUserId(userId.getUserId())
      .setDisplayName(user.getName())
      .setEmail(user.getEmail());
    IQ response = IQUtils.createResultIQ(packet, accountInfo.toJson());
    return response;
  } catch (UserNotFoundException e) {
    return IQUtils.createErrorIQ(packet,
        UserOperationStatusCode.USER_NOT_FOUND.getMessage(),
        UserOperationStatusCode.USER_NOT_FOUND.getCode());
  }
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
IQ handleGetTags(IQ packet, JID from, String appId, String payload) {
  try {
    User user = UserManager.getInstance().getUser(from.getNode());
    if(user == null) {
      return IQUtils.createErrorIQ(packet, "User does not exist", StatusCode.BAD_REQUEST);
    }
    TagDAO tagDao = DBUtil.getTagDAO();
    List<TagEntity> tagEntities = tagDao.getTagEntitiesForUsername(appId, user.getUsername());
    List<Date> dates = new ArrayList<Date>();
    List<String> tags = new ArrayList<String>();
    for(TagEntity te : tagEntities) {
      tags.add(te.getTagname());
      dates.add(te.getCreationDate());
    }
    Collections.sort(dates);
    UserTags userTags = new UserTags(tags, Utils.isNullOrEmpty(dates) ? null : dates.get(dates.size() - 1));
    return IQUtils.createResultIQ(packet, userTags.toJson());
  } catch (Exception e) {
    LOGGER.error("handleGetTags : caught Exception : {}", e);
    return IQUtils.createErrorIQ(packet, "Unknown Error", StatusCode.BAD_REQUEST);
  }
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
IQ handleSetTags(IQ packet, JID from, String appId, String payload) {
  String username = from.getNode();
  UserTags userTags = UserTags.fromJson(payload);

  try {
    User user = UserManager.getInstance().getUser(username);
    if (user != null) {
      TagDAO tagDao = DBUtil.getTagDAO();
      tagDao.deleteAllTagsForUsername(appId, username);
      if(!Utils.isNullOrEmpty(userTags.getTags())) {
        for (String tag : userTags.getTags()) {
          tagDao.createUsernameTag(tag, appId, username);
        }
      }
    }
  } catch (Exception e) {
    return IQUtils.createErrorIQ(packet, "User does not exist", StatusCode.BAD_REQUEST);
  }
  MMXStatus status = new MMXStatus();
  status.setCode(StatusCode.SUCCESS)
          .setMessage("Success");
  return IQUtils.createResultIQ(packet, status.toJson());
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
IQ handleRemoveTags(IQ packet, JID from, String appId, String payload) {
  String username = from.getNode();
  UserTags userTags = UserTags.fromJson(payload);
  
  try {
    User user = UserManager.getInstance().getUser(username);
    if (user != null && userTags != null) {
      if(!Utils.isNullOrEmpty(userTags.getTags())) {
        TagDAO tagDao = DBUtil.getTagDAO();
        tagDao.deleteTagsForUsername(appId, username, userTags.getTags());
      }
    }
  } catch (Exception e) {
    return IQUtils.createErrorIQ(packet, "User does not exist", StatusCode.BAD_REQUEST);
  }

  MMXStatus status = new MMXStatus();
  status.setCode(StatusCode.SUCCESS)
        .setMessage("Success");
  return IQUtils.createResultIQ(packet, status.toJson());

}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
public static void createUser(String appId, MMXUserInfo userCreationInfo) throws UserAlreadyExistsException, ServerNotInitializedException {
  LOGGER.trace("createUser : appId={}, username={}, password={}, name={}, email={}");
  if(Strings.isNullOrEmpty(userCreationInfo.getUsername()))
    throw new IllegalArgumentException("Illegal username");
  if(Strings.isNullOrEmpty(userCreationInfo.getPassword()))
    throw new IllegalArgumentException("Illegal password");
  User newUser = getUserManager().createUser(userCreationInfo.getMMXUsername(appId), userCreationInfo.getPassword(),
          userCreationInfo.getName(), userCreationInfo.getEmail());
  if(userCreationInfo.getIsAdmin() != null && userCreationInfo.getIsAdmin()) {
    AdminManager adminManager = AdminManager.getInstance();
    if(adminManager == null) {
      throw new ServerNotInitializedException();
    }
    adminManager.addAdminAccount(newUser.getUsername());
  }
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
public static void deleteUser(String appId, MMXUserInfo userInfo) throws UserNotFoundException, ServerNotInitializedException{
  User user = getUserManager().getUser(userInfo.getMMXUsername(appId));
  getUserManager().deleteUser(user);
  try {
    AdminManager adminManager = AdminManager.getInstance();
    if(adminManager != null) {
      adminManager.removeAdminAccount(user.getUsername());
    }
  } catch (Exception e) {
    LOGGER.trace("deleteUser : exception Caught while removing admin account, ignoring exception user={}", user.getUsername());
  }
  /**
   * Need to terminate any open user sessions.
   */
  // Close the user's connection
  terminateSessions(user.getUsername());
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
public static MMXUserInfo getUser(String appId, String username) throws UserNotFoundException{

    String mmxUsername = Helper.getMMXUsername(username, appId);
    MMXUserInfo userInfo = new MMXUserInfo();

    try {
      User user = getUserManager().getUser(mmxUsername);
      userInfo.setUsername(username);
      //userInfo.setAppId(appId);
      userInfo.setEmail(user.getEmail());
      userInfo.setIsAdmin(AdminManager.getInstance().isUserAdmin(username, true));
      userInfo.setName(user.getName());
      return userInfo;
    } catch (Exception e) {
      throw new UserNotFoundException(username + " not found", e);
    }
  }
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
/**
 * Deletes a user from all the groups where he/she belongs. The most probable cause
 * for this request is that the user has been deleted from the system.
 *
 * @param user the deleted user from the system.
 */
public void deleteUser(User user) {
    JID userJID = XMPPServer.getInstance().createJID(user.getUsername(), null);
    for (Group group : getGroups(userJID)) {
        if (group.getAdmins().contains(userJID)) {
            if (group.getAdmins().remove(userJID)) {
                // Remove the group from cache.
                groupCache.remove(group.getName());
            }
        }
        else {
            if (group.getMembers().remove(userJID)) {
                // Remove the group from cache.
                groupCache.remove(group.getName());
            }
        }
    }
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
public void userDeleting(User user, Map<String, Object> params) {
    // Delete this user's association in entityCapabilitiesUserMap.
    JID jid = XMPPServer.getInstance().createJID(user.getUsername(), null, true);
    String verHashOfUser = entityCapabilitiesUserMap.remove(jid);

    // If there are no other references to the deleted user's 'ver' hash,
    // it is safe to remove that 'ver' hash's associated entity
    // capabilities from the entityCapabilitiesMap cache.
    for (String verHash : entityCapabilitiesUserMap.values()) {
        if (verHash.equals(verHashOfUser)) {
            // A different user is making use of the deleted user's same
            // 'ver' hash, so let's not remove the associated entity
            // capabilities from the entityCapabilitiesMap.
            return;
        }
    }
    entityCapabilitiesMap.remove(verHashOfUser);
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
@Override
public Collection<User> findUsers(Set<String> fields, String query, int startIndex, int numResults) throws UnsupportedOperationException {
    lock.readLock().lock();
    try {
        ArrayList<User> foundUsers = (ArrayList<User>) findUsers(fields, query);
        
        Collection<User> results = new ArrayList<>(foundUsers.size());
        
        for (int i = 0, j = startIndex; i < numResults && j < foundUsers.size(); ++i, ++j) {
            results.add(foundUsers.get(j));
        }
        
        return results;
        
    } finally {
        lock.readLock().unlock();
    }
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
@Override
public void userDeleting(User user, Map<String, Object> params) {
    // Delete this user's association in entityCapabilitiesUserMap.
    JID jid = XMPPServer.getInstance().createJID(user.getUsername(), null, true);
    String verHashOfUser = entityCapabilitiesUserMap.remove(jid);

    // If there are no other references to the deleted user's 'ver' hash,
    // it is safe to remove that 'ver' hash's associated entity
    // capabilities from the entityCapabilitiesMap cache.
    for (String verHash : entityCapabilitiesUserMap.values()) {
        if (verHash.equals(verHashOfUser)) {
            // A different user is making use of the deleted user's same
            // 'ver' hash, so let's not remove the associated entity
            // capabilities from the entityCapabilitiesMap.
            return;
        }
    }
    entityCapabilitiesMap.remove(verHashOfUser);
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
@Override
public Presence getPresence(User user) {
    if (user == null) {
        return null;
    }
    Presence presence = null;

    for (ClientSession session : sessionManager.getSessions(user.getUsername())) {
        if (presence == null) {
            presence = session.getPresence();
        }
        else {
            // Get the ordinals of the presences to compare. If no ordinal is available then
            // assume a value of -1
            int o1 = presence.getShow() != null ? presence.getShow().ordinal() : -1;
            int o2 = session.getPresence().getShow() != null ?
                    session.getPresence().getShow().ordinal() : -1;
            // Compare the presences' show ordinals
            if (o1 > o2) {
                presence = session.getPresence();
            }
        }
    }
    return presence;
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
@Override
public long getLastActivity(User user) {
    String username = user.getUsername();
    long lastActivity = NULL_LONG;
    Long offlineDate = lastActivityCache.get(username);
    if (offlineDate == null) {
        loadOfflinePresence(username);
    }
    offlineDate = lastActivityCache.get(username);
    if (offlineDate != null) {
        // If the cached answer is no data, return -1.
        if (offlineDate == NULL_LONG) {
            return NULL_LONG;
        }
        else {
            try {
                lastActivity = (System.currentTimeMillis() - offlineDate);
            }
            catch (NumberFormatException e) {
                Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
            }
        }
    }
    return lastActivity;
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
public int getPageProperty(String pageName, String property, int defaultValue) {
    User user = getUser();
    if (user != null) {
        String values = user.getProperties().get(property);
        if (values != null) {
            StringTokenizer tokens = new StringTokenizer(values, ",=");
            while (tokens.hasMoreTokens()) {
                String page = tokens.nextToken().trim();
                String rows = tokens.nextToken().trim();
                if  (pageName.equals(page)) {
                    try {
                        return Integer.parseInt(rows);
                    }
                    catch (NumberFormatException e) {
                        return defaultValue;
                    }
                }
            }
        }
    }
    return defaultValue;
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
/**
 * Stores a list of users as having access to the transport in question.
 *
 * @param users list of users who should have access.
 */
public void storeUserList(ArrayList<User> users) {
    Connection con = null;
    PreparedStatement pstmt = null;
    try {
        con = DbConnectionManager.getConnection();
        pstmt = con.prepareStatement(DELETE_ALL_USERS);
        pstmt.setString(1, transportType.toString());
        pstmt.executeUpdate();
        pstmt.close();

        pstmt = con.prepareStatement(ADD_NEW_USER);
        pstmt.setString(1, transportType.toString());
        for (User user : users) {
            pstmt.setString(2, user.getUsername());
            pstmt.executeUpdate();
        }
        pstmt.close();
    }
    catch (SQLException sqle) {
        Log.error(sqle);
    }
    finally {
        DbConnectionManager.closeConnection(pstmt, con);
    }
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
public Presence getPresence(User user) {
    if (user == null) {
        return null;
    }
    Presence presence = null;

    for (ClientSession session : sessionManager.getSessions(user.getUsername())) {
        if (presence == null) {
            presence = session.getPresence();
        }
        else {
            // Get the ordinals of the presences to compare. If no ordinal is available then
            // assume a value of -1
            int o1 = presence.getShow() != null ? presence.getShow().ordinal() : -1;
            int o2 = session.getPresence().getShow() != null ?
                    session.getPresence().getShow().ordinal() : -1;
            // Compare the presences' show ordinals
            if (o1 > o2) {
                presence = session.getPresence();
            }
        }
    }
    return presence;
}
 

import org.jivesoftware.openfire.user.User; //导入依赖的package包/类
public void userCreated(User user, Map<String, Object> params) {
    if (imNotificationEnabled()) {
        sendIMNotificatonMessage(user);
    }
    
    if (emailNotificationEnabled()) {
        sendAlertEmail(user);
    }
    
    if (welcomeEnabled()) {
        sendWelcomeMessage(user);
    }
    
    if (groupEnabled()) {
        addUserToGroup(user);
    }
}