qydbmxb.java

web版的进销存系统

package jxc.web;
import jxc.com.DBConnect;
import jxc.util.StrFun;
import java.lang.String;
import java.sql.*;
import javax.servlet.http.*;

public class Qydbmxb {
	private int ID;
	private int djbh;
	private int wpbh;
	private int num;
	private float dj;
	private float je;
	private boolean isError=false;
	private String StrError="";

	public int getID() {
		return ID;}
	public void setID (int newID) {
		this.ID=newID;}
	public void setID(String anew) {
		if (anew!=null)
			this.ID=Integer.parseInt(anew);
	}
	public int getdjbh() {
		return djbh;}
	public void setdjbh (int newdjbh) {
		this.djbh=newdjbh;}
	public int getwpbh() {
		return wpbh;}
	public void setwpbh (int newwpbh) {
		this.wpbh=newwpbh;}
	public int getnum() {
		return num;}
	public void setnum (int newnum) {
		this.num=newnum;}
	public float getdj() {
		return dj;}
	public void setdj (float newdj) {
		this.dj=newdj;}
	public float getje() {
		return je;}
	public void setje (float newje) {
		this.je=newje;}
	public boolean getIsError(){
		return this.isError;
	}
	public String getStrError(){
		return this.StrError;
	}

	public boolean excute() throws Exception {
		String Str="Select * From qydbmxb 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 Del(HttpServletRequest request) throws Exception {
		ID=StrFun.getInt(request,"del"); 
		int ckid=StrFun.getInt(request,"ckid"); 
		int ckid2=StrFun.getInt(request,"ckid2"); 
		DBConnect dbc  = new DBConnect();
		String Str="Select *  From qydbmxb where id="+ID;
		ResultSet rs=dbc.executeQuery(Str);
		int x=0;
		if (rs.next()){
			x=rs.getInt("num");
			wpbh=rs.getInt("wpbh");
			Str="Select * From wpkcb where wpbh="+wpbh+" and ckbh="+ckid2;
			rs=dbc.executeQuery(Str);	
			if (rs.next()){  
				num=rs.getInt("num");
				int z=num-x;
				if (z<0) {
					isError=true;
					StrError=StrError+"shu liang bu gou!!！ <br>";	  	
				}
			}  	  
		} 

		if (!isError){    	
			Str="Delete From qydbmxb where ID="+ID;
			dbc.executeUpdate(Str);

			Str="Update wpkcb set Num=Num+"+x+" where wpbh="+wpbh+" and ckbh="+ckid;
			dbc.executeUpdate(Str);
			Str="Update wpkcb set Num=Num-"+x+" where wpbh="+wpbh+" and ckbh="+ckid2;
			dbc.executeUpdate(Str);
		}

		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");
		je=StrFun.getFloat(request,"je");
		if (num<=0){
			isError=true;
			StrError=StrError+"shu liang cuo wu!!!   <br>";
		} 
		String ckid=request.getParameter("ckid");
		String ckid2=request.getParameter("ckid2");

		String Str="Select * From wpkcb where wpbh="+wpbh+" and ckbh="+ckid;
		DBConnect dbc  = new DBConnect();
		ResultSet rs=dbc.executeQuery(Str);
		int x=0;
		int y=0;
		if (rs.next()){
			x=rs.getInt("Num");
			Str="Select Sum(num)  From qydbmxb where id="+ID;
			rs=dbc.executeQuery(Str);
			if (rs.next()){
				y=rs.getInt(1);	
				int z= x+y-num; 
				if (z<0) {
					isError=true;
					StrError=StrError+"shu liang da yu ku cun shu liang!!！  <br>";	  	
				}	
			}  
		} 
		je=dj*num;   
		if (!isError) {	
			Str="Update qydbmxb set djbh="+djbh+",wpbh="+wpbh+",num="+num+",dj="+dj+",je="+je+" where id="+ID;
			dbc.executeUpdate(Str);
			num=y-num;
			Str="Update wpkcb set Num=Num+"+num+" where wpbh="+wpbh+" and ckbh="+ckid;
			dbc.executeUpdate(Str);    
			Str="Update wpkcb set Num=Num-"+num+" where wpbh="+wpbh+" and ckbh="+ckid2;
			dbc.executeUpdate(Str);    
		}
		// rs.close();  
		dbc.close();
	}

	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");
		je=dj*num; 

		if (num<=0){
			isError=true;
			StrError=StrError+"shu liang cuo wu!!!  <br>";
		}

		String ckid=request.getParameter("ckid");
		String ckid2=request.getParameter("ckid2");

		String Str="Select * From wpkcb where wpbh="+wpbh+" and ckbh="+ckid;
		DBConnect dbc  = new DBConnect();
		ResultSet rs=dbc.executeQuery(Str);
		if (rs.next()){
			int x=rs.getInt("Num");
			if (num>x) {
				isError=true;
				StrError=StrError+"shu liang da yu ku cun shu liang!!！  <br>";	  	
			}	
		}else{
			isError=true;
			StrError=StrError+"ku mei you shang pin!!！  <br>";		
		}	

		if (!isError) {
			Str="insert into qydbmxb (djbh,wpbh,num,dj,je) values("+djbh+","+wpbh+","+num+","+dj+","+je+")";
			dbc.executeUpdate(Str);//更新STR字符串

			Str="Update wpkcb set Num=Num-"+num+" where wpbh="+wpbh+" and ckbh="+ckid;
			dbc.executeUpdate(Str);

			Str="Select * From wpkcb where wpbh="+wpbh+" and ckbh="+ckid2;
			rs=dbc.executeQuery(Str);
			if (rs.next()){
				Str="Update wpkcb set Num=Num+"+num+" where wpbh="+wpbh+" and ckbh="+ckid2;
				dbc.executeUpdate(Str);}
			else
			{
				Str="insert into wpkcb (ckbh,wpbh,num,maxnum) values("+ckid2+","+wpbh+","+num+",0)";
				dbc.executeUpdate(Str);
			} 

		}
		dbc.close();  
	}
}