blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2022-09-08 42f399525b68f57f0f8491f455c0488c27c293d5 
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java


@@ -1,30 +1,28 @@


package cc.mrbird.febs.mall.service.impl;




import cc.mrbird.febs.common.entity.FebsResponse;


import cc.mrbird.febs.common.enumerates.DataDictionaryEnum;


import cc.mrbird.febs.common.enumerates.OrderDeliveryStateEnum;


import cc.mrbird.febs.common.enumerates.OrderStatusEnum;


import cc.mrbird.febs.common.enumerates.*;


import cc.mrbird.febs.common.properties.XcxProperties;


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.DataDictionaryCustomMapper;


import cc.mrbird.febs.mall.mapper.MallMemberMapper;


import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper;


import cc.mrbird.febs.mall.mapper.MallTeamLeaderMapper;


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.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.service.IMallMoneyFlowService;


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;


import cc.mrbird.febs.pay.util.WeixinServiceUtil;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import com.baomidou.mybatisplus.core.metadata.IPage;


@@ -33,9 +31,11 @@


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections.CollectionUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.math.BigDecimal;


import java.util.Arrays;


import java.util.HashMap;


import java.util.List;


@@ -53,6 +53,15 @@


    private final IXcxPayService iXcxPayService;


    private final SpringContextHolder springContextHolder;


    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


@@ -156,12 +165,13 @@


            OrderStateDto orderStateDto = new OrderStateDto();


            orderStateDto.setOrderNo(mallOrderInfo.getOrderNo());


            String productNames = getProductNames(mallOrderInfo.getMemberId(), mallOrderInfo.getId());


            orderStateDto.setGoodsName(StrUtil.sub(StrUtil.isEmpty(productNames)?"商品":productNames,0,10)+"...");


            orderStateDto.setOrderState("已送达");


            orderStateDto.setGoodsName(StrUtil.sub(productNames,0,10)+"...");


            orderStateDto.setOrderState("待自提");


            orderStateDto.setTakeCode(mallOrderInfo.getTakeCode());


            String takeUniqueCode = mallOrderInfo.getTakeUniqueCode();


            MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(takeUniqueCode);


            orderStateDto.setAddressArea(StrUtil.sub(mallTeamLeader.getAddressArea(),0,10)+"...");


            orderStateDto.setDetailAddress(StrUtil.sub(mallTeamLeader.getDetailAddress(),0,10)+"...");


            orderStateDto.setOpenId(mallMemberMapper.selectById(mallOrderInfo.getMemberId()).getOpenId());


            DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WX_TEMPLATE_ID_ONE.getType(), DataDictionaryEnum.WX_TEMPLATE_ID_ONE.getCode());


            orderStateDto.setTemplateId(dataDictionaryCustom.getValue());


@@ -248,7 +258,16 @@


    @Override


    public FebsResponse findTeamOrderMarkCnt() {


        MallMember loginUser = LoginUserUtil.getLoginUser();


        MallTeamLeader mallTeamLeader = this.baseMapper.selectLeaderByUniqueCode(loginUser.getInviteId());


        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)){


            return new FebsResponse().success();


        }


        String uniqueCode = mallTeamLeader.getUniqueCode();


        List<Map<String, Integer>> maps = mallOrderInfoMapper.selectMemberOrderStatusCntByUniquecode(uniqueCode);


        Map<Integer, Integer> orderCnt = new HashMap<>();


@@ -262,4 +281,150 @@


        return new FebsResponse().success().data(result);


    }




    @Override


    @Transactional


    public FebsResponse leaderRefundOrder(ApiLeaderRefundOrderDto apiLeaderRefundOrderDto) {


        //获取退款订单信息


        Long orderId = apiLeaderRefundOrderDto.getOrderId();


        Long itemId = apiLeaderRefundOrderDto.getItemId();




        MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectById(orderId);


        MallOrderItem mallOrderItem = mallOrderItemMapper.selectById(itemId);


        List<MallRefundEntity> mallRefundEntities = mallRefundMapper.selectByItemIdAndOrderIdAndState(itemId, orderId, 3);


        if(CollUtil.isEmpty(mallRefundEntities)){


            return new FebsResponse().fail().message("退款失败，请联系客服人员");


        }


        MallRefundEntity mallRefundEntity = mallRefundEntities.get(0);




        Integer agreeState = apiLeaderRefundOrderDto.getAgreeState() == null? 2:apiLeaderRefundOrderDto.getAgreeState();


        if(2 == agreeState){


            //更新订单详情


            mallOrderItem.setState(1);


            mallOrderItemMapper.updateById(mallOrderItem);


            //更新退款订单


            mallRefundEntity.setState(2);


            mallRefundEntity.setUpdatedTime(DateUtil.date());


            mallRefundMapper.updateById(mallRefundEntity);


            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();




            //余额支付退款


            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());




                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("退款成功");


            }




            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("退款成功");


        }


    }




    @Override


    public FebsResponse refundOrderInfo(ApiRefundOrderInfoDto apiRefundOrderInfoDto) {


        Long orderId = apiRefundOrderInfoDto.getOrderId();


        Long itemId = apiRefundOrderInfoDto.getItemId();




        List<MallRefundEntity> mallRefundEntities = mallRefundMapper.selectByItemIdAndOrderIdAndState(itemId, orderId, null);


        if(CollUtil.isEmpty(mallRefundEntities)){


            return new FebsResponse().fail().message("退款信息不存在");


        }


        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());


    }




}