1

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

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