SUBMAIL赛邮短信邮件语音接口调用

package lib.base; import java.io.File; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.HttpURLConnection; import java.util.ArrayList; import java.util.List; import java.util.Map; import net.sf.json.JSONObject; import utils.HttpDeleteUtil; import utils.RequestEncoder; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.NameValuePair; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.entity.UrlEncodedFormEntity; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.methods.HttpPut; import org.apache.http.entity.ContentType; import org.apache.http.entity.StringEntity; import org.apache.http.entity.mime.MultipartEntityBuilder; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.message.BasicNameValuePair; import org.apache.http.protocol.HTTP; import org.apache.http.util.EntityUtils; import config.AppConfig; import lib.Mail; import lib.Message; /** * 这个类实现了ISender，包含了在发送之前处理发生的事件的常用方法 * 创建了一个签名并构建请求数据 * @author submail * */ public class Sender implements ISender { protected AppConfig config = null; private static final String API_TIMESTAMP = "http://api.submail.cn/service/timestamp.json"; public static final String APPID = "appid"; public static final String TIMESTAMP = "timestamp"; public static final String SIGN_TYPE = "sign_type"; public static final String SIGNATURE = "signature"; public static final String APPKEY = "appkey"; private CloseableHttpClient closeableHttpClient = null; public Sender() { closeableHttpClient = HttpClientBuilder.create().build(); } @Override public String send(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String xsend(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String subscribe(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String unsubscribe(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String multixsend(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String verify(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String log(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String get(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String post(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String put(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String delete(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String selMobiledata(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String toService(Map<String, Object> data) { // TODO Auto-generated method stub return null; } @Override public String charge(Map<String, Object> data) { // TODO Auto-generated method stub return null; } /** * 请求时间戳 * @return timestamp * */ protected String getTimestamp() { HttpGet httpget = new HttpGet(API_TIMESTAMP); HttpResponse response; try { response = closeableHttpClient.execute(httpget); HttpEntity httpEntity = response.getEntity(); String jsonStr = EntityUtils.toString(httpEntity, "UTF-8"); if (jsonStr != null) { JSONObject json = JSONObject.fromObject(jsonStr); return json.getString("timestamp"); } closeableHttpClient.close(); } catch (ClientProtocolException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; } protected String createSignature(String data) { if (AppConfig.TYPE_NORMAL.equals(config.getSignType())) { return config.getAppKey(); } else { return buildSignature(data); } } /** * 当 {@link AppConfig#setSignType(String)} 不正常时,创建 * 一个签名类型 * * @param data * 请求数据 * @return signature * */ private String buildSignature(String data) { String app = config.getAppId(); String appKey = config.getAppKey(); // order is confirmed String jointData = app + appKey + data + app + appKey; if (AppConfig.TYPE_MD5.equals(config.getSignType())) { return RequestEncoder.encode(RequestEncoder.MD5, jointData); } else if (AppConfig.TYPE_SHA1.equals(config.getSignType())) { return RequestEncoder.encode(RequestEncoder.SHA1, jointData); } return null; } /** * 请求数据 post提交 * * @param url * @param data * @return boolean * */ protected String request(String url, Map<String, Object> data) { HttpPost httppost = new HttpPost(url); httppost.addHeader("charset", "UTF-8"); httppost.setEntity(build(data)); try { HttpResponse response = closeableHttpClient.execute(httppost); HttpEntity httpEntity = response.getEntity(); if (httpEntity != null) { String jsonStr = EntityUtils.toString(httpEntity, "UTF-8"); System.out.println(jsonStr); return jsonStr; } closeableHttpClient.close(); } catch (ClientProtocolException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; } /** * 短信模板：get请求方法 * @param url * @param data * @return */ protected String getMethodRequest(String url, Map<String, Object> data) { data.put(APPID, config.getAppId()); data.put(TIMESTAMP, this.getTimestamp()); data.put(SIGNATURE, config.getAppKey()); String urlGet = url + "?"; for(Map.Entry<String, Object> entry: data.entrySet()){ String key = entry.getKey(); Object value = entry.getValue(); if(value instanceof String){ urlGet += key + "=" + String.valueOf(value) + "&"; } } urlGet = urlGet.substring(0, urlGet.length()-1); HttpGet httpGet = new HttpGet(urlGet); try{ CloseableHttpClient closeableHttpClient = HttpClientBuilder.create().build(); HttpResponse response = closeableHttpClient.execute(httpGet); HttpEntity httpEntity = response.getEntity(); if(httpEntity != null){ String jsonStr = EntityUtils.toString(httpEntity, "UTF-8"); System.out.println(jsonStr); return jsonStr; } closeableHttpClient.close(); }catch(ClientProtocolException e){ e.printStackTrace(); }catch(IOException e){ e.printStackTrace(); } return null; } /** * 短信模板：put方法 * @param url * @param data * @return */ protected String putMethodRequest(String url, Map<String, Object> data) { HttpPut httpput = new HttpPut(url); httpput.addHeader("charset", "UTF-8"); data.put(APPID, config.getAppId()); data.put(TIMESTAMP, this.getTimestamp()); data.put(SIGNATURE, config.getAppKey()); List<NameValuePair> params=new ArrayList<NameValuePair>(); for(Map.Entry<String, Object> entry: data.entrySet()){ String key = entry.getKey(); String value = (String) entry.getValue(); params.add(new BasicNameValuePair(key,value)); } try { httpput.setEntity(new UrlEncodedFormEntity(params,HTTP.UTF_8)); HttpResponse response = closeableHttpClient.execute(httpput); HttpEntity httpEntity = response.getEntity(); if (httpEntity !=