关于处理电商系统订单状态的流转,分享下我的技术方案(附带源码)

简介: 关于处理电商系统订单状态的流转,分享下我的技术方案(附带源码)

文章目录:

  • 前言
  • 目的
  • 逻辑分析
  • 代码实现
  • 定义状态
  • 定义事件
  • 定义事件的处理方法
  • 核心代码
  • 调用方式
  • 小结

前言

在设计电商系统订单模块时,订单会涉及各种状态以及状态与状态之间的流转,可扩展性可维护性 是我们需要关注的重点!本文分享一下我的技术方案。

fb0ce56b1e954b307e474093b6c8711d.png

如上图,使用 golang 实现上图的订单流转,同时当后续增加订单状态或订单事件时,可以进行快速完成。

目的

关于订单状态的处理,使用统一入口,提高程序的 可扩展性可维护性

逻辑分析

订单状态包括:默认已预订已确认已锁定

订单事件包括:创建订单确认订单修改订单支付订单

通过上图我们还知道了状态与事件之间的关系,比如只有 已确认 的订单才可以进行 修改订单

需要考虑如下问题:

  1. 当订单状态增加时,如何尽可能少的改动或改动对历史影响不大?
  2. 如果在同一入口调用,每个事件的处理方法需要的入参都有所不同,如何处理?
  3. 当某个事件完成后,有可能会进行发短信或客户端 Push 的操作,如何处理?
  4. 有可能某个事件,在不同平台(C端、商家后台、管理平台)的处理逻辑也有些不同,如何处理?

如何设计代码能够解决以上问题?

下面是我的一种代码实现,供大家参考,实现了在 创建订单 时,进行传入参数和完成后给用户发送短信,其他事件的操作,同理就可以实现。

代码实现

定义状态

// 定义订单状态
const (
 StatusDefault   = State(0)
 StatusReserved  = State(10)
 StatusConfirmed = State(20)
 StatusLocked    = State(30)
)
// statusText 定义订单状态文案
var statusText = map[State]string{
 StatusDefault:   "默认",
 StatusReserved:  "已预订",
 StatusConfirmed: "已确认",
 StatusLocked:    "已锁定",
}
// statusEvent 定义订单状态对应的可操作事件
var statusEvent = map[State][]Event{
 StatusDefault:   {EventCreate},
 StatusReserved:  {EventConfirm},
 StatusConfirmed: {EventModify, EventPay},
}
func StatusText(status State) string {
 return statusText[status]
}

当有新订单状态的增加时,在此文件中增加相应状态即可,同时维护好订单状态与订单事件之间的关系。

定义事件

// 定义订单事件
const (
 EventCreate  = Event("创建订单")
 EventConfirm = Event("确定订单")
 EventModify  = Event("修改订单")
 EventPay     = Event("支付订单")
)
// 定义订单事件对应的处理方法
var eventHandler = map[Event]Handler{
 EventCreate:  handlerCreate,
 EventConfirm: handlerConfirm,
 EventModify:  handlerModify,
 EventPay:     handlerPay,
}

当有新订单事件的增加时,在此文件中增加相应事件即可,同时维护好订单事件与事件实现方法之间的关系。

定义事件的处理方法

var (
 // handlerCreate 创建订单
 handlerCreate = Handler(func(opt *Opt) (State, error) {
  message := fmt.Sprintf("正在处理创建订单逻辑,订单ID(%d), 订单名称(%s) ... 处理完毕!", opt.OrderId, opt.OrderName)
  fmt.Println(message)
  if opt.HandlerSendSMS != nil {
   _ = opt.HandlerSendSMS("18888888888", "恭喜你预定成功了!")
  }
  return StatusReserved, nil
 })
 // handlerConfirm 确认订单
 handlerConfirm = Handler(func(opt *Opt) (State, error) {
  return StatusConfirmed, nil
 })
 // handlerModify 修改订单
 handlerModify = Handler(func(opt *Opt) (State, error) {
  return StatusReserved, nil
 })
 // handlerPay 支付订单
 handlerPay = Handler(func(opt *Opt) (State, error) {
  return StatusLocked, nil
 })
)

