public_producer/app/JsonRpc/PublicRpcService.php

<?php

namespace App\JsonRpc;

use _PHPStan_62c6a0a8b\OndraM\CiDetector\Env;
use App\Model\BlackWord;
use App\Model\Department;
use App\Model\District;
use App\Model\LetterOfComplaint;
use App\Model\LetterType;
use App\Model\LevelUser;
use App\Model\UserLevel;
use App\Tools\Result;
use Hyperf\DbConnection\Db;
use Hyperf\Di\Annotation\Inject;
use Hyperf\RpcServer\Annotation\RpcService;
use App\Service\MinioService;
use Hyperf\Redis\Redis;
use Overtrue\ChineseCalendar\Calendar;

use App\Model\TemplateClass;
use App\Model\Template;
use App\Model\WebsiteTemplate;
use App\Model\WebsiteTemplateInfo;
use App\Model\Sector;
use App\Model\Component;
use App\Model\Link;
use App\Model\FooterCategory;
use App\Model\Size;

use function Hyperf\Support\retry;
use Hyperf\Paginator\Paginator;
use App\Model\User;
use App\Model\Website;
use App\Constants\ErrorCode;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;
use App\Model\SectorPlace;
use App\Model\ComponentType;
use App\Model\Article;
use App\Model\WebsiteCategory;
use App\Model\AdPlace;
use App\Model\WebsiteImg;

#[RpcService(name: "PublicRpcService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
class PublicRpcService implements PublicRpcServiceInterface
{
    #[Inject]
    protected Redis $redis;

    /**
     * @param array $data
     * @return array
     */
    public function getDistrictList(array $data): array
    {
        $where = [];
        if (isset($data['keyWord'])) {
            $where = [
                ['name', 'like', '%' . $data['keyWord'] . '%']
            ];
        }
        $result  = [];
        if (isset($data['pageSize'])) {
            $rep = District::where($where)->limit($data['pageSize'])->offset(($data['page'] - 1) * $data['pageSize'])->orderBy("code", "asc")->get();
            $count = District::where($where)->count();
            $result = [
                'rows' => $rep,
                'count' => $count

            ];
        } else {
            $result = District::where($data)->orderBy("code", "asc")->get();
        }
        return $result ? Result::success($result) : Result::error("没有查到数据");
    }

    /**
     * @param array $data
     * @return array
     */
    public function getUserLevelList(array $data): array
    {
        $where = [];
        if (isset($data['keyWord'])) {
            $where = [
                ['name', 'like', '%' . $data['keyWord'] . '%'],
            ];
        }
        $result = [];
        if (isset($data['pageSize'])) {
            $rep = UserLevel::where($where)->limit($data['pageSize'])->offset(($data['page'] - 1) * $data['pageSize'])->orderBy("id", "asc")->get();
            $count = UserLevel::where($where)->count();
            $result = [
                'rows' => $rep,
                'count' => $count,
            ];
        } else {
            $result = UserLevel::orderBy("id", "asc")->get();
        }
        return $result ? Result::success($result) : Result::error("没有查到数据");
    }

    /**
     * 添加用户等级
     * @param array $data
     * @return array
     */
    public function addUserLevel(array $data): array
    {
        LevelUser::insertGetId($data);
        return Result::success([]);
    }
    /**
     * 更新等级
     * @param array $data
     * @return array
     */
    public function updateUserLevel(array $data): array
    {

        $result = LevelUser::where(['id' => $data['id']])->update($data);
        if ($result) {
            return Result::success($result);
        }
        return Result::error("更新失败");
    }

    /**
     * 删除等级
     * @param array $data
     * @return array
     */
    public function delUserLevel(array $data): array
    {

        $result = LevelUser::where(['id' => $data['id']])->delete();
        if ($result) {
            return Result::success($result);
        }
        return Result::error("删除失败");
    }

    /**
     * 查询投诉举报信息
     * @param array $data
     * @return array
     */
    public function getLetterOfComplaint(array $data = []): array
    {
        var_dump("====");
        $where = [];

        if (isset($data['user_id']) && !empty($data['user_id'])) {
            array_push($where, ['letter_of_complaint.user_id', '=', $data['user_id']]);
        }
        if (isset($data['nature']) && !empty($data['nature'])) {
            array_push($where, ['letter_of_complaint.nature', '=', $data['nature']]);
        }

        if (isset($data['nature_level0']) && !empty($data['nature_level0'])) {
            array_push($where, ['letter_of_complaint.nature_level0', '=', $data['nature_level0']]);
        }

        if (isset($data['status']) && !empty($data['status'])) {
            array_push($where, ['letter_of_complaint.status', '=', $data['status']]);
        }
        $result = [];
        if (isset($data['pageSize'])) {
            $rep = LetterOfComplaint::where($where)
                ->leftJoin("letter_type as type_a", "letter_of_complaint.nature", "type_a.id")
                ->leftJoin("letter_type as type_c", "letter_of_complaint.nature_level0", "type_c.id")
                ->leftJoin("letter_type as type_b", "letter_of_complaint.nature_level1", "type_b.id")
                ->leftJoin("letter_type as type_e", "letter_of_complaint.nature_level3", "type_e.id")
                ->leftJoin("letter_type as type_d", "letter_of_complaint.status", "type_d.id")

                ->select(
                    "letter_of_complaint.*",
                    "type_a.type_name as nature_name",
                    "type_b.type_name as nature_name1",
                    "type_c.type_name as nature_name0",
                    "type_d.type_name as status_name",
                    "type_e.type_name as nature_name3"
                )
                ->limit($data['pageSize'])->offset(($data['page'] - 1) * $data['pageSize'])->orderBy("letter_of_complaint.id", "desc")->get();
            $count = LetterOfComplaint::where($where)->count();
            if ($rep) {
                foreach ($rep as $val) {
                    if ($val['judgment']) {
                        $val['judgment'] = json_decode($val['judgment']);
                    }
                    if ($val['audio_and_video']) {
                        $val['audio_and_video'] = json_decode($val['audio_and_video']);
                    }
                    if ($val['contract']) {
                        $val['contract'] = json_decode($val['contract']);
                    }
                    if ($val['qualifications']) {
                        $val['qualifications'] = json_decode($val['qualifications']);
                    }
                }
            }
            $result = [
                'rows' => $rep,
                'count' => $count,
            ];
        } else {
            $result = LetterOfComplaint::where($where)
                ->leftJoin("letter_type as type_a", "letter_of_complaint.nature", "type_a.id")
                ->leftJoin("letter_type as type_c", "letter_of_complaint.nature_level0", "type_c.id")
                ->leftJoin("letter_type as type_b", "letter_of_complaint.nature_level1", "type_b.id")
                ->leftJoin("letter_type as type_e", "letter_of_complaint.nature_level3", "type_e.id")
                ->leftJoin("letter_type as type_d", "letter_of_complaint.status", "type_d.id")

                ->select(
                    "letter_of_complaint.*",
                    "type_a.type_name as nature_name",
                    "type_b.type_name as nature_name1",
                    "type_c.type_name as nature_name0",
                    "type_d.type_name as status_name",
                    "type_e.type_name as nature_name3"
                )
                ->orderBy("letter_of_complaint.id", "desc")->get();
        }
        return $result ? Result::success($result) : Result::error("没有查到数据");
    }

    /**
     * 添加投诉举报信息
     * @param array $data
     * @return array
     */
    public function addLetterOfComplaint(array $data): array
    {
        $data['judgment'] = $data['judgment'] ? json_encode($data['judgment']) : '';
        $data['audio_and_video'] = $data['audio_and_video'] ? json_encode($data['audio_and_video']) : '';
        $data['contract'] = $data['contract'] ? json_encode($data['contract']) : '';
        $data['qualifications'] = $data['qualifications'] ? json_encode($data['qualifications']) : '';
        unset($data['id']);
        $result = LetterOfComplaint::insertGetId($data);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }

    /**
     * 用户端更新投诉举报
     * @param array $data
     * @return array
     */
    public function userUpLetterOfComplaint(array $data): array
    {
        $data['judgment'] = $data['judgment'] ? json_encode($data['judgment']) : '';
        $data['audio_and_video'] = $data['audio_and_video'] ? json_encode($data['audio_and_video']) : '';
        $data['contract'] = $data['contract'] ? json_encode($data['contract']) : '';
        $data['qualifications'] = $data['qualifications'] ? json_encode($data['qualifications']) : '';
        $result = LetterOfComplaint::where(['id' => $data['id']])->update($data);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }
    /**
     * 管理后台更新投诉举报信息
     * @param array $data
     * @return array
     */
    public function upLetterOfComplaint(array $data): array
    {
        var_dump("admin:", $data);
        $where = [
            'id' => $data['id'],
        ];

        $filtered_array = array_filter($data, function ($value) {
            return $value !== "" && $value !== null && $value !== false && !is_array($value) || !empty($value);
        });
        $filtered_array['judgment'] = isset($filtered_array['judgment']) ? json_encode($filtered_array['judgment']) : '';
        $filtered_array['audio_and_video'] = isset($filtered_array['audio_and_video']) ? json_encode($filtered_array['audio_and_video']) : '';
        $filtered_array['contract'] = isset($filtered_array['contract']) ? json_encode($filtered_array['contract']) : '';
        $filtered_array['qualifications'] = isset($filtered_array['qualifications']) ? json_encode($filtered_array['qualifications']) : '';
        unset($filtered_array['nature_name']);
        unset($filtered_array['type_name']);
        unset($filtered_array['nature_level_name']);
        unset($filtered_array['status_name']);
        unset($filtered_array['is_admin']);
        unset($filtered_array['type_level_name']);
        $result = LetterOfComplaint::where($where)->update($filtered_array);
        if ($result) {
            return Result::success($result);
        }
        return Result::error("更新失败", 0);
    }

