diff --git a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AbstractSpectrumHandler.java b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AbstractSpectrumHandler.java index d1e9a8ff..63520992 100644 --- a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AbstractSpectrumHandler.java +++ b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AbstractSpectrumHandler.java @@ -243,7 +243,10 @@ public abstract class AbstractSpectrumHandler extends AbstractChain { } /** - * 处理解析失败的文件,上传到undeal目录 + * 处理解析失败的文件 + * 1.格式错误移动到errorfile + * 2.filerepeat错误直接删除 + * 3.非filerepeat错误移动到undel * @throws FileNotFoundException */ protected void handleParseingFailFile(Exception e) throws FileNotFoundException { diff --git a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AlertSpectrum.java b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AlertSpectrum.java index cdea2677..84264f8e 100644 --- a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AlertSpectrum.java +++ b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/AlertSpectrum.java @@ -89,6 +89,9 @@ public class AlertSpectrum extends AbstractSpectrumHandler{ }catch (Exception e){ //异常返回文件名称用于报错日志 super.returnFileName.append(super.spectrumFile.getName()); + + //处理解析失败的文件 + super.handleParseingFailFile(e); throw e; }finally { //把流程日志保存到日志目录 diff --git a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/HealthStatusSpectrum.java b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/HealthStatusSpectrum.java index 552b392f..13f4af23 100644 --- a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/HealthStatusSpectrum.java +++ b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/HealthStatusSpectrum.java @@ -91,6 +91,8 @@ public class HealthStatusSpectrum extends AbstractSpectrumHandler{ }catch (Exception e){ //异常返回文件名称用于报错日志 super.returnFileName.append(super.spectrumFile.getName()); + //处理解析失败的文件 + super.handleParseingFailFile(e); throw e; } }