浏览代码

修改重复构建判断逻辑

tianboguang 2 年之前
父节点
当前提交
4d79f112ba
共有 1 个文件被更改,包括 4 次插入4 次删除
  1. 4 4
      src/main/java/com/fdkankan/modeling/receiver/RabbitMqListener.java

+ 4 - 4
src/main/java/com/fdkankan/modeling/receiver/RabbitMqListener.java

@@ -334,11 +334,11 @@ public class RabbitMqListener {
         // 获取缓存锁,防止重复消费
         // 获取缓存锁,防止重复消费
         Long building = redisUtil.incr(key, 1);
         Long building = redisUtil.incr(key, 1);
         buildLogService.save(buildLog);
         buildLogService.save(buildLog);
-        if (building.equals(1L)) {
-            log.error("服务:{},重复构建:{}",SysConstants.hostName,buildLog.getSceneNum());
+        if (building > 1) {
+            log.error("服务:{},重复构建:{}", SysConstants.hostName, buildLog.getSceneNum());
             throw new BuildException(ModelingBuildStatus.REPEAT);
             throw new BuildException(ModelingBuildStatus.REPEAT);
-        }else{
-            redisUtil.expire(key,SysConstants.modelTimeOut);
+        } else {
+            redisUtil.expire(key, SysConstants.modelTimeOut);
         }
         }
     }
     }