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.Dcinsulation;
|
|
public class DcinsulationImpl 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) {
|
Dcinsulation di=(Dcinsulation) obj;
|
String sql=" select * from db_partinsystem.dcinsulation where dev_id=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{di.getDev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dcinsulation d=new Dcinsulation();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setMotor_branch1(rs.getFloat("motor_branch1"));
|
d.setInverter_power_1st(rs.getFloat("inverter_power_1st"));
|
d.setBack_branch1(rs.getFloat("back_branch1"));
|
d.setDc25v_1st(rs.getFloat("dc25v_1st"));
|
d.setDc230v_1st(rs.getFloat("dc230v_1st"));
|
d.setWaterpump1st_ark1(rs.getFloat("waterpump1st_ark1"));
|
d.setWaterpump1st_ark2(rs.getFloat("waterpump1st_ark2"));
|
d.setInverter_power_stream_1st(rs.getFloat("inverter_power_stream_1st"));
|
|
d.setMotor_branch2(rs.getFloat("motor_branch2"));
|
d.setInverter_power_2st(rs.getFloat("inverter_power_2st"));
|
d.setBack_branch2(rs.getFloat("back_branch2"));
|
d.setDc230v_2st(rs.getFloat("dc230v_2st"));
|
d.setWaterpump2st_ark1(rs.getFloat("waterpump2st_ark1"));
|
d.setWaterpump2st_ark2(rs.getFloat("waterpump2st_ark2"));
|
d.setInverter_power_stream_2st(rs.getFloat("inverter_power_stream_2st"));
|
|
d.setControl_power_1st(rs.getFloat("control_power_1st"));
|
d.setBack_branch3(rs.getFloat("back_branch3"));
|
d.setInverter_power_3st(rs.getFloat("inverter_power_3st"));
|
d.setDc25v_3st(rs.getFloat("dc25v_3st"));
|
d.setDc230v_3st(rs.getFloat("dc230v_3st"));
|
d.setDc25v_2st(rs.getFloat("dc25v_2st"));
|
d.setBalance_pump_inverter_ark(rs.getFloat("balance_pump_inverter_ark"));
|
d.setControl_power_2st(rs.getFloat("control_power_2st"));
|
d.setBatt_switch_board_1st(rs.getFloat("batt_switch_board_1st"));
|
d.setBack_branch4(rs.getFloat("back_branch4"));
|
d.setInverter_power_4st(rs.getFloat("inverter_power_4st"));
|
d.setDc25v_4st(rs.getFloat("dc25v_4st"));
|
d.setDc230v_4st(rs.getFloat("dc230v_4st"));
|
d.setEle_water_oxygen_generator(rs.getFloat("ele_water_oxygen_generator"));
|
d.setBatt_switch_board_2st(rs.getFloat("batt_switch_board_2st"));
|
d.setBack01(rs.getFloat("back01"));
|
d.setBack02(rs.getFloat("back02"));
|
d.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1"));
|
d.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2"));
|
d.setBack03(rs.getFloat("back03"));
|
d.setBack04(rs.getFloat("back04"));
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//设备实时数据显示（前100笔数据服务器的时间）
|
@Override
|
public List serchByInfo(Object obj) {
|
Dcinsulation di=(Dcinsulation) obj;
|
Date date=new Date();
|
String table=DAOHelper.sdf_withOut.format(date);
|
String sql=" select * from db_partinsystem_history.dcinsulation_"+di.getDev_id()+"_"+table+" where dev_id=? limit 0,100";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{di.getDev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dcinsulation d=new Dcinsulation();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setMotor_branch1(rs.getFloat("motor_branch1"));
|
d.setInverter_power_1st(rs.getFloat("inverter_power_1st"));
|
d.setBack_branch1(rs.getFloat("back_branch1"));
|
d.setDc25v_1st(rs.getFloat("dc25v_1st"));
|
d.setDc230v_1st(rs.getFloat("dc230v_1st"));
|
d.setWaterpump1st_ark1(rs.getFloat("waterpump1st_ark1"));
|
d.setWaterpump1st_ark2(rs.getFloat("waterpump1st_ark2"));
|
d.setInverter_power_stream_1st(rs.getFloat("inverter_power_stream_1st"));
|
|
d.setMotor_branch2(rs.getFloat("motor_branch2"));
|
d.setInverter_power_2st(rs.getFloat("inverter_power_2st"));
|
d.setBack_branch2(rs.getFloat("back_branch2"));
|
d.setDc230v_2st(rs.getFloat("dc230v_2st"));
|
d.setWaterpump2st_ark1(rs.getFloat("waterpump2st_ark1"));
|
d.setWaterpump2st_ark2(rs.getFloat("waterpump2st_ark2"));
|
d.setInverter_power_stream_2st(rs.getFloat("inverter_power_stream_2st"));
|
|
d.setControl_power_1st(rs.getFloat("control_power_1st"));
|
d.setBack_branch3(rs.getFloat("back_branch3"));
|
d.setInverter_power_3st(rs.getFloat("inverter_power_3st"));
|
d.setDc25v_3st(rs.getFloat("dc25v_3st"));
|
d.setDc230v_3st(rs.getFloat("dc230v_3st"));
|
d.setDc25v_2st(rs.getFloat("dc25v_2st"));
|
d.setBalance_pump_inverter_ark(rs.getFloat("balance_pump_inverter_ark"));
|
d.setControl_power_2st(rs.getFloat("control_power_2st"));
|
d.setBatt_switch_board_1st(rs.getFloat("batt_switch_board_1st"));
|
d.setBack_branch4(rs.getFloat("back_branch4"));
|
d.setInverter_power_4st(rs.getFloat("inverter_power_4st"));
|
d.setDc25v_4st(rs.getFloat("dc25v_4st"));
|
d.setDc230v_4st(rs.getFloat("dc230v_4st"));
|
d.setEle_water_oxygen_generator(rs.getFloat("ele_water_oxygen_generator"));
|
d.setBatt_switch_board_2st(rs.getFloat("batt_switch_board_2st"));
|
d.setBack01(rs.getFloat("back01"));
|
d.setBack02(rs.getFloat("back02"));
|
d.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1"));
|
d.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2"));
|
d.setBack03(rs.getFloat("back03"));
|
d.setBack04(rs.getFloat("back04"));
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//设备历史数据查询
|
public List serchHistory(Object obj) {
|
Dcinsulation di=(Dcinsulation) obj;
|
String table=DAOHelper.sdf_withOut.format(di.getRecord_time());
|
String sql=" select * from db_partinsystem_history.dcinsulation_"+di.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[]{di.getDev_id(),di.getRecord_time(),di.getRecord_time1()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Dcinsulation d=new Dcinsulation();
|
d.setDev_id(rs.getInt("dev_id"));
|
d.setRecord_time(rs.getTimestamp("record_time"));
|
d.setMotor_branch1(rs.getFloat("motor_branch1"));
|
d.setInverter_power_1st(rs.getFloat("inverter_power_1st"));
|
d.setBack_branch1(rs.getFloat("back_branch1"));
|
d.setDc25v_1st(rs.getFloat("dc25v_1st"));
|
d.setDc230v_1st(rs.getFloat("dc230v_1st"));
|
d.setWaterpump1st_ark1(rs.getFloat("waterpump1st_ark1"));
|
d.setWaterpump1st_ark2(rs.getFloat("waterpump1st_ark2"));
|
d.setInverter_power_stream_1st(rs.getFloat("inverter_power_stream_1st"));
|
|
d.setMotor_branch2(rs.getFloat("motor_branch2"));
|
d.setInverter_power_2st(rs.getFloat("inverter_power_2st"));
|
d.setBack_branch2(rs.getFloat("back_branch2"));
|
d.setDc230v_2st(rs.getFloat("dc230v_2st"));
|
d.setWaterpump2st_ark1(rs.getFloat("waterpump2st_ark1"));
|
d.setWaterpump2st_ark2(rs.getFloat("waterpump2st_ark2"));
|
d.setInverter_power_stream_2st(rs.getFloat("inverter_power_stream_2st"));
|
|
d.setControl_power_1st(rs.getFloat("control_power_1st"));
|
d.setBack_branch3(rs.getFloat("back_branch3"));
|
d.setInverter_power_3st(rs.getFloat("inverter_power_3st"));
|
d.setDc25v_3st(rs.getFloat("dc25v_3st"));
|
d.setDc230v_3st(rs.getFloat("dc230v_3st"));
|
d.setDc25v_2st(rs.getFloat("dc25v_2st"));
|
d.setBalance_pump_inverter_ark(rs.getFloat("balance_pump_inverter_ark"));
|
d.setControl_power_2st(rs.getFloat("control_power_2st"));
|
d.setBatt_switch_board_1st(rs.getFloat("batt_switch_board_1st"));
|
d.setBack_branch4(rs.getFloat("back_branch4"));
|
d.setInverter_power_4st(rs.getFloat("inverter_power_4st"));
|
d.setDc25v_4st(rs.getFloat("dc25v_4st"));
|
d.setDc230v_4st(rs.getFloat("dc230v_4st"));
|
d.setEle_water_oxygen_generator(rs.getFloat("ele_water_oxygen_generator"));
|
d.setBatt_switch_board_2st(rs.getFloat("batt_switch_board_2st"));
|
d.setBack01(rs.getFloat("back01"));
|
d.setBack02(rs.getFloat("back02"));
|
d.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1"));
|
d.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2"));
|
d.setBack03(rs.getFloat("back03"));
|
d.setBack04(rs.getFloat("back04"));
|
list.add(d);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//文件导出时的历史查询
|
public List serchCSV(Object obj) {
|
final Dcinsulation di=(Dcinsulation) obj;
|
String tablists=di.getNote()+",record_time";
|
String table=DAOHelper.sdf_withOut.format(di.getRecord_time());
|
String table1=DAOHelper.sdf_withOut.format(di.getRecord_time1());
|
|
String SqlAll="";
|
String sql=" (select "+tablists+" from db_partinsystem_history.dcinsulation_"+di.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.dcinsulation_"+di.getDev_id()+"_"+table1+" "
|
+ " where record_time >= ? and record_time <= ? order by record_time asc )";
|
|
Object[] strarr=null;
|
List list=new ArrayList();
|
String st=di.getDev_id()+"_"+table;
|
String st1=di.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(di.getRecord_time()),DAOHelper.sdf.format(di.getRecord_time1())};
|
|
}else{
|
SqlAll=sql+sql_union+sql1;
|
strarr=new Object[]{DAOHelper.sdf.format(di.getRecord_time()),DAOHelper.sdfwithOut.format(di.getRecord_time())+" 23:59:59",DAOHelper.sdfwithOut.format(di.getRecord_time())+" 00:00:00",DAOHelper.sdf.format(di.getRecord_time1())};
|
}
|
}
|
//存在一个表
|
if(size>0&&size1<=0){
|
SqlAll=sql;
|
strarr=new Object[]{DAOHelper.sdf.format(di.getRecord_time()),DAOHelper.sdfwithOut.format(di.getRecord_time())+" 23:59:59"};
|
|
}
|
if(size<=0&&size1>0){
|
SqlAll=sql1;
|
strarr=new Object[]{DAOHelper.sdfwithOut.format(di.getRecord_time1())+" 00:00:00",DAOHelper.sdf.format(di.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=di.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;
|
}
|
}
|
