test/app/Http/Controllers/Admin/Flow/ProgressRateController.php

<?php
/**
 * 建站期进度管理
 * @copyright 2021-浙江引擎力营销策划有限公司
 * @author Lc<sunshinecc1@163.com>
 * @since 2021-08-01
 */

namespace App\Http\Controllers\Admin\Flow;

use App\Exports\BasicExport;
use App\Exports\BqProgressRateExport;
use App\Exports\EditingScheduleExport;
use App\Exports\PlannerScheduleExport;
use App\Exports\ProgressRateExport;
use App\Http\Controllers\Controller;
use App\Http\Models\BqProjectProgress;
use App\Http\Models\FlowInfo;
use App\Http\Models\FlowStage;
use App\Http\Models\Mailbox;
use App\Http\Models\NotFound;
use App\Http\Models\ProcessProgress;
use App\Http\Models\ProjectFlowMemo;
use App\Http\Models\ProjectFlowMemoRelation;
use App\Http\Models\ProjectProgress;
use App\Http\Models\ProjectProgressCurrentMonth;
use App\Http\Models\ProjectProgressEditing;
use App\Http\Models\ProjectProgressPlanner;
use App\Http\Models\Role;
use App\Http\Models\ScheduledTasks;
use App\Http\Models\ScoreSummary;
use App\Http\Models\Site;
use App\Http\Models\SiteProcess;
use App\Http\Models\User;
use App\Http\Models\WeekTaskInfo;
use App\Http\Services\FlowService;
use App\Http\Services\HomeService;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Contracts\View\Factory;
use Illuminate\View\View;

/**
 * 建站期进度管理
 * Class ProgressRateController
 * @package App\Http\Controllers\Admin\Flow
 */
class ProgressRateController extends Controller
{
    public $userList = [];
    public const CAUSE = [
        '1' => '客户原因',
        '2' => '采编原因',
        '3' => '策划师原因',
        '4' => '设计原因',
        '5' => '项目经理原因',
        '6' => '其他原因',
    ];

    public function __construct()
    {
        $this->userList = User::query()->where('status', 1)->get() ?? [];
    }

