Go 重构案例分享：订单创建逻辑重构

背景：从 PHP (Laravel) 到 Go 的代码迁移

• 原 PHP (Laravel) 实现思路：核心模式： “行为管道” (Behavior Pipeline)。
  
• 如何工作： 将订单创建拆分成多个独立的小任务 (如：请求限流、素材验证、创建订单、调用支付、埋点)。每个任务是一个实现了特定接口 (BehaviorOrderCreateInterface) 的类。
  
• 执行过程： 将这些任务类注册到一个列表中。创建订单时，按顺序执行列表里每个任务的 handle 方法。
  
• 状态共享： 每个任务在执行时，能访问和修改同一个“订单创建服务”对象 (OrderCreateService)，通过它传递数据和状态（比如订单创建后，埋点任务需要用到订单ID）。
  
• 异常处理： 使用 try-catch 捕获异常并进行事务回滚。
  

makeOrder 创建订单方法


实例化OrderCreateService类后，通过registerBehavior通过 registerBehavior 方法将行为类注册。
最后执行create方法

1. /**
2.      * 生成订单
3.      * @param $params
4.      * @return string[]
5.      * @date 2023/6/6 13:30
6.      * @throws \Exception
7.      */
8.     public function makeOrder($params): array
9.     {
10.         $db = DB::connection(DbEnum::MYSQL_RELEBOOK);
11.         $db->beginTransaction();
13.         try {
14.             $data = (new OrderCreateService($params))->registerBehavior(
15.                 function () {
16.                     return new RequestLimit();
17.                 },
18.                 function () {
19.                     return new ResValidate();
20.                 },
21.                 function () {
22.                     return new Order();
23.                 },
24.                 function () {
25.                     return new Payment();
26.                 },
27.                 function () {
28.                     return new OrderBuried();
29.                 },
30.             )->create();
32.             $db->commit();
34.             return $data;
35.         } catch (\LogicException $logicException) {
36.             $db->rollback();
37.             // 异常code码（CODE_117006008）返回素材信息，不直接抛异常
38.             if ($logicException->getCode() == RelebookUserCodeEnum::CODE_117006008) {
39.                 $data = collect(json_decode($logicException->getMessage()))->toArray();
40.                 $data['order_no'] = '';
41.                 $data['pay_url'] = '';
42.                 return $data;
43.             }
44.             throw new \LogicException($logicException->getMessage(), $logicException->getCode());
45.         } catch (\Exception $exception) {
46.             $db->rollback();
47.             throw new \Exception($exception->getMessage(), intval($exception->getCode()));
48.         }
49.     }

复制代码

这些 行为类 都继承BehaviorOrderCreateInterface 接口

1. interface BehaviorOrderCreateInterface
2. {
3.     public function handle(OrderCreateService $orderCreateService);
5. }

复制代码

最后让我们来瞧瞧OrderCreateService类的实现。
$behaviorList 用来存放 registerBehavior方法注册的行为类
最后在create方法里面运行

1. class OrderCreateService
2. {
4.     public array $params;
6.     public array $params;
7.     /** 素材信息 **/
8.     public array $res;
9.     /**订单信息 **/
10.     public array $order_info;
11.     /**子订单信息 **/
12.     public array $subOrders;
13.     /**购物车信息 **/
14.     public array $cartItem;
15.     /**支付服务 **/
16.     public PaymentInterface $paymentService;
17.     /**支付信息 **/
18.     public array $payment;
20.     /**
21.      * @var array|\Closure[]
22.      */
23.     private array $behaviorList = [];
25.     public function __construct($params)
26.     {
27.         $this->params = $params;
28.     }
30.     /**
31.      * 订单创建行为注册
32.      * @param \Closure ...$callback
33.      * @return $this
34.      * @date 2023/6/29 13:58
35.      */
36.     public function registerBehavior(\Closure ...$callback): static
37.     {
38.         $this->behaviorList = array_merge($this->behaviorList,$callback);
39.         return $this;
40.     }
42. /**
43.      * 创建订单
44.      * @return mixed
45.      * @date 2023/6/29 14:21
46.      */
47.     public function create()
48.     {
49.         $this->params['order_type'] = PayEnum::ORDER_TYPE_RES;
51.         // A、执行订单创建行为
52.         foreach ($this->behaviorList as $behavior) {
53.             $behavior()->handle($this);
54.         }
56.         // B、订单返回数据
57.         $this->data = array_merge($this->data, $this->payment);
58.         $this->data['order_type'] = $this->params['order_type'];
59.         $this->data['cash_type'] = $this->params['cash_type'];
60.         $this->data['order_no'] = $this->order_info['order_no'];
61.         $this->data['pay_url'] = $this->payment['pay_url'];
62.         $this->data['type'] = RelebookUserOrder::ORDER_CREATE_STATUS_SUCCESS;
63.         $this->data['res'] = [];
65.         return $this->data;
66.     }
67. }

