kknongchang_2506/app/Module/AppGame/Handler/Shop/BuyHandler.php

<?php

namespace App\Module\AppGame\Handler\Shop;

use App\Module\AppGame\Handler\BaseHandler;
use App\Module\Fund\Enums\LOG_TYPE;
use App\Module\Fund\Logic\User as FundUser;
use App\Module\GameItems\Services\ItemService;

use App\Module\Shop\Validations\ShopBuyValidation;
use Google\Protobuf\Internal\Message;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Uraus\Kku\Request\RequestShopBuy;
use Uraus\Kku\Response\ResponseShopBuy;
use UCore\Exception\LogicException;

/**
 * 处理商品购买请求
 */
class BuyHandler extends BaseHandler
{
    /**
     * 是否需要登录
     * @var bool
     */
    protected bool $need_login = true;

    /**
     * 处理商品购买请求
     *
     * @param RequestShopBuy $data 商品购买请求数据
     * @return ResponseShopBuy 商品购买响应
     */
    public function handle(Message $data): Message
    {
        // 创建响应对象
        $response = new ResponseShopBuy();

        try {
            // 获取请求参数
            $goodId = $data->getGoodId();
            $number = $data->getNumber();
            $userId = $this->user_id;

            // 先进行验证，避免不必要的事务开销
            $validation = new ShopBuyValidation([
                'user_id' => $userId,
                'good_id' => $goodId,
                'number' => $number
            ]);

            // 验证数据
            $validation->validated();

            // 从验证结果中获取商品信息
            $shopItem = $validation->shop_item;
            $totalPrice = $shopItem->price * $number;

            // 验证通过后，开启事务
            DB::beginTransaction();

            // 扣除用户货币
            $fundResult = FundUser::handle(
                $userId,
                $shopItem->currency_id,
                -$totalPrice,
                LOG_TYPE::TRADE,
                $goodId,
                "购买商品：{$shopItem->name} x {$number}"
            );

            if (is_string($fundResult)) {
                throw new LogicException("购买失败：" . $fundResult);
            }

            // 添加物品到用户背包
            ItemService::addItem(
                $userId,
                $shopItem->item_id,
                $number * $shopItem->item_quantity,
                [
                    'source_type' => 'shop_buy',
                    'source_id' => $goodId,
                    'details' => [
                        'shop_item_id' => $goodId,
                        'shop_item_name' => $shopItem->name,
                        'price' => $shopItem->price,
                        'quantity' => $number
                    ]
                ]
            );

            // 记录购买记录
            $shopItem->recordPurchase($userId, $number, $totalPrice);

            // 提交事务
            DB::commit();

            // 设置响应状态
            $this->response->setCode(0);
            $this->response->setMsg('购买成功');

            // 记录日志
            Log::info('用户购买商品成功', [
                'user_id' => $userId,
                'good_id' => $goodId,
                'number' => $number,
                'total_price' => $totalPrice,
                'item_id' => $shopItem->item_id,
                'item_quantity' => $shopItem->item_quantity
            ]);

        } catch (\UCore\Exception\ValidateException $e) {
            // 验证失败，此时可能还没有开启事务
            $this->response->setCode(400);
            $this->response->setMsg($e->getMessage());

            Log::warning('商品购买验证失败', [
                'user_id' => $userId ?? null,
                'good_id' => $goodId ?? null,
                'number' => $number ?? null,
                'error' => $e->getMessage()
            ]);

        } catch (LogicException $e) {
            // 业务逻辑异常，需要回滚事务
            if (DB::transactionLevel() > 0) {
                DB::rollBack();
            }

            $this->response->setCode(400);
            $this->response->setMsg($e->getMessage());

            Log::warning('用户购买商品失败', [
                'user_id' => $userId ?? null,
                'good_id' => $goodId ?? null,
                'number' => $number ?? null,
                'error' => $e->getMessage()
            ]);

        } catch (\Exception $e) {
            // 系统异常，需要回滚事务
            if (DB::transactionLevel() > 0) {
                DB::rollBack();
            }

            $this->response->setCode(500);
            $this->response->setMsg('系统错误，请稍后再试');

            Log::error('购买商品操作异常', [
                'user_id' => $userId ?? null,
                'good_id' => $goodId ?? null,
                'number' => $number ?? null,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);
        }

        return $response;
    }
}