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

<?php

namespace App\Services\Coach;

use App\Models\Order;
use App\Models\ShopInfo;
use App\Models\CoachUser;
use App\Enums\OrderStatus;
use App\Models\MemberUser;
use App\Enums\ProjectStatus;
use App\Models\CoachProject;
use App\Models\CoachLocation;
use App\Models\CoachSchedule;
use App\Models\CoachStatistic;
use App\Enums\TechnicianStatus;
use App\Models\CoachInfoRecord;
use App\Models\OrderGrabRecord;
use Illuminate\Support\Facades\DB;
use App\Enums\TechnicianAuthStatus;
use App\Enums\TechnicianWorkStatus;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Auth;
use App\Enums\TechnicianLocationType;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Redis;
use App\Traits\LocationValidationTrait;

class AccountService
{
    use LocationValidationTrait;

    private const CACHE_KEY_PREFIX = 'coach_info_';

    private const CACHE_TTL = 300; // 5分钟

    /**
     * 提交技师基本信息
     * 包括个人基础资料的提交和审核
     *
     * 业务流程：
     * 1. 验证技师信息存在性
     * 2. 检查是否有待审核的记录
     * 3. 处理生活照片数据
     * 4. 创建新的基本信息记录
     * 5. 清除相关缓存
     *
     * 注意事项：
     * - 同一时间只能有一条待审核记录
     * - 审核不通过可以重新提交
     * - 头像和生活照片不限制格式
     * - 除性别和手机号外，其他字段均为可选
     * - 手机号会进行脱敏处理
     *
     * @param User $user 当前认证用户
     * @param array $data 基本信息数据，包含：
     *        - nickname: string|null 昵称(可选)
     *        - avatar: string|null 头像图片(可选)
     *        - life_photos: array|null 生活照片数组(可选)
     *        - gender: string 性别(1:男 2:女)
     *        - mobile: string 手机号
     *        - birthday: string|null 出生日期(可选)
     *        - work_years: int|null 工作年限(可选)
     *        - intention_city: string|null 意向城市(可选)
     *        - introduction: string|null 个人简介(可选)
     * @return array 返回结果，包含：
     *        - message: string 提示信息
     * @throws \Exception 当验证失败或保存失败时抛出异常
     */
    public function submitBaseInfo($user, array $data)
    {
        return DB::transaction(function () use ($user, $data) {
            // 验证技师信息是否存在，不存在则抛出404异常
            abort_if(!$user->coach, 404, '技师信息不存在');

            // 检查是否有待审核的记录，避免重复提交
            // 如果存在待审核记录，则抛出422异常
            $pendingRecord = $this->hasPendingRecord($user->coach, 'info');
            abort_if($pendingRecord, 422, '已有待审核的基本信息记录');

            // 处理生活照片数据：将数组转换为JSON格式存储
            // 如果没有生活照片数据，则保持原样
            if (isset($data['life_photos'])) {
                // 使用array_values确保数组索引连续
                $data['life_photos'] = json_encode(array_values($data['life_photos']));
            }

            // 创建新的基本信息记录，设置为待审核状态
            // 合并用户提交的数据和审核状态
            $user->coach->infoRecords()->create(array_merge($data, [
                'state' => TechnicianAuthStatus::AUDITING->value,  // 设置为待审核状态
            ]));

            // 清除技师信息缓存，确保数据一致性
            // 避免用户获取到旧的缓存数据
            $this->clearCoachCache($user->coach->id);

            return ['message' => '基本信息提交成功'];
        });
    }

    /**
     * 提交技师资质信息
     * 包括资质证书照片、营业执照和健康证照片的提交和审核
     *
     * 业务流程：
     * 1. 验证技师信息存在性
     * 2. 检查是否有待审核的记录
     * 3. 创建新的资质审核记录
     * 4. 清除相关缓存
     *
     * 注意事项：
     * - 同一时间只能有一条待审核记录
     * - 审核不通过可以重新提交
     * - 所有图片数据不限制格式
     *
     * @param User $user 当前认证用户
     * @param array $data 资质信息数据，包含：
     *        - qual_type: int 资质类型(1:初级 2:中级 3:高级)
     *        - qual_photo: string 资质证书照片
     *        - business_license: string 营业执照照片
     *        - health_cert: string 健康证照片
     * @return array 返回结果，包含：
     *        - message: string 提示信息
     *        - data: array 详细数据
     *            - record_id: int 记录ID
     *            - state: int 状态值
     *            - state_text: string 状态文本
     * @throws \Exception 当验证失败或保存失败时抛出异常
     */
    public function submitQualification($user, array $data)
    {
        // 开启数据库事务
        DB::beginTransaction();
        try {
            // 验证技师信息是否存在
            abort_if(!$user->coach, 404, '技师信息不存在');

            // 检查是否有待审核的记录，避免重复提交
            $pendingRecord = $this->hasPendingRecord($user->coach, 'qual');
            abort_if($pendingRecord, 422, '已有待审核的资质信息记录');

            // 创建新的资质审核记录，设置为待审核状态
            $record = $user->coach->qualRecords()->create(array_merge($data, [
                'state' => TechnicianAuthStatus::AUDITING->value,
            ]));

            // 清除技师信息缓存，确保数据一致性
            $this->clearCoachCache($user->coach->id);

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

            // 返回成功结果
            return [
                'message' => '资质信息提交成功',
                'data' => [
                    'record_id' => $record->id,
                    'state' => TechnicianAuthStatus::AUDITING->value,
                    'state_text' => TechnicianAuthStatus::fromValue(TechnicianAuthStatus::AUDITING->value)->label(),
                ]
            ];
        } catch (\Exception $e) {
            // 发生异常时回滚事务
            DB::rollBack();
            throw $e;
        }
    }

