<?php
class stakeholderModel extends model
{
    /**
     * Create a stakeholder.
     *
     * @param  int objectID
     * @access public
     * @return int|bool
     */
    public function create($objectID = 0)
    {
        $stakeholder = new stdclass();
        $data = fixer::input('post')
            ->setDefault('objectType', $this->app->tab)
            ->setDefault('objectID', $objectID)
            ->setDefault('createdBy', $this->app->user->account)
            ->setDefault('createdDate', helper::today())
            ->stripTags($this->config->stakeholder->editor->create['id'], $this->config->allowedTags)
            ->remove('uid')
            ->get();

        $account = isset($data->user) ? $data->user : '';
        $stakeholder->user = $account;
        if($data->from != 'outside')
        {
            if(!$account)
            {
                dao::$errors['user'] = $this->lang->stakeholder->userEmpty;
                return false;
            }
            $user = new stdclass();
            $user->nature   = $data->nature;
            $user->analysis = $data->analysis;
            $user->strategy = $data->strategy;

            $this->dao->update(TABLE_USER)->data($user)->where('account')->eq($account)->exec();
        }
        else
        {
            /* If it's an outsider and it's added for the first time, insert to user table. */
            if(!$account)
            {
                if(!$data->name)
                {
                    dao::$errors['name'] = $this->lang->stakeholder->nameEmpty;
                    return false;
                }

                $companyID = $data->company;
                if($data->company and isset($data->new))
                {
                    $company = new stdclass();
                    $company->name = $data->company;
                    $this->dao->insert(TABLE_COMPANY)->data($company)->exec();

                    $companyID = $this->dao->lastInsertID();
                }

                if(!$companyID)
                {
                    dao::$errors[] = $this->lang->stakeholder->companyEmpty;
                    return false;
                }

                $user = new stdclass();
                $user->type     = 'outside';
                $user->realname = $data->name;
                $user->account  = mt_rand(1111, 99999);
                $user->company  = $companyID;
                $user->phone    = $data->phone;
                $user->qq       = $data->qq;
                $user->weixin   = $data->weixin;
                $user->email    = $data->email;
                $user->nature   = $data->nature;
                $user->analysis = $data->analysis;
                $user->strategy = $data->strategy;

                $this->dao->insert(TABLE_USER)->data($user)->exec();
                $userID  = $this->dao->lastInsertID();
                $account = 'u' . $userID;
                $this->dao->update(TABLE_USER)->set('account')->eq($account)->where('id')->eq($userID)->exec();
                $stakeholder->user = $account;
            }
        }

        $stakeholder->objectType  = $data->objectType;
        $stakeholder->objectID    = $data->objectID;
        $stakeholder->key         = $data->key;
        $stakeholder->from        = $data->from;
        $stakeholder->type        = $data->from == 'team' ? 'inside' : 'outside';
        $stakeholder->createdBy   = $this->app->user->account;
        $stakeholder->createdDate = helper::today();

        $this->dao->insert(TABLE_STAKEHOLDER)->data($stakeholder)
            ->check('user', 'unique', "objectID = {$stakeholder->objectID} and deleted = '0'")
            ->autoCheck()
            ->exec();
        $stakeholderID = $this->dao->lastInsertID();

        if(!dao::isError())
        {
            $this->loadModel('user')->updateUserView($stakeholder->objectID, $stakeholder->objectType, $stakeholder->user);

            /* Update linked products view. */
            if($stakeholder->objectType == 'project' and $stakeholder->objectID)
            {
                $this->loadModel('project')->updateInvolvedUserView($stakeholder->objectID, $stakeholder->user);
            }

            if($stakeholder->objectType == 'program' and $stakeholder->objectID)
            {
                $programID = $stakeholder->objectID;
                /* Update children user view. */
                $childPrograms = $this->dao->select('id')->from(TABLE_PROJECT)->where('path')->like("%,$programID,%")->andWhere('type')->eq('program')->fetchPairs();
                $childProjects = $this->dao->select('id')->from(TABLE_PROJECT)->where('path')->like("%,$programID,%")->andWhere('type')->eq('project')->fetchPairs();
                $childProducts = $this->dao->select('id')->from(TABLE_PRODUCT)->where('program')->eq($programID)->fetchPairs();

                if(!empty($childPrograms)) $this->user->updateUserView($childPrograms, 'program', $stakeholder->user);
                if(!empty($childProjects)) $this->user->updateUserView($childProjects, 'project', $stakeholder->user);
                if(!empty($childProducts)) $this->user->updateUserView($childProducts, 'product', $stakeholder->user);
            }

            return $stakeholderID;
        }
        return false;
    }

