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; } }