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\WebsiteRole;
use App\Model\WebsiteRoleUser;
use App\Model\Website;
use App\Model\WebsiteColumn;
use Hyperf\DbConnection\Db;
use Hyperf\RpcServer\Annotation\RpcService;
use App\Tools\Result;
use Carbon\Carbon;   
use App\Model\WebsiteCategory;
use function PHPUnit\Framework\isNull;

#[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
    {
        $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']]);
        }
        if(isset($data['city_id']) && !empty($data['city_id'])){
            array_push($where,['website.city_id','=',$data['city_id']]);
        }

        $result = Website::where($where)
            ->leftJoin("website_column","website.website_column_id","website_column.id")
            ->leftJoin("district","district.id","website.city_id")
            ->select("website.*","website_column.column_name","district.name as city_name")
            ->limit($data['pageSize'])->offset(($data['page']-1)*$data['pageSize'])->orderBy("website.id","desc")->get();

        $count = Website::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 createWebsite(array $data): array
    {
        var_dump("网站数据:",$data);
        $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,
        ];
        $result = Website::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 updateWebsite(int $id,array $data): array
    {
        $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,
        ];
        $result = Website::where('id',$id)->update($insertData);
        var_dump("更新站点",$result);
        if(empty($result)){
            return Result::error("更新失败",0);
        }else{
            return Result::success();
        }
    }

    /**
     * @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 = [
            'website_id' => $data['website_id'],
            'ad_place.status' => 1,
            // 'ad.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'].'%'];
            $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.*",'ad.*',"ad_place.id as ad_place_id","ad.name as ad_name")
            ->get()->all();
            if(empty($result)){
                return Result::error("此广告位不存在！",0);
            } 
        }else{
            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 
    { 
        $provinces=District::where('pid',0)->where('status',1)->get();
       
        if(isset($data['province'])){ 
            $province=District::where('pid',0)->where('status',1)->where('id',$data['province'])->orderBy('code')->get();
            $province=$province->toArray(); 
            if(!empty($province)){
                $citys=District::where('pid',$data['province'])->where('status',1)->orderBy('code')->get();
                if(!empty($citys) && isset($data['city']) && !empty($data['city'])){
                    // $province = $province->toArray();
                    $province_id=[];
                    foreach($province as $val){
                        array_push($province_id,$val['id']); 
                    }
                    // var_dump($province_id);
                    $city=District::whereIn('pid',$province_id)->where('status',1)->where('id',$data['city'])->orderBy('code')->get();
                    if(!empty($city)){
                        $city_id=[];
                        foreach($city as $val){
                            array_push($city_id,$val['id']); 
                        }
                        $regions=District::whereIn('pid',$city_id)->where('status',1)->orderBy('code')->get();
                       
                            $result=[
                                'province' => $province,
                                'city' => $city,
                                'region' => $regions
                            ];
                    }else{
                        return Result::error("未查询到此城市",0);  
                    }
                }else{ 
                    $result=[
                        'province' => $province,
                        'city' => $citys,
                        'region' => null
                    ];
                }
            }else{
                return Result::error("未查询到此省份",0); 
            }
        }else{
            // $keys = array('data');
           $result =  $provinces;
        } 
        return Result::success($result);   
    }

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

    public function getWebsiteModelCategory(array $data): array 
    {
        $website_id=[ 
            'website_category.website_id' => $data['website_id'] 
        ];
        $placeid=$data['placeid']-1; 
        $pid=[
            'website_category.pid' => $data['pid'], 
        ];
        var_dump( "=======",$pid);
        $num = $data['num'];
        // return Result::success($data);
        $result=WebsiteCategory::where($website_id)
        ->leftJoin("category",'website_category.category_id','category.id')
        ->select('website_category.*','category.is_url','category.web_url')
        ->where($pid)
        // ->with(['children' => function ($query) use ($data) {
        //     $query->where('website_category.website_id', $data['website_id']);
        // }])
        ->orderBy('website_category.sort')  
        ->offset($placeid)
        ->limit($num)
        ->get();
        foreach($result as $k=>$v){
            $child[$k]['children_countent']=WebsiteCategory::where($website_id)
            ->where('website_category.pid',$v['category_id'])
            ->count();
            if(!empty($child[$k]['children_countent'])){
                $result[$k]['children_count']=$child[$k]['children_countent'];
            }else{
                $result[$k]['children_count']=0;
            }
        }
        return Result::success($result);
        if(!empty($result)){ 
            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['type_id']);
         switch ($data['type_id']){
             case 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;');
                 return Result::success($result);
                 break;
             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['monthArticle']= [];
                 //用户类型
                 $res['userType'] = [];
                 $res['website']['count']  = Website::where([])->count();
                 $res['article']['count']  = Article::whereNotIn('status',['404'])->count();
                 $res['category']['count']  = Category::where([])->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['userType']  = User::where([])->selectRaw("count(*) as counts,type_id")->groupBy('type_id')->get();
                 return Result::success($res);

         }

         return [];
    }

    /**
     * 获取模板类型
     * @return void
     */
    public function getTemplateClass(array $data): array
    {
        $where = [];
        if(isset($data['name']) && $data['name']){
            array_push($where,['name','like','%'.$data['name'].'%']);
        }
        $result = TemplateClass::where($where)->orderBy('sort','asc')->get();
        if(empty($result)){
            return Result::error("没有模板类型",0);
        }else{
            return Result::success($result);
        }
    }

    /**
     * 添加模板类型
     * @param
     * @return void
     */
    public function addTemplateClass(array $data): array
    {
        $insertData = [
            'name'=>$data['name']
        ];
        $result = TemplateClass::insertGetId($insertData);
        if(empty($result)){
            return Result::error("创建失败",0);
        }else{
            return Result::success(["id"=>$result]);
        }
    }

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

    /**
     * 删除模板
     * @param array $data
     * @return array
     */
    public function delTemplateClass(array $data): array
    {
        $where = [
            'id'=>$data['id']
        ];

        $result = TemplateClass::where($where)->delete();
        if(empty($result)){
            return Result::error("删除失败",0);
        }else{
            return Result::success();
        }
    }

    /**
     * 获取分类下的模板
     * @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($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'],
            'pid'=>0
        ];
        $result = WebsiteCategory::where($where)->get();
        if($result){
            return Result::success($result);
        }else{
            return Result::error("查询失败",0);
        }
    }

    /**
     * 更新网站导航
     * @param array $data
     * @return array
     */
    public function upWebsiteCategory(array $data): array
    {
        Db::beginTransaction();
        try{
           //合并栏目id
            $reqIds = array_merge($data['old_category_arr_id'],$data['new_category_arr_id']);
            //对比old 数组差异化，把差异化的删除
            $result = WebsiteCategory::where(['website_id'=>$data['website_id'],'pid'=>0])->get();
            $result = $result->toArray();
            $categoryIds = [];
            if($result){
                foreach ($result as $val){
                    array_push($categoryIds,$val['category_id']);
                }
            }
            //和原始数据对比取交际
            $reqidsIntersect = array_intersect($reqIds,$categoryIds);
            //再取差集 进行对比
            $differenceIDS =  array_merge(array_diff($reqidsIntersect, $categoryIds),array_diff($categoryIds,$reqidsIntersect));
            var_dump("差集：",$differenceIDS);
            $arr_ids = [];
            if(count($differenceIDS)>0){
                foreach ($differenceIDS as $vv){
                    $idV =  $this->getUnderlingUIds(intval($vv));
                    $ids_arrV = explode(",", $idV);
                    array_push($arr_ids,$ids_arrV);
                }
            }
           $del_ids = array_reduce($arr_ids, 'array_merge', array());
            //有差异  删除
            if(count($del_ids)>0){
                 WebsiteCategory::where(['website_id'=>$data['website_id']])->whereIn("category_id",$del_ids)->delete();
            }
            //传过来的值 和 交际 对比，选出要添加的值 进行插入
           $insertIDS =  array_merge(array_diff($reqIds, $reqidsIntersect),array_diff($reqidsIntersect,$reqIds));
            var_dump("要存储的：",$insertIDS);
            //新的数组重新创建
            if(count($insertIDS)>0){
                $arr = [];
                $categoryListIds = $insertIDS;
                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("要插入的ID:",$mergedArray);
                //查询出所有的分类进行分割插入 组装数据
                $categoryListData = Category::whereIn('id',$mergedArray)->get();
                $categoryListData = $categoryListData->toArray();
                $insertData = [];
                if($categoryListData){
                    foreach ($categoryListData as $key=>$value){
                        $insertData[$key]['website_id'] = $data['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'];
                    }
                }
                 WebsiteCategory::insert($insertData);

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

        return Result::success();
    }

    /**
     * 获取网站列表
     * @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'])->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
    {
        $where = [
            'website_id'=>$data['website_id'],
            'category_id'=>$data['category_id'],
        ];
        $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')
            ->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'])
            ->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($data);
        }else{
            return Result::error("查询失败",0);
        }
        if($result){
            return Result::success($result);
        }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 = Website::where('id',$data['website_id'])->where('status',1)->first();
            if (empty($website)) {
                return Result::error("找不到网站",0); 
            }
        }else{
            return Result::error("参数错误",0);
        }
        $website_foot = WebsiteTemplateInfo::where('website_id',$data['website_id'])->where('status',2)->first();
        $website_head = Website::where('id',$data['website_id'])
        ->select('id','website_name','logo','title','keywords','description')->first();
        if (empty($website_foot)) {
            return Result::error("暂无底部基础信息",0);
        }
        if (empty($website_head)) {
            return Result::error("暂无头部基础信息",0);
        }
        $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'])) {
            $fcatid = WebsiteCategory::where('website_id',$data['website_id'])->where('category_id',$data['catid'])->first();
            if (empty($fcatid)) {
                return Result::error("导航id错误",0);
            }
            $result = Category::where('id',$data['catid'])->first();
        }
        if (empty($result)) {
            return Result::error("暂无导航",0);
        }
        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); 
            }
            $result = WebsiteCategory::where('website_id',$data['website_id'])->where('category_id',$data['category_id'])->select('category_id','alias')->first();
            // return Result::success($category);
            if (empty($result)) {
                return Result::error("暂无此导航",0); 
            }            
            // department_id
        }else{
            return Result::error("参数错误",0);
        }
        return Result::success($result);
    }
}