<?php
/**
 * Created by PhpStorm.
 * User: zhl
 * Date: 2024/1/6
 * Time: 17:41
 */
namespace App\Http\Controllers\Api;

use App\Enums\Common\Code;
use App\Helper\Common;
use App\Http\Logic\Bside\User\UserLoginLogic;
use App\Models\Ai\AiBlog;
use App\Models\Blog\Blog;
use App\Models\Devops\ServerConfig;
use App\Models\Domain\DomainInfo;
use App\Models\Industry\ProjectIndustryRelated;
use App\Models\Inquiry\InquiryRelateDomain;
use App\Models\Manage\ManageHr;
use App\Models\News\News;
use App\Models\Product\Category;
use App\Models\Product\CategoryRelated;
use App\Models\Product\Keyword;
use App\Models\Product\Product;
use App\Models\Project\DeployBuild;
use App\Models\Project\DeployOptimize;
use App\Models\Project\OnlineCheck;
use App\Models\Project\Project;
use App\Models\Project\ProjectAiSetting;
use App\Models\Project\ProjectKeyword;
use App\Models\RouteMap\RouteMap;
use App\Models\User\User;
use App\Models\WebSetting\WebLanguage;
use App\Services\ProjectServer;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;

/**
 * Class PrivateController
 * @package App\Http\Controllers\Api
 */
class PrivateController extends BaseController
{
    /**
     * 优化中项目列表
     * @param Request $request
     * @return false|string
     */
    public function optimizeProjectList(Request $request)
    {
        $page_size = $request->input('page_size', 20);
        $field = ['gl_project.id', 'gl_project.company', 'gl_project.post_id' ,'gl_project.is_upgrade', 'b.start_date', 'd.domain', 'b.special', 'gl_project.from_order_id','g.servers_id'];// 'f.industry_name',
        $result = Project::select($field)->leftJoin('gl_project_deploy_optimize as b', 'gl_project.id', '=', 'b.project_id')
            ->leftJoin('gl_project_online_check as c', 'gl_project.id', '=', 'c.project_id')
            ->leftJoin('gl_domain_info as d', 'gl_project.id', '=', 'd.project_id')
            ->leftJoin('gl_servers_ip as g', 'gl_project.serve_id', '=', 'g.id')
//            ->leftJoin('gl_project_industry_related as e', 'gl_project.id', '=', 'e.project_id')
//            ->leftJoin('gl_project_industry as f', 'e.industry_id', '=', 'f.id')
            ->where('gl_project.type', Project::TYPE_TWO)
            ->where('gl_project.project_type',Project::TYPE_ZERO)
            ->where('gl_project.extend_type', 0) // 是否续费是由extend_type字段控制
            ->where('gl_project.delete_status', Project::IS_DEL_FALSE)
            ->where(function ($subQuery) {
                $subQuery->orwhere('c.qa_status', OnlineCheck::STATUS_ONLINE_TRUE)->orwhere('gl_project.is_upgrade', Project::IS_UPGRADE_TRUE);
            })
            ->paginate($page_size)
            ->toArray();

        // 直接关联查询， 会出现数据错误
        $project_ids = array_column($result['list'], 'id');
        $industry = ProjectIndustryRelated::leftJoin('gl_project_industry', 'gl_project_industry_related.industry_id', '=', 'gl_project_industry.id')->whereIn('project_id', $project_ids)->pluck('industry_name', 'project_id')->toArray();

        foreach ($result['list'] as &$val) {
            $val['industry_name'] = FALSE == empty($industry[$val['id']]) ? $industry[$val['id']] : '';
            $val['is_self_site'] = $val['servers_id'] == ServerConfig::SELF_SITE_ID ? 1 : 0;
        }

        return $this->success($result);
    }

