ISDP010_基于DDD架构实现收银用例主乐成场景

梦见你的名字  金牌会员 | 2024-12-28 00:17:56 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 759|帖子 759|积分 2277

信息体系开发实践 ｜ 系列文章传送门
ISDP001_课程概述
ISDP002_Maven上_创建Maven项目
ISDP003_Maven下_Maven项目依靠设置
ISDP004_创建SpringBoot3项目
ISDP005_Spring组件与自动装配
ISDP006_逻辑架构设计
ISDP007_Springboot日志设置与单元测试
ISDP008_SpringBoot Controller接口文档与测试
ISDP009_基于DDD架构设计ISDP的处理销售用例
ISDP010_基于DDD架构实现收银用例主乐成场景
1 面向DDD重构mis-pos模块

重要阐明：由于代码量增加，且常常需要重构。条记将难以展示项目完整代码。本章条记开始只展示部分代码。完整代码详见条记最后项目堆栈分支代码。
参考上篇分析与设计制品，参考DDD架构，重构的mis-pos模块的架构分层。
根据DDD架构分为application、domain、infrastructure三个包。

2 底子办法层

底子办法层暂时还没有写太多的类。只是添加了SaleFactory用于实例化Sale。
引入Hutool工具类，用于天生订单的雪花ID。
  1.         <dependency>
  2.             <groupId>cn.hutool</groupId>
  3.             <artifactId>hutool-all</artifactId>
  4.             <version>5.8.20</version>
  5.         </dependency>
复制代码
编写SaleFactory，实例化Sale并设置初始化值。
  1. package edu.scau.mis.pos.infrastructure.factory;
  3. import cn.hutool.core.util.IdUtil;
  4. import edu.scau.mis.pos.domain.entity.Sale;
  5. import edu.scau.mis.pos.domain.enums.SaleStatusEnum;
  6. import org.springframework.stereotype.Component;
  8. import java.math.BigDecimal;
  9. import java.util.Date;
  11. /**
  12. * Sale工厂类
  13. */
  14. @Component
  15. public class SaleFactory {
  16.     public Sale initSale()
  17.     {
  18.         Sale sale = new Sale();
  19.         sale.setSaleNo("so-" + IdUtil.getSnowflakeNextId());
  20.         sale.setSaleStatus(SaleStatusEnum.CREATED);
  21.         sale.setTotalAmount(BigDecimal.ZERO);
  22.         sale.setTotalQuantity(0);
  23.         sale.setSaleTime(new Date());
  24.         return sale;
  25.     }
  27. }
复制代码
3 领域层

在DDD架构中，领域层是重点关注层。
为了简化Setter和getter编写，引入了Lombok。
  1.         <dependency>
  2.             <groupId>org.projectlombok</groupId>
  3.             <artifactId>lombok</artifactId>
  4.         </dependency>
复制代码
3.1 SaleProduct实体类

SaleProduct实体类包含了业务逻辑方法getSubTotal，计算每个订单明细的小计。
  1. package edu.scau.mis.pos.domain.entity;
  3. import edu.scau.mis.pos.domain.enums.SaleProductStatusEnum;
  4. import lombok.Data;
  6. import java.math.BigDecimal;
  8. /**
  9. * 订单-产品明细实体类
  10. */
  11. @Data
  12. public class SaleProduct {
  13.     private Long saleProductId;
  15.     private Long saleId;
  17.     private Long productId;
  19.     private Product product;
  21.     private Integer saleQuantity;
  23.     private BigDecimal salePrice;
  25.     private SaleProductStatusEnum saleProductStatus;
  27.     /**
  28.      * 计算小计
  29.      * @return
  30.      */
  31.     public BigDecimal getSubTotal() {
  32.         return salePrice.multiply(new BigDecimal(saleQuantity));
  33.     }
  34. }
复制代码
3.2 付出实体类

