package com.gear.common.utils.email;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;

public class SendEmailUtils {
    public static boolean sendEmial(Emailer sender,Emailer[] to,String title,String content){
        String key  = "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";
        try {
            // 创建URL对象
            URL url = new URL("https://api.brevo.com/v3/smtp/email");

            // 打开连接，并将URLConnection转换为HttpURLConnection
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();

            // 设置请求方法为POST
            connection.setRequestMethod("POST");

            // 设置请求头参数
            connection.setRequestProperty("Content-Type", "application/json");
            connection.setRequestProperty("accept", "application/json");
            connection.setRequestProperty("api-key", key);

            // 启用输出流，以便向服务器发送数据
            connection.setDoOutput(true);
            JSONObject param = new JSONObject();
            param.put("sender",sender);
            param.put("to",to);
            param.put("subject",title);
            param.put("htmlContent",content);
            System.out.println("params:"+ param.toString());

            // 将JSON数据写入请求体
            try (DataOutputStream wr = new DataOutputStream(connection.getOutputStream())) {
                byte[] input = param.toString().getBytes("utf-8");
                wr.write(input, 0, input.length);
            }
            // 发送请求
            int responseCode = connection.getResponseCode();
            System.out.println("Response Code: " + responseCode);

            if (responseCode == HttpURLConnection.HTTP_CREATED || responseCode == HttpURLConnection.HTTP_OK) {
                // 读取响应
                BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
                String line;
                StringBuffer response = new StringBuffer();
                while ((line = reader.readLine()) != null) {
                    response.append(line);
                }
                reader.close();
                // 打印响应内容
                System.out.println("Response: " + response.toString());
                return true;
            } else {
                // 错误处理或其他逻辑
                System.out.println("Error: " + responseCode);
            }
            // 关闭连接
            connection.disconnect();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return false;
    }
}