package getReq;

import javax.xml.soap.SOAPException;

public class GetREQ {

    private javax.xml.soap.SOAPConnection _connection;
    private static String _url = "http://xxx.xx.xx.xx:xxxx/IXXXEServiceDirectoryService.asmx";
    private static String _inFilePath = "d:/exp/in/";
    private static String _outFilePath = "d:/exp/out/";
    private static String[] _inFileMsg = {
                                    "GetHBNamespaces",
                                    "GetHBList",
                                    "GetHBValuesByDate_rngFStruct",
                                };
    private static String[] _inSoapAction = {
                                        "http://xx.xxx.ru/..../GetHBNamespaces",
                                        "http://xx.xxx.ru/.../GetHBList",
                                        "http://xx.xxx.ru/.../GetHBValuesByDate",                                        
                                    };
    private StringBuffer preMsg;

    public static void main(String[] args) throws SOAPException {
        GetREQ client = new GetREQ();
        int im=_inFileMsg.length;
        for(int i=0;i<im;i++) {
            client.run(i);
        }
    }

    public void run(int indFile) throws SOAPException
    {
        writelog("===BEGIN===" );
        try {
            javax.xml.soap.SOAPConnectionFactory scf = javax.xml.soap.SOAPConnectionFactory.newInstance();
            _connection = scf.createConnection();
            writelog( callExecute(indFile) );
            _connection.close();
        } catch ( Exception e ) {
            writelog( e.getMessage() );
        }
        writelog( "===END===" );
    }

    public void writelog(String s){
        System.out.println( s );
    }

    private String callExecute(int indFile)
        throws javax.xml.soap.SOAPException, java.io.IOException
    {
        StringBuffer result = new StringBuffer();
        java.io.OutputStream os = null;
        javax.xml.soap.SOAPMessage message = null;
        try {
            // Затем создаем сообщение
            javax.xml.soap.MessageFactory messageFactory = javax.xml.soap.MessageFactory.newInstance();
            message = messageFactory.createMessage();
            // Создаем объекты, представляющие различные компоненты сообщения
            javax.xml.soap.SOAPPart soapPart = message.getSOAPPart();
            javax.xml.soap.SOAPEnvelope envelope = soapPart.getEnvelope();
            javax.xml.soap.SOAPBody body = envelope.getBody();
            // Формирование сообщения
            javax.xml.transform.stream.StreamSource preppedMsgSrc = new javax.xml.transform.stream.StreamSource( new java.io.FileInputStream( _inFilePath+_inFileMsg[indFile]+".msg" ) );
            soapPart.setContent( preppedMsgSrc );
            message.saveChanges();
            // synchronous request/response style
            javax.xml.soap.SOAPMessage response = null;
            message.getMimeHeaders().addHeader( "SOAPAction", _inSoapAction[indFile] );
            response = c.call( message, _url );
            result.append( "Successful request.\r\n" );
            result.append( "SOAP request:\r\n" );
            os = new java.io.ByteArrayOutputStream();
            message.writeTo( os );
            result.append( os.toString() );
            result.append( "\r\n" );
            result.append( "SOAP response:\r\n" );
            if (response != null) {
                response.writeTo(new java.io.FileOutputStream(_outFilePath+_inFileMsg[indFile]+".xml"));
                os = new java.io.ByteArrayOutputStream();
                response.writeTo( os );
                result.append( os.toString() );
                result.append( "\r\n" );                
            }
        } catch ( Throwable t ) {
            result.append( "Failed request.\r\n" );
            os = new java.io.ByteArrayOutputStream();
            message.writeTo( os );
            result.append( os.toString() );
            result.append( "\r\n" );
        }
        return result.toString();
    }    
}