Browse Source

场景计算测试阶段先关闭钉钉推送

dengsixing 3 years ago
parent
commit
2e97c6b4fd

+ 14 - 8
4dkankan-center-modeling/src/main/java/com/fdkankan/modeling/receiver/BuildSceneMQListener.java

@@ -143,8 +143,9 @@ public class BuildSceneMQListener implements RocketMQListener<String> {
                     e.printStackTrace();
                 }
             } catch (Exception e) {
-                e.printStackTrace();
-                this.handFail("计算失败", message);
+                log.error("大场景计算失败",e);
+                // TODO: 2022/1/25 测试阶段,先注释掉推送
+//                this.handFail("计算失败", message);
             }
             log.info("场景生成好了***");
             return "success";
@@ -160,7 +161,8 @@ public class BuildSceneMQListener implements RocketMQListener<String> {
             log.error(trace.toString());
             FileUtils.deleteFile("/opt/hosts/running.txt");
             future.cancel(true);
-            handFail("计算超时",message);
+            // TODO: 2022/1/25 测试阶段,先注释掉推送
+//            handFail("计算超时",message);
         } catch (Exception e) {
             e.printStackTrace();
             StringWriter trace=new StringWriter();
@@ -168,7 +170,8 @@ public class BuildSceneMQListener implements RocketMQListener<String> {
             log.error(trace.toString());
             FileUtils.deleteFile("/opt/hosts/running.txt");
             future.cancel(true);
-            handFail("计算失败",message);
+            // TODO: 2022/1/25 测试阶段,先注释掉推送
+//            handFail("计算失败",message);
         }
 
     }
@@ -281,7 +284,8 @@ public class BuildSceneMQListener implements RocketMQListener<String> {
                 Thread.sleep(1000);
                 if(sceneProId == null){
                     log.info(projectNum + ":场景不存在");
-                    handFail("场景不存在",message);
+                    // TODO: 2022/1/25 测试阶段,先注释掉推送
+//                    handFail("场景不存在",message);
                     return;
                 }
 
@@ -608,8 +612,9 @@ public class BuildSceneMQListener implements RocketMQListener<String> {
                                 com.alibaba.fastjson.JSONObject.parseObject(restTemplate.getForObject(url,String.class));
                         log.info("激光转台相机 同步结束 :" + hotListJson);
                     }catch (Exception e){
-                        e.printStackTrace();
-                        handFail("激光转台相机同步失败",message);
+                        log.error("激光转台相机同步失败", e);
+                        // TODO: 2022/1/25 测试阶段,先注释掉推送
+//                        handFail("激光转台相机同步失败",message);
                     }
                 }
             }
@@ -622,7 +627,8 @@ public class BuildSceneMQListener implements RocketMQListener<String> {
             StringWriter trace=new StringWriter();
             e.printStackTrace(new PrintWriter(trace));
             log.error(trace.toString());
-            handFail("计算失败",message);
+            // TODO: 2022/1/25 测试阶段,先注释掉推送
+//            handFail("计算失败",message);
         }finally {
             //发送计算结果到mq,再由消费者消费并操作数据库
             rocketMQProducer.sendOneWay(buildSceneResultTopic,

+ 1 - 28
4dkankan-center-scene/src/main/resources/logback-spring.xml

@@ -200,33 +200,7 @@
         <appender-ref ref="VISIT_FILE"/>
     </logger>
 
-	<!-- 2.5 所有 除了DEBUG级别的其它高于DEBUG的 日志,记录到一个文件  -->
-	<appender name="ALL_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
-		<!-- 正在记录的日志文档的路径及文档名 -->
-		<file>${log.path}/all.log</file>
-		<!--日志文档输出格式-->
-		<encoder>
-			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50}[%L] - %msg%n</pattern>
-			<charset>UTF-8</charset> <!-- 此处设置字符集 -->
-		</encoder>
-		<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
-		<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-			<fileNamePattern>${log.path}/all-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
-			<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
-				<maxFileSize>100MB</maxFileSize>
-			</timeBasedFileNamingAndTriggeringPolicy>
-			<!--日志文档保留天数-->
-			<maxHistory>15</maxHistory>
-		</rollingPolicy>
-		<!-- 此日志文档记录除了DEBUG级别的其它高于DEBUG的 -->
-		<filter class="ch.qos.logback.classic.filter.LevelFilter">
-			<level>DEBUG</level>
-			<onMatch>DENY</onMatch>
-			<onMismatch>ACCEPT</onMismatch>
-		</filter>
-	</appender>
-
-	<!-- <logger>用来设置某一个包或者具体的某一个类的日志打印级别、 以及指定<appender>。<logger>仅有一个name属性, 一个可选的level和一个可选的addtivity属性。 name:用来指定受此logger约束的某一个包或者具体的某一个类。 level:用来设置打印级别,大小写无关:TRACE, 
+	<!-- <logger>用来设置某一个包或者具体的某一个类的日志打印级别、 以及指定<appender>。<logger>仅有一个name属性, 一个可选的level和一个可选的addtivity属性。 name:用来指定受此logger约束的某一个包或者具体的某一个类。 level:用来设置打印级别,大小写无关:TRACE,
 		DEBUG, INFO, WARN, ERROR, ALL 和 OFF, 还有一个特俗值INHERITED或者同义词NULL,代表强制执行上级的级别。 如果未设置此属性,那么当前logger将会继承上级的级别。 addtivity:是否向上级logger传递打印信息。默认是true。 -->
 	<!--<logger name="org.springframework.web" level="info"/> -->
 	<!--<logger name="org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor" level="INFO"/> -->
@@ -239,7 +213,6 @@
 				<appender-ref ref="INFO_FILE" />
 				<appender-ref ref="WARN_FILE" />
 				<appender-ref ref="ERROR_FILE" />
-				<appender-ref ref="ALL_FILE" />
 			</root>
 
 <!--	<springProfile name="dev">-->