forked from extern/egroupware
New classes for importing and scheduling
This commit is contained in:
Nathan Gray
parent
731abfd2a3
commit
822230bf57
134
importexport/inc/class.importexport_import_ui.inc.php
Normal file
134
importexport/inc/class.importexport_import_ui.inc.php
Normal file
@ -0,0 +1,134 @@
|
||||
<?php
|
||||
/**
|
||||
* eGroupWare
|
||||
*
|
||||
* @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
|
||||
* @package importexport
|
||||
* @link http://www.egroupware.org
|
||||
* @author Nathan Gray
|
||||
* @copyright Nathan Gray
|
||||
* @version $Id: class.importexport_import_ui.inc.php 27222 2009-06-08 16:21:14Z ralfbecker $
|
||||
*/
|
||||
|
||||
require_once(EGW_INCLUDE_ROOT. '/importexport/inc/class.import_export_helper_functions.inc.php');
|
||||
require_once(EGW_INCLUDE_ROOT. '/importexport/inc/class.bodefinitions.inc.php');
|
||||
require_once(EGW_INCLUDE_ROOT. '/importexport/inc/class.definition.inc.php');
|
||||
|
||||
|
||||
/**
|
||||
* userinterface for imports
|
||||
*
|
||||
*/
|
||||
|
||||
class importexport_import_ui {
|
||||
|
||||
const _appname = 'importexport';
|
||||
|
||||
public $public_functions = array(
|
||||
'import_dialog' => true,
|
||||
'download' => true,
|
||||
);
|
||||
|
||||
/**
|
||||
* holds all import plugins from all apps
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
private $plugins;
|
||||
|
||||
public function __construct() {
|
||||
$GLOBALS['egw']->js->validate_file('.','import_dialog','importexport');
|
||||
$this->plugins = import_export_helper_functions::get_plugins('all','import');
|
||||
$GLOBALS['egw_info']['flags']['include_xajax'] = true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Step user through importing their file
|
||||
*/
|
||||
public function import_dialog($content = array()) {
|
||||
$appname = $_GET['appname'] ? $_GET['appname'] : $content['appname'];
|
||||
$definition = $_GET['definition'] ? $_GET['definition'] : $content['definition'];
|
||||
|
||||
if($content['import'] && $definition) {
|
||||
try {
|
||||
$definition_obj = new definition($content['definition']);
|
||||
if($content['dry-run']) {
|
||||
$definition_obj->plugin_options = $definition_obj->plugin_options + array('dry_run' => true);
|
||||
}
|
||||
$plugin = new $definition_obj->plugin;
|
||||
$file = fopen($content['file']['tmp_name'], 'r');
|
||||
|
||||
// Some of the translation, conversion, etc look here
|
||||
$GLOBALS['egw_info']['flags']['currentapp'] = $appname;
|
||||
$count = $plugin->import($file, $definition_obj);
|
||||
|
||||
$this->message = lang('%1 records imported successfully', $count);
|
||||
if(count($plugin->get_errors())) {
|
||||
$this->message .= "\n".lang('Unable to import:');
|
||||
foreach($plugin->get_errors() as $record => $message) {
|
||||
$this->message .= "\n$record: $message";
|
||||
}
|
||||
}
|
||||
} catch (Exception $e) {
|
||||
$this->message = $e->getMessage();
|
||||
}
|
||||
}
|
||||
$data['appname'] = $appname;
|
||||
$data['definition'] = $definition;
|
||||
$sel_options = self::get_select_options($data);
|
||||
|
||||
$data['message'] = $this->message;
|
||||
|
||||
$template = new etemplate('importexport.import_dialog');
|
||||
$template->exec('importexport.importexport_import_ui.import_dialog', $data, $sel_options, $readonlys, $preserve, 2);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get options for select boxes
|
||||
*/
|
||||
public static function get_select_options(Array $data) {
|
||||
$options = array();
|
||||
|
||||
(array)$apps = import_export_helper_functions::get_apps('import');
|
||||
$options['appname'] = array('' => lang('Select one')) + array_combine($apps,$apps);
|
||||
|
||||
if($data['appname']) {
|
||||
$options['definition'] = array();
|
||||
|
||||
if($data['file'] && !is_array($data['file'])) {
|
||||
$extension = substr($data['file'], -3);
|
||||
}
|
||||
$definitions = new bodefinitions(array(
|
||||
'type' => 'import',
|
||||
'application' => $data['appname']
|
||||
));
|
||||
foreach ((array)$definitions->get_definitions() as $identifier) {
|
||||
$definition = new definition($identifier);
|
||||
if ($title = $definition->get_title()) {
|
||||
$options['definition'][$title] = $title;
|
||||
}
|
||||
unset($definition);
|
||||
}
|
||||
unset($definitions);
|
||||
}
|
||||
|
||||
return $options;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get definitions via ajax
|
||||
*/
|
||||
public function ajax_get_definitions($appname, $file=null) {
|
||||
$options = self::get_select_options(array('appname'=>$appname, 'file'=>$file));
|
||||
if(is_array($options['definition'])) {
|
||||
foreach ($options['definition'] as $value => $title) {
|
||||
$sel_options['definition'] .= '<option value="'. $value. '" >'. $title. '</option>';
|
||||
}
|
||||
}
|
||||
$response = new xajaxResponse();
|
||||
$response->addScript('import_dialog.change_definition(document.getElementId(\'exec[definition]\'));');
|
||||
$response->addAssign('exec[definition]','innerHTML',$sel_options['definition']);
|
||||
return $response->getXML();
|
||||
}
|
||||
}
|
||||
?>
|
||||
286
importexport/inc/class.importexport_schedule_ui.inc.php
Normal file
286
importexport/inc/class.importexport_schedule_ui.inc.php
Normal file
@ -0,0 +1,286 @@
|
||||
<?php
|
||||
/**
|
||||
* eGroupWare
|
||||
*
|
||||
* @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
|
||||
* @package importexport
|
||||
* @link http://www.egroupware.org
|
||||
* @author Nathan Gray
|
||||
* @copyright Nathan Gray
|
||||
* @version $Id: class.importexport_import_ui.inc.php 27222 2009-06-08 16:21:14Z ralfbecker $
|
||||
*/
|
||||
|
||||
require_once(EGW_INCLUDE_ROOT. '/importexport/inc/class.bodefinitions.inc.php');
|
||||
require_once(EGW_INCLUDE_ROOT. '/importexport/inc/class.definition.inc.php');
|
||||
|
||||
|
||||
/**
|
||||
* userinterface for admins to schedule imports or exports using async services
|
||||
*
|
||||
*/
|
||||
|
||||
class importexport_schedule_ui {
|
||||
|
||||
public $public_functions = array(
|
||||
'index' => true,
|
||||
'edit' => true,
|
||||
);
|
||||
|
||||
protected static $template;
|
||||
|
||||
public function __construct() {
|
||||
$this->template = new etemplate();
|
||||
}
|
||||
|
||||
public function index($content = array()) {
|
||||
|
||||
if($content['scheduled']['delete']) {
|
||||
$key = key($content['scheduled']['delete']);
|
||||
ExecMethod('phpgwapi.asyncservice.cancel_timer', $key);
|
||||
}
|
||||
$async_list = ExecMethod('phpgwapi.asyncservice.read', 'importexport%');
|
||||
foreach($async_list as $id => $async) {
|
||||
$data['scheduled'][] = $async['data'] + array(
|
||||
'id' => $id,
|
||||
'next' => $async['next'],
|
||||
'times' => str_replace("\n", '', print_r($async['times'], true)),
|
||||
);
|
||||
}
|
||||
array_unshift($data['scheduled'], false);
|
||||
$sel_options = self::get_select_options($data);
|
||||
$this->template->read('importexport.schedule_index');
|
||||
|
||||
$GLOBALS['egw_info']['flags']['app_header'] = lang('Schedule import / export');
|
||||
$this->template->exec('importexport.importexport_schedule_ui.index', $data, $sel_options, $readonlys, $preserve);
|
||||
}
|
||||
|
||||
public function edit($content = array()) {
|
||||
$id = $_GET['id'] ? $_GET['id'] : $content['id'];
|
||||
unset($content['id']);
|
||||
|
||||
$data = $content;
|
||||
|
||||
// Deal with incoming
|
||||
if($content['save'] && self::check_target($content) === true) {
|
||||
unset($content['save']);
|
||||
ExecMethod('phpgwapi.asyncservice.cancel_timer', $id);
|
||||
$id = self::generate_id($content);
|
||||
$schedule = $content['schedule'];
|
||||
unset($content['schedule']);
|
||||
|
||||
// Fill in * for any left blank
|
||||
foreach($schedule as $key => &$value) {
|
||||
if($value == '') $value = '*';
|
||||
}
|
||||
$result = ExecMethod2('phpgwapi.asyncservice.set_timer',
|
||||
$schedule,
|
||||
$id,
|
||||
'importexport.importexport_schedule_ui.exec',
|
||||
$content
|
||||
);
|
||||
if($result) {
|
||||
$GLOBALS['egw']->js->set_onload('window.opener.location.reload(); self.close();');
|
||||
} else {
|
||||
$data['message'] = lang('Unable to schedule');
|
||||
unset($id);
|
||||
}
|
||||
}
|
||||
|
||||
if($id) {
|
||||
$preserve['id'] = $id;
|
||||
$async = ExecMethod('phpgwapi.asyncservice.read', $id);
|
||||
if(is_array($async[$id]['data'])) {
|
||||
$data += $async[$id]['data'];
|
||||
$data['schedule'] = $async[$id]['times'];
|
||||
} else {
|
||||
$data['message'] = lang('Schedule not found');
|
||||
}
|
||||
} else {
|
||||
$data['type'] = 'import';
|
||||
}
|
||||
|
||||
if($data['target'] && $data['type']) {
|
||||
$file_check = self::check_target($data);
|
||||
if($file_check !== true) $data['message'] .= ($data['message'] ? "\n" . $file_check : $file_check);
|
||||
}
|
||||
|
||||
$sel_options = self::get_select_options($data);
|
||||
|
||||
$GLOBALS['egw_info']['flags']['app_header'] = lang('Schedule import / export');
|
||||
$this->template->read('importexport.schedule_edit');
|
||||
$this->template->exec('importexport.importexport_schedule_ui.edit', $data, $sel_options, $readonlys, $preserve, 2);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get options for select boxes
|
||||
*/
|
||||
public static function get_select_options(Array $data) {
|
||||
$options = array(
|
||||
'type' => array(
|
||||
'import' => lang('import'),
|
||||
'export' => lang('export')
|
||||
)
|
||||
);
|
||||
|
||||
(array)$apps = import_export_helper_functions::get_apps($data['type'] ? $data['type'] : 'all');
|
||||
if(count($apps)) {
|
||||
$options['appname'] = array('' => lang('Select one')) + array_combine($apps,$apps);
|
||||
}
|
||||
|
||||
if($data['appname']) {
|
||||
$plugins = import_export_helper_functions::get_plugins($data['appname'], $data['type']);
|
||||
if(is_array($plugins[$data['appname']][$data['type']])) {
|
||||
foreach($plugins[$data['appname']][$data['type']] as $key => $title) {
|
||||
$options['plugin'][$key] = $title;
|
||||
}
|
||||
}
|
||||
} else {
|
||||
$plugins = import_export_helper_functions::get_plugins('all', $data['type'] ? $data['type'] : 'all');
|
||||
if(is_array($plugins)) {
|
||||
foreach($plugins as $appname => $_types) {
|
||||
foreach($_types as $type => $plugins) {
|
||||
foreach($plugins as $key => $title) {
|
||||
$options['plugin'][$key] = $title;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
$options['definition'] = array();
|
||||
|
||||
if($data['file'] && !is_array($data['file'])) {
|
||||
$extension = substr($data['file'], -3);
|
||||
}
|
||||
|
||||
// If the query isn't started with something, bodefinitions won't load the definitions
|
||||
$query = array('definition_id');
|
||||
if($data['type']) $query['type'] = $data['type'];
|
||||
if($data['application']) $query['application'] = $data['application'];
|
||||
if($data['plugin']) $query['plugin'] = $data['plugin'];
|
||||
$definitions = new bodefinitions($query);
|
||||
foreach ((array)$definitions->get_definitions() as $identifier) {
|
||||
$definition = new definition($identifier);
|
||||
if ($title = $definition->get_title()) {
|
||||
$options['definition'][$title] = $title;
|
||||
}
|
||||
unset($definition);
|
||||
}
|
||||
unset($definitions);
|
||||
|
||||
return $options;
|
||||
}
|
||||
|
||||
/**
|
||||
* Generate a async key
|
||||
*/
|
||||
public static function generate_id($data) {
|
||||
|
||||
$query = array(
|
||||
'name' => $data['definition']
|
||||
);
|
||||
|
||||
$definitions = new bodefinitions($query);
|
||||
$definition_list = ((array)$definitions->get_definitions());
|
||||
|
||||
$id = 'importexport'.$definition_list[0].time();
|
||||
return $id;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get plugins via ajax
|
||||
*/
|
||||
public function ajax_get_plugins($type, $appname, &$response = null) {
|
||||
if($response) {
|
||||
$return = false;
|
||||
} else {
|
||||
$response = new xajaxResponse();
|
||||
}
|
||||
$options = self::get_select_options(array('type' => $type, 'appname'=>$appname));
|
||||
if(is_array($options['plugins'])) {
|
||||
foreach ($options['plugins'] as $value => $title) {
|
||||
$response->addScript("selectbox_add_option('exec[plugin]','$title', '$value',false);");
|
||||
}
|
||||
}
|
||||
return $response->getXML();
|
||||
}
|
||||
|
||||
/**
|
||||
* Get definitions via ajax
|
||||
*/
|
||||
public function ajax_get_definitions($appname, $plugin) {
|
||||
$options = self::get_select_options(array('appname'=>$appname, 'plugin'=>$plugin));
|
||||
if(is_array($options['definition'])) {
|
||||
foreach ($options['definition'] as $value => $title) {
|
||||
$sel_options['definition'] .= '<option value="'. $value. '" >'. $title. '</option>';
|
||||
}
|
||||
}
|
||||
$response = new xajaxResponse();
|
||||
$response->addAssign('exec[definition]','innerHTML',$sel_options['definition']);
|
||||
return $response->getXML();
|
||||
}
|
||||
|
||||
/**
|
||||
* Check that the target is valid for the type (readable or writable)
|
||||
* $data should contain target & type
|
||||
*/
|
||||
public static function check_target(Array $data) {
|
||||
if ($data['type'] == 'import' && !is_readable($data['target']))
|
||||
{
|
||||
return $data['target']. ' is not readable';
|
||||
}
|
||||
elseif ($data['type'] == 'export' && !is_writable($data['target'])) {
|
||||
return $data['target']. ' is not writable';
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Execute a scheduled import or export
|
||||
*/
|
||||
public static function exec($data) {
|
||||
ob_start();
|
||||
|
||||
// check file
|
||||
$file_check = self::check_target($data);
|
||||
if($file_check !== true) {
|
||||
fwrite(STDERR,'importexport_schedule: ' . date('c') . ": $file_check \n");
|
||||
exit();
|
||||
}
|
||||
|
||||
$definition = new definition($data['definition']);
|
||||
if( $definition->get_identifier() < 1 ) {
|
||||
fwrite(STDERR,'importexport_schedule: ' . date('c') . ": Definition not found! \n");
|
||||
exit();
|
||||
}
|
||||
|
||||
$GLOBALS['egw_info']['flags']['currentapp'] = $definition->application;
|
||||
|
||||
require_once(EGW_INCLUDE_ROOT . "/$definition->application/importexport/class.$definition->plugin.inc.php");
|
||||
$po = new $definition->plugin;
|
||||
|
||||
$type = $data['type'];
|
||||
if($resource = fopen( $data['target'], $data['type'] == 'import' ? 'r' : 'w' )) {
|
||||
$po->$type( $resource, $definition );
|
||||
|
||||
fclose($resource);
|
||||
} else {
|
||||
fwrite(STDERR,'importexport_schedule: ' . date('c') . ": Definition not found! \n");
|
||||
}
|
||||
|
||||
if($po->get_errors()) {
|
||||
fwrite(STDERR, 'importexport_schedule: ' . date('c') . ": Import errors:\n#\tError\n");
|
||||
foreach($po->get_errors() as $record => $error) {
|
||||
fwrite(STDERR, "$record\t$error\n");
|
||||
}
|
||||
}
|
||||
|
||||
$contents = ob_get_contents();
|
||||
if($contents) {
|
||||
fwrite(STDOUT,'importexport_schedule: ' . date('c') . ": \n".$contents);
|
||||
}
|
||||
ob_end_clean();
|
||||
}
|
||||
}
|
||||
?>
|
||||
Loading…
Reference in New Issue
Block a user