outdatadaoimpl.java~19~

基本功能都实现了,对财务的增加,删除财务的信息,修改信息,查出财务的详细信息

package com.cn.cms.dao.impl;

import com.cn.cms.dao.OutdataDao;
import com.cn.cms.javabean.CheckdataBean;
import com.cn.cms.javabean.WpBean;
import com.cn.cms.util.DBConnection;
import java.sql.PreparedStatement;
import java.sql.Statement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.sql.SQLException;

public class OutdataDaoImpl
    implements OutdataDao {
  private PreparedStatement pstmt = null;
  private Statement stmt = null;
  private ResultSet rst = null;
  private DBConnection connect = null;
  private WpBean wbpbean = null;
  private List wplist = new ArrayList();
  public OutdataDaoImpl() {
    connect = new DBConnection();
  }

  public boolean insertBeandao(CheckdataBean checkdatabean) {
    try {
      String sql = "insert into sale_temp values(?,?,?,?,?,?,?,?,?)";
      pstmt = connect.getDBConnection().prepareStatement(sql);
      int iLoop = 1;
      int addId = findBymaxId();
      pstmt.setInt(iLoop++, ++addId);
      pstmt.setString(iLoop++, checkdatabean.getMMan());
      pstmt.setString(iLoop++, checkdatabean.getMAddr());
      pstmt.setString(iLoop++, checkdatabean.getMTel());
      pstmt.setInt(iLoop++, checkdatabean.getMKind().intValue());
      pstmt.setInt(iLoop++, checkdatabean.getMCount().intValue());
      pstmt.setString(iLoop++, checkdatabean.getMOperator());
      pstmt.setString(iLoop++, checkdatabean.getMEmp());
      pstmt.setString(iLoop++, checkdatabean.getMDate());
      int Result = 0;
      Result = pstmt.executeUpdate();
      if (Result != 0) {
        return true;
      }
      else {
        return false;
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
      return false;
    }
    finally {
      if (connect != null) {
        connect.closeStatement(pstmt);
      }
      if (connect != null) {
        connect.closeConnection();
      }
    }

  }

  /**
   * 查找最大的记录值
   */
  private int findBymaxId() {
    int recid = 0;
    try {
      String sql = "select IsNull(max(mId),0) from sale_temp";
      stmt = connect.getDBConnection().createStatement();
      rst = stmt.executeQuery(sql);
      if (rst.next()) {
        recid = rst.getInt(1);
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    finally {
      if (stmt != null) {
        connect.closeStatement(stmt);
      }
      if (rst != null) {
        connect.closeResultSet(rst);
      }
      connect.closeConnection();
    }
    return recid;
  }

  public List findByParameter(String mkind, String storeId) {
    try {
      String sql = " select m.mid , m.mName, t.mName , n.sName from wpdata m ,mData t, Store n where";
      sql += " m.mKind = t.mId and m.mSoreName = n.sId and m.mKind=" +
          new Integer(mkind).intValue();
      sql += " and m.mSoreName=" + new Integer(storeId).intValue();
      stmt = connect.getDBConnection().createStatement();
      rst = stmt.executeQuery(sql);
      while (rst.next()) {
        wbpbean = new WpBean();
        wbpbean.setMId(rst.getInt("mId"));
        wbpbean.setMName(rst.getString("mName"));
        wbpbean.setMKind(rst.getInt("mKind"));
        wbpbean.setMCount(rst.getInt("mCount"));
        wbpbean.setMSoreName(rst.getInt("mSoreName"));
        wplist.add(wbpbean);
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    return wplist;
  }

  public List findByParameter(String mkind) {
    try {
      String sql = " select m.mid , m.mName, t.mName , m.mCount, n.sName from wpdata m ,mData t, Store n where";
      sql += " m.mKind = t.mId and m.mSoreName = n.sId and m.mKind=" +
          new Integer(mkind).intValue();
      stmt = connect.getDBConnection().createStatement();
      rst = stmt.executeQuery(sql);
      while (rst.next()) {
        wbpbean = new WpBean();
        wbpbean.setMId(rst.getInt("m.mid"));
        wbpbean.setMName(rst.getString("m.mName"));
        wbpbean.setMKindName(rst.getString("t.mName"));
        wbpbean.setMCount(rst.getInt("m.mCount"));
        wbpbean.setMSoreNames(rst.getString("n.sName"));

        wplist.add(wbpbean);
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    return wplist;
  }

  public List findByParameter2(String storeId) {
    try {
      String sql = " select m.mid , m.mName, t.mName , n.sName from wpdata m ,mData t, Store n where";
      sql += " m.mKind = t.mId and m.mSoreName = n.sId and m.mSoreName=" +
          new Integer(storeId).intValue();
      stmt = connect.getDBConnection().createStatement();
      rst = stmt.executeQuery(sql);
      while (rst.next()) {
        wbpbean = new WpBean();
        wbpbean.setMId(rst.getInt("mId"));
        wbpbean.setMName(rst.getString("mName"));
        wbpbean.setMKind(rst.getInt("mKind"));
        wbpbean.setMCount(rst.getInt("mCount"));
        wbpbean.setMSoreName(rst.getInt("mSoreName"));
        wplist.add(wbpbean);
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    return wplist;
  }

  public boolean savewpbean(WpBean wpbean) {
    try {
      String sql = "insert into wpdata values(?,?,?,?,?)";
      pstmt = connect.getDBConnection().prepareStatement(sql);
      int iLoop = 1;
      pstmt.setInt(iLoop++, wpbean.getMId());
      pstmt.setString(iLoop++, wpbean.getMName());
      pstmt.setInt(iLoop++, wpbean.getMKind());
      pstmt.setInt(iLoop++, wpbean.getMCount());
      pstmt.setInt(iLoop++, wpbean.getMSoreName());
      int Result = 0;
      Result = pstmt.executeUpdate();
      if (Result != 0) {
        return true;
      }
      else {
        return false;
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
      return false;
    }
  }

  public boolean deletewpbean(WpBean wpbean) {
    try { //update wpdata set mCount =1015  where mId='1002'
      String sql = "update wpdata set mCount =mCount-" + wpbean.getMCount() +
          " where mId='" + wpbean.getMId() + "'";
      stmt = connect.getDBConnection().createStatement();
      int result = 0;
      result = stmt.executeUpdate(sql);
      if (result != 0) {
        return true;
      }
      else {
        return false;
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    return false;
  }
}