    /**
     * 提交实名认证信息
     * 包括姓名(可选)、身份证号(可选)和三张身份证照片的提交和审核
     *
     * 业务流程：
     * 1. 验证技师信息存在性
     * 2. 检查是否有待审核的记录
     * 3. 创建新的实名认证记录
     * 4. 清除相关缓存
     *
     * 注意事项：
     * - 同一时间只能有一条待审核记录
     * - 审核不通过可以重新提交
     * - 所有图片数据不限制格式
     * - 姓名和身份证号为可选字段
     * - 敏感信息会进行脱敏处理
     *
     * @param User $user 当前认证用户
     * @param array $data 实名认证数据，包含：
     *        - real_name: string|null 真实姓名(可选)
     *        - id_card: string|null 身份证号(可选)
     *        - id_card_front_photo: string 身份证正面照片
     *        - id_card_back_photo: string 身份证反面照片
     *        - id_card_hand_photo: string 手持身份证照片
     * @return array 返回结果
     * @throws \Exception 当验证失败或保存失败时抛出异常
     */
    public function submitRealName($user, array $data)
    {
        // 开启数据库事务
        DB::beginTransaction();
        try {
            // 验证技师信息是否存在
            abort_if(!$user->coach, 404, '技师信息不存在');

            // TODO: 临时清除技师信息，便于对接调试
            $this->clearCoachCache($user->coach->id);

            // 检查是否有待审核的记录，避免重复提交
            $pendingRecord = $this->hasPendingRecord($user->coach, 'real');
            abort_if($pendingRecord, 422, '已有待审核的实名认证信息');

            // 创建新的实名认证记录，设置为待审核状态
            $user->coach->realRecords()->create(array_merge($data, [
                'state' => TechnicianAuthStatus::AUDITING->value,
            ]));

            // 清除技师信息缓存，确保数据一致性
            $this->clearCoachCache($user->coach->id);

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

            // 返回成功结果
            return ['message' => '实名认证信息提交成功'];
        } catch (\Exception $e) {
            // 发生异常时回滚事务
            DB::rollBack();
            throw $e;
        }
    }

    /**
     * 获取技师信息
     * 包括基本信息、资质信息和实名认证信息
     *
     * 业务流程：
     * 1. 验证用户和技师信息存在性
     * 2. 尝试从缓存获取数据
     * 3. 如果缓存不存在，从数据库获取并缓存
     *
     * 注意事项：
     * - 所有图片数据不限制格式
     * - 敏感信息会进行脱敏处理
     * - 使用缓存提高性能
     *
     * @param User $user 当前认证用户
     * @return array 返回技师所有信息，包含：
     *        - base_info: array|null 基本信息
     *        - qualification: array|null 资质信息
     *        - real_name: array|null 实名认证信息
     * @throws \Exception 当验证失败时抛出异常
     */
    public function getCoachInfo($user)
    {
        // 验证用户和技师信息
        abort_if(!$user, 404, '用户不存在');
        abort_if(!$user->coach, 404, '技师信息不存在');

        // 尝试从缓存获取数据
        return Cache::remember(
            self::CACHE_KEY_PREFIX . $user->coach->id,
            self::CACHE_TTL,
            function () use ($user) {
                // 缓存不存在时，从数据库获取
                return $this->fetchCoachInfo($user->coach);
            }
        );
    }

    /**
     * 获取技师详细信息
     */
    public function getCoachDetail(): array
    {
        $coach = Auth::user()->coach->load([
            'latestInfoRecord',
            'latestRealRecord',
            'latestQualRecord',
            'commonLocation',
            'shop',
            'statistics',
        ]);

        // 获取基本信息
        $baseInfo = $this->formatBaseInfo($coach->latestInfoRecord);

        // 获取订单统计
        $orderStats = $this->getOrderStatistics($coach->id);

        // 获取评分统计
        $statistics = $this->formatStatistics($coach->statistics);

        // 合并所有统计数据
        $statistics = array_merge($orderStats, $statistics);

        // 生成技师工号
        $coachNo = str_pad($coach->id, 8, '0', STR_PAD_LEFT);

        // 获取技师邀请码
        $inviteCode = $this->generateInviteCode($coach->id);

        // 获取钱包信息
        $wallet = $this->getWalletInfo($coach->id);

        // 获取审核状态信息
        $authStatus = $this->formatAuthStatus($coach);

        // 获取位置信息
        $location = $this->formatLocation($coach->commonLocation);

        // 获取店铺信息
        $shop = $this->formatShop($coach->shop);

        // 组装返回数据
        return array_merge(
            [
                'coach_no' => $coachNo,
                'invite_code' => $inviteCode,
                'wallet' => $wallet,
            ],
            $baseInfo,
            [
                'state' => $coach->state,
                'state_text' => $coach->state
                    ? TechnicianStatus::fromValue($coach->state)->label()
                    : null,
                'work_status' => $coach->work_status,
                'work_status_text' => $coach->work_status
                    ? TechnicianWorkStatus::fromValue($coach->work_status)->label()
                    : null,
            ],
            [
                'auth_status' => $authStatus,
                'location' => $location,
                'shop' => $shop,
                'statistics' => $statistics,
            ]
        );
    }

