<?php

namespace App\Http\Controllers\Admin;

use App\Exports\BasicExport;
use App\Http\Constant\CacheConstant;
use App\Http\Controllers\Controller;
use App\Http\Logics\Admin\SiteLogic;
use App\Http\Logics\Admin\SiteSyncLogic;
use App\Http\Models\Article;
use App\Http\Models\ArticleNote;
use App\Http\Models\Business;
use App\Http\Models\Contract;
use App\Http\Models\HootsuiteHistory;
use App\Http\Models\HootsuiteUser;
use App\Http\Models\Role;
use App\Http\Models\Server;
use App\Http\Models\Site;
use App\Http\Models\SiteAddition;
use App\Http\Models\SiteEnterprise;
use App\Http\Models\SiteInfo;
use App\Http\Models\SiteMarketer;
use App\Http\Models\SiteOptimizePage;
use App\Http\Models\SitePayment;

use App\Http\Models\SiteSns;
use App\Http\Models\SiteStation;
use App\Http\Models\Social;
use App\Http\Models\SocialPublish;
use App\Http\Models\User;
use App\Http\Requests\Site\PaymentRequest;
use App\Http\Requests\Site\SiteOverviewRequest;
use App\Http\Requests\Site\CustomerRequest;
use App\Http\Requests\Site\SiteSaveRequest;
use App\Http\Requests\Site\SocialPublishRequest;
use App\Http\Requests\Site\SocialQueueRequest;
use App\Http\Requests\Site\SocialSaveRequest;
use App\Imports\OptimizePageImport;
use App\Imports\SocialImport;
use App\Imports\SocialMessageListImport;
use GuzzleHttp\Client;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;

use Illuminate\Support\Facades\Log;
use App\Http\Traits\HasSites;
use Maatwebsite\Excel\Facades\Excel;
use Illuminate\Contracts\View;
use Illuminate\Http\JsonResponse;


/**
 * 项目 站点 管理
 * Class SiteController
 * @package App\Http\Controllers\Admin
 */
class SiteController extends Controller
{
    use HasSites;

    protected $logic;


    const PC_SPEED_MEASUREMENT = 'http://googlepagespeed.yinqingli.net/?type=1&url=';
    const MOBILE_SPEED_MEASUREMENT = 'http://googlepagespeed.yinqingli.net/?type=2&url=';

    public function __construct(SiteLogic $logic)
    {
        $this->logic = $logic;
    }

    //站点渲染页面及列表
    public function index(Request $request)
    {
        $user = auth()->user();
        if (!$request->ajax()) {

            $userList = User::query()->where(['status' => 1])
                ->whereIn('role_id', [14, 27, 34, 32, 29, 15, 7, 6, 25, 26, 2, 1])
                ->select(['id', 'nickname', 'role_id'])
                ->get();
            $businessList = Business::query()->pluck('title', 'id');
            $month = date('m');
            $lastMonth = date('m', strtotime('last month'));

            return view('admin/site/index', [
                'userList' => $userList,
                'businessList' => $businessList,
                'role_id' => $user->role_id,
                'is_propaganda' => 0,//品宣只显示建站期和服务期
                'month' => $month,
                'lastMonth' => $lastMonth
            ]);
        }

        list($sites, $items, $sortName, $sortOrder) = $this->indexBuild($request, $user);
        $items = $this->sitePublishList($items);

        list($nowListReportMap, $listReportMapResult, $listReportMapResult1) = $this->getInquireList();
        list($nowtMonthKeywords, $keywordDropResults, $keywordDropResults1) = $this->getTop10List();
        list($nowtMonthFlow, $clicksDropResults, $clicksDropResults1) = $this->getFlowList();
        list($pcSpeedMeasurement, $mobileSpeedMeasurement) = $this->getSpeedMeasurementList();

        $articleNoteList = ArticleNote::query()
                ->selectRaw('site_id,count(*) as count')
                ->groupBy('site_id')
                ->pluck('count', 'site_id')
                ->toArray() ?? [];

        array_walk($items, function ($item) use (
            &$nowtMonthKeywords,
            &$nowListReportMap, &$listReportMapResult, &$listReportMapResult1,
            &$keywordDropResults, &$keywordDropResults1, &$clicksDropResults,
            &$clicksDropResults1, &$masterDropResult, &$pcSpeedMeasurement,
            &$mobileSpeedMeasurement, &$articleNoteList
        ) {
            $item->identify = base64_encode($item->id);
            $item->managers_title = implode('-', $item->users->where('role_id', Role::TYPE_MANAGER)->pluck('nickname')->toArray());
            $item->server_title = implode('-', $item->users->where('role_id', Role::TYPE_SERVER)->pluck('nickname')->toArray());
            $item->propaganda = implode('-', $item->users->where('role_id', Role::TYPE_SOFT_TEXT_SEARCH)->pluck('nickname')->toArray());

            $item->statusTitle = Site::STATUS_MAP[$item->status] ?? '';

            $item->top10 = $item->old_id ? ($nowtMonthKeywords[$item->old_id] ?? '-') : '未关联';
            $item->traffic = $item->old_id ? ($nowListReportMap[$item->old_id]->traffic ?? '-') : '未关联';
            $item->inquire = $item->old_id ? ($nowListReportMap[$item->old_id]->inquire ?? '-') : '未关联';

            $item->is_google_bid = in_array(Contract::GOOGLE_BID, $item->contract_ids ?? []) ? 1 : 0;

            $item->listReportMapResult = $listReportMapResult[$item->old_id] ?? '';
            $item->listReportMapResult1 = $listReportMapResult1[$item->old_id] ?? '';

            $item->keywordDropResults = $keywordDropResults[$item->old_id] ?? '';
            $item->keywordDropResults1 = $keywordDropResults1[$item->old_id] ?? '';

            $item->clicksDropResults = $clicksDropResults[$item->old_id] ?? '';
            $item->clicksDropResults1 = $clicksDropResults1[$item->old_id] ?? '';

            //$item->masterDropResult = $masterDropResult[$item->id] ?? '';

            $item->pcSpeedMeasurement = $pcSpeedMeasurement[$item->old_id] ?? '-';
            $item->mobileSpeedMeasurement = $mobileSpeedMeasurement[$item->old_id] ?? '-';
            $item->articleNote = $articleNoteList[$item->id] ?? 0;

            $item->order_at = substr($item->order_at, 0, 10);
            $item->reach_at = substr($item->reach_at, 0, 10);
            $item->online_at = substr($item->online_at, 0, 10);

        });

        $records = collect($items);
        if ($sortName == 'monthOfCompletionNum') {
            $sortName = 'monthOfCompletionNumTime';
        }

        if (in_array($sortName, ['traffic', 'inquire', 'top10', 'pcSpeedMeasurement', 'mobileSpeedMeasurement', 'monthOfCompletionNumTime', 'articleNote'])) {

            $descending = strtolower($sortOrder) == 'asc' ? false : true;
            $records = $records->sortBy(function ($item, $key) use ($sortName, $descending) {
                return intval($item[$sortName]);
            }, SORT_REGULAR, $descending)->values();
        }

        return response()->json([
            'rows' => $records,
            'total' => $sites->total()
        ]);
    }

