§
|
3h ã óz d Z ddlZddlmZmZmZ ddlmZ ddlm Z m
|
Z
|
m Z ddl m Z ddlmZ ddlmZ e¦ « Z G d d
|
e¦ « Z G d d e¦ « Ze d e¬¦ « defd¦ « Ze d¦ « defd¦ « Ze d¦ « d ¦ « ZdS )u
|
Eäºç®¡å®¶åè°æ¥å£
|
é N)Ú APIRouterÚ HTTPExceptionÚRequest)Ú BaseModel)ÚDictÚAnyÚOptional)Úlogger)Úmessage_processor)Úmessage_workerc ó\ e Zd ZU dZdZee ed< eed< eed< eee f ed< dS )Ú CallbackDatau åè°æ°æ®æ¨¡åNÚaccountÚ messageTypeÚwcIdÚdata)
|
Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r ÚstrÚ__annotations__r r © ó ú,d:\project\python\ECloud\app\api\callback.pyr r sU Ø Ð à !GXc]Ð!Ð!Ñ!ØÐÐÑØ
|
IIIØ
|
sCx.ÐÐÑÐÐr r c ó6 e Zd ZU dZeed< eed< dZeed< dS )ÚCallbackResponseu åè°ååºæ¨¡åÚsuccessÚmessageéÈ ÚcodeN) r r r r Úboolr r r! Úintr r r r r s5 Ø Ð à MMMØ LLLØD#OOOOOr r z /callback)Úresponse_modelÚ callback_datac ó K t j d| j d| j ¦ « | ¦ « }t j |¦ « }|rQ| di ¦ « d¦ « }|rt j |¦ « t ddd¬¦ « S t d d
|
d ¬¦ « S # t $ rJ}t j d t |¦ « ¦ « t d dt |¦ « ¬¦ « d}~ww xY w)ux
|
æ¥æ¶Eäºç®¡å®¶åè°æ¶æ¯
|
|
Args:
|
callback_data: åè°æ°æ®
|
|
Returns:
|
å¤çç»æ
|
u æ¶å°åè°æ¶æ¯: messageType=z, wcId=r ÚfromUserTõ! æ¶æ¯å·²æåå å
¥å¤çéår ©r r r! Fõ æ¶æ¯å¤ç失败é u åè°å¤çå¼å¸¸: éô õ æå¡å¨å
é¨é误: ©Ú status_codeÚdetailN)r
|
Úinfor r Ú
|
model_dumpr Úenqueue_callback_messageÚgetr Úprocess_user_queuer Ú ExceptionÚerrorr r )r% Ú callback_dictr Ú from_userÚes r Úreceive_callbackr; # sB è è ðXÝ Ø e¨}Ô/HÐ eÐ eÐQ^ÔQcÐ eÐ eñ
|
ô
|
ð
|
ð
|
&×0Ò0Ñ2Ô2 õ $Ô<¸]ÑKÔKà ð [à%×)Ò)¨&°"Ñ5Ô5×9Ò9¸*ÑEÔEIØð =å Ô1°)Ñ<Ô<Ð<å#Ø Ð&IÐPSðñ ô ð õ $¨EÐ;OÐVYÐZÑZÔZÐ Zøå ð Xð Xð XÝ Ð4C°©F¬FÐ4Ð4Ñ5Ô5Ð5ݨÐ4VÍcÐRSÉfÌfÐ4VÐ4VÐWÑWÔWÐWøøøøðXøøøs B B5 Â#B5 Â5
|
D Â?ADÄD z /callback/rawÚrequestc ó K | ¦ « d{V }t j d| ¦ « d|vsd|vrt dd¬¦ « t j |¦ « }|rE| di ¦ « d¦ « }|rt j |¦ « d d
|
d d S d ddd S # t $ rJ}t j
|
dt |¦ « ¦ « t ddt |¦ « ¬¦ « d}~ww xY w)u
|
æ¥æ¶åå§åè°æ°æ®ï¼ç¨äºè°è¯ï¼
|
|
Args:
|
request: åå§è¯·æ±
|
|
Returns:
|
å¤çç»æ
|
Nu æ¶å°åå§åè°æ°æ®: r r r+ u 缺å°å¿
è¦å段r. r' Tr( r r) Fr* u åå§åè°å¤çå¼å¸¸: r, r- ) Újsonr
|
r1 r r r3 r4 r r5 r6 r7 r )r< Úraw_datar r9 r: s r Úreceive_raw_callbackr@ K sL è è ðXà Ð'Ð'Ð'Ð'Ð'Ð'å Ð;°Ð;Ð;Ñ<Ô<Ð<ð Ð (Ð (¨F¸(Ð,BÐ,BÝ ¨CÐ8LÐMÑMÔMÐ Mõ $Ô<¸XÑFÔFà ð Tà V¨RÑ0Ô0×4Ò4°ZÑ@Ô@IØð =å Ô1°)Ñ<Ô<Ð<à #Ð0SÐ]`ÐaÐaÐ aà $Ð1EÈsÐSÐSÐ Søå ð Xð Xð XÝ Ð:µ#°a±&´&Ð:Ð:Ñ;Ô;Ð;ݨÐ4VÍcÐRSÉfÌfÐ4VÐ4VÐWÑWÔWÐWøøøøðXøøøs B$B/ Â)B/ Â/
|
DÂ9AC>Ã>Dz/healthc óN K ddt t j ¦ « ¦ « dS )u å¥åº·æ£æ¥æ¥å£Úhealthyu æå¡è¿è¡æ£å¸¸)Ústatusr Ú timestamp)r# Útimer r r Ú health_checkrF s s. è è ð Ø'ÝÑ%Ô%ð ð ð r )r rE Úfastapir r r Úpydanticr Útypingr r r Úlogurur
|
Ú app.services.message_processorr Úapp.workers.message_workerr Úrouterr r Úpostr; r@ r4 rF r r r ú<module>rO sª ððð ð Ø 5Ð 5Ð 5Ð 5Ð 5Ð 5Ð 5Ð 5Ð 5Ð 5Ø Ð Ð Ð Ð Ð Ø &Ð &Ð &Ð &Ð &Ð &Ð &Ð &Ð &Ð &Ø Ð Ð Ð Ð Ð à <Ð <Ð <Ð <Ð <Ð <Ø 5Ð 5Ð 5Ð 5Ð 5Ð 5ð
|
ðð ð ð ð 9ñ ô ð ðð ð ð ð yñ ô ð ð [Ð)9Ñ:Ô:ð$X¨,ð $Xð $Xð $Xñ ;Ô:ð$XðN _Ñ Ô ð$X¨ð $Xð $Xð $Xñ Ô ð$XðN IÑÔðð ñ Ôðð ð r
|
