productdistribution.java

java阿里巴巴代码

package com.saas.biz.productdistributionMgr;

import java.util.ArrayList;
import java.util.*;
import com.saas.sys.buffer.Buffers;
import com.saas.sys.dbm.Dbtable;
import com.saas.sys.exp.SaasApplicationException;
import com.saas.sys.log.Logger;
import com.saas.biz.dao.goodsDAO.GoodsExt;
import com.saas.biz.dao.productdistributionDAO.ProductDistributionDAO;
import com.saas.biz.dao.productdistributionDAO.ProductDistributionExt;
import com.saas.biz.goodsMgr.GoodsInfo;
import com.saas.biz.wareHouseMgr.wareHouseInfo;
import com.saas.biz.wareHousePosMgr.WareHousePosInfo;

public class ProductDistribution {
	Dbtable tradeQuery;

	Logger log;

	Buffers inBuffer;

	Buffers outBuffer;

	ArrayList queryResult = new ArrayList();

	public ProductDistribution() {
		log = new Logger(this);
		tradeQuery = new Dbtable();
	}

	public void setTradeQuery(Dbtable tradeQuery) {
		this.tradeQuery = tradeQuery;
	}

	public Dbtable getTradeQuery() {
		return this.tradeQuery;
	}

	public void setOutBuffer(Buffers outBuffer) {
		this.outBuffer = outBuffer;
	}

	public Buffers getOutBuffer() {
		return this.outBuffer;
	}

	public ArrayList getQueryResult() {
		return this.queryResult;
	}

	public void setQueryResult(ArrayList queryResult) {
		this.queryResult = queryResult;
	}

	// 将入库的产品分拣存储到各个仓库的仓位
	public void addProductDis(Buffers inbuffer) {
		log.LOG_INFO("进入addProductDis方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String cust_id = inbuffer.getString("SESSION_CUST_ID");
		String dis_id = inbuffer.getString("DIS_ID");
		String goods_id = inbuffer.getString("GOODS_ID");
		String house_id = inbuffer.getString("HOUSE_ID");
		String pos_id = inbuffer.getString("POS_ID");
		String last_pos = inbuffer.getString("LAST_POS");
		String lot_no = inbuffer.getString("LOT_NO");
		String my_lot1 = inbuffer.getString("MY_LOT1");
		String my_lot2 = inbuffer.getString("MY_LOT2");
		String my_lot3 = inbuffer.getString("MY_LOT3");
		String link_quo_id = inbuffer.getString("LINK_QUO_ID");
		String store_vol = inbuffer.getString("STORE_VOL");
		String state_code = inbuffer.getString("STATE_CODE");
		String state_code_date = inbuffer.getString("STATE_CODE_DATE");
		String user_id = inbuffer.getString("USER_ID");
		String publish_date = inbuffer.getString("PUBLISH_DATE");
		String remark = inbuffer.getString("REMARK");

		try {
			ProductDistributionDAO productdis = new ProductDistributionDAO();
			productdis.setCust_id(cust_id);
			productdis.setDis_id(dis_id);
			productdis.setGoods_id(goods_id);
			productdis.setHouse_id(house_id);
			productdis.setPos_id(pos_id);
			productdis.setLast_pos(last_pos);
			productdis.setLot_no(lot_no);
			productdis.setMy_lot1(my_lot1);
			productdis.setMy_lot2(my_lot2);
			productdis.setMy_lot3(my_lot3);
			productdis.setLink_quo_id(link_quo_id);
			productdis.setStore_vol(store_vol);
			productdis.setState_code(state_code);
			productdis.setState_code_date(state_code_date);
			productdis.setUser_id(user_id);
			productdis.setPublish_date(publish_date);
			productdis.setRemark(remark);

			iResult = addProductDis(productdis);
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());
		}
		if (iResult != 0) {
			this.outBuffer.setInt("RESULT_CODE", -1);
			this.outBuffer.setString("RESULT_INFO", "业务处理失败！");
		} else {
			this.outBuffer.setInt("RESULT_CODE", 0);
			this.outBuffer.setString("RESULT_INFO", "业务处理成功！");
		}
		log.LOG_INFO("退出addProductDis方法...");
	}

