public_producer/app/JsonRpc/WebsiteService.php

<?php

namespace App\JsonRpc;

use App\Model\Article;

use App\Model\Ad;
use App\Model\Category;

use App\Model\AdPlace;
use App\Model\Department;
use App\Model\District;
use App\Model\FooterCategory;
use App\Model\FooterContent;
use App\Model\WebsiteTemplateInfo;
use App\Model\Link;
use App\Model\LetterOfComplaint;
use App\Model\TemplateClass;
use App\Model\Template;
use App\Model\User;
use App\Model\UserInfo;
use App\Model\WebsiteRole;
use App\Model\WebsiteRoleUser;
use App\Model\Website;
use App\Model\WebsiteColumn;
use App\Model\Good;
use App\Model\Book;
use App\Model\ChatRecords;
use App\Model\ChatTopic;
use App\Model\JobRecruiting;
use App\Model\JobHunting;
use App\Model\Notice;
use App\Model\Complaint;
use App\Model\Order;
use App\Model\WebsiteImg;
use App\Model\Company;
use App\Model\Project;
use App\Model\ChatTopicsReply;
use Hyperf\HttpServer\Contract\RequestInterface;

use Hyperf\DbConnection\Db;
use Hyperf\RpcServer\Annotation\RpcService;
use App\Tools\Result;
use Carbon\Carbon;
use App\Model\WebsiteCategory;
use App\Model\WebsiteGroup;
use App\Model\WebsiteTemplate;
use App\Model\Sector;
use PhpParser\Node\Stmt\Return_;
use SimpleKafkaClient\Metadata\Topic;
use function PHPUnit\Framework\isNull;
use Overtrue\Pinyin\Pinyin;
use App\Tools\buildTree;
use App\Model\WhiteRouter;
use App\Model\Size;
use App\Tools\PinyinHelper;
use Hyperf\HttpServer\Annotation\AutoController;
use Hyperf\Utils\Parallel;
use Hyperf\Coroutine\Concurrent;
use function Hyperf\Coroutine\batch;
use Swoole\Coroutine;

#[RpcService(name: "WebsiteService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
class WebsiteService implements WebsiteServiceInterface
{
    /**
     * 获取网站列表
     * @param string $keyword
     * @param int $page
     * @param int $pageSize
     * @return array
     */
    public function getWebsitetList(array $data): array
    {
        // 构建查询
        $query = Website::when($data, function ($query) use ($data) {
            if (isset($data['keyword']) && !empty($data['keyword'])) {
                $query->where('website.website_name', 'like', '%' . trim($data['keyword']) . '%');
            }
            if (isset($data['website_column_id']) && !empty($data['website_column_id'])) {
                $query->whereJsonContains("website.website_column_arr_id", intval($data['website_column_id']));
            }
            if (isset($data['city_id']) && !empty($data['city_id'])) {
                $query->whereJsonContains("website.city_arr_id", intval($data['city_id']));
            }
        });

        // 执行查询并获取总数和结果
        $queryWithJoins = $query->leftJoin("website_column", "website.website_column_id", "website_column.id")
            ->leftJoin("district", "district.id", "website.city_id");

        $count = $queryWithJoins->count();
        $result = $queryWithJoins->select("website.*", "website_column.column_name", "district.name as city_name")
            ->limit($data['pageSize'])
            ->offset(($data['page'] - 1) * $data['pageSize'])
            ->orderBy("website.updated_at", "desc")
            ->get();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        $data = [
            'rows' => $result->toArray(),
            'count' => $count,
        ];
        return Result::success($data);
    }

