
    pha                         d dl mZ d dlmZ d dlmZmZmZmZ d dl	m	Z	 d dl
Z
d dlmZ d dlmZ  e
j                  e      Zded	eeef   d
eeef   fdZy)    )Session)HTTPException)DictAnyListOptional)datetimeN)MatchedType)trigger_wine_match_jobdbparamsreturnc           	        K   g }g }g }|j                  dd      }t        j                  j                  j	                         |j	                         k(  }|j                  di       }|r|j                         D ]t  \  }}	d|v r|	sd|	v s|j                  |	d          |j                  |       d}
|	j                  d      }|r	 t        j                  |d      }
|j                  |
       v g }t        |      D ]^  \  }}|t        |      k  r||   nd}|r-d
}|r"|j                  d| d|j                  d       d       J|j                  d| d       ` |rt!        d|      t#        | ||||j                  d             d{    d|||D cg c]  }|r|j                  d      nd c}|j                  d      d}|S # t        $ r,}t        j                  d	t        |              Y d}~!d}~ww xY w7 vc c}w w)z
    Direct conversion of the Groovy proceed() method to Python.
    
    Args:
        db: Database session
        params: Request parameters including retailers and matchedType
        
    Returns:
        Dict: Result of operation
    matchedType 	retailers.codeNdatez%Y-%m-%dzError parsing date: TzInput file not found for [z] at date []z] at date [null]i  )status_codedetailmode)r   codesrun_keywordsdatesr   	scheduled)statusr   r   r   r   )getr
   KEYWORDvalueloweritemsappendr	   strptime	Exceptionloggererrorstr	enumeratelenstrftimer   r   )r   r   r   r   r   matched_typerun_keywordr   kvr   date_stringeerrorsir   d
valid_fileresults                      a/var/www/html/wine-match-dev/backend/winematch-backend/src/apps/wine_match/services/wine_match.pyprocess_wine_matchr9      s,     ELE ::mR0L%%++113|7I7I7KKK 

;+IOO% 	#DAqaxVq[QvY'##K0 eeFmF'00jI T"#	#( FU# 	O4CJE!HD J :4&AJJWaLbKccdefMM6tf<LMN	O F;; !!ZZ   $AFGAA!**Z(47G

6"F MK % F';CF8%DEEF. Hsb   BHH:HGAHA0HHHH
6H	H!G=7H=HHH)sqlalchemy.ormr   fastapir   typingr   r   r   r   r	   loggingsrc.apps.match.enumsr
   &src.apps.wine_match.job.wine_match_jobr   	getLogger__name__r'   r)   r9        r8   <module>rD      s]    " ! , ,   , I			8	$J J$sCx. JT#s(^ JrC   