package com.manual.doc.order.ajax;

import java.util.HashMap;
import java.util.Vector;

import javax.servlet.http.HttpServletRequest;

import org.jboss.logging.Logger;
import org.json.JSONObject;

import com.master.form.MasterFormHandler;
import com.master.util.EAFManualUtil;
import com.master.util.ManualInterface;

public class CalculateOrderRequestItemSummaryPrice implements ManualInterface {
	static Logger logger = Logger.getLogger(CalculateOrderRequestItemSummaryPrice.class);
	HttpServletRequest request;
	@Override
	public String processManual() {
		try {
			MasterFormHandler FormData = (MasterFormHandler)request.getSession().getAttribute("MD8321225761_session");
			Vector vForm = FormData.getStoreActionList();
			logger.debug("#####vForm#####"+vForm); 
			double sumPrice = 0;
			for (int i=0; i<vForm.size(); i++) {
				HashMap hData = EAFManualUtil.getDataHashMapFromSession("MD8321225761", request, i);
				logger.debug("#####hData#####"+hData);
				
				String totalPrice = (String)hData.get("TOTAL_PRICE");
				if(totalPrice != null && !"".equals(totalPrice)){
					sumPrice += Double.parseDouble(totalPrice);
				}
				logger.debug("#####totalPrice#####"+totalPrice);
				logger.debug("#####sumPrice#####"+sumPrice);			
			}
			JSONObject jobj = new JSONObject();
			jobj.put("SUM_PRICE", sumPrice);
			return jobj.toString();
		}catch(Exception e) {
			e.printStackTrace();
			return "error|" + e.getMessage();
		}
	}

	@Override
	public void setRequest(HttpServletRequest arg0) {
		this.request = arg0;
	}

}

function MD8321225761manualJS(){
	var dataString = '';
	var uri = "/MasterWeb/ManualServlet?className=com.manual.doc.order.ajax.CalculateOrderRequestItemSummaryPrice";
	jQuery.ajax({
		type : "POST",
		url : uri,
		data : dataString,
		async : false,
		success : function(data) {
			var obj = JSON.parse(data);
			console.log('#####MD5801448545manualJS Ajax Success obj#####', obj);
			$('#MD9443222701_SUMMARY_PRICE_InputField [name="SUMMARY_PRICE"]').val(moneyFormat(obj.SUM_PRICE));
		}
	});
}

package com.manual.doc.order.java;

import java.util.HashMap;
import java.util.Vector;

import org.apache.log4j.Logger;

import com.master.form.MasterFormHandler;
import com.master.util.ProcessAction;
import com.master.util.ProcessHelper;

public class OrderRequestItemBackOfficeUpdateMode extends ProcessHelper implements ProcessAction {
	private static Logger logger = Logger.getLogger(OrderRequestItemBackOfficeUpdateMode.class);
	
