package com.fgkj.partinsystem.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
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.partinsystem.dto.Ac230v_ups;
|
import com.fgkj.partinsystem.dto.DcDistribution;
|
|
public class DcDistributionImpl 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) {
|
DcDistribution dd=(DcDistribution) obj;
|
String sql=" select * from db_partinsystem.dcdistribution where dev_id=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dd.getDev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
DcDistribution d=new DcDistribution();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setState1(rs.getInt("state1"));
|
d.setState2(rs.getInt("state2"));
|
d.setState3(rs.getInt("state3"));
|
d.setState4(rs.getInt("state4"));
|
d.setState5(rs.getInt("state5"));
|
d.setState6(rs.getInt("state6"));
|
d.setState7(rs.getInt("state7"));
|
d.setState8(rs.getInt("state8"));
|
d.setState9(rs.getInt("state9"));
|
d.setState10(rs.getInt("state10"));
|
d.setState11(rs.getInt("state11"));
|
d.setState12(rs.getInt("state12"));
|
|
d.setDc_state(rs.getInt("dc_state"));
|
d.setState1_curr(rs.getFloat("state1_curr"));
|
d.setState1_sw_state(rs.getInt("state1_sw_state"));
|
d.setState1_fu_state(rs.getInt("state1_fu_state"));
|
d.setState1_ele_state(rs.getInt("state1_ele_state"));
|
d.setState1_vol(rs.getFloat("state1_vol"));
|
|
d.setState2_curr(rs.getFloat("state2_curr"));
|
d.setState2_sw_state(rs.getInt("state2_sw_state"));
|
d.setState2_fu_state(rs.getInt("state2_fu_state"));
|
d.setState2_ele_state(rs.getInt("state2_ele_state"));
|
d.setState2_vol(rs.getFloat("state2_vol"));
|
|
d.setState3_curr(rs.getFloat("state3_curr"));
|
d.setState3_sw_state(rs.getInt("state3_sw_state"));
|
d.setState3_fu_state(rs.getInt("state3_fu_state"));
|
d.setState3_ele_state(rs.getInt("state3_ele_state"));
|
d.setState3_vol(rs.getFloat("state3_vol"));
|
|
d.setState4_curr(rs.getFloat("state4_curr"));
|
d.setState4_sw_state(rs.getInt("state4_sw_state"));
|
d.setState4_fu_state(rs.getInt("state4_fu_state"));
|
d.setState4_ele_state(rs.getInt("state4_ele_state"));
|
d.setState4_vol(rs.getFloat("state4_vol"));
|
|
d.setState5_curr(rs.getFloat("state5_curr"));
|
d.setState5_sw_state(rs.getInt("state5_sw_state"));
|
d.setState5_fu_state(rs.getInt("state5_fu_state"));
|
d.setState5_ele_state(rs.getInt("state5_ele_state"));
|
d.setState5_vol(rs.getFloat("state5_vol"));
|
|
d.setState6_curr(rs.getFloat("state6_curr"));
|
d.setState6_sw_state(rs.getInt("state6_sw_state"));
|
d.setState6_fu_state(rs.getInt("state6_fu_state"));
|
d.setState6_ele_state(rs.getInt("state6_ele_state"));
|
d.setState6_vol(rs.getFloat("state6_vol"));
|
|
d.setState7_curr(rs.getFloat("state7_curr"));
|
d.setState7_sw_state(rs.getInt("state7_sw_state"));
|
d.setState7_fu_state(rs.getInt("state7_fu_state"));
|
d.setState7_ele_state(rs.getInt("state7_ele_state"));
|
d.setState7_vol(rs.getFloat("state7_vol"));
|
|
d.setState8_curr(rs.getFloat("state8_curr"));
|
d.setState8_sw_state(rs.getInt("state8_sw_state"));
|
d.setState8_fu_state(rs.getInt("state8_fu_state"));
|
d.setState8_ele_state(rs.getInt("state8_ele_state"));
|
d.setState8_vol(rs.getFloat("state8_vol"));
|
|
d.setState9_curr(rs.getFloat("state9_curr"));
|
d.setState9_sw_state(rs.getInt("state9_sw_state"));
|
d.setState9_fu_state(rs.getInt("state9_fu_state"));
|
d.setState9_ele_state(rs.getInt("state9_ele_state"));
|
d.setState9_vol(rs.getFloat("state9_vol"));
|
|
d.setState10_curr(rs.getFloat("state10_curr"));
|
d.setState10_sw_state(rs.getInt("state10_sw_state"));
|
d.setState10_fu_state(rs.getInt("state10_fu_state"));
|
d.setState10_ele_state(rs.getInt("state10_ele_state"));
|
d.setState10_vol(rs.getFloat("state10_vol"));
|
|
d.setState11_curr(rs.getFloat("state11_curr"));
|
d.setState11_sw_state(rs.getInt("state11_sw_state"));
|
d.setState11_fu_state(rs.getInt("state11_fu_state"));
|
d.setState11_ele_state(rs.getInt("state11_ele_state"));
|
d.setState11_vol(rs.getFloat("state11_vol"));
|
|
d.setState12_curr(rs.getFloat("state12_curr"));
|
d.setState12_sw_state(rs.getInt("state12_sw_state"));
|
d.setState12_fu_state(rs.getInt("state12_fu_state"));
|
d.setState12_ele_state(rs.getInt("state12_ele_state"));
|
d.setState12_vol(rs.getFloat("state12_vol"));
|
|
d.setDc_vol(rs.getFloat("dc_vol"));
|
d.setDc_curr(rs.getFloat("dc_curr"));
|
d.setDc_power(rs.getFloat("dc_power"));
|
d.setBus_vol(rs.getFloat("bus_vol"));
|
d.setBranch1_curr(rs.getFloat("branch1_curr"));
|
d.setBus_curr(rs.getFloat("bus_curr"));
|
d.setInver1_branch_curr(rs.getFloat("inver1_branch_curr"));
|
d.setInver2_branch_curr(rs.getFloat("inver2_branch_curr"));
|
d.setBackup1(rs.getFloat("backup1"));
|
d.setBackup2(rs.getFloat("backup2"));
|
d.setPum_branch1_curr(rs.getFloat("pum_branch1_curr"));
|
d.setPum_branch2_curr(rs.getFloat("pum_branch2_curr"));
|
d.setBackup3(rs.getFloat("backup3"));
|
d.setJump_curr_right(rs.getFloat("jump_curr_right"));
|
d.setShore_dc_vol(rs.getFloat("shore_dc_vol"));
|
d.setShore_dc_curr(rs.getFloat("shore_dc_curr"));
|
|
d.setQ100(rs.getInt("q100"));
|
d.setQ101(rs.getInt("q101"));
|
d.setQ102(rs.getInt("q102"));
|
d.setQ103(rs.getInt("q103"));
|
d.setQ105(rs.getInt("q105"));
|
d.setQ106(rs.getInt("q106"));
|
d.setQ108(rs.getInt("q108"));
|
d.setQ109(rs.getInt("q109"));
|
d.setQ112(rs.getInt("q112"));
|
d.setQ113(rs.getInt("q113"));
|
d.setQ120(rs.getInt("q120"));
|
d.setQ122(rs.getInt("q122"));
|
d.setDc1_power_state(rs.getInt("dc1_power_state"));
|
d.setVol_diff_more_q100(rs.getInt("vol_diff_more_q100"));
|
d.setQ100_switch(rs.getInt("q100_switch"));
|
d.setVol_diff_more_q102(rs.getInt("vol_diff_more_q102"));
|
d.setQ102_switch(rs.getInt("q102_switch"));
|
d.setVol_diff_more_q120(rs.getInt("vol_diff_more_q120"));
|
d.setQ120_switch(rs.getInt("q120_switch"));
|
d.setDc_conn_state(rs.getInt("dc_conn_state"));
|
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//设备实时数据显示（前100笔数据服务器的时间）
|
@Override
|
public List serchByInfo(Object obj) {
|
DcDistribution dd=(DcDistribution) obj;
|
Date date=new Date();
|
String table=DAOHelper.sdf_withOut.format(date);
|
String sql=" select * from db_partinsystem_history.dcdistribution_"+dd.getDev_id()+"_"+table+" where dev_id=? limit 0,100 ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dd.getDev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
DcDistribution d=new DcDistribution();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setState1(rs.getInt("state1"));
|
d.setState2(rs.getInt("state2"));
|
d.setState3(rs.getInt("state3"));
|
d.setState4(rs.getInt("state4"));
|
d.setState5(rs.getInt("state5"));
|
d.setState6(rs.getInt("state6"));
|
d.setState7(rs.getInt("state7"));
|
d.setState8(rs.getInt("state8"));
|
d.setState9(rs.getInt("state9"));
|
d.setState10(rs.getInt("state10"));
|
d.setState11(rs.getInt("state11"));
|
d.setState12(rs.getInt("state12"));
|
|
d.setDc_state(rs.getInt("dc_state"));
|
d.setState1_curr(rs.getFloat("state1_curr"));
|
d.setState1_sw_state(rs.getInt("state1_sw_state"));
|
d.setState1_fu_state(rs.getInt("state1_fu_state"));
|
d.setState1_ele_state(rs.getInt("state1_ele_state"));
|
d.setState1_vol(rs.getFloat("state1_vol"));
|
|
d.setState2_curr(rs.getFloat("state2_curr"));
|
d.setState2_sw_state(rs.getInt("state2_sw_state"));
|
d.setState2_fu_state(rs.getInt("state2_fu_state"));
|
d.setState2_ele_state(rs.getInt("state2_ele_state"));
|
d.setState2_vol(rs.getFloat("state2_vol"));
|
|
d.setState3_curr(rs.getFloat("state3_curr"));
|
d.setState3_sw_state(rs.getInt("state3_sw_state"));
|
d.setState3_fu_state(rs.getInt("state3_fu_state"));
|
d.setState3_ele_state(rs.getInt("state3_ele_state"));
|
d.setState3_vol(rs.getFloat("state3_vol"));
|
|
d.setState4_curr(rs.getFloat("state4_curr"));
|
d.setState4_sw_state(rs.getInt("state4_sw_state"));
|
d.setState4_fu_state(rs.getInt("state4_fu_state"));
|
d.setState4_ele_state(rs.getInt("state4_ele_state"));
|
d.setState4_vol(rs.getFloat("state4_vol"));
|
|
d.setState5_curr(rs.getFloat("state5_curr"));
|
d.setState5_sw_state(rs.getInt("state5_sw_state"));
|
d.setState5_fu_state(rs.getInt("state5_fu_state"));
|
d.setState5_ele_state(rs.getInt("state5_ele_state"));
|
d.setState5_vol(rs.getFloat("state5_vol"));
|
|
d.setState6_curr(rs.getFloat("state6_curr"));
|
d.setState6_sw_state(rs.getInt("state6_sw_state"));
|
d.setState6_fu_state(rs.getInt("state6_fu_state"));
|
d.setState6_ele_state(rs.getInt("state6_ele_state"));
|
d.setState6_vol(rs.getFloat("state6_vol"));
|
|
d.setState7_curr(rs.getFloat("state7_curr"));
|
d.setState7_sw_state(rs.getInt("state7_sw_state"));
|
d.setState7_fu_state(rs.getInt("state7_fu_state"));
|
d.setState7_ele_state(rs.getInt("state7_ele_state"));
|
d.setState7_vol(rs.getFloat("state7_vol"));
|
|
d.setState8_curr(rs.getFloat("state8_curr"));
|
d.setState8_sw_state(rs.getInt("state8_sw_state"));
|
d.setState8_fu_state(rs.getInt("state8_fu_state"));
|
d.setState8_ele_state(rs.getInt("state8_ele_state"));
|
d.setState8_vol(rs.getFloat("state8_vol"));
|
|
d.setState9_curr(rs.getFloat("state9_curr"));
|
d.setState9_sw_state(rs.getInt("state9_sw_state"));
|
d.setState9_fu_state(rs.getInt("state9_fu_state"));
|
d.setState9_ele_state(rs.getInt("state9_ele_state"));
|
d.setState9_vol(rs.getFloat("state9_vol"));
|
|
d.setState10_curr(rs.getFloat("state10_curr"));
|
d.setState10_sw_state(rs.getInt("state10_sw_state"));
|
d.setState10_fu_state(rs.getInt("state10_fu_state"));
|
d.setState10_ele_state(rs.getInt("state10_ele_state"));
|
d.setState10_vol(rs.getFloat("state10_vol"));
|
|
d.setState11_curr(rs.getFloat("state11_curr"));
|
d.setState11_sw_state(rs.getInt("state11_sw_state"));
|
d.setState11_fu_state(rs.getInt("state11_fu_state"));
|
d.setState11_ele_state(rs.getInt("state11_ele_state"));
|
d.setState11_vol(rs.getFloat("state11_vol"));
|
|
d.setState12_curr(rs.getFloat("state12_curr"));
|
d.setState12_sw_state(rs.getInt("state12_sw_state"));
|
d.setState12_fu_state(rs.getInt("state12_fu_state"));
|
d.setState12_ele_state(rs.getInt("state12_ele_state"));
|
d.setState12_vol(rs.getFloat("state12_vol"));
|
|
d.setDc_vol(rs.getFloat("dc_vol"));
|
d.setDc_curr(rs.getFloat("dc_curr"));
|
d.setDc_power(rs.getFloat("dc_power"));
|
d.setBus_vol(rs.getFloat("bus_vol"));
|
d.setBranch1_curr(rs.getFloat("branch1_curr"));
|
d.setBus_curr(rs.getFloat("bus_curr"));
|
d.setInver1_branch_curr(rs.getFloat("inver1_branch_curr"));
|
d.setInver2_branch_curr(rs.getFloat("inver2_branch_curr"));
|
d.setBackup1(rs.getFloat("backup1"));
|
d.setBackup2(rs.getFloat("backup2"));
|
d.setPum_branch1_curr(rs.getFloat("pum_branch1_curr"));
|
d.setPum_branch2_curr(rs.getFloat("pum_branch2_curr"));
|
d.setBackup3(rs.getFloat("backup3"));
|
d.setJump_curr_right(rs.getFloat("jump_curr_right"));
|
d.setShore_dc_vol(rs.getFloat("shore_dc_vol"));
|
d.setShore_dc_curr(rs.getFloat("shore_dc_curr"));
|
|
d.setQ100(rs.getInt("q100"));
|
d.setQ101(rs.getInt("q101"));
|
d.setQ102(rs.getInt("q102"));
|
d.setQ103(rs.getInt("q103"));
|
d.setQ105(rs.getInt("q105"));
|
d.setQ106(rs.getInt("q106"));
|
d.setQ108(rs.getInt("q108"));
|
d.setQ109(rs.getInt("q109"));
|
d.setQ112(rs.getInt("q112"));
|
d.setQ113(rs.getInt("q113"));
|
d.setQ120(rs.getInt("q120"));
|
d.setQ122(rs.getInt("q122"));
|
d.setDc1_power_state(rs.getInt("dc1_power_state"));
|
d.setVol_diff_more_q100(rs.getInt("vol_diff_more_q100"));
|
d.setQ100_switch(rs.getInt("q100_switch"));
|
d.setVol_diff_more_q102(rs.getInt("vol_diff_more_q102"));
|
d.setQ102_switch(rs.getInt("q102_switch"));
|
d.setVol_diff_more_q120(rs.getInt("vol_diff_more_q120"));
|
d.setQ120_switch(rs.getInt("q120_switch"));
|
d.setDc_conn_state(rs.getInt("dc_conn_state"));
|
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//设备历史数据查询
|
public List serchHistory(Object obj) {
|
DcDistribution dd=(DcDistribution) obj;
|
String table=DAOHelper.sdf_withOut.format(dd.getRecord_time());
|
String sql=" select * from db_partinsystem_history.dcdistribution_"+dd.getDev_id()+"_"+table+" where dev_id=? "
|
+ " and record_time >= ? and record_time <= ? order by record_time asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dd.getDev_id(),dd.getRecord_time(),dd.getRecord_time1()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
DcDistribution d=new DcDistribution();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setState1(rs.getInt("state1"));
|
d.setState2(rs.getInt("state2"));
|
d.setState3(rs.getInt("state3"));
|
d.setState4(rs.getInt("state4"));
|
d.setState5(rs.getInt("state5"));
|
d.setState6(rs.getInt("state6"));
|
d.setState7(rs.getInt("state7"));
|
d.setState8(rs.getInt("state8"));
|
d.setState9(rs.getInt("state9"));
|
d.setState10(rs.getInt("state10"));
|
d.setState11(rs.getInt("state11"));
|
d.setState12(rs.getInt("state12"));
|
|
d.setDc_state(rs.getInt("dc_state"));
|
d.setState1_curr(rs.getFloat("state1_curr"));
|
d.setState1_sw_state(rs.getInt("state1_sw_state"));
|
d.setState1_fu_state(rs.getInt("state1_fu_state"));
|
d.setState1_ele_state(rs.getInt("state1_ele_state"));
|
d.setState1_vol(rs.getFloat("state1_vol"));
|
|
d.setState2_curr(rs.getFloat("state2_curr"));
|
d.setState2_sw_state(rs.getInt("state2_sw_state"));
|
d.setState2_fu_state(rs.getInt("state2_fu_state"));
|
d.setState2_ele_state(rs.getInt("state2_ele_state"));
|
d.setState2_vol(rs.getFloat("state2_vol"));
|
|
d.setState3_curr(rs.getFloat("state3_curr"));
|
d.setState3_sw_state(rs.getInt("state3_sw_state"));
|
d.setState3_fu_state(rs.getInt("state3_fu_state"));
|
d.setState3_ele_state(rs.getInt("state3_ele_state"));
|
d.setState3_vol(rs.getFloat("state3_vol"));
|
|
d.setState4_curr(rs.getFloat("state4_curr"));
|
d.setState4_sw_state(rs.getInt("state4_sw_state"));
|
d.setState4_fu_state(rs.getInt("state4_fu_state"));
|
d.setState4_ele_state(rs.getInt("state4_ele_state"));
|
d.setState4_vol(rs.getFloat("state4_vol"));
|
|
d.setState5_curr(rs.getFloat("state5_curr"));
|
d.setState5_sw_state(rs.getInt("state5_sw_state"));
|
d.setState5_fu_state(rs.getInt("state5_fu_state"));
|
d.setState5_ele_state(rs.getInt("state5_ele_state"));
|
d.setState5_vol(rs.getFloat("state5_vol"));
|
|
d.setState6_curr(rs.getFloat("state6_curr"));
|
d.setState6_sw_state(rs.getInt("state6_sw_state"));
|
d.setState6_fu_state(rs.getInt("state6_fu_state"));
|
d.setState6_ele_state(rs.getInt("state6_ele_state"));
|
d.setState6_vol(rs.getFloat("state6_vol"));
|
|
d.setState7_curr(rs.getFloat("state7_curr"));
|
d.setState7_sw_state(rs.getInt("state7_sw_state"));
|
d.setState7_fu_state(rs.getInt("state7_fu_state"));
|
d.setState7_ele_state(rs.getInt("state7_ele_state"));
|
d.setState7_vol(rs.getFloat("state7_vol"));
|
|
d.setState8_curr(rs.getFloat("state8_curr"));
|
d.setState8_sw_state(rs.getInt("state8_sw_state"));
|
d.setState8_fu_state(rs.getInt("state8_fu_state"));
|
d.setState8_ele_state(rs.getInt("state8_ele_state"));
|
d.setState8_vol(rs.getFloat("state8_vol"));
|
|
d.setState9_curr(rs.getFloat("state9_curr"));
|
d.setState9_sw_state(rs.getInt("state9_sw_state"));
|
d.setState9_fu_state(rs.getInt("state9_fu_state"));
|
d.setState9_ele_state(rs.getInt("state9_ele_state"));
|
d.setState9_vol(rs.getFloat("state9_vol"));
|
|
d.setState10_curr(rs.getFloat("state10_curr"));
|
d.setState10_sw_state(rs.getInt("state10_sw_state"));
|
d.setState10_fu_state(rs.getInt("state10_fu_state"));
|
d.setState10_ele_state(rs.getInt("state10_ele_state"));
|
d.setState10_vol(rs.getFloat("state10_vol"));
|
|
d.setState11_curr(rs.getFloat("state11_curr"));
|
d.setState11_sw_state(rs.getInt("state11_sw_state"));
|
d.setState11_fu_state(rs.getInt("state11_fu_state"));
|
d.setState11_ele_state(rs.getInt("state11_ele_state"));
|
d.setState11_vol(rs.getFloat("state11_vol"));
|
|
d.setState12_curr(rs.getFloat("state12_curr"));
|
d.setState12_sw_state(rs.getInt("state12_sw_state"));
|
d.setState12_fu_state(rs.getInt("state12_fu_state"));
|
d.setState12_ele_state(rs.getInt("state12_ele_state"));
|
d.setState12_vol(rs.getFloat("state12_vol"));
|
|
d.setDc_vol(rs.getFloat("dc_vol"));
|
d.setDc_curr(rs.getFloat("dc_curr"));
|
d.setDc_power(rs.getFloat("dc_power"));
|
d.setBus_vol(rs.getFloat("bus_vol"));
|
d.setBranch1_curr(rs.getFloat("branch1_curr"));
|
d.setBus_curr(rs.getFloat("bus_curr"));
|
d.setInver1_branch_curr(rs.getFloat("inver1_branch_curr"));
|
d.setInver2_branch_curr(rs.getFloat("inver2_branch_curr"));
|
d.setBackup1(rs.getFloat("backup1"));
|
d.setBackup2(rs.getFloat("backup2"));
|
d.setPum_branch1_curr(rs.getFloat("pum_branch1_curr"));
|
d.setPum_branch2_curr(rs.getFloat("pum_branch2_curr"));
|
d.setBackup3(rs.getFloat("backup3"));
|
d.setJump_curr_right(rs.getFloat("jump_curr_right"));
|
d.setShore_dc_vol(rs.getFloat("shore_dc_vol"));
|
d.setShore_dc_curr(rs.getFloat("shore_dc_curr"));
|
|
d.setQ100(rs.getInt("q100"));
|
d.setQ101(rs.getInt("q101"));
|
d.setQ102(rs.getInt("q102"));
|
d.setQ103(rs.getInt("q103"));
|
d.setQ105(rs.getInt("q105"));
|
d.setQ106(rs.getInt("q106"));
|
d.setQ108(rs.getInt("q108"));
|
d.setQ109(rs.getInt("q109"));
|
d.setQ112(rs.getInt("q112"));
|
d.setQ113(rs.getInt("q113"));
|
d.setQ120(rs.getInt("q120"));
|
d.setQ122(rs.getInt("q122"));
|
d.setDc1_power_state(rs.getInt("dc1_power_state"));
|
d.setVol_diff_more_q100(rs.getInt("vol_diff_more_q100"));
|
d.setQ100_switch(rs.getInt("q100_switch"));
|
d.setVol_diff_more_q102(rs.getInt("vol_diff_more_q102"));
|
d.setQ102_switch(rs.getInt("q102_switch"));
|
d.setVol_diff_more_q120(rs.getInt("vol_diff_more_q120"));
|
d.setQ120_switch(rs.getInt("q120_switch"));
|
d.setDc_conn_state(rs.getInt("dc_conn_state"));
|
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//文件导出时的历史查询
|
public List serchCSV(Object obj) {
|
final DcDistribution dd=(DcDistribution) obj;
|
String tablists=dd.getNote()+",record_time";
|
String table=DAOHelper.sdf_withOut.format(dd.getRecord_time());
|
String table1=DAOHelper.sdf_withOut.format(dd.getRecord_time1());
|
|
String SqlAll="";
|
String sql=" (select "+tablists+" from db_partinsystem_history.dcdistribution_"+dd.getDev_id()+"_"+table+" "
|
+ " where record_time >= ? and record_time <= ? order by record_time asc )";
|
String sql_union=" union all ";
|
|
String sql1= " (select "+tablists+" from db_partinsystem_history.dcdistribution_"+dd.getDev_id()+"_"+table1+" "
|
+ " where record_time >= ? and record_time <= ? order by record_time asc )";
|
|
Object[] strarr=null;
|
List list=new ArrayList();
|
String st=dd.getDev_id()+"_"+table;
|
String st1=dd.getDev_id()+"_"+table1;
|
|
int size=DAOHelper.serchTable(st);
|
int size1=DAOHelper.serchTable(st1);
|
|
//表都存在
|
if(size>0&&size1>0){
|
if(table.equals(table1)){
|
SqlAll=sql;
|
strarr=new Object[]{DAOHelper.sdf.format(dd.getRecord_time()),DAOHelper.sdf.format(dd.getRecord_time1())};
|
|
}else{
|
SqlAll=sql+sql_union+sql1;
|
strarr=new Object[]{DAOHelper.sdf.format(dd.getRecord_time()),DAOHelper.sdfwithOut.format(dd.getRecord_time())+" 23:59:59",DAOHelper.sdfwithOut.format(dd.getRecord_time())+" 00:00:00",DAOHelper.sdf.format(dd.getRecord_time1())};
|
}
|
}
|
//存在一个表
|
if(size>0&&size1<=0){
|
SqlAll=sql;
|
strarr=new Object[]{DAOHelper.sdf.format(dd.getRecord_time()),DAOHelper.sdfwithOut.format(dd.getRecord_time())+" 23:59:59"};
|
|
}
|
if(size<=0&&size1>0){
|
SqlAll=sql1;
|
strarr=new Object[]{DAOHelper.sdfwithOut.format(dd.getRecord_time1())+" 00:00:00",DAOHelper.sdf.format(dd.getRecord_time1())};
|
|
}
|
//表都不存在
|
if(size<=0&&size1<=0){
|
return list;
|
}
|
list=DAOHelper.executeQuery(SqlAll, DBUtil.getConn(), strarr, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
String[] state=dd.getNote().split(",");
|
try {
|
while(rs.next()){
|
List row=new ArrayList();
|
row.add(ActionUtil.chageDateToString(rs.getTimestamp("record_time"), ActionUtil.time_yyyyMMddHHmmss).trim());
|
for (int i = 0; i < state.length; i++) {
|
row.add(rs.getFloat(state[i]));
|
}
|
list.add(row);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
}
|
