Skip to content

B
business-java
Commit c0c2d7f3 authored by dkasliwal's avatar dkasliwal
Browse files
Options

Add FG Warehouse dashboard 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@105013 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 91a80c56
Hide whitespace changes
Inline Side-by-side
Showing with 1574 additions and 124 deletions
webitm-dashboard/ibase/dashboard/wms/ejb/EORLocationStock.java
View file @ c0c2d7f3
package ibase.dashboard.wms.ejb; package ibase.dashboard.wms.ejb;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.sql.Connection; import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
import javax.ejb.Stateless; import javax.ejb.Stateless;
/** /**
...@@ -22,21 +22,20 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe ...@@ -22,21 +22,20 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe
public EORLocationStock() public EORLocationStock()
{ {
} }
E12GenericUtility e12GenericUtility = new E12GenericUtility();
public String getEORLocPhyArea() throws RemoteException, ITMException public String getEORLocPhyArea() throws RemoteException, ITMException
{ {
String sql = ""; String sql = "";
ResultSet rs = null; ResultSet rs = null;
Connection conn = null; Connection conn = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
StringBuffer xmlData = null; ConnDriver connDriver = new ConnDriver();
StringBuffer xmlData = null;
try try
{ {
/*conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver = null;*/ connDriver = null;
/*add new code for connection DB on dated:16062016 by Nikhil*/
conn = getConnection();
sql = "select distinct loc_phy_area from location order by loc_phy_area "; sql = "select distinct loc_phy_area from location order by loc_phy_area ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -91,13 +90,12 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe ...@@ -91,13 +90,12 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe
ResultSet rs = null; ResultSet rs = null;
Connection conn = null; Connection conn = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ConnDriver connDriver = new ConnDriver();
String selectedArea = ""; String selectedArea = "";
try try
{ {
/*conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver = null;*/ connDriver = null;
/*add new code for connection DB on dated:14062016 by Nikhil*/
conn = getConnection();
sql = " select distinct loc_phy_area from location order by loc_phy_area "; sql = " select distinct loc_phy_area from location order by loc_phy_area ";
...@@ -144,33 +142,32 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe ...@@ -144,33 +142,32 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe
public String getEORLocDtl(String locPhyArea, String siteCode, String locationRange, String expDate, String reTestDate, String occupiedRack) throws RemoteException, ITMException public String getEORLocDtl(String locPhyArea, String siteCode, String locationRange, String expDate, String reTestDate, String occupiedRack) throws RemoteException, ITMException
{ {
String sql = ""; String sql = "";
ResultSet rs = null, rs1 = null; ResultSet rs = null, rs1 = null;
Connection conn = null; Connection conn = null;
PreparedStatement pstmt = null, pstmt1 = null; PreparedStatement pstmt = null, pstmt1 = null;
StringBuffer xmlData = null; ConnDriver connDriver = new ConnDriver();
String previousRow = ""; StringBuffer xmlData = null;
String previousStack = ""; String previousRow = "";
String currentRow = ""; String previousStack = "";
String cuurentStack = ""; String currentRow = "";
String locationCode = " "; String cuurentStack = "";
StringBuffer sqlStr = null; String locationCode = " ";
int count = 0; StringBuffer sqlStr = null;
String locCode = ""; int count = 0;
String locCode = "";
//String sysDate = "sysdate()"; //String sysDate = "sysdate()";
String sysDate = "sysdate"; String sysDate = "sysdate";
final String yseString = "Yes"; final String yseString = "Yes";
final String noString = "No"; final String noString = "No";
try try
{ {
System.out.println(" occupiedRack =" + occupiedRack); System.out.println(" occupiedRack =" + occupiedRack);
//sysDate = "sysdate"; //sysDate = "sysdate";
sqlStr = new StringBuffer(); sqlStr = new StringBuffer();
/*conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver = null;*/ connDriver = null;
/*add new code for connection DB on dated:14062016 by Nikhil*/
conn = getConnection();
if (locationRange != null && locationRange.trim().length() > 0) if (locationRange != null && locationRange.trim().length() > 0)
{ {
locCode = "AND loc_code like '" + locationRange + "%'"; locCode = "AND loc_code like '" + locationRange + "%'";
...@@ -374,18 +371,17 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe ...@@ -374,18 +371,17 @@ public class EORLocationStock extends ValidatorEJB implements EORLocationStockRe
System.out.println(" in getSiteCode method os EORLocationStock"); System.out.println(" in getSiteCode method os EORLocationStock");
String sql = ""; String sql = "";
ResultSet rs = null; ResultSet rs = null;
Connection conn = null; Connection conn = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
StringBuffer xmlData = null; ConnDriver connDriver = new ConnDriver();
String siteCode = ""; StringBuffer xmlData = null;
String siteCode = "";
try try
{ {
/*conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver = null;*/ connDriver = null;
/*add new code for connection DB on dated:14062016 by Nikhil*/
conn = getConnection();
// sql = "select distinct loc_phy_area from location order by loc_phy_area "; // sql = "select distinct loc_phy_area from location order by loc_phy_area ";
sql = "SELECT VAR_VALUE FROM DISPARM WHERE PRD_CODE='999999' AND VAR_NAME='SITE_CODE'"; sql = "SELECT VAR_VALUE FROM DISPARM WHERE PRD_CODE='999999' AND VAR_NAME='SITE_CODE'";
System.out.println(" sql is =" + sql); System.out.println(" sql is =" + sql);
......
webitm-dashboard/ibase/dashboard/wms/ejb/FGWarehouse.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.ejb;
import ibase.dashboard.Report.Utility.DashboardUtility;
import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.io.File;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import javax.ejb.Stateless;
import org.json.simple.JSONObject;
/**
* Session Bean implementation class SalesPersonSales
*/
@Stateless
public class FGWarehouse extends ValidatorEJB implements FGWarehouseLocal, FGWarehouseRemote
{
public FGWarehouse() {
}
GenericUtility genericUtility = GenericUtility.getInstance();
@SuppressWarnings("unchecked")
//public JSONObject getReceivableDashboard(String dataSourceName,String siteCode) throws RemoteException, ITMException
public JSONObject getReceivableDashboard(String dataSourceName,String siteCode, String facilityCode) throws RemoteException, ITMException
{
JSONObject rawDataReceivableJson = new JSONObject();
JSONObject rowData = null;
String sql = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" Inside FGWarehouse for getReceivableDashboard siteCode ="+siteCode);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
int count = 0;
facilityCode=checkNull(facilityCode);
if(facilityCode.equalsIgnoreCase(""))
{
facilityCode=getFacilityCode(siteCode, dataSourceName);
}
System.out.println("Facility Code: "+facilityCode);
sql = " Select round(sum(OverDue_Over_3Days),0) as OverDue_Over_3Days " +
" ,round(sum(OverDue_Over_2Days),0) as OverDue_Over_2Days " +
" ,round(sum(OverDue_Yesterday),0) as OverDue_Yesterday " +
" ,round(sum(OverDue_Today),0) as OverDue_Today " +
" ,round(sum(OverDue_Tomorrow),0) as OverDue_Tomorrow " +
" ,round(sum(OverDue_Day_After),0) as OverDue_Day_After " +
" ,round(sum(OverDue_Rest_of_week),0) as OverDue_Rest_of_week " +
" ,round(sum(OverDue_Next_Week),0) as OverDue_Next_Week " +
" ,round(sum(OverDue_Next_Month),0) as OverDue_Next_Month " +
" ,a.site_code, a.fin_entity, a.item_ser, a.cust_code, a.cust_name ,a.itm_descr " +
" from( " +
" select sum(r.tot_amt - r.adj_amt) as OverDue_Over_3Days, sum(0) as OverDue_Over_2Days, sum(0) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today, sum(0) as OverDue_Tomorrow, sum(0) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week, sum(0) as OverDue_Next_Week, sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between to_date(sysdate) -3 and to_date(sysdate) " +
" and r.cust_code=c.cust_code and r.item_ser=its.item_ser and r.site_code=s.site_code and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days, sum(r.tot_amt - r.adj_amt) as OverDue_Over_2Days ,sum(0) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today ,sum(0) as OverDue_Tomorrow ,sum(0) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week ,sum(0) as OverDue_Next_Week ,sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between to_date(sysdate) -2 and to_date(sysdate) " +
" and r.cust_code=c.cust_code and r.item_ser=its.item_ser and r.site_code=s.site_code and s.facility_code= '"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days " +
" ,sum(0) as OverDue_Over_2Days " +
" ,sum(r.tot_amt - r.adj_amt) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today " +
" ,sum(0) as OverDue_Tomorrow " +
" ,sum(0) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week " +
" ,sum(0) as OverDue_Next_Week " +
" ,sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between to_date(sysdate) -1 and to_date(sysdate) " +
" and r.cust_code=c.cust_code " +
" and r.item_ser=its.item_ser " +
" and r.site_code=s.site_code " +
" and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days " +
" ,sum(0) as OverDue_Over_2Days " +
" ,sum(0) as OverDue_Yesterday " +
" ,sum(r.tot_amt - r.adj_amt) as OverDue_Today " +
" ,sum(0) as OverDue_Tomorrow " +
" ,sum(0) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week " +
" ,sum(0) as OverDue_Next_Week " +
" ,sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between to_date(sysdate) and to_date(sysdate) " +
" and r.cust_code=c.cust_code " +
" and r.item_ser=its.item_ser " +
" and r.site_code=s.site_code " +
" and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days " +
" ,sum(0) as OverDue_Over_2Days " +
" ,sum(0) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today " +
" ,sum(r.tot_amt - r.adj_amt) as OverDue_Tomorrow " +
" ,sum(0) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week " +
" ,sum(0) as OverDue_Next_Week " +
" ,sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between to_date(sysdate) and to_date(sysdate)+1 " +
" and r.cust_code=c.cust_code " +
" and r.item_ser=its.item_ser " +
" and r.site_code=s.site_code " +
" and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days " +
" ,sum(0) as OverDue_Over_2Days " +
" ,sum(0) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today " +
" ,sum(0) as OverDue_Tomorrow " +
" ,sum(r.tot_amt - r.adj_amt) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week " +
" ,sum(0) as OverDue_Next_Week " +
" ,sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between to_date(sysdate) and to_date(sysdate)+2 " +
" and r.cust_code=c.cust_code " +
" and r.item_ser=its.item_ser " +
" and r.site_code=s.site_code " +
" and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days " +
" ,sum(0) as OverDue_Over_2Days " +
" ,sum(0) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today " +
" ,sum(0) as OverDue_Tomorrow " +
" ,sum(0) as OverDue_Day_After " +
" ,sum(r.tot_amt - r.adj_amt) as OverDue_Rest_of_week " +
" ,sum(0) as OverDue_Next_Week " +
" ,sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between to_date(sysdate) and TRUNC(sysdate+6, 'DAY') " +
" and r.cust_code=c.cust_code " +
" and r.item_ser=its.item_ser " +
" and r.site_code=s.site_code " +
" and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days " +
" ,sum(0) as OverDue_Over_2Days " +
" ,sum(0) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today " +
" ,sum(0) as OverDue_Tomorrow " +
" ,sum(0) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week " +
" ,sum(r.tot_amt - r.adj_amt) as OverDue_Next_Week " +
" ,sum(0) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between TRUNC(sysdate+6, 'DAY') and TRUNC(sysdate+12, 'DAY') " +
" and r.cust_code=c.cust_code " +
" and r.item_ser=its.item_ser " +
" and r.site_code=s.site_code " +
" and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" union all " +
" select sum(0) as OverDue_Over_3Days " +
" ,sum(0) as OverDue_Over_2Days " +
" ,sum(0) as OverDue_Yesterday " +
" ,sum(0) as OverDue_Today " +
" ,sum(0) as OverDue_Tomorrow " +
" ,sum(0) as OverDue_Day_After " +
" ,sum(0) as OverDue_Rest_of_week " +
" ,sum(0) as OverDue_Next_Week " +
" ,sum(r.tot_amt - r.adj_amt) as OverDue_Next_Month " +
" ,r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr as itm_descr " +
" from receivables r,customer c,site s,itemser its " +
" where r.tot_amt - r.adj_amt <> 0 " +
" and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end " +
" between TO_DATE(0||1||TO_CHAR(ADD_MONTHS(SYSDATE,1),'mmyyyy'),'ddmmyyyy') and (LAST_DAY(ADD_MONTHS(SYSDATE,1))) " +
" and r.cust_code=c.cust_code " +
" and r.item_ser=its.item_ser " +
" and r.site_code=s.site_code " +
" and s.facility_code='"+facilityCode+"' " +
" group by r.site_code,r.fin_entity,r.item_ser,c.cust_code,c.cust_name ,its.descr " +
" ) a " +
" group by a.site_code, a.fin_entity, a.item_ser, a.cust_code, a.cust_name ,a.itm_descr " +
" Order by a.site_code, a.fin_entity, a.item_ser, a.cust_code, a.cust_name,a.itm_descr ";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
double summaryVal = 0.0;
while (rs.next())
{
rowData = new JSONObject();
rowData.put("overdue_over_3days", checkZero(rs.getString("OverDue_Over_3Days")));
rowData.put("overdue_over_2days", checkZero(rs.getString("OverDue_Over_2Days")));
rowData.put("overdue_yesterday", checkZero(rs.getString("OverDue_Yesterday")));
rowData.put("overdue_today", checkZero(rs.getString("OverDue_Today")));
rowData.put("overdue_tomorrow", checkZero(rs.getString("OverDue_Tomorrow")));
rowData.put("overdue_day_after", checkZero(rs.getString("OverDue_Day_After")));
rowData.put("overdue_rest_of_week", checkZero(rs.getString("OverDue_Rest_of_week")));
rowData.put("overdue_next_week", checkZero(rs.getString("OverDue_Next_Week")));
rowData.put("overdue_next_month", checkZero(rs.getString("OverDue_Next_Month")));
rowData.put("site_code", checkNull(rs.getString("site_code")).trim());
rowData.put("fin_entity", checkNull(rs.getString("fin_entity")).trim());
rowData.put("item_ser", checkNull(rs.getString("item_ser")).trim());
rowData.put("cust_code", checkNull(rs.getString("cust_code")).trim());
rowData.put("cust_name", checkNull(rs.getString("cust_name")).trim());
rowData.put("itm_descr", checkNull(rs.getString("itm_descr")).trim());
rawDataReceivableJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getReceivableDashboard:" + d.getMessage());
throw new ITMException(d);
}
}
return rawDataReceivableJson;
}
@SuppressWarnings("unchecked")
@Override
//public JSONObject getCreditCompliance(String dataSourceName, String siteCode) throws RemoteException, ITMException
public JSONObject getCreditCompliance(String dataSourceName, String siteCode, String facilityCode) throws RemoteException, ITMException
{
JSONObject rawDataCreditComplianceJson = new JSONObject();
JSONObject rowData = null;
String sql = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" Inside FGWarehouse for getCreditCompliance siteCode ="+siteCode);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
int count = 0;
facilityCode=checkNull(facilityCode);
if(facilityCode.equalsIgnoreCase(""))
{
facilityCode=getFacilityCode(siteCode, dataSourceName);
}
System.out.println("Facility Code: "+facilityCode);
String userImagePath = CommonConstants.JBOSSHOME + File.separator +"server"+File.separator +"default"+File.separator +"deploy"+File.separator +"ibase.ear"+File.separator + "ibase.war" +File.separator + "resource" + File.separator + "images"+ File.separator + "users"+File.separator;
/*sql = " Select cust_code,cust_name,site_code, fin_entity,item_ser, sum(No_of_order) No_of_order, sum(Total_Order_Value) as Total_Order_Value " +
" from( " +
" Select cust.cust_code,cust.cust_name,so.site_code,s.fin_entity,so.item_ser, count(so.sale_order) as No_of_order ,so.tot_amt as Total_Order_Value " +
" from sorder so,sorddet sod ,customer cust,itemser its,site s " +
" where so.DUE_DATE <= sysdate " +
" and so.sale_order =sod.sale_order " +
" and so.item_ser = its.item_ser " +
" and so.cust_code =cust.cust_code " +
" and s.site_code =so.site_code " +
" and s.facility_code ='FC002' " +
" GROUP BY cust.cust_code, cust.cust_name, so.site_code, s.fin_entity, so.item_ser, so.sale_order, so.tot_amt " +
" ) " +
" group by cust_code,cust_name,site_code, fin_entity,item_ser " +
" order by cust_code, cust_name, site_code, fin_entity, item_ser ";*/
sql = "Select cust_code,cust_name,site_code, fin_entity,item_ser, itm_descr, sum(distinct No_of_order) No_of_order, " +
"sum(Total_Order_Value) as Order_Value ,sum(over_ridden_amount) over_ridden_amount " +
"from( Select cust.cust_code,cust.cust_name,so.site_code,s.fin_entity,so.item_ser, its.descr as itm_descr," +
"count(bl.sale_order) as No_of_order ,so.tot_amt as Total_Order_Value ,bl.aprv_amt as over_ridden_amount " +
"from sorder so,customer cust,itemser its,site s, business_logic_check bl where so.order_date <= sysdate " +
"and so.sale_order =bl.sale_order and so.item_ser =its.item_ser " +
"and so.cust_code =cust.cust_code and s.site_code =so.site_code " +
"and s.facility_code ='"+facilityCode+"' and so.cr_check_stat='F' " +
"GROUP BY cust.cust_code, cust.cust_name, so.site_code, s.fin_entity, " +
"so.item_ser, so.tot_amt, bl.aprv_amt,its.descr ) GROUP BY cust_code, cust_name, site_code, " +
"fin_entity, item_ser,itm_descr order by cust_code, cust_name, site_code, fin_entity, item_ser ";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next())
{
rowData = new JSONObject();
rowData.put("cust_code", checkNull(rs.getString("cust_code")).trim());
String custCode = checkNull(rs.getString("cust_code")).trim();
String custName = checkNull(rs.getString("cust_name")).trim();
File file = new File(userImagePath+custCode+".png");
if(file.exists())
{
rowData.put("custcode_image", "<img class='cardProdImg' src='"+CommonConstants.TOMCAT_HOME+"/ibase/resource/images/users/"+custCode+".png'/>");
}else
{
custName = custName.trim();
String[] splited = custName.split(" ");
String defaultUserImg = ""+splited[0].charAt(0);
if(splited.length>1)
{
/*Get lastWord of salesPersName and add first char to image for more than one space in salesPersName by Dhanendra on Date 07-07-2016 */
String lastWord = custName.substring(custName.lastIndexOf(" ")+1);
defaultUserImg = defaultUserImg + ""+lastWord.charAt(0);
}
rowData.put("custcode_image", "<div class='defaultUserImg'><div class='userImageChar'> "+defaultUserImg+"</div> </div>");
}
rowData.put("cust_name", checkNull(rs.getString("cust_name")).trim());
rowData.put("site_code", checkNull(rs.getString("site_code")).trim());
rowData.put("fin_entity", checkNull(rs.getString("fin_entity")).trim());
rowData.put("item_ser", checkNull(rs.getString("item_ser")).trim());
rowData.put("itm_descr", checkNull(rs.getString("itm_descr")).trim());
rowData.put("no_of_order", checkNull(rs.getString("No_of_order")).trim());
rowData.put("order_value", checkNull(rs.getString("Order_Value")).trim());
rowData.put("over_ridden_amount", checkNull(rs.getString("over_ridden_amount")).trim());
rawDataCreditComplianceJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getReceivableDashboard:" + d.getMessage());
throw new ITMException(d);
}
}
return rawDataCreditComplianceJson;
}
@SuppressWarnings("unchecked")
@Override
public JSONObject getCreditComplianceDetail(String dataSourceName, String siteCode, String finEntity, String itemSer, String custCode ) throws RemoteException, ITMException
{
JSONObject rawDataCreditComplianceDtlJson = new JSONObject();
JSONObject rowData = null;
String sql = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" ************* Inside FGWarehouse for getCreditComplianceDetail************ ");
System.out.println(" siteCode : "+siteCode);
System.out.println(" finEntity : "+finEntity);
System.out.println(" itemSer : "+itemSer);
System.out.println(" custCode : "+custCode);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
int count = 0;
/*sql = " Select cust.cust_code,cust.cust_name,so.site_code,s.fin_entity,so.item_ser, so.sale_order ,so.tot_amt as Total_Order_Value " +
" from sorder so,sorddet sod ,customer cust,itemser its,site s " +
" where so.DUE_DATE <= sysdate " +
" and so.sale_order =sod.sale_order " +
" and so.item_ser = its.item_ser " +
" and so.cust_code =cust.cust_code " +
" and s.site_code =so.site_code " +
" and so.cust_code ='"+custCode+"' " +
" and s.fin_entity ='"+finEntity+"' " +
" and so.item_ser ='"+itemSer+"' " +
" and so.site_code ='"+siteCode+"' " +
" GROUP BY cust.cust_code, cust.cust_name, so.site_code, s.fin_entity, so.item_ser, so.sale_order, so.tot_amt ";*/
sql=" Select so.cust_code,cust.cust_name, blc.sale_order ,blc.cr_policy,blc.descr,so.tot_amt as order_value , " +
" CASE when blc.cr_policy ='P06' then (select Max(busi_limit) from customer_series where cust_code=so.cust_code) " +
" else (select Max(CREDIT_LMT) from customer where cust_code=so.cust_code ) end as limit, " +
" fn_get_custos(so.cust_code,SO.SITE_CODE,'T') Exposure_due " +
" from sorder so,customer cust,itemser its,site s ,business_logic_check blc " +
" where so.order_date <= sysdate and so.sale_order =blc.sale_order" +
" and so.item_ser = its.item_ser and so.cust_code =cust.cust_code " +
" and so.cr_check_stat='F' " +
"and s.site_code =so.site_code and so.cust_code ='"+custCode+"' and s.fin_entity ='"+finEntity+"' " +
"and so.item_ser ='"+itemSer+"' and so.site_code ='"+siteCode+"' order by CUST.CUST_CODE, SO.SITE_CODE";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next())
{
rowData = new JSONObject();
rowData.put("cust_code", checkNull(rs.getString("cust_code")).trim());
rowData.put("cust_name", checkNull(rs.getString("cust_name")).trim());
//rowData.put("site_code", checkNull(rs.getString("site_code")).trim());
rowData.put("site_code", siteCode);
//rowData.put("fin_entity", checkNull(rs.getString("fin_entity")).trim());
//rowData.put("item_ser", checkNull(rs.getString("item_ser")).trim());
rowData.put("sale_order", checkNull(rs.getString("sale_order")).trim());
//rowData.put("total_order_value", checkNull(rs.getString("Total_Order_Value")).trim());
rowData.put("cr_policy", checkNull(rs.getString("cr_policy")).trim());
rowData.put("descr", checkNull(rs.getString("descr")).trim());
rowData.put("order_value", checkNull(rs.getString("order_value")).trim());
rowData.put("limit", checkNull(rs.getString("limit")).trim());
rowData.put("Exposure_due", checkNull(rs.getString("Exposure_due")).trim());
rawDataCreditComplianceDtlJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getReceivableDashboard:" + d.getMessage());
throw new ITMException(d);
}
}
return rawDataCreditComplianceDtlJson;
}
@SuppressWarnings("unchecked")
@Override
// public JSONObject getPendingShipment(String dataSourceName, String siteCode) throws RemoteException, ITMException
public JSONObject getPendingShipment(String dataSourceName, String siteCode, String facilityCode) throws RemoteException, ITMException
{
JSONObject rawDataPendingShipmentJson = new JSONObject();
JSONObject rowData = null;
String sql = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" ************* Inside FGWarehouse for getPendingShipment************ ");
System.out.println(" siteCode : "+siteCode);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
int count = 0;
facilityCode=checkNull(facilityCode);
if(facilityCode.equalsIgnoreCase(""))
{
facilityCode=getFacilityCode(siteCode, dataSourceName);
}
System.out.println("Facility Code: "+facilityCode);
/*sql = " select s.site_code, " +
" C.City, C.State_code , " +
" Count(Distinct C.cust_code) No_of_Customers, " +
" Sum(Quantity__STDUOM* Nvl(I.Net_Weight,0)) as Weight, " +
" Sum(SD.Ord_value) Order_Value, " +
" Count(Distinct Inv.Invoice_id) No_of_Shipments " +
" from sorder SO,Customer C,SOrddet SD,Item I,Invoice Inv, Site s " +
" where SO.cust_code=C.cust_code " +
" and SO.Sale_order=SD.Sale_order " +
" and so.sale_order=Inv.Sale_order " +
" and SD.Item_Code=I.Item_code " +
" and so.site_code = s.site_code " +
" and s.facility_code='FC002' " +
" group by C.City, C.State_code,s.site_code " +
" order by s.site_code,C.State_code,C.City ";*/
sql="select C.City, C.State_code ,k.distance as distance , c.stan_code,st.descr, " +
"Count(Distinct C.cust_code) No_of_Customers, " +
"Sum(Quantity__STDUOM* Nvl(I.Net_Weight,0)) as Weight, " +
"Sum(so.ord_amt) Order_Value, Count(Distinct d.desp_id) No_of_Shipments, " +
"so.site_code, s.fin_entity, so.item_ser,it.descr as itm_descr,state.descr as state_descr,C.cust_code from sorder SO,SOrddet SD, " +
"despatch d, Customer C,Item I,Invoice Inv,itemser it,site s,distance k,station st,state state " +
"where SO.cust_code = C.cust_code " +
"and SO.Sale_order = SD.Sale_order " +
"and so.sale_order =d.sord_no " +
"and so.sale_order =Inv.Sale_order " +
"and SD.Item_Code =I.Item_code " +
"and so.site_code =s.site_code " +
"and c.stan_code = st.stan_code " +
"and so.item_ser =it.item_ser " +
"and k.stan_code__from =s.stan_code " +
"and k.stan_code__to =c.stan_code " +
"AND c.State_code = state.State_code " +
"and s.facility_code ='"+facilityCode+"' " +
"group by C.City, C.State_code, k.distance, so.site_code, s.fin_entity, so.item_ser,c.stan_code,st.descr,it.descr,state.descr,C.cust_code " +
"order by C.City, C.State_code, so.site_code, s.fin_entity, so.item_ser,c.stan_code,st.descr ";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next())
{
rowData = new JSONObject();
rowData.put("site_code", checkNull(rs.getString("site_code")).trim());
rowData.put("city", checkNull(rs.getString("City")).trim());
rowData.put("state_code", checkNull(rs.getString("State_code")).trim());
rowData.put("distance", checkNull(rs.getString("distance")).trim());
rowData.put("no_of_customers", checkNull(rs.getString("No_of_Customers")).trim());
rowData.put("weight", checkNull(rs.getString("Weight")).trim());
rowData.put("order_value", checkNull(rs.getString("Order_Value")).trim());
if(count==0)
{
rowData.put("no_of_shipments", "10");
}
else if(count==1)
{
rowData.put("no_of_shipments", "20");
}
else{
rowData.put("no_of_shipments", checkNull(rs.getString("No_of_Shipments")).trim());
}
rowData.put("fin_entity", checkNull(rs.getString("fin_entity")).trim());
rowData.put("item_ser", checkNull(rs.getString("item_ser")).trim());
rowData.put("itm_descr", checkNull(rs.getString("itm_descr")).trim());
rowData.put("stan_code", checkNull(rs.getString("stan_code")).trim());
rowData.put("descr", checkNull(rs.getString("descr")).trim());
rowData.put("state_descr", checkNull(rs.getString("state_descr")).trim());
rowData.put("cust_code", checkNull(rs.getString("cust_code")).trim());
rawDataPendingShipmentJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getReceivableDashboard:" + d.getMessage());
throw new ITMException(d);
}
}
return rawDataPendingShipmentJson;
}
@SuppressWarnings("unchecked")
@Override
public JSONObject getCreditComplianceExposureDtl(String dataSourceName, String siteCode, String custCode ) throws RemoteException, ITMException
{
JSONObject rawDataCreditCompExpoDtlJson = new JSONObject();
JSONObject rowData = null;
String sql = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" ************* Inside FGWarehouse for getCreditComplianceExposureDtl************ ");
System.out.println(" siteCode : "+siteCode+"----- custCode :"+custCode);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
int count = 0;
sql=" select cust_code,site_code, ref_no as invoice_no,to_char(ref_date,'dd-MON-yy') as invoice_date,to_char(due_date,'dd-MON-yy') as due_date, tot_amt-adj_amt as balance_amt " +
" from receivables " +
" where cust_code = '"+custCode+"' " +
" and site_code = '"+siteCode+"' Order by 4,6 ";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next())
{
rowData = new JSONObject();
rowData.put("cust_code", checkNull(rs.getString("cust_code")).trim());
rowData.put("site_code", checkNull(rs.getString("site_code")).trim());
rowData.put("invoice_no", checkNull(rs.getString("invoice_no")).trim());
rowData.put("invoice_date", checkNull(rs.getString("invoice_date")).trim());
rowData.put("due_date", checkNull(rs.getString("due_date")).trim());
rowData.put("balance_amt", checkNull(rs.getString("balance_amt")).trim());
rawDataCreditCompExpoDtlJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getReceivableDashboard:" + d.getMessage());
throw new ITMException(d);
}
}
return rawDataCreditCompExpoDtlJson;
}
private String getFacilityCode(String siteCode, String dataSourceName) throws ITMException
{
String facilityCode = "";
String sql = "";
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try {
conn= connDriver.getConnectDB(dataSourceName);
connDriver = null;
sql = "Select facility_code from site where site_code='"+siteCode+"'";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if(rs.next())
{
facilityCode = checkNull(rs.getString("facility_code")).trim();
}
} catch (Exception e) {
e.printStackTrace();
throw new ITMException(e);
}finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getFacilityCode:" + d.getMessage());
throw new ITMException(d);
}
}
return facilityCode;
}
private String checkNull(String str)
{
if (str == null)
{
return "";
} else
{
return str.trim();
}
}
private String checkZero(String str)
{
if (str == null)
{
return "0";
} else
{
return str;
}
}
@SuppressWarnings("unchecked")
@Override
public JSONObject getReceivableDashboardDtl(String dataSourceName, String siteCode, String sessionSiteCode, String finEntity, String itemSeries, String custCode,String status) throws RemoteException,ITMException
{
JSONObject rawDataReceivableDtlJson = new JSONObject();
JSONObject rowData = null;
String sql = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
DashboardUtility dashboardUtility = null;
String falilityCode = "";
try
{
System.out.println(" Inside FGWarehouse for getReceivableDashboardDtl siteCode ="+siteCode);
dashboardUtility = new DashboardUtility();
conn = connDriver.getConnectDB(dataSourceName);
siteCode = dashboardUtility.getCommaSeparated(siteCode);
finEntity = dashboardUtility.getCommaSeparated(finEntity);
itemSeries = dashboardUtility.getCommaSeparated(itemSeries);
custCode = dashboardUtility.getCommaSeparated(custCode);
System.out.println(" status : "+status);
connDriver = null;
int count = 0;
String appendSqlStr = "";
if(siteCode.length()>0 && finEntity.length()>0 && itemSeries.length()>0 && custCode.length()>0)
{
appendSqlStr = " and r.cust_code in ("+custCode+") " +
" and r.site_code in ("+siteCode+") and r.item_ser in ("+itemSeries+") and r.fin_entity in ("+finEntity+") ";
}else
{
falilityCode = getFacilityCode(sessionSiteCode, dataSourceName);
appendSqlStr = "and s.facility_code='"+falilityCode+"' ";
}
if("Overdue over 3days".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between to_date(sysdate) -3 and to_date(sysdate)";
}else if("Overdue over 2days".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between to_date(sysdate) -2 and to_date(sysdate)";
}
else if("Overdue yesterday".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between to_date(sysdate) -1 and to_date(sysdate)";
}
else if("Overdue today".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between to_date(sysdate) and to_date(sysdate)";
}
else if("Overdue tomorrow".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between to_date(sysdate) and to_date(sysdate) +1";
}
else if("Overdue day after".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between to_date(sysdate) and to_date(sysdate) +2";
}
else if("Overdue rest of week".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between to_date(sysdate) and TRUNC(sysdate+6, 'DAY')";
}
else if("Overdue next week".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between TRUNC(sysdate+6, 'DAY') and TRUNC(sysdate+12, 'DAY')";
}
else if("Overdue next month".equalsIgnoreCase(status))
{
appendSqlStr = " and case when r.exp_rcp_date is null then r.due_date else r.exp_rcp_date end between TO_DATE(0||1||TO_CHAR(ADD_MONTHS(SYSDATE,1),'mmyyyy'),'ddmmyyyy') and (LAST_DAY(ADD_MONTHS(SYSDATE,1)))";
}
sql = " select c.cust_code,c.cust_name,r. site_code, r.ref_no as bill_no,to_char(r.ref_date,'dd-MON-yy') as bill_date, r.tot_amt as bill_amt, " +
" r.tot_amt-r.adj_amt as balance_amt,r.adj_amt as receipt_amt, to_char(r.due_date,'dd-MON-yy') as due_date " +
" ,its.descr as item_descr " +
" from receivables r ,customer c, itemser its,site s " +
" where " +
" c.cust_code = r.cust_code and s.site_code = r.site_code" +
" and its.item_ser = r.item_ser " +
appendSqlStr + " Order by 4,6 ";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next())
{
rowData = new JSONObject();
rowData.put("cust_code", checkNull(rs.getString("cust_code")));
rowData.put("cust_name", checkNull(rs.getString("cust_name")));
rowData.put("site_code", checkNull(rs.getString("site_code")));
rowData.put("bill_no", checkNull(rs.getString("bill_no")));
rowData.put("bill_date", checkNull(rs.getString("bill_date")));
rowData.put("bill_amt", checkNull(rs.getString("bill_amt")));
rowData.put("balance_amt", checkNull(rs.getString("balance_amt")));
rowData.put("receipt_amt", checkNull(rs.getString("receipt_amt")));
rowData.put("due_date", checkNull(rs.getString("due_date")));
rowData.put("item_descr", checkNull(rs.getString("item_descr")));
rawDataReceivableDtlJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getReceivableDashboard:" + d.getMessage());
throw new ITMException(d);
}
}
return rawDataReceivableDtlJson;
}
}
webitm-dashboard/ibase/dashboard/wms/ejb/FGWarehouseLocal.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.ejb;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
import org.json.simple.JSONObject;
@Local
public interface FGWarehouseLocal extends ValidatorLocal
{
/*public JSONObject getReceivableDashboard(String dataSourceName,String siteCode) throws RemoteException, ITMException;
public JSONObject getCreditCompliance(String dataSourceName,String siteCode) throws RemoteException, ITMException;
public JSONObject getCreditComplianceDetail(String dataSourceName, String siteCode, String finEntity, String itemSer, String custCode ) throws RemoteException, ITMException;
public JSONObject getPendingShipment(String dataSourceName, String siteCode) throws RemoteException, ITMException;
*/
public JSONObject getReceivableDashboard(String dataSourceName,String siteCode,String facilityCode) throws RemoteException, ITMException;
public JSONObject getReceivableDashboardDtl(String dataSourceName,String siteCode,String facilityCode,String finEntity,String itemSeries,String custCode,String status) throws RemoteException, ITMException;
public JSONObject getCreditCompliance(String dataSourceName,String siteCode, String facilityCode) throws RemoteException, ITMException;
public JSONObject getCreditComplianceDetail(String dataSourceName, String siteCode, String finEntity, String itemSer, String custCode ) throws RemoteException, ITMException;
public JSONObject getPendingShipment(String dataSourceName, String siteCode, String facilityCode) throws RemoteException, ITMException;
public JSONObject getCreditComplianceExposureDtl(String dataSourceName, String siteCode, String custCode ) throws RemoteException, ITMException;
}
webitm-dashboard/ibase/dashboard/wms/ejb/FGWarehouseRemote.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.ejb;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import org.json.simple.JSONObject;
@Remote
public interface FGWarehouseRemote extends ValidatorRemote
{
/*public JSONObject getReceivableDashboard(String dataSourceName,String siteCode) throws RemoteException, ITMException;
public JSONObject getCreditCompliance(String dataSourceName,String siteCode) throws RemoteException, ITMException;
public JSONObject getCreditComplianceDetail(String dataSourceName, String siteCode, String finEntity, String itemSer, String custCode ) throws RemoteException, ITMException;
public JSONObject getPendingShipment(String dataSourceName, String siteCode) throws RemoteException, ITMException;
*/
public JSONObject getReceivableDashboard(String dataSourceName,String siteCode,String facilityCode) throws RemoteException, ITMException;
public JSONObject getReceivableDashboardDtl(String dataSourceName,String siteCode,String facilityCode,String finEntity,String itemSeries,String custCode, String status) throws RemoteException, ITMException;
public JSONObject getCreditCompliance(String dataSourceName,String siteCode, String facilityCode) throws RemoteException, ITMException;
public JSONObject getCreditComplianceDetail(String dataSourceName, String siteCode, String finEntity, String itemSer, String custCode ) throws RemoteException, ITMException;
public JSONObject getPendingShipment(String dataSourceName, String siteCode, String facilityCode) throws RemoteException, ITMException;
public JSONObject getCreditComplianceExposureDtl(String dataSourceName, String siteCode, String custCode ) throws RemoteException, ITMException;
}
webitm-dashboard/ibase/dashboard/wms/ejb/WMS3PLDashboard.java
View file @ c0c2d7f3
package ibase.dashboard.wms.ejb; package ibase.dashboard.wms.ejb;
import ibase.dashboard.Report.Utility.DashboardUtility; import ibase.dashboard.Report.Utility.DashboardUtility;
import ibase.utility.E12GenericUtility; import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ValidatorEJB; import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.sql.Connection; import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
@Stateless @Stateless
...@@ -20,25 +23,25 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo ...@@ -20,25 +23,25 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo
public WMS3PLDashboard() public WMS3PLDashboard()
{ {
} }
E12GenericUtility e12GenericUtility = new E12GenericUtility();
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
@Override @Override
public JSONObject getOrderStatusSummary(String siteCode, String dataSourceName) throws RemoteException, ITMException public JSONObject getOrderStatusSummary(String siteCode, String dataSourceName) throws RemoteException, ITMException
{ {
JSONObject rawDataOrderStatusSumJson = new JSONObject(); JSONObject rawDataOrderStatusSumJson = new JSONObject();
JSONObject rowData = null; JSONObject rowData = null;
String sql = ""; String sql = "";
ResultSet rs = null; ResultSet rs = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Connection conn = null; Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try try
{ {
System.out.println("********** In WMS3PLDashboard : getOrderStatusSummary Method ****************** "); System.out.println("********** In WMS3PLDashboard : getOrderStatusSummary Method ****************** ");
System.out.println("************* dataSourceName :"+dataSourceName); System.out.println("************* dataSourceName :"+dataSourceName);
/*conn= connDriver.getConnectDB(dataSourceName); conn= connDriver.getConnectDB(dataSourceName);
connDriver = null;*/ connDriver = null;
/*add new code for connection DB on dated:14062016 by Nikhil*/
conn = getConnection();
int count = 0; int count = 0;
DashboardUtility dashboardUtility = new DashboardUtility(); DashboardUtility dashboardUtility = new DashboardUtility();
if(siteCode.length() == 0) if(siteCode.length() == 0)
...@@ -189,18 +192,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo ...@@ -189,18 +192,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo
{ {
JSONObject rawDataOrderStatusDtlJson = new JSONObject(); JSONObject rawDataOrderStatusDtlJson = new JSONObject();
JSONObject rowData = null; JSONObject rowData = null;
String sql = ""; String sql = "";
ResultSet rs = null; ResultSet rs = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Connection conn = null; Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try try
{ {
System.out.println("********** In WMS3PLDashboard : getOrderStatusDetail Method ****************** "); System.out.println("********** In WMS3PLDashboard : getOrderStatusDetail Method ****************** ");
/*conn= connDriver.getConnectDB(dataSourceName); conn= connDriver.getConnectDB(dataSourceName);
connDriver = null;*/ connDriver = null;
/*add new code for connection DB on dated:14062016 by Nikhil*/
conn = getConnection();
int count = 0; int count = 0;
double totalCircle=629; double totalCircle=629;
DashboardUtility dashboardUtility = new DashboardUtility(); DashboardUtility dashboardUtility = new DashboardUtility();
...@@ -469,21 +471,21 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo ...@@ -469,21 +471,21 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo
{ {
JSONObject rawDataShpmentEffiJson = new JSONObject(); JSONObject rawDataShpmentEffiJson = new JSONObject();
JSONObject rowData = null; JSONObject rowData = null;
String sql = ""; String sql = "";
String delay_time = ""; String delay_time = "";
String on_time = ""; String on_time = "";
double percntVal = 0.0; double percntVal = 0.0;
double percentage = 0.0,totalCircle=629,dashOffSet=0; double percentage=0.0,totalCircle=629,dashOffSet=0;
ResultSet rs = null; ResultSet rs = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Connection conn = null; Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try try
{ {
System.out.println("********** In WMS3PLDashboard : getShipmentEfficiencySummary Method ****************** "); System.out.println("********** In WMS3PLDashboard : getShipmentEfficiencySummary Method ****************** ");
/*conn= connDriver.getConnectDB(dataSourceName); conn= connDriver.getConnectDB(dataSourceName);
connDriver = null; */ connDriver = null;
/*add new code for connection DB on dated:16062016 by Nikhil*/
conn = getConnection();
int count = 0; int count = 0;
DashboardUtility dashboardUtility = new DashboardUtility(); DashboardUtility dashboardUtility = new DashboardUtility();
if(siteCode.length() == 0) if(siteCode.length() == 0)
...@@ -595,18 +597,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo ...@@ -595,18 +597,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo
{ {
JSONObject rawDataOrdStatusDueDateWiseJson = new JSONObject(); JSONObject rawDataOrdStatusDueDateWiseJson = new JSONObject();
JSONObject rowData = null; JSONObject rowData = null;
String sql = ""; String sql = "";
ResultSet rs = null; ResultSet rs = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Connection conn = null; Connection conn = null;
ConnDriver connDriver = new ConnDriver();
double percentage=0.0,totalCircle=629,dashOffSet=0; double percentage=0.0,totalCircle=629,dashOffSet=0;
try try
{ {
System.out.println("********** In WMS3PLDashboard : getOrderStatusDueDateWiseSummary Method ****************** "); System.out.println("********** In WMS3PLDashboard : getOrderStatusDueDateWiseSummary Method ****************** ");
/*conn= connDriver.getConnectDB(dataSourceName); conn= connDriver.getConnectDB(dataSourceName);
connDriver = null; */ connDriver = null;
/*add new code for connection DB on dated:16062016 by Nikhil*/
conn = getConnection();
int count = 0; int count = 0;
DashboardUtility dashboardUtility = new DashboardUtility(); DashboardUtility dashboardUtility = new DashboardUtility();
if(siteCode.length() == 0) if(siteCode.length() == 0)
...@@ -712,18 +713,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo ...@@ -712,18 +713,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo
{ {
JSONObject rawDataSalesOrderWiseDetailJson = new JSONObject(); JSONObject rawDataSalesOrderWiseDetailJson = new JSONObject();
JSONObject rowData = null; JSONObject rowData = null;
String sql = ""; String sql = "";
ResultSet rs = null; ResultSet rs = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Connection conn = null; Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try try
{ {
System.out.println("********** In WMS3PLDashboard : getSalesOrderWiseDetail Method ****************** "); System.out.println("********** In WMS3PLDashboard : getSalesOrderWiseDetail Method ****************** ");
/*conn= connDriver.getConnectDB(dataSourceName); conn= connDriver.getConnectDB(dataSourceName);
connDriver = null; */ connDriver = null;
/*add new code for connection DB on dated:16062016 by Nikhil*/
conn = getConnection();
int count = 0; int count = 0;
sql = "Select sorder.site_code, sorder.sale_order , count(sorddet.line_no) No_Of_Item,sorder.tot_amt as Total_Order_Value," + sql = "Select sorder.site_code, sorder.sale_order , count(sorddet.line_no) No_Of_Item,sorder.tot_amt as Total_Order_Value," +
...@@ -784,17 +784,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo ...@@ -784,17 +784,17 @@ public class WMS3PLDashboard extends ValidatorEJB implements WMS3PLDashboardRemo
{ {
JSONObject rawDataOrderStatusDtlJson = new JSONObject(); JSONObject rawDataOrderStatusDtlJson = new JSONObject();
JSONObject rowData = null; JSONObject rowData = null;
String sql = ""; String sql = "";
ResultSet rs = null; ResultSet rs = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Connection conn = null; Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try try
{ {
System.out.println("********** In WMS3PLDashboard : getPickShipSummary Method ****************** "); System.out.println("********** In WMS3PLDashboard : getPickShipSummary Method ****************** ");
/*conn= connDriver.getConnectDB(dataSourceName); conn= connDriver.getConnectDB(dataSourceName);
connDriver = null;*/ connDriver = null;
/*add new code for connection DB on dated:16062016 by Nikhil*/
conn = getConnection();
int count = 0; int count = 0;
DashboardUtility dashboardUtility = new DashboardUtility(); DashboardUtility dashboardUtility = new DashboardUtility();
if(siteCode.length() == 0) if(siteCode.length() == 0)
......
webitm-dashboard/ibase/dashboard/wms/ejb/WMS3PLDashboardRemote.java
View file @ c0c2d7f3
...@@ -2,8 +2,11 @@ package ibase.dashboard.wms.ejb; ...@@ -2,8 +2,11 @@ package ibase.dashboard.wms.ejb;
import ibase.webitm.ejb.ValidatorRemote; import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import javax.ejb.Remote; import javax.ejb.Remote;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
@Remote @Remote
......
webitm-dashboard/ibase/dashboard/wms/ejb/WMS3PLSummDtlDashboard.java
View file @ c0c2d7f3
...@@ -9287,7 +9287,7 @@ public class WMS3PLSummDtlDashboard extends ValidatorEJB implements WMS3PLSummDt ...@@ -9287,7 +9287,7 @@ public class WMS3PLSummDtlDashboard extends ValidatorEJB implements WMS3PLSummDt
if(!"No Data".equalsIgnoreCase(productCategory)) if(!"No Data".equalsIgnoreCase(productCategory))
{ {
sql = " Select cust.cust_name, so.sale_order , count(sod.line_no) No_Of_Item,so.tot_amt as Total_Order_Value, sod.quantity,so.status "+ sql = " Select cust.cust_name, so.sale_order , count(sod.line_no) No_Of_Item,so.tot_amt as Total_Order_Value, sod.quantity,so.status "+
" from sorder so,sorddet sod ,customer cust,itemser its,business_logic_check blc "+ " from sorder so,sorddet sod ,customer cust,itemser its "+
" where so.sale_order=sod.sale_order "+ " where so.sale_order=sod.sale_order "+
" and so.item_ser = its.item_ser "+appendSql+" "+ " and so.item_ser = its.item_ser "+appendSql+" "+
" and so.cust_code =cust.cust_code "+ " and so.cust_code =cust.cust_code "+
......
webitm-dashboard/ibase/dashboard/wms/servlet/CreditComplianceDetailServlet.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.servlet;
import ibase.dashboard.wms.ejb.FGWarehouseRemote;
import ibase.system.config.AppConnectParm;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.json.simple.JSONObject;
public class CreditComplianceDetailServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
FGWarehouseRemote fgWarehouseRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
String siteCode ="";
String finEntity = "";
String itemSer = "";
String custCode = "";
try
{
response.setContentType("application/xml");
dataSourceName = request.getParameter("dataSourceName");
siteCode = request.getParameter("siteCode");
custCode = request.getParameter("custCode");
finEntity = request.getParameter("finEntity");
itemSer = request.getParameter("itemSer");
context = new InitialContext(appConnectParm.getProperty());
fgWarehouseRemote = (FGWarehouseRemote) context.lookup("ibase/FGWarehouse/remote");
JSONObject jsonObjData = (JSONObject) fgWarehouseRemote.getCreditComplianceDetail(dataSourceName, siteCode,finEntity,itemSer,custCode);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for CreditComplianceDetailServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : CreditComplianceDetailServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/wms/servlet/CreditComplianceExposureDtlServlet.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.servlet;
import ibase.dashboard.wms.ejb.FGWarehouseRemote;
import ibase.system.config.AppConnectParm;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.json.simple.JSONObject;
public class CreditComplianceExposureDtlServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
FGWarehouseRemote fgWarehouseRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
String siteCode ="";
String finEntity = "";
String itemSer = "";
String custCode = "";
try
{
response.setContentType("application/xml");
dataSourceName = request.getParameter("dataSourceName");
siteCode = request.getParameter("site_code");
custCode = request.getParameter("cust_code");
context = new InitialContext(appConnectParm.getProperty());
fgWarehouseRemote = (FGWarehouseRemote) context.lookup("ibase/FGWarehouse/remote");
JSONObject jsonObjData = (JSONObject) fgWarehouseRemote.getCreditComplianceExposureDtl(dataSourceName, siteCode,custCode);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for CreditComplianceExposureDtlServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : CreditComplianceExposureDtlServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/wms/servlet/CreditComplianceServlet.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.servlet;
import ibase.dashboard.wms.ejb.FGWarehouseRemote;
import ibase.system.config.AppConnectParm;
import ibase.utility.UserInfoBean;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject;
public class CreditComplianceServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
FGWarehouseRemote fgWarehouseRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
HttpSession session = null;
UserInfoBean userInfo = null;
String sessionSiteCode = "";
String facilityCode = "";
try
{
response.setContentType("application/xml");
session = request.getSession(true);
userInfo = (UserInfoBean) session.getAttribute("USER_INFO");
sessionSiteCode = userInfo.getSiteCode();
//sessionSiteCode="TA821";
//facilityCode=request.getParameter("facilityCode");
dataSourceName = request.getParameter("dataSourceName");
context = new InitialContext(appConnectParm.getProperty());
fgWarehouseRemote = (FGWarehouseRemote) context.lookup("ibase/FGWarehouse/remote");
JSONObject jsonObjData = (JSONObject) fgWarehouseRemote.getCreditCompliance(dataSourceName, sessionSiteCode, facilityCode);
//JSONObject jsonObjData = (JSONObject) misDashboardRemote.getCreditCompliance(dataSourceName, sessionSiteCode);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for CreditComplianceServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : CreditComplianceServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/wms/servlet/OrderStatusDetailServlet.java
View file @ c0c2d7f3
...@@ -3,14 +3,16 @@ package ibase.dashboard.wms.servlet; ...@@ -3,14 +3,16 @@ package ibase.dashboard.wms.servlet;
import ibase.dashboard.wms.ejb.WMS3PLDashboardRemote; import ibase.dashboard.wms.ejb.WMS3PLDashboardRemote;
import ibase.system.config.AppConnectParm; import ibase.system.config.AppConnectParm;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import javax.naming.InitialContext; import javax.naming.InitialContext;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
public class OrderStatusDetailServlet extends HttpServlet public class OrderStatusDetailServlet extends HttpServlet
...@@ -37,8 +39,6 @@ public class OrderStatusDetailServlet extends HttpServlet ...@@ -37,8 +39,6 @@ public class OrderStatusDetailServlet extends HttpServlet
{ {
response.setContentType("application/xml"); response.setContentType("application/xml");
HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
siteCode = request.getParameter("siteCode"); siteCode = request.getParameter("siteCode");
dataSourceName = request.getParameter("dataSourceName"); dataSourceName = request.getParameter("dataSourceName");
...@@ -46,9 +46,7 @@ public class OrderStatusDetailServlet extends HttpServlet ...@@ -46,9 +46,7 @@ public class OrderStatusDetailServlet extends HttpServlet
context = new InitialContext(appConnectParm.getProperty()); context = new InitialContext(appConnectParm.getProperty());
wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote"); wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote");
/*setUserInfo(userInfo) for DB connection on dated:14062016*/ jsonObjData = (JSONObject) wms3PLDashboardRemote.getOrderStatusDetail(siteCode, dataSourceName);
wms3PLDashboardRemote.setUserInfo(userInfo);
jsonObjData = (JSONObject) wms3PLDashboardRemote.getOrderStatusDetail(dataSourceName,siteCode );
outputStream = response.getOutputStream(); outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes()); outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush(); outputStream.flush();
......
webitm-dashboard/ibase/dashboard/wms/servlet/OrderStatusDueDateWiseSummaryServlet.java
View file @ c0c2d7f3
...@@ -12,7 +12,6 @@ import javax.servlet.ServletException; ...@@ -12,7 +12,6 @@ import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
...@@ -40,17 +39,14 @@ public class OrderStatusDueDateWiseSummaryServlet extends HttpServlet ...@@ -40,17 +39,14 @@ public class OrderStatusDueDateWiseSummaryServlet extends HttpServlet
{ {
response.setContentType("application/xml"); response.setContentType("application/xml");
HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
siteCode = request.getParameter("siteCode"); siteCode = request.getParameter("siteCode");
dataSourceName = request.getParameter("dataSourceName"); dataSourceName = request.getParameter("dataSourceName");
System.out.println("*********** In OrderStatusDueDateWiseSummaryServlet siteCode is *************** =" + siteCode); System.out.println("*********** In OrderStatusDueDateWiseSummaryServlet siteCode is *************** =" + siteCode);
context = new InitialContext(appConnectParm.getProperty()); context = new InitialContext(appConnectParm.getProperty());
wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote"); wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote");
/*setUserInfo(userInfo) for DB connection on dated:14062016*/
wms3PLDashboardRemote.setUserInfo(userInfo);
jsonObjData = (JSONObject) wms3PLDashboardRemote.getOrderStatusDueDateWiseSummary(siteCode, dataSourceName); jsonObjData = (JSONObject) wms3PLDashboardRemote.getOrderStatusDueDateWiseSummary(siteCode, dataSourceName);
outputStream = response.getOutputStream(); outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes()); outputStream.write(jsonObjData.toString().getBytes());
......
webitm-dashboard/ibase/dashboard/wms/servlet/OrderStatusSummaryServlet.java
View file @ c0c2d7f3
...@@ -12,7 +12,6 @@ import javax.servlet.ServletException; ...@@ -12,7 +12,6 @@ import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
...@@ -40,8 +39,6 @@ public class OrderStatusSummaryServlet extends HttpServlet ...@@ -40,8 +39,6 @@ public class OrderStatusSummaryServlet extends HttpServlet
{ {
response.setContentType("application/xml"); response.setContentType("application/xml");
HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
siteCode = request.getParameter("siteCode"); siteCode = request.getParameter("siteCode");
dataSourceName = request.getParameter("dataSourceName"); dataSourceName = request.getParameter("dataSourceName");
...@@ -49,8 +46,6 @@ public class OrderStatusSummaryServlet extends HttpServlet ...@@ -49,8 +46,6 @@ public class OrderStatusSummaryServlet extends HttpServlet
context = new InitialContext(appConnectParm.getProperty()); context = new InitialContext(appConnectParm.getProperty());
wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote"); wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote");
/*setUserInfo(userInfo) for DB connection on dated:14062016*/
wms3PLDashboardRemote.setUserInfo(userInfo);
jsonObjData = (JSONObject) wms3PLDashboardRemote.getOrderStatusSummary(siteCode, dataSourceName); jsonObjData = (JSONObject) wms3PLDashboardRemote.getOrderStatusSummary(siteCode, dataSourceName);
outputStream = response.getOutputStream(); outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes()); outputStream.write(jsonObjData.toString().getBytes());
......
webitm-dashboard/ibase/dashboard/wms/servlet/PendingShipmentServlet.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.servlet;
import ibase.dashboard.wms.ejb.FGWarehouseRemote;
import ibase.system.config.AppConnectParm;
import ibase.utility.UserInfoBean;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject;
public class PendingShipmentServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
FGWarehouseRemote fgWarehouseRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
HttpSession session = null;
UserInfoBean userInfo = null;
String sessionSiteCode = "";
String facilityCode="";
try
{
response.setContentType("application/xml");
session = request.getSession(true);
userInfo = (UserInfoBean) session.getAttribute("USER_INFO");
sessionSiteCode = userInfo.getSiteCode();
//sessionSiteCode="TA821";
//facilityCode=request.getParameter("facilityCode");
dataSourceName = request.getParameter("dataSourceName");
context = new InitialContext(appConnectParm.getProperty());
fgWarehouseRemote = (FGWarehouseRemote) context.lookup("ibase/FGWarehouse/remote");
//JSONObject jsonObjData = (JSONObject) misDashboardRemote.getPendingShipment(dataSourceName, sessionSiteCode);
JSONObject jsonObjData = (JSONObject) fgWarehouseRemote.getPendingShipment(dataSourceName, sessionSiteCode, facilityCode);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for PendingShipmentServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : PendingShipmentServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/wms/servlet/PickShipSummaryServlet.java
View file @ c0c2d7f3
...@@ -12,7 +12,6 @@ import javax.servlet.ServletException; ...@@ -12,7 +12,6 @@ import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
...@@ -40,8 +39,6 @@ public class PickShipSummaryServlet extends HttpServlet ...@@ -40,8 +39,6 @@ public class PickShipSummaryServlet extends HttpServlet
{ {
response.setContentType("application/xml"); response.setContentType("application/xml");
HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
siteCode = request.getParameter("siteCode"); siteCode = request.getParameter("siteCode");
dataSourceName = request.getParameter("dataSourceName"); dataSourceName = request.getParameter("dataSourceName");
...@@ -49,8 +46,6 @@ public class PickShipSummaryServlet extends HttpServlet ...@@ -49,8 +46,6 @@ public class PickShipSummaryServlet extends HttpServlet
context = new InitialContext(appConnectParm.getProperty()); context = new InitialContext(appConnectParm.getProperty());
wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote"); wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote");
/*setUserInfo(userInfo) for DB connection on dated:14062016*/
wms3PLDashboardRemote.setUserInfo(userInfo);
jsonObjData = (JSONObject) wms3PLDashboardRemote.getPickShipSummary(siteCode, dataSourceName); jsonObjData = (JSONObject) wms3PLDashboardRemote.getPickShipSummary(siteCode, dataSourceName);
outputStream = response.getOutputStream(); outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes()); outputStream.write(jsonObjData.toString().getBytes());
......
webitm-dashboard/ibase/dashboard/wms/servlet/ReceivableDashboardDtlServlet.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.servlet;
import ibase.dashboard.wms.ejb.FGWarehouseRemote;
import ibase.system.config.AppConnectParm;
import ibase.utility.UserInfoBean;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject;
public class ReceivableDashboardDtlServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
FGWarehouseRemote fgWarehouseRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
String facilityCode = "";
String siteCode = "";
String finEntity = "";
String itemSeries = "";
String custCode = "";
String sessionSiteCode = "";
HttpSession session = null;
UserInfoBean userInfo = null;
String status = "";
try
{
response.setContentType("application/xml");
siteCode=request.getParameter("site_code");
finEntity=request.getParameter("fin_entity");
itemSeries=request.getParameter("item_ser");
custCode=request.getParameter("cust_code");
status = request.getParameter("status");
session = request.getSession(true);
//userInfo = (UserInfoBean) session.getAttribute("USER_INFO");
//sessionSiteCode = userInfo.getSiteCode();
System.out.println("**************** sessionSiteCode :"+sessionSiteCode);
sessionSiteCode="TA821";
dataSourceName = request.getParameter("dataSourceName");
System.out.println("***************************");
System.out.println("siteCode :"+siteCode);
System.out.println("finEntity :"+finEntity);
System.out.println("itemSeries :"+itemSeries);
System.out.println("custCode :"+custCode);
System.out.println("***************************");
context = new InitialContext(appConnectParm.getProperty());
fgWarehouseRemote = (FGWarehouseRemote) context.lookup("ibase/FGWarehouse/remote");
JSONObject jsonObjData = (JSONObject) fgWarehouseRemote.getReceivableDashboardDtl(dataSourceName, siteCode, sessionSiteCode, finEntity, itemSeries, custCode,status);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for ReceivableDashboardDtlServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : ReceivableDashboardDtlServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/wms/servlet/ReceivableDashboardServlet.java 0 → 100755
View file @ c0c2d7f3
package ibase.dashboard.wms.servlet;
import ibase.dashboard.wms.ejb.FGWarehouseRemote;
import ibase.system.config.AppConnectParm;
import ibase.utility.UserInfoBean;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject;
public class ReceivableDashboardServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
FGWarehouseRemote fgWarehouseRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
HttpSession session = null;
UserInfoBean userInfo = null;
String sessionSiteCode = "";
String facilityCode = "";
try
{
response.setContentType("application/xml");
session = request.getSession(true);
userInfo = (UserInfoBean) session.getAttribute("USER_INFO");
sessionSiteCode = userInfo.getSiteCode();
System.out.println("**************** sessionSiteCode :"+sessionSiteCode);
//sessionSiteCode="TA821";
//facilityCode=request.getParameter("facilityCode");
dataSourceName = request.getParameter("dataSourceName");
context = new InitialContext(appConnectParm.getProperty());
fgWarehouseRemote = (FGWarehouseRemote) context.lookup("ibase/FGWarehouse/remote");
JSONObject jsonObjData = (JSONObject) fgWarehouseRemote.getReceivableDashboard(dataSourceName,sessionSiteCode, facilityCode);
//JSONObject jsonObjData = (JSONObject) misDashboardRemote.getReceivableDashboard(dataSourceName,sessionSiteCode);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for ReceivableDashboardServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : ReceivableDashboardServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/wms/servlet/SalesOrderWiseDetailServlet.java
View file @ c0c2d7f3
...@@ -12,7 +12,6 @@ import javax.servlet.ServletException; ...@@ -12,7 +12,6 @@ import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
...@@ -40,8 +39,6 @@ public class SalesOrderWiseDetailServlet extends HttpServlet ...@@ -40,8 +39,6 @@ public class SalesOrderWiseDetailServlet extends HttpServlet
{ {
response.setContentType("application/xml"); response.setContentType("application/xml");
HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
siteCode = request.getParameter("siteCode"); siteCode = request.getParameter("siteCode");
dataSourceName = request.getParameter("dataSourceName"); dataSourceName = request.getParameter("dataSourceName");
...@@ -49,8 +46,6 @@ public class SalesOrderWiseDetailServlet extends HttpServlet ...@@ -49,8 +46,6 @@ public class SalesOrderWiseDetailServlet extends HttpServlet
context = new InitialContext(appConnectParm.getProperty()); context = new InitialContext(appConnectParm.getProperty());
wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote"); wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote");
/*setUserInfo(userInfo) for DB connection on dated:14062016*/
wms3PLDashboardRemote.setUserInfo(userInfo);
jsonObjData = (JSONObject) wms3PLDashboardRemote.getSalesOrderWiseDetail(siteCode, dataSourceName); jsonObjData = (JSONObject) wms3PLDashboardRemote.getSalesOrderWiseDetail(siteCode, dataSourceName);
outputStream = response.getOutputStream(); outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes()); outputStream.write(jsonObjData.toString().getBytes());
......
webitm-dashboard/ibase/dashboard/wms/servlet/ShipmentEfficiencySummaryServlet.java
View file @ c0c2d7f3
...@@ -12,7 +12,6 @@ import javax.servlet.ServletException; ...@@ -12,7 +12,6 @@ import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
...@@ -40,8 +39,6 @@ public class ShipmentEfficiencySummaryServlet extends HttpServlet ...@@ -40,8 +39,6 @@ public class ShipmentEfficiencySummaryServlet extends HttpServlet
{ {
response.setContentType("application/xml"); response.setContentType("application/xml");
HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
siteCode = request.getParameter("siteCode"); siteCode = request.getParameter("siteCode");
dataSourceName = request.getParameter("dataSourceName"); dataSourceName = request.getParameter("dataSourceName");
...@@ -49,8 +46,6 @@ public class ShipmentEfficiencySummaryServlet extends HttpServlet ...@@ -49,8 +46,6 @@ public class ShipmentEfficiencySummaryServlet extends HttpServlet
context = new InitialContext(appConnectParm.getProperty()); context = new InitialContext(appConnectParm.getProperty());
wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote"); wms3PLDashboardRemote = (WMS3PLDashboardRemote) context.lookup("ibase/WMS3PLDashboard/remote");
/*setUserInfo(userInfo) for DB connection on dated:14062016*/
wms3PLDashboardRemote.setUserInfo(userInfo);
jsonObjData = (JSONObject) wms3PLDashboardRemote.getShipmentEfficiencySummary(siteCode, dataSourceName); jsonObjData = (JSONObject) wms3PLDashboardRemote.getShipmentEfficiencySummary(siteCode, dataSourceName);
outputStream = response.getOutputStream(); outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes()); outputStream.write(jsonObjData.toString().getBytes());
......
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