    public function indexBuild($request, $user, $isExport = false)
    {
        $site = Site::query();
        $keyword = $request->input('keyword');
        $coreProduct = $request->input('coreProduct');

        $isPropaganda = $request->input('is_propaganda');
        $projectType = $request->input('projectType');
        if ($projectType) {
            $site->where('site_type', $projectType);
        }
        if ($status = $request->input('status')) {
            $site->where('status', $status);
        } else {
            if (in_array($user->role_id, [15, 17]) && !$keyword) {
                //查找任务管理[只显示建站期和服务期]==项目列表[品宣只显示建站期和服务期]
                $site->whereIn('status', [2, 3]);
            }
            if ($isPropaganda == 1 && !$keyword) {
                //查找任务管理[只显示建站期和服务期]==项目列表[品宣只显示建站期和服务期]
                $site->whereIn('status', [2, 3]);
            }

            if (!in_array($user->role_id, [15, 17]) && !$keyword) {
                $site->whereIn('status', [1, 2, 3, 4, 5, 6, 8, 9, 10]);
            }
        }

        if ($request->input('bid_status') == 'on') {
            $site->where('bid_status', 1);
        }

        if ($request->input('feedback_status') == 'on') {

            $feedbackSiteList = Article::query()->select('site_id')
                    ->where('be_applicable', 0)
                    ->groupBy('site_id')->pluck('site_id')
                    ->toArray() ?? [];
            $site->whereIn('id', $feedbackSiteList);
        }

        if ($request->input('customer_review') == 'on') {

            $feedbackSiteList = SiteInfo::query()->select('site_id')
                ->where('article_custom_audit', 1)
                ->pluck('site_id');
            $site->whereIn('id', $feedbackSiteList);
        }

        $layoutKeyword = $request->input('layoutKeyword');
        if (!empty($layoutKeyword)) {
            $sites = SiteOptimizePage::query()->where('keyword', 'like', $layoutKeyword . '%')->pluck('site_id');
            $site->whereIn('id', $sites);
        }

        $businessId = $request->input('businessId');

        $builder = $site->withCount(['articles' => function (Builder $query) {
            $query->where([
                ['publish_at', '>', date('Y-m-01 00:00:00')],
                ['publish_at', '<', date('Y-m-d 00:00:00', strtotime('first day of next month'))],
            ]);
        }, 'articles as articles_sum' => function (Builder $query) {
            $query->where('be_applicable', 1);
        }, 'articles as pendingUpgrade' => function (Builder $query) {
            $query->whereNull('publish_at');
        }, 'articles as published' => function (Builder $query) {
            $query->whereNotNull('publish_at');
        }, 'articles as thisMonthUpgrade' => function (Builder $query) {
            $query->whereBetween('publish_at', [date('Y-m-01 00:00:00'), date('Y-m-t 23:59:59')]);
        }, 'linkDetails' => function (Builder $query) {
            $query->where([
                ['enable', '=', 1],
                ['status', '=', 5],
                ['created_at', '>', date('Y-m-01 00:00:00')],
                ['created_at', '<', date('Y-m-d 00:00:00', strtotime('first day of next month'))],
            ]);

        }])->with(['users'])->scopes(['user'])->where(function (Builder $builder) use ($keyword, $businessId, $coreProduct) {
            if ($keyword) {
                $builder->whereIn('status', [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]);
                $builder->where('domain', 'like', '%' . $keyword . '%')
                    ->orWhere('cn_title', 'like', '%' . $keyword . '%');
            }
            if ($businessId) {
                $builder->where('business_id', $businessId);
            }
            if ($coreProduct) {
                $builder->where('core_product', 'like', '%' . $coreProduct . '%');
            }
        });

        $sortName = $request->input('sortName');
        $sortOrder = $request->input('sortOrder');

        if ($sortName == 'statusTitle') {
            $builder->orderBy('status', $sortOrder);
        }
        if ($sortName == 'order_at') {
            $builder->orderBy('order_at', $sortOrder);
        }
        if ($sortName == 'online_date') {
            $builder->orderBy('online_at', $sortOrder);
        }
        if ($sortName == 'reach_at') {
            $builder->orderBy('reach_at', $sortOrder);
        }

        if ($isExport) {
            $sites = '';
            $items = $builder->orderByDesc('id')->get();
        } else {
            $sites = $builder->orderByDesc('id')->paginate($request->input('pageSize') ?? TABLE_PAGE_SIZE);
            $items = $sites->items();
        }

        return [$sites, $items, $sortName, $sortOrder];
    }

    public function sitePublishList($items)
    {
        foreach ($items as $key => $item) {
            if (!empty($item->enterprise_nature)) {
                $list = explode(',', $item->enterprise_nature);
                foreach ($list as $value) {
                    if ($value == 1) {
                        $items[$key]->the500Strongest = 1;
                    }
                    if ($value == 2) {
                        $items[$key]->listedCompany = 1;
                    }
                    if ($value == 3) {
                        $items[$key]->stateEnterprises = 1;
                    }
                    if ($value == 4) {
                        $items[$key]->leadingEnterprise = 1;
                    }
                }
            }

            if (empty($item->article_goal)) {
                $item->article_goal = 0;
            }

            $c = false;

            if ($item->published > 0) {

                /*年月日Y-M-D，假设, 待更新数=A，每月更新数=B，完成月份至显示为y-m
                最新显示发布月：Y-M（如上图最新发布月 Y-M为2021-2）
                A>= B时, A/B=C（C只取整数，如2.5取2），则m=M+C，完成月份至显示为 Y-(M+C)
                如果M+C>12，则 显示为 (Y+1)- [(M+C)-12] , 例如 最新发布月：2021-11，M+C=2，则完成月份至 显示为 2022-1*/

                $m = Article::query()->where('site_id', $item->id)
                    ->whereNotNull('publish_at')
                    ->orderBy('publish_at', 'desc')
                    ->value('publish_at');

                if ($item->pendingUpgrade > $item->articles_updates_per_month) {

                    if ($item->pendingUpgrade > 0 && $item->articles_updates_per_month > 0) {
                        $c = floor($item->pendingUpgrade / $item->articles_updates_per_month);
                        if (!empty($m)) {
                            $c = date("Y-m", strtotime("first day of +{$c} month", strtotime($m)));
                        }
                    }
                }

                // 0<=A<B时, m=M, 完成月份至 显示 Y-M，即和最新发布月显示一致
                if ($item->articles_updates_per_month > $item->pendingUpgrade && $item->articles_updates_per_month >= 0) {
                    if (!empty($m)) {
                        $c = date('Y-m', strtotime($m));
                    } else {
                        $c = date('Y-m');
                    }
                }

            } else {

                /*年月日Y-M-D，假设, 待更新数=A，每月更新数=B，完成月份至显示为y-m
                A>=B时, A/B=C（C只取整数，如2.5取2），则m=本月份-1+C
                0<=A<B时，完成月份至 显示 “-”*/

                if ($item->pendingUpgrade > $item->articles_updates_per_month) {
                    if ($item->pendingUpgrade > 0 && $item->articles_updates_per_month > 0) {
                        $c = date('Y-m', strtotime("last day of -1 month", strtotime(date("Y-m"))));

                        $dateNum = floor($item->pendingUpgrade / $item->articles_updates_per_month);
                        $c = date("Y-m", strtotime("first day of +{$dateNum} month", strtotime($c)));

                    }
                }
                if ($item->articles_updates_per_month > $item->pendingUpgrade && $item->articles_updates_per_month >= 0) {
                    $c = false;
                }
            }

            if (!$c) {
                $item->monthOfCompletionNum = '-';
                $item->monthOfCompletionNumTime = '-';

            } else {
                $item->monthOfCompletionNum = $c;
                $item->monthOfCompletionNumTime = strtotime($c);
            }

            $item->articles_updates_per_month = $item->articles_updates_per_month + 1;
            $item->over = $item->article_goal - $item->articles_sum;
        }
        return $items;
    }

    public function getInquireList()
    {
        if (!Cache::has(CacheConstant::NOW_MONTH_INQUIRE_CACHE_KEY)) {
            $nowListReportMap = DB::connection('rank')
                ->table('project_listreport')
                ->where(['ym' => date('Ym', strtotime('first day of -1 month'))])
                ->get()->keyBy('project_id')
                ->toArray();

            Cache::put(CacheConstant::NOW_MONTH_INQUIRE_CACHE_KEY, $nowListReportMap, mt_rand(54000, 57600));
        }
        $nowListReportMap = Cache::get(CacheConstant::NOW_MONTH_INQUIRE_CACHE_KEY) ?? [];

        if (!Cache::has(CacheConstant::LAST_MONTH_INQUIRE_CACHE_KEY)) {
            $lastListReportMap = DB::connection('rank')
                ->table('project_listreport')
                ->where(['ym' => date('Ym', strtotime('first day of -2 month'))])
                ->get()->keyBy('project_id')
                ->toArray();

            Cache::put(CacheConstant::LAST_MONTH_INQUIRE_CACHE_KEY, $lastListReportMap, mt_rand(54000, 57600));
        }
        $lastListReportMap = Cache::get(CacheConstant::LAST_MONTH_INQUIRE_CACHE_KEY) ?? [];

        $listReportMapResult = [];
        $listReportMapResult1 = [];

        foreach ($lastListReportMap as $inx => $val) {
            $lastOne = $nowListReportMap[$inx] ?? null;
            if (empty($lastOne)) {
                continue;
            }
            $lessVal = $val->inquire - $lastOne->inquire;
            if ($lessVal > 0) {
                $listReportMapResult[$inx] = $lessVal;
            } else {
                $listReportMapResult1[$inx] = abs($lessVal);
            }
        }
        return [$nowListReportMap, $listReportMapResult, $listReportMapResult1];
    }

