* * originaly based on todo written by Joseph Engo * * -------------------------------------------- * * This program is free software; you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the * * Free Software Foundation; either version 2 of the License, or (at your * * option) any later version. * \**************************************************************************/ /* $Id$ */ include_once(EGW_INCLUDE_ROOT.'/infolog/inc/class.soinfolog.inc.php'); /** * This class is the BO-layer of InfoLog, it also handles xmlrpc requests * * @package infolog * @author Ralf Becker * @copyright (c) by Ralf Becker * @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License */ class boinfolog { var $enums; var $so; var $link; var $vfs; var $vfs_basedir='/infolog'; var $valid_pathes = array(); var $send_file_ips = array(); var $xmlrpc_methods = array(); var $soap_functions = array( 'read' => array( 'in' => array('int'), 'out' => array('array') ), 'search' => array( 'in' => array('array'), 'out' => array('array') ), 'write' => array( 'in' => array('array'), 'out' => array() ), 'delete' => array( 'in' => array('int'), 'out' => array() ), 'categories' => array( 'in' => array('bool'), 'out' => array('array') ), ); var $xmlrpc = False; // called via xmlrpc /** * @var int $tz_offset_s offset in secconds between user and server-time, * it need to be add to a server-time to get the user-time or substracted from a user-time to get the server-time */ var $tz_offset = 0; var $tz_offset_s = 0; var $user_time_now; /** * @var array $config infolog configuration */ var $config; /** * Constructor Infolog BO * * @param int $info_id * @param boolean $instanciate_link=true should the link class be instanciated, used by the link-registry to prevent infinit recursion */ function boinfolog($info_id = 0,$instanciate_link=true) { $this->enums = $this->stock_enums = array( 'priority' => array ( 3 => 'urgent', 2 => 'high', 1 => 'normal', 0 => 'low' ), /* 'status' => array( 'offer' => 'offer','ongoing' => 'ongoing','call' => 'call', 'will-call' => 'will-call','done' => 'done', 'billed' => 'billed' ), */ 'confirm' => array( 'not' => 'not','accept' => 'accept','finish' => 'finish', 'both' => 'both' ), 'type' => array( 'task' => 'task','phone' => 'phone','note' => 'note' /* ,'confirm' => 'confirm','reject' => 'reject','email' => 'email', 'fax' => 'fax' not implemented so far */ ) ); $this->status = $this->stock_status = array( 'defaults' => array( 'task' => 'ongoing', 'phone' => 'call', 'note' => 'done'), 'task' => array( 'offer' => 'offer','ongoing' => 'ongoing','done' => 'done', '0%' => '0%', '10%' => '10%', '20%' => '20%', '30%' => '30%', '40%' => '40%', '50%' => '50%', '60%' => '60%', '70%' => '70%', '80%' => '80%', '90%' => '90%', 'billed' => 'billed' ), 'phone' => array( 'call' => 'call','will-call' => 'will-call', 'done' => 'done', 'billed' => 'billed' ), 'note' => array( 'ongoing' => 'ongoing', 'done' => 'done' )); $this->so =& new soinfolog(); if (!is_object($GLOBALS['egw']->link) && $instanciate_link) { $GLOBALS['egw']->link =& CreateObject('phpgwapi.bolink'); } $this->link =& $GLOBALS['egw']->link; $this->config =& CreateObject('phpgwapi.config'); $this->config->read_repository(); $this->customfields = array(); if ($this->config->config_data) { $this->link_pathes = $this->config->config_data['link_pathes']; $this->send_file_ips = $this->config->config_data['send_file_ips']; if (isset($this->config->config_data['status']) && is_array($this->config->config_data['status'])) { foreach($this->config->config_data['status'] as $key => $data) { if (!is_array($this->status[$key])) { $this->status[$key] = array(); } $this->status[$key] = array_merge($this->status[$key],$this->config->config_data['status'][$key]); } } if (isset($this->config->config_data['types']) && is_array($this->config->config_data['types'])) { //echo "stock-types:
"; print_r($this->enums['type']); echo "
\n"; //echo "config-types:
"; print_r($this->config->config_data['types']); echo "
\n"; $this->enums['type'] += $this->config->config_data['types']; //echo "types:
"; print_r($this->enums['type']); echo "
\n"; } if (isset($this->config->config_data['customfields']) && is_array($this->config->config_data['customfields'])) { $this->customfields = $this->config->config_data['customfields']; } $this->user = $GLOBALS['egw_info']['user']['account_id']; } /** * @var int $tz_offset_s offset in secconds between user and server-time, * it need to be add to a server-time to get the user-time or substracted from a user-time to get the server-time */ $this->tz_offset = $GLOBALS['egw_info']['user']['preferences']['common']['tz_offset']; $this->tz_offset_s = 60*60*$this->tz_offset; $this->user_time_now = time() + $this->tz_offset_s; // are we called via xmlrpc? $this->xmlrpc = is_object($GLOBALS['server']) && $GLOBALS['server']->last_method; if ($info_id) { $this->read( $info_id ); } else { $this->init(); } } /** * checks if there are customfields for typ $typ * * @param string $typ * @return boolean True if there are customfields for $typ, else False */ function has_customfields($typ) { foreach($this->customfields as $name => $field) { if (empty($field['typ']) || $field['typ'] == $typ) { return True; } } return False; } /** * check's if user has the requiered rights on entry $info_id * * @param int/array $info data or info_id of infolog entry to check * @param int $required_rights EGW_ACL_{READ|EDIT|ADD|DELETE} * @return boolean */ function check_access( $info,$required_rights ) { static $cache = array(); $info_id = is_array($info) ? $info['info_id'] : $info; if (isset($cache[$info_id][$required_rights])) { return $cache[$info_id][$required_rights]; } return $cache[$info_id][$required_rights] = $this->so->check_access( $info,$required_rights ); } /** * init internal data to be empty */ function init() { $this->so->init(); } /** * convert a link_id value into an info_from text * * @param array &$info infolog entry, key info_from gets set by this function * @param string $not_app='' app to exclude * @param string $not_id='' id to exclude * @return boolean True if we have a linked item, False otherwise */ function link_id2from(&$info,$not_app='',$not_id='') { //echo "

boinfolog::link_id2from(subject='$info[info_subject]', link_id='$info[info_link_id], from='$info[info_from]', not_app='$not_app', not_id='$not_id')"; if ($info['info_link_id'] > 0 && ($link = $this->link->get_link($info['info_link_id'])) !== False) { $nr = $link['link_app1'] == 'infolog' && $link['link_id1'] == $info['info_id'] ? '2' : '1'; $title = $this->link->title($link['link_app'.$nr],$link['link_id'.$nr]); if ($title == $info['info_from'] || @htmlentities($title) == $info['info_from']) { $info['info_from'] = ''; } if ($link['link_app'.$nr] == $not_app && $link['link_id'.$nr] == $not_id) { return False; } $info['info_link'] = array( 'app' => $link['link_app'.$nr], 'id' => $link['link_id'.$nr], 'title' => (!empty($info['info_from']) ? $info['info_from'] : $title), ); //echo " title='$title'

\n"; return $info['blur_title'] = $title; } else { $info['info_link'] = array('title' => $info['info_from']); $info['info_link_id'] = 0; // link might have been deleted } return False; } /** * Create a subject from a description: truncate it and add ' ...' */ function subject_from_des($des) { return substr($des,0,60).' ...'; } /** * Read an infolog entry specified by $info_id * * @param int/array $info_id integer id or array with key 'info_id' of the entry to read * @return array/boolean infolog entry or False if not found or no permission to read it */ function &read($info_id) { if (is_array($info_id)) { $info_id = (int)$info_id['info_id']; } if ($this->so->read($info_id) === False) { if ($this->xmlrpc) { $GLOBALS['server']->xmlrpc_error($GLOBALS['xmlrpcerr']['not_exist'],$GLOBALS['xmlrpcstr']['not_exist']); } return False; } if (!$this->check_access($info_id,EGW_ACL_READ)) // check behind read, to prevent a double read { if ($this->xmlrpc) { $GLOBALS['server']->xmlrpc_error($GLOBALS['xmlrpcerr']['no_access'],$GLOBALS['xmlrpcstr']['no_access']); } return False; } $data = $this->so->data; if ($data['info_subject'] == $this->subject_from_des($data['info_des'])) { $data['info_subject'] = ''; } $this->link_id2from($data); // convert system- to user-time foreach(array('info_startdate','info_enddate','info_datemodified') as $time) { if ($data[$time]) $data[$time] += $this->tz_offset_s; } if ($this->xmlrpc) { $data = $this->data2xmlrpc($data); } return $data; } /** * Delete an infolog entry, evtl. incl. it's children / subs * * @param int/array $info_id int id or array with keys 'info_id', 'delete_children' and 'new_parent' setting all 3 params * @param boolean $delete_children should the children be deleted * @param int/boolean $new_parent parent to use for not deleted children if > 0 * @return boolean True if delete was successful, False otherwise ($info_id does not exist or no rights) */ function delete($info_id,$delete_children=False,$new_parent=False) { if (is_array($info_id)) { $delete_children = $info_id['delete_children']; $new_parent = $info_id['new_parent']; $info_id = (int)(isset($info_id[0]) ? $info_id[0] : (isset($info_id['info_id']) ? $info_id['info_id'] : $info_id['info_id'])); } if ($this->so->read($info_id) === False) { if ($this->xmlrpc) { $GLOBALS['server']->xmlrpc_error($GLOBALS['xmlrpcerr']['not_exist'],$GLOBALS['xmlrpcstr']['not_exist']); } return False; } if (!$this->check_access($info_id,EGW_ACL_DELETE)) { if ($this->xmlrpc) { $GLOBALS['server']->xmlrpc_error($GLOBALS['xmlrpcerr']['no_access'],$GLOBALS['xmlrpcstr']['no_access']); } return False; } $this->link->unlink(0,'infolog',$info_id); $info = $this->read($info_id); $this->so->delete($info_id,$delete_children,$new_parent); $GLOBALS['egw']->contenthistory->updateTimeStamp('infolog_'.$info['info_type'], $info_id, 'delete', time()); return True; } /** * writes the given $values to InfoLog, a new entry gets created if info_id is not set or 0 * * checks and asures ACL * * @param array &$values values to write, if contains values for check_defaults and touch_modified, * they have precedens over the parameters. The * @param boolean $check_defaults=true check and set certain defaults * @param boolean $touch_modified=true touch the modification data and sets the modiefier's user-id * @return int/boolean info_id on a successfull write or false */ function write(&$values,$check_defaults=True,$touch_modified=True) { //echo "boinfolog::write()values="; _debug_array($values); // allow to (un)set check_defaults and touch_modified via values, eg. via xmlrpc foreach(array('check_defaults','touch_modified') as $var) { if(isset($values[$var])) { $$var = $values[$var]; unset($values[$var]); } } // fix old names foreach($values as $key => $val) { if ($key[0] != '#' && substr($key,0,5) != 'info_') { $values['info_'.$key] = $val; unset($values[$key]); } } if ($status_only = $values['info_id'] && !$this->check_access($values['info_id'],EGW_ACL_EDIT)) { if (!isset($values['info_responsible'])) { if (!($values_read = $this->read($values['info_id']))) return false; $responsible =& $values_read['info_responsible']; } else { $responsible =& $values['info_responsible']; } $status_only = in_array($this->user, $responsible); // responsible has implicit right to change status } if ($values['info_id'] && !$this->check_access($values['info_id'],EGW_ACL_EDIT) && !$status_only || !$values['info_id'] && $values['info_id_parent'] && !$this->check_access($values['info_id_parent'],EGW_ACL_ADD)) { if ($this->xmlrpc) { $GLOBALS['server']->xmlrpc_error($GLOBALS['xmlrpcerr']['no_access'],$GLOBALS['xmlrpcstr']['no_access']); } return False; } if ($this->xmlrpc) { $values = $this->xmlrpc2data($values); } if ($status_only) // make sure only status gets writen { $set_enddate = !$values['info_enddate'] && // set enddate of finished job, only if its not already set ($values['info_status'] == 'done' || $values['info_status'] == 'billed'); $backup_values = $values; // to return the full values $values = array( 'info_id' => $values['info_id'], 'info_status' => $values['info_status'], 'info_owner' => $values['info_owner'], 'info_datemodified' => $values['info_datemodified'], ); if ($set_enddate) { $values['info_enddate'] = $this->user_time_now; } $check_defaults = False; } if ($check_defaults) { if (!$values['info_enddate'] && ($values['info_status'] == 'done' || $values['info_status'] == 'billed')) { $values['info_enddate'] = $this->user_time_now; // set enddate to today if status == done } if (count($values['info_responsible']) && $values['info_status'] == 'offer') { $values['info_status'] = 'ongoing'; // have to match if not finished } if (isset($values['info_subject']) && empty($values['info_subject'])) { $values['info_subject'] = $this->subject_from_des($values['info_des']); } } if (!$values['info_id'] && !$values['info_owner']) { $values['info_owner'] = $this->so->user; } if ($values['info_link_id'] && isset($values['info_from']) && empty($values['info_from'])) { $values['info_from'] = $this->link_id2from($values); } if ($touch_modified || !$values['info_datemodified']) { $check_modified = $values['info_datemodified'] ? $values['info_datemodified']-$this->tz_offset_s : false; $values['info_datemodified'] = $this->user_time_now; } if ($touch_modified || !$values['info_modifier']) { $values['info_modifier'] = $this->so->user; } $to_write = $values; if ($status_only) $values = array_merge($backup_values,$values); // convert user- to system-time foreach(array('info_startdate','info_enddate','info_datemodified') as $time) { if ($to_write[$time]) $to_write[$time] -= $this->tz_offset_s; } if(($info_id = $this->so->write($to_write,$check_modified))) { if (!isset($values['info_type']) || $status_only) { $values = $this->read($info_id); } if($values['info_id']) { // update $GLOBALS['egw']->contenthistory->updateTimeStamp( 'infolog_'.$values['info_type'], $info_id, 'modify', time() ); } else { // add $GLOBALS['egw']->contenthistory->updateTimeStamp( 'infolog_'.$values['info_type'], $info_id, 'add', time() ); } $values['info_id'] = $info_id; // notify the link-class about the update, as other apps may be subscribt to it $this->link->notify_update('infolog',$info_id,$values); } return $info_id; } /** * Query the number of children / subs * * @param int $info_id id * @return int number of subs */ function anzSubs( $info_id ) { return $this->so->anzSubs( $info_id ); } /** * searches InfoLog for a certain pattern in $query * * @param $query[order] column-name to sort after * @param $query[sort] sort-order DESC or ASC * @param $query[filter] string with combination of acl-, date- and status-filters, eg. 'own-open-today' or '' * @param $query[cat_id] category to use or 0 or unset * @param $query[search] pattern to search, search is done in info_from, info_subject and info_des * @param $query[action] / $query[action_id] if only entries linked to a specified app/entry show be used * @param &$query[start], &$query[total] nextmatch-parameters will be used and set if query returns less entries * @param $query[col_filter] array with column-name - data pairs, data == '' means no filter (!) * @return array with id's as key of the matching log-entries */ function &search(&$query) { //echo "

boinfolog::search(".print_r($query,True).")

\n"; $ret = $this->so->search($query); // convert system- to user-time if (is_array($ret) && $this->tz_offset_s) { foreach($ret as $id => $data) { foreach(array('info_startdate','info_enddate','info_datemodified') as $time) { if ($data[$time]) $ret[$id][$time] += $this->tz_offset_s; } } } if ($this->xmlrpc && is_array($ret)) { $infos = $ret; $ret = array(); foreach($infos as $id => $data) { $ret[] = $this->data2xmlrpc($data); } } //echo "

boinfolog::search(".print_r($query,True).")=

".print_r($ret,True)."
\n"; return $ret; } /** * Hook called by link-class to include infolog in the appregistry of the linkage * * @param array/string $location location and other parameters (not used) * @return array with method-names */ function search_link($location) { return array( 'query' => 'infolog.boinfolog.link_query', 'title' => 'infolog.boinfolog.link_title', 'view' => array( 'menuaction' => 'infolog.uiinfolog.index', 'action' => 'sp' ), 'view_id' => 'action_id', 'add' => array( 'menuaction' => 'infolog.uiinfolog.edit', 'type' => 'task' ), 'add_app' => 'action', 'add_id' => 'action_id', 'add_popup' => '750x550', ); } /** * get title for an infolog entry identified by $info * * Is called as hook to participate in the linking * * @param int/array $info int info_id or array with infolog entry * @return string the title */ function link_title( $info ) { if (!is_array($info)) { $info = $this->read( $info ); } if (!$info) { return False; } return !empty($info['info_subject']) ? $info['info_subject'] : $this->subject_from_des($info['info_descr']); } /** * query infolog for entries matching $pattern * * Is called as hook to participate in the linking * * @param string $pattern pattern to search * @return array with info_id - title pairs of the matching entries */ function link_query( $pattern ) { $query = array( 'search' => $pattern, 'start' => 0, 'subs' => true, ); $ids = $this->search($query); $content = array(); if (is_array($ids)) { foreach($ids as $id => $info ) { $content[$id] = $this->link_title($id); } } return $content; } /** * hook called be calendar to include events or todos in the cal-dayview * * @param int $args[year], $args[month], $args[day] date of the events * @param int $args[owner] owner of the events * @param string $args[location] calendar_include_{events|todos} * @return array of events (array with keys starttime, endtime, title, view, icon, content) */ function cal_to_include($args) { //echo "

cal_to_include("; print_r($args); echo ")

\n"; $user = intval($args['owner']); if ($user <= 0 && !checkdate($args['month'],$args['day'],$args['year'])) { return False; } if (!is_object($GLOBALS['egw']->html)) { $GLOBALS['egw']->html =& CreateObject('phpgwapi.html'); } $GLOBALS['egw']->translation->add_app('infolog'); $do_events = $args['location'] == 'calendar_include_events'; $to_include = array(); $date_wanted = sprintf('%04d/%02d/%02d',$args['year'],$args['month'],$args['day']); $query = array( 'order' => 'info_startdate', 'sort' => $do_events ? 'ASC' : 'DESC', 'filter'=> "user$user".($do_events ? 'date' : 'opentoday').$date_wanted, 'start' => 0, ); while ($infos = $this->search($query)) { foreach($infos as $info) { $time = (int) adodb_date('Hi',$info['info_startdate']); $date = adodb_date('Y/m/d',$info['info_startdate']); if ($do_events && !$time || !$do_events && $time && $date == $date_wanted) { continue; } $title = ($do_events?$GLOBALS['egw']->common->formattime(adodb_date('H',$info['info_startdate']),adodb_date('i',$info['info_startdate'])).' ':''). $info['info_subject']; $view = $this->link->view('infolog',$info['info_id']); $content=array(); foreach($icons = array( $info['info_type'] => 'infolog', $info['info_status'] => 'infolog' ) as $name => $app) { $content[] = $GLOBALS['egw']->html->image($app,$name,lang($name),'border="0" width="15" height="15"').' '; } $content[] = $GLOBALS['egw']->html->a_href($title,$view); $content = $GLOBALS['egw']->html->table(array(1 => $content)); $to_include[] = array( 'starttime' => $info['info_startdate'], 'endtime' => ($info['info_enddate'] ? $info['info_enddate'] : $info['info_startdate']), 'title' => $title, 'view' => $view, 'icons' => $icons, 'content' => $content ); } if ($query['total'] <= ($query['start']+=count($infos))) { break; // no more availible } } //echo "boinfolog::cal_to_include("; print_r($args); echo ")
"; print_r($to_include); echo "
\n"; return $to_include; } /** * handles introspection or discovery by the logged in client, * in which case the input might be an array. The server always calls * this function to fill the server dispatch map using a string. * * @param string $_type='xmlrpc' xmlrpc or soap * @return array */ function list_methods($_type='xmlrpc') { if (is_array($_type)) { $_type = $_type['type'] ? $_type['type'] : $_type[0]; } switch($_type) { case 'xmlrpc': $xml_functions = array( 'read' => array( 'function' => 'read', 'signature' => array(array(xmlrpcInt,xmlrpcInt)), 'docstring' => lang('Read one record by passing its id.') ), 'search' => array( 'function' => 'search', 'signature' => array(array(xmlrpcStruct,xmlrpcStruct)), 'docstring' => lang('Returns a list / search for records.') ), 'write' => array( 'function' => 'write', 'signature' => array(array(xmlrpcStruct,xmlrpcStruct)), 'docstring' => lang('Write (add or update) a record by passing its fields.') ), 'delete' => array( 'function' => 'delete', 'signature' => array(array(xmlrpcInt,xmlrpcInt)), 'docstring' => lang('Delete one record by passing its id.') ), 'categories' => array( 'function' => 'categories', 'signature' => array(array(xmlrpcBoolean,xmlrpcBoolean)), 'docstring' => lang('List all categories') ), 'list_methods' => array( 'function' => 'list_methods', 'signature' => array(array(xmlrpcStruct,xmlrpcString)), 'docstring' => lang('Read this list of methods.') ) ); return $xml_functions; break; case 'soap': return $this->soap_functions; break; default: return array(); break; } } /** * Convert an InfoLog entry into its xmlrpc representation, eg. convert timestamps to datetime.iso8601 * * @param array $data infolog entry * @param array xmlrpc infolog entry */ function data2xmlrpc($data) { $data['rights'] = $this->so->grants[$data['info_owner']]; // translate timestamps foreach(array('info_startdate','info_enddate','info_datemodified') as $name) { if (isset($data[$name])) { $data[$name] = $GLOBALS['server']->date2iso8601($data[$name]); } } // translate cat_id if (isset($data['info_cat'])) { $data['info_cat'] = $GLOBALS['server']->cats2xmlrpc(array($data['info_cat'])); } foreach($data as $name => $val) { if (substr($name,0,5) == 'info_') { unset($data[$name]); $data[substr($name,5)] = $val; } } return $data; } /** * Convert an InfoLog xmlrpc representation into the internal one, eg. convert datetime.iso8601 to timestamps * * @param array $data infolog entry * @param array xmlrpc infolog entry */ function xmlrpc2data($data) { foreach($data as $name => $val) { if (substr($name,0,5) != 'info_') { unset($data[$name]); $data['info_'.$name] = $val; } } // translate timestamps foreach(array('info_startdate','info_enddate','info_datemodified') as $name) { if (isset($data[$name])) { $data[$name] = $GLOBALS['server']->iso86012date($data[$name],True); } } // translate cat_id if (isset($data['info_cat'])) { $cats = $GLOBALS['server']->xmlrpc2cats($data['info_cat']); $data['info_cat'] = (int)$cats[0]; } return $data; } /** * return array with all infolog categories (for xmlrpc) * * @param boolean $complete true returns array with all data for each cat, else only the title is returned * @return array with cat_id / title or data pairs (see above) */ function categories($complete = False) { return $this->xmlrpc ? $GLOBALS['server']->categories($complete) : False; } }