diff --git a/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java b/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java index 06dbcb8b..08dff28b 100644 --- a/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java +++ b/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java @@ -39,7 +39,7 @@ import java.util.Date; import java.util.List; @Service -public class CourseDetailsServiceImpl extends ServiceImpl implements CourseDetailsService { +public class CourseDetailsServiceImpl extends ServiceImpl implements CourseDetailsService { @Autowired private CourseDao courseDao; @@ -57,7 +57,7 @@ public class CourseDetailsServiceImpl extends ServiceImpl().eq("user_id",userId).eq("classify",1).eq("course_id",bean.getCourseId()))); + bean.setIsCollect(courseCollectDao.selectCount(new QueryWrapper().eq("user_id", userId).eq("classify", 1).eq("course_id", bean.getCourseId()))); UserEntity userEntity = userService.selectUserById(userId); //查询用户是否购买了整集 CourseUser courseUser = courseUserDao.selectCourseUser(id, userId); - if (courseUser != null || (userEntity.getMember()!=null && userEntity.getMember()==2)) { - bean.setListsDetail(baseMapper.findByCourseId(id,userId)); - }else{ - bean.setListsDetail(baseMapper.findByCourseIdNotUrl(id,userId)); + if (courseUser != null || (userEntity != null && userEntity.getMember() != null && userEntity.getMember() == 2)) { + bean.setListsDetail(baseMapper.findByCourseId(id, userId)); + } else { + bean.setListsDetail(baseMapper.findByCourseIdNotUrl(id, userId)); //查询用户是否单独购买了集 List courseUsers = courseUserDao.selectCourseUserList(id, userId); - if(courseUsers.size()>0){ - for (CourseUser courseUser1:courseUsers){ - for (CourseDetails courseDetails:bean.getListsDetail()) { - if(courseUser1.getCourseDetailsId().equals(courseDetails.getCourseDetailsId())){ + if (courseUsers.size() > 0) { + for (CourseUser courseUser1 : courseUsers) { + for (CourseDetails courseDetails : bean.getListsDetail()) { + if (courseUser1.getCourseDetailsId().equals(courseDetails.getCourseDetailsId())) { CourseDetails courseDetails1 = baseMapper.selectById(courseDetails.getCourseDetailsId()); courseDetails.setVideoUrl(courseDetails1.getVideoUrl()); } @@ -124,22 +124,22 @@ public class CourseDetailsServiceImpl extends ServiceImpl0){ - for (CourseDetails courseDetails:bean.getListsDetail()){ - if(courseDetails.getCourseDetailsId().equals(Long.parseLong(courseDetailsId))){ + if (courseDetailsId != null) { + if (bean.getListsDetail().size() > 0) { + for (CourseDetails courseDetails : bean.getListsDetail()) { + if (courseDetails.getCourseDetailsId().equals(Long.parseLong(courseDetailsId))) { //微信内 - String url="https://api.weixin.qq.com/wxa/sec/vod/getmedialink?access_token="+ SenInfoCheckUtil.getMpToken(); - JSONObject jsonObject=new JSONObject(); - jsonObject.put("media_id",courseDetails.getWxCourseDetailsId()); - jsonObject.put("t",(new Date().getTime()/1000)+7200); + String url = "https://api.weixin.qq.com/wxa/sec/vod/getmedialink?access_token=" + SenInfoCheckUtil.getMpToken(); + JSONObject jsonObject = new JSONObject(); + jsonObject.put("media_id", courseDetails.getWxCourseDetailsId()); + jsonObject.put("t", (new Date().getTime() / 1000) + 7200); String s = HttpClientUtil.doPostJson(url, jsonObject.toJSONString()); JSONObject jsonObject1 = JSONObject.parseObject(s); String errcode = jsonObject1.getString("errcode"); - if(!"0".equals(errcode)){ - return Result.error("获取微信播放链接失败:"+jsonObject1.getString("errmsg")); + if (!"0".equals(errcode)) { + return Result.error("获取微信播放链接失败:" + jsonObject1.getString("errmsg")); } JSONObject media_info = jsonObject1.getJSONObject("media_info"); String mp4_url = media_info.getString("mp4_url"); @@ -149,39 +149,39 @@ public class CourseDetailsServiceImpl extends ServiceImpl courseDetailsIPage = baseMapper.selectCourseDetailsList(new Page<>(page, limit),randomNum,wxShow,dyShow); + IPage courseDetailsIPage = baseMapper.selectCourseDetailsList(new Page<>(page, limit), randomNum, wxShow, dyShow); if (userId != null) { List records = courseDetailsIPage.getRecords(); - for (CourseDetails courseDetails:records){ + for (CourseDetails courseDetails : records) { courseDetails.setIsCollect(courseCollectDao.selectCount(new QueryWrapper() - .eq("user_id", userId).eq("course_details_id", courseDetails.getCourseDetailsId()).eq("classify",1))); + .eq("user_id", userId).eq("course_details_id", courseDetails.getCourseDetailsId()).eq("classify", 1))); courseDetails.setIsGood(courseCollectDao.selectCount(new QueryWrapper() - .eq("user_id", userId).eq("course_details_id", courseDetails.getCourseDetailsId()).eq("classify",2))); + .eq("user_id", userId).eq("course_details_id", courseDetails.getCourseDetailsId()).eq("classify", 2))); courseDetails.setCourse(courseDao.selectById(courseDetails.getCourseId())); courseDetails.setTitle(courseDetails.getCourse().getTitle()); - courseDetails.setCourseDetailsCount(baseMapper.selectCount(new QueryWrapper().eq("course_id",courseDetails.getCourseId()))); + courseDetails.setCourseDetailsCount(baseMapper.selectCount(new QueryWrapper().eq("course_id", courseDetails.getCourseId()))); } } - return Result.success().put("data",new PageUtils(courseDetailsIPage)); + return Result.success().put("data", new PageUtils(courseDetailsIPage)); } @Override public Result courseDetailsListExcelIn(MultipartFile file, Long courseId) throws IOException { Course course = courseDao.selectById(courseId); - if (course==null){ + if (course == null) { return Result.error("所选剧不存在"); } List courseDetailsList = ExcelUtils.importExcel(file, 2, 1, CourseDetailsIn.class); @@ -195,13 +195,13 @@ public class CourseDetailsServiceImpl extends ServiceImpl 0) { successIndex++; - }else { + } else { repeat++; } }