owl-admin/app/Services/Coach/OrderService.php

<?php

namespace App\Services\Coach;

use App\Enums\OrderGrabRecordStatus;
use App\Enums\OrderRecordStatus;
use App\Enums\OrderStatus;
use App\Enums\OrderType;
use App\Enums\ProjectStatus;
use App\Enums\TechnicianAuthStatus;
use App\Enums\TechnicianLocationType;
use App\Enums\TechnicianStatus;
use App\Jobs\AutoFinishOrder;
use App\Models\CoachUser;
use App\Models\MemberUser;
use App\Models\Order;
use App\Models\OrderGrabRecord;
use App\Models\OrderRecord;
use App\Services\SettingItemService;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;

class OrderService
{
    private const DEFAULT_PER_PAGE = 10;

    private const MAX_DISTANCE = 40; // 最大距离限制（公里）

    private SettingItemService $settingService;

    public function __construct(SettingItemService $settingService)
    {
        $this->settingService = $settingService;
    }

    /**
     * 获取技师的订单列表
     *
     * @param  int  $userId  技师用户ID
     * @param  array  $params  请求参数
     * @return \Illuminate\Pagination\LengthAwarePaginator
     */
    public function getOrderList(int $userId, array $params)
    {
        return DB::transaction(function () use ($userId, $params) {
            try {
                // 加载技师用户信息
                $user = MemberUser::findOrFail($userId);
                $coach = $user->coach;
                abort_if(! $coach, 404, '技师不存在');

                // 构建订单查询
                $query = $coach->orders()->whereNotIn('state', [
                    OrderStatus::CREATED->value,
                    OrderStatus::ASSIGNED->value,
                ])
                    ->orderBy('created_at', 'desc');

                // 分页获取数据
                $paginator = $query->paginate(
                    $params['per_page'] ?? 10,
                    ['*'],
                    'page',
                    $params['page'] ?? 1
                );

                // 需要加载关联数据
                $items = collect($paginator->items())->map(function ($order) {
                    $order->type_text = OrderType::from($order->type)->label();
                    $order->state_text = OrderStatus::from($order->state)->label();

                    return $order;
                });
                $query->with(['project']); // 加载项目信息以便返回project_name等字段

                return [
                    'items' => $items,
                    'total' => $paginator->total(),
                ];

            } catch (\Exception $e) {
                Log::error('获取技师订单列表失败', [
                    'user_id' => $userId,
                    'error_message' => $e->getMessage(),
                    'error_trace' => $e->getTraceAsString(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 获取可抢订单列表
     *
     * @param  int  $userId  技师用户ID
     * @param  array  $params  请求参数
     * @return \Illuminate\Pagination\LengthAwarePaginator
     */
    public function getGrabList(int $userId, array $params)
    {
        try {
            // 加载用户和技师信息
            $user = MemberUser::with([
                'coach',
                'coach.info',
                'coach.real',
                'coach.qual',
                'coach.locations',
                'coach.projects',
            ])->findOrFail($userId);

            // 验证技师信息
            [$coach, $location] = $this->validateCoach($user);

            // 获取技师项目信息
            $coachProjects = $coach->projects;
            $coachProjectIds = $coachProjects->pluck('project_id')->toArray();

            // 获取系统配置
            $settings = $this->getSystemSettings();

            // 获取附近订单
            $orderDistances = $this->getNearbyOrders($location);

            // 构建订单查询
            $query = $this->buildOrderQuery($coachProjectIds, $orderDistances);

            // 处理订单数据
            $this->processOrderData($query, $orderDistances, $coachProjects, $settings);

            // 分页获取数据
            return $query->paginate(
                $params['per_page'] ?? 10,
                ['*'],
                'page',
                $params['page'] ?? 1
            );

        } catch (\Exception $e) {
            Log::error('获取可抢订单列表失败', [
                'user_id' => $userId,
                'params' => $params,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString(),
            ]);
            throw $e;
        }
    }

    /**
     * 验证技师信息
     */
    private function validateCoach(MemberUser $user): array
    {
        $coach = $user->coach;
        abort_if(! $coach, 404, '技师不存在');
        abort_if(! $coach->info, 404, '技师信息不存在');
        abort_if($coach->info->state != TechnicianStatus::ACTIVE->value, 404, '技师状态异常');
        abort_if($coach->real->state != TechnicianAuthStatus::PASSED->value, 404, '技师实名认证未通过');
        abort_if($coach->qual->state != TechnicianAuthStatus::PASSED->value, 404, '技师资质认证未通过');

        $location = $coach->locations()
            ->where('type', TechnicianLocationType::COMMON->value)
            ->first();
        abort_if(! $location, 404, '技师定位地址不存在');

        return [$coach, $location];
    }

    /**
     * 获取系统配置
     */
    private function getSystemSettings(): array
    {
        return [
            'coach_income' => $this->settingService->getItemDetail('coach_income')->default_value ?? 0,
            'min_distance' => $this->settingService->getItemDetail('qibugongli')->default_value ?? 0,
            'base_price' => $this->settingService->getItemDetail('qibujia')->default_value ?? 0,
            'per_km_price' => $this->settingService->getItemDetail('meigonglijiage')->default_value ?? 0,
        ];
    }

    /**
     * 获取附近订单
     */
    private function getNearbyOrders($location, float $maxDistance = 40): array
    {
        $nearbyOrders = Redis::georadius(
            'order_locations',
            $location->longitude,
            $location->latitude,
            $maxDistance,
            'km',
            ['WITHCOORD', 'WITHDIST']
        );

        if (! $nearbyOrders) {
            Log::warning('获取附近订单失败', [
                'location' => [
                    'longitude' => $location->longitude,
                    'latitude' => $location->latitude,
                ],
            ]);

            return [];
        }

        $orderDistances = [];
        foreach ($nearbyOrders as $order) {
            $orderId = str_replace('order:', '', $order[0]);
            $distance = round($order[1], 1);
            $orderDistances[$orderId] = $distance;
        }

        return $orderDistances;
    }

    /**
     * 构建订单查询
     */
    private function buildOrderQuery(array $coachProjectIds, array $orderDistances)
    {
        return Order::query()
            ->select([
                'id',
                'order_no',
                'project_id',
                'location',
                'address',
                'latitude',
                'longitude',
                'service_time',
                'created_at',
                'agent_id',
                DB::raw('0 as distance'),
            ])
            ->with(['project', 'agent.projects'])
            ->where('state', OrderStatus::CREATED)
            ->whereIn('project_id', $coachProjectIds)
            ->whereIn('id', array_keys($orderDistances))
            ->orderBy('created_at', 'desc');
    }

    /**
     * 处理订单数据
     */
    private function processOrderData($query, array $orderDistances, $coachProjects, array $settings): void
    {
        $query->get()->each(function ($order) use ($orderDistances, $coachProjects, $settings) {
            // 设置距离
            $order->distance = $orderDistances[$order->id];

            // 处理代理商项目价格
            $this->processAgentPrice($order);

            // 处理技师项目信息
            $this->processCoachProject($order, $coachProjects, $settings);
        });
    }

    /**
     * 处理代理商价格
     */
    private function processAgentPrice($order): void
    {
        if ($order->agent_id && $order->agent && $order->agent->projects) {
            $agentProject = $order->agent->projects
                ->where('id', $order->project_id)
                ->where('state', 1)
                ->first();

            if ($agentProject) {
                $order->project->price = $agentProject->agent_price;
                $order->project->duration = $agentProject->duration;
            }
        }
    }

    /**
     * 处理技师项目信息
     */
    private function processCoachProject($order, $coachProjects, array $settings): void
    {
        $coachProject = $coachProjects->where('project_id', $order->project_id)->first();
        if (! $coachProject) {
            return;
        }

        // 计算技师佣金
        $order->project->coach_income = round($order->project->price * $settings['coach_income'], 2);

        // 处理优惠金额
        if ($coachProject->discount_amount > 0) {
            $order->project->discount_amount = $coachProject->discount_amount;
            $order->project->final_price = $order->project->price - $coachProject->discount_amount;
        }

        // 处理路费
        if ($coachProject->traffic_fee > 0) {
            $this->calculateTrafficFee($order, $coachProject, $settings);
        }
    }

    /**
     * 计算路费
     */
    private function calculateTrafficFee($order, $coachProject, array $settings): void
    {
        $trafficFee = $settings['base_price'];

        if ($order->distance > $settings['min_distance']) {
            $trafficFee += ($order->distance - $settings['min_distance']) * $settings['per_km_price'];
        }

        $order->project->traffic_fee = round($trafficFee, 2);

        // 双程收费
        if ($coachProject->is_round_trip) {
            $order->project->traffic_fee *= 2;
        }

        // 计算最终价格
        $order->project->final_price = ($order->project->final_price ?? $order->project->price)
            + $order->project->traffic_fee;
    }

    /**
     * 技师抢单
     *
     * @param  int  $userId  技师用户ID
     * @param  int  $orderId  订单ID
     * @return array
     */
    public function grabOrder(int $userId, int $orderId)
    {
        return DB::transaction(function () use ($userId, $orderId) {
            try {
                // 加载用户和技师信息
                $user = MemberUser::with([
                    'coach',
                    'coach.info',
                    'coach.real',
                    'coach.qual',
                    'coach.locations',
                    'coach.projects',
                ])->findOrFail($userId);

                // 验证技师信息
                [$coach, $location] = $this->validateCoach($user);

                // 获取订单信息
                $order = Order::lockForUpdate()->findOrFail($orderId);

                // 验证订单状态
                abort_if($order->state !== OrderStatus::CREATED->value, 400, '订单状态异常，无法抢单');

                // 验证订单类型
                abort_if($order->type !== OrderType::GRAB->value, 400, '该订单不是抢单类型');

                // 检查技师是否已参与抢单
                $existingGrab = $coach->grabRecords()
                    ->where('order_id', $orderId)
                    ->first();
                abort_if($existingGrab, 400, '您已参与抢单，请勿重复操作');

                // 验证订单是否在技师服务范围内
                // 通过Redis GEO计算订单与技师的距离
                $distance = Redis::geodist(
                    'order_locations',
                    'order:'.$order->id,
                    $location->longitude.','.$location->latitude,
                    'km'
                ) ?? PHP_FLOAT_MAX;
                abort_if($distance > self::MAX_DISTANCE, 400, '订单超出服务范围');

                // 验证技师是否具备该项目服务资格
                $coachProject = $coach->projects()
                    ->where('project_id', $order->project_id)
                    ->where('state', ProjectStatus::OPEN->value)
                    ->first();
                abort_if(! $coachProject, 400, '未开通该项目服务资格');

                // 添加抢单记录
                OrderGrabRecord::create([
                    'order_id' => $order->id,
                    'coach_id' => $coach->id,
                    'distance' => $distance,
                    'state' => OrderGrabRecordStatus::JOINED->value,
                    'created_at' => now(),
                ]);

                // 记录日志
                Log::info('技师参与抢单', [
                    'user_id' => $userId,
                    'coach_id' => $coach->id,
                    'order_id' => $orderId,
                ]);

                return [
                    'message' => '已参与抢单',
                    'order_id' => $orderId,
                ];

            } catch (\Exception $e) {
                Log::error('技师参与抢单失败', [
                    'user_id' => $userId,
                    'order_id' => $orderId,
                    'error_message' => $e->getMessage(),
                    'error_trace' => $e->getTraceAsString(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 技师接单
     *
     * @param  int  $userId  技师用户ID
     * @param  int  $orderId  订单ID
     */
    public function acceptOrder(int $userId, int $orderId): array
    {
        return DB::transaction(function () use ($userId, $orderId) {
            try {
                // 加载用户和技师信息
                $user = MemberUser::with([
                    'coach',
                    'coach.info',
                    'coach.real',
                    'coach.qual',
                ])->findOrFail($userId);

                // 验证技师信息
                [$coach, $location] = $this->validateCoach($user);

                // 获取订单信息并加锁
                $order = Order::lockForUpdate()->findOrFail($orderId);

                // 验证订单状态
                abort_if($order->state !== OrderStatus::ASSIGNED->value, 400, '订单状态异常，无法接单');

                // 验证订单是否分配给该技师
                abort_if($order->coach_id !== $coach->id, 403, '该订单未分配给您');

                // 更新订单状态
                $order->update([
                    'state' => OrderStatus::ACCEPTED->value,
                    'accepted_at' => now(),
                ]);

                // 记录日志
                Log::info('技师接单成功', [
                    'user_id' => $userId,
                    'coach_id' => $coach->id,
                    'order_id' => $orderId,
                    'order_no' => $order->order_no,
                ]);

                return [
                    'message' => '接单成功',
                    'order_id' => $orderId,
                    'order_no' => $order->order_no,
                ];

            } catch (\Exception $e) {
                Log::error('技师接单失败', [
                    'user_id' => $userId,
                    'order_id' => $orderId,
                    'error' => $e->getMessage(),
                    'file' => $e->getFile(),
                    'line' => $e->getLine(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 技师拒单
     *
     * @param  int  $userId  用户ID
     * @param  int  $orderId  订单ID
     * @param  string  $reason  拒单原因
     */
    public function rejectOrder(int $userId, int $orderId, string $reason): array
    {
        return DB::transaction(function () use ($userId, $orderId, $reason) {
            try {
                // 获取技师信息(优化关联加载)
                $user = MemberUser::with([
                    'coach',
                    'coach.info',
                    'coach.real',
                    'coach.qual',
                ])->findOrFail($userId);

                // 验证技师信息
                [$coach, $location] = $this->validateCoach($user);

                // 获取订单信息并加锁
                $order = Order::lockForUpdate()->findOrFail($orderId);

                // 验证订单状态(修正状态判断)
                abort_if(! in_array($order->state, [
                    OrderStatus::ASSIGNED->value,
                    OrderStatus::PAID->value,
                ]), 400, '订单状态异常，无法拒单');

                // 验证订单是否分配给该技师
                abort_if($order->coach_id !== $coach->id, 403, '该订单未分配给您');

                // 检查拒单次数限制
                $rejectCount = OrderRecord::where('object_id', $coach->id)
                    ->where('object_type', CoachUser::class)
                    ->where('state', OrderRecordStatus::REJECTED->value)
                    ->whereDate('created_at', today())
                    ->count();

                // 更新订单状态
                $order->update([
                    'state' => OrderStatus::REJECTED->value,
                ]);

                // 创建订单记录
                OrderRecord::create([
                    'order_id' => $order->id,
                    'object_id' => $coach->id,
                    'object_type' => CoachUser::class,
                    'state' => OrderRecordStatus::REJECTED->value,
                    'remark' => $reason,
                ]);

                // 发送消息通知
                try {
                    // event(new OrderRejectedEvent($order, $coach, $reason));
                } catch (\Exception $e) {
                    Log::error('发送拒单通知失败', [
                        'order_id' => $orderId,
                        'coach_id' => $coach->id,
                        'error' => $e->getMessage(),
                    ]);
                }

                // 记录日志
                Log::info('技师拒单成功', [
                    'user_id' => $userId,
                    'coach_id' => $coach->id,
                    'order_id' => $orderId,
                    'order_no' => $order->order_no,
                    'reason' => $reason,
                    'reject_count' => $rejectCount + 1,
                ]);

                return [
                    'message' => '拒单成功',
                    'order_id' => $orderId,
                    'order_no' => $order->order_no,
                    'reject_count' => $rejectCount + 1,
                    'max_reject_count' => 5,
                ];

            } catch (\Exception $e) {
                Log::error('技师拒单失败', [
                    'user_id' => $userId,
                    'order_id' => $orderId,
                    'reason' => $reason,
                    'error' => $e->getMessage(),
                    'file' => $e->getFile(),
                    'line' => $e->getLine(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 技师出发
     *
     * @param  int  $userId  技师用户ID
     * @param  int  $orderId  订单ID
     */
    public function depart(int $userId, int $orderId): array
    {
        try {
            return DB::transaction(function () use ($userId, $orderId) {

                // 获取技师信息
                $user = MemberUser::with(['coach'])->findOrFail($userId);

                // 获取订单信息
                $order = Order::query()->where('id', $orderId)->lockForUpdate()->first();

                // 检查订单是否存在
                abort_if(! $order, 404, '订单不存在');

                // 检查是否是该技师的订单
                abort_if($order->coach_id !== $user->coach->id, 403, '无权操作此订单');

                // 检查订单状态是否为已分配技师
                abort_if($order->status !== OrderStatus::ASSIGNED->value, 400, '订单状态不正确');

                // 更新订单状态为技师出发
                $order->state = OrderStatus::DEPARTED->value;
                $order->save();

                // 记录订单状态变更日志
                OrderRecord::create([
                    'order_id' => $orderId,
                    'state' => OrderRecordStatus::DEPARTED->value,
                    'operator_id' => $user->coach->id,
                    'operator_type' => CoachUser::class,
                    'remark' => '技师已出发',
                ]);

                // 发送通知给用户
                // TODO: 发送通知
                // event(new TechnicianDepartedEvent($order));

                return [
                    'status' => true,
                    'message' => '操作成功',
                    'data' => [
                        'order_id' => $orderId,
                        'status' => $order->status,
                        'created_at' => $order->created_at,
                    ],
                ];
            });
        } catch (\Exception $e) {
            \Log::error('技师出发失败', [
                'user_id' => $userId,
                'order_id' => $orderId,
                'error' => $e->getMessage(),
            ]);
            throw $e;
        }
    }

    /**
     * 技师到达
     *
     * @param  int  $userId  技师用户ID
     * @param  int  $orderId  订单ID
     */
    public function arrive(int $userId, int $orderId): array
    {
        return DB::transaction(function () use ($userId, $orderId) {
            try {
                // 获取技师信息
                $user = MemberUser::with(['coach'])->findOrFail($userId);
                $coach = $user->coach;
                abort_if(! $coach, 404, '技师信息不存在');

                // 获取订单信息
                $order = Order::query()->where('id', $orderId)->lockForUpdate()->first();
                abort_if(! $order, 404, '订单不存在');

                // 检查是否是该技师的订单
                abort_if($order->coach_id !== $coach->id, 403, '无权操作此订单');

                // 检查订单状态
                abort_if(! in_array($order->state, [
                    OrderStatus::DEPARTED->value,
                ]), 400, '订单状态不正确');

                $now = now();

                // 更新订单状态为技师到达
                $order->state = OrderStatus::ARRIVED->value;
                $order->save();

                // 记录订单状态变更日志
                OrderRecord::create([
                    'order_id' => $orderId,
                    'state' => OrderRecordStatus::ARRIVED->value,
                    'object_id' => $coach->id,
                    'object_type' => CoachUser::class,
                    'remark' => '技师已到达',
                ]);

                // 更新技师当前位置到Redis GEO
                try {
                    Redis::geoadd(
                        'coach_locations',
                        $order->longitude,
                        $order->latitude,
                        $coach->id.'_'.TechnicianLocationType::CURRENT->value
                    );
                } catch (\Exception $e) {
                    Log::error('更新技师位置失败', [
                        'coach_id' => $coach->id,
                        'order_id' => $orderId,
                        'error' => $e->getMessage(),
                    ]);
                }

                // TODO: 发送通知给用户
                // event(new TechnicianArrivedEvent($order));

                Log::info('技师到达成功', [
                    'coach_id' => $coach->id,
                    'order_id' => $orderId,
                    'arrived_at' => $now,
                ]);

                return [
                    'status' => true,
                    'message' => '操作成功',
                    'data' => [
                        'order_id' => $orderId,
                        'status' => $order->state,
                        'arrived_at' => $now,
                    ],
                ];
            } catch (\Exception $e) {
                Log::error('技师到达失败', [
                    'user_id' => $userId,
                    'order_id' => $orderId,
                    'error' => $e->getMessage(),
                    'trace' => $e->getTraceAsString(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 技师扫码开始服务
     *
     * @param  int  $userId  技师用户ID
     * @param  int  $orderId  订单ID
     * @param  string  $qrCode  客户二维码
     */
    public function startService(int $userId, int $orderId, string $qrCode): array
    {
        return DB::transaction(function () use ($userId, $orderId, $qrCode) {
            try {
                // 获取技师信息
                $user = MemberUser::with(['coach'])->findOrFail($userId);
                $coach = $user->coach;
                abort_if(! $coach, 404, '技师信息不存在');

                // 获取订单信息
                $order = Order::query()
                    ->where('id', $orderId)
                    ->lockForUpdate()
                    ->first();
                abort_if(! $order, 404, '订单不存在');

                // 检查是否是该技师的订单
                abort_if($order->coach_id !== $coach->id, 403, '无权操作此订单');

                // 检查订单状态
                abort_if(! in_array($order->state, [
                    OrderStatus::ARRIVED->value,
                    OrderStatus::PAID->value,
                ]), 400, '订单状态不正确');

                // 验证二维码
                $this->validateQrCode($order, $qrCode);

                $now = now();

                // 更新订单状态为服务中
                $order->state = OrderStatus::SERVING->value;
                $order->save();

                // 记录订单状态变更日志
                OrderRecord::create([
                    'order_id' => $orderId,
                    'state' => OrderRecordStatus::STARTED->value,
                    'object_id' => $coach->id,
                    'object_type' => CoachUser::class,
                    'remark' => '开始服务',
                ]);

                // 获取项目服务时长(分钟)
                $duration = $order->project->duration ?? 60;

                // 派发延迟任务,在服务时长到期后自动完成订单
                AutoFinishOrder::dispatch($order)
                    ->delay(now()->addMinutes($duration));

                // TODO: 发送通知给用户
                // event(new ServiceStartedEvent($order));

                Log::info('技师开始服务', [
                    'coach_id' => $coach->id,
                    'order_id' => $orderId,
                    'service_start_time' => $now,
                ]);

                return [
                    'status' => true,
                    'message' => '开始服务成功',
                    'data' => [
                        'order_id' => $orderId,
                        'status' => $order->state,
                        'service_start_time' => $now,
                    ],
                ];

            } catch (\Exception $e) {
                Log::error('开始服务失败', [
                    'user_id' => $userId,
                    'order_id' => $orderId,
                    'qr_code' => $qrCode,
                    'error' => $e->getMessage(),
                    'trace' => $e->getTraceAsString(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 验证客户二维码
     *
     * @param  Order  $order  订单对象
     * @param  string  $qrCode  扫描的二维码
     */
    private function validateQrCode(Order $order, string $qrCode): void
    {
        // 二维码格式: order_{order_id}_{timestamp}_{sign}
        $parts = explode('_', $qrCode);
        abort_if(count($parts) !== 4, 400, '二维码格式错误');

        [$prefix, $scanOrderId, $timestamp, $sign] = $parts;

        // 验证前缀
        abort_if($prefix !== 'order', 400, '无效的二维码');

        // 验证订单ID
        abort_if((int) $scanOrderId !== $order->id, 400, '二维码与订单不匹配');

        // 验证时间戳(二维码5分钟内有效)
        $qrTimestamp = (int) $timestamp;
        $now = time();
        abort_if($now - $qrTimestamp > 300, 400, '二维码已过期');

        // 验证签名
        $correctSign = md5("order_{$order->id}_{$timestamp}_".config('app.key'));
        abort_if($sign !== $correctSign, 400, '二维码签名错误');
    }
}