|  | @@ -6,8 +6,6 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 | 
											
												
													
														|  |  import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 |  |  import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 | 
											
												
													
														|  |  import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 |  |  import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 | 
											
												
													
														|  |  import com.google.common.collect.Lists;
 |  |  import com.google.common.collect.Lists;
 | 
											
												
													
														|  | -import com.microsvc.toolkit.config.jwt.utils.JwtUserInfo;
 |  | 
 | 
											
												
													
														|  | -import com.yonge.cooleshow.auth.api.client.SysUserFeignService;
 |  | 
 | 
											
												
													
														|  |  import com.yonge.cooleshow.auth.api.entity.SysUser;
 |  |  import com.yonge.cooleshow.auth.api.entity.SysUser;
 | 
											
												
													
														|  |  import com.yonge.cooleshow.biz.dal.constant.CourseConstant;
 |  |  import com.yonge.cooleshow.biz.dal.constant.CourseConstant;
 | 
											
												
													
														|  |  import com.yonge.cooleshow.biz.dal.dao.CourseGroupDao;
 |  |  import com.yonge.cooleshow.biz.dal.dao.CourseGroupDao;
 | 
											
										
											
												
													
														|  | @@ -51,7 +49,6 @@ import org.springframework.transaction.annotation.Transactional;
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |  import java.math.BigDecimal;
 |  |  import java.math.BigDecimal;
 | 
											
												
													
														|  |  import java.math.RoundingMode;
 |  |  import java.math.RoundingMode;
 | 
											
												
													
														|  | -import java.text.MessageFormat;
 |  | 
 | 
											
												
													
														|  |  import java.time.LocalDate;
 |  |  import java.time.LocalDate;
 | 
											
												
													
														|  |  import java.time.ZoneId;
 |  |  import java.time.ZoneId;
 | 
											
												
													
														|  |  import java.util.*;
 |  |  import java.util.*;
 | 
											
										
											
												
													
														|  | @@ -75,7 +72,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |      private final static Logger log = LoggerFactory.getLogger(CourseGroupServiceImpl.class);
 |  |      private final static Logger log = LoggerFactory.getLogger(CourseGroupServiceImpl.class);
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |      @Autowired
 |  |      @Autowired
 | 
											
												
													
														|  | -    private SysUserFeignService sysUserFeignService;
 |  | 
 | 
											
												
													
														|  | 
 |  | +    private SysUserService sysUserService;
 | 
											
												
													
														|  |      @Autowired
 |  |      @Autowired
 | 
											
												
													
														|  |      private RedissonClient redissonClient;
 |  |      private RedissonClient redissonClient;
 | 
											
												
													
														|  |      @Autowired
 |  |      @Autowired
 | 
											
										
											
												
													
														|  | @@ -129,7 +126,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |       */
 |  |       */
 | 
											
												
													
														|  |      @Override
 |  |      @Override
 | 
											
												
													
														|  |      public LiveCourseInfoVo queryLiveCourseInfo(Long groupId) {
 |  |      public LiveCourseInfoVo queryLiveCourseInfo(Long groupId) {
 | 
											
												
													
														|  | -        return queryLiveCourseInfo(groupId, getSysUser());
 |  | 
 | 
											
												
													
														|  | 
 |  | +        return queryLiveCourseInfo(groupId, sysUserService.getUser());
 | 
											
												
													
														|  |      }
 |  |      }
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |      /**
 |  |      /**
 | 
											
										
											
												
													
														|  | @@ -159,7 +156,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |          result.setMixStudentNum(group.getMixStudentNum());
 |  |          result.setMixStudentNum(group.getMixStudentNum());
 | 
											
												
													
														|  |          result.setImGroupId(group.getImGroupId());
 |  |          result.setImGroupId(group.getImGroupId());
 | 
											
												
													
														|  |          result.setAuditVersion(group.getAuditVersion());
 |  |          result.setAuditVersion(group.getAuditVersion());
 | 
											
												
													
														|  | -        SysUser teacherUser = getSysUser(group.getTeacherId());
 |  | 
 | 
											
												
													
														|  | 
 |  | +        SysUser teacherUser = sysUserService.getByUserId(group.getTeacherId());
 | 
											
												
													
														|  |          if (teacherUser == null) {
 |  |          if (teacherUser == null) {
 | 
											
												
													
														|  |              throw new BizException("用户不存在");
 |  |              throw new BizException("用户不存在");
 | 
											
												
													
														|  |          }
 |  |          }
 | 
											
										
											
												
													
														|  | @@ -230,11 +227,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |          pageInfo.setAsc("b.created_time_");
 |  |          pageInfo.setAsc("b.created_time_");
 | 
											
												
													
														|  |          String os = WrapperUtil.toStr(param, "os");
 |  |          String os = WrapperUtil.toStr(param, "os");
 | 
											
												
													
														|  |          if (StringUtils.isNotBlank(os) && os.equals("student")) {
 |  |          if (StringUtils.isNotBlank(os) && os.equals("student")) {
 | 
											
												
													
														|  | -            Long studentId = getSysUser().getId();
 |  | 
 | 
											
												
													
														|  | -            if (Objects.isNull(studentId)) {
 |  | 
 | 
											
												
													
														|  | -                throw new BizException("未查询到用户信息请重新登录");
 |  | 
 | 
											
												
													
														|  | -            }
 |  | 
 | 
											
												
													
														|  | -            param.put("studentId", studentId);
 |  | 
 | 
											
												
													
														|  | 
 |  | +            param.put("studentId", sysUserService.getUserId());
 | 
											
												
													
														|  |              IPage<CourseGroupVo> page = baseMapper.queryStudentCourseGroup(pageInfo, param);
 |  |              IPage<CourseGroupVo> page = baseMapper.queryStudentCourseGroup(pageInfo, param);
 | 
											
												
													
														|  |              return PageUtil.pageInfo(page);
 |  |              return PageUtil.pageInfo(page);
 | 
											
												
													
														|  |          }
 |  |          }
 | 
											
										
											
												
													
														|  | @@ -356,7 +349,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |          Long groupId = WrapperUtil.toLong(param, "groupId", "课程组id不能为空!");
 |  |          Long groupId = WrapperUtil.toLong(param, "groupId", "课程组id不能为空!");
 | 
											
												
													
														|  |          Long studentId = orderGoodsInfo.getUserId();
 |  |          Long studentId = orderGoodsInfo.getUserId();
 | 
											
												
													
														|  |          //校验学生信息
 |  |          //校验学生信息
 | 
											
												
													
														|  | -        getSysUser(studentId);
 |  | 
 | 
											
												
													
														|  | 
 |  | +        sysUserService.findUserById(studentId);
 | 
											
												
													
														|  |          //课程组信息
 |  |          //课程组信息
 | 
											
												
													
														|  |          CourseGroup courseGroup = this.getOne(Wrappers.<CourseGroup>lambdaQuery()
 |  |          CourseGroup courseGroup = this.getOne(Wrappers.<CourseGroup>lambdaQuery()
 | 
											
												
													
														|  |                  .eq(CourseGroup::getId, groupId)
 |  |                  .eq(CourseGroup::getId, groupId)
 | 
											
										
											
												
													
														|  | @@ -412,6 +405,32 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |          return page.setRecords(records);
 |  |          return page.setRecords(records);
 | 
											
												
													
														|  |      }
 |  |      }
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  | 
 |  | +    @Override
 | 
											
												
													
														|  | 
 |  | +    public List<CourseGroupWrapper.CourseStudentVo> queryStudentByGroupId(Long groupId) {
 | 
											
												
													
														|  | 
 |  | +        List<CourseScheduleStudentPayment> studentPayments = courseScheduleStudentPaymentService.lambdaQuery()
 | 
											
												
													
														|  | 
 |  | +                .eq(CourseScheduleStudentPayment::getCourseGroupId, groupId)
 | 
											
												
													
														|  | 
 |  | +                .isNotNull(CourseScheduleStudentPayment::getUserId)
 | 
											
												
													
														|  | 
 |  | +                .list();
 | 
											
												
													
														|  | 
 |  | +        if (CollectionUtils.isNotEmpty(studentPayments)) {
 | 
											
												
													
														|  | 
 |  | +            List<Long> userIds = studentPayments.stream().map(CourseScheduleStudentPayment::getUserId).distinct().collect(Collectors.toList());
 | 
											
												
													
														|  | 
 |  | +            Map<Long, com.yonge.cooleshow.biz.dal.entity.SysUser> mapByIds = sysUserService.getMapByIds(userIds);
 | 
											
												
													
														|  | 
 |  | +            List<CourseGroupWrapper.CourseStudentVo> result = new ArrayList<>();
 | 
											
												
													
														|  | 
 |  | +            userIds.forEach(e -> {
 | 
											
												
													
														|  | 
 |  | +                CourseGroupWrapper.CourseStudentVo vo = new CourseGroupWrapper.CourseStudentVo();
 | 
											
												
													
														|  | 
 |  | +                vo.setStudentId(e);
 | 
											
												
													
														|  | 
 |  | +                com.yonge.cooleshow.biz.dal.entity.SysUser sysUser = mapByIds.get(e);
 | 
											
												
													
														|  | 
 |  | +                vo.setStudentName(sysUser.getRealName());
 | 
											
												
													
														|  | 
 |  | +                vo.setUserName(sysUser.getUsername());
 | 
											
												
													
														|  | 
 |  | +                vo.setAvatar(sysUser.getAvatar());
 | 
											
												
													
														|  | 
 |  | +                vo.setImUserId(imGroupService.getImUserId(String.valueOf(e),
 | 
											
												
													
														|  | 
 |  | +                        ClientEnum.STUDENT.name()));
 | 
											
												
													
														|  | 
 |  | +                result.add(vo);
 | 
											
												
													
														|  | 
 |  | +            });
 | 
											
												
													
														|  | 
 |  | +            return result;
 | 
											
												
													
														|  | 
 |  | +        }
 | 
											
												
													
														|  | 
 |  | +        return Collections.emptyList();
 | 
											
												
													
														|  | 
 |  | +    }
 | 
											
												
													
														|  | 
 |  | +
 | 
											
												
													
														|  |      /**
 |  |      /**
 | 
											
												
													
														|  |       *
 |  |       *
 | 
											
												
													
														|  |       * 直播课购买后数据写入
 |  |       * 直播课购买后数据写入
 | 
											
										
											
												
													
														|  | @@ -552,7 +571,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |          timeList.forEach(o -> {
 |  |          timeList.forEach(o -> {
 | 
											
												
													
														|  |              boolean checkDataTime = courseScheduleService.checkStudentCourseTime(studentId, startTimeFun.apply(o), endTimeFun.apply(o));
 |  |              boolean checkDataTime = courseScheduleService.checkStudentCourseTime(studentId, startTimeFun.apply(o), endTimeFun.apply(o));
 | 
											
												
													
														|  |              if (checkDataTime) {
 |  |              if (checkDataTime) {
 | 
											
												
													
														|  | -                SysUser sysUser = sysUserFeignService.queryUserById(studentId);
 |  | 
 | 
											
												
													
														|  | 
 |  | +                SysUser sysUser = sysUserService.getByUserId(studentId);
 | 
											
												
													
														|  |                  throw new BizException("学生:" + sysUser.getUsername() + ",预计安排在" + DateUtil.dateToString(startTimeFun.apply(o), "yyyy年MM月dd号 HH点mm分") + "的课程时间存在冲突!");
 |  |                  throw new BizException("学生:" + sysUser.getUsername() + ",预计安排在" + DateUtil.dateToString(startTimeFun.apply(o), "yyyy年MM月dd号 HH点mm分") + "的课程时间存在冲突!");
 | 
											
												
													
														|  |              }
 |  |              }
 | 
											
												
													
														|  |          });
 |  |          });
 | 
											
										
											
												
													
														|  | @@ -581,7 +600,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |              );
 |  |              );
 | 
											
												
													
														|  |              Optional.ofNullable(teacherTime).orElseThrow(() -> new BizException("未查询到老师陪练课设置!"));
 |  |              Optional.ofNullable(teacherTime).orElseThrow(() -> new BizException("未查询到老师陪练课设置!"));
 | 
											
												
													
														|  |              skipHoliday = teacherTime.getSkipHolidayFlag();
 |  |              skipHoliday = teacherTime.getSkipHolidayFlag();
 | 
											
												
													
														|  | -            studentId = getSysUser().getId();
 |  | 
 | 
											
												
													
														|  | 
 |  | +            studentId = sysUserService.getUserId();
 | 
											
												
													
														|  |          }
 |  |          }
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |          //获取当前课程
 |  |          //获取当前课程
 | 
											
										
											
												
													
														|  | @@ -821,7 +840,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |          Long groupId = WrapperUtil.toLong(param, "groupId", "课程组id不能为空!");
 |  |          Long groupId = WrapperUtil.toLong(param, "groupId", "课程组id不能为空!");
 | 
											
												
													
														|  |          Long studentId = orderReqInfo.getUserId();
 |  |          Long studentId = orderReqInfo.getUserId();
 | 
											
												
													
														|  |          //校验学生信息
 |  |          //校验学生信息
 | 
											
												
													
														|  | -        getSysUser(studentId);
 |  | 
 | 
											
												
													
														|  | 
 |  | +        sysUserService.findUserById(studentId);
 | 
											
												
													
														|  |          //课程组信息
 |  |          //课程组信息
 | 
											
												
													
														|  |          CourseGroup courseGroup = this.getOne(Wrappers.<CourseGroup>lambdaQuery()
 |  |          CourseGroup courseGroup = this.getOne(Wrappers.<CourseGroup>lambdaQuery()
 | 
											
												
													
														|  |                  .eq(CourseGroup::getId, groupId)
 |  |                  .eq(CourseGroup::getId, groupId)
 | 
											
										
											
												
													
														|  | @@ -1018,9 +1037,9 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |      @Override
 |  |      @Override
 | 
											
												
													
														|  |      public void buyLiveSendMessage(CourseScheduleStudentPayment studentPayment, CourseGroup courseGroup) {
 |  |      public void buyLiveSendMessage(CourseScheduleStudentPayment studentPayment, CourseGroup courseGroup) {
 | 
											
												
													
														|  |          //查询老师信息
 |  |          //查询老师信息
 | 
											
												
													
														|  | -        SysUser teacherInfo = getSysUser(courseGroup.getTeacherId());
 |  | 
 | 
											
												
													
														|  | 
 |  | +        SysUser teacherInfo = sysUserService.findUserById(courseGroup.getTeacherId());
 | 
											
												
													
														|  |          //查询学生信息
 |  |          //查询学生信息
 | 
											
												
													
														|  | -        SysUser studentInfo = getSysUser(studentPayment.getUserId());
 |  | 
 | 
											
												
													
														|  | 
 |  | +        SysUser studentInfo = sysUserService.findUserById(studentPayment.getUserId());
 | 
											
												
													
														|  |          try {
 |  |          try {
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |              String payType = "";
 |  |              String payType = "";
 | 
											
										
											
												
													
														|  | @@ -1102,17 +1121,6 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |                  .eq(CourseScheduleStudentPayment::getOrderNo, orderParam.getOrderNo()));
 |  |                  .eq(CourseScheduleStudentPayment::getOrderNo, orderParam.getOrderNo()));
 | 
											
												
													
														|  |      }
 |  |      }
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  | -    private SysUser getSysUser(Long userId) {
 |  | 
 | 
											
												
													
														|  | -        return Optional.ofNullable(userId)
 |  | 
 | 
											
												
													
														|  | -                .map(sysUserFeignService::queryUserById)
 |  | 
 | 
											
												
													
														|  | -                .orElseThrow(() -> new BizException("用户不存在"));
 |  | 
 | 
											
												
													
														|  | -    }
 |  | 
 | 
											
												
													
														|  | -
 |  | 
 | 
											
												
													
														|  | -    private SysUser getSysUser() {
 |  | 
 | 
											
												
													
														|  | -        return Optional.ofNullable(sysUserFeignService.queryUserInfo())
 |  | 
 | 
											
												
													
														|  | -                .orElseThrow(() -> new BizException("用户不存在"));
 |  | 
 | 
											
												
													
														|  | -    }
 |  | 
 | 
											
												
													
														|  | -
 |  | 
 | 
											
												
													
														|  |      /**
 |  |      /**
 | 
											
												
													
														|  |       * <p>定时将符合开售日期的未开售的直播课课程组修改为报名中状态-每隔10分钟执行一次
 |  |       * <p>定时将符合开售日期的未开售的直播课课程组修改为报名中状态-每隔10分钟执行一次
 | 
											
												
													
														|  |       * <p>定时将符合结束售卖日期的在售卖中的直播课课程组修改为取消或者成课状态状态-每隔10分钟执行一次
 |  |       * <p>定时将符合结束售卖日期的在售卖中的直播课课程组修改为取消或者成课状态状态-每隔10分钟执行一次
 | 
											
										
											
												
													
														|  | @@ -1330,7 +1338,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |      private void sendStudentMessage(Set<Long> userIds, CourseGroup courseGroup) {
 |  |      private void sendStudentMessage(Set<Long> userIds, CourseGroup courseGroup) {
 | 
											
												
													
														|  |          for (Long userId : userIds) {
 |  |          for (Long userId : userIds) {
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  | -                SysUser user = sysUserFeignService.queryUserById(userId);
 |  | 
 | 
											
												
													
														|  | 
 |  | +                SysUser user = sysUserService.getByUserId(userId);
 | 
											
												
													
														|  |                  // 发短信
 |  |                  // 发短信
 | 
											
												
													
														|  |                  try {
 |  |                  try {
 | 
											
												
													
														|  |                      Map<Long, String> receivers = new HashMap<>();
 |  |                      Map<Long, String> receivers = new HashMap<>();
 | 
											
										
											
												
													
														|  | @@ -1396,7 +1404,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |          }
 |  |          }
 | 
											
												
													
														|  |          // 发短信
 |  |          // 发短信
 | 
											
												
													
														|  |          try {
 |  |          try {
 | 
											
												
													
														|  | -            SysUser user = sysUserFeignService.queryUserById(courseGroup.getTeacherId());
 |  | 
 | 
											
												
													
														|  | 
 |  | +            SysUser user = sysUserService.getByUserId(courseGroup.getTeacherId());
 | 
											
												
													
														|  |              Map<Long, String> receivers = new HashMap<>();
 |  |              Map<Long, String> receivers = new HashMap<>();
 | 
											
												
													
														|  |              receivers.put(user.getId(), user.getPhone());
 |  |              receivers.put(user.getId(), user.getPhone());
 | 
											
												
													
														|  |              sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.AWSMS, MessageTypeEnum.SMS_LIVE_COMPLETION_FAIL,
 |  |              sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.AWSMS, MessageTypeEnum.SMS_LIVE_COMPLETION_FAIL,
 | 
											
										
											
												
													
														|  | @@ -1407,7 +1415,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |          // 发推送
 |  |          // 发推送
 | 
											
												
													
														|  |          try {
 |  |          try {
 | 
											
												
													
														|  | -            SysUser user = sysUserFeignService.queryUserById(courseGroup.getTeacherId());
 |  | 
 | 
											
												
													
														|  | 
 |  | +            SysUser user = sysUserService.getByUserId(courseGroup.getTeacherId());
 | 
											
												
													
														|  |              Map<Long, String> receivers = new HashMap<>();
 |  |              Map<Long, String> receivers = new HashMap<>();
 | 
											
												
													
														|  |              receivers.put(user.getId(), user.getPhone());
 |  |              receivers.put(user.getId(), user.getPhone());
 | 
											
												
													
														|  |              sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.LIVE_COMPLETION_FAIL,
 |  |              sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.LIVE_COMPLETION_FAIL,
 | 
											
										
											
												
													
														|  | @@ -1507,7 +1515,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |      @Override
 |  |      @Override
 | 
											
												
													
														|  |      public ShareProfitVo shareLiveCourseProfit(SysUser sysUser, Long liveGroupId) {
 |  |      public ShareProfitVo shareLiveCourseProfit(SysUser sysUser, Long liveGroupId) {
 | 
											
												
													
														|  |          LiveCourseInfoVo liveCourseInfoVo = queryLiveCourseInfo(liveGroupId, sysUser);
 |  |          LiveCourseInfoVo liveCourseInfoVo = queryLiveCourseInfo(liveGroupId, sysUser);
 | 
											
												
													
														|  | -        SysUser teacher = this.getSysUser(liveCourseInfoVo.getTeacherId());
 |  | 
 | 
											
												
													
														|  | 
 |  | +        SysUser teacher = sysUserService.getByUserId(liveCourseInfoVo.getTeacherId());
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |          LiveCourseGroupShareVo liveCourseGroupShareVo = new LiveCourseGroupShareVo();
 |  |          LiveCourseGroupShareVo liveCourseGroupShareVo = new LiveCourseGroupShareVo();
 | 
											
												
													
														|  |          BeanUtils.copyProperties(liveCourseInfoVo, liveCourseGroupShareVo);
 |  |          BeanUtils.copyProperties(liveCourseInfoVo, liveCourseGroupShareVo);
 | 
											
										
											
												
													
														|  | @@ -1580,7 +1588,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
 | 
											
												
													
														|  |      private void sendOutSaleMessage(LiveSaleOutDto dto, CourseGroup liveCourseGroupVo) {
 |  |      private void sendOutSaleMessage(LiveSaleOutDto dto, CourseGroup liveCourseGroupVo) {
 | 
											
												
													
														|  |          // 发送课程下架通知
 |  |          // 发送课程下架通知
 | 
											
												
													
														|  |          try {
 |  |          try {
 | 
											
												
													
														|  | -            SysUser user = sysUserFeignService.queryUserById(liveCourseGroupVo.getTeacherId());
 |  | 
 | 
											
												
													
														|  | 
 |  | +            SysUser user = sysUserService.getByUserId(liveCourseGroupVo.getTeacherId());
 | 
											
												
													
														|  |              Map<Long, String> receivers = new HashMap<>();
 |  |              Map<Long, String> receivers = new HashMap<>();
 | 
											
												
													
														|  |              receivers.put(user.getId(), user.getPhone());
 |  |              receivers.put(user.getId(), user.getPhone());
 | 
											
												
													
														|  |              sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.LIVE_COURSE_OUT_SALE_REASON,
 |  |              sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.LIVE_COURSE_OUT_SALE_REASON,
 |