From 573c491b4a1ba60e12a5678a01c1546c0077c1ee Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 30 七月 2019 09:07:42 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java |  870 +++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 719 insertions(+), 151 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
index f4effdd..9fe5b0c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
@@ -11,11 +11,13 @@
 
 import javax.annotation.Resource;
 
+import org.springframework.core.task.TaskExecutor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.yeshi.utils.DateUtil;
 
 import com.yeshi.fanli.dao.mybatis.user.UserSystemCouponMapper;
+import com.yeshi.fanli.entity.bus.user.DeviceLotteryRecord;
 import com.yeshi.fanli.entity.bus.user.HongBaoV2;
 import com.yeshi.fanli.entity.bus.user.Order;
 import com.yeshi.fanli.entity.bus.user.UserInfo;
@@ -27,6 +29,8 @@
 import com.yeshi.fanli.entity.order.CommonOrder;
 import com.yeshi.fanli.entity.system.SystemCoupon;
 import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
+import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
+import com.yeshi.fanli.exception.user.UserInfoExtraException;
 import com.yeshi.fanli.exception.user.UserSystemCouponException;
 import com.yeshi.fanli.log.LogHelper;
 import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
@@ -36,10 +40,14 @@
 import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
 import com.yeshi.fanli.service.inter.msg.UserMoneyMsgNotificationService;
 import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
+import com.yeshi.fanli.service.inter.order.CommonOrderCountService;
 import com.yeshi.fanli.service.inter.order.CommonOrderService;
 import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
 import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService;
 import com.yeshi.fanli.service.inter.order.OrderService;
+import com.yeshi.fanli.service.inter.push.PushCouponRecordService;
+import com.yeshi.fanli.service.inter.push.PushCouponService;
+import com.yeshi.fanli.service.inter.user.DeviceLotteryRecordService;
 import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
 import com.yeshi.fanli.service.inter.user.UserInfoService;
 import com.yeshi.fanli.service.inter.user.UserMoneyDetailService;
@@ -47,7 +55,9 @@
 import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
 import com.yeshi.fanli.util.Constant;
 import com.yeshi.fanli.util.MoneyBigDecimalUtil;
+import com.yeshi.fanli.util.RedisManager;
 import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
+import com.yeshi.fanli.util.taobao.TaoBaoUtil;
 import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
 import com.yeshi.fanli.vo.order.CommonOrderVO;
 import com.yeshi.fanli.vo.user.UserSystemCouponRecordVO;
@@ -57,6 +67,12 @@
 
 @Service
 public class UserSystemCouponServiceImpl implements UserSystemCouponService {
+
+	@Resource(name = "taskExecutor")
+	private TaskExecutor executor;
+
+	@Resource
+	private RedisManager redisManager;
 
 	@Resource
 	private UserSystemCouponMapper userSystemCouponMapper;
@@ -96,20 +112,29 @@
 
 	@Resource
 	private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
-	
+
 	@Resource
 	private UserInfoExtraService userInfoExtraService;
-	
+
 	@Resource
 	private ThreeSaleSerivce threeSaleSerivce;
-	
+
 	@Resource
 	private UserOtherMsgNotificationService userOtherMsgNotificationService;
+
+	@Resource
+	private DeviceLotteryRecordService deviceLotteryRecordService;
+
+	@Resource
+	private CommonOrderCountService commonOrderCountService;
 	
-
-	// 鍒稿け鏁堝浘鐗�
-	public final static String PIC_INVALID = "http://192.168.1.200/icon/mian_invalid.png";
-
+	@Resource
+	private PushCouponService pushCouponService;
+	
+	@Resource
+	private PushCouponRecordService pushCouponRecordService;
+	
+	
 	@Override
 	public int insertSelective(UserSystemCoupon record) {
 		return userSystemCouponMapper.insertSelective(record);
@@ -141,22 +166,38 @@
 	}
 	
 	@Override
+	public int countTodatyUserCouponBySource(Long uid, String source) {
+		return userSystemCouponMapper.countTodatyUserCouponBySource(uid, source);
+	}
+	
+	@Override
 	public long countUserCouponList(Long uid) {
 		return userSystemCouponMapper.countUserCouponList(uid);
 	}
 
 	@Override
-	public void insertUserCoupon(Long uid, String couponType,String source)throws UserSystemCouponException,Exception{
-		
+	@Transactional
+	public void insertUserCoupon(Long uid, String couponType, String source)
+			throws UserSystemCouponException, Exception {
+
 		if (couponType == null || uid == null) {
 			throw new UserSystemCouponException(1, "鍙傛暟涓嶆纭�");
-		} 
+		}
+
+		SystemCoupon coupon = null;
+		if (couponType.equals(CouponTypeEnum.welfareFreeCoupon.name())) {
+			// 绂忓埄鍏嶅崟鍒�
+			coupon = systemCouponService.getCouponByType(couponType);
+		} else if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) {
+			// 闅忔満濂栧姳鍒�
+			randomRewardCoupon(1, uid, source);
+			return;
+		}
 		
-		SystemCoupon coupon= systemCouponService.getCouponByType(couponType);
 		if (coupon == null) {
 			throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉姝g‘");
-		} 
-		
+		}
+
 		int stateActivated = 1;
 		if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
 			// 绂忓埄鍒哥姸鎬�
@@ -166,12 +207,13 @@
 				stateActivated = 0;
 			}
 		}
-		
+
 		// 缁撴潫鏃ユ湡