    /**
     * 格式化审核状态信息
     * 包含基本信息、实名认证和资质认证的审核状态
     *
     * @param CoachUser $coach 技师对象
     * @return array 审核状态信息
     */
    private function formatAuthStatus(CoachUser $coach): array
    {
        return [
            'base_info' => [
                'state' => $coach->latestInfoRecord?->state,
                'state_text' => $coach->latestInfoRecord?->state
                    ? TechnicianAuthStatus::fromValue($coach->latestInfoRecord->state)->label()
                    : null,
                'audit_remark' => $coach->latestInfoRecord?->audit_remark,
                'updated_at' => $coach->latestInfoRecord?->updated_at?->format('Y-m-d H:i:s'),
            ],
            'real_name' => [
                'state' => $coach->latestRealRecord?->state,
                'state_text' => $coach->latestRealRecord?->state
                    ? TechnicianAuthStatus::fromValue($coach->latestRealRecord->state)->label()
                    : null,
                'audit_remark' => $coach->latestRealRecord?->audit_remark,
                'updated_at' => $coach->latestRealRecord?->updated_at?->format('Y-m-d H:i:s'),
            ],
            'qualification' => [
                'state' => $coach->latestQualRecord?->state,
                'state_text' => $coach->latestQualRecord?->state
                    ? TechnicianAuthStatus::fromValue($coach->latestQualRecord->state)->label()
                    : null,
                'audit_remark' => $coach->latestQualRecord?->audit_remark,
                'updated_at' => $coach->latestQualRecord?->updated_at?->format('Y-m-d H:i:s'),
            ],
        ];
    }

    /**
     * 格式化位置信息
     * 处理技师的常用位置信息
     *
     * 业务逻辑：
     * 1. 检查位置信息是否存在
     * 2. 格式化地理位置信息
     * 3. 格式化行政区划信息
     *
     * @param CoachLocation|null $location 位置对象
     * @return array|null 格式化后的位置信息
     */
    private function formatLocation(?CoachLocation $location): ?array
    {
        // 如果没有位置信息，返回null
        if (!$location) {
            return null;
        }

        // 返回格式化的位置信息
        return [
            'province' => $location->province,      // 省份
            'city' => $location->city,             // 城市
            'district' => $location->district,      // 区县
            'address' => $location->address,        // 详细地址
            'adcode' => $location->adcode,         // 行政区划代码
            'longitude' => $location->longitude,    // 经度
            'latitude' => $location->latitude,      // 纬度
        ];
    }

    /**
     * 格式化店铺信息
     * 处理技师所属店铺的基本信息
     *
     * 业务逻辑：
     * 1. 检查店铺信息是否存在
     * 2. 格式化店铺基本信息
     * 3. 格式化联系信息
     *
     * @param ShopInfo|null $shop 店铺对象
     * @return array|null 格式化后的店铺信息
     */
    private function formatShop(?ShopInfo $shop): ?array
    {
        // 如果没有店铺信息，返回null
        if (!$shop) {
            return null;
        }

        // 返回格式化的店铺信息
        return [
            'id' => $shop->id,           // 店铺ID
            'name' => $shop->name,       // 店铺名称
            'address' => $shop->address, // 店铺地址
            'phone' => $shop->phone,     // 联系电话
        ];
    }

    /**
     * 格式化评分统计信息
     * 处理技师的评分和等级信息
     *
     * @param CoachStatistic|null $statistics 评分统计对象
     * @return array 格式化后的评分信息
     */
    private function formatStatistics(?CoachStatistic $statistics): array
    {
        if (!$statistics) {
            return [
                'level' => 1,                    // 技师等级
                'level_text' => $this->getLevelText(1),  // 等级文本
                'rating' => 5.0,                 // 评分
            ];
        }

        return [
            'level' => $statistics->level ?? 1,
            'level_text' => $this->getLevelText($statistics->level ?? 1),
            'rating' => $statistics->rating ?? 5.0,
        ];
    }

    /**
     * 获取技师详细信息
     * 从数据库获取最新的认证记录信息
     *
     * @param CoachUser $coach 技师对象
     * @return array 格式化后的技师信息
     */
    private function fetchCoachInfo($coach)
    {
        // 获取最新的各类认证记录
        $baseInfo = $coach->infoRecords()->latest()->first();
        $qualification = $coach->qualRecords()->latest()->first();
        $realName = $coach->realRecords()->latest()->first();

        // 格式化并返回数据
        return [
            'base_info' => $baseInfo ? $this->formatBaseInfo($baseInfo) : null,
            'qualification' => $qualification ? $this->formatQualification($qualification) : null,
            'real_name' => $realName ? $this->formatRealName($realName) : null,
        ];
    }

    /**
     * 格式化基本信息
     * 处理技师基本信息的展示格式
     *
     * @param object $info 基本信息记录对象
     * @return array 格式化后的基本信息
     */
    private function formatBaseInfo($info): array
    {
        // 如果 $info 为空，返回空数组
        if (!$info) {
            return [];
        }

        // 返回格式化后的基本信息，包含状态文本
        return [
            'nickname' => $info->nickname,
            'avatar' => $info->avatar,  // 支持任意格式的图片数据
            'life_photos' => $info->life_photos ?? [],  // 生活照片数组
            'gender' => $info->gender,
            'mobile' => $this->maskMobile($info->mobile),  // 手机号脱敏处理
            'birthday' => $info->birthday,
            'work_years' => $info->work_years,
            'intention_city' => $info->intention_city,
            'introduction' => $info->introduction,
            'state' => $info->state,
            'state_text' => $info->state ? TechnicianAuthStatus::fromValue($info->state)->label() : null,
            'audit_remark' => $info->audit_remark,
        ];
    }

    /**
     * 格式化资质信息
     * 处理技师资质信息的展示格式
     *
     * @param object|null $qual 资质记录对象
     * @return array|null 格式化后的资质信息
     */
    private function formatQualification($qual): ?array
    {
        // 如果资质信息为空，返回 null
        if (!$qual) {
            return null;
        }

        // 资质类型文本映射
        $qualTypeMap = [
            1 => '初级按摩师',
            2 => '中级按摩师',
            3 => '高级按摩师',
        ];

        // 返回格式化后的资质信息，包含状态文本
        return [
            'qual_type' => $qual->qual_type,
            'qual_type_text' => $qualTypeMap[$qual->qual_type] ?? '未知类型',
            'qual_photo' => $qual->qual_photo,
            'business_license' => $qual->business_license,
            'health_cert' => $qual->health_cert,
            'state' => $qual->state,
            'state_text' => $qual->state ? TechnicianAuthStatus::fromValue($qual->state)->label() : null,
            'audit_remark' => $qual->audit_remark,
        ];
    }