    public function getTop10List()
    {
        if (!Cache::has(CacheConstant::NOW_MONTH_KEY_WORDS_CACHE_KEY)) {
            $maxIdList = DB::connection('rank')
                ->table('project_history')
                ->selectRaw('max(id) as max_id')->where([
                    ['create_time', '>', strtotime(date('Y-m-01'))],
                    ['create_time', '<', strtotime(date('Y-m-t 23:59:59'))],
                ])->groupBy('project_id')->pluck('max_id')->toArray();

            $nowtMonthKeywords = DB::connection('rank')
                ->table('project_history')
                ->select('top10', 'project_id')->whereIn('id', $maxIdList)
                ->pluck('top10', 'project_id')->toArray();

            Cache::put(CacheConstant::NOW_MONTH_KEY_WORDS_CACHE_KEY, $nowtMonthKeywords, mt_rand(54000, 57600));
        }
        $nowtMonthKeywords = Cache::get(CacheConstant::NOW_MONTH_KEY_WORDS_CACHE_KEY) ?? [];

        if (!Cache::has(CacheConstant::LAST_MONTH_KEY_WORDS_CACHE_KEY)) {
            $maxIdList = DB::connection('rank')
                ->table('project_history')
                ->selectRaw('max(id) as max_id')->where([
                    ['create_time', '>', strtotime(date('Y-m-01', strtotime('first day of -1 month')))],
                    ['create_time', '<', strtotime(date('Y-m-t 23:59:59', strtotime('first day of -1 month')))],
                ])->groupBy('project_id')->pluck('max_id')->toArray();

            $lastMonthKeywords = DB::connection('rank')
                ->table('project_history')
                ->select('top10', 'project_id')->whereIn('id', $maxIdList)
                ->pluck('top10', 'project_id')->toArray();

            Cache::put(CacheConstant::LAST_MONTH_KEY_WORDS_CACHE_KEY, $lastMonthKeywords, mt_rand(54000, 57600));
        }
        $lastMonthKeywords = Cache::get(CacheConstant::LAST_MONTH_KEY_WORDS_CACHE_KEY) ?? [];

        $keywordDropResults = [];
        $keywordDropResults1 = [];

        foreach ($nowtMonthKeywords as $inx => $val) {
            $nowTop10 = $lastMonthKeywords[$inx] ?? 0;

            if ($nowTop10 > 0) {
                $lessVal = $val - $nowTop10;
                if ($lessVal > 0) {
                    $keywordDropResults1[$inx] = $lessVal;
                } else {
                    $keywordDropResults[$inx] = abs($lessVal);
                }
            }
        }
        return [$nowtMonthKeywords, $keywordDropResults, $keywordDropResults1];
    }

    public function getFlowList()
    {
        if (!Cache::has(CacheConstant::NOW_MONTH_FLOW_CACHE_KEY)) {
            $nowtMonthFlow = DB::connection('rank')
                ->table('webmaster_effect')
                ->selectRaw('SUM(clicks) as clicks,project_id')
                ->where(['ym' => date('Ym', strtotime('first day of -1 month'))])
                ->groupBy('project_id')
                ->get()->keyBy('project_id')->toArray();
            Cache::put(CacheConstant::NOW_MONTH_FLOW_CACHE_KEY, $nowtMonthFlow, mt_rand(54000, 57600));
        }
        $nowtMonthFlow = Cache::get(CacheConstant::NOW_MONTH_FLOW_CACHE_KEY);

        if (!Cache::has(CacheConstant::LAST_MONTH_FLOW_CACHE_KEY)) {
            $lastMonthFlow = DB::connection('rank')
                ->table('webmaster_effect')
                ->selectRaw('SUM(clicks) as clicks,project_id')
                ->where(['ym' => date('Ym', strtotime('first day of -2 month'))])
                ->groupBy('project_id')
                ->get()->keyBy('project_id')->toArray();
            Cache::put(CacheConstant::LAST_MONTH_FLOW_CACHE_KEY, $lastMonthFlow, mt_rand(54000, 57600));
        }
        $lastMonthFlow = Cache::get(CacheConstant::LAST_MONTH_FLOW_CACHE_KEY);

        $clicksDropResults = [];
        $clicksDropResults1 = [];

        foreach ($lastMonthFlow as $inx => $val) {

            $lastOne = $nowtMonthFlow[$inx] ?? null;
            if (empty($lastOne)) {
                continue;
            }
            $lessVal = $val->clicks - $lastOne->clicks;
            if ($lessVal > 0) {
                $clicksDropResults[$inx] = $lessVal;
            } else {
                $clicksDropResults1[$inx] = abs($lessVal);
            }
        }


        return [$nowtMonthFlow, $clicksDropResults, $clicksDropResults1];
    }

    public function getSpeedMeasurementList()
    {
        $pcSpeedMeasurement = [];
        $mobileSpeedMeasurement = [];

        $speedMeasurementList = DB::table('app_speed_measurement_cache')->get();
        foreach ($speedMeasurementList as $key => $value) {
            $array = json_decode($value->cache, true);
            if (!empty($array)) {
                $pcSpeedMeasurementResult = $array['pc'];
                $mobileSpeedMeasurementResult = $array['mobile'];

                $oldId = str_replace('cache:app/Http/Controllers/SpeedMeasurementController/index:', '', $value->key);

                $pcSpeedMeasurement[$oldId] = $pcSpeedMeasurementResult;
                $mobileSpeedMeasurement[$oldId] = $mobileSpeedMeasurementResult;
            }
        }
        return [$pcSpeedMeasurement, $mobileSpeedMeasurement];
    }

    public function indexExport(Request $request)
    {
        $user = auth()->user();
        list($sites, $items, $sortName, $sortOrder) = $this->indexBuild($request, $user, true);
        $items = $this->sitePublishList($items);
        list($nowListReportMap, $listReportMapResult, $listReportMapResult1) = $this->getInquireList();
        list($nowtMonthKeywords, $keywordDropResults, $keywordDropResults1) = $this->getTop10List();
        list($pcSpeedMeasurement, $mobileSpeedMeasurement) = $this->getSpeedMeasurementList();

        $list = [];
        foreach ($items as $site) {

            $list[] = [
                'statusTitle' => Site::STATUS_MAP[$site->status] ?? '',
                'cn_title' => $site->cn_title ?? '',
                'domain' => $site->domain ?? '',
                'pcSpeedMeasurement' => $pcSpeedMeasurement[$site->old_id] ?? '',
                'mobileSpeedMeasurement' => $mobileSpeedMeasurement[$site->old_id] ?? '',
                'traffic' => $nowListReportMap[$site->old_id]->traffic ?? '',
                'top10' => $nowtMonthKeywords[$site->old_id] ?? '',
                'inquire' => $nowListReportMap[$site->old_id]->inquire ?? '',
                'articles_count' => $site->articles_count ?? '',
                'link_details_count' => $site->link_details_count ?? '',
                'order_at' => $site->order_at ?? '',
                'server_title' => implode('-', $site->users->where('role_id', Role::TYPE_SERVER)->pluck('nickname')->toArray()),
                'online_date' => $site->online_at ?? '',
                'reach_at' => $site->reach_at ?? '',
            ];
        }

        array_unshift($list, ['项目状态', '项目过名称', '域名', 'pc端分数', '移动端分数', '月流量', '月排名', '询盘', '月软文', '月外链', '下单时间', '客服人员', '上线时间', '达标时间']);
        return (new BasicExport($list))->download(sprintf('项目汇总%s.xls', date('YmdHis')));
    }

    //站点添加和修改
    public function save(SiteSaveRequest $request, $id)
    {
        if (!$request->ajax()) {
            if ($id > 0) {
                $site = Site::query()->where(['id' => $id])->first();
                $payment = SitePayment::query()->where(['site_id' => $id])->first();
            }

            $businesses = Business::query()->get();

            return view('admin/site/save', [
                'data' => $site ?? null,
                'payment' => $payment ?? null,
                'businesses' => $businesses,
                'natures' => Site::NATURE_TYPE,
                'contracts' => Contract::all()
            ]);
        }

        return $this->logic->updateOrCreate($request->validated(), $id);
    }

