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

<?php

namespace App\Services\Coach;

use App\Enums\TechnicianAuthStatus;
use App\Enums\TechnicianLocationType;
use App\Models\MemberUser;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;

class AccountService
{
    private const CACHE_KEY_PREFIX = 'coach_info_';

    private const CACHE_TTL = 300; // 5分钟

    /**
     * 提交技师基本信息
     */
    public function submitBaseInfo($user, array $data)
    {
        DB::beginTransaction();
        try {
            $this->setTransactionConfig();

            abort_if(! $user->coach, 404, '技师信息不存在');

            // 检查是否有待审核的记录
            $pendingRecord = $user->coach->infoRecords()
                ->where('state', TechnicianAuthStatus::AUDITING->value)
                ->exists();
            abort_if($pendingRecord, 422, '已有待审核的基本信息记录');

            // 创建技师信息
            $record = $user->coach->infoRecords()->create(array_merge($data, [
                'state' => TechnicianAuthStatus::AUDITING->value,
            ]));

            // 清除技师信息缓存
            $this->clearCoachCache($user->coach->id);

            DB::commit();

            $this->logInfo('技师提交基本信息成功', $user, $data);

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

        } catch (\Exception $e) {
            DB::rollBack();
            $this->logError('提交技师基本信息失败', $user, $data, $e);
            throw $e;
        }
    }

    /**
     * 提交技师资质信息
     */
    public function submitQualification($user, array $data)
    {
        DB::beginTransaction();
        try {
            $this->setTransactionConfig();

            abort_if(! $user->coach, 404, '技师信息不存在');

            // 检查是否有待审核的记录
            $pendingRecord = $user->coach->qualRecords()
                ->where('state', TechnicianAuthStatus::AUDITING->value)
                ->exists();
            abort_if($pendingRecord, 422, '已有待审核的资质信息记录');

            // 创建资质信息
            $record = $user->coach->qualRecords()->create(array_merge($data, [
                'state' => TechnicianAuthStatus::AUDITING->value,
            ]));

            // 清除技师信息缓存
            $this->clearCoachCache($user->coach->id);

            DB::commit();

            $this->logInfo('技师提交资质信息成功', $user, $data);

            return ['message' => '资质信息提交成功'];

        } catch (\Exception $e) {
            DB::rollBack();
            $this->logError('提交技师资质信息失败', $user, $data, $e);
            throw $e;
        }
    }

    /**
     * 提交实名认证信息
     */
    public function submitRealName($user, array $data)
    {
        DB::beginTransaction();
        try {
            $this->setTransactionConfig();

            abort_if(! $user->coach, 404, '技师信息不存在');

            // 检查是否有待审核的记录
            $pendingRecord = $user->coach->realRecords()
                ->where('state', TechnicianAuthStatus::AUDITING->value)
                ->exists();
            abort_if($pendingRecord, 422, '已有待审核的实名认证信息');

            // 创建实名认证信息
            $record = $user->coach->realRecords()->create(array_merge($data, [
                'state' => TechnicianAuthStatus::AUDITING->value,
            ]));

            // 清除技师信息缓存
            $this->clearCoachCache($user->coach->id);

            DB::commit();

            $this->logInfo('技师提交实名认证信息成功', $user, $this->maskSensitiveData($data));

            return ['message' => '实名认证信息提交成功'];

        } catch (\Exception $e) {
            DB::rollBack();
            $this->logError('提交实名认证信息失败', $user, $this->maskSensitiveData($data), $e);
            throw $e;
        }
    }

