e57

src/main/java/com/fdkankan/contro/mq/listener/BuildE57Listener.java

@@ -32,7 +32,7 @@ public class BuildE57Listener{
     @Value("${queue.modeling.e57.modeling-pre:e57-modeling-pre}")
     private String queueModelingPre;
 
-    @Value("${queue.modeling.e57.modeling-pre:e57-modeling-post}")
+    @Value("${queue.modeling.e57.modeling-post:e57-modeling-post}")
     private String queueModelingPost;
 
     @Autowired

src/main/java/com/fdkankan/contro/mq/service/impl/BuildE57SceneServiceImpl.java

@@ -48,7 +48,7 @@ public class BuildE57SceneServiceImpl implements IBuildSceneService {
     private String env;
     @Value("#{'${build.scene.post.not-delete-nas-nums:}'.split(',')}")
     private List<String> notDeleteNasNumList;
-    @Value("${queue.modeling.e57.modeling-done:e57-modeling-done}")
+    @Value("${queue.application.laser.e57-modeling-done:e57-modeling-done}")
     private String queueE57ModelingDone;
     @Autowired
     private RabbitMqProducer mqProducer;
@@ -146,8 +146,12 @@ public class BuildE57SceneServiceImpl implements IBuildSceneService {
             String ossKey = String.format(ossKeyFormat, num, num);
             ZipUtil.zip(localPath, zipPath);
             fYunFileService.uploadFile(bucket, zipPath, ossKey);
-            log.info("e57场景计算结果处理结束，场景码：{}", num);
 
+            //发送mq通知激光系统
+            laserMqContent.put("status", CommonSuccessStatus.SUCCESS.code());
+            mqProducer.sendByWorkQueue(queueE57ModelingDone, laserMqContent);
+
+            log.info("e57场景计算结果处理结束，场景码：{}", num);
         }catch (Exception e){
             log.error("e57场景计算结果处理出错,num"+num, e);
             buildSceneDTService.handBaseFail("e57场景计算结果处理出错！", message.getPath(), num, "计算控制服务器");