    /**
     * 格式化实名信息
     * 处理技师实名认证信息的展示格式
     *
     * @param object|null $real 实名认证记录对象
     * @return array|null 格式化后的实名信息
     */
    private function formatRealName($real): ?array
    {
        // 如果实名信息为空，返回 null
        if (!$real) {
            return null;
        }

        // 返回格式化后的实名信息，包含状态文本和脱敏处理
        return [
            'real_name' => $real->real_name,
            'id_card' => $this->maskIdCard($real->id_card),
            'id_card_front_photo' => $real->id_card_front_photo,
            'id_card_back_photo' => $real->id_card_back_photo,
            'id_card_hand_photo' => $real->id_card_hand_photo,
            'state' => $real->state,
            'state_text' => $real->state ? TechnicianAuthStatus::fromValue($real->state)->label() : null,
            'audit_remark' => $real->audit_remark,
        ];
    }

    /**
     * 手机号脱敏
     * 将手机号中间4位替换为****
     *
     * @param string $mobile 原始手机号
     * @return string 脱敏后的手机号
     */
    private function maskMobile($mobile)
    {
        return substr_replace($mobile, '****', 3, 4);
    }

    /**
     * 身份证号脱敏
     * 将身份证号中间8位替换为****
     *
     * @param string|null $idCard 原始身份证号
     * @return string|null 脱敏后的身份证号
     */
    private function maskIdCard($idCard)
    {
        if (!$idCard) {
            return null;
        }
        return substr_replace($idCard, '****', 6, 8);
    }

    /**
     * 清除技师信息缓存
     */
    private function clearCoachCache($coachId)
    {
        Cache::forget(self::CACHE_KEY_PREFIX . $coachId);
    }

    /**
     * 设置定位信息
     * 支持设置当前位置和常用位置，包含地理位置和行政区划信息
     *
     * 业务流程：
     * 1. 验证经纬度参数
     * 2. 验证位置类型
     * 3. 保存到Redis的地理位置数据结构
     * 4. 同步保存到据库
     *
     * @param int $coachId 技师ID
     * @param float $latitude 纬度
     * @param float $longitude 经度
     * @param int $type 位置类型 (current：1|common：2)
     * @param array $locationInfo 位置信息，包含：
     *        - province: string|null 省份
     *        - city: string|null 城市
     *        - district: string|null 区县
     *        - address: string|null 详细地址
     *        - adcode: string|null 行政区划代码
     * @return bool 返回缓存更新结果
     * @throws \Exception 当验证失败或保存失败时抛出异常
     */
    public function setLocation($coachId, $latitude, $longitude, $type = TechnicianLocationType::COMMON->value, array $locationInfo = [])
    {
        // 使用事务确保一致性
        return DB::transaction(function () use ($coachId, $latitude, $longitude, $type, $locationInfo) {
            // 验证经纬度的有效性（-90≤纬度≤90，-180≤经度≤180）
            $this->validateCoordinates($latitude, $longitude);

            // 验证位置类型是否为有效值（1:当前位置 2:常用位置）
            $this->validateLocationType($type);

            // 格式化并验证位置信息（省市区、地址、行政区划代码）
            $formattedLocation = $this->formatLocationInfo($locationInfo);

            // 更新Redis地理位置缓存，用于实时位置查询
            $result = $this->updateLocationCache($coachId, $longitude, $latitude, $type);

            // 同步更新数据库，保存历史位置记录
            CoachLocation::updateOrCreate(
                // 查询条件：根据技师ID和位置类型确定唯一记录
                ['coach_id' => $coachId, 'type' => $type],
                // 更新数据：合并基础位置信息和格式化后的地址信息
                array_merge([
                    'latitude' => $latitude,
                    'longitude' => $longitude,
                ], $formattedLocation)
            );

            return $result;
        });
    }

    /**
     * 获取技师位置信息
     *
     * 业务流程：
     * 1. 获取指定类型的位置记录
     * 2. 返回格式化的位置数据
     *
     * @param User $user 认证用户
     * @param int $type 位置类型 (1:当前位置 2:常用位置)
     * @return array 位置信息，包含：
     *        - province: string 省份
     *        - city: string 城市
     *        - district: string 区县
     *        - address: string 详细地址
     *        - adcode: string 行政区划代码
     *        - longitude: float 经度
     *        - latitude: float 纬度
     *        - updated_at: string 更新时间
     */
    public function getLocation($user, int $type): array
    {
        // 获取指定类型的位置记录
        $location = $this->getLocationByType($user->coach, $type);

        // 返回格式化的位置数据
        return $this->formatLocationResponse($location);
    }

    /**
     * 根据类型获取技师位置记录
     *
     * @param CoachUser $coach 技师对象
     * @param int $type 位置类型 (1:当前位置 2:常用位置)
     * @return CoachLocation 位置信息
     * @throws \Illuminate\Http\Exceptions\HttpResponseException 当位置信息不存在时抛出404异常
     */
    private function getLocationByType(CoachUser $coach, int $type): CoachLocation
    {
        // 获取指定类型的位置记录
        $location = $coach->locations()
            ->where('type', $type)
            ->first();
        abort_if(!$location, 404, '位置信息不存在');

        // 返回位置数据
        return $location;
    }

