Commit 7e075384 authored by cpatil's avatar cpatil

modify for sava


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@103559 ce508802-f39f-4f6c-b175-0d175dae99d5
parent e5450a8d
......@@ -890,11 +890,14 @@ class ADPElement implements Cloneable
timeMRP = (TimeMRP)this.timeMRPArr.get(timeEle);
//added by sabyasachi 29.03.2011
//timeMRP.setDemand(demand,saleOrder,lineNo);
System.out.println("before setDemand() [" + demand + "] supply [" + supply + "]" );
timeMRP.setDemand(demand);
System.out.println("before setDemand() [" + demand + "] supply [" + supply + "]timeMRP.getDemand()["+timeMRP.getDemand()+"]" );
if(! (demand > 0 && timeMRP.getDemand() > 0 ))
{
timeMRP.setDemand(demand);
}
//end added by sabyasachi 29.03.2011
timeMRP.setSupply(supply);
System.out.println("after setSupply()" );
System.out.println("after setSupply() timeMRP.getDemand()["+timeMRP.getDemand()+"]" );
// 12/04/10 manoharan MF90BHU001
timeMRP.setStockQty(stockQty);
timeMRP.setOthSupply(othSupply);
......@@ -903,7 +906,7 @@ class ADPElement implements Cloneable
//timeMRP.setLineNo(lineNo);
this.timeMRPArr.set(timeEle,timeMRP);
}
System.out.println("before updateRunningDemandSupply()" );
System.out.println("before updateRunningDemandSupply()...dueDate["+dueDate+"]" );
updateRunningDemandSupply(dueDate);
System.out.println("after updateRunningDemandSupply()" );
}
......@@ -1041,7 +1044,7 @@ class ADPElement implements Cloneable
runningPlanSupply = runningPlanSupply + timeMRP.getPlanSupply();
// end 10-04-2006 manoharan
}
System.out.println("@@@@@@@1044 index["+index+"]timeMRPArr.size()["+timeMRPArr.size()+"]");
for (int ctr = index; ctr < timeMRPArr.size(); ctr++)
{
timeMRP = (TimeMRP)timeMRPArr.get(ctr);
......@@ -1052,6 +1055,7 @@ class ADPElement implements Cloneable
timeMRP.setRunningSupply(runningSupply);
// 10-04-2006 manoharan
planSupply = timeMRP.getPlanSupply();
System.out.println("@@@@@@1055 planSupply["+planSupply+"]");
runningPlanSupply = runningPlanSupply + planSupply;
timeMRP.setRunningPlanSupply(runningPlanSupply);
// end 10-04-2006 manoharan
......
......@@ -20,13 +20,19 @@ package ibase.webitm.ejb.mfg;
*/
import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants;
import ibase.utility.EMail;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ProcessEJB;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.fin.FinCommon;
import ibase.webitm.ejb.mfg.adv.WorkorderPrc;
import ibase.webitm.ejb.mfg.MfgCommon;
//import ibase.webitm.utility.GenericUtility;
import ibase.utility.E12GenericUtility;
import ibase.webitm.reports.utility.ArgumentHandler;
import ibase.webitm.reports.utility.JasperReportGenerator;
import ibase.webitm.reports.utility.ResourceConstants;
import ibase.webitm.reports.utility.XSDParser;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
......@@ -37,6 +43,7 @@ import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.rmi.RemoteException;
......@@ -252,6 +259,11 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
int bomLevel=0;
String[] arrStr = null;
String xtraParams="";
String msgStr="";
ArrayList<String> mrpErrDetList = new ArrayList<String>();
ArrayList<String> errList = new ArrayList<String>();
ArrayList<String> errFields = new ArrayList<String>();
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException, ITMException
{
......@@ -297,6 +309,9 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
finally
{
itemCodeList ="";
errList.clear();
mrpErrDetList.clear();
errFields.clear();
}
System.out.println("Returning from Process :: " + retString);
return retString;
......@@ -546,8 +561,8 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId");
CommonConstants.setIBASEHOME();
//Changed by Poonam Gole for changing connection object :Start
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection() ;
conn = connDriver.getConnectDB("DriverITM");
//conn = getConnection() ;
//Changed by Poonam Gole for changing connection object :End
conn.setAutoCommit(false);
connDriver = null;
......@@ -1031,7 +1046,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
//cpatil-25/08/14-System.out.println("Total Time Spend setValuesInBrow [" + totalHrs + "] Hours [" + totlMts + "] Minutes [" + totSecs + "] seconds");
if(!isDetailReq)
{
Write2XSL();
Write2XSL(conn);
}
endTime = System.currentTimeMillis();
totalTime = endTime - startTime;
......@@ -1043,6 +1058,23 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
totSecs = (int) (totSecs - ((totalHrs * 3600) + (totlMts * 60)));
//cpatil-25/08/14-System.out.println("Total Time Spend Write2XSL [" + totalHrs + "] Hours [" + totlMts + "] Minutes [" + totSecs + "] seconds");
if(verifier != null && "Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16 for sava M16FSAV002
{
Calendar currentDate = Calendar.getInstance();
SimpleDateFormat sdf1 = new SimpleDateFormat(
genericUtility.getApplDateTimeFormat());
String sysDate1 = sdf1.format(currentDate.getTime());
System.out.println("Now the date with time :=> [" + sysDate1+"]mrpErrDetList.size["+mrpErrDetList.size()+"]");
if( mrpErrDetList.size() > 0)
{
System.out.println("@@@@@@@@ start generateMRPLogReport.....");
generateMRPLogReport(mrpErrDetList,sysDate1,chgUser, conn);
System.out.println("@@@@@@@@ end generateMRPLogReport.......");
}
}
}
catch (SQLException se)
{
......@@ -1114,8 +1146,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
siteCodeFrom = "";
//cpatil-25/08/14-System.out.println("Site Code From is Null...");
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "site Code From is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("site_code__from");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Site Code From............." + siteCodeFrom);
// Fetching SiteCodeTo from Entered by User in GUI
......@@ -1124,8 +1167,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
siteCodeTo = "";
//cpatil-25/08/14-System.out.println("Site Code To is Null...");
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Site Code To is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("site_code__to");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Site Code To..............." + siteCodeTo);
// Fetching ItemCodeFrom from Entered by User in GUI
......@@ -1134,8 +1188,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
itemCodeFrom = "";
//cpatil-25/08/14-System.out.println("Item Code From is Null...");
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Item Code From is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("item_code__from");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Item Code From............." + itemCodeFrom);
// Fetching ItemCodeTo from Entered by User in GUI
......@@ -1144,8 +1209,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
itemCodeTo = "";
//cpatil-25/08/14-System.out.println("Item Code To is Null...");
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Item Code To is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("item_code__to");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Item Code To............." + itemCodeTo);
}
......@@ -1155,8 +1231,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
sDateFrom = "";
//cpatil-25/08/14-System.out.println("From Date is Null...");
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "From Date is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("date_from");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("From Date............." + sDateFrom);
......@@ -1167,8 +1254,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
sDateTo = "";
//cpatil-25/08/14-System.out.println("To Date is Null...");
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "To Date is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("date_to");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("To Date............." + sDateTo);
......@@ -1178,8 +1276,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
itemSerFrom = "";
//cpatil-25/08/14-System.out.println("From Item Series is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Item Series From is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("item_ser__from");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Item Series From............." + itemSerFrom);
// Fetching ItemSerTo from Entered by User in GUI
......@@ -1188,8 +1297,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
itemSerTo = "";
//cpatil-25/08/14-System.out.println("Item Series To is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Item Series To is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("item_ser__to");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("To Item Series............." + itemSerTo);
......@@ -1200,8 +1320,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
disPlan = "";
//cpatil-25/08/14-System.out.println("Dis Plan is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Dis Plan is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("dis_plan");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Dis Plan............." + disPlan);
// Fetching MfgPlan from Entered by User in GUI
......@@ -1210,8 +1341,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
mfgPlan = "";
//cpatil-25/08/14-System.out.println("Mfg Plan is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Mfg Plan is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("mfg_plan");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Mfg Plan............." + mfgPlan);
// Fetching MatPlan from Entered by User in GUI
......@@ -1220,8 +1362,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
matPlan = "";
//cpatil-25/08/14-System.out.println("Mat Plan is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Mat Plan is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("mat_plan");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Mat Plan............." + matPlan);
......@@ -1229,8 +1382,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
if (processCycleString == null || processCycleString.trim().length() == 0)
{
//cpatil-25/08/14-System.out.println("Process Cycle is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Process Cycle is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("process_cycle");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
try
{
......@@ -1247,8 +1411,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
madeToStock = "";
//cpatil-25/08/14-System.out.println("Made To Stock is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Made To Stock is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("made_to_stock");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Made To Stock............." + madeToStock);
......@@ -1258,8 +1433,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
madeToOrder = "";
//cpatil-25/08/14-System.out.println("Made To Order is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Made To Order is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("made_to_order");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Made To Order............." + madeToOrder);
......@@ -1269,16 +1455,38 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
balIntersite = "";
//cpatil-25/08/14-System.out.println("Balance Intersite is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Balance Intersite is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("balance_intersite");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
genIndent = genericUtility.getColumnValue("gen_ind", dom);
if (genIndent == null || genIndent.trim().length() == 0)
{
genIndent = "";
//cpatil-25/08/14-System.out.println("Generate Indent is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Generate Indent is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("gen_ind");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Generate Indent............." + genIndent);
......@@ -1340,8 +1548,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
sRunDate = "";
//cpatil-25/08/14-System.out.println("Run Date is Null...");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Run Date is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPPARM");
errFields.add("run_date");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPPARM", "", "", conn);
return errString;
}
}
//cpatil-25/08/14-System.out.println("Run Date............." + sRunDate);
......@@ -1370,8 +1589,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
//System.out.println(">>>>>>>In val getData bomLevelStr:"+bomLevelStr);
if (bomLevelStr == null || bomLevelStr.trim().length() == 0)
{
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Bom Level is null or blank.";
mrpErrDetList.add(msgStr);
errList.add("VMBOMLVLNL");
errFields.add("bom_level");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VMBOMLVLNL", "", "", conn);
return errString;
}
}
else
{
......@@ -1379,8 +1609,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
//System.out.println(">>>>>In val bomLevel:"+bomLevel);
if(bomLevel <= 0)
{
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Invalid Bom Level..Bom Level should be greater than zero.";
mrpErrDetList.add(msgStr);
errList.add("VMBOMLVLVD");
errFields.add("bom_level");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VMBOMLVLVD", "", "", conn);
return errString;
}
}
}
}
......@@ -1521,8 +1762,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
deptCodeMfg = itmDBAccessEJB.getEnvDis("999999", "DEPT_CODE_MFG", conn);
if (deptCodeMfg.equals("NULLFOUND"))
{
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Department Code is null or blank. Define 'DEPT_CODE_MFG' in disparm.";
mrpErrDetList.add(msgStr);
errList.add("VTMRPDEPT");
errFields.add("dept_code_mfg");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPDEPT", "", "", conn);
return errString;
}
} else
{
sql = "SELECT COUNT(1) FROM DEPARTMENT WHERE DEPT_CODE = '" + deptCodeMfg + "'";
......@@ -1533,7 +1785,18 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
} else
{
//cpatil-25/08/14-System.out.println("Department Code Mfg [" + deptCodeMfg + "] not exists in deparment master");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Invalid department code,The department code '"+deptCodeMfg+"' is not existing in department master.";
mrpErrDetList.add(msgStr);
errList.add("VTINVDEPT");
errFields.add("dept_code_mfg");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTINVDEPT", "", "", conn);
}
}
rs.close();
}
......@@ -1948,10 +2211,26 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
if (confirmedBom == null || confirmedBom.trim().length() == 0 || confirmedBom.equalsIgnoreCase("N"))
{
logMsg = logMsg + "BOM not confirmed";
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Invalid BOM "+bomCode+" Entered BOM "+bomCode+" is not confirmed. BOM should be confirmed";
mrpErrDetList.add(msgStr);
errList.add("VTBOMUCON");
errFields.add("bom_code");
}
}
if (activeBom == null || activeBom.trim().length() == 0 || activeBom.equalsIgnoreCase("N"))
{
logMsg = logMsg + " BOM not active";
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Invalid BOM "+bomCode+" Entered BOM "+bomCode+" is not active. BOM should be active";
mrpErrDetList.add(msgStr);
errList.add("VTBOMUCON");
errFields.add("bom_code");
}
}
invaldBomExists = true;
this.fwInvalidBom.write(logMsg + "\r\n");
......@@ -2193,10 +2472,21 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
} else
{
//cpatil-25/08/14-System.out.println("Cyclic Item Code is : " + rs.getString(1));
errString = itmDBAccessEJB.getErrorString("", "VTMRPITEME", "", "", conn);
rs.close();
pstmt.close();
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Cyclic item "+cyclicItem.itemCode+" found in one of the bill of material. ";
mrpErrDetList.add(msgStr);
errList.add("VTMRPITEME");
errFields.add("bom_code");
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTMRPITEME", "", "", conn);
return errString;
}
}
isCyclic = true;
}
......@@ -2964,8 +3254,19 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
else
{
//cpatil-25/08/14-System.out.println("NULL : SiteCode : [" + siteMapEntry.getKey() + "] ItemCode : [" + itemMapEntry.getKey() + "]");
if("Y".equalsIgnoreCase(verifier)) //for error_report @19/09/16
{
msgStr = "Supply source is null....";
mrpErrDetList.add(msgStr);
//errList.add("VTMRPITEME");
//errFields.add("bom_code");
}
else
{
errString = "Supply source is null...";
return errString;
}
}
}
// Code for adding Demand (i.e. getDemand()) in adpElement
......@@ -4225,7 +4526,8 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
if(!isDetailReq)
{
adpElement.setDemand(dueDate, demand, " ", " ");
adpElement.setDemand(dueDate, demand, " ", " "); //031016
//adpElement.setDemand(dueDate, demand, adpElement.getSaleOrder(), adpElement.getLineNo());
}
adpElement.setSupply(dueDate, supply);
// // 12/04/10 manoharan MF90BHU001
......@@ -4309,7 +4611,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
} else
{
//cpatil-25/08/14-System.out.println("Site Code :: " + siteCode + " rsItemCode :: " + rsItemCode + " Item Code :: " + itemCode);
System.out.println("4614 : Site Code :: " + siteCode + " rsItemCode :: " + rsItemCode + " Item Code :: " + itemCode);
int ctr = indexOfADPElement(siteCode, rsItemCode, " ", " ");
// System.out.println("AdpList : "+adpeList.size()+"Index ctr :: "+ctr);//Added
// by Jiten 09/11/06 Sun
......@@ -4909,7 +5211,8 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
if ((CommonConstants.DB_NAME).equalsIgnoreCase("db2"))
{
// System.out.println("Firing DB2 Sql For Site Code :" +
System.out.println("@@@@@@@@ madeToOrder called.....");
//System.out.println("Firing DB2 Sql For Site Code :" +
// siteCode + " Item Code : " + itemCode + " From Date : " +
// dateFrom + " To Date : "+ dateTo + " StandgOrdTypes : "+
// standingOrdTypes +" MadeToOrder " +madeToOrder+
......@@ -5010,7 +5313,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
siteCode = rs.getString(13);//Added by Chandrashekar on 09-07-2014
}
// cpatil start
//System.out.println("@@@@@saleOrder["+saleOrder+"]["+adpElement.getSaleOrder()+"]lineNo["+lineNo+"]["+adpElement.getLineNo()+"]rsItemCode["+rsItemCode+"]@@@@@@@@@@@");
System.out.println("300916 5315 saleOrder["+saleOrder+"]["+adpElement.getSaleOrder()+"]lineNo["+lineNo+"]["+adpElement.getLineNo()+"]rsItemCode["+rsItemCode+"]@@@@@@@@@@@");
//System.out.println("@@@@@@@@@@@sorderList["+sorderList+"]@@@@@@@@@itemCodeList["+itemCodeList+"]");
//System.out.println("itemCodeList.length()-----"+itemCodeList.isEmpty());
//System.out.println("@@@@@@@@@4884::saleOrder["+saleOrder+"]rsItemCode["+rsItemCode+"]demand["+demand+"]grossWeightMap["+grossWeightMap+"]");
......@@ -5077,8 +5380,24 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
dueDate = dateFrom;
}
String bomitemCode1=""; //031016
for(int ctr=0;ctr<adpeList.size();ctr++)
{
ADPElement tempADPElement = (ADPElement) adpeList.get(ctr);
bomitemCode1=tempADPElement.getItemCode();
//cpatil-25/08/14-System.out.println("bomitemCode----"+bomitemCode+"---tmpitemCode---"+tmpitemCode);
if(bomitemCode1.equalsIgnoreCase(rsItemCode))
{
System.out.println("5390 Setting SaleOrder and lineNo for Semi finish items---"+saleOrder+"---"+lineNo);
tempADPElement.setSaleOrder(saleOrder);
tempADPElement.setLineNo(lineNo);
adpeList.set(ctr, tempADPElement);
break;
}
}
//Commented by Manoj dtd 16/12/2014
/* pstmt1=conn.prepareStatement("SELECT ITEM_CODE FROM BOMDET WHERE BOM_CODE IN(SELECT BOM_CODE FROM BOM WHERE ITEM_CODE=? AND CONFIRMED='Y')");
pstmt1=conn.prepareStatement("SELECT ITEM_CODE FROM BOMDET WHERE BOM_CODE IN(SELECT BOM_CODE FROM BOM WHERE ITEM_CODE=? AND CONFIRMED='Y')");
pstmt1.setString(1,rsItemCode);
rs1=pstmt1.executeQuery();
String bomitemCode="";
......@@ -5093,9 +5412,10 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
//cpatil-25/08/14-System.out.println("bomitemCode----"+bomitemCode+"---tmpitemCode---"+tmpitemCode);
if(bomitemCode.equalsIgnoreCase(tmpitemCode))
{
//cpatil-25/08/14-System.out.println("Setting SaleOrder and lineNo for Semi finish items---"+saleOrder+"---"+lineNo);
System.out.println("Setting SaleOrder and lineNo for Semi finish items---"+saleOrder+"---"+lineNo);
tempADPElement.setSaleOrder(saleOrder);
tempADPElement.setLineNo(lineNo);
adpeList.set(ctr, tempADPElement);
break;
}
}
......@@ -5103,7 +5423,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
rs1.close();
rs1=null;
pstmt1.close();
pstmt1=null;*/
pstmt1=null;
/*
* if(rsItemCode != null &&
......@@ -5125,11 +5445,11 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
int ctr = indexOfADPElement(siteCode, rsItemCode, saleOrder, lineNo);
//System.out.println("01/04/11---BHU saleOrder [" + saleOrder + "]rsItemCode["+rsItemCode+"] itemCode["+itemCode+"]lineNo [" + lineNo + "] ctr [" + ctr + "] [--"+rsItemCode+"]");
System.out.println("300916---BHU saleOrder [" + saleOrder + "]rsItemCode["+rsItemCode+"] itemCode["+itemCode+"]lineNo [" + lineNo + "] ctr [" + ctr + "] [--"+rsItemCode+"]");
if (ctr > -1)
{
//System.out.println("@@@@@@4988 inside if ctr["+ctr+"]dueDate["+dueDate+"]demand["+demand+"]saleOrder["+saleOrder+"]rsItemCode["+rsItemCode+"]");
System.out.println("@@@@@@4988 inside if ctr["+ctr+"]dueDate["+dueDate+"]demand["+demand+"]saleOrder["+saleOrder+"]rsItemCode["+rsItemCode+"]");
ADPElement tempADPElement = (ADPElement) adpeList.get(ctr);
//cpatil-25/08/14-System.out.println("3155---saleOrder---"+saleOrder+"---lineNo---"+lineNo);
tempADPElement.setDemand(dueDate, demand, saleOrder, lineNo); // comment on 12/01/15
......@@ -5145,7 +5465,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
adpeList.set(ctr, tempADPElement);
} else if (ctr == -1)
{
//System.out.println("@@@@@@4999 inside else ctr["+ctr+"]dueDate["+dueDate+"]demand["+demand+"]saleOrder["+saleOrder+"]rsItemCode["+rsItemCode+"]lineNo["+lineNo+"]supply["+supply+"]siteCode["+siteCode+"]");
System.out.println("@@@@@@4999 inside else ctr["+ctr+"]dueDate["+dueDate+"]demand["+demand+"]saleOrder["+saleOrder+"]rsItemCode["+rsItemCode+"]lineNo["+lineNo+"]supply["+supply+"]siteCode["+siteCode+"]");
ADPElement newADPElement = new ADPElement();
newADPElement.setSiteCode(siteCode);
newADPElement.setItemCode(rsItemCode);
......@@ -5274,7 +5594,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
for (int cycle = 1; cycle <= processCycle; cycle++)
{
//System.out.println("12/06/14 Processing level no : [" + cycle + "] of [" + processCycle + "] adpeList.size() ["+ adpeList.size() + "]" );
// System.out.println("Size of Adpe List : " + adpeList.size());
System.out.println("Size of Adpe List : " + adpeList.size());
for (int adpeCtr = 0; adpeCtr < adpeList.size(); adpeCtr++)
{
adpElement = (ADPElement) adpeList.get(adpeCtr);
......@@ -6535,18 +6855,18 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
rs.close();
pstmt.close();
//int index = indexOfADPElement(siteCode, itemCode, " ", " ");//Commented by manoj dtd 19/11/2013
//cpatil-25/08/14-System.out.println("4040---siteCode----"+siteCode+"---itemCode---"+itemCode+"---saleOrder---"+saleOrder+"---lineNo---"+lineNo);
System.out.println("4040---siteCode----"+siteCode+"---itemCode---"+itemCode+"---saleOrder---"+saleOrder+"---lineNo---"+lineNo);
int index=0;
System.out.println("300916 itemCode [" + itemCode + "] dueDate [" + dueDate + "] quantity [" + quantity + "]saleOrder["+saleOrder+"]lineNo["+lineNo+"]");
if(isDetailReq)
{
index = indexOfADPElement(siteCode, itemCode);
}
else
{
index = indexOfADPElement(siteCode, itemCode, saleOrder,lineNo);
}
//System.out.println("4072----index---"+index);
System.out.println("4072----index---"+index);
/*if (isBomReplace)
{
//cpatil-25/08/14-System.out.println("12/06/14 index [" + index+ "] itemCode [" + itemCode + "] dueDate [" + dueDate + "] quantity [" + quantity + "] saleOrder [" + saleOrder + "] lineNo [" + lineNo +"]");
......@@ -6625,6 +6945,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
//cpatil-25/08/14-System.out.println("12/06/14 setting demand 2 itemCode [" + itemCode + "] dueDate [" + dueDate + "] quantity [" + quantity + "] saleOrder [" + saleOrder + "] lineNo [" + lineNo +"]");
}
System.out.println("300916 setting demand 2 itemCode [" + itemCode + "] dueDate [" + dueDate + "] quantity [" + quantity + "] saleOrder [" + saleOrder + "] lineNo [" + lineNo +"]");
adpElement.setDemand(dueDate, quantity, saleOrder, lineNo);
adpeList.set(index, adpElement);
......@@ -6634,6 +6955,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
else
{
System.out.println("300916 6928[" + itemCode + "] dueDate [" + dueDate + "] quantity [" + quantity + "] saleOrder [" + saleOrder + "] lineNo [" + lineNo +"]");
if (isBomReplace)
{
System.out.println("12/06/14 adding demand 1 itemCode [" + itemCode + "] dueDate [" + dueDate + "] quantity [" + quantity + "] saleOrder [" + saleOrder + "] lineNo [" + lineNo +"]");
......@@ -6784,11 +7106,11 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
for (ctr = 0; ctr < adpeList.size(); ctr++)
{
adpElement = (ADPElement) adpeList.get(ctr);
//System.out.println("adpElement------getSiteCode" + adpElement.getSiteCode());
//System.out.println("adpElement------getItemCode" + adpElement.getItemCode());
//System.out.println("adpElement------getSaleOrder" + adpElement.getSaleOrder());
//System.out.println("adpElement------getLineNo" + adpElement.getLineNo());
//System.out.println("siteCode["+siteCode+"]itemCode["+itemCode+"]saleOrder["+saleOrder+"]lineNo["+lineNo+"]");
System.out.println("adpElement------getSiteCode[" + adpElement.getSiteCode()+"]");
System.out.println("adpElement------getItemCode[" + adpElement.getItemCode()+"]");
System.out.println("adpElement------getSaleOrder[" + adpElement.getSaleOrder()+"]");
System.out.println("adpElement------getLineNo[" + adpElement.getLineNo()+"]");
System.out.println("siteCode["+siteCode+"]itemCode["+itemCode+"]saleOrder["+saleOrder+"]lineNo["+lineNo+"]");
//if ((adpElement.getSiteCode().equals(siteCode)) && (adpElement.getItemCode().equals(itemCode)) && (adpElement.getSaleOrder().equals(saleOrder)) && (adpElement.getLineNo().equals(lineNo)))
if (( adpElement.getSiteCode().equals(siteCode)) && (adpElement.getItemCode().equals(itemCode)) && (adpElement.getSaleOrder().equals(saleOrder)) && ( (adpElement.getLineNo()==null?"":adpElement.getLineNo()).equals(lineNo)))
{
......@@ -7012,8 +7334,8 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
isbomReplaceFlag= true;
ConnDriver connDriver = new ConnDriver();
//Changed by Poonam Gole for changing connection object :Start
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection() ;
conn = connDriver.getConnectDB("DriverITM");
//conn = getConnection() ;
//Changed by Poonam Gole for changing connection object :End
}
......@@ -8413,7 +8735,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
PreparedStatement pstmt4 = null;
ResultSet rs4 = null;
String MTOWoMps="";
try
{
//System.out.println("@@@@@@@@@cpatil:InsertPlanDemand called----winName["+winName+"] list["+list+"]--------");
......@@ -8580,7 +8902,17 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
xmlValues = xmlValues + "<current_batch_qty><![CDATA[" + quantity + "]]></current_batch_qty>";
xmlValues = xmlValues + "</Detail1></Root>";
System.out.println("@@@@@@@@@@@@@@@@@ 8196 winName["+winName+"]mfgType["+mpsOrder.mfgType+"]yieldPerc["+yieldPerc+"]");
if ("O".equals(mpsOrder.mfgType))
// Provision provide to create MPS for FG item having manufacturing type as ‘Make to Order’. M16FSAV004
MTOWoMps = mfgCommon.getEnvMfg("999999", "MTO_WO_MPS", conn);
if( MTOWoMps == null || MTOWoMps.trim().length() == 0 || "NULLFOUND".equalsIgnoreCase(MTOWoMps))
{
MTOWoMps = "W";
}
System.out.println("@@@@@@@9606 MTOWoMps["+MTOWoMps+"]mpsOrder.mfgType["+mpsOrder.mfgType+"]");
if ("O".equals(mpsOrder.mfgType) && (!"M".equalsIgnoreCase(MTOWoMps))) // added 2nd condition for MTO_WO_MPS
{
pstmtWorkOrder = conn.prepareStatement(sqlWorkOrder);
......@@ -11033,8 +11365,8 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
try
{
conn.close();
conn = null;
//conn.close();
//conn = null;
retTabSepStrBuff = null;
valueXmlString = null;
reqValueXmlString = null;
......@@ -11175,7 +11507,7 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
private void Write2XSL() throws ITMException
private void Write2XSL( Connection conn) throws ITMException
{
String errCode = "", date;
String errString = "";
......@@ -11233,8 +11565,9 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
SimpleDateFormat sdf = new SimpleDateFormat("MM/dd/yyyy");
final String[] titles =
{ "Site Code", "Item Code", "Item Description", "Supply Source", "Demand", "Supply", "Stock Qty", "Other Supply", "Pending PO", "Pending DO", "Pending Indent", "Pending DR", "Due Date", "Plan Supply", "Running Demand", "Running Supply", "Running Plan Supply", "Independent Demand", "Bom Code", "Order Opt", "Batch Qty Type", "Unit", "Min Order Qty", "Integral Qty", "Max Qty", "Min Qty", "Reorder Qty", "Yield Perc", "Min Plan %", "Batch Qty", "Purc Rate", "Pur Lead Time", "QC Lead Time", "MFG Lead Time" };
{ "Site Code","Item Type", "Item Code", "Item Description", "Supply Source", "Demand", "Supply", "Stock Qty", "Other Supply", "Pending PO", "Pending DO", "Pending Indent", "Pending DR", "Due Date", "Plan Supply", "Running Demand", "Running Supply", "Running Plan Supply", "Independent Demand", "Bom Code", "Order Opt", "Batch Qty Type", "Unit", "Min Order Qty", "Integral Qty", "Max Qty", "Min Qty", "Reorder Qty", "Yield Perc", "Min Plan %", "Batch Qty", "Purc Rate", "Pur Lead Time", "QC Lead Time", "MFG Lead Time" };
// 30
String itemType="";
try
{
......@@ -11304,6 +11637,21 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
mfgLeadTime = adpElement.getMfgLeadTime();
desc = adpElement.getItemDescr();
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql="";
System.out.println("@@@@@ itemCode["+itemCode+"]");
sql = "select item_type from item where item_code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString( 1, itemCode );
rs = pstmt.executeQuery();
if (rs.next())
{
itemType = checkNull(rs.getString(1));
}
rs.close();rs = null;
pstmt.close();pstmt = null;
ArrayList timeMRParr = adpElement.getTimeMrpList();
for (int timeCtr = 0; timeCtr < timeMRParr.size(); timeCtr++)
{
......@@ -11340,52 +11688,53 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
// if(flag)
// {
row.getCell(0).setCellValue(siteCode);
row.getCell(1).setCellValue(itemCode);
row.getCell(2).setCellValue(desc);
row.getCell(3).setCellValue(suppSour);
row.getCell(1).setCellValue(itemType);
row.getCell(2).setCellValue(itemCode);
row.getCell(3).setCellValue(desc);
row.getCell(4).setCellValue(suppSour);
// }
row.getCell(4).setCellValue(demand);
row.getCell(5).setCellValue(supply);
row.getCell(6).setCellValue(stockQty);
row.getCell(7).setCellValue(othSupply);
row.getCell(5).setCellValue(demand);
row.getCell(6).setCellValue(supply);
row.getCell(7).setCellValue(stockQty);
row.getCell(8).setCellValue(othSupply);
// Changed by Gulzar on 4/27/2012
row.getCell(8).setCellValue(pendPOQty);
row.getCell(9).setCellValue(pendDOQty);
row.getCell(10).setCellValue(pendIndQty);
row.getCell(11).setCellValue(pendDRQty);
row.getCell(9).setCellValue(pendPOQty);
row.getCell(10).setCellValue(pendDOQty);
row.getCell(11).setCellValue(pendIndQty);
row.getCell(12).setCellValue(pendDRQty);
// End Changes by Gulzar on 4/27/2012
cell = row.getCell(12);
cell = row.getCell(13);
cell.setCellValue(HSSFDateUtil.getExcelDate(dueDate));
cellStyle.setDataFormat(HSSFDataFormat.getBuiltinFormat("m/d/yy"));
cell.setCellStyle(cellStyle);
row.getCell(13).setCellValue(planSupply);
row.getCell(14).setCellValue(runningDemand);
row.getCell(15).setCellValue(runningSupply);
row.getCell(16).setCellValue(runningPlanSupply);
row.getCell(17).setCellValue(independentDemand);
row.getCell(14).setCellValue(planSupply);
row.getCell(15).setCellValue(runningDemand);
row.getCell(16).setCellValue(runningSupply);
row.getCell(17).setCellValue(runningPlanSupply);
row.getCell(18).setCellValue(independentDemand);
// if(flag)
// {
row.getCell(18).setCellValue(bomCode);
row.getCell(19).setCellValue(orderOpt);
row.getCell(20).setCellValue(batchQtyType);
row.getCell(21).setCellValue(unit);
row.getCell(22).setCellValue(minOrderQty);
row.getCell(23).setCellValue(integralQty);
row.getCell(24).setCellValue(maxQty);
row.getCell(25).setCellValue(minQty);
row.getCell(26).setCellValue(reorderQty);
row.getCell(27).setCellValue(yieldPerc);
row.getCell(28).setCellValue(minPlanPerc);
row.getCell(29).setCellValue(batchQty);
row.getCell(30).setCellValue(purcRate);
row.getCell(31).setCellValue(purLeadTime);
row.getCell(32).setCellValue(qcLeadTime);
row.getCell(33).setCellValue(mfgLeadTime);
row.getCell(19).setCellValue(bomCode);
row.getCell(20).setCellValue(orderOpt);
row.getCell(21).setCellValue(batchQtyType);
row.getCell(22).setCellValue(unit);
row.getCell(23).setCellValue(minOrderQty);
row.getCell(24).setCellValue(integralQty);
row.getCell(25).setCellValue(maxQty);
row.getCell(26).setCellValue(minQty);
row.getCell(27).setCellValue(reorderQty);
row.getCell(28).setCellValue(yieldPerc);
row.getCell(29).setCellValue(minPlanPerc);
row.getCell(30).setCellValue(batchQty);
row.getCell(31).setCellValue(purcRate);
row.getCell(32).setCellValue(purLeadTime);
row.getCell(33).setCellValue(qcLeadTime);
row.getCell(34).setCellValue(mfgLeadTime);
// }
// flag = false; // 25/02/11 manoharan commented as BTPL
......@@ -11458,6 +11807,60 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
wb.write(out);
out.close();
// code for mail file to login user for sava M16FSAV001 start 16/09/16
String mailMrpReport = "";
MfgCommon mfgCommon=new MfgCommon();
StringBuffer commInfo = new StringBuffer();
String loginUser = "", mailRetStr="",formatCode="",emailAddr="",userType="";
loginUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
formatCode="MRPRPT";// send mail only for 'To'.
mailMrpReport = mfgCommon.getEnvMfg("999999","MAIL_MRP_REPORT",conn);
System.out.println("@@@@@ mailMrpReport["+mailMrpReport+"]loginUser["+loginUser+"]fileName["+fileName+"]mrpErrDetList["+mrpErrDetList+"]");
if( mailMrpReport != null && "Y".equalsIgnoreCase(mailMrpReport) && (mrpErrDetList == null || mrpErrDetList.size()==0) )
{
//emailAddr = setDescription("email_id_off", "employee", "emp_code", loginUser, conn);
emailAddr = getEmailId(loginUser, conn);
System.out.println("@@@@@ emailAddr["+emailAddr+"]");
commInfo.append("<ROOT>");
commInfo.append("<MAIL><EMAIL_TYPE>page</EMAIL_TYPE><ENTITY_CODE>BASE</ENTITY_CODE>");
commInfo.append("<ENTITY_TYPE>"+userType+"</ENTITY_TYPE>");
//commInfo.append("<TO_ADD>"+emailAddr+"</TO_ADD>");
commInfo.append("<TO_ADD></TO_ADD>");
commInfo.append("<BCC_ADD></BCC_ADD>");
commInfo.append("<FORMAT_CODE>"+formatCode+"</FORMAT_CODE>");
commInfo.append("<ATTACHMENT><BODY></BODY><LOCATION></LOCATION></ATTACHMENT>");
commInfo.append("</MAIL>");
//commInfo.append("<XML_DATA><ROOT><Detail1><cust_code>"+custCode+"</cust_code><site_code>"+siteCode+"</site_code><emp_code>"+loginUser+"</emp_code>");
commInfo.append("<XML_DATA><ROOT><Detail1><emp_code>"+loginUser+"</emp_code>");
commInfo.append("<email_addr>"+emailAddr+"</email_addr><cc_to></cc_to></Detail1></ROOT></XML_DATA>");
commInfo.append("<EMAIL_TYPE>page</EMAIL_TYPE><XML_DATA_FILE_PATH>"+fileName+"</XML_DATA_FILE_PATH><ENTITY_CODE></ENTITY_CODE>");
commInfo.append("</ROOT>");
EMail email = new EMail();
mailRetStr=email.sendMail(commInfo.toString(), "ITM");
System.out.println("@V@ Mail return String :- ["+mailRetStr+"]");
if(mailRetStr.contains("S"))
{
System.out.println("@V@ loginUser :- [" + loginUser + "] Email Addres :- [" + emailAddr + "]");
//fos1.write(("\n Email send SUCCESSFULLY for Customer code :- [" + custCode + "]").getBytes());
}
else
{
System.out.println("@V@ Email addr NOT FOUND for loginUser :- [" + loginUser + "]");
//fos1.write(("\n Email sending FAIL for loginUser :- [" + loginUser + "]").getBytes());
}
}
// code for mail file to login user for sava M16FSAV001 end 16/09/16
// System.out.println("End of collected datas......");
resultString = retTabSepStrBuff.toString();
} catch (SQLException se)
......@@ -11474,8 +11877,8 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
{
try
{
conn.close();
conn = null;
//conn.close();
//conn = null;
retTabSepStrBuff = null;
} catch (Exception e)
{
......@@ -12401,6 +12804,418 @@ public class RunMRPPrc extends ProcessEJB implements RunMRPPrcLocal, RunMRPPrcRe
return dataMap;
}
private String errorType(Connection conn, String errorCode) {
String msgType = "";
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
String sql = "SELECT MSG_TYPE FROM MESSAGES WHERE MSG_NO = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, errorCode);
rs = pstmt.executeQuery();
while (rs.next()) {
msgType = checkNull(rs.getString("MSG_TYPE"));
}
} catch (Exception ex) {
ex.printStackTrace();
} finally {
try {
if (rs != null) {
rs.close();
rs = null;
}
if (pstmt != null) {
pstmt.close();
pstmt = null;
}
} catch (Exception e) {
e.printStackTrace();
}
}
return msgType;
}
private void generateMRPLogReport(ArrayList<String> mrpErrDetList,String key,String chgUser,Connection conn) throws SQLException //for error_report @19/09/16
{
PreparedStatement pstmt = null;
String errMsg = "",sql="";
String reportName="d_mrp_log",xmlString="",reportType = "PDF",formatCode="MRPERRRPT",retString="";
String reportArgs="last_event.String:as_last_event";
System.out.println("@@@@mrpErrDetList.size["+mrpErrDetList.size()+"]key["+key+"]userId["+userId+"]chgUser["+chgUser+"]");
int cnt=0;
sql = " insert into mrp_log ( last_event , event_value ) values ( ? , ? ) ";
pstmt = conn.prepareStatement(sql);
for( int i=0; i < mrpErrDetList.size(); i++ )
{
errMsg = checkNull(mrpErrDetList.get(i));
System.out.println("@@@@1100 i["+i+"]errMsg["+errMsg+"]");
if( errMsg != null && errMsg.trim().length() > 0)
{
cnt++;
pstmt.setString(1,key);
pstmt.setString(2,errMsg);
pstmt.addBatch();
pstmt.clearParameters();
}
}
System.out.println("@@@@@1154 cnt["+cnt+"]");
if(cnt > 0)
{
pstmt.executeBatch();
pstmt.clearBatch();
conn.commit();
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
// for generate report
StringBuffer xmlBuff = null;
xmlBuff = new StringBuffer();
xmlBuff.append("<?xml version='1.0' encoding='UTF-8'?>\n");
xmlBuff.append("<DocumentRoot>");
xmlBuff.append("<description>").append("Datawindow Root").append("</description>");
xmlBuff.append("<group0>");
xmlBuff.append("<description>").append("Group0 description").append("</description>");
xmlBuff.append("<Header0>");
// xmlBuff.append("<objName><![CDATA[").append("distrcp_exsh").append("]]></objName>");
xmlBuff.append("<objName><![CDATA[").append("mrp_log").append("]]></objName>");
xmlBuff.append("<pageContext><![CDATA[").append("1").append("]]></pageContext>");
xmlBuff.append("<objContext><![CDATA[").append("1").append("]]></objContext>");
xmlBuff.append("<editFlag><![CDATA[").append("A").append("]]></editFlag>");
xmlBuff.append("<focusedColumn><![CDATA[").append("").append("]]></focusedColumn>");
xmlBuff.append("<action><![CDATA[").append("SAVE").append("]]></action>");
xmlBuff.append("<elementName><![CDATA[").append("").append("]]></elementName>");
xmlBuff.append("<keyValue><![CDATA[").append("1").append("]]></keyValue>");
xmlBuff.append("<saveLevel><![CDATA[").append("1").append("]]></saveLevel>");
xmlBuff.append("<forcedSave><![CDATA[").append(true).append("]]></forcedSave>");
xmlBuff.append("<description>").append("Header0 members").append("</description>");
xmlBuff.append("<Detail1 objContext=\"1\" objName=\"mrp_log\" domID=\"\" dbID=\"\">");
xmlBuff.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\"/>");
//xmlBuff.append("<cust_code><![CDATA["+ custCode.trim() +"]]></cust_code>");
xmlBuff.append("<site_code><![CDATA["+ logInSite.trim() +"]]></site_code>");
xmlBuff.append("</Detail1>");
xmlBuff.append("</Header0>");
xmlBuff.append("</group0>");
xmlBuff.append("</DocumentRoot>");
xmlString = xmlBuff.toString();
System.out.println("@V@ xmlString for sendReport:-["+xmlString+"]");
retString= this.sendReport(chgUser,key,xmlString, reportName, reportArgs, reportType, formatCode, xtraParams, conn);
System.out.println("@@@@@@1211 retString["+retString+"]");
//return retString;
}
private String getEmailId(String chgUser,Connection conn) throws SQLException //for error_report @19/09/16
{
PreparedStatement pStmt = null;
ResultSet rs = null;
String sql="",emailId="",empCode="";
System.out.println("@@@@ chgUser["+chgUser+"]");
sql = " select email_id,emp_code from users where code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, chgUser);
rs = pStmt.executeQuery();
if (rs.next())
{
emailId = checkNull(rs.getString("email_id"));
empCode = checkNull(rs.getString("emp_code"));
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
System.out.println("@@@@ chgUser["+chgUser+"]empCode["+empCode+"]emailId["+emailId+"]");
if( emailId == null || emailId.trim().length() == 0 )
{
sql = " select email_id_of from employee where emp_code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, empCode);
rs = pStmt.executeQuery();
if (rs.next())
{
emailId = checkNull(rs.getString("email_id_of"));
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
System.out.println("@@@@ empCode["+empCode+"]emailId["+emailId+"]");
}
//System.out.println("@@@@@ emailId["+emailId+"]");
return emailId;
}
private String sendReport(String empCode,String key, String xmlString, String reportName, String reportArgs, String reportType,
String formatCode, String xtraParams, Connection conn)
{
String argumentString = "";
ibase.utility.E12GenericUtility genericUtility = new ibase.utility.E12GenericUtility();
String messageStr = "SEND_SUCCESS";
String emailAddr="", userType="";//empCode="";
ITMDBAccessEJB itmDBAccessEJB = null;
itmDBAccessEJB = new ITMDBAccessEJB();
StringBuffer commInfo = new StringBuffer();
boolean isError = false;
boolean isFileNotEmpty=false;
String reportDestination = "";
String mailRetStr="",siteCode="";
try
{
System.out.println("@V@ xmlString :-"+xmlString);
System.out.println("@V@ reportName :-["+reportName +"]");
System.out.println("@V@ reportArgs :-["+reportArgs +"]");
System.out.println("@V@ reportType :-["+reportType +"]");
System.out.println("@V@ formatCode :-["+formatCode +"]");
System.out.println("@V@ xtraParams :-["+xtraParams +"]");
String argName = "";
String argType = "";
String rptArgName = "";
String argValue = "";
Document xmlDom = genericUtility.parseString(xmlString);
siteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode");
if(reportArgs != null && reportArgs.trim().length() > 0)
{
String[] argNameArray= reportArgs.split(",");
argumentString= "<Arguments>";
for ( int cnt = 0 ; cnt < argNameArray.length ; cnt++ )
{
argName = argNameArray[cnt].substring( 0 , argNameArray[cnt].lastIndexOf("."));
if(argNameArray[cnt].lastIndexOf(":") != -1)
{
rptArgName = argNameArray[cnt].substring( argNameArray[cnt].lastIndexOf(":") + 1 , argNameArray[cnt].length());
argType = argNameArray[cnt].substring( argNameArray[cnt].lastIndexOf(".")+1 , argNameArray[cnt].lastIndexOf(":"));
}
else
{
rptArgName = argName;
argType = argNameArray[cnt].substring( argNameArray[cnt].lastIndexOf(".")+1 );
}
if("last_event".equalsIgnoreCase(argName))
{
argValue = key;
}
argumentString += "<Argument id=\"" + rptArgName + "\" name = \"" + rptArgName + "\">";
argumentString += "<argType>" + argType +"</argType>";
argumentString += "<value>" + argValue +"</value>";
argumentString += "</Argument>" ;
}
argumentString += "</Arguments>";
}
System.out.println("@V@ argumentString :- ["+argumentString+"]");
String userName = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("@V@ user name found from xtraParams :- ["+userName+"]");
String outputFilename = reportName +"_"+userName+"_"+ argValue;
//String outputFilename = reportName +"_"+userName;
outputFilename = outputFilename.replaceAll(" ", "_");
outputFilename = outputFilename.replaceAll("/", "");
outputFilename = outputFilename.replaceAll(":", "");
System.out.println("@V@ outputFilename :- ["+outputFilename+"]");
if("HTML".equalsIgnoreCase(reportType) || "PDF".equalsIgnoreCase(reportType) || "CSV".equalsIgnoreCase(reportType)
|| "CSVDATA".equalsIgnoreCase(reportType) || "EXCEL".equalsIgnoreCase(reportType) || "EXCELDATA".equalsIgnoreCase(reportType)
|| "TEXT".equalsIgnoreCase(reportType) || "ODS".equalsIgnoreCase(reportType) || "EXCEL(XLSX)".equalsIgnoreCase(reportType))
{
System.out.println("@V@ Report extention found :- ["+reportType+"]");
XSDParser xsdParser = new XSDParser(reportName);
ArgumentHandler argObj = new ArgumentHandler(xsdParser);
argObj.init();
JasperReportGenerator jasperReport= new JasperReportGenerator();
TreeMap argMap = jasperReport.createArgMap(argumentString);
argMap.put("report_save_type", reportType);
String rptExt = "";
System.out.println("@V@ checking report ext @@");
if("CSV".equalsIgnoreCase(reportType) || "CSVDATA".equalsIgnoreCase(reportType) )
{
rptExt = "csv";
}
else if("EXCEL".equalsIgnoreCase(reportType) || "EXCELDATA".equalsIgnoreCase(reportType) || "ODS".equalsIgnoreCase(reportType) )
{
rptExt = "xls";
}
else if("EXCEL(XLSX)".equalsIgnoreCase(reportType) )
{
rptExt = "xlsx";
}
else if("TEXT".equalsIgnoreCase(reportType) )
{
rptExt = "txt";
}
else if("PDF".equalsIgnoreCase(reportType) )
{
rptExt = "pdf";
}
else
{
rptExt = reportType.toLowerCase();
}
System.out.println("@V@ Report ext found :- ["+rptExt+"] creating report now");
System.out.println("@V@ Report Name :- ["+reportName+"]");
System.out.println("@V@ Arg Map :- ["+argMap+"]");
System.out.println("@V@ XSD Parser :- ["+xsdParser+"]");
System.out.println("@V@ User Name :- ["+userName+"]");
System.out.println("@V@ Out Put file name :- ["+outputFilename+"]");
jasperReport.createReport(reportName ,argMap, xsdParser, userName,outputFilename);
String reportOutputFileName = jasperReport.getOutputFileName();
System.out.println("@V@ Report OUT put file name :- ["+reportOutputFileName+"]");
reportDestination = ResourceConstants.REPORTDESTINATION + File.separator + userName + File.separator
+ reportOutputFileName + "." + rptExt;
System.out.println("@V@ Report Destination Path :- ["+reportDestination+"]");
/*
boolean isEmpty=isFileEmpty(reportDestination);
System.out.println("@V@ File ["+reportDestination+"] found check empty :- ["+isEmpty+"]");
if(isEmpty)
{
isFileNotEmpty=true;
}
else
{
isFileNotEmpty=false;
}
System.out.println("@V@ File not Empty :-["+isFileNotEmpty+"]");
*/
}
/*** Sending mail**/
//if(isFileNotEmpty && (formatCode != null && formatCode.trim().length() > 0) )
if((formatCode != null && formatCode.trim().length() > 0) )
{
emailAddr = getEmailId(empCode, conn);
System.out.println("@V@ Format Code :- ["+formatCode+"] emailAddr["+emailAddr+"]");
commInfo.append("<ROOT>");
commInfo.append("<MAIL><EMAIL_TYPE>page</EMAIL_TYPE><ENTITY_CODE>BASE</ENTITY_CODE>");
commInfo.append("<ENTITY_TYPE>"+userType+"</ENTITY_TYPE>");
//commInfo.append("<TO_ADD>"+emailAddr+"</TO_ADD>");
commInfo.append("<TO_ADD></TO_ADD>");
commInfo.append("<BCC_ADD></BCC_ADD>");
commInfo.append("<FORMAT_CODE>"+formatCode+"</FORMAT_CODE>");
commInfo.append("<ATTACHMENT><BODY></BODY><LOCATION></LOCATION></ATTACHMENT>");
commInfo.append("</MAIL>");
//commInfo.append("<XML_DATA><ROOT><Detail1><cust_code>"+custCode+"</cust_code><site_code>"+siteCode+"</site_code><emp_code>"
commInfo.append("<XML_DATA><ROOT><Detail1><site_code>"+siteCode+"</site_code><emp_code>"
+empCode+"</emp_code>");
commInfo.append("<email_addr>"+emailAddr+"</email_addr><cc_to></cc_to></Detail1></ROOT></XML_DATA>");
commInfo.append("<EMAIL_TYPE>page</EMAIL_TYPE><XML_DATA_FILE_PATH>"+reportDestination
+"</XML_DATA_FILE_PATH><ENTITY_CODE></ENTITY_CODE>");
commInfo.append("</ROOT>");
EMail email = new EMail();
mailRetStr=email.sendMail(commInfo.toString(), "ITM");
System.out.println("@V@ Mail return String :- ["+mailRetStr+"]");
if(mailRetStr.contains("S"))
{
System.out.println("@V@ Cust code :- [" + empCode + "] Email Addres :- [" + emailAddr + "]");
//fos1.write(("\n Email send SUCCESSFULLY for Customer code :- [" + custCode + "]").getBytes());
}
else
{
System.out.println("@V@ Email addr NOT FOUND for Cust code :- [" + empCode + "]");
//fos1.write(("\n Email sending FAIL for Customer code :- [" + custCode + "]").getBytes());
}
}
else
{
System.out.println("@V@ Skipping the mail for :-["+empCode+"]");
//fos1.write(("\n Skipping the mail for Customer code :- [" + custCode + "] the reoprt file may be empty").getBytes());
}
}
catch(Exception e)
{
isError = true;
try
{
messageStr = itmDBAccessEJB.getErrorString("", "RPTFAILED", "");
//String errMsg = e.getMessage();
//generateLog("REPORT Sending Failed :"+errMsg, reportName, reportDestination, formatCode, xtraParams);
}
catch(Exception se)
{
}
System.out.println("@V@ Exception :- ["+e.getMessage()+"]");
e.printStackTrace();
}
finally
{
try
{
System.out.println("@V@ isError in finally :- ["+isError+"]");
if(!isError)
{
messageStr = itmDBAccessEJB.getErrorString("", "REPORTSUCC", "");
System.out.println("@V@ Message Str :- ["+messageStr+"]");
//generateLog("Status : MSG_NO :REPORTSUCC", reportName, reportDestination, formatCode, xtraParams);
}
}
catch(Exception fe)
{
System.out.println("Exception ::"+fe.getMessage());
fe.printStackTrace();
}
}
System.out.println("@V@ messageStr :- ["+messageStr+"]");
return messageStr;
}
private boolean isFileEmpty(String reportDestination)
{
// TODO Auto-generated method stub
try
{
HSSFWorkbook wBook = new HSSFWorkbook(new FileInputStream(reportDestination));
for(int sCnt=0; sCnt< wBook.getNumberOfSheets();sCnt++)
{
HSSFSheet sheet=wBook.getSheetAt(sCnt);
Iterator rows = sheet.rowIterator();
while (rows.hasNext()) {
HSSFRow row = (HSSFRow) rows.next();
Iterator cells = row.cellIterator();
while (cells.hasNext()) {
HSSFCell cell = (HSSFCell) cells.next();
if(!cell.getStringCellValue().isEmpty()){
return true;
}
}
}
}
} catch (IOException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
}
}
//Added by Jiten 07/11/06
......
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