付出类暂时还没有写业务逻辑方法。后期思量通过适配器，毗连第三方付出。
  1. package edu.scau.mis.pos.domain.entity;
  3. import com.fasterxml.jackson.annotation.JsonFormat;
  4. import edu.scau.mis.pos.domain.enums.PaymentStatusEnum;
  5. import edu.scau.mis.pos.domain.enums.PaymentStrategyEnum;
  6. import lombok.Data;
  8. import java.math.BigDecimal;
  9. import java.util.Date;
  11. /**
  12. * 支付实体类
  13. */
  14. @Data
  15. public class Payment {
  16.     private Long paymentId;
  17.     private Long paymentSaleId;
  18.     private PaymentStrategyEnum paymentStrategy;
  19.     private String paymentNo;
  20.     private BigDecimal paymentAmount;
  21.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  22.     private Date paymentTime;
  23.     private PaymentStatusEnum paymentStatus;
  25. }
复制代码
3.3 Sale聚合根

Sale类是收银领域层的聚合根。
该类内聚了两个业务逻辑方法，分别为添加订单明细和计算总金额。
  1. package edu.scau.mis.pos.domain.entity;
  3. import com.fasterxml.jackson.annotation.JsonFormat;
  4. import edu.scau.mis.pos.domain.enums.SaleStatusEnum;
  5. import lombok.Data;
  7. import java.math.BigDecimal;
  8. import java.util.ArrayList;
  9. import java.util.Date;
  10. import java.util.List;
  12. /**
  13. * 销售实体类
  14. * 聚合根
  15. */
  16. @Data
  17. public class Sale {
  18.     private Long saleId;
  19.     private String saleNo;
  20.     private BigDecimal totalAmount;
  21.     private Integer totalQuantity;
  22.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  23.     private Date saleTime;
  24.     private Payment payment;
  25.     private List<SaleProduct> saleProducts = new ArrayList<>();
  26.     private SaleStatusEnum saleStatus;
  28.     /**
  29.      * 计算总金额
  30.      * @return
  31.      */
  33.     public BigDecimal getTotal(){
  34.         totalAmount = BigDecimal.ZERO;
  35.         totalQuantity = 0;
  36.         for(SaleProduct saleProduct: saleProducts){
  37.             totalAmount = totalAmount.add(saleProduct.getSubTotal());
  38.             totalQuantity = totalQuantity + saleProduct.getSaleQuantity();
  39.         }
  40.         return totalAmount;
  41.     }
  43.     /**
  44.      * 添加订单明细
  45.      * @param product
  46.      * @param saleQuantity
  47.      * @return
  48.      */
  50.     public List<SaleProduct> makeLineItem(Product product, Integer saleQuantity) {
  51.         // 判断商品是否已录入，未录入则新增。已录入则修改数量。
  52.         if(!isEntered(product.getProductSn(),saleQuantity)){
  53.             SaleProduct saleProduct = new SaleProduct();
  54.             saleProduct.setProduct(product);
  55.             saleProduct.setSaleQuantity(saleQuantity);
  56.             saleProduct.setSalePrice(product.getProductPrice());
  57.             saleProducts.add(saleProduct);
  58.         }
  59.         return saleProducts;
  60.     }
  62.     /**
  63.      * 判断商品是否已录入
  64.      * 业务逻辑：如果已录入，则修改数量，否则添加saleLineItem
  65.      * @param productSn
  66.      * @param saleQuantity
  67.      * @return
  68.      */
  69.     private boolean isEntered(String productSn, Integer saleQuantity){
  70.         boolean flag = false;
  71.         for(SaleProduct sp : saleProducts){
  72.             if(productSn.equals(sp.getProduct().getProductSn())) {
  73.                 flag = true;
  74.                 Integer quantityOriginal = sp.getSaleQuantity();
  75.                 sp.setSaleQuantity(quantityOriginal + saleQuantity);
  76.             }
  77.         }
  78.         return flag;
  79.     }
  80. }
复制代码
3.4 领域服务类SaleService