    //客户完善信息
    public function customer(CustomerRequest $request, $id)
    {
        if (!$request->ajax()) {

            $condition = ['site_id' => $id];

            $view = 'admin/site/customer';

            return view($view, [
                'siteId' => $id,
                'additionData' => SiteAddition::query()->where($condition)->first(),
                'keywordData' => SiteInfo::query()->where($condition)->first(),
                'stationData' => SiteStation::query()->where($condition)->first(),
                'enterpriseData' => SiteEnterprise::query()->where($condition)->first(),
                'marketerData' => SiteMarketer::query()->where($condition)->first(),
                'snsData' => SiteSns::query()->where($condition)->first(),
                'businesses' => Business::all(),
                'natures' => Site::NATURE_TYPE
            ]);
        }
        return $this->logic->customerHandle($request->validated(), $request->input('act'), $request->input('source'), $id);
    }

    //针对客户界面 没有左边侧栏的
    public function customerNoSide(CustomerRequest $request)
    {
        $siteId = $request->input('siteId');
        if (!$siteId) {
            $site = $this->hasUserOneSite();

            if (!$site) {
                return view('admin/errors/tips');
            }
            $siteId = $site->id;
        }

        if (!$request->ajax()) {

            $condition = ['site_id' => $siteId];

            $view = 'admin/site/customer_no_side';

            return view($view, [
                'siteId' => $siteId,
                'additionData' => SiteAddition::query()->where($condition)->first(),
                'keywordData' => SiteInfo::query()->where($condition)->first(),
                'stationData' => SiteStation::query()->where($condition)->first(),
                'enterpriseData' => SiteEnterprise::query()->where($condition)->first(),
                'marketerData' => SiteMarketer::query()->where($condition)->first(),
                'snsData' => SiteSns::query()->where($condition)->first(),
                'businesses' => Business::all(),
                'natures' => Site::NATURE_TYPE
            ]);
        }
    }


    public function customerIdentify(Request $request)
    {
        $siteId = $request->input('siteId');
        $str = $this->encrypt($siteId);
        return response()->json(['data' => $str]);
    }

    //加密
    protected function encrypt($siteId)
    {
        $info = [
            'site_id' => $siteId,
            'expire_time' => strtotime('+1 week')
        ];
        $str = encodeStr(json_encode($info));
        return $str . "." . md5($str . "customer_salt");

    }

    //解密
    protected function decrypt($str)
    {
        $arr = explode('.', $str);

        if (count($arr) != 2) {
            return '失效链接';
        }

        if (md5($arr[0] . "customer_salt") != $arr[1]) {
            return '失败链接';
        }

        return json_decode(decodeStr($arr[0]), true);
    }

    //客户信息中的连接
    public function customerAlone(CustomerRequest $request)
    {
        $identify = $request->input('identify');
        $info = $this->decrypt($identify);
        if (!is_array($info)) {
            return view('admin/site/customer_error', [
                'message' => $info
            ]);
        }

        $siteId = $info['site_id'];
        $expired_time = $info['expire_time'];

        if ($expired_time < time()) {
            return view('admin/site/customer_error', [
                'message' => '链接失效'
            ]);
        }

        if (!$request->ajax()) {
            $condition = ['site_id' => $siteId];
            $view = 'admin/site/customer_alone';
            return view($view, [
                'siteId' => $siteId,
                'additionData' => SiteAddition::query()->where($condition)->first(),
                'keywordData' => SiteInfo::query()->where($condition)->first(),
                'stationData' => SiteStation::query()->where($condition)->first(),
                'enterpriseData' => SiteEnterprise::query()->where($condition)->first(),
                'marketerData' => SiteMarketer::query()->where($condition)->first(),
                'snsData' => SiteSns::query()->where($condition)->first(),
                'businesses' => Business::all(),
                'natures' => Site::NATURE_TYPE,
                'identify' => $identify
            ]);
        }
        return $this->logic->customerHandle($request->validated(), $request->input('act'), $request->input('source'), $siteId);
    }

    //导出 SNS 社交资料
    public function snsExport(Request $request)
    {
        $data = SiteSns::query()->where(['site_id' => $request->input('siteId')])->first();

        if ($data) {
            $records = [
                [
                    'youtube',
                    '展示url地址',
                    $data->youtube_url
                ], [
                    'youtube',
                    '用户名（登入邮箱）',
                    $data->youtube_account
                ], [
                    'youtube',
                    '密码：',
                    $data->youtube_password
                ], [
                    'Facebook',
                    '个人页面展示url地址：',
                    $data->facebook_my_url,
                ], [
                    'Facebook',
                    '企业page展示url地址',
                    $data->facebook_url,
                ], [
                    'Facebook',
                    '用户名（登入邮箱）',
                    $data->facebook_account,
                ], [
                    'Facebook',
                    '密码：',
                    $data->facebook_password,
                ], [
                    'Twitter',
                    '展示url地址:',
                    $data->twitter_url,

                ], [
                    'Twitter',
                    '用户名（登入邮箱）',
                    $data->twitter_account,
                ], [
                    'Twitter',
                    '密码',
                    $data->twitter_password,
                ], [
                    'Linkedin',
                    '个人页面展示url地址',
                    $data->linkedin_my_url,
                ], [
                    'Linkedin',
                    '企业page展示url地址',
                    $data->linkedin_url,
                ], [
                    'Linkedin',
                    '用户名（登入邮箱）',
                    $data->linkedin_account，
                ], [
                    'Linkedin',
                    '密码',
                    $data->linkedin_password,
                ], [
                    'Pinterst',
                    '展示url地址:',
                    $data->pinterst_url,
                ], [
                    'Pinterst',
                    '用户名（登入邮箱',
                    $data->pinterst_account,
                ], [
                    'Pinterst',
                    '密码',
                    $data->pinterst_password,
                ]
            ];
        } else {
            $records = [];
        }


        array_unshift($records, ['社交类型', '概览', '详细']);

        return (new BasicExport($records))->download(sprintf('sns信息%s.xls', date('YmdHis')));
    }

    //批量删除
    public function batchDestroy(Request $request)
    {

        $ids = $request->input('ids');

        $oldSiteIds = Site::query()->whereIn('id', $ids)->pluck('old_id')->filter()->toArray();
        Site::destroy($ids);

        //同步老rank平台的数据
        $siteSync = new SiteSyncLogic();
        $siteSync->delete($oldSiteIds);

        return response()->json(['message' => '操作成功']);
    }

    //填写款项节点
    public function payment(PaymentRequest $request, $id)
    {
        if (!$request->ajax()) {
            $payment = SitePayment::query()->where(['site_id' => $id])->first();
            return view('admin/site/payment', [
                'data' => $payment ?? null,
                'siteId' => $id
            ]);
        }

        SitePayment::query()->updateOrCreate([
            'site_id' => $id
        ], $request->validated());
        return response()->json(['message' => '操作成功']);
    }

