From 3f220062a81ca7314c45201a73cc039debe050a4 Mon Sep 17 00:00:00 2001
From: fengxiang <110431245@qq.com>
Date: Tue, 17 Apr 2018 14:33:47 +0800
Subject: [PATCH] 设备缓存 orgids
---
src/main/java/com/moral/service/impl/DeviceServiceImpl.java | 25 +++++++++++++++++++++----
1 files changed, 21 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/moral/service/impl/DeviceServiceImpl.java b/src/main/java/com/moral/service/impl/DeviceServiceImpl.java
index 3b53edd..1e2499b 100644
--- a/src/main/java/com/moral/service/impl/DeviceServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/DeviceServiceImpl.java
@@ -12,6 +12,7 @@
import com.moral.common.bean.PageResult;
import com.moral.common.util.ExampleUtil;
import com.moral.common.util.RedisUtils;
+import com.moral.mapper.MonitorPointMapper;
import org.apache.commons.collections.MapUtils;
import org.apache.commons.lang3.BooleanUtils;
import org.apache.commons.lang3.StringUtils;
@@ -32,7 +33,8 @@
@Resource
private DeviceMapper deviceMapper;
-
+ @Resource
+ private MonitorPointMapper monitorPointMapper;
@Resource
private AccountService accountService;
private Class ENTITY_CLASS = Device.class;
@@ -205,8 +207,23 @@
/*
������ redis ���������������
*/
- private void refreshDeviceInRedis(String mac){
- getDeviceWithOrgIdsByMac(mac);
+ private void refreshDeviceInRedis(Device device){
+ if(!StringUtils.isBlank(device.getMac())){
+ Device simpleDevice = new Device();
+ simpleDevice.setId(device.getId());// id
+ simpleDevice.setName(device.getName());// name
+ simpleDevice.setAddress(device.getAddress());// address
+ simpleDevice.setDeviceVersionId(device.getDeviceVersionId());// version
+ simpleDevice.setMac(device.getMac()); // mac
+ simpleDevice.setMonitorPointId(device.getMonitorPointId());// ���������id
+ simpleDevice.setOrganizationIds(device.getOrganizationIds());// ������������
+ if(device.getMonitorPointId()!=null){
+ List<Integer> orgIds = monitorPointMapper.selectOrganizationIds(device.getMonitorPointId());
+ simpleDevice.setOrganizationIds(orgIds);
+ }
+ String key = "device_"+device.getMac();
+ redisUtils.set(key,simpleDevice);
+ }
}
@Override
public PageBean queryByPageBean(PageBean pageBean) {
@@ -256,7 +273,7 @@
}else{
deviceMapper.updateByPrimaryKeySelective(device);
//������redis���������������
- refreshDeviceInRedis(device.getMac());
+ refreshDeviceInRedis(device);
}
}
catch (Exception ex){
--
Gitblit v1.8.0