From 9faa74e1912022dc6e54c3e93426946876b5d83a Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 25 十月 2024 10:49:13 +0800
Subject: [PATCH] 修改redistemplate的hashkey serializer，更方便客户端查看redis的数据
---
collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java | 6 +-----
1 files changed, 1 insertions(+), 5 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java b/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java
index 21800ca..e96c3f6 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java
+++ b/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java
@@ -24,7 +24,6 @@
import com.alibaba.fastjson.JSONObject;
import com.qianwen.mdc.collect.service.DeviceStateFixPointService;
import com.qianwen.mdc.collect.service.IOTMqttReceiveService;
-import com.qianwen.mdc.collect.service.WorkstationAppMappingService;
import com.qianwen.mdc.collect.service.WorkstationDatapointsService;
import com.qianwen.mdc.collect.service.feedback.WorkstationFeedbackService;
@@ -48,8 +47,6 @@
private DeviceStateFixPointService stateFixPointService;
@Autowired
private WorkstationFeedbackService workstationFeedbackService;
- @Autowired
- private WorkstationAppMappingService workstationAppMappingService;
@Autowired
private WorkstationDatapointsService dpService;
@@ -134,11 +131,10 @@
}else if(WORKSTATION_DATAPOINT_CHANGED_TOPIC.equals(topic)) {
String payload = (String)message.getPayload();
logger.info("宸ヤ綅appId鏄犲皠鍙樺寲娑堟伅={}",payload);
- workstationAppMappingService.saveToCache();
+ //workstationAppMappingService.saveToCache();
//娓呴櫎璇ュ伐浣嶇殑鏁版嵁鐐圭紦瀛�
JSONObject payloadObj = JSONObject.parseObject(payload);
//payloadObj.getLong("workstationId");
-
dpService.datapointsCacheEvict(payloadObj.getString("appId"));
} else {//璁㈤槄浜嗗嚑涓猼opic灏变細鎺ユ敹鍒板嚑涓紝鍏朵粬鐨勪笉浼氳繘鏉�
logger.warn("topic={},msg={},鏃犲搴旂殑澶勭悊鍣�",topic,message.getPayload());
--
Gitblit v1.9.3