Skip to content

D
Daniels project
Commit 76a20487 authored by Daniel Quadras's avatar Daniel Quadras
Browse files
Options

Delete BatchloadReload.java

parent 004243fa
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 1066 deletions
BatchloadReload.java deleted 100644 → 0
View file @ 004243fa
package ibase.webitm.ejb.sys;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;
import com.mysql.jdbc.PreparedStatement;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseLogger;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.DBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ITMUploadFileEJB;
import ibase.webitm.ejb.MasterApplyEJB;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.RestAPIServiceUtility;
import ibase.webitm.utility.VisionEDIUtility;
import net.sf.saxon.functions.Evaluate.PreparedExpression;
/*
* Author: Gagan B.
* Purpose of the class: On click of Reload button in batch data upload screen LOAD_STAT should be changed from "E" to "N".
* After that the data should be saved in transaction (call transLoad method.)
* Reload button should be used only in cases like below.
* E.g.
1. Period not defined.
2. Master not available.
3. Some database access was not provided.
* */
public class BatchloadReload extends ActionHandlerEJB
{
protected ibase.utility.UserInfoBean userInfo = null;
@Override
public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException, ITMException
{
//Connection connectionObject = null;
String errString = "";
try
{
Connection conn = getConnection();
UpdateLoadStatus updateLoadStatus = new UpdateLoadStatus();
updateLoadStatus.setUserInfo(getUserInfo() );
//updateLoadStatus.UpdateLoadStat(tranId, xtraParams, forcedFlag);
BaseLogger.log("3",null,null,"tranId from BatchloadReload:: ["+tranId+"]");
String batchid = "";
int tranIdend = tranId.indexOf(":");
if (tranIdend != -1)
{
batchid = tranId.substring(0 , tranIdend);
}
System.out.println("batchid:" + batchid);
String appId = "";
String ediAddr = "";
if (getUserInfo() != null)
{
DBAccessEJB dbAccessEJB = new DBAccessEJB();
try
{
ediAddr = dbAccessEJB.getDBColumnValue("BATCHLOAD", "EDI_ADDR", "BATCH_ID = '"+batchid+"'", getUserInfo().getTransDB());
}
catch (RemoteException | ITMException e)
{
e.printStackTrace();
}
}
if(!ediAddr.equalsIgnoreCase(""))
{
int ediAddriend = ediAddr.indexOf("_");
if (ediAddriend != -1)
{
ediAddr= ediAddr.substring(0 , ediAddriend);
appId = ediAddr;
}
}
BaseLogger.log("3",null,null,"tranId from BatchloadReload:: ["+tranId+"]");
BaseLogger.log("3",null,null,"appId from BatchloadReload:: ["+appId+"]");
BaseLogger.log("3",null,null,"errString from BatchloadReload["+errString+"]");
String winName = "";
if (getUserInfo() != null)
{
DBAccessEJB dbAccessEJB = new DBAccessEJB();
try
{
winName = dbAccessEJB.getDBColumnValue("BATCHLOAD", "WIN_NAME", "BATCH_ID = '"+batchid+"'", getUserInfo().getTransDB());
}
catch (RemoteException | ITMException e)
{
e.printStackTrace();
}
}
String dataFileName = "";
String serviceName = winName.substring(2);
String enterprise = getUserInfo().getEnterprise();
String addUser = getUserInfo().getLoginCode();
BaseLogger.log("3",null,null,"serviceName from BatchloadReload:: ["+serviceName+"]");
BaseLogger.log("3",null,null,"enterprise from BatchloadReload:: ["+enterprise+"]");
if (getUserInfo() != null)
{
DBAccessEJB dbAccessEJB = new DBAccessEJB();
try
{
dataFileName = dbAccessEJB.getDBColumnValue("BATCHLOAD", "DATA_FILE_NAME", "BATCH_ID = '"+batchid+"'", getUserInfo().getTransDB());
}
catch (RemoteException | ITMException e)
{
e.printStackTrace();
}
}
String fromPath = CommonConstants.EDI_DATA_PATH + File.separator + serviceName + File.separator + enterprise + File.separator + appId + File.separator + dataFileName;
BaseLogger.log("3",null,null,"From Path: " + fromPath);
String fileType = dataFileName.substring( dataFileName.lastIndexOf(".") + 1 );
BaseLogger.log( "3", null, null, "fileType : ["+ fileType +"]" );
String dataDumpFolderName = "";
if( "json".equalsIgnoreCase( fileType ) )
{
dataDumpFolderName = "JSON_UPLOAD";
}
else
{
dataDumpFolderName = "XLS_UPLOAD";
fileType = "xml";
}
String toPath = CommonConstants.JBOSSHOME + File.separator + dataDumpFolderName + File.separator + addUser + File.separator + batchid + File.separator + dataFileName;
BaseLogger.log("3",null,null,"To Path: " + toPath);
moveFile(fromPath, toPath);
//
// ******************DANIEL changes
//reloadLoadStatE
errString = reloadLoadStatE(batchid,appId);
// errString = readFileContents(batchid,appId);
//***************
//ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
//errString = itmDBAccessEJB.getErrorString("","RLOADSUC",addUser,"",conn);
}
catch(Exception e)
{
BaseLogger.log("3",null,null,"BATCHLOAD Exception ::"+e.getMessage());
throw new ITMException(e);
}
BaseLogger.log("3",null,null,"Returning Result ::"+errString);
return errString;
}
public String moveFile(String fromPath, String toPath)
{
String result = "";
try
{
Path temp = Files.move(Paths.get(fromPath), Paths.get(toPath));
if (temp != null)
{
BaseLogger.log("3",null,null,"File moved sucessfully!");
result = "Y";
}
else
{
BaseLogger.log("3",null,null,"Failed to move file.");
result = "N";
}
}
catch (IOException e)
{
e.printStackTrace();
}
return result;
}
//reloadLoadStatE
//reload
public String reloadLoadStatE(String batchID,String appId) throws RemoteException, ITMException, SQLException
{
String input = "",fileName="",filepath ="",errorString="";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
Connection conn = getConnection();
java.sql.PreparedStatement pstmt = null, pstmt2=null;
try {
String addUser = getUserInfo().getLoginCode();
DBAccessEJB dbacessEJb = new DBAccessEJB();
String loadstat = dbacessEJb.getDBColumnValue("BATCHLOAD", "LOAD_STAT", "BATCH_ID = '"+batchID+"' ", getUserInfo().getTransDB());
BaseLogger.log("3",null,null,"DANiel appId: " + appId);
BaseLogger.log("3",null,null,"DANiel loadstat: " + loadstat);
BaseLogger.log("3",null,null,"DANiel batchID: " + batchID);
if("E".equalsIgnoreCase(loadstat))
{
// fileName = dbacessEJb.getDBColumnValue("BATCHLOAD", "DATA_FILE_NAME", "BATCH_ID = '"+batchID+"' ", getUserInfo().getTransDB());
// BaseLogger.log("3",null,null,"DANiel data_File_Name: " + fileName);
//
// if(fileName.isEmpty() || fileName.trim().length() == 0 || fileName == null )
//
// {
// errorString = itmDBAccessEJB.getErrorString("","FLNTFND",addUser,"",conn);
// }
//
// filepath = "/wildfly/upload_failed/"+fileName;
// BaseLogger.log("3",null,null,"DANiel filepath: " + filepath);
//
// BufferedReader bufferreader = new BufferedReader(new FileReader(filepath));
// StringBuilder sb = new StringBuilder();
// String line = bufferreader.readLine();
//
// while(line != null)
// {
// sb.append(line);
// line = bufferreader.readLine();
// }
//
// input = sb.toString();
// BaseLogger.log("3",null,null,"DANiel input: " + input);
// BaseLogger.log("3",null,null,"DANiel StringBuilder sb: " + sb);
//errString = input;
String sql = "UPDATE BATCHLOAD SET LOAD_STAT = 'R' WHERE BATCH_ID = '"+batchID+ "' ";
pstmt = conn.prepareStatement(sql);
int sqlresult = pstmt.executeUpdate();
BaseLogger.log("3",null,null,"DANiel new sqlresult: " + sqlresult);
//BaseLogger.log("3",null,null,"DANiel new loadstat: " + loadstat);
// VisionEDIUtility visionediutility = new VisionEDIUtility();
// String transload = visionediutility.transLoad(appId, getUserInfo(), input, "writeFilesavetrans");
// BaseLogger.log("3",null,null,"DANiel transload method value: " + transload);
// VisionEDIUtility visionediutility = new VisionEDIUtility();
// String transreload =visionediutility.transReload(appId, getUserInfo(), batchID);
// BaseLogger.log("3",null,null,"DANiel transreload method value: " + transreload);
// String transreloadresult = reloadTransLoad(appId, getUserInfo(), batchID);
// BaseLogger.log("3",null,null,"DANiel reloadtransload method value: " + transreloadresult);
String transreloadresult = transReload(appId, getUserInfo(), batchID);
BaseLogger.log("3",null,null,"DANiel transreloadresult method value: " + transreloadresult);
String sql2 = "UPDATE BATCHLOAD SET LOAD_STAT = 'Y' WHERE BATCH_ID = '"+batchID+ "' ";
pstmt2 = conn.prepareStatement(sql2);
int sqlresult2 = pstmt2.executeUpdate();
BaseLogger.log("3",null,null,"DANiel second sqlresult: " + sqlresult2);
//**********
// String result = reloadTransLoad(appId, userInfo, batchID, input);
// BaseLogger.log("3",null,null,"DANiel transload replicated method response " + result);
//*********
errorString = itmDBAccessEJB.getErrorString("","RLOADSUC",addUser,"",conn);
}
else
{
errorString = itmDBAccessEJB.getErrorString("","RLOADFAIL",addUser,"",conn);
//errString = itmDBAccessEJB.getErrorString("","RLOADSUC",addUser,"",conn);
//reload will only work for load stat E
}
}
catch(Exception e )
{
e.printStackTrace();
System.out.println("Exception is"+e);
}
finally
{
try {
if(conn != null)
{
conn.close();
conn = null;
}
if (pstmt != null) {
pstmt.close();
pstmt = null;
}
if(pstmt2 !=null )
{
pstmt2.close();
pstmt2 = null;
}
}
catch (Exception e) {
e.printStackTrace();
System.out.println("EXception is"+e);
}
}
BaseLogger.log("3",null,null,"DANiel errorString: " + errorString);
return errorString;
}
public String readUploadFailFileContents(String batchID) throws ITMException, IOException
{
String errorString = "";
DBAccessEJB dbacessEJb = new DBAccessEJB();
String addUser = getUserInfo().getLoginCode();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
String filepath = "",fileName="";
Connection conn = getConnection();
String input = "";
fileName = dbacessEJb.getDBColumnValue("BATCHLOAD", "DATA_FILE_NAME", "BATCH_ID = '"+batchID+"' ", getUserInfo().getTransDB());
BaseLogger.log("3",null,null,"DANiel data_File_Name: " + fileName);
if(fileName.isEmpty() || fileName.trim().length() == 0 || fileName == null )
{
errorString = itmDBAccessEJB.getErrorString("","FLNTFND",addUser,"",conn);
}
filepath = "/wildfly/upload_failed/"+fileName;
BaseLogger.log("3",null,null,"DANiel filepath: " + filepath);
BufferedReader bufferreader = new BufferedReader(new FileReader(filepath));
StringBuilder sb = new StringBuilder();
String line = bufferreader.readLine();
while(line != null)
{
sb.append(line);
line = bufferreader.readLine();
}
input = sb.toString();
BaseLogger.log("3",null,null,"DANiel input: " + input);
BaseLogger.log("3",null,null,"DANiel StringBuilder sb: " + sb);
bufferreader.close();
return input;
}
//
// public String reloadTransLoad(String appId, UserInfoBean userinfo,String batchId) throws Exception
// {
//
// String result = "";
// Connection conn = null;
// java.sql.PreparedStatement pstmt = null;
// ResultSet rs = null;
// String inputData = "";
// String PKValue = "";
//
// try {
//
//
// ConnDriver connDriver = new ConnDriver();
// conn = connDriver.getConnectDB( userinfo.getTransDB() );
// connDriver = null;
//
// BaseLogger.log( "3", userinfo, null, "daniel appId : ["+ appId +"]" );
//
// String appIdAddr = "";
// if ( appId.length() > 0 )
// {
// appIdAddr = (appId + "_");
// BaseLogger.log( "3", userinfo, null, "daniel appIdAddr : ["+ appIdAddr +"]" );
// }
//
// String sql = "select * from batchload where batch_id = '"+batchId+"' ";
// pstmt = conn.prepareStatement( sql );
// rs = pstmt.executeQuery();
// BaseLogger.log( "3", userinfo, null, "daniel sql : ["+ sql +"]" );
//
// HashMap<Integer, HashMap<String, String>> dataMap = new LinkedHashMap<Integer, HashMap<String,String>>();
//
// ResultSetMetaData rsmd = rs.getMetaData();
// int noOfColumns = rsmd.getColumnCount();
//
// while( rs.next() )
// {
// HashMap<String, String> tempMap = new HashMap<String, String>();
// for(int ctr = 1; ctr <= noOfColumns; ctr++)
// {
// if( "mysql".equalsIgnoreCase( CommonConstants.DB_NAME ) )
// {
// tempMap.put( rsmd.getColumnName(ctr).toUpperCase(), rs.getString(ctr) );
// }
// else
// {
// tempMap.put( rsmd.getColumnName(ctr), rs.getString(ctr) );
// }
// }
// dataMap.put( 1, tempMap ); // Changed by Gagan B. for storing only latest transaction in map.
// }
// rs.close();
// rs = null;
// pstmt.close();
// pstmt = null;
//
//
// MasterApplyEJB masterApplyEJB = new MasterApplyEJB();
// masterApplyEJB.updateBatchLoad( dataMap, "I", conn, userinfo );
//
//
// if ( conn != null )
// {
// conn.close();
// conn = null;
// }
//
// String batchID = "";
// String fileName = "";
// String objName = "";
// String subject = "";
// String templateId = "";
// String templateName = "";
// String ediAddr = "";
// String threadKey = "";
// String dependency = "";
// String addUser = "";
// String loadStat = "";
// String tranSlStr = "0";
// int tranSl = 0;
//
// for( Map.Entry<Integer, HashMap<String, String>> dataEntry : dataMap.entrySet() )
// {
//
//
//
// HashMap<String, String> tempDataMap = dataEntry.getValue();
// RestAPIServiceUtility restapiserviceutility = new RestAPIServiceUtility();
// objName = restapiserviceutility.checkNull( tempDataMap.get( "WIN_NAME" ) );
// objName = objName.substring( objName.indexOf("_") + 1 );
// batchID = restapiserviceutility.checkNull( tempDataMap.get( "BATCH_ID" ) );
// fileName = restapiserviceutility.checkNull( tempDataMap.get( "DATA_FILE_NAME" ) );
// subject = restapiserviceutility.checkNull( tempDataMap.get( "SUBJECT" ) );
// templateId = restapiserviceutility.checkNull( tempDataMap.get( "XFRM_TEMPLATE" ) );
// templateName = restapiserviceutility.checkNull( tempDataMap.get( "TEMPLATE_NAME" ) );
// //Added by Pooja S on 12-JAN-2021 [Batchload interface to store keyFieldValue for the transaction]
// tranSlStr = restapiserviceutility.checkNull( tempDataMap.get( "TRAN_SL" ) );
// if ( tranSlStr.length() > 0 )
// {
// tranSl = Integer.parseInt( tranSlStr );
// }
// ediAddr = restapiserviceutility.checkNull( tempDataMap.get( "EDI_ADDR" ) );
// threadKey = restapiserviceutility.checkNull( tempDataMap.get( "THREAD_KEY" ) );
// addUser = restapiserviceutility.checkNull( tempDataMap.get( "ADD_USER" ) ).trim();
// loadStat = restapiserviceutility.checkNull( tempDataMap.get( "LOAD_STAT" ) );
//
// BaseLogger.log( "3", userinfo, null, "objName : ["+ objName +"]" );
// BaseLogger.log( "3", userinfo, null, "batchID : ["+ batchID +"]" );
// BaseLogger.log( "3", userinfo, null, "fileName : ["+ fileName +"]" );
// BaseLogger.log( "3", userinfo, null, "subject : ["+ subject +"]" );
// BaseLogger.log( "3", userinfo, null, "templateId : ["+ templateId +"]" );
// BaseLogger.log( "3", userinfo, null, "templateName : ["+ templateName +"]" );
// BaseLogger.log( "3", userinfo, null, "ediAddr : ["+ ediAddr +"]" );
// BaseLogger.log( "3", userinfo, null, "threadKey : ["+ threadKey +"]" );
// BaseLogger.log( "3", userinfo, null, "addUser : ["+ addUser +"]" );
// BaseLogger.log( "3", userinfo, null, "loadStat : ["+ loadStat +"]" );
//
// if ( fileName.length() == 0 || fileName.indexOf( "." ) == -1 )
// {
// continue;
// }
// dependency = "";
// threadKey = restapiserviceutility.checkNull( threadKey );
// if ( threadKey.length() > 0 )
// {
// dependency = getDBAccess().getDBColumnValue( "BATCHLOAD", "(BATCH_ID || ':' || TRAN_SL)~AS~DEPENDENCY", (" THREAD_KEY = '"+ threadKey +"' AND LOAD_STAT = 'E' "), userinfo.getTransDB() );
// }
// dependency = restapiserviceutility.checkNull( dependency );
// if ( dependency.length() > 0 )
// {
// //Changed by Ravindra C on 17-07-21 to update the load_stat As a N. - Start
// //getDBAccess().updateTableColumnValue( "BATCHLOAD", "DEPENDENCY", dependency, (" BATCH_ID = '" + batchID + "' AND TRAN_SL = '"+ tranSl +"' "), userInfo.getTransDB() );
// masterApplyEJB.updateBatchLoad( batchID, tranSl, loadStat, dependency, null, userinfo );
// //Changed by Ravindra C on 17-07-21 to update the load_stat As a I. - End
// continue;
// }
// else
// {
// String[] fileInfoArr = new String[6];
// fileInfoArr[0] = "false";
// fileInfoArr[1] = fileName;
// fileInfoArr[2] = objName;
// fileInfoArr[3] = "";
// fileInfoArr[4] = templateName;
// fileInfoArr[5] = subject;
// //fileInfoArr[7] = "true"; //isRetXML
//
// String fileType = fileName.substring( fileName.lastIndexOf(".") + 1 );
// BaseLogger.log( "3", userinfo, null, "fileType : ["+ fileType +"]" );
// String uploadFilePath = "";
// String dataDumpFolderName = "";
// if( "json".equalsIgnoreCase( fileType ) )
// {
// dataDumpFolderName = "JSON_UPLOAD";
// }
// else
// {
// dataDumpFolderName = "XLS_UPLOAD";
// fileType = "xml";
// }
//
// uploadFilePath = CommonConstants.JBOSSHOME + File.separator + dataDumpFolderName + File.separator + addUser + File.separator + batchID;
// File DUMP_DIR = null;
// DUMP_DIR = new File( uploadFilePath );
// if ( ! DUMP_DIR.exists() )
// {
// DUMP_DIR.mkdirs();
// }
// //Added by Ravindra C on 19/02/2021 [move failed file to load folder in case of reload] START
// if( "R".equalsIgnoreCase( loadStat ) )
// {
// moveFailedFileToUpload( uploadFilePath, fileName );
// }
// //Added by Ravindra C on 19/02/2021 [move failed file to load folder in case of reload] END
//
//
//
//
//
// String inputdata = readUploadFailFileContents(batchID);
//
//
// // Changes by Gagan B. as per suggestions of Danish Sir to remove condition and pass inputData to writeFile method which is passed to transLoad as parameter.
// new E12GenericUtility().writeFile( uploadFilePath, fileName, inputdata );
// //new E12GenericUtility().writeFile( uploadFilePath, fileName + "GSB", inputData );
//
// ITMUploadFileEJB itmUploadFileEJB = new ITMUploadFileEJB();
// //serviceConfigGlobal = serviceConfig;
// result = itmUploadFileEJB.insertFileData( fileInfoArr, userInfo, DUMP_DIR, CommonConstants.APPLICATION_CONTEXT, "", false, false, batchID, tranSl );
//
// String messageFromBatchLoad = "";
// BaseLogger.log("3",null,null,"batchId --> handleRequest:: " + batchId);
// if (userInfo != null)
// {
// DBAccessEJB dbAccessEJB = new DBAccessEJB();
// try
// {
// //Changes by Gagan B. to not retrieve value if ERROR_MSG column's value is null.
// messageFromBatchLoad = dbAccessEJB.getDBColumnValue("BATCHLOAD", "ERROR_MSG", "BATCH_ID = '"+batchId+"'" + "AND ERROR_MSG IS NOT NULL", userInfo.getTransDB());
// }
// catch (RemoteException | ITMException e)
// {
// e.printStackTrace();
// }
// }
// //Added by Gagan B. for setDataAndConfirm endpoint functionality [START]
// BaseLogger.log("3",null,null,"messageFromBatchLoad --> transLoad:: " + messageFromBatchLoad);
// BaseLogger.log( "3", null, null, "result from transLoad gsb:::" + result);
//
// String parentPKValues = itmUploadFileEJB.globalTranID;
// PKValue = parentPKValues;
// BaseLogger.log( "3", null, null, "parentPKValues from transLoad gsb:::" + parentPKValues);
//
//
// }
//
//
// }
//
//
//
//
//
//
// }
//
// catch (SQLException e)
// {
// BaseLogger.log( "0", null, null, "SQLException :: from transLoad() : ["+ e.getMessage() +"]" );
// e.printStackTrace();
// throw new ITMException( e );
//
// }
//
//
// catch (Exception e)
// {
// BaseLogger.log( "0", null, null, "Exception :: from transLoad() : ["+ e.getMessage() +"]" );
// 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.close();
// conn = null;
// }
// }
// catch (SQLException e)
// {
// e.printStackTrace();
// }
// }
//
//
// return result;
// }
//
public String transReload(String appId, UserInfoBean userInfo, String batchId) throws ITMException
{
String result = "";
Connection conn = null;
java.sql.PreparedStatement pstmt = null;
ResultSet rs = null;
String inputData = "";
String PKValue = "";
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB( userInfo.getTransDB() );
connDriver = null;
BaseLogger.log( "3", userInfo, null, "appId : ["+ appId +"]" );
String appIdAddr = "";
if ( appId.length() > 0 )
{
appIdAddr = (appId + "_");
BaseLogger.log( "3", userInfo, null, "gsb appIdAddr : ["+ appIdAddr +"]" );
}
String sql = "SELECT BATCH.BATCH_ID, BATCH.WIN_NAME, BATCH.DATA_FILE_NAME, BATCH.SUBJECT, BATCH.XFRM_TEMPLATE, TEMPL.TEMPLATE_NAME, BATCH.TRAN_SL, BATCH.EDI_ADDR, BATCH.THREAD_KEY, BATCH.ADD_USER, BATCH.LOAD_STAT, TRAN.LOAD_ORDER, BATCH.LOAD_ORDER " +
" FROM TRANSETUP TRAN, BATCHLOAD BATCH LEFT OUTER JOIN OBJ_FILE_TEMPLATE TEMPL ON BATCH.XFRM_TEMPLATE = TEMPL.TEMPLATE_ID " +
" WHERE BATCH_ID = '"+batchId+ "' " +
" AND BATCH.LOAD_STAT IN ( 'N', 'R', 'E' ) " +
" AND TRAN.TRAN_WINDOW = BATCH.WIN_NAME " +
" AND BATCH.EDI_ADDR IS NOT NULL AND BATCH.EDI_ADDR IN ( '"+ appIdAddr +"fileSystem', '"+ ( appIdAddr + CommonConstants.API_FILE_DESTINATION ) +"' ) " +
" ORDER BY TRAN.LOAD_ORDER, BATCH.LOAD_ORDER, BATCH.ADD_DATE, BATCH.BATCH_ID, BATCH.TRAN_SL ";
pstmt = conn.prepareStatement( sql );
//pstmt.setString(1, batchId);
rs = pstmt.executeQuery();
BaseLogger.log( "3", userInfo, null, "daniel sql : ["+ sql +"]" );
BaseLogger.log("3",null,null,"DANiel BATCHid INSIDE transrelaod: " + batchId);
HashMap<Integer, HashMap<String, String>> dataMap = new LinkedHashMap<Integer, HashMap<String,String>>();
ResultSetMetaData rsmd = rs.getMetaData();
int noOfColumns = rsmd.getColumnCount();
while( rs.next() )
{
HashMap<String, String> tempMap = new HashMap<String, String>();
for(int ctr = 1; ctr <= noOfColumns; ctr++)
{
if( "mysql".equalsIgnoreCase( CommonConstants.DB_NAME ) )
{
tempMap.put( rsmd.getColumnName(ctr).toUpperCase(), rs.getString(ctr) );
}
else
{
tempMap.put( rsmd.getColumnName(ctr), rs.getString(ctr) );
}
}
dataMap.put( 1, tempMap ); // Changed by Gagan B. for storing only latest transaction in map.
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
//Added By Ravindra C on 17-07-21 to update the load_stat As a I.
MasterApplyEJB masterApplyEJB = new MasterApplyEJB();
masterApplyEJB.updateBatchLoad( dataMap, "I", conn, userInfo );
if ( conn != null )
{
conn.close();
conn = null;
}
String batchID = "";
String fileName = "";
String objName = "";
String subject = "";
String templateId = "";
String templateName = "";
String ediAddr = "";
String threadKey = "";
String dependency = "";
String addUser = "";
String loadStat = "";
String tranSlStr = "0";
int tranSl = 0;
for( Map.Entry<Integer, HashMap<String, String>> dataEntry : dataMap.entrySet() )
{
HashMap<String, String> tempDataMap = dataEntry.getValue();
RestAPIServiceUtility restapiserviceutility = new RestAPIServiceUtility();
objName = restapiserviceutility.checkNull( tempDataMap.get( "WIN_NAME" ) );
objName = objName.substring( objName.indexOf("_") + 1 );
batchID = restapiserviceutility.checkNull( tempDataMap.get( "BATCH_ID" ) );
fileName = restapiserviceutility.checkNull( tempDataMap.get( "DATA_FILE_NAME" ) );
subject = restapiserviceutility.checkNull( tempDataMap.get( "SUBJECT" ) );
templateId = restapiserviceutility.checkNull( tempDataMap.get( "XFRM_TEMPLATE" ) );
templateName = restapiserviceutility.checkNull( tempDataMap.get( "TEMPLATE_NAME" ) );
tranSlStr = restapiserviceutility.checkNull( tempDataMap.get( "TRAN_SL" ) );
if ( tranSlStr.length() > 0 )
{
tranSl = Integer.parseInt( tranSlStr );
}
ediAddr = restapiserviceutility.checkNull( tempDataMap.get( "EDI_ADDR" ) );
threadKey = restapiserviceutility.checkNull( tempDataMap.get( "THREAD_KEY" ) );
addUser = restapiserviceutility.checkNull( tempDataMap.get( "ADD_USER" ) ).trim();
loadStat = restapiserviceutility.checkNull( tempDataMap.get( "LOAD_STAT" ) );
BaseLogger.log("3",null,null,"DANiel BATCHid INSIDE transrelaod: " + batchId);
BaseLogger.log( "3", userInfo, null, "daniel objName : ["+ objName +"]" );
BaseLogger.log( "3", userInfo, null, "dan batchID : ["+ batchID +"]" );
BaseLogger.log( "3", userInfo, null, "fileName : ["+ fileName +"]" );
BaseLogger.log( "3", userInfo, null, "subject : ["+ subject +"]" );
BaseLogger.log( "3", userInfo, null, "templateId : ["+ templateId +"]" );
BaseLogger.log( "3", userInfo, null, "templateName : ["+ templateName +"]" );
BaseLogger.log( "3", userInfo, null, "dan ediAddr : ["+ ediAddr +"]" );
BaseLogger.log( "3", userInfo, null, "threadKey : ["+ threadKey +"]" );
BaseLogger.log( "3", userInfo, null, "addUser : ["+ addUser +"]" );
BaseLogger.log( "3", userInfo, null, "daniel loadStat : ["+ loadStat +"]" );
if ( fileName.length() == 0 || fileName.indexOf( "." ) == -1 )
{
continue;
}
dependency = "";
threadKey = restapiserviceutility.checkNull( threadKey );
if ( threadKey.length() > 0 )
{
dependency = getDBAccess().getDBColumnValue( "BATCHLOAD", "(BATCH_ID || ':' || TRAN_SL)~AS~DEPENDENCY", (" THREAD_KEY = '"+ threadKey +"' AND LOAD_STAT = 'E' "), userInfo.getTransDB() );
}
dependency = restapiserviceutility.checkNull( dependency );
if ( dependency.length() > 0 )
{
//Changed by Ravindra C on 17-07-21 to update the load_stat As a N. - Start
//getDBAccess().updateTableColumnValue( "BATCHLOAD", "DEPENDENCY", dependency, (" BATCH_ID = '" + batchID + "' AND TRAN_SL = '"+ tranSl +"' "), userInfo.getTransDB() );
masterApplyEJB.updateBatchLoad( batchID, tranSl, loadStat, dependency, null, userInfo );
//Changed by Ravindra C on 17-07-21 to update the load_stat As a I. - End
continue;
}
else
{
String[] fileInfoArr = new String[6];
fileInfoArr[0] = "false";
fileInfoArr[1] = fileName;
fileInfoArr[2] = objName;
fileInfoArr[3] = "";
fileInfoArr[4] = templateName;
fileInfoArr[5] = subject;
//fileInfoArr[7] = "true"; //isRetXML
String fileType = fileName.substring( fileName.lastIndexOf(".") + 1 );
BaseLogger.log( "3", userInfo, null, "fileType : ["+ fileType +"]" );
String uploadFilePath = "";
String dataDumpFolderName = "";
if( "json".equalsIgnoreCase( fileType ) )
{
dataDumpFolderName = "JSON_UPLOAD";
}
else
{
dataDumpFolderName = "XLS_UPLOAD";
fileType = "xml";
}
//Changed by Ravindra C on 19/02/2021 [set added user in path]
//uploadFilePath = CommonConstants.JBOSSHOME + File.separator + dataDumpFolderName + File.separator + userInfo.getLoginCode() + File.separator + batchID;
uploadFilePath = CommonConstants.JBOSSHOME + File.separator + dataDumpFolderName + File.separator + addUser + File.separator + batchID;
File DUMP_DIR = null;
DUMP_DIR = new File( uploadFilePath );
if ( ! DUMP_DIR.exists() )
{
DUMP_DIR.mkdirs();
}
//Added by Ravindra C on 19/02/2021 [move failed file to load folder in case of reload] START
if( "R".equalsIgnoreCase( loadStat ) )
{
moveFailedFileToUpload( uploadFilePath, fileName );
}
//Added by Ravindra C on 19/02/2021 [move failed file to load folder in case of reload] END
DBAccessEJB dbacessEJb = new DBAccessEJB();
fileName = dbacessEJb.getDBColumnValue("BATCHLOAD", "DATA_FILE_NAME", "BATCH_ID = '"+batchID+"' ", userInfo.getTransDB());
BaseLogger.log("3",null,null,"DANiel data_File_Name: " + fileName);
// if(fileName.isEmpty() || fileName.trim().length() == 0 || fileName == null )
//
// {
// errorString = itmDBAccessEJB.getErrorString("","FLNTFND",addUser,"",conn);
// }
// *************************daniel
//
// String filepath = "/wildfly/upload_failed/"+fileName;
// BaseLogger.log("3",null,null,"DANiel filepath: " + filepath);
//
// BufferedReader bufferreader = new BufferedReader(new FileReader(filepath));
// StringBuilder sb = new StringBuilder();
// String line = bufferreader.readLine();
//
// while(line != null)
// {
// sb.append(line);
// line = bufferreader.readLine();
// }
//
// inputData = sb.toString();
// BaseLogger.log("3",null,null,"DANiel input: " + inputData);
// BaseLogger.log("3",null,null,"DANiel StringBuilder sb: " + sb);
// ************daniel
String inputdata = readUploadFailFileContents(batchID);
// ***daniel
// Changes by Gagan B. as per suggestions of Danish Sir to remove condition and pass inputData to writeFile method which is passed to transLoad as parameter.
new E12GenericUtility().writeFile( uploadFilePath, fileName, inputdata );
//new E12GenericUtility().writeFile( uploadFilePath, fileName + "GSB", inputData );
ITMUploadFileEJB itmUploadFileEJB = new ITMUploadFileEJB();
result = itmUploadFileEJB.insertFileData( fileInfoArr, userInfo, DUMP_DIR, CommonConstants.APPLICATION_CONTEXT, "", false, false, batchID, tranSl );
String messageFromBatchLoad = "";
BaseLogger.log("3",null,null,"batchId --> handleRequest:: " + batchId);
if (userInfo != null)
{
DBAccessEJB dbAccessEJB = new DBAccessEJB();
try
{
//Changes by Gagan B. to not retrieve value if ERROR_MSG column's value is null.
messageFromBatchLoad = dbAccessEJB.getDBColumnValue("BATCHLOAD", "ERROR_MSG", "BATCH_ID = '"+batchId+"'" + "AND ERROR_MSG IS NOT NULL", userInfo.getTransDB());
}
catch (RemoteException | ITMException e)
{
e.printStackTrace();
}
}
//Added by Gagan B. for setDataAndConfirm endpoint functionality [START]
BaseLogger.log("3",null,null,"messageFromBatchLoad --> transLoad:: " + messageFromBatchLoad);
BaseLogger.log( "3", null, null, "result from transLoad gsb:::" + result);
String parentPKValues = itmUploadFileEJB.globalTranID;
PKValue = parentPKValues;
BaseLogger.log( "3", null, null, "parentPKValues from transLoad gsb:::" + parentPKValues);
}
}
}
catch (SQLException e)
{
BaseLogger.log( "0", null, null, "SQLException :: from transLoad() : ["+ e.getMessage() +"]" );
e.printStackTrace();
throw new ITMException( e );
}
catch (Exception e)
{
BaseLogger.log( "0", null, null, "Exception :: from transLoad() : ["+ e.getMessage() +"]" );
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.close();
conn = null;
}
}
catch (SQLException e)
{
e.printStackTrace();
}
}
return result;
}
private void moveFailedFileToUpload( String uploadFilePath, String fileName )
{
String commonUploadSuccessFilePath = ( new File( CommonConstants.UPLOAD_LOC ) ) + File.separator + "upload_success";
String commonUploadFailedFilePath = ( new File( CommonConstants.UPLOAD_LOC ) ) + File.separator + "upload_failed";
File file = new File( commonUploadFailedFilePath + File.separator + fileName );
if ( file.exists() )
{
File dir = new File( uploadFilePath );
if ( ! dir.exists() )
{
dir.mkdirs();
}
BaseLogger.log( "3", userInfo, null, "dir --> ["+ dir +"]" );
boolean success = file.renameTo( new File( dir, file.getName() ) );
if ( ! success )
{
BaseLogger.log( "3", userInfo, null, "File was not moved" );
}
}
else
{
BaseLogger.log( "3", userInfo, null, "File not exist In the failed path" );
file = new File( commonUploadSuccessFilePath + File.separator + fileName );
if ( file.exists() )
{
File dir = new File( uploadFilePath );
if ( ! dir.exists() )
{
dir.mkdirs();
}
BaseLogger.log( "3", userInfo, null, "dir --> ["+ dir +"]" );
boolean success = file.renameTo( new File( dir, file.getName() ) );
if ( ! success )
{
BaseLogger.log( "3", userInfo, null, "File was not moved" );
}
}
}
}
private DBAccessEJB getDBAccess()
{
DBAccessEJB dbAccess = null;
try
{
if ( dbAccess == null )
{
//AppConnectParm appConnect = new AppConnectParm();
//InitialContext initialContext = new InitialContext(appConnect.getProperty());
//dbAccess = (DBAccessLocal) initialContext.lookup("ibase/DBAccessEJB/local");
dbAccess = new DBAccessEJB();
}
}
/*catch (NamingException e)
{
e.printStackTrace();
}*/
catch (Exception e)
{
e.printStackTrace();
}
return dbAccess;
}
}
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