package com.fgkj.dao.impl;

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

import com.fgkj.actions.ActionUtil;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.User_inf;

public class User_infImpl implements BaseDAO, CallBack {

	@Override
	public List getResults(ResultSet rs) {
		// TODO Auto-generated method stub
		return null;
	}
    //添加用户
	@Override
	public boolean add(Object obj) {
		User_inf uinf=(User_inf) obj;
		String sql=" insert into db_equip_user.tb_user_inf(USnId,UName,Upassword) values(?,?,?) ";
		boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),uinf.getUName(),ActionUtil.EncryptionBase64(uinf.getUSnId())});
		return bl;
	}
    //修改用户密码
	@Override
	public boolean update(Object obj) {
		User_inf uinf=(User_inf) obj;
		String sql=" update  db_equip_user.tb_user_inf set USnId=?,Upassword=? where uid=? ";
		boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),ActionUtil.EncryptionBase64(uinf.getUSnId()),uinf.getUId()});
		return bl;
	}
    //删除用户
	@Override
	public boolean del(Object obj) {
		User_inf uinf=(User_inf) obj;
		String sql="delete from  db_equip_user.tb_user_inf  where uid=? ";
		boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUId()});
		return bl;
	}
    //查询所有的用户(不含密码)
	@Override
	public List searchAll() {
		String sql=" select distinct uid,UName from db_equip_user.tb_user_inf ";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			@Override
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						User_inf uinf=new User_inf();
						uinf.setUId(rs.getInt("uId"));
						uinf.setUName(rs.getString("uName"));
						list.add(uinf);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}
    //根据输入的用户名查询存在数据库中的用户名和加密密码
	@Override
	public List serchByCondition(Object obj) {
		User_inf uinf=(User_inf) obj;
		String sql = "select uid,uname,upassword,unote from db_equip_user.tb_user_inf where uname=?";
		List list = DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUName()},
						new CallBack() {
							
							public List getResults(ResultSet rs) {
								List list=new ArrayList();
								try {
									while(rs.next()){
										User_inf uinf=new User_inf();
										uinf.setUId(rs.getInt("uId"));
										uinf.setUName(rs.getString("uName"));
										uinf.setUNote(rs.getString("uNote"));
										uinf.setUpassword(rs.getString("upassword"));
										list.add(uinf);
									}
								} catch (SQLException e) {
									e.printStackTrace();
								}															
								return list;
							}
						});
		return list;
	}

	@Override
	public List serchByInfo(Object obj) {
		// TODO Auto-generated method stub
		return null;
	}

	
	
}