-		String endDay = DateUtil.plusDay(coupon.getExpiryDay(), new Date());
+		// 浠婂ぉ鍦ㄥ唴  鍑忓幓涓�澶�
+		String endDay = DateUtil.plusDay(coupon.getExpiryDay() - 1, new Date());
 		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
 		Date endTime = format.parse(endDay);
-		
+
 		UserSystemCoupon userCoupon = new UserSystemCoupon();
 		userCoupon.setUid(uid);
 		userCoupon.setSource(source);
@@ -184,19 +226,40 @@
 		userCoupon.setUpdateTime(new Date());
 		// 鎻掑叆鏁版嵁搴�
 		insertSelective(userCoupon);
-		
-		
+
+		executor.execute(new Runnable() {
+			@Override
+			public void run() {
+				UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
+				// 娣诲姞涓�鏉℃秷鎭�
+				if (userInfoExtra != null) {
+					if (userInfoExtra.getCouponNews() == null) {
+						userInfoExtra.setCouponNews(1);
+					} else {
+						userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);
+					}
+
+					try {
+						userInfoExtraService.saveUserInfoExtra(userInfoExtra);
+					} catch (UserInfoExtraException e) {
+						e.printStackTrace();
+					}
+				}
+
+			}
+		});
+
 		// 娑堟伅鎺ㄩ��
 		try {
-			if (coupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
+			if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
 				userOtherMsgNotificationService.welfareCouponGet(userCoupon);
-			} else if (coupon.getType() != CouponTypeEnum.freeCoupon) {
+			} else if (coupon.getType() == CouponTypeEnum.freeCoupon) {
 				userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);
-			} else if (coupon.getType() != CouponTypeEnum.rebatePercentCoupon) {
-				userOtherMsgNotificationService.rewardCouponGet(userCoupon);
+			} else if (coupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
+				userOtherMsgNotificationService.rewardCouponGet(userCoupon, coupon.getPercent().intValue());
 			}
-			
-		} catch(Exception e) {
+
+		} catch (Exception e) {
 			try {
 				LogHelper.errorDetailInfo(e);
 			} catch (Exception e1) {
@@ -205,20 +268,19 @@
 		}
 	}
 
-	
-	
+	@Transactional
 	@Override
-	public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid)
+	public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid, boolean changeJump)
 			throws UserSystemCouponException, Exception {
 
 		if (uid == null) {
 			return null;
 		}
-		
+
 		// 鏇存柊杩囨湡鍒�
 		updateCounponInvalid(uid);
 		// 閫�鍥炲埜
-		sendBackCoupon(uid);
+		sendBackTimeOutCoupon(uid);
 		
 		List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid);
 		if (listVO == null || listVO.size() == 0) {
@@ -226,7 +288,7 @@
 		}
 
 		// 鏁版嵁缁勭粐
-		listDataFactory(listVO, uid);
+		listDataFactory(listVO, uid, changeJump);
 
 		return listVO;
 	}
@@ -236,8 +298,14 @@
 	 * 
 	 * @param listVO
 	 */
-	public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid) throws Exception{
+	public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid, boolean changeJump) throws Exception {
 
+		String inviteCode = null;
+		UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
+		if (userInfoExtra != null) {
+			inviteCode = userInfoExtra.getInviteCode();
+		}
+		
 		for (UserSystemCouponVO userCouponVO : listVO) {
 
 			SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();
@@ -256,43 +324,43 @@
 			userCouponVO.setCouponPicture(systemCoupon.getPicture());
 			userCouponVO.setCouponEffect(systemCoupon.getEffect());
 			userCouponVO.setCouponRule(systemCoupon.getRule());
+			userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());
 
 			// 浣跨敤鐘舵��
 			Integer state = userCouponVO.getState();
 
+			// 鍒哥被鍨�
+			CouponTypeEnum type = systemCoupon.getType();
+
 			// 鎸夐挳璺宠浆
 			Map<String, Object> jumpBtn = null;
-			
+
 			Integer stateActivated = userCouponVO.getStateActivated();
-			
+
 			if (stateActivated == null || stateActivated == 0) {
 				// 鏄剧ず瑙勫垯
 				userCouponVO.setCouponRule(systemCoupon.getRemark());
 				userCouponVO.setCouponEffect("寰呮縺娲�");
-
 				// 鐘舵�佹湭婵�娲� -涓旀湭琚娇鐢�
 				if (UserSystemCoupon.STATE_CAN_USE == state) {
 					userCouponVO.setState(0);
 				}
 
 				jumpBtn = new HashMap<String, Object>();
-				Map<String, Object> jumpLink = new HashMap<String, Object>();
 				
-				UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
-				
-				// 閭�璇烽槦鍛樼晫闈�
-				if (userInfoExtra != null && userInfoExtra.getInviteCode() != null
-						&& userInfoExtra.getInviteCode().trim().length() > 0) {
-					// 閭�璇锋縺娲绘垚鍔熺晫闈�
-					jumpLink.put("url", configService.get("invite_activation_success_url") + "?alert=true");
+				// 绂忓埄鍒搁渶瑕佹縺娲荤晫闈�
+				if (!changeJump) {
+					jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));
 				} else {
-					// 婵�娲婚個璇风爜鐣岄潰
-					jumpLink.put("url", configService.get("invite_activation_url"));
+					if (inviteCode != null && inviteCode.trim().length() > 0) {
+						// 閭�璇峰ソ鍙嬬晫闈�
+						jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_friends"));
+					} else {
+						// 閭�璇锋縺娲荤晫闈�
+						jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate"));
+					}
 				}
 				
-				jumpBtn.put("params", jumpLink);
-				jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_web"));
-
 			} else if (stateActivated == 1) {
 				// 鏄剧ず瑙勫垯
 				userCouponVO.setCouponRule(systemCoupon.getRule());
@@ -300,10 +368,9 @@
 				if (UserSystemCoupon.STATE_CAN_USE == state) {
 					Map<String, Object> jumpLink = new HashMap<String, Object>();
 
-					CouponTypeEnum type = systemCoupon.getType();
 					if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type) {
 						// 鍏嶅崟鍒搞�� 绂忓埄鍏嶅崟鍒�
-						
+
 						// 鍏嶅崟鍟嗗搧鍒楄〃
 						jumpLink.put("url", configService.get("free_goods_list"));
 
@@ -313,25 +380,25 @@
 
 					} else if (CouponTypeEnum.rebatePercentCoupon == type) {
 						// 杩斿埄濂栧姳鍒�- 璺宠浆鑷宠鍗曞埌璐︾晫闈�
-						jumpLink.put("state", 2);
-						
+						jumpLink.put("state", "2");
+
 						jumpBtn = new HashMap<String, Object>();
 						jumpBtn.put("params", jumpLink);
 						// 璺宠浆璁㈠崟鍒楄〃
 						jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("orderList"));
 					}
