mirror of
https://github.com/EGroupware/egroupware.git
synced 2024-11-27 18:33:39 +01:00
0b96631cd4
we only recognice recuring events which start before or in the current timerange and end in or after it or have no end-date. --> give an error message, as it is a debuging/support nightmare, if this gets silently fixed when reading events. No idea how this situation (exceptions before startdate) can be created anyway.
2082 lines
68 KiB
PHP
2082 lines
68 KiB
PHP
<?php
|
|
/**
|
|
* eGroupWare - Calendar's storage-object
|
|
*
|
|
* @link http://www.egroupware.org
|
|
* @package calendar
|
|
* @author Ralf Becker <RalfBecker-AT-outdoor-training.de>
|
|
* @author Christian Binder <christian-AT-jaytraxx.de>
|
|
* @author Joerg Lehrke <jlehrke@noc.de>
|
|
* @copyright (c) 2005-11 by RalfBecker-At-outdoor-training.de
|
|
* @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
|
|
* @version $Id$
|
|
*/
|
|
|
|
/**
|
|
* some necessary defines used by the calendar
|
|
*/
|
|
if(!extension_loaded('mcal'))
|
|
{
|
|
define('MCAL_RECUR_NONE',0);
|
|
define('MCAL_RECUR_DAILY',1);
|
|
define('MCAL_RECUR_WEEKLY',2);
|
|
define('MCAL_RECUR_MONTHLY_MDAY',3);
|
|
define('MCAL_RECUR_MONTHLY_WDAY',4);
|
|
define('MCAL_RECUR_YEARLY',5);
|
|
define('MCAL_RECUR_SECONDLY',6);
|
|
define('MCAL_RECUR_MINUTELY',7);
|
|
define('MCAL_RECUR_HOURLY',8);
|
|
|
|
define('MCAL_M_SUNDAY',1);
|
|
define('MCAL_M_MONDAY',2);
|
|
define('MCAL_M_TUESDAY',4);
|
|
define('MCAL_M_WEDNESDAY',8);
|
|
define('MCAL_M_THURSDAY',16);
|
|
define('MCAL_M_FRIDAY',32);
|
|
define('MCAL_M_SATURDAY',64);
|
|
|
|
define('MCAL_M_WEEKDAYS',62);
|
|
define('MCAL_M_WEEKEND',65);
|
|
define('MCAL_M_ALLDAYS',127);
|
|
}
|
|
|
|
define('REJECTED',0);
|
|
define('NO_RESPONSE',1);
|
|
define('TENTATIVE',2);
|
|
define('ACCEPTED',3);
|
|
define('DELEGATED',4);
|
|
|
|
define('HOUR_s',60*60);
|
|
define('DAY_s',24*HOUR_s);
|
|
define('WEEK_s',7*DAY_s);
|
|
|
|
/**
|
|
* Class to store all calendar data (storage object)
|
|
*
|
|
* Tables used by socal:
|
|
* - egw_cal: general calendar data: cal_id, title, describtion, locations, ...
|
|
* - egw_cal_dates: start- and enddates (multiple entry per cal_id for recuring events!)
|
|
* - egw_cal_user: participant info including status (multiple entries per cal_id AND startdate for recuring events)
|
|
* - egw_cal_repeats: recur-data: type, optional enddate, etc.
|
|
* - egw_cal_extra: custom fields (multiple entries per cal_id possible)
|
|
*
|
|
* The new UI, BO and SO classes have a strikt definition, in which time-zone they operate:
|
|
* UI only operates in user-time, so there have to be no conversation at all !!!
|
|
* BO's functions take and return user-time only (!), they convert internaly everything to servertime, because
|
|
* SO operates only on server-time
|
|
*/
|
|
class calendar_so
|
|
{
|
|
/**
|
|
* name of the main calendar table and prefix for all other calendar tables
|
|
*/
|
|
var $cal_table = 'egw_cal';
|
|
var $extra_table,$repeats_table,$user_table,$dates_table,$all_tables;
|
|
|
|
/**
|
|
* reference to global db-object
|
|
*
|
|
* @var egw_db
|
|
*/
|
|
var $db;
|
|
/**
|
|
* instance of the async object
|
|
*
|
|
* @var asyncservice
|
|
*/
|
|
var $async;
|
|
/**
|
|
* SQL to sort by status U, T, A, R
|
|
*
|
|
*/
|
|
const STATUS_SORT = "CASE cal_status WHEN 'U' THEN 1 WHEN 'T' THEN 2 WHEN 'A' THEN 3 WHEN 'R' THEN 4 ELSE 0 END ASC";
|
|
|
|
/**
|
|
* Cached timezone data
|
|
*
|
|
* @var array id => data
|
|
*/
|
|
protected static $tz_cache = array();
|
|
|
|
|
|
/**
|
|
* Constructor of the socal class
|
|
*/
|
|
function __construct()
|
|
{
|
|
$this->async = $GLOBALS['egw']->asyncservice;
|
|
$this->db = $GLOBALS['egw']->db;
|
|
|
|
$this->all_tables = array($this->cal_table);
|
|
foreach(array('extra','repeats','user','dates') as $name)
|
|
{
|
|
$vname = $name.'_table';
|
|
$this->all_tables[] = $this->$vname = $this->cal_table.'_'.$name;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* reads one or more calendar entries
|
|
*
|
|
* All times (start, end and modified) are returned as timesstamps in servertime!
|
|
*
|
|
* @param int|array|string $ids id or array of id's of the entries to read, or string with a single uid
|
|
* @param int $recur_date=0 if set read the next recurrence at or after the timestamp, default 0 = read the initital one
|
|
* @return array|boolean array with id => data pairs or false if entry not found
|
|
*/
|
|
function read($ids,$recur_date=0)
|
|
{
|
|
if (isset($GLOBALS['egw_info']['user']['preferences']['syncml']['minimum_uid_length']))
|
|
{
|
|
$minimum_uid_length = $GLOBALS['egw_info']['user']['preferences']['syncml']['minimum_uid_length'];
|
|
}
|
|
else
|
|
{
|
|
$minimum_uid_length = 8;
|
|
}
|
|
|
|
//echo "<p>socal::read(".print_r($ids,true).",$recur_date)<br />\n".function_backtrace()."<p>\n";
|
|
|
|
$table_def = $this->db->get_table_definitions('calendar',$this->cal_table);
|
|
$group_by_cols = $this->cal_table.'.'.implode(','.$this->cal_table.'.',array_keys($table_def['fd']));
|
|
$table_def = $this->db->get_table_definitions('calendar',$this->repeats_table);
|
|
$group_by_cols .= ','.$this->repeats_table.'.'.implode(','.$this->repeats_table.'.',array_keys($table_def['fd']));
|
|
|
|
$where = array();
|
|
if (is_array($ids))
|
|
{
|
|
array_walk($ids,create_function('&$val,$key','$val = (int) $val;'));
|
|
|
|
$where[] = $this->cal_table.'.cal_id IN ('.implode(',',$ids).')';
|
|
}
|
|
elseif (is_numeric($ids))
|
|
{
|
|
$where[] = $this->cal_table.'.cal_id = '.(int) $ids;
|
|
}
|
|
else
|
|
{
|
|
// We want only the parents to match
|
|
$where['cal_uid'] = $ids;
|
|
$where['cal_reference'] = 0;
|
|
$where['cal_recurrence'] = 0;
|
|
}
|
|
if ((int) $recur_date)
|
|
{
|
|
$where[] = 'cal_start >= '.(int)$recur_date;
|
|
}
|
|
$events = array();
|
|
foreach($this->db->select($this->cal_table,"$this->repeats_table.*,$this->cal_table.*,MIN(cal_start) AS cal_start,MIN(cal_end) AS cal_end",
|
|
$where,__LINE__,__FILE__,false,'GROUP BY '.$group_by_cols,'calendar',0,
|
|
",$this->dates_table LEFT JOIN $this->repeats_table ON $this->dates_table.cal_id=$this->repeats_table.cal_id".
|
|
" WHERE $this->cal_table.cal_id=$this->dates_table.cal_id") as $row)
|
|
{
|
|
$row['recur_exception'] = $row['recur_exception'] ? explode(',',$row['recur_exception']) : array();
|
|
if (!$row['recur_type']) $row['recur_type'] = MCAL_RECUR_NONE;
|
|
$row['alarm'] = array();
|
|
$events[$row['cal_id']] = egw_db::strip_array_keys($row,'cal_');
|
|
|
|
// if a uid was supplied, convert it for the further code to an id
|
|
if (!is_array($ids) && !is_numeric($ids)) $ids = $row['cal_id'];
|
|
}
|
|
if (!$events) return false;
|
|
|
|
foreach ($events as &$event)
|
|
{
|
|
if (!isset($event['uid']) || strlen($event['uid']) < $minimum_uid_length)
|
|
{
|
|
// event (without uid), not strong enough uid => create new uid
|
|
$event['uid'] = $GLOBALS['egw']->common->generate_uid('calendar',$event['id']);
|
|
$this->db->update($this->cal_table, array('cal_uid' => $event['uid']),
|
|
array('cal_id' => $event['id']),__LINE__,__FILE__,'calendar');
|
|
}
|
|
if ((int) $recur_date == 0 &&
|
|
$event['recur_type'] != MCAL_RECUR_NONE &&
|
|
!empty($event['recur_exception']))
|
|
{
|
|
sort($event['recur_exception']);
|
|
if ($event['recur_exception'][0] < $event['start'])
|
|
{
|
|
// leading exceptions => move start and end
|
|
$event['end'] -= $event['start'] - $event['recur_exception'][0];
|
|
$event['start'] = $event['recur_exception'][0];
|
|
}
|
|
}
|
|
}
|
|
|
|
// check if we have a real recurance, if not set $recur_date=0
|
|
if (is_array($ids) || $events[(int)$ids]['recur_type'] == MCAL_RECUR_NONE)
|
|
{
|
|
$recur_date = 0;
|
|
}
|
|
else // adjust the given recurance to the real time, it can be a date without time(!)
|
|
{
|
|
if ($recur_date)
|
|
{
|
|
// also remember recur_date, maybe we need it later, duno now
|
|
$recur_date = array(0,$events[$ids]['recur_date'] = $events[$ids]['start']);
|
|
}
|
|
}
|
|
|
|
// participants, if a recur_date give, we read that recurance, plus the one users from the default entry with recur_date=0
|
|
// sorting by cal_recur_date ASC makes sure recurence status always overwrites series status
|
|
foreach($this->db->select($this->user_table,'*',array(
|
|
'cal_id' => $ids,
|
|
'cal_recur_date' => $recur_date,
|
|
),__LINE__,__FILE__,false,'ORDER BY cal_user_type DESC,cal_recur_date ASC,'.self::STATUS_SORT,'calendar') as $row) // DESC puts users before resources and contacts
|
|
{
|
|
// combine all participant data in uid and status values
|
|
$uid = self::combine_user($row['cal_user_type'],$row['cal_user_id']);
|
|
$status = self::combine_status($row['cal_status'],$row['cal_quantity'],$row['cal_role']);
|
|
|
|
$events[$row['cal_id']]['participants'][$uid] = $status;
|
|
$events[$row['cal_id']]['participant_types'][$row['cal_user_type']][$row['cal_user_id']] = $status;
|
|
}
|
|
|
|
// custom fields
|
|
foreach($this->db->select($this->extra_table,'*',array('cal_id'=>$ids),__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
$events[$row['cal_id']]['#'.$row['cal_extra_name']] = $row['cal_extra_value'];
|
|
}
|
|
|
|
// alarms, atm. we read all alarms in the system, as this can be done in a single query
|
|
foreach((array)$this->async->read('cal'.(is_array($ids) ? '' : ':'.(int)$ids).':%') as $id => $job)
|
|
{
|
|
list(,$cal_id) = explode(':',$id);
|
|
if (!isset($events[$cal_id])) continue; // not needed
|
|
|
|
$alarm = $job['data']; // text, enabled
|
|
$alarm['id'] = $id;
|
|
$alarm['time'] = $job['next'];
|
|
|
|
$events[$cal_id]['alarm'][$id] = $alarm;
|
|
}
|
|
//echo "<p>socal::read(".print_r($ids,true).")=<pre>".print_r($events,true)."</pre>\n";
|
|
return $events;
|
|
}
|
|
|
|
/**
|
|
* Get maximum modification time of participant data of given event(s)
|
|
*
|
|
* This includes ALL recurences of an event series
|
|
*
|
|
* @param int|array $ids one or multiple cal_id's
|
|
* @param booelan $return_maximum=false if true return only the maximum, even for multiple ids
|
|
* @return int|array (array of) modification timestamp(s)
|
|
*/
|
|
function max_user_modified($ids, $return_maximum=false)
|
|
{
|
|
if (!is_array($ids) || count($ids) == 1) $return_maximum = true;
|
|
|
|
if ($return_maximum)
|
|
{
|
|
if (($etags = $this->db->select($this->user_table,'MAX(cal_user_modified)',array(
|
|
'cal_id' => $ids,
|
|
),__LINE__,__FILE__,false,'','calendar')->fetchColumn()))
|
|
{
|
|
$etags = $this->db->from_timestamp($etags);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$etags = array();
|
|
foreach($this->db->select($this->user_table,'cal_id,MAX(cal_user_modified) AS user_etag',array(
|
|
'cal_id' => $ids,
|
|
),__LINE__,__FILE__,false,'GROUP BY cal_id','calendar') as $row)
|
|
{
|
|
$etags[$row['cal_id']] = $this->db->from_timestamp($row['user_etag']);
|
|
}
|
|
}
|
|
//echo "<p>".__METHOD__.'('.array2string($ids).','.array($return_maximum).') = '.array2string($etags)."</p>\n";
|
|
//error_log(__METHOD__.'('.array2string($ids).','.array2string($return_maximum).') = '.array2string($etags));
|
|
return $etags;
|
|
}
|
|
|
|
/**
|
|
* Get maximum modification time of events for given participants and optional owned by them
|
|
*
|
|
* This includes ALL recurences of an event series
|
|
*
|
|
* @param int|array $users one or mulitple calendar users
|
|
* @param booelan $owner_too=false if true return also events owned by given users
|
|
* @return int maximum modification timestamp
|
|
*/
|
|
function get_ctag($users, $owner_too=false)
|
|
{
|
|
$where = array(
|
|
'cal_user_type' => 'u',
|
|
'cal_user_id' => $users,
|
|
);
|
|
if ($owner_too)
|
|
{
|
|
// owner can only by users, no groups
|
|
foreach($users as $key => $user)
|
|
{
|
|
if ($user < 0) unset($users[$key]);
|
|
}
|
|
$where = $this->db->expression($this->user_table, '(', $where, ' OR ').
|
|
$this->db->expression($this->cal_table, array(
|
|
'cal_owner' => $users,
|
|
),')');
|
|
}
|
|
if (($data = $this->db->select($this->user_table,array(
|
|
'MAX(cal_user_modified) AS max_user_modified',
|
|
'MAX(cal_modified) AS max_modified',
|
|
),$where,__LINE__,__FILE__,false,'','calendar',0,'JOIN egw_cal ON egw_cal.cal_id=egw_cal_user.cal_id')->fetch()))
|
|
{
|
|
$data = max($this->db->from_timestamp($data['max_user_modified']),$data['max_modified']);
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* generate SQL to filter after a given category (incl. subcategories)
|
|
*
|
|
* @param array|int $cat_id cat-id or array of cat-ids, or !$cat_id for none
|
|
* @return string SQL to include in the query
|
|
*/
|
|
function cat_filter($cat_id)
|
|
{
|
|
$sql = '';
|
|
if ($cat_id)
|
|
{
|
|
$cats = $GLOBALS['egw']->categories->return_all_children($cat_id);
|
|
array_walk($cats,create_function('&$val,$key','$val = (int) $val;'));
|
|
|
|
$sql = '(cal_category'.(count($cats) > 1 ? " IN ('".implode("','",$cats)."')" : '='.$this->db->quote((int)$cat_id));
|
|
foreach($cats as $cat)
|
|
{
|
|
$sql .= ' OR '.$this->db->concat("','",'cal_category',"','").' LIKE '.$this->db->quote('%,'.$cat.',%');
|
|
}
|
|
$sql .= ') ';
|
|
}
|
|
return $sql;
|
|
}
|
|
|
|
/**
|
|
* Searches / lists calendar entries, including repeating ones
|
|
*
|
|
* @param int $start startdate of the search/list (servertime)
|
|
* @param int $end enddate of the search/list (servertime)
|
|
* @param int|array $users user-id or array of user-id's, !$users means all entries regardless of users
|
|
* @param int|array $cat_id=0 mixed category-id or array of cat-id's (incl. all sub-categories), default 0 = all
|
|
* @param string $filter='all' string filter-name: all (not rejected), accepted, unknown, tentative, rejected or hideprivate (handled elsewhere!)
|
|
* @param string $query='' pattern so search for, if unset or empty all matching entries are returned (no search)
|
|
* Please Note: a search never returns repeating events more then once AND does not honor start+end date !!!
|
|
* @param int|boolean $offset=False offset for a limited query or False (default)
|
|
* @param int $num_rows=0 number of rows to return if offset set, default 0 = use default in user prefs
|
|
* @param string $order='cal_start' column-names plus optional DESC|ASC separted by comma
|
|
* @param string $sql_filter='' sql to be and'ed into query (fully quoted)
|
|
* @param string|array $_cols=null what to select, default "$this->repeats_table.*,$this->cal_table.*,cal_start,cal_end,cal_recur_date",
|
|
* if specified and not false an iterator for the rows is returned
|
|
* @param string $append='' SQL to append to the query before $order, eg. for a GROUP BY clause
|
|
* @param array $cfs=null custom fields to query, null = none, array() = all, or array with cfs names
|
|
* @return array of cal_ids, or false if error in the parameters
|
|
*
|
|
* ToDo: search custom-fields too
|
|
*/
|
|
function &search($start,$end,$users,$cat_id=0,$filter='all',$query='',$offset=False,$num_rows=0,$order='cal_start',$sql_filter='',$_cols=null,$append='',$cfs=null)
|
|
{
|
|
//echo '<p>'.__METHOD__.'('.($start ? date('Y-m-d H:i',$start) : '').','.($end ? date('Y-m-d H:i',$end) : '').','.array2string($users).','.array2string($cat_id).",'$filter',".array2string($query).",$offset,$num_rows,$order,$show_rejected,".array2string($_cols).",$append,".array2string($cfs).")</p>\n";
|
|
|
|
$cols = !is_null($_cols) ? $_cols : "$this->repeats_table.*,$this->cal_table.*,cal_start,cal_end,cal_recur_date";
|
|
|
|
$where = array();
|
|
if (is_array($query))
|
|
{
|
|
$where = $query;
|
|
}
|
|
elseif ($query)
|
|
{
|
|
foreach(array('cal_title','cal_description','cal_location') as $col)
|
|
{
|
|
$to_or[] = $col.' '.$this->db->capabilities[egw_db::CAPABILITY_CASE_INSENSITIV_LIKE].' '.$this->db->quote('%'.$query.'%');
|
|
}
|
|
$where[] = '('.implode(' OR ',$to_or).')';
|
|
|
|
// Searching - restrict private to own or private grant
|
|
if (!isset($params['private_grants']))
|
|
{
|
|
$params['private_grants'] = $GLOBALS['egw']->acl->get_ids_for_location($GLOBALS['egw_info']['user']['account_id'], EGW_ACL_PRIVATE, 'calendar');
|
|
$params['private_grants'][] = $GLOBALS['egw_info']['user']['account_id']; // db query does NOT return current user
|
|
}
|
|
$private_filter = '(cal_public=1 OR cal_public=0 AND '.$this->db->expression($this->cal_table, array('cal_owner' => $params['private_grants'])) . ')';
|
|
$where[] = $private_filter;
|
|
}
|
|
if (!empty($sql_filter) && is_string($sql_filter))
|
|
{
|
|
$where[] = $sql_filter;
|
|
}
|
|
if ($users)
|
|
{
|
|
$users_by_type = array();
|
|
foreach((array)$users as $user)
|
|
{
|
|
if (is_numeric($user))
|
|
{
|
|
$users_by_type['u'][] = (int) $user;
|
|
}
|
|
elseif (is_numeric(substr($user,1)))
|
|
{
|
|
$users_by_type[$user[0]][] = (int) substr($user,1);
|
|
}
|
|
}
|
|
$to_or = $user_or = $owner_or = array();
|
|
$useUnionQuery = $this->db->capabilities['distinct_on_text'] && $this->db->capabilities['union'];
|
|
$table_def = $this->db->get_table_definitions('calendar',$this->user_table);
|
|
foreach($users_by_type as $type => $ids)
|
|
{
|
|
// when we are able to use Union Querys, we do not OR our query, we save the needed parts for later construction of the union
|
|
if ($useUnionQuery)
|
|
{
|
|
$user_or[] = $this->db->expression($table_def,array(
|
|
'cal_user_type' => $type,
|
|
'cal_user_id' => $ids,
|
|
));
|
|
if ($type == 'u' && ($filter == 'owner'))
|
|
{
|
|
$cal_table_def = $this->db->get_table_definitions('calendar',$this->cal_table);
|
|
$owner_or[] = $this->db->expression($cal_table_def,array('cal_owner' => $ids));
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$to_or[] = $this->db->expression($table_def,array(
|
|
'cal_user_type' => $type,
|
|
'cal_user_id' => $ids,
|
|
));
|
|
if ($type == 'u' && ($filter == 'owner'))
|
|
{
|
|
$cal_table_def = $this->db->get_table_definitions('calendar',$this->cal_table);
|
|
$to_or[] = $this->db->expression($cal_table_def,array('cal_owner' => $ids));
|
|
}
|
|
}
|
|
}
|
|
// this is only used, when we cannot use UNIONS
|
|
if (!$useUnionQuery) $where[] = '('.implode(' OR ',$to_or).')';
|
|
|
|
switch($filter)
|
|
{
|
|
case 'showonlypublic':
|
|
$where[] = "cal_public=1";
|
|
$where[] = "cal_status != 'R'"; break;
|
|
case 'unknown':
|
|
$where[] = "cal_status='U'"; break;
|
|
case 'accepted':
|
|
$where[] = "cal_status='A'"; break;
|
|
case 'tentative':
|
|
$where[] = "cal_status='T'"; break;
|
|
case 'rejected':
|
|
$where[] = "cal_status='R'"; break;
|
|
case 'delegated':
|
|
$where[] = "cal_status='D'"; break;
|
|
case 'all':
|
|
case 'owner':
|
|
break;
|
|
default:
|
|
//if (!$show_rejected) // not longer used
|
|
$where[] = "cal_status != 'R'";
|
|
break;
|
|
}
|
|
}
|
|
if ($cat_id)
|
|
{
|
|
$where[] = $this->cat_filter($cat_id);
|
|
}
|
|
if ($start) $where[] = (int)$start.' < cal_end';
|
|
if ($end) $where[] = 'cal_start < '.(int)$end;
|
|
|
|
if (!preg_match('/^[a-z_ ,]+$/i',$order)) $order = 'cal_start'; // gard against SQL injection
|
|
|
|
if ($useUnionQuery)
|
|
{
|
|
// changed the original OR in the query into a union, to speed up the query execution under MySQL 5
|
|
$select = array(
|
|
'table' => $this->cal_table,
|
|
'join' => "JOIN $this->dates_table ON $this->cal_table.cal_id=$this->dates_table.cal_id JOIN $this->user_table ON $this->cal_table.cal_id=$this->user_table.cal_id LEFT JOIN $this->repeats_table ON $this->cal_table.cal_id=$this->repeats_table.cal_id",
|
|
'cols' => $cols,
|
|
'where' => $where,
|
|
'app' => 'calendar',
|
|
'append'=> $append,
|
|
);
|
|
// we check if there are parts to use for the construction of our UNION query,
|
|
// as replace the OR by construction of a suitable UNION for performance reasons
|
|
if (!empty($owner_or)||!empty($user_or))
|
|
{
|
|
if (!empty($owner_or) && !empty($user_or))
|
|
{
|
|
// if the query is to be filtered by owner OR user we need 4 selects for the union
|
|
//_debug_array($owner_or);
|
|
$selects = array();
|
|
foreach(array_keys($user_or) as $key)
|
|
{
|
|
$selects[] = $select;
|
|
$selects[count($selects)-1]['where'][] = $user_or[$key];
|
|
$selects[count($selects)-1]['where'][] = 'recur_type IS NULL AND cal_recur_date=0';
|
|
$selects[] = $select;
|
|
$selects[count($selects)-1]['where'][] = $user_or[$key];
|
|
$selects[count($selects)-1]['where'][] = 'cal_recur_date=cal_start';
|
|
}
|
|
$selects[] = $select;
|
|
$selects[count($selects)-1]['where'][] = $owner_or;
|
|
$selects[count($selects)-1]['where'][] = 'recur_type IS NULL AND cal_recur_date=0';
|
|
$selects[] = $select;
|
|
$selects[count($selects)-1]['where'][] = $owner_or;
|
|
$selects[count($selects)-1]['where'][] = 'cal_recur_date=cal_start';
|
|
}
|
|
else
|
|
{
|
|
// if the query is to be filtered only by user we need 2 selects for the union
|
|
$selects = array();
|
|
foreach(array_keys($user_or) as $key)
|
|
{
|
|
$selects[] = $select;
|
|
$selects[count($selects)-1]['where'][] = $user_or[$key];
|
|
$selects[count($selects)-1]['where'][] = 'recur_type IS NULL AND cal_recur_date=0';
|
|
$selects[] = $select;
|
|
$selects[count($selects)-1]['where'][] = $user_or[$key];
|
|
$selects[count($selects)-1]['where'][] = 'cal_recur_date=cal_start';
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// if the query is to be filtered by neither by user nor owner (should not happen?) we need 2 selects for the union
|
|
$selects = array($select,$select);
|
|
$selects[0]['where'][] = 'recur_type IS NULL AND cal_recur_date=0';
|
|
$selects[1]['where'][] = 'cal_recur_date=cal_start';
|
|
}
|
|
if (is_numeric($offset)) // get the total too
|
|
{
|
|
// we only select cal_table.cal_id (and not cal_table.*) to be able to use DISTINCT (eg. MsSQL does not allow it for text-columns)
|
|
$countSelects = count($selects);
|
|
foreach(array_keys($selects) as $key)
|
|
{
|
|
$selects[$key]['cols'] = "DISTINCT $this->repeats_table.*,$this->cal_table.cal_id,cal_start,cal_end,cal_recur_date";
|
|
//$selects[0]['cols'] = $selects[1]['cols'] = "DISTINCT $this->repeats_table.*,$this->cal_table.cal_id,cal_start,cal_end,cal_recur_date";
|
|
}
|
|
|
|
$this->total = $this->db->union($selects,__LINE__,__FILE__)->NumRows();
|
|
$i = 0;
|
|
foreach(array_keys($selects) as $key)
|
|
{
|
|
if ($i >= $countSelects) continue;
|
|
$i++;
|
|
$selects[$key]['cols'] = $select['cols']; // restore the original cols
|
|
//$selects[0]['cols'] = $selects[1]['cols'] = $select['cols']; // restore the original cols
|
|
}
|
|
$i = 0;
|
|
$selections = array();
|
|
foreach(array_keys($selects) as $key)
|
|
{
|
|
if ($i >= $countSelects) continue;
|
|
$i++;
|
|
$selections[] = $selects[$key];
|
|
}
|
|
|
|
$selects = $selections;
|
|
}
|
|
// error_log("calendar_so_search:\n" . print_r($selects, true));
|
|
$rs = $this->db->union($selects,__LINE__,__FILE__,$order,$offset,$num_rows);
|
|
}
|
|
else // MsSQL oder MySQL 3.23
|
|
{
|
|
$where[] = '(recur_type IS NULL AND cal_recur_date=0 OR cal_recur_date=cal_start)';
|
|
|
|
//_debug_array($where);
|
|
if (is_numeric($offset)) // get the total too
|
|
{
|
|
// we only select cal_table.cal_id (and not cal_table.*) to be able to use DISTINCT (eg. MsSQL does not allow it for text-columns)
|
|
$this->total = $this->db->select($this->cal_table,"DISTINCT $this->repeats_table.*,$this->cal_table.cal_id,cal_start,cal_end,cal_recur_date",
|
|
$where,__LINE__,__FILE__,false,'','calendar',0,
|
|
"JOIN $this->dates_table ON $this->cal_table.cal_id=$this->dates_table.cal_id JOIN $this->user_table ON $this->cal_table.cal_id=$this->user_table.cal_id LEFT JOIN $this->repeats_table ON $this->cal_table.cal_id=$this->repeats_table.cal_id")->NumRows();
|
|
}
|
|
$rs = $this->db->select($this->cal_table,($this->db->capabilities['distinct_on_text'] ? 'DISTINCT ' : '').$cols,
|
|
$where,__LINE__,__FILE__,$offset,$append.' ORDER BY '.$order,'calendar',$num_rows,
|
|
"JOIN $this->dates_table ON $this->cal_table.cal_id=$this->dates_table.cal_id JOIN $this->user_table ON $this->cal_table.cal_id=$this->user_table.cal_id LEFT JOIN $this->repeats_table ON $this->cal_table.cal_id=$this->repeats_table.cal_id");
|
|
}
|
|
if (!is_null($_cols))
|
|
{
|
|
return $rs; // if colums are specified we return the recordset / iterator
|
|
}
|
|
$events = $ids = $recur_dates = $recur_ids = array();
|
|
foreach($rs as $row)
|
|
{
|
|
$id = $row['cal_id'];
|
|
if (is_numeric($id)) $ids[] = $id;
|
|
|
|
if ($row['cal_recur_date'])
|
|
{
|
|
$id .= '-'.$row['cal_recur_date'];
|
|
$recur_dates[] = $row['cal_recur_date'];
|
|
}
|
|
if ($row['participants'])
|
|
{
|
|
$row['participants'] = explode(',',$row['participants']);
|
|
$row['participants'] = array_combine($row['participants'],
|
|
array_fill(0,count($row['participants']),''));
|
|
}
|
|
else
|
|
{
|
|
$row['participants'] = array();
|
|
}
|
|
$row['alarm'] = array();
|
|
$row['recur_exception'] = $row['recur_exception'] ? explode(',',$row['recur_exception']) : array();
|
|
|
|
// compile a list of recurrences per cal_id
|
|
if (!in_array($id,(array)$recur_ids[$row['cal_id']])) $recur_ids[$row['cal_id']][] = $id;
|
|
|
|
$events[$id] = egw_db::strip_array_keys($row,'cal_');
|
|
}
|
|
//_debug_array($events);
|
|
if (count($ids))
|
|
{
|
|
// now ready all users with the given cal_id AND (cal_recur_date=0 or the fitting recur-date)
|
|
// This will always read the first entry of each recuring event too, we eliminate it later
|
|
$recur_dates[] = 0;
|
|
$utcal_id_view = " (SELECT * FROM ".$this->user_table." WHERE cal_id IN (".implode(',',array_unique($ids)).")) utcalid ";
|
|
//$utrecurdate_view = " (select * from ".$this->user_table." where cal_recur_date in (".implode(',',array_unique($recur_dates)).")) utrecurdates ";
|
|
foreach($this->db->select($utcal_id_view,'*',array(
|
|
//'cal_id' => array_unique($ids),
|
|
'cal_recur_date' => $recur_dates,
|
|
),__LINE__,__FILE__,false,'ORDER BY cal_id,cal_user_type DESC,'.self::STATUS_SORT,'calendar',$num_rows=0,$join='',
|
|
$this->db->get_table_definitions('calendar',$this->user_table)) as $row) // DESC puts users before resources and contacts
|
|
{
|
|
$id = $row['cal_id'];
|
|
if ($row['cal_recur_date']) $id .= '-'.$row['cal_recur_date'];
|
|
|
|
// combine all participant data in uid and status values
|
|
$uid = self::combine_user($row['cal_user_type'],$row['cal_user_id']);
|
|
$status = self::combine_status($row['cal_status'],$row['cal_quantity'],$row['cal_role']);
|
|
|
|
// set accept/reject/tentative of series for all recurrences
|
|
if (!$row['cal_recur_date'])
|
|
{
|
|
foreach((array)$recur_ids[$row['cal_id']] as $i)
|
|
{
|
|
if (isset($events[$i]) && !isset($events[$i]['participants'][$uid]))
|
|
{
|
|
$events[$i]['participants'][$uid] = $status;
|
|
}
|
|
}
|
|
}
|
|
|
|
// set data, if recurrence is requested
|
|
if (isset($events[$id])) $events[$id]['participants'][$uid] = $status;
|
|
}
|
|
//custom fields are not shown in the regular views, so we only query them, if explicitly required
|
|
if (!is_null($cfs))
|
|
{
|
|
$where = array('cal_id' => $ids);
|
|
if ($cfs) $where['cal_extra_name'] = $cfs;
|
|
foreach($this->db->select($this->extra_table,'*',$where,
|
|
__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
foreach((array)$recur_ids[$row['cal_id']] as $id)
|
|
{
|
|
if (isset($events[$id]))
|
|
{
|
|
$events[$id]['#'.$row['cal_extra_name']] = $row['cal_extra_value'];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
// alarms, atm. we read all alarms in the system, as this can be done in a single query
|
|
foreach((array)$this->async->read('cal'.(is_array($ids) ? '' : ':'.(int)$ids).':%') as $id => $job)
|
|
{
|
|
list(,$cal_id) = explode(':',$id);
|
|
|
|
$alarm = $job['data']; // text, enabled
|
|
$alarm['id'] = $id;
|
|
$alarm['time'] = $job['next'];
|
|
|
|
$event_start = $alarm['time'] + $alarm['offset'];
|
|
|
|
if (isset($events[$cal_id])) // none recuring event
|
|
{
|
|
$events[$cal_id]['alarm'][$id] = $alarm;
|
|
}
|
|
elseif (isset($events[$cal_id.'-'.$event_start])) // recuring event
|
|
{
|
|
$events[$cal_id.'-'.$event_start]['alarm'][$id] = $alarm;
|
|
}
|
|
}
|
|
}
|
|
//echo "<p>socal::search\n"; _debug_array($events);
|
|
return $events;
|
|
}
|
|
|
|
/**
|
|
* Checks for conflicts
|
|
*/
|
|
|
|
/* folowing SQL checks for conflicts completly on DB level
|
|
|
|
SELECT cal_user_type, cal_user_id, SUM( cal_quantity )
|
|
FROM egw_cal, egw_cal_dates, egw_cal_user
|
|
LEFT JOIN egw_cal_repeats ON egw_cal.cal_id = egw_cal_repeats.cal_id
|
|
WHERE egw_cal.cal_id = egw_cal_dates.cal_id
|
|
AND egw_cal.cal_id = egw_cal_user.cal_id
|
|
AND (
|
|
recur_type IS NULL
|
|
AND cal_recur_date =0
|
|
OR cal_recur_date = cal_start
|
|
)
|
|
AND (
|
|
(
|
|
cal_user_type = 'u' # user of the checked event
|
|
AND cal_user_id
|
|
IN ( 7, 5 )
|
|
)
|
|
AND 1118822400 < cal_end # start- and end-time of the checked event
|
|
AND cal_start <1118833200
|
|
)
|
|
AND egw_cal.cal_id !=26 # id of the checked event
|
|
AND cal_non_blocking !=1
|
|
AND cal_status != 'R'
|
|
GROUP BY cal_user_type, cal_user_id
|
|
ORDER BY cal_user_type, cal_usre_id
|
|
|
|
*/
|
|
|
|
/**
|
|
* Saves or creates an event
|
|
*
|
|
* We always set cal_modified and cal_modifier and for new events cal_uid.
|
|
* All other column are only written if they are set in the $event parameter!
|
|
*
|
|
* @param array $event
|
|
* @param boolean &$set_recurrences on return: true if the recurrences need to be written, false otherwise
|
|
* @param int &$set_recurrences_start=0 on return: time from which on the recurrences should be rebuilt, default 0=all
|
|
* @param int $change_since=0 time from which on the repetitions should be changed, default 0=all
|
|
* @param int &$etag etag=null etag to check or null, on return new etag
|
|
* @return boolean|int false on error, 0 if etag does not match, cal_id otherwise
|
|
*/
|
|
function save($event,&$set_recurrences,&$set_recurrences_start=0,$change_since=0,&$etag=null)
|
|
{
|
|
if (isset($GLOBALS['egw_info']['user']['preferences']['syncml']['minimum_uid_length']))
|
|
{
|
|
$minimum_uid_length = $GLOBALS['egw_info']['user']['preferences']['syncml']['minimum_uid_length'];
|
|
}
|
|
else
|
|
{
|
|
$minimum_uid_length = 8;
|
|
}
|
|
|
|
$old_min = $old_duration = 0;
|
|
|
|
//error_log(__METHOD__.'('.array2string($event).",$set_recurrences,$change_since,$etag)");
|
|
|
|
$cal_id = (int) $event['id'];
|
|
unset($event['id']);
|
|
$set_recurrences = !$cal_id && $event['recur_type'] != MCAL_RECUR_NONE;
|
|
|
|
if ($event['recur_type'] != MCAL_RECUR_NONE &&
|
|
!(int)$event['recur_interval'])
|
|
{
|
|
$event['recur_interval'] = 1;
|
|
}
|
|
|
|
// add colum prefix 'cal_' if there's not already a 'recur_' prefix
|
|
foreach($event as $col => $val)
|
|
{
|
|
if ($col[0] != '#' && substr($col,0,6) != 'recur_' && $col != 'alarm' && $col != 'tz_id')
|
|
{
|
|
$event['cal_'.$col] = $val;
|
|
unset($event[$col]);
|
|
}
|
|
}
|
|
// ensure that we find mathing entries later on
|
|
if (!is_array($event['cal_category']))
|
|
{
|
|
$categories = array_unique(explode(',',$event['cal_category']));
|
|
sort($categories);
|
|
}
|
|
else
|
|
{
|
|
$categories = array_unique($event['cal_category']);
|
|
}
|
|
sort($categories, SORT_NUMERIC);
|
|
|
|
$event['cal_category'] = implode(',',$categories);
|
|
|
|
if ($cal_id)
|
|
{
|
|
$where = array('cal_id' => $cal_id);
|
|
// read only timezone id, to check if it is changed
|
|
if ($event['recur_type'] != MCAL_RECUR_NONE)
|
|
{
|
|
$old_tz_id = $this->db->select($this->cal_table,'tz_id',$where,__LINE__,__FILE__,'calendar')->fetchColumn();
|
|
}
|
|
if (!is_null($etag)) $where['cal_etag'] = $etag;
|
|
|
|
unset($event['cal_etag']);
|
|
$event[] = 'cal_etag=cal_etag+1'; // always update the etag, even if none given to check
|
|
|
|
$this->db->update($this->cal_table,$event,$where,__LINE__,__FILE__,'calendar');
|
|
|
|
if (!is_null($etag) && $this->db->affected_rows() < 1)
|
|
{
|
|
return 0; // wrong etag, someone else updated the entry
|
|
}
|
|
if (!is_null($etag)) ++$etag;
|
|
}
|
|
else
|
|
{
|
|
// new event
|
|
if (!$event['cal_owner']) $event['cal_owner'] = $GLOBALS['egw_info']['user']['account_id'];
|
|
|
|
if (!$event['cal_id'] && !isset($event['cal_uid'])) $event['cal_uid'] = ''; // uid is NOT NULL!
|
|
|
|
$this->db->insert($this->cal_table,$event,false,__LINE__,__FILE__,'calendar');
|
|
if (!($cal_id = $this->db->get_last_insert_id($this->cal_table,'cal_id')))
|
|
{
|
|
return false;
|
|
}
|
|
$etag = 0;
|
|
}
|
|
if (!isset($event['cal_uid']) || strlen($event['cal_uid']) < $minimum_uid_length)
|
|
{
|
|
// event (without uid), not strong enough uid
|
|
$event['cal_uid'] = $GLOBALS['egw']->common->generate_uid('calendar',$cal_id);
|
|
$this->db->update($this->cal_table, array('cal_uid' => $event['cal_uid']),
|
|
array('cal_id' => $event['cal_id']),__LINE__,__FILE__,'calendar');
|
|
}
|
|
// write information about recuring event, if recur_type is present in the array
|
|
if ($event['recur_type'] != MCAL_RECUR_NONE)
|
|
{
|
|
// fetch information about the currently saved (old) event
|
|
$old_min = (int) $this->db->select($this->dates_table,'MIN(cal_start)',array('cal_id'=>$cal_id),__LINE__,__FILE__,false,'','calendar')->fetchColumn();
|
|
$old_duration = (int) $this->db->select($this->dates_table,'MIN(cal_end)',array('cal_id'=>$cal_id),__LINE__,__FILE__,false,'','calendar')->fetchColumn() - $old_min;
|
|
$old_repeats = $this->db->select($this->repeats_table,'*',array('cal_id' => $cal_id),__LINE__,__FILE__,false,'','calendar')->fetch();
|
|
$old_exceptions = $old_repeats['recur_exception'] ? explode(',',$old_repeats['recur_exception']) : array();
|
|
if (!empty($old_exceptions))
|
|
{
|
|
sort($old_exceptions);
|
|
if ($old_min > $old_exceptions[0]) $old_min = $old_exceptions[0];
|
|
}
|
|
|
|
$event['recur_exception'] = is_array($event['recur_exception']) ? $event['recur_exception'] : array();
|
|
if (!empty($event['recur_exception']))
|
|
{
|
|
sort($event['recur_exception']);
|
|
}
|
|
|
|
$where = array('cal_id' => $cal_id,
|
|
'cal_recur_date' => 0);
|
|
$old_participants = array();
|
|
foreach ($this->db->select($this->user_table,'cal_user_type,cal_user_id,cal_status,cal_quantity,cal_role', $where,
|
|
__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
$uid = self::combine_user($row['cal_user_type'], $row['cal_user_id']);
|
|
$status = self::combine_status($row['cal_status'], $row['cal_quantity'], $row['cal_role']);
|
|
$old_participants[$uid] = $status;
|
|
}
|
|
|
|
// re-check: did so much recurrence data change that we have to rebuild it from scratch?
|
|
if (!$set_recurrences)
|
|
{
|
|
$set_recurrences = (isset($event['cal_start']) && (int)$old_min != (int) $event['cal_start']) ||
|
|
$event['recur_type'] != $old_repeats['recur_type'] || $event['recur_data'] != $old_repeats['recur_data'] ||
|
|
(int)$event['recur_interval'] != (int)$old_repeats['recur_interval'] || $event['tz_id'] != $old_tz_id;
|
|
}
|
|
|
|
if ($set_recurrences)
|
|
{
|
|
// too much recurrence data has changed, we have to do a rebuild from scratch
|
|
// delete all, but the lowest dates record
|
|
$this->db->delete($this->dates_table,array(
|
|
'cal_id' => $cal_id,
|
|
'cal_start > '.(int)$old_min,
|
|
),__LINE__,__FILE__,'calendar');
|
|
|
|
// delete all user-records, with recur-date != 0
|
|
$this->db->delete($this->user_table,array(
|
|
'cal_id' => $cal_id,
|
|
'cal_recur_date != 0',
|
|
),__LINE__,__FILE__,'calendar');
|
|
}
|
|
else
|
|
{
|
|
// we adjust some possibly changed recurrences manually
|
|
// deleted exceptions: re-insert recurrences into the user and dates table
|
|
if (count($deleted_exceptions = array_diff($old_exceptions,$event['recur_exception'])))
|
|
{
|
|
if (isset($event['cal_participants']))
|
|
{
|
|
$participants = $event['cal_participants'];
|
|
}
|
|
else
|
|
{
|
|
// use old default
|
|
$participants = $old_participants;
|
|
}
|
|
foreach($deleted_exceptions as $id => $deleted_exception)
|
|
{
|
|
// rebuild participants for the re-inserted recurrence
|
|
$this->recurrence($cal_id, $deleted_exception, $deleted_exception + $old_duration, $participants);
|
|
}
|
|
}
|
|
|
|
// check if recurrence enddate was adjusted
|
|
if(isset($event['recur_enddate']))
|
|
{
|
|
// recurrences need to be truncated
|
|
if((int)$event['recur_enddate'] > 0 &&
|
|
((int)$old_repeats['recur_enddate'] == 0 || (int)$old_repeats['recur_enddate'] > (int)$event['recur_enddate'])
|
|
)
|
|
{
|
|
$this->db->delete($this->user_table,array('cal_id' => $cal_id,'cal_recur_date > '.($event['recur_enddate'] + 1*DAY_s)),__LINE__,__FILE__,'calendar');
|
|
$this->db->delete($this->dates_table,array('cal_id' => $cal_id,'cal_start > '.($event['recur_enddate'] + 1*DAY_s)),__LINE__,__FILE__,'calendar');
|
|
}
|
|
|
|
// recurrences need to be expanded
|
|
if(((int)$event['recur_enddate'] == 0 && (int)$old_repeats['recur_enddate'] > 0)
|
|
|| ((int)$event['recur_enddate'] > 0 && (int)$old_repeats['recur_enddate'] > 0 && (int)$old_repeats['recur_enddate'] < (int)$event['recur_enddate'])
|
|
)
|
|
{
|
|
$set_recurrences = true;
|
|
$set_recurrences_start = ($old_repeats['recur_enddate'] + 1*DAY_s);
|
|
}
|
|
}
|
|
|
|
// truncate recurrences by given exceptions
|
|
if (count($event['recur_exception']))
|
|
{
|
|
// added and existing exceptions: delete the execeptions from the user and dates table, it could be the first time
|
|
$this->db->delete($this->user_table,array('cal_id' => $cal_id,'cal_recur_date' => $event['recur_exception']),__LINE__,__FILE__,'calendar');
|
|
$this->db->delete($this->dates_table,array('cal_id' => $cal_id,'cal_start' => $event['recur_exception']),__LINE__,__FILE__,'calendar');
|
|
}
|
|
}
|
|
|
|
// write the repeats table
|
|
$event['recur_exception'] = empty($event['recur_exception']) ? null : implode(',',$event['recur_exception']);
|
|
unset($event[0]); // unset the 'etag=etag+1', as it's not in the repeats table
|
|
if($event['recur_type'] != MCAL_RECUR_NONE)
|
|
{
|
|
$this->db->insert($this->repeats_table,$event,array('cal_id' => $cal_id),__LINE__,__FILE__,'calendar');
|
|
}
|
|
else
|
|
{
|
|
$this->db->delete($this->repeats_table,array('cal_id' => $cal_id),__LINE__,__FILE__,'calendar');
|
|
}
|
|
}
|
|
// update start- and endtime if present in the event-array, evtl. we need to move all recurrences
|
|
if (isset($event['cal_start']) && isset($event['cal_end']))
|
|
{
|
|
$this->move($cal_id,$event['cal_start'],$event['cal_end'],!$cal_id ? false : $change_since, $old_min, $old_min + $old_duration);
|
|
}
|
|
// update participants if present in the event-array
|
|
if (isset($event['cal_participants']))
|
|
{
|
|
$this->participants($cal_id,$event['cal_participants'],!$cal_id ? false : $change_since);
|
|
}
|
|
// Custom fields
|
|
foreach($event as $name => $value)
|
|
{
|
|
if ($name[0] == '#')
|
|
{
|
|
if ($value)
|
|
{
|
|
$this->db->insert($this->extra_table,array(
|
|
'cal_extra_value' => is_array($value) ? implode(',',$value) : $value,
|
|
),array(
|
|
'cal_id' => $cal_id,
|
|
'cal_extra_name' => substr($name,1),
|
|
),__LINE__,__FILE__,'calendar');
|
|
}
|
|
else
|
|
{
|
|
$this->db->delete($this->extra_table,array(
|
|
'cal_id' => $cal_id,
|
|
'cal_extra_name' => substr($name,1),
|
|
),__LINE__,__FILE__,'calendar');
|
|
}
|
|
}
|
|
}
|
|
// updating or saving the alarms, new alarms have a temporary numeric id!
|
|
// ToDo: recuring events !!!
|
|
if (is_array($event['alarm']))
|
|
{
|
|
foreach ($event['alarm'] as $id => $alarm)
|
|
{
|
|
if (is_numeric($id)) unset($alarm['id']); // unset the temporary id, to add the alarm
|
|
|
|
if(!isset($alarm['offset']))
|
|
{
|
|
$alarm['offset'] = $event['cal_start'] - $alarm['time'];
|
|
}
|
|
elseif (!isset($alarm['time']))
|
|
{
|
|
$alarm['time'] = $event['cal_start'] - $alarm['offset'];
|
|
}
|
|
|
|
if ($alarm['time'] < time())
|
|
{
|
|
//pgoerzen: don't add an alarm in the past
|
|
if ($event['recur_type'] == MCAL_RECUR_NONE) continue;
|
|
$start = (int)time() + $alarm['offset'];
|
|
$event['start'] = $event['cal_start'];
|
|
$event['end'] = $event['cal_end'];
|
|
$event['tzid'] = $event['cal_tzid'];
|
|
$rrule = calendar_rrule::event2rrule($event, false);
|
|
foreach ($rrule as $time)
|
|
{
|
|
if ($start < ($ts = egw_time::to($time,'server'))) break;
|
|
$ts = 0;
|
|
}
|
|
if (!$ts) continue;
|
|
$alarm['time'] = $ts - $alarm['offset'];
|
|
}
|
|
$this->save_alarm($cal_id,$alarm);
|
|
}
|
|
}
|
|
if (is_null($etag))
|
|
{
|
|
$etag = $this->db->select($this->cal_table,'cal_etag',array('cal_id' => $cal_id),__LINE__,__FILE__,false,'','calendar')->fetchColumn();
|
|
}
|
|
return $cal_id;
|
|
}
|
|
|
|
/**
|
|
* moves an event to an other start- and end-time taken into account the evtl. recurrences of the event(!)
|
|
*
|
|
* @param int $cal_id
|
|
* @param int $start new starttime
|
|
* @param int $end new endtime
|
|
* @param int|boolean $change_since=0 false=new entry, > 0 time from which on the repetitions should be changed, default 0=all
|
|
* @param int $old_start=0 old starttime or (default) 0, to query it from the db
|
|
* @param int $old_end=0 old starttime or (default) 0
|
|
* @todo Recalculate recurrences, if timezone changes
|
|
* @return int|boolean number of moved recurrences or false on error
|
|
*/
|
|
function move($cal_id,$start,$end,$change_since=0,$old_start=0,$old_end=0)
|
|
{
|
|
//echo "<p>socal::move($cal_id,$start,$end,$change_since,$old_start,$old_end)</p>\n";
|
|
|
|
if (!(int) $cal_id) return false;
|
|
|
|
if (!$old_start)
|
|
{
|
|
if ($change_since !== false) $row = $this->db->select($this->dates_table,'MIN(cal_start) AS cal_start,MIN(cal_end) AS cal_end',
|
|
array('cal_id'=>$cal_id),__LINE__,__FILE__,false,'','calendar')->fetch();
|
|
// if no recurrence found, create one with the new dates
|
|
if ($change_since === false || !$row || !$row['cal_start'] || !$row['cal_end'])
|
|
{
|
|
$this->db->insert($this->dates_table,array(
|
|
'cal_id' => $cal_id,
|
|
'cal_start' => $start,
|
|
'cal_end' => $end,
|
|
),false,__LINE__,__FILE__,'calendar');
|
|
|
|
return 1;
|
|
}
|
|
$move_start = (int) ($start-$row['cal_start']);
|
|
$move_end = (int) ($end-$row['cal_end']);
|
|
}
|
|
else
|
|
{
|
|
$move_start = (int) ($start-$old_start);
|
|
$move_end = (int) ($end-$old_end);
|
|
}
|
|
$where = 'cal_id='.(int)$cal_id;
|
|
|
|
if ($move_start)
|
|
{
|
|
// move the recur-date of the participants
|
|
$this->db->query("UPDATE $this->user_table SET cal_recur_date=cal_recur_date+$move_start WHERE $where AND cal_recur_date ".
|
|
((int)$change_since ? '>= '.(int)$change_since : '!= 0'),__LINE__,__FILE__);
|
|
}
|
|
if ($move_start || $move_end)
|
|
{
|
|
// move the event and it's recurrences
|
|
$this->db->query("UPDATE $this->dates_table SET cal_start=cal_start+$move_start,cal_end=cal_end+$move_end WHERE $where".
|
|
((int) $change_since ? ' AND cal_start >= '.(int) $change_since : ''),__LINE__,__FILE__);
|
|
}
|
|
return $this->db->affected_rows();
|
|
}
|
|
|
|
/**
|
|
* combines user_type and user_id into a single string or integer (for users)
|
|
*
|
|
* @param string $user_type 1-char type: 'u' = user, ...
|
|
* @param string|int $user_id id
|
|
* @return string|int combined id
|
|
*/
|
|
static function combine_user($user_type,$user_id)
|
|
{
|
|
if (!$user_type || $user_type == 'u')
|
|
{
|
|
return (int) $user_id;
|
|
}
|
|
return $user_type.$user_id;
|
|
}
|
|
|
|
/**
|
|
* splits the combined user_type and user_id into a single values
|
|
*
|
|
* @param string|int $uid
|
|
* @param string &$user_type 1-char type: 'u' = user, ...
|
|
* @param string|int &$user_id id
|
|
*/
|
|
static function split_user($uid,&$user_type,&$user_id)
|
|
{
|
|
if (is_numeric($uid))
|
|
{
|
|
$user_type = 'u';
|
|
$user_id = (int) $uid;
|
|
}
|
|
else
|
|
{
|
|
$user_type = $uid[0];
|
|
$user_id = substr($uid,1);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Combine status, quantity and role into one value
|
|
*
|
|
* @param string $status
|
|
* @param int $quantity=1
|
|
* @param string $role='REQ-PARTICIPANT'
|
|
* @return string
|
|
*/
|
|
static function combine_status($status,$quantity=1,$role='REQ-PARTICIPANT')
|
|
{
|
|
if ((int)$quantity > 1) $status .= (int)$quantity;
|
|
if ($role != 'REQ-PARTICIPANT') $status .= $role;
|
|
|
|
return $status;
|
|
}
|
|
|
|
/**
|
|
* splits the combined status, quantity and role
|
|
*
|
|
* @param string &$status I: combined value, O: status letter: U, T, A, R
|
|
* @param int &$quantity only O: quantity
|
|
* @param string &$role only O: role
|
|
*/
|
|
static function split_status(&$status,&$quantity,&$role)
|
|
{
|
|
$quantity = 1;
|
|
$role = 'REQ-PARTICIPANT';
|
|
|
|
if (strlen($status) > 1 && preg_match('/^.([0-9]*)(.*)$/',$status,$matches))
|
|
{
|
|
if ((int)$matches[1] > 0) $quantity = (int)$matches[1];
|
|
if ($matches[2]) $role = $matches[2];
|
|
$status = $status[0];
|
|
}
|
|
elseif ($status === true)
|
|
{
|
|
$status = 'U';
|
|
}
|
|
}
|
|
|
|
/**
|
|
* updates the participants of an event, taken into account the evtl. recurrences of the event(!)
|
|
* this method just adds new participants or removes not longer set participants
|
|
* this method does never overwrite existing entries (except the 0-recurrence and for delete)
|
|
*
|
|
* @param int $cal_id
|
|
* @param array $participants uid => status pairs
|
|
* @param int|boolean $change_since=0, false=new event,
|
|
* 0=all, > 0 time from which on the repetitions should be changed
|
|
* @param boolean $add_only=false
|
|
* false = add AND delete participants if needed (full list of participants required in $participants)
|
|
* true = only add participants if needed, no participant will be deleted (participants to check/add required in $participants)
|
|
* @return int|boolean number of updated recurrences or false on error
|
|
*/
|
|
function participants($cal_id,$participants,$change_since=0,$add_only=false)
|
|
{
|
|
//error_log(__METHOD__."($cal_id,".array2string($participants).",$change_since,$add_only");
|
|
|
|
$recurrences = array();
|
|
|
|
// remove group-invitations, they are NOT stored in the db
|
|
foreach($participants as $uid => $status)
|
|
{
|
|
if ($status[0] == 'G')
|
|
{
|
|
unset($participants[$uid]);
|
|
}
|
|
}
|
|
$where = array('cal_id' => $cal_id);
|
|
|
|
if ((int) $change_since)
|
|
{
|
|
$where[] = '(cal_recur_date=0 OR cal_recur_date >= '.(int)$change_since.')';
|
|
}
|
|
|
|
if ($change_since !== false)
|
|
{
|
|
// find all existing recurrences
|
|
foreach($this->db->select($this->user_table,'DISTINCT cal_recur_date',$where,__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
$recurrences[] = $row['cal_recur_date'];
|
|
}
|
|
|
|
// update existing entries
|
|
$existing_entries = $this->db->select($this->user_table,'*',$where,__LINE__,__FILE__,false,'ORDER BY cal_recur_date DESC','calendar');
|
|
|
|
// create a full list of participants which already exist in the db
|
|
// with status, quantity and role of the earliest recurence
|
|
$old_participants = array();
|
|
foreach($existing_entries as $row)
|
|
{
|
|
$uid = self::combine_user($row['cal_user_type'],$row['cal_user_id']);
|
|
if ($row['cal_recur_date'] || !isset($old_participants[$uid]))
|
|
{
|
|
$old_participants[$uid] = self::combine_status($row['cal_status'],$row['cal_quantity'],$row['cal_role']);
|
|
}
|
|
}
|
|
|
|
// tag participants which should be deleted
|
|
if($add_only === false)
|
|
{
|
|
$deleted = array();
|
|
foreach($existing_entries as $row)
|
|
{
|
|
$uid = self::combine_user($row['cal_user_type'],$row['cal_user_id']);
|
|
// delete not longer set participants
|
|
if (!isset($participants[$uid]))
|
|
{
|
|
$deleted[$row['cal_user_type']][] = $row['cal_user_id'];
|
|
}
|
|
}
|
|
}
|
|
|
|
// only keep added OR status (incl. quantity!) changed participants for further steps
|
|
// we do not touch unchanged (!) existing ones
|
|
foreach($participants as $uid => $status)
|
|
{
|
|
if ($old_participants[$uid] === $status)
|
|
{
|
|
unset($participants[$uid]);
|
|
}
|
|
}
|
|
|
|
// delete participants tagged for delete
|
|
if ($add_only === false && count($deleted))
|
|
{
|
|
$to_or = array();
|
|
$table_def = $this->db->get_table_definitions('calendar',$this->user_table);
|
|
foreach($deleted as $type => $ids)
|
|
{
|
|
$to_or[] = $this->db->expression($table_def,array(
|
|
'cal_user_type' => $type,
|
|
'cal_user_id' => $ids,
|
|
));
|
|
}
|
|
$where[1] = '('.implode(' OR ',$to_or).')';
|
|
$this->db->delete($this->user_table,$where,__LINE__,__FILE__,'calendar');
|
|
unset($where[1]);
|
|
}
|
|
}
|
|
|
|
if (count($participants)) // participants which need to be added
|
|
{
|
|
if (!count($recurrences)) $recurrences[] = 0; // insert the default recurrence
|
|
|
|
// update participants
|
|
foreach($participants as $uid => $status)
|
|
{
|
|
$type = $id = $quantity = $role = null;
|
|
self::split_user($uid,$type,$id);
|
|
self::split_status($status,$quantity,$role);
|
|
$set = array(
|
|
'cal_status' => $status,
|
|
'cal_quantity' => $quantity,
|
|
'cal_role' => $role,
|
|
);
|
|
foreach($recurrences as $recur_date)
|
|
{
|
|
$this->db->insert($this->user_table,$set,array(
|
|
'cal_id' => $cal_id,
|
|
'cal_recur_date' => $recur_date,
|
|
'cal_user_type' => $type,
|
|
'cal_user_id' => $id,
|
|
),__LINE__,__FILE__,'calendar');
|
|
}
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* set the status of one participant for a given recurrence or for all recurrences since now (includes recur_date=0)
|
|
*
|
|
* @param int $cal_id
|
|
* @param char $user_type 'u' regular user, 'r' resource, 'c' contact
|
|
* @param int $user_id
|
|
* @param int|char $status numeric status (defines) or 1-char code: 'R', 'U', 'T' or 'A'
|
|
* @param int $recur_date=0 date to change, or 0 = all since now
|
|
* @param string $role=null role to set if !is_null($role)
|
|
* @return int number of changed recurrences
|
|
*/
|
|
function set_status($cal_id,$user_type,$user_id,$status,$recur_date=0,$role=null)
|
|
{
|
|
static $status_code_short = array(
|
|
REJECTED => 'R',
|
|
NO_RESPONSE => 'U',
|
|
TENTATIVE => 'T',
|
|
ACCEPTED => 'A',
|
|
DELEGATED => 'D'
|
|
);
|
|
if (!(int)$cal_id || !(int)$user_id && $user_type != 'e')
|
|
{
|
|
return false;
|
|
}
|
|
|
|
if (is_numeric($status)) $status = $status_code_short[$status];
|
|
|
|
$where = array(
|
|
'cal_id' => $cal_id,
|
|
'cal_user_type' => $user_type ? $user_type : 'u',
|
|
'cal_user_id' => $user_id,
|
|
);
|
|
if ((int) $recur_date)
|
|
{
|
|
$where['cal_recur_date'] = $recur_date;
|
|
}
|
|
else
|
|
{
|
|
$where[] = '(cal_recur_date=0 OR cal_recur_date >= '.time().')';
|
|
}
|
|
|
|
if ($status == 'G') // remove group invitations, as we dont store them in the db
|
|
{
|
|
$this->db->delete($this->user_table,$where,__LINE__,__FILE__,'calendar');
|
|
}
|
|
else
|
|
{
|
|
$set = array('cal_status' => $status);
|
|
if (!is_null($role) && $role != 'REQ-PARTICIPANT') $set['cal_role'] = $role;
|
|
$this->db->insert($this->user_table,$set,$where,__LINE__,__FILE__,'calendar');
|
|
}
|
|
$ret = $this->db->affected_rows();
|
|
//error_log(__METHOD__."($cal_id,$user_type,$user_id,$status,$recur_date) = $ret");
|
|
return $ret;
|
|
}
|
|
|
|
/**
|
|
* creates or update a recurrence in the dates and users table
|
|
*
|
|
* @param int $cal_id
|
|
* @param int $start
|
|
* @param int $end
|
|
* @param array $participants uid => status pairs
|
|
*/
|
|
function recurrence($cal_id,$start,$end,$participants)
|
|
{
|
|
//echo "<p>socal::recurrence($cal_id,$start,$end,".print_r($participants,true).")</p>\n";
|
|
$this->db->insert($this->dates_table,array(
|
|
'cal_end' => $end,
|
|
),array(
|
|
'cal_id' => $cal_id,
|
|
'cal_start' => $start,
|
|
),__LINE__,__FILE__,'calendar');
|
|
|
|
foreach($participants as $uid => $status)
|
|
{
|
|
if ($status == 'G') continue; // dont save group-invitations
|
|
|
|
$type = '';
|
|
$id = null;
|
|
self::split_user($uid,$type,$id);
|
|
self::split_status($status,$quantity,$role);
|
|
$this->db->insert($this->user_table,array(
|
|
'cal_status' => $status,
|
|
'cal_quantity' => $quantity,
|
|
'cal_role' => $role
|
|
),array(
|
|
'cal_id' => $cal_id,
|
|
'cal_recur_date' => $start,
|
|
'cal_user_type' => $type,
|
|
'cal_user_id' => $id,
|
|
),__LINE__,__FILE__,'calendar');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get all unfinished recuring events (or all users) after a given time
|
|
*
|
|
* @param int $time
|
|
* @return array with cal_id => max(cal_start) pairs
|
|
*/
|
|
function unfinished_recuring($time)
|
|
{
|
|
$ids = array();
|
|
foreach($this->db->select($this->repeats_table,"$this->repeats_table.cal_id,MAX(cal_start) AS cal_start",array(
|
|
"$this->repeats_table.cal_id = $this->dates_table.cal_id",
|
|
'(recur_enddate = 0 OR recur_enddate IS NULL OR recur_enddate > '.(int)$time.')',
|
|
),__LINE__,__FILE__,false,"GROUP BY $this->repeats_table.cal_id",'calendar',0,','.$this->dates_table) as $row)
|
|
{
|
|
$ids[$row['cal_id']] = $row['cal_start'];
|
|
}
|
|
return $ids;
|
|
}
|
|
|
|
/**
|
|
* deletes an event incl. all recurrences, participants and alarms
|
|
*
|
|
* @param int $cal_id
|
|
*/
|
|
function delete($cal_id)
|
|
{
|
|
//echo "<p>socal::delete($cal_id)</p>\n";
|
|
|
|
$this->delete_alarms($cal_id);
|
|
|
|
foreach($this->all_tables as $table)
|
|
{
|
|
$this->db->delete($table,array('cal_id'=>$cal_id),__LINE__,__FILE__,'calendar');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* read the alarms of a calendar-event specified by $cal_id
|
|
*
|
|
* alarm-id is a string of 'cal:'.$cal_id.':'.$alarm_nr, it is used as the job-id too
|
|
*
|
|
* @param int $cal_id
|
|
* @return array of alarms with alarm-id as key
|
|
*/
|
|
function read_alarms($cal_id)
|
|
{
|
|
$alarms = array();
|
|
|
|
if ($jobs = $this->async->read('cal:'.(int)$cal_id.':%'))
|
|
{
|
|
foreach($jobs as $id => $job)
|
|
{
|
|
$alarm = $job['data']; // text, enabled
|
|
$alarm['id'] = $id;
|
|
$alarm['time'] = $job['next'];
|
|
|
|
$alarms[$id] = $alarm;
|
|
}
|
|
}
|
|
return $alarms;
|
|
}
|
|
|
|
/**
|
|
* read a single alarm specified by it's $id
|
|
*
|
|
* @param string $id alarm-id is a string of 'cal:'.$cal_id.':'.$alarm_nr, it is used as the job-id too
|
|
* @return array with data of the alarm
|
|
*/
|
|
function read_alarm($id)
|
|
{
|
|
if (!($jobs = $this->async->read($id)))
|
|
{
|
|
return False;
|
|
}
|
|
list($id,$job) = each($jobs);
|
|
$alarm = $job['data']; // text, enabled
|
|
$alarm['id'] = $id;
|
|
$alarm['time'] = $job['next'];
|
|
|
|
//echo "<p>read_alarm('$id')="; print_r($alarm); echo "</p>\n";
|
|
return $alarm;
|
|
}
|
|
|
|
/**
|
|
* saves a new or updated alarm
|
|
*
|
|
* @param int $cal_id Id of the calendar-entry
|
|
* @param array $alarm array with fields: text, owner, enabled, ..
|
|
* @param timestamp $now_su=0 timestamp for modification of related event
|
|
* @return string id of the alarm
|
|
*/
|
|
function save_alarm($cal_id, $alarm, $now_su = 0)
|
|
{
|
|
//echo "<p>save_alarm(cal_id=$cal_id, alarm="; print_r($alarm); echo ")</p>\n";
|
|
if (!($id = $alarm['id']))
|
|
{
|
|
$alarms = $this->read_alarms($cal_id); // find a free alarm#
|
|
$n = count($alarms);
|
|
do
|
|
{
|
|
$id = 'cal:'.(int)$cal_id.':'.$n;
|
|
++$n;
|
|
}
|
|
while (@isset($alarms[$id]));
|
|
}
|
|
else
|
|
{
|
|
$this->async->cancel_timer($id);
|
|
}
|
|
$alarm['cal_id'] = $cal_id; // we need the back-reference
|
|
|
|
// allways store job with the alarm owner as job-owner to get eg. the correct from address
|
|
if (!$this->async->set_timer($alarm['time'],$id,'calendar.calendar_boupdate.send_alarm',$alarm,$alarm['owner']))
|
|
{
|
|
return False;
|
|
}
|
|
|
|
// update the modification information of the related event
|
|
$datetime = $GLOBALS['egw']->datetime;
|
|
$now = ($now_su ? $now_su : time() + $datetime->this->tz_offset);
|
|
$modifier = $GLOBALS['egw_info']['user']['account_id'];
|
|
$this->db->update($this->cal_table, array('cal_modified' => $now, 'cal_modifier' => $modifier),
|
|
array('cal_id' => $cal_id), __LINE__, __FILE__, 'calendar');
|
|
|
|
return $id;
|
|
}
|
|
|
|
/**
|
|
* delete all alarms of a calendar-entry
|
|
*
|
|
* @param int $cal_id Id of the calendar-entry
|
|
* @return int number of alarms deleted
|
|
*/
|
|
function delete_alarms($cal_id)
|
|
{
|
|
$alarms = $this->read_alarms($cal_id);
|
|
|
|
foreach($alarms as $id => $alarm)
|
|
{
|
|
$this->async->cancel_timer($id);
|
|
}
|
|
return count($alarms);
|
|
}
|
|
|
|
/**
|
|
* delete one alarms identified by its id
|
|
*
|
|
* @param string $id alarm-id is a string of 'cal:'.$cal_id.':'.$alarm_nr, it is used as the job-id too
|
|
* @param timestamp $now_su=0 timestamp for modification of related event
|
|
* @return int number of alarms deleted
|
|
*/
|
|
function delete_alarm($id, $now_su = 0)
|
|
{
|
|
// update the modification information of the related event
|
|
list(,$cal_id) = explode(':',$id);
|
|
if ($cal_id)
|
|
{
|
|
$datetime = $GLOBALS['egw']->datetime;
|
|
$now = ($now_su ? $now_su : time() + $datetime->this->tz_offset);
|
|
$modifier = $GLOBALS['egw_info']['user']['account_id'];
|
|
$this->db->update($this->cal_table, array('cal_modified' => $now, 'cal_modifier' => $modifier),
|
|
array('cal_id' => $cal_id), __LINE__, __FILE__, 'calendar');
|
|
}
|
|
return $this->async->cancel_timer($id);
|
|
}
|
|
|
|
/**
|
|
* Delete account hook
|
|
*
|
|
* @param array|int $old_user integer old user or array with keys 'account_id' and 'new_owner' as the deleteaccount hook uses it
|
|
* @param int $new_user=null
|
|
*/
|
|
function deleteaccount($old_user, $newuser=null)
|
|
{
|
|
if (is_array($old_user))
|
|
{
|
|
$new_user = $old_user['new_owner'];
|
|
$old_user = $old_user['account_id'];
|
|
}
|
|
if (!(int)$new_user)
|
|
{
|
|
$user_type = '';
|
|
$user_id = null;
|
|
self::split_user($old_user,$user_type,$user_id);
|
|
|
|
if ($user_type == 'u') // only accounts can be owners of events
|
|
{
|
|
foreach($this->db->select($this->cal_table,'cal_id',array('cal_owner' => $old_user),__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
$this->delete($row['cal_id']);
|
|
}
|
|
}
|
|
$this->db->delete($this->user_table,array(
|
|
'cal_user_type' => $user_type,
|
|
'cal_user_id' => $user_id,
|
|
),__LINE__,__FILE__,'calendar');
|
|
|
|
// delete calendar entries without participants (can happen if the deleted user is the only participants, but not the owner)
|
|
foreach($this->db->select($this->cal_table,"DISTINCT $this->cal_table.cal_id",'cal_user_id IS NULL',__LINE__,__FILE__,
|
|
False,'','calendar',0,"LEFT JOIN $this->user_table ON $this->cal_table.cal_id=$this->user_table.cal_id") as $row)
|
|
{
|
|
$this->delete($row['cal_id']);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$this->db->update($this->cal_table,array('cal_owner' => $new_user),array('cal_owner' => $old_user),__LINE__,__FILE__,'calendar');
|
|
// delete participation of old user, if new user is already a participant
|
|
$ids = array();
|
|
foreach($this->db->select($this->user_table,'cal_id',array( // MySQL does NOT allow to run this as delete!
|
|
'cal_user_type' => 'u',
|
|
'cal_user_id' => $old_user,
|
|
"cal_id IN (SELECT cal_id FROM $this->user_table other WHERE other.cal_id=cal_id AND other.cal_user_id=".$this->db->quote($new_user)." AND cal_user_type='u')",
|
|
),__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
$ids[] = $row['cal_id'];
|
|
}
|
|
if ($ids) $this->db->delete($this->user_table,array(
|
|
'cal_user_type' => 'u',
|
|
'cal_user_id' => $old_user,
|
|
'cal_id' => $ids,
|
|
),__LINE__,__FILE__,'calendar');
|
|
// now change participant in the rest to contain new user instead of old user
|
|
$this->db->update($this->user_table,array(
|
|
'cal_user_id' => $new_user,
|
|
),array(
|
|
'cal_user_type' => 'u',
|
|
'cal_user_id' => $old_user,
|
|
),__LINE__,__FILE__,'calendar');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* get stati of all recurrences of an event for a specific participant
|
|
*
|
|
* @param int $cal_id
|
|
* @param int $uid=null participant uid; if == null return only the recur dates
|
|
* @param int $start=0 if != 0: startdate of the search/list (servertime)
|
|
* @param int $end=0 if != 0: enddate of the search/list (servertime)
|
|
*
|
|
* @return array recur_date => status pairs (index 0 => main status)
|
|
*/
|
|
function get_recurrences($cal_id, $uid=null, $start=0, $end=0)
|
|
{
|
|
$participant_status = array();
|
|
$where = array('cal_id' => $cal_id);
|
|
if ($start != 0 && $end == 0) $where[] = '(cal_recur_date = 0 OR cal_recur_date >= ' . (int)$start . ')';
|
|
if ($start == 0 && $end != 0) $where[] = '(cal_recur_date = 0 OR cal_recur_date <= ' . (int)$end . ')';
|
|
if ($start != 0 && $end != 0)
|
|
{
|
|
$where[] = '(cal_recur_date = 0 OR (cal_recur_date >= ' . (int)$start .
|
|
' AND cal_recur_date <= ' . (int)$end . '))';
|
|
}
|
|
foreach($this->db->select($this->user_table,'DISTINCT cal_recur_date',$where,__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
// inititalize the array
|
|
$participant_status[$row['cal_recur_date']] = null;
|
|
}
|
|
if (is_null($uid)) return $participant_status;
|
|
$user_type = $user_id = null;
|
|
self::split_user($uid, $user_type, $user_id);
|
|
$where = array(
|
|
'cal_id' => $cal_id,
|
|
'cal_user_type' => $user_type ? $user_type : 'u',
|
|
'cal_user_id' => $user_id,
|
|
);
|
|
if ($start != 0 && $end == 0) $where[] = '(cal_recur_date = 0 OR cal_recur_date >= ' . (int)$start . ')';
|
|
if ($start == 0 && $end != 0) $where[] = '(cal_recur_date = 0 OR cal_recur_date <= ' . (int)$end . ')';
|
|
if ($start != 0 && $end != 0)
|
|
{
|
|
$where[] = '(cal_recur_date = 0 OR (cal_recur_date >= ' . (int)$start .
|
|
' AND cal_recur_date <= ' . (int)$end . '))';
|
|
}
|
|
foreach ($this->db->select($this->user_table,'cal_recur_date,cal_status,cal_quantity,cal_role',$where,
|
|
__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
$status = self::combine_status($row['cal_status'],$row['cal_quantity'],$row['cal_role']);
|
|
$participant_status[$row['cal_recur_date']] = $status;
|
|
}
|
|
return $participant_status;
|
|
}
|
|
|
|
/**
|
|
* get all participants of an event
|
|
*
|
|
* @param int $cal_id
|
|
* @param int $recur_date=0 gives participants of this recurrence, default 0=all
|
|
*
|
|
* @return array participants
|
|
*/
|
|
function get_participants($cal_id, $recur_date=0)
|
|
{
|
|
$participants = array();
|
|
$where = array('cal_id' => $cal_id);
|
|
if ($recur_date)
|
|
{
|
|
$where['cal_recur_date'] = $recur_date;
|
|
}
|
|
|
|
foreach ($this->db->select($this->user_table,'DISTINCT cal_user_type,cal_user_id', $where,
|
|
__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
$uid = self::combine_user($row['cal_user_type'], $row['cal_user_id']);
|
|
$id = $row['cal_user_type'] . $row['cal_user_id'];
|
|
$participants[$id]['type'] = $row['cal_user_type'];
|
|
$participants[$id]['id'] = $row['cal_user_id'];
|
|
$participants[$id]['uid'] = $uid;
|
|
}
|
|
return $participants;
|
|
}
|
|
|
|
/**
|
|
* get all releated events
|
|
*
|
|
* @param int $uid UID of the series
|
|
*
|
|
* @return array of event exception ids for all events which share $uid
|
|
*/
|
|
function get_related($uid)
|
|
{
|
|
$where = array(
|
|
'cal_uid' => $uid,
|
|
);
|
|
$related = array();
|
|
foreach ($this->db->select($this->cal_table,'cal_id,cal_reference',$where,
|
|
__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
if ($row['cal_reference'] != 0)
|
|
{
|
|
// not the series master
|
|
$related[] = $row['cal_id'];
|
|
}
|
|
}
|
|
return $related;
|
|
}
|
|
|
|
/**
|
|
* Gets the exception days of a given recurring event caused by
|
|
* irregular participant stati or timezone transitions
|
|
*
|
|
* @param array $event Recurring Event.
|
|
* @param string tz_id=null timezone for exports (null for event's timezone)
|
|
* @param int $start=0 if != 0: startdate of the search/list (servertime)
|
|
* @param int $end=0 if != 0: enddate of the search/list (servertime)
|
|
* @param string $filter='all' string filter-name: all (not rejected),
|
|
* accepted, unknown, tentative, rejected, delegated
|
|
* rrule return array of remote exceptions in servertime
|
|
* tz_rrule/tz_only, return (only by) timezone transition affected entries
|
|
* map return array of dates with no pseudo exception
|
|
* key remote occurrence date
|
|
* tz_map return array of all dates with no tz pseudo exception
|
|
*
|
|
* @return array Array of exception days (false for non-recurring events).
|
|
*/
|
|
function get_recurrence_exceptions($event, $tz_id=null, $start=0, $end=0, $filter='all')
|
|
{
|
|
if (!is_array($event)) return false;
|
|
$cal_id = (int) $event['id'];
|
|
//error_log(__FILE__.'['.__LINE__.'] '.__METHOD__.
|
|
// "($cal_id, $tz_id, $filter): " . $event['tzid']);
|
|
if (!$cal_id || $event['recur_type'] == MCAL_RECUR_NONE) return false;
|
|
|
|
$days = array();
|
|
|
|
$expand_all = (!$this->isWholeDay($event) && $tz_id && $tz_id != $event['tzid']);
|
|
|
|
if ($filter == 'tz_only' && !$expand_all) return $days;
|
|
|
|
$remote = in_array($filter, array('tz_rrule', 'rrule'));
|
|
|
|
$egw_rrule = calendar_rrule::event2rrule($event, false);
|
|
$egw_rrule->current = clone $egw_rrule->time;
|
|
if ($expand_all)
|
|
{
|
|
unset($event['recur_exception']);
|
|
$remote_rrule = calendar_rrule::event2rrule($event, false, $tz_id);
|
|
$remote_rrule->current = clone $remote_rrule->time;
|
|
}
|
|
while ($egw_rrule->valid())
|
|
{
|
|
while ($egw_rrule->exceptions &&
|
|
in_array($egw_rrule->current->format('Ymd'),$egw_rrule->exceptions))
|
|
{
|
|
if (in_array($filter, array('map','tz_map','rrule','tz_rrule')))
|
|
{
|
|
// real exception
|
|
$locts = (int)egw_time::to($egw_rrule->current(),'server');
|
|
if ($expand_all)
|
|
{
|
|
$remts = (int)egw_time::to($remote_rrule->current(),'server');
|
|
if ($remote)
|
|
{
|
|
$days[$locts]= $remts;
|
|
}
|
|
else
|
|
{
|
|
$days[$remts]= $locts;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$days[$locts]= $locts;
|
|
}
|
|
}
|
|
if ($expand_all)
|
|
{
|
|
$remote_rrule->next_no_exception();
|
|
}
|
|
$egw_rrule->next_no_exception();
|
|
if (!$egw_rrule->valid()) return $days;
|
|
}
|
|
$day = $egw_rrule->current();
|
|
$locts = (int)egw_time::to($day,'server');
|
|
$tz_exception = ($filter == 'tz_rrule');
|
|
//error_log(__FILE__.'['.__LINE__.'] '.__METHOD__.
|
|
// '()[EVENT Server]: ' . $day->format('Ymd\THis') . " ($locts)");
|
|
if ($expand_all)
|
|
{
|
|
$remote_day = $remote_rrule->current();
|
|
$remts = (int)egw_time::to($remote_day,'server');
|
|
// error_log(__FILE__.'['.__LINE__.'] '.__METHOD__.
|
|
// '()[EVENT Device]: ' . $remote_day->format('Ymd\THis') . " ($remts)");
|
|
}
|
|
|
|
|
|
if (!($end && $end < $locts) && $start <= $locts)
|
|
{
|
|
// we are within the relevant time period
|
|
if ($expand_all && $day->format('U') != $remote_day->format('U'))
|
|
{
|
|
$tz_exception = true;
|
|
if ($filter != 'map' && $filter != 'tz_map')
|
|
{
|
|
// timezone pseudo exception
|
|
//error_log(__FILE__.'['.__LINE__.'] '.__METHOD__.
|
|
// '() tz exception: ' . $day->format('Ymd\THis'));
|
|
if ($remote)
|
|
{
|
|
$days[$locts]= $remts;
|
|
}
|
|
else
|
|
{
|
|
$days[$remts]= $locts;
|
|
}
|
|
}
|
|
}
|
|
if ($filter != 'tz_map' && (!$tz_exception || $filter == 'tz_only') &&
|
|
$this->status_pseudo_exception($event['id'], $locts, $filter))
|
|
{
|
|
// status pseudo exception
|
|
//error_log(__FILE__.'['.__LINE__.'] '.__METHOD__.
|
|
// '() status exception: ' . $day->format('Ymd\THis'));
|
|
if ($expand_all)
|
|
{
|
|
if ($filter == 'tz_only')
|
|
{
|
|
unset($days[$remts]);
|
|
}
|
|
else
|
|
{
|
|
if ($filter != 'map')
|
|
{
|
|
if ($remote)
|
|
{
|
|
$days[$locts]= $remts;
|
|
}
|
|
else
|
|
{
|
|
$days[$remts]= $locts;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
elseif ($filter != 'map')
|
|
{
|
|
$days[$locts]= $locts;
|
|
}
|
|
}
|
|
elseif (($filter == 'map' || filter == 'tz_map') &&
|
|
!$tz_exception)
|
|
{
|
|
// no pseudo exception date
|
|
if ($expand_all)
|
|
{
|
|
|
|
$days[$remts]= $locts;
|
|
}
|
|
else
|
|
{
|
|
$days[$locts]= $locts;
|
|
}
|
|
}
|
|
}
|
|
if ($expand_all)
|
|
{
|
|
$remote_rrule->next_no_exception();
|
|
}
|
|
$egw_rrule->next_no_exception();
|
|
}
|
|
return $days;
|
|
}
|
|
|
|
/**
|
|
* Checks for status only pseudo exceptions
|
|
*
|
|
* @param int $cal_id event id
|
|
* @param int $recur_date occurrence to check
|
|
* @param string $filter status filter criteria for user
|
|
*
|
|
* @return boolean true, if stati don't match with defaults
|
|
*/
|
|
function status_pseudo_exception($cal_id, $recur_date, $filter)
|
|
{
|
|
static $recurrence_zero;
|
|
static $cached_id;
|
|
static $user;
|
|
|
|
if (!isset($cached_id) || $cached_id != $cal_id)
|
|
{
|
|
// get default stati
|
|
$recurrence_zero = array();
|
|
$user = $GLOBALS['egw_info']['user']['account_id'];
|
|
$where = array('cal_id' => $cal_id,
|
|
'cal_recur_date' => 0);
|
|
foreach ($this->db->select($this->user_table,'cal_user_id,cal_user_type,cal_status',$where,
|
|
__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
switch ($row['cal_user_type'])
|
|
{
|
|
case 'u': // account
|
|
case 'c': // contact
|
|
case 'e': // email address
|
|
$uid = self::combine_user($row['cal_user_type'], $row['cal_user_id']);
|
|
$recurrence_zero[$uid] = $row['cal_status'];
|
|
}
|
|
}
|
|
$cached_id = $cal_id;
|
|
}
|
|
|
|
//error_log(__FILE__.'['.__LINE__.'] '.__METHOD__.
|
|
// "($cal_id, $recur_date, $filter)[DEFAULTS]: " .
|
|
// array2string($recurrence_zero));
|
|
|
|
$participants = array();
|
|
$where = array('cal_id' => $cal_id,
|
|
'cal_recur_date' => $recur_date);
|
|
foreach ($this->db->select($this->user_table,'cal_user_id,cal_user_type,cal_status',$where,
|
|
__LINE__,__FILE__,false,'','calendar') as $row)
|
|
{
|
|
switch ($row['cal_user_type'])
|
|
{
|
|
case 'u': // account
|
|
case 'c': // contact
|
|
case 'e': // email address
|
|
$uid = self::combine_user($row['cal_user_type'], $row['cal_user_id']);
|
|
$participants[$uid] = $row['cal_status'];
|
|
}
|
|
}
|
|
|
|
if (empty($participants)) return false; // occurrence does not exist at all yet
|
|
|
|
foreach ($recurrence_zero as $uid => $status)
|
|
{
|
|
if ($uid == $user)
|
|
{
|
|
// handle filter for current user
|
|
switch ($filter)
|
|
{
|
|
case 'unknown':
|
|
if ($status != 'U')
|
|
{
|
|
unset($participants[$uid]);
|
|
continue;
|
|
}
|
|
break;
|
|
case 'accepted':
|
|
if ($status != 'A')
|
|
{
|
|
unset($participants[$uid]);
|
|
continue;
|
|
}
|
|
break;
|
|
case 'tentative':
|
|
if ($status != 'T')
|
|
{
|
|
unset($participants[$uid]);
|
|
continue;
|
|
}
|
|
break;
|
|
case 'rejected':
|
|
if ($status != 'R')
|
|
{
|
|
unset($participants[$uid]);
|
|
continue;
|
|
}
|
|
break;
|
|
case 'delegated':
|
|
if ($status != 'D')
|
|
{
|
|
unset($participants[$uid]);
|
|
continue;
|
|
}
|
|
break;
|
|
case 'default':
|
|
if ($status == 'R')
|
|
{
|
|
unset($participants[$uid]);
|
|
continue;
|
|
}
|
|
break;
|
|
default:
|
|
// All entries
|
|
}
|
|
}
|
|
if (!isset($participants[$uid])
|
|
|| $participants[$uid] != $status)
|
|
return true;
|
|
unset($participants[$uid]);
|
|
}
|
|
return (!empty($participants));
|
|
}
|
|
|
|
/**
|
|
* Check if the event is the whole day
|
|
*
|
|
* @param array $event event (all timestamps in servertime)
|
|
* @return boolean true if whole day event within its timezone, false othwerwise
|
|
*/
|
|
function isWholeDay($event)
|
|
{
|
|
if (!isset($event['start']) || !isset($event['end'])) return false;
|
|
|
|
if (empty($event['tzid']))
|
|
{
|
|
$timezone = egw_time::$server_timezone;
|
|
}
|
|
else
|
|
{
|
|
if (!isset(self::$tz_cache[$event['tzid']]))
|
|
{
|
|
self::$tz_cache[$event['tzid']] = calendar_timezones::DateTimeZone($event['tzid']);
|
|
}
|
|
$timezone = self::$tz_cache[$event['tzid']];
|
|
}
|
|
$start = new egw_time($event['start'],egw_time::$server_timezone);
|
|
$start->setTimezone($timezone);
|
|
$end = new egw_time($event['end'],egw_time::$server_timezone);
|
|
$end->setTimezone($timezone);
|
|
//error_log(__FILE__.'['.__LINE__.'] '.__METHOD__.
|
|
// '(): ' . $start . '-' . $end);
|
|
$start = egw_time::to($start,'array');
|
|
$end = egw_time::to($end,'array');
|
|
|
|
|
|
return !$start['hour'] && !$start['minute'] && $end['hour'] == 23 && $end['minute'] == 59;
|
|
}
|
|
|
|
/**
|
|
* Moves a datetime to the beginning of the day within timezone
|
|
*
|
|
* @param egw_time &time the datetime entry
|
|
* @param string tz_id timezone
|
|
*
|
|
* @return DateTime
|
|
*/
|
|
function &startOfDay(egw_time $time, $tz_id)
|
|
{
|
|
if (empty($tz_id))
|
|
{
|
|
$timezone = egw_time::$server_timezone;
|
|
}
|
|
else
|
|
{
|
|
if (!isset(self::$tz_cache[$tz_id]))
|
|
{
|
|
self::$tz_cache[$tz_id] = calendar_timezones::DateTimeZone($tz_id);
|
|
}
|
|
$timezone = self::$tz_cache[$tz_id];
|
|
}
|
|
return new egw_time($time->format('Y-m-d 00:00:00'), $timezone);
|
|
}
|
|
}
|