主要用于天生付出功能。ISDP项目POS体系设计支持挂单功能。
  1. package edu.scau.mis.pos.domain.service.impl;
  3. import cn.hutool.core.util.IdUtil;
  4. import edu.scau.mis.pos.domain.entity.Payment;
  5. import edu.scau.mis.pos.domain.entity.Sale;
  6. import edu.scau.mis.pos.domain.enums.PaymentStatusEnum;
  7. import edu.scau.mis.pos.domain.enums.PaymentStrategyEnum;
  8. import edu.scau.mis.pos.domain.service.ISaleService;
  9. import org.springframework.stereotype.Service;
  11. import java.math.BigDecimal;
  12. import java.util.Date;
  14. /**
  15. * 领域服务
  16. */
  17. @Service
  18. public class SaleServiceImpl implements ISaleService {
  19.     @Override
  20.     public Payment makePayment(Sale sale, String paymentStrategy, BigDecimal paymentAmount) {
  21.         Payment payment = new Payment();
  22.         payment.setPaymentStrategy(PaymentStrategyEnum.valueOf(paymentStrategy));
  23.         payment.setPaymentNo(paymentStrategy + "-" + IdUtil.getSnowflakeNextId());
  24.         payment.setPaymentAmount(paymentAmount);
  25.         payment.setPaymentTime(new Date());
  26.         payment.setPaymentStatus(PaymentStatusEnum.PAID);
  27.         // TODO: 根据不同支付策略调用不同外部接口
  28.         return payment;
  29.     }
  30. }
复制代码
3.5 其他

Domain层还有堆栈、枚举等包。由于暂时还没有利用数据库和Redis，堆栈代码暂时没写。
写了一些枚举类。由于只是讲授项目，没有设计过多状态。
  1. package edu.scau.mis.pos.domain.enums;
  3. /**
  4. * 订单状态枚举
  5. */
  6. public enum SaleStatusEnum {
  7.     CREATED("0","已预订"),
  9.     SUBMITTED("1","已提交"),
  11.     PAID("2","已支付");
  13.     private String value;
  15.     private String label;
  17.     SaleStatusEnum(String value, String label) {
  18.         this.value = value;
  19.         this.label = label;
  20.     }
  22.     public String getLabel() {
  23.         return label;
  24.     }
  26.     public String getValue() {
  27.         return value;
  28.     }
  30.     /**
  31.      * 根据匹配value的值获取Label
  32.      *
  33.      * @param value
  34.      * @return
  35.      */
  36.     public static String getLabelByValue(String value){
  37.         for (SaleStatusEnum s : SaleStatusEnum.values()) {
  38.             if(value.equals(s.getValue())){
  39.                 return s.getLabel();
  40.             }
  41.         }
  42.         return "";
  43.     }
  45.     /**
  46.      * 获取StatusEnum
  47.      *
  48.      * @param value
  49.      * @return
  50.      */
  51.     public static SaleStatusEnum getStatusEnum(String value){
  52.         for (SaleStatusEnum s : SaleStatusEnum.values()) {
  53.             if(value.equals(s.getValue())){
  54.                 return s;
  55.             }
  56.         }
  57.         return null;
  58.     }
  59. }
复制代码
付出策略枚举类
  1. package edu.scau.mis.pos.domain.enums;
  3. /**
  4. * 支付策略枚举
  5. */
  6. public enum PaymentStrategyEnum {
  7.     WECHAT("wechat","微信支付"),
  9.     ALIPAY("alipay","支付宝"),
  11.     CASH("cash","现金");
  13.     private String value;
  15.     private String label;
  17.     PaymentStrategyEnum(String value, String label) {
  18.         this.value = value;
  19.         this.label = label;
  20.     }
  22.     public String getLabel() {
  23.         return label;
  24.     }
  26.     public String getValue() {
  27.         return value;
  28.     }
  30.     /**
  31.      * 根据匹配value的值获取Label
  32.      *
  33.      * @param value
  34.      * @return
  35.      */
  36.     public static String getLabelByValue(String value){
  37.         for (PaymentStrategyEnum s : PaymentStrategyEnum.values()) {
  38.             if(value.equals(s.getValue())){
  39.                 return s.getLabel();
  40.             }
  41.         }
  42.         return "";
  43.     }
  45.     /**
  46.      * 获取StatusEnum
  47.      *
  48.      * @param value
  49.      * @return
  50.      */
  51.     public static PaymentStrategyEnum getStrategyEnum(String value){
  52.         for (PaymentStrategyEnum s : PaymentStrategyEnum.values()) {
  53.             if(value.equals(s.getValue())){
  54.                 return s;
  55.             }
  56.         }
  57.         return null;
  58.     }
  59. }
