<?php namespace Phpcmf\Library;
/**
 * https://www.besyun.com
 * BESCMS
 * 本文件是框架系统文件，二次开发时不可以修改本文件，可以通过继承类方法来重写此文件
 **/

/**
 * 用户通知处理
 */

class Notice {


    /**
     * 通知类型
     */
    public function get_type() {

        $notice_type = [
            'mobile' => [
                'file' => 'mobile',
                'name' => dr_lang('短信'),
                'help' => 'javascript:dr_help(479);',
                'height' => '100',
            ],
            'email' => [
                'file' => 'email',
                'name' => dr_lang('邮件'),
                'help' => 'javascript:dr_help(480);',
                'height' => '200',
            ]
        ];
        $local = \Phpcmf\Service::Apps();
        foreach ($local as $dir => $path) {
            if (is_file($path.'install.lock') && is_file($path.'/Config/App.php') ) {
                if (is_file($path.'/Config/Notice_type.php')) {
                    $cfg = require $path.'/Config/Notice_type.php';
                    $cfg && $notice_type[strtolower($dir)] = [
                        'name' => $cfg['name'],
                        'file' => $cfg['file'],
                        'help' => $cfg['help'],
                        'class' => $cfg['class'],
                        'height' => $cfg['height'],
                    ];
                }
            }
        }

        return $notice_type;
    }

    // 获取一些默认参数
    protected function _get_data($data, $param = []) {

        // 当前的信息变量
        $data['sys_app'] = defined('MOD_DIR') ? MOD_DIR : APP_DIR;
        $data['sys_uri'] = \Phpcmf\Service::L('router')->uri();
        $data['sys_time'] = SYS_TIME;
        $data['sys_ip'] = \Phpcmf\Service::L('input')->ip_address();
        $data['sys_ip_address'] = $data['ip_address'] = \Phpcmf\Service::L('input')->ip_address_info();
        // 自定义参数累加进去
        if ($param) {
            $data = array_merge($data, $param);
        }

        return $data;
    }

    /**
     * 发送通知动作
     *
     * $type    通知类型
     * $name    动作名称
     * $data    传入参数
     * $value   传入参数
     */
    public function send($type, $name, $data, $config, $is_send = 0) {

        $data = $this->_get_data($data);

        // 加入队列并执行
        $rt = \Phpcmf\Service::M('cron')->add_cron(SITE_ID, $type, [
            'name' => $name,
            'data' => $data,
            'config' => $config,
        ]);
        if (!$rt['code']) {
            log_message('error', '通知任务注册失败：'.$rt['msg']);
        }

        // 立即发送
        if ($is_send) {
            \Phpcmf\Service::M('cron')->do_cron_id($rt['code']);
        }

        return;
    }

    /**
     * 发送通知动作（按用户设置）
     *
     * $name    动作名称
     * $data    传入参数
     */
    public function send_notice($name, $data, $param = []) {

        if (!\Phpcmf\Service::C()->member_cache['notice'][$name]) {
            return; // 没有配置通知
        }

        $data = $this->_get_data($data, $param);

        // 加入队列并执行
        $rt = \Phpcmf\Service::M('cron')->add_cron(SITE_ID, 'notice', [
            'name' => $name,
            'data' => $data,
            'config' => \Phpcmf\Service::C()->member_cache['notice'][$name],
        ]);
        if (!$rt['code']) {
            log_message('error', '通知任务注册失败：'.$rt['msg']);
        }

        return;
    }

    /**
     * 发送通知动作（按自定义位置设置）
     *
     * $name    动作名称
     * $data    传入参数
     */
    public function send_notice_user($name, $uid, $data, $config, $is_send = 0) {

        if (!$config) {
            return; // 没有配置通知
        }

        $data = $this->_get_data($data, [
            'uid' => $uid
        ]);
        // 加入队列并执行
        $rt = \Phpcmf\Service::M('cron')->add_cron(SITE_ID, 'notice', [
            'name' => $name,
            'data' => $data,
            'config' => $config,
        ]);
        if (!$rt['code']) {
            log_message('error', '通知任务注册失败：'.$rt['msg']);
        }
        // 立即发送
        if ($is_send) {
            \Phpcmf\Service::M('cron')->do_cron_id($rt['code']);
        }

        return $rt;
    }