    /**
     * 查询投诉举报记录
     * @param array $data
     * @return array
     */
    public function getLetterOfComplaintInfo(array $data): array
    {
        $where = [
            'letter_of_complaint.id' => $data['id'],
        ];
        if (isset($data['user_id']) && !empty($data['user_id'])) {
            array_push($where, ['letter_of_complaint.user_id', '=', $data['user_id']]);
        }
        $result = LetterOfComplaint::where($where)
            ->leftJoin("letter_type as type_a", "letter_of_complaint.nature", "type_a.id")
            ->leftJoin("letter_type as type_c", "letter_of_complaint.nature_level0", "type_c.id")
            ->leftJoin("letter_type as type_b", "letter_of_complaint.nature_level1", "type_b.id")
            ->leftJoin("letter_type as type_e", "letter_of_complaint.nature_level3", "type_e.id")
            ->leftJoin("letter_type as type_d", "letter_of_complaint.status", "type_d.id")

            ->select(
                "letter_of_complaint.*",
                "type_a.type_name as nature_name",
                "type_b.type_name as nature_name1",
                "type_c.type_name as nature_name0",
                "type_d.type_name as status_name",
                "type_e.type_name as nature_name3"
            )
            ->first();
        return Result::success($result);
    }

    /**
     * 删除投诉举报信息
     * @param array $data
     * @return array
     */
    public function delLetterOfComplaint(array $data): array
    {
        $result = LetterOfComplaint::when($data, function ($query) use ($data) {
            if (isset($data['id']) && !empty($data['id'])) {
                $query->where(['id' => $data['id']]);
            }
            if (isset($data['user_id']) && !empty($data['user_id'])) {
                $query->where(['user_id' => $data['user_id']]);
            }
        })->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }
    /**
     * 获取举报信息类型
     * @param array $data
     * @return array
     */
    public function getLetterType(array $data): array
    {
        $where = [];
        if (isset($data['type'])) {
            array_push($where, ['type', '=', $data['type']]);
        }
        if (isset($data['pid']) && $data['pid'] > 0) {
            array_push($where, ['pid', '=', $data['pid']]);
        }
        $result = LetterType::where($where)->orderBy('sort', 'asc')->get();
        return $result ? Result::success($result) : Result::error("没有查到数据");
    }
    /**
     * 更新举报类型
     * @param array $data
     * @return array
     */
    public function upLetterType(array $data): array
    {
        return [];
    }

    /**
     * 添加举报类型
     * @param array $data
     * @return array
     */
    public function addLetterType(array $data): array
    {
        $result = LetterType::insertGetId($data);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }

    /**
     * 删除举报类型
     * @param array $data
     * @return array
     */
    public function delLetterType(array $data): array
    {
        $result = LetterType::where('id', $data['id'])->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }

    /**
     * 检测是否已经被接案
     * @param array $data
     * @return array
     */
    public function checkMeasure(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $letterOfComplaintInfo = LetterOfComplaint::where($where)->first();
        var_dump("查询数据：", $letterOfComplaintInfo['admin_id'], $data['user_id']);
        //操作人和当前登陆用户id 相等说明是当前人接收的案件
        if (($letterOfComplaintInfo['admin_id'] == $data['user_id']) || empty($letterOfComplaintInfo['admin_id'])) {
            return Result::success();
        } else {
            return Result::error("您不能处理其他人已经接过的案件", 0);
        }
    }

    /**
     * 后台获取职能部门
     * @param array $data
     * @return array
     */
    public function getZhinengbumenList(array $data): array
    {

        // 获取分页参数，默认每页 10 条记录
        $page = isset($data['page']) ? (int) $data['page'] : 1;
        $perPage = isset($data['pagesize']) ? (int) $data['pagesize'] : 10;

        // 查询数据并分页
        $query = Department::query();

        // 可以在这里添加更多的查询条件
        if (isset($data['search'])) {
            $query->where('name', 'like', '%' . $data['search'] . '%');
        }

        // 执行分页查询
        $result = $query->paginate($perPage, ['*'], 'page', $page);

        // 返回分页结果
        return Result::success([
            'count' => $result->total(),
            'current_page' => $result->currentPage(),
            'last_page' => $result->lastPage(),
            'pagesize' => $result->perPage(),
            'rows' => $result->items(),
        ]);
    }

