新增待评论推送

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

@@ -175,7 +175,7 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
 
         try {
             CourseScheduleReview hasReview = courseScheduleReviewDao.findByCourseScheduleAndStudent(courseScheduleId.longValue(), practiceGroup.getStudentId());
-            if(hasReview != null){
+            if (hasReview != null) {
                 throw new BizException("评论已提交,请勿重复提交");
             }
             courseScheduleReview.setClassGroupId(courseSchedule.getClassGroupId());
@@ -190,25 +190,25 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
 
             CourseHomework existHomework = courseHomeworkDao.findByCourseSchedule(courseScheduleId.longValue());
 
-            if(StringUtils.isNotBlank(courseScheduleReview.getHomeWork())&&Objects.isNull(existHomework)){
+            if (StringUtils.isNotBlank(courseScheduleReview.getHomeWork()) && Objects.isNull(existHomework)) {
                 //新增课堂作业
-                CourseHomework courseHomework=new CourseHomework();
+                CourseHomework courseHomework = new CourseHomework();
                 courseHomework.setContent(courseScheduleReview.getHomeWork());
                 courseHomework.setCourseScheduleId(courseSchedule.getId());
                 courseHomework.setMusicGroupId(courseSchedule.getMusicGroupId());
                 courseHomework.setGroupType(courseSchedule.getGroupType());
                 courseHomework.setClassGroupId(courseSchedule.getClassGroupId());
-                courseHomework.setExpiryDate(DateUtil.addDays(date,7));
+                courseHomework.setExpiryDate(DateUtil.addDays(date, 7));
                 List<CourseScheduleStudentPayment> courseScheduleStudentPayments = courseScheduleStudentPaymentDao.findByCourseSchedule(courseSchedule.getId());
 
-                courseHomework.setExpectNum(CollectionUtils.isEmpty(courseScheduleStudentPayments)?0:courseScheduleStudentPayments.size());
+                courseHomework.setExpectNum(CollectionUtils.isEmpty(courseScheduleStudentPayments) ? 0 : courseScheduleStudentPayments.size());
                 courseHomeworkService.insert(courseHomework);
 
-                if(!CollectionUtils.isEmpty(courseScheduleStudentPayments)){
-                    List<StudentCourseHomework> studentCourseHomeworks=new ArrayList<>();
+                if (!CollectionUtils.isEmpty(courseScheduleStudentPayments)) {
+                    List<StudentCourseHomework> studentCourseHomeworks = new ArrayList<>();
                     Map<Integer, String> userMap = new HashMap<>();
                     for (CourseScheduleStudentPayment courseScheduleStudentPayment : courseScheduleStudentPayments) {
-                        StudentCourseHomework studentCourseHomework=new StudentCourseHomework();
+                        StudentCourseHomework studentCourseHomework = new StudentCourseHomework();
                         studentCourseHomework.setCourseHomeworkId(courseHomework.getId());
                         studentCourseHomework.setUserId(courseScheduleStudentPayment.getUserId());
                         studentCourseHomework.setCourseScheduleId(courseSchedule.getId());
@@ -222,14 +222,14 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
                     }
                     studentCourseHomeworkDao.batchInsertStudentCourseHomeworkRecord(studentCourseHomeworks);
                     Teacher teacher = teacherDao.get(courseScheduleReview.getTeacherId());
-                    String dateStr=DateUtil.dateToString(DateUtil.addDays(date,1), "MM月dd日");
-                    String notifyUrl="3?courseScheduleID="+courseSchedule.getId()+"&studentCourseHomeworkId="+courseHomework.getId();
+                    String dateStr = DateUtil.dateToString(DateUtil.addDays(date, 1), "MM月dd日");
+                    String notifyUrl = "3?courseScheduleID=" + courseSchedule.getId() + "&studentCourseHomeworkId=" + courseHomework.getId();
                     sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.HOMEWORK_REMIND,
                             userMap, null, 0, notifyUrl, "STUDENT", teacher.getRealName(), courseSchedule.getName(), dateStr);
                 }
             }
 
-        }finally {
+        } finally {
             redisCache.releaseLocked(lockKey, 1);
         }
 
@@ -247,15 +247,17 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
         courseScheduleReview.setHomeWork(homework.getContent());
         TeacherClassHeadInfo teacherClassGroupInfo = getCourseInfoHead(courseScheduleReview.getCourseScheduleId());
         courseScheduleReview.setTeacherName(teacherClassGroupInfo.getBishopTeacher());
-        //学生评价
-        CourseScheduleComplaintsDto courseScheduleComplaint = courseScheduleComplaintsDao.findByUserIdAndCourseId(courseScheduleReview.getStudentId().longValue(), courseScheduleReview.getCourseScheduleId().longValue());
-        ArrayList<CourseScheduleComplaintsDto> courseScheduleComplaints = new ArrayList<>();
-        courseScheduleComplaints.add(courseScheduleComplaint);
 
         ReviewInfoDto reviewInfoDto = new ReviewInfoDto();
         reviewInfoDto.setCourseScheduleReview(courseScheduleReview);
         reviewInfoDto.setTeacherClassHeadInfo(teacherClassGroupInfo);
-        reviewInfoDto.setCourseScheduleComplaints(courseScheduleComplaints);
+        //学生评价
+        CourseScheduleComplaintsDto courseScheduleComplaint = courseScheduleComplaintsDao.findByUserIdAndCourseId(courseScheduleReview.getStudentId().longValue(), courseScheduleReview.getCourseScheduleId().longValue());
+        if (courseScheduleComplaint != null) {
+            List<CourseScheduleComplaintsDto> courseScheduleComplaints = new ArrayList<>();
+            courseScheduleComplaints.add(courseScheduleComplaint);
+            reviewInfoDto.setCourseScheduleComplaints(courseScheduleComplaints);
+        }
         return reviewInfoDto;
     }
 
@@ -264,9 +266,9 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
         CourseSchedule courseSchedule = courseScheduleDao.get(id.longValue());
         ClassGroup classGroup = classGroupService.get(courseSchedule.getClassGroupId());
         TeacherClassHeadInfo teacherClassGroupInfo = classGroupService.findTeacherClassGroupInfo(courseSchedule.getClassGroupId().longValue());
-        teacherClassGroupInfo.setClassDate(DateUtil.dateToString(courseSchedule.getClassDate(),"yyyy年MM月dd日"));
-        teacherClassGroupInfo.setStartClassTime(DateUtil.dateToString(courseSchedule.getStartClassTime(),"HH:mm"));
-        teacherClassGroupInfo.setEndClassTime(DateUtil.dateToString(courseSchedule.getEndClassTime(),"HH:mm"));
+        teacherClassGroupInfo.setClassDate(DateUtil.dateToString(courseSchedule.getClassDate(), "yyyy年MM月dd日"));
+        teacherClassGroupInfo.setStartClassTime(DateUtil.dateToString(courseSchedule.getStartClassTime(), "HH:mm"));
+        teacherClassGroupInfo.setEndClassTime(DateUtil.dateToString(courseSchedule.getEndClassTime(), "HH:mm"));
         teacherClassGroupInfo.setClassGroupName(classGroup.getName());
         return teacherClassGroupInfo;
     }
