package com.qxueyou.scc.admin.progress.service.impl;
|
|
import java.math.BigDecimal;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.PostConstruct;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
|
import com.qxueyou.scc.admin.progress.dao.ProgressDAO;
|
import com.qxueyou.scc.admin.progress.model.Progress;
|
import com.qxueyou.scc.admin.progress.model.view.SubjectProgressTreeV;
|
import com.qxueyou.scc.admin.progress.service.IDetailProgressService;
|
import com.qxueyou.scc.admin.progress.service.IProgressService;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.ICacheService;
|
import com.qxueyou.scc.base.service.impl.CommonAppService;
|
import com.qxueyou.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
|
@Service
|
public class ProgressService extends CommonAppService implements IProgressService {
|
public static final String SUBJECT_PROGRESS_STATISTIC = "subject_progress_statistic";
|
|
private final Logger log = LogManager.getLogger(ProgressService.class);
|
|
@Autowired
|
ICacheService cacheService;
|
|
@Autowired
|
ProgressDAO dao;
|
|
/**
|
* 各类型课件进度服务实现
|
*/
|
private Map<String, IDetailProgressService> resItemServiceMap = new HashMap<String, IDetailProgressService>(6);
|
|
@Autowired
|
private ApplicationContext appContext;
|
|
@PostConstruct
|
private void init() {
|
addProgressService(appContext.getBean("LectureProgressService", IDetailProgressService.class));
|
addProgressService(appContext.getBean("ChapterProgressService", IDetailProgressService.class));
|
addProgressService(appContext.getBean("SubjectProgressService", IDetailProgressService.class));
|
addProgressService(appContext.getBean("ClassProgressService", IDetailProgressService.class));
|
}
|
|
private void addProgressService(IDetailProgressService service) {
|
resItemServiceMap.put(service.getType(), service);
|
}
|
|
@Override
|
public List<Progress> query(String type, String learnerId, List<String> targetId) {
|
return queryLst(type, learnerId, targetId);
|
}
|
|
@Override
|
public List<Progress> query(String type, List<String> learnerId, String targetId) {
|
return queryLst(type, learnerId, targetId);
|
}
|
|
@Override
|
public Progress query(String type, String targetId, String learnerId) {
|
String hql = "from Progress where type=:type and learnerId=:learnerId and targetId=:targetId";
|
return findUniqueByHql(hql,
|
CollectionUtils.newObjectMap("type", type, "learnerId", learnerId, "targetId", targetId));
|
}
|
|
private List<Progress> queryLst(String type, Object learnerId, Object targetId) {
|
String hql = "from Progress where type=:type and learnerId=:learnerId and targetId=:targetId";
|
return findByComplexHql(hql,
|
CollectionUtils.newObjectMap("type", type, "learnerId", learnerId, "targetId", targetId),
|
Progress.class);
|
}
|
|
@Override
|
public Result addProgress(String type, String targetId, int start, int end, String userId) {
|
String userId_ = StringUtils.isBlank(userId) ? ClientUtils.getUserId() : userId;
|
return resItemServiceMap.get(type).addProgress(targetId, userId_, start, end);
|
}
|
|
@Scheduled(cron = "0/2 * * * * ?")
|
protected void doTimer() {
|
String nodeIdOrUserId = cacheService.lstLeftPop(SUBJECT_PROGRESS_STATISTIC);
|
|
if (StringUtils.isBlank(nodeIdOrUserId)) {
|
return;
|
}
|
String[] ids = nodeIdOrUserId.split(",");
|
String nodeId = ids[0];
|
String userId = ids[1];
|
SubjectProgressTreeV subjectProgressTreeV = null;
|
try {
|
|
subjectProgressTreeV = dao.getSubjectProgressTreeV(nodeId, userId);
|
Map<String, Object> itemProgress = dao.getItemProgress(nodeId, userId);
|
Progress progress = dao.getProgressObject(nodeId, userId);
|
Double progressPercent = Double.valueOf(itemProgress.get("progressPercent").toString());
|
BigDecimal progressValue = new BigDecimal(itemProgress.get("progressValue").toString());
|
if (progress == null) {
|
String nodeType = subjectProgressTreeV.getNodeType();
|
this.addProgress(nodeType, nodeId, 0, 0, userId);
|
cacheService.lstRightPush(SUBJECT_PROGRESS_STATISTIC, nodeIdOrUserId);
|
return;
|
}
|
TraceUtils.setUpdateTrace(progress);
|
progress.setProgressPercent(progressPercent);
|
progress.setProgressValue(progressValue);
|
save(progress);
|
|
} catch (Exception e) {
|
log.error("保存异常", e);
|
return;
|
}
|
|
if (StringUtils.isNotBlank(subjectProgressTreeV.getParentId())) {
|
cacheService.lstRightPush(SUBJECT_PROGRESS_STATISTIC, subjectProgressTreeV.getParentId() + "," + userId);
|
}
|
|
}
|
|
@Override
|
public List<SubjectProgressTreeV> getSubjectChapterTreeVList(String parentId, String userId) {
|
return dao.getSubjectChapterTreeVList(parentId, userId);
|
}
|
|
}
|
