Преглед на файлове

修改消息处理逻辑

tianboguang преди 2 години
родител
ревизия
8b43e4b6b8
променени са 1 файла, в които са добавени 2 реда и са изтрити 4 реда
  1. 2 4
      src/main/java/com/fdkankan/modeling/receiver/RabbitMqListener.java

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

@@ -234,10 +234,8 @@ public class RabbitMqListener {
         try {
             buildStatus = buildSceneResult.getBuildStatus();
             log.info("服务{} 计算结束:{},计算状态:{}", SysConstants.hostName, buildLog.getSceneNum(),buildStatus.message());
-            if(!buildStatus.equals(ModelingBuildStatus.REPEAT)){
-                //释放锁
-                redisUtil.del(String.format(RedisKey.SCENE_BUILDING, message.getSceneNum()));
-            }
+            //释放锁
+            redisUtil.decr(SysConstants.SCENE_BUILDING + buildLog.getSceneNum(),1);
             buildLog.setUpdateTime(new Date());
             buildLogService.updateById(buildLog);
         } catch (Exception e) {