From 3ce9e928e082ff8abf697dba560cbfbb412e89f8 Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期一, 11 十一月 2019 15:45:02 +0800
Subject: [PATCH] 商城后台编辑

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/redpack/RedPackWinInviteServiceImpl.java |   68 +++++++++-------------------------
 1 files changed, 18 insertions(+), 50 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/redpack/RedPackWinInviteServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/redpack/RedPackWinInviteServiceImpl.java
index 31d1d4a..dcaa65d 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/redpack/RedPackWinInviteServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/redpack/RedPackWinInviteServiceImpl.java
@@ -12,6 +12,7 @@
 
 import com.google.gson.Gson;
 import com.yeshi.fanli.dao.mybatis.redpack.RedPackWinInviteMapper;
+import com.yeshi.fanli.dto.mq.user.body.UserAccountBindingMQMsg;
 import com.yeshi.fanli.dto.msg.MsgRedPackAddContentDTO;
 import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail.MsgTypeMoneyTypeEnum;
 import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo;
@@ -78,6 +79,12 @@
 		return redPackWinInviteMapper.countRewardRecord(uid);
 	}
 	
+	@Override
+	public BigDecimal getRewardMoney(Long uid) {
+		return redPackWinInviteMapper.getRewardMoney(uid);
+	}
+	
+	
 	@RedPackGetVersionLimit(uid = "#uid")
 	@RequestSerializableByKeyService(key = "#uid")
 	@Transactional(rollbackFor = Exception.class)
@@ -89,7 +96,6 @@
 		// 涓婁竴绾х殑濂栧姳
 		UserInfo boss = threeSaleSerivce.getBoss(uid);
 		if(boss != null) {
-			firstReward(uid, source, orderNo);
 			bossReward(boss.getId(), uid, source, orderNo);
 		}
 	}
@@ -109,54 +115,6 @@
 		firstSharedOrderRewardToBoss(uid, teamUid, source, orderNo);
 		firstSharedOrderRewardTheMonthToBoss(uid, teamUid, source, orderNo);
 	}
-	
-	
-	/**
-	 * 琚個璇蜂汉涓嬮鍗曡繑鍒╋紙涓嬪崟灏辩粰锛夛細
-	 * 瀹屾垚棣栫瑪璁㈠崟 锛堝凡鍒拌处锛� 棣栧崟=涓嶉檺鍒堕噾棰濄�佷笉闄愬埗鍟嗗搧銆佷笉闄愬埗鏁伴噺銆佷笉闄愬埗璁㈠崟绫诲瀷锛�
-	 * @param uid
-	 * @param source
-	 * @param orderNo
-	 * @param bossId
-	 */
-	@Transactional
-	private void firstReward(Long uid, Integer source, String orderNo) throws Exception{
-		// 濂栧姳涓�娆�
-		long total = redPackWinInviteMapper.countByUidAndType(uid, RedPackWinInviteTypeEnum.newUserReward.name());
-		if (total > 0)
-			return;
-		
-		// 1銆佸垽鏂槸鍚︾敤鎴烽涓鍗�
-		CommonOrderVO order = commonOrderService.firstValidOrderByUid(uid);
-		if (order == null || source != order.getSourceType() || !orderNo.equals(order.getOrderNo())) 
-			return;
-		
-		// 閲戦
-		BigDecimal money = new BigDecimal(redPackConfigService.getValueByKey("new_user_first_order"));
-		
-		// 3銆佽幏寰楃孩鍖呰褰�
-		RedPackWinInvite winInvite = new RedPackWinInvite();
-		winInvite.setCreateTime(new Date());
-		winInvite.setUpdateTime(new Date());
-		winInvite.setType(RedPackWinInviteTypeEnum.newUserReward);
-		winInvite.setUid(uid);
-		winInvite.setTeamUid(null);
-		winInvite.setMoney(money);
-		winInvite.setSource(source);
-		winInvite.setOrderNo(orderNo);
-		redPackWinInviteMapper.insertSelective(winInvite);
-		
-		// 4銆佸鍔犵孩鍖�
-		redPackBalanceService.addRedPack(uid, money, RedPackDetailFactory.createNewUserReward(winInvite));
-		
-		//娑堟伅
-		MsgRedPackAddContentDTO dto = new MsgRedPackAddContentDTO();
-		dto.setTitle("绾㈠寘澧炲姞");
-		dto.setMoney("楼" + money.setScale(2));
-		dto.setBalance("楼" + redPackBalanceService.getBalance(uid).setScale(2));
-		userMoneyMsgNotificationService.redPackMsg(uid, MsgTypeMoneyTypeEnum.redPackNewUserReward, new Gson().toJson(dto), "绾㈠寘鍙敤浜庤喘涔颁細鍛�");
-	}
-	
 	
 	/**
 	 * 涓婄骇濂栧姳锛氳閭�璇蜂汉瀹屾垚棣栫瑪鍒嗕韩璁㈠崟 锛堝凡鍒拌处锛� 
@@ -272,7 +230,17 @@
 	}
 	
 	
-	@RequestSerializableByKeyService(key = "#uid")
+	@RedPackGetVersionLimit(uid = "#bindingMQMsg.uid")
+	@RequestSerializableByKeyService(key = "#bindingMQMsg.uid")
+	public void userAccountBinding(UserAccountBindingMQMsg bindingMQMsg) throws Exception{
+		Integer type = bindingMQMsg.getType();
+		if (type == UserAccountBindingMQMsg.TYPE_PHONE || type == UserAccountBindingMQMsg.TYPE_TAOBAO) {
+			inviteSucceedReward(bindingMQMsg.getUid());
+		}
+	}
+	
+	
+	
 	@Override
 	@Transactional
 	public void inviteSucceedReward(Long uid) throws Exception{

--
Gitblit v1.8.0