    /**
     * 获取项目链接
     * FIXME 当前直接获取的产品和产品分类， 后期需要封装到内部， 需要添加完整的链接规则
     * @param Request $request
     * @return false|string
     */
    public function getProjectRoute(Request $request)
    {
        $project_id = intval($request->input('project_id'));
//        $type = $request->input('type');
        $type = [RouteMap::SOURCE_PRODUCT, RouteMap::SOURCE_PRODUCT_CATE];

        $project = Project::where(['id' => $project_id])->first();
        if (empty($project))
            return $this->error('未发现需要查找的项目！');

        $project = ProjectServer::useProject($project_id);

        $domain = DomainInfo::where(['project_id' => $project_id])->first();
        $host = FALSE == empty($domain) ? 'https://' . $domain->domain . '/' : $project->deploy_build->test_domain;

        // 需要标题， 不能直接查询map表
//        $list = RouteMap::where(['project_id' => $project_id])
//            ->when($type, function ($query) use ($type) {
//                return $query->whereIn('source', $type);
//            })
//            ->get();
//
//        $result = [];
//        foreach ($list as $val) {
//            // 排除首页
//            if ($val->source == RouteMap::SOURCE_PAGE && in_array($val->route, ['index', '']))
//                continue;
//            $result[$val->source][] = $host . $val->route;
//        }
        $result = [];
        $product = Product::where(['status' => Product::STATUS_ON])->get(['title', 'route'])->toArray();
        foreach ($product as $val) {
            $val['route'] = $host . $val['route'];
            // FALSE == preg_match('/(\.html|\.htm)$/', $val['route'])
            if (FALSE === strpos($val['route'], '.htm')) {
                $val['route'] .= '/';
            }
            $result[RouteMap::SOURCE_PRODUCT][] = $val;
        }
        $product_category= Category::get(['title', 'route'])->toArray();
        foreach ($product_category as $val) {
            $val['route'] = $host . $val['route'];
            if (FALSE === strpos($val['route'], '.htm')) {
                $val['route'] .= '/';
            }
            $result[RouteMap::SOURCE_PRODUCT_CATE][] = $val;
        }
        return $this->success($result);
    }

    /**
     * 验证当前用户是否存在
     * TODO 查询手机号码是否是项目用户， 如果升级项目未上线项目return false;
     * @param Request $request
     * @return false|string
     */
    public function hasUser(Request $request)
    {
        // 获取数据，初始化信息
        $mobile = trim($request->input('mobile'));
        $result = ['mobile' => $mobile, 'v6_user' => false];

        // 获取用户，验证用户
        $project_ids = User::where(['mobile' => $mobile])->pluck('project_id')->toArray();
        if (empty($project_ids))
            return $this->success($result);

        $projects = Project::whereIn('id', $project_ids)->where('delete_status', 0)->get();
        foreach ($projects as $project) {
            // 如果是升级项目 并且未上线状态，不算做有效用户
            if ($project->is_upgrade == Project::IS_UPGRADE_TRUE && $project->type <= Project::TYPE_ONE)
                continue;
            $result['v6_user'] = true;
        }

        return $this->success($result);
    }

    /**
     * v6 有效用户
     * @param Request $request
     * @return false|string
     */
    public function validUser(Request $request)
    {
        // 排除演示项目数据
        $valid_user = User::select(['gl_project_user.mobile'])->leftJoin('gl_project', 'gl_project.id', '=', 'gl_project_user.project_id')->where(['delete_status' => 0, 'is_upgrade' => Project::IS_UPGRADE_FALSE])->where('gl_project.id', '>', 1)->pluck('mobile')->toArray();
        $upgrade_user = User::select(['gl_project_user.mobile'])->leftJoin('gl_project', 'gl_project.id', '=', 'gl_project_user.project_id')->where(['delete_status' => 0, 'is_upgrade' => Project::IS_UPGRADE_TRUE])->where('gl_project.type', '>', Project::TYPE_ONE)->pluck('mobile')->toArray();
        $user = array_unique(array_merge($valid_user, $upgrade_user));
        return $this->success($user);
    }

    /**
     * 模拟登录返回token
     */
    public function getAutoToken(){
        $this->request->validate([
            'project_id' => 'required',
        ], [
            'project_id.required' => '项目id不能为空',
        ]);
        //获取当前用户的管理员
        $userModel = new User();
        $userInfo = $userModel->read(['project_id'=>$this->param['project_id'],'role_id'=>0]);
        $userLoginLogicModel = new UserLoginLogic();
        $info = $userLoginLogicModel->autoAssembleParam($userInfo);
        //生成新token
        $token = md5(uniqid().'auto'.$info['id']);
        //存储缓存
        $info['token'] = $token;
        Cache::add($token,$info,3600);
        $languageModel = new WebLanguage();
        $languageInfo = $languageModel->read(['id'=>$info['main_lang_id']],['short','english','chinese']);
        $data = ['token'=>$token,'main_lang_id'=>$info['main_lang_id'],'language_info'=>$languageInfo];
        $this->response('success',Code::SUCCESS,$data);
    }

