服务报价 | 域名主机 | 网络营销 | 软件工具| [加入收藏]
 热线电话: #
当前位置: 主页 > php教程 > magento教程 >

magento通过csv文件与zip(图片压缩)上传产品到数据库的过程

时间:2016-04-06 08:07来源:未知 作者:最模板 点击:次
1，magento前台使用input-file type按钮提交文件到magento指定的控制器，controllers获取.csv文件，因为magento是在zend框架上实现的，可以使用如下代码获取文件的上传信息： /** * New zend File Uploa
1，magento前台使用input-file type按钮提交文件到magento指定的控制器，controllers获取.csv文件，因为magento是在zend框架上实现的，可以使用如下代码获取文件的上传信息：
/**
             * New zend File Uploader
             */
            $uploadsData = new Zend_File_Transfer_Adapter_Http ();
            $filesDataArray = $uploadsData->getFileInfo ();
2，遍历获取的$filesDataArray文件，这里上传的文件包括：保存产品信息的csv文件与对应的zip产品图片，遍历图片代码如下：
$currentDateTime = date ( "Ymd_His", Mage::getModel ( 'core/date' )->timestamp ( time () ) );
        
        foreach ( $filesDataArray as $key => $value ) {
            /**
             * Initilize file name
             */
            $filename = $key;
            
            /**
             * Upload csv file
             */
            
            if ($key == 'bulk-product-upload-csv-file' && isset ( $filesDataArray [$filename] ['name'] ) && (file_exists ( $filesDataArray [$filename] ['tmp_name'] ))) {
                $csvFilePath = '';
                $csvFilePath = array ();
                $uploader = new Varien_File_Uploader ( $filename );
                $uploader->setAllowedExtensions ( array (
                        'csv' 
                ) );
                $uploader->setAllowRenameFiles ( true );
                $uploader->setFilesDispersion ( false );
                $path = Mage::getBaseDir ( 'media' ) . DS . 'marketplace' . DS . 'bulk' . DS . 'product' . DS . 'csv' . DS;
                
                $uploader->save ( $path, 'seller_' . $sellerId . '_date_' . $currentDateTime . '.csv' );
                $csvFilePath = $path . $uploader->getUploadedFileName ();
            }
            
            /**
             * Upload csv image
             */
            if ($key == 'bulk-product-upload-image-file' && isset ( $filesDataArray [$filename] ['name'] ) && (file_exists ( $filesDataArray [$filename] ['tmp_name'] ))) {
                $uploader = new Varien_File_Uploader ( $filename );
                $uploader->setAllowedExtensions ( array (
                        'zip' 
                ) );
                $uploader->setAllowRenameFiles ( true );
                $uploader->setFilesDispersion ( false );
                $path = Mage::getBaseDir ( 'media' ) . DS . 'marketplace' . DS . 'bulk' . DS . 'product' . DS . 'image' . DS;
                /**
                 * Uploader save
                 */
                $uploader->save ( $path, 'seller_' . $sellerId . '_date_' . $currentDateTime . '.zip' );
                $imageFilePath = $path . $uploader->getUploadedFileName ();
                
                $ZipFileName = $imageFilePath;
                $homeFolder = Mage::getBaseDir ( 'media' ) . DS . 'marketplace' . DS . 'bulk' . DS . 'product' . DS . 'image' . DS . 'seller_' . $sellerId . '_date_' . $currentDateTime;
                /**
                 * New Varien File
                 */
                $file = new Varien_Io_File ();
                /**
                 * Make Directory
                 */
                $file->mkdir ( $homeFolder );
                Mage::helper ( 'marketplace/product' )->exportZipFile ( $ZipFileName, $homeFolder );
            }
        }

在此之中，对遍历到的csv和zip文件分别保存到设置的文件夹下：

对于csv文件设置了存储路径，限制了文件上传的格式，根据商户ID与上传时间设置了文的存储名称：

1  $uploader->save ( $path, 'seller_' . $sellerId . '_date_' . $currentDateTime . '.csv' );

对于zip的图片文件设置了存储路径，限制了文件上传的格式，根据商户ID与上传时间设置了文的存储名称：

$uploader->save ( $path, 'seller_' . $sellerId . '_date_' . $currentDateTime . '.zip' );
$imageFilePath = $path . $uploader->getUploadedFileName ();
$ZipFileName = $imageFilePath;