    /**
     * 项目概览
     * @param SiteOverviewRequest $request
     * @param $id
     * @return View\Factory|JsonResponse|\Illuminate\View\View
     */
    public function overview(SiteOverviewRequest $request, $id)
    {

        if (!$request->ajax()) {
            $site = Site::query()->with(['users'])->where('id', $id)->first();
            if (!$site) {
                return view('admin/site/tips', [
                    'tips' => '站点信息不存在',
                    'siteId' => $id
                ]);
            }
            if ($site) {
                $single['hasServerIds'] = $site->users->where('role_id', Role::TYPE_SERVER)->pluck('id')->toArray();
                $single['hasEditorIds'] = $site->users->where('role_id', Role::TYPE_AE)->pluck('id')->toArray();
                $single['hasMangerIds'] = $site->users->where('role_id', Role::TYPE_MANAGER)->pluck('id')->toArray();
                $single['hasBidIds'] = $site->users->whereIn('role_id', [Role::TYPE_BID, Role::TYPE_BIDDING_MANAGER])->pluck('id')->toArray();
                $single['hasSellerIds'] = $site->users->where('role_id', Role::TYPE_SELLER)->pluck('id')->toArray();
                $single['hasMangeHelpIds'] = $site->users->where('role_id', Role::TYPE_MANAGE_HELPER)->pluck('id')->toArray();
                $single['hasOptimizerIds'] = $site->users->where('role_id', Role::TYPE_OPTIMIZER)->pluck('id')->toArray();
                $single['hasWebIds'] = $site->users->where('role_id', Role::TYPE_WEB)->pluck('id')->toArray();
                $single['hasDesignerIds'] = $site->users->where('role_id', Role::TYPE_DESIGNER)->pluck('id')->toArray();
                $single['hasPropagandaIds'] = $site->users->where('role_id', Role::TYPE_SOFT_TEXT_SEARCH)->pluck('id')->toArray();
                /*$single['hasPlannerIds'] = $site->users->where('role_id', Role::TYPE_PLANNER)->pluck('id')->toArray();*/
                $single['hasExternalLinkIds'] = $site->users->where('role_id', Role::TYPE_LINK)->pluck('id')->toArray();
                $single['hasChongqingLinkIds'] = $site->users->where('role_id', Role::TYPE_LINK_PART_CHONGQING)->pluck('id')->toArray();
                $single['hasArticleIds'] = $site->users->where('role_id', Role::TYPE_ARTICLE)->pluck('id')->toArray();
                $single['hasOptimizationEditing'] = $site->users->where('role_id', Role::TYPE_OPTIMIZATION_EDITING)->pluck('id')->toArray();
            }

            return view('admin/site/overview', [
                    'roles' => $user = auth()->user(),
                    'siteInfo' => SiteInfo::query()->where(['site_id' => $id])->first(),
                    'siteId' => $id,
                    'data' => $site ?? null,
                    'enterpriseNature' => explode(',', $site->enterprise_nature) ?? [],
                    'case_ids' => explode(',', $site->case_ids) ?? [],
                    'businesses' => Business::query()->orderBy('sort')->get(),
                    'natures' => Site::NATURE_TYPE,
                    'contracts' => Contract::all(),
                    'servers' => Server::all(), //服务器
                    'article' => Role::getUsers(Role::TYPE_ARTICLE), //软文
                    'services' => Role::getUsers(Role::TYPE_SERVER), //服务人员
                    'editors' => Role::getUsers(Role::TYPE_AE),
                    'managers' => Role::getUsers(Role::TYPE_MANAGER),
                    'managerHelpers' => Role::getUsers(Role::TYPE_MANAGE_HELPER),
                    'planner' => Role::getUsers(Role::TYPE_PLANNER),
                    'propaganda' => Role::getUsers(Role::TYPE_SOFT_TEXT_SEARCH),//软文查找人员
                    'optimizers' => Role::getUsers(Role::TYPE_OPTIMIZER),
                    'bidUsers' => User::query()->whereIn('role_id', [Role::TYPE_BIDDING_MANAGER, Role::TYPE_BID])->get(),
                    'sellerUsers' => Role::getUsers(Role::TYPE_SELLER),
                    'webUsers' => Role::getUsers(Role::TYPE_WEB),
                    'designers' => Role::getUsers(Role::TYPE_DESIGNER),
                    'externalLink' => Role::getUsers(Role::TYPE_LINK),
                    'chongqingLink' => Role::getUsers(Role::TYPE_LINK_PART_CHONGQING),//重庆外链兼职
                    'optimizationEditing' => Role::getUsers(Role::TYPE_OPTIMIZATION_EDITING),
                    'payment' => SitePayment::query()->where(['site_id' => $id])->first(),
                    'facebookSocial' => Social::query()->where(['type' => Social::FACEBOOK])->first()
                ] + ($single ?? ['hasServerIds' => [], 'hasEditorIds' => [], 'hasMangerIds' => []]) +
                Social::query()->where(['site_id' => $id])->get()->keyBy('type')->toArray() + // 社交信息
                ['linkedBaseInfo' => Social::query()->where(['site_id' => 0, 'type' => Social::LINKED])->first()] +
                ['optimizePage' => SiteOptimizePage::query()->where(['site_id' => $id])->get()->toArray()]
            );
        }

        return $this->logic->overview($id, $request->validated(), $request->input('type'));

    }

    //账号保存
    public function accountSave(Request $request, $siteId)
    {
        $adminAccount = $request->input('adminAccount');
        $adminPass = $request->input('adminPass');
        $userAccount = $request->input('userAccount');
        $userPass = $request->input('userPass');
        $appAccount = $request->input('appAccount');
        $appPass = $request->input('appPass');

        if (SiteInfo::query()->where(['site_id' => $siteId])->exists()) {
            SiteInfo::query()->where(['site_id' => $siteId])->update([
                'admin_account' => $adminAccount,
                'admin_pass' => $adminPass,
                'user_account' => $userAccount,
                'user_pass' => $userPass,
                'app_account' => $appAccount,
                'app_pass' => $appPass,
            ]);
        } else {
            SiteInfo::query()->create([
                'site_id' => $siteId,
                'admin_account' => $adminAccount,
                'admin_pass' => $adminPass,
                'user_account' => $userAccount,
                'user_pass' => $userPass,
                'app_account' => $appAccount,
                'app_pass' => $appPass,
            ]);
        }

        return response()->json(['message' => '操作成功']);
    }

    //优化页保存
    public function optimizePageSave(Request $request, $siteId)
    {
        $groupData = $request->input('groupData');

        if (!is_array($groupData)) {
            $groupData = [];
        }

        $optimizePageIds = SiteOptimizePage::query()->where(['site_id' => $siteId])->pluck('id')->toArray();

        $newIds = array_filter(array_column($groupData, 'id'));

        foreach ($groupData as $item) {
            if (!isset($item['id'])) {
                continue;
            }

            if (!$item['id']) {
                SiteOptimizePage::query()->create([
                    'site_id' => $siteId,
                    'keyword' => $item['keyword'] ?? '',
                    'url' => $item['url'] ?? '',
                    'is_optimize' => !$item['is_optimize'] ? 0 : 1
                ]);
            } else {
                SiteOptimizePage::query()->where(['id' => $item['id']])->update([
                    'keyword' => $item['keyword'] ?? '',
                    'url' => $item['url'] ?? '',
                    'is_optimize' => !$item['is_optimize'] ? 0 : 1
                ]);
            }
        }

        $diffIds = array_diff($optimizePageIds, $newIds);
        if ($diffIds) {
            SiteOptimizePage::query()->whereIn('id', $diffIds)->delete();
        }


        return response()->json(['message' => '操作成功']);
    }

    //导入优化页
    public function importOptimizePage(Request $request)
    {
        set_time_limit(0);
        $siteId = $request->input('siteId');

        if (!$request->input('excel_path') || !$siteId) {
            return response()->json(['message' => '请先上传excel文件'], 422);
        }
        try {
            Excel::import(new OptimizePageImport($siteId), $request->input('excel_path'), 'public');
        } catch (\Throwable $throwable) {
            Log::error(var_export($throwable->getMessage(), 1));
            return response()->json(['message' => '导入失败'], 400);
        }
        return response()->json(['message' => '操作成功']);

    }

    //导出优化页
    public function exportOptimizePage(Request $request)
    {
        $siteId = $request->input('siteId');

        $results = SiteOptimizePage::query()->select(['keyword', 'url', 'is_optimize'])->where(['site_id' => $siteId])->get()->toArray();

        foreach ($results as &$result) {
            if (!empty($result['is_optimize'])) {
                $result['is_optimize'] = '是';
            } else {
                $result['is_optimize'] = '否';
            }
        }
        array_unshift($results, ['关键词', 'url地址', '是否优化']);

        return (new BasicExport($results))->download(sprintf('重点优化%s.xls', date('YmdHis')));
    }