-					
+
 				} else if (UserSystemCoupon.STATE_IN_USE == state) {
 					// 浣跨敤涓�
 					userCouponVO.setInUseExplain(configService.get("free_coupon_using-help"));
 				}
 			}
-			
+
 			// 鍒稿け鏁堝浘鐗囨浛鎹�
 			if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) {
-				userCouponVO.setCouponPicture(PIC_INVALID);
+				userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
 			}
-			
+
 			userCouponVO.setJumpBtn(jumpBtn);
 
 			String couponTerm = "鏈夋晥鏈燂細";
@@ -396,14 +463,7 @@
 			userCouponVO.setCouponName(systemCoupon.getName());
 			userCouponVO.setCouponEffect(systemCoupon.getEffect());
 			userCouponVO.setCouponRule(systemCoupon.getRule());
-
-			Integer stateActivated = userCouponVO.getStateActivated();
-			if (stateActivated == null || stateActivated == 0) {
-				userCouponVO.setCouponPicture(PIC_INVALID); // 鏈縺娲�
-				userCouponVO.setState(0);
-			} else {
-				userCouponVO.setCouponPicture(systemCoupon.getPicture());
-			}
+			userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());
 
 			int differentDays = 0;
 			String couponTerm = "鏈夋晥鏈燂細";
@@ -412,7 +472,7 @@
 			if (endTime != null && startTime != null) {
 				SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
 				couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);
-				
+
 				SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
 				differentDays = DateUtil.daysBetween(sdf2.format(new Date()), sdf2.format(endTime)) + 1;
 				if (differentDays < 0) {
@@ -425,7 +485,23 @@
 			// 鍓╀綑澶╂暟
 			Map<String, Object> remainDays = new HashMap<String, Object>();
 			remainDays.put("content", "杩樺墿" + differentDays + "澶╄繃鏈�");
-			remainDays.put("fontColor", "#F14242");
+			String remainDaysFontColor = "";
+
+			Integer stateActivated = userCouponVO.getStateActivated();
+			if (stateActivated == null || stateActivated == 0) {
+				userCouponVO.setState(0);
+				userCouponVO.setCouponEffect("寰呮縺娲�");
+				userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
+
+				remainDaysFontColor = "#CCCCCC";
+
+			} else {
+				userCouponVO.setCouponPicture(systemCoupon.getPicture());
+
+				remainDaysFontColor = "#F14242";
+			}
+
+			remainDays.put("fontColor", remainDaysFontColor);
 			userCouponVO.setRemainDays(remainDays);
 		}
 
@@ -456,17 +532,19 @@
 		return hasCoupon;
 	}
 
