forked from extern/egroupware
525 lines
14 KiB
PHP
525 lines
14 KiB
PHP
<?php
|
|
/**
|
|
* eGroupWare
|
|
*
|
|
* @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
|
|
* @package timesheet
|
|
* @subpackage importexport
|
|
* @link http://www.egroupware.org
|
|
* @author Nathan Gray
|
|
* @copyright 2011 Nathan Gray
|
|
* @version $Id$
|
|
*/
|
|
|
|
use EGroupware\Api;
|
|
use EGroupware\Api\Link;
|
|
|
|
/**
|
|
* class import_csv for timesheet
|
|
*/
|
|
class timesheet_import_csv extends importexport_basic_import_csv
|
|
{
|
|
public static $special_fields = array(
|
|
'addressbook' => 'Link to Addressbook, use nlast,nfirst[,org] or contact_id from addressbook',
|
|
'link_1' => '1. link: appname:appid the entry should be linked to, eg.: addressbook:123',
|
|
'link_2' => '2. link: appname:appid the entry should be linked to, eg.: addressbook:123',
|
|
'link_3' => '3. link: appname:appid the entry should be linked to, eg.: addressbook:123',
|
|
);
|
|
|
|
/**
|
|
* conditions for actions
|
|
*
|
|
* @var array
|
|
*/
|
|
protected static $conditions = array( 'exists' );
|
|
|
|
/**
|
|
* @var business object
|
|
*/
|
|
private $bo;
|
|
|
|
/**
|
|
* For figuring out if a record has changed
|
|
*/
|
|
protected $tracking;
|
|
|
|
/**
|
|
* Initialize for import
|
|
*
|
|
* @param definition $_definition
|
|
*/
|
|
protected function init( importexport_definition $_definition, importexport_import_csv &$import_csv )
|
|
{
|
|
// fetch the bo
|
|
$this->bo = new timesheet_bo();
|
|
|
|
// Get the tracker for changes
|
|
$this->tracking = new timesheet_tracking($this->bo);
|
|
|
|
// Add extra conversions
|
|
$import_csv->conversion_class = $this;
|
|
|
|
// set Owner
|
|
$plugin_options = $_definition->plugin_options;
|
|
$plugin_options['record_owner'] = isset( $_definition->plugin_options['record_owner'] ) ?
|
|
$_definition->plugin_options['record_owner'] : $this->user;
|
|
$_definition->plugin_options = $plugin_options;
|
|
|
|
// For converting human-friendly lookups
|
|
$this->lookups = array(
|
|
'ts_status' => $this->bo->status_labels
|
|
);
|
|
|
|
// Status need leading spaces removed
|
|
foreach($this->lookups['ts_status'] as $id => &$label)
|
|
{
|
|
$label = str_replace(' ', '',trim($label));
|
|
if($label == '') unset($this->lookups['ts_status'][$id]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
*Import a single record
|
|
*
|
|
* You don't need to worry about mappings or translations, they've been done already.
|
|
* You do need to handle the conditions and the actions taken.
|
|
*
|
|
* Updates the count of actions taken
|
|
*
|
|
* @return boolean success
|
|
*/
|
|
protected function import_record(importexport_iface_egw_record &$record, &$import_csv)
|
|
{
|
|
// Reset BO data for new record
|
|
$this->bo->data = array();
|
|
|
|
// Automatically handle text Api\Categories without explicit Api\Translation
|
|
foreach(array('ts_status','cat_id') as $field)
|
|
{
|
|
if(!is_numeric($record->$field))
|
|
{
|
|
$translate_key = 'translate'.(substr($field,0,2) == 'ts' ? substr($field,2) : '_cat_id');
|
|
if(!is_null($this->lookups[$field]) && ($key = array_search($record->$field, $this->lookups[$field])))
|
|
{
|
|
$record->$field = $key;
|
|
}
|
|
elseif(array_key_exists($translate_key, $_definition->plugin_options))
|
|
{
|
|
$t_field = $_definition->plugin_options[$translate_key];
|
|
switch ($t_field)
|
|
{
|
|
case '':
|
|
case '0':
|
|
// Skip that field
|
|
unset($record->$field);
|
|
break;
|
|
case '~skip~':
|
|
continue 2;
|
|
default:
|
|
if(strpos($t_field, 'add') === 0)
|
|
{
|
|
// Check for a parent
|
|
list($name, $parent_name) = explode('~',$t_field);
|
|
if($parent_name)
|
|
{
|
|
$parent = importexport_helper_functions::cat_name2id($parent_name);
|
|
}
|
|
|
|
if($field == 'cat_id')
|
|
{
|
|
$record->$field = importexport_helper_functions::cat_name2id($record->$field, $parent);
|
|
}
|
|
elseif ($field == 'ts_status')
|
|
{
|
|
end($this->bo->status_labels);
|
|
$id = key($this->bo->status_labels)+1;
|
|
$this->bo->status_labels[$id] = $record->$field;
|
|
$this->bo->status_labels_config[$id] = array(
|
|
'name' => $record->$field,
|
|
'parent' => $parent,
|
|
'admin' => false
|
|
);
|
|
Api\Config::save_value('status_labels',$this->bo->status_labels_config,TIMESHEET_APP);
|
|
$lookups[$field][$id] = $name;
|
|
$record->$field = $id;
|
|
}
|
|
}
|
|
elseif(!is_null($lookups[$field]) && ($key = array_search($t_field, $lookups[$field])))
|
|
{
|
|
$record->$field = $key;
|
|
}
|
|
else
|
|
{
|
|
$record->$field = $t_field;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// Set creator, unless it's supposed to come from CSV file
|
|
if($_definition->plugin_options['owner_from_csv'] && $record->ts_owner)
|
|
{
|
|
if(!is_numeric($record->ts_owner))
|
|
{
|
|
// Automatically handle text owner without explicit Api\Translation
|
|
$new_owner = importexport_helper_functions::account_name2id($record->ts_owner);
|
|
if($new_owner == '')
|
|
{
|
|
$this->errors[$import_csv->get_current_position()] = lang(
|
|
'Unable to convert "%1" to account ID. Using plugin setting (%2) for %3.',
|
|
$record->ts_owner,
|
|
Api\Accounts::username($_definition->plugin_options['record_owner']),
|
|
lang($this->bo->field2label['ts_owner'])
|
|
);
|
|
$record->ts_owner = $_definition->plugin_options['record_owner'];
|
|
}
|
|
else
|
|
{
|
|
$record->ts_owner = $new_owner;
|
|
}
|
|
}
|
|
}
|
|
elseif ($_definition->plugin_options['record_owner'])
|
|
{
|
|
$record->ts_owner = $_definition->plugin_options['record_owner'];
|
|
}
|
|
|
|
// Check account IDs
|
|
foreach(array('ts_modifier') as $field)
|
|
{
|
|
if($record->$field && !is_numeric($record->$field))
|
|
{
|
|
// Try an automatic conversion
|
|
$account_id = importexport_helper_functions::account_name2id($record->$field);
|
|
if($account_id && strtoupper(Api\Accounts::username($account_id)) == strtoupper($record->$field))
|
|
{
|
|
$record->$field = $account_id;
|
|
}
|
|
else
|
|
{
|
|
$this->errors[$import_csv->get_current_position()] = lang(
|
|
'Unable to convert "%1" to account ID. Using plugin setting (%2) for %3.',
|
|
$record->$field,
|
|
Api\Accounts::username($_definition->plugin_options['record_owner']),
|
|
$this->bo->field2label[$field] ? lang($this->bo->field2label[$field]) : $field
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Special values
|
|
if ($record->addressbook && !is_numeric($record->addressbook))
|
|
{
|
|
list($lastname,$firstname,$org_name) = explode(',',$record->addressbook);
|
|
$record->addressbook = self::addr_id($lastname,$firstname,$org_name);
|
|
}
|
|
if ($record->pm_id && !is_numeric($record->pm_id))
|
|
{
|
|
$pms = Link::query('projectmanager',$record->pm_id);
|
|
$record->pm_id = key($pms);
|
|
}
|
|
|
|
if ( $_definition->plugin_options['conditions'] )
|
|
{
|
|
foreach ( $_definition->plugin_options['conditions'] as $condition )
|
|
{
|
|
$results = array();
|
|
switch ( $condition['type'] )
|
|
{
|
|
// exists
|
|
case 'exists' :
|
|
if($record->$condition['string'])
|
|
{
|
|
$results = $this->bo->search(array($condition['string'] => $record->$condition['string']));
|
|
}
|
|
|
|
if ( is_array( $results ) && count( array_keys( $results )) >= 1 )
|
|
{
|
|
// apply action to all records matching this exists condition
|
|
$action = $condition['true'];
|
|
foreach ( (array)$results as $result )
|
|
{
|
|
$record->ts_id = $result['ts_id'];
|
|
if ( $_definition->plugin_options['update_cats'] == 'add' )
|
|
{
|
|
if ( !is_array( $result['cat_id'] ) ) $result['cat_id'] = explode( ',', $result['cat_id'] );
|
|
if ( !is_array( $record->cat_id ) ) $record->cat_id = explode( ',', $record->cat_id );
|
|
$record->cat_id = implode( ',', array_unique( array_merge( $record->cat_id, $result['cat_id'] ) ) );
|
|
}
|
|
$success = $this->action( $action['action'], $record, $import_csv->get_current_position() );
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$action = $condition['false'];
|
|
$success = ($this->action( $action['action'], $record, $import_csv->get_current_position() ));
|
|
}
|
|
break;
|
|
|
|
// not supported action
|
|
default :
|
|
die('condition / action not supported!!!');
|
|
break;
|
|
}
|
|
if ($action['last']) break;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// unconditional insert
|
|
$success = $this->action( 'insert', $record, $import_csv->get_current_position() );
|
|
}
|
|
|
|
return $success;
|
|
}
|
|
|
|
/**
|
|
* perform the required action
|
|
*
|
|
* @param int $_action one of $this->actions
|
|
* @param array $_data tracker data for the action
|
|
* @return bool success or not
|
|
*/
|
|
protected function action ( $_action, importexport_iface_egw_record &$record, $record_num = 0 )
|
|
{
|
|
$_data = $record->get_record_array();
|
|
$result = true;
|
|
switch ($_action)
|
|
{
|
|
case 'none' :
|
|
return true;
|
|
case 'update' :
|
|
// Only update if there are changes
|
|
$old_record = new timesheet_egw_record($_data['ts_id']);
|
|
$old = $old_record->get_record_array();
|
|
|
|
if(!$this->definition->plugin_options['change_owner'])
|
|
{
|
|
// Don't change creator of an existing ticket
|
|
unset($_data['ts_owner']);
|
|
}
|
|
|
|
// Merge to deal with fields not in import record
|
|
$_data = array_merge($old, $_data);
|
|
$changed = $this->tracking->changed_fields($_data, $old);
|
|
if(count($changed) == 0 && !$this->definition->plugin_options['update_timestamp'])
|
|
{
|
|
break;
|
|
}
|
|
|
|
// Clear old link, if different
|
|
if ($_data['ts_id'] && array_key_exists('pm_id', $_data) && $_data['pm_id'] != $old['pm_id'])
|
|
{
|
|
Link::unlink2(0,TIMESHEET_APP,$_data['ts_id'],0,'projectmanager',$old['pm_id']);
|
|
}
|
|
|
|
// Fall through
|
|
case 'insert' :
|
|
if ( $this->dry_run )
|
|
{
|
|
//print_r($_data);
|
|
$this->results[$_action]++;
|
|
break;
|
|
}
|
|
else
|
|
{
|
|
$result = $this->bo->save( $_data);
|
|
$_data['ts_id'] = $this->bo->data['ts_id'];
|
|
|
|
// Set projectmanager link
|
|
if ($_data['pm_id'])
|
|
{
|
|
Link::link(TIMESHEET_APP,$_data['ts_id'],'projectmanager',$_data['pm_id']);
|
|
|
|
// notify the link-class about the update, as other apps may be subscribed to it
|
|
Link::notify_update(TIMESHEET_APP,$this->data['ts_id'],$this->data);
|
|
}
|
|
|
|
if($result)
|
|
{
|
|
$this->errors[$record_num] = lang('Permissions error - %1 could not %2',
|
|
$GLOBALS['egw']->accounts->id2name($_data['owner']),
|
|
lang($_action)
|
|
) . ' ' . $result;
|
|
}
|
|
else
|
|
{
|
|
$this->results[$_action]++;
|
|
$result = $this->bo->data['ts_id'];
|
|
}
|
|
break;
|
|
}
|
|
default:
|
|
throw new Api\Exception('Unsupported action');
|
|
}
|
|
|
|
// Process some additional fields
|
|
if(!is_numeric($result))
|
|
{
|
|
return $result;
|
|
}
|
|
$_link_id = false;
|
|
foreach(self::$special_fields as $field => $desc)
|
|
{
|
|
if(!$_data[$field]) continue;
|
|
|
|
// Links
|
|
if(strpos($field, 'link') === 0)
|
|
{
|
|
list($app, $app_id) = explode(':', $_data[$field]);
|
|
}
|
|
else
|
|
{
|
|
$app = $field;
|
|
$app_id = $_data[$field];
|
|
}
|
|
if ($app && $app_id)
|
|
{
|
|
$link_id = Link::link('timesheet',$_data['ts_id'],$app,$app_id);
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* returns translated name of plugin
|
|
*
|
|
* @return string name
|
|
*/
|
|
public static function get_name()
|
|
{
|
|
return lang('Timesheet CSV import');
|
|
}
|
|
|
|
/**
|
|
* returns translated (user) description of plugin
|
|
*
|
|
* @return string descriprion
|
|
*/
|
|
public static function get_description()
|
|
{
|
|
return lang("Imports entries into the timesheet from a CSV File. ");
|
|
}
|
|
|
|
/**
|
|
* retruns file suffix(s) plugin can handle (e.g. csv)
|
|
*
|
|
* @return string suffix (comma seperated)
|
|
*/
|
|
public static function get_filesuffix()
|
|
{
|
|
return 'csv';
|
|
}
|
|
|
|
/**
|
|
* return etemplate components for options.
|
|
* @abstract We can't deal with etemplate objects here, as an uietemplate
|
|
* objects itself are scipt orientated and not "dialog objects"
|
|
*
|
|
* @return array (
|
|
* name => string,
|
|
* content => array,
|
|
* sel_options => array,
|
|
* preserv => array,
|
|
* )
|
|
*/
|
|
public function get_options_etpl(importexport_definition &$definition=null)
|
|
{
|
|
// lets do it!
|
|
}
|
|
|
|
/**
|
|
* returns etemplate name for slectors of this plugin
|
|
*
|
|
* @return string etemplate name
|
|
*/
|
|
public function get_selectors_etpl()
|
|
{
|
|
// lets do it!
|
|
}
|
|
|
|
/**
|
|
* Returns warnings that were encountered during importing
|
|
* Maximum of one warning message per record, but you can append if you need to
|
|
*
|
|
* @return Array (
|
|
* record_# => warning message
|
|
* )
|
|
*/
|
|
public function get_warnings()
|
|
{
|
|
return $this->warnings;
|
|
}
|
|
|
|
/**
|
|
* Returns errors that were encountered during importing
|
|
* Maximum of one error message per record, but you can append if you need to
|
|
*
|
|
* @return Array (
|
|
* record_# => error message
|
|
* )
|
|
*/
|
|
public function get_errors()
|
|
{
|
|
return $this->errors;
|
|
}
|
|
|
|
/**
|
|
* Returns a list of actions taken, and the number of records for that action.
|
|
* Actions are things like 'insert', 'update', 'delete', and may be different for each plugin.
|
|
*
|
|
* @return Array (
|
|
* action => record count
|
|
* )
|
|
*/
|
|
public function get_results()
|
|
{
|
|
return $this->results;
|
|
}
|
|
// end of iface_export_plugin
|
|
|
|
// Extra conversion functions - must be static
|
|
public static function addr_id( $n_family,$n_given=null,$org_name=null )
|
|
{
|
|
|
|
// find in Addressbook, at least n_family AND (n_given OR org_name) have to match
|
|
static $contacts;
|
|
if (is_null($n_given) && is_null($org_name))
|
|
{
|
|
// Maybe all in one
|
|
list($n_family, $n_given, $org_name) = explode(',', $n_family);
|
|
}
|
|
$n_family = trim($n_family);
|
|
if(!is_null($n_given)) $n_given = trim($n_given);
|
|
if (!is_object($contacts))
|
|
{
|
|
$contacts =& CreateObject('phpgwapi.contacts');
|
|
}
|
|
if (!is_null($org_name)) // org_name given?
|
|
{
|
|
$org_name = trim($org_name);
|
|
$addrs = $contacts->read( 0,0,array('id'),'',"n_family=$n_family,n_given=$n_given,org_name=$org_name" );
|
|
if (!count($addrs))
|
|
{
|
|
$addrs = $contacts->read( 0,0,array('id'),'',"n_family=$n_family,org_name=$org_name",'','n_family,org_name');
|
|
}
|
|
}
|
|
if (!is_null($n_given) && (is_null($org_name) || !count($addrs))) // first name given and no result so far
|
|
{
|
|
$addrs = $contacts->search(array('n_family' => $n_family, 'n_given' => $n_given));
|
|
}
|
|
if (is_null($n_given) && is_null($org_name)) // just one name given, check against fn (= full name)
|
|
{
|
|
$addrs = $contacts->read( 0,0,array('id'),'',"n_fn=$n_family",'','n_fn' );
|
|
}
|
|
if (count($addrs))
|
|
{
|
|
return $addrs[0]['id'];
|
|
}
|
|
return False;
|
|
}
|
|
}
|
|
?>
|