查询信息

81041

2018-10-22 aaa3e16cabaf5d70520634eaff6f8c83653000a8

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

@@ -43,7 +43,7 @@
import com.fgkj.services.User_logService;



public class BattInfImpl implements BaseDAO, CallBack {

    //添加新的电池组(多个)

   //添加新的电池组(多个)

   public boolean add(Object obj) {

      List<BattInf> list=(List<BattInf>) obj;

      ArrayList<String> sql_str=new ArrayList();

@@ -70,12 +70,12 @@
            String sql = "insert into db_battinf.tb_battinf(" +

                  "StationId,StationName,StationName1,StationName2,StationName3,StationName4,StationIp,FBSDeviceId,FbsDeviceIp,FbsDeviceIp_YM,FbsDeviceIp_WG,"

                  + "FBSDeviceName,GroupIndexInFBSDevice,battgroupId,BattGroupNum,BattGroupName,FloatVolLevel,OfflineVolLevel,BattFloatCurrent" +

                  ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,MonVolLowToAvg,BattProducer,BattModel,BattProductDate,BattInUseDate" +

                  ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,MonVolLowToAvg,BattProducer,BattModel,BattProductDate,BattInUseDate,Load_curr,DisCurrMax,station_phone" +

                  ") values('"+binf.getStationId()+"','"+binf.getStationName()+"','"+binf.getStationName1()+"','"+binf.getStationName2()+"','"+binf.getStationName3()+"','"+binf.getStationName4()+

                  "','"+binf.getStationIp()+"',"+binf.getFBSDeviceId()+",'"+binf.getFbsDeviceIp()+"','"+binf.getFbsDeviceIp_YM()+"','"+binf.getFbsDeviceIp_WG()+"','"+binf.getFBSDeviceName()+"',"+binf.getGroupIndexInFBSDevice()+

                  ","+binf.getBattGroupId()+","+binf.getBattGroupNum()+",'"+binf.getBattGroupName()+"',"+binf.getFloatVolLevel()+","+binf.getOfflineVolLevel()+","+binf.getBattFloatCurrent()+

                  ","+binf.getMonCount()+","+binf.getMonCapStd()+","+binf.getMonVolStd()+","+binf.getMonResStd()+","+binf.getMonSerStd()+","+binf.getMonVolLowToAvg()+

                  ",'"+binf.getBattProducer()+"','"+binf.getBattModel()+"','"+DAOHelper.sdf.format(binf.getBattProductDate())+"','"+DAOHelper.sdf.format(binf.getBattInUseDate())+"')";

                  ",'"+binf.getBattProducer()+"','"+binf.getBattModel()+"','"+DAOHelper.sdf.format(binf.getBattProductDate())+"','"+DAOHelper.sdf.format(binf.getBattInUseDate())+"',"+binf.getLoad_curr()+","+binf.getDisCurrMax()+",'"+binf.getStation_phone()+"')";

            

            if(binf.getStationId().equals(maxs)){

               maxs++;

@@ -116,8 +116,8 @@
            }

            String sql = "update db_battinf.tb_battinf set StationId='"+binf.getStationId()+"',StationName='"+binf.getStationName()+"',StationName1='"+binf.getStationName1()+"',StationName2='"+binf.getStationName2()+"',StationName3='"+binf.getStationName3()+"',StationName4='"+binf.getStationName4()+"',StationIp='"+binf.getStationIp()+"',FBSDeviceId="+binf.getFBSDeviceId()+",FbsDeviceIp='"+binf.getFbsDeviceIp()+"',"

                  + "FBSDeviceName='"+binf.getFBSDeviceName()+"',GroupIndexInFBSDevice="+binf.getGroupIndexInFBSDevice()+",BattGroupNum="+binf.getBattGroupNum()+",BattGroupName='"+binf.getBattGroupName()+"',FloatVolLevel="+binf.getFloatVolLevel()+",OfflineVolLevel="+binf.getOfflineVolLevel()+",BattFloatCurrent="+binf.getBattFloatCurrent()+"," +

                    "MonCount="+binf.getMonCount()+",MonCapStd="+binf.getMonCapStd()+",monVolStd="+binf.getMonVolStd()+",monResStd="+binf.getMonResStd()+",MonSerStd="+binf.getMonSerStd()+",MonVolLowToAvg="+binf.getMonVolLowToAvg()+",BattProducer='"+binf.getBattProducer()+"',BattModel='"+binf.getBattModel()+"',BattProductDate='"+DAOHelper.sdf.format(binf.getBattProductDate())+"',BattInUseDate='"+DAOHelper.sdf.format(binf.getBattInUseDate())+"' "

                   +" where battgroupId="+binf.getBattGroupId();

                    "MonCount="+binf.getMonCount()+",MonCapStd="+binf.getMonCapStd()+",monVolStd="+binf.getMonVolStd()+",monResStd="+binf.getMonResStd()+",MonSerStd="+binf.getMonSerStd()+",MonVolLowToAvg="+binf.getMonVolLowToAvg()+",BattProducer='"+binf.getBattProducer()+"',BattModel='"+binf.getBattModel()+"',BattProductDate='"+DAOHelper.sdf.format(binf.getBattProductDate())+"',BattInUseDate='"+DAOHelper.sdf.format(binf.getBattInUseDate())+"', "

                   +" Load_curr="+binf.getLoad_curr()+",DisCurrMax="+binf.getDisCurrMax()+",station_phone='"+binf.getStation_phone()+"'  where battgroupId="+binf.getBattGroupId();

            sql_str.add(sql);

            {

               String msg="修改"+binf.getStationName()+"机房"+binf.getBattGroupId()+"电池组的信息";

@@ -159,7 +159,7 @@
      Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);

      return bl;

   }