    /**
     * Batch create stakeholders for a project.
     *
     * @param  int    $projectID
     * @access public
     * @return array
     */
    public function batchCreate($projectID)
    {
        $this->loadModel('action');
        $data = (array)fixer::input('post')->get();

        $members  = $this->loadModel('user')->getTeamMemberPairs($projectID, 'project');
        $accounts = array_unique($data['accounts']);
        $oldJoin  = $this->dao->select('`user`, createdDate')->from(TABLE_STAKEHOLDER)->where('objectID')->eq($projectID)->andWhere('objectType')->eq('project')->fetchPairs();
        $this->dao->delete()->from(TABLE_STAKEHOLDER)->where('objectID')->eq($projectID)->andWhere('objectType')->eq('project')->exec();

        $stakeholderList = array();
        foreach($accounts as $key => $account)
        {
            if(empty($account)) continue;

            $stakeholder = new stdclass();
            $stakeholder->objectID    = $projectID;
            $stakeholder->objectType  = 'project';
            $stakeholder->user        = $account;
            $stakeholder->type        = in_array($account, array_keys($members)) ? 'inside' : 'outside';
            $stakeholder->createdBy   = $this->app->user->account;
            $stakeholder->createdDate = isset($oldJoin[$account]) ? $oldJoin[$account] : helper::today();

            $this->dao->insert(TABLE_STAKEHOLDER)->data($stakeholder)->exec();

            $stakeholderID     = $this->dao->lastInsertId();
            $stakeholderList[] = $stakeholderID;
            $this->action->create('stakeholder', $stakeholderID, 'added');
        }

        /* Only changed account update userview. */
        $oldAccounts     = array_keys($oldJoin);
        $changedAccounts = array_diff($accounts, $oldAccounts);
        $changedAccounts = array_merge($changedAccounts, array_diff($oldAccounts, $accounts));
        $changedAccounts = array_unique($changedAccounts);

        $this->loadModel('user')->updateUserView($projectID, 'project', $changedAccounts);

        $this->loadModel('project')->updateInvolvedUserView($projectID, $changedAccounts);

        if($stakeholder->objectType == 'program' and $stakeholder->objectID)
        {
            $programID = $stakeholder->objectID;
            /* Update children user view. */
            $childPrograms = $this->dao->select('id')->from(TABLE_PROJECT)->where('path')->like("%,$programID,%")->andWhere('type')->eq('program')->fetchPairs();
            $childProjects = $this->dao->select('id')->from(TABLE_PROJECT)->where('path')->like("%,$programID,%")->andWhere('type')->eq('project')->fetchPairs();
            $childProducts = $this->dao->select('id')->from(TABLE_PRODUCT)->where('program')->eq($programID)->fetchPairs();

            if(!empty($childPrograms)) $this->user->updateUserView($childPrograms, 'program', $stakeholder->user);
            if(!empty($childProjects)) $this->user->updateUserView($childProjects, 'project', $stakeholder->user);
            if(!empty($childProducts)) $this->user->updateUserView($childProducts, 'product', $stakeholder->user);
        }

        return $stakeholderList;
    }

