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); }