| | |
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | | public class DeviceServiceImpl implements DeviceService {
|
|---|
| | |
|
|---|
| | | //-----------------------redis key前缀-开始---------------------------------
|
|---|
| | | private static String AlARM = "alarm";//警报阀值储存key前缀
|
|---|
| | | private static String ADJUST="adjust";//校准值存储key前缀
|
|---|
| | | private static String DEVICE = "device";//设备信息数据key前缀
|
|---|
| | | private static String STATE = "state";//设备实时状态key前缀
|
|---|
| | | private static String DATA = "data";//设备实时数据key前缀
|
|---|
| | | //-----------------------redis key前缀-结束---------------------------------
|
|---|
| | | private String keysConnect(String... keys) {
|
|---|
| | | StringBuilder key = new StringBuilder(keys[0]);
|
|---|
| | | for(int i=1;i<keys.length;i++) {
|
|---|
| | | key.append("_");
|
|---|
| | | key.append(keys[i]);
|
|---|
| | | }
|
|---|
| | | return key.toString().toLowerCase();
|
|---|
| | | }
|
|---|
| | | @Resource
|
|---|
| | | private DeviceMapper deviceMapper;
|
|---|
| | | @Resource
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public Device getDeviceByMac(String mac) {
|
|---|
| | | ValidateUtil.notEmpty(mac, "param.is.null");
|
|---|
| | | Device device = new Device();
|
|---|
| | | device.setMac(mac);
|
|---|
| | | device = deviceMapper.selectOne(device);
|
|---|
| | | Device device = getDeviceFromRedis(mac);
|
|---|
| | | if(device==null) {
|
|---|
| | | device = deviceMapper.selectWithOrgIdsByMac(mac);
|
|---|
| | | if(device!=null){
|
|---|
| | | setDeviceToRedis(mac,device);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return device;
|
|---|
| | | }
|
|---|
| | | /*
|
|---|
| | | * 获取报警阀值在redis里的key
|
|---|
| | | */
|
|---|
| | | private String getDeviceKey(String mac) {
|
|---|
| | | return keysConnect(DEVICE,mac);
|
|---|
| | | }
|
|---|
| | | /*
|
|---|
| | | * 将校正值存入redis方法组 开始
|
|---|
| | | */
|
|---|
| | | private void setDeviceToRedis(String mac,Device device){
|
|---|
| | | String key = getDeviceKey(mac);
|
|---|
| | | 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());// 组织数组
|
|---|
| | | redisUtils.set(key,simpleDevice);
|
|---|
| | | }
|
|---|
| | | private Device getDeviceFromRedis(String mac) {
|
|---|
| | | String key = getDeviceKey(mac);
|
|---|
| | | return redisUtils.get(key,Device.class);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | *
|
|---|