    /**
     * 格式化位置响应数据
     *
     * @param CoachLocation $location 位置记录
     * @return array 格式化后的位置信息，包含：
     *        - province: string 省份
     *        - city: string 城市
     *        - district: string 区县
     *        - address: string 详细地址
     *        - adcode: string 行政区划代码
     *        - longitude: float 经度
     *        - latitude: float 纬度
     *        - updated_at: string 更新时间
     */
    private function formatLocationResponse(CoachLocation $location): array
    {
        return [
            'province' => $location->province,    // 省份
            'city' => $location->city,           // 城市
            'district' => $location->district,    // 区县
            'address' => $location->address,      // 详细地址
            'adcode' => $location->adcode,        // 行政区划代码
            'longitude' => $location->longitude,  // 经度
            'latitude' => $location->latitude,    // 纬度
            'updated_at' => $location->updated_at->toDateTimeString(), // 更新时间
        ];
    }

    /**
     * 设置技师排班时间(每天通用)
     *
     * @param CoachUser $coach 技师对象
     * @param array $timeRanges 时间段数组
     * @return array 返回设置结果
     * @throws \Exception 当设置失败时抛出异常
     */
    public function setSchedule(CoachUser $coach, array $timeRanges): array
    {
        return DB::transaction(function () use ($coach, $timeRanges) {
            // 验证并排序时间段
            $sortedRanges = $this->validateAndSortTimeRanges($timeRanges);

            // 创建或更新排班记录
            $schedule = CoachSchedule::updateOrCreate(
                ['coach_id' => $coach->id],
                [
                    'time_ranges' => $sortedRanges,  // 直接传入数组，模型会自动处理JSON转换
                    'state' => 1,
                ]
            );

            // 更新Redis缓存
            $this->updateScheduleCache($coach->id, $sortedRanges);

            // 返回设置结果
            return [
                'status' => true,
                'message' => '排班设置成功',
                'data' => [
                    'coach_id' => $coach->id,
                    'time_ranges' => $sortedRanges,
                    'updated_at' => $schedule->updated_at->toDateTimeString(),
                ],
            ];
        });
    }

    /**
     * 验证并排序时间段
     */
    private function validateAndSortTimeRanges(array $timeRanges): array
    {
        // 验证时间段数组
        abort_if(empty($timeRanges), 400, '必须至少设置一个时间段');

        // 验证每个时间段格式并转换为分钟数进行比较
        $ranges = collect($timeRanges)->map(function ($range) {
            abort_if(
                !isset($range['start_time'], $range['end_time']),
                400,
                '时间段格式错误'
            );

            // 验证时间格式，限制在 00:00-24:00
            foreach (['start_time', 'end_time'] as $field) {
                // 先检查是否为 24:00
                if ($range[$field] === '24:00') {
                    continue;
                }

                // 其他时间格式验证 (00:00-23:59)
                abort_if(
                    !preg_match('/^((?:[01][0-9]|2[0-3]):[0-5][0-9]|24:00)$/', $range[$field]),
                    400,
                    '时间格式错误，应为00:00-24:00格式'
                );
            }

            // 转换为分钟数便于比较
            $startMinutes = $this->timeToMinutes($range['start_time']);
            $endMinutes = $this->timeToMinutes($range['end_time']);

            // 验证时间先后
            abort_if(
                $startMinutes >= $endMinutes,
                400,
                "时间段 {$range['start_time']}-{$range['end_time']} 结束时间必须大于开始时间"
            );

            return [
                'start_time' => $range['start_time'],
                'end_time' => $range['end_time'],
                'start_minutes' => $startMinutes,
                'end_minutes' => $endMinutes,
            ];
        })
            ->sortBy('start_minutes')
            ->values();

        // 验证时间段是否重叠
        $ranges->each(function ($range, $index) use ($ranges) {
            if ($index > 0) {
                $prevRange = $ranges[$index - 1];
                abort_if(
                    $range['start_minutes'] <= $prevRange['end_minutes'],
                    400,
                    "时间段 {$prevRange['start_time']}-{$prevRange['end_time']} 和 " .
                        "{$range['start_time']}-{$range['end_time']} 之间有重叠"
                );
            }
        });

        // 返回排序后的时间，只保留需要的字段
        return $ranges->map(function ($range) {
            return [
                'start_time' => $range['start_time'],
                'end_time' => $range['end_time'],
            ];
        })->toArray();
    }

    /**
     * 将时间转换为分钟数
     */
    private function timeToMinutes(string $time): int
    {
        if ($time === '24:00') {
            return 24 * 60;  // 特殊处理 24:00
        }

        [$hours, $minutes] = explode(':', $time);
        return (int)$hours * 60 + (int)$minutes;
    }

    /**
     * 更新Redis缓存
     */
    private function updateScheduleCache(int $coachId, array $timeRanges): void
    {
        $cacheKey = "coach:schedule:{$coachId}";
        $cacheData = [
            'time_ranges' => $timeRanges,
            'updated_at' => now()->toDateTimeString(),
        ];

        // 使用 Redis 存储，24小时过期
        Redis::setex($cacheKey, 86400, json_encode($cacheData));

        // 清除相关的可预约时间段缓存
        $this->clearTimeSlotCache($coachId);
    }

    /**
     * 清除可预约时间段缓存
     */
    public function clearTimeSlotCache(int $coachId): void
    {
        $pattern = "coach:timeslots:{$coachId}:*";
        $keys = Redis::keys($pattern);
        if (! empty($keys)) {
            Redis::del($keys);
        }
    }

