Merge lp:~cv.clearcorp/openerp-ccorp-addons/6.1-sneldev_magento into lp:openerp-ccorp-addons/6.1

[Carlos Vásquez (ClearCorp)]

[ADD] module connector for openerp 6.1 and magento 1.7

[lp:~cv.clearcorp/openerp-ccorp-addons/6.1-sneldev_magento]

596. By diana rodriguez <email address hidden> on 2012-09-11

[FIX] Import customers and contact
[FIX] Export stock from Magento

=== added directory 'sneldev_magento'
=== added file 'sneldev_magento/__init__.py'
--- sneldev_magento/__init__.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/__init__.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,31 @@
+# -*- encoding: utf-8 -*-
+##############################################################################
+#
+# Copyright (c) 2009 SnelDev (http://www.sneldev.com) All Rights Reserved.
+#
+# WARNING: This program as such is intended to be used by professional
+# programmers who take the whole responsability of assessing all potential
+# consequences resulting from its eventual inadequacies and bugs
+# End users who are looking for a ready-to-use solution with commercial
+# garantees and support are strongly adviced to contract a Free Software
+# Service Company
+#
+# This program is Free Software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; either version 2
+# of the License, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+##############################################################################
+
+import sneldev_magento
+import wizard
+import report
\ No newline at end of file

=== added file 'sneldev_magento/__openerp__.py'
--- sneldev_magento/__openerp__.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/__openerp__.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,52 @@
+# -*- encoding: utf-8 -*-
+##############################################################################
+#
+# Copyright (c) 2009 SnelDev (http://www.sneldev.com) All Rights Reserved.
+#
+# WARNING: This program as such is intended to be used by professional
+# programmers who take the whole responsability of assessing all potential
+# consequences resulting from its eventual inadequacies and bugs
+# End users who are looking for a ready-to-use solution with commercial
+# garantees and support are strongly adviced to contract a Free Software
+# Service Company
+#
+# This program is Free Software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; either version 2
+# of the License, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+##############################################################################
+{
+    "name" : "Magento-OpenERP Interface",
+    "version" : "0.9.2.6",
+    "author" : "SnelDev",
+    "category" : "Interfaces/CMS & eCommerce",
+    "website" : "http://www.sneldev.com/",
+    "depends" : ["product", "stock", "sale", "account", "account_analytic_default"],
+    "description": "Magento-OpenERP Interface from SnelDev ([e-mail])\n\nExternal contributors:\n\tArnold Ligtvoet ([e-mail])",
+    "init_xml" : [],
+    "icon" : "icon.png",
+    "demo_xml" : [],
+    "update_xml" :  ['security/ir.model.access.csv',
+                     'wizard/sneldev_magento_categories_import.xml',
+                     'wizard/sneldev_magento_orders_import.xml',
+                     'wizard/sneldev_magento_products_import.xml',
+                     'wizard/sneldev_magento_customers_import.xml',
+                     'wizard/sneldev_magento_stock_init.xml',
+                     'wizard/sneldev_magento_products_export.xml',
+                     'wizard/sneldev_magento_stock_export.xml',
+                     'wizard/sneldev_magento_sync_start.xml',
+                     'wizard/sneldev_magento_sync_stop.xml',
+                     'sneldev_magento_view.xml'],
+    "active": False,
+    "installable": True
+}

=== added file 'sneldev_magento/common_tools.py'
--- sneldev_magento/common_tools.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/common_tools.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,116 @@
+#!/usr/bin/env python
+# -*- encoding: utf-8 -*-
+##############################################################################
+#
+# Copyright (c) 2009 SnelDev (http://www.sneldev.com) All Rights Reserved.
+#
+# WARNING: This program as such is intended to be used by professional
+# programmers who take the whole responsability of assessing all potential
+# consequences resulting from its eventual inadequacies and bugs
+# End users who are looking for a ready-to-use solution with commercial
+# garantees and support are strongly adviced to contract a Free Software
+# Service Company
+#
+# This program is Free Software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; either version 2
+# of the License, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+##############################################################################
+
+import sys
+import traceback
+import wizard
+import pooler
+import os
+import xmlrpclib
+from xmlrpclib import ServerProxy, Error
+from mx import DateTime
+import datetime
+import threading
+
+#Globals for syncrhonisation
+export_lock=threading.Lock();
+export_running=False;
+
+#Thread safe version of export_running
+def export_is_running():
+    global export_running
+    
+    retVal=False
+    export_lock.acquire()  
+    if (export_running == False):
+        export_running=True
+        retVal=False
+    else:
+        retVal=True  
+    export_lock.release()
+    return retVal
+
+def set_export_finished():
+    global export_running
+    export_running=False
+
+def magento_connect(self, cr, uid):
+    try:
+        ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+        export = self.pool.get('sneldev.magento').browse(cr, uid, [ids[0]])
+        server_address = export[0]['url']
+        if not server_address[-1:] == '/':
+            server_address = server_address + "/"
+        server_address = server_address + "index.php/api/xmlrpc/?wsdl"
+        server = ServerProxy(server_address)
+        session = server.login(export[0]['api_user'], export[0]['api_pwd'])
+        return [True, server, session]
+    except:
+        traceback.print_exc()
+        return [False, sys.exc_info()[0], False]
+            
+def to_proper_uni( text):
+    return text.encode('iso-8859-1', 'replace')
+
+def to_uni( text ):
+    return unicode(text, 'iso-8859-1')
+
+class sneldev_log:
+    _logfile = None
+    _logs = False
+
+    def __init__(self, filename):
+        try:
+            self._logfile = open('/var/log/openerp/'+filename , 'a')
+        except:
+            # Oops
+            self._logfile = False
+    
+    def define(self, logs, cr, uid):
+        self._logs = logs
+        self._cr = cr
+        self._uid = uid
+            
+    def append(self, log_line):
+        try:
+          log_line = unicode(log_line).encode('iso-8859-1', 'replace')
+        except:
+          pass
+          
+        log_line = str(datetime.datetime.now()).split('.',1)[0] + " " + log_line + "\n"
+        if (self._logfile):
+            self._logfile.write(log_line)
+            self._logfile.flush()
+            
+        if (self._logs):
+            self._logs.create(self._cr, self._uid, {'text': log_line})    
+    
+    def print_traceback(self):
+        traceback.print_exc(file=self._logfile)
+        self._logfile.flush()
\ No newline at end of file

=== added directory 'sneldev_magento/i18n'
=== added file 'sneldev_magento/i18n/es_CR.po'
--- sneldev_magento/i18n/es_CR.po	1970-01-01 00:00:00 +0000
+++ sneldev_magento/i18n/es_CR.po	2012-09-11 15:12:19 +0000
@@ -0,0 +1,439 @@
+# Translation of OpenERP Server.
+# This file contains the translation of the following modules:
+#	* sneldev_magento
+#
+msgid ""
+msgstr ""
+"Project-Id-Version: OpenERP Server 6.1\n"
+"Report-Msgid-Bugs-To: \n"
+"POT-Creation-Date: 2012-08-20 16:14+0000\n"
+"PO-Revision-Date: 2012-08-20 16:14+0000\n"
+"Last-Translator: <>\n"
+"Language-Team: \n"
+"MIME-Version: 1.0\n"
+"Content-Type: text/plain; charset=UTF-8\n"
+"Content-Transfer-Encoding: \n"
+"Plural-Forms: \n"
+
+#. module: sneldev_magento
+#: sql_constraint:sale.order:0
+msgid "Order Reference must be unique per Company!"
+msgstr "¡La referencia de la compra debe ser única por compañía!"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_magento_form
+msgid "Magento"
+msgstr "Magento"
+
+#. module: sneldev_magento
+#: view:sneldev.stock.export:0
+msgid "This wizard will export stock to Magento."
+msgstr "Esta opción exportará las existencias a Magento."
+
+#. module: sneldev_magento
+#: field:sneldev.magento,inital_stock_location:0
+msgid "Location for stock initialization"
+msgstr "Localización para la inicialización de existencias"
+
+#. module: sneldev_magento
+#: view:sneldev.customers.import:0
+msgid "This wizard will import customers from Magento."
+msgstr "Este asistente importará los clientes desde Magento ."
+
+#. module: sneldev_magento
+#: field:sneldev.magento,import_credit_memos:0
+msgid "Import credit memos after importing orders"
+msgstr "Importar notas de crédito después de importar las órdenes"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_products_import
+msgid "Import Products"
+msgstr "Importar productos"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_orders_import
+msgid "Import Orders"
+msgstr "Importar órdenes"
+
+#. module: sneldev_magento
+#: view:sneldev.sync.stop:0
+msgid "You will now stop the automatic synchronization."
+msgstr "Se detendrá ahora la sincronización automática."
+
+#. module: sneldev_magento
+#: field:product.category,modified:0
+#: field:product.product,modified:0
+msgid "Modified since last synchronization"
+msgstr "Modificado desde la última sincronización"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,api_pwd:0
+msgid "API Password"
+msgstr "Contraseña API"
+
+#. module: sneldev_magento
+#: field:product.product,qty_magento:0
+msgid "Magento Stock"
+msgstr "Existencias en Magento"
+
+#. module: sneldev_magento
+#: constraint:sneldev.magento:0
+msgid "Only one website supported at this time."
+msgstr "Sólo un sitio web es compatible en este momento."
+
+#. module: sneldev_magento
+#: view:sneldev.orders.import:0
+msgid "This wizard will import orders from Magento. It will first import categories and products."
+msgstr "Este asistente importará las órdenes de Magento. En primer lugar, se importarán las categorías y productos."
+
+#. module: sneldev_magento
+#: field:product.product,export_to_magento:0
+#: field:res.partner,export_to_magento:0
+msgid "Export to Magento"
+msgstr "Exportar a Magento"
+
+#. module: sneldev_magento
+#: view:sneldev.categories.import:0
+#: view:sneldev.customers.import:0
+#: view:sneldev.orders.import:0
+#: view:sneldev.products.import:0
+msgid "Import"
+msgstr "Importar"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_stock_init
+#: view:sneldev.stock.init:0
+msgid "Initialize stock"
+msgstr "Initializar existencias"
+
+#. module: sneldev_magento
+#: view:sneldev.products.export:0
+msgid "Export products"
+msgstr "Exportar productos"
+
+#. module: sneldev_magento
+#: view:sneldev.magento:0
+msgid "Automatic Synchronization Settings"
+msgstr "Configuración de la sincronización automática"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_categories_import
+msgid "Compute Categories"
+msgstr "Calcular categorías"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_customers_import
+#: model:ir.model,name:sneldev_magento.model_sneldev_customers_import
+#: view:sneldev.customers.import:0
+msgid "Import customers"
+msgstr "Importar clientes"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_product_product
+msgid "Product"
+msgstr "Producto"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_product_category
+msgid "Product Category"
+msgstr "Categoría de producto"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_import_credit_memos:0
+msgid "Automatic credit memos import"
+msgstr "Importar automáticamente notas de crédito"
+
+#. module: sneldev_magento
+#: field:product.category,magento_id:0
+#: field:product.product,magento_id:0
+#: field:res.partner,magento_id:0
+#: field:sale.order,magento_id:0
+msgid "Magento ID"
+msgstr "Magento ID"
+
+#. module: sneldev_magento
+#: view:sneldev.products.import:0
+msgid "This wizard will import products from Magento. It will first import categories."
+msgstr "Este asistente importará productos de Magento. En primer lugar, va a importar categorías."
+
+#. module: sneldev_magento
+#: view:sneldev.categories.import:0
+msgid "This wizard will import categories from Magento."
+msgstr "Este asistente importará categorías de Magento."
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_invoice_open:0
+msgid "Imported invoices automatically goes to Open state"
+msgstr "Facturas importadas pasarán automáticamente a estado abierto"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_import_orders:0
+msgid "Automatic orders import"
+msgstr "Importar órdenes automáticamente"
+
+#. module: sneldev_magento
+#: view:sneldev.stock.init:0
+msgid "This wizard will create an inventory from Magento stock. This will remove all current stock information in OpenERP !"
+msgstr "Este asistente creará un inventario de las existencias de Magento. Esto eliminará toda la información actual de las existencias en OpenERP!"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_export_stock:0
+msgid "Automatic stock export"
+msgstr "Exportar existencias automáticamente"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,sync_script_pid:0
+msgid "PID of Sync Script"
+msgstr "PID del script Sync"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,sync_sleep:0
+msgid "Time between synchronizations"
+msgstr "Tiempo entre sincronizaciones"
+
+#. module: sneldev_magento
+#: view:sneldev.sync.start:0
+msgid "You will now start the automatic synchronization."
+msgstr "Ahora se iniciará la sincronización automática."
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_sneldev_orders_import
+#: model:ir.model,name:sneldev_magento.model_sneldev_products_import
+#: view:sneldev.orders.import:0
+msgid "Import orders"
+msgstr "Importar órdenes"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_sneldev_categories_import
+#: view:sneldev.categories.import:0
+msgid "Import categories"
+msgstr "Importar categorías"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_sneldev_products_export
+msgid "Export orders"
+msgstr "Exportar órdenes"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_products_export
+msgid "Export Products"
+msgstr "Exportar Productos"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,last_imported_category_timestamp:0
+msgid "Timestamp of latest imported category"
+msgstr "Fecha y hora de la última categoría importada"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_sync_start
+#: model:ir.model,name:sneldev_magento.model_sneldev_sync_start
+#: view:sneldev.sync.start:0
+msgid "Start Synchronization"
+msgstr "Iniciar sincronización"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_sneldev_stock_export
+#: view:sneldev.stock.export:0
+msgid "Export stock"
+msgstr "Exportar existencias"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,default_category:0
+msgid "Default category for imported products"
+msgstr "Categoría por defecto para productos importados"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,name:0
+msgid "Name"
+msgstr "Nombre"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,sync_status:0
+msgid "Synchronisation status"
+msgstr "Estado de la sincronización"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,api_user:0
+msgid "API User"
+msgstr "Usuario API"
+
+#. module: sneldev_magento
+#: view:sneldev.magento:0
+msgid "Initial Inventory"
+msgstr "Inventario inicial"
+
+#. module: sneldev_magento
+#: view:sneldev.products.export:0
+msgid "This wizard will export products to Magento. It will first export categories."
+msgstr "Este asistente exportar productos a Magento. En primer lugar, se exportará categorías."
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_sneldev_magento
+msgid "Magento website infos"
+msgstr "Magento website infos"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_sneldev_stock_init
+msgid "Initialize stock from Magento"
+msgstr "Inicializar existencias desde Magento"
+
+#. module: sneldev_magento
+#: view:sneldev.magento:0
+msgid "Product Import Settings"
+msgstr "Configuración de importación de productos"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,last_imported_product_timestamp:0
+msgid "Timestamp of latest imported product"
+msgstr "Fecha y hora del último producto importado"
+
+#. module: sneldev_magento
+#: code:addons/sneldev_magento/sneldev_magento.py:819
+#, python-format
+msgid "Error"
+msgstr "Error"
+
+#. module: sneldev_magento
+#: view:sneldev.sync.stop:0
+msgid "Stop"
+msgstr "Alto"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_invoice_paid:0
+msgid "Imported invoices automatically goes to Paid state"
+msgstr "Facturas importados automáticamente pasa al estado Pagado"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,payment_journal:0
+msgid "Payment Journal"
+msgstr "Pago del diario"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,shipping_product:0
+msgid "Shipping Product"
+msgstr "Envío del producto"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_stock_export
+msgid "Export Stock"
+msgstr "Exportar existencias"
+
+#. module: sneldev_magento
+#: model:ir.actions.act_window,name:sneldev_magento.action_sneldev_sync_stop
+#: model:ir.model,name:sneldev_magento.model_sneldev_sync_stop
+#: view:sneldev.sync.stop:0
+msgid "Stop Synchronization"
+msgstr "Detener sincronización"
+
+#. module: sneldev_magento
+#: model:ir.ui.menu,name:sneldev_magento.menu_magento_form
+#: view:sneldev.magento:0
+msgid "Magento Settings"
+msgstr "Configuración"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_import_products:0
+msgid "Automatic products import"
+msgstr "Importación de productos automáticamente"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_script_path:0
+msgid "Syncronization Script Path"
+msgstr "Ruta del script de sincronización"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,auto_export_products:0
+msgid "Automatic products export"
+msgstr "Exportar productos automáticamente"
+
+#. module: sneldev_magento
+#: view:sneldev.stock.init:0
+#: view:sneldev.sync.start:0
+msgid "Start"
+msgstr "Inicio"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,last_imported_invoice_timestamp:0
+msgid "Timestamp of latest imported invoice"
+msgstr "Fecha y hora de la última importación de facturas"
+
+#. module: sneldev_magento
+#: view:sneldev.products.import:0
+msgid "Import products"
+msgstr "Importar productos"
+
+#. module: sneldev_magento
+#: view:sneldev.magento:0
+msgid "Magento website"
+msgstr "Sitio web de Magento"
+
+#. module: sneldev_magento
+#: constraint:product.category:0
+msgid "Error ! You cannot create recursive categories."
+msgstr "¡Error! No puede crear categorías recursivas"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,magento_root_cat_id:0
+msgid "Magento Root category ID"
+msgstr "Magento Root category ID"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,last_creditmemo_id:0
+msgid "Last imported credit memo"
+msgstr "Última importación de notas de crédito"
+
+#. module: sneldev_magento
+#: view:sneldev.magento:0
+msgid "Orders Import Settings"
+msgstr "Configuración de importación de órdenes"
+
+#. module: sneldev_magento
+#: code:addons/sneldev_magento/sneldev_magento.py:819
+#, python-format
+msgid "Import already running"
+msgstr "La importación ya se está ejecutando"
+
+#. module: sneldev_magento
+#: constraint:product.product:0
+msgid "Error: Invalid ean code"
+msgstr "Error: Código EAN erróneo"
+
+#. module: sneldev_magento
+#: view:sneldev.products.export:0
+#: view:sneldev.stock.export:0
+msgid "Export"
+msgstr "Exportar"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,last_invoice_id:0
+msgid "Last imported sale order"
+msgstr "Úlitma orden de compra importada"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_res_partner
+msgid "Partner"
+msgstr "Empresa"
+
+#. module: sneldev_magento
+#: view:sneldev.categories.import:0
+#: view:sneldev.customers.import:0
+#: view:sneldev.orders.import:0
+#: view:sneldev.products.export:0
+#: view:sneldev.products.import:0
+#: view:sneldev.stock.export:0
+#: view:sneldev.stock.init:0
+#: view:sneldev.sync.start:0
+#: view:sneldev.sync.stop:0
+msgid "Cancel"
+msgstr "Cancelar"
+
+#. module: sneldev_magento
+#: field:sneldev.magento,url:0
+msgid "Magento base URL"
+msgstr "URL de la tienda de Magento"
+
+#. module: sneldev_magento
+#: model:ir.model,name:sneldev_magento.model_sale_order
+msgid "Sales Order"
+msgstr "Pedido de venta"
+

