审片间接口bug修改

@@ -70,22 +70,22 @@ public class LiveMonitorRoomServiceImpl extends ServiceImpl<LiveMonitorRoomMappe
 
         List<CrpDataVo> dataList = lmRoomParam.getDataList();
 
-        //更新子任务信息
+        //初始化子任务信息
         if(!CollectionUtils.isEmpty(dataList)){
-             dataList.forEach(crpDataVo -> {
-                Long sId = crpDataVo.getId();
-                StreamTask streamTask = monitorMarkService.getById(sId);
+            List<StreamTask> taskList = dataList.stream().map(crpDataVo -> {
+                StreamTask streamTask = new StreamTask();
                 streamTask.setTaskId(crpDataVo.getTaskId());
                 streamTask.setChannelId(crpDataVo.getChannelId());
                 streamTask.setRoomId(roomId);
                 streamTask.setTaskType(crpDataVo.getTaskType());
                 streamTask.setCreatedBy("");
                 streamTask.setCreatedTime(LocalDateTime.now());
-                 monitorMarkService.updateById(streamTask);
-            });
+                return streamTask;
+            }).toList();
+            monitorMarkService.saveOrUpdateBatch(taskList);
         }
 
-        return ResultBean.ok("修改成功");
+        return ResultBean.ok("创建成功");
     }
 
     @Override
@@ -103,24 +103,23 @@ public class LiveMonitorRoomServiceImpl extends ServiceImpl<LiveMonitorRoomMappe
         monitorRoom.setLiveName(lmRoomParam.getLiveName());
         saveOrUpdate(monitorRoom);
 
-        //更新子任务
         List<CrpDataVo> dataList = lmRoomParam.getDataList();
 
+        //更新子任务信息
         if(!CollectionUtils.isEmpty(dataList)){
-            List<StreamTask> taskList = dataList.stream().map(crpDataVo -> {
-                StreamTask streamTask = new StreamTask();
+            dataList.forEach(crpDataVo -> {
+                Long sId = crpDataVo.getId();
+                StreamTask streamTask = monitorMarkService.getById(sId);
                 streamTask.setTaskId(crpDataVo.getTaskId());
                 streamTask.setChannelId(crpDataVo.getChannelId());
                 streamTask.setTaskType(crpDataVo.getTaskType());
                 streamTask.setCreatedBy("");
                 streamTask.setCreatedTime(LocalDateTime.now());
-                return streamTask;
-            }).toList();
-            monitorMarkService.saveOrUpdateBatch(taskList);
+                monitorMarkService.updateById(streamTask);
+            });
         }
 
-
-        return null;
+        return ResultBean.ok("修改成功");
     }
 
     @Override