    /**
     * 更改技师工作状态
     *
     * 业务流程：
     * 1. 验证技师认证状态
     * 2. 处理状态切换逻辑
     * 3. 更新状态并同步缓存
     *
     * @param CoachUser $coach 技师对象
     * @param int $status 目标状态(1:休息中 2:工作中)
     * @return array 返回更新结果，包含：
     *        - status: bool 更新是否成功
     *        - message: string 提示信息
     *        - data: array 状态信息
     *            - work_status: int 工作状态值
     *            - work_status_text: string 状态文本
     * @throws \Exception 当状态更新失败时抛出异常
     */
    public function updateWorkStatus(CoachUser $coach, int $status): array
    {
        DB::beginTransaction();
        try {
            // 验证技师认证状态
            $this->validateCoachStatus($coach);

            // 确保状态值为整数
            $status = (int)$status;

            // 更新状态
            $coach->work_status = $status;
            $coach->save();

            // 更新Redis缓存
            $this->updateWorkStatusCache($coach->id, $status);

            DB::commit();

            // 返回更新结果
            return [
                'status' => true,
                'message' => '状态更新成功',
                'data' => [
                    'work_status' => $status,
                    'work_status_text' => TechnicianWorkStatus::fromValue($status)->label()
                ],
            ];
        } catch (\Exception $e) {
            DB::rollBack();
            throw $e;
        }
    }

    /**
     * 验证技师认证状态
     */
    private function validateCoachStatus($coach): void
    {
        // 验证基本信息认证
        $baseInfo = $coach->info;
        abort_if(
            ! $baseInfo || (int)$baseInfo->state !== TechnicianAuthStatus::PASSED->value,
            422,
            '基本信息未认证通过'
        );

        // 验证资质认证
        $qualification = $coach->qual;
        abort_if(
            ! $qualification || (int)$qualification->state !== TechnicianAuthStatus::PASSED->value,
            422,
            '资质信息未认证通过'
        );

        // 验证实名认证
        $realName = $coach->real;
        abort_if(
            ! $realName || (int)$realName->state !== TechnicianAuthStatus::PASSED->value,
            422,
            '实名信息未认证通过'
        );
    }

    /**
     * 更新工作状态缓存
     */
    private function updateWorkStatusCache(int $coachId, int $status): void
    {
        try {
            $cacheKey = "coach:work_status:{$coachId}";
            $cacheData = [
                'status' => $status,
                'updated_at' => now()->toDateTimeString(),
            ];

            Redis::setex($cacheKey, 86400, json_encode($cacheData));
        } catch (\Exception $e) {
            Log::error('更新工作状态缓存失败', [
                'coach_id' => $coachId,
                'error' => $e->getMessage(),
            ]);
            // 缓存更新失败不影响主流程
        }
    }

    /**
     * 获取技师工作状态
     *
     * @param  int  $coachId  技师ID
     */
    public function getWorkStatus(int $coachId): array
    {
        try {
            // 验证技师信息
            $coach = CoachUser::find($coachId);

            abort_if(! $coach, 404, '技师不存在');

            // 直接获取技师信息里的work_status
            $workStatus = $coach->work_status;

            return [
                'work_status' => $workStatus,
                'work_status_text' => TechnicianWorkStatus::fromValue($workStatus)->label(),
                'updated_at' => now()->toDateTimeString(),
            ];
        } catch (\Exception $e) {
            Log::error('获取技师工作状态失败', [
                'coach_id' => $coachId,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString(),
            ]);
            throw $e;
        }
    }

    /**
     * 获取技师排班信息
     *
     * @param CoachUser $coach 技师对象
     * @return array 返回排班信息
     */
    public function getSchedule(CoachUser $coach): array
    {
        $cacheKey = "coach:schedule:{$coach->id}";

        // 尝试从 Redis 获取缓存
        $cached = Redis::get($cacheKey);
        if ($cached) {
            return json_decode($cached, true);
        }

        // 缓存不存在，从数据库获取
        $schedule = CoachSchedule::where('coach_id', $coach->id)
            ->where('state', 1)
            ->first();

        $data = [
            'time_ranges' => $schedule ? $schedule->time_ranges : [],
            'updated_at' => $schedule ? $schedule->updated_at->toDateTimeString() : now()->toDateTimeString(),
        ];

        // 写入 Redis 缓存
        Redis::setex($cacheKey, 86400, json_encode($data));

        return $data;
    }

    /**
     * 验证技师基础信息
     *
     * @param User $user 用户对象
     * @param bool $throwError 是否抛出异常
     * @return bool
     */
    private function validateBasicCoach($user, bool $throwError = true): bool
    {
        if (!$user || !$user->coach) {
            if ($throwError) {
                abort_if(!$user, 404, '用户不存在');
                abort_if(!$user->coach, 404, '技师信息不存在');
            }
            return false;
        }
        return true;
    }

    /**
     * 检查是否存在审核记录
     *
     * @param CoachUser $coach 技师对象
     * @param string $type 记录类型(info|qual|real)
     * @return bool
     */
    private function hasPendingRecord($coach, string $type): bool
    {
        $method = match ($type) {
            'info' => 'infoRecords',
            'qual' => 'qualRecords',
            'real' => 'realRecords',
            default => throw new \InvalidArgumentException('Invalid record type')
        };

        return $coach->{$method}()
            ->where('state', TechnicianAuthStatus::AUDITING->value)
            ->exists();
    }

    /**
     * 格式化位置信息
     * 过滤和验证位置相关字段
     *
     * @param array $locationInfo 原始位置信息
     * @return array 格式化后的位置信息
     * @throws \Exception 当行政区划代码格式无效时抛出异常
     */
    private function formatLocationInfo(array $locationInfo): array
    {
        // 定义允许的字段列表，确保数据安全性
        $allowedFields = [
            'province',  // 省份
            'city',      // 城市
            'district',  // 区县
            'address',   // 详细地址
            'adcode'     // 行政区划代码
        ];

        // 过滤并验证字段：
        // 1. 只保留允许的字段
        // 2. 移除空值
        $formatted = array_filter(
            array_intersect_key($locationInfo, array_flip($allowedFields)),
            function ($value) {
                return !is_null($value) && $value !== '';
            }
        );

        // 验证行政区划代码格式（6位数字）
        if (isset($formatted['adcode'])) {
            abort_if(!preg_match('/^\d{6}$/', $formatted['adcode']), 422, '无效的行政区划代码');
        }

        return $formatted;
    }

