消息管理

bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/basic/service/impl/BmMessageServiceImpl.java

@@ -68,24 +68,17 @@ public class BmMessageServiceImpl implements IBmMessageService {
             list.addAll(arrayCache.toList(BmMessage.class));
         });
         List<BmMessage> result = list.stream().filter(o -> companyId.equals(o.getFromCompany()) || companyId.equals(o.getToCompany())).collect(Collectors.toList());
-        Map<Long, BmMessage> groupedMessages1 = result.stream()
-                .collect(Collectors.toMap(
-                        BmMessage::getFromCompany,
-                        Function.identity(),
-                        (existing, replacement) -> existing
-                ));
-        Map<Long, BmMessage> groupedMessages2 = result.stream()
-                .collect(Collectors.toMap(
-                        BmMessage::getToCompany,
-                        Function.identity(),
-                        (existing, replacement) -> existing
-                ));
-        List<BmMessage> messages1 = new ArrayList<>(groupedMessages1.values());
-        List<BmMessage> messages2 = new ArrayList<>(groupedMessages2.values());
-        List<BmMessage> messages3 = new ArrayList<>();
-        messages3.addAll(messages1);
-        messages3.addAll(messages2);
-        return messages3;
+//        Optional<BmMessage> result2 = result.stream().min(Comparator.comparing(BmMessage::getCreateTime).reversed());
+//        if (result2.isPresent()) {
+//            BmMessage message = result2.get();
+//            // 现在你可以使用message对象
+//            // 如果你真的需要一个List，尽管这里只有一个元素，你可以这样做：
+//            List<BmMessage> singleElementList = Collections.singletonList(message);
+//            return singleElementList;
+//        }else {
+//            return new ArrayList<>();
+//        }
+        return result;
     }
 
     public List<BmMessage> selectBmMessageListFromCacheOne(BmMessage bmMessage) {