Tags: xwuxin/CronHub
Tags
record.setOn_processing(false);
record.setExec_type(execType);
if(execType != Params.EXECTYPE_AUTOREDO){
record.setStart_datetime(new Date());//不等于自动重执行类型时,设置初始时间
}else{//如果是自动重新时,设置current_redo_times+1
record.setCurrent_redo_times(record.getCurrent_redo_times()+1);
}
record.setEnd_datetime(new Date());
record.setExit_code(-1);//将修改为-99之前
record.setComplete_success(false);
this.doneRecordDao.update(record);
remoteExecute(Long doneRecordId,String doneTableName,final Integer execType)的
代码体参照
remoteExecute(final Task task,final Integer exec_type)
的代码体修改
-------------------------------------------
TaskRecordDone record = new TaskRecordDone();
record.setTask_id(task.getId());
record.setReal_cmd(ReplaceRealCmdUtils.replaceCmdFromOriginalToReal(task.getShell_cmd()));
record.setExit_code(Params.DB_EXITCODE_ERROR_PING);
record.setComplete_success(false);
record.setStart_datetime(startDate);//不能这么写，因为有可能干活5小时的中间第3小时执行失败，（网络异常）而发生问题。^M re
cord.setEnd_datetime(new Date());
record.setExec_type(exec_type);
record.setExec_return_str("无法ping通daemon端[ip:"+task.getDaemon().getMachine_ip()+",port:"+task.getDaemon().getMachine_port()+"],>
执行命令:"+task.getShell_cmd()+"的时候无法通信");
record.setCurrent_redo_times(0);
record.setOn_processing(false);
doneRecordDao.insert(record);
before modify core remote exec process 在crontab执行,自动重执行,手动重执行0.1版本原本的代码被修改之前