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.Sensor_inf;
import com.fgkj.dto.Sensor_mapinfo;
import com.fgkj.dto.Sensor_state;


public class Sensor_mapinfoImpl 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) {
		Sensor_mapinfo sinfo=(Sensor_mapinfo) obj;
		String sql=" repalce into db_sensor.tb_sensor_mapinfo(sensor_dev_id,longitude,latitude,address)"
				+ "  values(?,?,?,?)";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinfo.getSensor_dev_id(),sinfo.getLongitude(),sinfo.getLatitude(),sinfo.getAddress()});
		return bl;
	}
	//删除定位信息
	@Override
	public boolean del(Object obj) {
		Sensor_mapinfo sinfo=(Sensor_mapinfo) obj;
		String sql=" delete from  db_sensor.tb_sensor_mapinfo where sensor_dev_id=? ";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinfo.getSensor_dev_id()});
		return bl;
	}
    //查询所有传感器的定位信息
	@Override
	public List searchAll() {
		String sql=" select distinct db_sensor.tb_sensor_mapinfo.num,db_sensor.tb_sensor_mapinfo.sensor_dev_id,longitude,latitude,address "
				+ "  ,record_time,airtmp,airhum,smoke,water,lightintensity "
				+ "  ,province,city,county,device_name,airtmp_alarm,airhum_alarm,smoke_alarm  "
				+ " ,CO2concentration,COconcentration,CH4concentration,O2concentration,dev_commcount,dev_errcommcount "
				+ "  from db_sensor.tb_sensor_mapinfo,db_sensor.tb_sensor_state,db_sensor.tb_sensor_inf "
				+ "  where db_sensor.tb_sensor_mapinfo.sensor_dev_id=db_sensor.tb_sensor_state.sensor_dev_id  "
				+ "  and  db_sensor.tb_sensor_mapinfo.sensor_dev_id=db_sensor.tb_sensor_inf.sensor_dev_id ";
		
		List list= DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			@Override
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Sensor_mapinfo sinfo=new Sensor_mapinfo();
						sinfo.setNum(rs.getInt("num"));
						sinfo.setSensor_dev_id(rs.getInt("sensor_dev_id"));
						sinfo.setLongitude(rs.getDouble("longitude"));
						sinfo.setLatitude(rs.getDouble("latitude"));
						sinfo.setAddress(rs.getString("address"));
						
						Sensor_inf sinf=new Sensor_inf();
						sinf.setProvince(rs.getString("province"));
						sinf.setCity(rs.getString("city"));
						sinf.setCounty(rs.getString("county"));
						sinf.setDevice_name(rs.getString("device_name"));
						sinf.setAirtmp_alarm(rs.getFloat("airtmp_alarm"));
						sinf.setAirhum_alarm(rs.getFloat("airhum_alarm"));
						sinf.setSmoke_alarm(rs.getInt("smoke_alarm"));
						
						sinfo.setSinf(sinf);
						
						Sensor_state s=new Sensor_state();
						s.setRecord_time(rs.getTimestamp("record_time"));
						s.setAirtmp(rs.getFloat("airtmp"));
						s.setAirhum(rs.getFloat("airhum"));
						s.setSmoke(rs.getInt("smoke"));
						s.setWater(rs.getInt("water"));
						s.setLightintensity(rs.getInt("lightintensity"));
						s.setCO2concentration(rs.getInt("cO2concentration"));
						s.setCOconcentration(rs.getInt("cOconcentration"));
						s.setCH4concentration(rs.getInt("cH4concentration"));
						s.setO2concentration(rs.getInt("o2concentration"));
						s.setDev_commcount(rs.getInt("dev_commcount"));
						s.setDev_errcommcount(rs.getInt("dev_errcommcount"));
						sinfo.setState(s);
						list.add(sinfo);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}
    
	@Override
	public List serchByCondition(Object obj) {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public List serchByInfo(Object obj) {
		// TODO Auto-generated method stub
		return null;
	}
    
	public static void main(String[] args) {
		Sensor_mapinfoImpl simpl=new Sensor_mapinfoImpl();
		List<Sensor_mapinfo> list=simpl.searchAll();
		for (Sensor_mapinfo s : list) {
			System.out.println(s);
		}
	}
}