Browse Source

增加@Cacheable

jwy_category
review512jwy@163.com 1 month ago
parent
commit
234aa4098c
  1. 2
      src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertConfigDao.java
  2. 2
      src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateBindDao.java
  3. 2
      src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateDao.java
  4. 1
      src/main/java/com/techsor/datacenter/sender/dao/DeviceDao.java
  5. 2
      src/main/java/com/techsor/datacenter/sender/dao/DeviceForwardConfigDao.java
  6. 2
      src/main/java/com/techsor/datacenter/sender/dao/MqttConfigDao.java

2
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.dto.DeviceAlertInfo;
import com.techsor.datacenter.sender.entitiy.DeviceAlertConfigEntity; import com.techsor.datacenter.sender.entitiy.DeviceAlertConfigEntity;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -31,6 +32,7 @@ public class DeviceAlertConfigDao {
**/ **/
@Cacheable(value = "DeviceAlertConfigDao::selectCurrentDeviceAlertConfigByDeviceId", key = "#deviceId")
public List<DeviceAlertConfigEntity> selectCurrentDeviceAlertConfigByDeviceId(Long deviceId){ public List<DeviceAlertConfigEntity> selectCurrentDeviceAlertConfigByDeviceId(Long deviceId){
String sql="select * from device_alert_config where device_config_id="+deviceId+" and flag!=1"; String sql="select * from device_alert_config where device_config_id="+deviceId+" and flag!=1";

2
src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateBindDao.java

@ -1,6 +1,7 @@
package com.techsor.datacenter.sender.dao; package com.techsor.datacenter.sender.dao;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -13,6 +14,7 @@ public class DeviceAlertTemplateBindDao {
@Resource @Resource
private JdbcTemplate jdbcTemplate; private JdbcTemplate jdbcTemplate;
@Cacheable(value = "DeviceAlertTemplateBindDao::selectDeviceAlertTemplateBindByDeviceId", key = "#deviceId")
public List<Long> selectDeviceAlertTemplateBindByDeviceId(Long deviceId){ public List<Long> selectDeviceAlertTemplateBindByDeviceId(Long deviceId){
String sql="select device_alert_template_id from device_alert_template_bind where device_info_id="+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")); return this.jdbcTemplate.query(sql,(rs, rowNum)-> rs.getLong("device_alert_template_id"));

2
src/main/java/com/techsor/datacenter/sender/dao/DeviceAlertTemplateDao.java

@ -1,6 +1,7 @@
package com.techsor.datacenter.sender.dao; package com.techsor.datacenter.sender.dao;
import com.techsor.datacenter.sender.entitiy.DeviceAlertTemplateEntity; import com.techsor.datacenter.sender.entitiy.DeviceAlertTemplateEntity;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -35,6 +36,7 @@ public class DeviceAlertTemplateDao {
@Resource @Resource
private JdbcTemplate jdbcTemplate; private JdbcTemplate jdbcTemplate;
@Cacheable(value = "DeviceAlertTemplateDao::selectDeviceAlertTemplatesByDeviceId", key = "#deviceId")
public List<DeviceAlertInfo> selectDeviceAlertTemplatesByDeviceId(Long deviceId) { public List<DeviceAlertInfo> selectDeviceAlertTemplatesByDeviceId(Long deviceId) {
String sql = "SELECT tmp.id, " + String sql = "SELECT tmp.id, " +
"tmp.company_id AS companyId, " + "tmp.company_id AS companyId, " +

1
src/main/java/com/techsor/datacenter/sender/dao/DeviceDao.java

@ -227,6 +227,7 @@ public class DeviceDao {
} }
@Cacheable(value = "DeviceDao::getDeviceInfo", key = "#deviceId")
public List<DeviceInfoVO> getDeviceInfo(String deviceId){ public List<DeviceInfoVO> getDeviceInfo(String deviceId){
if (StringUtils.isEmpty(deviceId)){ if (StringUtils.isEmpty(deviceId)){
return new ArrayList<>(); return new ArrayList<>();

2
src/main/java/com/techsor/datacenter/sender/dao/DeviceForwardConfigDao.java

@ -1,6 +1,7 @@
package com.techsor.datacenter.sender.dao; package com.techsor.datacenter.sender.dao;
import com.techsor.datacenter.sender.entitiy.DeviceForwardConfigEntity; import com.techsor.datacenter.sender.entitiy.DeviceForwardConfigEntity;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -14,6 +15,7 @@ public class DeviceForwardConfigDao {
private JdbcTemplate jdbcTemplate ; private JdbcTemplate jdbcTemplate ;
@Cacheable(value = "DeviceForwardConfigDao::selectDeviceForwardConfigByDeviceId", key = "#deviceId")
public List<DeviceForwardConfigEntity> selectDeviceForwardConfigByDeviceId(Long deviceId){ public List<DeviceForwardConfigEntity> selectDeviceForwardConfigByDeviceId(Long deviceId){
String sql="select * from device_forward_config where device_id="+deviceId; String sql="select * from device_forward_config where device_id="+deviceId;
sql=String.format(sql,deviceId); sql=String.format(sql,deviceId);

2
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.MqttConfigEntity;
import com.techsor.datacenter.sender.entitiy.bastatus.BaStatusEntity; import com.techsor.datacenter.sender.entitiy.bastatus.BaStatusEntity;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -23,6 +24,7 @@ public class MqttConfigDao {
* @param purposeType * @param purposeType
* @return * @return
*/ */
@Cacheable(value = "MqttConfigDao::getByDeviceId", key = "#deviceId + '::' + #purposeType")
public List<MqttConfigEntity> getByDeviceId(String deviceId, int purposeType) { public List<MqttConfigEntity> getByDeviceId(String deviceId, int purposeType) {
String sql="SELECT " String sql="SELECT "
+ "bmqtt.id mqttId, bmqtt.company_id, bcomp.company_name, " + "bmqtt.id mqttId, bmqtt.company_id, bcomp.company_name, "

Loading…
Cancel
Save