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.BattTestData;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.db.IDatabaseName;
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.Batt_Maint_Dealarm;
|
import com.fgkj.dto.Batt_maintenance_inf;
|
import com.fgkj.dto.Battresdata;
|
import com.fgkj.dto.Battresdata_inf;
|
import com.fgkj.dto.Batttestdata_inf;
|
import com.fgkj.dto.Batttestdatastop;
|
import com.fgkj.dto.Page;
|
|
public class BattinfThirdImpl implements BaseDAO, CallBack {
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList();
|
try {
|
while (rs.next()) {
|
BattInf binf = new BattInf();
|
binf.setBattGroupId(rs.getInt("BattGroupId"));
|
binf.setMonCount(rs.getInt("monCount"));
|
binf.setMonVolStd(rs.getFloat("monVolStd"));
|
binf.setMonCapStd(rs.getFloat("monCapStd"));
|
binf.setMonResStd(rs.getFloat("monResStd"));
|
binf.setMonSerStd(rs.getFloat("monserstd"));
|
|
Batttestdata_inf tdata = new Batttestdata_inf();
|
tdata.setBattGroupId(rs.getInt("battGroupId"));
|
tdata.setMax_monvol(rs.getFloat("max_monvol"));
|
tdata.setMin_monvol(rs.getFloat("min_monvol"));
|
tdata.setTest_type(rs.getInt("test_type"));
|
tdata.setTest_record_count(rs.getInt("test_record_count"));
|
|
Batttestdatastop sdata=new Batttestdatastop();
|
sdata.setTest_starttime(rs.getTimestamp("test_starttime"));
|
sdata.setRecord_time(rs.getTimestamp("record_time"));
|
sdata.setTest_timelong(rs.getInt("test_timelong"));
|
sdata.setGroup_vol(rs.getFloat("group_vol"));
|
sdata.setTest_curr(rs.getFloat("test_curr"));
|
sdata.setTest_cap(rs.getFloat("test_cap"));
|
sdata.setMon_num(rs.getInt("mon_num"));
|
sdata.setMon_vol(rs.getFloat("mon_vol"));
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
bmd.setBinf(binf);
|
bmd.setTdata(tdata);
|
bmd.setSdata(sdata);
|
list.add(bmd);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
public boolean add(Object obj) {
|
return false;
|
}
|
|
public boolean update(Object obj) {
|
return false;
|
}
|
|
public boolean del(Object obj) {
|
return false;
|
}
|
|
public List searchAll() {
|
return null;
|
}
|
|
|
|
public List serchByInfo(Object obj) {
|
return null;
|
}
|
//1.3电池单体统计分析查询(旧)
|
public List serchByCondition1(Object obj){
|
Batt_Maint_Dealarm bmd = (Batt_Maint_Dealarm) obj;
|
Batttestdata_inf tdata=bmd.getTdata();
|
List list = null;
|
String sql="";
|
BattInf binf = bmd.getBinf();
|
String sqlT="select distinct(db_battinf.tb_battinf.BattgroupId),moncapstd,monvolstd,monresstd,monserstd" +
|
",db_batt_testdata.tb_batttestdata_inf.battgroupid,max_monvol,min_monvol,db_batt_testdata.tb_batttestdata_inf.test_record_count,test_type,test_record_count " +
|
"from db_battinf.tb_battinf,db_batt_testdata.tb_batttestdata_inf " +
|
"where " +
|
"db_battinf.tb_battinf.BattgroupId=db_batt_testdata.tb_batttestdata_inf.BattGroupId " +
|
"and db_battinf.tb_battinf.battgroupid=? and db_batt_testdata.tb_batttestdata_inf.data_available=1 " +
|
"and db_batt_testdata.tb_batttestdata_inf.test_type=? and db_batt_testdata.tb_batttestdata_inf.test_starttype=3 ";
|
String sqlE="select distinct(db_battinf.tb_battinf.BattgroupId),moncapstd,monvolstd,monresstd,monserstd" +
|
",db_batt_testdata.tb_battresdata_inf.battgroupid,db_batt_testdata.tb_battresdata_inf.test_record_count,test_type,test_record_count " +
|
"from db_battinf.tb_battinf,db_batt_testdata.tb_battresdata_inf " +
|
"where " +
|
"db_battinf.tb_battinf.BattgroupId=db_batt_testdata.tb_battresdata_inf.BattGroupId " +
|
"and db_battinf.tb_battinf.battgroupid=? and db_batt_testdata.tb_battresdata_inf.data_available=1 and db_batt_testdata.tb_battresdata_inf.test_type=? ";
|
//用于维护区
|
String station1SqlT=" and stationname1!=? ";//全部
|
String station1SqlF=" and stationname1=? ";
|
if(binf.getStationName1().equals("")){
|
sqlT+=station1SqlT;
|
sqlE+=station1SqlT;
|
}else{
|
sqlT+=station1SqlF;
|
sqlE+=station1SqlF;
|
}
|
//用于机房站点
|
String stationSqlT=" and stationname!=? ";//全部
|
String stationSqlF=" and stationname=? ";
|
if(binf.getStationName().equals("")){
|
sqlT+=stationSqlT;
|
sqlE+=stationSqlT;
|
}else{
|
sqlT+=stationSqlF;
|
sqlE+=stationSqlF;
|
}
|
|
//按照battgroupid排序
|
String endSql=" order by db_battinf.tb_battinf.battgroupid ";
|
sqlT+=endSql;
|
sqlE+=endSql;
|
if(tdata.getTest_type()==BattTestData.BATT_DISCHARGE){
|
sql=sqlT;
|
//System.out.println(sql);
|
list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId(),tdata.getTest_type(),binf.getStationName1(),binf.getStationName()},new BattinfThirdImpl());
|
}else if(tdata.getTest_type()==BattTestData.BATT_RES){
|
sql=sqlE;
|
//System.out.println(sql);
|
list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId(),tdata.getTest_type(),binf.getStationName1(),binf.getStationName()},new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
|
try {
|
while(rs.next()){
|
BattInf binf=new BattInf();
|
binf.setBattGroupId(rs.getInt("BattGroupId"));
|
|
binf.setMonVolStd(rs.getFloat("monVolStd"));
|
binf.setMonCapStd(rs.getFloat("monCapStd"));
|
binf.setMonResStd(rs.getFloat("monResStd"));
|
binf.setMonSerStd(rs.getFloat("monSerStd"));
|
Battresdata_inf rinf=new Battresdata_inf();
|
rinf.setBattGroupId(rs.getInt("battGroupId"));
|
rinf.setTest_record_count(rs.getInt("test_record_count"));
|
rinf.setTest_type(rs.getInt("test_type"));
|
rinf.setTest_record_count(rs.getInt("test_record_count"));
|
Batt_Maint_Dealarm bmd=new Batt_Maint_Dealarm();
|
bmd.setBinf(binf);
|
bmd.setRinf(rinf);
|
|
list.add(bmd);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
}
|
|
return list;
|
}
|
//1.3电池单体统计分析查询
|
public List serchByCondition(Object obj){
|
Batt_Maint_Dealarm bmd = (Batt_Maint_Dealarm) obj;
|
Batttestdata_inf tdata=bmd.getTdata();
|
List list = null;
|
String sql="";
|
BattInf binf = bmd.getBinf();
|
String sqlT="select distinct(db_battinf.tb_battinf.BattgroupId),moncount,moncapstd,monvolstd,monresstd,monserstd" +
|
",db_batt_testdata.tb_batttestdata_inf.battgroupid,max_monvol,min_monvol,db_batt_testdata.tb_batttestdata_inf.test_record_count,db_batt_testdata.tb_batttestdata_inf.test_type,db_batt_testdata.tb_batttestdata_inf.test_record_count" +
|
",db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_starttime,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".record_time,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_timelong,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".group_vol,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_curr,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_cap,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".mon_num,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".mon_vol " +
|
" from db_battinf.tb_battinf,db_batt_testdata.tb_batttestdata_inf,db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+" "+
|
" where " +
|
" db_battinf.tb_battinf.BattgroupId=db_batt_testdata.tb_batttestdata_inf.BattGroupId " +
|
" and db_batt_testdata.tb_batttestdata_inf.BattGroupId=db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".battgroupid" +
|
" and db_batt_testdata.tb_batttestdata_inf.test_record_count=db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_record_count" +
|
" and db_batt_testdata.tb_batttestdata_inf.record_num=db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".record_num" +
|
" and db_battinf.tb_battinf.battgroupid=? and db_batt_testdata.tb_batttestdata_inf.data_available=1 " +
|
" and db_batt_testdata.tb_batttestdata_inf.test_type=? and db_batt_testdata.tb_batttestdata_inf.test_starttype=3 ";
|
String sqlE="select distinct(db_battinf.tb_battinf.BattgroupId),moncount,moncapstd,monvolstd,monresstd,monserstd" +
|
" ,db_batt_testdata.tb_battresdata_inf.battgroupid,db_batt_testdata.tb_battresdata_inf.test_record_count " +
|
" ,db_batt_testdata.tb_battresdata_" +binf.getBattGroupId()+".group_vol,db_batt_testdata.tb_battresdata_" +binf.getBattGroupId()+".test_curr,db_batt_testdata.tb_battresdata_" +binf.getBattGroupId()+".test_starttime,mon_num,mon_vol,mon_tmp,mon_res,mon_ser,conn_res " +
|
" from db_battinf.tb_battinf,db_batt_testdata.tb_battresdata_inf,db_batt_testdata.tb_battresdata_"+binf.getBattGroupId()+" "+
|
" where " +
|
" db_battinf.tb_battinf.BattgroupId=db_batt_testdata.tb_battresdata_inf.BattGroupId" +
|
" and db_batt_testdata.tb_battresdata_inf.BattGroupId=db_batt_testdata.tb_battresdata_"+binf.getBattGroupId()+".battgroupid" +
|
" and db_batt_testdata.tb_battresdata_inf.test_record_count=db_batt_testdata.tb_battresdata_"+binf.getBattGroupId()+".test_record_count" +
|
" and db_battinf.tb_battinf.battgroupid=? and db_batt_testdata.tb_battresdata_inf.data_available=1 and db_batt_testdata.tb_battresdata_inf.test_type=? ";
|
//用于单体选择
|
String tmonNumSqlT=" and db_batt_testdata.tb_batttestdatastop_" +binf.getBattGroupId()+".mon_num!=? ";
|
String tmonNumSqlF=" and db_batt_testdata.tb_batttestdatastop_" +binf.getBattGroupId()+".mon_num=? ";
|
|
String emonNumSqlT=" and db_batt_testdata.tb_battresdata_" +binf.getBattGroupId()+".mon_num!=? ";
|
String emonNumSqlF=" and db_batt_testdata.tb_battresdata_" +binf.getBattGroupId()+".mon_num=? ";
|
if(binf.getMonNum()==0){
|
sqlT+=tmonNumSqlT;
|
sqlE+=emonNumSqlT;
|
}else{
|
sqlT+=tmonNumSqlF;
|
sqlE+=emonNumSqlF;
|
}
|
//用于维护区
|
String station1SqlT=" and stationname1!=? ";//全部
|
String station1SqlF=" and stationname1=? ";
|
if(binf.getStationName1().equals("")){
|
sqlT+=station1SqlT;
|
sqlE+=station1SqlT;
|
}else{
|
sqlT+=station1SqlF;
|
sqlE+=station1SqlF;
|
}
|
//用于市级
|
String station2SqlT=" and stationname2!=? ";//全部
|
String station2SqlF=" and stationname2=? ";
|
if(binf.getStationName2().equals("")){
|
sqlT+=station2SqlT;
|
sqlE+=station2SqlT;
|
}else{
|
sqlT+=station2SqlF;
|
sqlE+=station2SqlF;
|
}
|
//用于区县
|
String station5SqlT=" and stationname5!=? ";//全部
|
String station5SqlF=" and stationname5=? ";
|
if(binf.getStationName5().equals("")){
|
sqlT+=station5SqlT;
|
sqlE+=station5SqlT;
|
}else{
|
sqlT+=station5SqlF;
|
sqlE+=station5SqlF;
|
}
|
//按照battgroupid排序
|
String tendSql=" order by db_batt_testdata.tb_batttestdatastop_"+binf.getBattGroupId()+".test_record_count asc,db_batt_testdata.tb_batttestdatastop_" +binf.getBattGroupId()+".mon_num asc ";
|
String eendSql=" order by db_batt_testdata.tb_battresdata_"+binf.getBattGroupId()+".test_record_count asc,db_batt_testdata.tb_battresdata_" +binf.getBattGroupId()+".mon_num asc ";
|
//用于机房站点
|
String stationSqlT=" and stationname!=? ";//全部
|
String stationSqlF=" and stationname=? ";
|
if(binf.getStationName().equals("")){
|
sqlT+=stationSqlT+tendSql;
|
sqlE+=stationSqlT+eendSql;
|
}else{
|
sqlT+=stationSqlF+tendSql;
|
sqlE+=stationSqlF+eendSql;
|
}
|
if(tdata.getTest_type()==BattTestData.BATT_DISCHARGE){
|
sql=sqlT;
|
//System.out.println(sql);
|
list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId(),tdata.getTest_type(),binf.getMonNum(),binf.getStationName1(),binf.getStationName2(),binf.getStationName5(),binf.getStationName()},new BattinfThirdImpl());
|
}else if(tdata.getTest_type()==BattTestData.BATT_RES){
|
sql=sqlE;
|
//System.out.println(sql);
|
list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId(),tdata.getTest_type(),binf.getMonNum()*10+1,binf.getStationName1(),binf.getStationName2(),binf.getStationName5(),binf.getStationName()},new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
|
try {
|
while(rs.next()){
|
BattInf binf=new BattInf();
|
binf.setBattGroupId(rs.getInt("BattGroupId"));
|
binf.setMonCount(rs.getInt("monCount"));
|
binf.setMonVolStd(rs.getFloat("monVolStd"));
|
binf.setMonCapStd(rs.getFloat("monCapStd"));
|
binf.setMonResStd(rs.getFloat("monResStd"));
|
binf.setMonSerStd(rs.getFloat("monSerStd"));
|
|
Battresdata_inf rinf=new Battresdata_inf();
|
rinf.setBattGroupId(rs.getInt("battGroupId"));
|
rinf.setTest_record_count(rs.getInt("test_record_count"));
|
|
Battresdata rdata = new Battresdata();
|
rdata.setBattGroupId(rs.getInt("BattGroupId"));
|
rdata.setTest_record_count(rs.getInt("test_record_count"));
|
rdata.setTest_starttime(rs.getTimestamp("test_starttime"));
|
rdata.setGroup_vol(rs.getFloat("group_vol"));
|
rdata.setTest_curr(rs.getFloat("test_curr"));
|
rdata.setMon_num(rs.getInt("mon_num"));
|
rdata.setMon_vol(rs.getFloat("mon_vol"));
|
rdata.setMon_tmp(rs.getFloat("mon_tmp"));
|
rdata.setMon_res(rs.getFloat("mon_res"));
|
rdata.setMon_ser(rs.getFloat("mon_ser"));
|
rdata.setConn_res(rs.getFloat("conn_res"));
|
|
|
Batt_Maint_Dealarm bmd=new Batt_Maint_Dealarm();
|
bmd.setBinf(binf);
|
bmd.setRinf(rinf);
|
bmd.setRdata(rdata);
|
list.add(bmd);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
}
|
|
return list;
|
}
|
public static void main(String[] args) {
|
BattInfImpl biml = new BattInfImpl();
|
BattInf binf = new BattInf();
|
|
binf.setStationName("");
|
binf.setStationName1("");
|
binf.setBattGroupId(1000007);
|
//binf.setBattGroupName1("");
|
|
|
Batttestdata_inf tdata=new Batttestdata_inf();
|
tdata.setTest_type(3);
|
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
bmd.setBinf(binf);
|
bmd.setTdata(tdata);
|
|
|
BattinfThirdImpl bi=new BattinfThirdImpl();
|
List<Batt_Maint_Dealarm> list = bi.serchByCondition(bmd);
|
for (Batt_Maint_Dealarm b : list) {
|
System.out.println(b.getTdata());
|
}
|
System.out.println(list.size());
|
|
|
|
}
|
|
}
|