+	@Transactional
 	@Override
 	public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception {
+		
 		if (uid == null) {
 			throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�");
 		}
-		
+
 		// 鏇存柊杩囨湡鍒�
 		updateCounponInvalid(uid);
 		// 閫�鍥炲埜
-		sendBackCoupon(uid);
-				
+		sendBackTimeOutCoupon(uid);
+
 		// 璁㈠崟鐩稿叧鐨勫埜
 		List<SystemCoupon> couponList = systemCouponService.getOrderCouponList();
 		if (couponList == null || couponList.size() == 0) {
@@ -476,16 +554,23 @@
 		return getEnableListByCouponId(uid, 1, couponList);
 	}
 
+	@Transactional
 	@Override
-	public List<UserSystemCouponVO> getGoodsCouponList(Long uid) throws UserSystemCouponException, Exception {
+	public List<UserSystemCouponVO> getGoodsCouponList(Long uid, Long auctionId)
+			throws UserSystemCouponException, Exception {
+
 		if (uid == null) {
 			throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�");
 		}
-		
+
+		if (auctionId == null) {
+			throw new UserSystemCouponException(1, "鍟嗗搧ID涓虹┖");
+		}
+
 		// 鏇存柊杩囨湡鍒�
 		updateCounponInvalid(uid);
 		// 閫�鍥炲埜
-		sendBackCoupon(uid);
+		sendBackTimeOutCoupon(uid);
 		
 		// 鍟嗗搧鐩稿叧鐨勫埜
 		List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
@@ -493,9 +578,36 @@
 			return null;
 		}
 
-		return getEnableListByCouponId(uid, null, couponList);
+		List<UserSystemCouponVO> list = getEnableListByCouponId(uid, null, couponList);
+
+		// 鑾峰彇鍟嗗搧璇︽儏
+		TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
+		if (taoBaoGoodsBrief != null) {
+			BigDecimal quanPrice = TaoBaoUtil.getAfterUseCouplePrice(taoBaoGoodsBrief);
+
+			// 鍒稿悗浠� 澶т簬10鍏� 涓嶈兘鍏嶅崟
+			if (quanPrice.compareTo(new BigDecimal(10)) > 0) {
+				if (list != null && list.size() > 0) {
+					for (UserSystemCouponVO userCouponVO : list) {
+						// 鏄剧ず涓嶈兘浣跨敤
+						userCouponVO.setState(0);
+						userCouponVO.setCouponPicture(userCouponVO.getCouponPictureInvalid());
+
+						Map<String, Object> map = userCouponVO.getRemainDays();
+						if (map != null) {
+							map.put("fontColor", "#CCCCCC");
+						}
+						userCouponVO.setRemainDays(map);
+
+					}
+				}
+			}
+		}
+
+		return list;
 	}
 
+	@Transactional
 	@Override
 	public void useGoodsCoupon(Long uid, Long id, Long goodId) throws UserSystemCouponException, Exception {
 		if (uid == null) {
@@ -509,6 +621,16 @@
 		UserSystemCoupon userSystemCoupon = selectByPrimaryKey(id);
 		if (userSystemCoupon == null) {
 			throw new UserSystemCouponException(1, "鍒告暟鎹笉姝g‘");
+		}
+		
+		if (userSystemCoupon.getUid().longValue() != uid) {
+			throw new UserSystemCouponException(1, "涓嶅睘浜庤鐢ㄦ埛鐨勫埜");
+		}
+
+		Integer state = userSystemCoupon.getState();
+		Integer stateActivated = userSystemCoupon.getStateActivated();
+		if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated) {
+			throw new UserSystemCouponException(1, "璇ュ埜涓嶈兘琚娇鐢�");
 		}
 
 		Long couponUid = userSystemCoupon.getUid();
@@ -527,7 +649,7 @@
 				&& baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
 			throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉鍖归厤");
 		}
-		
+
 		Date date = new Date();
 		// 鏇存柊鍒镐娇鐢�
 		userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE); // 姝e湪鍖归厤
@@ -545,19 +667,19 @@
 		couponRecord.setCreateTime(date);
 		couponRecord.setUpdateTime(date);
 		userSystemCouponRecordService.insertSelective(couponRecord);
-		
+
 		// 娑堟伅鎺ㄩ��
 		try {
-			if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
-				userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon);
-			} else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
-				userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);
+			if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
+				// userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,order.get);
+			} else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {
+				// userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);
 			}
-			
-		} catch(Exception e) {
+
+		} catch (Exception e) {
 			LogHelper.errorDetailInfo(e);
 		}
-		
+
 	}
 
 	@Transactional
@@ -574,6 +696,16 @@
 			throw new UserSystemCouponException(1, "鍒镐俊鎭笉瀛樺湪");
 		}
 
+		if (userSystemCoupon.getUid().longValue() != uid) {
+			throw new UserSystemCouponException(1, "涓嶅睘浜庤鐢ㄦ埛鐨勫埜");
+		}
+
+		Integer state = userSystemCoupon.getState();
+		Integer stateActivated = userSystemCoupon.getStateActivated();
+		if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated) {
+			throw new UserSystemCouponException(1, "璇ュ埜涓嶈兘琚娇鐢�");
+		}
+
 		// 绯荤粺鍒镐俊鎭�
 		SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
 		if (systemCoupon != null && systemCoupon.getId() != null) {
@@ -587,7 +719,6 @@
 			throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉鍖归厤");
 		}
 
-		
 		if (orderNo == null || orderNo.trim().length() == 0) {
 			throw new UserSystemCouponException(1, "璁㈠崟鍙蜂笉瀛樺湪");
 		}
@@ -597,7 +728,6 @@
 		if (orderVO == null) {
 			throw new UserSystemCouponException(1, "璁㈠崟淇℃伅鑾峰彇澶辫触");
 		}
-
 
 		BigDecimal hongBao = orderVO.getHongBao();
 		// 绾㈠寘鐘舵��
@@ -663,11 +793,11 @@
 			couponRecord.setCreateTime(date);
 			couponRecord.setUpdateTime(date);
 			userSystemCouponRecordService.insertSelective(couponRecord);
-			
+
 			// 娑堟伅鎺ㄩ��
 			try {
-				userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon);
-			} catch(Exception e) {
+				userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon, hongBao, money, orderNo);
+			} catch (Exception e) {
 				LogHelper.errorDetailInfo(e);
 			}
 		}
@@ -709,29 +839,32 @@
 		}
 
 		Long uid = userSystemCoupon.getUid();
-		
-		CommonOrderVO commonOrderVO= commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(),
-				orderNo, CommonOrder.STATE_JS);
-		
+
+		CommonOrderVO commonOrderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo,
+				CommonOrder.STATE_JS);
+
 		if (commonOrderVO == null) {
 			throw new UserSystemCouponException(1, "璁㈠崟淇℃伅鑾峰彇澶辫触");
 		}
-		
+
 		// 鑾峰彇濂栧姳閲戦
-		Map<String, BigDecimal> map = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid);
+		BigDecimal couponMoney = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid);
 
 		UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO();
 		userRecordVO.setCouponMoneyState("宸插埌璐�");
 		userRecordVO.setCommonOrder(commonOrderVO);
