微信抽奖 代码提交

@@ -60,7 +60,6 @@ public class RedisCache {
 				log.error("init activity sort error with activityId {}", act.getId(), e);
 				log.error("init activity sort error with activityId {}", act.getId(), e);
 			}
 			}
 		}
 		}
-		
 	}
 	}
 	
 	
 	/**
 	/**

@@ -29,6 +29,8 @@ import com.yoho.activity.common.cache.Cacheable;
 import com.yoho.activity.common.helper.SendCouponHelper;
 import com.yoho.activity.common.helper.SendCouponHelper;
 import com.yoho.activity.common.vo.LotteryRespData;
 import com.yoho.activity.common.vo.LotteryRespData;
 import com.yoho.activity.service.ILotteryService;
 import com.yoho.activity.service.ILotteryService;
+import com.yoho.core.redis.YHRedisTemplate;
+import com.yoho.core.redis.YHValueOperations;
 import com.yoho.error.exception.ServiceException;
 import com.yoho.error.exception.ServiceException;
 import com.yoho.lottery.dal.LotteryMapper;
 import com.yoho.lottery.dal.LotteryMapper;
 import com.yoho.lottery.dal.LotteryRecordMapper;
 import com.yoho.lottery.dal.LotteryRecordMapper;
@@ -74,7 +76,15 @@ public class LotteryServiceImpl implements ILotteryService , ApplicationContextA
 	@Autowired
 	@Autowired
 	private CacheAop cacheAop;
 	private CacheAop cacheAop;
 	
 	
+	@Resource(name = "yhValueOperations")
+	private YHValueOperations<String, String> yhValueOperations;
+
+	@Resource(name = "yhRedisTemplate")
+	private YHRedisTemplate<String, String> yhRedisTemplate;
+	
 	private ILotteryService lotteryService;
 	private ILotteryService lotteryService;
+	
+	
 
 
 	@Override
 	@Override
 	@Cacheable(expireTime = CacheKeyAndTime.LOTTERY_INTO)
 	@Cacheable(expireTime = CacheKeyAndTime.LOTTERY_INTO)
@@ -145,21 +155,11 @@ public class LotteryServiceImpl implements ILotteryService , ApplicationContextA
 	@Override
 	@Override
 	public LotteryRespData lucky(Integer lotteryId, Integer userId, String orderCode) {
 	public LotteryRespData lucky(Integer lotteryId, Integer userId, String orderCode) {
 		logger.info("用户{}的订单{}进行抽奖！", userId, orderCode);
 		logger.info("用户{}的订单{}进行抽奖！", userId, orderCode);
-		// 已抽奖检查
-		LotteryRespData orderLotteryState = getOrderLotteryState(lotteryId, userId, null);
-		Map<String, LotteryRecord> recordMap = orderLotteryState.getLotteryRecordMap();
-		if (recordMap.containsKey(orderCode)) {
-			logger.info("用户{}的订单{}不符合抽奖条件！", userId, orderCode);
-			return orderLotteryState;
-		}
-
-		// 本活动中奖次数
-		// int lotteryCount = lotteryRecordMapper.selectUserLotteryPrizeCount(lotteryId, userId, userId % 10);
-		// 只能中一次
-		if (recordMap.size() > 0) {
-			logger.info("用户{}的订单{}已经中过奖！", userId, orderCode);
-			return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
+		boolean isIn = yhValueOperations.setIfAbsent(userId.toString(), "IN");
+		if(!isIn) {
+			logger.info("用户{}的抽奖不能多个客户端一起抽奖！", userId);
 		}
 		}
+		
 
 
 		// 查询抽奖统计信息
 		// 查询抽奖统计信息
 		/*List<LotteryPrizeInfo> lotteryPrizeInfo = lotteryRecordMapper.selectLotteryPrizeInfo(lotteryId, userId % 10);
 		/*List<LotteryPrizeInfo> lotteryPrizeInfo = lotteryRecordMapper.selectLotteryPrizeInfo(lotteryId, userId % 10);
@@ -169,77 +169,86 @@ public class LotteryServiceImpl implements ILotteryService , ApplicationContextA
 		}*/
 		}*/
 		
 		
 
 
