| '.
self::createSubmitButton(i18n::translate('< Previous'), $this->prev_xref).
self::createSubmitButton(i18n::translate('Next >'), $this->next_xref).
' | | '.
'
'.
'
'.implode('
',$this->PLUGIN->getActionButtons($this->curr_xref, $this->record)).'
'.
' | '.
$this->PLUGIN->getActionPreview($this->curr_xref, $this->record);
' |
';
} else {
$html.='| '.i18n::translate('Nothing found.').' |
';
}
}
}
$html.='
';
return $html.mod_print_footer();
}
// Constructor - initialise variables and validate user-input
function __construct() {
$this->plugins=self::getPluginList(); // List of available plugins
$this->plugin =safe_GET('plugin', array_keys($this->plugins)); // User parameters
$this->xref =safe_GET('xref', WT_REGEX_XREF);
$this->action =safe_GET('action');
$this->data =safe_GET('data');
// Don't do any processing until a plugin is chosen.
if ($this->plugin) {
$this->PLUGIN=new $this->plugin;
$this->PLUGIN->getOptions();
$this->getAllXrefs();
switch ($this->action) {
case '':
break;
case 'update':
$record=self::getLatestRecord($this->xref, $this->all_xrefs[$this->xref]);
if ($this->PLUGIN->doesRecordNeedUpdate($this->xref, $record)) {
$newrecord=$this->PLUGIN->updateRecord($this->xref, $record);
if ($newrecord!=$record) {
if ($newrecord) {
replace_gedrec($this->xref, WT_GED_ID, $newrecord, $this->PLUGIN->chan);
} else {
delete_gedrec($this->xref, WT_GED_ID);
}
}
}
$this->xref=$this->findNextXref($this->xref);
break;
case 'update_all':
foreach ($this->all_xrefs as $xref=>$type) {
$record=self::getLatestRecord($xref, $type);
if ($this->PLUGIN->doesRecordNeedUpdate($xref, $record)) {
$newrecord=$this->PLUGIN->updateRecord($xref, $record);
if ($newrecord!=$record) {
if ($newrecord) {
replace_gedrec($xref, WT_GED_ID, $newrecord, $this->PLUGIN->chan);
} else {
delete_gedrec($xref, WT_GED_ID);
}
}
}
}
$this->xref='';
return;
case 'delete':
$record=self::getLatestRecord($this->xref, $this->all_xrefs[$this->xref]);
if ($this->PLUGIN->doesRecordNeedUpdate($this->xref, $record)) {
delete_gedrec($this->xref, WT_GED_ID);
}
$this->xref=$this->findNextXref($this->xref);
break;
case 'delete_all':
foreach ($this->all_xrefs as $xref=>$type) {
$record=self::getLatestRecord($xref, $type);
if ($this->PLUGIN->doesRecordNeedUpdate($xref, $record)) {
delete_gedrec($xref, WT_GED_ID);
}
}
$xref->xref='';
return;
default:
// Anything else will be handled by the plugin
$this->PLUGIN->performAction($this->xref, $this->record, $this->action, $this->data);
break;
}
// Make sure that our requested record really does need updating.
// It may have been updated in another session, or may not have
// been specified at all.
if (array_key_exists($this->xref, $this->all_xrefs) &&
$this->PLUGIN->doesRecordNeedUpdate($this->xref, self::getLatestRecord($this->xref, $this->all_xrefs[$this->xref]))) {
$this->curr_xref=$this->xref;
}
// The requested record doesn't need updating - find one that does
if (!$this->curr_xref) {
$this->curr_xref=$this->findNextXref($this->xref);
}
if (!$this->curr_xref) {
$this->curr_xref=$this->findPrevXref($this->xref);
}
// If we've found a record to update, get details and look for the next/prev
if ($this->curr_xref) {
$this->record=self::getLatestRecord($this->curr_xref, $this->all_xrefs[$this->curr_xref]);
$this->prev_xref=$this->findPrevXref($this->curr_xref);
$this->next_xref=$this->findNextXref($this->curr_xref);
}
}
}
// Find the next record that needs to be updated
function findNextXref($xref) {
foreach (array_keys($this->all_xrefs) as $key) {
if ($key>$xref) {
$record=self::getLatestRecord($key, $this->all_xrefs[$key]);
if ($this->PLUGIN->doesRecordNeedUpdate($key, $record)) {
return $key;
}
}
}
return null;
}
// Find the previous record that needs to be updated
function findPrevXref($xref) {
foreach (array_reverse(array_keys($this->all_xrefs)) as $key) {
if ($key<$xref) {
$record=self::getLatestRecord($key, $this->all_xrefs[$key]);
if ($this->PLUGIN->doesRecordNeedUpdate($key, $record)) {
return $key;
}
}
}
return null;
}
function getAllXrefs() {
global $TBLPREFIX;
$sql=array();
$vars=array();
foreach ($this->PLUGIN->getRecordTypesToUpdate() as $type) {
switch ($type) {
case 'INDI':
$sql[]="SELECT i_id, 'INDI' FROM {$TBLPREFIX}individuals WHERE i_file=?";
$vars[]=WT_GED_ID;
break;
case 'FAM':
$sql[]="SELECT f_id, 'FAM' FROM {$TBLPREFIX}families WHERE f_file=?";
$vars[]=WT_GED_ID;
break;
case 'SOUR':
$sql[]="SELECT s_id, 'SOUR' FROM {$TBLPREFIX}sources WHERE s_file=?";
$vars[]=WT_GED_ID;
break;
case 'OBJE':
$sql[]="SELECT m_media, 'OBJE' FROM {$TBLPREFIX}media WHERE m_gedfile=?";
$vars[]=WT_GED_ID;
break;
default:
$sql[]="SELECT o_id, ? FROM {$TBLPREFIX}other WHERE o_type=? AND o_file=?";
$vars[]=$type;
$vars[]=$type;
$vars[]=WT_GED_ID;
break;
}
}
$this->all_xrefs=
WT_DB::prepare(implode(' UNION ', $sql).' ORDER BY 1 ASC')
->execute($vars)
->fetchAssoc();
}
// Scan the plugin directory for a list of plugins
static function getPluginList() {
$array=array();
$dir=dirname(__FILE__).'/plugins/';
$dir_handle=opendir($dir);
while ($file=readdir($dir_handle)) {
if (substr($file, -4)=='.php') {
require dirname(__FILE__).'/plugins/'.$file;
$class=basename($file, '.php').'_bu_plugin';
$array[$class]=new $class;
}
}
closedir($dir_handle);
return $array;
}
// Javascript that gets included on every page
static function getJavascript() {
return
''
;
}
// Create a submit button for our form
static function createSubmitButton($text, $xref, $action='', $data='') {
return
'