-		userRecordVO.setCouponName("濂栧姳閲�: 楼" + map.get("couponMoney").setScale(2, BigDecimal.ROUND_DOWN));
+		userRecordVO.setCouponName("濂栧姳閲�: 楼" + couponMoney.setScale(2, BigDecimal.ROUND_DOWN));
 
 		// 姣斾緥
 		BigDecimal percent = baseCoupon.getPercent();
-		BigDecimal hongBao = map.get("totalMoney").setScale(2, BigDecimal.ROUND_DOWN);
-		userRecordVO.setCouponEffect("杩斿埄楼" + hongBao + "宸茶繑" + percent + "%");
+		BigDecimal hongBao = commonOrderVO.getHongBao();
+		if (hongBao == null) {
+			hongBao = new BigDecimal(0);
+		}
+		userRecordVO.setCouponEffect("杩斿埄楼" + hongBao.setScale(2, BigDecimal.ROUND_DOWN) + "宸茶繑" + percent + "%");
 
-		// 璺宠浆绂忓埄涓績
-		JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("welfareCore");
+		// 璧勯噾鏄庣粏
+		JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("capitalDetails");
 		Map<String, Object> jumpWelfare = new HashMap<String, Object>();
 		jumpWelfare.put("jumpDetail", welfareCore);
 		Map<String, Object> jumpparms = new HashMap<String, Object>();
@@ -798,7 +931,7 @@
 		String progressMsg = "";
 		String progressColor = "";
 		// 璺宠浆濂栧姳鍒歌鍒�
-		userRecordVO.setRuleLink(configService.get("reward_coupon_help"));
+		userRecordVO.setRuleLink(configService.get("free_coupon_help"));
 
 		// 杩涘害锛� 1 鐏拌壊 2 绾㈣壊 3 缁胯壊
 		String progressState1 = "3";
@@ -949,58 +1082,53 @@
 
 		return userRecordVO;
 	}
-	
-	
+
+	@Transactional
 	@Override
-	public void activatedWelfareFreeCoupon(Long uid) {
+	public void activatedWelfareFreeCoupon(Long uid, String fromNickName) {
+
+		LogHelper.test("鍒告縺娲�:" + uid);
 		if (uid == null) {
 			return;
 		}
 		// 绂忓埄鍏嶅崟鍒�
 		String welfareFree = CouponTypeEnum.welfareFreeCoupon.name();
-		
+
 		SystemCoupon systemCoupon = systemCouponService.getCouponByType(welfareFree);
 		if (systemCoupon == null) {
 			return;
 		}
-		// 婵�娲荤鍒╁厤鍗曞埜
-		userSystemCouponMapper.activateCouponByType(uid, systemCoupon.getId());
-	}
-	
 
-	@Override
-	public void updateCounponInvalid(Long uid) {
-		List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalid(uid);
+		// 楠岃瘉鏄惁澶辨晥
+		updateCounponInvalid(uid);
+
+		// 寰呮椿绂忓埄鍏嶅崟鍒�
+		List<UserSystemCoupon> list = userSystemCouponMapper.getCouponByTypeAndNotActivated(uid, systemCoupon.getId());
 		if (list == null || list.size() == 0) {
 			return;
 		}
-		
-		for (UserSystemCoupon userSystemCoupon: list) {
-			// 鏇存柊鍒稿凡杩囨湡
-			userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE);
-			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
-			
-			SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
-			if (systemCoupon == null) {
-				continue;
+
+		for (UserSystemCoupon userSystemCoupon : list) {
+			// 婵�娲�
+			UserSystemCoupon update = new UserSystemCoupon();
+			update.setId(userSystemCoupon.getId());
+			update.setStateActivated(1);
+			update.setUpdateTime(new Date());
+			userSystemCouponMapper.updateByPrimaryKeySelective(update);
+
+			Integer state = userSystemCoupon.getState();
+			if (UserSystemCoupon.STATE_OVERDUE == state) {
+				continue; // 宸插け鏁堜笉鍋氭秷鎭帹閫�
 			}
-			
-			SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
-			if (baseCoupon == null || baseCoupon.getId() == null) {
-				continue;
-			}
-			
+
 			// 娑堟伅鎺ㄩ��
 			try {
-				if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
-					userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon);
-				} else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
-					userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon);
-				} else if (baseCoupon.getType() != CouponTypeEnum.rebatePercentCoupon) {
-					userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);
-				}
-				
-			} catch(Exception e) {
+				UserInfo userInfo = new UserInfo();
+				userInfo.setId(uid);
+				userInfo.setNickName(fromNickName);
+
+				userOtherMsgNotificationService.welfareCouponActive(userSystemCoupon, userInfo);
+			} catch (Exception e) {
 				try {
 					LogHelper.errorDetailInfo(e);
 				} catch (Exception e1) {
@@ -1009,54 +1137,494 @@
 			}
 		}
 	}
-	
+
+	@Transactional
 	@Override