	@Override
	public void modifyInsertMany(String moduleID, HashMap hStoreHashMap, String processMode, int row) {
		logger.debug("hStoreHashMap=" + hStoreHashMap);
		logger.debug("row=" + row);
		MasterFormHandler orderRequestformData = (MasterFormHandler)request.getSession().getAttribute("MD9443222701_session");
		HashMap orderRequestformHash = orderRequestformData.getStoreHashMap();
		logger.debug("orderRequestformHash="+orderRequestformHash);
		HashMap orderRequestHash = (HashMap)orderRequestformHash.get("WF_ORDER_REQ_ITEM");
		String orderUnit = (String)orderRequestHash.get("UNIT");
		logger.debug("orderUnit="+orderUnit);
		int orderUnitAmt = Integer.parseInt(orderUnit);
				
		MasterFormHandler supplierformData = (MasterFormHandler)request.getSession().getAttribute(moduleID + "_session");
		Vector supplierformVect = supplierformData.getStoreActionList();
		if(supplierformVect != null && supplierformVect.size() > 0){
			for(int i=0;i<supplierformVect.size();i++){
				if(i != row){
					HashMap supplierformHash = (HashMap)supplierformVect.get(i);
					logger.debug("supplierformHash="+supplierformHash);
					HashMap updateSupplierHash = (HashMap)supplierformHash.get("UPDATE");
					HashMap supplierHash = (HashMap)updateSupplierHash.get("WF_ORDER_REQ_ITEM_SUPPLIER");
					String unitSelected = (String)supplierHash.get("UNIT_BY_BACK_OFFICE");
					logger.debug("unitSelected="+unitSelected);
					if(unitSelected != null && !"".equals(unitSelected)){
						orderUnitAmt -= Integer.parseInt(unitSelected);
					}
				}
			}
		}
		logger.debug("orderUnitAmt after calculate="+orderUnitAmt);
		
		HashMap supplierHash = (HashMap)hStoreHashMap.get("WF_ORDER_REQ_ITEM_SUPPLIER");
		supplierHash.put("REMAIN_ORDER_UNIT", String.valueOf(orderUnitAmt));
				
		super.modifyInsertMany(moduleID, hStoreHashMap, processMode, row);
	}	
}	

@Override
public boolean validateResult() {
	// TODO Auto-generated method stub
	logger.debug("=========Validate require at least 1 order request item=======");
	boolean result = true;
	String nextEntity = (String)request.getParameter("nextEntity");
	logger.debug("##### nextEntity #####"+nextEntity);
		
	if(nextEntity == null || "".equals(nextEntity)) {
		String entityID = (String)getRequest().getSession().getAttribute("entityID");
		EntityFormHandler FormEntity = (EntityFormHandler)request.getSession().getAttribute(entityID + "_session");
		Vector vError = FormEntity.getFormErrors();
		
		MasterFormHandler FormMaster = (MasterFormHandler)request.getSession().getAttribute("MD11784591_session");
		Vector vFormMaster = FormMaster.getStoreActionList();
		logger.debug("##### vFormMaster #####"+vFormMaster);
		
		if (vFormMaster.size() == 0) {
			vError.add("Please add order item at least 1 item");
			result = false;
		}
	}
	return result;
}

package com.manual.service;

import java.sql.Connection;
import javax.naming.InitialContext;
import javax.sql.DataSource;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;

public class ManualJDBCServiceLocator {
    private final static transient Logger log = LogManager.getLogger(ManualJDBCServiceLocator.class);
    public static ManualJDBCServiceLocator serviceLocator;

    private final static String JAVA_ENV = "";

    public final static int MASTER_DB = 0;
    public final static int ONEWEB_DB = 1;

    public final static String MASTER_DATA_SOURCE = "jdbc/master";
    public final static String APPLICATION_DATA_SOURCE = "jdbc/application";

    public static synchronized ManualJDBCServiceLocator getInstance() {
        if (serviceLocator == null) {
            serviceLocator = new ManualJDBCServiceLocator();
        }
        return serviceLocator;
    }

    private ManualJDBCServiceLocator() {
    }

    /**
     * 
     * @param dbType
     * @return DataSource.getConnection()
     * @throws Exception
     */
    public Connection getConnection(int dbType) throws Exception {
    	DataSource ds = null;
    	try{			 
			InitialContext ctx = new InitialContext();
			switch(dbType){
				case MASTER_DB:
					ds = (DataSource)ctx.lookup(JAVA_ENV+MASTER_DATA_SOURCE); 
					break;
				case ONEWEB_DB:
					ds = (DataSource)ctx.lookup(JAVA_ENV+APPLICATION_DATA_SOURCE); 
					break;
				default:
					return null;
			}
			return ds.getConnection();
		} catch(Exception e){
			e.printStackTrace();
			throw new Exception(e.toString());
		}
	}

