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, "