package com.fgkj.dao.impl;

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

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.Devstate_usr;

public class Devstate_usrImpl implements BaseDAO,CallBack{

	public List getResults(ResultSet rs) {
		List list=new ArrayList();
		try {
			while(rs.next()){
				Devstate_usr dev_usr=new Devstate_usr();
				dev_usr.setNum(rs.getInt("num"));
				dev_usr.setUid(rs.getInt("uid"));
				dev_usr.setDev_id(rs.getInt("dev_id"));
				dev_usr.setBattgroupid(rs.getInt("battgroupid"));
				dev_usr.setBatt_index(rs.getInt("batt_index"));
				dev_usr.setStationname(rs.getString("stationname"));
				dev_usr.setBattgroupname(rs.getString("battgroupname"));
				dev_usr.setNote(rs.getString("note"));
				list.add(dev_usr);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}
   //添加
	public boolean add(Object obj) {
		Devstate_usr dev_usr=(Devstate_usr) obj;
		String sql="insert into web_site.tb_devstate_usr(uid,dev_id,battgroupid,batt_index,stationname,battgroupname) values(?,?,?,?,?,?)";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dev_usr.getUid(),dev_usr.getDev_id(),dev_usr.getBattgroupid(),dev_usr.getBatt_index(),dev_usr.getStationname(),dev_usr.getBattgroupname()});
		return bl;
	}
    //修改
	public boolean update(Object obj) {
		Devstate_usr dev_usr=(Devstate_usr) obj;
		String sql="update web_site.tb_devstate_usr set battgroupid=?,batt_index=?,battgroupname=?  where uid=? and  dev_id=? ";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dev_usr.getBattgroupid(),dev_usr.getBatt_index(),dev_usr.getBattgroupname(),dev_usr.getUid(),dev_usr.getDev_id()});
		return bl;
	}
   //删除
	public boolean del(Object obj) {
		Devstate_usr dev_usr=(Devstate_usr) obj;
		String sql="delete from web_site.tb_devstate_usr where uid=? and dev_id=? and battgroupid=?";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dev_usr.getUid(),dev_usr.getDev_id(),dev_usr.getBattgroupid()});
		return bl;
	}

	public List searchAll() {
		// TODO Auto-generated method stub
		return null;
	}
    //根据用户id查询
	public List serchByCondition(Object obj) {
		Devstate_usr dev_usr=(Devstate_usr) obj;
		String sql="   select distinct battgroupid,uid,dev_id,batt_index,stationname,battgroupname from web_site.tb_devstate_usr " +
				   "   where uid=? " +
				   "   and dev_id in(select distinct FBSDeviceId from db_battinf.tb_battinf)" +
				   "   order by num";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dev_usr.getUid()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Devstate_usr dev_usr=new Devstate_usr();
						dev_usr.setUid(rs.getInt("uid"));
						dev_usr.setDev_id(rs.getInt("dev_id"));
						dev_usr.setBattgroupid(rs.getInt("battgroupid"));
						dev_usr.setBatt_index(rs.getInt("batt_index"));
						dev_usr.setStationname(rs.getString("stationname"));
						dev_usr.setBattgroupname(rs.getString("battgroupname"));
						list.add(dev_usr);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	public List serchByInfo(Object obj) {
		// TODO Auto-generated method stub
		return null;
	}
    public static void main(String[] args) {
	  Devstate_usrImpl dimpl=new Devstate_usrImpl();
	  Devstate_usr dev_usr=new Devstate_usr();
	  dev_usr.setUid(1001);
	  List list=dimpl.serchByCondition(dev_usr);
	  System.out.println(list.size());
}
}