
    `j                    0    d dl mZ d dlZd ZddZddZdS )    )annotationsNc                V   d}i }|                      d          5 }|                    |           |                                }d d d            n# 1 swxY w Y   |D ]J}|d         pd                                }|s!|                    |g                               |           K|S )Nz
        SELECT
            id,
            nom,
            nom_poligono,
            etat_administratif
        FROM analyses_sites
        WHERE nom_poligono IS NOT NULL
          AND nom_poligono <> ''
    T
dictionarynom_poligono )cursorexecutefetchallstrip
setdefaultappend)connsqlmappingcurrowsrowkeys          import_situations/repository.pyfetch_sites_mappingr      s    	C &(G		%	% C||~~                0 0>"(b//11 	3##**3////Ns   *AAAloggerlogging.Loggerid_siteintplan
str | Nonetoxinesetat_administratifc                   |rdnd}d}|||||d}		 |                                  5 }
|
                    ||	           d d d            d S # 1 swxY w Y   d S # t          $ r}|                    d||            d }~ww xY w)N   r   a  
        UPDATE analyses_sites
           SET plan = %(plan)s,
               toxines = %(toxines)s,
               etat_administratif = %(etat_administratif)s,
               date_changement_etat = %(date_changement_etat)s
         WHERE id = %(id_site)s
    )r   r   r   date_changement_etatr   uA   Erreur lors de la mise à jour de l'état pour le site id=%s : %s)r	   r
   	Exceptionerror)r   r   r   r   r   r   r"   etat_valr   paramsr   excs               r   update_site_current_stater(      s    '-qqAHC & 4 F	[[]] 	%cKKV$$$	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	%   O	
 	
 	

 	s9   A A
A 
AA AA 
A>!A99A>c	                   |d S |rdnd}	d}
d}d}||d}	 |                      d          5 }|                    |
|           |                                }|r|d	         |||||	d
}|                    d          |k    pr|                    d          |k    pY|                    d          |k    p@|                    d          |k    p't	          |                    d          pd          |	k    }|r|                    ||           	 d d d            d S |                    |||||||	|d           d d d            d S # 1 swxY w Y   d S # t
          $ r}|                    d||            d }~ww xY w)Nr!   r   aJ  
        SELECT
            id_historique,
            date_document,
            heure_document,
            plan,
            toxines,
            etat_administratif
          FROM analyses_sites_historique
         WHERE id_site = %(id_site)s
           AND date_changement_etat = %(date_changement_etat)s
         LIMIT 1
    aF  
        UPDATE analyses_sites_historique
           SET date_document = %(date_document)s,
               heure_document = %(heure_document)s,
               plan = %(plan)s,
               toxines = %(toxines)s,
               etat_administratif = %(etat_administratif)s
         WHERE id_historique = %(id_historique)s
    a  
        INSERT INTO analyses_sites_historique (
            id_site,
            date_document,
            heure_document,
            plan,
            toxines,
            etat_administratif,
            date_changement_etat,
            created_at
        ) VALUES (
            %(id_site)s,
            %(date_document)s,
            %(heure_document)s,
            %(plan)s,
            %(toxines)s,
            %(etat_administratif)s,
            %(date_changement_etat)s,
            NOW()
        )
    )r   r"   Tr   id_historique)r*   date_documentheure_documentr   r   r   r+   r,   r   r   r   )r   r+   r,   r   r   r   r"   z=Erreur lors de l'insertion historique pour le site id=%s : %s)r	   r
   fetchonegetr   r#   r$   )r   r   r   r+   r,   r   r   r   r"   r%   	check_sql
update_sql
insert_sqlparams_checkr   r   params_updatehistory_changedr'   s                      r   insert_history_if_newr5   C   sh    #&-qqAHIJJ,  4 L
'[[D[)) 	SKK	<000,,..C %(%9%2&4 &*2! ! GGO,,= Kww/00NBKwwv$.K wwy))W4K 377#788=A>>(J   # ;KK
M:::+	 	 	 	 	 	 	 	. KK
"!."0"&.(<% %   /	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	@    K	
 	
 	

 	sG   E C!EE E9E E

E E
E 
E:E55E:)
r   r   r   r   r   r   r   r   r   r   )
__future__r   loggingr   r(   r5        r   <module>r:      sh    " " " " " "   0" " " "Jf f f f f fr9   