Skip to content

B
business-java
Commit 2b501395 authored by smanohar's avatar smanohar
Browse files
Options

Changes for existence of demand for item 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@196152 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 126d69ce
Hide whitespace changes
Inline Side-by-side
Showing with 73 additions and 75 deletions
webitm-mfg/ibase/webitm/ejb/mfg/RunMRPPrc.java
View file @ 2b501395
...@@ -173,7 +173,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -173,7 +173,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
HashMap siteCodeMap = new HashMap(); HashMap siteCodeMap = new HashMap();
HashMap itemHashMap = new HashMap(); HashMap itemHashMap = new HashMap();
HashMap<String, String> externalSqlMap = new HashMap<String, String>();//Pavan R jan2019[to hold external Sql files] HashMap<String, String> externalSqlMap = new HashMap<String, String>();//Pavan R jan2019[to hold external Sql files]
//HashMap<String, String> sqlParamMap = new HashMap<String, String>(); HashMap<String, String> sqlParamMap = new HashMap<String, String>();
Set itemList = new HashSet(); Set itemList = new HashSet();
Set cyclicCheck = null; Set cyclicCheck = null;
String logInSite = ""; String logInSite = "";
...@@ -323,7 +323,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -323,7 +323,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend:getData(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend:getData(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
...@@ -622,7 +622,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -622,7 +622,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :validateFilterParams(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :validateFilterParams(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
...@@ -648,7 +648,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -648,7 +648,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :populateCommonParameters(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :populateCommonParameters(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -697,7 +697,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -697,7 +697,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend populateSiteMap():: " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend populateSiteMap():: " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
...@@ -736,7 +736,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -736,7 +736,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend populateItemMap():: " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend populateItemMap():: " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -756,7 +756,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -756,7 +756,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
BaseLogger.log("2", null, null, "populateAllItem() completed "); BaseLogger.log("2", null, null, "populateAllItem() completed ");
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//BaseLogger.log("2", null, null, "Total Time Spend :populateAllItem(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :populateAllItem(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
...@@ -849,7 +849,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -849,7 +849,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null,"Total Time Spend :bomExplode(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null,"Total Time Spend :bomExplode(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
...@@ -881,7 +881,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -881,7 +881,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :populateADPElementList(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :populateADPElementList(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -916,7 +916,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -916,7 +916,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :mrpOptimize(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :mrpOptimize(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
...@@ -948,7 +948,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -948,7 +948,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :generatePlanDemand(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :generatePlanDemand(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
...@@ -974,7 +974,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -974,7 +974,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null,"Total Time Spend :InsertPlanDemand(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null,"Total Time Spend :InsertPlanDemand(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -1084,7 +1084,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -1084,7 +1084,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :delete old plan: " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :delete old plan: " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -1096,7 +1096,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -1096,7 +1096,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :InsertPlanTable(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :InsertPlanTable(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -1116,7 +1116,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -1116,7 +1116,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :setValuesInBrow(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :setValuesInBrow(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -1130,7 +1130,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -1130,7 +1130,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
endTime = System.currentTimeMillis(); endTime = System.currentTimeMillis();
totalTime = endTime - startTime; totalTime = endTime - startTime;
//System.out.println("Total Time Spend :: " + totalTime + " Milliseconds"); //System.out.println("Total Time Spend :: " + totalTime + " Milliseconds");
//BaseLogger.log("2", null, null, "Total Time Spend :Write2XSL(): " + totalTime + " Milliseconds"); BaseLogger.log("2", null, null, "Total Time Spend :Write2XSL(): " + totalTime + " Milliseconds");
totSecs = (int) (((double) 1 / 1000) * (totalTime)); totSecs = (int) (((double) 1 / 1000) * (totalTime));
totalHrs = (int) (totSecs / 3600); totalHrs = (int) (totSecs / 3600);
totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60)); totlMts = (int) (((totSecs - (totalHrs * 3600)) / 60));
...@@ -2115,15 +2115,14 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2115,15 +2115,14 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{ {
BaseLogger.log("2", null, null, "inside populateItemMap()........."); BaseLogger.log("2", null, null, "inside populateItemMap().........");
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; //ResultSet rs = null;
String sql = "";
Set setSite = siteCodeMap.entrySet(); Set setSite = siteCodeMap.entrySet();
Iterator itrSite = setSite.iterator(); Iterator itrSite = setSite.iterator();
String subQuery=" "; String siteCode = "";
//Added by Pavan R on 23/NOV/17 START //Added by Pavan R on 23/NOV/17 START
PreparedStatement pstmt1 = null, innrPstmt = null; PreparedStatement pstmt1 = null;
ResultSet rs1 = null; ResultSet rs1 = null;
String sql1 = "", sqlFileName = "", adpQuery = "", masterSh = "";//, mfgType1 = ""; String masterSh = "";//, mfgType1 = "";
int rowCount = 0; int rowCount = 0;
String adpQueryMO = "", adpQueryMOTmp = "", adpQueryMS = "", adpQueryMSTmp = ""; String adpQueryMO = "", adpQueryMOTmp = "", adpQueryMS = "", adpQueryMSTmp = "";
//Added by Pavan R on 23/NOV/17 END //Added by Pavan R on 23/NOV/17 END
...@@ -2151,13 +2150,13 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2151,13 +2150,13 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
adpQueryMOTmp = adpQueryMOTmp.replaceAll("@rundate@", dbRunDate); adpQueryMOTmp = adpQueryMOTmp.replaceAll("@rundate@", dbRunDate);
/**---Change suggested Sm sir -----------*/ /**---Change suggested Sm sir -----------*/
String SqlDet = "SELECT COUNT(*) FROM BOMDET B, BOM A WHERE B.BOM_CODE = A.BOM_CODE " //String SqlDet = "SELECT COUNT(*) FROM BOMDET B, BOM A WHERE B.BOM_CODE = A.BOM_CODE "
+ " AND B.ITEM_CODE = ? AND A.CONFIRMED = 'Y' AND A.ACTIVE = 'Y' " ; // + " AND B.ITEM_CODE = ? AND A.CONFIRMED = 'Y' AND A.ACTIVE = 'Y' " ;
PreparedStatement pstmtBom = conn.prepareStatement(SqlDet); //PreparedStatement pstmtBom = conn.prepareStatement(SqlDet);
ResultSet rsBom = null; //ResultSet rsBom = null;
/**------------end---------------*/ /**------------end---------------*/
/** commented by Pavan R 22Jan2019[to get item having demand on sitemap loop]
//sql1 = "SELECT (CASE WHEN MASTER_SCH IS NULL THEN ' ' ELSE MASTER_SCH END), (CASE WHEN MFG_TYPE IS NULL THEN ' ' ELSE MFG_TYPE END) FROM SITEITEM WHERE SITE_CODE = ? AND ITEM_CODE = ?"; //sql1 = "SELECT (CASE WHEN MASTER_SCH IS NULL THEN ' ' ELSE MASTER_SCH END), (CASE WHEN MFG_TYPE IS NULL THEN ' ' ELSE MFG_TYPE END) FROM SITEITEM WHERE SITE_CODE = ? AND ITEM_CODE = ?";
//innrPstmt = conn.prepareStatement(sql1); //innrPstmt = conn.prepareStatement(sql1);
if(isDetailReq) if(isDetailReq)
...@@ -2244,21 +2243,26 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2244,21 +2243,26 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
pstmt.setString(2, itemCodeTo); pstmt.setString(2, itemCodeTo);
pstmt.setString(4, itemSerFrom); pstmt.setString(4, itemSerFrom);
pstmt.setString(5, itemSerTo); pstmt.setString(5, itemSerTo);
Commented end Pavan R 22Jan2019[to get item having demand on sitemap loop]*/
while (itrSite.hasNext()) while (itrSite.hasNext())
{ {
Map.Entry siteMapEntry = (Map.Entry) itrSite.next(); Map.Entry siteMapEntry = (Map.Entry) itrSite.next();
String siteCode = (String) siteMapEntry.getKey(); siteCode = (String) siteMapEntry.getKey();
adpQueryMS = adpQueryMSTmp.replaceAll("@sitecode@", siteCode); adpQueryMS = adpQueryMSTmp.replaceAll("@sitecode@", siteCode);
adpQueryMS = adpQueryMS.replaceAll("@itemcodefr@", itemCodeFrom);
adpQueryMS = adpQueryMS.replaceAll("@itemcodeto@", itemCodeTo);
adpQueryMO = adpQueryMOTmp.replaceAll("@sitecode@", siteCode); adpQueryMO = adpQueryMOTmp.replaceAll("@sitecode@", siteCode);
adpQueryMO = adpQueryMO.replaceAll("@itemcodefr@", itemCodeFrom);
adpQueryMO = adpQueryMO.replaceAll("@itemcodeto@", itemCodeTo);
rowCount++; rowCount++;
BaseLogger.log("2", null, null, ">>>>>>>populateItemMap() Total Site["+setSite.size()+"] currSite::["+rowCount+"]"); BaseLogger.log("2", null, null, ">>>>>>>populateItemMap() Total Site["+setSite.size()+"] currSite::["+rowCount+"]");
pstmt.setString(3, siteCode); //pstmt.setString(3, siteCode);
rs = pstmt.executeQuery(); //rs = pstmt.executeQuery();
itemCodeMp = rs.getString(1); //itemCodeMp = rs.getString(1);
//System.out.println("BASEPopulating item for site : " + siteCode); //System.out.println("BASEPopulating item for site : " + siteCode);
while (rs.next()) /**while (rs.next())//Pavan R 22Jan2019[to get item having demand on sitemap loop]
{ {
//System.out.println("BASErs.getString(1)--" + rs.getString(1)); //System.out.println("BASErs.getString(1)--" + rs.getString(1));
//if (itemCodeMap.containsKey(rs.getString(1))) //if (itemCodeMap.containsKey(rs.getString(1)))
...@@ -2266,7 +2270,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2266,7 +2270,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{ {
BaseLogger.log("2", null, null, "Item Code already exists : " + itemCodeMp); BaseLogger.log("2", null, null, "Item Code already exists : " + itemCodeMp);
} else } else
{ {*/
//Added by Pavan R on 23/NOV/17 START //Added by Pavan R on 23/NOV/17 START
//sql1 = "SELECT (CASE WHEN MASTER_SCH IS NULL THEN ' ' ELSE MASTER_SCH END), (CASE WHEN MFG_TYPE IS NULL THEN ' ' ELSE MFG_TYPE END) FROM SITEITEM WHERE SITE_CODE = ? AND ITEM_CODE = ?"; //sql1 = "SELECT (CASE WHEN MASTER_SCH IS NULL THEN ' ' ELSE MASTER_SCH END), (CASE WHEN MFG_TYPE IS NULL THEN ' ' ELSE MFG_TYPE END) FROM SITEITEM WHERE SITE_CODE = ? AND ITEM_CODE = ?";
//pstmt1 = conn.prepareStatement(sql1); //pstmt1 = conn.prepareStatement(sql1);
...@@ -2286,21 +2290,22 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2286,21 +2290,22 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
innrPstmt.clearParameters();*/ innrPstmt.clearParameters();*/
//pstmt1.close(); //pstmt1.close();
//pstmt1 = null; //pstmt1 = null;
masterSh = checkNull(rs.getString("MASTER_SCH_PLAN")); //masterSh = checkNull(rs.getString("MASTER_SCH_PLAN"));
mfgType1 = checkNull(rs.getString("MFG_TYPE")); //mfgType1 = checkNull(rs.getString("MFG_TYPE"));
boolean isMtoS = false; boolean isMtoS = false;
boolean isMtoO = false; boolean isMtoO = false;
//System.out.println("masterSh::["+masterSh+"] MFG_TYPE::["+mfgType1+"]"); //System.out.println("masterSh::["+masterSh+"] MFG_TYPE::["+mfgType1+"]");
BaseLogger.log( "3", null, null, "masterSh::["+masterSh+"] MFG_TYPE::["+mfgType1+"]"); BaseLogger.log( "3", null, null, "masterSh::["+masterSh+"] MFG_TYPE::["+mfgType1+"]");
if(masterSh.equalsIgnoreCase("Y")) //if(masterSh.equalsIgnoreCase("Y"))
{ //{
if(madeToStock.equalsIgnoreCase("0") && (!(mfgType1.trim().equalsIgnoreCase("O") || mfgType1.trim().equalsIgnoreCase("D")))) /**if(madeToStock.equalsIgnoreCase("0") && (!(mfgType1.trim().equalsIgnoreCase("O") || mfgType1.trim().equalsIgnoreCase("D"))))*/
if(madeToStock.equalsIgnoreCase("0"))//Pavan R 22Jan2019[to get item having demand on sitemap loop]
{ {
//sqlFileName = CommonConstants.JBOSSHOME + File.separator + "sql" + File.separator + "demandsupplyMS"; //sqlFileName = CommonConstants.JBOSSHOME + File.separator + "sql" + File.separator + "demandsupplyMS";
//System.out.println("BASEsqlFileName---"+sqlFileName); //System.out.println("BASEsqlFileName---"+sqlFileName);
//BaseLogger.log( "0", null, null, "BASEsqlFileName---"+sqlFileName); //BaseLogger.log( "0", null, null, "BASEsqlFileName---"+sqlFileName);
if ((CommonConstants.DB_NAME).equalsIgnoreCase("oracle")) //if ((CommonConstants.DB_NAME).equalsIgnoreCase("oracle"))
{ //{
//String adpQueryOriginal = readFile(sqlFileName + "Oracle.sql"); //String adpQueryOriginal = readFile(sqlFileName + "Oracle.sql");
//adpQuery = adpQueryOriginal; //adpQuery = adpQueryOriginal;
//adpQuery = checkNull(externalSqlMap.get("demandsupplyMSOracle")); //adpQuery = checkNull(externalSqlMap.get("demandsupplyMSOracle"));
...@@ -2312,7 +2317,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2312,7 +2317,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
//BaseLogger.log( "0", null, null, "3309::Replacing Values.in SQL....."); //BaseLogger.log( "0", null, null, "3309::Replacing Values.in SQL.....");
//adpQuery = adpQuery.replaceAll("@sitecode@", siteCode); //adpQuery = adpQuery.replaceAll("@sitecode@", siteCode);
//adpQuery = adpQuery.replaceAll("@itemcode@", rs.getString(1)); //adpQuery = adpQuery.replaceAll("@itemcode@", rs.getString(1));
adpQuery = adpQueryMS.replaceAll("@itemcode@", itemCodeMp); //adpQuery = adpQueryMS.replaceAll("@itemcode@", itemCodeMp);
/*adpQuery = adpQuery.replaceAll("@fromdate@", dbDateFrom); /*adpQuery = adpQuery.replaceAll("@fromdate@", dbDateFrom);
adpQuery = adpQuery.replaceAll("@todate@", dbDateTo); adpQuery = adpQuery.replaceAll("@todate@", dbDateTo);
adpQuery = adpQuery.replaceAll("@ordtypes@", standingOrdTypes); adpQuery = adpQuery.replaceAll("@ordtypes@", standingOrdTypes);
...@@ -2321,27 +2326,29 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2321,27 +2326,29 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
adpQuery = adpQuery.replaceAll("@rundate@", dbRunDate);*/ adpQuery = adpQuery.replaceAll("@rundate@", dbRunDate);*/
//System.out.println("Replaced Values.in SQL....."); //System.out.println("Replaced Values.in SQL.....");
//BaseLogger.log( "0", null, null, "Replacing Values.in SQL....."+adpQuery); //BaseLogger.log( "0", null, null, "Replacing Values.in SQL....."+adpQuery);
} //}
pstmt1 = conn.prepareStatement(adpQuery); pstmt1 = conn.prepareStatement(adpQueryMS);
rs1 = pstmt1.executeQuery(); rs1 = pstmt1.executeQuery();
if (rs1.next()) while (rs1.next())
{ {
isMtoS = true; isMtoS = true;
//System.out.println("isMtoO=["+isMtoO+"]");
BaseLogger.log("3", null, null, "isMtoO=["+isMtoO+"]"); BaseLogger.log("3", null, null, "isMtoO=["+isMtoO+"]");
itemCodeMp = rs1.getString(1);
itemCodeMap.put(itemCodeMp, new Integer(itemCodeMap.size() + 1));
} }
rs1.close(); rs1.close();
rs1 = null; rs1 = null;
pstmt1.close(); pstmt1.close();
pstmt1 = null; pstmt1 = null;
} }
if(madeToOrder.equalsIgnoreCase("0") && (mfgType1.trim().equalsIgnoreCase("O") || mfgType1.trim().equalsIgnoreCase("D"))) //if(madeToOrder.equalsIgnoreCase("0") && (mfgType1.trim().equalsIgnoreCase("O") || mfgType1.trim().equalsIgnoreCase("D")))
if(madeToOrder.equalsIgnoreCase("0")) //Pavan R 22Jan2019[to get item having demand on sitemap loop]
{ {
//sqlFileName = CommonConstants.JBOSSHOME + File.separator + "sql" + File.separator + "madeToOrderMO"; //sqlFileName = CommonConstants.JBOSSHOME + File.separator + "sql" + File.separator + "madeToOrderMO";
//System.out.println("BASEsqlFileName---"+sqlFileName); //System.out.println("BASEsqlFileName---"+sqlFileName);
//BaseLogger.log( "0", null, null, "BASEsqlFileName---"+sqlFileName); //BaseLogger.log( "0", null, null, "BASEsqlFileName---"+sqlFileName);
if ((CommonConstants.DB_NAME).equalsIgnoreCase("oracle")) //if ((CommonConstants.DB_NAME).equalsIgnoreCase("oracle"))
{ //{
//String adpQueryOriginal = readFile(sqlFileName + "Oracle.sql"); //String adpQueryOriginal = readFile(sqlFileName + "Oracle.sql");
//adpQuery = adpQueryOriginal; //adpQuery = adpQueryOriginal;
//adpQuery = checkNull(externalSqlMap.get("madeToOrderMOOracle")); //adpQuery = checkNull(externalSqlMap.get("madeToOrderMOOracle"));
...@@ -2357,15 +2364,16 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2357,15 +2364,16 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
adpQuery = adpQuery.replaceAll("@madetoorder@", madeToOrder); adpQuery = adpQuery.replaceAll("@madetoorder@", madeToOrder);
adpQuery = adpQuery.replaceAll("@madetostock@", madeToStock); adpQuery = adpQuery.replaceAll("@madetostock@", madeToStock);
adpQuery = adpQuery.replaceAll("@rundate@", dbRunDate);*/ adpQuery = adpQuery.replaceAll("@rundate@", dbRunDate);*/
adpQuery = adpQueryMO.replaceAll("@itemcode@", itemCodeMp); //adpQuery = adpQueryMO.replaceAll("@itemcode@", itemCodeMp);
//System.out.println("Replaced Values.in SQL....."+adpQuery); //System.out.println("Replaced Values.in SQL....."+adpQuery);
} // }
pstmt1 = conn.prepareStatement(adpQuery); pstmt1 = conn.prepareStatement(adpQueryMO);
rs1 = pstmt1.executeQuery(); rs1 = pstmt1.executeQuery();
if (rs1.next()) while (rs1.next())
{ {
isMtoO = true; isMtoO = true;
//System.out.println("isMtoO=["+isMtoO+"]"); itemCodeMp = rs1.getString(1);
itemCodeMap.put(itemCodeMp, new Integer(itemCodeMap.size() + 1));
} }
rs1.close(); rs1.close();
rs1 = null; rs1 = null;
...@@ -2373,7 +2381,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2373,7 +2381,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
pstmt1 = null; pstmt1 = null;
} }
//System.out.println("isMadeToOrder["+isMtoO+"]isMadeToStock["+isMtoS+"]"); //System.out.println("isMadeToOrder["+isMtoO+"]isMadeToStock["+isMtoS+"]");
if (isMtoO != false || isMtoS != false) /**if (isMtoO != false || isMtoS != false)
{ {
//itemCodeMap.put(rs.getString(1), new Integer(itemCodeMap.size() + 1)); //itemCodeMap.put(rs.getString(1), new Integer(itemCodeMap.size() + 1));
itemCodeMap.put(itemCodeMp, new Integer(itemCodeMap.size() + 1)); itemCodeMap.put(itemCodeMp, new Integer(itemCodeMap.size() + 1));
...@@ -2382,7 +2390,6 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2382,7 +2390,6 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
}else{ }else{
//Added by Pavan R on 23/NOV/17 END //Added by Pavan R on 23/NOV/17 END
int cntBom = 0; int cntBom = 0;
//pstmtBom.setString(1, rs.getString(1));
pstmtBom.setString(1, itemCodeMp); pstmtBom.setString(1, itemCodeMp);
rsBom = pstmtBom.executeQuery(); rsBom = pstmtBom.executeQuery();
if(rsBom.next()) if(rsBom.next())
...@@ -2394,26 +2401,22 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2394,26 +2401,22 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
BaseLogger.log("2", null, null, "cntBom["+cntBom+"]"+itemCodeMp); BaseLogger.log("2", null, null, "cntBom["+cntBom+"]"+itemCodeMp);
if(cntBom > 0) if(cntBom > 0)
{ {
//itemCodeMap.put(rs.getString(1), new Integer(itemCodeMap.size() + 1));
itemCodeMap.put(itemCodeMp, new Integer(itemCodeMap.size() + 1)); itemCodeMap.put(itemCodeMp, new Integer(itemCodeMap.size() + 1));
} }
//System.out.println("Item Code added : "+rs.getString(1)); //System.out.println("Item Code added : "+rs.getString(1));
} }*/
} //}
} }
rs.close(); //rs.close();
rs = null; //rs = null;
BaseLogger.log("3", null, null, "SiteCode["+siteCode+"]itemCodeMap.size()::["+itemCodeMap.size()+"]"); BaseLogger.log("3", null, null, "SiteCode["+siteCode+"]itemCodeMap.size()::["+itemCodeMap.size()+"]");
} //}
pstmt.close(); //pstmt.close();
pstmt = null; //pstmt = null;
if(innrPstmt != null){ //if(innrPstmt != null){
innrPstmt.close(); // innrPstmt.close();
} //}
if(pstmtBom != null){
pstmtBom.close();
}
BaseLogger.log("3", null, null, " Total itemCodeMap.size()::["+itemCodeMap.size()+"]"); BaseLogger.log("3", null, null, " Total itemCodeMap.size()::["+itemCodeMap.size()+"]");
} catch (SQLException se) } catch (SQLException se)
{ {
...@@ -2434,11 +2437,6 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe ...@@ -2434,11 +2437,6 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{ {
try try
{ {
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null) if (pstmt != null)
{ {
pstmt.close(); pstmt.close();
......
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