设为首页收藏本站展会信息天天打卡快捷登录设置
会员登录 注册帐号

Discuz!大师网

搜索
新闻
教程汇集 问题互助 插件推荐 建站素材 功能源码 模板风格
热门城市展会
北京 上海 天津 重庆 广州 深圳 南京 武汉
交流
网站地图 批量注册 批量发帖 虚拟人气 自由马甲 格子广告 蜘蛛统计 百度推送
分类
批量套餐 SEO套餐 个人专栏 打卡签到 搜索附件 链接格子
Discuz!大师网»站长社区 › Discuz!资源区 › Discuz!教程汇集 › Discuz!开发之发帖回帖@会员功能代码解析
返回列表 发新帖
查看: 1679|回复: 0

Discuz!开发之发帖回帖@会员功能代码解析

[复制链接]
wgetmsqdmc
发表于 2017-5-2 18:50:00 | 显示全部楼层 |阅读模式

马上注册，结交更多好友，享用更多功能，让你轻松玩转社区。

您需要 登录 才可以下载或查看，没有账号？立即注册

x
定义文件：\source\class\extend\extend_thread_allowat.php
相关类定义如下：
  1. class extend_thread_allowat extends extend_thread_base {

  3.         public $atlist;
  4.         public $allowat;

  6.         public function before_newthread($parameters) {

  8.                 if($this->group['allowat']) {
  9.                         $this->atlist = $atlist_tmp = array();
  10.                         preg_match_all("/@([^\r\n]*?)\s/i", $parameters['message'].' ', $atlist_tmp);
  11.                         $atlist_tmp = array_slice(array_unique($atlist_tmp[1]), 0, $this->group['allowat']);
  12.                         if(!empty($atlist_tmp)) {
  13.                                 if(!$this->setting['at_anyone']) {
  14.                                         foreach(C::t('home_follow')->fetch_all_by_uid_fusername($this->member['uid'], $atlist_tmp) as $row) {
  15.                                                 $this->atlist[$row['followuid']] = $row['fusername'];
  16.                                         }
  17.                                         if(count($this->atlist) < $this->group['allowat']) {
  18.                                                 $query = C::t('home_friend')->fetch_all_by_uid_username($this->member['uid'], $atlist_tmp);
  19.                                                 foreach($query as $row) {
  20.                                                         $this->atlist[$row['fuid']] = $row['fusername'];
  21.                                                 }
  22.                                         }
  23.                                 } else {
  24.                                         foreach(C::t('common_member')->fetch_all_by_username($atlist_tmp) as $row) {
  25.                                                 $this->atlist[$row['uid']] = $row['username'];
  26.                                         }
  27.                                 }
  28.                         }
  29.                         if($this->atlist) {
  30.                                 foreach($this->atlist as $atuid => $atusername) {
  31.                                         $atsearch[] = "/@".str_replace('/', '\/', preg_quote($atusername))." /i";
  32.                                         $atreplace[] = "[url=home.php?mod=space&uid=$atuid]@{$atusername}[/url] ";
  33.                                 }
  34.                                 $this->param['message'] = preg_replace($atsearch, $atreplace, $parameters['message'].' ', 1);
  35.                                 $this->param['message'] = substr($this->param['message'], 0, strlen($this->param['message']) - 1);
  36.                         }
  37.                 }
  38.         }

  40.         public function after_newthread() {
  41.                 if($this->group['allowat'] && $this->atlist) {
  42.                         foreach($this->atlist as $atuid => $atusername) {
  43.                                 notification_add($atuid, 'at', 'at_message', array('from_id' => $this->tid, 'from_idtype' => 'at', 'buyerid' => $this->member['uid'], 'buyer' => $this->member['username'], 'tid' => $this->tid, 'subject' => $this->param['subject'], 'pid' => $this->pid, 'message' => messagecutstr($this->param['message'], 150)));
  44.                         }
  45.                         set_atlist_cookie(array_keys($this->atlist));
  46.                 }
  47.         }

  49.         public function before_newreply($parameters) {
  50.                 if($this->group['allowat']) {
  51.                         $atlist_tmp = $ateduids = array();
  52.                         preg_match_all("/@([^\r\n]*?)\s/i", $parameters['message'].' ', $atlist_tmp);
  53.                         $atlist_tmp = array_slice(array_unique($atlist_tmp[1]), 0, $this->group['allowat']);
  54.                         $atnum = $maxselect = 0;
  55.                         foreach(C::t('home_notification')->fetch_all_by_authorid_fromid($this->member['uid'], $this->thread['tid'], 'at') as $row) {
  56.                                 $atnum ++;
  57.                                 $ateduids[$row[uid]] = $row['uid'];
  58.                         }
  59.                         $maxselect = $this->group['allowat'] - $atnum;
  60.                         if($maxselect > 0 && !empty($atlist_tmp)) {
  61.                                 $at_anyone = $this->setting['at_anyone'];
  62.                                 if(empty($at_anyone)) {
  63.                                         foreach(C::t('home_follow')->fetch_all_by_uid_fusername($this->member['uid'], $atlist_tmp) as $row) {
  64.                                                 if(!in_array($row['followuid'], $ateduids)) {
  65.                                                         $this->atlist[$row[followuid]] = $row['fusername'];
  66.                                                 }
  67.                                                 if(count($this->atlist) == $maxselect) {
  68.                                                         break;
  69.                                                 }
  70.                                         }
  71.                                         if(count($this->atlist) < $maxselect) {
  72.                                                 $query = C::t('home_friend')->fetch_all_by_uid_username($this->member['uid'], $atlist_tmp);
  73.                                                 foreach($query as $row) {
  74.                                                         if(!in_array($row['followuid'], $ateduids)) {
  75.                                                                 $this->atlist[$row[fuid]] = $row['fusername'];
  76.                                                         }
  77.                                                 }
  78.                                         }
  79.                                 } else {
  80.                                         foreach(C::t('common_member')->fetch_all_by_username($atlist_tmp) as $row) {
  81.                                                 if(!in_array($row['uid'], $ateduids)) {
  82.                                                         $this->atlist[$row[uid]] = $row['username'];
  83.                                                 }
  84.                                                 if(count($this->atlist) == $maxselect) {
  85.                                                         break;
  86.                                                 }
  87.                                         }
  88.                                 }
  89.                         }
  90.                         if($this->atlist) {
  91.                                 foreach($this->atlist as $atuid => $atusername) {
  92.                                         $atsearch[] = "/@$atusername /i";
  93.                                         $atreplace[] = "[url=home.php?mod=space&uid=$atuid]@{$atusername}[/url] ";
  94.                                 }
  95.                                 $this->param['message'] = preg_replace($atsearch, $atreplace, $parameters['message'].' ', 1);
  96.                                 $this->param['message'] = substr($this->param['message'], 0, strlen($this->param['message']) - 1);
  97.                         }
  98.                 }
  99.         }

  101.         public function after_newreply() {
  102.                 if($this->group['allowat'] && $this->atlist) {
  103.                         foreach($this->atlist as $atuid => $atusername) {
  104.                                 notification_add($atuid, 'at', 'at_message', array('from_id' => $this->thread['tid'], 'from_idtype' => 'at', 'buyerid' => $this->member['uid'], 'buyer' => $this->member['username'], 'tid' => $this->thread['tid'], 'subject' => $this->thread['subject'], 'pid' => $this->pid, 'message' => messagecutstr($this->param['message'], 150)));
  105.                         }
  106.                         set_atlist_cookie(array_keys($this->atlist));
  107.                 }
  108.         }

  110.         public function before_editpost($parameters) {
  111.                 if($this->group['allowat']) {
  112.                         $this->atlist = $atlist_tmp = $ateduids = array();
  113.                         $atnum = $maxselect = 0;
  114.                         foreach(C::t('home_notification')->fetch_all_by_authorid_fromid($this->member['uid'], $this->thread['tid'], 'at') as $row) {
  115.                                 $atnum ++;
  116.                                 $ateduids[$row[uid]] = $row['uid'];
  117.                         }
  118.                         $maxselect = $this->group['allowat'] - $atnum;
  119.                         preg_match_all("/@([^\r\n]*?)\s/i", $parameters['message'].' ', $atlist_tmp);
  120.                         $atlist_tmp = array_slice(array_unique($atlist_tmp[1]), 0, $this->group['allowat']);
  121.                         if($maxselect > 0 && !empty($atlist_tmp)) {
  122.                                 if(empty($this->setting['at_anyone'])) {
  123.                                         foreach(C::t('home_follow')->fetch_all_by_uid_fusername($this->member['uid'], $atlist_tmp) as $row) {
  124.                                                 if(!in_array($row['followuid'], $ateduids)) {
  125.                                                         $this->atlist[$row[followuid]] = $row['fusername'];
  126.                                                 }
  127.                                                 if(count($this->atlist) == $maxselect) {
  128.                                                         break;
  129.                                                 }
  130.                                         }
  131.                                         if(count($this->atlist) < $maxselect) {
  132.                                                 $query = C::t('home_friend')->fetch_all_by_uid_username($this->member['uid'], $atlist_tmp);
  133.                                                 foreach($query as $row) {
  134.                                                         if(!in_array($row['followuid'], $ateduids)) {
  135.                                                                 $this->atlist[$row[fuid]] = $row['fusername'];
  136.                                                         }
  137.                                                 }
  138.                                         }
  139.                                 } else {
  140.                                         foreach(C::t('common_member')->fetch_all_by_username($atlist_tmp) as $row) {
  141.                                                 if(!in_array($row['uid'], $ateduids)) {
  142.                                                         $this->atlist[$row[uid]] = $row['username'];
  143.                                                 }
  144.                                                 if(count($this->atlist) == $maxselect) {
  145.                                                         break;
  146.                                                 }
  147.                                         }
  148.                                 }
  149.                                 if($this->atlist) {
  150.                                         foreach($this->atlist as $atuid => $atusername) {
  151.                                                 $atsearch[] = "/@$atusername /i";
  152.                                                 $atreplace[] = "[url=home.php?mod=space&uid=$atuid]@{$atusername}[/url] ";
  153.                                         }
  154.                                         $parameters['message'] = preg_replace($atsearch, $atreplace, $parameters['message'].' ', 1);
  155.                                         $parameters['message'] = substr($parameters['message'], 0, strlen($parameters['message']) - 1);
  156.                                 }
  157.                         }
  158.                 }
  159.         }

  161.         public function after_editpost() {
  162.                 if($this->group['allowat'] && $this->atlist) {
  163.                         foreach($this->atlist as $atuid => $atusername) {
  164.                                 notification_add($atuid, 'at', 'at_message', array('from_id' => $this->thread['tid'], 'from_idtype' => 'at', 'buyerid' => $this->member['uid'], 'buyer' => $this->member['username'], 'tid' => $this->thread['tid'], 'subject' => $this->thread['subject'], 'pid' => $this->post['pid'], 'message' => messagecutstr($this->param['message'], 150)));
  165.                         }
  166.                         set_atlist_cookie(array_keys($this->atlist));
  167.                 }
  168.         }
  169. }
复制代码


由以上代码定义我们看到程序处理@功能分别有三处：发帖、回帖、编辑;
首先以正则表达式方式从内容文本中抽取@会员信息存入atlist，并将内容文本中的@会员解析出会员的空间地址([url]标签)，然后在所有的after_xxx方法中向被@的会员发送通知，这里需要说明一点是：before_xxx方法是内容入库前的操作，after_xxx方法是内容入库后的操作！

回复 马甲回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|网站地图|小黑屋|展会网|Discuz站长论坛 |天天打卡

GMT+8, 2024-5-6 06:37 , Processed in 0.035424 second(s), 15 queries , Gzip On.

Powered by Discuz! X3.4

Copyright © 2001-2021, Tencent Cloud.

快速回复 返回顶部 返回列表