电池告警实时和设备告警实时筛选出未安装的

81041

2018-11-02 2383e6ae0913698f4de001c2dd91641967549985

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

@@ -306,10 +306,10 @@
      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 " ;

            " tb_devalarm_data.dev_id=db_battinf.tb_battinf.FbsDeviceId  and tb_battinf.station_install=1 " ;

      //设备实时告警

      String alarmTypeSql=" AND alm_cleared_type=0 ";

      baseSql+=alarmTypeSql;

@@ -337,6 +337,14 @@
      }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!=? ";//全部

      String almTypeF=" and alm_type=? ";

@@ -358,7 +366,7 @@
      //分页

      String limitSql=" LIMIT ?,? ";

      sql=baseSql+endSql+limitSql;

      List<Batt_devalarm_data> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{ddata.getStationName1(),ddata.getStationName(),ddata.getStationName2(),ddata.getAlm_type(),uinf.getUId(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {

      List<Batt_devalarm_data> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{ddata.getStationName1(),ddata.getStationName(),ddata.getStationName2(),ddata.getStationName5(),ddata.getAlm_type(),uinf.getUId(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {

         

         public List getResults(ResultSet rs) {

            List list=new ArrayList();

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

@@ -436,7 +444,7 @@
            " where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId   " +

            " and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id  " +

            " and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid  " +

            " and db_user.tb_user_inf.uid=? ) ";

            " and db_user.tb_user_inf.uid=?  and tb_battinf.station_install=1 ) ";

      //System.out.println(sql);

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() {

         

@@ -542,7 +550,7 @@
       String sql="select distinct db_alarm.tb_devalarm_data.dev_id,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 db_alarm.tb_devalarm_data.dev_id=db_battinf.tb_battinf.fbsdeviceid and tb_battinf.station_install=1 " +

             "  and  db_alarm.tb_devalarm_data.dev_id  in (select distinct db_battinf.tb_battinf.FbsDeviceId " +

            " from db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf   " +

            " where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId   " +

@@ -588,7 +596,7 @@
       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 db_alarm.tb_devalarm_data.dev_id=db_battinf.tb_battinf.fbsdeviceid and tb_battinf.station_install=1 " +

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

       //用户管理

      String userSql=" and tb_battinf.StationId in(" +

@@ -633,7 +641,7 @@
       Batt_devalarm_data ddata=(Batt_devalarm_data) obj;

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

             "  from db_alarm.tb_devalarm_data,db_battinf.tb_battinf " +

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

             "  where db_alarm.tb_devalarm_data.dev_id=db_battinf.tb_battinf.fbsdeviceid and tb_battinf.station_install=1 " +

             "  and  db_alarm.tb_devalarm_data.dev_id=? and alm_type=? and alm_start_time=? ";

       List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ddata.getDev_id(),ddata.getAlm_type(),ddata.getAlm_start_time()}, new CallBack() {

         

@@ -671,6 +679,8 @@
      ddata.setAlm_start_time1(ActionUtil.getSimpDate(date2));

        ddata.setStationName1("");

        ddata.setStationName("");

        ddata.setStationName2("");

        ddata.setStationName5("");

        ddata.setAlm_type(0);

      Page page = new Page();

      page.setPageCurr(1);

@@ -683,19 +693,23 @@
      BattInf binf = new BattInf();

      binf.setStationName("");

      binf.setStationName1("");

      binf.setStationName2("");

      binf.setStationName5("");

      binf.setBattProductDate(ActionUtil.getSimpDate(date1));

      binf.setBattProductDate1(ActionUtil.getSimpDate(date2));



      bmd.setBinf(binf);

      bmd.setPage(page);

      bmd.setUinf(uinf);

      List list=dimpl.serchIn30(uinf);

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

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

      int nums=dimpl.searchNums(uinf);

      System.out.println(nums);

   }