    /**
	 * 
	 * @param jndiName (For example, "jdbc/master")
	 * @return DataSource.getConnection()
	 * @throws Exception
	 */
	public Connection getConnection(String jndiName) throws Exception{
		try{
			DataSource ds = null;
			InitialContext ctx = new InitialContext();
			if(null != jndiName && !"".equalsIgnoreCase(jndiName)){
				ds = (DataSource)ctx.lookup(JAVA_ENV+jndiName);
			}else{
				return null;
			}
			return ds.getConnection();
		}catch(Exception e){
			e.printStackTrace();
			throw new Exception(e.toString());
		}
	}
    
    public static String getPoolName(int dbType) {
        switch (dbType) {
        default:
            return MASTER_DATA_SOURCE;
        }
    }
}

package com.manual.doc.order.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class ManualDocObjectDAO {
	public void closeConnection(Connection conn, PreparedStatement ps, ResultSet rs ) {
		if(conn != null){
			try{
				conn.commit();
			}catch(Exception e){}
			try{
				conn.close();
			}catch(Exception e){}
		}
		if(ps != null){
			try{
				ps.close();
			}catch(Exception e){}
		}
		if(rs != null){
			try{
				rs.close();
			}catch(Exception e){}
		}
	}
}

package com.manual.doc.order.dao;

public interface ManualDocOrderDAO {
	public int countInCompleteOrderUnit(String requestID) throws Exception;
}

package com.manual.doc.order.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import org.apache.log4j.Logger;

import com.manual.service.ManualJDBCServiceLocator;

public class ManualDocOrderDAOImpl extends ManualDocObjectDAO implements ManualDocOrderDAO {
	private Logger logger = Logger.getLogger(ManualDocOrderDAOImpl.class);
	@Override
	
public class ManualDocOrderDAOImpl extends ManualDocObjectDAO implements ManualDocOrderDAO {
	private Logger logger = Logger.getLogger(ManualDocOrderDAOImpl.class);
	@Override
	public int countInCompleteOrderUnit(String requestID) throws Exception {
		Connection conn = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		int result = 0;
		try{
			conn = ManualJDBCServiceLocator.getInstance().getConnection(ManualJDBCServiceLocator.ONEWEB_DB);
			StringBuilder sql = new StringBuilder("");
			
			sql.append("SELECT COUNT(1) AS in_complete_amt ");
			sql.append("FROM (SELECT ");
			sql.append("oi.request_id, oi.unit, SUM(ois.unit_by_back_office) as order_unit ");
			sql.append("FROM wf_order_req_item oi ");
			sql.append("INNER JOIN wf_order_req_item_supplier ois ON oi.order_item_id = ois.order_item_id ");
			sql.append("WHERE oi.request_id = ? ");
			sql.append("GROUP BY oi.request_id, oi.unit) tmp ");
			sql.append("WHERE tmp.unit - tmp.order_unit <> 0 ");
			
			ps = conn.prepareStatement(sql.toString());
			ps.setString(1, requestID);
			
			logger.debug("@@@@@ countInCompleteOrderUnit sql :"  + sql.toString());
			logger.debug("@@@@@ countInCompleteOrderUnit requestID :"  + requestID);
			
			rs = ps.executeQuery();
			
			if(rs.next()){
				result = rs.getInt("in_complete_amt");
			}
			
			return result;
		}catch(Exception e){
			e.printStackTrace();
			throw e;
		}finally{
			this.closeConnection(conn, ps, rs);
		}
	}

}

package com.manual.service;

import com.manual.doc.order.dao.ManualDocOrderDAO;
import com.manual.doc.order.dao.ManualDocOrderDAOImpl;

public class ManualDAOFactory {
	public static ManualDocOrderDAO getManualDocOrderDAO(){
		return new ManualDocOrderDAOImpl();
	}
}

package com.manual.doc.order.java;

import java.util.HashMap;
import java.util.Vector;

import org.apache.log4j.Logger;

import com.manual.service.ManualDAOFactory;
import com.master.form.EntityFormHandler;
import com.master.util.EAFManualUtil;
import com.master.util.ProcessAction;
import com.master.util.ProcessHelper;

public class OrderRequestBackOfficeUpdateMode extends ProcessHelper implements ProcessAction {
	private static Logger logger = Logger.getLogger(OrderRequestBackOfficeUpdateMode.class);

	@Override
	public boolean validateResult() {		
		String nextEntity = request.getParameter("goEntity");
		logger.debug("@@@@@ nextEntity :" + nextEntity);
		
		if(nextEntity == null || "".equals(nextEntity)) {
			String entityID = (String)getRequest().getSession().getAttribute("entityID");
			EntityFormHandler entityForm = (EntityFormHandler)getRequest().getSession().getAttribute(entityID +"_session");
			Vector errorVect = entityForm.getFormErrors();
			String moduleID = entityForm.getMainModuleID();
			
			HashMap mainRequestData = EAFManualUtil.getDataHashMapFromSession(moduleID, request);
			String requestID = (String)mainRequestData.get("REQUEST_ID");
			
			try{
				int inCompleteAmt = ManualDAOFactory.getManualDocOrderDAO().countInCompleteOrderUnit(requestID);
				logger.debug("@@@@@ completeAmt :" + completeAmt);
				if(completeAmt > 0){
					errorVect.add("Please verify un-assign order unit.");
					return false;
				}
			}catch(Exception e){
				errorVect.add(e.getMessage());
				return false;
			}
		}
		return super.validateResult();
	}	
	
}

@Override
	public int countInCompleteInStock(String requestID) throws Exception {
		Connection conn = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		int result = 0;
		try{
			conn = ManualJDBCServiceLocator.getInstance().getConnection(ManualJDBCServiceLocator.ONEWEB_DB);
			StringBuilder sql = new StringBuilder("");
					
			sql.append("SELECT COUNT(1) AS more_than_stock ");
			sql.append("FROM (SELECT oi.order_item_id, oi.unit, SUM(in_stock) as sum_stock ");
			sql.append("FROM wf_order_req_item oi ");
			sql.append("INNER JOIN wf_order_req_item_supplier ois ON oi.order_item_id = ois.order_item_id ");
			sql.append("WHERE oi.request_id = ? ");
			sql.append("GROUP BY oi.order_item_id, oi.unit) tmp ");
			sql.append("where tmp.unit - tmp.sum_stock > 0 ");
			
			ps = conn.prepareStatement(sql.toString());
			ps.setString(1, requestID);
			
			logger.debug("@@@@@ countInCompleteInStock sql :"  + sql.toString());
			logger.debug("@@@@@ countInCompleteInStock requestID :"  + requestID);
			
			rs = ps.executeQuery();
			
			if(rs.next()){
				result = rs.getInt("more_than_stock");
			}
			
			return result;
		}catch(Exception e){
			e.printStackTrace();
			throw e;
		}finally{
			this.closeConnection(conn, ps, rs);
		}
	}

package com.manual.doc.order.java;

import java.util.HashMap;
import java.util.Vector;

import com.manual.service.ManualDAOFactory;
import com.master.form.EntityFormHandler;
import com.master.util.EAFManualUtil;
import com.master.util.ProcessAction;
import com.master.util.ProcessHelper;

public class OrderRequestAdminUpdateMode extends ProcessHelper implements ProcessAction {

