<?php
/**
 * The control file of customer module of ZDOO.
 *
 * @copyright   Copyright 2009-2018 青岛易软天创网络科技有限公司(QingDao Nature Easy Soft Network Technology Co,LTD, www.cnezsoft.com)
 * @license     ZPL (http://zpl.pub/page/zplv12.html)
 * @author      Xiying Guan <guanxiying@xirangit.com>
 * @package     customer
 * @version     $Id$
 * @link        http://www.zdoo.com
 */
class customer extends control
{
    /**
     * The index page, locate to the browse page.
     *
     * @access public
     * @return void
     */
    public function index()
    {
        $this->locate(inlink('browse'));
    }

    /**
     * Browse customer.
     *
     * @param string $mode
     * @param string $param
     * @param string $orderBy
     * @param int    $recTotal
     * @param int    $recPerPage
     * @param int    $pageID
     * @access public
     * @return void
     */
    public function browse($mode = 'all', $param = '', $orderBy = 'id_desc', $recTotal = 0, $recPerPage = 20, $pageID = 1)
    {   
        $this->app->loadClass('pager', $static = true);
        $pager = new pager($recTotal, $recPerPage, $pageID);

        /* Auto move customer to public. */
        $this->customer->move2CustomerPool();

        $this->session->set('customerList', $this->app->getURI(true));
        $this->session->set('contactList',  '');

        /* Build search form. */
        $this->loadModel('search');
        $this->config->customer->search['actionURL'] = $this->createLink('customer', 'browse', 'mode=bysearch');
        $this->config->customer->search['params']['t1.industry']['values'] = array('' => '') + $this->loadModel('tree')->getOptionMenu('industry');
        $this->config->customer->search['params']['t1.area']['values']     = array('' => '') + $this->loadModel('tree')->getOptionMenu('area');
        $this->search->setSearchParams($this->config->customer->search);

        $customers = $this->customer->getList($mode, $param, $relation = 'client', $orderBy, $pager);

        /* Set allowed edit customer ID list. */
        $this->app->user->canEditCustomerIdList = ',' . implode(',', $this->customer->getCustomersSawByMe('edit', array_keys($customers))) . ',';
        
        $this->view->title      = $this->lang->customer->list;
        $this->view->users      = $this->loadModel('user')->getPairs();
        $this->view->validUsers = $this->loadModel('user')->getPairs('nodeleted');
        $this->view->moduleMenu = $this->customer->createModuleMenu($mode, $param, $orderBy, $recTotal, $recPerPage, $pageID);
        $this->view->mode       = $mode;
        $this->view->customers  = $customers;
        $this->view->pager      = $pager;
        $this->view->orderBy    = $orderBy;

        $this->display();
    }   

    /**
     * Get option menu.
     * 
     * @param  int    $current 
     * @access public
     * @return void
     */
    public function getOptionMenu($current = 0)
    {
        $options = $this->customer->getPairs('client');
        foreach($options as $value => $text)
        {
            $selected = $value == $current ? 'selected' : '';
            echo "<option value='{$value}' {$selected}>{$text}</option>";
        }
        exit;
    }

    /**
     * Create a customer.
     * 
     * @access public
     * @return void
     */
    public function create()
    {
        if($_POST)
        {
            $result = $this->customer->create();
            return $this->send($result);
        }

        unset($this->lang->customer->menu);
        $this->view->title        = $this->lang->customer->create;
        $this->view->position[]   = $this->lang->customer->create;
        $this->view->sizeList     = $this->customer->combineSizeList();
        $this->view->industryList = $this->loadModel('tree')->getOptionMenu('industry');
        $this->view->areaList     = $this->tree->getOptionMenu('area');
        $this->view->levelList    = $this->customer->combineLevelList();
        $this->view->contacts     = $this->loadModel('contact', 'crm')->getPairs(0, 'normal', $emptyOption = true, 'id_desc', $limit = $this->config->contactLimit);
        $this->display();
    }

