领域驱动设计(DDD)四 订单管理系统实践步骤
以下是基于 领域驱动设计(DDD) 的订单管理系统实践步骤,系统功能主要包括订单的创建、更新、查询和状态管理,采用 Spring Boot 框架进行实现。
1. 需求分析
订单管理系统的基本功能:
- 订单创建:用户下单创建订单。
- 订单状态更新:更新订单状态(如已支付、已发货、已完成)。
- 订单查询:支持按订单 ID 或用户查询订单信息。
- 库存管理(简化版):订单创建时检查并扣减库存。
2. 领域划分与限界上下文
限界上下文
- 订单上下文(Order Context):负责订单的生命周期管理。
- 库存上下文(Inventory Context):负责商品库存的管理。
模块划分
src/main/java/com/example/order
├── application # 应用层:处理用例逻辑
│ ├── service # 应用服务
│ └── dto # 数据传输对象
├── domain # 领域层:业务逻辑
│ ├── model # 领域模型(实体、值对象、聚合)
│ ├── repository # 仓储接口
│ ├── service # 领域服务
│ └── event # 领域事件
├── infrastructure # 基础设施层:技术实现
│ ├── repository # 仓储实现
│ └── event # 事件机制
└── interfaces # 接口层:用户交互├── controller # REST 接口└── vo # 视图对象
3. 代码实现
3.1 领域层设计
领域模型
(1) 订单实体
public class Order {private Long id; // 订单IDprivate String customerId; // 用户IDprivate List<OrderItem> items; // 订单项private OrderStatus status; // 订单状态// 创建订单public Order(String customerId, List<OrderItem> items) {this.customerId = customerId;this.items = items;this.status = OrderStatus.CREATED;}// 更新订单状态public void updateStatus(OrderStatus status) {if (this.status.canTransitionTo(status)) {this.status = status;} else {throw new IllegalStateException("非法状态转换");}}// 计算总金额public BigDecimal calculateTotal() {return items.stream().map(item -> item.getPrice().multiply(BigDecimal.valueOf(item.getQuantity()))).reduce(BigDecimal.ZERO, BigDecimal::add);}// Getters and Setters
}
(2) 订单项值对象
public class OrderItem {private Long productId; // 商品IDprivate int quantity; // 数量private BigDecimal price; // 单价// 构造方法public OrderItem(Long productId, int quantity, BigDecimal price) {this.productId = productId;this.quantity = quantity;this.price = price;}// Getters and Setters
}
(3) 订单状态值对象
public enum OrderStatus {CREATED, PAID, SHIPPED, COMPLETED;// 状态转换规则public boolean canTransitionTo(OrderStatus newStatus) {return switch (this) {case CREATED -> newStatus == PAID;case PAID -> newStatus == SHIPPED;case SHIPPED -> newStatus == COMPLETED;default -> false;};}
}
3.2 应用层设计
订单服务
@Service
public class OrderApplicationService {private final OrderRepository orderRepository;private final InventoryService inventoryService;public OrderApplicationService(OrderRepository orderRepository, InventoryService inventoryService) {this.orderRepository = orderRepository;this.inventoryService = inventoryService;}// 创建订单public Long createOrder(String customerId, List<OrderItemDto> itemDtos) {// 转换 DTO 为领域模型List<OrderItem> items = itemDtos.stream().map(dto -> new OrderItem(dto.getProductId(), dto.getQuantity(), dto.getPrice())).toList();// 检查库存items.forEach(item -> inventoryService.reserveStock(item.getProductId(), item.getQuantity()));// 创建订单Order order = new Order(customerId, items);orderRepository.save(order);return order.getId();}// 更新订单状态public void updateOrderStatus(Long orderId, OrderStatus status) {Order order = orderRepository.findById(orderId).orElseThrow(() -> new RuntimeException("订单不存在"));order.updateStatus(status);orderRepository.save(order);}// 查询订单public OrderDto getOrderById(Long orderId) {Order order = orderRepository.findById(orderId).orElseThrow(() -> new RuntimeException("订单不存在"));return OrderDto.fromDomain(order);}
}
3.3 基础设施层设计
仓储实现
@Repository
public class JpaOrderRepository implements OrderRepository {private final SpringDataOrderJpaRepository jpaRepository;public JpaOrderRepository(SpringDataOrderJpaRepository jpaRepository) {this.jpaRepository = jpaRepository;}@Overridepublic void save(Order order) {jpaRepository.save(order);}@Overridepublic Optional<Order> findById(Long id) {return jpaRepository.findById(id);}
}
事件机制
@Component
public class DomainEventPublisher {private final ApplicationEventPublisher eventPublisher;public DomainEventPublisher(ApplicationEventPublisher eventPublisher) {this.eventPublisher = eventPublisher;}public void publish(Object event) {eventPublisher.publishEvent(event);}
}
3.4 接口层设计
订单控制器
@RestController
@RequestMapping("/api/orders")
public class OrderController {private final OrderApplicationService orderService;public OrderController(OrderApplicationService orderService) {this.orderService = orderService;}@PostMappingpublic ResponseEntity<Long> createOrder(@RequestBody OrderRequest request) {Long orderId = orderService.createOrder(request.getCustomerId(), request.getItems());return ResponseEntity.status(HttpStatus.CREATED).body(orderId);}@PutMapping("/{orderId}/status")public ResponseEntity<Void> updateStatus(@PathVariable Long orderId, @RequestParam OrderStatus status) {orderService.updateOrderStatus(orderId, status);return ResponseEntity.ok().build();}@GetMapping("/{orderId}")public ResponseEntity<OrderDto> getOrderById(@PathVariable Long orderId) {return ResponseEntity.ok(orderService.getOrderById(orderId));}
}
3.5 示例数据传输对象(DTO)
public class OrderDto {private Long id;private String customerId;private List<OrderItemDto> items;private OrderStatus status;public static OrderDto fromDomain(Order order) {return new OrderDto(order.getId(), order.getCustomerId(),order.getItems().stream().map(OrderItemDto::fromDomain).toList(),order.getStatus());}
}
4. 运行与测试
数据库表结构(MySQL 示例)
CREATE TABLE orders (id BIGINT AUTO_INCREMENT PRIMARY KEY,customer_id VARCHAR(255),status VARCHAR(50)
);CREATE TABLE order_items (id BIGINT AUTO_INCREMENT PRIMARY KEY,order_id BIGINT,product_id BIGINT,quantity INT,price DECIMAL(10,2),FOREIGN KEY (order_id) REFERENCES orders(id)
);
测试示例
-
创建订单
POST /api/orders {"customerId": "123","items": [{ "productId": 1, "quantity": 2, "price": 50.00 },{ "productId": 2, "quantity": 1, "price": 100.00 }] }
-
更新订单状态
PUT /api/orders/1/status?status=PAID
-
查询订单
GET /api/orders/1
这套设计是 DDD 的小型实践示例,后续可以扩展领域事件、复杂聚合和限界上下文的实现。
相关文章:
领域驱动设计(DDD)四 订单管理系统实践步骤
以下是基于 领域驱动设计(DDD) 的订单管理系统实践步骤,系统功能主要包括订单的创建、更新、查询和状态管理,采用 Spring Boot 框架进行实现。 1. 需求分析 订单管理系统的基本功能: 订单创建:用户下单创…...
leetcode 面试经典 150 题:简化路径
链接简化路径题序号71题型字符串解法栈难度中等熟练度✅✅✅ 题目 给你一个字符串 path ,表示指向某一文件或目录的 Unix 风格 绝对路径 (以 ‘/’ 开头),请你将其转化为 更加简洁的规范路径。 在 Unix 风格的文件系统中规则如下…...