复制代码
4 应用层

4.1 应用服务类SaleApplicationService

编写SaleApplicationService类。该类主要负责跨领域协作。
现在主要就两个领域Sale（SaleProduct、Payment）和Product（Category）。
如果利用微服务，可以分别针对这两个领域创建两个微服务模块。
  1. package edu.scau.mis.pos.application.service;
  3. import edu.scau.mis.pos.application.assembler.SaleAssembler;
  4. import edu.scau.mis.pos.application.dto.command.EnterItemCommand;
  5. import edu.scau.mis.pos.application.dto.command.MakePaymentCommand;
  6. import edu.scau.mis.pos.application.dto.vo.*;
  7. import edu.scau.mis.pos.domain.entity.Payment;
  8. import edu.scau.mis.pos.domain.entity.Product;
  9. import edu.scau.mis.pos.domain.entity.Sale;
  10. import edu.scau.mis.pos.domain.entity.SaleProduct;
  11. import edu.scau.mis.pos.domain.enums.SaleStatusEnum;
  12. import edu.scau.mis.pos.domain.service.IProductService;
  13. import edu.scau.mis.pos.infrastructure.factory.SaleFactory;
  14. import edu.scau.mis.pos.domain.service.ISaleService;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.stereotype.Service;
  18. import java.util.List;
  20. @Service
  21. public class SaleApplicationService {
  22.     @Autowired
  23.     private IProductService productService;
  25.     @Autowired
  26.     private ISaleService saleService;
  28.     @Autowired
  29.     private SaleFactory saleFactory;
  31.     @Autowired
  32.     private SaleAssembler saleAssembler;
  34.     private Sale currentSale; // 后期改成Redis缓存CurrentSale
  36.     /**
  37.      * 开始一次新销售
  38.      * @return
  39.      */
  40.     public SaleVo makeNewSale(){
  41.         SaleVo saleVo = new SaleVo();
  42.         currentSale = saleFactory.initSale();
  43.         // TODO：引入Redis缓存
  44.         return saleAssembler.toSaleVo(currentSale);
  45.     }
  47.     /**
  48.      * 录入商品
  49.      * @param command
  50.      * @return
  51.      */
  52.     public SaleAndProductListVo enterItem(EnterItemCommand command){
  53.         SaleAndProductListVo saleAndProductListVo = new SaleAndProductListVo();
  54.         Product product = productService.selectProductBySn(command.getProductSn());
  55.         List<SaleProduct> saleProducts = currentSale.makeLineItem(product, command.getSaleQuantity());
  56.         currentSale.getTotal();
  57.         List<SaleProductVo> saleProductVoList = saleProducts.stream()
  58.                 .map(saleProduct -> new SaleProductVo(saleProduct.getProduct().getProductSn(), saleProduct.getProduct().getProductName(), saleProduct.getSalePrice(), saleProduct.getSaleQuantity()))
  59.                 .toList();
  60.         saleAndProductListVo.setSaleVo(saleAssembler.toSaleVo(currentSale));
  61.         saleAndProductListVo.setSaleProductVoList(saleProductVoList);
  62.         return saleAndProductListVo;
  63.     }
  65.     /**
  66.      * 结束销售
  67.      * 计算优惠、持久化订单等
  68.      * @return
  69.      */
  70.     public SaleVo endSale(){
  71.         currentSale.setSaleStatus(SaleStatusEnum.SUBMITTED);
  72.         // TODO: 持久化Sale和SaleProduct，添加事务注解
  73.         return saleAssembler.toSaleVo(currentSale);
  74.     }
  76.     /**
  77.      * 完成支付
  78.      * @param command
  79.      * @return
  80.      */
  81.     public SaleAndPaymentVo makePayment(MakePaymentCommand command){
  82.         SaleAndPaymentVo saleAndPaymentVo = new SaleAndPaymentVo();
  83.         // TODO: 挂单--根据saleNo获取Sale
  84.         Payment payment = saleService.makePayment(currentSale,command.getPaymentStrategy(), command.getPaymentAmount());
  85.         currentSale.setPayment(payment);
  86.         currentSale.setSaleStatus(SaleStatusEnum.PAID);
  87.         // TODO： 持久化Sale和Payment，添加事务注解
  88.         // payment.setPaymentSaleId(sale.getSaleId());
  89.         saleAndPaymentVo.setSaleVo(saleAssembler.toSaleVo(currentSale));
  90.         saleAndPaymentVo.setPaymentVo(saleAssembler.toPaymentVo(payment));
  91.         return saleAndPaymentVo;
  92.     }
  93. }
