mirror of
https://gh.wpcy.net/https://github.com/buddypress/buddypress.git
synced 2026-05-31 05:04:29 +08:00
a7c6581e37
git-svn-id: https://buddypress.svn.wordpress.org/trunk@1931 cdf35c40-ae34-48e0-9cc9-0c9da1808c22
338 lines
No EOL
13 KiB
PHP
338 lines
No EOL
13 KiB
PHP
<?php
|
|
|
|
Class BP_Activity_Activity {
|
|
var $id;
|
|
var $item_id;
|
|
var $secondary_item_id;
|
|
var $user_id;
|
|
var $primary_link;
|
|
var $component_name;
|
|
var $component_action;
|
|
var $date_recorded;
|
|
var $hide_sitewide = false;
|
|
|
|
function bp_activity_activity( $id = false ) {
|
|
global $bp;
|
|
|
|
if ( $id ) {
|
|
$this->id = $id;
|
|
$this->populate();
|
|
}
|
|
}
|
|
|
|
function populate() {
|
|
global $wpdb, $bp;
|
|
|
|
$activity = $wpdb->get_row( $wpdb->prepare( "SELECT * FROM {$bp->activity->table_name} WHERE id = %d", $this->id ) );
|
|
|
|
$this->id = $activity->id;
|
|
$this->item_id = $activity->item_id;
|
|
$this->secondary_item_id = $activity->secondary_item_id;
|
|
$this->user_id = $activity->user_id;
|
|
$this->content = $activity->content;
|
|
$this->primary_link = $activity->primary_link;
|
|
$this->component_name = $activity->component_name;
|
|
$this->component_action = $activity->component_action;
|
|
$this->date_recorded = $activity->date_recorded;
|
|
$this->hide_sitewide = $activity->hide_sitewide;
|
|
}
|
|
|
|
function save() {
|
|
global $wpdb, $bp, $current_user;
|
|
|
|
do_action( 'bp_activity_before_save', $this );
|
|
|
|
if ( !$this->component_name || !$this->component_action )
|
|
return false;
|
|
|
|
/***
|
|
* Before v1.1 of BuddyPress, activity content was calculated at a later point. This is no longer the
|
|
* case, to to be backwards compatible we need to fetch content here to continue.
|
|
*/
|
|
if ( empty( $this->content ) || !$this->content ) {
|
|
if ( function_exists( $bp->{$this->component_name}->format_activity_function ) ) {
|
|
if ( !$fetched_content = call_user_func( $bp->{$this->component_name}->format_activity_function, $this->item_id, $this->user_id, $this->component_action, $this->secondary_item_id, $this->for_secondary_user ) )
|
|
return false;
|
|
|
|
$this->content = $fetched_content['content'];
|
|
$this->primary_link = $fetched_content['primary_link'];
|
|
}
|
|
}
|
|
|
|
if ( !$this->primary_link )
|
|
$this->primary_link = $bp->loggedin_user->domain;
|
|
|
|
if ( $existing_activity_id = $this->exists() )
|
|
BP_Activity_Activity::delete_by_activity_id( $existing_activity_id );
|
|
|
|
/* If we have an existing ID, update the activity item, otherwise insert it. */
|
|
if ( $this->id ) {
|
|
if ( $wpdb->query( $wpdb->prepare( "UPDATE {$bp->activity->table_name} SET user_id = %d, component_name = %s, component_action = %s, content = %s, primary_link = %s, date_recorded = FROM_UNIXTIME(%d), item_id = %s, secondary_item_id = %s, hide_sitewide = %d WHERE id = %d", $this->user_id, $this->component_name, $this->component_action, $this->content, $this->primary_link, $this->date_recorded, $this->item_id, $this->secondary_item_id, $this->hide_sitewide, $this->id ) ) ) {
|
|
do_action( 'bp_activity_after_save', $this );
|
|
return true;
|
|
}
|
|
} else {
|
|
if ( $wpdb->query( $wpdb->prepare( "INSERT INTO {$bp->activity->table_name} ( user_id, component_name, component_action, content, primary_link, date_recorded, item_id, secondary_item_id, hide_sitewide ) VALUES ( %d, %s, %s, %s, %s, FROM_UNIXTIME(%d), %s, %s, %d )", $this->user_id, $this->component_name, $this->component_action, $this->content, $this->primary_link, $this->date_recorded, $this->item_id, $this->secondary_item_id, $this->hide_sitewide ) ) ) {
|
|
do_action( 'bp_activity_after_save', $this );
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
function exists() {
|
|
global $wpdb, $bp;
|
|
|
|
/* This doesn't seem to be working correctly at the moment, so it is disabled [TODO] */
|
|
return false;
|
|
|
|
/* If we have an item id, try and match on that, if not do a content match */
|
|
if ( $this->item_id ) {
|
|
if ( $this->secondary_item_id )
|
|
$secondary_sql = $wpdb->prepare( " AND secondary_item_id = %s", $secondary_item_id );
|
|
|
|
return $wpdb->get_var( $wpdb->prepare( "SELECT id FROM {$bp->activity->table_name} WHERE user_id = %d AND item_id = %s{$secondary_sql} AND component_name = %s AND component_action = %s", $this->user_id, $this->item_id, $this->component_name, $this->component_action ) );
|
|
} else {
|
|
return $wpdb->get_var( $wpdb->prepare( "SELECT id FROM {$bp->activity->table_name} WHERE user_id = %d AND content = %s AND component_name = %s AND component_action = %s", $this->user_id, $this->content, $this->component_name, $this->component_action ) );
|
|
}
|
|
}
|
|
|
|
/* Static Functions */
|
|
|
|
function delete( $item_id, $component_name, $component_action, $user_id = false, $secondary_item_id = false ) {
|
|
global $wpdb, $bp;
|
|
|
|
if ( $secondary_item_id )
|
|
$secondary_sql = $wpdb->prepare( "AND secondary_item_id = %s", $secondary_item_id );
|
|
|
|
if ( $component_action )
|
|
$component_action_sql = $wpdb->prepare( "AND component_action = %s", $component_action );
|
|
|
|
if ( $user_id )
|
|
$user_sql = $wpdb->prepare( "AND user_id = %d", $user_id );
|
|
|
|
return $wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name} WHERE item_id = %s {$secondary_sql} AND component_name = %s {$component_action_sql} {$user_sql}", $item_id, $component_name ) );
|
|
}
|
|
|
|
function delete_by_item_id( $item_id, $component_name, $component_action, $user_id = false, $secondary_item_id = false ) {
|
|
return BP_Activity_Activity::delete( $item_id, $component_name, $component_action, $user_id, $secondary_item_id );
|
|
}
|
|
|
|
function delete_by_activity_id( $activity_id ) {
|
|
global $bp, $wpdb;
|
|
|
|
return $wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name} WHERE id = %d", $activity_id ) );
|
|
}
|
|
|
|
function delete_by_content( $user_id, $content, $component_name, $component_action ) {
|
|
global $bp, $wpdb;
|
|
|
|
return $wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name} WHERE user_id = %d AND content = %s AND component_name = %s AND component_action = %s", $user_id, $content, $component_name, $component_action ) );
|
|
}
|
|
|
|
function delete_for_user_by_component( $user_id, $component_name ) {
|
|
global $bp, $wpdb;
|
|
|
|
return $wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name} WHERE user_id = %d AND component_name = %s", $user_id, $component_name ) );
|
|
}
|
|
|
|
function delete_for_user( $user_id ) {
|
|
global $wpdb, $bp;
|
|
|
|
return $wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name} WHERE user_id = %d", $user_id ) );
|
|
}
|
|
|
|
function get_activity_for_user( $user_id, $max_items, $limit, $page, $filter ) {
|
|
global $wpdb, $bp;
|
|
|
|
$since = strtotime($since);
|
|
|
|
if ( $limit && $page )
|
|
$pag_sql = $wpdb->prepare( "LIMIT %d, %d", intval( ( $page - 1 ) * $limit), intval( $limit ) );
|
|
|
|
if ( $max_items )
|
|
$max_sql = $wpdb->prepare( "LIMIT %d", $max_items );
|
|
|
|
/* Sort out filtering */
|
|
if ( $filter )
|
|
$filter_sql = BP_Activity_Activity::get_filter_sql( $filter );
|
|
|
|
if ( $limit && $page && $max_items )
|
|
$activities = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$bp->activity->table_name} WHERE user_id = %d $filter_sql ORDER BY date_recorded DESC $pag_sql", $user_id ) );
|
|
else
|
|
$activities = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$bp->activity->table_name} WHERE user_id = %d $filter_sql ORDER BY date_recorded DESC $pag_sql $max_sql", $user_id ) );
|
|
|
|
$total_activities = $wpdb->get_var( $wpdb->prepare( "SELECT count(id) FROM {$bp->activity->table_name} WHERE user_id = %d $filter_sql ORDER BY date_recorded DESC $max_sql", $user_id ) );
|
|
|
|
return array( 'activities' => $activities, 'total' => (int)$total_activities );
|
|
}
|
|
|
|
function get_activity_for_friends( $user_id, $max_items, $max_items_per_friend, $limit, $page, $filter ) {
|
|
global $wpdb, $bp;
|
|
|
|
// TODO: Max items per friend not yet implemented.
|
|
|
|
if ( !function_exists('friends_get_friend_user_ids') )
|
|
return false;
|
|
|
|
if ( $limit && $page )
|
|
$pag_sql = $wpdb->prepare( "LIMIT %d, %d", intval( ( $page - 1 ) * $limit), intval( $limit ) );
|
|
|
|
if ( $max_items )
|
|
$max_sql = $wpdb->prepare( "LIMIT %d", $max_items );
|
|
|
|
/* Sort out filtering */
|
|
if ( $filter )
|
|
$filter_sql = BP_Activity_Activity::get_filter_sql( $filter );
|
|
|
|
$friend_ids = friends_get_friend_user_ids( $user_id );
|
|
|
|
if ( !$friend_ids )
|
|
return false;
|
|
|
|
$friend_ids = implode( ',', $friend_ids );
|
|
|
|
if ( $limit && $page && $max_items )
|
|
$activities = $wpdb->get_results( $wpdb->prepare( "SELECT DISTINCT id, user_id, content, primary_link, date_recorded, component_name, component_action FROM {$bp->activity->table_name} WHERE user_id IN ({$friend_ids}) $filter_sql ORDER BY date_recorded DESC $pag_sql" ) );
|
|
else
|
|
$activities = $wpdb->get_results( $wpdb->prepare( "SELECT DISTINCT id, user_id, content, primary_link, date_recorded, component_name, component_action FROM {$bp->activity->table_name} WHERE user_id IN ({$friend_ids}) $filter_sql ORDER BY date_recorded DESC $pag_sql $max_sql" ) );
|
|
|
|
$total_activities = $wpdb->get_var( $wpdb->prepare( "SELECT DISTINCT count(user_id) FROM {$bp->activity->table_name} WHERE user_id IN ({$friend_ids}) $filter_sql ORDER BY date_recorded DESC $max_sql" ) );
|
|
|
|
return array( 'activities' => $activities, 'total' => (int)$total_activities );
|
|
}
|
|
|
|
function get_sitewide_activity( $max, $limit, $page, $filter ) {
|
|
global $wpdb, $bp;
|
|
|
|
if ( $limit && $page )
|
|
$pag_sql = $wpdb->prepare( "LIMIT %d, %d", intval( ( $page - 1 ) * $limit), intval( $limit ) );
|
|
|
|
if ( $max )
|
|
$max_sql = $wpdb->prepare( "LIMIT %d", $max );
|
|
|
|
/* Sort out filtering */
|
|
if ( $filter )
|
|
$filter_sql = BP_Activity_Activity::get_filter_sql( $filter );
|
|
|
|
if ( $limit && $page && $max )
|
|
$activities = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$bp->activity->table_name} WHERE hide_sitewide = 0 $filter_sql ORDER BY date_recorded DESC $pag_sql" ) );
|
|
else
|
|
$activities = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$bp->activity->table_name} WHERE hide_sitewide = 0 $filter_sql ORDER BY date_recorded DESC $pag_sql $max_sql" ) );
|
|
|
|
$total_activities = $wpdb->get_var( $wpdb->prepare( "SELECT count(id) FROM {$bp->activity->table_name} WHERE hide_sitewide = 0 $filter_sql ORDER BY date_recorded DESC $max_sql" ) );
|
|
|
|
return array( 'activities' => $activities, 'total' => (int)$total_activities );
|
|
}
|
|
|
|
function get_recorded_component_names() {
|
|
global $wpdb, $bp;
|
|
|
|
return $wpdb->get_col( $wpdb->prepare( "SELECT DISTINCT component_name FROM {$bp->activity->table_name} ORDER BY component_name ASC" ) );
|
|
}
|
|
|
|
function get_sitewide_items_for_feed( $limit = 35 ) {
|
|
global $wpdb, $bp;
|
|
|
|
$activities = bp_activity_get_sitewide_activity( $limit );
|
|
for ( $i = 0; $i < count($activities); $i++ ) {
|
|
$title = explode( '<span', $activities[$i]['content'] );
|
|
|
|
$activity_feed[$i]['title'] = trim( strip_tags( $title[0] ) );
|
|
$activity_feed[$i]['link'] = $activities[$i]['primary_link'];
|
|
$activity_feed[$i]['description'] = @sprintf( $activities[$i]['content'], '' );
|
|
$activity_feed[$i]['pubdate'] = $activities[$i]['date_recorded'];
|
|
}
|
|
|
|
return $activity_feed;
|
|
}
|
|
|
|
function get_filter_sql( $filter_array ) {
|
|
global $wpdb;
|
|
|
|
if ( !empty( $filter_array['object'] ) ) {
|
|
$object_filter = explode( ',', $filter_array['object'] );
|
|
$object_sql = ' AND ( ';
|
|
|
|
$counter = 1;
|
|
foreach( (array) $object_filter as $object ) {
|
|
$object_sql .= $wpdb->prepare( "component_name = %s", trim( $object ) );
|
|
|
|
if ( $counter != count( $object_filter ) )
|
|
$object_sql .= ' || ';
|
|
|
|
$counter++;
|
|
}
|
|
|
|
$object_sql .= ' )';
|
|
}
|
|
|
|
if ( !empty( $filter_array['action'] ) ) {
|
|
$action_filter = explode( ',', $filter_array['action'] );
|
|
$action_sql = ' AND ( ';
|
|
|
|
$counter = 1;
|
|
foreach( (array) $action_filter as $action ) {
|
|
$action_sql .= $wpdb->prepare( "component_action = %s", trim( $action ) );
|
|
|
|
if ( $counter != count( $action_filter ) )
|
|
$action_sql .= ' || ';
|
|
|
|
$counter++;
|
|
}
|
|
|
|
$action_sql .= ' )';
|
|
}
|
|
|
|
if ( !empty( $filter_array['primary_id'] ) ) {
|
|
$pid_filter = explode( ',', $filter_array['primary_id'] );
|
|
$pid_sql = ' AND ( ';
|
|
|
|
$counter = 1;
|
|
foreach( (array) $pid_filter as $pid ) {
|
|
$pid_sql .= $wpdb->prepare( "item_id = %s", trim( $pid ) );
|
|
|
|
if ( $counter != count( $pid_filter ) )
|
|
$pid_sql .= ' || ';
|
|
|
|
$counter++;
|
|
}
|
|
|
|
$pid_sql .= ' )';
|
|
}
|
|
|
|
if ( !empty( $filter_array['secondary_id'] ) ) {
|
|
$sid_filter = explode( ',', $filter_array['secondary_id'] );
|
|
$sid_sql = ' AND ( ';
|
|
|
|
$counter = 1;
|
|
foreach( (array) $sid_filter as $sid ) {
|
|
$sid_sql .= $wpdb->prepare( "secondary_item_id = %s", trim( $sid ) );
|
|
|
|
if ( $counter != count( $sid_filter ) )
|
|
$sid_sql .= ' || ';
|
|
|
|
$counter++;
|
|
}
|
|
|
|
$sid_sql .= ' )';
|
|
}
|
|
|
|
return $object_sql . $action_sql . $pid_sql . $sid_sql;
|
|
}
|
|
|
|
function get_last_updated() {
|
|
global $bp, $wpdb;
|
|
|
|
return $wpdb->get_var( $wpdb->prepare( "SELECT date_recorded FROM {$bp->activity->table_name} ORDER BY date_recorded ASC LIMIT 1" ) );
|
|
}
|
|
|
|
function check_exists_by_content( $content ) {
|
|
global $wpdb, $bp;
|
|
|
|
return $wpdb->get_var( $wpdb->prepare( "SELECT id FROM {$bp->activity->table_name} WHERE content = %s", $content ) );
|
|
}
|
|
}
|
|
|
|
?>
|
