1111

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

@@ -45,7 +45,13 @@ public class RabbitMqListener {
         String correlationId = (String) correlation;
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
         log.info("场景升级开始，队列名：{}，id：{},消息体:{}", upgradeToV4, correlationId, msg);
-        HashMap hashMap = JSON.parseObject(msg, HashMap.class);
+        HashMap hashMap = null;
+        try {
+            hashMap = JSON.parseObject(msg, HashMap.class);
+        }catch (Exception e){
+            log.error("消息结果错误");
+            return;
+        }
         int sceneProId = (int)hashMap.get("sceneProId");
         boolean reUpgrade = (boolean)hashMap.get("reUpgrade");
         //迁移数据