v1.0 test

2025-11-06 23:39:06 +08:00
commit caa7509a20
562 changed files with 59715 additions and 0 deletions
--- a/app/main/api/internal/service/agentService.go
+++ b/app/main/api/internal/service/agentService.go
@@ -0,0 +1,588 @@
+package service
+
+import (
+	"context"
+	"qnc-server/app/main/api/internal/config"
+	"qnc-server/app/main/model"
+	"qnc-server/pkg/lzkit/lzUtils"
+
+	"github.com/pkg/errors"
+	"github.com/zeromicro/go-zero/core/stores/sqlx"
+)
+
+type AgentService struct {
+	config                            config.Config
+	OrderModel                        model.OrderModel
+	AgentModel                        model.AgentModel
+	AgentAuditModel                   model.AgentAuditModel
+	AgentClosureModel                 model.AgentClosureModel
+	AgentCommissionModel              model.AgentCommissionModel
+	AgentCommissionDeductionModel     model.AgentCommissionDeductionModel
+	AgentWalletModel                  model.AgentWalletModel
+	AgentLinkModel                    model.AgentLinkModel
+	AgentOrderModel                   model.AgentOrderModel
+	AgentRewardsModel                 model.AgentRewardsModel
+	AgentMembershipConfigModel        model.AgentMembershipConfigModel
+	AgentMembershipRechargeOrderModel model.AgentMembershipRechargeOrderModel
+	AgentMembershipUserConfigModel    model.AgentMembershipUserConfigModel
+	AgentProductConfigModel           model.AgentProductConfigModel
+	AgentPlatformDeductionModel       model.AgentPlatformDeductionModel
+	AgentActiveStatModel              model.AgentActiveStatModel
+	AgentWithdrawalModel              model.AgentWithdrawalModel
+}
+
+func NewAgentService(c config.Config, orderModel model.OrderModel, agentModel model.AgentModel, agentAuditModel model.AgentAuditModel,
+	agentClosureModel model.AgentClosureModel, agentCommissionModel model.AgentCommissionModel,
+	agentCommissionDeductionModel model.AgentCommissionDeductionModel, agentWalletModel model.AgentWalletModel, agentLinkModel model.AgentLinkModel, agentOrderModel model.AgentOrderModel, agentRewardsModel model.AgentRewardsModel,
+	agentMembershipConfigModel model.AgentMembershipConfigModel,
+	agentMembershipRechargeOrderModel model.AgentMembershipRechargeOrderModel,
+	agentMembershipUserConfigModel model.AgentMembershipUserConfigModel,
+	agentProductConfigModel model.AgentProductConfigModel, agentPlatformDeductionModel model.AgentPlatformDeductionModel,
+	agentActiveStatModel model.AgentActiveStatModel, agentWithdrawalModel model.AgentWithdrawalModel) *AgentService {
+
+	return &AgentService{
+		config:                            c,
+		OrderModel:                        orderModel,
+		AgentModel:                        agentModel,
+		AgentAuditModel:                   agentAuditModel,
+		AgentClosureModel:                 agentClosureModel,
+		AgentCommissionModel:              agentCommissionModel,
+		AgentCommissionDeductionModel:     agentCommissionDeductionModel,
+		AgentWalletModel:                  agentWalletModel,
+		AgentLinkModel:                    agentLinkModel,
+		AgentOrderModel:                   agentOrderModel,
+		AgentRewardsModel:                 agentRewardsModel,
+		AgentMembershipConfigModel:        agentMembershipConfigModel,
+		AgentMembershipRechargeOrderModel: agentMembershipRechargeOrderModel,
+		AgentMembershipUserConfigModel:    agentMembershipUserConfigModel,
+		AgentProductConfigModel:           agentProductConfigModel,
+		AgentPlatformDeductionModel:       agentPlatformDeductionModel,
+		AgentActiveStatModel:              agentActiveStatModel,
+		AgentWithdrawalModel:              agentWithdrawalModel,
+	}
+}
+
+// AgentProcess 推广单成功
+func (l *AgentService) AgentProcess(ctx context.Context, order *model.Order) error {
+	// 获取是否该订单是代理推广订单
+	agentOrderModel, err := l.AgentOrderModel.FindOneByOrderId(ctx, order.Id)
+	if err != nil && !errors.Is(err, model.ErrNotFound) {
+		return err
+	}
+	if errors.Is(err, model.ErrNotFound) || agentOrderModel == nil {
+		return nil
+	}
+	// 事务
+	transErr := l.AgentWalletModel.Trans(ctx, func(transCtx context.Context, session sqlx.Session) error {
+		agentID := agentOrderModel.AgentId
+		agentProductConfigModel, findAgentProductConfigModelErr := l.AgentProductConfigModel.FindOneByProductId(transCtx, order.ProductId)
+		if findAgentProductConfigModelErr != nil {
+			return findAgentProductConfigModelErr
+		}
+		// 平台底价成本
+		PlatformCostAmount, platformCostErr := l.PlatformCost(transCtx, agentID, agentProductConfigModel, session)
+		if platformCostErr != nil {
+			return platformCostErr
+		}
+
+		// 平台提价成本
+		PlatformPricingAmount, platformPricingErr := l.PlatformPricing(transCtx, agentID, order.Amount, agentProductConfigModel, session)
+		if platformPricingErr != nil {
+			return platformPricingErr
+		}
+
+		// 查找上级
+		AgentClosureModel, findAgentClosureModelErr := l.AgentClosureModel.FindOneByDescendantIdDepth(transCtx, agentID, 1)
+		if findAgentClosureModelErr != nil && !errors.Is(findAgentClosureModelErr, model.ErrNotFound) {
+			return findAgentClosureModelErr
+		}
+
+		var descendantDeductedAmount = 0.00
+		if AgentClosureModel != nil {
+			AncestorId := AgentClosureModel.AncestorId
+			AncestorModel, findAgentModelErr := l.AgentModel.FindOne(transCtx, AncestorId)
+			if findAgentModelErr != nil && !errors.Is(findAgentModelErr, model.ErrNotFound) {
+				return findAgentModelErr
+			}
+			if AncestorModel != nil {
+				if AncestorModel.LevelName == "" {
+					AncestorModel.LevelName = model.AgentLeveNameNormal
+				}
+				AgentMembershipConfigModel, findAgentMembersipConfigModelErr := l.AgentMembershipConfigModel.FindOneByLevelName(ctx, AncestorModel.LevelName)
+				if findAgentMembersipConfigModelErr != nil {
+					return findAgentMembersipConfigModelErr
+				}
+				// 定价
+				commissionCost, commissionCostErr := l.CommissionCost(transCtx, agentID, AncestorId, AgentMembershipConfigModel, order.ProductId, session)
+				if commissionCostErr != nil {
+					return commissionCostErr
+				}
+				// 提价
+				commissionPricing, commissionPricingErr := l.CommissionPricing(transCtx, agentID, AncestorId, AgentMembershipConfigModel, order.ProductId, order.Amount, session)
+				if commissionPricingErr != nil {
+					return commissionPricingErr
+				}
+
+				// 上级克扣的成本
+				descendantDeductedAmount = commissionCost + commissionPricing
+
+				// 佣金
+				ancestorCommissionReward, ancestorCommissionErr := l.AncestorCommission(transCtx, agentID, AncestorId, session)
+				if ancestorCommissionErr != nil {
+					return ancestorCommissionErr
+				}
+
+				// 给上级成本以及佣金
+				ancestorCommissionAmount := commissionCost + commissionPricing + ancestorCommissionReward
+				ancestorWallet, findAgentWalletModelErr := l.AgentWalletModel.FindOneByAgentId(transCtx, AncestorId)
+				if findAgentWalletModelErr != nil {
+					return findAgentWalletModelErr
+				}
+
+				ancestorWallet.Balance += ancestorCommissionAmount
+				ancestorWallet.TotalEarnings += ancestorCommissionAmount
+				updateErr := l.AgentWalletModel.UpdateWithVersion(transCtx, session, ancestorWallet)
+				if updateErr != nil {
+					return updateErr
+				}
+			}
+		}
+
+		// 推广人扣除金额 = 平台成本价 + 平台提价成本 + 上级佣金
+		deductedAmount := PlatformCostAmount + PlatformPricingAmount + descendantDeductedAmount
+		agentCommissionErr := l.AgentCommission(transCtx, agentID, order, deductedAmount, session)
+		if agentCommissionErr != nil {
+			return agentCommissionErr
+		}
+
+		return nil
+	})
+	if transErr != nil {
+		return transErr
+	}
+
+	return nil
+}
+
+// AgentCommission 直推报告推广人佣金
+func (l *AgentService) AgentCommission(ctx context.Context, agentID int64, order *model.Order, deductedAmount float64, session sqlx.Session) error {
+	agentWalletModel, findAgentWalletModelErr := l.AgentWalletModel.FindOneByAgentId(ctx, agentID)
+	if findAgentWalletModelErr != nil {
+		return findAgentWalletModelErr
+	}
+	// 推广人最终获得代理佣金
+	finalCommission := order.Amount - deductedAmount
+	agentWalletModel.Balance += finalCommission
+	agentWalletModel.TotalEarnings += finalCommission
+
+	agentCommission := model.AgentCommission{
+		AgentId:   agentID,
+		OrderId:   order.Id,
+		Amount:    finalCommission,
+		ProductId: order.ProductId,
+	}
+	_, insertAgentCommissionErr := l.AgentCommissionModel.Insert(ctx, session, &agentCommission)
+	if insertAgentCommissionErr != nil {
+		return insertAgentCommissionErr
+	}
+
+	updateAgentWalletErr := l.AgentWalletModel.UpdateWithVersion(ctx, session, agentWalletModel)
+	if updateAgentWalletErr != nil {
+		return updateAgentWalletErr
+	}
+	return nil
+}
+
+// AncestorCommission 直推报告上级佣金（奖励型）
+func (l *AgentService) AncestorCommission(ctx context.Context, descendantId int64, ancestorId int64, session sqlx.Session) (float64, error) {
+	agentModel, err := l.AgentModel.FindOne(ctx, ancestorId)
+	if err != nil {
+		return 0, err
+	}
+	if agentModel.LevelName == "" {
+		agentModel.LevelName = model.AgentLeveNameNormal
+	}
+	agentMembershipConfigModel, err := l.AgentMembershipConfigModel.FindOneByLevelName(ctx, agentModel.LevelName)
+	if err != nil {
+		return 0, err
+	}
+
+	if agentMembershipConfigModel.ReportCommission.Valid {
+		reportCommissionAmount := agentMembershipConfigModel.ReportCommission.Float64
+		agentRewards := model.AgentRewards{
+			AgentId:         ancestorId,
+			Amount:          reportCommissionAmount,
+			RelationAgentId: lzUtils.Int64ToNullInt64(descendantId),
+			Type:            model.AgentRewardsTypeDescendantPromotion,
+		}
+
+		_, agentRewardsModelInsetErr := l.AgentRewardsModel.Insert(ctx, session, &agentRewards)
+		if agentRewardsModelInsetErr != nil {
+			return 0, agentRewardsModelInsetErr
+		}
+		return reportCommissionAmount, nil
+	}
+
+	return 0, nil
+}
+
+// PlatformCost 平台底价成本
+func (l *AgentService) PlatformCost(ctx context.Context, agentID int64, agentProductConfigModel *model.AgentProductConfig, session sqlx.Session) (float64, error) {
+
+	costAgentPlatformDeductionModel := model.AgentPlatformDeduction{
+		AgentId: agentID,
+		Amount:  agentProductConfigModel.CostPrice,
+		Type:    model.AgentDeductionTypeCost,
+	}
+
+	_, err := l.AgentPlatformDeductionModel.Insert(ctx, session, &costAgentPlatformDeductionModel)
+	if err != nil {
+		return 0, err
+	}
+	return agentProductConfigModel.CostPrice, nil
+}
+
+// PlatformPricing 平台提价成本
+func (l *AgentService) PlatformPricing(ctx context.Context, agentID int64, pricing float64, agentProductConfigModel *model.AgentProductConfig, session sqlx.Session) (float64, error) {
+	// 2. 计算平台提价成本
+	if pricing > agentProductConfigModel.PricingStandard {
+		// 超出部分
+		overpricing := pricing - agentProductConfigModel.PricingStandard
+
+		// 收取成本
+		overpricingCost := overpricing * agentProductConfigModel.OverpricingRatio
+
+		pricingAgentPlatformDeductionModel := model.AgentPlatformDeduction{
+			AgentId: agentID,
+			Amount:  overpricingCost,
+			Type:    model.AgentDeductionTypePricing,
+		}
+
+		_, err := l.AgentPlatformDeductionModel.Insert(ctx, session, &pricingAgentPlatformDeductionModel)
+		if err != nil {
+			return 0, err
+		}
+		return overpricingCost, nil
+	}
+	return 0, nil
+}
+
+// CommissionCost 上级底价成本
+func (l *AgentService) CommissionCost(ctx context.Context, descendantId int64, AncestorId int64, agentMembershipConfigModel *model.AgentMembershipConfig, productID int64, session sqlx.Session) (float64, error) {
+	if agentMembershipConfigModel.PriceIncreaseAmount.Valid {
+		// 拥有则查看该上级设定的成本
+		agentMembershipUserConfigModel, findAgentMembershipUserConfigModelErr := l.AgentMembershipUserConfigModel.FindOneByAgentIdProductId(ctx, AncestorId, productID)
+		if findAgentMembershipUserConfigModelErr != nil {
+			// 如果上级没有配置该产品的定价规则，则跳过成本计算
+			if errors.Is(findAgentMembershipUserConfigModelErr, model.ErrNotFound) {
+				return 0, nil
+			}
+			return 0, findAgentMembershipUserConfigModelErr
+		}
+
+		deductCostAmount := agentMembershipUserConfigModel.PriceIncreaseAmount
+
+		agentCommissionDeductionModel := model.AgentCommissionDeduction{
+			AgentId:         AncestorId,
+			DeductedAgentId: descendantId,
+			Amount:          deductCostAmount,
+			Type:            model.AgentDeductionTypeCost,
+			ProductId:       productID,
+		}
+
+		_, insertAgentCommissionDeductionModelErr := l.AgentCommissionDeductionModel.Insert(ctx, session, &agentCommissionDeductionModel)
+		if insertAgentCommissionDeductionModelErr != nil {
+			return 0, insertAgentCommissionDeductionModelErr
+		}
+
+		return deductCostAmount, nil
+	}
+	return 0, nil
+}
+
+// CommissionPricing 上级提价成本
+func (l *AgentService) CommissionPricing(ctx context.Context, descendantId int64, AncestorId int64, agentMembershipConfigModel *model.AgentMembershipConfig, productID int64, pricing float64, session sqlx.Session) (float64, error) {
+	//看上级代理等级否有拥有定价标准收益功能
+	if agentMembershipConfigModel.PriceIncreaseMax.Valid && agentMembershipConfigModel.PriceRatio.Valid {
+		// 拥有则查看该上级设定的成本
+		agentMembershipUserConfigModel, findAgentMembershipUserConfigModelErr := l.AgentMembershipUserConfigModel.FindOneByAgentIdProductId(ctx, AncestorId, productID)
+		if findAgentMembershipUserConfigModelErr != nil {
+			// 如果上级没有配置该产品的定价规则，则跳过成本计算
+			if errors.Is(findAgentMembershipUserConfigModelErr, model.ErrNotFound) {
+				return 0, nil
+			}
+			return 0, findAgentMembershipUserConfigModelErr
+		}
+
+		// 计算是否在范围内
+		var pricingRange float64
+		if pricing > agentMembershipUserConfigModel.PriceRangeFrom {
+			if pricing > agentMembershipUserConfigModel.PriceRangeTo {
+				pricingRange = agentMembershipUserConfigModel.PriceRangeTo - agentMembershipUserConfigModel.PriceRangeFrom
+			} else {
+				pricingRange = pricing - agentMembershipUserConfigModel.PriceRangeFrom
+			}
+		}
+
+		deductCostAmount := pricingRange * agentMembershipUserConfigModel.PriceRatio
+
+		agentCommissionDeductionModel := model.AgentCommissionDeduction{
+			AgentId:         AncestorId,
+			DeductedAgentId: descendantId,
+			Amount:          deductCostAmount,
+			Type:            model.AgentDeductionTypePricing,
+			ProductId:       productID,
+		}
+		_, insertAgentCommissionDeductionModelErr := l.AgentCommissionDeductionModel.Insert(ctx, session, &agentCommissionDeductionModel)
+		if insertAgentCommissionDeductionModelErr != nil {
+			return 0, insertAgentCommissionDeductionModelErr
+		}
+		return deductCostAmount, nil
+	}
+	return 0, nil
+}
+
+// GiveUpgradeReward 给上级代理发放下级升级奖励
+func (l *AgentService) GiveUpgradeReward(ctx context.Context, agentID int64, oldLevel, newLevel string, session sqlx.Session) error {
+	// 查找上级代理
+	agentClosureModel, err := l.AgentClosureModel.FindOneByDescendantIdDepth(ctx, agentID, 1)
+	if err != nil {
+		if errors.Is(err, model.ErrNotFound) {
+			// 没有上级代理，直接返回
+			return nil
+		}
+		return err
+	}
+
+	ancestorID := agentClosureModel.AncestorId
+	ancestorModel, err := l.AgentModel.FindOne(ctx, ancestorID)
+	if err != nil {
+		if errors.Is(err, model.ErrNotFound) {
+			// 上级代理不存在，直接返回
+			return nil
+		}
+		return err
+	}
+	if ancestorModel == nil {
+		// 上级代理不存在，直接返回
+		return nil
+	}
+
+	// 获取上级代理的等级配置
+	if ancestorModel.LevelName == "" {
+		ancestorModel.LevelName = model.AgentLeveNameNormal
+	}
+	agentMembershipConfigModel, err := l.AgentMembershipConfigModel.FindOneByLevelName(ctx, ancestorModel.LevelName)
+	if err != nil {
+		return err
+	}
+
+	// 根据升级路径计算奖励金额差额
+	var rewardAmount float64
+	var rewardType string
+
+	// 获取各等级的奖励金额
+	var vipRewardAmount float64
+	var svipRewardAmount float64
+	
+	if agentMembershipConfigModel.LowerConvertVipReward.Valid {
+		vipRewardAmount = agentMembershipConfigModel.LowerConvertVipReward.Float64
+	}
+	if agentMembershipConfigModel.LowerConvertSvipReward.Valid {
+		svipRewardAmount = agentMembershipConfigModel.LowerConvertSvipReward.Float64
+	}
+
+	// 根据升级路径计算实际奖励金额
+	switch {
+	case oldLevel == "" || oldLevel == model.AgentLeveNameNormal:
+		// 普通代理升级
+		switch newLevel {
+		case model.AgentLeveNameVIP:
+			rewardAmount = vipRewardAmount
+			rewardType = model.AgentRewardsTypeDescendantUpgradeVip
+		case model.AgentLeveNameSVIP:
+			rewardAmount = svipRewardAmount
+			rewardType = model.AgentRewardsTypeDescendantUpgradeSvip
+		default:
+			// 无效的升级路径，直接返回
+			return nil
+		}
+	case oldLevel == model.AgentLeveNameVIP && newLevel == model.AgentLeveNameSVIP:
+		// VIP升级到SVIP，发放差额奖励
+		rewardAmount = svipRewardAmount - vipRewardAmount
+		rewardType = model.AgentRewardsTypeDescendantUpgradeSvip
+		// 如果差额为负数或零，不发放奖励
+		if rewardAmount <= 0 {
+			return nil
+		}
+	default:
+		// 其他无效的升级路径（如SVIP降级等），直接返回
+		return nil
+	}
+
+	// 如果有奖励金额，则发放奖励
+	if rewardAmount > 0 {
+		// 创建奖励记录
+		agentRewards := model.AgentRewards{
+			AgentId:         ancestorID,
+			Amount:          rewardAmount,
+			RelationAgentId: lzUtils.Int64ToNullInt64(agentID),
+			Type:            rewardType,
+		}
+
+		_, err = l.AgentRewardsModel.Insert(ctx, session, &agentRewards)
+		if err != nil {
+			return err
+		}
+
+		// 更新上级代理钱包
+		ancestorWallet, err := l.AgentWalletModel.FindOneByAgentId(ctx, ancestorID)
+		if err != nil {
+			return err
+		}
+
+		ancestorWallet.Balance += rewardAmount
+		ancestorWallet.TotalEarnings += rewardAmount
+		err = l.AgentWalletModel.UpdateWithVersion(ctx, session, ancestorWallet)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+// GiveWithdrawReward 给上级代理发放下级提现奖励
+func (l *AgentService) GiveWithdrawReward(ctx context.Context, agentID int64, withdrawAmount float64, session sqlx.Session) error {
+	// 验证提现金额
+	if withdrawAmount <= 0 {
+		return nil
+	}
+	// 查找上级代理
+	agentClosureModel, err := l.AgentClosureModel.FindOneByDescendantIdDepth(ctx, agentID, 1)
+	if err != nil {
+		if errors.Is(err, model.ErrNotFound) {
+			// 没有上级代理，直接返回
+			return nil
+		}
+		return err
+	}
+
+	ancestorID := agentClosureModel.AncestorId
+	ancestorModel, err := l.AgentModel.FindOne(ctx, ancestorID)
+	if err != nil {
+		if errors.Is(err, model.ErrNotFound) {
+			// 上级代理不存在，直接返回
+			return nil
+		}
+		return err
+	}
+	if ancestorModel == nil {
+		// 上级代理不存在，直接返回
+		return nil
+	}
+
+	// 获取上级代理的等级配置
+	if ancestorModel.LevelName == "" {
+		ancestorModel.LevelName = model.AgentLeveNameNormal
+	}
+	agentMembershipConfigModel, err := l.AgentMembershipConfigModel.FindOneByLevelName(ctx, ancestorModel.LevelName)
+	if err != nil {
+		return err
+	}
+
+	// 计算提现奖励金额
+	if agentMembershipConfigModel.LowerWithdrawRewardRatio.Valid {
+		rewardRatio := agentMembershipConfigModel.LowerWithdrawRewardRatio.Float64
+		// 验证奖励比例的有效性（0-1之间）
+		if rewardRatio < 0 || rewardRatio > 1 {
+			// 无效的奖励比例，直接返回
+			return nil
+		}
+		rewardAmount := withdrawAmount * rewardRatio
+		
+		if rewardAmount > 0 {
+			// 创建奖励记录
+			agentRewards := model.AgentRewards{
+				AgentId:         ancestorID,
+				Amount:          rewardAmount,
+				RelationAgentId: lzUtils.Int64ToNullInt64(agentID),
+				Type:            model.AgentRewardsTypeDescendantWithdraw,
+			}
+
+			_, err = l.AgentRewardsModel.Insert(ctx, session, &agentRewards)
+			if err != nil {
+				return err
+			}
+
+			// 更新上级代理钱包
+			ancestorWallet, err := l.AgentWalletModel.FindOneByAgentId(ctx, ancestorID)
+			if err != nil {
+				return err
+			}
+
+			ancestorWallet.Balance += rewardAmount
+			ancestorWallet.TotalEarnings += rewardAmount
+			err = l.AgentWalletModel.UpdateWithVersion(ctx, session, ancestorWallet)
+			if err != nil {
+				return err
+			}
+		}
+	}
+
+	return nil
+}
+
+// CheckAgentProcessStatus 检查代理处理事务是否已成功
+func (l *AgentService) CheckAgentProcessStatus(ctx context.Context, orderID int64) (bool, error) {
+	// 检查是否存在代理订单记录
+	_, err := l.AgentOrderModel.FindOneByOrderId(ctx, orderID)
+	if err != nil {
+		if errors.Is(err, model.ErrNotFound) {
+			// 没有代理订单记录，说明不是代理推广订单
+			return true, nil
+		}
+		return false, err
+	}
+
+	// 检查是否存在代理佣金记录
+	// 使用SelectBuilder查询该订单的佣金记录
+	selectBuilder := l.AgentCommissionModel.SelectBuilder()
+	selectBuilder = selectBuilder.Where("order_id = ?", orderID)
+	selectBuilder = selectBuilder.Where("del_state = ?", 0) // 未删除
+
+	commissions, err := l.AgentCommissionModel.FindAll(ctx, selectBuilder, "")
+	if err != nil {
+		return false, err
+	}
+
+	// 如果存在佣金记录，说明代理处理已成功
+	return len(commissions) > 0, nil
+}
+
+// RetryAgentProcess 重新执行代理处理事务
+func (l *AgentService) RetryAgentProcess(ctx context.Context, orderID int64) error {
+	// 首先检查订单是否存在
+	order, err := l.OrderModel.FindOne(ctx, orderID)
+	if err != nil {
+		return err
+	}
+
+	// 检查订单状态是否为已支付
+	if order.Status != "paid" {
+		return errors.New("订单状态不是已支付，无法执行代理处理")
+	}
+
+	// 检查代理处理是否已经成功
+	alreadyProcessed, err := l.CheckAgentProcessStatus(ctx, orderID)
+	if err != nil {
+		return err
+	}
+
+	if alreadyProcessed {
+		return errors.New("代理处理已经成功，无需重新执行")
+	}
+
+	// 执行代理处理
+	return l.AgentProcess(ctx, order)
+}