mysyncorderexample.java

中国移动 provision MISC1.6 接口

package net.smsfan.provision.example;

import java.io.*;
import cmd.db.*;
import sms.sendmt.*;

import net.smsfan.provision.*;

/**
 * 正向同步接口演示代码<br>
 * 1.初始化正向同步类SyncOrderRelation<br>
 * 2.实现 SyncOrderRelationReqListener 接口的onSyncOrderRelationReq方法即可接收到正向请求的xml数据<br>
 * 
 * @author Joy Liu ([e-mail])
 * @version 1.0
 */
public class MySyncOrderExample implements SyncOrderRelationReqListener {

	public MySyncOrderExample(int port, String serviceName) throws IOException {
		// port:打开的HTTP服务的端口号，serviceName:服务名称
		// 初始化成功后，misc网关访问URL:http://serverip:port/serviceName 即可提交正向同步数据
		
		SyncOrderRelation syncOrder = new SyncOrderRelation(port, serviceName);
		syncOrder.addListener("syncOrder", this);
	}

	/**
	 * 接收misc网关提交正向同步数据,进行处理,本函数只实现简单的屏幕输出<br>
	 * 注意: xml中的FeatureStr是通过Base64编码的,SyncOrderRelation类中提供decodeBase64方法进行解码<br>
	 * 
	 * @param xml
	 *            String
	 */
	public void onSyncOrderRelationReq(String xml) {
		String sPseudoCode = "";
		String sMSISDN1 = "";
		String sMSISDN2 = "";
		String sSPID = "";
		String sSPServiceID = "";
		String sAccessMode = "";
		String sFeatureStr = "";
		String sMTMSG;
		// SMSSubmitInf mt = new SMSSubmitInf();
		// System.out.println("Receive One SyncOrderRelation Request:");
		System.out.println("网关正向同步定购接口");
		AddProvision add = new AddProvision();
		// SMSCode smsCode = new SMSCode();
		UserDBAdd userDBAdd = new UserDBAdd();
		// System.out.println(xml);
		String sXML = xml;
		System.out.println("接收的信息：：" + sXML + "::::信息结尾");
		System.out.println(sXML.indexOf("<PseudoCode>"));
		System.out.println(sXML.indexOf("</PseudoCode>"));
		sPseudoCode = sXML.substring(sXML.indexOf("<PseudoCode>")
				+ "<PseudoCode>".length(), sXML.indexOf("</PseudoCode>"));
		sMSISDN1 = sXML.substring(sXML.indexOf("<MSISDN>")
				+ "<MSISDN>".length(), sXML.indexOf("</MSISDN>"));
		sMSISDN2 = sXML.substring(sXML.indexOf("<MSISDN>")
				+ "<MSISDN>".length(), sXML.indexOf("</MSISDN>"));
		sSPID = sXML.substring(sXML.indexOf("<SPID>") + "<SPID>".length(), sXML
				.indexOf("</SPID>"));
		sSPServiceID = sXML.substring(sXML.indexOf("<SPServiceID>")
				+ "<SPServiceID>".length(), sXML.indexOf("</SPServiceID>"));
		sAccessMode = sXML.substring(sXML.indexOf("<AccessMode>")
				+ "<AccessMode>".length(), sXML.indexOf("</AccessMode>"));
		sFeatureStr = sXML.substring(sXML.indexOf("<FeatureStr>")
				+ "<FeatureStr>".length(), sXML.indexOf("</FeatureStr>"));

		System.out.println(sPseudoCode);
		System.out.println(sMSISDN1);
		System.out.println(sMSISDN2);
		System.out.println(sSPID);
		System.out.println(sSPServiceID);
		System.out.println(sAccessMode);
		System.out.println(sFeatureStr);
		System.out.println(add.InsertProvision(sPseudoCode, sMSISDN1, sMSISDN2,
				sSPID, sSPServiceID, sAccessMode, sFeatureStr));
		String ReInterface = "ERR";
		if (sFeatureStr != null && !sFeatureStr.equals("")) {
			userDBAdd.AddUserToDB(sMSISDN1.trim(), sMSISDN2.trim(),sSPServiceID.trim());

		} else {
			userDBAdd.DelUserInDB(sMSISDN1.trim(), sMSISDN2.trim());

		}
		System.out.println("--------------------------------------");
	}

	/*
	 * public void onSyncOrderRelationReq(String xml) { String sPseudoCode="";
	 * String sMSISDN1=""; String sMSISDN2=""; String sSPID=""; String
	 * sSPServiceID=""; String sAccessMode=""; String sFeatureStr=""; String
	 * sMTMSG; System.out.println("网关正向同步定购接口"); AddProvision add = new
	 * AddProvision(); //SMSCode smsCode = new SMSCode(); UserDBAdd userDBAdd =
	 * new UserDBAdd(); System.out.println("Receive One SyncOrderRelation
	 * Request:"); System.out.println(xml);
	 * System.out.println("--------------------------------------"); }
	 */
	public static void main(String[] args) {
		System.out.println(".............................");
		if (args == null || args.length != 2) {
			System.out.println("Please input Server Port and Service Name");
			System.exit(0);
		}

		String port = args[0];
		if (port == null) {
			System.out.println("Please input Server Port");
			System.exit(0);
		}

		String serviceName = args[1];
		if (serviceName == null) {
			System.out.println("Please input Service Name");
			System.exit(0);
		}

		try {
			int p = Integer.parseInt(port);
			new SyncOrderExample(p, serviceName);
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}
}