计算场景关闭推送钉钉

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildSceneFailDTMQListener.java

@@ -87,8 +87,8 @@ public class BuildSceneFailDTMQListener implements RocketMQListener<String> {
     }
 
     private void process(BuildSceneFailDTMqMessage message){
-        buildScenePreService.handFail(message.getReason(), message.getServerPath(), message.getNum(), message.getHostName(),
-            BuildScenePreServiceImpl.contentExt);
+//        buildScenePreService.handFail(message.getReason(), message.getServerPath(), message.getNum(), message.getHostName(),
+//            BuildScenePreServiceImpl.contentExt);
     }
 
 }

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildScenePreMQListener.java

@@ -126,11 +126,13 @@ public class BuildScenePreMQListener implements RocketMQListener<String> {
             //发送mq，就进行计算
             producer.syncSend(topicName, message);
 
+            log.info("场景计算前置处理完成，场景码：{}", message.getSceneNum());
+
         }catch (Exception e){
             log.error("场景计算前置处理出错", e);
             //发送钉钉
             String serverPath = message.getPath().substring(0,message.getPath().lastIndexOf("/")+1).concat(message.getPrefix());
-            buildScenePreService.handFail("前置处理失败", serverPath, message.getSceneNum(), BuildScenePreServiceImpl.hostName, null);
+//            buildScenePreService.handFail("前置处理失败", serverPath, message.getSceneNum(), BuildScenePreServiceImpl.hostName, null);
         }
     }
 

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildSceneResultMQListener.java

@@ -184,10 +184,10 @@ public class BuildSceneResultMQListener implements RocketMQListener<String> {
             buildScenePreService.uploadLogFile(sceneCode, sceneProExt.getDataSource());
 
         }catch (Exception e){
-            log.error("场景计算后置处理出错：{}",e);
+            log.error("场景计算后置处理出错", e);
             //发送钉钉
             String serverPath = message.getPath().substring(0,message.getPath().lastIndexOf("/")+1).concat(prefix);
-            buildScenePreService.handFail("后置处理失败", serverPath, sceneCode, BuildScenePreServiceImpl.hostName, BuildScenePreServiceImpl.contentExt);
+//            buildScenePreService.handFail("后置处理失败", serverPath, sceneCode, BuildScenePreServiceImpl.hostName, BuildScenePreServiceImpl.contentExt);
         }
     }