<?php

namespace App\Http\Logic\Bside\RankData;


use App\Helper\Arr;
use App\Helper\QuanqiusouApi;
use App\Helper\Translate;
use App\Http\Logic\Aside\Project\DomainInfoLogic;
use App\Http\Logic\Aside\Project\ProjectLogic;
use App\Http\Logic\Bside\BaseLogic;
use App\Models\Domain\DomainInfo;
use App\Models\Project\DeployBuild;
use App\Models\Project\DeployOptimize;
use App\Models\Project\Project;
use App\Models\RankData\ExternalLinks;
use App\Models\RankData\IndexedPages;
use App\Models\RankData\RankData;
use App\Models\RankData\RankWeek;
use App\Models\RankData\RecommDomain;
use App\Models\RankData\Speed;
use App\Utils\HttpUtils;
use GuzzleHttp\Exception\GuzzleException;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Str;

class RankDataLogic extends BaseLogic
{

    /**
     * 统计数据
     * @author zbj
     * @date 2023/5/11
     */
    public function index()
    {
        $project_id = $this->user['project_id'];

        //查数据
        $project = (new ProjectLogic())->getProjectInfo($project_id);
        $domain_info = (new DomainInfoLogic)->getDomainInfo($project_id);
        $rank = RankData::where('project_id', $project_id)->first();
        $rank_week = RankWeek::where('project_id', $project_id)->first();
        $recomm_domain = RecommDomain::where('project_id', $project_id)->first();
        $external_links = ExternalLinks::where('project_id', $project_id)->first();
        $indexed_pages = IndexedPages::where('project_id', $project_id)->first();
        $speed = Speed::where('project_id', $project_id)->first();
        $api_no = $project['deploy_optimize']['api_no'] ?? '';
        //排名数据
        $data = [
            'first_num' => $rank['first_num'] ?? 0,
            'first_page_num' => $rank['first_page_num'] ?? 0,
            'first_three_pages_num' => $rank['first_three_pages_num'] ?? 0,
            'first_five_pages_num' => $rank['first_five_pages_num'] ?? 0,
            'first_ten_pages_num' => $rank['first_ten_pages_num'] ?? 0,
            'indexed_pages_num' => $rank['indexed_pages_num'] ?? 0,
            'external_links_num' => $external_links['total'] ?? 0,
        ];

        //项目信息
        $data['project'] = [
            'company' => $project['company'],
            'domain' =>  $domain_info['domain'] ?? '',
            'domain_info' => $domain_info['domain_info'] ?? '',
            'cert_info' => $domain_info['cert_info'] ?? '',
            'plan' => Project::planMap()[$project['deploy_build']['plan']],
            'keyword_num' => $project['deploy_build']['keyword_num'],
            'compliance_day' => $project['finish_remain_day'] ?? 0,
            'remain_day' => $project['deploy_build']['service_duration'] - ($project['finish_remain_day'] ?? 0),
        ];

        //小语种列表
        $quanqiusou_api = new QuanqiusouApi();
        $lang_data = $quanqiusou_api->getLangRankData($api_no);
        $lang_data = Arr::setValueToKey($lang_data, 'language');
        $data['langs'] = [];
        foreach($project['deploy_optimize']['minor_languages']??[] as $lang){
            $remain_day = $lang_data[$lang['tl']]['dabiao_day'] ?? 0;
            $data['langs'][$lang['tl'] ?? ''] = [
                'lang_text' => Translate::getTls($lang['tl'] ?? ''),
                'keyword_num' => $lang['keywords'] ?? 0,
                'reach_day' => $lang_data[$lang['tl']]['dabiao_day'] ?? 0,
                'home_cnt' => $lang_data[$lang['tl']]['home_cnt'] ?? 0,
                'remain_day' => ($lang['type']??0) == 1 ? $data['project']['remain_day'] : $lang['service_day'] - $remain_day,
                'type' => $lang['type'] ?? 0, //1 项目关键词 项目天数  2 保证首页关键词 项目达标天数
            ];
        }


        //测速
        $data['speed'] = $speed['data'] ?? [];

        //seo基础设置
        $data['seo'] = [
            'H1,H2,H3标签',
            'TDK设置(Title, Description, Keywords)',
            'Google 收录提交',
            'Sitemap.xml Google站长地图',
            'Robots.txt文件优化',
            'Google站长工具优化设置'
        ];

        //外链引荐域名
        $recomm_domain = $recomm_domain ? $recomm_domain->toArray() : [];
        $data['external_links_domain_chat'] = [
            'labels' => array_map(function ($item) {
                return Str::substrReplace($item, '***', 2, 3);
            }, Arr::pluck($recomm_domain['data'] ?? [], 'domain')),
            'data' => Arr::pluck($recomm_domain['data'] ?? [], 'backlinks_num'),
            'list_date' => $recomm_domain['updated_at'] ?? '',
        ];
        //SEO数据周期分析图 外链数
        $data['external_links_chat'] = [
            'labels' => array_keys($external_links['data'] ?? []),
            'data' => array_values($external_links['data'] ?? []),
        ];
        //SEO数据周期分析图 收录数
        $data['indexed_pages_chat'] = [
            'labels' => array_keys($indexed_pages['data'] ?? []),
            'data' => array_values($indexed_pages['data'] ?? []),
        ];
        //收录数加上当日数据
        if ((Arr::last($data['indexed_pages_chat']['labels'])) != date('Y-m-d')) {
            $data['indexed_pages_chat']['labels'][] = date('Y-m-d');
            $data['indexed_pages_chat']['data'][] = $data['indexed_pages_num'];
        }
        //关键词排名分析图
        $data['rank_chat'] = [
            'data' => $rank_week['data'] ?? [],
            'labels' => $rank_week['date'] ?? [],
        ];

        return $data;
    }

