From b887e1187f0e82820bae847386331b963130beed Mon Sep 17 00:00:00 2001 From: 81041 <81041@192.168.10.9> Date: 星期一, 26 十一月 2018 11:03:13 +0800 Subject: [PATCH] //地图右下角显示出已安装机房中(停电数/掉站数/机房告警数/落后单体机房数) --- gx_tieta/src/com/fgkj/services/ram/Bts_station_stateService.java | 18 ++++++ gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java | 24 ++----- gx_tieta/src/com/fgkj/dao/impl/BadBatt_monImpl.java | 40 ++++++++++++- gx_tieta/src/com/fgkj/actions/ram/Bts_station_stateAction.java | 10 ++ gx_tieta/src/com/fgkj/dao/impl/Battalarm_dataDAOImpl.java | 37 +++++++++++- 5 files changed, 104 insertions(+), 25 deletions(-) diff --git a/gx_tieta/src/com/fgkj/actions/ram/Bts_station_stateAction.java b/gx_tieta/src/com/fgkj/actions/ram/Bts_station_stateAction.java index d3a110f..7537c98 100644 --- a/gx_tieta/src/com/fgkj/actions/ram/Bts_station_stateAction.java +++ b/gx_tieta/src/com/fgkj/actions/ram/Bts_station_stateAction.java @@ -27,14 +27,20 @@ return SUCCESS; } - //鏈烘埧鏂數缁熻(棣栭〉涓婄殑楗肩姸鍥�) + //鏈烘埧鏂數缁熻(棣栭〉涓婄殑楗肩姸鍥�) public String serchPowerOff(){ User_inf uinf=(User_inf) ActionUtil.getUser(); ServiceModel model = service.serchPowerOff(uinf); result = tojson(model); return SUCCESS; } - + //鍦板浘鍙充笅瑙掓樉绀哄嚭宸插畨瑁呮満鎴夸腑(鍋滅數鏁�/鎺夌珯鏁�/鏈烘埧鍛婅鏁�/钀藉悗鍗曚綋鏈烘埧鏁�) + public String serchStationState(){ + User_inf uinf=(User_inf) ActionUtil.getUser(); + ServiceModel model = service.serchStationState(uinf); + result = tojson(model); + return SUCCESS; + } diff --git a/gx_tieta/src/com/fgkj/dao/impl/BadBatt_monImpl.java b/gx_tieta/src/com/fgkj/dao/impl/BadBatt_monImpl.java index 0d3825a..04aeb5e 100644 --- a/gx_tieta/src/com/fgkj/dao/impl/BadBatt_monImpl.java +++ b/gx_tieta/src/com/fgkj/dao/impl/BadBatt_monImpl.java @@ -377,8 +377,38 @@ } return list; } - - + + //鏌ヨ瀛樺湪钀藉悗鍗曚綋寰楁満鎴夸釜鏁� + public int searchBadBattInStation(Object obj) { + User_inf uinf=(User_inf) obj; + String sql=" select count(distinct db_battinf.tb_battinf.stationid) as nums from db_battinf.tb_battinf where station_install=1 " + + " and db_battinf.tb_battinf.battgroupid in (select distinct tb_badbatt_mon.BattGroupId from web_site.tb_badbatt_mon) " + + " and db_battinf.tb_battinf.stationid 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=? ) "; + //System.out.println(sql); + List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() { + + public List getResults(ResultSet rs) { + List list=new ArrayList(); + try { + while(rs.next()){ + list.add(rs.getInt("nums")); + } + } catch (SQLException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return list; + } + }); + int nums=0;//鏈�鍚庣殑缁撴灉 + if(list!=null&&list.size()>0){ + nums=(Integer) list.get(list.size()-1); + } + return nums; + } public static void main(String[] args) throws ParseException { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); Date date1 = sdf.parse("2000-01-01"); @@ -410,10 +440,12 @@ bmd.setBinf(binf); bmd.setPage(page); bmd.setUinf(uinf); - List<Batt_Maint_Dealarm> list=bimpl.serchByInfo(bmd); + /*List<Batt_Maint_Dealarm> list=bimpl.serchByInfo(bmd); for (Batt_Maint_Dealarm b : list) { System.out.println(b); - } + }*/ + int nums=bimpl.searchBadBattInStation(uinf); + System.out.println(nums); } diff --git a/gx_tieta/src/com/fgkj/dao/impl/Battalarm_dataDAOImpl.java b/gx_tieta/src/com/fgkj/dao/impl/Battalarm_dataDAOImpl.java index 97f1712..e6ffb26 100644 --- a/gx_tieta/src/com/fgkj/dao/impl/Battalarm_dataDAOImpl.java +++ b/gx_tieta/src/com/fgkj/dao/impl/Battalarm_dataDAOImpl.java @@ -1898,7 +1898,36 @@ return list; } - + //鏌ヨ瀛樺湪鐢垫睜鍛婅鐨勬満鎴夸釜鏁� + public int searchAlarmInStation(Object obj){ + User_inf uinf=(User_inf) obj; + String sql=" select count(distinct db_battinf.tb_battinf.stationid) as nums from db_battinf.tb_battinf where station_install=1 " + + " and db_battinf.tb_battinf.battgroupid in (select distinct db_alarm.tb_battalarm_data.battgroupid from db_alarm.tb_battalarm_data) " + + " and db_battinf.tb_battinf.stationid 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) { + List list=new ArrayList(); + try { + while(rs.next()){ + list.add(rs.getInt("nums")); + } + } catch (SQLException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return list; + } + }); + int nums=0;//鏈�鍚庣殑缁撴灉 + if(list!=null&&list.size()>0){ + nums=(Integer) list.get(list.size()-1); + } + return nums; + } public static void main(String[] args) throws ParseException { Battalarm_dataDAOImpl bimp = new Battalarm_dataDAOImpl(); @@ -1970,7 +1999,9 @@ for (int num : list) { System.out.println(num); }*/ - List list=bimp.serchIn30(uinf); - System.out.println(list.size()); + //List list=bimp.serchIn30(uinf); + //System.out.println(list.size()); + int nums=bimp.searchAlarmInStation(uinf); + System.out.println(nums); } } 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..e8d8225 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 @@ -182,13 +182,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 +211,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,7 +234,7 @@ } 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 " + @@ -295,11 +287,11 @@ //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);*/ + 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); + //int nums=bimpl.serchByState_diaozhan(uinf); System.out.println(nums); } diff --git a/gx_tieta/src/com/fgkj/services/ram/Bts_station_stateService.java b/gx_tieta/src/com/fgkj/services/ram/Bts_station_stateService.java index 1416cc3..3f27a1d 100644 --- a/gx_tieta/src/com/fgkj/services/ram/Bts_station_stateService.java +++ b/gx_tieta/src/com/fgkj/services/ram/Bts_station_stateService.java @@ -4,9 +4,12 @@ import com.fgkj.dao.BaseDAO; import com.fgkj.dao.BaseDAOFactory; +import com.fgkj.dao.impl.BadBatt_monImpl; import com.fgkj.dao.impl.BattInfImpl; import com.fgkj.dao.impl.BattPower_offImpl; +import com.fgkj.dao.impl.Battalarm_dataDAOImpl; import com.fgkj.dao.impl.ram.Bts_station_stateImpl; +import com.fgkj.dto.Battalarm_data; import com.fgkj.dto.ServiceModel; public class Bts_station_stateService { @@ -47,4 +50,19 @@ model.setCode(dianzhanNum); return model; } + //鍦板浘鍙充笅瑙掓樉绀哄嚭宸插畨瑁呮満鎴夸腑(鍋滅數鏁�/鎺夌珯鏁�/鏈烘埧鍛婅鏁�/钀藉悗鍗曚綋鏈烘埧鏁�) + public ServiceModel serchStationState(Object obj){ + int powerNum=((Bts_station_stateImpl)dao).serchByState(obj); //鍋滅數瀹炴椂鏁� + int dianzhanNum=((Bts_station_stateImpl)dao).serchByState_diaozhan(obj); //鎺夌珯瀹炴椂鏁� + int badbattNum=(new BadBatt_monImpl()).searchBadBattInStation(obj);//瀛樺湪钀藉悗鍗曚綋鐨勬満鎴夸釜鏁� + int alarmNum=(new Battalarm_dataDAOImpl()).searchAlarmInStation(obj);//瀛樺湪鐢垫睜鍛婅鐨勬満鎴夸釜鏁� + int devNum=(new BattInfImpl()).serchByDeviceId(obj); //鎬昏澶囨暟 + model.setSum(powerNum);//鍋滅數瀹炴椂鏁� + model.setCode(dianzhanNum);//鎺夌珯瀹炴椂鏁� + model.setNewsum(devNum); //鎬昏澶囨暟 + model.setMsgN(String.valueOf(badbattNum));//瀛樺湪钀藉悗鍗曚綋鐨勬満鎴夸釜鏁� + model.setMsg(String.valueOf(alarmNum));//瀛樺湪鐢垫睜鍛婅鐨勬満鎴夸釜鏁� + return model; + } + } -- Gitblit v1.9.1