用java的stream流库在实际项目的使用案例

由于自己用stream+lambda很不熟悉，用文章记录在一个电商项目中的用法
购物车模块：

     //获取购物车，校验（是否有商品、库存）List<Cart> cartList = cartService.listForCart(uid).stream().filter(Cart::getProductSelected).collect(Collectors.toList());

订单模块：

//获取cartList里的productIdsSet<Integer> productIdSet = cartList.stream().map(Cart::getProductId).collect(Collectors.toSet());List<Product> productList = productMapper.selectByProductIdSet(productIdSet);Map<Integer, Product> map  = productList.stream().collect(Collectors.toMap(Product::getId, product -> product));List<OrderItem> orderItemList = new ArrayList<>();Long orderNo = generateOrderNo();for (Cart cart : cartList) {//根据productId查数据库Product product = map.get(cart.getProductId());//是否有商品if (product == null) {return ResponseVo.error(ResponseEnum.PRODUCT_NOT_EXIST,"商品不存在. productId = " + cart.getProductId());}//商品上下架状态if (!ProductStatusEnum.ON_SALE.getCode().equals(product.getStatus())) {return ResponseVo.error(ResponseEnum.PRODUCT_OFF_SALE_OR_DELETE,"商品不是在售状态. " + product.getName());}}

返回订单视图

 private OrderVo buildOrderVo(Order order, List<OrderItem> orderItemList, Shipping shipping) {OrderVo orderVo = new OrderVo();BeanUtils.copyProperties(order, orderVo);List<OrderItemVo> OrderItemVoList = orderItemList.stream().map(e -> {OrderItemVo orderItemVo = new OrderItemVo();BeanUtils.copyProperties(e, orderItemVo);return orderItemVo;}).collect(Collectors.toList());orderVo.setOrderItemVoList(OrderItemVoList);if (shipping != null) {orderVo.setShippingId(shipping.getId());orderVo.setShippingVo(shipping);}return orderVo;}

创建订单

private Order buildOrder(Integer uid,Long orderNo,Integer shippingId,List<OrderItem> orderItemList) {BigDecimal payment = orderItemList.stream().map(OrderItem::getTotalPrice).reduce(BigDecimal.ZERO, BigDecimal::add);Order order = new Order();order.setOrderNo(orderNo);order.setUserId(uid);order.setShippingId(shippingId);order.setPayment(payment);order.setPaymentType(PaymentTypeEnum.PAY_ONLINE.getCode());order.setPostage(0);order.setStatus(OrderStatusEnum.NO_PAY.getCode());return order;}

获取订单列表

 @Overridepublic ResponseVo<PageInfo> list(Integer uid, Integer pageNum, Integer pageSize) {PageHelper.startPage(pageNum, pageSize);List<Order> orderList = orderMapper.selectByUid(uid);Set<Long> orderNoSet = orderList.stream().map(Order::getOrderNo).collect(Collectors.toSet());List<OrderItem> orderItemList = orderItemMapper.selectByOrderNoSet(orderNoSet);Map<Long, List<OrderItem>> orderItemMap = orderItemList.stream().collect(Collectors.groupingBy(OrderItem::getOrderNo));Set<Integer> shippingIdSet = orderList.stream().map(Order::getShippingId).collect(Collectors.toSet());List<Shipping> shippingList = shippingMapper.selectByIdSet(shippingIdSet);Map<Integer, Shipping> shippingMap = shippingList.stream().collect(Collectors.toMap(Shipping::getId, shipping -> shipping));List<OrderVo> orderVoList = new ArrayList<>();for (Order order : orderList) {OrderVo orderVo = buildOrderVo(order,orderItemMap.get(order.getOrderNo()),shippingMap.get(order.getShippingId()));orderVoList.add(orderVo);}PageInfo pageInfo = new PageInfo<>(orderList);pageInfo.setList(orderVoList);return ResponseVo.success(pageInfo);}

关于Collectors.groupingBy：根据一个或多个属性对集合中的项目进行分组，返回一个map:

Map<Integer, List<Integer>> mapGroupBy = Stream.of(1, 2, 3, 4, 5, 4, 3).collect(Collectors.groupingBy(x -> x * 10));
System.out.println(mapGroupBy); // {50=[5], 20=[2], 40=[4, 4], 10=[1], 30=[3, 3]}
for(Map.Entry entry:mapGroupBy.entrySet())
{System.out.print(entry.getKey()+":");System.out.println(String.valueOf(entry.getValue()));
}

用java的stream流库在实际项目的使用案例相关推荐

Java 8 - Stream流骚操作解读2_归约操作
文章目录 Pre 什么是归约操作元素求和 reduce reduce如何运行的最大值和最小值 Pre Java 8 - Stream流骚操作解读见到过的终端操作都是返回一个 boolean ( a ...
Java 8 Stream 流用法及语法
Java 8 Stream 流用法 1.简介 Stream流最全的用法 Stream 能用来干什么?用来处理集合,通过使用Stream API 对集合数据进行操作,就类似于使用 SQL 执行的数据 ...
函数式编程（JAVA）——Stream流
函数式编程(JAVA)--Stream流概述 Java8的Stream使用的是函数式编程模式,如同它的名字一样,它可以被用来对集合或数组进行链状流式的操作.可以更方便的让我们对集合或数组操作. 下述 ...
Java 8 Stream流的用法
Java 8 Stream流什么是 Stream? Stream(流)是一个来自数据源的元素队列并支持聚合操作元素是特定类型的对象,形成一个队列. Java中的Stream并不会存储元素,而是按需 ...
对比Java的Stream流和C# 的Linq
Java由于没有委托的概念,所以用函数式接口 @FunctionalInterface 与 lambda表达式相结合,实现了类似于C# 中委托,C++中函数指针的功能. 函数指针/委托在Java中被命 ...
Java 8 - Stream流骚操作解读
文章目录分类中间操作终端操作使用Stream流筛选和切片用谓词筛选 filter 筛选各异的元素 distinct 截短流 limit 跳过元素 skip 映射对流中每一个元素应用函数 ...
【java学习笔记】java se8的流库概念以及使用
概念代码实例流的创建惰性求值与及早求值概念流提供了一种让我们可以在比集合更高的概念级别上指定计算的数据视图.通过使用流,我们可以说明想要完成什么任务,而不是说明如何去实现它.我们将操作的调度 ...
JAVA的stream流操作详细解析
java的stram流操作为什么需要 Stream 流与集合的区别对比:原始集合操作与Stream集合操作 (过滤/映射/扁平化/遍历/排序/去重/跳过/截断的应用) 流的组成流操作的分类流的 ...
[Java基础]Stream流的收集操作
代码如下: package CollectPack;import java.util.*; import java.util.stream.Collectors; import java.util.s ...

用java的stream流库在实际项目的使用案例

用java的stream流库在实际项目的使用案例相关推荐

最新文章

热门文章