浏览代码

计算优化

dengsixing 3 年之前
父节点
当前提交
26e4e0291e

+ 8 - 8
4dkankan-center-modeling/src/main/java/com/fdkankan/modeling/receiver/BuildSceneListener.java

@@ -418,14 +418,14 @@ public class BuildSceneListener implements RocketMQListener<String> {
         buildLog.setDataSource(message.getDataSource());
         buildLogService.save(buildLog);
 
-        String key = RedisKey.SCENE_BUILDING + message.getSceneNum();
-        Long building = redisUtil.incr(key, 1);
-        if (building.compareTo(1L) != 0) {
-            log.error("场景正在构建中,退出构建,当前服务器id:{},参数:{}", SysConstants.hostName, JSONObject.toJSONString(message));
-            throw new BuildException(ModelingBuildStatus.REPEAT);
-        } else {
-            redisUtil.expire(key, Duration.of(SysConstants.modelTimeOut, ChronoUnit.HOURS));
-        }
+//        String key = RedisKey.SCENE_BUILDING + message.getSceneNum();
+//        Long building = redisUtil.incr(key, 1);
+//        if (building.compareTo(1L) != 0) {
+//            log.error("场景正在构建中,退出构建,当前服务器id:{},参数:{}", SysConstants.hostName, JSONObject.toJSONString(message));
+//            throw new BuildException(ModelingBuildStatus.REPEAT);
+//        } else {
+//            redisUtil.expire(key, Duration.of(SysConstants.modelTimeOut, ChronoUnit.HOURS));
+//        }
     }
 
     private void copyToEditDir(String num) throws IOException {