package com.fgkj.dao.impl.rt;
|
|
import java.sql.Connection;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.BattTestData;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.dao.LimitNumberFactory;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.Batt_Maint_Dealarm;
|
import com.fgkj.dto.Batt_State;
|
import com.fgkj.dto.Batt_rtdata;
|
import com.fgkj.dto.Batt_rtstate;
|
import com.fgkj.dto.Page;
|
import com.fgkj.dto.rt.Batt_State_rt;
|
import com.fgkj.dto.rt.Rtdata_rt;
|
import com.fgkj.dto.rt.Rtstate_rt;
|
|
public class Rtstate_rtImpl implements CallBack,BaseDAO{
|
private SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
|
public boolean add(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public boolean update(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
|
public List searchAll() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public List serchByCondition(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//测试数据——实时查询中左下角的充放电统计
|
public List serchDisOrChargr(){
|
String sql="SELECT battgroupid,batt_test_type from db_ram_batt_rt.tb_rtstate_rt WHERE batt_test_type IN(2,3) ORDER BY battgroupid";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List<Rtstate_rt> list=new ArrayList();
|
int charge=0;
|
int dischar=0;
|
try {
|
while(rs.next()){
|
Rtstate_rt rts=new Rtstate_rt();
|
rts.setBattGroupId(rs.getInt("battGroupId"));
|
rts.setBatt_test_type(rs.getInt("batt_test_type"));
|
if(rs.getInt("batt_test_type")==3){
|
dischar++;
|
}else if(rs.getInt("batt_test_type")==2){
|
charge++;
|
}
|
list.add(rts);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
if(list!=null&&list.size()>0){
|
list.get(list.size()-1).setNum(charge);
|
list.get(list.size()-1).setBatt_count(dischar);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//电池组实时情况+实时电池续航能力查询
|
public List serchBattLife(Object obj) {
|
Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
|
BattInf binf=bmd.getBinf();
|
Page page=bmd.getPage();
|
String numberSql=" SELECT FOUND_ROWS() number";
|
Connection conn=DBUtil.getConn();
|
String sql="";
|
String baseSql="select SQL_CALC_FOUND_ROWS tb_rtstate_rt.BattGroupId,batt_count,tb_rtstate_rt.rec_datetime,online_vol,group_vol,group_curr,batt_state," +
|
"batt_test_type,batt_test_starttime,batt_test_recordtime,batt_test_tlong," +
|
"batt_test_cap,batt_real_cap,batt_rest_cap,batt_rest_power1_time,batt_rest_power2_time" +
|
",db_ram_batt_rt.tb_rtdata_rt.BattGroupId,db_ram_batt_rt.tb_rtdata_rt.rec_datetime,mon_num,mon_vol,mon_tmp," +
|
"mon_res,mon_ser,mon_conn_res,mon_cap" +
|
",db_battinf.tb_battinf.moncapstd,db_battinf.tb_battinf.monvolstd " +
|
",db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.BattGroupName,db_battinf.tb_battinf.deviceName " +
|
",max(binary db_ram_batt_rt.tb_rtdata_rt.mon_vol) as maxmonvol,min(binary db_ram_batt_rt.tb_rtdata_rt.mon_vol) as minmonvol " +
|
"FROM db_ram_batt_rt.tb_rtstate_rt " +
|
"LEFT OUTER JOIN db_ram_batt_rt.tb_rtdata_rt ON db_ram_batt_rt.tb_rtstate_rt.BattGroupId = db_ram_batt_rt.tb_rtdata_rt.BattGroupId " +
|
"LEFT OUTER JOIN db_battinf.tb_battinf ON db_ram_batt_rt.tb_rtstate_rt.BattGroupId = db_battinf.tb_battinf.BattGroupId " +
|
"WHERE ";
|
//电池组的选择
|
String idSqlT=" db_ram_batt_rt.tb_rtstate_rt.BattGroupId=? ";
|
String idSqlF=" db_ram_batt_rt.tb_rtstate_rt.BattGroupId!=? ";
|
if(binf.getBattGroupId()==0){
|
baseSql+=idSqlF;
|
}else{
|
baseSql+=idSqlT;
|
}
|
//机房维护区选择
|
String stationSql=" AND db_battinf.tb_battinf.stationname like ? AND db_battinf.tb_battinf.stationname1 like ? ";
|
baseSql+=stationSql;
|
//电池状态
|
String stateSqlT=" AND batt_state=? ";
|
String stateSqlF=" AND batt_state!=? ";
|
if(binf.getNum()==100){
|
baseSql+=stateSqlF;
|
}else{
|
baseSql+=stateSqlT;
|
}
|
//排序
|
String endSql=" GROUP BY db_ram_batt_rt.tb_rtstate_rt.BattGroupId ";
|
//分页
|
String limitSql=" limit ?,?";
|
sql=baseSql+endSql+limitSql;
|
//System.out.println(sql);
|
List<Batt_State_rt> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{binf.getBattGroupId(),"%"+binf.getStationName()+"%","%"+binf.getStationName1()+"%"
|
,binf.getNum(),(page.getPageCurr() - 1)*page.getPageSize(),
|
page.getPageSize()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_State_rt state_rt=new Batt_State_rt();
|
|
Rtstate_rt rts=new Rtstate_rt();
|
rts.setBattGroupId(rs.getInt("tb_rtstate_rt.BattGroupId"));
|
rts.setBatt_count(rs.getInt("batt_count"));
|
rts.setRec_datetime(rs.getTimestamp("tb_rtstate_rt.rec_datetime"));
|
rts.setOnline_vol(rs.getFloat("online_vol"));
|
rts.setGroup_vol(rs.getFloat("group_vol"));
|
|
rts.setGroup_curr(rs.getFloat("group_curr"));//
|
rts.setBatt_state(rs.getInt("batt_state"));
|
rts.setBatt_test_type(rs.getInt("batt_test_type"));
|
rts.setBatt_test_starttime(rs.getTimestamp("batt_test_starttime"));
|
rts.setBatt_test_recordtime(rs.getTimestamp("batt_test_recordtime"));
|
rts.setBatt_test_tlong(rs.getInt("batt_test_tlong"));
|
rts.setBatt_test_cap(rs.getFloat("batt_test_cap"));
|
rts.setBatt_real_cap(rs.getFloat("batt_real_cap"));
|
rts.setBatt_rest_cap(rs.getFloat("batt_rest_cap"));
|
rts.setBatt_rest_power1_time(rs.getInt("batt_rest_power1_time"));
|
rts.setBatt_rest_power2_time(rs.getInt("batt_rest_power2_time"));
|
|
Rtdata_rt rtd=new Rtdata_rt();
|
rtd.setMon_vol(rs.getFloat("maxmonvol"));
|
rtd.setMon_tmp(rs.getFloat("minmonvol"));
|
|
|
BattInf binf=new BattInf();
|
binf.setBattGroupId(rs.getInt("battGroupId"));
|
binf.setMonCapStd(rs.getFloat("monCapStd"));
|
binf.setMonVolStd(rs.getFloat("MonVolStd"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
binf.setDeviceName(rs.getString("deviceName"));
|
binf.setStationName(rs.getString("stationName"));
|
binf.setStationName1(rs.getString("stationName1"));
|
|
binf.setStationName9(BattTestData.battState(rs.getInt("batt_state")));
|
|
state_rt.setRts(rts);
|
state_rt.setRtd(rtd);
|
state_rt.setBinf(binf);
|
list.add(state_rt);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
//去掉limit条件后的总数
|
int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
|
//System.out.println("number: "+number);
|
if(list!=null&&list.size()>0){
|
list.get(list.size()-1).getBinf().setMonNum(number);
|
}
|
return list;
|
}
|
|
//首页上饼状图电池状态比例
|
public List serchBattStateRate(){
|
String sql=" SELECT DISTINCT db_ram_batt_rt.tb_rtstate_rt.BattGroupId,batt_state, " +
|
" COUNT(db_ram_batt_rt.tb_rtstate_rt.BattGroupId) as stateNum " +
|
" FROM db_ram_batt_rt.tb_rtstate_rt " +
|
" GROUP BY batt_state ORDER BY batt_state";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Rtstate_rt rts=new Rtstate_rt();
|
rts.setBatt_state(rs.getInt("batt_state"));
|
rts.setNum(rs.getInt("stateNum"));
|
list.add(rts);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
|
}
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
public static void main(String[] args) {
|
Rtstate_rtImpl rimpl=new Rtstate_rtImpl();
|
/*List<Rtstate_rt> list=rimpl.serchDisOrChargr();
|
for (Rtstate_rt r : list) {
|
System.out.println(r);
|
}*/
|
List<Rtstate_rt> list=rimpl.serchBattStateRate();
|
for (Rtstate_rt r : list) {
|
System.out.println(r);
|
}
|
}
|
}
|