    /**
     * @param array $data
     */
    public function createWebsite(array $data): array
    {
        var_dump("网站数据:", $data);
        // $wzbs = $this->getWebsitetAdkey($data);
        // return Result::success($wzbs);
        $web = Website::where('ad_key', $data['ad_key'])->first();
        if (!empty($web)) {
            return Result::error("网站名称简写重复,请填写", 0);
        }
        $insertData = [
            'website_name' => $data['website_name'],
            'logo' => $data['logo'] ?? '',
            'website_url' => $data['website_url'] ?? '',
            //'city_id'=>$data['city_id']??0,
            'website_column_id' => $data['website_column_id'],
            'title' => $data['title'] ?? '',
            'keywords' => $data['keywords'] ?? '',
            'description' => $data['description'] ?? '',
            'status' => $data['status'] ?? 1,
            'website_column_arr_id' => $data['website_column_arr_id'],
            //'city_arr_id'=>$data['city_arr_id']??[0],
            'template_id' => $data['template_id'] ?? 0,
            'suffix' => $data['suffix'] ?? "",
            'ad_key' => $data['ad_key'] ?? "",
        ];
        $result = Website::insertGetId($insertData);
        if (empty($result)) {
            return Result::error("创建网站失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }

    /**
     * 修改网站头部基础信息
     * @param array $data
     */
    public function updateWebsite(int $id, array $data): array
    {
        $website = Website::where('id', $id)->first();
        if (empty($website)) {
            return Result::error("网站不存在", 0);
        }
        $insertData = [
            'website_name' => $data['website_name'],
            'logo' => $data['logo'] ?? '',
            'website_url' => $data['website_url'] ?? '',
            //           'city_id'=>$data['city_id']??0,
            'website_column_id' => $data['website_column_id'],
            'title' => $data['title'] ?? '',
            'keywords' => $data['keywords'] ?? '',
            'description' => $data['description'] ?? '',
            //            'status' => $data['status'] ?? 0,
            'website_column_arr_id' => $data['website_column_arr_id'],
            //           'city_arr_id'=>$data['city_arr_id']??[0],
            'template_id' => $data['template_id'] ?? 0,
            'suffix' => $data['suffix'] ?? "",
            'ad_key' => $data['ad_key'] ?? "",
        ];
        // $web_templsate = WebsiteTemplateInfo::where('website_id', $data['id'])->first();
        // `status` tinyint(1) DEFAULT '0' COMMENT '0:未构建 1:未应用 2：已应用',
        // if (!empty($web_templsate) && $web_templsate['status'] == 2) {
        //     return Result::error("此网站已应用，不可修改基本信息", 0);
        // }
       
       Db::beginTransaction();
       try{
            if($data['ad_key'] !=  $website['ad_key']){
                $web = Website::where(function ($query) use ($data) {
                    $query->where('id', '!=', $data['id'])
                        ->where('ad_key', $data['ad_key']);
                })->first();
                if (!empty($web)) {
                    Db::rollBack();
                    return Result::error("网站名称简写重复,请填写", 0);
                }
                $ad_place = AdPlace::where('website_id', $data['id'])->select('ad_tag', 'id')->get()->toArray();
                if (!empty($ad_place)) {
                    foreach ($ad_place as $key => $val) {
                        $ad_keys = explode('_', $val['ad_tag']);
                        $ad_keys[0] = $data['ad_key'];
                        $ad_place[$key]['ad_tag'] = implode('_', $ad_keys);

                        // $up_adtags = AdPlace::where('id', $val['id'])->update(['ad_tag' => $ad_tags[$key]]);

                    }
                    $up_adtags = AdPlace::upsert($ad_place, ['id'], ['ad_tag']);

                    if (empty($up_adtags)) {
                        Db::rollBack();
                        return Result::error('广告位标识同步失败', 0);
                    }
                }
                $template = WebsiteTemplate::where('website_id', $data['id'])->first();
                if (!empty($template)) {
                    // Eloquent 没有 replace 方法，推测你可能是想替换模板中的字符串，假设是更新 content 字段
                    $uptemplate = WebsiteTemplate::where('website_id', $data['id'])->update([
                        'template_data' => DB::raw("REPLACE(template_data, '{$website['ad_key']}', '{$data['ad_key']}')")
                    ]);
                    if (empty($uptemplate)) {
                        Db::rollBack();
                        return Result::error("更新模板失败！", 0);
                    }
                }
            }
            // return Result::success($UP_template);

            $result = Website::where('id', $data['id'])->update($insertData);
            if (empty($result)) {
                Db::rollBack();
                return Result::error("更新网站失败！", 0);
            }
            Db::commit();
            return Result::success("更新成功");
        } catch (\Exception $e) {
            Db::rollBack();
            return Result::error($e->getMessage(), 0);
        }
    }
    /**
     * @param int $id
     * @return array
     */
    public function delWebsite(int $id): array
    {
        $result = Website::where('id', $id)->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * @param int $id
     * @return array
     */
    public function getWebsiteInfo(int $id): array
    {

        $where = [
            ['website.id', '=', $id],
        ];
        $result = Website::where($where)
            ->leftJoin("template", "template.id", "website.template_id")
            ->select("website.*", "template.template_name", "template.template_img")
            ->first();
        if (empty($result)) {
            return Result::error("数据不存在", 0);
        } else {
            return Result::success($result->toArray());
        }
    }

    /**
     * 查询所有的站点栏目
     * @return array
     */
    public function getWebsiteColumn(array $data): array
    {
        $result = WebsiteColumn::where($data)->get();
        if (empty($result)) {
            return Result::error("数据不存在", 0);
        } else {
            return Result::success($result->toArray());
        }
    }

    /**
     * @param string $keyword
     * @param int $page
     * @param int $pageSize
     * @return array
     */
    public function getWebsiteColumnList(array $data): array
    {
        $where = [];
        if (isset($data['keyword']) && $data['keyword']) {
            array_push($where, ['website_column.column_name', 'like', '%' . $data['keyword'] . '%']);
        }
        $result = WebsiteColumn::where($where)
            ->leftJoin("website_column as wc", "website_column.pid", "wc.id")
            ->select("website_column.*", "wc.column_name as parent_column_name")
            ->limit($data['pageSize'])->offset(($data['page'] - 1) * $data['pageSize'])->get();
        $count = WebsiteColumn::where($where)->count();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        $data = [
            'rows' => $result->toArray(),
            'count' => $count,
        ];
        return Result::success($data);
    }

    /**
     * @param array $data
     * @return array
     */
    public function createWebsiteColumn(array $data): array
    {
        $insertData = [
            'column_name' => $data['column_name'],
            'pid' => $data['pid'] ?? '',
            'column_arr_id' => $data['column_arr_id'] ?? [0],
            'sort' => $data['sort'] ?? 0,
            'remark' => $data['remark'] ?? '',
        ];
        $result = WebsiteColumn::insertGetId($insertData);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }

    /**
     * @param int $id
     * @param array $data
     * @return array
     */
    public function updateWebsiteColumn(int $id, array $data): array
    {
        $insertData = [
            'column_name' => $data['column_name'],
            'pid' => $data['pid'] ?? '',
            'column_arr_id' => $data['column_arr_id'] ?? [0],
            'sort' => $data['sort'] ?? 0,
            'remark' => $data['remark'] ?? '',
        ];
        $result = WebsiteColumn::where('id', $id)->update($insertData);
        if (empty($result)) {
            return Result::error("更新失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * @param int $id
     * @return array
     */
    public function delWebsiteColumn(int $id): array
    {
        $list = WebsiteColumn::where(['pid' => $id])->get();
        if ($list) {
            return Result::error("存在子网系,不能删除,请先删除子网系", 0);
        }
        $result = WebsiteColumn::where('id', $id)->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * @param string $keyword
     * @param int $page
     * @param int $pageSize
     * @return array
     */
    public function getWebsiteRoleList(string $keyword, int $page, int $pageSize, int $websiteId): array
    {
        $where = [
            ['role.role_name', 'like', '%' . $keyword . '%'],
            ['website_role.website_id', '=', $websiteId],
        ];
        $result = WebsiteRole::where($where)
            ->leftJoin("role", "role.id", "website_role.role_id")
            ->select("role.*", "website_role.type", "website_role.role_id", "website_role.id as website_role_id", "website_role.website_id")
            ->limit($pageSize)->offset(($page - 1) * $pageSize)->get();
        $count = WebsiteRole::where($where)->leftJoin("role", "role.id", "website_role.role_id")->count();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        $data = [
            'rows' => $result->toArray(),
            'count' => $count,
        ];
        return Result::success($data);
    }

    /**
     * @param array $data
     * @return array
     */
    public function createWebsiteRole(array $data): array
    {

        $insertData = [
            'website_id' => $data['website_id'],
            'role_id' => $data['role_id'] ?? '',
        ];
        $info = WebsiteRole::where($insertData)->first();
        if ($info) {
            return Result::error("不能重复添加角色", 0);
        }
        $insertData['admin_user_id'] = $data['admin_user_id'] ?? '';
        $insertData['type'] = $data['type'] ?? '';
        $result = WebsiteRole::insertGetId($insertData);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }

    /**
     * 暂时用不上
     * @param int $id
     * @param array $data
     * @return array
     */
    public function updateWebsiteRole(int $id, array $data): array
    {
        $insertData = [
            'website_id' => $data['website_id'],
            'type' => $data['type'] ?? '',
        ];
        $result = WebsiteRole::where('id', $id)->update($insertData);
        if (empty($result)) {
            return Result::error("更新失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * @param int $id
     * @return array
     */
    public function delWebsiteRole(int $id): array
    {
        $result = WebsiteRole::where('id', $id)->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * @param string $keyword
     * @param int $page
     * @param int $pageSize
     * @return array
     */
    public function getWebsiteRoleUserList(string $keyword, int $page, int $pageSize, int $websiteId, int $roleId): array
    {
        $where = [
            ['website_role_user.website_id', '=', $websiteId],
            ['website_role_user.role_id', '=', $roleId],
        ];
        $count = WebsiteRoleUser::where($where)->count();
        $where[] = ['u.user_name', 'like', '%' . $keyword . '%'];
        $result = WebsiteRoleUser::where($where)
            ->leftJoin("user as u", "website_role_user.user_id", "u.id")
            ->leftJoin("website as w", "website_role_user.website_id", "u.id")
            ->leftJoin("role as r", "website_role_user.role_id", "r.id")
            ->select("u.*", "u.user_name", 'w.website_name', 'r.role_name', 'website_role_user.id as website_role_user_id', 'website_role_user.updated_at as user_update_at')
            ->limit($pageSize)->offset(($page - 1) * $pageSize)->get();

        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        $data = [
            'rows' => $result->toArray(),
            'count' => $count,
        ];
        return Result::success($data);
    }

    /**
     * @param array $data
     * @return array
     */
    public function createWebsiteRoleUser(array $data): array
    {
        $insertData = [
            'website_id' => $data['website_id'],
            'user_id' => $data['user_id'] ?? '',
        ];
        $info = WebsiteRoleUser::where($insertData)->first();
        if ($info) {
            return Result::error("不能重复添加角色用户", 0);
        }
        $insertData['role_id'] = $data['role_id'] ?? '';
        $insertData['admin_user_id'] = $data['admin_user_id'] ?? '';
        $insertData['type'] = $data['type'] ?? '';
        $result = WebsiteRoleUser::insertGetId($insertData);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }

    /**
     * @param int $id
     * @param array $data
     * @return array
     */
    public function updateWebsiteRoleUser(int $id, array $data): array
    {
        $insertData = [
            'website_id' => $data['website_id'],
            'type' => $data['type'] ?? '',
            'type_id' => $data['type_id'] ?? '',
            'role_id' => $data['role_id'] ?? '',
        ];
        $result = WebsiteRoleUser::where('id', $id)->update($insertData);
        if (empty($result)) {
            return Result::error("更新失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * @param int $id
     * @return array
     */
    public function delWebsiteRoleUser(int $id): array
    {
        $result = WebsiteRoleUser::where('id', $id)->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * 根据域名获取网站 站点id
     * @param array $data
     * @return array
     */
    public function getWebsiteId(array $data): array
    {
        $result = Website::whereJsonContains('website_url', $data['website_url'])->first();
        if (empty($result)) {
            return Result::error("查询站点失败", 0);
        } else {
            return Result::success($result);
        }
    }

    /**
     * 查询网站下面的导航
     * @param array $data
     * @return array
     */
    public function getWebsiteCategory(array $data): array
    {
        $where = [
            'website_id' => $data['website_id'],
        ];
        // 使用递归查询构建树状结构
        $category = WebsiteCategory::where($where)
            ->with([
                'children' => function ($query) {
                    $query->orderBy('sort', 'asc');
                },
            ])
            ->orderBy('sort', 'asc')
            ->where('pid', 0) // 仅查询顶级节点
            ->get()->all();
        if (empty($category)) {
            return Result::error("查询站点栏目失败", 0);
        } else {
            $count = WebsiteCategory::where($where)->count();
            $result = [
                'rep' => $category,
                'count' => $count,
            ];
            return Result::success($result);
        }
    }

    /**
     * 查询网站的广告
     * @param array $data
     * @return array
     */
    public function getWebsiteAdvertisement(array $data): array
    {
        $where = [
            'ad_place.status' => 1,
        ];
        if (isset($data['ad_tag']) && !empty($data['ad_tag'])) {
            $now = Carbon::now()->format('Y-m-d H:i:s'); // 获取当前时间
            $where[] = ['ad_place.ad_tag', 'like', '%' . $data['ad_tag'] . '%'];
            // return Result::success($where);
            $result =  AdPlace::where($where)
                ->leftJoin("ad", function ($join) use ($now) {
                    $join->on("ad.pid", "=", "ad_place.id")
                        ->where('ad.status', 1)
                        ->where('ad.fromtime', '<=', $now)
                        ->where('ad.totime', '>=', $now);
                })
                ->select(
                    'ad_place.name as place_name',
                    'ad_place.thumb',
                    'ad_place.ad_tag',
                    'ad_place.introduce',
                    'ad.name as ad_name',
                    'ad.image_src',
                    'ad.image_url',
                    'ad.image_alt',
                    'ad_place.ad_url'
                )
                ->get()->all();
        } else {
            $now = Carbon::now()->format('Y-m-d H:i:s'); // 获取当前时间
            // return Result::success($where);
            $result =  AdPlace::where($where)
                ->where('ad_place.website_id', $data['website_id'])
                ->leftJoin("ad", function ($join) use ($now) {
                    $join->on("ad.pid", "=", "ad_place.id")
                        ->where('ad.status', 1)
                        ->where('ad.fromtime', '<=', $now)
                        ->where('ad.totime', '>=', $now);
                })
                ->select(
                    'ad_place.name as place_name',
                    'ad_place.thumb',
                    'ad_place.ad_tag',
                    'ad_place.introduce',
                    'ad.name as ad_name',
                    'ad.image_src',
                    'ad.image_url',
                    'ad.image_alt',
                    'ad_place.ad_url',
                )
                ->get()->all();
            // return Result::error("请选择广告位！",0);
        }
        if (empty($result)) {
            return Result::error("此广告位不存在！", 0);
        }
        return Result::success($result);
    }

    /**
     *
     * @param array $data
     * @return array
     */
    /**网站行政职能搜索 */
    public function selectWebsiteDepartment(array $data): array
    {

        $depart = Department::where('pid', 0)->orderBy('id', 'asc')->get();
        if (isset($data['keyword']) && !empty($data['keyword'])) {
            $departments = Department::where('name', 'like', '%' . $data['keyword'] . '%')->get();
            if (empty($departments)) {
                $result['message'] = "未查询到与此相关职能部门";
            } else {
                $count = Department::where('name', 'like', "%{$data['keyword']}%")->count();
                $m = [
                    'department' => $depart,
                    'type' => $departments,
                    'count' => $count,
                ];
            }

            $result['sele'] = $m;
            return Result::success($result['sele']);
        }
        $result = $depart;
        return Result::success($result);
    }

    /**
     * 搜索地区
     * @param array $data
     * @return array
     */
    public function selectWebsiteArea(array $data): array
    {

        // return Result::success($data);
        $pid = $data['pid'] ?? 0;
        $result = District::leftJoin('district as district2', 'district.pid', '=', 'district2.id')
            ->where('district.pid', $pid)
            ->where('district.status', 1)
            ->select('district.*', 'district2.name as pid_name')
            ->orderBy('district.code')->get();
        if (empty($result)) {
            return Result::error("未查询到此地区", 0);
        } else {
            return Result::success($result);
        }
    }

    /**
     * 获取栏目
     * @param array $data
     * @return array
     */

    public function getWebsiteModelCategory(array $data): array
    {
        // return Result::success($data);
        $website_id = [
            'website_id' => $data['website_id'],
        ];
        // 初始化 $pid 数组
        // $pid = [];
        // 以下注释掉的代码是之前的逻辑，用于获取非顶级分类的 pid
        $pidQuery = WebsiteCategory::where($website_id)
            ->where('pid', '!=', 0)
            ->orderBy('sort')
            ->select('pid', 'category_id', 'alias', 'aLIas_pinyin');
        $pid = $pidQuery->pluck('pid');
        $pid = array_values(array_unique($pid->toArray()));
        // 构建查询语句
        $query = WebsiteCategory::where($website_id)
            ->where('pid', $data['pid'])
            ->offset($data['placeid'])
            ->limit($data['num'])
            ->orderBy('sort')
            ->orderBy('updated_at', 'desc');
        // 如果 $pid 数组不为空，添加 CASE WHEN 条件
        if (!empty($pid)) {
            $placeholders = implode(',', array_fill(0, count($pid), '?'));
            $query->selectRaw("website_category.*, CASE WHEN website_category.category_id IN ($placeholders) THEN 1 ELSE 0 END AS children_count", $pid);
        } else {
            // 如果 $pid 数组为空，不添加 CASE WHEN 条件，添加字段 children_count 并赋值为 0
            $query->select('website_category.*', DB::raw('0 as children_count'));
        }

        // 执行查询
        $placeid = $data['placeid'] - 1;
        $result = $query->offset($placeid)->limit($data['num'])->get();

        if (!empty($result)) {
            $pidResults = $pidQuery->get();
            if (isset($data['type']) && $data['type'] == 1) {
                $result = $result->map(function ($item) use ($pidResults) {
                    $children = $pidResults->where('pid', $item->category_id)->map(function ($child) {
                        if (!empty($child)) {
                            return $child;
                        }
                    });
                    // 重置索引，使 key 值从 0 开始
                    $item->children = $children->values();
                    return $item;
                });
            } else {
                $pidMap = $pidResults->keyBy('pid');
                $result->each(function ($record) use ($pidMap) {
                    if ($pidMap->has($record->category_id)) {
                        $pidResult = $pidMap->get($record->category_id);
                        $record->chilid_id = $pidResult->category_id;
                        $record->chilid_alias = $pidResult->alias;
                        // $record->aLIas_pinyin = $pidResult->aLIas_pinyin;
                    }
                });
            }

            return Result::success($result);
        } else {
            return Result::error("本网站暂无栏目", 0);
        }
    }


    /**
     * 获取友情链接
     * @param array $data
     * @return array
     */

    public function selectWebsiteLinks(array $data): array
    {
        $where = [
            'website_id' => $data['website_id'],
            'status' => 1,
            'type' => $data['type'],
        ];
        $num = $data['num'];
        $result = Link::where($where)->orderBy('sort')->limit($num)->get();
        if (!empty($result)) {
            return Result::success($result);
        } else {
            return Result::error("本网站暂无此类型友情链接", 0);
        }
    }

    /**
     * 网站首页数据统计， 管理员
     * @return void
     */
    public function getAdminIndex(array $data): array
    {
        var_dump("用户类型：", $data);
        switch ($data['type_id']) {
            case 10000:
                $res = [];
                //网站
                $res['website']['count'] = 0;
                $res['website']['growth_rate'] = 0;
                //资讯
                $res['article']['count'] = 0;
                $res['article']['growth_rate'] = 0;
                //导航池
                $res['category']['count'] = 0;
                $res['category']['growth_rate'] = 0;
                //商品
                $res['good']['count'] = 0;
                $res['book']['count'] = 0;
                $res['jobHunting']['count'] = 0;
                $res['jobRecruiting']['count'] = 0;
                //近一月数据
                $res['monthArticle'] = [];
                //用户类型
                $res['userType'] = [];
                $res['website']['count'] = Website::where([])->count();
                $res['article']['count'] = Article::whereIn('status', [1])->count();
                $res['category']['count'] = Category::where([])->count();
                $res['good']['count'] =  Good::whereIn('status', [2])->count();
                $res['book']['count'] = Book::whereIn('status', [2])->count();
                $res['jobHunting']['count'] = JobHunting::whereIn('status', [2])->count();
                $res['jobRecruiting']['count'] = JobRecruiting::whereIn('status', [1])->count();
                $res['complaint']['count'] = Complaint::whereIn('status', [2])->count();
                $res['notice']['count'] = Notice::whereIn('status', [2])->count();
                //已审核数量
                $res['company']['count'] = Company::whereIn('status', [1])->count();
                $res['project']['count'] = Project::whereIn('status', [1])->count();

                // $res['monthArticle'] = Db::select('SELECT  DATE(created_at) AS date,COUNT(*) AS total_count FROM  article  WHERE  created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(created_at)  ORDER BY  date ASC;');
                $res['monthArticle'] = Db::select(' SELECT  DATE(article.created_at) AS date,COUNT(*) AS count ,user.type_id FROM  article left JOIN user on article.admin_user_id = user.id  WHERE
                 article.status =1 and   article.created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(article.created_at),`user`.type_id  ORDER BY  date ASC');

                $res['monthGood'] = Db::select(' SELECT  DATE(good.created_at) AS date,COUNT(*) AS count ,user.type_id FROM  good left JOIN user on good.user_id = user.id  WHERE
                 good.status =2 and   good.created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(good.created_at),`user`.type_id  ORDER BY  date ASC');

                $res['monthBook'] = Db::select(' SELECT  DATE(book.created_at) AS date,COUNT(*) AS count ,user.type_id FROM  book left JOIN user on book.user_id = user.id  WHERE   book.status =2 and  book.created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(book.created_at),`user`.type_id  ORDER BY  date ASC');

                $res['monthJobHunting'] = Db::select(' SELECT  DATE(job_hunting.created_at) AS date,COUNT(*) AS count ,user.type_id FROM  job_hunting left JOIN user on job_hunting.user_id = user.id  WHERE   job_hunting.status =2 and  job_hunting.created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(job_hunting.created_at),`user`.type_id  ORDER BY  date ASC');

                $res['monthJobRecruiting'] = Db::select(' SELECT  DATE(job_recruiting.created_at) AS date,COUNT(*) AS count ,user.type_id FROM  job_recruiting left JOIN user on job_recruiting.user_id = user.id  WHERE  job_recruiting.status =1 and   job_recruiting.created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(job_recruiting.created_at),`user`.type_id  ORDER BY  date ASC');

                //company project  1 已审核
                $res['monthCompany'] = Db::select(' SELECT  DATE(company.created_at) AS date,COUNT(*) AS count ,user.type_id FROM  company left JOIN user on company.user_id = user.id  WHERE  company.status =1 and   company.created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(company.created_at),`user`.type_id  ORDER BY  date ASC');
                $res['monthProject'] = Db::select(' SELECT  DATE(project.created_at) AS date,COUNT(*) AS count ,user.type_id FROM  project left JOIN user on project.user_id = user.id  WHERE  project.status =1 and   project.created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(project.created_at),`user`.type_id  ORDER BY  date ASC');


                $res['userType'] = User::where([])->selectRaw("count(*) as counts,type_id")->groupBy('type_id')->get();

                //待审核数据
                $res['apply']['article'] = Article::where(['status' => 0])->count();   //
                $res['apply']['good'] = Good::where(['status' => 1])->count();
                $res['apply']['book'] = Book::where(['status' => 1])->count();
                $res['apply']['jobHunting'] = JobHunting::where(['status' => 1])->count();
                $res['apply']['jobRecruiting'] = JobRecruiting::where(['status' => 0])->count();
                $res['apply']['complaint'] = Complaint::where(['status' => 1])->count();
                $res['apply']['notice'] = Notice::where(['status' => 1])->count(); //订单状态：1：通过；2：驳回；3：撤回；4：修改；5：过期；6：待审核；7：结束',
                $res['apply']['order'] = Order::where(['status' => 6])->count();
                $res['apply']['company'] = Company::where(['status' => 1])->count();
                $res['apply']['project'] = Project::where(['status' => 1])->count();

                return Result::success($res);
            case 1:
            case 2:
            case 3:
            case 4:
                $res = [];
                if ($data['type_id'] == 4) {
                    $result = Db::select('SELECT  DATE(created_at) AS date,COUNT(*) AS total_count FROM  letter_of_complaint  WHERE  created_at >= CURDATE() - INTERVAL 30 DAY  GROUP BY  DATE(created_at)  ORDER BY  date ASC;');
                    $res = [];
                    //查询已审核文章
                    $user_id = $data['user_id'];
                    $article = Article::where('status', 1)
                        ->where('admin_user_id', $user_id)
                        ->orderBy('updated_at', 'desc')
                        ->limit(10)
                        ->get();
                    $res['letterOfComplaintList'] = $result;
                    $res['article'] = $article;
                }

                //查询已审核文章
                $user_id = $data['user_id'];
                $now = Carbon::now();
                // 系统提醒审核消息
                $sys_msg = [];
                $article = Article::where('status', 0)
                    ->where('admin_user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->limit(5)
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        $item->class = '资讯';
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });

                var_dump($article, '---1--');
                $good = Good::where('status', 1)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'name as title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = '商品';
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                $book = Book::query()
                    ->where('status', 1)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = '书刊';
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                //招聘 求职
                $jobhunting = JobHunting::query()
                    ->where('status', 1)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'name as title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = '求职';
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                $jobrecruiting = JobRecruiting::query()
                    ->where('status', 0)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = '招聘';
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });

                //通知 投诉

                $notice = Notice::query()
                    ->where('status', 1)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = $item->type == 1 ? "通知" : "公告";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });

                $complaint = Complaint::query()
                    ->where('status', 1)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = "投诉";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                //项目 公司  待审核  ：0：未审核；1：已审核；2：已拒绝

                $project = Project::query()
                    ->where('status', 0)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = "项目";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });

                $company = Company::query()
                    ->where('status', 0)
                    ->where('user_id', $user_id)
                    ->orderBy('updated_at', 'desc')
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        //去掉name的属性
                        $item->class = "公司";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });

                // var_dump($jobrecruiting, '-1--------------------11111111111111--');


                // var_dump($good, '-3--');
                // $s = $article->toArray();
                // var_dump($s, '=====31111111111111111');
                // 合并两个集合
                // 合并两个集合，并按 updated_at 倒序排序
                // $combined = $article->merge($good)->sortByDesc('updated_at');
                $combined = $article
                    ->concat($good)
                    ->concat($book)
                    ->concat($jobhunting)
                    ->concat($jobrecruiting)
                    ->concat($notice)
                    ->concat($complaint)
                    ->concat($project)
                    ->concat($company)
                    ->sortByDesc(function ($item) {
                        return Carbon::createFromFormat('Y-m-d H:i:s', $item->updated_at);
                    });
                // ->sortBy('updated_at');
                // var_dump($combined, '--4--');
                // 转换为数组输出
                $res['sys_msg'] = $combined->values()->all();
                // 互动消息
                $chat_msg = [];
                // 通知投诉
                $notice_msg = [];
                // $res['sys_msg'] = $sys_msg;
                $chat_single_msg = ChatRecords::where('user_id', $user_id)
                    ->where('is_read', 0)
                    ->where('talk_type', 1)
                    ->orderBy('updated_at', 'desc')
                    ->limit(5)
                    ->get(['id', 'content', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        $item->class = "单聊";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                $chat_group_msg = ChatRecords::where('user_id', $user_id)
                    ->where('is_read', 0)
                    ->where('talk_type', 2)
                    ->leftJoin('chat_groups', 'chat_records.receiver_id', '=', 'chat_groups.id')
                    ->orderBy('updated_at', 'desc')
                    ->limit(5)
                    ->get(['chat_records.id', 'content as content1', 'chat_records.updated_at', 'chat_groups.group_name as content'])
                    ->map(function ($item) use ($now) {
                        $item->class = "群聊";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });

                $topic_msg = ChatTopic::where('chat_topics.user_id', $user_id)
                    ->whereNotNull('chat_topics_reply.updated_at')
                    ->leftJoin('chat_topics_reply', 'chat_topics.id', '=', 'chat_topics_reply.topic_id')
                    ->select('chat_topics.id', 'chat_topics.title as content', 'chat_topics_reply.updated_at as updated_at')
                    ->orderBy('updated_at', 'desc')
                    ->limit(5)
                    ->get(['chat_topics.id', 'chat_topics.content', 'chat_topics.updated_at'])
                    ->map(function ($item) use ($now) {
                        $item->class = "话题";
                        // $item->content = $item->content;
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                // 合并单聊和群聊消息
                $chat_msg = $chat_single_msg
                    ->concat($chat_group_msg)
                    ->concat($topic_msg)
                    ->sortByDesc(function ($item) {
                        return Carbon::createFromFormat('Y-m-d H:i:s', $item->updated_at);
                    })->values()->all();

                $res['chat_msg'] = $chat_msg;
                //未读消息
                $notce_recieve_msg = Notice::where('status', 1)
                    ->whereJsonContains('re_user_ids', $user_id)
                    ->where(function ($query) use ($user_id) {
                        $query->whereNull('read_id')
                            ->orWhereRaw('NOT JSON_CONTAINS(`read_id`, ?)', [$user_id]);
                    })
                    ->orderBy('updated_at', 'desc')
                    ->limit(5)
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        $item->class = "通知";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                $complaint_recieve_msg = Complaint::where('status', 1)
                    ->whereJsonContains('re_user_ids', $user_id)
                    ->where(function ($query) use ($user_id) {
                        $query->whereNull('read_id')
                            ->orWhereRaw('NOT JSON_CONTAINS(`read_id`, ?)', [$user_id]);
                    })
                    ->orderBy('updated_at', 'desc')
                    ->limit(5)
                    ->get(['id', 'title', 'updated_at'])
                    ->map(function ($item) use ($now) {
                        $item->class = "投诉";
                        $item->formatted_updated_at = $this->timeAgo($item->updated_at, $now);
                        return $item;
                    });
                // 合并消息

                $notice_msg = $notce_recieve_msg
                    ->concat($complaint_recieve_msg)
                    ->sortByDesc(function ($item) {
                        return Carbon::createFromFormat('Y-m-d H:i:s', $item->updated_at);
                    })->values()->all();

                $res['notice_msg'] = $notice_msg;
                // $res['article'] = $article;
                $res['website']['count'] = Website::where([])->count();
                $res['article']['count'] = Article::whereIn('status', [1])->where('admin_user_id', $user_id)->count();
                $res['category']['count'] = Category::where([])->count();
                $res['good']['count'] =  Good::whereIn('status', [2])
                    ->where('user_id', $user_id)->count();
                $res['book']['count'] = Book::whereIn('status', [2])
                    ->where('user_id', $user_id)->count();
                $res['jobHunting']['count'] = JobHunting::whereIn('status', [2])
                    ->where('user_id', $user_id)->count();
                $res['jobRecruiting']['count'] = JobRecruiting::whereIn('status', [1])
                    ->where('user_id', $user_id)->count();
                $res['complaint']['count'] = Complaint::whereIn('status', [2])
                    ->where('user_id', $user_id)->count();
                $res['notice']['count'] = Notice::whereIn('status', [2])
                    ->where('user_id', $user_id)->count();
                //company project  0 待审核  1  已审核
                $res['company']['count'] = Company::whereIn('status', [1])
                    ->where('user_id', $user_id)->count();
                $res['project']['count'] = Project::whereIn('status', [1])
                    ->where('user_id', $user_id)->count();

                //待处理的complaint
                $res['complaint_deal']['count'] = Complaint::where(['status' => 2])
                    ->where('deal', 1)
                    // ->where('user_id', $user_id)
                    ->whereJsonContains('re_user_ids', $user_id)
                    ->count();
                //待审核数据
                $res['apply']['article'] = Article::where(['status' => 0])->where('admin_user_id', $user_id)->count();   //
                $res['apply']['good'] = Good::where(['status' => 1])->where('user_id', $user_id)->count();
                $res['apply']['book'] = Book::where(['status' => 1])->where('user_id', $user_id)->count();
                $res['apply']['jobHunting'] = JobHunting::where(['status' => 1])->where('user_id', $user_id)->count();
                $res['apply']['jobRecruiting'] = JobRecruiting::where(['status' => 0])->where('user_id', $user_id)->count();
                $res['apply']['complaint'] = Complaint::where(['status' => 1])->where('user_id', $user_id)->count();
                $res['apply']['notice'] = Notice::where(['status' => 1])->where('user_id', $user_id)->count();
                //project company
                $res['apply']['project'] = Project::whereIn('status', [0])
                    ->where('user_id', $user_id)->count();
                $res['apply']['company'] = Company::whereIn('status', [0])
                    ->where('user_id', $user_id)->count();
                return Result::success($res);
        }
        return [];
    }

    private function timeAgo(string $date, Carbon $now): string
    {
        $diff = (new Carbon($date))->diffInMinutes($now);

        if ($diff < 1) {
            return '刚刚';
        } elseif ($diff < 60) {
            return "{$diff} 分钟前";
        } elseif ($diff < 1440) {
            return (int)($diff / 60) . " 小时前";
        } elseif ($diff < 2880) { // 两天内
            return "1 天前";
        } elseif ($diff < 7 * 1440) {
            return (int)($diff / 1440) . " 天前";
        } else {
            return (new Carbon($date))->format('Y-m-d');
        }
    }

    /**
     * 获取分类下的模板
     * @param array $data
     * @return array
     */
    public function getTemplate(array $data): array
    {
        $page = $data['page'];
        $pageSize = $data['pageSize'];
        $where = [];
        if (isset($data['template_class_id']) && $data['template_class_id']) {
            array_push($where, ['template_class_id', '=', $data['template_class_id']]);
        }
        $result = Template::where($where)
            ->limit($pageSize)->offset(($page - 1) * $pageSize)->get();
        $count = Template::where($where)->count();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        $data = [
            'rows' => $result->toArray(),
            'count' => $count,
        ];
        return Result::success($data);
    }

    /**
     * 创建模板
     * @param
     * @return void
     */
    public function addTemplate(array $data): array
    {
        $insertData = [
            'template_name' => $data['template_name'],
            'template_img' => json_encode($data['template_img']),
            'template_class_id' => $data['template_class_id'],
        ];
        $result = Template::insertGetId($insertData);
        if (empty($result)) {
            return Result::error("创建模板失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }

    /**
     * 更新模板
     * @param array $data
     * @return array
     */
    public function upTemplate(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $insertData = [
            'template_name' => $data['template_name'],
            'template_img' => json_encode($data['template_img']),
            'template_class_id' => $data['template_class_id'],
        ];
        $result = Template::where($where)->update($insertData);
        if (empty($result)) {
            return Result::error("更新模板失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * 删除模板
     * @param array $data
     * @return array
     */
    public function delTemplate(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $result = Template::where($where)->delete();
        if (empty($result)) {
            return Result::error("删除模板失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * 搜索网站
     * @param array $data
     * @return array
     */
    public function websiteList(array $data): array
    {
        $where = [];
        if (isset($data['keyword']) && !empty($data['keyword'])) {
            array_push($where, ['website.website_name', 'like', '%' . $data['keyword'] . '%']);
        }
        $result = Website::where($where)->get();

        if (isset($data['website_column_id'])) {
            $target = $data['website_column_id'];
            $result = $result->filter(function ($item) use ($target) {
                $arr = json_decode($item->website_column_arr_id, true);
                return !in_array($target, $arr);
            });
        }

        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("没有网站", 0);
        }
    }

    public function addWebsiteCategory(array $data): array
    {
        $website_id = $data['website_id'];
        $category_arr_id = $data['category_arr_id'];
        $categoryList = Category::whereIn('id', $category_arr_id)->get();
        $categoryListIds = [];
        if ($categoryList) {
            foreach ($categoryList->toArray() as $val) {
                array_push($categoryListIds, $val['id']);
            }
        }
        $arr = [];
        if ($categoryListIds) {
            foreach ($categoryListIds as $v) {
                $ids = $this->getUnderlingUIds(intval($v));
                $ids_arr = explode(",", $ids);
                array_push($arr, $ids_arr);
            }
        }
        $mergedArray = [];
        foreach ($arr as $subarray) {
            $mergedArray = array_merge($mergedArray, $subarray);
        }
        var_dump("所有:", $arr, $mergedArray);
        //查询出所有的分类进行分割插入 组装数据
        $categoryListData = Category::whereIn('id', $mergedArray)->get();
        $categoryListData = $categoryListData->toArray();
        $insertData = [];
        if ($categoryListData) {
            foreach ($categoryListData as $key => $value) {
                $insertData[$key]['website_id'] = $website_id;
                $insertData[$key]['name'] = $value['name'];
                $insertData[$key]['sort'] = $value['sort'];
                $insertData[$key]['pid'] = $value['pid'];
                $insertData[$key]['pid_arr'] = $value['pid_arr'];
                $insertData[$key]['seo_title'] = $value['seo_title'];
                $insertData[$key]['seo_keywords'] = $value['seo_keywords'];
                $insertData[$key]['seo_description'] = $value['seo_description'];
                $insertData[$key]['alias'] = $value['name'];
                $insertData[$key]['category_id'] = $value['id'];
            }
        }
        $result = WebsiteCategory::insert($insertData);
        var_dump("插入数据状态：", $result);
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("创建失败", 0);
        }
    }

    /**
     * 删除网站导航
     * @param array $data
     * @return array
     */
    public function delWebsiteCategory(array $data): array
    {
        $website_id = $data['website_id'] ?? 0;
        $category_id = $data['category_id'] ?? 0;
        $ids = $this->getUnderlingUIds(intval($category_id));
        $ids_arr = explode(",", $ids);
        $result = WebsiteCategory::where(['website_id' => $website_id])->whereIn("category_id", $ids_arr)->delete();
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("删除失败", 0);
        }
    }

    /**
     * 获取网站导航
     * @param array $data
     * @return array
     */
    public function getAdminWebsiteCategory(array $data): array
    {
        $where = [
            'website_id' => $data['website_id'],
        ];
        $result = WebsiteCategory::where($where)->orderBy('sort', 'asc')->get();
        $list = [];
        if ($result) {
            foreach ($result->toArray() as $val) {
                array_push($list, json_decode($val['category_arr_id']));
            }
        }
        if ($result) {
            return Result::success($list);
        } else {
            return Result::error("查询失败", 0);
        }
    }

    /**
     * 更新网站导航
     * @param array $data
     * @return array
     */
    public function upWebsiteCategory(array $data): array
    {
        $pinyin = new Pinyin();
        Db::beginTransaction();
        try {
            if (!empty($data['category_arr_id'])) {
                $websiteId = $data['website_id'];
                // 1. 获取旧的 category_id 列表
                $oldCategoryListIds = WebsiteCategory::where('website_id', $websiteId)->pluck('category_id')->toArray();
                // 2. 获取新的 category_id 列表（去重）
                $newCategoryListIds = [];
                foreach ($data['category_arr_id'] as $arr) {
                    $lastId = end($arr);
                    $newCategoryListIds[] = $lastId;
                }
                $newCategoryListIds = array_unique($newCategoryListIds);
                // 3. 需要删除的 category_id
                $toDelete = array_diff($oldCategoryListIds, $newCategoryListIds);
                if (!empty($toDelete)) {
                    WebsiteCategory::where('website_id', $websiteId)
                        ->whereIn('category_id', $toDelete)
                        ->delete();
                }
                // 4. 批量查出所有需要的 category 信息
                $categories = Category::whereIn('id', $newCategoryListIds)->get()->keyBy('id');
                // 5. 组装 upsertData，确保 category_id 不重复
                $upsertData = [];
                $handledCategoryIds = [];
                foreach ($data['category_arr_id'] as $arr) {
                    $categoryId = end($arr);
                    if (!isset($categories[$categoryId]) || in_array($categoryId, $handledCategoryIds)) continue;
                    $info = $categories[$categoryId];
                    $aLIas_pinyin = $pinyin->permalink($info->name, '');
                    $upsertData[] = [
                        'website_id' => $websiteId,
                        'category_id' => $categoryId,
                        'name' => $info->name ?? '',
                        'alias' => $info->name ?? '',
                        'aLIas_pinyin' => $aLIas_pinyin ?? '',
                        'sort' => $info->sort ?? 0,
                        'pid' => $info->pid ?? 0,
                        'pid_arr' => $info->pid_arr ?? json_encode([]),
                        'seo_title' => $info->seo_title ?? "",
                        'seo_keywords' => $info->seo_keywords ?? "",
                        'seo_description' => $info->seo_description ?? "",
                        'is_url' => $info->is_url ?? 0,
                        'web_url' => $info->web_url ?? '',
                        'type' => $info->type ?? 1,
                        'category_arr_id' => json_encode($arr)
                    ];
                    $handledCategoryIds[] = $categoryId;
                }
                // 6. upsert
                if (!empty($upsertData)) {
                    WebsiteCategory::upsert(
                        $upsertData,
                        ['website_id', 'category_id'],
                        [
                            'aLIas_pinyin',
                            'pid',
                            'pid_arr',
                            'is_url',
                            'web_url',
                            'category_arr_id'
                        ]
                    );
                }
            }
            //处理所有path
            var_dump($data, '--------111----');
            $website_id = $data['website_id'];
            //获取所有数据
            $result = WebsiteCategory::where(['website_id' => $website_id, 'path' => NULL])->get()->toArray();
            if (empty($result)) {
                return Result::error("没有数据", 0);
            }
            //处理path
            foreach ($result as $key => $value) {
                $array_category_arr_id = json_decode($value['category_arr_id'], true);
                $result[$key]['path'] = WebsiteCategory::where('website_id', $website_id)
                    ->orderByRaw('FIELD(category_id, ' . implode(',', $array_category_arr_id) . ')')
                    ->whereIn('category_id', $array_category_arr_id)
                    ->pluck('aLIas_pinyin')
                    ->implode('/');
            }
            //批量更新数据path
            $updateData = [];
            foreach ($result as $item) {
                $updateData[] = [
                    'id' => $item['id'],
                    'path' => $item['path']
                ];
            }
            //批量更新
            DB::beginTransaction();
            try {
                foreach ($result as $item) {
                    WebsiteCategory::where('id', $item['id'])->update(['path' => $item['path']]);
                }
                DB::commit();
            } catch (\Exception $e) {
                DB::rollBack();
                throw $e; // 或者返回错误信息
            }

            Db::commit();
            return Result::success();
        } catch (\Throwable $ex) {
            Db::rollBack();
            return Result::error("修改失败" . $ex->getMessage(), 0);
        }
    }

    /**
     * 获取网站列表
     * @param array $data
     * @return array
     */
    public function getWebsiteCategoryList(array $data): array
    {
        $where = [];
        if (isset($data['keyword']) && !empty($data['keyword'])) {
            array_push($where, ['website.website_name', 'like', '%' . $data['keyword'] . '%']);
        }
        if (isset($data['website_column_id']) && !empty($data['website_column_id'])) {
            array_push($where, ['website.website_column_id', '=', $data['website_column_id']]);
        }
        $result = Website::where($where)
            ->with(["websiteCategory" => function ($query) {
                $query->where(['pid' => 0])->select('website_id', 'name', 'alias', 'category_id');
            }])
            ->limit($data['pageSize'])->orderBy("updated_at", "desc")->offset(($data['page'] - 1) * $data['pageSize'])
            ->get();

        $count = Website::where($where)->count();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        $data = [
            'rows' => $result->toArray(),
            'count' => $count,
        ];
        if ($result) {
            return Result::success($data);
        } else {
            return Result::error("查询失败", 0);
        }
    }

    /**
     * 删除网站下的所有导航
     * @param array $data
     * @return array
     */
    public function delWebsiteAllCategory(array $data): array
    {
        $website_id = $data['website_id'];
        $result = WebsiteCategory::where(['website_id' => $website_id])->delete();

        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("删除失败", 0);
        }
    }

    /**
     * 获取网站下的某一个导航
     * @param array $data
     * @return array
     */
    public function getWebsiteCategoryOnes(array $data): array
    {
        $website_id = $data['website_id'];
        $category_id = $data['category_id'];
        $result = WebsiteCategory::where(['website_category.website_id' => $website_id, 'website_category.category_id' => $category_id])
            ->first();
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("查询失败", 0);
        }
    }

    /**
     * 更新网闸下的某一个导航
     * @param array $data
     * @return array
     */
    public function upWebsiteCategoryones(array $data): array
    {
        //处理所有数据
        //获取所有数据
        if (isset($data['all']) && $data['all'] == 'all') {
            $result = WebsiteCategory::get();
            $result = $result->toArray();
            var_dump($result, '------------');
            $pinyin = new Pinyin();
            $letters = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
            for ($i = 0; $i < count($result); $i++) {
                // $randss = substr(str_shuffle($letters), 0, 4);
                $result[$i]['aLIas_pinyin'] = $pinyin->permalink($result[$i]['alias'], '');
                WebsiteCategory::where(['id' => $result[$i]['id']])->update(['aLIas_pinyin' => $result[$i]['aLIas_pinyin']]);
            }
            var_dump($result, '--------222----');
            if ($result) {
                return Result::success($result);
            } else {
                return Result::error("更新失败", 0);
            }
        }
        //处理所有path
        if (isset($data['pathone']) && $data['pathone'] == 'pathone') {
            var_dump($data, '--------111----');
            $website_id = $data['website_id'];
            //获取所有数据
            $result = WebsiteCategory::where(['website_id' => $website_id, 'path' => NULL])->get()->toArray();
            if (empty($result)) {
                return Result::error("没有数据", 0);
            }
            //处理path
            foreach ($result as $key => $value) {
                $array_category_arr_id = json_decode($value['category_arr_id'], true);
                $result[$key]['path'] = WebsiteCategory::where('website_id', $website_id)
                    ->orderByRaw('FIELD(category_id, ' . implode(',', $array_category_arr_id) . ')')
                    ->whereIn('category_id', $array_category_arr_id)
                    ->pluck('aLIas_pinyin')
                    ->implode('/');
            }
            //批量更新数据path
            $updateData = [];
            foreach ($result as $item) {
                $updateData[] = [
                    'id' => $item['id'],
                    'path' => $item['path']
                ];
            }
            //批量更新
            DB::beginTransaction();
            try {
                foreach ($result as $item) {
                    WebsiteCategory::where('id', $item['id'])->update(['path' => $item['path']]);
                }
                DB::commit();
            } catch (\Exception $e) {
                DB::rollBack();
                throw $e; // 或者返回错误信息
            }
            return Result::success($result);
        }

        if (isset($data['pathall']) && $data['pathall'] == 'pathall') {
            //获取所有数据
            $result = WebsiteCategory::where(['path' => NULL])->get()->toArray();
            if (empty($result)) {
                return Result::error("没有数据", 0);
            }
            //处理path
            foreach ($result as $key => $value) {
                if (empty($value['category_arr_id'])) continue;
                if ($key >= 4) {  // 改为 >= 4 如果你想处理最多4个元素
                    // break;
                }
                $array_category_arr_id = json_decode($value['category_arr_id'], true);
                $result[$key]['path'] = WebsiteCategory::where('website_id', $value['website_id'])
                    ->orderByRaw('FIELD(category_id, ' . implode(',', $array_category_arr_id) . ')')
                    ->whereIn('category_id', $array_category_arr_id)
                    ->pluck('aLIas_pinyin')
                    ->implode('/');
            }
            //批量更新数据path
            $updateData = [];
            foreach ($result as $item) {
                $updateData[] = [
                    'id' => $item['id'],
                    'category_arr_id' => $item['category_arr_id'],
                    'path' => $item['path']
                ];
            }
            // var_dump($updateData);
            // return  Result::success($updateData);
            //批量更新
            DB::beginTransaction();
            try {
                foreach ($result as $item) {
                    WebsiteCategory::where('id', $item['id'])->update(['path' => $item['path']]);
                }
                DB::commit();
            } catch (\Exception $e) {
                DB::rollBack();
                throw $e; // 或者返回错误信息
            }
            return Result::success($result);
        }


        $where = [
            'website_id' => $data['website_id'],
            'category_id' => $data['category_id'],
        ];
        $alias = $data['alias'];
        $pinyin = new Pinyin();
        $aLIas_pinyin = $pinyin->permalink($alias, '');
        //从WebsiteCategory取出alis ，并转成拼音存放到aLIas_pinyin
        $result = WebsiteCategory::where($where)->first();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        $result = $result->toArray();
        //+四位随机字母
        $letters = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
        // 打乱字符串顺序并截取前四位
        // $randss = substr(str_shuffle($letters), 0, 4);

        $data['aLIas_pinyin'] = $aLIas_pinyin;
        //数据库先更新一下，再改path
        WebsiteCategory::where($where)->update(['aLIas_pinyin' => $data['aLIas_pinyin']]);
        //处理path
        $category_arr_id = json_decode($result['category_arr_id'], true);
        //取出来设置path
        $path = WebsiteCategory::where('website_id', $data['website_id'])
            ->orderByRaw('FIELD(category_id, ' . implode(',', $category_arr_id) . ')')
            ->whereIn('category_id', $category_arr_id)
            ->pluck('aLIas_pinyin')
            ->implode('/');
        $data['path'] = $path;
        //处理包含此id的所有path
        // 取出category_arr_id包含此id的所有数据
        $all_other = WebsiteCategory::where('website_id', $data['website_id'])
            ->whereJsonContains('category_arr_id', $data['category_id'])
            ->get();
        var_dump($all_other, '------------');

        // 遍历所有数据，更新path
        $newAliasPinyin = $aLIas_pinyin ?? ''; // 添加空值判断
        $oldAliasPinyin = $result['alias_pinyin'] ?? ''; // 修正键名大小写

        // 收集需要更新的ID和路径
        $updateData = [];
        foreach ($all_other as $item) {
            $newPath = str_replace($oldAliasPinyin, $newAliasPinyin, $item->path);
            if ($newPath !== $item->path) { // 仅在路径变化时更新
                $updateData[] = [
                    'id' => $item->id,
                    'path' => $newPath
                ];
            }
        }

        // 批量更新提高性能
        if (!empty($updateData)) {
            // 假设模型对应的数据表为 'table_name'，请替换为实际表名
            Db::table('website_category')->updateOrInsert(
                ['id' => DB::raw('VALUES(id)')],
                $updateData
            );
        }

        $result = WebsiteCategory::where($where)->update($data);
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("更新失败", 0);
        }
    }

    /**
     * 获取网站下的所有导航（包含子导航）
     * @param array $data
     * @return array
     */
    public function getWebsiteAllCategory(array $data): array
    {
        $where = [];
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            array_push($where, ['website_category.website_id', '=', $data['website_id']]);
        }
        //        if (isset($data['name']) && !empty($data['name'])) {
        //            array_push($where, ['website_category.name', 'like', '%' . $data['name'] . '%']);
        //        }
        //        if (isset($data['alias']) && !empty($data['alias'])) {
        //            array_push($where, ['website_category.alias', 'like', '%' . $data['alias'] . '%']);
        //        }
        //        if (isset($data['department_id']) && !empty($data['department_id'])) {
        //            array_push($where, ['category.department_id', '=', $data['department_id']]);
        //        }
        //        if (isset($data['city_id']) && !empty($data['city_id'])) {
        //            array_push($where, ['category.city_id', '=', $data['city_id']]);
        //        }
        $result = WebsiteCategory::where($where)
            ->leftJoin("category", 'website_category.category_id', 'category.id')
            ->select("website_category.*", "category.name as name")
            //            ->leftJoin("category", 'website_category.category_id', 'category.id')
            //            ->leftJoin("department", 'category.department_id', 'department.id')
            //            ->leftJoin("district", 'category.city_id', 'district.id')
            //            ->select("website_category.*", "department.name as department_name", "district.name as city_name")
            //            ->limit($data['pageSize'])->offset(($data['page'] - 1) * $data['pageSize'])
            ->orderBy("sort", "asc")
            ->orderBy("updated_at", "desc")
            ->get();

        //        $count = WebsiteCategory::where($where)
        //            ->leftJoin("category", 'website_category.category_id', 'category.id')
        //            ->leftJoin("department", 'category.department_id', 'department.id')
        //            ->leftJoin("district", 'category.city_id', 'district.id')
        //            ->count();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        //        $data = [
        //            'rows' => $result->toArray(),
        //            'count' => $count,
        //        ];
        if ($result) {
            return Result::success($result->toArray());
        } else {
            return Result::error("查询失败", 0);
        }
    }

    /**
     * 递归查询数据
     * @param $id
     * @param $ids
     * @return string
     */
    public function getUnderlingUIds($id, $ids = '')
    {
        $back = Category::where(['pid' => $id])->get();
        $back = $back->toArray();
        if (!empty($back) && is_array($back)) {
            foreach ($back as $v) {
                //防止当前人的ID重复去查询，形成恶性循环
                if ($v['id'] == $id) {
                    continue;
                }
                $back2 = Category::where(['pid' => $id])->count('id');
                if ($back2 > 0) {
                    $ids = $this->getUnderlingUIds($v['id'], $ids);
                } else {
                    $ids .= ',' . $v['id'];
                }
            }
        }
        $ids = $id . ',' . $ids . ',';
        $ids = str_replace(',,', ",", $ids);
        $ids = trim($ids, ',');
        return $ids;
    }

    /**
     * 检测网站名称是否重复
     * @param array $data
     * @return array
     */
    public function checkWebsiteName(array $data): array
    {
        if (isset($data['id'])) {
            $data[] = ['id', "!=", $data['id']];
            unset($data['id']);
        }
        $websiteInfo = Website::query()->where($data)->first();
        if (empty($websiteInfo)) {
            return Result::error("找不到网站", 0);
        }
        return Result::success($websiteInfo->toArray());
    }

    /**
     * 检测网站url是否重复
     * @param array $data
     * @return array
     */
    public function checkWebsiteUrl(array $data): array
    {
        $whereData = [];
        if (isset($data['id'])) {
            $whereData = [['id', "!=", $data['id']]];
            unset($data['id']);
        }
        $websiteInfo = Website::query()->where($whereData)->whereJsonContains('website_url', $data['website_url'])->first();
        if (empty($websiteInfo)) {
            return Result::error("找不到URL", 0);
        }
        return Result::success($websiteInfo->toArray());
    }

    /**
     * 获取网站底部基础信息
     * @param array $data
     * @return array
     */
    public function getWebsiteFootInfo(array $data): array
    {

        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website_head = Website::where('id', $data['website_id'])
                ->where('status', 1)
                ->select('id', 'website_name', 'logo', 'title', 'keywords', 'description', 'suffix', 'website_url')
                ->first();
            if (empty($website_head)) {
                return Result::error("找不到网站", 0);
            }
        } else {
            return Result::error("参数错误", 0);
        }
        $website_head = Website::where('id', $data['website_id'])
            ->select('id', 'website_name', 'logo', 'title', 'keywords', 'description', 'suffix', 'website_url')->first();
        $website_foot = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($website_foot)) {
            return Result::error("暂无底部基础信息", 0);
        }
        $website_head['website_url'] = $website_head['website_url'] ? json_decode($website_head['website_url']) : [];
        $result = [
            'website_foot' => $website_foot,
            'website_head' => $website_head,
        ];
        return Result::success($result);
    }
    /**
     * 获取网站底部导航
     * @param array $data
     * @return array
     */
    public function getWebsiteFooterCategory(array $data): array
    {
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
            if (empty($website)) {
                return Result::error("找不到网站", 0);
            }
        } else {
            return Result::error("参数错误", 0);
        }
        $result = FooterCategory::where('website_id', $data['website_id'])->get();
        if (empty($result)) {
            return Result::error("暂无底部导航", 0);
        }
        return Result::success($result->toArray());
    }
    /**
     * 获取网站底部导航列表
     * @param array $data
     * @return array
     */
    public function getWebsiteFooterCategoryList(array $data): array
    {
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
            if (empty($website)) {
                return Result::error("找不到网站", 0);
            }
        } else {
            return Result::error("参数错误", 0);
        }
        $footercategory = FooterCategory::where('website_id', $data['website_id'])->where('id', $data['fcat_id'])->first();
        // '底部导航类型   0：内容型；1：列表型；',
        if (!isset($footercategory['type']) || $footercategory['type'] == 0) {
            return Result::error("底部导航id错误", 0);
        } else {
            $query = FooterContent::where('fcat_id', $data['fcat_id']);
            if ($query->count() == 0) {
                return Result::error("暂无底部导航列表", 0);
            } elseif ($query->count() == 1) {
                $result = $query->first();
            } else {
                $result = $query->get();
            }
        }
        return Result::success($result);
    }
    /**
     * 获取网站底部导航
     * @param array $data
     * @return array
     */
    public function getWebsiteFooterCategoryInfo(array $data): array
    {
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
            if (empty($website)) {
                return Result::error("找不到网站", 0);
            }
        } else {
            return Result::error("参数错误", 0);
        }
        if (isset($data['type']) && $data['type'] == 0) {
            $fcatid = FooterCategory::where('website_id', $data['website_id'])->where('id', $data['fcat_id'])->first();
            if (empty($fcatid)) {
                return Result::error("底部导航id错误", 0);
            }
            $result = FooterContent::where('fcat_id', $data['fcat_id'])->first();
        } else {
            $result = FooterContent::where('id', $data['fcat_id'])->first();
        }
        if (empty($result)) {
            return Result::error("暂无底部导航内容", 0);
        }
        return Result::success($result);
    }
    /*
     * 搜索网站二级导航
     * @param array $data
     * @return array
     * */
    public function selectWebsiteCategory(array $data): array
    {
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
            if (empty($website)) {
                return Result::error("暂无该网站", 0);
            }
            $category = WebsiteCategory::where('website_id', $data['website_id'])->pluck('category_id')->all();
            // return Result::success($category);
            if (empty($category)) {
                return Result::error("暂无此导航", 0);
            }
            $query = Category::whereIn('id', $category);
            if (isset($data['cityid']) && !empty($data['cityid'])) {
                $cityid = District::where('id', $data['cityid'])->first();
                if (empty($cityid)) {
                    return Result::error("暂无此城市", 0);
                } else {
                    $city_category = $query->whereRaw('JSON_CONTAINS(city_arr_id,?)', [$data['cityid']])->pluck('id');
                    // $where[] = ['JSON_CONTAINS(city_arr_id, ?)', $data['cityid']];
                    if (empty($city_category)) {
                        return Result::error("暂无此城市下的导航", 0);
                    }
                    $result['catid'] = $city_category;
                    $city = 1;
                    // var_dump("城市====================",$result);
                }
            }
            if (isset($data['department_id']) && !empty($data['department_id'])) {
                $departmentid = Department::where('id', $data['department_id'])->first();
                if (empty($departmentid)) {
                    return Result::error("暂无此部门", 0);
                } else {
                    $depart_category = $query->whereRaw('JSON_CONTAINS(department_arr_id,?)', [$data['department_id']])->pluck('id');
                    if (empty($depart_category)) {
                        return Result::error("暂无此部门下的导航", 0);
                    }
                    $result['catid'] = $depart_category;
                    // var_dump("职能部门*******************",$result);
                    $department = 1;
                }
            }
            if (!empty($city) && !empty($department)) {
                // var_dump("城市和职能部门----------------------",$result);
                $sel_category = $query->whereRaw('JSON_CONTAINS(city_arr_id,?)', [$data['cityid']])->whereRaw('JSON_CONTAINS(department_arr_id,?)', [$data['department_id']])->pluck('id');
                if (empty($sel_category)) {
                    return Result::error("暂无此城市和职能部门下的导航", 0);
                }
                $result['catid'] = $sel_category;
            }
            if (empty($result)) {
                return Result::error("暂无导航", 0);
            }

            // department_id
        } else {
            return Result::error("参数错误", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取网站栏目seo
     * @param array $data
     * @return array
     */
    public function getWebsiteCategoryHead(array $data): array
    {
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
            if (empty($website)) {
                return Result::error("找不到网站", 0);
            }
        } else {
            return Result::error("参数错误", 0);
        }
        if (isset($data['catid']) && !empty($data['catid'])) {
            $result = WebsiteCategory::where('website_id', $data['website_id'])->where('category_id', $data['catid'])->first();
        }
        if (empty($result)) {
            return Result::error("暂无导航", 0);
        }
        $result['website_name'] = $website['website_name'] ?? '';
        $result['suffix'] = $website['suffix'] ?? '';
        return Result::success($result);
    }
    /*
     * 获取某个栏目
     * @param array $data
     * @return array
     * */
    public function getOneWebsiteCategory(array $data): array
    {
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
            if (empty($website)) {

                return Result::error("暂无该网站", 0);
            }
            $category = WebsiteCategory::where('website_id', $data['website_id'])->where('category_id', $data['category_id'])->first();
            if (empty($category)) {
                return Result::error("暂无此导航", 0);
            }
            $category['children_count'] = WebsiteCategory::where('website_id', $data['website_id'])->where('pid', $data['category_id'])->count();
            $parent = WebsiteCategory::where('website_id', $data['website_id'])->where('category_id', $category['pid'])->select('category_id as parent_id', 'alias as parent_name', 'aLIas_pinyin')->first();
            $category['parent_id'] = $parent['parent_id'] ?? '';
            $category['parent_pinyin'] = $parent['aLIas_pinyin'] ?? '';
            $category['parent_name'] = $parent['parent_name'] ?? '';
            return Result::success($category);
        } else {
            return Result::error("参数错误", 0);
        }
    }

    // 自助建站--fr-------------------

    /**
     * 获取并搜索 网站模板信息
     * @param array $data
     * @return array
     */
    public function getWebsiteintel(array $data): array
    {
        //查询所有网站模板信息
        $query = Website::leftJoin("website_template_info", "website_template_info.website_id", "website.id")
            ->leftJoin("template", "template.template_id", "website_template_info.template_id")
            ->leftJoin("template_class", "template_class.class_id", "template.template_class_id")
            ->leftJoin('website_column', 'website_column.id', 'website.website_column_id')
            ->leftJoin('website_column as parent_column', function ($join) {
                $join->on('website_column.pid', '=', 'parent_column.id')
                    ->where('website_column.pid', 2);
            })
            ->whereRaw('JSON_CONTAINS(website_column_arr_id,?)', [2])
            ->select(
                "website_template_info.id",
                "template_class.name",
                "website.id as website_id",
                "website.website_name",
                "website.website_url",
                "website_template_info.action_id",
                "website_template_info.created_at",
                "website_template_info.updated_at",
                "website_template_info.page_type",
                'website_column.column_name',
                'parent_column.column_name as parent_column_name',
                DB::raw("COALESCE(website_template_info.status, 0) as template_status"),
                "template.template_name"
            );
        //若存在条件；则在$query的基础上进行筛选
        if (isset($data['website_name']) && !empty($data['website_name'])) {
            $query->where('website.website_name', 'like', '%' . $data['website_name'] . '%');
        }
        if (isset($data['status']) && !empty($data['status'])) {
            $query->where('website_template_info.status', $data['status']);
        }
        $count = $query->count();
        $query->limit($data['pageSize'])
            ->offset(($data['page'] - 1) * $data['pageSize'])
            ->orderBy("website_template_info.updated_at", "desc");
        $rep = $query->get();
        if ($rep->count() == 0) {
            return Result::error("没有查找到相关数据", 0);
        } else {
            $rep->each(function ($item) {
                if (!empty($item->page_type)) {
                    $pageTypeArray = json_decode($item->page_type, true);
                    if (is_array($pageTypeArray)) {
                        $item->page_type = $pageTypeArray;
                    }
                }
            });

            $result = [
                "rows" => $rep->toArray(),
                "count" => $count,
            ];
            return Result::success($result);
        }
        // return Result::success($result);
    }

    /**
     * 自助建站-验证搭建网站
     * @param array $data
     * @return array
     */
    public function checkWebsiteBuild(array $data): array
    {
        $website = Website::where('website.id', $data['website_id'])->first();
        if (empty($website)) {
            return Result::error("请输入正确的网站id！", 0);
        }
        if (empty($website['website_column_id'])) {
            return Result::error("请先关联导航池！", 0);
        }
        // 获取此网站的底部导航  类型   type：  0：内容型底部导航（只有一条详情内容）；1：列表型底部导航（可以有多条详情内容）
        $foot_type = FooterCategory::where('website_id', $data['website_id'])->pluck('type')->toArray();
        if (empty($foot_type)) {
            return Result::error("请先关联单页！", 0);
        }
        // if (!in_array(1, $foot_type) ) {
        //     $missingTypes[] = "列表型底部导航";
        // }
        if (!in_array(0, $foot_type)) {
            $missingTypes[] = "单页（详情）";
        }
        if (!empty($missingTypes)) {
            $errorMessage = "请先添加" . $missingTypes . "！";
            return Result::error($errorMessage, 0);
        }
        $result['foot_type'] = $foot_type;
        //  友情链接类型'1:图片 2：文字 3：底部';
        $types = Link::where('website_id', $data['website_id'])->pluck('type')->toArray();
        $missingTypes = [];
        if (!in_array(1, $types)) {
            $missingTypes[] = "文字链接";
        }
        if (!in_array(2, $types)) {
            $missingTypes[] = "图片链接";
        }
        if (!in_array(3, $types)) {
            $missingTypes[] = "底部链接";
        }
        if (!empty($missingTypes)) {
            $errorMessage = "请先添加 " . implode(" 和 ", $missingTypes) . "！";
            return Result::error($errorMessage, 0);
        }
        return Result::success($result);
    }
    /**
     * 自助建站-验证编辑网站
     * @return array
     * 
     */
    public function checkWebsiteEdit(array $data): array
    {

        $result = WebsiteTemplateInfo::where('website_template_info.website_id', $data['website_id'])->first();
        if (empty($result)) {
            return Result::error("请输入正确的网站id！", 0);
        }
        // 0:未构建 1:未应用 2：已应用
        if($result['status'] == 2){
            return Result::error("此网站的模板正在应用中，暂不可编辑！", 0);
        }

        // 订单状态：1：通过；2：驳回；3：撤回；4：修改；5：过期；6：待审核；7：结束
        $order = Order::where('website_id', $data['website_id'])->where('status', 1)->first();
        if (!empty($order)) {
            return Result::error("此网站的广告位正在使用中,暂不可编辑！", 0);
        }
        $check = $this->checkWebsiteBuild($data);
        if ($check['code'] != 200) {
            return Result::error($check['message'], 0);
        }
        // return Result::success($check);
        if ($result['page_type']) {
            $result['page_type'] = json_decode($result['page_type'], true);
            return Result::success('网站编辑验证通过！');
        } else {
            return Result::error("请先选择网站页面类型！", 0);
        }
    }
    /**
     * 修改网站基础信息
     *
     * @return array
     */
    public function upWebsiteTemplateintel(array $data): array
    {
        $web = Website::where('website.id', $data['website_id'])->first();
        if (empty($web)) {
            return Result::error("请输入正确的网站id！", 0);
        }
        $where = ['website_id' => $data['website_id']];
        $result = WebsiteTemplateInfo::where($where)->first();
        if (empty($result)) {
            return Result::error("请先添加网站基础信息！", 0);
        } else {
            unset($data['website_id']);
            // 删除重复元素
            $data['page_type'] = array_unique($data['page_type']);
            // 重新索引数组
            $data['page_type'] = array_values($data['page_type']);
            //  数组中同时包含值为 1（首页） 和值为 7 （底部导航详情页）的元素
            if (in_array(1, $data['page_type']) && in_array(7, $data['page_type'])) {
                // 将数组转换为 JSON 字符串
                $data['page_type'] = json_encode($data['page_type']) ?? '';
                try {
                    $result = WebsiteTemplateInfo::where($where)->update($data);
                } catch (\Exception $e) {
                    if ($e->getCode() == 22001) {
                        $errorMessage = $e->getMessage();
                        return Result::error("请检查表单，某个字段超出了长度限制！");
                    } else {
                        // 处理其他类型的数据库错误
                        return Result::error("修改操作失败: " . $e->getMessage());
                    }
                    return Result::error("修改失败！", 0);
                }
            } else {
                return Result::error("请先选择首页和单页（详情）！", 0);
            }
        }
        if (empty($result)) {
            return Result::error("修改失败！", 0);
        } else {
            return Result::success($result);
        }
    }
    /**
     * 获取所有网站风格信息
     *
     * @return array
     */
    public function getAllTemplateClass(array $data): array
    {
        $result = TemplateClass::all();
        if (empty($result)) {
            return Result::error("没有查找到相关数据！", 0);
        } else {
            return Result::success($result);
        }
    }

    /**
     * 搜索并获取网站模板信息
     * @param array $data
     * @return array
     */
    public function getWebsiteTemplateList(array $data): array
    {

        $website = Website::where('website.id', $data['website_id'])->first();
        if (empty($website)) {
            return Result::error("请输入正确的网站id！", 0);
        } else {
            $page_type = WebsiteTemplateInfo::where('website_id', $data['website_id'])->select('page_type')->first();
            if (empty($page_type)) {
                return Result::error("此网站还未添加基础信息！", 0);
            } else {
                $where = json_decode($page_type['page_type'], true);
                // $where = $data["page_type"];
                if (isset($data['template_class_id']) && !empty($data['template_class_id'])) {
                    $template_class = TemplateClass::where('id', $data['template_class_id'])->first();
                    if (empty($template_class)) {
                        return Result::error("请输入正确的模板风格id！", 0);
                    } else {
                        // 获取指定风格下的模板
                        $rep = Template::where('template_class_id', $data['template_class_id'])
                            ->where(function ($query) use ($where) {
                                foreach ($where as $value) {
                                    $query->whereJsonContains('template_img', ['value' => $value]);
                                }
                            })
                            ->limit($data['pageSize'])
                            ->offset(($data['page'] - 1) * $data['pageSize'])
                            ->orderBy("template.updated_at", "desc")
                            ->get();
                        $count = Template::where('template_class_id', $data['template_class_id'])
                            ->where(function ($query) use ($where) {
                                foreach ($where as $value) {
                                    $query->whereJsonContains('template_img', ['value' => $value]);
                                }
                            })->count();
                    }
                } else {

                    //获取所有模板
                    $rep = Template::where(function ($query) use ($where) {
                        foreach ($where as $value) {
                            $query->whereJsonContains('template_img', ['value' => $value]);
                        }
                    })
                        ->limit($data['pageSize'])
                        ->offset(($data['page'] - 1) * $data['pageSize'])
                        ->orderBy("template.updated_at", "desc")
                        ->get();
                    $count = Template::where(function ($query) use ($where) {
                        foreach ($where as $value) {
                            $query->whereJsonContains('template_img', ['value' => $value]);
                        }
                    })->count();
                }
                if (empty($rep) || $rep->count() == 0) {
                    return Result::error("没有查找到相关数据！", 0);
                } else {
                    // 过滤 template_img 字段 只获取 基础信息中 包含的模板图片
                    // $rep->each(function ($item) use ($where) {
                    //     $template_img = json_decode($item->template_img, true);
                    //     if(is_array($template_img)){
                    //         $filtered_img = array_filter($template_img, function ($img) use ($where) {
                    //             return isset($img['value']) && in_array($img['value'], $where);
                    //         });
                    //     }

                    //     $item->template_img = $filtered_img;
                    // });
                    // $result = [
                    //     "rows" => $rep->toArray(),
                    //     "count" => $count
                    // ];
                    $rep->each(function ($item) use ($where) {
                        $template_img = json_decode($item->template_img, true);
                        if (is_array($template_img)) {
                            $filtered_img = array_filter($template_img, function ($img) use ($where) {
                                return isset($img['value']) && in_array($img['value'], $where);
                            });
                            // 对过滤后的数组进行重新排序
                            $sorted_img = array_values($filtered_img);
                            $item->template_img = $sorted_img;
                        } else {
                            $item->template_img = []; // 如果无法解码为数组，则设置为空数组
                        }
                    });

                    $result = [
                        "rows" => $rep->toArray(),
                        "count" => $count,
                    ];
                }
            }
        }
        return Result::success($result);
    }

    /**
     * 添加网站模板
     * @param array $data
     */
    public function addWebsiteTemplateclassintel(array $data): array
    {
        $template = Template::where('id', $data['template_id'])->first();
        $web = Website::where('id', $data['website_id'])->first();
        if (empty($template)) {
            return Result::error("请输入正确的模板id", 0);
        }
        if (empty($web)) {
            return Result::error("请输入正确的网站id", 0);
        }

        $result = WebsiteTemplateInfo::where('website_id', $data['website_id'])->update(['template_id' => $data['template_id'], 'action_id' => 2]);
        if (empty($result)) {
            return Result::error("添加失败", 0);
        } else {
            return Result::success($result);
        }
    }
    /**
     * 获取网站模板信息
     * @param array $data
     */
    public function getWebsiteTemplateclassintel(array $data): array
    {
        // return Result::success($data);
        $template = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($template)) {
            return Result::error("请输入正确的搭建网站id", 0);
        }
        $page_type = json_decode($template['page_type'], true);
        // 获取指定网站下的基础信息和模板及风格信息
        $result = WebsiteTemplateInfo::where([
            ['website_template_info.website_id', $data['website_id']],
            ['website_template_info.template_id', '!=', null],
        ])
            ->leftJoin('template', 'template.id', 'website_template_info.template_id')
            ->leftJoin('template_class', 'template_class.id', 'template.template_class_id')
            ->where(function ($query) use ($page_type) {
                // 假设 $data['page_type'] 是一个数组，包含需要匹配的 page_type 值
                foreach ($page_type as $pageType) {
                    $query->orWhereJsonContains('template.template_img', ['value' => $pageType]);
                }
            })
            ->select(
                'template.template_name',
                'template.template_img',
                'template.id as tid',
                'template_class.name',
                'template_class.id as class_id',
                'website_template_info.page_type',
                'website_template_info.website_id'
            )
            ->first();

        if (empty($result)) {
            return Result::error("没有查找到相关数据", 0);
        }

        // return Result::success($result);
        // 过滤 template_img 字段  只获取 基础信息中 包含的模板图片
        $template_img = $result['template_img'] !== null ? json_decode($result['template_img'], true) : [];
        $page_type = $result['page_type'] !== null ? json_decode($result['page_type'], true) : [];
        foreach ($template_img as $key => $value) {
            if (!in_array($value['value'], $page_type)) {
                unset($template_img[$key]);
            }
        }
        // return Result::success($result);
        $result['template_img'] = array_values($template_img);
        $result['page_type'] = $page_type;

        // $templateList = $this->getWebsiteTemplateList($data);
        // $count = $templateList['data']['count']??'';
        // $pages = $count / $data['pageSize'];
        // $found = false;
        // while ($pages && !$found) {
        //     $templates = $this->getWebsiteTemplateList($pages,$data['pageSize']);
        //     $index = array_search($template['template_id'], array_column($templates['rows'], 'id'));
        //     if ($index !== false) {
        //         $found = true;
        //         $result['page'] = $pages;
        //         $pages = 0;
        //         // echo "查询到的 template 在第 $page 页";
        //     }
        //     $pages--;
        // }

        return Result::success($result);
    }
    /**
     * 获取网站模板下的板块信息
     * @param array $data
     */
    public function getWebsiteSectorList(array $data): array
    {
        $website = Website::where('id', $data['website_id'])->first();
        if (empty($website)) {
            return Result::error("请输入正确的网站id", 0);
        }
        $template = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($template['template_id'])) {
            return Result::error("请先添加网站模板", 0);
        }
        $query = Sector::where('template_id', $template['template_id']);
        if ($query->count() == 0) {
            return Result::error("没有查找到相关板块数据", 0);
        } elseif ($query->count() == 1) {
            $sector = $query->first();
        } else {
            $sector = $query->get();
        }
        $result['page_type'] = $template['page_type'];
        $result['tid'] = $template['template_id'];
        $result = [
            "tid" => $template['template_id'],
            "page_type" => $template['page_type'],
            "sector" => $sector,
        ];
        return Result::success($result);
    }

    // 自助建站---------------fr---------------

    // 网站底基础信息--fr-------------------

    /**
     * 添加网站底基础信息
     * @param array $data
     */
    public function addWebFootInfo(array $data): array
    {
        $website = Website::where('id', $data['website_id'])->first();
        if (empty($website)) {
            return Result::error("请输入正确的网站id！", 0);
        }
        $info = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (!empty($info)) {
            return Result::error("该网站已经添加过了！", 0);
        }
        $result = WebsiteTemplateInfo::where('website_id', $data['website_id'])->insertGetId($data);
        if (empty($result)) {
            return Result::error("请先添加网站基础信息！", 0);
        } else {
            return Result::success($result);
        }
    }
    /**
     * 获取网站底基础信息
     * @param array $data
     */
    public function getWebFootInfo(array $data): array
    {
        $website = Website::where('id', $data['website_id'])->first();
        if (empty($website)) {
            return Result::error("请输入正确的网站id！", 0);
        }
        $result = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($result)) {
            return Result::error("请先添加网站基础信息！", 0);
        }
        return Result::success($result);
    }
    /**
     * 修改网站底基础信息
     * @param array $data
     */
    public function upWebFootInfo(array $data): array
    {
        // return Result::success($data);
        $website = Website::where('id', $data['website_id'])->first();
        if (empty($website)) {
            return Result::error("请输入正确的网站id！", 0);
        }
        $web = $data['website_id'];
        unset($data['website_id']);
        $where = ['website_id' => $web];
        // return Result::success($data);
        $result = WebsiteTemplateInfo::where($where)->first();
        if (empty($result)) {
            $data['website_id'] = $web;
            $result = WebsiteTemplateInfo::insertGetId($data);
            // return Result::error("请先添加网站基础信息！",0);
        } else {
            $result = WebsiteTemplateInfo::where($where)->update($data);
        }
        // $where = ['website_id'=>$data['website_id']];
        // unset($data['website_id']);
        // $result = WebsiteTemplateInfo::updateOrInsert($where, $data);
        if (empty($result)) {
            return Result::error("修改失败！", 0);
        }
        return Result::success($result);
    }

    /*
     * 获取父级/子级栏目------路由
     * @param array $data
     * @return array
     * */
    public function getWebsiteParentCategory(array $data): array
    {
        // return Result::success($data);
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
        }
        if (empty($website)) {
            return Result::error("暂无该网站", 0);
        }
        // 在 Hyperf 中，查询构建器（Builder）没有 `map` 方法，`map` 方法是集合（Collection）的方法。
        // 因此，需要先调用 `get()` 方法获取查询结果集合，再使用 `map` 方法进行处理。
        $category['parent'] = WebsiteCategory::where('website_id', $data['website_id'])
            ->where('pid', 0)
            ->selectRaw("category_id as cid, alias as name, CONCAT('/', '', aLIas_pinyin, '/') as path")
            ->get() // 添加 get() 方法获取结果集合
            ->all();
        // 提前查询所有父级栏目，避免在 map 中多次查询
        // 提前查询所有父级栏目信息并以 category_id 作为键存储
        $parentCategories = WebsiteCategory::where('website_id', $data['website_id'])
            ->where('pid', 0)
            ->select('category_id', 'aLIas_pinyin')
            ->get()
            ->keyBy('category_id');

        // 直接查询子栏目信息
        $child = WebsiteCategory::where('website_id', $data['website_id'])
            ->where('pid', '!=', 0)
            ->select('alias', 'category_id', 'aLIas_pinyin', 'pid')
            ->get();

        // 使用集合的 map 方法处理子栏目信息
        $category['child'] = $child->map(function ($item) use ($parentCategories) {
            $alias = $item->alias;
            $category_id = $item->category_id;
            $aLIas_pinyin = $item->aLIas_pinyin;
            $parent = $parentCategories->get($item->pid);
            $parentAlias = $parent ? $parent->aLIas_pinyin : '';
            $result = [
                'name' => $alias,
                'cid' => $category_id
            ];
            if (!empty($aLIas_pinyin) && !empty($parentAlias)) {
                $result['path'] = "/{$parentAlias}/{$aLIas_pinyin}/";
            }
            return $result;
        })->values()->all();
        if (empty($category)) {
            return Result::error("暂无此导航", 0);
        }
        return Result::success($category);
    }
    /**
     * 获取网站栏目信息
     * @param array $data
     */
    public function getWebsiteFootAll(array $data): array
    {
        $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
        if (empty($website)) {
            return Result::error("暂无该网站", 0);
        }
        // 1:图片 2：文字 3：底部
        $result['foot_cate'] = FooterCategory::where('website_id', $data['website_id'])->get()->all();
        $result['link_img'] = Link::where('website_id', $data['website_id'])->where('type', 1)->where('status', 1)->limit($data['link_imgnum'])->orderBy('sort')->get()->all();
        $result['link_text'] = Link::where('website_id', $data['website_id'])->where('type', 2)->where('status', 1)->limit($data['link_textnum'])->orderBy('sort')->get()->all();
        $result['link_foot'] = Link::where('website_id', $data['website_id'])->where('type', 3)->where('status', 1)->limit($data['link_footnum'])->orderBy('sort')->get()->all();
        $result['foot_info'] = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($result)) {
            return Result::error("暂无此网站信息", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取网站顶部信息
     * @param array $data
     */
    public function getWebsiteHead(array $data): array
    {
        $result = Website::where('id', $data['website_id'])->where('status', 1)->select('website_name', 'logo')->first();
        if (empty($result)) {
            return Result::error("暂无该网站", 0);
        }
        return Result::success($result);
    }


    /**
     * 路由匹配
     * @param array $data
     */
    public function getWebsiteRoute(array $data): array
    {
        $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
        if (empty($website)) {
            return Result::error("暂无该网站", 0);
        }
        if (isset($data['pinyin']) && !empty($data['pinyin'])) {
            $result = WebsiteCategory::where('website_category.website_id', $data['website_id'])
                ->where('website_category.aLIas_pinyin', $data['pinyin'])
                ->leftJoin('website_category as pc', function ($join) use ($data) {
                    $join->on('pc.pid', '=', 'website_category.category_id')
                        ->where('pc.website_id', '=', $data['website_id']);
                })
                ->select('website_category.category_id', 'website_category.type', 'website_category.alias', DB::raw('CASE WHEN pc.category_id IS NOT NULL THEN 1 ELSE 0 END as children_count'))
                ->first();
        }
        if (isset($data['foot_pinyin']) && !empty($data['foot_pinyin'])) {
            $result = FooterCategory::where('website_id', $data['website_id'])->where('name_pinyin', $data['foot_pinyin'])->first(['id']);
        }
        if (!isset($result) || empty($result)) {
            return Result::error("暂无该导航", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取网站栏目信息
     * @param array $data
     */
    public function getWebsiteAllinfo(array $data): array
    {
        $website = Website::where('id', $data['website_id'])->where('status', 1)->first();
        if (empty($website)) {
            return Result::error("暂无该网站", 0);
        }
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            $website_head = Website::where('id', $data['website_id'])
                ->where('status', 1)
                ->select(
                    'id',
                    'website_name',
                    'logo',
                    'title',
                    'keywords',
                    'description',
                    'suffix',
                    'website_url',
                    'ad_key',
                    'api_url',
                    'login_url',
                    'weblog_url'
                )
                ->first();
            if (empty($website_head)) {
                return Result::error("找不到网站", 0);
            }
        } else {
            return Result::error("参数错误", 0);
        }
        $website_foot['foot_info'] = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($website_foot)) {
            return Result::error("暂无底部基础信息", 0);
        }
        $website_head['website_url'] = $website_head['website_url'] ? json_decode($website_head['website_url']) : [];
        $result['website_head'] = $website_head;
        $result['website_foot'] = $website_foot;

        // return Result::success($result);
        // 1:图片 2：文字 3：底部
        $result['website_foot']['foot_cate'] = FooterCategory::where('website_id', $data['website_id'])->get()->all();
        $result['website_foot']['link_img'] = Link::where('website_id', $data['website_id'])->where('type', 1)->where('status', 1)->limit($data['link_imgnum'])->orderBy('sort')->get()->all();
        $result['website_foot']['link_text'] = Link::where('website_id', $data['website_id'])->where('type', 2)->where('status', 1)->limit($data['link_textnum'])->orderBy('sort')->get()->all();
        $result['website_foot']['link_foot'] = Link::where('website_id', $data['website_id'])->where('type', 3)->where('status', 1)->limit($data['link_footnum'])->orderBy('sort')->get()->all();
        if (empty($result)) {
            return Result::error("暂无此网站信息", 0);
        }
        return Result::success($result);
    }
    //20250212  网站标识
    public function addWebsiteGroup(array $data): array
    {
        //判斷name是不是重复
        $websiteGroupInfo = WebsiteGroup::query()->where('name', $data['name'])->first();
        if (!empty($websiteGroupInfo)) {
            return Result::error("网站标识重复", 0);
        }
        //添加信息
        $result = WebsiteGroup::insertGetId($data);
        var_dump($result);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success($result);
        }
    }
    public function getWebsiteGroupList(array $data): array
    {
        $where = [];
        if (isset($data['name']) && !empty($data['name'])) {
            array_push($where, ['website_group.name', 'like', '%' . $data['name'] . '%']);
        }
        $result = WebsiteGroup::where($where)
            ->limit($data['pageSize'])->orderBy("id", "desc")->offset(($data['page'] - 1) * $data['pageSize'])
            ->get();

        foreach ($result as $websiteGroup) {
            $webIds = json_decode($websiteGroup->web_ids, true);
            $websites = Website::whereIn('id', $webIds)->get();
            $websiteNames = $websites->pluck('website_name', 'id')->toArray();
            $websiteGroup->website_names = $websiteNames;
            $websiteGroup->website_names1 = implode(',', array_values($websiteNames));
        }
        $count = WebsiteGroup::where($where)->count();
        if (empty($result)) {
            return Result::error("没有数据", 0);
        }
        return Result::success(['list' => $result->toArray(), 'count' => $count]);
    }
    public function getWebsiteGroupInfo(array $data): array
    {
        $websiteInfo = WebsiteGroup::query()->where('id', $data['id'])->first();
        $webIds = json_decode($websiteInfo->web_ids, true);
        $websites = Website::whereIn('id', $webIds)->get();
        $websiteNames = $websites->pluck('website_name', 'id')->toArray();
        $websiteInfo->website_names = $websiteNames;
        $websiteInfo->website_names1 = implode(',', array_values($websiteNames));
        if (empty($websiteInfo)) {
            return Result::error("找不到URL", 0);
        }
        return Result::success($websiteInfo->toArray());
    }
    public function updateWebsiteGroup(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $insertData = [
            'name' => $data['name'],
            'web_ids' => $data['web_ids'],
        ];

        //判斷name是不是重复
        $websiteGroupInfo = WebsiteGroup::query()->where('name', $data['name'])->first();
        if (!empty($websiteGroupInfo) && $websiteGroupInfo->id != $data['id']) {
            return Result::error("网站标识重复", 0);
        }

        $result = WebsiteGroup::where($where)->update($insertData);
        var_dump($result, '------更新');
        if (empty($result)) {
            return Result::error("更新失败", 0);
        } else {
            return Result::success();
        }
    }
    public function deleteWebsiteGroup(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        //看看user表是不是有这个id
        $userGroup = User::query()->where('sszq', $data['id'])->first();
        if (!empty($userGroup)) {
            return Result::error("有用户在使用该网站标识，不能删除", 0);
        }
        $result = WebsiteGroup::where($where)->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }
    public function getWebsiteNavList(array $data): array
    {
        $data['type'] = isset($data['type']) ? $data['type'] : 1;
        $where = [];
        if (isset($data['website_id']) && !empty($data['website_id'])) {
            array_push($where, ['website_id', '=', $data['website_id']]);
        }
        if (isset($data['pid'])) {
            array_push($where, ['pid', '=', $data['pid']]);
        }
        if (isset($data['type']) && !empty($data['type'])) {
            array_push($where, ['type', '=', $data['type']]);
        }
        // 根据站点和type获取websiteCategory 中的id
        $websiteCategoryids = WebsiteCategory::query()
            ->where('website_id', '=', $data['website_id'])
            ->where('type', '=', $data['type'])
            ->pluck('category_arr_id')->toArray();
        var_dump($websiteCategoryids, '------获取websiteCategory 中的id');
        //合并去重
        $category_ids = [];
        foreach ($websiteCategoryids as $key => $value) {
            $v = json_decode($value, true);
            $category_ids = array_unique(array_merge($category_ids, $v));
        }
        // var_dump($category_ids, '------获取websiteCategory 中的id');
        //根据pid取出所有的websiteCategory 中的id
        $list = WebsiteCategory::query()
            ->where('website_id', '=', $data['website_id'])
            ->where('is_url', '!=', 1)
            ->where('pid', '=', $data['pid'])
            ->whereIn('category_id', $category_ids)
            ->get();
        if (empty($list)) {
            return Result::error("获取失败", 0);
        } else {
            return Result::success($list);
        }
    }

    // 20250307 根据网站标识获和导航获取站点

    public function getWebsiteNavPoolSite(array $data): array
    {
        $where = [];
        if (isset($data['category_id']) && !empty($data['category_id'])) {
            array_push($where, ['category_id', '=', $data['category_id']]);
        }
        $list = WebsiteCategory::query()->where($where)
            ->leftJoin('website', 'website.id', '=', 'website_category.website_id')
            ->select('website_category.*', 'website.website_name')
            ->distinct()
            ->get();
        if (empty($list)) {
            return Result::error("获取失败", 0);
        } else {
            return Result::success($list);
        }
    }
    public function getWebsiteNavPool(array $data): array
    {
        // 初始化查询条件数组
        $query = WebsiteCategory::query();

        // 如果传入了 websiteids，则添加到查询条件中
        if (isset($data['websiteids']) && !empty($data['websiteids'])) {
            $query->whereIn('website_id', $data['websiteids']);
        }

        // 如果传入了 pid，则添加到查询条件中
        if (isset($data['pid'])) {
            $query->where('pid', '=', $data['pid']);
        }

        // 执行查询 唯一性 id
        $list = $query->distinct()->get();

        // 根据查询结果返回相应的结果
        if ($list->isEmpty()) {
            return Result::error("获取失败", 0);
        } else {
            return Result::success($list->toArray());
        }
    }

    /**
     *
     * @param array $data
     * @return array
     */
    public function getAllCategory(array $data): array
    {
        $total = Category::count();
        $pageSize = 2000;
        $pages = (int) ceil($total / $pageSize);

        $results = [];
        $concurrency = 5; // 最大并发数
        $running = 0;
        $chan = new \Swoole\Coroutine\Channel($pages);

        for ($i = 0; $i < $pages; $i++) {
            Coroutine::create(function () use ($i, $pageSize, $chan) {
                $offset = $i * $pageSize;
                $data = Category::useIndex('idx_covering')
                    ->orderBy('id', 'asc')
                    ->select('id', 'name', 'pid')
                    ->offset($offset)
                    ->limit($pageSize)
                    ->get()
                    ->toArray();
                $chan->push($data);
            });
        }

        for ($i = 0; $i < $pages; $i++) {
            $res = $chan->pop();
            if (is_array($res)) {
                $results = array_merge($results, $res);
            }
        }

        return Result::success($results);
    }

    /**
     * 修改网站栏目排序
     * @param array $data
     * @return array
     */
    public function upWebsiteCategorySort(array $data): array
    {
        $where = [
            'website_id' => $data['website_id'],
            'id' => $data['id'],
        ];
        $result = WebsiteCategory::where($where)->update($data);
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("更新失败", 0);
        }
    }

    //获取底部导航内容详情
    public function getFooterContentInfo(array $data): array
    {
        $where = [
            "id" => $data['content_id']
        ];
        $result = FooterContent::where($where)->first();
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("没有数据");
        }
    }
    //获取底部导航内容列表
    public function getFooterContentList(array $data): array
    {
        $where = [
            "fcat_id" => $data['fcat_id'],
        ];
        switch (intval($data['type'])) {
            case 0:
                $result = FooterContent::where($where)->first();
                break;
            case 1:
                $result = FooterContent::where($where)->get();
                break;
        }
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("没有数据");
        }
    }

    /**
     * 获取底部导航列表
     * @param array $data
     * @return array
     */
    public function getFooterCategoryList(array $data): array
    {
        $where = [
            "website_id" => $data['website_id']
        ];
        $result = FooterCategory::where($where)->get();
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("没有数据");
        }
    }
    // --自助建站-----------20250522fr----------------------start
    /**
     * 获取网站模板下的板块信息
     * @param array $data
     * @return array
     */
    public function getStaticResourceList(array $data): array
    {
        // return Result::success($data);
        $where = [];
        if (isset($data['img_alias']) && !empty($data['img_alias'])) {
            array_push($where, ['website_img.img_alias', 'like', '%' . $data['img_alias'] . '%']);
        }
        if (isset($data['img_type']) && !empty($data['img_type'])) {
            array_push($where, ['website_img.img_type', '=', $data['img_type']]);
        }
        if (isset($data['website_name']) && !empty($data['website_name'])) {
            $website = Website::where('website_name', 'like', '%' . $data['website_name'] . '%')->first();
            if (empty($website)) {
                return Result::error("没有查找到相关数据", 0);
            } else {
                array_push($where, ['website_img.website_id', '=', $website['id']]);
            }
        }
        // return Result::success($where);
        $query = WebsiteImg::when(!empty($where), function ($query) use ($where) {
            $query->where($where);
        })
            ->orderBy('updated_at', 'desc');
        $count = $query->count();
        $row = $query->leftJoin('website', 'website.id', '=', 'website_img.website_id')
            ->select('website_img.*', 'website.website_name')
            ->limit($data['pageSize'])
            ->offset(($data['page'] - 1) * $data['pageSize'])
            ->get();
        if (empty($row)) {
            return Result::error("没有查找到相关数据", 0);
        } else {
            $result = [
                'row' => $row,
                'count' => $count,
            ];
        }
        return Result::success($result);
    }
    /**
     * 添加网站模板下的板块信息
     * @param array $data
     */
    public function addStaticResource(array $data): array
    {
        // $file = $data['img_url']->file('image');
        // $size = $file->getSize();
        $img_data = [
            'website_id' => $data['website_id'] ?? 0,
            'img_alias' => $data['img_alias'] ?? '',
            'img_url' => $data['img_url'],
            'img_size' => $data['img_size'],
        ];
        $img = WebsiteImg::insertGetId($img_data);
        if (empty($img)) {
            return Result::error("添加失败", 0);
        }
        $img_id['id'] = $img;
        $url = WebsiteImg::where($img_id)->value('img_url');

        // 1. 分割路径部分（以 / 为分隔符）
        $pathSegments = explode('/', parse_url($url, PHP_URL_PATH));

        // 2. 取最后一个元素作为文件名
        $fileName = end($pathSegments); // 1743041040714597.jpg

        // 3. 分割文件名获取扩展名
        $fileParts = explode('.', $fileName);
        $fileType = end($fileParts); // jpg


        $img_datas = [
            'img_type' => $fileType,
            'name' => $fileName
        ];
        $up_img = WebsiteImg::where($img_id)->update($img_datas);
        if (empty($up_img)) {
            return Result::error("修改失败", 0);
        }
        return Result::success($up_img);
        // 将字节转换为更友好的单位
        // $friendlySize = $this->formatFileSize($size);
        // $data['img_size'] = $friendlySize;


    }
    /**
     * 修改网站模板下的板块信息
     * @param array $data
     */
    public function delStaticResource(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $result = WebsiteImg::where($where)->delete();
        if (empty($result)) {

            return Result::error("修改失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取尺寸列表
     * @param array $data
     */
    public function getSizeList(array $data): array
    {
        $where = [];
        if (isset($data['width']) && !empty($data['width'])) {
            array_push($where, ['width', 'like', '%' . $data['width'] . '%']);
        }
        if (isset($data['height']) && !empty($data['height'])) {
            array_push($where, ['height', 'like', '%' . $data['height'] . '%']);
        }
        $query = Size::when($where, function ($query) use ($where) {
            $query->where($where);
        })
            ->orderBy('updated_at', 'desc');
        $count = $query->count();
        $rep = $query
            ->offset(($data['page'] - 1) * $data['pageSize'])
            ->limit($data['pageSize'])
            ->get();
        $result = [
            'row' => $rep,
            'count' => $count,
        ];
        if (empty($result)) {
            return Result::error("获取失败", 0);
        } else {
            return Result::success($result);
        }
    }
    /**
     * 添加尺寸
     * @param array $data
     */
    public function addSize(array $data): array
    {
        $size = Size::where('width', $data['width'])->where('height', $data['height'])->first();
        if (!empty($size)) {
            return Result::error("尺寸已存在", 0);
        }
        $result = Size::insertGetId($data);
        if (empty($result)) {
            return Result::error("添加失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 删除尺寸
     * @param array $data
     */
    public function delSize(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $result = Size::where($where)->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 修改尺寸
     * @param array $data
     */
    public function upSize(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $size = Size::where('id', '!=', $data['id'])->where('width', $data['width'])->where('height', $data['height'])->first();
        if (!empty($size)) {
            return Result::error("尺寸已存在", 0);
        }
        $result = Size::where($where)->update($data);
        if (empty($result)) {
            return Result::error("修改失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取尺寸详情
     * @param array $data
     */
    public function getSizeInfo(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $result = Size::where($where)->first();
        if (empty($result)) {
            return Result::error("获取失败", 0);
        } else {
            return Result::success($result);
        }
    }
    /**
     * 获取网站名称缩写
     * @param array $data
     */
    public function getWebsiteAdkey(array $data): array
    {

        $result = PinyinHelper::getFirstLetter($data['website_name']);
        if (empty($result)) {
            return Result::error("没有数据", 0);
        } else {
            return Result::success($result);
        }
    }
    /**
     * 静态资源管理-修改图片别名
     * @param array $data
     */
    public function upStaticResource(array $data): array
    {
        $id = $data['id'];
        unset($data['id']);
        $result = WebsiteImg::where('id', $id)->update($data);
        if (empty($result)) {
            return Result::error("修改失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 自助建站-修改网站应用状态
     * @param array $data
     */
    public function upWebsiteStatus(array $data): array
    {
        $where = [
            'website_id' => $data['website_id'],
        ];
        $website_template = WebsiteTemplate::where($where)->first();
        unset($data['website_id']);
        if ($data['status'] == 2) {
            $template_status = 6;
        } else {
            $template_status = 1;
        }
        if (empty($website_template)) {
            return Result::error("网站预制模板获取失败", 0);
        } else {
            Db::beginTransaction();
            try {
                $result['website_template'] = WebsiteTemplate::where($where)->update(['status' => $template_status]);
                if (empty($result['website_template'])) {
                    return Result::error("修改网站模板状态失败", 0);
                }
                $result['website_template_info'] = WebsiteTemplateInfo::where($where)->update(['status' => $data['status']]);
                if (empty($result['website_template_info'])) {
                    return Result::error("修改网站基础信息状态失败", 0);
                }
                Db::commit();
                return Result::success($result);
            } catch (\Exception $e) {
                Db::rollBack();
                return Result::error($e->getMessage(), 0);
            }
        }
    }

    // --自助建站-----------20250522fr----------------------end

    /**
     * 获取网站白名单路由地址
     * @param array $data
     * @return array
     */
    public function getWhiteRouterList(array $data): array
    {
        // 构建基础查询
        $baseQuery = WhiteRouter::query();

        // 功能名称模糊查询
        if (!empty($data['function_name'])) {
            $baseQuery->where('function_name', 'like', '%' . $data['function_name'] . '%');
        }

        // 网站ID查询 - 使用 JSON_CONTAINS 检查数组中是否包含指定的 website_id
        if (!empty($data['website_id'])) {
            $baseQuery->whereRaw('JSON_CONTAINS(website_id, ?)', [json_encode((int)$data['website_id'])]);
        }

        // 获取总数
        $count = $baseQuery->count();

        // 分页查询
        $result = $baseQuery->orderBy('updated_at', 'desc')
            ->limit($data['pageSize'])
            ->offset(($data['page'] - 1) * $data['pageSize'])
            ->get();

        if (empty($result)) {
            return Result::error("暂无数据", 0);
        }

        // 处理结果，将 website_id 转换为数组并获取对应的网站名称
        $result->transform(function ($item) {
            $websiteIds = json_decode($item->website_id, true);
            $websiteNames = Website::whereIn('id', $websiteIds)
                ->pluck('website_name')
                ->toArray();
            $item->website_names = $websiteNames;
            $item->website_id = $websiteIds; // 将 website_id 转换为数组
            return $item;
        });

        return Result::success([
            'rows' => $result->toArray(),
            'count' => $count
        ]);
    }
    /**
     * 添加网站白名单路由地址
     * @param array $data
     * @return array
     */
    public function addWhiteRouter(array $data): array
    {
        // 确保 website_id 是数组
        $websiteIds = is_array($data['website_id']) ? $data['website_id'] : [$data['website_id']];
        // 过滤空值并去重
        $websiteIds = array_filter($websiteIds);
        $websiteIds = array_unique($websiteIds);
        // 将数组中的值转换为整数
        $websiteIds = array_map(function ($value) {
            return (int)$value;
        }, $websiteIds);
        // 转换为 JSON 字符串存储
        $data['website_id'] = json_encode($websiteIds);

        $result = WhiteRouter::insertGetId($data);
        if (empty($result)) {
            return Result::error("添加失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 修改网站白名单路由地址
     * @param array $data
     * @return array        
     */
    public function upWhiteRouter(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        // 确保 website_id 是数组
        $websiteIds = is_array($data['website_id']) ? $data['website_id'] : [$data['website_id']];
        // 过滤空值并去重
        $websiteIds = array_filter($websiteIds);
        $websiteIds = array_unique($websiteIds);
        // 将数组中的值转换为整数
        $websiteIds = array_map(function ($value) {
            return (int)$value;
        }, $websiteIds);
        // 转换为 JSON 字符串存储
        $data['website_id'] = json_encode($websiteIds);

        $result = WhiteRouter::where($where)->update($data);
        if (empty($result)) {
            return Result::error("修改失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 删除网站白名单路由地址
     * @param array $data
     * @return array
     */
    public function delWhiteRouter(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $result = WhiteRouter::where($where)->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取网站白名单路由地址详情
     * @param array $data
     * @return array
     */
    public function getWhiteRouterInfo(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $result = WhiteRouter::where($where)->first();
        if (empty($result)) {
            return Result::error("没有查找到相关数据", 0);
        }
        // 将 website_id 从 JSON 字符串转换为数组
        $result->website_id = json_decode($result->website_id, true);
        return Result::success($result);
    }

    /**
     * 克隆网站
     * @param array $data
     * @return array
     */
    public function cloneWebsite(array $data): array
    {
        DB::beginTransaction();
        try {
            // 获取原始网站信息
            $originalWebsite = Website::find($data['website_id']);
            if (!$originalWebsite) {
                return Result::error("找不到该网站", 0);
            }
            // 提取基础名称（去除已有 _copy 或 _copy_xxx）
            $baseName = preg_replace('/_copy(\d+)?$/', '', $originalWebsite->website_name);
            // 查询当前系统中已存在的克隆名称数量
            $count = Website::where('website_name', 'like', $baseName . '_copy%')
                ->orWhere('website_name', $baseName)
                ->count();
            // 构造新名称：第一次是 _copy，之后是 _copy_1, _copy_2 ...
            $newName = $baseName . ($count === 0 ? '_copy' : '_copy_' . $count);
            // 创建克隆网站实例
            $clone_website = $originalWebsite->replicate();
            $clone_website->website_name = $newName;
            $clone_website->save();
            $clone_website->website_url = "[]";
            $clone_website->save();
            //            var_dump("返回值：",$clone_website->id);
            //克隆网站基础信息  website_template_info website_category
            $resultWebsiteTemplateInfo = WebsiteTemplateInfo::where(['website_id' => $data['website_id']])->first();
            $clone_website_template_info = $resultWebsiteTemplateInfo->replicate();
            $clone_website_template_info->website_id = $clone_website->id;
            $clone_website_template_info->save();
            //克隆网站导航 获取原始 website_id 对应的所有 WebsiteCategory 记录
            $originalCategories = WebsiteCategory::where('website_id', $data['website_id'])->get();
            // 克隆网站后的新 ID（假设 $clone_website->id 已存在）
            $newWebsiteId = $clone_website->id;
            // 遍历每条记录并克隆
            foreach ($originalCategories as $category) {
                // 使用 replicate() 方法创建模型副本（不包含主键）
                $clonedCategory = $category->replicate();
                // 修改外键字段指向新网站 ID
                $clonedCategory->website_id = $newWebsiteId;
                // 保存克隆后的记录到数据库
                $clonedCategory->save();
            }
            //克隆友情链接 Link 对应的是多个
            $originalLinks = Link::where('website_id', $data['website_id'])->get();
            foreach ($originalLinks as $link) {
                // 使用 replicate() 方法创建模型副本（不包含主键）
                $clonedLink = $link->replicate();
                // 修改外键字段指向新网站 ID
                $clonedLink->website_id = $newWebsiteId;
                // 保存克隆后的记录到数据库
                $clonedLink->save();
            }
            //克隆网站底部信息 footer_category 表 和footer_content 表 footer_category.id = footer_content.fcat_id 都是一对多关系
            $originalFooterCategories = FooterCategory::where('website_id', $data['website_id'])->get();
            foreach ($originalFooterCategories as $footerCategory) {
                $clonedFooterCategory = $footerCategory->replicate();
                $clonedFooterCategory->website_id = $newWebsiteId;
                $clonedFooterCategory->save();
                $originalFooterContents = FooterContent::where('fcat_id', $footerCategory->id)->get();
                foreach ($originalFooterContents  as $footerContent) {
                    $clonedFooterContent = $footerContent->replicate();
                    $clonedFooterContent->fcat_id = $clonedFooterCategory->id;
                    $clonedFooterContent->save();
                }
            }
            Db::commit();
            return Result::success([]);
        } catch (\Exception $e) {
            Db::rollBack();
            return Result::error($e->getMessage(), 0);
        }
    }

    /**
     * 更新网站状态
     * @param array $data
     * @return array
     */
    public function updateWebsiteStatus(array $data): array
    {
        try {
            Website::where(["id" => $data['id']])->update(["status" => intval($data['status'])]);
            return Result::success([]);
        } catch (\Exception $e) {
            return Result::error($e->getMessage(), 0);
        }
    }
    /**
     * 删除网站url
     * @param array $data
     * @return array
     */
    public function delWebsiteUrl(array $data): array
    {
        try {
            $wensiteInfo = Website::where(["id" => $data['website_id']])->first();
            if (empty($wensiteInfo)) {
                return Result::error("找不到该网站", 0);
            }

            $websiteUrlArray = [];
            if (!empty($wensiteInfo->website_url)) {
                $decoded = json_decode((string) $wensiteInfo->website_url, true);
                $websiteUrlArray = is_array($decoded) ? $decoded : [];
            }

            // 从数组中按值删除对应的 URL
            $index = array_search($data['website_url'] ?? null, $websiteUrlArray, true);
            if ($index !== false) {
                unset($websiteUrlArray[$index]);
                // 重新索引，保持为连续的 JSON 数组
                $websiteUrlArray = array_values($websiteUrlArray);
            }

            $newWebsiteUrlJson = json_encode($websiteUrlArray, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
            Website::where(["id" => $data['website_id']])->update(["website_url" => $newWebsiteUrlJson]);
            return Result::success([]);
        } catch (\Exception $e) {
            return Result::error($e->getMessage(), 0);
        }
    }
}