| | |
| | | List<Device> devices = deviceMapper.select(device);
|
| | | return devices;
|
| | | }
|
| | |
|
| | | /**
|
| | | *
|
| | | * @param mac
|
| | | * @param fromCache
|
| | | * @return 包含组织数组
|
| | | */
|
| | | @Override
|
| | | public Device getDeviceByMac (String mac ,boolean fromCache){
|
| | | if(fromCache){
|
| | |
| | | */
|
| | | 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());// 组织数组
|
| | | // 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);
|
| | | device.setOrganizationIds(orgIds);
|
| | | }
|
| | | String key = "device_"+device.getMac();
|
| | | redisUtils.set(key,simpleDevice);
|
| | | redisUtils.set(key,device);
|
| | | }
|
| | | }
|
| | | @Override
|
| | |
| | | public void addOrModify(Device device){
|
| | | try{
|
| | | //mac 转小写
|
| | | if(StringUtils.isBlank(device.getMac())){
|
| | | if(!StringUtils.isBlank(device.getMac())){
|
| | | device.setMac(device.getMac().toLowerCase());
|
| | | }
|
| | | if(device.getId()==null){
|
| | |
| | | deviceMapper.insertSelective(device);
|
| | | }else{
|
| | | deviceMapper.updateByPrimaryKeySelective(device);
|
| | | //刷新redis里设备信息
|
| | | refreshDeviceInRedis(device);
|
| | | }
|
| | | //刷新redis里设备信息
|
| | | refreshDeviceInRedis(device);
|
| | | }
|
| | | catch (Exception ex){
|
| | | throw ex;
|
| | |
| | | }).collect(Collectors.toList());
|
| | | return list;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public Device queryById(Integer id) {
|
| | | return deviceMapper.selectByPrimaryKey(id);
|
| | | }
|
| | |
|
| | | @Override
|
| | | public List<Device> getDevicesByProfessionId(Map<String, Object> parameters) {
|
| | | |
| | | return deviceMapper.getDevicesByProfession(parameters);
|
| | | }
|
| | |
|
| | | }
|