colleague / study-project · Files

<?php
/**
 * AbstractService.class.php
 * Service 层基类
 * @author: zhuxun37
 * @version: $Id$
 * @copyright: vchangyi.com
 */

namespace Common\Service;

use Common\Common\Msg;
use Common\Common\User;
use VcySDK\Service;

abstract class AbstractService extends \Com\Service
{
    // 默认显示条数
    const DEFAULT_LIMIT = 15;

    // 【同事圈】成功发表帖子
    const MSG_CIRCLE_PUBLISH = 1;
    // 【同事圈】帖子通过审核
    const MSG_CIRCLE_ADOPT = 2;
    // 【同事圈】帖子未通过审核
    const MSG_CIRCLE_REFUSE = 3;
    // 【同事圈】成功发表评论
    const MSG_COMMENT_PUBLISH = 4;
    // 【同事圈】评论通过审核
    const MSG_COMMENT_ADOPT = 5;
    // 【同事圈】评论未通过审核
    const MSG_COMMENT_REFUSE = 6;
    // 【同事圈】收到评论消息
    const MSG_COMMENT = 7;

    // 【同事圈】回帖通过审核
    const MSG_REPLIES_PUBLISH = 8;
    // 【同事圈】回帖通过审核
    const MSG_REPLIES_ADOPT = 9;
    // 【同事圈】回帖未通过审核
    const MSG_REPLIES_REFUSE = 10;

    // 【同事圈】话题通过审核
    const MSG_CIRCLE_TOPIC_ADOPT = 11;
    // 【同事圈】话题未通过审核
    const MSG_CIRCLE_TOPIC_REFUSE = 12;
    // 【同事圈】话题回帖评论通过审核
    const MSG_CIRCLE_TOPIC_COMMENT_ADOPT = 13;
    // 【同事圈】收到回帖评论消息
    const MSG_TOPIC_COMMENT = 14;
    // 【同事圈】成功发表话题
    const MSG_TOPIC_PUBLISH = 15;
    // 【同事圈】成功发表回帖的
    const MSG_REPLIES_COMMENT_PUBLISH = 16;

    // 我的评论类型
    const MY_COMMENT_INFO = 1;
    // 我的帖子详情类型
    const MY_CIRCLE_INFO = 2;
    // 我的评论详情类型
    const CIRCLE_INFO = 3;
    // 回帖详情
    const REPLIES_INFO = 4;
    // 话题详情
    const TOPIC_INFO = 5;
    // 我的话题详情
    const MY_TOPIC_INFO = 6;
    // 我的回帖详情
    const MY_REPLIES_INFO = 7;

    // 构造方法
    public function __construct()
    {

        parent::__construct();
    }

