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.Eventdata_inf;

public class Eventdata_infImpl implements BaseDAO,CallBack{

	@Override
	public List getResults(ResultSet rs) {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public boolean add(Object obj) {
		// TODO Auto-generated method stub
		return false;
	}

	@Override
	public boolean update(Object obj) {
		// TODO Auto-generated method stub
		return false;
	}

	@Override
	public boolean del(Object obj) {
		// TODO Auto-generated method stub
		return false;
	}

	@Override
	public List searchAll() {
		// TODO Auto-generated method stub
		return null;
	}
    //根据设备id查询该设备的所有事件
	public List serchByCondition(Object obj) {
		Eventdata_inf einf=(Eventdata_inf) obj;
		String sql=" select distinct(test_type) "
				+ " from db_equipstand.tb_eventdata_inf "
				+ " where dev_id=? "
				+ " order by test_type asc";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{einf.getDev_id()}, new CallBack() {
			
			@Override
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						list.add(rs.getInt("test_type"));
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	//根据事件类型查询事件出现的所有次数信息
	public List serchByInfo(Object obj) {
		Eventdata_inf einf=(Eventdata_inf) obj;
		String sql=" select num,dev_id,test_record_count,test_type,record_time,record_num,test_starttime "
				+ " from  db_equipstand.tb_eventdata_inf "
				+ " where dev_id=? and test_type=? "
				+ " order by test_starttime asc ";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{einf.getDev_id(),einf.getTest_type()}, new CallBack() {
			
			@Override
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Eventdata_inf e=new Eventdata_inf();
						e.setNum(rs.getInt("num"));
						e.setDev_id(rs.getInt("dev_id"));
						e.setTest_record_count(rs.getInt("test_record_count"));
						e.setTest_type(rs.getInt("test_type"));
						e.setRecord_num(rs.getInt("record_num"));
						e.setRecord_time(rs.getTimestamp("record_time"));
						e.setTest_starttime(rs.getTimestamp("test_starttime"));
						list.add(e);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

}