~whychwj/haha.git

parent: 1bc9f92c | 补丁 | 提交 | show whitespace

81041

2018-11-26 b887e1187f0e82820bae847386331b963130beed

//地图右下角显示出已安装机房中(停电数/掉站数/机房告警数/落后单体机房数)

5个文件已修改

	gx_tieta/src/com/fgkj/actions/ram/Bts_station_stateAction.java	8 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	gx_tieta/src/com/fgkj/dao/impl/BadBatt_monImpl.java	36 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	gx_tieta/src/com/fgkj/dao/impl/Battalarm_dataDAOImpl.java	35 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java	22 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	gx_tieta/src/com/fgkj/services/ram/Bts_station_stateService.java	18 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

 gx_tieta/src/com/fgkj/actions/ram/Bts_station_stateAction.java

@@ -34,7 +34,13 @@
        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;

    }

    

    

    


 gx_tieta/src/com/fgkj/dao/impl/BadBatt_monImpl.java

@@ -378,7 +378,37 @@
        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);

    }






 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);

    }

}


 gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java

@@ -183,12 +183,8 @@
        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=?  ) " ;

                " 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);

    }




 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;

    }

    
}

			@@ -34,7 +34,13 @@
			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;
			}

			@@ -378,7 +378,37 @@
			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);
			}

			@@ -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);
			}
			}

			@@ -183,12 +183,8 @@
			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=? ) " ;
			" 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);
			}

			@@ -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;
			}

			}