@@ -278,34 +280,34 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
             throw new BizException("评论id为空");
         }
         CourseScheduleReview review = courseScheduleReviewDao.get(courseScheduleReview.getId());
-        if(review == null){
+        if (review == null) {
             throw new BizException("评论不存在");
         }
         courseScheduleReviewDao.update(courseScheduleReview);
 
-        if(StringUtils.isNotBlank(courseScheduleReview.getHomeWork())){
-            Date date=new Date();
+        if (StringUtils.isNotBlank(courseScheduleReview.getHomeWork())) {
+            Date date = new Date();
             CourseSchedule courseSchedule = courseScheduleDao.get(review.getCourseScheduleId().longValue());
             CourseHomework homework = courseHomeworkDao.findByCourseSchedule(review.getCourseScheduleId().longValue());
-            if(Objects.isNull(homework)){
-                if(StringUtils.isNotBlank(courseScheduleReview.getHomeWork())){
+            if (Objects.isNull(homework)) {
+                if (StringUtils.isNotBlank(courseScheduleReview.getHomeWork())) {
                     //新增课堂作业
-                    CourseHomework courseHomework=new CourseHomework();
+                    CourseHomework courseHomework = new CourseHomework();
                     courseHomework.setContent(courseScheduleReview.getHomeWork());
                     courseHomework.setCourseScheduleId(courseSchedule.getId());
                     courseHomework.setMusicGroupId(courseSchedule.getMusicGroupId());
                     courseHomework.setGroupType(courseSchedule.getGroupType());
                     courseHomework.setClassGroupId(courseSchedule.getClassGroupId());
-                    courseHomework.setExpiryDate(DateUtil.addDays(date,7));
+                    courseHomework.setExpiryDate(DateUtil.addDays(date, 7));
                     List<CourseScheduleStudentPayment> courseScheduleStudentPayments = courseScheduleStudentPaymentDao.findByCourseSchedule(courseSchedule.getId());
 
-                    courseHomework.setExpectNum(CollectionUtils.isEmpty(courseScheduleStudentPayments)?0:courseScheduleStudentPayments.size());
+                    courseHomework.setExpectNum(CollectionUtils.isEmpty(courseScheduleStudentPayments) ? 0 : courseScheduleStudentPayments.size());
                     courseHomeworkService.insert(courseHomework);
 
-                    if(!CollectionUtils.isEmpty(courseScheduleStudentPayments)){
-                        List<StudentCourseHomework> studentCourseHomeworks=new ArrayList<>();
+                    if (!CollectionUtils.isEmpty(courseScheduleStudentPayments)) {
+                        List<StudentCourseHomework> studentCourseHomeworks = new ArrayList<>();
                         for (CourseScheduleStudentPayment courseScheduleStudentPayment : courseScheduleStudentPayments) {
-                            StudentCourseHomework studentCourseHomework=new StudentCourseHomework();
+                            StudentCourseHomework studentCourseHomework = new StudentCourseHomework();
                             studentCourseHomework.setCourseHomeworkId(courseHomework.getId());
                             studentCourseHomework.setUserId(courseScheduleStudentPayment.getUserId());
                             studentCourseHomework.setCourseScheduleId(courseSchedule.getId());
@@ -317,7 +319,7 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
                         studentCourseHomeworkDao.batchInsertStudentCourseHomeworkRecord(studentCourseHomeworks);
                     }
                 }
-            }else if(Objects.isNull(homework.getContent())||!homework.getContent().equals(courseScheduleReview.getHomeWork())){
+            } else if (Objects.isNull(homework.getContent()) || !homework.getContent().equals(courseScheduleReview.getHomeWork())) {
                 homework.setContent(courseScheduleReview.getHomeWork());
                 courseHomeworkDao.update(homework);
             }
@@ -332,8 +334,8 @@ public class CourseReviewServiceImpl extends BaseServiceImpl<Integer, CourseSche
         courseReviewQueryInfo.setRows(10000);
         PageInfo<CourseReviewDto> practiceGroupReviews = findPracticeGroupReviews(courseReviewQueryInfo);
 
-        if(practiceGroupReviews.getTotal() <=0){
-          return;
+        if (practiceGroupReviews.getTotal() <= 0) {
+            return;
         }
         Map<Integer, List<CourseReviewDto>> teacherNeedReview = practiceGroupReviews.getRows().stream().collect(Collectors.groupingBy(CourseReviewDto::getTeacherId));