<?php
declare(strict_types=1);
/**
 * The control file of message of ZenTaoPMS.
 *
 * @copyright   Copyright 2009-2023 禅道软件（青岛）有限公司(ZenTao Software (Qingdao) Co., Ltd. www.cnezsoft.com)
 * @license     ZPL(http://zpl.pub/page/zplv12.html) or AGPL(https://www.gnu.org/licenses/agpl-3.0.en.html)
 * @author      Yidong Wang <yidong@cnezsoft.com>
 * @package     message
 * @version     $Id$
 * @link        https://www.zentao.net
 */
class message extends control
{
    /**
     * 主页。
     * Index.
     *
     * @access public
     * @return void
     */
    public function index()
    {
        foreach($this->lang->message->typeList as $type => $typeName)
        {
            if(isset($this->config->message->typeLink[$type]))
            {
                list($moduleName, $methodName) = explode('|', $this->config->message->typeLink[$type]);
                if(common::hasPriv($moduleName, $methodName)) $this->locate($this->createLink($moduleName, $methodName));
            }
        }

        if(common::hasPriv('message', 'setting')) $this->locate($this->createLink('message', 'setting'));
    }

    /**
     * 浏览器设置。
     * Browser setting.
     *
     * @access public
     * @return void
     */
    public function browser()
    {
        if($_POST)
        {
            $data = fixer::input('post')->get();

            $browserConfig = new stdclass();
            $browserConfig->turnon   = $data->turnon;
            $browserConfig->pollTime = (int)$data->pollTime;

            if($browserConfig->turnon)
            {
                if(empty($browserConfig->pollTime)) $this->send(array('result' => 'fail', 'message' => array('pollTime' => sprintf($this->lang->error->notempty, $this->lang->message->browserSetting->pollTime))));
                if($browserConfig->pollTime < $this->config->message->browser->minPollTime) $this->send(array('result' => 'fail', 'message' => array('pollTime' => $this->lang->message->browserSetting->pollTimeTip)));
            }

            $this->loadModel('setting')->setItems('system.message.browser', $browserConfig);
            if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
            return $this->send(array('result' => 'success', 'message' => $this->lang->saveSuccess, 'load' => array('url' => $this->createLink('message', 'browser'), 'selector' => array('#header', '#mainContainer'))));
        }

        $this->view->title         = $this->lang->message->browser;
        $this->view->browserConfig = $this->config->message->browser;
        $this->display();
    }

    /**
     * 消息设置。
     * Message setting.
     *
     * @access public
     * @return void
     */
    public function setting()
    {
        if(strtolower($this->server->request_method) == "post")
        {
            $data = fixer::input('post')->get();
            $data->messageSetting = !empty($data->messageSetting) ? json_encode($data->messageSetting) : '';
            $data->blockUser      = !empty($data->blockUser) && is_array($data->blockUser) ? implode(',', $data->blockUser) : zget($data, 'blockUser', '');
            $this->loadModel('setting')->setItem('system.message.setting@' . $this->config->vision, $data->messageSetting);
            $this->setting->setItem('system.message.blockUser@' . $this->config->vision, $data->blockUser);
            return $this->send(array('result' => 'success', 'message' => $this->lang->saveSuccess, 'load' => true));
        }

        $users = $this->loadModel('user')->getPairs('noletter,noclosed');
        unset($users['']);

        $this->view->title         = $this->lang->message->setting;
        $this->view->users         = $users;
        $this->view->objectTypes   = $this->message->getObjectTypes();
        $this->view->objectActions = $this->message->getObjectActions();
        $this->display();
    }

    /**
     * Ajax: 获取消息。
     * Ajax get message.
     *
     * @param  string $windowBlur
     * @access public
     * @return void
     */
    public function ajaxGetMessage(string $windowBlur = 'false')
    {
        if($this->config->message->browser->turnon == 0) return;

        $this->message->deleteExpired();

        $todos        = $this->message->batchSaveTodoNotice();
        $waitMessages = array_merge($todos, $this->message->getMessages('wait'));
        $unreadCount  = $this->message->getUnreadCount();
        if(!$this->config->message->browser->show) return print(json_encode(array('newCount' => $unreadCount, 'showCount' => $this->config->message->browser->count)));
        if(empty($waitMessages)) return;

        $windowBlur = !empty($windowBlur) && $windowBlur != 'false';

        $messages = array();
        $newline  = $windowBlur ? "\n" : '<br />';
        foreach($waitMessages as $message) $messages[$message->id] = $message->data;
        $this->dao->update(TABLE_NOTIFY)->set('status')->eq('sended')->set('sendTime')->eq(helper::now())->where('id')->in(array_keys($messages))->exec();

        foreach($messages as $id => $message)
        {
            preg_match_all("/<a href='([^\']+)'/", $message, $out);
            $link = count($out[1]) ? $out[1][0] : '';
            $message = $windowBlur ? strip_tags($message) : str_replace("<a href='$link'", "<a data-url='{$link}' href='###' onclick='clickMessage(this)'", $message);
            $message = preg_replace("/data-app='([^\']+)'/", '', $message);

            $browserMessages[] = $windowBlur ? array('text' => $message, 'url' => $link) : "<div class='browser-message-content'><span class='text-secondary-500' data-id={$id}>{$message}</span></div>";
        }
        echo json_encode(array('newCount' => $unreadCount, 'messages' => $browserMessages, 'showCount' => $this->config->message->browser->count));
    }

    /**
     * Ajax: 获取消息下拉菜单。
     * Ajax get dropmenu.
     *
     * @param  string $active  unread|all
     * @access public
     * @return void
     */
    public function ajaxGetDropmenu(string $active = 'unread')
    {
        $this->messageZen->assignDropmenuVars($active);
        $this->display();
    }

    /**
     * Ajax: 获取旧页面消息下拉菜单。
     * Ajax get dropmenu for old.
     *
     * @param  string $active  unread|all
     * @access public
     * @return void
     */
    public function ajaxGetDropmenuForOld(string $active = 'unread')
    {
        $this->messageZen->assignDropmenuVars($active);
        $this->display();
    }

    /**
     * Ajax: 标记消息已读。
     * Ajax mark read.
     *
     * @param  string $messageID  all|int
     * @access public
     * @return void
     */
    public function ajaxMarkRead(string $messageID)
    {
        if($messageID != 'all') $messageID = (int)$messageID;
        $this->dao->update(TABLE_NOTIFY)->set('status')->eq('read')->where('objectType')->eq('message')
            ->andWhere('toList')->eq(",{$this->app->user->account},")
            ->beginIF(is_int($messageID))->andWhere('id')->eq($messageID)->fi()
            ->exec();
    }

    /**
     * Ajax: 标记消息未读。
     * Ajax: Mark message to unread
     *
     * @param  int    $messageID
     * @access public
     * @return void
     */
    public function ajaxMarkUnread(int $messageID)
    {
        $messageID = (int)$messageID;
        $this->dao->update(TABLE_NOTIFY)->set('status')->eq('sended')->where('objectType')->eq('message')
            ->andWhere('toList')->eq(",{$this->app->user->account},")
            ->beginIF(is_int($messageID))->andWhere('id')->eq($messageID)->fi()
            ->exec();
    }

    /**
     * Ajax: 删除消息。
     * Ajax delete message.
     *
     * @param  string $messageID  all|allread|int
     * @access public
     * @return void
     */
    public function ajaxDelete(string $messageID)
    {
        if($messageID != 'all' && $messageID != 'allread') $messageID = (int)$messageID;
        $this->dao->delete()->from(TABLE_NOTIFY)->where('objectType')->eq('message')
            ->andWhere('toList')->eq(",{$this->app->user->account},")
            ->beginIF($messageID == 'allread')->andWhere('status')->eq('read')->fi()
            ->beginIF(is_int($messageID))->andWhere('id')->eq($messageID)->fi()
            ->exec();
    }

    /**
     * Ajax: 设置自己的消息配置。
     * Ajax: Set for oneself
     *
     * @access public
     * @return void
     */
    public function ajaxSetOneself()
    {
        if(empty($_POST)) return;

        $data = fixer::input('post')->setDefault('show', 0)->setDefault('count', 0)->get();
        if(!is_numeric($data->maxDays)) dao::$errors['maxDays'] = $this->lang->message->error->maxDaysFormat;
        if(strpos($data->maxDays, '.') !== false) dao::$errors['maxDays'] = $this->lang->message->error->maxDaysFormat;

        $data->maxDays = (int)$data->maxDays;
        if($data->maxDays < 0) dao::$errors['maxDays'] = $this->lang->message->error->maxDaysValue;
        if(dao::isError()) return $this->send(array('result' => 'fail', 'message' => dao::getError()));

        $account = $this->app->user->account;
        $this->loadModel('setting')->setItems("{$account}.message.browser", $data);

        $this->config->message->browser->maxDays = $data->maxDays;
        $this->message->deleteExpired();

        $this->send(array('result' => 'success', 'message' => $this->lang->saveSuccess, 'callback' => "reloadSettingModal({$data->count})"));
    }
}