-	public void  sendBackCoupon(Long uid) {
-		// 瓒呰繃120绉� 鏈鍖归厤鐨勫埜
-		List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 120);
+	public void updateStateByDrawback(String orderNo) throws Exception {
+
+		if (orderNo == null || orderNo.trim().length() == 0) {
+			return;
+		}
+
+		UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, null);
+		if (record == null) {
+			return;
+		}
+
+		record.setOrderNo(orderNo);
+		record.setUpdateTime(new Date());
+		record.setState(UserSystemCouponRecord.STATE_FAIL_DRAWBACK);
+		userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+
+		// 鍒搁��鍥�
+		sendBackCoupon(record.getUserSystemCoupon(), record);
+	}
+
+	@Transactional
+	@Override
+	public void updateStateByArrivalAccount(String orderNo) throws Exception {
+
+		if (orderNo == null || orderNo.trim().length() == 0) {
+			return;
+		}
+
+		UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, 2);
+		if (record == null) {
+			return;
+		}
+
+		record.setOrderNo(orderNo);
+		record.setUpdateTime(new Date());
+		record.setState(UserSystemCouponRecord.STATE_SUCCESS);
+		userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+
+		// 娑堟伅鎺ㄩ��
+		if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
+			userOtherMsgNotificationService.welfareCouponUsed(record.getUserSystemCoupon(), orderNo);
+		} else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
+			userOtherMsgNotificationService.freeSheetCouponUsed(record.getUserSystemCoupon(), orderNo);
+		}
+	}
+
+	@Transactional
+	@Override
+	public void updateCounponInvalid(Long uid) {
+		List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalid(uid);
 		if (list == null || list.size() == 0) {
 			return;
 		}
-		
-		for (UserSystemCouponRecord couponRecord: list) {
+
+		for (UserSystemCoupon userSystemCoupon : list) {
+			// 鏇存柊鍒稿凡杩囨湡
+			userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE);
+			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
+
+			SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
+			if (systemCoupon == null) {
+				continue;
+			}
+
+			SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
+			if (baseCoupon == null || baseCoupon.getId() == null) {
+				continue;
+			}
+
+			// 娑堟伅鎺ㄩ��
+			try {
+				if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
+					userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon);
+				} else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {
+					userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon);
+				} else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
+					userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);
+				}
+
+			} catch (Exception e) {
+				try {
+					LogHelper.errorDetailInfo(e);
+				} catch (Exception e1) {
+					e1.printStackTrace();
+				}
+			}
+		}
+	}
+
+	@Transactional
+	@Override
+	public void sendBackTimeOutCoupon(Long uid) {
+		// 瓒呰繃10鍒嗛挓   鏈鍖归厤鐨勫埜
+		List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid,600L);
+		if (list == null || list.size() == 0) {
+			return;
+		}
+
+		for (UserSystemCouponRecord couponRecord : list) {
 			// 鏇存柊鐘舵�侊細鍖归厤瓒呮椂
 			couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
 			couponRecord.setUpdateTime(new Date());
 			userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);
-			
+
 			UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon();
-			// 鐘舵�佸垵濮嬪寲
-			userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
-			userSystemCoupon.setUseTime(null);
-			
+
 			int expiryDay = 15;
-			
+
 			SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
-			SystemCoupon coupon= systemCouponService.selectByPrimaryKey(systemCoupon.getId());
+			SystemCoupon coupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
 			if (coupon != null) {
 				expiryDay = coupon.getExpiryDay();
-			} 
-			
+			}
+
 			// 缁撴潫鏃ユ湡
 			Date endTime = null;
 			try {
-				String endDay = DateUtil.plusDay(expiryDay, new Date());
+				// 浠婂ぉ鍦ㄥ唴  鍑忓幓涓�澶�
+				String endDay = DateUtil.plusDay(expiryDay - 1, new Date());
 				SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
 				endTime = format.parse(endDay);
 			} catch (ParseException e) {
 				e.printStackTrace();
 			}
-			
+			// 鐘舵�佸垵濮嬪寲
+			userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
+			userSystemCoupon.setUseTime(null);
+
 			// 鏈夋晥鏈熸椂闂撮噸鏂板畾涔�
 			userSystemCoupon.setStartTime(new Date());
 			userSystemCoupon.setEndTime(endTime);
 			userSystemCoupon.setUpdateTime(new Date());
 			userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);
 		}