	@Override
	public boolean validateResult() {
		String nextEntity = request.getParameter("goEntity");
		//logger.debug("@@@@@ nextEntity :" + nextEntity);
		
		if(nextEntity == null || "".equals(nextEntity)) {
			String entityID = (String)getRequest().getSession().getAttribute("entityID");
			EntityFormHandler entityForm = (EntityFormHandler)getRequest().getSession().getAttribute(entityID +"_session");
			Vector errorVect = entityForm.getFormErrors();
			String moduleID = entityForm.getMainModuleID();
			
			HashMap mainRequestData = EAFManualUtil.getDataHashMapFromSession(moduleID, request);
			String requestID = (String)mainRequestData.get("REQUEST_ID");
			
			try{
				int inCompleteAmt = ManualDAOFactory.getManualDocOrderDAO().countInCompleteInStock(requestID);
				//logger.debug("@@@@@ incompleteAmt :" + inCompleteAmt);
				if(inCompleteAmt > 0){
					errorVect.add("Please verify supplier stock");
					return false;
				}
			}catch(Exception e){
				errorVect.add(e.getMessage());
				return false;
			}
		}
		return super.validateResult();
	}

}

// Auto script when open popup
function loadUpdateManyManual(){
	calPriceByInputUnit();
}

// Auto calculate field on popup
function calPriceByInputUnit(){
	$("[name=UNIT_BY_BACK_OFFICE]").change(function(){
		var stock = parseInt($("[name=IN_STOCK]").val());
		var remain = parseInt($("[name=REMAIN_ORDER_UNIT]").val());
		var getUnitBackofc = parseInt($("[name=UNIT_BY_BACK_OFFICE]").val());
		
		if(getUnitBackofc > stock || getUnitBackofc > remain){
			alert('Unit choose by backoffice must less than stock and remain');
			$("[name=UNIT_BY_BACK_OFFICE]").val('');
			$("[name=UNIT_BY_BACK_OFFICE]").focus();
		}else{
			var pricePerUnit = $("[name=UNIT_PRICE]").val();
			var totalPrice = getUnitBackofc*pricePerUnit;
			console.log('totalPrice: '+totalPrice) ;
			$('[name=TOTAL_PRICE]').val(moneyFormat(totalPrice));
		}
	});
}

// Change to money format
function moneyFormat(strMoneyA) {
	var strMoney = new String(strMoneyA);
	if(strMoney != undefined && strMoney != 'null' && strMoney != ''){
		strMoney  = strMoney.replace(/\,/g,'');
		strMoney = parseFloat(strMoney).toFixed(2);
		strMoney += '';
		x = strMoney.split('.');
		x1 = x[0];
		x2 = x.length > 1 ? '.' + x[1] : '';
		var rgx = /(\d+)(\d{3})/;
		while (rgx.test(x1)) {
			x1 = x1.replace(rgx, '$1' + ',' + '$2');
		}
		return x1 + x2;
	}else{
		return '0.00';
	}	
}

@Override
	public Vector modifyResult() {
		//Current child entity
		HashMap currentRequestItemData = EAFManualUtil.getDataHashMapFromSession("MD9443222701", request);
		String currentOrderItemID = (String)currentRequestItemData.get("ORDER_ITEM_ID");
		String currentOrderItemSummary = (String)currentRequestItemData.get("SUMMARY_PRICE");
		
		//One to many before open child entity
		MasterFormHandler orderItemForm = (MasterFormHandler)getRequest().getSession().getAttribute("MD1290242832_session");
		Vector vForm = orderItemForm.getStoreActionList();
		logger.debug("#####vForm#####"+vForm); 
		double sumPrice = 0;
		for (int i=0; i<vForm.size(); i++) {
			HashMap hData = EAFManualUtil.getDataHashMapFromSession("MD1290242832", request, i);
			logger.debug("#####hData#####"+hData);
			
			String recordOrderItemId = (String)hData.get("ORDER_ITEM_ID");
			String recordSummary = (String)hData.get("SUMMARY_PRICE");
			
			//Summary all record except editing record (current child entity is editing record)
			if(!currentOrderItemID.equals(recordOrderItemId)){
				if(recordSummary != null && !"".equals(recordSummary)){
					sumPrice += Double.parseDouble(recordSummary);
				}
			}
			logger.debug("#####recordSummary#####"+recordSummary);
			logger.debug("#####sumPrice#####"+sumPrice);			
		}
		
		//Plus editing data to summary
		sumPrice += Double.parseDouble(currentOrderItemSummary);
		
		HashMap mainRequestData = EAFManualUtil.getDataHashMapFromSession("MD7333074691", request);
		
		Vector resultForProcess = getResultForProcess();
		
		HashMap serviceRequestDataHash = new HashMap();
		serviceRequestDataHash.put("TOTAL_AMT", String.valueOf(sumPrice));
		serviceRequestDataHash.put("REQUEST_ID", mainRequestData.get("REQUEST_ID"));
		
		Vector moduleKeyVect = new Vector();
		moduleKeyVect.add("REQUEST_ID");
		
		HashMap serviceRequestHash = new HashMap();
		serviceRequestHash.put("WF_SERVICE_REQUEST", serviceRequestDataHash);
		serviceRequestHash.put("MODULE_FIELD_KEY", moduleKeyVect);
		
		HashMap updateServiceRequestHash = new HashMap();
		updateServiceRequestHash.put("UPDATE", serviceRequestHash);
		
		resultForProcess.add(updateServiceRequestHash);
		
		logger.debug("#####resultForProcess#####"+resultForProcess); 
		
		return super.modifyResult();
	}

package com.manual.doc.order.java;

import java.util.HashMap;

import org.apache.log4j.Logger;

import com.master.form.EntityFormHandler;
import com.master.util.EAFManualUtil;
import com.master.util.ProcessAction;
import com.master.util.ProcessHelper;

public class OrderRequestRequesterInsertMode extends ProcessHelper implements ProcessAction {
	Logger logger = Logger.getLogger(OrderRequestRequesterInsertMode.class);
	@Override
	public void modifyInsert() {
		logger.debug("========= Get userName from userLogin and put to Requester on screen =======");
		//get data model of main module
		String entityID = (String)getRequest().getSession().getAttribute("entityID");
		EntityFormHandler entityForm = (EntityFormHandler)getRequest().getSession().getAttribute(entityID +"_session");
		String moduleID = entityForm.getMainModuleID();
		
		String userName = (String)request.getSession().getAttribute("userName");
		HashMap hRequester = EAFManualUtil.getDataHashMapFromSession(moduleID, request);
		//set value of field "Requester" as user login
		hRequester.put("REQUESTER", userName);		
	}
}

import java.util.HashMap;

import org.apache.log4j.Logger;

import com.master.form.EntityFormHandler;
import com.master.form.MasterFormHandler;
import com.master.util.EAFManualUtil;
import com.master.util.ProcessAction;
import com.master.util.ProcessHelper;

public class OrderRequestRequesterSearchMode extends ProcessHelper implements ProcessAction {
	Logger logger = Logger.getLogger(OrderRequestRequesterInsertMode.class);
	@Override
	public HashMap getSearchResult() {
		//get data model of main module
		String entityID = (String)getRequest().getSession().getAttribute("entityID");
		EntityFormHandler entityForm = (EntityFormHandler)getRequest().getSession().getAttribute(entityID +"_session");
		String moduleID = entityForm.getMainModuleID();
				
		MasterFormHandler moduleForm = (MasterFormHandler) request.getSession().getAttribute(moduleID + "_session");
		String userName = (String)request.getSession().getAttribute("userName");
		StringBuilder appendSql = new StringBuilder(" and wf_service_request.requester ='");
		appendSql.append(userName).append("' ");
		
		String sql = moduleForm.getModuleM().getSqlWorkQueue();
		logger.info("@@@@@ old sql :" + sql);
		
		StringBuilder newSql = new StringBuilder(sql);
		newSql.append(appendSql);
		
		logger.info("@@@@@ new sql :" + newSql.toString());
		
		//moduleForm.getModuleM().setSqlWorkQueue(sql);
		
		return EAFManualUtil.loadTableData(request, newSql.toString(), moduleForm.getPage(), moduleForm.getVolumePerPage());
	}
}