fix流媒体

zhongzheng-system/src/main/java/com/zhongzheng/modules/course/bo/CourseStreamingAddBo.java

@@ -5,7 +5,7 @@ import io.swagger.annotations.ApiModelProperty;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
 import java.util.Date;
-
+import java.util.List;
 
 
 /**
@@ -60,4 +60,7 @@ public class CourseStreamingAddBo {
     /** 状态 1正常 0关闭 */
     @ApiModelProperty("状态 1正常 0关闭")
     private Integer status;
+    /** 业务层级列表 */
+    @ApiModelProperty("业务层级列表")
+    private List<CourseStreamingBusinessAddBo> businessList;
 }

zhongzheng-system/src/main/java/com/zhongzheng/modules/course/bo/CourseStreamingEditBo.java

@@ -5,6 +5,7 @@ import io.swagger.annotations.ApiModelProperty;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
 import java.util.Date;
+import java.util.List;
 
 
 /**
@@ -73,4 +74,8 @@ public class CourseStreamingEditBo {
     @ApiModelProperty("状态 1正常 0关闭")
     private Integer status;
 
+    /** 业务层级列表 */
+    @ApiModelProperty("业务层级列表")
+    private List<CourseStreamingBusinessAddBo> businessList;
+
 }

zhongzheng-system/src/main/java/com/zhongzheng/modules/course/service/impl/CourseChapterServiceImpl.java

@@ -4,13 +4,16 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.StrUtil;
 import com.zhongzheng.common.utils.DateUtils;
 import com.zhongzheng.common.utils.ServletUtils;
-import com.zhongzheng.modules.course.bo.CourseChapterAddBo;
-import com.zhongzheng.modules.course.bo.CourseChapterEditBo;
-import com.zhongzheng.modules.course.bo.CourseChapterQueryBo;
+import com.zhongzheng.modules.course.bo.*;
 import com.zhongzheng.modules.course.domain.CourseChapter;
+import com.zhongzheng.modules.course.domain.CourseChapterBusiness;
+import com.zhongzheng.modules.course.domain.CourseSectionBusiness;
 import com.zhongzheng.modules.course.mapper.CourseChapterMapper;
+import com.zhongzheng.modules.course.service.ICourseChapterBusinessService;
 import com.zhongzheng.modules.course.service.ICourseChapterService;
+import com.zhongzheng.modules.course.service.ICourseSectionBusinessService;
 import com.zhongzheng.modules.course.vo.CourseChapterVo;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -31,6 +34,9 @@ import java.util.stream.Collectors;
 @Service
 public class CourseChapterServiceImpl extends ServiceImpl<CourseChapterMapper, CourseChapter> implements ICourseChapterService {
 
+    @Autowired
+    private ICourseChapterBusinessService iCourseChapterBusinessService;
+
     @Override
     public CourseChapterVo queryById(Long chapterId){
         CourseChapter db = this.baseMapper.selectById(chapterId);
@@ -77,7 +83,15 @@ public class CourseChapterServiceImpl extends ServiceImpl<CourseChapterMapper, C
         validEntityBeforeSave(add);
         add.setCreateTime(DateUtils.getNowTime());
         add.setUpdateTime(DateUtils.getNowTime());
-        return this.save(add);
+        boolean result = this.save(add);
+        if(result){
+            for(int i=0;i<bo.getBusinessList().size();i++){
+                CourseChapterBusinessAddBo item = bo.getBusinessList().get(i);
+                item.setChapterId(add.getChapterId());
+                iCourseChapterBusinessService.insertByAddBo(item);
+            }
+        }
+        return result;
     }
 
     @Override
@@ -85,6 +99,12 @@ public class CourseChapterServiceImpl extends ServiceImpl<CourseChapterMapper, C
         CourseChapter update = BeanUtil.toBean(bo, CourseChapter.class);
         validEntityBeforeSave(update);
         update.setUpdateTime(DateUtils.getNowTime());
+        iCourseChapterBusinessService.remove(new LambdaQueryWrapper<CourseChapterBusiness>().eq(CourseChapterBusiness::getChapterId, bo.getChapterId()));
+        for(int i=0;i<bo.getBusinessList().size();i++){
+            CourseChapterBusinessAddBo item = bo.getBusinessList().get(i);
+            item.setChapterId(bo.getChapterId());
+            iCourseChapterBusinessService.insertByAddBo(item);
+        }
         return this.updateById(update);
     }
 