-		
+	}
+
+	@Transactional
+	@Override
+	public boolean updateCouponRecordUsed(Long uid, String orderNo, BigDecimal payment, Long auctionId)
+			throws Exception {
+
+		boolean isfree = false;
+
+		if (uid == null || payment == null || auctionId == null || orderNo == null || orderNo.trim().length() == 0) {
+			throw new Exception("浼犻�掑弬鏁颁笉鑳戒负绌�");
+		}
+
+		// 鏌ヨ绛夊緟鍖归厤鐨勫埜璁板綍
+		List<UserSystemCouponRecord> list = userSystemCouponRecordService.getRecordByState(uid,
+				UserSystemCouponRecord.STATE_WAIT);
+		if (list == null || list.size() == 0) {
+			return isfree;
+		}
+
+		// 鍖归厤
+		boolean matching = false;
+		UserSystemCouponRecord record = null;
+
+		for (UserSystemCouponRecord userSystemCouponRecord : list) {
+			Long goodId = userSystemCouponRecord.getGoodId();
+			if (auctionId.equals(goodId)) {
+				matching = true; // 鍖归厤鎴愬姛
+				record = userSystemCouponRecord;
+				break;
+			}
+		}
+
+		// 鍟嗗搧鍖归厤鎴愬姛
+		if (matching) {
+
+			record.setOrderNo(orderNo);
+			record.setUpdateTime(new Date());
+
+			UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon();
+
+			if (payment.compareTo(new BigDecimal(10)) > 0) {
+				// 鏇存柊璁板綍 -- 閲戦涓嶅尮閰� 澶�10鍏�
+				record.setState(UserSystemCouponRecord.STATE_FAIL_RULE);
+				userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+
+				// 閫�鍥炲埜
+				sendBackCoupon(userSystemCoupon, record);
+
+			} else {
+				// 鍏嶅崟鍖归厤鎴愬姛
+				isfree = true;
+
+				// 鏇存柊璁板綍--鍏嶅崟涓�
+				record.setState(UserSystemCouponRecord.STATE_FREE_ON);
+				userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+
+				// 鍒哥粨鏉熶娇鐢�
+				userSystemCoupon.setState(UserSystemCoupon.STATE_END_USE);
+				userSystemCoupon.setUpdateTime(new Date());
+				userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
+
+				String couponType = record.getCouponType();
+				if (couponType == null || couponType.trim().length() == 0) {
+					throw new Exception("鍒哥被鍨嬫湭琚褰�");
+				}
+
+				if (CouponTypeEnum.welfareFreeCoupon.name().equals(couponType)) {
+					userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon, orderNo, payment);
+				} else if (CouponTypeEnum.freeCoupon.name().equals(couponType)) {
+					userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon, orderNo, payment);
+				}
+			}
+		}
+
+		return isfree;
+	}
+
+	/**
+	 * 閫�鍥炲埜 鍒濆鏁版嵁
+	 * 
+	 * @param userSystemCoupon
+	 */
+	public void sendBackCoupon(UserSystemCoupon userSystemCoupon, UserSystemCouponRecord record) throws Exception {
+
+		int expiryDay = 15;
+
+		SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
+		SystemCoupon coupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
+		if (coupon != null) {
+			expiryDay = coupon.getExpiryDay();
+		}
+
+		// 缁撴潫鏃ユ湡
+		Date endTime = null;
+		try {
+			// 浠婂ぉ鍦ㄥ唴  鍑忓幓涓�澶�
+			String endDay = DateUtil.plusDay(expiryDay - 1, new Date());
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+			endTime = format.parse(endDay);
+		} catch (ParseException e) {
+			e.printStackTrace();
+		}
+		// 鐘舵�佸垵濮嬪寲
+		userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
+		userSystemCoupon.setUseTime(null);
+		// 鏈夋晥鏈熸椂闂撮噸鏂板畾涔�
+		userSystemCoupon.setStartTime(new Date());
+		userSystemCoupon.setEndTime(endTime);
+
+		userSystemCoupon.setUpdateTime(new Date());
+
+		userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);
+
+		if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
+			userOtherMsgNotificationService.welfareCouponDrawBack(userSystemCoupon, record.getOrderNo());
+		} else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
+			userOtherMsgNotificationService.freeSheetCouponDrawBack(userSystemCoupon, record.getOrderNo());
+		}
+	}
+
+	@Override
+	@Transactional
+	public void copyLotteryPrize(Long uid, int platform, String device) throws Exception {
+
+		if (uid == null || device == null) {
+			return;
+		}
+
+		// 鏈櫥闄嗕箣鍓嶆娊濂栬褰�
+		List<DeviceLotteryRecord> list = deviceLotteryRecordService.listByPlatformAndDevice(platform, device);
+		if (list == null || list.size() == 0) {
+			return;
+		}
+
+		// 鑾峰彇棰濆淇℃伅
+		UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
+
+		// 宸茬粡鎶借繃濂栫殑鎴栬�呭凡缁忚繘鍏ヨ繃鎶藉椤甸潰鐨�
+		if (userInfoExtra != null && userInfoExtra.getLotteryNewbies() != null) {
+			return;
+		}
+
+		// 鏄惁鏄柊鐢ㄦ埛
+		boolean isNewUser = userInfoExtraService.isNewUser(uid);
+		if (!isNewUser) {
+			return;
+		}
+
+		int coupon = 0;
+
+		for (DeviceLotteryRecord reviceLotteryRecord : list) {
+
+			// 鍒犻櫎璁板綍
+			deviceLotteryRecordService.deleteByPrimaryKey(reviceLotteryRecord.getId());
+
+			Long systemCouponId = reviceLotteryRecord.getSystemCouponId();
+			if (systemCouponId == null) {
+				continue;
+			}
+			SystemCoupon systemCoupon = systemCouponService.selectByPrimaryKey(systemCouponId);
+			if (systemCoupon == null) {
+				continue;
+			}
+
+			int stateActivated = 1;
+			if (systemCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
+				// 绂忓埄鍒哥姸鎬�
+				long countSuccess = threeSaleSerivce.countSuccessFirstTeam(uid);
+				// 娌℃湁涓嬬骇闃熷憳 --寰呮縺娲�
+				if (countSuccess == 0) {
+					stateActivated = 0;
+				}
+			}
+			
+			// 缁撴潫鏃ユ湡
+			// 浠婂ぉ鍦ㄥ唴  鍑忓幓涓�澶�
+			String endDay = DateUtil.plusDay(systemCoupon.getExpiryDay() - 1, new Date());
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+			Date endTime = format.parse(endDay);
+
+			UserSystemCoupon userCoupon = new UserSystemCoupon();
+			userCoupon.setUid(uid);
+			userCoupon.setSource(UserSystemCoupon.SOURCE_NEWBIES);
+			userCoupon.setSystemCoupon(systemCoupon);
+			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
+			userCoupon.setStateActivated(stateActivated);
+			userCoupon.setStartTime(new Date());
+			userCoupon.setEndTime(endTime);
+			userCoupon.setCreateTime(new Date());
+			userCoupon.setUpdateTime(new Date());
+			// 鎻掑叆鏁版嵁搴�
+			insertSelective(userCoupon);
+
+			// 鍒告暟閲�
+			coupon++;
+
+			// 娑堟伅鎺ㄩ��
+			try {
+				if (systemCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
+					userOtherMsgNotificationService.welfareCouponGet(userCoupon);
+				} else if (systemCoupon.getType() == CouponTypeEnum.freeCoupon) {
+					userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);
+				} else if (systemCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
+					userOtherMsgNotificationService.rewardCouponGet(userCoupon, systemCoupon.getPercent().intValue());
+				}
+
+			} catch (Exception e) {
+				try {
+					LogHelper.errorDetailInfo(e);
+				} catch (Exception e1) {
+					e1.printStackTrace();
+				}
+			}
+		}
+
+		if (userInfoExtra == null) {
+			userInfoExtra = new UserInfoExtra();
+			userInfoExtra.setUserInfo(new UserInfo(uid));
+		}
+
+		userInfoExtra.setLotteryNewbies(Constant.MAX_COUNT_LOTTERY_NEWBIES - list.size());
+		Integer couponNews = userInfoExtra.getCouponNews();
+		if (couponNews == null) {
+			userInfoExtra.setCouponNews(coupon);
+		} else {
+			userInfoExtra.setCouponNews(couponNews + coupon);
+		}
+		userInfoExtraService.saveUserInfoExtra(userInfoExtra);
+
 	}
 	
 	
