From 88c7df1d5089d8e39f356a68eaccc18f308e190c Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期二, 24 三月 2020 12:10:07 +0800
Subject: [PATCH] Merge branch 'div' into div-1
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImplV2.java | 146 +++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 137 insertions(+), 9 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImplV2.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImplV2.java
index 0343fa6..dbbece5 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImplV2.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImplV2.java
@@ -2,10 +2,13 @@
import java.math.BigDecimal;
import java.util.ArrayList;
+import java.util.Calendar;
import java.util.Date;
+import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
+import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import javax.annotation.Resource;
@@ -15,21 +18,29 @@
import com.yeshi.fanli.dao.mybatis.order.InviteOrderSubsidyMapper;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
+import com.yeshi.fanli.entity.bus.user.ThreeSale;
+import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;
import com.yeshi.fanli.entity.order.CommonOrder;
import com.yeshi.fanli.entity.order.HongBaoOrder;
import com.yeshi.fanli.entity.order.InviteOrderSubsidy;
+import com.yeshi.fanli.entity.order.OrderTeamReward;
+import com.yeshi.fanli.exception.order.CommonOrderException;
import com.yeshi.fanli.exception.order.InviteOrderSubsidyException;
+import com.yeshi.fanli.exception.order.OrderTeamRewardException;
import com.yeshi.fanli.service.inter.order.CommonOrderService;
import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
import com.yeshi.fanli.service.inter.order.InviteOrderSubsidyServiceV2;
import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService;
import com.yeshi.fanli.service.inter.order.OrderHongBaoMoneyComputeService;
+import com.yeshi.fanli.service.inter.order.OrderTeamRewardService;
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
+import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;
import com.yeshi.fanli.service.manger.user.UserLevelManager;
import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.TimeUtil;
@Service
public class InviteOrderSubsidyServiceImplV2 implements InviteOrderSubsidyServiceV2 {
@@ -61,6 +72,12 @@
@Resource
private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;
+ @Resource
+ private OrderTeamRewardService orderTeamRewardService;
+
+ @Resource
+ private ThreeSaleSerivce threeSaleSerivce;
+
@Override
public InviteOrderSubsidy getByOrderNoAndType(Long uid, String orderNo, Integer type) {
return inviteOrderSubsidyMapper.getByOrderNoAndType(uid, orderNo, type);
@@ -72,7 +89,8 @@
}
@Transactional(rollbackFor = Exception.class)
- private void addOrderSubsidy(InviteOrderSubsidy orderSubsidy) throws InviteOrderSubsidyException {
+ private void addOrderSubsidy(InviteOrderSubsidy orderSubsidy)
+ throws InviteOrderSubsidyException, OrderTeamRewardException, CommonOrderException {
if (orderSubsidy.getMoney() == null || StringUtil.isNullOrEmpty(orderSubsidy.getOrderNo())
|| orderSubsidy.getSourceType() == null || orderSubsidy.getUid() == null)
throw new InviteOrderSubsidyException(1, "鏁版嵁涓嶅畬鏁�");
@@ -92,10 +110,86 @@
update.setState(orderSubsidy.getState());
update.setUpdateTime(new Date());
inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);
+ // 娣诲姞濂栧姳
+ addTeamReward(old.getId());
} else {// 娣诲姞
if (orderSubsidy.getCreateTime() == null)
orderSubsidy.setCreateTime(new Date());
inviteOrderSubsidyMapper.insertSelective(orderSubsidy);
+ // 娣诲姞濂栧姳
+ addTeamReward(orderSubsidy.getId());
+ }
+ }
+
+ // 娣诲姞鍥㈤槦濂栧姳
+ private void addTeamReward(Long subsidyId) throws OrderTeamRewardException, CommonOrderException {
+ // 鏌ヨ鍥㈤槦濂栧姳鐨勪汉
+ // 璁＄畻鐩稿簲鐨勬瘮渚�
+ InviteOrderSubsidy subsidy = inviteOrderSubsidyMapper.selectByPrimaryKeyForUpdate(subsidyId);
+ if (subsidy == null)
+ throw new OrderTeamRewardException(20, "琛ヨ创涓嶅瓨鍦�");
+
+ // 鑾峰彇涓�4绾х敤鎴�
+ List<CommonOrder> commonOrderList = commonOrderService.listBySourceTypeAndOrderId(subsidy.getSourceType(),
+ subsidy.getOrderNo());
+ if (commonOrderList == null || commonOrderList.size() == 0) {
+ throw new CommonOrderException(1, "璁㈠崟涓嶅瓨鍦�");
+ }
+
+ Date orderTime = commonOrderList.get(0).getThirdCreateTime();
+
+ Long sourceUid = commonOrderList.get(0).getUserInfo().getId();
+
+ List<ThreeSale> bossList = threeSaleSerivce.getMyBossDeepList(sourceUid, 4);
+ // 鏃犻渶瑕佸洟闃熷鍔辩殑涓婄骇
+ if (bossList.size() < 3)
+ return;
+
+ Set<Long> rewardUid = new HashSet<>();
+ for (int i = 2; i < bossList.size(); i++) {
+ rewardUid.add(bossList.get(i).getBoss().getId());
+ }
+
+ // 鍒犻櫎琛ヨ创鐢ㄦ埛鐨勪笅绾х敤鎴�
+ for (int i = 0; i < bossList.size(); i++) {
+ if (bossList.get(i).getBoss().getId().longValue() == subsidy.getUid()) {
+ break;
+ } else {
+ bossList.remove(i);
+ i--;
+ }
+ }
+
+ for (int i = 1; i < bossList.size(); i++) {
+ if (rewardUid.contains(bossList.get(i).getBoss().getId())) {
+ UserInfo boss = bossList.get(i).getBoss();
+ if (i == 1) {
+ if (bossList.get(i).getSucceedTime() < subsidy.getCreateTime().getTime()) {
+ UserLevelEnum userLevel = userLevelManager.getUserLevel(boss.getId(), orderTime);
+ BigDecimal rewardMoney = orderHongBaoMoneyComputeService
+ .computeFirstTeamReward(subsidy.getMoney(), subsidy.getCreateTime(), userLevel);
+
+ if (rewardMoney != null) {
+ // 娣诲姞濂栧姳
+ orderTeamRewardService.addOrUpdate(subsidy, rewardMoney, boss.getId(),
+ OrderTeamReward.LEVEL_ONE);
+ }
+ }
+ } else if (i == 2) {
+ if (bossList.get(i).getSucceedTime() < subsidy.getCreateTime().getTime()) {
+ UserLevelEnum userLevel = userLevelManager.getUserLevel(boss.getId(), orderTime);
+ BigDecimal rewardMoney = orderHongBaoMoneyComputeService
+ .computeSecondTeamReward(subsidy.getMoney(), subsidy.getCreateTime(), userLevel);
+
+ if (rewardMoney != null) {
+ // 娣诲姞濂栧姳
+ orderTeamRewardService.addOrUpdate(subsidy, rewardMoney, boss.getId(),
+ OrderTeamReward.LEVEL_TWO);
+ }
+ }
+ }
+
+ }
}
}
@@ -106,7 +200,9 @@
if (list != null && list.size() > 0) {
// 蹇呴』鏄嚜璐鍗曟墠杩斿埄
HongBaoV2 parent = hongBaoV2Service.selectByPrimaryKey(list.get(0).getHongBaoV2().getId());
- if (parent != null && parent.getUrank() != UserLevelEnum.superVIP.getOrderRank()) {// 涓嶆槸瓒呯骇浼氬憳鐨勮嚜璐�/鍒嗕韩鎵嶈ˉ璐�
+ if (parent != null && parent.getUrank() != UserLevelEnum.superVIP.getOrderRank()
+ && (parent.getType() == HongBaoV2.TYPE_SHARE_GOODS || parent.getType() == HongBaoV2.TYPE_ZIGOU)) {// 涓嶆槸瓒呯骇浼氬憳鐨勮嚜璐�/鍒嗕韩鎵嶈ˉ璐�
+ boolean isShare = (parent.getType() == HongBaoV2.TYPE_SHARE_GOODS);
List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(sourceType, orderId);
if (orderList == null || orderList.size() == 0)
@@ -164,7 +260,7 @@
// 璁＄畻濂栧姳閲�
for (Iterator<Long> its = uidHongBaoMap.keySet().iterator(); its.hasNext();) {
Long uid = its.next();
- UserLevelEnum userLevel = userLevelManager.getUserLevel(uid);
+ UserLevelEnum userLevel = userLevelManager.getUserLevel(uid, placeOrderTime);
int type = uidHongBaoMap.get(uid);
if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_ERJI) {
@@ -183,9 +279,24 @@
orderSubsidy.setOrderNo(orderId);
orderSubsidy.setSourceType(sourceType);
orderSubsidy.setState(state);
+ if (type == HongBaoV2.TYPE_YIJI)
+ orderSubsidy.setLevel(InviteOrderSubsidy.LEVEL_ONE);
+ else
+ orderSubsidy.setLevel(InviteOrderSubsidy.LEVEL_TWO);
// 浼氬憳鎵嶈兘琛ヨ创
- if (userLevel != UserLevelEnum.daRen)
- addOrderSubsidy(orderSubsidy);
+ if (userLevel != UserLevelEnum.daRen) {
+ try {
+ addOrderSubsidy(orderSubsidy);
+ } catch (OrderTeamRewardException e) {
+ throw new InviteOrderSubsidyException(e.getCode(), e.getMsg());
+ } catch (CommonOrderException e) {
+ throw new InviteOrderSubsidyException(e.getCode(), e.getMsg());
+ }
+ // 鍒嗕韩璧氫笉鑳戒娇鐢ㄨ繑鍒╁鍔卞埜锛屼笉鐢ㄧ瓑寰�5澶�
+ if (isShare) {
+ validByOrderIdAndSourceType(orderId, sourceType);
+ }
+ }
}
}
}
@@ -222,7 +333,7 @@
return inviteOrderSubsidyMapper.countByOrderNoAndType(orderId, sourceType);
}
- @Transactional
+ @Transactional(rollbackFor = Exception.class)
@Override
public void invalidByOrderIdAndSourceType(String orderId, int sourceType) {
List<InviteOrderSubsidy> list = inviteOrderSubsidyMapper.listByOrderNoAndType(orderId, sourceType);
@@ -234,13 +345,29 @@
update.setState(InviteOrderSubsidy.STATE_INVALID);
update.setUpdateTime(new Date());
inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);
+ orderTeamRewardService.invalidByOrderIdAndSourceType(subsidy.getId());
}
}
}
- @Transactional
+ @Transactional(rollbackFor = Exception.class)
@Override
- public void validByOrderIdAndSourceType(String orderId, int sourceType) {
+ public void validByOrderIdAndSourceType(String orderId, int sourceType) throws InviteOrderSubsidyException {
+ // 鏌ヨ棰勮鍒拌处鏃堕棿
+ List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(sourceType, orderId);
+ if (orderList == null || orderList.size() == 0)
+ throw new InviteOrderSubsidyException(31, "璁㈠崟涓嶅瓨鍦�");
+
+ if (orderList.get(0).getSettleTime() == null)
+ throw new InviteOrderSubsidyException(32, "璁㈠崟灏氭湭纭鏀惰揣");
+
+ // 纭鏀惰揣鏃堕棿鐨勪笅鏈�25鍙峰埌璐�
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(orderList.get(0).getSettleTime());
+ calendar.add(Calendar.MONTH, 1);
+ Date preGetTime = new Date(TimeUtil.convertToTimeTemp(
+ calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-25", "yyyy-M-dd"));
+
List<InviteOrderSubsidy> list = inviteOrderSubsidyMapper.listByOrderNoAndType(orderId, sourceType);
if (list != null && list.size() > 0)
for (InviteOrderSubsidy subsidy : list) {
@@ -248,10 +375,11 @@
InviteOrderSubsidy update = new InviteOrderSubsidy(subsidy.getId());
update.setState(InviteOrderSubsidy.STATE_VALID);
update.setUpdateTime(new Date());
+ update.setPreGetTime(preGetTime);
inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);
+ orderTeamRewardService.validByOrderIdAndSourceType(subsidy.getId(), preGetTime);
}
}
-
}
@Override
--
Gitblit v1.8.0