| | |
|---|
| | | boolean result = false; |
|---|
| | | TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition); |
|---|
| | | ParentPlatform parentPlatform = platformMapper.getParentPlatByServerGBId(platformId); |
|---|
| | | if (catalogId == null) catalogId = parentPlatform.getCatalogId(); |
|---|
| | | if (catalogId == null) { |
|---|
| | | catalogId = parentPlatform.getCatalogId(); |
|---|
| | | } |
|---|
| | | try { |
|---|
| | | List<DeviceChannel> deviceChannelList = new ArrayList<>(); |
|---|
| | | for (GbStream gbStream : gbStreams) { |
|---|
| | |
|---|
| | | gbStream.setPlatformId(platformId); |
|---|
| | | // TODO 修改为批量提交 |
|---|
| | | platformGbStreamMapper.add(gbStream); |
|---|
| | | DeviceChannel deviceChannelListByStream = getDeviceChannelListByStream(gbStream, catalogId, parentPlatform.getDeviceGBId()); |
|---|
| | | DeviceChannel deviceChannelListByStream = getDeviceChannelListByStream(gbStream, catalogId, parentPlatform); |
|---|
| | | deviceChannelList.add(deviceChannelListByStream); |
|---|
| | | } |
|---|
| | | dataSourceTransactionManager.commit(transactionStatus); //手动提交 |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public DeviceChannel getDeviceChannelListByStream(GbStream gbStream, String catalogId, String deviceGBId) { |
|---|
| | | public DeviceChannel getDeviceChannelListByStream(GbStream gbStream, String catalogId, ParentPlatform platform) { |
|---|
| | | DeviceChannel deviceChannel = new DeviceChannel(); |
|---|
| | | deviceChannel.setChannelId(gbStream.getGbId()); |
|---|
| | | deviceChannel.setName(gbStream.getName()); |
|---|
| | | deviceChannel.setLongitude(gbStream.getLongitude()); |
|---|
| | | deviceChannel.setLatitude(gbStream.getLatitude()); |
|---|
| | | deviceChannel.setDeviceId(deviceGBId); |
|---|
| | | deviceChannel.setDeviceId(platform.getDeviceGBId()); |
|---|
| | | deviceChannel.setManufacture("wvp-pro"); |
|---|
| | | deviceChannel.setStatus(gbStream.isStatus()?1:0); |
|---|
| | | // deviceChannel.setStatus(gbStream.isStatus()?1:0); |
|---|
| | | deviceChannel.setStatus(1); |
|---|
| | | deviceChannel.setParentId(catalogId ==null?gbStream.getCatalogId():catalogId); |
|---|
| | | deviceChannel.setRegisterWay(1); |
|---|
| | | deviceChannel.setCivilCode(sipConfig.getDomain()); |
|---|
| | | if (catalogId.length() > 0 && catalogId.length() <= 10) { |
|---|
| | | // 父节点是行政区划,则设置CivilCode使用此行政区划 |
|---|
| | | deviceChannel.setCivilCode(catalogId); |
|---|
| | | }else { |
|---|
| | | deviceChannel.setCivilCode(platform.getAdministrativeDivision()); |
|---|
| | | } |
|---|
| | | deviceChannel.setModel("live"); |
|---|
| | | deviceChannel.setOwner("wvp-pro"); |
|---|
| | | deviceChannel.setParental(0); |
|---|
