smsnotificationbindingimpl.java

电信ISAG的服务连接和服务

/**
 * SmsNotificationBindingImpl.java
 *
 * This file was auto-generated from WSDL
 * by the Apache Axis WSDL2Java emitter.
 */

package cn.com.chinatelecom.www.wsdl.ctcc.sms.notification.v2_1.service;
import java.util.*;
import org.apache.axis.MessageContext;
import test.DecodeSoapHeader;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.NotifySOAPHeader;
import java.net.URL;
import cn.com.chinatelecom.www.wsdl.ctcc.terminal_location.v2_1.service.*;
import cn.com.chinatelecom.www.wsdl.ctcc.terminal_location.v2_1._interface.*;
import test.RouteSoapHeader;
import cn.com.chinatelecom.www.schema.ctcc.terminal_location.v2_1.LocationInfo;
import org.apache.axis.types.URI;
import java.net.*;
import cn.com.chinatelecom.www.wsdl.ctcc.sms.send.v2_1.service.SendSmsServiceLocator;
import cn.com.chinatelecom.www.wsdl.ctcc.sms.send.v2_1._interface.SendSms;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.ChargingInformation;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.SimpleReference;
import cn.com.chinatelecom.www.schema.ctcc.terminal_location.v2_1.LocationData;
import cn.com.chinatelecom.www.schema.ctcc.terminal_location.v2_1.RetrievalStatus;
import cn.com.chinatelecom.www.wsdl.ctcc.terminal_location.notification_manager.v2_2.service.TerminalLocationNotificationManagerServiceLocator;
import cn.com.chinatelecom.www.wsdl.ctcc.terminal_location.notification_manager.v2_2._interface.TerminalLocationNotificationManager;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.TimeMetric;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.TimeMetrics;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.PrintStream;
import cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.SendMessageServiceLocator;
import cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2._interface.SendMessage;
import cn.com.chinatelecom.www.schema.ctcc.multimedia_messaging.v2_2.MessagePriority;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.ServiceException;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.PolicyException;
import cn.com.chinatelecom.www.wsdl.ctcc.wap_push.send.v1_0.service.SendWapMessageServiceLocator;
import cn.com.chinatelecom.www.wsdl.ctcc.wap_push.send.v1_0._interface.SendWapMessage;
public class SmsNotificationBindingImpl
    implements cn.com.chinatelecom.www.wsdl.ctcc.sms.notification.v2_1.
    _interface.SmsNotification {
  private static java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("HH:mm:ss:SSSS");
  public static int i = 0;
  public static int colnum = 1000000;
  public static int a01 = 888;
  public static int a02 = 1920;
  public static int a03 = 2003;
  public static int a04 = 609;
  String changed [] = {"中國","澳門","謝謝","火車","飛機"};
  //{"中国","澳门","谢谢","火车","飞机"}
  public void notifySmsReception(java.lang.String registrationIdentifier,
                                 cn.com.chinatelecom.www.schema.ctcc.sms.v2_1.
                                 SmsMessage message) throws java.rmi.
      RemoteException {
    MessageContext context = MessageContext.getCurrentContext();
    DecodeSoapHeader soapHeader = new DecodeSoapHeader(context);
    NotifySOAPHeader header = soapHeader.DecodeUpSoapHeader();
    System.out.println("registrationIdentifier:" + registrationIdentifier);
    System.out.println("message.getMessage:" + message.getMessage());
    System.out.println("message.getSenderAddress:" + message.getSenderAddress());
    System.out.println("message.getSmsServiceActivationNumber:" + message.getSmsServiceActivationNumber());
    String msg = "";


    if(message.getMessage().toLowerCase().startsWith("bc"))
    {
      try{
      URL url = new URL("http://192.80.100.133:9081/WapSendMessageService");
      SendWapMessageServiceLocator locator = new SendWapMessageServiceLocator();
     // RouteSoapHeader.fileName = "D:\\cpsp\\spConfig\\downsoap_wap.properties";
      SendWapMessage service = locator.getSendWapMessage(url);
      String num0 = "12345"; //02762308185   8614101110303
      String num = message.getSenderAddress().getPath().substring(3);
      org.apache.axis.types.URI[] addresses = new org.apache.axis.types.URI[1];
      addresses[0] = new org.apache.axis.types.URI("tel:" + num);
      org.apache.axis.types.URI targetURl = new org.apache.axis.types.URI("http://10.130.1.48:8080/lottery/lottery.jsp");
      String senderAddress = "8113";
      String subject ="waptest";   // "中兴彩信测试";
      cn.com.chinatelecom.www.schema.ctcc.wap_push.v1_0.MessagePriority priority2= cn.com.chinatelecom.www.schema.ctcc.wap_push.v1_0.MessagePriority.Normal;
      ChargingInformation charging = new ChargingInformation("haha","yes", new java.math.BigDecimal("100"), num0);
      SimpleReference receiptRequest = new SimpleReference(new org.apache.axis.types.URI("tel:" + num0), "1","333");
      String res = service.sendMessage(addresses, targetURl, senderAddress, subject,priority2, charging, receiptRequest);
      System.out.println("res:" + res);
      }
        catch(Exception ex)
        {
        ex.printStackTrace();
        }
    }

         if(message.getMessage().toLowerCase().startsWith("c"))//简体转繁体
   {
     String changed [] = {"中國","澳門","謝謝","火車","飛機"};
     String num = "";
     String tonum ="";
     String temp[] = new String[2];
     int i = 0;
     if(message.getSenderAddress().getPath().startsWith("853"))
     {num = message.getSenderAddress().getPath().substring(3);}
     StringTokenizer st = new StringTokenizer(message.getMessage());
      while (st.hasMoreTokens()) {
        temp[i] = st.nextToken();
        System.out.println("temp[i]:" + temp[i]);
        i++;
      }

     if(temp[1].equals("中国"))
     {msg = changed[0] + " from" +" "+ num;}
     else  if(temp[1].equals("澳门"))
     {msg = changed[1] + " from" +" "+ num;}
     else  if(temp[1].equals("谢谢"))
     {msg = changed[2] + " from" +" "+ num;}
     else  if(temp[1].equals("火车"))
     {msg = changed[3] + " from" +" "+ num;}
     else  if(temp[1].equals("飞机"))
     {msg = changed[4] + " from" +" "+ num;}
     System.out.println("-----msg------"+msg);
     tonum = temp[0].substring(1);
     System.out.println("-----tonum------"+tonum);
     URL url = null;
     try {
       url = new URL("http://192.80.100.133:9081/SendSmsService");
       SendSmsServiceLocator locator = new SendSmsServiceLocator();
       SendSms service = locator.getSendSms(url);
       org.apache.axis.types.URI[] addresses = new org.apache.axis.types.URI[1];
       addresses[0] = new org.apache.axis.types.URI("tel:" + tonum);
       int flag = 0;
       //RouteSoapHeader.fileName = "D:\\cpsp\\spConfig\\downsoap_sms.properties";
       String senderName = "930006";//02762308185  8341
       ChargingInformation charging = new ChargingInformation("haha", "yes", new java.math.BigDecimal("100"), num);
       SimpleReference receiptRequest = null;
       receiptRequest = new SimpleReference(new org.apache.axis.types.URI("tel:"+ tonum), "1", "333");
       String reqId = service.sendSms(addresses, senderName,charging, msg, receiptRequest);
       System.out.println("reqId:" + reqId);
     }
     catch (Exception ex1) {
     }
   }



    System.out.println("...调用北向接口notifySmsReception结束...");

  }

  public void notifySmsDeliveryReceipt(java.lang.String correlator,
                                       cn.com.chinatelecom.www.schema.ctcc.sms.
                                       v2_1.DeliveryInformation deliveryStatus) throws
      java.rmi.RemoteException {
    System.out.println("==开始调用北向接口notifySmsDeliveryReceipt==");
    System.out.println("状态通知:correlator==" + correlator);
    System.out.println("状态通知:deliveryStatus.getAddress==" +
                       deliveryStatus.getAddress());
    System.out.println("状态通知:deliveryStatus.getDeliveryStatus==" +
                       deliveryStatus.getDeliveryStatus());
    System.out.println("调用北向接口notifySmsDeliveryReceipt结束");
  }

}