lendmodel.java

来自「一个企业小型固定资产系统的源代码。发布出来让刚学习java的人研究。」· Java 代码 · 共 296 行

package project;

/*
 *LendModel.java：建立固定资产借用与归还实体类。
 *包括：与数据库进行增、删、改、查操作。
 */

import java.sql.*;
import java.math.*;

public class LendModel {
    int pno;
    int cno=1;
    int[] no=new int[10];
    int dno=Share.useid;
   String assetid;  //资产代码
   String assetname;  //资产名称
   String model;    //规格型号
   String price;   //单位
   float emp;    //数量
   float use;   //单价

   float ret;    //金额
   String date;
   String empno;
   String usedate;
   String retdate;
   String type;
   String isreturn;    //仓库
   String lender;     //操作人
   String lenProess;   //用途
   String remarks;    //备注
   DbConn dbc;
   Connection conn;
   public LendModel() {

   }

   public LendModel(String ID) {
        assetid = ID;
   }

   public void setlend(String t,String r,float n, float p,float s,String d,String k) {
        type=t;
        lenProess=r;
         emp=n;
         use=p;
         ret=s;
         date=d;
         remarks=k;

   }
   public void setret(String s1,String s2,String s3) {
        retdate = s1;
        isreturn = s2;
        remarks = s3;
        lender = Share.operator;
   }
   public int getAssetno() {
        return pno;
   }
   public String getAssetName() {
        return assetname;
   }
   public String getEmpno() {
        return empno;
   }
   public String getUsedate() {
        return usedate;
   }
   public String getModel() {
        return model;
   }
   public String getPrice() {
        return price;
   }
   public String getRetdate() {
        return retdate;
   }
   public String getIsreturn() {
        return isreturn;
   }
   public String getLender() {
        return lender;
   }
   public String getlenProess() {
       return lenProess;
  }

   public String getRemarks() {
        return remarks;
   }
   public void insert() {
   }

   public void selno() {

      dbc = new DbConn();
      conn = dbc.getConnection();
 String  sql = "SELECT P_NO,P_Name,P_TypeSize,P_Unit  FROM  ProductInfo WHERE P_ID = '"+assetid+"'";
      try {
      Statement stmt = conn.createStatement();
      ResultSet rset = stmt.executeQuery (sql);
          boolean b = rset.next();
                 pno=rset.getInt(1);
                 assetname = rset.getString(2);
                  model = rset.getString(3);
                  price = rset.getString(4);

      rset.close();
      stmt.close();
      conn.close();
      }
      catch (java.sql.SQLException s) {
        System.out.println("selnoexception: " + s.getMessage());

      }

    }
    public void seldo() {

     dbc = new DbConn();
     conn = dbc.getConnection();
String  sql = "SELECT  ProductInfo.P_NO ,ProductInfo.P_Name ";
     sql=sql+"FROM ProductInfo INNER JOIN Depot ON ProductInfo.P_NO = Depot.D_P_NO ";
     sql=sql+"WHERE ProductInfo.P_ID= '"+assetid+"'";
     try {
     Statement stmt = conn.createStatement();
     ResultSet rset = stmt.executeQuery (sql);
         boolean b = rset.next();
                pno=rset.getInt(1);
                assetname = rset.getString(2);


     rset.close();
     stmt.close();
     conn.close();
     }
     catch (java.sql.SQLException s) {
       System.out.println("selnoexception: " + s.getMessage());

     }

   }

    public void select() {
        String sql;
        dbc = new DbConn();
        conn = dbc.getConnection();

         sql = "SELECT Depot.D_C_NO, Depot.D_P_NO, ProductInfo.P_Name, ProductInfo.P_TypeSize, ";
         sql=sql+"ProductInfo.P_Unit, Depot.D_Num, Depot.D_Price, Depot.D_Money ";
         sql=sql+"FROM ProductInfo INNER JOIN (CKInfo INNER JOIN Depot ON CKInfo.C_NO = Depot.D_C_NO) ";
         sql=sql+"ON ProductInfo.P_NO = Depot.D_P_NO ";
         sql=sql+"WHERE ProductInfo.P_ID =  '"+assetid+"'"+" AND CKInfo.C_ID='C01' ";

        try {
        Statement stmt = conn.createStatement();
        ResultSet rset = stmt.executeQuery (sql);
        boolean b = rset.next();

                   pno=rset.getInt(2);
                  assetname = rset.getString(3);
                  model = rset.getString(4);
                  price = rset.getString(5);
                  empno = rset.getString(6);
                  usedate = rset.getString(7);
                  retdate = rset.getString(8);

        rset.close();
        stmt.close();
        conn.close();
        }
        catch (java.sql.SQLException s) {
          System.out.println("selexception: " + s.getMessage());
        }
    }
    public void update() {
      dbc = new DbConn();
      conn = dbc.getConnection();

      String sql3=" INSERT INTO RecodeInfo( R_P_NO,R_U_NO,R_C_NO,R_Type,R_Process,R_Num,R_BB_Price, R_Money, R_Date ,R_Note )";
      sql3=sql3+" VALUES (?,?,?,?,?,?,?,?,?,?) ;";

      try {
      PreparedStatement pstmt =conn.prepareStatement(sql3);
      pstmt.setInt(1, pno);
       pstmt.setInt(2, dno);
      pstmt.setInt(3, 1);

      pstmt.setString(4, type);
      pstmt.setString(5, lenProess);
      pstmt.setFloat(6, emp);
      pstmt.setFloat(7, use);
       pstmt.setFloat(8, ret);
        pstmt.setString(9, date);
         pstmt.setString(10, remarks);
      pstmt.execute();
      conn.commit();
      conn.close();
      }
      catch (java.sql.SQLException s) {
        System.out.println("Upexception: " + s.getMessage());
      }
   }

