v4.13.0

src/main/java/com/fdkankan/scene/listener/RabbitMqListener.java

@@ -91,7 +91,7 @@ public class RabbitMqListener {
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
         log.info("开始消费消息,id:{},queue:{},content:{}", messageId, "save-scene-orientation", msg);
         try {
-            Map<String, String> map = JSON.parseObject(msg, Map.class);
+            Map<String, Object> map = JSON.parseObject(msg, Map.class);
             sceneService.saveSceneOientation(map);
         }catch (Exception e){
             log.error("更新场景方向报错", e);

src/main/java/com/fdkankan/scene/service/ISceneService.java

@@ -15,6 +15,6 @@ public interface ISceneService {
 
     ResultData getBodySegmentStatus(String uuid);
 
-    void saveSceneOientation(Map<String, String> map);
+    void saveSceneOientation(Map<String, Object> map);
 
 }

src/main/java/com/fdkankan/scene/service/impl/SceneServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.io.FileUtil;
 import cn.hutool.core.lang.UUID;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.fdkankan.common.constant.CommonOperStatus;
 import com.fdkankan.common.constant.ErrorCode;
 import com.fdkankan.common.exception.BusinessException;
@@ -165,16 +166,21 @@ public class SceneServiceImpl implements ISceneService {
     }
 
     @Override
-    public void saveSceneOientation(Map<String, String> map) {
-        String num = map.get("num");
-        String orientation = map.get("orientation");
+    public void saveSceneOientation(Map<String, Object> map) {
+        String num = (String) map.get("num");
+        String orientation = (String)map.get("orientation");
+        Integer status = (Integer)map.get("status");
         ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
         if(Objects.isNull(scenePlus)){
             return;
         }
         ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
-        scenePlusExt.setOrientation(orientation);
-        scenePlusExtService.updateById(scenePlusExt);
+        if(status == 0){
+            scenePlusExtService.update(new LambdaUpdateWrapper<ScenePlusExt>().eq(ScenePlusExt::getId, scenePlusExt.getId()).setSql("set orientation = null"));
+        }else{
+            scenePlusExt.setOrientation(orientation);
+            scenePlusExtService.updateById(scenePlusExt);
+        }
     }
 
     @Override