|
Server : nginx/1.22.1 System : Linux iZwz9daxib3w3i063fw434Z 3.10.0-1127.19.1.el7.x86_64 #1 SMP Tue Aug 25 17:23:54 UTC 2020 x86_64 User : www ( 1000) PHP Version : 5.6.40 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv Directory : /www/wwwroot/www.jkmold.com/phpsso_server/phpcms/modules/admin/classes/ |
<?php
class messagequeue {
private $db;
private static function get_db() {
return pc_base::load_model('messagequeue_model');
}
/**
* 添加队列信息
*/
public static function add($operation, $noticedata_send) {
$db = self::get_db();
$noticedata_send['action'] = $operation;
$noticedata_send_string = array2string($noticedata_send);
if ($noticeid = $db->insert(array('operation'=>$operation, 'noticedata'=>$noticedata_send_string, 'dateline'=>SYS_TIME), 1)) {
self::notice($operation, $noticedata_send, $noticeid);
return 1;
} else {
return 0;
}
}
/**
* 通知应用
*/
public static function notice($operation, $noticedata, $noticeid) {
$db = self::get_db();
$applist = getcache('applist', 'admin');
foreach($applist as $k=>$v) {
//由于编码转换会改变notice_send的值，所以每次循环需要重新赋值noticedate_send
$noticedata_send = $noticedata;
//应用添加用户时不重复通知该应用
if(isset($noticedata_send['appname']) && $noticedata_send['appname'] == $v['name']) {
$appstatus[$k] = 1;
continue;
}
$url = $v['url'].$v['apifilename'];
if (CHARSET != $v['charset'] && isset($noticedata_send['action']) && $noticedata_send['action'] == 'member_add') {
if(isset($noticedata_send['username']) && !empty($noticedata_send['username'])) {
if(CHARSET == 'utf-8') { //判断phpsso字符集是否为utf-8编码
//应用字符集如果是utf-8，并且用户名是utf-8编码，转换用户名为phpsso字符集，如果为英文，is_utf8返回false，不进行转换
if(!is_utf8($noticedata_send['username'])) {
$noticedata_send['username'] = iconv(CHARSET, $v['charset'], $noticedata_send['username']);
}
} else {
if(!is_utf8($noticedata_send['username'])) {
$noticedata_send['username'] = iconv(CHARSET, $v['charset'], $noticedata_send['username']);
}
}
}
}
$tmp_s = strstr($url, '?') ? '&' : '?';
$status = ps_send($url.$tmp_s.'appid='.$k, $noticedata_send, $v['authkey']);
if ($status == 1) {
$appstatus[$k] = 1;
} else {
$appstatus[$k] = 0;
}
}
$db->update(array('totalnum'=>'+=1', 'appstatus'=>json_encode($appstatus)), array('id'=>$noticeid));
}
}
?>