diff --git a/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java b/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java index 8b0aad2..8c91519 100644 --- a/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java +++ b/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java @@ -247,6 +247,8 @@ public class MqttMessageHandler { logDto.setResult(0); logDto.setFailReason(AccessResponseEnum.MODEL_VERSION_ERROR.getMessage()); csLogsFeignClient.addUserLog(logDto); + //有异常删除缓存的模板信息 + redisUtil.delete(AppRedisKey.MODEL + nDid); throw new BusinessException(AccessResponseEnum.MODEL_VERSION_ERROR); } //校验前置传递的装置模板库中是否存在 @@ -265,6 +267,8 @@ public class MqttMessageHandler { logDto.setResult(0); logDto.setFailReason(AccessResponseEnum.MODEL_NO_FIND.getMessage()); csLogsFeignClient.addUserLog(logDto); + //有异常删除缓存的模板信息 + redisUtil.delete(AppRedisKey.MODEL + nDid); throw new BusinessException(AccessResponseEnum.MODEL_NO_FIND); } if (Objects.equals(po.getType(),0)){ @@ -273,6 +277,8 @@ public class MqttMessageHandler { logDto.setResult(0); logDto.setFailReason(AccessResponseEnum.MODULE_NUMBER_IS_NULL.getMessage()); csLogsFeignClient.addUserLog(logDto); + //有异常删除缓存的模板信息 + redisUtil.delete(AppRedisKey.MODEL + nDid); throw new BusinessException(AccessResponseEnum.MODULE_NUMBER_IS_NULL); } csModelDto.setModuleNumber(dataSetList.size());