81041
2019-01-11 d04cea72d0c721f9e7e65d3074c5546ac6eb594f
gx_tieta/src/com/fgkj/dao/impl/BattInfImpl.java
@@ -460,10 +460,11 @@
      }
      return dev_id;
   }
    //判断新增的电池组是否存在
    //判断新增的机房是否存在
   public List judgeBatt(Object obj){
      BattInf binf=(BattInf) obj;
      String sql="select distinct stationid from db_battinf.tb_battinf where stationname=? limit 1";
      String sql="select distinct(StationId) "
             + "from db_battinf.tb_battinf where stationname=? limit 1";
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getStationName()}, new CallBack() {
         
         public List getResults(ResultSet rs) {
@@ -482,7 +483,8 @@
      });
      return list;
   }
    //判断新增的电池组是否存在
    //判断新增的机房是否存在
   public boolean judgeBattInOrNot(Object obj){
      BattInf binf=(BattInf) obj;
      String sql="select distinct stationid from db_battinf.tb_battinf where stationname=? limit 1";
@@ -4495,7 +4497,7 @@
      //Page page=binf.getPage();
      /*Connection conn=DBUtil.getConn();
      String numberSql=" SELECT FOUND_ROWS() number";SQL_CALC_FOUND_ROWS*/
      String sql=" select  distinct(StationId),StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FBSDeviceId,"
      String sql=" select  distinct(db_battinf.tb_battinf.StationId),StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FBSDeviceId,"
            + "FBSDeviceName,battGroupNum" +
             ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,Load_curr,DisCurrMax,montmpstd,floatVolLevel,offlineVolLevel,battFloatCurrent"
             + ",db_ram_db.tb_fbs9100_state.dev_version  "
@@ -4505,7 +4507,7 @@
            //+ "  limit ?,? ";StationName1 like ? and StationName2 like ? and StationName3 like ? and StationName5 like ? "
      //,(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize(),"%"+binf.getStationName1()+"%","%"+binf.getStationName2()+"%","%"+binf.getStationName3()+"%",
      //条件
      String sql0=" and stationid=? "; //具体机房
      String sql0=" and db_battinf.tb_battinf.stationid=? "; //具体机房
      String sql1=" and stationname1=? ";//省
      String sql2=" and stationname2=? ";//市
      String sql5=" and stationname5=? ";//区县
@@ -4594,14 +4596,130 @@
      }*/
      return list;
   }
   //批量设置系统参数时,根据省市区,电池单体型号(伏数),组数筛选出电池组<还需要获取实际容量>
   public List serchBySys_param(Object obj) {
      BattInf binf=(BattInf) obj;
      //Page page=binf.getPage();
      /*Connection conn=DBUtil.getConn();
      String numberSql=" SELECT FOUND_ROWS() number";SQL_CALC_FOUND_ROWS*/
      String sql=" select  distinct(tb_battinf.StationId),StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FBSDeviceId,"
            + "FBSDeviceName,count(FBSDeviceId) as batt_num" +
             ",MonCount,monVolStd,monResStd,MonSerStd,Load_curr,DisCurrMax,montmpstd,floatVolLevel,offlineVolLevel,battFloatCurrent"
             + ",GROUP_CONCAT(tb_battinf.MonCapStd order by groupIndexInFBSDevice separator '/' ) as moncapstds "
             + ",db_ram_db.tb_fbs9100_state.dev_version"
             + ",web_site.tb_batt_endurance.real_cap_group1 ,web_site.tb_batt_endurance.real_cap_group2,web_site.tb_batt_endurance.real_cap_group3,web_site.tb_batt_endurance.real_cap_group4 "
            + " from db_battinf.tb_battinf,db_ram_db.tb_fbs9100_state,web_site.tb_batt_endurance  "
            + " where db_battinf.tb_battinf.FBSDeviceId=db_ram_db.tb_fbs9100_state.dev_id "
            + " and db_battinf.tb_battinf.FBSDeviceId=web_site.tb_batt_endurance.deviceid "
            + "  and MonVolStd=?  and Station_install=1 ";
            //+ "  limit ?,? ";StationName1 like ? and StationName2 like ? and StationName3 like ? and StationName5 like ? "
      //,(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize(),"%"+binf.getStationName1()+"%","%"+binf.getStationName2()+"%","%"+binf.getStationName3()+"%",
      //条件
      String sql0=" and db_battinf.tb_battinf.stationid=? "; //具体机房
      String sql1=" and stationname1=? ";//省
      String sql2=" and stationname2=? ";//市
      String sql5=" and stationname5=? ";//区县
      switch (binf.getNum()) {
      case 0:
         sql+=sql0;
         break;
        case 1:
           sql+=sql1;
         break;
        case 2:
           sql+=sql2;
         break;
        case 5:
           sql+=sql5;
          break;
      default:
         return null;
      }
      //排序
      String orderSql=" GROUP BY  FBSDeviceId  order by StationId asc,GroupIndexInFBSDevice asc ";
      sql+=orderSql;
      //System.out.println(sql);
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[] {binf.getMonVolStd(),binf.getStationName()}, new CallBack() {
         @Override
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
            try {
               while(rs.next()) {
                  BattInf binf = new BattInf();
                  binf.setNum(0);
                  binf.setStationId(rs.getString("stationId"));
                  binf.setStationName(rs.getString("stationName"));
                  binf.setStationName1(rs.getString("stationName1"));
                  binf.setStationName2(rs.getString("stationName2"));
                  binf.setStationName3(rs.getString("stationName3"));
                  binf.setStationName4(rs.getString("stationName4"));
                  binf.setStationName5(rs.getString("stationName5"));
                  binf.setStationIp(rs.getString("stationIp"));
                  binf.setFBSDeviceId(rs.getInt("fBSDeviceId"));
                  /*binf.setFbsDeviceIp(rs.getString("fbsDeviceIp"));
                  binf.setFbsDeviceIp_YM(rs.getString("fbsDeviceIp_YM"));
                  binf.setFbsDeviceIp_WG(rs.getString("fbsDeviceIp_WG"));*/
                  binf.setFBSDeviceName(rs.getString("fBSDeviceName"));
                  binf.setBattGroupNum(rs.getInt("batt_num"));
                  binf.setFloatVolLevel(rs.getFloat("floatVolLevel"));
                  binf.setOfflineVolLevel(rs.getFloat("offlineVolLevel"));
                  binf.setBattFloatCurrent(rs.getFloat("battFloatCurrent"));
                  binf.setMonCount(rs.getInt("monCount"));
                  //binf.setMonCapStd(rs.getFloat("monCapStd"));
                  binf.setMoncapstds(rs.getString("moncapstds"));
                  binf.setReal_cap_group1(rs.getFloat("real_cap_group1"));
                  binf.setReal_cap_group2(rs.getFloat("real_cap_group2"));
                  binf.setReal_cap_group3(rs.getFloat("real_cap_group3"));
                  binf.setReal_cap_group4(rs.getFloat("real_cap_group4"));
                  binf.setMonVolStd(rs.getFloat("monVolStd"));
                  binf.setMonResStd(rs.getFloat("monResStd"));
                  binf.setMonSerStd(rs.getFloat("monSerStd"));
                  binf.setMonTmpStd(rs.getFloat("monTmpStd"));
                  /*binf.setMonVolLowToAvg(rs.getFloat("monVolLowToAvg"));
                  binf.setBattProducer(rs.getString("battProducer"));
                  binf.setBattModel(rs.getString("battModel"));
                  binf.setBattProductDate(rs.getDate("battProductDate"));
                  binf.setBattInUseDate(rs.getDate("battInUseDate"));
                  binf.setInstall_user(rs.getString("install_user"));*/
                  binf.setLoad_curr(rs.getFloat("load_curr"));
                        binf.setDisCurrMax(rs.getFloat("disCurrMax"));
                        /*binf.setStation_phone(rs.getString("station_phone"));
                        binf.setStation_install(rs.getInt("station_install"));*/
                        binf.setStationName9(rs.getString("dev_version"));
                  list.add(binf);
               }
            } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
            }
            return list;
         }
      });
      /*//去掉limit条件后的总数
      int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
      //System.out.println("number: "+number);
      if(list!=null&&list.size()>0){
         list.get(list.size()-1).setNum(number);
      }*/
      return list;
   }
   public static void main(String[] args) throws ParseException {
      //new BattInfImpl().searchAll();
      
      BattInfImpl biml = new BattInfImpl();
      BattInf binf = new BattInf();
      binf.setNum(2);
      binf.setNum(0);
      binf.setBattGroupId(1000001);
      binf.setStationName("百色");
      binf.setStationName("42000611");
      binf.setStationName1("");
      binf.setStationName2("");
      binf.setStationName3("");
@@ -4649,7 +4767,7 @@
      System.out.println(nums);*/
      /*boolean bl=biml.judgeBattInOrNot(binf);
      System.out.println(bl);*/
      List<BattInf> list=biml.serchByBatt_param(binf);
      List<BattInf> list=biml.serchBySys_param(binf);
      for (BattInf b : list) {
         System.out.println(b);
      }
@@ -4657,7 +4775,9 @@
      for (BattInf b : list) {
         System.out.println(b);
      }*/
      System.out.println(list.size());
      /*List list=biml.judgeBatt(binf);
      System.out.println(list);*/
      //System.out.println(list.size());
   }
   
    public List getResults(ResultSet rs) {