    /**
     * 即时消息通知方法 【发消息统一写这里，方便维护】
     *
     * @param $params -通知参数
     *          + User     -审核人
     *          + name     -评论人
     *          + uids      -用户uid数组
     *              + memID     -用户uid
     *          + cd_ids    -部门id数组
     *              + dpID      -部门id
     *          + tag_ids   -标签id数组
     *              + tagID     -标签id
     *          + id   -话题ID
     *          + description -摘要
     * @param $type -通知文案类型
     *
     * @return bool
     */
    public function send_msg($params, $type)
    {

        // 初始化审核人信息
        $reviewer = '';

        // 如果审核人存在
        if (!empty($params['User'])) {

            $reviewer = "\r\n审核人：" . $params['User'];
        }

        // 转换格式
        $params['description'] = $this->DeleteHtml($params['description']);

        // 获取应用名称
        $application_name = '员圈';

        // 本方法根据类型区分拼接不通的文案
        switch ($type) {
            case self::MSG_CIRCLE_PUBLISH:

                $data = [
                    'title' => '【' . $application_name . '】您已成功发表帖子，请耐心等待审核',
                    'description' => '帖子内容：' . $this->cutstr($params['description'], 0,
                            20) . "\r\n发表时间：" . rgmdate(MILLI_TIME,
                            'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_CIRCLE_INFO
                ];
                break;
            case self::MSG_TOPIC_PUBLISH:

                $data = [
                    'title' => '【' . $application_name . '】您已成功发表话题，请耐心等待审核',
                    'description' => '话题标题：' . $this->cutstr($params['title'], 0,
                            20) . "\r\n发表时间：" . rgmdate(MILLI_TIME,
                            'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_TOPIC_INFO
                ];
                break;

            case self::MSG_CIRCLE_ADOPT:

                $data = [
                    'title' => '【' . $application_name . '】恭喜您，您的帖子已通过审核，现已正式发布',
                    'description' => '帖子内容：' . $this->cutstr($params['description'], 0,
                            20) . $reviewer . "\r\n审核时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::CIRCLE_INFO
                ];

                break;
            case self::MSG_CIRCLE_REFUSE:

                $data = [
                    'title' => '【' . $application_name . '】抱歉，您的帖子未通过审核，无法发布',
                    'description' => '帖子内容：' . $this->cutstr($params['description'], 0,
                            20) . $reviewer . "\r\n审核时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_CIRCLE_INFO
                ];

                break;
            case self::MSG_REPLIES_PUBLISH:

                $data = [
                    'title' => '【' . $application_name . '】您已成功发表回帖，请耐心等待审核',
                    'description' => '回帖内容：' . $this->cutstr($params['description'], 0,
                            20) . "\r\n发表时间：" . rgmdate(MILLI_TIME,
                            'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_REPLIES_INFO
                ];
                break;
            case self::MSG_REPLIES_ADOPT:

                $data = [
                    'title' => '【' . $application_name . '】恭喜您，您的回帖已通过审核，现已正式发布',
                    'description' => '回帖内容：' . $this->cutstr($params['description'], 0,
                            20) . $reviewer . "\r\n审核时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::REPLIES_INFO
                ];

                break;
            case self::MSG_REPLIES_REFUSE:

                $data = [
                    'title' => '【' . $application_name . '】抱歉，您的回帖未通过审核，无法发布',
                    'description' => '回帖内容：' . $this->cutstr($params['description'], 0,
                            20) . $reviewer . "\r\n审核时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_REPLIES_INFO
                ];

                break;
            case self::MSG_COMMENT_PUBLISH:

                $data = [
                    'title' => '【' . $application_name . '】您已成功发表评论，请耐心等待审核',
                    'description' => '评论内容：' . $this->cutstr($params['description'], 0,
                            20) . "\r\n评论时间：" . rgmdate(MILLI_TIME,
                            'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_COMMENT_INFO
                ];

                break;
            case self::MSG_REPLIES_COMMENT_PUBLISH:

                $data = [
                    'title' => '【' . $application_name . '】您已成功发表回帖评论，请耐心等待审核',
                    'description' => '评论内容：' . $this->cutstr($params['description'], 0,
                            20) . "\r\n评论时间：" . rgmdate(MILLI_TIME,
                            'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_COMMENT_INFO
                ];

                break;
            case self::MSG_COMMENT_ADOPT:
                $data = [
                    'title' => '【' . $application_name . '】恭喜您，您的评论已通过审核，现已正式发布',
                    'description' => '评论内容：' . $this->cutstr($params['description'], 0,
                            20) . $reviewer . "\r\n评论时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::CIRCLE_INFO
                ];

                break;
            case self::MSG_COMMENT_REFUSE:
                $data = [
                    'title' => '【' . $application_name . '】抱歉，您的评论未通过审核，无法发布',
                    'description' => '评论内容：' . $this->cutstr($params['description'], 0,
                            20) . $reviewer . "\r\n评论时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_COMMENT_INFO
                ];
                break;
            case self::MSG_COMMENT:

                $data = [
                    'title' => '【' . $application_name . '】您发布的帖子有一条新评论',
                    'description' => '评论人：' . $params['name'] . "\r\n评论内容：" . $this->cutstr($params['description'], 0,
                            20) . "\r\n评论时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::CIRCLE_INFO
                ];
                break;
            case self::MSG_TOPIC_COMMENT:

                $data = [
                    'title' => '【' . $application_name . '】您发布的回帖有一条新评论',
                    'description' => '评论人：' . $params['name'] . "\r\n评论内容：" . $this->cutstr($params['description'], 0,
                            20) . "\r\n评论时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::REPLIES_INFO
                ];
                break;
            case self::MSG_CIRCLE_TOPIC_COMMENT_ADOPT:

                $data = [
                    'title' => '【' . $application_name . '】恭喜您，您回帖的评论已通过审核，现已正式发布',
                    'description' => '评论内容：' . $this->cutstr($params['description'], 0,
                            20) . $reviewer . "\r\n评论时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::REPLIES_INFO
                ];
                break;
                case self::MSG_CIRCLE_TOPIC_ADOPT:

                    $data = [
                        'title' => '【' . $application_name . '】恭喜您，您的话题已通过审核，现已正式发布',
                        'description' => '话题标题：' . $this->cutstr($params['title'], 0,
                                20) . $reviewer . "\r\n审核时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                        'picUrl' => '',
                        'type' => self::TOPIC_INFO
                    ];
                    break;

            case self::MSG_CIRCLE_TOPIC_REFUSE:

                $data = [
                    'title' => '【' . $application_name . '】抱歉，您的话题未通过审核，无法发布',
                    'description' => '话题标题：' . $this->cutstr($params['title'], 0,
                            20) . $reviewer . "\r\n审核时间：" . rgmdate(strval(MILLI_TIME), 'Y-m-d H:i:s'),
                    'picUrl' => '',
                    'type' => self::MY_TOPIC_INFO
                ];
                break;

            default:

                return true;
        }

        $this->send($params, $data);

        return true;
    }


    /**
     * 发送消息
     *
     * @param $params -通知参数
     *          + uids      -用户uid数组
     *              + memID     -用户uid
     *          + cd_ids    -部门id数组
     *              + dpID      -部门id
     *          + tag_ids   -标签id数组
     *              + tagID     -标签id
     *          + ac_id   -ID
     * @param array $condition 消息参数
     *          + title  -标题
     *          + description -内容
     *          + picUrl -图片URL
     *
     * @return bool
     */
    private function send($params = [], $condition = [])
    {
        // 发送消息接收人
        $toUser = array_unique(array_filter(array_column($params['uids'], 'memID')));
        if (empty($toUser)) {
            $toUser = $params['uids'];
        }

        $msgUser = implode('|', $toUser);

        // 发送消息部门
        $toParty = array_unique(array_filter(array_column($params['cd_ids'], 'dpID')));
        if (empty($toParty)) {
            $toParty = $params['cd_ids'];
        }
        // 发送消息标签
        $toTag = array_unique(array_filter(array_column($params['tag_ids'], 'tagID')));
        if (empty($toTag)) {
            $toTag = $params['tag_ids'];
        }

        // 实例化发消息SDK
        $common_msg = Msg::instance();
        $msg['toUser'] = !empty($msgUser) ? $msgUser : ''; // 接收人
        $msg['toParty'] = !empty($toParty) ? implode('|', $toParty) : '';
        $msg['toTag'] = !empty($toTag) ? implode('|', $toTag) : '';
        $msg['articles'] = [
            [
                'title' => $condition['title'],
                'description' => $condition['description'],
                'url' => oaUrl('Frontend/Index/Msg/Index',
                    ['type' => $condition['type'], 'id' => $params['id']]
                ),
                'picUrl' => '',
            ],
        ];

        $common_msg->sendNews($msg['toUser'], $msg['toParty'], $msg['toTag'], $msg['articles']);

        return true;
    }

    /**
     * 转换时间格式
     * 时间显示规则：1小时内显示XX分钟前，1天以内的显示XX个小时前，1~7天显示XX天前，超过7天显示具体年-月-日 时-分
     *
     * @param string $time 当前时间戳
     *
     * @return bool
     */
    public function get_time($time = '')
    {
        // 获取剩余秒数
        $way = NOW_TIME - ($time / 1000);

        // 一分钟之内
        if ($way < 60) {

            return '刚刚';
        }

        // 如果是一小时之内
        if ($way < 3600) {

            return intval($way / 60) . '分钟前';
        }

        // 如果是一小时之内
        if ($way < 3600) {

            return intval($way / 60) . '分钟前';
        }

        // 如果是一天之内
        if ($way < 86400) {

            return intval($way / 3600) . '小时前';
        }

        // 如果是一周之内
        if ($way < 604800) {

            return intval($way / 86400) . '天前';
        }

        return rgmdate(strval($time),'m-d H:i');
    }

    /**
     * 格式化图片地址
     *
     * @param array $images_list 附件列表
     *
     * @return array
     */
    public function format_att_images($images_list = [])
    {
        // 初始化
        $covers = [];

        // 如果附件ID为空
        if (empty($images_list)) {
            return $covers;
        }

        // 遍历数据
        foreach ($images_list as $key => $v) {
            $covers[$v['cid']][] = [
                'atId' => $v['atid'],
                'imgUrl' => imgUrlReal($v['atid']),
            ];

        }
        return $covers;
    }

    /**
     * 格式化人员信息
     *
     * @param array $mem_uids 人员UIDS
     *
     * @return array
     */
    public function format_user($mem_uids = [])
    {
        // 初始化
        $users = [];

        // 如果附件ID为空
        if (empty($mem_uids)) {

            return $users;
        }

        // 实例化公共User类
        $user = User::instance();

        // 获取人员列表
        $user_list = $user->listByConds(['memUids' => $mem_uids], 1, count($mem_uids));

        // 获取已查到人员UID集合
        $uid_list = array_column($user_list['list'], 'memUid');

        // 获取全部用户列表
        $this->user_list($user_list['list'], $mem_uids, $uid_list);

        // 遍历数据
        foreach ($user_list['list'] as $key => $v) {

            $users[$v['memUid']] = [
                'username' => strval($v['memUsername']),
                'avatar' => strval($user->avatar($v['memUid'])),
                'uid' => strval($v['memUid'])
            ];
        }

        return $users;
    }

    /**
     * 【微信端】去除字符串html标签方法
     *
     * @param  string $str 字符串
     *
     * @return string
     */
    public function DeleteHtml($str = '')
    {
        $str = trim($str); //清除字符串两边的空格

        $str = strip_tags($str, ""); //利用php自带的函数清除html格式

        $replace = ["\t", "\n", "\r"];

        return trim(str_replace($replace, '', $str)); //返回字符串
    }

    /**
     * 替换字符串中的/r/n为回车
     *
     * @param string $str 字符串
     *
     * @return string
     */
    public function Enter($str = '')
    {

        $str = trim($str); //清除字符串两边的空格

        $replace = ["\r\n", "\n", "\r", "&crarr;", "&#8629;"];

        return trim(str_replace($replace, "<br/>", $str)); //返回字符串

    }

    /**
     * 获取已删除用户信息
     *
     * @param array &$user_list 用户列表
     * @param array $uids 全部用户UID
     * @param array $uid_list 已查询到用户UID
     *
     * @return array
     */
    public function user_list(&$user_list = [], $uids = [], $uid_list = [])
    {

        // 获取被删除的用户UID
        $un_uid = array_diff($uids, $uid_list);

        // 实例化
        $user = User::instance();

        // 遍历数据
        foreach ($un_uid as $k => $v) {

            // 如果UID不为空
            if (!empty($v)) {

                $user_list[] = $user->getByUid($v);
            }
        }

        return $uid_list;
    }

    /**
     * 字符串截取，支持中文和其他编码
     * static
     * access public
     *
     * @param string $str 需要转换的字符串
     * @param string $start 开始位置
     * @param string $length 截取长度
     * @param string $charset 编码格式
     * @param string $suffix 截断显示字符
     * return string
     */
    public function cutstr($str, $start = 0, $length, $charset = "utf-8", $suffix = true)
    {
        if (function_exists("mb_substr")) {
            $slice = mb_substr($str, $start, $length, $charset);
        } elseif (function_exists('iconv_substr')) {
            $slice = iconv_substr($str, $start, $length, $charset);
            if (false === $slice) {
                $slice = '';
            }
        } else {
            $re['utf-8'] = "/[\x01-\x7f]|[\xc2-\xdf][\x80-\xbf]|[\xe0-\xef][\x80-\xbf]{2}|[\xf0-\xff][\x80-\xbf]{3}/";
            $re['gb2312'] = "/[\x01-\x7f]|[\xb0-\xf7][\xa0-\xfe]/";
            $re['gbk'] = "/[\x01-\x7f]|[\x81-\xfe][\x40-\xfe]/";
            $re['big5'] = "/[\x01-\x7f]|[\x81-\xfe]([\x40-\x7e]|\xa1-\xfe])/";
            preg_match_all($re[$charset], $str, $match);
            $slice = join("", array_slice($match[0], $start, $length));
        }

        if (get_str_len($str) > $length && $slice) {

            $slice = $slice . '...';
        }

        return $suffix ? $slice : $slice;
    }

    /**
     * 同事圈 修改UC返回积分格式
     *
     * @param array $msg_list 积分格式数据
     *
     * @return array
     */
    public function msg_list($msg_list = [])
    {
        // 初始化
        $list = [];

        // 遍历数据重新组合
        foreach ($msg_list as $key => $v) {

            if ($v['result'] == 'SUCCESS') {

                $list[] = [
                    'number' => intval($v['score']),
                    'content' => '积分'
                ];

            }

        }

        return $list;

    }
}