在此文件中维护具体的事件处理方法,如果逻辑比较复杂可以考虑拆分文件处理。

核心代码

type State int                             // 状态
type Event string                          // 事件
type Handler func(opt *Opt) (State, error) // 处理方法,并返回新的状态
// FSM 有限状态机
type FSM struct {
 mu       sync.Mutex                  // 排他锁
 state    State                       // 当前状态
 handlers map[State]map[Event]Handler // 当前状态可触发的有限个事件
}
// 获取当前状态
func (f *FSM) getState() State {
 return f.state
}
// 设置当前状态
func (f *FSM) setState(newState State) {
 f.state = newState
}
// addHandlers 添加事件和处理方法
func (f *FSM) addHandlers() (*FSM, error) {
 ...
 return f, nil
}
// Call 事件处理
func (f *FSM) Call(event Event, opts ...Option) (State, error) {
 f.mu.Lock()
 defer f.mu.Unlock()
 ...
 return f.getState(), nil
}
// NewFSM 实例化 FSM
func NewFSM(initState State) (fsm *FSM, err error) {
 fsm = new(FSM)
 fsm.state = initState
 fsm.handlers = make(map[State]map[Event]Handler)
 fsm, err = fsm.addHandlers()
 if err != nil {
  return
 }
 return
}

对订单状态的操作,只需要使用 Call 方法即可!

关于方法 addHandlersCall 的代码就不贴了,在文章后面我提供了源码地址,供大家下载。

调用方式

例如当前状态为 默认状态,依次进行如下操作:

  • 创建订单,状态变为 已预订
  • 修改订单,不可操作(已预订状态不可修改);
  • 确定订单,状态变为 已确认
  • 修改订单,状态变为 已预订
  • 确定订单,状态变为 已确认
  • 支付订单,状态变为 已锁定
// 通过订单ID 或 其他信息查询到订单状态
orderStatus := order.StatusDefault
orderMachine, err := order.NewFSM(orderStatus)
if err != nil {
 fmt.Println(err.Error())
 return
}
// 创建订单,订单创建成功后再给用户发送短信
if _, err = orderMachine.Call(order.EventCreate,
 order.WithOrderId(1),
 order.WithOrderName("测试订单"),
 order.WithHandlerSendSMS(sendSMS),
); err != nil {
 fmt.Println(err.Error())
}
// 修改订单
if _, err = orderMachine.Call(order.EventModify); err != nil {
 fmt.Println(err.Error())
}
// 确认订单
if _, err = orderMachine.Call(order.EventConfirm); err != nil {
 fmt.Println(err.Error())
}
// 修改订单
if _, err = orderMachine.Call(order.EventModify); err != nil {
 fmt.Println(err.Error())
}
// 确认订单
if _, err = orderMachine.Call(order.EventConfirm); err != nil {
 fmt.Println(err.Error())
}
// 支付订单
if _, err = orderMachine.Call(order.EventPay); err != nil {
 fmt.Println(err.Error())
}

输出:

正在处理创建订单逻辑,订单ID(1), 订单名称(测试订单) ... 处理完毕!
发送短信,给(18888888888)发送了(恭喜你预定成功了!)
操作[创建订单],状态从 [默认] 变成 [已预订]
[警告] 状态(已预订)不允许操作(修改订单)
操作[确定订单],状态从 [已预订] 变成 [已确认]
操作[修改订单],状态从 [已确认] 变成 [已预订]
操作[确定订单],状态从 [已预订] 变成 [已确认]
操作[支付订单],状态从 [已确认] 变成 [已锁定]

小结

以上就是我的技术方案,希望能对你有所帮助,感兴趣的可以再进行封装,上述代码已提交到 github go-fsm-order[1],供下载使用。

参考资料

[1]

