hdw
2019-01-19 7f953d9aa0e7d4fcbe3c366c7f9f0b3f847f12bd
gx_tieta/src/com/fgkj/dao/impl/ram/Fbs9100_setparamImpl.java
@@ -21,6 +21,7 @@
import com.fgkj.dto.ram.FBS9100;
import com.fgkj.dto.ram.Fbs9100_setparam;
import com.fgkj.dto.ram.Fbs9100_state;
import com.fgkj.dto.ram.Fbs9100_sysparam;
import com.fgkj.services.User_logService;
public class Fbs9100_setparamImpl implements BaseDAO,CallBack{
@@ -97,6 +98,52 @@
            sql_str.add(sql);
            {
               String msg="修改"+fs.getDev_id()+"机房放电参数";
               User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
               listU.add(ulog);
             }
         }
      }
      Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      return bl;
   }
   //批量放电
   public boolean updatePro_dis(Object obj) {
      List<Fbs9100_setparam> list=(List<Fbs9100_setparam>) obj;
      ArrayList sql_str=new ArrayList();
      List<User_log> listU=new ArrayList<User_log>();//存放user_log
      if(list!=null&&list.size()>0){
         for (int i = 0; i < list.size(); i++) {
            Fbs9100_setparam fs=list.get(i);
            String sql="UPDATE db_ram_db.tb_fbs9100_setparam  SET "
                  + " op_cmd="+fs.getOp_cmd()+ ",TestCmd="+fs.getTestCmd()+ " WHERE dev_id= "+fs.getDev_id();
            sql_str.add(sql);
            {
               String msg="启动"+fs.getDev_id()+"机房放电";
               User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
               listU.add(ulog);
             }
         }
      }
      Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      return bl;
   }
   //批量重启
   public boolean restartPL_FBS(Object obj) {
      List<Fbs9100_sysparam> list=(List<Fbs9100_sysparam>) obj;
      ArrayList sql_str=new ArrayList();
      List<User_log> listU=new ArrayList<User_log>();//存放user_log
      if(list!=null&&list.size()>0){
         for (int i = 0; i < list.size(); i++) {
            Fbs9100_sysparam fs=list.get(i);
            String sql="UPDATE db_ram_db.tb_fbs9100_setparam  SET "
                  + " op_cmd="+fs.getOp_cmd()+ " WHERE dev_id= "+fs.getDev_id();
            sql_str.add(sql);
            {
               String msg="重启"+fs.getDev_id()+"机房";
               User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
               listU.add(ulog);
             }
@@ -346,17 +393,17 @@
      try {
         ps = conn.prepareStatement(sql);
         rs=ps.executeQuery();
            if(rs.next())
         if(rs.next())
         {
            if(rs.getInt("op_cmd") == m_cmd_ack)
            {
               if(rs.getInt("op_cmd") == m_cmd_ack)
               {
                  res_exe = true;
               }
               }
         } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
               res_exe = true;
            }
         }
      } catch (SQLException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
      }
      DBUtil.close(rs, ps, conn);
      return res_exe;
   }