From 234aa4098c961c1ecb356d0c556d0d8df016e36b Mon Sep 17 00:00:00 2001 From: "review512jwy@163.com" <“review512jwy@163.com”> Date: Tue, 9 Dec 2025 09:05:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0@Cacheable?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../techsor/datacenter/sender/dao/DeviceAlertConfigDao.java | 2 ++ .../datacenter/sender/dao/DeviceAlertTemplateBindDao.java | 2 ++ .../datacenter/sender/dao/DeviceAlertTemplateDao.java | 2 ++ .../java/com/techsor/datacenter/sender/dao/DeviceDao.java | 5 +++-- .../datacenter/sender/dao/DeviceForwardConfigDao.java | 2 ++ .../com/techsor/datacenter/sender/dao/MqttConfigDao.java | 2 ++ 6 files changed, 13 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertConfigDao.java b/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertConfigDao.java index 7136f2a..c5a5fa9 100644 --- a/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertConfigDao.java +++ b/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertConfigDao.java @@ -2,6 +2,7 @@ package com.techsor.datacenter.sender.dao; import com.techsor.datacenter.sender.dto.DeviceAlertInfo; import com.techsor.datacenter.sender.entitiy.DeviceAlertConfigEntity; +import org.springframework.cache.annotation.Cacheable; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; @@ -31,6 +32,7 @@ public class DeviceAlertConfigDao { **/ + @Cacheable(value = "DeviceAlertConfigDao::selectCurrentDeviceAlertConfigByDeviceId", key = "#deviceId") public List selectCurrentDeviceAlertConfigByDeviceId(Long deviceId){ String sql="select * from device_alert_config where device_config_id="+deviceId+" and flag!=1"; diff --git a/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateBindDao.java b/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateBindDao.java index 5b8c7d9..11c6d35 100644 --- a/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateBindDao.java +++ b/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateBindDao.java @@ -1,6 +1,7 @@ package com.techsor.datacenter.sender.dao; +import org.springframework.cache.annotation.Cacheable; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; @@ -13,6 +14,7 @@ public class DeviceAlertTemplateBindDao { @Resource private JdbcTemplate jdbcTemplate; + @Cacheable(value = "DeviceAlertTemplateBindDao::selectDeviceAlertTemplateBindByDeviceId", key = "#deviceId") public List selectDeviceAlertTemplateBindByDeviceId(Long deviceId){ String sql="select device_alert_template_id from device_alert_template_bind where device_info_id="+deviceId; return this.jdbcTemplate.query(sql,(rs, rowNum)-> rs.getLong("device_alert_template_id")); diff --git a/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateDao.java b/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateDao.java index 672293b..b9b3318 100644 --- a/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateDao.java +++ b/src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateDao.java @@ -1,6 +1,7 @@ package com.techsor.datacenter.sender.dao; import com.techsor.datacenter.sender.entitiy.DeviceAlertTemplateEntity; +import org.springframework.cache.annotation.Cacheable; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; @@ -35,6 +36,7 @@ public class DeviceAlertTemplateDao { @Resource private JdbcTemplate jdbcTemplate; + @Cacheable(value = "DeviceAlertTemplateDao::selectDeviceAlertTemplatesByDeviceId", key = "#deviceId") public List selectDeviceAlertTemplatesByDeviceId(Long deviceId) { String sql = "SELECT tmp.id, " + "tmp.company_id AS companyId, " + diff --git a/src/main/java/com/techsor/datacenter/sender/dao/DeviceDao.java b/src/main/java/com/techsor/datacenter/sender/dao/DeviceDao.java index 305971c..942ad81 100644 --- a/src/main/java/com/techsor/datacenter/sender/dao/DeviceDao.java +++ b/src/main/java/com/techsor/datacenter/sender/dao/DeviceDao.java @@ -225,8 +225,9 @@ public class DeviceDao { }); return dataList; } - - + + + @Cacheable(value = "DeviceDao::getDeviceInfo", key = "#deviceId") public List getDeviceInfo(String deviceId){ if (StringUtils.isEmpty(deviceId)){ return new ArrayList<>(); diff --git a/src/main/java/com/techsor/datacenter/sender/dao/DeviceForwardConfigDao.java b/src/main/java/com/techsor/datacenter/sender/dao/DeviceForwardConfigDao.java index 6dc8446..bdf146a 100644 --- a/src/main/java/com/techsor/datacenter/sender/dao/DeviceForwardConfigDao.java +++ b/src/main/java/com/techsor/datacenter/sender/dao/DeviceForwardConfigDao.java @@ -1,6 +1,7 @@ package com.techsor.datacenter.sender.dao; import com.techsor.datacenter.sender.entitiy.DeviceForwardConfigEntity; +import org.springframework.cache.annotation.Cacheable; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; @@ -14,6 +15,7 @@ public class DeviceForwardConfigDao { private JdbcTemplate jdbcTemplate ; + @Cacheable(value = "DeviceForwardConfigDao::selectDeviceForwardConfigByDeviceId", key = "#deviceId") public List selectDeviceForwardConfigByDeviceId(Long deviceId){ String sql="select * from device_forward_config where device_id="+deviceId; sql=String.format(sql,deviceId); diff --git a/src/main/java/com/techsor/datacenter/sender/dao/MqttConfigDao.java b/src/main/java/com/techsor/datacenter/sender/dao/MqttConfigDao.java index 3716cd4..bb0bac1 100644 --- a/src/main/java/com/techsor/datacenter/sender/dao/MqttConfigDao.java +++ b/src/main/java/com/techsor/datacenter/sender/dao/MqttConfigDao.java @@ -3,6 +3,7 @@ package com.techsor.datacenter.sender.dao; import com.techsor.datacenter.sender.entitiy.MqttConfigEntity; import com.techsor.datacenter.sender.entitiy.bastatus.BaStatusEntity; import lombok.extern.slf4j.Slf4j; +import org.springframework.cache.annotation.Cacheable; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; @@ -23,6 +24,7 @@ public class MqttConfigDao { * @param purposeType * @return */ + @Cacheable(value = "MqttConfigDao::getByDeviceId", key = "#deviceId + '::' + #purposeType") public List getByDeviceId(String deviceId, int purposeType) { String sql="SELECT " + "bmqtt.id mqttId, bmqtt.company_id, bcomp.company_name, "