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

<?php

namespace App\Services\Coach;

use App\Models\Project;
use App\Models\CoachUser;
use App\Models\MemberUser;
use App\Enums\ProjectStatus;
use App\Models\SettingGroup;
use App\Enums\TechnicianStatus;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class ProjectService
{
    /**
     * 获取所有可以开通的项目列表
     *
     * 业务流程：
     * 1. 获取所有状态为开放的项目
     * 2. 通过关联查询检查项目开通状态
     * 3. 返回项目列表
     *
     * 注意事项：
     * - 只返回状态为开放的项目
     * - 已开通的项目必须是状态正常的
     * - 使用 leftJoin 优化查询性能
     * - 在数据库层面计算开通状态文本
     *
     * @param CoachUser $coach 技师对象
     * @return array 项目列表，每个项目包含：
     *        - id: int 项目ID
     *        - title: string 项目标题
     *        - subtitle: string|null 项目副标题
     *        - cover: string 项目封面图
     *        - price: decimal 项目价格
     *        - original_price: decimal 原价
     *        - sales: int 销量
     *        - duration: int 服务时长(分钟)
     *        - project_desc: string 项目描述
     *        - service_desc: string 服务说明
     *        - type: int 项目类型
     *        - is_opened: bool 是否已开通
     *        - opened_text: string 开通状态文本(已开通|未开通)
     */
    public function getAvailableProjects(CoachUser $coach): array
    {
        // 使用 leftJoin 优化查询，避免 N+1 问题
        return Project::where('project.state', ProjectStatus::OPEN->value)
            ->leftJoin('coach_project', function ($join) use ($coach) {
                $join->on('project.id', '=', 'coach_project.project_id')
                    ->where('coach_project.coach_id', '=', $coach->id)
                    ->where('coach_project.state', '=', ProjectStatus::OPEN->value);
            })
            ->select([
                'project.id',
                'project.title',
                'project.subtitle',
                'project.cover',
                'project.price',
                'project.original_price',
                'project.sales',
                'project.duration',
                'project.project_desc',
                'project.service_desc',
                'project.type',
                DB::raw('CASE WHEN coach_project.id IS NOT NULL THEN true ELSE false END as is_opened'),
                DB::raw('CASE WHEN coach_project.id IS NOT NULL THEN "已开通" ELSE "未开通" END as opened_text'),
            ])
            ->get()
            ->toArray();
    }

    /**
     * 技师开通项目
     *
     * @param  int  $userId  技师用户ID
     * @param  array  $data  开通项目数据
     */
    public function openProject(int $userId, array $data): array
    {
        return DB::transaction(function () use ($userId, $data) {
            try {
                // 加载用户和技师信息
                $user = MemberUser::with(['coach', 'coach.projects'])->findOrFail($userId);
                abort_if(! $user->coach, 404, '技师信息不存在');

                // 验证项目是否存在且状态正常
                $project = Project::where('id', $data['project_id'])
                    ->where('state', ProjectStatus::OPEN->value)
                    ->first();
                abort_if(! $project, 404, '项目不存在或已下架');

                // 检查是否已开通该项目
                $existingProject = $user->coach->projects()
                    ->where('project_id', $data['project_id'])
                    ->first();
                abort_if($existingProject, 422, '已开通该项目');

                // 检查技师状态
                abort_if($user->coach->state !== TechnicianStatus::ACTIVE->value,
                    422, '技师状态异常，无法开通项目');

                // 创建技师项目关联
                $coachProject = $user->coach->projects()->create([
                    'project_id' => $data['project_id'],
                    'state' => ProjectStatus::OPEN->value,
                    'discount_amount' => 0.00,
                    'service_gender' => 0,
                    'service_distance' => 0,
                    'traffic_fee_type' => 2,
                    'traffic_fee' => 0,
                    'created_at' => now(),
                    'updated_at' => now(),
                ]);

                // 记录日志
                Log::info('技师开通项目成功', [
                    'user_id' => $userId,
                    'coach_id' => $user->coach->id,
                    'project_id' => $data['project_id'],
                    'project_name' => $project->name,
                ]);

                return [
                    'message' => '项目开通成功',
                    'project_id' => $project->id,
                    'project_name' => $project->name,
                ];

            } catch (\Exception $e) {
                Log::error('技师开通项目失败', [
                    'user_id' => $userId,
                    'data' => $data,
                    'error' => $e->getMessage(),
                    'file' => $e->getFile(),
                    'line' => $e->getLine(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 设置项目
     *
     * @param  int  $userId  技师用户ID
     * @param  array  $data  项目设置数据
     * @return array
     *
     * @throws \Exception
     */
    public function setProject(int $userId, array $data)
    {
        return DB::transaction(function () use ($userId, $data) {
            try {
                // 加载用户和技师信息
                $user = MemberUser::with(['coach', 'coach.projects'])->findOrFail($userId);
                abort_if(! $user->coach, 404, '技师信息不存在');

                // 检查项目是否存在
                $coachProject = $user->coach->projects()
                    ->where('project_id', $data['project_id'])
                    ->first();
                abort_if(! $coachProject, 404, '未开通该项目');

                // 获取全局项目设置分组
                $projectSettingGroup = SettingGroup::where('code', 'project')->first();
                abort_if(! $projectSettingGroup, 404, '项目设置分组不存在');

                // 获取项目设置中代金卷、交通费、顾客性别设置
                $projectSettingItems = $projectSettingGroup->items()->where('code', 'voucher')->orWhere('code', 'traffic_fee')->orWhere('code', 'gender')->get();

                // 检查代金卷金额是否存在，并且是否大于0
                if (isset($data['voucher']) && $data['voucher'] > 0) {
                    $voucherSettingItem = $projectSettingItems->where('code', 'voucher')->first();
                    abort_if(! $voucherSettingItem, 404, '代金卷设置不存在');

                    // 从项目设置中验证代金卷金额的合理范围
                    abort_if($data['voucher'] > $voucherSettingItem->max_value, 422, '代金卷金额不能超过'.$voucherSettingItem->max_value.'元');

                    // 更新技师折扣金额配置
                    $user->coach->settingValues()->updateOrCreate(
                        ['item_id' => $projectSettingItems->where('code', 'voucher')->first()->id],
                        ['value' => $data['voucher']],
                        ['object_type' => $coachProject::class],
                        ['object_id' => $coachProject->id],
                    );
                }

                // 检查路费设置是否存在，并且是否大于0
                if (isset($data['traffic_fee']) && $data['traffic_fee'] >= 0) {
                    $trafficFeeSettingItem = $projectSettingItems->where('code', 'traffic_fee')->first();
                    abort_if(! $trafficFeeSettingItem, 404, '路费设置不存在');

                    // 从项目设置中验证交通费类型的合理范围
                    abort_if($data['traffic_fee'] > $trafficFeeSettingItem->max_value, 422, '交通费类型不能超过'.$trafficFeeSettingItem->max_value.'元');

                    // 更新技师路费配置
                    $user->coach->settingValues()->updateOrCreate(
                        ['item_id' => $projectSettingItems->where('code', 'traffic_fee')->first()->id],
                        ['value' => $data['traffic_fee']],
                        ['object_type' => $coachProject::class],
                        ['object_id' => $coachProject->id],
                    );
                }

                // 检查顾客性别设置是否存在，并且是否大于0
                if (isset($data['gender']) && $data['gender'] >= 0) {
                    $customerGenderSettingItem = $projectSettingItems->where('code', 'gender')->first();
                    abort_if(! $customerGenderSettingItem, 404, '顾客性别设置不存在');

                    // 从项目设置中验证顾客性别设置的合理范围
                    abort_if($data['gender'] > $customerGenderSettingItem->max_value, 422, '顾客性别设置不能超过'.$customerGenderSettingItem->max_value.'元');

                    // 更新技师顾客性别设置
                    $user->coach->settingValues()->updateOrCreate(
                        ['item_id' => $projectSettingItems->where('code', 'gender')->first()->id],
                        ['value' => $data['gender']],
                        ['object_type' => $coachProject::class],
                        ['object_id' => $coachProject->id],
                    );
                }

                // 记录日志
                Log::info('技师项目设置更新成功', [
                    'user_id' => $userId,
                    'coach_id' => $user->coach->id,
                    'project_id' => $data['project_id'],
                    'settings' => $data,
                ]);

                return [
                    'message' => '项目设置更新成功',
                    'coach_id' => $user->coach->id,
                    'settings' => $data,
                ];

            } catch (\Exception $e) {
                Log::error('技师项目设置更新失败', [
                    'user_id' => $userId,
                    'data' => $data,
                    'error' => $e->getMessage(),
                    'file' => $e->getFile(),
                    'line' => $e->getLine(),
                ]);
                throw $e;
            }
        });
    }
}