
     ah#                        d dl mZ d dlmZmZ d dlmZ d dlmZ  e            Z	e	
                    de           ed           ed           ed          fdd            ZdS )    )annotations)	APIRouterForm)RedirectResponse)sbz/sync/decide)response_class.batch_idstr
staging_idintchoicec                8  K   d}d }d}d }|dk    rd}n/|dk    rd}d}d}n"t          |          }n# t          $ r d }Y nw xY w| |||||d	}t          j        d
                              |d                                           t          d|  dd          S )NMANUALg      ?__NEW__z
manual-new__SKIP__SKIPg        zmanual-skip)r	   r   decision	person_idscore	rationalematch_decisionszbatch_id,staging_id)on_conflictz/sync/batch/z?saved=1i.  )status_code)r   	Exceptionr   tableupsertexecuter   )r	   r   r   r   r   r   r   payloads           ./var/www/html/bot/app/web/pages/sync/decide.pysync_decider       s       HT35D	 			:		35M		VYY***d)))* JHY G H&&w<Q&RRZZ\\\=8===3OOOOs   1 A A N)r	   r
   r   r   r   r
   )
__future__r   fastapir   r   fastapi.responsesr   app.web.depsr   routerpostr         r   <module>r)      s    " " " " " " # # # # # # # # . . . . . .      	^,<==DIId3ii$s))P P P P >=P P Pr(   