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 c0ccad74..c701086f 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 @@ -1,5 +1,6 @@ package org.jeecg.modules.spectrum; +import cn.hutool.core.util.ObjectUtil; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.constant.StringConstant; import org.jeecg.common.properties.SpectrumPathProperties; @@ -88,6 +89,11 @@ public class AlertSpectrum extends AbstractSpectrumHandler{ //若本次文件来自于undel目录,解析成功则删除 deleteIfFromUndelFile(); }catch (Exception e){ + // 如果解析流程异常 入库开始/结束时间赋初始值 + if (ObjectUtil.isNull(this.startIntoDatabaseTime)) + this.startIntoDatabaseTime = new Date(); + if (ObjectUtil.isNull(this.endIntoDatabaseTime)) + this.endIntoDatabaseTime = new Date(); //异常返回文件名称用于报错日志 super.returnFileName.append(super.spectrumFile.getName()); 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 b85c6c0c..2fea9251 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 @@ -1,5 +1,6 @@ package org.jeecg.modules.spectrum; +import cn.hutool.core.util.ObjectUtil; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.constant.StringConstant; import org.jeecg.common.properties.SpectrumPathProperties; @@ -89,6 +90,12 @@ public class HealthStatusSpectrum extends AbstractSpectrumHandler{ //若本次文件来自于undel目录,解析成功则删除 deleteIfFromUndelFile(); }catch (Exception e){ + // 如果解析流程异常 入库开始/结束时间赋初始值 + if (ObjectUtil.isNull(this.startIntoDatabaseTime)) + this.startIntoDatabaseTime = new Date(); + if (ObjectUtil.isNull(this.endIntoDatabaseTime)) + this.endIntoDatabaseTime = new Date(); + //异常返回文件名称用于报错日志 super.returnFileName.append(super.spectrumFile.getName()); //处理解析失败的文件 diff --git a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/MetSpectrum.java b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/MetSpectrum.java index 7125a537..4bd5d96c 100644 --- a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/MetSpectrum.java +++ b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/spectrum/MetSpectrum.java @@ -1,5 +1,6 @@ package org.jeecg.modules.spectrum; +import cn.hutool.core.util.ObjectUtil; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.constant.StringConstant; import org.jeecg.common.properties.SpectrumPathProperties; @@ -80,6 +81,12 @@ public class MetSpectrum extends AbstractSpectrumHandler{ //若本次文件来自于undel目录,解析成功则删除 deleteIfFromUndelFile(); }catch (Exception e){ + // 如果解析流程异常 入库开始/结束时间赋初始值 + if (ObjectUtil.isNull(this.startIntoDatabaseTime)) + this.startIntoDatabaseTime = new Date(); + if (ObjectUtil.isNull(this.endIntoDatabaseTime)) + this.endIntoDatabaseTime = new Date(); + //异常返回文件名称用于报错日志 super.returnFileName.append(super.spectrumFile.getName()); throw e;