    /**
     * 获取技师信息
     */
    public function getCoachInfo($user)
    {
        try {
            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);
                }
            );
        } catch (\Exception $e) {
            $this->logError('获取技师信息失败', $user, [], $e);
            throw $e;
        }
    }

    /**
     * 设置事务配置
     */
    private function setTransactionConfig()
    {
        DB::statement('SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED');
        DB::statement('SET SESSION innodb_lock_wait_timeout=10');
    }

    /**
     * 记录信息日志
     */
    private function logInfo(string $message, $user, array $data)
    {
        Log::info($message, [
            'user_id' => $user->id,
            'coach_id' => $user->coach->id,
            'data' => $data,
            'ip' => request()->ip(),
            'timestamp' => now()->toDateTimeString(),
        ]);
    }

    /**
     * 记录错误日志
     */
    private function logError(string $message, $user, array $data, \Exception $e)
    {
        Log::error($message, [
            'user_id' => $user->id,
            'coach_id' => $user->coach->id ?? null,
            'data' => $data,
            'error' => $e->getMessage(),
            'file' => $e->getFile(),
            'line' => $e->getLine(),
            'ip' => request()->ip(),
            'timestamp' => now()->toDateTimeString(),
        ]);
    }

    /**
     * 获取技师详细信息
     */
    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,
        ];
    }

    /**
     * 格式化基本信息
     */
    private function formatBaseInfo($info)
    {
        return [
            'nickname' => $info->nickname,
            'avatar' => $info->avatar,
            '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' => TechnicianAuthStatus::fromValue($info->state)->label(),
            'audit_remark' => $info->audit_remark,
        ];
    }

    /**
     * 格式化资质信息
     */
    private function formatQualification($qual)
    {
        return [
            'qual_type' => $qual->qual_type,
            'qual_no' => $qual->qual_no,
            'qual_photo' => $qual->qual_photo,
            'valid_start' => $qual->valid_start,
            'valid_end' => $qual->valid_end,
            'state' => $qual->state,
            'state_text' => TechnicianAuthStatus::fromValue($qual->state)->label(),
            'audit_remark' => $qual->audit_remark,
        ];
    }

    /**
     * 格式化实名信息
     */
    private function formatRealName($real)
    {
        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' => TechnicianAuthStatus::fromValue($real->state)->label(),
            'audit_remark' => $real->audit_remark,
        ];
    }

    /**
     * 手机号脱敏
     */
    private function maskMobile($mobile)
    {
        return substr_replace($mobile, '****', 3, 4);
    }

    /**
     * 身份证号脱敏
     */
    private function maskIdCard($idCard)
    {
        return substr_replace($idCard, '****', 6, 8);
    }

    /**
     * 敏感数据脱敏
     */
    private function maskSensitiveData(array $data)
    {
        if (isset($data['id_card'])) {
            $data['id_card'] = $this->maskIdCard($data['id_card']);
        }
        if (isset($data['mobile'])) {
            $data['mobile'] = $this->maskMobile($data['mobile']);
        }

        return $data;
    }

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

    /**
     * 设置定位信息
     *
     * @param  int  $coachId  技师ID
     * @param  float  $latitude  纬度
     * @param  float  $longitude  经度
     * @param  int  $type  位置类型 (current：1|common：2)
     * @return bool
     *
     * @throws \Exception
     */
    public function setLocation($coachId, $latitude, $longitude, $type = TechnicianLocationType::COMMON->value)
    {
        DB::beginTransaction();
        try {
            // 验证经纬度参数
            if (! is_numeric($latitude) || ! is_numeric($longitude)) {
                throw new \Exception('无效的经纬度坐标');
            }

            // 验证位置类型
            if (! in_array($type, [TechnicianLocationType::CURRENT->value, TechnicianLocationType::COMMON->value])) {
                throw new \Exception('无效的位置类型');
            }

            // 生成Redis键
            $key = $coachId.'_'.$type;

            // 将位置信息写入Redis
            $result = Redis::geoadd('coach_locations', $longitude, $latitude, $key);

            // 同时写入数据库保存历史记录
            DB::table('coach_locations')->updateOrInsert(
                ['coach_id' => $coachId, 'type' => $type],
                [
                    'latitude' => $latitude,
                    'longitude' => $longitude,
                    'updated_at' => now(),
                ]
            );

            DB::commit();

            Log::info('技师位置信息设置成功', [
                'coach_id' => $coachId,
                'type' => $type,
                'latitude' => $latitude,
                'longitude' => $longitude,
            ]);

            return $result;

        } catch (\Exception $e) {
            DB::rollBack();
            Log::error('技师位置信息设置异常', [
                'coach_id' => $coachId,
                'latitude' => $latitude,
                'longitude' => $longitude,
                'type' => $type,
                'error' => $e->getMessage(),
                'file' => $e->getFile(),
                'line' => $e->getLine(),
            ]);
            throw $e;
        }
    }

    /**
     * 获取技师位置信息
     *
     * @param  int  $userId  用户ID
     * @return array 位置信息
     */
    public function getLocation($userId)
    {
        try {
            // 改进：直接使用 coach 模型
            $user = MemberUser::find($userId);
            abort_if(! $user, 404, '用户不存在');
            abort_if(! $user->coach, 404, '技师信息不存在');

            // 获取常用位置信息
            $location = $user->coach->locations()
                ->where('type', TechnicianLocationType::COMMON->value)
                ->first();

            $result = [
                'address' => $location ? $location->location : null,
            ];

            // 记录日志
            Log::info('获取技师常用位置信息成功', [
                'coach_id' => $user->coach->id,
                'location' => $result,
            ]);

            return $result;

        } catch (\Exception $e) {
            Log::error('获取技师常用位置信息异常', [
                'coach_id' => $user->coach->id ?? null,
                'error' => $e->getMessage(),
                'file' => $e->getFile(),
                'line' => $e->getLine(),
            ]);
            throw $e;
        }
    }
}