From a6b43a4b8d6188711bc916248736f77e10a2b97d Mon Sep 17 00:00:00 2001
From: like <1025687351@qq.com>
Date: Mon, 7 Apr 2025 18:04:42 +0800
Subject: [PATCH] =?UTF-8?q?=E5=96=8A=E8=AF=9D=E5=99=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/MegaphoneController.java       | 51 +++++++++++++++----
 1 file changed, 41 insertions(+), 10 deletions(-)

diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java b/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java
index a62929b..ae6737a 100644
--- a/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java
+++ b/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);
-        RedisOpsUtils.set(key,dto);
+        if (dto == null){
+            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);
-        RedisOpsUtils.set(key,dto);
+        if (dto == null){
+            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);
-        RedisOpsUtils.set(key,dto);
+        if (dto == null){
+            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());
-        RedisOpsUtils.set(key,dto);
+        if (dto == null){
+            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());
-        RedisOpsUtils.set(key,dto);
+        if (dto == null){
+            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);
     }