Add Mobile Thirdparty Heper

GabonTelMobicashMobileAppHelper/.checkstyle

@@ -0,0 +1,3 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<fileset-config file-format-version="1.2.0" simple-config="false" sync-formatter="false"/>

GabonTelMobicashMobileAppHelper/pom.xml

@@ -7,6 +7,8 @@
 		<artifactId>common-libs</artifactId>
 		<version>1.0.0</version>
 	</parent>
+	
+	
 
 
 	<groupId>GabonTelMobicashMobileAppHelper</groupId>
@@ -63,6 +65,13 @@
 			<artifactId>resteasy-client</artifactId>
 			<scope>provided</scope>
 		</dependency>
+		
+		<dependency>
+			<groupId>com.psi.ussd</groupId>
+			<artifactId>ussd-interfaces</artifactId>
+			<scope>provided</scope>
+			<version>1.0.1</version>
+		</dependency>
 
 
 

GabonTelMobicashMobileAppHelper/src/com/psi/gabontel/mobileapp/thirdparty/helper/JsonResponse.java

@@ -0,0 +1,28 @@
+package com.psi.gabontel.mobileapp.thirdparty.helper;
+
+import org.json.simple.JSONObject;
+
+public class JsonResponse {
+	
+	public int code = 99;
+	public String message ="System is busy";
+	
+	public JsonResponse(int code,String message) {
+		this.code = code;
+		this.message= message;
+	}
+	
+	public String toString() {
+		
+		
+		JSONObject obj = new JSONObject();
+		
+		obj.put("Code", code);
+		obj.put("Message",message);
+		
+		return obj.toJSONString();
+	}
+	
+	
+	
+}

GabonTelMobicashMobileAppHelper/src/com/psi/gabontel/mobileapp/thirdparty/helper/MobileAppThirdPartyHelper.java

@@ -0,0 +1,110 @@
+package com.psi.gabontel.mobileapp.thirdparty.helper;
+
+import java.util.Arrays;
+import java.util.Hashtable;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+
+import javax.ejb.EJB;
+import javax.ejb.Remote;
+import javax.ejb.Stateless;
+import javax.lang.model.element.ModuleElement.UsesDirective;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+
+import org.jboss.logging.Logger;
+
+import com.psi.applicationmanager.AppManagerFunction;
+import com.psi.applicationmanager.AppMessage;
+import com.psi.common.db.DataRow;
+import com.psi.common.db.DataRowCollection;
+import com.psi.common.db.DbWrapper;
+import com.psi.common.transactions.Message;
+import com.psi.common.transactions.MessageId;
+import com.psi.common.transactions.Messanger;
+import com.psi.gabontel.mobileapp.helper.GetMobileAppExternalData;
+import com.psi.ussd.interfaces.UssdReceiverFunction;
+
+@Stateless
+@Remote(AppManagerFunction.class)
+public class MobileAppThirdPartyHelper  implements AppManagerFunction {
+	private static final Logger log = Logger.getLogger(MobileAppThirdPartyHelper.class);
+	private static Hashtable<String,String> ussdgwmenuejb = new Hashtable<String,String>();
+	
+	static {
+		
+		DbWrapper db = new DbWrapper("java:jboss/datasources/UssdDbClient");
+		DbWrapper.setInstance(db);
+		
+		// LOAD EJB
+		
+		DataRowCollection rows = db.QueryDataRows("SELECT PARAMNAME,EJBNAME FROM TBLUSSDGWMENUEJB WHERE STATUS = 1");
+		Iterator iterator = rows.iterator();
+		
+		while(iterator.hasNext()) {
+			DataRow row = (DataRow) iterator.next();
+			
+			String paramname = row.getString("PARAMNAME");
+			String ejbname = row.getString("EJBNAME");
+			
+			ussdgwmenuejb.put(paramname, ejbname);
+		
+		}
+		
+	}
+	
+
+
+	@Override
+	public String processTransaction(String refid, String msisdn, String message, Map<String, String> syntax) {
+		return manageTransaction(refid, msisdn, message, syntax).getMessage();
+	}
+	
+	@Override
+	public AppMessage manageTransaction(String refid, String msisdn, String message, Map<String, String> syntax) {
+		// TODO Auto-generated method stub
+		
+		try {
+		String method  =  syntax.get("method");
+	
+		
+		UssdReceiverFunction clazz = null;
+		
+		
+		if(ussdgwmenuejb.containsKey(method)) {
+			
+			Object obj = InitialContext.doLookup(ussdgwmenuejb.get(method));
+			clazz  = (UssdReceiverFunction)obj;
+			
+			String[] paramarr = syntax.get("param").split("\\|");
+			List<String> listarr = Arrays.asList(paramarr);
+			
+			//SPECIAL CASE
+			if(method.equals("postpaidinvoices")){
+				
+				String arisreturn = clazz.requestFunc(listarr);
+				
+			    obj = InitialContext.doLookup(ussdgwmenuejb.get("displayinvoices"));
+				clazz  = (UssdReceiverFunction)obj;
+				
+				listarr =  Arrays.asList(arisreturn);
+				clazz.requestFunc(listarr);
+				
+				return new Message(0,0,new JsonResponse(0,clazz.requestFunc(listarr)).toString());
+					
+			}
+			
+			return new Message(0,0,new JsonResponse(0,clazz.requestFunc(listarr)).toString());
+			
+		}else {
+			return new Message(99,0,new JsonResponse(99,"System is busy").toString());
+		}
+		
+		}catch(Exception e) {
+			log.error("Error: Refid:"+refid+"|" ,e);
+		}
+		return new Message(99,0,new JsonResponse(99,"System is busy").toString());
+		
+	}
+}