rmstest.java

实现不同服务器上的ｅｊｂ通信的程序

package com.rms.inte;

import java.io.File;
import java.io.IOException;
import java.rmi.RemoteException;
import java.util.List;

import javax.ejb.CreateException;
import javax.naming.NamingException;

import org.apache.xmlbeans.XmlException;

import oss.rms.share.bss.crm.business.CrmInterfaceSvrBoEJB;
import oss.rms.share.bss.crm.business.CrmInterfaceSvrBoEJBHome;
import oss.rms.share.bss.sps.business.AutoAsgnPubBoEJB;
import oss.rms.share.bss.sps.business.AutoAsgnPubBoEJBHome;
import oss.rms.share.bss.sps.business.SpsInterfaceSvrBoEJBHome;
import pub.AppJndiFactory;
//import pub.AppJndiFactory;

import com.cattsoft.xmlbeans.res.SoSyncRequestDocument;

public class RMSTest {

	/**
	 * @param args
	 */
	private  String url ="http://127.0.0.1:8080/RMSInte/services/RMSInte";
	public static void main(String[] args) throws XmlException, IOException, CreateException, NamingException {
		// TODO Auto-generated method stub
		
		
		//服务开通的测试
		/*String xmlHeader = "<HeaderInfoType>"+
		  "<EventType>ASYN</EventType>"+
		  "<Action/>"+
		  "<_EID>RES_SO_SYNC_SERV_REQ</_EID>"+
		  "<SerialNo>381</SerialNo>"+
		  "<UserId>admin</UserId>"+
		  "<Password>qazwsxedc</Password>"+
		  "<Sender>"+
		    "<Application>SPS</Application>"+
		  "</Sender>"+
		"</HeaderInfoType>";
		
		File file = new File("d:\\434012008031X000346.xml");
		SoSyncRequestDocument soDoc = SoSyncRequestDocument.Factory.parse(file);
		
		System.out.println(soDoc.toString());
		svcCallRMBySps( "soSyncRequest", "a2", soDoc.toString() );
		
		
		
		System.out.println("操你妈的结束了！");*/
		
		String s = "<CrmTORm>"+
		"<areaInfo>"+
		"<localNetId>43101</localNetId>"+
		"<areaId>431</areaId>"+
		"<workAreaId>431010001</workAreaId>"+
		"<staffId>1</staffId>"+
		"</areaInfo>"+
		"<pimInfo>"+
		"<pSNbr/>"+
		"<iCCId>89869600743121000023</iCCId>"+
		"<opt>R</opt>"+
		"</pimInfo>"+
	"</CrmTORm>"; 



	svcCallRMByCRM("distillPsNbrByIccId",null,s);
		
		/*########################*/
//		tstCrm();
		
	
		
//		tstCrm();
	}
	
	public static void tstCrm() throws RemoteException, CreateException, NamingException{
		
		
		System.out.println("客户端开始获取");
		try{
		CrmInterfaceSvrBoEJBHome home =(CrmInterfaceSvrBoEJBHome) AppJndiFactory.getInstance().getLocalHome(
				"oss.rms.share.bss.crm.business.CrmInterfaceSvrBo");
												
				 
		CrmInterfaceSvrBoEJB ejb = home.create();
		}catch(RuntimeException ex){
			System.out.println("获取ejb出错！");
			throw ex;
			
		}

		System.out.println("获取到资源的ejb客户端");
		
//		Sps home1 = (SpsInterfaceSvrEjbHome) AppJndiFactory.getInstance().getLocalHome("oss.rms.share.bss.sps.business.SpsInterfaceSvrBo");
		
		//LogHome.getLog().info(remote);
		//LogHome.getLog().info("获取到资源的ejb客户端");
		
		
		
	}
	
	
	 public static void svcCallRMBySps(java.lang.String funCode, java.lang.String xmlHeader, java.lang.String xmlString) {
		 RMSInte inte = new RMSInteProxy("http://133.193.14.14:9761/RMSInte/services/RMSInte");
		 try {
			 
			String str = inte.svcCallRMBySps(funCode, xmlHeader, xmlString);
			System.out.println(str);
		} catch (RemoteException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	 }
	 
	/* 
	 public static void svcCallRMBySps1(java.lang.String funCode, java.lang.String xmlHeader, String xmlString){
		 SpsInterfaceSvrBoEJBHome home = appJndiFactory.
	 }*/
	  public static void svcCallRMByCRM(java.lang.String autoChooseDn, java.lang.String xmlHeader, java.lang.String xmlString){
		  RMSInte inte = new RMSInteProxy("http://133.193.14.14:9761/RMSInte/services/RMSInte");
		  try {
			String str = inte.svcCallRMByCRM(autoChooseDn, xmlHeader, xmlString);
			System.out.println(str);
		} catch (RemoteException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		  
	  }

}