Spring Boot点餐系统实战(7)–买家订单service层(上)

avatar 2017年11月14日17:49:47 8 6363 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
本文介绍买家下单的service层的创建，并实现创建订单的方法。


本文关键词


DTO

@Transactional 注解

@Transient  注解

扣库存

随机数主键

异常


一、开发准备


1、数据库效果

order_master 表



order_detail 表





2、最终文件结构




二、创建 DTO


DTO 全称数据传输对象，用于各个层的交互。而我们的 Entity 用于和数据库对接。

1、OrderDTO.java
  1. package com.liuyanzhao.sell.dto;
  3. import com.liuyanzhao.sell.entity.OrderDetail;
  4. import lombok.Data;
  6. import java.math.BigDecimal;
  7. import java.util.Date;
  8. import java.util.List;
  10. /**
  11.  * 订单
  12.  * @Author: 言曌
  13.  * @Date: 2017/11/13
  14.  * @Time: 上午11:23
  15.  */
  17. @Data
  18. public class OrderDTO {
  20.     //订单编号
  21.     private String orderId;
  23.     //买家名字
  24.     private String buyerName;
  26.     //买家电话
  27.     private String buyerPhone;
  29.     //买家地址
  30.     private String buyerAddress;
  32.     //买家微信Openid
  33.     private String buyerOpenid;
  35.     //订单总金额
  36.     private BigDecimal orderAmount;
  38.     //订单状态，默认为0新订单
  39.     private Integer orderStatus;
  41.     //支付状态，默认为0未支付
  42.     private Integer payStatus;
  44.     //订单创建时间
  45.     private Date createTime;
  47.     //订单更新时间
  48.     private Date updateTime;
  50.     private List<OrderDetail> orderDetailList;
  52. }

注意：第 50 行的 private List<OrderDetail> orderDetailList;  表示订单详情列表，因为一个订单通常可能会有多个东西(订单详情)。

如果我们不使用 DTO，直接在 Entity 里加这一句在 OrderMaster.java 中，导致数据库里没有这个字段会报错，需要加一个注解  @Transient ，让 orderDetailList 不被序列化。

但是，为了管理方便，数据交互我们统一使用 DTO，而不用 Entity。只需要复制 Entity 里的内容到 DTO 中，然后添加我们需要的变量即可。



2、CartDTO.java
  1. package com.liuyanzhao.sell.dto;
  3. import lombok.Data;
  5. /**
  6.  * 购物车
  7.  * @Author: 言曌
  8.  * @Date: 2017/11/14
  9.  * @Time: 下午4:00
  10.  */
  12. @Data
  13. public class CartDTO {
  15.     //商品id
  16.     private String productId;
  18.     //数量
  19.     private Integer productQuantity;
  21.     public CartDTO(String productId, Integer productQuantity) {
  22.         this.productId = productId;
  23.         this.productQuantity = productQuantity;
  24.     }
  25. }

购物车里只需要存储两个主要信息，即商品变量和购买数量。


三、Service 创建


1、OrderService.java
  1. package com.liuyanzhao.sell.service;
  3. import com.liuyanzhao.sell.dto.OrderDTO;
  4. import org.springframework.data.domain.Page;
  5. import org.springframework.data.domain.Pageable;
  7. /**
  8.  * @Author: 言曌
  9.  * @Date: 2017/11/13
  10.  * @Time: 上午11:17
  11.  */
  13. public interface OrderService {
  15.     //创建订单
  16.     OrderDTO create(OrderDTO orderDTO);
  18.     //查询单个订单
  19.     OrderDTO findOne();
  21.     //查询订单列表
  22.     Page<OrderDTO> findList(String buyerOpenid, Pageable pageable);
  24.     //取消订单
  25.     OrderDTO cancel(OrderDTO orderDTO);
  27.     //完结订单
  28.     OrderDTO finish(OrderDTO orderDTO);
  30.     //支付订单
  31.     OrderDTO paid(OrderDTO orderDTO);
  33. }

