fix(email): 更新邮件服务配置以支持飞书SMTP

ruoshui-core/src/main/java/com/ruoshui/core/enums/glue/GlueTypeEnum.java

-package com.ruoshui.core.enums.glue;
-
-/**
- * Created by xuxueli on 17/4/26.
- */
-public enum GlueTypeEnum {
-    seatunnel("seatunnel", false, null, null),
-    datax("data", false, null, null),
-    flinkx("flinkx", false, null, null),
-    BEAN("BEAN", false, null, null),
-    GLUE_GROOVY("GLUE(Java)", false, null, null),
-    GLUE_SHELL("GLUE(Shell)", true, "bash", ".sh"),
-//    GLUE_PYTHON("GLUE(Python)", true, "python", ".py"),
-    GLUE_PYTHON("GLUE(Python)", true, "python3", ".py"),
-    GLUE_PHP("GLUE(PHP)", true, "php", ".php"),
-    GLUE_NODEJS("GLUE(Nodejs)", true, "node", ".js"),
-    GLUE_POWERSHELL("GLUE(PowerShell)", true, "powershell", ".ps1");
-
-    private String desc;
-    private boolean isScript;
-    private String cmd;
-    private String suffix;
-
-    private GlueTypeEnum(String desc, boolean isScript, String cmd, String suffix) {
-        this.desc = desc;
-        this.isScript = isScript;
-        this.cmd = cmd;
-        this.suffix = suffix;
-    }
-
-    public String getDesc() {
-        return desc;
-    }
-
-    public boolean isScript() {
-        return isScript;
-    }
-
-    public String getCmd() {
-        return cmd;
-    }
-
-    public String getSuffix() {
-        return suffix;
-    }
-
-    public static GlueTypeEnum match(String name){
-        for (GlueTypeEnum item: GlueTypeEnum.values()) {
-            if (item.name().equals(name)) {
-                return item;
-            }
-        }
-        return null;
-    }
-
-}

ruoshui-core/src/main/java/com/ruoshui/core/enums/handler/impl/ScriptJobHandler.java

@@ -2,12 +2,12 @@ package com.ruoshui.core.enums.handler.impl;
 
 import com.ruoshui.core.enums.biz.model.ReturnT;
 import com.ruoshui.core.enums.biz.model.TriggerParam;
-import com.ruoshui.core.enums.glue.GlueTypeEnum;
 import com.ruoshui.core.enums.handler.IJobHandler;
 import com.ruoshui.core.enums.log.JobFileAppender;
 import com.ruoshui.core.enums.log.JobLogger;
 import com.ruoshui.core.enums.util.ScriptUtil;
 import com.ruoshui.core.enums.util.ShardingUtil;
+import com.ruoshui.core.glue.GlueTypeEnum;
 
 import java.io.File;
 

ruoshui-system/src/main/java/com/ruoshui/bigdata/core/util/EmailUtil.java

 package com.ruoshui.bigdata.core.util;
 
-import com.sun.mail.util.MailSSLSocketFactory;
 import javax.mail.*;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
+import javax.net.ssl.X509TrustManager;
+import javax.net.ssl.SSLSocketFactory;
+import javax.net.ssl.TrustManager;
+import java.security.cert.X509Certificate;
 import java.util.Properties;
 
-
-
 public class EmailUtil {
 
     public static void send(String emailUserName,String emailPassword,String emailAuthorization,String SJemailUserName,String title,String msg) throws Exception{
         Properties properties = new Properties();
         //设置QQ邮件服务器
-        properties.setProperty("mail.host","smtp.qq.com");
+        properties.setProperty("mail.host","smtp.feishu.cn");
         //邮件发送协议
         properties.setProperty("mail.transport.protocol","smtp");
         //需要验证用户名密码
+        properties.setProperty("mail.smtp.host","smtp.feishu.cn");
+
+        properties.setProperty("mail.smtp.port","465");
         properties.setProperty("mail.smtp.auth","true");
-        //还要设置SSL加密，加上以下代码即可
-        MailSSLSocketFactory mailSSLSocketFactory = new MailSSLSocketFactory();
-        mailSSLSocketFactory.setTrustAllHosts(true);
-        properties.put("mail.smtp.ssl.enable","true");
-        properties.put("mail.smtp.ssl.socketFactory",mailSSLSocketFactory);
-        //使用JavaMail发送邮件的5个步骤
-        //1、创建定义整个应用程序所需环境信息的 Session 对象
-        Session session = Session.getDefaultInstance(properties, new Authenticator() {
+        properties.setProperty("mail.smtp.ssl.enable","true");
+        properties.setProperty("mail.smtp.ssl.trust","*");
+        properties.setProperty("mail.smtp.ssl.checkserveridentity","false");
+        properties.setProperty("mail.smtp.starttls.enable","true");
+        properties.setProperty("mail.smtp.starttls.required","true");
+        
+        // 核心：指定SSL协议版本（关键解决No appropriate protocol问题）
+        // 支持的协议：TLSv1.2（推荐）、TLSv1.1、TLSv1（根据邮件服务器调整）
+        javax.net.ssl.SSLContext sslContext = javax.net.ssl.SSLContext.getInstance("TLSv1.2");
+        sslContext.init(null, new TrustManager[]{new X509TrustManager() {
+            // 信任所有证书（仅测试/内网环境用，生产环境需配置可信证书）
             @Override
-            public PasswordAuthentication getPasswordAuthentication() {
-                //发件人用户名，授权码
-                return new PasswordAuthentication(emailUserName,emailAuthorization);
+            public void checkClientTrusted(X509Certificate[] chain, String authType) {}
+            @Override
+            public void checkServerTrusted(X509Certificate[] chain, String authType) {}
+            @Override
+            public X509Certificate[] getAcceptedIssuers() { return new X509Certificate[0]; }
+        }}, null);
+        SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory();
+        properties.put("mail.smtp.ssl.socketFactory", sslSocketFactory);
+        // 强制使用指定的协议版本
+        properties.put("mail.smtp.ssl.protocols", "TLSv1.2"); // 替换为TLSv1.1/TLSv1（如果服务器仅支持）
+
+        // 2. 创建会话
+        Session session = Session.getInstance(properties, new Authenticator() {
+            @Override
+            protected PasswordAuthentication getPasswordAuthentication() {
+                return new PasswordAuthentication(emailUserName, emailAuthorization);
             }
         });
-        //开启Session的debug模式，这样就可以查看程序发送Email的运行状态
+        
         session.setDebug(true);
-        //2、通过session得到transport对象
-        Transport transport = session.getTransport();
-        //3、使用用户名和授权码连上邮件服务器
-        transport.connect("smtp.qq.com",emailUserName,emailPassword);
-        //4、创建邮件：写邮件
-        //注意需要传递Session
+        
+        Transport transport = session.getTransport("smtp");
+        transport.connect("smtp.feishu.cn",465,emailUserName,emailAuthorization);
+        
         MimeMessage message = new MimeMessage(session);
-        //指明邮件的发件人
         message.setFrom(new InternetAddress(emailUserName));
-        //指明邮件的收件人，现在发件人和收件人是一样的，就是自己给自己发
         message.setRecipient(Message.RecipientType.TO , new InternetAddress(SJemailUserName));
         message.setSubject(title);
         message.setContent(msg,"text/html;charset=UTF-8");
-        //5、发送邮件
-        transport.sendMessage(message,message.getAllRecipients());
         
-        //6、关闭连接
+        transport.sendMessage(message,message.getAllRecipients());
         transport.close();
     }
 }
\ No newline at end of file