python版本要求在3.3.x，需要mysql connector for python第三方库支持不适用所有的zencart导入到magento
代码如下:
#encoding=utf-8#@ author:凋零#@ contact:342103944@qq.comimport mysql.connectorimport sysimport timeimport globimport osimport reimport shutilconfig={‘host’:’127.0.0.1′,’user’:’root’,’password’:’1′,’port’:3306 ,’database’:’zencart’,’charset’:’utf8′} config1={‘host’:’127.0.0.1′,’user’:’root’,’password’:’1′,’port’:3306 ,’database’:’magento’,’charset’:’utf8′}zencart_image_dir=”d:/wamp/www/public/images/”#此处改为自己实际路径magento_image_dir=”d:/wamp/www/public1/media/catalog/product/”#此处改为自己实际路径#所有产品信息，列表类型products=[]
#连接到zencart数据库try: cnn=mysql.connector.connect(**config)except mysql.connector.error as e: print(‘connect fails!{}’.format(e))
#连接到magento数据库
try: cnn_magento=mysql.connector.connect(**config1)except mysql.connector.error as e: print(‘connect fails!{}’.format(e))
#连接到magento数据库
try: cnn_magento1=mysql.connector.connect(**config1)except mysql.connector.error as e: print(‘connect fails!{}’.format(e))#————–获取产品信息函数块开始—————##（获取产品描述，返回字典）def get_productdescription(product_id): global cnn product_select products_name,products_url from products_description where products_name’]=temp_description[0] description[‘url’]=temp_description[1] return description
#（获取产品多图，返回列表）def get_productaddtionimage(product_image): base_dir=”d:\\wamp\www\\public\\images\\”#此处改为自己实际路径 addtion_image=[] image_uri=(base_dir+product_image).replace(‘.jpg’,”) for i in range(16): if os.path.isfile(image_uri+’_’+str(i)+’.jpg’): addtion_image.append(product_image.replace(‘.jpg’,”)+’_’+str(i)+’.jpg’) else: #print (“none”) pass return addtion_image
#（获取产品对应目录,返回列表）def get_product_categories(product_id): product_id=str(product_id)
categories=[] cursor=cnn.cursor()
cursor.execute(“select categories_id from products_to_categories where products_id=”+product_id) for row in cursor.fetchall():
for r in row: categories.append(r)
return categories#————–获取产品信息函数块结束—————##分类id对应字典categories_to={\’2′:’10’,’3′:’13’,’4′:’18’,’139′:’37’,’176′:’38’,’201′:’70’,’202′:’71’,’203′:’69’,’204′:’76’,’205′:’77’,\’206′:’66’,’207′:’73’,’208′:’72’,’209′:’78’,’210′:’79’,’211′:’68’,’212′:’74’,’213′:’59’,’214′:’60’,’215′:’58’,’216′:’62’,’217′:’63’,’218′:’64’,’219′:’65’,’222′:’54’,\’223′:’53’,’224′:’56’,’225′:’80’,’230′:’81’,’231′:’48’,’232′:’49’,’233′:’50’,’234′:’82’,’235′:’83’,’236′:’84’,’237′:’45’,’238′:’46’,\’239′:’85’,’240′:’51’,’241′:’52’,’242′:’86’,’245′:’40’,’247′:’44’,’248′:’87’,’249′:’43’,’250′:’88’,’251′:’89’,’252′:’42’,\’260′:’38’,’261′:’38’,’271′:’41’,\’279′:’90’,’280′:’39’,’281′:’61’,’282′:’91’\}
#替换特殊字符函数def cleanchar(str): str=str.replace(‘?’,’oe’) str=str.replace(‘é’,’e’) str=str.replace(‘è’,’e’) str=str.replace(‘?’,’e’) str=str.replace(‘?’,’i’) str=str.replace(‘ê’,’e’) str=str.replace(‘a’,’a’) str=str.replace(‘à’,’a’) str=str.replace(‘?’,’u’) str=str.replace(‘ü’,’u’) str=str.replace(‘?’,’ae’) str=str.replace(‘?’,’o’) str=str.replace(‘?’,’o’) str=str.replace(‘?’,’c’) str=str.replace(‘?’,’i’) str=str.replace(‘?’,’i’) str=str.replace(‘?’,’i’) str=str.replace(“‘”,””) str=str.lower() str=str.strip() return str
#函数，检查是否有相同的url,有则返回新urldef check_url(product_name,sku): cursor1=cnn_magento1.cursor() cursor1.execute(“select value from catalog_product_entity_varchar where entity_type_”+str.strip(product_name)+”‘”) #result=cursor1.execute(“select value_id from catalog_product_entity_varchar where entity_type_”+str.strip(test)+”‘”) #print (“select value_id from catalog_product_entity_varchar where entity_type_”+str.strip(product_name)+”‘”) row=cursor1.fetchall() if len(row)!=0: rstr = r”[\/\\\:\*\?\”\\|]” url=str.strip(re.sub(rstr, “-“, product_name)) url=url.replace(‘?’,’oe’) url=url.replace(‘é’,’e’) url=url.replace(‘è’,’e’) url=url.replace(‘?’,’e’) url=url.replace(‘?’,’i’) url=url.replace(‘ê’,’e’) url=url.replace(‘a’,’a’) url=url.replace(‘à’,’a’) url=url.replace(‘?’,’u’) url=url.replace(‘ü’,’u’) url=url.replace(‘?’,’ae’) url=url.replace(‘?’,’o’) url=url.replace(‘?’,’o’) url=url.replace(‘?’,’c’) url=url.replace(‘?’,’i’) url=url.replace(‘?’,’i’) url=url.replace(‘?’,’i’) url=url.replace(“‘”,””) url=url.lower() url=url.replace(‘ ‘,’-‘)+’_’+sku.lower() return url else: rstr = r”[\/\\\:\*\?\”\\|]” url=str.strip(re.sub(rstr, “-“, product_name)) url=url.replace(‘?’,’oe’) url=url.replace(‘é’,’e’) url=url.replace(‘è’,’e’) url=url.replace(‘?’,’e’) url=url.replace(‘?’,’i’) url=url.replace(‘ê’,’e’) url=url.replace(‘a’,’a’) url=url.replace(‘à’,’a’) url=url.replace(‘?’,’u’) url=url.replace(‘ü’,’u’) url=url.replace(‘?’,’ae’) url=url.replace(‘?’,’o’) url=url.replace(‘?’,’o’) url=url.replace(‘?’,’c’) url=url.replace(‘?’,’i’) url=url.replace(‘?’,’i’) url=url.replace(‘?’,’i’) url=url.replace(“‘”,””) url=url.lower() url=url.replace(‘ ‘,’-‘) return url #函数，拷贝zencart产品图片到magento目录并根据产品名重命名def copy_image_to_magento(image,sku,product_name,if_addition_image=false): if if_addition_image: #去除路径，获取图片名称 image_name=os.path.basename(zencart_image_dir+image) #获取图片类型（后缀） extension = os.path.splitext(image_name)[1] #分拆图片名称 image_all=image_name.split(‘_’)
#新的图片名称重命名后与产品名称一样（正则替换掉非法字符如/,\，|,*等） rstr = r”[\/\\\:\*\?\”\\|]” new_image_name_noextension=str.strip(re.sub(rstr, “-“, product_name))
new_image_name_noextension=cleanchar(new_image_name_noextension) new_image_name=new_image_name_noextension+”_”+image_all[1] #判断图片是否存在 if os.path.isfile(magento_image_dir+new_image_name): print (“\t\t\t\t存在图片”+new_image_name) shutil.copy(zencart_image_dir+image,magento_image_dir+new_image_name_noextension+”_”+sku+”_”+image_all[1]) return ‘/’+new_image_name_noextension+”_”+sku+”_”+image_all[1] else: print (“\t\t\t不存在图片”+new_image_name+”，执行拷贝图片并重命名”) #不存在图片则拷贝图片到magento目录并重命名 shutil.copy(zencart_image_dir+image, magento_image_dir+new_image_name) return ‘/’+new_image_name
else: #去除路径，获取图片名称 image_name=os.path.basename(zencart_image_dir+image) #获取图片类型（后缀） extension = os.path.splitext(image_name)[1] #新的图片名称重命名后与产品名称一样（正则替换掉非法字符如/,\，|,*等） rstr = r”[\/\\\:\*\?\”\\|]” new_image_name_noextension=str.strip(re.sub(rstr, “-“, product_name)) new_image_name_noextension=cleanchar(new_image_name_noextension)
new_image_name=cleanchar(str.strip(re.sub(rstr, “-“, product_name)))+extension #先判断图片是否存在 if os.path.isfile(magento_image_dir+new_image_name): print (“\t\t\t\t存在图片”+magento_image_dir+new_image_name+”\n”) #存在图片，则加sku shutil.copy(zencart_image_dir+image, magento_image_dir+new_image_name_noextension+”_”+sku+extension) return ‘/’+new_image_name_noextension+”_”+sku+extension else: print (“\t\t\t\t不存在图片”+magento_image_dir+new_image_name+”，执行拷贝图片并重命名\n”) #不存在图片则拷贝图片到magento目录并重命名 shutil.copy(zencart_image_dir+image, magento_image_dir+new_image_name) return ‘/’+new_image_name
product_sql=’select * from products’cursor=cnn.cursor()cursor1=cnn.cursor()cursor.execute(product_sql)cursor.fetchall()
#返回产品总个数numrows = cursor.rowcount
i=0cursor1.execute(product_sql)print (“作者：凋零（qq:342103944）”)print (“开始获取zencart数据库产品信息……….”)time.sleep(3)for row in cursor1.fetchall(): #临时产品列表 temp_product=[] #存放产品信息，字典类型 product_info={} for r in row: #循环存放产品信息到产品列表 temp_product.append(r) product_info[‘product_id’]=temp_product[0] product_info[‘sku’]=temp_product[3] product_info[‘product_image’]=temp_product[4] product_info[‘price’]=temp_product[5] product_info[‘silhouette’]=temp_product[6].replace(‘\n’,”) product_info[‘neckline’]=temp_product[7].replace(‘\n’,”) product_info[‘waist’]=temp_product[8].replace(‘\n’,”) product_info[‘hemline’]=temp_product[9].replace(‘\n’,”) product_info[‘sleeve_length’]=temp_product[10].replace(‘\n’,”) product_info[‘sleeve_type’]=temp_product[11].replace(‘\n’,”) product_info[‘fabric’]=temp_product[12].replace(‘\n’,”) product_info[’embellishment’]=temp_product[13].replace(‘\n’,”) product_info[‘belt_fabric’]=temp_product[14].replace(‘\n’,”) product_info[‘back_detail’]=temp_product[15].replace(‘\n’,”) product_info[‘fully_lined’]=temp_product[16].replace(‘\n’,”) product_info[‘built_in_bra’]=temp_product[17].replace(‘\n’,”) product_info[‘body_shape’]=temp_product[18].replace(‘\n’,”) product_info[‘season’]=temp_product[19].replace(‘\n’,”) product_info[‘color’]=temp_product[20].replace(‘\n’,”) product_info[‘special_price’]=temp_product[42] product_info[‘master_categories_id’]=temp_product[43] product_info[‘product_name’]=get_productdescription(product_info[‘product_id’])[‘name’] product_info[‘addtion_image’]=get_productaddtionimage(product_info[‘product_image’]) product_info[‘product_categories’]=get_product_categories(product_info[‘product_id’])
products.append(product_info) i=i+1
cursor1.closeprint (“获取数据完毕总共数据为：”+str(i)+”条”)time.sleep(1)print (“开始转存数据到magento库…….”)time.sleep(1)#—————————————-##—— —-##—— 开始存储数据到magento库 —-##—— —-##—————————————-#
cursor=cnn_magento.cursor()cursor.execute(“set foreign_key_checks = 0”)not_import_categores_product_id’]
product_sku=products[j][‘sku’] product_baseimage=products[j][‘product_image’] product_price=products[j][‘price’] product_silhouette=products[j][‘silhouette’] product_neckline=products[j][‘neckline’] product_waist=products[j][‘waist’] product_hemline=products[j][‘hemline’] product_sleeve_length=products[j][‘sleeve_length’] product_sleeve_type=products[j][‘sleeve_type’] product_fabric=products[j][‘fabric’] product_embellishment=products[j][’embellishment’] product_belt_fabric=products[j][‘belt_fabric’] product_back_detail=products[j][‘back_detail’] product_fully_lined=products[j][‘fully_lined’] product_built_in_bra=products[j][‘built_in_bra’] product_body_shape=products[j][‘body_shape’] product_season=products[j][‘season’] product_color=products[j][‘color’] product_special_price=products[j][‘special_price’] product_master_categories_master_categories_id’] product_name=products[j][‘product_name’] product_addtion_image=products[j][‘addtion_image’] product_to_categories=products[j][‘product_categories’]
#判断两个数据库之间分类是否对应，然后插入数据到magneto库，没有则不执行 if str(product_master_categories_id) in categories_to.keys(): p=p+1 print (“—第【”+str(p)+”】条：”+product_sku) #开始转存数据到catalog_product_entity表 cursor.execute(“insert into catalog_product_entity set entity_type_simple’,sku='”+product_sku+”‘,created_at=’2013-05-27 03:18:42′,updated_at=’2013-05-29 07:59:35’,has_options=1,required_options=1”)
#获取实体（产品）id catalog_entity_id=cursor.lastrowid
#插入数据到产品分类对应表 for categories_id in product_to_categories: if str(categories_id) in categories_to.keys(): cursor.execute(“insert into catalog_category_product set category_,product_,position=1”) for i in range(1,4): cursor.execute(“insert into catalog_category_product_index set category_,product_,position=1,is_parent=1,store_,visibility=4”)
#插入产品相关值到实体时间值表 cursor.execute(“insert into catalog_product_entity_datetime set entity_type_+str(catalog_entity_id)+”,value=’2013-05-19 00:00:00′”) cursor.execute(“insert into catalog_product_entity_datetime set entity_type_+str(catalog_entity_id)+”,value=’2013-05-25 00:00:00′”) cursor.execute(“insert into catalog_product_entity_datetime set entity_type_+str(catalog_entity_id)) cursor.execute(“insert into catalog_product_entity_datetime set entity_type_+str(catalog_entity_id))
#插入促销价格，如果没促销价格则不执行 if product_special_price!=”:
cursor.execute(“insert into catalog_product_entity_decimal set entity_type_+str(catalog_entity_id)+”,value=”+str(product_special_price))
#插入产品重量，产品价格 cursor.execute(“insert into catalog_product_entity_decimal set entity_type_+str(catalog_entity_id)+”,value=2″) cursor.execute(“insert into catalog_product_entity_decimal set entity_type_+str(catalog_entity_id)+”,value=”+str(product_price)) cursor.execute(“insert into catalog_product_entity_decimal set entity_type_+str(catalog_entity_id))
#插入产品相关值到实体整型表(产品状态，关税，前台可见，制造商，enable_googlecheckout)
cursor.execute(“insert into catalog_product_entity_int set entity_type_+str(catalog_entity_id)+”,value=1″) cursor.execute(“insert into catalog_product_entity_int set entity_type_+str(catalog_entity_id)+”,value=1″) cursor.execute(“insert into catalog_product_entity_int set entity_type_+str(catalog_entity_id)+”,value=4″) cursor.execute(“insert into catalog_product_entity_int set entity_type_+str(catalog_entity_id)) cursor.execute(“insert into catalog_product_entity_int set entity_type_+str(catalog_entity_id)+”,value=1″) cursor.execute(“insert into catalog_product_entity_int set entity_type_+str(catalog_entity_id)+”,value=0″)
#####拷贝产品图片到magento目录并插入到数据库#######
#拷贝并插入主图 base_image_in_magento=copy_image_to_magento(product_baseimage,product_sku,product_name,false) cursor.execute(“insert into catalog_product_entity_media_gallery set attribute_+str(catalog_entity_id)+”,value='”+base_image_in_magento+”‘”) gallery_insert into catalog_product_entity_media_gallery_value set value_,store_) cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value='”+base_image_in_magento+”‘”) #small_image cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value='”+base_image_in_magento+”‘”) #image cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value='”+base_image_in_magento+”‘”)
#拷贝并插入附加图 if len(product_addtion_image)!=0: iii=2 for each_image in product_addtion_image: addition_image_in_magento=copy_image_to_magento(each_image,product_sku,product_name,true) cursor.execute(“insert into catalog_product_entity_media_gallery set attribute_+str(catalog_entity_id)+”,value='”+addition_image_in_magento+”‘”) addition_insert into catalog_product_entity_media_gallery_value set value_,store_+str(iii)+”,disabled=0″) iii=iii+1 #插入产品相关值到实体文本表(产品描述，段描述等) cursor.execute(“insert into catalog_product_entity_text set entity_type_+str(catalog_entity_id)+”,value=’short_description& & '”) cursor.execute(“insert into catalog_product_entity_text set entity_type_+str(catalog_entity_id)) cursor.execute(“insert into catalog_product_entity_text set entity_type_+str(catalog_entity_id)) cursor.execute(“insert into catalog_product_entity_text set entity_type_+str(catalog_entity_id)+”,value=’description& & '”)
#插入产品到catalog_product_entity_varchar(产品名称，url等) #插入name product_name=product_name.replace(“‘”,””) cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value='”+str.strip(product_name)+”‘”) #插入url_key url=check_url(product_name,product_sku) cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value='”+str.strip(url)+”‘”) #manufacture cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)) #msrp_enabled cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value=2″) #msrp_display_actual_price_type cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value=4″) #meta_title #cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value=4″) #meta_description #cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value=4″)
#thumbnail #print (“insert into `catalog_product_entity_varchar` set `entity_type_id`=10,`attribute_id`=493,`store_id`=0,`entity_id`=”+str(catalog_entity_id)+”,`value`=’no_selection'”) #input() #cursor.execute(“insert into `catalog_product_entity_varchar` set `entity_type_id`=10,`attribute_id`=493,`store_id`=0,`entity_id`=”+str(catalog_entity_id)+”,`value`=’no_selection'”) #custom_design cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)) #options_container cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value=’container2′”) #page_layout cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)) #gift_message_available cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value=1″)
#thumbnail_label cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)) #small_image_label cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id))
#image_label cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)) #url_path cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value='”+str.strip(url)+”‘”) cursor.execute(“insert into catalog_product_entity_varchar set entity_type_+str(catalog_entity_id)+”,value='”+str.strip(url)+”‘”)
#插入catalog_product_flat(1,2,3)表 for aa in range(1,4): cursor.execute(“insert into catalog_product_flat_”+str(aa)+” set entity_,attribute_set_simple’,created_at=’2013-05-31 06:43:21’\ ,description=’test test ，& ’,enable_googlecheckout=1,has_options=1,image='”+base_image_in_magento+”‘,is_recurring=0,msrp_display_actual_price_type=4\ ,msrp_enabled=2,name='”+product_name+”‘,price=”+str(product_price)+”,required_options=1,short_description=’short description & ’,sku='”+product_sku+”‘\ ,small_image='”+base_image_in_magento+”‘,special_from_date=’2013-05-19 00:00:00′,special_price=”+str(product_special_price)+”,special_to_date=’2014-06-27 00:00:00’\ ,tax_class_no_selection’,updated_at=’2013-05-31 10:38:25′,url_key='”+url+”‘,url_path='”+url+”‘,visibility=4,weight=2″) for aa in range(1,4): cursor.execute(“insert into catalog_product_index_eav set entity_,attribute_+str(aa)+”,value=1″) cursor.execute(“insert into catalog_product_index_eav set entity_,attribute_+str(aa)+”,value=128″)
#catalog_product_index_eav_idx for aa in range(1,4): cursor.execute(“insert into catalog_product_index_eav_idx set entity_,attribute_+str(aa)+”,value=1″)
#catalog_product_index_price for aa in range(5): cursor.execute(“insert into catalog_product_index_price set entity_,customer_group_,website_+str(product_price)+”\ ,final_price=”+str(product_special_price)+”,min_price=”+str(product_special_price)+”,max_price=”+str(product_special_price)) #catalog_product_index_price_idx for aa in range(5): cursor.execute(“insert into catalog_product_index_price_idx set entity_,customer_group_,website_+str(product_price)+”\ ,final_price=”+str(product_special_price)+”,min_price=”+str(product_special_price)+”,max_price=”+str(product_special_price)) #catalog_product_website cursor.execute(“insert into catalog_product_website set product_,website_)
#cataloginventory_stock_item cursor.execute(“insert into cataloginventory_stock_item set product_,stock_) #cataloginventory_stock_status cursor.execute(“insert into cataloginventory_stock_status set product_,website_) #cataloginventory_stock_status_idx cursor.execute(“insert into cataloginventory_stock_status_idx set product_,website_) cnn_magento.commit() else: print (“\t\t\tid[“+str(product_master_categories_id)+”]在magneto库中没有与之对应的id，跳过此分类”) not_import_categores_id.append(str(product_master_categories_id))
cursor.execute(“set foreign_key_checks = 1”)cursor.closeprint (“导入完成”)print (“一共有”+str(len(not_import_categores_id))+”没导入”)