    /**
     * Edit a stakeholder.
     *
     * @param  int $stakeholderID
     * @access public
     * @return void
     */
    public function edit($stakeholderID)
    {
        $oldStakeholder = $this->getByID($stakeholderID);
        $data = fixer::input('post')
            ->stripTags($this->config->stakeholder->editor->edit['id'], $this->config->allowedTags)
            ->remove('uid')
            ->get();

        $user = new stdclass();
        if($oldStakeholder->from == 'outside')
        {
            $user->realname = $data->name;
            $user->phone    = $data->phone;
            $user->qq       = $data->qq;
            $user->weixin   = $data->weixin;
            $user->email    = $data->email;
        }

        $user->nature   = $data->nature;
        $user->analysis = $data->analysis;
        $user->strategy = $data->strategy;

        $this->dao->update(TABLE_USER)->data($user)->where('account')->eq($oldStakeholder->user)->exec();

        $stakeholder = new stdclass();
        $stakeholder->key        = $data->key;
        $stakeholder->editedBy   = $this->app->user->account;
        $stakeholder->editedDate = helper::today();

        $this->dao->update(TABLE_STAKEHOLDER)->data($stakeholder)
            ->autoCheck()
            ->where('id')->eq($stakeholderID)
            ->exec();

        if(!dao::isError()) return common::createChanges($oldStakeholder, $stakeholder);
        return false;
    }

    /**
     * Get stakeholder list.
     *
     * @param  int    $projectID
     * @param  string $browseType
     * @param  string $orderBy
     * @param  object $pager
     * @access public
     * @return array
     */
    public function getStakeholders($projectID, $browseType = 'all', $orderBy = 'id_desc', $pager = null)
    {
        $stakeholders = $this->dao->select('t1.*, t2.phone, t2.realname as name, t2.email, t2.qq, t2.weixin, t2.nature, t2.analysis, t2.strategy, t3.name as companyName, t4.model as projectModel')->from(TABLE_STAKEHOLDER)->alias('t1')
            ->leftJoin(TABLE_USER)->alias('t2')->on('t1.user=t2.account')
            ->leftJoin(TABLE_COMPANY)->alias('t3')->on('t2.company=t3.id')
            ->leftJoin(TABLE_PROJECT)->alias('t4')->on('t1.objectID=t4.id')
            ->where('t1.deleted')->eq('0')
            ->andWhere('t1.objectID')->eq($projectID)
            ->beginIF($browseType == 'inside')->andWhere('t1.type')->eq('inside')->fi()
            ->beginIF($browseType == 'outside')->andWhere('t1.type')->eq('outside')->fi()
            ->beginIF($browseType == 'key')->andWhere('t1.key')->ne('0')->fi()
            ->orderBy($orderBy)
            ->page($pager)
            ->fetchAll('id');

        return $stakeholders;
    }

    /**
     * Get stakeholder pairs.
     *
     * @param  int    $projectID
     * @access public
     * @return array
     */
    public function getStakeHolderPairs($projectID)
    {
        $stakeholders = $this->dao->select('t1.user, t2.realname')->from(TABLE_STAKEHOLDER)->alias('t1')
            ->leftJoin(TABLE_USER)->alias('t2')->on('t1.user=t2.account')
            ->where('t1.deleted')->eq('0')
            ->andWhere('t1.objectID')->eq($projectID)
            ->orderBy('t1.id_desc')
            ->fetchPairs();

        return $stakeholders;
    }

    /**
     * Get self stakeholders by object id list.
     *
     * @param  array  $objectIdList
     * @access public
     * @return array
     */
    public function getStakeholderGroup($objectIdList)
    {
        $stakeholders = $this->dao->select('objectID, user')->from(TABLE_STAKEHOLDER)->where('objectID')->in($objectIdList)->andWhere('deleted')->eq('0')->fetchAll();

        $stakeholderGroup = array();
        foreach($stakeholders as $stakeholder)
        {
            $stakeholderGroup[$stakeholder->objectID][$stakeholder->user] = $stakeholder->user;
        }

        return $stakeholderGroup;
    }

