8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-09 16:32:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

网关增加配置及修改配置时，version不变化问题修复

Browse Source
This commit is contained in:
zengqiao
2022-01-07 15:35:14 +08:00
parent 354e0d6a87
commit 4e10f8d1c5
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/GatewayConfigServiceImpl.java
View File

@@ -185,7 +185,8 @@ public class GatewayConfigServiceImpl implements GatewayConfigService {
List<GatewayConfigDO> gatewayConfigDOList = gatewayConfigDao.getByConfigType(gatewayConfigDO.getType()); List<GatewayConfigDO> gatewayConfigDOList = gatewayConfigDao.getByConfigType(gatewayConfigDO.getType());
Long version = 1L; Long version = 1L;
for (GatewayConfigDO elem: gatewayConfigDOList) { for (GatewayConfigDO elem: gatewayConfigDOList) {
if (elem.getVersion() > version) { if (elem.getVersion() >= version) {
// 大于等于的情况下，都需要+1
version = elem.getVersion() + 1L; version = elem.getVersion() + 1L;
} }
} }
@@ -204,6 +205,7 @@ public class GatewayConfigServiceImpl implements GatewayConfigService {
@Override @Override
public Result deleteById(Long id) { public Result deleteById(Long id) {
try { try {
// TODO 删除的时候，不能直接删，也需要变更一下version
if (gatewayConfigDao.deleteById(id) > 0) { if (gatewayConfigDao.deleteById(id) > 0) {
return Result.buildSuc(); return Result.buildSuc();
} }
@@ -232,7 +234,8 @@ public class GatewayConfigServiceImpl implements GatewayConfigService {
List<GatewayConfigDO> gatewayConfigDOList = gatewayConfigDao.getByConfigType(newGatewayConfigDO.getType()); List<GatewayConfigDO> gatewayConfigDOList = gatewayConfigDao.getByConfigType(newGatewayConfigDO.getType());
Long version = 1L; Long version = 1L;
for (GatewayConfigDO elem: gatewayConfigDOList) { for (GatewayConfigDO elem: gatewayConfigDOList) {
if (elem.getVersion() > version) { if (elem.getVersion() >= version) {
// 大于等于的情况下，都需要+1
version = elem.getVersion() + 1L; version = elem.getVersion() + 1L;
} }
} }