Documentation
¶
Overview ¶
Package orderLogic provides order processing logic for handling various types of orders including subscription purchases, renewals, traffic resets, and balance recharges.
Index ¶
- Constants
- Variables
- type ActivateOrderLogic
- func (l *ActivateOrderLogic) NewPurchase(ctx context.Context, orderInfo *order.Order) error
- func (l *ActivateOrderLogic) ProcessTask(ctx context.Context, task *asynq.Task) error
- func (l *ActivateOrderLogic) Recharge(ctx context.Context, orderInfo *order.Order) error
- func (l *ActivateOrderLogic) Renewal(ctx context.Context, orderInfo *order.Order) error
- func (l *ActivateOrderLogic) ResetTraffic(ctx context.Context, orderInfo *order.Order) error
- type CleanupOrderEventsLogic
- type DeferCloseOrderLogic
- type PublishOrderEventsLogic
- type ReconcilePaidOrdersLogic
- type ReconcilePendingOrdersLogic
Constants ¶
const ( OrderTypeSubscribe = 1 // New subscription purchase OrderTypeRenewal = 2 // Subscription renewal OrderTypeResetTraffic = 3 // Traffic quota reset OrderTypeRecharge = 4 // Balance recharge )
Order type constants define the different types of orders that can be processed
const ( OrderStatusPending = 1 // Order created but not paid OrderStatusPaid = 2 // Order paid and ready for processing OrderStatusClose = 3 // Order closed/cancelled OrderStatusFailed = 4 // Order processing failed OrderStatusFinished = 5 // Order successfully completed )
Order status constants define the lifecycle states of an order
Variables ¶
var ( ErrInvalidOrderStatus = fmt.Errorf("invalid order status") ErrInvalidOrderType = fmt.Errorf("invalid order type") )
Predefined error variables for common error conditions
Functions ¶
This section is empty.
Types ¶
type ActivateOrderLogic ¶
type ActivateOrderLogic struct {
// contains filtered or unexported fields
}
ActivateOrderLogic handles the activation and processing of paid orders
func NewActivateOrderLogic ¶
func NewActivateOrderLogic(svc *svc.ServiceContext) *ActivateOrderLogic
NewActivateOrderLogic creates a new instance of ActivateOrderLogic
func (*ActivateOrderLogic) NewPurchase ¶
NewPurchase handles new subscription purchase including user creation, subscription setup, commission processing, cache updates, and notifications
func (*ActivateOrderLogic) ProcessTask ¶
ProcessTask is the main entry point for processing order activation tasks. It handles the complete workflow of activating a paid order including validation, processing based on order type, and finalization.
func (*ActivateOrderLogic) Recharge ¶
Recharge handles balance recharge orders including balance updates, transaction logging, and notifications
func (*ActivateOrderLogic) Renewal ¶
Renewal handles subscription renewal including subscription extension, traffic reset (if configured), commission processing, and notifications
func (*ActivateOrderLogic) ResetTraffic ¶
ResetTraffic handles traffic quota reset for existing subscriptions
type CleanupOrderEventsLogic ¶ added in v1.14.19
type CleanupOrderEventsLogic struct {
// contains filtered or unexported fields
}
CleanupOrderEventsLogic removes only events that have already reached Redis and are older than the replay contract. Unpublished events are never deleted, even if an outage lasts longer than the normal retention period.
func NewCleanupOrderEventsLogic ¶ added in v1.14.19
func NewCleanupOrderEventsLogic(svcCtx *svc.ServiceContext) *CleanupOrderEventsLogic
func (*CleanupOrderEventsLogic) ProcessTask ¶ added in v1.14.19
type DeferCloseOrderLogic ¶
type DeferCloseOrderLogic struct {
// contains filtered or unexported fields
}
func NewDeferCloseOrderLogic ¶
func NewDeferCloseOrderLogic(svc *svc.ServiceContext) *DeferCloseOrderLogic
func (*DeferCloseOrderLogic) ProcessTask ¶
type PublishOrderEventsLogic ¶ added in v1.14.19
type PublishOrderEventsLogic struct {
// contains filtered or unexported fields
}
PublishOrderEventsLogic drains the durable order event outbox. Publishing is intentionally separate from writing the event: a Redis outage may delay a notification but can never roll back a committed payment state.
func NewPublishOrderEventsLogic ¶ added in v1.14.19
func NewPublishOrderEventsLogic(svcCtx *svc.ServiceContext) *PublishOrderEventsLogic
func (*PublishOrderEventsLogic) ProcessTask ¶ added in v1.14.19
type ReconcilePaidOrdersLogic ¶ added in v1.14.0
type ReconcilePaidOrdersLogic struct {
// contains filtered or unexported fields
}
ReconcilePaidOrdersLogic treats the durable Paid state as an activation outbox. It repairs the database/Redis gap if a callback committed payment but Redis was unavailable before the activation task could be inserted.
func NewReconcilePaidOrdersLogic ¶ added in v1.14.0
func NewReconcilePaidOrdersLogic(svc *svc.ServiceContext) *ReconcilePaidOrdersLogic
func (*ReconcilePaidOrdersLogic) ProcessTask ¶ added in v1.14.0
type ReconcilePendingOrdersLogic ¶ added in v1.14.16
type ReconcilePendingOrdersLogic struct {
// contains filtered or unexported fields
}
ReconcilePendingOrdersLogic is a durable fallback for deferred close tasks. State transitions in CloseOrder remain conditional, so a late callback can safely race this scan without turning a paid order back into a close order.
func NewReconcilePendingOrdersLogic ¶ added in v1.14.16
func NewReconcilePendingOrdersLogic(svc *svc.ServiceContext) *ReconcilePendingOrdersLogic
Source Files