pljFddlZddlZddlZddlmZddlmZddlmZddl m Z eje Z ifdededed efd Zdd ededededzd edzd edzf dZd ededdefdZy)N)text)Literal) get_async_db) HTTPExceptionquestionhotel_id sub_hotel_idmetadatac K t4d{}ttj}|j t d|||||rt j|nddd{|jd{dddd{|S77077 #1d{7swYSxYw#t$r"}tjd|Yd}~yd}~wwxYww)NzINSERT INTO conversations (id, first_message, hotel_id, sub_hotel_id, metadata) VALUES (:id, :msg, :hotel_id, :sub_hotel_id, :metadata))idmsgrr r zError creating conversation: ) rstruuiduuid4executerjsondumpscommit Exceptionlogerror)rrr r dbconversation_ides =/var/www/html/ls-ibe-bot-apis/app/utils/store_conversation.pycreate_conversationr(s>>R!$**,/O**_`&xX_kRZy}zDzDEMzN`de   ))+  ">"  ">>>  1!56sC*B<BB<AB&/B 0B&B"B& B<B$B<C*B< B&"B&$B<&B9,B/ -B94B<8C*9B<< C'C"C*"C''C*ranswer customer_idcpK |st|||d{}g}|r|j||d|d|r|j||d|dt|dk(r|St4d{}t d}t d} |j ||d{|j | d|id{|j d{dddd{|S77|7N7477#1d{7swY|SxYw#t$r"} tjd| Yd} ~ yd} ~ wwxYww) Nhuman)rmessagerolerairz INSERT INTO messages (conversation_id, message, role, customer_id) VALUES (:conversation_id, :message, :role, :customer_id) z UPDATE conversations SET updated_at = NOW() WHERE id = :conversation_id rzError saving conversation: ) rappendlenrrrrrrr) rrr rrrmessagesrqueryquery1rs rsave_conversationr):sG+$7(L$YYO  OO#2#*    OO#2!*   x=A " ">>RE F **UH- - -**V&7%IJ J J))+  ">MZ." . J ">>>  /s34sD6DC&ADD6D+C(,D/,C2C*C27C,8C2C.C2 DC0 D%D6&D(D*C2,C2.C20D2D8C; 9DDD6D D3D.)D6.D33D6feedback)updownreturnc(Kt4d{}|jtdd|id{}|js t dd|jtdd|id{}|j}|s t dd|d }|jtd ||d d{|j d{ dddd{y 777|7477#1d{7swYyxYww) z Update feedback directly in `messages` table. - feedback: "up" -> 1, "down" -> 0 - Targets latest AI message in the conversation - Raises HTTPException if conversation or message not found Nz SELECT id FROM conversations WHERE id = :conversation_id AND is_deleted = 0 LIMIT 1; rizConversation not found) status_codedetailz SELECT id FROM messages WHERE conversation_id = :conversation_id AND role = 'ai' ORDER BY created_at DESC LIMIT 1; zNo AI message foundrz~ UPDATE messages SET feedback = :feedback WHERE id = :message_id; )r* message_idT)rrrfetchonerr)rr*r conv_result msg_resultmsg_rowr1s rsave_conversation_feedbackr6gs!~~JJ   0   ##%C8PQ Q::   0   %%'C8MN NQZ jj   %(   iik_~~    $  ]~~~sDC1D!C=C3AC=8C59A C=C7C=C9C= D+C;,D3C=5C=7C=9C=;D=DD D D)NNN)rrlogging sqlalchemyrtypingrapp.models.connectionrapp.exceptions.httpr getLogger__name__rrdictrr)boolr6rrBs .->g!`bs#Y]$,S,C,s,^adh^h,y|@DzD,Z]`dZd,Z::l#: :rA