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.BattInf;
|
import com.fgkj.dto.Devtmp_record;
|
|
public class Devtmp_recordImpl 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) {
|
Devtmp_record dre=(Devtmp_record) obj;
|
String sql=" select distinct dev_id,dev_tmp,recordtime from web_site.tb_devtmp_record "
|
+ " where dev_id=? and recordtime>=? and recordtime<=? "
|
+ " order by recordtime asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dre.getDev_id(),dre.getRecordtime(),dre.getRecordtime1()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Devtmp_record d=new Devtmp_record();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setDev_tmp(rs.getFloat("dev_tmp"));
|
d.setRecordtime(rs.getTimestamp("recordtime"));
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//批量显示每个站的温度最大值
|
@Override
|
public List serchByInfo(Object obj) {
|
BattInf binf=(BattInf) obj;
|
String sql=" select dev_id,FORMAT(max(dev_tmp),1) as max_tmp, stationname,stationname1,stationname2,stationname3,stationname5 "
|
+ " from web_site.tb_devtmp_record,db_battinf.tb_battinf "
|
+ " where web_site.tb_devtmp_record.dev_id=db_battinf.tb_battinf.FBSDeviceId "
|
+ " and recordtime>=? and recordtime<=? ";
|
//区域选择
|
String stationsqlO=" and stationname1 like ? ";
|
String stationsqlT=" and stationname2 like ? ";
|
String stationsqlH=" and stationname5 like ? ";
|
if(binf.getNum()==1){
|
sql+=stationsqlO;
|
}else if(binf.getNum()==2){
|
sql+=stationsqlT;
|
}else if(binf.getNum()==3){
|
sql+=stationsqlH;
|
}
|
//分组sql
|
String groupSql=" GROUP BY dev_id ";
|
sql+=groupSql;
|
//排序
|
String orderSql=" order by dev_id asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattProductDate(),binf.getBattProductDate1(),"%"+binf.getStationName()+"%"}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Devtmp_record d=new Devtmp_record();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setDev_tmp(rs.getFloat("max_tmp"));
|
d.setStationname(rs.getString("stationname"));
|
d.setStationname1(rs.getString("stationname1"));
|
d.setStationname2(rs.getString("stationname2"));
|
d.setStationname3(rs.getString("stationname3"));
|
d.setStationname5(rs.getString("stationname5"));
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
public static void main(String[] args) throws ParseException {
|
Devtmp_recordImpl dimpl=new Devtmp_recordImpl();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date date1 = sdf.parse("2000-01-01");
|
Date date2 = sdf.parse("2020-01-01");
|
|
Devtmp_record dre=new Devtmp_record();
|
dre.setDev_id(910000113);
|
dre.setRecordtime(ActionUtil.getSimpDate(date1));
|
dre.setRecordtime1(ActionUtil.getSimpDate(date2));
|
BattInf binf=new BattInf();
|
binf.setNum(2);
|
binf.setStationName("");
|
binf.setBattProductDate(ActionUtil.getSimpDate(date1));
|
binf.setBattProductDate1(ActionUtil.getSimpDate(date2));
|
//List<Devtmp_record> list=dimpl.serchByCondition(dre);
|
List<Devtmp_record> list=dimpl.serchByInfo(binf);
|
for (Devtmp_record d : list) {
|
System.out.println(d);
|
}
|
}
|
}
|
