Commit c9911566 by huangfusuper

修改异常级别

parent 74f0e51a
...@@ -105,7 +105,7 @@ public class ScriptExecutorJobTask implements TimerTask { ...@@ -105,7 +105,7 @@ public class ScriptExecutorJobTask implements TimerTask {
DispatchResponseDto dispatchResponseDto = new DispatchResponseDto(); DispatchResponseDto dispatchResponseDto = new DispatchResponseDto();
try{ try{
dispatchResponseDto = runScriptService.runScript(scriptDto); dispatchResponseDto = runScriptService.runScript(scriptDto);
}catch (RpcException rpcException){ }catch (Exception rpcException){
StringRedisTemplate stringRedisTemplate = (StringRedisTemplate) SpringUtil.getBean("stringRedisTemplate"); StringRedisTemplate stringRedisTemplate = (StringRedisTemplate) SpringUtil.getBean("stringRedisTemplate");
RunLog runLog = RunLog.builder().isEnd(true).isSuccess(false).runLog("执行资源异常" + rpcException.getMessage()).build(); RunLog runLog = RunLog.builder().isEnd(true).isSuccess(false).runLog("执行资源异常" + rpcException.getMessage()).build();
stringRedisTemplate.convertAndSend("REAL-EXEC-" + mythJobTaskSchedule.getLogId() , JSON.toJSONString(runLog, WriteClassName)); stringRedisTemplate.convertAndSend("REAL-EXEC-" + mythJobTaskSchedule.getLogId() , JSON.toJSONString(runLog, WriteClassName));
......
...@@ -105,7 +105,7 @@ public class ScriptExecutorServiceImpl implements ScriptExecutorService { ...@@ -105,7 +105,7 @@ public class ScriptExecutorServiceImpl implements ScriptExecutorService {
command = PlaceholderUtils.commandReplace(command,scriptParamAndPlaceholderDto.getParam()); command = PlaceholderUtils.commandReplace(command,scriptParamAndPlaceholderDto.getParam());
} }
List<String> cmdList = Arrays.asList(command.split(" ")); List<String> cmdList = Arrays.asList(command.split(" "));
MythJobProcess mythJobProcess = new MythJobProcess(cmdList, null, null, scriptDto.getLogId(), scriptDto.getRunId(), stringRedisTemplate); MythJobProcess mythJobProcess = new MythJobProcess(cmdList, null, null, scriptDto.getLogId(), stringRedisTemplate);
//保存日志 //保存日志
String logData = mythJobProcess.call(); String logData = mythJobProcess.call();
byte[] logDataByte = stringToByteArray(logData); byte[] logDataByte = stringToByteArray(logData);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment