orderBy('updated_at', 'desc')->pluck('id')->toArray(); if (empty($matchedIds)) { return Result::success(['rows' => [], 'total' => 0]); } // 2. 递归查所有父级,直到一级分类 $idsStr = implode(',', $matchedIds); $sql = " WITH RECURSIVE parents AS ( SELECT * FROM category WHERE id IN ($idsStr) UNION ALL SELECT c.* FROM category c INNER JOIN parents p ON c.id = p.pid ) SELECT * FROM parents "; $parents = Db::select($sql); $parentIds = []; foreach ($parents as $row) { if ($row->pid == 0) { $parentIds[] = $row->id; } } $parentIds = array_unique($parentIds); } else { // 没有搜索,一级分类就是根 $parentIds = Category::where('pid', 0)->orderBy('updated_at', 'desc')->pluck('id')->toArray(); } // 3. 一级分类分页 $total = count($parentIds); $parentIds = array_slice($parentIds, ($page - 1) * $perPage, $perPage); if (empty($parentIds)) { return Result::success(['rows' => [], 'total' => $total]); } // 4. 递归查所有子孙 $idsStr = implode(',', $parentIds); $sql = " WITH RECURSIVE subcategories AS ( SELECT * FROM category WHERE id IN ($idsStr) UNION ALL SELECT c.* FROM category c INNER JOIN subcategories s ON c.pid = s.id ) SELECT * FROM subcategories ORDER BY updated_at DESC "; $allCategories = Db::select($sql); // 5. 组装树结构 $categoryMap = []; foreach ($allCategories as $cat) { $cat = (array)$cat; $cat['children'] = []; $categoryMap[$cat['id']] = $cat; } foreach ($categoryMap as $id => &$cat) { if ($cat['pid'] && isset($categoryMap[$cat['pid']])) { $categoryMap[$cat['pid']]['children'][] = &$cat; } } unset($cat); $categoryTree = []; foreach ($parentIds as $id) { if (isset($categoryMap[$id])) { $categoryTree[] = $categoryMap[$id]; } } return Result::success([ 'rows' => $categoryTree, 'total' => $total, ]); } private function findMatchedCategories($search) { if ($search) { return Category::where('name', 'like', "%{$search}%") ->orderBy('updated_at', 'desc') ->get(); } return Category::orderBy('updated_at', 'desc') // 按 updated_at 字段倒序排序 ->get(); } private function findAllParents($categories) { $allCategories = []; foreach ($categories as $category) { $parentId = $category->pid; while ($parentId > 0) { $parent = Category::find($parentId); if ($parent) { $allCategories[$parent->id] = $parent; $parentId = $parent->pid; } else { break; } } $allCategories[$category->id] = $category; } return array_values($allCategories); } private function buildCategoryTree($category, $allRequiredCategories) { $categoryData = $category->toArray(); $children = []; foreach ($allRequiredCategories as $c) { if ($c->pid === $category->id) { $children[] = $this->buildCategoryTree($c, $allRequiredCategories); } } if (!empty($children)) { $categoryData['children'] = $children; } return $categoryData; } public function myCategoryList(array $data): array { $sszq = $data['sszq'] ?? ''; unset($data['sszq']); //1,2,3 根据这些webid,。从website_category表中取出对应的分类id,然后从category表中取出分类信息 $catorytids = WebsiteCategory::whereIn('website_id', explode(',', $sszq))->get()->pluck('category_id')->toArray(); $where[] = [ 'pid', '=', $data['pid'], ]; if (isset($data['name'])) { array_push($where, ['category.name', 'like', '%' . $data['name'] . '%']); } var_dump($where); //根据分类id,从category表中取出分类信息 $result = Category::where($where) ->whereIn('category.id', $catorytids) ->select('category.*', 'category.id as category_id')->get(); if (empty($result)) { return Result::error("没有栏目数据"); } return Result::success($result); } /** * @param array $data * @return array */ public function categoryList(array $data): array { $where[] = [ 'pid', '=', $data['pid'] ]; if (isset($data['name'])) { array_push($where, ['category.name', 'like', '%' . $data['name'] . '%']); } var_dump($where); $result = Category::where($where)->select('category.*', 'category.id as category_id')->get(); if (empty($result)) { return Result::error("没有栏目数据"); } return Result::success($result); } /** * @param array $data * @return array */ public function addCategory(array $data): array { if (isset($data['id'])) { unset($data['id']); } $id = Category::insertGetId($data); if (empty($id)) { return Result::error("添加失败"); } return Result::success(['id' => $id]); } /** * @param array $data * @return array */ public function delCategory(array $data): array { Db::beginTransaction(); try { $categoryList = Category::where(['pid' => $data['id']])->get(); if ($categoryList->toArray()) { Db::rollBack(); return Result::error("分类下面有子分类不能删除"); } $articleList = Article::where(['catid' => $data['id']])->get(); if ($articleList->toArray()) { Db::rollBack(); return Result::error("分类下面有资讯不能删除"); } $result = Category::where($data)->delete(); WebsiteCategory::where(['category_id' => $data['id']])->delete(); if (!$result) { Db::rollBack(); return Result::error("删除失败"); } Db::commit(); return Result::success($result); } catch (\Exception $e) { Db::rollBack(); return Result::error("删除失败" . $e->getMessage()); } } /** * @param array $data * @return array */ public function updateCategory(array $data): array { $where = [ 'id' => $data['id'], ]; $result = Category::where($where)->update($data); if ($result) { return Result::success($result); } else { return Result::error("更新失败"); } } /** * 获取导航池信息 * @param array $data * @return array */ public function getCategoryInfo(array $data): array { $where = [ 'id' => $data['id'], ]; $result = Category::where($where)->first(); if ($result) { return Result::success($result); } else { return Result::error("更新失败"); } } /** * @param array $data * @return array */ public function getArticleList(array $data): array { //判断是否是管理员'1:个人会员 2:政务会员 3:企业会员 4:调研员 10000:管理员 20000:游客(小程序)' $type_id = $data['type_id']; unset($data['type_id']); $user_id = $data['user_id']; unset($data['user_id']); $where = []; $status1 = []; if (isset($data['id']) && $data['id']) { array_push($where, ['article.id', '=', $data['id']]); } if (isset($data['title']) && $data['title']) { array_push($where, ['article.title', 'like', '%' . $data['title'] . '%']); } if (isset($data['category_name']) && $data['category_name']) { array_push($where, ['category.name', 'like', '%' . $data['category_name'] . '%']); } if (isset($data['author']) && $data['author']) { array_push($where, ['article.author', '=', $data['author']]); } if (isset($data['islink']) && $data['islink'] !== "") { array_push($where, ['article.islink', '=', $data['islink']]); } if (isset($data['status']) && $data['status'] !== "") { array_push($where, ['article.status', '=', $data['status']]); } if (isset($data['status1'])) { $status1 = json_decode(($data['status1'])); } //不是管理员展示个人数据; if ($type_id != 10000) { $where[] = ['article.admin_user_id', '=', $user_id]; } $rep = Article::where($where) ->whereNotIn('article.status', [404]) ->when($status1, function ($query) use ($status1) { if (isset($status1) && $status1) { $query->whereIn('article.status', $status1); } }) ->leftJoin('category', 'article.catid', 'category.id') ->leftJoin('website_category', function ($join) { $join->on('article.web_site_id', '=', 'website_category.website_id') ->on('article.catid', '=', 'website_category.category_id'); }) ->select("article.*", "category.name as category_name", "website_category.alias") ->orderBy("article.updated_at", "desc") ->limit($data['pageSize']) ->offset(($data['page'] - 1) * $data['pageSize'])->get(); $count = Article::where($where)->whereNotIn('article.status', [404]) ->when($status1, function ($query) use ($status1) { if (isset($status1) && $status1) { $query->whereIn('article.status', $status1); } }) ->leftJoin('category', 'article.catid', 'category.id')->count(); $data = [ 'rows' => $rep->toArray(), 'count' => $count, ]; if (empty($rep)) { return Result::error("没有信息数据"); } return Result::success($data); } /** * @param array $data * @return array */ public function addArticle(array $data): array { var_dump($data, '----------12-----------1'); unset($data['user_type']); unset($data['nav_add_pool_id']); // unset($data['commend_id']); // $data['cat_arr_id'] = is_string($data['cat_arr_id']) ? json_encode($data['cat_arr_id']) : ''; Db::beginTransaction(); try { //处理投票 $is_survey = isset($data['is_survey']) ? $data['is_survey'] : 0; $survey_name = isset($data['survey_name']) ? $data['survey_name'] : ''; $suvey_array = isset($data['suvey_array']) ? $data['suvey_array'] : ''; $website_id = isset($data['website_id']) ? $data['website_id'] : 2; unset($data['is_survey']); unset($data['survey_name']); unset($data['suvey_array']); // unset($data['website_id']); // unset($data['web_site_id']); // $data['web_site_id'] = is_array($data['web_site_id']) ? json_encode($data['web_site_id']) : ($data['web_site_id']); if ($data['hits'] == '') { $data['hits'] = 0; } if ($data['is_original'] == '') { $data['is_original'] = 0; } if ($data['status'] == '') { $data['status'] = 0; } $articleData = $data; unset($articleData['content']); //自动处理缩略图、关键字、描述 if ($articleData['imgurl'] == '') { //如果没有图,设置level=0 $levelArr = json_decode($articleData['level'], true); var_dump($levelArr, '----------levelArr-----------1'); //content中提取图片第一个图,正则提取 $reg = '//i'; preg_match_all($reg, $data['content'], $matches); if (isset($matches[1][0])) { //截取varchar240 $articleData['imgurl'] = substr($matches[1][0], 0, 240); //如果有图,设置level=3 if (!in_array(3, $levelArr)) { $levelArr[] = 3; } $articleData['level'] = json_encode($levelArr); } else { if (!in_array(0, $levelArr)) { $levelArr[] = 0; } $articleData['level'] = json_encode($levelArr); } } var_dump($articleData['level'], '----------$articleData[level]----------1'); if ($articleData['keyword'] == '') { //提取标题+内容中的关键词 $articleData['keyword'] = $data['title']; // . substr(str_replace(' ', '', strip_tags($data['content'])), 0, 20); Jieba::init(); // 初始化 jieba-php Finalseg::init(); $segList = Jieba::cut($articleData['keyword']); $segList1 = array_slice($segList, 0, 8); $articleData['keyword'] = implode(',', $segList1); } if ($articleData['introduce'] == '') { //提取内容中的描述 $content = $data['content']; // 去除