o
     ah#                     @  sj   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	j
dededededfdddZdS )    )annotations)	APIRouterForm)RedirectResponse)sbz/sync/decide)response_class.batch_idstr
staging_idintchoicec                   s   d}d }d}d }|dkrd}n|dkrd}d}d}nzt |}W n ty,   d }Y nw | |||||d	}td
j|dd  td|  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   payload r   ./var/www/html/bot/app/web/pages/sync/decide.pysync_decide   s   r   N)r   r	   r
   r   r   r	   )
__future__r   fastapir   r   fastapi.responsesr   app.web.depsr   routerpostr   r   r   r   r   <module>   s    