    /**
     * 客户界面项目概览
     * @param SiteOverviewRequest $request
     * @return \Illuminate\Contracts\View\Factory|\Illuminate\Http\JsonResponse|\Illuminate\View\View
     */
    public function customerOverview(SiteOverviewRequest $request)
    {
        $userSite = $this->hasUserOneSite();
        if (!$userSite) {
            return view('admin/errors/tips', [
                'tips' => '站点信息不存在'
            ]);
        }
        $id = $userSite->id;

        if (!$request->ajax()) {
            $site = Site::query()->with(['users'])->where('id', $id)->first();
            if (!$site) {
                return view('admin/errors/tips', [
                    'tips' => '站点信息不存在'
                ]);
            }

            if ($site) {
                $single['hasServerIds'] = $site->users->where('role_id', Role::TYPE_SERVER)->pluck('id')->toArray();
                $single['hasEditorIds'] = $site->users->where('role_id', Role::TYPE_AE)->pluck('id')->toArray();
                $single['hasMangerIds'] = $site->users->where('role_id', Role::TYPE_MANAGER)->pluck('id')->toArray();
                $single['hasBidIds'] = $site->users->whereIn('role_id', [Role::TYPE_BID, Role::TYPE_BIDDING_MANAGER])->pluck('id')->toArray();
                $single['hasSellerIds'] = $site->users->where('role_id', Role::TYPE_SELLER)->pluck('id')->toArray();
                $single['hasMangeHelpIds'] = $site->users->where('role_id', Role::TYPE_MANAGE_HELPER)->pluck('id')->toArray();
                $single['hasOptimizerIds'] = $site->users->where('role_id', Role::TYPE_OPTIMIZER)->pluck('id')->toArray();
                $single['hasWebIds'] = $site->users->where('role_id', Role::TYPE_WEB)->pluck('id')->toArray();
                $single['hasDesignerIds'] = $site->users->where('role_id', Role::TYPE_DESIGNER)->pluck('id')->toArray();
                $single['hasPropagandaIds'] = $site->users->where('role_id', Role::TYPE_SOFT_TEXT_SEARCH)->pluck('id')->toArray();
                /*$single['hasPlannerIds'] = $site->users->where('role_id', Role::TYPE_PLANNER)->pluck('id')->toArray();*/
                $single['hasExternalLinkIds'] = $site->users->where('role_id', Role::TYPE_LINK)->pluck('id')->toArray();
                $single['hasChongqingLinkIds'] = $site->users->where('role_id', Role::TYPE_LINK_PART_CHONGQING)->pluck('id')->toArray();
                $single['hasArticleIds'] = $site->users->where('role_id', Role::TYPE_ARTICLE)->pluck('id')->toArray();
                $single['hasOptimizationEditing'] = $site->users->where('role_id', Role::TYPE_OPTIMIZATION_EDITING)->pluck('id')->toArray();
            }

            return view('admin/site/customer_overview', [
                    'siteId' => $id,
                    'data' => $site ?? null,
                    'businesses' => Business::all(),
                    'natures' => Site::NATURE_TYPE,
                    'contracts' => Contract::all(),
                    'servers' => Server::all(), //服务器
                    'article' => Role::getUsers(Role::TYPE_ARTICLE), //软文
                    'services' => Role::getUsers(Role::TYPE_SERVER), //服务人员
                    'editors' => Role::getUsers(Role::TYPE_AE),
                    'managers' => Role::getUsers(Role::TYPE_MANAGER),
                    'managerHelpers' => Role::getUsers(Role::TYPE_MANAGE_HELPER),
                    'planner' => Role::getUsers(Role::TYPE_PLANNER),
                    'propaganda' => Role::getUsers(Role::TYPE_SOFT_TEXT_SEARCH),//软文查找人员
                    'optimizers' => Role::getUsers(Role::TYPE_OPTIMIZER),
                    'bidUsers' => User::query()->whereIn('role_id', [Role::TYPE_BIDDING_MANAGER, Role::TYPE_BID])->get(),
                    'sellerUsers' => Role::getUsers(Role::TYPE_SELLER),
                    'webUsers' => Role::getUsers(Role::TYPE_WEB),
                    'designers' => Role::getUsers(Role::TYPE_DESIGNER),
                    'externalLink' => Role::getUsers(Role::TYPE_LINK),
                    'chongqingLink' => Role::getUsers(Role::TYPE_LINK_PART_CHONGQING),//重庆外链兼职
                    'optimizationEditing' => Role::getUsers(Role::TYPE_OPTIMIZATION_EDITING),
                    'payment' => SitePayment::query()->where(['site_id' => $id])->first(),
                    'facebookSocial' => Social::query()->where(['type' => Social::FACEBOOK])->first()
                ] + ($single ?? ['hasServerIds' => [], 'hasEditorIds' => [], 'hasMangerIds' => []]) +
                Social::query()->where(['site_id' => $id])->get()->keyBy('type')->toArray() // 社交信息
            );
        }

        return $this->logic->overview($id, $request->validated(), $request->input('type'));

    }


    //项目概况下的 修改bid状态
    public function changeBidStatus(Request $request, $id)
    {
        $bidStatus = $request->input('bidStatus');
        Site::query()->where(['id' => $id])->update(['bid_status' => $bidStatus]);
        return response()->json(['message' => '操作成功']);
    }

    //项目概况下的  是否特殊软文
    public function changeSpecArticle(Request $request, $siteId)
    {
        $spec_article = $request->input('spec_article');
        Site::query()->where(['id' => $siteId])->update(['spec_article' => $spec_article]);
        return response()->json(['message' => '操作成功']);
    }