	public int addProductDis(ProductDistributionDAO productdisdao)
			throws SaasApplicationException {
		ProductDistributionExt productdisExt = new ProductDistributionExt();
		productdisExt.setParam(":VCUST_ID", productdisdao.getCust_id());
		productdisExt.setParam(":VDIS_ID", productdisdao.getDis_id());
		productdisExt.setParam(":VGOODS_ID", productdisdao.getGoods_id());
		productdisExt.setParam(":VHOUSE_ID", productdisdao.getHouse_id());
		productdisExt.setParam(":VPOS_ID", productdisdao.getPos_id());
		productdisExt.setParam(":VLAST_POS", productdisdao.getLast_pos());
		productdisExt.setParam(":VLOT_NO", productdisdao.getLot_no());
		productdisExt.setParam(":VMY_LOT1", productdisdao.getMy_lot1());
		productdisExt.setParam(":VMY_LOT2", productdisdao.getMy_lot2());
		productdisExt.setParam(":VMY_LOT3", productdisdao.getMy_lot3());
		productdisExt.setParam(":VLINK_QUO_ID", productdisdao.getLink_quo_id());
		productdisExt.setParam(":VSTORE_VOL", productdisdao.getStore_vol());
		productdisExt.setParam(":VSTATE_CODE", productdisdao.getState_code());
		productdisExt.setParam(":VSTATE_CODE_DATE", productdisdao
				.getState_code_date());
		productdisExt.setParam(":VUSER_ID", productdisdao.getUser_id());
		productdisExt.setParam(":VPUBLISH_DATE", productdisdao
				.getPublish_date());
		productdisExt.setParam(":VREMARK", productdisdao.getRemark());

		tradeQuery.executeBy(productdisExt.insBy("INS_PRO_DIS_ALL"));
		return 0;
	}

	// 仓库转储
	public void ModiProductDis(Buffers inbuffer) {
		log.LOG_INFO("进入ModiProductDis方法...");
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		int iResult = -1;
		String cust_id = inbuffer.getString("SESSION_CUST_ID");
		String dis_id = inbuffer.getString("DIS_ID");
		String goods_id = inbuffer.getString("GOODS_ID");
		String house_id = inbuffer.getString("HOUSE_ID");
		String pos_id = inbuffer.getString("POS_ID");
		String user_id = inbuffer.getString("SESSION_USER_ID");

		try {
			ProductDistributionDAO productdis = new ProductDistributionDAO();
			productdis.setCust_id(cust_id);
			productdis.setDis_id(dis_id);
			productdis.setGoods_id(goods_id);
			productdis.setHouse_id(house_id);
			productdis.setPos_id(pos_id);
			productdis.setUser_id(user_id);

			iResult = ModiProductDis(productdis);
		} catch (SaasApplicationException e) {
			log.LOG_INFO(e.getMessage());
		}
		if (iResult != 0) {
			this.outBuffer.setInt("RESULT_CODE", -1);
			this.outBuffer.setString("RESULT_INFO", "业务处理失败！");
		} else {
			this.outBuffer.setInt("RESULT_CODE", 0);
			this.outBuffer.setString("RESULT_INFO", "业务处理成功！");
		}
		log.LOG_INFO("退出ModiProductDis方法...");
	}

	public int ModiProductDis(ProductDistributionDAO productdisdao)
			throws SaasApplicationException {
		ProductDistributionExt productdisExt = new ProductDistributionExt();
		productdisExt.setParam(":VCUST_ID", productdisdao.getCust_id());
		productdisExt.setParam(":VDIS_ID", productdisdao.getDis_id());
		productdisExt.setParam(":VGOODS_ID", productdisdao.getGoods_id());
		productdisExt.setParam(":VHOUSE_ID", productdisdao.getHouse_id());
		productdisExt.setParam(":VPOS_ID", productdisdao.getPos_id());
		productdisExt.setParam(":VUSER_ID", productdisdao.getUser_id());

		tradeQuery.executeBy(productdisExt.insBy("UP_PRO_DIS_ALL"));
		return 0;
	}

