喊话器

dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java

@@ -72,8 +72,14 @@ public class MegaphoneController {
                 .setData(param), DEFAULT_RETRY_COUNT, DEFAULT_RETRY_TIMEOUT);
         String key = "PSDK"+gatewaySn;
         MegaphoneDTO dto = (MegaphoneDTO) RedisOpsUtils.get(key);
-        dto.setStop(0);
+        if (dto == null){
-        RedisOpsUtils.set(key,dto);
+            MegaphoneDTO dto1 = new MegaphoneDTO();
+            dto1.setStop(0);
+            RedisOpsUtils.set(key,dto1);
+        }else {
+            dto.setStop(0);
+            RedisOpsUtils.set(key,dto);
+        }
         return HttpResultResponse.success(servicesReplyReceiverCommonTopicResponse);
     }
 
@@ -99,8 +105,15 @@ public class MegaphoneController {
                 .setData(param), DEFAULT_RETRY_COUNT, DEFAULT_RETRY_TIMEOUT);
         String key = "PSDK"+gatewaySn;
         MegaphoneDTO dto = (MegaphoneDTO) RedisOpsUtils.get(key);
-        dto.setStop(0);
+        if (dto == null){
-        RedisOpsUtils.set(key,dto);
+            MegaphoneDTO dto1 = new MegaphoneDTO();
+            dto1.setStop(0);
+            RedisOpsUtils.set(key,dto1);
+        }else {
+            dto.setStop(0);
+            RedisOpsUtils.set(key,dto);
+        }
+
         return HttpResultResponse.success(servicesReplyReceiverCommonTopicResponse);
     }
     /**
@@ -125,8 +138,14 @@ public class MegaphoneController {
                 .setData(param), DEFAULT_RETRY_COUNT, DEFAULT_RETRY_TIMEOUT);
         String key = "PSDK"+gatewaySn;
         MegaphoneDTO dto = (MegaphoneDTO) RedisOpsUtils.get(key);
-        dto.setStop(1);
+        if (dto == null){
-        RedisOpsUtils.set(key,dto);
+            MegaphoneDTO dto1 = new MegaphoneDTO();
+            dto1.setStop(1);
+            RedisOpsUtils.set(key,dto1);
+        }else {
+            dto.setStop(1);
+            RedisOpsUtils.set(key,dto);
+        }
         return HttpResultResponse.success(servicesReplyReceiverCommonTopicResponse);
     }
 
@@ -152,8 +171,14 @@ public class MegaphoneController {
                 .setData(param), DEFAULT_RETRY_COUNT, DEFAULT_RETRY_TIMEOUT);
         String key = "PSDK"+gatewaySn;
         MegaphoneDTO dto = (MegaphoneDTO) RedisOpsUtils.get(key);
-        dto.setPlay_mode(param.getPlay_mode());
+        if (dto == null){
-        RedisOpsUtils.set(key,dto);
+            MegaphoneDTO dto1 = new MegaphoneDTO();
+            dto1.setPlay_mode(param.getPlay_mode());
+            RedisOpsUtils.set(key,dto1);
+        }else {
+            dto.setPlay_mode(param.getPlay_mode());
+            RedisOpsUtils.set(key,dto);
+        }
         return HttpResultResponse.success(servicesReplyReceiverCommonTopicResponse);
     }
 
@@ -182,8 +207,14 @@ public class MegaphoneController {
                 .setData(param), DEFAULT_RETRY_COUNT, DEFAULT_RETRY_TIMEOUT);
         String key = "PSDK"+gatewaySn;
         MegaphoneDTO dto = (MegaphoneDTO) RedisOpsUtils.get(key);
-        dto.setPlay_volume(param.getPlay_volume());
+        if (dto == null){
-        RedisOpsUtils.set(key,dto);
+            MegaphoneDTO dto1 = new MegaphoneDTO();
+            dto1.setPlay_volume(param.getPlay_volume());
+            RedisOpsUtils.set(key,dto1);
+        }else {
+            dto.setPlay_volume(param.getPlay_volume());
+            RedisOpsUtils.set(key,dto);
+        }
         return HttpResultResponse.success(servicesReplyReceiverCommonTopicResponse);
     }