保利威同步

zhongzheng-admin/src/main/java/com/zhongzheng/controller/course/CourseStreamingController.java

@@ -125,4 +125,15 @@ public class CourseStreamingController extends BaseController {
         List<CourseStreamingBusiness> list = iCourseStreamingBusinessService.getListById(id);
         return AjaxResult.success(list);
     }
+
+    /**
+     * 新增课程流媒体
+     */
+    @ApiOperation("同步保利威新增课程流媒体")
+    @PreAuthorize("@ss.hasPermi('system:streaming:add')")
+    @Log(title = "同步保利威新增课程流媒体", businessType = BusinessType.INSERT)
+    @PostMapping("addAll")
+    public AjaxResult<Void> addAll(@RequestBody CourseStreamingAddBo bo) {
+        return toAjax(iCourseStreamingService.insertByAddAllBo(bo) ? 1 : 0);
+    }
 }

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

@@ -48,6 +48,10 @@ public class CourseStreamingAddBo {
     /** 录播保利威视频ID */
     @ApiModelProperty("录播保利威视频ID")
     private String recordingVideoId;
+
+    /** 录播保利威视频ID */
+    @ApiModelProperty("录播保利威视频ID")
+    private String[] recordingVideoIds;
     /** 回放地址 */
     @ApiModelProperty("回放地址")
     private String playbackUrl;

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

@@ -51,4 +51,6 @@ public interface ICourseStreamingService extends IService<CourseStreaming> {
 	 * @return
 	 */
 	Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
+
+	boolean insertByAddAllBo(CourseStreamingAddBo bo);
 }

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

@@ -168,6 +168,28 @@ public class CourseStreamingServiceImpl extends ServiceImpl<CourseStreamingMappe
         return this.removeByIds(ids);
     }
 
+    @Override
+    public boolean insertByAddAllBo(CourseStreamingAddBo bo) {
+        for (String code : bo.getRecordingVideoIds()) {
+            CourseStreaming add = BeanUtil.toBean(bo, CourseStreaming.class);
+            add.setCode(ServletUtils.getEncoded("L"));
+            add.setRecordingVideoId(code);
+            validEntityBeforeSave(add);
+            add.setCreateTime(DateUtils.getNowTime());
+            add.setUpdateTime(DateUtils.getNowTime());
+            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 true;
+    }
+
     private boolean checkNameUnique(CourseStreaming entity) {
         CourseStreaming info = getOne(new LambdaQueryWrapper<CourseStreaming>()
                 .eq(CourseStreaming::getStreamingName,entity.getStreamingName()).last("limit 1"));