package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
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.Sensor_hisdata;
|
|
public class Sensor_hisdataImpl 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查询历史记录
|
@Override
|
public List serchByCondition(Object obj) {
|
Sensor_hisdata sdata=(Sensor_hisdata) obj;
|
String sql=" select distinct num,sensor_dev_id,record_time,airtmp,airhum,smoke,water,lightintensity"
|
+ " ,CO2concentration,COconcentration,CH4concentration,O2concentration,note "
|
+ " from db_sensor_history.tb_sensor_hisdata_"+sdata.getSensor_dev_id()
|
+ " where sensor_dev_id=? and record_time>=? and record_time<=? "
|
+ " order by record_time asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{sdata.getSensor_dev_id(),sdata.getRecord_time1(),sdata.getRecord_time()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Sensor_hisdata s=new Sensor_hisdata();
|
s.setNum(rs.getInt("num"));
|
s.setSensor_dev_id(rs.getInt("sensor_dev_id"));
|
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.setNote(rs.getString("note"));
|
list.add(s);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//实时页面最新的的10笔数据
|
public List serchByInfo(Object obj) {
|
Sensor_hisdata sdata=(Sensor_hisdata) obj;
|
String sql=" select distinct num,sensor_dev_id,record_time,airtmp,airhum,smoke,water,lightintensity"
|
+ " ,CO2concentration,COconcentration,CH4concentration,O2concentration,note "
|
+ " from db_sensor_history.tb_sensor_hisdata_"+sdata.getSensor_dev_id()
|
+ " where sensor_dev_id=? "
|
+ " order by record_time desc limit 0,10";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{sdata.getSensor_dev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Sensor_hisdata s=new Sensor_hisdata();
|
s.setNum(rs.getInt("num"));
|
s.setSensor_dev_id(rs.getInt("sensor_dev_id"));
|
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.setNote(rs.getString("note"));
|
list.add(s);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
public static void main(String[] args) throws ParseException {
|
Sensor_hisdataImpl simpl=new Sensor_hisdataImpl();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date date1 = sdf.parse("2000-01-01");
|
Date date2 = sdf.parse("2020-01-01");
|
Sensor_hisdata sdata=new Sensor_hisdata();
|
sdata.setSensor_dev_id(291200001);
|
sdata.setRecord_time(ActionUtil.getSimpDate(date2));
|
sdata.setRecord_time1(ActionUtil.getSimpDate(date1));
|
//List list=simpl.serchByCondition(sdata);
|
List list=simpl.serchByInfo(sdata);
|
System.out.println(list.size());
|
|
}
|
}
|
