soap

package net.cnki.common.validator;

import com.fasterxml.jackson.databind.ObjectMapper;
import net.cnki.bean.ClientMsg;
import net.cnki.common.util.RSAUtil;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
import org.xml.sax.SAXException;

import javax.xml.soap.*;
import java.io.*;
import java.math.BigInteger;
import java.net.URL;
import java.net.URLConnection;
import java.nio.charset.Charset;
import java.security.PublicKey;
import java.security.interfaces.RSAPublicKey;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

public class TestSmsCodeSender {
    static int socketTimeout = 30000;// 请求超时时间
    static int connectTimeout = 30000;// 传输超时时间
    static StringBuilder value=new StringBuilder();
    public static void main(String[] args) throws SOAPException ,Exception{
        String rsa = getRsa();
        System.out.println("osdijaskdlfjasdf==========="+rsa);
        ObjectMapper om = new ObjectMapper();
        String afterSer = om.writeValueAsString(new ClientMsg());
        RSAUtil rsaUtil=new RSAUtil();
        byte[] data=rsaUtil.encrypt(afterSer.getBytes(),rsa);
        // smsCode
        String originXml = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" +
                "<soap12:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap12=\"http://www.w3.org/2003/05/soap-envelope\">\n" +
                "  <soap12:Body>\n" +
                "    <SendSms xmlns=\"http://tempuri.org/\">\n" +
                "      <rsaClientMsg>"+data+"</rsaClientMsg>\n" +
                "    </SendSms>\n" +
                "  </soap12:Body>\n" +
                "</soap12:Envelope>";

        //byte[] data1=rsaUtil.decrypt(data);
     //   String str=new String(data,"UTF-8");
      //  System.out.println("--------------"+str);

        String rsaXml = originXml.replace("needSendMsg",new String(data));
        System.out.println("====the after xml is:"+rsaXml);
        String Smsurl = "http://192.168.25.115:8096/SMSService.asmx?op=SendSms";
        String SmsSOAPAction = "http://tempuri.org/SendSms";
       doPostSoap1_2(Smsurl,rsaXml,SmsSOAPAction);

    }




// getrsa
    public static String getRsa() throws SOAPException{
        String xml = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" +
                "<soap12:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap12=\"http://www.w3.org/2003/05/soap-envelope\">\n" +
                "  <soap12:Body>\n" +
                "    <GetRsaPublicKey xmlns=\"http://tempuri.org/\" />\n" +
                "  </soap12:Body>\n" +
                "</soap12:Envelope>";
        String url = "http://192.168.25.115:8096/SMSService.asmx?op=GetRsaPublicKey";
        String SOAPAction = "http://tempuri.org/GetRsaPublicKey";
        String retStr = doPostSoap1_2(url,xml,SOAPAction);
        SOAPMessage msg = formatSoapString(retStr);
        SOAPBody body = msg.getSOAPBody();
        Iterator<SOAPElement> iterator = body.getChildElements();
        String rsa = PrintBody(iterator, null);
        System.out.println("the rsa is:"+rsa);
        String result = StringUtils.substringBetween(rsa,"<Modulus>","</Modulus>");
        System.out.println("after between:    "+result);
        //加密后的字符串
        String afterLow = result.toLowerCase() + "@check.cnki";
        String encodeStr=DigestUtils.md5Hex(afterLow.substring(7,15));

        return rsa;

    }
    // 发送soap
    public static String doPostSoap1_2(String postUrl, String soapXml,
          String soapAction) {
          String retStr = "";
          // 创建HttpClientBuilder
          HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
          // HttpClient
          CloseableHttpClient closeableHttpClient = httpClientBuilder.build();
          HttpPost httpPost = new HttpPost(postUrl);
          // 设置请求和传输超时时间
          RequestConfig requestConfig = RequestConfig.custom()
           .setSocketTimeout(socketTimeout)
           .setConnectTimeout(connectTimeout).build();
          httpPost.setConfig(requestConfig);
          try {
                httpPost.setHeader("Content-Type",
                                  "application/soap+xml;charset=UTF-8");
                httpPost.setHeader("SOAPAction", soapAction);
                StringEntity data = new StringEntity(soapXml,
                                 Charset.forName("UTF-8"));
                httpPost.setEntity(data);
                CloseableHttpResponse response = closeableHttpClient.execute(httpPost);
                HttpEntity httpEntity = response.getEntity();
                if (httpEntity != null) {
                        // 打印响应内容
                        retStr = EntityUtils.toString(httpEntity, "UTF-8");
                        System.out.println("response:" + retStr);
                }

            //  Md5("12345678.ToLower() + "@check.cnki", "md5").Substring(7, 15)

              // 释放资源
                closeableHttpClient.close();
            } catch (Exception e) {
                 System.out.println("exception in doPostSoap1_2"+ e);
            }
        return retStr;
    }

    private static SOAPMessage formatSoapString(String soapString) {
        MessageFactory msgFactory;
        try {
            msgFactory = MessageFactory.newInstance(SOAPConstants.SOAP_1_2_PROTOCOL);
            SOAPMessage reqMsg = msgFactory.createMessage(new MimeHeaders(),
                    new ByteArrayInputStream(soapString.getBytes("UTF-8")));
            reqMsg.saveChanges();
            return reqMsg;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    private static String PrintBody(Iterator<SOAPElement> iterator, String side) {

        while (iterator.hasNext()) {
            SOAPElement element = (SOAPElement) iterator.next();
            System.out.println("Local Name:" + element.getLocalName());
            System.out.println("Node Name:" + element.getNodeName());
            System.out.println("Tag Name:" + element.getTagName());
            System.out.println("Value:" + element.getValue());
            if(StringUtils.equals(element.getNodeName(),"GetRsaPublicKeyResult")){
                value.append(element.getValue());
            }
            if (null == element.getValue()
                    && element.getChildElements().hasNext()) {
                PrintBody(element.getChildElements(), side + "-----");
            }

        }
        return value.toString();
    }



}