    /**
     * Get parent stakeholder group by object id list.
     *
     * @param  array  $objectIdList
     * @access public
     * @return array
     */
    public function getParentStakeholderGroup($objectIdList)
    {
        $objects = $this->dao->select('id, path, parent')->from(TABLE_PROJECT)->where('id')->in($objectIdList)->andWhere('acl')->ne('open')->fetchAll('id');

        $parents = array();
        foreach($objects as $object)
        {
            if($object->parent == 0) continue;
            foreach(explode(',', $object->path) as $objectID)
            {
                if(empty($objectID)) continue;
                if($objectID == $object->id) continue;
                $parents[$objectID][] = $object->id;
            }
        }

        if(empty($parents)) return array();

        /* Get all parent stakeholders.*/
        $parentStakeholders = $this->dao->select('objectID, user')->from(TABLE_STAKEHOLDER)->where('objectID')->in(array_keys($parents))->andWhere('deleted')->eq('0')->fetchAll();

        $parentStakeholderGroup = array();
        foreach($parentStakeholders as $parentStakeholder)
        {
            $subPrograms = zget($parents, $parentStakeholder->objectID, array());
            foreach($subPrograms as $subProgramID) $parentStakeholderGroup[$subProgramID][$parentStakeholder->user] = $parentStakeholder->user;
        }

        return $parentStakeholderGroup;
    }

    /**
     * Get stakeholder group by type.
     *
     * @access public
     * @return array
     */
    public function getListByType()
    {
        $stakeholders = $this->dao->select('t2.realname as name, t2.account, t1.type, t2.role')->from(TABLE_STAKEHOLDER)->alias('t1')
            ->leftJoin(TABLE_USER)->alias('t2')->on('t1.user=t2.account')
            ->where('t1.deleted')->eq('0')
            ->andWhere('t1.objectID')->eq($this->session->project)
            ->fetchGroup('type');

        return $stakeholders;
    }

    /**
     * Get stakeholder by id.
     *
     * @param  int    $userID
     * @access public
     * @return array
     */
    public function getByID($userID)
    {
        $stakeholder = $this->dao->select('t1.*, t2.phone, t2.realname as name, t2.email, t2.qq, t2.weixin, t2.nature, t2.analysis, t2.strategy, t3.name as companyName, t3.id as company')->from(TABLE_STAKEHOLDER)->alias('t1')
            ->leftJoin(TABLE_USER)->alias('t2')->on('t1.user=t2.account')
            ->leftJoin(TABLE_COMPANY)->alias('t3')->on('t2.company=t3.id')
            ->where('t1.id')->eq($userID)
            ->fetch();

        return $stakeholder;
    }

    /**
     * Get group activities.
     *
     * @access public
     * @return array
     */
    public function getProcessGroup()
    {
        $group = $this->dao->select('process, activity')->from(TABLE_PROGRAMACTIVITY)
            ->where('project')->eq($this->session->project)
            ->andWhere('result')->eq('yes')
            ->fetchGroup('process');

        return $group;
    }

    /**
     * Get process pairs.
     *
     * @access public
     * @return array
     */
    public function getProcess()
    {
        return $this->dao->select('id, name')->from(TABLE_PROCESS)
            ->where('deleted')->eq(0)
            ->fetchPairs();
    }

    /**
     * Get plans.
     *
     * @access public
     * @return array
     */
    public function getPlans()
    {
        return $this->dao->select('*')->from(TABLE_INTERVENTION)
            ->where('deleted')->eq(0)
            ->andWhere('project')->eq($this->session->project)
            ->fetchAll('activity');
    }

    /**
     * Get stakeholder issues.
     *
     * @access public
     * @return array
     */
    public function getIssues()
    {
        $stakeholders = $this->getStakeHolderPairs($this->session->project);
        return $this->dao->select('*')->from(TABLE_ISSUE)
            ->where('deleted')->eq(0)
            ->andWhere('project')->eq($this->session->project)
            ->andWhere('owner')->in(array_keys($stakeholders))
            ->orWhere('activity')->ne('')
            ->orderBy('id_desc')
            ->fetchAll('id');
    }