    // 来至队列中执行
    public function cron_email($email, $siteid, $value) {
        
        if (!$email) {
            $debug = 'email参数为空，不能发送邮件';
            $error = [
                $debug
            ];
            CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）邮件执行失败：'.$debug);
        } else {
            $error = $this->_send_email($email, $siteid, $value);
        }

        return [$error, $error ? $value : []];
    }

    // 来至队列中执行
    public function cron_notice($siteid, $value) {

        \Phpcmf\Service::M()->siteid = $siteid;

        $error = [];
        if (!$value['data']['uid']) {
            CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）执行失败：用户uid参数为空，任务不能执行');
            return [['用户uid参数为空，任务不能执行'], $value];
        }

        $member = dr_member_info($value['data']['uid']);
        if (!$member) {
            CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）执行失败：用户uid('.$value['data']['uid'].')账号不存在，任务不能执行');
            return [['用户uid('.$value['data']['uid'].')账号不存在，任务不能执行'], $value];
        }

        $notice_type = $this->get_type();
        foreach ($notice_type as $nid => $tt) {
            if (isset($value['config'][$nid]) && $value['config'][$nid]) {
                if ($nid == 'mobile') {
                    // 短信通知
                    $phone = $member['phone'];
                    if (!$phone) {
                        $error[] = $debug = '用户【'.$member['username'].'】phone参数为空，不能发送短信';
                        CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）短信执行失败：'.$debug);
                    } else {
                        $content = [];
                        if (isset($value['config']['mobile']['tpl_content']) && ($value['config']['mobile']['tpl_content'])) {
                            $content = $value['config']['mobile']['tpl_content'];
                            if (!$content) {
                                $error[] = $debug = '自定义通知内容参数tpl_content不存在';
                                CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）短信执行失败：'.$debug);
                            }
                        } else {
                            $rt = $this->_get_tpl_content($siteid, $value['name'], 'mobile', $value['data']);
                            if (!$rt['code']) {
                                $error[] = $debug = $rt['msg'];
                                CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）短信执行失败：'.$debug);
                            } else {
                                $content = $rt['msg'];
                            }
                        }
                        if ($content) {
                            $rt = \Phpcmf\Service::M('member')->sendsms_text($phone, $content);
                            if (!$rt['code']) {
                                $error[] = $debug = '短信通知执行错误：'.$rt['msg'];
                                CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）短信执行失败：'.$debug);
                            } else {
                                // 成功
                                unset($value['config'][$nid]);
                            }
                        }
                    }
                } elseif ($nid == 'email') {
                    // 邮件通知
                    $email = $member['email'];
                    if (!$email) {
                        $error[] = $debug = '用户【'.$member['username'].'】的email参数为空，不能发送邮件';
                        CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）邮件执行失败：'.$debug);
                    } else {
                        $err = $this->_send_email($email, $siteid, $value);
                        if ($err) {
                            $error = dr_array2array($err, $error);
                        } else {
                            // 成功
                            unset($value['config'][$nid]);
                        }
                    }
                } else {
                    //其他
                    $class = isset($tt['class']) && $tt['class'] ? $tt['class'] : 'notice';
                    $classFile = dr_get_app_dir($nid).'Models/'.ucfirst($class).'.php';
                    if (!is_file($classFile)) {
                        CI_DEBUG && log_message('debug', '通知对象('.$nid.')类文件（'.$classFile.'）不存在');
                        return;
                    }
                    list($error, $value) = \Phpcmf\Service::M($class, $nid)->send_notice($value, $siteid, $error);
                }
            }
        }


        return [$error, $error ? $value : []];
    }

