kknongchang_2506/app/Module/UrsPromotion/Logics/UrsPartnerDividendLogic.php

<?php

namespace App\Module\UrsPromotion\Logics;

use App\Module\UrsPromotion\Models\UrsPartnerDividendRecord;
use App\Module\UrsPromotion\Models\UrsPartnerDividendDetail;
use App\Module\UrsPromotion\Models\UrsUserTalent;
use App\Module\UrsPromotion\Services\UrsUserMappingService;
use App\Module\Transfer\Services\FeeStatisticsService;
use App\Module\Transfer\Services\FeeService;
use App\Module\Transfer\Models\TransferApp;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Carbon\Carbon;

/**
 * URS合伙人分红逻辑类
 *
 * 处理合伙人分红的核心业务逻辑
 */
class UrsPartnerDividendLogic
{
    /**
     * 分红比例 (20%)
     */
    const DIVIDEND_RATE = 0.20;

    /**
     * 合伙人等级 (顶级达人)
     */
    const PARTNER_LEVEL = 5;

    /**
     * 执行每日合伙人分红
     *
     * @param string|null $date 分红日期，默认为今天
     * @return array 分红结果
     */
    public function executeDailyDividend(?string $date = null): array
    {
        $date = $date ?: Carbon::today()->format('Y-m-d');

        Log::info("开始执行合伙人分红", ['date' => $date]);

        // 检查是否已经分红
        $existingRecord = UrsPartnerDividendRecord::getByDate($date);
        if ($existingRecord && $existingRecord->status === UrsPartnerDividendRecord::STATUS_COMPLETED) {
            $message = "日期 {$date} 的分红已经完成";
            Log::warning($message);
            return ['success' => false, 'message' => $message];
        }
        $transferAppId = 2;
        try {
            // 1. 获取今日手续费统计
            $totalFeeAmount = $this->getTodayTotalFeeAmount($date,$transferAppId);
            if ($totalFeeAmount <= 0) {
                $message = "日期 {$date} 没有手续费收入，无需分红";
                Log::info($message);
                return ['success' => false, 'message' => $message];
            }

            // 2. 计算分红金额 (总手续费的20%)
            $dividendAmount = bcmul($totalFeeAmount, self::DIVIDEND_RATE, 10);

            // 3. 获取所有合伙人
            $partners = $this->getAllPartners();
            if (empty($partners)) {
                $message = "没有找到合伙人，无需分红";
                Log::info($message);
                return ['success' => false, 'message' => $message];
            }

            // 4. 计算每个合伙人的分红金额
            $partnerCount = count($partners);
            $perPartnerAmount = bcdiv($dividendAmount, $partnerCount, 10);

            // 5. 创建或获取分红记录（幂等性）
            $dividendRecord = $this->createOrGetDividendRecord($date, $totalFeeAmount, $dividendAmount, $partnerCount, $perPartnerAmount,$transferAppId);

            // 6. 分批处理分红详情
            $result = $this->processDividendDetailsBatch($dividendRecord, $partners, $perPartnerAmount);

            // 7. 更新分红记录状态
            $this->updateDividendRecordStatus($dividendRecord, $result);

            Log::info("合伙人分红执行完成", [
                'date' => $date,
                'total_fee_amount' => $totalFeeAmount,
                'dividend_amount' => $dividendAmount,
                'partner_count' => $partnerCount,
                'per_partner_amount' => $perPartnerAmount,
                'success_count' => $result['success_count'],
                'failed_count' => $result['failed_count']
            ]);

            return [
                'success' => true,
                'message' => '分红执行完成',
                'data' => [
                    'date' => $date,
                    'total_fee_amount' => $totalFeeAmount,
                    'dividend_amount' => $dividendAmount,
                    'partner_count' => $partnerCount,
                    'per_partner_amount' => $perPartnerAmount,
                    'success_count' => $result['success_count'],
                    'failed_count' => $result['failed_count']
                ]
            ];

        } catch (\Exception $e) {
            Log::error("合伙人分红执行失败", [
                'date' => $date,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);

            return [
                'success' => false,
                'message' => '分红执行失败: ' . $e->getMessage()
            ];
        }
    }

    /**
     * 获取今日总手续费金额
     */
    private function getTodayTotalFeeAmount(string $date,$appId): string
    {
        try {
            // 获取所有应用的手续费统计
            $result = FeeStatisticsService::getStatsByDateRange($date, $date,$appId);

            // 检查是否有错误
            if (isset($result['error'])) {
                Log::warning("获取手续费统计有错误", [
                    'date' => $date,
                    'error' => $result['error']
                ]);
                return '0.0000000000';
            }

            // 从返回结果中获取数据
            $stats = $result['data'] ?? [];

            $totalFee = '0.0000000000';
            foreach ($stats as $stat) {
                // $stat是数组格式，不是对象
                $feeAmount = $stat['total_fee_amount'] ?? '0.0000000000';
                $totalFee = bcadd($totalFee, $feeAmount, 10);
            }

            Log::info("获取今日手续费统计", [
                'date' => $date,
                'total_fee' => $totalFee,
                'stats_count' => count($stats)
            ]);

            return $totalFee;

        } catch (\Exception $e) {
            Log::error("获取今日手续费统计失败", [
                'date' => $date,
                'error' => $e->getMessage()
            ]);
            return '0.0000000000';
        }
    }

    /**
     * 获取所有合伙人
     */
    private function getAllPartners(): array
    {
        // 获取所有顶级达人(合伙人)
        $talents = UrsUserTalent::where('talent_level', self::PARTNER_LEVEL)
            ->get();

        $partners = [];
        foreach ($talents as $talent) {
            // UrsUserTalent表中的user_id就是农场用户ID
            $userId = $talent->user_id;

            // 获取对应的URS用户ID
            $ursUserId = UrsUserMappingService::getMappingUrsUserId($userId);

            if ($ursUserId) {
                $partners[] = [
                    'user_id' => $userId,
                    'urs_user_id' => $ursUserId,
                    'talent_level' => $talent->talent_level
                ];
            }
        }

        Log::info("获取合伙人列表", [
            'total_talents' => $talents->count(),
            'valid_partners' => count($partners)
        ]);

        return $partners;
    }

    /**
     * 创建或获取分红记录（幂等性）
     */
    private function createOrGetDividendRecord(string $date, string $totalFeeAmount, string $dividendAmount, int $partnerCount, string $perPartnerAmount,int $transferAppId): UrsPartnerDividendRecord
    {
        // 先尝试获取已存在的记录
        $existingRecord = UrsPartnerDividendRecord::getByDate($date);
        if ($existingRecord) {
            // 如果状态是失败，重置为处理中
            if ($existingRecord->status === UrsPartnerDividendRecord::STATUS_FAILED) {
                $existingRecord->update(['status' => UrsPartnerDividendRecord::STATUS_PROCESSING]);
            }
            return $existingRecord;
        }




        return UrsPartnerDividendRecord::create([
            'dividend_date' => $date,
            'total_fee_amount' => $totalFeeAmount,
            'dividend_amount' => $dividendAmount,
            'partner_count' => $partnerCount,
            'per_partner_amount' => $perPartnerAmount,
            'transfer_app_id' => $transferAppId,
            'status' => UrsPartnerDividendRecord::STATUS_PROCESSING
        ]);
    }

    /**
     * 分批处理分红详情并执行转账
     */
    private function processDividendDetailsBatch(UrsPartnerDividendRecord $dividendRecord, array $partners, string $perPartnerAmount): array
    {
        $batchSize = 10; // 每批处理10个合伙人
        $totalSuccessCount = 0;
        $totalFailedCount = 0;

        // 先创建所有分红详情记录（如果不存在）
        $this->createDividendDetailsIfNotExists($dividendRecord, $partners, $perPartnerAmount);

        // 获取所有待处理的分红详情
        $pendingDetails = UrsPartnerDividendDetail::where('dividend_record_id', $dividendRecord->id)
            ->where('status', UrsPartnerDividendDetail::STATUS_PENDING)
            ->get();

        Log::info("开始分批处理分红详情", [
            'total_partners' => count($partners),
            'pending_details' => $pendingDetails->count(),
            'batch_size' => $batchSize
        ]);

        // 分批处理
        $batches = $pendingDetails->chunk($batchSize);
        foreach ($batches as $batchIndex => $batch) {
            Log::info("处理第 " . ($batchIndex + 1) . " 批分红", [
                'batch_size' => $batch->count()
            ]);

            $batchResult = $this->processSingleBatch($dividendRecord, $batch, $perPartnerAmount);
            $totalSuccessCount += $batchResult['success_count'];
            $totalFailedCount += $batchResult['failed_count'];

            // 批次间短暂休息，避免系统压力过大
            if ($batchIndex < $batches->count() - 1) {
                usleep(100000); // 休息0.1秒
            }
        }

        return [
            'success_count' => $totalSuccessCount,
            'failed_count' => $totalFailedCount
        ];
    }

    /**
     * 创建分红详情记录（如果不存在）
     */
    private function createDividendDetailsIfNotExists(UrsPartnerDividendRecord $dividendRecord, array $partners, string $perPartnerAmount): void
    {
        foreach ($partners as $partner) {
            // 检查是否已存在
            $existingDetail = UrsPartnerDividendDetail::where('dividend_record_id', $dividendRecord->id)
                ->where('user_id', $partner['user_id'])
                ->first();

            if (!$existingDetail) {
                UrsPartnerDividendDetail::create([
                    'dividend_record_id' => $dividendRecord->id,
                    'user_id' => $partner['user_id'],
                    'urs_user_id' => $partner['urs_user_id'],
                    'talent_level' => $partner['talent_level'],
                    'dividend_amount' => $perPartnerAmount,
                    'status' => UrsPartnerDividendDetail::STATUS_PENDING
                ]);
            }
        }
    }

    /**
     * 处理单个批次
     */
    private function processSingleBatch(UrsPartnerDividendRecord $dividendRecord, $batch, string $perPartnerAmount): array
    {
        $successCount = 0;
        $failedCount = 0;

        foreach ($batch as $detail) {
            try {
                // 特殊情况：批量分红需要独立事务处理每个转账，确保单个失败不影响其他转账
                // 这是业务需求，与一般Logic层规范不同
                DB::transaction(function () use ($detail, $dividendRecord, $perPartnerAmount, &$successCount, &$failedCount) {
                    // 执行手续费转移
                    $transferResult = FeeService::transfer(
                        $dividendRecord->transfer_app_id,
                        $detail->user_id,
                        floatval($perPartnerAmount),
                        $dividendRecord->id,
                        'partner_dividend'
                    );

                    if ($transferResult === true) {
                        // 转账成功
                        $detail->update([
                            'status' => UrsPartnerDividendDetail::STATUS_COMPLETED
                        ]);
                        $successCount++;

                        Log::info("合伙人分红转账成功", [
                            'user_id' => $detail->user_id,
                            'urs_user_id' => $detail->urs_user_id,
                            'amount' => $perPartnerAmount
                        ]);
                    } else {
                        // 转账失败
                        $detail->update([
                            'status' => UrsPartnerDividendDetail::STATUS_FAILED,
                            'error_message' => is_string($transferResult) ? $transferResult : '转账失败'
                        ]);
                        $failedCount++;

                        Log::error("合伙人分红转账失败", [
                            'user_id' => $detail->user_id,
                            'urs_user_id' => $detail->urs_user_id,
                            'amount' => $perPartnerAmount,
                            'error' => $transferResult
                        ]);
                    }
                });

            } catch (\Exception $e) {
                $failedCount++;

                // 更新详情状态为失败
                try {
                    $detail->update([
                        'status' => UrsPartnerDividendDetail::STATUS_FAILED,
                        'error_message' => $e->getMessage()
                    ]);
                } catch (\Exception $updateException) {
                    Log::error("更新分红详情状态失败", [
                        'detail_id' => $detail->id,
                        'error' => $updateException->getMessage()
                    ]);
                }

                Log::error("处理合伙人分红详情失败", [
                    'user_id' => $detail->user_id,
                    'urs_user_id' => $detail->urs_user_id,
                    'error' => $e->getMessage()
                ]);
            }
        }

        return [
            'success_count' => $successCount,
            'failed_count' => $failedCount
        ];
    }

    /**
     * 更新分红记录状态
     */
    private function updateDividendRecordStatus(UrsPartnerDividendRecord $dividendRecord, array $result): void
    {
        if ($result['failed_count'] == 0) {
            // 全部成功
            $dividendRecord->update(['status' => UrsPartnerDividendRecord::STATUS_COMPLETED]);
        } else if ($result['success_count'] == 0) {
            // 全部失败
            $dividendRecord->update([
                'status' => UrsPartnerDividendRecord::STATUS_FAILED,
                'error_message' => '所有分红转账都失败了'
            ]);
        } else {
            // 部分成功
            $dividendRecord->update([
                'status' => UrsPartnerDividendRecord::STATUS_COMPLETED,
                'error_message' => "部分转账失败，成功{$result['success_count']}个，失败{$result['failed_count']}个"
            ]);
        }
    }

    /**
     * 重试失败的分红
     *
     * @param string $date 分红日期
     * @return array 重试结果
     */
    public function retryFailedDividend(string $date): array
    {
        Log::info("开始重试失败的分红", ['date' => $date]);

        $dividendRecord = UrsPartnerDividendRecord::getByDate($date);
        if (!$dividendRecord) {
            return ['success' => false, 'message' => '分红记录不存在'];
        }

        // 获取失败的分红详情
        $failedDetails = UrsPartnerDividendDetail::where('dividend_record_id', $dividendRecord->id)
            ->where('status', UrsPartnerDividendDetail::STATUS_FAILED)
            ->get();

        if ($failedDetails->isEmpty()) {
            return ['success' => false, 'message' => '没有失败的分红记录需要重试'];
        }

        Log::info("找到失败的分红记录", ['count' => $failedDetails->count()]);

        $successCount = 0;
        $failedCount = 0;

        foreach ($failedDetails as $detail) {
            try {
                // 重置状态为待处理
                $detail->update([
                    'status' => UrsPartnerDividendDetail::STATUS_PENDING,
                    'error_message' => null
                ]);

                // 重新执行转账
                DB::transaction(function () use ($detail, $dividendRecord, &$successCount, &$failedCount) {
                    $transferResult = FeeService::transfer(
                        $dividendRecord->transfer_app_id,
                        $detail->user_id,
                        floatval($detail->dividend_amount),
                        $dividendRecord->id,
                        'partner_dividend_retry'
                    );

                    if ($transferResult === true) {
                        $detail->update(['status' => UrsPartnerDividendDetail::STATUS_COMPLETED]);
                        $successCount++;

                        Log::info("重试分红转账成功", [
                            'user_id' => $detail->user_id,
                            'amount' => $detail->dividend_amount
                        ]);
                    } else {
                        $detail->update([
                            'status' => UrsPartnerDividendDetail::STATUS_FAILED,
                            'error_message' => is_string($transferResult) ? $transferResult : '重试转账失败'
                        ]);
                        $failedCount++;

                        Log::error("重试分红转账失败", [
                            'user_id' => $detail->user_id,
                            'error' => $transferResult
                        ]);
                    }
                });

            } catch (\Exception $e) {
                $failedCount++;
                $detail->update([
                    'status' => UrsPartnerDividendDetail::STATUS_FAILED,
                    'error_message' => '重试异常: ' . $e->getMessage()
                ]);

                Log::error("重试分红异常", [
                    'user_id' => $detail->user_id,
                    'error' => $e->getMessage()
                ]);
            }
        }

        // 更新分红记录状态
        $this->updateDividendRecordStatus($dividendRecord, [
            'success_count' => $successCount,
            'failed_count' => $failedCount
        ]);

        return [
            'success' => true,
            'message' => '重试完成',
            'data' => [
                'retry_count' => $failedDetails->count(),
                'success_count' => $successCount,
                'failed_count' => $failedCount
            ]
        ];
    }
}