    /**
     * 更新位置缓存
     * 处理Redis地理位置数据结构的更新
     * 使用Redis的GEOADD命令存储地理位置信息
     *
     * @param int $coachId 技师ID
     * @param float $longitude 经度
     * @param float $latitude 纬度
     * @param int $type 位置类型
     * @return bool 操作是否成功
     */
    private function updateLocationCache(int $coachId, float $longitude, float $latitude, int $type): bool
    {
        // 生成缓存键：技师ID_位置类型
        $key = $coachId . '_' . $type;

        // 使用Redis的GEOADD命令添加地理位置信息
        // 参数顺序：key longitude latitude member
        return Redis::geoadd('coach_locations', $longitude, $latitude, $key);
    }

    /**
     * 获取技师最新基本信息
     *
     * @param CoachUser $coach 技师对象
     * @return CoachInfoRecord 最新的基本信息记录
     * @throws \Illuminate\Http\Exceptions\HttpResponseException 当信息不存在时抛出404异常
     */
    private function getLatestBaseInfo(CoachUser $coach): CoachInfoRecord
    {
        // 获取最新的技师信息记录（排除审核拒绝的记录）
        $latestInfo = $coach->infoRecords()
            ->where('state', '<>', TechnicianAuthStatus::REJECTED->value)
            ->latest()
            ->first();

        abort_if(!$latestInfo, 404, '技师基本信息不存在');

        return $latestInfo;
    }

    /**
     * 生成技师邀请码
     *
     * @param int $coachId 技师ID
     * @return string 邀请码
     */
    private function generateInviteCode(int $coachId): string
    {
        return sprintf('C%d', $coachId);
    }

    /**
     * 获取技师钱包信息
     *
     * 业务逻辑：
     * 1. 获取技师钱包关联数据
     * 2. 如果钱包不存在，返回默认值
     * 3. 返回钱包概况数据
     *
     * @param int $coachId 技师ID
     * @return array 钱包概况信息
     */
    private function getWalletInfo(int $coachId): array
    {
        // 获取技师及其钱包关联
        $coach = CoachUser::with('wallet')->find($coachId);

        // 如果钱包不存在，返回默认值
        if (!$coach || !$coach->wallet) {
            return [
                'total_balance' => 0,         // 总余额
                'available_balance' => 0,     // 可用余额
                'frozen_amount' => 0,         // 冻结金额
                'total_income' => 0,          // 累计收入
                'total_expense' => 0,         // 累计支出
            ];
        }

        // 返回钱包概况数据
        return [
            'total_balance' => $coach->wallet->total_balance ?? 0,           // 总余额
            'available_balance' => $coach->wallet->available_balance ?? 0,   // 可用余额
            'frozen_amount' => $coach->wallet->frozen_amount ?? 0,          // 冻结金额
            'total_income' => $coach->wallet->total_income ?? 0,            // 累计收入
            'total_expense' => $coach->wallet->total_expense ?? 0,          // 累计支出
        ];
    }

    /**
     * 更新技师基础信息
     *
     * 业务流程：
     * 1. 获取最新的非拒绝记录
     * 2. 验证手机验证码(如果修改手机号)
     * 3. 如果是待审核状态，直接更新字段
     * 4. 如果是已通过状态，创建新记录并复制字段
     *
     * @param CoachUser $coach 技师对象
     * @param array $data 待更新的数据，可包含：
     *        - nickname: ?string 昵称
     *        - gender: ?int 性别(1:男 2:女)
     *        - mobile: ?string 手机号
     *        - code: ?string 验证码(修改手机号时必填)
     * @return array 返回结果
     */
    public function updateBasicInfo(CoachUser $coach, array $data): array
    {
        return DB::transaction(function () use ($coach, $data) {
            // 获取最新的非拒绝记录
            $latestRecord = $coach->infoRecords()
                ->where('state', '<>', TechnicianAuthStatus::REJECTED->value)
                ->latest()
                ->first();

            abort_if(!$latestRecord, 404, '未找到有效的基础信息记录');

            // 如果要修改手机号，验证验证码
            if (isset($data['mobile'])) {
                $this->verifyMobileCode($data['mobile'], $data['code']);
            }

            // 提取要更新的字段
            $updateFields = array_intersect_key($data, [
                'nickname' => '',
                'gender' => '',
                'mobile' => '',
            ]);

            // 如果没有要更新的字段，直接返回
            abort_if(empty($updateFields), 422, '没有需要更新的字段');

            // 如果最新记录是待审核状态，直接更新
            if ($latestRecord->state === TechnicianAuthStatus::AUDITING->value) {
                $latestRecord->update($updateFields);

                return [
                    'message' => '基础信息修改申请已更新',
                    'record_id' => $latestRecord->id,
                    'updated_fields' => array_keys($updateFields)
                ];
            }

            // 创建新的审核记录，复制其他字段
            $newRecord = $coach->infoRecords()->create(array_merge([
                'avatar' => $latestRecord->avatar,
                'life_photos' => $latestRecord->life_photos,
                'gender' => $latestRecord->gender,
                'mobile' => $latestRecord->mobile,
                'birthday' => $latestRecord->birthday,
                'work_years' => $latestRecord->work_years,
                'intention_city' => $latestRecord->intention_city,
                'introduction' => $latestRecord->introduction,
                'state' => TechnicianAuthStatus::AUDITING->value,
            ], $updateFields)); // 使用新的字段值覆盖

            return [
                'message' => '基础信息修改申请已提交',
                'record_id' => $newRecord->id,
                'updated_fields' => array_keys($updateFields)
            ];
        });
    }

