goodsinfomanager.java

关于商品的进、销、存管理系统

package supercms;

import java.sql.*;

import superdb.*;
import supershopmanager.GoodsInfo;
import supershopmanager.GoodsType;

import java.util.*;

/*
 * 商品信息管理
 * 完成商品基本资料的数据插入、删除、修改、查询、统计
 * 
 * */
public class GoodsInfoManager {

	private SuperDBConn sdb;
	private SuperInfoManager sim;
	private Statement stmt;// 创建命令对象

	public GoodsInfoManager() {

		sdb = new SuperDBConn();
		sim = new SuperInfoManager(sdb.getConn());
		stmt = sim.getStmt();
	}

	/*-----------商品基本资料的数据插入----------*/
	public void addGoodsInfo(GoodsInfo goodsInfo) {
		String sql = "insert into goodsinfo(goodsnumber,goodsname,guigetype,kindnumber,singleprice,safesum,unit,remarks)" +
				"values('"+goodsInfo.getGoodsnumber()+"','"+goodsInfo.getGoodsname()+"','"+goodsInfo.getGuigetype()+"','"+goodsInfo.getKindnumber()+"','"+goodsInfo.getSingleprice()+"','"+goodsInfo.getSafesum()+"','"+goodsInfo.getUnit()+"','"+goodsInfo.getRemarks()+"')";

		try
		{
		stmt.executeUpdate(sql);
		System.out.println("商品基本资料数据插入------成功！！！！！");
		}catch(Exception e){
			
			System.out.println("商品基本资料数据插入------失败！！！！！");
		}
	}
	/*-----------商品基本资料的数据查询----------*/
	public Vector selectGoodsInfo(GoodsInfo goodsInfo,int type)
	{
		Vector allGoodsInfo=new Vector();
		String sql="";
		if(type==1)//说明按编号查询
		{
		 sql="select * from goodsinfo where id="+goodsInfo.getId();
		}
		if(type==2)//说明按商品码进行查询
		{
			sql="select * from goodsinfo where goodsnumber='"+goodsInfo.getGoodsnumber()+"'";
		}
		if(type==3)//说明按照商品名进行查询
		{
			sql="select * from goodsinfo where goodsname='"+goodsInfo.getGoodsname()+"'";
		}
		if(type==4)//说明按照商品种类型号进行查询
		{
			sql="select * from goodsinfo where kindnumber='"+goodsInfo.getKindnumber()+"'";
		}
		if(type==5)//说明按照单价进行查询
		{
			sql="select * from goodsinfo where singleprice="+goodsInfo.getSingleprice();
		}
		try
		{
			ResultSet rs=stmt.executeQuery(sql);//执行查询
			while(rs.next())
			{
				GoodsInfo gi=new GoodsInfo();
				gi.setId(rs.getInt("id"));
				gi.setGoodsnumber(rs.getString("goodsnumber"));
				gi.setGoodsname(rs.getString("goodsname"));
				gi.setGuigetype(rs.getString("guigetype"));
				gi.setKindnumber(rs.getInt("kindnumber"));
				gi.setSingleprice(rs.getLong("singleprice"));
				gi.setSafesum(rs.getInt("safesum"));
				gi.setUnit(rs.getString("unit"));
				gi.setRemarks(rs.getString("remarks"));
				allGoodsInfo.add(gi);
				System.out.println("商品基本资料数据查询------成功！！！！");
				
			}
			
		}catch(Exception e)
		{
			e.printStackTrace();
			System.out.println("商品基本资料数据查询------失败！！！！");
		}
		return allGoodsInfo;
	}
/*-----------商品基本资料数据的删除------------*/
	public void deleteGoodsInfo(GoodsInfo goodsInfo)
	{
		String sql="delete from goodsinfo where id="+goodsInfo.getId();
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("删除商品基本资料------成功！！！！");
		}catch(Exception e)
		{
			System.out.println("删除商品基本资料------失败！！！！");
		}
		
	}
	public void delGoodsInfo(GoodsInfo goodsInfo)
	{
		String sql="delete from goodsinfo where kindnumber="+goodsInfo.getKindnumber();
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("删除商品基本资料------成功！！！！");
		}catch(Exception e)
		{
			System.out.println("删除商品基本资料------失败！！！！");
		}
	}
	/*---------------商品基本资料数据的修改----------*/
	public void updateGoodsInfo(GoodsInfo goodsInfo)
	{
		String sql="update goodsinfo set goodsnumber='"+goodsInfo.getGoodsnumber()+"'," +
				"goodsname='"+goodsInfo.getGoodsname()+"',guigetype='"+goodsInfo.getGuigetype()+"'," +
				"kindnumber='"+goodsInfo.getKindnumber()+"',singleprice='"+goodsInfo.getSingleprice()+"',safesum='"+goodsInfo.getSafesum()+"'," +
				"unit='"+goodsInfo.getUnit()+"',remarks='"+goodsInfo.getRemarks()+"' where id="+goodsInfo.getId();
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("修改商品基本资料------成功！！！！");
		}catch(Exception e)
		{
			System.out.println("修改商品基本资料------失败！！！！");
		}
		
	}
	/*-----------------统计商品数量------------------*/
	public long countGoodsInfo(GoodsInfo goodsInfo,int type)
	{
		long count=0;
		String sql="";
		if(type==1)//说明按编号查询
		{
		 sql="select count(*) from goodsinfo where id="+goodsInfo.getId();
		}
		if(type==2)//说明按商品码进行查询
		{
			sql="select count(*) from goodsinfo where goodsnumber='"+goodsInfo.getGoodsnumber()+"'";
		}
		if(type==3)//说明按照商品名进行查询
		{
			sql="select count(*) from goodsinfo where goodsname='"+goodsInfo.getGoodsname()+"'";
		}
		if(type==4)//说明按照商品种类型号进行查询
		{
			sql="select count(*) from goodsinfo where kindnumber="+goodsInfo.getKindnumber();
		}
		if(type==5)//说明按照单价进行查询
		{
			sql="select count(*) from goodsinfo where singleprice="+goodsInfo.getSingleprice();
		}
		
		try
		{
			ResultSet rs=stmt.executeQuery(sql);//执行查询
			while(rs.next())
			{
				count++;
				System.out.println("商品基本资料数据统计------成功！！！！");
				
			}
			
		}catch(Exception e)
		{
			e.printStackTrace();
			System.out.println("商品基本资料数据统计------失败！！！！");
		}
		
		return count;
	}
	
	 /*------查询分页-----*/
	  
	public List getAllInfo(int pagesize,int nowpage) throws Exception
	{List allinfo=new ArrayList();
	String sql="select * from goodsinfo order by id";	
	  ResultSet rs=stmt.executeQuery(sql);
	  rs.last();// 定位到最后一条记录
	  int rows=rs.getRow();
	  int num=pagesize;
	  int pagecount=rows/pagesize;//总页数
	  if(rows%pagesize>0){pagecount++;}
	  if(nowpage>0&&nowpage<=pagecount)
	  {
		if(nowpage==1){rs.beforeFirst();}
		if(nowpage>1){rs.absolute((nowpage-1)*pagesize);}
	  while(rs.next()&&num>0)
	  { 
		  GoodsInfo gi=new GoodsInfo();
		  gi.setId(rs.getInt("id"));
		  gi.setGoodsnumber(rs.getString("goodsnumber"));
		  gi.setGuigetype(rs.getString("guigetype"));
		  gi.setKindnumber(rs.getInt("kindnumber"));
		  gi.setSafesum(rs.getInt("safesum"));
		  gi.setSingleprice(rs.getLong("singleprice"));
		  gi.setUnit(rs.getString("unit"));
		  gi.setRemarks(rs.getString("remarks"));
		  
	    num--;
	    allinfo.add(gi);
	  }
	  return allinfo;
	 }
	  return null;
	}
  
	public int getcount()throws Exception
	{
		int count=0;
		String sql="select * from goodsinfo order by id";
		 ResultSet rs=stmt.executeQuery(sql);
		 rs.last();
		 count=rs.getRow();
		return count;
	}
}