缓存更新

2024年8月21日14:32:58

modules/thing/src/main/java/com/thing/listener/QueueDeviceEventListener.java

@@ -87,7 +87,13 @@ public class QueueDeviceEventListener {
                 //更新物模板缓存
                 List<IotThingModelDTO> iotThingModelDTOS = ConvertUtils.sourceToTarget(insertModelList, IotThingModelDTO.class);
                 List<ObjectNode> modelList = JsonConverter.convertToJsonObjectListObjectNode(iotThingModelDTOS);
-                CacheInit.modelMap(modelList,thingCache);
+
+                for (ObjectNode item : modelList) {
+                    //更新物模型
+                    thingCache.updateKeyMap(CacheNameEnum.THING_MODEL
+                            , item.get(CacheNameEnum.ModelField.THING_MODEL_CODE.getField()).asText()
+                                    + ":" + item.get(CacheNameEnum.ModelField.THING_MODEL_ID.getField()).asText(),item);
+                }
 
                 if(CollectionUtils.isNotEmpty(insertEntityList)){
                     List<IotThingEntity> distinctStudentFile = insertEntityList.stream()
@@ -122,7 +128,12 @@ public class QueueDeviceEventListener {
                                 .setCreateDate(e.getCreateDate());
                     }).toList();
                     List<ObjectNode> entityJsonList = JsonConverter.convertToJsonObjectListObjectNode(entityList);
-                    CacheInit.entityMap(entityJsonList,thingCache);
+                    for (ObjectNode entityNode : entityJsonList) {
+                        thingCache.updateKeyMap(CacheNameEnum.THING_ENTITY
+                                ,entityNode.get(CacheNameEnum.EntityField.THING_ENTITY_TENANT_CODE.getField()).asText()
+                                        + ":" + entityNode.get(CacheNameEnum.EntityField.THING_ENTITY_CODE.getField()).asText()
+                                        + ":" + entityNode.get(CacheNameEnum.EntityField.THING_ENTITY_ID.getField()).asText(),entityNode);
+                    }
                 }
             }
         } catch (Exception e) {

modules/thing/src/main/java/com/thing/thing/model/service/impl/IotThingModelServiceImpl.java

@@ -137,6 +137,7 @@ public class IotThingModelServiceImpl extends BaseServiceImpl<IotThingModelMappe
                                      Long startTime,
                                      Long endTime) {
         List<ObjectNode> modelList = cache.getTopicMap(CacheNameEnum.THING_MODEL);
+        log.info("modelList缓存数据个数:{},modelList缓存数据:{}", modelList.size(),modelList.toString());
         if (CollectionUtils.isEmpty(modelList)) {
             List<IotThingModelDTO> list = mapper.selectListByQueryAs(getWrapper(orderField, order, null, null, null,
                     null, null,null,null, null), IotThingModelDTO.class);