+	@Override
+	@Transactional
+	public void randomRewardCoupon(int num, Long uid, String source) throws Exception {
+		if (num < 1) {
+			return;
+		}
+		
+		for (int i = 0; i < num; i++) {
+			
+			// 杩斿埄姣�-闅忔満
+			BigDecimal percent = new BigDecimal(randomNum());
+			// 鏌ヨ濂栧姳鍒�
+			SystemCoupon systemCoupon = systemCouponService.getCouponByTypeAndPercent(
+					CouponTypeEnum.rebatePercentCoupon.name(),percent);
+			if (systemCoupon == null) {
+				return;
+			}
+			
+			// 缁撴潫鏃ユ湡 浠婂ぉ鍦ㄥ唴  鍑忓幓涓�澶�
+			String endDay = DateUtil.plusDay(systemCoupon.getExpiryDay() - 1, new Date());
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+			Date endTime = format.parse(endDay);
+			
+			UserSystemCoupon userCoupon = new UserSystemCoupon();
+			userCoupon.setUid(uid);
+			userCoupon.setSource(source);
+			userCoupon.setSystemCoupon(systemCoupon);
+			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
+			userCoupon.setStateActivated(1);
+			userCoupon.setStartTime(new Date());
+			userCoupon.setEndTime(endTime);
+			userCoupon.setCreateTime(new Date());
+			userCoupon.setUpdateTime(new Date());
+			// 鎻掑叆鏁版嵁搴�
+			insertSelective(userCoupon);
+			
+			// 娑堟伅鎺ㄩ��
+			try {
+				userOtherMsgNotificationService.rewardCouponGet(userCoupon,systemCoupon.getPercent().intValue());
+			} catch(Exception e) {
+				try {
+					LogHelper.errorDetailInfo(e);
+				} catch (Exception e1) {
+					e1.printStackTrace();
+				}
+			}
+		}
+		
+		// 绂忓埄涓績绾㈢偣
+		UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
+		if (userInfoExtra == null) {
+			return;
+		}
+		Integer couponNews = userInfoExtra.getCouponNews();
+		if (couponNews == null) {
+			userInfoExtra.setCouponNews(num);
+		} else {
+			userInfoExtra.setCouponNews(couponNews + num);
+		}
+		userInfoExtraService.saveUserInfoExtra(userInfoExtra);
+	}
 	
+	/**
+	 * 闅忔満鍒告瘮渚�
+	 * @return
+	 */
+	public int randomNum() {
+		
+		int result = 1;
+		
+		List<RandomProportion> list = new ArrayList<RandomProportion>();
+		list.add(new RandomProportion(1, 22));
+		list.add(new RandomProportion(2, 22));
+		list.add(new RandomProportion(3, 22));
+		list.add(new RandomProportion(4, 22));
+		list.add(new RandomProportion(5, 20));
+		list.add(new RandomProportion(6, 18));
+		list.add(new RandomProportion(7, 16));
+		list.add(new RandomProportion(8, 14));
+		list.add(new RandomProportion(9, 12));
+		list.add(new RandomProportion(10, 10));
+		list.add(new RandomProportion(11, 8));
+		list.add(new RandomProportion(12, 6));
+		list.add(new RandomProportion(13, 4));
+		list.add(new RandomProportion(14, 2));
+		list.add(new RandomProportion(15, 1));
+
+		int minRange = 0;
+		int maxRange = 0;
+		int randomNum = (int) (1 + Math.round(Math.random() * (199)));
+		
+		for (int i = 0; i < list.size(); i++) {
+			
+			RandomProportion proportion = list.get(i);
+			int probability = proportion.probability;
+			
+			maxRange = maxRange + probability;
+			minRange = maxRange - probability;
+			
+			if(randomNum > minRange && randomNum <= maxRange) {
+				result = proportion.num;
+				break;
+			}
+		}
+		
+		return result;
+	}
+	
+	class RandomProportion {
+		public int num;//鍒稿��
+		public int probability; // 姒傜巼
+		
+		RandomProportion () {}
+		
+		RandomProportion (int num, int probability) {
+			this.num = num;
+			this.probability = probability;
+		}
+	}
 	
 }

--
Gitblit v1.8.0