    //当月上线目标
    public function currentMonthOnline(Request $request)
    {
        $result = $request->all();
        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                        $list[$key]['type'] = implode(',', $value['type']);
                    }
                    ProjectProgressCurrentMonth::query()->whereIn('site_id', $siteIds)->delete();
                    ProjectProgressCurrentMonth::query()->insert($list);
                });
            } catch (\Throwable $exception) {
                return response()->json(['message' => $exception->getMessage()], 400);
            }
            return response()->json(['message' => '操作成功']);
        }
        $sites = $this->onlineBuilder($request, 0);

        $list = $this->arraySort($sites->toArray(), 'rank', 'desc');
        $list = array_merge($list);

        return view('admin/flow/current_month_online', [
            'siteList' => $list,
            'userList' => $this->userList,
            'result' => $result
        ]);
    }

    //保存当月达标进度
    public function saveCurrentMonthOnline(Request $request)
    {
        $result = $request->all();
        $update = [
            'site_id' => $result['siteId'] ?? 0,
            'type' => implode(',', $result['project_progress'] ?? [0]),
            'memo' => $result['memo'] ?? '',
        ];
        $info = ProjectProgressCurrentMonth::query()->where('site_id', $result['siteId'])->first();
        if (empty($info)) {
            ProjectProgressCurrentMonth::query()->insert($update);
        } else {
            ProjectProgressCurrentMonth::query()->where('site_id', $result['siteId'])->update($update);
        }

        $patten = "/^\d{4}[\-](0?[1-9]|1[012])[\-](0?[1-9]|[12][0-9]|3[01])(\s+(0?[0-9]|1[0-9]|2[0-3])\:(0?[0-9]|[1-5][0-9])\:(0?[0-9]|[1-5][0-9]))?$/";
        if (preg_match($patten, $result['month_range'])) {
            Site::query()->where('id', $result['siteId'])->update(['current_month_online_date' => $result['month_range']]);
        } else {
            return response()->json(['message' => '时间格式不正确'], 400);
        }
        return response()->json(['message' => '操作成功']);
    }

    public function onlineBuilder($request, $type = 0)
    {
        $filterUserIds = [];
        $editorId = $request->input('editorId');
        $editorId && $filterUserIds[] = $editorId;
        $manageHelperId = $request->input('manageHelperId');
        $manageHelperId && $filterUserIds[] = $manageHelperId;
        $optimizerId = $request->input('optimizerId');
        $optimizerId && $filterUserIds[] = $optimizerId;
        $webId = $request->input('webId');
        $webId && $filterUserIds[] = $webId;
        $plannerId = $request->input('plannerId');
        $plannerId && $filterUserIds[] = $plannerId;
        $keyword = $request->input('keyword');
        $schedule = $request->input('schedule');

        $site = Site::query();

        if (!empty($schedule)) {
            $siteIs = ProjectProgressCurrentMonth::query()->whereRaw('FIND_IN_SET(?,type)', [$schedule])->select('site_id')->pluck('site_id')->toArray() ?? [];
            $site->whereIn('id', $siteIs);
        }

        if ($type != 0) {
            $site->with(['projectProgressCurrentMonth', 'users'])->where('is_current_month_online', 1);
        } else {
            $site->with(['projectProgressCurrentMonth', 'users'])->where('is_current_month_online', 1)->whereBetween('current_month_online_date', [date('Y-m-01 00:00:00'), date('Y-m-t 23:59:59')]);
        }

        $builder = $site->where(function (Builder $q) use ($keyword) {
            if ($keyword) {
                $q->where('domain', 'like', '%' . $keyword . '%')
                    ->orWhere('cn_title', 'like', '%' . $keyword . '%');
            }
        });

        if ($filterUserIds) {
            $builder->whereExists(function (\Illuminate\Database\Query\Builder $b) use ($filterUserIds) {
                $raw = sprintf('SUM(CASE WHEN user_id in (%s) then  1 ELSE  0 end) as total', implode(',', $filterUserIds));
                $b->select(DB::raw($raw))->from('user_has_sites')
                    ->whereRaw(sprintf('user_has_sites.site_id=sites.id HAVING total=%s', count($filterUserIds)));
            });
        }

        $sites = $builder->orderByDesc('id')->get();
        foreach ($sites as $item) {
            $item->rank = $item->projectProgressCurrentMonth->rank ?? 0;
            $item->type = explode(',', $item->projectProgressCurrentMonth->type ?? 0);
            $item->memo = $item->projectProgressCurrentMonth->memo ?? '';
            $item->manage_helper_title = implode('-', $item->users->where('role_id', Role::TYPE_MANAGE_HELPER)->pluck('nickname')->toArray());
            $item->ae_title = implode('-', $item->users->where('role_id', Role::TYPE_AE)->pluck('nickname')->toArray());
            $item->planner = implode('-', $item->users->where('role_id', Role::TYPE_PLANNER)->pluck('nickname')->toArray());
            $item->web = implode('-', $item->users->where('role_id', Role::TYPE_WEB)->pluck('nickname')->toArray());
            $item->designerTitle = implode('-', $item->users->where('role_id', Role::TYPE_DESIGNER)->pluck('nickname')->toArray());
        };
        return $sites;
    }

    //未上线原因
    public function notOnlineReason(Request $request)
    {
        $result = $request->all();
        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                        $list[$key]['type'] = implode(',', $value['type']);
                    }
                    ProjectProgressCurrentMonth::query()->whereIn('site_id', $siteIds)->delete();
                    ProjectProgressCurrentMonth::query()->insert($list);
                });
            } catch (\Throwable $exception) {
                return response()->json(['message' => $exception->getMessage()], 400);
            }
            return response()->json(['message' => '操作成功']);
        }
        $sites = $this->onlineBuilder($request, 1);
        $list = $this->arraySort($sites->toArray(), 'rank', 'desc');
        $list = array_merge($list);

        return view('admin/flow/not_online_reason', [
            'siteList' => $list,
            'userList' => $this->userList,
            'result' => $result
        ]);
    }

    //项目进度(废弃不用)
    public function progressRate(Request $request)
    {
        $result = $request->all();
        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                    }
                    ProjectProgress::query()->whereIn('site_id', $siteIds)->delete();
                    ProjectProgress::query()->insert($list);
                });
            } catch (\Throwable $exception) {
                return response()->json(['message' => $exception->getMessage()], 400);
            }
            return response()->json(['message' => '操作成功']);
        }

        list($list, $user) = $this->progressRateBuild($request);

        return view('admin.flow.progress_rate', [
            'siteList' => $list,
            'role_id' => $user->role_id,
            'userList' => $this->userList,
            'result' => $result
        ]);
    }

    //项目进度(废弃不用)
    public function progressRateBuild($request, $type = 0)
    {
        $user = auth()->user();
        $list = Site::query()->with(['projectProgress', 'projectProgressEditing', 'projectProgressPlanner', 'users']);
        $list = $this->getAuthBySiteId($request, $list, $user)->whereIn('status', [1, 4])->get();

        foreach ($list as $key => $item) {

            $item->info = 0;
            $info = FlowInfo::query()->where('site_id', $item->id)->where('detail_list', 'like', '%网站架构定稿%')->first();
            if (!empty($info)) {
                foreach ($info->detail_list as $kk => $vv) {
                    if ($vv['flow_name'] == '网站架构定稿') {
                        if (!empty($vv['flow_done_date'])) {
                            $item->info = 1;
                        }
                    }
                }
            }

            $item->rank = $item->projectProgress->rank ?? 0;
            $item->sort = $item->projectProgress->sort ?? 0;
            $item->memo = $item->projectProgress->memo ?? '';

            $item->prophase = 0;
            if (!empty($item->projectProgressEditing->is_backstage) &&
                !empty($item->projectProgressEditing->is_first_mail)) {
                $item->prophase = 1;
            }

            $item->data = 0;
            if (!empty($item->projectProgressEditing->is_data) &&
                !empty($item->projectProgressEditing->is_folder) &&
                !empty($item->projectProgressEditing->is_order_index) &&
                !empty($item->projectProgressEditing->is_product_index)) {
                $item->data = 1;
            }

            $item->test = 0;
            if (!empty($item->projectProgressEditing->is_test_station) &&
                !empty($item->projectProgressEditing->is_opinion) &&
                !empty($item->projectProgressEditing->is_project_group) &&
                !empty($item->projectProgressEditing->is_client_feedback)) {
                $item->test = 1;
            }

            $item->online = 0;
            if (!empty($item->projectProgressEditing->is_online_inspection_form) &&
                !empty($item->projectProgressEditing->is_in_group_inspection) &&
                !empty($item->projectProgressEditing->is_quality_inspection_departments) &&
                !empty($item->projectProgressEditing->is_optimization)) {
                $item->online = 1;
            }

            $item->is_keywords = $item->projectProgressPlanner->is_keywords ?? 0;
            $item->is_keywords_map = $item->projectProgressPlanner->is_keywords_map ?? 0;
            $item->is_tdk = $item->projectProgressPlanner->is_tdk ?? 0;

            $item->page_planning = 0;
            if (!empty($item->projectProgressPlanner->is_keywords_implantation) &&
                !empty($item->projectProgressPlanner->is_home_planning) &&
                !empty($item->projectProgressPlanner->is_product_guidance_document) &&
                !empty($item->projectProgressPlanner->is_inside_page_planning) &&
                !empty($item->projectProgressPlanner->is_special_page_planning)) {
                $item->page_planning = 1;
            }

            $item->editing = $item->users->where('role_id', Role::TYPE_AE)->first()->nickname ?? '';
            $item->project_manager = $item->users->where('role_id', Role::TYPE_MANAGE_HELPER)->first()->nickname ?? '';
            $item->planner = $item->users->where('role_id', Role::TYPE_PLANNER)->first()->nickname ?? '';
        }

        if ($type == 1) {
            $list = $list->toArray();
        }
        $list = $this->arraySort($list, 'rank', 'desc');
        $list = array_merge($list);
        return [$list, $user];
    }

    //百千项目进度
    public function bqProgressRate(Request $request)
    {
        $result = $request->all();
        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                    }
                    BqProjectProgress::query()->whereIn('site_id', $siteIds)->delete();
                    BqProjectProgress::query()->insert($list);
                });
            } catch (\Throwable $exception) {
                return response()->json(['message' => $exception->getMessage()], 400);
            }
            return response()->json(['message' => '操作成功']);
        }
        list($list, $userAuth) = $this->bqProgressRateBuild($request);

        return view('admin.flow.bq_progress_rate', [
            'siteList' => $list,
            'role_id' => $userAuth->role_id,
            'userList' => $this->userList,
            'result' => $result
        ]);
    }

    public function bqProgressRateBuild($request)
    {
        $userAuth = auth()->user();
        $list = Site::query()
            ->where('is_bq', 1)
            ->with(['bqProjectProgress', 'users', 'bqFlow.bqFlowInfo']);
        $list = $this->getAuthBySiteId($request, $list, $userAuth)->get()->toArray();

        $result = [];
        foreach ($list as $key => $item) {

            $data = [
                'id' => $item['id'],
                'bq_at' => date('Y-m-d', strtotime($item['bq_at'])),
                'cn_title' => $item['cn_title'] ?? '',
                'optimization' => '',
                'bq_meeting' => 1,
                'home_page_adjustment' => 1,
                'product_series_page_adjustment' => 1,
                'other_page_adjustments' => 1,
                'code_adjustment' => 1,
                'web_page_adjustment' => 1,
                'website_seo_quality_inspection' => 1,
                'small_language_station' => 1,
                'rank' => $item['bq_project_progress']['rank'] ?? 0,
                'memo' => $item['bq_project_progress']['memo'] ?? '',
            ];

            foreach ($item['users'] as $user) {
                if ($user['role_id'] == Role::TYPE_OPTIMIZER) {
                    $data['optimization'] = $user['nickname'];
                }
            }
            if (empty($item['bq_flow'])) {
                $data['bq_meeting'] = 0;
                $data['home_page_adjustment'] = 0;
                $data['product_series_page_adjustment'] = 0;
                $data['other_page_adjustments'] = 0;
                $data['code_adjustment'] = 0;
                $data['web_page_adjustment'] = 0;
                $data['website_seo_quality_inspection'] = 0;
                $data['small_language_station'] = 0;
            } else {

                foreach ($item['bq_flow'] as $value) {

                    foreach ($value['bq_flow_info'] as $index) {

                        foreach ($index['detail_list'] as $k => $v) {

                            foreach ($v['children'] as $vv) {
                                $vv['title'] = $value['title'];

                                if (empty($vv['flow_done_date']) && $vv['title'] == '百千会议') {
                                    $data['bq_meeting'] = 0;
                                }
                                if (empty($vv['flow_done_date']) && $vv['title'] == '首页调整') {
                                    $data['home_page_adjustment'] = 0;
                                }
                                if (empty($vv['flow_done_date']) && $vv['title'] == '产品系列页面调整') {
                                    $data['product_series_page_adjustment'] = 0;
                                }
                                if (empty($vv['flow_done_date']) && $vv['title'] == '其他页面调整') {
                                    $data['other_page_adjustments'] = 0;
                                }
                                if (empty($vv['flow_done_date']) && $vv['title'] == '代码调整') {
                                    $data['code_adjustment'] = 0;
                                }
                                if (empty($vv['flow_done_date']) && $vv['title'] == '网页调整') {
                                    $data['web_page_adjustment'] = 0;
                                }
                                if (empty($vv['flow_done_date']) && $vv['title'] == '网站SEO质检') {
                                    $data['website_seo_quality_inspection'] = 0;
                                }
                                if (empty($vv['flow_done_date']) && $vv['title'] == '小语言站') {
                                    $data['small_language_station'] = 0;
                                }
                            }
                        }
                    }
                }

            }
            $result[] = $data;
        }

        $result = $this->arraySort($result, 'rank', 'desc');
        $result = array_merge($result);
        return [$result, $userAuth];
    }

    //策划师进度(废弃不用)
    public function plannerSchedule(Request $request)
    {
        $result = $request->all();
        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                    }
                    ProjectProgressPlanner::query()->whereIn('site_id', $siteIds)->delete();
                    ProjectProgressPlanner::query()->insert($list);
                });

            } catch (\Throwable $exception) {
                return response()->json(['message' => $exception->getMessage()], 400);
            }
            return response()->json(['message' => '操作成功']);
        }
        $user = auth()->user();
        $list = Site::query()->with(['projectProgressPlanner', 'users']);
        $list = $this->getAuthBySiteId($request, $list, $user)->whereIn('status', [1, 4])->get();

        $siteProcess = SiteProcess::query()
                ->whereNotNull('deploy')
                ->where('process_id', 7)->where('active', 2)
                ->pluck('deploy', 'site_id')->toArray() ?? [];

        $siteProcessList = [];
        foreach ($siteProcess as $key => $process) {
            $siteProcessList[$key] = $process['domain'];
        }
        foreach ($list as $key => $item) {
            $item->url = $siteProcessList[$item->id] ?? '';
            $item->memo = $item->projectProgressPlanner->memo ?? '';
            $item->is_keywords = $item->projectProgressPlanner->is_keywords ?? 0;
            $item->is_keywords_map = $item->projectProgressPlanner->is_keywords_map ?? 0;
            $item->is_tdk = $item->projectProgressPlanner->is_tdk ?? 0;
            $item->is_keywords_implantation = $item->projectProgressPlanner->is_keywords_implantation ?? 0;
            $item->is_home_planning = $item->projectProgressPlanner->is_home_planning ?? 0;
            $item->is_product_guidance_document = $item->projectProgressPlanner->is_product_guidance_document ?? 0;
            $item->is_inside_page_planning = $item->projectProgressPlanner->is_inside_page_planning ?? 0;
            $item->is_special_page_planning = $item->projectProgressPlanner->is_special_page_planning ?? 0;
            $item->rank = $item->projectProgressPlanner->rank ?? 0;

            $item->editing = $item->users->where('role_id', Role::TYPE_AE)->first()->nickname ?? '';
            $item->nickname = $item->users->where('role_id', Role::TYPE_PLANNER)->first()->nickname ?? '';
        }

        $list = $this->arraySort($list, 'rank', 'desc');
        $list = array_merge($list);

        $editors = User::query()->where('status', 1)->where('role_id', Role::TYPE_PLANNER)->pluck('nickname', 'id');

        return view('admin.flow.planner_schedule', [
            'siteList' => $list,
            'editors' => $editors,
            'role_id' => $user->role_id,
        ]);
    }

    //采编进度(废弃不用)
    public function editingSchedule(Request $request)
    {
        $result = $request->all();

        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                    }
                    ProjectProgressEditing::query()->whereIn('site_id', $siteIds)->delete();
                    ProjectProgressEditing::query()->insert($list);
                });
            } catch (\Throwable $exception) {
                return response()->json(['message' => $exception->getMessage()], 400);
            }
            return response()->json(['message' => '操作成功']);
        }
        $user = auth()->user();
        $list = Site::query()->with(['projectProgressEditing', 'users']);
        $list = $this->getAuthBySiteId($request, $list, $user)->whereIn('status', [1, 4])->get();
        foreach ($list as $key => $item) {

            $item->is_backstage = $item->projectProgressEditing->is_backstage ?? 0;
            $item->memo = $item->projectProgressEditing->memo ?? '';

            $item->is_first_mail = $item->projectProgressEditing->is_first_mail ?? 0;
            $item->is_data = $item->projectProgressEditing->is_data ?? 0;
            $item->is_folder = $item->projectProgressEditing->is_folder ?? 0;

            $item->is_order_index = $item->projectProgressEditing->is_order_index ?? 0;
            $item->is_product_index = $item->projectProgressEditing->is_product_index ?? 0;

            $item->is_test_station = $item->projectProgressEditing->is_test_station ?? 0;
            $item->is_opinion = $item->projectProgressEditing->is_opinion ?? 0;
            $item->is_project_group = $item->projectProgressEditing->is_project_group ?? 0;
            $item->is_client_feedback = $item->projectProgressEditing->is_client_feedback ?? 0;
            $item->is_online_inspection_form = $item->projectProgressEditing->is_online_inspection_form ?? 0;
            $item->is_in_group_inspection = $item->projectProgressEditing->is_in_group_inspection ?? 0;
            $item->is_quality_inspection_departments = $item->projectProgressEditing->is_quality_inspection_departments ?? 0;
            $item->is_optimization = $item->projectProgressEditing->is_optimization ?? 0;
            $item->rank = $item->projectProgressEditing->rank ?? 0;

            $item->nickname = $item->users->where('role_id', Role::TYPE_AE)->first()->nickname ?? '';
        }
        $list = $this->arraySort($list, 'rank', 'desc');
        $list = array_merge($list);
        $editors = User::query()->where('status', 1)->where('role_id', Role::TYPE_AE)->pluck('nickname', 'id');

        return view('admin.flow.editing_schedule', [
            'siteList' => $list,
            'editors' => $editors,
            'role_id' => $user->role_id,
        ]);
    }

    //逾期导出(废弃不用)
    public function scheduleOverdueExport(Request $request)
    {
        $site = $this->scheduleOverdueBuilder($request)->get();
        $siteList = $this->resetScheduleOverdue($site);
        $result = [];
        foreach ($siteList as $item) {
            $data = [
                'cn_title' => $item->cn_title,
                'domain' => $item->domain,

                'projectManager' => $item->projectManager,
                'serverManager' => $item->serverManager,
                'salesManager' => $item->salesManager,
                'expectedDay' => $item->expectedDay,
                'overdueDay' => $item->overdueDay,

                'projectDataCollection' => $item->projectDataCollection,
                'projectDataCollectionMemo' => $item->projectDataCollectionMemo,
                'projectDataCollectionComplete' => $item->projectDataCollectionComplete,
                'siteArchitecture' => $item->siteArchitecture,
                'siteArchitectureMemo' => $item->siteArchitectureMemo,
                'siteArchitectureComplete' => $item->siteArchitectureComplete,

                'homepageDesign' => $item->homepageDesign,
                'homepageDesignMemo' => $item->homepageDesignMemo,
                'homepageDesignComplete' => $item->homepageDesignComplete,

                'insidePageDesign' => $item->insidePageDesign,
                'insidePageDesignMemo' => $item->insidePageDesignMemo,
                'insidePageDesignComplete' => $item->insidePageDesignComplete,

                'websiteInformationProvision' => $item->websiteInformationProvision,
                'websiteInformationProvisionMemo' => $item->websiteInformationProvisionMemo,
                'websiteInformationProvisionComplete' => $item->websiteInformationProvisionComplete,

                'testStation' => $item->testStation,
                'testStationMemo' => $item->testStationMemo,
                'testStationComplete' => $item->testStationComplete,

                'keyWords' => $item->keyWords,
                'keyWordsMemo' => $item->keyWordsMemo,
                'keyWordsComplete' => $item->keyWordsComplete,

                'seo' => $item->seo,
                'seoMemo' => $item->seoMemo,
                'seoComplete' => $item->seoComplete,

                'online' => $item->online,
                'onlineMemo' => $item->onlineMemo,
                'onlineComplete' => $item->onlineComplete,
            ];
            $result[] = $data;
        }
        array_unshift($result, ['项目名称', '域名', '项目经理', '销售经理', '项目管家', '预计总天数', '逾期天数', '项目资料搜集逾期时间', '逾期原因', '项目资料搜集完成用时', '网站架构逾期时间', '逾期原因', '网站架构完成用时', '首页设计逾期时间', '逾期原因', '首页设计完成用时', '内页设计逾期时间', '逾期原因', '内页设计完成用时', '整站资料提供逾期时间', '逾期原因', '整站资料提供完成用时', '测试站逾期时间', '逾期原因', '测试站完成用时', '关键词逾期时间', '逾期原因', '关键词完成用时', 'seo完善逾期时间', '逾期原因', 'seo完善完成用时', '上线逾期时间', '逾期原因', '上线完成用时']);
        return (new BasicExport($result))->download(sprintf('进度逾期%s.xls', date('YmdHis')));
    }

    //逾期汇总及原因(废弃不用)
    public function scheduleOverdue(Request $request)
    {
        if (!$request->ajax()) {
            $managerHelpers = User::query()->where('role_id', Role::TYPE_MANAGE_HELPER)->get();
            return view('admin.flow.schedule_overdue', [
                'managerHelpers' => $managerHelpers,
            ]);
        }
        $site = $this->scheduleOverdueBuilder($request);
        $siteList = $site->paginate($request->input('pageSize') ?? TABLE_PAGE_SIZE);
        $siteList = $this->resetScheduleOverdue($siteList);

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

    //逾期汇总及原因(废弃不用)
    public function scheduleOverdueBuilder($request)
    {
        $site = Site::query();
        $keyword = $request->input('keyword');
        if ($keyword) {
            $site->where('domain', 'like', "%{$keyword}%")
                ->orWhere('cn_title', 'like', "%{$keyword}%");
        }
        $manageHelperId = $request->input('manageHelperId');
        if ($manageHelperId) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $manageHelperId)->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        $date = $request->input('date');
        if ($date) {
            $siteIdList = FlowStage::query()
                    ->whereBetween('expected_date', [date('Y-m-d', strtotime($date)), date('Y-m-t', strtotime($date))])
                    ->groupBy('site_id')->pluck('site_id')->toArray() ?? [];
            $site->whereIn('id', $siteIdList);
        }
        $siteIds = FlowStage::query()->whereNotNull('expected_date')->groupBy('site_id')->pluck('site_id')->toArray() ?? [];
        if ($siteIds) {
            $site->whereIn('id', $siteIds);
        }
        $site = $site->with(['users', 'projectProgressFlowStage']);
        return $site;
    }

    //逾期汇总及原因(废弃不用)
    public function resetScheduleOverdue($siteList)
    {
        foreach ($siteList as $item) {
            $item->projectManager = implode('-', $item->users->where('role_id', Role::TYPE_MANAGE_HELPER)->pluck('nickname')->toArray());
            $item->serverManager = implode('-', $item->users->where('role_id', Role::TYPE_SERVER)->pluck('nickname')->toArray());
            $item->salesManager = implode('-', $item->users->where('role_id', Role::TYPE_SELLER)->pluck('nickname')->toArray());
            $item->expectedDay = '';
            $item->overdueDay = '';

            $item->projectDataCollection = '';
            $item->projectDataCollectionMemo = '';
            $item->projectDataCollectionComplete = '';

            $item->siteArchitecture = '';
            $item->siteArchitectureMemo = '';
            $item->siteArchitectureComplete = '';

            $item->homepageDesign = '';
            $item->homepageDesignMemo = '';
            $item->homepageDesignComplete = '';

            $item->insidePageDesign = '';
            $item->insidePageDesignMemo = '';
            $item->insidePageDesignComplete = '';

            $item->websiteInformationProvision = '';
            $item->websiteInformationProvisionMemo = '';
            $item->websiteInformationProvisionComplete = '';

            $item->testStation = '';
            $item->testStationMemo = '';
            $item->testStationComplete = '';

            $item->keyWords = '';
            $item->keyWordsMemo = '';
            $item->keyWordsComplete = '';

            $item->seo = '';
            $item->seoMemo = '';
            $item->seoComplete = '';

            $item->online = '';
            $item->onlineMemo = '';
            $item->onlineComplete = '';

            if (!empty($item->projectProgressFlowStage)) {
                $day = [];
                foreach ($item->projectProgressFlowStage as $value) {
                    if (!empty($value->expected_date)) {
                        $day[] = strtotime($value->expected_date);
                    }
                    $this->getOverdueList($item, $value);
                }

                $dayList = $this->maoPao($day);
                if (count($dayList) > 0) {
                    $day = ($dayList[count($dayList) - 1] - $dayList[0]) / 86400;
                    $item->expectedDay = $day;

                    $overdueDay = (strtotime(date('Y-m-d')) - $dayList[0]) / 86400;
                    $item->overdueDay = $overdueDay;
                }
            }
        }
        return $siteList;
    }

    //标记
    public function setSiteIdByRankId(Request $request)
    {
        $result = $request->all();
        if ($result['type'] == 1) {
            $model = ProjectProgressEditing::query();
        } elseif ($result['type'] == 2) {
            $model = ProjectProgressPlanner::query();
        } elseif ($result['type'] == 3) {
            $model = BqProjectProgress::query();
        } elseif ($result['type'] == 4) {
            $model = ProjectProgress::query();
        } elseif ($result['type'] == 5) {
            $model = ScoreSummary::query();
        } elseif ($result['type'] == 6) {
            $model = ProcessProgress::query();
        } elseif ($result['type'] == 7) {
            $model = ProjectProgressCurrentMonth::query();
        } else {
            $model = '';
        }
        $info = $model->where('site_id', $result['siteId'])->first();
        if (empty($info)) {
            return response()->json(['message' => '请先保存再标记'], 400);
        }
        $model->where('site_id', $result['siteId'])->update(['rank' => $result['rank']]);
        return response()->json(['message' => '操作成功']);
    }

    //二维数组排序
    public function arraySort($array, $keys, $sort = 'asc')
    {
        $newArr = $valArr = array();
        foreach ($array as $key => $value) {
            $valArr[$key] = $value[$keys];
        }
        ($sort == 'asc') ? asort($valArr) : arsort($valArr);
        reset($valArr);
        foreach ($valArr as $key => $value) {
            $newArr[$key] = $array[$key];
        }
        return $newArr;
    }

    /**
     * 筛选查询对象
     * @param $result
     * @param $site object
     * @param $user
     * @return mixed
     */
    public function getAuthBySiteId($result, $site, $user)
    {
        if (!empty($result['keyword'])) {
            $site->where('cn_title', 'like', '%' . $result['keyword'] . '%');
        }
        if (!empty($result['userId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['userId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['projectManagerId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['projectManagerId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['plannerId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['plannerId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['editingId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['editingId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['designerId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['designerId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['webId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['webId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['projectStewardId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['projectStewardId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['sellerId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['sellerId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['serverId'])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $result['serverId'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!empty($result['sort'])) {
            $siteIdList = ProjectProgress::query()->where('sort', $result['sort'])->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        if (!in_array($user->role_id, [Role::TYPE_MANAGE_LEADER, Role::TYPE_DESIGN_DIRECTOR, Role::TYPE_HR, Role::TYPE_CHONGQING_MANAGER, Role::TYPE_QUALITY])) {
            $siteIdList = DB::table('user_has_sites')->where('user_id', $user->id)->pluck('site_id') ?? [];
            $site->whereIn('id', $siteIdList);
        }
        return $site;
    }

    //逾期汇总及原因(废弃不用)
    public function getOverdueList(&$item, &$value)
    {
        if ($value->title == '项目资料搜集') {
            //逾期天数
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->projectDataCollection = floor($time / 86400);
                }
            }
            //逾期天数
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                //重置延期天数
                if ($value->complete_date > $value->expected_date) {
                    $item->projectDataCollection = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->projectDataCollection = '';
                }
            }
            //逾期原因
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $result = explode(',', $value->extension);
                $projectDataCollectionMemo = [];
                foreach ($result as $index) {
                    $projectDataCollectionMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->projectDataCollectionMemo = implode(',', $projectDataCollectionMemo);
            }
            //完成用时
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->projectDataCollectionComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == '网站架构') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->siteArchitecture = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                if ($value->complete_date > $value->expected_date) {
                    $item->siteArchitecture = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->siteArchitecture = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $siteArchitectureMemo = [];
                foreach ($result as $index) {
                    $siteArchitectureMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->siteArchitectureMemo = implode(',', $siteArchitectureMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->siteArchitectureComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == '首页设计') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->homepageDesign = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                if ($value->complete_date > $value->expected_date) {
                    $item->homepageDesign = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->homepageDesign = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $homepageDesignMemo = [];
                foreach ($result as $index) {
                    $homepageDesignMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->homepageDesignMemo = implode(',', $homepageDesignMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->homepageDesignComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == '内页设计') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->insidePageDesign = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                //重置延期天数
                if ($value->complete_date > $value->expected_date) {
                    $item->insidePageDesign = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->insidePageDesign = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $insidePageDesignMemo = [];
                foreach ($result as $index) {
                    $insidePageDesignMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->insidePageDesignMemo = implode(',', $insidePageDesignMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->insidePageDesignComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == '整站资料提供') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->websiteInformationProvision = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                if ($value->complete_date > $value->expected_date) {
                    $item->websiteInformationProvision = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->websiteInformationProvision = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $websiteInformationProvisionMemo = [];
                foreach ($result as $index) {
                    $websiteInformationProvisionMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->websiteInformationProvisionMemo = implode(',', $websiteInformationProvisionMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->websiteInformationProvisionComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == '测试站') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->testStation = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                if ($value->complete_date > $value->expected_date) {
                    $item->testStation = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->testStation = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $testStationMemo = [];
                foreach ($result as $index) {
                    $testStationMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->testStationMemo = implode(',', $testStationMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->testStationComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == '关键词') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->keyWords = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                if ($value->complete_date > $value->expected_date) {
                    $item->keyWords = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->keyWords = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $keyWordsMemo = [];
                foreach ($result as $index) {
                    $keyWordsMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->keyWordsMemo = implode(',', $keyWordsMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->keyWordsComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == 'SEO完善') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->seo = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                if ($value->complete_date > $value->expected_date) {
                    $item->seo = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->seo = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $seoMemo = [];
                foreach ($result as $index) {
                    $seoMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->seoMemo = implode(',', $seoMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->seoComplete = floor($time / 86400);
                }
            }
        }
        if ($value->title == '上线') {
            if (!empty($value->expected_date) && empty($value->complete_date)) {
                $time = strtotime(date('Y-m-d')) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->online = floor($time / 86400);
                }
            }
            if (!empty($value->expected_date) && !empty($value->complete_date)) {
                if ($value->complete_date > $value->expected_date) {
                    $item->online = floor((strtotime($value->complete_date) - strtotime($value->expected_date)) / 86400);
                } else {
                    $item->online = '';
                }
            }
            if (!empty($value->extension)) {
                $result = explode(',', $value->extension);
                $onlineMemo = [];
                foreach ($result as $index) {
                    $onlineMemo[] = self::CAUSE[$index] ?? '';
                }
                $item->onlineMemo = implode(',', $onlineMemo);
            }
            if (!empty($value->complete_date)) {
                $time = strtotime($value->complete_date) - strtotime($value->expected_date);
                if ($time > 0) {
                    $item->onlineComplete = floor($time / 86400);
                }
            }
        }
    }

    //冒泡
    public function maoPao($a)
    {
        for ($i = 0; $i < count($a); $i++) {
            for ($j = $i + 1; $j < count($a); $j++) {
                if ($a[$i] > $a[$j]) {
                    $tem = $a[$i]; // 这里临时变量，存贮$i的值
                    $a[$i] = $a[$j]; // 第一次更换位置
                    $a[$j] = $tem; // 完成位置互换
                }
            }
        }
        return $a;
    }


    //策划师进度导出
    public function plannerScheduleExport(Request $request)
    {
        $user = auth()->user();
        $list = Site::query()->with(['projectProgressPlanner', 'users']);
        $list = $this->getAuthBySiteId($request, $list, $user)->whereIn('status', [1, 4])->get();

        $siteProcess = SiteProcess::query()
                ->whereNotNull('deploy')
                ->where('process_id', 7)->where('active', 2)
                ->pluck('deploy', 'site_id')->toArray() ?? [];

        $siteProcessList = [];
        foreach ($siteProcess as $key => $process) {
            $siteProcessList[$key] = $process['domain'];
        }
        $result = [];
        foreach ($list as $key => $item) {

            $ae = $item->users->where('role_id', Role::TYPE_AE)->first()->nickname ?? '';
            $data = [
                'id' => ++$key,
                'cn_title' => $item->cn_title . '-' . $ae,
                'url' => $siteProcessList[$item->id] ?? '',
                'memo' => $item->projectProgressPlanner->memo ?? '',
                'nickname' => $item->users->where('role_id', Role::TYPE_PLANNER)->first()->nickname ?? '',
                'is_keywords' => $item->projectProgressPlanner->is_keywords ?? 0,
                'is_keywords_map' => $item->projectProgressPlanner->is_keywords_map ?? 0,
                'is_tdk' => $item->projectProgressPlanner->is_tdk ?? 0,
                'is_keywords_implantation' => $item->projectProgressPlanner->is_keywords_implantation ?? 0,
                'is_home_planning' => $item->projectProgressPlanner->is_home_planning ?? 0,
                'is_product_guidance_document' => $item->projectProgressPlanner->is_product_guidance_document ?? 0,
                'is_inside_page_planning' => $item->projectProgressPlanner->is_inside_page_planning ?? 0,
                'is_special_page_planning' => $item->projectProgressPlanner->is_special_page_planning ?? 0,
                'rank' => $item->projectProgressPlanner->rank ?? 0,
            ];
            $result[] = $data;
        }

        $result = $this->arraySort($result, 'rank', 'desc');
        $result = array_merge($result);

        foreach ($result as $key => $value) {
            unset($result[$key]['rank']);
            $result[$key]['id'] = $key + 1;
        }

        array_unshift($result, ['序号', '项目及采编', '测试站网址', '备注', '策划师', '关键词初选', '关键词地图', 'TDK', '关键词植入', '首页策划', '产品指导交流', '内页策划', '特殊页策划']);
        array_unshift($result, ['项目配置', '', '', '', '', '关键词工作', '', '', '页面策划', '', '', '', '']);
        array_unshift($result, ['策划师核心工作：关键词（关键词初选，关键词地图，关键词植入，TDK）+页面策划（首页策划，内页策划，软文策划）+产品指导文档' . "\n" . '注：个人邮箱发送常用文件；关键词地图定稿公共邮箱发送；提前安排关键词地图；日期加打钩']);

        return (new PlannerScheduleExport($result))->download(sprintf('策划师进度%s.xls', date('YmdHis')));
    }

    //采编进度导出(废弃不用)
    public function editingScheduleExport(Request $request)
    {
        $user = auth()->user();
        $list = Site::query()->with(['projectProgressEditing', 'users']);
        $list = $this->getAuthBySiteId($request, $list, $user)->whereIn('status', [1, 4])->get();

        $result = [];
        foreach ($list as $key => $item) {

            $ae = $item->users->where('role_id', Role::TYPE_AE)->first()->nickname ?? '';
            $result[] = [
                'id' => ++$key,
                'cn_title' => $item->cn_title ?? '',
                'domain' => $item->domain ?? '',
                'memo' => $item->projectProgressEditing->memo ?? '',
                'nickname' => $ae,
                'is_backstage' => $item->projectProgressEditing->is_backstage ?? 0,
                'is_first_mail' => $item->projectProgressEditing->is_first_mail ?? 0,
                'is_data' => $item->projectProgressEditing->is_data ?? 0,
                'is_folder' => $item->projectProgressEditing->is_folder ?? 0,
                'is_order_index' => $item->projectProgressEditing->is_order_index ?? 0,
                'is_product_index' => $item->projectProgressEditing->is_product_index ?? 0,
                'is_test_station' => $item->projectProgressEditing->is_test_station ?? 0,
                'is_opinion' => $item->projectProgressEditing->is_opinion ?? 0,
                'is_project_group' => $item->projectProgressEditing->is_project_group ?? 0,
                'is_client_feedback' => $item->projectProgressEditing->is_client_feedback ?? 0,
                'is_online_inspection_form' => $item->projectProgressEditing->is_online_inspection_form ?? 0,
                'is_in_group_inspection' => $item->projectProgressEditing->is_in_group_inspection ?? 0,
                'is_quality_inspection_departments' => $item->projectProgressEditing->is_quality_inspection_departments ?? 0,
                'is_optimization' => $item->projectProgressEditing->is_optimization ?? 0,
                'rank' => $item->projectProgressPlanner->rank ?? 0,
            ];
        }

        $result = $this->arraySort($result, 'rank', 'desc');
        $result = array_merge($result);

        foreach ($result as $key => $value) {
            unset($result[$key]['rank']);
            $result[$key]['id'] = $key + 1;
        }

        array_unshift($result, ['序号', '项目', '网址', '备注', '采编', '后台搭建', '第一封邮件', '资料进度表', '共享盘文件夹整理', '单页面提供完整', '产品页面提供完整', '测试站检查表', '组内意见', '项目部群', '客户反馈', '上线检查表格', '组内检查', '质检部', 'Hina&优化师检查']);
        array_unshift($result, ['项目配置', '', '', '', '', '建站前期', '', '资料', '', '', '', '测试站', '', '', '', '上线', '', '', '']);
        array_unshift($result, ['采编核心工作：资料（资料进度表，共享盘文件夹） + 测试站（测试站检查表格，组内意见，项目部群，客户反馈） + 上线（上线检查表格，组内检查，组间互查，杜佳检查，Hina检查）注：资料要求客户邮件发送，及时查收；网站检查表格（放在共享盘）；客户催促上线及时告知项目经理和采编']);
        return (new EditingScheduleExport($result))->download(sprintf('采编进度 %s.xls', date('YmdHis')));
    }

    //项目进度导出(废弃不用)
    public function progressRateExport(Request $request)
    {
        list($list, $user) = $this->progressRateBuild($request, 1);
        $result = [];
        foreach ($list as $key => $value) {
            if ($value['sort'] == 1) {
                $type = '上线阶段';
            } elseif ($value['sort'] == 2) {
                $type = '测试站阶段';
            } elseif ($value['sort'] == 3) {
                $type = '设计阶段策划师跟进';
            } elseif ($value['sort'] == 4) {
                $type = '架构阶段';
            } elseif ($value['sort'] == 5) {
                $type = '暂停项目';
            } else {
                $type = '请选择阶段';
            }

            $result[] = [
                'id' => ++$key,
                'cn_title' => $value['cn_title'],
                'sort' => $type,
                'project_manager' => $value['project_manager'],
                'planner' => $value['planner'],
                'editing' => $value['editing'],
                'memo' => $value['memo'],
                'info' => $value['info'],
                'prophase' => $value['prophase'],
                'data' => $value['data'],
                'test' => $value['test'],
                'online' => $value['online'],
                'is_keywords' => $value['is_keywords'],
                'is_keywords_map' => $value['is_keywords_map'],
                'is_tdk' => $value['is_tdk'],
                'page_planning' => $value['page_planning'],
                'rank' => $value['rank'],
                'domain' => $value['domain'],
            ];
        }

        foreach ($result as $key => $value) {
            unset($result[$key]['rank']);
            $result[$key]['id'] = $key + 1;
        }

        array_unshift($result, ['序号', '项目', '阶级', '项目经理', '策划师', '采编', '备注', '架构&确定域名', '建站前期', '资料', '测试站', '上线', '关键词初选', '关键词地图', 'TDK', '页面策划']);
        array_unshift($result, ['项目配置', '', '', '', '', '', '', '', '采编进度', '', '', '', '策划师进度', '', '', '']);
        array_unshift($result, ['项目总进度']);
        return (new ProgressRateExport($result))->download(sprintf('项目总进度 %s.xls', date('YmdHis')));

    }


    //项目进度导出(废弃不用)
    public function bqProgressRateExport(Request $request)
    {
        list($list, $userAuth) = $this->bqProgressRateBuild($request);
        $result = [];
        foreach ($list as $key => $value) {
            $result[] = [
                'id' => ++$key,
                'cn_title' => $value['cn_title'],
                'optimization' => $value['optimization'],
                'memo' => $value['memo'],
                'bq_at' => $value['bq_at'],
                'bq_meeting' => $value['bq_meeting'],
                'home_page_adjustment' => $value['home_page_adjustment'],
                'product_series_page_adjustment' => $value['product_series_page_adjustment'],
                'other_page_adjustments' => $value['other_page_adjustments'],
                'code_adjustment' => $value['code_adjustment'],
                'web_page_adjustment' => $value['web_page_adjustment'],
                'website_seo_quality_inspection' => $value['website_seo_quality_inspection'],
                'small_language_station' => $value['small_language_station'],
                'rank' => $value['rank'],
            ];
        }

        foreach ($result as $key => $value) {
            unset($result[$key]['rank']);
            $result[$key]['id'] = $key + 1;
        }

        array_unshift($result, ['序号', '项目', '优化师', '备注', '百千约访时间', '百千会议', '首页调整', '产品系列页面调整', '其他页面调整', '代码调整', '网页调整', '网站SEO质检', '小语言站']);
        array_unshift($result, ['百千项目总进度']);
        return (new BqProgressRateExport($result))->download(sprintf('百千项目总进度 %s.xls', date('YmdHis')));

    }


    //评分统计
    public function designScore(Request $request)
    {
        $result = $request->all();
        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                    }
                    ScoreSummary::query()->whereIn('site_id', $siteIds)->delete();
                    ScoreSummary::query()->insert($list);
                });
            } catch (\Throwable $exception) {
                return response()->json(['message' => $exception->getMessage()], 400);
            }
            return response()->json(['message' => '操作成功']);
        }
        $user = auth()->user();
        $siteIds = ProjectFlowMemo::query()->groupBy('site_id')->pluck('site_id');
        $siteList = Site::query()->whereIn('id', $siteIds);
        $siteList = $this->getAuthBySiteId($request, $siteList, $user);
        $siteList = $siteList->select('id', 'cn_title', 'order_at', 'online_at')
            ->with(['projectFlowMemo' => function ($query) {
                $query->select('title', 'level', 'status', 'site_id', 'node_date', 'is_client_score', 'client_score');
            }, 'scoreSummary', 'users'])->get();
        $list = [];
        foreach ($siteList as $item) {
            $data = [
                'site_id' => $item->id,
                'cn_title' => $item->cn_title,
                'order_at' => $item->order_at,
                'online_at' => substr($item->online_at, 0, 10),
                'rank' => $item->scoreSummary->rank ?? 0,
                'project_manager' => $item->users->where('role_id', Role::TYPE_MANAGE_HELPER)->first()->nickname ?? '',
                'project_steward' => $item->users->where('role_id', Role::TYPE_SERVER)->first()->nickname ?? '',
                'editing' => $item->users->where('role_id', Role::TYPE_AE)->first()->nickname ?? '',
                'web' => $item->users->where('role_id', Role::TYPE_WEB)->first()->nickname ?? '',
                'design' => $item->users->where('role_id', Role::TYPE_DESIGNER)->first()->nickname ?? '',
                'plan' => $item->users->where('role_id', Role::TYPE_PLANNER)->first()->nickname ?? '',
            ];

            foreach ($item->projectFlowMemo as $progress) {
                if ($progress->title == '竞争对手分析') {
                    $data['score1'] = $progress->client_score;
                }
                if ($progress->title == '网站架构定稿') {
                    $data['score2'] = $progress->client_score;
                }
                if ($progress->title == '首页设计定稿') {
                    $data['score3'] = $progress->client_score;
                }
                if ($progress->title == '手机端首页+两张banner设计定稿') {
                    $data['score4'] = $progress->client_score;
                }
                if ($progress->title == '产品内页设计定稿') {
                    $data['score5'] = $progress->client_score;
                }
                if ($progress->title == 'PC 端测试站客户验收反馈') {
                    $data['score6'] = $progress->client_score;
                }
                if ($progress->title == '关键词地图定稿') {
                    $data['score7'] = $progress->client_score;
                }
                if ($progress->title == '上线确认进入实施期') {
                    $data['score8'] = $progress->client_score;
                }
            }
            $list[] = $data;
        }
        $siteList = $this->arraySort($list, 'rank', 'desc');
        $siteList = array_merge($siteList);

        return view('admin.flow.design_score', [
            'siteList' => $siteList,
            'request' => $request,
            'projectManager' => User::query()->where('status', 1)->where('role_id', Role::TYPE_MANAGE_HELPER)->pluck('nickname', 'id'),
            'planner' => User::query()->where('status', 1)->where('role_id', Role::TYPE_PLANNER)->pluck('nickname', 'id'),
            'editors' => User::query()->where('status', 1)->where('role_id', Role::TYPE_AE)->pluck('nickname', 'id'),
            'designer' => User::query()->where('status', 1)->where('role_id', Role::TYPE_DESIGNER)->pluck('nickname', 'id'),
            'web' => User::query()->where('status', 1)->where('role_id', Role::TYPE_WEB)->pluck('nickname', 'id'),
            'projectSteward' => User::query()->where('status', 1)->where('role_id', Role::TYPE_SERVER)->pluck('nickname', 'id'),
        ]);
    }

    /**
     * 建站流程表&&保存
     * @param Request $request
     * @param $siteId
     * @param int $type 0全部，1局部
     * @return Factory|View
     */
    public function siteConstructionProcess(Request $request, $siteId, $type = 0)
    {
        $user = auth()->user();
        if ($user->role_id == 5) {
            return redirect('/wap/site-flow/0');
            /*return view('admin/site/not_found', [
                'tips' => '暂无权限,请登陆后台查看',
                'siteId' => $siteId,
            ]);*/
        }
        $siteInfo = Site::query()->where('id', $siteId)->first();
        if (empty($siteInfo)) {
            return view('admin/site/not_found', [
                'tips' => '暂无项目',
                'siteId' => $siteId,
            ]);
        }
        if (empty($siteInfo->task_at)) {
            return view('admin/site/not_found', [
                'tips' => '项目任务起始时间未设置，初始化失败',
                'siteId' => $siteId,
            ]);
        }
        $siteByUserList = Site::query()->where('id', $siteId)->with(['users'])->first();
        $pm = $siteByUserList->users->where('role_id', Role::TYPE_MANAGE_HELPER)->first();
        if (empty($pm)) {
            return view('admin/site/not_found', [
                'tips' => '该项目没有分配项目经理，初始化失败',
                'siteId' => $siteId,
            ]);
        }
        $server = $siteByUserList->users->where('role_id', Role::TYPE_SERVER)->first();
        if (empty($server)) {
            return view('admin/site/not_found', [
                'tips' => '该项目没有分配客服人员，初始化失败',
                'siteId' => $siteId,
            ]);
        }
        $ae = $siteByUserList->users->where('role_id', Role::TYPE_AE)->first();
        if (empty($ae)) {
            return view('admin/site/not_found', [
                'tips' => '该项目没有分配采编人员，初始化失败',
                'siteId' => $siteId,
            ]);
        }
        $result = $request->all();
        if (!empty($result)) {
            //保存流程
            $this->saveFlow($result, $siteId);
        }
        //流程初始化
        $siteInfo = $this->iniFlow($siteId, $siteInfo);
        //区别权限
        $flowService = new FlowService();

        [$list, $count, $toBeCompletedCount, $nodeDate,
            $user, $taskLastDateStart, $taskLastDateEnd, $newNodeDate,
            $thisWeekTaskList, $nextWeekTaskList]
            = $flowService->getFlowListByUserId($type, $siteId);

        //测试站
        $deploy = SiteProcess::query()
            ->where('process_id', 7)
            ->where('active', 2)
            ->where('site_id', $siteId)
            ->whereNotNull('deploy')->value('deploy');

        return view('admin.flow.site_construction_process', [
            'count' => $count,
            'toBeCompletedCount' => $toBeCompletedCount,
            'list' => $list,
            'siteInfo' => $siteInfo,
            'siteName' => $this->substrFormat($siteInfo->cn_title, 4),
            'roles' => $user,
            'siteId' => $siteId,
            'reasonsForOverdueList' => ProjectFlowMemo::REASONS_FOR_OVERDUE_LIST,
            'scoreList' => ProjectFlowMemo::SCORE,
            'date' => date('Y-m-d H:i:s'),
            'nodeDate' => $nodeDate ?? '',
            'taskLastDateStart' => $taskLastDateStart,
            'taskLastDateEnd' => $taskLastDateEnd,
            'type' => $type,
            'newNodeDate' => $newNodeDate,
            'thisWeekTaskList' => $thisWeekTaskList,//这周任务规划
            'nextWeekTaskList' => $nextWeekTaskList,//下周任务规划
            'domain' => $deploy['domain'] ?? '',
        ]);
    }

    //初始化流程
    private function iniFlow($siteId, $siteInfo)
    {
        $result = ProjectFlowMemo::query()->where('site_id', $siteId)->first();
        if (empty($result)) {
            $data = [];
            $list = DB::table('project_flow_memo_tpl')->get();

            $days = 120;
            $dayList = [];
            for ($i = 1; $i <= $days; $i++) {
                $day = date('Y-m-d', strtotime($siteInfo->task_at) + 86400 * $i);
                $result = $this->isWeekend($day);
                if (!$result) {
                    $dayList[] = $day;
                }
            }
            foreach ($list as $value) {

                $data[] = [
                    'site_id' => $siteId,
                    'status' => $value->status,
                    'title' => $value->title,
                    'level' => $value->level,
                    'rank' => $value->rank,
                    'memo' => $value->memo,
                    'roles' => $value->roles,
                    'acceptance' => $value->acceptance,
                    'file' => $value->file,
                    'file_path' => $value->file_path,
                    'client_file' => $value->client_file,
                    'client_file_path' => $value->client_file_path,
                    'master_plate_path' => $value->master_plate_path,
                    'file_list' => $value->file_list ?? null,
                    'node_date' => $dayList[$value->day - 1],
                    'node' => $value->node,
                    'day' => $value->day,
                    'overdue_day' => $value->overdue_day,
                    'reasons_for_overdue' => $value->reasons_for_overdue,
                    'overdue_memo' => $value->overdue_memo,
                    'client_score' => $value->client_score,
                    'is_client_score' => $value->is_client_score,
                    'inspection_score' => $value->inspection_score,
                    'is_inspection_score' => $value->is_inspection_score,
                    'inspection' => 0,
                    'color' => $value->color,
                    'updated_at' => date('Y-m-d'),
                ];
            }

            ProjectFlowMemo::query()->insert($data);

            $userList = [];
            $siteInfo = Site::query()->where('id', $siteId)->with(['users'])->first();

            foreach ($siteInfo->users as $user) {
                $userList[$user->role_id] = $user->id;
            }

            $flow = ProjectFlowMemo::query()->where('site_id', $siteId)->get();
            $list = [];
            foreach ($flow as $item) {
                $rolesList = explode(',', $item->roles);
                foreach ($rolesList as $roles) {
                    if ($roles != 5) {
                        $list[] = [
                            'roles_id' => $roles,
                            'memo_id' => $item->id,
                        ];
                    }
                }
            }

            foreach ($list as $key => $item) {
                $list[$key]['user_id'] = $userList[$item['roles_id']] ?? 0;
            }
            foreach ($list as $key => $item) {
                if (empty($item['user_id'])) {
                    unset($list[$key]);
                }
            }
            ProjectFlowMemoRelation::query()->insert($list);
        }
        return $siteInfo;
    }

    //保存流程
    public function saveFlow($result, $siteId)
    {
        $data = [];
        $user = [];
        $ids = ProjectFlowMemo::query()->where('site_id', $siteId)->pluck('id') ?? 0;
        foreach ($result as $key => $item) {
            //拆分表单提交过来的字段
            $filed = explode('-', $key);
            if (!empty($filed[2])) {

                foreach ($ids as $id) {
                    if ($filed[0] == $id && $filed[1]) {
                        $user[$filed[0]][] = [
                            $filed[1] => $item,
                            'roles_id' => $filed[2],
                            'memo_id' => $filed[0],
                        ];
                    }
                }
            } else {
                foreach ($ids as $id) {
                    if ($filed[0] == $id && $filed[1]) {
                        $data[$filed[0]][] = [
                            $filed[1] => $item,
                        ];
                    }
                }
            }
        }

        $userList = [];
        foreach ($user as $key => $item) {
            foreach ($item as $value) {
                $userList[] = $value;
            }
        }

        $userResult = [];
        $workingHoursResult = [];

        //工时
        foreach ($userList as $value) {
            if (!empty($value['user_id'])) {
                $userResult[] = $value;
            }
            if (!empty($value['working_hours'])) {
                $workingHoursResult[] = $value;
            }
        }

        foreach ($userResult as $key => $value) {
            foreach ($workingHoursResult as $vv) {
                if ($value['memo_id'] == $vv['memo_id'] && $value['roles_id'] == $vv['roles_id']) {
                    $userResult[$key]['working_hours'] = $vv['working_hours'] ?? '';
                }
            }
        }

        try {
            DB::transaction(function () use ($userResult) {

                $memoIds = array_unique(array_column($userResult, 'memo_id'));
                ProjectFlowMemoRelation::query()->whereIn('memo_id', $memoIds)->delete();

                foreach ($userResult as $value) {
                    ProjectFlowMemoRelation::query()->insert($value);
                }
            });
        } catch (\Throwable $exception) {
            return response()->json(['message' => $exception->getMessage()], 400);
        }

        $list = [];
        foreach ($data as $key => $item) {
            if (!empty($item[1]['id'])) {
                $reasonsForOverdue = $item[3]['reasons_for_overdue'] ?? 0;
                $inspectionScore = $item[3]['inspection_score'] ?? $item[4]['inspection_score'] ?? 0;
                $overdueMemo = $item[3]['overdue_memo'] ?? $item[4]['overdue_memo'] ?? $item[5]['overdue_memo'] ?? '';
                $planningWeek = $item[4]['planning_week'] ?? $item[5]['planning_week'] ?? $item[6]['planning_week'] ?? '';
                $planningNextWeek = $item[4]['planning_next_week'] ?? $item[5]['planning_next_week'] ?? $item[6]['planning_next_week'] ?? '';

                $update = [
                    'id' => $item[1]['id'],
                    'status' => $item[0]['status'] ?? 0,
                    'memo' => $item[2]['memo'] ?? 0,
                ];
                if (!empty($reasonsForOverdue)) {
                    $update['reasons_for_overdue'] = $reasonsForOverdue;
                }
                if (!empty($inspectionScore)) {
                    $update['inspection_score'] = $inspectionScore;
                }
                if (!empty($overdueMemo)) {
                    $update['overdue_memo'] = $overdueMemo;
                }
                if (!empty($planningWeek)) {
                    $update['planning_week'] = $planningWeek;
                }
                if (!empty($planningNextWeek)) {
                    $update['planning_next_week'] = $planningNextWeek;
                }
                $list[] = $update;
            }
        }
        if (!empty($list)) {
            foreach ($list as $value) {
                if (!empty($value['overdue_memo']) && mb_strlen($value['overdue_memo'], 'utf8') > 100) {
                    die('备注请保持在100字以内');
                }
            }
            foreach ($list as $value) {
                ProjectFlowMemo::query()->where('id', $value['id'])->update($value);
            }
        }
    }

    //流程上传资料（废弃不用 改oss）
    public function uploadSiteFile(Request $request)
    {
        $file = $request->file('file');
        if (empty($file)) {
            return response()->json(['message' => '请上传文件'], 400);
        }
        $fileName = date('Y-m-d_His') . $file->getClientOriginalName();
        $fileData['file_url'] = $file->storeAs(date('Y-m') . '/' . $file->getClientOriginalExtension(), $fileName, 'public');
        $fileData['file_url'] = asset('storage/' . $fileData['file_url']);
        $fileData['original_name'] = $file->getClientOriginalName();
        $fileData['time'] = time();
        return response()->json(['message' => '上传成功', 'data' => $fileData]);
    }

    //流程资料下载（废弃 不用 改oss）
    public function downloadSiteFile($taskId, $type = 0)
    {
        $info = DB::table('project_flow_memo')
            ->where('id', $taskId)
            ->first();
        $user = auth()->user();
        if ($user->role_id == 5) {
            if ($type == 1) {
                $path = $info->master_plate_path;
            } else {
                $path = $info->client_file_path;
            }
        } else {
            $path = $info->file_path;
        }
        if (empty($path)) {
            die('暂无文件');
        }
        $pathInfo = pathinfo($path);
        $dirnamePath = explode('storage', $pathInfo['dirname']);
        return response()->download(realpath(base_path('public')) . '/storage' . $dirnamePath[1] . '/' . $pathInfo['basename'], $pathInfo['basename']);
    }

    private function substrFormat($text, $length, $replace = '...', $encoding = 'UTF-8')
    {
        if ($text && mb_strlen($text, $encoding) > $length) {
            return mb_substr($text, 0, $length, $encoding) . $replace;
        }
        return $text;
    }


    //建站2.0进度逾期统计
    public function stationConstructionOverdue(Request $request)
    {
        if (!$request->ajax()) {
            $userList = User::query()->where('status', 1)->get();
            return view('admin.flow.station_construction_overdue', [
                'userList' => $userList,
            ]);
        }

        $list = $this->stationConstructionOverdueBuild($request, ProjectFlowMemo::query());
        return response()->json([
            'rows' => $list->items(),
            'total' => $list->total()
        ]);
    }

    public function stationConstructionOverdueExport(Request $request)
    {
        $projectFlowMemo = ProjectFlowMemo::query();
        $list = $this->stationConstructionOverdueBuild($request, $projectFlowMemo, true);
        $data = [];
        foreach ($list as $item) {
            $data[] = [
                'title' => $item->title ?? '',
                'rank' => $item->rank ?? '',
                'node_date' => $item->node_date ?? '',
                'user' => $item->user ?? '',
                'overdue_day' => $item->overdue_day ?? '',
                'cn_title' => $item->cn_title ?? '',
                'order_at' => $item->order_at ?? '',
            ];
        }
        array_unshift($data, ['逾期事项', '阶段', '任务截止时间', '逾期阶段负责人', '逾期天数', '关联项目', '下单时间']);
        return (new BasicExport($data))->download(sprintf('建站流程逾期列表%s.xls', date('YmdHis')));
    }

    /**
     * 建站2.0进度逾期统计
     * @param $request object
     * @param $projectFlowMemo object
     * @param bool $isExport
     * @param bool $isAll
     * @return mixed
     */
    private function stationConstructionOverdueBuild($request, $projectFlowMemo, $isExport = false, $isAll = false)
    {
        $role = auth()->user();
        if ($role->is_super != 1 || !in_array($role->role_id, [Role::TYPE_MANAGE_LEADER, Role::TYPE_DESIGN_DIRECTOR, Role::TYPE_HR])) {
            $memoIdList = ProjectFlowMemoRelation::query()->where('user_id', $role->id)->pluck('memo_id');
            $projectFlowMemo->whereIn('id', $memoIdList ?? []);
        }
        $request = $request->all();

        if (!empty($request['projectManagerId'])) {
            $memoIds = ProjectFlowMemoRelation::query()->where('user_id', $request['projectManagerId'])->pluck('memo_id');
            $projectFlowMemo->whereIn('id', $memoIds ?? []);
        }
        if (!empty($request['serverId'])) {
            $memoIds = ProjectFlowMemoRelation::query()->where('user_id', $request['serverId'])->pluck('memo_id');
            $projectFlowMemo->whereIn('id', $memoIds ?? []);
        }
        if (!empty($request['sellerId'])) {
            $memoIds = ProjectFlowMemoRelation::query()->where('user_id', $request['sellerId'])->pluck('memo_id');
            $projectFlowMemo->whereIn('id', $memoIds ?? []);
        }
        if (!empty($request['editingId'])) {
            $memoIds = ProjectFlowMemoRelation::query()->where('user_id', $request['editingId'])->pluck('memo_id');
            $projectFlowMemo->whereIn('id', $memoIds ?? []);
        }

        $task = $request['task'];
        if (!empty($task)) {
            $projectFlowMemo->where('title', 'like', '%' . $task . '%');
        }

        $projectFlowMemo->with(['sites', 'projectFlowMemoRelation'])->where('status', '=', 0);

        if (!$isAll) {
            $projectFlowMemo->where('node_date', '<', date('Y-m-d'));
        }


        if ($isExport) {
            $list = $projectFlowMemo->get();
        } else {
            $list = $projectFlowMemo->paginate($request['pageSize'] ?? 10);
        }

        $userList = User::query()->where('status', 1)->pluck('nickname', 'id')->toArray();
        foreach ($list as $item) {

            $users = [];
            $item->cn_title = $item->sites->cn_title ?? '';
            $item->order_at = '';
            $item->online_at = '';

            if (!empty($item->sites->order_at)) {
                $item->order_at = date('Y-m-d', strtotime($item->sites->order_at));
            }
            if (!empty($item->sites->online_at)) {
                $item->online_at = date('Y-m-d', strtotime($item->sites->online_at));
            }
            foreach ($item->projectFlowMemoRelation as $user) {
                $users[] = $userList[$user->user_id] ?? '';
            }
            $item->user = implode(',', $users);

            if (strtotime($item->node_date) < strtotime(date('Y-m-d'))) {
                $item->overdue_day = (strtotime(date('Y-m-d')) - strtotime($item->node_date)) / 3600 / 24 . '天';
            } else {
                $item->overdue_day = '';
            }

            if ($item->reasons_for_overdue == 0) {
                $item->reasons_for_overdue = '';
            } else {
                $item->reasons_for_overdue = ProjectFlowMemo::REASONS_FOR_OVERDUE_LIST[$item->reasons_for_overdue] ?? '';
            }

        }
        return $list;
    }

    //个人任务
    public function personalTasks(Request $request)
    {
        if (!$request->ajax()) {
            $managerHelpers = User::query()->where('status', 1)->where('role_id', Role::TYPE_MANAGE_HELPER)->get();
            return view('admin.flow.test_remind', [
                'managerHelpers' => $managerHelpers,
            ]);
        }
        $taskList = $this->stationConstructionOverdueBuild($request, ProjectFlowMemo::query(), false, true);

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


    //个人邮箱
    public function mailbox(Request $request)
    {
        if (!$request->ajax()) {
            return view('admin.flow.mailbox', [
            ]);
        }
        $message = $request->input('message');
        $user = auth()->user();
        $list = Mailbox::query();
        if (!empty($message)) {
            $list->where('message', 'like', '%' . $message . '%');
        }
        if (!empty($user->is_super != 1)) {
            $list->where('user_id', $user->id);
        }
        $userList = User::query()->where('status', 1)->pluck('nickname', 'id');
        $list = $list->orderByDesc('id')->paginate($request->input('pageSize'));
        foreach ($list as $item) {

            $item->user = $userList[$item->user_id] ?? '';
            $item->read = '未读';
            if ($item->is_read == 1) {
                $item->read = '已读';
            }
        }
        return response()->json([
            'rows' => $list->items(),
            'total' => $list->total()
        ]);
    }

    public function getMailboxStatus()
    {
        $user = auth()->user();
        $mailbox = Mailbox::query();
        $mailbox1 = Mailbox::query();

        if (!empty($user->is_super != 1)) {
            $mailbox->where('user_id', $user->id);
            $mailbox1->where('user_id', $user->id);
        }
        $count = $mailbox->where('is_read', 0)->count() ?? 0;
        $message = $mailbox1->where('is_read', 0)->orderByDesc('id')->value('message') ?? '';
        return response()->json([
            'count' => $count,
            'message' => $message
        ]);
    }

    public function batchRead()
    {
        $user = auth()->user();
        if ($user->is_super == 1) {
            return response()->json(['message' => '管理员不允许批量操作'], 400);

        } else {
            Mailbox::query()->where('user_id', $user->id)->update(['is_read' => 1]);
            return response()->json(['message' => '操作成功']);
        }
    }

    public function buildFlow(Request $request)
    {
        $result = $request->all();
        if (!empty($result['list'])) {
            $list = json_decode($result['list'], true);
            try {
                DB::transaction(function () use ($list) {
                    $siteIds = [];
                    foreach ($list as $key => $value) {
                        $siteIds[] = $value['site_id'];
                    }
                    ProcessProgress::query()->whereIn('site_id', $siteIds)->delete();
                    ProcessProgress::query()->insert($list);
                });

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

        $user = auth()->user();
        $sites = Site::query();

        if (empty($result['status']) || $result['status'] == 1) {
            $sites->where('status', 1);
        } else {
            $sites->where('status', '!=', 1);
        }
        $siteIds = ProjectFlowMemo::query()->groupBy('site_id')->pluck('site_id');

        $siteList = $sites->whereIn('id', $siteIds)
            ->select('id', 'cn_title', 'order_at')
            ->with(['projectFlowMemo' => function ($query) {
                $query->select('level', 'status', 'site_id', 'node_date');
            }, 'processProgress']);

        $flowService = new FlowService();
        $siteList = $flowService->getFlowListBySiteId($this->getAuthBySiteId($request, $siteList, $user)->get()->toArray());

        $sort = 'rank';
        if (!empty($result['lv'])) {
            $sort = $result['lv'];
        }
        $siteList = $this->arraySort($siteList, $sort, 'desc');
        $siteList = array_merge($siteList);

        return view('admin.flow.build_flow', [
            'siteList' => $siteList,
            'role_id' => $user->role_id,
            'result' => $result,
            'userList' => $this->userList,
        ]);
    }

    public function delSitesTaskFlow($siteId)
    {
        DB::transaction(function () use ($siteId) {
            $ids = ProjectFlowMemo::query()->where('site_id', $siteId)->pluck('id');
            ProjectFlowMemoRelation::query()->where('memo_id', $ids)->delete();
            ProjectFlowMemo::query()->where('site_id', $siteId)->delete();
            ProcessProgress::query()->where('site_id', $siteId)->delete();
        });
        return response()->json(['message' => '清除成功']);
    }

    public function resetting(Request $request)
    {
        $siteId = $request->input('siteId');
        $flowIds = ProjectFlowMemo::query()->where('site_id', $siteId)->pluck('id');
        if ($flowIds) {
            ProjectFlowMemo::query()->where('site_id', $siteId)->delete();
            ProjectFlowMemoRelation::query()->whereIn('memo_id', $flowIds)->delete();
        }

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

    public function taskResetting(Request $request)
    {
        $taskId = $request->input('taskId');
        $flowInfo = ProjectFlowMemo::query()->where('id', $taskId)->first();
        if ($flowInfo) {
            $memo = [
                'status' => 0,
                'overdue_memo' => '',
                'reasons_for_overdue' => '',
                'client_score' => 0,
                'inspection_score' => 0,
            ];
            ProjectFlowMemo::query()->where('id', $taskId)->update($memo);
            $siteInfo = Site::query()->where('id', $flowInfo->site_id)->with(['users'])->first();
            $role = explode(',', $flowInfo->roles);
            $update = [];
            foreach ($role as $item) {
                if ($item != 5) {
                    $user = $siteInfo->users->where('role_id', $item)->first();
                    $update[] = [
                        'user_id' => $user->id ?? 0,
                        'working_hours' => '',
                        'roles_id' => $user->role_id ?? 0,
                        'memo_id' => $taskId,
                    ];
                }
            }
            try {
                DB::transaction(function () use ($update, $taskId) {
                    ProjectFlowMemoRelation::query()->where('memo_id', $taskId)->delete();
                    ProjectFlowMemoRelation::query()->insert($update);
                });
                return response()->json(['message' => '重置成功']);

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

    }

    public function notFound(Request $request, $siteId)
    {
        if (!$request->ajax()) {
            return view('admin.flow.not_found', [
                'siteId' => $siteId
            ]);
        }
        $ids = NotFound::get404List($siteId);

        $list = DB::table('site_status')
            ->where('status', 404)
            ->where('site_id', $siteId)
            ->whereIn('id', $ids)
            ->paginate($request->input('pageSize') ?? 10);

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

    public function isHandle(Request $request, $id)
    {
        $type = $request->input('type');
        DB::table('site_status')->where('id', $id)->update(['is_handle' => $type]);
        return response()->json(['message' => '处理成功']);

    }

    public function isWeekend($date)
    {
        if ((date('w', strtotime($date)) == 6) || (date('w', strtotime($date)) == 0)) {
            return true;
        } else {
            return false;
        }
    }

    public function home()
    {
        $homeService = new HomeService();
        $taskList = $homeService->getTaskList(Role::TYPE_WEB) ?? [];
        $taskList2 = $homeService->getTaskList(Role::TYPE_DESIGNER) ?? [];

        $taskListByWeek = $homeService->getTaskByWeek(Role::TYPE_WEB);
        $taskListByWeek2 = $homeService->getTaskByWeek(Role::TYPE_DESIGNER);

        list($sitesStatusList,
            $thisMonthOnlineSite,
            $ratioOnlineSite,
            $thisMonthOrderSite,
            $ratioOrderSite,
            $thisMonthQualifiedSite,
            $ratioQualifiedSite,
            $thisMonthAssignSite,
            $ratioAssignSite) = $homeService->getProjectOverview();

        $projectStatusList = $homeService->getProjectStatusList(Role::TYPE_WEB);
        $projectStatusList2 = $homeService->getProjectStatusList(Role::TYPE_DESIGNER);

        $monthBySiteList = $homeService->getMonthBySiteList();
        $monthBySiteList2 = $homeService->getMonthBySiteList2();
        $speedMeasurement = $homeService->getSpeedMeasurement();

        $siteListCountByUsers = $homeService->getSiteListByProjectManagers();
        $siteListByOptimizeEditing = $homeService->getSiteListByOptimizeEditing();
        $siteListByProjectHousekeeper = $homeService->getSiteListByProjectHousekeeper();
        $siteRenewListByProjectHousekeeper = $homeService->getSiteRenewListByProjectHousekeeper();

        return view('admin.flow.home', [
            'sitesStatusList' => $sitesStatusList,
            'thisMonthOnlineSite' => $thisMonthOnlineSite,
            'ratioOnlineSite' => $ratioOnlineSite,
            'thisMonthOrderSite' => $thisMonthOrderSite,
            'ratioOrderSite' => $ratioOrderSite,
            'thisMonthQualifiedSite' => $thisMonthQualifiedSite,
            'ratioQualifiedSite' => $ratioQualifiedSite,
            'thisMonthAssignSite' => $thisMonthAssignSite,
            'ratioAssignSite' => $ratioAssignSite,

            'projectStatusList' => $projectStatusList,
            'projectStatusList2' => $projectStatusList2,

            'monthBySiteList' => $monthBySiteList,
            'monthBySiteList2' => $monthBySiteList2,
            'speedMeasurement' => $speedMeasurement,

            'siteListCountByUsers' => $siteListCountByUsers,
            'siteListByOptimizeEditing' => $siteListByOptimizeEditing,
            'siteListByProjectHousekeeper' => $siteListByProjectHousekeeper,
            'siteRenewListByProjectHousekeeper' => $siteRenewListByProjectHousekeeper,

            'date' => date('Y-m-d'),
            'user' => auth()->user(),
            'taskList' => $taskList,
            'taskList2' => $taskList2,
            'taskListByWeek' => $taskListByWeek,
            'taskListByWeek2' => $taskListByWeek2,
        ]);
    }


    public function clientDataUpload(Request $request, $siteId, $type = 0)
    {
        $result = $request->all();
        if (!empty($result)) {
            $this->saveClientData($result);
            return redirect("/admin/flow/clientDataUpload/{$siteId}/1");
        }
        if (!empty($type)) {
            $user = auth()->user();
            $siteIds = DB::table('user_has_sites')->where('user_id', $user->id)->first();
            $siteId = $siteIds->site_id;
        }

        $list = DB::table('client_data_upload')->where('site_id', $siteId)->get();
        $cnTitle = Site::query()->where('id', $siteId)->value('cn_title') ?? '';

        return view('admin.flow.client_data_upload', [
            'siteId' => $siteId,
            'cn_title' => $cnTitle,
            'list' => $list,
            'token' => time(),
        ]);
    }

    private function saveClientData($result)
    {
        $data = [];
        foreach ($result as $key => $item) {
            $array = explode(':', $key);
            if (!empty($array[1])) {
                foreach ($item as $value) {
                    $data[$array[0]][] = $value;
                }
            }
        }

        try {
            DB::transaction(function () use ($data, $result) {

                $user = auth()->user();
                if ($user->role_id == Role::TYPE_CUSTOMER) {
                    foreach ($data as $key => $datum) {
                        $url = [];
                        $urls = DB::table('client_data_upload')
                            ->where('id', $key)
                            ->where('site_id', $result['siteId'])
                            ->value('url');
                        if (!empty($urls)) {
                            $url = json_decode($urls, true);
                        }
                        $datum = array_merge($url, $datum);
                        DB::table('client_data_upload')
                            ->where('id', $key)
                            ->where('site_id', $result['siteId'])
                            ->update(['url' => json_encode($datum)]);
                    }
                } else {
                    foreach ($data as $key => $datum) {
                        $url = [];
                        $urls = DB::table('client_data_upload')
                            ->where('id', $key)
                            ->where('site_id', $result['siteId'])
                            ->value('list');
                        if (!empty($urls)) {
                            $url = json_decode($urls, true);
                        }
                        $datum = array_merge($url, $datum);
                        DB::table('client_data_upload')
                            ->where('id', $key)
                            ->where('site_id', $result['siteId'])
                            ->update(['list' => json_encode($datum)]);
                    }
                }

            });

        } catch (\Throwable $exception) {
            pre_dump($exception->getMessage());
        }
    }


    public function clientData(Request $request, $siteId)
    {
        if (!$request->ajax()) {
            return view('admin.flow.client_data', [
                'siteId' => $siteId,
            ]);
        }

        $result = DB::table('client_data_upload')
            ->where('site_id', $siteId)
            ->paginate($request->input('pageSize') ?? 10);

        $list = $result->items();
        foreach ($list as $value) {
            $value->data_memo = $this->substrFormat($value->data_memo, 20);
        }

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

    public function clientAdd(Request $request, $taskId, $siteId)
    {
        if (!$request->ajax()) {
            $result = DB::table('client_data_upload')
                    ->where('id', $taskId)
                    ->first() ?? [];
            return view('admin.flow.client_data_add', [
                'siteId' => $siteId,
                'taskId' => $taskId,
                'info' => $result,
            ]);
        }

        $request = $request->all();
        $data = [
            'site_id' => $request['siteId'] ?? 0,
            'page' => $request['page'] ?? '',
            'style_path' => $request['style_path'] ?? '',
            'data_memo' => $request['data_memo'] ?? '',
            'deadline' => $request['deadline'] ?? date('Y-m-d'),
        ];
        try {
            if (empty($taskId)) {
                $info = DB::table('client_data_upload')->where('id', $taskId)->first();
                if (empty($info)) {
                    DB::table('client_data_upload')->insert($data);
                }
            } else {
                DB::table('client_data_upload')->where('id', $taskId)->update($data);
            }
            return response()->json(['message' => 'success']);

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

        }
    }

    public function clientDel(Request $request)
    {
        $request = $request->input('ids');
        try {
            DB::table('client_data_upload')->whereIn('id', $request)->delete();
            return response()->json(['message' => 'success']);

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

        }
    }

    //项目数量关联人员统计汇总
    public function projectPersonnelStatistics(Request $request, $type = 1)
    {
        $roles = [Role::TYPE_AE, Role::TYPE_MANAGE_HELPER];

        if (!$request->ajax()) {
            $role = User::query()->where('status', 1)
                ->whereIn('role_id', $roles)
                ->select('id', 'role_id', 'nickname')
                ->get();

            return view('admin.flow.project_personnel_statistics', [
                'roles' => $role
            ]);
        }
        $yearStart = date('Y-01-01 00:00:00');
        $yearEnd = date('Y-m-d H:i:s', strtotime('+1 year', strtotime($yearStart)) - 1);

        $role = Role::query()->pluck('name', 'id');
        $user = User::query()->whereIn('role_id', $roles);

        $editingId = $request->input('editingId');
        if (!empty($editingId) && $editingId != -1) {
            $user->where('id', $editingId);
        }
        if ($editingId == -1) {
            $user->where('role_id', Role::TYPE_AE);
        }
        $projectManagerId = $request->input('projectManagerId');
        if (!empty($projectManagerId) && $projectManagerId != -1) {
            $user->where('id', $projectManagerId);
        }
        if ($projectManagerId == -1) {
            $user->where('role_id', Role::TYPE_MANAGE_HELPER);
        }

        $list = $user->where('status', 1)->withCount(
            ['sites' => function (Builder $query) {
                $query->where('status', 1);
            }, 'sites as sites_online' => function (Builder $query) use ($yearStart, $yearEnd) {
                $query->whereBetween('online_at', [$yearStart, $yearEnd]);
            }])->orderBy('role_id', 'desc')
            ->paginate($request->input('pageSize') ?? 50);

        foreach ($list as $item) {
            $item->role = $role[$item->role_id] ?? '';
        }

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

    public function optimizationPersonnel(Request $request)
    {
        $roles = [Role::TYPE_OPTIMIZATION_EDITING, Role::TYPE_OPTIMIZER];

        if (!$request->ajax()) {
            $role = User::query()->where('status', 1)
                ->whereIn('role_id', $roles)
                ->select('id', 'role_id', 'nickname')
                ->get();

            return view('admin.flow.optimization_personnel', [
                'roles' => $role
            ]);
        }

        $user = User::query()->whereIn('role_id', $roles);
        $optimizationId = $request->input('optimizationId');
        if (!empty($optimizationId) && $optimizationId != -1) {
            $user->where('id', $optimizationId);
        }
        if ($optimizationId == -1) {
            $user->where('role_id', Role::TYPE_OPTIMIZER);
        }
        $optimizationEditingId = $request->input('optimizationEditingId');
        if (!empty($optimizationEditingId) && $optimizationEditingId != -1) {
            $user->where('id', $optimizationEditingId);
        }
        if ($optimizationEditingId == -1) {
            $user->where('role_id', Role::TYPE_OPTIMIZATION_EDITING);
        }

        $yearStart = date('Y-01-01 00:00:00');
        $yearEnd = date('Y-m-d H:i:s', strtotime('+1 year', strtotime($yearStart)) - 1);

        $list = $user->where('status', 1)
            ->withCount([
                'sites as count' => function (Builder $query) {
                    $query->whereIn('status', [2, 3]);
                },
                'sites as implementCount' => function (Builder $query) {
                    $query->where('status', 2);
                },
                'sites as serverCount' => function (Builder $query) {
                    $query->where('status', 3);
                },
                'sites as reachCount' => function (Builder $query) use ($yearStart, $yearEnd) {
                    $query->whereBetween('reach_at', [$yearStart, $yearEnd]);
                },
                'sites as renewalCount' => function (Builder $query) use ($yearStart, $yearEnd) {
                    $query->whereBetween('renewal_at', [$yearStart, $yearEnd]);
                },
            ])
            ->orderBy('role_id', 'desc')
            ->paginate($request->input('pageSize') ?? 50);

        $role = Role::query()->pluck('name', 'id');
        foreach ($list as $item) {
            $item->role = $role[$item->role_id] ?? '';
        }
        return response()->json([
            'rows' => $list->items(),
            'total' => $list->total()
        ]);
    }
}