czg_team/video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

用户为空

Browse Source
This commit is contained in:
wangw
2024-12-06 16:01:34 +08:00
parent ce8c9f38e0
commit 383867e7a2
1 changed files with 48 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

96
src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java
View File

@@ -39,7 +39,7 @@ import java.util.Date;
import java.util.List; import java.util.List;
@Service @Service
public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, CourseDetails> implements CourseDetailsService { public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, CourseDetails> implements CourseDetailsService {
@Autowired @Autowired
private CourseDao courseDao; private CourseDao courseDao;
@@ -57,7 +57,7 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cou
@Override @Override
public Result insert(CourseDetails courseDetails) { public Result insert(CourseDetails courseDetails) {
if(courseDetails.getGoodNum()==null){ if (courseDetails.getGoodNum() == null) {
courseDetails.setGoodNum(0); courseDetails.setGoodNum(0);
} }
baseMapper.insert(courseDetails); baseMapper.insert(courseDetails);
@@ -78,37 +78,37 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cou
} }
@Override @Override
public Result selectCourseDetailsById(Long id,String token,String courseDetailsId){ public Result selectCourseDetailsById(Long id, String token, String courseDetailsId) {
Course bean = courseDao.selectById(id); Course bean = courseDao.selectById(id);
if(bean.getViewCounts()==null){ if (bean.getViewCounts() == null) {
bean.setViewCounts(1); bean.setViewCounts(1);
}else{ } else {
bean.setViewCounts(bean.getViewCounts()+1); bean.setViewCounts(bean.getViewCounts() + 1);
} }
courseDao.updateById(bean); courseDao.updateById(bean);
Long userId=null; Long userId = null;
if(StringUtils.isNotEmpty(token)){ if (StringUtils.isNotEmpty(token)) {
Claims claims = jwtUtils.getClaimByToken(token); Claims claims = jwtUtils.getClaimByToken(token);
if(claims != null && !jwtUtils.isTokenExpired(claims.getExpiration())){ if (claims != null && !jwtUtils.isTokenExpired(claims.getExpiration())) {
userId=Long.parseLong(claims.getSubject()); userId = Long.parseLong(claims.getSubject());
} }
} }
bean.setIsCollect(0); bean.setIsCollect(0);
if (userId != null) { if (userId != null) {
bean.setIsCollect(courseCollectDao.selectCount(new QueryWrapper<CourseCollect>().eq("user_id",userId).eq("classify",1).eq("course_id",bean.getCourseId()))); bean.setIsCollect(courseCollectDao.selectCount(new QueryWrapper<CourseCollect>().eq("user_id", userId).eq("classify", 1).eq("course_id", bean.getCourseId())));
UserEntity userEntity = userService.selectUserById(userId); UserEntity userEntity = userService.selectUserById(userId);
//查询用户是否购买了整集 //查询用户是否购买了整集
CourseUser courseUser = courseUserDao.selectCourseUser(id, userId); CourseUser courseUser = courseUserDao.selectCourseUser(id, userId);
if (courseUser != null || (userEntity.getMember()!=null && userEntity.getMember()==2)) { if (courseUser != null || (userEntity != null && userEntity.getMember() != null && userEntity.getMember() == 2)) {
bean.setListsDetail(baseMapper.findByCourseId(id,userId)); bean.setListsDetail(baseMapper.findByCourseId(id, userId));
}else{ } else {
bean.setListsDetail(baseMapper.findByCourseIdNotUrl(id,userId)); bean.setListsDetail(baseMapper.findByCourseIdNotUrl(id, userId));
//查询用户是否单独购买了集 //查询用户是否单独购买了集
List<CourseUser> courseUsers = courseUserDao.selectCourseUserList(id, userId); List<CourseUser> courseUsers = courseUserDao.selectCourseUserList(id, userId);
if(courseUsers.size()>0){ if (courseUsers.size() > 0) {
for (CourseUser courseUser1:courseUsers){ for (CourseUser courseUser1 : courseUsers) {
for (CourseDetails courseDetails:bean.getListsDetail()) { for (CourseDetails courseDetails : bean.getListsDetail()) {
if(courseUser1.getCourseDetailsId().equals(courseDetails.getCourseDetailsId())){ if (courseUser1.getCourseDetailsId().equals(courseDetails.getCourseDetailsId())) {
CourseDetails courseDetails1 = baseMapper.selectById(courseDetails.getCourseDetailsId()); CourseDetails courseDetails1 = baseMapper.selectById(courseDetails.getCourseDetailsId());
courseDetails.setVideoUrl(courseDetails1.getVideoUrl()); courseDetails.setVideoUrl(courseDetails1.getVideoUrl());
} }
@@ -124,22 +124,22 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cou
}*/ }*/
} else { } else {
bean.setListsDetail(baseMapper.findByCourseIdNotUrl(id,null)); bean.setListsDetail(baseMapper.findByCourseIdNotUrl(id, null));
} }
if(courseDetailsId!=null){ if (courseDetailsId != null) {
if (bean.getListsDetail().size()>0){ if (bean.getListsDetail().size() > 0) {
for (CourseDetails courseDetails:bean.getListsDetail()){ for (CourseDetails courseDetails : bean.getListsDetail()) {
if(courseDetails.getCourseDetailsId().equals(Long.parseLong(courseDetailsId))){ if (courseDetails.getCourseDetailsId().equals(Long.parseLong(courseDetailsId))) {
//微信内 //微信内
String url="https://api.weixin.qq.com/wxa/sec/vod/getmedialink?access_token="+ SenInfoCheckUtil.getMpToken(); String url = "https://api.weixin.qq.com/wxa/sec/vod/getmedialink?access_token=" + SenInfoCheckUtil.getMpToken();
JSONObject jsonObject=new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("media_id",courseDetails.getWxCourseDetailsId()); jsonObject.put("media_id", courseDetails.getWxCourseDetailsId());
jsonObject.put("t",(new Date().getTime()/1000)+7200); jsonObject.put("t", (new Date().getTime() / 1000) + 7200);
String s = HttpClientUtil.doPostJson(url, jsonObject.toJSONString()); String s = HttpClientUtil.doPostJson(url, jsonObject.toJSONString());
JSONObject jsonObject1 = JSONObject.parseObject(s); JSONObject jsonObject1 = JSONObject.parseObject(s);
String errcode = jsonObject1.getString("errcode"); String errcode = jsonObject1.getString("errcode");
if(!"0".equals(errcode)){ if (!"0".equals(errcode)) {
return Result.error("获取微信播放链接失败："+jsonObject1.getString("errmsg")); return Result.error("获取微信播放链接失败：" + jsonObject1.getString("errmsg"));
} }
JSONObject media_info = jsonObject1.getJSONObject("media_info"); JSONObject media_info = jsonObject1.getJSONObject("media_info");
String mp4_url = media_info.getString("mp4_url"); String mp4_url = media_info.getString("mp4_url");
@@ -149,39 +149,39 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cou
} }
} }
} }
return Result.success().put("data",bean); return Result.success().put("data", bean);
} }
@Override @Override
public Result selectCourseDetailsList(Integer page,Integer limit,String token,String randomNum,Integer wxShow,Integer dyShow){ public Result selectCourseDetailsList(Integer page, Integer limit, String token, String randomNum, Integer wxShow, Integer dyShow) {
Long userId=null; Long userId = null;
if(StringUtils.isNotEmpty(token)){ if (StringUtils.isNotEmpty(token)) {
Claims claims = jwtUtils.getClaimByToken(token); Claims claims = jwtUtils.getClaimByToken(token);
if(claims != null && !jwtUtils.isTokenExpired(claims.getExpiration())){ if (claims != null && !jwtUtils.isTokenExpired(claims.getExpiration())) {
userId=Long.parseLong(claims.getSubject()); userId = Long.parseLong(claims.getSubject());
} }
} }
IPage<CourseDetails> courseDetailsIPage = baseMapper.selectCourseDetailsList(new Page<>(page, limit),randomNum,wxShow,dyShow); IPage<CourseDetails> courseDetailsIPage = baseMapper.selectCourseDetailsList(new Page<>(page, limit), randomNum, wxShow, dyShow);
if (userId != null) { if (userId != null) {
List<CourseDetails> records = courseDetailsIPage.getRecords(); List<CourseDetails> records = courseDetailsIPage.getRecords();
for (CourseDetails courseDetails:records){ for (CourseDetails courseDetails : records) {
courseDetails.setIsCollect(courseCollectDao.selectCount(new QueryWrapper<CourseCollect>() courseDetails.setIsCollect(courseCollectDao.selectCount(new QueryWrapper<CourseCollect>()
.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<CourseCollect>() courseDetails.setIsGood(courseCollectDao.selectCount(new QueryWrapper<CourseCollect>()
.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.setCourse(courseDao.selectById(courseDetails.getCourseId()));
courseDetails.setTitle(courseDetails.getCourse().getTitle()); courseDetails.setTitle(courseDetails.getCourse().getTitle());
courseDetails.setCourseDetailsCount(baseMapper.selectCount(new QueryWrapper<CourseDetails>().eq("course_id",courseDetails.getCourseId()))); courseDetails.setCourseDetailsCount(baseMapper.selectCount(new QueryWrapper<CourseDetails>().eq("course_id", courseDetails.getCourseId())));
} }
} }
return Result.success().put("data",new PageUtils(courseDetailsIPage)); return Result.success().put("data", new PageUtils(courseDetailsIPage));
} }
@Override @Override
public Result courseDetailsListExcelIn(MultipartFile file, Long courseId) throws IOException { public Result courseDetailsListExcelIn(MultipartFile file, Long courseId) throws IOException {
Course course = courseDao.selectById(courseId); Course course = courseDao.selectById(courseId);
if (course==null){ if (course == null) {
return Result.error("所选剧不存在"); return Result.error("所选剧不存在");
} }
List<CourseDetailsIn> courseDetailsList = ExcelUtils.importExcel(file, 2, 1, CourseDetailsIn.class); List<CourseDetailsIn> courseDetailsList = ExcelUtils.importExcel(file, 2, 1, CourseDetailsIn.class);
@@ -195,13 +195,13 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cou
//成功条数 //成功条数
int successIndex = 0; int successIndex = 0;
//空数据 //空数据
int emptyCount=0; int emptyCount = 0;
for (CourseDetailsIn courseDetailsIn : courseDetailsList) { for (CourseDetailsIn courseDetailsIn : courseDetailsList) {
if(courseDetailsIn.getCourseDetailsName()==null){ if (courseDetailsIn.getCourseDetailsName() == null) {
emptyCount++; emptyCount++;
continue; continue;
} }
if (courseDetailsIn.getIsPrice()!=2){ if (courseDetailsIn.getIsPrice() != 2) {
if (courseDetailsIn.getPrice() == null || courseDetailsIn.getPrice().compareTo(BigDecimal.ZERO) <= 0) { if (courseDetailsIn.getPrice() == null || courseDetailsIn.getPrice().compareTo(BigDecimal.ZERO) <= 0) {
return Result.error("第【" + index + "】行数据为收费,但并没有设置价格"); return Result.error("第【" + index + "】行数据为收费,但并没有设置价格");
} }
@@ -215,10 +215,10 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cou
courseDetails.setViewCount(0L); courseDetails.setViewCount(0L);
courseDetails.setPlayCompleteCount(0L); courseDetails.setPlayCompleteCount(0L);
BeanUtils.copyProperties(courseDetailsIn, courseDetails); BeanUtils.copyProperties(courseDetailsIn, courseDetails);
int result = baseMapper.insert(courseDetails); int result = baseMapper.insert(courseDetails);
if (result > 0) { if (result > 0) {
successIndex++; successIndex++;
}else { } else {
repeat++; repeat++;
} }
} }