Sfoglia il codice sorgente

计算流程状态日志mq监听

dsx 2 anni fa
parent
commit
fa293e85c0

+ 8 - 6
src/main/java/com/fdkankan/contro/mq/listener/BuildSceneProcessLogListener.java

@@ -43,16 +43,18 @@ public class BuildSceneProcessLogListener{
         BuildSceneProcessLogMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneProcessLogMessage.class);
         String num = buildSceneMessage.getNum();
         try {
+            String reason = null;
+            int status = CommonOperStatus.SUCCESS.code();
             int buildStatus = buildSceneMessage.getBuildStatus();
             //新的计算开始,需要将之前的记录置为失效
             if(buildStatus == ModelingBuildStatus.CALCULATING.code()){
                 sceneBuildProcessLogService.clearSceneBuildProcessLog(num, SceneBuildProcessType.CALL.code(),queueModelingCall);
-            }
-            int status = CommonOperStatus.SUCCESS.code();
-            String reason = null;
-            if(buildStatus != ModelingBuildStatus.SUCCESS.code()){
-                status = CommonOperStatus.FAILD.code();
-                reason = ModelingBuildStatus.get(buildStatus).message();
+                status = CommonOperStatus.WAITING.code();
+            }else{
+                if(buildStatus != ModelingBuildStatus.SUCCESS.code()){
+                    status = CommonOperStatus.FAILD.code();
+                    reason = ModelingBuildStatus.get(buildStatus).message();
+                }
             }
             sceneBuildProcessLogService.saveSceneBuildProcessLog(num, SceneBuildProcessType.CALL.code(), queueModelingCall, status, reason);
         }catch (Exception e){