xsmxb.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 Xsmxb{
	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 xsmxb 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;//库存数量

		if (num<=0){//数量不能小于0
			isError=true;
			StrError="number.error";
		} 
//		if (wpbh<=0){//物品编号不能异常？？
//			isError=true;
//			StrError=StrError+"商品错误!!! <br>";
//		} 
		if (!isError){      
			float xsje=dj*num; //（单个）物品的销售金额＝销售的单价×销售的数量
			String ckid=request.getParameter("ckid");
						
			DBConnect dbc  = new DBConnect();			
			
			String Str="Select * From kcb where wpbh="+wpbh+" and ckbh="+ckid;//查找库存里面对应的商品			
			ResultSet rs = dbc.executeQuery(Str);			
			if (rs.next()){
				
				kcnum = rs.getInt("num");//库存数量
				
				if(kcnum-num<=-1){
					isError=true;
					StrError="number.error.enought";
				}
				else{				
				Str="Update kcb set Num=Num-"+num+" where wpbh="+wpbh+" and ckbh="+ckid;
				dbc.executeUpdate(Str);
				Str="Insert into xsmxb(Tdate,djbh,wpbh,num,dj,je) values(now(),"+djbh+","+wpbh+","+num+","+dj+","+xsje+")";
				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 xsmxb where id="+ID;//得到明细表中的原来添加的商品数量
			rs=dbc.executeQuery(Str);
			if (rs.next()){
				beforeNum = rs.getInt("num");//修改前的数量				
				int k = kcnum-num+beforeNum; //修改后的库存量				
				if (k<0) {
					isError=true;
					StrError="number.error.enought";
				}	
			}  
		} 
						
		if (!isError) {
			//更新销售明细表中的总金额
			Str="Update xsmxb set djbh="+djbh+",num="+num+",dj="+dj+",je="+nowMoneySell+"  where id="+ID;
			dbc.executeUpdate(Str);
			int k = kcnum-num+beforeNum; //修改后的库存量 
			Str="Update kcb set Num="+k+" where wpbh="+wpbh+" and ckbh="+ckid;
			dbc.executeUpdate(Str);
		}
		rs.close();
		dbc.close();
	}


	public void Del(HttpServletRequest request) throws Exception {
		int del=StrFun.getInt(request,"del");//明细表的ID
		ID=StrFun.getInt(request,"id"); 
		int ckid=StrFun.getInt(request,"ckid");
		
		DBConnect dbc  = new DBConnect();
		String Str="Select * From xsmxb where id="+del;//找到对应的记录，应该是ID不是djbh
		ResultSet rs=dbc.executeQuery(Str);
				
		if (rs.next()){
			int x=rs.getInt("num");//得到这条记录的数量
			je=rs.getFloat("je");
			
			wpbh=rs.getInt("wpbh");
			Str="Select * From kclist where wpid="+wpbh+" and ckid="+ckid;
			rs=dbc.executeQuery(Str);	
			if (rs.next()){
				num = rs.getInt("num");//库存数量
				num=num+x;    //库存量＋返回量
				if (num<0) {
					isError=true;
					StrError="number.error";	  	
				}
			}  	  
		} 		 
		if (!isError){
			Str="Delete From xsmxb where djbh="+ID+" and ID="+del;
			dbc.executeUpdate(Str);

			Str="Update kcb set Num="+num+" where wpbh="+wpbh+" and ckbh="+ckid;
			dbc.executeUpdate(Str);
		}
		rs.close();
		dbc.close();

	}

}