	public HashMap getProtInfoById(String cust_id, String goods_id)
			throws SaasApplicationException {
		ArrayList productList = new ArrayList();
		ProductDistributionExt productdisExt = new ProductDistributionExt();
		productdisExt.setParam(":VCUST_ID", cust_id);
		productdisExt.setParam(":VGOODS_ID", goods_id);
		HashMap map = new HashMap();
		productList = productdisExt.selByList("SEL_BY_GOODS");
		if (productList != null && productList.size() > 0) {
			map = (HashMap) productList.get(0);
		}
		return map;
	}
	
	public HashMap getHousePos(String cust_id, String goods_id)
			throws SaasApplicationException {
		ArrayList productList = new ArrayList();
		ProductDistributionExt productdisExt = new ProductDistributionExt();
		productdisExt.setParam(":VCUST_ID", cust_id);
		productdisExt.setParam(":VGOODS_ID", goods_id);
		HashMap map = new HashMap();
		productList = productdisExt.selByList("SEL_HOUSE_POS_BY_ID");
		if (productList != null && productList.size() > 0) {
			map = (HashMap) productList.get(0);
		}
		return map;
	}
	
	public ArrayList getById(String cust_id,String goods_id) throws SaasApplicationException {

		ArrayList relationList = new ArrayList();
		ProductDistributionExt relaExt = new ProductDistributionExt();
		relaExt.setParam(":VCUST_ID", cust_id);
		relaExt.setParam(":VGOODS_ID", goods_id);
		relationList = relaExt.selByList("SEL_BY_ID");
		return relationList;
	}
	
	public String getSelectHouse(String cust_id) throws SaasApplicationException {

		ArrayList relationList = new ArrayList();
		ProductDistributionExt relaExt = new ProductDistributionExt();
		relaExt.setParam(":VCUST_ID", cust_id);
		relationList = relaExt.selByList("SEL_HOUSE_BY_CUST_ID");
		HashMap map  = new HashMap();
		wareHouseInfo houseInfo = new wareHouseInfo();
		String house_id="",house_name="",str="";
		if(relationList!=null && relationList.size()>0){
			for (int i = 0; i < relationList.size(); i++) {
				map = (HashMap)relationList.get(i);
				if(map.get("house_id")!=null){
					house_id = map.get("house_id").toString();
					house_name=houseInfo.getHouseNameById(cust_id,house_id);
				}
				str=str+"<option value="+house_id+">"+house_name+"</option>";
			}
			
		}
		return str;
	}
	
	public Map getOneGoodsByHousePosId(String cust_id,String house_id,String pos_id) throws SaasApplicationException 
	{
		ArrayList list = new ArrayList();
		ProductDistributionExt relaExt = new ProductDistributionExt();
		relaExt.setParam(":VCUST_ID",cust_id);
		relaExt.setParam(":VHOUSE_ID",house_id);
		relaExt.setParam(":VPOS_ID",pos_id);
		list = relaExt.selByList("SEL_GOODS_BY_HOUSE_POS_ID");
		String goods_id="",goods_name="";
		Map childMap=new HashMap();
		HashMap map = new HashMap();
		HashMap infoMap = new HashMap();
		GoodsInfo info  = new GoodsInfo();
		if(list!=null&&list.size()>0){
			for (int i = 0; i < list.size(); i++) {
				map = (HashMap)list.get(i);
				if( map.get("goods_id")!=null){
					goods_id= map.get("goods_id").toString();
				}
				infoMap=info.getOneGoods(cust_id,goods_id);
				if(infoMap.get("goods_name")!=null){
					goods_name=infoMap.get("goods_name").toString();
				}
				childMap.put(goods_id,goods_name);
			}
		}
		return childMap;
	}
}