messages and email
This commit is contained in:
parent
acee95995c
commit
fcc74dbac2
Binary file not shown.
@ -4693,6 +4693,7 @@ def message_detail(request, message_id):
|
|||||||
@login_required
|
@login_required
|
||||||
def message_create(request):
|
def message_create(request):
|
||||||
"""Create a new message"""
|
"""Create a new message"""
|
||||||
|
from .email_service import EmailService
|
||||||
if request.method == "POST":
|
if request.method == "POST":
|
||||||
form = MessageForm(request.user, request.POST)
|
form = MessageForm(request.user, request.POST)
|
||||||
|
|
||||||
@ -4700,8 +4701,25 @@ def message_create(request):
|
|||||||
message = form.save(commit=False)
|
message = form.save(commit=False)
|
||||||
message.sender = request.user
|
message.sender = request.user
|
||||||
message.save()
|
message.save()
|
||||||
|
|
||||||
messages.success(request, "Message sent successfully!")
|
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")
|
return redirect("message_list")
|
||||||
else:
|
else:
|
||||||
messages.error(request, "Please correct the errors below.")
|
messages.error(request, "Please correct the errors below.")
|
||||||
@ -4714,6 +4732,8 @@ def message_create(request):
|
|||||||
if request.user.user_type != "staff":
|
if request.user.user_type != "staff":
|
||||||
return render(request, "messages/candidate_message_form.html", context)
|
return render(request, "messages/candidate_message_form.html", context)
|
||||||
return render(request, "messages/message_form.html", context)
|
return render(request, "messages/message_form.html", context)
|
||||||
|
|
||||||
|
|
||||||
@login_required
|
@login_required
|
||||||
def message_reply(request, message_id):
|
def message_reply(request, message_id):
|
||||||
"""Reply to a message"""
|
"""Reply to a message"""
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user