|
@ -45,7 +45,7 @@ import java.util.*;
|
|
|
public class QuestionnaireService extends BaseService {
|
|
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(QuestionnaireService.class);
|
|
|
static Object obj = new Object();
|
|
|
|
|
|
@Autowired
|
|
|
private ElasticFactory elasticFactory;
|
|
|
@Autowired
|
|
@ -154,7 +154,7 @@ public class QuestionnaireService extends BaseService {
|
|
|
//如果抽中的奖品对象为空,则直接返回未中奖
|
|
|
if(questionnairePrize != null){
|
|
|
try {
|
|
|
questionnaireWinning.setWinning(1);
|
|
|
questionnaireWinning.setWinning(1);//---中奖
|
|
|
questionnaireWinning.setPrizeType(questionnairePrize.getType());
|
|
|
questionnaireWinning.setPrizeName(questionnairePrize.getPrizeName());
|
|
|
questionnaireWinning.setPrizeCode(questionnairePrize.getPrizeCode());
|
|
@ -168,7 +168,7 @@ public class QuestionnaireService extends BaseService {
|
|
|
String prizejson = JSON.toJSONString(questionnairePrize);
|
|
|
redisTemplate.opsForValue().set("questionnaire:prize:code:" + questionnairePrize.getCode(), prizejson);
|
|
|
|
|
|
questionnaireWinning.setWinning(0);
|
|
|
questionnaireWinning.setWinning(0);//--未中奖
|
|
|
questionnaireWinning.setPrizeType(0);
|
|
|
questionnaireWinning.setPrizeName("");
|
|
|
questionnaireWinning.setPrizeCode("");
|
|
@ -194,17 +194,21 @@ public class QuestionnaireService extends BaseService {
|
|
|
return result;
|
|
|
}
|
|
|
}else{
|
|
|
questionnaireWinning.setWinning(0);//未中奖
|
|
|
questionnaireWinning.setWinning(0);//--未中奖
|
|
|
}
|
|
|
}else{
|
|
|
questionnaireWinning.setWinning(0);//未中奖
|
|
|
questionnaireWinning.setWinning(0);//--未中奖
|
|
|
}
|
|
|
one = doToESDO(questionnaireWinning);
|
|
|
result.add(one);
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
//中奖对象转成ES对象
|
|
|
/**
|
|
|
* 中奖对象转成ES对象
|
|
|
* @param questionnaireWinning
|
|
|
* @return
|
|
|
*/
|
|
|
private QuestionnaireWinningESDO doToESDO(QuestionnaireWinning questionnaireWinning){
|
|
|
QuestionnaireWinningESDO questionnaireWinningESDO = new QuestionnaireWinningESDO();
|
|
|
questionnaireWinningESDO.setCode(questionnaireWinning.getCode());
|
|
@ -230,19 +234,19 @@ public class QuestionnaireService extends BaseService {
|
|
|
*/
|
|
|
synchronized public QuestionnairePrize getQuestionnairePrizeFromRedis(){
|
|
|
try {
|
|
|
QuestionnairePrize questionnairePrize = new QuestionnairePrize();
|
|
|
Set<String> exists = redisTemplate.keys("questionnaire:prize:code:*");
|
|
|
if(exists.size() > 0){
|
|
|
String key = "";
|
|
|
String prizeJsonStr = "";
|
|
|
for (String setkey :exists) {
|
|
|
if(StringUtils.isNotBlank(setkey)){
|
|
|
key = setkey;
|
|
|
break;
|
|
|
}
|
|
|
QuestionnairePrize questionnairePrize = new QuestionnairePrize();
|
|
|
Set<String> exists = redisTemplate.keys("questionnaire:prize:code:*");
|
|
|
if(exists.size() > 0){
|
|
|
String key = "";
|
|
|
String prizeJsonStr = "";
|
|
|
for (String setkey :exists) {
|
|
|
if(StringUtils.isNotBlank(setkey)){
|
|
|
key = setkey;
|
|
|
break;
|
|
|
}
|
|
|
if(StringUtils.isNotBlank(key)){
|
|
|
prizeJsonStr = redisTemplate.opsForValue().get(key);
|
|
|
}
|
|
|
if(StringUtils.isNotBlank(key)){
|
|
|
prizeJsonStr = redisTemplate.opsForValue().get(key);
|
|
|
// JSONObject jsonObject = JSONObject.parseObject(prizeJsonStr);
|
|
|
// questionnairePrize.setUsed(jsonObject.getInteger("used"));
|
|
|
// questionnairePrize.setAddress(jsonObject.getString("address"));
|
|
@ -253,14 +257,14 @@ public class QuestionnaireService extends BaseService {
|
|
|
// questionnairePrize.setValidity(jsonObject.getDate("validity"));
|
|
|
// questionnairePrize.setCreateTime(jsonObject.getDate("createTime"));
|
|
|
// questionnairePrize.setUpdateTime(jsonObject.getDate("updateTime"));
|
|
|
questionnairePrize = JSON.parseObject(prizeJsonStr,QuestionnairePrize.class);
|
|
|
//捞取完之后,从redis缓存中删掉
|
|
|
redisTemplate.delete(key);
|
|
|
return questionnairePrize;
|
|
|
}
|
|
|
}else{
|
|
|
return null;
|
|
|
questionnairePrize = JSON.parseObject(prizeJsonStr,QuestionnairePrize.class);
|
|
|
//捞取完之后,从redis缓存中删掉
|
|
|
redisTemplate.delete(key);
|
|
|
return questionnairePrize;
|
|
|
}
|
|
|
}else{
|
|
|
return null;
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
return null;
|