    //根据维护区和机房名称查询电池组信息

    //根据维护区和机房名称查询电池组信息(电池组信息配置)

   public List searchInform(Object obj){

      Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;

      BattInf binf=bmd.getBinf();

@@ -168,7 +168,7 @@
      String numberSql=" SELECT FOUND_ROWS() number";

      String sql="select SQL_CALC_FOUND_ROWS distinct(StationId),StationName1,StationName2,StationName3,StationName4,StationIp,FBSDeviceId,FbsDeviceIp_YM,FbsDeviceIp_WG,FbsDeviceIp,"

            + "FBSDeviceName,GroupIndexInFBSDevice,battgroupId,BattGroupNum,BattGroupName,FloatVolLevel,OfflineVolLevel,BattFloatCurrent" +

             ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,MonVolLowToAvg,BattProducer,BattModel,BattProductDate,BattInUseDate " +

             ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,MonVolLowToAvg,BattProducer,BattModel,BattProductDate,BattInUseDate,Load_curr,DisCurrMax,station_phone  " +

             " From db_battinf.tb_battinf " +

             " Where StationName like ? and StationName1 like ? and StationName2 like ?  " +

             " order by StationId  " +

@@ -211,7 +211,51 @@
                  binf.setBattModel(rs.getString("battModel"));

                  binf.setBattProductDate(rs.getDate("battProductDate"));

                  binf.setBattInUseDate(rs.getDate("battInUseDate"));

                  binf.setLoad_curr(rs.getFloat("load_curr"));

                        binf.setDisCurrMax(rs.getFloat("disCurrMax"));

                        binf.setStation_phone(rs.getString("station_phone"));

                  list.add(binf);



               }

            } catch (SQLException e) {

               e.printStackTrace();

            }		
            return list;

         }

      });

      //去掉limit条件后的总数

      int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);

      if(list!=null&&list.size()>0){

         list.get(list.size()-1).setNum(number);

      }

      return list;

   }

   //根据维护区和机房名称查询电池组信息(电池组信息配置)

   public List searchInform1(Object obj){

      Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;

      BattInf binf=bmd.getBinf();

      Page page=bmd.getPage();

      Connection conn= DBUtil.getConn();

      String numberSql=" SELECT FOUND_ROWS() number";

      String sql="select SQL_CALC_FOUND_ROWS distinct(StationId),StationId_ex,StationName1,StationName2,StationName3,StationName,FBSDeviceId  " +

             " From db_battinf.tb_battinf " +

             " limit ?,?";

      List<BattInf> list=DAOHelper.executeQueryLimit(sql,conn, new Object[]{(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()},new CallBack() {

			
         public List getResults(ResultSet rs) {

            List list = new ArrayList<BattInf>();

            int id=0;

				
            try {

               while (rs.next()) {

                  BattInf binf = new BattInf();

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

                  binf.setStationName1(rs.getString("stationName1"));

                  binf.setStationName2(rs.getString("stationName2"));

                  binf.setStationName3(rs.getString("stationName3"));

                  binf.setFBSDeviceId(rs.getInt("fBSDeviceId"));

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

                  binf.setStationId_ex(rs.getString("stationId_ex"));

                  list.add(binf);



               }

@@ -3434,7 +3478,7 @@
   //根据机房id查询机房下的电池组信息(左侧导航第四层,根据机房查询下面的电池组,num中存放uid)

   public List serchBattByStation(Object obj){

      BattInf binf=(BattInf) obj;

      String sql="select DISTINCT StationName,StationId,StationIP,FBSDeviceId,BattGroupName,BattGroupName1,BattGroupName2,MonCount,battgroupId,MonCapStd,MonVolStd,MonResStd,MonSerStd,BattProducer,BattInUseDate,GroupIndexInFBSDevice " +

      String sql="select DISTINCT StationName,StationId,StationIP,FBSDeviceId,BattGroupName,BattGroupName1,BattGroupName2,MonCount,battgroupId,MonCapStd,MonVolStd,MonResStd,MonSerStd,BattProducer,BattInUseDate,GroupIndexInFBSDevice,Load_curr,DisCurrMax " +

            "from db_battinf.tb_battinf  where StationName1 like ? and StationName2 like ?  and  StationName like ?  ";

       //机房id

      String idSqlT=" and  Stationid like ? ";

@@ -3471,6 +3515,8 @@
                  batt.setBattProducer(rs.getString("BattProducer"));

                  batt.setBattInUseDate(rs.getDate("BattInUseDate"));

                  batt.setGroupIndexInFBSDevice(rs.getInt("groupIndexInFBSDevice"));

                  batt.setLoad_curr(rs.getFloat("load_curr"));

                  batt.setDisCurrMax(rs.getFloat("disCurrMax"));

                  list.add(batt);

               }

            } catch (SQLException e) {

@@ -3624,7 +3670,12 @@
            " from db_battinf.tb_battinf " +

            " left outer join (select * from db_battinf.tb_battinf_rebuild where tb_battinf_rebuild.rebuild_clear_type=1 ) as battinf_re " +

            " on BattGroupId=battinf_re.new_battgroupid or BattGroupId=battinf_re.old_battgroupid " +

            " where stationname2 like ? ";

            " where stationname2 like ?  ";

      //用户管理

      String userSql=" and 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 producerSqlT=" order by BattProducer,MonCapStd,MonVolStd,BattGroupId ";//一致

      String producerSqlF=" order by MonCapStd,MonVolStd,BattGroupId ";//不一致

@@ -3633,7 +3684,7 @@
      }else{

         sql+=producerSqlF;

      }

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName2()+"%"}, new CallBack() {

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName2()+"%",binf.getNum()}, new CallBack() {

         

         public List getResults(ResultSet rs) {

            List<BattInf> list=new ArrayList();

@@ -3700,7 +3751,12 @@
            " left outer join (select * from db_battinf.tb_battinf_rebuild where tb_battinf_rebuild.rebuild_clear_type=1 ) as battinf_re " +

            " on BattGroupId=battinf_re.new_battgroupid or BattGroupId=battinf_re.old_battgroupid " +

            " where stationname1 like ? and stationname2 like ? and stationname3 like ?  and battgroupname like ?  and battgroupid=? ";

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName1()+"%","%"+binf.getStationName2()+"%","%"+binf.getStationName3()+"%","%"+binf.getBattGroupName()+"%",binf.getBattGroupId()}, new CallBack() {

      //用户管理

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

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName1()+"%","%"+binf.getStationName2()+"%","%"+binf.getStationName3()+"%","%"+binf.getBattGroupName()+"%",binf.getBattGroupId(),binf.getNum()}, new CallBack() {

         

         public List getResults(ResultSet rs) {

            List<BattInf> list=new ArrayList();

@@ -3765,11 +3821,12 @@
      

      BattInfImpl biml = new BattInfImpl();

      BattInf binf = new BattInf();

      binf.setNum(1002);

      binf.setBattGroupId(1000001);

      binf.setStationName("");

      binf.setStationName1("");

      binf.setStationName2("");

      binf.setStationName3("武汉源暢实验室1");

      binf.setStationName3("");

      binf.setBattGroupName("");

      binf.setBattProducer("1");

      User_inf uinf=new User_inf();

@@ -3797,7 +3854,8 @@
      //List<BattInf> list=biml.serchByTestType(bmd);

      //List<BattInf> list=biml.serchGroupAssess(bmd);

      //List<BattInf> list=biml.serchMakeGroup(binf);

      List<BattInf> list=biml.serchGroupByInfor(binf);

      //List<BattInf> list=biml.serchGroupByInfor(binf);

      List<BattInf> list=biml.searchInform1(bmd);

      for (BattInf b : list) {

         System.out.println(b);

      }