-		// 查询奖品总数信息
-		LotteryRespData lotteryInfo =  lotteryService.getLotteryInfo(lotteryId);
-		List<Prize> prizeList = lotteryInfo.getPrizes();
-		Map<Integer, Integer> allMap = new HashMap<>();
-		for (Prize p : prizeList) {
-			allMap.put(p.getId(), p.getTotal());
-		}
-		/*
-		// 奖品剩余计算
-		Map<Integer, Integer> remainMap = new HashMap<>();
-		for (Integer prizeId : allMap.keySet()) {
-			Integer all = allMap.get(prizeId);
-			Integer used = usedMap.get(prizeId);
-			if (used == null) {
-				used = 0;
+		try {
+			// 已抽奖检查
+			LotteryRespData orderLotteryState = getOrderLotteryState(lotteryId, userId, null);
+			Map<String, LotteryRecord> recordMap = orderLotteryState.getLotteryRecordMap();
+			if (recordMap.containsKey(orderCode)) {
+				logger.info("用户{}的订单{}不符合抽奖条件！", userId, orderCode);
+				return orderLotteryState;
 			}
 			}
-			remainMap.put(prizeId, all - used);
-		}*/
-
-		// 随机抽取一个
-		Integer prizeId = selectOne(allMap);
-		logger.info("用户{}的订单{}抽到奖项{}！", userId, orderCode, prizeId);
-		
-		// 未抽到
-		if (prizeId == null) {
-			return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
-		}
-		
-		Prize prize = null;
-		for(Prize p : prizeList) {
-			if(p.getId().equals(prizeId)) {
-				prize = p;
+			// 本活动中奖次数
+			// int lotteryCount = lotteryRecordMapper.selectUserLotteryPrizeCount(lotteryId, userId, userId % 10);
+			// 只能中一次
+			if (recordMap.size() > 0) {
+				logger.info("用户{}的订单{}已经中过奖！", userId, orderCode);
+				return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
 			}
 			}
-		}
-		if (prize == null) {
-			logger.warn("错误的奖品id：活动id{} 奖品id{}", lotteryId, prizeId);
-			return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
-		}
-		
-		int update = 0;
-		if (prize.getRemain() > 0) {
-			// 更新剩余奖品
-			update = prizeMapper.subtractPrize(prizeId);
-		}
-
-		// 奖品已经抽完
-		if (update == 0) {
-			logger.info("用户{}的订单{}抽到奖项{}，该奖项剩余量为0！", userId, orderCode, prizeId);
-			try {
-				cacheAop.clearCache(LotteryServiceImpl.class.getMethod("getLotteryInfo", Integer.class),
-						new Object[] { lotteryId });
-			} catch (Exception e) {
-				logger.warn("清除LotteryServiceImpl.getLotteryInfo lotteryId={}错误", lotteryId);
+			// 查询奖品总数信息
+			LotteryRespData lotteryInfo = lotteryService.getLotteryInfo(lotteryId);
+			List<Prize> prizeList = lotteryInfo.getPrizes();
+			Map<Integer, Integer> allMap = new HashMap<>();
+			for (Prize p : prizeList) {
+				allMap.put(p.getId(), p.getTotal());
 			}
 			}
-			return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
-		}
-		
-		LotteryRespData data = savePrizeAndGetResp(lotteryId, userId, orderCode, prizeId);
-		/*Prize prize = prizeMapper.selectByPrimaryKey(prizeId);
-		if (!hasRealPrize(prize)) {
-			logger.info("用户{}的订单{}抽到奖项{}，该奖项为nothing！", userId, orderCode, prizeId);
-			data.setOrderLotteryCode(STATE_USE_NO_PRIZE);
-			data.setOrderLotteryMessage(MSG_NO_PRIZE);
+			/*
+			// 奖品剩余计算
+			Map<Integer, Integer> remainMap = new HashMap<>();
+			for (Integer prizeId : allMap.keySet()) {
+				Integer all = allMap.get(prizeId);
+				Integer used = usedMap.get(prizeId);
+				if (used == null) {
+					used = 0;
+				}
+				remainMap.put(prizeId, all - used);
+			}*/
+			// 随机抽取一个
+			Integer prizeId = selectOne(allMap);
+			logger.info("用户{}的订单{}抽到奖项{}！", userId, orderCode, prizeId);
+			// 未抽到
+			if (prizeId == null) {
+				return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
+			}
+			Prize prize = null;
+			for (Prize p : prizeList) {
+				if (p.getId().equals(prizeId)) {
+					prize = p;
+				}
+			}
+			if (prize == null) {
+				logger.warn("错误的奖品id：活动id{} 奖品id{}", lotteryId, prizeId);
+				return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
+			}
+			int update = 0;
+			if (prize.getRemain() > 0) {
+				// 更新剩余奖品
+				update = prizeMapper.subtractPrize(prizeId);
+			}
+			// 奖品已经抽完
+			if (update == 0) {
+				logger.info("用户{}的订单{}抽到奖项{}，该奖项剩余量为0！", userId, orderCode, prizeId);
+				try {
+					cacheAop.clearCache(LotteryServiceImpl.class.getMethod("getLotteryInfo", Integer.class),
+							new Object[] { lotteryId });
+				} catch (Exception e) {
+					logger.warn("清除LotteryServiceImpl.getLotteryInfo lotteryId={}错误", lotteryId);
+				}
+				return savePrizeAndGetResp(lotteryId, userId, orderCode, null);
+			}
+			LotteryRespData data = savePrizeAndGetResp(lotteryId, userId, orderCode, prizeId);
+			/*Prize prize = prizeMapper.selectByPrimaryKey(prizeId);
+			if (!hasRealPrize(prize)) {
+				logger.info("用户{}的订单{}抽到奖项{}，该奖项为nothing！", userId, orderCode, prizeId);
+				data.setOrderLotteryCode(STATE_USE_NO_PRIZE);
+				data.setOrderLotteryMessage(MSG_NO_PRIZE);
+				return data;
+			}*/
+			data.setPrize(prize);
+			givePrize(userId, orderCode, prize);
 			return data;
 			return data;
-		}*/
-
-		data.setPrize(prize);
-
-		givePrize(userId, orderCode, prize);
-
-		return data;
+		} finally {
+			yhRedisTemplate.delete(userId.toString());
+		}
 	}
 	}
 	
 	
 	@Cacheable(expireTime = CacheKeyAndTime.LOTTERY_USER_LOTTERY)
 	@Cacheable(expireTime = CacheKeyAndTime.LOTTERY_USER_LOTTERY)