复制代码
4.2 数据传输对象DTO

ISDP项目采用CQRS思想，该层编写大量的数据传输对象DTO。条记只展示部分代码。详细参加项目堆栈。
EnterItemCommand参考代码如下。
后期将利用Redis缓存currentSale，设计saleNo作为key。保留saleNo备用。
  1. package edu.scau.mis.pos.application.dto.command;
  3. import lombok.Data;
  5. import java.io.Serializable;
  7. /**
  8. * 输入订单明细命令
  9. */
  10. @Data
  11. public class EnterItemCommand implements Serializable {
  12.     private String saleNo;
  14.     private String productSn;
  16.     private Integer saleQuantity;
  17. }
复制代码
MakePaymentCommand代码参考如下：
同上，saleNo暂时不需要。
  1. package edu.scau.mis.pos.application.dto.command;
  3. import lombok.Data;
  5. import java.io.Serializable;
  6. import java.math.BigDecimal;
  8. /**
  9. * 创建支付命令
  10. */
  11. @Data
  12. public class MakePaymentCommand implements Serializable {
  13.     private String saleNo;
  14.     private BigDecimal paymentAmount;
  15.     private String paymentStrategy;
  16. }
复制代码
SaleVo类
  1. package edu.scau.mis.pos.application.dto.vo;
  3. import lombok.Data;
  5. import java.io.Serializable;
  6. import java.math.BigDecimal;
  7. import java.util.Date;
  8. @Data
  9. public class SaleVo implements Serializable {
  10.     private String saleNo;
  11.     private BigDecimal totalAmount;
  12.     private Integer totalQuantity;
  13.     private Date saleTime;
  14.     private String saleStatus;
  15. }
复制代码
SaleAndPaymentVo
  1. package edu.scau.mis.pos.application.dto.vo;
  3. import lombok.Data;
  5. import java.io.Serializable;
  6. @Data
  7. public class SaleAndPaymentVo implements Serializable {
  8.     private SaleVo saleVo;
  9.     private PaymentVo paymentVo;
  10. }
复制代码
4.3 对象转换器SaleAssembler

