package com.product.text.message.util;
|
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
import java.io.OutputStreamWriter;
|
import java.net.URL;
|
import java.net.URLConnection;
|
import java.text.SimpleDateFormat;
|
import java.util.Calendar;
|
|
import org.apache.commons.codec.binary.Base64;
|
|
import com.alibaba.fastjson.JSON;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.text.message.config.CmnConst;
|
import com.product.text.message.entity.SendReq;
|
import com.product.text.message.entity.SendRes;
|
|
/**
|
* 云MAS服务Http发送
|
* Copyright PRODUCT-BASE
|
* @Title: PRODUCT-BASE-
|
* @Project: HttpSmsSendUtil
|
* @Date: 2021年6月25日 下午5:09:59
|
* @Author: 杜洪波
|
* @Description:
|
*/
|
public class HttpSmsSendUtil {
|
|
private static String apId = "zgctjt"; //用户
|
private static String secretKey = "zgctjt2019"; //密码
|
private static String ecName = "自贡市城市建设投资开发集团有限公司"; // 集团名称
|
private static String sign = "9OOWx4mtn"; // 网关签名编码
|
private static String addSerial = ""; // 拓展码 填空
|
public static String url = "http://112.35.1.155:1992/sms/norsubmit";// 请求url
|
|
public static void sendMsg(FieldSetEntity fseMessageInfo) {
|
try {
|
SendReq sendReq = new SendReq();
|
sendReq.setApId(fseMessageInfo.getString(CmnConst.USER_ACCOUNT));
|
sendReq.setEcName(fseMessageInfo.getString(CmnConst.ECNAME));
|
sendReq.setSecretKey(fseMessageInfo.getString(CmnConst.SECRETKEY));
|
sendReq.setContent(fseMessageInfo.getString("content"));
|
sendReq.setMobiles(fseMessageInfo.getString(CmnConst.RECEIVE_USER));
|
sendReq.setAddSerial(fseMessageInfo.getString(CmnConst.ADDSERIAL));
|
sendReq.setSign(fseMessageInfo.getString(CmnConst.SIGN));
|
|
StringBuilder stringBuffer = new StringBuilder();
|
stringBuffer.append(sendReq.getEcName());
|
stringBuffer.append(sendReq.getApId());
|
stringBuffer.append(sendReq.getSecretKey());
|
stringBuffer.append(sendReq.getMobiles());
|
stringBuffer.append(sendReq.getContent());
|
stringBuffer.append(sendReq.getSign());
|
stringBuffer.append(sendReq.getAddSerial());
|
|
sendReq.setMac(Md5Util.MD5(stringBuffer.toString()).toLowerCase());
|
|
String reqText = JSON.toJSONString(sendReq);
|
|
String encode = Base64.encodeBase64String(reqText.getBytes("UTF-8"));
|
|
String resStr = sendPost(url, encode);
|
|
SendRes sendRes = JSON.parseObject(resStr, SendRes.class);
|
|
if (sendRes.isSuccess()) {
|
fseMessageInfo.setValue(CmnConst.SEND_STAT, 0);
|
} else {
|
fseMessageInfo.setValue(CmnConst.SEND_STAT, 1);
|
fseMessageInfo.setValue(CmnConst.FAILURE_REASON, sendRes.getMsgGroup());
|
}
|
} catch (IOException e) {
|
fseMessageInfo.setValue(CmnConst.SEND_STAT, 1);
|
fseMessageInfo.setValue(CmnConst.FAILURE_REASON, e.getMessage());
|
}
|
}
|
|
/**
|
* 多用户发送短信信息
|
*
|
* @param mobiles 手机号码逗号分隔
|
* @param content 短信内容
|
* @return 返回1表示成功，0表示失败
|
* @throws IOException
|
*/
|
public static int sendMsg(String mobiles, String content) throws IOException {
|
Calendar calendar = Calendar.getInstance();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String nowDatestr = sdf.format(calendar.getTimeInMillis()); //发送日期
|
content += nowDatestr; // 短信内容后跟个日期时间（可有可无），需求要求
|
|
SendReq sendReq = new SendReq();
|
sendReq.setApId(apId);
|
sendReq.setEcName(ecName);
|
sendReq.setSecretKey(secretKey);
|
sendReq.setContent(content);
|
sendReq.setMobiles(mobiles);
|
sendReq.setAddSerial(addSerial);
|
sendReq.setSign(sign);
|
|
StringBuffer stringBuffer = new StringBuffer();
|
stringBuffer.append(sendReq.getEcName());
|
stringBuffer.append(sendReq.getApId());
|
stringBuffer.append(sendReq.getSecretKey());
|
stringBuffer.append(sendReq.getMobiles());
|
stringBuffer.append(sendReq.getContent());
|
stringBuffer.append(sendReq.getSign());
|
stringBuffer.append(sendReq.getAddSerial());
|
|
sendReq.setMac(Md5Util.MD5(stringBuffer.toString()).toLowerCase());
|
|
String reqText = JSON.toJSONString(sendReq);
|
|
String encode = Base64.encodeBase64String(reqText.getBytes("UTF-8"));
|
|
String resStr = sendPost(url, encode);
|
|
SendRes sendRes = JSON.parseObject(resStr, SendRes.class);
|
|
if (sendRes.isSuccess() && !"".equals(sendRes.getMsgGroup()) && "success".equals(sendRes.getRspcod())) {
|
return 1;
|
} else {
|
return 0;
|
}
|
}
|
|
// main方法测试发送短信，返回1表示成功，0表示失败
|
public static void main(String[] args) throws IOException {
|
String msg = "这是发送短信的内容！";
|
int result = sendMsg("15182792202", msg);
|
System.out.println("===" + result);
|
if (result!=1) {
|
System.out.println("生成系统日志");
|
}else {
|
System.out.println("发送成功!");
|
}
|
}
|
|
/**
|
* 向指定 URL 发送POST方法的请求
|
*
|
* @param url 发送请求的 URL
|
* @param param 请求参数
|
* @return 所代表远程资源的响应结果
|
*/
|
private static String sendPost(String url, String param) {
|
OutputStreamWriter out = null;
|
BufferedReader in = null;
|
String result = "";
|
try {
|
URL realUrl = new URL(url);
|
URLConnection conn = realUrl.openConnection();
|
conn.setRequestProperty("accept", "*/*");
|
conn.setRequestProperty("contentType", "utf-8");
|
conn.setRequestProperty("connection", "Keep-Alive");
|
conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
|
conn.setDoOutput(true);
|
conn.setDoInput(true);
|
|
out = new OutputStreamWriter(conn.getOutputStream());
|
out.write(param);
|
out.flush();
|
|
in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
|
String line;
|
while ((line = in.readLine()) != null) {
|
result += "\n" + line;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
if (out != null) {
|
out.close();
|
}
|
if (in != null) {
|
in.close();
|
}
|
} catch (IOException ex) {
|
ex.printStackTrace();
|
}
|
}
|
return result;
|
}
|
|
}
|