2、OrderServiceImpl.java
  1. package com.liuyanzhao.sell.service.impl;
  3. import com.liuyanzhao.sell.dao.OrderDetailDao;
  4. import com.liuyanzhao.sell.dao.OrderMasterDao;
  5. import com.liuyanzhao.sell.dto.CartDTO;
  6. import com.liuyanzhao.sell.dto.OrderDTO;
  7. import com.liuyanzhao.sell.entity.OrderDetail;
  8. import com.liuyanzhao.sell.entity.OrderMaster;
  9. import com.liuyanzhao.sell.entity.ProductInfo;
  10. import com.liuyanzhao.sell.enums.OrderStatusEnum;
  11. import com.liuyanzhao.sell.enums.PayStatusEnum;
  12. import com.liuyanzhao.sell.enums.ResultEnum;
  13. import com.liuyanzhao.sell.exception.SellException;
  14. import com.liuyanzhao.sell.service.OrderService;
  15. import com.liuyanzhao.sell.service.ProductService;
  16. import com.liuyanzhao.sell.utils.KeyUtil;
  17. import org.springframework.beans.BeanUtils;
  18. import org.springframework.beans.factory.annotation.Autowired;
  19. import org.springframework.data.domain.Page;
  20. import org.springframework.data.domain.Pageable;
  21. import org.springframework.stereotype.Service;
  22. import org.springframework.transaction.annotation.Transactional;
  24. import java.math.BigDecimal;
  25. import java.math.BigInteger;
  26. import java.util.ArrayList;
  27. import java.util.List;
  28. import java.util.stream.Collectors;
  30. /**
  31.  * @Author: 言曌
  32.  * @Date: 2017/11/13
  33.  * @Time: 上午11:29
  34.  */
  36. @Service
  37. public class OrderServiceImpl implements OrderService{
  40.     @Autowired
  41.     private ProductService productService;
  43.     @Autowired
  44.     private OrderDetailDao orderDetailDao;
  46.     @Autowired
  47.     private OrderMasterDao orderMasterDao;
  49.     @Override
  50.     @Transactional //事务管理
  51.     public OrderDTO create(OrderDTO orderDTO) {
  53.         String orderId = KeyUtil.genUniqueKey();
  54.         BigDecimal orderAmount = new BigDecimal(BigInteger.ZERO );
  56.         //1、查询商品（数量，价格）
  57.         List<OrderDetail> orderDetailList = new ArrayList<>();
  58.         for(OrderDetail orderDetail:orderDTO.getOrderDetailList()) {
  59.             ProductInfo productInfo = productService.findOne(orderDetail.getProductId());
  60.             if(productInfo == null) {
  61.                 throw new SellException(ResultEnum.PRODUCT_NOT_EXISTS);
  62.             }
  64.             //2、计算订单总价
  65.             orderAmount = productInfo.getProductPrice()
  66.                     .multiply(new BigDecimal(orderDetail.getProductQuantity()))
  67.                     .add(orderAmount);
  69.             //订单详情入库
  70.             orderDetail.setDetailId(KeyUtil.genUniqueKey());
  71.             orderDetail.setOrderId(orderId);
  72.             BeanUtils.copyProperties(productInfo,orderDetail);
  73.             orderDetailDao.save(orderDetail);
  75.         }
  78.         //3、写入订单数据库(orderMaster和orderDetail)
  79.         OrderMaster orderMaster = new OrderMaster();
  80.         BeanUtils.copyProperties(orderDTO,orderMaster);
  81.         orderMaster.setOrderId(orderId);
  82.         orderMaster.setOrderAmount(orderAmount);
  83.         orderMaster.setOrderStatus(OrderStatusEnum.NEW.getCode());
  84.         orderMaster.setPayStatus(PayStatusEnum.WAIT.getCode());
  85.         orderMasterDao.save(orderMaster);
  87.         //4、扣库存
  88.         List<CartDTO> cartDTOList = new ArrayList<>();
  89.         orderDTO.getOrderDetailList().stream().map(e->
  90.             new CartDTO(e.getProductId(),e.getProductQuantity())
  91.         ).collect(Collectors.toList());
  92.         productService.decreaseStock(cartDTOList);
  94.         return orderDTO;
  95.     }
  97.     @Override
  98.     public OrderDTO findOne() {
  99.         return null;
  100.     }
  102.     @Override
  103.     public Page<OrderDTO> findList(String buyerOpenid, Pageable pageable) {
  104.         return null;
  105.     }
  107.     @Override
  108.     public OrderDTO cancel(OrderDTO orderDTO) {
  109.         return null;
  110.     }
  112.     @Override
  113.     public OrderDTO finish(OrderDTO orderDTO) {
  114.         return null;
  115.     }
  117.     @Override
  118.     public OrderDTO paid(OrderDTO orderDTO) {
  119.         return null;
  120.     }
  121. }



