lyhzzz 2 年之前
父节点
当前提交
69f3c29532

+ 1 - 0
src/main/java/com/fdkankan/manage/service/ISceneProService.java

@@ -25,6 +25,7 @@ public interface ISceneProService extends IService<ScenePro> {
     void unbindCamera(Long cameraId);
 
     void lockOrUnLockBySpace(CameraDetail cameraDetail,Long cameraId,Integer payStatus);
+    void lockOrUnLockBySpace(Long cameraId);
     void lockOrUnLockBySpace(ScenePro scenePro, ScenePlus scenePlus,Integer payStatus);
 
     List<ScenePro> getListByCameraId(Long cameraId);

+ 8 - 0
src/main/java/com/fdkankan/manage/service/impl/SceneProServiceImpl.java

@@ -156,6 +156,13 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
     }
 
     @Override
+    public void lockOrUnLockBySpace(Long cameraId) {
+        ScenePayStatusVo scenePayStatusVo = new ScenePayStatusVo(cameraId);
+        Map<String, Object> map = BeanUtil.beanToMap(scenePayStatusVo);
+        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatusQueue, map);
+    }
+
+    @Override
     public void lockOrUnLockBySpace(ScenePro scenePro, ScenePlus scenePlus,Integer payStatus) {
         Long sceneId = scenePro == null ? scenePlus.getId() : scenePro.getId();
         ScenePayStatusVo scenePayStatusVo = new ScenePayStatusVo(sceneId,payStatus);
@@ -514,6 +521,7 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
         }
         if(cameraId != null){
             cameraDetailService.initSpace(cameraId);
+            this.lockOrUnLockBySpace(cameraId);
         }
         sceneDelLogService.saveLog(num, StpUtil.getLoginId());
     }