dengsixing 3 tháng trước cách đây
mục cha
commit
d328d5af10

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

@@ -131,6 +131,7 @@ public class RabbitMqListener {
 
         //进入计算程序前,场景已删除,就不往下跑
         if(SysConstants.interrupCallingNums.contains(buildSceneMessage.getSceneNum())){
+            SysConstants.interrupCallingNums.remove(buildSceneMessage.getSceneNum());
             channel.basicAck(deliveryTag, false);
         }
 
@@ -267,7 +268,8 @@ public class RabbitMqListener {
 
         //场景已删除,不启动算法进程
         if(SysConstants.interrupCallingNums.contains(num)){
-            throw new BusinessException(ErrorCode.APP_ID_ILLEGAL);
+            SysConstants.interrupCallingNums.remove(num);
+            throw new BusinessException(ErrorCode.FAILURE_CODE_5009);
         }
 
         //计算模型并返回需要上传oss的文件集合