快速更新MAGENT产品价格



快速更新MAGENT产品价格

用后台的magento上传功能， 只是要更新价格而已， 是不是只有几百条或几千条数据要更新几百年

google后， 找到一个更新价格的方面比较快的方法是， 直接操作sql

 

  1. <?php
  2. /**
  3.  * @author      MagePsycho <info@magepsycho.com>
  4.  * @website     http://www.magepsycho.com
  5.  * @category    Export / Import
  6.  */
  7. $mageFilename = ’app/Mage.php’;
  8. require_once $mageFilename;
  9. Mage::setIsDeveloperMode(true);
  10. ini_set(‘display_errors’, 1);
  11. umask(0);
  12. Mage::app(‘admin’);
  13. Mage::register(‘isSecureArea’, 1);
  14. Mage::app()->setCurrentStore(Mage_Core_Model_App::ADMIN_STORE_ID);
  16. set_time_limit(0);
  17. ini_set(‘memory_limit’,’1024M’);
  19. /***************** UTILITY FUNCTIONS ********************/
  20. function _getConnection($type = ’core_read’){
  21.     return Mage::getSingleton(‘core/resource’)->getConnection($type);
  22. }
  24. function _getTableName($tableName){
  25.     return Mage::getSingleton(‘core/resource’)->getTableName($tableName);
  26. }
  28. function _getAttributeId($attribute_code = ’price’){
  29.     $connection = _getConnection(‘core_read’);
  30.     $sql = ”SELECT attribute_id
  31.                 FROM ” . _getTableName(‘eav_attribute’) . ”
  32.             WHERE
  33.                 entity_type_id = ?
  34.                 AND attribute_code = ?”;
  35.     $entity_type_id = _getEntityTypeId();
  36.     return $connection->fetchOne($sql, array($entity_type_id, $attribute_code));
  37. }
  39. function _getEntityTypeId($entity_type_code = ’catalog_product’){
  40.     $connection = _getConnection(‘core_read’);
  41.     $sql        = ”SELECT entity_type_id FROM ” . _getTableName(‘eav_entity_type’) . ” WHERE entity_type_code = ?”;
  42.     return $connection->fetchOne($sql, array($entity_type_code));
  43. }
  45. function _getIdFromSku($sku){
  46.     $connection = _getConnection(‘core_read’);
  47.     $sql        = ”SELECT entity_id FROM ” . _getTableName(‘catalog_product_entity’) . ” WHERE sku = ?”;
  48.     return $connection->fetchOne($sql, array($sku));
  50. }
  52. function _checkIfSkuExists($sku){
  53.     $connection = _getConnection(‘core_read’);
  54.     $sql        = ”SELECT COUNT(*) AS count_no FROM ” . _getTableName(‘catalog_product_entity’) . ” WHERE sku = ?”;
  55.     $count      = $connection->fetchOne($sql, array($sku));
  56.     if($count > 0){
  57.         return true;
  58.     }else{
  59.         return false;
  60.     }
  61. }
  63. function _updatePrices($data){
  64.     $connection     = _getConnection(‘core_write’);
  65.     $sku            = $data[0];
  66.     $newPrice       = $data[1];
  67.     $productId      = _getIdFromSku($sku);
  68.     $attributeId    = _getAttributeId();
  70.     $sql = ”UPDATE ” . _getTableName(‘catalog_product_entity_decimal’) . ” cped
  71.                 SET  cped.value = ?
  72.             WHERE  cped.attribute_id = ?
  73.             AND cped.entity_id = ?”;
  74.     $connection->query($sql, array($newPrice, $attributeId, $productId));
  75. }
  76. /***************** UTILITY FUNCTIONS ********************/
  78. $csv                = new Varien_File_Csv();
  79. $data               = $csv->getData(‘prices.csv’); //path to csv
  80. array_shift($data);
  82. $message = ”;
  83. $count   = 1;
  84. foreach($data as $_data){
  85.     if(_checkIfSkuExists($_data[0])){
  86.         try{
  87.             _updatePrices($_data);
  88.             $message .= $count . ’> Success:: While Updating Price (‘ . $_data[1] . ’) of Sku (‘ . $_data[0] . ’). <br />’;
  90.         }catch(Exception $e){
  91.             $message .=  $count .’> Error:: While Upating  Price (‘ . $_data[1] . ’) of Sku (‘ . $_data[0] . ’) => ’.$e->getMessage().’<br />’;
  92.         }
  93.     }else{
  94.         $message .=  $count .’> Error:: Product with Sku (‘ . $_data[0] . ’) does\’t exist.<br />’;
  95.     }
  96.     $count++;
  97. }
  98. echo $message;

 

上传的csv格式如图：