Bläddra i källkod

计算流程状态日志mq监听

dsx 2 år sedan
förälder
incheckning
1e403e5cb8

+ 2 - 9
src/main/java/com/fdkankan/contro/mq/service/impl/BuildV3SceneServiceImpl.java

@@ -111,11 +111,6 @@ public class BuildV3SceneServiceImpl implements IBuildSceneService {
         boolean success = false;
         boolean success = false;
         String num = message.getSceneNum();
         String num = message.getSceneNum();
         try {
         try {
-
-            //记录日志
-            sceneBuildProcessLogService.clearSceneBuildProcessLog(num, SceneBuildProcessType.PRE.code(), queueV3ModelingPre);
-            sceneBuildProcessLogService.saveSceneBuildProcessLog(num, SceneBuildProcessType.PRE.code(), queueV3ModelingPre, CommonOperStatus.WAITING.code(), null);
-
             //根据相机类型,组装资源路径
             //根据相机类型,组装资源路径
             //下载资源到本地
             //下载资源到本地
             this.downLoadSource(message, message.getPath());
             this.downLoadSource(message, message.getPath());
@@ -148,15 +143,13 @@ public class BuildV3SceneServiceImpl implements IBuildSceneService {
             //发送mq,就进行计算
             //发送mq,就进行计算
             mqProducer.sendByWorkQueue(queueModelingCall, message);
             mqProducer.sendByWorkQueue(queueModelingCall, message);
 
 
-            sceneBuildProcessLogService.saveSceneBuildProcessLog(num, SceneBuildProcessType.PRE.code(), queueV3ModelingPre, CommonOperStatus.SUCCESS.code(), null);
-
             success = true;
             success = true;
 
 
             log.info("场景计算资源准备结束,场景码:{}", message.getSceneNum());
             log.info("场景计算资源准备结束,场景码:{}", message.getSceneNum());
 
 
         }catch (Exception e){
         }catch (Exception e){
-            log.error("场景计算前置处理出错", e);
-            sceneBuildProcessLogService.saveSceneBuildProcessLog(num, SceneBuildProcessType.PRE.code(), queueV3ModelingPre, CommonOperStatus.FAILD.code(), ExceptionUtil.stacktraceToString(e, 3000));
+            log.error("场景计算前置处理出错,num="+num, e);
+            throw e;
         }finally {
         }finally {
             //如果前置处理失败,发送钉钉消息
             //如果前置处理失败,发送钉钉消息
             if(!success){
             if(!success){