');
$strVal = preg_replace('/(
', $strVal);
}
}
$strVal = str_replace($this->arrConfig['field_encloser'],$this->arrConfig['escape_char'].$this->arrConfig['field_encloser'],$strVal);
if (strlen($strVal))
{
$strVal = preg_replace('/(^|$)/',$this->arrConfig['field_encloser'],$strVal);
} else {
$strVal = $this->arrConfig['field_encloser'].$this->arrConfig['field_encloser'];
}
return $strVal.($blnSkipTerminator ? '' : $this->arrConfig['field_terminator']);
}
protected function convert($strValue, $strCharset = null)
{
if (is_null($strCharset))
{
$strCharset = strtoupper($this->arrConfig['encoding']);
} else {
$strCharset = strtoupper($strCharset);
}
$strSrcEncoding = mb_detect_encoding($strValue,"UTF-8,".$this->arrConfig['encoding'].",cp1252,cp1251,cp1250,iso-8859-1,iso-8859-15",true);
return ($strSrcEncoding == $strCharset) ? $strValue : mb_convert_encoding($strValue, $strCharset, $strSrcEncoding);
}
protected function getHeader()
{
$strHeader = '';
$index = 0;
foreach(array_keys($GLOBALS['EXPORT']['fields']) as $field)
{
$field = $this->encapsulate($field, ($this->arrConfig['skipLastTerminator'] && ++$index == count($GLOBALS['EXPORT']['fields']) ? true : false));
$strHeader .= $this->convert($field);
}
return $strHeader."\n";
}
public function getCSV()
{
// echo 'Datensätze: '.count($this->arrDB)."\n";
$strBuffer = ($this->arrConfig['includeHeader']) ? $this->getHeader() : '';
foreach($this->arrDB as $this->arrRow)
{
$strBuffer .= $this->parseLine($this->arrRow);
}
return $strBuffer;
}
public function saveCSV()
{
$tmpname = sys_get_temp_dir().'/'.hash('crc32', uniqid(microtime()));
$count = 0;
if (count($this->_aOrders) < 1)
{
return $count;
}
//$fh = fopen($tmpname,"a");
$fh = fopen(getShopBasePath() . $this->arrConfig['filename'],"a");
fputs($fh,(($this->arrConfig['includeHeader']) ? $this->getHeader() : ''));
foreach($this->_aOrders as $order)
{
$this->_aArticles = array();
$sql = "SELECT OXID FROM oxorderarticles AS ooa WHERE ooa.OXORDERID = " . $this->db->quote($order['order']) . " ORDER BY ooa.OXARTNUM";
$rs = $this->db->execute($sql);
while ($rs && !$rs->EOF)
{
$arrRow = $rs->fetchRow();
$this->_aArticles[] = array_merge($order,array('orderarticle'=>$arrRow['OXID'], 'orderarticlepos'=>count($this->_aArticles)+1));
}
foreach ($this->_aArticles as $article)
{
// echo $article['article']->oxarticles__oxtitle->value."\n";
// echo $article['category']->oxcategories__oxtitle->value."\n\n";
fputs($fh, $this->parseLine($article));
}
// Shipping costs
$aShipping = $article;
$aShipping['orderarticlepos'] = $aShipping['orderarticlepos']+1;
fputs($fh, $this->parseLine($aShipping,'shipping'));
$sql = "UPDATE oxorder SET oxesexported = 1 WHERE oxid = " . $this->db->quote($order['order']) . "";
$rs = $this->db->execute($sql);
$count += count($this->_aArticles);
}
fclose($fh);
/*if (!rename($tmpname, getShopBasePath() . $this->arrConfig['filename']))
{
die('Export file could not be created');
}*/
return $count;
}
}
$Export = new Export();
$intArticles = $Export->saveCSV();
header('Content-Type: text/plain; charset='.$Export->getConfigParam['encoding']);
echo "Items exported: " . $intArticles."\n";
$intMemory = memory_get_peak_usage(true);
$hrsize = function($intMemory) {
$kilobyte = 1024;
$megabyte = $kilobyte * 1024;
$gigabyte = $megabyte * 1024;
$terabyte = $gigabyte * 1024;
$precision = 2;
$bytes = $intMemory;
if (($bytes >= 0) && ($bytes < $kilobyte)) {
return $bytes . ' B';
} elseif (($bytes >= $kilobyte) && ($bytes < $megabyte)) {
return round($bytes / $kilobyte, $precision) . ' KB';
} elseif (($bytes >= $megabyte) && ($bytes < $gigabyte)) {
return round($bytes / $megabyte, $precision) . ' MB';
} elseif (($bytes >= $gigabyte) && ($bytes < $terabyte)) {
return round($bytes / $gigabyte, $precision) . ' GB';
} elseif ($bytes >= $terabyte) {
return round($bytes / $terabyte, $precision) . ' TB';
} else {
return $bytes . ' B';
}
};
echo "Memory used for export: " . $hrsize($intMemory)."\n";