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 | 213 ----------------------------------------------------- 1 files changed, 0 insertions(+), 213 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..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 @@ -74,15 +74,6 @@ 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 { @@ -110,210 +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_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