ismp_webservice.java

中国电信ISMP管理平台SMS订购关系同步接口

package com.wireless.sms.ismp;

import java.sql.Timestamp;

import com.wireless.sms.ismp.global.CommonData;
import com.wireless.sms.ismp.global.LoggerConstant;
import com.wireless.sms.pub.entity.MO;


/**
 * <p>Title:ISMP webservice</p>
 * <p>Description: 电信ISMP平台订购关系同步接口服务端</p>
 * <p>Copyright: Copyright (c) 2007</p>
 * <p>Company: entel</p>
 * @author MAZY
 * @version 1.0
 */
public class ISMP_webservice implements javax.xml.rpc.server.ServiceLifecycle {
	
	public void init(Object context) {
//		System.out.println("init Going...");
//		javax.xml.rpc.server.ServletEndpointContext servletEndpointContext = 
//			(javax.xml.rpc.server.ServletEndpointContext)context;
//		
//		javax.servlet.ServletContext servletContext = servletEndpointContext.getServletContext();
//		java.util.Enumeration en = 
//		String log4j = 	
//		servletContext
//		.getInitParameter("className");
//		.getInitParameterNames();
//		while(en!=null && en.hasMoreElements()){
//			Object el = en.nextElement();
//			System.out.println(log4j);
//		}
	}
	/**
	 * Axis服务端
	 * @param srcDeviceType 源设备类型,由ISMP填写 int
	 * @param srcDeviceId	源设备标识,由ISMP填写 String
	 * @param destDeviceType目的设备类型,由ISMP填写 int
	 * @param destDeviceId	目的设备标识,由ISMP填写 String
	 * @param userIdType	1.MSISDN 2.PsedoCode 默认为1 int
	 * @param userId		用户小灵通号码 String
	 * @param spId			SP在ISMP系统中的标识,SP在创建SP帐户时由ISMP分配 String
	 * @param packageID		套餐ID,创建套餐时由ISMP分配 String
	 * @param productId		产品ID,创建产品时由ISMP分配 String
	 * @param updateType	1.订购 2.取消订购 更新操作类型 int
	 * @param updateTime	更新时间 String
	 * @param updateDesc	更新描述 String
	 * @return				0.成功 1.失败 int
	 * @throws java.rmi.RemoteException
	 */
	public int orderRelationUpdateNotify(int srcDeviceType,
			java.lang.String srcDeviceId, int destDeviceType,
			java.lang.String destDeviceId, int userIdType,
			java.lang.String userId, java.lang.String spId,
			java.lang.String packageID, java.lang.String productId,
			int updateType, java.lang.String updateTime,
			java.lang.String updateDesc) throws java.rmi.RemoteException {
		
		LoggerConstant.mo_log.info("---this is a mo orderRelationUpdateNotify---");
		LoggerConstant.mo_log.info("srcDeviceType = " + srcDeviceType);
		LoggerConstant.mo_log.info("srcDeviceId = " + srcDeviceId);
		LoggerConstant.mo_log.info("destDeviceType = " + destDeviceType);
		LoggerConstant.mo_log.info("destDeviceId = " + destDeviceId);
		LoggerConstant.mo_log.info("userIdType = " + userIdType);
		LoggerConstant.mo_log.info("userId = " + userId);
		LoggerConstant.mo_log.info("spId = " + spId);
		LoggerConstant.mo_log.info("packageID = " + packageID);
		LoggerConstant.mo_log.info("productId = " + productId);
		LoggerConstant.mo_log.info("updateType = " + updateType);
		LoggerConstant.mo_log.info("updateTime = " + updateTime);
		LoggerConstant.mo_log.info("updateDesc = " + updateDesc);
		/////////////
		MO mo = new MO();
		
		//mo.setMsgContent(message);
		String temp = (String) CommonData.getKeyMap().get(productId);
    	if(temp!=null){
    		String[] tmpCommands = temp.split(":");
    		switch (updateType) {
    		case 0:
    			mo.setMsgContent(tmpCommands[0]); //定购指令
    			break;
    		case 1:
    			mo.setMsgContent(tmpCommands[2]); //退订
    			break;
    		}
    	} else {
    		mo.setMsgContent("productId = " + productId);
    		LoggerConstant.mo_log.info("没有找到相关指令,productId = " + productId);
    	}
		
		mo.setSrcTermID(userId.startsWith("86")?userId.substring(2):userId);
		
		mo.setDestTermID(destDeviceId);
		
		mo.setLinkID("");
		mo.setRemark5("");
		
		Timestamp time = new Timestamp(System.currentTimeMillis());
        mo.setRemark1(time.toLocaleString());
        mo.setGatewayID(InitHandler.GATEWAYID);
        mo.setMsgLen(String.valueOf(mo.getMsgContent().getBytes().length));
        writeMO(mo);
		InitHandler.MOQUEUE.add(mo);
		///////////////
		return 0;
	}
	
	private void writeMO(MO mo){
		LoggerConstant.mo_log.info("---Struct MO Object---");
		LoggerConstant.mo_log.info("DestTermID = " + mo.getDestTermID());
		LoggerConstant.mo_log.info("SrcTermID  = " + mo.getSrcTermID());
		LoggerConstant.mo_log.info("LinkID     = " + mo.getLinkID());
		LoggerConstant.mo_log.info("MsgContent = " + mo.getMsgContent());
		LoggerConstant.mo_log.info("---Struct MO Object over---");
	}
	
	public void destroy() {
//		System.out.println("run destroy...");
//		SMSSender.getInstance().stopSendMT();
//	    SmsGWIFGlobal.sendMonitor("I000011");
//	    ReloadProcess.getInstance().stopInterface();
//	    System.out.println("destory over!");
	}
}