loadTotalBySessionId($sessionId); $callbacks = array(); if ($mapperCb = $this->_parseCallback($this->getVar('mapper'), 'mapRow')) { $callbacks[] = $mapperCb; } if ($adapterCb = $this->_parseCallback($this->getVar('adapter'), 'saveRow')) { $callbacks[] = $adapterCb; } $callbacks[] = array($this, 'updateProgress'); echo $this->_getProgressBarHtml($sessionId, $total['cnt']); Mage::getModel('core/resource_iterator') ->walk($import->select($sessionId), $callbacks); } protected function _getProgressBarHtml($sessionId, $totalRows) { return '

' . $this->__('Total records: %s', '' . $totalRows . '').', ' . $this->__('Processed records: %s', '0') .', ' . $this->__('ETA: %s', 'N/A') . ', ' . $this->__('Memory Used: %s', '' . memory_get_usage(true).'') . '

'; } public function updateProgress($args) { $memory = !empty($args['memory']) ? $args['memory'] : ''; echo ''; echo '

' . $memory . '

'; return array(); } protected function _parseCallback($callback, $defaultMethod=null) { if (!preg_match('#^([a-z0-9_/]+)(::([a-z0-9_]+))?$#i', $callback, $match)) { return false; } if (!($model = Mage::getModel($match[1]))) { return false; } if (!($method = $match[3] ? $match[3] : $defaultMethod)) { return false; } return array($model, $method); } }