    /**
     * Edit a customer.
     * 
     * @param  int    $customerID 
     * @param  bool   $comment
     * @access public
     * @return void
     */
    public function edit($customerID, $comment = false)
    {
        $customer = $this->customer->getByID($customerID);
        $this->loadModel('common')->checkPrivByCustomer(empty($customer) ? '0' : $customerID, 'edit');

        if($_POST)
        {
            $changes = array();
            if($comment == false)
            {
                $changes = $this->customer->update($customerID);
                if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
            }

            if($this->post->comment != '' or !empty($changes))
            {
                $action   = $this->post->comment == '' ? 'Edited' : 'Commented';
                $actionID = $this->loadModel('action')->create('customer', $customerID, $action, $this->post->comment);
                $this->action->logHistory($actionID, $changes);
            }

            $this->send(array('result' => 'success', 'message' => $this->lang->saveSuccess, 'locate' => inlink('view', "customerID=$customerID")));
        }

        $this->view->title        = $this->lang->customer->edit;
        $this->view->position[]   = $this->lang->customer->edit;
        $this->view->customer     = $customer;
        $this->view->areaList     = $this->loadModel('tree')->getOptionMenu('area');
        $this->view->industryList = $this->tree->getOptionMenu('industry');
        $this->view->sizeList     = $this->customer->combineSizeList();
        $this->view->levelList    = $this->customer->combineLevelList();
        $this->view->moduleMenu   = false;

        $this->display();
    }

    /**
     * View a customer.
     * 
     * @param  int    $customerID 
     * @access public
     * @return void
     */
    public function view($customerID)
    {
        $this->app->loadLang('trade', 'cash');
        $customer = $this->customer->getByID($customerID);
        $this->loadModel('common')->checkPrivByCustomer(empty($customer) ? '0' : $customerID);

        /* Set allowed edit customer ID list. */
        $this->app->user->canEditCustomerIdList = ',' . implode(',', $this->customer->getCustomersSawByMe('edit', (array)$customerID)) . ',';

        $uri = $this->app->getURI(true);
        $this->session->set('orderList',    $uri);
        $this->session->set('contractList', $uri);
        $this->session->set('contactList',  $uri);
        if(!$this->session->contactList or $this->session->customerList == $this->session->contactList) $this->session->set('contactList', $this->app->getURI(true));

        $this->app->loadLang('resume', 'crm');
        $this->app->loadLang('product');

        $actionList   = $this->loadModel('action')->getList('customer', $customerID);
        $actionIDList = array_keys($actionList);
        $actionFiles  = $this->loadModel('file')->getByObject('action', $actionIDList);
        $fileList = array();
        foreach($actionFiles as $files)
        {
            foreach($files as $file) $fileList[$file->id] = $file;
        }

        /* Compute purchased products from signed orders. */
        $orders         = $this->loadModel('order', 'crm')->getList($mode = 'query', "customer=$customerID");
        $contracts      = $this->loadModel('contract', 'crm')->getList($customerID);
        $contractOrders = $this->dao->select('*')->from(TABLE_CONTRACTORDER)->fetchGroup('contract');
        $productIDList  = '';
        foreach($contracts as $contract)
        {
            if($contract->status == 'canceled') continue;
            if(!isset($contractOrders[$contract->id])) continue;

            foreach($contractOrders[$contract->id] as $contractOrder)
            {
                if(empty($orders[$contractOrder->order])) continue;

                $productIDList .= ',' . trim($orders[$contractOrder->order]->product, ',');
                $productIDList = trim($productIDList, ',');
            }
        }
        $productIDList = array_unique(explode(',', $productIDList));
        $productList   = $this->dao->select('*')->from(TABLE_PRODUCT)->where('id')->in($productIDList)->fetchAll();

        $this->view->title             = $this->lang->customer->view;
        $this->view->position[]        = $this->lang->customer->view;
        $this->view->customer          = $customer;
        $this->view->orders            = $orders;
        $this->view->contacts          = $this->loadModel('contact', 'crm')->getList($customerID);
        $this->view->contracts         = $contracts;
        $this->view->addresses         = $this->loadModel('address', 'crm')->getList('customer', $customerID);
        $this->view->actions           = $this->loadModel('action')->getList('customer', $customerID);
        $this->view->products          = $this->loadModel('product')->getPairs();
        $this->view->productList       = $productList;
        $this->view->productCategories = $this->loadModel('tree')->getPairs('product');
        $this->view->users             = $this->loadModel('user')->getPairs();
        $this->view->areaList          = $this->tree->getPairs('area');
        $this->view->industryList      = $this->tree->getPairs('industry');
        $this->view->returnList        = $this->contract->getReturnList(array_keys($contracts), 'returnedDate_desc');
        $this->view->currencySign      = $this->loadModel('common')->getCurrencySign();
        $this->view->preAndNext        = $this->common->getPreAndNextObject('customer', $customerID);
        $this->view->files             = $fileList;
        $this->view->moduleMenu        = false;
        $this->display();
    }