    /**
     * 项目 有效产品路由列表
     * @param Request $request
     * @return false|string
     */
    public function getProductRoute(Request $request)
    {
        $domain = trim($request->input('domain'));
        if (empty($domain)) {
            return $this->error('非法参数！');
        }

        $project = Project::getProjectByDomain($domain);
        if (empty($project)) {
            return $this->error('未找到当前域名对应的项目！');
        }
        ProjectServer::useProject($project->id);
        $feature_category = Category::whereIn('title', ['Featured','featured', 'Featured Products'])->pluck('id');
        $feature_product = CategoryRelated::whereIn('cate_id',$feature_category)->pluck('product_id')->unique()->toArray();
        $product_route = Product::where(['status' => Product::STATUS_ON])->whereNotIn('id', $feature_product)->pluck('route')->toArray();
        return $this->success($product_route);
    }

    /**
     * 获取项目信息---站群服务
     * @param Request $request
     * @return false|string
     */
    public function getProjectByDomain(Request $request)
    {
        $domain = trim($request->input('domain'));
        if (empty($domain)) {
            return $this->error('非法参数！');
        }

        $project = Project::getProjectByDomain($domain);
        if (empty($project)) {
            return $this->error('未找到当前域名对应的项目！');
        }
        $optimize = $project->deploy_optimize;
        $keyword = $project->project_keyword;
        $keywords = explode("\r\n", $keyword ? $keyword->main_keyword : []);
        $result = [
            'company' => $project->company,
            'company_en_name' => $optimize ? $optimize->company_en_name : '',
            'company_en_description' => $optimize ? $optimize->company_en_description : '',
            'keywords' => $keywords
        ];
        return $this->success($result);
    }

    /**
     * 获取产品信息---站群服务
     * @param Request $request
     * @return false|string
     */
    public function getProjectProduct(Request $request)
    {
        $domain = trim($request->input('domain'));
        $page_size = intval($request->input('page_size', 20));
        if (empty($domain)) {
            return $this->error('非法参数！');
        }

        $project = Project::getProjectByDomain($domain);
        if (empty($project)) {
            return $this->error('未找到当前域名对应的项目！');
        }
        ProjectServer::useProject($project->id);
        $products = Product::select(['id', 'title', 'thumb', 'gallery', 'intro', 'content', 'keyword_id', 'route'])->with('category')->where(['status' => Product::STATUS_ON])->paginate($page_size);

//        $products_ids = $products->pluck('id')->toArray();
//        $category_ids = CategoryRelated::whereIn('product_id', $products_ids)->pluck('cate_id')->toArray();
//        $category = Category::whereIn('id', $category_ids)->pluck('title', 'id')->toArray();

        $keyword_id = $products->pluck('keyword_id')->toArray();
        $keyword_ids = array_reduce($keyword_id, 'array_merge', array());
        $keyword = Keyword::whereIn('id', $keyword_ids)->pluck('title', 'id')->toArray();

        foreach ($products as $product) {
            $product_keyword = [];
            foreach ($product->keyword_id as $k_id) {
                array_push($product_keyword, $keyword[$k_id]);
            }
            $product_category = $product->category->pluck('title')->toArray();
            unset($product->category);
            unset($product->keyword_id);
            $product->category = $product_category;
            $product->keyword = $product_keyword;
        }
        return $this->success($products);
    }

    /**
     * 获取上线项目 --- 监控服务
     * @param Request $request
     * @return false|string
     */
    public function getProjectOnline(Request $request)
    {
        $page_size = intval($request->input('page_size', 20));
        $projects = Project::select(['id', 'title', 'company', 'type', 'finish_remain_day', 'remain_day'])->where('extend_type', 0)->whereIn('type', [2, 3, 4, 6])->where('delete_status', 0)->paginate($page_size);
        foreach ($projects as $project) {
            $project->domain = $project->domainInfo ? $project->domainInfo->domain : '';
        }
        return $this->success($projects);
    }

