From ab6603d889f482459c1812e52ce2c5c04fe8e3e7 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Thu, 08 Sep 2022 09:53:10 +0800 Subject: [PATCH] 20220902 --- src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java | 171 ++++++++++++++++++++++++++++++++++++++------------------ 1 files changed, 116 insertions(+), 55 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java index 453bf97..d127eb4 100644 --- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java @@ -6,18 +6,17 @@ import cc.mrbird.febs.common.utils.LoginUserUtil; import cc.mrbird.febs.common.utils.ShareCodeUtil; import cc.mrbird.febs.common.utils.SpringContextHolder; +import cc.mrbird.febs.mall.conversion.MallLeaderAchieveConversion; import cc.mrbird.febs.mall.conversion.MallOrderInfoConversion; import cc.mrbird.febs.mall.conversion.MallTeamLeaderConversion; import cc.mrbird.febs.mall.dto.*; import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.service.IAdminMallOrderService; +import cc.mrbird.febs.mall.service.IApiMallMemberWalletService; import cc.mrbird.febs.mall.service.IApiMallTeamLeaderService; import cc.mrbird.febs.mall.service.IMallMoneyFlowService; -import cc.mrbird.febs.mall.vo.ApiLeaderInfoVo; -import cc.mrbird.febs.mall.vo.ApiLeaderListVo; -import cc.mrbird.febs.mall.vo.ApiMallleaderStateVo; -import cc.mrbird.febs.mall.vo.OrderListVo; +import cc.mrbird.febs.mall.vo.*; import cc.mrbird.febs.pay.model.OrderStateDto; import cc.mrbird.febs.pay.service.IXcxPayService; import cc.mrbird.febs.pay.util.WechatConfigure; @@ -56,6 +55,13 @@ private final DataDictionaryCustomMapper dataDictionaryCustomMapper; private final MallOrderItemMapper mallOrderItemMapper; private final MallRefundMapper mallRefundMapper; + @Autowired + private WeixinServiceUtil weixinServiceUtil; + private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class); + private final IMallMoneyFlowService mallMoneyFlowService; + private final IApiMallMemberWalletService memberWalletService; + private final MallLeaderAchieveMapper mallLeaderAchieveMapper; + private final MallMoneyFlowMapper mallMoneyFlowMapper; @Override @Transactional @@ -253,7 +259,9 @@ MallMember loginUser = LoginUserUtil.getLoginUser(); Long memberId = loginUser.getId(); MallMember mallMember = mallMemberMapper.selectById(memberId); - + if(ObjectUtil.isEmpty(mallMember)){ + return new FebsResponse().success(); + } log.info(mallMember.getInviteId()); MallTeamLeader mallTeamLeader = this.baseMapper.selectLeaderByUniqueCode(mallMember.getInviteId()); if(ObjectUtil.isEmpty(mallTeamLeader)){ @@ -271,13 +279,6 @@ result.put("order", orderCnt); return new FebsResponse().success().data(result); } - - - - @Autowired - private WeixinServiceUtil weixinServiceUtil; - private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class); - private final IMallMoneyFlowService mallMoneyFlowService; @Override @Transactional @@ -303,54 +304,81 @@ mallRefundEntity.setState(2); mallRefundEntity.setUpdatedTime(DateUtil.date()); mallRefundMapper.updateById(mallRefundEntity); - } - //退款订单编号 - String orderNo = mallOrderInfo.getOrderNo(); - //退款退款编号 - String refundNo = mallRefundEntity.getRefundNo(); - //退款订单金额 - BigDecimal orderAmount = mallOrderInfo.getAmount(); - BigDecimal aa = new BigDecimal(100); - int orderMoney = orderAmount.multiply(aa).intValue(); + return new FebsResponse().success().message("操作成功"); + }else{//退款订单编号 + String orderNo = mallOrderInfo.getOrderNo(); + //退款退款编号 + String refundNo = mallRefundEntity.getRefundNo(); + //退款订单金额 + BigDecimal orderAmount = mallOrderInfo.getAmount(); + BigDecimal aa = new BigDecimal(100); + int orderMoney = orderAmount.multiply(aa).intValue(); - //退款退款金额 - BigDecimal refundAmount = mallRefundEntity.getAmount(); - BigDecimal bb = new BigDecimal(100); - int refundMoney = refundAmount.multiply(bb).intValue(); + //退款退款金额 + BigDecimal refundAmount = mallRefundEntity.getAmount(); + BigDecimal bb = new BigDecimal(100); + int refundMoney = refundAmount.multiply(bb).intValue(); - Boolean flag = false; - Boolean debug = xcxProperties.getDebug(); - if (debug) { - boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, 1, 1, null); - flag = b; - } else { - log.info("开始调用退款接口。。。退款编号为{}", refundNo); - boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, orderMoney, refundMoney, null); - flag = b; - } + //余额支付退款 + if(mallRefundEntity.getType() == 3){ + //更新订单详情 + mallOrderItem.setState(3); + mallOrderItemMapper.updateById(mallOrderItem); + //更新退款订单 + mallRefundEntity.setState(1); + mallRefundEntity.setUpdatedTime(DateUtil.date()); + mallRefundMapper.updateById(mallRefundEntity); + mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue()); - if(flag){ - //更新订单详情 - mallOrderItem.setState(3); - mallOrderItemMapper.updateById(mallOrderItem); - //更新退款订单 - mallRefundEntity.setState(1); - mallRefundEntity.setUpdatedTime(DateUtil.date()); - mallRefundMapper.updateById(mallRefundEntity); - mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue()); - - List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByStateAndOrderId(1,orderId); - if(CollUtil.isEmpty(mallOrderItemList)){ - MallOrderInfo mallOrderRefund = mallOrderInfoMapper.selectById(orderId); - mallOrderRefund.setStatus(6); - mallOrderInfoMapper.updateById(mallOrderRefund); + List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByNotInStateAndOrderId(3,orderId); + if(CollUtil.isEmpty(mallOrderItemList)){ + MallOrderInfo mallOrderRefund = mallOrderInfoMapper.selectById(orderId); + mallOrderRefund.setStatus(6); + mallOrderInfoMapper.updateById(mallOrderRefund); + } + memberWalletService.add(refundAmount, mallOrderInfo.getMemberId(), "balance"); + return new FebsResponse().success().message("退款成功"); } - }else{ - mallRefundEntity.setState(2); - mallRefundMapper.updateById(mallRefundEntity); - return new FebsResponse().fail().message("退款失败,请联系客服人员"); + + Boolean flag = false; + Boolean debug = xcxProperties.getDebug(); + if (debug) { + boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, 1, 1, null); + flag = b; + } else { + log.info("开始调用退款接口。。。退款编号为{}", refundNo); + boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, orderMoney, refundMoney, null); + flag = b; + } + + if(flag){ + //更新订单详情 + mallOrderItem.setState(3); + mallOrderItemMapper.updateById(mallOrderItem); + //更新退款订单 + mallRefundEntity.setState(1); + mallRefundEntity.setUpdatedTime(DateUtil.date()); + mallRefundMapper.updateById(mallRefundEntity); + mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue()); + + List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByNotInStateAndOrderId(3,orderId); + if(CollUtil.isEmpty(mallOrderItemList)){ + MallOrderInfo mallOrderRefund = mallOrderInfoMapper.selectById(orderId); + mallOrderRefund.setStatus(6); + mallOrderInfoMapper.updateById(mallOrderRefund); + } + }else{ + + //更新订单详情 + mallOrderItem.setState(1); + mallOrderItemMapper.updateById(mallOrderItem); + + mallRefundEntity.setState(2); + mallRefundMapper.updateById(mallRefundEntity); + return new FebsResponse().fail().message("退款失败,请联系客服人员"); + } + return new FebsResponse().success().message("退款成功"); } - return new FebsResponse().success().message("退款成功"); } @Override @@ -365,4 +393,37 @@ return new FebsResponse().success().data(mallRefundEntities.get(0)); } + @Override + public FebsResponse leaderProfit() { + MallMember loginUser = LoginUserUtil.getLoginUser(); + ApiLeaderProfitVo apiLeaderProfitVo = new ApiLeaderProfitVo(); + + BigDecimal totalProfit = mallMoneyFlowMapper.selectAmountByFlowtypeAndType(loginUser.getId(),FlowTypeEnum.BALANCE.getValue(),MoneyFlowTypeEnum.LEADERACHIEVE.getValue(),null,null,null); + apiLeaderProfitVo.setTotalProfit(totalProfit); + BigDecimal todayProfit = mallMoneyFlowMapper.selectAmountByFlowtypeAndType(loginUser.getId(),FlowTypeEnum.BALANCE.getValue(), + MoneyFlowTypeEnum.LEADERACHIEVE.getValue(), + null,DateUtil.date(), + null); + apiLeaderProfitVo.setTodayProfit(todayProfit); + + BigDecimal monthProfit = mallMoneyFlowMapper.selectAmountByFlowtypeAndType(loginUser.getId(),FlowTypeEnum.BALANCE.getValue(), + MoneyFlowTypeEnum.LEADERACHIEVE.getValue(), + null,null, + DateUtil.date()); + apiLeaderProfitVo.setMonthProfit(monthProfit); + BigDecimal waitProfit = mallLeaderAchieveMapper.selectProfitByStateAndDateTimeAndUniqueCode(1,null,loginUser.getInviteId()).setScale(2,BigDecimal.ROUND_DOWN); + apiLeaderProfitVo.setWaitProfit(waitProfit); + + return new FebsResponse().success().data(apiLeaderProfitVo); + } + + @Override + public List<ApiOrderProfitVo> findLeaderProfitListInPage(ApiOrderProfitDto apiOrderProfitDto) { + MallMember member = LoginUserUtil.getLoginUser(); + IPage<MallLeaderAchieve> page = new Page<>(apiOrderProfitDto.getPageNum(), apiOrderProfitDto.getPageSize()); + apiOrderProfitDto.setInvitedId(member.getInviteId()); + IPage<MallLeaderAchieve> mallLeaderAchieves = mallLeaderAchieveMapper.selectApiLeaderProfitListInPage(page, apiOrderProfitDto); + return MallLeaderAchieveConversion.INSTANCE.entitysToVos(mallLeaderAchieves.getRecords()); + } + } -- Gitblit v1.9.1