9j$- d Z ddlmZ ddlZddlZddlmZ ddlm Z m
Z
m Z ej e
ZdZdZdZd Zd
Zd Zd Zd
Z G d d Zy)u E-mail notifications for status-67 (Dopasowano) leads via SendGrid.
Sends SEPARATE mail per operator address — recipients never see each other.
Failures are logged and swallowed so the pipeline continues uninterrupted.
) annotationsN)Settings) MatchResult PartQueryPostz#2563ebz#1877F2z#16a34az#6b7280z#f3f4f6z#f9fafbz#e5e7ebz#111827c e Zd ZdZd dZed
d Z ddZddZ ddZ ddZ
e dd Z e dd Z
e dd
Zy )
MatchNotifierzDSendGrid notifier for matched leads. Safe to use even without a key.c z |j | _ |j | _ |j j d D cg c]# }|j
s|j
% c}| _ |j | _ |j j d | _ d| _
t | _ y c c}w )N,/r )sendgrid_api_key_api_keynotify_email_from _from_emailnotify_email_tosplitstrip
_to_emailsnotify_max_per_cycle_max_per_cycledgred_base_urlrstrip _dgred_base _sent_countset_notified_posts)selfsettingses G/var/www/html/agent.samochodowy/src/agent_samochodowy/dgred/notifier.py__init__zMatchNotifier.__init__ s 11
#55 ' 7 7 = =c B
aggiAGGI
' ; ;#2299#> ),
s B8B8c H t | j xr | j S )N)boolr r )r s r enabledzMatchNotifier.enabled* s DMM5doo66 c | j st j d y|j | j v r!t j d|j y| j
| j k\ r7t j d| j
| j |j y|j r|j d nd}| j | }| j ||||| }d} | j D ] }
| j |
|| | j j |j | xj
d z
c_ t j! d
|j t# | j | j
| j | S # t $ r& t j d|j |
d} Y w xY w) zBSend notification for a Dopasowano lead. Returns True if all sent.z,Notifier disabled (no API key or recipients)Fz&Already notified for post %s, skippingz7Notification throttle reached (%d/%d), skipping post %sr NTu/ SendGrid error for post %s to %s — continuing z8Notification sent for post %s to %d recipient(s) (%d/%d))r$ loggerdebugpost_idr r r warningoffers_build_subject _build_htmlr _send_single Exception exceptionaddinfolen) r postqueryresult client_id
reply_text top_offersubject body_htmlall_ok recipients r notify_matchzMatchNotifier.notify_match. s || LLG H <<4// / LLA4<< P t 2 2 2 NNI $"5"5t||
(.
FMM!$4 %%e,$$T5)Y
S I
!!)Wi@
. A F LL#doo.0@0@$BUBU
ELL)
s F ,G
G c |j xs d}|j |j fD cg c] }|s| }}|rdj | nd}|rd| d| S d| S c c}w )N część zNowe dopasowanie: )categorybrandmodeljoin)r r6 partp
vehicle_partsvehicles r r- z MatchNotifier._build_subjecta sm ~~+%*[[%++$>Dq!D
D-:#((=) 'vQwi8 8#D6** Es
A A c l t j }| j j dd d| } ||j xs d }|j
|j fD cg c] } | s| }
} |
r |dj |
nd} | d| j } |j
|j |j fD cg c] } | s| }
} |
r |dj |
nd}|j r! |dj |j nd}|j xs d}|r| j d|t nd }|j r!| j d
|j t nd}d}|r| j! | }|j" xs d}|r| j d |t$ nd}d t& d
t( dt dt* d ||j, dt* d || d| d}dt dt. dt* d || d }dj g d || dt0 d t0 d t d t* d | d t( d!t d" ||j2 d#t* d ||j4 d$t* d% ||j6 d&t d'| d(| d)| d*| d+t( d,| d-| d.t( d/| j d0|t. d1t( d2t d3 S c c} w c c} w )4Nz/api/v1rC z/client/rA rB u —z, u Otwórz post na FacebookuzQ
Brak linku do posta
z
Profil autorau Zobacz ofertęz}
Dopasowana oferta
z:
z
z@
z
Gotowa propozycja odpowiedzi
z
z
z;
Nowe dopasowanie
zj
Zapytanie z grupy z
z>
Pojazd: z · OE: z
z1
z{
z
zd
u Otwórz lead w dgredzY
Agent Samochodowy · powiadomienie automatyczne
) html_modescaper replacerD rE rF rG r year
oe_numberspost_url
_btn_block_CLR_FBauthor_profile_url
_CLR_MUTED
_format_priceurl
_CLR_GREEN _CLR_CARD _CLR_BORDER _CLR_TEXTtitle _CLR_PRIMARY_CLR_BGgrouptext author_name)r r5 r6 r: r8 r9 r
dgred_linkrH rI rJ rK header_title vehicle_full vehicle_stroe_strrR post_btn profile_btn
offer_html price_str offer_urlsee_btn
reply_htmls r r. zMatchNotifier._build_htmlm sq
OO ((00B?@ T
-:.%*[[%++$>Dq!D
D0=!CHH]+,2 q *002 $)KKejj#IOaQO O3?a ./U 383C3C499U - -./ ==&B
OO 77 Kd &&
OOOT-D-Dj Q,.
**95I!
+IR[doo&6 :NacG GGPkQcdocp qRR\Q] ^55>K?jklmvm|m|k}j~ 44=;>STUV_T`Sa b
) ,
/JR S]Q] ^88D~E} H ~I I{ |} ~H |I {J J
> > > ,>,> -49>5G> HOi
> PT
> U_S_ > `6 > 7@[ > AS > T`R` > aC >& DO-'>&PT'>. U_S_/>. `G/>. HI JN JT JT HU GV/>.Vy/>0 zC yD1>0 Dv1>0 wx y} yB yB wC vD1>0D+1>4 ,5+5>4 6S5>4 TUUYUeUeSfRg5>4h+5>6 ,6,7>6 7U7>6 VaTa7>6 b|7>6 }C |D7>6D7>8 j9>8'9>: (3m;>:4C;>D DO-E>DPE>L LM>LM>N LO>NCO>V DO-W>VPW>^
__+Z FG_>^H9_>f :E
g>fF&g>h '1\i>h
2i> > c E Ps "L,*L,L1
L1c ddl m} ddlm}m} | j | j } ||||| } || j } | j | }
|
j dk\ r%t d|
j d|
j y) z3Send one mail to one recipient via SendGrid v3 API.r )SendGridAPIClient)EmailMail)
from_email to_emailsr; html_contenti zSendGrid HTTP z: N) sendgridrp sendgrid.helpers.mailrq rr _parse_emailr r send status_code RuntimeErrorbody) r r> r; ru rp rq rr rs messagesgresponses r r/ zMatchNotifier._send_single s .5&&t'7'78
! %
t}}
-777# 3 & !5!5 6b H
'r% c ddl m} | j } d| v rZ| j d rI| j dd \ }} ||j d j |j S || S )z@Parse 'Display Name ' or plain 'addr' into SendGrid Email.r )rq <>r' )rw rq r endswithrsplitr )rawrq nameaddrs r rx zMatchNotifier._parse_email sg 0iik #:#,,s+ C+JD$S)//14::<@ @Szr% c @ d| d| dt j | dS )uB Full-width block button — works on mobile without media queries.zT
)rM rN )labelrX colors r rS zMatchNotifier._btn_block s: u >ug F* +3//%*@)A B!
"
r% c | j ^| j xs d}| j t | j k( rt | j d| S | j dd| S y)NPLNrB z.2fzdo uzgodnienia)pricecurrencyint)offercurs r rW zMatchNotifier._format_price se ;; "..)EC{{c%++ .. ekk*+1SE22kk#&au- - r% N)r r returnNone)r r# ) r5 r r6 r r7 r r8 int | strr9 strr r# )r6 r r r )
r5 r r6 r r8 r r9 r r r )r> r r; r ru r r r )r r r z'Email')r r rX r r r r r )r r )__name__
__module__ __qualname____doc__r! propertyr$ r? r- r. r/ staticmethodrx rS rW r% r r r s N / 7 7-- - -
-
-
-f+{{ {
{
{
{B&
r% r )r
__future__r htmlrM loggingagent_samochodowy.configr agent_samochodowy.modelsr r r getLoggerr r( r^ rT rY rV r_ rZ r[ r\ r r r% r r sf # - A A 8 $
C C r%