    /**
     * 验证手机验证码
     *
     * @param string $mobile 手机号
     * @param string $code 验证码
     * @throws \Illuminate\Http\Exceptions\HttpResponseException
     */
    private function verifyMobileCode(string $mobile, string $code): void
    {
        // 缓存键
        $cacheKey = "sms_code:update:{$mobile}";

        // 获取缓存中的验证码
        $cacheCode = Redis::get($cacheKey);

        // 验证码不存在或不匹配
        abort_if(!$cacheCode || $cacheCode !== $code, 422, '验证码错误或已过期');

        // 验证成功后删除验证码
        Redis::del($cacheKey);
    }

    /**
     * 发送验证码
     *
     * 业务流程：
     * 1. 检查手机号是否已被使用
     * 2. 生成验证码
     * 3. 保存到 Redis
     * 4. 发送验证码
     *
     * @param array $data 包含：
     *        - mobile: string 手机号
     *        - type: string 验证码类型
     * @return array 返回结果
     */
    public function sendVerifyCode(array $data): array
    {
        // 检查手机号是否已被使用
        $exists = MemberUser::where('mobile', $data['mobile'])
            ->whereHas('coach')
            ->exists();
        abort_if($exists, 422, '该手机号已被使用');

        // 生成6位随机验证码
        $code = str_pad(random_int(0, 999999), 6, '0', STR_PAD_LEFT);

        // 验证码有效期(5分钟)
        $expireTime = 300;

        // 缓存键
        $cacheKey = "sms_code:{$data['type']}:{$data['mobile']}";

        // 保存到Redis，设置5分钟过期
        Redis::setex($cacheKey, $expireTime, $code);


        return [
            'code' => $code,
            'mobile' => substr_replace($data['mobile'], '****', 3, 4),
            'expire_time' => $expireTime
        ];
    }

    /**
     * 获取等级文本
     * 将等级数值转换为对应的文本描述
     *
     * @param int $level 等级值
     * @return string 等级文本描述
     */
    private function getLevelText(int $level): string
    {
        // 使用 match 表达式转换等级文本
        return match ($level) {
            1 => '初级技师',
            2 => '中级技师',
            3 => '高级技师',
            default => '未知等级',
        };
    }

    /**
     * 获取技师已开通的项目列表
     *
     * 业务逻辑：
     * 1. 获取技师开通的所有项目
     * 2. 预加载项目基础信息
     * 3. 格式化返回数据
     *
     * @param int $coachId 技师ID
     * @return array 项目列表数据，包含：
     *        - total: int 总数
     *        - list: array 项目列表
     */
    public function getEnabledProjects(int $coachId): array
    {
        // 获取技师开通且启用的项目
        $projects = CoachProject::with(['project', 'project.category'])
            ->where('coach_id', $coachId)
            ->where('state', ProjectStatus::OPEN->value)
            ->get();

        // 格式化项目数据
        $list = $projects->map(function ($item) {
            return [
                'id' => $item->id,
                'project_id' => $item->project_id,
                'project_name' => $item->project?->name,
                'category_id' => $item->project?->category_id,
                'category_name' => $item->project?->category?->name,
                'duration' => $item->project?->duration,          // 服务时长(分钟)
                'price' => $item->project?->price,               // 项目价格
                'discount_amount' => $item->discount_amount,      // 优惠金额
                'final_price' => $item->project?->price - $item->discount_amount,  // 最终价格
                'service_gender' => $item->service_gender,        // 服务性别
                'service_distance' => $item->service_distance,    // 服务距离(米)
                'traffic_fee_type' => $item->traffic_fee_type,   // 路费类型
                'traffic_fee' => $item->traffic_fee,             // 路费金额
                'created_at' => $item->created_at?->format('Y-m-d H:i:s'),
                'updated_at' => $item->updated_at?->format('Y-m-d H:i:s'),
            ];
        })->values()->all();

        return [
            'total' => count($list),
            'list' => $list
        ];
    }

    /**
     * 获取订单统计数据
     *
     * @param int $coachId 技师ID
     * @return array 订单统计数据
     */
    private function getOrderStatistics(int $coachId): array
    {
        // 从 Order 表获取订单统计
        $orderStats = Order::where('coach_id', $coachId)
            ->selectRaw('
                COUNT(*) as total_count,
                SUM(CASE WHEN state = ? THEN 1 ELSE 0 END) as completed_count,
                SUM(CASE WHEN state IN (?,?,?,?,?,?,?,?) THEN 1 ELSE 0 END) as pending_count,
                SUM(CASE WHEN state = ? THEN 1 ELSE 0 END) as carrying_count
            ', [
                OrderStatus::COMPLETED->value,  // 已完成
                OrderStatus::PAID->value,       // 已支付
                OrderStatus::ACCEPTED->value,   // 已接单
                OrderStatus::DEPARTED->value,   // 已出发
                OrderStatus::ARRIVED->value,    // 已到达
                OrderStatus::SERVICE_START->value, // 开始服务
                OrderStatus::SERVICING->value,  // 服务中
                OrderStatus::SERVICE_END->value, // 服务结束
                OrderStatus::LEAVING->value,    // 撤离中
                OrderStatus::PAID->value        // 带接单（已支付）
            ])
            ->first();

        // 获取抢单数量
        $grabOrderCount = OrderGrabRecord::where('coach_id', $coachId)->count();

        return [
            'order_count' => $orderStats->total_count ?? 0,         // 总订单数
            'completed_order_count' => $orderStats->completed_count ?? 0,  // 已完成订单数
            'pending_order_count' => $orderStats->pending_count ?? 0,      // 进行中订单数
            'carrying_order_count' => $orderStats->carrying_count ?? 0,    // 带接单数量
            'grab_order_count' => $grabOrderCount,                  // 抢单数量
        ];
    }
}