    /**
     * 获取有效时间内 新增有效URL
     * 用于自动提交Google收录
     * @param Request $request
     * @return false|string
     */
    public function projectNewUrl(Request $request)
    {
        $domain = trim($request->input('domain'));
        $domain_parse = parse_url($domain);
        $domain = $domain_parse['host'] ?? $domain;
        $date = trim($request->input('date'));

        if (empty($domain) || empty($date)) {
            return $this->error('非法参数！');
        }

        $project = Project::getProjectByDomain($domain);
        if (empty($project)) {
            return $this->error('未找到当前域名对应的项目！');
        }

        ProjectServer::useProject($project->id);
        $result = [];
        // 查询有效时间后 有效的产品、新闻、博客、聚合页 链接
//        $product = Product::where(['status' => Product::STATUS_ON])->where('created_at', '>=', $date)->pluck('route');
        $news = News::where(['status' => News::STATUS_ONE])->where('release_at', '>', $date)->pluck('url');
        $blog = Blog::where(['status' => Blog::STATUS_ONE])->where('release_at', '>', $date)->pluck('url');
//        $keyword = Keyword::where('created_at', '>', $date)->pluck('route');
        $ai_blog = AiBlog::where(['status' => AiBlog::STATUS_FINISH])->where('updated_at', '>=', $date)->pluck('route');

        // 组装链接
//        foreach ($product as $item) {
//            $url = 'https://' . $domain . '/' . $item;
//            array_push($result, $url);
//        }
//        foreach ($keyword as $item) {
//            $url = 'https://' . $domain . '/' . $item;
//            array_push($result, $url);
//        }
        foreach ($news as $item) {
            $url = 'https://' . $domain . '/news/' . $item;
            array_push($result, $url);
        }
        foreach ($blog as $item) {
            $url = 'https://' . $domain . '/blogs/' . $item;
            array_push($result, $url);
        }
        foreach ($ai_blog as $item) {
            $url = 'https://' . $domain . '/blog/' . $item;
            array_push($result, $url);
        }
        return $this->success($result);
    }

    /**
     * 获取升级项目域名
     * @return false|string
     */
    public function upgradeProjectDomain()
    {
        $domain = Project::leftJoin('gl_domain_info', 'gl_project.id', '=', 'gl_domain_info.project_id')
            ->where(['gl_project.is_upgrade' => Project::IS_UPGRADE_TRUE, 'gl_project.delete_status' => Project::IS_DEL_FALSE, 'gl_project.extend_type' => 0])
            ->pluck('domain')
            ->toArray();
        $list = array_filter(array_unique($domain));
        return $this->success($list);
    }

    /**
     * 将项目标记为广告状态
     * @param Request $request
     * @return false|string
     */
    public function markProjectAds(Request $request)
    {
        $company = trim($request->input('company_name'));
        $project = Project::where(['company' => $company])->first();
        if (empty($project))
            return $this->error('未找到企业名称为："' . $company . '"的项目');

        $optimize = DeployOptimize::where(['project_id' => $project->id])->first();
        $array = [
            $optimize->special,
            16
        ];
        $array = array_unique(array_filter($array));
        $string = ',' . implode(',', $array) . ',';
        $optimize->special = $string;
        $optimize->save();
        return $this->success();
    }

