81041
2018-11-28 971b5ef71e184c6300da5f187627cb3496dc62dd
gx_tieta/src/com/fgkj/dao/impl/ram/Fbs9100s_dfu_stateImpl.java
@@ -24,16 +24,16 @@
    //升级插入
   public boolean add(Object obj) {
      Fbs9100s_dfu_state dfu=(Fbs9100s_dfu_state) obj;
      String sql=" REPLACE into db_ram_db.tb_fbs9100s_dfu_state (dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum) values (?,?,?,?)";
      boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dfu.getDev_id(),dfu.getDfu_file(),dfu.getDfu_wr_stat(),dfu.getDfu_data_blocknum()});
      String sql=" REPLACE into db_ram_db.tb_fbs9100s_dfu_state (dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum,dfu_data_blocksum) values (?,?,?,?,?)";
      boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dfu.getDev_id(),dfu.getDfu_file(),dfu.getDfu_wr_stat(),dfu.getDfu_data_blocknum(),dfu.getDfu_data_blocksum()});
      return bl;
   }
   //批量升级插入(所有属性传到stationName中)
   //批量升级插入(所有属性传到stationName中,文件大小的值放在num中)
   public boolean addPro(Object obj) {
      BattInf binf=(BattInf) obj;
      String sql=" REPLACE into db_ram_db.tb_fbs9100s_dfu_state(dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum) " +
            " SELECT  DISTINCT fBSDeviceId,'avr_dfu.uc3',1,1 FROM  db_battinf.tb_battinf " +
            " where fBSDeviceId not in(select DISTINCT dev_id from db_ram_db.tb_fbs9100s_dfu_state)  ";
      String sql=" REPLACE into db_ram_db.tb_fbs9100s_dfu_state(dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum,dfu_data_blocksum) " +
            " SELECT  DISTINCT fBSDeviceId,'avr_dfu.uc3',1,1,"+binf.getSize()+"  FROM db_battinf.tb_battinf " +
            " where fBSDeviceId not in(select DISTINCT dev_id from db_ram_db.tb_fbs9100s_dfu_state where dfu_en=true)  ";
      //条件
      String sql0=" and stationid=? "; //具体机房
      String sql1=" and stationname1=? ";//省
@@ -189,7 +189,7 @@
   }
    //查询出所有处于升级的设备
   public List searchAll() {
      String sql=" select distinct dev_id,db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.stationId,db_battinf.tb_battinf.fBSDeviceName,sysVersion_new,softVersion_new,sysVersion_dev,softVersion_dev,dfu_file,dfu_en,dfu_wr_stat,dfu_data_blocknum,dfu_data_blocklen " +
      String sql=" select distinct dev_id,db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.stationId,db_battinf.tb_battinf.fBSDeviceName,sysVersion_new,softVersion_new,sysVersion_dev,softVersion_dev,dfu_file,dfu_en,dfu_wr_stat,dfu_data_blocknum,dfu_data_blocklen,dfu_data_blocksum " +
            " from  db_ram_db.tb_fbs9100s_dfu_state,db_battinf.tb_battinf " +
            " where db_ram_db.tb_fbs9100s_dfu_state.dev_id=db_battinf.tb_battinf.fBSDeviceId  and dfu_en=1";
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null , new CallBack() {
@@ -208,6 +208,7 @@
                  dfu.setDfu_en(rs.getInt("dfu_en"));
                  dfu.setDfu_wr_stat(rs.getInt("dfu_wr_stat"));
                  dfu.setDfu_data_blocknum(rs.getInt("dfu_data_blocknum"));
                  dfu.setDfu_data_blocksum(rs.getInt("dfu_data_blocksum"));
                  dfu.setDfu_data_blocklen(rs.getInt("dfu_data_blocklen"));
                  dfu.setStationName(rs.getString("stationName"));
                  dfu.setStationId(rs.getString("stationId"));
@@ -261,6 +262,7 @@
                  dfu.setDfu_en(rs.getInt("dfu_en"));
                  dfu.setDfu_wr_stat(rs.getInt("dfu_wr_stat"));
                  dfu.setDfu_data_blocknum(rs.getInt("dfu_data_blocknum"));
                  dfu.setDfu_data_blocksum(rs.getInt("dfu_data_blocksum"));
                  dfu.setDfu_data_blocklen(rs.getInt("dfu_data_blocklen"));
                  list.add(dfu);
               }
@@ -274,8 +276,8 @@
      return listAll;
   }
   
   //升级界面点击添加的时候查询出设备对应的版本号
   public List serchByInfo(Object obj) {
      // TODO Auto-generated method stub
      return null;
   }
    public static void main(String[] args) {
@@ -296,16 +298,16 @@
   for (BattInf binf : listAll) {
      System.out.println(binf.getStationName3()+" "+binf.getFBSDeviceId());
   }*/
   /*
   boolean bl=fimpl.addPro(binf);
   System.out.println(bl);*/
   System.out.println(bl);
   /*List<BattInf> listAll=fimpl.serchInserStation(binf);
   for (BattInf b : listAll) {
      System.out.println(b.getStationName3()+" "+b.getFBSDeviceId());
   }*/
   List<Fbs9100s_dfu_state> listAll=fimpl.searchAll();
   /*List<Fbs9100s_dfu_state> listAll=fimpl.searchAll();
   for (Fbs9100s_dfu_state dfu : listAll) {
      System.out.println(dfu);
   }
   }*/
}
}