面向接口层主要利用DTO对象，因此不可避免涉及到DTO与领域对象的转换。
  1. package edu.scau.mis.pos.application.assembler;
  3. import edu.scau.mis.pos.application.dto.vo.PaymentVo;
  4. import edu.scau.mis.pos.application.dto.vo.SaleVo;
  5. import edu.scau.mis.pos.domain.entity.Payment;
  6. import edu.scau.mis.pos.domain.entity.Sale;
  7. import org.springframework.stereotype.Component;
  9. /**
  10. * 订单转换器
  11. * 实现DTO与Entity的转换
  12. */
  14. @Component
  15. public class SaleAssembler {
  16.     public SaleVo toSaleVo(Sale sale){
  17.         SaleVo saleVo = new SaleVo();
  18.         saleVo.setSaleNo(sale.getSaleNo());
  19.         saleVo.setTotalAmount(sale.getTotalAmount());
  20.         saleVo.setTotalQuantity(sale.getTotalQuantity());
  21.         saleVo.setSaleTime(sale.getSaleTime());
  22.         saleVo.setSaleStatus(sale.getSaleStatus().getLabel());
  23.         return saleVo;
  24.     }
  26.     public PaymentVo toPaymentVo(Payment payment){
  27.         PaymentVo paymentVo = new PaymentVo();
  28.         paymentVo.setPaymentId(payment.getPaymentId());
  29.         paymentVo.setPaymentSaleId(payment.getPaymentSaleId());
  30.         paymentVo.setPaymentNo(payment.getPaymentNo());
  31.         paymentVo.setPaymentAmount(payment.getPaymentAmount());
  32.         paymentVo.setPaymentTime(payment.getPaymentTime());
  33.         paymentVo.setPaymentStrategy(payment.getPaymentStrategy().getLabel());
  34.         paymentVo.setPaymentStatus(payment.getPaymentStatus().getLabel());
  35.         return paymentVo;
  36.     }
  37. }
复制代码
5 接口层

5.1 Controller接口

SaleController参考如下：
  1. package edu.scau.mis.web.controller;
  3. import edu.scau.mis.pos.application.dto.command.EnterItemCommand;
  4. import edu.scau.mis.pos.application.dto.command.MakePaymentCommand;
  5. import edu.scau.mis.pos.application.dto.vo.SaleAndPaymentVo;
  6. import edu.scau.mis.pos.application.dto.vo.SaleAndProductListVo;
  7. import edu.scau.mis.pos.application.dto.vo.SaleVo;
  8. import edu.scau.mis.pos.application.service.SaleApplicationService;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.http.ResponseEntity;
  11. import org.springframework.web.bind.annotation.*;
  13. @RestController
  14. @RequestMapping("/sale")
  15. public class SaleController {
  16.     @Autowired
  17.     private SaleApplicationService saleApplicationService;
  18.     @GetMapping("/makeNewSale")
  19.     public ResponseEntity<SaleVo> makeNewSale()
  20.     {
  21.         return ResponseEntity.ok(saleApplicationService.makeNewSale());
  22.     }
  24.     @PostMapping("/enterItem")
  25.     public ResponseEntity<SaleAndProductListVo> enterItem(@RequestBody  EnterItemCommand enterItemCommand)
  26.     {
  27.         return ResponseEntity.ok(saleApplicationService.enterItem(enterItemCommand));
  28.     }
  30.     @GetMapping("/endSale")
  31.     public ResponseEntity<SaleVo> endSale()
  32.     {
  33.         return ResponseEntity.ok(saleApplicationService.endSale());
  34.     }
  36.     @PostMapping("/makePayment")
  37.     public ResponseEntity<SaleAndPaymentVo> makePayment(@RequestBody MakePaymentCommand makePaymentCommand)
  38.     {
  39.         return ResponseEntity.ok(saleApplicationService.makePayment(makePaymentCommand));
  40.     }
  41. }
复制代码
5.2 接口测试

利用Knife4j对SaleController接口举行测试，简朴验证后端业务逻辑。
5.2.1 makeNewSale接口

该接口现在只是初始化currentSale数据。

5.2.2 enterItem接口

接口吸收产品编号和订购数量。
接口返回订单和订购商品聚集的json数据。

5.2.3 endSale接口

该接口暂时未写太多业务逻辑，只是提交订单，更新订单状。
后期将会从redis中清除缓存currentSale，然后恒久化currentSale数据。

5.2.4 makePayment接口

接口吸收付出金额和付出方式两个参数。
接口返回订单和付出json数据。

本章条记基于上篇的分析与设计模子，编写DDD架构底子办法层、领域层、应用层和接口层的代码。实现了收银用例的4个主要步骤makeNewSale、enterItem、endSale和makePayment。
下一篇条记将应用适配器模式调用付出宝沙箱付出接口。
本条记项目堆栈地点：
https://gitcode.com/tiger2704/isdp-boot3/tree/isdp010

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

正序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

梦见你的名字

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表