| | |
|---|
| | | // 遍历存储结果，查找app+Stream->platformId+catalogId的对应关系，然后执行批量写入 |
|---|
| | | for (StreamPushItem streamPushItem : streamPushItemsForPlatform) { |
|---|
| | | List<String[]> platFormInfoList = streamPushItemsForAll.get(streamPushItem.getApp() + streamPushItem.getStream()); |
|---|
| | | if (platFormInfoList != null) { |
|---|
| | | if (platFormInfoList.size() > 0) { |
|---|
| | | if (platFormInfoList != null && platFormInfoList.size() > 0) { |
|---|
| | | for (String[] platFormInfoArray : platFormInfoList) { |
|---|
| | | StreamPushItem streamPushItemForPlatform = new StreamPushItem(); |
|---|
| | | streamPushItemForPlatform.setGbStreamId(streamPushItem.getGbStreamId()); |
|---|
| | |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | streamPushItemForPlatform.setPlatformId(platFormInfoArray[0]); |
|---|
| | | |
|---|
| | | List<GbStream> gbStreamList = platformForEvent.get(streamPushItem.getPlatformId()); |
|---|
| | | if (platFormInfoArray[0].equals("34020000002110000001")) { |
|---|
| | | System.out.println(111); |
|---|
| | | } |
|---|
| | | List<GbStream> gbStreamList = platformForEvent.get(platFormInfoArray[0]); |
|---|
| | | if (gbStreamList == null) { |
|---|
| | | gbStreamList = new ArrayList<>(); |
|---|
| | | platformForEvent.put(platFormInfoArray[0], gbStreamList); |
|---|
| | |
|---|
| | | streamPushItemForPlatform.setCatalogId(platFormInfoArray[1]); |
|---|
| | | } |
|---|
| | | streamPushItemListFroPlatform.add(streamPushItemForPlatform); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
