<?php

namespace app\api\controller;

use app\api\controller\User;
use think\Config;
use think\Controller;
use think\Db;
use think\Log;
use think\Model;
use think\Request;
use think\cache\driver\Memcache;


header("Access-Control-Allow-Origin:*");
header("Access-Control-Allow-Methods:GET, POST, OPTIONS, DELETE");
header("Access-Control-Allow-Headers:DNT,X-Mx-ReqToken,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type, Accept-Language, Origin, Accept-Encoding");


class Work extends Common
{

    //获取内部客户参与的项目
    public function GetWorkInfoByLoginId()
    {
        $param = request()->post();
        $user_id = $param['user_id'];
        $user = new User();
        $project_work = $this->GetProjectList($user_id);

        for ($i = 0; $i < count($project_work); $i++) {
            $involve_manager = $project_work[$i]['involve_manager'];
            $info = $user->GetUserInfoByLoginId($involve_manager);
            if ($info && isset($info['name'])) {
                $project_work[$i]['issue_creator_name'] = $info['name'];
            }
        }
        return $this->sendSuccess($project_work);
    }

    //获取外部客户合作项目
    public function GetWorkInfoByLoginProject()
    {
        $param     = request()->post();
        $user      = new User();
        $user_id   = $param['user_id'];
        $user_info = db('system_user')->where('id', $user_id)->find();
        if ($user_info) {
            $user_project = explode(',', $user_info['user_project']);
            $project_info = db('project_info')->alias('p')
                ->join('project_state s', 's.id =p.project_state', 'left')
                ->whereIn('project_id', $user_project)
                ->where('p.project_state', '<', 10) // 未关闭的项目
                // ->where('p.project_type', 3) //合作类项目
                ->field('p.*, s.desp as project_state_name,1 as project_types')
                ->select();
            foreach ($project_info as &$info) {
                $involve_manager = $info['involve_manager'];
                $userInfo = $user->GetUserInfoByLoginId($involve_manager);
                if ($userInfo && isset($userInfo['name'])) {
                    $info['issue_creator_name'] = $userInfo['name'];
                }
                $info['issue_count'] = $this->GetProjectIssueCount($user_id, $info['project_id']);
                $info['task_count']  = $this->GetProjectTaskCount($user_id, $info['project_id']);
            }
            unset($info);
            return $this->sendSuccess($project_info);
        }
    }

    //获取业主客户参与的项目
    public function GetWorkInfoByLoginProjectCustomer()
    {
        $param     = request()->post();
        $user      = new User();
        $user_id   = $param['user_id'];
        $user_info = db('system_user')->where('id', $user_id)->find();
        if ($user_info) {
            $user_project = explode(',', $user_info['user_project']);
            $project_info = db('project_info')->alias('p')
                ->join('project_state s', 's.id =p.project_state', 'left')
                ->whereIn('project_id', $user_project)
                ->where('p.project_state', '<', 10) // 未关闭的项目
                ->where('p.project_type', 1) //销售类项目
                ->field('p.*, s.desp as project_state_name,1 as project_types')
                ->select();
            foreach ($project_info as &$info) {
                $involve_manager = $info['involve_manager'];
                $userInfo = $user->GetUserInfoByLoginId($involve_manager);
                if ($userInfo && isset($userInfo['name'])) {
                    $info['issue_creator_name'] = $userInfo['name'];
                }
                $info['issue_count'] = $this->GetProjectIssueCountCustomer($user_id, $info['project_id']);
                $info['task_count']  = $this->GetProjectTaskCountCustomer($user_id, $info['project_id']);
            }
            unset($info);
            return $this->sendSuccess($project_info);
        }
    }

    public function GetProjectIssueCountCustomer($user_id, $project_id)
    {
        $count = db('project_issues')->alias('s')
            ->join('project_info i', 'i.project_id =s.project_id', 'left')
            ->join('project_issue_state t', 't.id =s.issue_state', 'left')
            ->where('s.project_id', $project_id)
            ->where('s.issue_state', '<', 10)
            ->field('s.*, i.project_name, i.project_number, t.desp as issue_state_name')
            ->count();

        return $count;
    }

    public function GetProjectTaskCountCustomer($user_id, $project_id)
    {
        $count = db('work_task_info')->alias('s')
            ->join('work_story_info x', 'x.story_id =s.story_id', 'left')
            ->join('project_info i', 'i.project_id =x.work_id', 'left')
            ->join('work_task_state t', 't.id =s.task_state', 'left')
            ->where('x.work_id', $project_id)
            ->count();

        return $count;
    }

    //获取参与的客户项目列表
    public function GetProjectList($user_id)
    {
        //判断登录用户的角色，如果是管理员，就获取所有的项目信息
        $user_info = db('system_user')->where('id', $user_id)->find();
        
        $ret = [];
        if (1 == $user_info['user_role'])
        {
            $ret = db('project_info')->alias('p')
                ->join('project_state s', 's.id =p.project_state', 'left')
                ->where('p.project_state', '<', 10) //未关闭的项目
                ->field('p.*, s.desp as project_state_name,1 as project_types')
                ->select();
        }
        else
        {
            $ret = db('project_info')->alias('p')
                ->join('project_state s', 's.id =p.project_state', 'left')
                ->where('p.project_state', '<', 10) //未关闭的项目
                ->where(function ($query) use ($user_id) {
                    $query->where('p.involve_manager', $user_id)
                        ->whereor('p.involve_members', 'like', $user_id . ',%')
                        ->whereor('p.involve_members', 'like', '%,' . $user_id . ',%')
                        ->whereor('p.involve_members', 'like', $user_id . '')
                        ->whereor('p.involve_members', 'like', '%,' . $user_id);
                })
                ->field('p.*, s.desp as project_state_name,1 as project_types')
                ->select();
        }

        //统计每个项目与登录用户有关的任务数
        for ($i = 0; $i < count($ret); $i++) {
            $ret[$i]['issue_count'] = $this->GetProjectIssueCount($user_id, $ret[$i]['project_id']);
            $ret[$i]['task_count']  = $this->GetProjectTaskCount($user_id, $ret[$i]['project_id']);
        }
        return $ret;
    }

    public function GetProjectIssueList()
    {
        $param       = request()->post();
        $user        = new User();
        $user_id     = $param['user_id'];//    = 60;
        $project_id  = $param['project_id']; //  = 122;
        $issue_state = $param['issue_state']; // = 0;

        $user_info = db('system_user')->where('id', $user_id)->find();
        $count = 0;
        if (1 == $user_info['user_role'])
        {
            $where = [];
            if ($issue_state == 1) {
                $where['s.issue_state'] = array('<', 10); //未关闭
            } else if ($issue_state == 2) {
                $where['s.issue_state'] = array('>', 10);//已关闭
            }

            //负责处理的问题
            $ret = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where($where)
                ->field('s.*, i.project_name, i.project_number, t.desp as issue_state_name, i.involve_manager,1 as project_types')
                ->select();


            for ($i = 0; $i < count($ret); $i++) {
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_processor']);
                if ($info != "")
                {
                    $ret[$i]['issue_processor_name'] = $info['name'];
                }
                else
                {
                    $ret[$i]['issue_processor_name'] = '-';
                }
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_creator']);
                $ret[$i]['issue_creator_name'] = $info['name'];
            }
            return $this->sendSuccess($ret);
        }else{
            $where = [];
            if ($issue_state == 1) {
                $where['s.issue_state'] = array('<', 10); //未关闭
            } else if ($issue_state == 2) {
                $where['s.issue_state'] = array('>', 10);//已关闭
            }

            //负责处理的问题
            $ret = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.issue_processor', $user_id)
                        ->whereor('s.issue_creator', $user_id)
                        ->whereor('i.involve_manager', $user_id);
                })
                ->where($where)
                ->field('s.*, i.project_name, i.project_number, t.desp as issue_state_name, i.involve_manager,1 as project_types')
                ->select();

            for ($i = 0; $i < count($ret); $i++) {
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_processor']);
                if ($info != "")
                {
                    $ret[$i]['issue_processor_name'] = $info['name'];
                }
                else
                {
                    $ret[$i]['issue_processor_name'] = '-';
                }
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_creator']);
                
                // error_log("ret: " . print_r($info, true));
                $ret[$i]['issue_creator_name'] = $info['name'];
            }

