vipconsumedaoimpl.java

一个优秀的干洗店管理系统

package dao.vipconsumedao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Vector;

import javax.swing.JOptionPane;

import common.LogWriter;

import vo.VipChargeVo;
import vo.VipConsumeVo;
import dao.common.DBConnectionManager;
import dao.common.DbException;
import dao.common.sql.DbSql;
import dao.vipconsumedao.VipConsumeDao;

public class VipConsumeDaoImpl implements VipConsumeDao {
	private DBConnectionManager manager = DBConnectionManager.getInstance();
	private LogWriter log;
	/**
	 * @param log
	 */
	public VipConsumeDaoImpl(LogWriter log) {
		super();
		this.log = log;
	}

	public Vector findVipConsume(String fromDate, String toDate, String vipName)
			throws DbException {
		Vector v = null;
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet set = null;
		try {
			con = manager.getConnection("oracle");			
			if (vipName.equals("")) {
				pstmt = con.prepareStatement(DbSql.VIP_CONSUME_RECORDER);
				pstmt.setString(1, fromDate);
				pstmt.setString(2, toDate);
			} else {
				pstmt = con.prepareStatement(DbSql.VIP_CONSUME_RECORDER
						+ DbSql.WITH_NAME);
				pstmt.setString(1, fromDate);
				pstmt.setString(2, toDate);
				pstmt.setString(3, vipName);
			}
			set = pstmt.executeQuery();
			v = new Vector();
			while (set.next()) {
				long orderId = set.getLong("order_id");
				int vipId = set.getInt("vip_id");
				String consumeDate = set.getString("consume_date").substring(0,10);
				int neededAmount = set.getInt("needed_amount");
				int receiveAmount = set.getInt("received_amount");
				int reducedAmount = set.getInt("reduced_amount");
				v.addElement(new VipConsumeVo(orderId, vipId, consumeDate,
						neededAmount, receiveAmount, reducedAmount));
			}
			log.log("会员信息查找成功", LogWriter.INFO);
			if (v.size() == 0) {			
				JOptionPane.showMessageDialog(null,
						"数据库中没有从"+fromDate+ "到"+toDate+vipName+"的消费记录");
			}
		} catch (SQLException e) {
			log.log("会员信息查找失败", LogWriter.ERROR);
			JOptionPane.showMessageDialog(null,
					e.getMessage(),"提示",JOptionPane.YES_OPTION);			
		}finally{
			manager.freeConnection("oracle", con);
		}
		return v;
	}

	public Vector findVipCharge(String fromDate, String toDate, String vipName)
			throws DbException {
		Vector v = null;
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet set = null;
		try {
			con = manager.getConnection("oracle");
			if (vipName.equals("")) {
				pstmt = con.prepareStatement(DbSql.GET_VIPCHARGE_RECORDER);
				pstmt.setString(1, fromDate);
				pstmt.setString(2, toDate);
			} else {
				pstmt = con.prepareStatement(DbSql.GET_VIPCHARGE_RECORDER
						+ DbSql.WITH_NAME);
				pstmt.setString(1, fromDate);
				pstmt.setString(2, toDate);
				pstmt.setString(3, vipName);
			}
			set = pstmt.executeQuery();
//			System.out.println("run here......1");
			v = new Vector();
			while (set.next()) {
//				System.out.println("run here......");
				int vipId = set.getInt("vip_id");
				String chargeDate = set.getString("charge_date").substring(0,10);
				int chargeAmount = set.getInt("charge_amount");
				int receiveAmount = set.getInt("receive_amount");
				String operaterName = set.getString("operator_name");
				v.addElement(new VipChargeVo(vipId, chargeDate, receiveAmount,
						chargeAmount, operaterName));
			}
			
			if (v.size() == 0) {
				//throw new DbException("数据库中不存在符合条件的记录");
				JOptionPane.showMessageDialog(null,
						"数据库中没有从"+fromDate+ "到"+toDate+vipName+"的记录");
			}
			log.log("会员充值信息查找成功", LogWriter.INFO);
		} catch (SQLException e) {
			log.log("会员充值信息查找失败", LogWriter.ERROR);
			JOptionPane.showMessageDialog(null,
					e.getMessage(),"提示",JOptionPane.YES_OPTION);
			//System.out.println("会员充值记录查找dao异常:= " + e.getMessage());
		}finally{
			manager.freeConnection("oracle", con);
		}
		return v;
	}

}