浏览代码

深光合并

dsx 1 年之前
父节点
当前提交
f3375bf8ac

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

@@ -146,11 +146,12 @@ public class RabbitMqListener {
                 message.getResultReceiverMqName() : queueModelingPost;
         buildSceneResult.setResultQueueName(resultQueueName);
         ModelingBuildStatus status = null;
+        Future<ModelingBuildStatus> future = null;
         try {
             Map<String,Object> buildContext = new HashMap<>();
             //计算前准备
             preBuild(buildContext,message, buildLog);
-            Future<ModelingBuildStatus> future = SysConstants.executorService.submit(() -> {
+            future = SysConstants.executorService.submit(() -> {
                 try {
                     return buildScene(buildContext,message, buildSceneResult,buildLog);
                 } catch (Exception e) {
@@ -167,6 +168,9 @@ public class RabbitMqListener {
         } catch (TimeoutException ex) {
             log.error("服务实例:{} 构建异常:",SysConstants.hostName,ex);
             status = ModelingBuildStatus.OVERTIME;
+            log.info("释放线程");
+            //场景计算超时,需要中断当前执行任务,释放线程池中的任务线程,否则下个场景计算获取不到线程进行计算
+            future.cancel(true);
         } catch (BuildException e){
             status = e.getBuildStatus();
         } catch(Exception e) {

+ 8 - 1
src/main/java/com/fdkankan/modeling/service/impl/BuildServiceImpl.java

@@ -52,10 +52,15 @@ public class BuildServiceImpl implements IBuildService {
             }
 
             if(Integer.parseInt(cameraType) == 14){
+                Integer location = fdageData.getInteger("location");
                 //转台相机
                 log.info("激光转台相机调用算法");
                 skyboxType = "SKYBOX_V11";
                 splitType = "SPLIT_V14";
+                if(location == 5 || location == 6){//深广相机SLAM拍摄模式,5:纯slam,6:有点位
+//                    skyboxType = "SKYBOX_V6";
+                    splitType = "SPLIT_V25";
+                }
                 if (!ObjectUtils.isEmpty(fdageData)) {
                     if ((fdageData.containsKey("exportMeshObj") && fdageData.getIntValue("exportMeshObj") == 1)) {
                         splitType = "SPLIT_V22";
@@ -82,7 +87,9 @@ public class BuildServiceImpl implements IBuildService {
                 case ModelTypeEnums.TILE_CODE:
                     if(skyboxType.equals("SKYBOX_V6")){
                         skyboxType = "SKYBOX_V14";
-                    }else{
+                    }else if(skyboxType.equals("SKYBOX_V11")){
+                        skyboxType = "SKYBOX_V15";
+                    } else{
                         skyboxType = "SKYBOX_V13";
                     }
             }

+ 7 - 7
src/main/resources/logback-spring.xml

@@ -18,7 +18,7 @@
 	<conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter" />
 	<!-- 彩色日志格式 -->
 	<property name="CONSOLE_LOG_PATTERN"
-		value="${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}" />
+			  value="${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}" />
 
 	<!--输出到控制台 -->
 	<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
@@ -144,7 +144,7 @@
 			<onMismatch>DENY</onMismatch>
 		</filter>
 	</appender>
-	
+
 	<appender name="PROGRAM_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
 		<!-- 正在记录的日志文件的路径及文件名 -->
 		<file>${log.path}/program/log_program.log</file>
@@ -170,8 +170,8 @@
 		</filter>
 	</appender>
 	<logger name="programLog" level="INFO" additivity="true">
-        <appender-ref ref="PROGRAM_FILE"/>
-    </logger>
+		<appender-ref ref="PROGRAM_FILE"/>
+	</logger>
 
 	<appender name="VISIT_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
 		<!-- 正在记录的日志文件的路径及文件名 -->
@@ -199,10 +199,10 @@
 		</filter>
 	</appender>
 	<logger name="visitLog" level="INFO" additivity="true">
-        <appender-ref ref="VISIT_FILE"/>
-    </logger>
+		<appender-ref ref="VISIT_FILE"/>
+	</logger>
 
-	<!-- <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"/> -->