复制代码

Go重构的挑战与解决方案

• 挑战 1：状态共享 (Go 没有类属性)问题： Go 没有类的概念，不同的小任务（函数/方法）不能直接共享一个“服务对象”的状态。解决方案： 引入 DTO (Data Transfer Object)。DTO 是什么？ 一个专门用来在不同部分之间传递数据的结构体。它就像是一个共享的“数据盒子”。作用： 将所有小任务需要共享的数据（请求参数、中间结果、最终响应、错误信息）都定义在这个结构体 (OrderBehaviorDTO) 里。如何工作： 每个小任务接收这个 DTO 指针作为参数，从中读取需要的数据，并将自己产生的结果写回到 DTO 中。这样，后续的任务就能访问到前面任务写入的数据。
  
• 挑战 2：异常处理 (Go 没有 try-catch)问题： Go 通常通过函数返回 error 值来处理错误，不能像 PHP 那样在任意地方 throw 并被外层 catch。解决方案：在 DTO 中加入专门的错误字段 (Err)。每个小任务在执行过程中，如果遇到错误，不直接 panic 或抛异常，而是将错误信息设置到 DTO 的 Err 字段 (或 Response.Code/ErrMsg) 中，然后返回 DTO。主流程 (Handle 方法) 检查每个任务执行后 DTO 中的错误状态。一旦发现错误，立即终止后续任务并返回错误响应。
  

Go 实现的核心逻辑 (简化说明)

• 定义 DTO 结构体 (OrderBehaviorDTO): 包含所有需要流转的数据（输入参数、支付结果、订单信息、错误码等）。
  
• 定义任务接口 (BehaviorOrderCreateInterface): 要求所有小任务都必须实现一个 Handle(*OrderBehaviorDTO) *OrderBehaviorDTO 方法。
  
• 创建主服务 (MakeOrderService):初始化时创建 DTO。将需要执行的小任务 (如 OrderValidate, OrderCreate, OrderPayment, OrderBuried) 添加到任务列表 (Behavior 切片)。
  
• 执行主流程 (Handle 方法):按顺序遍历任务列表，调用每个任务的 Handle 方法，并传入 同一个 DTO 指针。每个任务从 DTO 读数据，处理业务，把结果写回 DTO。检查每个任务执行后 DTO 中的错误状态，遇错即停。
  
• 组装最终响应： 所有任务成功后，从 DTO 中提取所需数据，组装成最终的订单创建响应 (OrderMakeResponse)。
  

关键优势 (使用 DTO + 接口模式)

• 解耦清晰： 每个小任务只依赖 DTO 接口，不直接依赖其他任务的具体实现。
  
• 状态管理： DTO 作为唯一的、明确的数据交换通道，解决了 Go 中跨函数/方法状态共享的问题。
  
• 灵活可扩展： 添加新任务只需实现接口并注册到列表即可。
  
• 错误处理适配 Go 习惯： 通过返回值和 DTO 中的错误状态显式处理错误，符合 Go 的 error 处理哲学。
  

实现代码：1.定义DTO结构体内容
// OrderBehaviorDTO 用于解耦在不同结构体(服务)里面传递的数据结构体

1. type OrderBehaviorDTO struct {
2.         Params    *order.OrderMakeRequest // 请求参数
3.         Response  *order.OrderMakeResponse // 响应参数
4.         UserId    int // 用户id
5.         Uid       string // uid
6.         CartItem  []relebook.LlRelebookCartItem // 子服务查询产生的购物车信息
7.         Res       map[int32]relebook.LlRelebookRes // 子服务查询产生的素材信息
8.         Orders    OrderInfos  // 子服务创建的订单信息 -用于埋点
9.         PayResult payment.PayResult // 支付子服务产生的支付信息 -用于埋点
10.     Err Errer
11. }

复制代码

// 响应参数的proto

