ismpspenginesoapbindingimpl.java

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

/**
 * IsmpSpEngineSoapBindingImpl.java
 *
 * This file was auto-generated from WSDL
 * by the Apache Axis 1.3 Oct 05, 2005 (05:23:37 EDT) WSDL2Java emitter.
 */

package test.ismp;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.util.Properties;

import org.apache.log4j.Logger;

import com.hbpubinfo.sp.ismp.schema.NotifyManagementInfoRsp;
import com.hbpubinfo.sp.ismp.schema.Response;

import test.jdbc.SmsDAO;
import test.link.GetLinkIdSoapProxy;



public class IsmpSpEngineSoapBindingImpl implements
		test.ismp.IsmpSpEngine
{
	/**
	 * Logger for this class
	 */
	private static final Logger logger = Logger
			.getLogger(IsmpSpEngineSoapBindingImpl.class);
	
	
	public static String tospPash = "";
	
	private static boolean flag;
	
	
	public static String tosp;
	
	String spurl = "";
	
	
	private void init()
	{
		
	}
	
	
	public com.hbpubinfo.sp.ismp.schema.Response orderRelationUpdateNotify(
			com.hbpubinfo.sp.ismp.schema.OrderRelationUpdateNotifyReq orderRelationUpdateNotifyReq)
			throws java.rmi.RemoteException
	{
		
		if (!flag)
		{
			init();
			flag = true;
		}
		
		String streamingNo = orderRelationUpdateNotifyReq.getStreamingNo();
		
		String productID = orderRelationUpdateNotifyReq.getProductID();
		
		String packageID = orderRelationUpdateNotifyReq.getPackageID();
		
		String userID = orderRelationUpdateNotifyReq.getUserID();
		
		int userIDType = orderRelationUpdateNotifyReq.getUserIDType();
		
		int OPType = orderRelationUpdateNotifyReq.getOPType();
		
		logger.info("orderRelationUpdateNotify() " + streamingNo + " " + userID
				+ " " + productID + " " + OPType);
		
		
		SmsDAO insertSMSAction = new SmsDAO();
		  //订购消息更新消息存入数据库
		insertSMSAction.orderUpdate(streamingNo, productID, packageID, userID, userIDType, OPType);
		
		
		Response res = new Response();
		res.setResultCode(0);
		res.setStreamingNo(streamingNo);
		return res;
		
	}
	
	
	public com.hbpubinfo.sp.ismp.schema.Response serviceConsumeNotify(
			com.hbpubinfo.sp.ismp.schema.ServiceConsumeNotifyReq serviceConsumeNotifyReqPara)
			throws java.rmi.RemoteException
	{
		if (!flag)
		{
			init();
			flag = true;
		}
		
		String streamingNo = serviceConsumeNotifyReqPara.getStreamingNo();
		
		String productID = serviceConsumeNotifyReqPara.getProductID();
		
		String userID = serviceConsumeNotifyReqPara.getUserID();
		
		int userIdType = serviceConsumeNotifyReqPara.getUserIDType();
		
		String linkID = serviceConsumeNotifyReqPara.getLinkID();
		
		String featureStr = serviceConsumeNotifyReqPara.getFeatureStr();
		
		logger.info("serviceConsumeNotify() " + streamingNo + " " + userID
				+ " " + productID + " " + linkID + " " + " " + featureStr);
		
		
		SmsDAO insertSMSAction = new SmsDAO();
//		执行业务通知消息
		insertSMSAction.serviceConsumeNotify(streamingNo, productID, userID, userIdType, linkID, featureStr);
		Response res = new Response();
		res.setResultCode(0);
		res.setStreamingNo(streamingNo);
		return res;
	}
	
	
	public com.hbpubinfo.sp.ismp.schema.NotifyManagementInfoRsp notifyManagementInfo(
			com.hbpubinfo.sp.ismp.schema.NotifyManagementInfoReq notifyManagementInfoReq)
			throws java.rmi.RemoteException
	{
		if (!flag)
		{
			init();
			flag = true;
		}
		
		String streamingNo = notifyManagementInfoReq.getStreamingNo();
		
		String ID = notifyManagementInfoReq.getID();
		
		int status = notifyManagementInfoReq.getStatus();
		
		int IDType = notifyManagementInfoReq.getIDType();
		
		logger.info("notifyManagementInfo() " + streamingNo + " " + IDType
				+ " " + ID + " " + status);
		/*
		 * try { GetLinkIdSoapProxy client = new GetLinkIdSoapProxy(URL1);
		 * client.seviceStatusChange(streamingNo, ID, IDType, String
		 * .valueOf(status)); } catch (Exception e) {
		 * logger.error("notifyManagementInfo(NotifyManagementInfoReq)", e); }
		 */
		
		SmsDAO insertSMSAction = new SmsDAO();
//		管理信息更新存入数据库
		insertSMSAction.notifyManagementInfo(streamingNo, ID, status, IDType);
		
		NotifyManagementInfoRsp res = new NotifyManagementInfoRsp();
		res.setResultCode(0);
		res.setStreamingNo(streamingNo);
		return res;
	}
	
}