smsnotificationbindingimpl.java

湖北电信ＳＯＡ平台短信发送实例

/**
 * 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 test.sms.NotifySMS;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.NotifySOAPHeader;
import java.net.URL;

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;




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结束"); }
	 */
	
	
	
	/*接受上行
	 * @see cn.com.chinatelecom.www.wsdl.ctcc.sms.notification.v2_1._interface.SmsNotification#notifySmsReception(java.lang.String, cn.com.chinatelecom.www.schema.ctcc.sms.v2_1.SmsMessage)
	 */
	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();
		NotifySMS sms=new NotifySMS();
		sms.notifySmsReception(registrationIdentifier, message, header);
	}

	/* 接受状态报告
	 * @see cn.com.chinatelecom.www.wsdl.ctcc.sms.notification.v2_1._interface.SmsNotification#notifySmsDeliveryReceipt(java.lang.String, cn.com.chinatelecom.www.schema.ctcc.sms.v2_1.DeliveryInformation)
	 */
	public void notifySmsDeliveryReceipt(
			java.lang.String correlator,
			cn.com.chinatelecom.www.schema.ctcc.sms.v2_1.DeliveryInformation deliveryStatus)
			throws java.rmi.RemoteException {
		MessageContext context = MessageContext.getCurrentContext();
		DecodeSoapHeader soapHeader = new DecodeSoapHeader(context);
		NotifySOAPHeader header = soapHeader.DecodeUpSoapHeader();
		NotifySMS sms=new NotifySMS();
		sms.notifySmsDeliveryReceipt(correlator, deliveryStatus, header);
	}

}