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(); } /** * 技师开通/关闭项目 * * 业务流程: * 1. 验证技师状态 * 2. 验证项目状态 * 3. 根据操作类型处理项目 * 4. 返回操作结果 * * @param CoachUser $coach 技师对象 * @param array $data 项目操作数据,包含: * - project_id: int 项目ID * - action: string 操作类型(open:开通 close:关闭) * @return array 操作结果,包含: * - project_id: int 项目ID * - project_name: string 项目名称 * - state: int 项目状态 * - state_text: string 状态描述 * @throws \Illuminate\Http\Exceptions\HttpResponseException 当验证失败时抛出异常 */ public function openProject(CoachUser $coach, array $data): array { return DB::transaction(function () use ($coach, $data) { // 检查技师状态是否正常 $coach->validateActiveStatus('技师状态异常,无法操作项目'); // 验证项目是否存在且状态为开放 $project = Project::validateOpenProject($data['project_id']); // 根据操作类型处理项目并获取状态 $state = match ($data['action']) { 'open' => $this->handleProjectOpen($coach, $data['project_id']), 'close' => $this->handleProjectClose($coach, $data['project_id']), }; // 返回格式化的操作结果 return $project->formatActionResult($state); }); } /** * 处理项目开通 * * @param CoachUser $coach 技师对象 * @param int $projectId 项目ID * @return int 返回开通后的状态值 */ private function handleProjectOpen(CoachUser $coach, int $projectId): int { // 创建或更新项目关联为开通状态 $coach->updateOrCreateProjectRelation($projectId, ProjectStatus::OPEN->value); return ProjectStatus::OPEN->value; } /** * 处理项目关闭 * * @param CoachUser $coach 技师对象 * @param int $projectId 项目ID * @return int 返回关闭后的状态值 */ private function handleProjectClose(CoachUser $coach, int $projectId): int { // 创建或更新项目关联为关闭状态 $coach->updateOrCreateProjectRelation($projectId, ProjectStatus::CLOSE->value); return ProjectStatus::CLOSE->value; } /** * 设置项目 * * @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; } }); } }