package com.qxueyou.scc.school.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.stereotype.Service;
|
|
import com.qxueyou.scc.base.model.Result;
|
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;
|
import com.qxueyou.scc.exercise.model.ExerciseGroup;
|
import com.qxueyou.scc.exercise.model.ExerciseGroupExtend;
|
import com.qxueyou.scc.exercise.model.ExerciseItemAnswerU;
|
import com.qxueyou.scc.exercise.model.ExerciseRecord;
|
import com.qxueyou.scc.exercise.service.IExerciseService;
|
import com.qxueyou.scc.school.dao.InteractDAO;
|
import com.qxueyou.scc.school.model.InteractResultData;
|
import com.qxueyou.scc.school.model.InterateAnswer;
|
import com.qxueyou.scc.school.model.SchInteract;
|
import com.qxueyou.scc.school.service.IInteractService;
|
|
@Service
|
public class InteactService extends CommonAppService implements IInteractService {
|
|
private InteractDAO interactDAO;
|
|
/** 扩展练习service */
|
@Autowired
|
private IExerciseService exerciseService;
|
|
public InteractDAO getInteractDAO() {
|
return interactDAO;
|
}
|
|
/**
|
* 依赖注入
|
*
|
* @param interactDAO
|
*/
|
@Autowired(required = false)
|
public void setInteractDAO(@Qualifier("interactDAO")
|
InteractDAO interactDAO) {
|
this.interactDAO = interactDAO;
|
}
|
|
/*
|
* (non-Javadoc)
|
* @see com.qxueyou.scc.school.service.IInteractService#insertInteract(com.qxueyou.scc.school.model.SchInteract)
|
*/
|
@Override
|
public Result insertInteract(String interactName, String exerciseTime) {
|
|
// 设置基本字段
|
ExerciseGroup group = new ExerciseGroup();
|
TraceUtils.setCreateTrace(group);
|
group.setName(interactName);
|
group.setDeleteFlag(false);
|
group.setType(ExerciseGroup.TYPE_INTERACT);
|
group.setClassId(ClientUtils.getClassId());
|
group.setOrgId(ClientUtils.getOrgId());
|
|
this.exerciseService.saveExerciseGroup(group);
|
|
// 添加组扩展表信息
|
ExerciseGroupExtend extend = new ExerciseGroupExtend();
|
extend.setGroupId(group.getGroupId());
|
extend.setExerciseTime(exerciseTime);
|
extend.setDeleteFlag(false);
|
TraceUtils.setCreateTrace(extend);
|
save(extend);
|
|
SchInteract interact = new SchInteract();
|
interact.setClassId(ClientUtils.getClassId());
|
interact.setExerciseGroupId(group.getGroupId());
|
interact.setStatus(SchInteract.STATUS_LOCK);
|
interact.setDeleteFlag(false);
|
TraceUtils.setCreateTrace(interact);
|
|
save(interact);
|
|
return new Result(true,interact.getInteractId());
|
}
|
|
/*
|
* (non-Javadoc)
|
* @see com.qxueyou.scc.school.service.IInteractService#deleteInteracts(java.lang.String[])
|
*/
|
@Override
|
public Result deleteInteracts(String[] interactIds) {
|
for(String interactId:interactIds){
|
SchInteract interact = read(SchInteract.class,interactId);
|
interact.setDeleteFlag(true);
|
TraceUtils.setUpdateTrace(interact);
|
save(interact);
|
}
|
return new Result(true);
|
}
|
|
@Override
|
public Result doStartInteracts(String[] interactIds) {// 激活
|
|
Result result = new Result(true);
|
|
for(String interactId:interactIds){
|
SchInteract interact = read(SchInteract.class,interactId);
|
if(SchInteract.STATUS_LOCK == interact.getStatus()){
|
interact.setStatus(SchInteract.STATUS_INTERACTING);
|
interact.setStartTime(new Date());
|
TraceUtils.setUpdateTrace(interact);
|
save(interact);
|
}else{
|
result = new Result(true,"只有锁定的互动才能激活");
|
}
|
}
|
|
return result;// changeStatus(interactIds,SchInteract.STATUS_INTERACTING)
|
}
|
|
@Override
|
public Result doStopInteracts(String[] interactIds) {
|
|
Result result = new Result(true);
|
|
for(String interactId:interactIds){
|
SchInteract interact = read(SchInteract.class,interactId);
|
if(SchInteract.STATUS_LOCK == interact.getStatus() || SchInteract.STATUS_INTERACTING == interact.getStatus()){
|
interact.setStatus(SchInteract.STATUS_END);
|
interact.setStopTime(new Date());
|
TraceUtils.setUpdateTrace(interact);
|
save(interact);
|
}else{
|
result = new Result(true,"只有锁定和正在互动的互动才能停用");
|
}
|
}
|
|
return result;// changeStatus(interactIds,SchInteract.STATUS_END)
|
}
|
|
/**
|
* 修改互动状态
|
* @param interactIds
|
* @param status
|
* @return
|
|
private Result changeStatus(String[] interactIds,short status,short selectStatus){
|
for(String interactId:interactIds){
|
SchInteract interact = read(SchInteract.class,interactId);
|
interact.setStatus(status);
|
TraceUtils.setUpdateTrace(interact);
|
save(interact);
|
}
|
return new Result(true);
|
}*/
|
|
/**
|
* 新增练习记录
|
* @param groupId
|
* @return
|
*/
|
public String insertExerciseRecord(String groupId,String currTitleNumber) {
|
|
ExerciseRecord record = new ExerciseRecord();
|
record.setExerciseGroupId(groupId);
|
if(StringUtils.isBlank(currTitleNumber)){
|
currTitleNumber="0";
|
}
|
record.setTitleMaxNumber(currTitleNumber);
|
record.setUserId(ClientUtils.getUserId());
|
record.setDeleteFlag(false);
|
record.setClassId(ClientUtils.getClassId());
|
record.setCollegeCourseId(ClientUtils.getCourseId());
|
record.setOrgId(ClientUtils.getOrgId());
|
record.setStatus(ExerciseRecord.STATUS_SUBMIT);
|
|
TraceUtils.setCreateTrace(record);
|
|
this.save(record);
|
|
return record.getRecordId();
|
}
|
|
/**
|
* 新增练习记录
|
* @param groupId
|
* @return
|
*/
|
public String updateExerciseRecord(ExerciseRecord record) {
|
|
TraceUtils.setUpdateTrace(record);
|
|
this.save(record);
|
|
return record.getRecordId();
|
}
|
|
/**
|
* 新增练习记录答案
|
* @return
|
*/
|
public Result insertExerciseItemAnswerU(String exerciseId,
|
String exerciseRecordId, String answers, byte corrects) {
|
String userId = ClientUtils.getUserId();
|
|
// 组装答案记录
|
ExerciseItemAnswerU answerU = new ExerciseItemAnswerU();
|
|
answerU.setExerciseItemId(exerciseId);
|
answerU.setExerciseRecordId(exerciseRecordId);
|
answerU.setAnswer(answers);
|
answerU.setCorrect(corrects);
|
answerU.setUserId(userId);
|
answerU.setDeleteFlag(false);
|
TraceUtils.setCreateTrace(answerU);
|
|
// 保存
|
this.save(answerU);
|
|
return new Result(true);
|
}
|
|
/**
|
* 更新练习记录答案
|
* @return
|
*/
|
public Result updateExerciseItemAnswerU(ExerciseItemAnswerU answerU, String answers, byte corrects) {
|
answerU.setAnswer(answers);
|
answerU.setCorrect(corrects);
|
TraceUtils.setUpdateTrace(answerU);
|
|
// 保存更新
|
this.save(answerU);
|
|
return new Result(true);
|
}
|
|
/**
|
* 操作互动练习答案记录
|
* @return
|
*/
|
@Override
|
public Result doOperInteractExerciseAnswer(String interactGroupId,
|
String exerciseId, String answers,byte corrects,String currTitleNumber) {
|
// 1.互动组 判断 是否新纪录
|
String hql = "from ExerciseRecord where deleteFlag is false "
|
+ "and exerciseGroupId=? and userId=? ";
|
|
List<ExerciseRecord> lstRecord = this.find(hql,
|
CollectionUtils.newList(interactGroupId, ClientUtils.getUserId()), ExerciseRecord.class);
|
|
// 练习记录id
|
String exerciseRecordId= "";
|
if(lstRecord.isEmpty()){
|
// 1. 没有 互动组记录 插入一条新数据
|
exerciseRecordId = this.insertExerciseRecord(interactGroupId,currTitleNumber);
|
}else{
|
// 更新题号
|
ExerciseRecord record = lstRecord.get(0);
|
record.setTitleMaxNumber(currTitleNumber);
|
updateExerciseRecord(record);
|
|
exerciseRecordId = record.getRecordId();
|
}
|
|
/*// 判断是否重复提交 已经存在 先删除 再插入
|
hql = "from ExerciseItemAnswerU where deleteFlag is false "
|
+ "and exerciseItemId=? and userId=? and exerciseRecordId=?";
|
|
List<ExerciseItemAnswerU> lstAnswerU = this.find(hql,
|
CollectionUtils.newList(exerciseId, ClientUtils.getUserId(),exerciseRecordId), ExerciseItemAnswerU.class);
|
|
// 2.已经存在 更新
|
if(!lstAnswerU.isEmpty()){
|
|
// 答案obj
|
ExerciseItemAnswerU answerU = lstAnswerU.get(0);
|
|
return updateExerciseItemAnswerU(answerU, answers, corrects);
|
}*/
|
|
// 3.不存在 插入
|
Result result = this.insertExerciseItemAnswerU(exerciseId, exerciseRecordId, answers, corrects);
|
|
return result;
|
}
|
|
/**
|
* 查询互动练习结果
|
* @param hql
|
* @param args
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
@Override
|
public List<Map<String, Object>> queryResultByInteractExer(String hql,
|
List<Object> args) {
|
|
List<Object[]> lst = this.findBySql(hql, args);
|
|
List<Map<String, Object>> resultLst = new ArrayList<Map<String, Object>>(lst.size());
|
|
Map<String, Object> resultMap = new HashMap<String, Object>(3);
|
for (Object[] obj : lst) {
|
resultMap = new HashMap<String, Object>();
|
resultMap.put("name", obj[0]);
|
resultMap.put("count", obj[1]);
|
resultMap.put("peopleCount", obj[2]);
|
resultLst.add(resultMap);
|
}
|
|
return resultLst;
|
}
|
|
/**
|
* 查询互动练习结果
|
* @param hql
|
* @param args
|
* @return
|
*/
|
@Override
|
public List<Map<String, Object>> queryResultByInteract(String hql,
|
List<Object> args) {
|
|
return interactDAO.queryResultByInteractExer(hql, args);
|
}
|
|
/**
|
* 操作互动练习答案记录
|
* @return
|
*/
|
@Override
|
public Result doOperInteractExerciseAnswerNew(
|
InteractResultData resultData) {
|
|
String exerciseGroupId = resultData.getExerciseGroupId();
|
String currTitleNumber = resultData.getCurrTitleNum();
|
|
// 1.互动组 判断 是否新纪录
|
String hql = "from ExerciseRecord where deleteFlag is false "
|
+ "and exerciseGroupId=? and userId=? ";
|
|
List<ExerciseRecord> lstRecord = this.find(hql,
|
CollectionUtils.newList(exerciseGroupId, ClientUtils.getUserId()), ExerciseRecord.class);
|
|
// 练习记录id
|
String exerciseRecordId= "";
|
if(lstRecord.isEmpty()){
|
// 1. 没有 互动组记录 插入一条新数据
|
exerciseRecordId = this.insertExerciseRecord(exerciseGroupId,currTitleNumber);
|
}else{
|
// 更新题号
|
ExerciseRecord record = lstRecord.get(0);
|
record.setTitleMaxNumber(currTitleNumber);
|
record.setStatus(ExerciseRecord.STATUS_SUBMIT);
|
|
this.updateExerciseRecord(record);
|
|
exerciseRecordId = record.getRecordId();
|
}
|
|
|
// 2.保存答案
|
this.saveInteractExerciseAnswerBatch(resultData.getItems(), exerciseRecordId);
|
|
|
return new Result(true);
|
}
|
|
/**
|
* 批量保存互动答案
|
* @param resultData
|
* @param exerciseRecordId
|
* @return
|
*/
|
private Result saveInteractExerciseAnswerBatch(List<InterateAnswer> lstAnswers,
|
String exerciseRecordId){
|
String userId = ClientUtils.getUserId();
|
List<ExerciseItemAnswerU> lstAnswerU = new ArrayList<ExerciseItemAnswerU>(lstAnswers.size());
|
ExerciseItemAnswerU answerU = null;
|
for(InterateAnswer answer:lstAnswers){
|
answerU = new ExerciseItemAnswerU();
|
|
answerU.setExerciseItemId(answer.getExerciseId());
|
answerU.setExerciseRecordId(exerciseRecordId);
|
answerU.setAnswer(answer.getAnswer());
|
answerU.setCorrect(Byte.valueOf(answer.getCorrect()));
|
answerU.setUserId(userId);
|
answerU.setDeleteFlag(false);
|
TraceUtils.setCreateTrace(answerU);
|
|
lstAnswerU.add(answerU);
|
}
|
|
// 保存结果
|
this.saveOrUpdateAll(lstAnswerU);
|
|
return new Result(true);
|
}
|
|
@Override
|
public Result doSubmitInteractResult(String interactGroupId) {
|
|
|
// 1.互动组 判断 是否新纪录
|
String hql = "from ExerciseRecord where deleteFlag is false "
|
+ "and exerciseGroupId=? and userId=? ";
|
|
List<ExerciseRecord> lstRecord = this.find(hql,
|
CollectionUtils.newList(interactGroupId, ClientUtils.getUserId()), ExerciseRecord.class);
|
|
// 练习记录id
|
if(lstRecord.isEmpty()){
|
// 1. 没有 互动组记录 插入一条新数据
|
this.insertExerciseRecord(interactGroupId,null);
|
}else{
|
// 更新题号
|
ExerciseRecord record = lstRecord.get(0);
|
|
record.setStatus(ExerciseRecord.STATUS_SUBMIT);
|
|
this.updateExerciseRecord(record);
|
}
|
|
return new Result(true);
|
}
|
|
}
|
