package JXC.web;
import JXC.Com.DBConnect;
import JXC.util.StrFun;
import java.lang.String;
import java.sql.*;
import javax.servlet.*;
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+"庫存中的數量不夠！ <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+"數量輸入錯誤  <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+"輸入的數量大于庫存的數量！  <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+"數量輸入錯誤  <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+"輸入的數量大于庫存的數量！  <br>";	  	
	  	}	
	}else{
   	    isError=true;
   	    StrError=StrError+"庫存中沒有此物品！  <br>";		
	}	
 
    if (!isError) {
     Str="insert into qydbmxb (djbh,wpbh,num,dj,je) values("+djbh+","+wpbh+","+num+","+dj+","+je+")";
     dbc.executeUpdate(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();  
    }
   }