up:直播提醒接口修改

zhongzheng-system/src/main/java/com/zhongzheng/modules/order/service/impl/OrderGoodsServiceImpl.java

@@ -539,6 +539,7 @@ public class OrderGoodsServiceImpl extends ServiceImpl<OrderGoodsMapper, OrderGo
                         }).collect(Collectors.toList());
                         listVoList.addAll(collect);
                     }
+                    break;
             }
         });
         listVoList.forEach(vo -> {
@@ -549,38 +550,6 @@ public class OrderGoodsServiceImpl extends ServiceImpl<OrderGoodsMapper, OrderGo
                 }
             });
         });
-//        //节ID
-//        List<LiveListVo> liveListVos = menus.stream().filter(x -> x.getType() == 3).map(item -> {
-//            LiveListVo vo = new LiveListVo();
-//            vo.setCourseId(item.getCourseId());
-//            vo.setSectionId(item.getMenuId());
-//            return vo;
-//        }).collect(Collectors.toList());
-//
-//        //章ID
-//        List<Long> chapterIds = menus.stream().filter(x -> x.getType() == 2).map(CourseMenu::getMenuId).collect(Collectors.toList());
-//        if (!CollectionUtils.isEmpty(chapterIds)){
-//            List<CourseChapterSection> chapterSections = courseChapterSectionService.list(new LambdaQueryWrapper<CourseChapterSection>()
-//                    .in(CourseChapterSection::getChapterId, chapterIds));
-//            if (!CollectionUtils.isEmpty(chapterSections)){
-//                chapterSections.stream().map(item -> {
-//                    LiveListVo vo = new LiveListVo();
-//                    vo.setCourseId(item.getCourseId());
-//                    vo.setSectionId(item.getMenuId());
-//                    return vo;
-//                })
-//                List<Long> ids = chapterSections.stream().map(CourseChapterSection::getSectionId).collect(Collectors.toList());
-//                sectionIds.addAll(ids);
-//            }
-//        }
-//        //模块ID
-//        List<Long> moduleIds = menus.stream().filter(x -> x.getType() == 1).map(CourseMenu::getMenuId).collect(Collectors.toList());
-//        if (!CollectionUtils.isEmpty(moduleIds)){
-//            List<Long> ids = courseMenuService.getSectionIds(moduleIds);
-//            if (!CollectionUtils.isEmpty(ids)){
-//                sectionIds.addAll(ids);
-//            }
-//        }
         List<Long> sectionIds = listVoList.stream().map(LiveListVo::getSectionId).collect(Collectors.toList());
         if (CollectionUtils.isEmpty(sectionIds)){
             return info;
@@ -605,9 +574,9 @@ public class OrderGoodsServiceImpl extends ServiceImpl<OrderGoodsMapper, OrderGo
             try {
                 response = ployvLiveService.GetChannelBasicInfo(bo);
             } catch (Exception e) {
-//                throw new CustomException("获取保利威直播状态失败");
-                response.setChannelId(url);
-                response.setWatchStatus("waiting");
+                throw new CustomException("获取保利威直播状态失败");
+//                response.setChannelId(url);
+//                response.setWatchStatus("waiting");
             }
             return response;
         }).collect(Collectors.toList());