=== added directory 'sneldev_magento/security'
=== added file 'sneldev_magento/security/ir.model.access.csv'
--- sneldev_magento/security/ir.model.access.csv	1970-01-01 00:00:00 +0000
+++ sneldev_magento/security/ir.model.access.csv	2012-09-11 15:12:19 +0000
@@ -0,0 +1,2 @@
+"id","name","model_id:id","group_id:id","perm_read","perm_write","perm_create","perm_unlink"
+"access_sneldev_magento","Magento Settings","model_sneldev_magento","base.group_user",1,0,0,0

=== added file 'sneldev_magento/sneldev_magento.py'
--- sneldev_magento/sneldev_magento.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/sneldev_magento.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,1528 @@
+#!/usr/bin/env python
+# -*- encoding: utf-8 -*-
+##############################################################################
+#
+# Copyright (c) 2009 SnelDev (http://www.sneldev.com) All Rights Reserved.
+#
+# WARNING: This program as such is intended to be used by professional
+# programmers who take the whole responsability of assessing all potential
+# consequences resulting from its eventual inadequacies and bugs
+# End users who are looking for a ready-to-use solution with commercial
+# garantees and support are strongly adviced to contract a Free Software
+# Service Company
+#
+# This program is Free Software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; either version 2
+# of the License, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+##############################################################################
+
+from osv import fields,osv
+from mx import DateTime
+import netsvc
+import tools
+import pooler
+import time
+import datetime
+import math
+import os
+import traceback
+from common_tools import *
+import traceback
+from pprint import pprint
+
+from tools.translate import _
+
+log = sneldev_log("magento_export.log");
+
+class sneldev_magento(osv.osv):
+    _name = 'sneldev.magento'
+    _description = 'Magento website infos'
+    _columns = {
+        'name': fields.char('Name', size=128), 
+        'url': fields.char('Magento base URL', size=128), 
+        'api_user': fields.char('API User', size=64),
+        'api_pwd': fields.char('API Password', size=64),
+        'auto_export_stock': fields.boolean('Automatic stock export'),
+        'auto_export_products': fields.boolean('Automatic products export'),
+        'auto_import_products': fields.boolean('Automatic products import'),
+        'auto_import_orders': fields.boolean('Automatic orders import'),
+        'auto_import_credit_memos': fields.boolean('Automatic credit memos import'),
+        'auto_script_path': fields.char('Syncronization Script Path', size=256),
+        'sync_sleep': fields.integer('Time between synchronizations'),
+        'sync_script_pid': fields.integer('PID of Sync Script'),
+        'sync_status': fields.char('Synchronisation status', size=128),
+        'shipping_product': fields.many2one('product.product', 'Shipping Product', required=True, change_default=True),
+        'default_category': fields.many2one('product.category', 'Default category for imported products', required=True, change_default=True),
+        'magento_root_cat_id': fields.integer('Magento Root category ID'),
+        'last_imported_product_timestamp': fields.char('Timestamp of latest imported product', size=128),
+        'last_imported_category_timestamp': fields.char('Timestamp of latest imported category', size=128),
+        'last_imported_invoice_timestamp': fields.char('Timestamp of latest imported invoice', size=128),
+        'payment_journal': fields.many2one('account.journal', 'Payment Journal'),  
+        'last_invoice_id': fields.integer('Last imported sale order'),
+        'last_creditmemo_id': fields.integer('Last imported credit memo'),
+        'auto_invoice_open': fields.boolean('Imported invoices automatically goes to Open state'),
+        'auto_invoice_paid': fields.boolean('Imported invoices automatically goes to Paid state'),
+        'inital_stock_location': fields.many2one('stock.location', 'Location for stock initialization'),
+        'import_credit_memos': fields.boolean('Import credit memos after importing orders'),
+    }
+    
+    _defaults = {
+        'auto_export_stock': lambda *a: False,
+        'auto_export_products': lambda *a: False,
+        'auto_import_products': lambda *a: False,
+        'auto_import_orders': lambda *a: False,
+        'auto_import_credit_memos': lambda *a: False,
+        'sync_sleep': lambda *a: 300,
+        'sync_script_pid': lambda *a: -1,
+        'last_creditmemo_id' : lambda *a: -1,
+        'last_invoice_id': lambda *a: -1,
+        'sync_status': lambda *a: 'Idle',
+        'last_imported_invoice_timestamp': lambda *a: '2011-01-01',
+        'magento_root_cat_id': lambda *a: -1,
+        'auto_invoice_open': lambda *a: False,
+        'auto_invoice_paid': lambda *a: False,
+    }
+    
+    def _unique(self, cr, uid, ids):
+        res = self.pool.get('sneldev.magento').search(cr, uid,[])
+        if len(res) > 1 :
+            return False
+        else :
+            return True
+    
+    _constraints = [
+        (_unique, 'Only one website supported at this time.', [])
+    ]
+
+
+    ##################################################################
+    # Common functions
+    ##################################################################  
+    def get_magento_params(self, cr, uid):
+        try:
+            website_ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+            magento_params = self.pool.get('sneldev.magento').browse(cr, uid, [website_ids[0]])
+            return magento_params
+        except:
+            log.append('Cannot find Magento shop')   
+            raise osv.except_osv(_('Error !'), _('Cannot find Magento shop'))
+        
+    ##################################################################
+    # Scheduler
+    ##################################################################   
+    def get_params(self, cr, uid):
+        try:
+            website_ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+            magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+            return {
+                'sync_sleep': magento_params[0].sync_sleep, 
+                'auto_export_stock': magento_params[0].auto_export_stock,
+                'auto_export_products': magento_params[0].auto_export_products, 
+                'auto_export_partners': magento_params[0].auto_export_partners,                 
+                'auto_import_products': magento_params[0].auto_import_products, 
+                'auto_import_orders': magento_params[0].auto_import_orders, 
+                'auto_import_partners':magento_params[0].auto_import_partners,
+                'auto_import_credit_memos': magento_params[0].auto_import_credit_memos,
+                'sync_script_pid': magento_params[0].sync_script_pid,
+            }
+        except:
+            return -1    
+            
+    def set_status(self, cr, uid, status):
+        ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+        self.pool.get('sneldev.magento').write(cr, uid, ids[0], {'sync_status': str(status)})        
+        return 0
+        
+    def set_pid(self, cr, uid, pid):
+        ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+        self.pool.get('sneldev.magento').write(cr, uid, ids[0], {'sync_script_pid': pid})        
+        return 0
+                
+    def sync_start(self, cr, uid):
+        try:
+            log.append('===== Sync start')
+            website_ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+            magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+            if (magento_params[0].auto_script_path):
+                pid = os.spawnl(os.P_NOWAIT, magento_params[0].auto_script_path)
+            else:   
+                log.append('Script not found in scheduler loop')  
+                raise osv.except_osv(_('Error !'), _('Script not found in scheduler loop'))
+        except:   
+            log.append('Unknown error in scheduler loop')
+            raise osv.except_osv(_('Error !'), _('Unknown error in scheduler loop'))
+        return 0
+        
+    def sync_stop(self, cr, uid):
+        log.append('===== Sync stop')
+        ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+        self.pool.get('sneldev.magento').write(cr, uid, ids[0], {'sync_script_pid': -1})   
+        
+    ##################################################################
+    # Categories export
+    ##################################################################    
+    def export_categories(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        if (export_is_running() == False):
+            try:
+                log.append('===== Category export')
+                website_ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+                magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+                [status, server, session] = magento_connect(self, cr, uid)
+                if not status:
+                    log.append('Cannot connect ' + str(server))   
+                    set_export_finished()  
+                    return -1
+                cat_ids = self.pool.get('product.category').search(cr, uid, [('modified', '=', 'True')])
+                cats = self.pool.get('product.category').browse(cr, uid, cat_ids)
+            except: 
+                set_export_finished()  
+                return -1 
+                     
+            for cat in cats:
+                try:
+                    log.append('Category: ' + cat.name)
+                    if cat.magento_id == -1:
+                        log.append('New')
+                        category_data = {
+                            'name': cat.name, 
+                            'is_active': 1, 
+                            'available_sort_by': 'name,price',
+                            'default_sort_by': 'price', 
+                            'include_in_menu': False,
+                        }
+                        log.append("Parent : " + str(cat.parent_id.magento_id))
+                        magento_id = server.call(session, 'category.create', [1, category_data])
+                        self.pool.get('product.category').write(cr, uid, cat.id, {'magento_id': magento_id, 'modified': False})
+                        if cat.parent_id.magento_id and (cat.parent_id.magento_id != -1):
+                            server.call(session, 'category.move', [magento_id, cat.parent_id.magento_id])
+                        elif magento_params[0].magento_root_cat_id != -1:
+                             server.call(session, 'category.move', [magento_id, magento_params[0].magento_root_cat_id])
+                        log.append(magento_id)
+                    else:
+                        log.append('Old')  
+                        log.append(cat.magento_id)  
+                        category_data = {
+                            'name': cat.name,  
+                            'available_sort_by': 'name,price',
+                        }
+                        server.call(session, 'category.update', [cat.magento_id, category_data])
+                        if cat.parent_id.magento_id and (cat.parent_id.magento_id != -1):
+                            server.call(session, 'category.move', [cat.magento_id, cat.parent_id.magento_id])
+                        self.pool.get('product.category').write(cr, uid, cat.id, {'modified': False})
+                        log.append('Done')  
+                except:
+                    log.append('Error') 
+                    log.print_traceback()   
+                log.append('-----')   
+            set_export_finished()
+            return 0
+        log.append('Export already running')
+        raise osv.except_osv(_('Error !'), _('Export already running'))
+        return -1
+        
+
+    ##################################################################
+    # Products export
+    ##################################################################
+    def export_products(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        if (export_is_running() == False):
+            log.append('===== Product export')
+            [status, server, session] = magento_connect(self, cr, uid)
+            if not status:
+                log.append('Cannot connect ' + str(server))   
+                set_export_finished()  
+                return -1
+            prod_ids = self.pool.get('product.product').search(cr, uid, [('modified', '=', 'True')])
+            prods = self.pool.get('product.product').browse(cr, uid, prod_ids)
+            for prod in prods:
+                try:
+                    log.append('Product: ' + prod.name)
+                    if prod.code and prod.export_to_magento:
+                        attribute_sets = server.call(session, 'product_attribute_set.list');
+                        product_data = {
+                            'status': True,
+                            'name': prod.name,  
+                            'sku': prod.code,
+                        }
+                        if prod.list_price:
+                            product_data['price'] = str(prod.list_price) 
+                        if prod.weight:    
+                             product_data['weight'] = str(prod.weight)
+                        if prod.magento_id == -1:
+                            log.append('New')
+                            magento_id = server.call(session, 'catalog_product.create', ['simple', attribute_sets[0]['set_id'], prod.code, product_data]);
+                            self.pool.get('product.product').write(cr, uid, prod.id, {'magento_id': magento_id, 'modified': False})
+                            log.append(magento_id)
+                            if not prod.categ_id.magento_id == -1:
+                                server.call(session, 'category.assignProduct', [prod.categ_id.magento_id, magento_id]);
+                        else:
+                            log.append('Old')
+                            server.call(session, 'catalog_product.update', [prod.magento_id, product_data]);
+                            self.pool.get('product.product').write(cr, uid, prod.id, {'modified': False})
+                            log.append('Done')            
+                    else:
+                        log.append('Not set for export or no valid code')    
+                        self.pool.get('product.product').write(cr, uid, prod.id, {'modified': False})
+                except:
+                    log.append('Error')  
+                    log.print_traceback()
+                log.append('-----')
+            set_export_finished()
+            return 0
+        log.append('Export already running')
+        raise osv.except_osv(_('Error !'), _('Export already running'))
+        return -1
+
+    ################################################################## 
+    # Stock export
+    ##################################################################
+    def export_stock(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        if (export_is_running() == False):
+            log.append('===== Stock export')
+            [status, server, session] = magento_connect(self, cr, uid)
+            if not status:
+                log.append('Cannot connect ' + str(server))   
+                set_export_finished()  
+                return -1  
+            prod_ids = self.pool.get('product.product').search(cr, uid, [('magento_id', '!=', -1)])
+            prods = self.pool.get('product.product').browse(cr, uid, prod_ids)
+            
+            sku_list = []
+            for prod in prods:
+                sku_list.append(prod.code)
+            res = server.call(session, 'product_stock.list', [sku_list])
+            magento_stock = {}
+            for magento_prod in res:
+                magento_stock[unicode(magento_prod['sku'])] = magento_prod['qty']
+  
+            for i in range(0, len(prod_ids)):
+                try:
+                    try:
+                        if float(prods[i]['qty_magento']) != float(magento_stock[prods[i]['code']]):
+                            entry = [prods[i]['code'], {'qty': prods[i]['qty_magento'], 'is_in_stock': 1}]
+                            server.call(session,'product_stock.update', entry)
+                            log.append(entry)
+                            log.append('-----')
+                    except:
+                        log.append('Creating new stock entry')
+                        entry = [prods[i]['code'], {'qty': prods[i]['qty_magento'], 'is_in_stock': 1}]
+                        server.call(session,'product_stock.update', entry)
+                        log.append(entry)
+                        log.append('-----')
+                except:
+                    log.append('ERROR : ' + prods[i]['code'])
+                    log.print_traceback()
+                    log.append('-----')
+                    raise osv.except_osv(_('Error !'), _('Error with product import'))
+            set_export_finished()
+            return 0 
+       
+        log.append('Export already running') 
+        raise osv.except_osv(_('Error !'), _('Export already running'))  
+    
+        return -1
+
+            
+    ##################################################################
+    # Update customer
+    ##################################################################
+    def update_customer(self, cr, uid, infos):
+        try:
+    		infos['customer_is_guest']
+    	except:
+    		infos['customer_is_guest'] = '0'
+    
+    	if infos['customer_is_guest'] == '1':
+    		infos['customer_id'] = '0'
+    		
+        erp_customer = {  'magento_id' : infos['customer_id'],
+                        'name' : infos['firstname'] + ' ' + infos['lastname'],
+                        #'email'      : infos['email'],
+                        'customer'   : True,
+                        'supplier'   : False}
+        
+        log.append('\tUpdating customer ' + infos['firstname'] + ' ' + infos['lastname'])
+        new_shipping_address = infos['shipping_address']
+        new_billing_address = infos['billing_address']
+        
+    	# check to see if customer is guest, if so always create
+    	if infos['customer_is_guest'] == '1':
+    		cust_ids = []
+    	else: 
+    	    cust_ids = self.pool.get('res.partner').search(cr, uid, [('magento_id', '=', erp_customer['magento_id'])])
+            
+        if cust_ids == []:
+            cust_ids = [self.pool.get('res.partner').create(cr, uid, erp_customer)]
+            log.append("\t\tCustomer not found in OpenErp -> creation")
+        else:
+            self.pool.get('res.partner').write(cr, uid, [cust_ids[0]], erp_customer  )
+            log.append("\t\tCustomer exists in OpenErp -> updating its info")
+  
+        if cust_ids == []:
+            log.append("\t\tError! Customer not found and creation failed !!!")
+            return [None , None, None]
+   
+        # Billing country
+        try:
+            new_billing_address_country = self.pool.get('res.country').name_search(cr, uid, new_billing_address['country_id'])[0][0]
+        except:
+            new_country = { 'name': new_billing_address['country_id'],
+                            'code': new_billing_address['country_id']} 
+            new_billing_address_country = self.pool.get('res.country').create(cr, uid, new_country)
+  
+        new_billing_address['street'] = new_billing_address['street'] + "\n "
+        new_billing_address['street'] = new_billing_address['street'].split('\n')
+        erp_contact_billing = { 'partner_id' : cust_ids[0],
+                              'type' : 'invoice',
+                              'name': new_billing_address['firstname'] + ' ' + new_billing_address['lastname'],
+                              'street' : new_billing_address['street'][0],
+                              'street2' : new_billing_address['street'][1],
+                              'zip'    : new_billing_address['postcode'],
+                              'city'   : new_billing_address['city'],
+                              'country_id' : new_billing_address_country,
+                              'phone' : new_billing_address['telephone']}
+        # Shipping country
+        try:
+            new_shipping_address_country = self.pool.get('res.country').name_search(cr, uid, new_shipping_address['country_id'])[0][0]
+        except:
+            new_country = { 'name': new_shipping_address['country_id'],
+                            'code': new_shipping_address['country_id']}
+            new_shipping_address_country = self.pool.get('res.country').create(cr, uid, new_country)    
+                                   
+        new_shipping_address['street'] = new_shipping_address['street'] + "\n "
+        new_shipping_address['street'] = new_shipping_address['street'].split('\n')
+        erp_contact_shipping = {  'partner_id' : cust_ids[0],
+                              'type' : 'delivery',
+                              'name': new_shipping_address['firstname'] + ' ' + new_shipping_address['lastname'],
+                              'street' : new_shipping_address['street'][0],
+                              'street2' : new_shipping_address['street'][1],
+                              'zip'    : new_shipping_address['postcode'],
+                              'city'   : new_shipping_address['city'],
+                              'country_id' : new_shipping_address_country,
+                              'phone' : new_shipping_address['telephone']}
+     
+        contact_ids = self.pool.get('res.partner.address').search(cr, uid, [('partner_id', '=', cust_ids[0])])
+        if (contact_ids != []):
+            contacts = self.pool.get('res.partner.address').browse(cr, uid, contact_ids)
+        else:
+            contacts = []
+
+        new_contact_ids = []
+  
+        for new_contact in [erp_contact_billing , erp_contact_shipping]:    
+            if (new_contact == {}):
+                continue      
+            skip_contact_creation = False
+            i = 0
+            for _contact in contacts:
+                is_contact_same = True
+                contact={}
+                #for key in ['first_name','last_name','street','street2','zip','country_id','city','phone']:
+                for key in ['name','street','street2','zip','country_id','city','phone']:
+                    if (key == 'country_id'):
+                        if (_contact[key]['id'] != new_contact[key]):
+                            is_contact_same = False
+                            break
+                    else:
+                        if (_contact[key] != new_contact[key]):
+                            is_contact_same = False
+                            break
+
+                if (is_contact_same == True):
+                    skip_contact_creation = True
+                    log.append("\t\tSkipping creation of " + new_contact['type'] + " contact address (already existing)")
+                    break
+          
+                i = i + 1
+      
+            if (skip_contact_creation == False):
+                log.append("\t\tCreation of new " + new_contact['type'] + " contact address")
+                id_address = self.pool.get('res.partner.address').create(cr, uid, new_contact)
+                new_contact_ids.append(id_address)
+            else:
+                new_contact_ids.append(contact_ids[i])
+    
+        return { 'id' : cust_ids[0] , 'billing_id' : new_contact_ids[0] , 'shipping_id' : new_contact_ids[1] }
+    
+    ##################################################################
+    # Get Tax ID
+    ##################################################################
+    def get_tax_id(self, cr, uid, rate_percent): 
+        rate = float(rate_percent) / 100
+        int_rate = float(rate_percent) * 10
+        low_rate = math.floor(int_rate + 0.5) / 1000
+        high_rate = math.ceil(int_rate - 0.5) / 1000
+        list_tax_ids = self.pool.get('account.tax').search(cr, uid, [('amount' , "<=", high_rate),('amount' , ">=", low_rate), ('type_tax_use', "=", 'sale')])
+        if (list_tax_ids == []):
+            # Need to add flag for TVA creation
+            log.append('\t\t\tNo sale tax found with rate ' + str(rate) + '/' + str(low_rate) + '/' + str(high_rate))
+            tax = {'name': ('Tax ' + str(rate*100) + '%'),
+                            'amount': rate,
+                            'type': 'percent',
+                            'description': ('Magento' + str(rate*100) + '%'),
+                            'price_include': False,
+                            'type_tax_use': 'sale',
+            }            
+            tax_id = self.pool.get('account.tax').create(cr, uid, tax)
+            log.append('\t\t\tCreated tax ' + str(tax_id))
+        else:
+            #should add a check in case of sevral taxes
+            tax_id = list_tax_ids[0]
+        return tax_id
+            
+    ##################################################################          
+    # Categories import
+    ##################################################################
+    def _create_category(self, cr, uid, info_category, magento_params):
+        category = { 'magento_id' : info_category['category_id'],
+          'name' : info_category['name'],
+          'modified' : False,
+        }
+        log.append('Updating category ' + info_category['category_id'] + ' ' + info_category['name'])
+        if (info_category['level'] != '0'):
+            if info_category['parent_id'] == str(magento_params[0].magento_root_cat_id):
+                category['parent_id'] = False
+                log.append("Parent is root")
+            else:
+                cat_ids = self.pool.get('product.category').search(cr, uid, [('magento_id', '=', info_category['parent_id'])])
+                if cat_ids == []:
+                    log.append("Parent not found")
+                else:
+                    category['parent_id'] = cat_ids[0]
+                    log.append("Parent found " + str(cat_ids[0]))
+        else:
+            log.append("Root found " + str(category['magento_id']))
+            self.pool.get('sneldev.magento').write(cr, uid, [magento_params[0].id], {'magento_root_cat_id':category['magento_id']})
+            
+        cat_ids = self.pool.get('product.category').search(cr, uid, [('magento_id', '=', category['magento_id'])])
+        if cat_ids == []:
+            cat_ids = [self.pool.get('product.category').create(cr, uid, category)]
+            log.append("\tCategory not found in OpenErp -> creation")
+        else:
+            self.pool.get('product.category').write(cr, uid, [cat_ids[0]], category)
+            log.append("\tCategory exists in OpenErp -> updating its info")
+        if cat_ids == []:
+            log.append("\tError! Category not found and creation failed !!!")
+            return -1  
+        log.append('-------------')
+        for child in info_category['children']:
+           self.pool.get('sneldev.magento')._create_category(cr, uid, child, magento_params) 
+        return 0         
+    
+    def import_categories(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        if (export_is_running() == False):
+            try:
+                log.append('===== Categories import')
+                start_timestamp = str(DateTime.utc())
+                website_ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+                magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+                # Get latest categories from Magento 
+                self.pool = pooler.get_pool(cr.dbname) 
+                [status, server, session] = magento_connect(self, cr, uid)
+                if not status:
+                    log.append('Cannot connect ' + str(server))   
+                    set_export_finished()  
+                    return -1 
+                log.append('Logged in to Magento')
+                info_category = server.call(session, 'category.tree',[])
+                self.pool.get('sneldev.magento')._create_category(cr, uid, info_category, magento_params)
+                self.pool.get('sneldev.magento').write(cr, uid, [website_ids[0]], {'last_imported_category_timestamp':start_timestamp})
+            except:
+                log.append('Cannot get categories, check Magento web user config')
+                log.print_traceback()
+                set_export_finished()
+                return -1    
+            set_export_finished()
+            log.append('Import done')
+            return 0
+        log.append('Import already running')
+        raise osv.except_osv(_('Error !'), _('Import already running'))     
+        return -1    
+        
+    ##################################################################          
+    # Product import
+    ##################################################################
+    def import_products(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        if (export_is_running() == False):
+            try:
+                log.append('===== Products import')
+                start_timestamp = str(DateTime.utc())
+                website_ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+                magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+                # Last update
+                last_import = magento_params[0].last_imported_product_timestamp
+                # Get latest products from Magento 
+                self.pool = pooler.get_pool(cr.dbname) 
+                [status, server, session] = magento_connect(self, cr, uid)
+                if not status:
+                    log.append('Cannot connect ' + str(server))   
+                    set_export_finished()  
+                    return -1
+                attribute_sets = server.call(session, 'product_attribute_set.list');
+                log.append('Logged in to Magento')
+            except:
+                set_export_finished()
+                raise osv.except_osv(_('Error !'), _('Connection error!!!'))       
+                return -1
+                
+            increment = 300
+            index = 1
+            while True:
+                stop = index + increment - 1
+                log.append('Products ID from ' + str(index) + ' to ' + str(stop))
+                all_products = server.call(session, 'product.list',[{'product_id': {'from': str(index), 'to': str(stop)}}])
+                if last_import:
+                    products = server.call(session, 'product.list',[{'updated_at': {'from': last_import}, 'product_id': {'from': str(index), 'to': str(stop)}}])
+                    log.append('Last import: ' + last_import)
+                else:  
+                    products = all_products
+                index = stop + 1
+                
+                for prod in products:
+                    try:
+                        log.append('Loading product ' + to_proper_uni(prod['sku']))
+                        info_product = server.call(session, 'product.info',[prod['product_id']])
+                        product = { 'magento_id' : info_product['product_id'],
+                          'name' : info_product['name'],
+                          'default_code' : prod['sku'],
+                          'modified' : False,
+                          'export_to_magento': True,
+                        }
+                        try:
+                            product['list_price'] = info_product['price']
+                        except:
+                            product['list_price'] = '0.00'
+                        try:
+                            product['weight'] = info_product['weight']
+                        except:
+                            product['weight'] = '0.00'
+                        
+                        
+                        if info_product.has_key('category_ids'):
+                            magento_cat_ids = info_product['category_ids']
+                        elif info_product.has_key('categories'):
+                            magento_cat_ids = info_product['categories']
+                        else:
+                            magento_cat_ids = []  
+                        if magento_cat_ids:
+                            cat_ids = self.pool.get('product.category').search(cr, uid, [('magento_id', '=', magento_cat_ids[0])])
+                            if (cat_ids[0]):
+                                product['categ_id'] = cat_ids[0]
+                            else:
+                                product['categ_id'] = magento_params[0].default_category.id    
+                        else:
+                            log.append('Default category')
+                            product['categ_id'] = magento_params[0].default_category.id    
+                        log.append('Updating product ' + product['default_code'] + ' ' + product['name'])
+                        prod_ids = self.pool.get('product.product').search(cr, uid, [('magento_id', '=', product['magento_id'])])
+                        if prod_ids == []:
+                            prod_ids = [self.pool.get('product.product').create(cr, uid, product)]
+                            log.append("Product not found in OpenErp -> creation")
+                        else:
+                            self.pool.get('product.product').write(cr, uid, [prod_ids[0]], product)
+                            log.append("Product exists in OpenErp -> updating its info")
+    
+                        if prod_ids == []:
+                            log.append("Error! Product not found and creation failed !!!")
+                            set_export_finished()
+                            return -1 
+                    except:
+                        log.append("Error")
+                        log.print_traceback()
+                        raise osv.except_osv(_('Error !'), _('View log'))     
+                        
+                # If no products we can leave
+                if (all_products == []):
+                    self.pool.get('sneldev.magento').write(cr, uid, [website_ids[0]], {'last_imported_product_timestamp':start_timestamp})                                    
+                    set_export_finished()
+                    log.append("Done")
+                    return 0
+        log.append('Import already running')
+        raise osv.except_osv(_('Error !'), _('Import already running'))      
+        return -1       
+         
+    ##################################################################          
+    # Customer import
+    ##################################################################
+    
+    def import_customers(self, cr, uid):
+        flag = False
+        list = []
+        
+        if (export_is_running() == False):
+            try:
+                start_timestamp = str(DateTime.utc())
+                website_ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+                magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+                self.pool = pooler.get_pool(cr.dbname) 
+                [status, server, session] = magento_connect(self, cr, uid)
+                if not status:
+                    log.append('Cannot connect ' + str(server))   
+                    set_export_finished()
+                    return -1
+                log.append('Logged in to Magento')
+            except:
+                log.append('Cannot get customers, check Magento web user config')
+                log.print_traceback()
+                set_export_finished()
+                raise osv.except_osv(_('Error !'), _('Cannot get customers, check Magento web user config'))      
+                return -1 
+
+            customers = server.call(session, 'customer.list')
+    
+            for cust in customers:
+                try:
+                    log.append('Loading customers ' + cust['customer_id'])
+                    info_cust = server.call(session, 'customer.info',[cust['customer_id']])
+                    
+                    ##### <<<<< check to see if customer is guest, if so always create >>>>> ######
+                    try:
+                        info_cust['customer_is_guest']
+                    except:
+                        info_cust['customer_is_guest'] = '0'
+                
+                    if info_cust['customer_is_guest'] == '1':
+                        info_cust['customer_id'] = '0'
+                
+                    erp_customer = {
+                        'magento_id' : int(info_cust['customer_id']),
+                        'name' : info_cust['firstname'] + ' ' + info_cust['lastname'],
+                        'email': str(info_cust['email']),
+                        'customer'   : True,
+                        'supplier'   : False,
+                    }
+                                        
+                    if info_cust['customer_is_guest'] == '1':
+                        cust_ids = []
+                    else: 
+                        cust_ids = self.pool.get('res.partner').search(cr, uid, [('magento_id', '=', erp_customer['magento_id'])])
+                        
+                    if cust_ids == []:
+                        cust_ids = [self.pool.get('res.partner').create(cr, uid, erp_customer)]
+                        log.append("\t\tCustomer not found in OpenErp -> creation")
+                    else:
+                        self.pool.get('res.partner').write(cr, uid, [cust_ids[0]], erp_customer  )
+                        log.append("\t\tCustomer exists in OpenErp -> updating its info")
+              
+                    if cust_ids == []:
+                        log.append("\t\tError! Customer not found and creation failed !!!")
+                        return [None , None, None]
+                    ####################################################################################################
+                        
+                    info_address = server.call(session, 'customer_address.list', [cust['customer_id']])
+                    
+                    if (info_address != []):                               
+                        ########## <<<<<<<CUSTOMERS ADDRESS>>>>>>> ##########################
+                        list = []
+                        try:
+                            info_address = server.call(session, 'customer_address.list', [cust['customer_id']])
+                            
+                            for address in info_address:
+                                
+                                try:
+                                    new_address_country = self.pool.get('res.country').name_search(cr, uid, address['country_id'])[0][0]
+                                except:
+                                    new_country = { 'name': address['country_id'],
+                                            'code': address['country_id']}
+                                    address = self.pool.get('res.country').create(cr, uid, new_country)    
+    
+                                address['street'] = address['street'] + "\n "
+                                address['street'] = address['street'].split('\n')
+                                
+                                #if the billing and shipping address are the same...
+                                if address['is_default_shipping'] and address['is_default_billing']:
+                                    flag = True;
+                                    #BILLING
+                                    erp_contact_billing = {  'partner_id' : cust_ids[0],
+                                          'type':'invoice',
+                                          'name': address['firstname'] + ' ' + address['lastname'],
+                                          'street' : address['street'][0],
+                                          'street2' : address['street'][1],
+                                          'zip'    : address['postcode'],
+                                          'city'   : address['city'],
+                                          'country_id' : new_address_country,
+                                          'phone' : address['telephone']}
+    
+                                    #SHIPPING
+                                    erp_contact_shipping = {  'partner_id' : cust_ids[0],
+                                          'type':'delivery',
+                                          'name': address['firstname'] + ' ' + address['lastname'],
+                                          'street' : address['street'][0],
+                                          'street2' : address['street'][1],
+                                          'zip'    : address['postcode'],
+                                          'city'   : address['city'],
+                                          'country_id' : new_address_country,
+                                          'phone' : address['telephone']}
+                                    
+                                    list.append(erp_contact_billing)
+                                    list.append(erp_contact_shipping)
+                                    
+                                #if the billing and shipping address are different ... 
+                                else:
+                                    #Address type (Billing - Shipping)
+                                    if address['is_default_shipping']:
+                                        type = 'delivery'
+                                    elif address['is_default_billing']:
+                                        type ='invoice'
+                                    else:
+                                        type = 'default'
+                                                                                                    
+                                    erp_contact = {  'partner_id' : cust_ids[0],
+                                              #'type' : 'default',
+                                              'type':type,
+                                              'name': address['firstname'] + ' ' + address['lastname'],
+                                              'street' : address['street'][0],
+                                              'street2' : address['street'][1],
+                                              'zip'    : address['postcode'],
+                                              'city'   : address['city'],
+                                              'country_id' : new_address_country,
+                                              'phone' : address['telephone']}
+                                    
+                                    list.append(erp_contact)
+                                    
+                                contact_ids = self.pool.get('res.partner.address').search(cr, uid, [('partner_id', '=', cust_ids[0])])
+                                
+                                if (contact_ids != []):
+                                    contacts = self.pool.get('res.partner.address').browse(cr, uid, contact_ids)
+                                else:
+                                    contacts = []
+        
+                                new_contact_ids = []
+                                is_contact_same = False
+                  
+                                #for new_contact in [erp_contact]:
+                                for new_contact in list:    
+                                    if (new_contact == {}):
+                                        continue      
+                                    skip_contact_creation = False
+                                    i = 0
+                                    
+                                    for _contact in contacts:
+                                        is_contact_same = True
+                                        contact={}
+                                        for key in ['name','street','street2','zip','country_id','city','phone']:
+                                            if (key == 'country_id'):
+                                                if (_contact[key]['id'] != new_contact[key]):
+                                                    is_contact_same = False
+                                                    break
+                                            else:
+                                                if (_contact[key] != new_contact[key]):
+                                                    is_contact_same = False
+                                                    break
+                                                
+                                        if (is_contact_same == True):
+                                            skip_contact_creation = True
+                                            log.append("\t\tSkipping creation of " + new_contact['type'] + " contact address (already existing)")
+                                            break
+                                  
+                                    i = i + 1
+                              
+                                    if (skip_contact_creation == False):
+                                        log.append("\t\tCreation of new " + new_contact['type'] + " contact address")
+                                        id_address = self.pool.get('res.partner.address').create(cr, uid, new_contact)
+                                        new_contact_ids.append(id_address)
+                                        
+                                        if flag is False:
+                                            list.remove(new_contact)
+                                    else:
+                                        new_contact_ids.append(contact_ids[i])
+                                    
+                        except:
+                            log.append('Cannot get customers, check Magento web user config')
+                            log.print_traceback()
+                            set_export_finished()
+                            raise osv.except_osv(_('Error !'), _('Cannot get customers, check Magento web user config'))  
+                            return -1
+                        
+                    else:
+                        contact_ids = self.pool.get('res.partner.address').search(cr, uid, [('partner_id', '=', cust_ids[0])])
+                        
+                        if (contact_ids == []):
+                           erp_contact = {  'partner_id' : cust_ids[0],
+                                'type'       : 'other',
+                                'name'       : info_cust['firstname'] + ' ' + info_cust['lastname'],
+                                'street'     : None,
+                                'street2'    : None,
+                                'zip'        : None,
+                                'city'       : None,
+                                'country_id' : None,
+                                'phone'      : None}
+                           self.pool.get('res.partner.address').create(cr, uid, erp_contact)
+                            
+                except:
+                   log.append('Cannot get customers, check Magento web user config')
+                   log.print_traceback()
+                   set_export_finished() 
+                   raise osv.except_osv(_('Error !'), _('Cannot get customers, check Magento web user config'))                 
+
+            if (customers == []):
+                #self.pool.get('sneldev.magento').write(cr, uid, [website_ids[0]], {'last_imported_product_timestamp':start_timestamp})                                    
+                set_export_finished()
+                log.append("Done")
+                return 0
+        
+        else:
+            log.append('Import already running') 
+            raise osv.except_osv(_('Error'), _('Import already running')% ('error') )
+            return -1                           
+    
+    ##################################################################          
+    # Initialize OpenERP stock 
+    ##################################################################
+    def init_stock(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        if (export_is_running() == False):
+            try:
+                log.append('===== Stock init')
+                [status, server, session] = magento_connect(self, cr, uid)
+                if not status:
+                    log.append('Cannot connect ' + str(server))   
+                    set_export_finished()  
+                    return -1  
+                prod_ids = self.pool.get('product.product').search(cr, uid, [('magento_id', '!=', -1)])
+                prods = self.pool.get('product.product').browse(cr, uid, prod_ids)
+                
+                sku_list = []
+                for prod in prods:
+                    sku_list.append(prod.code)
+                res = server.call(session, 'product_stock.list', [sku_list])
+                magento_stock = {}
+                for magento_prod in res:
+                    magento_stock[unicode(magento_prod['sku'])] = magento_prod['qty']
+            except:
+                log.append('Could not get stock from Magento')
+                log.print_traceback()
+                log.append('-----')  
+                raise osv.except_osv(_('Error !'), _('Could not get stock from Magento'))  
+            
+            #try:
+            magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+            location_id = magento_params[0].inital_stock_location.id
+            inventry_obj = self.pool.get('stock.inventory')
+            inventry_line_obj = self.pool.get('stock.inventory.line')
+            name = 'Initial Magento Inventory'
+            inventory_id = inventry_obj.create(cr , uid, {'name': name})
+            log.append('New inventory ' + str(inventory_id) + ' / Location id : ' + str(location_id))
+            for prod in prods:
+                try:
+                    log.append('\tAdding line : ' + prod['code'] + ' / ' + magento_stock[prod.code])
+                    line_data ={
+                        'inventory_id' : inventory_id,
+                        'product_qty' : magento_stock[prod.code],
+                        'location_id' : location_id,
+                        'product_id' : prod.id,
+                        'product_uom' : prod.uom_id.id,
+                    }
+                    inventry_line_obj.create(cr , uid, line_data)
+                except:
+                    log.append('\tSkipping : ' + prod['code'])
+                    log.print_traceback()
+                
+                inventry_obj.action_confirm(cr, uid, [inventory_id])
+                inventry_obj.action_done(cr, uid, [inventory_id])
+            #except:
+                #log.append('ERROR')
+                #log.print_traceback()
+                #log.append('-----')
+                #raise osv.except_osv(_('Error !'), _('Error, check log files'))                    
+            set_export_finished()
+            return 0 
+        
+        else:
+            log.append('Export already running') 
+            raise osv.except_osv(_('Error !'), _('Export already running'))  
+            return -1    
+      
+    ##################################################################          
+    # Orders import
+    ##################################################################
+    def import_orders(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        wf_service = netsvc.LocalService('workflow')
+        if (export_is_running() == False):
+            failed_order = False
+            try:
+                log.append('===== Orders import')
+                ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+                magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+                
+                # Get latest sales orders in Magento 
+                self.pool = pooler.get_pool(cr.dbname) 
+                [status, server, session] = magento_connect(self, cr, uid)
+                if not status:
+                    log.append('Cannot connect ' + str(server))   
+                    set_export_finished()  
+                    return -1
+                log.append('Logged in to Magento')
+                log.append('Last import from ' + magento_params[0].last_imported_invoice_timestamp)
+                listinvoices = server.call(session, 'sales_order_invoice.list',[{'updated_at': {'from': magento_params[0].last_imported_invoice_timestamp}}])
+#                if (magento_params[0].last_invoice_id == -1):
+#                    listinvoices = server.call(session, 'sales_order_invoice.list',[{'updated_at': {'from': '2011-05-01'}}])
+#                else:
+#                    listinvoices = server.call(session, 'sales_order_invoice.list',[{'updated_at': {'from': '2011-05-01'}}])
+#                    #listinvoices = server.call(session, 'sales_order_invoice.list',[{'entity_id': {'gt': magento_params[0].last_invoice_id}}])
+                log.append('Looking for invoives to import')
+                log.append("Found " + str(len(listinvoices)) + " new invoice(s) created")
+
+                orders_magento=[]
+                for invoice in listinvoices:          
+                    try:
+                        log.append("Invoice "+ invoice['increment_id'] + " - Order " + invoice['order_id'] + " - Created " + invoice['created_at'])
+                        log.append("\tGetting Info invoice " + str(invoice['increment_id']) )
+                        info_invoice = server.call(session, 'sales_order_invoice.info',[invoice['increment_id']]);
+                        log.append("\tGetting Info order " + str(invoice['order_id']))
+                        try:
+                            info_order = server.call(session, 'sales_order.list', [{'order_id': {'eq': invoice['order_id']}}])
+                            info_order = info_order[0]
+                            info_order = server.call(session, 'sales_order.info',[info_order['increment_id']]);
+                        except:
+                            info_order = server.call(session, 'sales_order.info',[invoice['order_increment_id']]);
+                        
+                        name_sales_order = str(info_order['increment_id'])
+                        name_invoice     = str(info_invoice['increment_id'])
+                        id_orders = self.pool.get('sale.order').search(cr, uid, [('magento_id', '=', info_order['order_id'])])
+                        if (id_orders != []):
+                            log.append("\tSales order " + name_sales_order + " already exists in ERP. Skipping")
+                            continue
+                        
+                        log.append("\tGetting Info customer " + str(info_order['customer_id']))
+                        try:
+                            info_customer = server.call(session, 'customer.info' , [info_order['customer_id'] ])
+                        except:
+                            log.append("\t\tCustomer is guest")
+                            info_customer = {
+                                    'customer_id' : '0'
+                                }
+                    except:
+                        log.append("\tERROR ! Invoice Skipped")
+                        log.print_traceback()
+                        failed_order = True
+                        continue
+            
+#                orders_magento.append( { 'order' : info_order , 'invoice' : info_invoice , 'customer' : info_customer} )   
+#                new_last_invoice_id = magento_params[0].last_invoice_id
+#    
+#                # Import orders one by one
+#                for info in orders_magento:
+                    try:
+#                        info_customer = info['customer']
+#                        info_order = info['order']
+#                        info_invoice = info['invoice']
+#                        new_last_invoice_id = max(int(new_last_invoice_id) , int(info_invoice["invoice_id"]))
+                        
+                        pricelist_ids = self.pool.get('product.pricelist').search(cr, uid,[])
+  
+                        if (info_order['customer_is_guest'] == '1'):
+                            info_customer['store_id'] = info_order['store_id']
+                            info_customer['website_id'] = '1'
+                            info_customer['email'] = info_order['customer_email']
+                            info_customer['firstname'] = info_order['billing_address']['firstname']
+                            info_customer['lastname'] = info_order['billing_address']['lastname']
+                            info_customer['customer_is_guest'] = '1'
+                            
+                        info_customer['shipping_address'] = info_order['shipping_address']
+                        info_customer['billing_address'] = info_order['billing_address']
+                        erp_customer_info = self.pool.get('sneldev.magento').update_customer(cr, uid, info_customer)  
+
+                        try:
+                            #comments = u"Infos paiement\n"
+                            comments = ""
+                            for comment in info_order['status_history']:
+                                if comment.has_key('comment') and len(comment['comment']) > 0:
+                                    comments = comments + comment['comment'] + u"\n"
+                            #Adding customer note
+                            if (info_order.has_key("giftMessage")):
+                                #comments = comments + u"Infos commande\n"
+                                comments = comments + info_order["giftMessage"] + u"\n"
+                        except:
+                            pass
+                            
+                        # Creating sales order
+                        erp_sales_order = { 'name' : name_sales_order,
+                                            'order_policy' : 'manual',  
+                                            'client_order_ref' : name_invoice,
+                                            'state' : 'draft',  
+                                            'partner_id' : erp_customer_info['id'],
+                                            'partner_invoice_id'  : erp_customer_info['billing_id'],
+                                            'partner_order_id'    : erp_customer_info['billing_id'],
+                                            'partner_shipping_id' : erp_customer_info['shipping_id'],
+                                            'pricelist_id'        : pricelist_ids[0],
+                                            'magento_id'      : info_order['order_id'],
+                                            'date_order'        : invoice['created_at'][:10],
+                                            'note'      : comments
+                        }
+                        log.append("\tCreation of sales order in OpenErp " + name_sales_order)
+                        id_order = self.pool.get('sale.order').create(cr, uid, erp_sales_order)
+                        
+                        # Sale order lines
+                        missing_products_in_openerp = False
+                        parents = {}
+                        for item in info_order['items']:
+                            if item.has_key('product_type') and (item['product_type'] == 'configurable'):
+                                parents[item['item_id']] = {
+                                    'base_price':   item['base_price'],
+                                    'tax_percent':  item['tax_percent'],
+                                }
+                                log.append("\t\tParent product "  + str(item['sku']))
+                                continue
+                            if item.has_key('parent_item_id'):
+                                try:
+                                    item['base_price'] = str(float(item['base_price']) + float(parents[item['parent_item_id']]['base_price']))
+                                    item['tax_percent'] = parents[item['parent_item_id']]['tax_percent']
+                                except:
+                                    log.append("\t\tNo parent price")
+                            product_ids = self.pool.get('product.product').search(cr, uid, [('magento_id', '=', item['product_id'])])
+                            if (product_ids == []):
+                                log.append("\t\tProduct with magento_id " + str(item['product_id'])  + " not found in ERP - skipping")
+                                missing_products_in_openerp = True
+                                continue
+                            product_id = product_ids[0]
+                            my_product = self.pool.get('product.product').browse(cr, uid, product_id)     
+                            log.append("\t\tCreation of sale order line for qty " + str(item['qty_ordered']) + " product " + my_product['name'])
+                            try:
+                                if (item['tax_percent'] != '0.0000'):
+                                    tax_id = self.pool.get('sneldev.magento').get_tax_id(cr, uid, item['tax_percent'])
+                                    if (tax_id == 0):
+                                        raise 
+                                    else:
+                                        tax_ids = [[6,0,[tax_id]]]   
+                                else:
+                                    tax_ids = []
+                                    log.append("\t\t\tNo tax " + item['tax_percent'])      
+                            except:
+                                log.append("\t\t\tError Found unsupported tax rate - skipping tax")
+                                tax_ids = []      
+
+                            erp_sales_order_line = {'order_id'        : id_order,
+                                                  'product_id'      : product_id,
+                                                  'name'            : my_product['name'],
+                                                  'tax_id'          : tax_ids,
+                                                  'price_unit'      : item['base_price'],
+                                                  'product_uom'     : my_product['uom_id']['id'],
+                                                  'product_uom_qty' : item['qty_ordered']
+                            } 
+                            id_order_line = self.pool.get('sale.order.line').create(cr, uid, erp_sales_order_line)
+        
+                        #Shipping costs
+                        log.append("\t\tCreating shipping costs :" + str(info_order['shipping_amount']))
+                        try:
+                            my_shipping = magento_params[0].shipping_product
+                            try:
+                                if (info_order['shipping_tax_amount'] != '0.0000'):
+                                    tax_percent = 100 * float(info_order['shipping_tax_amount']) / float(info_order['shipping_amount'])
+                                    tax_id = self.pool.get('sneldev.magento').get_tax_id(cr, uid, tax_percent)
+                                    if (tax_id == 0):
+                                        raise  
+                                    else:
+                                        log.append("\t\t\tTax added, id: " + str(tax_id))
+                                        tax_ids = [[6,0,[tax_id]]]      
+                                else:
+                                    tax_ids = []     
+                            except:
+                                tax_ids = []
+                                log.append("\t\t\tError Found unsupported tax rate - skipping tax") 
+                                 
+                            erp_shipping_line = {
+                                'order_id' : id_order,
+                                'name': my_shipping['name'],
+                                'product_id' : my_shipping['id'],
+                                'price_unit':info_order['shipping_amount'],
+                                'product_uom': my_shipping['uom_id']['id'],
+                                'product_uom_qty' : 1,
+                                'tax_id'          : tax_ids
+                            }
+                            id_order_line = self.pool.get('sale.order.line').create(cr, uid, erp_shipping_line)   
+                        except:
+                            log.append("\t\t\tNo Shipping costs")  
+                            pass
+                                
+                        if missing_products_in_openerp:
+                            log.append("\tMissing products in openERP, leaving in order in draft state")   
+                            failed_order = True
+                            continue                          
+                            
+                        log.append("\tConfirming Sales Order (Draft -> In progress)" )
+                        wf_service.trg_validate(uid, 'sale.order', id_order, 'order_confirm', cr)
+                              
+                        # Creation of invoice
+                        try:
+                            log.append("\tCreating Invoice")  
+                            self.pool.get('sale.order').manual_invoice(cr, uid, [id_order])
+                            erp_invoice_id  = self.pool.get('sale.order').browse(cr, uid, id_order).invoice_ids[0]['id']
+                            log.append("\t\tInvoice created : " + str(erp_invoice_id))
+                            self.pool.get('account.invoice').write(cr,uid,[erp_invoice_id],{ "date_invoice" : invoice['created_at'][:10]})
+                            
+                            #Promo Code
+                            erp_invoice_lines = self.pool.get('account.invoice').browse(cr, uid, erp_invoice_id).invoice_line
+                            for erp_item in erp_invoice_lines:
+                                erp_product_id = erp_item.product_id['id']
+                                erp_product_magento_id = erp_item.product_id['magento_id']
+                            
+                                for item in info_order['items']:
+                                    if (str(item["product_id"])==str(erp_product_magento_id)):
+                                        if (item.has_key('discount_percent') and item["discount_percent"] != '0.0000'):
+                                            log.append('\t\tAppending Discount to line with product magento id '+str(erp_product_magento_id))
+                                            self.pool.get('account.invoice.line').write(cr,uid,[erp_item["id"]],{ "discount" : item["discount_percent"]})
+                                        elif (item.has_key('discount_invoiced') and item['discount_invoiced']!='0.0000'):                
+                                            #Managing fixed coupon reduction as a percentage also
+                                            if (item.has_key('row_invoiced') and item['row_invoiced']!='0.0000'):
+                                                discount = float(item['discount_invoiced'])
+                                                total_price = float(item['row_invoiced'])                    
+                                                discount_percent = discount / total_price * 100.0
+                                                log.append('\t\tAppending Discount '+str(discount_percent)+' to line with product magento id '+str(erp_product_magento_id))
+                                                self.pool.get('account.invoice.line').write(cr,uid,[erp_item["id"]],{ "discount" : discount_percent})
+                                            else:
+                                                log.append("Unsupported Promo Code type!")
+                            #END MANAGEMENT PROMO CODE
+                            
+                            #Update Tax Base after promo codes
+                            self.pool.get('account.invoice').button_reset_taxes(cr,uid,[erp_invoice_id])
+                            
+                            journal_code = info_order['payment']['method']
+                            log.append("\t\tPayment method " + journal_code) 
+                            #invoice_from_draft_to_paid(self, cr,uid, erp_invoice_id, info_invoice['created_at'] , name_invoice, journal_code ,context)
+                                                
+                        except:
+                            log.append("\t\tError: Unable to create invoice")
+                            log.print_traceback()
+                            continue
+                        
+                        # Invoice from Draft to Open  
+                        try:    
+                            if magento_params[0].auto_invoice_open:    
+                                log.append("\tConfirming Invoice (Draft -> Open)")
+                                wf_service.trg_validate(uid, 'account.invoice', erp_invoice_id, 'invoice_open', cr)
+                            else:
+                                log.append("\tInvoice left in Draft")
+                        except:
+                            log.append("\tError: Unable to move invoice to Open status")
+                            traceback.print_exc(file=sys.stdout)
+                            continue
+                            
+                        # Invoice from Open to Paid   
+                        try:
+                            if magento_params[0].auto_invoice_paid and magento_params[0].auto_invoice_open:  
+                                if magento_params[0].payment_journal:
+                                    journal = magento_params[0].payment_journal
+                                    log.append("\tPaying Invoice (Open -> Paid)")
+                                else:
+                                    log.append("\tNo journal set - Skipping invoice payment")
+                                    continue
+                                    
+                                #from wizard_pay_invoice.py
+                                log.append("\tGetting account period")
+                                ids = self.pool.get('account.period').find(cr, uid, None)
+                                period_id = False
+                                if len(ids):
+                                    period_id = ids[0]
+                                else:
+                                    log.append("\t\tNO ACCOUNT PERIOD AVAILABLE - SKIP invoice payment")
+                                    raise
+                                  
+                                invoice = self.pool.get('account.invoice').browse(cr, uid, erp_invoice_id)
+                                
+                                # Need to change partner
+                                log.append("\tMake customer reconcilable")
+                                data = {'reconcile': True}
+                                self.pool.get('account.account').write(cr, uid, [invoice.partner_id.property_account_receivable.id], data)
+                  
+                                amount = invoice.amount_total
+                                ecriture_name = 'Order payment'
+                                
+                                writeoff_account_id = False
+                                writeoff_journal_id = False
+                                context={'date_p': info_invoice['created_at'], 'comment':''}
+                                acc_id = journal.default_credit_account_id and journal.default_credit_account_id.id
+                                if acc_id == []:
+                                    log.append("\t\tERROR The journal does not have default credit - debit account")
+                                else:
+                                    self.pool.get('account.invoice').pay_and_reconcile(cr,uid,[erp_invoice_id], amount, acc_id, period_id, journal.id, writeoff_account_id, period_id, writeoff_journal_id, context, ecriture_name)
+                                    log.append("\t\tPayment done")      
+                            else:
+                                log.append("\tInvoice not moved to Paid state")                                              
+                        except:
+                            pass
+                            
+                    except:
+                        log.append("Invoice/Order skipped")  
+                        failed_order = True 
+                        log.print_traceback()
+                if not failed_order:
+                    today = str(datetime.date.today())
+                    log.append("Update last import : " + today)
+                    self.pool.get('sneldev.magento').write(cr, uid, [magento_params[0].id], {'last_imported_invoice_timestamp':today})
+#                    log.append("Last invoice_id " + str(new_last_invoice_id))
+#                    self.pool.get('sneldev.magento').write(cr, uid, [magento_params[0].id], {'last_invoice_id':new_last_invoice_id})
+                set_export_finished()
+                log.append("Done")
+                return 0     
+            except:
+                log.append('Cannot import orders')
+                traceback.print_exc(file=sys.stdout)
+                set_export_finished()  
+                return -1
+        log.append('Import already running') 
+        return -1       
+        
+    def _invoice_from_draft_to_paid(self, cr, uid, erp_invoice_id,invoice_created_at, name_invoice, journal_code):
+        log.append("Invoice from draft to Open")
+        wf_service = netsvc.LocalService('workflow')
+        wf_service.trg_validate(uid, 'account.invoice', erp_invoice_id, 'invoice_open', cr)
+        
+        # Invoice from Open to Paid
+        log.append("Invoice from Open to Paid")
+        
+        #from wizard_pay_invoice.py
+        log.append("-getting account.period")
+        ids = self.pool.get('account.period').find(cr, uid, None)
+        period_id = False
+        if len(ids):
+            period_id = ids[0]
+        else:
+            log.append("NO ACCOUNT PERIOD AVAILABLE - SKIP invoice payment")
+            return False
+          
+        invoice = self.pool.get('account.invoice').browse(cr, uid, erp_invoice_id)
+        # Need to change partner
+        log.append("Make customer reconcilable")
+        data = {'reconcile': True}
+        self.pool.get('account.account').write(cr, uid, [invoice.partner_id.property_account_receivable.id], data)
+          
+        amount = invoice.amount_total
+        ecriture_name = 'Paiement effectue'
+        journals = self.pool.get('account.journal').search(cr, uid, [("code" , "=" , journal_code)])
+        if len(journals) > 0:
+            journal_id = journals[0]
+        else:
+            self.pool.get('account.journal').create_payment_methods(cr, uid, [])
+            journals = self.pool.get('account.journal').search(cr, uid, [("code" , "=" , journal_code)])
+            journal_id = journals[0]
+        journal = self.pool.get('account.journal').browse(cr, uid, journal_id, None)
+          
+        writeoff_account_id = False
+        writeoff_journal_id = False
+        context={'date_p': invoice_created_at, 'comment':''}
+        acc_id = journal.default_credit_account_id and journal.default_credit_account_id.id
+        if acc_id == []:
+            log.append("The journal does not have default credit - debit account")
+        else:
+            self.pool.get('account.invoice').pay_and_reconcile(cr,uid,[erp_invoice_id], amount, acc_id, period_id, journal_id, writeoff_account_id, period_id, writeoff_journal_id, context, ecriture_name)
+            log.append("Payment done")
+            
+        return True
+        
+    
+    ##################################################################          
+    # Credit memo import
+    ##################################################################    
+    def import_credit_memos(self, cr, uid):
+        log.define(self.pool.get('sneldev.logs'), cr, uid)
+        wf_service = netsvc.LocalService('workflow')
+        if (export_is_running() == False):
+            try:
+                log.append('===== Credit memo import')
+                ids = self.pool.get('sneldev.magento').search(cr, uid, [])
+                magento_params = self.pool.get('sneldev.magento').get_magento_params(cr, uid)
+                if not magento_params[0].import_credit_memos:
+                    log.append('Credit memo import disabled')   
+                    set_export_finished()
+                    return 0
+                
+                self.pool = pooler.get_pool(cr.dbname) 
+                [status, server, session] = magento_connect(self, cr, uid)
+                if not status:
+                    log.append('Cannot connect ' + str(server))   
+                    set_export_finished()  
+                    return -1
+                log.append('Logged in to Magento')
+            
+                #get all credit memos from Magento created after last sync date
+                listcreditmemos = server.call(session,'creditmemoapi.list', [{'entity_id': {'gt': magento_params[0].last_creditmemo_id}}])
+            
+                credits_memos = []
+                log.append("Found " + str(len(listcreditmemos)) + " credit memos: id - order_id - created_at")
+                for cm in listcreditmemos:
+                    log.append("credit_memo:" + cm['increment_id'] + " - " + cm['order_id'] + " - " + cm['created_at'])
+                    credits_memos.append({ 'creditmemo_id' : cm['creditmemo_id'],'increment_id' : cm['increment_id'] , 'order_id' : cm['order_id'] , 'created_at' : cm['created_at']} )
+             
+                new_last_creditmemo_id = magento_params[0].last_creditmemo_id
+            except:
+                log.append('Could not retreive Magento credit memos. Did you install the Magento module ?')
+                set_export_finished()  
+                return -1
+                
+            try:                
+                for credits_memo in credits_memos:
+                    #get invoice id whose origine is the related order
+                    new_last_creditmemo_id = max(int(new_last_creditmemo_id), int(credits_memo['creditmemo_id']))
+                    id_orders_related_to_cm = self.pool.get('sale.order').search(cr, uid, [('magento_id', '=', credits_memo['order_id'])])
+                    if (id_orders_related_to_cm == []):
+                        #Skip
+                        log.append("\tOrignial Magento order was not imported :" + str(credits_memo['order_id']))
+                        continue
+            
+                    order = self.pool.get('sale.order').browse(cr, uid, id_orders_related_to_cm[0], None)
+                    id_invoices_related_to_order = self.pool.get('account.invoice').search(cr, uid, [('origin', '=', order['name'])])
+                    if (id_invoices_related_to_order == []):
+                        #Skip
+                        log.append("\tNo invoice with origin:" + order['name'])
+                        continue
+    
+                    # Current date and period       
+                    period_ids = self.pool.get('account.period').find(cr, uid, credits_memo['created_at'][:10])
+                    date = credits_memo['created_at'][:10]
+                    description = 'credit memo' + str(credits_memo['increment_id'])
+                    period = period_ids[0]
+                    log.append("\tCreate Refund Invoice for invoice " + str(id_invoices_related_to_order))
+                    for inv in self.pool.get('account.invoice').browse(cr, uid, id_invoices_related_to_order):
+                        journal_id = inv.journal_id.id
+                        refund_id = self.pool.get('account.invoice').refund(cr, uid, [inv.id], date, period, description, journal_id)
+                        #self.pool.get('account.invoice').write(cr, uid, [refund_id], {'date_due': date, 'check_total': inv.check_total})
+                        self.pool.get('account.invoice').button_compute(cr, uid, refund_id)
+                    # Get payment method from original invoice
+                    invoices_related_to_order = self.pool.get('account.invoice').browse(cr, uid, id_invoices_related_to_order)
+                    if len(invoices_related_to_order[0].payment_ids) > 0:
+                        journal_code = invoices_related_to_order[0].payment_ids[0].journal_id.code
+                    else:
+                        journal_code = 'checkmo'
+                    #self.pool.get('sneldev.magento')._invoice_from_draft_to_paid(cr,uid, id,credits_memo['created_at'], str(credits_memo['increment_id']), journal_code)
+      
+                    # Return products
+                    log.append("\tReturning goods for " + invoices_related_to_order[0].origin)
+                    package_ids = self.pool.get('stock.picking').search(cr, uid, [('origin', '=', invoices_related_to_order[0].origin), ('type', '=', 'out')])
+                    date_cur = time.strftime('%Y-%m-%d %H:%M:%S')
+                    for package_id in package_ids:
+                        package = self.pool.get('stock.picking').browse(cr, uid, package_id)
+                        if not package.state == 'done':
+                            wf_service.trg_validate(uid, 'stock.picking', package_id, 'button_cancel', cr)
+                        else:
+                            log.append("\tReturning ID " + str(package_id))
+                            new_picking = self.pool.get('stock.picking').copy(cr, uid, package_id, {'name': package.name, 'state':'draft', 'type':'in', 'move_lines':[], 'date':date_cur})
+                            log.append("\tNew ID " + str(new_picking))
+                            for move in package.move_lines:
+                                new_move = self.pool.get('stock.move').copy(cr, uid, move.id, {
+                                    'picking_id':new_picking,
+                                    'state':'draft',
+                                    'date':date_cur,
+                                    'location_id':move.location_dest_id.id,
+                                    'location_dest_id':move.location_id.id,
+                                    'date_planned':date_cur,})
+                            self.pool.get('stock.picking').draft_validate(cr, uid, [new_picking], [])
+        
+                log.append("Last credit memo id " + str(new_last_creditmemo_id))
+                self.pool.get('sneldev.magento').write(cr, uid, [magento_params[0].id], {'last_creditmemo_id':new_last_creditmemo_id})  
+                set_export_finished()  
+                return 0
+            except: 
+                log.print_traceback()  
+                set_export_finished()  
+                return -1
+        log.append('Import already running') 
+        return 0
+                                  
+sneldev_magento()
+
+# Categories
+class product_category(osv.osv):
+    _name = 'product.category'
+    _inherit ='product.category'
+    _columns = {
+      'modified':fields.boolean('Modified since last synchronization'),
+      'magento_id':fields.integer('Magento ID'),
+    }
+    
+    _defaults = {
+        'modified': lambda *a: True,
+        'magento_id': lambda *a: -1,
+    }
+    
+    def write(self, cr, uid, ids, vals, context={}):
+        if not vals.has_key('modified'):
+          vals['modified'] = True
+        return super(product_category, self).write(cr, uid, ids, vals, context)    
+        
+product_category()
+
+# Products
+class product_product(osv.osv):
+    _name = 'product.product'
+    _inherit ='product.product'
+
+    def _product_qty_magento(self, cr, uid, ids, name, arg, context={}):
+        qtys = super(product_product, self).read(cr,uid,ids,['qty_available','virtual_available','incoming_qty','outgoing_qty'],context)
+        magento = {}
+        for element in qtys:
+            magento[element['id']]=element['virtual_available']-element['incoming_qty']
+        
+        return magento
+  
+    _columns = {
+        'modified':fields.boolean('Modified since last synchronization'),
+        'magento_id':fields.integer('Magento ID'),
+        'qty_magento': fields.function(_product_qty_magento, method=True, type='float', string='Magento Stock'),
+        'export_to_magento': fields.boolean('Export to Magento'),    
+    }
+    
+    _defaults = {
+        'modified': lambda *a: True,
+        'magento_id': lambda *a: -1,
+        'export_to_magento': lambda *a: False,
+    }
+    
+    def write(self, cr, uid, ids, vals, context={}):
+        if not vals.has_key('modified'):
+            vals['modified'] = True
+        return super(product_product, self).write(cr, uid, ids, vals, context)    
+        
+product_product()
+
+# Sale orders
+class sale_order(osv.osv):
+    _name = "sale.order"
+    _inherit = "sale.order"
+
+    _columns = {
+        'magento_id' : fields.integer('Magento ID')
+    }
+sale_order()
+
+# Partner
+class res_partner(osv.osv):
+    _name = 'res.partner'
+    _inherit = 'res.partner'
+            
+    _columns = {
+        'magento_id':fields.integer('Magento ID'),
+        'email':fields.char('Email', size=128),
+        'export_to_magento': fields.boolean('Export to Magento'),    
+    }
+      
+    _defaults = {
+        'magento_id': lambda *a: -1,
+        'export_to_magento': lambda *a: False,        
+    }
+    """
+    def write(self, cr, uid, ids, vals, context={}):
+        if not vals.has_key('modified'):
+            vals['modified'] = True
+        return super(product_product, self).write(cr, uid, ids, vals, context)
+    """
+res_partner()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:

=== added file 'sneldev_magento/sneldev_magento_data.xml'
--- sneldev_magento/sneldev_magento_data.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/sneldev_magento_data.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,6 @@
+<?xml version="1.0"?>
+<openerp>
+	<data>
+
+	</data>
+</openerp>
\ No newline at end of file

=== added file 'sneldev_magento/sneldev_magento_view.xml'
--- sneldev_magento/sneldev_magento_view.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/sneldev_magento_view.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,131 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<openerp>
+    <data>
+    	<!-- Magento / View	-->
+			<record model="ir.actions.act_window" id="action_magento_form">
+				<field name="name">Magento</field>
+				<field name="res_model">sneldev.magento</field>
+				<field name="view_mode">tree,form</field>
+			</record>
+
+			<menuitem id="base.menu_magento" name="Magento" web_icon="static/src/img/magento.png" web_icon_hover="static/src/img/magento.png" />
+				<menuitem name="Magento Settings" id="menu_magento_form" parent="base.menu_magento" action="action_magento_form" />
+				
+			<menuitem id="base.import_menu_magento" name="Import" parent="base.menu_magento"/>			
+				<menuitem name="Import categories from Magento" action="action_sneldev_categories_import" parent="base.import_menu_magento" id="base.menu_magento_categories_import" />
+		    	<menuitem name="Import products from Magento" action="action_sneldev_products_import" parent="base.import_menu_magento" id="base.menu_magento_products_import" />
+		    	<menuitem name="Import orders from Magento" action="action_sneldev_orders_import" parent="base.import_menu_magento" id="base.menu_magento_orders_import" />
+		   		<menuitem name="Import customers from Magento" action="action_sneldev_customers_import" parent="base.import_menu_magento" id="base.menu_magento_clients_import" />
+            
+            <menuitem id="base.export_menu_magento" name="Export" parent="base.menu_magento"/>
+           		<menuitem name="Export categories and products to Magento" action="action_sneldev_products_export" parent="base.export_menu_magento" id="base.menu_magento_products_export" />
+		    	<menuitem name="Export stock to Magento" action="action_sneldev_stock_export" parent="base.export_menu_magento" id="base.menu_magento_stock_export" />
+		
+            <menuitem name="Initialize stock from Magento" action="action_sneldev_stock_init" parent="base.menu_magento" id="base.menu_magento_stock_init" />
+		    <menuitem name="Start automatic synchronization" action="action_sneldev_sync_start" parent="base.menu_magento" id="base.menu_magento_sync_start" />
+		    <menuitem name="Stop automatic synchronization" action="action_sneldev_sync_stop" parent="base.menu_magento" id="base.menu_magento_sync_stop" />
+            			
+			<record model="ir.ui.view" id="view_magento_form">
+				<field name="name">sneldev.magento.form</field>
+				<field name="model">sneldev.magento</field>
+				<field name="type">form</field>
+				<field name="arch" type="xml">
+					<form string="Magento website">
+						<separator string="Magento Settings" colspan="4" />
+						<newline />
+						<field name="name" />
+						<field name="url" />
+						<newline />
+						<field name="api_user" />
+						<field name="api_pwd" password="True" />					
+						<separator string="Product Import Settings" colspan="4" />
+						<field name="default_category" />	
+						<separator string="Orders Import Settings" colspan="4" />						
+						<field name="shipping_product" />	
+						<field name="payment_journal" />	
+						<field name="auto_invoice_open" />	
+						<field name="auto_invoice_paid" />						
+						<field name="import_credit_memos" />
+						<separator string="Automatic Synchronization Settings" colspan="4" />
+						<field name="auto_import_products" />	
+						<field name="auto_export_products" />	
+						<field name="auto_export_stock" />	
+						<field name="auto_import_orders" />	
+						<field name="auto_import_credit_memos" />		
+						<newline />				
+						<field name="sync_sleep" />		
+						<newline />	
+						<field name="auto_script_path" />						
+						<separator string="Initial Inventory" colspan="4" />	
+						<!--This field must be required, because it's necessary to init the stock -->					
+						<field name="inital_stock_location" attrs="{'required':True}" />	
+					</form>
+				</field>
+			</record>
+			<record model="ir.ui.view" id="view_magento_tree">
+				<field name="name">sneldev.magento.tree</field>
+				<field name="model">sneldev.magento</field>
+				<field name="type">tree</field>
+				<field name="arch" type="xml">
+					<tree string="Magento website">
+						<field name="name" />
+						<field name="url" />
+					</tree>
+				</field>
+			</record>
+			
+            <record model="ir.ui.view" id="product_product_tree_view_inherited">
+            <field name="name">product.product.tree.inherit</field>
+            <field name="model">product.product</field>
+            <field name="type">tree</field>
+            <field name="inherit_id" ref="product.product_product_tree_view"/>
+            <field name="arch" type="xml">
+                <field name="virtual_available" position="after">
+                    <field name="qty_magento"/>
+                </field>
+            </field>
+            </record>
+
+            <record model="ir.ui.view" id="product_product_tree_view_inherited">
+            <field name="name">product.product.tree.inherit</field>
+            <field name="model">product.product</field>
+            <field name="type">tree</field>
+            <field name="inherit_id" ref="product.product_product_tree_view"/>
+            <field name="arch" type="xml">
+                <field name="variants" position="after">
+                    <field name="export_to_magento"/>
+                </field>
+            </field>
+            </record>
+    
+            <record model="ir.ui.view" id="product_normal_stock_form_inherit_inherit">
+            <field name="name">product.normal.stock.form.inherit.inherit</field>
+            <field name="model">product.product</field>
+            <field name="type">form</field>
+            <field name="inherit_id" ref="stock.view_normal_property_acc_form"/>
+            <field name="arch" type="xml">
+                <field name="virtual_available" position="after">
+                    <field name="qty_magento"/>
+                </field>
+            </field>
+            </record>
+    
+            <record model="ir.ui.view" id="product_normal_form_view_inherited">
+            <field name="name">product.normal.form.inherit.inherit</field>
+            <field name="model">product.product</field>
+            <field name="type">form</field>
+            <field name="inherit_id" ref="product.product_normal_form_view"/>
+            <field name="arch" type="xml">
+                <field name="variants" position="after">
+                    <field name="export_to_magento"/>
+                </field>
+                <!-- You need this field to be required for the export to run magento
+                     Those products that have no reference (default_code) are not exported -->
+                <field name="default_code" position="attributes">
+                	<attribute name="attrs">{'required':True}</attribute>
+                </field>
+            </field>
+            </record>
+   
+    </data>
+</openerp>

=== added file 'sneldev_magento/sneldev_magento_wizard.xml'
--- sneldev_magento/sneldev_magento_wizard.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/sneldev_magento_wizard.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,114 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+        <menuitem 
+            id="base.menu_magento" 
+            name="Magento" />
+        <wizard 
+            string="Export categories and products to Magento" 
+            model="product.product"
+            name="sneldev.products.export" 
+            id="wizard_sneldev_products_export" />
+        <menuitem
+            name="Export categories and products to Magento"
+            action="wizard_sneldev_products_export" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_products_export" />
+        
+        <wizard 
+            string="Export stock to Magento" 
+            model="product.product"
+            name="sneldev.stock.export" 
+            id="wizard_sneldev_stock_export" />
+        <menuitem
+            name="Export stock to Magento"
+            action="wizard_sneldev_stock_export" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_stock_export" />
+            
+        <wizard 
+            string="Import orders and credit memos from Magento" 
+            model="sale.order"
+            name="sneldev.orders.import" 
+            id="wizard_sneldev_orders_import" />
+        <menuitem
+            name="Import orders from Magento"
+            action="wizard_sneldev_orders_import" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_orders_import" />
+        <wizard 
+            string="Import categories and products from Magento" 
+            model="product.product"
+            name="sneldev.products.import" 
+            id="wizard_sneldev_products_import" />
+        <menuitem
+            name="Import categories and products from Magento"
+            action="wizard_sneldev_products_import" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_products_import" />
+        
+        <wizard 
+            string="Import categories from Magento" 
+            model="product.category"
+            name="sneldev.categories.import" 
+            id="wizard_sneldev_categories_import" />
+        <menuitem
+            name="Import categories from Magento"
+            action="wizard_sneldev_categories_import" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_categories_import" />
+
+        <wizard 
+            string="Initialize stock from Magento" 
+            model="product.product"
+            name="sneldev.stock.init" 
+            id="wizard_sneldev_stock_init" />
+        <menuitem
+            name="Initialize stock from Magento"
+            action="wizard_sneldev_stock_init" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_stock_init" />
+
+        <wizard 
+            string="Start automatic synchronization" 
+            model="sneldev.magento"
+            name="sneldev.sync.start" 
+            id="wizard_sneldev_sync_start" />
+        <menuitem
+            name="Start automatic synchronization"
+            action="wizard_sneldev_sync_start" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_sync_start" />
+
+        <wizard 
+            string="Stop automatic synchronization" 
+            model="sneldev.magento"
+            name="sneldev.sync.stop" 
+            id="wizard_sneldev_sync_stop" />
+        <menuitem
+            name="Stop automatic synchronization"
+            action="wizard_sneldev_sync_stop" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_sync_stop" />
+        
+        <wizard 
+            string="Import customers from magento" 
+            model="res.partner"
+            name="res.partner" 
+            id="wizard_sneldev_customers" />
+        <menuitem
+            name="Import customers from magento"
+            action="wizard_sneldev_customers" 
+            type="wizard" 
+            parent="base.menu_magento" 
+            id="base.menu_magento_customers_import" />
+	</data>
+</openerp>  

=== added directory 'sneldev_magento/static'
=== added directory 'sneldev_magento/static/src'
=== added directory 'sneldev_magento/static/src/img'
=== added file 'sneldev_magento/static/src/img/icon.png'
Binary files sneldev_magento/static/src/img/icon.png	1970-01-01 00:00:00 +0000 and sneldev_magento/static/src/img/icon.png	2012-09-11 15:12:19 +0000 differ
=== added file 'sneldev_magento/static/src/img/magento.png'
Binary files sneldev_magento/static/src/img/magento.png	1970-01-01 00:00:00 +0000 and sneldev_magento/static/src/img/magento.png	2012-09-11 15:12:19 +0000 differ
=== added directory 'sneldev_magento/wizard'
=== added file 'sneldev_magento/wizard/__init__.py'
--- sneldev_magento/wizard/__init__.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/__init__.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,10 @@
+import export_tools
+import sneldev_magento_products_export
+import sneldev_magento_stock_export
+import sneldev_magento_products_import
+import sneldev_magento_categories_import
+import sneldev_magento_orders_import
+import sneldev_magento_customers_import
+import sneldev_magento_stock_init
+import sneldev_magento_sync_start
+import sneldev_magento_sync_stop

=== added file 'sneldev_magento/wizard/export_tools.py'
--- sneldev_magento/wizard/export_tools.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/export_tools.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,54 @@
+#!/usr/bin/env python
+# -*- encoding: utf-8 -*-
+##############################################################################
+#
+# Copyright (c) 2009 SnelDev (http://www.sneldev.com) All Rights Reserved.
+#
+# WARNING: This program as such is intended to be used by professional
+# programmers who take the whole responsability of assessing all potential
+# consequences resulting from its eventual inadequacies and bugs
+# End users who are looking for a ready-to-use solution with commercial
+# garantees and support are strongly adviced to contract a Free Software
+# Service Company
+#
+# This program is Free Software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; either version 2
+# of the License, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+##############################################################################
+
+import wizard
+import pooler
+import threading
+
+#Globals for syncrhonisation
+export_lock=threading.Lock();
+export_running=False;
+
+#Thread safe version of export_running
+def export_is_running():
+    global export_running
+    
+    retVal=False
+    export_lock.acquire()  
+    if (export_running == False):
+        export_running=True
+        retVal=False
+    else:
+        retVal=True  
+    export_lock.release()
+    return retVal
+
+def set_export_finished():
+    global export_running
+    export_running=False

=== added file 'sneldev_magento/wizard/sneldev_magento_categories_import.py'
--- sneldev_magento/wizard/sneldev_magento_categories_import.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_categories_import.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,49 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_categories_import(osv.osv_memory):
+    _name = 'sneldev.categories.import'
+    _description = 'Import categories'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_categories_import(self, cr, uid, ids, context=None):
+        if (self.pool.get('sneldev.magento').import_categories(cr, uid) < 0):
+            raise osv.except_osv(('Warning'), ('Import failed, please refer to log file for failure details.'))
+        
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_categories_import()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
\ No newline at end of file

=== added file 'sneldev_magento/wizard/sneldev_magento_categories_import.xml'
--- sneldev_magento/wizard/sneldev_magento_categories_import.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_categories_import.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_categories_import" model="ir.ui.view">
+            <field name="name">Import categories</field>
+            <field name="model">sneldev.categories.import</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Import categories">
+                <label string="This wizard will import categories from Magento." colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_categories_import" string="Import"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Compute Categories"
+    	    res_model="sneldev.categories.import"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_categories_import"/>
+			
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_customers_import.py'
--- sneldev_magento/wizard/sneldev_magento_customers_import.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_customers_import.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,51 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_customers_import(osv.osv_memory):
+    _name = 'sneldev.customers.import'
+    _description = 'Import customers'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_customers_import(self, cr, uid, ids, context=None):
+        try:
+            self.pool.get('sneldev.magento').import_customers(cr, uid)
+        
+        except:
+            raise osv.except_osv(('Warning'), ('Import failed, please refer to log file for failure details.'))
+        
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_customers_import()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:

=== added file 'sneldev_magento/wizard/sneldev_magento_customers_import.xml'
--- sneldev_magento/wizard/sneldev_magento_customers_import.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_customers_import.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+        <record id="view_sneldev_customers_import" model="ir.ui.view">
+            <field name="name">Import customers</field>
+            <field name="model">sneldev.customers.import</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Import customers">
+                <label string="This wizard will import customers from Magento." colspan="4"/>
+                    <separator colspan="4"/>
+                    <group col="2" colspan="4">
+                        <button icon='gtk-cancel' special="cancel" string="Cancel" />
+                        <button name="do_customers_import" string="Import" colspan="1" type="object" icon="gtk-ok" />
+                    </group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Import customers"
+            res_model="sneldev.customers.import"
+            view_mode="form"
+            target="new"
+            key2="client_action_multi"
+            id="action_sneldev_customers_import"/>
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_orders_import.py'
--- sneldev_magento/wizard/sneldev_magento_orders_import.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_orders_import.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,54 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_orders_import(osv.osv_memory):
+    _name = 'sneldev.orders.import'
+    _description = 'Import orders'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_orders_import(self, cr, uid, ids, context=None):
+        self.pool.get('sneldev.magento').import_categories(cr, uid)
+        self.pool.get('sneldev.magento').import_products(cr, uid)
+        if (self.pool.get('sneldev.magento').import_orders(cr, uid) < 0):
+            raise osv.except_osv(('Warning'), ('Import failed, please refer to log file for failure details.'))
+        
+        if (self.pool.get('sneldev.magento').import_credit_memos(cr, uid) < 0):
+            raise osv.except_osv(('Warning'), ('Import failed, please refer to log file for failure details.'))
+       
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_orders_import()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
\ No newline at end of file

=== added file 'sneldev_magento/wizard/sneldev_magento_orders_import.xml'
--- sneldev_magento/wizard/sneldev_magento_orders_import.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_orders_import.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_orders_import" model="ir.ui.view">
+            <field name="name">Import orders</field>
+            <field name="model">sneldev.orders.import</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Import orders">
+                <label string="This wizard will import orders from Magento. It will first import categories and products." colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_orders_import" string="Import"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Import Orders"
+    	    res_model="sneldev.orders.import"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_orders_import"/>
+			
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_products_export.py'
--- sneldev_magento/wizard/sneldev_magento_products_export.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_products_export.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,50 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_products_export(osv.osv_memory):
+    _name = 'sneldev.products.export'
+    _description = 'Export orders'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_products_export(self, cr, uid, ids, context=None):
+        self.pool.get('sneldev.magento').export_categories(cr, uid)
+        if (self.pool.get('sneldev.magento').export_products(cr, uid) < 0):
+            raise osv.except_osv(('Warning'), ('Export failed, please refer to log file for failure details.'))
+        
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_products_export()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:

=== added file 'sneldev_magento/wizard/sneldev_magento_products_export.xml'
--- sneldev_magento/wizard/sneldev_magento_products_export.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_products_export.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_products_export" model="ir.ui.view">
+            <field name="name">Export products</field>
+            <field name="model">sneldev.products.export</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Export products">
+                <label string="This wizard will export products to Magento. It will first export categories." colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_products_export" string="Export"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Export Products"
+    	    res_model="sneldev.products.export"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_products_export"/>
+			
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_products_import.py'
--- sneldev_magento/wizard/sneldev_magento_products_import.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_products_import.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,50 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_products_import(osv.osv_memory):
+    _name = 'sneldev.products.import'
+    _description = 'Import orders'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_products_import(self, cr, uid, ids, context=None):
+        self.pool.get('sneldev.magento').import_categories(cr, uid)
+        if (self.pool.get('sneldev.magento').import_products(cr, uid) < 0):
+            raise osv.except_osv(('Warning'), ('Import failed, please refer to log file for failure details.'))
+        
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_products_import()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:

=== added file 'sneldev_magento/wizard/sneldev_magento_products_import.xml'
--- sneldev_magento/wizard/sneldev_magento_products_import.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_products_import.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_products_import" model="ir.ui.view">
+            <field name="name">Import products</field>
+            <field name="model">sneldev.products.import</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Import products">
+                <label string="This wizard will import products from Magento. It will first import categories." colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_products_import" string="Import"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Import Products"
+    	    res_model="sneldev.products.import"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_products_import"/>
+			
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_stock_export.py'
--- sneldev_magento/wizard/sneldev_magento_stock_export.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_stock_export.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,50 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_stock_export(osv.osv_memory):
+    _name = 'sneldev.stock.export'
+    _description = 'Export stock'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_stock_export(self, cr, uid, ids, context=None):
+        if (self.pool.get('sneldev.magento').export_stock(cr, uid) < 0):
+            raise osv.except_osv(('Warning'), ('Export failed, please refer to log file for failure details.'))
+        
+        else:        
+            return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_stock_export()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
\ No newline at end of file

=== added file 'sneldev_magento/wizard/sneldev_magento_stock_export.xml'
--- sneldev_magento/wizard/sneldev_magento_stock_export.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_stock_export.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_stock_export" model="ir.ui.view">
+            <field name="name">Export stock</field>
+            <field name="model">sneldev.stock.export</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Export stock">
+                <label string="This wizard will export stock to Magento." colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_stock_export" string="Export"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Export Stock"
+    	    res_model="sneldev.stock.export"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_stock_export"/>
+			
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_stock_init.py'
--- sneldev_magento/wizard/sneldev_magento_stock_init.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_stock_init.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,49 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_stock_init(osv.osv_memory):
+    _name = 'sneldev.stock.init'
+    _description = 'Initialize stock from Magento'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_stock_init(self, cr, uid, ids, context=None):
+        if (self.pool.get('sneldev.magento').init_stock(cr, uid) < 0):
+            raise osv.except_osv(('Warning'), ('Init failed, please refer to log file for failure details.'))
+        
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_stock_init()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:

=== added file 'sneldev_magento/wizard/sneldev_magento_stock_init.xml'
--- sneldev_magento/wizard/sneldev_magento_stock_init.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_stock_init.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_stock_init" model="ir.ui.view">
+            <field name="name">Initialize stock from Magento</field>
+            <field name="model">sneldev.stock.init</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Initialize stock">
+                <label string="This wizard will create an inventory from Magento stock. This will remove all current stock information in OpenERP !" colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_stock_init" string="Start"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Initialize stock"
+    	    res_model="sneldev.stock.init"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_stock_init"/>
+			
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_sync_start.py'
--- sneldev_magento/wizard/sneldev_magento_sync_start.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_sync_start.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,47 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_sync_start(osv.osv_memory):
+    _name = 'sneldev.sync.start'
+    _description = 'Start Synchronization'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_sync_start(self, cr, uid, ids, context=None):
+        self.pool.get('sneldev.magento').sync_start(cr, uid)
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_sync_start()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
\ No newline at end of file

=== added file 'sneldev_magento/wizard/sneldev_magento_sync_start.xml'
--- sneldev_magento/wizard/sneldev_magento_sync_start.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_sync_start.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_sync_start" model="ir.ui.view">
+            <field name="name">Start synchronization</field>
+            <field name="model">sneldev.sync.start</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Start Synchronization">
+                <label string="You will now start the automatic synchronization." colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_sync_start" string="Start"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Start Synchronization"
+    	    res_model="sneldev.sync.start"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_sync_start"/>
+			
+	</data>
+</openerp>

=== added file 'sneldev_magento/wizard/sneldev_magento_sync_stop.py'
--- sneldev_magento/wizard/sneldev_magento_sync_stop.py	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_sync_stop.py	2012-09-11 15:12:19 +0000
@@ -0,0 +1,47 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    OpenERP, Open Source Management Solution
+#    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+
+import pooler
+import wizard
+import pooler
+import os
+
+from export_tools import *
+from osv import osv, fields
+
+class wiz_sneldev_sync_stop(osv.osv_memory):
+    _name = 'sneldev.sync.stop'
+    _description = 'Stop Synchronization'
+
+    _columns = {
+    }
+
+    _defaults = {
+    }
+
+    def do_sync_stop(self, cr, uid, ids, context=None):
+        self.pool.get('sneldev.magento').sync_stop(cr, uid)
+        return {'type': 'ir.actions.act_window_close'}
+
+wiz_sneldev_sync_stop()
+
+# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
\ No newline at end of file

=== added file 'sneldev_magento/wizard/sneldev_magento_sync_stop.xml'
--- sneldev_magento/wizard/sneldev_magento_sync_stop.xml	1970-01-01 00:00:00 +0000
+++ sneldev_magento/wizard/sneldev_magento_sync_stop.xml	2012-09-11 15:12:19 +0000
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8"?>
+<openerp>
+    <data>
+		<record id="view_sneldev_sync_stop" model="ir.ui.view">
+            <field name="name">Stop synchronization</field>
+            <field name="model">sneldev.sync.stop</field>
+            <field name="type">form</field>
+            <field name="arch" type="xml">
+                <form string="Stop Synchronization">
+                <label string="You will now stop the automatic synchronization." colspan="4"/>
+				    <separator colspan="4"/>
+				    <group col="2" colspan="4">
+                		<button icon='gtk-cancel' special="cancel"
+                			string="Cancel" />
+                		<button name="do_sync_stop" string="Stop"
+                			colspan="1" type="object" icon="gtk-ok" />
+                	</group>
+                </form>
+            </field>
+        </record>
+
+       <act_window name="Stop Synchronization"
+    	    res_model="sneldev.sync.stop"
+    	    view_mode="form"
+    	    target="new"
+            key2="client_action_multi"
+    	    id="action_sneldev_sync_stop"/>
+			
+	</data>
+</openerp>