/home/edulekha/studygroup.edulekha.com/ow_plugins/newsfeed/bol/action_set_dao.php
<?php
/**
* This software is intended for use with Oxwall Free Community Software http://www.oxwall.org/ and is
* licensed under The BSD license.
* ---
* Copyright (c) 2011, Oxwall Foundation
* All rights reserved.
* Redistribution and use in source and binary forms, with or without modification, are permitted provided that the
* following conditions are met:
*
* - Redistributions of source code must retain the above copyright notice, this list of conditions and
* the following disclaimer.
*
* - Redistributions in binary form must reproduce the above copyright notice, this list of conditions and
* the following disclaimer in the documentation and/or other materials provided with the distribution.
*
* - Neither the name of the Oxwall Foundation nor the names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
* INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
* AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
/**
* Data Access Object for `newsfeed_action_set` table.
*
* @author Podyachev Evgeny <joker.OW2@gmail.com>
* @package ow_plugins.newsfeed.bol
* @since 1.0
*/
class NEWSFEED_BOL_ActionSetDao extends OW_BaseDao
{
/**
* Singleton instance.
*
* @var NEWSFEED_BOL_ActionSetDao
*/
private static $classInstance;
/**
* Returns an instance of class (singleton pattern implementation).
*
* @return NEWSFEED_BOL_ActionSetDao
*/
public static function getInstance()
{
if ( self::$classInstance === null )
{
self::$classInstance = new self();
}
return self::$classInstance;
}
/**
* @see OW_BaseDao::getDtoClassName()
*
*/
public function getDtoClassName()
{
return 'NEWSFEED_BOL_ActionSetDao';
}
/**
* @see OW_BaseDao::getTableName()
*
*/
public function getTableName()
{
return OW_DB_PREFIX . 'newsfeed_action_set';
}
/**
* @param int $userId
* @param int $startTime
*/
public function generateActionSet( $userId, $startTime = null )
{
$followDao = NEWSFEED_BOL_FollowDao::getInstance();
$actionFeedDao = NEWSFEED_BOL_ActionFeedDao::getInstance();
$activityDao = NEWSFEED_BOL_ActivityDao::getInstance();
/*$query = ' REPLACE INTO '. $this->getTableName() . ' ( `actionId`, `userId`, `timestamp` )
SELECT DISTINCT sactivity.actionId, :u as `userId`, :st FROM ' . $activityDao->getTableName() . ' sactivity
INNER JOIN ' . $actionFeedDao->getTableName() . ' saction_feed ON sactivity.id=saction_feed.activityId
INNER JOIN ' . $followDao->getTableName() . ' sfollow ON saction_feed.feedId = sfollow.feedId AND saction_feed.feedType = sfollow.feedType
WHERE sactivity.status=:s AND sactivity.activityType=:ac AND sactivity.timeStamp<:st AND
sfollow.userId=:u AND
( sactivity.privacy=sfollow.permission OR sactivity.privacy=:peb)
AND sactivity.visibility & :vf
UNION
SELECT DISTINCT sactivity.actionId, :u as `userId`, :st FROM ' . $activityDao->getTableName() . ' sactivity
INNER JOIN ' . $actionFeedDao->getTableName() . ' saction_feed ON sactivity.id=saction_feed.activityId
WHERE sactivity.status=:s AND sactivity.activityType=:ac AND sactivity.timeStamp<:st AND
saction_feed.feedId=:u AND saction_feed.feedType="user" AND sactivity.visibility & :vfeed
UNION
SELECT DISTINCT sactivity.actionId, :u as `userId`, :st FROM ' . $activityDao->getTableName() . ' sactivity
WHERE sactivity.status=:s AND sactivity.timeStamp<:st AND
( sactivity.userId=:u AND sactivity.visibility & :va )';*/
$query = ' REPLACE INTO '. $this->getTableName() . ' ( `actionId`, `userId`, `timestamp` )
SELECT DISTINCT sactivity.actionId, :u as `userId`, :st FROM ' . $activityDao->getTableName() . ' sactivity
INNER JOIN ' . $actionFeedDao->getTableName() . ' saction_feed ON sactivity.id=saction_feed.activityId
INNER JOIN ' . $followDao->getTableName() . ' sfollow ON saction_feed.feedId = sfollow.feedId AND saction_feed.feedType = sfollow.feedType
WHERE sactivity.status=:s AND sactivity.activityType=:ac AND sactivity.timeStamp<:st AND
sfollow.userId=:u AND
( sactivity.privacy=sfollow.permission OR sactivity.privacy=:peb)
AND sactivity.visibility & :vf
UNION
SELECT DISTINCT sactivity.actionId, :u as `userId`, :st FROM ' . $activityDao->getTableName() . ' sactivity
INNER JOIN ' . $activityDao->getTableName() . ' cactivity ON sactivity.actionId = cactivity.actionId
WHERE sactivity.status=:s AND sactivity.timeStamp<:st
AND cactivity.activityType=:ac
AND cactivity.visibility & :va
AND sactivity.userId=:u
AND sactivity.visibility & :va
AND cactivity.status=:s
UNION
SELECT DISTINCT sactivity.actionId, :u as `userId`, :st FROM ' . $activityDao->getTableName() . ' sactivity
INNER JOIN ' . $actionFeedDao->getTableName() . ' saction_feed ON sactivity.id=saction_feed.activityId
INNER JOIN ' . $activityDao->getTableName() . ' cactivity ON sactivity.actionId = cactivity.actionId
WHERE sactivity.status=:s AND sactivity.timeStamp<:st
AND cactivity.activityType=:ac
AND sactivity.visibility & :vfeed
AND saction_feed.feedId=:u
AND saction_feed.feedType="user"
AND cactivity.status=:s';
$this->dbo->update($query, array(
'u' => (int)$userId,
'va' => NEWSFEED_BOL_Service::VISIBILITY_AUTHOR,
'vf' => NEWSFEED_BOL_Service::VISIBILITY_FOLLOW,
'vfeed' => NEWSFEED_BOL_Service::VISIBILITY_FEED,
's' => NEWSFEED_BOL_Service::ACTION_STATUS_ACTIVE,
'st' => empty($startTime) ? time() : $startTime,
'peb' => NEWSFEED_BOL_Service::PRIVACY_EVERYBODY,
'ac' => NEWSFEED_BOL_Service::SYSTEM_ACTIVITY_CREATE,
'as' => NEWSFEED_BOL_Service::SYSTEM_ACTIVITY_SUBSCRIBE
));
}
/*
* @param int $userId
*/
public function deleteActionSetUserId( $userId )
{
$ex = new OW_Example();
$ex->andFieldEqual('userId', (int)$userId);
$this->deleteByExample($ex);
}
/**
* @param int $startTime
*/
public function deleteActionSetByTimestamp( $timestamp )
{
$ex = new OW_Example();
$ex->andFieldLessOrEqual('timestamp', (int)$timestamp);
$this->deleteByExample($ex);
}
}