kknongchang_2506/app/Module/Mex/Logic/MexOrderLogic.php

<?php

namespace App\Module\Mex\Logic;

use App\Module\Mex\Models\MexOrder;
use App\Module\Mex\Models\MexPriceConfig;
use App\Module\Mex\Enums\OrderType;
use App\Module\Mex\Enums\OrderStatus;
use App\Module\Mex\Events\OrderCreatedEvent;
use App\Module\Fund\Enums\FUND_CURRENCY_TYPE;
use App\Module\Mex\Logic\FundLogic;
use App\Module\GameItems\Services\ItemService;
use App\Module\GameItems\Enums\FREEZE_REASON_TYPE;
use Illuminate\Support\Facades\DB;

/**
 * 农贸市场订单逻辑
 * 
 * 处理订单相关的核心业务逻辑
 */
class MexOrderLogic
{
    /**
     * 创建卖出订单
     *
     * @param int $userId 用户ID
     * @param int $itemId 商品ID
     * @param int $quantity 数量
     * @param float $price 价格（信任Fund模块的数据处理）
     * @param FUND_CURRENCY_TYPE|null $currencyType 币种类型，默认使用钻石
     * @return array 操作结果
     */
    public static function createSellOrder(int $userId, int $itemId, int $quantity, float $price, ?FUND_CURRENCY_TYPE $currencyType = null): array
    {
        // 获取币种类型，默认使用钻石
        $currencyType = $currencyType ?? FundLogic::getDefaultCurrency();

        // 验证价格配置是否存在（不验证价格范围，挂单阶段无价格验证）
        $priceConfig = MexPriceConfig::where('item_id', $itemId)->where('is_enabled', true)->first();
        if (!$priceConfig) {
            return ['success' => false, 'message' => '商品未配置价格信息'];
        }

        // 直接计算总金额，信任Fund模块的精度处理
        $totalAmount = $price * $quantity;

        return DB::transaction(function () use ($userId, $itemId, $quantity, $price, $currencyType, $totalAmount) {
            try {
                // 1. 验证用户是否有足够的物品
                $checkResult = ItemService::checkItemQuantity($userId, $itemId, $quantity);
                if (!$checkResult->success) {
                    return ['success' => false, 'message' => $checkResult->message];
                }

                // 2. 创建订单记录
                $order = MexOrder::create([
                    'user_id' => $userId,
                    'item_id' => $itemId,
                    'currency_type' => $currencyType->value,
                    'order_type' => OrderType::SELL,
                    'quantity' => $quantity,
                    'price' => $price,
                    'total_amount' => $totalAmount,
                    'status' => OrderStatus::PENDING,
                ]);

                // 3. 冻结用户物品
                $freezeResult = ItemService::freezeItem(
                    $userId,
                    $itemId,
                    null, // 统一属性物品，不需要实例ID
                    $quantity,
                    "农贸市场卖出订单冻结，订单ID：{$order->id}",
                    [
                        'reason_type' => FREEZE_REASON_TYPE::TRADE_ORDER->value,
                        'source_id' => $order->id,
                        'source_type' => 'mex_sell_order',
                    ]
                );

                if (!$freezeResult['success']) {
                    throw new \Exception('冻结物品失败：' . $freezeResult['message']);
                }

                // 4. 触发订单创建事件
                event(new OrderCreatedEvent($order));

                return [
                    'success' => true,
                    'order_id' => $order->id,
                    'freeze_log_id' => $freezeResult['freeze_log_id'] ?? null,
                    'message' => '卖出订单创建成功，等待撮合'
                ];
            } catch (\Exception $e) {
                return ['success' => false, 'message' => '创建订单失败：' . $e->getMessage()];
            }
        });
    }

