Skip to content

B
business-java
Commit 6af8c6f1 authored by wansari's avatar wansari
Browse files
Options

W15GSUN003 changed by wasim to update interface2 column name as it was changed later 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@98811 ce508802-f39f-4f6c-b175-0d175dae99d5
parent f42bb720
Show whitespace changes
Inline Side-by-side
Showing with 385 additions and 64 deletions
webitm-wms/ibase/webitm/utility/wms/CommonWmsUtil.java
View file @ 6af8c6f1
......@@ -2,12 +2,14 @@ package ibase.webitm.utility.wms;
import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
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.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
......@@ -246,7 +248,7 @@ public class CommonWmsUtil {
}
return hm;
}
public void updateAwmsInterface(ArrayList interfaceArrList,Connection connWms) throws ITMException, SQLException
public void updateAwmsInterface(ArrayList interfaceArrList,String siteCode,Connection connWms) throws ITMException, SQLException
{
System.out.println("Inside updateAwmsInterface");
......@@ -260,37 +262,40 @@ public class CommonWmsUtil {
int caseCount = 0;
Boolean isError = false;
Timestamp tranDateAct = null,expDate = null,mfgDate = null;
Timestamp tranDateAct = null,expDate = null,mfgDate = null,transactionDate = null;;
String tranDate = "",expDt = "",mfgDt = "";
String itemCode = "",lineNo = "",descr = "",unit = "",itemType = "",familyGrp = "",refSer = "",lotNo = "",refId = "",lotSl = "",quantity = "",
palletNo = "",palletStatus = "",lockStat = "",qcType = "",stroPref = "",palletRej = "",palletRejDesc = "",confirmed = "",siteCode = "",
inOut = "",errCod = "",msgStat = "";
palletNo = "",palletStatus = "",lockStat = "",qcType = "",stroPref = "",palletRej = "",palletRejDesc = "",confirmed = "",
inOut = "",errCod = "",msgStat = "",transDate = "",errDesc = "";
String totalQty ,qtyPerArt ;
String transactionId = "",WMSSql = "";
java.sql.Timestamp currDate = new java.sql.Timestamp( System.currentTimeMillis() );
try
{
conn = connDriver.getConnectDB("DriverAWMS");
conn.setAutoCommit(false);
interfaceSql = "INSERT INTO INTERFACE (IN_OUT,ERR_COD,MSG_STAT,TRANS_DT_ACK,TRAN_ID,"
+ "ITEM_CODE,DESCR,UNIT,ITEM_TYPE,FAMILY_GRP,REF_SER,"
+ "LOT_NO,REF_ID,LOT_SL,QUANTITY,EXP_DATE,MFG_DATE,"
+ "PALLET_NO,PALLET_STATUS,LOCK_STAT,QC_TYPE,STRO_PREF,PALLET_REJ,"
+ "PALLET_REJ_DESC,REF_LINE_NO) "
interfaceSql = "INSERT INTO INTERFACE (TRAN_ID,ITEM_CODE,DESCR,UNIT,ITEM_TYPE,"
+ "FAMILY_GRP,IN_OUT,REF_SER,REF_ID,TRAN_DATE,LOT_NO,"
+ "LOT_SL,QUANTITY,QTY_PER_ART,TOTAL_QTY,EXP_DATE,MFG_DATE,"
+ "PALLET_NO,PALLET_STATUS,MSG_STAT,LOCK_STAT,ERR_COD,ERR_DESC,"
+ "QC_TYPE,TRANS_DT_ACK,STRO_PREF,LINE_NO) "
+ "VALUES (?,?,?,?,?,?,"
+ "?,?,?,?,?,?,"
+ "?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?)";
+ "?,?,?,?,?,?,?,?,?)";
WMSSql = "INSERT INTO INTERFACE2 (IN_OUT,ERR_COD,MSG_STAT,TRANS_DT_ACK,TRAN_ID,"
+ "ITEM_CODE,DESCR,UNIT,ITEM_TYPE,FAMILY_GRP,REF_SER,"
+ "LOT_NO,REF_ID,LOT_SL,QUANTITY,EXP_DATE,MFG_DATE,"
+ "PALLET_NO,PALLET_STATUS,LOCK_STAT,QC_TYPE,STRO_PREF,PALLET_REJ,"
+ "PALLET_REJ_DESC,REF_LINE_NO) "
WMSSql = "INSERT INTO INTERFACE2 (TRAN_ID,ITEM_CODE,DESCR,UNIT,ITEM_TYPE,"
+ "FAMILY_GRP,IN_OUT,REF_SER,REF_ID,TRAN_DATE,LOT_NO,"
+ "LOT_SL,QUANTITY,QTY_PER_ART,TOTAL_QTY,EXP_DATE,MFG_DATE,"
+ "PALLET_NO,PALLET_STATUS,MSG_STAT,LOCK_STAT,ERR_COD,ERR_DESC,"
+ "QC_TYPE,TRANS_DT_ACK,STRO_PREF,LINE_NO) "
+ "VALUES (?,?,?,?,?,?,"
+ "?,?,?,?,?,?,"
+ "?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?)";
+ "?,?,?,?,?,?,?,?,?)";
Iterator itr=interfaceArrList.iterator();
......@@ -302,6 +307,9 @@ public class CommonWmsUtil {
detail = (HashMap) itr.next();
transactionId = generateTranTd("w_interface2", currDate.toString(), siteCode, connWms);
System.out.println("interface2TranId ::::::::::::: " + transactionId);
inOut = (String) detail.get("IN_OUT");
errCod = (String) detail.get("ERR_COD");
msgStat = (String) detail.get("MSG_STAT");
......@@ -313,7 +321,14 @@ public class CommonWmsUtil {
tranDateAct = Timestamp.valueOf((String) detail.get("TRANS_DT_ACK"));
}
transactionId = (String) detail.get("TRAN_ID");
transDate = (String) detail.get("TRAN_DATE");
System.out.println("Tran Date is="+tranDate);
if(transDate != null && transDate.trim().length() > 0 && !transDate.equals("null"))
{
transactionDate = Timestamp.valueOf((String) detail.get("TRAN_DATE"));
}
//transactionId = (String) detail.get("TRAN_ID");
itemCode = (String) detail.get("ITEM_CODE");
descr = (String) detail.get("DESCR");
unit = (String) detail.get("UNIT");
......@@ -338,70 +353,73 @@ public class CommonWmsUtil {
{
mfgDate = Timestamp.valueOf((String) detail.get("MFG_DATE"));
}
//expDate = (Timestamp) detail.get("EXP_DATE");
//mfgDate = (Timestamp) detail.get("MFG_DATE");
palletNo = (String) detail.get("PALLET_NO");
palletStatus = (String) detail.get("PALLET_STATUS");
lockStat = (String) detail.get("LOCK_STAT");
qcType = (String) detail.get("QC_TYPE");
stroPref = (String) detail.get("STRO_PREF");
palletRej = (String) detail.get("PALLET_REJ");
palletRejDesc = (String) detail.get("PALLET_REJ_DESC");
lineNo = (String) detail.get("REF_LINE_NO");
lockStat = (String) detail.get("LOCK_STAT");
qtyPerArt = (String) detail.get("QTY_PER_ART");
totalQty = (String) detail.get("TOTAL_QTY");
lineNo = (String) detail.get("LINE_NO");
interfacePstmt = conn.prepareStatement(interfaceSql);
interfacePstmt.setString(1, inOut);
interfacePstmt.setString(2, errCod);
interfacePstmt.setString(3, msgStat);
interfacePstmt.setTimestamp(4, tranDateAct);
interfacePstmt.setString(5, transactionId);
interfacePstmt.setString(6, itemCode);
interfacePstmt.setString(7, descr);
interfacePstmt.setString(8, unit);
interfacePstmt.setString(9, itemType);
interfacePstmt.setString(10, familyGrp);
interfacePstmt.setString(11, refSer);
interfacePstmt.setString(12, lotNo);
interfacePstmt.setString(13, refId);
interfacePstmt.setString(14, lotSl);
interfacePstmt.setString(15, quantity);
interfacePstmt.setString(1, transactionId);
interfacePstmt.setString(2, itemCode);
interfacePstmt.setString(3, descr);
interfacePstmt.setString(4, unit);
interfacePstmt.setString(5, itemType);
interfacePstmt.setString(6, familyGrp);
interfacePstmt.setString(7, inOut);
interfacePstmt.setString(8, refSer);
interfacePstmt.setString(9, refId);
interfacePstmt.setTimestamp(10, transactionDate);
interfacePstmt.setString(11, lotNo);
interfacePstmt.setString(12, lotSl);
interfacePstmt.setString(13, quantity);
interfacePstmt.setString(14, qtyPerArt);
interfacePstmt.setString(15, totalQty);
interfacePstmt.setTimestamp(16, expDate);
interfacePstmt.setTimestamp(17, mfgDate);
interfacePstmt.setString(18, palletNo);
interfacePstmt.setString(19, palletStatus);
interfacePstmt.setString(20, lockStat);
interfacePstmt.setString(21, qcType);
interfacePstmt.setString(22, stroPref);
interfacePstmt.setString(23, palletRej);
interfacePstmt.setString(24, palletRejDesc);
interfacePstmt.setString(25, lineNo);
interfacePstmt.setString(20, msgStat);
interfacePstmt.setString(21, lockStat);
interfacePstmt.setString(22, errCod);
interfacePstmt.setString(23, errDesc);
interfacePstmt.setString(24, qcType);
interfacePstmt.setTimestamp(25, tranDateAct);
interfacePstmt.setString(26, stroPref);
interfacePstmt.setString(27, lineNo);
interfaceWmsPstmt = connWms.prepareStatement(WMSSql);
interfaceWmsPstmt.setString(1, inOut);
interfaceWmsPstmt.setString(2, errCod);
interfaceWmsPstmt.setString(3, msgStat);
interfaceWmsPstmt.setTimestamp(4, tranDateAct);
interfaceWmsPstmt.setString(5, transactionId);
interfaceWmsPstmt.setString(6, itemCode);
interfaceWmsPstmt.setString(7, descr);
interfaceWmsPstmt.setString(8, unit);
interfaceWmsPstmt.setString(9, itemType);
interfaceWmsPstmt.setString(10, familyGrp);
interfaceWmsPstmt.setString(11, refSer);
interfaceWmsPstmt.setString(12, lotNo);
interfaceWmsPstmt.setString(13, refId);
interfaceWmsPstmt.setString(14, lotSl);
interfaceWmsPstmt.setString(15, quantity);
interfaceWmsPstmt.setString(1, transactionId);
interfaceWmsPstmt.setString(2, itemCode);
interfaceWmsPstmt.setString(3, descr);
interfaceWmsPstmt.setString(4, unit);
interfaceWmsPstmt.setString(5, itemType);
interfaceWmsPstmt.setString(6, familyGrp);
interfaceWmsPstmt.setString(7, inOut);
interfaceWmsPstmt.setString(8, refSer);
interfaceWmsPstmt.setString(9, refId);
interfaceWmsPstmt.setTimestamp(10, transactionDate);
interfaceWmsPstmt.setString(11, lotNo);
interfaceWmsPstmt.setString(12, lotSl);
interfaceWmsPstmt.setString(13, quantity);
interfaceWmsPstmt.setString(14, qtyPerArt);
interfaceWmsPstmt.setString(15, totalQty);
interfaceWmsPstmt.setTimestamp(16, expDate);
interfaceWmsPstmt.setTimestamp(17, mfgDate);
interfaceWmsPstmt.setString(18, palletNo);
interfaceWmsPstmt.setString(19, palletStatus);
interfaceWmsPstmt.setString(20, lockStat);
interfaceWmsPstmt.setString(21, qcType);
interfaceWmsPstmt.setString(22, stroPref);
interfaceWmsPstmt.setString(23, palletRej);
interfaceWmsPstmt.setString(24, palletRejDesc);
interfaceWmsPstmt.setString(25, lineNo);
interfaceWmsPstmt.setString(20, msgStat);
interfaceWmsPstmt.setString(21, lockStat);
interfaceWmsPstmt.setString(22, errCod);
interfaceWmsPstmt.setString(23, errDesc);
interfaceWmsPstmt.setString(24, qcType);
interfaceWmsPstmt.setTimestamp(25, tranDateAct);
interfaceWmsPstmt.setString(26, stroPref);
interfaceWmsPstmt.setString(27, lineNo);
caseCount = interfaceWmsPstmt.executeUpdate();
interfaceWmsPstmt.close(); interfaceWmsPstmt = null;
......@@ -443,4 +461,307 @@ public class CommonWmsUtil {
return input.trim();
}
//Changed by wasim on 09-10-15 to for AWMS interface2 table [END]
// Changed by Sneha on 23-10-2015, for generation of transaction id [start]
private String generateTranTd( String windowName, String tranDate, String siteCode, Connection conn )throws ITMException, SQLException
{
System.out.println("inside generateTranTd@@.........");
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "";
String tranId = "";
String tranSer1 = "",keyString = "",keyCol = "";
CommonConstants commonConstants = new CommonConstants();
try
{
sql = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, windowName);
rs = pstmt.executeQuery();
System.out.println("keyString :"+sql);
if (rs.next())
{
keyString = rs.getString(1);
keyCol = rs.getString(2);
tranSer1 = rs.getString(3);
}
else
{
sql = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "GENERAL");
rs = pstmt.executeQuery();
System.out.println("keyString :"+sql);
if (rs.next())
{
keyString = rs.getString(1);
keyCol = rs.getString(2);
tranSer1 = rs.getString(3);
}
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("keyString :"+keyString);
System.out.println("keyCol :"+keyCol);
System.out.println("tranSer1 :"+tranSer1);
String xmlValues = "";
xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
xmlValues = xmlValues + "<Header></Header>";
xmlValues = xmlValues + "<Detail1>";
xmlValues = xmlValues + "<tran_id></tran_id>";
xmlValues = xmlValues + "<site_code>" + siteCode + "</site_code>";
xmlValues = xmlValues + "<tran_date>"+ tranDate + "</tran_date>";
xmlValues = xmlValues + "<tran_type>"+"U"+"</tran_type>";
xmlValues = xmlValues + "</Detail1></Root>";
System.out.println("xmlValues :["+xmlValues+"]");
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", commonConstants.DB_NAME);
tranId = tg.generateTranSeqID(tranSer1, keyCol, keyString, conn);
System.out.println("tranId ::"+tranId);
}
catch (SQLException ex)
{
System.out.println("Exception ::" +sql+ ex.getMessage() + ":");
ex.printStackTrace();
throw new ITMException(ex);
}
catch (Exception e)
{
System.out.println("Exception ::" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
finally
{
if(rs!=null)
{
rs.close();
rs = null;
}
if(pstmt!=null)
{
pstmt.close();
pstmt = null;
}
}
return tranId;
}
public HashMap getItemVoumeMap(String itemCode,String lotNo,Connection con)throws Exception
{
double packSize = 0,itemSize = 0,lotSize = 0;
PreparedStatement pstmt = null;
String sql="",hazardous = "";
String harmonizCode = "",harmonizDescr = "",originCountry = "";
ResultSet rs = null;
double itmLen = 0,itmWidth = 0,itmHeight = 0,itemWeight = 0,lotLen = 0 ,lotHeight = 0,lotWidth = 0,lotWeight = 0;
HashMap dataVolumeMap = new HashMap();
try
{
System.out.println("@@LOT NO["+lotNo+"]");
sql = "SELECT I.LENGTH ITEM_LEN,I.WIDTH ITEM_WID,I.HEIGHT ITEM_HEIGHT,I.GROSS_WEIGHT ITEM_WEIGHT,I.HAZARDOUS HAZARD, "
+" I.HARMONIZATION_NO HARMONIZATION_NO,I.HARMONIZATION_DESCR HARMONIZATION_DESCR,I.COUNT_CODE__MFG ORIGIN_COUNTRY,"
+" L.LENGTH LITEM_LEN,L.WIDTH LITEM_WID,L.HEIGHT LITEM_HEIGHT,L.SHIPPER_SIZE SHIPSIZE,L.GROSS_WEIGHT LOT_WEIGHT FROM"
+" ITEM I,ITEM_LOT_PACKSIZE L"
+" WHERE I.ITEM_CODE = L.ITEM_CODE"
+" AND L.LOT_NO__FROM <= ? AND L.LOT_NO__TO >= ?"
+" AND I.ITEM_CODE = ?";
pstmt = con.prepareStatement(sql);
if(lotNo != null && (lotNo.trim()).length() > 0)
{
pstmt.setString(1, lotNo);
pstmt.setString(2, lotNo);
}
else
{
return dataVolumeMap = getItemVoumeMap(itemCode, con);
}
pstmt.setString(3, itemCode);
rs = pstmt.executeQuery();
if(rs.next())
{
itmLen = rs.getDouble("ITEM_LEN");
itmWidth = rs.getDouble("ITEM_WID");
itmHeight = rs.getDouble("ITEM_HEIGHT");
itemWeight = rs.getDouble("ITEM_WEIGHT");
hazardous = rs.getString("HAZARD");
lotLen = rs.getDouble("LITEM_LEN");
lotWidth = rs.getDouble("LITEM_WID");
lotHeight = rs.getDouble("LITEM_HEIGHT");
packSize = rs.getDouble("SHIPSIZE");
lotWeight = rs.getDouble("LOT_WEIGHT");
harmonizCode = rs.getString("HARMONIZATION_NO");
harmonizDescr = rs.getString("HARMONIZATION_DESCR");
originCountry = rs.getString("ORIGIN_COUNTRY");
}
itemSize = itmLen * itmWidth * itmHeight;
lotSize = lotHeight * lotWidth * lotLen;
dataVolumeMap.put("PACK_SIZE", packSize);
dataVolumeMap.put("ITEM_SIZE", itemSize);
dataVolumeMap.put("LOT_SIZE", lotSize);
dataVolumeMap.put("HAZARDOUS", hazardous);
dataVolumeMap.put("ITEM_WEIGHT", itemWeight);
dataVolumeMap.put("PACK_WEIGHT", lotWeight);
dataVolumeMap.put("HARMONIZATION_NO", harmonizCode);
dataVolumeMap.put("HARMONIZATION_DESCR", harmonizDescr);
dataVolumeMap.put("ORIGIN_COUNTRY", originCountry);
dataVolumeMap.put("ITEM_LEN", itmLen);
dataVolumeMap.put("ITEM_WID", itmWidth);
dataVolumeMap.put("ITEM_HEIGHT", itmHeight);
dataVolumeMap.put("LITEM_LEN", lotLen);
dataVolumeMap.put("LITEM_WID", lotWidth);
dataVolumeMap.put("LITEM_HEIGHT", lotHeight);
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
} catch (Exception e) {
throw e;
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch(Exception e)
{
throw e;
}
}
return dataVolumeMap;
}
private HashMap getItemVoumeMap(String itemCode,Connection con)throws Exception
{
double packSize = 0,itemSize = 0,lotSize = 0;
PreparedStatement pstmt = null;
String sql="",hazardous = "";
String harmonizCode = "",harmonizDescr = "",originCountry = "";
ResultSet rs = null;
double itmLen = 0,itmWidth = 0,itmHeight = 0,itemWeight = 0,lotLen = 0 ,lotHeight = 0,lotWidth = 0,lotWeight = 0;
HashMap dataVolumeMap = new HashMap();
System.out.println("As Lot No Passed as Blank Calling Override method for getItemVoumeMap");
try
{
sql = "SELECT I.LENGTH ITEM_LEN,I.WIDTH ITEM_WID,I.HEIGHT ITEM_HEIGHT,I.GROSS_WEIGHT ITEM_WEIGHT,I.HAZARDOUS HAZARD, "
+" I.HARMONIZATION_NO HARMONIZATION_NO,I.HARMONIZATION_DESCR HARMONIZATION_DESCR,I.COUNT_CODE__MFG ORIGIN_COUNTRY,"
+" L.LENGTH LITEM_LEN,L.WIDTH LITEM_WID,L.HEIGHT LITEM_HEIGHT,L.SHIPPER_SIZE SHIPSIZE,L.GROSS_WEIGHT LOT_WEIGHT FROM"
+" ITEM I,ITEM_LOT_PACKSIZE L"
+" WHERE I.ITEM_CODE = L.ITEM_CODE"
+" AND L.LOT_NO__TO IN (SELECT MAX(LOT_NO__TO) FROM ITEM_LOT_PACKSIZE WHERE ITEM_CODE = ?)"
+" AND I.ITEM_CODE = ?";
pstmt = con.prepareStatement(sql);
pstmt.setString(1, itemCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if(rs.next())
{
itmLen = rs.getDouble("ITEM_LEN");
itmWidth = rs.getDouble("ITEM_WID");
itmHeight = rs.getDouble("ITEM_HEIGHT");
itemWeight = rs.getDouble("ITEM_WEIGHT");
hazardous = rs.getString("HAZARD");
lotLen = rs.getDouble("LITEM_LEN");
lotWidth = rs.getDouble("LITEM_WID");
lotHeight = rs.getDouble("LITEM_HEIGHT");
packSize = rs.getDouble("SHIPSIZE");
lotWeight = rs.getDouble("LOT_WEIGHT");
harmonizCode = rs.getString("HARMONIZATION_NO");
harmonizDescr = rs.getString("HARMONIZATION_DESCR");
originCountry = rs.getString("ORIGIN_COUNTRY");
}
itemSize = itmLen * itmWidth * itmHeight;
lotSize = lotHeight * lotWidth * lotLen;
dataVolumeMap.put("PACK_SIZE", packSize);
dataVolumeMap.put("ITEM_SIZE", itemSize);
dataVolumeMap.put("LOT_SIZE", lotSize);
dataVolumeMap.put("HAZARDOUS", hazardous);
dataVolumeMap.put("ITEM_WEIGHT", itemWeight);
dataVolumeMap.put("PACK_WEIGHT", lotWeight);
dataVolumeMap.put("HARMONIZATION_NO", harmonizCode);
dataVolumeMap.put("HARMONIZATION_DESCR", harmonizDescr);
dataVolumeMap.put("ORIGIN_COUNTRY", originCountry);
dataVolumeMap.put("ITEM_LEN", itmLen);
dataVolumeMap.put("ITEM_WID", itmWidth);
dataVolumeMap.put("ITEM_HEIGHT", itmHeight);
dataVolumeMap.put("LITEM_LEN", lotLen);
dataVolumeMap.put("LITEM_WID", lotWidth);
dataVolumeMap.put("LITEM_HEIGHT", lotHeight);
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
} catch (Exception e) {
throw e;
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch(Exception e)
{
throw e;
}
}
return dataVolumeMap;
}
// Changed by Sneha on 23-10-2015, for generation of transaction id [end]
}
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