注意：

① 第 50 行的 @Transactional  注解表示该方法需要事务管理，防止突然出现异常(机器坏了，停电了，断网啦啥的)，这个 create() 方法执行一半，导致数据不全，从而出错。我们希望的是要么全部成功，要么全部失败。

② 第 51 行，我们使用 OrderDTO 类来储存订单信息，而不使用 OrderMaster 类。

③ 第 53 行的 KeyUtil.genUniqueKey() 还没有建立，用于生成 随机主键(当前时间毫秒数+六位随机整数)

④ 商品的价格一定要从数据库里查询，不能通过前台传过来

⑤ 一定要判断库存是否充足，不足抛异常

⑥ 第 61 行的抛出异常，该异常下文会写，枚举也是

⑦ 89-91 行是 lambda 表达式


四、新建异常

  1. package com.liuyanzhao.sell.exception;
  3. import com.liuyanzhao.sell.enums.ResultEnum;
  5. /**
  6.  * @Author: 言曌
  7.  * @Date: 2017/11/13
  8.  * @Time: 下午12:04
  9.  */
  11. public class SellException extends RuntimeException {
  13.     private Integer code;
  15.     public SellException(ResultEnum resultEnum) {
  16.         super(resultEnum.getMessage());
  18.         this.code = resultEnum.getCode();
  19.     }
  20. }

枚举信息从下文中定义


五、新建异常信息的枚举


ResultEnum.java
  1. package com.liuyanzhao.sell.enums;
  3. import lombok.Getter;
  5. /**
  6.  * 返回给前端提示
  7.  * @Author: 言曌
  8.  * @Date: 2017/11/13
  9.  * @Time: 下午12:05
  10.  */
  12. @Getter
  13. public enum ResultEnum {
  15.     PRODUCT_NOT_EXISTS(10,"商品不存在"),
  16.     PRODUCT_STOCK_ERROR(11, "库存不正确"),
  18.     ;
  20.     private Integer code;
  22.     private String message;
  24.     ResultEnum(Integer code, String message) {
  25.         this.code = code;
  26.         this.message = message;
  27.     }
  29. }


六、新建 生成唯一索引的方法


KeyUtil.java
  1. package com.liuyanzhao.sell.utils;
  3. import java.util.Random;
  5. /**
  6.  * 数据库索引，约束
  7.  * @Author: 言曌
  8.  * @Date: 2017/11/13
  9.  * @Time: 下午12:28
  10.  */
  12. public class KeyUtil {
  15.     /**
  16.      * 生成唯一主键
  17.      * 格式：时间+六位随机数
  18.      * @return
  19.      */
  20.     public static synchronized String genUniqueKey() {
  21.         Random random = new Random();
  22.         Integer number = random.nextInt(900000)+100000;//生成六位随机数
  24.         return System.currentTimeMillis() + String.valueOf(number);
  25.     }
  27. }

注意：防止多线程异步导致订单号重复。

其实如果用户数量非常多，比如上亿级的，1ms 内还是可能会出现相同的随机数的，也就是订单号相同。这个时候我们可以再在订单号上加一个用户id。


六、新建测试类


我们目前只写了 create() 方法，下一节会继续写。

先把创建订单的方法测试下再说

OrderServiceImplTest.java
  1. package com.liuyanzhao.sell.service.impl;
  3. import com.liuyanzhao.sell.dto.OrderDTO;
  4. import com.liuyanzhao.sell.entity.OrderDetail;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.junit.Test;
  7. import org.junit.runner.RunWith;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.boot.test.context.SpringBootTest;
  10. import org.springframework.test.context.junit4.SpringRunner;
  12. import java.util.ArrayList;
  13. import java.util.List;
  16. /**
  17.  * @Author: 言曌
  18.  * @Date: 2017/11/14
  19.  * @Time: 下午4:26
  20.  */
  21. @Slf4j
  22. @RunWith(SpringRunner.class)
  23. @SpringBootTest
  24. public class OrderServiceImplTest {
  26.     @Autowired
  27.     private OrderServiceImpl orderService;
  29.     private final String BUYER_OPENID = "111111";
  30.     @Test
  31.     public void create() throws Exception {
  33.         OrderDTO orderDTO = new OrderDTO();
  34.         orderDTO.setBuyerAddress("地球村");
  35.         orderDTO.setBuyerName("千小寻");
  36.         orderDTO.setBuyerPhone("12345678912");
  37.         orderDTO.setBuyerOpenid(BUYER_OPENID);
  39.         //购物车
  40.         List<OrderDetail> orderDetailList = new ArrayList<>();
  42.         OrderDetail orderDetail = new OrderDetail();
  43.         orderDetail.setProductId("123456");
  44.         orderDetail.setProductQuantity(1);
  45.         orderDetailList.add(orderDetail);
  47.         OrderDetail orderDetail2 = new OrderDetail();
  48.         orderDetail2.setProductId("123458");
  49.         orderDetail2.setProductQuantity(2);
  50.         orderDetailList.add(orderDetail2);
  52.         OrderDetail orderDetail3 = new OrderDetail();
  53.         orderDetail3.setProductId("123459");
  54.         orderDetail3.setProductQuantity(3);
  55.         orderDetailList.add(orderDetail3);
  57.         orderDTO.setOrderDetailList(orderDetailList);
  59.         OrderDTO result = orderService.create(orderDTO);
  60.         log.info("【创建订单】result={}",result);
  62.     }
  64.     @Test
  65.     public void findOne() throws Exception {
  66.     }
  69.     @Test
  70.     public void findList() throws Exception {
  71.     }
  73.     @Test
  74.     public void cancel() throws Exception {
  75.     }
  77.     @Test
  78.     public void finish() throws Exception {
  79.     }
  81.     @Test
  82.     public void paid() throws Exception {
  83.     }
  86. }

我们这个测试中，一个订单中有三种详情订单，第 21 行和第 61 行是日志相关内容



最终我们运行 Tomcat，查看数据库，可以查看到 OrderMaster 有一条记录，OrderDetail 一条记录。

即上面基本准备中的效果



本文地址：https://liuyanzhao.com/6720.html
历史上的今天
November
14日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：1   待审核评论数：0
  1. avatar sss
    回复 2017年11月20日 19:44:59

    for (OrderDetail orderDetail : orderDTO.getOrderDetailList()) { ProductInfo productInfo = productService.findOne(orderDetail.getProductId()); if (productInfo == null) { throw new SellException(ResultEnum.PRODUCT_NOT_EXI); } //2. 计算订单总价 orderAmount = productInfo.getProductPrice() .multiply(new BigDecimal(orderDetail.getProductQuantity())) .add(orderAmount); orderDetail.setDetailId(KeyUtil.genUniqueKey()); orderDetail.setOrderId(orderId); BeanUtils.copyProperties(productInfo, orderDetail); orderDetailRepository.save(orderDetail); } 老哥抄来这段代码就没有疑问吗