    /**
     * 关键词排名
     * @author zbj
     * @date 2023/5/12
     */
    public function keywords_rank_list($export = false)
    {
        $page = intval($this->request['page'] ?: 1);
        $lang = $this->request['lang'] ?: '';
        $project_id = $this->user['project_id'];
        $project = (new ProjectLogic())->getProjectInfo($project_id);
        $api_no = $project['deploy_optimize']['api_no'] ?? '';
        $domain = (!empty($project['deploy_optimize']['domain']) ? ((new DomainInfo())->getDomain($project['deploy_optimize']['domain'])) :  '');
        $domain_arr = parse_url($domain);
        $domain = $domain_arr['host'] ?? $domain_arr['path'];
        //复制站点域名
        $ext_projects = $this->getExtendProjects();
        $flg_ext = $this->getExtFlag($ext_projects, $domain, $api_no);
        $ext_domain = str_replace('www.', '', $this->getExtendProjects($api_no)['ext'] ?? '');
        //AI站点域名
        $ai_projects = $this->getAiProjects()['data'] ?? [];
        $flg_ai = $this->getAiFlag($ai_projects, $domain);
        $ai_domain = str_replace('www.', '', $this->getAiProjects($domain)['domain'] ?? '');
        $list = RankData::where('project_id', $project_id)->where('lang', $lang)->value('data') ?: [];
        $list30 = []; //排名前三十的
        $list30_0 = []; //排名前三十且近三天没有排名的
        $list100 = []; //排名前100的
        $list0 = [];//排名为0的
        foreach ($list as $key => $v) {
            $last = Arr::last($v);
            $data = [];
            //处理日期
            foreach ($v as $date => $position) {
                $data[date('m-d', strtotime($date . '+ 1 day'))] = $position['position'];
            }
            //域名类型
            $domain_text = '主域名：' . str_replace('www.', '', $domain);
            if (!empty($last['r'])) {
                $domain_text = 'AI域名：' . $last['r'];
                if (in_array($flg_ext, [1, 2]) || $flg_ai == 1) {
                    if ($last['r'] == $ai_domain) {
                        $domain_text = '星链域名：' . $ai_domain;
                    } else if ($last['r'] == $ext_domain) {
                        $domain_text = '主域名2：' . $ext_domain;
                    } else {
                        $domain_text = 'AI域名：' . $last['r'];
                    }
                }
            }
            $domain_arr = explode('：', $domain_text);
            $v = [
                'keyword' => $key,
                'domain_type' => $domain_arr[0],
                'domain' => $domain_arr[1],
                'domain_text' => $domain_text,
                'g' => $last['g'],  //1核心关键词
                'position' => $data,
            ];
            //图片排名
            if(isset($last['p_img'])){
                $v['img_position'] = $last['p_img'];
            }
            //视频排名
            if(isset($last['p_vid'])){
                $v['video_position'] = $last['p_vid'];
            }

            if ($last['position'] == 0) {
                $list0[] = $v;
            } elseif ($last['position'] <= 30) {
                if (($v['position'][date('m-d', strtotime('-1day'))] ?? '') == 0 ||
                    ($v['position'][date('m-d', strtotime('-2day'))] ?? '') == 0) {
                    $list30_0[] = $v;
                } else {
                    $list30[] = $v;
                }
            } else {
                $list100[] = $v;
            }
        }
        //排序 排名前30的 按关键词长短排序 最近三天无排名的排后; 后30名的按排名排序
        $list30 = collect($list30)->sortBy(function ($item) {
            return strlen($item['keyword']);
        })->values()->all();
        $list30_0 = collect($list30_0)->sortBy(function ($item) {
            return strlen($item['keyword']);
        })->values()->all();
        $list100 = collect($list100)->sortBy(function ($item) {
            return Arr::last($item['position']);
        })->values()->all();
        $list = collect($list30)->merge($list30_0)->merge($list100)->merge($list0)->filter(function ($item) {
            //搜索
            if ($this->request['search']) {
                return strpos($item['keyword'], $this->request['search']) !== false;
            }
            //前几名
            if ($this->request['first']) {
                $position = Arr::last($item['position']);
                return $position > 0 && $position <= $this->request['first'];
            }
            //核心词
            if ($this->request['g']) {
                return $item['g'] == $this->request['g'];
            }
            return true;
        })->values();

        if($export){
            return $list->toArray();
        }
        $data = [
            "list" => $list->forPage($page, 100)->toArray(),
            "total" => $list->count(),
            "page" => $page,
            "total_page" => ceil($list->count() / 100),
            "size" => 100
        ];
        return $this->success($data);
    }


