
    2Hg                         d dl Z d dlZd dlZd dlmZ d dlmZ d dlm	Z	m
Z
mZ d Zd Zedk    r ej         e                       dS dS )    N)map_csv_file)collections)get_all_smart_collectionscreate_smart_collectionupdate_smart_collectionc                  (  K   d} d}d}d}d}t           j                            t           j                            t                              }t           j                            t           j                            |d                    }t           j                            |dd          }t          j        |d	
           t           j                            |d          }t          j        | |f          }		 |		                    ||           t          j
                            |	          }
|
                    ||           |
                                 |	                                 n-# |
                                 |	                                 w xY wt          |t                    }t!                       d {V }d |D             }|D ]}|                    d          }|s||v r_||                             d          }t#          ||           d {V }d|v rt%          d| d           gt%          d| d|            }t'          |           d {V }d|v rt%          d| d           t%          d| d|            d S )Nzemde.autarcia.com   zftp-shoppingfeedz5vm_*2I[f2yL2A6J!/dEz1/exports/CSV/shopify/DATA_RUBRIQ_ID_SHOP_2941.csvz..filesr   T)exist_okzDATA_RUBRIQ_ID_SHOP_2941.csv)usernamepasswordc                 d    i | ]-}|                     d           |                     d           |.S )title)get).0cols     '/var/www/sites/EMDE/main/collections.py
<dictcomp>z'process_collections.<locals>.<dictcomp>&   s;    bbb#QTQXQXY`QaQab((#bbb    collectionTitleidsmart_collectionzCollection 'u   ' mise à jour.u,   Échec de la mise à jour de la collection 'z': u
   ' créée.u)   Échec de la création de la collection ')ospathdirnameabspath__file__joinmakedirsparamiko	Transportconnect
SFTPClientfrom_transportr   closer   collections_mappingr   r   printr   )hostportr   r   remote_pathbase_dirproject_dir	local_dircollections_csv	transportsftpcollection_recordsexisting_collectionsexisting_mappingrecordr   coll_idresults                     r   process_collectionsr7      s     DD!H%HEKwrwx8899H'//"',,x">">??K['=AAIK	D))))gll9.LMMO"D$<00I8h???"11)<<o...

 	

%o7JKK!:!<!<<<<<<<bb9Mbbb$ V V

,-- 	$$$&u-11$77G27FCCCCCCCCF!V++;U;;;<<<<WUWWvWWXXXX26::::::::F!V++6U6667777T%TTFTTUUUU#V Vs   9AE. .*Fc                  2   K   t                       d {V  d S )N)r7    r   r   mainr:   ;   s*      


r   __main__)r   asyncior    utils.utilsr   mapping.collectionsERPr   r&   api.collectionsr   r   r   r7   r:   __name__runr9   r   r   <module>rB      s    				   $ $ $ $ $ $ E E E E E E         -V -V -V^      zGK r   