package org.yeshi.utils.mail;
|
|
import net.sf.json.JSONObject;
|
import org.yeshi.utils.HttpUtil;
|
import org.yeshi.utils.StringUtil;
|
import org.yeshi.utils.encrypt.AESUtil;
|
import org.yeshi.utils.exception.MailSendException;
|
|
import java.util.*;
|
|
/**
|
* @author hxh
|
* @title: EmailApiUtil
|
* @description: 邮件帮助
|
* @date 2022/3/15 17:04
|
*/
|
public class EmailApiUtil {
|
|
final static String AESKEY = "123bN5%M7*~a8888";
|
final static String SIGNKEY = "EmailYeshi@88889!~";
|
final static String API_SEND = "http://api.mail.yeshitv.com:8081/email/send";
|
|
|
/**
|
* @return void
|
* @author hxh
|
* @description 邮件发送接口
|
* @date 18:13 2022/3/15
|
* @param: emailInfo
|
**/
|
public static void sendEmail(EmailInfo emailInfo) throws MailSendException {
|
JSONObject accountJSON = new JSONObject();
|
accountJSON.put("toEmail", emailInfo.getToEmail());
|
accountJSON.put("fromEmail", emailInfo.getFromEmail());
|
accountJSON.put("fromEmailPwd", emailInfo.getFormEmailPwd());
|
Map<String, String> params = getBaseParams();
|
params.put("title", emailInfo.getTitle());
|
params.put("content", emailInfo.getContent());
|
params.put("app", emailInfo.getApp());
|
params.put("accountInfo", AESUtil.encrypt(accountJSON.toString(), AESKEY));
|
params.put("sign", getSign(params));
|
|
Map<String, String> headers = new HashMap<>();
|
headers.put("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
|
|
try {
|
String result = HttpUtil.post(API_SEND, params, headers);
|
if (StringUtil.isNullOrEmpty(result)) {
|
throw new Exception("内容返回为空");
|
}
|
JSONObject resultJSON = JSONObject.fromObject(result);
|
if (resultJSON.optInt("code") != 0) {
|
throw new MailSendException(MailSendException.CODE_BUSINESS_ERROR, resultJSON.optString("msg"));
|
}
|
} catch (MailSendException e) {
|
throw e;
|
} catch (Exception e) {
|
throw new MailSendException(MailSendException.CODE_NETWORK_ERROR, "接口网络出错");
|
}
|
}
|
|
private static Map<String, String> getBaseParams() {
|
Map<String, String> params = new HashMap<>();
|
params.put("timestamp", System.currentTimeMillis() + "");
|
return params;
|
}
|
|
private static String getSign(Map<String, String> params) {
|
List<String> list = new ArrayList<>();
|
for (Iterator<String> its = params.keySet().iterator(); its.hasNext(); ) {
|
String key = its.next();
|
if ("sign".equalsIgnoreCase(key))
|
continue;
|
list.add(key + "=" + params.get(key));
|
}
|
|
Collections.sort(list);
|
String str = StringUtil.concat(list, "&");
|
str += SIGNKEY;
|
String sign = StringUtil.Md5(str);
|
return sign;
|
}
|
|
// public static void main(String[] args) {
|
//
|
// //"he15901227708@163.com", "hexiaohui1011", "hexiaohui@banliapp.com", "测试", "测试内容"
|
// EmailInfo emailInfo = new EmailInfo();
|
// emailInfo.setApp("test");
|
// emailInfo.setContent("测试内容");
|
// emailInfo.setFormEmailPwd("hexiaohui1011");
|
// emailInfo.setFromEmail("he15901227708@163.com");
|
// emailInfo.setTitle("测试");
|
// emailInfo.setToEmail("hexiaohui@banliapp.com");
|
//
|
// try {
|
// EmailApiUtil.sendEmail(emailInfo);
|
// } catch (MailSendException e) {
|
// e.printStackTrace();
|
// }
|
//
|
// }
|
|
|
}
|