    /**
     * Get activity pairs.
     *
     * @access public
     * @return array
     */
    public function getActivities()
    {
        return $this->dao->select('id, name')->from(TABLE_ACTIVITY)
            ->where('deleted')->eq(0)
            ->fetchPairs();
    }

    /**
     * Add communication record.
     *
     * @param  int    $stakeholderID
     * @access public
     * @return void
     */
    public function communicate($stakeholderID)
    {
        $stakeholder = $this->getByID($stakeholderID);

        $data = fixer::input('post')
            ->stripTags($this->config->stakeholder->editor->communicate['id'], $this->config->allowedTags)
            ->get();
        $this->loadModel('action')->create('stakeholder', $stakeholderID, 'communicate', $data->comment);
    }

    /**
     * Add expect record.
     *
     * @param  int    $userID
     * @access public
     * @return void|int
     */
    public function expect($userID)
    {
        $data = fixer::input('post')
            ->add('userID', $userID)
            ->add('createdBy', $this->app->user->account)
            ->add('createdDate', date('Y-m-d'))
            ->add('project', $this->session->project)
            ->stripTags($this->config->stakeholder->editor->expect['id'], $this->config->allowedTags)
            ->get();

        if(strpos($this->config->stakeholder->expect->requiredFields, 'expect') !== false and !$this->post->expect)
        {
            dao::$errors[] = sprintf($this->lang->error->notempty, $this->lang->stakeholder->expect);
            return false;
        }

        if(strpos($this->config->stakeholder->expect->requiredFields, 'progress') !== false and !$this->post->progress)
        {
            dao::$errors[] = sprintf($this->lang->error->notempty, $this->lang->stakeholder->progress);
            return false;
        }

        $this->dao->insert(TABLE_EXPECT)->data($data)
            ->autoCheck()
            ->exec();

        if(!dao::isError()) return $this->dao->lastInsertID();
        return false;
    }

    /**
     * Get expect list.
     *
     * @param  string $browseType
     * @param  int    $queryID
     * @param  string $orderBy
     * @param  object $pager
     * @access public
     * @return object
     */
    public function getExpectList($browseType = 'all', $queryID = 0, $orderBy = 'id_desc', $pager = null)
    {
        $stakeholderQuery = '';
        if($browseType == 'bysearch')
        {
            $query = $queryID ? $this->loadModel('search')->getQuery($queryID) : '';
            if($query)
            {
                $this->session->set('stakeholderQuery', $query->sql);
                $this->session->set('stakeholderForm', $query->form);
            }
            if($this->session->stakeholderQuery == false) $this->session->set('stakeholderQuery', ' 1=1');
            $stakeholderQuery = $this->session->stakeholderQuery;
        }

        $expects = $this->dao->select('t1.*,t2.key,t3.realname')->from(TABLE_EXPECT)->alias('t1')
            ->leftJoin(TABLE_STAKEHOLDER)->alias('t2')->on('t1.userID=t2.id')
            ->leftJoin(TABLE_USER)->alias('t3')->on('t2.user=t3.account')
            ->where('t1.project')->eq($this->session->project)
            ->beginIF($browseType == 'bysearch')
            ->andWhere($stakeholderQuery)
            ->fi()
            ->andWhere('t1.deleted')->eq('0')
            ->orderBy($orderBy)
            ->page($pager)
            ->fetchAll();

        return $expects;
    }

    /**
     * Delete expect.
     *
     * @param  int    $expectID
     * @param  object $null
     * @access public
     * @return void
     */
    public function deleteExpect($expectID, $null = null)
    {
        $this->dao->update(TABLE_EXPECT)->set('deleted')->eq('1')->where('id')->eq($expectID)->exec();
    }

