D:/workspace/chenjingjing/git/gx_tieta/gx_tieta/.gitignore
2019-01-18 864e4772eea5e0a589b6f6797d0695a3b3dd225e
gx_tieta/src/com/fgkj/dao/impl/Battalarm_dataDAOImpl.java
@@ -552,6 +552,62 @@
         
         return list;
      }
   // 3.1电池告警实时查询<***********跨域专用**************>
   public List serchByCondition_ky(Object obj) {
         BattInf binf=(BattInf) obj;
         String sql="";
         String baseSql = "select  distinct db_alarm.tb_battalarm_data.BattGroupId,db_alarm.tb_battalarm_data.num,alm_signal_id,db_alarm.tb_battalarm_data.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time  "
               + " ,stationname,stationname5,battgroupname"
               + " from db_alarm.tb_battalarm_data,db_battinf.tb_battinf  "
               + " where alm_cleared_type=0 ";
         //用于电池组条件
         String idSqlT=" and db_battinf.tb_battinf.battgroupid!=? and db_alarm.tb_battalarm_data.battgroupid=db_battinf.tb_battinf.battgroupid ";//全部
         String idSqlF=" and db_battinf.tb_battinf.battgroupid=?  and db_alarm.tb_battalarm_data.battgroupid=db_battinf.tb_battinf.battgroupid ";
          if(binf.getBattGroupId()==0){
            baseSql+=idSqlT;
         }else{
            baseSql+=idSqlF;
         }
         String endSql="order by db_alarm.tb_battalarm_data.BattGroupId,db_alarm.tb_battalarm_data.alm_start_time desc,db_alarm.tb_battalarm_data.monnum asc ";
         sql=baseSql+endSql;
         List  list = DAOHelper.executeQuery(sql,DBUtil.getConn(),new Object[] {binf.getBattGroupId()}, new CallBack() {
                  public List getResults(ResultSet rs) {
                     List list = new ArrayList();
                     try {
                        while (rs.next()) {
                           String name="未知";         //存放告警名称
                           String type="未知";         //存放告警等级
                           Battalarm_data adata = new Battalarm_data();
                           adata.setNum(rs.getInt("num"));
                           adata.setBattGroupId(rs.getInt("battGroupId"));
                           adata.setAlm_signal_id(rs.getInt("alm_signal_id"));
                           adata.setMonNum(rs.getInt("monNum"));
                           adata.setAlm_value(rs.getFloat("alm_value"));
                           adata.setAlm_level(rs.getInt("alm_level"));
                           adata.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));
                           adata.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));
                           adata.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                           adata.setAlm_end_time(rs.getTimestamp("alm_end_time"));
                           adata.setStationname(rs.getString("stationName"));
                           adata.setBattGroupName(rs.getString("battGroupName"));
                           //battinf中的StationName8,StationName9存放告警名称和等级
                           name=AlarmDaoFactory.getAlarmName(adata.getAlm_signal_id());
                           adata.setAlarmname(name);
                           type=AlarmDaoFactory.getAlarmType(adata.getAlm_level());
                           adata.setAlarmtype(type);
                           list.add(adata);
                        }
                     } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                     }
                     return list;
                  }
               });
         return list;
      }
   // 3.2电池告警
      /*
    * 条件所存放的位置前台:tb_batt_maint_inf 
@@ -1296,25 +1352,21 @@
      return list;   
   }*/
   public List serchAlm(Object obj){
      Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
      Battalarm_data adata=bmd.getAdata();
      BattInf binf=bmd.getBinf();
      User_inf uinf=bmd.getUinf();
      User_inf uinf=(User_inf) obj;
      String sql="select count(num) as number,alm_id " +
            "from db_alarm.tb_battalarm_data  " +
            "where  " +
            "alm_cleared_type=0  " ;
        //根据城市选取
      String citySql=" and tb_battalarm_data.BattGroupId in (select distinct db_battinf.tb_battinf.battgroupid " +
            " 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   " +
            " 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_battinf.tb_battinf.stationname like ? and tb_battinf.station_install=1  )  " +
      String citySql=" and tb_battalarm_data.BattGroupId in ( select distinct db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId " +
            " 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=? )  " +
            " and tb_battalarm_data.BattGroupId in (select distinct db_battinf.tb_battinf.BattGroupId  from db_battinf.tb_battinf where  station_install=1) " +
            " GROUP BY(alm_id) ";
      sql+=citySql;
      //System.out.println(sql);
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId(),"%"+binf.getStationName()+"%"}, new CallBack() {
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() {
         
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
@@ -1934,7 +1986,7 @@
      
      Page p = new Page();
      p.setPageCurr(1);
      p.setPageSize(10);
      p.setPageSize(10000);
      /*条件所存放的位置前台:tb_batt_maint_inf 
       * 在线电压:usr_id 
       * 组端电压:fault_type_id
@@ -1949,7 +2001,7 @@
      Date date1 = sdf.parse("2000-01-01");
      Date date2 = sdf.parse("2020-01-01");
      Batt_maint_inf mainf=new Batt_maint_inf();
      mainf.setUsr_id(0);
      mainf.setUsr_id(1002);
      mainf.setFault_type_id(119002);
      mainf.setFault_level(119003);
      mainf.setRecord_uid(119004);
@@ -1975,6 +2027,9 @@
      
       binf.setStationName("");
      binf.setStationName1("");
      binf.setStationName2("");
      binf.setStationName3("");
      binf.setStationName5("");
      binf.setBattGroupId(0);
      
      
@@ -1987,12 +2042,12 @@
      bmd.setBinf(binf);
        bmd.setUinf(uinf);
        
      //List<Batt_Maint_Dealarm> list = bimp.serchByCondition(bmd);
      /*  List<Batt_Maint_Dealarm> list = bimp.serchByInfo(bmd);
      List<Batt_Maint_Dealarm> list = bimp.serchByCondition(bmd);
        //List<Batt_Maint_Dealarm> list = bimp.serchByInfo(bmd);
      for (Batt_Maint_Dealarm b : list) {
         System.out.println(b);
      }
      System.out.println(list.size());*/
      System.out.println(list.size());
       // List list=bimp.serchRealTime(uinf);
       // System.out.println(list);
        /*List<Integer> list = bimp.serchGood(uinf);
@@ -2001,7 +2056,11 @@
      }*/
        //List list=bimp.serchIn30(uinf);
        //System.out.println(list.size());
        int nums=bimp.searchAlarmInStation(uinf);
        System.out.println(nums);
        /*int nums=bimp.searchAlarmInStation(uinf);
        System.out.println(nums);*/
        /*List<Battalarm_data> list = bimp.serchByCondition_ky(binf);
        for (Battalarm_data b : list) {
         System.out.println(b);
      }*/
   }
}