warehousemanager.java

基于J2EE的网络物流系统 用户操作： 1． 录入出库商品信息 2． 查询出库单信息 3． 录入入库商品信息 4． 查询入库单信息 5． 查询商品位置信息 6． 查询商品信息 7． 查

package com.logistic.business;

import com.logistic.data.DataConnect;
import com.logistic.dao.IWareHouseDAO;
import java.sql.Statement;
import java.sql.ResultSet;
import java.util.Vector;
import com.logistic.model.WareHouseInfo;

public class WareHouseManager implements IWareHouseDAO {
	
	DataConnect dc=new DataConnect();
	Statement   stat=null;
	ResultSet   rs=null;
	int flag=-10;
	
	public int AddWareHouseInfo(String warehouseid,String warehousename,String chargeid,String warehouseaddress){
		
		flag=0;
		try{
			
			String id=warehouseid;			//仓库信息编号
     		String name=warehousename;		//仓库名称	
			String cid=chargeid;            //负责人编号
			String add=warehouseaddress;    //仓库地址
			
			String strsql="insert into warehouseinfotable(WareHouseId,WareHouseName,ChargeId,WareHouseAdd)values" +
						  "('"+id+"','"+name+"','"+cid+"','"+add+"')";
			flag=dc.updata(strsql);
			if(flag>0){
				System.out.println("仓库信息保存成功!");
			 }else{
				 System.out.println("仓库信息保存失败!");
			 }
			
		}catch(Exception ex){
			
			flag=-1;
			ex.printStackTrace();
		}finally{dc.close();}
	  
		return flag;	
	}

	public Vector WareHouseSearch(String strsql,int page){
		
		Vector items=new Vector();
		
		try{
			
			stat=dc.getStmtread();
			rs=stat.executeQuery(strsql);
			PageAble pgb=new PageAble(rs);
			pgb.setPagesize(5);
			pgb.setCurrentpage(1);
			pgb.gotoPage(page);
			
			rs.absolute(pgb.getRowscount());
			
			int i=0;
			do{
				items.add(new WareHouseInfo(rs.getString("WareHouseId"),rs.getString("WareHouseName"),rs.getString("ChargeId"),rs.getString("WareHouseAdd")));
			  
			   }while(rs.next()&&i<pgb.getCurrentPageRowsCount());
			
		}catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
		
	  return items;	
	}

	public int DelWareHouse(String warehouseid){
		
		String delwarehoue="delete from warehouseinfotable where WareHouseId="+warehouseid;
		
		int flag=0;
		
		try{
			flag=dc.updata(delwarehoue);
			if(flag>0){
				System.out.println("编号为:"+warehouseid+"仓库信息删除成功!");
			   }else{
				System.out.println("编号为:"+warehouseid+"仓库信息删除失败!");
			         }
		    }catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
			
	    return flag;
	}

	public int ModifyWareHouse(String warehouseid,String warehousename,String chargeid,String warehouseaddress){
		
		int flag=-10;
		try{
			
			String whid=warehouseid;
			String whname=warehousename;
			String cid=chargeid;
			String whaddress=warehouseaddress;
			
			String strsql="update warehouseinfotable set WareHouseName='"+whname+"',ChargeId='"+cid+"',WareHouseAdd='"+whaddress+"' where WareHouseId="+whid;
			flag=dc.updata(strsql);
			if(flag>0){
				System.out.println("编号="+whid+"的仓库信息修改成功!");
			}else{
				System.out.println("编号="+whid+"的仓库信息修改失败!");
			}
			
		}catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
	return flag;	
	}

	public WareHouseInfo WareHouseSearchById(String warehouseid){
		
		String strsql="select * from warehouseinfotable where WareHouseId="+warehouseid;
		WareHouseInfo whi=new WareHouseInfo();
		
		try{
			stat=dc.getStmtread();
			rs  =stat.executeQuery(strsql);
			while(rs.next()){
				whi.setWarehouseid(rs.getString("WareHouseId"));
				whi.setWarehousename(rs.getString("WareHouseName"));
				whi.setChargeid(rs.getString("ChargeId"));
				whi.setWarehouseadd(rs.getString("WareHouseAdd"));
			}
			
		}catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
	return whi;
	}
}