khthmxb.java

web版的进销存系统

package jxc.web;

import jxc.com.DBConnect;
import java.lang.String;
import jxc.util.StrFun;
import java.sql.*;

import javax.servlet.http.*;

public class Khthmxb{
	private int ID;
	private int djbh;
	private int wpbh;
	private int num;
	private float dj;
	private float je;
	private Date Tdate;
	private boolean isError=false;
	private String StrError="";
	public int  getID() {
		return ID;
	}
	public void setID(int anew) {
		this.ID=anew;
	}
	public void setID(String anew) {
		if (anew!=null)
			this.ID=Integer.parseInt(anew);
	}
	public int  getDjbh() {
		return djbh;
	}
	public void setDjbh(int anew) {
		this.djbh=anew;
	}
	public int  getWpbh() {
		return wpbh;
	}
	public void setWpbh(int anew) {
		this.wpbh=anew;
	}
	public int  getNum() {
		return num;
	}
	public void setNum(int anew) {
		this.num=anew;
	}
	public float  getDj() {
		return dj;
	}
	public void setDj(float anew) {
		this.dj=anew;
	}
	public float  getJe() {
		return je;
	}
	public void setJe(float anew) {
		this.je=anew;
	}
	public Date getFdate() {
		return Tdate;
	}
	public void setFdate(Date anew) {
		Tdate = anew;
	}
	public boolean getIsError(){
		return this.isError;
	}
	public String getStrError(){
		return this.StrError;
	}

	public boolean excute() throws Exception {
		String Str="Select * From khthmxb where Id="+ID;
		try {
			DBConnect dbc  = new DBConnect(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
			ResultSet rs = dbc.executeQuery(Str);
			if (rs.next()){
				ID=rs.getInt("ID"); 
				djbh=rs.getInt("djbh"); 
				wpbh=rs.getInt("wpbh"); 
				num=rs.getInt("num"); 
				dj=rs.getFloat("dj"); 
				je=rs.getFloat("je"); 
			}
			rs.close();
			dbc.close();
			return true;
		}
		catch (SQLException sqle){
			return false;
		}
	} 
	
	public void Add(HttpServletRequest request) throws Exception {//添加商品
		djbh=StrFun.getInt(request,"djbh"); 
		wpbh=StrFun.getInt(request,"wpbh"); 
		num=StrFun.getInt(request,"num"); //退货的数量
		dj=StrFun.getFloat(request,"dj");
		int kcNum = 0;
		int nowNum = 0;

		if (num<=0){
			isError=true;
			StrError="number.error";
		} 
//		if (wpbh<=0){
//		isError=true;
//		StrError=StrError+"商品错误!!! <br>";
//		} 
		if (!isError){      
			je=dj*num; //退货的总金额
			String ckid=request.getParameter("ckid");
			String Str="Insert into khthmxb(Tdate,djbh,wpbh,num,dj,je) values(now(),"+djbh+","+wpbh+","+num+","+dj+","+je+")";
			DBConnect dbc  = new DBConnect();
			dbc.executeUpdate(Str);
			Str="Select * From kcb where wpbh="+wpbh+" and ckbh="+ckid;
			ResultSet rs=dbc.executeQuery(Str);

			if (rs.next()){
				kcNum = rs.getInt("num");//库存数量
				nowNum = kcNum+num;
				Str="Update kcb set Num="+nowNum+" where wpbh="+wpbh+" and ckbh="+ckid;
			}
			else{
//				isError=false;
//				StrError="number.error.no";//库存里没有这个商品，在库存里加入这个商品
				Str="insert into kcb (ckbh,wpbh,num) values("+ckid+","+wpbh+","+num+")";
			}
			dbc.executeUpdate(Str);
			rs.close();
			dbc.close();   
		}
	}   

	public void Edit(HttpServletRequest request) throws Exception {
		ID=StrFun.getInt(request,"id"); 
		djbh=StrFun.getInt(request,"djbh"); 
		wpbh=StrFun.getInt(request,"wpbh"); 
		num=StrFun.getInt(request,"num");//修改后的数量
		dj=StrFun.getFloat(request,"dj");//修改后的单价
		int kcnum = 0;
		int beforeNum = 0;
		float nowMoneySell = dj*num;

		if (num<=0){
			isError=true;
			StrError="number.error";
		} 
		String ckid=request.getParameter("ckid");
		String Str="Select * From kcb where wpbh="+wpbh+" and ckbh="+ckid;
		DBConnect dbc  = new DBConnect();
		ResultSet rs=dbc.executeQuery(Str);
		if (rs.next()){
			kcnum = rs.getInt("num");//库存数量
			Str="Select * From khthmxb where id="+ID;//得到明细表中的原来添加的商品数量
			rs=dbc.executeQuery(Str);
			if (rs.next()){
				beforeNum = rs.getInt("num");//修改前的数量
				int afterNum = kcnum-beforeNum+num; //修改后的库存量
				if (afterNum<0) {
					isError=true;
					StrError="number.error.enought";
				}	
			}  
		} 

		if (!isError) {
			//更新销售明细表中的总金额
			Str="Update khthmxb set djbh="+djbh+",num="+num+",dj="+dj+",je="+nowMoneySell+"  where id="+ID;
			dbc.executeUpdate(Str);
			
			int afterNum = kcnum-beforeNum+num; //修改后的库存量 
			Str="Update kcb set Num="+afterNum+" where wpbh="+wpbh+" and ckbh="+ckid;
			dbc.executeUpdate(Str);    
		}
		rs.close();
		dbc.close();
	}

	public void Del(HttpServletRequest request) throws Exception {
		ID=StrFun.getInt(request,"id");
		int del=StrFun.getInt(request,"del");		 
		int ckid=StrFun.getInt(request,"ckid"); 		
		int kcNum = 0;
		int nowNum = 0;

		DBConnect dbc  = new DBConnect();
		String Str="Select * From khthmxb where id="+del;//对应的记录
		ResultSet rs=dbc.executeQuery(Str);
		if (rs.next()){
			int x = rs.getInt("num");
			wpbh=rs.getInt("wpbh");
			Str="Select * From kcb where wpbh="+wpbh+" and ckbh="+ckid;
			rs=dbc.executeQuery(Str);
			if (rs.next()){  				
				kcNum = rs.getInt("num");
				nowNum = kcNum-x;
				if (nowNum<0) {
					isError=true;
					StrError="number.error";	  	
				}
			}  	  
		} 		 
		if (!isError){
			Str="Delete From khthmxb where djbh="+ID+" and ID="+del;
			dbc.executeUpdate(Str);			
			if(nowNum==0)//如果取消采购后仓库里的数量为0，就删除库存表的记录
			{
				Str="Delete From kcb where wpbh="+wpbh+" and ckbh="+ckid+"";
			}
			else
			{
				Str="Update kcb set Num="+nowNum+" where wpbh="+wpbh+" and ckbh="+ckid;
			}
			dbc.executeUpdate(Str);
		}
		rs.close();
		dbc.close();  

	}

}