1

src/main/java/com/fdkankan/mqcontroller/service/impl/ScenePlusServiceImpl.java

@@ -37,11 +37,13 @@ public class ScenePlusServiceImpl extends ServiceImpl<IScenePlusMapper, ScenePlu
             return null;
         }
         JSONObject jsonObject = JSONObject.parseObject(mqSendLog.getContent());
-        JSONObject jsonObject2  = jsonObject.getJSONObject("ext");
-        if(jsonObject2.containsKey("128G") && jsonObject2.getInteger("128G") == 1){
-            MqQueueConfig dfConfig = queueConfigService.getDfConfig128();
-            if(dfConfig != null){
-                return dfConfig.getId();
+        if(jsonObject.containsKey("ext")){
+            JSONObject ext  = jsonObject.getJSONObject("ext");
+            if(ext.containsKey("128G") && ext.getInteger("128G") == 1){
+                MqQueueConfig dfConfig = queueConfigService.getDfConfig128();
+                if(dfConfig != null){
+                    return dfConfig.getId();
+                }
             }
         }