package org.springblade.common.utils;

import liquibase.repackaged.org.apache.commons.lang3.text.StrSubstitutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;

public class SmsUtils {

	private static Logger logger = LoggerFactory.getLogger(SmsUtils.class);

	public static String buildRequestXMLString(String id, String pwd, String serviceid, String phone, String content) {
		StringBuffer sb = new StringBuffer();

		sb.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>")
			.append("<svc_init ver=\"2.0.0\">")
			.append("<sms ver=\"2.0.0\">")
			.append("<client>")
			.append("<id>").append(id).append("</id>")
			.append("<pwd>").append(pwd).append("</pwd>")
			.append("<serviceid>").append(serviceid).append("</serviceid>")
			.append("</client>")
			.append("<sms_info>")
			.append("<phone>").append(phone).append("</phone>")
			.append("<content>").append(content).append("</content>")
			.append("</sms_info>")
			.append("</sms>")
			.append(" </svc_init>");

		logger.info("buildRequestXMLString:" + sb.toString());
		return sb.toString();
	}

	public static String postXMLSendSMSRequest(String servletUrl, String content) {
		String result = null;

		BufferedReader br = null;
		OutputStreamWriter out = null;
		HttpURLConnection con = null;

		try {
			URL url = new URL(servletUrl);

			con = (HttpURLConnection) url.openConnection();
			con.setDoOutput(true);
			con.setRequestMethod("POST");

			out = new OutputStreamWriter(con.getOutputStream(), "UTF-8");

			out.write(content);

			out.flush();

			br = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));

			String line = null;

			StringBuilder sb = new StringBuilder();

			while ((line = br.readLine()) != null) {
				sb.append(line);
			}

			result = sb.toString();

			System.out.println(result);
			logger.info("postXMLSendSMSRequest:" + result);
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (br != null) {
				try {
					br.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}

			if (out != null) {
				try {
					out.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}

			if (con != null) {
				con.disconnect();
				con = null;
			}
		}

		return result;
	}


	public static void send(String phone, Map<String, String> content) {

		StrSubstitutor strSubstitutor = new StrSubstitutor(content);
		String url3 = "【上饶基层自治】您正在验证投票操作，验证码：${code}。如非本人操作，则密码可能已泄露，建议立即修改密码或联系客服。";
		String context3 = strSubstitutor.replace(url3);
		String MAS_ID = "182";
		String PASSWORD = "bYcLgYwXOZspDzEnaGsNHAGUykKEiexknHY9H98xVTQ8Zbeya8bexQ==";
		String reqXML = buildRequestXMLString(MAS_ID, PASSWORD, "", phone, context3);
		postXMLSendSMSRequest("http://218.204.110.232:8080/emc/HttpSendSMSService", reqXML);
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		//下面的MAS_ID、PASSWORD仅供测试使用，正式使用由移动公司分配
		String MAS_ID = "182";
		String PASSWORD = "bYcLgYwXOZspDzEnaGsNHAGUykKEiexknHY9H98xVTQ8Zbeya8bexQ==";
		String reqXML = buildRequestXMLString(MAS_ID, PASSWORD, "", "18720768376", "测试短信");
		postXMLSendSMSRequest("http://218.204.110.232:8080/emc/HttpSendSMSService", reqXML);
	}
}