使用具有自定义条件的java8流从另一个对象创建对象列表

Question

我有一个要求，我需要根据2个条件从另一个列表中创建一个对象列表。对象应处于会话中或处于活动状态。[这个问题与使用java8流从另一个对象创建对象列表有着模糊的联系

class Person
{
    private String firstName;
    private String lastName;
    private String personId;
    //Getters and Setters
}

class UserInfo
{
    private String uFirstName;
    private String uLastName;
    private String userId;
    //Constructor, Getters and Setters
}

主要类别：

Boolean isActiveUser = ..... [getting from upstream systems]
HttpSession session = request.session();
List<String> sessionUserIds = session.getAttribute("users");

List<Person> personList = criteria.list(); //Get list from db.

//CURRENT COCDE
List<UserInfo> userList = new ArrayList<>();
for(Person person: personList) {
   UserInfo userInfo = new UserInfo(person);
   if(sessionUserIds.contains(person.getPersonId())){
       userInfo.setLoginTime("");  //Get LoginTime from upstream
       userInfo.setIdleTime("");   // Get IdleTime from Upstream
       userList.add(userInfo);
   } else {
       if(isActiveUser) {
            userList.add(userInfo);
       }
   }
}

 // Trying to GET IT converted to JAVA-8

 List<UserInfo> userList = personList.stream()
                   .filter(p ->  ??)
                   .map( ??
                   .collect(Collectors.toList());

任何帮助都将不胜感激。

Answer 1

不是一个很好的主意，但只是一个尝试。

如果人成为userId，那么你可以尝试如下：

List<UserInfo> userList = new ArrayList<>();

personList.stream()
          .map(p -> new UserInfo(person)) // person becomes user here
          .forEach(u -> {

                if(sessionUserIds.contains(u.getUserId())){
                   userInfo.setLoginTime("");
                   userInfo.setIdleTime("");
                   userList.add(userInfo);
                } else if(isActiveUser) {
                    userList.add(userInfo);
                }
          }
      });

Answer 2

您可以创建流，然后检查用户是否处于活动状态或在会话中，然后如果用户在会话中，则使用setter并最终收集。

List<UserInfo> userList = personList.stream()
        .map(UserInfo::new)
        .filter(userInfo -> isUserActive || sessionUserIds.contains(userInfo.getUserId()))
        .map(userInfo -> {
            if(sessionUserIds.contains(userInfo.getUserId())) {
                userInfo.setLoginTime("");
                userInfo.setIdleTime("");
            }
            return userInfo;
        })
        .collect(Collectors.toList());

或者如果您不介意在过滤器中使用setter。

List<UserInfo> userList = personList.stream()
        .map(UserInfo::new)
        .filter(userInfo -> {
            if (sessionUserIds.contains(userInfo.getUserId())) {
                userInfo.setLoginTime("");
                userInfo.setIdleTime("");
                return true;
            }
            return isUserActive;
        })
        .collect(Collectors.toList());

Answer 3

是否要调整会话用户id列表中所有用户的数据，但不调整其他用户的数据？也许以下内容对您来说是可以的（假设，正如您在其他地方所说的那样，getPersonId（）返回的值与getUserId（）相同）：

List<UserInfo> userList;
userList = personList.stream()
                       .filter(p -> isActiveUser || sessionUserIds.contains(p.getPersonId()))
                       .map(UserInfo::new)
                       .collect(Collectors.toList());
userList.stream()
        .filter(u -> sessionUserIds.contains(u.getUserId())
        .forEach(u -> {
          u.setLoginTime(""); // Get LoginTime from upstream
          u.setIdleTime(""); // Get IdleTime from Upstream
        });

请务必阅读foreachjavadoc。

或者仅使用一个流：

List<UserInfo> userList;
userList = personList.stream()
                     .filter(p -> isActiveUser || sessionUserIds.contains(p.getPersonId()))
                     .map(p -> {
                        UserInfo u = new UserInfo(p);
                        if (sessionUserIds.contains(u.getUserId())) {
                          u.setLoginTime(""); // Get LoginTime from upstream
                          u.setIdleTime(""); // Get IdleTime from Upstream
                        }
                        return u;
                      })
                     .collect(Collectors.toList());

我建议在映射之前进行过滤。对我来说，它更具可读性。这绝对不是每个人都这样。在精神上调试代码时，至少我可以过滤掉一些已经存在的元素，集中精力处理在进一步处理中重要的事情。