Commit 735f0115 by 吴博

feat: [10073776] 多渠道

parent 60e51aa7
...@@ -159,8 +159,9 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz { ...@@ -159,8 +159,9 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz {
private List<MultiChannelContentDTO> getMultiChannelContentDTOS4Bili(List<MultiChannelContentDTO> multiChannelContentDTOS, List<MultiChannelContent> multiChannelContents, List<Long> contentIds4Bili) { private List<MultiChannelContentDTO> getMultiChannelContentDTOS4Bili(List<MultiChannelContentDTO> multiChannelContentDTOS, List<MultiChannelContent> multiChannelContents, List<Long> contentIds4Bili) {
//获取抖音视频 //获取抖音视频
List<MultiChannelContentItemDTO> multiChannelContentItemDTOS = multiChannelContentItemBiz.getByMultiChannelContentId(contentIds4Bili); List<MultiChannelContentItemDTO> multiChannelContentItemDTOS = multiChannelContentItemBiz.getByMultiChannelContentId(contentIds4Bili);
List<MultiChannelContentDTO> multiChannelContentDTOS4Bili = new ArrayList<>();
if (CollUtil.isNotEmpty(multiChannelContentItemDTOS)) { if (CollUtil.isNotEmpty(multiChannelContentItemDTOS)) {
multiChannelContentDTOS = BeanUtil.copyToList(multiChannelContents, MultiChannelContentDTO.class); multiChannelContentDTOS4Bili = BeanUtil.copyToList(multiChannelContents, MultiChannelContentDTO.class);
List<String> itemIds = multiChannelContentItemDTOS.stream().map(e -> e.getItemId()).collect(Collectors.toList()); List<String> itemIds = multiChannelContentItemDTOS.stream().map(e -> e.getItemId()).collect(Collectors.toList());
Map<String, BiliVideoDTO> biliVideoDTOMap = channelConsr.getBiliVideoByItemIds(itemIds); Map<String, BiliVideoDTO> biliVideoDTOMap = channelConsr.getBiliVideoByItemIds(itemIds);
multiChannelContentItemDTOS.stream().forEach(e -> { multiChannelContentItemDTOS.stream().forEach(e -> {
...@@ -170,7 +171,7 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz { ...@@ -170,7 +171,7 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz {
} }
}); });
Map<Long, List<MultiChannelContentItemDTO>> itemDTOMap = multiChannelContentItemDTOS.stream().collect(Collectors.groupingBy(MultiChannelContentItemDTO::getMultiChannelContentId)); Map<Long, List<MultiChannelContentItemDTO>> itemDTOMap = multiChannelContentItemDTOS.stream().collect(Collectors.groupingBy(MultiChannelContentItemDTO::getMultiChannelContentId));
multiChannelContentDTOS.stream().forEach(e -> { multiChannelContentDTOS4Bili.stream().forEach(e -> {
List<MultiChannelContentItemDTO> multiChannelContentItems = CollUtil.isEmpty(e.getMultiChannelContentItems()) ? new ArrayList<>() : e.getMultiChannelContentItems(); List<MultiChannelContentItemDTO> multiChannelContentItems = CollUtil.isEmpty(e.getMultiChannelContentItems()) ? new ArrayList<>() : e.getMultiChannelContentItems();
if (CollUtil.isNotEmpty(itemDTOMap.get(e.getId()))) { if (CollUtil.isNotEmpty(itemDTOMap.get(e.getId()))) {
multiChannelContentItems.addAll(itemDTOMap.get(e.getId())); multiChannelContentItems.addAll(itemDTOMap.get(e.getId()));
...@@ -178,14 +179,18 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz { ...@@ -178,14 +179,18 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz {
} }
}); });
} }
if (CollUtil.isNotEmpty(multiChannelContentDTOS4Bili)) {
multiChannelContentDTOS.addAll(multiChannelContentDTOS4Bili);
}
return multiChannelContentDTOS; return multiChannelContentDTOS;
} }
private List<MultiChannelContentDTO> getMultiChannelContentDTOS4Douyin(List<MultiChannelContentDTO> multiChannelContentDTOS, List<MultiChannelContent> multiChannelContents, List<Long> contentIds4Douyin) { private List<MultiChannelContentDTO> getMultiChannelContentDTOS4Douyin(List<MultiChannelContentDTO> multiChannelContentDTOS, List<MultiChannelContent> multiChannelContents, List<Long> contentIds4Douyin) {
//获取抖音视频 //获取抖音视频
List<MultiChannelContentItemDTO> multiChannelContentItemDTOS = multiChannelContentItemBiz.getByMultiChannelContentId(contentIds4Douyin); List<MultiChannelContentItemDTO> multiChannelContentItemDTOS = multiChannelContentItemBiz.getByMultiChannelContentId(contentIds4Douyin);
List<MultiChannelContentDTO> multiChannelContentDTOS4Douyin = new ArrayList<>();
if ( CollUtil.isNotEmpty(multiChannelContentItemDTOS)) { if ( CollUtil.isNotEmpty(multiChannelContentItemDTOS)) {
multiChannelContentDTOS = BeanUtil.copyToList(multiChannelContents, MultiChannelContentDTO.class); multiChannelContentDTOS4Douyin = BeanUtil.copyToList(multiChannelContents, MultiChannelContentDTO.class);
List<String> itemIds = multiChannelContentItemDTOS.stream().map(e -> e.getItemId()).collect(Collectors.toList()); List<String> itemIds = multiChannelContentItemDTOS.stream().map(e -> e.getItemId()).collect(Collectors.toList());
Map<String, DouyinVideoDTO> douyinVideoDTOMap = channelConsr.getDouyinVideoByItemIds(itemIds); Map<String, DouyinVideoDTO> douyinVideoDTOMap = channelConsr.getDouyinVideoByItemIds(itemIds);
multiChannelContentItemDTOS.stream().forEach(e -> { multiChannelContentItemDTOS.stream().forEach(e -> {
...@@ -195,7 +200,7 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz { ...@@ -195,7 +200,7 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz {
} }
}); });
Map<Long, List<MultiChannelContentItemDTO>> itemDTOMap = multiChannelContentItemDTOS.stream().collect(Collectors.groupingBy(MultiChannelContentItemDTO::getMultiChannelContentId)); Map<Long, List<MultiChannelContentItemDTO>> itemDTOMap = multiChannelContentItemDTOS.stream().collect(Collectors.groupingBy(MultiChannelContentItemDTO::getMultiChannelContentId));
multiChannelContentDTOS.stream().forEach(e -> { multiChannelContentDTOS4Douyin.stream().forEach(e -> {
List<MultiChannelContentItemDTO> multiChannelContentItems = CollUtil.isEmpty(e.getMultiChannelContentItems()) ? new ArrayList<>() : e.getMultiChannelContentItems(); List<MultiChannelContentItemDTO> multiChannelContentItems = CollUtil.isEmpty(e.getMultiChannelContentItems()) ? new ArrayList<>() : e.getMultiChannelContentItems();
if (CollUtil.isNotEmpty(itemDTOMap.get(e.getId()))) { if (CollUtil.isNotEmpty(itemDTOMap.get(e.getId()))) {
multiChannelContentItems.addAll(itemDTOMap.get(e.getId())); multiChannelContentItems.addAll(itemDTOMap.get(e.getId()));
...@@ -203,6 +208,9 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz { ...@@ -203,6 +208,9 @@ public class MultiChannelContentBizImpl implements MultiChannelContentBiz {
} }
}); });
} }
if (CollUtil.isNotEmpty(multiChannelContentDTOS4Douyin)) {
multiChannelContentDTOS.addAll(multiChannelContentDTOS4Douyin);
}
return multiChannelContentDTOS; return multiChannelContentDTOS;
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment