From 248aa38c12a393d12c5ab721ee75fbd5c7dfbb9f Mon Sep 17 00:00:00 2001
From: yujian <yujian>
Date: 星期四, 18 四月 2019 12:31:28 +0800
Subject: [PATCH] Merge branch 'div'

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java |  154 +++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 112 insertions(+), 42 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 b064408..0df0c57 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
@@ -166,7 +166,12 @@
 	public List<UserSystemCoupon> getUserCouponBySource(Long uid, String source) {
 		return userSystemCouponMapper.getUserCouponBySource(uid, source);
 	}
-
+	
+	@Override
+	public int countTodatyUserCouponBySource(Long uid, String source) {
+		return userSystemCouponMapper.countTodatyUserCouponBySource(uid, source);
+	}
+	
 	@Override
 	public long countUserCouponList(Long uid) {
 		return userSystemCouponMapper.countUserCouponList(uid);
@@ -181,7 +186,15 @@
 			throw new UserSystemCouponException(1, "鍙傛暟涓嶆纭�");
 		}
 
-		SystemCoupon coupon = systemCouponService.getCouponByType(couponType);
+		SystemCoupon coupon = null;
+		if (couponType.equals(CouponTypeEnum.welfareFreeCoupon.name())) {
+			// 绂忓埄鍏嶅崟鍒�
+			coupon = systemCouponService.getCouponByType(couponType);
+		} else if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) {
+			// 濂栧姳鍒�10%
+			coupon = systemCouponService.getCouponByTypeAndPercent(couponType,new BigDecimal(10));
+		}
+		
 		if (coupon == null) {
 			throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉姝g‘");
 		}
@@ -258,7 +271,7 @@
 
 	@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) {
@@ -276,7 +289,7 @@
 		}
 
 		// 鏁版嵁缁勭粐
-		listDataFactory(listVO, uid);
+		listDataFactory(listVO, uid, changeJump);
 
 		return listVO;
 	}
@@ -286,8 +299,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();
@@ -323,30 +342,26 @@
 				// 鏄剧ず瑙勫垯
 				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"); } else { // 婵�娲婚個璇风爜鐣岄潰 jumpLink.put("url",
-				 * configService.get("invite_activation_url")); }
-				 * jumpBtn.put("params", jumpLink);
-				 */
-
-				jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));
-
+				
+				// 绂忓埄鍒搁渶瑕佹縺娲荤晫闈�
+				if (!changeJump) {
+					jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));
+				} else {
+					if (inviteCode != null && inviteCode.trim().length() > 0) {
+						// 閭�璇峰ソ鍙嬬晫闈�
+						jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_friends"));
+					} else {
+						// 閭�璇锋縺娲荤晫闈�
+						jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate"));
+					}
+				}
+				
 			} else if (stateActivated == 1) {
 				// 鏄剧ず瑙勫垯
 				userCouponVO.setCouponRule(systemCoupon.getRule());
@@ -521,6 +536,7 @@
 	@Transactional
 	@Override
 	public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception {
+		
 		if (uid == null) {
 			throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�");
 		}
@@ -530,7 +546,7 @@
 		// 閫�鍥炲埜
 		sendBackTimeOutCoupon(uid);
 		// 娲诲姩棰嗗彇鍒�
-		receivedCoupon(uid);
+//		receivedCoupon(uid);
 
 		// 璁㈠崟鐩稿叧鐨勫埜
 		List<SystemCoupon> couponList = systemCouponService.getOrderCouponList();
@@ -1222,8 +1238,8 @@
 	@Transactional
 	@Override
 	public void sendBackTimeOutCoupon(Long uid) {
-		// 瓒呰繃120绉� 鏈鍖归厤鐨勫埜
-		List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 120L);
+		// 瓒呰繃10鍒嗛挓   鏈鍖归厤鐨勫埜
+		List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid,600L);
 		if (list == null || list.size() == 0) {
 			return;
 		}
@@ -1407,9 +1423,9 @@
 			return;
 		}
 
-		// 鏄惁鏈夎繃璁㈠崟锛氳繑鍒┿�佸垎浜鍗�
-		boolean hasOrder = commonOrderCountService.hasRebateAndShareOrder(uid);
-		if (hasOrder) {
+		// 鏄惁鏄柊鐢ㄦ埛
+		boolean isNewUser = userInfoExtraService.isNewUser(uid);
+		if (!isNewUser) {
 			return;
 		}
 
@@ -1447,7 +1463,7 @@
 
 			UserSystemCoupon userCoupon = new UserSystemCoupon();
 			userCoupon.setUid(uid);
-			userCoupon.setSource(UserSystemCoupon.SOURCE_CHOUJIANG);
+			userCoupon.setSource(UserSystemCoupon.SOURCE_NEWBIES);
 			userCoupon.setSystemCoupon(systemCoupon);
 			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
 			userCoupon.setStateActivated(stateActivated);
@@ -1545,7 +1561,6 @@
 			}
 			
 			if (receive) {
-				
 				// 鎻掑叆璁板綍
 				PushCouponRecord pushCouponRecord = new PushCouponRecord();
 				pushCouponRecord.setPushCoupon(pushCoupon);
@@ -1554,14 +1569,13 @@
 				pushCouponRecordService.insertSelective(pushCouponRecord);
 				
 				// 鎻掑叆鍒�
-				randomRewardCoupon(pushCoupon, uid);
+				randomRewardCouponForPush(pushCoupon, uid);
 			}
 		}
 	}
 	
-	@Override
 	@Transactional
-	public void randomRewardCoupon(PushCoupon pushCoupon, Long uid) throws Exception {
+	public void randomRewardCouponForPush(PushCoupon pushCoupon, Long uid) throws Exception {
 		int coupon = 0;
 		
 		Integer amount = pushCoupon.getAmount();
@@ -1599,14 +1613,7 @@
 			
 			// 娑堟伅鎺ㄩ��
 			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());
-				}
-				
+				userOtherMsgNotificationService.rewardCouponGet(userCoupon,systemCoupon.getPercent().intValue());
 			} catch(Exception e) {
 				try {
 					LogHelper.errorDetailInfo(e);
@@ -1630,7 +1637,70 @@
 		}
 		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

--
Gitblit v1.8.0