From 6688e50ba02988d742baadaca156a303a90b6191 Mon Sep 17 00:00:00 2001
From: fengxiang <110431245@qq.com>
Date: Fri, 20 Apr 2018 14:03:37 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 src/main/java/com/moral/service/impl/DeviceServiceImpl.java |   28 ++++++++++++++++++++++++++--
 1 files changed, 26 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/moral/service/impl/DeviceServiceImpl.java b/src/main/java/com/moral/service/impl/DeviceServiceImpl.java
index bb9406d..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;
@@ -202,7 +204,27 @@
 		}
 		return device;
 	}
-
+	/*
+	  ������ redis ���������������
+	 */
+	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) {
 		Example example = ExampleUtil.generateExample(ENTITY_CLASS,pageBean);
@@ -250,6 +272,8 @@
 				deviceMapper.insertSelective(device);
 			}else{
 				deviceMapper.updateByPrimaryKeySelective(device);
+				//������redis���������������
+				refreshDeviceInRedis(device);
 			}
 		}
 		catch (Exception ex){

--
Gitblit v1.8.0