    /**
     * 添加获取职能部门
     * @param array $data
     * @return array
     */
    public function addZhinengbumen(array $data): array
    {
        $result = Department::insertGetId($data);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success(["id" => $result]);
        }
    }
    public function delZhinengbumen(array $data): array
    {
        $result = Department::where('id', $data['id'])->delete();
        if (empty($result)) {
            return Result::error("删除失败", 0);
        } else {
            return Result::success();
        }
    }
    public function getZhinengbumen(array $data): array
    {
        $result = Department::where('id', $data['id'])
            ->orderBy('department', 'desc')
            ->first();
        return Result::success($result);
    }
    public function getPidZhinengbumen(array $data): array
    {
        if (empty($data['pid'])) {
            $data['pid'] = 0;
        }

        $result = Department::where('pid', $data['pid'])->get();
        return Result::success($result);
    }
    public function modZhinengbumen(array $data): array
    {
        $result = Department::where('id', $data['id'])->update($data);
        if (empty($result)) {
            return Result::error("修改失败", 0);
        } else {
            return Result::success();
        }
    }


    /**
     * 查询职能列表
     * @param array $data
     * @return array
     */
    public function getDepartment(array $data): array
    {
        $where = [];
        if (isset($data['pid'])) {
            $where  = [
                'pid' => $data['pid'] ?? 0
            ];
        }
        $result = Department::when(!empty($where), function ($query) use ($where) {
            $query->where($where);
        })->orderBy("sort", "desc")->get();
        if (empty($result)) {
            return Result::error("查询失败", 0);
        } else {
            return Result::success($result);
        }
    }

    /**
     * 获取所有的buckets
     * @param array $data
     * @return array
     */
    public function getBuckets(array $data): array
    {
        $result = new MinioService();
        // 调用服务层的方法获取存储桶列表
        $bucketsResponse = $result->listBuckets();
        // 直接返回服务层生成的响应
        return Result::success($bucketsResponse['data']);
    }

    /**
     * 上传文件
     * @param array $data
     * @return array
     */
    public function uploadFile(array $data): array
    {
        $result = new MinioService();
        $rep = $result->uploadFile($data);
        if ($rep['code'] == 200) {
            return Result::success($rep['data']);
        } else {
            return Result::error("上传失败！");
        }
    }

    /**
     * 黑名单管理
     * @param array $data
     * @return array
     */
    public function getBlackWordList(array $data): array
    {
        $result = BlackWord::when($data, function ($query) use ($data) {
            if (isset($data['name']) && $data['name']) {
                $query->where('black_word.name', 'like', '%' . $data['name'] . '%');
            }
        })->orderBy('black_word.id', 'desc')
            ->paginate(
                intval($data['pageSize']),
                [
                    'black_word.*',
                ],
                'page',
                intval($data['page'])
            );
        $count = $result->total();
        $returnData = [
            'rows' => $result->items(),
            'count' => $count
        ];
        return Result::success($returnData);
    }

    /**
     * 添加黑名单
     * @param array $data
     * @return array
     */
    public function addBlackWord(array $data): array
    {
        Db::beginTransaction();
        try {
            $info = BlackWord::where(['name' => $data['name']])->first();
            if ($info) {
                Db::rollBack();
                return  Result::error("该黑名单已存在", 0);
            }
            $data['type'] = 10;
            $result = BlackWord::insertGetId($data);
            $redisKey = 'black_word';
            $this->redis->sAdd($redisKey, $data['name']);
            Db::commit();
            return Result::success(["id" => $result]);
        } catch (\Exception $e) {
            Db::rollBack();
            return Result::error("创建失败" . $e->getMessage(), 0);
        }
    }
    /**
     * 删除黑名单
     * @param array $data
     * @return array
     */
    public function delBlackWord(array $data): array
    {
        Db::beginTransaction();
        try {
            BlackWord::where(['name' => $data['name']])->delete();
            $redisKey = 'black_word';
            $this->redis->sRem($redisKey, $data['name']);
            Db::commit();
            return Result::success([]);
        } catch (\Exception $e) {
            Db::rollBack();
            return Result::error("删除失败" . $e->getMessage(), 0);
        }
    }

    /**
     * 修改违禁词
     * @param array $data
     * @return array
     */
    public function upBlackWord(array $data): array
    {
        Db::beginTransaction();
        try {
            $checkInfo = BlackWord::where(['name' => $data['name']])->first();
            if ($checkInfo) {
                Db::rollBack();
                return Result::error("该违禁词已经存在", 0);
            }
            $blackWordInfo = BlackWord::where(['id' => $data['id']])->first();
            if ($blackWordInfo) {
                //先删除redis
                $blackWordInfo = $blackWordInfo->toArray();
                $redisKey = 'black_word';
                $this->redis->sRem($redisKey, $blackWordInfo['name']);
                $this->redis->sAdd($redisKey, $data['name']);
                BlackWord::where(['id' => $data['id']])->update(['name' => $data['name']]);
                Db::commit();
                return Result::success([]);
            } else {
                Db::rollBack();
                return Result::error("系统错误", 0);
            }
        } catch (\Exception $e) {
            Db::rollBack();
            return Result::error("修改失败" . $e->getMessage(), 0);
        }
    }
    /**
     * 获取风格
     * @return void
     */
    public function getTemplateClassList(array $data): array
    {
        $where = [];
        if (isset($data['name']) && $data['name']) {
            array_push($where, ['template_class.name', 'like', '%' . $data['name'] . '%']);
        }
        if (isset($data['keyword']) && $data['keyword']) {
            array_push($where, ['template_class.keyword', 'like', '%' . $data['keyword'] . '%']);
        }
        $template = TemplateClass::when($where, function ($query) use ($where) {
            $query->where($where);
        });
        $count = $template->count();
        // $countQuery = clone $template;
        $row = $template
            ->leftJoin('template', function ($join) {
                $join->on('template_class.class_id', '=', 'template.template_class_id');
            })
            ->select('template_class.*', DB::raw('COUNT(template.template_class_id) as template_count'))
            ->groupBy('template_class.id')
            ->orderBy('template_class.id', 'desc')
            ->offset(($data['page'] - 1) * $data['pageSize'])
            ->limit($data['pageSize'])
            ->get();

        $result = [
            'rows' => $row,
            'count' => $count,
        ];

        if ($row->isEmpty()) {
            return Result::error("暂无风格", 0);
        } else {
            return Result::success($result);
        }
    }

    /**
     * 添加风格
     * @param
     * @return void
     */
    public function addTemplateClass(array $data): array
    {
        $data['keyword'] = json_encode($data['keyword']);
        $template_class = TemplateClass::where('name', $data['name'])
            ->orWhere('class_id', $data['class_id'])
            ->first();
        if ($template_class) {
            return Result::error("风格名称或者风格编号已存在，不可添加！", 0);
        }
        $result = TemplateClass::insertGetId($data);
        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'],
        ];
        $template_class = TemplateClass::where($where)->first();
        if (empty($template_class)) {
            return Result::error("未查询到风格", 0);
        }
        if ($template_class->type == 1) {
            return Result::error("默认风格不能修改", 0);
        }
        $template = TemplateClass::where('id', '!=', $data['id'])
            // ->where(['name' => $data['name']])
            // ->orWhere(['class_id' => $data['class_id']])
            ->where(function ($query) use ($data) {
                $query->where('name', $data['name'])
                    ->orWhere('class_id', $data['class_id']);
            })
            ->first();
        if ($template) {
            return Result::error("风格名称或者风格编号已存在，不可编辑！", 0);
        }
        $updateData = [
            'name' => $data['name'],
            'keyword' => json_encode($data['keyword']),
            'class_id' => $data['class_id'],
        ];
        $result = TemplateClass::where($where)->update($updateData);
        if (empty($result)) {
            return Result::error("更新失败", 0);
        } else {
            return Result::success($result);
        }
    }

    /**
     * 删除风格
     * @param array $data
     * @return array
     */
    public function delTemplateClass(array $data): array
    {
        $where = [
            'id' => $data['id'],
        ];
        $template_class = TemplateClass::where($where)->first();
        if (empty($template_class)) {
            return Result::error("未查询到风格", 0);
        }
        if ($template_class->type == 1) {
            return Result::error("默认风格不能删除", 0);
        }
        $template = Template::where('template_class_id', $template_class['class_id'])->get();
        if (!empty($template->all())) {
            try {
                // 默认风格   1
                Db::beginTransaction();
                $template = Template::where('template_class_id', $template['class_id'])->update(['template_class_id' => 1]);

                if (empty($template)) {
                    Db::rollBack();
                    return Result::error("删除失败", 0);
                }
                $result = TemplateClass::where($where)->delete();
            } catch (\Exception $e) {
                return Result::error("删除失败" . $e->getMessage(), 0);
            }
        } else {
            $result = TemplateClass::where('id', $data['id'])->delete();
        }
        if (empty($result)) {
            return Result::error("删除失败", 0);
        }

        return Result::success($result);
    }
    /**
     * 根据风格名称-获取获取所有风格
     * @param array $data
     * @return array
     */
    public function getTemplateClass(array $data): array
    {
        $where = [];
        if (!empty($data['template_name'])) {
            $where['name'] = $data['template_name'];
        }
        $result = TemplateClass::where($where)->get();
        if (empty($result)) {
            return Result::error("暂无风格", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取皮肤列表
     * @param array $data
     * @return array
     */
    public function getTemplateList(array $data): array
    {
        $where = [];
        if (!empty($data['template_class_id'])) {
            $where['template_class_id'] = $data['template_class_id'];
        }
        if (!empty($data['template_name'])) {
            array_push($where, ['template_name', 'like', '%' . $data['template_name'] . '%']);
        }
        if (!empty($data['template_keyword'])) {
            array_push($where, ['template_keyword', 'like', '%' . $data['template_keyword'] . '%']);
        }
        $result = Template::where($where)
            ->leftJoin('template_class', 'template.template_class_id', 'template_class.class_id')
            ->select('template.*', 'template_class.name as template_class_name')
            ->orderBy('template.id', 'desc')
            ->paginate($data['page_size'], ['*'], 'mypage_name', $data['page']);
        if (empty($result)) {
            return Result::error("暂无皮肤", 0);
        }
        return Result::success($result);
    }
    public function getTemplateInfo(array $data): array
    {
        $result = Template::where('template.id', $data['id'])
            ->leftJoin('template_class', 'template.template_class_id', 'template_class.class_id')
            ->select('template.*', 'template_class.name as template_class_name')
            ->first();
        if (empty($result)) {
            return Result::error("暂无皮肤", 0);
        }
        return Result::success($result);
    }
    /**
     * 添加皮肤
     * @param array $data
     * @return array
     */
    public function addTemplate(array $data): array
    {
        var_dump($data);
        unset($data['user_id']);
        $template = Template::where('template_name', $data['template_name'])
            ->orWhere('template_id', $data['template_id'])
            ->first();
        if ($template) {
            return Result::error("皮肤名称或者皮肤编号已存在，不可添加！", 0);
        }
        $data['template_keyword'] = json_encode($data['template_keyword']) ?? '';
        $page_type = json_decode($data['page_type'], true);
        $data['page_type'] = json_encode(array_values(array_unique($page_type)));
        $result = Template::insertGetId($data);
        if (empty($result)) {
            return Result::error("创建失败", 0);
        } else {
            return Result::success($result);
        }
    }
    /**
     * 删除皮肤
     * @param array $data
     * @return array
     */
    public function delTemplate(array $data): array
    {
        $rector = Sector::where('template_id', $data['id'])->first();
        if (!empty($rector)) {
            return Result::error("此皮肤已被绑定通栏，不可删除", 0);
        }
        $template = WebsiteTemplateInfo::where('template_id', $data['id'])->first();
        if (empty($template)) {
            return Result::error("此皮肤已被绑定网站，不可删除", 0);
        }
        if ($template->type == 1) {
            return Result::error("默认皮肤不能删除", 0);
        }
        $result = Template::where('id', $data['id'])->delete();
        var_dump($result, '-------------------delete');
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error("删除失败", 0);
        }
    }
    /**
     * 更新皮肤
     * @param array $data
     * @return array
     */
    public function updateTemplate(array $data): array
    {
        unset($data['user_id']);
        $template = Template::where('id', $data['id'])
            ->first();
        if (empty($template)) {
            return Result::error("此皮肤不存在！", 0);
        }
        $template = Template::where('id', '!=', $data['id'])
            ->where(function ($query) use ($data) {
                $query->where('template_name', $data['template_name'])
                    ->orWhere('template_id', $data['template_id']);
            })
            ->first();
        if ($template) {
            return Result::error("皮肤名称或者皮肤编号已存在，不可编辑！", 0);
        }
        $data['template_keyword'] = json_encode($data['template_keyword']) ?? '';
        $page_type = json_decode($data['page_type'], true);
        $data['page_type'] = json_encode(array_values(array_unique($page_type)));
        $result = Template::where('id', $data['id'])->update($data);
        var_dump($result, '-------------------update');
        if (!$result) {
            return Result::error("更新失败", 0);
        } else {
            return Result::success('更新成功');
        }
    }
    /**
     * 获取所有尺寸
     * @param array $data
     * @return array
     */
    public function getAllSize(array $data): array
    {
        if(isset($data['id']) && !empty($data['id'])){
            $result = Size::where('id', $data['id'])->get()->all();
        }else{
            $result = Size::get()->all();
        }
        if(empty($result)){
            return Result::error("暂无尺寸", 0);
        }
        return Result::success($result);
    }
    /**
     * 根据皮肤名称-获取所有皮肤
     * @param array $data
     * @return array
     */
    public function getAllTemplate(array $data): array
    {
        $where = [];
        if (isset($data['template_class_id']) && !empty($data['template_class_id'])) {
            $where[] = ['template_class_id', $data['template_class_id']];
        }
        if (isset($data['template_name']) && !empty($data['template_name'])) {
            $where[] = ['template_name', 'like', '%' . $data['template_name'] . '%'];
        }
        $result = Template::where($where)->get()->all();
        if (empty($result)) {
            return Result::error("暂无皮肤", 0);
        }
        return Result::success($result);
    }
    /**
     * 获取通栏列表
     * @param array $data
     * @return array
     */
    public function getSectorList(array $data): array
    {
        $where = [];
        if (isset($data['template_class_id']) && !empty($data['template_class_id'])) {
            $where['template.template_class_id'] = $data['template_class_id'];
        }
        if (isset($data['template_id']) && !empty($data['template_id'])) {
            array_push($where, ['template.template_id', $data['template_id']]);
        }
        if (isset($data['sector_name']) && !empty($data['sector_name'])) {
            array_push($where, ['sector.sector_name', 'like', '%' . $data['sector_name'] . '%']);
        }
        if (isset($data['width']) && !empty($data['width']) && isset($data['height']) && !empty($data['height'])) {
            $size_id = Size::where('width', 'like', '%' . $data['width'] . '%')->where('height', 'like', '%' . $data['height'] . '%')->pluck('id');
        } else if (isset($data['width']) && !empty($data['width'])) {
            $size_id = Size::where('width', 'like', '%' . $data['width'] . '%')->pluck('id');
        } else if (isset($data['height']) && !empty($data['height'])) {
            $size_id = Size::where('height', 'like', '%' . $data['height'] . '%')->pluck('id');
        } else {
            $size_id = [];
        }
        if(isset($data['page_type']) && !empty($data['page_type'])){
             array_push($where, ['sector.page_type', 'like', '%' . $data['page_type'] . '%']);
        }
        $result = Sector::when(!empty($size_id), function ($query) use ($size_id) {
                $query->whereIn('sector.size_id', $size_id);
            })
            ->leftJoin('size', 'size.id', '=', 'sector.size_id')
            ->leftJoin('template', 'template.template_id', '=', 'sector.template_id')
            ->leftJoin('template_class', 'template_class.class_id', '=', 'template.template_class_id') 
            ->leftJoin('sector_place', 'sector_place.sector_type', '=', 'sector.place_type')
            ->where($where)
            ->where('sector_place.type_id', 1)
            ->select('sector.*', 'size.width', 'size.height', 'template_class.name as class_name', 'template_class.class_id', 'template.template_name',
                     'sector_place.name as place_name', 'sector_place.sector_img as place_img')
            ->orderBy('sector.id', 'desc')
            ->paginate($data['page_size'], ['*'], 'page', $data['page']);
        if(empty($result)){
            return Result::error('暂无通栏！');
        }
        return Result::success($result);
    }
    /**
     * 获取通栏详情
     * @param array $data
     * @return array
     */

    public function getSectorInfo(array $data): array
    {
        $where = [];
        $where[] = ['sector.id', '=', $data['id']];
        $result = Sector::where($where)
            ->leftJoin('size', 'size.id', '=', 'sector.size_id')
            ->select('sector.*', 'size.width', 'size.height')
            ->orderBy('sector.id', 'desc')
            ->first();
        if (empty($result)) {
            return Result::error('此通栏不存在！');
        }
        return Result::success($result);
    }

    /**
     * 获取经纬度信息
     * @return void
     */
    public function getIpInfo(array $data): array
    {
        if (empty($data['ip'])) {
            // 在RPC服务中，依赖$_SERVER是不可靠的，强制要求调用方传入IP
            return Result::error('IP地址不能为空！');
        }
        $client_ip = $data['ip'];

        try {
            // 直接从容器获取 Guzzle 客户端实例
            /** @var \GuzzleHttp\Client $client */
            $client = \Hyperf\Context\ApplicationContext::getContainer()->get(Client::class);

            // 使用新的 GeoJS API 地址
            $api_url = "https://get.geojs.io/v1/ip/geo/{$client_ip}.json";
            // 将 timeout 作为请求选项传递
            $response = $client->get($api_url, ['timeout' => 5]);

            if ($response->getStatusCode() !== 200) {
                return Result::error('IP查询接口请求失败，状态码：' . $response->getStatusCode());
            }

            $ip_info = json_decode($response->getBody()->getContents(), true);

            // GeoJS 的成功响应不包含 'status' 字段，直接检查关键数据是否存在
            if ($ip_info && isset($ip_info['latitude']) && isset($ip_info['longitude'])) {
                // GeoJS 返回的经纬度是字符串，转换为浮点数
                $ip_info['latitude'] = floatval($ip_info['latitude']);
                $ip_info['longitude'] = floatval($ip_info['longitude']);
                return Result::success($ip_info);
            }

            // 如果返回的数据不符合预期，提供一个通用错误
            $errorMessage = $ip_info['message'] ?? '获取IP地理位置信息失败';
            return Result::error($errorMessage);
        } catch (GuzzleException $e) {
            // 这个异常会给出详细的网络错误信息，如超时、无法解析域名等
            return Result::error('请求IP查询接口异常: ' . $e->getMessage());
        } catch (\Throwable $e) {
            return Result::error('获取IP信息时发生未知错误: ' . $e->getMessage());
        }
    }

    /**
     * 获取天气
     * @param array $data
     * @return array
     */
    public function getWeatherInfo(array $data): array
    {
        $month = $data['month'] ?? date('m');
        $day = $data['day'] ?? date('d');
        // 使用缓存键
        $cacheKey = "tsbb_data_weather_{$month}_{$day}";

        // 尝试从缓存获取数据
        $container = \Hyperf\Context\ApplicationContext::getContainer();
        $cache = $container->get(\Psr\SimpleCache\CacheInterface::class);
        if ($cachedData = $cache->get($cacheKey)) {
            return Result::success(unserialize($cachedData));
        }
        $location = $data['latitude'] . ":" . $data['longitude'];
        $api_url = "https://api.seniverse.com/v3/weather/now.json?key=" . \Hyperf\Support\env('WEATHER_KEY') . "&location=" . $location . "&language=zh-Hans&unit=c";
        $ch = curl_init($api_url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        $response = curl_exec($ch);
        curl_close($ch);
        // 解析 JSON 响应
        $WeatherInfo = json_decode($response, true);
        // 缓存结果，设置1小时过期
        $cache->set($cacheKey, serialize($WeatherInfo), 3600);
        if ($WeatherInfo) {
            return Result::success($WeatherInfo);
        } else {
            return Result::error("获取天气失败", 0);
        }
    }

    /**
     * 获取农历信息
     * @return void
     */
    public function getCalendar(array $data): array
    {
        $calendar = new Calendar();
        $result = $calendar->solar($data['year'], $data['month'], $data['day'], $data['hour']); // 阳历
        return Result::success($result);
    }
    /**
     * 添加通栏
     * @param array $data
     * @return array
     */
    public function addSector(array $data): array
    {
        unset($data['user_id']);
        // 对传入的 page_type 数组进行去重、转换为整数并重新索引
        $data['page_type'] = array_values(array_unique(array_map('intval', $data['page_type'])));
        $data['page_type'] = json_encode($data['page_type']);
        $template = Template::where('template_id', $data['template_id'])
            ->first();
        if (empty($template)) {
            return Result::error('皮肤不存在！');
        }
        $sector_id = Sector::where('sector_id',$data['sector_id'])->first();
        if(!empty($sector_id)){
            return Result::error('通栏编号已存在！');
        }
        $data['status'] = 0;
        // 通栏分类：1：资讯类：2：通栏广告类；3：混合类；4：头条类；5：轮播图类；
        $sector_code = [
            'sectorName' => $data['sector_name'],
            'sectorId' => $data['sector_id'],
            'sectorType' => $data['sector_type'],
            'sectorPlace' => $data['place_type'],
        ];
        // return Result::success($sector_code);
         $data['sector_code'] = json_encode($sector_code);
        $result = Sector::insertGetId($data);
        if (empty($result)) {
            return Result::error('添加失败');
        }
        return Result::success($result);
    }
    /**
     * 删除通栏
     * @param array $data
     * @return array
     */
    public function delSector(array $data): array
    {
        $component_id = Component::where('sector_id', $data['id'])->pluck('id')->toArray();
        if (!empty($component_id)) {
            return Result::error('请先删除相关组件！');
        }
        $result = Sector::where('id', $data['id'])->delete();
        if ($result == 1) {
            return Result::success('删除成功');
        } else {
            return Result::error('删除失败');
        }
    }
    /**
     * 修改通栏
     * @param array $data
     * @return array
     */
    public function updateSector(array $data): array
    {
        unset($data['user_id']);
        $sector = Sector::where('id', $data['id'])->first();
        if (empty($sector)) {
            return Result::error('通栏不存在！');
        }
        if($sector['sector_id'] != $data['sector_id']){
            $sector_id = Sector::where('sector_id',$data['sector_id'])->first();
            if(!empty($sector_id)){
                return Result::error('通栏编号已存在！');
            }
        }
        $sector_code = [
            'sectorName' => strval($data['sector_name']),
            'sectorId' => intval($data['sector_id']),
            'sectorType' => intval($data['sector_type']),
            'sectorPlace' => intval($data['place_type']),
        ];
        // return Result::success($sector_code);
        $data['sector_code'] = json_encode($sector_code);
        // 对传入的 page_type 数组进行去重、转换为整数并重新索引
        $data['page_type'] = array_values(array_unique(array_map('intval', $data['page_type'])));
        $data['page_type'] = json_encode($data['page_type']);
        $template = Template::where('template_id', $data['template_id'])
            ->whereRaw("JSON_CONTAINS(template.page_type, ?)", [$data['page_type']])
            ->first();
        if (empty($template)) {
            return Result::error('皮肤不存在！');
        }
        $result = Sector::where('id', $data['id'])->update($data);
        if ($result == 1) {
            return Result::success('修改成功');
        } else {
            return Result::error('修改失败');
        }
    }
    public function getComponentList(array $data): array
    {
        $where = [];
        if (isset($data['component_name']) && !empty($data['component_name'])) {
            array_push($where, ['component.component_name', 'like', '%' . $data['component_name'] . '%']);
        }
        if (isset($data['width']) && !empty($data['width']) && isset($data['height']) && !empty($data['height'])) {
            array_push($where, ['size.width', 'like', '%' . $data['width'] . '%']);
            array_push($where, ['size.height', 'like', '%' . $data['height'] . '%']);
        } else if (isset($data['width']) && !empty($data['width'])) {
            array_push($where, ['size.width', 'like', '%' . $data['width'] . '%']);
        } else if (isset($data['height']) && !empty($data['height'])) {
            array_push($where, ['size.height', 'like', '%' . $data['height'] . '%']);
        } else {
        }
        if(isset($data['type_id']) && !empty($data['type_id'])){
            $where['component.type_id'] = $data['type_id'];
        }
        $result = Component::where($where)
            ->leftJoin('component_type','component_type.id','=','component.type_id')
            ->select( 'component.*', 'component_type.com_typename')
            ->orderBy('component.updated_at', 'desc')
            ->paginate($data['page_size'], ['*'], 'mypage_name', $data['page']);
        if(empty($result)){
            return Result::error('暂无数据');
        }
        return Result::success($result);
    }
    public function getComponentInfo(array $data): array
    {
        $where = ['component.id'=>$data['id']];

        $result = Component::where($where)
            ->leftJoin('component_type','component_type.id','=','component.type_id')
            ->select(  'component.*','component_type.com_typename')
            ->get();
        if(empty($result)){
            return Result::error('暂无数据');
        }

        return Result::success($result);
    }
    /*
    新增组件
    */
    public function addComponent(array $data): array
    {
        unset($data['user_id']);
        $component_id = Component::where('component_type',$data['component_type'])->first();
        if(!empty($component_id)){
            return Result::error('组件编号已存在！');
        }
        // 组件分类：1：资讯-头条组件；2：资讯-轮播组件；3：资讯-推荐图类组件；4：资讯-最新类组件；5：资讯-推荐类；6：资讯-热点类组件；
        // 7：资讯-栏目类组件；8：列表类组件；9：详情类组件；10：二级导航栏类组件；11：广告类；12：静态资源类；13：底部导航类；
        $data['type_id'] = intval($data['type_id']);
        $add_arr = [
            'template_id' => intval($data['template_id']),
            'component_type' => intval($data['component_type']),
            'component_name' => $data['component_name'],
            'component_img' => $data['component_img'],
            'component_width' => $data['component_width'],
            'component_height' => $data['component_height'],
            'type_id' => intval($data['type_id']),
            'component_keyword' => $data['component_keyword'],
        ];
        switch($data['type_id']){
        //    组件分类：1：资讯-头条组件；2：资讯-轮播组件；3：资讯-推荐图类组件；4：资讯-最新类组件；5：资讯-推荐类；6：资讯-热点类组件；
        //    7：资讯-栏目类组件；8：列表类组件；9：详情类组件；10：二级导航栏类组件；11：广告类；12：静态资源类；13：底部导航类；
        // 14:广告资讯混合类；
            case 1:                         //1：资讯-头条组件；
                 $add_arr['level'] = 1;
            case 2:                         //2：资讯-轮播组件；
                $add_arr['level'] = 2;
            case 3:                         //3：资讯-推荐图类组件；
                $add_arr['level'] = 3;
            case 4:                         //4：资讯-最新类组件；
                $add_arr['level'] = 4;
            case 5:                        //5：资讯-推荐类组件；
                $add_arr['level'] = 5;
            case 6:                        //6：资讯-热点类组件；
                $add_arr['level'] = 6;
            case 14:
                $add_arr['ad_width'] = intval($data['ad_width']);
                $add_arr['ad_height'] = intval($data['ad_height']);
                $add_arr['component_width'] = intval($data['ad_width']);
                $add_arr['component_height'] = intval($data['ad_height']);
                $add_arr['ad_type'] = intval($data['ad_type']);
                $add_arr['ad_img'] = $data['ad_img'];
             case 7:                        //7：资讯-栏目类组件；
                $add_arr['img_num'] = intval($data['img_num']);
                $add_arr['text_num'] = intval($data['text_num']);
                $add_arr['child_imgnum'] = intval($data['child_imgnum'] ?? null);
                $add_arr['child_textnum'] = intval($data['child_textnum'] ?? null);
                $component_data['componentData'] = [
                    'category_id' => '',
                    'level' => $add_arr['level'] ?? '',
                    'imgSize' => $add_arr['img_num'] ?? '',
                    'textSize' => $add_arr['text_num'] ?? '',
                    'child' => [
                        'id' => '',
                        'imgSize' => $add_arr['child_imgnum'] ?? '',
                        'textSize' => $add_arr['child_textnum'] ?? '',
                    ]
                ];
                break;
            case 8:                      //8：列表类组件；
                $add_arr['pageSize'] = intval($data['pageSize']);
                $component_data['componentData'] = [
                    'category_id' => '',
                    'pageType' => [
                        'page' => 1,
                        'pageSize' => $add_arr['pageSize'] ?? '',
                    ]
                ];
                break;
            case 9:                     //9：详情类组件；
                $component_data['componentData'] = [
                    'article_id' => '',
                ];
                break;
            case 10:                     //10：二级导航类组件；
                $component_data['componentData'] = [
                    'fcat_id' => '',
                ];
                break;
            case 13:                     //13：底部导航类；
                $add_arr['cate_place'] = 0;
                $add_arr['pageSize'] = intval($data['pageSize']);
                $component_data['componentData'] = [
                    'pid' => '',
                    'placeid' => 1,
                    'num' => $add_arr['pageSize'],
                ];
                break;
            case 11:                     //11：广告类；
                $add_arr['ad_width'] = intval($data['ad_width']);
                $add_arr['ad_height'] = intval($data['ad_height']);
                $add_arr['component_width'] = intval($data['ad_width']);
                $add_arr['component_height'] = intval($data['ad_height']);
                $add_arr['ad_type'] = intval($data['ad_type']);
                $add_arr['ad_img'] = $data['ad_img'];
                break;

            default:
                break;
        }
        $component_head_code = [
            'component_type' => $add_arr['component_type'],
            'type_id' => $add_arr['type_id'],
            'component_name' => $add_arr['component_name'],
        ];
        if(isset($data['listType']) && !empty($data['listType']) && is_array($data['listType'])){
            $list_type['listType'] = $data['listType'];
            $add_arr['component_column'] = json_encode($list_type,true);
        }
        if(isset($component_head_code) && !empty($component_head_code) && is_array($component_head_code)){
            $add_arr['component_code'] = json_encode($component_head_code,true);
        }
        if(isset($component_data) && !empty($component_data) && is_array($component_data)){
            $add_arr['component_data'] = json_encode($component_data,true);
        }
        if($data['type_id'] == 11 || $data['type_id'] == 14){
            $ad = [
                'width' => $add_arr['ad_width'],
                'height' => $add_arr['ad_height'],
                'name' => '',
                'price' => '',
                'introduce' => '',
                'website_id' => '',
                'thumb' => $add_arr['ad_img'],
                'typeid' => $add_arr['ad_type'],
                'ad_tag' => '',
            ];
            $add_arr['ad'] = json_encode($ad);
        }
        // return Result::success($add_arr);
            
        $result = Component::insertGetId($add_arr);
        if(empty($result)){ 
            return Result::error('添加失败！');
        }
        return Result::success($result);
    }
    public function delComponent(array $data): array
    {

        $component = Component::where('id', $data['id'])->first();
        if(empty($component)){
            return Result::error('组件不存在！');
        }
        $result = Component::where('id',$data['id'])->delete();
        if(empty($result)){
            return Result::error('删除失败！');
        }
        return Result::success($result);
    }
    public function updateComponent(array $data): array
    {
        unset($data['user_id']);
        $id = $data['id'];
        unset($data['id']);
        $component_id = Component::where('id','!=',$id)->where('component_type',$data['component_type'])->first();
        if(!empty($component_id) || $component_id != null){
            return Result::error('组件编号已存在！');
        }
        // return Result::success($component_id);
        // return Result::success($component_place);
        //    组件分类：1：资讯-头条组件；2：资讯-轮播组件；3：资讯-推荐图类组件；4：资讯-最新类组件；5：资讯-推荐类；6：资讯-热点类组件；
        //    7：资讯-栏目类组件；8：列表类组件；9：详情类组件；10：二级导航栏类组件；11：广告类；12：静态资源类；13：底部导航类；
        $data['type_id'] = intval($data['type_id']);
        $add_arr = [
            'template_id' => intval($data['template_id']),
            'component_type' => intval($data['component_type']),
            'component_name' => $data['component_name'],
            'component_img' => $data['component_img'],
            'component_width' => $data['component_width'],
            'component_height' => $data['component_height'],
            'type_id' => intval($data['type_id']),
            'component_keyword' => $data['component_keyword'],
        ];
        
        switch($data['type_id']){
            case 1:                         //1：资讯-头条组件；
                 $add_arr['level'] = 1;
            case 2:                         //2：资讯-轮播组件；
                $add_arr['level'] = 2;
            case 3:                         //3：资讯-推荐图类组件；
                $add_arr['level'] = 3;
            case 4:                         //4：资讯-最新类组件；
                $add_arr['level'] = 4;
            case 5:                        //5：资讯-推荐类组件；
                $add_arr['level'] = 5;
            case 6:                        //6：资讯-热点类组件；
                $add_arr['level'] = 6;
            case 14:
                $add_arr['ad_width'] = intval($data['ad_width']);
                $add_arr['ad_height'] = intval($data['ad_height']);
                $add_arr['component_width'] = intval($data['ad_width']);
                $add_arr['component_height'] = intval($data['ad_height']);
                $add_arr['ad_type'] = intval($data['ad_type']);
                $add_arr['ad_img'] = $data['ad_img'];
            case 7:                        //7：资讯-栏目类组件；
                $add_arr['img_num'] = intval($data['img_num']);
                $add_arr['text_num'] = intval($data['text_num']);
                $add_arr['child_imgnum'] = intval($data['child_imgnum'] ?? null);
                $add_arr['child_textnum'] = intval($data['child_textnum'] ?? null);
                $component_data['componentData'] = [
                    'category_id' => '',
                    'level' => $add_arr['level'] ?? '',
                    'imgSize' => $add_arr['img_num'] ?? '',
                    'textSize' => $add_arr['text_num'] ?? '',
                    'child' => [
                        'id' => '',
                        'imgSize' => $add_arr['child_imgnum'] ?? '',
                        'textSize' => $add_arr['child_textnum'] ?? '',
                    ]
                ];
                break;
            case 8:                      //8：列表类组件；
                $add_arr['pageSize'] = intval($data['pageSize']);
                $component_data['componentData'] = [
                    'category_id' => '',
                    'pageType' => [
                        'page' => 1,
                        'pageSize' => $add_arr['pageSize'] ?? '',
                    ]
                ];
                break;
            case 9:                     //9：详情类组件；
                $component_data['componentData'] = [
                    'article_id' => '',
                ];
                break;
            case 10:                     //10：二级导航类组件；
                $component_data['componentData'] = [
                    'fcat_id' => '',
                ];
                break;
             case 11:                     //11：广告类；
                $add_arr['ad_width'] = intval($data['ad_width']);
                $add_arr['ad_height'] = intval($data['ad_height']);
                $add_arr['component_width'] = intval($data['ad_width']);
                $add_arr['component_height'] = intval($data['ad_height']);
                $add_arr['ad_type'] = intval($data['ad_type']);
                $add_arr['ad_img'] = $data['ad_img'];
                break;
            case 13:                     //13：底部导航类；
                $add_arr['cate_place'] = 0;
                $add_arr['pageSize'] = intval($data['pageSize']);
                $component_data['componentData'] = [
                    'pid' => '',
                    'placeid' => 1,
                    'num' => $add_arr['pageSize'],
                ];
                break;
            default:
                break;
        }
        $component_head_code = [
            'component_type' => $add_arr['component_type'],
            'type_id' => $add_arr['type_id'],
            'component_name' => $add_arr['component_name'],
        ];
        if(isset($data['listType']) && !empty($data['listType']) && is_array($data['listType'])){
            $list_type['listType'] = $data['listType'];
            $add_arr['component_column'] = json_encode($list_type,true);
        }
        if(isset($component_head_code) && !empty($component_head_code) && is_array($component_head_code)){
            $add_arr['component_code'] = json_encode($component_head_code,true);
        }
        if(isset($component_data) && !empty($component_data) && is_array($component_data)){
            $add_arr['component_data'] = json_encode($component_data,true);
        }
        if($data['type_id'] == 11 || $data['type_id'] == 14){
            $ad = [
                'width' => $add_arr['ad_width'],
                'height' => $add_arr['ad_height'],
                'name' => '',
                'price' => '',
                'introduce' => '',
                'website_id' => '',
                'thumb' => $add_arr['ad_img'],
                'typeid' => $add_arr['ad_type'],
                'ad_tag' => '',
            ];
            $add_arr['ad'] = json_encode($ad);
        }
        $result =  Component::where('id',$id)->update($add_arr);
        if(empty($result)){ 
            Db::rollBack();
            return Result::error('修改失败！');
        }
        return Result::success($result);
    }

    public function getWebsiteTemplateInfo(array $data)
    {
        $where = [];
        if (isset($data['id'])) {
            $where[] = ['id', '=', $data['id']];
        }
        $result = WebsiteTemplateInfo::where($where)
            ->leftJoin('website', 'website_template_info.website_id', '=', 'website.id')
            ->leftJoin('website_template', 'website_template_info.template_id', '=', 'website_template.id')
            ->select('website_template_info.*', 'website.website_name')
            ->get();
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error('暂无数据');
        }
    }
    /**
     * 自助建站----1.获取页面类型回显
     * @param array $data
     * @return array
     */
    public function getWebPageType(array $data): array
    {
        // 1:图片 2：文字 3：底部
        $friend_link = Link::where('website_id', $data['website_id'])->where('type', 3)->get();
        if (empty($friend_link->toArray())) {
            return Result::error('暂无友情链接数据！');
        }
        $footer_category = FooterCategory::where('website_id', $data['website_id'])->get();
        if (empty($footer_category->toArray())) {
            return Result::error('暂无底部导航数据！');
        }
        $page_type = WebsiteTemplateInfo::where('website_id', $data['website_id'])->value('page_type');
        if (empty($page_type)) {
            $page_type = [];
        } else {
            $page_type = json_decode($page_type, true);
        }
        // '网站页面类型（存数组）1:首页 2：分类页 3：列表页 4：详情页 5：搜索页 6：特殊列表 7：特殊详情页
        if (isset($page_type) && in_array(5, $page_type)) {
            $page_type = 1;
        } else {
            $page_type = 0;
        }
        $result = [
            'friend_link' => $friend_link,
            'footer_category' => $footer_category,
            'page_type' => $page_type,
        ];
        return Result::success($result);
    }
    /**
     * 自助建站----2.添加页面类型
     * @param array $data
     * @return array
     */
    public function addWebPageType(array $data): array
    {
        // return Result::success($data);
        // 1:首页 2：频道页 3：列表页 4：详情页 5：搜索页 6：特殊列表 7：特殊详情页'
        if ($data['is_search'] == 1) {
            $page_type = json_encode([1, 2, 3, 4, 5, 6, 7]);
        } else {
            $page_type = json_encode([1, 2, 3, 4, 6, 7]);
        }
        // 0：未构建；1：已填写基础信息；2：已选择模板；    action_id
        $website_template_info = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        // return Result::success($website_template_info);

        // return Result::success(empty($website_template_info));
        if (empty($website_template_info)) {
            $result = WebsiteTemplateInfo::insertGetId(['website_id' => $data['website_id'], 'page_type' => $page_type, 'user_id' => $data['user_id']]);
        } else {
            if ($website_template_info['status'] == 2) {
                return Result::error('网站已应用，不可再次修改！');
            }
            $result = WebsiteTemplateInfo::where('website_id', $data['website_id'])->update(['page_type' => $page_type], ['action_id' => 1, 'user_id' => $data['user_id']]);
        }
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error('添加失败');
        }
    }
    /**
     * 自助建站---流程---3.选择皮肤列表
     * @param array $data
     * @return array
     */
    public function getWebsiteTemplateList(array $data): array
    {
        $where = [];
        if (isset($data['template_class_id']) && $data['template_class_id']) {
            $where[] = ['template_class_id', '=', $data['template_class_id']];
        }
        // 0:未构建 1:未应用 2：已应用   status
        $templste_info = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($templste_info)) {
            return Result::error('请先填写网站基础信息！');
        }
        if ($templste_info['status'] == 2) {
            return Result::error('网站已应用，不可再次修改！');
        }

        if (isset($data['keyword']) && !empty($data['keyword'])) {
            if (is_array($data['keyword'])) {
                // 拼接多个模糊查询条件
                $query = Template::query();
                foreach ($data['keyword'] as $kw) {
                    $escapedKw = addcslashes($kw, '%_'); // 转义通配符
                    $query->WhereRaw("JSON_EXTRACT(template_keyword, '$[*]') LIKE ?", ["%$escapedKw%"]);
                }
            } else {
                $escapedKeyword = addcslashes($data['keyword'], '%_'); // 转义通配符
                $where[] = [DB::raw("JSON_EXTRACT(template_keyword, '$[*]') LIKE ?"), "%$escapedKeyword%"];
            }
        } else {
            $query = Template::where($where);
        }
        $template_id = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first(['template_id', 'page_type']);
        // return Result::success($template_id);
        if (!empty($template_id['page_type']) && $templste_info['page_type'] != '[]' && is_string($templste_info['page_type'])) {
            $template_page = is_string($templste_info['page_type']) ? json_decode($templste_info['page_type'], true) : [];
        } else {
            $template_page = [];
        }
        if (!empty($template_id['template_id'])) {
            $result['template_id'] = $templste_info['template_id'];
        }
        // 确保 $template_page 为有效数据，避免 SQL 注入风险，这里使用参数绑定
        $template_page_str = json_encode($template_page);
        $result['template'] = $query->where($where)
            ->whereRaw("JSON_CONTAINS(template.page_type, ?)", [$template_page_str])
            ->orderBy('updated_at', 'desc')
            ->paginate($data['page_size'], ['*'], 'page', $data['page']);
        if (empty($result['template'])) {
            $result['template'] = Template::orderBy('updated_at', 'desc')
                ->paginate($data['page_size'], ['*'], 'page', $data['page']);
        }
        $template = WebsiteTemplateInfo::where('website_id', $data['website_id'])->value('template_id');
        if ($template) {
            $result['template_id'] = $template;
        } else {
            $result['template_id'] = 0;
        }
        return Result::success($result);
    }
    /**
     * 自助建站---流程---4.选择皮肤
     * @param array $data
     * @return array
     */
    public function chooseWebsiteTemplate(array $data): array
    {
        $website_template_info = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($website_template_info)) {
            return Result::error('请先填写网站基础信息！');
        }
        // 0:未构建 1:未应用 2：已应用   status
        if ($website_template_info['status'] == 2) {
            return Result::error('网站已应用，不可再次修改！');
        }
        $template = Template::where('template_id', $data['template_id'])->first();
        if (empty($template)) {
            return Result::error('未查询到皮肤！');
        }
        // 0：未构建；1：已填写基础信息；2：已选择模板；    action_id
        $web_template = WebsiteTemplateInfo::where('website_id', $data['website_id'])->update(['template_id' => $data['template_id'], 'action_id' => 2]);
        if ($web_template) {
            return Result::success($web_template);
        } else {
            return Result::error('选择皮肤失败！');
        }
    }
    /**
     * 自助建站---流程---5.保存模版
     * @param array $data
     * @return array
     */
    public function saveWebsiteTemplate(array $data): array
    {
        // return Result::success($data);
        $website_template_info = WebsiteTemplateInfo::where('website_id', $data['website_id'])->first();
        if (empty($website_template_info) || empty($website_template_info->template_id) || empty($website_template_info->page_type)) {
            return Result::error('请先填写网站基础信息！');
        }
        // 0:未构建 1:未应用 2：已应用   status
        if ($website_template_info['status'] == 2) {
            return Result::error('网站已应用，不可再次保存！');
        }
        if ($website_template_info['action_id'] != 2) {
            return Result::error('请完成之前的步骤！');
        }
        $template_info = WebsiteTemplate::where('website_id', $data['website_id'])->first();
        // var_dump($data['template_data']);
        try {
            Db::beginTransaction();
            if (empty($template_info)) {
                $template = WebsiteTemplate::insertGetId([
                    'website_id' => $data['website_id'],
                    'template_data' => $data['template_data'],
                    'user_id' => $data['user_id'],
                    'canvas_data' => $data['canvas_data'],
                    'page_type' => $website_template_info['page_type'],
                    'template_id' => $website_template_info['template_id'],
                ]);
            } else {
                $template = WebsiteTemplate::where('website_id', $data['website_id'])->update(
                    [
                        'template_data' => $data['template_data'],
                        'user_id' => $data['user_id'],
                        'canvas_data' => $data['canvas_data'],
                        'page_type' => $website_template_info['page_type'],
                        'template_id' => $website_template_info['template_id'],
                    ]
                );
            }
            if (empty($template)) {
                Db::rollback();
                return Result::error('保存失败！');
            } else {
                $tempalte_info = WebsiteTemplateInfo::where('website_id', $data['website_id'])->update(['status' => 1]);
                if (empty($tempalte_info)) {
                    Db::rollback();
                    return Result::error('保存失败！');
                }
                Db::commit();
            }
        } catch (\Exception $e) {
            return Result::error('模版数据格式错误！');
        }
        return Result::success($template);
    }
    /**
     * 自助建站---流程---6.返显保存的模版
     * @param array $data
     * @return array
     */
    public function getWebsiteTemplate(array $data): array
    {
        $web = Website::where('id', $data['website_id'])->first();
        if (empty($web)) {
            return Result::error('未查询到网站信息！');
        }
        $template = WebsiteTemplate::where('website_id', $data['website_id'])
            ->first(['website_id', 'template_id', 'page_type', 'template_data', 'canvas_data']);
        if (empty($template)) {
            return Result::error('未查询到模版！');
        }
        return Result::success($template);
    }

    /**
     * 通栏版式管理-获取通栏版式列表
     */ 
    public function getSectorPlaceList(array $data): array
    {
        $where['sector_place.type_id'] = $data['type_id'];
        if(isset($data['component_num']) && !empty($data['component_num'])){
            $where['sector_place.component_num'] = $data['component_num'];
        }
        if(isset($data['sector_type']) && !empty($data['sector_type'])){
            $where['sector_place.sector_type'] = $data['sector_type'];
        }
        // if(isset($data['component_type']) && !empty($data['component_type'])){
        //     $where['sector_place.component_type'] = $data['component_type'];
        // }
        if(isset($data['name']) && !empty($data['name'])){
            array_push($where,['sector_place.name', 'like', '%'.$data['name'].'%']);
        } 
        if (isset($data['width']) && !empty($data['width']) && isset($data['height']) && !empty($data['height'])){
            $size_id = Size::where('width','like','%' .$data['width'].'%')->where('height','like','%' .$data['height'].'%')->pluck('id');
        } else if( isset($data['width']) && !empty($data['width'])){
            $size_id = Size::where('width','like','%' .$data['width'].'%')->pluck('id');
        }else if( isset($data['height']) && !empty($data['height'])){
            $size_id = Size::where('height','like','%' .$data['height'].'%')->pluck('id');
        }else{
            $size_id = [];
        }
        $sector_place = SectorPlace::where($where)
            ->when(!empty($size_id), function ($query) use ($size_id) {
                $query->whereIn('sector_place.size_id', $size_id);
            })
            ->leftJoin('size','sector_place.size_id','=','size.id')
            ->select('sector_place.*','size.width','size.height');
        $result['count'] = $sector_place->count();
        $result['row'] =$sector_place->paginate($data['page_size'], ['*'], 'page', $data['page']);
        if(empty($result['count'])){
            return Result::error("暂无相关版式数据！");
        }
        return Result::success($result);
    }
    /**
     * 通栏版式管理-添加通栏版式
     */ 
    public function addSectorPlace(array $data): array
    {
        // 1：通栏；2：组件；
        if($data['type_id'] == 1){
            $sector_place = SectorPlace::where('sector_type', $data['type'])->first(); 
            if(!empty($sector_place)){
                return Result::error('通栏版式类别编号已存在！');
            }
            $data = [
                'name' => $data['name'],
                'component_num' => $data['component_num'], 
                'size_id' => $data['size_id'],
                'sort_id' => 0,
                'sector_img' => $data['sector_img'],
                'sector_type' => $data['type'],
                'type_id' => $data['type_id'],
                'status' => 0,
            ];
        }else{
            $sector_type = SectorPlace::where('sector_type', $data['sector_type'])->where('type_id',1)->first(); 
            if(empty($sector_type)){
                return Result::error('通栏版式类别不存在！');
            }
            // $com_query = SectorPlace::where('type_id',2);
            // ->query(function($query) use ($data){
            //     $query->where('component_type', $data['type'])
            //         ->Subquery(function($subQuery) use ($data) {
            //             $subQuery->where('sector_type', $data['sector_type'])
            //                      ->where('sort_id', $data['sort']);
            //         });
            // })                                                               //若是组件版式编号或者组件版式位置重复用此语句筛选
            // ->where('sector_type',$data['sector_type'])                      //若是组件版式编号在同一个通栏版式下不重复就行，则启用此语句
            $component =  SectorPlace::where('type_id',2)->where('component_type',$data['type'])->first();
            if(!empty($component)){
                return Result::error('组件版式类别编号已存在！');
            }
            // $com_query = clone $com_query;
            $com_num =  SectorPlace::where('type_id',2)->where('sector_type',$data['sector_type'])->count('sort_id');
            // return Result::success($com_num);
            if($sector_type['component_num'] = $com_num){
                $sector = SectorPlace::where('sector_type',$data['sector_type'])->where('type_id',1)->update(['status'=>1]);
                if(empty($sector)){
                    return Result::error('通栏版式状态修改失败！');
                }
            }
            $data = [
                'name' => $data['name'],
                'component_num' => 0, 
                'size_id' => $data['size_id'],
                'sort_id' => $data['sort_id'],
                'sector_img' => $data['sector_img'],
                'component_type' => $data['type'],
                'type_id' => $data['type_id'],
                'sector_type' => $data['sector_type'],
            ];
        }
        
        $result = SectorPlace::insertGetId($data);
        if(empty($result)){
            return Result::error('添加失败！');
        }
        return Result::success('添加成功！',$result);
    }
    /**
     * 通栏版式管理-修改通栏版式
     */ 
    public function upSectorPlace(array $data): array
    {
        $id = $data['id'];
       // 1：通栏；2：组件；
        if($data['type_id'] == 1){
            $sector_place = SectorPlace::where('id','!=',$id)->where('sector_type', $data['type'])->where('type_id',1)->first(); 
            if(!empty($sector_place)){
                return Result::error('通栏版式类别编号已存在！');
            }
            $data = [
                'name' => $data['name'],
                'component_num' => $data['component_num'], 
                'size_id' => $data['size_id'],
                'sort_id' => 0,
                'sector_img' => $data['sector_img'],
                'sector_type' => $data['type'],
                'type_id' => $data['type_id'],
            ];
        }else{
            $sector_type = SectorPlace::where('sector_type', $data['sector_type'])->where('type_id',1)->first(); 
            if(empty($sector_type)){
                return Result::error('通栏版式类别不存在！');
            }
            $component = SectorPlace::where('id','!=',$id) 
            ->where('component_type', $data['type'])
            ->where('type_id',2)
            ->first();
            if(!empty($component)){
                return Result::error('组件版式类别编号已存在！');
            }
            $data = [
                'name' => $data['name'],
                'component_num' => 0, 
                'size_id' => $data['size_id'],
                'sort_id' => $data['sort_id'],
                'sector_img' => $data['sector_img'],
                'component_type' => $data['type'],
                'type_id' => $data['type_id'],
                'sector_type' => $data['sector_type'],
            ];
        }
        
        $result = SectorPlace::where('id',$id)->update($data);
        if(empty($result)){
            return Result::error('修改失败！');
        }
        return Result::success('修改成功！',$result);
    }
    /**
     * 通栏版式管理-删除通栏版式
     */ 
    public function delSectorPlace(array $data): array
    {
        $sector_place = SectorPlace::where('id',$data['id'])->first();
        if(empty($sector_place)){
            return Result::error('通栏版式不存在！');
        }
        if($sector_place['type_id'] == 1){
            $sector = Sector::where('place_type', $sector_place['sector_type'])->first();
            $component = SectorPlace::where('sector_type', $sector_place['sector_type'])
            ->where('type_id',2)
            ->first(); 
            if(!empty($sector) || !empty($component)){
                return Result::error('通栏版式分类已应用，暂不可删除！');
            }
        }else{
            $sector = Component::where('place_type', $sector_place['component_type'])->first();
            if(!empty($sector)){
                return Result::error('组件版式分类已应用，暂不可删除！');
            }
            $component_num = SectorPlace::where('sector_type', $sector_place['sector_type'])
            ->where('type_id',1)->update(['status'=> 0]);
            if(empty($component_num)){
                return Result::error('通栏版式状态修改失败！');
            }
        }
       $result = SectorPlace::where('id',$data['id'])->delete();
        if(empty($result)){
            return Result::error('删除失败！');
        }
        return Result::success('删除成功！');
    }
    /**
     * 自助建站-通栏版式管理-获取通栏版式详情
     */
    public function getSectorPlaceInfo(array $data): array
    {
        $result = SectorPlace::where('sector_place.id',$data['id'])
        ->leftJoin('size','sector_place.size_id','=','size.id') 
        ->select('sector_place.*','size.width','size.height')
        ->first();
        if(empty($result)){
            return Result::error('通栏版式不存在！');
        }
        return Result::success($result);
    }
    /**
     * 自助建站-通栏版式管理-获取通栏版式列表
     */
    public function getSectorPlaceSort(array $data): array
    {
        $sector = SectorPlace::where('sector_type',$data['sector_type'])->first();
        if(empty($sector)){
            return Result::error('通栏版式不存在！');
        }
        $component = SectorPlace::where('type_id',2)->where('sector_type',$sector['sector_type'])->pluck('sort_id')->toArray();
        if(count($component) < $sector['component_num']){
            // 根据 $sector['component_num'] 的值生成对应元素数量的数组
            if (isset($sector['component_num']) && is_numeric($sector['component_num'])) {
                $num = intval($sector['component_num']);
                if ($num > 0 && $num <= 10) {
// 使用 range 函数生成一个从 1 到 $num 的连续整数数组，存储到 $sector_arr 中
                    $sector_arr = range(1, $num);
                } else {
                    $sector_arr = [];
                }
            } else {
                $sector_arr = [];
            }
            // 获取 $sector_arr 中不在 $component 里的元素
            $sort = array_diff($sector_arr, $component);
            // return Result::success($sort);
        }
        if(!empty($sort)){
            $sort = array_values(array_map(function($value) {
                return ['id' => $value];
            }, $sort));
        }else{
            return Result::error("组件版式数量已达上限！");
        }
        return Result::success($sort);
    }
    /**
     * 获取所有通栏版式
     */ 
    public function getAllSectorPlace(array $data): array
    {
        $where['type_id'] = $data['type_id'];
        if($data['type_id'] == 1){
            $where['status'] = 1;
        }
        if(isset($data['sector_type']) && !empty($data['sector_type'])){
            $where['sector_type'] = $data['sector_type'];
        }
        if(isset($data['component_num']) && !empty($data['component_num'])){
            $where['component_num'] = $data['component_num'];
        }
       $sector_place = SectorPlace::where($where)
       ->leftJoin('size','sector_place.size_id','=','size.id') 
       ->select('sector_place.*','size.width','size.height')
       ->get()->all();
       if(empty($sector_place)){
            return Result::error('通栏版式不存在！');
       }
       return Result::success($sector_place);
    }
    /**
     * 组件管理-获取组件类型
     */
    public function getComponentType(array $data): array
    {
        $where = [];
        if(isset($data['id']) && !empty($data['id'])){
            $where['id'] = $data['id'];
        }
        $component_type = ComponentType::where($where)->first();
        if(empty($component_type)){
            return Result::error('组件类型不存在！');
        }
        $all_code = json_decode($component_type['com_code'] ?? '',true);
        $component_type['all_code'] = $all_code['listType'] ?? [];
        if(empty($component_type)){
            return Result::error('组件类型不存在！');
        }
        return Result::success($component_type);
    }
    /**
     * 组件管理-获取所有组件
     */
    public function getAllComponent(array $data): array
    {
        $where = [];
        if(isset($data['sector_id']) && !empty($data['sector_id'])){
            $where['component.sector_id'] = $data['sector_id'];
        }
        if(isset($data['sort_id']) && !empty($data['sort_id'])){
            $where['component.sort_id'] = $data['sort_id'];
        }
        $component = Component::where($where)->leftJoin('size','component.size_id','=','size.id')
        ->select('component.*','size.width','size.height')
        ->get()->all();
        if(empty($component)){
            return Result::error('组件不存在！');
        }
        return Result::success($component);
    }
    /**
     * 自助建站-流程管理-获取所有通栏
     */
    public function getAllSector(array $data): array
    {
        $where = [];
         if(isset($data['template_id']) && !empty($data['template_id'])){
            $where['template_id'] = $data['template_id'];
        }
        if(isset($data['page_type']) && !empty($data['page_type'])){
            array_push($where,['page_type', 'like', '%'.$data['page_type'].'%']);
        }
        if(isset($data['status']) && !empty($data['status'])){
            array_push($where,['status','!=',0]);
        }
        $sector = Sector::where($where)
        ->leftJoin('size','sector.size_id','=','size.id')
        ->select('sector.*','size.width','size.height')
        ->get()->all();
        if(empty($sector)){
            return Result::error('通栏不存在！');
        }
        return Result::success($sector);
    }
}