lyhzzz 2 years ago
parent
commit
4529162007

+ 5 - 2
src/main/java/com/fdkankan/manage/service/impl/SceneProServiceImpl.java

@@ -1,6 +1,7 @@
 package com.fdkankan.manage.service.impl;
 
 import cn.dev33.satoken.stp.StpUtil;
+import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.io.FileUtil;
 import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSONArray;
@@ -150,14 +151,16 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
     public void lockOrUnLockBySpace(CameraDetail cameraDetail, Long cameraId, Integer payStatus) {
 
         ScenePayStatusVo scenePayStatusVo = new ScenePayStatusVo(cameraDetail.getCameraId());
-        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatusQueue, JSONObject.toJSONString(scenePayStatusVo));
+        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);
-        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatusQueue, JSONObject.toJSONString(scenePayStatusVo));
+        Map<String, Object> map = BeanUtil.beanToMap(scenePayStatusVo);
+        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatusQueue, map);
     }