from django.core.mail import send_mail, EmailMultiAlternatives, get_connection from django.template.loader import render_to_string from django.conf import settings from django.utils.html import strip_tags def send_welcome_email(user, verification_token=None): """Send welcome email after registration""" subject = f"Welcome to Wananchimart, {user.full_name}!" # Build verification URL if token provided verify_url = None if verification_token and user.email: verify_url = f"{settings.FRONTEND_URL}/verify-email?token={verification_token.token}" context = { 'user': user, 'verify_url': verify_url, 'frontend_url': settings.FRONTEND_URL, } # HTML message html_message = f"""

Welcome to Wananchimart!

Hi {user.full_name},

Thank you for joining Wananchimart! We're excited to have you on board.

{"

You've registered as a " + user.get_user_type_display() + ".

" if user.user_type else ""} {f'''

Please verify your email address by clicking the button below:

Verify Email Address

If the button doesn't work, copy and paste this link into your browser:

{verify_url}

''' if verify_url else '''

You can now start exploring the marketplace!

'''}

If you have any questions, feel free to reach out to our support team.

Best regards,
The Wananchimart Team

""" plain_message = strip_tags(html_message) try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send welcome email: {e}") return False return False def send_otp_email(user, otp): """Send OTP via email for login verification""" subject = "Your Wananchimart Login Code" html_message = f"""

Your Login Code

Hi {user.full_name},

You requested to log in to your Wananchimart account. Use the code below to complete your login:

{otp.otp_code}
Important: This code expires in 10 minutes. Do not share this code with anyone.

If you didn't request this code, please ignore this email or contact support if you're concerned about your account security.

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, Your Wananchimart login code is: {otp.otp_code} This code expires in 10 minutes. Do not share this code with anyone. If you didn't request this code, please ignore this email. Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send OTP email: {e}") return False return False def send_password_reset_otp_email(user, otp): """Send OTP via email for password reset""" subject = "Your Wananchimart Password Reset Code" html_message = f"""

Password Reset Code

Hi {user.full_name},

You requested to reset your password. Use the code below to proceed:

{otp.otp_code}
Important: This code expires in 10 minutes. Do not share this code with anyone.

If you didn't request a password reset, please ignore this email. Your password will remain unchanged.

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, Your Wananchimart password reset code is: {otp.otp_code} This code expires in 10 minutes. Do not share this code with anyone. If you didn't request this, please ignore this email. Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send password reset OTP email: {e}") return False return False def send_email_verification(user, token): """Send email verification link""" subject = "Verify Your Wananchimart Email" verify_url = f"{settings.FRONTEND_URL}/verify-email?token={token.token}" html_message = f"""

Verify Your Email

Hi {user.full_name},

Please click the button below to verify your email address:

Verify Email Address

If the button doesn't work, copy and paste this link:

{verify_url}

This link expires in 24 hours.

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, Please verify your email by visiting: {verify_url} This link expires in 24 hours. Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send verification email: {e}") return False return False def send_upgrade_email(user, vendor_profile, amount, plan_type='monthly', expires_at=None): """Send email after successful Pro upgrade""" subject = "Welcome to Wananchimart Pro!" plan_label = "Yearly Plan" if plan_type == 'yearly' else "Monthly Plan" expiry_str = expires_at.strftime('%B %d, %Y') if expires_at else 'N/A' html_message = f"""
👑

Welcome to Pro!

Hi {user.full_name},

Congratulations! Your Wananchimart Pro subscription is now active for {vendor_profile.shop_name}.

Plan: {plan_label}

Amount paid: KES {amount:,.2f}

Valid until: {expiry_str}

Your Pro Features:

✔ Up to 100 products
✔ 5 images per product
✔ Video uploads
✔ Discount pricing
✔ Featured products
✔ Analytics dashboard
✔ Priority in search
✔ Direct messaging

You can manage your subscription and renew from the "My Plan" page in your dashboard.

View My Plan

Thank you for upgrading and supporting Wananchimart!

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, Congratulations! Your Wananchimart Pro subscription is now active for {vendor_profile.shop_name}. Plan: {plan_label} Amount paid: KES {amount:,.2f} Valid until: {expiry_str} Your Pro Features: - Up to 100 products - 5 images per product - Video uploads - Discount pricing - Featured products - Analytics dashboard - Priority in search - Direct messaging You can manage your subscription from the "My Plan" page in your dashboard. Thank you for upgrading! Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send upgrade email: {e}") return False return False def send_verification_submitted_email(user, vendor_profile): """Send email when verification request is submitted""" subject = "Verification Request Received - Wananchimart" html_message = f"""

Verification Request Received

Hi {user.full_name},

We've received your verification request for {vendor_profile.shop_name}. Our team will review your submission and get back to you.

What happens next?

Our team will review your business information and verify your account. You'll receive a notification once the review is complete.

Check Status

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, We've received your verification request for {vendor_profile.shop_name}. Our team will review your submission and get back to you. You can check the status at: {settings.FRONTEND_URL}/vendor/verify Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send verification submitted email: {e}") return False return False def send_verification_approved_email(user, vendor_profile): """Send email when verification is approved""" subject = "You're Verified! - Wananchimart" html_message = f"""
✅

You're Verified!

Hi {user.full_name},

Congratulations! Your business {vendor_profile.shop_name} has been verified on Wananchimart.

A verified badge is now displayed on your profile and shop, helping you build trust with customers.

Go to Dashboard

Thank you for being part of Wananchimart!

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, Congratulations! Your business {vendor_profile.shop_name} has been verified on Wananchimart. A verified badge is now displayed on your profile and shop. Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send verification approved email: {e}") return False return False def send_sponsored_ad_email(user, vendor_profile, item_name, item_type, days, amount, starts_at, ends_at): """Send email after successful sponsored ad purchase""" subject = "Sponsored Ad Confirmed - Wananchimart" start_str = starts_at.strftime('%B %d, %Y') if starts_at else 'N/A' end_str = ends_at.strftime('%B %d, %Y') if ends_at else 'N/A' type_label = item_type.capitalize() html_message = f"""
📢

Ad Confirmed!

Hi {user.full_name},

Your sponsored ad for {item_name} is now live on Wananchimart!

Ad Details

Item: {item_name}
Type: {type_label}
Duration: {days} day{'s' if days > 1 else ''}
Amount Paid: KES {amount:,.2f}
Start Date: {start_str}
End Date: {end_str}

Your {item_type} will appear with a "Sponsored" badge on relevant pages across Wananchimart, giving it extra visibility.

View My Ads

Thank you for advertising on Wananchimart!

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, Your sponsored ad for {item_name} is now live on Wananchimart! Ad Details: - Item: {item_name} - Type: {type_label} - Duration: {days} day{'s' if days > 1 else ''} - Amount Paid: KES {amount:,.2f} - Start Date: {start_str} - End Date: {end_str} Your {item_type} will appear with a "Sponsored" badge on relevant pages. View your ads at: {settings.FRONTEND_URL}/vendor/ads Thank you for advertising on Wananchimart! Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send sponsored ad email: {e}") return False return False def send_verification_rejected_email(user, vendor_profile, reason=''): """Send email when verification is rejected""" subject = "Verification Update - Wananchimart" reason_html = f'

Reason: {reason}

' if reason else '' reason_text = f'\nReason: {reason}' if reason else '' html_message = f"""

Verification Update

Hi {user.full_name},

Unfortunately, your verification request for {vendor_profile.shop_name} was not approved at this time.

{f'
{reason_html}
' if reason else ''}

You can resubmit your verification request with updated information.

Resubmit Verification

Best regards,
The Wananchimart Team

""" plain_message = f""" Hi {user.full_name}, Unfortunately, your verification request for {vendor_profile.shop_name} was not approved.{reason_text} You can resubmit with updated information at: {settings.FRONTEND_URL}/vendor/verify Best regards, The Wananchimart Team """ try: if user.email: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[user.email], html_message=html_message, fail_silently=False, ) return True except Exception as e: print(f"Failed to send verification rejected email: {e}") return False return False def _build_bulk_email_html(recipient_name, body_content): """Build branded HTML email for bulk sends""" return f"""

Wananchimart

Hi {recipient_name},

{body_content}

Best regards,
The Wananchimart Team

You received this email because you are a member of Wananchimart.

""" def send_bulk_email(subject, body_html, recipients, campaign_id=None): """ Send bulk email using a single SMTP connection. recipients: list of dicts with 'name' and 'email' keys. campaign_id: optional EmailCampaign pk to update with results. Designed to run in a background thread — always updates campaign on exit. """ from django import db as django_db sent_count = 0 failed_count = 0 failed_emails = [] error_message = '' try: # Close any stale DB connections inherited from the parent thread django_db.connections.close_all() connection = get_connection() connection.open() for recipient in recipients: name = recipient.get('name', '') email = recipient.get('email', '') if not email: failed_count += 1 failed_emails.append(email) continue html_message = _build_bulk_email_html(name, body_html) plain_message = strip_tags(html_message) try: send_mail( subject=subject, message=plain_message, from_email=settings.DEFAULT_FROM_EMAIL, recipient_list=[email], html_message=html_message, connection=connection, fail_silently=False, ) sent_count += 1 except Exception as e: print(f"Failed to send to {email}: {e}") failed_count += 1 failed_emails.append(email) try: connection.close() except Exception: pass except Exception as e: error_message = str(e) print(f"SMTP connection error: {e}") failed_count = len(recipients) - sent_count failed_emails = [r.get('email', '') for r in recipients[sent_count:]] finally: # ALWAYS update campaign — even if thread crashed if campaign_id: try: django_db.connections.close_all() from accounts.models import EmailCampaign from django.utils import timezone as tz campaign = EmailCampaign.objects.get(pk=campaign_id) campaign.sent_count = sent_count campaign.failed_count = failed_count campaign.failed_emails = ','.join(failed_emails) campaign.error_message = error_message campaign.status = 'failed' if sent_count == 0 and failed_count > 0 else 'completed' campaign.completed_at = tz.now() campaign.save() except Exception as e: print(f"Failed to update campaign {campaign_id}: {e}") return { 'sent_count': sent_count, 'failed_count': failed_count, 'failed_emails': failed_emails, }