This commit is contained in:
Arslan Hassan
parent
231e481855
commit
6131a4c6ea
4 changed files with 650 additions and 59 deletions
633
upload/includes/classes/pm.class.php
Normal file
633
upload/includes/classes/pm.class.php
Normal file
|
|
@ -0,0 +1,633 @@
|
|||
<?php
|
||||
|
||||
|
||||
/**
|
||||
* This Class is used to
|
||||
* Send and recieve
|
||||
* private or personal messages
|
||||
* within the CLIPBUCKET system
|
||||
*
|
||||
* @Author : Arslan Hassan (=D)
|
||||
* @Software : ClipBucket v2
|
||||
* @License : CBLA
|
||||
*
|
||||
* Pleae check CBLA for more details
|
||||
* For code reference, please check docs.clip-bucket.com
|
||||
* This Code is property of PHPBucket - ClipBucket - Arslan Hassan
|
||||
*
|
||||
* NOTE : MAINTAIN THIS SECTION
|
||||
*
|
||||
*
|
||||
* Attachment Pattern : {v:videoidid}{p:pictureid}{g:groupid}{c:channelid}
|
||||
* For Multi Users : uid can be uid1|uid2|uid3|....
|
||||
*/
|
||||
|
||||
|
||||
define('CB_PM','ON');
|
||||
define('CB_PM_MAX_INBOX',500); // 0 - OFF , U - Unlimited
|
||||
|
||||
/**
|
||||
* Function used to to attach video to pm
|
||||
* @param array => 'attachment_video'
|
||||
*/
|
||||
function attach_video($array)
|
||||
{
|
||||
global $cbvid;
|
||||
if($cbvid->video_exists($array['attach_video']))
|
||||
return '{v:'.$array['attach_video'].'}';
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to pars video from attachemtn
|
||||
*/
|
||||
function parse_and_attach_video($att)
|
||||
{
|
||||
global $cbvid;
|
||||
preg_match('/{v:(.*)}/',$att,$matches);
|
||||
$vkey = $matches[1];
|
||||
if(!empty($vkey))
|
||||
{
|
||||
assign('video',$cbvid->get_video_details($vkey));
|
||||
assign('only_once',true);
|
||||
echo '<h3>Attached Video</h3>';
|
||||
template('blocks/video.html');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to add custom video attachment form field
|
||||
*/
|
||||
function video_attachment_form()
|
||||
{
|
||||
global $cbvid;
|
||||
$vid_array = array('user'=>userid(),'order'=>'title');
|
||||
$videos = $cbvid->get_videos($vid_array);
|
||||
$vids_array = array(''=>'No Video');
|
||||
if($videos)
|
||||
foreach($videos as $video)
|
||||
{
|
||||
$vids_array[$video['videokey']] = $video['title'];
|
||||
}
|
||||
$field = array(
|
||||
'video_form' => array
|
||||
('title'=> 'Attach video',
|
||||
'type'=>'dropdown',
|
||||
'name'=> 'attach_video',
|
||||
'id'=> 'attach_video',
|
||||
'value'=> $vids_array,
|
||||
'checked'=>post('attach_video'),
|
||||
'anchor_before'=>'before_video_attach_box',
|
||||
)
|
||||
);
|
||||
return $field;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
class cb_pm
|
||||
{
|
||||
/**
|
||||
* Private messages table
|
||||
*/
|
||||
var $tbl = 'messages';
|
||||
|
||||
/**
|
||||
* Allow multi users
|
||||
*/
|
||||
var $multi = true;
|
||||
|
||||
|
||||
/**
|
||||
* Default Template
|
||||
*/
|
||||
var $email_template = 'pm_email_message';
|
||||
|
||||
/**
|
||||
* Send Email on pm
|
||||
*/
|
||||
var $send_email = true;
|
||||
|
||||
/**
|
||||
* Allow inline attachments
|
||||
* these attachements are linked in the messages instead of attached like emails
|
||||
*/
|
||||
var $allow_attachments = true;
|
||||
|
||||
//Attachment functionss
|
||||
var $pm_attachments = array('attach_video');
|
||||
var $pm_attachments_parse = array('parse_and_attach_video');
|
||||
|
||||
var $pm_custom_field = array();
|
||||
|
||||
|
||||
/**
|
||||
* Calling Constructor
|
||||
*/
|
||||
function init()
|
||||
{
|
||||
$this->add_custom_field(video_attachment_form());
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Sending PM
|
||||
*/
|
||||
function send_pm($array)
|
||||
{
|
||||
global $userquery,$db;
|
||||
$to = $this->check_users($array['to'],$from);
|
||||
//checking from user
|
||||
if(!$userquery->user_exists($array['from']))
|
||||
{
|
||||
e(lang('unknown_sender'));
|
||||
//checking to user
|
||||
}elseif(!$to)
|
||||
e(lang('unknown_reciever'));
|
||||
//Checking if subject is empty
|
||||
elseif(empty($array['subj']))
|
||||
e(lang('class_subj_err'));
|
||||
elseif(empty($array['content']))
|
||||
e(lang('please_enter_message'));
|
||||
else
|
||||
{
|
||||
$from = $this->get_the_user($array['from']);
|
||||
$attachments = $this->get_attachments($array);
|
||||
$type = $array['type'] ? $array['type'] : 'pm';
|
||||
$reply_to = $this->is_reply($array['reply_to'],$from);
|
||||
$to = $to.'|';
|
||||
|
||||
$fields = array('message_from','message_to','message_content',
|
||||
'message_subject','date_added','message_attachments','message_box','reply_to');
|
||||
$values = array($from,$to,$array['content'],
|
||||
$array['subj'],now(),$attachments);
|
||||
|
||||
//PM INBOX FIELDS
|
||||
$fields_in = $fields;
|
||||
//PM INBOX
|
||||
$values_in = $values;
|
||||
$values_in[] = 'in';
|
||||
$values_in[] = $reply_to;
|
||||
|
||||
$db->insert($this->tbl,$fields_in,$values_in);
|
||||
$array['msg_id'] = $db->insert_id();
|
||||
if($array['is_pm'])
|
||||
{
|
||||
//PM SENTBOX FIELDS
|
||||
$fields_out = $fields;
|
||||
$fields_out[] = 'message_status';
|
||||
|
||||
//PM SENTBOX
|
||||
$values_out = $values;
|
||||
$values_out[] = 'out';
|
||||
$values_out[] = $reply_to;
|
||||
$values_out[] = 'read';
|
||||
|
||||
$db->insert($this->tbl,$fields_out,$values_out);
|
||||
}
|
||||
|
||||
//Sending Email
|
||||
$this->send_pm_email($array);
|
||||
e(lang("pm_sent_success"),"m");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Function used to check input users
|
||||
* are valid or not
|
||||
*/
|
||||
function check_users($input,$sender)
|
||||
{
|
||||
global $userquery;
|
||||
//check if usernames are sperated by colon ';'
|
||||
$input = preg_replace('/;/',',',$input);
|
||||
//Now Exploding Input and converting it to and array
|
||||
$usernames = explode(',',$input);
|
||||
//Now Checkinf for valid usernames
|
||||
$valid_users = array();
|
||||
foreach($usernames as $username)
|
||||
{
|
||||
$user_id = $this->get_the_user($username);
|
||||
if($userquery->user_exists($username) && $username!=$sender && !$this->is_user_banned($username,userid()))
|
||||
$valid_users[] = $user_id;
|
||||
}
|
||||
|
||||
$valid_users = array_unique($valid_users);
|
||||
if(count($valid_users)>0)
|
||||
return implode('|',$valid_users);
|
||||
else
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Function used to get user
|
||||
*/
|
||||
function get_the_user($user)
|
||||
{
|
||||
global $userquery;
|
||||
if(!is_numeric($user))
|
||||
return $userquery->get_user_field_only($user,'userid');
|
||||
else
|
||||
return $user;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Function used to make attachment valid
|
||||
* and embed it in the message
|
||||
*/
|
||||
function get_attachments($array)
|
||||
{
|
||||
$funcs = $this->pm_attachments;
|
||||
$attachments = '';
|
||||
|
||||
if(is_array($funcs))
|
||||
foreach($funcs as $func)
|
||||
{
|
||||
if(function_exists($func))
|
||||
{
|
||||
$attachments .= $func($array);
|
||||
}
|
||||
}
|
||||
return $attachments;
|
||||
}
|
||||
|
||||
/**
|
||||
* function used to check weather message is reply or not
|
||||
*/
|
||||
function is_reply($id,$uid)
|
||||
{
|
||||
global $db;
|
||||
$results = $db->select($this->tbl,'message_to'," message_id = '$id' AND message_to LIKE '%$uid|%'");
|
||||
if($db->num_rows>0)
|
||||
return true;
|
||||
else
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to get message from inbox, set the template
|
||||
* and display it
|
||||
*/
|
||||
function get_message($id)
|
||||
{
|
||||
global $db;
|
||||
$result = $db->select($this->tbl,'*'," message_id='$id'");
|
||||
$result = $result[0];
|
||||
if($db->num_rows>0)
|
||||
{
|
||||
return $result[0];
|
||||
}else{
|
||||
e(lang('no_pm_exist'));
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to get user INBOX Message
|
||||
* @param MESSAGE ID
|
||||
* @param USER ID
|
||||
*/
|
||||
function get_inbox_message($mid,$uid=NULL)
|
||||
{
|
||||
global $db;
|
||||
if(!$uid)
|
||||
$uid = userid();
|
||||
$result = $db->select($this->tbl.',users',$this->tbl.'.*,users.userid,users.username'," message_id='$mid' AND message_to LIKE '%$uid|%' AND userid=".$this->tbl.".message_from");
|
||||
|
||||
if($db->num_rows>0)
|
||||
{
|
||||
return $result[0];
|
||||
}else{
|
||||
e(lang('no_pm_exist'));
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to get user OUTBOX Message
|
||||
* @param MESSAGE ID
|
||||
* @param USER ID
|
||||
*/
|
||||
function get_outbox_message($mid,$uid=NULL)
|
||||
{
|
||||
global $db;
|
||||
if(!$uid)
|
||||
$uid = userid();
|
||||
$result = $db->select($this->tbl.',users',$this->tbl.'.*,users.userid,users.username'," message_id='$mid' AND message_from='$uid' AND userid=".$this->tbl.".message_from");
|
||||
|
||||
if($db->num_rows>0)
|
||||
{
|
||||
return $result[0];
|
||||
}else{
|
||||
e(lang('no_pm_exist'));
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Get Total PM
|
||||
*/
|
||||
function pm_count() {
|
||||
global $db;
|
||||
return $db->count($this->tbl,'message_id');
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to get user inbox messages
|
||||
*/
|
||||
function get_user_messages($uid,$box='in',$count_only=false)
|
||||
{
|
||||
global $db;
|
||||
|
||||
if(!$uid)
|
||||
$uid = userid();
|
||||
switch ($box)
|
||||
{
|
||||
|
||||
case 'in':
|
||||
{
|
||||
if($count_only)
|
||||
{
|
||||
$result = $db->count($this->tbl,'message_id'," message_to LIKE '%$uid|%' AND message_box ='in' AND message_type='pm' ");
|
||||
}else{
|
||||
$result = $db->select($this->tbl.',users',$this->tbl.'.*,users.username AS message_from_user ',
|
||||
$this->tbl.".message_to LIKE '%$uid|%' AND users.userid = ".$this->tbl.".message_from
|
||||
AND ".$this->tbl.".message_box ='in' AND message_type='pm'");
|
||||
}
|
||||
}
|
||||
break;
|
||||
|
||||
|
||||
case 'out':
|
||||
{
|
||||
if($count_only)
|
||||
{
|
||||
$result = $db->count($this->tbl,'message_id'," message_from = '$uid' AND message_box ='out' ");
|
||||
}else{
|
||||
$result = $db->select($this->tbl.',users',$this->tbl.'.*,users.username AS message_from_user ',
|
||||
$this->tbl.".message_from = '$uid' AND users.userid = ".$this->tbl.".message_from
|
||||
AND ".$this->tbl.".message_box ='out'");
|
||||
|
||||
|
||||
//One More Query Need To be executed to get username of recievers
|
||||
$count = 0;
|
||||
|
||||
if(is_array($result))
|
||||
foreach($result as $re)
|
||||
{
|
||||
|
||||
$cond = '';
|
||||
$receivers = explode('|',$re['message_to']);
|
||||
|
||||
foreach($receivers as $to_user)
|
||||
{
|
||||
|
||||
if(!empty($to_user))
|
||||
{
|
||||
if(!empty($cond))
|
||||
$cond .= " OR ";
|
||||
$cond .= " userid='$to_user' ";
|
||||
}
|
||||
}
|
||||
|
||||
$to_names = $db->select('users','username',$cond);
|
||||
|
||||
$t_names = '';
|
||||
|
||||
if(is_array($to_names))
|
||||
foreach($to_names as $tn)
|
||||
{
|
||||
$t_names[] = $tn[0];
|
||||
}
|
||||
$to_user_names = implode(', ',$t_names);
|
||||
$result[$count]['to_usernames'] = $to_user_names;
|
||||
$count++;
|
||||
}
|
||||
}
|
||||
}
|
||||
break;
|
||||
|
||||
case 'notification':
|
||||
{
|
||||
if($count_only)
|
||||
{
|
||||
$result = $db->count($this->tbl,'message_id'," message_to LIKE '%$uid|%' AND message_box ='in' AND message_type='pm' ");
|
||||
}else{
|
||||
$result = $db->select($this->tbl.',users',$this->tbl.'.*,users.username AS message_from_user ',
|
||||
$this->tbl.".message_to LIKE '%$uid|' AND users.userid = ".$this->tbl.".message_from
|
||||
AND ".$this->tbl.".message_box ='in' AND message_type='notification'");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if($result)
|
||||
return $result;
|
||||
else
|
||||
return false;
|
||||
|
||||
}
|
||||
|
||||
function get_user_inbox_messages($uid,$count_only=false){ return $this->get_user_messages($uid,'in',$count_only); }
|
||||
function get_user_outbox_messages($uid,$count_only=false){ return $this->get_user_messages($uid,'out',$count_only); }
|
||||
function get_user_notification_messages($uid,$count_only=false){ return $this->get_user_messages($uid,'notification',$count_only); }
|
||||
|
||||
/**
|
||||
* Function used parse attachments
|
||||
*/
|
||||
function parse_attachments($attachment)
|
||||
{
|
||||
$funcs = $this->pm_attachments_parse;
|
||||
if(is_array($funcs))
|
||||
foreach($funcs as $func)
|
||||
{
|
||||
if(function_exists($func))
|
||||
{
|
||||
$attachments .= $func($attachment);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Function used to create PM FORM
|
||||
*/
|
||||
function load_compose_form()
|
||||
{
|
||||
$array = array
|
||||
(
|
||||
'to' =>array(
|
||||
'title'=> 'to',
|
||||
'type'=>'textfield',
|
||||
'name'=> 'to',
|
||||
'id'=> 'to',
|
||||
'value'=> post('to'),
|
||||
//'hint_2'=> "seperate usernames by comma ','",
|
||||
'required'=>'yes'
|
||||
),
|
||||
'subj' =>array(
|
||||
'title'=> 'Subject',
|
||||
'type'=>'textfield',
|
||||
'name'=> 'subj',
|
||||
'id'=> 'subj',
|
||||
'value'=> post('subj'),
|
||||
'required'=>'yes'
|
||||
),
|
||||
'content' =>array(
|
||||
'title'=> 'content',
|
||||
'type'=>'textarea',
|
||||
'name'=> 'content',
|
||||
'id'=> 'pm_content',
|
||||
'value'=> post('content'),
|
||||
'required'=>'yes',
|
||||
'anchor_before'=>'before_pm_compose_box',
|
||||
),
|
||||
|
||||
|
||||
);
|
||||
|
||||
return array_merge($array,$this->pm_custom_field);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Function used to add custom pm field
|
||||
*/
|
||||
function add_custom_field($array)
|
||||
{
|
||||
$this->pm_custom_field = array_merge($array,$this->pm_custom_field);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Function used to send PM EMAIL
|
||||
*/
|
||||
function send_pm_email($array)
|
||||
{
|
||||
global $cbemail,$userquery;
|
||||
$sender = $userquery->get_user_field_only($array['from'],'username');
|
||||
$content = clean($array['content']);
|
||||
$subject = clean($array['subj']);
|
||||
$msgid = $array['msg_id'];
|
||||
//Get To(Emails)
|
||||
$emails = $this->get_users_emails($array['to']);
|
||||
$vars = array
|
||||
(
|
||||
'{sender}' => $sender,
|
||||
'{content}' => $content,
|
||||
'{subject}' => $subject,
|
||||
'{msg_id}' => $msgid
|
||||
);
|
||||
|
||||
$tpl = $cbemail->get_template($this->email_template);
|
||||
$subj = $cbemail->replace($tpl['email_template_subject'],$vars);
|
||||
$msg = $cbemail->replace($tpl['email_template'],$vars);
|
||||
|
||||
cbmail(array('to'=>$emails,'from'=>'webmaster@localhost','subject'=>$subj,'content'=>$msg,'nl2br'=>true));
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to get emails of users from input
|
||||
*/
|
||||
|
||||
function get_users_emails($input)
|
||||
{
|
||||
global $userquery,$db;
|
||||
//check if usernames are sperated by colon ';'
|
||||
$input = preg_replace('/;/',',',$input);
|
||||
//Now Exploding Input and converting it to and array
|
||||
$usernames = explode(',',$input);
|
||||
$cond = '';
|
||||
foreach($usernames as $user)
|
||||
{
|
||||
if(!empty($user))
|
||||
{
|
||||
if(!empty($cond))
|
||||
$cond .= " OR ";
|
||||
$cond .= " username ='".$user."' ";
|
||||
}
|
||||
}
|
||||
|
||||
$emails = array();
|
||||
$results = $db->select($userquery->dbtbl['users'],'email',$cond);
|
||||
foreach($results as $result)
|
||||
{
|
||||
$emails[] = $result[0];
|
||||
}
|
||||
|
||||
return implode(',',$emails);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Function used to set private message status as read
|
||||
*/
|
||||
function set_message_status($mid,$status='read')
|
||||
{
|
||||
global $db;
|
||||
if($mid)
|
||||
$db->update($this->tbl,array('message_status'),array($status)," message_id='$mid'");
|
||||
}
|
||||
|
||||
/**
|
||||
* Function used to delete message from user messages box
|
||||
*/
|
||||
function delete_msg($mid,$uid,$box='in')
|
||||
{
|
||||
global $db;
|
||||
if($box=='in')
|
||||
{
|
||||
if($this->get_inbox_message($mid,$uid))
|
||||
{
|
||||
$db->delete($this->tbl,array("message_id"),array($mid));
|
||||
e(lang('msg_delete_inbox'),'m');
|
||||
}
|
||||
}else{
|
||||
if($this->get_outbox_message($mid,$uid))
|
||||
{
|
||||
$db->delete($this->tbl,array("message_id"),array($mid));
|
||||
e(lang('msg_delete_outbox'),'m');
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Function used to get new messages
|
||||
*/
|
||||
function get_new_messages($uid=NULL,$type='pm')
|
||||
{
|
||||
if(!$uid)
|
||||
$uid = userid();
|
||||
global $db;
|
||||
switch($type)
|
||||
{
|
||||
case 'pm':
|
||||
default:
|
||||
{
|
||||
$count = $db->count($this->tbl,"message_id"," message_to LIKE '%$uid|%' AND message_box='in' AND message_type='pm' AND message_status='unread'");
|
||||
|
||||
}
|
||||
break;
|
||||
|
||||
case 'notification':
|
||||
default:
|
||||
{
|
||||
$count = $db->count($this->tbl,"message_id"," message_to LIKE '%$uid|%' AND message_box='in' AND message_type='notification' AND message_status='unread'");
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
if($count>0)
|
||||
return $count;
|
||||
else
|
||||
return "0";
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
|
|
@ -2378,5 +2378,22 @@ class userquery {
|
|||
e(lang("no_user_ban_msg"),"m");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Function used to check weather user is banned or not
|
||||
*/
|
||||
function is_user_banned($ban,$user=NULL)
|
||||
{
|
||||
global $db;
|
||||
if(!$user)
|
||||
$user = userid();
|
||||
$result = $db->count($this->dbtbl['users'],"userid"," banned_users LIKE '%$ban%' AND (username='$user' OR userid='$user') ");
|
||||
if($result)
|
||||
return true;
|
||||
else
|
||||
return false;
|
||||
}
|
||||
}
|
||||
?>
|
||||
|
|
@ -1,9 +0,0 @@
|
|||
#tooltip {
|
||||
position: absolute;
|
||||
z-index: 3000;
|
||||
border: 1px solid #111;
|
||||
background-color: #eee;
|
||||
padding: 5px;
|
||||
opacity: 0.85;
|
||||
}
|
||||
#tooltip h3, #tooltip div { margin: 0; }
|
||||
|
|
@ -1,50 +0,0 @@
|
|||
<?php
|
||||
/*
|
||||
****************************************************************************************************
|
||||
| Copyright (c) 2007-2008 Clip-Bucket.com. All rights reserved. |
|
||||
| @ Author : ArslanHassan |
|
||||
| @ Software : ClipBucket , © PHPBucket.com |
|
||||
****************************************************************************************************
|
||||
*/
|
||||
|
||||
require 'includes/config.inc.php';
|
||||
|
||||
if(!empty($_REQUEST['returnto']))
|
||||
{
|
||||
$return_to = $_REQUEST['returnto'];
|
||||
Assign('return_to',$return_to);
|
||||
}
|
||||
else
|
||||
{
|
||||
$return_to = "/";
|
||||
Assign('return_to',$return_to);
|
||||
}
|
||||
|
||||
if(ALLOW_LANG_SELECT == 1)
|
||||
{
|
||||
subtitle('lang_change');
|
||||
Template('header.html');
|
||||
Template('message.html');
|
||||
Template('lang_change.html');
|
||||
Template('footer.html');
|
||||
|
||||
if(!empty($_REQUEST['lang']))
|
||||
{
|
||||
$lang = $_REQUEST['lang'];
|
||||
setcookie('sitelang', $lang, time()+315360000, '/');
|
||||
if(isset($_COOKIE['userid']))
|
||||
{
|
||||
mysql_query("UPDATE users SET site_lang = '".$lang."' WHERE userid = '".$_COOKIE['userid']."'");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
redirect_to(BASEURL);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
redirect_to($return_to);
|
||||
}
|
||||
|
||||
?>
|
||||
Loading…
Add table
Reference in a new issue