package cn.ksource.web.service.record;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.web.Constants;
|
import cn.ksource.web.interfacee.InterfaceFacade;
|
|
@SuppressWarnings("unchecked")
|
@Service("scoreService")
|
public class ScoreServiceImpl implements ScoreService {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Autowired
|
private InterfaceFacade interfaceFacade;
|
|
@Override
|
public void addScore(String userId, String scoreKey) {
|
|
Map dic = interfaceFacade.getDataDictionaryByKey(scoreKey);
|
String reason = ConvertUtil.obj2StrBlank(dic.get("BEIZ"));
|
int addCount = ConvertUtil.obj2Int(dic.get("DATAVALUE"));
|
|
String scoreRecord = "INSERT INTO NS_SCORE_RECODE(ID,MEMBER_ID,REASON,SCORE_NUM,ADD_TIME,TYPE) VALUES (:id,:userId,:reason,:addCount,:addTime,1)";
|
String addScoreSql = "UPDATE NS_MEMBER SET SCORE_NUM = SCORE_NUM + :addCount WHERE ID = :userId";
|
Map paramMap = new HashMap();
|
paramMap.put("id", StringUtil.getUUID());
|
paramMap.put("userId", userId);
|
paramMap.put("reason", reason);
|
paramMap.put("addCount", addCount);
|
paramMap.put("addTime", DateUtil.getCurrentDate14());
|
|
baseDao.execute(scoreRecord, paramMap);
|
baseDao.execute(addScoreSql, paramMap);
|
}
|
|
|
|
@Override
|
public void reduceScore(String userId, String reason, int reduceCount) {
|
String scoreRecord = "INSERT INTO NS_SCORE_RECODE(ID,MEMBER_ID,REASON,SCORE_NUM,ADD_TIME,TYPE) VALUES (:id,:userId,:reason,:reduceCount,:addTime,2)";
|
String addScoreSql = "UPDATE NS_MEMBER SET SCORE_NUM = SCORE_NUM - :reduceCount WHERE ID = :userId";
|
Map paramMap = new HashMap();
|
paramMap.put("id", StringUtil.getUUID());
|
paramMap.put("userId", userId);
|
paramMap.put("reason", reason);
|
paramMap.put("reduceCount", reduceCount);
|
paramMap.put("addTime", DateUtil.getCurrentDate14());
|
|
baseDao.execute(scoreRecord, paramMap);
|
baseDao.execute(addScoreSql, paramMap);
|
}
|
|
|
|
|
|
|
|
}
|