package smsbao.internal;
|
|
import java.io.BufferedReader;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.io.OutputStreamWriter;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.net.URLEncoder;
|
import java.security.MessageDigest;
|
import java.security.NoSuchAlgorithmException;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import project.log.SysLogService;
|
import project.syspara.SysparaService;
|
import smsbao.sender.SmsMessage;
|
|
public class InternalSmsSenderServiceImpl implements InternalSmsSenderService {
|
private Logger logger = LoggerFactory.getLogger(InternalSmsSenderServiceImpl.class);
|
private SysparaService sysparaService;
|
|
private SysLogService sysLogService;
|
|
@Override
|
public void send(SmsMessage smsMessage) {
|
|
/**
|
* 发送的短信接口类型 tiantian---天天---smsSendService--->>>>--
|
* moduyun---摩杜云---smsSingleSender
|
*/
|
String send_code_type = this.sysparaService.find("send_code_type").getValue();
|
logger.info("开始发送短信参数："+smsMessage.getMobile()+"----"+smsMessage.getContent());
|
if ("tiantian".equals(send_code_type)) {
|
// 用户名
|
String user = sysparaService.find("smsbao_u").getValue();
|
|
// 密码：
|
String pwd = sysparaService.find("smsbao_p").getValue();
|
|
String dest = "";
|
String ip = "";
|
if (smsMessage.getInter()) {
|
|
ip = "210.51.190.232";
|
int port = 8085;
|
HttpClientUtil util = new HttpClientUtil(ip, port, "/mt/MT3.ashx");
|
String ServiceID = "SEND";
|
// 目的号码
|
dest = smsMessage.getMobile();
|
// 原号码
|
String sender = "";
|
|
// 短信内容
|
String msg = smsMessage.getContent();
|
|
// UTF-16BE
|
String hex = WebNetEncode.encodeHexStr(0, msg);
|
hex = hex.trim() + "&codec=0";
|
// util.sendPostMessage(user, pwd, ServiceID, dest, sender, hex);
|
logger.info("tiantian--" + smsMessage.getMobile() + ",短信内容：" + smsMessage.getContent() + "--验证码发送返回信息 = "
|
+ util.sendPostMessage(user, pwd, ServiceID, dest, sender, hex));
|
// System.out.println("验证码发送返回信息 = " + util.sendPostMessage( user, pwd, ServiceID, dest, sender, hex));
|
|
} else {
|
ip = "210.51.190.233";
|
int port = 8085;
|
HttpClientUtil util = new HttpClientUtil(ip, port, "/mt/MT3.ashx");
|
String ServiceID = "SEND";
|
// 目的号码
|
dest = smsMessage.getMobile();
|
// 原号码
|
String sender = "";
|
|
// 短信内容
|
String msg = smsMessage.getContent();
|
|
// UTF-16BE
|
String hex = WebNetEncode.encodeHexStr(8, msg);
|
hex = hex.trim() + "&codec=8";
|
|
// util.sendPostMessage(user, pwd, ServiceID, dest, sender, hex);
|
logger.info("tiantian--" + smsMessage.getMobile() + ",短信内容：" + smsMessage.getContent() + "--验证码发送返回信息 = "
|
+ util.sendPostMessage(user, pwd, ServiceID, dest, sender, hex));
|
// System.out.println("验证码发送返回信息 = " + util.sendPostMessage( user, pwd, ServiceID, dest, sender, hex));
|
|
}
|
|
// if (!"0".equals(result)) {
|
// SysLog sysLog = new SysLog();
|
// sysLog.setLevel(SysLog.level_error);
|
// sysLog.setCreateTime(new Date());
|
// sysLog.setLog("");
|
//
|
// sysLogService.saveAsyn(sysLog);
|
//
|
// }
|
|
} else if ("smsbao".equals(send_code_type)) {
|
|
String username = sysparaService.find("smsbao_u").getValue(); // 在短信宝注册的用户名
|
String password = sysparaService.find("smsbao_p").getValue(); // 在短信宝注册的密码
|
String httpUrl = null;
|
if (smsMessage.getInter()) {
|
// 国际
|
httpUrl = "http://api.smsbao.com/wsms";
|
// 国际
|
// httpUrl = "http://iauhnbqszxl.site";
|
|
} else {
|
httpUrl = "http://api.smsbao.com/sms";
|
// httpUrl = "http://xahsdfg.site";
|
}
|
|
StringBuffer httpArg = new StringBuffer();
|
httpArg.append("u=").append(username).append("&");
|
httpArg.append("p=").append(md5(password)).append("&");
|
|
if (smsMessage.getInter()) {
|
// 国际
|
httpArg.append("m=").append(encodeUrlString("+", "UTF-8") + smsMessage.getMobile()).append("&");
|
} else {
|
httpArg.append("m=").append(smsMessage.getMobile().substring(2, smsMessage.getMobile().length()))
|
.append("&");
|
}
|
httpArg.append("c=").append(encodeUrlString(smsMessage.getContent(), "UTF-8"));
|
|
String result = request(httpUrl, httpArg.toString());
|
|
if (!"0".equals(result)) {
|
logger.info("Smsbao--" + smsMessage.getMobile() + ",短信内容：" + smsMessage.getContent() + "--验证码发送失败 ");
|
|
} else {
|
logger.info("Smsbao--" + smsMessage.getMobile() + ",短信内容：" + smsMessage.getContent() + "--验证码发送成功 ");
|
}
|
|
}else if ("smsgj".equals(send_code_type)) {
|
logger.info("开始发送短信【国际】："+smsMessage.getMobile()+"----"+smsMessage.getContent());
|
String urlString = "http://190.92.241.43:9090/sms/batch/v2";
|
String appKey = "EKUPl0";
|
String appSecret = "m4O6gU";
|
String appcode = "1000";
|
String phone = smsMessage.getMobile();
|
String message = smsMessage.getContent();
|
|
try {
|
String response = sendPostRequest(urlString, appKey, appSecret, phone, message, appcode);
|
logger.info("发送短信返回状态："+response);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
|
public static String sendPostRequest(String urlString, String appKey, String appSecret, String phone, String message, String appcode) throws Exception {
|
URL url = new URL(urlString);
|
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
|
// 设置请求方法为POST
|
connection.setRequestMethod("POST");
|
connection.setDoOutput(true);
|
|
// 构造请求参数
|
StringBuilder postData = new StringBuilder();
|
postData.append("appkey=").append(URLEncoder.encode(appKey, "UTF-8"));
|
postData.append("&appsecret=").append(URLEncoder.encode(appSecret, "UTF-8"));
|
postData.append("&phone=").append(URLEncoder.encode(phone, "UTF-8"));
|
postData.append("&msg=").append(URLEncoder.encode(message, "UTF-8"));
|
postData.append("&appcode=").append(URLEncoder.encode(appcode, "UTF-8"));
|
|
// 发送请求
|
try (OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream())) {
|
writer.write(postData.toString());
|
writer.flush();
|
}
|
|
// 读取响应
|
StringBuilder response = new StringBuilder();
|
try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()))) {
|
String line;
|
while ((line = reader.readLine()) != null) {
|
response.append(line);
|
}
|
}
|
|
return response.toString();
|
}
|
|
public static String request(String httpUrl, String httpArg) {
|
BufferedReader reader = null;
|
String result = null;
|
StringBuffer sbf = new StringBuffer();
|
httpUrl = httpUrl + "?" + httpArg;
|
|
try {
|
URL url = new URL(httpUrl);
|
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
connection.setRequestMethod("GET");
|
connection.connect();
|
InputStream is = connection.getInputStream();
|
reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
|
String strRead = reader.readLine();
|
if (strRead != null) {
|
sbf.append(strRead);
|
while ((strRead = reader.readLine()) != null) {
|
sbf.append("\n");
|
sbf.append(strRead);
|
}
|
}
|
reader.close();
|
result = sbf.toString();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return result;
|
}
|
|
public static String md5(String plainText) {
|
StringBuffer buf = null;
|
try {
|
MessageDigest md = MessageDigest.getInstance("MD5");
|
md.update(plainText.getBytes());
|
byte b[] = md.digest();
|
int i;
|
buf = new StringBuffer("");
|
for (int offset = 0; offset < b.length; offset++) {
|
i = b[offset];
|
if (i < 0)
|
i += 256;
|
if (i < 16)
|
buf.append("0");
|
buf.append(Integer.toHexString(i));
|
}
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
}
|
return buf.toString();
|
}
|
|
public static String encodeUrlString(String str, String charset) {
|
String strret = null;
|
if (str == null)
|
return str;
|
try {
|
strret = java.net.URLEncoder.encode(str, charset);
|
} catch (Exception e) {
|
e.printStackTrace();
|
return null;
|
}
|
return strret;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setSysLogService(SysLogService sysLogService) {
|
this.sysLogService = sysLogService;
|
}
|
|
}
|