    /**
     * 根据项目域名获取产品关键字
     */
    public function getProjectKeyword(){
        $this->request->validate([
            'domain' => 'required',
        ], [
            'domain.required' => '域名不能为空',
        ]);
        $parsedUrl = parse_url($this->param['domain']);
        $this->param['domain'] = $parsedUrl['host'] ?? $this->param['domain'];
        $domainModel = new DomainInfo();
        $info = $domainModel->read(['domain'=>$this->param['domain']]);
        if(empty($info) || ($info['project_id'] == DomainInfo::STATUS_ZERO)){
            $this->response('当前域名不存在或当前域名未绑定',Code::SYSTEM_ERROR);
        }
        ProjectServer::useProject($info['project_id']);
        $projectKeywordModel = new ProjectKeyword();
        $keywordsInfo = $projectKeywordModel->read(['project_id'=>$info['project_id']],'customer_keywords');
        if($keywordsInfo === false){
            $keywordModel = new Keyword();
            $list = $keywordModel::orderByRaw('LENGTH(title) ASC')->limit(50)->pluck('title','route')->toArray();
        }else{
            $keywords_sts = $keywordsInfo['customer_keywords'];
            if(!empty($keywords_sts)){
                $keywordModel = new Keyword();
                $keywords_arr = explode("\n",$keywords_sts);
                $num = count($keywords_arr);
                if($num >= 50){
                    $list = $keywordModel::orderByRaw('LENGTH(title) ASC')->whereIn('title',$keywords_arr)->limit(50)->pluck('title', 'route')->toArray();
                    $list_num = count($list);
                    if($list_num < 50){
                        $key_list = $keywordModel::orderByRaw('LENGTH(title) ASC')->limit(50 - $list_num)->pluck('title','route')->toArray();
                    }
                    $list = array_merge($key_list,$list);
                }else{
                    $list = $keywordModel::orderByRaw('LENGTH(title) ASC')->whereIn('title',$keywords_arr)->pluck('title', 'route')->toArray();
                    $key_list = $keywordModel::orderByRaw('LENGTH(title) ASC')->limit(50 - $num)->pluck('title','route')->toArray();
                    $list = array_merge($key_list,$list);
                }
            }else{
                $keywordModel = new Keyword();
                $list = $keywordModel::orderByRaw('LENGTH(title) ASC')->limit(50)->pluck('title','route')->toArray();
            }
        }
        $data = [];
        foreach ($list as $k => $v){
            $route = 'https://' . $this->param['domain'].'/'.$k;
            $data[] = [
                'keyword' => $v,
                'url' => $route
            ];
        }
        DB::disconnect('custom_mysql');
        $this->response('success',Code::SUCCESS,$data);
    }

    /**
     * 获取项目监控关键词
     * @param Request $request
     * @return false|string
     */
    public function getMonitorKeyword(Request $request)
    {
        $domain = trim($request->input('domain'));
        $domain_parse = parse_url($domain);
        $domain = $domain_parse['host'] ?? $domain;

        if (empty($domain)) {
            return $this->error('非法参数！');
        }

        $project = Project::getProjectByDomain($domain);
        if (empty($project)) {
            return $this->error('未找到当前域名对应的项目！');
        }

        $json = @file_get_contents(storage_path('data/send_product_tag_keyword/' . $project->id . '.json'));
        $result = json_decode($json, true) ?: [];
        return $this->success($result);
    }

    public function inquiry_relate_domain(Request $request){
        $this->request->validate([
            'from_domain' => 'required',
            'to_domain' => 'required',
        ]);
        $from_domain = trim($this->param['from_domain']);
        $to_domain = trim($this->param['to_domain']);

        $from_domain = parse_url($from_domain, PHP_URL_HOST) ?: $from_domain;
        $to_domain = parse_url($to_domain, PHP_URL_HOST) ?: $to_domain;

        $project = Project::getProjectByDomain($to_domain);
        if (empty($project)) {
            return $this->error('未找到被关联域名对应的项目！');
        }

        $relate = InquiryRelateDomain::where('from_domain', $from_domain)->first();
        if(!$relate){
            $relate = new InquiryRelateDomain();
        }
        $relate->from_domain = $from_domain;
        $relate->to_domain = $to_domain;
        $relate->save();

        return $this->success($relate);
    }

