Skip to content

D
Daniels project
Commit 0503ad40 authored by Daniel Quadras's avatar Daniel Quadras
Browse files
Options

Delete BatchloadReload.java

parent 945408cf
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 347 deletions
BatchloadReload.java deleted 100644 → 0
View file @ 945408cf
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.SQLException;
import com.mysql.jdbc.PreparedStatement;
import ibase.utility.BaseLogger;
import ibase.utility.CommonConstants;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.DBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.ITMException;
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
{
@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);
// VisionEDIUtility visionediutility = new VisionEDIUtility();
// visionediutility.transLoad(appId, getUserInfo(), "", "");
// ******************DANIEL changes
errString = readFileContents(batchid,appId);
// BaseLogger.log("3",null,null,"DANIEL input" + input);
//***************
//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;
}
public String readFileContents(String batchID,String appId) throws RemoteException, ITMException, SQLException
{
String input = "",fileName="",filepath ="",errorString="";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
Connection conn = getConnection();
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))
//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 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,"DANiel appId: " + appId);
//loadstat ="R";
// String sql = "update batchload \n"
// + "set load_stat = 'R'\n"
// + "where batch_id =";
String sql = "UPDATE BATCHLOAD SET LOAD_STAT = 'R' WHERE BATCH_ID = '"+batchID+ "' ";
java.sql.PreparedStatement 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);
errorString = itmDBAccessEJB.getErrorString("","RLOADSUC",addUser,"",conn);
//errorString = itmDBAccessEJB.getErrorString("","RLOADFAIL",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;
}
}
catch (Exception e) {
e.printStackTrace();
System.out.println("EXception is"+e);
}
}
BaseLogger.log("3",null,null,"DANiel errorString: " + errorString);
return errorString;
}
}
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