    protected function _send_email($email, $siteid, $value) {

        $title = '';
        $error = [];
        $content = [];
        if (isset($value['config']['email']['tpl_content']) && ($value['config']['email']['tpl_content'])) {
            $content = $value['config']['email']['tpl_content'];
            if (!$content) {
                $error[] = $debug = '自定义通知内容参数tpl_content不存在';
                CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）邮件执行失败：'.$debug);
            }
        } else {
            $rt = $this->_get_tpl_content($siteid, $value['name'], 'email', $value['data']);
            if (!$rt['code']) {
                $error[] = $debug = $rt['msg'];
                CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）邮件执行失败：'.$debug);
            } else {
                $content = $rt['msg'];
            }
        }
        if ($content) {
            if (preg_match('/<title>(.+)<\/title>/U', $content, $mt)) {
                $title = $mt[1];
                $content = str_replace($mt[0], '', $content);
            }
            $rt = \Phpcmf\Service::M('email')->site_name($siteid)->sendmail($email, $title ? $title : '通知', $content);
            if (!$rt['code']) {
                $error[] = $debug = '邮件发送失败：'.$rt['msg'];
                CI_DEBUG && log_message('debug', '通知任务（'.$value['name'].'）邮件执行失败：'.$debug);
            } else {
                // 成功
                unset($value['config']['email']);
            }
        }

        return $error;
    }

    // 获取通知模板内容
    public function _get_tpl_content($siteid, $name, $type, $data) {

        /*
        if ($siteid > 1) {
            $my = \Phpcmf\Service::L('html')->get_webpath($siteid, 'site', 'config/notice/'.$type.'/'.$name.'.html');
            $my = is_file($my) ? file_get_contents($my) : '';
        } else {
            $my = '';
        }*/

        $my = \Phpcmf\Service::L('html')->get_webpath($siteid, 'site', 'config/notice/'.$type.'/'.$name.'.html');
        if (is_file($my)) {
            $content_code = file_get_contents($my);
        } else {
            $my = CONFIGPATH.'notice/'.$type.'/'.$name.'.html';
            $content_code = file_get_contents($my);
        }

        if (!$content_code) {
            return dr_return_data(0, '模板不存在【'.$my.'】');
        }

        // 替换多站点变量
        if (isset(\Phpcmf\Service::C()->site_info[$siteid]) && \Phpcmf\Service::C()->site_info[$siteid]) {
            $site_info = \Phpcmf\Service::C()->site_info[$siteid];
            $content_code = str_replace('{SITE_NAME}', $site_info['SITE_NAME'], $content_code);
            $content_code = str_replace('{SITE_URL}', $site_info['SITE_URL'], $content_code);
        }

        ob_start();
        extract($data, EXTR_OVERWRITE);
        $require_file = \Phpcmf\Service::V()->code2php($content_code);
        require $require_file;
        $code = ob_get_clean();

        return dr_return_data(1, $code);
    }

    // xml转换数组
    public function _xml_array($xml) {

        $reg = "/<(\\w+)[^>]*?>(.*?)<\\/\\1>/Us";
        if (preg_match_all($reg, $xml, $matches)) {
            $count = dr_count($matches[0]);
            $arr = array();
            for($i = 0; $i < $count; $i++) {
                $key = $matches[1][$i];
                $val = $this->_xml_array( $matches[2][$i] );  // 递归
                if (array_key_exists($key, $arr)) {
                    if (is_array($arr[$key])) {
                        if(!array_key_exists(0,$arr[$key]))
                        {
                            $arr[$key] = array($arr[$key]);
                        }
                    } else {
                        $arr[$key] = array($arr[$key]);
                    }
                    $arr[$key][] = $val;
                } else {
                    $arr[$key] = $val;
                }
            }
            return $arr;
        }else{
            return $xml;
        }
    }

}