    /**
     * 获取复制站点项目
     * @author zbj
     * @date 2023/5/12
     */
    public function getExtendProjects($api_no = null)
    {
        $key = 'extend_projects_list';
        $data = Cache::get($key);
        if (!$data) {
            $api_url = 'http://api.quanqiusou.cn/google-rank/api/extend_projects.php';
            try {
                $data = HttpUtils::get($api_url, []);
                if ($data) {
                    $data = Arr::s2a($data);
                    Cache::put($key, $data, 4 * 3600);
                }
            } catch (\Exception | GuzzleException $e) {
                errorLog('复制站点项目获取失败', [], $e);
                return false;
            }
        }
        if ($api_no !== null) {
            $data = collect($data)->where('apino', $api_no)->first();
            return $data ?: [];
        }
        return $data;
    }

    /**
     * 获取AI站点项目
     * @author zbj
     * @date 2023/5/12
     */
    public function getAiProjects($domain = null)
    {
        $key = 'ai_projects_list';
        $data = Cache::get($key);
        if (!$data) {
            $api_url = 'https://demosite5.globalso.com/api/domain';
            try {
                $data = HttpUtils::get($api_url, []);
                if ($data) {
                    $data = Arr::s2a($data);
                    Cache::put($key, $data, 4 * 3600);
                }
            } catch (\Exception | GuzzleException $e) {
                errorLog('AI站点项目获取失败', [], $e);
                return false;
            }
        }
        if ($domain !== null) {
            $domain = parse_url($domain);
            $data = collect($data['data'])->where('bind_domain', $domain['host'] ?? $domain['path'])->first();
            return $data ?: [];
        }
        return $data;
    }

    /**
     * 获取复制项目标识
     * @author zbj
     * @date 2023/5/15
     */
    protected function getExtFlag($ext_projects, $domain, $api_no)
    {
        //复制站点标识
        $flg_ext = 0;
        if ($ext_projects) {
            $ext_urls = array_column($ext_projects, 'ext');
            $api_nos = array_column($ext_projects, 'apino');
            if (in_array($api_no, $api_nos)) {
                $flg_ext = 1;
            }
            if (in_array($domain, $ext_urls)) {
                $flg_ext = 2;
            }
        }
        return $flg_ext;
    }

    /**
     * 获取AI项目标识
     * @author zbj
     * @date 2023/5/15
     */
    protected function getAiFlag($ai_projects, $domain)
    {
        $flg_ai = 0;
        foreach ($ai_projects as $ai_project) {
            if ($ai_project['bind_domain'] == $domain) {
                $flg_ai = 1;
            }
        }
        return $flg_ai;
    }

