diff --git a/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java b/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java index cb8c86d..0aea0fc 100644 --- a/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java +++ b/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java @@ -911,6 +911,7 @@ public class AtuPlanTaskApiServiceImpl extends AbstractExcelService TaskCaseStepDetailDto detailDto) { // 获取脚本执行结果信息 Map stepResultMap = new HashMap<>(); + String stepId = ""; if (StrUtil.isNotEmpty(execResultFile)) { // 读取结果文件信息 File file = null; @@ -928,6 +929,12 @@ public class AtuPlanTaskApiServiceImpl extends AbstractExcelService } StepExecuteResult stepExecuteResult = JSONUtil.toBean(line, StepExecuteResult.class); processStepResult(stepExecuteResult, stepResultMap, ""); + if (stepExecuteResult.getStepId() != null && stepExecuteResult.getStepId().startsWith("3e9da7b7c")) { // 用于只输出对应异常数据的详情,可以删除判断,每一个查询进行输出,日志增多而已 + stepId = stepExecuteResult.getStepId(); + stepResultMap.forEach((key, value) -> { + logger.debug("每一步的执行情况:{},success:{},isExecuted:{}", key, value.isSuccess(), value.isExecuted()); + }); + } } } catch (Exception e) { logger.error("读取结果文件失败", e); @@ -942,7 +949,13 @@ public class AtuPlanTaskApiServiceImpl extends AbstractExcelService } JSONArray commands = JSONUtil.parseArray(scriptJson.get(MsgConstant.COMMANDS)); - return processStepData(commands, stepResultMap, scriptJson, detailDto, 0, false, false, ""); + List resultList = processStepData(commands, stepResultMap, scriptJson, detailDto, 0, false, false, ""); + if (StringUtils.isNotBlank(stepId)) { + for (TaskCaseStepDetailDto dto : resultList) { // 用于只输出对应异常数据的详情,可以删除判断,每一个查询进行输出,日志增多而已 + logger.debug("步骤id:{},步骤名称:{},skip:{},是否成功:{},是否已执行:{}", dto.getStepId(), dto.getStepName(), dto.getSkip(), dto.getExecResult(), dto.getExecuted()); + } + } + return resultList; } /**