zhongzheng-system/src/main/java/com/zhongzheng/modules/course/service/impl/CourseSectionServiceImpl.java

@@ -97,7 +97,6 @@ public class CourseSectionServiceImpl extends ServiceImpl<CourseSectionMapper, C
                 iCourseSectionBusinessService.insertByAddBo(item);
             }
         }
-
         return result;
     }
 

zhongzheng-system/src/main/java/com/zhongzheng/modules/course/service/impl/CourseServiceImpl.java

@@ -9,8 +9,10 @@ import com.zhongzheng.modules.course.bo.CourseEditBo;
 import com.zhongzheng.modules.course.bo.CourseQueryBo;
 import com.zhongzheng.modules.course.domain.Course;
 import com.zhongzheng.modules.course.mapper.CourseMapper;
+import com.zhongzheng.modules.course.service.ICourseSectionBusinessService;
 import com.zhongzheng.modules.course.service.ICourseService;
 import com.zhongzheng.modules.course.vo.CourseVo;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -31,6 +33,8 @@ import java.util.stream.Collectors;
 @Service
 public class CourseServiceImpl extends ServiceImpl<CourseMapper, Course> implements ICourseService {
 
+
+
     @Override
     public CourseVo queryById(Long courseId){
         Course db = this.baseMapper.selectById(courseId);

zhongzheng-system/src/main/java/com/zhongzheng/modules/course/service/impl/CourseStreamingServiceImpl.java

@@ -4,13 +4,16 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.StrUtil;
 import com.zhongzheng.common.utils.DateUtils;
 import com.zhongzheng.common.utils.ServletUtils;
-import com.zhongzheng.modules.course.bo.CourseStreamingAddBo;
-import com.zhongzheng.modules.course.bo.CourseStreamingEditBo;
-import com.zhongzheng.modules.course.bo.CourseStreamingQueryBo;
+import com.zhongzheng.modules.course.bo.*;
+import com.zhongzheng.modules.course.domain.CourseSectionBusiness;
 import com.zhongzheng.modules.course.domain.CourseStreaming;
+import com.zhongzheng.modules.course.domain.CourseStreamingBusiness;
 import com.zhongzheng.modules.course.mapper.CourseStreamingMapper;
+import com.zhongzheng.modules.course.service.ICourseSectionBusinessService;
+import com.zhongzheng.modules.course.service.ICourseStreamingBusinessService;
 import com.zhongzheng.modules.course.service.ICourseStreamingService;
 import com.zhongzheng.modules.course.vo.CourseStreamingVo;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -31,6 +34,9 @@ import java.util.stream.Collectors;
 @Service
 public class CourseStreamingServiceImpl extends ServiceImpl<CourseStreamingMapper, CourseStreaming> implements ICourseStreamingService {
 
+    @Autowired
+    private ICourseStreamingBusinessService iCourseStreamingBusinessService;
+
     @Override
     public CourseStreamingVo queryById(Long id){
         CourseStreaming db = this.baseMapper.selectById(id);
@@ -82,7 +88,15 @@ public class CourseStreamingServiceImpl extends ServiceImpl<CourseStreamingMappe
         validEntityBeforeSave(add);
         add.setCreateTime(DateUtils.getNowTime());
         add.setUpdateTime(DateUtils.getNowTime());
-        return this.save(add);
+        boolean result = this.save(add);
+        if(result){
+            for(int i=0;i<bo.getBusinessList().size();i++){
+                CourseStreamingBusinessAddBo item = bo.getBusinessList().get(i);
+                item.setStreamingId(add.getId());
+                iCourseStreamingBusinessService.insertByAddBo(item);
+            }
+        }
+        return result;
     }
 
     @Override
@@ -90,6 +104,12 @@ public class CourseStreamingServiceImpl extends ServiceImpl<CourseStreamingMappe
         CourseStreaming update = BeanUtil.toBean(bo, CourseStreaming.class);
         validEntityBeforeSave(update);
         update.setUpdateTime(DateUtils.getNowTime());
+        iCourseStreamingBusinessService.remove(new LambdaQueryWrapper<CourseStreamingBusiness>().eq(CourseStreamingBusiness::getStreamingId, bo.getId()));
+        for(int i=0;i<bo.getBusinessList().size();i++){
+            CourseStreamingBusinessAddBo item = bo.getBusinessList().get(i);
+            item.setStreamingId(bo.getId());
+            iCourseStreamingBusinessService.insertByAddBo(item);
+        }
         return this.updateById(update);
     }