    ///项目概况下的  是否cdn
    public function changeCDNStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['is_cdn' => $status]);
        return response()->json(['message' => '操作成功']);
    }

    ///项目概况下的 是否退款
    public function changeRefundStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['is_refund' => $status]);
        return response()->json(['message' => '操作成功']);
    }

    ///项目概况下的  域名是否我们购买
    public function changeDomainStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['domain_us_buy' => $status]);
        return response()->json(['message' => '操作成功']);
    }

    //项目概况下的  是否网站续费
    public function changeRenewStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['is_renew' => $status]);
        return response()->json(['message' => '操作成功']);
    }

    //项目概况下的  当月上线目标
    public function changeOnlineStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['is_current_month_online' => $status, 'current_month_online_date' => date('Y-m-t 23:59:59')]);
        return response()->json(['message' => '操作成功']);
    }

    //项目概况下的  证书是否我们购买
    public function changeCertStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['cert_us_buy' => $status]);
        return response()->json(['message' => '操作成功']);
    }

    //项目概况下的  是否案例
    public function changeCaseStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['is_case' => $status]);
        return response()->json(['message' => '操作成功']);
    }

    //项目概况下的  是否百千
    public function changeBqStatus(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['is_bq' => $status]);
        return response()->json(['message' => '操作成功']);
    }


    //项目概况下的  软文是否暂停
    public function articlePause(Request $request, $id)
    {
        $status = $request->input('status');
        Site::query()->where(['id' => $id])->update(['article_pause' => $status]);
        return response()->json(['message' => '操作成功']);
    }

    //社交授权 没啥用了  hootsuite代替
    public function socialSave(SocialSaveRequest $request, $siteId)
    {
        $type = $request->input('type');
        $validated = $request->validated()[$type];
        switch ($type) {
            case 'facebook':
                Site::query()->where(['id' => $siteId])->update([
                    'facebook_page' => $validated['facebook_page']
                ]);
                break;
            case 'linkedIn':
            case 'pin':
                Social::query()->updateOrCreate(['site_id' => $siteId, 'type' => $type], $validated);
                break;
        }

        return response()->json(['message' => '操作成功']);
    }

    //社交发布
    public function socialPublish(SocialPublishRequest $request, $id)
    {
        $site = Site::query()->with(['server'])->select(['domain', 'id', 'server_id', 'database', 'webmaster_domain'])->where(['id' => $id])->first();
        if (empty($site->database)) {
            if ($request->ajax()) {
                return response()->json(['message' => '站点数据库信息不存在'], 400);
            } else {
                return view('admin/site/tips', [
                    'tips' => '站点数据库信息不存在',
                    'siteId' => $id,
                ]);
            }
        }

        if (empty($site->server)) {
            if ($request->ajax()) {
                return response()->json(['message' => '站点服务器未分配'], 400);
            } else {
                return view('admin/site/tips', [
                    'tips' => '站点服务器未分配',
                    'siteId' => $id,
                ]);
            }
        }

        try {
            $config = [
                'connection_name' => sprintf('connection_name_%s', $id),
                'host' => $site->server->server_ip,
                'port' => '3306',
                'database' => $site->database,
                'username' => $site->server->mysql_user_name,
                'password' => $site->server->mysql_passwd,
            ];
            config_connection($config);
            $connection = DB::connection($config['connection_name']);

            $publishedMaps = HootsuiteHistory::query()->where(['site_id' => $site->id])->pluck('remote_content_id')->toArray();

            if (!$request->ajax()) {

                $cacheKey = 'socialPublish_' . $site->id;
                if (!Cache::has($cacheKey)) {

                    $start = 0;
                    $count = 100;
                    $list = [];

                    while (true) {
                        $orders = $connection->table('content')->where(['lang' => 'en', 'is_hidemenu' => 0])
                            ->selectRaw('id,parent_id,title,thumb,summary,subtitle,uri')
                            ->skip($start)->take($count)->get();

                        foreach ($orders as $order) {
                            $data = [
                                'id' => $order->id,
                                'parent_id' => $order->parent_id,
                                'name' => $order->title,
                                'thumb' => $order->thumb,
                                'summary' => $order->summary,
                                'subtitle' => $order->subtitle,
                                'uri' => $order->uri,
                            ];
                            $list[] = $data;
                        }

                        if (count($orders) < $count) break;
                        $start += $count;
                    }
                    Cache::put($cacheKey, $list, 600);
                }
                $records = Cache::get($cacheKey);

                foreach ($records as &$record) {
                    if (in_array($record['id'], $publishedMaps)) {
                        $record['name'] = '【已发布】' . $record['name'];
                    }
                }

                $trees = list_to_tree($records, 'id', 'parent_id', 'children');

                $hootsuiteUser = HootsuiteUser::query()->where(['site_id' => $id])->first();

                if (!$hootsuiteUser) {
                    return view('admin/site/tips', [
                        'tips' => '站点hootsuite未指定',
                        'siteId' => $id,
                    ]);
                }
                $label = DB::table('social_label')->where('site_id', $id)->pluck('label', 'id');
				//账号切换
                $number_list = HootsuiteUser::all()->where('site_id', $id);
                $hootsuiteUser_count = HootsuiteUser::query()->where(['site_id' => $id])->count();
                if($hootsuiteUser_count>'1'){
                    $hootsuiteUser_style = 'inline';
                }else{
                    $hootsuiteUser_style = 'none';
                }
                return view('admin/site/social_publish', [
                    'trees' => $trees,
                    'siteId' => $id,
                    'site' => $site,
                    'socialProfiles' => $hootsuiteUser->social_profiles ?? [],
                    'labelList' => $label ?? [],
                    'number_list'=>$number_list,
                    'hootsuiteUser_style'=>$hootsuiteUser_style,
                ]);
            }

            //return $this->logic->socialPublish($request->validated(), $connection, $site);
            return $this->logic->socialPublish($request->validated(), $connection, $site,$request->input('hootsuiteUser_id'));

        } catch (\Throwable $exception) {
            return view('admin/site/tips', [
                'tips' => '远端的数据库链接或配置有误！ http://test.build.yinqingli.net/admin',
                'siteId' => $id,
            ]);
        }

    }

	public function AjaxSocialProfiles(Request $request)
    {
        $HootsuiteUserId = $request->input('HootsuiteUserId');
        $hootsuiteUser = HootsuiteUser::query()->where(['id' => $HootsuiteUserId])->first();
        //var_dump($hootsuiteUser->social_profiles);
        $data = '';
        if(!empty($hootsuiteUser->social_profiles)){
            foreach ($hootsuiteUser->social_profiles as $value){
                $data.="<option value=\"".$value['id']."\">".$value['type']."--".$value['socialNetworkUsername']."</option>";
            }
        }
        if(empty($data)){
            return response()->json(['message' => '操作失败','status'=>100]);
        }else{
            return response()->json(['message' => '操作成功','data'=>$data,'status'=>200]);
        }


    }
    public function socialUpdate(Request $request, $siteId)
    {
        pre_dump($request);
        pre_dump($siteId);
        die;

    }

    //社交队列 后面被hootsutie 方式代替
    public function socialQueue(Request $request, $siteId)
    {

        if (!$request->ajax()) {


//            $client = new Client();
//            $url = sprintf('%s/admin/hootsuite/social-list', config('app.wall_url'));
//            try {
//
//                $response = $client->request('GET', $url);
//                $result = json_decode($response->getBody()->getContents(), true);
//                $socialList = $result['data']??[];
//            } catch (\GuzzleHttp\Exception\GuzzleException $exception) {
//                $socialList = [];
//            }


            return view('admin/site/social_queue', [
                'siteId' => $siteId,
                'socialList' => $socialList ?? []
            ]);
        }
        $records = SocialPublish::query()->where(['site_id' => $siteId])->orderBy('id', 'desc')->paginate($request->input('pageSize') ?? TABLE_PAGE_SIZE);
        $items = $records->items();
        array_walk($items, function ($item) {
            $item->is_published = $item->social_sync_at ? '已发布' : '未发布';
            $item->content = str_limit($item->content, 20);

            $resultStatus = $item->result_status ?? [];

            $item->published_result = sprintf(
                'pin:%s twitter:%s facebook:%s',
                (SocialPublish::STATUS_TITLE[($resultStatus['pin'] ?? null)] ?? ''),
                (SocialPublish::STATUS_TITLE[($resultStatus['twitter'] ?? null)] ?? ''),
                (SocialPublish::STATUS_TITLE[($resultStatus['facebook'] ?? null)] ?? '')
            );

        });

        return response()->json([
            'rows' => $items,
            'total' => $records->total()
        ]);

    }


    public function socialMetastasis($siteId)
    {
        $list = SocialPublish::query()->where('site_id', $siteId)->get();
        HootsuiteHistory::query()
            ->where('site_id', $siteId)
            ->delete();
        $array = [];
        foreach ($list as $key => $value) {
            $data = [
                'site_id' => $value->site_id,
                'remote_content_id' => $value->remote_content_id,
                'content' => $value->content ?? '',
                'url' => $value->url ?? '',
                'media' => $value->media ?? '',
                'publish_at' => $value->publish_at,
                'created_at' => $value->created_at,
            ];
            $array[] = $data;
        }
        HootsuiteHistory::query()->insert($array);

        return response()->json(['message' => '操作成功']);
    }

    //自定义
    public function socialQueueSave(SocialQueueRequest $request, $socialQueueId)
    {
        $siteId = $request->input('siteId');
        if (!$request->ajax()) {
            $data = SocialPublish::query()->find($socialQueueId);
            $label = DB::table('social_label')->where('site_id', $siteId)->pluck('label', 'id');

            //$hootSuiteUser = HootsuiteUser::query()->where(['site_id' => $siteId])->first();
            if(!empty($request->input('sid'))){
                $hootSuiteUser = HootsuiteUser::query()->where(['id' => $request->input('sid')])->first();
            }else{
                $hootSuiteUser = HootsuiteUser::query()->where(['site_id' => $siteId])->first();
            }
            if (!$hootSuiteUser) {
                return view('admin/site/tips', [
                    'tips' => '站点hootsuite未指定',
                    'siteId' => $siteId,
                ]);
            }

            return view('admin/site/social_queue_save', [
                'data' => $data ?? null,
                'siteId' => $siteId,
                'boards' => $boardList ?? [],
                'boardsErr' => $boardsErr ?? null,
                'labelList' => $label ?? [],
                'socialProfiles' => $hootSuiteUser->social_profiles ?? [],
            ]);
        }

        $validated = $request->validated();

        $publishAt = date('Y-m-d H:i:s', strtotime('+' . $validated['release_interval'] . ' day', strtotime($validated['publish_at'])));
        if (strtotime($publishAt) < (time() + 60 * 10)) {
            return response()->json(['message' => '发布时间距离当前时间过近或小于当前时间'], 400);
        }

        $url = sprintf('%s/admin/hootsuite/schedule-message', config('app.wall_url'));
        try {

            $client = new Client();
            $response = $client->request('POST', $url, [
                'form_params' => [
                    'siteId' => $siteId,
                    'socialIds' => $validated['social_ids'],
                    'remoteImg' => $validated['media'],
                    'content' => $validated['content'],
                    'sendAt' => $validated['publish_at'],
                ]
            ]);

            if ($response->getStatusCode() != 200) {
                return response()->json(['message' => "发送失败"], 400);
            }
            $result = json_decode($response->getBody()->getContents(), true);

            if (!empty($result['errors'])) {
                return response()->json(['message' => ($result['errors'][0]['message'] ?? 'schedule error')], 400);
            }

            $updateData = [
                'site_id' => $siteId,
                'media' => $validated['media'],
                'url' => $validated['url'],
                'content' => $validated['content'],
                'result' => json_encode($result['data'] ?? []),
                'publish_at' => $validated['publish_at'],
                'created_at' => date('Y-m-d H:i:s'),
            ];
            SocialPublish::query()->insert($updateData);

            $hootSuiteUser = HootsuiteUser::query()->where(['id' => $siteId])->first();
            $socialProfiles = $hootSuiteUser->social_profiles ?? [];
            $mapSocialProfiles = array_column($socialProfiles, null, 'id');
            $tempSocialProfiles = [];
            foreach ($mapSocialProfiles as $key => $item) {
                if (in_array($key, $validated['social_ids'])) {
                    $tempSocialProfiles[] = $item;
                }
            }
            $queues = [
                'site_id' => $siteId,
                'remote_content_id' => 0,
                'media' => $validated['media'],
                'url' => $validated['url'],
                'content' => $validated['content'],
                'created_at' => date('Y-m-d H:i:s'),
                'updated_at' => date('Y-m-d H:i:s'),
                'publish_at' => $validated['publish_at'],
                'social_ids' => json_encode($validated['social_ids'] ?? []),
                'social_profiles' => json_encode($tempSocialProfiles ?? []),
                'result' => json_encode($result['data'] ?? []),
            ];
            HootsuiteHistory::query()->insert($queues);
            return response()->json(['message' => '操作成功']);

        } catch (\GuzzleHttp\Exception\GuzzleException $exception) {
            Log::error(var_export($exception->getMessage(), 1));
            return response()->json(['message' => '发布失败'], 400);
        }
    }


    public function socialQueueDel($socialQueueId)
    {
        SocialPublish::destroy($socialQueueId);
        return response()->json(['message' => '操作成功']);
    }

    //项目管理详情下的 hootsuite记录
    public function hootsuiteHistory(Request $request, $siteId)
    {
        if (!$request->ajax()) {

            return view('admin/site/hootsuite_history', [
                'siteId' => $siteId,
                'socialList' => $socialList ?? []
            ]);
        }

        $hUser = HootsuiteUser::query()->where(['site_id' => $siteId])->first();
        $records = HootsuiteHistory::query()->where(['site_id' => $siteId])
            ->orderBy('publish_at', 'desc')
            ->paginate($request->input('pageSize') ?? TABLE_PAGE_SIZE);
        $items = $records->items();

        $socialProfiles = $hUser->social_profiles ?? [];
        foreach ($items as $item) {
            $item->publishStatus = '失败';
            $item->content = str_limit($item->content, 30);
            /**付饶修改新的**/
            $new_hUser = HootsuiteUser::query()->where(['site_id' => $siteId])->select();
            $new_hUser = HootsuiteUser::all()->where('site_id', $siteId);
            $ids_new = $item->social_ids ?? [];
            $type_name = '';
            foreach ($new_hUser as $value){

                foreach ($value->social_profiles as $val) {
                    if (in_array($val['id'], $ids_new)) {
                        $type_name .= $val['type'] . ' ';
                    }
                }
            }
            $item->profileStr =$type_name;
            /**付饶修改新的**/
//            $ids = $item->social_ids ?? [];
//            $profileStr = '';
//            foreach ($socialProfiles as $val) {
//                if (in_array($val['id'], $ids)) {
//                    $profileStr .= $val['type'] . ' ';
//                }
//            }
            //$item->profileStr = $profileStr;
            if (!empty($item->result)) {
                $item->publishStatus = '成功';
            }
        }

        return response()->json([
            'rows' => $items,
            'total' => $records->total()
        ]);
    }

    public function siteListExport()
    {
        $siteList = Site::query()->whereIn('status', [1, 2, 3])->select('cn_title', 'old_id', 'domain', 'status')->get()->toJson();
        $siteList = \GuzzleHttp\json_decode($siteList, true);

        $top10ListMapCacheKey = 'top10ListMap_cache_key';
        $top10ListMap = Cache::get($top10ListMapCacheKey);

        $listReportMap_cache_key = 'listReportMap_cache_key';
        $listReportMap = Cache::get($listReportMap_cache_key);

        foreach ($siteList as $key => $value) {

            $siteList[$key]['top10'] = '';
            $siteList[$key]['traffic'] = '';
            $siteList[$key]['inquire'] = '';

            foreach ($top10ListMap as $kk => $vv) {
                if (!empty($value['old_id'] && $value['old_id'] == $vv->project_id)) {
                    $siteList[$key]['top10'] = $vv->top10;
                }
            }

            foreach ($listReportMap as $kk => $vv) {
                if (!empty($value['old_id'] && $value['old_id'] == $vv->project_id)) {
                    $siteList[$key]['traffic'] = $vv->traffic;
                }
                if (!empty($value['old_id'] && $value['old_id'] == $vv->project_id)) {
                    $siteList[$key]['inquire'] = $vv->inquire;
                }
            }
            if ($value['status'] == 1) {
                $siteList[$key]['status'] = '建站期';
            }
            if ($value['status'] == 2) {
                $siteList[$key]['status'] = '实施期';
            }
            if ($value['status'] == 3) {
                $siteList[$key]['status'] = '服务期';
            }
        }
        $dataList = [];
        $dataList[] = ['项目名称', '网址', '项目状态', '月排名', '月流量', '询盘'];
        foreach ($siteList as $key => $value) {
            unset($value['old_id']);
            $dataList[] = $value;
        }
        return (new BasicExport($dataList))->download(sprintf('项目流量统计%s.xls', date('YmdHis')));

    }


    public function socialTemplateImport(Request $request, $id)
    {
        set_time_limit(0);
        if (!$request->input('excel_path')) {
            return response()->json(['message' => '请先上传excel文件'], 422);
        }
        $site = Site::query()->where(['id' => $id])->first();
        if (!$site) {
            return response()->json(['message' => '站点信息不存在'], 400);
        }
        if (!$site->old_id) {
            return response()->json(['message' => '请先与rank项目关联'], 400);
        }
        try {
            Excel::import(new SocialImport($site->id), $request->input('excel_path'), 'public');
        } catch (\Throwable $throwable) {
            Log::error(var_export($throwable->getMessage(), 1));
            return response()->json(['message' => '导入失败'], 400);
        }
        return response()->json(['message' => '操作成功']);
    }


    public function socialMessageListImport(Request $request)
    {
        set_time_limit(0);
        if (!$request->input('excel_path')) {
            return response()->json(['message' => '请先上传excel文件'], 422);
        }
        try {
            Excel::import(new SocialMessageListImport(), $request->input('excel_path'), 'public');
            return response()->json(['message' => '操作成功']);

        } catch (\Throwable $throwable) {

            return response()->json(['message' => $throwable->getMessage()], 400);
        }
    }

    //单个项目测速
    public function getSpeedMeasurementCacheResult($siteId)
    {
        try {

            $site = Site::query()->where('id', $siteId)->first();

            $pcResult = $this->apiResult(self::PC_SPEED_MEASUREMENT, $site->webmaster_domain);
            $data['pc'] = '';
            $result = $pcResult['lighthouseResult']['categories']['performance']['score'] ?? '';
            if (!empty($result)) {
                $data['pc'] = intval(round(floatval($result) * 100));
            }

            $data['mobile'] = '';
            $mobileResult = $this->apiResult(self::MOBILE_SPEED_MEASUREMENT, $site->webmaster_domain);
            $result1 = $mobileResult['lighthouseResult']['categories']['performance']['score'] ?? '';
            if (!empty($result1)) {
                $data['mobile'] = intval(round(floatval($result1) * 100));
            }
            $key = 'cache:app/Http/Controllers/SpeedMeasurementController/index:' . $site->old_id;

            if (!empty($data['pc']) || !empty($data['mobile'])) {
                DB::table('app_speed_measurement_cache')->where('key', $key)->delete();
                DB::table('app_speed_measurement_cache')->insert(['cache' => \GuzzleHttp\json_encode($data), 'key' => $key]);
            }
            return response()->json(['code' => 200, 'message' => '操作成功']);

        } catch (\Throwable $exception) {
            return response()->json(['message' => $exception->getMessage()], 400);
        }
    }

    public function apiResult($api, $url)
    {
        $client = new Client();
        $response = $client->request('GET', $api . $url);
        $response = json_decode($response->getBody()->getContents(), true);
        return $response;
    }

    public function isComponent(Request $request, $siteId)
    {
        $type = $request->input('type') ?? 0;
        Site::query()->where('id', $siteId)->update(['is_component' => $type]);
        return response()->json(['message' => '操作成功']);

    }

    public function downloadSiteFile(Request $request)
    {
        $siteId = $request->input('siteId') ?? '';
        $siteInfo = Site::query()->where('id', $siteId)->first();

        if (empty($siteInfo->business_license_business_scope)) {
            die('暂无文件');
        }
        $pathInfo = pathinfo($siteInfo->business_license_business_scope);
        $dirnamePath = explode('storage', $pathInfo['dirname']);
        return response()->download(realpath(base_path('public')) . '/storage' . $dirnamePath[1] . '/' . $pathInfo['basename'], $pathInfo['basename']);
    }
}