Merge branch 'feature/0529-live' of http://git.dayaedu.com/yonge/mec into zx-06-15-live

mec-biz/src/main/java/com/ym/mec/biz/service/impl/CourseScheduleServiceImpl.java

@@ -1876,6 +1876,10 @@ public class CourseScheduleServiceImpl extends BaseServiceImpl<Long, CourseSched
 		if (CollectionUtils.isEmpty(courseSchedules)) {
 			return false;
 		}
+		//直播课不校验冲突
+		if(courseSchedules.get(0).getGroupType() == LIVE){
+			return true;
+		}
 		List<String> classDates = courseSchedules.stream().map(courseSchedule -> DateUtil.dateToString(courseSchedule.getClassDate(), "yyyy-MM-dd"))
 				.collect(Collectors.toList());
 
@@ -3516,7 +3520,10 @@ public class CourseScheduleServiceImpl extends BaseServiceImpl<Long, CourseSched
 		}
 
 		if(newCourseSchedules.size() > 0){
-			courseScheduleDao.batchUpdate(newCourseSchedules);
+            for (CourseSchedule course : newCourseSchedules) {
+                course.setLiveRemind(0);
+            }
+            courseScheduleDao.batchUpdate(newCourseSchedules);
             List<Integer> classGroupIds = newCourseSchedules.stream().filter(courseSchedule -> Objects.nonNull(courseSchedule.getClassGroupId())).map(CourseSchedule::getClassGroupId).collect(Collectors.toList());
             if(!CollectionUtils.isEmpty(classGroupIds)){
                 classGroupService.updateClassGroupsCourseInfo(classGroupIds);
@@ -6477,7 +6484,7 @@ public class CourseScheduleServiceImpl extends BaseServiceImpl<Long, CourseSched
 					CourseSchedule next = beforeCourse.get(i + 1);
 
 					if (!next.getContinuousCourse()) {
-						newCourseSchedules.add(next);
+						//newCourseSchedules.add(next);
 						break;
 					}
 				}

mec-biz/src/main/java/com/ym/mec/biz/service/impl/VipGroupServiceImpl.java

@@ -5133,10 +5133,10 @@ public class VipGroupServiceImpl extends BaseServiceImpl<Long, VipGroup> impleme
 
         DateTime time = DateTime.parse(liveStartTime, DateTimeFormat.forPattern(DateUtil.DEFAULT_PATTERN + " " + DateUtil.EXPANDED_TIME_FORMAT));
 
-        String roomUid = "LIVE-" + roomId + "-" + time.toDate().getTime();
+        String roomUid = "LIVE-" + roomId + "-" + courseSchedule.getActualTeacherId().toString() + time.toDate().getTime();
         ImLiveBroadcastRoom room = imLiveBroadcastRoomService.getByRoomUid(roomUid);
         if (Objects.nonNull(room)) {
-            return;
+            liveRoom.setId(room.getId());
         }
         liveRoom.setTenantId(TenantContextHolder.getTenantId());
         liveRoom.setRoomUid(roomUid);
@@ -5151,7 +5151,7 @@ public class VipGroupServiceImpl extends BaseServiceImpl<Long, VipGroup> impleme
         liveRoom.setTenantId(courseSchedule.getTenantId());
 
         // 创建直播间
-        imLiveBroadcastRoomService.save(liveRoom);
+        imLiveBroadcastRoomService.saveOrUpdate(liveRoom);
 
         // 开启直播间
         try {

mec-biz/src/main/resources/config/mybatis/CourseScheduleMapper.xml

@@ -1913,7 +1913,7 @@
         )
         and cs.tenant_id_ = #{tenantId}
         AND (cs.del_flag_ IS NULL OR cs.del_flag_=0)
-        AND (cs.new_course_id_ IS NULL OR cs.new_course_id_=cs.id_)
+        AND (cs.new_course_id_ IS NULL OR cs.new_course_id_=cs.id_) AND cs.group_type_ != 'LIVE'
     </select>
 
     <select id="queryStudentCoursesTimesOfTomorrow" resultMap="Mapper">

mec-im/src/main/java/com/ym/service/Impl/RoomServiceImpl.java

@@ -400,11 +400,14 @@ public class RoomServiceImpl implements RoomService {
 
         DateTime time = DateTime.parse(liveStartTime, DateTimeFormat.forPattern(DateUtil.DEFAULT_PATTERN + " " + DateUtil.EXPANDED_TIME_FORMAT));
 
-        String roomUid = "LIVE-" + roomId + "-" + time.toDate().getTime();
+        String roomUid = "LIVE-" + roomId + "-" + courseSchedule.getActualTeacherId().toString() + time.toDate().getTime();
         ImLiveBroadcastRoom liveRoom = JSON.parseObject(vipGroup.getLiveConfigJson(), ImLiveBroadcastRoom.class);
 
         try {
-
+            ImLiveBroadcastRoom room = imLiveBroadcastRoomService.getByRoomUid(roomUid);
+            if (Objects.nonNull(room)) {
+                liveRoom.setId(room.getId());
+            }
 
             if (StringUtils.isBlank(liveRoom.getServiceProvider())) {
                 //查询房间过期时间
@@ -424,7 +427,7 @@ public class RoomServiceImpl implements RoomService {
             liveRoom.setTenantId(courseSchedule.getTenantId());
 
             // 创建直播间
-            imLiveBroadcastRoomService.save(liveRoom);
+            imLiveBroadcastRoomService.saveOrUpdate(liveRoom);
 
             // 开启直播间
             imLiveBroadcastRoomService.createLiveRoom(liveRoom);