解压zip图片，用使用当前模块中helper=>exportZipFile ( $ZipFileName, $homeFolder )对上传的zip图片进行解压，代码如下:

/**
     *
     *
     *
     * Unzip uploaded images
     *
     * @param string $zipFileName            
     * @return boolean
     */
    public function exportZipFile($zipFileName, $homeFolder) {
        /**
         * New ZIP archive
         */
        $zip = new ZipArchive ();
        if ($zip->open ( $zipFileName ) === true) {
            /**
             * Make all the folders
             */
            for($i = 0; $i < $zip->numFiles; $i ++) {
                $onlyFileName = $zip->getNameIndex ( $i );
                $fullFileName = $zip->statIndex ( $i );
                if ($fullFileName ['name'] [strlen ( $fullFileName ['name'] ) - 1] == "/") {
                    @mkdir ( $homeFolder . "/" . $fullFileName ['name'], 0700, true );
                }
            }
            
            /**
             * Unzip into the folders
             */
            for($i = 0; $i < $zip->numFiles; $i ++) {
                $onlyFileName = $zip->getNameIndex ( $i );
                $fullFileName = $zip->statIndex ( $i );
                
                if (! ($fullFileName ['name'] [strlen ( $fullFileName ['name'] ) - 1] == "/") && preg_match ( '#\.(jpg|jpeg|gif|png)$#i', $onlyFileName )) {
                    copy ( 'zip://' . $zipFileName . '#' . $onlyFileName, $homeFolder . "/" . $fullFileName ['name'] );
                }
            }
            $zip->close ();
        } else {
            Mage::getSingleton ( 'core/session' )->addError ( $this->__ ( "Error: Can't open zip file" ) );
        }
        return true;
    }
把csv文件转换为数组形式，使用当前模块中helper=>convertCsvFileToUploadArray ( $csvFilePath )进行转换，代码如下：
/**
     *
     *
     *
     * Convert csv file to upload array
     *
     * @param string $csvFilePath            
     * @return array
     */
    public function convertCsvFileToUploadArray($csvFilePath) {
        $productInfo = array ();
        if (! empty ( $csvFilePath )) {
            /**
             * Initializing new varien file
             */
            $csv = new Varien_File_Csv ();
            $data = $csv->getData ( $csvFilePath );
            $line = $lines = '';
            
            $keys = array_shift ( $data );
            
            /**
             * Getting instance for catalog product collection
             */
            $productInfo = $createProductData = array ();
            foreach ( $data as $lines => $line ) {
                if (count ( $keys ) == count ( $line )) {
                    $data [$lines] = array_combine ( $keys, $line );
                }
            }
            
            if (count ( $data ) <= 1 && count ( $keys ) >= 1 && ! empty ( $line ) && count ( $keys ) == count ( $line )) {
                $data [$lines + 1] = array_combine ( $keys, $line );
            }
            
            $createProductData = $this->uploadProductData ( $data );
            
            if (! empty ( $createProductData )) {
                $productInfo [] = $createProductData;
            }
        }
        
        return $productInfo;
    }
只要是获取csv表格头部的命名（数据库字段）使用 $data [$lines] = array_combine ( $keys, $line )，转换为以下标为字段名，对应为值得二维数组
3，使用一下方法处理收集到的数据，代码如下:
/**
     *
     * @param string $imageFilePath            
     * @param array $productData            
     * @param string $homeFolder            
     * @param string $csvFilePath            
     * @return boolean
     */
    public function bulkproductuploadfuncationality($imageFilePath, $productData, $homeFolder, $csvFilePath) {
        if (file_exists ( $imageFilePath )) {
            /**
             * Delete images from temporary zip folder
             */
            unlink ( $imageFilePath );
        }
        
        if (isset ( $productData [0] )) {
            $configurableAttributes = array ();
            /**
             * Get Configurable Products
             */
            $configurableAttributes = $this->getRequest ()->getPost ( 'configurable_attribute' );
            Mage::helper ( 'marketplace/image' )->saveProductData ( $productData [0], $homeFolder, $configurableAttributes );
            if (Mage::getStoreConfig ( 'marketplace/product/save_uploadfiles' ) != 1) {
                if (file_exists ( $csvFilePath )) {
                    /**
                     * Delete csv file
                     */
                    unlink ( $csvFilePath );
                }
                
                /**
                 * Delete images from temporary zip folder
                 */
                Mage::helper ( 'marketplace/image' )->rrmdir ( $homeFolder );
            }
            $this->_redirect ( 'marketplace/product/manage/' );
        } else {
            /**
             * Add Notice
             */
            Mage::getSingleton ( 'core/session' )->addNotice ( Mage::helper ( 'marketplace' )->__ ( 'No data found' ) );
            $this->_redirect ( 'marketplace/product/manage/' );
            return true;
        }
    }
