diff --git a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/upgrade/provider/MoGoUpgradeProviderImpl.kt b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/upgrade/provider/MoGoUpgradeProviderImpl.kt index f8afaa5ab0..d53d6a3948 100644 --- a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/upgrade/provider/MoGoUpgradeProviderImpl.kt +++ b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/upgrade/provider/MoGoUpgradeProviderImpl.kt @@ -18,6 +18,7 @@ import com.zhjt.mogo_core_function_devatools.upgrade.provider.db.vo.UpgradeRecor import com.zhjt.service.chain.* import com.zhjt.service.chain.TracingConstants.Endpoint import java.util.TreeMap +import java.util.concurrent.TimeUnit @Route(path = MogoServicePaths.PATH_UPGRADE_TYPE_API) class MoGoUpgradeProviderImpl: IMoGoUpgradeProvider { @@ -235,6 +236,10 @@ class MoGoUpgradeProviderImpl: IMoGoUpgradeProvider { if (left.isNotEmpty()) { UpgradeDbHelper.deleteRecords(left.map { it.versionName }) } + if (fail != null && fail.time <= (System.currentTimeMillis() - TimeUnit.DAYS.toMillis(1))) { + //清除一天前的数据 + UpgradeDbHelper.deleteRecord(fail.versionName) + } return TreeMap>>().also { itx -> if (success != null) { val all = UpgradeDbHelper.getUpgradeRecordFull(success.versionName)