   public void updatedepot() {
      dbc = new DbConn();
      conn = dbc.getConnection();
       String sql1="SELECT D_Num,D_Money FROM Depot WHERE D_P_NO =" +pno ;
       String sql2="UPDATE  Depot SET D_Num=?, D_Price=? ,D_Money=?  WHERE D_P_NO = "+pno ;
       float numtemp;
       float ptemp;
       float dtemo;
      try {
           Statement stmt1 = conn.createStatement();
           ResultSet rset1 = stmt1.executeQuery (sql1);
             boolean b = rset1.next();
             numtemp=rset1.getFloat(1)-emp;
             dtemo=rset1.getFloat(2)- ret;
             ptemp=dtemo/ numtemp*1.00f;
             System.out.print("aa");
      PreparedStatement pstmt1 =conn.prepareStatement(sql2);
      pstmt1.setFloat(1, numtemp);
      pstmt1.setFloat(2, ptemp);
      pstmt1.setFloat(3, dtemo);
   //   pstmt.setInt(4, pno);
      pstmt1.execute();
      conn.commit();
      conn.close();
      }
      catch (java.sql.SQLException s) {
        System.out.println("updexception: " + s.getMessage());
      }
   }
   public void updated() {
        dbc = new DbConn();
        conn = dbc.getConnection();
         String sql1="SELECT ProductInfo.P_NO, Depot.D_Num, Depot.D_Price, Depot.D_Money"  ;
         sql1=sql1+" FROM ProductInfo INNER JOIN Depot ON ProductInfo.P_NO = Depot.D_P_NO ";
         sql1=sql1+" WHERE  ProductInfo.P_ID ='"+assetid+"'";
         String sql2="UPDATE  Depot SET D_Num=?, D_Price=? ,D_Money=?  WHERE D_P_NO = "+pno ;
         float numtemp;
         float ptemp;
         float dtemo;
        try {
             Statement stmt1 = conn.createStatement();
             ResultSet rset1 = stmt1.executeQuery (sql1);
               boolean b = rset1.next();
               pno=rset1.getInt(1);
               numtemp=rset1.getFloat(2)+emp;
               dtemo=rset1.getFloat(4)+ret;
               ptemp=dtemo/ numtemp*1.00f;
        PreparedStatement pstmt1 =conn.prepareStatement(sql2);
        pstmt1.setFloat(1, numtemp);
        pstmt1.setFloat(2, ptemp);
        pstmt1.setFloat(3, dtemo);
        pstmt1.execute();
        conn.commit();
        conn.close();
        }
        catch (java.sql.SQLException s) {
          System.out.println("库修改失败updexception: " + s.getMessage());
        }
   }
   public void insertde() {
       dbc = new DbConn();
       conn = dbc.getConnection();
        String sql1="SELECT P_NO FROM ProductInfo WHERE P_ID =  '"+assetid+"'" ;
        String sql2="INSERT INTO  Depot (D_C_NO, D_P_NO, D_Num, D_Price ,D_Money )" ;
                    sql2=sql2+" VALUES (?,?,?,?,?)";
       try {
           Statement stmt1 = conn.createStatement();
             ResultSet rset1 = stmt1.executeQuery (sql1);
               boolean b = rset1.next();
               pno=rset1.getInt(1);

       PreparedStatement pstmt1 =conn.prepareStatement(sql2);
        pstmt1.setInt(1,1);
        pstmt1.setInt(2,pno);
       pstmt1.setFloat(3, emp);
       pstmt1.setFloat(4, use);
       pstmt1.setFloat(5, ret);
       pstmt1.execute();
       conn.commit();
       conn.close();
       }
       catch (java.sql.SQLException s) {
         System.out.println("库更新失败updexception: " + s.getMessage());
       }
  }

}