get_parms(
'period'
, 'flush'
, 'maxrecs'
, 'maxmegs'
);
$dom = new DOMDocument();
$dom->preserveWhiteSpace = false;
$dom->formatOutput = true;
if( $dom->loadXML($oldxml) )
{
$xmlchanged = false;
// foreach($parm2 as $pname=>$pvalue)
foreach(array("str:period", "str:flush", "str:maxrecs", "str:maxmegs") as $pname)
{
$ptype = substr($pname, 0, 3);
$pname = substr($pname, 4);
$pvalue = $parm2[$pname];
if( $ns = $dom->getElementsByTagName($pname)->item(0) )
{
// le champ existait dans le xml, on supprime son ancienne valeur (tout le contenu)
while( ($n = $ns->firstChild) )
$ns->removeChild($n);
}
else
{
// le champ n'existait pas dans le xml, on le cr�e
$ns = $dom->documentElement->appendChild($dom->createElement($pname));
}
// on fixe sa valeur
switch($ptype)
{
case "str":
$ns->appendChild($dom->createTextNode($pvalue));
break;
case "boo":
$ns->appendChild($dom->createTextNode($pvalue ? '1':'0'));
break;
}
$xmlchanged = true;
}
}
return($dom->saveXML());
}
// ====================================================================
// xml2graphic : must fill the graphic form (using js) from xml
// ====================================================================
public function xml2graphic($xml, $form)
{
if( ($sxml = simplexml_load_string($xml)) ) // in fact XML IS always valid here...
{
// ... but we could check for safe values (ex. 0 < period < 3600)
if( (int)($sxml->period) < 10 )
$sxml->period = 10;
elseif( (int)($sxml->period) > 300 )
$sxml->period = 300;
if( (string)($sxml->flush) == '' )
$sxml->flush = 10;
elseif( (int)($sxml->flush) < 1 )
$sxml->flush = 1;
elseif( (int)($sxml->flush) > 100 )
$sxml->flush = 100;
if( (string)($sxml->maxrecs) == '')
$sxml->maxrecs = 100;
if( (int)($sxml->maxrecs) < 10 )
$sxml->maxrecs = 10;
elseif( (int)($sxml->maxrecs) > 500 )
$sxml->maxrecs = 500;
if( (string)($sxml->maxmegs) == '' )
$sxml->maxmegs = 6;
if( (int)($sxml->maxmegs) < 3 )
$sxml->maxmegs = 3;
elseif( (int)($sxml->maxmegs) > 32 )
$sxml->maxmegs = 32;
?>
0 ORDER BY ord';
if($conn && ($rs = $conn->query($sql)))
{
?>
array("set"=>false, "values"=>array(), "usage"=>" : usage du truc")
);
// ======================================================================================================
// ===== help() : text displayed if --help (optional)
// ======================================================================================================
function help()
{
return(_("task::subdef:creation des sous definitions des documents d'origine"));
}
// ======================================================================================================
// ===== run() : le code d'�x�cution de la t�che proprement dite
// ======================================================================================================
private $sxTaskSettings = null; // les settings de la tache en simplexml
private $connbas = null; // cnx � la base
private $running = false;
private $msg = "";
function run()
{
if( ($this->sxTaskSettings = simplexml_load_string($this->taskSettings)) )
{
return($this->run2());
}
else
{
// Settings illisibles
return(false);
}
}
private function run2()
{
// ex : 3 dbox, maxrecs=500, maxmegs=4
// scenario 1 : 100;0;80
// 100;0;80 ; 0;0;0;sleep ; 0;0;0;sleep...
// scenario 2 : 630;0;750
// 500;0;500;restart ; 130;0;250 ; 0;0;0;sleep ; 0;0;0;sleep...
// scenario 3 : 820;0;750 (420+250>500 --> restart)
// 500;0;500;restart ; 420;0;250;restart ; 0;0;0;sleep ; 0;0;0;sleep...
// scenario 4 : 100;0;80 (mem overflow each 45 records)
// 45;restart ; 45;restart ; 10;0;45;restart; 0;0;35; 0;0;0;sleep ; 0;0;0;sleep...
$ret = '';
$this->period = (int)($this->sxTaskSettings->period);
if($this->period <= 0 || $this->period >= 60*60)
$this->period = 60;
// ici la t�che tourne tant qu'elle est active
$this->running = true;
$taskStatus = '';
$conn = connection::getInstance();
$loop = 0;
while($this->running)
{
if(!$conn || !$conn->ping())
{
$this->log(("Warning : abox connection lost, restarting in 10 min."));
sleep(60*10);
$this->running = false;
return('');
}
$sql = "UPDATE task2 SET last_exec_time=NOW() WHERE task_id=" . $this->taskid ;
$conn->query($sql);
$sql = "SELECT sbas_id, task2.* FROM sbas, task2 WHERE task_id=" . $this->taskid ;
if($rs = $conn->query($sql))
{
$allRecsDone = 0; // sum of records done on each dbox
$duration = time();
while($this->running && ($row = $conn->fetch_assoc($rs)) )
{
$taskStatus = $row['status'];
$this->sbas_id = (int)$row['sbas_id'];
if($taskStatus == 'tostop')
{
$ret = 'stopped';
$this->running = false;
}
else
{
if( !($this->connbas = connection::getInstance($this->sbas_id)) )
{
continue;
}
if(!$this->connbas->isok())
{
$this->connbas->close();
continue;
}
if( $this->sxTaskSettings = simplexml_load_string($row['settings']) )
{
$period = (int)($this->sxTaskSettings->period);
if($period <= 0 || $period >= 60*60)
$period = 60;
if((int)($this->sxTaskSettings->maxrecs)<10 || (int)($this->sxTaskSettings->maxrecs)>1000)
$this->sxTaskSettings->maxrecs = 100;
if((int)($this->sxTaskSettings->maxmegs)<2 || (int)($this->sxTaskSettings->maxmegs)>100)
$this->sxTaskSettings->maxmegs = 20;
}
else
{
$period = 60;
}
// on lit les prefs de cette base
$this->sxBasePrefs = databox::get_sxml_structure($this->sbas_id);
$retStatus = null;
$allRecsDone += $this->doRecords($retStatus); // $retStatus:byref
$this->connbas->close();
if($retStatus == 'TOSTOP')
{
$ret = 'stopped';
$this->running = false; // quit NOW !
}
elseif($retStatus == 'MAXMEGSREACHED')
{
if($taskStatus != 'manual')
{
$ret = 'torestart';
$this->running = false; // restart NOW !
}
}
elseif($retStatus == 'MAXRECSDONE')
{
if($taskStatus != 'manual')
{
$ret = 'torestart'; // restart after last dbox
}
}
//printf("--- %s ret=%s taskStatus=%s \n", __LINE__, $ret, $taskStatus);
}
}
$conn->free_result($rs);
if($loop > 5 || $allRecsDone >= (int)($this->sxTaskSettings->maxrecs))
{
if($ret == 'started')
{
$ret = 'torestart';
}
}
if($this->running && $ret=='' && $allRecsDone == 0)
{
// nothing to do on every dbox, so pause
$duration = time() - $duration;
if($duration < $period)
{
$conn->close();
sleep($period - $duration);
$conn = connection::getInstance();
}
}
if($ret != '')
$this->running = false;
}
else
{
$ret = 'stopped';
$this->running = false;
}
$loop++;
}
return($ret);
}
function doRecords(&$ret)
{
// $this->traceRam();
$ndone = 0;
$tsub = array();
$ret = '';
$conn = connection::getInstance();
$this->sxBasePrefs = databox::get_sxml_structure($this->sbas_id);
if($this->sxBasePrefs)
{
$recsToNext = array();
// $sql = 'SELECT record.xml, record.type, subdef.record_id, name, path, file, mime FROM record INNER JOIN subdef ON (record.jeton & '.JETON_MAKE_SUBDEF.' > 0) AND subdef.record_id=record.record_id ORDER BY record_id' ;
$sql = 'SELECT record.type, subdef.record_id, name, path, file, mime FROM record INNER JOIN subdef ON (record.jeton & '.JETON_MAKE_SUBDEF.' > 0) AND subdef.record_id=record.record_id ORDER BY record_id DESC' ;
if( ($rsbas = $this->connbas->query($sql)) )
{
$last_rid = '?';
$tsub = array();
$rowstodo = $this->connbas->num_rows($rsbas);
$rowsdone = 0;
if($rowstodo > 0)
$this->setProgress(0, $rowstodo);
while( ($rowbas = $this->connbas->fetch_assoc($rsbas)) )
{
if($rowbas['record_id'] != $last_rid)
{
if($last_rid != '?')
{
// $this->traceRam();
$this->doSubdef($last_rid, $tsub, $recsToNext);
$ndone++;
$this->setProgress($rowsdone, $rowstodo);
if(count($recsToNext) >= (int)($this->sxTaskSettings->flush))
{
$this->flushRecsToNext($recsToNext);
}
}
unset($tsub);
$tsub = array();
$last_rid = $rowbas['record_id'];
}
$tsub[$rowbas['name']] = $rowbas;
$rowsdone++;
unset($rowbas);
$sql = "SELECT status FROM task2 WHERE task_id=" . $this->taskid ;
if($rs = $conn->query($sql))
{
$row = $conn->fetch_assoc($rs);
$conn->free_result($rs);
if(!$row || $row['status'] == 'tostop')
{
$ret = 'TOSTOP';
break;
}
}
else
{
// appbox crashed ? stop task
$ret = 'TOSTOP';
break;
}
if($ndone >= (int)($this->sxTaskSettings->maxrecs))
{
$ret = 'MAXRECSDONE';
break;
}
if(memory_get_usage()>>20 >= (int)($this->sxTaskSettings->maxmegs))
{
$ret = 'MAXMEGSREACHED';
break;
}
}
if($last_rid != '?')
{
$this->doSubdef($last_rid, $tsub, $recsToNext);
$ndone++;
$this->setProgress($rowsdone, $rowstodo);
$this->flushRecsToNext($recsToNext);
}
if($ndone >= (int)($this->sxTaskSettings->maxrecs))
{
$this->log(sprintf(('%d records done, restarting'), $ndone));
}
if(memory_get_usage()>>20 >= (int)($this->sxTaskSettings->maxmegs))
{
$this->log(printf(('memory reached %d Ko, restarting'), memory_get_usage()>>10));
}
$this->connbas->free_result($rsbas);
unset($rsbas);
if($rowstodo > 0)
$this->setProgress(0, 0);
unset($tsub);
}
unset($recsToNext);
}
if($ret == '' && $ndone==0)
$ret = 'NORECSTODO';
return($ndone);
}
function doSubdef($rid, $tsub, &$recsToNext)
{
$this->log(sprintf(('creating subdefs for sbas_id=%1$d - record_id=%2$d'), (int)$this->sbas_id, (int)$rid) );
$good_to_go = true;
$sql = 'DELETE FROM subdef WHERE record_id=' . $rid . ' AND name!=\'document\'' ;
$this->connbas->query($sql);
$doc = null;
foreach($tsub as $name=>$sub)
{
if($name == 'document')
{
$doc = $sub;
}
else
{
if(is_file(p4string::addEndSlash($sub['path']) . 'watermark_' . $sub['file']))
unlink(p4string::addEndSlash($sub['path']) . 'watermark_' . $sub['file']);
if(is_file(p4string::addEndSlash($sub['path']) . 'stamp_' . $sub['file']))
unlink(p4string::addEndSlash($sub['path']) . 'stamp_' . $sub['file']);
@unlink(p4string::addEndSlash($sub['path']) . $sub['file']);
}
}
if( !$doc || !file_exists($docfile=(p4string::addEndSlash($doc['path']) . $doc['file'])) )
$good_to_go = false;
$mtim = microtime(true);
if($good_to_go === true && !($r = makeSubdefs($this->sbas_id, $doc)) )
$good_to_go = false;
$this->log(sprintf(("\t(duration : %01.2f)"), microtime(true)-$mtim));
if($good_to_go === true)
{
if(isset($r['document']))
{
$sql = sprintf('UPDATE subdef SET width=%s, height=%s WHERE name=\'document\' AND record_id=%s', $r['document']['width'], $r['document']['height'], $rid);
$this->connbas->query($sql);
}
foreach($r['subdefs'] as $s)
{
if($s === false)
continue;
$fn = 'record_id, inbase, dispatched ';
$fv = $rid . ', 1, 1 ';
foreach(array('name', 'path', 'file', 'baseurl', 'width', 'height', 'mime', 'size') as $p)
{
$fn .= ', ' . $p ;
$fv .= ', \'' . $this->connbas->escape_string($s[$p]) . '\'';
}
$sql = 'INSERT INTO subdef ('.$fn.') VALUES ('.$fv.')';
$this->connbas->query($sql);
if($s['name'] == 'preview')
{
$cache_preview = cache_preview::getInstance();
$cache_preview->delete($this->sbas_id,$rid);
}
if($s['name'] == 'thumbnail')
{
$cache_thumbnail = cache_thumbnail::getInstance();
$cache_thumbnail->delete($this->sbas_id,$rid);
}
unset($sql);
unset($fv, $fn);
}
unset($r);
$recsToNext[] = $rid;
}
$sql = 'UPDATE record SET jeton=(jeton & ~'.JETON_MAKE_SUBDEF.'), moddate=NOW() WHERE record_id=' . $rid;
$this->connbas->query($sql);
// $this->traceRam();
}
function flushRecsToNext(&$recsToNext)
{
$sql = '';
foreach($recsToNext as $rid)
$sql .= ($sql?',':'') . $rid;
// ask for write meta on subdef
if($sql != '')
{
$this->log(sprintf(('setting %d record(s) to subdef meta writing'), count($recsToNext)));
$sql = 'UPDATE record SET status=(status & ~0x03), jeton=(jeton | '.JETON_WRITE_META_SUBDEF.') WHERE record_id IN ('.$sql.')';
$this->connbas->query($sql);
}
$recsToNext = array();
}
}
?>