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); } }