做僾免费观看网站,最近实时热点事件,wordpress更新后图片不显示,拿自己爱人做网站信息系统开发实践 #xff5c; 系列文章传送门 ISDP001_课程概述 ISDP002_Maven上_创建Maven项目 ISDP003_Maven下_Maven项目依赖配置 ISDP004_创建SpringBoot3项目 ISDP005_Spring组件与自动装配 ISDP006_逻辑架构设计 ISDP007_Springboot日志配置与单元测试 ISDP008_SpringB…信息系统开发实践 系列文章传送门 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。 dependencygroupIdcn.hutool/groupIdartifactIdhutool-all/artifactIdversion5.8.20/version/dependency编写SaleFactory实例化Sale并设置初始化值。
package edu.scau.mis.pos.infrastructure.factory;import cn.hutool.core.util.IdUtil;
import edu.scau.mis.pos.domain.entity.Sale;
import edu.scau.mis.pos.domain.enums.SaleStatusEnum;
import org.springframework.stereotype.Component;import java.math.BigDecimal;
import java.util.Date;/*** Sale工厂类*/
Component
public class SaleFactory {public Sale initSale(){Sale sale new Sale();sale.setSaleNo(so- IdUtil.getSnowflakeNextId());sale.setSaleStatus(SaleStatusEnum.CREATED);sale.setTotalAmount(BigDecimal.ZERO);sale.setTotalQuantity(0);sale.setSaleTime(new Date());return sale;}}
3 领域层
在DDD架构中领域层是重点关注层。
为了简化Setter和getter编写引入了Lombok。 dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/dependency3.1 SaleProduct实体类
SaleProduct实体类包含了业务逻辑方法getSubTotal计算每个订单明细的小计。
package edu.scau.mis.pos.domain.entity;import edu.scau.mis.pos.domain.enums.SaleProductStatusEnum;
import lombok.Data;import java.math.BigDecimal;/*** 订单-产品明细实体类*/
Data
public class SaleProduct {private Long saleProductId;private Long saleId;private Long productId;private Product product;private Integer saleQuantity;private BigDecimal salePrice;private SaleProductStatusEnum saleProductStatus;/*** 计算小计* return*/public BigDecimal getSubTotal() {return salePrice.multiply(new BigDecimal(saleQuantity));}
}
3.2 支付实体类
支付类暂时还没有写业务逻辑方法。后期考虑通过适配器连接第三方支付。
package edu.scau.mis.pos.domain.entity;import com.fasterxml.jackson.annotation.JsonFormat;
import edu.scau.mis.pos.domain.enums.PaymentStatusEnum;
import edu.scau.mis.pos.domain.enums.PaymentStrategyEnum;
import lombok.Data;import java.math.BigDecimal;
import java.util.Date;/*** 支付实体类*/
Data
public class Payment {private Long paymentId;private Long paymentSaleId;private PaymentStrategyEnum paymentStrategy;private String paymentNo;private BigDecimal paymentAmount;JsonFormat(pattern yyyy-MM-dd HH:mm:ss)private Date paymentTime;private PaymentStatusEnum paymentStatus;}
3.3 Sale聚合根
Sale类是收银领域层的聚合根。
该类内聚了两个业务逻辑方法分别为添加订单明细和计算总金额。
package edu.scau.mis.pos.domain.entity;import com.fasterxml.jackson.annotation.JsonFormat;
import edu.scau.mis.pos.domain.enums.SaleStatusEnum;
import lombok.Data;import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;/*** 销售实体类* 聚合根*/
Data
public class Sale {private Long saleId;private String saleNo;private BigDecimal totalAmount;private Integer totalQuantity;JsonFormat(pattern yyyy-MM-dd HH:mm:ss)private Date saleTime;private Payment payment;private ListSaleProduct saleProducts new ArrayList();private SaleStatusEnum saleStatus;/*** 计算总金额* return*/public BigDecimal getTotal(){totalAmount BigDecimal.ZERO;totalQuantity 0;for(SaleProduct saleProduct: saleProducts){totalAmount totalAmount.add(saleProduct.getSubTotal());totalQuantity totalQuantity saleProduct.getSaleQuantity();}return totalAmount;}/*** 添加订单明细* param product* param saleQuantity* return*/public ListSaleProduct makeLineItem(Product product, Integer saleQuantity) {// 判断商品是否已录入未录入则新增。已录入则修改数量。if(!isEntered(product.getProductSn(),saleQuantity)){SaleProduct saleProduct new SaleProduct();saleProduct.setProduct(product);saleProduct.setSaleQuantity(saleQuantity);saleProduct.setSalePrice(product.getProductPrice());saleProducts.add(saleProduct);}return saleProducts;}/*** 判断商品是否已录入* 业务逻辑如果已录入则修改数量否则添加saleLineItem* param productSn* param saleQuantity* return*/private boolean isEntered(String productSn, Integer saleQuantity){boolean flag false;for(SaleProduct sp : saleProducts){if(productSn.equals(sp.getProduct().getProductSn())) {flag true;Integer quantityOriginal sp.getSaleQuantity();sp.setSaleQuantity(quantityOriginal saleQuantity);}}return flag;}
}
3.4 领域服务类SaleService
主要用于生成支付功能。ISDP项目POS系统设计支持挂单功能。
package edu.scau.mis.pos.domain.service.impl;import cn.hutool.core.util.IdUtil;
import edu.scau.mis.pos.domain.entity.Payment;
import edu.scau.mis.pos.domain.entity.Sale;
import edu.scau.mis.pos.domain.enums.PaymentStatusEnum;
import edu.scau.mis.pos.domain.enums.PaymentStrategyEnum;
import edu.scau.mis.pos.domain.service.ISaleService;
import org.springframework.stereotype.Service;import java.math.BigDecimal;
import java.util.Date;/*** 领域服务*/
Service
public class SaleServiceImpl implements ISaleService {Overridepublic Payment makePayment(Sale sale, String paymentStrategy, BigDecimal paymentAmount) {Payment payment new Payment();payment.setPaymentStrategy(PaymentStrategyEnum.valueOf(paymentStrategy));payment.setPaymentNo(paymentStrategy - IdUtil.getSnowflakeNextId());payment.setPaymentAmount(paymentAmount);payment.setPaymentTime(new Date());payment.setPaymentStatus(PaymentStatusEnum.PAID);// TODO: 根据不同支付策略调用不同外部接口return payment;}
}
3.5 其他
Domain层还有仓库、枚举等包。由于暂时还没有使用数据库和Redis仓库代码暂时没写。
写了一些枚举类。由于只是教学项目没有设计过多状态。
package edu.scau.mis.pos.domain.enums;/*** 订单状态枚举*/
public enum SaleStatusEnum {CREATED(0,已预订),SUBMITTED(1,已提交),PAID(2,已支付);private String value;private String label;SaleStatusEnum(String value, String label) {this.value value;this.label label;}public String getLabel() {return label;}public String getValue() {return value;}/*** 根据匹配value的值获取Label** param value* return*/public static String getLabelByValue(String value){for (SaleStatusEnum s : SaleStatusEnum.values()) {if(value.equals(s.getValue())){return s.getLabel();}}return ;}/*** 获取StatusEnum** param value* return*/public static SaleStatusEnum getStatusEnum(String value){for (SaleStatusEnum s : SaleStatusEnum.values()) {if(value.equals(s.getValue())){return s;}}return null;}
}
支付策略枚举类
package edu.scau.mis.pos.domain.enums;/*** 支付策略枚举*/
public enum PaymentStrategyEnum {WECHAT(wechat,微信支付),ALIPAY(alipay,支付宝),CASH(cash,现金);private String value;private String label;PaymentStrategyEnum(String value, String label) {this.value value;this.label label;}public String getLabel() {return label;}public String getValue() {return value;}/*** 根据匹配value的值获取Label** param value* return*/public static String getLabelByValue(String value){for (PaymentStrategyEnum s : PaymentStrategyEnum.values()) {if(value.equals(s.getValue())){return s.getLabel();}}return ;}/*** 获取StatusEnum** param value* return*/public static PaymentStrategyEnum getStrategyEnum(String value){for (PaymentStrategyEnum s : PaymentStrategyEnum.values()) {if(value.equals(s.getValue())){return s;}}return null;}
}
4 应用层
4.1 应用服务类SaleApplicationService
编写SaleApplicationService类。该类主要负责跨领域协作。
目前主要就两个领域SaleSaleProduct、Payment和ProductCategory。
如果使用微服务可以分别针对这两个领域创建两个微服务模块。
package edu.scau.mis.pos.application.service;import edu.scau.mis.pos.application.assembler.SaleAssembler;
import edu.scau.mis.pos.application.dto.command.EnterItemCommand;
import edu.scau.mis.pos.application.dto.command.MakePaymentCommand;
import edu.scau.mis.pos.application.dto.vo.*;
import edu.scau.mis.pos.domain.entity.Payment;
import edu.scau.mis.pos.domain.entity.Product;
import edu.scau.mis.pos.domain.entity.Sale;
import edu.scau.mis.pos.domain.entity.SaleProduct;
import edu.scau.mis.pos.domain.enums.SaleStatusEnum;
import edu.scau.mis.pos.domain.service.IProductService;
import edu.scau.mis.pos.infrastructure.factory.SaleFactory;
import edu.scau.mis.pos.domain.service.ISaleService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.List;Service
public class SaleApplicationService {Autowiredprivate IProductService productService;Autowiredprivate ISaleService saleService;Autowiredprivate SaleFactory saleFactory;Autowiredprivate SaleAssembler saleAssembler;private Sale currentSale; // 后期改成Redis缓存CurrentSale/*** 开始一次新销售* return*/public SaleVo makeNewSale(){SaleVo saleVo new SaleVo();currentSale saleFactory.initSale();// TODO引入Redis缓存return saleAssembler.toSaleVo(currentSale);}/*** 录入商品* param command* return*/public SaleAndProductListVo enterItem(EnterItemCommand command){SaleAndProductListVo saleAndProductListVo new SaleAndProductListVo();Product product productService.selectProductBySn(command.getProductSn());ListSaleProduct saleProducts currentSale.makeLineItem(product, command.getSaleQuantity());currentSale.getTotal();ListSaleProductVo saleProductVoList saleProducts.stream().map(saleProduct - new SaleProductVo(saleProduct.getProduct().getProductSn(), saleProduct.getProduct().getProductName(), saleProduct.getSalePrice(), saleProduct.getSaleQuantity())).toList();saleAndProductListVo.setSaleVo(saleAssembler.toSaleVo(currentSale));saleAndProductListVo.setSaleProductVoList(saleProductVoList);return saleAndProductListVo;}/*** 结束销售* 计算优惠、持久化订单等* return*/public SaleVo endSale(){currentSale.setSaleStatus(SaleStatusEnum.SUBMITTED);// TODO: 持久化Sale和SaleProduct添加事务注解return saleAssembler.toSaleVo(currentSale);}/*** 完成支付* param command* return*/public SaleAndPaymentVo makePayment(MakePaymentCommand command){SaleAndPaymentVo saleAndPaymentVo new SaleAndPaymentVo();// TODO: 挂单--根据saleNo获取SalePayment payment saleService.makePayment(currentSale,command.getPaymentStrategy(), command.getPaymentAmount());currentSale.setPayment(payment);currentSale.setSaleStatus(SaleStatusEnum.PAID);// TODO 持久化Sale和Payment添加事务注解// payment.setPaymentSaleId(sale.getSaleId());saleAndPaymentVo.setSaleVo(saleAssembler.toSaleVo(currentSale));saleAndPaymentVo.setPaymentVo(saleAssembler.toPaymentVo(payment));return saleAndPaymentVo;}
}
4.2 数据传输对象DTO
ISDP项目采用CQRS思想该层编写大量的数据传输对象DTO。笔记只展示部分代码。详细参加项目仓库。
EnterItemCommand参考代码如下。
后期将使用Redis缓存currentSale设计saleNo作为key。保留saleNo备用。
package edu.scau.mis.pos.application.dto.command;import lombok.Data;import java.io.Serializable;/*** 输入订单明细命令*/
Data
public class EnterItemCommand implements Serializable {private String saleNo;private String productSn;private Integer saleQuantity;
}
MakePaymentCommand代码参考如下
同上saleNo暂时不需要。
package edu.scau.mis.pos.application.dto.command;import lombok.Data;import java.io.Serializable;
import java.math.BigDecimal;/*** 创建支付命令*/
Data
public class MakePaymentCommand implements Serializable {private String saleNo;private BigDecimal paymentAmount;private String paymentStrategy;
}
SaleVo类
package edu.scau.mis.pos.application.dto.vo;import lombok.Data;import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
Data
public class SaleVo implements Serializable {private String saleNo;private BigDecimal totalAmount;private Integer totalQuantity;private Date saleTime;private String saleStatus;
}
SaleAndPaymentVo
package edu.scau.mis.pos.application.dto.vo;import lombok.Data;import java.io.Serializable;
Data
public class SaleAndPaymentVo implements Serializable {private SaleVo saleVo;private PaymentVo paymentVo;
}
4.3 对象转换器SaleAssembler
面向接口层主要使用DTO对象因此不可避免涉及到DTO与领域对象的转换。
package edu.scau.mis.pos.application.assembler;import edu.scau.mis.pos.application.dto.vo.PaymentVo;
import edu.scau.mis.pos.application.dto.vo.SaleVo;
import edu.scau.mis.pos.domain.entity.Payment;
import edu.scau.mis.pos.domain.entity.Sale;
import org.springframework.stereotype.Component;/*** 订单转换器* 实现DTO与Entity的转换*/Component
public class SaleAssembler {public SaleVo toSaleVo(Sale sale){SaleVo saleVo new SaleVo();saleVo.setSaleNo(sale.getSaleNo());saleVo.setTotalAmount(sale.getTotalAmount());saleVo.setTotalQuantity(sale.getTotalQuantity());saleVo.setSaleTime(sale.getSaleTime());saleVo.setSaleStatus(sale.getSaleStatus().getLabel());return saleVo;}public PaymentVo toPaymentVo(Payment payment){PaymentVo paymentVo new PaymentVo();paymentVo.setPaymentId(payment.getPaymentId());paymentVo.setPaymentSaleId(payment.getPaymentSaleId());paymentVo.setPaymentNo(payment.getPaymentNo());paymentVo.setPaymentAmount(payment.getPaymentAmount());paymentVo.setPaymentTime(payment.getPaymentTime());paymentVo.setPaymentStrategy(payment.getPaymentStrategy().getLabel());paymentVo.setPaymentStatus(payment.getPaymentStatus().getLabel());return paymentVo;}
}
5 接口层
5.1 Controller接口
SaleController参考如下
package edu.scau.mis.web.controller;import edu.scau.mis.pos.application.dto.command.EnterItemCommand;
import edu.scau.mis.pos.application.dto.command.MakePaymentCommand;
import edu.scau.mis.pos.application.dto.vo.SaleAndPaymentVo;
import edu.scau.mis.pos.application.dto.vo.SaleAndProductListVo;
import edu.scau.mis.pos.application.dto.vo.SaleVo;
import edu.scau.mis.pos.application.service.SaleApplicationService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;RestController
RequestMapping(/sale)
public class SaleController {Autowiredprivate SaleApplicationService saleApplicationService;GetMapping(/makeNewSale)public ResponseEntitySaleVo makeNewSale(){return ResponseEntity.ok(saleApplicationService.makeNewSale());}PostMapping(/enterItem)public ResponseEntitySaleAndProductListVo enterItem(RequestBody EnterItemCommand enterItemCommand){return ResponseEntity.ok(saleApplicationService.enterItem(enterItemCommand));}GetMapping(/endSale)public ResponseEntitySaleVo endSale(){return ResponseEntity.ok(saleApplicationService.endSale());}PostMapping(/makePayment)public ResponseEntitySaleAndPaymentVo makePayment(RequestBody MakePaymentCommand makePaymentCommand){return ResponseEntity.ok(saleApplicationService.makePayment(makePaymentCommand));}
}
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
