From fcc74dbac2741edac0e899066d6f4f4d392a5115 Mon Sep 17 00:00:00 2001
From: Faheed <faheed@tenhal.sa>
Date: Tue, 18 Nov 2025 19:03:20 +0300
Subject: [PATCH] messages and email

---
 recruitment/__pycache__/views.cpython-312.pyc | Bin 193644 -> 194502 bytes
 recruitment/views.py                          |  24 ++++++++++++++++--
 2 files changed, 22 insertions(+), 2 deletions(-)

diff --git a/recruitment/__pycache__/views.cpython-312.pyc b/recruitment/__pycache__/views.cpython-312.pyc
index a4efc7df727700a840986734e663c6477c538e79..e95788d2c380bd5a7fdfcd878d2ffd4e24c68813 100644
GIT binary patch
delta 2583
zcmZWqd2o~05!YLPpAO5CPszgID}X^X$P`Gx+=j6!L*l@gqn&_+(WhV;d_75EJQB7E
z0YehQR4r=*<{SuMCwNHH&jX>wIFpOeST0kkY9Mr)G-Q$z(vq2`w54xloPYX_=cj#p
z{NBEOZ`WVnHNN|e(R|%xO4f+4qH~<Lrn=4il9|0_hJCZb^Lh;#FC=L+s8N^#TQs#S
z#Fz#nFS2aBI)lm50mfG#dz}^Hg&APMt1Fp49B#AWoeE}<8P^9PJn(%MZnyv@mK08Z
z&z9`c(@ykZq>dGa=PWG1d$Yl)-=tA=Ck1;rb-Xp)cU_BvFR-kzX}k?D{0ekTCOtMB
zVOlAqRgAQfwrcof67-63j3DG=XptlqIM58)+B&ABgmhTQMYhFPSmu<F-k+P;T7Y5-
z%0X>V+QfqTpiVLOruOJYY$1a`4;$~YaZ`eZ!x|;68+zD?g=zfbe~3>X)mCc!nHbyz
z`KF8>7<H_(P+1BvEsGfppkxNY%R<Q`xy*T*W!jXi&9g+xCck}@F{n{2!DM`6HOnrs
z29tY4-RY~;*t46nmT*s%-&0UkQ0LiJQ0wvesy2DJNto>{o>Ep@<=s;0;ak0KJYNEn
zTkJA_Rub%|ghO2C3v8_MxczaRyS~ovsq^y{WJ@?WNpg+4Rx}rJkDCX){#xPY@K^aZ
z`y4(`o#NUU*s|H>p>15GZJzM|ej`?2!0q-pd_Groef?&8Qrt}89_|YG1b7vmB`Oq`
z$k?neXbgA)9>syfC9u|FiJKl%Bo5-?>qS~PWezx6o)`7!KNFFB2}%3JsrVR@A_N;~
z`3b@EqGa49B)gHHCIwOO3nWDa#8XAq-UhEY+sIis9Y1b%2YmkeTGwb*DMh}4EIK-?
z%gYoTdWYo{$IXvjT<*ke@M__-IzyxJ?G$;mYQEEI<R@b~^PU}TJ36hu$NQyV)!#9u
z?w`MR{;OzS47qrzgIQV@-%MHZr<C$o-V@Qh;z(X`pD~g*FPgVFlDD}1xtKL4YMm6Z
zPC9FdSf{ryjpY_ba~+Xf$Jy<X+>-W+*vyjtRnhqs5%D*(VyJR$v{H#wDnp){;mXYi
zRz)pE5lhkWK*TaNYMC}{nKslIXfKcDPB^x%Yuzzdm#e*E_Gi|Dm~BzamLIbf#l}n?
zvf1xUdMcJbF_ydJLApM>jI}R)kfkwY?q9xldFQN7`|;UBwkL0<OjT3oLX|8hs)pMa
z!4ukzq5#~DCl<lVv>K9!sMd)~aw3$%0#<{ir7&Ht6~;ETsT9sh$qhp8qpJ1ciDgi(
zHkQL9VD;Fz42onfj325;mcb{Iyj94bsi6ue1J;CtE5wG|g-Xg)zghu>DcTmX;H{Xk
z9`>?UJhC3XVJ-NI6H2W?vZ$2H7X-WLMt4it+9qbyKb?@SeOWk|GSyTU>@=_)`15L5
z#dhHr)lkCrV4)ZC*-k9=!V*FFk{6z4yYX!=%#ja>ur~Ff7jDaGJ7^C^%!xhr;FtAq
z)V!0l)ONf>NVvuecER!62FTIwC(~~Hv;pSHVIf~s3mTyb<X;N;bG6$CuO%@*mTiMC
z<-<aC52uEpOl@j{SQ0~A8H7D!{X}ts*l!SY(z1)-kc8iFgDIFB0;9HDXfm@@M+ica
zd|WJMt9@<o7p;+=d&R19yPiAMqwTPq>9`_P{1pCcFI-}$@U49?i#hRc`=C^QQ&^np
zjF+KPmivVqQ-=<~nk4x*LjF$u(J$Z?U{|pJAZ%d+I1yoj^$Kwf5L_b|BzQ-{Z$D=_
z#>=!IFj~}I2v@;)i8T4tz?bp4L*PhDgxg4QlKS{<eDx6g6s}14_4{nx7?ZC)z}+5K
zpg|FXkiRRUi!9<1UBZGhkgv`?4C#+KFH&?ruI+~MjKsD-6zrVDui%AlXcdW1I|?(C
zKNKtri3N$JK<zjR*MMEdl_y{idmsOJ0+ywJM0wsI2omw{Bz)r#6ymCrU`<J+{MZ5a
zPiHpl5bETQg?A;<UK>g7#!2V^b_v&=hKYiG=V@??4E}r?o|110*IIS#8Hh{TC~XqM
zhv%W2{Q<jrpiTUY?S)CBmY?*(T=t^6s~5IP@~6W4vihhGy5yXb6nUJUL}E&wCF!pO
zPQ3VQa8}U8Cq^JYLsDWkzDCknf^!6k&OJ|34?&Egdr6|n$rp;F+w(?Wi&F(3yMx0j
zEESI?ryo{}N7K*`Kh|Cp5xz{U>V?ek$HN93><6oSPbhDyxBH<>&mLma02H#>>Y)KB
z(XxN5H{XM2SxS;DHn~STfs9i>faSVst6<84aH}I*J@^4E0(dBeZx!bz->0Mqit*8P
zF=6hj3qFED86+8#hT*hq7F5U7*N5S{WKAPlf+(>K3jS8jgA}Z~4L0>m6#gsgWb)9;
z*mDaCwGu5-aQGH%PtG8j;6Li>+i=~`Lc^ZZ9OE>=I1MUJ6N=MJ;xte=jR#Jx&8eq3
zbup)A<kW<m8j4dVacZGNGbEldr&q}7&2V}Rd@jwD2UH8X;&_@;Q&qRA{uzh6o_ieh
zFPPsUH>zr)4xCP$IAtPVevm?upi@9xKd-i432gB!;ERNxXfKVgS^erRR2ecRv&HNm
TNg7D|7D&9mhN<iS4yo`zSC#9Q

delta 1834
zcmX|BYfMyE5WZ)2@4`NKF0KzAia{z;uryVIP_2U22PL&))Wm`dY%RK|Js={kf?BmI
zV(qpW1wl|iunJg_lY&isP+JQMB(^H3m9+Jd5b>GDSWC~W#{Kc_oVnk8bMD-kIX__R
zziaet_wX<%^4Gd0AaiQQM$avt?4&2`h;}CS>)Cz$;~E>yN}Ub+N8#dmV8PRKnLDg!
zxbasOq~*yD=Im=5;`A=_Mn@wvn;ej;BQ^Trhn39Y9QBFOxuh%@>yuy<<ajxw8Ut`#
z4fA3{r06*J3^xbMWa~A~sAof+;i=|f8ScxY6@`1`41cMjC=Mk<@6h1*Y&H~^)-Z4M
zjFlIOiG@%!#lZsRfq8Kdi90qi173;)1I|J)YWNie&vY;gw$BB<e>%5Wb8I|St0?n*
z6(zeviWe#mbc(wdCQgSyb_;hGv*CE)T`>FnW%9dX3g|Wk>|M|mI_<J4UgS;&tE%sD
z%U+$f%$A;m*W+Qd@nb2*QzV29#}_kUB#uph2=6rVc1d|2&m>sUmH?Ak8dfF1+p0}I
z%o4o`P^VQtmG*wIeHP5tu%&o85kl2v($y>m6XCj6T_No*aceG22et}BlVP;(GwFKZ
zE0U5S*rZz{4?GW7FM;hW4+odP09%6tR+!3iFe(kqYy(bDgEw@WCGVN9;AyZ)&vNnU
za!6(loNb4g-~y7UpsUW5R+xpSkiD7Ukw!v3R@ot5%HFlZM5#A23nr;wNNScy$%31z
zcP<GqkZ^~B3NSGn%02VRdx#ucrG?+yAuQN++YpzJs!}K+%#Bx*V;j*o;ItfwQ+G<c
zTx`yPJWzK@ySsS}9M&*9*5<=Kol|;x%($lz5=8GhxT;~hv8e#I`P)gNlEf|&d`ZVW
z1Yc=!@j4iXg@s_$eIq@CW+B7ZYt_B-5F*T5;7^^=D($4?8DZ|+Dp(QBVLm+`wk&I=
zJvH0Lb2HOzycFl{f)-Yap2ZN&tT>|>rm9C}*lbZ$40~0>acQ^t$;P^Xw_2FLnDsSG
z)Tlyw`^4u6MZlWTrv&V*1vivHh^1LR;VlHM1g8jo(Bi|t*$8739SHvM6E{lWG#F2i
zXCxJ_32VzB(%Th2j2s8)L!HFiWw21Dm{JaJsy|A$uUJ(M6JAArN1Wr>SOGJ9UE;4x
zRj1|6=w1nhGIo0<ykj^gW5b8Y_dx6`0W%iWfd`sSup+!!1A5^&2ob=V@JJPG)18sr
z{0I!F1b_Uf8p3>jqHCTfa8SmdwHSmDjK`|MVszd3B>^v0!+66lk~f7ioqe6jBtmPT
z7}yCsSqo!in%-JSkvE%E2NMhzC4Uj|kGc3l-t4Sa*G1X7F}WVfSSLQJhmG<tr$P4p
zt0$EW5X)AI8x4@FRj*3+VX?3Y_NgOED6)duWf3)SEm^k-tY~b3lq6~jxkDtBljUmF
z1Fjf?N&?rEA0+D#!Brwxk>v`TB5M#9#H-0silPOw*)<Grh4*C}Ww*k7*+v&yA&PyA
z&s!l{y(4+2Mf54y=gyvBcN+w=5b?MTVsz}Oh-ilonCV}Vx=&f2YjJA_%yCP$$b$HR
zvoLa~80diaK!(262|<Q?L?!UYg`F^2M`pU#8Fkc8G<L!f6<)~6_zkKJZmOc}B$W!h
z@52Jc*x%)DGU%n36Py#hJ#zE7{YQF(TGaMIu<ivNR1EKfwFV<G3GRvdK4{k$(2C`>
z=Qu4mPAiSmF5|SlIBg?ND}>XibDD8ZW6fzeISnPJvEnpOoW{pB2%K7)Q*Ux=8&18z
zW9hR!p=!`)?eWf7W?iv#<(SCymE0Cd)61_Bjq2*E1gBSZy%aZMU_S&JVx&XPkdnPt
bB=mz-?_*)p*kg?X-VcGy2a!TN1uys?Zs8H+

diff --git a/recruitment/views.py b/recruitment/views.py
index 72b5e92..9db131b 100644
--- a/recruitment/views.py
+++ b/recruitment/views.py
@@ -4692,7 +4692,8 @@ def message_detail(request, message_id):
 
 @login_required
 def message_create(request):
-    """Create a new message"""
+    """Create a new message""" 
+    from .email_service import EmailService
     if request.method == "POST":
         form = MessageForm(request.user, request.POST)
 
@@ -4700,8 +4701,25 @@ def message_create(request):
             message = form.save(commit=False)
             message.sender = request.user
             message.save()
-
             messages.success(request, "Message sent successfully!")
+            ["recipient", "job", "subject", "content", "message_type"]
+            recipient_email = form.cleaned_data['recipient'].email # Assuming recipient is a User or Model with an 'email' field
+            subject = form.cleaned_data['subject']
+            custom_message = form.cleaned_data['content']
+            job_id = form.cleaned_data['job'].id if 'job' in form.cleaned_data and form.cleaned_data['job'] else None
+            sender_user_id = request.user.id
+           
+            task_id = async_task(
+                        'recruitment.tasks.send_bulk_email_task', 
+                        subject,
+                        custom_message, # Pass the custom message
+                        [recipient_email], # Pass the specific recipient as a list of one
+                      
+                        sender_user_id=sender_user_id,
+                        job_id=job_id,
+                        hook='recruitment.tasks.email_success_hook')
+            
+            logger.info(f"{task_id} queued.")
             return redirect("message_list")
         else:
             messages.error(request, "Please correct the errors below.")
@@ -4714,6 +4732,8 @@ def message_create(request):
     if request.user.user_type != "staff":
         return render(request, "messages/candidate_message_form.html", context)
     return render(request, "messages/message_form.html", context)
+
+
 @login_required
 def message_reply(request, message_id):
     """Reply to a message"""