设备实时告警和历史实时告警加区县

81041

2018-11-01 162b1ec7816f035de05ef93ba432e64b95c96b7b

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

@@ -306,7 +306,7 @@
      String sql="";

      String baseSql=" SELECT SQL_CALC_FOUND_ROWS distinct tb_devalarm_data.num,dev_id,dev_ip,alm_type,alm_level,alm_start_time,alm_end_time," +

            " alm_is_confirmed,alm_confirmed_time,alm_cleared_type," +

            " db_battinf.tb_battinf.stationName,db_battinf.tb_battinf.FbsDeviceName  " +

            " db_battinf.tb_battinf.stationName,db_battinf.tb_battinf.stationName5,db_battinf.tb_battinf.FbsDeviceName  " +

            " FROM db_alarm.tb_devalarm_data,db_battinf.tb_battinf " +

            " WHERE  " +

            " tb_devalarm_data.dev_id=db_battinf.tb_battinf.FbsDeviceId " ;

@@ -336,6 +336,14 @@
         baseSql+=stationSql2T;

      }else{

         baseSql+=stationSql2F;

      }

      //用于区县

      String stationSql5T=" and stationname5!=? ";//全部

      String stationSql5F=" and stationname5=? ";

      if(ddata.getStationName5().equals("")){

         baseSql+=stationSql5T;

      }else{

         baseSql+=stationSql5F;

      }

      //用于故障事件

      String almTypeT=" and alm_type!=? ";//全部

@@ -378,7 +386,7 @@
                  

                  ddata.setDev_name(rs.getString("FbsDeviceName"));

                  ddata.setStationName(rs.getString("stationName"));                  

						
                  ddata.setStationName5(rs.getString("stationName5"));		
                  list.add(ddata);

               }

            } catch (SQLException e) {

@@ -582,6 +590,52 @@
      });

      return list;

    }

  //告警发声(30秒之内的告警)

    public List serchIn30(Object obj){

       User_inf uinf=(User_inf) obj;

       String sql="select distinct db_alarm.tb_devalarm_data.dev_id,db_battinf.tb_battinf.stationid,db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.stationid,db_battinf.tb_battinf.fbsdevicename,dev_ip,alm_type,alm_start_time " +

             "  from db_alarm.tb_devalarm_data,db_battinf.tb_battinf" +

             "  where alm_cleared_type=0 " +

             "  and db_alarm.tb_devalarm_data.dev_id=db_battinf.tb_battinf.fbsdeviceid " +

             "  and (UNIX_TIMESTAMP(NOW())-UNIX_TIMESTAMP(alm_start_time))<"+AlarmDaoFactory.alarm_voice_timelong ;

       //用户管理

      String userSql=" and 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=?" +

            " ) ";

      sql+=userSql;	
      String orderSql="  order by alm_start_time desc ";

      sql+=orderSql;

       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()){

                  Batt_devalarm_data ddata=new Batt_devalarm_data();

                  ddata.setNum(1);//1表示设备告警

                  ddata.setDev_id(rs.getInt("dev_id"));

                  ddata.setDev_ip(rs.getString("dev_ip"));

                  ddata.setDev_name(rs.getString("fbsdevicename"));

                  ddata.setStationName(rs.getString("stationName"));

                  ddata.setStationId(rs.getString("stationId"));

                  ddata.setAlm_type(rs.getInt("alm_type"));

                  ddata.setAlm_start_time(rs.getTimestamp("alm_start_time"));

                  String ddataStr=""+ddata.getStationName()   // 机房名称

                        +"在"+ActionUtil.chageDateToString(ddata.getAlm_start_time(), ActionUtil.time_yyyyMMddHHmmss)   // 告警开始时间

                        +"出现了"+AlarmDaoFactory.getdevName(ddata.getAlm_type()) // 告警类型名称

                        +"告警!";

                  ddata.setNote(ddataStr);

                  list.add(ddata);

               }

            } catch (SQLException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

            }

            return list;

         }

      });

      return list;

    }

    //项目下方的滚动，查询该设备告警的实时信息

    public List serchDev_alarm(Object obj){

       Batt_devalarm_data ddata=(Batt_devalarm_data) obj;

@@ -643,10 +697,11 @@
      bmd.setBinf(binf);

      bmd.setPage(page);

      bmd.setUinf(uinf);

      List<Batt_devalarm_data> list=dimpl.serchByInfo(ddata);

      List list=dimpl.serchIn30(uinf);

      /*List<Batt_devalarm_data> list=dimpl.serchByInfo(ddata);

      for (Batt_devalarm_data b : list) {

         System.out.println(b);

      }

      }*/

      //List<Batt_devalarm_data> list = dimpl.serchByCondition(bmd);

      System.out.println(list.size());

   }