对于zip的图片文件进行删除，并使用saveProductData($productData, $imagePath, $configurableAttributes) 对存储数据的结果进行消息返回提示，在此之中会提示重复的sku,gtin码的验证结果及是否重复，或者上传成功产品数量，此方法中使用saveBulkUploadProduct ( $productData, $imagePath,$configurableAttributes, $rowcountForImport )对产品信息存入数据库，代码如下：
/**
     * Save bulk upload product
     *
     * @param array $productData            
     * @param array $imagePath            
     * @param array $configurableAttributes            
     * @param number $rowcountForImport            
     * @return array $productCountArray
     */
    public function saveBulkUploadProduct($productData, $imagePath, $configurableAttributes, $rowcountForImport) {
        $countries = Mage::getModel ( 'marketplace/bulk' )->getContriesValue ();
        /**
         * Initilize website ids
         */
        $websiteIds = array (
                Mage::app ()->getStore ( true )->getWebsite ()->getId () 
        );
        $importProductsCount = 0;
        $existSkuCounts = 0;
        $existGtinCounts = 0;
        $notValidGtinsCounts = 0;
        $existGtinLists = array();
        $notValidGtinsArr=array();
        $productCountArray = array ();
        foreach ( $productData ['sku'] as $key => $value ) {
            $flag = Mage::getModel ( 'marketplace/bulk' )->checkRequiredFieldForBulkUpload ( $productData, $key );
            if ($flag == 1) {
                $images = array ();
                $checkSkuAndGtinModel= Mage::getModel ( 'catalog/product' );
                $productSkuForCheck =$checkSkuAndGtinModel->getIdBySku ( $productData ['sku'] [$key] );
                if ($productSkuForCheck) {
                    $existSkuCounts = $existSkuCounts + 1;
                    continue;
                }
                $gtinCode= $productData ['gtin'] [$key];
                $collection =$checkSkuAndGtinModel->getCollection ()->addAttributeToFilter ( 'gtin', $gtinCode );
                $count = count ( $collection );
                if($count){
                    $existGtinLists[]=$gtinCode;
                    $existGtinCounts=$existGtinCounts+1;
                    continue;
                }
                if(!preg_match('/^[0-9]{12,13}$ /', $gtinCode)){
                    $notValidGtinsArr[]=$gtinCode;
                    $notValidGtinsCounts=$notValidGtinsCounts+1;
                    continue;
                }
                $orFlag = Mage::getModel ( 'marketplace/bulk' )->checkProductTypeForBulkUpload ( $productData, $key );
                if ($orFlag == 1) {
                    $product = Mage::getModel ( 'catalog/product' );
                    $categoryIds = array ();
                    /**
                     * Multi row product data
                     */
                    $attributeSetName = $productData ['_attribute_set'] [$key];
                    $sku = $productData ['sku'] [$key];
                    $name = $productData ['name'] [$key];
                    $gtin = $productData ['gtin'] [$key];
                    $description = $productData ['description'] [$key];
                    $shortDescription = $productData ['short_description'] [$key];
                    $price = $productData ['price'] [$key];
                    $type = $productData ['_type'] [$key];
                    $weight = Mage::getModel ( 'marketplace/bulk' )->getWeightForBulkUpload ( $productData, $key, $type );
                    /**
                     * Getting special price values
                     */
                    $specialPrice = $productData ['special_price'] [$key];
                    $specialDate = array ();
                    $specialDate ['special_from_date'] = $productData ['special_from_date'] [$key];
                    $specialDate ['special_to_date'] = $productData ['special_to_date'] [$key];
                    /**
                     * Fetch images info for product
                     */
                    $images = Mage::getModel ( 'marketplace/bulk' )->getImagesForBulkProduct ( $key, $productData );
                    $categoryIds = Mage::getModel ( 'marketplace/bulk' )->getCategoryIdsForBulk ( $key, $productData );
                    $customOptions = Mage::getModel ( 'marketplace/bulk' )->getCustomOptionsForBulk ( $key, $productData, $rowcountForImport );
                    $dataForBulkUpload = Mage::getModel ( 'marketplace/bulk' )->getDataForBulkProduct ( $key, $productData );
                    /**
                     * Fetch attribute set id by attribute set name
                     */
                    $entityTypeId = Mage::getModel ( 'eav/entity' )->setType ( 'catalog_product' )->getTypeId ();
                    $attributeSetId = Mage::getModel ( 'eav/entity_attribute_set' )->getCollection ()->setEntityTypeFilter ( $entityTypeId )->addFieldToFilter ( 'attribute_set_name', $attributeSetName )->getFirstItem ()->getAttributeSetId ();
                    
                    if (empty ( $attributeSetId )) {
                        $attributeSetId = Mage::getModel ( 'eav/entity_attribute_set' )->getCollection ()->setEntityTypeFilter ( $entityTypeId )->addFieldToFilter ( 'attribute_set_name', 'Default' )->getFirstItem ()->getAttributeSetId ();
                    }
                    
                    $product->setSku ( $sku );
                    $product->setName ( $name );
                    $product->setGtin ( $gtin );
                    $product->setDescription ( $description );
                    $product->setShortDescription ( $shortDescription );
                    $product->setPrice ( $price );
                    /**
                     * Set product data for bulk product upload
                     */
                    $product = Mage::getModel ( 'marketplace/bulk' )->setProductDataForBulkProductUpload ( $product, $specialPrice, $specialDate, $type, $weight, $attributeSetId, $categoryIds );
                    $product = Mage::getModel ( 'marketplace/bulk' )->setProductInfoForBulkProductUpload ( $dataForBulkUpload, $productData, $key, $product, $websiteIds, $countries );
                    $product = Mage::getModel ( 'marketplace/bulk' )->setImagesAndCustomOptionForBulkProductUpload ( $product, $images, $imagePath, $customOptions );
                    /**
                     * Fetch configurable product options
                     */
                    $configurableProductsDataBulk = Mage::getModel ( 'marketplace/bulk' )->getConfigurableProductDataForBulkUpload ( $key, $type, $productData );
                    $attributeIds = $configurableProductsDataBulk ['attribute_ids'];
                    $configurableProductsData = $configurableProductsDataBulk ['configurable_products_data'];
                    $superProductsSkus = $configurableProductsDataBulk ['super_products_skus'];
                    $product = Mage::getModel ( 'marketplace/bulk' )->setConfigurableProductDataForBulkUpload ( $product, $attributeIds, $type, $attributeSetId, $configurableProductsData );
                    $product = Mage::getModel ( 'marketplace/bulk' )->setProductConfigData ( $productData, $product, $configurableAttributes, $key );
                    
                    /**
                     * Initialize configurable product options
                     */
                    $product->save ();
                    Mage::getModel ( 'marketplace/bulk' )->saveSimpleProductForBulkUpload ( $type, $superProductsSkus, $product );
                    
                    Mage::getSingleton ( 'catalog/product_option' )->unsetOptions ();
                    $importProductsCount = $importProductsCount + 1;
                }
            }
        }
        /**
         * Initilize rpoduct count array
         */
        $productCountArray ['import_products_count'] = $importProductsCount;
        $productCountArray ['exist_sku_counts'] = $existSkuCounts;
        $productCountArray ['exist_gtin_counts'] = $existGtinCounts;
        $productCountArray ['exist_gtin_lists'] = $existGtinLists;
        $productCountArray ['not_valid_gtin_counts'] = $notValidGtinsCounts;
        $productCountArray ['not_valid_gtin_lists'] = $notValidGtinsArr;
        return $productCountArray;
    }

在此之中，会用到magento特有的model方法，把数据存入数据库，最常用的collection,resource等

总结：整个过程下来，一个模块中的model,helper方法混合调用，使用magento特有的model方法操作数据比较方便，使用zend框架处理文件上传与csv文件转数据也比较省事


(责任编辑：最模板)
顶一下
(0)
0%
踩一下
(0)
0%
------分隔线----------------------------
栏目列表
热点内容
随机内容
随机模板
CopyRight © 2010-2016 最模板 ZuiMoban.Com, All Rights Reserved.