From 2ff38cf4200a2235567e8ff6f5560a7026e1f1a6 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 23 四月 2020 14:08:56 +0800
Subject: [PATCH] 返利比例兼容
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImpl.java | 190 ++++-------------------------------------------
1 files changed, 17 insertions(+), 173 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImpl.java
index ec8c4bc..8fa12e3 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImpl.java
@@ -16,26 +16,29 @@
import com.yeshi.fanli.dao.mybatis.order.InviteOrderSubsidyMapper;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
-import com.yeshi.fanli.entity.bus.user.Order;
+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.exception.order.CommonOrderException;
import com.yeshi.fanli.exception.order.InviteOrderSubsidyException;
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.InviteOrderSubsidyService;
import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService;
-import com.yeshi.fanli.service.inter.order.OrderService;
+import com.yeshi.fanli.service.inter.order.OrderHongBaoMoneyComputeService;
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.util.MoneyBigDecimalUtil;
+import com.yeshi.fanli.service.manger.user.UserLevelManager;
+import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
+import com.yeshi.fanli.util.user.UserLevelUtil;
@Service
public class InviteOrderSubsidyServiceImpl implements InviteOrderSubsidyService {
-
@Resource
private InviteOrderSubsidyMapper inviteOrderSubsidyMapper;
@@ -49,7 +52,7 @@
private OrderHongBaoMapService orderHongBaoMapService;
@Resource
- private OrderService orderService;
+ private CommonOrderService commonOrderService;
@Resource
private HongBaoManageService hongBaoManageService;
@@ -58,20 +61,22 @@
private UserVIPInfoService userVIPInfoService;
@Resource
- private CommonOrderService commonOrderService;
+ private UserLevelManager userLevelManager;
+
+ @Resource
+ private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;
+
+ @Resource
+ private ThreeSaleSerivce threeSaleSerivce;
@Override
public InviteOrderSubsidy getByOrderNoAndType(Long uid, String orderNo, Integer type) {
return inviteOrderSubsidyMapper.getByOrderNoAndType(uid, orderNo, type);
}
- @Override
- public InviteOrderSubsidy getByOrderNoAndTypeForUpdate(Long uid, String orderNo, Integer type) {
- return inviteOrderSubsidyMapper.getByOrderNoAndTypeForUpdate(uid, orderNo, type);
- }
- @Transactional(rollbackFor = Exception.class)
- private void addOrderSubsidy(InviteOrderSubsidy orderSubsidy) throws InviteOrderSubsidyException {
+ private void addOrderSubsidy(InviteOrderSubsidy orderSubsidy)
+ throws InviteOrderSubsidyException, CommonOrderException {
if (orderSubsidy.getMoney() == null || StringUtil.isNullOrEmpty(orderSubsidy.getOrderNo())
|| orderSubsidy.getSourceType() == null || orderSubsidy.getUid() == null)
throw new InviteOrderSubsidyException(1, "鏁版嵁涓嶅畬鏁�");
@@ -96,167 +101,6 @@
orderSubsidy.setCreateTime(new Date());
inviteOrderSubsidyMapper.insertSelective(orderSubsidy);
}
- }
-
- @Transactional(rollbackFor = Exception.class)
- @Override
- public void addOrUpdateByOrder(String orderId, int sourceType) throws InviteOrderSubsidyException {
- List<HongBaoOrder> list = hongBaoOrderService.listByOrderIdAndSourceType(orderId, sourceType);
- if (list != null && list.size() > 0) {
- // 蹇呴』鏄嚜璐鍗曟墠杩斿埄
- HongBaoV2 parent = hongBaoV2Service.selectByPrimaryKey(list.get(0).getHongBaoV2().getId());
- if (parent != null && parent.getType() == HongBaoV2.TYPE_ZIGOU && parent.getUrank() != 100) {// 涓嶆槸浼氬憳鐨勮嚜璐墠琛ヨ创
- Order order = orderService.findOrderByOrderIdAndType(orderId, sourceType);
- List<Long> idList = new ArrayList<>();
- for (HongBaoOrder ho : list)
- if (ho.getHongBaoV2() != null)
- idList.add(ho.getHongBaoV2().getId());
- // 鏌ヨ瀛愮孩鍖�
- List<HongBaoV2> children = hongBaoV2Service.listChildrenByIds(idList);
- if (children != null && children.size() > 0) {
- Map<Long, Integer> uidHongBaoMap = new ConcurrentHashMap<>();
- for (HongBaoV2 v2 : children) {// 鎸夌敤鎴稩D缁熻绾㈠寘
- Long uid = v2.getUserInfo().getId();
- if (v2.getState() == HongBaoV2.STATE_BUKELINGQU || v2.getState() == HongBaoV2.STATE_KELINGQU
- || v2.getState() == HongBaoV2.STATE_YILINGQU) {
- uidHongBaoMap.put(uid, v2.getType());
- }
- }
-
- List<HongBaoV2> hbList = hongBaoV2Service.listByIds(idList);
- int state = InviteOrderSubsidy.STATE_UNKNOWN;
- // 纭畾鏄惁浣跨敤浜嗗鍔卞埜
- if (orderHongBaoMapService.selectByOrderIdAndSourceType(orderId, sourceType) != null) {
- state = InviteOrderSubsidy.STATE_INVALID;
- } else {
- // 纭畾鏄惁杩斿埄鍒拌处5澶╁悗
- if (recieveMoneyMoreThan(hbList, 5)) {
- state = InviteOrderSubsidy.STATE_VALID;
- } else {
- state = InviteOrderSubsidy.STATE_UNKNOWN;
- }
- }
-
- BigDecimal totalMoney = new BigDecimal(0);
- // 璁＄畻鎬昏繑鍒�
- for (HongBaoV2 v2 : hbList) {
- if (v2.getState() == HongBaoV2.STATE_BUKELINGQU || v2.getState() == HongBaoV2.STATE_KELINGQU
- || v2.getState() == HongBaoV2.STATE_YILINGQU)
- totalMoney = totalMoney.add(v2.getMoney());
- }
-
- BigDecimal firstRate = hongBaoManageService
- .getInviteFirstLevelSubsidyRate(order.getThirdCreateTime().getTime());
- BigDecimal secondRate = hongBaoManageService
- .getInviteSecondLevelSubsidyRate(order.getThirdCreateTime().getTime());
-
- // 璁＄畻濂栧姳閲�
- for (Iterator<Long> its = uidHongBaoMap.keySet().iterator(); its.hasNext();) {
- Long uid = its.next();
- int type = uidHongBaoMap.get(uid);
- if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_ERJI) {
- BigDecimal rate = null;
- if (type == HongBaoV2.TYPE_YIJI)
- rate = firstRate;
- else
- rate = secondRate;
- BigDecimal money = MoneyBigDecimalUtil.div(MoneyBigDecimalUtil.mul(totalMoney, rate),
- new BigDecimal(100));
- InviteOrderSubsidy orderSubsidy = new InviteOrderSubsidy();
- orderSubsidy.setMoney(money);
- orderSubsidy.setOriginalMoney(money);
- orderSubsidy.setUid(uid);
- 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);
- // VIP鐢ㄦ埛鎵嶈兘琛ヨ创
- if (userVIPInfoService.isVIP(uid))
- addOrderSubsidy(orderSubsidy);
- }
- }
- }
- }
- }
-
- }
-
- private boolean recieveMoneyMoreThan(List<HongBaoV2> hbList, int day) {
- // 鏄惁鍏ㄩ儴鏄埌璐︾姸鎬佹垨澶辨晥鐘舵��
- int invalidCount = 0;// 澶辨晥涓暟
- int recieveCount = 0;// 鍒拌处鐨勪釜鏁�
- long maxGetTime = 0;
- for (HongBaoV2 v2 : hbList) {
- if (v2.getState() == HongBaoV2.STATE_SHIXIAO)
- invalidCount++;
- else if (v2.getState() == HongBaoV2.STATE_YILINGQU) {
- recieveCount++;
- if (v2.getGetTime() != null && v2.getGetTime().getTime() > maxGetTime)
- maxGetTime = v2.getGetTime().getTime();
-
- }
- }
- if (invalidCount + recieveCount == hbList.size() && recieveCount > 0 && maxGetTime > 0) {// 鍏ㄩ儴宸插埌璐�
- // 鏌ヨ鍒拌处鏃堕棿璺濈褰撳墠鏃堕棿鏄惁瓒呰繃鎸囧畾澶�
- if (System.currentTimeMillis() - maxGetTime > 1000 * 60 * 60 * 24L * day)
- return true;
- }
- return false;
- }
-
- @Override
- public long countByOrderIdAndSourceType(String orderId, int sourceType) {
- return inviteOrderSubsidyMapper.countByOrderNoAndType(orderId, sourceType);
- }
-
- @Transactional
- @Override
- public void invalidByOrderIdAndSourceType(String orderId, int sourceType) {
- List<InviteOrderSubsidy> list = inviteOrderSubsidyMapper.listByOrderNoAndType(orderId, sourceType);
- if (list != null && list.size() > 0)
- for (InviteOrderSubsidy subsidy : list) {
- if (subsidy.getState() == InviteOrderSubsidy.STATE_UNKNOWN
- || subsidy.getState() == InviteOrderSubsidy.STATE_VALID) {
- InviteOrderSubsidy update = new InviteOrderSubsidy(subsidy.getId());
- update.setState(InviteOrderSubsidy.STATE_INVALID);
- update.setUpdateTime(new Date());
- update.setInValidTime(new Date());
- inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);
- }
- }
- }
-
- @Transactional
- @Override
- public void validByOrderIdAndSourceType(String orderId, int sourceType) throws InviteOrderSubsidyException {
-
- List<InviteOrderSubsidy> list = inviteOrderSubsidyMapper.listByOrderNoAndType(orderId, sourceType);
- if (list != null && list.size() > 0)
- for (InviteOrderSubsidy subsidy : list) {
- if (subsidy.getState() == InviteOrderSubsidy.STATE_UNKNOWN) {
- InviteOrderSubsidy update = new InviteOrderSubsidy(subsidy.getId());
- update.setState(InviteOrderSubsidy.STATE_VALID);
- update.setUpdateTime(new Date());
- update.setValidTime(new Date());
- inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);
- }
- }
-
- }
-
- @Transactional
- @Override
- public void settleById(Long id, BigDecimal money) {
- InviteOrderSubsidy orderSubsidy = new InviteOrderSubsidy(id);
- orderSubsidy.setMoney(money);
- orderSubsidy.setState(InviteOrderSubsidy.STATE_SUBSIDIZED);
- orderSubsidy.setUpdateTime(new Date());
- inviteOrderSubsidyMapper.updateByPrimaryKeySelective(orderSubsidy);
- // 璁剧疆鍙粨绠�
-
}
}
--
Gitblit v1.8.0