From 1c25524f12918b63af745a79f59d0e94f1ec6d3c Mon Sep 17 00:00:00 2001 From: 81041 <81041@192.168.10.16> Date: 星期二, 11 十二月 2018 15:25:44 +0800 Subject: [PATCH] 修改 --- gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java | 66 +++++++++++++++++++++++--------- 1 files changed, 47 insertions(+), 19 deletions(-) diff --git a/gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java b/gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java index 26ef434..dff7238 100644 --- a/gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java +++ b/gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java @@ -51,7 +51,7 @@ Connection conn=DBUtil.getConn(); String numberSql="SELECT FOUND_ROWS() number";//瀛樻斁鎬绘暟 String sql="select SQL_CALC_FOUND_ROWS distinct station_id,dev_id,record_datetime,station_stat,station_poff_start_time,station_fadian_start_time" + - " ,station_diaozhan_start_time,station_temp,station_damp,station_dooropen_start_time,station_xuhang_start_time" + + " ,station_diaozhan_start_time,station_temp,station_damp,station_dooropen_start_time,station_xuhang_start_time,station_xuhang_end_time" + " ,tb_battinf.stationname,tb_battinf.stationname1,tb_battinf.stationname2,tb_battinf.stationname3,tb_battinf.stationname5 " + " from db_ram_db.tb_bts_station_state,db_battinf.tb_battinf " + " where tb_bts_station_state.dev_id=db_battinf.tb_battinf.FBSDeviceId " + @@ -154,6 +154,7 @@ b.setStation_damp(rs.getFloat("station_damp")); b.setStation_dooropen_start_time(rs.getTimestamp("station_dooropen_start_time")); b.setStation_xuhang_start_time(rs.getTimestamp("station_xuhang_start_time")); + b.setStation_xuhang_end_time(rs.getTimestamp("station_xuhang_end_time")); b.setStationName(rs.getString("stationName")); b.setStationName1(rs.getString("stationName1")); b.setStationName2(rs.getString("stationName2")); @@ -182,13 +183,9 @@ public int serchByState(Object obj) { User_inf uinf=(User_inf) obj; String sql=" select count(*) as nums from db_ram_db.tb_bts_station_state where station_stat&2>1 " + - " and tb_bts_station_state.station_id in (" + - " select distinct db_battinf.tb_battinf.stationid " + - " from db_battinf.tb_battinf " + - " left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " + - " left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + - " left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + - " where db_user.tb_user_inf.uid=? ) " ; + " and tb_bts_station_state.station_id in (" + + " select distinct db_user.tb_user_battgroup_baojigroup_battgroup.StationId from db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr where db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id=db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id and db_user.tb_user_battgroup_baojigroup_usr.uId=?" + + " ) "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() { public List getResults(ResultSet rs) { @@ -215,12 +212,8 @@ User_inf uinf=(User_inf) obj; String sql=" select count(*) as nums from db_ram_db.tb_bts_station_state where station_stat&32>1 " + " and tb_bts_station_state.station_id in (" + - " select distinct db_battinf.tb_battinf.stationid " + - " from db_battinf.tb_battinf " + - " left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " + - " left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + - " left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + - " where db_user.tb_user_inf.uid=? ) " ; + " select distinct db_user.tb_user_battgroup_baojigroup_battgroup.StationId from db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr where db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id=db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id and db_user.tb_user_battgroup_baojigroup_usr.uId=?" + + " ) "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() { public List getResults(ResultSet rs) { @@ -242,11 +235,40 @@ } return nums; } - //鏌ヨ褰撳墠鏈烘埧鍋滅數鏁�(鏍规嵁station_id ) + //鏌ヨ鍏蜂綋鏌愭満鎴垮仠鐢垫暟(鏍规嵁station_id ) public int serchByStationId(Object obj) { BattMap_information binformation=(BattMap_information) obj; String sql="select count(num) as nums from db_ram_db.tb_bts_station_state " + " where station_stat&2>1 " + + " and station_id=? " + + " limit 1 "; + //System.out.println(sql); + List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binformation.getStationId()}, new CallBack() { + + public List getResults(ResultSet rs) { + List list=new ArrayList(); + try { + while(rs.next()){ + int nums=rs.getInt("nums"); + list.add(nums); + } + } catch (SQLException e) { + e.printStackTrace(); + } + return list; + } + }); + int nums=0;//鏈�鍚庣殑缁撴灉 + if(list!=null&&list.size()>0){ + nums=(Integer) list.get(list.size()-1); + } + return nums; + } + //鏌ヨ鍏蜂綋鏌愭満鎴挎帀绔欐暟(鏍规嵁station_id ) + public int serchByStationId_diaozhan(Object obj) { + BattMap_information binformation=(BattMap_information) obj; + String sql="select count(num) as nums from db_ram_db.tb_bts_station_state " + + " where station_stat&32>1 " + " and station_id=? " + " limit 1 "; //System.out.println(sql); @@ -282,8 +304,9 @@ binf.setStationName1(""); binf.setStationName2(""); binf.setStationName3(""); + binf.setStationName5(""); binf.setStationId(""); - binf.setBattGroupNum(36); + binf.setBattGroupNum(62); User_inf uinf=new User_inf(); uinf.setUId(1002); Page p=new Page(); @@ -295,12 +318,17 @@ //System.out.println(bs.getStation_stat_diaozhan()+" "+bs.getStation_stat_dooropen()+" "+bs.getStation_stat_fadian()+" "+bs.getStation_stat_xuhang()+" "+bs.getStation_stat_poff()); System.out.println(bs); } - /*int nums=bimpl.serchByState(uinf);*/ + //System.out.println(list.size()); + //int nums=bimpl.serchByState(uinf); /*BattMap_information bm=new BattMap_information(); bm.setStationId("42000570"); int nums=bimpl.serchByStationId(bm);*/ - int nums=bimpl.serchByState_diaozhan(uinf); - System.out.println(nums); + //int nums=bimpl.serchByState_diaozhan(uinf); + /*BattMap_information bm=new BattMap_information(); + bm.setStationId("42000366"); + int nums=bimpl.serchByStationId_diaozhan(bm); + + System.out.println(nums);*/ } -- Gitblit v1.9.1