琴房

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/entity/ImGroup.java

@@ -66,6 +66,18 @@ public class ImGroup implements Serializable {
     @ApiModelProperty(value = "修改时间;")
     private Date updateTime;
 
+    @TableField("course_group_id_")
+    @ApiModelProperty(value = "课程组id")
+    private Long courseGroupId;
+
+    public Long getCourseGroupId() {
+        return courseGroupId;
+    }
+
+    public void setCourseGroupId(Long courseGroupId) {
+        this.courseGroupId = courseGroupId;
+    }
+
     public Boolean getAutoPassFlag() {
         return autoPassFlag;
     }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/CourseScheduleService.java

@@ -242,7 +242,7 @@ public interface CourseScheduleService extends IService<CourseSchedule> {
 
     PageInfo<CourseStudentVo> selectStudent(Map<String, Object> param);
 
-    String arrangeCourse(ArrangeCourseVo arrangeCourseVo, Long teacherId);
+    void arrangeCourse(ArrangeCourseVo arrangeCourseVo, Long teacherId);
 
     Map<String, Object> selectConsumeTime(String month, Long teacherId);
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/CourseScheduleServiceImpl.java

@@ -1142,10 +1142,10 @@ public class CourseScheduleServiceImpl extends ServiceImpl<CourseScheduleDao, Co
         }
 
         //课程改为过去式避免校验时报错
-        baseMapper.update(null,Wrappers.<CourseSchedule>lambdaUpdate()
-                .eq(CourseSchedule::getId,adjustVo.getCourseId())
-                .set(CourseSchedule::getStartTime,DateUtil.getYesterday())
-                .set(CourseSchedule::getEndTime,DateUtil.getYesterday()));
+        baseMapper.update(null, Wrappers.<CourseSchedule>lambdaUpdate()
+                .eq(CourseSchedule::getId, adjustVo.getCourseId())
+                .set(CourseSchedule::getStartTime, DateUtil.getYesterday())
+                .set(CourseSchedule::getEndTime, DateUtil.getYesterday()));
 
         CourseTimeEntity timeEntity = new CourseTimeEntity();
         timeEntity.setStartTime(startTime);
@@ -1494,7 +1494,7 @@ public class CourseScheduleServiceImpl extends ServiceImpl<CourseScheduleDao, Co
      * @return
      */
     public List<DateChangeVo> splicingDate(String day, List<DateVo> strDateList, List<DateChangeVo> rList) {
-        if (CollectionUtils.isNotEmpty(strDateList)){
+        if (CollectionUtils.isNotEmpty(strDateList)) {
             for (DateVo vo : strDateList) {
                 if (vo != null) {
                     DateChangeVo dateChange = new DateChangeVo();
@@ -1636,14 +1636,14 @@ public class CourseScheduleServiceImpl extends ServiceImpl<CourseScheduleDao, Co
      * @Author: cy
      * @Date: 2022/5/27
      */
-    public String arrangeCourse(ArrangeCourseVo arrangeCourseVo, Long teacherId) {
-       return DistributedLock.of(redissonClient)
+    public void arrangeCourse(ArrangeCourseVo arrangeCourseVo, Long teacherId) {
+        DistributedLock.of(redissonClient)
                 .runIfLockCanGet(CacheNameEnum.LOCK_EXECUTE_ORDER.getRedisKey("teacherId:" + teacherId)
                         , () -> this.checkArrangeCourse(arrangeCourseVo, teacherId), 60L, TimeUnit.SECONDS);
     }
 
     @Transactional(rollbackFor = Exception.class)
-    public String checkArrangeCourse(ArrangeCourseVo arrangeCourseVo, Long teacherId) {
+    public void checkArrangeCourse(ArrangeCourseVo arrangeCourseVo, Long teacherId) {
         Integer classNum = arrangeCourseVo.getClassNum();//课时数
         Integer singleClssTime = arrangeCourseVo.getSingleClssTime();//单课时长
         List<Long> studentIds = arrangeCourseVo.getStudentIds();//学员id集合
@@ -1772,12 +1772,11 @@ public class CourseScheduleServiceImpl extends ServiceImpl<CourseScheduleDao, Co
 
         //创建群聊
         try {
-            return imGroupService.autoCreate(courseGroup.getId(), CourseScheduleEnum.PIANO_ROOM_CLASS.getCode());
+            imGroupService.autoCreate(courseGroup.getId(), CourseScheduleEnum.PIANO_ROOM_CLASS.getCode());
         } catch (Exception e) {
             log.error("琴房课程组id:{},创建群聊失败:{}", courseGroup.getId(), e);
             e.printStackTrace();
         }
-        return null;
     }
 
     /**

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImGroupServiceImpl.java

@@ -101,6 +101,7 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
         imGroup.setUpdateTime(now);
         String imGroupId = UUID.randomUUID() + imGroup.getType().getCode();
         imGroup.setId(imGroupId);
+        imGroup.setCourseGroupId(courseGroupId);
         this.baseMapper.insert(imGroup);
         //保存老师学员关联的通讯录
         imUserFriendService.saveUserFriend(teacherId, studentIds);

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/vo/CourseScheduleRecordVo.java

@@ -42,6 +42,17 @@ public class CourseScheduleRecordVo implements Serializable {
     @ApiModelProperty(value = "单课时长")
     private Integer singleCourseTime;
 
+    @ApiModelProperty(value = "通讯组id")
+    private String imGroupId;
+
+    public String getImGroupId() {
+        return imGroupId;
+    }
+
+    public void setImGroupId(String imGroupId) {
+        this.imGroupId = imGroupId;
+    }
+
     public Integer getSingleCourseTime() {
         return singleCourseTime;
     }

cooleshow-user/user-biz/src/main/resources/config/mybatis/CourseScheduleRecordMapper.xml

@@ -79,11 +79,13 @@
         s.start_time_ AS startTime,
         s.end_time_ AS endTime,
         s.single_course_time_ AS singleCourseTime,
-        a.count_ AS studentCount
+        a.count_ AS studentCount,
+        i.id_ AS imGroupId
         FROM course_schedule s
         LEFT JOIN course_group g ON s.course_group_id_ = g.id_
         LEFT JOIN `subject` sb ON g.subject_id_ = sb.id_
         LEFT JOIN (SELECT course_id_,COUNT(1) AS count_ FROM course_schedule_student_payment WHERE course_type_='PIANO_ROOM_CLASS' GROUP BY course_id_) a ON s.id_=a.course_id_
+        LEFT JOIN im_group i ON g.id_=i.course_group_id_
         <where>
             <if test="param.type != null and param.type !=''">
                 AND s.type_ = #{param.type}

cooleshow-user/user-teacher/src/main/java/com/yonge/cooleshow/teacher/controller/TeacherCourseScheduleController.java

@@ -198,7 +198,8 @@ public class TeacherCourseScheduleController extends BaseController {
         if (user == null || null == user.getId()) {
             return failed(HttpStatus.FORBIDDEN, "请登录");
         }
-        return succeed(courseScheduleService.arrangeCourse(arrangeCourseVo, user.getId()));
+        courseScheduleService.arrangeCourse(arrangeCourseVo, user.getId());
+        return succeed();
     }
 
     @ApiOperation("根据月份查询消耗时长")