    /**
     * 根据域名获取项目人员配置信息
     * @param Request $request
     * @return false|string
     */
    public function getProjectManageByDomain(Request $request)
    {
        $domain = trim($request->input('domain'));
        $domain_parse = parse_url($domain);
        $domain = $domain_parse['host'] ?? $domain;

        if (empty($domain)) {
            return $this->error('非法参数！');
        }

        $project = Project::getProjectByDomain($domain);
        if (empty($project)) {
            return $this->error('未找到当前域名对应的项目！');
        }

        $build = DeployBuild::select(['leader_mid', 'manager_mid', 'designer_mid', 'tech_mid'])->where(['project_id' => $project->id])->first();
        $optimize = DeployOptimize::select(['manager_mid', 'optimist_mid', 'assist_mid', 'tech_mid', 'tech_leader', 'quality_mid', 'design_mid'])->where(['project_id' => $project->id])->first();

        $build = $build ? $build->toArray() : [];
        $optimize = $optimize ? $optimize->toArray() : [];
        $manage_ids = array_merge(array_values($build), array_values($optimize));


        $member = ManageHr::whereIn('id', $manage_ids)->pluck('name', 'id')->toArray();
        $result = [
            'build_leader' => $build && $build['leader_mid'] ? $member[$build['leader_mid']] : '',                  // 组长
            'build_manager' => $build && $build['manager_mid'] ? $member[$build['manager_mid']] : '',               // 项目经理
            'build_designer' => $build && $build['designer_mid'] ? $member[$build['designer_mid']] : '',            // 设计师
            'build_tech' => $build && $build['tech_mid'] ? $member[$build['tech_mid']] : '',                        // 技术助理
            'optimize_manager' => $optimize && $optimize['manager_mid'] ? $member[$optimize['manager_mid']] : '',   // 优化经理
            'optimize_optimist' => $optimize && $optimize['optimist_mid'] ? $member[$optimize['optimist_mid']] : '',// 优化师
            'optimize_assist' => $optimize && $optimize['assist_mid'] ? $member[$optimize['assist_mid']] : '',      // 优化师助理
            'optimize_tech' => $optimize && $optimize['tech_mid'] ? $member[$optimize['tech_mid']] : '',            // 售后技术
            'optimize_leader' => $optimize && $optimize['tech_leader'] ? $member[$optimize['tech_leader']] : '',    // 售后主管
            'optimize_quality' => $optimize && $optimize['quality_mid'] ? $member[$optimize['quality_mid']] : '',   // 品控
            'optimize_design' => $optimize && $optimize['design_mid'] ? $member[$optimize['design_mid']] : '',      // 平面设计
        ];
        return $this->success($result);
    }

    /**
     * 获取项目信息，通过商户号
     * @param Request $request
     * @return false|string
     */
    public function getProjectByMchId(Request $request)
    {
        $mch_id = intval($request->input('mch_id'));
        $project_setting = ProjectAiSetting::where(['mch_id' => $mch_id])->first();
        if (empty($project_setting))
            return $this->error('商户号未匹配到项目');
        $domain = DomainInfo::where(['status' => 1, 'project_id' => $project_setting->project_id])->first();
        if (empty($domain))
            return $this->error('项目未匹配到域名');
        return $this->success(['domain' => $domain->domain]);
    }

    /**
     * 根据域名获取外链
     * @param Request $request
     * @return false|string
     */
    public function getProjectExternalLink(Request $request)
    {
        $domain = trim($request->input('domain'));
        $domain_parse = parse_url($domain);
        $domain = $domain_parse['host'] ?? $domain;

        if (empty($domain)) {
            return $this->error('非法参数！');
        }

        $project = Project::getProjectByDomain($domain);
        if (empty($project)) {
            return $this->error('未找到当前域名对应的项目！');
        }

        ProjectServer::useProject($project->id);
        $keywords = Keyword::select(['id', 'title', 'route', 'seo_title'])->where('route', '<>', null)->orderBy('id', 'desc')->limit(500)->get();
        $host = 'https://' . $domain . '/';
        $data = [];
        foreach ($keywords as $keyword) {
            $data[] = $host . $keyword->route . '/{' . $keyword->seo_title . '}';
        }
        DB::disconnect('custom_mysql');
        return $this->success($data);
    }

    /**
     * 获取今日需要推送的外链
     * @param Request $request
     * @return false|string
     */
    public function getExternalLink(Request $request)
    {
        $max_id = DB::table('gl_project_external_link_make')->where(['status' => 0])->max('id');
        if (empty($max_id))
            return $this->success();
        $links = DB::table('gl_project_external_link_make')->where(['status' => 0])->where('id', '<=', $max_id)->pluck('external_link')->toArray();
        DB::table('gl_project_external_link_make')->where(['status' => 0])->where('id', '<=', $max_id)->update(['status' => 1, 'updated_at' => date('Y-m-d H:i;s')]);
        return $this->success($links);
    }

    /**
     * 5.0项目获取加密token
     * @param Request $request
     * @return false|string
     */
    public function getAICCToken(Request $request)
    {
        $data = $request->all();
        $data = array_unique(array_filter($data));
        $data['timestamp'] = time();
        $common = new Common();
        $token = $common->encrypt($data);
        return $this->success(['token' => $token]);
    }
}