cgmxb.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 Cgmxb{
  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 cgmxb 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"); 


    if (num<=0){
   	  isError=true;
   	  StrError=new String(StrError.getBytes("Iso-8859-1"),"GBK") ;
   	  StrError=StrError+"数据错误!!!  <br>";
      } 
    if (wpbh<=0){
   	  isError=true;
   	  StrError=StrError+"商品错误!!! <br>";
      } 
   if (!isError){      
      je=dj*num; 
      String ckid=request.getParameter("ckid");
	  String Str="Insert into cgmxb(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())
	  Str="Update kcb set Num=Num+"+num+"  where wpbh="+wpbh+" and ckbh="+ckid;
	  else 
	  Str="insert into kcb (ckbh,wpbh,num) values("+ckid+","+wpbh+","+num+")";	
	  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"); 

	    if (num<=0){
	   	  isError=true;
	   	  StrError=StrError+"数量错误!!!  <br>";
	   } 
		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);
		int x=0;
		int y=0;
		if (rs.next()){
		  x=rs.getInt("Num");
		 
		  Str="Select Sum(num)  From cgmxb 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+"库存数据量不够！ <br>";
			    }	
			  }  
			
		  }
		je=dj*num;   
	   if (!isError) {	
	     Str="Update cgmxb set djbh="+djbh+",num="+num+",dj="+dj+",je="+je+"  where id="+ID;
	     dbc.executeUpdate(Str);
	     num=x-y+num;
	        
	     Str="Update kcb set Num="+num+"  where wpbh="+wpbh+" and ckbh="+ckid;
		 dbc.executeUpdate(Str);    
	   } 
	   dbc.close();
	   
	    }
  public void Del(HttpServletRequest request) throws Exception {
	     ID=StrFun.getInt(request,"del");
	    int ckid=StrFun.getInt(request,"ckid"); 
	  	DBConnect dbc  = new DBConnect();
	  	String Str="Select *  From cgmxb 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 kcb where wpbh="+wpbh+" and ckbh="+ckid;
		  rs=dbc.executeQuery(Str);	
		  if (rs.next()){  
		    num=rs.getInt("num");
		    num=num-x;
		    if (num<0) {
	   	      isError=true;
	   	      StrError=StrError+"库存中的数量不够！ <br>";	  	
		       }
		     }  	  
		   } 		 
		if (!isError){
	      Str="Delete From cgmxb  where id="+ID;
	      dbc.executeUpdate(Str);
	    
	      Str="Select * From kcb where wpbh="+wpbh+" and ckbh="+ckid;
		  rs=dbc.executeQuery(Str);	
		  if (rs.next()){  
		    num=rs.getInt("num");
		    num=num-x;
		    if (num==0) {
		     Str="Delete From kcb where wpbh="+wpbh+" and  ckbh="+ckid;
		     dbc.executeUpdate(Str);
		                }
		    else{
		      Str="Update kcb set Num="+num+"  where wpbh="+wpbh+" and ckbh="+ckid;
		      dbc.executeUpdate(Str);
			    }
		  }
		}
		
		dbc.close();  

  } 
 }