    /**
     * Edit expect.
     *
     * @param  int    $expectID
     * @access public
     * @return object
     */
    public function editExpect($expectID)
    {
        $data = fixer::input('post')
            ->stripTags($this->config->stakeholder->editor->editexpect['id'], $this->config->allowedTags)
            ->get();

        if(strpos($this->config->stakeholder->expect->requiredFields, 'userID') !== false and !$this->post->userID)
        {
            dao::$errors[] = sprintf($this->lang->error->notempty, $this->lang->stakeholder->common);
            return false;
        }

        if(strpos($this->config->stakeholder->expect->requiredFields, 'expect') !== false and !$this->post->expect)
        {
            dao::$errors[] = sprintf($this->lang->error->notempty, $this->lang->stakeholder->expect);
            return false;
        }

        if(strpos($this->config->stakeholder->expect->requiredFields, 'progress') !== false and !$this->post->progress)
        {
            dao::$errors[] = sprintf($this->lang->error->notempty, $this->lang->stakeholder->progress);
            return false;
        }

        $oldExpect = $this->getExpectByID($expectID);
        $this->dao->update(TABLE_EXPECT)->data($data)->where('id')->eq($expectID)->autoCheck()->exec();

        if(dao::isError()) return false;
        return common::createChanges($oldExpect, $data);
    }

    /**
     * Get stakeholder user.
     *
     * @access public
     * @return object
     */
    public function getStakeholderUsers()
    {
        $users = $this->dao->select("t1.id, CONCAT_WS('/', t3.name,t2.realname) as realname")->from(TABLE_STAKEHOLDER)->alias('t1')
            ->leftJoin(TABLE_USER)->alias('t2')->on('t1.user=t2.account')
            ->leftJoin(TABLE_COMPANY)->alias('t3')->on('t2.company=t3.id')
            ->where('t1.objectID')->eq($this->session->project)
            ->andWhere('t1.deleted')->eq('0')
            ->fetchPairs('id', 'realname');

        return $users;
    }

    /**
     * Get stakeholder pairs for issue.
     *
     * @access public
     * @return object
     */
    public function getStakeholders4Issue()
    {
        $users = $this->dao->select("t1.user, CONCAT_WS('/', t3.name,t2.realname) as realname")->from(TABLE_STAKEHOLDER)->alias('t1')
            ->leftJoin(TABLE_USER)->alias('t2')->on('t1.user=t2.account')
            ->leftJoin(TABLE_COMPANY)->alias('t3')->on('t2.company=t3.id')
            ->where('t1.objectID')->eq($this->session->project)
            ->andWhere('t1.deleted')->eq('0')
            ->fetchPairs('user', 'realname');

        return $users;
    }

    /**
     * Get expect details.
     *
     * @param  int    $expectID
     * @access public
     * @return object
     */
    public function getExpectByID($expectID = 0)
    {
        return $this->dao->select('*')->from(TABLE_EXPECT)->where('id')->eq($expectID)->andWhere('deleted')->eq('0')->fetch();
    }

    /**
     * Build search form.
     *
     * @param  int    $queryID
     * @param  string $actionURL
     * @access public
     * @return void
     */
    public function buildSearchForm($actionURL, $queryID)
    {
        $this->config->stakeholder->search['actionURL'] = $actionURL;
        $this->config->stakeholder->search['queryID']   = $queryID;

        $this->loadModel('search')->setSearchParams($this->config->stakeholder->search);
    }

    /**
     * Get expect details.
     *
     * @param  int    $userID
     * @access public
     * @return object
     */
    public function getExpectByUser($userID = 0)
    {
        return $this->dao->select('*')->from(TABLE_EXPECT)
            ->where('userID')->eq($userID)
            ->andWhere('deleted')->eq('0')
            ->orderBy('id_desc')
            ->fetchAll();
    }

    /**
     * Get stakeholder issue.
     *
     * @param  int    $account
     * @access public
     * @return object
     */
    public function getStakeholderIssue($account)
    {
        $issueList = $this->dao->select('*')->from(TABLE_ISSUE)
            ->where('project')->eq($this->session->project)
            ->andWhere('owner')->eq($account)
            ->andWhere('deleted')->eq('0')
            ->orderBy('id_desc')
            ->fetchAll();
        return $issueList;
    }
}