            return $this->sendSuccess($ret);
        }

    }

    public function GetProjectIssueCount($user_id, $project_id)
    {
        $user_info = db('system_user')->where('id', $user_id)->find();
        $count = 0;
//        dump($user_info['user_role']);
        if (1 == $user_info['user_role'])
        {
            $count = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where('s.issue_state', '<', 10)
                ->field('s.*, i.project_name, i.project_number, t.desp as issue_state_name')
                ->count();
        }
        else
        {
            $count = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.issue_processor', $user_id)
                        ->whereor('s.issue_creator', $user_id)
                        ->whereor('i.involve_manager', $user_id);
                })
                ->where('s.issue_state', '<', 10)
                ->field('s.*, i.project_name, i.project_number, t.desp as issue_state_name')
                ->count();
        }

        return $count;
    }

    public function GetProjectTaskList()
    {

        $param       = request()->post();
        $user        = new User();
        $user_id     = $param['user_id'];
        $project_id  = $param['project_id'];
        $user_info = db('system_user')->where('id', $user_id)->find();
        if (1 == $user_info['user_role'])
        {
            $where = [];
            if(isset($param['task_state']) && $param['task_state'] != ''){
                $where['s.task_state'] = $param['task_state'];
            }
            if(isset($param['task_processor']) && $param['task_processor'] != ''){
                $where['s.task_processor'] = $param['task_processor'];
            }
            $ret = db('work_task_info')->alias('s')
                ->join('work_story_info y', 'y.story_id =s.story_id', 'left')
                ->join('system_user u', 'u.id =s.task_processor', 'left')
                ->join('work_task_state p', 'p.id =s.task_state', 'left')
                ->where('y.work_id', $project_id)
                ->where($where)
                ->field('s.*, p.desp as task_state_desp, y.story_id,2 as project_types,y.story_manager')
                ->select();

            $user = new User();
            for ($i=0; $i<count($ret); $i++)
            {
                //根据登录账号获取用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['task_processor']);
                $ret[$i]['task_processor_name'] = $user_info['name'];
            }
            return $this->sendSuccess($ret);
        }else{
            $where = [];
            if(isset($param['task_state']) && $param['task_state'] != ''){
                $where['s.task_state'] = $param['task_state'];
            }
            $ret = db('work_task_info')->alias('s')
                ->join('work_story_info y', 'y.story_id =s.story_id', 'left')
                ->join('system_user u', 'u.id =s.task_processor', 'left')
                ->join('work_task_state p', 'p.id =s.task_state', 'left')
                ->where('y.work_id', $project_id)
                ->where($where)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.task_processor', $user_id)
                        ->whereor('y.story_manager', $user_id);
                })
                ->field('s.*, p.desp as task_state_desp, y.story_id,2 as project_types,y.story_manager')
                ->select();

            $user = new User();
            for ($i=0; $i<count($ret); $i++)
            {
                //根据登录账号获取用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['task_processor']);
                $ret[$i]['task_processor_name'] = $user_info['name'];
            }
            return $this->sendSuccess($ret);
        }

    }

    public function GetProjectTaskCount($user_id, $project_id)
    {
        $user_info = db('system_user')->where('id', $user_id)->find();
        $count = 0;
        if (1 == $user_info['user_role'])
        {
            $count = db('work_task_info')->alias('s')
                ->join('work_story_info x', 'x.story_id =s.story_id', 'left')
                ->join('project_info i', 'i.project_id =x.work_id', 'left')
                ->join('work_task_state t', 't.id =s.task_state', 'left')
                ->where('x.work_id', $project_id)
                ->where('s.task_state', '<', 4)
                ->count();
        }
        else 
        {
            $count = db('work_task_info')->alias('s')
                ->join('work_story_info x', 'x.story_id =s.story_id', 'left')
                ->join('project_info i', 'i.project_id =x.work_id', 'left')
                ->join('work_task_state t', 't.id =s.task_state', 'left')
                ->where('x.work_id', $project_id)
                ->where('s.task_state', '<', 4)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.task_processor', $user_id)
                          ->whereor('x.story_manager', $user_id);
                })
                ->count();
        }

        return $count;
    }

    public function GetProjectDevelopProcessor()
    {
        $param = request()->post();
        if (!$param) {
            return [];
        }
        $member_ids = [];
        $array = [];
        if ($param['project_types'] === 1) {
            $project_info = db('project_info')->where('project_id', $param['project_id'])->find();
            if ($project_info && !empty($project_info['involve_members'])) {
                $member_ids = explode(',', $project_info['involve_members']);
            }
        } elseif ($param['project_types'] === 2) {
            $develop_info = db('develop_project')->where('project_id', $param['project_id'])
                ->field('project_members')->find();
            if ($develop_info && !empty($develop_info['project_members'])) {
                $member_ids = explode(',', $develop_info['project_members']);
            }
        }
        for ($i = 0; $i < count($member_ids); $i++){
            $ret =  db('system_user')->alias('su')
                ->join('hr_staff hs', 'su.user_id = hs.staff_id')
                ->whereIn('su.id', $member_ids[$i])
                ->field('su.id, hs.staff_name')
                ->find();
            $array[]  = $ret;
        }
        return $this->sendSuccess($array);
    }

    public function UpdateProDeveProcessor()
    {
        $param = request()->post();
        if($param){
            if($param['project_types']===1){
                $ret=   db('project_issues')
                        ->where('issue_id',$param['issue_id'])
                        ->update(['issue_processor'=>$param['processor'] ,'issue_state' => 2]);
                if($ret){
                    return $this->sendSuccess('分配成功');
                }else{
                    return $this->sendError('分配失败');
                }
            }else if($param['project_types']===2){
                $ret =  db('develop_issues')
                        ->where('issue_id',$param['issue_id'])
                        ->update(['issue_processor'=>$param['processor'],'issue_state' => 2]);
                if($ret){
                    return $this->sendSuccess('分配成功');
                }else{
                    return $this->sendError('分配失败');
                }
            }
        }
    }
    
    public function GetOperationTaskList()
    {
        $param       = request()->post();
        $user        = new User();
        $user_id     = $param['user_id'];
        $story_id    = $param['story_id'];
        $user_info = db('system_user')->where('id', $user_id)->find();
        if (1 == $user_info['user_role'])
        {
            $where = [];
            if(isset($param['task_state']) && $param['task_state'] != ''){
                $where['s.task_state'] = $param['task_state'];
            }
            $ret = db('work_task_info')->alias('s')
                ->join('work_story_info y', 'y.story_id =s.story_id', 'left')
                ->join('system_user u', 'u.id =s.task_processor', 'left')
                ->join('work_task_state p', 'p.id =s.task_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_id', $story_id)
                ->where($where)
                ->field('s.*, p.desp as task_state_desp, y.story_id,2 as project_types')
                ->select();

            $user = new User();
            for ($i=0; $i<count($ret); $i++)
            {
                //根据登录账号获取用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['task_processor']);
                $ret[$i]['task_processor_name'] = $user_info['name'];
            }
            return $this->sendSuccess($ret);
        }else{
            $where = [];
            if(isset($param['task_state']) && $param['task_state'] != ''){
                $where['s.task_state'] = $param['task_state'];
            }
            $ret = db('work_task_info')->alias('s')
                ->join('work_story_info y', 'y.story_id =s.story_id', 'left')
                ->join('system_user u', 'u.id =s.task_processor', 'left')
                ->join('work_task_state p', 'p.id =s.task_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_id', $story_id)
                ->where($where)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.task_processor', $user_id)
                        ->whereor('y.story_manager', $user_id);
                })
                ->field('s.*, p.desp as task_state_desp, y.story_id,2 as project_types')
                ->select();

            $user = new User();
            for ($i=0; $i<count($ret); $i++)
            {
                //根据登录账号获取用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['task_processor']);
                $ret[$i]['task_processor_name'] = $user_info['name'];
            }
            return $this->sendSuccess($ret);
        }

    }
    
    public function GetOperationStoryList()
    {

        $param       = request()->post();
        $user        = new User();
        $user_id     = $param['user_id'];
        $user_info = db('system_user')->where('id', $user_id)->find();
        if (1 == $user_info['user_role'])
        {
            $where = [];
            if(isset($param['story_state']) && $param['story_state'] != ''){
                $where['s.story_state'] = $param['story_state'];
            }
            $ret = db('work_story_info')->alias('y')
                ->join('work_story_state p', 'p.id =y.story_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_state', '<', 4) //未完成的Story
                ->where($where)
                ->field('y.*, p.desp as story_state_desp')
                ->select();

            $user = new User();
            for ($i=0; $i<count($ret); $i++)
            {
                //根据登录账号获取Story管理员用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['story_manager']);
                $ret[$i]['story_manager_name'] = $user_info['name'];
                $ret[$i]['story_tasks']        = $this->GetOperationTaskCount($user_id,$ret[$i]['story_id']);
            }

            //dump($ret);
            return $this->sendSuccess($ret);
        }else{
            $where = [];
            if(isset($param['story_state']) && $param['story_state'] != ''){
                $where['s.story_state'] = $param['story_state'];
            }
            $ret = db('work_story_info')->alias('y')
                ->join('work_story_state p', 'p.id =y.story_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_state', '<', 4) //未完成的Story
                ->where($where)
                ->where(function ($query) use ($user_id) {
                    $query->where('y.story_manager', $user_id)
                        ->whereor('y.story_member', 'like', $user_id . ',%')
                        ->whereor('y.story_member', 'like', '%,' . $user_id . ',%')
                        ->whereor('y.story_member',  $user_id)
                        ->whereor('y.story_member', 'like', '%,' . $user_id);
                })
                ->field('y.*, p.desp as story_state_desp')
                ->select();

            $user = new User();
            for ($i=0; $i<count($ret); $i++)
            {
                //根据登录账号获取Story管理员用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['story_manager']);
                $ret[$i]['story_manager_name'] = $user_info['name'];
                $ret[$i]['story_tasks']        = $this->GetOperationTaskCount($user_id,$ret[$i]['story_id']);
            }

            //dump($ret);
            return $this->sendSuccess($ret);
        }
    }

    public function GetOperationTaskCount($user_id,$story_id)
    {

        $param       = request()->post();
        $user        = new User();
        $user_info = db('system_user')->where('id', $user_id)->find();
        if (1 == $user_info['user_role'])
        {
            $where = [];
            if(isset($param['task_state']) && $param['task_state'] != ''){
                $where['s.task_state'] = $param['task_state'];
            }
            $ret = db('work_task_info')->alias('s')
                ->join('work_story_info y', 'y.story_id =s.story_id', 'left')
                ->join('system_user u', 'u.id =s.task_processor', 'left')
                ->join('work_task_state p', 'p.id =s.task_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_id', $story_id)
                ->where($where)
                ->count();
            return $ret;
        }else{
            $where = [];
            if(isset($param['task_state']) && $param['task_state'] != ''){
                $where['s.task_state'] = $param['task_state'];
            }
            $ret = db('work_task_info')->alias('s')
                ->join('work_story_info y', 'y.story_id =s.story_id', 'left')
                ->join('system_user u', 'u.id =s.task_processor', 'left')
                ->join('work_task_state p', 'p.id =s.task_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_id', $story_id)
                ->where($where)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.task_processor', $user_id)
                        ->whereor('y.story_manager', $user_id);
                })
                ->count();
            return $ret;
        }

    }

    public function getEmployeeWorkStatistics()
    {
        $param = request()->post();
        $timeRange = $param['timeRange'] ?? 'month';
        $startDate = '';
        $endDate = '';

        if ($timeRange === 'week') {
            $startDate = date('Y-m-d', strtotime('this week'));
            $endDate = date('Y-m-d', strtotime('this week +6 days'));
        } elseif ($timeRange === 'month') {
            $startDate = date('Y-m-01');
            $endDate = date('Y-m-t');
        } elseif ($timeRange === 'year') {
            $startDate = date('Y-01-01');
            $endDate = date('Y-12-31');
        }


        $StaffList = db('system_user')->alias('u')
            ->join('hr_staff s', 's.staff_id = u.user_id', 'left')
            ->where('u.user_type', 1)
            ->field('u.id as staff_id, s.staff_name, s.staff_dept')
            ->select();

        $user = new User();
        $statistics = [];

        foreach ($StaffList as $employee) {
            $staffId = $employee['staff_id'];
            $employeeName = $employee['staff_name'];
            $staffDept = $employee['staff_dept'];

            $totalTaskCount = 0;
            $totalIssueCount = 0;
            $onTimeCount = 0;
            $overTimeCount = 0;
            $project_work = $this->GetProjectListState($staffId, $startDate, $endDate);
            foreach ($project_work as $work) {
                $involve_manager = $work['involve_manager'];
                $info = $user->GetUserInfoByLoginId($involve_manager);
                if ($info && isset($info['name'])) {
                    $work['issue_creator_name'] = $info['name'];
                }
                if (isset($work['task_count'])) {
                    $totalTaskCount += $work['task_count']['task_count'];
                }
                if (isset($work['issue_count'])) {
                    $totalIssueCount += $work['issue_count']['issue_count'];
                }
                if (isset($work['issue_count'])) {
                    $onTimeCount += $work['issue_count']['on_count'] + $work['task_count']['on_count'];
                }
                if (isset($work['task_count'])) {
                    $overTimeCount += $work['task_count']['over_count'] + $work['task_count']['over_count'];
                }
            }

            $deptIds = explode(',', $staffDept);
            if (in_array(2, $deptIds)) {
                $operationTaskCount = $this->GetOperationWorkTaskCount($staffId, $startDate, $endDate);
                $totalTaskCount += $operationTaskCount['2Type_count'];
                $onTimeCount += $operationTaskCount['on_count'];
                $overTimeCount += $operationTaskCount['over_count'];
            }

            $statistics[] = [
                'employeeName' => $employeeName,
                'taskCount' => $totalTaskCount,
                'issueCount' => $totalIssueCount,
                'onTimeCount' => $onTimeCount,
                'overTimeCount' => $overTimeCount,
            ];
        }

        return $this->sendSuccess($statistics);
    }


    public function GetProjectListState($user_id, $startDate, $endDate)
    {
        $ret = db('project_info')->alias('p')
            ->join('project_state s', 's.id =p.project_state', 'left')
            ->where(function ($query) use ($user_id) {
                $query->where('p.involve_manager', $user_id)
                    ->whereor('p.involve_members', 'like', $user_id . ',%')
                    ->whereor('p.involve_members', 'like', '%,' . $user_id . ',%')
                    ->whereor('p.involve_members', 'like', $user_id . '')
                    ->whereor('p.involve_members', 'like', '%,' . $user_id);
            })
//            ->whereBetween('p.create_time', [$startDate, $endDate])
            ->field('p.*, s.desp as project_state_name,1 as project_types')
            ->select();

        //统计每个项目与登录用户有关的任务数
        for ($i = 0; $i < count($ret); $i++) {
            $ret[$i]['issue_count'] = $this->GetProjectIssueCounts($user_id, $ret[$i]['project_id'], $startDate, $endDate);
            $ret[$i]['task_count']  = $this->GetProjectTaskCounts($user_id, $ret[$i]['project_id'], $startDate, $endDate);
        }
        return $ret;
    }

    public function GetProjectIssueCounts($user_id, $project_id, $startDate, $endDate)
    {
        $count = db('project_issues')->alias('s')
            ->join('project_info i', 'i.project_id =s.project_id', 'left')
            ->join('project_issue_state t', 't.id =s.issue_state', 'left')
            ->where('s.project_id', $project_id)
            ->where(function ($query) use ($user_id) {
                $query->where('s.issue_processor', $user_id)
                    ->whereor('s.issue_creator', $user_id)
                    ->whereor('i.involve_manager', $user_id);
            })
            ->whereBetween('s.create_time', [$startDate, $endDate])
            ->count();

        $OnCount = db('project_issues')->alias('s')
            ->join('project_info i', 'i.project_id =s.project_id', 'left')
            ->join('project_issue_state t', 't.id =s.issue_state', 'left')
            ->where('s.project_id', $project_id)
            ->where(function ($query) use ($user_id) {
                $query->where('s.issue_processor', $user_id)
                    ->whereor('s.issue_creator', $user_id)
                    ->whereor('i.involve_manager', $user_id);
            })
            ->whereBetween('s.create_time', [$startDate, $endDate])
            ->where('s.real_close_time','exp','<= s.plan_close_time')
            ->count();

        $OverCount = db('project_issues')->alias('s')
            ->join('project_info i', 'i.project_id = s.project_id', 'left')
            ->join('project_issue_state t', 't.id = s.issue_state', 'left')
            ->where('s.project_id', $project_id)
            ->where(function ($query) use ($user_id) {
                $query->where('s.issue_processor', $user_id)
                    ->whereor('s.issue_creator', $user_id)
                    ->whereor('i.involve_manager', $user_id);
            })
            ->whereBetween('s.create_time', [$startDate, $endDate])
            ->where('s.real_close_time','exp','> s.plan_close_time')
            ->count();
        $ret = [];
        $ret['issue_count'] = $count;
        $ret['on_count'] = $OnCount;
        $ret['over_count'] = $OverCount;
        return $ret;
    }

    public function GetProjectTaskCounts($user_id, $project_id, $startDate, $endDate)
    {
        $count = db('work_task_info')->alias('s')
            ->join('work_story_info x', 'x.story_id =s.story_id', 'left')
            ->join('project_info i', 'i.project_id =x.work_id', 'left')
            ->join('work_task_state t', 't.id =s.task_state', 'left')
            ->where('x.work_id', $project_id)
            ->where(function ($query) use ($user_id) {
                $query->where('s.task_processor', $user_id)
                    ->whereor('x.story_manager', $user_id);
            })
            ->whereBetween('s.create_time', [$startDate, $endDate])
            ->count();

        $OnCount = db('work_task_info')->alias('s')
            ->join('work_story_info x', 'x.story_id =s.story_id', 'left')
            ->join('project_info i', 'i.project_id =x.work_id', 'left')
            ->join('work_task_state t', 't.id =s.task_state', 'left')
            ->where('x.work_id', $project_id)
            ->where(function ($query) use ($user_id) {
                $query->where('s.task_processor', $user_id)
                    ->whereor('x.story_manager', $user_id);
            })
            ->whereBetween('s.create_time', [$startDate, $endDate])
            ->where('s.real_close_time','exp','<= s.plan_close_time')
            ->count();

        $OverCount = db('work_task_info')->alias('s')
            ->join('work_story_info x', 'x.story_id =s.story_id', 'left')
            ->join('project_info i', 'i.project_id =x.work_id', 'left')
            ->join('work_task_state t', 't.id =s.task_state', 'left')
            ->where('x.work_id', $project_id)
            ->where(function ($query) use ($user_id) {
                $query->where('s.task_processor', $user_id)
                    ->whereor('x.story_manager', $user_id);
            })
            ->whereBetween('s.create_time', [$startDate, $endDate])
            ->where('s.real_close_time','exp','> s.plan_close_time')
            ->count();
        $ret = [];
        $ret['task_count'] = $count;
        $ret['on_count'] = $OnCount;
        $ret['over_count'] = $OverCount;
        return $ret;
    }

    public function GetOperationWorkTaskCount($user_id, $startDate, $endDate)
    {
        $count = db('work_task_info')
            ->where('task_processor', $user_id)
            ->whereBetween('create_time', [$startDate, $endDate])
            ->count();
        $On_Count = db('work_task_info')
            ->where('task_processor', $user_id)
            ->whereBetween('create_time', [$startDate, $endDate])
            ->where('real_close_time','exp','<= plan_close_time')
            ->count();
        $Over_count = db('work_task_info')
            ->where('task_processor', $user_id)
            ->whereBetween('create_time', [$startDate, $endDate])
            ->where('real_close_time','exp','> plan_close_time')
            ->count();
        $ret = [];
        $ret['2Type_count'] = $count;
        $ret['on_count'] = $On_Count;
        $ret['over_count'] = $Over_count;
        return $ret;
    }

    //获取内部客户参与的项目 - 分页版本
    public function GetWorkInfoByLoginIdPaginated()
    {
        $param = request()->post();
        $user_id = $param['user_id'];
        $currPage = isset($param['currPage']) ? $param['currPage'] : 1;
        $pageSize = isset($param['pageSize']) ? $param['pageSize'] : 10;
        $project_name = isset($param['project_name']) ? $param['project_name'] : '';
        
        $user = new User();
        $project_work = $this->GetProjectListPaginated($user_id, $currPage, $pageSize, $project_name);

        for ($i = 0; $i < count($project_work['list']); $i++) {
            $involve_manager = $project_work['list'][$i]['involve_manager'];
            $info = $user->GetUserInfoByLoginId($involve_manager);
            if ($info && isset($info['name'])) {
                $project_work['list'][$i]['issue_creator_name'] = $info['name'];
            }
        }
        
        $res['list'] = $project_work['list'];
        $res['total'] = $project_work['total'];
        return $this->sendSuccess($res);
    }

    //获取参与的客户项目列表 - 分页版本
    public function GetProjectListPaginated($user_id, $currPage, $pageSize, $project_name = '')
    {
        //判断登录用户的角色，如果是管理员，就获取所有的项目信息
        $user_info = db('system_user')->where('id', $user_id)->find();
        
        $query = db('project_info')->alias('p')
            ->join('project_state s', 's.id =p.project_state', 'left')
            ->where('p.project_state', '<', 10) //未关闭的项目
            ->field('p.*, s.desp as project_state_name,1 as project_types');
        
        // 添加项目名称模糊查询
        if (!empty($project_name)) {
            $query->where('p.project_name', 'like', '%' . $project_name . '%');
        }
        
        if (1 != $user_info['user_role']) {
            $query->where(function ($query) use ($user_id) {
                $query->where('p.involve_manager', $user_id)
                    ->whereor('p.involve_members', 'like', $user_id . ',%')
                    ->whereor('p.involve_members', 'like', '%,' . $user_id . ',%')
                    ->whereor('p.involve_members', 'like', $user_id . '')
                    ->whereor('p.involve_members', 'like', '%,' . $user_id);
            });
        }
        
        // 获取分页数据
        $ret = $query->page($currPage, $pageSize)->select();
        
        // 获取总数
        $totalQuery = db('project_info')->alias('p')
            ->join('project_state s', 's.id =p.project_state', 'left')
            ->where('p.project_state', '<', 10);
            
        // 添加项目名称模糊查询到总数查询
        if (!empty($project_name)) {
            $totalQuery->where('p.project_name', 'like', '%' . $project_name . '%');
        }
            
        if (1 != $user_info['user_role']) {
            $totalQuery->where(function ($query) use ($user_id) {
                $query->where('p.involve_manager', $user_id)
                    ->whereor('p.involve_members', 'like', $user_id . ',%')
                    ->whereor('p.involve_members', 'like', '%,' . $user_id . ',%')
                    ->whereor('p.involve_members', 'like', $user_id . '')
                    ->whereor('p.involve_members', 'like', '%,' . $user_id);
            });
        }
        
        $total = $totalQuery->count();

        //统计每个项目与登录用户有关的任务数
        for ($i = 0; $i < count($ret); $i++) {
            $ret[$i]['issue_count'] = $this->GetProjectIssueCount($user_id, $ret[$i]['project_id']);
            $ret[$i]['task_count']  = $this->GetProjectTaskCount($user_id, $ret[$i]['project_id']);
        }
        
        return [
            'list' => $ret,
            'total' => $total
        ];
    }

    //获取项目问题列表 - 分页版本
    public function GetProjectIssueListPaginated()
    {
        $param       = request()->post();
        $user        = new User();
        $user_id     = $param['user_id'];
        $project_id  = $param['project_id'];
        $issue_state = $param['issue_state'];
        $currPage    = isset($param['currPage']) ? $param['currPage'] : 1;
        $pageSize    = isset($param['pageSize']) ? $param['pageSize'] : 10;

        $user_info = db('system_user')->where('id', $user_id)->find();
        
        if (1 == $user_info['user_role']) {
            $where = [];
            if ($issue_state == 1) {
                $where['s.issue_state'] = array('<', 10); //未关闭
            } else if ($issue_state == 2) {
                $where['s.issue_state'] = array('>', 10);//已关闭
            }

            // 获取分页数据
            $query = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where($where)
                ->field('s.*, i.project_name, i.project_number, t.desp as issue_state_name, i.involve_manager,1 as project_types');
                
            $ret = $query->page($currPage, $pageSize)->select();
            
            // 获取总数
            $total = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where($where)
                ->count();

            for ($i = 0; $i < count($ret); $i++) {
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_processor']);
                if ($info != "") {
                    $ret[$i]['issue_processor_name'] = $info['name'];
                } else {
                    $ret[$i]['issue_processor_name'] = '-';
                }
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_creator']);
                $ret[$i]['issue_creator_name'] = $info['name'];
            }
            
            $res['list'] = $ret;
            $res['total'] = $total;
            return $this->sendSuccess($res);
        } else {
            $where = [];
            if ($issue_state == 1) {
                $where['s.issue_state'] = array('<', 10); //未关闭
            } else if ($issue_state == 2) {
                $where['s.issue_state'] = array('>', 10);//已关闭
            }

            // 获取分页数据
            $query = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.issue_processor', $user_id)
                        ->whereor('s.issue_creator', $user_id)
                        ->whereor('i.involve_manager', $user_id);
                })
                ->where($where)
                ->field('s.*, i.project_name, i.project_number, t.desp as issue_state_name, i.involve_manager,1 as project_types');
                
            $ret = $query->page($currPage, $pageSize)->select();
            
            // 获取总数
            $total = db('project_issues')->alias('s')
                ->join('project_info i', 'i.project_id =s.project_id', 'left')
                ->join('project_issue_state t', 't.id =s.issue_state', 'left')
                ->where('s.project_id', $project_id)
                ->where(function ($query) use ($user_id) {
                    $query->where('s.issue_processor', $user_id)
                        ->whereor('s.issue_creator', $user_id)
                        ->whereor('i.involve_manager', $user_id);
                })
                ->where($where)
                ->count();

            for ($i = 0; $i < count($ret); $i++) {
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_processor']);
                if ($info != "") {
                    $ret[$i]['issue_processor_name'] = $info['name'];
                } else {
                    $ret[$i]['issue_processor_name'] = '-';
                }
                $info = $user->GetUserInfoByLoginId($ret[$i]['issue_creator']);
                $ret[$i]['issue_creator_name'] = $info['name'];
            }

            $res['list'] = $ret;
            $res['total'] = $total;
            return $this->sendSuccess($res);
        }
    }

    //获取运营Story列表 - 分页版本
    public function GetOperationStoryListPaginated()
    {
        $param       = request()->post();
        $user        = new User();
        $user_id     = $param['user_id'];
        $currPage    = isset($param['currPage']) ? $param['currPage'] : 1;
        $pageSize    = isset($param['pageSize']) ? $param['pageSize'] : 10;
        
        $user_info = db('system_user')->where('id', $user_id)->find();
        
        if (1 == $user_info['user_role']) {
            $where = [];
            if(isset($param['story_state']) && $param['story_state'] != ''){
                $where['y.story_state'] = $param['story_state'];
            }
            
            // 获取分页数据
            $query = db('work_story_info')->alias('y')
                ->join('work_story_state p', 'p.id =y.story_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_state', '<', 4) //未完成的Story
                ->where($where)
                ->field('y.*, p.desp as story_state_desp');
                
            $ret = $query->page($currPage, $pageSize)->select();
            
            // 获取总数
            $total = db('work_story_info')->alias('y')
                ->join('work_story_state p', 'p.id =y.story_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_state', '<', 4)
                ->where($where)
                ->count();

            for ($i=0; $i<count($ret); $i++) {
                //根据登录账号获取Story管理员用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['story_manager']);
                $ret[$i]['story_manager_name'] = $user_info['name'];
                $ret[$i]['story_tasks'] = $this->GetOperationTaskCount($user_id,$ret[$i]['story_id']);
            }

            $res['list'] = $ret;
            $res['total'] = $total;
            return $this->sendSuccess($res);
        } else {
            $where = [];
            if(isset($param['story_state']) && $param['story_state'] != ''){
                $where['y.story_state'] = $param['story_state'];
            }
            
            // 获取分页数据
            $query = db('work_story_info')->alias('y')
                ->join('work_story_state p', 'p.id =y.story_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_state', '<', 4) //未完成的Story
                ->where($where)
                ->where(function ($query) use ($user_id) {
                    $query->where('y.story_manager', $user_id)
                        ->whereor('y.story_member', 'like', $user_id . ',%')
                        ->whereor('y.story_member', 'like', '%,' . $user_id . ',%')
                        ->whereor('y.story_member',  $user_id)
                        ->whereor('y.story_member', 'like', '%,' . $user_id);
                })
                ->field('y.*, p.desp as story_state_desp');
                
            $ret = $query->page($currPage, $pageSize)->select();
            
            // 获取总数
            $total = db('work_story_info')->alias('y')
                ->join('work_story_state p', 'p.id =y.story_state', 'left')
                ->where('y.story_type', 2)
                ->where('y.story_state', '<', 4)
                ->where($where)
                ->where(function ($query) use ($user_id) {
                    $query->where('y.story_manager', $user_id)
                        ->whereor('y.story_member', 'like', $user_id . ',%')
                        ->whereor('y.story_member', 'like', '%,' . $user_id . ',%')
                        ->whereor('y.story_member',  $user_id)
                        ->whereor('y.story_member', 'like', '%,' . $user_id);
                })
                ->count();

            for ($i=0; $i<count($ret); $i++) {
                //根据登录账号获取Story管理员用户姓名
                $user_info = $user->GetUserInfoByLoginId($ret[$i]['story_manager']);
                $ret[$i]['story_manager_name'] = $user_info['name'];
                $ret[$i]['story_tasks'] = $this->GetOperationTaskCount($user_id,$ret[$i]['story_id']);
            }

            $res['list'] = $ret;
            $res['total'] = $total;
            return $this->sendSuccess($res);
        }
    }

}