pdb.java

web版的进销存系统

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

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

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

public class Pdb{
	private int ID;
	private String djbh;
	private int ckbh;
	private Date Tdate;
	private int ygbh;
	private String tdr;
	private String tpr;
	private String tply;
	private String bz;
	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 String getTply() {
		return tply;
	}
	public void setTply(String tply) {
		this.tply = tply;
	}
	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 int getCkbh() {
		return ckbh;
	}
	public void setCkbh(int ckbh) {
		this.ckbh = ckbh;
	}
	public Date getTdate() {
		return Tdate;
	}
	public void setTdate(Date tdate) {
		Tdate = tdate;
	}
	public int getYgbh() {
		return ygbh;
	}
	public void setYgbh(int ygbh) {
		this.ygbh = ygbh;
	}
	public String getTdr() {
		return tdr;
	}
	public void setTdr(String tdr) {
		this.tdr = tdr;
	}
	public String getTpr() {
		return tpr;
	}
	public void setTpr(String tpr) {
		this.tpr = tpr;
	}
	public String getBz() {
		return bz;
	}
	public void setBz(String bz) {
		this.bz = bz;
	}
	public void setError(boolean isError) {
		this.isError = isError;
	}
	public void setStrError(String strError) {
		StrError = strError;
	}
	public boolean excute() throws Exception {
		String Str="Select * From ckpd 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"); 
				ygbh=rs.getInt("ygbh");
				tdr=rs.getString("tdr");
				ckbh=rs.getInt("ckbh");
				Tdate=rs.getDate("Tdate");  
				bz=rs.getString("bz"); 
			}
			rs.close();
			dbc.close();
			return true;
		}
		catch (SQLException sqle){
			return false;
		}
	} 

	public void Add(HttpServletRequest request,HttpSession session) throws Exception {//添加盘点单
		djbh=StrFun.getString(request,"djbh"); 
		ygbh=StrFun.getInt(request,"ygbh");
		tdr=String.valueOf(session.getAttribute("usname"));
		ckbh=StrFun.getInt(request,"ckbh"); 
		bz=StrFun.getString(request,"bz"); 

		String Str="Select * From ckpd where djbh='"+djbh+"'";
		DBConnect dbc  = new DBConnect();
		ResultSet rs=dbc.executeQuery(Str);
		if (rs.next()){
			isError=true;
			StrError=StrError+"此编号已经存在!<br>";      
		}
		else{ 
			Str="Insert into ckpd (Tdate,djbh,ygbh,tdr,ckbh,bz) values (now(),'"+djbh+"','"+ygbh+"','"+tdr+"','"+ckbh+"','"+bz+"') ";
		dbc.executeUpdate(Str);
		}
		rs.close();
		dbc.close();
	}
	
	public void Addly(HttpServletRequest request,HttpSession session) throws Exception {//添加盘点单
		tply=StrFun.getString(request,"tply");
		djbh=StrFun.getString(request,"id");
		tpr=String.valueOf(session.getAttribute("usname"));

		String Str="update ckpd set tpr='"+tpr+"',tply='"+tply+"' where id="+djbh;
		DBConnect dbc  = new DBConnect();			
		dbc.executeUpdate(Str);
		dbc.close();
	}

	public void Del(HttpServletRequest request) throws Exception {
		ID=StrFun.getInt(request,"id"); 
		String Str="Select * From ckpdmxb where djbh="+ID;
		DBConnect dbc  = new DBConnect();
		ResultSet rs=dbc.executeQuery(Str);
		if (rs.next()){
			isError=true;
			StrError=StrError+"需先将明细表中数据删除后方可进行该项操作！ <br>";	  	
		}
		else{    
			Str="Delete From ckpd where Id="+ID;
			dbc.executeUpdate(Str);}
		dbc.close();

	}
}