kknongchang_2506/app/Module/Game/Logics/ConsumeProcessors/FundConfigsConsume.php

<?php

namespace App\Module\Game\Logics\ConsumeProcessors;

use App\Module\Fund\Enums\LOG_TYPE as FUND_LOG_TYPE;
use App\Module\Fund\Logic\User as FundLogic;
use App\Module\Game\Models\GameConsumeItem;
use UCore\Dto\Res;

class FundConfigsConsume
{

    /**
     * 检查多账户种类消耗
     *
     * 注意：这里的target_id指向fund_config表的id（主账户种类ID），
     * extra_data中存储多个账户种类ID的数组，按照顺序依次消耗
     *
     * @param int $userId 用户ID
     * @param GameConsumeItem $consumeItem 消耗项
     * @param float $multiplier 倍数，用于验证几倍消耗，默认为1
     * @return Res 检查结果
     */
    public static function checkFundConfigsConsume(int $userId, GameConsumeItem $consumeItem, float $multiplier = 1.0): Res
    {
        $amount = $consumeItem->quantity * $multiplier; // 使用倍数计算所需金额

        // 获取账户种类ID列表
        $fundConfigIds = self::getFundConfigIds($consumeItem);

        if (empty($fundConfigIds)) {
            return Res::error("多账户种类配置错误：未找到有效的账户种类ID", [
                'fund_config_ids' => []
            ]);
        }

        // 检查每个账户的余额
        $totalBalance = 0;
        $accountBalances = [];

        foreach ($fundConfigIds as $fundConfigId) {
            // 获取用户账户
            $account = FundLogic::get_account($userId, $fundConfigId);

            if ($account === false) {
                // 如果某个账户不存在，余额为0
                $accountBalances[$fundConfigId] = 0;
            } else {
                $accountBalances[$fundConfigId] = $account->balance;
                $totalBalance += $account->balance;
            }
        }

        // 检查总余额是否足够
        if ($totalBalance < $amount) {
            return Res::error("多账户种类总余额不足，需要 {$amount}，实际 {$totalBalance}", [
                'fund_config_ids' => $fundConfigIds,
                'required'        => $amount,
                'actual'          => $totalBalance,
                'account_balances' => $accountBalances
            ]);
        }

        return Res::success('多账户种类总余额足够', [
            'fund_config_ids'  => $fundConfigIds,
            'required'         => $amount,
            'actual'           => $totalBalance,
            'account_balances' => $accountBalances
        ]);
    }

    public static function process(int $userId, GameConsumeItem $consumeItem, string $source, int $sourceId,$multiplier): Res
    {

        $amountToConsume = $consumeItem->quantity * $multiplier; // 使用倍数计算实际消耗金额

        // 获取账户种类ID列表
        $fundConfigIds = self::getFundConfigIds($consumeItem);

        if (empty($fundConfigIds)) {
            return Res::error("多账户种类配置错误：未找到有效的账户种类ID", [
                'fund_config_ids' => []
            ]);
        }

        // 先检查是否有足够的余额（使用相同的倍数）
        $checkResult = self::checkFundConfigsConsume($userId, $consumeItem, $multiplier);
        if (!$checkResult->success) {
            return $checkResult;
        }

        try {
            // 验证事务是否已开启（由调用者负责事务管理）
            \UCore\Db\Helper::check_tr();

            $remainingAmount = $amountToConsume;
            $consumedAccounts = [];

            // 按照配置的顺序依次从各个账户中扣除
            foreach ($fundConfigIds as $fundConfigId) {
                if ($remainingAmount <= 0) {
                    break;
                }

                // 获取用户账户
                $account = FundLogic::get_account($userId, $fundConfigId);

                if ($account === false || $account->balance <= 0) {
                    // 账户不存在或余额为0，跳过
                    continue;
                }

                $accountBalance = $account->balance;
                $amountToDeduct = min($accountBalance, $remainingAmount);

                if ($amountToDeduct > 0) {
                    // 构建备注
                    $remark = "多账户消耗组:{$consumeItem->group_id},来源:{$source}";
                    if ($sourceId > 0) {
                        $remark .= ",ID:{$sourceId}";
                    }
                    if ($multiplier != 1.0) {
                        $remark .= ",倍数:{$multiplier}";
                    }

                    // 从当前账户扣除
                    $result = FundLogic::handle(
                        $userId,
                        $fundConfigId,
                        -$amountToDeduct, // 负数表示消耗
                        FUND_LOG_TYPE::TRADE,
                        $sourceId,
                        $remark
                    );

                    if ($result !== true) {
                        $errorMessage = is_string($result) ? $result : "从账户 {$fundConfigId} 扣除失败";
                        return Res::error($errorMessage, [
                            'fund_config_ids' => $fundConfigIds,
                            'fund_config_id'  => $fundConfigId,
                            'amount'          => $amountToDeduct
                        ]);
                    }

                    $consumedAccounts[] = [
                        'fund_config_id' => $fundConfigId,
                        'amount'         => $amountToDeduct
                    ];

                    $remainingAmount -= $amountToDeduct;
                }
            }

            return Res::success('多账户种类消耗成功', [
                'fund_config_ids'  => $fundConfigIds,
                'amount'           => $amountToConsume,
                'consumed_accounts' => $consumedAccounts
            ]);
        } catch (\Exception $e) {
            return Res::error('多账户种类消耗异常: ' . $e->getMessage(), [
                'fund_config_ids' => $fundConfigIds,
                'amount'          => $amountToConsume
            ]);
        }
    }

    /**
     * 获取消耗项的账户种类ID列表
     *
     * @param GameConsumeItem $consumeItem 消耗项
     * @return array 账户种类ID列表
     */
    protected static function getFundConfigIds(GameConsumeItem $consumeItem): array
    {
        $fundConfigIds = [];

        // 首先添加主账户种类ID（target_id）
        if ($consumeItem->target_id > 0) {
            $fundConfigIds[] = $consumeItem->target_id;
        }

        // 然后从extra_data中获取额外的账户种类ID
        if (!empty($consumeItem->extra_data) && is_array($consumeItem->extra_data)) {
            if (isset($consumeItem->extra_data['fund_config_ids']) && is_array($consumeItem->extra_data['fund_config_ids'])) {
                foreach ($consumeItem->extra_data['fund_config_ids'] as $id) {
                    if (is_numeric($id) && $id > 0 && !in_array($id, $fundConfigIds)) {
                        $fundConfigIds[] = (int)$id;
                    }
                }
            }
        }

        return $fundConfigIds;
    }
}