Upload router_users.py

router_users.py

@@ -4,8 +4,8 @@ import time
 import re
 import random
 import os
-import smtplib
-from email.mime.text import MIMEText
+import json
+import urllib.request
 import 数据库连接 as db
 from notifications import add_notification
 from models import UserRegister, UserLogin, UserUpdate, PasswordReset, FollowToggle, PrivacySettings, SendCodeRequest
@@ -18,36 +18,46 @@ router = APIRouter()
 VERIFY_CODES = {} 
 
 def send_email_code(to_email: str, code: str, action: str):
-    """底层邮件发送引擎"""
-    sender = os.environ.get("SMTP_USER")
-    pwd = os.environ.get("SMTP_PASS")
-    server = os.environ.get("SMTP_SERVER", "smtp.qq.com")
-    port = int(os.environ.get("SMTP_PORT", 465))
-
-    if not sender or not pwd:
-        print("警告: 未配置 SMTP_USER 或 SMTP_PASS，跳过邮件发送")
+    """利用自动化 Webhook 作为 HTTPS 到 SMTP 的代理桥梁"""
+    webhook_url = os.environ.get("MAKE_WEBHOOK_URL")
+
+    if not webhook_url:
+        print("警告: 未配置 MAKE_WEBHOOK_URL，跳过邮件发送")
         return
 
     action_str = "注册账号" if action == "register" else "修改/找回密码"
-    msg = MIMEText(f"【ComfyUI 社区精选】您的验证码是：{code}，用于{action_str}。有效期 10 分钟。如非本人操作，请忽略此邮件。")
-    msg['Subject'] = f"ComfyUI 社区 - {action_str}验证码"
-    msg['From'] = sender
-    msg['To'] = to_email
+    subject = f"ComfyUI 社区 - {action_str}验证码"
+    
+    html_content = f"""
+    <div style="background:#f9f9f9; padding:20px; font-family:sans-serif;">
+        <div style="background:#fff; padding:20px; border-radius:8px; max-width:500px; margin:0 auto; box-shadow:0 2px 10px rgba(0,0,0,0.05);">
+            <h2 style="color:#4CAF50; margin-top:0;">ComfyUI 社区精选</h2>
+            <p>您好，</p>
+            <p>您正在请求<strong>{action_str}</strong>，您的验证码是：</p>
+            <div style="font-size:24px; font-weight:bold; color:#2196F3; background:#e3f2fd; padding:15px; text-align:center; border-radius:6px; letter-spacing: 5px;">{code}</div>
+            <p style="color:#888; font-size:12px; margin-top:20px;">该验证码在 10 分钟内有效。如非本人操作，请忽略此邮件。</p>
+        </div>
+    </div>
+    """
+
+    # 组装要发送给 Make.com 的数据
+    data = {
+        "to": to_email,
+        "subject": subject,
+        "html": html_content
+    }
 
+    # 发送普通的 HTTPS POST 请求，绝对不会被拦截
+    req = urllib.request.Request(
+        webhook_url, 
+        data=json.dumps(data).encode('utf-8'), 
+        headers={'Content-Type': 'application/json'}
+    )
     try:
-        # 【核心优化】：加入 timeout=10 防卡死机制
-        if port == 465:
-            with smtplib.SMTP_SSL(server, port, timeout=10) as smtp:
-                smtp.login(sender, pwd)
-                smtp.send_message(msg)
-        else:
-            with smtplib.SMTP(server, port, timeout=10) as smtp:
-                smtp.starttls()
-                smtp.login(sender, pwd)
-                smtp.send_message(msg)
-        print(f"✅ 成功发送验证码 {code} 至 {to_email}")
+        with urllib.request.urlopen(req, timeout=10) as response:
+            print(f"✅ 成功触发 Webhook 发送验证码 {code} 至 {to_email}")
     except Exception as e:
-        print(f"❌ 邮件发送失败: {e}")
+        print(f"❌ Webhook 触发失败: {e}")
 
 def send_sms_code(phone: str, code: str, action: str):
     """短信发送接口挂载点"""