    /**
     * 同步排名信息
     * @throws \Exception
     * @author zbj
     * @date 2023/9/20
     */
    public function syncRankData($api_no, $site_res, $force=false){
        $project_ids = DeployOptimize::where('api_no', $api_no)->pluck('project_id');
        foreach ($project_ids as $project_id) {
            $project = Project::find($project_id);
            if (!$project) {
                throw new \Exception($api_no . '关联的项目不存在');
            }

            $api = new QuanqiusouApi();

            $model = RankData::where('project_id', $project_id)->where('lang', '')->first();
            if (!$model || $model->updated_date != date('Y-m-d') || $force) {
                $res = $api->getGoogleRank($api_no, 0, 7, $force);
                if (!$res) {
                    throw new \Exception("接口数据获取失败,api_no:{$api_no}");
                }
                //收录数
                $indexed_pages_num = $site_res[$api_no] ?? 0;
                $this->save_rank($project_id, $res, $indexed_pages_num);
            }
            //有小语种的
            $lang_list = $api->getLangList();
            if (!empty($lang_list[$api_no])) {
                $model = RankData::where('project_id', $project_id)->where('lang', '<>', '')->first();
                if (!$model || $model->updated_date != date('Y-m-d') || $force) {
                    $res = $api->getGoogleRank($api_no, 1, 7, $force);
                    if (!$res) {
                        throw new \Exception("接口数据获取失败,api_no:{$api_no},lang");
                    }
                    $data = [];
                    //不同的小语种取出来
                    foreach ($res as $keyword => $v) {
                        $data[Arr::last($v)['lang']][$keyword] = $v;
                    }
                    foreach ($data as $lang => $rank) {
                        $this->save_rank($project_id, $rank, 0, $lang);
                    }
                }
            }
        }
    }

    /**
     * @param $project_id
     * @param int $indexed_pages_num
     * @param $data
     * @param string $lang
     * @author zbj
     * @date 2023/5/8
     */
    public function save_rank($project_id, $data, int $indexed_pages_num = 0, string $lang = ''){
        $without_project_ids = [];  //不用处理排名的项目

        $first_num = $first_page_num = $first_three_pages_num = $first_five_pages_num = $first_ten_pages_num = 0;

        if(!$lang){
            foreach ($data as &$ranks){
                ksort($ranks);
                foreach ($ranks as &$rank){
                    //处理排名
                    if(!in_array($project_id, $without_project_ids)){
                        if($rank['position'] >= 10){
                            $rank['position'] -= 5;
                        }
                        //todo 需要特殊处理排名的项目
                    }
                }
                $last = Arr::last($ranks);
                //第一名
                if($last['position'] == 1){
                    $first_num ++;
                }
                //排名第一页
                if($last['position'] > 0 && $last['position'] <= 10){
                    $first_page_num ++;
                }
                //排名前三页
                if($last['position'] > 0 && $last['position'] <= 30){
                    $first_three_pages_num ++;
                }
                //排名前五页
                if($last['position'] > 0 && $last['position'] <= 50){
                    $first_five_pages_num ++;
                }
                //排名前十页
                if($last['position'] > 0 && $last['position'] <= 100){
                    $first_ten_pages_num ++;
                }
            }
        }

        $where = [
            'project_id' => $project_id,
            'lang' => $lang
        ];
        $model = RankData::where($where)->first();
        if(!$model){
            $model = new RankData();
        }

        //关键词达标天数
        $model->is_compliance = 0;
        if($model->updated_date != date('Y-m-d')){
            //保证关键词数
            $keyword_num = DeployBuild::where('project_id', $project_id)->value('keyword_num');
            $type = Project::where('id', $project_id)->value('type');
            if($keyword_num && $type == Project::TYPE_TWO && $first_page_num >= $keyword_num){
                $model->compliance_day = $model->compliance_day + 1;
                $model->is_compliance = 1;
                //项目表更新
                $compliance_day  = Project::where(['id' => $project_id])->value('finish_remain_day') ?: 0;
                Project::where('id', $project_id)->update(['is_remain_today' => 1, 'finish_remain_day' => $compliance_day+1]);
            }
        }

        $model->project_id = $project_id;
        $model->first_num = $first_num;
        $model->first_page_num = $first_page_num;
        $model->first_three_pages_num = $first_three_pages_num;
        $model->first_five_pages_num = $first_five_pages_num;
        $model->first_ten_pages_num = $first_ten_pages_num;
        $model->indexed_pages_num = $indexed_pages_num;
        $model->lang = $lang;
        $model->data = $data;
        $model->updated_date = date('Y-m-d');
        $model->save();
    }
}