| | |
|---|
| | | import org.springframework.util.StringUtils; |
|---|
| | | |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.ConcurrentHashMap; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 视频设备数据存储-jdbc实现 |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public boolean exists(String deviceId) { |
|---|
| | | return deviceMapper.getDeviceByDeviceId(deviceId) != null; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 视频设备创建 |
|---|
| | | * |
|---|
| | | * @param device 设备对象 |
|---|
| | | * @return true：创建成功 false：创建失败 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public synchronized boolean create(Device device) { |
|---|
| | | redisCatchStorage.updateDevice(device); |
|---|
| | | return deviceMapper.add(device) > 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 视频设备更新 |
|---|
| | | * |
|---|
| | | * @param device 设备对象 |
|---|
| | | * @return true：更新成功 false：更新失败 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public synchronized boolean updateDevice(Device device) { |
|---|
| | | String now = DateUtil.getNow(); |
|---|
| | | device.setUpdateTime(now); |
|---|
| | | Device deviceByDeviceId = deviceMapper.getDeviceByDeviceId(device.getDeviceId()); |
|---|
| | | device.setCharset(device.getCharset().toUpperCase()); |
|---|
| | | if (deviceByDeviceId == null) { |
|---|
| | | device.setCreateTime(now); |
|---|
| | | redisCatchStorage.updateDevice(device); |
|---|
| | | return deviceMapper.add(device) > 0; |
|---|
| | | }else { |
|---|
| | | redisCatchStorage.updateDevice(device); |
|---|
| | | |
|---|
| | | return deviceMapper.update(device) > 0; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | if (deviceChannelList == null) { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | List<DeviceChannel> allChannelInPlay = deviceChannelMapper.getAllChannelInPlay(); |
|---|
| | | Map<String,DeviceChannel> allChannelMapInPlay = new ConcurrentHashMap<>(); |
|---|
| | | if (allChannelInPlay.size() > 0) { |
|---|
| | | for (DeviceChannel deviceChannel : allChannelInPlay) { |
|---|
| | | allChannelMapInPlay.put(deviceChannel.getChannelId(), deviceChannel); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition); |
|---|
| | | // 数据去重 |
|---|
| | | List<DeviceChannel> channels = new ArrayList<>(); |
|---|
| | | StringBuilder stringBuilder = new StringBuilder(); |
|---|
| | | Map<String, Integer> subContMap = new HashMap<>(); |
|---|
| | | if (deviceChannelList != null && deviceChannelList.size() > 1) { |
|---|
| | | if (deviceChannelList.size() > 1) { |
|---|
| | | // 数据去重 |
|---|
| | | Set<String> gbIdSet = new HashSet<>(); |
|---|
| | | for (DeviceChannel deviceChannel : deviceChannelList) { |
|---|
| | | if (!gbIdSet.contains(deviceChannel.getChannelId())) { |
|---|
| | | gbIdSet.add(deviceChannel.getChannelId()); |
|---|
| | | if (allChannelMapInPlay.containsKey(deviceChannel.getChannelId())) { |
|---|
| | | deviceChannel.setStreamId(allChannelMapInPlay.get(deviceChannel.getChannelId()).getStreamId()); |
|---|
| | | } |
|---|
| | | channels.add(deviceChannel); |
|---|
| | | if (!StringUtils.isEmpty(deviceChannel.getParentId())) { |
|---|
| | | if (subContMap.get(deviceChannel.getParentId()) == null) { |
|---|