    /**
     * Assign an customer function.
     *
     * @param  int    $customerID
     * @param  null   $table  
     * @access public
     * @return void
     */
    public function assign($customerID, $table = null)
    {
        $this->loadModel('common')->checkPrivByCustomer($customerID, 'edit');

        if($_POST)
        {
            $this->customer->assign($customerID);
            if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));

            if($this->post->assignedTo) 
            {
                $actionID = $this->loadModel('action')->create('customer', $customerID, 'Assigned', $this->post->note, $this->post->assignedTo);
                $this->sendmail($customerID, $actionID);
            }

            $this->send(array('result' => 'success', 'message' => $this->lang->saveSuccess, 'locate' => $this->server->http_referer));
        }

        $this->view->title      = $this->lang->customer->assignedTo;
        $this->view->customerID = $customerID;
        $this->view->customer   = $this->customer->getByID($customerID);
        $this->view->members    = $this->loadModel('user')->getPairs('noclosed,nodeleted,noforbidden');
        $this->display();
    }

    /**
     * Batch assign customers to a user. 
     * 
     * @access public
     * @return void
     */
    public function batchAssign()
    {
        if($this->post->assignedTo && $this->post->customerIDList)
        {
            $this->dao->update(TABLE_CUSTOMER)->set('assignedTo')->eq($this->post->assignedTo)->where('id')->in($this->post->customerIDList)->exec();
            if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));

            $this->loadModel('action');
            foreach($this->post->customerIDList as $customerID)
            {
                $actionID = $this->action->create('customer', $customerID, 'Assigned', '', $this->post->assignedTo);
                $this->sendmail($customerID, $actionID);
            }
            $this->send(array('result' => 'success', 'locate' => inlink('browse')));
        }
        $this->send(array('result' => 'success'));
    }

    /**
     * Browse orders of the customer.
     * 
     * @param  int    $customerID 
     * @access public
     * @return void
     */
    public function order($customerID)
    {
        $this->view->title      = $this->lang->customer->order;
        $this->view->orders     = $this->loadModel('order', 'crm')->getList($mode = 'query', "customer=$customerID");
        $this->view->products   = $this->loadModel('product')->getPairs();
        $this->view->users      = $this->loadModel('user')->getPairs();
        $this->view->modalWidth = 1000;
        $this->display();
    }

    /**
     * Browse contacts of the customer.
     * 
     * @param  int    $customerID 
     * @param  string $relation
     * @access public
     * @return void
     */
    public function contact($customerID, $relation = 'client')
    {
        $this->app->loadLang('resume', 'crm');
        $this->app->user->canEditContactIdList = ',' . implode(',', $this->loadModel('contact', 'crm')->getContactsSawByMe('edit')) . ',';

        if(empty($this->app->user->canEditCustomerIdList))
        {
            $this->app->user->canEditCustomerIdList = ',' . implode(',', $this->customer->getCustomersSawByMe('edit', (array)$customerID)) . ',';
        }

        $this->view->title      = $this->lang->customer->contact;
        $this->view->modalWidth = 'lg';
        $this->view->contacts   = $this->loadModel('contact', 'crm')->getList($customerID, $relation);
        $this->view->customerID = $customerID;
        $this->view->relation   = $relation;
        $this->display();
    }

    /**
     * Link contact.
     * 
     * @param  int    $customerID 
     * @access public
     * @return void
     */
    public function linkContact($customerID)
    {
        if($_POST)
        {
            $return = $this->customer->linkContact($customerID);
            $this->send($return);
        }

        $customerContacts = $this->loadModel('contact', 'crm')->getList($customerID);
        $contacts = $this->contact->getPairs();
        foreach($contacts as $id => $name)
        {
            if(isset($customerContacts[$id])) unset($contacts[$id]);
        }

        $this->view->title      = $this->lang->customer->linkContact;
        $this->view->contacts   = $contacts;
        $this->view->customerID = $customerID;
        $this->display();
    }

    /**
     * Browse contracts of the customer.
     * 
     * @param  int    $customerID 
     * @access public
     * @return void
     */
    public function contract($customerID)
    {
        $this->view->title      = $this->lang->customer->contract;
        $this->view->contracts  = $this->loadModel('contract', 'crm')->getList($customerID);
        $this->view->modalWidth = 1000;
        $this->display();
    }

    /**
     * Delete a customer.
     *
     * @param  int    $customerID
     * @access public
     * @return void
     */
    public function delete($customerID)
    {
        $customer = $this->customer->getByID($customerID);
        if(!$customer) $this->loadModel('common')->checkPrivByCustomer('0');

        $this->customer->delete(TABLE_CUSTOMER, $customerID);
        if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
        $this->send(array('result' => 'success', 'locate' => inlink('browse')));
    }

    /**
     * Export customers.
     *
     * @param  string $mode     all | thisPage
     * @access public
     * @return void
     */
    public function export($mode = 'all')
    { 
        if($_POST)
        {
            $customerLang   = $this->lang->customer;
            $customerConfig = $this->config->customer;

            /* Create field lists. */
            $fields = explode(',', $customerConfig->list->exportFields);
            foreach($fields as $key => $fieldName)
            {
                $fieldName = trim($fieldName);
                $fields[$fieldName] = isset($customerLang->$fieldName) ? $customerLang->$fieldName : $fieldName;
                unset($fields[$key]);
            }

            $customers      = array();
            $queryCondition = $this->session->customerQueryCondition;
            if($queryCondition)
            {
                if($mode == 'all' && strpos($queryCondition, 'LIMIT') !== false) $queryCondition = substr($queryCondition, 0, strpos($queryCondition, 'LIMIT'));

                $stmt = $this->dbh->query($queryCondition);
                while($row = $stmt->fetch()) $customers[$row->id] = $row;
            }

            $users        = $this->loadModel('user')->getPairs();
            $areaList     = $this->loadModel('tree')->getOptionMenu('area');
            $industryList = $this->tree->getOptionMenu('industry');

            foreach($customers as $customer)
            {
                $customer->desc = htmlspecialchars_decode($customer->desc);
                $customer->desc = str_replace("<br />", "\n", $customer->desc);
                $customer->desc = str_replace('"', '""', $customer->desc);

                $customer->public = $customer->public ? $this->lang->yes : $this->lang->no;

                /* fill some field with useful value. */
                if(isset($customerLang->statusList[$customer->status]))     $customer->status   = $customerLang->statusList[$customer->status];
                if(isset($customerLang->typeList[$customer->type]))         $customer->type     = $customerLang->typeList[$customer->type];
                if(isset($customerLang->sizeNameList[$customer->size]))     $customer->size     = $customerLang->sizeNameList[$customer->size];
                if(isset($customerLang->levelNameList[$customer->level]))   $customer->level    = $customerLang->levelNameList[$customer->level];
                if(isset($customerLang->relationList[$customer->relation])) $customer->relation = $customerLang->relationList[$customer->relation];
                if(isset($areaList[$customer->area]))                       $customer->area     = $areaList[$customer->area];
                if(isset($industryList[$customer->industry]))               $customer->industry = $industryList[$customer->industry];

                if(isset($users[$customer->createdBy]))   $customer->createdBy   = $users[$customer->createdBy];
                if(isset($users[$customer->editedBy]))    $customer->editedBy    = $users[$customer->editedBy];
                if(isset($users[$customer->assignedTo]))  $customer->assignedTo  = $users[$customer->assignedTo];
                if(isset($users[$customer->assignedBy]))  $customer->assignedBy  = $users[$customer->assignedBy];
                if(isset($users[$customer->contactedBy])) $customer->contactedBy = $users[$customer->contactedBy];

                $customer->createdDate   = formatTime($customer->createdDate, DT_DATE1);
                $customer->editedDate    = formatTime($customer->editedDate, DT_DATE1);
                $customer->assignedDate  = formatTime($customer->assignedDate, DT_DATE1);
                $customer->contactedDate = formatTime($customer->contactedDate, DT_DATE1);
                $customer->nextDate      = formatTime($customer->nextDate, DT_DATE1);
            }

            if($this->session->customerQuery == false) $this->session->set('customerQuery', ' 1 = 1');
            $customerQuery = $this->loadModel('search')->replaceDynamic($this->session->customerQuery);

            if(strpos(',contactedby,past,today,tomorrow,thisweek,thismonth,', ",{$mode},") !== false or ($mode == 'bysearch' && strpos($customerQuery, '`nextDate`') !== false))
            {
                $this->app->loadClass('date', $static = true);
                $thisMonth = date::getThisMonth();
                $thisWeek  = date::getThisWeek();

                $datingList = $this->dao->select('objectID, MIN(date) AS date')->from(TABLE_DATING)
                    ->where('status')->eq('wait')
                    ->andWhere('objectType')->eq('customer')
                    ->andWhere('objectID')->in(array_keys($customers))
                    ->beginIF($mode == 'contactedby')->andWhere('account')->eq($this->app->user->account)->fi()
                    ->beginIF($mode == 'past')->andWhere('date')->lt(helper::today())->fi()
                    ->beginIF($mode == 'today')->andWhere('date')->eq(helper::today())->fi()
                    ->beginIF($mode == 'tomorrow')->andWhere('date')->eq(formattime(date::tomorrow(), DT_DATE1))->fi()
                    ->beginIF($mode == 'thisweek')->andWhere('date')->between($thisWeek['begin'], $thisWeek['end'])->fi()
                    ->beginIF($mode == 'thismonth')->andWhere('date')->between($thisMonth['begin'], $thisMonth['end'])->fi()
                    ->andWhere('date')->ne('0000-00-00')
                    ->groupBy('objectID')
                    ->fetchPairs();

                foreach($customers as $id => $customer) $customer->nextDate = zget($datingList, $id, $customer->nextDate);
            }

            $this->post->set('fields', $fields);
            $this->post->set('rows', $customers);
            $this->post->set('kind', 'customer');
            $this->fetch('file', 'export2CSV' , $_POST);
        }

        $this->view->fileName = $this->lang->customer->list;
        $this->display();
    }

    /**
     * Send email.
     * 
     * @param  int    $customerID 
     * @param  int    $actionID 
     * @access public
     * @return void
     */
    public function sendmail($customerID, $actionID)
    {
        /* Reset $this->output. */
        $this->clear();

        /* Set toList and ccList. */
        $customer = $this->customer->getById($customerID);
        $users    = $this->loadModel('user')->getPairs();
        $toList   = $customer->assignedTo;

        /* send notice if user is online and return failed accounts. */
        $toList = $this->loadModel('action')->sendNotice($actionID, $toList);

        /* Get action info. */
        $action          = $this->loadModel('action')->getById($actionID);
        $history         = $this->action->getHistory($actionID);
        $action->history = isset($history[$actionID]) ? $history[$actionID] : array();

        /* Create the email content. */
        $this->view->customer = $customer;
        $this->view->action   = $action;
        $this->view->users    = $users;

        $mailContent = $this->parse($this->moduleName, 'sendmail');

        /* Send emails. */
        $this->loadModel('mail')->send($toList, 'CUSTOMER#' . $customer->id . ' ' . $customer->name, $mailContent);
        if($this->mail->isError()) trigger_error(join("\n", $this->mail->getError()));
    }

    /**
     * Merge two customers.
     * 
     * @param  int    $customerID 
     * @access public
     * @return void
     */
    public function merge($customerID)
    {
        if($_POST)
        {
            $customer = $this->customer->getByID($customerID);

            $this->customer->merge($customerID);
            if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
            $actionID = $this->loadModel('action')->create('customer', $this->post->customer, 'Merged', '', $customer->name);
            $this->send(array('result' => 'success', 'message' => $this->lang->saveSuccess, 'locate' => inlink('browse')));
        }

        $customers = $this->customer->getPairs('client');
        unset($customers[$customerID]);

        $this->view->title      = $this->lang->customer->merge;
        $this->view->customerID = $customerID;
        $this->view->customers  = $customers;
        $this->display();
    }

    /**
     * ajax get customers for todo.
     * 
     * @param  string $account    not used.
     * @param  string $id 
     * @param  string $type       select|json|board 
     * @access public
     * @return void
     */
    public function ajaxGetTodoList($account = '', $id = '', $type = 'select')
    {
        if($account == '') $account = $this->app->user->account;

        $customers          = array();
        $customerIdList     = $this->loadModel('customer')->getCustomersSawByMe();
        $datingCustomerList = $this->dao->select('objectID')->from(TABLE_DATING)->where('account')->eq($account)->andWhere('objectType')->eq('customer')->andWhere('status')->eq('wait')->orderBy('date_asc')->fetchPairs();
        $customerIdList     = array_intersect($customerIdList, $datingCustomerList);

        $sql = $this->dao->select('c.id, c.name, d.id as dating, d.date as nextDate')->from(TABLE_CUSTOMER)->alias('c')
            ->leftJoin(TABLE_DATING)->alias('d')->on("d.objectType='customer' and c.id = d.objectID")
            ->where('c.deleted')->eq(0)
            ->andWhere('c.relation')->ne('provider')
            ->andWhere('c.id')->in($customerIdList)
            ->andWhere('d.status')->eq('wait')
            ->orderBy('nextDate_asc');

        $stmt = $sql->query();
        while($customer = $stmt->fetch())
        {    
            if(empty($customer)) continue;
            if(isset($customers[$customer->id])) continue;
            $customers[$customer->id] = $customer->name . '(' . $customer->nextDate . ')';
        } 

        if($type == 'select')
        {
            $customers = array('') +  $customers;
            if($id) die(html::select("idvalues[$id]", $customers, '', 'class="form-control"'));
            die(html::select('idvalue', $customers, '', 'class=form-control'));
        }
        if($type == 'board')
        {
            die($this->loadModel('todo')->buildBoardList($customers, 'customer'));
        }
        die(json_encode($customers));
    }

    /**
     * Get area by ajax. 
     * 
     * @param  string $location 
     * @access public
     * @return void
     */
    public function ajaxGetArea($location)
    {
        $areaID    = 0;
        $areaPairs = $this->loadModel('tree')->getPairs($type = 'area');
        foreach($areaPairs as $id => $area)
        {
            if(strpos($location, $area) !== false) $areaID = $id;
        }
        echo $areaID;
    }

    /**
     * Search customer by ajax.
     *
     * @param  string $key
     * @param  string $relation
     * @param  string $customers
     * @access public
     * @return void
     */
    public function ajaxSearchCustomer($key = '', $relation = '', $customers = '')
    {
        $this->view->title     = $this->lang->customer->search;
        $this->view->key       = $key;
        $this->view->relation  = $relation;
        $this->view->customers = $customers;
        $this->display();
    }

    /**
     * Ajax get customer pairs 
     * 
     * @param  string $key
     * @param  string $relation 
     * @param  int    $limit
     * @access public
     * @return void
     */
    public function ajaxGetPairs($key = '', $relation = '', $limit = 0)
    {
        $i      = 0;
        $result = array();
        if(!$limit) $limit = $this->config->searchLimit;
        $customers = $this->customer->getPairs($relation);
        foreach ($customers as $id => $customer)
        {
            if($limit > 0 && $i > $limit) break;
            if(stripos($customer,  $key) !== false)
            {
                $result[$id] = $customer;
                $i++;
            }
        }
        if($i < 1)
        {
            $result['info'] = $this->lang->noResultsMatch;
        }

        die(json_encode($result));
    }
}
