Skip to content

P
Phyzii
Commit 81305f5c authored by Ketan Patil's avatar Ketan Patil
Browse files
Options

Update src/ibase/webitm/ejb/phyzii/PhyziiCommentApiSch.java,... 

Update src/ibase/webitm/ejb/phyzii/PhyziiCommentApiSch.java, src/ibase/webitm/ejb/phyzii/PhyziiPaymentPushApiSch.java, src/ibase/webitm/ejb/phyzii/PhyziiPullApiSch.java, src/ibase/webitm/ejb/phyzii/PhyziiPushApiSch.java, src/ibase/webitm/ejb/phyzii/PhyziiPushApiSch2.java, src/ibase/webitm/ejb/phyzii/PhyziiPosSave.java, src/ibase/webitm/ejb/phyzii/PhyziiIC.java, src/ibase/webitm/ejb/phyzii/PhyziiPosSaveRemote.java, src/ibase/webitm/ejb/phyzii/PhyziiPosSaveLocal.java, src/ibase/webitm/ejb/phyzii/PhyziiICRemote.java, src/ibase/webitm/ejb/phyzii/PhyziiICLocal.java files
parent 8443a777
Hide whitespace changes
Inline Side-by-side
Showing with 6279 additions and 0 deletions
src/ibase/webitm/ejb/phyzii/PhyziiCommentApiSch.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Authenticator;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.PasswordAuthentication;
import java.net.Proxy;
import java.net.URL;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;
import java.util.TimeZone;
import javax.lang.model.element.Element;
import javax.naming.InitialContext;
import org.json.JSONArray;
import org.json.JSONObject;
import org.w3c.dom.Document;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.AppConnectParm;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.utility.GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.MasterStatefulLocal;
import ibase.webitm.ejb.Messages;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.fin.FinCommon;
import java.net.URL;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.HashMap;
import java.util.Iterator;
import org.json.JSONObject;
//import ibase.planner.utility.ITMException;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.fin.FinCommon;
public class PhyziiCommentApiSch extends ValidatorEJB implements Schedule {
@Override
public String schedulePriority(String wrkflwPriority) throws Exception {
System.out.println("schedulePriority..1");
return "";
}
public String schedule(HashMap map) throws Exception {
System.out.println("schedulePriority..2");
return "";
}
public String schedule(String scheduleParamXML) throws ITMException, Exception {
String flag = "PWC";
String reultString = "";
try {
System.out.println("schedulePriority..3");
reultString = update(scheduleParamXML, flag);
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return reultString;
}
public String update(String scheduleParamXML, String flag) throws BaseException, Exception
{
System.out.println("inside method ===>");
ibase.utility.UserInfoBean userInfo = null;
Connection conn = null;
ResultSet rs = null;
PreparedStatement pstmt = null,pstmt1=null;
String selectQuery = "";
String sql="";
String cont = "";
int cnt=0;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
userInfo = new UserInfoBean(scheduleParamXML);
String transDB = userInfo.getTransDB();
String loginCode = userInfo.getLoginCode();
System.out.println(
"get TransDB & login code connection in updateStatus : " + transDB + "::loginCode::" + loginCode);
if (transDB != null && transDB.trim().length() > 0) { conn =
connDriver.getConnectDB(transDB); }
else { conn = connDriver.getConnectDB("DriverITM");
}
if (conn == null) { conn = connDriver.getConnectDB("DriverITM"); } connDriver
= null; conn.setAutoCommit(false);
FinCommon disCom1 = new FinCommon();
String fizzSkApiName = disCom1.getFinparams("999999", "FIZZ_SK_API_NAME_PAY", conn);
String fizzSkApiKey = disCom1.getFinparams("999999", "FIZZ_SK_API_KEY_PAY", conn);
String fizzSkApiCtype = disCom1.getFinparams("999999", "FIZZ_SK_API_CTYPE", conn);
String fizzSkApiComment = disCom1.getFinparams("999999", "FIZZ_SK_API_PUSH_COMMENT", conn);
String fizzSkApiIp = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_IP", conn);
String fizzSkProxyPort = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PORT", conn);
final String fizzSkProxyUname = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_UNAME", conn);
final String fizzSkProxyPass = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PASS", conn);
/*
* conn = connDriver.getConnectDB("DriverITM"); conn.setAutoCommit(false);
*/
userInfo = new ibase.utility.UserInfoBean();
selectQuery = "select EXPENSE_UNIQUE_ID,VOUCH_NO, DDF_GET_COMMENTS('M-VOUC',VOUCH_NO) as COMMENT from Phyzii_metis_track_hdr where error_flag in ('P') GROUP BY EXPENSE_UNIQUE_ID,VOUCH_NO HAVING FN_GET_COMMENTS_CNT (VOUCH_NO) > 0";
pstmt = conn.prepareStatement(selectQuery);
//pstmt.setString(1, "P");
//pstmt.setString(2, "Y");
rs = pstmt.executeQuery();
System.out.println("rs===>"+rs);
while (rs.next())
{
System.out.println("IN WHILE");
String expenseUniqueId = checkNull(rs.getString("EXPENSE_UNIQUE_ID"));
System.out.println("uniqueid==> "+expenseUniqueId);
String tranIdVoucher= checkNull(rs.getString("VOUCH_NO"));
String comment= checkNull(rs.getString("COMMENT"));
System.out.println("VOUCH_NOnew=vijay====> "+tranIdVoucher);
System.out.println("VOUCH_NOnew=vijay====> "+comment);
if(comment.trim().length() > 0) {
String query="";
query="[{ " +
" \"EXPENSE_UNIQUE_ID\": \""+expenseUniqueId+"\", " +
" \"DOCNO\": \""+tranIdVoucher+"\", " +
" \"COMMENT\": \""+comment+"\" }]";
System.out.println("Retrival json::"+query);
//String urlStr=fizzSkApiPuSH;
URL url = new URL(fizzSkApiComment);
System.out.println("@S@ url using %20["+url+"]");
System.out.println("Start iteration of response==>" + new java.sql.Timestamp(System.currentTimeMillis()));
int proxyPortInt = 0;
if (!fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = Integer.parseInt(fizzSkProxyPort);
}
if (fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = 8080;
}
Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(fizzSkApiIp, proxyPortInt));
HttpURLConnection conn7 = (HttpURLConnection) url.openConnection(proxy);
System.out.println("Test++");
Authenticator authenticator = new Authenticator() {
public PasswordAuthentication getPasswordAuthentication() {
return (new PasswordAuthentication(fizzSkProxyUname, fizzSkProxyPass.toCharArray()));
}
};
Authenticator.setDefault(authenticator);
System.out.println("Verify++");
conn7.setDoOutput(true);
conn7.setRequestMethod("POST");
conn7.setUseCaches(false);
conn7.setRequestProperty(fizzSkApiName.trim(), fizzSkApiKey.trim());
conn7.setRequestProperty("Content-Type", fizzSkApiCtype.trim());
try {
conn7.connect();
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
System.out.println("After Try & catch");
try
{
System.out.println("In OutputStream block");
OutputStream os = conn7.getOutputStream();
os.write(query.getBytes());
os.flush();
System.out.println("After OutputStream flush");
}
catch (Exception e)
{
System.out.println( "Exception - "+ e.getMessage() );
e.printStackTrace();
}
System.out.println( "URL: "+ url );
System.out.println( "ResponseCode: "+ conn7.getResponseCode() );
System.out.println( "ResponseMessage Ketan: "+ conn7.getResponseMessage() );
if(conn7.getResponseCode()==200) {
System.out.println("IN KETTTTTAN");
String sql1 = "update PHYZII_METIS_TRACK_HDR set comment_flag='Y' where EXPENSE_UNIQUE_ID=? and vouch_no=?";
System.out.println("==>inside SQL" + sql1);
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, expenseUniqueId);
pstmt1.setString(2, tranIdVoucher);
cnt = pstmt1.executeUpdate();
if (cnt > 0) {
conn.commit();
System.out.println("misc voucher inserted successfully" + sql);
}else {
System.out.println("No Update");
}
if (pstmt1 != null) {
if (!pstmt1.isClosed()) {
pstmt1.close();
}
pstmt1 = null;
}
}
}
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
}
catch (Exception e)
{
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return "";
}
private String checkNull(String input) {
if (input == null) {
input = "";
}
return input.trim();
}
}
src/ibase/webitm/ejb/phyzii/PhyziiIC.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.system.config.ConnDriver;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.fin.FinCommon;
import ibase.webitm.utility.ITMException;
public class PhyziiIC extends ValidatorEJB implements PhyziiICLocal, PhyziiICRemote
{
E12GenericUtility genericUtility = new E12GenericUtility();
public String wfValData(String currFrmXmlStr, String hdrFrmXmlStr,String allFrmXmlStr, String objContext, String editFlag,String xtraParams) throws RemoteException
{
System.out.println("In PriSecSalesConsolidationIC wfValData");
Document currDom = null;
Document hdrDom = null;
Document allDom = null;
String errString = "";
try
{
System.out.println("currFrmXmlStr..." + currFrmXmlStr);
System.out.println("hdrFrmXmlStr..." + hdrFrmXmlStr);
System.out.println("allFrmXmlStr..." + allFrmXmlStr);
if ((currFrmXmlStr != null) && (currFrmXmlStr.trim().length() != 0))
{
currDom = parseString(currFrmXmlStr);
}
if ((hdrFrmXmlStr != null) && (hdrFrmXmlStr.trim().length() != 0))
{
hdrDom = parseString(hdrFrmXmlStr);
}
if ((allFrmXmlStr != null) && (allFrmXmlStr.trim().length() != 0))
{
allDom = parseString(allFrmXmlStr);
}
errString = wfValData(currDom, hdrDom, allDom, objContext, editFlag, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception : [PriSecSalesConsolidationIC][wfValData(String currFrmXmlStr)] : ==>\n" + e.getMessage());
}
return errString;
}
public String wfValData(Document currDom, Document hdrDom, Document allDom,String objContext, String editFlag, String xtraParams)throws RemoteException, ITMException
{
E12GenericUtility genericUtility= new E12GenericUtility();
String errString = "" , loginSiteCode = "" , userId ="" , isPrdClosed = "",overWrite="" ;
String childNodeName = "";
String sql = "";
int noOfChilds = 0;
ResultSet rs = null;
Connection conn = null;
PreparedStatement pstmt = null;
int currentFormNo = 0;
int cnt = 0,count=0,unConfCnt=0,excnt=0;
ConnDriver connDriver = null;
Node childNode = null;
String empCode="" , prdCode = "" ,maxPrdCode="" ,countryCode="", accPeriod="" ,versionId="",prdCodeFrm="",prdCodeTo="";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try {
System.out.println("************xtraParams*************" + xtraParams);
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
System.out.println("In wfValData PriSecSalesConsolidationIC :::");
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
loginSiteCode = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode"));
System.out.println("**************loginCode************" + userId);
if ((objContext != null) && (objContext.trim().length() > 0))
{
currentFormNo = Integer.parseInt(objContext);
}
NodeList parentList = currDom.getElementsByTagName("Detail"+ currentFormNo);
NodeList childList = null;
System.out.println("hdrDom..." + hdrDom.toString());
switch (currentFormNo)
{
case 1:
{
childList = parentList.item(0).getChildNodes();
noOfChilds = childList.getLength();
for (int ctr = 0; ctr < noOfChilds; ctr++)
{
childNode = childList.item(ctr);
if (childNode.getNodeType() != 1)
{
continue;
}
childNodeName = childNode.getNodeName();
System.out.println("Editflag =" + editFlag);
System.out.println("parentList = " + parentList);
System.out.println("childList = " + childList);
if ("emp_no".equalsIgnoreCase(childNodeName))
{
empCode = genericUtility.getColumnValue("emp_no", currDom);
System.out.println("wfValData>>itemSer>>"+empCode);
if(empCode == null || empCode.trim().length()==0 )
{
errString = itmDBAccessEJB.getErrorString("emp_no","VMNULLEMP",userId);
break;
}
else
{
sql = "SELECT COUNT(*) AS COUNT FROM EMPLOYEE WHERE EMP_CODE = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empCode);
rs = pstmt.executeQuery();
if (rs.next())
{
count = rs.getInt("COUNT");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("Count: " + count);
if (count == 0)
{
errString = itmDBAccessEJB.getErrorString("emp_no","VTINVEMP",userId);
break;
}
}
}
}
}
break;
}
}
catch (Exception e)
{
System.out.println("Exception in "+this.getClass().getSimpleName()+" == >");
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if ((conn != null) && (!conn.isClosed()))
conn.close();
}
catch (Exception e)
{
System.out.println("Exception :"+this.getClass().getSimpleName()+":wfValData :==>\n" + e.getMessage());
throw new ITMException(e);
}
}
return errString;
}
private String checkNull(String str)
{
if(str == null)
{
return "";
}
else
{
return str ;
}
}
}
src/ibase/webitm/ejb/phyzii/PhyziiICLocal.java 0 → 100644
View file @ 81305f5c
/********************************************************
Title : AdjIssueICLocal[D16ASUN021]
Date : 29/04/16
Developer: Chandrashekar
********************************************************/
package ibase.webitm.ejb.phizzy;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ValidatorLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface PhyziiICLocal extends ValidatorLocal
{
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException, ITMException;
public String wfValData(Document dom, Document dom1,Document dom2, String objCotext, String editFlag, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
src/ibase/webitm/ejb/phyzii/PhyziiICRemote.java 0 → 100644
View file @ 81305f5c
/********************************************************
Title : AdjIssueICRemote[D16ASUN021]
Date : 29/04/16
Developer: Chandrashekar
********************************************************/
package ibase.webitm.ejb.phizzy;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote; // added for ejb3
import ibase.webitm.ejb.ValidatorRemote;// added for ejb3
@Remote // added for ejb3
public interface PhyziiICRemote extends ValidatorRemote
{
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException, ITMException;
public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
src/ibase/webitm/ejb/phyzii/PhyziiPaymentPushApiSch.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Authenticator;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.PasswordAuthentication;
import java.net.Proxy;
import java.net.URL;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;
import java.util.TimeZone;
import javax.lang.model.element.Element;
import javax.naming.InitialContext;
import org.json.JSONArray;
import org.json.JSONObject;
import org.w3c.dom.Document;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.AppConnectParm;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.utility.GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.MasterStatefulLocal;
import ibase.webitm.ejb.Messages;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.fin.FinCommon;
import java.net.URL;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.HashMap;
import java.util.Iterator;
import org.json.JSONObject;
//import ibase.planner.utility.ITMException;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.fin.FinCommon;
public class PhyziiPaymentPushApiSch extends ValidatorEJB implements Schedule {
@Override
public String schedulePriority(String wrkflwPriority) throws Exception {
System.out.println("schedulePriority..1");
return "";
}
public String schedule(HashMap map) throws Exception {
System.out.println("schedulePriority..2");
return "";
}
public String schedule(String scheduleParamXML) throws ITMException, Exception {
String flag = "PWC";
String reultString = "";
try {
System.out.println("schedulePriority..3");
reultString = update(scheduleParamXML, flag);
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return reultString;
}
public String update(String scheduleParamXML, String flag) throws BaseException, Exception
{
System.out.println("inside method ===>");
ibase.utility.UserInfoBean userInfo = null;
Connection conn = null;
ResultSet rs = null;
PreparedStatement pstmt = null,pstmt1=null;
String selectQuery = "";
String sql="";
String cont = "";
int cnt=0;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
userInfo = new UserInfoBean(scheduleParamXML);
String transDB = userInfo.getTransDB();
String loginCode = userInfo.getLoginCode();
System.out.println(
"get TransDB & login code connection in updateStatus : " + transDB + "::loginCode::" + loginCode);
if (transDB != null && transDB.trim().length() > 0) { conn =
connDriver.getConnectDB(transDB); }
else { conn = connDriver.getConnectDB("DriverITM");
}
if (conn == null) { conn = connDriver.getConnectDB("DriverITM"); } connDriver
= null; conn.setAutoCommit(false);
FinCommon disCom1 = new FinCommon();
String fizzSkApiName = disCom1.getFinparams("999999", "FIZZ_SK_API_NAME_PAY", conn);
String fizzSkApiKey = disCom1.getFinparams("999999", "FIZZ_SK_API_KEY_PAY", conn);
String fizzSkApiCtype = disCom1.getFinparams("999999", "FIZZ_SK_API_CTYPE", conn);
String fizzSkApiPush = disCom1.getFinparams("999999", "FIZZ_SK_API_PUSH_PAY", conn);
String fizzSkApiIp = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_IP", conn);
String fizzSkProxyPort = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PORT", conn);
final String fizzSkProxyUname = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_UNAME", conn);
final String fizzSkProxyPass = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PASS", conn);
/*
* conn = connDriver.getConnectDB("DriverITM"); conn.setAutoCommit(false);
*/
userInfo = new ibase.utility.UserInfoBean();
selectQuery = "SELECT VOUCH_NO,DDF_GET_PAYDET(VOUCH_NO,'T') as PAY_NO,DDF_GET_PAYDET(VOUCH_NO,'D') as PAY_DATE,DDF_GET_PAYDET(VOUCH_NO,'A') as PAY_AMT FROM PHYZII_METIS_TRACK_HDR WHERE ERROR_FLAG ='P' AND VOUCH_no is not null and (pay_flag !='Y' or vouch_flag is null)";
pstmt = conn.prepareStatement(selectQuery);
//pstmt.setString(1, "P");
//pstmt.setString(2, "Y");
rs = pstmt.executeQuery();
System.out.println("rs===>"+rs);
while (rs.next())
{
System.out.println("IN WHILE");
String expenseUniqueId = checkNull(rs.getString("EXPENSE_UNIQUE_ID"));
System.out.println("uniqueid==> "+expenseUniqueId);
String tranIdVoucher= checkNull(rs.getString("VOUCH_NO"));
String tranIdPayment= checkNull(rs.getString("PAY_NO"));
String tranIdPaymentDt= checkNull(rs.getString("PAY_DATE"));
String tranIdPaymentAmt= checkNull(rs.getString("PAY_AMT"));
System.out.println("VOUCH_NOnew=vijay====> "+tranIdVoucher);
System.out.println("VOUCH_NOnew=vijay====> "+tranIdPayment);
System.out.println("VOUCH_NOnew=vijay====> "+tranIdPaymentDt);
System.out.println("VOUCH_NOnew=vijay====> "+tranIdPaymentAmt);
if(tranIdPayment.trim().length() > 0) {
String query="";
query="[{ " +
" \"EXPENSE_UNIQUE_ID\": \""+expenseUniqueId+"\", " +
" \"PAYMENTID\": \""+tranIdPayment+"\", " +
" \"DOCNO\": \""+tranIdVoucher+"\", " +
" \"BANKNAME\": \""+""+"\", " +
" \"PAYMENTDT\": \""+tranIdPaymentDt+"\", " +
" \"PAYAMT\": \""+tranIdPaymentAmt+"\", " +
" \"ADVADJAMT\": \""+"NA"+"\", " +
" \"CANCEL_ID\": \""+"NA"+"\", " +
" \"FLAG\": \""+"I"+"\" " +"\" }]";
System.out.println("Retrival json::"+query);
//String urlStr=fizzSkApiPuSH;
URL url = new URL(fizzSkApiPush);
System.out.println("@S@ url using %20["+url+"]");
System.out.println("Start iteration of response==>" + new java.sql.Timestamp(System.currentTimeMillis()));
int proxyPortInt = 0;
if (!fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = Integer.parseInt(fizzSkProxyPort);
}
if (fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = 8080;
}
Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(fizzSkApiIp, proxyPortInt));
HttpURLConnection conn7 = (HttpURLConnection) url.openConnection(proxy);
System.out.println("Test++");
Authenticator authenticator = new Authenticator() {
public PasswordAuthentication getPasswordAuthentication() {
return (new PasswordAuthentication(fizzSkProxyUname, fizzSkProxyPass.toCharArray()));
}
};
Authenticator.setDefault(authenticator);
System.out.println("Verify++");
conn7.setDoOutput(true);
conn7.setRequestMethod("POST");
conn7.setUseCaches(false);
conn7.setRequestProperty(fizzSkApiName.trim(), fizzSkApiKey.trim());
conn7.setRequestProperty("Content-Type", fizzSkApiCtype.trim());
try {
conn7.connect();
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
System.out.println("After Try & catch");
try
{
System.out.println("In OutputStream block");
OutputStream os = conn7.getOutputStream();
os.write(query.getBytes());
os.flush();
System.out.println("After OutputStream flush");
}
catch (Exception e)
{
System.out.println( "Exception - "+ e.getMessage() );
e.printStackTrace();
}
System.out.println( "URL: "+ url );
System.out.println( "ResponseCode: "+ conn7.getResponseCode() );
System.out.println( "ResponseMessage Ketan: "+ conn7.getResponseMessage() );
if(conn7.getResponseCode()==200) {
System.out.println("IN KETTTTTAN");
String sql1 = "update PHYZII_METIS_TRACK_HDR set pay_flag='Y',payment_id= ? where EXPENSE_UNIQUE_ID=? and vouch_no=?";
System.out.println("==>inside SQL" + sql1);
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, tranIdPayment);
pstmt1.setString(2, expenseUniqueId);
pstmt1.setString(3, tranIdVoucher);
cnt = pstmt1.executeUpdate();
if (cnt > 0) {
conn.commit();
System.out.println("misc voucher inserted successfully" + sql);
}else {
System.out.println("No Update");
}
if (pstmt1 != null) {
if (!pstmt1.isClosed()) {
pstmt1.close();
}
pstmt1 = null;
}
}
}
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
}
catch (Exception e)
{
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return "";
}
private String checkNull(String input) {
if (input == null) {
input = "";
}
return input.trim();
}
}
src/ibase/webitm/ejb/phyzii/PhyziiPosSave.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import ibase.ejb.E12EMAILComp;
import ibase.system.config.AppConnectParm;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseLogger;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.MasterStatefulLocal;
import ibase.webitm.ejb.UnAllocatedDocEJBLocal;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
import java.io.File;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import javax.ejb.Stateless;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
/**
* Session Bean implementation class MarketingBillPosEJB
*/
@Stateless
public class PhyziiPosSave extends ValidatorEJB implements PhyziiPosSaveRemote, PhyziiPosSaveLocal
{
E12GenericUtility genericUtility = new E12GenericUtility();
String errString = "" ;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
/**
* Default constructor.
*/
public PhyziiPosSave()
{
// TODO Auto-generated constructor stub
}
@Override
public String postSave(String xmlStringAll, String tranId, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
Document dom = null;
String retString="";
//By VALLABH KADAM.
String suppCode="",porderNo="",billNo="",reasonCodes="",voucherNo="",status="", sundryType = "", sundryCode = "", docType = "";// Added by parikshit on 15/02/16 [added docType variable - F15KSUN007 ]
int cnt=0,cnt1=0;
Timestamp billDate=null,billRcvDate=null;
PreparedStatement pstmt1=null,pstmt2=null,pstmt3=null,pstmt=null;
ResultSet rs1=null,rs2=null,rs3=null,rs=null;
String sql1="",sql2="",sql3="",sql="";
String transDB="";
String chgUser="";
String loginEmpCode="";
String loginSiteCode="";
ibase.utility.UserInfoBean userInfo=null;
String empCode="";
// By VALLABH KADAM.
System.out.println("PostSave Action Called:::"+ xmlStringAll);
System.out.println("PostSave editFlag:::"+ editFlag);
try
{
dom = genericUtility.parseString(xmlStringAll);
userInfo = new ibase.utility.UserInfoBean();
System.out.println("xtraParams>>>>" + xtraParams);
String userId = getValueFromXTRA_PARAMS(xtraParams, "loginCode");
String termId = getValueFromXTRA_PARAMS(xtraParams, "termId");
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
loginSiteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
userInfo.setEmpCode(loginEmpCode);
userInfo.setRemoteHost(termId);
userInfo.setSiteCode(loginSiteCode);
userInfo.setLoginCode(userId);
userInfo.setEntityCode(loginEmpCode);
// if ( editFlag.equalsIgnoreCase( "A" ) )
// {
// String objName = checkNull(getObjNameFromDom(dom, "objName","1"));
//
// tranId = checkNull(genericUtility.getColumnValue("tran_id",dom, "1"));
// String billDocId = checkNull(genericUtility.getColumnValue("bill_doc_id",dom, "1"));
// empCode= checkNull(genericUtility.getColumnValue("emp_code",dom, "1"));
// System.out.println("billDocId>>> " +billDocId);
// System.out.println("objName = ["+ objName +"] tranId = ["+ tranId +"] billDocId = ["+ billDocId +"] userId = ["+ userId +"]");
//
// if ( empCode != null && empCode.trim().length() > 0)
//// {
//// int countCovid=0;
//// int countPassport=0;
//// int countPhoto=0;
//// int countPan=0;
//// int countElig=0;
////
//// sql="UPDATE PHYZII_METIS_TRACK_HDR SET ERROR_FLAG = ?,STATUS = ? WHERE TRAN_ID = ?";
//// System.out.println("==>inside SQL"+ sql);
////
//// pstmt1 = conn.prepareStatement(sql);
//// pstmt1.setString(1, "U");
//// pstmt1.setString(1, "");
//// pstmt1.setString(3, tranId);
////
//// cnt = pstmt1.executeUpdate();
//// {
//// countCovid = rs.getInt("cnt");
////
//// }
//// System.out.println("transDB = " + transDB);
//// if(rs != null)
//// {
//// rs.close();
//// rs= null;
//// }
//// if(pstmt != null)
//// {
//// pstmt.close();
//// pstmt = null;
//// }
//// if(countCovid == 0) {
//// errString = itmDBAccessEJB.getErrorString("emp_code","VTCOVIDCNT",userId);
//// return errString;
////
//// }
////
////
//// }
// }
tranId = checkNull(genericUtility.getColumnValue("tran_id",dom, "1"));
System.out.println("tranId==>"+tranId);
sql="UPDATE PHYZII_METIS_TRACK_HDR SET ERROR_FLAG = ?,STATUS = ? WHERE TRAN_ID = ?";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, "U");
pstmt1.setString(1, "");
pstmt1.setString(3, tranId);
int count=pstmt1.executeUpdate();
System.out.println("post count---->String>["+count+"]");
if(count > 0) {
conn.commit();
}
}
catch(Exception e) {
e.printStackTrace();
}
return "";
}
private String getObjNameFromDom( Document dom, String attribute, String objContext ) throws RemoteException,ITMException
{
NodeList detailList = null;
Node currDetail = null;
String objName = "";
int detailListLength = 0;
try
{
detailList = dom.getElementsByTagName("Detail"+objContext);
detailListLength = detailList.getLength();
for (int ctr = 0; ctr < detailListLength; ctr++)
{
currDetail = detailList.item(ctr);
objName = currDetail.getAttributes().getNamedItem(attribute).getNodeValue();
}
}
catch ( Exception e )
{
throw new ITMException(e);
}
System.out.println("objName =["+objName+"]");
return objName;
}
private String checkNull(String input)
{
if (input == null || "null".equalsIgnoreCase(input))
{
input= "";
}
return input.trim();
}
}
src/ibase/webitm/ejb/phyzii/PhyziiPosSaveLocal.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Local;
@Local
public interface PhyziiPosSaveLocal extends ValidatorLocal
{
public String postSave(String xmlStringAll, String tranId, String editFlag, String xtraParams, Connection conn) throws RemoteException,ITMException;
}
src/ibase/webitm/ejb/phyzii/PhyziiPosSaveRemote.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Remote;// added for ejb3
//public interface AdjIssPos extends ValidatorRemote, EJBObject //commented for ejb3
import ibase.webitm.ejb.ValidatorRemote;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
@Remote // added for ejb3
public interface PhyziiPosSaveRemote extends ValidatorRemote
{
public String postSave(String xmlStringAll, String tranId, String editFlag, String xtraParams, Connection conn) throws RemoteException,ITMException;
}
\ No newline at end of file
src/ibase/webitm/ejb/phyzii/PhyziiPullApiSch.java 0 → 100644
View file @ 81305f5c
This source diff could not be displayed because it is too large. You can view the blob instead.
src/ibase/webitm/ejb/phyzii/PhyziiPushApiSch.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Authenticator;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.PasswordAuthentication;
import java.net.Proxy;
import java.net.URL;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;
import java.util.TimeZone;
import javax.lang.model.element.Element;
import javax.naming.InitialContext;
import org.json.JSONArray;
import org.json.JSONObject;
import org.w3c.dom.Document;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.AppConnectParm;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.utility.GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.MasterStatefulLocal;
import ibase.webitm.ejb.Messages;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.fin.FinCommon;
import java.net.URL;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.HashMap;
import java.util.Iterator;
import org.json.JSONObject;
//import ibase.planner.utility.ITMException;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.fin.FinCommon;
public class PhyziiPushApiSch extends ValidatorEJB implements Schedule {
@Override
public String schedulePriority(String wrkflwPriority) throws Exception {
System.out.println("schedulePriority..1");
return "";
}
public String schedule(HashMap map) throws Exception {
System.out.println("schedulePriority..2");
return "";
}
public String schedule(String scheduleParamXML) throws ITMException, Exception {
String flag = "PWC";
String reultString = "";
try {
System.out.println("schedulePriority..3");
reultString = update(scheduleParamXML, flag);
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return reultString;
}
public String update(String scheduleParamXML, String flag) throws BaseException, Exception
{
System.out.println("inside method ===>");
ibase.utility.UserInfoBean userInfo = null;
Connection conn = null;
ResultSet rs = null;
PreparedStatement pstmt = null,pstmt1=null;
String selectQuery = "";
String sql="";
String cont = "";
int cnt=0;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
userInfo = new UserInfoBean(scheduleParamXML);
String transDB = userInfo.getTransDB();
String loginCode = userInfo.getLoginCode();
System.out.println(
"get TransDB & login code connection in updateStatus : " + transDB + "::loginCode::" + loginCode);
if (transDB != null && transDB.trim().length() > 0) { conn =
connDriver.getConnectDB(transDB); }
else { conn = connDriver.getConnectDB("DriverITM");
}
if (conn == null) { conn = connDriver.getConnectDB("DriverITM"); } connDriver
= null; conn.setAutoCommit(false);
FinCommon disCom1 = new FinCommon();
String fizzSkApiName = disCom1.getFinparams("999999", "FIZZ_SK_API_NAME", conn);
String fizzSkApiKey = disCom1.getFinparams("999999", "FIZZ_SK_API_KEY", conn);
String fizzSkApiCtype = disCom1.getFinparams("999999", "FIZZ_SK_API_CTYPE", conn);
String fizzSkApiPush = disCom1.getFinparams("999999", "FIZZ_SK_API_PUSH", conn);
String fizzSkApiIp = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_IP", conn);
String fizzSkProxyPort = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PORT", conn);
final String fizzSkProxyUname = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_UNAME", conn);
final String fizzSkProxyPass = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PASS", conn);
/*
* conn = connDriver.getConnectDB("DriverITM"); conn.setAutoCommit(false);
*/
userInfo = new ibase.utility.UserInfoBean();
selectQuery = "select VOUCH_NO,EXPENSE_UNIQUE_ID from PHYZII_METIS_TRACK_HDR where ERROR_FLAG='P' and (vouch_flag !='Y' or vouch_flag is null)";
pstmt = conn.prepareStatement(selectQuery);
//pstmt.setString(1, "P");
//pstmt.setString(2, "Y");
rs = pstmt.executeQuery();
System.out.println("rs===>"+rs);
while (rs.next())
{
System.out.println("IN WHILE");
String expenseUniqueId = checkNull(rs.getString("EXPENSE_UNIQUE_ID"));
System.out.println("uniqueid==> "+expenseUniqueId);
String tranIdVoucher= checkNull(rs.getString("VOUCH_NO"));
System.out.println("VOUCH_NOnew=vijay====> "+tranIdVoucher);
String query="";
query="[{ " +
" \"EXPENSE_UNIQUE_ID\": \""+expenseUniqueId+"\", " +
" \"DOCNO\": \""+tranIdVoucher+"\", " +
" \"Status\": \""+"SUCCESS"+"\", " +
" \"Message\": \""+tranIdVoucher+" ==> SUCCESSFULLY CREATED."+"\" }]";
System.out.println("Retrival json::"+query);
//String urlStr=fizzSkApiPuSH;
URL url = new URL(fizzSkApiPush);
System.out.println("@S@ url using %20["+url+"]");
System.out.println("Start iteration of response==>" + new java.sql.Timestamp(System.currentTimeMillis()));
int proxyPortInt = 0;
if (!fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = Integer.parseInt(fizzSkProxyPort);
}
if (fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = 8080;
}
Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(fizzSkApiIp, proxyPortInt));
HttpURLConnection conn7 = (HttpURLConnection) url.openConnection(proxy);
System.out.println("Test++");
Authenticator authenticator = new Authenticator() {
public PasswordAuthentication getPasswordAuthentication() {
return (new PasswordAuthentication(fizzSkProxyUname, fizzSkProxyPass.toCharArray()));
}
};
Authenticator.setDefault(authenticator);
System.out.println("Verify++");
conn7.setDoOutput(true);
conn7.setRequestMethod("POST");
conn7.setUseCaches(false);
conn7.setRequestProperty(fizzSkApiName.trim(), fizzSkApiKey.trim());
conn7.setRequestProperty("Content-Type", fizzSkApiCtype.trim());
try {
conn7.connect();
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
System.out.println("After Try & catch");
try
{
System.out.println("In OutputStream block");
OutputStream os = conn7.getOutputStream();
os.write(query.getBytes());
os.flush();
System.out.println("After OutputStream flush");
}
catch (Exception e)
{
System.out.println( "Exception - "+ e.getMessage() );
e.printStackTrace();
}
System.out.println( "URL: "+ url );
System.out.println( "ResponseCode: "+ conn7.getResponseCode() );
System.out.println( "ResponseMessage Ketan: "+ conn7.getResponseMessage() );
if(conn7.getResponseCode()==200) {
System.out.println("IN KETTTTTAN");
String sql1 = "update PHYZII_METIS_TRACK_HDR set vouch_flag='Y' where EXPENSE_UNIQUE_ID=? and vouch_no=?";
System.out.println("==>inside SQL" + sql1);
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, expenseUniqueId);
pstmt1.setString(2, tranIdVoucher);
cnt = pstmt1.executeUpdate();
if (cnt > 0) {
conn.commit();
System.out.println("misc voucher inserted successfully" + sql);
}else {
System.out.println("No Update");
}
if (pstmt1 != null) {
if (!pstmt1.isClosed()) {
pstmt1.close();
}
pstmt1 = null;
}
}
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
}
catch (Exception e)
{
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return "";
}
private String checkNull(String input) {
if (input == null) {
input = "";
}
return input.trim();
}
}
src/ibase/webitm/ejb/phyzii/PhyziiPushApiSch2.java 0 → 100644
View file @ 81305f5c
package ibase.webitm.ejb.phizzy;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Authenticator;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.PasswordAuthentication;
import java.net.Proxy;
import java.net.URL;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;
import java.util.TimeZone;
import javax.lang.model.element.Element;
import javax.naming.InitialContext;
import org.json.JSONArray;
import org.json.JSONObject;
import org.w3c.dom.Document;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.AppConnectParm;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.utility.GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.MasterStatefulLocal;
import ibase.webitm.ejb.Messages;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.fin.FinCommon;
import java.net.URL;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.HashMap;
import java.util.Iterator;
import org.json.JSONObject;
//import ibase.planner.utility.ITMException;
import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseException;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.fin.FinCommon;
public class PhyziiPushApiSch2 extends ValidatorEJB implements Schedule {
@Override
public String schedulePriority(String wrkflwPriority) throws Exception {
System.out.println("schedulePriority..1");
return "";
}
public String schedule(HashMap map) throws Exception {
System.out.println("schedulePriority..2");
return "";
}
public String schedule(String scheduleParamXML) throws ITMException, Exception {
String flag = "PWC";
String reultString = "";
try {
System.out.println("schedulePriority..3");
reultString = update(scheduleParamXML, flag);
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return reultString;
}
public String update(String scheduleParamXML, String flag) throws BaseException, Exception
{
System.out.println("inside method ===>");
ibase.utility.UserInfoBean userInfo = null;
Connection conn = null;
ResultSet rs = null;
PreparedStatement pstmt = null,pstmt1=null;
String selectQuery = "";
String sql="";
String cont = "";
int cnt=0;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
userInfo = new UserInfoBean(scheduleParamXML);
String transDB = userInfo.getTransDB();
String loginCode = userInfo.getLoginCode();
System.out.println(
"get TransDB & login code connection in updateStatus : " + transDB + "::loginCode::" + loginCode);
if (transDB != null && transDB.trim().length() > 0) { conn =
connDriver.getConnectDB(transDB); }
else { conn = connDriver.getConnectDB("DriverITM");
}
if (conn == null) { conn = connDriver.getConnectDB("DriverITM"); } connDriver
= null; conn.setAutoCommit(false);
/*
* conn = connDriver.getConnectDB("DriverITM"); conn.setAutoCommit(false);
*/
userInfo = new ibase.utility.UserInfoBean();
String expenseUniqueId = "0000000079";
System.out.println("uniqueid==> "+expenseUniqueId);
String tranIdVoucher= "006XFNBW94";
System.out.println("VOUCH_NOnew=vijay====> "+tranIdVoucher);
String query="";
query="[{ " +
" \"EXPENSE_UNIQUE_ID\": \""+expenseUniqueId+"\", " +
" \"DOCNO\": \""+tranIdVoucher+"\", " +
" \"Status\": \""+"SUCCESS"+"\", " +
" \"Message\": \""+tranIdVoucher+" ==> SUCCESSFULLY CREATED."+"\" }]";
System.out.println("Retrival json::"+query);
FinCommon disCom1 = new FinCommon();
String fizzSkApiName = disCom1.getFinparams("999999", "FIZZ_SK_API_NAME", conn);
String fizzSkApiKey = disCom1.getFinparams("999999", "FIZZ_SK_API_KEY", conn);
String fizzSkApiCtype = disCom1.getFinparams("999999", "FIZZ_SK_API_CTYPE", conn);
String fizzSkApiPull = disCom1.getFinparams("999999", "FIZZ_SK_API_PULL", conn);
String fizzSkApiIp = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_IP", conn);
String fizzSkProxyPort = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PORT", conn);
final String fizzSkProxyUname = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_UNAME", conn);
final String fizzSkProxyPass = disCom1.getFinparams("999999", "FIZZ_SK_PROXY_PASS", conn);
//String urlStr="http://dev1.cirrius.in/CommonIntegrationAPI/Expense/ExpenseDataAck";
String urlStr="http://apiintegration.cirrius.in/CommonIntegrationAPI/Expense/ExpenseDataAck";
URL url = new URL(urlStr);
System.out.println("@S@ url using %20["+url+"]");
System.out.println("Start iteration of response==>" + new java.sql.Timestamp(System.currentTimeMillis()));
int proxyPortInt = 0;
if (!fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = Integer.parseInt(fizzSkProxyPort);
}
if (fizzSkProxyPort.equalsIgnoreCase("NULLFOUND")) {
proxyPortInt = 8080;
}
Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(fizzSkApiIp, proxyPortInt));
HttpURLConnection conn7 = (HttpURLConnection) url.openConnection(proxy);
System.out.println("Test++");
Authenticator authenticator = new Authenticator() {
public PasswordAuthentication getPasswordAuthentication() {
return (new PasswordAuthentication(fizzSkProxyUname, fizzSkProxyPass.toCharArray()));
}
};
Authenticator.setDefault(authenticator);
System.out.println("Verify++");
conn7.setDoOutput(true);
conn7.setRequestMethod("POST");
conn7.setUseCaches(false);
//conn7.setRequestProperty(fizzSkApiName.trim(), fizzSkApiKey.trim());
conn7.setRequestProperty(fizzSkApiName.trim(), "Q0hD");
conn7.setRequestProperty("Content-Type", fizzSkApiCtype.trim());
try {
conn7.connect();
} catch (Exception e) {
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
System.out.println("After Try & catch");
try
{
System.out.println("In OutputStream block");
OutputStream os = conn7.getOutputStream();
os.write(query.getBytes());
os.flush();
System.out.println("After OutputStream flush");
}
catch (Exception e)
{
System.out.println( "Exception - "+ e.getMessage() );
e.printStackTrace();
}
System.out.println( "URL: "+ url );
System.out.println( "ResponseCode: "+ conn7.getResponseCode() );
System.out.println( "ResponseMessage Ketan: "+ conn7.getResponseMessage() );
/*
* if(conn7.getResponseCode()==200) {
*
* String sql1 =
* "update PHYZII_METIS_TRACK_HDR set vouch_flag='Y' where EXPENSE_UNIQUE_ID=? and vouch_no=?"
* ; System.out.println("==>inside SQL" + sql1); pstmt1 =
* conn.prepareStatement(sql1); pstmt1.setString(1, expenseUniqueId);
* pstmt1.setString(2, tranIdVoucher); cnt = pstmt1.executeUpdate(); if (cnt >
* 0) { conn.commit(); System.out.println("misc voucher inserted successfully" +
* sql); } if (pstmt1 != null) { if (!pstmt1.isClosed()) { pstmt1.close(); }
* pstmt1 = null; } }
*/
}
catch (Exception e)
{
System.out.println("Exception - " + e.getMessage());
e.printStackTrace();
}
return "";
}
private String checkNull(String input) {
if (input == null) {
input = "";
}
return input.trim();
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment