回访问卷抽奖同步代码提交

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/service/questionnaire/QuestionnaireService.java

@@ -114,9 +114,6 @@ public class QuestionnaireService extends BaseService {
	 */
	public List<QuestionnaireWinningESDO> questionnaireLottery(QuestionnaireUsers questionnaireUsers)throws Exception{
		
		List<QuestionnaireWinningESDO> result = new ArrayList<>();
		QuestionnaireWinningESDO one = new QuestionnaireWinningESDO();
		
		if(StringUtils.isBlank(questionnaireUsers.getIdcard()) || "undefined".equals(questionnaireUsers.getIdcard())){
			throw new Exception("身份证号为空或者异常："+questionnaireUsers.getIdcard());
		}
@@ -125,6 +122,10 @@ public class QuestionnaireService extends BaseService {
			throw new Exception("openid为空或者异常："+questionnaireUsers.getIdcard());
		}
		
		List<QuestionnaireWinningESDO> result = new ArrayList<>();
		QuestionnaireWinningESDO one = new QuestionnaireWinningESDO();
		
		// 从redis获取剩余奖品数量
		// 判断奖品池的奖品是否已经发完
		Integer prizeCount = gerPrizeCountFromRedis();
@@ -188,7 +189,7 @@ public class QuestionnaireService extends BaseService {
						}
						one = doToESDO(questionnaireWinning);
						result.add(one);
						//将中奖记录信息缓存到ES
						//将已中奖记录信息缓存到ES
						esQuestionnaireWinningESData(result);
						logger.info("抽奖：居民身份证:"+questionnaireUsers.getIdcard()+",openid="+questionnaireUsers.getOpenid()+",结果04：中奖结果成功保存到ES,奖品CODE:"+questionnairePrize.getCode());
						return result;
@@ -211,6 +212,8 @@ public class QuestionnaireService extends BaseService {
		}
		one = doToESDO(questionnaireWinning);
		result.add(one);
		//将未中奖记录信息缓存到ES
		esQuestionnaireWinningESData(result);
		return result;
	}
	
@@ -276,6 +279,7 @@ public class QuestionnaireService extends BaseService {
				return null;
			}
		}catch (Exception e){
			logger.info("从redis奖品池捞取一个奖品出错，错误信息："+e.getMessage());
		    e.printStackTrace();
			return null;
		}