From 83bb6e0580b646c5d89da1cdb4085787c8136822 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期四, 23 四月 2020 14:29:48 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/div' into div
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImpl.java | 298 -----------------------------------------------------------
1 files changed, 0 insertions(+), 298 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 98fa7c3..a1f443f 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
@@ -1,319 +1,21 @@
package com.yeshi.fanli.service.impl.order;
-import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
import com.yeshi.fanli.dao.mybatis.order.InviteOrderSubsidyMapper;
-import com.yeshi.fanli.entity.bus.user.HongBaoV2;
-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.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.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;
- @Resource
- private HongBaoV2Service hongBaoV2Service;
-
- @Resource
- private HongBaoOrderService hongBaoOrderService;
-
- @Resource
- private OrderHongBaoMapService orderHongBaoMapService;
-
- @Resource
- private CommonOrderService commonOrderService;
-
- @Resource
- private HongBaoManageService hongBaoManageService;
-
- @Resource
- private UserVIPInfoService userVIPInfoService;
-
- @Resource
- 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);
- }
-
- @Override
- public List<InviteOrderSubsidy> listByOrderNoAndType(String orderNo, Integer type) {
- return inviteOrderSubsidyMapper.listByOrderNoAndType(orderNo, type);
- }
-
- 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, "鏁版嵁涓嶅畬鏁�");
- InviteOrderSubsidy old = getByOrderNoAndType(orderSubsidy.getUid(), orderSubsidy.getOrderNo(),
- orderSubsidy.getSourceType());
- if (old != null) {// 淇敼
- if (old.getState() == InviteOrderSubsidy.STATE_INVALID
- || old.getState() == InviteOrderSubsidy.STATE_SUBSIDIZED)
- return;
-
- // 淇敼鐘舵��
- InviteOrderSubsidy update = new InviteOrderSubsidy(old.getId());
- update.setMoney(orderSubsidy.getMoney());
- if (old.getState() == InviteOrderSubsidy.STATE_UNKNOWN) {// 鐘舵�佹湭纭畾涔嬪墠鎵嶅彲浠ユ洿鏀瑰師濮嬭ˉ璐磋祫閲�
- update.setOriginalMoney(orderSubsidy.getOriginalMoney());
- }
- update.setState(orderSubsidy.getState());
- update.setUpdateTime(new Date());
- inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);
- } else {// 娣诲姞
- if (orderSubsidy.getCreateTime() == null)
- 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_SHARE_GOODS || parent.getType() == HongBaoV2.TYPE_ZIGOU)) {//
-
- List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(sourceType, orderId);
- if (orderList == null || orderList.size() == 0)
- throw new InviteOrderSubsidyException(10, "璁㈠崟涓虹┖");
- CommonOrder firstOrder = orderList.get(0);
- Date placeOrderTime = firstOrder.getThirdCreateTime();
-
- if (placeOrderTime.getTime() < Constant.NEW_ORDER_FANLI_RULE_TIME)
- return;
-
- int urank = firstOrder.getUrank();
- UserLevelEnum buyerUserLevel = UserLevelUtil.getByOrderRank(urank);
- if (buyerUserLevel == null)
- throw new InviteOrderSubsidyException(11, "鐢ㄦ埛绛夌骇涓虹┖");
-
- 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);
- Integer state = InviteOrderSubsidy.STATE_UNKNOWN;
-
- // 浜х敓鏀硅鍗曠殑杩斿埄鎬婚噾棰�
- BigDecimal totalBuyFanLiMoney = new BigDecimal(0);
- // 璁＄畻鎬昏繑鍒�
- for (HongBaoV2 v2 : hbList) {
- if (v2.getState() == HongBaoV2.STATE_BUKELINGQU || v2.getState() == HongBaoV2.STATE_KELINGQU
- || v2.getState() == HongBaoV2.STATE_YILINGQU)
- totalBuyFanLiMoney = totalBuyFanLiMoney.add(v2.getMoney());
- }
-
- // 璁＄畻濂栧姳閲�
- for (Iterator<Long> its = uidHongBaoMap.keySet().iterator(); its.hasNext();) {
- Long uid = its.next();
- UserLevelEnum userLevel = userLevelManager.getUserLevel(uid, placeOrderTime);
-
- int type = uidHongBaoMap.get(uid);
- if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_ERJI
- || type == HongBaoV2.TYPE_SHARE_YIJI || type == HongBaoV2.TYPE_SHARE_ERJI) {
- BigDecimal money = null;
- if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_SHARE_YIJI)
- money = orderHongBaoMoneyComputeService.computeFirstTeamSubsidy(totalBuyFanLiMoney,
- placeOrderTime, buyerUserLevel, userLevel);
- else
- money = orderHongBaoMoneyComputeService.computeSecondTeamSubsidy(totalBuyFanLiMoney,
- placeOrderTime, buyerUserLevel, userLevel);
-
- if (money == null)
- continue;
-
- 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 || type == HongBaoV2.TYPE_SHARE_YIJI)
- orderSubsidy.setLevel(InviteOrderSubsidy.LEVEL_ONE);
- else
- orderSubsidy.setLevel(InviteOrderSubsidy.LEVEL_TWO);
-
- try {
- addOrderSubsidy(orderSubsidy);
- } catch (CommonOrderException e) {
- throw new InviteOrderSubsidyException(e.getCode(), e.getMsg());
- }
- }
- }
-
- boolean isSettle = false;
- if (orderList != null)
- for (CommonOrder commonOrder : orderList) {
- if (commonOrder.getState() == CommonOrder.STATE_JS
- || commonOrder.getState() == CommonOrder.STATE_WQ) {
- isSettle = true;
- break;
- }
- }
- if (isSettle) {
- validByOrderIdAndSourceType(orderId, sourceType);
- }
- }
- }
- }
-
- }
-
- @Override
- public long countByOrderIdAndSourceType(String orderId, int sourceType) {
- return inviteOrderSubsidyMapper.countByOrderNoAndType(orderId, sourceType);
- }
-
- @Transactional(rollbackFor = Exception.class)
- @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(rollbackFor = Exception.class)
- @Override
- 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) {
- 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());
- update.setPreGetTime(preGetTime);
- inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);
- }
- }
- }
-
- @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);
- }
-
- @Override
- public BigDecimal sumRecievedMoneyByUid(long uid, Integer level) {
- BigDecimal money = inviteOrderSubsidyMapper.sumRecievedMoneyByUid(uid, level);
- if (money == null) {
- money = new BigDecimal(0);
- }
- return money;
- }
-
- @Override
- public BigDecimal sumValidMoneyByUidAndDate(long uid, Integer day, Integer level) {
- BigDecimal money = inviteOrderSubsidyMapper.sumValidMoneyByUidAndDate(uid, day, level);
- if (money == null) {
- money = new BigDecimal(0);
- }
- return money;
- }
-
- @Override
- public BigDecimal sumMoneyByUidAndDateAndState(long uid, Integer day, Integer level, Integer state) {
- BigDecimal money = inviteOrderSubsidyMapper.sumMoneyByUidAndDateAndState(uid, day, level, state);
- if (money == null) {
- money = new BigDecimal(0);
- }
- return money;
- }
-
- @Override
- public List<InviteOrderSubsidy> listByOrderNoAndTypeAndUid(String orderNo, Integer type, Long uid) {
- return inviteOrderSubsidyMapper.listByOrderNoAndTypeAndUid(orderNo, type, uid);
}
}
--
Gitblit v1.8.0