后台的邮件通知更新天数功能分析

邮件通知更新天数功能介绍：当用户多少天没有登录站点的时候才会给其发送邮件通知。


邮件通知更新天数的位置：后台-》全局-》空间设置-》基本设置下的邮件通知更新天数，如图。
设置为0则不启用该功能，单位为天。




功能分析：

比如用户A回复了用户B的帖子，这时候在用户A回复用户B帖子的同时会执行下面这个操作。
具体文件：source\include\post\post_newreply.php的98行附近。

1. notification_add($post['authorid'], 'pcomment', 'comment_add', array(
   
2.                         'tid' => $_G['tid'],
   
3.                         'pid' => $_G['gp_pid'],
   
4.                         'subject' => $thread['subject'],
   
5.                         'commentmsg' => cutstr(str_replace(array('[b]', '[/b]', '[/color]'), '', preg_replace("/\[color=([#\w]+?)\]/i", "", stripslashes($comment))), 200)
   
6.                 ));

复制代码

notification_add()函数是在source/function/function_core.php文件定义的，1897行附近，具体代码如下。

1. function notification_add($touid, $type, $note, $notevars = array(), $system = 0) {
   
2.         global $_G;
   
3. 
   
4.         $tospace = array('uid'=>$touid);
   
5.         space_merge($tospace, 'field_home');
   
6.         $filter = empty($tospace['privacy']['filter_note'])?array():array_keys($tospace['privacy']['filter_note']);
   
7. 
   
8.         if($filter && (in_array($type.'|0', $filter) || in_array($type.'|'.$_G['uid'], $filter))) {
   
9.                 return false;
   
10.         }
    
11. 
    
12.         $notevars['actor'] = "<a href="home.php?mod=space&uid=$_G[uid]">".$_G['member']['username']."</a>";
    
13.         if(!is_numeric($type)) {
    
14.                 $vars = explode(':', $note);
    
15.                 if(count($vars) == 2) {
    
16.                         $notestring = lang('plugin/'.$vars[0], $vars[1], $notevars);
    
17.                 } else {
    
18.                         $notestring = lang('notification', $note, $notevars);
    
19.                 }
    
20.                 $frommyapp = false;
    
21.         } else {
    
22.                 $frommyapp = true;
    
23.                 $notestring = $note;
    
24.         }
    
25. 
    
26.         $oldnote = array();
    
27.         if($notevars['from_id'] && $notevars['from_idtype']) {
    
28.                 $oldnote = DB::fetch_first("SELECT * FROM ".DB::table('home_notification')."
    
29.                         WHERE uid='$touid' AND from_id='$notevars[from_id]' AND from_idtype='$notevars[from_idtype]'");
    
30.         }
    
31.         if(empty($oldnote['from_num'])) $oldnote['from_num'] = 0;
    
32.         $notevars['from_num'] = $notevars['from_num'] ? $notevars['from_num'] : 1;
    
33.         $setarr = array(
    
34.                 'uid' => $touid,
    
35.                 'type' => $type,
    
36.                 'new' => 1,
    
37.                 'authorid' => $_G['uid'],
    
38.                 'author' => $_G['username'],
    
39.                 'note' => addslashes($notestring),
    
40.                 'dateline' => $_G['timestamp'],
    
41.                 'from_id' => $notevars['from_id'],
    
42.                 'from_idtype' => $notevars['from_idtype'],
    
43.                 'from_num' => ($oldnote['from_num']+$notevars['from_num'])
    
44.         );
    
45.         if($system) {
    
46.                 $setarr['authorid'] = 0;
    
47.                 $setarr['author'] = '';
    
48.         }
    
49. 
    
50.         if($oldnote['id']) {
    
51.                 DB::update('home_notification', $setarr, array('id'=>$oldnote['id']));
    
52.         } else {
    
53.                 $oldnote['new'] = 0;
    
54.                 DB::insert('home_notification', $setarr);
    
55.         }
    
56. 
    
57.         if(empty($oldnote['new'])) {
    
58.                 DB::query("UPDATE ".DB::table('common_member')." SET newprompt=newprompt+1 WHERE uid='$touid'");
    
59. 
    
60.                 require_once libfile('function/mail');
    
61.                 $mail_subject = lang('notification', 'mail_to_user');
    
62.                 sendmail_touser($touid, $mail_subject, $notestring, $frommyapp ? 'myapp' : $type);
    
63.         }
    
64. 
    
65.         if(!$system && $_G['uid'] && $touid != $_G['uid']) {
    
66.                 DB::query("UPDATE ".DB::table('home_friend')." SET num=num+1 WHERE uid='$_G[uid]' AND fuid='$touid'");
    
67.         }
    
68. }

复制代码

前面都是给相应用户发送提醒操作，具体不再此处进行分析，单独看发送邮件代码，如下。

1. require_once libfile('function/mail');
   
2.                 $mail_subject = lang('notification', 'mail_to_user');
   
3.                 sendmail_touser($touid, $mail_subject, $notestring, $frommyapp ? 'myapp' : $type);

复制代码

这里会执行sendmail_touser()函数，$mail_subject是邮件标题，$notestring是提醒的内容，$frommyapp是操作的类型。
sendmail_touser()函数是在source\function\function_mail.php文件里定义的，204行附近，具体代码如下。

1. function sendmail_touser($touid, $subject, $message, $mailtype='') {
   
2.         global $_G;
   
3. 
   
4.         if(empty($_G['setting']['sendmailday'])) return false;
   
5. 
   
6.         require_once libfile('function/home');
   
7.         $tospace = getspace($touid);
   
8.         if(empty($tospace['email'])) return false;
   
9. 
   
10.         space_merge($tospace, 'field_home');
    
11.         space_merge($tospace, 'status');
    
12. 
    
13.         $acceptemail = $tospace['acceptemail'];
    
14.         if(!empty($acceptemail[$mailtype]) && $_G['timestamp'] - $tospace['lastvisit'] > $_G['setting']['sendmailday']*86400) {
    
15.                 if(empty($tospace['lastsendmail'])) {
    
16.                         $tospace['lastsendmail'] = $_G['timestamp'];
    
17.                 }
    
18.                 $sendtime = $tospace['lastsendmail'] + $acceptemail['frequency'];
    
19. 
    
20.                 $query = DB::query("SELECT * FROM ".DB::table('common_mailcron')." WHERE touid='$touid' LIMIT 1");
    
21.                 if($value = DB::fetch($query)) {
    
22.                         $cid = $value['cid'];
    
23.                         if($value['sendtime'] < $sendtime) $sendtime = $value['sendtime'];
    
24.                         DB::update('common_mailcron', array('email'=>addslashes($tospace['email']), 'sendtime'=>$sendtime), array('cid'=>$cid));
    
25.                 } else {
    
26.                         $cid = DB::insert('common_mailcron', array('touid'=>$touid, 'email'=>addslashes($tospace['email']), 'sendtime'=>$sendtime), 1);
    
27.                 }
    
28.                 $message = preg_replace("/href\="(?!http\:\/\/)(.+?)"/i", 'href="'.$_G['siteurl'].'\\1"', $message);
    
29.                 $setarr = array(
    
30.                         'cid' => $cid,
    
31.                         'subject' => addslashes($subject),
    
32.                         'message' => addslashes($message),
    
33.                         'dateline' => $_G['timestamp']
    
34.                 );
    
35.                 DB::insert('common_mailqueue', $setarr);
    
36.                 return true;
    
37.         }
    
38.         return false;
    
39. }

复制代码

下面具体分析代码的执行过程。

1. if(empty($_G['setting']['sendmailday'])) return false;

复制代码

首先会判断$_G['setting']['sendmailday']变量是否存在，如果不存在则直接返回false。$_G['setting']['sendmailday']就是后台设置的邮件通知更新天数。

1. require_once libfile('function/home');
   
2.         $tospace = getspace($touid);
   
3.         if(empty($tospace['email'])) return false;

复制代码

getspace($touid)是要获取发送对象的详细信息，如果该用户没有设置邮箱，就直接返回false.

1. space_merge($tospace, 'field_home');
   
2.         space_merge($tospace, 'status');
   
3. 
   
4.         $acceptemail = $tospace['acceptemail'];

复制代码

前两句是查询该用户的相关信息。
$tospace['acceptemail']是该用户设置的邮件提醒。邮件提醒设置的具体位置在家园的设置-》邮件提醒，如图。

1. if(!empty($acceptemail[$mailtype]) && $_G['timestamp'] - $tospace['lastvisit'] > $_G['setting']['sendmailday']*86400) {

复制代码

首先判断该类型的操作是否进行邮件提醒（判断$acceptemail[$mailtype]变量是否存在），同时判断当前时间（TIMESTAMP）- 用户上一次的活动时间（$tospace['lastvisit']） > 后台设置的邮件通知更新天数（$_G['setting']['sendmailday']）*86400。不满足则跳出if判断，返回false。

1. if(empty($tospace['lastsendmail'])) {
   
2. $tospace['lastsendmail'] = $_G['timestamp'];
   
3. }

复制代码

如果用户上一次发送邮件的时间不存在，那么就赋予当前时间给$tospace['lastsendmail'].

1. $sendtime = $tospace['lastsendmail'] + $acceptemail['frequency'];

复制代码

计算发送邮件的时间，$acceptemail['frequency']为邮件提醒里的发送频率设置。

1. $query = DB::query("SELECT * FROM ".DB::table('common_mailcron')." WHERE touid='$touid' LIMIT 1");
   
2.                 if($value = DB::fetch($query)) {
   
3.                         $cid = $value['cid'];
   
4.                         if($value['sendtime'] < $sendtime) $sendtime = $value['sendtime'];
   
5.                         DB::update('common_mailcron', array('email'=>addslashes($tospace['email']), 'sendtime'=>$sendtime), array('cid'=>$cid));
   
6.                 } else {
   
7.                         $cid = DB::insert('common_mailcron', array('touid'=>$touid, 'email'=>addslashes($tospace['email']), 'sendtime'=>$sendtime), 1);
   
8.                 }

复制代码

首先到common_mailcron表里查询是否有向该用户发送邮件的邮件任务。如果存在就更新任务，如果不存在就往表里新插入一条任务。

1. $message = preg_replace("/href\="(?!http\:\/\/)(.+?)"/i", 'href="'.$_G['siteurl'].'\\1"', $message);
   
2.                 $setarr = array(
   
3.                         'cid' => $cid,
   
4.                         'subject' => addslashes($subject),
   
5.                         'message' => addslashes($message),
   
6.                         'dateline' => $_G['timestamp']
   
7.                 );
   
8.                 DB::insert('common_mailqueue', $setarr);
   
9.                 return true;

复制代码

前面是对内容进行处理，然后往common_mailqueue表里插入一条数据，返回true。
至此，相应的邮件任务已经添加，但是邮件还没有发送。下面看下邮件任务是如何触发处理的。

在template\default\common\footer.htm文件，79行附近，找到如下代码。

1. <!--{if !isset($_G['cookie']['sendmail'])}-->
   
2.         <script type="text/javascript" src="home.php?mod=misc&ac=sendmail&rand=$_G[timestamp]"></script>
   
3.         <!--{/if}-->

复制代码

如果不存在$_G['cookie']['sendmail']，那么就会输出一个js。
看js的src地址，是进入到了source\include\misc\misc_sendmail.php文件中，下面只分析重点，其他不做分析。

1. $query = DB::query("SELECT * FROM ".DB::table('common_mailcron')." WHERE sendtime<='$_G[timestamp]' ORDER BY sendtime LIMIT 0,$pernum");
   
2. while ($value = DB::fetch($query)) {
   
3.         if($value['touid']) $touids[$value['touid']] = $value['touid'];
   
4.         $cids[] = $value['cid'];
   
5.         $list[$value['cid']] = $value;
   
6. }
   
7. 
   
8. if(empty($cids)) exit();
   
9. 
   
10. $query = DB::query("SELECT * FROM ".DB::table('common_mailqueue')." WHERE cid IN (".dimplode($cids).")");
    
11. while ($value = DB::fetch($query)) {
    
12.         $sublist[$value['cid']][] = $value;
    
13. }

复制代码

从common_mailcron和common_mailqueue表分别查询数据然后赋值。

1. if($touids) {
   
2.         DB::query("UPDATE ".DB::table('common_member_status')." SET lastsendmail='$_G[timestamp]' WHERE uid IN (".dimplode($touids).")");
   
3. }

复制代码

更新common_member_status表里用户的最后发送邮件时间。

1. DB::query("DELETE FROM ".DB::table('common_mailcron')." WHERE cid IN (".dimplode($cids).")");
   
2. DB::query("DELETE FROM ".DB::table('common_mailqueue')." WHERE cid IN (".dimplode($cids).")");

复制代码

删除common_mailcron表里跟common_mailqueue表里删除相应的任务。

1. require_once libfile('function/mail');
   
2. 
   
3. foreach ($list as $cid => $value) {
   
4.         $mlist = $sublist[$cid];
   
5.         if($value['email'] && $mlist) {
   
6.                 $subject = getstr($mlist[0]['subject'], 80, 0, 0, 0, -1);
   
7.                 $message = '';
   
8.                 foreach ($mlist as $subvalue) {
   
9.                         if($subvalue['message']) {
   
10.                                 $message .= "<br><strong>$subvalue[subject]</strong><br>$subvalue[message]<br>";
    
11.                         } else {
    
12.                                 $message .= $subvalue['subject'].'<br>';
    
13.                         }
    
14.                 }
    
15.                 if(!sendmail($value['email'], $subject, $message)) {
    
16.                         runlog('sendmail', "$value[email] sendmail failed.");
    
17.                 }
    
18.         }
    
19. }

复制代码

执行相应的发送邮件操作。
至此邮件就发送出去了。

老大的帖子 常给我抢到sf的 高興~

支持啊。。。。。。

前排支持一下~~~

之前没有回复过帖子的会员就不会发送这个推送了

学习学习

学习学习

好麻烦，感觉。。。还要用户登录后才能触发。。？ 是这样的吗？