enteroperation.java

该源代码实现了系统的进货

package operation;


import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Calendar;
import dataBase.DataBase;
import java.sql.Date;

public class EnterOperation 
{

	private ResultSet rs;
	private DataBase db;
	public EnterOperation()
	{
		db=new DataBase();
	}
	
	public String getEnterID()                                    //得到进货编号
	{
		String EnterID=null;
		Calendar cal=Calendar.getInstance();
		String Year=String.valueOf(cal.get(Calendar.YEAR));
		int m=Integer.parseInt(String.valueOf(cal.get(Calendar.MONTH)+1));
		String Month=null;
		if(m<10)
		{
			Month="0"+String.valueOf(m);
		}
		else
			Month=String.valueOf(m);
		 
		String Day=null;
		int f=cal.get(Calendar.DAY_OF_MONTH);
		if(f<10)
		{
			Day="0"+String.valueOf(f);
		}
		else
			Day=String.valueOf(f);
			
		String Date=Year+Month+Day;
        //查询是否存在当天的进货记录  
		
		String sql="select * from EnterInfo where EnterID like '%"+Date+"%'";
		
		try
		{
		 ResultSet rs=db.getResult(sql);
		 if(rs.next())
		 {	
		  rs.last();
		  int Row=rs.getRow();
		  String R=String.valueOf(Row+1);
		  EnterID="E"+Date+"00"+R;             //生成进货编号
		 }
		 else
		  EnterID="E"+Date+"001";             //若不存在当天的进货记录，记为001
		   
		}
		catch(SQLException e)
		{
			e.printStackTrace();
		}
		return EnterID;
	}
	
	
  public int getProductID(String ProductName)                       //从商品信息中得到商品编号
  {
	  int ProductID=0;
	  String sql="select * from ProductInfo where ProductName='"+ProductName+"'";
	  try
	  {
		  rs=db.getResult(sql);
		  if(rs.next())
		  {
			  ProductID=rs.getInt("ProductID");
		  }
			  
	  }
	  catch(SQLException e)
		{
			e.printStackTrace();
		}
	  return ProductID;
  }
  
  public boolean checkStockID(int ProductID)   //判断该种商品在库存中有没有记录
  {
	  boolean a=false;
	  String sql="select * from StockRecord where ProductID="+ProductID;
	  try
	  {
		  rs=db.getResult(sql);
		  if(rs.next())
		  a=true;
	  }
	  catch(Exception e)
	  {
		  e.printStackTrace();
	  }
	  return a;
  }
  
  public void StockInsert(int ProductID,int ProductQuantity)   //对于没有库存记录的商品，新建库存记录
  {
	  String sql="select * from StockRecord";
	  try
	  {
		  rs=db.getResult(sql);
		  rs.next();
		  rs.last();
		  int  StockID=rs.getRow()+1;
		  sql="insert into StockRecord values("+StockID+","+ProductID+","+ProductQuantity+")";
		  db.ExeQuery(sql);
	  }
	  catch(Exception e)
	  {
		  e.printStackTrace();
	  }
  }
  
  //添加进货单和应付款记录
  public void EnterInfoInsert(String EnterID,String StockID,int ProductID,String ProviderName,int EnterQuantity,float EnterPrice,float ProductPrice,float EnterSum,Date EnterDate,
		                  String Chargeman,String EnterNotice,String ShouldPayID,float ShouldPaySum,float LeaveSum,
		                  Date ShouldPayDate,
		                  String ShouldPayNotice)
  {
	  String ShouldPayFlag="否";
	  String sql1="insert into EnterInfo values('"+EnterID+"','"+StockID+"',"+ProductID+","+ProviderName+","+EnterQuantity+","+EnterPrice+","+ProductPrice+","+EnterSum+",'"+EnterDate+"','"
	      +Chargeman+"','"+EnterNotice+"')";
	  String sql2="insert into ShouldPayList values('"+ShouldPayID+"','"+EnterID+"',"+ShouldPaySum+","+LeaveSum+",'"
	       +ShouldPayFlag+"','"+Chargeman+"','"+ShouldPayDate+"','"+ShouldPayNotice+"')";
	  String sql3="update StockRecord set ProductQuantity=ProductQuantity+"+EnterQuantity+" where ProductID="+ProductID;
	  try
	  {
		  db.ExeQuery(sql1,sql2,sql3);
	  }
	  catch(Exception e)
	  {
		  e.printStackTrace();
	  }
  }
  public void Close()
  {
	  db.close();
  }
}