    /**
     * 创建买入订单
     *
     * @param int $userId 用户ID
     * @param int $itemId 商品ID
     * @param int $quantity 数量
     * @param float $price 价格（信任Fund模块的数据处理）
     * @param FUND_CURRENCY_TYPE|null $currencyType 币种类型，默认使用钻石
     * @return array 操作结果
     */
    public static function createBuyOrder(int $userId, int $itemId, int $quantity, float $price, ?FUND_CURRENCY_TYPE $currencyType = null): array
    {
        // 获取币种类型，默认使用钻石
        $currencyType = $currencyType ?? FundLogic::getDefaultCurrency();

        // 验证价格配置是否存在（不验证价格范围和保护阈值，挂单阶段无价格验证）
        $priceConfig = MexPriceConfig::where('item_id', $itemId)->where('is_enabled', true)->first();
        if (!$priceConfig) {
            return ['success' => false, 'message' => '商品未配置价格信息'];
        }

        // 直接计算总金额，信任Fund模块的精度处理
        $totalAmount = $price * $quantity;

        try {
            $order = MexOrder::create([
                'user_id' => $userId,
                'item_id' => $itemId,
                'currency_type' => $currencyType->value,
                'order_type' => OrderType::BUY,
                'quantity' => $quantity,
                'price' => $price,
                'total_amount' => $totalAmount,
                'status' => OrderStatus::PENDING,
                'frozen_amount' => $totalAmount,
            ]);

            // 触发订单创建事件
            event(new OrderCreatedEvent($order));

            return [
                'success' => true,
                'order_id' => $order->id,
                'message' => '买入订单创建成功，等待撮合'
            ];
        } catch (\Exception $e) {
            return ['success' => false, 'message' => '创建订单失败：' . $e->getMessage()];
        }
    }



    /**
     * 取消订单
     * 
     * @param int $userId 用户ID
     * @param int $orderId 订单ID
     * @return array 操作结果
     */
    public static function cancelOrder(int $userId, int $orderId): array
    {
        $order = MexOrder::where('id', $orderId)->where('user_id', $userId)->first();
        if (!$order) {
            return ['success' => false, 'message' => '订单不存在'];
        }

        if ($order->status !== OrderStatus::PENDING) {
            return ['success' => false, 'message' => '只能取消等待中的订单'];
        }

        try {
            $order->update(['status' => OrderStatus::CANCELLED]);
            return ['success' => true, 'message' => '订单已取消'];
        } catch (\Exception $e) {
            return ['success' => false, 'message' => '取消订单失败：' . $e->getMessage()];
        }
    }

    /**
     * 获取用户订单列表
     * 
     * @param int $userId 用户ID
     * @param int $page 页码
     * @param int $pageSize 每页数量
     * @return array 订单列表
     */
    public static function getUserOrders(int $userId, int $page = 1, int $pageSize = 20): array
    {
        $orders = MexOrder::where('user_id', $userId)
            ->orderBy('created_at', 'desc')
            ->paginate($pageSize, ['*'], 'page', $page);

        return [
            'orders' => $orders->items(),
            'total' => $orders->total(),
            'page' => $page,
            'page_size' => $pageSize,
        ];
    }

    /**
     * 获取订单详情
     * 
     * @param int $userId 用户ID
     * @param int $orderId 订单ID
     * @return array|null 订单详情
     */
    public static function getOrderDetail(int $userId, int $orderId): ?array
    {
        $order = MexOrder::where('id', $orderId)->where('user_id', $userId)->first();
        return $order ? $order->toArray() : null;
    }

    /**
     * 获取待撮合的买入订单
     * 根据文档要求：二级排序（价格DESC + 时间ASC），移除数量排序
     *
     * @param int $itemId 商品ID
     * @param int $limit 限制数量
     * @return array 订单列表
     */
    public static function getPendingBuyOrders(int $itemId, int $limit = 100): array
    {
        $orders = MexOrder::where('item_id', $itemId)
            ->where('order_type', OrderType::BUY)
            ->where('status', OrderStatus::PENDING)
            ->orderBy('price', 'desc')      // 价格优先（高价优先）
            ->orderBy('created_at', 'asc')  // 时间优先（早下单优先）
            ->limit($limit)
            ->get();

        return $orders->toArray();
    }
}