基于 STM32 的智能农业温室控制系统设计
1. 引言 随着农业现代化的发展,智能农业温室控制系统对于提高农作物产量和质量具有重要意义。该系统能够实时监测温室内的环境参数,如温度、湿度、光照强度和土壤湿度等,并根据这些参数自动调节温室设备,如通风扇、加热器、加湿器…...

【Spring Boot】掌握 Spring 事务:隔离级别与传播机制解读与应用
前言 🌟🌟本期讲解关于spring 事务传播机制介绍~~~ 🌈感兴趣的小伙伴看一看小编主页:GGBondlctrl-CSDN博客 🔥 你的点赞就是小编不断更新的最大动力 🎆那么废话…...

【Postgres_Python】使用python脚本将多个PG数据库合并为一个PG数据库
需要合并的多个PG数据库表个数和结构一致,这里提供一种思路,选择sql语句insert插入的方式进行,即将其他PG数据库的每个表内容插入到一个PG数据库中完成数据库合并 示例代码说明: 选择一个数据库导出表结构为.sql文件(…...

Tailwind CSS v4.0 发布
Holy shit its actually done ! 1 月 22 日,Tailwind CSS 正式发布了 4.0 版本,针对性能和灵活性进行了优化,重新构想了配置和定制体验,并充分利用了 Web 平台提供的最新进展。 新的高性能引擎- 完整构建速度提高 5 …...

pandas基础:文件的读取和写入
文件的读取和写入 读取csv文件 csv文件: name,age,city Alice,25,New York Bob,30,Los Angelesread_csv(filename) header:如 何处理文件的第一行。header0将第一行作为列名,headerNone表示文件中没有列名,所有行都是数据。 im…...

【MySQL — 数据库增删改查操作】深入解析MySQL的create insert 操作
数据库CRUD操作 1 CRUD简介 CURD是对数据库中的记录进行基本的增删改查操作: 2. Create 新增 语法 INSERT [INTO] table_name[(column [,column] ...)] VALUES(value_list)[,(value_list)] ... # value 后面的列的个数和类型,要和表结构匹配…...

每日OJ_牛客_小红的子串_滑动窗口+前缀和_C++_Java
目录 牛客_小红的子串_滑动窗口前缀和 题目解析 C代码 Java代码 牛客_小红的子串_滑动窗口前缀和 小红的子串 描述: 小红拿到了一个长度为nnn的字符串,她准备选取一段子串,满足该子串中字母的种类数量在[l,r]之间。小红想知道&…...

HTTP 配置与应用(局域网)
想做一个自己学习的有关的csdn账号,努力奋斗......会更新我计算机网络实验课程的所有内容,还有其他的学习知识^_^,为自己巩固一下所学知识,下次更新HTTP 配置与应用(不同网段)。 我是一个萌新小白…...
ultralytics 是什么?
ultralytics 是一个用于计算机视觉任务的 Python 库,专注于提供高效、易用的目标检测、实例分割和图像分类工具。它最著名的功能是实现 YOLO(You Only Look Once) 系列模型,特别是最新的 YOLOv8。 1. YOLO 是什么? YO…...
AI竞争:从技术壁垒到用户数据之争
标题:AI竞争:从技术壁垒到用户数据之争 文章信息摘要: AI市场呈现开放模型与封闭模型并存的双轨发展态势,但核心竞争力已从模型技术转向用户数据积累和使用习惯培养。商业模式正在多元化发展,从早期的价格战转向subsc…...

MySQL 主从复制(单组传统复制,GTID复制。双主复制)
案例环境 单组复制 master: 192.168.180.143 slave01:192.168.180.144 双组复制 master01:192.168.180.143 master02:192.168.180.144 案例过程 准备工作 关闭所有防火墙 setenforce 0 && systemctl stop firewa…...

python学opencv|读取图像(四十)掩模:三通道图像的局部覆盖
【1】引言 前序学习了使用numpy创建单通道的灰色图像,并对灰色图像的局部进行了颜色更改,相关链接为: python学opencv|读取图像(九)用numpy创建黑白相间灰度图_numpy生成全黑图片-CSDN博客 之后又学习了使用numpy创…...
vue3 中如何监听 props 中的值的变化
在 Vue 3 中,你可以使用 watch 函数来监听组件的 props 值的变化。watch 函数允许你观察一个或多个响应式数据源,并在这些数据源发生变化时执行回调函数。 以下是一个示例,展示了如何在 Vue 3 中使用 watch 来监听 props 中的值的变化&#…...

Scrapy之一个item包含多级页面的处理方案
目标 在实际开发过程中,我们所需要的数据往往需要通过多个页面的数据汇总得到,通过列表获取到的数据只有简单的介绍。站在Scrapy框架的角度来看,实际上就是考虑如何处理一个item包含多级页面数据的问题。本文将以获取叶子猪网站的手游排行榜及…...
hive 自动检测、自动重启、记录检测日志、自动清理日志
最终效果 定时检测hive运行状态,进程不存在或者进程存在但是不监听端口的hiveserver2,自动重新拉起每次检测脚本执行的日志都会保存在log目录下.check文件,每一个月一个文件每月15日,删除2月前的检测日志开启hive自带日志输出后&…...

HFSS同轴替换波端口
波端口仿真正常 将波端口换成内径内径0.3mm外径0.6mm同轴之后 结果很不对 换成下面的尺寸就好了...

【2024年华为OD机试】 (C卷,100分)- 素数之积(JavaScriptJava PythonC/C++)
一、问题描述 RSA 因数分解问题 题目描述 RSA 加密算法在网络安全世界中无处不在,它利用了极大整数因数分解的困难度。数据越大,安全系数越高。给定一个 32 位正整数,请对其进行因数分解,找出是哪两个素数的乘积。 输入描述 …...
【C++模板】:如何判断自定义类型是否实现某个函数
一、引子 偶尔我们会面对这样的尴尬的场景,我们需要显示的去判断在某个自定义类型中,是否已经提供了我们期待的API接口,以避免产生“莫须有”的错误。阁下该如何破解此问题! 这里,直接给出一种通用的方法,…...

ETLCloud可能遇到的问题有哪些?常见坑位解析
数据集成平台ETLCloud,主要用于支持数据的抽取(Extract)、转换(Transform)和加载(Load)过程。提供了一个简洁直观的界面,以便用户可以在不同的数据源之间轻松地进行数据迁移和转换。…...

PL0语法,分析器实现!
简介 PL/0 是一种简单的编程语言,通常用于教学编译原理。它的语法结构清晰,功能包括常量定义、变量声明、过程(子程序)定义以及基本的控制结构(如条件语句和循环语句)。 PL/0 语法规范 PL/0 是一种教学用的小型编程语言,由 Niklaus Wirth 设计,用于展示编译原理的核…...
Python 包管理器 uv 介绍
Python 包管理器 uv 全面介绍 uv 是由 Astral(热门工具 Ruff 的开发者)推出的下一代高性能 Python 包管理器和构建工具,用 Rust 编写。它旨在解决传统工具(如 pip、virtualenv、pip-tools)的性能瓶颈,同时…...
Spring是如何解决Bean的循环依赖:三级缓存机制
1、什么是 Bean 的循环依赖 在 Spring框架中,Bean 的循环依赖是指多个 Bean 之间互相持有对方引用,形成闭环依赖关系的现象。 多个 Bean 的依赖关系构成环形链路,例如: 双向依赖:Bean A 依赖 Bean B,同时 Bean B 也依赖 Bean A(A↔B)。链条循环: Bean A → Bean…...

Docker 本地安装 mysql 数据库
Docker: Accelerated Container Application Development 下载对应操作系统版本的 docker ;并安装。 基础操作不再赘述。 打开 macOS 终端,开始 docker 安装mysql之旅 第一步 docker search mysql 》〉docker search mysql NAME DE…...
iOS性能调优实战:借助克魔(KeyMob)与常用工具深度洞察App瓶颈
在日常iOS开发过程中,性能问题往往是最令人头疼的一类Bug。尤其是在App上线前的压测阶段或是处理用户反馈的高发期,开发者往往需要面对卡顿、崩溃、能耗异常、日志混乱等一系列问题。这些问题表面上看似偶发,但背后往往隐藏着系统资源调度不当…...
Redis:现代应用开发的高效内存数据存储利器
一、Redis的起源与发展 Redis最初由意大利程序员Salvatore Sanfilippo在2009年开发,其初衷是为了满足他自己的一个项目需求,即需要一个高性能的键值存储系统来解决传统数据库在高并发场景下的性能瓶颈。随着项目的开源,Redis凭借其简单易用、…...

【LeetCode】算法详解#6 ---除自身以外数组的乘积
1.题目介绍 给定一个整数数组 nums,返回 数组 answer ,其中 answer[i] 等于 nums 中除 nums[i] 之外其余各元素的乘积 。 题目数据 保证 数组 nums之中任意元素的全部前缀元素和后缀的乘积都在 32 位 整数范围内。 请 不要使用除法,且在 O…...

tauri项目,如何在rust端读取电脑环境变量
如果想在前端通过调用来获取环境变量的值,可以通过标准的依赖: std::env::var(name).ok() 想在前端通过调用来获取,可以写一个command函数: #[tauri::command] pub fn get_env_var(name: String) -> Result<String, Stri…...

C++实现分布式网络通信框架RPC(2)——rpc发布端
有了上篇文章的项目的基本知识的了解,现在我们就开始构建项目。 目录 一、构建工程目录 二、本地服务发布成RPC服务 2.1理解RPC发布 2.2实现 三、Mprpc框架的基础类设计 3.1框架的初始化类 MprpcApplication 代码实现 3.2读取配置文件类 MprpcConfig 代码实现…...