Payment Crontab

整体交互流程图

功能描述

用于定期检查所有等待支付的订单，并根据支付状态进行相应的处理，包括查询订单状态、取消过期订单以及更新订单状态。

定时查询：定期检查所有等待支付的订单。 订单状态更新：根据支付提供商返回的状态更新订单。 取消过期订单：自动取消已经过期但未支付的订单。 实现步骤

1. 初始化定时任务 在 init 函数中调用 startPaymentCron，启动支付定时任务。

   func init() {
       base.AddRegisteredHook(startPaymentCron)
   }
   

2. 定时任务执行 使用 time.Tick 设置定时任务的间隔。

   for range time.Tick(time.Duration(cast.ToInt(cronIntervalSec)) * time.Second) {
       // 任务执行逻辑
   }
   

3. 处理待支付订单 对于每个待支付订单，检查订单的创建时间和过期时间。 如果订单未过期，根据订单的支付类型创建相应的支付客户端。 使用 statusQuery 方法查询订单的支付状态。

   paymentsRD, err := getPendingPayments(internalClient)
   // 处理每个订单
   

4. 订单状态更新 使用 UpdateOnePayment 函数更新订单的支付状态。

   paymentUpdateInput := PaymentUpdateI{ /* ... */ }
   updateResp, err := UpdateOnePayment(internalClient, paymentUpdateInput)
   

5. 取消过期订单 如果订单已过期，使用 cancelOnePayment 函数取消订单。

   _, err := cancelOnePayment(internalClient, data.Id)
   

6. 处理特定的支付类型 根据订单的支付类型（支付宝或微信支付），处理返回的支付状态。

   // 示例：处理支付宝支付类型
   if resp, ok := result.(*alipay.TradeQueryRsp); ok {
       tradeStatus = string(resp.TradeStatus)
   }