浏览代码

http://192.168.0.21/index.php?m=bug&f=view&bugID=47574

dengsixing 10 月之前
父节点
当前提交
d10d5ac3b7

+ 7 - 0
src/main/java/com/fdkankan/scene/service/IWbService.java

@@ -0,0 +1,7 @@
+package com.fdkankan.scene.service;
+
+public interface IWbService {
+
+    void sendMq(String num);
+
+}

+ 5 - 0
src/main/java/com/fdkankan/scene/service/impl/SceneEditInfoServiceImpl.java

@@ -118,6 +118,8 @@ public class SceneEditInfoServiceImpl extends ServiceImpl<ISceneEditInfoMapper,
     private ISceneDrawService sceneDrawService;
     @Autowired
     private ISceneDynamicPanelService sceneDynamicPanelService;
+    @Autowired
+    private IWbService wbService;
 
     @Transactional
     @Override
@@ -316,6 +318,9 @@ public class SceneEditInfoServiceImpl extends ServiceImpl<ISceneEditInfoMapper,
         scenePlus.setHouseType(this.existsHouseType(bucket, num));
         scenePlusService.updateById(scenePlus);
 
+        //推送文保系统
+        wbService.sendMq(num);
+
         return ResultData.ok();
     }
 

+ 50 - 0
src/main/java/com/fdkankan/scene/service/impl/WbServiceImpl.java

@@ -0,0 +1,50 @@
+package com.fdkankan.scene.service.impl;
+
+import com.fdkankan.common.constant.SceneSource;
+import com.fdkankan.rabbitmq.util.RabbitMqProducer;
+import com.fdkankan.scene.entity.Camera;
+import com.fdkankan.scene.entity.CameraDetail;
+import com.fdkankan.scene.entity.ScenePlus;
+import com.fdkankan.scene.service.ICameraDetailService;
+import com.fdkankan.scene.service.ICameraService;
+import com.fdkankan.scene.service.IScenePlusService;
+import com.fdkankan.scene.service.IWbService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+@Slf4j
+@Service
+public class WbServiceImpl implements IWbService {
+
+    @Autowired
+    private RabbitMqProducer mqProducer;
+    @Autowired
+    private IScenePlusService scenePlusService;
+    @Autowired
+    private ICameraService cameraService;
+    @Autowired
+    private ICameraDetailService cameraDetailService;
+
+    @Override
+    public void sendMq(String num) {
+        try {
+            ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
+            Camera camera = cameraService.getById(scenePlus.getCameraId());
+            CameraDetail cameraDetail = cameraDetailService.findByCameraId(camera.getId());
+            if(Objects.isNull(cameraDetail.getCompanyId()) || cameraDetail.getCompanyId() != 26 || scenePlus.getSceneSource() != SceneSource.ZT.code().intValue()){
+                return;
+            }
+            Map<String, Object> params = new HashMap<>();
+            params.put("sceneCode", num);
+            params.put("sceneName", scenePlus.getTitle());
+            mqProducer.sendByWorkQueue("relics-update-name-queue", params);
+        }catch (Exception e){
+            log.error("发送看见场景到全景看看失败, num:{}", num, e);
+        }
+    }
+}