| | |
| | | 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{
|
| | |
| | | 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);
|
| | | }
|
| | |
| | | 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;
|
| | | }
|