package org.itstar.netbar.dao.impl;

import org.itstar.netbar.utils.ConnectDB;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.itstar.netbar.bean.CustomerBean;
import org.itstar.netbar.dao.ICustomerDao;

public class CustomerDaoImpl implements ICustomerDao
{
	public int delete(String cusCardNum) 
	{
		String strSQL="delete from customer where cusCardNum='"+cusCardNum+"'";
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return count;
	}

	public int insert(CustomerBean cBean) 
	{
		String strSQL="insert into customer values('"+cBean.getCusCardNum()+"','" 
		                                             +cBean.getCusCardPassword()+"','"
		                                             +cBean.getCusBalance()+"','"
		                                             +cBean.getCusName()+"','"
		                                             +cBean.getCusPersonID()+"','"
		                                             +cBean.getCusRegDate()+"','0','"
		                                             +cBean.getCusLastLoginTime()+"')";
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return count;
	}

	public List query(Map map) 
	{
		String strSQL="select * from customer where 1=1";
		if(map!=null)
		{
			if(map.get("cusCardNum")!=null)
				strSQL=strSQL+" and cusCardNum='"+map.get("cusCardNum")+"'";
			if(map.get("cusCardPassword")!=null)
				strSQL=strSQL+" and cusCardPassword='"+map.get("cusCardPassword")+"'";
			if(map.get("cusBalance")!=null)
				strSQL=strSQL+" and cusBalance='"+map.get("cusBalance")+"'";
			if(map.get("cusName")!=null)
				strSQL=strSQL+" and cusName='"+map.get("cusName");
			if(map.get("cusPersonID")!=null)
				strSQL=strSQL+" and cusPersonID='"+map.get("cusPersonID")+"'";
			if(map.get("cusRegDate")!=null)
				strSQL=strSQL+" and cusRegDate='"+map.get("cusRegDate")+"'";
			if(map.get("cusCardState")!=null)
				strSQL=strSQL+" and cusCardState='"+map.get("cusCardState")+"'";
			if(map.get("cusLastLoginTime")!=null)
				strSQL=strSQL+" and cusLastLoginTime='"+map.get("cusLastLoginTime")+"'";
		}
		
		List list=new ArrayList();
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			ResultSet rs=stmt.executeQuery(strSQL);
			while(rs.next())
			{
				CustomerBean cBean=new CustomerBean();
				cBean.setCusCardNum(rs.getString(1));
				cBean.setCusCardPassword(rs.getString(2));
				cBean.setCusBalance(rs.getString(3));
				cBean.setCusName(rs.getString(4));
				cBean.setCusPersonID(rs.getString(5));
				cBean.setCusRegDate(rs.getString(6));
				cBean.setCusCardState(rs.getString(7));
				cBean.setCusLastLoginTime(rs.getString(8));
				list.add(cBean);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return list;
	}

	public List queryAll() 
	{
		String strSQL="select * from customer where 1=1";
		List list=new ArrayList();
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			ResultSet rs=stmt.executeQuery(strSQL);
			while(rs.next())
			{
				CustomerBean cBean=new CustomerBean();
				cBean.setCusCardNum(rs.getString(1));
				cBean.setCusCardPassword(rs.getString(2));
				cBean.setCusBalance(rs.getString(3));
				cBean.setCusName(rs.getString(4));
				cBean.setCusPersonID(rs.getString(5));
				cBean.setCusRegDate(rs.getString(6));
				cBean.setCusCardState(rs.getString(7));
				cBean.setCusLastLoginTime(rs.getString(8));
				list.add(cBean);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return list;
	}

	public int update(CustomerBean cBean) 
	{
		String strSQL="update customer set cusCardPassword='"+cBean.getCusCardPassword()+"',"
		                                      +"cusBalance='"+cBean.getCusBalance()+"',"
		                                      +"cusName='"+cBean.getCusName()+"',"
		                                      +"cusPersonID='"+cBean.getCusPersonID()+"',"
		                                      +"cusRegDate='"+cBean.getCusRegDate()+"',"
		                                      +"cusLastLoginTime='"+cBean.getCusLastLoginTime()+"',"
		                                      +"cusCardState='"+cBean.getCusCardState()+"',"
		                                      +" where cusCardNum='"+cBean.getCusCardNum()+")";
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return count;
	}
	
	public int updateBalance(CustomerBean cBean) 
	{
		String strSQL="update customer set cusBalance='"+cBean.getCusBalance()+"'"
		                         +" where cusCardNum='"+cBean.getCusCardNum()+"'";
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return count;
	}

	public int updateCardState(String cusCardState, String cusCardNum) 
	{
		String strSQL="update customer set cusCardState='"+cusCardState+"'"
        						  +" where cusCardNum='"+cusCardNum+"'";
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return count;
	}

	public int updateCardStateReset() {
		String strSQL="update customer set cusCardState='0' where cusCardState='1'";
		int count=0;
		try {
		Statement stmt=ConnectDB.getConn().createStatement();
		count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
		e.printStackTrace();
		}
		
		return count;
	}

	public int updateCardLastLoginTime(String cusLastLoginTime, String cusCardNum) {
		String strSQL="update customer set cusLastLoginTime='"+cusLastLoginTime+"'"
		  +" where cusCardNum='"+cusCardNum+"'";
		int count=0;
		try {
		Statement stmt=ConnectDB.getConn().createStatement();
		count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
		e.printStackTrace();
		}
		
		return count;
	}
}