Merge branch 'dev_1_2_1_20220802' of http://git.dayaedu.com/yonge/cooleshow into dev_1_2_1_20220802

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

@@ -2258,6 +2258,40 @@ public class CourseScheduleServiceImpl extends ServiceImpl<CourseScheduleDao, Co
                 .set(CourseSchedule::getClassDate, DateUtil.trunc(startTime))
                 .set(CourseSchedule::getStartTime, startTime)
                 .set(CourseSchedule::getEndTime, endTime));
+
+        if (CollectionUtils.isNotEmpty(studentPayments)) {
+            SysUser teacher = sysUserFeignService.queryUserById(teacherId);
+
+            CourseSchedule schedule = this.getById(courseId);
+            CourseGroup courseGroup = courseGroupService.getById(courseSchedule.getCourseGroupId());
+
+            String courseName = courseGroup.getName() + "-第" + courseSchedule.getClassNum() + "课";
+
+            String dateString = startTime.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime().format(
+                    DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+
+            for (CourseScheduleStudentPayment payment : studentPayments) {
+                sendPianoCourseAdjustMessage(teacher,payment.getUserId(),courseName,dateString);
+
+            }
+        }
+    }
+
+    //{老师昵称}已将{课程类型琴房课}{课程名称}课调整到{上课时间yyyy-MM-dd HH:mm:ss}，请注意查看
+    private void sendPianoCourseAdjustMessage(SysUser teacher,Long studentId,String courseName,String dateString) {
+        //  琴房课调整模板
+        try {
+            //  发送消息
+            SysUser student = sysUserFeignService.queryUserById(studentId);
+
+            Map<Long, String> receivers = new HashMap<>();
+            receivers.put(studentId, student.getPhone());
+            sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.PIANO_ROOM_ADJUST, receivers, null,
+                    0, null, ClientEnum.STUDENT.getCode(), teacher.getUsername(),"琴房课",courseName,dateString);
+
+        } catch (Exception e) {
+            log.error("琴房课调整发送消息失败--> {}", e.fillInStackTrace());
+        }
     }
 
     /**