package com.qxueyou.scc.exercise.service.impl;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.qxueyou.scc.exercise.service.IExerciseVerService;
|
|
/*import com.qxueyou.scc.base.model.Constants;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.ICacheService;
|
import com.qxueyou.scc.exercise.model.ExerciseSubmitAnswerData;
|
import com.qxueyou.scc.exercise.service.IExerciseVerService;
|
import com.qxueyou.scc.msg.model.Message;*/
|
|
/**
|
* 练习题目全站统计 个人统计
|
* @author zhiyong
|
*
|
*/
|
@Service("ExerciseItemStatisticsDealService")
|
public class ExerciseItemStatisticsDealService{
|
|
// /** 缓存service */
|
// @Autowired
|
// ICacheService cacheService;
|
|
/** 练习接口service */
|
@Autowired
|
IExerciseVerService exerciseVerService;
|
|
@SuppressWarnings("unused")
|
private static final Logger log = LogManager.getLogger("ExerciseItemStatisticsDealService");
|
|
// @PostConstruct
|
// void init() {
|
//
|
// CommonONSConsumer.registerHandler("USER_EXER_ITEM_STATIS", "ExerciseItemStatisticsDealService");
|
//
|
// }
|
|
// @Override
|
// public void doHandle(Message msg, ConsumeContext context) {
|
// try {
|
// String userId = msg.getUserProperties("userId");
|
// String userName = msg.getUserProperties("userName");
|
// String currTime = msg.getUserProperties("currTime");
|
// String exerciseGroupId = msg.getUserProperties("groupId");
|
//
|
//
|
// String key = Constants.EXER_ITEM_STATISTICAL_CACHE_KEY
|
// + userId + exerciseGroupId + currTime;
|
//
|
// // 获取答案集合
|
// ExerciseSubmitAnswerData answerData = cacheService.get(key, ExerciseSubmitAnswerData.class);
|
// //log.error("练习个人全站统计开始---------exerItemIdMap="+exerItemIdMap);
|
// if(answerData == null){
|
// return;
|
// }
|
// Result result = exerciseVerService.doStatisUserExerciseItemData(userId, userName, answerData);
|
//
|
// if(result.isSuccess()){
|
// cacheService.delete(key);
|
// }
|
//
|
// } catch (Exception e) {
|
//
|
// log.error("更新用户练习个人统计全站统计数据失败:" + e, e);
|
//
|
// throw e;
|
// }
|
// }
|
|
|
|
}
|
