--add sendMarketMessage();add sendMarket();

src/main/java/com/ekexiu/portal/mobile/MobilePhoneService.java

@@ -16,6 +16,7 @@ import org.jfw.apt.annotation.Bean;
import org.jfw.util.ConstData;
import org.jfw.util.DateUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
@@ -26,6 +27,7 @@ public class MobilePhoneService {
	private String accountSid = "a9e818c5ffb547c6a1db15ce45381ab0";
	private String authToken = "d34f7d9bccd74d67abe8a62263a73fda";
	private String restUrl = "https://api.miaodiyun.com/20150822/industrySMS/sendSMS";
	private String marketUrl = "https://api.miaodiyun.com/20150822/affMarkSMS/sendSMS";
	private int sendTimeout = 10 * 1000;
	private int readTimeout = 10 * 1000;
@@ -53,6 +55,14 @@ public class MobilePhoneService {
		this.restUrl = restUrl;
	}
	public String getMarketUrl() {
		return marketUrl;
	}
	public void setMarketUrl(String marketUrl) {
		this.marketUrl = marketUrl;
	}
	public String getAccountSid() {
		return accountSid;
	}
@@ -88,6 +98,26 @@ public class MobilePhoneService {
		InputStream inStream = conn.getInputStream();
		return IoUtil.readStream(inStream, true);
	}
	
	private byte[] sendMarket(String content) throws IOException {
		URL url = new URL(this.marketUrl);
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		conn.setRequestMethod("POST");// 提交模式
		conn.setRequestProperty("Content-type", "application/x-www-form-urlencoded");
		conn.setConnectTimeout(this.sendTimeout);// 连接超时 单位毫秒
		conn.setReadTimeout(this.readTimeout);// 读取超时 单位毫秒
		conn.setDoOutput(true);// 是否输入参数
		byte[] bypes = content.getBytes(ConstData.UTF8);
		OutputStream out = conn.getOutputStream();
		try {
			out.write(bypes);
			out.flush();
		} finally {
			out.close();
		}
		InputStream inStream = conn.getInputStream();
		return IoUtil.readStream(inStream, true);
	}
	private MobilePhoneResult parse(byte[] bytes) {
		return JsonService.fromJson(new InputStreamReader(new ByteArrayInputStream(bytes), ConstData.UTF8), MobilePhoneResult.class);
@@ -109,10 +139,31 @@ public class MobilePhoneService {
		}
	}
	
	public void sendMarketMessage(String to, String contentTemplate) throws Exception {
		String dateStr = DateUtil.formatDateTime(System.currentTimeMillis());
		StringBuilder sb = new StringBuilder();
		sb.append("accountSid=").append(this.accountSid).append("&smsContent=").append(URLEncoder.encode(contentTemplate, "UTF-8")).append("&to=").append(to)
				.append("&timestamp=").append(dateStr).append("&sig=");
		String md5 = StringUtil.md5(this.accountSid + this.authToken + dateStr).toLowerCase(Locale.US);
		sb.append(md5);
		MobilePhoneResult mpr = this.parse(this.sendMarket(sb.toString()));
		if (!MobilePhoneResult.SUCCESS.equals(mpr.getRespCode())) {
			String reason = errorReason.get(mpr.getRespCode());
			if(reason==null) reason="未知错误，请联系技术客服。";
			throw new Exception(mpr.getRespCode()+"-"+reason);
		}
	}
	
	
	public static void main(String[] args) throws Exception{
		MobilePhoneService mps = new MobilePhoneService();
		mps.sendMessage("18601149468","【科袖科技】请输入验证码yzm，完成手机绑定。请于1分钟内正确输入验证码。如非本人操作，请忽略本短信。科袖科技","yzm","122234");
		try {
			mps.sendMarketMessage("13525007261", "【科袖】您收到了一个新的咨询，快去查看吧。http://a.app.qq.com/o/simple.jsp?pkgname=com.ekexiu.app退订回N");
			System.out.println("send success!");
		} catch (Exception e) {
			throw new JfwBaseException("send error!");
		}
		//mps.sendMessage("18601149468","【科袖科技】请输入验证码yzm，完成手机绑定。请于1分钟内正确输入验证码。如非本人操作，请忽略本短信。科袖科技","yzm","122234");
	}
	static {