From 21ee13e71f7bd0e43a9781f2665521f15e49156c Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Fri, 16 Aug 2024 18:18:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/njcn/access/handler/MqttMessageHandler.java    | 6 ++++++
 1 file changed, 6 insertions(+)

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