pdmxb.java

web版的进销存系统

package jxc.web;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.servlet.http.HttpServletRequest;

import jxc.com.DBConnect;
import jxc.util.StrFun;

public class Pdmxb{
	private int ID;
	private String djbh;
	private String wpbh;
	private int yNum;
	private int xNum;
	private int ckbh;
	private boolean isError=false;
	private String StrError="";
	private String tply;
	
	public String getTply() {
		return tply;
	}
	public void setTpyy(String tply) {
		this.tply = tply;
	}
	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 boolean getIsError(){
		return this.isError;
	}
	public String getStrError(){
		return this.StrError;
	}
	public String  getDjbh() {
		return djbh;
	}
	public void setDjbh(String anew) {
		this.djbh=anew;
	}
	public void setError(boolean isError) {
		this.isError = isError;
	}
	public void setStrError(String strError) {
		StrError = strError;
	}
	public String getWpbh() {
		return wpbh;
	}
	public void setWpbh(String wpbh) {
		this.wpbh = wpbh;
	}
	public int getYNum() {
		return yNum;
	}
	public void setYNum(int num) {
		yNum = num;
	}
	public int getXNum() {
		return xNum;
	}
	public void setXNum(int num) {
		xNum = num;
	}	
	public int getCkbh() {
		return ckbh;
	}
	public void setCkbh(int ckbh) {
		this.ckbh = ckbh;
	}

	public boolean excute() throws Exception {
		String Str="Select * From ckpdmxb 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.getString("djbh");
				wpbh=rs.getString("wpbh");
				yNum=rs.getInt("yNum");
				xNum=rs.getInt("xNum");
				tply=rs.getString("tply");
			}
			rs.close();
			dbc.close();
			return true;
		}
		catch (SQLException sqle){
			return false;
		}
	} 

	public void Edit(HttpServletRequest request) throws Exception {
		ID=StrFun.getInt(request,"id");//得到明细表记录的ID???为什么是ID不是EDIT，奇怪阿 
		djbh=StrFun.getString(request,"djbh");
		wpbh=StrFun.getString(request,"wpbh");
		yNum=StrFun.getInt(request,"yNum");
		xNum=StrFun.getInt(request,"xNum");

		String Str="Update ckpdmxb set xNum="+xNum+" where id="+ID;
		DBConnect dbc  = new DBConnect();
		dbc.executeUpdate(Str);
		dbc.close();
	}

	public void Add(HttpServletRequest request) throws Exception {//添加盘点单
		djbh=StrFun.getString(request,"djbh");
		wpbh=StrFun.getString(request,"wpbh");
		yNum=StrFun.getInt(request,"yNum");
		xNum=StrFun.getInt(request,"xNum");		
//		int pdNum = xNum-yNum;//盈亏数额

		DBConnect dbc  = new DBConnect();
		String Str ="select * from ckpdmxb where djbh="+djbh+" and wpbh="+wpbh;
		ResultSet rs = dbc.executeQuery(Str);
		if (rs.next()){
			isError=true;
			StrError="item.exist";
		}
		else{		
			Str="Insert into ckpdmxb (djbh,wpbh,yNum,xNum) values ('"+djbh+"','"+wpbh+"','"+yNum+"','"+xNum+"') ";
			dbc.executeUpdate(Str);
		}
		dbc.close();
	}

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

		String Str="Delete From ckpdmxb where djbh="+ID+" and ID="+del;
		DBConnect dbc  = new DBConnect();
		dbc.executeUpdate(Str);
		dbc.close();
	}

	public void Equal(HttpServletRequest request) throws Exception {
		ID=StrFun.getInt(request,"id");
		tply=StrFun.getString(request,"tply");
		
		int equal=StrFun.getInt(request,"equal");
		int xNum=0;
		int wpid=0;
		String ckid=request.getParameter("ckid");

		String Str="select * From ckpdmxb where djbh="+ID+" and ID="+equal;
		DBConnect dbc  = new DBConnect();
		ResultSet rs = dbc.executeQuery(Str);
		if (rs.next()){
			xNum=rs.getInt("xNum");
			wpid=rs.getInt("wpbh");
		}
		Str="update ckpdmxb set tpok=1 where djbh="+ID+" and ID="+equal;
		dbc.executeUpdate(Str);
		
		DBConnect dbc1  = new DBConnect();
		Str="select * From ckpdmxb where djbh="+ID+" and tpok=0";
		ResultSet rs1 = dbc.executeQuery(Str);
		if (!rs1.next()){
			Str="update ckpd set tpok=1 where id="+ID;
			dbc1.executeUpdate(Str);
		}
		Str="update kcb set num="+xNum+" where ckbh="+ckid+" and wpbh="+wpid;
		dbc.executeUpdate(Str);		
		rs.close();
		dbc.close();
	}

}