hdw
2018-11-13 d76718af796b1bbe7dfae7c2488e8dc5643d903f
gx_tieta/src/com/fgkj/dao/impl/ram/Fbs9100s_dfu_stateImpl.java
@@ -1,13 +1,18 @@
package com.fgkj.dao.impl.ram;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.dao.UinfDaoFactory;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.User_log;
import com.fgkj.dto.ram.Fbs9100s_dfu_state;
import com.fgkj.services.User_logService;
public class Fbs9100s_dfu_stateImpl implements BaseDAO,CallBack{
@@ -18,18 +23,38 @@
    //升级插入
   public boolean add(Object obj) {
      Fbs9100s_dfu_state dfu=(Fbs9100s_dfu_state) obj;
      String sql="insert into db_ram_db.tb_fbs9100s_dfu_state (dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum) values (?,?,?,?)";
      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()});
      return bl;
   }
    //升级确认
   public boolean update(Object obj) {
      Fbs9100s_dfu_state dfu=(Fbs9100s_dfu_state) obj;
      String sql="update db_ram_db.tb_fbs9100s_dfu_state set dfu_en=true,dfu_wr_stat=1, dfu_data_blocknum=1 where dev_id=?;";
      String sql="update db_ram_db.tb_fbs9100s_dfu_state set dfu_en=true,dfu_wr_stat=1, dfu_data_blocknum=1 where dev_id=?";
      boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dfu.getDev_id()});
      return bl;
   }
   //批量升级确认
   public boolean updatePro(Object obj) {
      List<Fbs9100s_dfu_state> list=(List<Fbs9100s_dfu_state>) obj;
      List<User_log> listU=new ArrayList<User_log>();//存放user_log
      ArrayList sql_str=new ArrayList();
      if(list!=null&&list.size()>0){
         for (int i = 0; i < list.size(); i++) {
            Fbs9100s_dfu_state dfu=list.get(i);
            String sql="update db_ram_db.tb_fbs9100s_dfu_state set dfu_en=true,dfu_wr_stat=1, dfu_data_blocknum=1 where dev_id="+dfu.getDev_id();
            sql_str.add(sql);
            {
               String msg="升级"+dfu.getDev_id()+"设备";
               User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg);
               listU.add(ulog);
             }
         }
      }
      boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      return bl;
   }
   public boolean del(Object obj) {
      // TODO Auto-generated method stub
      return false;
@@ -39,15 +64,70 @@
      // TODO Auto-generated method stub
      return null;
   }
    //升级界面实时刷新
   public List serchByCondition(Object obj) {
      // TODO Auto-generated method stub
      return null;
      List<Integer> list=(List<Integer>) obj;
      String sql=" select * from db_ram_db.tb_fbs9100s_dfu_state  " +
            " where dev_id in(";
      String devSql="";
      Object[] object=new Object[list.size()];
      //System.out.println(list.size());
      if(list!=null&&list.size()>0){
         for (int i = 0; i <list.size(); i++) {
            if(i==(list.size()-1)){
               devSql+="?)";
            }else{
               devSql+="?,";
            }
            object[i]=list.get(i);
         }
      }
      sql+=devSql;
      String endSql="  order by dev_id";
      sql+=endSql;
      //System.out.println(sql);
      List listAll=DAOHelper.executeQuery(sql, DBUtil.getConn(), object, new CallBack() {
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
            try {
               while(rs.next()){
                  Fbs9100s_dfu_state dfu=new Fbs9100s_dfu_state();
                  dfu.setDev_id(rs.getInt("dev_id"));
                  dfu.setSysVersion_new(rs.getInt("sysVersion_new"));
                  dfu.setSoftVersion_new(rs.getInt("softVersion_new"));
                  dfu.setSysVersion_dev(rs.getInt("sysVersion_dev"));
                  dfu.setSoftVersion_dev(rs.getInt("softVersion_dev"));
                  dfu.setDfu_file(rs.getString("dfu_file"));
                  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_blocklen(rs.getInt("dfu_data_blocklen"));
                  list.add(dfu);
               }
            } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
            }
            return list;
         }
      });
      return listAll;
   }
   public List serchByInfo(Object obj) {
      // TODO Auto-generated method stub
      return null;
   }
   public static void main(String[] args) {
   Fbs9100s_dfu_stateImpl fimpl=new Fbs9100s_dfu_stateImpl();
   List list=new ArrayList();
   list.add(910000013);
   list.add(910000577);
   list.add(910000534);
   List<Fbs9100s_dfu_state> listAll=fimpl.serchByCondition(list);
   for (Fbs9100s_dfu_state dfu : listAll) {
      System.out.println(dfu);
   }
}
}