From 9af919c65d23a09b670463b7f51e8939ee5cb526 Mon Sep 17 00:00:00 2001 From: 81041 <81041@192.168.10.31> Date: 星期三, 31 十月 2018 13:44:43 +0800 Subject: [PATCH] 电池组统计分析查询和蓄电池组后评估加区县 --- gx_tieta/src/com/fgkj/dao/impl/Batttestdata_infDAOImpl.java | 48 +++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 43 insertions(+), 5 deletions(-) diff --git a/gx_tieta/src/com/fgkj/dao/impl/Batttestdata_infDAOImpl.java b/gx_tieta/src/com/fgkj/dao/impl/Batttestdata_infDAOImpl.java index a16dee8..1fd9d7b 100644 --- a/gx_tieta/src/com/fgkj/dao/impl/Batttestdata_infDAOImpl.java +++ b/gx_tieta/src/com/fgkj/dao/impl/Batttestdata_infDAOImpl.java @@ -449,7 +449,7 @@ " WHERE tb_batttestdata_inf.test_starttime>=? and tb_batttestdata_inf.test_starttime<=? " + " and db_batt_testdata.tb_batttestdata_inf.data_available=1 "; //鏈烘埧缁存姢鍖洪�夋嫨 - String stationSql=" AND db_battinf.tb_battinf.stationname like ? and db_battinf.tb_battinf.stationname1 like ? "; + String stationSql=" AND db_battinf.tb_battinf.stationname like ? and db_battinf.tb_battinf.stationname1 like ? and db_battinf.tb_battinf.stationname2 like ? "; baseSql+=stationSql; String endSql=" ORDER BY db_battinf.tb_battinf.stationid asc,tb_batttestdata_inf.BattGroupId asc,db_batt_testdata.tb_batttestdata_inf.test_starttime desc "; sql=baseSql+endSql; @@ -458,7 +458,7 @@ List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ binf.getBattProductDate(),binf.getBattProductDate1(), - "%"+binf.getStationName()+"%","%"+binf.getStationName1()+"%" + "%"+binf.getStationName()+"%","%"+binf.getStationName1()+"%","%"+binf.getStationName2()+"%" }, new CallBack() { public List getResults(ResultSet rs) { @@ -520,7 +520,7 @@ "LEFT OUTER JOIN db_ram_db.cmcc_power_data ON db_battinf.tb_battinf.fbsdeviceid=cmcc_power_data.dev_id " + "where "; //鏈烘埧缁存姢鍖洪�夋嫨 - String stationSql=" db_battinf.tb_battinf.stationname like ? AND db_battinf.tb_battinf.stationname1 like ? "; + String stationSql=" db_battinf.tb_battinf.stationname like ? AND db_battinf.tb_battinf.stationname1 like ? AND db_battinf.tb_battinf.stationname2 like ? "; baseSql+=stationSql; //鐢垫睜鐘舵�� String stateSqlT=" AND batt_state=? "; @@ -536,7 +536,7 @@ String orderSql=" order by db_battinf.tb_battinf.stationid asc"; sql=baseSql+endSql+orderSql; //System.out.println(sql); - List<Batt_State> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{"%"+binf.getStationName()+"%","%"+binf.getStationName1()+"%" + List<Batt_State> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{"%"+binf.getStationName()+"%","%"+binf.getStationName1()+"%","%"+binf.getStationName2()+"%" ,binf.getNum()}, new CallBack() { public List getResults(ResultSet rs) { @@ -957,7 +957,45 @@ }); return list; } - + //鐢垫睜閰嶇粍鐢ㄥ埌(绛涢�夊嚭鏈夋晥鐨勬渶杩戠殑涓�娆¤妭鑳芥斁鐢垫妧鏈�) + public List Batt_selecteffectiveBatt(Object obj,float param){ + BattInf binf=(BattInf) obj; + String sql="SELECT distinct battGroupId,test_starttime,record_time,test_cap,max_monvol,min_monvol,test_record_count,test_curr FROM db_batt_testdata.tb_batttestdata_inf " + + " WHERE BattGroupId =? " + + " AND data_available=1 AND data_new = 1 AND " + + " test_type = 3 AND test_starttype = 3 AND " //鍒ゆ柇鏄妭鑳芥斁鐢� + + " abs(test_cap) >?*? " //鍒ゆ柇娴嬭瘯鏁版嵁瀹归噺鏄惁鏈夋晥 + + " ORDER BY test_record_count DESC LIMIT 1 "; + + List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId(),binf.getMonCapStd(),param}, new CallBack() { + + public List getResults(ResultSet rs) { + List list=new ArrayList(); + try { + while(rs.next()){ + Batttestdata_inf tinf=new Batttestdata_inf(); + tinf.setBattGroupId(rs.getInt("battGroupId")); + if(rs.getString("test_starttime")!=null) + tinf.setTest_starttime(rs.getTimestamp("test_starttime")); + if(rs.getString("record_time")!=null) + tinf.setRecord_time(rs.getTimestamp("record_time")); + tinf.setTest_cap(rs.getFloat("test_cap")); + tinf.setMax_monvol(rs.getFloat("max_monvol")); + tinf.setMin_monvol(rs.getFloat("min_monvol")); + tinf.setTest_record_count(rs.getInt("test_record_count")); + tinf.setTest_curr(rs.getFloat("test_curr")); + list.add(tinf); + } + } catch (SQLException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return list; + } + }); + return list; + } + public static void main(String[] args) throws ParseException { Batttestdata_infDAOImpl bimpl=new Batttestdata_infDAOImpl(); Batttestdata_inf tdata=new Batttestdata_inf(); -- Gitblit v1.9.1