orderoperation.java

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

package operation;


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

public class OrderOperation
{
	private ResultSet rs;
	private DataBase db;
	public OrderOperation()
	{
		 db=new DataBase();
	}
	public String getOrderID()                                    //得到进货编号
	{
		String OrderID=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 OrderList where OrderID like '%"+Date+"%'";
	
		try
		{
		 rs=db.getResult(sql);
		 if(rs.next())
		 {	
		  rs.last();
		  int Row=rs.getRow();
		  String R=String.valueOf(Row+1);
		  OrderID="O"+Date+"00"+R;             //生成订货编号
		 }
		 else
		 OrderID="O"+Date+"001";             //若不存在当天的订货记录，记为001
		   
		}
		catch(SQLException e)
		{
			e.printStackTrace();
		}
		return OrderID;
	}
	 public boolean checkStock(int ProductID,int OrderQuantity)   //判断该种商品库存够不够
	  {
		  boolean a=false;
		  String sql="select * from StockRecord where ProductID="+ProductID;
		  try
		  {
			  rs=db.getResult(sql);
			  if(rs.next())
			  {
			   int q=rs.getInt("ProductQuantity");
			   if(q>=OrderQuantity)
			   {
				   a=true;
			   }
			  }
		  }
		  catch(Exception e)
		  {
			  e.printStackTrace();
		  }
		  return a;
	  }
	public void OrderInsert(String OrderID,int CustomerID,int ProductID,int OrderQuantity,Date OrderDate,String OrderNotice,String OrderState)
	{
		String sql="insert into OrderList values('"+OrderID+"',"+ProductID+","+CustomerID+","+OrderQuantity+",'"+OrderDate+"','"+OrderNotice+"','"+OrderState+"')";
		try
		{
			db.ExeQuery(sql);
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	public void close()
	{
		db.close();
	}
}