From 4e10f8d1c581034f3c04a1c8964b66f0ea307b4a Mon Sep 17 00:00:00 2001 From: zengqiao Date: Fri, 7 Jan 2022 15:35:14 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BD=91=E5=85=B3=E5=A2=9E=E5=8A=A0=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E5=8F=8A=E4=BF=AE=E6=94=B9=E9=85=8D=E7=BD=AE=E6=97=B6?= =?UTF-8?q?=EF=BC=8Cversion=E4=B8=8D=E5=8F=98=E5=8C=96=E9=97=AE=E9=A2=98?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/gateway/impl/GatewayConfigServiceImpl.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/GatewayConfigServiceImpl.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/GatewayConfigServiceImpl.java index 0ceb3b30..754a81a7 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/GatewayConfigServiceImpl.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/GatewayConfigServiceImpl.java @@ -185,7 +185,8 @@ public class GatewayConfigServiceImpl implements GatewayConfigService { List gatewayConfigDOList = gatewayConfigDao.getByConfigType(gatewayConfigDO.getType()); Long version = 1L; for (GatewayConfigDO elem: gatewayConfigDOList) { - if (elem.getVersion() > version) { + if (elem.getVersion() >= version) { + // 大于等于的情况下，都需要+1 version = elem.getVersion() + 1L; } } @@ -204,6 +205,7 @@ public class GatewayConfigServiceImpl implements GatewayConfigService { @Override public Result deleteById(Long id) { try { + // TODO 删除的时候，不能直接删，也需要变更一下version if (gatewayConfigDao.deleteById(id) > 0) { return Result.buildSuc(); } @@ -232,7 +234,8 @@ public class GatewayConfigServiceImpl implements GatewayConfigService { List gatewayConfigDOList = gatewayConfigDao.getByConfigType(newGatewayConfigDO.getType()); Long version = 1L; for (GatewayConfigDO elem: gatewayConfigDOList) { - if (elem.getVersion() > version) { + if (elem.getVersion() >= version) { + // 大于等于的情况下，都需要+1 version = elem.getVersion() + 1L; } }