Skip to content

B
business-java
Commit 1685f9e6 authored by wansari's avatar wansari
Browse files
Options

W15GSUN003 changed by wasim to update source code 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@99149 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 54732219
Show whitespace changes
Inline Side-by-side
Showing with 678 additions and 300 deletions
webitm-wms/ibase/webitm/utility/wms/ScheduleAWMSInOutTasks.java
View file @ 1685f9e6
...@@ -105,12 +105,16 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -105,12 +105,16 @@ public class ScheduleAWMSInOutTasks implements Schedule
connDriver = null; connDriver = null;
conn.setAutoCommit(false); conn.setAutoCommit(false);
//Changed by wasim on 02-11-15 to change table name from interface to wms_to_host[start] /*sql = "SELECT IN_OUT,ERR_COD,MSG_STAT,TRANS_DT_ACK,TRAN_ID,"
/*sql = "SELECT DISTINCT REF_ID,REF_SER FROM INTERFACE WHERE REF_ID IN " + "ITEM_CODE,DESCR,UNIT,ITEM_TYPE,FAMILY_GRP,REF_SER,"
+ "(SELECT REF_ID FROM INTERFACE2 WHERE SCHEDULE_STATUS IS NULL)";*/ + "LOT_NO,REF_ID,LOT_SL,QUANTITY,NO_ART,EXP_DATE,MFG_DATE,"
+ "PALLET_NO,PALLET_STATUS,LOCK_STAT,QC_TYPE,STRO_PREF,PALLET_REJ,"
+ "PALLET_REJ_DESC,REF_LINE_NO FROM INTERFACE "
+ "WHERE SYSDATE > TRANS_DT_ACK";*/
//sql = "SELECT DISTINCT REF_ID,REF_SER,IN_OUT,MSG_STAT FROM INTERFACE WHERE SYSDATE > TRANS_DT_ACK";
sql = "SELECT DISTINCT REF_ID,REF_SER FROM WMS_TO_HOST WHERE REF_ID IN " sql = "SELECT DISTINCT REF_ID,REF_SER FROM WMS_TO_HOST WHERE REF_ID IN "
+ "(SELECT REF_ID FROM SWMS_TO_AWMS WHERE SCHEDULE_STATUS IS NULL)"; + "(SELECT REF_ID FROM SWMS_TO_AWMS WHERE SCHEDULE_STATUS IS NULL)";
//Changed by wasim on 02-11-15 to change table name from interface to wms_to_host[end]
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) while(rs.next())
...@@ -127,8 +131,6 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -127,8 +131,6 @@ public class ScheduleAWMSInOutTasks implements Schedule
countError = 0; countError = 0;
flag = 0; flag = 0;
/*sqlInf = "SELECT COUNT(*) AS COUNT FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT = 'E' "
+ "AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";*/
sqlInf = "SELECT COUNT(*) AS COUNT FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT = 'E' " sqlInf = "SELECT COUNT(*) AS COUNT FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT = 'E' "
+ "AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)"; + "AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";
interfacePstmt = conn.prepareStatement(sqlInf); interfacePstmt = conn.prepareStatement(sqlInf);
...@@ -222,18 +224,18 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -222,18 +224,18 @@ public class ScheduleAWMSInOutTasks implements Schedule
private String stockTransfer(HashMap interfaceMap,String xtraParams,Connection conn) throws SQLException, ITMException private String stockTransfer(HashMap interfaceMap,String xtraParams,Connection conn) throws SQLException, ITMException
{ {
PreparedStatement pstmt=null, pstmtHdr = null, pstmtDet = null,pstmtInterface = null,pstmtUpdate = null; PreparedStatement pstmt=null, pstmtHdr = null, pstmtDet = null,pstmtInterface = null,pstmtUpdate = null,pstmtDso = null;
ResultSet rs = null,rsInterface = null; ResultSet rs = null,rsInterface = null,rsDso = null;
String sql = "",insertSql = "",tranID = "",loginSiteCode = "",userId = "",errString = "",sqlInterface = "",sqlUpdate = ""; String sql = "",insertSql = "",tranID = "",loginSiteCode = "",userId = "",errString = "",sqlInterface = "",sqlUpdate = "",sqlDso = "";
String refSer = "",refId = "",noArt = "",itemCode = "",lotNo = "",lotSl = "",acctCodeInv = "",cctrCodeInv = "", String refSer = "",refId = "",noArt = "",itemCode = "",lotNo = "",lotSl = "",acctCodeInv = "",cctrCodeInv = "",
palletNo = "",locCodeTo = "",locCodeFrom = "",siteCode = "",lineNoInterface = ""; palletNo = "",locCodeTo = "",locCodeFrom = "",siteCode = "",lineNoInterface = "";
Double quantity = 0d; Double quantity = 0d;
int updCnt = 0,lineNo = 0; int updCnt = 0,lineNo = 0,countDso = 0;
HashMap hashMap = new HashMap(); //HashMap hashMap = new HashMap();
loginSiteCode = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" ); loginSiteCode = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" );
userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" ); userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
...@@ -244,6 +246,8 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -244,6 +246,8 @@ public class ScheduleAWMSInOutTasks implements Schedule
ArrayList lineNoList = new ArrayList(); ArrayList lineNoList = new ArrayList();
ArrayList tranIdList = new ArrayList(); ArrayList tranIdList = new ArrayList();
ArrayList allocList = new ArrayList();
ArrayList tranIdIssList = new ArrayList();
boolean isRecordExist = false; boolean isRecordExist = false;
try try
...@@ -264,10 +268,32 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -264,10 +268,32 @@ public class ScheduleAWMSInOutTasks implements Schedule
lineNoInterface = lineNoInterface.substring( lineNoInterface.length()-3 );*/ lineNoInterface = lineNoInterface.substring( lineNoInterface.length()-3 );*/
if("D-SO".equalsIgnoreCase(refSer)) if("D-SO".equalsIgnoreCase(refSer))
{
sqlDso = "SELECT COUNT(*) AS COUNT FROM DISTORDER_ALLOC WHERE DIST_ORDER = ?";
pstmtDso = conn.prepareStatement(sqlDso);
pstmtDso.setString(1, refId);
rsDso = pstmtDso.executeQuery();
if(rsDso.next())
{
countDso = rsDso.getInt("COUNT");
}
if(pstmtDso != null){pstmtDso.close();pstmtDso = null;}
if(rsDso != null){rsDso.close();rsDso = null;}
System.out.println("Count DSO ="+countDso);
if(countDso == 0)
{
sql = "SELECT D.TRAN_ID,D.ITEM_CODE,D.LINE_NO,D.QUANTITY,D.LOT_NO,D.LOT_SL,D.LOC_CODE,H.SITE_CODE"
+" FROM DISTORD_ISSDET D,DISTORD_ISS H WHERE D.TRAN_ID = H.TRAN_ID AND H.CONFIRMED = 'N' AND D.DIST_ORDER = ?"
+ "AND D.LINE_NO = ? AND D.QUANTITY > 0";
}
else
{ {
sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,QTY_ALLOC,UNIT,LOT_NO,LOT_SL,MFG_DATE,EXP_DATE,LOC_CODE,SITE_CODE__MFG AS SITE_CODE" sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,QTY_ALLOC,UNIT,LOT_NO,LOT_SL,MFG_DATE,EXP_DATE,LOC_CODE,SITE_CODE__MFG AS SITE_CODE"
+ " FROM DISTORDER_ALLOC WHERE DIST_ORDER = ? AND LINE_NO = ? AND QUANTITY > 0"; + " FROM DISTORDER_ALLOC WHERE DIST_ORDER = ? AND LINE_NO = ? AND QUANTITY > 0";
} }
}
else if("S-ORD".equalsIgnoreCase(refSer)) else if("S-ORD".equalsIgnoreCase(refSer))
{ {
sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,QTY_ALLOC,UNIT__STD AS UNIT,LOT_NO,LOT_SL,MFG_DATE,EXP_DATE,LOC_CODE,SITE_CODE " sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,QTY_ALLOC,UNIT__STD AS UNIT,LOT_NO,LOT_SL,MFG_DATE,EXP_DATE,LOC_CODE,SITE_CODE "
...@@ -293,8 +319,6 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -293,8 +319,6 @@ public class ScheduleAWMSInOutTasks implements Schedule
pstmtDet = conn.prepareStatement(insertSql); pstmtDet = conn.prepareStatement(insertSql);
/*sqlInterface = "SELECT LINE_NO FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT != 'E'"
+ " AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";*/
sqlInterface = "SELECT LINE_NO FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT != 'E'" sqlInterface = "SELECT LINE_NO FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT != 'E'"
+ " AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)"; + " AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";
pstmtInterface = conn.prepareStatement(sqlInterface); pstmtInterface = conn.prepareStatement(sqlInterface);
...@@ -312,7 +336,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -312,7 +336,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
lineNoInterface = " " + lineNoInterface; lineNoInterface = " " + lineNoInterface;
lineNoInterface = lineNoInterface.substring( lineNoInterface.length()-3 ); lineNoInterface = lineNoInterface.substring( lineNoInterface.length()-3 );
lineNoList.add(lineNoInterface); //lineNoList.add(lineNoInterface);
if(headerFlag) if(headerFlag)
{ {
...@@ -345,6 +369,8 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -345,6 +369,8 @@ public class ScheduleAWMSInOutTasks implements Schedule
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) while(rs.next())
{ {
lineNoList.add(lineNoInterface);
isRecordExist = true; isRecordExist = true;
itemCode = checkNullAndTrim(rs.getString("ITEM_CODE")); itemCode = checkNullAndTrim(rs.getString("ITEM_CODE"));
quantity = rs.getDouble("QUANTITY"); quantity = rs.getDouble("QUANTITY");
...@@ -367,6 +393,10 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -367,6 +393,10 @@ public class ScheduleAWMSInOutTasks implements Schedule
else else
{ {
locCodeFrom = checkNullAndTrim(rs.getString("LOC_CODE")); locCodeFrom = checkNullAndTrim(rs.getString("LOC_CODE"));
if(countDso == 0 && "D-SO".equalsIgnoreCase(refSer))
{
tranIdIssList.add(checkNullAndTrim(rs.getString("TRAN_ID")));//Added by wasim on 10-11-2015
}
locCodeTo = distComm.getDisparams("999999",refSer,conn); locCodeTo = distComm.getDisparams("999999",refSer,conn);
} }
System.out.println("Loc code to recieved="+locCodeTo); System.out.println("Loc code to recieved="+locCodeTo);
...@@ -398,7 +428,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -398,7 +428,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
if("PR".equalsIgnoreCase(refSer)) if("PR".equalsIgnoreCase(refSer))
{ {
System.out.println("Going for Allocation"); System.out.println("Going for Allocation");
HashMap hashMap = new HashMap();
hashMap.put("tran_date", new java.sql.Date(System.currentTimeMillis())); hashMap.put("tran_date", new java.sql.Date(System.currentTimeMillis()));
hashMap.put("ref_ser",refSer); hashMap.put("ref_ser",refSer);
hashMap.put("ref_id", tranID); hashMap.put("ref_id", tranID);
...@@ -419,6 +449,27 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -419,6 +449,27 @@ public class ScheduleAWMSInOutTasks implements Schedule
System.out.println("distStkUpd.UpdAllocTrace(HashMap, Connection) : Sucessuful!"); System.out.println("distStkUpd.UpdAllocTrace(HashMap, Connection) : Sucessuful!");
} }
} }
else if("D-SO".equalsIgnoreCase(refSer) || "S-ORD".equalsIgnoreCase(refSer))
{
System.out.println("Going for Allocation");
HashMap hashMap = new HashMap();
hashMap.put("tran_date", new java.sql.Date(System.currentTimeMillis()));
hashMap.put("ref_ser",refSer);
hashMap.put("ref_id", tranID);
hashMap.put("ref_line", String.valueOf(lineNo));
hashMap.put("item_code", itemCode);
hashMap.put("site_code", siteCode);
hashMap.put("loc_code",locCodeTo);
hashMap.put("lot_no",lotNo);
hashMap.put("lot_sl",lotSl);
hashMap.put("alloc_qty", quantity);
hashMap.put("chg_win","W_STOCK_TRANSFER_MULTI");
hashMap.put("chg_user", userId);
hashMap.put("chg_term", chgTerm);
allocList.add(hashMap);
}
sqlUpdate = "UPDATE SWMS_TO_AWMS SET SCHEDULE_STATUS = 'Y' WHERE REF_ID = ? AND LINE_NO = ?"; sqlUpdate = "UPDATE SWMS_TO_AWMS SET SCHEDULE_STATUS = 'Y' WHERE REF_ID = ? AND LINE_NO = ?";
pstmtUpdate = conn.prepareStatement(sqlUpdate); pstmtUpdate = conn.prepareStatement(sqlUpdate);
...@@ -501,12 +552,12 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -501,12 +552,12 @@ public class ScheduleAWMSInOutTasks implements Schedule
if( errString != null && errString.indexOf( "CONFSUCC" ) > -1) if( errString != null && errString.indexOf( "CONFSUCC" ) > -1)
{ {
/*sql = "UPDATE INTERFACE2 SET SCHEDULE_STATUS = 'Y' WHERE REF_ID = ? "; errString = allocStockLocCodeTo(allocList,tranIdIssList,refSer,refId,conn);
pstmt = conn.prepareStatement(sql); System.out.println("Return from alloc To="+errString);
pstmt.setString(1, refId);
int caseCount = pstmt.executeUpdate(); if(errString != null && (errString.indexOf("CONFSTKSUCC") > -1))
System.out.println("Updated ="+caseCount);*/ {
if("D-SO".equalsIgnoreCase(refSer)) if("D-SO".equalsIgnoreCase(refSer) && countDso > 0)//Changed by wasim on 09-11-2015 to add countDso if dist issue required
{ {
System.out.println("Going for Distribution issue"); System.out.println("Going for Distribution issue");
//errString = callDistIssue(refId,xtraParams,conn);//Using club //errString = callDistIssue(refId,xtraParams,conn);//Using club
...@@ -515,9 +566,9 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -515,9 +566,9 @@ public class ScheduleAWMSInOutTasks implements Schedule
errString = callDistIssue(loginSiteCode, refId,lineNoList, xtraParams, conn); errString = callDistIssue(loginSiteCode, refId,lineNoList, xtraParams, conn);
System.out.println("Return from dist issue"+errString); System.out.println("Return from dist issue"+errString);
if( errString != null && errString.indexOf( "VTCONPARM" ) > -1) if( errString != null && (errString.indexOf( "Success" ) > -1 || errString.indexOf( "VTCONPARM" ) > -1))//VTCONPARM
{ {
System.out.println("Despatch/Dist issue created successfully---------"); System.out.println("Distribution issue created successfully---------");
conn.commit(); conn.commit();
} }
else else
...@@ -533,7 +584,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -533,7 +584,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
if( errString != null && errString.indexOf( "VTCONPARM" ) > -1) if( errString != null && errString.indexOf( "VTCONPARM" ) > -1)
{ {
System.out.println("Despatch/Dist issue created successfully and commited"); System.out.println("Despatch created successfully and commited");
conn.commit(); conn.commit();
} }
else else
...@@ -541,9 +592,9 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -541,9 +592,9 @@ public class ScheduleAWMSInOutTasks implements Schedule
throw new Exception (errString); throw new Exception (errString);
} }
} }
else if ("PZ".equalsIgnoreCase(refSer) || "PR".equalsIgnoreCase(refSer)) else if ("PZ".equalsIgnoreCase(refSer) || "D-SO".equalsIgnoreCase(refSer))
{ {
System.out.println("Stock Transfer for PZ/PR completed successfully and committed"); System.out.println("Stock Transfer for PZ/D-SO completed successfully and committed");
conn.commit(); conn.commit();
} }
} }
...@@ -553,6 +604,11 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -553,6 +604,11 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
} }
else else
{
throw new Exception (errString);
}
}
else
{ {
System.out.println("hiii"); System.out.println("hiii");
conn.rollback(); conn.rollback();
...@@ -560,6 +616,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -560,6 +616,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
catch(Exception e) catch(Exception e)
{ {
System.out.println("Stock Transfer Catch Received");
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
...@@ -570,6 +627,8 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -570,6 +627,8 @@ public class ScheduleAWMSInOutTasks implements Schedule
if(pstmtHdr != null){pstmtHdr.close();pstmtHdr = null;} if(pstmtHdr != null){pstmtHdr.close();pstmtHdr = null;}
if(pstmtDet != null){pstmtDet.close();pstmtDet = null;} if(pstmtDet != null){pstmtDet.close();pstmtDet = null;}
if(rs != null){rs.close();rs = null;} if(rs != null){rs.close();rs = null;}
if(pstmtDso != null){pstmtDso.close();pstmtDso = null;}
if(rsDso != null){rsDso.close();rsDso = null;}
} }
catch(Exception ex) catch(Exception ex)
{ {
...@@ -580,11 +639,11 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -580,11 +639,11 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
private String inventoryHold(HashMap interfaceMap,String siteCode, String xtraParams,Connection conn) throws SQLException, ITMException private String inventoryHold(HashMap interfaceMap,String siteCode, String xtraParams,Connection conn) throws SQLException, ITMException
{ {
PreparedStatement pstmt= null,pstmtHold = null,pstmtHolddet = null,pstmtInterface= null,pstmtUpdate = null; PreparedStatement pstmt= null,pstmtHold = null,pstmtHolddet = null,pstmtInterface= null,pstmtUpdate = null,pstmtDso = null;
ResultSet rs = null,rsInterface = null; ResultSet rs = null,rsInterface = null,rsDso = null;
String sql = "",loginSiteCode = "",userId = "",sqlInterface = ""; String sql = "",loginSiteCode = "",userId = "",sqlInterface = "",sqlDso = "";
int updCnt = 0,lineNo = 0,caseCount = 0; int updCnt = 0,lineNo = 0,caseCount = 0,countDso = 0;
String holdInsertSql = "",holddetInsertSql = "",invtranId = "",invLockDetsql = "",errString = "",sqlUpdate = ""; String holdInsertSql = "",holddetInsertSql = "",invtranId = "",invLockDetsql = "",errString = "",sqlUpdate = "";
...@@ -619,10 +678,34 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -619,10 +678,34 @@ public class ScheduleAWMSInOutTasks implements Schedule
pstmtHolddet = conn.prepareStatement(holddetInsertSql); pstmtHolddet = conn.prepareStatement(holddetInsertSql);
if("D-SO".equalsIgnoreCase(refSer)) if("D-SO".equalsIgnoreCase(refSer))
{
/*sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,LOT_NO,LOT_SL,LOC_CODE,SITE_CODE__MFG AS SITE_CODE"
+ " FROM DISTORDER_ALLOC WHERE DIST_ORDER = ? AND LINE_NO = ?";*/
sqlDso = "SELECT COUNT(*) AS COUNT FROM DISTORDER_ALLOC WHERE DIST_ORDER = ?";
pstmtDso = conn.prepareStatement(sqlDso);
pstmtDso.setString(1, refId);
rsDso = pstmtDso.executeQuery();
if(rsDso.next())
{
countDso = rsDso.getInt("COUNT");
}
if(pstmtDso != null){pstmtDso.close();pstmtDso = null;}
if(rsDso != null){rsDso.close();rsDso = null;}
System.out.println("Count DSO ="+countDso);
if(countDso == 0)
{
sql = "SELECT D.ITEM_CODE,D.LINE_NO,D.QUANTITY,D.LOT_NO,D.LOT_SL,D.LOC_CODE,H.SITE_CODE"
+" FROM DISTORD_ISSDET D,DISTORD_ISS H WHERE D.TRAN_ID = H.TRAN_ID AND H.CONFIRMED = 'N' AND D.DIST_ORDER = ?"
+ "AND D.LINE_NO = ? AND D.QUANTITY > 0";
}
else
{ {
sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,LOT_NO,LOT_SL,LOC_CODE,SITE_CODE__MFG AS SITE_CODE" sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,LOT_NO,LOT_SL,LOC_CODE,SITE_CODE__MFG AS SITE_CODE"
+ " FROM DISTORDER_ALLOC WHERE DIST_ORDER = ? AND LINE_NO = ?"; + " FROM DISTORDER_ALLOC WHERE DIST_ORDER = ? AND LINE_NO = ?";
} }
}
else if("S-ORD".equalsIgnoreCase(refSer)) else if("S-ORD".equalsIgnoreCase(refSer))
{ {
sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,LOT_NO,LOT_SL,LOC_CODE," sql = "SELECT ITEM_CODE,LINE_NO,QUANTITY,LOT_NO,LOT_SL,LOC_CODE,"
...@@ -643,8 +726,6 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -643,8 +726,6 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
/*sqlInterface = "SELECT LINE_NO FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT = 'E'"
+ "AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";*/
sqlInterface = "SELECT LINE_NO FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT = 'E'" sqlInterface = "SELECT LINE_NO FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT = 'E'"
+ "AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)"; + "AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";
pstmtInterface = conn.prepareStatement(sqlInterface); pstmtInterface = conn.prepareStatement(sqlInterface);
...@@ -1493,7 +1574,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1493,7 +1574,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
System.out.println("inside isstock count:"+count+"issToBeGenerated:"+issToBeGenerated+"unConf:"+unConf); System.out.println("inside isstock count:"+count+"issToBeGenerated:"+issToBeGenerated+"unConf:"+unConf);
return count > 0 && issToBeGenerated && unConf == 0; return count > 0 && issToBeGenerated && unConf == 0;
}*/ }*/
private String callDistIssue(String loginSiteCode, String refId, ArrayList lineNoList,String xtraParams,Connection conn) throws ITMException, Exception private String callDistIssue(String loginSiteCode, String distOrderNo, ArrayList lineNoList,String xtraParams,Connection conn) throws ITMException, Exception
{ {
String result = ""; String result = "";
PreparedStatement pstmt=null; PreparedStatement pstmt=null;
...@@ -1506,7 +1587,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1506,7 +1587,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
sql = "SELECT TRAN_ID FROM DISTORD_ISS WHERE DIST_ORDER = ? AND CONFIRMED = 'N'"; sql = "SELECT TRAN_ID FROM DISTORD_ISS WHERE DIST_ORDER = ? AND CONFIRMED = 'N'";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, refId); pstmt.setString(1, distOrderNo);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
...@@ -1517,18 +1598,19 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1517,18 +1598,19 @@ public class ScheduleAWMSInOutTasks implements Schedule
if(existTranId != null && existTranId.length() > 0) if(existTranId != null && existTranId.length() > 0)
{ {
result = createDistIssue(loginSiteCode, "<Root><TranID>" + refId + "</TranID></Root>" , lineNoList, existTranId, false, xtraParams, conn); result = createDistIssue(loginSiteCode, distOrderNo , lineNoList, existTranId, false, xtraParams, conn);
} }
else else
{ {
//result = createDistIssue(loginSiteCode, "<Root><TranID>" + refId + "</TranID></Root>" , lineNoList, existTranId ,false, xtraParams, conn); //result = createDistIssue(loginSiteCode, "<Root><TranID>" + refId + "</TranID></Root>" , lineNoList, existTranId ,false, xtraParams, conn);
CreateDistIssue disIssue = new CreateDistIssue();//VTCONPARM //CreateDistIssue disIssue = new CreateDistIssue();//VTCONPARM
result = disIssue.createDistIssue(loginSiteCode, "<Root><TranID>" + refId + "</TranID></Root>", xtraParams, conn); //result = disIssue.createDistIssue(loginSiteCode, "<Root><TranID>" + distOrderNo + "</TranID></Root>", xtraParams, conn);
result = createDistIssue(loginSiteCode, distOrderNo , lineNoList, existTranId, true, xtraParams, conn);
} }
} }
catch(Exception e) catch(Exception e)
{ {
e.printStackTrace(); System.out.println("callDistIssue Catch Received");
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
...@@ -1546,7 +1628,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1546,7 +1628,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
return result; return result;
} }
public String createDistIssue(String siteCode, String xmlString, ArrayList lineNoList, String tranId, boolean headerFlag, String xtraParams, Connection conn) throws RemoteException, ITMException public String createDistIssue(String siteCode, String distOrderNo, ArrayList lineNoList, String tranId, boolean headerFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{ {
StringBuffer xmlBuff = new StringBuffer(); StringBuffer xmlBuff = new StringBuffer();
...@@ -1555,7 +1637,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1555,7 +1637,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
StringBuffer detail2xml = new StringBuffer(); StringBuffer detail2xml = new StringBuffer();
StringBuffer xmldetail2ftr = new StringBuffer(); StringBuffer xmldetail2ftr = new StringBuffer();
xmldetail2ftr.append("</Detail2>"); xmldetail2ftr.append("</Detail2>");
String distOrderNo = null; //String distOrderNo = null;
String sql = null; String sql = null;
String tranDate = null; String tranDate = null;
String locCode = null; String locCode = null;
...@@ -1598,10 +1680,16 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1598,10 +1680,16 @@ public class ScheduleAWMSInOutTasks implements Schedule
Timestamp today = new Timestamp(System.currentTimeMillis()); Timestamp today = new Timestamp(System.currentTimeMillis());
int lineNoIssDet = 0; int lineNoIssDet = 0;
int distCount = 0; int distCount = 0;
double totalGrossWeight = 0, totalTareWeight = 0, totalNetWeight = 0;
int totalNoArt = 0;
String sqlHdr = "",sqlDist = "";
PreparedStatement pstmtHdr = null;
try try
{ {
SimpleDateFormat sdf = new SimpleDateFormat(this.genericUtility.getApplDateFormat()); SimpleDateFormat sdf = new SimpleDateFormat(this.genericUtility.getApplDateFormat());
SimpleDateFormat dbf = new SimpleDateFormat(this.genericUtility.getDBDateFormat());
if (conn == null) if (conn == null)
{ {
System.out.println("Inside creating connection"); System.out.println("Inside creating connection");
...@@ -1610,16 +1698,15 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1610,16 +1698,15 @@ public class ScheduleAWMSInOutTasks implements Schedule
connDriver = null; connDriver = null;
conn.setAutoCommit(false); conn.setAutoCommit(false);
} }
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); //ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
DistCommon disCommon = new DistCommon(); //DistCommon disCommon = new DistCommon();
ByteArrayInputStream bais = new ByteArrayInputStream(xmlString.getBytes()); /*ByteArrayInputStream bais = new ByteArrayInputStream(xmlString.getBytes());
Document dom = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(bais); Document dom = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(bais);
NodeList parent = dom.getElementsByTagName("TranID"); NodeList parent = dom.getElementsByTagName("TranID");
distOrderNo = parent.item(0).getFirstChild().getNodeValue(); distOrderNo = parent.item(0).getFirstChild().getNodeValue();*/
tranDate = getCurrdateAppFormat(); tranDate = getCurrdateAppFormat();
/*this.isAutoConfirm = disCommon.getDisparams("999999", "AUTO_DIST_ISS_CONFIRM", conn); /*this.isAutoConfirm = disCommon.getDisparams("999999", "AUTO_DIST_ISS_CONFIRM", conn);
if ((this.isAutoConfirm != null) && (this.isAutoConfirm.trim().length() > 0)) if ((this.isAutoConfirm != null) && (this.isAutoConfirm.trim().length() > 0))
{ {
this.isAutoConfirm = this.isAutoConfirm.substring(0, 1); this.isAutoConfirm = this.isAutoConfirm.substring(0, 1);
...@@ -1627,20 +1714,38 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1627,20 +1714,38 @@ public class ScheduleAWMSInOutTasks implements Schedule
else else
{ {
this.isAutoConfirm = "N"; this.isAutoConfirm = "N";
}*/ }
this.isAutoConfirm = "N";*/
this.isAutoConfirm = "N"; String maxLinesStr = distComm.getDisparams("999999", "MAX_LINES_DIST_ISS", conn);
locCode = distComm.getDisparams("999999", "D-SO", conn);
String maxLinesStr = disCommon.getDisparams("999999", "MAX_LINES_DIST_ISS", conn);
if ((maxLinesStr == null) || (maxLinesStr.trim().length() == 0) || (maxLinesStr.equals("NULLFOUND"))) if ((maxLinesStr == null) || (maxLinesStr.trim().length() == 0) || (maxLinesStr.equals("NULLFOUND")))
{ {
maxLinesStr = "600"; maxLinesStr = "600";
} }
MAXLINESALLOWED = Integer.parseInt(maxLinesStr.trim()); MAXLINESALLOWED = Integer.parseInt(maxLinesStr.trim());
maxLinesStr = null; maxLinesStr = null;
prvDeptCode = "NULL"; prvDeptCode = "NULL";
sql = "SELECT D.DIST_ORDER,D.LINE_NO AS LINE_NO,D.TRAN_ID__DEMAND,D.ITEM_CODE AS ITEM_CODE,D.QTY_ORDER"
if(headerFlag)
{
tranId = createHeader(siteCode, distOrderNo,xtraParams, conn);
}
sql = "SELECT MAX(LINE_NO) AS LINE_NO FROM DISTORD_ISSDET WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
lineNoIssDet = rs.getInt("LINE_NO");
}
rs.close();rs = null;
pstmt.close();pstmt = null;
sqlDist = "SELECT D.DIST_ORDER,D.LINE_NO AS LINE_NO,D.TRAN_ID__DEMAND,D.ITEM_CODE AS ITEM_CODE,D.QTY_ORDER"
+ " AS QTY_ORDER,D.QTY_CONFIRM AS QTY_CONFIRM, D.QTY_RECEIVED AS QTY_RECEIVED,D.QTY_SHIPPED AS" + " AS QTY_ORDER,D.QTY_CONFIRM AS QTY_CONFIRM, D.QTY_RECEIVED AS QTY_RECEIVED,D.QTY_SHIPPED AS"
+ " QTY_SHIPPED,D.DUE_DATE AS DUE_DATE,D.TAX_CLASS AS TAX_CLASS,D.TAX_CHAP AS TAX_CHAP," + " QTY_SHIPPED,D.DUE_DATE AS DUE_DATE,D.TAX_CLASS AS TAX_CLASS,D.TAX_CHAP AS TAX_CHAP,"
+ " D.TAX_ENV AS TAX_ENV,D.UNIT AS UNIT,ITEM.DESCR AS ITEM_DESCR, D.SALE_ORDER AS SALE_ORDER," + " D.TAX_ENV AS TAX_ENV,D.UNIT AS UNIT,ITEM.DESCR AS ITEM_DESCR, D.SALE_ORDER AS SALE_ORDER,"
...@@ -1657,13 +1762,14 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1657,13 +1762,14 @@ public class ScheduleAWMSInOutTasks implements Schedule
+ " AND CASE WHEN D.STATUS IS NULL THEN 'O' ELSE D.STATUS END<>'C' " + " AND CASE WHEN D.STATUS IS NULL THEN 'O' ELSE D.STATUS END<>'C' "
+ " ORDER BY item.dept_code__iss ASC," + " ORDER BY item.dept_code__iss ASC,"
+ " D.LINE_NO ASC "; + " D.LINE_NO ASC ";
pstmt = conn.prepareStatement(sqlDist);
Iterator itr = lineNoList.iterator(); Iterator itr = lineNoList.iterator();
while(itr.hasNext()) while(itr.hasNext())
{ {
lineNoInterface = (String) itr.next(); lineNoInterface = (String) itr.next();
pstmt = conn.prepareStatement(sql); //pstmt = conn.prepareStatement(sql);
pstmt.setString(1, distOrderNo); pstmt.setString(1, distOrderNo);
pstmt.setString(2, lineNoInterface); pstmt.setString(2, lineNoInterface);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -1707,15 +1813,13 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1707,15 +1813,13 @@ public class ScheduleAWMSInOutTasks implements Schedule
System.out.println("prvDeptCode----deptCode--" + prvDeptCode + "----" + deptCode); System.out.println("prvDeptCode----deptCode--" + prvDeptCode + "----" + deptCode);
System.out.println("match dept....................... "); System.out.println("match dept....................... ");
StringBuffer xmldetail2hdr = new StringBuffer();
/*StringBuffer xmldetail2hdr = new StringBuffer();
xmldetail2hdr.append("<Detail2 dbID=\"\" domID=\"1\" objName=\"dist_order_post\" objContext=\"2\">"); xmldetail2hdr.append("<Detail2 dbID=\"\" domID=\"1\" objName=\"dist_order_post\" objContext=\"2\">");
xmldetail2hdr.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\"/>"); xmldetail2hdr.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\"/>");
xmldetail2hdr.append("<tran_id/>"); xmldetail2hdr.append("<tran_id/>");
xmldetail2hdr.append("<dist_order><![CDATA[" + distOrderNo + "]]></dist_order>"); xmldetail2hdr.append("<dist_order><![CDATA[" + distOrderNo + "]]></dist_order>");
xmldetail2hdr.append("<line_no_dist_order><![CDATA[" + rs.getInt("LINE_NO") + "]]></line_no_dist_order>"); xmldetail2hdr.append("<line_no_dist_order><![CDATA[" + rs.getInt("LINE_NO") + "]]></line_no_dist_order>");*/
mLineNoDist = rs.getInt("LINE_NO"); mLineNoDist = rs.getInt("LINE_NO");
unit = rs.getString("UNIT"); unit = rs.getString("UNIT");
...@@ -1726,7 +1830,6 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1726,7 +1830,6 @@ public class ScheduleAWMSInOutTasks implements Schedule
discount = rs.getDouble("DISCOUNT"); discount = rs.getDouble("DISCOUNT");
remQuantity = qtyConfirm - qtyShipped; remQuantity = qtyConfirm - qtyShipped;
//xmldetail2hdr.append(getDetails(siteCode, mLineNoDist, distOrderNo, tranType, conn)); //xmldetail2hdr.append(getDetails(siteCode, mLineNoDist, distOrderNo, tranType, conn));
HashMap getData = new HashMap(); HashMap getData = new HashMap();
getData = getDetails(siteCode, mLineNoDist, distOrderNo, tranType, conn); getData = getDetails(siteCode, mLineNoDist, distOrderNo, tranType, conn);
...@@ -1975,20 +2078,20 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -1975,20 +2078,20 @@ public class ScheduleAWMSInOutTasks implements Schedule
if (count == 0) if (count == 0)
{ {
rate2 = disCommon.pickRate(priceList, tranDate, itemCode, rs1.getString(1), "D", conn); rate2 = distComm.pickRate(priceList, tranDate, itemCode, rs1.getString(1), "D", conn);
} }
else else
{ {
tabValue = siteCode + "~t" + rs1.getString(12) + "~t" + rs1.getString(1) + "~t"; tabValue = siteCode + "~t" + rs1.getString(12) + "~t" + rs1.getString(1) + "~t";
System.out.println("printing tabValue----" + tabValue); System.out.println("printing tabValue----" + tabValue);
rate2 = disCommon.pickRate(priceList, tranDate, itemCode, tabValue, "I", conn); rate2 = distComm.pickRate(priceList, tranDate, itemCode, tabValue, "I", conn);
} }
} }
rate1 = Double.toString(rate2); rate1 = Double.toString(rate2);
} }
System.out.println("My getString3="+rs1.getString(3));
if (Double.parseDouble(rs1.getString(3)) > 0.0D) if (Double.parseDouble(rs1.getString(3)) > 0.0D)
{ {
grossPer = rs1.getDouble(15) / rs1.getDouble(3); grossPer = rs1.getDouble(15) / rs1.getDouble(3);
...@@ -2097,7 +2200,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2097,7 +2200,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
lcFact = 0.0D; lcFact = 0.0D;
ArrayList QtyFactorList = new ArrayList(); ArrayList QtyFactorList = new ArrayList();
QtyFactorList = disCommon.convQtyFactor(unitAlt, unit, itemCode, minputQty, lcFact, conn); QtyFactorList = distComm.convQtyFactor(unitAlt, unit, itemCode, minputQty, lcFact, conn);
lcQtyOrderAlt = ((Double)QtyFactorList.get(1)).doubleValue(); lcQtyOrderAlt = ((Double)QtyFactorList.get(1)).doubleValue();
lcFact = ((Double)QtyFactorList.get(0)).doubleValue(); lcFact = ((Double)QtyFactorList.get(0)).doubleValue();
QtyFactorList = null; QtyFactorList = null;
...@@ -2134,7 +2237,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2134,7 +2237,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
netWt = Double.parseDouble(getFormatedValue(netWt, 3)); netWt = Double.parseDouble(getFormatedValue(netWt, 3));
//xmldetail2stock.append("<net_weight>").append("<![CDATA[").append(netWt).append("]]>").append("</net_weight>\r\n"); //xmldetail2stock.append("<net_weight>").append("<![CDATA[").append(netWt).append("]]>").append("</net_weight>\r\n");
tareWt = Double.parseDouble(getFormatedValue(netWt, 3)); tareWt = Double.parseDouble(getFormatedValue(tareWt, 3));
/*xmldetail2stock.append("<tare_weight>").append("<![CDATA[").append(tareWt).append("]]>").append("</tare_weight>\r\n"); /*xmldetail2stock.append("<tare_weight>").append("<![CDATA[").append(tareWt).append("]]>").append("</tare_weight>\r\n");
xmldetail2stock.append("<pack_instr>").append("<![CDATA[").append(rs1.getString(21) == null ? "" : rs1.getString(21)).append("]]>").append("</pack_instr>\r\n"); xmldetail2stock.append("<pack_instr>").append("<![CDATA[").append(rs1.getString(21) == null ? "" : rs1.getString(21)).append("]]>").append("</pack_instr>\r\n");
...@@ -2158,11 +2261,10 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2158,11 +2261,10 @@ public class ScheduleAWMSInOutTasks implements Schedule
System.out.println("xmlString detail2......" + detail2xml.toString());*/ System.out.println("xmlString detail2......" + detail2xml.toString());*/
///// /////
lotSl = rs1.getString(2); lotSl = rs1.getString(2);
unit = rs1.getString(5); unit = rs1.getString(5);
locCode = rs1.getString(12); //locCode = rs1.getString(12);Changed by wasim on 09-11-2015 to get location code from disparm.
System.out.println("Location code recieved from disparm for despatch="+locCode);
//////// ////////
sqlDistIssDet = "INSERT INTO DISTORD_ISSDET (TRAN_ID,LINE_NO,DIST_ORDER,LINE_NO_DIST_ORDER,ITEM_CODE,QUANTITY,UNIT,TAX_CLASS," sqlDistIssDet = "INSERT INTO DISTORD_ISSDET (TRAN_ID,LINE_NO,DIST_ORDER,LINE_NO_DIST_ORDER,ITEM_CODE,QUANTITY,UNIT,TAX_CLASS,"
+" TAX_CHAP,TAX_ENV,LOC_CODE,LOT_NO,LOT_SL,PACK_CODE,RATE,AMOUNT,TAX_AMT,NET_AMT,SITE_CODE__MFG,MFG_DATE," +" TAX_CHAP,TAX_ENV,LOC_CODE,LOT_NO,LOT_SL,PACK_CODE,RATE,AMOUNT,TAX_AMT,NET_AMT,SITE_CODE__MFG,MFG_DATE,"
...@@ -2174,14 +2276,14 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2174,14 +2276,14 @@ public class ScheduleAWMSInOutTasks implements Schedule
+ "?,?,?,?,?,?,?,?,?,?," + "?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?,?,?,?," + "?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?,?,?,?," + "?,?,?,?,?,?,?,?,?,?,"
+ "?,?"; + "?,?)";
distIssDetPstmt = conn.prepareStatement(sqlDistIssDet); distIssDetPstmt = conn.prepareStatement(sqlDistIssDet);
lineNoIssDet++; lineNoIssDet++;
distIssDetPstmt.setString(1, tranId); distIssDetPstmt.setString(1, tranId);
distIssDetPstmt.setInt(2, lineNoIssDet); distIssDetPstmt.setInt(2, lineNoIssDet);
distIssDetPstmt.setString(3, distOrderNo); distIssDetPstmt.setString(3, distOrderNo);
distIssDetPstmt.setString(4, lineNoInterface); distIssDetPstmt.setInt(4, rs.getInt("LINE_NO"));
distIssDetPstmt.setString(5, itemCode); distIssDetPstmt.setString(5, itemCode);
distIssDetPstmt.setDouble(6, minputQty); distIssDetPstmt.setDouble(6, minputQty);
distIssDetPstmt.setString(7, unit); distIssDetPstmt.setString(7, unit);
...@@ -2197,8 +2299,10 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2197,8 +2299,10 @@ public class ScheduleAWMSInOutTasks implements Schedule
distIssDetPstmt.setDouble(17, 0); distIssDetPstmt.setDouble(17, 0);
distIssDetPstmt.setDouble(18, 0); distIssDetPstmt.setDouble(18, 0);
distIssDetPstmt.setString(19, rs1.getString(7) == null ? "" : rs1.getString(7)); distIssDetPstmt.setString(19, rs1.getString(7) == null ? "" : rs1.getString(7));
distIssDetPstmt.setString(20, rs1.getDate(8) == null ? "" : sdf.format(rs1.getDate(8))); /*distIssDetPstmt.setString(20, rs1.getDate(8) == null ? "" : dbf.format(rs1.getDate(8)));
distIssDetPstmt.setString(21, rs1.getDate(4) == null ? "" : sdf.format(rs1.getDate(4))); distIssDetPstmt.setString(21, rs1.getDate(4) == null ? "" : dbf.format(rs1.getDate(4)));*/
distIssDetPstmt.setTimestamp(20, rs1.getTimestamp(8));
distIssDetPstmt.setTimestamp(21, rs1.getTimestamp(4));
distIssDetPstmt.setString(22, rs1.getString(9) == null ? "" : rs1.getString(9)); distIssDetPstmt.setString(22, rs1.getString(9) == null ? "" : rs1.getString(9));
distIssDetPstmt.setDouble(23, noArt); distIssDetPstmt.setDouble(23, noArt);
distIssDetPstmt.setDouble(24, grossWt); distIssDetPstmt.setDouble(24, grossWt);
...@@ -2209,7 +2313,8 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2209,7 +2313,8 @@ public class ScheduleAWMSInOutTasks implements Schedule
distIssDetPstmt.setString(29, rs1.getString(20) == null ? "" : rs1.getString(20)); distIssDetPstmt.setString(29, rs1.getString(20) == null ? "" : rs1.getString(20));
distIssDetPstmt.setString(30, rs1.getString(13) == null ? "" : rs1.getString(13)); distIssDetPstmt.setString(30, rs1.getString(13) == null ? "" : rs1.getString(13));
distIssDetPstmt.setString(31, rs1.getString(14) == null ? "" : rs1.getString(14)); distIssDetPstmt.setString(31, rs1.getString(14) == null ? "" : rs1.getString(14));
distIssDetPstmt.setString(32, rs1.getDate(19) == null ? "" : sdf.format(rs1.getDate(19))); //distIssDetPstmt.setString(32, rs1.getDate(19) == null ? "" : dbf.format(rs1.getDate(19)));
distIssDetPstmt.setTimestamp(32, rs1.getTimestamp(19));
distIssDetPstmt.setString(33, ""); distIssDetPstmt.setString(33, "");
distIssDetPstmt.setString(34, rateClg); distIssDetPstmt.setString(34, rateClg);
distIssDetPstmt.setDouble(35, discount); distIssDetPstmt.setDouble(35, discount);
...@@ -2240,13 +2345,12 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2240,13 +2345,12 @@ public class ScheduleAWMSInOutTasks implements Schedule
tareWt = 0.0D; tareWt = 0.0D;
netWt = 0.0D; netWt = 0.0D;
} }
rs1.close(); rs1.close();rs1 = null;
rs1 = null; pstmt1.close();pstmt1 = null;
pstmt1.close();
pstmt1 = null;
sql = null; sql = null;
} }
rs.close();rs = null;
pstmt.clearParameters();
/* xmlBuff = null; /* xmlBuff = null;
xmlBuff = new StringBuffer(); xmlBuff = new StringBuffer();
xmldetail1 = createHeader(siteCode, distOrderNo, tranId, headerFlag, xtraParams, conn); xmldetail1 = createHeader(siteCode, distOrderNo, tranId, headerFlag, xtraParams, conn);
...@@ -2272,10 +2376,39 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2272,10 +2376,39 @@ public class ScheduleAWMSInOutTasks implements Schedule
}*/ }*/
}//End ArrayList line number }//End ArrayList line number
sql = "SELECT LINE_NO,GROSS_WEIGHT,TARE_WEIGHT,NET_WEIGHT,NO_ART FROM DISTORD_ISSDET WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
while(rs.next())
{
System.out.println("Line No="+rs.getString("LINE_NO"));
totalGrossWeight = totalGrossWeight + rs.getDouble("GROSS_WEIGHT");
totalTareWeight = totalTareWeight + rs.getDouble("TARE_WEIGHT");
totalNetWeight = totalNetWeight + rs.getDouble("NET_WEIGHT");
totalNoArt = totalNoArt + rs.getInt("NO_ART");
}
rs.close();rs = null;
pstmt.close();pstmt = null;
sqlHdr = "UPDATE DISTORD_ISS SET GROSS_WEIGHT = ?, TARE_WEIGHT = ? ,NET_WEIGHT = ?, NO_ART = ? "
+ "WHERE TRAN_ID = ? ";
pstmtHdr = conn.prepareStatement(sqlHdr);
pstmtHdr.setDouble(1, totalGrossWeight);
pstmtHdr.setDouble(2, totalTareWeight);
pstmtHdr.setDouble(3, totalNetWeight);
pstmtHdr.setInt(4, totalNoArt);
pstmtHdr.setString(5, tranId);
int upctr = pstmtHdr.executeUpdate();
System.out.println("NO OF ROW UPDATED = "+upctr);
pstmtHdr.close();
pstmtHdr = null;
} }
catch (Exception e) catch (Exception e)
{ {
e.printStackTrace(); System.out.println("createDistIssue Catch Recived");
isError = true; isError = true;
throw new ITMException(e); throw new ITMException(e);
} }
...@@ -2291,6 +2424,14 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2291,6 +2424,14 @@ public class ScheduleAWMSInOutTasks implements Schedule
{ {
retString = "VTCONPARM"; retString = "VTCONPARM";
} }
if(pstmt != null){pstmt.close();pstmt = null;}
if(pstmt1 != null){pstmt1.close();pstmt1 = null;}
if(pstmt2 != null){pstmt2.close();pstmt2 = null;}
if(distIssDetPstmt != null){distIssDetPstmt.close();distIssDetPstmt = null;}
if(pstmtHdr != null){pstmtHdr.close();pstmtHdr = null;}
if(rs != null){rs.close();rs = null;}
if(rs1 != null){rs1.close();rs1 = null;}
if(rs2 != null){rs2.close();rs2 = null;}
} }
catch(Exception ex) catch(Exception ex)
{ {
...@@ -2430,16 +2571,17 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2430,16 +2571,17 @@ public class ScheduleAWMSInOutTasks implements Schedule
return s; return s;
} }
public String createHeader(String siteCode, String distOrderNo, String tranId, boolean headerFlag, String xtraParams, Connection conn) public String createHeader(String siteCode, String distOrderNo,String xtraParams, Connection conn)
throws RemoteException, ITMException throws RemoteException, ITMException
{ {
StringBuffer xmlBuffHeader = new StringBuffer(); StringBuffer xmlBuffHeader = new StringBuffer();
String sql = null; String sql = null,sqlInsert = "";
String tranDate = null; //String tranDate = null;
Timestamp tranDate = null;
String locCode = null; String locCode = null;
String retString = ""; String retString = "";
PreparedStatement pstmt = null; PreparedStatement pstmt1 = null; PreparedStatement pstmt2 = null; PreparedStatement pstmt = null; PreparedStatement pstmt1 = null; PreparedStatement pstmt2 = null,distIssHdrPstmt = null;
ResultSet rs = null; ResultSet rs1 = null; ResultSet rs2 = null; ResultSet rs = null; ResultSet rs1 = null; ResultSet rs2 = null;
String lsPackCode = null; String unitAlt = null; String unit = null; String mLotNo = null; String lsPackCode = null; String unitAlt = null; String unit = null; String mLotNo = null;
...@@ -2462,10 +2604,12 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2462,10 +2604,12 @@ public class ScheduleAWMSInOutTasks implements Schedule
String detail2stock = ""; String errString = ""; String taxChap = ""; String siteCodeShip = ""; String detail2stock = ""; String errString = ""; String taxChap = ""; String siteCodeShip = "";
String lotNo = ""; String lotSl = ""; String packCode = ""; String rateClg = ""; String taxEnv = ""; String taxClass = ""; String lotNo = ""; String lotSl = ""; String packCode = ""; String rateClg = ""; String taxEnv = ""; String taxClass = "";
java.util.Date expDate = null; java.util.Date mfgDate = null; java.util.Date chkDate1 = null; java.util.Date expDate = null; java.util.Date mfgDate = null; java.util.Date chkDate1 = null;
int caseCount = 0;
boolean isDetFound = false; boolean isDetFound = false;
String today = "",tranId = "";
try try
{ {
SimpleDateFormat sdf = new SimpleDateFormat(this.genericUtility.getApplDateFormat()); SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
if (conn == null) if (conn == null)
{ {
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
...@@ -2474,23 +2618,47 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2474,23 +2618,47 @@ public class ScheduleAWMSInOutTasks implements Schedule
conn.setAutoCommit(false); conn.setAutoCommit(false);
} }
String userId = this.genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"); System.out.println("Xtra Params in dist issue="+xtraParams);
String chgUser = this.genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"); String userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
String chgTerm = this.genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chgTerm"); String chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
String chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chgTerm");
tranDate = getCurrdateAppFormat();
today = getCurrdateAppFormat();
sql = "SELECT D.DIST_ORDER AS DIST_ORDER,D.ORDER_DATE AS ORDER_DATE,D.SITE_CODE__SHIP AS SITE_CODE__SHIP,D.SITE_CODE__DLV AS SITE_CODE__DLV,D.SHIP_DATE AS SHIP_DATE,D.DUE_DATE AS DUE_DATE,D.REMARKS AS REMARKS, D.DIST_ROUTE AS DIST_ROUTE,D.PRICE_LIST AS PRICE_LIST,D.CONFIRMED AS CONFIRMED,D.CHG_USER AS CHG_USER,D.CHG_TERM AS CHG_TERM,D.TARGET_WGT AS TARGET_WGT,D.TARGET_VOL AS TARGET_VOL,D.LOC_CODE__GIT AS LOC_CODE__GIT, D.CHG_DATE AS CHG_DATE,SITE_A.DESCR AS SITEA_DESCR,SITE_B.DESCR AS SITEB_DESCR,LOCATION.DESCR AS LOCATION_DESCR,D.CONF_DATE AS CONF_DATE,D.SITE_CODE AS SITE_CODE,D.STATUS AS STATUS,D.SALE_ORDER AS SALE_ORDER, D.REMARKS1 AS REMARK1,D.REMARKS2 AS REMARK2,TRIM(D.ORDER_TYPE) AS ORDER_TYPE,SITE_A.ADD1 AS SITEA_ADD1,SITE_A.ADD2 AS SITEA_ADD2,SITE_A.CITY AS SITEA_CITY,SITE_A.PIN AS SITEA_PIN,SITE_A.STATE_CODE AS SITEA_STATE_CODE, SITE_B.ADD1 AS SITEB_ADD1,SITE_B.ADD2 AS SITEB_ADD2,SITE_B.CITY AS SITEB_CITY,SITE_B.PIN AS SITEB_PIN,SITE_B.STATE_CODE AS SITEB_STATE_CODE,D.LOC_CODE__CONS AS LOC_CODE__CONS,D.SUNDRY_TYPE AS SUNDRY_TYPE, D.SUNDRY_CODE AS SUNDRY_CODE,D.AUTO_RECEIPT AS AUTO_RECEIPT,D.TRAN_TYPE AS TRAN_TYPE,D.CURR_CODE AS CURR_CODE,D.EXCH_RATE AS EXCH_RATE,D.SALES_PERS AS SALES_PERS,SALES_PERS.SP_NAME AS SP_NAME, D.LOC_CODE__GITBF AS LOC_CODE__GITBF,D.CUST_CODE__DLV AS CUST_CODE__DLV,D.DLV_TO AS DLV_TO,D.DLV_ADD1 AS DLV_ADD1,D.DLV_ADD2 AS DLV_ADD2,D.DLV_ADD3 AS DLV_ADD3,D.DLV_CITY AS DLV_CITY, D.STATE_CODE__DLV AS STATE_CODE__DLV,D.COUNT_CODE__DLV AS COUNT_CODE__DLV,D.DLV_PIN AS DLV_PIN,D.STAN_CODE AS STAN_CODE,D.TEL1__DLV AS TEL1__DLV,D.TEL2__DLV AS TEL2__DLV,D.TEL3__DLV AS TEL3__DLV, D.FAX__DLV AS FAX__DLV,D.AVALIABLE_YN AS AVALIABLE_YN,D.PURC_ORDER AS PURC_ORDER,D.TOT_AMT AS TOT_AMT,D.TAX_AMT AS TAX_AMT,D.NET_AMT AS NET_AMT,D.TRAN_SER AS TRAN_SER, D.PRICE_LIST__CLG AS PRICE_LIST__CLG,SPACE(25) AS LOC,FN_SUNDRY_NAME(D.SUNDRY_TYPE,D.SUNDRY_CODE,'N') AS SUNDRY_NAME, D.PROJ_CODE AS PROJ_CODE,SITE_C.DESCR AS SITEC_DESCR,D.POLICY_NO AS POLICY_NO,D.LOC_CODE__DAMAGED AS LOC_CODE__DAMAGED,D.SITE_CODE__BIL AS SITE_CODE__BIL,SITE_D.DESCR AS SITED_DESCR,SITE_D.ADD1 AS SITED_ADD1, SITE_D.ADD2 AS SITED_ADD2,SITE_D.CITY AS SITED_CITY,SITE_D.PIN SITED_PIN ,SITE_D.STATE_CODE AS SITED_STATE_CODE,D.TRANS_MODE AS TRANS_MODE FROM DISTORDER D,SITE SITE_A,SITE SITE_B,LOCATION LOCATION,SALES_PERS SALES_PERS,SITE SITE_C,SITE SITE_D WHERE ( D.SITE_CODE__SHIP = SITE_A.SITE_CODE ) AND ( D.SITE_CODE__DLV = SITE_B.SITE_CODE (+) ) AND ( D.LOC_CODE__GIT = LOCATION.LOC_CODE (+) ) AND ( D.SITE_CODE = SITE_C.SITE_CODE (+) ) AND ( D.SALES_PERS=SALES_PERS.SALES_PERS(+)) AND ( D.SITE_CODE__BIL=SITE_D.SITE_CODE(+)) AND ( ( D.DIST_ORDER = '" + tranDate = getCurrtDate();
distOrderNo + "' ) ) ";
tranId = generateTranTd("w_dist_order_post", today, siteCode, conn);
sql = "SELECT D.DIST_ORDER AS DIST_ORDER,D.ORDER_DATE AS ORDER_DATE,D.SITE_CODE__SHIP AS SITE_CODE__SHIP,"
+ "D.SITE_CODE__DLV AS SITE_CODE__DLV,D.SHIP_DATE AS SHIP_DATE,D.DUE_DATE AS DUE_DATE,D.REMARKS AS REMARKS,"
+ " D.DIST_ROUTE AS DIST_ROUTE,D.PRICE_LIST AS PRICE_LIST,D.CONFIRMED AS CONFIRMED,D.CHG_USER AS CHG_USER,"
+ "D.CHG_TERM AS CHG_TERM,D.TARGET_WGT AS TARGET_WGT,D.TARGET_VOL AS TARGET_VOL,D.LOC_CODE__GIT AS LOC_CODE__GIT,"
+ " D.CHG_DATE AS CHG_DATE,SITE_A.DESCR AS SITEA_DESCR,SITE_B.DESCR AS SITEB_DESCR,LOCATION.DESCR AS LOCATION_DESCR,"
+ "D.CONF_DATE AS CONF_DATE,D.SITE_CODE AS SITE_CODE,D.STATUS AS STATUS,D.SALE_ORDER AS SALE_ORDER, D.REMARKS1 AS REMARK1,"
+ "D.REMARKS2 AS REMARK2,TRIM(D.ORDER_TYPE) AS ORDER_TYPE,SITE_A.ADD1 AS SITEA_ADD1,SITE_A.ADD2 AS SITEA_ADD2,"
+ "SITE_A.CITY AS SITEA_CITY,SITE_A.PIN AS SITEA_PIN,SITE_A.STATE_CODE AS SITEA_STATE_CODE, SITE_B.ADD1 AS SITEB_ADD1,"
+ "SITE_B.ADD2 AS SITEB_ADD2,SITE_B.CITY AS SITEB_CITY,SITE_B.PIN AS SITEB_PIN,SITE_B.STATE_CODE AS SITEB_STATE_CODE,"
+ "D.LOC_CODE__CONS AS LOC_CODE__CONS,D.SUNDRY_TYPE AS SUNDRY_TYPE, D.SUNDRY_CODE AS SUNDRY_CODE,"
+ "D.AUTO_RECEIPT AS AUTO_RECEIPT,D.TRAN_TYPE AS TRAN_TYPE,D.CURR_CODE AS CURR_CODE,D.EXCH_RATE AS EXCH_RATE,"
+ "D.SALES_PERS AS SALES_PERS,SALES_PERS.SP_NAME AS SP_NAME, D.LOC_CODE__GITBF AS LOC_CODE__GITBF,D.CUST_CODE__DLV AS"
+ " CUST_CODE__DLV,D.DLV_TO AS DLV_TO,D.DLV_ADD1 AS DLV_ADD1,D.DLV_ADD2 AS DLV_ADD2,D.DLV_ADD3 AS DLV_ADD3,D.DLV_CITY"
+ " AS DLV_CITY, D.STATE_CODE__DLV AS STATE_CODE__DLV,D.COUNT_CODE__DLV AS COUNT_CODE__DLV,D.DLV_PIN AS DLV_PIN,"
+ "D.STAN_CODE AS STAN_CODE,D.TEL1__DLV AS TEL1__DLV,D.TEL2__DLV AS TEL2__DLV,D.TEL3__DLV AS TEL3__DLV,"
+ " D.FAX__DLV AS FAX__DLV,D.AVALIABLE_YN AS AVALIABLE_YN,D.PURC_ORDER AS PURC_ORDER,D.TOT_AMT AS TOT_AMT,"
+ "D.TAX_AMT AS TAX_AMT,D.NET_AMT AS NET_AMT,D.TRAN_SER AS TRAN_SER, D.PRICE_LIST__CLG AS PRICE_LIST__CLG,SPACE(25)"
+ " AS LOC,FN_SUNDRY_NAME(D.SUNDRY_TYPE,D.SUNDRY_CODE,'N') AS SUNDRY_NAME, D.PROJ_CODE AS PROJ_CODE,"
+ "SITE_C.DESCR AS SITEC_DESCR,D.POLICY_NO AS POLICY_NO,D.LOC_CODE__DAMAGED AS LOC_CODE__DAMAGED,"
+ "D.SITE_CODE__BIL AS SITE_CODE__BIL,SITE_D.DESCR AS SITED_DESCR,SITE_D.ADD1 AS SITED_ADD1, SITE_D.ADD2 AS SITED_ADD2,"
+ "SITE_D.CITY AS SITED_CITY,SITE_D.PIN SITED_PIN ,SITE_D.STATE_CODE AS SITED_STATE_CODE,D.TRANS_MODE AS TRANS_MODE "
+ " FROM DISTORDER D,SITE SITE_A,SITE SITE_B,LOCATION LOCATION,SALES_PERS SALES_PERS,SITE SITE_C,SITE SITE_D "
+ " WHERE ( D.SITE_CODE__SHIP = SITE_A.SITE_CODE ) AND ( D.SITE_CODE__DLV = SITE_B.SITE_CODE (+) ) AND "
+ " ( D.LOC_CODE__GIT = LOCATION.LOC_CODE (+) ) AND ( D.SITE_CODE = SITE_C.SITE_CODE (+) ) AND "
+ " ( D.SALES_PERS=SALES_PERS.SALES_PERS(+)) AND ( D.SITE_CODE__BIL=SITE_D.SITE_CODE(+))"
+ " AND ( ( D.DIST_ORDER = '" + distOrderNo + "' ) ) ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
this.currCode = rs.getString("CURR_CODE"); /* xmlBuffHeader.append("<?xml version='1.0' encoding='ISO-8859-1'?>\n");
locCode = rs.getString("LOC_CODE__GIT");
tranType = rs.getString("TRAN_TYPE");
siteCodeShip = rs.getString("SITE_CODE__SHIP");
xmlBuffHeader.append("<?xml version='1.0' encoding='ISO-8859-1'?>\n");
xmlBuffHeader.append("<DocumentRoot>"); xmlBuffHeader.append("<DocumentRoot>");
xmlBuffHeader.append("<description>").append("Datawindow Root").append("</description>"); xmlBuffHeader.append("<description>").append("Datawindow Root").append("</description>");
xmlBuffHeader.append("<group0>"); xmlBuffHeader.append("<group0>");
...@@ -2501,7 +2669,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2501,7 +2669,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
xmlBuffHeader.append("<pageContext><![CDATA[").append("1").append("]]></pageContext>"); xmlBuffHeader.append("<pageContext><![CDATA[").append("1").append("]]></pageContext>");
xmlBuffHeader.append("<objContext><![CDATA[").append("1").append("]]></objContext>"); xmlBuffHeader.append("<objContext><![CDATA[").append("1").append("]]></objContext>");
xmlBuffHeader.append("<editFlag><![CDATA[").append("A").append("]]></editFlag>");
xmlBuffHeader.append("<focusedColumn><![CDATA[").append("").append("]]></focusedColumn>"); xmlBuffHeader.append("<focusedColumn><![CDATA[").append("").append("]]></focusedColumn>");
xmlBuffHeader.append("<action><![CDATA[").append("SAVE").append("]]></action>"); xmlBuffHeader.append("<action><![CDATA[").append("SAVE").append("]]></action>");
xmlBuffHeader.append("<elementName><![CDATA[").append("").append("]]></elementName>"); xmlBuffHeader.append("<elementName><![CDATA[").append("").append("]]></elementName>");
...@@ -2514,19 +2682,8 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2514,19 +2682,8 @@ public class ScheduleAWMSInOutTasks implements Schedule
xmlBuffHeader.append("<Detail1 dbID=\"\" domID=\"1\" objName=\"dist_order_post\" objContext=\"1\">"); xmlBuffHeader.append("<Detail1 dbID=\"\" domID=\"1\" objName=\"dist_order_post\" objContext=\"1\">");
if(headerFlag)
{
xmlBuffHeader.append("<editFlag><![CDATA[").append("A").append("]]></editFlag>");
xmlBuffHeader.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\"/>"); xmlBuffHeader.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\"/>");
xmlBuffHeader.append("<tran_id/>"); xmlBuffHeader.append("<tran_id/>");
}
else
{
xmlBuffHeader.append("<tran_id><![CDATA[").append(tranId).append("]]></tran_id>");;
xmlBuffHeader.append("<editFlag><![CDATA[").append("E").append("]]></editFlag>");
xmlBuffHeader.append("<attribute selected=\"N\" updateFlag=\"E\" status=\"N\" pkNames=\"\"/>");
}
xmlBuffHeader.append("<tran_date><![CDATA[" + tranDate + "]]></tran_date>"); xmlBuffHeader.append("<tran_date><![CDATA[" + tranDate + "]]></tran_date>");
xmlBuffHeader.append("<eff_date><![CDATA[" + tranDate + "]]></eff_date>"); xmlBuffHeader.append("<eff_date><![CDATA[" + tranDate + "]]></eff_date>");
...@@ -2607,24 +2764,126 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2607,24 +2764,126 @@ public class ScheduleAWMSInOutTasks implements Schedule
xmlBuffHeader.append("<site_state_code_bill><![CDATA[]]></site_state_code_bill>"); xmlBuffHeader.append("<site_state_code_bill><![CDATA[]]></site_state_code_bill>");
xmlBuffHeader.append("<pallet_wt><![CDATA[]]></pallet_wt>"); xmlBuffHeader.append("<pallet_wt><![CDATA[]]></pallet_wt>");
xmlBuffHeader.append("<auto_receipt><![CDATA[N]]></auto_receipt>"); xmlBuffHeader.append("<auto_receipt><![CDATA[N]]></auto_receipt>");
xmlBuffHeader.append("</Detail1>"); xmlBuffHeader.append("</Detail1>");*/
sqlInsert = "INSERT INTO DISTORD_ISS (TRAN_ID,TRAN_DATE,EFF_DATE,DIST_ORDER,SITE_CODE,SITE_CODE__DLV,DIST_ROUTE,TRAN_CODE,LR_NO,LR_DATE,"
+" LORRY_NO,GROSS_WEIGHT,TARE_WEIGHT,NET_WEIGHT,FRT_AMT,AMOUNT,TAX_AMT,NET_AMT,LOC_CODE__GIT,REMARKS,FRT_TYPE,CHG_USER,"
+" CHG_TERM,CURR_CODE,CHG_DATE,CONFIRMED,CONF_DATE,NO_ART,TRANS_MODE,GP_NO,GP_DATE,ORDER_TYPE,CONF_PASSWD,GP_SER,REF_NO,"
+" REF_DATE,AVAILABLE_YN,STOCK_STATUS,EXCH_RATE,TRAN_TYPE,EMP_CODE__APRV,DISCOUNT,PERMIT_NO,SHIPMENT_ID,CURR_CODE__FRT,EXCH_RATE__FRT,"
+" RD_PERMIT_NO,DC_NO,PARENT__TRAN_ID,REV__TRAN,PROJ_CODE,TRAN_SER,PART_QTY,SITE_CODE__BIL,PALLET_WT,CR_TERM,DLV_TERM,OUTSIDE_INSPECTION,"
+" LABEL_TYPE,ADD_DATE,ADD_USER,ADD_TERM,SEAL_NO,DATA_LOGGER_NO)"
+" VALUES (?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?,?,?,?,?,?,?,"
+ "?,?,?,?)";
distIssHdrPstmt = conn.prepareStatement(sqlInsert);
distIssHdrPstmt.setString(1, tranId);
distIssHdrPstmt.setTimestamp(2, tranDate);
distIssHdrPstmt.setTimestamp(3, tranDate);
distIssHdrPstmt.setString(4, distOrderNo);
distIssHdrPstmt.setString(5, (rs.getString("SITE_CODE__SHIP") == null ? "" : rs.getString("SITE_CODE__SHIP").trim()));
distIssHdrPstmt.setString(6, (rs.getString("SITE_CODE__DLV") == null ? "" : rs.getString("SITE_CODE__DLV").trim()));
distIssHdrPstmt.setString(7, (rs.getString("DIST_ROUTE") == null ? "" : rs.getString("DIST_ROUTE")));
distIssHdrPstmt.setString(8, "");
distIssHdrPstmt.setString(9, "");
distIssHdrPstmt.setString(10, "");
distIssHdrPstmt.setString(11, "");
distIssHdrPstmt.setDouble(12, 0);
distIssHdrPstmt.setDouble(13, 0);
distIssHdrPstmt.setDouble(14, 0);
distIssHdrPstmt.setDouble(15, 0);
distIssHdrPstmt.setDouble(16, 0);
distIssHdrPstmt.setDouble(17, 0);
distIssHdrPstmt.setDouble(18, 0);
distIssHdrPstmt.setString(19, "");
distIssHdrPstmt.setString(20, "");
distIssHdrPstmt.setString(21, "T");
distIssHdrPstmt.setString(22, userId);
distIssHdrPstmt.setString(23, chgTerm);
distIssHdrPstmt.setString(24, rs.getString("CURR_CODE"));
distIssHdrPstmt.setTimestamp(25, tranDate);
distIssHdrPstmt.setString(26, "N");
distIssHdrPstmt.setTimestamp(27, tranDate);
distIssHdrPstmt.setString(28, "0");
distIssHdrPstmt.setString(29, (rs.getString("TRANS_MODE") == null ? "" : rs.getString("TRANS_MODE").trim()));
distIssHdrPstmt.setString(30, "");
distIssHdrPstmt.setString(31, "");
distIssHdrPstmt.setString(32, (rs.getString("ORDER_TYPE") == null ? "" : rs.getString("ORDER_TYPE").trim()));
distIssHdrPstmt.setString(33, "");
distIssHdrPstmt.setString(34, "I");
distIssHdrPstmt.setString(35, "");
distIssHdrPstmt.setString(36, "");
distIssHdrPstmt.setString(37, (rs.getString("AVALIABLE_YN") == null ? "N" : rs.getString("AVALIABLE_YN").trim()));
distIssHdrPstmt.setString(38, "");
distIssHdrPstmt.setDouble(39, rs.getDouble("EXCH_RATE"));
distIssHdrPstmt.setString(40, (rs.getString("TRAN_TYPE") == null ? "" : rs.getString("TRAN_TYPE").trim()));
distIssHdrPstmt.setString(41, "");
distIssHdrPstmt.setDouble(42, 0);
distIssHdrPstmt.setString(43, "");
distIssHdrPstmt.setString(44, "");
distIssHdrPstmt.setString(45, rs.getString("CURR_CODE"));
distIssHdrPstmt.setString(46, "");
distIssHdrPstmt.setString(47, "");
distIssHdrPstmt.setString(48, "");
distIssHdrPstmt.setString(49, "");
distIssHdrPstmt.setString(50, "");
distIssHdrPstmt.setString(51, (rs.getString("PROJ_CODE") == null ? "" : rs.getString("PROJ_CODE").trim()));
distIssHdrPstmt.setString(52, "D-ISS");
distIssHdrPstmt.setString(53, "A");
distIssHdrPstmt.setString(54, "");
distIssHdrPstmt.setString(55, "");
distIssHdrPstmt.setString(56, "");
distIssHdrPstmt.setString(57, "");
distIssHdrPstmt.setString(58, "");
distIssHdrPstmt.setString(59, "");
distIssHdrPstmt.setString(60, "");
distIssHdrPstmt.setString(61, "");
distIssHdrPstmt.setString(62, "");
distIssHdrPstmt.setString(63, "");
distIssHdrPstmt.setString(64, "");
caseCount = distIssHdrPstmt.executeUpdate();
distIssHdrPstmt.close(); distIssHdrPstmt = null;
System.out.println("Inserted Data in Dist Issue Header"+caseCount);
} }
rs.close();rs = null;
rs.close(); pstmt.close();pstmt = null;
rs = null;
pstmt.close();
pstmt = null;
retString = xmlBuffHeader.toString();
System.out.println("Chandni retString is::" + retString);
} }
catch (Exception e) catch (Exception e)
{ {
e.printStackTrace(); isError = true;
retString = "ERROR";
throw new ITMException(e); throw new ITMException(e);
} }
finally
{
try
{
if(isError)
{
retString = "VTTNSVD";
}
else
{
retString = tranId;
}
if(pstmt != null){pstmt.close();pstmt = null;}
if(distIssHdrPstmt != null){distIssHdrPstmt.close();distIssHdrPstmt = null;}
if(rs != null){rs.close();rs = null;}
}
catch(Exception ex)
{
throw new ITMException(ex);
}
}
return retString; return retString;
} }
private HashMap getDetails(String mSiteCode, int mLineNoDist, String mDistOrder, String lsTranType, Connection conn) private HashMap getDetails(String mSiteCode, int mLineNoDist, String mDistOrder, String lsTranType, Connection conn)
...@@ -2994,14 +3253,14 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -2994,14 +3253,14 @@ public class ScheduleAWMSInOutTasks implements Schedule
return (int)noArt; return (int)noArt;
} }
private String createDespatch(String refId,ArrayList lineNoList, Connection conn) throws ITMException, Exception private String createDespatch(String refId,ArrayList<String> lineNoList, Connection conn) throws ITMException, Exception
{ {
String resultStr = "",sql = "",despId = "",despDetSql = "",sordItemSql = "",sordSql = "",sordDetSql = "",stockSql = "",itemSql = "", String resultStr = "",sql = "",despId = "",despDetSql = "",sordItemSql = "",sordSql = "",sordDetSql = "",stockSql = "",itemSql = "",
sqlHdr = ""; sqlHdr = "";
String despLineNo = "",lineNoSord = "",expLev = "",itemCodeOrd = "",itemCode = "",lotNo= "",lotSl = "", String despLineNo = "",lineNoSord = "",expLev = "",itemCodeOrd = "",itemCode = "",lotNo= "",lotSl = "",
mbaseUnit = "", unit = "",unitStd = "",locCode = "",siteCode = "",partNo = "",siteCodeMfg = "", mbaseUnit = "", unit = "",unitStd = "",locCode = "",siteCode = "",partNo = "",siteCodeMfg = "",
custItemRef = "",rateClg = "",packInstr = "",siteCodeSord = "",rateStduom = "",packCode = "",lineType = "I",palletNo = "",lineNoInterface = ""; custItemRef = "",rateClg = "",packInstr = "",siteCodeSord = "",rateStduom = "",packCode = "",lineType = "I",palletNo = "";
PreparedStatement pstmt=null,despDetPstmt = null,pstmtSordItem = null,pstmtSord = null,pstmtSordDet = null,pstmtStock = null, PreparedStatement pstmt=null,despDetPstmt = null,pstmtSordItem = null,pstmtSord = null,pstmtSordDet = null,pstmtStock = null,
pstmtItem = null,pstmtHdr = null; pstmtItem = null,pstmtHdr = null;
...@@ -3019,6 +3278,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -3019,6 +3278,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
try try
{ {
System.out.println("Inside createDespatch"); System.out.println("Inside createDespatch");
System.out.println("Linr number list="+lineNoList.toString());
sql = "SELECT DESP_ID FROM DESPATCH WHERE SORD_NO = ?"; sql = "SELECT DESP_ID FROM DESPATCH WHERE SORD_NO = ?";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -3031,6 +3291,17 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -3031,6 +3291,17 @@ public class ScheduleAWMSInOutTasks implements Schedule
rs.close();rs = null; rs.close();rs = null;
pstmt.close();pstmt = null; pstmt.close();pstmt = null;
sql = "SELECT MAX(LINE_NO) AS LINE_NO FROM DESPATCHDET WHERE DESP_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, despId);
rs = pstmt.executeQuery();
if(rs.next())
{
lineNo = rs.getInt("LINE_NO");
}
rs.close();rs = null;
pstmt.close();pstmt = null;
itemSql = "SELECT I.UNIT AS UNIT_STD, I.MFR_PART_NO, ILP.SHIPPER_SIZE,I.GROSS_WEIGHT,I.NET_WEIGHT FROM ITEM I , ITEM_LOT_PACKSIZE ILP " itemSql = "SELECT I.UNIT AS UNIT_STD, I.MFR_PART_NO, ILP.SHIPPER_SIZE,I.GROSS_WEIGHT,I.NET_WEIGHT FROM ITEM I , ITEM_LOT_PACKSIZE ILP "
+ " WHERE I.ITEM_CODE = ? AND I.ITEM_CODE = ILP.ITEM_CODE "; + " WHERE I.ITEM_CODE = ? AND I.ITEM_CODE = ILP.ITEM_CODE ";
pstmtItem = conn.prepareStatement(itemSql); pstmtItem = conn.prepareStatement(itemSql);
...@@ -3067,14 +3338,16 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -3067,14 +3338,16 @@ public class ScheduleAWMSInOutTasks implements Schedule
+ " MFG_DATE,EXP_DATE,SITE_CODE,SITE_CODE__MFG FROM SORDALLOC WHERE SALE_ORDER = ? AND LINE_NO = ?"; + " MFG_DATE,EXP_DATE,SITE_CODE,SITE_CODE__MFG FROM SORDALLOC WHERE SALE_ORDER = ? AND LINE_NO = ?";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
Iterator itr = lineNoList.iterator(); for(String lineNoInterface : lineNoList)
while(itr.hasNext())
{ {
lineNoInterface = (String) itr.next(); //lineNoInterface = (String) itr.next();
System.out.println("Line["+lineNoInterface+"]");
lineNoInterface = " " + lineNoInterface; lineNoInterface = " " + lineNoInterface;
lineNoInterface = lineNoInterface.substring( lineNoInterface.length()-3 ); lineNoInterface = lineNoInterface.substring( lineNoInterface.length()-3 );
System.out.println("Inside First refId["+refId+"]lineNumber=["+lineNoInterface+"]");
pstmt.setString(1, refId); pstmt.setString(1, refId);
pstmt.setString(2, lineNoInterface); pstmt.setString(2, lineNoInterface);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -3101,6 +3374,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -3101,6 +3374,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
despLineNo = despLineNo.substring( despLineNo.length()-3 ); despLineNo = despLineNo.substring( despLineNo.length()-3 );
despDetPstmt.setString(2, despLineNo); despDetPstmt.setString(2, despLineNo);
despDetPstmt.setString(2, lineNoInterface);
despDetPstmt.setString(3, refId); despDetPstmt.setString(3, refId);
despDetPstmt.setString(4, lineNoSord); despDetPstmt.setString(4, lineNoSord);
despDetPstmt.setString(5, expLev); despDetPstmt.setString(5, expLev);
...@@ -3201,10 +3475,10 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -3201,10 +3475,10 @@ public class ScheduleAWMSInOutTasks implements Schedule
tareWeight = (tareWtPerArt * noArt); tareWeight = (tareWtPerArt * noArt);
netWeight = grossWeight - tareWeight ; netWeight = grossWeight - tareWeight ;
} }
totalNoArt = totalNoArt + noArt; /*totalNoArt = totalNoArt + noArt;
totalGrossWeight = totalGrossWeight + grossWeight; totalGrossWeight = totalGrossWeight + grossWeight;
totalTareWeight = totalTareWeight + tareWeight ; totalTareWeight = totalTareWeight + tareWeight ;
totalNetWeight = totalNetWeight + netWeight; totalNetWeight = totalNetWeight + netWeight; */
if(convQtyStduom != 0) if(convQtyStduom != 0)
{ {
...@@ -3268,11 +3542,25 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -3268,11 +3542,25 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
despDetPstmt.executeBatch(); despDetPstmt.executeBatch();
despDetPstmt.clearBatch(); despDetPstmt.clearBatch();
pstmt.clearParameters();
rs.close();rs = null;
}
sql = "SELECT LINE_NO,GROSS_WEIGHT,TARE_WEIGHT,NETT_WEIGHT,NO_ART FROM DESPATCHDET WHERE DESP_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, despId);
rs = pstmt.executeQuery();
while(rs.next())
{
System.out.println("Line No="+rs.getString("LINE_NO"));
totalGrossWeight = totalGrossWeight + rs.getDouble("GROSS_WEIGHT");
totalTareWeight = totalTareWeight + rs.getDouble("TARE_WEIGHT");
totalNetWeight = totalNetWeight + rs.getDouble("NETT_WEIGHT");
totalNoArt = totalNoArt + rs.getInt("NO_ART");
}
rs.close();rs = null; rs.close();rs = null;
pstmt.close();pstmt = null; pstmt.close();pstmt = null;
despDetPstmt.close();despDetPstmt = null;
}
sqlHdr = "UPDATE DESPATCH SET GROSS_WEIGHT = ?, TARE_WEIGHT = TARE_WEIGHT + ? ,NETT_WEIGHT = ?, NO_ART = ? " sqlHdr = "UPDATE DESPATCH SET GROSS_WEIGHT = ?, TARE_WEIGHT = TARE_WEIGHT + ? ,NETT_WEIGHT = ?, NO_ART = ? "
+ "WHERE DESP_ID = ? "; + "WHERE DESP_ID = ? ";
...@@ -3397,5 +3685,95 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -3397,5 +3685,95 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
return (currDate); return (currDate);
} }
private String allocStockLocCodeTo(ArrayList stkList,ArrayList tranIdIssList,String refSer,String refId,Connection conn) throws ITMException, Exception
{
String result = "",locCodeTo = "",sqlUpdate = "",tranIdList = "";
PreparedStatement pstmt=null;
ResultSet rs = null;
DistStkUpdLocal distStkUpd = null;
int count = 0;
int cntList = 0;
try
{
System.out.println("Inside allocStockLocCodeTo");
Iterator itr = stkList.iterator();
System.out.println("Array List size="+stkList.size());
while(itr.hasNext())
{
HashMap detail = new HashMap();
detail = (HashMap) itr.next();
distStkUpd = getComponent("DistStkUpd");
if (distStkUpd.updAllocTrace(detail, conn) > 0)
{
System.out.println("distStkUpd.UpdAllocTrace(HashMap, Connection) : Sucessuful!="+count);
}
count++;
}
if("D-SO".equalsIgnoreCase(refSer))
{
locCodeTo = distComm.getDisparams("999999",refSer,conn);
while(cntList < tranIdIssList.size())
{
if(cntList != 0)
{
tranIdList = tranIdList + ",?";
}
else
{
tranIdList = tranIdList + "?";
}
cntList++;
}
System.out.println( "tranIdList ["+tranIdList+"]");
sqlUpdate = "UPDATE DISTORD_ISSDET SET LOC_CODE = ? WHERE TRAN_ID IN ("+tranIdList+")";
pstmt = conn.prepareStatement(sqlUpdate);
pstmt.setString(1, locCodeTo);
for(cntList=0 ; cntList<tranIdIssList.size(); cntList++)
{
System.out.println( "tranId ["+(String)tranIdIssList.get(cntList)+"]");
pstmt.setString( (cntList+2), (String)tranIdIssList.get(cntList));
}
System.out.println("CNT List count ["+cntList+"]");
int upctr = pstmt.executeUpdate();
System.out.println("NO OF ROW UPDATED = "+upctr);
pstmt.close();pstmt = null;
}
}
catch(Exception e)
{
isError = true;
System.out.println("Catch allocStockLocCodeTo");
throw new ITMException(e);
}
finally
{
try
{
if(isError)
{
result = "ERROR";
}
else
{
result = "CONFSTKSUCC";
}
if(pstmt != null){pstmt.close();pstmt = null;}
if(rs != null){rs.close();rs = null;}
}
catch(Exception ex)
{
throw new ITMException(ex);
}
}
return result;
}
} }
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