1. message OrderMakeResponse {
2.   string order_no = 1;
3.   string pay_url = 2;
4.   string payment_intent_id = 3;
5.   string client_secret = 4;
6.   int32 order_type = 5;
7.   int32 cash_type = 6;
8.   int32 type = 7;
9.   repeated Empty res = 8;
10.   // 异常码和返回消息
11.   int32 code = 9;
12.   string err_msg = 10;
13. }

复制代码

• 将订单限流功能抽离成限流组件
  
• 执行 orderService.NewMakeOrder方法 实例化订单创建服务并注入DTO结构体然后调用.Handle方法
  

1. func (*OrderLogic) OrderMake(ctx context.Context, in *order.OrderMakeRequest) (*order.OrderMakeResponse, error) {
2.     // 订单请求限制
3.     if utils.SlidingWindowRateLimiter(utils.GetLimitKey(ctx, "make_order"), 1, time.Second*1) != nil {
4.         result := &order.OrderMakeResponse{}
5.         result.Code = code.CODE_117001011
6.         result.ErrMsg = lang.OperatingLimit
7.         return result, nil
8.     }
9.     // 开始执行业务
10.     return orderService.NewMakeOrder(&dto.OrderBehaviorDTO{
11.         Params:   in,
12.         Response: &order.OrderMakeResponse{},
13.         UserId:   cast.ToInt(trace.GetUserId(ctx)),
14.         Uid:      in.Uid,
15.     }).Handle()
16. }

复制代码

MakeOrderService结构体内容
定义了支付、素材信息、素材封装数据DAO、用户id、以及DTO 和行为单元
最后执行 Handle方法进行行为服务执行。

1. type MakeOrderService struct {
2.         payService payment.PaymentInterface // 支付服务接口
3.         resInfos   map[int32]relebook.LlRelebookRes // 订单支付的素材
4.         resDAOImpl dao.ResDAOImpl // 素材表DAO封装的查询集合
5.         userId     int // 用户id
6.         Dto        *dto.OrderBehaviorDTO // DTO
7.         Behavior   []BehaviorOrderCreateInterface // 行为单元
8. }
10. type BehaviorOrderCreateInterface interface {
11.         Handle(Dto *dto.OrderBehaviorDTO) *dto.OrderBehaviorDTO
12. }
14. func (m *MakeOrderService) SetBehavior(behavior BehaviorOrderCreateInterface) *MakeOrderService {
15.         m.Behavior = append(m.Behavior, behavior)
16.         return m
17. }
19. func NewMakeOrder(Dto *dto.OrderBehaviorDTO) *MakeOrderService {
20.         service, _ := payment.GetPaymentService(int(Dto.Params.CashType))
21.         return &MakeOrderService{
22.                 payService: service,
23.                 Dto:        Dto,
24.         }
25. }
26. func (m *MakeOrderService) Handle() (*order.OrderMakeResponse, error) {
27.         // 支付验签
28.         if err := m.payService.Validate(payment.PaymentParams{}); err != nil {
29.                 m.Dto.Response.Code = code.CODE_117001001
30.                 m.Dto.Response.ErrMsg = err.Error()
31.                 return m.Dto.Response, nil
32.         }
33.         //设置需要写入的服务
34.         m.SetBehavior(new(behavior_create.OrderValidate)).
35.                 SetBehavior(new(behavior_create.OrderCreate)).
36.                 SetBehavior(new(behavior_create.OrderPayment)).
37.                 SetBehavior(new(behavior_create.OrderBuried))
38.         // 执行服务
39.         for _, behavior := range m.Behavior {
40.                 if behavior.Handle(m.Dto).Response.Code != 0 {
41.                         return m.Dto.Response, nil
42.                 }
43.         }
44.         // 执行完成后
45.         m.Dto.Response.ClientSecret = m.Dto.PayResult.ClientSecret
46.         m.Dto.Response.PayUrl = m.Dto.PayResult.PaymentIntentId
47.         m.Dto.Response.PayUrl = m.Dto.PayResult.PayUrl
48.         m.Dto.Response.OrderType = m.Dto.Params.OrderType
49.         m.Dto.Response.CashType = m.Dto.Params.CashType
50.         m.Dto.Response.OrderNo = m.Dto.Orders.OrderInfo.OrderNo
51.         m.Dto.Response.Type = relebook.ORDER_CREATE_STATUS_SUCCESS
53.         return m.Dto.Response, nil
54. }

复制代码

来源：豆瓜网用户自行投稿发布，如果侵权，请联系站长删除