
    ph                         d dl Z d dlmZ d dlmZmZmZmZ d dlmZm	Z	m
Z
 d dlmZ d dlmZ d dlmZ d dlmZ d d	lmZmZmZ d d
l  e j0                  e      Z e       Zdedede
fdZy)    N)datetime)AnyDictListOptional)FastAPIHTTPExceptionRequest)	BaseModel)Session)MatchedType)wine_match_job)
DataResultRetailerItemRetailersRequest)*dbpayloadrequestc                   K   |}g }g }g }g }d}|j                   xs dj                         t        j                  k(  }	|j                  j                         D ]v  \  }
}d|
v r|j                  |j                         |j                  |	       d }|j                  r!	 t        j                  |j                  |      }|j                  |       x t        d| d| d|        t        |      D ]`  \  }}||   }|r?t         j#                  ||      r$|j                  d| d	|j%                  |       d
       L|j                  d| d       b t        d|        |rt'        dd|i      t)        | |||D cg c]  }|r|j%                  |      nd  c}|j*                         d {    t-        dg       S # t        $ r#}t        j                  d|        Y d }~+d }~ww xY wc c}w 7 Ew)Nz%Y-%m-%d .zDate parse error: zCodes: z, Run Keywords: z	, Dates: zInput file not found for [z] at date []z] at date [null]zErrors: i  errors)status_codedetail)codesrun_keywordsdatesmodeT)successr   )matched_typeupperr   KEYWORDclientsitemsappendcodedater   strptime	Exceptionloggererrorprint	enumerateoutput_serviceis_valid_crawl_outputstrftimer	   r   r    r   )r   r   r   paramsr   r   r   r   sdfrun_keyword_flagkeyvaluedate_objeidxr(   r)   ds                     f/var/www/html/wine-match-dev/backend/winematch-backend/src/apps/match/controller/wine_match_process.pyproceedr=      s    FELEF
C++1r88:k>Q>QQnn**, 
U#:UZZ ,-::7#,,UZZ= 	X 
GE7*<.	%
IJu% O	TSz!77dC :4&DMMZ]L^K__`abMM6tf<LMNO 
HVH
Xv4FGG 
!7<=!!qzz#-=[[   d2..5  71!5667( >	sP   BG8 G>AG8A*G8>G1G80G61G8	G.G)#G8)G..	G8)loggingr   typingr   r   r   r   fastapir   r	   r
   pydanticr   sqlalchemy.ormr   src.apps.match.enumsr   !src.apps.match.job.wine_match_jobr   src.apps.match.schemas.wine_dbr   r   r   &src.apps.match.services.output_service	getLogger__name__r,   OutputServicer0   r=        r<   <module>rL      s`      , , 3 3  " , < U U 4			8	$0/g 0/(8 0/7 0/rK   