mirror of
https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git
synced 2025-12-07 01:46:47 +08:00
Compare commits
5 Commits
lzx1031
...
zcwy1105-l
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1250903178 | ||
|
|
d92d2fa0ba | ||
|
|
d94485d00a | ||
|
|
2a771b8d20 | ||
|
|
f07bdce34f |
@@ -93,6 +93,9 @@ public class CourseServiceImpl implements ICourseService {
|
|||||||
@Resource
|
@Resource
|
||||||
private CourseHRBPAuditDao courseHRBPAuditDao;
|
private CourseHRBPAuditDao courseHRBPAuditDao;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private StudyCourseDao scdao;
|
||||||
|
|
||||||
|
|
||||||
@Resource
|
@Resource
|
||||||
private SysLogAuditDao logAuditDao;//审核日志记录
|
private SysLogAuditDao logAuditDao;//审核日志记录
|
||||||
@@ -1093,6 +1096,15 @@ public class CourseServiceImpl implements ICourseService {
|
|||||||
courseCrowdDao.saveOrUpdate(cc);
|
courseCrowdDao.saveOrUpdate(cc);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if (c != null) {
|
||||||
|
List<StudyCourse> studyCourses = scdao.findListById(c.getId());
|
||||||
|
if (studyCourses != null && !studyCourses.isEmpty()) {
|
||||||
|
for (StudyCourse sc : studyCourses) {
|
||||||
|
scdao.finishCheck(sc.getId(), c.getId(), 0, aid);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
//同步发布
|
//同步发布
|
||||||
publishUtil.fullTextPublish(c);
|
publishUtil.fullTextPublish(c);
|
||||||
//发布事件处理
|
//发布事件处理
|
||||||
|
|||||||
@@ -377,7 +377,7 @@ public class StudyCourseApi extends ApiBaseController{
|
|||||||
//更新时长
|
//更新时长
|
||||||
/**追加学习时长*/
|
/**追加学习时长*/
|
||||||
@PostMapping("/study-append-duration")
|
@PostMapping("/study-append-duration")
|
||||||
public JsonResponse<Boolean> appendStudyDuration(String studyId,String studyItemId,String contentId,Integer duration){
|
public JsonResponse<Boolean> appendStudyDuration(String studyId,String studyItemId,String contentId,Integer duration,String courseId,HttpServletRequest request){
|
||||||
if(StringUtils.isBlank(studyId)){
|
if(StringUtils.isBlank(studyId)){
|
||||||
return error("参数错误");
|
return error("参数错误");
|
||||||
}
|
}
|
||||||
@@ -387,8 +387,12 @@ public class StudyCourseApi extends ApiBaseController{
|
|||||||
if(duration==null){
|
if(duration==null){
|
||||||
return error("无学习时长");
|
return error("无学习时长");
|
||||||
}
|
}
|
||||||
|
String token = request.getHeader("Xboe-Access-Token");
|
||||||
|
if (StringUtils.isEmpty(token)) {
|
||||||
|
token = request.getHeader("token");
|
||||||
|
}
|
||||||
try {
|
try {
|
||||||
studyService.appendStudyDuration(studyId, studyItemId,contentId,duration);
|
studyService.appendStudyDuration(studyId, studyItemId,contentId,duration,courseId,token);
|
||||||
return success(true);
|
return success(true);
|
||||||
}catch(Exception e) {
|
}catch(Exception e) {
|
||||||
log.error("追加学习时长错误",e);
|
log.error("追加学习时长错误",e);
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import java.time.LocalDateTime;
|
|||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
import com.xboe.api.ThirdApi;
|
import com.xboe.api.ThirdApi;
|
||||||
|
import com.xboe.school.study.entity.StudyExam;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
@@ -120,4 +121,10 @@ public class StudyCourseDao extends BaseDao<StudyCourse> {
|
|||||||
public StudyCourse findByCourseIdAndAid(String aid, String courseId) {
|
public StudyCourse findByCourseIdAndAid(String aid, String courseId) {
|
||||||
return this.findOne(FieldFilters.eq("aid",aid),FieldFilters.eq("courseId",courseId));
|
return this.findOne(FieldFilters.eq("aid",aid),FieldFilters.eq("courseId",courseId));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public List<StudyCourse> findListById(String courseId) {
|
||||||
|
String hql1 = "FROM StudyCourse WHERE courseId = ?1";
|
||||||
|
List<StudyCourse> listByHql = super.findListByHql(hql1, courseId);
|
||||||
|
return listByHql;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -77,6 +77,7 @@ public interface IStudyService {
|
|||||||
* @param duration 学习时长
|
* @param duration 学习时长
|
||||||
*/
|
*/
|
||||||
void appendStudyDuration(String studyId,String studyItemId,String courseContentId, int duration);
|
void appendStudyDuration(String studyId,String studyItemId,String courseContentId, int duration);
|
||||||
|
void appendStudyDuration(String studyId,String studyItemId,String courseContentId, int duration,String courseId,String token);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 根据学习id,得到章节的学习记录情况
|
* 根据学习id,得到章节的学习记录情况
|
||||||
|
|||||||
@@ -108,6 +108,42 @@ public class StudyServiceImpl implements IStudyService{
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
@Transactional
|
||||||
|
public void appendStudyDuration(String studyId,String studyItemId,String courseContentId, int duration,String courseId,String token) {
|
||||||
|
|
||||||
|
//增加内容的学习时长
|
||||||
|
if(StringUtils.isNotBlank(studyItemId)) {
|
||||||
|
//直接根据id更新
|
||||||
|
// String hql="Update StudyCourseItem set studyDuration=studyDuration+"+duration+",status=(case when status<2 then 2 else status end) where id=?1";
|
||||||
|
// scItemDao.update(hql,studyItemId);
|
||||||
|
String sql="Update boe_study_course_item set study_duration=study_duration+"+duration+",status=(case when status<2 then 2 else status end) where id=?1";
|
||||||
|
scItemDao.sqlUpdate(sql,studyItemId);
|
||||||
|
//scItemDao.updateMultiFieldById(studyItemId, UpdateBuilder.create("studyDuration", "studyDuration+"+duration,FieldUpdateType.EXPRESSION));
|
||||||
|
|
||||||
|
}else {
|
||||||
|
//根据学习id和课程内容id更新
|
||||||
|
// scItemDao.update(UpdateBuilder.from(StudyCourseItem.class)
|
||||||
|
// .addUpdateField("studyDuration", "studyDuration+"+duration,FieldUpdateType.EXPRESSION)
|
||||||
|
// .addFilter(FieldFilters.eq("studyId", studyId))
|
||||||
|
// .addFilter(FieldFilters.eq("contentId", courseContentId))
|
||||||
|
// .builder());
|
||||||
|
//
|
||||||
|
// String hql="Update StudyCourseItem set studyDuration=studyDuration+"+duration+",status=(case when status<2 then 2 else status end) where studyId=?1 and contentId=?2";
|
||||||
|
// scItemDao.update(hql,studyId,courseContentId);
|
||||||
|
String sql="Update boe_study_course_item set study_duration=study_duration+"+duration+",status=(case when status<2 then 2 else status end) where study_id=?1 and content_id=?2";
|
||||||
|
scItemDao.sqlUpdate(sql,studyId,courseContentId);
|
||||||
|
}
|
||||||
|
|
||||||
|
//追加课程的学习时长
|
||||||
|
//scDao.updateMultiFieldById(studyId, UpdateBuilder.create("totalDuration", "totalDuration+"+duration,FieldUpdateType.EXPRESSION));
|
||||||
|
|
||||||
|
String sql="Update boe_study_course set total_duration=total_duration+"+duration+",status=(case when status<2 then 2 else status end),progress=(case when progress=0 then 1 else progress end),last_time = '"+LocalDateTime.now()+"' where id=?1";
|
||||||
|
scDao.sqlUpdate(sql,studyId);
|
||||||
|
Integer total = 0;
|
||||||
|
scDao.finishCheck(studyId,courseId,total,token);
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional
|
@Transactional
|
||||||
public void appendStudyDuration(String studyId,String studyItemId,String courseContentId, int duration) {
|
public void appendStudyDuration(String studyId,String studyItemId,String courseContentId, int duration) {
|
||||||
|
|||||||
Reference in New Issue
Block a user