mirror of
https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git
synced 2025-12-12 04:16:51 +08:00
Compare commits
6 Commits
250331-bug
...
250331-bug
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
cdf9698f71 | ||
|
|
74bcec72bc | ||
|
|
b8c171bf86 | ||
|
|
175e7f6c28 | ||
|
|
5705bb8529 | ||
|
|
87e5dd81f8 |
@@ -1,9 +1,14 @@
|
|||||||
package com.xboe.school.study.api;
|
package com.xboe.school.study.api;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import java.math.RoundingMode;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
import java.util.function.Function;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
import cn.hutool.core.collection.CollectionUtil;
|
||||||
import com.alibaba.nacos.shaded.com.google.common.util.concurrent.RateLimiter;
|
import com.alibaba.nacos.shaded.com.google.common.util.concurrent.RateLimiter;
|
||||||
import com.xboe.api.ThirdApi;
|
import com.xboe.api.ThirdApi;
|
||||||
import com.xboe.constants.CacheName;
|
import com.xboe.constants.CacheName;
|
||||||
@@ -253,6 +258,49 @@ public class StudyCourseApi extends ApiBaseController{
|
|||||||
rs.put("progress", sc.getProgress());
|
rs.put("progress", sc.getProgress());
|
||||||
//查询上次学习的是什么资源。查询用户的学习情况
|
//查询上次学习的是什么资源。查询用户的学习情况
|
||||||
List<StudyCourseItem> items=studyService.findByStudyId(sc.getId());
|
List<StudyCourseItem> items=studyService.findByStudyId(sc.getId());
|
||||||
|
// 和内容匹配,根据内容的视频时长,计算学习进度
|
||||||
|
if(CollectionUtil.isNotEmpty(items) && CollectionUtil.isNotEmpty(cclist)){
|
||||||
|
// 根据ID转换map
|
||||||
|
Map<String, CourseContent> contentMap = cclist.stream().collect(Collectors.toMap(CourseContent::getId, Function.identity()));
|
||||||
|
for (StudyCourseItem item : items) {
|
||||||
|
CourseContent content = contentMap.get(item.getContentId());
|
||||||
|
if(null == content){
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
if(null==item.getLastStudyTime()
|
||||||
|
|| item.getLastStudyTime()<=0
|
||||||
|
|| null==content.getDuration()
|
||||||
|
|| content.getDuration()<=0){
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 查询redis上面的key,并解析value获取到lastStudyTime
|
||||||
|
String lastActive = redisTemplate.opsForValue().get("studyContentId:" + item.getId() + ":last_active");
|
||||||
|
if (StringUtil.isNotBlank(lastActive)) {
|
||||||
|
String[] parts = lastActive.split("&");
|
||||||
|
if (parts.length == 2) {
|
||||||
|
int lastStudyTimeRedis = Integer.parseInt(parts[0]);
|
||||||
|
log.info("study-video-time-redis获取---lastStudyTimeRedis = " + lastStudyTimeRedis);
|
||||||
|
if(lastStudyTimeRedis>0){
|
||||||
|
item.setLastStudyTime(lastStudyTimeRedis);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
BigDecimal lastStudyTime = new BigDecimal(item.getLastStudyTime());
|
||||||
|
BigDecimal duration = new BigDecimal(content.getDuration());
|
||||||
|
BigDecimal progress = lastStudyTime.divide(duration, 10, RoundingMode.HALF_UP);
|
||||||
|
if(progress.compareTo(BigDecimal.ZERO) < 0){
|
||||||
|
progress = BigDecimal.ZERO;
|
||||||
|
}else if(progress.compareTo(BigDecimal.ONE) > 0){
|
||||||
|
progress = BigDecimal.ONE;
|
||||||
|
}
|
||||||
|
|
||||||
|
item.setProgressVideo(progress);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
rs.put("contentStudys",items);//学习的内容
|
rs.put("contentStudys",items);//学习的内容
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,10 +1,12 @@
|
|||||||
package com.xboe.school.study.entity;
|
package com.xboe.school.study.entity;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
import javax.persistence.Column;
|
import javax.persistence.Column;
|
||||||
import javax.persistence.Entity;
|
import javax.persistence.Entity;
|
||||||
import javax.persistence.Table;
|
import javax.persistence.Table;
|
||||||
|
import javax.persistence.Transient;
|
||||||
|
|
||||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||||
import com.xboe.core.SysConstant;
|
import com.xboe.core.SysConstant;
|
||||||
@@ -128,5 +130,11 @@ public class StudyCourseItem extends IdEntity {
|
|||||||
*/
|
*/
|
||||||
@Column(name = "status",length=1)
|
@Column(name = "status",length=1)
|
||||||
private Integer status;
|
private Integer status;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 视频播放进度
|
||||||
|
* */
|
||||||
|
@Transient
|
||||||
|
private BigDecimal progressVideo;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -8,7 +8,6 @@ import com.xboe.common.PageList;
|
|||||||
import com.xboe.school.study.dto.StudyContentDto;
|
import com.xboe.school.study.dto.StudyContentDto;
|
||||||
import com.xboe.school.study.entity.StudyCourseItem;
|
import com.xboe.school.study.entity.StudyCourseItem;
|
||||||
import com.xboe.school.study.entity.StudyTime;
|
import com.xboe.school.study.entity.StudyTime;
|
||||||
import com.xboe.system.user.entity.User;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 学习情况处理,比较综合一个处理类
|
* 学习情况处理,比较综合一个处理类
|
||||||
@@ -36,11 +35,12 @@ public interface IStudyService {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* 更新最后的学习时间,及学习时间点
|
* 更新最后的学习时间,及学习时间点
|
||||||
|
*
|
||||||
* @param studyContentId
|
* @param studyContentId
|
||||||
* @param lastStudyTime
|
* @param lastStudyTime
|
||||||
* @param aid
|
* @param aid
|
||||||
*/
|
*/
|
||||||
void updateLastTime(String studyContentId,int lastStudyTime,String aid);
|
void updateLastTime(String studyContentId, int lastStudyTime, String aid);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 资源学习记录
|
* 资源学习记录
|
||||||
|
|||||||
@@ -10,10 +10,6 @@ import java.util.Map;
|
|||||||
|
|
||||||
import javax.transaction.Transactional;
|
import javax.transaction.Transactional;
|
||||||
|
|
||||||
import com.xboe.module.article.entity.Article;
|
|
||||||
import com.xboe.module.interaction.entity.Shares;
|
|
||||||
import com.xboe.school.study.entity.StudyCourse;
|
|
||||||
import com.xboe.system.user.entity.User;
|
|
||||||
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.StringUtils;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.data.redis.core.StringRedisTemplate;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
||||||
|
|||||||
Reference in New Issue
Block a user