go-fsm-order: https://github.com/xinliangnote/go-fsm-order

目录
相关文章
|
消息中间件 设计模式 移动开发
高德打车通用可编排订单状态机引擎设计
订单状态流转是交易系统的最为核心的工作,订单系统往往都会存在状态多、链路长、逻辑复杂的特点,还存在多场景、多类型、多业务维度等业务特性。在保证订单状态流转稳定性的前提下、可扩展性和可维护性是我们需要重点关注和解决的问题。
高德打车通用可编排订单状态机引擎设计
|
存储 监控 数据可视化
日志分析对决:揭示 ELK 与 GrayLog 的优势和差异
日志分析对决:揭示 ELK 与 GrayLog 的优势和差异
3483 0
|
SQL 运维 安全
闲鱼交易实时资损防控体系
聊一聊资损防控体系和闲鱼实践
6642 0
闲鱼交易实时资损防控体系
|
Java 网络架构 容器
面向整洁对象的分层架构COLA 4.0
COLA 是 Clean Object-Oriented and Layered Architecture的缩写,代表“面向整洁对象的分层架构”。 目前COLA已经发展到COLA 4.0。 COLA分为两个部分,COLA架构和COLA组件。
面向整洁对象的分层架构COLA 4.0
|
人工智能 IDE 测试技术
一文教会你如何用好通义灵码,让这款 AI 编码工具帮你做更多工作,更高效
如何用好通义灵码?欢迎收藏最佳使用指南。本文提供通义灵码使用指南,涵盖快捷键、配置调整、跨文件索引及上下文管理等内容,帮助用户更高效地使用通义灵码。
|
传感器 机器学习/深度学习 弹性计算
Agent与大模型的区别
本文详细对比了人工智能领域的两个重要概念——Agent和大模型。大模型如GPT-3、BERT等,擅长自然语言处理任务,如文本生成、翻译等;Agent则是自主的软件实体,能够在特定环境中感知、决策并执行任务,如管理日程、控制智能家居等。文章介绍了它们的定义、功能、技术架构及应用场景,并总结了两者的核心差异和未来发展方向。
7481 26
|
NoSQL 中间件 Java
字节面试:聊聊 CAP 定理?哪些中间件是AP? 哪些是CP? 说说 为什么?
45岁老架构师尼恩在其读者交流群中分享了关于CAP定理的重要面试题及其解析,包括CAP定理的基本概念、CAP三要素之间的关系,以及如何在分布式系统设计中权衡一致性和可用性。文章还详细分析了几种常见中间件(如Redis Cluster、Zookeeper、MongoDB、Cassandra、Eureka、Nacos)的CAP特性,并提供了高端面试技巧,帮助读者在面试中脱颖而出。尼恩还推荐了其团队编写的《尼恩Java面试宝典PDF》等资料,助力求职者准备面试,提升技术水平。
|
存储 监控 供应链
账单系统-架构设计思路(对外版)
阿里商旅背景阿里商旅作为飞猪旅行旗下面向企业客户的数字化差旅解决方案产品,依托飞猪旅行机票、酒店供应链,为企业客户提供一站式的机票、酒店、火车票、用车等预订管控及结算票据服务。阿里商旅不仅是集团欢行的供应商,而且近几年在商业化差旅市场上崭露头角,服务了2万+中大型客户,43万+小微企业。FY22财年商旅技术团队重点规划在酒店供应链、预订管控服务、B+C客户服务、渠道及商旅基础建设等核心方向进行建设
5309 2
账单系统-架构设计思路(对外版)
|
JSON 负载均衡 Java
SpringCloud Feign 远程调用(史上最详细讲解)
SpringCloud Feign 远程调用(史上最详细讲解)
14785 0
SpringCloud Feign 远程调用(史上最详细讲解)
|
消息中间件 测试技术 领域建模
DDD - 一文读懂DDD领域驱动设计
DDD - 一文读懂DDD领域驱动设计
44816 6