notifysms.java

中国电信isag短信部分源码和ismp部分源码

/**
 * 
 */
package test.sms;

import org.apache.log4j.Logger;

import test.ismp.IsmpSpEngineSoapBindingImpl;
import test.jdbc.SmsDAO;
import test.send.SendMessageEntity;


import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.NotifySOAPHeader;
import cn.com.chinatelecom.www.schema.ctcc.sms.v2_1.DeliveryInformation;
import cn.com.chinatelecom.www.schema.ctcc.sms.v2_1.DeliveryStatus;
import cn.com.chinatelecom.www.schema.ctcc.sms.v2_1.SmsMessage;

//import com.personplat.service.PersonSpecialService;
/**
 * @author wangqijun
 * 
 */
public class NotifySMS
{

	/**
	 * 
	 */
	
	public NotifySMS()
	{
		// TODO 自动生成构造函数存根
	}

	/**
	 * @param registrationIdentifier
	 *            消息标识
	 * @param message
	 *            消息对象
	 * @param header
	 *            消息头
	 * @throws Exception 
	 * 
	 * 
	 */
	//private PersonSpecialService	personSpecialService;
	
	public void notifySmsReception(String registrationIdentifier,
			SmsMessage message, NotifySOAPHeader header) 
	{
		
		System.out.println("registrationIdentifier:" + registrationIdentifier);
		System.out.println("message.getMessage:------." + message.getMessage());
		
		
		//返回上行消息
	    String notifMessage = message.getMessage();
	   
	    String senderAddress = String.valueOf(message.getSenderAddress());
	    
	    header.getLinkId();
	    header.getProductId();
	    header.getSpId();
	    header.getSpRevpassword();
        
	  
	    
	    String strs[]=senderAddress.split(":");
		String address = strs[1].substring(5,13);
		
		
		address = "tel:027"+address;
		System.out.println("address:------." + address);
		
		 
	    SMSTest sMSTest = new SMSTest();
	    SendMessageEntity sengMessageEntity = new SendMessageEntity();
	    sengMessageEntity.setAddresse(address);
		sengMessageEntity.setCharging(address);
		sengMessageEntity.setFeecode("100");
		sengMessageEntity.setLinkId(header.getLinkId());
		sengMessageEntity.setMessage("nihao");
		sengMessageEntity.setProductId("118100247010000000057");
		sengMessageEntity.setSAN("0");
		sengMessageEntity.setSenderAddress("9421");
		sengMessageEntity.setSmsURL("http://58.53.194.143:9081/SendSmsService");
		sengMessageEntity.setSpId(header.getSpId());
		sengMessageEntity.setSpPassword("12345678");
		
		sMSTest.sendSMS(sengMessageEntity);
		
	
	    
	    
	    SmsDAO insertSMSAction = new SmsDAO();
	    // //将接收到的短信内容插入数据库
	    insertSMSAction.insertNotifySms(notifMessage, senderAddress, header.getLinkId(), header.getProductId(), header.getSpId(), header.getSpRevpassword());
	    
	    
	  
	  
		System.out.println("message.getSenderAddress:"+ message.getSenderAddress());
		System.out.println("message.getSmsServiceActivationNumber:"+ message.getSmsServiceActivationNumber());
		
		System.out.println("...调用北向接口notifySmsReception结束...");

	}

	/**
	 * @param correlator
	 *            状态报告标识
	 * @param deliveryStatus
	 *            报告对象
	 * @param header
	 *            消息头
	 */
	public void notifySmsDeliveryReceipt(String correlator,
			DeliveryInformation deliveryStatus, NotifySOAPHeader header)
	{
		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结束");
		
		 SmsDAO insertSMSAction = new SmsDAO();
		 
		 DeliveryStatus deliveryStatus1 = deliveryStatus.getDeliveryStatus();
		 deliveryStatus1.getValue();
		  //发送短信返回的状态报告存入数据库
		 insertSMSAction.insertDelivery(correlator,String.valueOf(deliveryStatus.getAddress()), deliveryStatus1.getValue());
		 
		
	}



}